Export token denom

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/registry-sdk",
-  "version": "0.2.8",
+  "version": "0.2.5",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
   "repository": "git@github.com:cerc-io/registry-sdk.git",

src/bond.test.ts

@@ -54,20 +54,15 @@ const bondTests = () => {
     test('Query bonds.', async () => {
       const bonds = await registry.queryBonds();
       expect(bonds).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 });
+      const bond = bonds.filter((bond: any) => bond.id === bond1.id);
+      expect(bond).toBeDefined();
     });
 
     test('Query bonds by owner.', async () => {
-      const [result] = await registry.queryBondsByOwner([bond1.owner]);
-      expect(result).toBeDefined();
-      expect(result.bonds).toBeDefined();
-
-      const filteredBonds = result.bonds.filter((bond: any) => bond.id === bond1.id);
-      expect(filteredBonds).toHaveLength(1);
-      expect(filteredBonds[0]).toMatchObject({ id: bond1.id, owner: bond1.owner });
+      const bonds = await registry.queryBonds({ owner: bond1.owner });
+      expect(bonds).toBeDefined();
+      const bond = bonds.filter((bond: any) => bond.id === bond1.id);
+      expect(bond).toBeDefined();
     });
 
     test('Refill bond.', async () => {

src/constants.ts

@@ -1 +1,2 @@
 export const DENOM = 'alnt';
+export const DEFAULT_CHAIN_ID = 'laconic_9000-1';

src/index.ts

@@ -31,8 +31,7 @@ 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';
-
-export const DEFAULT_CHAIN_ID = 'laconic_9000-1';
+import { DEFAULT_CHAIN_ID } from './constants';
 
 /**
  * Create an auction bid.
@@ -107,8 +106,8 @@ export class Registry {
   /**
    * Get records by attributes.
    */
-  async queryRecords (attributes: { [key: string]: any }, all = false, refs = false, limit?: number, offset?: number) {
-    return this._client.queryRecords(attributes, all, refs, limit, offset);
+  async queryRecords (attributes: { [key: string]: any }, all = false, refs = false) {
+    return this._client.queryRecords(attributes, all, refs);
   }
 
   /**
@@ -186,17 +185,10 @@ export class Registry {
   }
 
   /**
-   * Query bonds.
+   * Query bonds by attributes.
    */
-  async queryBonds () {
-    return this._client.queryBonds();
-  }
-
-  /**
- * Query bonds by owner(s).
- */
-  async queryBondsByOwner (owners: string[]) {
-    return this._client.queryBondsByOwner(owners);
+  async queryBonds (attributes = {}) {
+    return this._client.queryBonds(attributes);
   }
 
   /**
@@ -396,13 +388,6 @@ export class Registry {
     return this._client.getAuctionsByIds(ids);
   }
 
-  /**
-   * List authorities by owner.
-   */
-  async getAuthorities (owner?: string, auction = false) {
-    return this._client.getAuthorities(owner, auction);
-  }
-
   /**
    * Lookup authorities by names.
    */
@@ -493,5 +478,6 @@ export class Registry {
 
 export { Account };
 export { LaconicClient };
+export { DENOM, DEFAULT_CHAIN_ID } from './constants';
 export * from './types/cerc/bond/message';
 export * from './types/cerc/onboarding/message';

src/laconic-client.ts

@@ -13,7 +13,7 @@ import { MsgCancelBondEncodeObject, MsgCreateBondEncodeObject, MsgRefillBondEnco
 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 { MsgOnboardParticipantEncodeObject, ONBOARDING_DISABLED_ERROR, onboardingTypes, typeUrlMsgOnboardParticipant } from './types/cerc/onboarding/message';
+import { MsgOnboardParticipantEncodeObject, 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';
@@ -381,7 +381,7 @@ export class LaconicClient extends SigningStargateClient {
   }
 
   processWriteError (error: string) {
-    const errorMessage = [...NAMESERVICE_ERRORS, ONBOARDING_DISABLED_ERROR].find(message => error.includes(message));
+    const errorMessage = NAMESERVICE_ERRORS.find(message => error.includes(message));
 
     if (!errorMessage) {
       console.error(error);

src/nameservice-expiry.test.ts

@@ -60,11 +60,7 @@ const nameserviceExpiryTests = () => {
   });
 
   test('Wait for expiry duration', (done) => {
-    // Wait for expiry time + time for a block to be executed
-    const expiryTime = 60 * 1000;
-    const waitTime = expiryTime + (3 * 1000);
-
-    setTimeout(done, waitTime);
+    setTimeout(done, 60 * 1000);
   });
 
   test('Check record expiry time', async () => {
@@ -88,11 +84,7 @@ const nameserviceExpiryTests = () => {
   });
 
   test('Wait for expiry duration', (done) => {
-    // Wait for expiry time + time for a block to be executed
-    const expiryTime = 60 * 1000;
-    const waitTime = expiryTime + (3 * 1000);
-
-    setTimeout(done, waitTime);
+    setTimeout(done, 60 * 1000);
   });
 
   test('Check record deleted without bond balance', async () => {

src/naming.test.ts

@@ -1,8 +1,6 @@
 import assert from 'assert';
 import path from 'path';
 
-import { DirectSecp256k1Wallet, AccountData as CosmosAccount } from '@cosmjs/proto-signing';
-
 import { Account } from './account';
 import { Registry } from './index';
 import { ensureUpdatedConfig, getConfig } from './testing/helper';
@@ -21,18 +19,6 @@ const namingTests = () => {
   let watcher: any;
   let watcherId: string;
 
-  let otherAccount1: Account;
-
-  let reservedAuthorities: {
-    name: string;
-    entry: {
-      ownerAddress: string;
-      status: string;
-    };
-  }[] = [];
-
-  let account: CosmosAccount;
-
   beforeAll(async () => {
     registry = new Registry(gqlEndpoint, rpcEndpoint, chainId);
 
@@ -53,26 +39,12 @@ const namingTests = () => {
     );
 
     watcherId = result.id;
-
-    const accountWallet = await DirectSecp256k1Wallet.fromKey(Buffer.from(privateKey, 'hex'), 'laconic');
-    [account] = await accountWallet.getAccounts();
-
-    const mnenonic1 = Account.generateMnemonic();
-    otherAccount1 = await Account.generateFromMnemonic(mnenonic1);
-    await otherAccount1.init();
   });
 
   describe('Authority tests', () => {
     test('Reserve authority.', async () => {
       const authorityName = `laconic-${Date.now()}`;
       await registry.reserveAuthority({ name: authorityName }, privateKey, fee);
-      reservedAuthorities.push({
-        name: authorityName,
-        entry: {
-          ownerAddress: account.address,
-          status: 'active'
-        }
-      });
     });
 
     describe('With authority reserved', () => {
@@ -84,13 +56,6 @@ const namingTests = () => {
         lrn = `lrn://${authorityName}/app/test`;
 
         await registry.reserveAuthority({ name: authorityName }, privateKey, fee);
-        reservedAuthorities.push({
-          name: authorityName,
-          entry: {
-            ownerAddress: account.address,
-            status: 'active'
-          }
-        });
       });
 
       test('Lookup authority.', async () => {
@@ -115,13 +80,6 @@ const namingTests = () => {
       test('Reserve sub-authority.', async () => {
         const subAuthority = `echo.${authorityName}`;
         await registry.reserveAuthority({ name: subAuthority }, privateKey, fee);
-        reservedAuthorities.push({
-          name: subAuthority,
-          entry: {
-            ownerAddress: account.address,
-            status: 'active'
-          }
-        });
 
         const [record] = await registry.lookupAuthorities([subAuthority]);
         expect(record).toBeDefined();
@@ -132,22 +90,18 @@ const namingTests = () => {
 
       test('Reserve sub-authority with different owner.', async () => {
         // Create another account, send tx to set public key on the account.
+        const mnenonic1 = Account.generateMnemonic();
+        const otherAccount1 = await Account.generateFromMnemonic(mnenonic1);
+        await otherAccount1.init();
+        await registry.sendCoins({ denom: DENOM, amount: '1000000000', destinationAddress: otherAccount1.address }, privateKey, fee);
+
         const mnenonic2 = Account.generateMnemonic();
         const otherAccount2 = await Account.generateFromMnemonic(mnenonic2);
         await otherAccount2.init();
-
-        await registry.sendCoins({ denom: DENOM, amount: '1000000000', destinationAddress: otherAccount1.address }, privateKey, fee);
         await registry.sendCoins({ denom: DENOM, amount: '1000', destinationAddress: otherAccount2.address }, otherAccount1.getPrivateKey(), fee);
 
         const subAuthority = `halo.${authorityName}`;
         await registry.reserveAuthority({ name: subAuthority, owner: otherAccount1.address }, privateKey, fee);
-        reservedAuthorities.push({
-          name: subAuthority,
-          entry: {
-            ownerAddress: otherAccount1.address,
-            status: 'active'
-          }
-        });
 
         const [record] = await registry.lookupAuthorities([subAuthority]);
         expect(record).toBeDefined();
@@ -166,39 +120,6 @@ const namingTests = () => {
       test('Set authority bond', async () => {
         await registry.setAuthorityBond({ name: authorityName, bondId }, privateKey, fee);
       });
-
-      test('List authorities.', async () => {
-        const authorities = await registry.getAuthorities(undefined, true);
-        reservedAuthorities.sort((a, b) => a.name.localeCompare(b.name));
-        const expectedEntryKeys = [
-          'ownerAddress',
-          'ownerPublicKey',
-          'height',
-          'status',
-          'bondId',
-          'expiryTime',
-          'auction'
-        ];
-
-        expect(authorities.length).toEqual(4);
-        expectedEntryKeys.forEach(key => {
-          authorities.forEach((authority: any) => {
-            expect(authority).toHaveProperty('name');
-            expect(authority.entry).toHaveProperty(key);
-          });
-        });
-        authorities.forEach((authority: any, index: number) => {
-          expect(authority).toMatchObject(reservedAuthorities[index]);
-        });
-      });
-
-      test('List authorities by owner.', async () => {
-        const authorities = await registry.getAuthorities(otherAccount1.address);
-
-        expect(authorities.length).toEqual(1);
-        expect(authorities[0].entry.ownerAddress).toBe(otherAccount1.address);
-        expect(authorities[0].entry.ownerPublicKey).toBe(otherAccount1.encodedPubkey);
-      });
     });
   });
 

src/onboarding.test.ts

@@ -2,7 +2,7 @@ import { Wallet } from 'ethers';
 
 import { DirectSecp256k1Wallet, AccountData as CosmosAccount } from '@cosmjs/proto-signing';
 
-import { Registry, Account, ONBOARDING_DISABLED_ERROR } from './index';
+import { Registry, Account } from './index';
 import { getConfig } from './testing/helper';
 import { Participant } from './proto/cerc/onboarding/v1/onboarding';
 
@@ -25,8 +25,9 @@ const onboardingEnabledTests = () => {
     const mnemonic = Account.generateMnemonic();
     ethWallet = Wallet.fromMnemonic(mnemonic);
 
-    const accountWallet = await DirectSecp256k1Wallet.fromKey(Buffer.from(privateKey, 'hex'), 'laconic');
-    [cosmosWallet] = await accountWallet.getAccounts();
+    const account = new Account(Buffer.from(privateKey, 'hex'));
+    const cosmosAccount = await DirectSecp256k1Wallet.fromKey(account._privateKey, 'laconic');
+    [cosmosWallet] = await cosmosAccount.getAccounts();
 
     expectedParticipants = [
       {
@@ -80,6 +81,7 @@ const onboardingDisabledTests = () => {
   });
 
   test('Error on onboarding attempt.', async () => {
+    const errorMsg = 'Validator onboarding is disabled: invalid request';
     const mnemonic = Account.generateMnemonic();
     ethWallet = Wallet.fromMnemonic(mnemonic);
 
@@ -99,7 +101,7 @@ const onboardingDisabledTests = () => {
         kycId: DUMMY_KYC_ID
       }, privateKey, fee);
     } catch (error: any) {
-      expect(error.toString()).toContain(ONBOARDING_DISABLED_ERROR);
+      expect(error.toString()).toContain(errorMsg);
     }
   });
 

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) {
-    return Uint8Array.from(_globalThis.Buffer.from(b64, "base64"));
+  if (globalThis.Buffer) {
+    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) {
-    return _globalThis.Buffer.from(arr).toString("base64");
+  if (globalThis.Buffer) {
+    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/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) {
-    return Uint8Array.from(_globalThis.Buffer.from(b64, "base64"));
+  if (globalThis.Buffer) {
+    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) {
-    return _globalThis.Buffer.from(arr).toString("base64");
+  if (globalThis.Buffer) {
+    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) {
-    return Uint8Array.from(_globalThis.Buffer.from(b64, "base64"));
+  if (globalThis.Buffer) {
+    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) {
-    return _globalThis.Buffer.from(arr).toString("base64");
+  if (globalThis.Buffer) {
+    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

@@ -241,13 +241,13 @@ export class RegistryClient {
   /**
    * Get records by attributes.
    */
-  async queryRecords (attributes: { [key: string]: any }, all = false, refs = false, limit?: number, offset?: number) {
+  async queryRecords (attributes: { [key: string]: any }, all = false, refs = false) {
     if (!attributes) {
       attributes = {};
     }
 
-    const query = `query ($attributes: [KeyValueInput!], $all: Boolean, $limit: Int, $offset: Int) {
-      queryRecords(attributes: $attributes, all: $all, limit: $limit, offset: $offset) {
+    const query = `query ($attributes: [KeyValueInput!], $all: Boolean) {
+      queryRecords(attributes: $attributes, all: $all) {
         id
         names
         owners
@@ -261,9 +261,7 @@ export class RegistryClient {
 
     const variables = {
       attributes: Util.toGQLAttributes(attributes),
-      all,
-      limit,
-      offset
+      all
     };
 
     let result = (await this._graph(query)(variables)).queryRecords;
@@ -272,34 +270,6 @@ export class RegistryClient {
     return result;
   }
 
-  /**
-   * List authorities by owner.
-   */
-  async getAuthorities (owner?: string, auction = false) {
-    const query = `query ($owner: String) {
-      getAuthorities(owner: $owner) {
-        name
-        entry {
-          ownerAddress
-          ownerPublicKey
-          height
-          status
-          bondId
-          expiryTime
-          ${auction ? ('auction { ' + auctionFields + ' }') : ''}
-        }
-      }
-    }`;
-
-    const variables = {
-      owner
-    };
-
-    const result = await this._graph(query)(variables);
-
-    return result.getAuthorities;
-  }
-
   /**
    * Lookup authorities by names.
    */
@@ -427,11 +397,11 @@ export class RegistryClient {
   }
 
   /**
-   * Get bonds.
+   * Get bonds by attributes.
    */
-  async queryBonds () {
-    const query = `query {
-      queryBonds {
+  async queryBonds (attributes = {}) {
+    const query = `query ($attributes: [KeyValueInput!]) {
+      queryBonds(attributes: $attributes) {
         id
         owner
         balance {
@@ -441,32 +411,11 @@ export class RegistryClient {
       }
     }`;
 
-    return RegistryClient.getResult(this._graph(query)({}), 'queryBonds');
-  }
-
-  /**
-   * Get bonds by owner(s).
-   */
-  async queryBondsByOwner (ownerAddresses: string[]) {
-    const query = `query ($ownerAddresses: [String!]) {
-      queryBondsByOwner(ownerAddresses: $ownerAddresses) {
-        owner
-        bonds {
-          id
-          owner
-          balance {
-            type
-            quantity
-          }
-        }
-      }
-    }`;
-
     const variables = {
-      ownerAddresses
+      attributes: Util.toGQLAttributes(attributes)
     };
 
-    return RegistryClient.getResult(this._graph(query)(variables), 'queryBondsByOwner');
+    return RegistryClient.getResult(this._graph(query)(variables), 'queryBonds');
   }
 
   /**

src/testing/helper.ts

@@ -2,7 +2,7 @@ import assert from 'assert';
 import yaml from 'node-yaml';
 import semver from 'semver';
 
-import { DEFAULT_CHAIN_ID } from '../index';
+import { DEFAULT_CHAIN_ID } from '../constants';
 
 export const ensureUpdatedConfig = async (path: string) => {
   const conf = await yaml.read(path);

src/types/cerc/onboarding/message.ts

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