server.js

const { WebhookClient } = require('discord.js');
const { TwitterApi } = require('twitter-api-v2');
const { watchForTransfers } = require('./utils/watcher');
const { formatDiscordMessage, formatTwitterMessage, formatValue } = require('./utils/format');

require('dotenv').config()

const {
	DISCORD_ID, DISCORD_TOKEN,
	TWITTER_API_KEY, TWITTER_API_KEY_SECRET, TWITTER_ACCESS_TOKEN_KEY, TWITTER_ACCESS_TOKEN_SECRET,
  MINIMUM_ETH_AMOUNT
} = process.env

const ENABLE_DISCORD = DISCORD_ID !== ''
const ENABLE_TWITTER = TWITTER_API_KEY !== ''

let discordClient, _twitterClient, twitterClient

if(ENABLE_DISCORD) {
  discordClient = new WebhookClient({id: DISCORD_ID, token: DISCORD_TOKEN})
}

if(ENABLE_TWITTER) {
  _twitterClient = new TwitterApi({
    appKey: TWITTER_API_KEY,
    appSecret: TWITTER_API_KEY_SECRET,
    accessToken: TWITTER_ACCESS_TOKEN_KEY,
    accessSecret: TWITTER_ACCESS_TOKEN_SECRET
  })

  twitterClient = _twitterClient.readWrite
}

const transferHandler = async ({ data, totalPrice, buyer, seller, ethPrice, currency, platforms, transactionHash }) => {
  if(totalPrice >= MINIMUM_ETH_AMOUNT) {
    if(ENABLE_DISCORD) {
      // post to discord
      const discordMsg = await formatDiscordMessage({ data, totalPrice, buyer, seller, ethPrice, currency, platforms })
      discordClient.send(discordMsg).catch(console.error)
    }

    if(ENABLE_TWITTER) {
      // tweet
      const [twitterMessage, mediaId] = await formatTwitterMessage(twitterClient, { data, totalPrice, buyer, seller, ethPrice, currency, platforms })
      twitterClient.v1.tweet(twitterMessage, { media_ids: mediaId }).catch(err => { console.log(JSON.stringify(twitterMessage)); console.log(err) })
    }
  } else {
    console.log(`Price of sale (${formatValue(totalPrice, 2)}) too low.. tx id ${transactionHash}`)
  }
}

watchForTransfers(transferHandler)