package message

import (
	"context"
	"testing"
	"time"

	"github.com/stretchr/testify/require"
)

func TestListSubscribedThreadsDeduplicatesDuplicateOpenParentMemberships(t *testing.T) {
	t.Parallel()

	ctx := context.Background()
	db := startMessagingTestPool(t, ctx)
	now := time.Date(2026, 6, 16, 15, 30, 0, 0, time.UTC)
	fixture := seedReplyThreadSubscriptionFixture(t, ctx, db, "duplicate_parent_membership", now)
	mustExecMessaging(t, ctx, db, `
INSERT INTO scope_memberships (
    scope_id, member_id, visibility, owner_member_id, last_read_seq,
    last_read_global_seq, last_activity_global_seq, owner_context_dismissed_through_global_seq,
    effective_from_seq, effective_to_seq, created_at, updated_at, removed_at, archived_at
)
VALUES ($1, $2, 'public', NULL, 0, 0, 0, 0, 1, NULL, $3, $3, NULL, NULL)
`, fixture.channelID, fixture.ownerMemberID, now.Add(time.Minute))
	require.NoError(t, ActivateThreadSubscription(ctx, db, fixture.ownerMemberID, fixture.threadChannelID, now.Add(2*time.Minute)))

	store := New(db, nil, 0, Options{})
	threads, err := store.ListSubscribedThreadsForUserWithLimit(ctx, fixture.ownerUserID, fixture.workspaceID, 0)
	require.NoError(t, err)
	require.Equal(t, []string{fixture.threadChannelID}, subscribedThreadIDsForTest(threads))

	page, err := store.ListSubscribedThreadInboxPageForUser(ctx, fixture.ownerUserID, fixture.workspaceID, 10, ThreadInboxCursor{})
	require.NoError(t, err)
	require.Equal(t, []string{fixture.threadChannelID}, subscribedThreadPageIDsForTest(page.Threads))

	count, err := store.CountSubscribedThreadsForUser(ctx, fixture.ownerUserID, fixture.workspaceID)
	require.NoError(t, err)
	require.Equal(t, int64(1), count.Count)
}