Ed 3835 lookback (#27)

* adding chain sync service

* adding ws transport to viem
commenting out alchemy and sign module co-dependencies
commenting out atomic nonces
moving BalanceService token loading to onApplicationBootstrap

* getting the ChainSync service to work
refactored websocket inetent service to use viem subscription on websocket connection instead of the ethers alchemy ws
adding provers array to the sourceIntents config
modifying everywhere we handle addresses to use viems getAddress instead of toLowercase

* adding tests for chain sync service
updating the abi contracts

* add prover to intent

config/development.ts

@@ -42,6 +42,7 @@ export default {
         '0xd3F4Bef596a04e2be4fbeB17Dd70f02F717c5a6c',
         '0x93551e3F61F8E3EE73DDc096BddbC1ADc52f5A3a',
       ],
+      provers: ['0x99b07fF401E2c73826f3043AdaB2ef37e53d4f23'],
     },
   ],
   solvers: {

src/alchemy/aa-smart-multichain-client.ts

@@ -4,12 +4,12 @@ import {
   SmartAccountClient,
   SmartAccountClientConfig,
 } from '@alchemy/aa-core'
-import { extractChain, http } from 'viem'
+import { extractChain } from 'viem'
 import { EcoError } from '../common/errors/eco-error'
 import { ChainsSupported } from '../common/utils/chains'
 import { createMultiOwnerModularAccount } from '@alchemy/aa-accounts'
-import { getAchemyRPCUrl } from '../common/utils/strings'
 import { AAMultiChainConfig } from './aa-smart-multichain.service'
+import { getTransport } from './utils'
 
 export class AASmartMultichainClient {
   readonly configs: AAMultiChainConfig
@@ -42,7 +42,7 @@ export class AASmartMultichainClient {
 
     // const c = Object.values(aaChains)[0]
     if (this.configs && this.configs.ids.includes(chainID) && chain) {
-      const rpcTransport = http(getAchemyRPCUrl(chain, this.configs.apiKey))
+      const rpcTransport = getTransport(chain, this.configs.apiKey, true)
       return {
         transport: rpcTransport as any,
         chain: chain,

src/alchemy/alchemy.module.ts

@@ -1,12 +1,12 @@
-import { forwardRef, Module } from '@nestjs/common'
+import { Module } from '@nestjs/common'
 import { EcoConfigModule } from '../eco-configs/eco-config.module'
 import { AlchemyService } from './alchemy.service'
 import { SignModule } from '../sign/sign.module'
 import { MultichainSmartAccountService } from './multichain_smart_account.service'
 import { MultichainPublicClientService } from './multichain-public-client.service'
 
 @Module({
-  imports: [EcoConfigModule, forwardRef(() => SignModule)],
+  imports: [EcoConfigModule, SignModule],
 
   providers: [
     AlchemyService,

src/alchemy/multichain-atomic-smart-account.service.ts

@@ -7,11 +7,10 @@ import {
   SmartAccountClientConfig,
 } from '@alchemy/aa-core'
 import { ViemMultichainClientService } from './viem_multichain_client.service'
-import { http } from 'viem'
-import { getAchemyRPCUrl } from '../common/utils/strings'
 import { createMultiOwnerModularAccount } from '@alchemy/aa-accounts'
 import { EcoConfigService } from '../eco-configs/eco-config.service'
 import { AtomicSignerService } from '../sign/atomic-signer.service'
+import { getTransport } from './utils'
 
 @Injectable()
 export class MultichainAtomicSmartAccountService extends ViemMultichainClientService<
@@ -34,7 +33,7 @@ export class MultichainAtomicSmartAccountService extends ViemMultichainClientSer
   protected override async buildChainConfig(
     chain: chains.Chain,
   ): Promise<SmartAccountClientConfig> {
-    const rpcTransport = http(getAchemyRPCUrl(chain, this.apiKey))
+    const rpcTransport = getTransport(chain, this.apiKey, true)
     return {
       transport: rpcTransport as any,
       chain: chain,

src/alchemy/multichain_smart_account.service.ts

@@ -7,11 +7,10 @@ import {
   SmartAccountClientConfig,
 } from '@alchemy/aa-core'
 import { ViemMultichainClientService } from './viem_multichain_client.service'
-import { http } from 'viem'
-import { getAchemyRPCUrl } from '../common/utils/strings'
 import { createMultiOwnerModularAccount } from '@alchemy/aa-accounts'
 import { EcoConfigService } from '../eco-configs/eco-config.service'
 import { SignerService } from '../sign/signer.service'
+import { getTransport } from './utils'
 
 @Injectable()
 export class MultichainSmartAccountService extends ViemMultichainClientService<
@@ -38,7 +37,7 @@ export class MultichainSmartAccountService extends ViemMultichainClientService<
   protected override async buildChainConfig(
     chain: chains.Chain,
   ): Promise<SmartAccountClientConfig> {
-    const rpcTransport = http(getAchemyRPCUrl(chain, this.apiKey))
+    const rpcTransport = getTransport(chain, this.apiKey, true)
     return {
       transport: rpcTransport as any,
       chain: chain,

src/alchemy/utils.ts

@@ -0,0 +1,37 @@
+import { chains } from '@alchemy/aa-core'
+import { http, HttpTransport, webSocket, WebSocketTransport } from 'viem'
+
+/**
+ * Merges the two strings into a valid api url
+ * @param rpc the rpc endpoint
+ * @param apiKey the alchemy api key
+ * @returns
+ */
+export function getAchemyRPCUrl(
+  chain: chains.Chain,
+  apiKey: string,
+  websocketEnabled: boolean = true,
+): string {
+  const url =
+    websocketEnabled && chain.rpcUrls.alchemy.webSocket
+      ? chain.rpcUrls.alchemy.webSocket[0]
+      : chain.rpcUrls.alchemy.http[0]
+  return url + '/' + apiKey
+}
+
+/**
+ * Returns a transport for the chain with the given api key
+ *
+ * @param chain the chain to get the transport for
+ * @param apiKey the alchemy api key
+ * @param websocketEnabled whether to use websocket or not, defaults to true
+ * @returns the websocket or http transport
+ */
+export function getTransport(
+  chain: chains.Chain,
+  apiKey: string,
+  websocketEnabled: boolean = true,
+): WebSocketTransport | HttpTransport {
+  const url = getAchemyRPCUrl(chain, apiKey, websocketEnabled)
+  return websocketEnabled ? webSocket(url) : http(url)
+}

src/alchemy/viem_multichain_client.service.ts

@@ -1,10 +1,10 @@
 import { Injectable, OnModuleInit } from '@nestjs/common'
 import { EcoConfigService } from '../eco-configs/eco-config.service'
 import { chains } from '@alchemy/aa-core'
-import { createClient, extractChain, http } from 'viem'
+import { createClient, extractChain } from 'viem'
 import { EcoError } from '../common/errors/eco-error'
 import { ChainsSupported } from '../common/utils/chains'
-import { getAchemyRPCUrl } from '../common/utils/strings'
+import { getTransport } from './utils'
 
 @Injectable()
 export class ViemMultichainClientService<T, V> implements OnModuleInit {
@@ -70,7 +70,7 @@ export class ViemMultichainClientService<T, V> implements OnModuleInit {
   }
 
   protected async buildChainConfig(chain: chains.Chain): Promise<V> {
-    const rpcTransport = http(getAchemyRPCUrl(chain, this.apiKey))
+    const rpcTransport = getTransport(chain, this.apiKey, true)
     return {
       transport: rpcTransport,
       chain: chain,