CIV-16511 Adding Send And Reply Messages To API Cse Worker tests

e2e/api/steps.js

@@ -40,6 +40,7 @@ const {adjustCaseSubmittedDateForMinti, assertTrackAfterClaimCreation, addSubmit
 const stayCase = require('../fixtures/events/stayCase');
 const manageStay = require('../fixtures/events/manageStay');
 const dismissCase = require('../fixtures/events/dismissCase');
+const sendAndReplyMessage = require('../fixtures/events/sendAndReplyMessages');
 
 
 const data = {
@@ -100,7 +101,9 @@ const data = {
   STAY_CASE: () => stayCase.stayCase(),
   MANAGE_STAY_UPDATE: () => manageStay.manageStayRequestUpdateDamages(),
   MANAGE_STAY_LIFT: () => manageStay.manageStayLiftStayDamages(),
-  DISMISS_CASE: () => dismissCase.dismissCaseDamages()
+  DISMISS_CASE: () => dismissCase.dismissCaseDamages(),
+  SEND_MESSAGE: () => sendAndReplyMessage.sendMessage(),
+  REPLY_MESSAGE: (messageCode, messageLabel) => sendAndReplyMessage.replyMessage(messageCode, messageLabel)
 };
 const calculatedClaimsTrackDRH = {
     disposalOrderWithoutHearing: (d) => typeof d.input === 'string',
@@ -1483,11 +1486,63 @@ module.exports = {
 
     await waitForFinishedBusinessProcess(caseId);
   },
+  sendMessage: async (user) => {
+    console.log('Send message  case for case id ' + caseId);
+    await apiRequest.setupTokens(user);
+    eventName = 'SEND_AND_REPLY';
+
+    let returnedCaseData = await apiRequest.startEvent(eventName, caseId);
+    delete returnedCaseData['SearchCriteria'];
+    caseData = returnedCaseData;
+    let disposalData = data.SEND_MESSAGE();
+    for (let pageId of Object.keys(disposalData.valid)) {
+      await assertValidData(disposalData, pageId);
+    }
+    await assertSubmittedEvent('CASE_STAYED', {
+      header: '# Your message has been sent',
+      body: '<br /><h2 class="govuk-heading-m">What happens next</h2><br />A task has been created to review your message'
+    }, true);
+
+    await waitForFinishedBusinessProcess(caseId);
+  },
+
+  replyMessage: async (user) => {
+    console.log('Send message  case for case id ' + caseId);
+    await apiRequest.setupTokens(user);
+    eventName = 'SEND_AND_REPLY';
+
+    let returnedCaseData = await apiRequest.startEvent(eventName, caseId);
+    delete returnedCaseData['SearchCriteria'];
+    caseData = returnedCaseData;
 
+    const latestMessage = getLatestMessageToReplyTo(caseData);
+    const disposalData = data.REPLY_MESSAGE(latestMessage.code, latestMessage.label);
+    for (let pageId of Object.keys(disposalData.valid)) {
+      await assertValidData(disposalData, pageId);
+    }
+    await assertSubmittedEvent('CASE_STAYED', {
+      header: '# Reply sent',
+      body: '<br /><h2 class="govuk-heading-m">What happens next</h2><br />A task has been created to review your reply.'
+    }, true);
+
+    await waitForFinishedBusinessProcess(caseId);
+  },
 
 };
 
 // Functions
+const getLatestMessageToReplyTo = (caseData) => {
+  const messagesToReplyTo = caseData.messagesToReplyTo;
+  if (messagesToReplyTo && messagesToReplyTo.list_items && messagesToReplyTo.list_items.length > 0) {
+    const latestMessage = messagesToReplyTo.list_items[messagesToReplyTo.list_items.length - 1];
+    return {
+      code: latestMessage.code,
+      label: latestMessage.label
+    };
+  }
+  return null;
+};
+
 const validateEventPages = async (data, solicitor) => {
   //transform the data
   for (let pageId of Object.keys(data.valid)) {
@@ -1541,6 +1596,19 @@ const assertValidData = async (data, pageId, solicitor) => {
     responseBody.data.allocatedTrack = caseData.allocatedTrack;
     responseBody.data.respondent1Represented = caseData.respondent1Represented;
   }
+
+  if(eventName === 'SEND_AND_REPLY') {
+    if (pageId === 'sendAndReplyOption') {
+      if (typeof caseData.lastMessage !== 'undefined') {
+        responseBody.data.lastMessageJudgeLabel = caseData.lastMessageJudgeLabel;
+        responseBody.data.lastMessage = caseData.lastMessage;
+        responseBody.data.lastMessageAllocatedTrack = caseData.lastMessageAllocatedTrack;
+      }
+
+      delete responseBody.data['messageHistory'];
+    }
+  }
+
   if(sdoR2Flag){
     delete responseBody.data['smallClaimsFlightDelayToggle'];
     delete responseBody.data['smallClaimsFlightDelay'];

e2e/api/steps_LRspec.js

@@ -45,6 +45,7 @@ const manageStay = require('../fixtures/events/manageStay');
 const dismissCase = require('../fixtures/events/dismissCase');
 const genAppClaimData = require('../fixtures/events/createGeneralApplication');
 const genAppClaimDataLR = require('../fixtures/events/createGeneralApplicationLR');
+const sendAndReplyMessage = require('../fixtures/events/sendAndReplyMessages');
 
 let caseId, eventName, mintiClaimTrack;
 let caseData = {};
@@ -100,7 +101,9 @@ const data = {
   STAY_CASE: () => stayCase.stayCaseSpec(),
   MANAGE_STAY_UPDATE: () => manageStay.manageStayRequestUpdate(),
   MANAGE_STAY_LIFT: () => manageStay.manageStayLiftStay(),
-  DISMISS_CASE: () => dismissCase.dismissCase()
+  DISMISS_CASE: () => dismissCase.dismissCase(),
+  SEND_MESSAGE: () => sendAndReplyMessage.sendMessageLr(),
+  REPLY_MESSAGE: (messageCode, messageLabel) => sendAndReplyMessage.replyMessageLr(messageCode, messageLabel)
 };
 
 const eventData = {
@@ -1876,6 +1879,59 @@ module.exports = {
     await waitForFinishedBusinessProcess(caseId);
   },
 
+  sendMessage: async (user) => {
+    console.log('Send message  case for case id ' + caseId);
+    await apiRequest.setupTokens(user);
+    eventName = 'SEND_AND_REPLY';
+
+    let returnedCaseData = await apiRequest.startEvent(eventName, caseId);
+    delete returnedCaseData['SearchCriteria'];
+    caseData = returnedCaseData;
+    let disposalData = data.SEND_MESSAGE();
+    for (let pageId of Object.keys(disposalData.userInput)) {
+      await assertValidData(disposalData, pageId);
+    }
+    await assertSubmittedEvent('CASE_STAYED', {
+      header: '# Your message has been sent',
+      body: '<br /><h2 class="govuk-heading-m">What happens next</h2><br />A task has been created to review your message'
+    }, true);
+
+    await waitForFinishedBusinessProcess(caseId);
+  },
+
+  replyMessage: async (user) => {
+    console.log('Send message  case for case id ' + caseId);
+    await apiRequest.setupTokens(user);
+    eventName = 'SEND_AND_REPLY';
+
+    let returnedCaseData = await apiRequest.startEvent(eventName, caseId);
+    delete returnedCaseData['SearchCriteria'];
+    caseData = returnedCaseData;
+
+    const latestMessage = getLatestMessageToReplyTo(caseData);
+    const disposalData = data.REPLY_MESSAGE(latestMessage.code, latestMessage.label);
+    for (let pageId of Object.keys(disposalData.userInput)) {
+      await assertValidData(disposalData, pageId);
+    }
+    await assertSubmittedEvent('CASE_STAYED', {
+      header: '# Reply sent',
+      body: '<br /><h2 class="govuk-heading-m">What happens next</h2><br />A task has been created to review your reply.'
+    }, true);
+
+    await waitForFinishedBusinessProcess(caseId);
+  },
+};
+
+const getLatestMessageToReplyTo = (caseData) => {
+  const messagesToReplyTo = caseData.messagesToReplyTo;
+  if (messagesToReplyTo && messagesToReplyTo.list_items && messagesToReplyTo.list_items.length > 0) {
+    const latestMessage = messagesToReplyTo.list_items[messagesToReplyTo.list_items.length - 1];
+    return {
+      code: latestMessage.code,
+      label: latestMessage.label
+    };
+  }
+  return null;
 };
 
 // Functions

e2e/api/steps_LRspecCui.js

@@ -41,6 +41,7 @@ const stayCase = require('../fixtures/events/stayCase');
 const manageStay = require('../fixtures/events/manageStay');
 const dismissCase = require('../fixtures/events/dismissCase');
 const { toJSON } = require('lodash/seq');
+const sendAndReplyMessage = require('../fixtures/events/sendAndReplyMessages');
 
 let caseId, eventName;
 let caseData = {};
@@ -72,7 +73,9 @@ const data = {
   STAY_CASE: () => stayCase.stayCaseSpec(),
   MANAGE_STAY_UPDATE: () => manageStay.manageStayRequestUpdate(),
   MANAGE_STAY_LIFT: () => manageStay.manageStayLiftStay(),
-  DISMISS_CASE: () => dismissCase.dismissCase()
+  DISMISS_CASE: () => dismissCase.dismissCase(),
+  SEND_MESSAGE: () => sendAndReplyMessage.sendMessageLr(),
+  REPLY_MESSAGE: (messageCode, messageLabel) => sendAndReplyMessage.replyMessageLr(messageCode, messageLabel)
 };
 
 const eventData = {
@@ -692,6 +695,60 @@ module.exports = {
 
     await waitForFinishedBusinessProcess(caseId);
   },
+
+  sendMessage: async (user) => {
+    console.log('Send message  case for case id ' + caseId);
+    await apiRequest.setupTokens(user);
+    eventName = 'SEND_AND_REPLY';
+
+    let returnedCaseData = await apiRequest.startEvent(eventName, caseId);
+    delete returnedCaseData['SearchCriteria'];
+    caseData = returnedCaseData;
+    let disposalData = data.SEND_MESSAGE();
+    for (let pageId of Object.keys(disposalData.userInput)) {
+      await assertValidData(disposalData, pageId);
+    }
+    await assertSubmittedEvent('CASE_STAYED', {
+      header: '# Your message has been sent',
+      body: '<br /><h2 class="govuk-heading-m">What happens next</h2><br />A task has been created to review your message'
+    }, true);
+
+    await waitForFinishedBusinessProcess(caseId);
+  },
+
+  replyMessage: async (user) => {
+    console.log('Send message  case for case id ' + caseId);
+    await apiRequest.setupTokens(user);
+    eventName = 'SEND_AND_REPLY';
+
+    let returnedCaseData = await apiRequest.startEvent(eventName, caseId);
+    delete returnedCaseData['SearchCriteria'];
+    caseData = returnedCaseData;
+
+    const latestMessage = getLatestMessageToReplyTo(caseData);
+    const disposalData = data.REPLY_MESSAGE(latestMessage.code, latestMessage.label);
+    for (let pageId of Object.keys(disposalData.userInput)) {
+      await assertValidData(disposalData, pageId);
+    }
+    await assertSubmittedEvent('CASE_STAYED', {
+      header: '# Reply sent',
+      body: '<br /><h2 class="govuk-heading-m">What happens next</h2><br />A task has been created to review your reply.'
+    }, true);
+
+    await waitForFinishedBusinessProcess(caseId);
+  },
+};
+
+const getLatestMessageToReplyTo = (caseData) => {
+  const messagesToReplyTo = caseData.messagesToReplyTo;
+  if (messagesToReplyTo && messagesToReplyTo.list_items && messagesToReplyTo.list_items.length > 0) {
+    const latestMessage = messagesToReplyTo.list_items[messagesToReplyTo.list_items.length - 1];
+    return {
+      code: latestMessage.code,
+      label: latestMessage.label
+    };
+  }
+  return null;
 };
 
 const validateEventPages = async (data, solicitor) => {

e2e/fixtures/events/sendAndReplyMessages.js

@@ -0,0 +1,110 @@
+module.exports = {
+  sendMessage: () => {
+    return {
+      valid: {
+        sendAndReplyOption: {
+          sendAndReplyOption: 'SEND'
+        },
+        sendMessageMetadata: {
+          sendMessageMetadata: {
+            recipientRoleType: 'DISTRICT_JUDGE',
+            isUrgent: 'No',
+            subjectType: 'APPLICATION',
+            subject: 'Test'
+          }
+        },
+        sendMessageContent: {
+          sendMessageContent: 'Test Message'
+        }
+    }
+    };
+  },
+  replyMessage: (messageCode, messageLabel) => {
+    return {
+      valid: {
+        sendAndReplyOption: {
+          sendAndReplyOption: 'REPLY',
+          messagesToReplyTo: {
+            value: {
+              code: messageCode,
+              label: messageLabel
+            },
+            list_items: [
+              {
+                code: messageCode,
+                label: messageLabel
+              }
+            ]
+          }
+        },
+        replyToMessage: {
+          messageReplyMetadata: {
+            recipientRoleType: 'ADMIN',
+            isUrgent: 'No',
+            messageContent: 'Test reply',
+            senderRoleType: null,
+            sentTime: null,
+            senderName: null,
+            subjectType: null,
+            subject: null
+          },
+          messageHistory: 'Test reply'
+        },
+      }
+    };
+  },
+  sendMessageLr: () => {
+    return {
+      userInput: {
+        sendAndReplyOption: {
+          sendAndReplyOption: 'SEND'
+        },
+        sendMessageMetadata: {
+          sendMessageMetadata: {
+            recipientRoleType: 'DISTRICT_JUDGE',
+            isUrgent: 'No',
+            subjectType: 'APPLICATION',
+            subject: 'Test'
+          }
+        },
+        sendMessageContent: {
+          sendMessageContent: 'Test Message'
+        }
+      }
+    };
+  },
+  replyMessageLr: (messageCode, messageLabel) => {
+    return {
+      userInput: {
+        sendAndReplyOption: {
+          sendAndReplyOption: 'REPLY',
+          messagesToReplyTo: {
+            value: {
+              code: messageCode,
+              label: messageLabel
+            },
+            list_items: [
+              {
+                code: messageCode,
+                label: messageLabel
+              }
+            ]
+          }
+        },
+        replyToMessage: {
+          messageReplyMetadata: {
+            recipientRoleType: 'ADMIN',
+            isUrgent: 'No',
+            messageContent: 'Test reply',
+            senderRoleType: null,
+            sentTime: null,
+            senderName: null,
+            subjectType: null,
+            subject: null
+          },
+          messageHistory: 'Test reply'
+        },
+      }
+    };
+  }
+};