server.js

const { Client, Intents } = require('discord.js');
const { verify } = require('jsonwebtoken');
const express = require('express');
const cors = require('cors');

const PAYLOAD_ROUTER = require('./routes/payload');
const HIREUS_V2_ROUTER = require('./routes/hireus-v2');
// const ESCROW_ROUTER = require("./routes/escrow");
const JOINUS_ROUTER = require('./routes/joinus');
const HASURA_ROUTER = require('./routes/hasura');

// const subscribeEvent = require("./features/bids");

const { SECRETS } = require('./config');
const { verifySignature } = require('./utils/auth');

const createServer = () => {
  const client = new Client({
    partials: ['MESSAGE', 'REACTION', 'CHANNEL'],
    intents: [
      Intents.FLAGS.GUILDS,
      Intents.FLAGS.GUILD_MESSAGES,
      Intents.FLAGS.GUILD_MEMBERS,
      Intents.FLAGS.GUILD_MESSAGE_REACTIONS,
      Intents.FLAGS.DIRECT_MESSAGES,
    ],
  });

  client.once('ready', () => {
    // subscribeEvent(client);

    const app = express();

    app.use(express.json());
    app.use(cors());

    app.use(
      '/payload',
      (req, res, next) => {
        try {
          if (!verifySignature(req)) {
            return res.status(403).send('Forbidden');
          }
          req.CLIENT = client;
          next();
        } catch (err) {
          return res.status(403).send('Forbidden');
        }
      },
      PAYLOAD_ROUTER,
    );

    app.use(
      '/hireus-v2',
      (req, res, next) => {
        req.CLIENT = client;
        const { authorization } = req.headers;
        const token = authorization && authorization.split(' ')[1];
        if (token !== null) {
          try {
            verify(token, SECRETS.JWT_SECRET);
            next();
          } catch (err) {
            console.log(err);
            return;
          }
        }
        next();
      },
      HIREUS_V2_ROUTER,
    );

    app.use(
      '/joinus',
      (req, res, next) => {
        req.CLIENT = client;
        const { authorization } = req.headers;
        const token = authorization && authorization.split(' ')[1];
        if (token !== null) {
          try {
            verify(token, SECRETS.JWT_SECRET);
            next();
          } catch (err) {
            return;
          }
        }
      },
      JOINUS_ROUTER,
    );

    app.use(
      '/hasura',
      (req, res, next) => {
        req.CLIENT = client;
        const { authorization } = req.headers;
        const token = authorization && authorization.split(' ')[1];
        if (token !== null) {
          try {
            if (token !== SECRETS.WEBHOOK_API_TOKEN) {
              return res.status(403).json({ error: 'Forbidden' });
            }
            next();
          } catch (err) {
            return res.status(403).json({ error: 'Forbidden' });
          }
        }
      },
      HASURA_ROUTER,
    );

    // app.use(
    //   "/escrow",
    //   (req, res, next) => {
    //     req.CLIENT = client;
    //     next();
    //   },
    //   ESCROW_ROUTER
    // );

    app.get('/', (req, res) => {
      res.send('Hi');
    });

    app.listen(process.env.PORT || 8080, () =>
      console.log(`Server Listening on port ${process.env.PORT || 8080}..`),
    );
  });

  client.login(SECRETS.TOKEN);
};

module.exports = createServer;