added migrate command

Author: tomcastro

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "fast-fastcli",
-  "version": "0.1.2",
+  "version": "0.1.3",
   "main": "index.js",
   "author": "Robert Zibert",
   "license": "MIT",
@@ -15,12 +15,16 @@
     "quasar": "quasar dev"
   },
   "dependencies": {
+    "await-to-js": "^2.1.1",
     "axios": "^0.18.0",
     "babel-core": "^6.26.3",
     "babel-plugin-source-map-support": "^2.0.1",
+    "babel-polyfill": "^6.26.0",
     "chokidar": "^2.0.4",
     "colors": "^1.2.1",
     "commander": "^2.15.1",
+    "fast-fluent": "^0.1.18",
+    "fluent-formio": "^0.1.3",
     "globby": "^8.0.1",
     "hygen": "^1.6.2",
     "lodash": "^4.17.5",

package.json

@@ -3,6 +3,7 @@ import program from 'commander'
 import init from './init'
 import pull from './pull'
 import runServer from './run'
+import migrate from './migrate'
 // import build from './build'
 import colors from 'colors/safe'
 import './helpers/fastLogo'
@@ -49,9 +50,20 @@ program
 
 program
   .command('run')
-  .description('Runs dev build for the current Fast project.')
+  .description('Runs dev build for the current FAST project.')
   .action(run(runServer))
 
+program
+  .command('migrate <file>')
+  .option('-u, --url [URL]', 'Existing project url')
+  .option('-p, --path [Path to form]', 'Path where data should be imported')
+  .option('-k, --dst-key [API key]', 'Form.io API key')
+  .description('Migrate data from a JSON file to an existing FAST project')
+  // eslint-disable-next-line
+  .action((file, cmd) => {
+    migrate(file, cmd)
+  })
+
 // program
 //   .command('build')
 //   .description('Compiles an Orionjs app and exports it to a simple nodejs app')

src/index.js

@@ -0,0 +1,65 @@
+import 'babel-polyfill'
+import fs from 'fs'
+import { Fluent } from 'fast-fluent'
+import formio from 'fluent-formio'
+import to from 'await-to-js'
+
+export default async function(file, options) {
+  console.log(file, options.url, options.path, options.dstKey)
+
+  if (!options.url) {
+    console.error('No url specified.')
+    return
+  }
+
+  if (!options.path) {
+    console.error('No form or resource path specified.')
+    return
+  }
+
+  if (!options.dstKey) {
+    console.error('No API key provided.')
+    return
+  }
+
+  const data = JSON.parse(fs.readFileSync(file, 'utf-8'))
+
+  await Fluent.config({
+    REMOTE_CONNECTORS: [{
+      name: 'formio',
+      baseUrl: options.url,
+      connector: formio
+    }]
+  })
+
+  const model = Fluent.model({
+    properties: {
+      name: 'submission',
+      config: {
+        remote: {
+          path: options.path,
+          token: options.dstKey
+        }
+      }
+    }
+  })()
+
+  const collection = Fluent.collect(data)
+  const errors = []
+
+  try {
+    console.time('saveChunk')
+    await collection.chunkApply(200, async (d) => {
+      const [error, result] = await to(model.remote().insert(d))
+
+      if (error) {
+        errors.push({ original: d, error })
+      }
+    })
+    const time = console.timeEnd('saveChunk')
+
+    console.log(`Took ${time} seconds, with ${errors.length} errors.`)
+  } catch (e) {
+    console.error(e)
+  }
+}