Make sure we have unique keys for queue metadata (#24)

Also rename queue keys to use dot notation

Author: adam-fowler

Sources/JobsRedis/Configuration.swift

@@ -21,15 +21,17 @@ extension RedisJobQueue {
         let queueKey: RedisKey
         let processingQueueKey: RedisKey
         let failedQueueKey: RedisKey
+        let metadataKeyPrefix: String
         let pollTime: Duration
 
         public init(
             queueKey: String = "_hbJobQueue",
             pollTime: Duration = .milliseconds(100)
         ) {
-            self.queueKey = RedisKey(queueKey)
-            self.processingQueueKey = RedisKey("\(queueKey)Processing")
-            self.failedQueueKey = RedisKey("\(queueKey)Failed")
+            self.queueKey = RedisKey("\(queueKey).pending")
+            self.processingQueueKey = RedisKey("\(queueKey).processing")
+            self.failedQueueKey = RedisKey("\(queueKey).failed")
+            self.metadataKeyPrefix = "\(queueKey).metadata"
             self.pollTime = pollTime
         }
     }

Sources/JobsRedis/RedisJobQueue.swift

@@ -221,14 +221,16 @@ public final class RedisJobQueue: JobQueueDriver {
     /// - Parameter key: Metadata key
     /// - Returns: Associated ByteBuffer
     public func getMetadata(_ key: String) async throws -> ByteBuffer? {
-        try await self.redisConnectionPool.wrappedValue.get(.init(key)).get().byteBuffer
+        let key = "\(self.configuration.metadataKeyPrefix).\(key)"
+        return try await self.redisConnectionPool.wrappedValue.get(.init(key)).get().byteBuffer
     }
 
     /// Set job queue metadata
     /// - Parameters:
     ///   - key: Metadata key
     ///   - value: Associated ByteBuffer
     public func setMetadata(key: String, value: ByteBuffer) async throws {
+        let key = "\(self.configuration.metadataKeyPrefix).\(key)"
         try await self.redisConnectionPool.wrappedValue.set(.init(key), to: value).get()
     }