Add market fee discount to protocol (backport #3130)

indexer/packages/v4-protos/src/codegen/dydxprotocol/feetiers/per_market_fee_discount.ts

@@ -0,0 +1,122 @@
+import { Timestamp } from "../../google/protobuf/timestamp";
+import * as _m0 from "protobufjs/minimal";
+import { toTimestamp, fromTimestamp, DeepPartial } from "../../helpers";
+/**
+ * PerMarketFeeDiscountParams defines a fee discount period for a specific CLOB
+ * pair
+ */
+
+export interface PerMarketFeeDiscountParams {
+  /** The CLOB Pair ID this fee holiday applies to */
+  clobPairId: number;
+  /** Start time */
+
+  startTime?: Date;
+  /** End time */
+
+  endTime?: Date;
+  /**
+   * Percentage of normal fee to charge during the period (in parts per
+   * million) 0 = completely free (100% discount) 500000 = charge 50% of normal
+   * fee (50% discount) 1000000 = charge 100% of normal fee (no discount)
+   */
+
+  chargePpm: number;
+}
+/**
+ * PerMarketFeeDiscountParams defines a fee discount period for a specific CLOB
+ * pair
+ */
+
+export interface PerMarketFeeDiscountParamsSDKType {
+  /** The CLOB Pair ID this fee holiday applies to */
+  clob_pair_id: number;
+  /** Start time */
+
+  start_time?: Date;
+  /** End time */
+
+  end_time?: Date;
+  /**
+   * Percentage of normal fee to charge during the period (in parts per
+   * million) 0 = completely free (100% discount) 500000 = charge 50% of normal
+   * fee (50% discount) 1000000 = charge 100% of normal fee (no discount)
+   */
+
+  charge_ppm: number;
+}
+
+function createBasePerMarketFeeDiscountParams(): PerMarketFeeDiscountParams {
+  return {
+    clobPairId: 0,
+    startTime: undefined,
+    endTime: undefined,
+    chargePpm: 0
+  };
+}
+
+export const PerMarketFeeDiscountParams = {
+  encode(message: PerMarketFeeDiscountParams, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
+    if (message.clobPairId !== 0) {
+      writer.uint32(8).uint32(message.clobPairId);
+    }
+
+    if (message.startTime !== undefined) {
+      Timestamp.encode(toTimestamp(message.startTime), writer.uint32(18).fork()).ldelim();
+    }
+
+    if (message.endTime !== undefined) {
+      Timestamp.encode(toTimestamp(message.endTime), writer.uint32(26).fork()).ldelim();
+    }
+
+    if (message.chargePpm !== 0) {
+      writer.uint32(32).uint32(message.chargePpm);
+    }
+
+    return writer;
+  },
+
+  decode(input: _m0.Reader | Uint8Array, length?: number): PerMarketFeeDiscountParams {
+    const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
+    let end = length === undefined ? reader.len : reader.pos + length;
+    const message = createBasePerMarketFeeDiscountParams();
+
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+
+      switch (tag >>> 3) {
+        case 1:
+          message.clobPairId = reader.uint32();
+          break;
+
+        case 2:
+          message.startTime = fromTimestamp(Timestamp.decode(reader, reader.uint32()));
+          break;
+
+        case 3:
+          message.endTime = fromTimestamp(Timestamp.decode(reader, reader.uint32()));
+          break;
+
+        case 4:
+          message.chargePpm = reader.uint32();
+          break;
+
+        default:
+          reader.skipType(tag & 7);
+          break;
+      }
+    }
+
+    return message;
+  },
+
+  fromPartial(object: DeepPartial<PerMarketFeeDiscountParams>): PerMarketFeeDiscountParams {
+    const message = createBasePerMarketFeeDiscountParams();
+    message.clobPairId = object.clobPairId ?? 0;
+    message.startTime = object.startTime ?? undefined;
+    message.endTime = object.endTime ?? undefined;
+    message.chargePpm = object.chargePpm ?? 0;
+    return message;
+  }
+
+};

indexer/packages/v4-protos/src/codegen/dydxprotocol/feetiers/query.lcd.ts

@@ -1,5 +1,5 @@
 import { LCDClient } from "@osmonauts/lcd";
-import { QueryPerpetualFeeParamsRequest, QueryPerpetualFeeParamsResponseSDKType, QueryUserFeeTierRequest, QueryUserFeeTierResponseSDKType } from "./query";
+import { QueryPerpetualFeeParamsRequest, QueryPerpetualFeeParamsResponseSDKType, QueryUserFeeTierRequest, QueryUserFeeTierResponseSDKType, QueryPerMarketFeeDiscountParamsRequest, QueryPerMarketFeeDiscountParamsResponseSDKType, QueryAllMarketFeeDiscountParamsRequest, QueryAllMarketFeeDiscountParamsResponseSDKType } from "./query";
 export class LCDQueryClient {
   req: LCDClient;
 
@@ -11,6 +11,8 @@ export class LCDQueryClient {
     this.req = requestClient;
     this.perpetualFeeParams = this.perpetualFeeParams.bind(this);
     this.userFeeTier = this.userFeeTier.bind(this);
+    this.perMarketFeeDiscountParams = this.perMarketFeeDiscountParams.bind(this);
+    this.allMarketFeeDiscountParams = this.allMarketFeeDiscountParams.bind(this);
   }
   /* Queries the PerpetualFeeParams. */
 
@@ -34,5 +36,20 @@ export class LCDQueryClient {
     const endpoint = `dydxprotocol/v4/feetiers/user_fee_tier`;
     return await this.req.get<QueryUserFeeTierResponseSDKType>(endpoint, options);
   }
+  /* PerMarketFeeDiscountParams queries fee discount parameters for a
+   specific market/CLOB pair. */
+
+
+  async perMarketFeeDiscountParams(params: QueryPerMarketFeeDiscountParamsRequest): Promise<QueryPerMarketFeeDiscountParamsResponseSDKType> {
+    const endpoint = `dydxprotocol/v4/feetiers/market_fee_discount_params/${params.clobPairId}`;
+    return await this.req.get<QueryPerMarketFeeDiscountParamsResponseSDKType>(endpoint);
+  }
+  /* AllMarketFeeDiscountParams queries all per-market fee discount parameters. */
+
+
+  async allMarketFeeDiscountParams(_params: QueryAllMarketFeeDiscountParamsRequest = {}): Promise<QueryAllMarketFeeDiscountParamsResponseSDKType> {
+    const endpoint = `dydxprotocol/v4/feetiers/market_fee_discount_params`;
+    return await this.req.get<QueryAllMarketFeeDiscountParamsResponseSDKType>(endpoint);
+  }
 
 }

