feat(api): fetch members count

internal/api/api.go

@@ -4,24 +4,27 @@ import (
 	"context"
 
 	"github.com/gotd/td/telegram"
+	"github.com/gotd/td/telegram/message/peer"
 	"github.com/ogen-go/ogen/http"
 
 	"github.com/go-faster/bot/internal/ent"
 	"github.com/go-faster/bot/internal/oas"
 )
 
-func NewServer(db *ent.Client, tg *telegram.Client, ht http.Client) *Server {
+func NewServer(db *ent.Client, tg *telegram.Client, resolver peer.Resolver, ht http.Client) *Server {
 	return &Server{
-		db: db,
-		tg: tg,
-		ht: ht,
+		db:       db,
+		tg:       tg,
+		ht:       ht,
+		resolver: resolver,
 	}
 }
 
 type Server struct {
-	db *ent.Client
-	tg *telegram.Client
-	ht http.Client
+	db       *ent.Client
+	tg       *telegram.Client
+	ht       http.Client
+	resolver peer.Resolver
 }
 
 func (s Server) NewError(ctx context.Context, err error) *oas.ErrorStatusCode {

internal/api/badge.go

@@ -12,6 +12,9 @@ import (
 	"strings"
 
 	"github.com/go-faster/errors"
+	"github.com/go-faster/sdk/zctx"
+	"github.com/gotd/td/tg"
+	"go.uber.org/zap"
 
 	"github.com/go-faster/bot/internal/oas"
 )
@@ -35,22 +38,41 @@ func etag(name string, data []byte) string {
 }
 
 func (s Server) GetTelegramBadge(ctx context.Context, params oas.GetTelegramBadgeParams) (*oas.GetTelegramBadgeOKHeaders, error) {
-	members := map[string]int{
-		"gotd_en":   237,
-		"gotd_ru":   234,
-		"gotd_zhcn": 15,
-	}[params.GroupName]
-	_ = s.tg // TODO(ernado): fetch actual data.
-	title := params.Title.Or(params.GroupName)
-	text := strconv.Itoa(members)
-	u := &url.URL{
-		Scheme: "https",
-		Host:   "img.shields.io",
-		Path:   generateBadgePath(title, text, "179cde"),
+	var members int
+	{
+		peer, err := s.resolver.ResolveDomain(ctx, "@"+params.GroupName)
+		if err != nil {
+			return nil, errors.Wrap(err, "resolve domain")
+		}
+		fullChat, err := s.tg.API().MessagesGetFullChat(ctx, peer.(*tg.InputPeerChat).ChatID)
+		if err != nil {
+			return nil, errors.Wrap(err, "get chat")
+		}
+		for _, chat := range fullChat.Chats {
+			switch c := chat.(type) {
+			case *tg.Chat:
+				members = c.ParticipantsCount
+			default:
+				zctx.From(ctx).Warn("unexpected chat type",
+					zap.String("type", fmt.Sprintf("%T", chat)),
+				)
+			}
+		}
+	}
+	var (
+		title = params.Title.Or(params.GroupName)
+		text  = strconv.Itoa(members)
+		u     = &url.URL{
+			Scheme: "https",
+			Host:   "img.shields.io",
+			Path:   generateBadgePath(title, text, "179cde"),
+		}
+	)
+	{
+		q := u.Query()
+		q.Set("logo", "telegram")
+		u.RawQuery = q.Encode()
 	}
-	q := u.Query()
-	q.Set("logo", "telegram")
-	u.RawQuery = q.Encode()
 	req, err := http.NewRequestWithContext(ctx, http.MethodGet, u.String(), http.NoBody)
 	if err != nil {
 		return nil, errors.Wrap(err, "create request")

internal/cmd/internal/server/app.go

@@ -71,6 +71,7 @@ type App struct {
 	gaps          *updates.Manager
 	rdy           *Readiness
 	httpTransport *otelhttp.Transport
+	resolver      peer.Resolver
 }
 
 func initApp(m *sdkapp.Metrics, lg *zap.Logger) (_ *App, rerr error) {
@@ -129,7 +130,9 @@ func initApp(m *sdkapp.Metrics, lg *zap.Logger) (_ *App, rerr error) {
 		},
 	})
 	raw := client.API()
-	sender := message.NewSender(raw)
+	resolver := peer.DefaultResolver(raw)
+	sender := message.NewSender(raw).
+		WithResolver(resolver)
 	dd := downloader.NewDownloader()
 	httpTransport := otelhttp.NewTransport(http.DefaultTransport,
 		otelhttp.WithTracerProvider(m.TracerProvider()),
@@ -195,6 +198,7 @@ func initApp(m *sdkapp.Metrics, lg *zap.Logger) (_ *App, rerr error) {
 		token:         token,
 		raw:           raw,
 		sender:        sender,
+		resolver:      resolver,
 		dispatcher:    dispatcher,
 		mux:           mux,
 		m:             m,
@@ -325,7 +329,7 @@ func (a *App) Run(ctx context.Context) error {
 		httpClient := &http.Client{
 			Transport: a.httpTransport,
 		}
-		h, err := oas.NewServer(api.NewServer(a.db, a.client, httpClient),
+		h, err := oas.NewServer(api.NewServer(a.db, a.client, a.resolver, httpClient),
 			oas.WithMeterProvider(a.m.MeterProvider()),
 			oas.WithTracerProvider(a.m.TracerProvider()),
 		)