Merge branch 'develop'

Author: lebascou

package.json

@@ -1,6 +1,6 @@
 {
     "name": "@lum-network/sdk-javascript",
-    "version": "0.7.5",
+    "version": "0.7.6",
     "license": "Apache-2.0",
     "description": "Javascript SDK library for NodeJS and Web browsers to interact with the Lum Network.",
     "homepage": "https://github.com/lum-network/sdk-javascript#readme",

src/client/LumClient.ts

@@ -21,6 +21,8 @@ import {
     setupStakingExtension,
     AirdropExtension,
     setupAirdropExtension,
+    TxExtension,
+    setupTxExtension,
 } from '../extensions';
 import { setupSlashingExtension, SlashingExtension } from '../extensions/slashing';
 import { AuthzExtension, setupAuthzExtension } from '../extensions/authz';
@@ -40,7 +42,8 @@ export class LumClient {
         StakingExtension &
         SlashingExtension &
         FeegrantExtension &
-        AirdropExtension;
+        AirdropExtension &
+        TxExtension;
     private chainId?: string;
 
     /**
@@ -64,6 +67,7 @@ export class LumClient {
             setupSlashingExtension,
             setupFeegrantExtension,
             setupAirdropExtension,
+            setupTxExtension,
         );
 
         // Used for debugging while gasWanted, gasUsed and codespace are still waiting to be included in the code lib

src/extensions/index.ts

@@ -7,3 +7,4 @@ export * from './gov';
 export * from './ibc';
 export * from './mint';
 export * from './staking';
+export * from './tx';

src/extensions/tx.ts

@@ -0,0 +1,63 @@
+import Long from 'long';
+import { createProtobufRpcClient, QueryClient } from '@cosmjs/stargate';
+
+import { SignMode } from '../codec/cosmos/tx/signing/v1beta1/signing';
+import { GetTxRequest, GetTxResponse, ServiceClientImpl, SimulateRequest, SimulateResponse } from '../codec/cosmos/tx/v1beta1/service';
+import { AuthInfo, Fee, Tx, TxBody } from '../codec/cosmos/tx/v1beta1/tx';
+import { Message } from '../messages';
+import { LumRegistry } from '../registry';
+import { publicKeyToProto } from '../utils';
+
+export interface TxExtension {
+    readonly tx: {
+        getTx: (txId: string) => Promise<GetTxResponse>;
+        simulate: (messages: readonly Message[], memo: string | undefined, pubkey: Uint8Array, sequence: number) => Promise<SimulateResponse>;
+    };
+}
+
+export function setupTxExtension(base: QueryClient): TxExtension {
+    // Use this service to get easy typed access to query methods
+    // This cannot be used for proof verification
+    const rpc = createProtobufRpcClient(base);
+    const queryService = new ServiceClientImpl(rpc);
+
+    return {
+        tx: {
+            getTx: async (hash: string) => {
+                const request: GetTxRequest = {
+                    hash,
+                };
+                const response = await queryService.GetTx(request);
+                return response;
+            },
+            simulate: async (messages: readonly Message[], memo: string | undefined, pubkey: Uint8Array, sequence: number) => {
+                const request = SimulateRequest.fromPartial({
+                    tx: Tx.fromPartial({
+                        authInfo: AuthInfo.fromPartial({
+                            fee: Fee.fromPartial({}),
+                            signerInfos: [
+                                {
+                                    publicKey: publicKeyToProto(pubkey),
+                                    sequence: Long.fromNumber(sequence, true),
+                                    modeInfo: { single: { mode: SignMode.SIGN_MODE_UNSPECIFIED } },
+                                },
+                            ],
+                        }),
+                        body: TxBody.fromPartial({
+                            messages: messages.map((m) => {
+                                return { typeUrl: m.typeUrl, value: LumRegistry.encode(m) };
+                            }),
+                            memo: memo,
+                        }),
+                        signatures: [new Uint8Array()],
+                    }),
+                    // Sending serialized `txBytes` is the future. But
+                    // this is not available in Comsos SDK 0.42.
+                    txBytes: undefined,
+                });
+                const response = await queryService.Simulate(request);
+                return response;
+            },
+        },
+    };
+}

tests/client.test.ts

@@ -35,6 +35,36 @@ describe('LumClient', () => {
         wsClt.disconnect();
     });
 
+    it.only('should be able to simulate transactions', async () => {
+        const w3 = await LumWalletFactory.fromMnemonic(LumUtils.generateMnemonic());
+        // Should reject invalid bech32 addresses
+        await expect(
+            clt.queryClient.tx.simulate([LumMessages.BuildMsgSend(w1.getAddress(), 'toto', [{ denom: LumConstants.MicroLumDenom, amount: '1' }])], 'hello', w1.getPublicKey(), 0),
+        ).rejects.toThrow();
+        // Should reject invalid signer
+        await expect(
+            clt.queryClient.tx.simulate([LumMessages.BuildMsgSend(w3.getAddress(), w3.getAddress(), [{ denom: LumConstants.MicroLumDenom, amount: '1' }])], 'hello', w3.getPublicKey(), 0),
+        ).rejects.toThrow();
+        // Should reject invalid amounts
+        await expect(
+            clt.queryClient.tx.simulate([LumMessages.BuildMsgSend(w1.getAddress(), w1.getAddress(), [{ denom: LumConstants.MicroLumDenom, amount: '-1' }])], 'hello', w3.getPublicKey(), 0),
+        ).rejects.toThrow();
+        // Should reject invalid sequences
+        await expect(
+            clt.queryClient.tx.simulate([LumMessages.BuildMsgSend(w1.getAddress(), w1.getAddress(), [{ denom: LumConstants.MicroLumDenom, amount: '1' }])], 'hello', w3.getPublicKey(), -1),
+        ).rejects.toThrow();
+        // Should return simulation in case of success
+        const res = await clt.queryClient.tx.simulate(
+            [LumMessages.BuildMsgSend(w1.getAddress(), w1.getAddress(), [{ denom: LumConstants.MicroLumDenom, amount: '1' }])],
+            'hello',
+            w3.getPublicKey(),
+            0,
+        );
+        expect(res).toBeTruthy();
+        expect(res.gasInfo).toBeTruthy();
+        expect(res.result).toBeTruthy();
+    });
+
     it('should open a beam and close it', async () => {
         const beamId = randomString();