index.js

const express = require("express");
const bodyParser = require("body-parser");
const amqp = require("amqp");
const config = require("./config/config.json");
const CloudStorm = require("@xandium/cloudstorm").Client;
const app = express();
const bot = new CloudStorm(config.token, config.botConfig);
const shardRouter = require("./routes/shardStatusRoutes");
const gatewayRouter = require("./routes/gatewayRoutes");
let StatsD;
let statsClient;
try {
  StatsD = require("hot-shots");
} catch (e) {}
if (StatsD && config.statsD && config.statsD.enabled) {
  statsClient = new StatsD(config.statsD);
}
const version = require("./package.json").version;
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
app.use((req, res, next) => {
  req.bot = bot;
  next();
});
app.use("/shards", shardRouter);
app.use("/gateway", gatewayRouter);
app.all("/", (req, res) => {
  res.json({ version: version, gatewayVersion: bot.version });
});
app.listen(config.port, config.host);
const connection = amqp.createConnection(config.amqpUrl);
connection.on("error", e => {
  console.error(e);
});
connection.on("ready", async () => {
  console.log("AMQP Connection ready");
  await bot.connect();
  bot.on("event", event => {
    if (statsClient) {
      statsClient.increment(
        `discordevent`,
        1,
        1,
        [`shard:${event.shard_id}`, `event:${event.t}`],
        err => {
          if (err) {
            console.log(err);
          }
        }
      );
      if (event.t !== "PRESENCE_UPDATE") {
        statsClient.increment(
          `discordevent.np`,
          1,
          1,
          [`shard:${event.shard_id}`, `event:${event.t}`],
          err => {
            if (err) {
              console.log(err);
            }
          }
        );
      }
    }
    connection.publish(config.amqpQueue, event);
    // Event was sent to amqp queue, now you can use it somewhere else
  });
});
bot.on("ready", () => {
  console.log(
    `Bot is ready with ${Object.keys(bot.shardManager.shards).length} shards`
  );
});
// bot.on('event', (event) => {
//     console.log(event);
// });

console.log(`Server listening on ${config.host}:${config.port}`);