Merge pull request #196 from ckb-devrel/v0.3.x

feat: merge v0.3.2 into master

Author: RetricSu

package.json

@@ -67,7 +67,7 @@
     "@types/http-proxy": "^1.17.15",
     "adm-zip": "^0.5.10",
     "child_process": "^1.0.2",
-    "ckb-transaction-dumper": "^0.4.0",
+    "ckb-transaction-dumper": "^0.4.2",
     "commander": "^12.0.0",
     "cpu-features": "^0.0.10",
     "http-proxy": "^1.18.1",

src/cmd/repl.ts

@@ -6,6 +6,8 @@ import { Network, NetworkOption } from '../type/base';
 import { buildCCCDevnetKnownScripts } from '../scripts/private';
 import accounts from '../../account/account.json';
 import { validateNetworkOpt } from '../util/validator';
+import { genSystemScripts } from '../scripts/gen';
+import { readUserDeployedScriptsInfo } from '../scripts/util';
 
 export interface ReplProp extends NetworkOption {
   proxyRpc?: boolean;
@@ -28,15 +30,28 @@ export function repl({ network = Network.devnet, proxyRpc = false }: ReplProp) {
   context.ccc = ccc;
   context.cccA = cccA;
   context.networks = networks;
-  context.Client = initGlobalClientBuilder();
-  context.client = initGlobalClientBuilder().new(network);
+  context.Client = initGlobalClientBuilder(proxyRpc);
+  context.client = initGlobalClientBuilder(proxyRpc).new(network);
   context.accounts = accounts;
+  context.myScripts = buildMyScripts().new(network);
+  context.systemScripts = buildSystemScripts().new(network);
+
   context.help = printHelpText;
 }
 
-export function initGlobalClientBuilder() {
+export function initGlobalClientBuilder(proxyRpc: boolean) {
   return {
     new: (network: Network) => {
+      if (proxyRpc) {
+        return network === 'mainnet'
+          ? new ccc.ClientPublicMainnet({ url: networks.mainnet.proxy_rpc_url })
+          : network === 'testnet'
+            ? new ccc.ClientPublicTestnet({ url: networks.testnet.proxy_rpc_url })
+            : new ccc.ClientPublicTestnet({
+                url: networks.devnet.proxy_rpc_url,
+                scripts: buildCCCDevnetKnownScripts(),
+              });
+      }
       return network === 'mainnet'
         ? new ccc.ClientPublicMainnet()
         : network === 'testnet'
@@ -72,6 +87,29 @@ Global Variables to use:
      const myClient = Client.fromUrl('<your rpc url>', 'devnet' | 'testnet' | 'mainnet');
   - accounts, test accounts array from OffCKB
   - networks, network information configs
+  - myScripts, user-deployed scripts information via offckb deploy
+  - systemScripts, built-in scripts information in the blockchain
   - help, print this help message
 `);
 }
+
+export function buildSystemScripts() {
+  return {
+    new: (network: Network) => {
+      const systemScripts = genSystemScripts();
+      return network === Network.devnet
+        ? systemScripts?.devnet
+        : network === Network.testnet
+          ? systemScripts?.testnet
+          : systemScripts?.mainnet;
+    },
+  };
+}
+
+export function buildMyScripts() {
+  return {
+    new: (network: Network) => {
+      return readUserDeployedScriptsInfo(network);
+    },
+  };
+}

src/tools/rpc-proxy.ts

@@ -37,6 +37,7 @@ export function createRPCProxy(network: Network, targetRpcUrl: string, port: num
             }
             const txFile = path.resolve(settings.devnet.transactionsPath, `${txHash}.json`);
             fs.writeFileSync(txFile, JSON.stringify(tx, null, 2));
+            console.debug(`RPC Req:  store tx ${txHash}`);
           }
         }
       } catch (err) {
@@ -45,6 +46,25 @@ export function createRPCProxy(network: Network, targetRpcUrl: string, port: num
     });
   });
 
+  proxy.on('proxyRes', function (proxyRes, _req, _res) {
+    const body: Buffer[] = [];
+    proxyRes.on('data', function (chunk) {
+      body.push(chunk);
+    });
+    proxyRes.on('end', function () {
+      const res = Buffer.concat(body).toString();
+      try {
+        const jsonRpcResponse = JSON.parse(res);
+        const error = jsonRpcResponse.error;
+        if (error) {
+          console.debug('RPC Response: ', jsonRpcResponse);
+        }
+      } catch (err) {
+        console.error('Error parsing JSON-RPC content:', err);
+      }
+    });
+  });
+
   const server = http.createServer((req, res) => {
     proxy.web(req, res, {}, (err) => {
       if (err) {

yarn.lock

@@ -832,10 +832,10 @@ cipher-base@^1.0.0, cipher-base@^1.0.1, cipher-base@^1.0.3:
     inherits "^2.0.1"
     safe-buffer "^5.0.1"
 
-ckb-transaction-dumper@^0.4.0:
-  version "0.4.0"
-  resolved "https://registry.yarnpkg.com/ckb-transaction-dumper/-/ckb-transaction-dumper-0.4.0.tgz#21c248b58883779219f43d3e5002caa319c97129"
-  integrity sha512-/Ue1s41BRgrHAYw1LEVcVetyEOLzSGx2Qrn2zPh8TuI5PZ3FO/TtDMEnDJQNu/wEE+vCYEsr0rDAFNY2NiFgLw==
+ckb-transaction-dumper@^0.4.2:
+  version "0.4.2"
+  resolved "https://registry.yarnpkg.com/ckb-transaction-dumper/-/ckb-transaction-dumper-0.4.2.tgz#bceadef621a8ea793b4f698d606cbf4f5c874ec8"
+  integrity sha512-0frB1FYY3dlKLlef6ps8dfuwTXitdm4myYTc/+hAP3RCo/OrC1/MYXEedUCLXgqcXBnlOQ8VbK5PseNZovWPHQ==
 
 cli-cursor@^4.0.0:
   version "4.0.0"