@nerimity/mimiqueue - npm Package Compare versions

Comparing version 1.0.3 to 1.1.0

package.json

 {
   "name": "@nerimity/mimiqueue",
-  "version": "1.0.3",
+  "version": "1.1.0",
   "description": "NodeJS group queuing library. Requires Redis.",
@@ -5,0 +5,0 @@ "main": "dist/index.mjs",

readme.md

@@ -45,1 +45,34 @@ # Mimiqueue
 ```
+
+## Alt Usage
+
+```ts
+import { createClient } from "redis";
+import { AltQueue } from "@nerimity/mimiqueue";
+import { setTimeout } from "timers/promises";
+
+const redisClient = createClient({
+  socket: {
+    host: "127.0.0.1",
+    port: 6379,
+  },
+});
+
+await redisClient.connect();
+await redisClient.flushAll();
+
+const queue = new AltQueue({
+  redisClient,
+  name: "addFriend",
+});
+
+async function doSomething(groupName) {
+  const done = await queue.start({ groupName });
+  console.log("doing something");
+  await setTimeout(1000);
+  done();
+}
+
+doSomething("123");
+doSomething("123");
+```

src/index.ts

 export * from "./Queue";
+export * from "./AltQueue";

src/Queue.ts

@@ -140,18 +140,2 @@ import { createClient } from "redis";
 
-function waitJobCount(queue: Queue, id: number, groupName?: string) {
-  let key = `${queue.prefix}:${queue.name}`;
-  if (groupName) key += `:${groupName}`;
-  key += ":wait";
-
-  return queue.redisClient.lLen(key);
-}
-
-function activeJobCount(queue: Queue, groupName?: string) {
-  let key = `${queue.prefix}:${queue.name}`;
-  if (groupName) key += `:${groupName}`;
-  key += ":active";
-
-  return queue.redisClient.lLen(key);
-}
-
 function addJobToActive(queue: Queue, id: number | string, groupName?: string) {
@@ -162,3 +146,3 @@ let key = `${queue.prefix}:${queue.name}`;
 
-  return queue.redisClient.rPush(key, id.toString());
+  return queue.redisClient.set(key, id.toString());
 }
@@ -171,3 +155,3 @@
   const multi = queue.redisClient.multi();
-  multi.lLen(`${key}:active`);
+  multi.get(`${key}:active`);
   multi.lLen(`${key}:wait`);
@@ -177,3 +161,3 @@
 
-  return active + wait;
+  return (active ? 1 : 0) + wait;
 }
@@ -197,3 +181,3 @@
 
-  multi.lRem(key1, 1, id.toString());
+  multi.del(key1);
   multi.del(key2);
@@ -200,0 +184,0 @@

No alert changes

Improved metrics

Total package byte prevSize

44227

increased by77.78%

Number of package files

14

increased by16.67%

Lines of code

495

increased by68.94%

Number of lines in readme file

78

increased by73.33%

No dependency changes