package laniakea

import (
	"encoding/json"
	"fmt"
	"io"
	"net/http"

	"git.nix13.pw/scuroneko/laniakea/tgapi"
)

func (bot *Bot[T]) Updates() ([]tgapi.Update, error) {
	offset := bot.GetUpdateOffset()
	params := tgapi.UpdateParams{
		Offset:         Ptr(offset),
		Timeout:        Ptr(30),
		AllowedUpdates: bot.GetUpdateTypes(),
	}

	updates, err := bot.api.GetUpdates(params)
	if err != nil {
		return nil, err
	}

	for _, u := range updates {
		bot.SetUpdateOffset(u.UpdateID + 1)
		err = bot.GetQueue().Enqueue(&u)
		if err != nil {
			return nil, err
		}

		if bot.RequestLogger != nil {
			j, err := json.Marshal(u)
			if err != nil {
				bot.GetLogger().Error(err)
			}
			bot.RequestLogger.Debugf("UPDATE %s\n", j)
		}
	}
	return updates, err
}

func (bot *Bot[T]) GetFileByLink(link string) ([]byte, error) {
	u := fmt.Sprintf("https://api.telegram.org/file/bot%s/%s", bot.token, link)
	res, err := http.Get(u)
	if err != nil {
		return nil, err
	}
	defer res.Body.Close()
	return io.ReadAll(res.Body)
}