Make txs in parallel in auction tests to reduce run time (#30)

Part of [Service provider auctions](https://www.notion.so/Service-provider-auctions-a7b63697d818479493ec145ea6ea3c1c)

Reviewed-on: #30
Co-authored-by: Prathamesh Musale <prathamesh.musale0@gmail.com>
Co-committed-by: Prathamesh Musale <prathamesh.musale0@gmail.com>

.gitea/workflows/test.yml

@@ -44,14 +44,14 @@ jobs:
         working-directory: laconicd/tests/sdk_tests
         run: ./run-tests.sh
 
-      - name: Start containers (auctions enabled)
+      - name: Start containers (authority auctions enabled)
         working-directory: laconicd/tests/sdk_tests
         env:
           TEST_AUCTION_ENABLED: true
         run: docker compose up -d
-      - name: Run auction tests
+      - name: Run authority auction tests
         working-directory: laconicd/tests/sdk_tests
-        run: ./run-tests.sh test:auctions
+        run: ./run-tests.sh test:authority-auctions
 
       - name: Start containers (expiry enabled)
         working-directory: laconicd/tests/sdk_tests

README.md

@@ -53,7 +53,7 @@ Follow these steps to run the tests:
   - Run tests:
 
     ```bash
-    yarn test:auctions
+    yarn test:authority-auctions
     ```
 
 - Run the tests for record and authority expiry

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/registry-sdk",
-  "version": "0.2.51",
+  "version": "0.2.11",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
   "repository": "git@github.com:cerc-io/registry-sdk.git",
@@ -62,7 +62,7 @@
   },
   "scripts": {
     "test": "jest --runInBand --verbose --testPathPattern=src",
-    "test:auctions": "TEST_AUCTIONS_ENABLED=1 jest --runInBand --verbose src/auction.test.ts",
+    "test:authority-auctions": "TEST_AUCTIONS_ENABLED=1 jest --runInBand --verbose src/authority-auction.test.ts",
     "test:nameservice-expiry": "TEST_NAMESERVICE_EXPIRY=1 jest --runInBand --verbose src/nameservice-expiry.test.ts",
     "test:onboarding": "ONBOARDING_ENABLED=1 jest --runInBand --verbose src/onboarding.test.ts",
     "build": "tsc",

proto/cerc/auction/module/v1/module.proto

@@ -10,4 +10,8 @@ message Module {
   option (cosmos.app.v1alpha1.module) = {
     go_import : "git.vdb.to/cerc-io/laconicd/x/auction"
   };
+
+  // authority defines the custom module authority. If not set, defaults to the
+  // governance module.
+  string authority = 2;
 }

proto/cerc/auction/v1/auction.proto

@@ -3,76 +3,44 @@ syntax = "proto3";
 package cerc.auction.v1;
 
 import "gogoproto/gogo.proto";
-import "google/protobuf/duration.proto";
 import "google/protobuf/timestamp.proto";
 import "cosmos/base/v1beta1/coin.proto";
 
 option go_package = "git.vdb.to/cerc-io/laconicd/x/auction";
 
 // Params defines the auction module parameters
-message Params {
+message Params {}
-  // Write custom stringer method
-  option (gogoproto.goproto_stringer) = false;
-
-  // Duration of the commits phase in seconds
-  google.protobuf.Duration commits_duration = 1 [
-    (gogoproto.nullable) = false,
-    (gogoproto.stdduration) = true,
-    (gogoproto.moretags) = "json:\"commits_duration\" yaml:\"commits_duration\""
-  ];
-
-  // Duration of the reveals phase in seconds
-  google.protobuf.Duration reveals_duration = 2 [
-    (gogoproto.nullable) = false,
-    (gogoproto.stdduration) = true,
-    (gogoproto.moretags) = "json:\"reveals_duration\" yaml:\"reveals_duration\""
-  ];
-
-  // Commit fees
-  cosmos.base.v1beta1.Coin commit_fee = 3 [
-    (gogoproto.nullable) = false,
-    (gogoproto.moretags) = "json:\"commit_fee\" yaml:\"commit_fee\""
-  ];
-
-  // Reveal fees
-  cosmos.base.v1beta1.Coin reveal_fee = 4 [
-    (gogoproto.nullable) = false,
-    (gogoproto.moretags) = "json:\"reveal_fee\" yaml:\"reveal_fee\""
-  ];
-
-  // Minimum acceptable bid amount
-  cosmos.base.v1beta1.Coin minimum_bid = 5 [
-    (gogoproto.nullable) = false,
-    (gogoproto.moretags) = "json:\"minimum_bid\" yaml:\"minimum_bid\""
-  ];
-}
 
 // Auction represents a sealed-bid on-chain auction
 message Auction {
   option (gogoproto.goproto_getters) = false;
 
   string id = 1;
-  string status = 2;
+
+  // Auction kind (vickrey | provider)
+  string kind = 2 [ (gogoproto.moretags) = "json:\"kind\" yaml:\"kind\"" ];
+
+  string status = 3;
 
   // Address of the creator of the auction
-  string owner_address = 3;
+  string owner_address = 4;
 
   // Timestamp at which the auction was created
-  google.protobuf.Timestamp create_time = 4 [
+  google.protobuf.Timestamp create_time = 5 [
     (gogoproto.stdtime) = true,
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"create_time\" yaml:\"create_time\""
   ];
 
   // Timestamp at which the commits phase concluded
-  google.protobuf.Timestamp commits_end_time = 5 [
+  google.protobuf.Timestamp commits_end_time = 6 [
     (gogoproto.stdtime) = true,
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"commits_end_time\" yaml:\"commits_end_time\""
   ];
 
   // Timestamp at which the reveals phase concluded
-  google.protobuf.Timestamp reveals_end_time = 6 [
+  google.protobuf.Timestamp reveals_end_time = 7 [
     (gogoproto.stdtime) = true,
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"reveals_end_time\" yaml:\"reveals_end_time\""
@@ -80,35 +48,56 @@ message Auction {
 
   // Commit and reveal fees must both be paid when committing a bid
   // Reveal fee is returned only if the bid is revealed
-  cosmos.base.v1beta1.Coin commit_fee = 7 [
+  cosmos.base.v1beta1.Coin commit_fee = 8 [
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"commit_fee\" yaml:\"commit_fee\""
   ];
-  cosmos.base.v1beta1.Coin reveal_fee = 8 [
+  cosmos.base.v1beta1.Coin reveal_fee = 9 [
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"reveal_fee\" yaml:\"reveal_fee\""
   ];
 
   // Minimum acceptable bid amount for a valid commit
-  cosmos.base.v1beta1.Coin minimum_bid = 9 [
+  // Only applicable in vickrey auctions
+  cosmos.base.v1beta1.Coin minimum_bid = 10 [
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"minimum_bid\" yaml:\"minimum_bid\""
   ];
 
-  // Address of the winner
+  // Addresses of the winners
-  string winner_address = 10;
+  // (single winner for vickrey auction)
+  // (multiple winners for provider auctions)
+  repeated string winner_addresses = 11;
 
-  // Winning bid, i.e., the highest bid
+  // Winning bids, i.e. the best bids
-  cosmos.base.v1beta1.Coin winning_bid = 11 [
+  repeated cosmos.base.v1beta1.Coin winning_bids = 12 [
     (gogoproto.nullable) = false,
-    (gogoproto.moretags) = "json:\"winning_bid\" yaml:\"winning_bid\""
+    (gogoproto.moretags) = "json:\"winning_bids\" yaml:\"winning_bids\""
   ];
 
-  // Amount the winner pays, i.e. the second highest auction
+  // Auction winning price
-  cosmos.base.v1beta1.Coin winning_price = 12 [
+  // vickrey auction: second highest bid, paid by the winner
+  // provider auction: higest bid amongst winning_bids, paid by auction creator
+  // to each winner
+  cosmos.base.v1beta1.Coin winning_price = 13 [
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"winning_price\" yaml:\"winning_price\""
   ];
+
+  // Maximum acceptable bid amount for a valid commit
+  // Only applicable in provider auctions
+  cosmos.base.v1beta1.Coin max_price = 14 [
+    (gogoproto.nullable) = false,
+    (gogoproto.moretags) = "json:\"max_price\" yaml:\"max_price\""
+  ];
+
+  // Number of desired providers (num of auction winners)
+  // Only applicable in provider auctions
+  int32 num_providers = 15;
+
+  bool funds_released = 16 [
+    (gogoproto.moretags) =
+        "json:\"funds_released\" yaml:\"funds_released\"" ];
 }
 
 // Auctions represent all the auctions in the module

proto/cerc/auction/v1/tx.proto

@@ -7,6 +7,7 @@ import "gogoproto/gogo.proto";
 import "google/api/annotations.proto";
 import "google/protobuf/duration.proto";
 import "cosmos/base/v1beta1/coin.proto";
+import "cosmos_proto/cosmos.proto";
 import "cerc/auction/v1/auction.proto";
 
 option go_package = "git.vdb.to/cerc-io/laconicd/x/auction";
@@ -29,6 +30,15 @@ service Msg {
   rpc RevealBid(MsgRevealBid) returns (MsgRevealBidResponse) {
     option (google.api.http).post = "/cerc/auction/v1/reveal_bid";
   };
+
+  // UpdateParams defines an operation for updating the x/staking module
+  // parameters.
+  rpc UpdateParams(MsgUpdateParams) returns (MsgUpdateParamsResponse);
+
+  // ReleaseFunds is the command for paying the winners of provider auctions
+  rpc ReleaseFunds(MsgReleaseFunds) returns (MsgReleaseFundsResponse) {
+    option (google.api.http).post = "/cerc/auction/v1/release_funds";
+  };
 }
 
 // MsgCreateAuction defines a create auction message
@@ -36,41 +46,56 @@ message MsgCreateAuction {
   option (gogoproto.goproto_getters) = false;
   option (cosmos.msg.v1.signer) = "signer";
 
+  // Address of the signer
+  string signer = 1
+      [ (gogoproto.moretags) = "json:\"signer\" yaml:\"signer\"" ];
+
+  // Auction kind (vickrey | provider)
+  string kind = 2 [ (gogoproto.moretags) = "json:\"kind\" yaml:\"kind\"" ];
+
   // Duration of the commits phase in seconds
-  google.protobuf.Duration commits_duration = 1 [
+  google.protobuf.Duration commits_duration = 3 [
     (gogoproto.nullable) = false,
     (gogoproto.stdduration) = true,
     (gogoproto.moretags) = "json:\"commits_duration\" yaml:\"commits_duration\""
   ];
 
   // Duration of the reveals phase in seconds
-  google.protobuf.Duration reveals_duration = 2 [
+  google.protobuf.Duration reveals_duration = 4 [
     (gogoproto.nullable) = false,
     (gogoproto.stdduration) = true,
     (gogoproto.moretags) = "json:\"reveals_duration\" yaml:\"reveals_duration\""
   ];
 
   // Commit fees
-  cosmos.base.v1beta1.Coin commit_fee = 3 [
+  cosmos.base.v1beta1.Coin commit_fee = 5 [
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"commit_fee\" yaml:\"commit_fee\""
   ];
 
   // Reveal fees
-  cosmos.base.v1beta1.Coin reveal_fee = 4 [
+  cosmos.base.v1beta1.Coin reveal_fee = 6 [
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"reveal_fee\" yaml:\"reveal_fee\""
   ];
 
   // Minimum acceptable bid amount
-  cosmos.base.v1beta1.Coin minimum_bid = 5 [
+  // Only applicable in vickrey auctions
+  cosmos.base.v1beta1.Coin minimum_bid = 7 [
     (gogoproto.nullable) = false,
     (gogoproto.moretags) = "json:\"minimum_bid\" yaml:\"minimum_bid\""
   ];
 
-  // Address of the signer
+  // Maximum acceptable bid amount
-  string signer = 6
+  // Only applicable in provider auctions
-      [ (gogoproto.moretags) = "json:\"signer\" yaml:\"signer\"" ];
+  cosmos.base.v1beta1.Coin max_price = 8 [
+    (gogoproto.nullable) = false,
+    (gogoproto.moretags) = "json:\"max_price\" yaml:\"max_price\""
+  ];
+
+  // Number of desired providers (num of auction winners)
+  // Only applicable in provider auctions
+  int32 num_providers = 9;
 }
 
 // MsgCreateAuctionResponse returns the details of the created auction
@@ -134,3 +159,44 @@ message MsgRevealBidResponse {
   Auction auction = 1
       [ (gogoproto.moretags) = "json:\"auction\" yaml:\"auction\"" ];
 }
+
+// MsgUpdateParams is the Msg/UpdateParams request type.
+message MsgUpdateParams {
+  option (cosmos.msg.v1.signer) = "authority";
+
+  // authority is the address that controls the module (defaults to x/gov unless
+  // overwritten).
+  string authority = 1 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+
+  // params defines the x/auction parameters to update.
+  //
+  // NOTE: All parameters must be supplied.
+  Params params = 2 [ (gogoproto.nullable) = false ];
+}
+
+// MsgUpdateParamsResponse defines the response structure for executing a
+// MsgUpdateParams message.
+message MsgUpdateParamsResponse {};
+
+// ReleaseFunds defines the message to pay the winners of provider auctions
+message MsgReleaseFunds {
+  option (gogoproto.goproto_getters) = false;
+  option (cosmos.msg.v1.signer) = "signer";
+
+  // Auction id
+  string auction_id = 1
+      [ (gogoproto.moretags) = "json:\"auction_id\" yaml:\"auction_id\"" ];
+
+  // Address of the signer
+  string signer = 2
+      [ (gogoproto.moretags) = "json:\"signer\" yaml:\"signer\"" ];
+}
+
+// MsgReleaseFundsResponse returns the state of the auction after releasing the funds
+message MsgReleaseFundsResponse {
+  option (gogoproto.goproto_getters) = false;
+
+  // Auction details
+  Auction auction = 1
+      [ (gogoproto.moretags) = "json:\"auction\" yaml:\"auction\"" ];
+}

proto/cerc/bond/module/v1/module.proto

@@ -10,4 +10,8 @@ message Module {
   option (cosmos.app.v1alpha1.module) = {
     go_import : "git.vdb.to/cerc-io/laconicd/x/bond"
   };
+
+  // authority defines the custom module authority. If not set, defaults to the
+  // governance module.
+  string authority = 2;
 }

proto/cerc/bond/v1/tx.proto

@@ -6,6 +6,8 @@ import "cosmos/msg/v1/msg.proto";
 import "gogoproto/gogo.proto";
 import "google/api/annotations.proto";
 import "cosmos/base/v1beta1/coin.proto";
+import "cosmos_proto/cosmos.proto";
+import "cerc/bond/v1/bond.proto";
 
 option go_package = "git.vdb.to/cerc-io/laconicd/x/bond";
 
@@ -32,6 +34,10 @@ service Msg {
   rpc CancelBond(MsgCancelBond) returns (MsgCancelBondResponse) {
     option (google.api.http).post = "/cerc/bond/v1/cancel_bond";
   };
+
+  // UpdateParams defines an operation for updating the x/staking module
+  // parameters.
+  rpc UpdateParams(MsgUpdateParams) returns (MsgUpdateParamsResponse);
 }
 
 // MsgCreateBond defines a SDK message for creating a new bond.
@@ -91,3 +97,21 @@ message MsgCancelBond {
 
 // MsgCancelBondResponse defines the Msg/CancelBond response type.
 message MsgCancelBondResponse {}
+
+// MsgUpdateParams is the Msg/UpdateParams request type.
+message MsgUpdateParams {
+  option (cosmos.msg.v1.signer) = "authority";
+
+  // authority is the address that controls the module (defaults to x/gov unless
+  // overwritten).
+  string authority = 1 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+
+  // params defines the x/bond parameters to update.
+  //
+  // NOTE: All parameters must be supplied.
+  Params params = 2 [ (gogoproto.nullable) = false ];
+}
+
+// MsgUpdateParamsResponse defines the response structure for executing a
+// MsgUpdateParams message.
+message MsgUpdateParamsResponse {};

proto/cerc/registry/module/v1/module.proto

@@ -10,4 +10,8 @@ message Module {
   option (cosmos.app.v1alpha1.module) = {
     go_import : "git.vdb.to/cerc-io/laconicd/x/registry"
   };
+
+  // authority defines the custom module authority. If not set, defaults to the
+  // governance module.
+  string authority = 2;
 }

proto/cerc/registry/v1/tx.proto

@@ -6,6 +6,7 @@ import "google/api/annotations.proto";
 import "gogoproto/gogo.proto";
 import "cosmos/msg/v1/msg.proto";
 import "cerc/registry/v1/registry.proto";
+import "cosmos_proto/cosmos.proto";
 
 option go_package = "git.vdb.to/cerc-io/laconicd/x/registry";
 
@@ -66,6 +67,10 @@ service Msg {
       returns (MsgSetAuthorityBondResponse) {
     option (google.api.http).post = "/cerc/registry/v1/set_authority_bond";
   }
+
+  // UpdateParams defines an operation for updating the x/staking module
+  // parameters.
+  rpc UpdateParams(MsgUpdateParams) returns (MsgUpdateParamsResponse);
 }
 
 // MsgSetRecord
@@ -203,3 +208,21 @@ message MsgReassociateRecords {
 
 // MsgReassociateRecordsResponse
 message MsgReassociateRecordsResponse {}
+
+// MsgUpdateParams is the Msg/UpdateParams request type.
+message MsgUpdateParams {
+  option (cosmos.msg.v1.signer) = "authority";
+
+  // authority is the address that controls the module (defaults to x/gov unless
+  // overwritten).
+  string authority = 1 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+
+  // params defines the x/registry parameters to update.
+  //
+  // NOTE: All parameters must be supplied.
+  Params params = 2 [ (gogoproto.nullable) = false ];
+}
+
+// MsgUpdateParamsResponse defines the response structure for executing a
+// MsgUpdateParams message.
+message MsgUpdateParamsResponse {}

src/auction.test.ts

@@ -1,129 +1,390 @@
 import { Registry, Account, createBid } from './index';
-import { getConfig } from './testing/helper';
+import { createTestAccounts, getConfig } from './testing/helper';
 import { DENOM } from './constants';
+import { INVALID_BID_ERROR, OWNER_MISMATCH_ERROR, RELEASE_FUNDS_ERROR } from './types/cerc/auction/message';
 
 jest.setTimeout(30 * 60 * 1000);
 const { chainId, rpcEndpoint, gqlEndpoint, privateKey, fee } = getConfig();
 
-const auctionTests = (numBidders = 3) => {
+const DURATION = 60;
+const TX_FEES = Number(fee.amount[0].amount);
+const COMMIT_FEE = '1000';
+const REVEAL_FEE = '1000';
+
+const CREATOR_INITIAL_BALANCE = 1000000000000;
+const BIDDER_INITIAL_BALANCE = 20000000;
+const LOWEST_BID_AMOUNT = 10000000;
+
+const auctionTests = () => {
   let registry: Registry;
-
-  const accounts: { address: string, privateKey: string, bid?: any }[] = [];
-
   let auctionId: string;
-  let authorityName: string;
+
+  let auctionCreatorAccount: { address: string, privateKey: string };
+  let bidderAccounts: { address: string, privateKey: string, bid?: any }[] = [];
+
+  const numBidders = 3;
+  let bidAmounts: string[] = [];
 
   beforeAll(async () => {
-    console.log('Running auction tests with num bidders', numBidders);
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
 
-    registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
+    // Create auction creator account
-  });
+    const [auctionCreator] = await createTestAccounts(1);
+    await registry.sendCoins({ denom: DENOM, amount: CREATOR_INITIAL_BALANCE.toString(), destinationAddress: auctionCreator.address }, privateKey, fee);
+    auctionCreatorAccount = { address: auctionCreator.address, privateKey: auctionCreator.privateKey.toString('hex') };
 
-  test('Setup bidder accounts', async () => {
+    // Create bidder accounts
+    const accounts = await createTestAccounts(numBidders);
     for (let i = 0; i < numBidders; i++) {
-      const mnenonic = Account.generateMnemonic();
+      await registry.sendCoins({ denom: DENOM, amount: BIDDER_INITIAL_BALANCE.toString(), destinationAddress: accounts[i].address }, privateKey, fee);
-      const account = await Account.generateFromMnemonic(mnenonic);
+      bidderAccounts.push({ address: accounts[i].address, privateKey: accounts[i].privateKey.toString('hex') });
-      await account.init();
-      await registry.sendCoins({ denom: DENOM, amount: '20000000', destinationAddress: account.address }, privateKey, fee);
-      accounts.push({ address: account.address, privateKey: account.privateKey.toString('hex') });
     }
   });
 
-  test('Reserve authority.', async () => {
+  test('Create a vickrey auction', async () => {
-    authorityName = `laconic-${Date.now()}`;
+    const minimumBid = '1000000';
-    await registry.reserveAuthority({ name: authorityName }, accounts[0].privateKey, fee);
-  });
 
-  test('Authority should be under auction.', async () => {
+    const auction = await registry.createAuction(
-    const [record] = await registry.lookupAuthorities([authorityName], true);
+      {
-    expect(record.ownerAddress).toEqual('');
+        commitsDuration: DURATION.toString(),
-    expect(record.height).toBeDefined();
+        revealsDuration: DURATION.toString(),
-    expect(record.status).toEqual('auction');
+        denom: DENOM,
+        commitFee: COMMIT_FEE,
+        revealFee: REVEAL_FEE,
+        minimumBid
+      },
+      auctionCreatorAccount.privateKey,
+      fee
+    );
 
-    expect(record.auction.id).toBeDefined();
+    expect(auction.auction?.id).toBeDefined();
-    expect(record.auction.status).toEqual('commit');
 
-    auctionId = record.auction.id;
+    // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
+    auctionId = auction.auction!.id;
+    expect(auction.auction?.status).toEqual('commit');
   });
 
   test('Commit bids.', async () => {
     for (let i = 0; i < numBidders; i++) {
-      accounts[i].bid = await createBid(chainId, auctionId, accounts[i].address, `${10000000 + (i * 500)}${DENOM}`);
+      bidAmounts.push((LOWEST_BID_AMOUNT + (i * 500)).toString());
-      await registry.commitBid({ auctionId, commitHash: accounts[i].bid.commitHash }, accounts[i].privateKey, fee);
     }
-  });
 
-  test('Check bids are committed', async () => {
+    await Promise.all(bidderAccounts.map(async (bidderAccount, i) => {
-    const [record] = await registry.lookupAuthorities([authorityName], true);
+      bidderAccounts[i].bid = await createBid(chainId, auctionId, bidderAccount.address, `${bidAmounts[i]}${DENOM}`);
-    expect(record.auction.id).toBeDefined();
+      return registry.commitBid({ auctionId, commitHash: bidderAccount.bid.commitHash }, bidderAccount.privateKey, fee);
-    expect(record.auction.status).toEqual('commit');
+    }));
-    expect(record.auction.bids).toHaveLength(accounts.length);
 
-    record.auction.bids.forEach((bid: any) => {
+    const [auction] = await registry.getAuctionsByIds([auctionId]);
+    expect(auction.status).toEqual('commit');
+    expect(auction.bids.length).toEqual(3);
+    auction.bids.forEach((bid: any) => {
       expect(bid.status).toEqual('commit');
     });
   });
 
   test('Wait for reveal phase.', (done) => {
-    setTimeout(done, 60 * 1000);
+    const commitTime = DURATION * 1000;
+    const waitTime = commitTime + (6 * 1000);
+
+    setTimeout(done, waitTime);
   });
 
   test('Reveal bids.', async () => {
     const [auction] = await registry.getAuctionsByIds([auctionId]);
     expect(auction.status).toEqual('reveal');
 
+    await Promise.all(bidderAccounts.map(async bidderAccount => {
+      return registry.revealBid({ auctionId, reveal: bidderAccount.bid.revealString }, bidderAccount.privateKey, fee);
+    }));
+  });
+
+  test('Check bids are revealed', async () => {
+    const [auction] = await registry.getAuctionsByIds([auctionId]);
+    expect(auction.status).toEqual('reveal');
+    auction.bids.forEach((bid: any) => {
+      expect(bid.status).toEqual('reveal');
+    });
+
+    const expectedBidAmounts = bidAmounts.map(bidAmount => { return { quantity: bidAmount.toString(), type: DENOM }; });
+    const actualBidAmounts = auction.bids.map((bid: any) => bid.bidAmount);
+    expect(actualBidAmounts).toEqual(expect.arrayContaining(expectedBidAmounts));
+
+    // Check that the bid amounts are locked after reveal phase
     for (let i = 0; i < numBidders; i++) {
-      await registry.revealBid({ auctionId, reveal: accounts[i].bid.revealString }, accounts[i].privateKey, fee);
+      // The bid amount, commit fee, reveal fee and tx fees (for commit and reveal txs) will be deducted from the bidder's acoount
+      const expectedBalance = BIDDER_INITIAL_BALANCE - parseInt(bidAmounts[i]) - (2 * TX_FEES) - parseInt(COMMIT_FEE) - parseInt(REVEAL_FEE);
+      await checkAccountBalance(registry, bidderAccounts[i].address, expectedBalance);
     }
   });
 
+  test('Wait for auction completion.', (done) => {
+    const revealTime = DURATION * 1000;
+    const waitTime = revealTime + (6 * 1000);
+
+    setTimeout(done, waitTime);
+  });
+
+  test('Check auction status, winner address and balance.', async () => {
+    const [auction] = await registry.getAuctionsByIds([auctionId]);
+    expect(auction.status).toEqual('completed');
+
+    const highestBidder = bidderAccounts[bidderAccounts.length - 1];
+    const secondHighestBidder = bidderAccounts[bidderAccounts.length - 2];
+
+    expect(auction.winnerAddresses).toHaveLength(1);
+
+    expect(auction.winnerAddresses[0]).toEqual(highestBidder.address);
+    expect(highestBidder.bid.reveal.bidAmount).toEqual(`${auction.winnerBids[0].quantity}${auction.winnerBids[0].type}`);
+    expect(secondHighestBidder.bid.reveal.bidAmount).toEqual(`${auction.winnerPrice.quantity}${auction.winnerPrice.type}`);
+
+    const winningPriceAmount = parseInt(auction.winnerPrice.quantity);
+
+    // The winning price will get deducted after auction completion
+    const expectedBalance = BIDDER_INITIAL_BALANCE - winningPriceAmount - (2 * TX_FEES) - parseInt(COMMIT_FEE);
+    await checkAccountBalance(registry, highestBidder.address, expectedBalance);
+  });
+};
+
+const providerAuctionTestsWithBids = (bidAmounts: number[], numProviders: number) => {
+  let registry: Registry;
+  let auctionId: string;
+
+  let auctionCreatorAccount: { address: string, privateKey: string };
+  let bidderAccounts: { address: string, privateKey: string, bid?: any }[] = [];
+  let sortedBidders: { address: string, privateKey: string, bid?: any }[] = [];
+  let filteredBidders: { address: string, privateKey: string, bid?: any }[] = [];
+  let invalidBidderAddress: string;
+  let otherAccount: { address: string, privateKey: string };
+
+  const numBidders = bidAmounts.length;
+  const maxPrice = 10 * LOWEST_BID_AMOUNT;
+
+  beforeAll(async () => {
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
+
+    // Create auction creator account
+    const [auctionCreator] = await createTestAccounts(1);
+    await registry.sendCoins({ denom: DENOM, amount: CREATOR_INITIAL_BALANCE.toString(), destinationAddress: auctionCreator.address }, privateKey, fee);
+    auctionCreatorAccount = { address: auctionCreator.address, privateKey: auctionCreator.privateKey.toString('hex') };
+
+    // Create bidder accounts
+    const accounts = await createTestAccounts(numBidders);
+    for (let i = 0; i < numBidders; i++) {
+      await registry.sendCoins({ denom: DENOM, amount: BIDDER_INITIAL_BALANCE.toString(), destinationAddress: accounts[i].address }, privateKey, fee);
+      bidderAccounts.push({ address: accounts[i].address, privateKey: accounts[i].privateKey.toString('hex') });
+    }
+
+    const mnenonic3 = Account.generateMnemonic();
+    const otherAcc = await Account.generateFromMnemonic(mnenonic3);
+    await otherAcc.init();
+
+    await registry.sendCoins({ denom: DENOM, amount: BIDDER_INITIAL_BALANCE.toString(), destinationAddress: otherAcc.address }, privateKey, fee);
+    otherAccount = { address: otherAcc.address, privateKey: otherAcc.privateKey.toString('hex') };
+  });
+
+  test('Create a provider auction', async () => {
+    const auction = await registry.createProviderAuction(
+      {
+        commitsDuration: DURATION.toString(),
+        revealsDuration: DURATION.toString(),
+        denom: DENOM,
+        commitFee: COMMIT_FEE,
+        revealFee: REVEAL_FEE,
+        maxPrice: maxPrice.toString(),
+        numProviders
+      },
+      auctionCreatorAccount.privateKey, fee
+    );
+
+    expect(auction.auction?.id).toBeDefined();
+
+    // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
+    auctionId = auction.auction!.id;
+    expect(auction.auction?.status).toEqual('commit');
+
+    // The locked amount and tx fees are deducted from the auction creator's account
+    const expectedBalance = CREATOR_INITIAL_BALANCE - (maxPrice * numProviders) - TX_FEES;
+    await checkAccountBalance(registry, auctionCreatorAccount.address, expectedBalance);
+  });
+
+  test('Commit bids.', async () => {
+    await Promise.all(bidderAccounts.map(async (bidderAccount, i) => {
+      bidderAccounts[i].bid = await createBid(chainId, auctionId, bidderAccount.address, `${bidAmounts[i]}${DENOM}`);
+      return registry.commitBid({ auctionId, commitHash: bidderAccount.bid.commitHash }, bidderAccount.privateKey, fee);
+    }));
+
+    sortedBidders = bidderAccounts.slice().sort((a, b) => {
+      return parseInt(a.bid.reveal.bidAmount) - parseInt(b.bid.reveal.bidAmount);
+    });
+
+    for (const bidder of sortedBidders) {
+      if (parseInt(bidder.bid.reveal.bidAmount) > maxPrice) {
+        invalidBidderAddress = bidder.address;
+      }
+    }
+
+    const [auction] = await registry.getAuctionsByIds([auctionId]);
+    expect(auction.status).toEqual('commit');
+    expect(auction.bids.length).toEqual(numBidders);
+    auction.bids.forEach((bid: any) => {
+      expect(bid.status).toEqual('commit');
+    });
+  });
+
+  test('Wait for reveal phase.', (done) => {
+    const commitTime = DURATION * 1000;
+    const waitTime = commitTime + (6 * 1000);
+
+    setTimeout(done, waitTime);
+  });
+
+  test('Reveal bids.', async () => {
+    const [auction] = await registry.getAuctionsByIds([auctionId]);
+    expect(auction.status).toEqual('reveal');
+
+    await Promise.all(bidderAccounts.map(async bidderAccount => {
+      try {
+        await registry.revealBid(
+          { auctionId, reveal: bidderAccount.bid.revealString },
+          bidderAccount.privateKey,
+          fee
+        );
+      } catch (error: any) {
+        if (bidderAccount.address === invalidBidderAddress) {
+          expect(error.toString()).toContain(INVALID_BID_ERROR);
+        } else {
+          throw error;
+        }
+      }
+    }));
+  });
+
   test('Check bids are revealed', async () => {
     const [auction] = await registry.getAuctionsByIds([auctionId]);
     expect(auction.status).toEqual('reveal');
 
-    auction.bids.forEach((bid: any) => {
+    const expectedBids = sortedBidders.map((bidder: any) => {
-      expect(bid.status).toEqual('reveal');
+      if (invalidBidderAddress === bidder.address) {
+        return '0';
+      }
+      return bidder.bid.reveal.bidAmount;
     });
+
+    const actualBidAmounts = auction.bids.map((bid: any) => `${bid.bidAmount.quantity}${bid.bidAmount.type}`);
+    expect(actualBidAmounts).toEqual(expect.arrayContaining(expectedBids));
   });
 
   test('Wait for auction completion.', (done) => {
-    setTimeout(done, 60 * 1000);
+    const revealTime = DURATION * 1000;
+    const waitTime = revealTime + (6 * 1000);
+
+    setTimeout(done, waitTime);
   });
 
-  test('Check auction winner, authority owner and status.', async () => {
+  test('Check auction status, winners and creator balance.', async () => {
     const [auction] = await registry.getAuctionsByIds([auctionId]);
     expect(auction.status).toEqual('completed');
 
-    const highestBidder = accounts[accounts.length - 1];
+    // Filter bidders to exclude bids exceeding maxPrice
-    const secondHighestBidder = (accounts.length > 1 ? accounts[accounts.length - 2] : highestBidder);
+    filteredBidders = sortedBidders.filter(bidder => {
+      return parseInt(bidder.bid.reveal.bidAmount) <= parseInt(`${maxPrice}${DENOM}`);
+    });
 
-    expect(auction.winnerAddress).toEqual(highestBidder.address);
+    const numWinners = Math.min(filteredBidders.length, numProviders);
-    expect(highestBidder.bid.reveal.bidAmount).toEqual(`${auction.winnerBid.quantity}${auction.winnerBid.type}`);
+    const winningBidders = filteredBidders.slice(0, numWinners);
-    expect(secondHighestBidder.bid.reveal.bidAmount).toEqual(`${auction.winnerPrice.quantity}${auction.winnerPrice.type}`);
 
-    const [record] = await registry.lookupAuthorities([authorityName], true);
+    // Check winner price is equal to highest winning bid
-    expect(record.ownerAddress).toEqual(highestBidder.address);
+    const expectedWinningPrice = winningBidders[numWinners - 1].bid.reveal.bidAmount;
-    expect(record.height).toBeDefined();
+    expect(`${auction.winnerPrice.quantity}${auction.winnerPrice.type}`).toEqual(expectedWinningPrice);
-    expect(record.status).toEqual('active');
+
+    // The total winning amount will get deducted and the leftover locked amount is returned
+    const totalWinningAmount = parseInt(auction.winnerPrice.quantity) * winningBidders.length;
+    const expectedCreatorBalance = CREATOR_INITIAL_BALANCE - totalWinningAmount - TX_FEES;
+    await checkAccountBalance(registry, auctionCreatorAccount.address, expectedCreatorBalance);
+
+    // Funds should not be given to winners on auction completion
+    for (let i = 0; i < winningBidders.length; i++) {
+      const bidWinner = winningBidders[i];
+
+      expect(auction.winnerAddresses[i]).toEqual(bidWinner.address);
+      expect(`${auction.winnerBids[i].quantity}${auction.winnerBids[i].type}`).toEqual(bidWinner.bid.reveal.bidAmount);
+
+      const expectedBidderBalance = BIDDER_INITIAL_BALANCE - (2 * TX_FEES) - parseInt(COMMIT_FEE);
+      await checkAccountBalance(registry, bidWinner.address, expectedBidderBalance);
+    }
+  });
+
+  test('Release funds and check provider balances.', async () => {
+    const [auction] = await registry.getAuctionsByIds([auctionId]);
+
+    const numWinners = Math.min(filteredBidders.length, numProviders);
+    const winningBidders = filteredBidders.slice(0, numWinners);
+    const losingBidders = bidderAccounts.filter(bidder => !winningBidders.includes(bidder));
+
+    const winningBidAmount = parseInt(auction.winnerPrice.quantity);
+
+    // Only owner can release funds
+    try {
+      await registry.releaseFunds({ auctionId }, otherAccount.privateKey, fee);
+    } catch (error: any) {
+      expect(error.toString()).toContain(OWNER_MISMATCH_ERROR);
+    }
+
+    // Release funds
+    const auctionObj = await registry.releaseFunds({ auctionId }, auctionCreatorAccount.privateKey, fee);
+    expect(auctionObj.auction?.fundsReleased).toBe(true);
+
+    // Auction winners get the winning amount after funds are released
+    const expectedBidderBalance = BIDDER_INITIAL_BALANCE + winningBidAmount - (2 * TX_FEES) - parseInt(COMMIT_FEE);
+    for (let i = 0; i < winningBidders.length; i++) {
+      const bidWinner = winningBidders[i];
+
+      expect(auction.winnerAddresses[i]).toEqual(bidWinner.address);
+      expect(`${auction.winnerBids[i].quantity}${auction.winnerBids[i].type}`).toEqual(bidWinner.bid.reveal.bidAmount);
+
+      await checkAccountBalance(registry, bidWinner.address, expectedBidderBalance);
+    }
+
+    // Check balances of non-winners
+    for (const bidder of losingBidders) {
+      let expectedBidderBalance: number;
+      if (invalidBidderAddress !== bidder.address) {
+        expectedBidderBalance = BIDDER_INITIAL_BALANCE - (2 * TX_FEES) - parseInt(COMMIT_FEE);
+      } else {
+        // Bid is invalid, reveal fees are not returned
+        expectedBidderBalance = BIDDER_INITIAL_BALANCE - (2 * TX_FEES) - parseInt(COMMIT_FEE) - parseInt(REVEAL_FEE);
+      }
+
+      await checkAccountBalance(registry, bidder.address, expectedBidderBalance);
+    }
+
+    // Funds cannot be released twice
+    try {
+      await registry.releaseFunds({ auctionId }, auctionCreatorAccount.privateKey, fee);
+    } catch (error: any) {
+      expect(error.toString()).toContain(RELEASE_FUNDS_ERROR);
+    }
   });
 };
 
-const withNumBidders = (numBidders: number) => () => auctionTests(numBidders);
+const checkAccountBalance = async (registry: Registry, address: string, expectedBalance: number): Promise<void> => {
+  const [winnerAccountObj] = await registry.getAccounts([address]);
+  const [{ type, quantity }] = winnerAccountObj.balance;
+  const actualBalance = parseInt(quantity);
 
-if (!process.env.TEST_AUCTIONS_ENABLED) {
+  expect(actualBalance).toBe(expectedBalance);
-  // Required as jest complains if file has no tests.
+  expect(type).toBe(DENOM);
-  test('skipping auction tests', () => {});
+};
-} else {
-  /**
-    Running these tests requires name auctions enabled. In laconicd repo run:
 
-    TEST_AUCTION_ENABLED=true ./init.sh
+const providerAuctionTests = () => {
+  // With a bid amount greater than the max price
+  const bids = [10002000, 10009000, 10006000 * 10, 10004000];
 
-    Run tests:
+  // Number of providers is less than number of bidders
+  describe('Auction with numProviders < numBidders', () => providerAuctionTestsWithBids(bids, 3));
+  // Number of providers is greater than number of bidders
+  describe('Auction numProviders > numBidders', () => providerAuctionTestsWithBids(bids, 5));
+};
 
-    yarn test:auctions
+describe('Vickrey Auction', () => auctionTests());
-  */
+describe('Provider Auction', () => providerAuctionTests());
-  describe('Auction (1 bidder)', withNumBidders(1));
-  describe('Auction (2 bidders)', withNumBidders(2));
-  describe('Auction (4 bidders)', withNumBidders(4));
-}

src/authority-auction.test.ts

@@ -0,0 +1,139 @@
+import { Registry, Account, createBid } from './index';
+import { getConfig } from './testing/helper';
+import { DENOM } from './constants';
+
+jest.setTimeout(30 * 60 * 1000);
+const { chainId, rpcEndpoint, gqlEndpoint, privateKey, fee } = getConfig();
+
+const DURATION = 60;
+
+const auctionTests = (numBidders = 3) => {
+  let registry: Registry;
+
+  const accounts: { address: string, privateKey: string, bid?: any }[] = [];
+
+  let auctionId: string;
+  let authorityName: string;
+
+  beforeAll(async () => {
+    console.log('Running auction tests with num bidders', numBidders);
+
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
+  });
+
+  test('Setup bidder accounts', async () => {
+    for (let i = 0; i < numBidders; i++) {
+      const mnenonic = Account.generateMnemonic();
+      const account = await Account.generateFromMnemonic(mnenonic);
+      await account.init();
+      await registry.sendCoins({ denom: DENOM, amount: '20000000', destinationAddress: account.address }, privateKey, fee);
+      accounts.push({ address: account.address, privateKey: account.privateKey.toString('hex') });
+    }
+  });
+
+  test('Reserve authority.', async () => {
+    authorityName = `laconic-${Date.now()}`;
+    await registry.reserveAuthority({ name: authorityName }, accounts[0].privateKey, fee);
+  });
+
+  test('Authority should be under auction.', async () => {
+    const [record] = await registry.lookupAuthorities([authorityName], true);
+    expect(record.ownerAddress).toEqual('');
+    expect(record.height).toBeDefined();
+    expect(record.status).toEqual('auction');
+
+    expect(record.auction.id).toBeDefined();
+    expect(record.auction.status).toEqual('commit');
+
+    auctionId = record.auction.id;
+  });
+
+  test('Commit bids.', async () => {
+    for (let i = 0; i < numBidders; i++) {
+      accounts[i].bid = await createBid(chainId, auctionId, accounts[i].address, `${10000000 + (i * 500)}${DENOM}`);
+      await registry.commitBid({ auctionId, commitHash: accounts[i].bid.commitHash }, accounts[i].privateKey, fee);
+    }
+  });
+
+  test('Check bids are committed', async () => {
+    const [record] = await registry.lookupAuthorities([authorityName], true);
+    expect(record.auction.id).toBeDefined();
+    expect(record.auction.status).toEqual('commit');
+    expect(record.auction.bids).toHaveLength(accounts.length);
+
+    record.auction.bids.forEach((bid: any) => {
+      expect(bid.status).toEqual('commit');
+    });
+  });
+
+  test('Wait for reveal phase.', (done) => {
+    const commitTime = DURATION * 1000;
+    const waitTime = commitTime + (6 * 1000);
+
+    setTimeout(done, waitTime);
+  });
+
+  test('Reveal bids.', async () => {
+    const [auction] = await registry.getAuctionsByIds([auctionId]);
+    expect(auction.status).toEqual('reveal');
+
+    for (let i = 0; i < numBidders; i++) {
+      await registry.revealBid({ auctionId, reveal: accounts[i].bid.revealString }, accounts[i].privateKey, fee);
+    }
+  });
+
+  test('Check bids are revealed', async () => {
+    const [auction] = await registry.getAuctionsByIds([auctionId]);
+    expect(auction.status).toEqual('reveal');
+
+    auction.bids.forEach((bid: any) => {
+      expect(bid.status).toEqual('reveal');
+    });
+  });
+
+  test('Wait for auction completion.', (done) => {
+    const revealTime = DURATION * 1000;
+    const waitTime = revealTime + (6 * 1000);
+
+    setTimeout(done, waitTime);
+  });
+
+  test('Check auction winner, authority owner and status.', async () => {
+    const [auction] = await registry.getAuctionsByIds([auctionId]);
+    expect(auction.status).toEqual('completed');
+
+    const highestBidder = accounts[accounts.length - 1];
+    const secondHighestBidder = (accounts.length > 1 ? accounts[accounts.length - 2] : highestBidder);
+
+    expect(auction.winnerAddresses).toHaveLength(1);
+
+    expect(auction.winnerAddresses[0]).toEqual(highestBidder.address);
+    expect(`${auction.winnerBids[0].quantity}${auction.winnerBids[0].type}`).toEqual(highestBidder.bid.reveal.bidAmount);
+    expect(`${auction.winnerPrice.quantity}${auction.winnerPrice.type}`).toEqual(secondHighestBidder.bid.reveal.bidAmount);
+
+    const [record] = await registry.lookupAuthorities([authorityName], true);
+    expect(record.ownerAddress).toEqual(highestBidder.address);
+    expect(record.height).toBeDefined();
+    expect(record.status).toEqual('active');
+  });
+};
+
+const withNumBidders = (numBidders: number) => () => auctionTests(numBidders);
+
+if (!process.env.TEST_AUCTIONS_ENABLED) {
+  // Required as jest complains if file has no tests.
+  test('skipping auction tests', () => {});
+} else {
+  /**
+    Running these tests requires name auctions enabled. In laconicd repo run:
+
+    TEST_AUCTION_ENABLED=true ./init.sh
+
+    Run tests:
+
+    yarn test:auctions
+  */
+  describe('Auction (1 bidder)', withNumBidders(1));
+  describe('Auction (2 bidders)', withNumBidders(2));
+  describe('Auction (4 bidders)', withNumBidders(4));
+}

src/bond.test.ts

@@ -1,6 +1,6 @@
 import path from 'path';
 
-import { Registry } from './index';
+import { Account, Registry } from './index';
 import { ensureUpdatedConfig, getConfig } from './testing/helper';
 import { DENOM } from './constants';
 
@@ -13,6 +13,7 @@ jest.setTimeout(90 * 1000);
 
 const bondTests = () => {
   let registry: Registry;
+  let bond0: { id: string, owner: string };
 
   const publishNewWatcherVersion = async (bondId: string) => {
     let watcher = await ensureUpdatedConfig(WATCHER_YML_PATH);
@@ -21,17 +22,19 @@ const bondTests = () => {
   };
 
   beforeAll(async () => {
-    registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
   });
 
   test('Create bond.', async () => {
     let bondId = await registry.getNextBondId(privateKey);
     expect(bondId).toBeDefined();
     await registry.createBond({ denom: DENOM, amount: BOND_AMOUNT }, privateKey, fee);
+
+    [bond0] = await registry.getBondsByIds([bondId]);
   });
 
   describe('With bond created', () => {
-    let bond1: any;
+    let bond1: { id: string, owner: string };
 
     beforeAll(async () => {
       let bondId1 = await registry.getNextBondId(privateKey);
@@ -54,15 +57,31 @@ const bondTests = () => {
     test('Query bonds.', async () => {
       const bonds = await registry.queryBonds();
       expect(bonds).toBeDefined();
-      const bond = bonds.filter((bond: any) => bond.id === bond1.id);
+
-      expect(bond).toBeDefined();
+      const filteredBonds = bonds.filter((bond: any) => bond.id === bond1.id);
+      expect(filteredBonds).toHaveLength(1);
+      expect(filteredBonds[0]).toMatchObject({ id: bond1.id, owner: bond1.owner });
     });
 
     test('Query bonds by owner.', async () => {
-      const bonds = await registry.queryBonds({ owner: bond1.owner });
+      const mnenonic = Account.generateMnemonic();
-      expect(bonds).toBeDefined();
+      const otherAccount = await Account.generateFromMnemonic(mnenonic);
-      const bond = bonds.filter((bond: any) => bond.id === bond1.id);
+      await otherAccount.init();
-      expect(bond).toBeDefined();
+      await registry.sendCoins({ denom: DENOM, amount: '1000000000000', destinationAddress: otherAccount.address }, privateKey, fee);
+
+      const { id: bondId2 } = await registry.createBond({ denom: DENOM, amount: BOND_AMOUNT }, otherAccount.getPrivateKey(), fee);
+
+      const [owner1Bonds] = await registry.queryBondsByOwners([bond0.owner]);
+      const owner1Bond1 = owner1Bonds.bonds.filter((b: any) => b.id === bond0.id);
+      const owner1Bond2 = owner1Bonds.bonds.filter((b: any) => b.id === bond1.id);
+      expect(owner1Bond1).toBeDefined();
+      expect(owner1Bond2).toBeDefined();
+
+      const [bond2] = await registry.getBondsByIds([bondId2]);
+      const [owner2Bonds] = await registry.queryBondsByOwners([bond2.owner]);
+      expect(owner2Bonds.bonds).toHaveLength(1);
+      const owner2Bond = owner2Bonds.bonds.filter((b: any) => b.id === bondId2);
+      expect(owner2Bond).toBeDefined();
     });
 
     test('Refill bond.', async () => {

src/config.test.ts

@@ -0,0 +1,103 @@
+import { GasPrice } from '@cosmjs/stargate';
+
+import { Account } from './account';
+import { DENOM } from './constants';
+import { Registry } from './index';
+import { createTestAccounts, getConfig } from './testing/helper';
+
+const { chainId, rpcEndpoint, gqlEndpoint, privateKey, fee } = getConfig();
+
+jest.setTimeout(90 * 1000);
+
+const configTests = () => {
+  let registry: Registry;
+  let testAccount: Account;
+
+  beforeAll(async () => {
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
+
+    // Fund a new account for the test
+    [testAccount] = await createTestAccounts(1);
+    await registry.sendCoins({ denom: DENOM, amount: '10000000', destinationAddress: testAccount.address }, privateKey, fee);
+  });
+
+  test('StdFee fees with gas price not set', async () => {
+    const testFees = {
+      amount: [{ denom: 'alnt', amount: '400000' }],
+      gas: '400000'
+    };
+
+    // Send a bond creation tx
+    await registry.createBond({ denom: DENOM, amount: '100000' }, testAccount.getPrivateKey(), testFees);
+
+    // Check that bond gets created
+    const [result] = await registry.queryBondsByOwners([testAccount.address]);
+    expect(result.bonds).toHaveLength(1);
+  });
+
+  test('StdFee fees with gas price set', async () => {
+    const testFees = {
+      amount: [{ denom: 'alnt', amount: '400000' }],
+      gas: '400000'
+    };
+
+    // Set gas price lower than min gas price
+    const testGasPrice = GasPrice.fromString(String('0.00001alnt'));
+    const registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId, gasPrice: testGasPrice });
+
+    // Send a bond creation tx
+    await registry.createBond({ denom: DENOM, amount: '100000' }, testAccount.getPrivateKey(), testFees);
+
+    // Check that bond gets created (gas price ignored)
+    const [result] = await registry.queryBondsByOwners([testAccount.address]);
+    expect(result.bonds).toHaveLength(2);
+  });
+
+  test('Gas price with fees not set (default gas estimation multiplier)', async () => {
+    // Set gas price
+    const testGasPrice = GasPrice.fromString('1alnt');
+    const registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId, gasPrice: testGasPrice });
+
+    // Send a bond creation tx
+    await registry.createBond({ denom: DENOM, amount: '100000' }, testAccount.getPrivateKey());
+
+    // Check that bond gets created (gas price ignored)
+    const [result] = await registry.queryBondsByOwners([testAccount.address]);
+    expect(result.bonds).toHaveLength(3);
+  });
+
+  test('Gas price with fees set (fees as the gas estimation multiplier)', async () => {
+    const testFees = 2.1;
+
+    // Set gas price
+    const testGasPrice = GasPrice.fromString('1alnt');
+    const registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId, gasPrice: testGasPrice });
+
+    // Send a bond creation tx
+    await registry.createBond({ denom: DENOM, amount: '100000' }, testAccount.getPrivateKey(), testFees);
+
+    // Check that bond gets created (gas price ignored)
+    const [result] = await registry.queryBondsByOwners([testAccount.address]);
+    expect(result.bonds).toHaveLength(4);
+  });
+
+  test('Error on fees and gas price both not set', async () => {
+    const errorMsg = 'Gas price must be set in the client options when auto gas is used';
+
+    // Create registry without gasPrice
+    const registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
+
+    // Send a bond creation tx
+    try {
+      await registry.createBond({ denom: DENOM, amount: '100000' }, testAccount.getPrivateKey());
+    } catch (error: any) {
+      expect(error.toString()).toContain(errorMsg);
+    }
+
+    // Check that bond doesn't get created
+    const [result] = await registry.queryBondsByOwners([testAccount.address]);
+    expect(result.bonds).toHaveLength(4);
+  });
+};
+
+describe('Config', configTests);

src/constants.ts

@@ -1 +1,5 @@
 export const DENOM = 'alnt';
+export const DEFAULT_GAS_ESTIMATION_MULTIPLIER = 2;
+
+export const AUCTION_KIND_VICKREY = 'vickrey';
+export const AUCTION_KIND_PROVIDER = 'provider';

src/index.test.ts

@@ -1,7 +1,7 @@
 import { Account } from './account';
 import { DENOM } from './constants';
 import { Registry } from './index';
-import { getConfig } from './testing/helper';
+import { createTestAccounts, getConfig } from './testing/helper';
 
 const { chainId, rpcEndpoint, gqlEndpoint, privateKey, fee } = getConfig();
 
@@ -11,7 +11,7 @@ const registryTests = () => {
   let registry: Registry;
 
   beforeAll(async () => {
-    registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
   });
 
   test('Get account info.', async () => {
@@ -43,6 +43,40 @@ const registryTests = () => {
     expect(type).toBe(DENOM);
     expect(quantity).toBe('10000');
   });
+
+  describe('Batch txs', () => {
+    let accounts: Account[];
+
+    beforeAll(async () => {
+      // Fund 5 new accounts for the test
+      accounts = await createTestAccounts(5);
+      for (let i = 0; i < accounts.length; i++) {
+        await registry.sendCoins({ denom: DENOM, amount: '1000000', destinationAddress: accounts[i].address }, privateKey, fee);
+      }
+    });
+
+    test('Multiple txs get included in a block.', async () => {
+      // Send a bond creation tx from each account (send from different accounts to avoid sequence errors)
+      await Promise.all(accounts.map((account) =>
+        registry.createBond({ denom: DENOM, amount: '100000' }, account.getPrivateKey(), fee)
+      ));
+
+      const laconicClient = await registry.getLaconicClient(accounts[0]);
+      const bondCreationTxHeights = await Promise.all(accounts.map(async (account) => {
+        // Get the bond creation tx for each account
+        const [tx] = await laconicClient.searchTx(`message.sender='${account.address}' AND message.action='/cerc.bond.v1.MsgCreateBond'`);
+        return tx.height;
+      }));
+
+      bondCreationTxHeights.forEach((txHeight, i) => {
+        console.log('tx', accounts[i].address, txHeight);
+      });
+
+      // Check that all txs are within two blocks
+      const expectedBlockHeight = bondCreationTxHeights.sort()[0];
+      expect(bondCreationTxHeights.every(txHeight => txHeight === expectedBlockHeight || txHeight === expectedBlockHeight + 1)).toBe(true);
+    });
+  });
 };
 
 describe('Registry', registryTests);

src/index.ts

@@ -1,6 +1,6 @@
 import { sha256 } from 'js-sha256';
 
-import { DeliverTxResponse, StdFee } from '@cosmjs/stargate';
+import { DeliverTxResponse, StdFee, GasPrice } from '@cosmjs/stargate';
 
 import { RegistryClient } from './registry-client';
 import { Account } from './account';
@@ -22,7 +22,10 @@ import {
 } from './types/cerc/registry/message';
 import {
   MessageMsgCommitBid,
-  MessageMsgRevealBid
+  MessageMsgRevealBid,
+  MessageCreateVickreyAuction,
+  MessageCreateProviderAuction,
+  MessageMsgReleaseFunds
 } from './types/cerc/auction/message';
 import { MessageMsgSendCoins } from './types/cosmos/bank/message';
 import { MessageMsgOnboardParticipant } from './types/cerc/onboarding/message';
@@ -31,8 +34,8 @@ import { Coin } from './proto/cosmos/base/v1beta1/coin';
 import { MsgCancelBondResponse, MsgCreateBondResponse, MsgRefillBondResponse, MsgWithdrawBondResponse } from './proto/cerc/bond/v1/tx';
 import { MsgOnboardParticipantResponse } from './proto/cerc/onboarding/v1/tx';
 import { MsgSendResponse } from './proto/cosmos/bank/v1beta1/tx';
-
+import { AUCTION_KIND_PROVIDER, AUCTION_KIND_VICKREY, DEFAULT_GAS_ESTIMATION_MULTIPLIER } from './constants';
-export const DEFAULT_CHAIN_ID = 'laconic_9000-1';
+import { MsgCreateAuctionResponse } from './proto/cerc/auction/v1/tx';
 
 /**
  * Create an auction bid.
@@ -60,19 +63,26 @@ export const createBid = async (chainId: string, auctionId: string, bidderAddres
   };
 };
 
+interface RegistryOptions {
+  chainId: string
+  gasPrice?: GasPrice
+}
+
 export class Registry {
   _endpoints: { [key: string]: string };
   _chainID: string;
   _client: RegistryClient;
+  _gasPrice?: GasPrice;
 
-  constructor (gqlUrl: string, rpcUrl = '', chainId: string = DEFAULT_CHAIN_ID) {
+  constructor (gqlUrl: string, rpcUrl = '', options: RegistryOptions) {
     this._endpoints = {
       rpc: rpcUrl,
       gql: gqlUrl
     };
 
     this._client = new RegistryClient(gqlUrl, rpcUrl);
-    this._chainID = chainId;
+    this._chainID = options.chainId;
+    this._gasPrice = options.gasPrice;
   }
 
   /**
@@ -107,8 +117,8 @@ export class Registry {
   /**
    * Get records by attributes.
    */
-  async queryRecords (attributes: { [key: string]: any }, all = false, refs = false) {
+  async queryRecords (attributes: { [key: string]: any }, all = false, refs = false, limit?: number, offset?: number) {
-    return this._client.queryRecords(attributes, all, refs);
+    return this._client.queryRecords(attributes, all, refs, limit, offset);
   }
 
   /**
@@ -125,7 +135,7 @@ export class Registry {
   async setRecord (
     { privateKey, record, bondId }: { privateKey: string, record: any, bondId: string },
     transactionPrivateKey: string,
-    fee: StdFee
+    fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER
   ) {
     const account = new Account(Buffer.from(transactionPrivateKey, 'hex'));
     await account.init();
@@ -140,7 +150,7 @@ export class Registry {
   /**
    * Send coins.
    */
-  async sendCoins ({ amount, denom, destinationAddress }: MessageMsgSendCoins, privateKey: string, fee: StdFee) {
+  async sendCoins ({ amount, denom, destinationAddress }: MessageMsgSendCoins, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -186,16 +196,23 @@ export class Registry {
   }
 
   /**
-   * Query bonds by attributes.
+   * Query bonds.
    */
-  async queryBonds (attributes = {}) {
+  async queryBonds () {
-    return this._client.queryBonds(attributes);
+    return this._client.queryBonds();
+  }
+
+  /**
+ * Query bonds by owner(s).
+ */
+  async queryBondsByOwners (owners: string[]) {
+    return this._client.queryBondsByOwners(owners);
   }
 
   /**
    * Create bond.
    */
-  async createBond ({ denom, amount }: MessageMsgCreateBond, privateKey: string, fee: StdFee): Promise<MsgCreateBondResponse> {
+  async createBond ({ denom, amount }: MessageMsgCreateBond, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER): Promise<MsgCreateBondResponse> {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -211,7 +228,7 @@ export class Registry {
   /**
    * Refill bond.
    */
-  async refillBond ({ denom, amount, id }: MessageMsgRefillBond, privateKey: string, fee: StdFee): Promise<MsgRefillBondResponse> {
+  async refillBond ({ denom, amount, id }: MessageMsgRefillBond, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER): Promise<MsgRefillBondResponse> {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -228,7 +245,7 @@ export class Registry {
   /**
    * Withdraw (from) bond.
    */
-  async withdrawBond ({ denom, amount, id }: MessageMsgWithdrawBond, privateKey: string, fee: StdFee): Promise<MsgWithdrawBondResponse> {
+  async withdrawBond ({ denom, amount, id }: MessageMsgWithdrawBond, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER): Promise<MsgWithdrawBondResponse> {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -245,7 +262,7 @@ export class Registry {
   /**
    * Cancel bond.
    */
-  async cancelBond ({ id }: MessageMsgCancelBond, privateKey: string, fee: StdFee): Promise<MsgCancelBondResponse> {
+  async cancelBond ({ id }: MessageMsgCancelBond, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER): Promise<MsgCancelBondResponse> {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -260,7 +277,7 @@ export class Registry {
   /**
    * Associate record with bond.
    */
-  async associateBond ({ bondId, recordId }: MessageMsgAssociateBond, privateKey: string, fee: StdFee) {
+  async associateBond ({ bondId, recordId }: MessageMsgAssociateBond, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -276,7 +293,7 @@ export class Registry {
   /**
    * Dissociate record from bond.
    */
-  async dissociateBond ({ recordId }: MessageMsgDissociateBond, privateKey: string, fee: StdFee) {
+  async dissociateBond ({ recordId }: MessageMsgDissociateBond, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -291,7 +308,7 @@ export class Registry {
   /**
    * Dissociate all records from bond.
    */
-  async dissociateRecords ({ bondId }: MessageMsgDissociateRecords, privateKey: string, fee: StdFee) {
+  async dissociateRecords ({ bondId }: MessageMsgDissociateRecords, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -306,7 +323,7 @@ export class Registry {
   /**
    * Reassociate records (switch bond).
    */
-  async reassociateRecords ({ newBondId, oldBondId }: MessageMsgReAssociateRecords, privateKey: string, fee: StdFee) {
+  async reassociateRecords ({ newBondId, oldBondId }: MessageMsgReAssociateRecords, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -322,7 +339,7 @@ export class Registry {
   /**
    * Reserve authority.
    */
-  async reserveAuthority ({ name, owner }: { name: string, owner?: string }, privateKey: string, fee: StdFee) {
+  async reserveAuthority ({ name, owner }: { name: string, owner?: string }, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -338,7 +355,7 @@ export class Registry {
   /**
    * Set authority bond.
    */
-  async setAuthorityBond ({ bondId, name }: MessageMsgSetAuthorityBond, privateKey: string, fee: StdFee) {
+  async setAuthorityBond ({ bondId, name }: MessageMsgSetAuthorityBond, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -354,7 +371,7 @@ export class Registry {
   /**
    * Commit auction bid.
    */
-  async commitBid ({ auctionId, commitHash }: MessageMsgCommitBid, privateKey: string, fee: StdFee) {
+  async commitBid ({ auctionId, commitHash }: MessageMsgCommitBid, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -370,7 +387,7 @@ export class Registry {
   /**
    * Reveal auction bid.
    */
-  async revealBid ({ auctionId, reveal }: MessageMsgRevealBid, privateKey: string, fee: StdFee) {
+  async revealBid ({ auctionId, reveal }: MessageMsgRevealBid, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -406,7 +423,7 @@ export class Registry {
   /**
    * Set name (LRN) to record ID (CID).
    */
-  async setName ({ cid, lrn }: MessageMsgSetName, privateKey: string, fee: StdFee) {
+  async setName ({ cid, lrn }: MessageMsgSetName, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -429,7 +446,7 @@ export class Registry {
   /**
    * Delete name (LRN) mapping.
    */
-  async deleteName ({ lrn }: MessageMsgDeleteName, privateKey: string, fee: StdFee) {
+  async deleteName ({ lrn }: MessageMsgDeleteName, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -440,14 +457,10 @@ export class Registry {
     );
   }
 
-  async getLaconicClient (account: Account) {
-    return LaconicClient.connectWithSigner(this._endpoints.rpc, account.wallet);
-  }
-
   /**
    * Onboard participant.
    */
-  async onboardParticipant ({ ethPayload, ethSignature, role, kycId }: MessageMsgOnboardParticipant, privateKey: string, fee: StdFee): Promise<MsgOnboardParticipantResponse> {
+  async onboardParticipant ({ ethPayload, ethSignature, role, kycId }: MessageMsgOnboardParticipant, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER): Promise<MsgOnboardParticipantResponse> {
     const account = new Account(Buffer.from(privateKey, 'hex'));
     await account.init();
     const laconicClient = await this.getLaconicClient(account);
@@ -482,9 +495,97 @@ export class Registry {
   async getParticipantByNitroAddress (nitroAddress: string) {
     return this._client.getParticipantByNitroAddress(nitroAddress);
   }
+
+  async getLaconicClient (account: Account) {
+    return LaconicClient.connectWithSigner(
+      this._endpoints.rpc,
+      account.wallet,
+      { gasPrice: this._gasPrice }
+    );
+  }
+
+  async createAuction (
+    {
+      commitsDuration,
+      revealsDuration,
+      denom,
+      commitFee,
+      revealFee,
+      minimumBid
+    }: MessageCreateVickreyAuction,
+    privateKey: string,
+    fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER
+  ): Promise<MsgCreateAuctionResponse> {
+    const account = new Account(Buffer.from(privateKey, 'hex'));
+    await account.init();
+    const laconicClient = await this.getLaconicClient(account);
+
+    return laconicClient.createAuction(
+      account.address,
+      AUCTION_KIND_VICKREY,
+      commitsDuration,
+      revealsDuration,
+      denom,
+      commitFee,
+      revealFee,
+      minimumBid,
+      '',
+      0,
+      fee
+    );
+  }
+
+  async createProviderAuction (
+    {
+      commitsDuration,
+      revealsDuration,
+      denom,
+      commitFee,
+      revealFee,
+      maxPrice,
+      numProviders
+    }: MessageCreateProviderAuction,
+    privateKey: string,
+    fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER
+  ): Promise<MsgCreateAuctionResponse> {
+    const account = new Account(Buffer.from(privateKey, 'hex'));
+    await account.init();
+    const laconicClient = await this.getLaconicClient(account);
+
+    return laconicClient.createAuction(
+      account.address,
+      AUCTION_KIND_PROVIDER,
+      commitsDuration,
+      revealsDuration,
+      denom,
+      commitFee,
+      revealFee,
+      '',
+      maxPrice,
+      numProviders,
+      fee
+    );
+  }
+
+  /**
+   * Release provider auction winner funds.
+   */
+  async releaseFunds ({ auctionId }: MessageMsgReleaseFunds, privateKey: string, fee: StdFee | number = DEFAULT_GAS_ESTIMATION_MULTIPLIER) {
+    const account = new Account(Buffer.from(privateKey, 'hex'));
+    await account.init();
+    const laconicClient = await this.getLaconicClient(account);
+
+    return laconicClient.releaseFunds(
+      account.address,
+      auctionId,
+      fee
+    );
+  }
 }
 
 export { Account };
 export { LaconicClient };
+export * from './constants';
 export * from './types/cerc/bond/message';
 export * from './types/cerc/onboarding/message';
+export { getGasPrice, parseGasAndFees } from './util';

src/laconic-client.ts

@@ -1,3 +1,4 @@
+import Long from 'long';
 
 import { GeneratedType, OfflineSigner, Registry } from '@cosmjs/proto-signing';
 import {
@@ -12,17 +13,18 @@ import { Comet38Client } from '@cosmjs/tendermint-rpc';
 import { MsgCancelBondEncodeObject, MsgCreateBondEncodeObject, MsgRefillBondEncodeObject, MsgWithdrawBondEncodeObject, bondTypes, typeUrlMsgCancelBond, typeUrlMsgCreateBond, typeUrlMsgRefillBond, typeUrlMsgWithdrawBond } from './types/cerc/bond/message';
 import { Coin } from './proto/cosmos/base/v1beta1/coin';
 import { MsgAssociateBondEncodeObject, MsgDeleteNameEncodeObject, MsgDissociateBondEncodeObject, MsgDissociateRecordsEncodeObject, MsgReassociateRecordsEncodeObject, MsgReserveAuthorityEncodeObject, MsgSetAuthorityBondEncodeObject, MsgSetNameEncodeObject, MsgSetRecordEncodeObject, registryTypes, typeUrlMsgAssociateBond, typeUrlMsgDeleteName, typeUrlMsgDissociateBond, typeUrlMsgDissociateRecords, typeUrlMsgReassociateRecords, typeUrlMsgReserveAuthority, typeUrlMsgSetAuthorityBond, typeUrlMsgSetName, typeUrlMsgSetRecord, NAMESERVICE_ERRORS } from './types/cerc/registry/message';
-import { MsgCommitBidEncodeObject, MsgRevealBidEncodeObject, auctionTypes, typeUrlMsgCommitBid, typeUrlMsgRevealBid } from './types/cerc/auction/message';
+import { AUCTION_ERRORS, MsgCommitBidEncodeObject, MsgCreateAuctionEncodeObject, MsgReleaseFundsEncodeObject, MsgRevealBidEncodeObject, auctionTypes, typeUrlMsgCommitBid, typeUrlMsgCreateAuction, typeUrlMsgReleaseFunds, typeUrlMsgRevealBid } from './types/cerc/auction/message';
-import { MsgOnboardParticipantEncodeObject, onboardingTypes, typeUrlMsgOnboardParticipant } from './types/cerc/onboarding/message';
+import { MsgOnboardParticipantEncodeObject, ONBOARDING_DISABLED_ERROR, onboardingTypes, typeUrlMsgOnboardParticipant } from './types/cerc/onboarding/message';
 import { MsgAssociateBondResponse, MsgDeleteNameResponse, MsgDissociateBondResponse, MsgDissociateRecordsResponse, MsgReassociateRecordsResponse, MsgReserveAuthorityResponse, MsgSetAuthorityBondResponse, MsgSetNameResponse, MsgSetRecordResponse, Payload } from './proto/cerc/registry/v1/tx';
 import { Record, Signature } from './proto/cerc/registry/v1/registry';
 import { Account } from './account';
 import { Util } from './util';
-import { MsgCommitBidResponse, MsgRevealBidResponse } from './proto/cerc/auction/v1/tx';
+import { MsgCommitBidResponse, MsgCreateAuction, MsgCreateAuctionResponse, MsgReleaseFundsResponse, MsgRevealBidResponse } from './proto/cerc/auction/v1/tx';
 import { MsgCancelBondResponse, MsgCreateBondResponse, MsgRefillBondResponse, MsgWithdrawBondResponse } from './proto/cerc/bond/v1/tx';
 import { MsgOnboardParticipantResponse } from './proto/cerc/onboarding/v1/tx';
 import { bankTypes } from './types/cosmos/bank/message';
 import { EthPayload } from './proto/cerc/onboarding/v1/onboarding';
+import { Duration } from './proto/google/protobuf/duration';
 
 const DEFAULT_WRITE_ERROR = 'Unable to write to laconicd.';
 
@@ -381,7 +383,7 @@ export class LaconicClient extends SigningStargateClient {
   }
 
   processWriteError (error: string) {
-    const errorMessage = NAMESERVICE_ERRORS.find(message => error.includes(message));
+    const errorMessage = [...NAMESERVICE_ERRORS, ...AUCTION_ERRORS, ONBOARDING_DISABLED_ERROR].find(message => error.includes(message));
 
     if (!errorMessage) {
       console.error(error);
@@ -413,4 +415,55 @@ export class LaconicClient extends SigningStargateClient {
     const response = await this.signAndBroadcast(signer, [onboardParticipantMsg], fee, memo);
     return this.parseResponse<MsgOnboardParticipantResponse>(response);
   }
+
+  public async createAuction (
+    signer: string,
+    kind: string,
+    commitsDuration: string,
+    revealsDuration: string,
+    denom: string,
+    commitFee: string,
+    revealFee: string,
+    minimumBid: string,
+    maxPrice: string,
+    numProviders: number,
+    fee: StdFee | 'auto' | number,
+    memo = ''
+  ) {
+    const createAuctionMsg: MsgCreateAuctionEncodeObject = {
+      typeUrl: typeUrlMsgCreateAuction,
+      value: {
+        signer,
+        kind,
+        commitsDuration: Duration.fromPartial({ seconds: Long.fromString(commitsDuration) }),
+        revealsDuration: Duration.fromPartial({ seconds: Long.fromString(revealsDuration) }),
+        commitFee: Coin.fromPartial({ amount: commitFee, denom }),
+        revealFee: Coin.fromPartial({ amount: revealFee, denom }),
+        minimumBid: Coin.fromPartial({ amount: minimumBid, denom }),
+        maxPrice: Coin.fromPartial({ amount: maxPrice, denom }),
+        numProviders
+      }
+    };
+
+    const response = await this.signAndBroadcast(signer, [createAuctionMsg], fee, memo);
+    return this.parseResponse<MsgCreateAuctionResponse>(response);
+  }
+
+  public async releaseFunds (
+    signer: string,
+    auctionId: string,
+    fee: StdFee | 'auto' | number,
+    memo = ''
+  ) {
+    const createMsg: MsgReleaseFundsEncodeObject = {
+      typeUrl: typeUrlMsgReleaseFunds,
+      value: {
+        signer,
+        auctionId
+      }
+    };
+
+    const response = await this.signAndBroadcast(signer, [createMsg], fee, memo);
+    return this.parseResponse<MsgReleaseFundsResponse>(response);
+  }
 }

src/nameservice-expiry.test.ts

@@ -21,7 +21,7 @@ const nameserviceExpiryTests = () => {
   let recordExpiryTime: Date;
 
   beforeAll(async () => {
-    registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
 
     // Create bond.
     bondId = await registry.getNextBondId(privateKey);

src/naming.test.ts

@@ -34,7 +34,7 @@ const namingTests = () => {
   let account: CosmosAccount;
 
   beforeAll(async () => {
-    registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
 
     // Create bond.
     bondId = await registry.getNextBondId(privateKey);

src/onboarding.test.ts

@@ -2,7 +2,7 @@ import { Wallet } from 'ethers';
 
 import { DirectSecp256k1Wallet, AccountData as CosmosAccount } from '@cosmjs/proto-signing';
 
-import { Registry, Account } from './index';
+import { Registry, Account, ONBOARDING_DISABLED_ERROR } from './index';
 import { getConfig } from './testing/helper';
 import { Participant } from './proto/cerc/onboarding/v1/onboarding';
 
@@ -20,7 +20,7 @@ const onboardingEnabledTests = () => {
   let expectedParticipants: Participant[] = [];
 
   beforeAll(async () => {
-    registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
 
     const mnemonic = Account.generateMnemonic();
     ethWallet = Wallet.fromMnemonic(mnemonic);
@@ -76,11 +76,10 @@ const onboardingDisabledTests = () => {
   let ethWallet: Wallet;
 
   beforeAll(async () => {
-    registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
   });
 
   test('Error on onboarding attempt.', async () => {
-    const errorMsg = 'Validator onboarding is disabled: invalid request';
     const mnemonic = Account.generateMnemonic();
     ethWallet = Wallet.fromMnemonic(mnemonic);
 
@@ -100,7 +99,7 @@ const onboardingDisabledTests = () => {
         kycId: DUMMY_KYC_ID
       }, privateKey, fee);
     } catch (error: any) {
-      expect(error.toString()).toContain(errorMsg);
+      expect(error.toString()).toContain(ONBOARDING_DISABLED_ERROR);
     }
   });
 

src/proto/cerc/auction/module/v1/module.ts

@@ -8,14 +8,26 @@ export const protobufPackage = "cerc.auction.module.v1";
  * Module is the app config object of the module.
  * Learn more: https://docs.cosmos.network/main/building-modules/depinject
  */
-export interface Module {}
+export interface Module {
+  /**
+   * authority defines the custom module authority. If not set, defaults to the
+   * governance module.
+   */
+  authority: string;
+}
 
 function createBaseModule(): Module {
-  return {};
+  return { authority: "" };
 }
 
 export const Module = {
-  encode(_: Module, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
+  encode(
+    message: Module,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    if (message.authority !== "") {
+      writer.uint32(18).string(message.authority);
+    }
     return writer;
   },
 
@@ -26,6 +38,9 @@ export const Module = {
     while (reader.pos < end) {
       const tag = reader.uint32();
       switch (tag >>> 3) {
+        case 2:
+          message.authority = reader.string();
+          break;
         default:
           reader.skipType(tag & 7);
           break;
@@ -34,17 +49,21 @@ export const Module = {
     return message;
   },
 
-  fromJSON(_: any): Module {
+  fromJSON(object: any): Module {
-    return {};
+    return {
+      authority: isSet(object.authority) ? String(object.authority) : "",
+    };
   },
 
-  toJSON(_: Module): unknown {
+  toJSON(message: Module): unknown {
     const obj: any = {};
+    message.authority !== undefined && (obj.authority = message.authority);
     return obj;
   },
 
-  fromPartial<I extends Exact<DeepPartial<Module>, I>>(_: I): Module {
+  fromPartial<I extends Exact<DeepPartial<Module>, I>>(object: I): Module {
     const message = createBaseModule();
+    message.authority = object.authority ?? "";
     return message;
   },
 };
@@ -81,3 +100,7 @@ if (_m0.util.Long !== Long) {
   _m0.util.Long = Long as any;
   _m0.configure();
 }
+
+function isSet(value: any): boolean {
+  return value !== null && value !== undefined;
+}

src/proto/cerc/auction/v1/auction.ts

@@ -1,5 +1,4 @@
 /* eslint-disable */
-import { Duration } from "../../../google/protobuf/duration";
 import { Coin } from "../../../cosmos/base/v1beta1/coin";
 import { Timestamp } from "../../../google/protobuf/timestamp";
 import Long from "long";
@@ -8,22 +7,13 @@ import _m0 from "protobufjs/minimal";
 export const protobufPackage = "cerc.auction.v1";
 
 /** Params defines the auction module parameters */
-export interface Params {
+export interface Params {}
-  /** Duration of the commits phase in seconds */
-  commitsDuration?: Duration;
-  /** Duration of the reveals phase in seconds */
-  revealsDuration?: Duration;
-  /** Commit fees */
-  commitFee?: Coin;
-  /** Reveal fees */
-  revealFee?: Coin;
-  /** Minimum acceptable bid amount */
-  minimumBid?: Coin;
-}
 
 /** Auction represents a sealed-bid on-chain auction */
 export interface Auction {
   id: string;
+  /** Auction kind (vickrey | provider) */
+  kind: string;
   status: string;
   /** Address of the creator of the auction */
   ownerAddress: string;
@@ -39,14 +29,37 @@ export interface Auction {
    */
   commitFee?: Coin;
   revealFee?: Coin;
-  /** Minimum acceptable bid amount for a valid commit */
+  /**
+   * Minimum acceptable bid amount for a valid commit
+   * Only applicable in vickrey auctions
+   */
   minimumBid?: Coin;
-  /** Address of the winner */
+  /**
-  winnerAddress: string;
+   * Addresses of the winners
-  /** Winning bid, i.e., the highest bid */
+   * (single winner for vickrey auction)
-  winningBid?: Coin;
+   * (multiple winners for provider auctions)
-  /** Amount the winner pays, i.e. the second highest auction */
+   */
+  winnerAddresses: string[];
+  /** Winning bids, i.e. the best bids */
+  winningBids: Coin[];
+  /**
+   * Auction winning price
+   * vickrey auction: second highest bid, paid by the winner
+   * provider auction: higest bid amongst winning_bids, paid by auction creator
+   * to each winner
+   */
   winningPrice?: Coin;
+  /**
+   * Maximum acceptable bid amount for a valid commit
+   * Only applicable in provider auctions
+   */
+  maxPrice?: Coin;
+  /**
+   * Number of desired providers (num of auction winners)
+   * Only applicable in provider auctions
+   */
+  numProviders: number;
+  fundsReleased: boolean;
 }
 
 /** Auctions represent all the auctions in the module */
@@ -68,41 +81,11 @@ export interface Bid {
 }
 
 function createBaseParams(): Params {
-  return {
+  return {};
-    commitsDuration: undefined,
-    revealsDuration: undefined,
-    commitFee: undefined,
-    revealFee: undefined,
-    minimumBid: undefined,
-  };
 }
 
 export const Params = {
-  encode(
+  encode(_: Params, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
-    message: Params,
-    writer: _m0.Writer = _m0.Writer.create()
-  ): _m0.Writer {
-    if (message.commitsDuration !== undefined) {
-      Duration.encode(
-        message.commitsDuration,
-        writer.uint32(10).fork()
-      ).ldelim();
-    }
-    if (message.revealsDuration !== undefined) {
-      Duration.encode(
-        message.revealsDuration,
-        writer.uint32(18).fork()
-      ).ldelim();
-    }
-    if (message.commitFee !== undefined) {
-      Coin.encode(message.commitFee, writer.uint32(26).fork()).ldelim();
-    }
-    if (message.revealFee !== undefined) {
-      Coin.encode(message.revealFee, writer.uint32(34).fork()).ldelim();
-    }
-    if (message.minimumBid !== undefined) {
-      Coin.encode(message.minimumBid, writer.uint32(42).fork()).ldelim();
-    }
     return writer;
   },
 
@@ -113,21 +96,6 @@ export const Params = {
     while (reader.pos < end) {
       const tag = reader.uint32();
       switch (tag >>> 3) {
-        case 1:
-          message.commitsDuration = Duration.decode(reader, reader.uint32());
-          break;
-        case 2:
-          message.revealsDuration = Duration.decode(reader, reader.uint32());
-          break;
-        case 3:
-          message.commitFee = Coin.decode(reader, reader.uint32());
-          break;
-        case 4:
-          message.revealFee = Coin.decode(reader, reader.uint32());
-          break;
-        case 5:
-          message.minimumBid = Coin.decode(reader, reader.uint32());
-          break;
         default:
           reader.skipType(tag & 7);
           break;
@@ -136,73 +104,17 @@ export const Params = {
     return message;
   },
 
-  fromJSON(object: any): Params {
+  fromJSON(_: any): Params {
-    return {
+    return {};
-      commitsDuration: isSet(object.commitsDuration)
-        ? Duration.fromJSON(object.commitsDuration)
-        : undefined,
-      revealsDuration: isSet(object.revealsDuration)
-        ? Duration.fromJSON(object.revealsDuration)
-        : undefined,
-      commitFee: isSet(object.commitFee)
-        ? Coin.fromJSON(object.commitFee)
-        : undefined,
-      revealFee: isSet(object.revealFee)
-        ? Coin.fromJSON(object.revealFee)
-        : undefined,
-      minimumBid: isSet(object.minimumBid)
-        ? Coin.fromJSON(object.minimumBid)
-        : undefined,
-    };
   },
 
-  toJSON(message: Params): unknown {
+  toJSON(_: Params): unknown {
     const obj: any = {};
-    message.commitsDuration !== undefined &&
-      (obj.commitsDuration = message.commitsDuration
-        ? Duration.toJSON(message.commitsDuration)
-        : undefined);
-    message.revealsDuration !== undefined &&
-      (obj.revealsDuration = message.revealsDuration
-        ? Duration.toJSON(message.revealsDuration)
-        : undefined);
-    message.commitFee !== undefined &&
-      (obj.commitFee = message.commitFee
-        ? Coin.toJSON(message.commitFee)
-        : undefined);
-    message.revealFee !== undefined &&
-      (obj.revealFee = message.revealFee
-        ? Coin.toJSON(message.revealFee)
-        : undefined);
-    message.minimumBid !== undefined &&
-      (obj.minimumBid = message.minimumBid
-        ? Coin.toJSON(message.minimumBid)
-        : undefined);
     return obj;
   },
 
-  fromPartial<I extends Exact<DeepPartial<Params>, I>>(object: I): Params {
+  fromPartial<I extends Exact<DeepPartial<Params>, I>>(_: I): Params {
     const message = createBaseParams();
-    message.commitsDuration =
-      object.commitsDuration !== undefined && object.commitsDuration !== null
-        ? Duration.fromPartial(object.commitsDuration)
-        : undefined;
-    message.revealsDuration =
-      object.revealsDuration !== undefined && object.revealsDuration !== null
-        ? Duration.fromPartial(object.revealsDuration)
-        : undefined;
-    message.commitFee =
-      object.commitFee !== undefined && object.commitFee !== null
-        ? Coin.fromPartial(object.commitFee)
-        : undefined;
-    message.revealFee =
-      object.revealFee !== undefined && object.revealFee !== null
-        ? Coin.fromPartial(object.revealFee)
-        : undefined;
-    message.minimumBid =
-      object.minimumBid !== undefined && object.minimumBid !== null
-        ? Coin.fromPartial(object.minimumBid)
-        : undefined;
     return message;
   },
 };
@@ -210,6 +122,7 @@ export const Params = {
 function createBaseAuction(): Auction {
   return {
     id: "",
+    kind: "",
     status: "",
     ownerAddress: "",
     createTime: undefined,
@@ -218,9 +131,12 @@ function createBaseAuction(): Auction {
     commitFee: undefined,
     revealFee: undefined,
     minimumBid: undefined,
-    winnerAddress: "",
+    winnerAddresses: [],
-    winningBid: undefined,
+    winningBids: [],
     winningPrice: undefined,
+    maxPrice: undefined,
+    numProviders: 0,
+    fundsReleased: false,
   };
 }
 
@@ -232,47 +148,59 @@ export const Auction = {
     if (message.id !== "") {
       writer.uint32(10).string(message.id);
     }
+    if (message.kind !== "") {
+      writer.uint32(18).string(message.kind);
+    }
     if (message.status !== "") {
-      writer.uint32(18).string(message.status);
+      writer.uint32(26).string(message.status);
     }
     if (message.ownerAddress !== "") {
-      writer.uint32(26).string(message.ownerAddress);
+      writer.uint32(34).string(message.ownerAddress);
     }
     if (message.createTime !== undefined) {
       Timestamp.encode(
         toTimestamp(message.createTime),
-        writer.uint32(34).fork()
+        writer.uint32(42).fork()
       ).ldelim();
     }
     if (message.commitsEndTime !== undefined) {
       Timestamp.encode(
         toTimestamp(message.commitsEndTime),
-        writer.uint32(42).fork()
+        writer.uint32(50).fork()
       ).ldelim();
     }
     if (message.revealsEndTime !== undefined) {
       Timestamp.encode(
         toTimestamp(message.revealsEndTime),
-        writer.uint32(50).fork()
+        writer.uint32(58).fork()
       ).ldelim();
     }
     if (message.commitFee !== undefined) {
-      Coin.encode(message.commitFee, writer.uint32(58).fork()).ldelim();
+      Coin.encode(message.commitFee, writer.uint32(66).fork()).ldelim();
     }
     if (message.revealFee !== undefined) {
-      Coin.encode(message.revealFee, writer.uint32(66).fork()).ldelim();
+      Coin.encode(message.revealFee, writer.uint32(74).fork()).ldelim();
     }
     if (message.minimumBid !== undefined) {
-      Coin.encode(message.minimumBid, writer.uint32(74).fork()).ldelim();
+      Coin.encode(message.minimumBid, writer.uint32(82).fork()).ldelim();
     }
-    if (message.winnerAddress !== "") {
+    for (const v of message.winnerAddresses) {
-      writer.uint32(82).string(message.winnerAddress);
+      writer.uint32(90).string(v!);
     }
-    if (message.winningBid !== undefined) {
+    for (const v of message.winningBids) {
-      Coin.encode(message.winningBid, writer.uint32(90).fork()).ldelim();
+      Coin.encode(v!, writer.uint32(98).fork()).ldelim();
     }
     if (message.winningPrice !== undefined) {
-      Coin.encode(message.winningPrice, writer.uint32(98).fork()).ldelim();
+      Coin.encode(message.winningPrice, writer.uint32(106).fork()).ldelim();
+    }
+    if (message.maxPrice !== undefined) {
+      Coin.encode(message.maxPrice, writer.uint32(114).fork()).ldelim();
+    }
+    if (message.numProviders !== 0) {
+      writer.uint32(120).int32(message.numProviders);
+    }
+    if (message.fundsReleased === true) {
+      writer.uint32(128).bool(message.fundsReleased);
     }
     return writer;
   },
@@ -288,44 +216,56 @@ export const Auction = {
           message.id = reader.string();
           break;
         case 2:
-          message.status = reader.string();
+          message.kind = reader.string();
           break;
         case 3:
-          message.ownerAddress = reader.string();
+          message.status = reader.string();
           break;
         case 4:
+          message.ownerAddress = reader.string();
+          break;
+        case 5:
           message.createTime = fromTimestamp(
             Timestamp.decode(reader, reader.uint32())
           );
           break;
-        case 5:
+        case 6:
           message.commitsEndTime = fromTimestamp(
             Timestamp.decode(reader, reader.uint32())
           );
           break;
-        case 6:
+        case 7:
           message.revealsEndTime = fromTimestamp(
             Timestamp.decode(reader, reader.uint32())
           );
           break;
-        case 7:
+        case 8:
           message.commitFee = Coin.decode(reader, reader.uint32());
           break;
-        case 8:
+        case 9:
           message.revealFee = Coin.decode(reader, reader.uint32());
           break;
-        case 9:
+        case 10:
           message.minimumBid = Coin.decode(reader, reader.uint32());
           break;
-        case 10:
-          message.winnerAddress = reader.string();
-          break;
         case 11:
-          message.winningBid = Coin.decode(reader, reader.uint32());
+          message.winnerAddresses.push(reader.string());
           break;
         case 12:
+          message.winningBids.push(Coin.decode(reader, reader.uint32()));
+          break;
+        case 13:
           message.winningPrice = Coin.decode(reader, reader.uint32());
           break;
+        case 14:
+          message.maxPrice = Coin.decode(reader, reader.uint32());
+          break;
+        case 15:
+          message.numProviders = reader.int32();
+          break;
+        case 16:
+          message.fundsReleased = reader.bool();
+          break;
         default:
           reader.skipType(tag & 7);
           break;
@@ -337,6 +277,7 @@ export const Auction = {
   fromJSON(object: any): Auction {
     return {
       id: isSet(object.id) ? String(object.id) : "",
+      kind: isSet(object.kind) ? String(object.kind) : "",
       status: isSet(object.status) ? String(object.status) : "",
       ownerAddress: isSet(object.ownerAddress)
         ? String(object.ownerAddress)
@@ -359,21 +300,31 @@ export const Auction = {
       minimumBid: isSet(object.minimumBid)
         ? Coin.fromJSON(object.minimumBid)
         : undefined,
-      winnerAddress: isSet(object.winnerAddress)
+      winnerAddresses: Array.isArray(object?.winnerAddresses)
-        ? String(object.winnerAddress)
+        ? object.winnerAddresses.map((e: any) => String(e))
-        : "",
+        : [],
-      winningBid: isSet(object.winningBid)
+      winningBids: Array.isArray(object?.winningBids)
-        ? Coin.fromJSON(object.winningBid)
+        ? object.winningBids.map((e: any) => Coin.fromJSON(e))
-        : undefined,
+        : [],
       winningPrice: isSet(object.winningPrice)
         ? Coin.fromJSON(object.winningPrice)
         : undefined,
+      maxPrice: isSet(object.maxPrice)
+        ? Coin.fromJSON(object.maxPrice)
+        : undefined,
+      numProviders: isSet(object.numProviders)
+        ? Number(object.numProviders)
+        : 0,
+      fundsReleased: isSet(object.fundsReleased)
+        ? Boolean(object.fundsReleased)
+        : false,
     };
   },
 
   toJSON(message: Auction): unknown {
     const obj: any = {};
     message.id !== undefined && (obj.id = message.id);
+    message.kind !== undefined && (obj.kind = message.kind);
     message.status !== undefined && (obj.status = message.status);
     message.ownerAddress !== undefined &&
       (obj.ownerAddress = message.ownerAddress);
@@ -395,22 +346,37 @@ export const Auction = {
       (obj.minimumBid = message.minimumBid
         ? Coin.toJSON(message.minimumBid)
         : undefined);
-    message.winnerAddress !== undefined &&
+    if (message.winnerAddresses) {
-      (obj.winnerAddress = message.winnerAddress);
+      obj.winnerAddresses = message.winnerAddresses.map((e) => e);
-    message.winningBid !== undefined &&
+    } else {
-      (obj.winningBid = message.winningBid
+      obj.winnerAddresses = [];
-        ? Coin.toJSON(message.winningBid)
+    }
-        : undefined);
+    if (message.winningBids) {
+      obj.winningBids = message.winningBids.map((e) =>
+        e ? Coin.toJSON(e) : undefined
+      );
+    } else {
+      obj.winningBids = [];
+    }
     message.winningPrice !== undefined &&
       (obj.winningPrice = message.winningPrice
         ? Coin.toJSON(message.winningPrice)
         : undefined);
+    message.maxPrice !== undefined &&
+      (obj.maxPrice = message.maxPrice
+        ? Coin.toJSON(message.maxPrice)
+        : undefined);
+    message.numProviders !== undefined &&
+      (obj.numProviders = Math.round(message.numProviders));
+    message.fundsReleased !== undefined &&
+      (obj.fundsReleased = message.fundsReleased);
     return obj;
   },
 
   fromPartial<I extends Exact<DeepPartial<Auction>, I>>(object: I): Auction {
     const message = createBaseAuction();
     message.id = object.id ?? "";
+    message.kind = object.kind ?? "";
     message.status = object.status ?? "";
     message.ownerAddress = object.ownerAddress ?? "";
     message.createTime = object.createTime ?? undefined;
@@ -428,15 +394,19 @@ export const Auction = {
       object.minimumBid !== undefined && object.minimumBid !== null
         ? Coin.fromPartial(object.minimumBid)
         : undefined;
-    message.winnerAddress = object.winnerAddress ?? "";
+    message.winnerAddresses = object.winnerAddresses?.map((e) => e) || [];
-    message.winningBid =
+    message.winningBids =
-      object.winningBid !== undefined && object.winningBid !== null
+      object.winningBids?.map((e) => Coin.fromPartial(e)) || [];
-        ? Coin.fromPartial(object.winningBid)
-        : undefined;
     message.winningPrice =
       object.winningPrice !== undefined && object.winningPrice !== null
         ? Coin.fromPartial(object.winningPrice)
         : undefined;
+    message.maxPrice =
+      object.maxPrice !== undefined && object.maxPrice !== null
+        ? Coin.fromPartial(object.maxPrice)
+        : undefined;
+    message.numProviders = object.numProviders ?? 0;
+    message.fundsReleased = object.fundsReleased ?? false;
     return message;
   },
 };

src/proto/cerc/auction/v1/tx.ts

@@ -1,7 +1,7 @@
 /* eslint-disable */
 import { Duration } from "../../../google/protobuf/duration";
 import { Coin } from "../../../cosmos/base/v1beta1/coin";
-import { Auction, Bid } from "./auction";
+import { Auction, Bid, Params } from "./auction";
 import Long from "long";
 import _m0 from "protobufjs/minimal";
 
@@ -9,6 +9,10 @@ export const protobufPackage = "cerc.auction.v1";
 
 /** MsgCreateAuction defines a create auction message */
 export interface MsgCreateAuction {
+  /** Address of the signer */
+  signer: string;
+  /** Auction kind (vickrey | provider) */
+  kind: string;
   /** Duration of the commits phase in seconds */
   commitsDuration?: Duration;
   /** Duration of the reveals phase in seconds */
@@ -17,10 +21,21 @@ export interface MsgCreateAuction {
   commitFee?: Coin;
   /** Reveal fees */
   revealFee?: Coin;
-  /** Minimum acceptable bid amount */
+  /**
+   * Minimum acceptable bid amount
+   * Only applicable in vickrey auctions
+   */
   minimumBid?: Coin;
-  /** Address of the signer */
+  /**
-  signer: string;
+   * Maximum acceptable bid amount
+   * Only applicable in provider auctions
+   */
+  maxPrice?: Coin;
+  /**
+   * Number of desired providers (num of auction winners)
+   * Only applicable in provider auctions
+   */
+  numProviders: number;
 }
 
 /** MsgCreateAuctionResponse returns the details of the created auction */
@@ -61,14 +76,52 @@ export interface MsgRevealBidResponse {
   auction?: Auction;
 }
 
+/** MsgUpdateParams is the Msg/UpdateParams request type. */
+export interface MsgUpdateParams {
+  /**
+   * authority is the address that controls the module (defaults to x/gov unless
+   * overwritten).
+   */
+  authority: string;
+  /**
+   * params defines the x/auction parameters to update.
+   *
+   * NOTE: All parameters must be supplied.
+   */
+  params?: Params;
+}
+
+/**
+ * MsgUpdateParamsResponse defines the response structure for executing a
+ * MsgUpdateParams message.
+ */
+export interface MsgUpdateParamsResponse {}
+
+/** ReleaseFunds defines the message to pay the winners of provider auctions */
+export interface MsgReleaseFunds {
+  /** Auction id */
+  auctionId: string;
+  /** Address of the signer */
+  signer: string;
+}
+
+/** MsgReleaseFundsResponse returns the state of the auction after releasing the funds */
+export interface MsgReleaseFundsResponse {
+  /** Auction details */
+  auction?: Auction;
+}
+
 function createBaseMsgCreateAuction(): MsgCreateAuction {
   return {
+    signer: "",
+    kind: "",
     commitsDuration: undefined,
     revealsDuration: undefined,
     commitFee: undefined,
     revealFee: undefined,
     minimumBid: undefined,
-    signer: "",
+    maxPrice: undefined,
+    numProviders: 0,
   };
 }
 
@@ -77,29 +130,38 @@ export const MsgCreateAuction = {
     message: MsgCreateAuction,
     writer: _m0.Writer = _m0.Writer.create()
   ): _m0.Writer {
+    if (message.signer !== "") {
+      writer.uint32(10).string(message.signer);
+    }
+    if (message.kind !== "") {
+      writer.uint32(18).string(message.kind);
+    }
     if (message.commitsDuration !== undefined) {
       Duration.encode(
         message.commitsDuration,
-        writer.uint32(10).fork()
+        writer.uint32(26).fork()
       ).ldelim();
     }
     if (message.revealsDuration !== undefined) {
       Duration.encode(
         message.revealsDuration,
-        writer.uint32(18).fork()
+        writer.uint32(34).fork()
       ).ldelim();
     }
     if (message.commitFee !== undefined) {
-      Coin.encode(message.commitFee, writer.uint32(26).fork()).ldelim();
+      Coin.encode(message.commitFee, writer.uint32(42).fork()).ldelim();
     }
     if (message.revealFee !== undefined) {
-      Coin.encode(message.revealFee, writer.uint32(34).fork()).ldelim();
+      Coin.encode(message.revealFee, writer.uint32(50).fork()).ldelim();
     }
     if (message.minimumBid !== undefined) {
-      Coin.encode(message.minimumBid, writer.uint32(42).fork()).ldelim();
+      Coin.encode(message.minimumBid, writer.uint32(58).fork()).ldelim();
     }
-    if (message.signer !== "") {
+    if (message.maxPrice !== undefined) {
-      writer.uint32(50).string(message.signer);
+      Coin.encode(message.maxPrice, writer.uint32(66).fork()).ldelim();
+    }
+    if (message.numProviders !== 0) {
+      writer.uint32(72).int32(message.numProviders);
     }
     return writer;
   },
@@ -112,22 +174,31 @@ export const MsgCreateAuction = {
       const tag = reader.uint32();
       switch (tag >>> 3) {
         case 1:
-          message.commitsDuration = Duration.decode(reader, reader.uint32());
+          message.signer = reader.string();
           break;
         case 2:
-          message.revealsDuration = Duration.decode(reader, reader.uint32());
+          message.kind = reader.string();
           break;
         case 3:
-          message.commitFee = Coin.decode(reader, reader.uint32());
+          message.commitsDuration = Duration.decode(reader, reader.uint32());
           break;
         case 4:
-          message.revealFee = Coin.decode(reader, reader.uint32());
+          message.revealsDuration = Duration.decode(reader, reader.uint32());
           break;
         case 5:
-          message.minimumBid = Coin.decode(reader, reader.uint32());
+          message.commitFee = Coin.decode(reader, reader.uint32());
           break;
         case 6:
-          message.signer = reader.string();
+          message.revealFee = Coin.decode(reader, reader.uint32());
+          break;
+        case 7:
+          message.minimumBid = Coin.decode(reader, reader.uint32());
+          break;
+        case 8:
+          message.maxPrice = Coin.decode(reader, reader.uint32());
+          break;
+        case 9:
+          message.numProviders = reader.int32();
           break;
         default:
           reader.skipType(tag & 7);
@@ -139,6 +210,8 @@ export const MsgCreateAuction = {
 
   fromJSON(object: any): MsgCreateAuction {
     return {
+      signer: isSet(object.signer) ? String(object.signer) : "",
+      kind: isSet(object.kind) ? String(object.kind) : "",
       commitsDuration: isSet(object.commitsDuration)
         ? Duration.fromJSON(object.commitsDuration)
         : undefined,
@@ -154,12 +227,19 @@ export const MsgCreateAuction = {
       minimumBid: isSet(object.minimumBid)
         ? Coin.fromJSON(object.minimumBid)
         : undefined,
-      signer: isSet(object.signer) ? String(object.signer) : "",
+      maxPrice: isSet(object.maxPrice)
+        ? Coin.fromJSON(object.maxPrice)
+        : undefined,
+      numProviders: isSet(object.numProviders)
+        ? Number(object.numProviders)
+        : 0,
     };
   },
 
   toJSON(message: MsgCreateAuction): unknown {
     const obj: any = {};
+    message.signer !== undefined && (obj.signer = message.signer);
+    message.kind !== undefined && (obj.kind = message.kind);
     message.commitsDuration !== undefined &&
       (obj.commitsDuration = message.commitsDuration
         ? Duration.toJSON(message.commitsDuration)
@@ -180,7 +260,12 @@ export const MsgCreateAuction = {
       (obj.minimumBid = message.minimumBid
         ? Coin.toJSON(message.minimumBid)
         : undefined);
-    message.signer !== undefined && (obj.signer = message.signer);
+    message.maxPrice !== undefined &&
+      (obj.maxPrice = message.maxPrice
+        ? Coin.toJSON(message.maxPrice)
+        : undefined);
+    message.numProviders !== undefined &&
+      (obj.numProviders = Math.round(message.numProviders));
     return obj;
   },
 
@@ -188,6 +273,8 @@ export const MsgCreateAuction = {
     object: I
   ): MsgCreateAuction {
     const message = createBaseMsgCreateAuction();
+    message.signer = object.signer ?? "";
+    message.kind = object.kind ?? "";
     message.commitsDuration =
       object.commitsDuration !== undefined && object.commitsDuration !== null
         ? Duration.fromPartial(object.commitsDuration)
@@ -208,7 +295,11 @@ export const MsgCreateAuction = {
       object.minimumBid !== undefined && object.minimumBid !== null
         ? Coin.fromPartial(object.minimumBid)
         : undefined;
-    message.signer = object.signer ?? "";
+    message.maxPrice =
+      object.maxPrice !== undefined && object.maxPrice !== null
+        ? Coin.fromPartial(object.maxPrice)
+        : undefined;
+    message.numProviders = object.numProviders ?? 0;
     return message;
   },
 };
@@ -548,6 +639,248 @@ export const MsgRevealBidResponse = {
   },
 };
 
+function createBaseMsgUpdateParams(): MsgUpdateParams {
+  return { authority: "", params: undefined };
+}
+
+export const MsgUpdateParams = {
+  encode(
+    message: MsgUpdateParams,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    if (message.authority !== "") {
+      writer.uint32(10).string(message.authority);
+    }
+    if (message.params !== undefined) {
+      Params.encode(message.params, writer.uint32(18).fork()).ldelim();
+    }
+    return writer;
+  },
+
+  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 = createBaseMsgUpdateParams();
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+      switch (tag >>> 3) {
+        case 1:
+          message.authority = reader.string();
+          break;
+        case 2:
+          message.params = Params.decode(reader, reader.uint32());
+          break;
+        default:
+          reader.skipType(tag & 7);
+          break;
+      }
+    }
+    return message;
+  },
+
+  fromJSON(object: any): MsgUpdateParams {
+    return {
+      authority: isSet(object.authority) ? String(object.authority) : "",
+      params: isSet(object.params) ? Params.fromJSON(object.params) : undefined,
+    };
+  },
+
+  toJSON(message: MsgUpdateParams): unknown {
+    const obj: any = {};
+    message.authority !== undefined && (obj.authority = message.authority);
+    message.params !== undefined &&
+      (obj.params = message.params ? Params.toJSON(message.params) : undefined);
+    return obj;
+  },
+
+  fromPartial<I extends Exact<DeepPartial<MsgUpdateParams>, I>>(
+    object: I
+  ): MsgUpdateParams {
+    const message = createBaseMsgUpdateParams();
+    message.authority = object.authority ?? "";
+    message.params =
+      object.params !== undefined && object.params !== null
+        ? Params.fromPartial(object.params)
+        : undefined;
+    return message;
+  },
+};
+
+function createBaseMsgUpdateParamsResponse(): MsgUpdateParamsResponse {
+  return {};
+}
+
+export const MsgUpdateParamsResponse = {
+  encode(
+    _: MsgUpdateParamsResponse,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    return writer;
+  },
+
+  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 = createBaseMsgUpdateParamsResponse();
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+      switch (tag >>> 3) {
+        default:
+          reader.skipType(tag & 7);
+          break;
+      }
+    }
+    return message;
+  },
+
+  fromJSON(_: any): MsgUpdateParamsResponse {
+    return {};
+  },
+
+  toJSON(_: MsgUpdateParamsResponse): unknown {
+    const obj: any = {};
+    return obj;
+  },
+
+  fromPartial<I extends Exact<DeepPartial<MsgUpdateParamsResponse>, I>>(
+    _: I
+  ): MsgUpdateParamsResponse {
+    const message = createBaseMsgUpdateParamsResponse();
+    return message;
+  },
+};
+
+function createBaseMsgReleaseFunds(): MsgReleaseFunds {
+  return { auctionId: "", signer: "" };
+}
+
+export const MsgReleaseFunds = {
+  encode(
+    message: MsgReleaseFunds,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    if (message.auctionId !== "") {
+      writer.uint32(10).string(message.auctionId);
+    }
+    if (message.signer !== "") {
+      writer.uint32(18).string(message.signer);
+    }
+    return writer;
+  },
+
+  decode(input: _m0.Reader | Uint8Array, length?: number): MsgReleaseFunds {
+    const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
+    let end = length === undefined ? reader.len : reader.pos + length;
+    const message = createBaseMsgReleaseFunds();
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+      switch (tag >>> 3) {
+        case 1:
+          message.auctionId = reader.string();
+          break;
+        case 2:
+          message.signer = reader.string();
+          break;
+        default:
+          reader.skipType(tag & 7);
+          break;
+      }
+    }
+    return message;
+  },
+
+  fromJSON(object: any): MsgReleaseFunds {
+    return {
+      auctionId: isSet(object.auctionId) ? String(object.auctionId) : "",
+      signer: isSet(object.signer) ? String(object.signer) : "",
+    };
+  },
+
+  toJSON(message: MsgReleaseFunds): unknown {
+    const obj: any = {};
+    message.auctionId !== undefined && (obj.auctionId = message.auctionId);
+    message.signer !== undefined && (obj.signer = message.signer);
+    return obj;
+  },
+
+  fromPartial<I extends Exact<DeepPartial<MsgReleaseFunds>, I>>(
+    object: I
+  ): MsgReleaseFunds {
+    const message = createBaseMsgReleaseFunds();
+    message.auctionId = object.auctionId ?? "";
+    message.signer = object.signer ?? "";
+    return message;
+  },
+};
+
+function createBaseMsgReleaseFundsResponse(): MsgReleaseFundsResponse {
+  return { auction: undefined };
+}
+
+export const MsgReleaseFundsResponse = {
+  encode(
+    message: MsgReleaseFundsResponse,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    if (message.auction !== undefined) {
+      Auction.encode(message.auction, writer.uint32(10).fork()).ldelim();
+    }
+    return writer;
+  },
+
+  decode(
+    input: _m0.Reader | Uint8Array,
+    length?: number
+  ): MsgReleaseFundsResponse {
+    const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
+    let end = length === undefined ? reader.len : reader.pos + length;
+    const message = createBaseMsgReleaseFundsResponse();
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+      switch (tag >>> 3) {
+        case 1:
+          message.auction = Auction.decode(reader, reader.uint32());
+          break;
+        default:
+          reader.skipType(tag & 7);
+          break;
+      }
+    }
+    return message;
+  },
+
+  fromJSON(object: any): MsgReleaseFundsResponse {
+    return {
+      auction: isSet(object.auction)
+        ? Auction.fromJSON(object.auction)
+        : undefined,
+    };
+  },
+
+  toJSON(message: MsgReleaseFundsResponse): unknown {
+    const obj: any = {};
+    message.auction !== undefined &&
+      (obj.auction = message.auction
+        ? Auction.toJSON(message.auction)
+        : undefined);
+    return obj;
+  },
+
+  fromPartial<I extends Exact<DeepPartial<MsgReleaseFundsResponse>, I>>(
+    object: I
+  ): MsgReleaseFundsResponse {
+    const message = createBaseMsgReleaseFundsResponse();
+    message.auction =
+      object.auction !== undefined && object.auction !== null
+        ? Auction.fromPartial(object.auction)
+        : undefined;
+    return message;
+  },
+};
+
 /** Tx defines the gRPC tx interface */
 export interface Msg {
   /** CreateAuction is the command for creating an auction */
@@ -556,6 +889,13 @@ export interface Msg {
   CommitBid(request: MsgCommitBid): Promise<MsgCommitBidResponse>;
   /** RevealBid is the command for revealing a bid */
   RevealBid(request: MsgRevealBid): Promise<MsgRevealBidResponse>;
+  /**
+   * UpdateParams defines an operation for updating the x/staking module
+   * parameters.
+   */
+  UpdateParams(request: MsgUpdateParams): Promise<MsgUpdateParamsResponse>;
+  /** ReleaseFunds is the command for paying the winners of provider auctions */
+  ReleaseFunds(request: MsgReleaseFunds): Promise<MsgReleaseFundsResponse>;
 }
 
 export class MsgClientImpl implements Msg {
@@ -565,6 +905,8 @@ export class MsgClientImpl implements Msg {
     this.CreateAuction = this.CreateAuction.bind(this);
     this.CommitBid = this.CommitBid.bind(this);
     this.RevealBid = this.RevealBid.bind(this);
+    this.UpdateParams = this.UpdateParams.bind(this);
+    this.ReleaseFunds = this.ReleaseFunds.bind(this);
   }
   CreateAuction(request: MsgCreateAuction): Promise<MsgCreateAuctionResponse> {
     const data = MsgCreateAuction.encode(request).finish();
@@ -593,6 +935,30 @@ export class MsgClientImpl implements Msg {
       MsgRevealBidResponse.decode(new _m0.Reader(data))
     );
   }
+
+  UpdateParams(request: MsgUpdateParams): Promise<MsgUpdateParamsResponse> {
+    const data = MsgUpdateParams.encode(request).finish();
+    const promise = this.rpc.request(
+      "cerc.auction.v1.Msg",
+      "UpdateParams",
+      data
+    );
+    return promise.then((data) =>
+      MsgUpdateParamsResponse.decode(new _m0.Reader(data))
+    );
+  }
+
+  ReleaseFunds(request: MsgReleaseFunds): Promise<MsgReleaseFundsResponse> {
+    const data = MsgReleaseFunds.encode(request).finish();
+    const promise = this.rpc.request(
+      "cerc.auction.v1.Msg",
+      "ReleaseFunds",
+      data
+    );
+    return promise.then((data) =>
+      MsgReleaseFundsResponse.decode(new _m0.Reader(data))
+    );
+  }
 }
 
 interface Rpc {

src/proto/cerc/bond/module/v1/module.ts

@@ -8,14 +8,26 @@ export const protobufPackage = "cerc.bond.module.v1";
  * Module is the app config object of the module.
  * Learn more: https://docs.cosmos.network/main/building-modules/depinject
  */
-export interface Module {}
+export interface Module {
+  /**
+   * authority defines the custom module authority. If not set, defaults to the
+   * governance module.
+   */
+  authority: string;
+}
 
 function createBaseModule(): Module {
-  return {};
+  return { authority: "" };
 }
 
 export const Module = {
-  encode(_: Module, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
+  encode(
+    message: Module,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    if (message.authority !== "") {
+      writer.uint32(18).string(message.authority);
+    }
     return writer;
   },
 
@@ -26,6 +38,9 @@ export const Module = {
     while (reader.pos < end) {
       const tag = reader.uint32();
       switch (tag >>> 3) {
+        case 2:
+          message.authority = reader.string();
+          break;
         default:
           reader.skipType(tag & 7);
           break;
@@ -34,17 +49,21 @@ export const Module = {
     return message;
   },
 
-  fromJSON(_: any): Module {
+  fromJSON(object: any): Module {
-    return {};
+    return {
+      authority: isSet(object.authority) ? String(object.authority) : "",
+    };
   },
 
-  toJSON(_: Module): unknown {
+  toJSON(message: Module): unknown {
     const obj: any = {};
+    message.authority !== undefined && (obj.authority = message.authority);
     return obj;
   },
 
-  fromPartial<I extends Exact<DeepPartial<Module>, I>>(_: I): Module {
+  fromPartial<I extends Exact<DeepPartial<Module>, I>>(object: I): Module {
     const message = createBaseModule();
+    message.authority = object.authority ?? "";
     return message;
   },
 };
@@ -81,3 +100,7 @@ if (_m0.util.Long !== Long) {
   _m0.util.Long = Long as any;
   _m0.configure();
 }
+
+function isSet(value: any): boolean {
+  return value !== null && value !== undefined;
+}

src/proto/cerc/bond/v1/tx.ts

@@ -1,4 +1,5 @@
 /* eslint-disable */
+import { Params } from "./bond";
 import Long from "long";
 import { Coin } from "../../../cosmos/base/v1beta1/coin";
 import _m0 from "protobufjs/minimal";
@@ -45,6 +46,27 @@ export interface MsgCancelBond {
 /** MsgCancelBondResponse defines the Msg/CancelBond response type. */
 export interface MsgCancelBondResponse {}
 
+/** MsgUpdateParams is the Msg/UpdateParams request type. */
+export interface MsgUpdateParams {
+  /**
+   * authority is the address that controls the module (defaults to x/gov unless
+   * overwritten).
+   */
+  authority: string;
+  /**
+   * params defines the x/bond parameters to update.
+   *
+   * NOTE: All parameters must be supplied.
+   */
+  params?: Params;
+}
+
+/**
+ * MsgUpdateParamsResponse defines the response structure for executing a
+ * MsgUpdateParams message.
+ */
+export interface MsgUpdateParamsResponse {}
+
 function createBaseMsgCreateBond(): MsgCreateBond {
   return { signer: "", coins: [] };
 }
@@ -531,6 +553,120 @@ export const MsgCancelBondResponse = {
   },
 };
 
+function createBaseMsgUpdateParams(): MsgUpdateParams {
+  return { authority: "", params: undefined };
+}
+
+export const MsgUpdateParams = {
+  encode(
+    message: MsgUpdateParams,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    if (message.authority !== "") {
+      writer.uint32(10).string(message.authority);
+    }
+    if (message.params !== undefined) {
+      Params.encode(message.params, writer.uint32(18).fork()).ldelim();
+    }
+    return writer;
+  },
+
+  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 = createBaseMsgUpdateParams();
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+      switch (tag >>> 3) {
+        case 1:
+          message.authority = reader.string();
+          break;
+        case 2:
+          message.params = Params.decode(reader, reader.uint32());
+          break;
+        default:
+          reader.skipType(tag & 7);
+          break;
+      }
+    }
+    return message;
+  },
+
+  fromJSON(object: any): MsgUpdateParams {
+    return {
+      authority: isSet(object.authority) ? String(object.authority) : "",
+      params: isSet(object.params) ? Params.fromJSON(object.params) : undefined,
+    };
+  },
+
+  toJSON(message: MsgUpdateParams): unknown {
+    const obj: any = {};
+    message.authority !== undefined && (obj.authority = message.authority);
+    message.params !== undefined &&
+      (obj.params = message.params ? Params.toJSON(message.params) : undefined);
+    return obj;
+  },
+
+  fromPartial<I extends Exact<DeepPartial<MsgUpdateParams>, I>>(
+    object: I
+  ): MsgUpdateParams {
+    const message = createBaseMsgUpdateParams();
+    message.authority = object.authority ?? "";
+    message.params =
+      object.params !== undefined && object.params !== null
+        ? Params.fromPartial(object.params)
+        : undefined;
+    return message;
+  },
+};
+
+function createBaseMsgUpdateParamsResponse(): MsgUpdateParamsResponse {
+  return {};
+}
+
+export const MsgUpdateParamsResponse = {
+  encode(
+    _: MsgUpdateParamsResponse,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    return writer;
+  },
+
+  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 = createBaseMsgUpdateParamsResponse();
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+      switch (tag >>> 3) {
+        default:
+          reader.skipType(tag & 7);
+          break;
+      }
+    }
+    return message;
+  },
+
+  fromJSON(_: any): MsgUpdateParamsResponse {
+    return {};
+  },
+
+  toJSON(_: MsgUpdateParamsResponse): unknown {
+    const obj: any = {};
+    return obj;
+  },
+
+  fromPartial<I extends Exact<DeepPartial<MsgUpdateParamsResponse>, I>>(
+    _: I
+  ): MsgUpdateParamsResponse {
+    const message = createBaseMsgUpdateParamsResponse();
+    return message;
+  },
+};
+
 /** Msg defines the bond Msg service. */
 export interface Msg {
   /** CreateBond defines a method for creating a new bond. */
@@ -541,6 +677,11 @@ export interface Msg {
   WithdrawBond(request: MsgWithdrawBond): Promise<MsgWithdrawBondResponse>;
   /** CancelBond defines a method for cancelling a bond. */
   CancelBond(request: MsgCancelBond): Promise<MsgCancelBondResponse>;
+  /**
+   * UpdateParams defines an operation for updating the x/staking module
+   * parameters.
+   */
+  UpdateParams(request: MsgUpdateParams): Promise<MsgUpdateParamsResponse>;
 }
 
 export class MsgClientImpl implements Msg {
@@ -551,6 +692,7 @@ export class MsgClientImpl implements Msg {
     this.RefillBond = this.RefillBond.bind(this);
     this.WithdrawBond = this.WithdrawBond.bind(this);
     this.CancelBond = this.CancelBond.bind(this);
+    this.UpdateParams = this.UpdateParams.bind(this);
   }
   CreateBond(request: MsgCreateBond): Promise<MsgCreateBondResponse> {
     const data = MsgCreateBond.encode(request).finish();
@@ -583,6 +725,14 @@ export class MsgClientImpl implements Msg {
       MsgCancelBondResponse.decode(new _m0.Reader(data))
     );
   }
+
+  UpdateParams(request: MsgUpdateParams): Promise<MsgUpdateParamsResponse> {
+    const data = MsgUpdateParams.encode(request).finish();
+    const promise = this.rpc.request("cerc.bond.v1.Msg", "UpdateParams", data);
+    return promise.then((data) =>
+      MsgUpdateParamsResponse.decode(new _m0.Reader(data))
+    );
+  }
 }
 
 interface Rpc {

src/proto/cerc/registry/module/v1/module.ts

@@ -8,14 +8,26 @@ export const protobufPackage = "cerc.registry.module.v1";
  * Module is the app config object of the module.
  * Learn more: https://docs.cosmos.network/main/building-modules/depinject
  */
-export interface Module {}
+export interface Module {
+  /**
+   * authority defines the custom module authority. If not set, defaults to the
+   * governance module.
+   */
+  authority: string;
+}
 
 function createBaseModule(): Module {
-  return {};
+  return { authority: "" };
 }
 
 export const Module = {
-  encode(_: Module, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
+  encode(
+    message: Module,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    if (message.authority !== "") {
+      writer.uint32(18).string(message.authority);
+    }
     return writer;
   },
 
@@ -26,6 +38,9 @@ export const Module = {
     while (reader.pos < end) {
       const tag = reader.uint32();
       switch (tag >>> 3) {
+        case 2:
+          message.authority = reader.string();
+          break;
         default:
           reader.skipType(tag & 7);
           break;
@@ -34,17 +49,21 @@ export const Module = {
     return message;
   },
 
-  fromJSON(_: any): Module {
+  fromJSON(object: any): Module {
-    return {};
+    return {
+      authority: isSet(object.authority) ? String(object.authority) : "",
+    };
   },
 
-  toJSON(_: Module): unknown {
+  toJSON(message: Module): unknown {
     const obj: any = {};
+    message.authority !== undefined && (obj.authority = message.authority);
     return obj;
   },
 
-  fromPartial<I extends Exact<DeepPartial<Module>, I>>(_: I): Module {
+  fromPartial<I extends Exact<DeepPartial<Module>, I>>(object: I): Module {
     const message = createBaseModule();
+    message.authority = object.authority ?? "";
     return message;
   },
 };
@@ -81,3 +100,7 @@ if (_m0.util.Long !== Long) {
   _m0.util.Long = Long as any;
   _m0.configure();
 }
+
+function isSet(value: any): boolean {
+  return value !== null && value !== undefined;
+}

src/proto/cerc/registry/v1/registry.ts

@@ -1162,7 +1162,7 @@ export const RecordsList = {
 declare var self: any | undefined;
 declare var window: any | undefined;
 declare var global: any | undefined;
-var _globalThis: any = (() => {
+var globalThis: any = (() => {
   if (typeof globalThis !== "undefined") return globalThis;
   if (typeof self !== "undefined") return self;
   if (typeof window !== "undefined") return window;
@@ -1171,10 +1171,10 @@ var _globalThis: any = (() => {
 })();
 
 function bytesFromBase64(b64: string): Uint8Array {
-  if (_globalThis.Buffer) {
+  if (globalThis.Buffer) {
-    return Uint8Array.from(_globalThis.Buffer.from(b64, "base64"));
+    return Uint8Array.from(globalThis.Buffer.from(b64, "base64"));
   } else {
-    const bin = _globalThis.atob(b64);
+    const bin = globalThis.atob(b64);
     const arr = new Uint8Array(bin.length);
     for (let i = 0; i < bin.length; ++i) {
       arr[i] = bin.charCodeAt(i);
@@ -1184,14 +1184,14 @@ function bytesFromBase64(b64: string): Uint8Array {
 }
 
 function base64FromBytes(arr: Uint8Array): string {
-  if (_globalThis.Buffer) {
+  if (globalThis.Buffer) {
-    return _globalThis.Buffer.from(arr).toString("base64");
+    return globalThis.Buffer.from(arr).toString("base64");
   } else {
     const bin: string[] = [];
     arr.forEach((byte) => {
       bin.push(String.fromCharCode(byte));
     });
-    return _globalThis.btoa(bin.join(""));
+    return globalThis.btoa(bin.join(""));
   }
 }
 

src/proto/cerc/registry/v1/tx.ts

@@ -1,5 +1,5 @@
 /* eslint-disable */
-import { Record, Signature } from "./registry";
+import { Record, Params, Signature } from "./registry";
 import Long from "long";
 import _m0 from "protobufjs/minimal";
 
@@ -110,6 +110,27 @@ export interface MsgReassociateRecords {
 /** MsgReassociateRecordsResponse */
 export interface MsgReassociateRecordsResponse {}
 
+/** MsgUpdateParams is the Msg/UpdateParams request type. */
+export interface MsgUpdateParams {
+  /**
+   * authority is the address that controls the module (defaults to x/gov unless
+   * overwritten).
+   */
+  authority: string;
+  /**
+   * params defines the x/registry parameters to update.
+   *
+   * NOTE: All parameters must be supplied.
+   */
+  params?: Params;
+}
+
+/**
+ * MsgUpdateParamsResponse defines the response structure for executing a
+ * MsgUpdateParams message.
+ */
+export interface MsgUpdateParamsResponse {}
+
 function createBaseMsgSetRecord(): MsgSetRecord {
   return { bondId: "", signer: "", payload: undefined };
 }
@@ -1359,6 +1380,120 @@ export const MsgReassociateRecordsResponse = {
   },
 };
 
+function createBaseMsgUpdateParams(): MsgUpdateParams {
+  return { authority: "", params: undefined };
+}
+
+export const MsgUpdateParams = {
+  encode(
+    message: MsgUpdateParams,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    if (message.authority !== "") {
+      writer.uint32(10).string(message.authority);
+    }
+    if (message.params !== undefined) {
+      Params.encode(message.params, writer.uint32(18).fork()).ldelim();
+    }
+    return writer;
+  },
+
+  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 = createBaseMsgUpdateParams();
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+      switch (tag >>> 3) {
+        case 1:
+          message.authority = reader.string();
+          break;
+        case 2:
+          message.params = Params.decode(reader, reader.uint32());
+          break;
+        default:
+          reader.skipType(tag & 7);
+          break;
+      }
+    }
+    return message;
+  },
+
+  fromJSON(object: any): MsgUpdateParams {
+    return {
+      authority: isSet(object.authority) ? String(object.authority) : "",
+      params: isSet(object.params) ? Params.fromJSON(object.params) : undefined,
+    };
+  },
+
+  toJSON(message: MsgUpdateParams): unknown {
+    const obj: any = {};
+    message.authority !== undefined && (obj.authority = message.authority);
+    message.params !== undefined &&
+      (obj.params = message.params ? Params.toJSON(message.params) : undefined);
+    return obj;
+  },
+
+  fromPartial<I extends Exact<DeepPartial<MsgUpdateParams>, I>>(
+    object: I
+  ): MsgUpdateParams {
+    const message = createBaseMsgUpdateParams();
+    message.authority = object.authority ?? "";
+    message.params =
+      object.params !== undefined && object.params !== null
+        ? Params.fromPartial(object.params)
+        : undefined;
+    return message;
+  },
+};
+
+function createBaseMsgUpdateParamsResponse(): MsgUpdateParamsResponse {
+  return {};
+}
+
+export const MsgUpdateParamsResponse = {
+  encode(
+    _: MsgUpdateParamsResponse,
+    writer: _m0.Writer = _m0.Writer.create()
+  ): _m0.Writer {
+    return writer;
+  },
+
+  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 = createBaseMsgUpdateParamsResponse();
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+      switch (tag >>> 3) {
+        default:
+          reader.skipType(tag & 7);
+          break;
+      }
+    }
+    return message;
+  },
+
+  fromJSON(_: any): MsgUpdateParamsResponse {
+    return {};
+  },
+
+  toJSON(_: MsgUpdateParamsResponse): unknown {
+    const obj: any = {};
+    return obj;
+  },
+
+  fromPartial<I extends Exact<DeepPartial<MsgUpdateParamsResponse>, I>>(
+    _: I
+  ): MsgUpdateParamsResponse {
+    const message = createBaseMsgUpdateParamsResponse();
+    return message;
+  },
+};
+
 /** Msg is a service which exposes the registry functionality */
 export interface Msg {
   /** SetRecord records a new record with given payload and bond id */
@@ -1391,6 +1526,11 @@ export interface Msg {
   SetAuthorityBond(
     request: MsgSetAuthorityBond
   ): Promise<MsgSetAuthorityBondResponse>;
+  /**
+   * UpdateParams defines an operation for updating the x/staking module
+   * parameters.
+   */
+  UpdateParams(request: MsgUpdateParams): Promise<MsgUpdateParamsResponse>;
 }
 
 export class MsgClientImpl implements Msg {
@@ -1407,6 +1547,7 @@ export class MsgClientImpl implements Msg {
     this.DeleteName = this.DeleteName.bind(this);
     this.ReserveAuthority = this.ReserveAuthority.bind(this);
     this.SetAuthorityBond = this.SetAuthorityBond.bind(this);
+    this.UpdateParams = this.UpdateParams.bind(this);
   }
   SetRecord(request: MsgSetRecord): Promise<MsgSetRecordResponse> {
     const data = MsgSetRecord.encode(request).finish();
@@ -1529,6 +1670,18 @@ export class MsgClientImpl implements Msg {
       MsgSetAuthorityBondResponse.decode(new _m0.Reader(data))
     );
   }
+
+  UpdateParams(request: MsgUpdateParams): Promise<MsgUpdateParamsResponse> {
+    const data = MsgUpdateParams.encode(request).finish();
+    const promise = this.rpc.request(
+      "cerc.registry.v1.Msg",
+      "UpdateParams",
+      data
+    );
+    return promise.then((data) =>
+      MsgUpdateParamsResponse.decode(new _m0.Reader(data))
+    );
+  }
 }
 
 interface Rpc {

src/proto/cosmos/base/query/v1beta1/pagination.ts

@@ -251,7 +251,7 @@ export const PageResponse = {
 declare var self: any | undefined;
 declare var window: any | undefined;
 declare var global: any | undefined;
-var _globalThis: any = (() => {
+var globalThis: any = (() => {
   if (typeof globalThis !== "undefined") return globalThis;
   if (typeof self !== "undefined") return self;
   if (typeof window !== "undefined") return window;
@@ -260,10 +260,10 @@ var _globalThis: any = (() => {
 })();
 
 function bytesFromBase64(b64: string): Uint8Array {
-  if (_globalThis.Buffer) {
+  if (globalThis.Buffer) {
-    return Uint8Array.from(_globalThis.Buffer.from(b64, "base64"));
+    return Uint8Array.from(globalThis.Buffer.from(b64, "base64"));
   } else {
-    const bin = _globalThis.atob(b64);
+    const bin = globalThis.atob(b64);
     const arr = new Uint8Array(bin.length);
     for (let i = 0; i < bin.length; ++i) {
       arr[i] = bin.charCodeAt(i);
@@ -273,14 +273,14 @@ function bytesFromBase64(b64: string): Uint8Array {
 }
 
 function base64FromBytes(arr: Uint8Array): string {
-  if (_globalThis.Buffer) {
+  if (globalThis.Buffer) {
-    return _globalThis.Buffer.from(arr).toString("base64");
+    return globalThis.Buffer.from(arr).toString("base64");
   } else {
     const bin: string[] = [];
     arr.forEach((byte) => {
       bin.push(String.fromCharCode(byte));
     });
-    return _globalThis.btoa(bin.join(""));
+    return globalThis.btoa(bin.join(""));
   }
 }
 

src/proto/google/protobuf/descriptor.ts

@@ -4324,7 +4324,7 @@ export const GeneratedCodeInfo_Annotation = {
 declare var self: any | undefined;
 declare var window: any | undefined;
 declare var global: any | undefined;
-var _globalThis: any = (() => {
+var globalThis: any = (() => {
   if (typeof globalThis !== "undefined") return globalThis;
   if (typeof self !== "undefined") return self;
   if (typeof window !== "undefined") return window;
@@ -4333,10 +4333,10 @@ var _globalThis: any = (() => {
 })();
 
 function bytesFromBase64(b64: string): Uint8Array {
-  if (_globalThis.Buffer) {
+  if (globalThis.Buffer) {
-    return Uint8Array.from(_globalThis.Buffer.from(b64, "base64"));
+    return Uint8Array.from(globalThis.Buffer.from(b64, "base64"));
   } else {
-    const bin = _globalThis.atob(b64);
+    const bin = globalThis.atob(b64);
     const arr = new Uint8Array(bin.length);
     for (let i = 0; i < bin.length; ++i) {
       arr[i] = bin.charCodeAt(i);
@@ -4346,14 +4346,14 @@ function bytesFromBase64(b64: string): Uint8Array {
 }
 
 function base64FromBytes(arr: Uint8Array): string {
-  if (_globalThis.Buffer) {
+  if (globalThis.Buffer) {
-    return _globalThis.Buffer.from(arr).toString("base64");
+    return globalThis.Buffer.from(arr).toString("base64");
   } else {
     const bin: string[] = [];
     arr.forEach((byte) => {
       bin.push(String.fromCharCode(byte));
     });
-    return _globalThis.btoa(bin.join(""));
+    return globalThis.btoa(bin.join(""));
   }
 }
 

src/registry-client.ts

@@ -44,6 +44,7 @@ const historyFields = `
 
 const auctionFields = `
   id
+  kind
   status
   ownerAddress
   createTime
@@ -61,8 +62,8 @@ const auctionFields = `
     type
     quantity
   }
-  winnerAddress
+  winnerAddresses
-  winnerBid {
+  winnerBids {
     type
     quantity
   }
@@ -70,6 +71,12 @@ const auctionFields = `
     type
     quantity
   }
+  maxPrice {
+    type
+    quantity
+  }
+  numProviders
+  fundsReleased
   bids {
     bidderAddress
     status
@@ -241,13 +248,13 @@ export class RegistryClient {
   /**
    * Get records by attributes.
    */
-  async queryRecords (attributes: { [key: string]: any }, all = false, refs = false) {
+  async queryRecords (attributes: { [key: string]: any }, all = false, refs = false, limit?: number, offset?: number) {
     if (!attributes) {
       attributes = {};
     }
 
-    const query = `query ($attributes: [KeyValueInput!], $all: Boolean) {
+    const query = `query ($attributes: [KeyValueInput!], $all: Boolean, $limit: Int, $offset: Int) {
-      queryRecords(attributes: $attributes, all: $all) {
+      queryRecords(attributes: $attributes, all: $all, limit: $limit, offset: $offset) {
         id
         names
         owners
@@ -261,7 +268,9 @@ export class RegistryClient {
 
     const variables = {
       attributes: Util.toGQLAttributes(attributes),
-      all
+      all,
+      limit,
+      offset
     };
 
     let result = (await this._graph(query)(variables)).queryRecords;
@@ -425,11 +434,11 @@ export class RegistryClient {
   }
 
   /**
-   * Get bonds by attributes.
+   * Get bonds.
    */
-  async queryBonds (attributes = {}) {
+  async queryBonds () {
-    const query = `query ($attributes: [KeyValueInput!]) {
+    const query = `query {
-      queryBonds(attributes: $attributes) {
+      queryBonds {
         id
         owner
         balance {
@@ -439,11 +448,32 @@ export class RegistryClient {
       }
     }`;
 
+    return RegistryClient.getResult(this._graph(query)({}), 'queryBonds');
+  }
+
+  /**
+   * Get bonds by owner(s).
+   */
+  async queryBondsByOwners (ownerAddresses: string[]) {
+    const query = `query ($ownerAddresses: [String!]) {
+      queryBondsByOwner(ownerAddresses: $ownerAddresses) {
+        owner
+        bonds {
+          id
+          owner
+          balance {
+            type
+            quantity
+          }
+        }
+      }
+    }`;
+
     const variables = {
-      attributes: Util.toGQLAttributes(attributes)
+      ownerAddresses
     };
 
-    return RegistryClient.getResult(this._graph(query)(variables), 'queryBonds');
+    return RegistryClient.getResult(this._graph(query)(variables), 'queryBondsByOwner');
   }
 
   /**

src/sdk.test.ts

@@ -16,7 +16,7 @@ describe('Querying', () => {
   let bondId: string;
 
   beforeAll(async () => {
-    registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
 
     bondId = await registry.getNextBondId(privateKey);
     await registry.createBond({ denom: DENOM, amount: '1000000000' }, privateKey, fee);

src/testing/helper.ts

@@ -2,7 +2,9 @@ import assert from 'assert';
 import yaml from 'node-yaml';
 import semver from 'semver';
 
-import { DEFAULT_CHAIN_ID } from '../index';
+import { Account, Registry } from '../index';
+
+const DEFAULT_CHAIN_ID = 'laconic_9000-1';
 
 export const ensureUpdatedConfig = async (path: string) => {
   const conf = await yaml.read(path);
@@ -28,8 +30,21 @@ export const getConfig = () => {
     rpcEndpoint: process.env.LACONICD_RPC_ENDPOINT || 'http://localhost:26657',
     gqlEndpoint: process.env.LACONICD_GQL_ENDPOINT || 'http://localhost:9473/api',
     fee: {
-      amount: [{ denom: 'alnt', amount: '400000' }],
+      amount: [{ denom: 'alnt', amount: '200000' }],
-      gas: '400000'
+      gas: '200000'
     }
   };
 };
+
+export const createTestAccounts = async (numAccounts: number): Promise<Account[]> => {
+  const accounts: Account[] = [];
+
+  for (let i = 0; i < numAccounts; i++) {
+    const mnemonic = Account.generateMnemonic();
+    const account = await Account.generateFromMnemonic(mnemonic);
+    await account.init();
+    accounts.push(account);
+  }
+
+  return accounts;
+};

src/types/cerc/auction/message.ts

@@ -1,19 +1,32 @@
 import { EncodeObject, GeneratedType } from '@cosmjs/proto-signing';
 
-import { MsgCommitBidResponse, MsgCommitBid, MsgRevealBid, MsgRevealBidResponse } from '../../../proto/cerc/auction/v1/tx';
+import { MsgCommitBidResponse, MsgCommitBid, MsgRevealBid, MsgRevealBidResponse, MsgCreateAuction, MsgCreateAuctionResponse, MsgReleaseFunds, MsgReleaseFundsResponse } from '../../../proto/cerc/auction/v1/tx';
 
+export const typeUrlMsgCreateAuction = '/cerc.auction.v1.MsgCreateAuction';
 export const typeUrlMsgCommitBid = '/cerc.auction.v1.MsgCommitBid';
 export const typeUrlMsgCommitBidResponse = '/cerc.auction.v1.MsgCommitBidResponse';
 export const typeUrlMsgRevealBid = '/cerc.auction.v1.MsgRevealBid';
 export const typeUrlMsgRevealBidResponse = '/cerc.auction.v1.MsgRevealBidResponse';
+export const typeUrlMsgCreateAuctionResponse = '/cerc.auction.v1.MsgCreateAuctionResponse';
+export const typeUrlMsgReleaseFunds = '/cerc.auction.v1.MsgReleaseFunds';
+export const typeUrlMsgReleaseFundsResponse = '/cerc.auction.v1.MsgReleaseFundsResponse';
 
 export const auctionTypes: ReadonlyArray<[string, GeneratedType]> = [
+  [typeUrlMsgCreateAuction, MsgCreateAuction],
   [typeUrlMsgCommitBid, MsgCommitBid],
   [typeUrlMsgCommitBidResponse, MsgCommitBidResponse],
   [typeUrlMsgRevealBid, MsgRevealBid],
-  [typeUrlMsgRevealBidResponse, MsgRevealBidResponse]
+  [typeUrlMsgRevealBidResponse, MsgRevealBidResponse],
+  [typeUrlMsgCreateAuctionResponse, MsgCreateAuctionResponse],
+  [typeUrlMsgReleaseFunds, MsgReleaseFunds],
+  [typeUrlMsgReleaseFundsResponse, MsgReleaseFundsResponse]
 ];
 
+export interface MsgCreateAuctionEncodeObject extends EncodeObject {
+  readonly typeUrl: '/cerc.auction.v1.MsgCreateAuction';
+  readonly value: Partial<MsgCreateAuction>;
+}
+
 export interface MsgCommitBidEncodeObject extends EncodeObject {
   readonly typeUrl: '/cerc.auction.v1.MsgCommitBid';
   readonly value: Partial<MsgCommitBid>;
@@ -24,6 +37,16 @@ export interface MsgRevealBidEncodeObject extends EncodeObject {
   readonly value: Partial<MsgRevealBid>;
 }
 
+export interface MsgReleaseFundsEncodeObject extends EncodeObject {
+  readonly typeUrl: '/cerc.auction.v1.MsgReleaseFunds';
+  readonly value: Partial<MsgReleaseFunds>;
+}
+
+export const INVALID_BID_ERROR = 'Bid is higher than max price';
+export const RELEASE_FUNDS_ERROR = 'Auction funds already released';
+export const OWNER_MISMATCH_ERROR = 'Only auction owner can release funds';
+export const AUCTION_ERRORS = [INVALID_BID_ERROR, RELEASE_FUNDS_ERROR, OWNER_MISMATCH_ERROR];
+
 export interface MessageMsgCommitBid {
   auctionId: string,
   commitHash: string,
@@ -33,3 +56,26 @@ export interface MessageMsgRevealBid {
   auctionId: string,
   reveal: string,
 }
+
+export interface MessageCreateVickreyAuction {
+  commitsDuration: string;
+  revealsDuration: string;
+  denom: string;
+  commitFee: string;
+  revealFee: string;
+  minimumBid: string;
+}
+
+export interface MessageCreateProviderAuction {
+  commitsDuration: string;
+  revealsDuration: string;
+  denom: string;
+  commitFee: string;
+  revealFee: string;
+  maxPrice: string;
+  numProviders: number;
+}
+
+export interface MessageMsgReleaseFunds {
+  auctionId: string
+}

src/types/cerc/onboarding/message.ts

@@ -15,6 +15,8 @@ export interface MsgOnboardParticipantEncodeObject extends EncodeObject {
   readonly value: MsgOnboardParticipant;
 }
 
+export const ONBOARDING_DISABLED_ERROR = 'Onboarding is disabled';
+
 interface ethPayload {
   address: string
   msg: string

src/util.test.ts

@@ -19,7 +19,7 @@ const utilTests = () => {
   let watcherId: string;
 
   beforeAll(async () => {
-    registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
+    registry = new Registry(gqlEndpoint, rpcEndpoint, { chainId });
 
     // Create bond.
     bondId = await registry.getNextBondId(privateKey);

src/util.ts

@@ -1,6 +1,8 @@
 import * as Block from 'multiformats/block';
 import { sha256 as hasher } from 'multiformats/hashes/sha2';
+import assert from 'assert';
 
+import { GasPrice, StdFee, parseCoins } from '@cosmjs/stargate';
 import * as dagCBOR from '@ipld/dag-cbor';
 import * as dagJSON from '@ipld/dag-json';
 
@@ -119,3 +121,33 @@ export class Util {
     return block.cid.toString();
   }
 }
+
+/**
+ * Get gas in proper format
+ */
+export const parseGasAndFees = (gas?: string, fees?: string): StdFee | undefined | number => {
+  // If fees is not given or a number, treat it as a gas estimation multiplier
+  if (fees === null || fees === undefined) {
+    return undefined;
+  }
+
+  const isFeesANumber = !isNaN(Number(fees));
+  if (isFeesANumber) {
+    return Number(fees);
+  }
+
+  // If fees is not a gas estimation multiplier, gas is required
+  assert(gas, 'Invalid gas.');
+
+  return {
+    amount: parseCoins(String(fees)),
+    gas: String(gas)
+  };
+};
+
+/**
+ * Get gas price in proper format
+ */
+export const getGasPrice = (gasPrice: string | null): GasPrice | undefined => {
+  return gasPrice != null ? GasPrice.fromString(String(gasPrice)) : undefined;
+};