mirror of
https://github.com/MODSetter/SurfSense.git
synced 2026-07-08 22:22:17 +02:00
a64c8205fe
- Added the ensure_publication function to create and verify the zero_publication if it is missing, ensuring idempotency during database initialization. - Integrated ensure_publication into the create_db_and_tables function to prevent zero-cache crash loops on startup. - Introduced a self-check script to validate the ensure_publication functionality on a create_all-bootstrapped database. - Updated various components to reflect the transition from search space to workspace, including adjustments in imports and routing paths.
50 lines
1.7 KiB
TypeScript
50 lines
1.7 KiB
TypeScript
import { json, number, string, table } from "@rocicorp/zero";
|
|
|
|
export const newChatMessageTable = table("new_chat_messages")
|
|
.columns({
|
|
id: number(),
|
|
role: string(),
|
|
content: json(),
|
|
threadId: number().from("thread_id"),
|
|
authorId: string().optional().from("author_id"),
|
|
createdAt: number().from("created_at"),
|
|
source: string(),
|
|
platformMetadata: json().optional().from("platform_metadata"),
|
|
// Per-turn correlation id sourced from ``configurable.turn_id``
|
|
// at streaming time. Required by the inline Revert button's
|
|
// (chat_turn_id, tool_name, position) fallback in tool-fallback.tsx
|
|
// — without it the live-collab Zero sync would clobber the
|
|
// metadata we set during streaming and the button would vanish
|
|
// the moment Zero re-syncs after the stream finishes.
|
|
turnId: string().optional().from("turn_id"),
|
|
})
|
|
.primaryKey("id");
|
|
|
|
export const newChatThreadTable = table("new_chat_threads")
|
|
.columns({
|
|
id: number(),
|
|
searchSpaceId: number().from("workspace_id"),
|
|
})
|
|
.primaryKey("id");
|
|
|
|
export const chatCommentTable = table("chat_comments")
|
|
.columns({
|
|
id: number(),
|
|
messageId: number().from("message_id"),
|
|
threadId: number().from("thread_id"),
|
|
parentId: number().optional().from("parent_id"),
|
|
authorId: string().optional().from("author_id"),
|
|
content: string(),
|
|
createdAt: number().from("created_at"),
|
|
updatedAt: number().from("updated_at"),
|
|
})
|
|
.primaryKey("id");
|
|
|
|
export const chatSessionStateTable = table("chat_session_state")
|
|
.columns({
|
|
id: number(),
|
|
threadId: number().from("thread_id"),
|
|
aiRespondingToUserId: string().optional().from("ai_responding_to_user_id"),
|
|
updatedAt: number().from("updated_at"),
|
|
})
|
|
.primaryKey("id");
|