feat: replace mysql with sqlite (#393)

Author: anbraten

docker-compose.yml

@@ -8,19 +8,6 @@ services:
       - 6379:6379
     restart: unless-stopped
 
-  mysql:
-    image: mariadb:12.2.2
-    environment:
-      MYSQL_RANDOM_ROOT_PASSWORD: true
-      MYSQL_DATABASE: lagoss
-      MYSQL_USER: lagoss
-      MYSQL_PASSWORD: ${MYSQL_PASSWORD}
-    ports:
-      - 3306:3306
-    volumes:
-      - mysql:/var/lib/mysql
-    restart: unless-stopped
-
   prometheus:
     image: prom/prometheus:v3.9.1
     ports:
@@ -70,7 +57,6 @@ services:
 
 volumes:
   valkey:
-  mysql:
   prometheus:
   grafana:
   clickhouse:

packages/dashboard/.env.example

@@ -1,8 +1,5 @@
-NEXTAUTH_URL=http://localhost:3000
-NEXTAUTH_SECRET=
-
 REDIS_URL=redis://localhost:6379
-DATABASE_URL=mysql://root:mysql@localhost:3306/lagoss
+NUXT_DATABASE_URL=file:.data/lagoss.sqlite
 LAGOSS_RESTRICT_LOGIN=false
 LAGOSS_BLACKLISTED_FUNCTIONS_NAMES=
 LAGOSS_ROOT_SCHEM=http
@@ -17,23 +14,10 @@ S3_SECRET_ACCESS_KEY=supersecret
 
 GITHUB_CLIENT_ID=
 GITHUB_CLIENT_SECRET=
-GOOGLE_CLIENT_ID=
-GOOGLE_CLIENT_SECRET=
 
 AXIOM_ORG_ID=
 AXIOM_TOKEN=
 
 CLICKHOUSE_URL=http://localhost:8123
 CLICKHOUSE_USER=default
 CLICKHOUSE_PASSWORD=
-
-STRIPE_SECRET_KEY=
-STRIPE_WEBHOOK_SECRET=
-STRIPE_PRO_PLAN_PRICE_ID=
-STRIPE_PRO_PLAN_PRICE_ID_METERED=
-
-SMTP_HOST=
-SMTP_PORT=
-SMTP_USER=
-SMTP_PASSWORD=
-SMTP_FROM=

packages/dashboard/app/components/AppBar.vue

@@ -31,7 +31,6 @@
               :to="`/organizations/${organization.id}`"
               variant="ghost"
               class="w-full"
-              @click="selectOrganization(organization.id)"
             >
               <UAvatar :alt="organization.name" size="xs" />
               <span class="truncate">{{ organization.name }}</span>
@@ -113,7 +112,7 @@ const isDark = computed({
   },
 });
 
-const { user, logout, selectOrganization } = await useAuth();
+const { user, logout } = await useAuth();
 
 const { data: organizations } = await useFetch('/api/organizations');
 

packages/dashboard/app/composables/auth.ts

