bot.go

func (b *bot) runLoop(ctx *schema.Ctx) {
	b.log.Info(ctx, "Initializing bot, channel id=%d", b.channelId)

init:

	retryCounter := 0

	for {
		err := b.init(ctx)
		if err == nil {
			break
		}

		retryCounter++
		retryTimeout := retry.Delay(retryCounter)

		b.log.Info(ctx, "Failed to initialize, retry in %ds, error=%v", retryTimeout/time.Second, err)

		select {
		case <-b.stop:
			goto stop

		case <-time.After(retryTimeout):
			continue
		}
	}

	b.log.Info(ctx, "Bot initialized, channel id=%d", b.channelId)

	retryCounter = 0

	for {
		err := b.sendNextMessage(ctx)
		delay := time.Duration(0)

		switch {
		case err == sql.ErrNoRows:
			retryCounter = 0
			delay = time.Second * 30
		case err == nil:
			retryCounter = 0
		default:
			retryCounter++
			delay = retry.Delay(retryCounter)
		}

		select {
		case <-bot.stop:
			goto stop

		case <-bot.configChanged:
			goto init

		case <-bot.send:
			if retryCounter == 0 {
				continue
			}

		case <-time.After(delay):
			continue
		}
	}

stop:

	b.log.Info(ctx, "Bot stopped, channel id=%d", b.channelId)
	close(b.stopped)
}