Merge pull request #263 from expand-network/feature_ENC-2674_CosmosSigner

Feature enc 2674 cosmos signer

Author: varun24143

configuration/config.json

@@ -272,6 +272,22 @@
             "networkPassphrase": "Test SDF Network ; September 2015",
             "rpc": "https://horizon-testnet.stellar.org"
         },
+        "cosmoshub-4": {
+            "localName": "cosmoshub_mainnet",
+            "chainName": "Cosmos",
+            "chainSymbol": "cosmos",
+            "rpc": "https://cosmos-rpc.publicnode.com:443",
+            "publicRpc": "https://cosmos-rpc.publicnode.com:443",
+            "gasPrice": "3000"
+        },
+        "theta-testnet-001": {
+            "localName": "cosmoshub_testnet",
+            "chainName": "Cosmos",
+            "chainSymbol": "cosmos",
+            "rpc": "https://rpc.sentry-01.theta-testnet.polypore.xyz",
+            "publicRpc": "https://rpc.sentry-01.theta-testnet.polypore.xyz",
+            "gasPrice": "3000"
+        },
         "1600": {
             "localName": "XRPLedger",
             "chainName": "XRPL",

configuration/intialiseWeb3.js

@@ -10,6 +10,8 @@ const {
 } = require("@mysten/sui.js");
 const aptos = require('aptos');
 const { TonClient, WalletContractV4, internal } = require("@ton/ton");
+const { StargateClient } = require("@cosmjs/stargate");
+
 const common = require('./common');
 const config = require('./config.json');
 const errorMessage = require('./errorMessage.json');
@@ -97,9 +99,10 @@ exports.initialiseWeb3 = async (data) => {
         });
     } else if (chainName === 'Stellar') {
         web3 = new Horizon.Server(rpc);
+    } else if (chainName === "Cosmos") {
+        web3 = await StargateClient.connect(rpc);
     }
 
-
     return (web3);
 
 };

package.json

@@ -61,6 +61,7 @@
     "tronweb": "5.3.1",
     "tweetnacl": "1.0.3",
     "web3": "1.7.5",
