feat: update GitHub bot command handling, database layer, and repository webhook integration

Author: bisug

internal/bot/callbacks/callbacks.go

@@ -684,8 +684,9 @@ func (h *CallbackHandler) handleAddRepoByID(b *gotgbot.Bot, ctx *ext.Context, re
 
 	webhookID := createdHook.GetID()
 	link := models.RepoLink{
-		RepoFullName: repo.GetFullName(),
-		WebhookID:    webhookID,
+		RepoFullName:    repo.GetFullName(),
+		WebhookID:       webhookID,
+		MessageThreadID: ctx.EffectiveMessage.MessageThreadId,
 	}
 
 	err = h.DB.AddRepoLink(context.Background(), ctx.EffectiveChat.Id, link)

internal/bot/commands/commands.go

@@ -272,8 +272,9 @@ func (h *CommandHandler) AddRepo(b *gotgbot.Bot, ctx *ext.Context) error {
 
 	webhookID := createdHook.GetID()
 	link := models.RepoLink{
-		RepoFullName: repoFullName,
-		WebhookID:    webhookID,
+		RepoFullName:    repoFullName,
+		WebhookID:       webhookID,
+		MessageThreadID: ctx.EffectiveMessage.MessageThreadId,
 	}
 
 	err = h.DB.AddRepoLink(context.Background(), ctx.EffectiveChat.Id, link)

internal/db/db.go

@@ -180,6 +180,22 @@ func (d *DB) GetRepoLink(ctx context.Context, chatID int64, repoFullName string)
 	return nil, errors.New("link not found")
 }
 
+// GetRepoLinkByWebhookID returns a specific repository link by webhook ID
+func (d *DB) GetRepoLinkByWebhookID(ctx context.Context, chatID int64, webhookID int64) (*models.RepoLink, error) {
+	links, err := d.GetChatLinks(ctx, chatID)
+	if err != nil {
+		return nil, err
+	}
+
+	for _, link := range links {
+		if link.WebhookID == webhookID {
+			return &link, nil
+		}
+	}
+
+	return nil, errors.New("link not found")
+}
+
 // GetChatsForRepo finds all chats subscribed to a given repository.
 func (d *DB) GetChatsForRepo(ctx context.Context, repoFullName string) ([]models.Chat, error) {
 	cursor, err := d.Chats.Find(ctx, bson.M{"links.repo_full_name": repoFullName})

internal/github/webhooks.go

@@ -136,12 +136,21 @@ func (s *WebhookServer) processEvent(event interface{}, chatID int64, hookID int
 
 	msg = normalizeMessage(msg)
 
+	var threadID int64
+	if hookID != 0 {
+		link, err := s.DB.GetRepoLinkByWebhookID(context.Background(), chatID, hookID)
+		if err == nil && link != nil {
+			threadID = link.MessageThreadID
+		}
+	}
+
 	opts := &gotgbot.SendMessageOpts{
 		ParseMode: "MarkdownV2",
 		LinkPreviewOptions: &gotgbot.LinkPreviewOptions{
 			IsDisabled: true,
 		},
-		ReplyMarkup: markup,
+		ReplyMarkup:     markup,
+		MessageThreadId: threadID,
 	}
 
 	sentMsg, err := s.Bot.SendMessage(chatID, msg, opts)
@@ -151,7 +160,8 @@ func (s *WebhookServer) processEvent(event interface{}, chatID int64, hookID int
 			LinkPreviewOptions: &gotgbot.LinkPreviewOptions{
 				IsDisabled: true,
 			},
-			ReplyMarkup: markup,
+			ReplyMarkup:     markup,
+			MessageThreadId: threadID,
 		}
 		sentMsg, err = s.Bot.SendMessage(chatID, plainTextForTelegram(msg), fallbackOpts)
 		if err != nil {

internal/models/models.go

@@ -15,8 +15,9 @@ type User struct {
 
 // RepoLink represents a link to a GitHub repository within a chat
 type RepoLink struct {
-	RepoFullName string `bson:"repo_full_name" json:"repo_full_name"`
-	WebhookID    int64  `bson:"webhook_id,omitempty" json:"webhook_id,omitempty"`
+	RepoFullName    string `bson:"repo_full_name" json:"repo_full_name"`
+	WebhookID       int64  `bson:"webhook_id,omitempty" json:"webhook_id,omitempty"`
+	MessageThreadID int64  `bson:"message_thread_id,omitempty" json:"message_thread_id,omitempty"`
 }
 
 // Chat represents a Telegram chat (group, channel, or private)