From 6c3a7ecd2623fa99187274d6a896f2a12c2a639a Mon Sep 17 00:00:00 2001
From: intpro <boris.dorofeev@gmail.com>
Date: Mon, 18 May 2020 02:32:43 +0600
Subject: [PATCH] feat: Queue.jobs add sorting order

* feat: add queue delete mutation

* fix: clean console.log

* refactor: return promis from deleteQueue

* fix: remove import

* refactor: pipeline for keys del

* feat: add remove bulk mutation

* fix: add unknown state job

* fix: every type

* feat: order for jobs query

* feat: order for jobs query

* fix: no delete by prefix name

Co-authored-by: Boris Dorofeev <bdorofeev@bdorofeev-laptop.corp.ps.kz>
---
 src/helpers/deleteKeys.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/helpers/deleteKeys.ts b/src/helpers/deleteKeys.ts
index 8cb78bd..d382abc 100644
--- a/src/helpers/deleteKeys.ts
+++ b/src/helpers/deleteKeys.ts
@@ -22,7 +22,7 @@ export async function deleteQueue(
 
   const total = await new Promise<number>((resolve, reject) => {
     //redis-cli: scan 0 match fullName* count 300
-    const stream = connection.scanStream({ match: fullName + '*', count: 1000 });
+    const stream = connection.scanStream({ match: fullName + ':*', count: 1000 });
 
     let total = 0;