[SKIP CI] Merge pull request #609 from subquery/feat/add-solana

feat: integrate solana rpc
subquery · Feb 24, 2025 · 0c74b1b · 0c74b1b
2 parents 57e6218 + ca80747
commit 0c74b1b
Show file tree

Hide file tree

Showing 5 changed files with 168 additions and 3 deletions.
diff --git a/apps/indexer-admin/src/pages/project-details/components/rpcSetting.tsx b/apps/indexer-admin/src/pages/project-details/components/rpcSetting.tsx
@@ -221,6 +221,7 @@ const RpcSetting: FC<IProps> = (props) => {
       polkadot: polkadotAndSubstrateRule,
       substrate: polkadotAndSubstrateRule,
       subql_dict: evmAndDataNodeRule,
+      solana: evmAndDataNodeRule,
     };
   }, [form, keys.data?.getRpcEndpointKeys]);
 

diff --git a/apps/indexer-coordinator/package.json b/apps/indexer-coordinator/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@subql/indexer-coordinator",
-  "version": "2.8.4",
+  "version": "2.9.0",
   "description": "",
   "author": "SubQuery",
   "license": "Apache-2.0",

diff --git a/apps/indexer-coordinator/src/project/project.rpc.service.ts b/apps/indexer-coordinator/src/project/project.rpc.service.ts
@@ -264,6 +264,7 @@ export class ProjectRpcService implements OnModuleInit {
         .withClientNameAndVersion(projectManifest.client?.name, projectManifest.client?.version)
         .withBlockFitlerCapability()
         .withFilteredBlocks()
+        .withHealth()
         .validate(endpoint, endpointKey as RpcEndpointType);
       return this.formatResponse(true);
     } catch (e) {
@@ -403,7 +404,7 @@ export class ProjectRpcService implements OnModuleInit {
         targetHeight = (await family.getTargetHeight(endpoint.value)) || lastHeight;
       }
     } catch (e) {
-      logger.debug(`getRpcMetadata error: ${e}`);
+      logger.debug(`getRpcMetadata error ${id}: ${e}`);
     }
     return {
       startHeight,

diff --git a/apps/indexer-coordinator/src/project/rpc.factory.ts b/apps/indexer-coordinator/src/project/rpc.factory.ts
@@ -28,6 +28,9 @@ export function getRpcFamilyObject(rpcFamily: string): IRpcFamily | undefined {
     case 'subql_dict':
       family = new RpcFamilySubqlDict();
       break;
+    case 'solana':
+      family = new RpcFamilySolana();
+      break;
     default:
       break;
   }
@@ -60,7 +63,7 @@ function jsonRpcRequest(endpoint: string, method: string, params: any[]): Promis
       headers: {
         'Content-Type': 'application/json',
       },
-      timeout: 10000,
+      timeout: 30000,
     }
   );
 }
