feat: add Helius SDK

Author: beeman

.env.example

@@ -49,6 +49,8 @@ DATABASE_PROVISION=true
 GRAPHQL_PLAYGROUND=true
 # JWT Secret (generate a random string with `openssl rand -hex 32`)
 JWT_SECRET=
+# Helius API Key
+HELIUS_API_KEY=
 # Host to listen on
 HOST=127.0.0.1
 # Network Cluster configuration. Configure at least one in order to start the API.

libs/api/core/data-access/src/lib/api-core-network.service.ts

@@ -5,14 +5,27 @@ import { Injectable, Logger } from '@nestjs/common'
 import { OnEvent } from '@nestjs/event-emitter'
 import { NetworkCluster } from '@prisma/client'
 import { AccountInfo, Connection, ParsedAccountData, PublicKey } from '@solana/web3.js'
+import { Helius, HeliusCluster } from 'helius-sdk'
 import { CORE_APP_STARTED } from './api-core.events'
 import { ApiCoreConfigService, NetworkClusterMap } from './config/api-core-config.service'
 
+function heliusCluster(cluster: NetworkCluster): HeliusCluster {
+  switch (cluster) {
+    case NetworkCluster.SolanaMainnet:
+      return 'mainnet-beta'
+    case NetworkCluster.SolanaDevnet:
+      return 'devnet'
+    default:
+      throw new Error(`HeliusCluster: Unsupported cluster: ${cluster}`)
+  }
+}
+
 @Injectable()
 export class ApiCoreNetworkService {
   private readonly logger = new Logger(ApiCoreNetworkService.name)
   private readonly connectionMap = new Map<NetworkCluster, Connection>()
   private readonly clusterMap: NetworkClusterMap = this.config.networkClusters
+  private readonly helius: Map<NetworkCluster, Helius> = new Map()
   private readonly umis: Map<NetworkCluster, Umi> = new Map()
   constructor(readonly config: ApiCoreConfigService) {}
 
@@ -26,9 +39,15 @@ export class ApiCoreNetworkService {
       const connection = this.ensureConnection(cluster as NetworkCluster)
       try {
         const version = await connection.getVersion()
-        this.logger.debug(`Connected to ${cluster} cluster, version ${version['solana-core']}`)
+        this.logger.debug(`[${cluster}] Connected to cluster version ${version['solana-core']}`)
       } catch (error) {
-        this.logger.error(`Error connecting to ${cluster} cluster, ${error}`)
+        this.logger.error(`[${cluster}] Error connecting to cluster, ${error}`)
+      }
+      // Helius SDK only supports devnet and mainnet
+      if (this.config.heliusApiKey && ['SolanaDevnet', 'SolanaMainnet'].includes(cluster.toString())) {
+        this.logger.debug(`[${cluster}] Helius SDK enabled for cluster`)
+        this.helius.set(cluster as NetworkCluster, this.configureHelius(cluster as NetworkCluster))
+        this.listWebhooks(cluster as NetworkCluster)
       }
     }
   }
@@ -49,11 +68,26 @@ export class ApiCoreNetworkService {
     return found
   }
 
-  getClusterEndpoint(cluster: NetworkCluster): string {
+  ensureHelius(cluster: NetworkCluster): Helius {
+    const found = this.getHelius(cluster)
+    if (!found) {
+      throw new Error(`Connection ${cluster} not found`)
+    }
+    return found
+  }
+
+  private configureHelius(cluster: NetworkCluster) {
+    if (!this.config.heliusApiKey) {
+      throw new Error('Helius API key not configured')
+    }
+    return new Helius(this.config.heliusApiKey as string, heliusCluster(cluster as NetworkCluster))
+  }
+
+  private getClusterEndpoint(cluster: NetworkCluster): string {
     return this.clusterMap[cluster]
   }
 
-  getConnection(cluster: NetworkCluster) {
+  private getConnection(cluster: NetworkCluster) {
     if (!this.connectionMap.has(cluster)) {
       const endpoint = this.ensureClusterEndpoint(cluster)
       this.connectionMap.set(cluster, new Connection(endpoint, 'confirmed'))
@@ -65,6 +99,23 @@ export class ApiCoreNetworkService {
     return connection
   }
 
+  private getHelius(cluster: NetworkCluster) {
+    if (!this.helius.has(cluster)) {
+      this.helius.set(cluster, new Helius(this.config.heliusApiKey as string, heliusCluster(cluster)))
+    }
+    return this.helius.get(cluster)
+  }
+
+  private listWebhooks(cluster: NetworkCluster) {
+    const helius = this.ensureHelius(cluster)
+    helius.getAllWebhooks().then((webhooks) => {
+      this.logger.debug(`[${cluster}] Helius Webhooks: ${webhooks.length} configured`)
+      for (const webhook of webhooks) {
+        this.logger.debug(`[${cluster}] - Webhook: ${webhook.accountAddresses.length} addresses`)
+      }
+    })
+  }
+
   async getTokenAccountsByMint({
     cluster,
     wallet,

libs/api/core/data-access/src/lib/config/api-core-config.service.ts

@@ -106,6 +106,10 @@ export class ApiCoreConfigService {
     return this.service.get('environment')
   }
 
+  get heliusApiKey() {
+    return this.service.get('heliusApiKey')
+  }
+
   get host() {
     return this.service.get<string>('host')
   }

libs/api/core/data-access/src/lib/config/configuration.ts

@@ -35,6 +35,7 @@ export interface ApiCoreConfig {
   corsOrigins: string[]
   databaseProvision: boolean
   environment: Env
+  heliusApiKey?: string
   host: string
   jwtSecret: string
   networkClusterSolanaCustom?: string
@@ -61,6 +62,7 @@ export function configuration(): ApiCoreConfig {
     corsOrigins,
     databaseProvision: process.env['DATABASE_PROVISION'] === 'true',
     environment: (process.env['NODE_ENV'] as Env) || 'development',
+    heliusApiKey: process.env['HELIUS_API_KEY'],
     host: process.env['HOST'] as string,
     jwtSecret: process.env['JWT_SECRET'] as string,
     networkClusterSolanaCustom: process.env['NETWORK_CLUSTER_SOLANA_CUSTOM'],

libs/api/core/data-access/src/lib/config/validation-schema.ts

@@ -21,6 +21,7 @@ export const validationSchema = Joi.object({
   DATABASE_URL: Joi.string(),
   GRAPHQL_PLAYGROUND: Joi.boolean().default(false),
   JWT_SECRET: Joi.string().required(),
+  HELIUS_API_KEY: Joi.string().optional(),
   HOST: Joi.string().default('0.0.0.0'),
   NETWORK_CLUSTER_SOLANA_CUSTOM: Joi.string().optional(),
   NETWORK_CLUSTER_SOLANA_DEVNET: Joi.string().optional(),

package.json

@@ -72,6 +72,7 @@
     "graphql": "^16.9.0",
     "graphql-codegen-typescript-validation-schema": "^0.15.0",
     "graphql-scalars": "^1.23.0",
+    "helius-sdk": "^1.3.5",
     "joi": "^17.13.3",
     "jotai": "^2.8.3",
     "linkify-react": "^4.1.3",