feat(MED-85): run sending fake medipost results in dev from Medusa BO

app/api/job/send-medipost-test-response-for-order/route.ts

@@ -0,0 +1,57 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getAnalysisOrdersAdmin } from "~/lib/services/order.service";
+import { composeOrderTestResponseXML, sendPrivateMessageTestResponse } from "~/lib/services/medipostTest.service";
+import { retrieveOrder } from "@lib/data";
+import { getAccountAdmin } from "~/lib/services/account.service";
+import { getOrderedAnalysisElementsIds } from "~/lib/services/medipost.service";
+import loadEnv from "../handler/load-env";
+import validateApiKey from "../handler/validate-api-key";
+
+export async function POST(request: NextRequest) {
+  loadEnv();
+
+  try {
+    validateApiKey(request);
+  } catch (e) {
+    return NextResponse.json({}, { status: 401, statusText: 'Unauthorized' });
+  }
+  
+  const { order_id: medusaOrderId } = await request.json();
+  if (!medusaOrderId) {
+    return NextResponse.json({ error: 'order_id is required' }, { status: 400 });
+  }
+
+  const analysisOrders = await getAnalysisOrdersAdmin({ medusaOrderId });
+
+  console.error(`Sending test responses for ${analysisOrders.length} analysis orders`);
+  for (const medreportOrder of analysisOrders) {
+    const medusaOrderId = medreportOrder.medusa_order_id;
+    const medusaOrder = await retrieveOrder(medusaOrderId)
+
+    const account = await getAccountAdmin({ primaryOwnerUserId: medreportOrder.user_id });
+    const orderedAnalysisElementsIds = await getOrderedAnalysisElementsIds({ medusaOrder });
+
+    console.info(`Sending test response for order=${medusaOrderId} with ${orderedAnalysisElementsIds.length} ordered analysis elements`);
+    const idsToSend = orderedAnalysisElementsIds;
+    const messageXml = await composeOrderTestResponseXML({
+      person: {
+        idCode: account.personal_code!,
+        firstName: account.name ?? '',
+        lastName: account.last_name ?? '',
+        phone: account.phone ?? '',
+      },
+      orderedAnalysisElementsIds: idsToSend.map(({ analysisElementId }) => analysisElementId),
+      orderedAnalysesIds: [],
+      orderId: medusaOrderId,
+      orderCreatedAt: new Date(medreportOrder.created_at),
+    });
+
+    try {
+      await sendPrivateMessageTestResponse({ messageXml });
+    } catch (error) {
+      console.error("Error sending private message test response: ", error);
+    }
+  }
+
+  return NextResponse.json({ success: true });
+}

app/api/job/test-medipost-responses/route.ts

@@ -41,8 +41,6 @@ export async function POST(request: NextRequest) {
       orderCreatedAt: new Date(medreportOrder.created_at),
     });
 
-    console.info("SEND XML", messageXml);
-
     try {
       await sendPrivateMessageTestResponse({ messageXml });
     } catch (error) {

lib/services/order.service.ts

@@ -134,8 +134,10 @@ export async function getAnalysisOrders({
 
 export async function getAnalysisOrdersAdmin({
   orderStatus,
+  medusaOrderId,
 }: {
   orderStatus?: Tables<{ schema: 'medreport' }, 'analysis_orders'>['status'];
+  medusaOrderId?: string | null;
 } = {}) {
   const query = getSupabaseServerAdminClient()
     .schema('medreport')
@@ -144,6 +146,9 @@ export async function getAnalysisOrdersAdmin({
   if (orderStatus) {
     query.eq('status', orderStatus);
   }
+  if (medusaOrderId) {
+    query.eq('medusa_order_id', medusaOrderId);
+  }
   const orders = await query.order('created_at', { ascending: false }).throwOnError();
   return orders.data;
 }

packages/supabase/src/database.types.ts

@@ -2074,6 +2074,11 @@ export type Database = {
       }
       sync_analysis_results: {
       }
+      send_medipost_test_response_for_order: {
+        Args: {
+          order_id: string
+        }
+      }
     }
     Enums: {
       analysis_feedback_status: "STARTED" | "DRAFT" | "COMPLETED"

supabase/migrations-env-specific/20250827090151_bo_run_results_sync.sql

@@ -12,3 +12,5 @@ BEGIN
   ) as request_id;
 END;
 $$;
+
+grant execute on function medreport.sync_analysis_results() to service_role;

supabase/migrations-env-specific/20250827090152_bo_run_dev_fake_results_sync.sql

@@ -0,0 +1,20 @@
+-- Parameters order_id
+CREATE OR REPLACE FUNCTION medreport.send_medipost_test_response_for_order(order_id text)
+RETURNS void
+LANGUAGE plpgsql
+AS $$
+BEGIN
+  select net.http_post(
+    url := 'https://test.medreport.ee/api/job/send-medipost-test-response-for-order',
+    headers := jsonb_build_object(
+      'Content-Type', 'application/json',
+      'x-jobs-api-key', 'fd26ec26-70ed-11f0-9e95-431ac3b15a84'
+    ),
+    body := jsonb_build_object(
+      'order_id', order_id
+    )
+  ) as request_id;
+END;
+$$;
+
+grant execute on function medreport.send_medipost_test_response_for_order(text) to service_role;