refactor: remove all disconnect features

Author: Julien-R44

docs/content/docs/api.md

@@ -156,14 +156,6 @@ const lock1 = verrou.createLock('key', 'owner')
 const lock2 = verrou.restoreLock(lock1.serialize())
 ```
 
-### `disconnect`
-
-Disconnect from the store if applicable. With a Redis Store, it will close the `ioredis` connection.
-
-```ts
-await verrou.disconnect()
-```
-
 ## Verrou API
 
 Verrou API is a wrapper around the LockFactory API. 
@@ -200,11 +192,3 @@ As explained above, the `use` method allows you to use a different store than th
 verrou.use('myMemoryStore').createLock('key')
 ```
 
-### `disconnectAll`
-
-Disconnect from all stores.
-
-```ts
-await verrou.disconnectAll()
-```
-

docs/content/docs/extend/custom_lock_store.md

@@ -12,7 +12,6 @@ interface LockStore {
   delete(key: string, owner: string): Promise<void>
   exists(key: string): Promise<boolean>
   extend(key: string, owner: string, duration: number): Promise<void>
-  disconnect(): Promise<void>
 }
 ```
 

packages/verrou/src/drivers/database.ts

@@ -105,6 +105,4 @@ export class DatabaseStore {
 
     return lock.expiration > Date.now()
   }
-
-  async disconnect() {}
 }

packages/verrou/src/drivers/dynamodb.ts

@@ -166,11 +166,4 @@ export class DynamoDBStore implements LockStore {
       throw new E_LOCK_NOT_OWNED()
     }
   }
-
-  /**
-   * Disconnect from DynamoDB
-   */
-  async disconnect() {
-    this.#client.destroy()
-  }
 }

packages/verrou/src/drivers/memory.ts

@@ -109,8 +109,4 @@ export class MemoryStore implements LockStore {
 
     return lock.mutex.isLocked()
   }
-
-  async disconnect() {
-    // noop
-  }
 }

packages/verrou/src/drivers/redis.ts

@@ -85,11 +85,4 @@ export class RedisStore implements LockStore {
     const result = await this.#connection.eval(lua, 1, key, owner, duration)
     if (result === 0) throw new E_LOCK_NOT_OWNED()
   }
-
-  /**
-   * Disconnect from Redis
-   */
-  async disconnect() {
-    await this.#connection.quit()
-  }
 }

packages/verrou/src/lock_factory.ts

@@ -60,11 +60,4 @@ export class LockFactory {
   restoreLock(lock: SerializedLock) {
     return new Lock(lock.key, this.#store, this.#config, lock.owner, lock.ttl, lock.expirationTime)
   }
-
-  /**
-   * Disconnect the store ( if applicable )
-   */
-  disconnect() {
-    return this.#store.disconnect()
-  }
 }

packages/verrou/src/types/main.ts

@@ -110,9 +110,4 @@ export interface LockStore {
    * Duration is in milliseconds
    */
   extend(key: string, owner: string, duration: number): Promise<void>
-
-  /**
-   * Disconnect the store from the underlying storage ( when applicable )
-   */
-  disconnect(): Promise<void>
 }

packages/verrou/src/verrou.ts

@@ -70,24 +70,4 @@ export class Verrou<KnownStores extends Record<string, StoreFactory>> {
   restoreLock(lock: SerializedLock) {
     return this.use(this.#defaultStoreName).restoreLock(lock)
   }
-
-  /**
-   * Disconnect the default store
-   */
-  async disconnect() {
-    await this.use(this.#defaultStoreName).disconnect()
-  }
-
-  /**
-   * Disconnect all connections to the stores
-   */
-  async disconnectAll() {
-    const promises = []
-
-    for (const store of this.#storesCache.values()) {
-      promises.push(store.disconnect())
-    }
-
-    await Promise.allSettled(promises)
-  }
 }

packages/verrou/test_helpers/null_store.ts

@@ -24,8 +24,4 @@ export class NullStore implements LockStore {
   async extend(_key: string, _owner: string, _duration: number): Promise<void> {
     return
   }
-
-  async disconnect() {
-    return
-  }
 }