go/chat/transcripts_test.go - master - githubmirror/client

go/chat/transcripts_test.go
154 строки4 KB
chrisnojima-zoom
Version 670 - clean2 (#29122)
08 июн 2026, 19:31
08 июн 2026, 19:311943197
package chat

import (
	"fmt"
	"strings"
	"testing"

	"github.com/keybase/client/go/kbun"

	"github.com/keybase/client/go/protocol/chat1"
	"github.com/keybase/client/go/protocol/keybase1"
	"github.com/stretchr/testify/require"
)

func TestTranscript(t *testing.T) {
	t.Skip("Y2K-1384")
	runWithMemberTypes(t, func(mt chat1.ConversationMembersType) {
		// Only run this test for imp teams
		switch mt {
		case chat1.ConversationMembersType_IMPTEAMNATIVE,
			chat1.ConversationMembersType_IMPTEAMUPGRADE:
		default:
			return
		}

		ctc := makeChatTestContext(t, "TestTranscripts", 3)
		defer ctc.cleanup()
		users := ctc.users()

		tc1 := ctc.world.Tcs[users[0].Username]
		ctx := ctc.as(t, users[0]).startCtx

		displayName := strings.Join([]string{
			users[0].Username,
			users[1].Username,
			users[2].Username,
		}, ",")

		ncres, err := ctc.as(t, users[0]).chatLocalHandler().NewConversationLocal(ctx,
			chat1.NewConversationLocalArg{
				TlfName:          displayName,
				TopicType:        chat1.TopicType_CHAT,
				TlfVisibility:    keybase1.TLFVisibility_PRIVATE,
				MembersType:      mt,
				IdentifyBehavior: keybase1.TLFIdentifyBehavior_CHAT_CLI,
			})
		require.NoError(t, err)

		for i := range users {
			mustPostLocalForTest(t, ctc, users[i], ncres.Conv.Info,
				chat1.NewMessageBodyWithText(chat1.MessageText{
					Body: fmt.Sprintf("hello from user %d", i),
				}))
		}

		// Make a config for tests to ensure fetching multiple batches with
		// pagination.
		config := PullTranscriptConfig{
			messageCount: 10,
			batchSize:    2,
			batchCount:   5,
		}

		mctx := tc1.MetaContext().WithLogTag("REPORT")
		res, err := PullTranscript(mctx, tc1.Context().ConvSource,
			ncres.Conv.GetConvID().ConvIDStr(), nil, config)
		require.NoError(t, err)
		require.Len(t, res.Messages, 3)
		for i := range res.Messages {
			require.Equal(t, res.Messages[i].SenderUsername, users[2-i].Username)
		}

		mctx = tc1.MetaContext().WithLogTag("REPORT")
		usernames := []kbun.NormalizedUsername{
			kbun.NewNormalizedUsername(users[0].Username),
			kbun.NewNormalizedUsername(users[1].Username),
		}
		res, err = PullTranscript(mctx, tc1.Context().ConvSource,
			ncres.Conv.GetConvID().ConvIDStr(), usernames, config)
		require.NoError(t, err)
		require.Len(t, res.Messages, 2)
		// Messages from users[2] should be skipped.
		require.Equal(t, res.Messages[0].SenderUsername, users[1].Username)
		require.Equal(t, res.Messages[1].SenderUsername, users[0].Username)
	})
}

func TestTranscriptLimit(t *testing.T) {
	t.Skip("Y2K-1384")
	// Make sure the pagination is limited, so we don't end up digging for
	// messages in a busy channel for e.g. someone who hasn't even spoken
	// there.

	runWithMemberTypes(t, func(mt chat1.ConversationMembersType) {
		// Only run this test for imp teams
		switch mt {
		case chat1.ConversationMembersType_IMPTEAMNATIVE,
			chat1.ConversationMembersType_IMPTEAMUPGRADE:
		default:
			return
		}

		ctc := makeChatTestContext(t, "TestTranscripts", 2)
		defer ctc.cleanup()
		users := ctc.users()

		tc1 := ctc.world.Tcs[users[0].Username]
		ctx := ctc.as(t, users[0]).startCtx

		displayName := strings.Join([]string{
			users[0].Username,
			users[1].Username,
		}, ",")

		ncres, err := ctc.as(t, users[0]).chatLocalHandler().NewConversationLocal(ctx,
			chat1.NewConversationLocalArg{
				TlfName:          displayName,
				TopicType:        chat1.TopicType_CHAT,
				TlfVisibility:    keybase1.TLFVisibility_PRIVATE,
				MembersType:      mt,
				IdentifyBehavior: keybase1.TLFIdentifyBehavior_CHAT_CLI,
			})
		require.NoError(t, err)

		mustPostLocalForTest(t, ctc, users[1], ncres.Conv.Info,
			chat1.NewMessageBodyWithText(chat1.MessageText{
				Body: "hello chat",
			}))

		for i := range 10 {
			mustPostLocalForTest(t, ctc, users[0], ncres.Conv.Info,
				chat1.NewMessageBodyWithText(chat1.MessageText{
					Body: fmt.Sprintf("hello message %d", i),
				}))
		}

		// With this config, we will not be able to dig through 10 messages
		// from users[0] to reach message from users[1].
		config := PullTranscriptConfig{
			messageCount: 5,
			batchSize:    2,
			batchCount:   3,
		}

		mctx := tc1.MetaContext().WithLogTag("REPORT")
		usernames := []kbun.NormalizedUsername{
			kbun.NewNormalizedUsername(users[1].Username),
		}
		res, err := PullTranscript(mctx, tc1.Context().ConvSource,
			ncres.Conv.GetConvID().ConvIDStr(), usernames, config)
		require.NoError(t, err)
		require.Len(t, res.Messages, 0)
	})
}