Merge pull request #83 from connext/schedule-cleanup-client

scheduled cleanup

src/client.ts

@@ -31,6 +31,8 @@ export default class Client {
   private subscriber: Subscriber;
   private connecting = false;
   private logLevel: number;
+  private cleanUpInterval: NodeJS.Timeout | undefined;
+  private cleaningUp = false;
 
   constructor(opts: InitClientManagerOptions) {
     this.subscriber = new Subscriber(opts.logger, opts.store);
@@ -42,6 +44,8 @@ export default class Client {
     rootStoreDir: string,
     opts: InternalConnectOptions,
   ): Promise<IConnextClient> {
+    if (this.cleaningUp) throw new Error(`Client is cleaning up`);
+
     if (this.connecting) {
       throw new Error(`Client is connecting`);
     }
@@ -71,9 +75,25 @@ export default class Client {
       return client;
     } finally {
       this.connecting = false;
+      this.scheduleCleanup();
     }
   }
 
+  public scheduleCleanup(): void {
+    if (typeof this.cleanUpInterval !== "undefined") clearInterval(this.cleanUpInterval);
+    this.cleanUpInterval = setInterval(
+      this.cleanupRegistryApps,
+      86_400_000, // 24 hours
+    );
+  }
+
+  public async cleanupRegistryApps(): Promise<void> {
+    const client = this.getClient();
+    this.cleaningUp = true;
+    await (client as connext.ConnextClient).cleanupRegistryApps();
+    this.cleaningUp = false;
+  }
+
   public getConfig(): RouteMethods.GetConfigResponse {
     const client = this.getClient();
     const config = {
@@ -308,6 +328,7 @@ export default class Client {
     if (!this.client) {
       throw new Error("Client is not initialized");
     }
+    if (this.cleaningUp) throw new Error(`Client is cleanning up`);
     return this.client;
   }
 }