feat: init soap obiz client in trpc context and begin order router

webapp/package.json

@@ -39,6 +39,7 @@
     "@trpc/react-query": "^10.44.1",
     "@trpc/server": "^10.44.1",
     "aws-crt": "^1.20.1",
+    "axios": "^1.7.7",
     "bowser": "^2.11.0",
     "cookies-next": "^4.1.0",
     "crisp-sdk-web": "^1.0.21",
@@ -64,6 +65,7 @@
     "react-qrcode-logo": "^2.9.0",
     "react-toastify": "^10.0.5",
     "sharp": "^0.33.2",
+    "soap": "^1.1.6",
     "superjson": "^1.13.3",
     "tsx": "^4.7.0",
     "usehooks-ts": "^2.14.0",

webapp/src/server/api/root.ts

@@ -12,6 +12,7 @@ import { tagRouter } from "./routers/tag";
 import { searchRequestRouter } from "./routers/searchRequest";
 import { emailAuthTokenRouter } from "./routers/emailAuthToken";
 import { widgetRouter } from "./routers/widget";
+import { orderRouter } from "./routers/order";
 
 /**
  * This is the primary router for your server.
@@ -31,6 +32,7 @@ export const appRouter = createTRPCRouter({
   searchRequest: searchRequestRouter,
   emailAuthToken: emailAuthTokenRouter,
   widget: widgetRouter,
+  order: orderRouter,
 });
 
 // export type definition of API

webapp/src/server/api/routers/order.ts

@@ -0,0 +1,11 @@
+import { createTRPCRouter, userProtectedProcedure } from "~/server/api/trpc";
+
+export const orderRouter = createTRPCRouter({
+  createOrder: userProtectedProcedure.query(async ({ ctx }) => {
+    // const [test] = await ctx.soapObizClient.ETAT_SITEAsync();
+
+    // console.log(JSON.stringify(test, null, 2));
+
+    return { data: "Hello" };
+  }),
+});

webapp/src/server/api/trpc.ts

@@ -17,6 +17,8 @@ import jwt from "jsonwebtoken";
 import { Payload } from "payload";
 import { NextApiRequest } from "next";
 import { ZWidgetToken } from "../types";
+var soap = require("soap");
+import { obiz_soap_client_options, obiz_soap_client_url } from "../soap-obiz";
 
 export type PayloadJwtSession = {
   id: number;
@@ -66,13 +68,19 @@ export const createTRPCContext = async (_opts: CreateNextContextOptions) => {
     seed: false,
   });
 
+  var soapObizClient = await soap.createClientAsync(
+    obiz_soap_client_url,
+    obiz_soap_client_options
+  );
+
   const jwtCookie =
     _opts.req.cookies[process.env.NEXT_PUBLIC_JWT_NAME ?? "cje-jwt"];
 
   if (!jwtCookie) {
     return {
       payload,
       session: null,
+      soapObizClient,
       req: _opts.req,
     };
   }
@@ -82,6 +90,7 @@ export const createTRPCContext = async (_opts: CreateNextContextOptions) => {
   return {
     payload,
     session,
+    soapObizClient,
     req: _opts.req,
   };
 };

webapp/src/server/soap-obiz.ts

@@ -0,0 +1,51 @@
+import { IOptions } from "soap";
+
+export const obiz_soap_client_url =
+  "https://webservices-test.reducce.fr/Partenaire.svc?wsdl";
+
+function parseMultipartResponse(data: string) {
+  // Find the XML content between the MIME boundaries
+  const xmlMatch = data.match(/<s:Envelope[\s\S]*?<\/s:Envelope>/);
+  if (xmlMatch) {
+    return xmlMatch[0];
+  }
+  throw new Error("No SOAP envelope found in response");
+}
+
+export const obiz_soap_client_options: IOptions = {
+  forceSoap12Headers: false,
+  endpoint: "https://webservices-test.reducce.fr/Partenaire.svc/Partenaire.svc",
+  httpClient: {
+    request: function (
+      url: string,
+      data: string,
+      callback: any,
+      exheaders: any
+    ): any {
+      const headers = {
+        "Content-Type": "text/xml;charset=utf-8",
+        Accept: "multipart/related,text/xml",
+        ...exheaders,
+      };
+
+      const options = {
+        url: url,
+        method: data ? "POST" : "GET",
+        headers: headers,
+        data: data,
+        responseType: "text",
+      };
+
+      require("axios")(options)
+        .then((response: any) => {
+          if (response.headers["content-type"]?.includes("multipart/related")) {
+            // Parse multipart response to get just the SOAP envelope
+            const xmlContent = parseMultipartResponse(response.data);
+            response.data = xmlContent;
+          }
+          callback(null, response, response.data);
+        })
+        .catch((error: any) => callback(error));
+    },
+  },
+};