Print specific message if CORE row isn't found

.github/workflows/pr.yml

@@ -12,7 +12,7 @@
 ##
 ## 4) Edit the ## REPOSITORY SPECIFIC ## section below.
 
-name: Terraform Plan
+name: PR Checks
 on:
   pull_request:
     branches: [ main ]
@@ -42,7 +42,7 @@ jobs:
     strategy:
       matrix:
         environment: [dev, test, pre-prod, prod]
-    name: ${{ matrix.environment }}
+    name: Terraform Plan (${{ matrix.environment }})
     runs-on: ubuntu-latest
     environment: ${{ matrix.environment }}
     defaults:

src/api/patients/patient-details-controller.js

@@ -6,7 +6,7 @@ import {
   getCurrentConversationIdForPatient,
   getMessageIdsForConversation
 } from '../../services/database/ehr-conversation-repository';
-import { HealthRecordNotFoundError } from '../../errors/errors';
+import { HealthRecordNotFoundError, CoreNotFoundError } from '../../errors/errors';
 
 export const patientDetailsValidation = [
   param('nhsNumber')
@@ -52,6 +52,12 @@ export const patientDetailsController = async (req, res) => {
       return;
     }
 
+    if (err instanceof CoreNotFoundError) {
+      logInfo('Did not find a core message');
+      res.sendStatus(503);
+      return;
+    }
+
     logError('Could not retrieve patient health record', err);
     res.sendStatus(503);
   }

src/errors/errors.js

@@ -12,7 +12,7 @@ export class HealthRecordNotFoundError extends Error {
   }
 }
 
-export class MessageNotFoundError extends Error {
+export class CoreNotFoundError extends Error {
   constructor(error) {
     super(errorMessages.MessageNotFound);
     logError(errorMessages.MessageNotFound, error);

src/services/database/__tests__/ehr-conversation-repository.integration.test.js

@@ -17,7 +17,7 @@ import {
 import { createCore } from '../ehr-core-repository';
 import { EhrTransferTracker } from '../dynamo-ehr-transfer-tracker';
 import { markFragmentAsReceivedAndCreateItsParts } from '../ehr-fragment-repository';
-import { HealthRecordNotFoundError, MessageNotFoundError } from '../../../errors/errors';
+import { HealthRecordNotFoundError, CoreNotFoundError } from '../../../errors/errors';
 import moment from 'moment-timezone';
 
 jest.mock('../../../middleware/logging');
@@ -247,7 +247,7 @@ describe('ehr-conversation-repository', () => {
       // when
       await expect(() => getMessageIdsForConversation(conversationId))
         // then
-        .rejects.toThrowError(MessageNotFoundError);
+        .rejects.toThrowError(CoreNotFoundError);
     });
 
     it('should return health record extract message id given a conversation id for a small health record', async () => {

src/services/database/ehr-conversation-repository.js

@@ -2,7 +2,7 @@ import { ConversationStatus, HealthRecordStatus, RecordType } from '../../models
 import { logError, logInfo } from '../../middleware/logging';
 import { EhrTransferTracker } from './dynamo-ehr-transfer-tracker';
 import { buildConversationUpdateParams, isInCompleteStatus } from '../../models/conversation';
-import { HealthRecordNotFoundError, MessageNotFoundError } from '../../errors/errors';
+import { HealthRecordNotFoundError, CoreNotFoundError } from '../../errors/errors';
 import { isCore } from '../../models/core';
 import { isFragment } from '../../models/fragment';
 import { buildSoftDeleteUpdateParams } from '../../utilities/dynamodb-helper';
@@ -125,7 +125,7 @@ export const getMessageIdsForConversation = async (conversationId) => {
   const fragments = items.filter(isFragment);
 
   if (!core) {
-    throw new MessageNotFoundError();
+    throw new CoreNotFoundError();
   }
   const coreMessageId = core.InboundMessageId;
   const fragmentMessageIds = fragments.map((message) => message.InboundMessageId);