feat: add solana send endpoint

node/coinstacks/solana/api/package.json

@@ -13,6 +13,7 @@
   },
   "dependencies": {
     "@shapeshiftoss/common-api": "^10.0.0",
-    "@solana/web3.js": "^2.0.0-rc.1"
+    "@solana/web3.js": "^2.0.0-rc.1",
+    "helius-sdk": "^1.3.5"
   }
 }

node/coinstacks/solana/api/src/controller.ts

@@ -9,10 +9,21 @@ import {
   ValidationError,
 } from '../../../common/api/src' // unable to import models from a module with tsoa
 import { Account, TxHistory } from './models'
+import { Service } from './service'
+
+const RPC_URL = process.env.RPC_URL
+const RPC_API_KEY = process.env.RPC_API_KEY
 
 const NETWORK = process.env.NETWORK
 
 if (!NETWORK) throw new Error('NETWORK env var not set')
+if (!RPC_URL) throw new Error('RPC_URL env var not set')
+if (!RPC_API_KEY) throw new Error('RPC_API_KEY env var not set')
+
+export const service = new Service({
+  rpcUrl: RPC_URL,
+  rpcApiKey: RPC_API_KEY,
+})
 
 export const logger = new Logger({
   namespace: ['unchained', 'coinstacks', 'solana', 'api'],
@@ -22,6 +33,8 @@ export const logger = new Logger({
 @Route('api/v1')
 @Tags('v1')
 export class Solana implements BaseAPI {
+  static service: Service
+
   /**
    * Get information about the running coinstack
    *
@@ -78,8 +91,9 @@ export class Solana implements BaseAPI {
   @Response<ValidationError>(422, 'Validation Error')
   @Response<InternalServerError>(500, 'Internal Server Error')
   @Post('send/')
-  // eslint-disable-next-line @typescript-eslint/no-unused-vars
   async sendTx(@Body() _body: SendTxBody): Promise<string> {
-    return ''
+    return Solana.service.sendTx(_body)
   }
 }
+
+Solana.service = service

node/coinstacks/solana/api/src/service.ts

@@ -0,0 +1,38 @@
+import type { Account, API, Tx, TxHistory } from './models'
+import { BaseAPI, handleError,  SendTxBody } from '@shapeshiftoss/common-api'
+import { Helius } from "helius-sdk";
+
+export interface ServiceArgs {
+  rpcUrl: string
+  rpcApiKey: string
+}
+
+export class Service implements Omit<BaseAPI, 'getInfo'>, API {
+  private readonly heliusSdk: Helius
+
+  constructor(args: ServiceArgs) {
+    this.heliusSdk = new Helius(args.rpcApiKey)
+  }
+
+  async getTransaction(): Promise<Tx> {
+    throw new Error('Method not implemented.')
+  }
+
+  async getAccount(): Promise<Account> {
+    throw new Error('Method not implemented.')
+  }
+
+  async getTxHistory(): Promise<TxHistory> {
+    throw new Error('Method not implemented.')
+  }
+
+  async sendTx(body: SendTxBody): Promise<string> {
+    try {
+      const txSig = await this.heliusSdk.connection.sendRawTransaction(Buffer.from(body.hex, 'base64'));
+
+      return txSig
+    } catch (err) {
+      throw handleError(err)
+    }
+  }
+}

node/coinstacks/solana/sample.env

@@ -6,4 +6,4 @@ RPC_API_KEY=
 INDEXER_URL=https://api.helius.xyz
 LOG_LEVEL=debug
 NETWORK=mainnet
-RPC_URL=https://mainnet.helius-rpc.com
+RPC_URL=https://mainnet.helius-rpc.com