feat: DB provider/migration 스캐폴드 추가

Author: SOIV

packages/core/src/db/index.ts

@@ -8,3 +8,13 @@ export interface MigrationRunner {
   up(): Promise<void>;
   down(): Promise<void>;
 }
+
+export interface DbConnectionConfig {
+  connectionString: string;
+}
+
+export * from "./migrations";
+export * from "./providers/postgres";
+export * from "./providers/sqlite";
+export * from "./providers/supabase";
+export * from "./providers/mongodb";

packages/core/src/db/migrations/index.ts

@@ -0,0 +1,25 @@
+import type { MigrationRunner } from "../index";
+
+export interface MigrationDefinition {
+  id: string;
+  upSql: string;
+  downSql: string;
+}
+
+export class InMemoryMigrationRunner implements MigrationRunner {
+  private readonly applied: string[] = [];
+
+  public constructor(private readonly migrations: MigrationDefinition[]) {}
+
+  public async up(): Promise<void> {
+    this.applied.splice(0, this.applied.length, ...this.migrations.map((item) => item.id));
+  }
+
+  public async down(): Promise<void> {
+    this.applied.splice(0, this.applied.length);
+  }
+
+  public listApplied(): string[] {
+    return [...this.applied];
+  }
+}

packages/core/src/db/providers/mongodb.ts

@@ -0,0 +1,15 @@
+import type { DbConnectionConfig, DbProvider } from "../index";
+
+export class MongoDbProvider implements DbProvider {
+  public readonly name = "mongodb";
+
+  public constructor(private readonly config: DbConnectionConfig) {}
+
+  public async connect(): Promise<void> {
+    void this.config.connectionString;
+  }
+
+  public async disconnect(): Promise<void> {
+    return Promise.resolve();
+  }
+}

packages/core/src/db/providers/postgres.ts

@@ -0,0 +1,15 @@
+import type { DbConnectionConfig, DbProvider } from "../index";
+
+export class PostgresProvider implements DbProvider {
+  public readonly name = "postgres";
+
+  public constructor(private readonly config: DbConnectionConfig) {}
+
+  public async connect(): Promise<void> {
+    void this.config.connectionString;
+  }
+
+  public async disconnect(): Promise<void> {
+    return Promise.resolve();
+  }
+}

packages/core/src/db/providers/sqlite.ts

@@ -0,0 +1,15 @@
+import type { DbConnectionConfig, DbProvider } from "../index";
+
+export class SqliteProvider implements DbProvider {
+  public readonly name = "sqlite";
+
+  public constructor(private readonly config: DbConnectionConfig) {}
+
+  public async connect(): Promise<void> {
+    void this.config.connectionString;
+  }
+
+  public async disconnect(): Promise<void> {
+    return Promise.resolve();
+  }
+}

packages/core/src/db/providers/supabase.ts

@@ -0,0 +1,15 @@
+import type { DbConnectionConfig, DbProvider } from "../index";
+
+export class SupabaseProvider implements DbProvider {
+  public readonly name = "supabase";
+
+  public constructor(private readonly config: DbConnectionConfig) {}
+
+  public async connect(): Promise<void> {
+    void this.config.connectionString;
+  }
+
+  public async disconnect(): Promise<void> {
+    return Promise.resolve();
+  }
+}