init

.idea/vcs.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="VcsDirectoryMappings">
-    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+    <mapping directory="" vcs="Git" />
   </component>
 </project>
\ No newline at end of file

Hetzner.js

@@ -26,6 +26,22 @@ class Hetzner {
     }
 
 
+    getAllFloatingIps() {
+        return new Promise(function (resolve, reject) {
+
+            client.floatingIPs.list().then(function (res) {
+
+                let d = _.values(res.floatingIPs);
+
+                resolve(d)
+
+            })
+        })
+
+
+    }
+
+
     async deleteServer(id) {
         return new Promise(function (resolve, reject) {
 
@@ -35,14 +51,22 @@ class Hetzner {
         })
     }
 
+    async delFloatingIp(id) {
+        return new Promise(function (resolve, reject) {
+
+            client.floatingIPs.delete(id).then(function (res) {
+                resolve(res)
+            })
+        })
+    }
+
     async removeByIp(ip) {
         try {
-            ip=_.trim(ip)
-            console.log('try to remove ip:'+ip)
+            ip = _.trim(ip)
+            console.log('try to remove ip:' + ip)
             let servers = await this.getAllServers()
             for (let i = 0; i < servers.length; i++) {
-                if (ip === servers[i].publicNet.server.publicNet.ipv4.ip)
-                {
+                if (ip === servers[i].publicNet.server.publicNet.ipv4.ip) {
 
                     await this.deleteServer(servers[i].id)
                 }
@@ -57,16 +81,54 @@ class Hetzner {
     }
 
 
-    async getAllFloatingIps() {
 
+    async removeFloatingIpByIp(ip) {
+        try {
+            ip = _.trim(ip)
+            console.log('try to remove ip:' + ip)
+            let ips = await this.getAllFloatingIps()
+            for (let i = 0; i < ips.length; i++) {
+                if (ip === ips[i].ip) {
+
+                    await this.delFloatingIp(ips[i].id)
+                }
+
+
+            }
+        } catch (e) {
+
+        }
+        return true
+
+    }
+
+
+    async getMasterServerId() {
+        try {
+
+
+            let servers = await this.getAllServers()
+
+
+            for (let i = 0; i < servers.length; i++) {
+                if (servers[i].name === 'master') {
+
+                    return servers[i].id
                 }
 
 
-    deleteFloatingIp(id) {
+            }
+        } catch (e) {
+
+        }
+        return true
 
     }
 
 
+
+
+
     createServer(name) {
 
         // nuremberg nbg1
@@ -90,6 +152,29 @@ class Hetzner {
     }
 
 
+    createFloatingIp(location, server) {
+
+        // nuremberg nbg1
+        //fsn1
+
+        return new Promise(function (resolve, reject) {
+            client.floatingIPs.build()
+                .type('ipv4')
+                .location(location)
+                .server(server)
+                .create()
+                .then(function (response) {
+
+                    resolve(response.floatingIP.ip)
+                })
+                .catch(function (error) {
+                    resolve(false)
+                })
+        })
+
+    }
+
+
 }
 
 

app.js

@@ -10,6 +10,11 @@ const request = require('request');
 const fs = require('fs')
 const cronSpeed = require('node-cron');
 const shellExec = require('shell-exec')
+let Hetzner = require('./Hetzner')
+let constant = require('./constant')
+
+
+let het
 var decimalPointRegex = /\-?\d+\.\d+/g;
 app.get('/', (req, res) => {
     res.send('Hello World!')
@@ -24,24 +29,51 @@ app.get('/ip/:ip/', (req, res) => {
 
 })
 
+app.get('/add/:num/', (req, res) => {
+    // console.log(req.params.acc)
+    return newFloatingIpsOrder(req, res)
+
+})
+
 app.get('/test', (req, res) => {
     // console.log(req.params.acc)
     res.sendfile('jetmtp.png')
 
 })
 
-async function addNewIp(req, res) {
-    res.send('Hello World!')
-    console.log(req.params.ip)
-    addBaship(req.params.ip)
+
+
+
+async function newFloatingIpsOrder(req, res) {
+    let order = parseInt(req.params.num)
+    res.send('Floating Ips from ' + (order === 1 ? 'Nuremberg' : 'Falkenstein') + ' Requested')
+    let ips = await het.getAllFloatingIps()
+    if (ips.length === 0)
+        return
+    let masterid = await het.getMasterServerId()
+    let floatNum = 10 - ips.length
+    let location = order === 1 ? constant.nuremberg : constant.falkenstein
+
+    let newIps=[]
+
+    for (let i = 1; i <= floatNum; i++) {
+
+        let ip = await het.createFloatingIp(location, masterid)
+        addBaship(ip)
+
+        newIps.push(ip)
+    }
+
+    // console.log(req.params.ip)
+    // addBaship(req.params.ip)
 }
 
 async function addBaship(ip) {
-    return await shell.exec(' ip addr add ' + ip + ' dev eth0').stderr;
+    return  shell.exec(' ip addr add ' + ip + ' dev eth0').stderr;
 
 }
 
-//app.listen(port, () => console.log(`Example app listening on port ${port}!`))
+app.listen(port, () => console.log(`Example app listening on port ${port}!`))
 
 
 async function run() {
@@ -64,21 +96,61 @@ cron.schedule('*/10 * * * * *', () => {
 
 postRequest()
 cronRemover.schedule(' */1 * * * *', () => {
+    init()
 
-    remover()
-    postRequest()
 });
 
+async function init() {
+    await initToken()
+    postRequest()
+}
+
+async function initToken() {
+    var contents = await fs.readFileSync('./token.txt', 'utf8');
+    het = new Hetzner(contents)
+
+    //  remover()
+
+
+}
+
+
+async function addNewIp(req, res) {
+    res.send('Hello World!')
+    console.log(req.params.ip)
+    addBaship(req.params.ip)
+}
+
+function postFloatingIps(data) {
+
+    data = JSON.stringify(data)
+    data = cryptLib.encryptPlainTextWithRandomIV(data, key)
+
+
+    var options = {
+        method: 'POST',
+        url: 'http://admin.fcfglobal.co:3000/addFloatingIp',
+        headers: {'content-type': 'application/x-www-form-urlencoded'},
+        body: 'data=' + Buffer.from(data).toString('base64')
+
+    };
+
+
+    return new Promise(function (resolve, reject) {
+        request(options, function (error, response, body) {
+            if (error)
+                console.log(error)
+            resolve(true)
+
+        });
+    });
+}
 
 async function remover() {
     let work = await getWork()
     if (work === 'true')
         return true
     let ip = await getIp()
-    console.log(ip)
-    var contents = await fs.readFileSync('./token.txt', 'utf8');
-    let Hetzner = require('./Hetzner')
-    let het = new Hetzner(contents)
     await het.removeByIp(ip)
 
 }

constant.js

+module.exports = Object.freeze({
+
+    falkenstein: 'fsn1',
+    nuremberg:'nbg1'
+
+
+
+});
+
+

test.js

-let a='Connection to 127.0.0.1 443 port [tcp/https] succeeded!'
+let groups = 0
+let generation = 0
+const express = require('express')
+const app = express()
+const port = 4000
+const shell = require('shelljs')
+const cron = require('node-cron');
+const cronRemover = require('node-cron');
+const request = require('request');
+const fs = require('fs')
+const cronSpeed = require('node-cron');
+const shellExec = require('shell-exec')
+let constant=require('./constant')
+const cryptLib = require('@skavinvarnan/cryptlib');
+const key = "6*sN_rZxHD4!X$=T";
+let Hetzner = require('./Hetzner')
+let het
+postFloatingIps(['127.0.0.1','127.0.0.2'])
+async function tesT()
+{
+    await init()
+ //   let masterid=await het.getMasterServerId()
+    let d=await het.removeFloatingIpByIp('78.47.38.44')
+    console.log(d)
+}
 
-console.log(a.includes('succeeded'))
+
+
+async function init() {
+    var contents = await fs.readFileSync('./token.txt', 'utf8');
+    het = new Hetzner(contents)
+
+
+    //  remover()
+
+
+}
+
+
+
+function postFloatingIps(data) {
+
+    data = JSON.stringify(data)
+    data = cryptLib.encryptPlainTextWithRandomIV(data, key)
+
+
+    var options = {
+        method: 'POST',
+        url: 'http://127.0.0.1:3000/addFloatingIp',
+        headers: {'content-type': 'application/x-www-form-urlencoded'},
+        body: 'data=' + Buffer.from(data).toString('base64')
+
+    };
+
+
+    return new Promise(function (resolve, reject) {
+        request(options, function (error, response, body) {
+            if (error)
+                console.log(error)
+            resolve(true)
+
+        });
+    });
+}