feat: publish package migrations

bin/cli.js

@@ -116,6 +116,35 @@ program
     }
   });
 
+program
+  .command('migrate:publish <package>')
+  .description('Publish any migration files from packages.')
+  .action(async (package, opts) => {
+    if (!env.configPath) {
+      exit('Error: sutando config not found. Run `sutando init` first.');
+    }
+
+    const config = require(env.configPath);
+
+    try {
+      const packagePath = findModulePkg(package);
+
+      if (!packagePath) {
+        exit(`Error: package ${package} not found`);
+      }
+
+      const MigrationCreator = getSutandoModule('src/migrations/migration-creator');
+      const creator = new MigrationCreator(path.join(packagePath, 'migrations'));
+
+      console.log(color.green(`Publishing migrations:`));
+      const fileNames = await creator.publish(env.cwd + `/${config?.migrations?.path || 'migrations'}`, (fileName, oldPath, newPath) => {
+        console.log(newPath + ' ' + color.green(`DONE`));
+      });
+    } catch (err) {
+      exit(err);
+    }
+  });
+
 program
   .command('migrate:run')
   .description('Run all pending migrations.')

src/migrations/migration-creator.js

@@ -24,6 +24,19 @@ class MigrationCreator {
     return filePath;
   }
 
+  async publish(dir, callback) {
+    const migrationFiles = await promisify(fs.readdir)(this.customStubPath);
+    await this.ensureDirectoryExists(dir);
+
+    for (const migrationFile of migrationFiles) {
+      const sourceFilePath = path.join(this.customStubPath, migrationFile);
+      const destinationFilePath = path.join(dir, migrationFile);
+
+      await promisify(fs.copyFile)(sourceFilePath, destinationFilePath);
+      callback && await callback(migrationFile, sourceFilePath, destinationFilePath);
+    }
+  }
+
   async ensureMigrationDoesntAlreadyExist(name, dir) {
     const migrationFiles = await promisify(fs.glob)(path.join(dir, '*.js'));