feat(MED-161): create analysis-order service

lib/services/analysis-order.service.ts

@@ -0,0 +1,17 @@
+import { getSupabaseServerAdminClient } from "@/packages/supabase/src/clients/server-admin-client";
+import type { AnalysisResponseElement } from "../types/analysis-response-element";
+
+export async function getExistingAnalysisResponseElements({
+  analysisResponseId,
+}: {
+  analysisResponseId: number;
+}) {
+  const { data } = await getSupabaseServerAdminClient()
+    .schema('medreport')
+    .from('analysis_response_elements')
+    .select('*')
+    .eq('analysis_response_id', analysisResponseId)
+    .throwOnError();
+
+  return data as AnalysisResponseElement[];
+}

lib/services/medipost/medipostPrivateMessage.service.ts

@@ -22,6 +22,7 @@ import { composeOrderXML, OrderedAnalysisElement } from './medipostXML.service';
 import { getAccountAdmin } from '../account.service';
 import { logMedipostDispatch } from '../audit.service';
 import { MedipostValidationError } from './MedipostValidationError';
+import { getExistingAnalysisResponseElements } from '../analysis-order.service';
 
 const BASE_URL = process.env.MEDIPOST_URL!;
 const USER = process.env.MEDIPOST_USER!;
@@ -152,14 +153,9 @@ export async function syncPrivateMessage({
     );
   }
 
-  const { data: allOrderResponseElements } = await supabase
-    .schema('medreport')
-    .from('analysis_response_elements')
-    .select('*')
-    .eq('analysis_response_id', analysisResponseId)
-    .throwOnError();
+  const existingAnalysisResponseElements = await getExistingAnalysisResponseElements({ analysisResponseId });
   const expectedOrderResponseElements = order.analysis_element_ids?.length ?? 0;
-  if (allOrderResponseElements.length !== expectedOrderResponseElements) {
+  if (existingAnalysisResponseElements.length !== expectedOrderResponseElements) {
     return { isPartial: true };
   }
 

lib/types/analysis-response-element.ts

@@ -0,0 +1,3 @@
+import type { Database } from "@/packages/supabase/src/database.types";
+
+export type AnalysisResponseElement = Database['medreport']['Tables']['analysis_response_elements']['Row'];