luulam/AFFiNE
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix: update channel message schema

Browse Source
This commit is contained in:
himself65
2023-03-30 18:33:09 -05:00
parent bb1224f9ee
commit f935bbaf5d
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
packages/workspace/src/affine/api/index.ts
View File

@@ -99,7 +99,7 @@ export const userSchema = z.object({
name: z.string(), name: z.string(),
email: z.string(), email: z.string(),
avatar_url: z.string(), avatar_url: z.string(),
create_at: z.string(), created_at: z.number(),
}); });
export const workspaceSchema = z.object({ export const workspaceSchema = z.object({
@@ -113,6 +113,7 @@ export type Workspace = z.infer<typeof workspaceSchema>;
export const workspaceDetailSchema = z.object({ export const workspaceDetailSchema = z.object({
...workspaceSchema.shape, ...workspaceSchema.shape,
permission: z.undefined(),
owner: userSchema, owner: userSchema,
member_count: z.number(), member_count: z.number(),
}); });

3
packages/workspace/src/affine/sync.ts
View File

@@ -14,7 +14,7 @@ const channelMessageSchema = z.object({
ws_details: z.record(workspaceDetailSchema), ws_details: z.record(workspaceDetailSchema),
metadata: z.record( metadata: z.record(
z.object({ z.object({
avatar: z.string(), search_index: z.array(z.string()),
name: z.string(), name: z.string(),
}) })
), ),
@@ -28,6 +28,7 @@ export function createAffineGlobalChannel(
let client: WebsocketClient | null; let client: WebsocketClient | null;
async function handleMessage(channelMessage: ChannelMessage) { async function handleMessage(channelMessage: ChannelMessage) {
console.log('channelMessage', channelMessage);
const parseResult = channelMessageSchema.safeParse(channelMessage); const parseResult = channelMessageSchema.safeParse(channelMessage);
if (!parseResult.success) { if (!parseResult.success) {
console.error( console.error(