add verify harvester endpoint

serverless.yml

@@ -81,3 +81,9 @@ functions:
       - httpApi:
           path: /bridgeworld/legions/verify
           method: post
+  verifyHarvesterAccess:
+    handler: src/handlers/bridgeworld.verifyHarvesterAccess
+    events:
+      - httpApi:
+          path: /bridgeworld/harvesters/{id}/verify
+          method: post

src/handlers/bridgeworld.js

@@ -3,6 +3,7 @@ const {
   getMines,
   getLegionHolders,
   hasGenesisLegion,
+  hasHarvesterAccess,
 } = require("../services/bridgeworld");
 
 exports.getCorruption = getCorruption;
@@ -21,3 +22,15 @@ exports.verifyGenesisLegionHolders = async (event) => {
     success: await hasGenesisLegion(wallets),
   };
 };
+
+exports.verifyHarvesterAccess = async (event) => {
+  const body = JSON.parse(event.body);
+  const wallets = (body.wallets || body.wallet || []).map((wallet) =>
+    wallet.toLowerCase()
+  );
+  const id = event.pathParameters.id.toLowerCase();
+  console.log("Querying Harvester access for wallets:", id, wallets);
+  return {
+    success: await hasHarvesterAccess(id, wallets),
+  };
+};

src/services/bridgeworld.js

@@ -383,3 +383,21 @@ exports.hasGenesisLegion = async (wallets) => {
   }`);
   return tokens.length > 0;
 };
+
+exports.hasHarvesterAccess = async (id, wallets) => {
+  const { stakedTokens = [] } = await querySubgraph(`{
+    stakedTokens(
+      first: 1000
+      where: {
+        user_in: ["${wallets.join('","')}"]
+        harvester: "${id}"
+        token_: {
+          category: Consumable
+        }
+      }
+    ) {
+      id
+    }
+  }`);
+  return stakedTokens.length > 0;
+};