hypixel-auction-notifier/index.js

const { default: axios } = require('axios');
const config = require('./config.json');
const { WebhookClient, EmbedBuilder, Embed } = require('discord.js');
const { Worker } = require('worker_threads');
const { asyncInterval, addNotation } = require('./src/helperFunctions');
const { string } = require('prismarine-nbt');

let threadsToUse = config.data['threadsToUse/speed'] ?? 1;
let lastUpdated = 0;
let doneWorkers = 0;
let startingTime;
let maxPrice = 0;
let itemDatas = {};
const workers = [];
const webhookRegex = /https:\/\/discord.com\/api\/webhooks\/(.+)\/(.+)/;

const bazaarPrice = {
  RECOMBOBULATOR_3000: 0,
  HOT_POTATO_BOOK: 0,
  FUMING_POTATO_BOOK: 0,
};

async function initialize() {
  const matches = process.env.webhook_url.match(webhookRegex);
  if (!matches) return console.log(`[Main thread] Couldn't parse Webhook URL`);
  const webhook = new WebhookClient({ id: matches[1], token: matches[2] });

  await getBzData();
  await getMoulberry();
  await getLBINs();

  for (let j = 0; j < threadsToUse; j++) {
    workers[j] = new Worker('./AuctionHandler.js', {
      workerData: {
        itemDatas: itemDatas,
        bazaarData: bazaarPrice,
        workerNumber: j,
        maxPrice: maxPrice,
      },
    });

    workers[j].on('message', async (result) => {
      if (result.itemData !== undefined) {
        let averagePrice = itemDatas[result.itemData.id]?.cleanPrice || 'N/A';
        if (
          result.auctionData.lbin - result.auctionData.price >=
            config.data.minSnipeProfit &&
          averagePrice - result.auctionData.price >= config.data.minAvgProfit
        ) {
          let mustBuyMessage = '';
          const embed = new EmbedBuilder()
            .setTitle(`**${result.itemData.name.replace(/§./g, '')}**`)
            .setColor('#2e3137')
            .setThumbnail(`https://sky.shiiyu.moe/item/${result.itemData.id}`)
            .setDescription(
              `${mustBuyMessage}\nAuction:
              \`\`\`/viewauction ${result.auctionData.auctionID}\`\`\`
              \nProfit: \`${addNotation(
                'oneLetters',
                result.auctionData.profit
              )} (${result.auctionData.percentProfit}%)\`
              \nCost: \`${addNotation('oneLetters', result.auctionData.price)}\`
              \nLBIN: \`${addNotation('oneLetters', result.auctionData.lbin)}\`
              \nSales/Day: \`${addNotation(
                'oneLetters',
                result.auctionData.sales
              )}\`
              \nType: \`${result.auctionData.ahType}\`
              \nAverage Price: \`${addNotation('oneLetters', averagePrice)}\``
            );

          await webhook.send({
            username: process.env.webhook_name,
            avatarURL: process.env.webhook_profile_picture_link,
            embeds: [embed],
          });
        }
      } else if (result === 'finished') {
        doneWorkers++;
        if (doneWorkers === threadsToUse) {
          doneWorkers = 0;
          console.log(
            `Completed in ${(Date.now() - startingTime) / 1000} seconds`
          );
          startingTime = 0;
          workers[0].emit('done');
        }
      }
    });
  }

  asyncInterval(
    async () => {
      await getLBINs();
      workers.forEach((worker) => {
        worker.postMessage({ type: 'moulberry', data: itemDatas });
      });
    },
    'lbin',
    60000
  );

  asyncInterval(
    async () => {
      await getMoulberry();
      workers.forEach((worker) => {
        worker.postMessage({ type: 'moulberry', data: itemDatas });
      });
    },
    'avg',
    60e5
  );

  asyncInterval(
    async () => {
      return new Promise(async (resolve) => {
        const ahFirstPage = await axios.get(
          'https://api.hypixel.net/skyblock/auctions?page=0'
        );
        const totalPages = ahFirstPage.data.totalPages;
        if (ahFirstPage.data.lastUpdated === lastUpdated) {
          resolve();
        } else {
          lastUpdated = ahFirstPage.data.lastUpdated;
          startingTime = Date.now();
          console.log('Getting auctions..');
          workers.forEach((worker) => {
            worker.postMessage({ type: 'pageCount', data: totalPages });
          });
          workers[0].once('done', () => {
            resolve();
          });
        }
      });
    },
    'check',
    0
  );
}

async function getLBINs() {
  const lbins = await axios.get('https://moulberry.codes/lowestbin.json');
  const lbinData = lbins.data;
  for (const item of Object.keys(lbinData)) {
    if (!itemDatas[item]) itemDatas[item] = {};
    itemDatas[item].lbin = lbinData[item];
  }
}

async function getMoulberry() {
  const moulberryAvgs = await axios.get(
    'https://moulberry.codes/auction_averages/3day.json'
  );
  const avgData = moulberryAvgs.data;

  const cleanPriceAvgs = await axios.get(
    'https://moulberry.codes/auction_averages_lbin/1day.json'
  );
  const cleanPriceData = cleanPriceAvgs.data;

  for (const item of Object.keys(avgData)) {
    if (!itemDatas[item]) itemDatas[item] = {};
    const itemInfo = avgData[item];

    itemDatas[item].sales = itemInfo.sales !== undefined ? itemInfo.sales : 0;
    itemDatas[item].cleanPrice =
      cleanPriceData[item] !== undefined
        ? Math.round(cleanPriceData[item])
        : itemInfo.clean_price !== undefined
        ? itemInfo.clean_price
        : itemInfo.price;
  }
}

async function getBzData() {
  const bzData = await axios.get('https://api.hypixel.net/skyblock/bazaar');
  bazaarPrice['RECOMBOBULATOR_3000'] =
    bzData.data.products.RECOMBOBULATOR_3000.quick_status.buyPrice;
  bazaarPrice['HOT_POTATO_BOOK'] =
    bzData.data.products.HOT_POTATO_BOOK.quick_status.buyPrice;
  bazaarPrice['FUMING_POTATO_BOOK'] =
    bzData.data.products.FUMING_POTATO_BOOK.quick_status.buyPrice;
}

initialize();