(t *testing.T)
| 293 | } |
| 294 | |
| 295 | func 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 | { |
nothing calls this directly
no test coverage detected