feat: added ad-hoc transfer script

bridge/package.json

@@ -11,7 +11,8 @@
     "coverage": "jest --coverage --config=./bridge.jest.config.js",
     "lint": "eslint src --ext .ts",
     "build": "tsc",
-    "mint": "node scripts/mint-script.js mint"
+    "mint": "node scripts/mint-script.js mint",
+    "transfer": "node scripts/transfer-script.js transfer"
   },
   "repository": {
     "type": "git",
@@ -68,12 +69,12 @@
   },
   "dependencies": {
     "@pagerduty/pdjs": "^2.2.3",
-    "@planetarium/account": "2.4.0",
+    "@planetarium/account": "^4.1.0",
     "@planetarium/account-aws-kms": "^0.0.2",
     "@planetarium/aws-kms-provider": "0.3.4",
     "@planetarium/bencodex": "0.2.2",
     "@planetarium/sign": "^0.0.3",
-    "@planetarium/tx": "2.4.0",
+    "@planetarium/tx": "^4.1.0",
     "@safe-global/safe-core-sdk": "^3.3.2",
     "@safe-global/safe-core-sdk-types": "^1.9.0",
     "@safe-global/safe-ethers-lib": "^1.9.2",

bridge/scripts/transfer-script.ts

@@ -0,0 +1,142 @@
+"use strict";
+import { NCGKMSTransfer } from "../src/ncg-kms-transfer";
+import { KmsProvider } from "@planetarium/aws-kms-provider";
+import Web3 from "web3";
+import { HeadlessGraphQLClient } from "../src/headless-graphql-client";
+import { KMSNCGSigner } from "../src/kms-ncg-signer";
+import { isAddress } from "web3-utils";
+import { Command } from "commander";
+import readline from "readline";
+
+async function transfer() {
+    const program = new Command();
+    program
+        .name("ad-hoc transfer script")
+        .description("Transfer token")
+        .version("0.0.1");
+
+    program
+        .command("transfer")
+        .description("transfer ( ad-hoc transfer )")
+        .argument("<address>", "destination( 9c address )")
+        .argument("<amount>", "amount( to transfer )")
+        .action(async (address: string, amount: string) => {
+            await transferNcg(address, amount);
+        });
+
+    program.parseAsync();
+}
+
+transfer();
+
+async function transferNcg(user9cAddress: string, amount: string) {
+    const isValidAddress = (address: string) => {
+        const ZERO_ADDRESS = "0x0000000000000000000000000000000000000000";
+        return (
+            address.startsWith("0x") &&
+            isAddress(address) &&
+            address !== ZERO_ADDRESS
+        );
+    };
+    if (!isValidAddress(user9cAddress)) {
+        console.log("isValidAddress - Cancel transfer...");
+        process.exit(1);
+    }
+
+    const GRAPHQL_API_ENDPOINT = process.env.GRAPHQL_API_ENDPOINT!;
+    const NCG_MINTER = process.env.NCG_MINTER!;
+
+    const KMS_PROVIDER_URL = process.env.KMS_PROVIDER_URL!;
+    const KMS_PROVIDER_REGION = process.env.KMS_PROVIDER_REGION!;
+    const KMS_PROVIDER_KEY_ID = process.env.KMS_PROVIDER_KEY_ID!;
+    const KMS_PROVIDER_AWS_ACCESSKEY = process.env.KMS_PROVIDER_AWS_ACCESSKEY!;
+    const KMS_PROVIDER_AWS_SECRETKEY = process.env.KMS_PROVIDER_AWS_SECRETKEY!;
+    const KMS_PROVIDER_PUBLIC_KEY = process.env.KMS_PROVIDER_PUBLIC_KEY!;
+
+    const GRAPHQL_REQUEST_RETRY = 5;
+    const headlessGraphQLCLient = new HeadlessGraphQLClient(
+        GRAPHQL_API_ENDPOINT,
+        GRAPHQL_REQUEST_RETRY
+    );
+
+    const kmsProvider = new KmsProvider(KMS_PROVIDER_URL, {
+        region: KMS_PROVIDER_REGION,
+        keyIds: [KMS_PROVIDER_KEY_ID],
+        credential: {
+            accessKeyId: KMS_PROVIDER_AWS_ACCESSKEY,
+            secretAccessKey: KMS_PROVIDER_AWS_SECRETKEY,
+        },
+    });
+    const web3 = new Web3(kmsProvider);
+
+    const kmsAddresses = await kmsProvider.getAccounts();
+    if (kmsAddresses.length != 1) {
+        console.log("NineChronicles.EthBridge is supported only one address.");
+        process.exit(1);
+    }
+    const kmsAddress = kmsAddresses[0];
+    console.log("kmsAddress", kmsAddress);
+
+    const signer = new KMSNCGSigner(KMS_PROVIDER_REGION, KMS_PROVIDER_KEY_ID, {
+        accessKeyId: KMS_PROVIDER_AWS_ACCESSKEY,
+        secretAccessKey: KMS_PROVIDER_AWS_SECRETKEY,
+    });
+    const derivedAddress =
+        "0x" +
+        web3.utils
+            .keccak256(
+                "0x" +
+                    Buffer.from(KMS_PROVIDER_PUBLIC_KEY, "base64")
+                        .toString("hex")
+                        .slice(2)
+            )
+            .slice(26);
+    if (kmsAddress.toLowerCase() !== derivedAddress.toLowerCase()) {
+        console.log(
+            "KMS_PROVIDER_PUBLIC_KEY variable seems invalid because it doesn't match to address from KMS."
+        );
+        process.exit(1);
+    }
+
+    const ncgKmsTransfer = new NCGKMSTransfer(
+        [headlessGraphQLCLient],
+        kmsAddress,
+        KMS_PROVIDER_PUBLIC_KEY,
+        [NCG_MINTER],
+        signer
+    );
+
+    console.log(
+        "==========================================================================================================="
+    );
+    console.log(
+        `Are you trying to Transfer NCG. To: ${user9cAddress}, Amount: ${amount} ??`
+    );
+    console.log('If Correct, Enter "yes", If not Enter anything');
+
+    const reader = readline.createInterface({
+        input: process.stdin,
+        output: process.stdout,
+    });
+
+    await reader.on("line", async (input) => {
+        reader.close();
+
+        if (input.toLowerCase() !== "yes") {
+            console.log("Cancel Transferring....");
+            process.exit(1);
+        }
+
+        console.log(
+            `Transferring NCG to ${user9cAddress}, amount: ${amount}...`
+        );
+
+        const txId = await ncgKmsTransfer.transfer(
+            user9cAddress,
+            amount.toString(),
+            null
+        );
+
+        console.log("txId", txId);
+    });
+}