[{"_1":2,"_170":-5,"_171":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","1351d8f1f447bd5e330991ab31e39fcdf7d5b4b4","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_147":148,"_167":168,"_169":-5},"handle","nbbaier","name","drizzleMigrations","path","main.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":110,"_111":-5,"_12":112,"_113":-5,"_114":20,"_115":-5,"_116":32,"_14":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":127,"_130":131,"_133":134,"_146":20},"id","e6efa630-c8ec-11f0-928c-42dde27851f2","createdAt",["D",1763958026076],"deletedAt","legacyEnvVars","privacy","public","description","Type-safe Drizzle migrations for Val Town (no filesystem needed)","imageUrl","5d1042a9-7b0b-499d-8a72-3a8ac7a4e185","pinnedFileId","pinPreview","screenshotVersion","likeCount","5f80108f-7ca4-4327-b77b-089dbe4b5a82","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_128":129},"profileImageUrl","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","org",{"_93":94,"_132":129,"_12":112},"avatar","branch",{"_135":136,"_95":43,"_101":137,"_138":102,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},"version",31,"e6f06124-c8ec-11f0-928c-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":149,"_95":98,"_150":151,"_152":-5,"_153":137,"_154":155,"_156":157,"_103":158,"_135":159,"_160":161,"_162":163,"_164":20,"_165":-5,"_97":166},"cd655428-c8ef-11f0-bd04-42dde27851f2","fileId","e6f3abfe-c8ec-11f0-928c-42dde27851f2","parentId","branchId","branchVersion",7,"latest",true,["D",1763959271707],1,"fileType","script","content","/**\n * Lightweight Drizzle Schema to SQL Migration Generator\n * Built for Val Town (no filesystem, no drizzle-kit)\n *\n * Usage:\n * import { generateCreateTableSQL, migrate } from '@YOUR_USERNAME/drizzleMigrations';\n *\n * const sql = generateCreateTableSQL(myTable);\n * // or\n * await migrate(db, { users, posts, ... });\n */\n\n// Symbol keys that Drizzle uses\nconst DRIZZLE_SYMBOLS = {\n\tName: Symbol.for(\"drizzle:Name\"),\n\tColumns: Symbol.for(\"drizzle:Columns\"),\n\tSQLiteInlineForeignKeys: Symbol.for(\"drizzle:SQLiteInlineForeignKeys\"),\n\tExtraConfigBuilder: Symbol.for(\"drizzle:ExtraConfigBuilder\"),\n};\n\ninterface ColumnMetadata {\n\tname: string;\n\tcolumnType: string;\n\tdataType: string;\n\tnotNull: boolean;\n\tprimary: boolean;\n\tdefault?: any;\n\tisUnique: boolean;\n\tautoIncrement?: boolean;\n\tenumValues?: string[];\n\tconfig?: any;\n}\n\ninterface ForeignKeyMetadata {\n\treference: () => any;\n\tonUpdate?: string;\n\tonDelete?: string;\n}\n\n/**\n * Generate CREATE TABLE SQL for a Drizzle table\n */\nexport function generateCreateTableSQL(table: any): string {\n\tconst tableName = table[DRIZZLE_SYMBOLS.Name];\n\tconst columns = table[DRIZZLE_SYMBOLS.Columns];\n\n\tif (!tableName || !columns) {\n\t\tthrow new Error(\"Invalid Drizzle table object\");\n\t}\n\n\tconst columnDefs: string[] = [];\n\tconst constraints: string[] = [];\n\n\t// Process columns\n\tfor (const [_key, column] of Object.entries(columns)) {\n\t\tconst col = column as ColumnMetadata;\n\t\tcolumnDefs.push(generateColumnDef(col));\n\t}\n\n\t// Process foreign keys\n\tconst foreignKeys = table[DRIZZLE_SYMBOLS.SQLiteInlineForeignKeys] || [];\n\tfor (const fk of foreignKeys) {\n\t\tconst fkDef = generateForeignKeyDef(fk);\n\t\tif (fkDef) constraints.push(fkDef);\n\t}\n\n\tconst allDefs = [...columnDefs, ...constraints];\n\treturn `CREATE TABLE IF NOT EXISTS \"${tableName}\" (\\n ${allDefs.join(\",\\n \")}\\n);`;\n}\n\n/**\n * Generate column definition\n */\nfunction generateColumnDef(col: ColumnMetadata): string {\n\tlet def = `\"${col.name}\" `;\n\n\t// Map Drizzle types to SQLite types\n\tswitch (col.columnType) {\n\t\tcase \"SQLiteInteger\":\n\t\t\tdef += \"INTEGER\";\n\t\t\tbreak;\n\t\tcase \"SQLiteText\":\n\t\t\tdef += \"TEXT\";\n\t\t\tbreak;\n\t\tcase \"SQLiteReal\":\n\t\t\tdef += \"REAL\";\n\t\t\tbreak;\n\t\tcase \"SQLiteBlob\":\n\t\t\tdef += \"BLOB\";\n\t\t\tbreak;\n\t\tdefault:\n\t\t\tdef += \"TEXT\";\n\t}\n\n\t// PRIMARY KEY\n\tif (col.primary) {\n\t\tdef += \" PRIMARY KEY\";\n\t\tif (col.autoIncrement) {\n\t\t\tdef += \" AUTOINCREMENT\";\n\t\t}\n\t}\n\n\t// NOT NULL\n\tif (col.notNull && !col.primary) {\n\t\tdef += \" NOT NULL\";\n\t}\n\n\t// UNIQUE\n\tif (col.isUnique) {\n\t\tdef += \" UNIQUE\";\n\t}\n\n\t// DEFAULT\n\tif (col.default !== undefined) {\n\t\tif (typeof col.default === \"string\") {\n\t\t\tdef += ` DEFAULT '${col.default}'`;\n\t\t} else if (typeof col.default === \"number\") {\n\t\t\tdef += ` DEFAULT ${col.default}`;\n\t\t} else if (typeof col.default === \"boolean\") {\n\t\t\tdef += ` DEFAULT ${col.default ? 1 : 0}`;\n\t\t}\n\t}\n\n\treturn def;\n}\n\n/**\n * Generate foreign key constraint\n */\nfunction generateForeignKeyDef(fk: ForeignKeyMetadata): string | null {\n\ttry {\n\t\t// Call the reference function to get FK info\n\t\tconst ref = fk.reference();\n\n\t\t// ref has: columns (local), foreignTable, foreignColumns (referenced)\n\t\tif (!ref || !ref.foreignTable || !ref.columns || !ref.foreignColumns) {\n\t\t\treturn null;\n\t\t}\n\n\t\tconst foreignTableName = ref.foreignTable[DRIZZLE_SYMBOLS.Name];\n\t\tif (!foreignTableName) {\n\t\t\treturn null;\n\t\t}\n\n\t\t// Get column names\n\t\tconst localColumns = ref.columns\n\t\t\t.map((col: any) => `\"${col.name}\"`)\n\t\t\t.join(\", \");\n\t\tconst foreignColumns = ref.foreignColumns\n\t\t\t.map((col: any) => `\"${col.name}\"`)\n\t\t\t.join(\", \");\n\n\t\tlet def = `FOREIGN KEY (${localColumns}) REFERENCES \"${foreignTableName}\" (${foreignColumns})`;\n\n\t\tif (fk.onUpdate) {\n\t\t\tdef += ` ON UPDATE ${fk.onUpdate.toUpperCase()}`;\n\t\t}\n\n\t\tif (fk.onDelete) {\n\t\t\tdef += ` ON DELETE ${fk.onDelete.toUpperCase()}`;\n\t\t}\n\n\t\treturn def;\n\t} catch (_e) {\n\t\t// Silently skip FK generation if it fails - not critical\n\t\treturn null;\n\t}\n}\n\n/**\n * Generate CREATE INDEX SQL for a Drizzle index\n */\nexport function generateCreateIndexSQL(\n\ttableName: string,\n\tindexName: string,\n\tindex: any,\n): string {\n\tconst unique = index.config?.unique ? \"UNIQUE \" : \"\";\n\tconst columns = index.config?.columns || [];\n\n\tconst columnNames = columns.map((col: any) => `\"${col.name}\"`).join(\", \");\n\n\treturn `CREATE ${unique}INDEX IF NOT EXISTS \"${indexName}\" ON \"${tableName}\" (${columnNames});`;\n}\n\n/**\n * Extract all indexes from a table\n */\nexport function extractIndexes(\n\ttable: any,\n): Array<{ name: string; sql: string }> {\n\tconst tableName = table[DRIZZLE_SYMBOLS.Name];\n\tconst columns = table[DRIZZLE_SYMBOLS.Columns];\n\tconst extraConfigBuilder = table[DRIZZLE_SYMBOLS.ExtraConfigBuilder];\n\n\tconst indexes: Array<{ name: string; sql: string }> = [];\n\n\tif (extraConfigBuilder) {\n\t\tconst config = extraConfigBuilder(columns);\n\t\tfor (const [name, index] of Object.entries(config)) {\n\t\t\tconst sql = generateCreateIndexSQL(tableName, name, index);\n\t\t\tindexes.push({ name, sql });\n\t\t}\n\t}\n\n\treturn indexes;\n}\n\n/**\n * Migration system - stores state in SQLite\n */\ninterface MigrationState {\n\tversion: number;\n\ttables: Record; // table name -> SQL hash\n\tappliedAt: string;\n}\n\n/**\n * Initialize migrations table\n */\nasync function initMigrationsTable(db: any): Promise {\n\tawait db.execute(`\n CREATE TABLE IF NOT EXISTS __drizzle_migrations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n version INTEGER NOT NULL UNIQUE,\n tables TEXT NOT NULL,\n applied_at TEXT NOT NULL DEFAULT (datetime('now'))\n )\n `);\n}\n\n/**\n * Get current migration state\n */\nasync function getCurrentState(db: any): Promise {\n\tconst result = await db.execute(`\n SELECT version, tables, applied_at\n FROM __drizzle_migrations\n ORDER BY version DESC\n LIMIT 1\n `);\n\n\tif (result.rows.length === 0) {\n\t\treturn null;\n\t}\n\n\tconst row = result.rows[0];\n\treturn {\n\t\tversion: row[0] as number,\n\t\ttables: JSON.parse(row[1] as string),\n\t\tappliedAt: row[2] as string,\n\t};\n}\n\n/**\n * Simple hash function for SQL strings\n */\nfunction hashSQL(sql: string): string {\n\tlet hash = 0;\n\tfor (let i = 0; i < sql.length; i++) {\n\t\tconst char = sql.charCodeAt(i);\n\t\thash = (hash << 5) - hash + char;\n\t\thash = hash & hash; // Convert to 32bit integer\n\t}\n\treturn hash.toString(36);\n}\n\n/**\n * Main migration function\n * Pass in your db instance and an object with all your tables\n */\nexport async function migrate(\n\tdb: any,\n\ttables: Record,\n\toptions: { dryRun?: boolean } = {},\n): Promise<{ applied: string[]; skipped: string[]; version?: number }> {\n\tawait initMigrationsTable(db);\n\n\tconst currentState = await getCurrentState(db);\n\tconst newVersion = (currentState?.version || 0) + 1;\n\n\tconst applied: string[] = [];\n\tconst skipped: string[] = [];\n\tconst newTableHashes: Record = {};\n\n\tconsole.log(`\\n=== Migration v${newVersion} ===`);\n\n\t// Generate SQL for all tables\n\tfor (const [tableName, table] of Object.entries(tables)) {\n\t\tconst sql = generateCreateTableSQL(table);\n\t\tconst hash = hashSQL(sql);\n\n\t\tnewTableHashes[tableName] = hash;\n\n\t\t// Check if this table needs to be created/updated\n\t\tconst previousHash = currentState?.tables[tableName];\n\n\t\tif (!previousHash) {\n\t\t\tconsole.log(`[NEW] Creating table: ${tableName}`);\n\t\t\tconsole.log(sql);\n\n\t\t\tif (!options.dryRun) {\n\t\t\t\tawait db.execute(sql);\n\n\t\t\t\t// Create indexes\n\t\t\t\tconst indexes = extractIndexes(table);\n\t\t\t\tfor (const idx of indexes) {\n\t\t\t\t\tconsole.log(`[INDEX] ${idx.name}`);\n\t\t\t\t\tconsole.log(idx.sql);\n\t\t\t\t\tawait db.execute(idx.sql);\n\t\t\t\t}\n\t\t\t}\n\n\t\t\tapplied.push(tableName);\n\t\t} else if (previousHash !== hash) {\n\t\t\tconsole.log(`[CHANGED] Table schema changed: ${tableName}`);\n\t\t\tconsole.log(\"⚠️ Manual migration required for schema changes\");\n\t\t\tconsole.log(\"New SQL:\", sql);\n\t\t\tskipped.push(tableName);\n\t\t} else {\n\t\t\tconsole.log(`[SKIP] No changes: ${tableName}`);\n\t\t\tskipped.push(tableName);\n\t\t}\n\t}\n\n\t// Save new state\n\tif (!options.dryRun && applied.length > 0) {\n\t\tawait db.execute(\n\t\t\t`\n INSERT INTO __drizzle_migrations (version, tables)\n VALUES (?, ?)\n `,\n\t\t\t[newVersion, JSON.stringify(newTableHashes)],\n\t\t);\n\n\t\tconsole.log(`\\n✅ Migration v${newVersion} applied`);\n\t}\n\n\treturn { applied, skipped, version: newVersion };\n}\n\n/**\n * Generate SQL for an entire schema (useful for inspection)\n */\nexport function generateSchemaSQL(tables: Record): string {\n\tconst statements: string[] = [];\n\n\tfor (const [_tableName, table] of Object.entries(tables)) {\n\t\tstatements.push(generateCreateTableSQL(table));\n\n\t\tconst indexes = extractIndexes(table);\n\t\tfor (const idx of indexes) {\n\t\t\tstatements.push(idx.sql);\n\t\t}\n\n\t\tstatements.push(\"\"); // blank line between tables\n\t}\n\n\treturn statements.join(\"\\n\");\n}\n","deleted","label",[98],"permalink","https://www.val.town/x/nbbaier/drizzleMigrations/code/main.ts","extension","actionData","errors"]