feat: migrate unique (#128)

1 files changed, 50 insertions, 0 deletions

diff --git a/src/unique.ts b/src/unique.ts
new file mode 100644
index 00000000..c077ea58
--- /dev/null
+++ b/src/unique.ts
@@ -0,0 +1,50 @@
+const uniqueExec = require('../vendor/unique');
+
+export class Unique {
+  // maximum time unique.exec will attempt to run before aborting
+  maxTime: number = 10;
+
+  // maximum retries unique.exec will recurse before aborting ( max loop depth )
+  maxRetries: number = 10;
+
+  // time the script started
+  // startTime: number = 0;
+
+  constructor() {
+    // Bind `this` so namespaced is working correctly
+    for (const name of Object.getOwnPropertyNames(Unique.prototype)) {
+      if (name === 'constructor' || typeof this[name] !== 'function') {
+        continue;
+      }
+      this[name] = this[name].bind(this);
+    }
+  }
+
+  /**
+   * unique
+   *
+   * @method unique
+   */
+  unique(
+    method: any,
+    args: any,
+    opts?: {
+      startTime?: number;
+      maxTime?: number;
+      maxRetries?: number;
+      currentIterations?: number;
+      [key: string]: any;
+    }
+  ): any {
+    opts ||= {};
+    opts.startTime = new Date().getTime();
+    if (typeof opts.maxTime !== 'number') {
+      opts.maxTime = this.maxTime;
+    }
+    if (typeof opts.maxRetries !== 'number') {
+      opts.maxRetries = this.maxRetries;
+    }
+    opts.currentIterations = 0;
+    return uniqueExec.exec(method, args, opts);
+  }
+}