feat: add @mina-js/klesia-utils package with handleJsonRpcRequest (#11)

Introduce a new package @mina-js/klesia-utils that exports the
handleJsonRpcRequest function. This utility converts JSON-RPC requests
into Mina node GraphQL requests, enabling seamless integration between
different request formats.

Author: DeMonkeyCoder

.github/workflows/ci.yml

@@ -14,4 +14,4 @@ jobs:
       - run: bun i --no-save
       - run: bun run build
       - run: bun run test
-      - run: bunx pkg-pr-new publish './packages/klesia-sdk' './packages/accounts' './packages/connect' './packages/providers' './packages/utils'
+      - run: bunx pkg-pr-new publish './packages/klesia-sdk' './packages/klesia-utils' './packages/accounts' './packages/connect' './packages/providers' './packages/utils'

apps/klesia/package.json

@@ -18,19 +18,16 @@
 		"cleanup": "rimraf dist .turbo node_modules"
 	},
 	"devDependencies": {
+		"@mina-js/klesia-utils": "workspace:*",
 		"@mina-js/utils": "workspace:*"
 	},
 	"dependencies": {
 		"@hono/node-server": "1.13.8",
 		"@hono/zod-openapi": "0.19.2",
-		"@urql/core": "5.1.1",
-		"bigint-quantile": "0.0.2",
-		"dayjs": "1.11.13",
 		"dotenv": "16.4.7",
 		"hono": "4.7.4",
 		"hono-rate-limiter": "0.4.2",
 		"nanoid": "5.1.3",
-		"ofetch": "1.4.1",
 		"ts-pattern": "5.6.2",
 		"zod": "3.24.2"
 	}

apps/klesia/src/index.ts

@@ -1,19 +1,15 @@
 import { getConnInfo } from "@hono/node-server/conninfo";
 import { OpenAPIHono, createRoute } from "@hono/zod-openapi";
 import {
-	KlesiaRpcMethod,
 	KlesiaRpcMethodSchema,
 	KlesiaRpcResponseSchema,
-	PublicKeySchema,
-} from "@mina-js/utils";
+} from "@mina-js/klesia-utils";
+import { handleJsonRpcRequest } from "@mina-js/klesia-utils";
 import { rateLimiter } from "hono-rate-limiter";
 import { cors } from "hono/cors";
 import { logger } from "hono/logger";
 import { nanoid } from "nanoid";
-import { match } from "ts-pattern";
-import { mina } from "./methods/mina";
-import { buildResponse } from "./utils/build-response";
-import { z } from "zod";
+import { getNodeApiUrl } from "./utils/node";
 
 export const api = new OpenAPIHono();
 
@@ -62,78 +58,10 @@ const rpcRoute = createRoute({
 });
 
 export const klesiaRpcRoute = api.openapi(rpcRoute, async ({ req, json }) => {
-	const body = KlesiaRpcMethodSchema.parse(await req.json());
-	return match(body)
-		.with(
-			{ method: KlesiaRpcMethod.enum.mina_getTransactionCount },
-			async ({ params }) => {
-				const [publicKey] = params;
-				const result = await mina.getTransactionCount({
-					publicKey: PublicKeySchema.parse(publicKey),
-				});
-				return json(
-					buildResponse({
-						result,
-					}),
-					200,
-				);
-			},
-		)
-		.with(
-			{ method: KlesiaRpcMethod.enum.mina_getBalance },
-			async ({ params }) => {
-				const [publicKey, tokenId] = params;
-				const result = await mina.getBalance({
-					publicKey: PublicKeySchema.parse(publicKey),
-					tokenId: tokenId !== undefined ? z.string().parse(tokenId) : "1",
-				});
-				return json(buildResponse({ result }), 200);
-			},
-		)
-		.with({ method: KlesiaRpcMethod.enum.mina_blockHash }, async () => {
-			if (process.env.MINA_NETWORK === "zeko_devnet") {
-				return json(
-					buildResponse({
-						error: {
-							code: -32600,
-							message: "Network not supported.",
-						},
-					}),
-					200,
-				);
-			}
-			const result = await mina.blockHash();
-			return json(buildResponse({ result }), 200);
-		})
-		.with({ method: KlesiaRpcMethod.enum.mina_networkId }, async () => {
-			const result = await mina.networkId();
-			return json(buildResponse({ result }), 200);
-		})
-		.with(
-			{ method: KlesiaRpcMethod.enum.mina_sendTransaction },
-			async ({ params }) => {
-				const [signedTransaction, type] = params;
-				const result = await mina.sendTransaction({ signedTransaction, type });
-				return json(
-					buildResponse({
-						result,
-					}),
-					200,
-				);
-			},
-		)
-		.with(
-			{ method: KlesiaRpcMethod.enum.mina_getAccount },
-			async ({ params }) => {
-				const [publicKey, tokenId] = params;
-				const result = await mina.getAccount({
-					publicKey: PublicKeySchema.parse(publicKey),
-					tokenId: tokenId !== undefined ? z.string().parse(tokenId) : "1",
-				});
-				return json(buildResponse({ result }), 200);
-			},
-		)
-		.exhaustive();
+	return json(
+		await handleJsonRpcRequest(getNodeApiUrl(), await req.json()),
+		200,
+	);
 });
 
 export type KlesiaRpc = typeof klesiaRpcRoute;

apps/klesia/src/methods/mina.ts

@@ -1,5 +1,4 @@
-import { KlesiaNetwork } from "@mina-js/utils";
-import { Client, cacheExchange, fetchExchange } from "@urql/core";
+import { KlesiaNetwork } from "@mina-js/klesia-utils";
 import { match } from "ts-pattern";
 import { z } from "zod";
 
@@ -27,9 +26,3 @@ export const getNodeApiUrl = () => {
 		.with("zeko_devnet", () => NODE_API_ZEKO_DEVNET)
 		.exhaustive();
 };
-
-export const getNodeClient = () => {
-	const url = getNodeApiUrl();
-	if (!url) throw new Error("Invalid network config.");
-	return new Client({ url, exchanges: [cacheExchange, fetchExchange] });
-};

apps/klesia/src/utils/node.ts

@@ -20,7 +20,8 @@
 		"typescript": "^5.0.0"
 	},
 	"devDependencies": {
-		"@mina-js/utils": "workspace:*"
+		"@mina-js/utils": "workspace:*",
+		"@mina-js/klesia-utils": "workspace:*"
 	},
 	"dependencies": {
 		"micro-ftch": "0.4.2",

bun.lockb

@@ -2,7 +2,7 @@ import {
 	KlesiaNetwork,
 	type KlesiaRpcRequestType,
 	type KlesiaRpcResponseType,
-} from "@mina-js/utils";
+} from "@mina-js/klesia-utils";
 import { ftch, jsonrpc } from "micro-ftch";
 import { match } from "ts-pattern";