import { RpcRequest, RpcResponse } from 'ox'; import { fallback, http, HttpTransport, Transport } from 'viem'; import { arbitrum, base, degen, gnosis, mainnet, optimism, polygon, zora } from 'viem/chains'; import { ALCHEMY_FRONTEND_API_KEY } from '~/env'; import { BadRequestError } from '~/errors'; import { isSupportedWalletChainId, SUPPORTED_WALLET_CHAINS, WalletChainId } from '~/eth'; import { Service } from '~/services'; const chainIdAlchemyNetworkMap: Record = { [arbitrum.id]: 'arb-mainnet', [base.id]: 'base-mainnet', [optimism.id]: 'opt-mainnet', [degen.id]: 'degen-mainnet', [mainnet.id]: 'eth-mainnet', [gnosis.id]: 'gnosis-mainnet', [polygon.id]: 'polygon-mainnet', [zora.id]: 'zora-mainnet', }; const chainIdQuickNodeNetworkMap: Record, string | null> = { [arbitrum.id]: 'arb-mainnet', [base.id]: 'base-mainnet', [optimism.id]: 'optimism', [mainnet.id]: 'eth-mainnet', [gnosis.id]: 'gnosis-mainnet', [polygon.id]: 'polygon-mainnet', [zora.id]: 'zora-mainnet', }; const rpcClients = SUPPORTED_WALLET_CHAINS.reduce>>( (acc, chain) => { const chainTransports: HttpTransport[] = []; const quickNodeNetwork = (chainIdQuickNodeNetworkMap as Record)[chain.id]; if (quickNodeNetwork) { chainTransports.push( http(`https://not-gunna-work.${quickNodeNetwork}.quiknode.pro`, { key: 'quicknode', }) ); } const alchemyNetwork = chainIdAlchemyNetworkMap[chain.id]; if (alchemyNetwork) { chainTransports.push( http(`https://${alchemyNetwork}.g.alchemy.com/v2`, { key: 'alchemy', fetchOptions: { headers: { Authorization: 'Bearer ' + ALCHEMY_FRONTEND_API_KEY, }, }, }) ); } return { ...acc, [chain.id]: fallback(chainTransports, { rank: false, // always prefer quicknode unless it's not responding })({ chain }), }; }, {} as Record> ); export class EthRpcProxyService extends Service.Provider { public static post({ chainId, body }: { chainId: number; body: any }): Service.Result { return this.result(async () => { if (!isSupportedWalletChainId(chainId)) { return new BadRequestError(`Chain ${chainId} is not supported`); } const rpcClient = rpcClients[chainId]; const request = RpcRequest.from(body); const result = await rpcClient.request({ method: request.method, params: request.params, }); // TODO return errors as responses instead of throwing return RpcResponse.from({ result }, { request }); }); } }