feat: break things and rebuild some of them

.env.example

@@ -6,6 +6,13 @@ PUBLIC_FIREBASE_MESSAGING_SENDER_ID="585902608528"
 PUBLIC_FIREBASE_APP_ID="1:585902608528:web:908698a423651bb865c815"
 PUBLIC_FIREBASE_MEASUREMENT_ID="G-QFXF543DV8"
 
+CLOUDFLARE_ACCOUNT_ID="CLOUDFLARE_ACCOUNT_ID"
+CLOUDFLARE_R2_BUCKET="CLOUDFLARE_R2_BUCKET"
+CLOUDFLARE_R2_ACCESS_KEY_ID="CLOUDFLARE_R2_ACCESS_KEY_ID"
+CLOUDFLARE_R2_SECRET_ACCESS_KEY="CLOUDFLARE_R2_SECRET_ACCESS_KEY"
+CLOUDFLARE_PUBLIC_URL="https://hinagiku-dev-storage.csie.cool"
+
 GOOGLE_APPLICATION_CREDENTIALS="service-account-file.example.json"
 HUGGINGFACE_TOKEN="hf_xxx"
 OPENAI_BASE_URL="https://api.openai.com/v1"
+OPENAI_API_KEY=""

src/lib/components/Auth.svelte

@@ -5,7 +5,7 @@
 
 {#if $user}
 	<div>
-		<p class="inline-block">Welcome, {$profile?.displayName ?? $user.displayName}!</p>
+		<p class="inline-block">Welcome, {$profile?.displayName || $user.displayName}!</p>
 		<button class="rounded-lg" on:click={signOut}>Sign Out</button>
 	</div>
 {:else}

src/lib/firebase/store.ts

@@ -4,20 +4,20 @@ import { writable, type Readable } from 'svelte/store';
 
 const log = debug('app:store');
 
-export interface DocumentStore<T> extends Readable<T> {
+export type DocumentStore<T> = [Readable<T | null>, {
 	unsubscribe: () => void;
-}
+}];
 
 export function subscribeAll<T = unknown>(
 	ref: Query,
-	store = writable<T[]>([])
-): DocumentStore<T[]> {
+	store = writable<[string, T][]>([])
+): DocumentStore<[string, T][]> {
 	log('subscribe', ref);
 
 	const unsubscribe = onSnapshot(
 		ref,
 		(snapshot) => {
-			const data = snapshot.docs.map((doc) => doc.data() as T);
+			const data = snapshot.docs.map((doc) => [doc.id, doc.data()] as [string, T]);
 			log('onSnapshot', ref, data);
 			store.set(data);
 		},
@@ -26,18 +26,18 @@ export function subscribeAll<T = unknown>(
 		}
 	);
 
-	return Object.assign(store, {
+	return [store, {
 		unsubscribe: () => {
 			log('unsubscribe', ref);
 			unsubscribe();
 		}
-	});
+	}];
 }
 
 export function subscribe<T = unknown>(
 	ref: DocumentReference,
 	store = writable<T | null>(null)
-): DocumentStore<T | null> {
+): DocumentStore<T> {
 	log('subscribe', ref.path);
 
 	const unsubscribe = onSnapshot(
@@ -52,10 +52,10 @@ export function subscribe<T = unknown>(
 		}
 	);
 
-	return Object.assign(store, {
+	return [store, {
 		unsubscribe: () => {
-			log('unsubscribe', ref.path);
+			log('unsubscribe', ref);
 			unsubscribe();
 		}
-	});
+	}];
 }

src/lib/schema/code.ts

@@ -0,0 +1,9 @@
+import { z } from 'zod';
+import { Timestamp } from 'firebase/firestore';
+
+export const CodeSchema = z.object({
+    target: z.string().min(1),
+    exp: z.instanceof(Timestamp),
+});
+
+export type Code = z.infer<typeof CodeSchema>;

src/lib/schema/conversation.ts

@@ -0,0 +1,12 @@
+import { z } from 'zod';
+
+export const ConversationSchema = z.object({
+    history: z.array(
+        z.object({
+            role: z.enum(['system', 'user', 'assistant']),
+            content: z.string(),
+        })
+    ),
+});
+
+export type Conversation = z.infer<typeof ConversationSchema>;

src/lib/schema/group.ts

@@ -0,0 +1,15 @@
+import { z } from 'zod';
+
+export const GroupSchema = z.object({
+    concept: z.string().min(1),
+    discussions: z.array(
+        z.object({
+            content: z.string(),
+            id: z.string().nullable(),
+        })
+    ),
+    summary: z.string().nullable(),
+    keywords: z.record(z.string(), z.number()),
+});
+
+export type Group = z.infer<typeof GroupSchema>;

src/lib/schema/profile.ts

@@ -0,0 +1,12 @@
+import { Timestamp } from 'firebase/firestore';
+import { z } from 'zod';
+
+export const ProfileSchema = z.object({
+	uid: z.string(),
+	displayName: z.string(),
+	title: z.string().nullable(),
+	bio: z.string().nullable(),
+	updatedAt: z.instanceof(Timestamp)
+});
+
+export type Profile = z.infer<typeof ProfileSchema>;

src/lib/schema/session.ts

@@ -0,0 +1,27 @@
+import { z } from 'zod';
+import { Timestamp } from 'firebase/firestore';
+
+export const SessionSchema = z.object({
+    title: z.string().min(1).max(200),
+    status: z.enum(['draft', 'waiting', 'active', 'ended']),
+    host: z.string(),
+    participants: z.array(z.string()),
+    group: z.record(z.string(), z.string()),
+    resources: z.array(
+        z.object({
+            name: z.string(),
+            content: z.string().min(1),
+            createdAt: z.instanceof(Timestamp),
+            id: z.string().nullable(),
+        })
+    ).max(10),
+    task: z.string().min(1).max(200),
+    subtasks: z.array(z.string().min(1).max(200)).max(10),
+    timing: z.object({
+        self: z.number().int().min(1),
+        group: z.number().int().min(1),
+    }),
+    createdAt: z.instanceof(Timestamp),
+});
+
+export type Session = z.infer<typeof SessionSchema>;

src/lib/stores/profile.ts

@@ -1,25 +1,18 @@
 import { db } from '$lib/firebase';
 import { subscribe } from '$lib/firebase/store';
-import { collection, doc, Timestamp } from 'firebase/firestore';
+import { collection, doc } from 'firebase/firestore';
 import { writable } from 'svelte/store';
 import { z } from 'zod';
 import { user } from './auth';
+import type { ProfileSchema } from '$lib/schema/profile';
 
-export const profileSchema = z.object({
-	uid: z.string(),
-	displayName: z.string(),
-	title: z.string().nullable(),
-	bio: z.string().nullable(),
-	updatedAt: z.instanceof(Timestamp)
-});
-
-export const profile = writable<z.infer<typeof profileSchema> | null>(null);
+export const profile = writable<z.infer<typeof ProfileSchema> | null>(null);
 let unsubscribe: () => void | undefined;
 
 user.subscribe((user) => {
 	if (user) {
 		const ref = doc(collection(db, 'profiles'), user.uid);
-		unsubscribe = subscribe(ref, profile).unsubscribe;
+		unsubscribe = subscribe(ref, profile)[1].unsubscribe;
 	} else {
 		unsubscribe?.();
 		profile.set(null);

src/lib/stores/sidebar.ts

@@ -1,2 +1,3 @@
 import { writable } from 'svelte/store';
+
 export const sidebarOpen = writable(false);