bcgov/common-hosted-email-service

Similar blocks of code found in 2 locations. Consider refactoring.

Open

      if (integrityList && integrityList.length) {
        log.error(`Message(s) ${integrityList} inconsistent or corrupted.`, { function: 'findPromoteMessages' });
        throw new Problem(500, {
          detail: 'Some message(s) are inconsistent or corrupted.',
          messages: integrityList

• Read up
  Read up

Function default has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export default function (data) {
  console.log(`VU: ${__VU}  -  ITER: ${__ITER}`);
  console.debug('Running Tests');
  console.debug(`Data from setup: ${JSON.stringify(data)}`);
  if (!data.token) {

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  return Promise.resolve()
    .then(() => knex.schema.alterTable('message', table => {
      table.dropForeign('transactionId');
      table.foreign('transactionId').references('transactionId').inTable('trxn');
    }))

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  resume() {
    if (this.queue) {
      this.queue.resume(true).then(() => {
        log.info('Start accepting new jobs', { function: 'resume' });
      });

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  pause() {
    if (this.queue) {
      this.queue.pause(true).then(() => {
        log.info('Stop accepting new jobs', { function: 'pause' });
      });

• Read up
  Read up

Function up has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

exports.up = function (knex) {

  const statusTable = (table) => {
    table.uuid('messageId').references('messageId').inTable('message').notNullable().index();
    table.string('status').notNullable().defaultTo('accepted');

Similar blocks of code found in 5 locations. Consider refactoring.

Open

          if (!models.context.tag(c['tag'])) {
            errors.push({ value: c['tag'], message: `Contexts[${i}] invalid value \`tag\`.` });
          }

• Read up
  Read up

Similar blocks of code found in 5 locations. Consider refactoring.

Open

          if (!models.context.to(c['to'])) {
            errors.push({ value: c['to'], message: `Contexts[${i}] invalid value \`to\`.` });
          }

• Read up
  Read up

Similar blocks of code found in 5 locations. Consider refactoring.

Open

          if (!models.context.bcc(c['bcc'])) {
            errors.push({ value: c['bcc'], message: `Contexts[${i}] invalid value \`bcc\`.` });
          }

• Read up
  Read up

Similar blocks of code found in 5 locations. Consider refactoring.

Open

          if (!models.context.cc(c['cc'])) {
            errors.push({ value: c['cc'], message: `Contexts[${i}] invalid value \`cc\`.` });
          }

• Read up
  Read up

Similar blocks of code found in 5 locations. Consider refactoring.

Open

          if (!models.context.delayTS(c['delayTS'])) {
            errors.push({ value: c['delayTS'], message: `Contexts[${i}] invalid value \`delayTS\`.` });
          }

• Read up
  Read up

Function relationMappings has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  static relationMappings () {
    const Queue = require('./queue');
    const Status = require('./status');
    const Trxn = require('./trxn');
    return {

Similar blocks of code found in 2 locations. Consider refactoring.

Open

process.on('unhandledRejection', err => {
  log.error(`Unhandled Rejection: ${err.message ?? err}`, { function: 'onUnhandledRejection' });
  fatalErrorHandler();
});

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

process.on('uncaughtException', err => {
  log.error(`Unhandled Exception: ${err.message ?? err}`, { function: 'onUncaughtException' });
  fatalErrorHandler();
});

• Read up
  Read up

Function sendEmailMerge has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  async sendEmailMerge(client, template, ethereal = false) {
    if (!template) {
      throw new Problem(400, { detail: 'Error sending email merge. Email templates/contexts cannot be null' });
    }
    if (!ethereal && !client) {

Function cancelMessage has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  async cancelMessage(client, messageId) {
    if (!client || !messageId) {
      throw new Problem(400, { detail: 'Error cancelling message. Client and messageId cannot be null' });
    }

Function updateStatus has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  async updateStatus(client, messageId, status, description) {
    let trx;
    try {
      trx = await Message.startTransaction();

Function setup has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function setup() {
  console.log(`Email url: ${emailUrl}`);
  console.log(`SSO url: ${oidcUrl}`);
  console.debug('Getting Token');
  // Check a secret was supplied or nothing will work

Function promoteMessage has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  async promoteMessage(client, messageId) {
    if (!client || !messageId) {
      throw new Problem(400, { detail: 'Error promoting message. Client and messageId cannot be null' });
    }

Function _createClient has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

const _createClient = () => {
  let redis;

  const redisOpts = {
    enableReadyCheck: false, // Bull forcibly assumes Redis is ready if it has connected to it