indexer/packages/v4-protos/src/codegen/dydxprotocol/feetiers/query.rpc.Query.ts

@@ -1,7 +1,7 @@
 import { Rpc } from "../../helpers";
 import * as _m0 from "protobufjs/minimal";
 import { QueryClient, createProtobufRpcClient } from "@cosmjs/stargate";
-import { QueryPerpetualFeeParamsRequest, QueryPerpetualFeeParamsResponse, QueryUserFeeTierRequest, QueryUserFeeTierResponse } from "./query";
+import { QueryPerpetualFeeParamsRequest, QueryPerpetualFeeParamsResponse, QueryUserFeeTierRequest, QueryUserFeeTierResponse, QueryPerMarketFeeDiscountParamsRequest, QueryPerMarketFeeDiscountParamsResponse, QueryAllMarketFeeDiscountParamsRequest, QueryAllMarketFeeDiscountParamsResponse } from "./query";
 /** Query defines the gRPC querier service. */
 
 export interface Query {
@@ -10,6 +10,15 @@ export interface Query {
   /** Queries a user's fee tier */
 
   userFeeTier(request: QueryUserFeeTierRequest): Promise<QueryUserFeeTierResponse>;
+  /**
+   * PerMarketFeeDiscountParams queries fee discount parameters for a
+   * specific market/CLOB pair.
+   */
+
+  perMarketFeeDiscountParams(request: QueryPerMarketFeeDiscountParamsRequest): Promise<QueryPerMarketFeeDiscountParamsResponse>;
+  /** AllMarketFeeDiscountParams queries all per-market fee discount parameters. */
+
+  allMarketFeeDiscountParams(request?: QueryAllMarketFeeDiscountParamsRequest): Promise<QueryAllMarketFeeDiscountParamsResponse>;
 }
 export class QueryClientImpl implements Query {
   private readonly rpc: Rpc;
@@ -18,6 +27,8 @@ export class QueryClientImpl implements Query {
     this.rpc = rpc;
     this.perpetualFeeParams = this.perpetualFeeParams.bind(this);
     this.userFeeTier = this.userFeeTier.bind(this);
+    this.perMarketFeeDiscountParams = this.perMarketFeeDiscountParams.bind(this);
+    this.allMarketFeeDiscountParams = this.allMarketFeeDiscountParams.bind(this);
   }
 
   perpetualFeeParams(request: QueryPerpetualFeeParamsRequest = {}): Promise<QueryPerpetualFeeParamsResponse> {
@@ -32,6 +43,18 @@ export class QueryClientImpl implements Query {
     return promise.then(data => QueryUserFeeTierResponse.decode(new _m0.Reader(data)));
   }
 
+  perMarketFeeDiscountParams(request: QueryPerMarketFeeDiscountParamsRequest): Promise<QueryPerMarketFeeDiscountParamsResponse> {
+    const data = QueryPerMarketFeeDiscountParamsRequest.encode(request).finish();
+    const promise = this.rpc.request("dydxprotocol.feetiers.Query", "PerMarketFeeDiscountParams", data);
+    return promise.then(data => QueryPerMarketFeeDiscountParamsResponse.decode(new _m0.Reader(data)));
+  }
+
+  allMarketFeeDiscountParams(request: QueryAllMarketFeeDiscountParamsRequest = {}): Promise<QueryAllMarketFeeDiscountParamsResponse> {
+    const data = QueryAllMarketFeeDiscountParamsRequest.encode(request).finish();
+    const promise = this.rpc.request("dydxprotocol.feetiers.Query", "AllMarketFeeDiscountParams", data);
+    return promise.then(data => QueryAllMarketFeeDiscountParamsResponse.decode(new _m0.Reader(data)));
+  }
+
 }
 export const createRpcQueryExtension = (base: QueryClient) => {
   const rpc = createProtobufRpcClient(base);
@@ -43,6 +66,14 @@ export const createRpcQueryExtension = (base: QueryClient) => {
 
     userFeeTier(request: QueryUserFeeTierRequest): Promise<QueryUserFeeTierResponse> {
       return queryService.userFeeTier(request);
+    },
+
+    perMarketFeeDiscountParams(request: QueryPerMarketFeeDiscountParamsRequest): Promise<QueryPerMarketFeeDiscountParamsResponse> {
+      return queryService.perMarketFeeDiscountParams(request);
+    },
+
+    allMarketFeeDiscountParams(request?: QueryAllMarketFeeDiscountParamsRequest): Promise<QueryAllMarketFeeDiscountParamsResponse> {
+      return queryService.allMarketFeeDiscountParams(request);
     }
 
   };