feat(sidecar): Add jsonrpc request handler

sidecar/src/app.ts

@@ -32,6 +32,7 @@ import {
 	AbciRpcHandler,
 	TxRpcHandler
 } from "./rpc";
+import { JsonRpcHandler } from "./handlers/jsonrpc";
 
 export class App {
 	config: IConfig;
@@ -125,6 +126,7 @@ export class App {
 		const txHandler = new TxHandler(this.services.get<TxService>('tx'));
 		const stakingHandler = new StakingHandler(this.services.get<StakingService>('staking'));
 		const wsHandler = new WebsocketHandler(this.jsonrpc);
+		const jsonrpcHandler = new JsonRpcHandler(this.jsonrpc);
 
 		this.server.get('/cosmos/bank/v1beta1/balances/:address', balanceHandler.handleGetBalance);
 		this.server.get('/cosmos/auth/v1beta1/accounts/:address', accountHandler.handleGetAccount);
@@ -134,7 +136,8 @@ export class App {
 		this.server.post('/cosmos/tx/v1beta1/simulate', txHandler.handlePostSimulate);
 		this.server.get('/cosmos/staking/v1beta1/delegations/:delegatorAddr', stakingHandler.handleGetStaking);
 		this.server.get('/cosmos/staking/v1beta1/delegators/:delegatorAddr/unbonding_delegations', stakingHandler.handleGetUnbondingDelegations);
-		this.server.get('/websocket', { websocket: true }, wsHandler.handlerMessage);
+		this.server.get('/websocket', { websocket: true }, wsHandler.handleMessage);
+		this.server.post('/', jsonrpcHandler.handleRequest)
 	}
 
 	async initJsonRpcServer() {

sidecar/src/handlers/index.ts

@@ -1,5 +1,6 @@
 export * from './balance';
 export * from './account';
+export * from './jsonrpc';
 export * from './nodeinfo';
 export * from './tx';
 export * from './distribution';

sidecar/src/handlers/jsonrpc.ts

@@ -0,0 +1,16 @@
+import { FastifyRequest } from "fastify";
+import { JSONRPCRequest, JSONRPCResponse, JSONRPCServer } from "json-rpc-2.0";
+
+export class JsonRpcHandler {
+    jsonrpc: JSONRPCServer;
+
+    constructor(jsonrpc: JSONRPCServer) {
+        this.jsonrpc = jsonrpc;
+    }
+
+    handleRequest = async (request: FastifyRequest<{
+        Body: JSONRPCRequest;
+    }>): Promise<JSONRPCResponse | null> => {
+        return await this.jsonrpc.receive(request.body);
+    }
+}

sidecar/src/handlers/ws.ts

@@ -8,7 +8,7 @@ export class WebsocketHandler {
         this.jsonrpc = jsonrpc;
     }
 
-    handlerMessage = (connection: SocketStream) => {
+    handleMessage = (connection: SocketStream) => {
         connection.socket.on('message', async (message) => {
             const request = JSON.parse(message.toString());
             const response = await this.jsonrpc.receive(request);

sidecar/src/services/tx.ts

@@ -8,7 +8,7 @@ import {
 import Long from "long";
 import { createHash } from "crypto";
 import { convertToCodespace } from "../constants/codespace";
-import { encodeTo, sleep } from "../utils";
+import { encodeTo } from "../utils";
 import { Event as CosmosEvent } from "cosmjs-types/tendermint/abci/types";
 import { Header } from "@polkadot/types/interfaces";
 import { ChainService } from "./chain";