+    "@cosmjs/stargate": "0.32.4",
     "xrpl": "^3.0.0"
   },
   "devDependencies": {

src/adapters/Wallet/index.js

@@ -56,7 +56,7 @@ class Wallet {
     signVersionedTransaction = async (transactionObject) => {
 
         const configuration = { "params": {} };
-        transactionObject.function = "txObjectSol()";
+        transactionObject.function = "txObjSol()";
         const validObject = await schemaValidator.validateInput(transactionObject);
 
         if (!validObject.valid) {

src/adapters/WalletCosmos/index.js

@@ -0,0 +1,109 @@
+const { DirectSecp256k1HdWallet } = require("@cosmjs/proto-signing");
+const { SigningStargateClient } = require("@cosmjs/stargate");
+const { TxRaw } = require("cosmjs-types/cosmos/tx/v1beta1/tx");
+const axios = require('axios').default;
+const schemaValidator = require('../../../configuration/schemaValidator');
+const common = require('../../../configuration/common');
+const config = require('../../../configuration/config.json');
+
+
+class WalletCosmos {
+
+    constructor(options) {
+        this.wallet = options.privateKey;
+    }
+
+    signTransaction = async (transactionObject) => {
+
+        const configuration = { "params": {} };
+        transactionObject.function = "txObjSol()";
+        const validJson = await schemaValidator.validateInput(transactionObject);
+
+        if (!validJson.valid) {
+            return validJson;
+        }
+
+        const chainId = await common.getChainId({ chainId: transactionObject.chainId, chainSymbol: transactionObject.chainSymbol });
+        let chainName = config.chains[chainId].chainName;
+
+        axios.defaults.headers['X-API-KEY'] = this.xApiKey;
+        const apiURL = `${config.url.apiurl}/chain/getpublicrpc/`;
+
+        configuration.params = {
+            chainId
+        };
+
+        let rpc = await axios.get(apiURL, configuration);
+        rpc = rpc.data.data.rpc;
+
+        if (chainName !== "Cosmos") {
+            return {
+                "msg": "Cosmos wallet can be used only with Cosmos chains"
+            }
+        };
+
+        const wallet = await DirectSecp256k1HdWallet.fromMnemonic(this.wallet, {
+            prefix: "cosmos",
+        });
+
+        const Account = (await wallet.getAccounts())[0].address;
+        const signingClient = await SigningStargateClient.connectWithSigner(rpc, wallet);
+
+        const tx = await signingClient.sign(Account, [
+            {
+                typeUrl: "/cosmos.bank.v1beta1.MsgSend",
+                value: {
+                  fromAddress: Account,
+                  toAddress: transactionObject.to,
+                  amount: [{ denom: "uatom", amount: transactionObject.value }],
+                },
+              }
+          ], {
+            amount: [{ denom: "uatom", amount: "1000" }],
+            gas: "200000",
+         },
+         "expand"
+        );
+
+        const encodedTx = TxRaw.encode(tx).finish();
+        const rawString = Buffer.from(encodedTx).toString("base64");
+        return { chainId: chainId, rawTransaction: rawString };
+
+    }
+
+    sendTransaction = async (options) => {
+
+        const filterOptions = options;
+        filterOptions.function = "sendTransaction()";
+        const validJson = await schemaValidator.validateInput(options);
+        if (!validJson.valid) {
+            return (validJson);
+        }
+
+        try {
+
+            const apiURL = `${config.url.apiurl}/chain/sendtransaction/`;
+
+            const params = {
+                method: "post",
+                url: apiURL,
+                data: options,
+                headers: {
+                    "x-api-key": this.xApiKey
+                }
+            };
+
+            const transactionHash = await axios(params);
+            return transactionHash.data;
+        }
+
+        catch (error) {
+            return error;
+        }
+
+    };
+
+
+}
+
+module.exports = { WalletCosmos }; 

src/adapters/WalletPhantom/index.js

@@ -16,7 +16,7 @@ class WalletPhantom {
     signTransaction = async (transactionObject) => {
 
         const configuration = { "params": {} };
-        transactionObject.function = "txObjectSol()";
+        transactionObject.function = "txObjSol()";
         const validObject = await schemaValidator.validateInput(transactionObject);
 
         if (!validObject.valid) {

src/index.js

@@ -1,7 +1,9 @@
 const axios = require('axios').default;
 const config = require('../configuration/config.json');
 const schemaValidator = require('../configuration/schemaValidator');
-const { Wallet, WalletFordefi, WalletDFNS, WalletTON, WalletFireblocks, WalletPhantom, WalletCoinbase, WalletCircle, WalletStellar, WalletXRPL } = require('./interfaces/index');
+const { Wallet, WalletFordefi, WalletDFNS, WalletTON, 
+        WalletFireblocks, WalletPhantom, WalletCoinbase, 
+        WalletCircle, WalletCosmos, WalletStellar, WalletXRPL } = require('./interfaces/index');
 
 exports.prepareTransaction = async (apiURL, options) => {
 
@@ -88,6 +90,9 @@ exports.WalletStellar = WalletStellar;
 
 exports.WalletXRPL = WalletXRPL;
 
+exports.WalletCosmos = WalletCosmos;
+
+
 
 
 

src/interfaces/index.js

@@ -6,6 +6,7 @@ const { WalletCoinbase } = require('../adapters/WalletCoinbase');
 const { WalletTON } = require('../adapters/WalletTON');
 const { WalletFireblocks } = require('../adapters/WalletFireblocks');
 const { WalletCircle } = require('../adapters/WalletCircle');
+const { WalletCosmos } = require("../adapters/WalletCosmos");
 const { WalletStellar } = require('../adapters/WalletStellar');
 const { WalletXRPL } = require('../adapters/WalletXRPL');
 
@@ -19,5 +20,6 @@ module.exports = {
     WalletFireblocks,
     WalletCircle,
     WalletStellar,
-    WalletXRPL
+    WalletXRPL,
+    WalletCosmos
 };

test/cosmosTest.js

@@ -0,0 +1,20 @@
+const { WalletCosmos } = require('../src');
+
+const xApiKey = 'X_API_KEY';
+
+async function main() {
+    const preparedTx = {
+        "chainId": "theta-testnet-001",
+        "from": "cosmos1h7sp085zemehp5gunplymxhflrp8ls4qm3mxrq",
+        "to": "cosmos1h6r7sgwxfxps4payfyc8rl56svzmx6t5kpumg3",
+        "value": "1000",
+    }
+    
+    const wallet  = new WalletCosmos({ privateKey:'your Mnemonic in English', xApiKey:xApiKey});
+    const signedTx = await wallet.signTransaction(preparedTx);
+    console.log(signedTx);
+    // const TxHash = await wallet.sendTransaction(signedTx);
+    // console.log(TxHash);
+}
+    
+main();