wire_metadata_test.go RawHistoryFolder

1package daemon
2
3import (
4	"fmt"
5	"sync"
6	"testing"
7
8	"github.com/bnema/vev/internal/ports"
9)
10
11func TestFrameWelcomeSnapshotsSessionMetadataUnderLock(t *testing.T) {
12	sess := &session{sessionCore: sessionCore{id: "session", name: "initial"}}
13	ac := &attachedClient{resumeToken: 42}
14
15	var wg sync.WaitGroup
16	wg.Go(func() {
17		for i := range 1000 {
18			sess.mu.Lock()
19			sess.name = fmt.Sprintf("session-%d", i)
20			sess.ephemeral = i%2 == 0
21			sess.mu.Unlock()
22		}
23	})
24
25	for range 1000 {
26		frame, frameErr := frameWelcome(sess, ac.resumeToken)
27		if frameErr != nil {
28			t.Fatalf("frameWelcome() error = %v", frameErr)
29		}
30		welcome, err := ports.UnmarshalWelcome(frame.Payload)
31		if err != nil {
32			t.Fatalf("UnmarshalWelcome() error = %v", err)
33		}
34		if welcome.SessionID != "session" || welcome.SessionName == "" {
35			t.Fatalf("welcome metadata = %+v", welcome)
36		}
37	}
38	wg.Wait()
39}