icm-noti.js

channel = '#c-crazy';
enableTrade = false;

openAt = undefined;
lastSend = Date.now();
lastCountTrades = 0;

backendApi='https://backend.xbot.com.vn:3050/api';

tradeNew = (rows) => {
  fetch(`${backendApi}/trade/new`, {
    method: 'POST',
    body: JSON.stringify({
      rows,
    }),
    headers: {
      'Content-type': 'application/json; charset=UTF-8'
    }
  }).then(console.log).catch(console.log)
};
tradeClose = () => {
  fetch(`${backendApi}/trade/close`, {
    method: 'POST',
    body: JSON.stringify({
    }),
    headers: {
      'Content-type': 'application/json; charset=UTF-8'
    }
  }).then(console.log).catch(console.log)
};

send = (text, customChannel) => {
  fetch(`${backendApi}/noti/new`, {
    method: 'POST',
    body: JSON.stringify({
      payload: {
        channel: customChannel || channel,
        username: 'webhookbot',
        icon_emoji: ':ghost:',
        text,
      }
    }),
    headers: {
      'Content-type': 'application/json; charset=UTF-8'
    }
  }).then(console.log).catch(console.log)
};
send(`Started ${channel}`, "c-log");

parseRow = (node) => {
  return [...node.children].map(node => {
    if (node.children[0].children[0]) {
      return node.children[0].children[0].innerText;
    } else {
      return node.children[0].innerText;
    }
  });
};
parseNum = (num) => parseFloat(parseFloat(num).toFixed(2));

run = () => {
  const checkArr = document.querySelectorAll("div[data-test-id^=table-header-cell-created]");
  if (!checkArr.length) {
    if (Date.now() - lastSend > 1000 * 60 * 5) {
      lastSend = Date.now();
      send('ERROR! Page is sleeping!');
    }
  } else {
    const rows = document.querySelectorAll("div[data-test-id^=table-row-root]");
    if (rows.length) {
      if (rows.length !== lastCountTrades) {
        lastCountTrades = rows.length;
        const trades = [];
        rows.forEach(row => {
          trades.push(parseRow(row));
        })
        console.log(trades);
        if (enableTrade) tradeNew(trades);
      }

      if (!openAt) {
        openAt = Date.now();
        lastSend = openAt;
        const pos = parseRow(rows[0]).join(', ');
        const text = `New pos: ${pos}`;
        send(text);
      } else {
        if (Date.now() - lastSend > 1000 * 60 * 5) {
          lastSend = Date.now();
          let profit = 0;
          let pips = 0;
          rows.forEach(row => {
            const pos = parseRow(row);
            profit += parseNum(pos[9]);
            pips += parseNum(pos[7]);
          })
          const firstPos = parseRow(rows[rows.length - 1]).join(', ');
          const lastPos = parseRow(rows[0]).join(', ');
          const text = `Last pos: ${lastPos}.\nFirst pos: ${firstPos}\nNum pos: ${rows.length}. Profit: ${profit}. Pips: ${pips}`;
          send(text);
        }
      }
    } else {
      if (openAt) {
        tradeClose();
        openAt = undefined;
        lastSend = Date.now();
        lastCountTrades = 0;
        send('Close pos!');
      } else {
        if (Date.now() - lastSend > 1000 * 60 * 60) {
          lastSend = Date.now();
          send(`Heartbeat! ${channel}`, "c-log");
        }
      }
    }
  }
}

loop = setInterval(() => {
  try {
    run();
  } catch (error) {
    send(`Error: ${error.message}`);
  }
}, 1000);