feat: exec remote script endpoint

.gitignore

@@ -107,3 +107,6 @@ sw.*
 # Storybook
 .nuxt-storybook
 storybook-static
+
+# test remote build script
+remote-build.sh

packages/be/modules/exec/index.js

@@ -0,0 +1,10 @@
+console.log('📦 [module] exec')
+
+// ///////////////////////////////////////////////////////////////////// Imports
+// -----------------------------------------------------------------------------
+const { RunStartupChecks } = require('@Module_Utilities')
+
+// ////////////////////////////////////////////////////////////// Startup Checks
+// -----------------------------------------------------------------------------
+const checks = []
+RunStartupChecks(checks)

packages/be/modules/exec/rest/exec-remote.js

@@ -0,0 +1,52 @@
+// ////////////////////////////////////////////////////////////////////// Import
+// -----------------------------------------------------------------------------
+const Path = require('path')
+const exec = require('child_process').exec
+
+const { SendData } = require('@Module_Utilities')
+const MC = require('@Root/config')
+require('dotenv').config({ path: Path.resolve(__dirname, '../.env') })
+
+const REMOTE_EXEC_ENPOINT = process.env.REMOTE_EXEC_ENDPOINT
+const REMOTE_EXEC_PATH = process.env.REMOTE_EXEC_PATH
+const REMOTE_EXEC_FILENAME = process.env.REMOTE_EXEC_FILENAME
+
+// /////////////////////////////////////////////////////////////////// Functions
+// -----------------------------------------------------------------------------
+const executeRemoteProcess = (command, path) => {
+  return new Promise((resolve, reject) => {
+    const executed = exec(REMOTE_EXEC_PATH + REMOTE_EXEC_FILENAME)
+    const results = []
+    const errors = []
+    executed.stdout.on('data', (msg) => {
+      results.push(msg.toString())
+    })
+    executed.stderr.on('data', msg => {
+      errors.push(msg.toString())
+    })
+    executed.on('exit', (code) => {
+      const err = errors.length > 0 && code !== 0
+      if (err) {
+        reject(errors.join('\n'))
+      }
+      resolve(results.join('\n'))
+    })
+  })
+}
+// //////////////////////////////////////////////////////////////////// Endpoint
+// -----------------------------------------------------------------------------
+MC.app.get(REMOTE_EXEC_ENPOINT, async (req, res) => {
+  const command = req.query.command
+  const path = req.query.path
+  const remoteProcess = executeRemoteProcess(command, path)
+    .then((result) => {
+      console.log(result)
+      SendData(res, 200, 'Successfully executed remote script')
+    })
+    .catch((err) => {
+      console.log('================================ [Endpoint: /exec-remote]')
+      console.log(err)
+      SendData(res, 404, 'An error occured')
+    })
+})
+

packages/fe/pages/index.vue

@@ -86,6 +86,13 @@ export default {
   },
 
   async fetch ({ app, store, route, redirect }) {
+    await store.dispatch('general/execRemoteScript', {
+      endpoint: '/execute-remote-shell-script',
+      params: {
+        command: 'ls',
+        path: 'crons'
+      }
+    })
     await store.dispatch('general/getBaseData', { key: 'index', data: IndexPageData })
     const response = await store.dispatch('datasets/getDatasetList', { route })
     if (response.fail) {

packages/fe/store/general.js

@@ -94,6 +94,21 @@ const actions = {
   setClipboard ({ commit }, text) {
     this.$addTextToClipboard(text)
     commit('SET_CLIPBOARD', text)
+  },
+  // ////////////////////////////////////////////////////////// execRemoteScript
+  async execRemoteScript ({ commit, getters }, payload) {
+    try {
+      const endpoint = payload.endpoint
+      const params = payload.params
+      const response = await this.$axiosAuth.get(endpoint, { params })
+      const data = response.data.payload
+      console.log(response.data)
+      return data
+    } catch (e) {
+      console.log('================== [Store Action: general/execRemoteScript]')
+      console.log(e)
+      return false
+    }
   }
 }