avoid circular dependency

Author: eisbilir

src/common/helper.js

@@ -180,17 +180,6 @@ async function postMessageViaWebhook (webhook, message) {
   await request.post(webhook).send(message)
 }
 
-/**
- * Calls ActionProcessorService to attempt to retry failed process
- * @param {String} topic the failed topic name
- * @param {Object} payload the payload
- * @param {String} retry how many times has it been retried
- */
-async function retryFailedProcess (topic, payload, retry) {
-  const ActionProcessorService = require('../services/ActionProcessorService')
-  await ActionProcessorService.processCreate(topic, payload, retry)
-}
-
 let busApiClient
 
 /**
@@ -242,7 +231,6 @@ module.exports = {
   checkEsMutexRelease,
   getM2MToken,
   postMessageViaWebhook,
-  retryFailedProcess,
   getBusApiClient,
   postEvent
 }

src/services/WorkPeriodProcessorService.js

@@ -9,6 +9,7 @@ const constants = require('../common/constants')
 const config = require('config')
 const _ = require('lodash')
 const esClient = helper.getESClient()
+const ActionProcessorService = require('../services/ActionProcessorService')
 
 /**
  * Process create entity message
@@ -31,7 +32,7 @@ async function processCreate (message, transactionId, options) {
     // it has not yet been created. We should send a retry request.
     if (err.httpStatus === 404) {
       logger.logFullError(err, { component: 'WorkPeriodProcessorService', context: 'processCreate' })
-      await helper.retryFailedProcess(message.topic, workPeriod, options.retry)
+      await ActionProcessorService.processCreate(message.topic, workPeriod, options.retry)
       return
     } else {
       throw err