Function TestLocalHubPollingPicksUpExternalAppend

cli/hub_local_test.go:47–88

TestLocalHubPollingPicksUpExternalAppend proves the realtime path: a turn written by another process (a second handle on the same db, standing in for the gateway) surfaces through the polling subscription.

(t *testing.T)

// written by another process (a second handle on the same db, standing in for
// the gateway) surfaces through the polling subscription.
func TestLocalHubPollingPicksUpExternalAppend(t *testing.T) {
	path := filepath.Join(t.TempDir(), "hub.db")
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	cliStore, err := hub.OpenSQLiteStore(ctx, path, nil)
	if err != nil {
		t.Fatalf("open cli store: %v", err)
	}
	t.Cleanup(func() { _ = cliStore.Close() })
	gwStore, err := hub.OpenSQLiteStore(ctx, path, nil)
	if err != nil {
		t.Fatalf("open gw store: %v", err)
	}
	t.Cleanup(func() { _ = gwStore.Close() })

	c := newLocalHubClient(cliStore, "edilson")
	c.poll = 50 * time.Millisecond // snappy for the test

	conv, _, err := c.ResolveActiveConversation(ctx, "")
	if err != nil {
		t.Fatalf("resolve: %v", err)
	}
	stream, err := c.SubscribeConversation(ctx, conv, 0)
	if err != nil {
		t.Fatalf("subscribe: %v", err)
	}

	// The "gateway" process appends a Telegram turn on the shared conversation.
	if _, err := gwStore.Append(ctx, models.ConversationEvent{ConvID: conv, Principal: "edilson", Channel: "telegram", Role: models.ConvRoleUser, Content: "from phone"}); err != nil {
		t.Fatalf("gw append: %v", err)
	}

	select {
	case ev := <-stream:
		if ev.Content != "from phone" || ev.Channel != "telegram" {
			t.Fatalf("unexpected polled event: %+v", ev)
		}
	case <-time.After(3 * time.Second):
		t.Fatal("polling did not pick up the external append")
	}
}

// TestGatewayPrincipalCollapseSingleUser checks that, with CHATCLI_HUB_PRINCIPAL
// set, an unbound gateway sender and the local CLI resolve to the same shared