@@ -161,6 +164,7 @@ export interface IRpcFamily {
   withHeight(height?: number): IRpcFamily;
   withBlockFitlerCapability(): IRpcFamily;
   withFilteredBlocks(): IRpcFamily;
+  withHealth(): IRpcFamily;
   validate(endpoint: string, endpointKey: string): Promise<void>;
   getStartHeight(endpoint: string): Promise<number>;
   getTargetHeight(endpoint: string): Promise<number>;
@@ -210,6 +214,9 @@ abstract class RpcFamily implements IRpcFamily {
   withFilteredBlocks(): IRpcFamily {
     throw new Error('Method not implemented.');
   }
+  withHealth(): IRpcFamily {
+    throw new Error('Method not implemented.');
+  }
   getStartHeight(endpoint: string): Promise<number> {
     throw new Error('Method not implemented.');
   }
@@ -447,6 +454,10 @@ export class RpcFamilyEvm extends RpcFamily {
     return this;
   }
 
+  withHealth(): IRpcFamily {
+    return this;
+  }
+
   async getStartHeight(endpoint: string): Promise<number> {
     const result = await getRpcRequestFunction(endpoint)(endpoint, 'eth_syncing', []);
     if (result.data.error) {
@@ -694,6 +705,10 @@ export class RpcFamilySubstrate extends RpcFamily {
     return this;
   }
 
+  withHealth(): IRpcFamily {
+    return this;
+  }
+
   async getStartHeight(endpoint: string): Promise<number> {
     if (this.startHeight) {
       return Promise.resolve(this.startHeight);
@@ -790,3 +805,146 @@ export class RpcFamilyPolkadot extends RpcFamilySubstrate {
     return '';
   }
 }
+
+export class RpcFamilySolana extends RpcFamily {
+  getEndpointKeys(): string[] {
+    return [
+      RpcEndpointType.solanaWs,
+      RpcEndpointType.solanaHttp,
+      RpcEndpointType.solanaMetricsHttp,
+    ];
+  }
+
+  get ws() {
+    return RpcEndpointType.solanaWs;
+  }
+  get http() {
+    return RpcEndpointType.solanaHttp;
+  }
+  get metricsHttp() {
+    return RpcEndpointType.solanaMetricsHttp;
+  }
+
+  withChainId(chainId: string): IRpcFamily {
+    return this;
+  }
+
+  withGenesisHash(genesisHash: string): IRpcFamily {
+    this.actions.push(async () => {
+      const result = await getRpcRequestFunction(this.endpoint)(
+        this.endpoint,
+        'getGenesisHash',
+        []
+      );
+      if (result.data.error) {
+        throw new Error(`Request getGenesisHash failed: ${result.data.error.message}`);
+      }
+      const genesisHashFromRpc = result.data.result;
+      if (genesisHashFromRpc !== genesisHash) {
+        throw new Error(`GenesisHash mismatch: ${genesisHashFromRpc} != ${genesisHash}`);
+      }
+    });
+    return this;
+  }
+
+  withNodeType(nodeType: string): IRpcFamily {
+    this.actions.push(async () => {
+      let slot = 1;
+      if (nodeType !== 'archive') {
+        let result = await getRpcRequestFunction(this.endpoint)(
+          this.endpoint,
+          'getLatestBlockhash',
+          []
+        );
+        if (result.data.error) {
+          throw new Error(`Request withNodeType failed: ${result.data.error.message}`);
+        }
+        slot = BigNumber.from(result.data.result.context.slot).toNumber();
+      }
+      const result = await getRpcRequestFunction(this.endpoint)(this.endpoint, 'getBlock', [
+        slot,
+        {
+          maxSupportedTransactionVersion: 0,
+          transactionDetails: 'none',
+          rewards: false,
+        },
+      ]);
+      if (result.data.error) {
+        throw new Error(`NodeType mismatch: ${nodeType} required`);
+      }
+    });
+    return this;
+  }
+
+  withClientNameAndVersion(clientName: string, clientVersion: string): IRpcFamily {
+    this.actions.push(async () => {
+      if (!clientName && !clientVersion) {
+        return;
+      }
+      const result = await getRpcRequestFunction(this.endpoint)(this.endpoint, 'getVersion', []);
+      if (result.data.error) {
+        throw new Error(`Request getVersion failed: ${result.data.error.message}`);
+      }
+      const resultSet = result.data.result;
+      const clientVersionFromRpc = resultSet['solana-core'];
+      if (
+        !!clientVersion &&
+        !semver.satisfies(semver.coerce(clientVersionFromRpc), clientVersion)
+      ) {
+        throw new Error(`ClientVersion mismatch: ${clientVersionFromRpc} vs ${clientVersion}`);
+      }
+    });
+    return this;
+  }
+
+  withHeight(height?: number): IRpcFamily {
+    return this;
+  }
+
+  withBlockFitlerCapability(): IRpcFamily {
+    return this;
+  }
+
+  withFilteredBlocks(): IRpcFamily {
+    return this;
+  }
+
+  withHealth(): IRpcFamily {
+    this.actions.push(async () => {
+      const result = await getRpcRequestFunction(this.endpoint)(this.endpoint, 'getHealth', []);
+      if (result.data.error) {
+        throw new Error(`Not health: ${result.data.error}`);
+      }
+    });
+    return this;
+  }
+
+  async getStartHeight(endpoint: string): Promise<number> {
+    return 0;
+  }
+
+  async getTargetHeight(endpoint: string): Promise<number> {
+    return 0;
+  }
+
+  async getLastHeight(endpoint: string): Promise<number> {
+    const result = await getRpcRequestFunction(endpoint)(endpoint, 'getBlockHeight', []);
+    if (result.data.error) {
+      throw new Error(`Request getBlockHeight failed: ${result.data.error.message}`);
+    }
+    return BigNumber.from(result.data.result).toNumber();
+  }
+
+  async getLastTimestamp(endpoint: string): Promise<number> {
+    let result = await getRpcRequestFunction(endpoint)(endpoint, 'getLatestBlockhash', []);
+    if (result.data.error) {
+      throw new Error(`Request getLastTimestamp failed: ${result.data.error.message}`);
+    }
+    const slot = BigNumber.from(result.data.result.context.slot).toNumber();
+    result = await getRpcRequestFunction(endpoint)(endpoint, 'getBlockTime', [slot]);
+    if (result.data.error) {
+      throw new Error(`Request getLastTimestamp-getBlockTime failed: ${result.data.error.message}`);
+    }
+    return BigNumber.from(result.data.result).toNumber();
+  }
+}
diff --git a/apps/indexer-coordinator/src/project/types.ts b/apps/indexer-coordinator/src/project/types.ts
@@ -83,12 +83,17 @@ export enum RpcEndpointType {
   subqlDictWs = 'subql_dictWs',
   subqlDictHttp = 'subql_dictHttp',
   subqlDictMetricsHttp = 'subql_dictMetricsHttp',
+
+  solanaHttp = 'solanaHttp',
+  solanaWs = 'solanaWs',
+  solanaMetricsHttp = 'solanaMetricsHttp',
 }
 
 export const RpcEndpointAccessType = {
   [RpcEndpointType.evmMetricsHttp]: AccessType.INTERNAL,
   [RpcEndpointType.polkadotMetricsHttp]: AccessType.INTERNAL,
   [RpcEndpointType.subqlDictMetricsHttp]: AccessType.INTERNAL,
+  [RpcEndpointType.solanaMetricsHttp]: AccessType.INTERNAL,
 };
 
 @InputType('SubgraphPort')