Generate reports for allocators using metaallocator flow

Author: pingwindyktator

src/jobs/allocator-report-generator-job/allocator-report-generator-job.service.ts

@@ -53,14 +53,14 @@ export class AllocatorReportGeneratorJobService extends HealthIndicator {
     for (const [, allocator] of allocators.entries()) {
       try {
         this.logger.debug(
-          `Starting generation of allocator report for ${allocator.address}`,
+          `Starting generation of allocator report for ${allocator.multisig_address}`,
         );
 
-        await this.generateAllocatorReport(allocator.address);
+        await this.generateAllocatorReport(allocator.multisig_address);
       } catch (err) {
         fails++;
         this.logger.error(
-          `Error during generation of allocator report for ${allocator.address}: ${err.message}`,
+          `Error during generation of allocator report for ${allocator.multisig_address}: ${err.message}`,
           err.cause || err.stack,
         );
 

src/service/allocator-report/allocator-report.service.ts

@@ -48,7 +48,7 @@ export class AllocatorReportService {
             0,
           ) / storageProviderDistribution.length,
         clients_number: verifiedClients.data.length,
-        data_types: allocatorInfo?.data_types,
+        data_types: allocatorInfo?.data_types ?? [],
         required_copies: allocatorInfo?.required_replicas,
         required_sps: allocatorInfo?.required_sps,
         clients: {

src/service/allocator-tech/allocator-tech.service.ts

@@ -41,7 +41,9 @@ export class AllocatorTechService {
 
     return data.filter(
       (allocator) =>
-        allocator.address?.startsWith('f') && allocator.address?.length > 3,
+        // assume multisig_address === address for standard allocators
+        allocator.multisig_address?.startsWith('f') &&
+        allocator.multisig_address?.length > 3,
     );
   }
 
@@ -51,7 +53,9 @@ export class AllocatorTechService {
     const allocators = await this.getAllocators();
 
     return allocators.find(
-      (allocator) => allocator.address === allocatorAddress,
+      (allocator) =>
+        allocator.multisig_address === allocatorAddress || // standard allocator
+        allocator.address === allocatorAddress, // metaallocator
     );
   }
 }

src/service/allocator-tech/types.allocator-tech.ts

@@ -16,11 +16,11 @@ export interface AllocatorTechAllocatorResponse {
   owner: string;
   repo: string;
   installation_id: number;
-  multisig_address: string | null;
+  multisig_address: string | null; // equals address for standard allocators
   verifiers_gh_handles: string | null;
   multisig_threshold: number | null;
   allocation_amount_type: any | null;
-  address: string | null;
+  address: string | null; // metaallocator address if different from multisig_address
   tooling: string | null;
   data_types: string[] | null;
   required_sps: string | null;