chore: wip

Author: glennmichael123

.stacks/core/actions/src/database/migration-mysql.ts

@@ -2,6 +2,9 @@ import User from '../../../../../app/models/User'
 import { fieldAssociation, fieldEntity, modelEntity } from './fields'
 
 const file = Bun.file('user-migration.ts')
+
+const driver = 'mysql'
+
 const writer = file.writer()
 
 writer.write('import { Kysely, sql } from \'kysely\'\n')

.stacks/core/actions/src/database/migration.ts

@@ -1,3 +1,10 @@
 // import { generateMigrationFile } from '@stacksjs/database'
+// import { config } from '@stacksjs/config'
 
-// const driver = 'mysql'
+// const driver = config.database.default
+const driver = 'sqlite'
+
+if (driver === 'sqlite')
+  await import('./migration-sqlite.ts')
+else
+  await import('./migration-mysql.ts')

.stacks/core/actions/src/database/stacks.sqlite

@@ -1 +1,31 @@
-// loops over all the models to generate the model classes
+import { path as p } from '@stacksjs/path'
+
+const file = Bun.file(p.projectStoragePath('framework/orm/UserModel.ts'))
+
+const writer = file.writer()
+
+writer.write(`import { dbDialect } from '@stacksjs/database'
+import { Kysely } from 'kysely'
+
+class UserModel extends Kysely<any> {
+  constructor() {
+    super({ dialect: dbDialect })
+  }
+
+  public async find(id: number) {
+    return await this.selectFrom('users')
+      .selectAll()
+      .where('id', '=', id)
+      .executeTakeFirst()
+  }
+
+  public all() {
+    return this.selectFrom('users')
+      .selectAll()
+  }
+}
+
+export const User = new UserModel()
+`)
+
+await writer.end()

.stacks/core/actions/src/generate/model-classes.ts

@@ -1,52 +1,39 @@
 // export * from './migrations'
 // export * from './seeder''
-
-import { storage } from '@stacksjs/storage'
+import { Kysely, MysqlDialect } from 'kysely'
+import { createPool } from 'mysql2'
 import { BunWorkerDialect } from './kysely-bun-worker'
 
-// eslint-disable-next-line no-console
-console.log('Hello from database!', storage)
-
-const dialect = new BunWorkerDialect({
-  database: sqdb,
+// const driver = config.database.default
+const driver = 'mysql'
+
+// const dbName = config.database.name
+
+export interface DatabaseType {
+  user: any
+}
+
+let dialect
+
+if (driver === 'sqlite') {
+  dialect = new BunWorkerDialect({
+    url: 'stacks.sqlite',
+  })
+}
+else {
+  dialect = new MysqlDialect({
+    pool: createPool({
+      database: 'stacks',
+      host: '127.0.0.1',
+      user: 'root',
+      password: '',
+      port: 3306,
+    }),
+  })
+}
+
+export const QueryBuilder = new Kysely<DatabaseType>({
+  dialect,
 })
 
-console.log(BunWorkerDialect)
-
-// import { Kysely, MysqlDialect, SqliteDialect } from 'kysely'
-// import { createPool } from 'mysql2'
-// import { Database } from "bun:sqlite"
-
-// const driver = 'sqlite'
-
-// export interface DatabaseType {
-//   user: any
-// }
-
-// const sqdb = new Database("mydb.sqlite", { create: true })
-
-// let dialect
-
-// if (driver === 'sqlite') {
-//   dialect = new SqliteDialect({
-//     database: sqdb,
-//   })
-// }
-// else {
-//   dialect = new MysqlDialect({
-//     pool: createPool({
-//       database: 'stacks',
-//       host: '127.0.0.1',
-//       user: 'root',
-//       password: '',
-//       port: 3306,
-//       connectionLimit: 10,
-//     }),
-//   })
-// }
-
-// console.log(dialect)
-
-// export const db = new Kysely<Database>({
-//   dialect,
-// })
+export const dbDialect = dialect

.stacks/core/actions/src/generate/stacks.sqlite

@@ -1,5 +1,6 @@
 import type { DatabaseConnection, Driver, QueryResult } from 'kysely'
 import { CompiledQuery } from 'kysely'
+import { path as p } from '@stacksjs/path'
 import type { EmitterOnce } from './mitt'
 import MittOnce from './mitt'
 import type { EventWithError, MainMsg, WorkerMsg } from './type'
@@ -17,7 +18,7 @@ export class BunWorkerDriver implements Driver {
 
   async init(): Promise<void> {
     this.worker = this.config?.worker ?? new Worker(
-      new URL('./worker', import.meta.url),
+      new URL('../src/kysely-bun-worker/worker', import.meta.url),
       { type: 'module' },
     )
     this.mitt = MittOnce<EventWithError>()

.stacks/core/database/src/index.ts

@@ -0,0 +1,22 @@
+import { dbDialect } from '@stacksjs/database'
+import { Kysely } from 'kysely'
+
+class UserModel extends Kysely<any> {
+  constructor() {
+    super({ dialect: dbDialect })
+  }
+
+  public async find(id: number) {
+    return await this.selectFrom('users')
+      .selectAll()
+      .where('id', '=', id)
+      .executeTakeFirst()
+  }
+
+  public all() {
+    return this.selectFrom('users')
+      .selectAll()
+  }
+}
+
+export const User = new UserModel()