feat: Add /seam/bridge/v1/bridge_client_sessions/report_status

src/lib/database/schema.ts

@@ -117,6 +117,7 @@ export interface DatabaseMethods {
     bridge_client_session_id: string
     pairing_code?: string
     pairing_code_expires_at?: string
+    _last_status_report_received_at?: string
   }) => void
   addBridge: (
     params: Pick<Bridge, "workspace_id" | "bridge_client_session_id">,

src/lib/database/store.ts

@@ -317,6 +317,7 @@ const initializer = immer<Database>((set, get) => ({
       bridge_client_name: `${bridge_client_session_id}_bridge`,
       bridge_client_time_zone: "America/Los_Angeles",
       bridge_client_machine_identifier_key: `${bridge_client_session_id}_key`,
+      _last_status_report_received_at: null,
       ...params,
     }
 

src/lib/zod/bridge_client_session.ts

@@ -13,6 +13,7 @@ export const bridge_client_session = z.object({
   bridge_client_name: z.string(),
   bridge_client_time_zone: z.string(),
   bridge_client_machine_identifier_key: z.string(),
+  _last_status_report_received_at: z.string().datetime().nullable(),
 })
 
 export type BridgeClientSession = z.infer<typeof bridge_client_session>

src/pages/api/seam/bridge/v1/bridge_client_sessions/report_status.ts

@@ -0,0 +1,36 @@
+import { NotFoundException } from "nextlove"
+import { z } from "zod"
+
+import { withRouteSpec } from "lib/middleware/index.ts"
+
+export default withRouteSpec({
+  auth: ["bridge_client_session"],
+  methods: ["POST"],
+  jsonBody: z.object({
+    is_tailscale_connected: z.boolean().nullable(),
+    tailscale_ip_v4: z.string().nullable(),
+  }),
+  jsonResponse: z.object({}),
+} as const)(async (req, res) => {
+  const { db, auth } = req
+
+  const bridge_client_session = db.bridge_client_sessions.find(
+    (bridge_client_session) =>
+      bridge_client_session.bridge_client_session_id ===
+      auth.bridge_client_session.bridge_client_session_id,
+  )
+
+  if (bridge_client_session == null) {
+    throw new NotFoundException({
+      type: "bridge_client_session_not_found",
+      message: "Bridge client session not found",
+    })
+  }
+
+  db.updateBridgeClientSession({
+    bridge_client_session_id: bridge_client_session.bridge_client_session_id,
+    _last_status_report_received_at: new Date().toISOString(),
+  })
+
+  res.status(200).json({})
+})

src/route-types.ts

@@ -4484,6 +4484,7 @@ export type Routes = {
         bridge_client_name: string
         bridge_client_time_zone: string
         bridge_client_machine_identifier_key: string
+        _last_status_report_received_at: string | null
       }
       ok: boolean
     }
@@ -4509,6 +4510,7 @@ export type Routes = {
         bridge_client_name: string
         bridge_client_time_zone: string
         bridge_client_machine_identifier_key: string
+        _last_status_report_received_at: string | null
       }
       ok: boolean
     }
@@ -4534,10 +4536,25 @@ export type Routes = {
         bridge_client_name: string
         bridge_client_time_zone: string
         bridge_client_machine_identifier_key: string
+        _last_status_report_received_at: string | null
       }
       ok: boolean
     }
   }
+  "/seam/bridge/v1/bridge_client_sessions/report_status": {
+    route: "/seam/bridge/v1/bridge_client_sessions/report_status"
+    method: "POST"
+    queryParams: {}
+    jsonBody: {
+      is_tailscale_connected: boolean | null
+      tailscale_ip_v4: string | null
+    }
+    commonParams: {}
+    formData: {}
+    jsonResponse: {
+      ok: boolean
+    }
+  }
   "/seam/bridge/v1/bridge_connected_systems/list": {
     route: "/seam/bridge/v1/bridge_connected_systems/list"
     method: "GET" | "POST"

test/api/bridge/v1/bridge_client_sessions/report_status.test.ts

@@ -0,0 +1,22 @@
+import test, { type ExecutionContext } from "ava"
+
+import { getTestServer } from "fixtures/get-test-server.ts"
+
+test("POST /bridge/v1/bridge_client_sessions/report_status", async (t: ExecutionContext) => {
+  const { axios, seed } = await getTestServer(t)
+
+  const response = await axios.post(
+    "/seam/bridge/v1/bridge_client_sessions/report_status",
+    {
+      is_tailscale_connected: true,
+      tailscale_ip_v4: "100.100.100.100",
+    },
+    {
+      headers: {
+        Authorization: `Bearer ${seed.bridge_client_session.bridge_client_session_token}`,
+      },
+    },
+  )
+
+  t.is(response.status, 200)
+})