Fix pure proxy check, #919

opensquare-network · Aug 20, 2024 · b3a4e59 · b3a4e59
1 parent e2c7c46
commit b3a4e59
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 3 deletions.
diff --git a/backend/packages/mongo/src/palletProxy/proxy.js b/backend/packages/mongo/src/palletProxy/proxy.js
@@ -31,8 +31,27 @@ async function getAllActiveProxiesOfDelegator(delegator) {
   return await col.find({ delegator, isRemoved: false }).toArray();
 }
 
+async function isPureProxyDelegator(delegator) {
+  if (!delegator) {
+    return false;
+  }
+
+  const col = await getProxyCol();
+  const proxies = await col
+    .find({ delegator })
+    .sort({ "indexer.blockHeight": 1 })
+    .toArray();
+  if ((proxies || []).length <= 0) {
+    return false;
+  }
+
+  const firstProxy = proxies[0];
+  return firstProxy.isPure;
+}
+
 module.exports = {
   upsertProxyIfNo,
   markProxyRemoved,
   getAllActiveProxiesOfDelegator,
+  isPureProxyDelegator,
 };
diff --git a/backend/packages/pallet-proxy-scan/src/play.js b/backend/packages/pallet-proxy-scan/src/play.js
@@ -11,7 +11,7 @@ const {
 (async () => {
   await initPalletProxyScanDb();
   await subscribeFinalizedHeight();
-  const blockHeights = [2748486, 4197210];
+  const blockHeights = [247043, 2727281];
 
   const api = await getApi();
   for (const height of blockHeights) {

diff --git a/backend/packages/pallet-proxy-scan/src/scan/extrinsics/calls/addProxy.js b/backend/packages/pallet-proxy-scan/src/scan/extrinsics/calls/addProxy.js
@@ -4,7 +4,7 @@ const {
 } = require("@osn/scan-common");
 const { generateProxyId } = require("../../common/hash");
 const {
-  palletProxy: { upsertProxyIfNo, getProxyTimelineCol },
+  palletProxy: { upsertProxyIfNo, getProxyTimelineCol, isPureProxyDelegator },
 } = require("@statescan/mongo");
 const {
   store: { setKnownHeightMark },
@@ -35,14 +35,15 @@ async function handleAddProxy(call, signer, extrinsicIndexer) {
   const type = call.args[1].toString();
   const proxyId = generateProxyId(signer, delegatee, type, delay);
 
+  const isPure = await isPureProxyDelegator(signer);
   await upsertProxyIfNo({
     proxyId,
     delegator: signer,
     delegatee,
     type,
     delay,
     isRemoved: false,
-    isPure: false,
+    isPure,
     indexer: extrinsicIndexer,
   });