include a FetchCurrency, but is more of a test - as a direct call provides full currency list supported by the exchange.

Author: rsoury

README.md

@@ -212,6 +212,7 @@ message ActionResponse {
 - `FetchDepositAddresses` (8): Get deposit addresses for a token/network
 - `FetchTicker` (9): Get ticker information
 - `Call` (10): Generic method invocation on the underlying broker instance. Provide `functionName`, optional `args` array, and optional `params` object.
+- `FetchCurrency` (11): Get currency metadata (networks, fees, etc.) for a symbol
 
 **Example Usage:**
 
@@ -277,6 +278,14 @@ const depositAddressRequest = {
   cex: "binance",
   symbol: "USDT"
 };
+
+// Fetch currency metadata
+const fetchCurrencyRequest = {
+  action: 11, // FetchCurrency
+  payload: {},
+  cex: "binance",
+  symbol: "USDT"
+};
 ```
 
 ### Subscribe (Streaming)

src/proto/node.proto

@@ -55,4 +55,5 @@ enum Action {
   FetchDepositAddresses=8;
   FetchTicker=9;
   Call=10;
+  FetchCurrency=11;
 }

src/server.ts

@@ -166,6 +166,45 @@ export function getServer(
 					break;
 				}
 
+				case Action.FetchCurrency: {
+					if (!symbol) {
+						return callback(
+							{
+								code: grpc.status.INVALID_ARGUMENT,
+								message: `ValidationError: Symbol requied`,
+							},
+							null,
+						);
+					}
+					try {
+						const currencies = await broker.fetchCurrencies(symbol);
+						const currencyInfo = currencies[symbol];
+						if (!currencyInfo) {
+							return callback(
+								{
+									code: grpc.status.NOT_FOUND,
+									message: `Currency not found for ${symbol}`,
+								},
+								null,
+							);
+						}
+						callback(null, {
+							proof: broker.last_proof || "",
+							result: JSON.stringify(currencyInfo),
+						});
+					} catch (error) {
+						log.error(`Error fetching currency ${symbol} from ${cex}:`, error);
+						callback(
+							{
+								code: grpc.status.INTERNAL,
+								message: `Failed to fetch currency for ${symbol} from ${cex}`,
+							},
+							null,
+						);
+					}
+					break;
+				}
+
 				case Action.Call: {
 					const callSchema = Joi.object({
 						functionName: Joi.string()
@@ -187,14 +226,19 @@ export function getServer(
 
 					// Normalise payload coming from protobuf map<string, string>
 					// to support JSON-encoded complex types for args/params
-					const rawPayload = (call.request.payload ?? {}) as Record<string, unknown>;
+					const rawPayload = (call.request.payload ?? {}) as Record<
+						string,
+						unknown
+					>;
 					const preparedPayload: Record<string, unknown> = { ...rawPayload };
 					try {
 						if (typeof preparedPayload.args === "string") {
 							preparedPayload.args = JSON.parse(preparedPayload.args as string);
 						}
 						if (typeof preparedPayload.params === "string") {
-							preparedPayload.params = JSON.parse(preparedPayload.params as string);
+							preparedPayload.params = JSON.parse(
+								preparedPayload.params as string,
+							);
 						}
 					} catch {
 						return callback(
@@ -207,9 +251,8 @@ export function getServer(
 						);
 					}
 
-					const { value: callValue, error: callError } = callSchema.validate(
-						preparedPayload,
-					);
+					const { value: callValue, error: callError } =
+						callSchema.validate(preparedPayload);
 
 					if (callError) {
 						return callback(
@@ -226,7 +269,10 @@ export function getServer(
 						const fn = (broker as unknown as Record<string, unknown>)[
 							callValue.functionName
 						];
-						if (typeof fn !== "function" || !broker.has[callValue.functionName]) {
+						if (
+							typeof fn !== "function" ||
+							!broker.has[callValue.functionName]
+						) {
 							return callback(
 								{
 									code: grpc.status.INVALID_ARGUMENT,
@@ -797,13 +843,11 @@ export function getServer(
 				const subscriptionType =
 					type !== undefined ? type : SubscriptionType.ORDERBOOK;
 
-				log.info(
-					`Request - Subscribe:`, {
-						cex: request.cex,
-						symbol: request.symbol,
-						type: subscriptionType,
-					}
-				);
+				log.info(`Request - Subscribe:`, {
+					cex: request.cex,
+					symbol: request.symbol,
+					type: subscriptionType,
+				});
 
 				// Validate required fields
 				if (!cex || !symbol) {