feat(conversations): filter meta query source

internal/repository/conversation_repo.go

@@ -397,6 +397,8 @@ type ConversationMetaParams struct {
 	TeamID             *uint
 	Labels             []string
 	ConversationType   string
+	Query              string
+	SourceID           string
 	RestrictedInboxIDs []uint
 	RestrictToInboxes  bool
 }
@@ -446,6 +448,16 @@ func (r *ConversationRepo) conversationMetaBaseQuery(ctx context.Context, accoun
 			query = query.Where(r.db.Where(strings.Join(conditions, " OR "), args...).Or("conversations.id IN (?)", tagSubquery))
 		}
 	}
+	if strings.TrimSpace(params.Query) != "" {
+		searchTerm := "%" + strings.TrimSpace(params.Query) + "%"
+		query = query.Joins("JOIN messages ON messages.conversation_id = conversations.id").
+			Where("messages.content LIKE ?", searchTerm).
+			Where("messages.message_type IN ?", []string{string(model.MessageTypeIncoming), string(model.MessageTypeOutgoing)})
+	}
+	if strings.TrimSpace(params.SourceID) != "" {
+		query = query.Joins("JOIN contact_inboxes ON contact_inboxes.id = conversations.contact_inbox_id").
+			Where("contact_inboxes.source_id = ?", strings.TrimSpace(params.SourceID))
+	}
 
 	switch params.ConversationType {
 	case "mention":

internal/repository/conversation_repo_test.go

@@ -523,6 +523,39 @@ func TestConversationRepo_GetMeta_FiltersStatusLabelsAndConversationType(t *test
 	assert.Equal(t, int64(1), meta.UnassignedCount)
 }
 
+func TestConversationRepo_GetMeta_FiltersQueryAndSourceID(t *testing.T) {
+	db := setupTestDB(t)
+	repo := NewConversationRepo(db)
+	userID := uint(88)
+
+	account := &model.Account{Name: "MetaQueryOrg", Locale: "en", Active: true}
+	require.NoError(t, db.Create(account).Error)
+	inbox := &model.Inbox{AccountID: account.ID, Name: "MetaQueryInbox", ChannelType: "web_widget", ChannelID: 1}
+	require.NoError(t, db.Create(inbox).Error)
+	contact := &model.Contact{AccountID: account.ID, Name: "MetaQueryContact"}
+	require.NoError(t, db.Create(contact).Error)
+	contactInbox := &model.ContactInbox{ContactID: contact.ID, InboxID: inbox.ID, SourceID: "source-a"}
+	require.NoError(t, db.Create(contactInbox).Error)
+	otherContactInbox := &model.ContactInbox{ContactID: contact.ID, InboxID: inbox.ID, SourceID: "source-b"}
+	require.NoError(t, db.Create(otherContactInbox).Error)
+
+	match := createTestConversation(t, db, account.ID, inbox.ID, contact.ID, "open")
+	require.NoError(t, db.Model(match).Updates(map[string]any{"contact_inbox_id": contactInbox.ID, "assignee_id": userID}).Error)
+	otherSource := createTestConversation(t, db, account.ID, inbox.ID, contact.ID, "open")
+	require.NoError(t, db.Model(otherSource).Update("contact_inbox_id", otherContactInbox.ID).Error)
+	activityOnly := createTestConversation(t, db, account.ID, inbox.ID, contact.ID, "open")
+	require.NoError(t, db.Model(activityOnly).Update("contact_inbox_id", contactInbox.ID).Error)
+
+	require.NoError(t, db.Create(&model.Message{AccountID: account.ID, InboxID: inbox.ID, ConversationID: match.ID, Content: "needle visible", MessageType: string(model.MessageTypeIncoming)}).Error)
+	require.NoError(t, db.Create(&model.Message{AccountID: account.ID, InboxID: inbox.ID, ConversationID: otherSource.ID, Content: "needle wrong source", MessageType: string(model.MessageTypeOutgoing)}).Error)
+	require.NoError(t, db.Create(&model.Message{AccountID: account.ID, InboxID: inbox.ID, ConversationID: activityOnly.ID, Content: "needle activity", MessageType: string(model.MessageTypeActivity)}).Error)
+
+	meta, err := repo.GetMeta(context.Background(), account.ID, userID, ConversationMetaParams{Query: "needle", SourceID: "source-a"})
+	require.NoError(t, err)
+	assert.Equal(t, int64(1), meta.AllCount)
+	assert.Equal(t, int64(1), meta.MineCount)
+}
+
 // ========== MarkUnread Tests ==========
 
 func TestConversationRepo_MarkUnread(t *testing.T) {