Merge pull request #317 from blockfrost/chore/session-timeout

chore: configurable idle_session_timeout

Author: slowbackspace

CHANGELOG.md

@@ -7,6 +7,16 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [6.3.4] - 2026-03-17
+
+### Added
+
+- Configurable `idle_session_timeout` for dbsync connections. Set via `dbSync.idleSessionTimeoutMs` in config or `BLOCKFROST_CONFIG_DBSYNC_IDLE_SESSION_TIMEOUT_MS` env var (value in milliseconds). Cleans up zombie connections from restarted PM2 instances. Disabled by default
+
+### Fixed
+
+- Fixed connection leak in `/governance/proposals/:gov_action_id/metadata` where the DB connection was not released on validation failure
+
 ## [6.3.3] - 2026-03-13
 
 ### Fixed

package.json

@@ -1,6 +1,6 @@
 {
   "name": "blockfrost-backend-ryo",
-  "version": "6.3.3",
+  "version": "6.3.4",
   "description": "",
   "keywords": [],
   "license": "Apache-2.0",

src/app.ts

@@ -118,6 +118,9 @@ const start = (options = {}): FastifyInstance => {
     application_name: config.dbSync.applicationName,
     statement_timeout: config.dbSync.statementTimeout,
     connectionTimeoutMillis: config.dbSync.connectionTimeoutMs,
+    ...(config.dbSync.idleSessionTimeoutMs !== undefined && {
+      options: `-c idle_session_timeout=${config.dbSync.idleSessionTimeoutMs}`,
+    }),
   });
 
   // proxies

src/config.ts

@@ -83,6 +83,12 @@ export const loadConfig = () => {
     : config.has('dbSync.connectionTimeoutMs')
       ? config.get<number>('dbSync.connectionTimeoutMs')
       : undefined;
+  const databaseSyncIdleSessionTimeoutMs = process.env
+    .BLOCKFROST_CONFIG_DBSYNC_IDLE_SESSION_TIMEOUT_MS
+    ? Number(process.env.BLOCKFROST_CONFIG_DBSYNC_IDLE_SESSION_TIMEOUT_MS)
+    : config.has('dbSync.idleSessionTimeoutMs')
+      ? config.get<number>('dbSync.idleSessionTimeoutMs')
+      : undefined;
   const ssl = config.has('dbSync.ssl') ? { rejectUnauthorized: false } : false;
   const databaseSyncApplicationName =
     process.env.BLOCKFROST_CONFIG_APPLICATION_NAME ??
@@ -168,6 +174,7 @@ export const loadConfig = () => {
       maxConnections: databaseSyncMaxConnections,
       statementTimeout: databaseSyncStatementTimeout,
       connectionTimeoutMs: databaseSyncConnectionTimeoutMs,
+      idleSessionTimeoutMs: databaseSyncIdleSessionTimeoutMs,
       ssl,
       applicationName: databaseSyncApplicationName,
     },

src/routes/governance/proposals/gov-action-id/metadata.ts

@@ -13,8 +13,6 @@ async function route(fastify: FastifyInstance) {
     method: 'GET',
     schema: getSchemaForEndpoint('/governance/proposals/{gov_action_id}/metadata'),
     handler: async (request: FastifyRequest<QueryTypes.RequestParametersGovAction>, reply) => {
-      const clientDbSync = await getDbSync(fastify);
-
       let parsedGovAction;
 
       try {
@@ -23,6 +21,8 @@ async function route(fastify: FastifyInstance) {
         return handle400Custom(reply, 'Invalid or malformed gov action id.');
       }
 
+      const clientDbSync = await getDbSync(fastify);
+
       try {
         const { rows } = await clientDbSync.query<QueryTypes.ProposalsProposalMetadata>(
           SQLQuery.get('governance_proposals_proposal_metadata_v2'),