add feeder-module test

__tests__/message.test.ts

@@ -18,6 +18,10 @@ import {
   MsgDeposit,
   MsgSubmitProposal,
   MsgSubmitCouncilProposal,
+  MsgSubmitSignals,
+  MsgSubmitSignalPrices,
+  MsgUpdateReferenceSourceConfig,
+  MsgUpdateParams,
 } from '../src/message'
 import { VoteOption } from '../proto/cosmos/gov/v1beta1/gov_pb'
 import {
@@ -28,6 +32,12 @@ import {
 import fs from 'fs'
 import path from 'path'
 import { VetoProposal } from '../src/proposal'
+import {
+  Signal,
+  SignalPrice,
+  ReferenceSourceConfig,
+} from '../proto/feeds/v1beta1/feeds_pb'
+import { Params } from '../proto/feeds/v1beta1/params_pb'
 
 let coin = new Coin()
 coin.setDenom('uband')
@@ -1167,3 +1177,165 @@ describe('MsgSubmitCouncilProposal', () => {
     })
   })
 })
+
+describe('MsgSubmitSignals', () => {
+  let signal = new Signal()
+  signal.setId('crypto_price.btcbusd')
+  signal.setPower(1)
+
+  it('create successfully', () => {
+    const msgSubmitSignals = new MsgSubmitSignals(
+      'band13eznuehmqzd3r84fkxu8wklxl22r2qfmtlth8c',
+      [signal],
+    )
+    const anyMsg = new Any()
+    const name = 'feeds.v1beta1.MsgSubmitSignals'
+    anyMsg.pack(msgSubmitSignals.serializeBinary(), name, '/')
+
+    expect(msgSubmitSignals.toAny()).toEqual(anyMsg)
+
+    expect(() => msgSubmitSignals.validate()).not.toThrow()
+  })
+
+  it('error MsgSubmitSignals', () => {
+    let msgs: MsgSubmitSignals[] = []
+    let errorText: string[] = []
+
+    msgs.push(new MsgSubmitSignals('', [signal]))
+
+    errorText.push('Delegator address should not be an empty string')
+
+    msgs.forEach((msg, index) => {
+      expect(() => {
+        msg.validate()
+      }).toThrowError(errorText[index])
+    })
+  })
+})
+
+describe('MsgSubmitSignalPrice', () => {
+  const signalPrice = new SignalPrice()
+  signalPrice.setSignalId('crypto_price.btcbusd')
+  signalPrice.setPrice(1)
+  signalPrice.setPriceStatus(0)
+
+  it('create successfully', () => {
+    const msgSubmitSignalPrice = new MsgSubmitSignalPrices(
+      'bandvaloper1dqsqfh537nzdr3ue9whc9tk7zqre4322hkru33',
+      1723027871382,
+      [signalPrice],
+    )
+
+    const anyMsg = new Any()
+    const name = 'feeds.v1beta1.MsgSubmitSignalPrices'
+    anyMsg.pack(msgSubmitSignalPrice.serializeBinary(), name, '/')
+
+    expect(msgSubmitSignalPrice.toAny()).toEqual(anyMsg)
+
+    expect(() => msgSubmitSignalPrice.validate()).not.toThrow()
+  })
+
+  it('error MsgSubmitSignals', () => {
+    let msgs: MsgSubmitSignalPrices[] = []
+    let errorText: string[] = []
+
+    msgs.push(new MsgSubmitSignalPrices('', 1723027871382, [signalPrice]))
+    msgs.push(
+      new MsgSubmitSignalPrices(
+        'band13eznuehmqzd3r84fkxu8wklxl22r2qfmtlth8c',
+        1723027871382,
+        [signalPrice],
+      ),
+    )
+
+    errorText.push('Validator address should not be an empty string')
+    errorText.push('invalid Bech32 prefix; expected bandvaloper, got band')
+
+    msgs.forEach((msg, index) => {
+      expect(() => {
+        msg.validate()
+      }).toThrowError(errorText[index])
+    })
+  })
+})
+
+describe('MsgUpdateReferenceSourceConfig', () => {
+  const referenceSource = new ReferenceSourceConfig()
+  referenceSource.setIpfsHash('QmTzQ1b4SijKVDe3XZPq3N5tHk3PvCjAosYtK6KDxDZXn6')
+  referenceSource.setVersion('1.1')
+
+  it('create successfully', () => {
+    const msgUpdateReferenceSourceConfig = new MsgUpdateReferenceSourceConfig(
+      'band13eznuehmqzd3r84fkxu8wklxl22r2qfmtlth8c',
+      referenceSource,
+    )
+
+    const anyMsg = new Any()
+    const name = 'feeds.v1beta1.MsgUpdateReferenceSourceConfig'
+    anyMsg.pack(msgUpdateReferenceSourceConfig.serializeBinary(), name, '/')
+
+    expect(msgUpdateReferenceSourceConfig.toAny()).toEqual(anyMsg)
+
+    expect(() => msgUpdateReferenceSourceConfig.validate()).not.toThrow()
+  })
+
+  it('error MsgSubmitSignals', () => {
+    let msgs: MsgUpdateReferenceSourceConfig[] = []
+    let errorText: string[] = []
+
+    msgs.push(new MsgUpdateReferenceSourceConfig('', referenceSource))
+
+    errorText.push('Authority address should not be an empty string')
+
+    msgs.forEach((msg, index) => {
+      expect(() => {
+        msg.validate()
+      }).toThrowError(errorText[index])
+    })
+  })
+})
+
+describe('MsgUpdateParams', () => {
+  const param = new Params()
+  param.setAdmin('band13eznuehmqzd3r84fkxu8wklxl22r2qfmtlth8c')
+  param.setAllowableBlockTimeDiscrepancy(1)
+  param.setGracePeriod(1)
+  param.setMinInterval(1)
+  param.setMaxInterval(1)
+  param.setPowerStepThreshold(1)
+  param.setMaxCurrentFeeds(1)
+  param.setCooldownTime(1)
+  param.setMinDeviationBasisPoint(1)
+  param.setMaxDeviationBasisPoint(1)
+  param.setCurrentFeedsUpdateInterval(1)
+
+  it('create successfully', () => {
+    const msgUpdateParams = new MsgUpdateParams(
+      'band13eznuehmqzd3r84fkxu8wklxl22r2qfmtlth8c',
+      param,
+    )
+
+    const anyMsg = new Any()
+    const name = 'feeds.v1beta1.MsgUpdateParams'
+    anyMsg.pack(msgUpdateParams.serializeBinary(), name, '/')
+
+    expect(msgUpdateParams.toAny()).toEqual(anyMsg)
+
+    expect(() => msgUpdateParams.validate()).not.toThrow()
+  })
+
+  it('error MsgSubmitSignals', () => {
+    let msgs: MsgUpdateParams[] = []
+    let errorText: string[] = []
+
+    msgs.push(new MsgUpdateParams('', param))
+
+    errorText.push('Admin address should not be an empty string')
+
+    msgs.forEach((msg, index) => {
+      expect(() => {
+        msg.validate()
+      }).toThrowError(errorText[index])
+    })
+  })
+})

