v2.13.10: Add unref() to all timers to not prevent Node script from exiting in its end

Author: dimikot

.gitignore

@@ -4,6 +4,7 @@ dist
 node_modules
 package-lock.json
 yarn.lock
+pnpm-lock.yaml
 .DS_Store
 *.log
 *.tmp

.npmignore

@@ -1,3 +1,5 @@
+pg-id-consts.sql
+
 dist/__tests__
 dist/**/__tests__
 dist/*.tsbuildinfo
@@ -7,6 +9,7 @@ dist/*.tsbuildinfo
 node_modules
 package-lock.json
 yarn.lock
+pnpm-lock.yaml
 .DS_Store
 *.log
 *.tmp

docs/classes/Cluster.md

@@ -57,7 +57,7 @@ queries (also, no implicit prewarming).
 
 > **prewarm**(`randomizedDelayMs`, `onInitialPrewarm`?): `void`
 
-Defined in: [src/abstract/Cluster.ts:230](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L230)
+Defined in: [src/abstract/Cluster.ts:234](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L234)
 
 Signals the Cluster to keep the Clients pre-warmed, e.g. open. (It's up to
 the particular Client's implementation, what does a "pre-warmed Client"
@@ -87,7 +87,7 @@ pgbouncer or when DB is accessed over SSL).
 
 > **globalShard**(): [`Shard`](Shard.md)\<`TClient`\>
 
-Defined in: [src/abstract/Cluster.ts:261](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L261)
+Defined in: [src/abstract/Cluster.ts:265](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L265)
 
 Returns a global Shard of the Cluster. This method is made synchronous
 intentionally, to defer the I/O and possible errors to the moment of the
@@ -103,7 +103,7 @@ actual query.
 
 > **nonGlobalShards**(): `Promise`\<readonly [`Shard`](Shard.md)\<`TClient`\>[]\>
 
-Defined in: [src/abstract/Cluster.ts:268](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L268)
+Defined in: [src/abstract/Cluster.ts:272](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L272)
 
 Returns all currently known (discovered) non-global Shards in the Cluster.
 
@@ -117,7 +117,7 @@ Returns all currently known (discovered) non-global Shards in the Cluster.
 
 > **shard**(`id`): [`Shard`](Shard.md)\<`TClient`\>
 
-Defined in: [src/abstract/Cluster.ts:288](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L288)
+Defined in: [src/abstract/Cluster.ts:292](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L292)
 
 Returns Shard of a particular id. This method is made synchronous
 intentionally, to defer the I/O and possible errors to the moment of the
@@ -149,7 +149,7 @@ the query), no matter whether it was an immediate call or a deferred one.
 
 > **shardByNo**(`shardNo`): [`Shard`](Shard.md)\<`TClient`\>
 
-Defined in: [src/abstract/Cluster.ts:301](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L301)
+Defined in: [src/abstract/Cluster.ts:305](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L305)
 
 Returns a Shard if we know its number. The idea: for each Shard number
 (even for non-discovered yet Shards), we keep the corresponding Shard
@@ -174,7 +174,7 @@ Shard hasn't been discovered actually).
 
 > **randomShard**(`seed`?): `Promise`\<[`Shard`](Shard.md)\<`TClient`\>\>
 
-Defined in: [src/abstract/Cluster.ts:311](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L311)
+Defined in: [src/abstract/Cluster.ts:315](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L315)
 
 Returns a random Shard among the ones which are currently known
 (discovered) in the Cluster.
@@ -195,7 +195,7 @@ Returns a random Shard among the ones which are currently known
 
 > **island**(`islandNo`): `Promise`\<[`Island`](Island.md)\<`TClient`\>\>
 
-Defined in: [src/abstract/Cluster.ts:335](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L335)
+Defined in: [src/abstract/Cluster.ts:339](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L339)
 
 Returns an Island by its number.
 
@@ -215,7 +215,7 @@ Returns an Island by its number.
 
 > **islands**(): `Promise`\<[`Island`](Island.md)\<`TClient`\>[]\>
 
-Defined in: [src/abstract/Cluster.ts:346](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L346)
+Defined in: [src/abstract/Cluster.ts:350](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L350)
 
 Returns all Islands in the Cluster.
 
@@ -229,7 +229,7 @@ Returns all Islands in the Cluster.
 
 > **rediscover**(): `Promise`\<`void`\>
 
-Defined in: [src/abstract/Cluster.ts:356](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L356)
+Defined in: [src/abstract/Cluster.ts:360](https://github.com/clickup/ent-framework/blob/master/src/abstract/Cluster.ts#L360)
 
 Triggers shards rediscovery and finishes as soon as it's done. To be used
 in unit tests mostly, because in real life, it's enough to just modify the

docs/classes/PgClientPool.md

@@ -279,7 +279,7 @@ until e.g. the next discovery query to it (or any query) succeeds.
 
 > **acquireConn**(): `Promise`\<[`PgClientConn`](../interfaces/PgClientConn.md)\>
 
-Defined in: [src/pg/PgClientPool.ts:114](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L114)
+Defined in: [src/pg/PgClientPool.ts:117](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L117)
 
 Called when the Client needs a connection to run a query against. Implies
 than the caller MUST call release() method on the returned object.
@@ -298,7 +298,7 @@ than the caller MUST call release() method on the returned object.
 
 > **poolStats**(): `object`
 
-Defined in: [src/pg/PgClientPool.ts:127](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L127)
+Defined in: [src/pg/PgClientPool.ts:130](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L130)
 
 Returns statistics about the connection pool.
 
@@ -335,7 +335,7 @@ new available connection. This is the number of such queued requests.
 
 > **address**(): `string`
 
-Defined in: [src/pg/PgClientPool.ts:135](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L135)
+Defined in: [src/pg/PgClientPool.ts:138](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L138)
 
 Represents the full destination address this Client is working with.
 Depending on the implementation, it may include hostname, port number,
@@ -357,7 +357,7 @@ shardNos) based on that address.
 
 > **logSwallowedError**(`props`): `void`
 
-Defined in: [src/pg/PgClientPool.ts:146](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L146)
+Defined in: [src/pg/PgClientPool.ts:149](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L149)
 
 Calls swallowedErrorLogger() doing some preliminary amendment.
 
@@ -381,7 +381,7 @@ Calls swallowedErrorLogger() doing some preliminary amendment.
 
 > **end**(): `Promise`\<`void`\>
 
-Defined in: [src/pg/PgClientPool.ts:152](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L152)
+Defined in: [src/pg/PgClientPool.ts:155](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L155)
 
 Gracefully closes the connections to let the caller destroy the Client. The
 pending queries are awaited to finish before returning. The Client becomes
@@ -401,7 +401,7 @@ unusable after calling this method: you should not send queries to it.
 
 > **isEnded**(): `boolean`
 
-Defined in: [src/pg/PgClientPool.ts:163](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L163)
+Defined in: [src/pg/PgClientPool.ts:166](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L166)
 
 Returns true if the Client is ended and can't be used anymore.
 
@@ -419,7 +419,7 @@ Returns true if the Client is ended and can't be used anymore.
 
 > **prewarm**(): `void`
 
-Defined in: [src/pg/PgClientPool.ts:167](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L167)
+Defined in: [src/pg/PgClientPool.ts:170](https://github.com/clickup/ent-framework/blob/master/src/pg/PgClientPool.ts#L170)
 
 A convenience method to put connections prewarming logic to. The idea is to
 keep the needed number of open connections and also, in each connection,

docs/classes/ShardIsNotDiscoverableError.md

@@ -6,7 +6,7 @@
 
 # Class: ShardIsNotDiscoverableError
 
-Defined in: src/abstract/ShardIsNotDiscoverableError.ts:10
+Defined in: [src/abstract/ShardIsNotDiscoverableError.ts:10](https://github.com/clickup/ent-framework/blob/master/src/abstract/ShardIsNotDiscoverableError.ts#L10)
 
 This non-retriable error is thrown when shardsDiscoverCache.cached() returns
 no shard with the requested number.
@@ -21,7 +21,7 @@ no shard with the requested number.
 
 > **new ShardIsNotDiscoverableError**(`shardNo`, `errors`, `islands`, `elapsed`): [`ShardIsNotDiscoverableError`](ShardIsNotDiscoverableError.md)
 
-Defined in: src/abstract/ShardIsNotDiscoverableError.ts:11
+Defined in: [src/abstract/ShardIsNotDiscoverableError.ts:11](https://github.com/clickup/ent-framework/blob/master/src/abstract/ShardIsNotDiscoverableError.ts#L11)
 
 #### Parameters
 

internal/clean.sh

@@ -1,4 +1,4 @@
 #!/bin/bash
 set -e
 
-rm -rf dist dist.* yarn.lock package-lock.json node_modules ./*.log
+rm -rf dist dist.* yarn.lock package-lock.json pnpm-lock.yaml node_modules ./*.log

internal/init-db.sh

@@ -16,7 +16,7 @@ done
 dir="$dir/$REL"
 
 if [[ ! -e $dir/pg-id-consts.sql ]]; then
-  ln -s "$dir/pg-id-consts.sql.example" "$dir/pg-id-consts.sql"
+  ln -s "$dir/pg-id.config.sql.example" "$dir/pg-id.config.sql"
 fi
 
 rm -f $LOG

internal/with-docker-compose-up.postgres.sh

@@ -17,4 +17,8 @@ export PGPASSWORD=postgres
 # properly quoted arguments to it.
 cmd="$1"
 shift
-eval "$cmd \"\$@\""
+if [[ "$*" == "" ]]; then
+  eval "$cmd"
+else
+  eval "$cmd \"\$@\""
+fi

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@clickup/ent-framework",
   "description": "A PostgreSQL graph-database-alike library with microsharding and row-level security",
-  "version": "2.13.9",
+  "version": "2.13.10",
   "license": "MIT",
   "keywords": [
     "postgresql",
@@ -46,12 +46,12 @@
     "table": "^6.8.0"
   },
   "devDependencies": {
-    "@clickup/pg-id": "^2.10.292",
+    "@clickup/pg-id": "2.12.2",
     "@types/jest": "^29.5.5",
     "@types/lodash": "^4.14.175",
     "@types/node": "^20.4.1",
     "@types/object-hash": "^2.2.1",
-    "@types/pg": "^8.6.1",
+    "@types/pg": "^8.11.11",
     "@types/uniqid": "^4.1.3",
     "@typescript-eslint/eslint-plugin": "^5.59.6",
     "@typescript-eslint/parser": "^5.59.6",