Small fixes

CHANGELOG.md

@@ -5,6 +5,13 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
+## v2.0.2 - 2025-11-XX
+
+### Fixed
+
+- [Admin Service] Correctly return open locks after adding namespace to locks
+- [Admin Service] Publish events improved error handling
+
 ## v2.0.1 - 2025-11-24
 
 ### Fixed

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@cap-js-community/event-queue",
-  "version": "2.0.1",
+  "version": "2.0.2",
   "description": "An event queue that enables secure transactional processing of asynchronous and periodic events, featuring instant event processing with Redis Pub/Sub and load distribution across all application instances.",
   "main": "src/index.js",
   "types": "src/index.d.ts",

src/shared/distributedLock.js

@@ -216,14 +216,15 @@ const getAllLocksRedis = async () => {
   // NOTE: use SCAN because KEYS is not supported for cluster clients
   for (const client of clients) {
     for await (const key of client.scanIterator({ MATCH: "EVENT*", COUNT: 1000 })) {
-      const [, tenant, guidOrType, subType] = key.split("##");
+      const [, namespace, tenant, guidOrType, subType] = key.split("##");
       if (!subType) {
         continue;
       }
 
       const pipeline = client.multi();
       output.push({
-        tenant: tenant,
+        namespace,
+        tenant,
         type: guidOrType,
         subType: subType,
       });