feat: add bridge_connected_systems/list (#248)

* feat: add bridge_connected_systems/list

* ci: Format code

* fix noise threshold flaky test

* add test

* fix noise threshold flaky test

* fix: Use Node 20.18 for build (#249)

* 1.80.1

* Use Node 20.18 in development

* Update Dockerfile to use Node 20.18

* Fix Dockerfile case

* Use alpine in Dockerfile

* revert from third_party_account_id -> connected_account_id

* ci: Generate code

* fix missing third_party_account_id

---------

Co-authored-by: Seam Bot <[email protected]>
Co-authored-by: Evan Sosenko <[email protected]>

Author: 3 people

src/lib/database/schema.ts

@@ -8,6 +8,7 @@ import type {
   AcsUser,
   ActionAttempt,
   ApiKey,
+  Bridge,
   BridgeClientSession,
   ClientSession,
   ConnectedAccount,
@@ -51,6 +52,7 @@ export interface DatabaseState {
   connect_webviews: ConnectWebview[]
   client_sessions: ClientSession[]
   bridge_client_sessions: BridgeClientSession[]
+  bridges: Bridge[]
   connected_accounts: ConnectedAccount[]
   devices: Device[]
   events: Event[]
@@ -115,6 +117,9 @@ export interface DatabaseMethods {
     pairing_code?: string
     pairing_code_expires_at?: string
   }) => void
+  addBridge: (
+    params: Pick<Bridge, "workspace_id" | "bridge_client_session_id">,
+  ) => Bridge
   addUserIdentity: (params: {
     workspace_id: WorkspaceId
     user_identity_id?: string
@@ -167,6 +172,7 @@ export interface DatabaseMethods {
     account_type?: string
     automatically_manage_new_devices?: boolean
     custom_metadata?: ConnectedAccount["custom_metadata"]
+    bridge_id?: string
   }) => ConnectedAccount
   updateConnectedAccount: (params: {
     connected_account_id: string
@@ -298,7 +304,7 @@ export interface DatabaseMethods {
   addAcsSystem: (
     params: Pick<
       AcsSystem,
-      "external_type" | "name" | "workspace_id" | "connected_account_ids"
+      "external_type" | "name" | "workspace_id" | "connected_account_id"
     > &
       Partial<Pick<AcsSystem, "created_at" | "acs_system_id">>,
   ) => AcsSystem

src/lib/database/seed.ts

@@ -183,7 +183,7 @@ export const seedDatabase = (db: Database): Seed => {
     noise_threshold_decibels: 60,
     name: "builtin_normal_hours",
     starts_daily_at: "00:00:00[America/Los_Angeles]",
-    ends_daily_at: "23:00:00[America/Los_Angeles]",
+    ends_daily_at: "23:59:59[America/Los_Angeles]",
   })
 
   db.addDevice({
@@ -273,7 +273,7 @@ export const seedDatabase = (db: Database): Seed => {
     external_type: "visionline_system",
     name: "Fake Visionline System",
     workspace_id: seed.seed_workspace_1,
-    connected_account_ids: [seed.john_connected_account_id],
+    connected_account_id: seed.john_connected_account_id,
   })
 
   const [, short_token = "", long_token = ""] = seed.seam_at1_token.split("_")

src/lib/database/store.ts

@@ -7,7 +7,7 @@ import { immer } from "zustand/middleware/immer"
 import { createStore, type StoreApi } from "zustand/vanilla"
 import { hoist } from "zustand-hoist"
 
-import type { BridgeClientSession, UserSession } from "lib/zod/index.ts"
+import type { Bridge, BridgeClientSession, UserSession } from "lib/zod/index.ts"
 
 import {
   ACS_ACCESS_GROUP_EXTERNAL_TYPE_TO_DISPLAY_NAME,
@@ -72,6 +72,7 @@ const initializer = immer<Database>((set, get) => ({
   simulatedEvents: {},
   client_sessions: [],
   bridge_client_sessions: [],
+  bridges: [],
   assa_abloy_credential_services: [],
   assa_abloy_cards: [],
   endpoints: [],
@@ -342,6 +343,24 @@ const initializer = immer<Database>((set, get) => ({
     })
   },
 
+  addBridge(params) {
+    const bridge_id = get()._getNextId("bid")
+
+    const new_bridge: Bridge = {
+      ...params,
+      bridge_id,
+      created_at: new Date().toISOString(),
+      workspace_id: params.workspace_id,
+      bridge_client_session_id: params.bridge_client_session_id,
+    }
+
+    set({
+      bridges: [...get().bridges, new_bridge],
+    })
+
+    return new_bridge
+  },
+
   addUserIdentity(params) {
     const user_identity_id = params.user_identity_id ?? get()._getNextId("uid")
     const new_user_identity: UserIdentity = {
@@ -557,6 +576,7 @@ const initializer = immer<Database>((set, get) => ({
       automatically_manage_new_devices:
         params?.automatically_manage_new_devices ?? true,
       custom_metadata: params.custom_metadata ?? {},
+      bridge_id: params.bridge_id ?? null,
     }
 
     if (params.provider === "assa_abloy_credential_service") {
@@ -1237,7 +1257,7 @@ const initializer = immer<Database>((set, get) => ({
     name,
     workspace_id,
     created_at,
-    connected_account_ids,
+    connected_account_id,
     acs_system_id,
   }) {
     const new_acs_system: AcsSystem = {
@@ -1250,7 +1270,7 @@ const initializer = immer<Database>((set, get) => ({
       external_type,
       external_type_display_name:
         ACS_SYSTEM_TYPE_TO_DISPLAY_NAME[external_type],
-      connected_account_ids: connected_account_ids ?? [],
+      connected_account_id,
     }
 
     set({

src/lib/zod/acs/system.ts

@@ -25,7 +25,7 @@ export const acs_system = z.object({
   name: z.string(),
   created_at: z.string().datetime(),
   workspace_id: z.string(),
-  connected_account_ids: z.array(z.string()),
+  connected_account_id: z.string(),
 })
 
 export type AcsSystem = z.output<typeof acs_system>

src/lib/zod/bridge.ts

@@ -0,0 +1,10 @@
+import { z } from "zod"
+
+export const bridge = z.object({
+  bridge_id: z.string().uuid(),
+  created_at: z.string().datetime(),
+  workspace_id: z.string().uuid(),
+  bridge_client_session_id: z.string().uuid(),
+})
+
+export type Bridge = z.infer<typeof bridge>

src/lib/zod/bridge_connected_system.ts

@@ -0,0 +1,19 @@
+import { z } from "zod"
+
+export const bridge_connected_system = z.object({
+  bridge_id: z.string().uuid(),
+  bridge_created_at: z.string().datetime(),
+  connected_account_id: z.string().uuid(),
+  connected_account_created_at: z.string().datetime(),
+  acs_system_id: z.string().uuid(),
+  acs_system_display_name: z.string(),
+  workspace_id: z.string().uuid(),
+  workspace_display_name: z.string(),
+}).describe(`
+  ---
+  route_path: /seam/bridge/v1/bridge_connected_systems
+  undocumented: Seam Bridge Client only.
+  ---
+`)
+
+export type BridgeConnectedSystem = z.infer<typeof bridge_connected_system>

src/lib/zod/connected_account.ts

@@ -15,8 +15,8 @@ export const connected_account = z.object({
   account_type_display_name: z.string(),
   automatically_manage_new_devices: z.boolean(),
   custom_metadata: custom_metadata.optional(),
-
   assa_abloy_credential_service_id: z.string().optional(),
+  bridge_id: z.string().nullable(),
 })
 
 export type ConnectedAccount = z.infer<typeof connected_account>

src/lib/zod/index.ts

@@ -3,7 +3,9 @@ export * from "./access_token.ts"
 export * from "./acs/index.ts"
 export * from "./action_attempt.ts"
 export * from "./api_key.ts"
+export * from "./bridge.ts"
 export * from "./bridge_client_session.ts"
+export * from "./bridge_connected_system.ts"
 export * from "./client_session.ts"
 export * from "./common.ts"
 export * from "./connect_webview.ts"

src/pages/api/acs/systems/list.ts

@@ -24,7 +24,7 @@ export default withRouteSpec({
     (acs_system) =>
       acs_system.workspace_id === req.auth.workspace_id &&
       (connected_account_id == null ||
-        acs_system.connected_account_ids.includes(connected_account_id)),
+        acs_system.connected_account_id === connected_account_id),
   )
 
   res.status(200).json({

src/pages/api/seam/bridge/v1/bridge_connected_systems/list.ts

@@ -0,0 +1,77 @@
+import { z } from "zod"
+
+import { withRouteSpec } from "lib/middleware/index.ts"
+
+import {
+  bridge_connected_system,
+  type BridgeConnectedSystem,
+} from "lib/zod/bridge_connected_system.ts"
+
+export default withRouteSpec({
+  description: `
+  ---
+  title: List Bridge Connected Systems
+  response_key: bridge_connected_systems
+  undocumented: Seam Bridge Client only.
+  ---
+  Returns the bridge connected systems associated with the session token used.
+  `,
+  auth: ["bridge_client_session"],
+  methods: ["GET", "POST"],
+  jsonResponse: z.object({
+    bridge_connected_systems: z.array(bridge_connected_system),
+  }),
+} as const)(async (req, res) => {
+  const { db, auth } = req
+
+  const bridges = db.bridges.filter(
+    (bridge) =>
+      bridge.bridge_client_session_id ===
+      auth.bridge_client_session.bridge_client_session_id,
+  )
+
+  const bridge_connected_systems: BridgeConnectedSystem[] = bridges.map(
+    (bridge) => {
+      const connected_account = db.connected_accounts.find(
+        (connected_account) => connected_account.bridge_id === bridge.bridge_id,
+      )
+
+      if (connected_account == null) {
+        throw new Error("Could not find connected_account for bridge.")
+      }
+
+      const acs_system = db.acs_systems.find(
+        (acs_system) =>
+          acs_system.connected_account_id ===
+          connected_account.connected_account_id,
+      )
+
+      if (acs_system == null) {
+        throw new Error("Could not find acs_system for third_party_account.")
+      }
+
+      const workspace = db.workspaces.find(
+        (workspace) => workspace.workspace_id === bridge.workspace_id,
+      )
+
+      if (workspace == null) {
+        throw new Error("Could not find workspace for bridge.")
+      }
+
+      return {
+        bridge_id: bridge.bridge_id,
+        bridge_created_at: bridge.created_at,
+        connected_account_id: connected_account.connected_account_id,
+        connected_account_created_at: connected_account.created_at,
+        acs_system_id: acs_system.acs_system_id,
+        acs_system_display_name: acs_system.name,
+        workspace_id: bridge.workspace_id,
+        workspace_display_name: workspace.name,
+      }
+    },
+  )
+
+  res.status(200).json({
+    bridge_connected_systems,
+  })
+})