feat: chunk broadcasting support

Author: bangjelkoski

apps/price_pusher/README.md

@@ -114,6 +114,7 @@ pnpm run start injective --grpc-endpoint https://grpc-endpoint.com \
     --network testnet \
     [--gas-price 160000000] \
     [--gas-multiplier 1.1] \
+    [--priceIds-process-chunk-size 100] \
     [--pushing-frequency 10] \
     [--polling-frequency 5]
 

apps/price_pusher/package.json

@@ -60,8 +60,9 @@
   },
   "dependencies": {
     "@coral-xyz/anchor": "^0.30.0",
-    "@injectivelabs/networks": "^1.14.6",
-    "@injectivelabs/sdk-ts": "1.10.72",
+    "@injectivelabs/networks": "1.14.47",
+    "@injectivelabs/utils": "^1.14.47",
+    "@injectivelabs/sdk-ts": "1.14.49",
     "@mysten/sui": "^1.3.0",
     "@pythnetwork/hermes-client": "^1.3.1",
     "@pythnetwork/price-service-sdk": "workspace:^",

apps/price_pusher/src/injective/command.ts

@@ -27,13 +27,18 @@ export default {
       required: true,
     } as Options,
     "gas-price": {
-      description: "Gas price to be used for each transasction",
+      description: "Gas price to be used for each transaction",
       type: "number",
     } as Options,
     "gas-multiplier": {
-      description: "Gas multiplier to be used for each transasction",
+      description: "Gas multiplier to be used for each transaction",
       type: "number",
     } as Options,
+    "price-ids-process-chunk-size": {
+      description: "Set in case we wanna split price feeds updates into chunks to have smaller transactions. Set to -1 to disable chunking.",
+      type: "number",
+      required: false
+    } as Options,
     ...options.priceConfigFile,
     ...options.priceServiceEndpoint,
     ...options.mnemonicFile,
@@ -46,18 +51,19 @@ export default {
   handler: async function (argv: any) {
     // FIXME: type checks for this
     const {
+      network,
+      logLevel,
       gasPrice,
-      gasMultiplier,
       grpcEndpoint,
-      priceConfigFile,
-      priceServiceEndpoint,
       mnemonicFile,
-      pythContractAddress,
-      pushingFrequency,
+      gasMultiplier,
+      priceConfigFile,
       pollingFrequency,
-      network,
-      logLevel,
+      pushingFrequency,
       controllerLogLevel,
+      pythContractAddress,
+      priceServiceEndpoint,
+      priceIdsProcessChunkSize,
     } = argv;
 
     const logger = pino({ level: logLevel });
@@ -111,6 +117,7 @@ export default {
         chainId: getNetworkInfo(network).chainId,
         gasPrice,
         gasMultiplier,
+        priceIdsProcessChunkSize
       },
     );