Migration log enabled by default

Author: ackava

src/migrations/Migrations.ts

@@ -1,3 +1,4 @@
+import Logger, { ConsoleLogger } from "../common/Logger.js";
 import { modelSymbol } from "../common/symbols/symbols.js";
 import type QueryCompiler from "../compiler/QueryCompiler.js";
 import ICheckConstraint from "../decorators/ICheckConstraint.js";
@@ -11,28 +12,34 @@ import type EntityQuery from "../model/EntityQuery.js";
 
 export default abstract class Migrations {
 
+    logger: Logger;
+
     constructor(
         private context: EntityContext,
         private connection: BaseConnection = context.connection,
         protected compiler: QueryCompiler = context.driver.compiler
-    ) {}
+    ) {
+
+    }
 
     public async migrate({
         version,
         name = "default",
         historyTableName = "migrations",
+        log = new ConsoleLogger(false),
         seed,
         createIndexForForeignKeys = true
     }: {
         version?: string,
         name?: string,
-        historyTableName?:
-        string,
+        historyTableName?: string,
+        log?: Logger,
         seed?: (c: EntityContext) => Promise<any>,
         createIndexForForeignKeys?: boolean
     } = {} ) {
         const { context } = this;
         const { model } = context;
+        this.logger = log ?? context.logger;
         const postMigration = [] as (() => Promise<void>)[];
 
         if (version) {
@@ -194,7 +201,7 @@ export default abstract class Migrations {
 
     protected executeQuery(command: IQuery, signal?: AbortSignal): Promise<IQueryResult> {
         const text = typeof command === "string" ? command : command.text;
-        this.context.logger?.log(text);
+        this.logger?.log(text);
         return this.connection.executeQuery(command, signal);
     }
 

src/tests/db-tests/tests/version-history.ts

@@ -20,5 +20,5 @@ async function migrate(this: TestConfig) {
 
     await context.connection.ensureDatabase();
 
-    return await context.connection.automaticMigrations(context).migrate({ version: "v1" });
+    return await context.connection.automaticMigrations(context).migrate({ log: null, version: "v1" });
 }

src/tests/model/createContext.ts

@@ -14,7 +14,7 @@ export async function createContext(driver: BaseDriver, events?: ContextEvents)
 
     await context.connection.ensureDatabase();
 
-    await context.connection.automaticMigrations(context).migrate();
+    await context.connection.automaticMigrations(context).migrate({ log: null });
 
     await seed(context);
 

src/workflows/WorkflowStorage.ts

@@ -234,7 +234,7 @@ export default class WorkflowStorage {
     async seed(version?) {
         const db = new WorkflowDbContext(this.driver);
         await db.connection.ensureDatabase();
-        await db.connection.automaticMigrations(db).migrate({ version, name: "workflows" });
+        await db.connection.automaticMigrations(db).migrate({ log: null, version, name: "workflows" });
     }
 
 }