utilise enabled feature flag (#22)

app/messaging/index.js

@@ -1,13 +1,17 @@
 const { MessageReceiver } = require('ffc-messaging')
-const { messagingConfig } = require('../config')
+const { messagingConfig, processingConfig } = require('../config')
 const processDemographicsMessage = require('./process-demographics-message')
 let updateReceiver
 
 const start = async () => {
-  const updateAction = message => processDemographicsMessage(message, updateReceiver)
-  updateReceiver = new MessageReceiver(messagingConfig.updatesSubscription, updateAction)
-  await updateReceiver.subscribe()
-  console.info('Receiver ready to receive demographics updates')
+  if (processingConfig.enabled) {
+    const updateAction = message => processDemographicsMessage(message, updateReceiver)
+    updateReceiver = new MessageReceiver(messagingConfig.updatesSubscription, updateAction)
+    await updateReceiver.subscribe()
+    console.info('Receiver ready to receive demographics updates')
+  } else {
+    console.info('Demographics updates are not configured in this environment')
+  }
 }
 
 const stop = async () => {

app/storage.js

@@ -34,9 +34,9 @@ const setupBlobServiceClient = () => {
 }
 
 const initialiseContainers = async () => {
-  if (!containersInitialised) {
-    setupBlobServiceClient()
-    if (storageConfig.enabled) {
+  if (storageConfig.enabled) {
+    if (!containersInitialised) {
+      setupBlobServiceClient()
       if (storageConfig.createContainers) {
         console.log('Making sure blob containers exist')
         await demographicsContainer.createIfNotExists()

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ffc-pay-demographics",
-  "version": "1.2.8",
+  "version": "1.2.9",
   "description": "Process customer updates",
   "homepage": "https://github.com/DEFRA/ffc-pay-demographics",
   "main": "app/index.js",

test/unit/messaging/index.test.js

@@ -1,7 +1,8 @@
 const mockSubscribe = jest.fn()
 const mockCloseConnection = jest.fn()
+const mockProcessDemographicsMessage = jest.fn()
 
-const MockMessageReceiver = jest.fn().mockImplementation(() => {
+const MockMessageReceiver = jest.fn().mockImplementation((subscription, action) => {
   return {
     subscribe: mockSubscribe,
     closeConnection: mockCloseConnection
@@ -14,32 +15,40 @@ jest.mock('ffc-messaging', () => {
   }
 })
 
-jest.mock('../../../app/messaging/process-demographics-message')
-
-const config = require('../../../app/config')
+jest.mock('../../../app/messaging/process-demographics-message', () => mockProcessDemographicsMessage)
 
+const { messagingConfig, processingConfig } = require('../../../app/config')
 const { start, stop } = require('../../../app/messaging')
 
 beforeEach(() => {
   jest.clearAllMocks()
 
-  config.enabled = true
+  processingConfig.enabled = true
 })
 
 describe('messaging start', () => {
-  test('creates new message receiver', async () => {
+  test('creates new message receiver with correct subscription', async () => {
     await start()
     expect(MockMessageReceiver).toHaveBeenCalledTimes(1)
+    expect(MockMessageReceiver).toHaveBeenCalledWith(messagingConfig.updatesSubscription, expect.any(Function))
   })
 
   test('subscribes to message receiver', async () => {
     await start()
     expect(mockSubscribe).toHaveBeenCalledTimes(1)
   })
+
+  test('does not start receiver if processingConfig is disabled', async () => {
+    processingConfig.enabled = false
+    await start()
+    expect(MockMessageReceiver).not.toHaveBeenCalled()
+    expect(mockSubscribe).not.toHaveBeenCalled()
+  })
 })
 
 describe('messaging stop', () => {
   test('closes connection', async () => {
+    await start()
     await stop()
     expect(mockCloseConnection).toHaveBeenCalledTimes(1)
   })