From f935bbaf5d62191217b2b1b6635ff9108d41123f Mon Sep 17 00:00:00 2001 From: himself65 Date: Thu, 30 Mar 2023 18:33:09 -0500 Subject: [PATCH] fix: update channel message schema --- packages/workspace/src/affine/api/index.ts | 3 ++- packages/workspace/src/affine/sync.ts | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/packages/workspace/src/affine/api/index.ts b/packages/workspace/src/affine/api/index.ts index 0068895f4..b8d84379a 100644 --- a/packages/workspace/src/affine/api/index.ts +++ b/packages/workspace/src/affine/api/index.ts @@ -99,7 +99,7 @@ export const userSchema = z.object({ name: z.string(), email: z.string(), avatar_url: z.string(), - create_at: z.string(), + created_at: z.number(), }); export const workspaceSchema = z.object({ @@ -113,6 +113,7 @@ export type Workspace = z.infer; export const workspaceDetailSchema = z.object({ ...workspaceSchema.shape, + permission: z.undefined(), owner: userSchema, member_count: z.number(), }); diff --git a/packages/workspace/src/affine/sync.ts b/packages/workspace/src/affine/sync.ts index f8ecfc09b..9ff58b228 100644 --- a/packages/workspace/src/affine/sync.ts +++ b/packages/workspace/src/affine/sync.ts @@ -14,7 +14,7 @@ const channelMessageSchema = z.object({ ws_details: z.record(workspaceDetailSchema), metadata: z.record( z.object({ - avatar: z.string(), + search_index: z.array(z.string()), name: z.string(), }) ), @@ -28,6 +28,7 @@ export function createAffineGlobalChannel( let client: WebsocketClient | null; async function handleMessage(channelMessage: ChannelMessage) { + console.log('channelMessage', channelMessage); const parseResult = channelMessageSchema.safeParse(channelMessage); if (!parseResult.success) { console.error(