git pull

trade.js

@@ -19,12 +19,89 @@ const ccxt = require('ccxt')
 
 let exchange
 let info
+var cors = require('cors')
+const _ = require('lodash')
+let express = require('express');
+let moment = require('moment-timezone')
 
+let app = express();
+let files=[]
+var bodyParser = require('body-parser')
 
+
+let server = require('http').createServer(app);
+
+
+let port = 80;
 init()
 
+app.use(cors())
+app.use(bodyParser.text());
+server.listen(port, () => {
+    console.log('Server listening at port %d', port);
+
+
+})
+
+
+app.post('/signal', (req, res) => {
+
+    res.send('Done')
+
+    console.log(req.body)
+    analyse(req.body)
+
+
+})
+
+async function analyse(body) {
+    let t = body.split(',')
+    let obj = {}
+    obj.symbol = t[0]
+    obj.entry = parseFloat(t[1])
+    obj.exit = parseFloat(t[2])
+    obj.side = t[3]
+    obj.timeframe = t[4]
+    obj.runUp = parseFloat(t[5])
+    obj.drawDown = parseFloat(t[6])
+    obj.profit = getPercent(obj.entry, obj.exit)
+    obj.runUp = getPercent(obj.entry, (obj.runUp + obj.entry))
+    obj.drawDown = getPercent(obj.entry, (obj.drawDown + obj.entry))
+    obj.closeTime = moment().utc().format('YYYY.MM.DD HH:mm') + ':00.000'
+    let indicator = ''
+    for (let i = 7; i < t.length; i++) {
+        indicator = indicator + t[i]
+        if (i !== t.length - 1)
+            indicator = indicator + '&'
+    }
+//Ticket,Open_Time,Type,Symbol,Open_Price,Close_Price,Close_Time,dPrfPipWrtOpPrPc,dAgeHiPrfInPrPc_RunUpPc,dAgeLoPrfInPrPc_DrawDownPc
+
+    let final = '0,00:00,'
+    if (obj.side === 'Long') {
+        final = final + 'Buy'
+        obj.side = 'Buy'
+    } else {
+        final = final + 'Sell'
+        obj.side = 'Sell'
+    }
+    final = final + ',BTCUSDT,'
+
+    final = final + obj.entry + ',' + obj.exit + ',' + obj.closeTime + ',' + obj.profit + ',' + obj.runUp + ',' + obj.drawDown
+    //  let file = await fs.readFileSync('temp/' + indicator + '.csv', 'utf8')
+    //  file = file.match(/.+/g)
+    // console.log('try Check ',obj.side,file[file.length - 1])
+    //  if (file.length > 2 && !file[file.length - 1].includes(obj.side))
+   // appendCsv(final, indicator)
+  //  appendCsvtoMain(final,indicator)
+    updateVars(indicator,final)
+}
+
+
+
+
 
 async function init() {
+    files = await fs.readdirSync('E:\\YashilFinal')
     client.on('error', (err) => console.log('Redis Client Error', err));
 
     await client.connect();
@@ -135,22 +212,7 @@ function grabData(data) {
 }
 
 
-async function checker() {
-    let arr = []
-    //  console.log('check')
-    let files = await fs.readdirSync(path)
-    for (let i = 0; i < files.length; i++) {
-
-        if (!files[i].includes('Lp'))
-            continue
-
 
-        arr.push(make(files[i]))
-    }
-    await Promise.all(arr)
-    await sleep(50)
-    return checker()
-}
 
 async function make(name) {
     let stats = await fs.statSync(path + name)
@@ -382,9 +444,9 @@ async function adder(sig, qty, date, allData, pair) {
 }
 
 
-function getVarsFromName(name) {
+function getVarsFromName(config) {
     for (let i = 0; i < datas.length; i++)
-        if (datas[i].name === name)
+        if (datas[i].name.startsWith(config + '_'))
             return datas[i].vars
 }
 
@@ -394,22 +456,22 @@ function getSizeFromName(name) {
             return datas[i].size
 }
 
-function getAllFromName(name) {
+function getAllFromName(config) {
     for (let i = 0; i < datas.length; i++)
-        if (datas[i].name === name)
+        if (datas[i].name.startsWith(config + '_'))
             return datas[i]
 }
 
 
-function updateVarsFromName(name, vars) {
+function updateVarsFromName(config, vars) {
     for (let i = 0; i < datas.length; i++)
-        if (datas[i].name === name)
+        if (datas[i].name.startsWith(config + '_'))
             datas[i].vars = vars
 }
 
-function updateSizeFromName(name, size) {
+function updateSizeFromName(config, size) {
     for (let i = 0; i < datas.length; i++)
-        if (datas[i].name === name)
+        if (datas[i].name.startsWith(config + '_'))
             datas[i].size = size
 }