index.js

"use strict";
import line from "@line/bot-sdk";
import express from "express";
import _ from "lodash";
import { getReward, getMirPrice, getPrices, getMarketPrices } from "./mirror.js";

import { listTemplate, generateRow, generateRow3, generateTemplate } from "./line.js";

// create LINE SDK config from env variables
const config = {
  channelAccessToken: process.env.CHANNEL_ACCESS_TOKEN,
  channelSecret: process.env.CHANNEL_SECRET
};

// create LINE SDK client
const client = new line.Client(config);

// create Express app
// about Express itself: https://expressjs.com/
const app = express();

// register a webhook handler with middleware
// about the middleware, please refer to doc
app.post("/callback", line.middleware(config), (req, res) => {
  Promise.all(req.body.events.map(handleEvent))
    .then(result => res.json(result))
    .catch(err => {
      console.error(err);
      res.status(500).end();
    });
});

// event handler
async function handleEvent(event) {
  if (event.type !== "message" || event.message.type !== "text") {
    // ignore non-text-message event
    return Promise.resolve(null);
  }

  // Test valid address
  const text = event.message.text;

  const terraAddressFormat = /^terra[a-z0-9]{39}$/;

  if (terraAddressFormat.test(text)) {
    return await getMirrorReward(text, event);
  }
  if (text.toLowerCase() === "mirror" || text.toLowerCase() === "mir") {
    return await getMirrorPrices(event);
  } else {
    const replyMessage = { type: "text", text: "Invalid Command" };
    return client.replyMessage(event.replyToken, replyMessage);
  }
}

async function getMirrorReward(text, event) {
  const mirrorReward = await getReward(text);
  const priceData = await getMirPrice();
  const mirPrice = priceData.asset.prices.price;

  let replyContent = JSON.parse(JSON.stringify(listTemplate));

  // Set current mir price
  replyContent.body.contents[2].text = "MIR = $" + mirPrice;

  // Push Reward List
  let sum = 0;
  mirrorReward.forEach(reward => {
    sum += parseFloat(reward.reward);
    replyContent.body.contents[4].contents.push(generateRow(reward.name, reward.reward));
  });

  replyContent.body.contents[4].contents.push(generateRow("Total(MIR)", "" + sum.toFixed(6), { bold: true }));

  replyContent.body.contents[4].contents.push(
    generateRow("Total(UST)", "" + (sum * parseFloat(mirPrice)).toFixed(6), {
      bold: true
    })
  );

  replyContent.body.contents[replyContent.body.contents.length - 1].contents[0].text = new Date().toUTCString();

  const replyMessage = {
    type: "flex",
    altText: "Your mirror reward",
    contents: replyContent
  };

  // use reply API
  return client.replyMessage(event.replyToken, replyMessage);
}

async function getMirrorPrices(event) {
  let template = generateTemplate("Market Prices", "Mirror", "to the moon");
  let prices = await getMarketPrices();
  template.body.contents[4].contents.push(generateRow3("Name", "Oracle", "AMM", "Diff%"));

  prices = prices.assets;

  prices = _.sortBy(prices, price => {
    return price.symbol;
  });

  prices.forEach(price => {
    let realPrice = price.prices.price;
    realPrice = realPrice ? parseFloat(realPrice).toFixed(2) + "" : "-";
    let oraclePrice = price.prices.oraclePrice;
    oraclePrice = oraclePrice ? parseFloat(oraclePrice).toFixed(2) + "" : "-";

    const diff = "" + (((realPrice - oraclePrice) * 100) / oraclePrice).toFixed(2);

    template.body.contents[4].contents.push(
      generateRow3(price.symbol, oraclePrice, realPrice, diff, {
        thirdColor: "#FF2400",
        firstBold: true
      })
    );
  });

  template.body.contents[template.body.contents.length - 1].contents[0].text = new Date().toUTCString();

  const replyMessage = {
    type: "flex",
    altText: "Mirror Prices",
    contents: template
  };

  // use reply API
  return client.replyMessage(event.replyToken, replyMessage);
}

// listen on port
const port = process.env.PORT || 3000;
app.listen(port, () => {
  console.log(`listening on ${port}`);
});