MCPcopy Create free account
hub / github.com/compozy/agh / TestNetworkClientHelpersAndAliases

Function TestNetworkClientHelpersAndAliases

internal/cli/network_client_test.go:295–391  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

293}
294
295func TestNetworkClientHelpersAndAliases(t *testing.T) {
296 t.Parallel()
297
298 t.Run("Should build network query helpers and preserve contract aliases", func(t *testing.T) {
299 t.Parallel()
300
301 if got := networkPeersValues(NetworkPeersQuery{Channel: "builders"}); got.Get("channel") != "builders" {
302 t.Fatalf("networkPeersValues() = %v, want channel filter", got)
303 }
304 if got := networkInboxValues("sess-a"); got.Get("session_id") != "sess-a" {
305 t.Fatalf("networkInboxValues() = %v, want session_id filter", got)
306 }
307 if got := networkThreadsValues(NetworkThreadsQuery{Limit: 2, After: "thread_0"}); got.Get("limit") != "2" ||
308 got.Get("after") != "thread_0" {
309 t.Fatalf("networkThreadsValues() = %v, want list cursor filters", got)
310 }
311 if got := networkDirectsValues(NetworkDirectsQuery{
312 PeerID: "reviewer.sess-b",
313 Limit: 2,
314 After: "direct_0",
315 }); got.Get("peer_id") != "reviewer.sess-b" || got.Get("limit") != "2" || got.Get("after") != "direct_0" {
316 t.Fatalf("networkDirectsValues() = %v, want peer/list filters", got)
317 }
318 if got := networkConversationMessagesValues(NetworkConversationMessagesQuery{
319 Limit: 2,
320 Before: "msg-3",
321 After: "msg-1",
322 Kind: "say",
323 WorkID: "work_1",
324 }); got.Get("limit") != "2" || got.Get("before") != "msg-3" ||
325 got.Get("after") != "msg-1" || got.Get("kind") != "say" || got.Get("work_id") != "work_1" {
326 t.Fatalf("networkConversationMessagesValues() = %v, want message filters", got)
327 }
328 if got, err := networkThreadPath(" ws-alpha ", " builders ", " thread_1 "); err != nil ||
329 got != "/api/workspaces/ws-alpha/network/channels/builders/threads/thread_1" {
330 t.Fatalf("networkThreadPath() = %q, %v", got, err)
331 }
332 if got, err := networkDirectMessagesPath("ws-alpha", "builders", "direct_1"); err != nil ||
333 got != "/api/workspaces/ws-alpha/network/channels/builders/directs/direct_1/messages" {
334 t.Fatalf("networkDirectMessagesPath() = %q, %v", got, err)
335 }
336
337 tests := []struct {
338 name string
339 cliType any
340 want any
341 }{
342 {name: "NetworkStatusRecord", cliType: NetworkStatusRecord{}, want: contract.NetworkStatusPayload{}},
343 {
344 name: "NetworkKindMetricRecord",
345 cliType: NetworkKindMetricRecord{},
346 want: contract.NetworkKindMetricPayload{},
347 },
348 {name: "NetworkSendRequest", cliType: NetworkSendRequest{}, want: contract.NetworkSendRequest{}},
349 {name: "NetworkSendRecord", cliType: NetworkSendRecord{}, want: contract.NetworkSendPayload{}},
350 {name: "NetworkPeerRecord", cliType: NetworkPeerRecord{}, want: contract.NetworkPeerPayload{}},
351 {name: "NetworkChannelRecord", cliType: NetworkChannelRecord{}, want: contract.NetworkChannelPayload{}},
352 {

Callers

nothing calls this directly

Calls 9

networkPeersValuesFunction · 0.85
networkInboxValuesFunction · 0.85
networkThreadsValuesFunction · 0.85
networkDirectsValuesFunction · 0.85
networkThreadPathFunction · 0.85
RunMethod · 0.65
GetMethod · 0.65

Tested by

no test coverage detected