Experiment/session bundler url

packages/sign-client/src/controllers/engine.ts

@@ -452,8 +452,19 @@
       this.client.logger.error("request() -> isValidRequest() failed");
       throw error;
     }
+
     const { chainId, request, topic, expiry = ENGINE_RPC_OPTS.wc_sessionRequest.req.ttl } = params;
+
     const session = this.client.session.get(topic);
+
+    console.log(">>>> checking to intercept", {params, sessionProps: session.sessionProperties})
+    const intercepted = await this.interceptRequestIfConfigured(params, session.sessionProperties ?? {})
+    console.log(">>>> intercept", {intercepted})
+
+    if(intercepted) {
+      return intercepted
+    }
+
     const clientRpcId = payloadId();
     const relayRpcId = getBigIntRpcId().toString() as any;
     const { done, resolve, reject } = createDelayedPromise<T>(
@@ -1030,6 +1041,44 @@
 
   // ---------- Private Helpers --------------------------------------- //
 
+  private interceptGetCallsStatus = async (request: EngineTypes.RequestParams, sessionProperties: ProposalTypes.SessionProperties) => {
+    const bundlerUrl = sessionProperties.bundler_url;
+
+    const response = await fetch(bundlerUrl, {
+      method: "POST",
+      headers: {
+        "Content-Type": "application/json",
+      },
+      body: JSON.stringify(formatJsonRpcRequest("eth_getUserOperationReceipt", [request.request.params[0]]))
+    })
+
+    const json = await response.json()
+
+    console.log(">>>>", {json})
+
+    return json;
+  }
+
+  private interceptRequestIfConfigured = async (request: EngineTypes.RequestParams, sessionProperties: ProposalTypes.SessionProperties) => {
+    const interceptableMethods = []
+    const interceptionMethods = {
+      ["wallet_getCallsStatus"]: this.interceptGetCallsStatus 
+    } as const;
+
+    if(Object.keys(sessionProperties).includes("bundler_url")) {
+      interceptableMethods.push("wallet_getCallsStatus")
+    }
+
+    console.log(">>>>", { interceptableMethods, method: request.request.method  })
+
+    if(interceptableMethods.includes(request.request.method)) {
+      return interceptionMethods[request.request.method](request, sessionProperties)
+    }
+
+    return null;
+  }
+
+
   private cleanupDuplicatePairings: EnginePrivate["cleanupDuplicatePairings"] = async (
     session: SessionTypes.Struct,
   ) => {