feat: add phase 1 chat persistence schema

Co-authored-by: multica-agent <github@multica.ai>

Author: zhangxichang

package.json

@@ -15,6 +15,7 @@
 		"test": "playwright test",
 		"format": "biome check --write",
 		"check": "run-p 'check:*'",
+		"check:schema-contract": "bun scripts/check_schema_contract.ts",
 		"check:tsc": "tsc",
 		"check:eslint": "eslint src",
 		"check:script": "uv run basedpyright scripts",

schema.prisma

@@ -18,16 +18,41 @@ model user {
 }
 
 model friend {
-  id       String @id
   owner_id String
+  id       String
   name     String
   avatar   Bytes?
   bio      String
+
+  @@id([owner_id, id])
 }
 
 model chat_message {
-  timestamp    DateTime @id @default(now())
+  id           String @id
   owner_id     String
   chat_user_id String
+  sender_id    String
   content      String
+  status       String   @default("sent")
+  created_at   DateTime @default(now())
+  updated_at   DateTime @default(now()) @updatedAt
+  retry_count  Int      @default(0)
+  last_error   String?
+
+  @@index([owner_id, chat_user_id, created_at])
+  @@index([owner_id, status])
+}
+
+model friend_request {
+  owner_id     String
+  remote_id    String
+  name         String
+  avatar       Bytes?
+  bio          String
+  status       String   @default("pending")
+  created_at   DateTime @default(now())
+  responded_at DateTime?
+
+  @@id([owner_id, remote_id])
+  @@index([owner_id, status, created_at])
 }

scripts/check_schema_contract.ts

@@ -0,0 +1,88 @@
+import { readFileSync } from "node:fs";
+
+const schema = readFileSync("schema.prisma", "utf8");
+const endpointTypes = readFileSync("src/lib/endpoint/types.ts", "utf8");
+
+function modelBody(name: string) {
+	const match = schema.match(
+		new RegExp(`model\\s+${name}\\s+\\{([\\s\\S]*?)\\n\\}`),
+	);
+	if (!match) throw new Error(`Missing Prisma model: ${name}`);
+	return match[1];
+}
+
+function expectMatch(source: string, pattern: RegExp, message: string) {
+	if (!pattern.test(source)) throw new Error(message);
+}
+
+const friend = modelBody("friend");
+expectMatch(
+	friend,
+	/^\s*@@id\(\[owner_id,\s*id\]\)/m,
+	"friend must be keyed by owner_id + id",
+);
+if (/^\s*id\s+String\s+@id\b/m.test(friend)) {
+	throw new Error("friend.id must not be a global primary key");
+}
+
+const chatMessage = modelBody("chat_message");
+for (const [field, pattern] of [
+	["id", /^\s*id\s+String\s+@id\b/m],
+	["owner_id", /^\s*owner_id\s+String\b/m],
+	["chat_user_id", /^\s*chat_user_id\s+String\b/m],
+	["sender_id", /^\s*sender_id\s+String\b/m],
+	["content", /^\s*content\s+String\b/m],
+	["status", /^\s*status\s+String\b/m],
+	["created_at", /^\s*created_at\s+DateTime\b/m],
+	["updated_at", /^\s*updated_at\s+DateTime\b/m],
+	["retry_count", /^\s*retry_count\s+Int\b/m],
+	["last_error", /^\s*last_error\s+String\?/m],
+] as const) {
+	expectMatch(chatMessage, pattern, `chat_message is missing ${field}`);
+}
+
+const friendRequest = modelBody("friend_request");
+for (const [field, pattern] of [
+	["owner_id", /^\s*owner_id\s+String\b/m],
+	["remote_id", /^\s*remote_id\s+String\b/m],
+	["name", /^\s*name\s+String\b/m],
+	["avatar", /^\s*avatar\s+Bytes\?/m],
+	["bio", /^\s*bio\s+String\b/m],
+	["status", /^\s*status\s+String\b/m],
+	["created_at", /^\s*created_at\s+DateTime\b/m],
+	["responded_at", /^\s*responded_at\s+DateTime\?/m],
+] as const) {
+	expectMatch(friendRequest, pattern, `friend_request is missing ${field}`);
+}
+expectMatch(
+	friendRequest,
+	/^\s*@@id\(\[owner_id,\s*remote_id\]\)/m,
+	"friend_request must be keyed by owner_id + remote_id",
+);
+
+expectMatch(endpointTypes, /id:\s*string/, "Message type must include id");
+expectMatch(
+	endpointTypes,
+	/sender_id:\s*string/,
+	"Message type must include sender_id",
+);
+expectMatch(
+	endpointTypes,
+	/status:\s*MessageStatus/,
+	"Message type must expose MessageStatus",
+);
+expectMatch(
+	endpointTypes,
+	/created_at:\s*string/,
+	"Message type must expose sortable created_at",
+);
+expectMatch(
+	endpointTypes,
+	/retry_count:\s*number/,
+	"Message type must include retry_count",
+);
+expectMatch(
+	endpointTypes,
+	/last_error\?:\s*string/,
+	"Message type must include optional last_error",
+);

src/components/ui/chat_bar.tsx

@@ -17,9 +17,21 @@ export default function ChatBar(props: { chat_user: User }) {
 		if (!u) throw new Error("用户不存在");
 		return await main_store.sqlite.query<Message>(
 			QueryBuilder.selectFrom("chat_message")
-				.select(["chat_user_id", "timestamp", "content"])
+				.select([
+					"id",
+					"owner_id",
+					"chat_user_id",
+					"sender_id",
+					"content",
+					"status",
+					"created_at",
+					"updated_at",
+					"retry_count",
+					"last_error",
+				])
 				.where("owner_id", "=", u.id)
 				.where("chat_user_id", "=", props.chat_user.id)
+				.orderBy("created_at", "asc")
 				.compile(),
 		);
 	});

src/lib/endpoint/types.ts

@@ -13,8 +13,30 @@ export type RelayConfig = {
 	quic_port: number;
 };
 
+export type MessageStatus = "sending" | "sent" | "failed" | "received";
+
 export type Message = {
+	id: string;
+	owner_id: string;
+	chat_user_id: string;
 	sender_id: string;
-	timestamp: number;
 	content: string;
+	status: MessageStatus;
+	created_at: string;
+	updated_at: string;
+	retry_count: number;
+	last_error?: string | null;
+};
+
+export type FriendRequestStatus = "pending" | "accepted" | "rejected";
+
+export type FriendRequest = {
+	owner_id: string;
+	remote_id: string;
+	name: string;
+	avatar?: Uint8Array;
+	bio: string;
+	status: FriendRequestStatus;
+	created_at: string;
+	responded_at?: string | null;
 };