feat(redis): only quit the connection when we own it

Author: RomainLanz

src/drivers/redis_adapter.ts

@@ -123,10 +123,20 @@ const RETRY_JOB_SCRIPT = `
   return 1
 `
 
+/**
+ * Create a new Redis adapter factory.
+ * Accepts either a Redis instance or Redis options.
+ *
+ * When passing options, the adapter will create and manage
+ * the connection lifecycle (closing it on destroy).
+ *
+ * When passing a Redis instance, the caller is responsible for
+ * managing the connection lifecycle.
+ */
 export function redis(config?: RedisConfig) {
   return () => {
     if (config instanceof Redis) {
-      return new RedisAdapter(config)
+      return new RedisAdapter(config, false)
     }
 
     const options: RedisOptions = {
@@ -138,24 +148,28 @@ export function redis(config?: RedisConfig) {
     }
 
     const connection = new Redis(options)
-    return new RedisAdapter(connection)
+    return new RedisAdapter(connection, true)
   }
 }
 
 export class RedisAdapter implements Adapter {
   readonly #connection: Redis
+  readonly #ownsConnection: boolean
   #workerId: string = ''
 
-  constructor(connection: Redis) {
+  constructor(connection: Redis, ownsConnection: boolean = false) {
     this.#connection = connection
+    this.#ownsConnection = ownsConnection
   }
 
   setWorkerId(workerId: string): void {
     this.#workerId = workerId
   }
 
   async destroy(): Promise<void> {
-    await this.#connection.quit()
+    if (this.#ownsConnection) {
+      await this.#connection.quit()
+    }
   }
 
   pop(): Promise<AcquiredJob | null> {