refactor: introduce platform control commands (#149)

Author: Che-Zhu

docs/architecture-evolution.md

@@ -189,7 +189,7 @@ Typical examples:
 - task prerequisite rules
 - lifecycle transition rules
 
-### `lib/control/`
+### `lib/platform/control/`
 
 Should contain:
 

lib/actions/database.ts

@@ -10,16 +10,13 @@
 import type { Database } from '@prisma/client'
 
 import { auth } from '@/lib/auth'
-import { prisma } from '@/lib/db'
-import { getK8sServiceForUser } from '@/lib/k8s/k8s-service-helper'
-import { KubernetesUtils } from '@/lib/k8s/kubernetes-utils'
-import { VERSIONS } from '@/lib/k8s/versions'
-import { logger as baseLogger } from '@/lib/logger'
+import {
+  createDatabaseCommand,
+  deleteDatabaseCommand,
+} from '@/lib/platform/control/commands/database'
 
 import type { ActionResult } from './types'
 
-const logger = baseLogger.child({ module: 'actions/database' })
-
 /**
  * Create a database for an existing project
  *
@@ -35,66 +32,11 @@ export async function createDatabase(
     return { success: false, error: 'Unauthorized' }
   }
 
-  // Verify project exists and belongs to user
-  const project = await prisma.project.findUnique({
-    where: { id: projectId },
-    include: { databases: true },
-  })
-
-  if (!project) {
-    return { success: false, error: 'Project not found' }
-  }
-
-  if (project.userId !== session.user.id) {
-    return { success: false, error: 'Unauthorized' }
-  }
-
-  // Check if database already exists
-  if (project.databases.length > 0) {
-    return { success: false, error: 'Database already exists for this project' }
-  }
-
-  // Get K8s service for user
-  let k8sService
-  let namespace
-  try {
-    k8sService = await getK8sServiceForUser(session.user.id)
-    namespace = k8sService.getDefaultNamespace()
-  } catch (error) {
-    if (error instanceof Error && error.message.includes('does not have KUBECONFIG configured')) {
-      return {
-        success: false,
-        error: 'Please configure your kubeconfig before creating a database',
-      }
-    }
-    throw error
-  }
-
-  // Generate database name if not provided
-  const k8sProjectName = KubernetesUtils.toK8sProjectName(project.name)
-  const randomSuffix = KubernetesUtils.generateRandomString()
-  const finalDatabaseName = databaseName || `${k8sProjectName}-db-${randomSuffix}`
-
-  // Create Database record
-  const database = await prisma.database.create({
-    data: {
-      projectId: project.id,
-      name: finalDatabaseName,
-      k8sNamespace: namespace,
-      databaseName: finalDatabaseName,
-      status: 'CREATING',
-      lockedUntil: null,
-      storageSize: VERSIONS.STORAGE.DATABASE_SIZE,
-      cpuRequest: VERSIONS.RESOURCES.DATABASE.requests.cpu,
-      cpuLimit: VERSIONS.RESOURCES.DATABASE.limits.cpu,
-      memoryRequest: VERSIONS.RESOURCES.DATABASE.requests.memory,
-      memoryLimit: VERSIONS.RESOURCES.DATABASE.limits.memory,
-    },
+  return createDatabaseCommand({
+    userId: session.user.id,
+    projectId,
+    databaseName,
   })
-
-  logger.info(`Database created: ${database.id} for project: ${project.id}`)
-
-  return { success: true, data: database }
 }
 
 /**
@@ -108,30 +50,8 @@ export async function deleteDatabase(databaseId: string): Promise<ActionResult<v
     return { success: false, error: 'Unauthorized' }
   }
 
-  // Verify database exists and belongs to user
-  const database = await prisma.database.findUnique({
-    where: { id: databaseId },
-    include: { project: true },
-  })
-
-  if (!database) {
-    return { success: false, error: 'Database not found' }
-  }
-
-  if (database.project.userId !== session.user.id) {
-    return { success: false, error: 'Unauthorized' }
-  }
-
-  // Update status to TERMINATING (reconciliation job will handle K8s deletion)
-  await prisma.database.update({
-    where: { id: databaseId },
-    data: {
-      status: 'TERMINATING',
-      lockedUntil: null, // Unlock for reconciliation job
-    },
+  return deleteDatabaseCommand({
+    userId: session.user.id,
+    databaseId,
   })
-
-  logger.info(`Database ${databaseId} marked for deletion`)
-
-  return { success: true, data: undefined }
 }