Method NewConversation

cli/hub_sync_test.go:40–47

(_ context.Context, _ string)

}

func (f *fakeHubClient) NewConversation(_ context.Context, _ string) (string, error) {
	f.mu.Lock()
	defer f.mu.Unlock()
	f.convCounter++
	f.convID = fmt.Sprintf("conv-%d", f.convCounter)
	f.events = nil // ephemeral: rotating prunes the prior thread
	return f.convID, nil
}

func (f *fakeHubClient) AppendEvent(_ context.Context, ev models.ConversationEvent) (models.ConversationEvent, error) {
	f.mu.Lock()