feat: Implement fluency score upload and storage functionality

- Added fluency_score_json column to users table for storing AI fluency scores.
- Introduced API endpoint to receive and store fluency scores from the extension.
- Updated backend services to handle fluency score uploads and ensure synchronization with the server dashboard.
- Enhanced dashboard rendering to display the latest fluency scores directly from the database.

Author: rajbos

sharing-server/src/db.ts

@@ -11,6 +11,7 @@ export interface UserRow {
 	created_at: string;
 	last_seen_at: string | null;
 	is_admin: number;
+	fluency_score_json: string | null;
 }
 
 export interface UploadRow {
@@ -158,6 +159,14 @@ function initSchema(db: DatabaseSync): void {
 	if (!cols.some(c => c.name === 'fluency_json')) {
 		db.exec('ALTER TABLE usage_uploads ADD COLUMN fluency_json TEXT');
 	}
+
+	// Add fluency_score_json column to users if it doesn't exist (migration for existing DBs)
+	const userCols = db
+		.prepare("PRAGMA table_info(users)")
+		.all() as unknown as Array<{ name: string }>;
+	if (!userCols.some(c => c.name === 'fluency_score_json')) {
+		db.exec('ALTER TABLE users ADD COLUMN fluency_score_json TEXT');
+	}
 }
 
 export function upsertUser(
@@ -247,3 +256,14 @@ export function getUploadsForUser(userId: number, days = 30): UploadRow[] {
 export function getAllUsers(): UserRow[] {
 	return getDb().prepare('SELECT * FROM users ORDER BY created_at DESC').all() as unknown as UserRow[];
 }
+
+export function upsertUserFluencyScore(userId: number, scoreJson: string): void {
+	getDb().prepare(`
+		UPDATE users SET fluency_score_json = ? WHERE id = ?
+	`).run(scoreJson, userId);
+}
+
+export function getUserFluencyScore(userId: number): string | null {
+	const row = getDb().prepare('SELECT fluency_score_json FROM users WHERE id = ?').get(userId) as unknown as { fluency_score_json: string | null } | undefined;
+	return row?.fluency_score_json ?? null;
+}

sharing-server/src/routes/api.ts

@@ -1,6 +1,6 @@
 import { Hono } from 'hono';
 import { requireBearerAuth, checkUploadRateLimit, type AuthVariables } from '../auth.js';
-import { upsertUpload, deleteUploadsForDays, getUploadsForUser, getDb, type UploadEntry } from '../db.js';
+import { upsertUpload, deleteUploadsForDays, getUploadsForUser, getDb, upsertUserFluencyScore, type UploadEntry } from '../db.js';
 
 const MAX_STRING_LENGTHS = {
 	model: 128,
@@ -111,6 +111,35 @@ api.get('/data', requireBearerAuth, (c) => {
 	return c.json(data);
 });
 
+/**
+ * POST /api/fluency-score — Store the extension's locally-computed fluency score.
+ * Body: { overallStage, overallLabel, categories, computedAt }
+ * This is the authoritative score: the server dashboard uses it directly instead of
+ * re-computing from aggregated upload blobs.
+ */
+api.post('/fluency-score', requireBearerAuth, async (c) => {
+	const user = c.get('user');
+
+	let body: unknown;
+	try {
+		body = await c.req.json();
+	} catch {
+		return c.json({ error: 'Invalid JSON body.' }, 400);
+	}
+
+	if (typeof body !== 'object' || body === null || Array.isArray(body)) {
+		return c.json({ error: 'Body must be a JSON object.' }, 400);
+	}
+
+	const b = body as Record<string, unknown>;
+	if (typeof b.overallStage !== 'number' || !Array.isArray(b.categories)) {
+		return c.json({ error: '"overallStage" (number) and "categories" (array) are required.' }, 400);
+	}
+
+	upsertUserFluencyScore(user.id, JSON.stringify(body));
+	return c.json({ ok: true });
+});
+
 // ── Helpers ──────────────────────────────────────────────────────────────────
 
 function clampDays(raw: string | undefined): number {