src/message.ts

@@ -65,6 +65,7 @@ import {
   SignalPrice,
 } from '../proto/feeds/v1beta1/feeds_pb'
 import { Params } from '../proto/feeds/v1beta1/params_pb'
+import { bech32 } from 'bech32'
 
 export interface BaseMsg extends JSPBMesage {
   toJSON(): object
@@ -1012,11 +1013,8 @@ export class MsgSubmitSignals extends MsgSubmitSignalsProto implements BaseMsg {
   }
 
   validate() {
-    if (this.getDelegator() === 'undefined') {
-      throw new ValueError('Delegator Address should not be an empty string')
-    }
-    if (this.getSignalsList().length === 0) {
-      throw new ValueError('Signal List should not be emtpy')
+    if (this.getDelegator() === '') {
+      throw new ValueError('Delegator address should not be an empty string')
     }
   }
 }
@@ -1053,14 +1051,16 @@ export class MsgSubmitSignalPrices
   }
 
   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.getValidator() === '') {
+      throw new ValueError('Validator address should not be an empty string')
     }
-    if (this.getPricesList().length === 0) {
-      throw new ValueError('Signal List should not be emtpy')
+
+    const { prefix } = bech32.decode(this.getValidator())
+
+    if (prefix != 'bandvaloper') {
+      throw new ValueError(
+        `invalid Bech32 prefix; expected bandvaloper, got ${prefix}`,
+      )
     }
   }
 }
@@ -1094,8 +1094,11 @@ export class MsgUpdateReferenceSourceConfig
     }
   }
 
-  // TODO
-  validate() {}
+  validate() {
+    if (this.getAdmin() === '') {
+      throw new ValueError('Authority address should not be an empty string')
+    }
+  }
 }
 
 export class MsgUpdateParams extends MsgUpdateParamsProto implements BaseMsg {
@@ -1124,6 +1127,9 @@ export class MsgUpdateParams extends MsgUpdateParamsProto implements BaseMsg {
     }
   }
 
-  // TODO
-  validate() {}
+  validate() {
+    if (this.getAuthority() === '') {
+      throw new ValueError('Admin address should not be an empty string')
+    }
+  }
 }