Fix: call the bot if something is wrong
This commit is contained in:
@ -187,10 +187,21 @@ func (b *Bot) BotMove() {
|
|||||||
eventName := models.NotifyRoomUpdatePrefix + room.ID
|
eventName := models.NotifyRoomUpdatePrefix + room.ID
|
||||||
eventPayload := ""
|
eventPayload := ""
|
||||||
defer func() { // save room
|
defer func() { // save room
|
||||||
|
// just incase, get the room once more
|
||||||
|
// room, err = repo.RoomGetExtended(context.Background(), b.RoomID)
|
||||||
|
// if err != nil {
|
||||||
|
// b.log.Error("bot loop", "error", err)
|
||||||
|
// return
|
||||||
|
// }
|
||||||
if err := saveRoom(room); err != nil {
|
if err := saveRoom(room); err != nil {
|
||||||
b.log.Error("failed to save room", "error", err)
|
b.log.Error("failed to save room", "error", err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
if botName := room.WhichBotToMove(); botName != "" {
|
||||||
|
b.log.Debug("notifying bot", "name", botName)
|
||||||
|
SignalChanMap[botName] <- true
|
||||||
|
b.log.Debug("after sending the signal", "name", botName)
|
||||||
|
}
|
||||||
broker.Notifier.Notifier <- broker.NotificationEvent{
|
broker.Notifier.Notifier <- broker.NotificationEvent{
|
||||||
EventName: eventName,
|
EventName: eventName,
|
||||||
Payload: eventPayload,
|
Payload: eventPayload,
|
||||||
@ -313,17 +324,6 @@ func (b *Bot) BotMove() {
|
|||||||
b.log.Error("unexpected role", "role", b.Role, "resp-map", tempMap)
|
b.log.Error("unexpected role", "role", b.Role, "resp-map", tempMap)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
// just incase, get the room once more
|
|
||||||
room, err = repo.RoomGetExtended(context.Background(), b.RoomID)
|
|
||||||
if err != nil {
|
|
||||||
b.log.Error("bot loop", "error", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
if botName := room.WhichBotToMove(); botName != "" {
|
|
||||||
b.log.Debug("notifying bot", "name", botName)
|
|
||||||
SignalChanMap[botName] <- true
|
|
||||||
b.log.Debug("after sending the signal", "name", botName)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// StartBot
|
// StartBot
|
||||||
|
Reference in New Issue
Block a user