refactor: use migration endpoint instead of script

Author: aurelleb

Dockerfile

@@ -31,7 +31,6 @@ RUN apk add --no-cache sqlite
 COPY --from=deps /app/node_modules ./node_modules
 COPY --from=build /app/src ./src
 COPY --from=build /app/prisma ./prisma
-COPY --from=build /app/scripts ./scripts
 COPY --from=build /app/package.json ./package.json
 
 # Create storage and analytics data directories

scripts/migrate-telemetry-to-duckdb.ts

@@ -1,5 +1,6 @@
 import { DuckDBInstance, type DuckDBValue } from "@duckdb/node-api";
 import type { SystemInfoPayload } from "@/schemas/telemetry.js";
+import { prisma } from "@/db.js";
 
 const DB_PATH = process.env.ANALYTICS_DB_PATH || "./analytics.duckdb";
 
@@ -103,6 +104,40 @@ export async function upsertSystemInfo(
 	);
 }
 
+export async function migrateFromSqlite() {
+	const rows = await prisma.telemetrySystemInfo.findMany();
+	if (rows.length === 0) {
+		return { migrated: 0, message: "No rows to migrate." };
+	}
+
+	let migrated = 0;
+	for (const row of rows) {
+		const desktops = JSON.parse(row.desktops) as string[];
+		const screens = JSON.parse(row.screens);
+
+		await upsertSystemInfo({
+			userId: row.userId,
+			date: row.date,
+			desktops,
+			vicinaeVersion: row.vicinaeVersion,
+			displayProtocol: row.displayProtocol,
+			architecture: row.architecture,
+			operatingSystem: row.operatingSystem,
+			buildProvenance: row.buildProvenance,
+			locale: row.locale,
+			screens,
+			chassisType: row.chassisType,
+			kernelVersion: row.kernelVersion,
+			productId: row.productId,
+			productVersion: row.productVersion,
+			qtVersion: row.qtVersion ?? undefined,
+		});
+		migrated++;
+	}
+
+	return { migrated, message: `Migrated ${migrated} rows from SQLite to DuckDB.` };
+}
+
 export async function deleteUserData(userId: string) {
 	const conn = getConnection();
 	await conn.run(

src/analytics.ts

@@ -4,6 +4,7 @@ import {
 	queryRawRows,
 	queryStats,
 	queryAnalytics,
+	migrateFromSqlite,
 	VALID_GRANULARITIES,
 	ALLOWED_FILTERS,
 	type Granularity,
@@ -71,4 +72,9 @@ admin.get("/analytics", async (c) => {
 	return c.json({ data, filters, granularity, periods });
 });
 
+admin.post("/telemetry/migrate", async (c) => {
+	const result = await migrateFromSqlite();
+	return c.json(result);
+});
+
 export default admin;