@@ -3,7 +3,7 @@ export async function useAuth() {
 
   const user = computed(() => data.value?.user ?? null);
 
-  const isAuthenticated = computed(() => !!user.value?.id);
+  const isAuthenticated = computed(() => !!user.value);
 
   function login() {
     window.location.href = '/api/auth/login';
@@ -13,21 +13,11 @@ export async function useAuth() {
     window.location.href = '/api/auth/logout';
   }
 
-  // TODO: select using link params and remove the currentOrganizationId property
-  async function selectOrganization(organizationId: string) {
-    await $fetch(`/api/user/`, {
-      method: 'PATCH',
-      body: JSON.stringify({ currentOrganizationId: organizationId }),
-    });
-    await updateAuthSession();
-  }
-
   return {
     isAuthenticated,
     user,
     login,
     logout,
-    selectOrganization,
     updateAuthSession,
   };
 }

packages/dashboard/drizzle.config.ts

@@ -4,8 +4,8 @@ import { defineConfig } from 'drizzle-kit';
 export default defineConfig({
   schema: './server/db/schema.ts',
   out: './server/db/migrations',
-  dialect: 'mysql',
+  dialect: 'sqlite',
   dbCredentials: {
-    url: process.env.NUXT_DATABASE_URL || 'mysql://root:root@localhost:3306/drizzle',
+    url: process.env.NUXT_DATABASE_URL || 'file:.data/lagoss.sqlite',
   },
 });

packages/dashboard/nuxt.config.ts

@@ -69,7 +69,7 @@ export default defineNuxtConfig({
         forcePathStyle: true,
       },
       database: {
-        url: 'mysql://root:lagoss@localhost:3306/lagoss',
+        url: 'file:.data/lagoss.sqlite',
       },
       redis: {
         url: 'redis://localhost:6379',

packages/dashboard/package.json

@@ -19,6 +19,7 @@
     "@clickhouse/client": "^1.17.0",
     "@iconify-json/heroicons": "^1.2.3",
     "@iconify-json/ion": "^1.2.6",
+    "@libsql/client": "^0.17.0",
     "@nuxt/ui": "^4.5.0",
     "@scaleway/use-random-name": "^1.0.10",
     "@types/nodemailer": "^7.0.11",
@@ -30,7 +31,6 @@
     "drizzle-orm": "^0.45.1",
     "is-in-subnet": "^4.0.1",
     "monaco-editor": "^0.55.1",
-    "mysql2": "^3.18.0",
     "nodemailer": "^8.0.1",
     "nuxt": "^4.3.1",
     "nuxt-monaco-editor": "^1.3.2",

packages/dashboard/server/api/apps/[appId]/code.get.ts

@@ -36,13 +36,11 @@ export default defineEventHandler(async event => {
   const db = await useDB();
   const app = await requireApp(event);
 
-  const deployment = await getFirst(
-    db
-      .select()
-      .from(deploymentSchema)
-      .where(and(eq(deploymentSchema.appId, app.id), eq(deploymentSchema.isProduction, 1)))
-      .execute(),
-  );
+  const deployment = await db
+    .select()
+    .from(deploymentSchema)
+    .where(and(eq(deploymentSchema.appId, app.id), eq(deploymentSchema.isProduction, true)))
+    .get();
 
   if (!deployment) {
     throw createError({

packages/dashboard/server/api/apps/[appId]/deployments/[deploymentId]/deploy.post.ts

@@ -17,13 +17,11 @@ export default defineEventHandler(async event => {
     });
   }
 
-  const deployment = await getFirst(
-    db
-      .select()
-      .from(deploymentSchema)
-      .where(and(eq(deploymentSchema.id, deploymentId), eq(deploymentSchema.appId, app.id)))
-      .execute(),
-  );
+  const deployment = await db
+    .select()
+    .from(deploymentSchema)
+    .where(and(eq(deploymentSchema.id, deploymentId), eq(deploymentSchema.appId, app.id)))
+    .get();
   if (!deployment) {
     throw createError({
       status: 404,
@@ -37,26 +35,24 @@ export default defineEventHandler(async event => {
     })
     .parseAsync(await readBody(event));
 
-  const hasProductionDeployment = await getFirst(
-    db
-      .select()
-      .from(deploymentSchema)
-      .where(and(eq(deploymentSchema.appId, app.id), eq(deploymentSchema.isProduction, 1)))
-      .execute(),
-  );
+  const hasProductionDeployment = await db
+    .select()
+    .from(deploymentSchema)
+    .where(and(eq(deploymentSchema.appId, app.id), eq(deploymentSchema.isProduction, true)))
+    .get();
 
   if (input.isProduction && hasProductionDeployment) {
     await db
       .update(deploymentSchema)
-      .set({ isProduction: 0 })
+      .set({ isProduction: false })
       .where(eq(deploymentSchema.appId, deployment.appId))
       .execute();
   }
 
   await db
     .update(deploymentSchema)
     .set({
-      isProduction: !hasProductionDeployment || input.isProduction ? 1 : 0,
+      isProduction: !hasProductionDeployment || input.isProduction,
     })
     .where(eq(deploymentSchema.id, deploymentId))
     .execute();
@@ -75,7 +71,7 @@ export default defineEventHandler(async event => {
     cron: app.cron,
     cronRegion: app.cronRegion,
     env: envStringToObject(env),
-    isProduction: deployment.isProduction === 1,
+    isProduction: deployment.isProduction,
     assets: parseAssets(deployment.assets),
   });
 

packages/dashboard/server/api/apps/[appId]/deployments/[deploymentId]/index.delete.ts

@@ -14,21 +14,19 @@ export default defineEventHandler(async event => {
     });
   }
 
-  const deployment = await getFirst(
-    db
-      .select()
-      .from(deploymentSchema)
-      .where(and(eq(deploymentSchema.id, deploymentId), eq(deploymentSchema.appId, app.id)))
-      .execute(),
-  );
+  const deployment = await db
+    .select()
+    .from(deploymentSchema)
+    .where(and(eq(deploymentSchema.id, deploymentId), eq(deploymentSchema.appId, app.id)))
+    .get();
   if (!deployment) {
     throw createError({
       status: 404,
       message: 'Deployment not found',
     });
   }
 
-  if (deployment.isProduction === 1) {
+  if (deployment.isProduction) {
     throw createError({
       status: 400,
       message: 'Cannot delete a production deployment, promote another deployment first.',