Gfrktyl

This is the main entry point for the my application (a micro-service). I feel like I'm doing a lot of things outside of main(), but even if I brought them all inside of main(), that would just make that massive.

Still relatively new to writing production ready code, and whilst there are no problems with this code, i can't help but feel there are better ways to structure it? Is there a better way of breaking down the code I have already written and making the code more readable/maintainable?

'use strict';



const fs = require('fs');

const http = require('http');

const {Receiver, Publisher} = require('openimprabbit');

const OSSEventEmitter = require('oss-events-emitter');

const Discovery = require('service-discovery');



const authorisation = require('./services/Authorisation');

const jobParser = require('./Parser');



const rabbitMQURL = new URL('amqp://'+process.env.AMQP_HOST);

rabbitMQURL.port = process.env.AMQP_PORT;

rabbitMQURL.username = process.env.AMQP_USER;

rabbitMQURL.password = process.env.AMQP_PASS;



const rabbitMQDetails = {

  url: rabbitMQURL.toString(),

  exchange: process.env.AMQP_SEND_EXCHANGE,

  exchangeType: process.env.AMQP_TOPIC,

  routingKey: '',

};



const ossEmitter = new OSSEventEmitter(rabbitMQDetails);

const Logger = require('./AOP/Logger');

Logger.Publisher(ossEmitter);



const QAFlagValidator = Logger.ClassHandler(

  require('./job/QAFlagValidator')

);

const SchemaValidator = Logger.ClassHandler(

  require('./job/validation/SchemaValidator')

);

const RuleSetCheck = Logger.ClassHandler(

  require('./job/validation/RuleSetCheck')

);

const Releases = Logger.ClassHandler(require('./services/Releases'));



const discovery = new Discovery(http, process.env.DISCOVERY_URL);



const receiver = new Receiver(

  rabbitMQURL.toString(),

  process.env.AMQP_EXCHANGE,

  process.env.AMQP_TOPIC,

  process.env.AMQP_QUEUE,

  process.env.AMQP_PATTERN,

  {noAck: true}

);



const releaseAPI = new Releases(authorisation, http, discovery);



const schemaValidator = new SchemaValidator(

  fs,

  [

    {location: './schemas/asset-controller.json', key: 'asset_controller'},

    {location: './schemas/label.json', key: 'label'},

    {location: './schemas/musicset.json', key: 'musicset'},

    {location: './schemas/artist.json', key: 'artist'},

  ]

);



const rulesCheck = new RuleSetCheck(fs, Logger);



const qaValidator = new QAFlagValidator(

  schemaValidator, rulesCheck

);



const main = async () => {

  receiver.listen( async (msg) => {

    const releaseIDs = jobParser.parse(msg);

    const releases = await releaseAPI.getReleases(releaseIDs)

      .catch((err) => {

        console.error(err);

      });



    releases.forEach((release) => {

      if (Object.keys(release).length) {

        const rules = qaValidator.startValidation(release);

        // console.log(rules);

      }

    });

  });

};



main()

  .catch((err) => {

    console.error(err);

  });