New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

@dydxprotocol/v4-proto

Package Overview
Dependencies
Maintainers
0
Versions
169
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@dydxprotocol/v4-proto - npm Package Compare versions

Comparing version 5.2.1 to 5.2.2

2

package.json
{
"name": "@dydxprotocol/v4-proto",
"version": "5.2.1",
"version": "5.2.2",
"access": "public",

@@ -5,0 +5,0 @@ "description": "Protos for dYdX v4 protocol",

252

src/codegen/cosmos/bundle.ts

@@ -127,65 +127,65 @@ import * as _2 from "./app/runtime/v1alpha1/module";

import * as _127 from "./vesting/v1beta1/vesting";
import * as _257 from "./auth/v1beta1/query.lcd";
import * as _258 from "./authz/v1beta1/query.lcd";
import * as _259 from "./bank/v1beta1/query.lcd";
import * as _260 from "./base/node/v1beta1/query.lcd";
import * as _261 from "./base/tendermint/v1beta1/query.lcd";
import * as _262 from "./circuit/v1/query.lcd";
import * as _263 from "./consensus/v1/query.lcd";
import * as _264 from "./distribution/v1beta1/query.lcd";
import * as _265 from "./evidence/v1beta1/query.lcd";
import * as _266 from "./feegrant/v1beta1/query.lcd";
import * as _267 from "./gov/v1/query.lcd";
import * as _268 from "./gov/v1beta1/query.lcd";
import * as _269 from "./group/v1/query.lcd";
import * as _270 from "./mint/v1beta1/query.lcd";
import * as _271 from "./nft/v1beta1/query.lcd";
import * as _272 from "./params/v1beta1/query.lcd";
import * as _273 from "./slashing/v1beta1/query.lcd";
import * as _274 from "./staking/v1beta1/query.lcd";
import * as _275 from "./tx/v1beta1/service.lcd";
import * as _276 from "./upgrade/v1beta1/query.lcd";
import * as _277 from "./app/v1alpha1/query.rpc.Query";
import * as _278 from "./auth/v1beta1/query.rpc.Query";
import * as _279 from "./authz/v1beta1/query.rpc.Query";
import * as _280 from "./bank/v1beta1/query.rpc.Query";
import * as _281 from "./base/node/v1beta1/query.rpc.Service";
import * as _282 from "./base/tendermint/v1beta1/query.rpc.Service";
import * as _283 from "./circuit/v1/query.rpc.Query";
import * as _284 from "./consensus/v1/query.rpc.Query";
import * as _285 from "./distribution/v1beta1/query.rpc.Query";
import * as _286 from "./evidence/v1beta1/query.rpc.Query";
import * as _287 from "./feegrant/v1beta1/query.rpc.Query";
import * as _288 from "./gov/v1/query.rpc.Query";
import * as _289 from "./gov/v1beta1/query.rpc.Query";
import * as _290 from "./group/v1/query.rpc.Query";
import * as _291 from "./mint/v1beta1/query.rpc.Query";
import * as _292 from "./nft/v1beta1/query.rpc.Query";
import * as _293 from "./orm/query/v1alpha1/query.rpc.Query";
import * as _294 from "./params/v1beta1/query.rpc.Query";
import * as _295 from "./slashing/v1beta1/query.rpc.Query";
import * as _296 from "./staking/v1beta1/query.rpc.Query";
import * as _297 from "./tx/v1beta1/service.rpc.Service";
import * as _298 from "./upgrade/v1beta1/query.rpc.Query";
import * as _299 from "./auth/v1beta1/tx.rpc.msg";
import * as _300 from "./authz/v1beta1/tx.rpc.msg";
import * as _301 from "./bank/v1beta1/tx.rpc.msg";
import * as _302 from "./circuit/v1/tx.rpc.msg";
import * as _303 from "./consensus/v1/tx.rpc.msg";
import * as _304 from "./crisis/v1beta1/tx.rpc.msg";
import * as _305 from "./distribution/v1beta1/tx.rpc.msg";
import * as _306 from "./evidence/v1beta1/tx.rpc.msg";
import * as _307 from "./feegrant/v1beta1/tx.rpc.msg";
import * as _308 from "./gov/v1/tx.rpc.msg";
import * as _309 from "./gov/v1beta1/tx.rpc.msg";
import * as _310 from "./group/v1/tx.rpc.msg";
import * as _311 from "./mint/v1beta1/tx.rpc.msg";
import * as _312 from "./nft/v1beta1/tx.rpc.msg";
import * as _313 from "./slashing/v1beta1/tx.rpc.msg";
import * as _314 from "./staking/v1beta1/tx.rpc.msg";
import * as _315 from "./upgrade/v1beta1/tx.rpc.msg";
import * as _316 from "./vesting/v1beta1/tx.rpc.msg";
import * as _368 from "./lcd";
import * as _369 from "./rpc.query";
import * as _370 from "./rpc.tx";
import * as _246 from "./auth/v1beta1/query.lcd";
import * as _247 from "./authz/v1beta1/query.lcd";
import * as _248 from "./bank/v1beta1/query.lcd";
import * as _249 from "./base/node/v1beta1/query.lcd";
import * as _250 from "./base/tendermint/v1beta1/query.lcd";
import * as _251 from "./circuit/v1/query.lcd";
import * as _252 from "./consensus/v1/query.lcd";
import * as _253 from "./distribution/v1beta1/query.lcd";
import * as _254 from "./evidence/v1beta1/query.lcd";
import * as _255 from "./feegrant/v1beta1/query.lcd";
import * as _256 from "./gov/v1/query.lcd";
import * as _257 from "./gov/v1beta1/query.lcd";
import * as _258 from "./group/v1/query.lcd";
import * as _259 from "./mint/v1beta1/query.lcd";
import * as _260 from "./nft/v1beta1/query.lcd";
import * as _261 from "./params/v1beta1/query.lcd";
import * as _262 from "./slashing/v1beta1/query.lcd";
import * as _263 from "./staking/v1beta1/query.lcd";
import * as _264 from "./tx/v1beta1/service.lcd";
import * as _265 from "./upgrade/v1beta1/query.lcd";
import * as _266 from "./app/v1alpha1/query.rpc.Query";
import * as _267 from "./auth/v1beta1/query.rpc.Query";
import * as _268 from "./authz/v1beta1/query.rpc.Query";
import * as _269 from "./bank/v1beta1/query.rpc.Query";
import * as _270 from "./base/node/v1beta1/query.rpc.Service";
import * as _271 from "./base/tendermint/v1beta1/query.rpc.Service";
import * as _272 from "./circuit/v1/query.rpc.Query";
import * as _273 from "./consensus/v1/query.rpc.Query";
import * as _274 from "./distribution/v1beta1/query.rpc.Query";
import * as _275 from "./evidence/v1beta1/query.rpc.Query";
import * as _276 from "./feegrant/v1beta1/query.rpc.Query";
import * as _277 from "./gov/v1/query.rpc.Query";
import * as _278 from "./gov/v1beta1/query.rpc.Query";
import * as _279 from "./group/v1/query.rpc.Query";
import * as _280 from "./mint/v1beta1/query.rpc.Query";
import * as _281 from "./nft/v1beta1/query.rpc.Query";
import * as _282 from "./orm/query/v1alpha1/query.rpc.Query";
import * as _283 from "./params/v1beta1/query.rpc.Query";
import * as _284 from "./slashing/v1beta1/query.rpc.Query";
import * as _285 from "./staking/v1beta1/query.rpc.Query";
import * as _286 from "./tx/v1beta1/service.rpc.Service";
import * as _287 from "./upgrade/v1beta1/query.rpc.Query";
import * as _288 from "./auth/v1beta1/tx.rpc.msg";
import * as _289 from "./authz/v1beta1/tx.rpc.msg";
import * as _290 from "./bank/v1beta1/tx.rpc.msg";
import * as _291 from "./circuit/v1/tx.rpc.msg";
import * as _292 from "./consensus/v1/tx.rpc.msg";
import * as _293 from "./crisis/v1beta1/tx.rpc.msg";
import * as _294 from "./distribution/v1beta1/tx.rpc.msg";
import * as _295 from "./evidence/v1beta1/tx.rpc.msg";
import * as _296 from "./feegrant/v1beta1/tx.rpc.msg";
import * as _297 from "./gov/v1/tx.rpc.msg";
import * as _298 from "./gov/v1beta1/tx.rpc.msg";
import * as _299 from "./group/v1/tx.rpc.msg";
import * as _300 from "./mint/v1beta1/tx.rpc.msg";
import * as _301 from "./nft/v1beta1/tx.rpc.msg";
import * as _302 from "./slashing/v1beta1/tx.rpc.msg";
import * as _303 from "./staking/v1beta1/tx.rpc.msg";
import * as _304 from "./upgrade/v1beta1/tx.rpc.msg";
import * as _305 from "./vesting/v1beta1/tx.rpc.msg";
import * as _352 from "./lcd";
import * as _353 from "./rpc.query";
import * as _354 from "./rpc.tx";
export namespace cosmos {

@@ -200,3 +200,3 @@ export namespace app {

..._5,
..._277
..._266
};

@@ -213,5 +213,5 @@ }

..._10,
..._257,
..._278,
..._299
..._246,
..._267,
..._288
};

@@ -229,5 +229,5 @@ }

..._16,
..._258,
..._279,
..._300
..._247,
..._268,
..._289
};

@@ -245,5 +245,5 @@ }

..._22,
..._259,
..._280,
..._301
..._248,
..._269,
..._290
};

@@ -258,4 +258,4 @@ }

export const v1beta1 = { ..._24,
..._260,
..._281
..._249,
..._270
};

@@ -276,4 +276,4 @@ }

..._29,
..._261,
..._282
..._250,
..._271
};

@@ -292,5 +292,5 @@ }

..._34,
..._262,
..._283,
..._302
..._251,
..._272,
..._291
};

@@ -305,5 +305,5 @@ }

..._37,
..._263,
..._284,
..._303
..._252,
..._273,
..._292
};

@@ -318,3 +318,3 @@ }

..._40,
..._304
..._293
};

@@ -349,5 +349,5 @@ }

..._51,
..._264,
..._285,
..._305
..._253,
..._274,
..._294
};

@@ -364,5 +364,5 @@ }

..._56,
..._265,
..._286,
..._306
..._254,
..._275,
..._295
};

@@ -379,5 +379,5 @@ }

..._61,
..._266,
..._287,
..._307
..._255,
..._276,
..._296
};

@@ -402,5 +402,5 @@ }

..._68,
..._267,
..._288,
..._308
..._256,
..._277,
..._297
};

@@ -411,5 +411,5 @@ export const v1beta1 = { ..._69,

..._72,
..._268,
..._289,
..._309
..._257,
..._278,
..._298
};

@@ -427,5 +427,5 @@ }

..._78,
..._269,
..._290,
..._310
..._258,
..._279,
..._299
};

@@ -442,5 +442,5 @@ }

