feat(prepare): added prepare step

package.json

@@ -24,6 +24,7 @@
     "@rxdi/core": "^0.7.37",
     "chalk": "2.4.2",
     "esbuild": "^0.20.2",
+    "esbuild-plugin-tsc": "^0.4.0",
     "esm": "3.2.25",
     "mongodb": "3.3.3",
     "mongoose": "5.7.6"

src/helpers/typescript-builder.ts

@@ -26,6 +26,7 @@ export const TranspileTypescriptESBuild = async (
   outdir: string,
 ) => {
   try {
+    const tscPlugin = await import('esbuild-plugin-tsc');
     return (await import('esbuild')).build({
       entryPoints,
       bundle: true,
@@ -35,6 +36,7 @@ export const TranspileTypescriptESBuild = async (
       format: 'cjs',
       outdir,
       logLevel: 'info',
+      plugins: [tscPlugin.default()],
     });
   } catch (e) {
     console.error(e);

src/injection.tokens.ts

@@ -15,6 +15,7 @@ export const Config = new InjectionToken('migrations-config');
 export type MigrationSchema = {
   down: (db: MongoClient) => unknown;
   up: (db: MongoClient) => unknown;
+  prepare: (db: MongoClient) => unknown;
 };
 
 export interface LoggerConfig {

src/services/migration/migration.service.ts

@@ -52,6 +52,7 @@ export class MigrationService {
         const migration = await this.migrationsResolver.loadMigration(
           item.fileName,
         );
+        await migration.prepare(client);
         result = await migration.up(client);
       } catch (err) {
         const error = new ErrorMap(err.message);
@@ -87,7 +88,7 @@ export class MigrationService {
       };
       await logger.log(res);
       migrated.push(res);
-      return await true;
+      return true;
     };
     for (const item of pendingItems) {
       await migrateItem(item);
@@ -126,6 +127,7 @@ export class MigrationService {
         const migration = await this.migrationsResolver.loadMigration(
           lastAppliedItem.fileName,
         );
+        await migration.prepare(client);
         result = await migration.down(client);
       } catch (err) {
         const error = new ErrorMap(err.message);

src/services/migrations-resolver/migrations-resolver.service.ts

@@ -42,6 +42,7 @@ export class MigrationsResolver {
       // eslint-disable-next-line @typescript-eslint/no-var-requires
       migration = require('esm')(module)(this.getFilePath(fileName));
     }
+    migration.prepare = migration.prepare || (() => Promise.resolve());
     return migration;
   }
 
@@ -74,7 +75,7 @@ export class MigrationsResolver {
   }
 
   async loadTsCompiledMigration(fileName: string) {
-    return require(this.getTsCompiledFilePath(fileName));
+    return import(this.getTsCompiledFilePath(fileName));
   }
 
   async transpileMigrations(

tsconfig.json

@@ -10,6 +10,7 @@
     "experimentalDecorators": true,
     "moduleResolution": "node",
     "noUnusedLocals": true,
+    "esModuleInterop": true,
     "outDir": "lib",
     "lib": [
       "es2017",