fix: fix #1044 support for typescript processors

OptimalBits · Jan 20, 2019 · 5c1376d · 5c1376d
1 parent f12d7ad
commit 5c1376d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/queue.js b/lib/queue.js
@@ -663,8 +663,10 @@ Queue.prototype.setHandler = function(name, handler) {
   this.setWorkerName();
 
   if (typeof handler === 'string') {
+    const supportedFileTypes = ['js', 'ts', 'flow'];
     const processorFile =
-      handler + (path.extname(handler) === '.js' ? '' : '.js');
+      handler +
+      (supportedFileTypes.indexOf(path.extname(handler)) !== '-1' ? '' : '.js');
 
     if (!fs.existsSync(processorFile)) {
       throw new Error('File ' + processorFile + ' does not exist');