..._83,
..._270,
..._291,
..._311
..._259,
..._280,
..._300
};

@@ -466,5 +466,5 @@ }

..._91,
..._271,
..._292,
..._312
..._260,
..._281,
..._301
};

@@ -479,3 +479,3 @@ }

export const v1alpha1 = { ..._93,
..._293
..._282
};

@@ -495,4 +495,4 @@ }

..._98,
..._272,
..._294
..._261,
..._283
};

@@ -517,5 +517,5 @@ }

..._105,
..._273,
..._295,
..._313
..._262,
..._284,
..._302
};

@@ -533,5 +533,5 @@ }

..._111,
..._274,
..._296,
..._314
..._263,
..._285,
..._303
};

@@ -569,4 +569,4 @@ }

..._120,
..._275,
..._297
..._264,
..._286
};

@@ -582,5 +582,5 @@ }

..._124,
..._276,
..._298,
..._315
..._265,
..._287,
..._304
};

@@ -595,9 +595,9 @@ }

..._127,
..._316
..._305
};
}
export const ClientFactory = { ..._368,
..._369,
..._370
export const ClientFactory = { ..._352,
..._353,
..._354
};
}

529

src/codegen/dydxprotocol/bundle.ts

@@ -1,197 +0,180 @@

import * as _128 from "./accountplus/accountplus";
import * as _129 from "./accountplus/genesis";
import * as _130 from "./assets/asset";
import * as _131 from "./assets/genesis";
import * as _132 from "./assets/query";
import * as _133 from "./assets/tx";
import * as _134 from "./blocktime/blocktime";
import * as _135 from "./blocktime/genesis";
import * as _136 from "./blocktime/params";
import * as _137 from "./blocktime/query";
import * as _138 from "./blocktime/tx";
import * as _139 from "./bridge/bridge_event_info";
import * as _140 from "./bridge/bridge_event";
import * as _141 from "./bridge/genesis";
import * as _142 from "./bridge/params";
import * as _143 from "./bridge/query";
import * as _144 from "./bridge/tx";
import * as _145 from "./clob/block_rate_limit_config";
import * as _146 from "./clob/clob_pair";
import * as _147 from "./clob/equity_tier_limit_config";
import * as _148 from "./clob/genesis";
import * as _149 from "./clob/liquidations_config";
import * as _150 from "./clob/liquidations";
import * as _151 from "./clob/matches";
import * as _152 from "./clob/mev";
import * as _153 from "./clob/operation";
import * as _154 from "./clob/order_removals";
import * as _155 from "./clob/order";
import * as _156 from "./clob/process_proposer_matches_events";
import * as _157 from "./clob/query";
import * as _158 from "./clob/tx";
import * as _159 from "./daemons/bridge/bridge";
import * as _160 from "./daemons/liquidation/liquidation";
import * as _161 from "./daemons/pricefeed/price_feed";
import * as _162 from "./delaymsg/block_message_ids";
import * as _163 from "./delaymsg/delayed_message";
import * as _164 from "./delaymsg/genesis";
import * as _165 from "./delaymsg/query";
import * as _166 from "./delaymsg/tx";
import * as _167 from "./epochs/epoch_info";
import * as _168 from "./epochs/genesis";
import * as _169 from "./epochs/query";
import * as _170 from "./feetiers/genesis";
import * as _171 from "./feetiers/params";
import * as _172 from "./feetiers/query";
import * as _173 from "./feetiers/tx";
import * as _174 from "./govplus/genesis";
import * as _175 from "./govplus/query";
import * as _176 from "./govplus/tx";
import * as _177 from "./indexer/events/events";
import * as _178 from "./indexer/indexer_manager/event";
import * as _179 from "./indexer/off_chain_updates/off_chain_updates";
import * as _180 from "./indexer/protocol/v1/clob";
import * as _181 from "./indexer/protocol/v1/perpetual";
import * as _182 from "./indexer/protocol/v1/subaccount";
import * as _183 from "./indexer/redis/redis_order";
import * as _184 from "./indexer/shared/removal_reason";
import * as _185 from "./indexer/socks/messages";
import * as _186 from "./listing/genesis";
import * as _187 from "./listing/query";
import * as _188 from "./listing/tx";
import * as _189 from "./perpetuals/genesis";
import * as _190 from "./perpetuals/params";
import * as _191 from "./perpetuals/perpetual";
import * as _192 from "./perpetuals/query";
import * as _193 from "./perpetuals/tx";
import * as _194 from "./prices/genesis";
import * as _195 from "./prices/market_param";
import * as _196 from "./prices/market_price";
import * as _197 from "./prices/query";
import * as _198 from "./prices/tx";
import * as _199 from "./ratelimit/capacity";
import * as _200 from "./ratelimit/genesis";
import * as _201 from "./ratelimit/limit_params";
import * as _202 from "./ratelimit/pending_send_packet";
import * as _203 from "./ratelimit/query";
import * as _204 from "./ratelimit/tx";
import * as _205 from "./revshare/genesis";
import * as _206 from "./revshare/params";
import * as _207 from "./revshare/query";
import * as _208 from "./revshare/revshare";
import * as _209 from "./revshare/tx";
import * as _210 from "./rewards/genesis";
import * as _211 from "./rewards/params";
import * as _212 from "./rewards/query";
import * as _213 from "./rewards/reward_share";
import * as _214 from "./rewards/tx";
import * as _215 from "./sending/genesis";
import * as _216 from "./sending/query";
import * as _217 from "./sending/transfer";
import * as _218 from "./sending/tx";
import * as _219 from "./stats/genesis";
import * as _220 from "./stats/params";
import * as _221 from "./stats/query";
import * as _222 from "./stats/stats";
import * as _223 from "./stats/tx";
import * as _224 from "./subaccounts/asset_position";
import * as _225 from "./subaccounts/genesis";
import * as _226 from "./subaccounts/perpetual_position";
import * as _227 from "./subaccounts/query";
import * as _228 from "./subaccounts/subaccount";
import * as _229 from "./vault/genesis";
import * as _230 from "./vault/params";
import * as _231 from "./vault/query";
import * as _232 from "./vault/share";
import * as _233 from "./vault/tx";
import * as _234 from "./vault/vault";
import * as _235 from "./vest/genesis";
import * as _236 from "./vest/query";
import * as _237 from "./vest/tx";
import * as _238 from "./vest/vest_entry";
import * as _317 from "./assets/query.lcd";
import * as _318 from "./blocktime/query.lcd";
import * as _319 from "./bridge/query.lcd";
import * as _320 from "./clob/query.lcd";
import * as _321 from "./delaymsg/query.lcd";
import * as _322 from "./epochs/query.lcd";
import * as _323 from "./feetiers/query.lcd";
import * as _324 from "./perpetuals/query.lcd";
import * as _325 from "./prices/query.lcd";
import * as _326 from "./ratelimit/query.lcd";
import * as _327 from "./revshare/query.lcd";
import * as _328 from "./rewards/query.lcd";
import * as _329 from "./stats/query.lcd";
import * as _330 from "./subaccounts/query.lcd";
import * as _331 from "./vault/query.lcd";
import * as _332 from "./vest/query.lcd";
import * as _333 from "./assets/query.rpc.Query";
import * as _334 from "./blocktime/query.rpc.Query";
import * as _335 from "./bridge/query.rpc.Query";
import * as _336 from "./clob/query.rpc.Query";
import * as _337 from "./delaymsg/query.rpc.Query";
import * as _338 from "./epochs/query.rpc.Query";
import * as _339 from "./feetiers/query.rpc.Query";
import * as _340 from "./govplus/query.rpc.Query";
import * as _341 from "./listing/query.rpc.Query";
import * as _342 from "./perpetuals/query.rpc.Query";
import * as _343 from "./prices/query.rpc.Query";
import * as _344 from "./ratelimit/query.rpc.Query";
import * as _345 from "./revshare/query.rpc.Query";
import * as _346 from "./rewards/query.rpc.Query";
import * as _347 from "./sending/query.rpc.Query";
import * as _348 from "./stats/query.rpc.Query";
import * as _349 from "./subaccounts/query.rpc.Query";
import * as _350 from "./vault/query.rpc.Query";
import * as _351 from "./vest/query.rpc.Query";
import * as _352 from "./blocktime/tx.rpc.msg";
import * as _353 from "./bridge/tx.rpc.msg";
import * as _354 from "./clob/tx.rpc.msg";
import * as _355 from "./delaymsg/tx.rpc.msg";
import * as _356 from "./feetiers/tx.rpc.msg";
import * as _357 from "./govplus/tx.rpc.msg";
import * as _358 from "./listing/tx.rpc.msg";
import * as _359 from "./perpetuals/tx.rpc.msg";
import * as _360 from "./prices/tx.rpc.msg";
import * as _361 from "./ratelimit/tx.rpc.msg";
import * as _362 from "./revshare/tx.rpc.msg";
import * as _363 from "./rewards/tx.rpc.msg";
import * as _364 from "./sending/tx.rpc.msg";
import * as _365 from "./stats/tx.rpc.msg";
import * as _366 from "./vault/tx.rpc.msg";
import * as _367 from "./vest/tx.rpc.msg";
import * as _371 from "./lcd";
import * as _372 from "./rpc.query";
import * as _373 from "./rpc.tx";
import * as _128 from "./assets/asset";
import * as _129 from "./assets/genesis";
import * as _130 from "./assets/query";
import * as _131 from "./assets/tx";
import * as _132 from "./blocktime/blocktime";
import * as _133 from "./blocktime/genesis";
import * as _134 from "./blocktime/params";
import * as _135 from "./blocktime/query";
import * as _136 from "./blocktime/tx";
import * as _137 from "./bridge/bridge_event_info";
import * as _138 from "./bridge/bridge_event";
import * as _139 from "./bridge/genesis";
import * as _140 from "./bridge/params";
import * as _141 from "./bridge/query";
import * as _142 from "./bridge/tx";
import * as _143 from "./clob/block_rate_limit_config";
import * as _144 from "./clob/clob_pair";
import * as _145 from "./clob/equity_tier_limit_config";
import * as _146 from "./clob/genesis";
import * as _147 from "./clob/liquidations_config";
import * as _148 from "./clob/liquidations";
import * as _149 from "./clob/matches";
import * as _150 from "./clob/mev";
import * as _151 from "./clob/operation";
import * as _152 from "./clob/order_removals";
import * as _153 from "./clob/order";
import * as _154 from "./clob/process_proposer_matches_events";
import * as _155 from "./clob/query";
import * as _156 from "./clob/tx";
import * as _157 from "./daemons/bridge/bridge";
import * as _158 from "./daemons/liquidation/liquidation";
import * as _159 from "./daemons/pricefeed/price_feed";
import * as _160 from "./delaymsg/block_message_ids";
import * as _161 from "./delaymsg/delayed_message";
import * as _162 from "./delaymsg/genesis";
import * as _163 from "./delaymsg/query";
import * as _164 from "./delaymsg/tx";
import * as _165 from "./epochs/epoch_info";
import * as _166 from "./epochs/genesis";
import * as _167 from "./epochs/query";
import * as _168 from "./feetiers/genesis";
import * as _169 from "./feetiers/params";
import * as _170 from "./feetiers/query";
import * as _171 from "./feetiers/tx";
import * as _172 from "./govplus/genesis";
import * as _173 from "./govplus/query";
import * as _174 from "./govplus/tx";
import * as _175 from "./indexer/events/events";
import * as _176 from "./indexer/indexer_manager/event";
import * as _177 from "./indexer/off_chain_updates/off_chain_updates";
import * as _178 from "./indexer/protocol/v1/clob";
import * as _179 from "./indexer/protocol/v1/perpetual";
import * as _180 from "./indexer/protocol/v1/subaccount";
import * as _181 from "./indexer/redis/redis_order";
import * as _182 from "./indexer/shared/removal_reason";
import * as _183 from "./indexer/socks/messages";
import * as _184 from "./perpetuals/genesis";
import * as _185 from "./perpetuals/params";
import * as _186 from "./perpetuals/perpetual";
import * as _187 from "./perpetuals/query";
import * as _188 from "./perpetuals/tx";
import * as _189 from "./prices/genesis";
import * as _190 from "./prices/market_param";
import * as _191 from "./prices/market_price";
import * as _192 from "./prices/query";
import * as _193 from "./prices/tx";
import * as _194 from "./ratelimit/capacity";
import * as _195 from "./ratelimit/genesis";
import * as _196 from "./ratelimit/limit_params";
import * as _197 from "./ratelimit/pending_send_packet";
import * as _198 from "./ratelimit/query";
import * as _199 from "./ratelimit/tx";
import * as _200 from "./rewards/genesis";
import * as _201 from "./rewards/params";
import * as _202 from "./rewards/query";
import * as _203 from "./rewards/reward_share";
import * as _204 from "./rewards/tx";
import * as _205 from "./sending/genesis";
import * as _206 from "./sending/query";
import * as _207 from "./sending/transfer";
import * as _208 from "./sending/tx";
import * as _209 from "./stats/genesis";
import * as _210 from "./stats/params";
import * as _211 from "./stats/query";
import * as _212 from "./stats/stats";
import * as _213 from "./stats/tx";
import * as _214 from "./subaccounts/asset_position";
import * as _215 from "./subaccounts/genesis";
import * as _216 from "./subaccounts/perpetual_position";
import * as _217 from "./subaccounts/query";
import * as _218 from "./subaccounts/subaccount";
import * as _219 from "./vault/genesis";
import * as _220 from "./vault/params";
import * as _221 from "./vault/query";
import * as _222 from "./vault/tx";
import * as _223 from "./vault/vault";
import * as _224 from "./vest/genesis";
import * as _225 from "./vest/query";
import * as _226 from "./vest/tx";
import * as _227 from "./vest/vest_entry";
import * as _306 from "./assets/query.lcd";
import * as _307 from "./blocktime/query.lcd";
import * as _308 from "./bridge/query.lcd";
import * as _309 from "./clob/query.lcd";
import * as _310 from "./delaymsg/query.lcd";
import * as _311 from "./epochs/query.lcd";
import * as _312 from "./feetiers/query.lcd";
import * as _313 from "./perpetuals/query.lcd";
import * as _314 from "./prices/query.lcd";
import * as _315 from "./ratelimit/query.lcd";
import * as _316 from "./rewards/query.lcd";
import * as _317 from "./stats/query.lcd";
import * as _318 from "./subaccounts/query.lcd";
import * as _319 from "./vault/query.lcd";
import * as _320 from "./vest/query.lcd";
import * as _321 from "./assets/query.rpc.Query";
import * as _322 from "./blocktime/query.rpc.Query";
import * as _323 from "./bridge/query.rpc.Query";
import * as _324 from "./clob/query.rpc.Query";
import * as _325 from "./delaymsg/query.rpc.Query";
import * as _326 from "./epochs/query.rpc.Query";
import * as _327 from "./feetiers/query.rpc.Query";
import * as _328 from "./govplus/query.rpc.Query";
import * as _329 from "./perpetuals/query.rpc.Query";
import * as _330 from "./prices/query.rpc.Query";
import * as _331 from "./ratelimit/query.rpc.Query";
import * as _332 from "./rewards/query.rpc.Query";
import * as _333 from "./sending/query.rpc.Query";
import * as _334 from "./stats/query.rpc.Query";
import * as _335 from "./subaccounts/query.rpc.Query";
import * as _336 from "./vault/query.rpc.Query";
import * as _337 from "./vest/query.rpc.Query";
import * as _338 from "./blocktime/tx.rpc.msg";
import * as _339 from "./bridge/tx.rpc.msg";
import * as _340 from "./clob/tx.rpc.msg";
import * as _341 from "./delaymsg/tx.rpc.msg";
import * as _342 from "./feetiers/tx.rpc.msg";
import * as _343 from "./govplus/tx.rpc.msg";
import * as _344 from "./perpetuals/tx.rpc.msg";
import * as _345 from "./prices/tx.rpc.msg";
import * as _346 from "./ratelimit/tx.rpc.msg";
import * as _347 from "./rewards/tx.rpc.msg";
import * as _348 from "./sending/tx.rpc.msg";
import * as _349 from "./stats/tx.rpc.msg";
import * as _350 from "./vault/tx.rpc.msg";
import * as _351 from "./vest/tx.rpc.msg";
import * as _355 from "./lcd";
import * as _356 from "./rpc.query";
import * as _357 from "./rpc.tx";
export namespace dydxprotocol {
export const accountplus = { ..._128,
..._129
export const assets = { ..._128,
..._129,
..._130,
..._131,
..._306,
..._321
};
export const assets = { ..._130,
..._131,
..._132,
export const blocktime = { ..._132,
..._133,
..._317,
..._333
};
export const blocktime = { ..._134,
..._134,
..._135,
..._136,
..._137,
..._307,
..._322,
..._338
};
export const bridge = { ..._137,
..._138,
..._318,
..._334,
..._352
};
export const bridge = { ..._139,
..._139,
..._140,
..._141,
..._142,
..._143,
..._308,
..._323,
..._339
};
export const clob = { ..._143,
..._144,
..._319,
..._335,
..._353
};
export const clob = { ..._145,
..._145,
..._146,

@@ -208,72 +191,73 @@ ..._147,

..._156,
..._157,
..._158,
..._320,
..._336,
..._354
..._309,
..._324,
..._340
};
export namespace daemons {
export const bridge = { ..._159
export const bridge = { ..._157
};
export const liquidation = { ..._160
export const liquidation = { ..._158
};
export const pricefeed = { ..._161
export const pricefeed = { ..._159
};
}
export const delaymsg = { ..._162,
export const delaymsg = { ..._160,
..._161,
..._162,
..._163,
..._164,
..._165,
..._310,
..._325,
..._341
};
export const epochs = { ..._165,
..._166,
..._321,
..._337,
..._355
..._167,
..._311,
..._326
};
export const epochs = { ..._167,
..._168,
export const feetiers = { ..._168,
..._169,
..._322,
..._338
..._170,
..._171,
..._312,
..._327,
..._342
};
export const feetiers = { ..._170,
..._171,
..._172,
export const govplus = { ..._172,
..._173,
..._323,
..._339,
..._356
..._174,
..._328,
..._343
};
export const govplus = { ..._174,
..._175,
..._176,
..._340,
..._357
};
export namespace indexer {
export const events = { ..._177
export const events = { ..._175
};
export const indexer_manager = { ..._178
export const indexer_manager = { ..._176
};
export const off_chain_updates = { ..._179
export const off_chain_updates = { ..._177
};
export namespace protocol {
export const v1 = { ..._180,
..._181,
..._182
export const v1 = { ..._178,
..._179,
..._180
};
}
export const redis = { ..._183
export const redis = { ..._181
};
export const shared = { ..._184
export const shared = { ..._182
};
export const socks = { ..._185
export const socks = { ..._183
};
}
export const listing = { ..._186,
export const perpetuals = { ..._184,
..._185,
..._186,
..._187,
..._188,
..._341,
..._358
..._313,
..._329,
..._344
};
export const perpetuals = { ..._189,
export const prices = { ..._189,
..._190,

@@ -283,7 +267,7 @@ ..._191,

..._193,
..._324,
..._342,
..._359
..._314,
..._330,
..._345
};
export const prices = { ..._194,
export const ratelimit = { ..._194,
..._195,

@@ -293,8 +277,8 @@ ..._196,

..._198,
..._325,
..._343,
..._360
..._199,
..._315,
..._331,
..._346
};
export const ratelimit = { ..._199,
..._200,
export const rewards = { ..._200,
..._201,

@@ -304,32 +288,31 @@ ..._202,

..._204,
..._326,
..._344,
..._361
..._316,
..._332,
..._347
};
export const revshare = { ..._205,
export const sending = { ..._205,
..._206,
..._207,
..._208,
..._209,
..._327,
..._345,
..._362
..._333,
..._348
};
export const rewards = { ..._210,
export const stats = { ..._209,
..._210,
..._211,
..._212,
..._213,
..._214,
..._328,
..._346,
..._363
..._317,
..._334,
..._349
};
export const sending = { ..._215,
export const subaccounts = { ..._214,
..._215,
..._216,
..._217,
..._218,
..._347,
..._364
..._318,
..._335
};
export const stats = { ..._219,
export const vault = { ..._219,
..._220,

@@ -339,36 +322,18 @@ ..._221,

..._223,
..._329,
..._348,
..._365
..._319,
..._336,
..._350
};
export const subaccounts = { ..._224,
export const vest = { ..._224,
..._225,
..._226,
..._227,
..._228,
..._330,
..._349
..._320,
..._337,
..._351
};
export const vault = { ..._229,
..._230,
..._231,
..._232,
..._233,
..._234,
..._331,
..._350,
..._366
export const ClientFactory = { ..._355,
..._356,
..._357
};
export const vest = { ..._235,
..._236,
..._237,
..._238,
..._332,
..._351,
..._367
};
export const ClientFactory = { ..._371,
..._372,
..._373
};
}

130

src/codegen/dydxprotocol/clob/order.ts
import { SubaccountId, SubaccountIdSDKType } from "../subaccounts/subaccount";
import { PerpetualLiquidationInfo, PerpetualLiquidationInfoSDKType } from "./liquidations";
import * as _m0 from "protobufjs/minimal";

@@ -89,4 +88,5 @@ import { DeepPartial, Long } from "../../helpers";

/**
* TIME_IN_FORCE_FILL_OR_KILL - TIME_IN_FORCE_FILL_OR_KILL has been deprecated and will be removed in
* future versions.
* TIME_IN_FORCE_FILL_OR_KILL - TIME_IN_FORCE_FILL_OR_KILL enforces that an order will either be filled
* completely and immediately by maker orders on the book or canceled if the
* entire amount can‘t be matched.
*/

@@ -515,42 +515,3 @@ TIME_IN_FORCE_FILL_OR_KILL = 3,

}
/**
* StreamLiquidationOrder represents an protocol-generated IOC liquidation
* order. Used in full node streaming.
*/
export interface StreamLiquidationOrder {
/** Information about this liquidation order. */
liquidationInfo?: PerpetualLiquidationInfo;
/**
* CLOB pair ID of the CLOB pair the liquidation order will be matched
* against.
*/
clobPairId: number;
/**
* True if this is a buy order liquidating a short position, false if vice
* versa.
*/
isBuy: boolean;
/** The number of base quantums for this liquidation order. */
quantums: Long;
/** The subticks this liquidation order will be submitted at. */
subticks: Long;
}
/**
* StreamLiquidationOrder represents an protocol-generated IOC liquidation
* order. Used in full node streaming.
*/
export interface StreamLiquidationOrderSDKType {
liquidation_info?: PerpetualLiquidationInfoSDKType;
clob_pair_id: number;
is_buy: boolean;
quantums: Long;
subticks: Long;
}
function createBaseOrderId(): OrderId {

@@ -1139,87 +1100,2 @@ return {

};
function createBaseStreamLiquidationOrder(): StreamLiquidationOrder {
return {
liquidationInfo: undefined,
clobPairId: 0,
isBuy: false,
quantums: Long.UZERO,
subticks: Long.UZERO
};
}
export const StreamLiquidationOrder = {
encode(message: StreamLiquidationOrder, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.liquidationInfo !== undefined) {
PerpetualLiquidationInfo.encode(message.liquidationInfo, writer.uint32(10).fork()).ldelim();
}
if (message.clobPairId !== 0) {
writer.uint32(16).uint32(message.clobPairId);
}
if (message.isBuy === true) {
writer.uint32(24).bool(message.isBuy);
}
if (!message.quantums.isZero()) {
writer.uint32(32).uint64(message.quantums);
}
if (!message.subticks.isZero()) {
writer.uint32(40).uint64(message.subticks);
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): StreamLiquidationOrder {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseStreamLiquidationOrder();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.liquidationInfo = PerpetualLiquidationInfo.decode(reader, reader.uint32());
break;
case 2:
message.clobPairId = reader.uint32();
break;
case 3:
message.isBuy = reader.bool();
break;
case 4:
message.quantums = (reader.uint64() as Long);
break;
case 5:
message.subticks = (reader.uint64() as Long);
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<StreamLiquidationOrder>): StreamLiquidationOrder {
const message = createBaseStreamLiquidationOrder();
message.liquidationInfo = object.liquidationInfo !== undefined && object.liquidationInfo !== null ? PerpetualLiquidationInfo.fromPartial(object.liquidationInfo) : undefined;
message.clobPairId = object.clobPairId ?? 0;
message.isBuy = object.isBuy ?? false;
message.quantums = object.quantums !== undefined && object.quantums !== null ? Long.fromValue(object.quantums) : Long.UZERO;
message.subticks = object.subticks !== undefined && object.subticks !== null ? Long.fromValue(object.subticks) : Long.UZERO;
return message;
}
};

507

src/codegen/dydxprotocol/clob/query.ts
import { PageRequest, PageRequestSDKType, PageResponse, PageResponseSDKType } from "../../cosmos/base/query/v1beta1/pagination";
import { ValidatorMevMatches, ValidatorMevMatchesSDKType, MevNodeToNodeMetrics, MevNodeToNodeMetricsSDKType } from "./mev";
import { OrderId, OrderIdSDKType, LongTermOrderPlacement, LongTermOrderPlacementSDKType, Order, OrderSDKType, StreamLiquidationOrder, StreamLiquidationOrderSDKType } from "./order";
import { SubaccountId, SubaccountIdSDKType } from "../subaccounts/subaccount";
import { OrderId, OrderIdSDKType, LongTermOrderPlacement, LongTermOrderPlacementSDKType, Order, OrderSDKType } from "./order";
import { ClobPair, ClobPairSDKType } from "./clob_pair";

@@ -240,5 +239,2 @@ import { EquityTierLimitConfiguration, EquityTierLimitConfigurationSDKType } from "./equity_tier_limit_config";

clobPairId: number[];
/** Subaccount ids to stream subaccount updates for. */
subaccountIds: SubaccountId[];
}

@@ -252,3 +248,2 @@ /**

clob_pair_id: number[];
subaccount_ids: SubaccountIdSDKType[];
}

@@ -280,4 +275,2 @@ /**

orderFill?: StreamOrderbookFill;
takerOrder?: StreamTakerOrder;
subaccountUpdate?: StreamSubaccountUpdate;
/** Block height of the update. */

@@ -298,4 +291,2 @@

order_fill?: StreamOrderbookFillSDKType;
taker_order?: StreamTakerOrderSDKType;
subaccount_update?: StreamSubaccountUpdateSDKType;
block_height: number;

@@ -305,80 +296,2 @@ exec_mode: number;

/**
* SubaccountPerpetualPosition provides information on a subaccount's updated
* perpetual positions.
*/
export interface SubaccountPerpetualPosition {
/** The `Id` of the `Perpetual`. */
perpetualId: number;
/** The size of the position in base quantums. */
quantums: Long;
}
/**
* SubaccountPerpetualPosition provides information on a subaccount's updated
* perpetual positions.
*/
export interface SubaccountPerpetualPositionSDKType {
perpetual_id: number;
quantums: Long;
}
/**
* SubaccountAssetPosition provides information on a subaccount's updated asset
* positions.
*/
export interface SubaccountAssetPosition {
/** The `Id` of the `Asset`. */
assetId: number;
/** The absolute size of the position in base quantums. */
quantums: Long;
}
/**
* SubaccountAssetPosition provides information on a subaccount's updated asset
* positions.
*/
export interface SubaccountAssetPositionSDKType {
asset_id: number;
quantums: Long;
}
/**
* StreamSubaccountUpdate provides information on a subaccount update. Used in
* the full node GRPC stream.
*/
export interface StreamSubaccountUpdate {
subaccountId?: SubaccountId;
/** updated_perpetual_positions will each be for unique perpetuals. */
updatedPerpetualPositions: SubaccountPerpetualPosition[];
/** updated_asset_positions will each be for unique assets. */
updatedAssetPositions: SubaccountAssetPosition[];
/**
* Snapshot indicates if the response is from a snapshot of the subaccount.
* All updates should be ignored until snapshot is received.
* If the snapshot is true, then all previous entries should be
* discarded and the subaccount should be resynced.
* For a snapshot subaccount update, the `updated_perpetual_positions` and
* `updated_asset_positions` fields will contain the full state of the
* subaccount.
*/
snapshot: boolean;
}
/**
* StreamSubaccountUpdate provides information on a subaccount update. Used in
* the full node GRPC stream.
*/
export interface StreamSubaccountUpdateSDKType {
subaccount_id?: SubaccountIdSDKType;
updated_perpetual_positions: SubaccountPerpetualPositionSDKType[];
updated_asset_positions: SubaccountAssetPositionSDKType[];
snapshot: boolean;
}
/**
* StreamOrderbookUpdate provides information on an orderbook update. Used in

@@ -443,67 +356,3 @@ * the full node GRPC stream.

}
/**
* StreamTakerOrder provides information on a taker order that was attempted
* to be matched on the orderbook.
* It is intended to be used only in full node streaming.
*/
export interface StreamTakerOrder {
order?: Order;
liquidationOrder?: StreamLiquidationOrder;
/**
* Information on the taker order after it is matched on the book,
* either successfully or unsuccessfully.
*/
takerOrderStatus?: StreamTakerOrderStatus;
}
/**
* StreamTakerOrder provides information on a taker order that was attempted
* to be matched on the orderbook.
* It is intended to be used only in full node streaming.
*/
export interface StreamTakerOrderSDKType {
order?: OrderSDKType;
liquidation_order?: StreamLiquidationOrderSDKType;
taker_order_status?: StreamTakerOrderStatusSDKType;
}
/**
* StreamTakerOrderStatus is a representation of a taker order
* after it is attempted to be matched on the orderbook.
* It is intended to be used only in full node streaming.
*/
export interface StreamTakerOrderStatus {
/**
* The state of the taker order after attempting to match it against the
* orderbook. Possible enum values can be found here:
* https://github.com/dydxprotocol/v4-chain/blob/main/protocol/x/clob/types/orderbook.go#L105
*/
orderStatus: number;
/** The amount of remaining (non-matched) base quantums of this taker order. */
remainingQuantums: Long;
/**
* The amount of base quantums that were *optimistically* filled for this
* taker order when the order is matched against the orderbook. Note that if
* any quantums of this order were optimistically filled or filled in state
* before this invocation of the matching loop, this value will not include
* them.
*/
optimisticallyFilledQuantums: Long;
}
/**
* StreamTakerOrderStatus is a representation of a taker order
* after it is attempted to be matched on the orderbook.
* It is intended to be used only in full node streaming.
*/
export interface StreamTakerOrderStatusSDKType {
order_status: number;
remaining_quantums: Long;
optimistically_filled_quantums: Long;
}
function createBaseQueryGetClobPairRequest(): QueryGetClobPairRequest {

@@ -1213,4 +1062,3 @@ return {

return {
clobPairId: [],
subaccountIds: []
clobPairId: []
};

@@ -1228,7 +1076,2 @@ }

writer.ldelim();
for (const v of message.subaccountIds) {
SubaccountId.encode(v!, writer.uint32(18).fork()).ldelim();
}
return writer;

@@ -1259,6 +1102,2 @@ },

case 2:
message.subaccountIds.push(SubaccountId.decode(reader, reader.uint32()));
break;
default:

@@ -1276,3 +1115,2 @@ reader.skipType(tag & 7);

message.clobPairId = object.clobPairId?.map(e => e) || [];
message.subaccountIds = object.subaccountIds?.map(e => SubaccountId.fromPartial(e)) || [];
return message;

@@ -1332,4 +1170,2 @@ }

orderFill: undefined,
takerOrder: undefined,
subaccountUpdate: undefined,
blockHeight: 0,

@@ -1350,16 +1186,8 @@ execMode: 0

if (message.takerOrder !== undefined) {
StreamTakerOrder.encode(message.takerOrder, writer.uint32(26).fork()).ldelim();
}
if (message.subaccountUpdate !== undefined) {
StreamSubaccountUpdate.encode(message.subaccountUpdate, writer.uint32(34).fork()).ldelim();
}
if (message.blockHeight !== 0) {
writer.uint32(40).uint32(message.blockHeight);
writer.uint32(24).uint32(message.blockHeight);
}
if (message.execMode !== 0) {
writer.uint32(48).uint32(message.execMode);
writer.uint32(32).uint32(message.execMode);
}

@@ -1388,14 +1216,6 @@

case 3:
message.takerOrder = StreamTakerOrder.decode(reader, reader.uint32());
message.blockHeight = reader.uint32();
break;
case 4:
message.subaccountUpdate = StreamSubaccountUpdate.decode(reader, reader.uint32());
break;
case 5:
message.blockHeight = reader.uint32();
break;
case 6:
message.execMode = reader.uint32();

@@ -1417,4 +1237,2 @@ break;

message.orderFill = object.orderFill !== undefined && object.orderFill !== null ? StreamOrderbookFill.fromPartial(object.orderFill) : undefined;
message.takerOrder = object.takerOrder !== undefined && object.takerOrder !== null ? StreamTakerOrder.fromPartial(object.takerOrder) : undefined;
message.subaccountUpdate = object.subaccountUpdate !== undefined && object.subaccountUpdate !== null ? StreamSubaccountUpdate.fromPartial(object.subaccountUpdate) : undefined;
message.blockHeight = object.blockHeight ?? 0;

@@ -1427,187 +1245,2 @@ message.execMode = object.execMode ?? 0;

function createBaseSubaccountPerpetualPosition(): SubaccountPerpetualPosition {
return {
perpetualId: 0,
quantums: Long.UZERO
};
}
export const SubaccountPerpetualPosition = {
encode(message: SubaccountPerpetualPosition, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.perpetualId !== 0) {
writer.uint32(8).uint32(message.perpetualId);
}
if (!message.quantums.isZero()) {
writer.uint32(16).uint64(message.quantums);
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): SubaccountPerpetualPosition {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseSubaccountPerpetualPosition();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.perpetualId = reader.uint32();
break;
case 2:
message.quantums = (reader.uint64() as Long);
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<SubaccountPerpetualPosition>): SubaccountPerpetualPosition {
const message = createBaseSubaccountPerpetualPosition();
message.perpetualId = object.perpetualId ?? 0;
message.quantums = object.quantums !== undefined && object.quantums !== null ? Long.fromValue(object.quantums) : Long.UZERO;
return message;
}
};
function createBaseSubaccountAssetPosition(): SubaccountAssetPosition {
return {
assetId: 0,
quantums: Long.UZERO
};
}
export const SubaccountAssetPosition = {
encode(message: SubaccountAssetPosition, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.assetId !== 0) {
writer.uint32(8).uint32(message.assetId);
}
if (!message.quantums.isZero()) {
writer.uint32(16).uint64(message.quantums);
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): SubaccountAssetPosition {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseSubaccountAssetPosition();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.assetId = reader.uint32();
break;
case 2:
message.quantums = (reader.uint64() as Long);
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<SubaccountAssetPosition>): SubaccountAssetPosition {
const message = createBaseSubaccountAssetPosition();
message.assetId = object.assetId ?? 0;
message.quantums = object.quantums !== undefined && object.quantums !== null ? Long.fromValue(object.quantums) : Long.UZERO;
return message;
}
};
function createBaseStreamSubaccountUpdate(): StreamSubaccountUpdate {
return {
subaccountId: undefined,
updatedPerpetualPositions: [],
updatedAssetPositions: [],
snapshot: false
};
}
export const StreamSubaccountUpdate = {
encode(message: StreamSubaccountUpdate, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.subaccountId !== undefined) {
SubaccountId.encode(message.subaccountId, writer.uint32(10).fork()).ldelim();
}
for (const v of message.updatedPerpetualPositions) {
SubaccountPerpetualPosition.encode(v!, writer.uint32(18).fork()).ldelim();
}
for (const v of message.updatedAssetPositions) {
SubaccountAssetPosition.encode(v!, writer.uint32(26).fork()).ldelim();
}
if (message.snapshot === true) {
writer.uint32(32).bool(message.snapshot);
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): StreamSubaccountUpdate {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseStreamSubaccountUpdate();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.subaccountId = SubaccountId.decode(reader, reader.uint32());
break;
case 2:
message.updatedPerpetualPositions.push(SubaccountPerpetualPosition.decode(reader, reader.uint32()));
break;
case 3:
message.updatedAssetPositions.push(SubaccountAssetPosition.decode(reader, reader.uint32()));
break;
case 4:
message.snapshot = reader.bool();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<StreamSubaccountUpdate>): StreamSubaccountUpdate {
const message = createBaseStreamSubaccountUpdate();
message.subaccountId = object.subaccountId !== undefined && object.subaccountId !== null ? SubaccountId.fromPartial(object.subaccountId) : undefined;
message.updatedPerpetualPositions = object.updatedPerpetualPositions?.map(e => SubaccountPerpetualPosition.fromPartial(e)) || [];
message.updatedAssetPositions = object.updatedAssetPositions?.map(e => SubaccountAssetPosition.fromPartial(e)) || [];
message.snapshot = object.snapshot ?? false;
return message;
}
};
function createBaseStreamOrderbookUpdate(): StreamOrderbookUpdate {

@@ -1743,132 +1376,2 @@ return {

};
function createBaseStreamTakerOrder(): StreamTakerOrder {
return {
order: undefined,
liquidationOrder: undefined,
takerOrderStatus: undefined
};
}
export const StreamTakerOrder = {
encode(message: StreamTakerOrder, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.order !== undefined) {
Order.encode(message.order, writer.uint32(10).fork()).ldelim();
}
if (message.liquidationOrder !== undefined) {
StreamLiquidationOrder.encode(message.liquidationOrder, writer.uint32(18).fork()).ldelim();
}
if (message.takerOrderStatus !== undefined) {
StreamTakerOrderStatus.encode(message.takerOrderStatus, writer.uint32(26).fork()).ldelim();
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): StreamTakerOrder {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseStreamTakerOrder();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.order = Order.decode(reader, reader.uint32());
break;
case 2:
message.liquidationOrder = StreamLiquidationOrder.decode(reader, reader.uint32());
break;
case 3:
message.takerOrderStatus = StreamTakerOrderStatus.decode(reader, reader.uint32());
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<StreamTakerOrder>): StreamTakerOrder {
const message = createBaseStreamTakerOrder();
message.order = object.order !== undefined && object.order !== null ? Order.fromPartial(object.order) : undefined;
message.liquidationOrder = object.liquidationOrder !== undefined && object.liquidationOrder !== null ? StreamLiquidationOrder.fromPartial(object.liquidationOrder) : undefined;
message.takerOrderStatus = object.takerOrderStatus !== undefined && object.takerOrderStatus !== null ? StreamTakerOrderStatus.fromPartial(object.takerOrderStatus) : undefined;
return message;
}
};
function createBaseStreamTakerOrderStatus(): StreamTakerOrderStatus {
return {
orderStatus: 0,
remainingQuantums: Long.UZERO,
optimisticallyFilledQuantums: Long.UZERO
};
}
export const StreamTakerOrderStatus = {
encode(message: StreamTakerOrderStatus, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.orderStatus !== 0) {
writer.uint32(8).uint32(message.orderStatus);
}
if (!message.remainingQuantums.isZero()) {
writer.uint32(16).uint64(message.remainingQuantums);
}
if (!message.optimisticallyFilledQuantums.isZero()) {
writer.uint32(24).uint64(message.optimisticallyFilledQuantums);
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): StreamTakerOrderStatus {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseStreamTakerOrderStatus();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.orderStatus = reader.uint32();
break;
case 2:
message.remainingQuantums = (reader.uint64() as Long);
break;
case 3:
message.optimisticallyFilledQuantums = (reader.uint64() as Long);
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<StreamTakerOrderStatus>): StreamTakerOrderStatus {
const message = createBaseStreamTakerOrderStatus();
message.orderStatus = object.orderStatus ?? 0;
message.remainingQuantums = object.remainingQuantums !== undefined && object.remainingQuantums !== null ? Long.fromValue(object.remainingQuantums) : Long.UZERO;
message.optimisticallyFilledQuantums = object.optimisticallyFilledQuantums !== undefined && object.optimisticallyFilledQuantums !== null ? Long.fromValue(object.optimisticallyFilledQuantums) : Long.UZERO;
return message;
}
};

84

src/codegen/dydxprotocol/indexer/socks/messages.ts

@@ -208,22 +208,3 @@ import { IndexerSubaccountId, IndexerSubaccountIdSDKType } from "../protocol/v1/subaccount";

}
/** Message to be sent through the 'to-websockets-block-height` kafka topic. */
export interface BlockHeightMessage {
/** Block height where the contents occur. */
blockHeight: string;
/** ISO formatted time of the block height. */
time: string;
/** Version of the websocket message. */
version: string;
}
/** Message to be sent through the 'to-websockets-block-height` kafka topic. */
export interface BlockHeightMessageSDKType {
block_height: string;
time: string;
version: string;
}
function createBaseOrderbookMessage(): OrderbookMessage {

@@ -592,67 +573,2 @@ return {

};
function createBaseBlockHeightMessage(): BlockHeightMessage {
return {
blockHeight: "",
time: "",
version: ""
};
}
export const BlockHeightMessage = {
encode(message: BlockHeightMessage, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.blockHeight !== "") {
writer.uint32(10).string(message.blockHeight);
}
if (message.time !== "") {
writer.uint32(18).string(message.time);
}
if (message.version !== "") {
writer.uint32(26).string(message.version);
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): BlockHeightMessage {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseBlockHeightMessage();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.blockHeight = reader.string();
break;
case 2:
message.time = reader.string();
break;
case 3:
message.version = reader.string();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<BlockHeightMessage>): BlockHeightMessage {
const message = createBaseBlockHeightMessage();
message.blockHeight = object.blockHeight ?? "";
message.time = object.time ?? "";
message.version = object.version ?? "";
return message;
}
};

3

src/codegen/dydxprotocol/lcd.ts

@@ -144,5 +144,2 @@ import { LCDClient } from "@osmonauts/lcd";

}),
revshare: new (await import("./revshare/query.lcd")).LCDQueryClient({
requestClient
}),
rewards: new (await import("./rewards/query.lcd")).LCDQueryClient({

@@ -149,0 +146,0 @@ requestClient

2

src/codegen/dydxprotocol/rpc.query.ts

@@ -90,7 +90,5 @@ import { Tendermint34Client, HttpEndpoint } from "@cosmjs/tendermint-rpc";

govplus: (await import("./govplus/query.rpc.Query")).createRpcQueryExtension(client),
listing: (await import("./listing/query.rpc.Query")).createRpcQueryExtension(client),
perpetuals: (await import("./perpetuals/query.rpc.Query")).createRpcQueryExtension(client),
prices: (await import("./prices/query.rpc.Query")).createRpcQueryExtension(client),
ratelimit: (await import("./ratelimit/query.rpc.Query")).createRpcQueryExtension(client),
revshare: (await import("./revshare/query.rpc.Query")).createRpcQueryExtension(client),
rewards: (await import("./rewards/query.rpc.Query")).createRpcQueryExtension(client),

@@ -97,0 +95,0 @@ sending: (await import("./sending/query.rpc.Query")).createRpcQueryExtension(client),

2

src/codegen/dydxprotocol/rpc.tx.ts

@@ -68,7 +68,5 @@ import { Rpc } from "../helpers";

govplus: new (await import("./govplus/tx.rpc.msg")).MsgClientImpl(rpc),
listing: new (await import("./listing/tx.rpc.msg")).MsgClientImpl(rpc),
perpetuals: new (await import("./perpetuals/tx.rpc.msg")).MsgClientImpl(rpc),
prices: new (await import("./prices/tx.rpc.msg")).MsgClientImpl(rpc),
ratelimit: new (await import("./ratelimit/tx.rpc.msg")).MsgClientImpl(rpc),
revshare: new (await import("./revshare/tx.rpc.msg")).MsgClientImpl(rpc),
rewards: new (await import("./rewards/tx.rpc.msg")).MsgClientImpl(rpc),

@@ -75,0 +73,0 @@ sending: new (await import("./sending/tx.rpc.msg")).MsgClientImpl(rpc),

16

src/codegen/dydxprotocol/subaccounts/perpetual_position.ts

@@ -20,5 +20,2 @@ import * as _m0 from "protobufjs/minimal";

fundingIndex: Uint8Array;
/** The quote_balance of the `Perpetual`. */
quoteBalance: Uint8Array;
}

@@ -34,3 +31,2 @@ /**

funding_index: Uint8Array;
quote_balance: Uint8Array;
}

@@ -42,4 +38,3 @@

quantums: new Uint8Array(),
fundingIndex: new Uint8Array(),
quoteBalance: new Uint8Array()
fundingIndex: new Uint8Array()
};

@@ -62,6 +57,2 @@ }

if (message.quoteBalance.length !== 0) {
writer.uint32(34).bytes(message.quoteBalance);
}
return writer;

@@ -91,6 +82,2 @@ },

case 4:
message.quoteBalance = reader.bytes();
break;
default:

@@ -110,3 +97,2 @@ reader.skipType(tag & 7);

message.fundingIndex = object.fundingIndex ?? new Uint8Array();
message.quoteBalance = object.quoteBalance ?? new Uint8Array();
return message;

@@ -113,0 +99,0 @@ }

51

src/codegen/dydxprotocol/vault/genesis.ts

@@ -1,4 +0,3 @@

import { QuotingParams, QuotingParamsSDKType } from "./params";
import { VaultId, VaultIdSDKType } from "./vault";
import { NumShares, NumSharesSDKType, OwnerShare, OwnerShareSDKType } from "./share";
import { Params, ParamsSDKType } from "./params";
import { VaultId, VaultIdSDKType, NumShares, NumSharesSDKType, OwnerShare, OwnerShareSDKType, VaultParams, VaultParamsSDKType } from "./vault";
import * as _m0 from "protobufjs/minimal";

@@ -9,7 +8,7 @@ import { DeepPartial } from "../../helpers";

export interface GenesisState {
/** The parameters of the module. */
params?: Params;
/** The vaults. */
vaults: Vault[];
/** The default quoting parameters for all vaults. */
defaultQuotingParams?: QuotingParams;
}

@@ -19,4 +18,4 @@ /** GenesisState defines `x/vault`'s genesis state. */

export interface GenesisStateSDKType {
params?: ParamsSDKType;
vaults: VaultSDKType[];
default_quoting_params?: QuotingParamsSDKType;
}

@@ -34,5 +33,5 @@ /** Vault defines the total shares and owner shares of a vault. */

ownerShares: OwnerShare[];
/** The quoting parameters of the vault. */
/** The individual parameters of the vault. */
quotingParams?: QuotingParams;
vaultParams?: VaultParams;
/** The client IDs of the most recently placed orders of the vault. */

@@ -48,3 +47,3 @@

owner_shares: OwnerShareSDKType[];
quoting_params?: QuotingParamsSDKType;
vault_params?: VaultParamsSDKType;
most_recent_client_ids: number[];

@@ -55,4 +54,4 @@ }

return {
vaults: [],
defaultQuotingParams: undefined
params: undefined,
vaults: []
};

@@ -63,2 +62,6 @@ }

encode(message: GenesisState, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.params !== undefined) {
Params.encode(message.params, writer.uint32(10).fork()).ldelim();
}
for (const v of message.vaults) {

@@ -68,6 +71,2 @@ Vault.encode(v!, writer.uint32(18).fork()).ldelim();

if (message.defaultQuotingParams !== undefined) {
QuotingParams.encode(message.defaultQuotingParams, writer.uint32(26).fork()).ldelim();
}
return writer;

@@ -85,2 +84,6 @@ },

switch (tag >>> 3) {
case 1:
message.params = Params.decode(reader, reader.uint32());
break;
case 2:

@@ -90,6 +93,2 @@ message.vaults.push(Vault.decode(reader, reader.uint32()));

case 3:
message.defaultQuotingParams = QuotingParams.decode(reader, reader.uint32());
break;
default:

@@ -106,4 +105,4 @@ reader.skipType(tag & 7);

const message = createBaseGenesisState();
message.params = object.params !== undefined && object.params !== null ? Params.fromPartial(object.params) : undefined;
message.vaults = object.vaults?.map(e => Vault.fromPartial(e)) || [];
message.defaultQuotingParams = object.defaultQuotingParams !== undefined && object.defaultQuotingParams !== null ? QuotingParams.fromPartial(object.defaultQuotingParams) : undefined;
return message;

@@ -119,3 +118,3 @@ }

ownerShares: [],
quotingParams: undefined,
vaultParams: undefined,
mostRecentClientIds: []

@@ -139,4 +138,4 @@ };

if (message.quotingParams !== undefined) {
QuotingParams.encode(message.quotingParams, writer.uint32(34).fork()).ldelim();
if (message.vaultParams !== undefined) {
VaultParams.encode(message.vaultParams, writer.uint32(34).fork()).ldelim();
}

@@ -176,3 +175,3 @@

case 4:
message.quotingParams = QuotingParams.decode(reader, reader.uint32());
message.vaultParams = VaultParams.decode(reader, reader.uint32());
break;

@@ -207,3 +206,3 @@

message.ownerShares = object.ownerShares?.map(e => OwnerShare.fromPartial(e)) || [];
message.quotingParams = object.quotingParams !== undefined && object.quotingParams !== null ? QuotingParams.fromPartial(object.quotingParams) : undefined;
message.vaultParams = object.vaultParams !== undefined && object.vaultParams !== null ? VaultParams.fromPartial(object.vaultParams) : undefined;
message.mostRecentClientIds = object.mostRecentClientIds?.map(e => e) || [];

@@ -210,0 +209,0 @@ return message;

162

src/codegen/dydxprotocol/vault/params.ts
import * as _m0 from "protobufjs/minimal";
import { DeepPartial } from "../../helpers";
/** QuotingParams stores vault quoting parameters. */
/** Params stores `x/vault` parameters. */
export interface QuotingParams {
/**
* The number of layers of orders a vault places. For example if
* `layers=2`, a vault places 2 asks and 2 bids.
*/
layers: number;
/** The minimum base spread when a vault quotes around reservation price. */
spreadMinPpm: number;
/**
* The buffer amount to add to min_price_change_ppm to arrive at `spread`
* according to formula:
* `spread = max(spread_min_ppm, min_price_change_ppm + spread_buffer_ppm)`.
*/
spreadBufferPpm: number;
/** The factor that determines how aggressive a vault skews its orders. */
skewFactorPpm: number;
/** The percentage of vault equity that each order is sized at. */
orderSizePctPpm: number;
/** The duration that a vault's orders are valid for. */
orderExpirationSeconds: number;
/**
* The number of quote quantums in quote asset that a vault with no perpetual
* positions must have to activate, i.e. if a vault has no perpetual positions
* and has strictly less than this amount of quote asset, it will not
* activate.
*/
activationThresholdQuoteQuantums: Uint8Array;
}
/** QuotingParams stores vault quoting parameters. */
export interface QuotingParamsSDKType {
layers: number;
spread_min_ppm: number;
spread_buffer_ppm: number;
skew_factor_ppm: number;
order_size_pct_ppm: number;
order_expiration_seconds: number;
activation_threshold_quote_quantums: Uint8Array;
}
/**
* Deprecated: Params stores `x/vault` parameters.
* Deprecated since v6.x as is replaced by QuotingParams.
*/
export interface Params {

@@ -89,6 +39,3 @@ /**

}
/**
* Deprecated: Params stores `x/vault` parameters.
* Deprecated since v6.x as is replaced by QuotingParams.
*/
/** Params stores `x/vault` parameters. */

@@ -105,107 +52,2 @@ export interface ParamsSDKType {

function createBaseQuotingParams(): QuotingParams {
return {
layers: 0,
spreadMinPpm: 0,
spreadBufferPpm: 0,
skewFactorPpm: 0,
orderSizePctPpm: 0,
orderExpirationSeconds: 0,
activationThresholdQuoteQuantums: new Uint8Array()
};
}
export const QuotingParams = {
encode(message: QuotingParams, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.layers !== 0) {
writer.uint32(8).uint32(message.layers);
}
if (message.spreadMinPpm !== 0) {
writer.uint32(16).uint32(message.spreadMinPpm);
}
if (message.spreadBufferPpm !== 0) {
writer.uint32(24).uint32(message.spreadBufferPpm);
}
if (message.skewFactorPpm !== 0) {
writer.uint32(32).uint32(message.skewFactorPpm);
}
if (message.orderSizePctPpm !== 0) {
writer.uint32(40).uint32(message.orderSizePctPpm);
}
if (message.orderExpirationSeconds !== 0) {
writer.uint32(48).uint32(message.orderExpirationSeconds);
}
if (message.activationThresholdQuoteQuantums.length !== 0) {
writer.uint32(58).bytes(message.activationThresholdQuoteQuantums);
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): QuotingParams {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseQuotingParams();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.layers = reader.uint32();
break;
case 2:
message.spreadMinPpm = reader.uint32();
break;
case 3:
message.spreadBufferPpm = reader.uint32();
break;
case 4:
message.skewFactorPpm = reader.uint32();
break;
case 5:
message.orderSizePctPpm = reader.uint32();
break;
case 6:
message.orderExpirationSeconds = reader.uint32();
break;
case 7:
message.activationThresholdQuoteQuantums = reader.bytes();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<QuotingParams>): QuotingParams {
const message = createBaseQuotingParams();
message.layers = object.layers ?? 0;
message.spreadMinPpm = object.spreadMinPpm ?? 0;
message.spreadBufferPpm = object.spreadBufferPpm ?? 0;
message.skewFactorPpm = object.skewFactorPpm ?? 0;
message.orderSizePctPpm = object.orderSizePctPpm ?? 0;
message.orderExpirationSeconds = object.orderExpirationSeconds ?? 0;
message.activationThresholdQuoteQuantums = object.activationThresholdQuoteQuantums ?? new Uint8Array();
return message;
}
};
function createBaseParams(): Params {

@@ -212,0 +54,0 @@ return {

37

src/codegen/dydxprotocol/vault/query.ts

@@ -1,6 +0,5 @@

import { VaultType, VaultId, VaultIdSDKType } from "./vault";
import { VaultType, VaultId, VaultIdSDKType, NumShares, NumSharesSDKType, OwnerShare, OwnerShareSDKType } from "./vault";
import { PageRequest, PageRequestSDKType, PageResponse, PageResponseSDKType } from "../../cosmos/base/query/v1beta1/pagination";
import { Params, ParamsSDKType, QuotingParams, QuotingParamsSDKType } from "./params";
import { Params, ParamsSDKType } from "./params";
import { SubaccountId, SubaccountIdSDKType } from "../subaccounts/subaccount";
import { NumShares, NumSharesSDKType, OwnerShare, OwnerShareSDKType } from "./share";
import * as _m0 from "protobufjs/minimal";

@@ -17,7 +16,3 @@ import { DeepPartial } from "../../helpers";

export interface QueryParamsResponse {
/** Deprecated since v6.x in favor of default_quoting_params. */
/** @deprecated */
params?: Params;
defaultQuotingParams?: QuotingParams;
}

@@ -27,5 +22,3 @@ /** QueryParamsResponse is a response type for the Params RPC method. */

export interface QueryParamsResponseSDKType {
/** @deprecated */
params?: ParamsSDKType;
default_quoting_params?: QuotingParamsSDKType;
}

@@ -52,3 +45,2 @@ /** QueryVaultRequest is a request type for the Vault RPC method. */

totalShares?: NumShares;
quotingParams?: QuotingParams;
}

@@ -63,3 +55,2 @@ /** QueryVaultResponse is a response type for the Vault RPC method. */

total_shares?: NumSharesSDKType;
quoting_params?: QuotingParamsSDKType;
}

@@ -151,4 +142,3 @@ /** QueryAllVaultsRequest is a request type for the AllVaults RPC method. */

return {
params: undefined,
defaultQuotingParams: undefined
params: undefined
};

@@ -163,6 +153,2 @@ }

if (message.defaultQuotingParams !== undefined) {
QuotingParams.encode(message.defaultQuotingParams, writer.uint32(18).fork()).ldelim();
}
return writer;

@@ -184,6 +170,2 @@ },

case 2:
message.defaultQuotingParams = QuotingParams.decode(reader, reader.uint32());
break;
default:

@@ -201,3 +183,2 @@ reader.skipType(tag & 7);

message.params = object.params !== undefined && object.params !== null ? Params.fromPartial(object.params) : undefined;
message.defaultQuotingParams = object.defaultQuotingParams !== undefined && object.defaultQuotingParams !== null ? QuotingParams.fromPartial(object.defaultQuotingParams) : undefined;
return message;

@@ -269,4 +250,3 @@ }

inventory: new Uint8Array(),
totalShares: undefined,
quotingParams: undefined
totalShares: undefined
};

@@ -297,6 +277,2 @@ }

if (message.quotingParams !== undefined) {
QuotingParams.encode(message.quotingParams, writer.uint32(50).fork()).ldelim();
}
return writer;

@@ -334,6 +310,2 @@ },

case 6:
message.quotingParams = QuotingParams.decode(reader, reader.uint32());
break;
default:

@@ -355,3 +327,2 @@ reader.skipType(tag & 7);

message.totalShares = object.totalShares !== undefined && object.totalShares !== null ? NumShares.fromPartial(object.totalShares) : undefined;
message.quotingParams = object.quotingParams !== undefined && object.quotingParams !== null ? QuotingParams.fromPartial(object.quotingParams) : undefined;
return message;

@@ -358,0 +329,0 @@ }

26

src/codegen/dydxprotocol/vault/tx.rpc.msg.ts
import { Rpc } from "../../helpers";
import * as _m0 from "protobufjs/minimal";
import { MsgDepositToVault, MsgDepositToVaultResponse, MsgUpdateDefaultQuotingParams, MsgUpdateDefaultQuotingParamsResponse, MsgSetVaultQuotingParams, MsgSetVaultQuotingParamsResponse } from "./tx";
import { MsgDepositToVault, MsgDepositToVaultResponse, MsgUpdateParams, MsgUpdateParamsResponse } from "./tx";
/** Msg defines the Msg service. */

@@ -9,8 +9,5 @@

depositToVault(request: MsgDepositToVault): Promise<MsgDepositToVaultResponse>;
/** UpdateDefaultQuotingParams updates the default quoting params in state. */
/** UpdateParams updates the Params in state. */
updateDefaultQuotingParams(request: MsgUpdateDefaultQuotingParams): Promise<MsgUpdateDefaultQuotingParamsResponse>;
/** SetVaultQuotingParams sets the quoting parameters of a specific vault. */
setVaultQuotingParams(request: MsgSetVaultQuotingParams): Promise<MsgSetVaultQuotingParamsResponse>;
updateParams(request: MsgUpdateParams): Promise<MsgUpdateParamsResponse>;
}

@@ -23,4 +20,3 @@ export class MsgClientImpl implements Msg {

this.depositToVault = this.depositToVault.bind(this);
this.updateDefaultQuotingParams = this.updateDefaultQuotingParams.bind(this);
this.setVaultQuotingParams = this.setVaultQuotingParams.bind(this);
this.updateParams = this.updateParams.bind(this);
}

@@ -34,14 +30,8 @@

updateDefaultQuotingParams(request: MsgUpdateDefaultQuotingParams): Promise<MsgUpdateDefaultQuotingParamsResponse> {
const data = MsgUpdateDefaultQuotingParams.encode(request).finish();
const promise = this.rpc.request("dydxprotocol.vault.Msg", "UpdateDefaultQuotingParams", data);
return promise.then(data => MsgUpdateDefaultQuotingParamsResponse.decode(new _m0.Reader(data)));
updateParams(request: MsgUpdateParams): Promise<MsgUpdateParamsResponse> {
const data = MsgUpdateParams.encode(request).finish();
const promise = this.rpc.request("dydxprotocol.vault.Msg", "UpdateParams", data);
return promise.then(data => MsgUpdateParamsResponse.decode(new _m0.Reader(data)));
}
setVaultQuotingParams(request: MsgSetVaultQuotingParams): Promise<MsgSetVaultQuotingParamsResponse> {
const data = MsgSetVaultQuotingParams.encode(request).finish();
const promise = this.rpc.request("dydxprotocol.vault.Msg", "SetVaultQuotingParams", data);
return promise.then(data => MsgSetVaultQuotingParamsResponse.decode(new _m0.Reader(data)));
}
}

203

src/codegen/dydxprotocol/vault/tx.ts
import { VaultId, VaultIdSDKType } from "./vault";
import { SubaccountId, SubaccountIdSDKType } from "../subaccounts/subaccount";
import { QuotingParams, QuotingParamsSDKType } from "./params";
import { Params, ParamsSDKType } from "./params";
import * as _m0 from "protobufjs/minimal";

@@ -37,65 +37,23 @@ import { DeepPartial } from "../../helpers";

export interface MsgDepositToVaultResponseSDKType {}
/**
* MsgUpdateDefaultQuotingParams is the Msg/UpdateDefaultQuotingParams request
* type.
*/
/** MsgUpdateParams is the Msg/UpdateParams request type. */
export interface MsgUpdateDefaultQuotingParams {
export interface MsgUpdateParams {
authority: string;
/** The quoting parameters to update to. Every field must be set. */
/** The parameters to update. Each field must be set. */
defaultQuotingParams?: QuotingParams;
params?: Params;
}
/**
* MsgUpdateDefaultQuotingParams is the Msg/UpdateDefaultQuotingParams request
* type.
*/
/** MsgUpdateParams is the Msg/UpdateParams request type. */
export interface MsgUpdateDefaultQuotingParamsSDKType {
export interface MsgUpdateParamsSDKType {
authority: string;
default_quoting_params?: QuotingParamsSDKType;
params?: ParamsSDKType;
}
/**
* MsgUpdateDefaultQuotingParamsResponse is the Msg/UpdateDefaultQuotingParams
* response type.
*/
/** MsgUpdateParamsResponse is the Msg/UpdateParams response type. */
export interface MsgUpdateDefaultQuotingParamsResponse {}
/**
* MsgUpdateDefaultQuotingParamsResponse is the Msg/UpdateDefaultQuotingParams
* response type.
*/
export interface MsgUpdateParamsResponse {}
/** MsgUpdateParamsResponse is the Msg/UpdateParams response type. */
export interface MsgUpdateDefaultQuotingParamsResponseSDKType {}
/** MsgSetVaultQuotingParams is the Msg/SetVaultQuotingParams request type. */
export interface MsgUpdateParamsResponseSDKType {}
export interface MsgSetVaultQuotingParams {
authority: string;
/** The vault to set quoting params of. */
vaultId?: VaultId;
/** The quoting parameters to set. Each field must be set. */
quotingParams?: QuotingParams;
}
/** MsgSetVaultQuotingParams is the Msg/SetVaultQuotingParams request type. */
export interface MsgSetVaultQuotingParamsSDKType {
authority: string;
vault_id?: VaultIdSDKType;
quoting_params?: QuotingParamsSDKType;
}
/**
* MsgSetVaultQuotingParamsResponse is the Msg/SetVaultQuotingParams response
* type.
*/
export interface MsgSetVaultQuotingParamsResponse {}
/**
* MsgSetVaultQuotingParamsResponse is the Msg/SetVaultQuotingParams response
* type.
*/
export interface MsgSetVaultQuotingParamsResponseSDKType {}
function createBaseMsgDepositToVault(): MsgDepositToVault {

@@ -200,11 +158,11 @@ return {

function createBaseMsgUpdateDefaultQuotingParams(): MsgUpdateDefaultQuotingParams {
function createBaseMsgUpdateParams(): MsgUpdateParams {
return {
authority: "",
defaultQuotingParams: undefined
params: undefined
};
}
export const MsgUpdateDefaultQuotingParams = {
encode(message: MsgUpdateDefaultQuotingParams, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
export const MsgUpdateParams = {
encode(message: MsgUpdateParams, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.authority !== "") {

@@ -214,4 +172,4 @@ writer.uint32(10).string(message.authority);

if (message.defaultQuotingParams !== undefined) {
QuotingParams.encode(message.defaultQuotingParams, writer.uint32(18).fork()).ldelim();
if (message.params !== undefined) {
Params.encode(message.params, writer.uint32(18).fork()).ldelim();
}

@@ -222,6 +180,6 @@

decode(input: _m0.Reader | Uint8Array, length?: number): MsgUpdateDefaultQuotingParams {
decode(input: _m0.Reader | Uint8Array, length?: number): MsgUpdateParams {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseMsgUpdateDefaultQuotingParams();
const message = createBaseMsgUpdateParams();

@@ -237,3 +195,3 @@ while (reader.pos < end) {

case 2:
message.defaultQuotingParams = QuotingParams.decode(reader, reader.uint32());
message.params = Params.decode(reader, reader.uint32());
break;

@@ -250,6 +208,6 @@

fromPartial(object: DeepPartial<MsgUpdateDefaultQuotingParams>): MsgUpdateDefaultQuotingParams {
const message = createBaseMsgUpdateDefaultQuotingParams();
fromPartial(object: DeepPartial<MsgUpdateParams>): MsgUpdateParams {
const message = createBaseMsgUpdateParams();
message.authority = object.authority ?? "";
message.defaultQuotingParams = object.defaultQuotingParams !== undefined && object.defaultQuotingParams !== null ? QuotingParams.fromPartial(object.defaultQuotingParams) : undefined;
message.params = object.params !== undefined && object.params !== null ? Params.fromPartial(object.params) : undefined;
return message;

@@ -260,15 +218,15 @@ }

function createBaseMsgUpdateDefaultQuotingParamsResponse(): MsgUpdateDefaultQuotingParamsResponse {
function createBaseMsgUpdateParamsResponse(): MsgUpdateParamsResponse {
return {};
}
export const MsgUpdateDefaultQuotingParamsResponse = {
encode(_: MsgUpdateDefaultQuotingParamsResponse, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
export const MsgUpdateParamsResponse = {
encode(_: MsgUpdateParamsResponse, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): MsgUpdateDefaultQuotingParamsResponse {
decode(input: _m0.Reader | Uint8Array, length?: number): MsgUpdateParamsResponse {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseMsgUpdateDefaultQuotingParamsResponse();
const message = createBaseMsgUpdateParamsResponse();

@@ -288,106 +246,7 @@ while (reader.pos < end) {

fromPartial(_: DeepPartial<MsgUpdateDefaultQuotingParamsResponse>): MsgUpdateDefaultQuotingParamsResponse {
const message = createBaseMsgUpdateDefaultQuotingParamsResponse();
fromPartial(_: DeepPartial<MsgUpdateParamsResponse>): MsgUpdateParamsResponse {
const message = createBaseMsgUpdateParamsResponse();
return message;
}
};
function createBaseMsgSetVaultQuotingParams(): MsgSetVaultQuotingParams {
return {
authority: "",
vaultId: undefined,
quotingParams: undefined
};
}
export const MsgSetVaultQuotingParams = {
encode(message: MsgSetVaultQuotingParams, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.authority !== "") {
writer.uint32(10).string(message.authority);
}
if (message.vaultId !== undefined) {
VaultId.encode(message.vaultId, writer.uint32(18).fork()).ldelim();
}
if (message.quotingParams !== undefined) {
QuotingParams.encode(message.quotingParams, writer.uint32(26).fork()).ldelim();
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): MsgSetVaultQuotingParams {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseMsgSetVaultQuotingParams();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.authority = reader.string();
break;
case 2:
message.vaultId = VaultId.decode(reader, reader.uint32());
break;
case 3:
message.quotingParams = QuotingParams.decode(reader, reader.uint32());
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<MsgSetVaultQuotingParams>): MsgSetVaultQuotingParams {
const message = createBaseMsgSetVaultQuotingParams();
message.authority = object.authority ?? "";
message.vaultId = object.vaultId !== undefined && object.vaultId !== null ? VaultId.fromPartial(object.vaultId) : undefined;
message.quotingParams = object.quotingParams !== undefined && object.quotingParams !== null ? QuotingParams.fromPartial(object.quotingParams) : undefined;
return message;
}
};
function createBaseMsgSetVaultQuotingParamsResponse(): MsgSetVaultQuotingParamsResponse {
return {};
}
export const MsgSetVaultQuotingParamsResponse = {
encode(_: MsgSetVaultQuotingParamsResponse, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): MsgSetVaultQuotingParamsResponse {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseMsgSetVaultQuotingParamsResponse();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(_: DeepPartial<MsgSetVaultQuotingParamsResponse>): MsgSetVaultQuotingParamsResponse {
const message = createBaseMsgSetVaultQuotingParamsResponse();
return message;
}
};

180

src/codegen/dydxprotocol/vault/vault.ts

@@ -0,1 +1,2 @@

import { MarketPrice, MarketPriceSDKType } from "../prices/market_price";
import * as _m0 from "protobufjs/minimal";

@@ -58,3 +59,37 @@ import { DeepPartial } from "../../helpers";

}
/** NumShares represents the number of shares in a vault. */
export interface NumShares {
/** Number of shares. */
numShares: Uint8Array;
}
/** NumShares represents the number of shares in a vault. */
export interface NumSharesSDKType {
num_shares: Uint8Array;
}
/** OwnerShare is a type for owner shares in a vault. */
export interface OwnerShare {
owner: string;
shares?: NumShares;
}
/** OwnerShare is a type for owner shares in a vault. */
export interface OwnerShareSDKType {
owner: string;
shares?: NumSharesSDKType;
}
/** VaultParams is the individual parameters of a vault. */
export interface VaultParams {
/** Lagged price that the vault quotes at. */
laggedPrice?: MarketPrice;
}
/** VaultParams is the individual parameters of a vault. */
export interface VaultParamsSDKType {
lagged_price?: MarketPriceSDKType;
}
function createBaseVaultId(): VaultId {

@@ -113,2 +148,147 @@ return {

};
function createBaseNumShares(): NumShares {
return {
numShares: new Uint8Array()
};
}
export const NumShares = {
encode(message: NumShares, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.numShares.length !== 0) {
writer.uint32(18).bytes(message.numShares);
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): NumShares {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseNumShares();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 2:
message.numShares = reader.bytes();
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<NumShares>): NumShares {
const message = createBaseNumShares();
message.numShares = object.numShares ?? new Uint8Array();
return message;
}
};
function createBaseOwnerShare(): OwnerShare {
return {
owner: "",
shares: undefined
};
}
export const OwnerShare = {
encode(message: OwnerShare, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.owner !== "") {
writer.uint32(10).string(message.owner);
}
if (message.shares !== undefined) {
NumShares.encode(message.shares, writer.uint32(18).fork()).ldelim();
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): OwnerShare {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseOwnerShare();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.owner = reader.string();
break;
case 2:
message.shares = NumShares.decode(reader, reader.uint32());
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<OwnerShare>): OwnerShare {
const message = createBaseOwnerShare();
message.owner = object.owner ?? "";
message.shares = object.shares !== undefined && object.shares !== null ? NumShares.fromPartial(object.shares) : undefined;
return message;
}
};
function createBaseVaultParams(): VaultParams {
return {
laggedPrice: undefined
};
}
export const VaultParams = {
encode(message: VaultParams, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
if (message.laggedPrice !== undefined) {
MarketPrice.encode(message.laggedPrice, writer.uint32(10).fork()).ldelim();
}
return writer;
},
decode(input: _m0.Reader | Uint8Array, length?: number): VaultParams {
const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseVaultParams();
while (reader.pos < end) {
const tag = reader.uint32();
switch (tag >>> 3) {
case 1:
message.laggedPrice = MarketPrice.decode(reader, reader.uint32());
break;
default:
reader.skipType(tag & 7);
break;
}
}
return message;
},
fromPartial(object: DeepPartial<VaultParams>): VaultParams {
const message = createBaseVaultParams();
message.laggedPrice = object.laggedPrice !== undefined && object.laggedPrice !== null ? MarketPrice.fromPartial(object.laggedPrice) : undefined;
return message;
}
};

4

src/codegen/gogoproto/bundle.ts

@@ -1,3 +0,3 @@

import * as _239 from "./gogo";
export const gogoproto = { ..._239
import * as _228 from "./gogo";
export const gogoproto = { ..._228
};

24

src/codegen/google/bundle.ts

@@ -1,16 +0,16 @@

import * as _240 from "./api/annotations";
import * as _241 from "./api/http";
import * as _242 from "./protobuf/descriptor";
import * as _243 from "./protobuf/any";
import * as _244 from "./protobuf/timestamp";
import * as _245 from "./protobuf/duration";
import * as _229 from "./api/annotations";
import * as _230 from "./api/http";
import * as _231 from "./protobuf/descriptor";
import * as _232 from "./protobuf/any";
import * as _233 from "./protobuf/timestamp";
import * as _234 from "./protobuf/duration";
export namespace google {
export const api = { ..._240,
..._241
export const api = { ..._229,
..._230
};
export const protobuf = { ..._242,
..._243,
..._244,
..._245
export const protobuf = { ..._231,
..._232,
..._233,
..._234
};
}

44

src/codegen/tendermint/bundle.ts

@@ -1,32 +0,32 @@

import * as _246 from "./abci/types";
import * as _247 from "./crypto/keys";
import * as _248 from "./crypto/proof";
import * as _249 from "./libs/bits/types";
import * as _250 from "./p2p/types";
import * as _251 from "./types/block";
import * as _252 from "./types/evidence";
import * as _253 from "./types/params";
import * as _254 from "./types/types";
import * as _255 from "./types/validator";
import * as _256 from "./version/types";
import * as _235 from "./abci/types";
import * as _236 from "./crypto/keys";
import * as _237 from "./crypto/proof";
import * as _238 from "./libs/bits/types";
import * as _239 from "./p2p/types";
import * as _240 from "./types/block";
import * as _241 from "./types/evidence";
import * as _242 from "./types/params";
import * as _243 from "./types/types";
import * as _244 from "./types/validator";
import * as _245 from "./version/types";
export namespace tendermint {
export const abci = { ..._246
export const abci = { ..._235
};
export const crypto = { ..._247,
..._248
export const crypto = { ..._236,
..._237
};
export namespace libs {
export const bits = { ..._249
export const bits = { ..._238
};
}
export const p2p = { ..._250
export const p2p = { ..._239
};
export const types = { ..._251,
..._252,
..._253,
..._254,
..._255
export const types = { ..._240,
..._241,
..._242,
..._243,
..._244
};
export const version = { ..._256
export const version = { ..._245
};
}
src/codegen/dydxprotocol/accountplus/accountplus.ts
src/codegen/dydxprotocol/accountplus/genesis.ts
src/codegen/dydxprotocol/listing/genesis.ts
src/codegen/dydxprotocol/listing/query.rpc.Query.ts
src/codegen/dydxprotocol/listing/query.ts
src/codegen/dydxprotocol/listing/tx.rpc.msg.ts
src/codegen/dydxprotocol/listing/tx.ts
src/codegen/dydxprotocol/revshare/genesis.ts
src/codegen/dydxprotocol/revshare/params.ts
src/codegen/dydxprotocol/revshare/query.lcd.ts
src/codegen/dydxprotocol/revshare/query.rpc.Query.ts
src/codegen/dydxprotocol/revshare/query.ts
src/codegen/dydxprotocol/revshare/revshare.ts
src/codegen/dydxprotocol/revshare/tx.rpc.msg.ts
src/codegen/dydxprotocol/revshare/tx.ts
src/codegen/dydxprotocol/vault/share.ts
src/codegen/dydxprotocol/indexer/events/events.ts

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc