FIL-248 - double-check allowance with Glif

src/bot/checkApplications.ts

@@ -16,6 +16,7 @@ import {
 } from "../types/types";
 import { config } from "../config";
 import { anyToBytes, calculateAllocationToRequest } from "../utils/utils";
+import { getVerifiedClientStatus } from "../services/glifService";
 
 const metrics = Metrics.getInstance();
 
@@ -132,19 +133,46 @@ export const checkApplication = async (
     logGeneral(
       `${config.logPrefix} ${
         application.ID
-      } datacap remaining / datacap allocated: ${(margin * 100).toFixed(
+      } datacap remaining (DMOB) / datacap allocated: ${(margin * 100).toFixed(
         2,
       )}% - doesn't need more allowance`,
     );
     return;
   }
 
+  // double check, as remainingDatacap from DMOB is often outdated
+  const {
+    data: glifRemainingDatacap,
+    success,
+    error,
+  } = await getVerifiedClientStatus(client?.addressId);
+  if (!success) {
+    logError(error);
+    return;
+  }
+
+  const glifMargin = computeMargin(
+    glifRemainingDatacap,
+    lastRequestAllowance["Allocation Amount"],
+  );
+
+  if (glifMargin > 0.25) {
+    logGeneral(
+      `${config.logPrefix} ${
+        application.ID
+      } datacap remaining (Glif) / datacap allocated: ${(
+        glifMargin * 100
+      ).toFixed(2)}% - doesn't need more allowance`,
+    );
+    return;
+  }
+
   logGeneral(
     `${config.logPrefix} ${
       application.ID
-    } datacap remaining / datacap allocated: ${(margin * 100).toFixed(
-      2,
-    )}% - Needs more allowance`,
+    } datacap remaining (Glif) / datacap allocated: ${(
+      glifMargin * 100
+    ).toFixed(2)}% - Needs more allowance`,
   );
   const amountToRequest = calculateAmountToRequest(application);
   await requestAllowance(application, owner, repo, amountToRequest);

src/config.ts

@@ -13,4 +13,5 @@ export const config = {
   awsAccessKeyId: process.env.AWS_ACCESS_KEY_ID ?? "",
   awsSecretAccessKey: process.env.AWS_SECRET_ACCESS_KEY ?? "",
   networkType: process.env.NETWORK_TYPE ?? "production",
+  glifApi: process.env.GLIF_API_URL ?? "https://api.node.glif.io/rpc/v0",
 };

src/services/glifService.ts

@@ -0,0 +1,30 @@
+import axios from "axios";
+import { config } from "../config";
+import { logDebug } from "../utils/consoleLogger";
+import { type GetVerifiedClientStatusReturn } from "types";
+
+export const getVerifiedClientStatus = async (
+  clientId: string,
+): Promise<GetVerifiedClientStatusReturn> => {
+  logDebug(`Requesting allocators from backend`);
+  try {
+    const response = await axios.post(config.glifApi, {
+      jsonrpc: "2.0",
+      method: "Filecoin.StateVerifiedClientStatus",
+      params: [clientId, null],
+      id: 0,
+    });
+    return {
+      data: response.data.result,
+      error: "",
+      success: true,
+    };
+  } catch (error) {
+    const errMessage = `Error accessing Glif API Filecoin.StateVerifiedClientStatus: ${error.message}`;
+    return {
+      data: "",
+      error: errMessage,
+      success: false,
+    };
+  }
+};

src/types/types.ts

@@ -227,3 +227,9 @@ export interface CheckApplicationReturn {
   newAllocationNeeded: boolean;
   amount?: string;
 }
+
+export interface GetVerifiedClientStatusReturn {
+  success: boolean;
+  error: string;
+  data: string;
+}