feat: added alto transport

Author: dhvanipa

packages/common/src/exports/internal.ts

@@ -5,4 +5,5 @@ export * from "../deploy/ensureDeployer";
 export * from "../deploy/getContractAddress";
 export * from "../deploy/getDeployer";
 export * from "../transports/wiresaw";
+export * from "../transports/alto";
 export * from "../transports/methods/getUserOperationReceipt";

packages/common/src/transports/alto.ts

@@ -0,0 +1,56 @@
+import { Chain, EIP1193RequestFn, Hex, http, Transport } from "viem";
+import { chainTransport } from "./chainTransport";
+
+type AltoSendUserOperationResultuest = {
+  txHash: Hex;
+  userOpHash: Hex;
+};
+
+type AltoOptions<transport extends Transport> = {
+  /** alto-compatible transport */
+  altoTransport: transport;
+  /** fallback transport for all other RPC methods */
+  fallbackDefaultTransport?: Transport;
+};
+
+export function alto<const altoTransport extends Transport>(transports?: AltoOptions<altoTransport>): altoTransport {
+  return ((opts) => {
+    const { altoTransport } = transports ?? getDefaultTransports(opts.chain);
+
+    const { request: altoRequest, ...rest } = altoTransport(opts);
+
+    return {
+      ...rest,
+      // TODO: type `request` so we don't have to cast
+      async request(req): ReturnType<EIP1193RequestFn> {
+        if (req.method === "eth_sendUserOperation") {
+          console.log("sending user operation via pimlico_sendUserOperationNow", req);
+          const result = (await altoRequest({
+            ...req,
+            method: "pimlico_sendUserOperationNow",
+          })) as AltoSendUserOperationResultuest;
+          console.log("pimlico_sendUserOperationNow", result);
+          return result;
+        }
+
+        return await altoRequest(req);
+      },
+    };
+  }) as altoTransport;
+}
+
+function getDefaultTransports(chain?: Chain): AltoOptions<Transport> {
+  if (!chain) {
+    throw new Error("No chain or transports provided");
+  }
+
+  const altoTransport = chainTransport(chain.rpcUrls.alto);
+  if (!altoTransport) {
+    throw new Error("Provided chain does not support alto");
+  }
+
+  return {
+    altoTransport,
+    fallbackDefaultTransport: http(),
+  };
+}

packages/entrykit/src/getBundlerTransport.ts

@@ -2,12 +2,15 @@ import { transactionQueue } from "@latticexyz/common/actions";
 import { Chain, createClient, fallback, http, keccak256, stringToHex, webSocket } from "viem";
 import { privateKeyToAccount } from "viem/accounts";
 import { userOpExecutor } from "./quarry/transports/userOpExecutor";
-import { wiresaw } from "@latticexyz/common/internal";
+import { wiresaw, alto } from "@latticexyz/common/internal";
 
 export function getBundlerTransport(chain: Chain) {
   if ("wiresaw" in chain.rpcUrls) {
     return wiresaw();
   }
+  if ("alto" in chain.rpcUrls) {
+    return alto();
+  }
 
   // TODO: bundler websocket
   const bundlerHttpUrl = chain.rpcUrls.bundler?.http[0];