ftp deploy added

Author: muhammedikinci

.env.dev

@@ -1,3 +1,7 @@
 BUILD_HASH=XXXXXXXXXXXXXXXXX
 SERVER_IP=0.0.0.0
-SERVER_PORT=5466
+SERVER_PORT=5466
+FTP_USERNAME=
+FTP_PASSWORD=
+FTP_HOST=
+FTP_PORT=

hook.js

@@ -1,11 +1,28 @@
-const dotenv = require('dotenv')
-dotenv.config()
-const fastify = require('fastify')({ logger: true })
+
 const { exec } = require("child_process")
 const gatsbyProcesses = require("./hook_commands/gatsby")
+const gatsbyFtpProcesses = require("./hook_commands/gatsby_ftp")
+const FtpDeploy = require("ftp-deploy");
+const ftpDeploy = new FtpDeploy();
+const dotenv = require('dotenv')
+dotenv.config()
 
 let isPublishing = false
 let results = ''
+
+const ftpConfig = {
+  user: process.env.FTP_USERNAME,
+  password: process.env.FTP_PASSWORD,
+  host: process.env.FTP_HOST,
+  port: parseInt(process.env.FTP_PORT),
+  include: ['*', '**/*'],
+  localRoot: __dirname + "/hook_commands",
+  remoteRoot: "/backup/",
+  deleteRemote: false,
+  forcePasv: true,
+  sftp: false
+}
+
 let processes = []
 
 const writeResult = (value) => {
@@ -25,6 +42,17 @@ function ejectRecursive(index) {
 
   writeResult(`=====> command is started [ ${processes[index].command} ] : ${new Date()} : <=====`)
 
+  //ftp commond check
+  if (processes[index].ftp) {
+    ftpDeploy
+      .deploy(ftpConfig)
+      .then(res => {
+        writeResult(`=====> FTP Upload Finished <=====`)
+        ejectRecursive(index + 1)
+      })
+    return
+  }
+
   exec(processes[index].command, processes[index].option, (error, stdout, stderr) => {
     if (error) {
       writeResult(`=====> error command: [ ${processes[index].command} ] : ${new Date()} : <=====`)
@@ -56,7 +84,7 @@ function ejectRecursive(index) {
   })
 }
 
-fastify.post('/build/:hash', async (request, reply) => {
+module.exports.startBuild = (request, reply) => {
   const receivedHash = request.params.hash
 
   if (isPublishing)
@@ -67,26 +95,12 @@ fastify.post('/build/:hash', async (request, reply) => {
   }
 
   results = ''
-  processes = gatsbyProcesses;
+  processes = gatsbyFtpProcesses;
   writeResult(`Process is starting... : ${new Date()} :`)
   ejectRecursive(0)
   isPublishing = true
 
   return response(true, "build is started")
-})
-
-fastify.get('/build_result', async () => {
-  return results
-})
-
-const start = async () => {
-  try {
-    await fastify.listen(process.env.SERVER_PORT, process.env.SERVER_IP)
-    fastify.log.info(`server listening on ${fastify.server.address().port}`)
-  } catch (err) {
-    fastify.log.error(err)
-    process.exit(1)
-  }
 }
 
-start()
+module.exports.results = () => results

hook_commands/gatsby.js

@@ -15,7 +15,16 @@ const copyProcess = {
     option: projectOptions.public
 }
 
-module.exports = [{
+module.exports = [
+    {
+        command: "git reset --hard",
+        option: projectOptions.main
+    },
+    {
+        command: "git clean -df",
+        option: projectOptions.main
+    },
+    {
         command: "git pull",
         option: projectOptions.main
     },

hook_commands/gatsby_ftp.js

@@ -0,0 +1,32 @@
+const projectOptions = {
+    main: {
+        cwd: '/root/gatsby/'
+    }
+}
+
+module.exports = [
+    {
+        command: "git reset --hard",
+        option: projectOptions.main
+    },
+    {
+        command: "git clean -df",
+        option: projectOptions.main
+    },
+    {
+        command: "git pull",
+        option: projectOptions.main
+    },
+    {
+        command: "npm install",
+        option: projectOptions.main
+    },
+    {
+        command: "npm run build",
+        option: projectOptions.main
+    },
+    {
+        command: "FTP Upload", // optional
+        ftp: true // required
+    }
+]

index.js

@@ -0,0 +1,24 @@
+const hook = require('./hook.js');
+const fastify = require('fastify')({ logger: true })
+const dotenv = require('dotenv')
+dotenv.config()
+
+fastify.post('/build/:hash', async (request, reply) => {
+    return hook.startBuild(request, reply)
+})
+
+fastify.get('/build_result', async () => {
+    return hook.results()
+})
+
+const start = async () => {
+    try {
+        await fastify.listen(process.env.SERVER_PORT, process.env.SERVER_IP)
+        fastify.log.info(`server listening on ${fastify.server.address().port}`)
+    } catch (err) {
+        fastify.log.error(err)
+        process.exit(1)
+    }
+}
+
+start()

package.json

@@ -11,6 +11,7 @@
   "dependencies": {
     "child_process": "^1.0.2",
     "dotenv": "^8.2.0",
-    "fastify": "^3.3.0"
+    "fastify": "^3.3.0",
+    "ftp-deploy": "^2.4.1"
   }
 }