dev-script for populating data for one contract only (trying to fix psalomo.near nft image)

.gitpod.yml

@@ -0,0 +1,7 @@
+tasks:
+  - init: |
+      yarn
+      sudo apt install redis -y
+    command: |
+      sudo service redis-server start
+      DEBUG=* yarn start

dev-scripts/preload-data.js

@@ -0,0 +1,86 @@
+const redis = require('redis');
+const nearAPI = require("near-api-js");
+
+const { connect } = nearAPI;
+const { keyStores } = nearAPI;
+
+const config = {
+  networkId: "mainnet",
+  keyStore: new keyStores.InMemoryKeyStore(), // optional if not signing transactions
+  nodeUrl: "https://rpc.mainnet.near.org",
+  walletUrl: "https://wallet.mainnet.near.org",
+  helperUrl: "https://helper.mainnet.near.org",
+  explorerUrl: "https://explorer.mainnet.near.org",
+};
+
+const preload_account = process.argv[2];
+
+(async () => {
+  console.log('preloading contract code for account', preload_account);
+  const near = await connect(config);
+  const response = await near.connection.provider.query({
+    request_type: "view_account",
+    finality: "final",
+    account_id: preload_account,
+  });
+  const block_height = response.block_height;
+  const client = redis.createClient();
+  await client.set('latest_block_height', block_height);
+  const contractBlockHash = response.code_hash;
+  await client.sendCommand('ZADD', [`code:${preload_account}`, block_height, response.code_hash]);
+  await client.sendCommand('ZADD', [`account:${preload_account}`, block_height, response.block_hash]);
+
+  const code_base64 = (await near.connection.provider.query({
+    request_type: "view_code",
+    block_id: block_height,
+    account_id: preload_account,
+  })).code_base64;
+  await client.set(`code:${preload_account}:${contractBlockHash}`, Buffer.from(code_base64, 'base64'));
+
+  console.log('getting data for', preload_account);
+  try {
+    const datavalues = (await near.connection.provider.query({
+      request_type: "view_state",
+      block_id: block_height,
+      account_id: preload_account,
+      prefix_base64: "",
+    })).values;
+
+    for (const datavalue of datavalues) {
+      await client.sendCommand('ZADD', [`data:${preload_account}:${datavalue.key}`, block_height, datavalue.value]);
+    }
+  } catch (e) {
+    console.error(e.message);
+    if (e.message.indexOf('too large')) {
+      console.log('trying to get state from history instead');
+      const activityHistory = await (await fetch(`https://helper.mainnet.near.org/account/${preload_account}/activity?limit=1000`)).json();
+
+      for(const activity of activityHistory) {
+        console.log('getting changes from block_hash', activity.block_hash);
+
+        const changes_response = await (await fetch('https://archival-rpc.mainnet.near.org', {
+          method: 'POST',
+          headers: {'Content-Type': 'application/json'},
+          body: JSON.stringify({
+            jsonrpc: '2.0',
+            id: 'dontcare',
+            method: 'EXPERIMENTAL_changes', params: {
+              "changes_type": "data_changes",
+              "account_ids": [preload_account],
+              "key_prefix_base64": "",
+              "block_id": activity.block_hash
+            }
+          })
+        })).json();
+        const changes = changes_response.result.changes.filter(ch => ch.type === 'data_update').map(ch => ch.change);
+        for (const change of changes) {
+          const storagekey = Buffer.from(change.key_base64,'base64').toString();
+          console.log('updating storage with key', storagekey);
+          await client.sendCommand('ZADD', [`data:${preload_account}:${storagekey}`, block_height, activity.block_hash]);
+          await client.set(`data-value:${preload_account}:${storagekey}:${activity.block_hash}`, Buffer.from(change.value_base64, 'base64'));
+        }
+      }
+    }
+  }
+  await client.quit();
+})();

json-rpc.js

@@ -143,7 +143,7 @@ const parseBlockIndex = async (ctx) => {
 
 const handleJsonRpc = async ctx => {
     if (ALWAYS_PROXY) {
-        return await proxyJson(ctx);
+        return await proxyJson(ctx, {});
     }
 
     ctx.request.body = JSON.parse((await getRawBody(ctx.req)).toString('utf8'));
@@ -183,8 +183,8 @@ const handleJsonRpc = async ctx => {
 };
 
 const callViewFunction = async (ctx,  { accountId, methodName, args }) => {
+    const { blockHeight } = ctx;
     try {
-        const { blockHeight } = ctx;
         const { result, logs, blockHeight: resolvedBlockHeight } = await runContract(accountId, methodName, args, blockHeight);
         const resultBuffer = Buffer.from(result);
         ctx.body = {