patch feed msg

bandprotocol · Aug 7, 2024 · 8aac4a9 · 8aac4a9
1 parent 2bce581
commit 8aac4a9
Show file tree

Hide file tree

Showing 2 changed files with 123 additions and 5 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -1,6 +1,7 @@
 export * as Data from './data'
 export * as Message from './message'
 export * as Wallet from './wallet'
+export * as Feed from '../proto/feeds/v1beta1/feeds_pb'
 export { default as Client } from './client'
 export { default as Transaction } from './transaction'
 export { Obi } from './obi'
@@ -9,4 +10,4 @@ export { Fee } from '../proto/cosmos/tx/v1beta1/tx_pb'
 export * as Proposal from './proposal'
 export { Plan } from '../proto/cosmos/upgrade/v1beta1/upgrade_pb'
 export { ParamChange } from '../proto/cosmos/params/v1beta1/params_pb'
-export { Signal } from '../proto/feeds/v1beta1/feeds_pb'
+export { Params as FeedParams } from '../proto/feeds/v1beta1/params_pb'
diff --git a/src/message.ts b/src/message.ts
@@ -53,8 +53,18 @@ import { MsgSubmitProposal as MsgSubmitProposalProto } from '../proto/cosmos/gov
 import { MsgSubmitProposal as MsgSubmitCouncilProposalProto } from '../proto/council/v1beta1/tx_pb'
 import { CouncilType, CouncilTypeMap } from '../proto/council/v1beta1/types_pb'
 import { Proposal } from 'proposal'
-import { MsgSubmitSignals as MsgSubmitSignalsProto } from '../proto/feeds/v1beta1/tx_pb'
-import { Signal } from '../proto/feeds/v1beta1/feeds_pb'
+import {
+  MsgSubmitSignals as MsgSubmitSignalsProto,
+  MsgSubmitSignalPrices as MsgSubmitSignalPricesProto,
+  MsgUpdateReferenceSourceConfig as MsgUpdateReferenceSourceConfigProto,
+  MsgUpdateParams as MsgUpdateParamsProto,
+} from '../proto/feeds/v1beta1/tx_pb'
+import {
+  ReferenceSourceConfig,
+  Signal,
+  SignalPrice,
+} from '../proto/feeds/v1beta1/feeds_pb'
+import { Params } from '../proto/feeds/v1beta1/params_pb'
 
 export interface BaseMsg extends JSPBMesage {
   toJSON(): object
@@ -986,14 +996,14 @@ export class MsgSubmitSignals extends MsgSubmitSignalsProto implements BaseMsg {
     this.validate()
 
     const anyMsg = new Any()
-    const name = 'cosmos.gov.v1beta1.MsgSubmitProposal'
+    const name = 'feeds.v1beta1.MsgSubmitSignals'
     anyMsg.pack(this.serializeBinary(), name, '/')
     return anyMsg
   }
 
   toJSON(): object {
     return {
-      type: 'test/MsgSubmitSignals',
+      type: 'feeds.v1beta1.MsgSubmitSignals',
       value: {
         delegator_address: this.getDelegator(),
         amount: this.getSignalsList(),
@@ -1010,3 +1020,110 @@ export class MsgSubmitSignals extends MsgSubmitSignalsProto implements BaseMsg {
     }
   }
 }
+
+export class MsgSubmitSignalPrices
+  extends MsgSubmitSignalPricesProto
+  implements BaseMsg
+{
+  constructor(validator: string, timestamp: number, pricesList: SignalPrice[]) {
+    super()
+    this.setValidator(validator)
+    this.setTimestamp(timestamp)
+    this.setPricesList(pricesList)
+  }
+
+  toAny(): Any {
+    this.validate()
+
+    const anyMsg = new Any()
+    const name = 'feeds.v1beta1.MsgSubmitSignalPrices'
+    anyMsg.pack(this.serializeBinary(), name, '/')
+    return anyMsg
+  }
+
+  toJSON(): object {
+    return {
+      type: 'feeds.v1beta1.MsgSubmitSignalPrices',
+      value: {
+        validator: this.getValidator(),
+        timestamp: this.getTimestamp(),
+        pricesList: this.getPricesList(),
+      },
+    }
+  }
+
+  validate() {
+    if (this.getValidator() === 'undefined') {
+      throw new ValueError('getValidator Address should not be an empty string')
+    }
+    if (this.getValidator() === 'undefined') {
+      throw new ValueError('timestamp isnot defined')
+    }
+    if (this.getPricesList().length === 0) {
+      throw new ValueError('Signal List should not be emtpy')
+    }
+  }
+}
+
+export class MsgUpdateReferenceSourceConfig
+  extends MsgUpdateReferenceSourceConfigProto
+  implements BaseMsg
+{
+  constructor(admin: string, referenceSourceConfig: ReferenceSourceConfig) {
+    super()
+    this.setAdmin(admin)
+    this.setReferenceSourceConfig(referenceSourceConfig)
+  }
+
+  toAny(): Any {
+    this.validate()
+
+    const anyMsg = new Any()
+    const name = 'feeds.v1beta1.MsgUpdateReferenceSourceConfig'
+    anyMsg.pack(this.serializeBinary(), name, '/')
+    return anyMsg
+  }
+
+  toJSON(): object {
+    return {
+      type: 'feeds.v1beta1.MsgUpdateReferenceSourceConfig',
+      value: {
+        admin: this.getAdmin(),
+        referenceSourceConfig: this.getReferenceSourceConfig(),
+      },
+    }
+  }
+
+  // TODO
+  validate() {}
+}
+
+export class MsgUpdateParams extends MsgUpdateParamsProto implements BaseMsg {
+  constructor(authority: string, params: Params) {
+    super()
+    this.setAuthority(authority)
+    this.setParams(params)
+  }
+
+  toAny(): Any {
+    this.validate()
+
+    const anyMsg = new Any()
+    const name = 'feeds.v1beta1.MsgUpdateParams'
+    anyMsg.pack(this.serializeBinary(), name, '/')
+    return anyMsg
+  }
+
+  toJSON(): object {
+    return {
+      type: 'feeds.v1beta1.MsgUpdateParams',
+      value: {
+        authority: this.getAuthority(),
+        params: this.getParams(),
+      },
+    }
+  }
+
+  // TODO
+  validate() {}
+}