Commit 431e2f7a authored by Ahmad Nemati's avatar Ahmad Nemati

init

parent af25290c
...@@ -69,6 +69,7 @@ cronRemover.schedule(' */2 * * * *', () => { ...@@ -69,6 +69,7 @@ cronRemover.schedule(' */2 * * * *', () => {
}); });
init()
async function init() { async function init() {
await initToken() await initToken()
...@@ -120,12 +121,12 @@ async function sleep(millis) { ...@@ -120,12 +121,12 @@ async function sleep(millis) {
async function initToken() { async function initToken() {
let d = aruba.getDc()
if (typeof d === "undefined")
await aruba.init() await aruba.init()
// remover()
aruba.logData()
} }
......
...@@ -12,7 +12,7 @@ let serverId ...@@ -12,7 +12,7 @@ let serverId
//test() //test()
async function test() { async function test() {
ip = '94.177.244.45' ip = '195.231.67.162'
for (let i = 0; i < AvailDc.length; i++) { for (let i = 0; i < AvailDc.length; i++) {
let servers = await getAllServers(AvailDc[i]) let servers = await getAllServers(AvailDc[i])
servers = servers.Value servers = servers.Value
...@@ -47,6 +47,8 @@ async function test() { ...@@ -47,6 +47,8 @@ async function test() {
async function init() { async function init() {
if (typeof foundDc !=="undefined")
return true
ip = await getIp() ip = await getIp()
for (let i = 0; i < AvailDc.length; i++) { for (let i = 0; i < AvailDc.length; i++) {
let servers = await getAllServers(AvailDc[i]) let servers = await getAllServers(AvailDc[i])
...@@ -60,7 +62,6 @@ async function init() { ...@@ -60,7 +62,6 @@ async function init() {
let server = await getDetailsofServer(AvailDc[i], servers[j].ServerId) let server = await getDetailsofServer(AvailDc[i], servers[j].ServerId)
server = server.Value server = server.Value
if (ip === server.NetworkAdapters[0].IPAddresses[0].Value) { if (ip === server.NetworkAdapters[0].IPAddresses[0].Value) {
masterIp = server.NetworkAdapters[0].IPAddresses[0].Value
networkId = server.NetworkAdapters[0].Id networkId = server.NetworkAdapters[0].Id
serverId = server.ServerId serverId = server.ServerId
foundDc = AvailDc[i] foundDc = AvailDc[i]
...@@ -71,6 +72,8 @@ async function init() { ...@@ -71,6 +72,8 @@ async function init() {
} }
return true
} }
...@@ -235,6 +238,7 @@ async function doRequest(url, body) { ...@@ -235,6 +238,7 @@ async function doRequest(url, body) {
resolve(JSON.parse(body)) resolve(JSON.parse(body))
} catch (e) { } catch (e) {
console.log(e)
resolve(true) resolve(true)
// console.log('Problem --->' + options.url) // console.log('Problem --->' + options.url)
// console.log(e) // console.log(e)
...@@ -299,6 +303,14 @@ function getIp() { ...@@ -299,6 +303,14 @@ function getIp() {
} }
function logData()
{
console.log('foundDc ->' + foundDc)
console.log('masterIp ->' + masterIp)
console.log('networkId ->' + networkId)
console.log('serverId ->' + serverId)
}
module.exports = module.exports =
{ {
init: init, init: init,
...@@ -306,6 +318,7 @@ module.exports = ...@@ -306,6 +318,7 @@ module.exports =
attachedToServerByIp: attachedToServerByIp, attachedToServerByIp: attachedToServerByIp,
RemovedByIp: RemovedByIp, RemovedByIp: RemovedByIp,
getDc: getDc, getDc: getDc,
logData:logData,
createFloatingIp: createFloatingIp createFloatingIp: createFloatingIp
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment