a91a4c4689
Some checks failed
Build and Push Docker Image / build-and-push (push) Has been cancelled
429 lines
19 KiB
JavaScript
429 lines
19 KiB
JavaScript
/**
|
|
* Database migration script using PrismaClient raw SQL.
|
|
* Does NOT require the Prisma CLI (npx prisma) — only the runtime client.
|
|
* Safe to run multiple times (all statements are idempotent).
|
|
*
|
|
* SAFETY RULES:
|
|
* - NO deleteMany / DELETE / TRUNCATE on icon_assets, icon_categories,
|
|
* tenant_symbols, or features. These contain user data.
|
|
* - All operations must be idempotent (safe to re-run).
|
|
* - In production, destructive operations are blocked.
|
|
*/
|
|
const { PrismaClient } = require('@prisma/client')
|
|
|
|
const prisma = new PrismaClient()
|
|
|
|
async function migrate() {
|
|
console.log('🔧 Running database migrations...')
|
|
|
|
// ─── Step 1: Ensure enum values exist ───
|
|
console.log(' [1/7] Ensuring enum values...')
|
|
const enumMigrations = [
|
|
// Role enum
|
|
`DO $$ BEGIN IF NOT EXISTS (SELECT 1 FROM pg_enum WHERE enumlabel = 'SERVER_ADMIN' AND enumtypid = (SELECT oid FROM pg_type WHERE typname = 'Role')) THEN ALTER TYPE "Role" ADD VALUE 'SERVER_ADMIN'; END IF; END$$;`,
|
|
`DO $$ BEGIN IF NOT EXISTS (SELECT 1 FROM pg_enum WHERE enumlabel = 'TENANT_ADMIN' AND enumtypid = (SELECT oid FROM pg_type WHERE typname = 'Role')) THEN ALTER TYPE "Role" ADD VALUE 'TENANT_ADMIN'; END IF; END$$;`,
|
|
`DO $$ BEGIN IF NOT EXISTS (SELECT 1 FROM pg_enum WHERE enumlabel = 'OPERATOR' AND enumtypid = (SELECT oid FROM pg_type WHERE typname = 'Role')) THEN ALTER TYPE "Role" ADD VALUE 'OPERATOR'; END IF; END$$;`,
|
|
`DO $$ BEGIN IF NOT EXISTS (SELECT 1 FROM pg_enum WHERE enumlabel = 'VIEWER' AND enumtypid = (SELECT oid FROM pg_type WHERE typname = 'Role')) THEN ALTER TYPE "Role" ADD VALUE 'VIEWER'; END IF; END$$;`,
|
|
// DictionaryScope enum
|
|
`DO $$ BEGIN IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'DictionaryScope') THEN CREATE TYPE "DictionaryScope" AS ENUM ('GLOBAL', 'TENANT'); END IF; END$$;`,
|
|
]
|
|
for (const sql of enumMigrations) {
|
|
try { await prisma.$executeRawUnsafe(sql) } catch (e) { /* enum might already exist */ }
|
|
}
|
|
|
|
// ─── Step 2: Migrate old enum data ───
|
|
console.log(' [2/7] Migrating old data...')
|
|
const dataMigrations = [
|
|
`UPDATE users SET role = 'SERVER_ADMIN' WHERE role = 'ADMIN'`,
|
|
`UPDATE users SET role = 'OPERATOR' WHERE role = 'EDITOR'`,
|
|
`UPDATE tenants SET "subscriptionStatus" = 'ACTIVE' WHERE "subscriptionStatus" = 'TRIAL'`,
|
|
]
|
|
for (const sql of dataMigrations) {
|
|
try { await prisma.$executeRawUnsafe(sql) } catch (e) { /* table might not exist yet */ }
|
|
}
|
|
|
|
// ─── Step 3: Add missing columns (idempotent) ───
|
|
console.log(' [3/7] Adding missing columns...')
|
|
const columnMigrations = [
|
|
// Tenants
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "logoUrl" TEXT`,
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "logoFileKey" TEXT`,
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "hiddenIconIds" TEXT[] DEFAULT '{}'`,
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "journalSuggestions" TEXT[] DEFAULT '{}'`,
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "contactEmail" TEXT`,
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "contactPhone" TEXT`,
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "address" TEXT`,
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "notes" TEXT`,
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "maxUsers" INTEGER DEFAULT 5`,
|
|
`ALTER TABLE tenants ADD COLUMN IF NOT EXISTS "maxProjects" INTEGER DEFAULT 10`,
|
|
// Users
|
|
`ALTER TABLE users ADD COLUMN IF NOT EXISTS "lastLoginAt" TIMESTAMP`,
|
|
`ALTER TABLE users ADD COLUMN IF NOT EXISTS "emailVerified" BOOLEAN DEFAULT true`,
|
|
`ALTER TABLE users ADD COLUMN IF NOT EXISTS "emailVerificationToken" TEXT`,
|
|
`ALTER TABLE users ADD COLUMN IF NOT EXISTS "resetToken" TEXT`,
|
|
`ALTER TABLE users ADD COLUMN IF NOT EXISTS "resetTokenExpiry" TIMESTAMP`,
|
|
// Icon categories
|
|
`ALTER TABLE icon_categories ADD COLUMN IF NOT EXISTS "isGlobal" BOOLEAN DEFAULT false`,
|
|
`ALTER TABLE icon_categories ADD COLUMN IF NOT EXISTS "tenantId" TEXT`,
|
|
// Projects
|
|
`ALTER TABLE projects ADD COLUMN IF NOT EXISTS "planImageKey" TEXT`,
|
|
`ALTER TABLE projects ADD COLUMN IF NOT EXISTS "planBounds" JSONB`,
|
|
`ALTER TABLE projects ADD COLUMN IF NOT EXISTS "einsatzleiter" TEXT`,
|
|
`ALTER TABLE projects ADD COLUMN IF NOT EXISTS "journalfuehrer" TEXT`,
|
|
`ALTER TABLE projects ADD COLUMN IF NOT EXISTS "editingById" TEXT`,
|
|
`ALTER TABLE projects ADD COLUMN IF NOT EXISTS "editingUserName" TEXT`,
|
|
`ALTER TABLE projects ADD COLUMN IF NOT EXISTS "editingSessionId" TEXT`,
|
|
`ALTER TABLE projects ADD COLUMN IF NOT EXISTS "editingStartedAt" TIMESTAMP`,
|
|
`ALTER TABLE projects ADD COLUMN IF NOT EXISTS "editingHeartbeat" TIMESTAMP`,
|
|
// Journal
|
|
`ALTER TABLE journal_entries ADD COLUMN IF NOT EXISTS "isCorrected" BOOLEAN DEFAULT false`,
|
|
`ALTER TABLE journal_entries ADD COLUMN IF NOT EXISTS "correctionOfId" TEXT`,
|
|
]
|
|
let added = 0
|
|
for (const sql of columnMigrations) {
|
|
try {
|
|
await prisma.$executeRawUnsafe(sql)
|
|
added++
|
|
} catch (e) {
|
|
// Table might not exist yet — that's OK, prisma db push or first seed will create it
|
|
}
|
|
}
|
|
console.log(` ${added}/${columnMigrations.length} column migrations executed`)
|
|
|
|
// ─── Step 4: Create new tables ───
|
|
console.log(' [4/7] Creating new tables...')
|
|
const tableMigrations = [
|
|
// Dictionary entries table
|
|
`CREATE TABLE IF NOT EXISTS dictionary_entries (
|
|
id TEXT PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
word TEXT NOT NULL,
|
|
scope "DictionaryScope" NOT NULL DEFAULT 'GLOBAL',
|
|
"createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
"tenantId" TEXT REFERENCES tenants(id) ON DELETE CASCADE,
|
|
UNIQUE(word, "tenantId")
|
|
)`,
|
|
// Rapports table
|
|
`CREATE TABLE IF NOT EXISTS rapports (
|
|
id TEXT PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
"reportNumber" TEXT NOT NULL,
|
|
token TEXT NOT NULL UNIQUE DEFAULT gen_random_uuid(),
|
|
data JSONB NOT NULL DEFAULT '{}',
|
|
"generatedAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
"createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
"updatedAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
"projectId" TEXT NOT NULL REFERENCES projects(id) ON DELETE CASCADE,
|
|
"tenantId" TEXT NOT NULL REFERENCES tenants(id) ON DELETE CASCADE,
|
|
"createdById" TEXT REFERENCES users(id) ON DELETE SET NULL,
|
|
UNIQUE("tenantId", "reportNumber")
|
|
)`,
|
|
]
|
|
for (const sql of tableMigrations) {
|
|
try { await prisma.$executeRawUnsafe(sql) } catch (e) { /* table might already exist */ }
|
|
}
|
|
|
|
// ─── Step 5: Set safe defaults ───
|
|
console.log(' [5/7] Setting defaults...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`UPDATE tenants SET "subscriptionStatus" = 'ACTIVE' WHERE "subscriptionStatus" = 'TRIAL'`)
|
|
} catch (e) { /* ignore */ }
|
|
|
|
// ─── Step 6: Detect orphan users (log only, no deletion) ───
|
|
console.log(' [6/7] Checking for orphan users...')
|
|
try {
|
|
const orphans = await prisma.user.findMany({
|
|
where: {
|
|
role: { not: 'SERVER_ADMIN' },
|
|
memberships: { none: {} },
|
|
},
|
|
select: { id: true, email: true, name: true },
|
|
})
|
|
if (orphans.length > 0) {
|
|
console.log(` ⚠️ Found ${orphans.length} orphan user(s) (NOT deleting — manual review required):`)
|
|
for (const o of orphans) {
|
|
console.log(` - ${o.email} (${o.name})`)
|
|
}
|
|
} else {
|
|
console.log(' No orphan users found')
|
|
}
|
|
} catch (e) {
|
|
console.log(' Orphan check skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 7: Backfill logoFileKey from logoUrl ───
|
|
console.log(' [7/7] Backfilling logoFileKey...')
|
|
try {
|
|
// Extract fileKey from MinIO URLs: the path after the bucket name
|
|
// e.g. http://localhost:9002/lageplan-icons/logos/tenant-xxx.png → logos/tenant-xxx.png
|
|
const tenants = await prisma.tenant.findMany({
|
|
where: { logoUrl: { not: null }, logoFileKey: null },
|
|
select: { id: true, logoUrl: true },
|
|
})
|
|
for (const t of tenants) {
|
|
if (!t.logoUrl) continue
|
|
// Try to extract the fileKey from the URL
|
|
const match = t.logoUrl.match(/logos\/[^?]+/)
|
|
if (match) {
|
|
await prisma.tenant.update({
|
|
where: { id: t.id },
|
|
data: { logoFileKey: match[0] },
|
|
})
|
|
}
|
|
}
|
|
if (tenants.length > 0) console.log(` Backfilled ${tenants.length} logo fileKey(s)`)
|
|
} catch (e) {
|
|
console.log(' Logo backfill skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 8: Drop unique constraint on rapports(tenantId, reportNumber) ───
|
|
console.log(' [8] Dropping rapports unique constraint on (tenantId, reportNumber)...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`ALTER TABLE "rapports" DROP CONSTRAINT IF EXISTS "rapports_tenantId_reportNumber_key"`)
|
|
console.log(' Constraint dropped (or did not exist)')
|
|
} catch (e) {
|
|
console.log(' Constraint drop skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 9: Add einsatzNr column to projects ───
|
|
console.log(' [9] Adding einsatzNr column to projects...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`ALTER TABLE "projects" ADD COLUMN IF NOT EXISTS "einsatzNr" TEXT`)
|
|
console.log(' einsatzNr column added (or already exists)')
|
|
} catch (e) {
|
|
console.log(' einsatzNr column skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 10: Make rapports.tenantId nullable ───
|
|
console.log(' [10] Making rapports.tenantId nullable...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`ALTER TABLE "rapports" ALTER COLUMN "tenantId" DROP NOT NULL`)
|
|
console.log(' rapports.tenantId is now nullable')
|
|
} catch (e) {
|
|
console.log(' rapports.tenantId nullable skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 11: Add privacy consent columns to tenants ───
|
|
console.log(' [11] Adding privacy consent columns to tenants...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`ALTER TABLE "tenants" ADD COLUMN IF NOT EXISTS "privacyAccepted" BOOLEAN DEFAULT false`)
|
|
await prisma.$executeRawUnsafe(`ALTER TABLE "tenants" ADD COLUMN IF NOT EXISTS "privacyAcceptedAt" TIMESTAMP`)
|
|
await prisma.$executeRawUnsafe(`ALTER TABLE "tenants" ADD COLUMN IF NOT EXISTS "adminAccessAccepted" BOOLEAN DEFAULT false`)
|
|
console.log(' Privacy consent columns added')
|
|
} catch (e) {
|
|
console.log(' Privacy consent columns skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 12: Create tenant_symbols table (CRITICAL — fail-fast) ───
|
|
console.log(' [12] Creating tenant_symbols table...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`
|
|
CREATE TABLE IF NOT EXISTS tenant_symbols (
|
|
id TEXT PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
"isActive" BOOLEAN NOT NULL DEFAULT true,
|
|
"tenantId" TEXT NOT NULL REFERENCES tenants(id) ON DELETE CASCADE,
|
|
"iconId" TEXT REFERENCES icon_assets(id) ON DELETE SET NULL,
|
|
UNIQUE("tenantId", "iconId")
|
|
)
|
|
`)
|
|
console.log(' tenant_symbols table created (or already exists)')
|
|
} catch (e) {
|
|
console.error(' ❌ CRITICAL: tenant_symbols table creation failed:', e.message)
|
|
throw e
|
|
}
|
|
|
|
// ─── Step 13: Create symbol_templates table ───
|
|
console.log(' [13] Creating symbol_templates table...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`
|
|
CREATE TABLE IF NOT EXISTS symbol_templates (
|
|
id TEXT PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
"fileKey" TEXT NOT NULL,
|
|
"originalFilename" TEXT NOT NULL,
|
|
"displayName" TEXT,
|
|
"categoryName" TEXT,
|
|
"svgPath" TEXT,
|
|
"metadata" JSONB NOT NULL DEFAULT '{}',
|
|
"createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
"updatedAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
UNIQUE("fileKey")
|
|
)
|
|
`)
|
|
console.log(' symbol_templates table created (or already exists)')
|
|
} catch (e) {
|
|
console.log(' symbol_templates table skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 14: Create tenant_categories table (CRITICAL — fail-fast) ───
|
|
console.log(' [14] Creating tenant_categories table...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`
|
|
CREATE TABLE IF NOT EXISTS tenant_categories (
|
|
id TEXT PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
"name" TEXT NOT NULL,
|
|
"description" TEXT,
|
|
"sortOrder" INTEGER NOT NULL DEFAULT 0,
|
|
"isActive" BOOLEAN NOT NULL DEFAULT true,
|
|
"createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
"updatedAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
"tenantId" TEXT NOT NULL REFERENCES tenants(id) ON DELETE CASCADE
|
|
)
|
|
`)
|
|
console.log(' tenant_categories table created (or already exists)')
|
|
} catch (e) {
|
|
console.error(' ❌ CRITICAL: tenant_categories table creation failed:', e.message)
|
|
throw e
|
|
}
|
|
|
|
// ─── Step 14b: Ensure tenant_categories has NOT NULL defaults ───
|
|
console.log(' [14b] Ensuring tenant_categories columns...')
|
|
const tcColumns = [
|
|
`ALTER TABLE tenant_categories ALTER COLUMN "isActive" SET DEFAULT true`,
|
|
`ALTER TABLE tenant_categories ALTER COLUMN "sortOrder" SET DEFAULT 0`,
|
|
`ALTER TABLE tenant_categories ALTER COLUMN "createdAt" SET DEFAULT CURRENT_TIMESTAMP`,
|
|
`ALTER TABLE tenant_categories ALTER COLUMN "updatedAt" SET DEFAULT CURRENT_TIMESTAMP`,
|
|
]
|
|
for (const sql of tcColumns) {
|
|
try { await prisma.$executeRawUnsafe(sql) } catch (e) { /* ignore */ }
|
|
}
|
|
|
|
// ─── Step 15: Extend tenant_symbols with Phase 1 columns ───
|
|
console.log(' [15] Extending tenant_symbols with Phase 1 columns...')
|
|
const tenantSymbolColumns = [
|
|
`ALTER TABLE tenant_symbols ADD COLUMN IF NOT EXISTS "name" TEXT`,
|
|
`ALTER TABLE tenant_symbols ADD COLUMN IF NOT EXISTS "svgPath" TEXT`,
|
|
`ALTER TABLE tenant_symbols ADD COLUMN IF NOT EXISTS "isUploaded" BOOLEAN NOT NULL DEFAULT false`,
|
|
`ALTER TABLE tenant_symbols ADD COLUMN IF NOT EXISTS "categoryId" TEXT`,
|
|
`ALTER TABLE tenant_symbols ADD COLUMN IF NOT EXISTS "migratedFromIconId" TEXT`,
|
|
`ALTER TABLE tenant_symbols ADD COLUMN IF NOT EXISTS "customName" TEXT`,
|
|
`ALTER TABLE tenant_symbols ADD COLUMN IF NOT EXISTS "sortOrder" INTEGER`,
|
|
`ALTER TABLE tenant_symbols ADD COLUMN IF NOT EXISTS "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP`,
|
|
`ALTER TABLE tenant_symbols ADD COLUMN IF NOT EXISTS "updatedAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP`,
|
|
]
|
|
let tsAdded = 0
|
|
for (const sql of tenantSymbolColumns) {
|
|
try { await prisma.$executeRawUnsafe(sql); tsAdded++ } catch (e) { /* ignore */ }
|
|
}
|
|
console.log(` ${tsAdded}/${tenantSymbolColumns.length} tenant_symbol columns added`)
|
|
|
|
// ─── Step 15b: Add tenant_symbols.categoryId FK separately (idempotent) ───
|
|
console.log(' [15b] Adding tenant_symbols.categoryId FK...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`
|
|
DO $$ BEGIN
|
|
IF NOT EXISTS (
|
|
SELECT 1 FROM information_schema.table_constraints
|
|
WHERE constraint_name = 'tenant_symbols_categoryId_fkey'
|
|
AND table_name = 'tenant_symbols'
|
|
) THEN
|
|
ALTER TABLE tenant_symbols
|
|
ADD CONSTRAINT "tenant_symbols_categoryId_fkey"
|
|
FOREIGN KEY ("categoryId") REFERENCES tenant_categories(id) ON DELETE SET NULL;
|
|
END IF;
|
|
EXCEPTION WHEN OTHERS THEN
|
|
RAISE NOTICE 'categoryId FK skipped: %', SQLERRM;
|
|
END $$;
|
|
`)
|
|
console.log(' ✅ tenant_symbols.categoryId FK added')
|
|
} catch (e) {
|
|
console.log(' categoryId FK skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 16: Fix tenant_symbols FK (CASCADE → SET NULL) ───
|
|
console.log(' [16] Fixing tenant_symbols.iconId FK (CASCADE → SET NULL)...')
|
|
try {
|
|
// Make iconId nullable
|
|
await prisma.$executeRawUnsafe(`ALTER TABLE tenant_symbols ALTER COLUMN "iconId" DROP NOT NULL`)
|
|
// Drop old cascade FK and recreate with SET NULL
|
|
await prisma.$executeRawUnsafe(`
|
|
DO $$ BEGIN
|
|
-- Drop existing FK constraint (name varies)
|
|
ALTER TABLE tenant_symbols DROP CONSTRAINT IF EXISTS "tenant_symbols_iconId_fkey";
|
|
ALTER TABLE tenant_symbols DROP CONSTRAINT IF EXISTS "tenant_symbols_iconId_icon_assets_id_fk";
|
|
-- Recreate with SET NULL
|
|
ALTER TABLE tenant_symbols
|
|
ADD CONSTRAINT "tenant_symbols_iconId_fkey"
|
|
FOREIGN KEY ("iconId") REFERENCES icon_assets(id) ON DELETE SET NULL;
|
|
EXCEPTION WHEN OTHERS THEN
|
|
RAISE NOTICE 'FK fix skipped: %', SQLERRM;
|
|
END $$;
|
|
`)
|
|
console.log(' ✅ tenant_symbols.iconId FK is now ON DELETE SET NULL')
|
|
} catch (e) {
|
|
console.log(' FK fix skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 17: Drop unique constraint on tenant_symbols(tenantId, iconId) ───
|
|
console.log(' [17] Dropping UNIQUE(tenantId, iconId) on tenant_symbols...')
|
|
try {
|
|
await prisma.$executeRawUnsafe(`ALTER TABLE tenant_symbols DROP CONSTRAINT IF EXISTS "tenant_symbols_tenantId_iconId_key"`)
|
|
console.log(' ✅ Unique constraint dropped (duplicates now allowed)')
|
|
} catch (e) {
|
|
console.log(' Unique constraint drop skipped:', e.message)
|
|
}
|
|
|
|
// ─── Step 18: Migrate legacy tenantSymbols (name, svgPath, categoryId, migratedFromIconId) ───
|
|
console.log(' [18] Migrating legacy tenantSymbols data...')
|
|
try {
|
|
const tenantsWithSymbols = await prisma.$queryRawUnsafe(`
|
|
SELECT "tenantId", COUNT(id) as cnt FROM tenant_symbols GROUP BY "tenantId"
|
|
`)
|
|
let catsCreated = 0
|
|
let symsMigrated = 0
|
|
for (const row of tenantsWithSymbols) {
|
|
const tenantId = row.tenantId
|
|
// Create default category if none exists for this tenant
|
|
let defaultCat = await prisma.$queryRawUnsafe(`
|
|
SELECT id FROM tenant_categories WHERE "tenantId" = '${tenantId}' AND name = 'Meine Symbole' LIMIT 1
|
|
`)
|
|
if (!defaultCat || !defaultCat.length) {
|
|
const newCatId = crypto.randomUUID()
|
|
await prisma.$executeRawUnsafe(`
|
|
INSERT INTO tenant_categories (id, "tenantId", name, "sortOrder", "createdAt", "updatedAt")
|
|
VALUES ('${newCatId}', '${tenantId}', 'Meine Symbole', 0, NOW(), NOW())
|
|
`)
|
|
defaultCat = [{ id: newCatId }]
|
|
catsCreated++
|
|
}
|
|
const catId = defaultCat[0].id
|
|
|
|
// Migrate symbols: set name, svgPath, categoryId, migratedFromIconId where null
|
|
await prisma.$executeRawUnsafe(`
|
|
UPDATE tenant_symbols ts
|
|
SET
|
|
name = COALESCE(ts.name, ts."customName", ia.name, 'Unbenannt'),
|
|
"svgPath" = COALESCE(ts."svgPath", ia."fileKey"),
|
|
"categoryId" = COALESCE(ts."categoryId", '${catId}'),
|
|
"migratedFromIconId" = COALESCE(ts."migratedFromIconId", ts."iconId"),
|
|
"updatedAt" = NOW()
|
|
FROM icon_assets ia
|
|
WHERE ts."tenantId" = '${tenantId}'
|
|
AND ia.id = ts."iconId"
|
|
AND (ts.name IS NULL OR ts."svgPath" IS NULL OR ts."categoryId" IS NULL OR ts."migratedFromIconId" IS NULL)
|
|
`)
|
|
// Also handle symbols where iconId is already null (orphaned) — at least set category & name
|
|
await prisma.$executeRawUnsafe(`
|
|
UPDATE tenant_symbols
|
|
SET
|
|
name = COALESCE(name, "customName", 'Unbenannt'),
|
|
"categoryId" = COALESCE("categoryId", '${catId}'),
|
|
"updatedAt" = NOW()
|
|
WHERE "tenantId" = '${tenantId}'
|
|
AND (name IS NULL OR "categoryId" IS NULL)
|
|
`)
|
|
symsMigrated++
|
|
}
|
|
console.log(` ✅ ${catsCreated} default categories created, ${symsMigrated} tenants processed`)
|
|
} catch (e) {
|
|
console.log(' Legacy migration skipped:', e.message)
|
|
}
|
|
|
|
console.log('✅ Database migrations complete')
|
|
}
|
|
|
|
migrate()
|
|
.then(async () => { await prisma.$disconnect() })
|
|
.catch(async (e) => {
|
|
console.error('Migration error:', e.message)
|
|
await prisma.$disconnect()
|
|
process.exit(1)
|
|
})
|