Log rounds

jobs.ts

@@ -38,16 +38,20 @@ export class JobsObserver {
     this.gateway = gatewayAddress;
   }
 
-  public async check(): Promise<void> {
+  /**
+   * Checks gateway for pending jobs and returns the rounds of those jobs as a list
+   */
+  public async check(): Promise<number[]> {
     const query = { jobs_desc: { offset: null, limit: 3 } };
     const { jobs }: JobsResponse = await this.noisClient.queryContractSmart(this.gateway, query);
-    if (jobs.length === 0) return; // Nothing to do for us
+    if (jobs.length === 0) return []; // Nothing to do for us
 
     const rounds = jobs.map(parseRound);
     const roundInfos = rounds.map((round) => {
       const due = timeOfRound(round) - Date.now();
       return `#${round} (due ${formatDuration(due)})`;
     });
     console.log(`Jobs pending for rounds: %c${roundInfos.join(", ")}`, "color: orange");
+    return rounds;
   }
 }

main.ts

@@ -173,12 +173,26 @@ if (import.meta.main) {
     const shift = 1200;
     setTimeout(() =>
       jobs?.check().then(
-        (_) => {},
+        (rs) => {
+          if (!rs.length) return;
+          console.log(
+            `Past: %o, Future: %o`,
+            rs.filter((r) => r <= n),
+            rs.filter((r) => r > n),
+          );
+        },
         (err) => console.error(err),
       ), shift);
     setTimeout(() =>
       jobs?.check().then(
-        (_) => {},
+        (rs) => {
+          if (!rs.length) return;
+          console.log(
+            `Past: %o, Future: %o`,
+            rs.filter((r) => r <= n),
+            rs.filter((r) => r > n),
+          );
+        },
         (err) => console.error(err),
       ), shift + 1500);