homeio

1import "server-only";
2
3import { and, asc, desc, eq, inArray, or, sql } from "drizzle-orm";
4import { db } from "@/lib/server/db/drizzle";
5import { appOperations, appStacks } from "@/lib/server/db/schema";
6import type {
7  InstalledApp,
8  InstalledAppActiveOperation,
9  StoreOperationAction,
10  StoreOperationStatus,
11} from "@/lib/shared/contracts/apps";
12
13export async function listInstalledAppsFromDb(): Promise<InstalledApp[]> {
14  const tableCheck = await db.execute<{ table_exists: string | null }>(
15    sql`SELECT to_regclass('public.app_stacks') AS table_exists`,
16  );
17  if (!tableCheck.rows[0]?.table_exists) {
18    return [];
19  }
20
21  const rows = await db
22    .select({
23      appId: appStacks.appId,
24      templateName: appStacks.templateName,
25      stackName: appStacks.stackName,
26      composePath: appStacks.composePath,
27      webUiPort: appStacks.webUiPort,
28      webUiUrl: appStacks.webUiUrl,
29      displayName: appStacks.displayName,
30      updatedAt: appStacks.updatedAt,
31    })
32    .from(appStacks)
33    .where(eq(appStacks.status, "installed"))
34    .orderBy(asc(sql`COALESCE(${appStacks.displayName}, ${appStacks.templateName})`))
35    .limit(200);
36
37  return rows.map((row) => ({
38    id: row.appId,
39    name: row.displayName || row.templateName || row.appId,
40    stackName: row.stackName,
41    composePath: row.composePath,
42    webUiPort: row.webUiPort,
43    webUiUrl: row.webUiUrl ?? null,
44    status: "unknown" as const,
45    activeOperation: null,
46    updatedAt: row.updatedAt instanceof Date ? row.updatedAt.toISOString() : row.updatedAt,
47  }));
48}
49
50export async function findActiveStoreOperationsByAppIds(
51  appIds: string[],
52): Promise<Record<string, InstalledAppActiveOperation>> {
53  if (appIds.length === 0) {
54    return {};
55  }
56
57  const tableCheck = await db.execute<{ table_exists: string | null }>(
58    sql`SELECT to_regclass('public.app_operations') AS table_exists`,
59  );
60  if (!tableCheck.rows[0]?.table_exists) {
61    return {};
62  }
63
64  const rows = await db
65    .select({
66      id: appOperations.id,
67      appId: appOperations.appId,
68      action: appOperations.action,
69      status: appOperations.status,
70      progressPercent: appOperations.progressPercent,
71      currentStep: appOperations.currentStep,
72      updatedAt: appOperations.updatedAt,
73    })
74    .from(appOperations)
75    .where(
76      and(
77        inArray(appOperations.appId, appIds),
78        or(eq(appOperations.status, "queued"), eq(appOperations.status, "running")),
79      ),
80    )
81    .orderBy(asc(appOperations.appId), desc(appOperations.updatedAt));
82
83  const activeByAppId: Record<string, InstalledAppActiveOperation> = {};
84
85  for (const row of rows) {
86    if (activeByAppId[row.appId]) {
87      continue;
88    }
89
90    activeByAppId[row.appId] = {
91      id: row.id,
92      action: row.action as StoreOperationAction,
93      status: row.status as StoreOperationStatus,
94      progressPercent: row.progressPercent,
95      currentStep: row.currentStep,
96      updatedAt: row.updatedAt instanceof Date ? row.updatedAt.toISOString() : row.updatedAt,
97    };
98  }
99
100  return activeByAppId;
101}
102