feat(MED-131): send to medipost on montonio callback

lib/services/medipost.service.ts

@@ -41,12 +41,19 @@ import { getAnalysisElementsAdmin } from './analysis-element.service';
 import { getAnalyses } from './analyses.service';
 import { retrieveOrder } from '@lib/data/orders';
 import { getAccountAdmin } from './account.service';
+import { StoreProduct } from '@medusajs/types';
+import { listProducts } from '@lib/data/products';
+import { listRegions } from '@lib/data/regions';
+import { getAnalysisElementMedusaProductIds } from '@/utils/medusa-product';
 
 const BASE_URL = process.env.MEDIPOST_URL!;
 const USER = process.env.MEDIPOST_USER!;
 const PASSWORD = process.env.MEDIPOST_PASSWORD!;
 const RECIPIENT = process.env.MEDIPOST_RECIPIENT!;
 
+const ANALYSIS_ELEMENT_HANDLE_PREFIX = 'analysis-element-';
+const ANALYSIS_PACKAGE_HANDLE_PREFIX = 'analysis-package-';
+
 function parseXML(xml: string) {
   const parser = new XMLParser({ ignoreAttributes: false });
   return parser.parse(xml);
@@ -630,16 +637,46 @@ export async function sendOrderToMedipost({
 }: {
   medusaOrderId: string;
 }) {
-  const medusaOrder = await retrieveOrder(medusaOrderId)
-  const medreportOrder = await getOrder({ medusaOrderId });
-
+  const [medusaOrder, medreportOrder, countryCodes] = await Promise.all([
+    retrieveOrder(medusaOrderId),
+    getOrder({ medusaOrderId }),
+    listRegions(),
+  ]);
+  const countryCode = countryCodes[0]!.countries![0]!.iso_2!;
   const account = await getAccountAdmin({ primaryOwnerUserId: medreportOrder.user_id });
+  
+  let analysisPackageElements: StoreProduct[] = [];
+  const orderedAnalysisPackages = (medusaOrder?.items ?? []).filter(({ product }) => product?.handle.startsWith(ANALYSIS_PACKAGE_HANDLE_PREFIX));
+  const orderedAnalysisElements = (medusaOrder?.items ?? []).filter(({ product }) => product?.handle.startsWith(ANALYSIS_ELEMENT_HANDLE_PREFIX));
 
-  const ANALYSIS_ELEMENT_HANDLE_PREFIX = 'analysis-element-';
-  const orderedAnalysisElementsIds = (medusaOrder?.items ?? [])
-    .filter((item) => item.product?.handle?.startsWith(ANALYSIS_ELEMENT_HANDLE_PREFIX))
-    .map((item) => {
-      const id = Number(item.product?.handle?.replace(ANALYSIS_ELEMENT_HANDLE_PREFIX, ''));
+  if (orderedAnalysisPackages.length > 0) {
+    const { response: { products: analysisPackages } } = await listProducts({
+      countryCode,
+      queryParams: { limit: 100, "type_id[0]": orderedAnalysisPackages[0]!.product_type_id! },
+    });
+    const analysisElementMedusaProductIds = getAnalysisElementMedusaProductIds(analysisPackages);
+    const { response: { products } } = await listProducts({
+      countryCode,
+      queryParams: {
+        id: analysisElementMedusaProductIds,
+        limit: 100,
+      },
+    });
+    analysisPackageElements = products;
+  }
+
+  const analysisPackageElementsIds = analysisPackageElements
+    .map((product) => {
+      const id = Number(product?.metadata?.analysisIdOriginal);
+      if (Number.isNaN(id)) {
+        return null;
+      }
+      return id;
+    })
+    .filter(Boolean) as number[];
+  const orderedAnalysisElementsIds = orderedAnalysisElements
+    .map((line) => {
+      const id = Number(line.product?.handle?.replace(ANALYSIS_ELEMENT_HANDLE_PREFIX, ''));
       if (Number.isNaN(id)) {
         return null;
       }
@@ -653,7 +690,7 @@ export async function sendOrderToMedipost({
       lastName: account.last_name ?? '',
       phone: account.phone ?? '',
     },
-    orderedAnalysisElementsIds,
+    orderedAnalysisElementsIds: [...analysisPackageElementsIds, ...orderedAnalysisElementsIds],
     orderedAnalysesIds: [],
     orderId: medusaOrderId,
     orderCreatedAt: new Date(medreportOrder.created_at),