feat(Listener): Add timelimit option

src/base/Listener.ts

@@ -27,16 +27,32 @@ export abstract class Listener extends Executor {
    */
   public readonly timeout: number = 0
 
+  /**
+   * Maximum time that the process will run.
+   */
+  public readonly timelimit: number = 0
+
+  /**
+   * The UNIX timestamp when the listener was `start`ed.
+   */
+  private started = 0
+
   /**
    * The UNIX timestamp of the last call to `dispatch`
    * or `notified`.
    */
   private heartbeat = 0
 
-  public constructor(family = 'li', servers: Server[] = [], timeout = 0) {
+  public constructor(
+    family = 'li',
+    servers: Server[] = [],
+    timeout = 0,
+    timelimit = 0
+  ) {
     super(family)
     this.servers = servers
     this.timeout = timeout
+    this.timelimit = timelimit
   }
 
   /**
@@ -137,14 +153,18 @@ export abstract class Listener extends Executor {
     process.on('SIGINT', stop)
     process.on('SIGTERM', stop)
 
+    this.started = Date.now()
     this.heartbeat = Date.now()
-    if (this.timeout > 0) {
+    if (this.timeout > 0 || this.timelimit > 0) {
       const interval = setInterval((): void => {
-        const duration = (Date.now() - this.heartbeat) / 1000
-        console.log(duration, this.heartbeat, this.timeout)
-        if (duration > this.timeout) {
+        const now = Date.now()
+        const sinceHeartbeat = (now - this.heartbeat) / 1000
+        const sinceStarted = (now - this.started) / 1000
+        if (sinceHeartbeat > this.timeout || sinceStarted > this.timelimit) {
           clearInterval(interval)
-          log.info(`Timed out after ${Math.round(duration)}s`)
+          if (sinceHeartbeat > this.timeout)
+            log.info(`Timed out after ${Math.round(sinceHeartbeat)}s`)
+          else log.info(`Time limit reached after ${Math.round(sinceStarted)}s`)
           stop()
         }
       }, 1000)

src/base/Manager.ts

@@ -22,9 +22,10 @@ export class Manager extends Listener {
     servers: Server[] = [],
     delegator: Delegator = new Delegator([new Worker()]),
     queuer: Queuer = new Queuer(),
-    timeout = 0
+    timeout = 0,
+    timelimit = 0
   ) {
-    super('ma', servers, timeout)
+    super('ma', servers, timeout, timelimit)
     this.delegator = delegator
     this.queuer = queuer
   }

src/cli/init.ts

@@ -68,6 +68,6 @@ export async function init(config: Config): Promise<Listener> {
   // Configure the queue
   const queuer = new Queuer(config)
 
-  const { timeout } = config
-  return new Manager(servers, delegator, queuer, timeout)
+  const { timeout, timelimit } = config
+  return new Manager(servers, delegator, queuer, timeout, timelimit)
 }

src/config.schema.json

@@ -70,8 +70,14 @@
       "default": false
     },
     "timeout": {
-      "description": "Seconds of inactivity after which the process should stop.",
-      "$comment": "Zero means no timeout.",
+      "description": "Duration of inactivity after which the process should stop.",
+      "$comment": "Seconds. Zero means no timeout.",
+      "type": "number",
+      "default": 0
+    },
+    "timelimit": {
+      "description": "Maximum duration for the process.",
+      "$comment": "Seconds. Zero means no time limit.",
       "type": "number",
       "default": 0
     },

src/config.ts

@@ -60,12 +60,19 @@ export class Config {
   ws: boolean | string = false
 
   /**
-   * Seconds of inactivity after which the process should stop.
+   * Duration of inactivity after which the process should stop.
    *
-   * Zero means no timeout.
+   * Seconds. Zero means no timeout.
    */
   timeout = 0
 
+  /**
+   * Maximum duration for the process.
+   *
+   * Seconds. Zero means no time limit.
+   */
+  timelimit = 0
+
   /**
    * List of peer addresses.
    *