feat: zero hf accounts logic

Author: doomsower

package.json

@@ -40,6 +40,7 @@
     "axios-retry": "^4.5.0",
     "date-fns": "^4.1.0",
     "di-at-home": "^0.0.7",
+    "es-toolkit": "^1.39.10",
     "esbuild": "^0.25.9",
     "husky": "^9.1.7",
     "lint-staged": "^16.1.6",

src/services/Scanner.ts

@@ -8,6 +8,7 @@ import type {
 } from "@gearbox-protocol/sdk";
 import {
   AbstractCreditAccountService,
+  AddressSet,
   hexEq,
   MAX_UINT256,
   PERCENTAGE_FACTOR,
@@ -19,13 +20,15 @@ import {
   iCreditManagerV3Abi,
   iPartialLiquidationBotV3Abi,
 } from "@gearbox-protocol/types/abi";
+import { throttle } from "es-toolkit";
 import type { Address, Block, HttpTransportConfig, PublicClient } from "viem";
 import { createPublicClient, getContract, http } from "viem";
 import type { Config } from "../config/index.js";
 import { DI } from "../di.js";
 import { type ILogger, Logger } from "../log/index.js";
 import type Client from "./Client.js";
 import type { ILiquidatorService } from "./liquidate/index.js";
+import type { INotifier } from "./notifier/index.js";
 
 const RESTAKING_CMS: Partial<Record<NetworkType, Address>> = {
   Mainnet:
@@ -51,6 +54,9 @@ export class Scanner {
   @DI.Inject(DI.CreditAccountService)
   caService!: ICreditAccountsService;
 
+  @DI.Inject(DI.Notifier)
+  notifier!: INotifier;
+
   #processing: bigint | null = null;
   #restakingCMAddr?: Address;
   #restakingMinHF?: bigint;
@@ -59,6 +65,14 @@ export class Scanner {
   #minHealthFactor = 0n;
   #unwatch?: () => void;
 
+  constructor() {
+    this.#notifyOnZeroHFAccounts = throttle(
+      this.#notifyOnZeroHFAccounts,
+      1000 * 60 * 5,
+      { edges: ["leading"] },
+    );
+  }
+
   public async launch(): Promise<void> {
     await this.liquidatorService.launch();
     if (this.config.restakingWorkaround) {
@@ -161,7 +175,7 @@ export class Scanner {
           this.config.liquidationMode !== "deleverage" &&
           !this.config.updateReservePrices,
       };
-      accounts = await this.caService.getCreditAccounts(queue, blockNumber);
+      accounts = await this.#getAllCreditAccounts(queue, blockNumber);
     }
     if (this.config.restakingWorkaround) {
       const before = accounts.length;
@@ -214,6 +228,46 @@ export class Scanner {
     }
   }
 
+  async #getAllCreditAccounts(
+    queue: GetCreditAccountsOptions,
+    blockNumber?: bigint,
+  ): Promise<CreditAccountData[]> {
+    let accounts = await this.caService.getCreditAccounts(queue, blockNumber);
+    let zeroHFAccs = accounts.filter(ca => ca.healthFactor === 0n);
+
+    if (zeroHFAccs.length > 0) {
+      this.log.warn(
+        `found ${zeroHFAccs.length} accounts with HF=0 on first attempt, retrying`,
+      );
+      accounts = await this.caService.getCreditAccounts(queue, blockNumber);
+      zeroHFAccs = accounts.filter(ca => ca.healthFactor === 0n);
+
+      if (zeroHFAccs.length > 0) {
+        this.log.warn(
+          `found ${zeroHFAccs.length} accounts with HF=0 on second attempt, skipping them`,
+        );
+        accounts = accounts.filter(ca => ca.healthFactor !== 0n);
+
+        const badTokens = new AddressSet();
+        for (const ca of zeroHFAccs) {
+          for (const token of ca.tokens) {
+            if (!token.success) {
+              badTokens.add(token.token);
+            }
+          }
+        }
+        const badTokensStr = badTokens
+          .asArray()
+          .map(t => this.caService.sdk.tokensMeta.get(t)?.symbol)
+          .join(", ");
+        this.log.warn(`bad tokens: ${badTokensStr}`);
+        this.#notifyOnZeroHFAccounts(zeroHFAccs.length, badTokensStr);
+      }
+    }
+
+    return accounts;
+  }
+
   async #setupRestakingWorkaround(): Promise<void> {
     this.#restakingCMAddr = RESTAKING_CMS[this.config.network];
 
@@ -350,6 +404,13 @@ export class Scanner {
     return result;
   }
 
+  #notifyOnZeroHFAccounts = (count: number, badTokens: string): void => {
+    this.notifier.alert({
+      plain: `found ${count} accounts with HF=0, bad tokens: ${badTokens}`,
+      markdown: `found ${count} accounts with HF=0, bad tokens: ${badTokens}`,
+    });
+  };
+
   public get lastUpdated(): bigint {
     return this.#lastUpdated;
   }

src/services/liquidate/AbstractLiquidator.ts

@@ -10,11 +10,7 @@ import { ierc20MetadataAbi } from "@gearbox-protocol/types/abi";
 import type { OptimisticResult } from "@gearbox-protocol/types/optimist";
 import type { Address, TransactionReceipt } from "viem";
 
-import type {
-  CommonSchema,
-  Config,
-  LiqduiatorConfig,
-} from "../../config/index.js";
+import type { CommonSchema, LiqduiatorConfig } from "../../config/index.js";
 import { DI } from "../../di.js";
 import { ErrorHandler } from "../../errors/index.js";
 import type { ILogger } from "../../log/index.js";

yarn.lock

@@ -1789,6 +1789,7 @@ __metadata:
     axios-retry: "npm:^4.5.0"
     date-fns: "npm:^4.1.0"
     di-at-home: "npm:^0.0.7"
+    es-toolkit: "npm:^1.39.10"
     esbuild: "npm:^0.25.9"
     husky: "npm:^9.1.7"
     lint-staged: "npm:^16.1.6"
@@ -3865,6 +3866,18 @@ __metadata:
   languageName: node
   linkType: hard
 
+"es-toolkit@npm:^1.39.10":
+  version: 1.39.10
+  resolution: "es-toolkit@npm:1.39.10"
+  dependenciesMeta:
+    "@trivago/prettier-plugin-sort-imports@4.3.0":
+      unplugged: true
+    prettier-plugin-sort-re-exports@0.0.1:
+      unplugged: true
+  checksum: 10c0/244dd6be25bc8c7af9f085f5b9aae08169eca760fc7d4735020f8f711b6a572e0bf205400326fa85a7924e20747d315756dba1b3a5f0d2887231374ec3651a98
+  languageName: node
+  linkType: hard
+
 "esbuild@npm:^0.25.0, esbuild@npm:^0.25.9, esbuild@npm:~0.25.0":
   version: 0.25.9
   resolution: "esbuild@npm:0.25.9"