Function TestUnixSocketClientBridgeMethods

internal/cli/client_test.go:2709–2904

(t *testing.T)

}

func TestUnixSocketClientBridgeMethods(t *testing.T) {
	t.Parallel()

	client := &unixSocketClient{
		socketPath: "/tmp/agh.sock",
		httpClient: &http.Client{
			Transport: roundTripperFunc(func(req *http.Request) (*http.Response, error) {
				switch {
				case req.Method == http.MethodGet && req.URL.Path == "/api/bridges":
					return newHTTPResponse(
						http.StatusOK,
						`{"bridges":[{"id":"brg-a","scope":"global","platform":"telegram","extension_name":"ext-telegram","display_name":"Support","enabled":true,"status":"ready","routing_policy":{"include_peer":true},"created_at":"2026-04-11T12:00:00Z","updated_at":"2026-04-11T12:00:00Z"}]}`,
					), nil
				case req.Method == http.MethodPost && req.URL.Path == "/api/bridges":
					var payload contract.CreateBridgeRequest
					if err := json.NewDecoder(req.Body).Decode(&payload); err != nil {
						t.Fatalf("json.Decode(create bridge body) error = %v", err)
					}
					if payload.Scope != bridgepkg.ScopeGlobal ||
						payload.WorkspaceID != "" ||
						payload.Platform != "telegram" ||
						payload.ExtensionName != "ext-telegram" ||
						payload.DisplayName != "Support" ||
						!payload.Enabled ||
						!reflect.DeepEqual(payload.RoutingPolicy, bridgepkg.RoutingPolicy{IncludePeer: true}) ||
						len(payload.DeliveryDefaults) != 0 {
						t.Fatalf("create bridge payload = %#v", payload)
					}
					return newHTTPResponse(
						http.StatusCreated,
						`{"bridge":{"id":"brg-a","scope":"global","platform":"telegram","extension_name":"ext-telegram","display_name":"Support","enabled":true,"status":"starting","routing_policy":{"include_peer":true},"created_at":"2026-04-11T12:00:00Z","updated_at":"2026-04-11T12:00:00Z"}}`,
					), nil
				case req.Method == http.MethodGet && req.URL.Path == "/api/bridges/brg-a":
					return newHTTPResponse(
						http.StatusOK,
						`{"bridge":{"id":"brg-a","scope":"global","platform":"telegram","extension_name":"ext-telegram","display_name":"Support","enabled":true,"status":"ready","routing_policy":{"include_peer":true},"created_at":"2026-04-11T12:00:00Z","updated_at":"2026-04-11T12:00:00Z"}}`,
					), nil
				case req.Method == http.MethodPatch && req.URL.Path == "/api/bridges/brg-a":
					var payload contract.UpdateBridgeRequest
					if err := json.NewDecoder(req.Body).Decode(&payload); err != nil {
						t.Fatalf("json.Decode(update bridge body) error = %v", err)
					}
					if payload.DisplayName == nil ||
						*payload.DisplayName != "Support Ops" ||
						payload.RoutingPolicy == nil ||
						!reflect.DeepEqual(
							*payload.RoutingPolicy,
							bridgepkg.RoutingPolicy{IncludePeer: true, IncludeThread: true},
						) ||
						payload.DeliveryDefaults != nil {
						t.Fatalf("update bridge payload = %#v, want updated display name", payload)
					}
					return newHTTPResponse(
						http.StatusOK,
						`{"bridge":{"id":"brg-a","scope":"global","platform":"telegram","extension_name":"ext-telegram","display_name":"Support Ops","enabled":true,"status":"ready","routing_policy":{"include_peer":true,"include_thread":true},"created_at":"2026-04-11T12:00:00Z","updated_at":"2026-04-11T12:05:00Z"}}`,
					), nil
				case req.Method == http.MethodPost && req.URL.Path == "/api/bridges/brg-a/enable":
					return newHTTPResponse(