Dev0.4

containerexec.js

@@ -0,0 +1,13 @@
+var Docker = require('dockerode');
+
+const { workerData} = require("worker_threads")
+const docker = new Docker({ socketPath: '/var/run/docker.sock' });
+var command = workerData
+console.log(command["com"])
+
+    var container = docker.getContainer(`${command["ContainerId"]}`);
+    container.exec({Cmd: ['/bin/bash', '-c', `${command["com"]}`], AttachStdin: true, AttachStdout: true},function(err,exec){
+    exec.start({hijack: true, stdin: true}, function(err, stream) {
+        docker.modem.demuxStream(stream, process.stdout, process.stderr);
+            })
+        })

controller1.js

@@ -0,0 +1,82 @@
+const { Worker } = require("worker_threads")
+const request = require('request-promise');
+
+var WebSocket = new require('ws');
+var websocket = new WebSocket.Server({
+    port:3000
+});
+
+var Docker = require('dockerode');
+var docker = new Docker({socketPath: '/var/run/docker.sock'});
+websocket.on('connection', (websocket) => {
+
+    websocket.on('message', function message(data) {
+
+        var data = JSON.parse(data)
+        console.log(data["start"])
+        console.log(data["Id"]) // get id for get
+
+        const createdocker = new Worker("./dockercreate.js",{
+            workerData: data ,
+        })
+        const options = {
+            method: 'GET',
+            uri: `http://20.82.178.99:5240/Servers/Detailsapi/${data["Id"]}`,
+            json:true
+            }
+
+            if (data["stop"] === "dockerstop()"){
+              const dockerun = request(options)
+              .then((response) => {
+                  console.log(response)
+               const ftpworker = new Worker("./dockerstop.js",{
+                   workerData: response,
+               })
+         // const containerexec = new Worker("./containerexec.js",{
+         //     workerData: data,
+         // })
+           });
+         }
+            if (data["run"] === "dockerun()"){
+              const dockerun = request(options)
+              .then((response) => {
+                  console.log(response)
+               const ftpworker = new Worker("./dockerun.js",{
+                   workerData: response,
+               })
+         // const containerexec = new Worker("./containerexec.js",{
+         //     workerData: data,
+         // })
+         var container = docker.getContainer(`${response["containerId"]}`);
+         container.attach({stream: true, stdout: true, stderr: true}, function (err, stream) {
+           stream.pipe(process.stdout)
+           stream.on("data", info => websocket.send((info)))  
+         })
+           });
+         }
+            const information = request(options)
+            .then((response) => {
+                console.log(response)
+             const ftpworker = new Worker("./ftpworker.js",{
+                 workerData: response,
+             })
+
+          if(data["start"] === "dockercreate()"){
+           const dockercontainerinfo = request(options)
+          .then((response) => {
+               var container = docker.getContainer(`${response["containerId"]}`);
+               container.start()
+               container.attach({stream: true, stdout: true, stderr: true}, function (err, stream) {
+                stream.pipe(process.stdout)
+                stream.on("data", info => websocket.send((info)))  
+              })
+            }) 
+          }
+        })
+      })
+    })
+    //If it will be error, node js wont crash!
+    process.on('uncaughtException', function (err) {
+        console.error(err);
+        console.log("Node NOT Exiting...");
+      });

dockercreate.js

@@ -0,0 +1,72 @@
+const { Worker } = require("worker_threads")
+const { parentPort,workerData} = require("worker_threads")
+const request = require('request-promise');
+const Docker = require('dockerode');
+const docker = new Docker({socketPath: '/var/run/docker.sock'});
+var datas = workerData
+const options = {
+    method: 'GET',
+    uri: `http://20.82.177.87:5240/Servers/Detailsapi/${datas["Id"]}`,
+    json:true
+    }
+console.log(datas["Id"])
+if (datas["start"] === "dockercreate()"){
+    const fas = request(options)
+    .then((response) => {
+        console.log(response["image"])
+        console.log(response['Id'])
+
+  docker.createContainer({
+    Image: `${response["image"]}`,
+    AttachStdin: false,
+    AttachStdout: true,
+    AttachStderr: true,
+    Tty: true,
+    ExposedPorts: {
+      "22/tcp": { }
+      },
+   //Cmd: ["/bin/bash","-c",`${response['setup']}`],
+   Cmd: ["/bin/bash","-c",`apt-get update`],
+   OpenStdin: false,
+   StdinOnce: false
+  }, function(err,container){
+     container.inspect(function(err,data){
+      console.log(data)
+        var gethostname = data[["Config"]];
+        console.log(gethostname)
+         // websocket.send(gethostname["Hostname"])
+          const containerexec = new Worker("./containerexec.js",{
+                   workerData: gethostname,
+               })
+               const options1 = {
+                method:"PUT",
+                uri:`http://20.82.177.87:5240/Servers/Detailsapi/${datas["Id"]}`,
+                body:{
+                    "id":`2`,
+                    "name":response["name"],
+                    "ContainerId":gethostname["Hostname"],
+                    "ip":response["ip"],
+                    "email":response["email"],
+                    "setup": response["setup"],
+                    "image": response["image"],
+                    "cpu": response["cpu"],
+                    "memory": response["memory"],
+                    "disk": response["disk"],
+                    "port": response["port"],
+                },
+                json:true
+            }
+            request(options1)
+                .then(function (response) {
+                   console.log(response)
+                })
+                .catch(function (err) {
+                    console.log(err)
+                })
+      })
+
+  })
+
+})
+
+}

dockerun.js

@@ -0,0 +1,10 @@
+const { Worker, workerData } = require("worker_threads")
+var Docker = require('dockerode');
+var docker = new Docker({socketPath: '/var/run/docker.sock'});
+var datas = workerData
+
+var container = docker.getContainer(`${workerData["containerId"]}`)
+
+container.start(function (err,data){
+console.log(data)
+});

ftpworker.js

@@ -0,0 +1,9 @@
+const { workerData} = require("worker_threads")
+var datas = workerData
+const { ftpd } = require('jsftpd')
+
+
+
+const server = new ftpd({cnf: {username: `${datas["email"]}`, password: `${datas["name"]}`, basefolder: `${datas["containervolume"]}`}})
+
+server.start()