queue.go

package main

import (
	"context"
	"log"
	"time"

	"github.com/go-telegram/bot"
	"github.com/go-telegram/bot/models"
)

type InlineQueryJob struct {
	ID    string
	Query string
	From  models.User
}

func processInqueryQueue(ctx context.Context, b *bot.Bot) {
	for {
		time.Sleep(50 * time.Millisecond)

		var batch []InlineQueryJob
		drain:
		for {
			select {
				case job := <-inqueryQueue:
					batch = append(batch, job)
				default:
					break drain
			}
		}
		if len(batch) == 0 {
			continue
		}

		groups := make(map[string][]InlineQueryJob)
		for _, job := range batch {
			groups[job.Query] = append(groups[job.Query], job)
		}
		for _, jobs := range groups {
			go func(ctx context.Context, b *bot.Bot, jobs []InlineQueryJob) {
				for _, job := range jobs {
					_, err := b.AnswerInlineQuery(ctx, &bot.AnswerInlineQueryParams{
						InlineQueryID: job.ID,
						Results:       buildRpArticles(job.Query, job.From),
								      CacheTime:     1,
					})
					if err != nil {
						log.Printf("failed to answer inline query %s: %s", job.ID, err)
					}
				}
			}(ctx, b, jobs)
		}

		time.Sleep(950 * time.Millisecond)
	}
}