feat: check for valid prefix when unpacking

moclojer · Sep 4, 2024 · cfd6b2c · cfd6b2c
1 parent c696ff2
commit cfd6b2c
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/src/com/moclojer/rq/adapters.clj b/src/com/moclojer/rq/adapters.clj
@@ -2,6 +2,7 @@
   (:require
    [clojure.data.json :as json]
    [clojure.edn :as edn]
+   [clojure.string :as str]
    [clojure.tools.logging :as log])
   (:import
    [redis.clients.jedis.args ListPosition]))
@@ -30,7 +31,14 @@
 (defn unpack-pattern
   [pattern queue-name]
   (log/debug :unpacking pattern queue-name)
-  (subs queue-name (count (pattern->str pattern))))
+  (let [prefix (pattern->str pattern)]
+    (if (str/starts-with? queue-name prefix)
+      (subs queue-name (count prefix))
+      (do
+        (log/warn :invalid-prefix
+                  :queue-name queue-name
+                  :expected-prefix prefix)
+        queue-name))))
 
 (def encoding-fns
   {:none identity