refactored design

src-tauri/database/schemas/haex.ts

@@ -9,30 +9,28 @@ import {
   type SQLiteColumnBuilderBase,
 } from 'drizzle-orm/sqlite-core'
 import tableNames from '../tableNames.json'
+import { crdtColumnNames } from '.'
 
 // Helper function to add common CRDT columns ( haexTimestamp)
 export const withCrdtColumns = <
   T extends Record<string, SQLiteColumnBuilderBase>,
 >(
   columns: T,
-  columnNames: { haexTimestamp: string },
 ) => ({
   ...columns,
-  haexTimestamp: text(columnNames.haexTimestamp),
+  haexTimestamp: text(crdtColumnNames.haexTimestamp),
 })
 
 export const haexSettings = sqliteTable(
   tableNames.haex.settings.name,
-  {
+  withCrdtColumns({
     id: text()
       .primaryKey()
       .$defaultFn(() => crypto.randomUUID()),
     key: text(),
     type: text(),
     value: text(),
-
-    haexTimestamp: text(tableNames.haex.settings.columns.haexTimestamp),
-  },
+  }),
   (table) => [unique().on(table.key, table.type, table.value)],
 )
 export type InsertHaexSettings = typeof haexSettings.$inferInsert
@@ -40,7 +38,7 @@ export type SelectHaexSettings = typeof haexSettings.$inferSelect
 
 export const haexExtensions = sqliteTable(
   tableNames.haex.extensions.name,
-  {
+  withCrdtColumns({
     id: text()
       .primaryKey()
       .$defaultFn(() => crypto.randomUUID()),
@@ -54,8 +52,7 @@ export const haexExtensions = sqliteTable(
     enabled: integer({ mode: 'boolean' }).default(true),
     icon: text(),
     signature: text().notNull(),
-    haexTimestamp: text(tableNames.haex.extensions.columns.haexTimestamp),
-  },
+  }),
   (table) => [
     // UNIQUE constraint: Pro Developer (public_key) kann nur eine Extension mit diesem Namen existieren
     unique().on(table.public_key, table.name),
@@ -66,7 +63,7 @@ export type SelectHaexExtensions = typeof haexExtensions.$inferSelect
 
 export const haexExtensionPermissions = sqliteTable(
   tableNames.haex.extension_permissions.name,
-  {
+  withCrdtColumns({
     id: text()
       .primaryKey()
       .$defaultFn(() => crypto.randomUUID()),
@@ -88,10 +85,7 @@ export const haexExtensionPermissions = sqliteTable(
     updateAt: integer('updated_at', { mode: 'timestamp' }).$onUpdate(
       () => new Date(),
     ),
-    haexTimestamp: text(
-      tableNames.haex.extension_permissions.columns.haexTimestamp,
-    ),
-  },
+  }),
   (table) => [
     unique().on(
       table.extensionId,
@@ -108,7 +102,7 @@ export type SelecthaexExtensionPermissions =
 
 export const haexNotifications = sqliteTable(
   tableNames.haex.notifications.name,
-  {
+  withCrdtColumns({
     id: text().primaryKey(),
     alt: text(),
     date: text(),
@@ -121,26 +115,23 @@ export const haexNotifications = sqliteTable(
     type: text({
       enum: ['error', 'success', 'warning', 'info', 'log'],
     }).notNull(),
-    haexTimestamp: text(tableNames.haex.notifications.columns.haexTimestamp),
-  },
+  }),
 )
 export type InsertHaexNotifications = typeof haexNotifications.$inferInsert
 export type SelectHaexNotifications = typeof haexNotifications.$inferSelect
 
 export const haexWorkspaces = sqliteTable(
   tableNames.haex.workspaces.name,
-  withCrdtColumns(
-    {
-      id: text(tableNames.haex.workspaces.columns.id)
-        .primaryKey()
-        .$defaultFn(() => crypto.randomUUID()),
-      name: text(tableNames.haex.workspaces.columns.name).notNull(),
-      position: integer(tableNames.haex.workspaces.columns.position)
-        .notNull()
-        .default(0),
-    },
-    tableNames.haex.workspaces.columns,
-  ),
+  withCrdtColumns({
+    id: text(tableNames.haex.workspaces.columns.id)
+      .primaryKey()
+      .$defaultFn(() => crypto.randomUUID()),
+    deviceId: text(tableNames.haex.workspaces.columns.deviceId).notNull(),
+    name: text(tableNames.haex.workspaces.columns.name).notNull(),
+    position: integer(tableNames.haex.workspaces.columns.position)
+      .notNull()
+      .default(0),
+  }),
   (table) => [unique().on(table.position)],
 )
 export type InsertHaexWorkspaces = typeof haexWorkspaces.$inferInsert
@@ -148,33 +139,31 @@ export type SelectHaexWorkspaces = typeof haexWorkspaces.$inferSelect
 
 export const haexDesktopItems = sqliteTable(
   tableNames.haex.desktop_items.name,
-  withCrdtColumns(
-    {
-      id: text(tableNames.haex.desktop_items.columns.id)
-        .primaryKey()
-        .$defaultFn(() => crypto.randomUUID()),
-      workspaceId: text(tableNames.haex.desktop_items.columns.workspaceId)
-        .notNull()
-        .references(() => haexWorkspaces.id, { onDelete: 'cascade' }),
-      itemType: text(tableNames.haex.desktop_items.columns.itemType, {
-        enum: ['system', 'extension', 'file', 'folder'],
-      }).notNull(),
-      // Für Extensions (wenn itemType = 'extension')
-      extensionId: text(tableNames.haex.desktop_items.columns.extensionId)
-        .references((): AnySQLiteColumn => haexExtensions.id, {
-          onDelete: 'cascade',
-        }),
-      // Für System Windows (wenn itemType = 'system')
-      systemWindowId: text(tableNames.haex.desktop_items.columns.systemWindowId),
-      positionX: integer(tableNames.haex.desktop_items.columns.positionX)
-        .notNull()
-        .default(0),
-      positionY: integer(tableNames.haex.desktop_items.columns.positionY)
-        .notNull()
-        .default(0),
-    },
-    tableNames.haex.desktop_items.columns,
-  ),
+  withCrdtColumns({
+    id: text(tableNames.haex.desktop_items.columns.id)
+      .primaryKey()
+      .$defaultFn(() => crypto.randomUUID()),
+    workspaceId: text(tableNames.haex.desktop_items.columns.workspaceId)
+      .notNull()
+      .references(() => haexWorkspaces.id, { onDelete: 'cascade' }),
+    itemType: text(tableNames.haex.desktop_items.columns.itemType, {
+      enum: ['system', 'extension', 'file', 'folder'],
+    }).notNull(),
+    // Für Extensions (wenn itemType = 'extension')
+    extensionId: text(
+      tableNames.haex.desktop_items.columns.extensionId,
+    ).references((): AnySQLiteColumn => haexExtensions.id, {
+      onDelete: 'cascade',
+    }),
+    // Für System Windows (wenn itemType = 'system')
+    systemWindowId: text(tableNames.haex.desktop_items.columns.systemWindowId),
+    positionX: integer(tableNames.haex.desktop_items.columns.positionX)
+      .notNull()
+      .default(0),
+    positionY: integer(tableNames.haex.desktop_items.columns.positionY)
+      .notNull()
+      .default(0),
+  }),
   (table) => [
     check(
       'item_reference',

src-tauri/database/schemas/index.ts

@@ -1,2 +1,5 @@
+export const crdtColumnNames = {
+  haexTimestamp: 'haex_timestamp',
+}
 export * from './crdt'
 export * from './haex'