ustaxcourt · Mwindo · Jul 10, 2025 · Jul 10, 2025 · Jul 11, 2025 · Jul 11, 2025
diff --git a/cypress/helpers/cypressTasks/postgres/getCypressPostgresDb.ts b/cypress/helpers/cypressTasks/postgres/getCypressPostgresDb.ts
@@ -1,5 +1,5 @@
 import { Signer } from '@aws-sdk/rds-signer';
-import type { Database } from '@web-api/database-schema';
+import type { Database } from '@web-api/persistence/postgres/database-schema';
 import { getCypressEnv } from 'cypress/helpers/env/cypressEnvironment';
 import fs from 'fs';
 import { CamelCasePlugin, Kysely, PostgresDialect } from 'kysely';

diff --git a/scripts/archived/run-once/cleanup-corrupt-messages.ts b/scripts/archived/run-once/cleanup-corrupt-messages.ts
@@ -13,7 +13,7 @@ import { queryFull } from '@web-api/persistence/dynamodbClientService';
 import PQueue from 'p-queue';
 import fs from 'fs';
 import path from 'path';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 
 const scriptConfig: ScriptConfig = {
   description:

diff --git a/scripts/reindex/index-cases/_index-cases-child.ts b/scripts/reindex/index-cases/_index-cases-child.ts
@@ -4,7 +4,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import {
   OPENSEARCH_SYNC_ACTIONS,

diff --git a/scripts/reindex/index-cases/index-cases.ts b/scripts/reindex/index-cases/index-cases.ts
@@ -5,7 +5,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { spawn } from 'child_process';
 import { CompiledQuery } from 'kysely';
 

diff --git a/scripts/reindex/index-docket-entries/_index-docket-entries-child.ts b/scripts/reindex/index-docket-entries/_index-docket-entries-child.ts
@@ -4,7 +4,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import {
   OPENSEARCH_SYNC_ACTIONS,

diff --git a/scripts/reindex/index-docket-entries/index-docket-entries.ts b/scripts/reindex/index-docket-entries/index-docket-entries.ts
@@ -5,7 +5,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { spawn } from 'child_process';
 import { CompiledQuery } from 'kysely';
 

diff --git a/...once-scripts/postgres-migration/delete-all-docket-entries/_delete-docket-entries-child.ts b/...once-scripts/postgres-migration/delete-all-docket-entries/_delete-docket-entries-child.ts
@@ -4,7 +4,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import { calculateDate } from '@shared/business/utilities/DateHandler';
 import { batchDeleteDynamoItems } from 'scripts/run-once-scripts/postgres-migration/batch-delete-dynamo-items';

diff --git a/...ts/run-once-scripts/postgres-migration/delete-all-docket-entries/delete-docket-entries.ts b/...ts/run-once-scripts/postgres-migration/delete-all-docket-entries/delete-docket-entries.ts
@@ -5,7 +5,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { spawn } from 'child_process';
 import { CompiledQuery } from 'kysely';
 

diff --git a/scripts/run-once-scripts/postgres-migration/delete-case-correspondences.ts b/scripts/run-once-scripts/postgres-migration/delete-case-correspondences.ts
@@ -6,7 +6,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import { batchDeleteDynamoItems } from './batch-delete-dynamo-items';
 import { environment } from '@web-api/environment';

diff --git a/scripts/run-once-scripts/postgres-migration/delete-case-deadlines.ts b/scripts/run-once-scripts/postgres-migration/delete-case-deadlines.ts
@@ -6,7 +6,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import { batchDeleteDynamoItems } from './batch-delete-dynamo-items';
 import { environment } from '@web-api/environment';

diff --git a/scripts/run-once-scripts/postgres-migration/delete-case-notes.ts b/scripts/run-once-scripts/postgres-migration/delete-case-notes.ts
@@ -8,7 +8,7 @@ import {
 } from '../../helpers/parseArgsAndEnvVars';
 import { batchDeleteDynamoItems } from './batch-delete-dynamo-items';
 import { environment } from '@web-api/environment';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 
 const scriptConfig: ScriptConfig = {

diff --git a/scripts/run-once-scripts/postgres-migration/delete-case-worksheets.ts b/scripts/run-once-scripts/postgres-migration/delete-case-worksheets.ts
@@ -6,7 +6,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import { batchDeleteDynamoItems } from './batch-delete-dynamo-items';
 import { environment } from '@web-api/environment';

diff --git a/scripts/run-once-scripts/postgres-migration/delete-cases.ts b/scripts/run-once-scripts/postgres-migration/delete-cases.ts
@@ -6,7 +6,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import { batchDeleteDynamoItems } from './batch-delete-dynamo-items';
 import { environment } from '@web-api/environment';

diff --git a/scripts/run-once-scripts/postgres-migration/delete-docket-entry-worksheets.ts b/scripts/run-once-scripts/postgres-migration/delete-docket-entry-worksheets.ts
@@ -6,7 +6,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import { batchDeleteDynamoItems } from './batch-delete-dynamo-items';
 import { environment } from '@web-api/environment';

diff --git a/scripts/run-once-scripts/postgres-migration/delete-work-items.ts b/scripts/run-once-scripts/postgres-migration/delete-work-items.ts
@@ -6,7 +6,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import { batchDeleteDynamoItems } from './batch-delete-dynamo-items';
 import { environment } from '@web-api/environment';

diff --git a/scripts/run-once-scripts/postgres-migration/index-docket-entries.ts b/scripts/run-once-scripts/postgres-migration/index-docket-entries.ts
@@ -5,7 +5,7 @@ import {
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
 import { environment } from '@web-api/environment';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import {
   OPENSEARCH_SYNC_ACTIONS,

diff --git a/scripts/run-once-scripts/postgres-migration/migrate-petitioners-data-to-jsonb.ts b/scripts/run-once-scripts/postgres-migration/migrate-petitioners-data-to-jsonb.ts
@@ -4,7 +4,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import { environment } from '@web-api/environment';
 import { CompiledQuery } from 'kysely';

diff --git a/scripts/run-once-scripts/postgres-migration/migrate-status-history-data-to-jsonb.ts b/scripts/run-once-scripts/postgres-migration/migrate-status-history-data-to-jsonb.ts
@@ -4,7 +4,7 @@ import {
   parseArgsAndEnvVars,
   type ScriptConfig,
 } from '../../helpers/parseArgsAndEnvVars';
-import { getDbReader } from '@web-api/database';
+import { getDbReader } from '@web-api/persistence/postgres/database';
 import { isEmpty } from 'lodash';
 import { environment } from '@web-api/environment';
 import { CompiledQuery } from 'kysely';

diff --git a/web-api/src/environment.ts b/web-api/src/environment.ts
@@ -45,7 +45,7 @@ export const environment = {
         (process.env.NODE_ENV !== 'test'
           ? 'localhost'
           : getJestDBConnectionError()),
-      idleTimeoutMillis: isRunningOnLambda ? null : 1000, // null idleTimeoutMillis means the db connection is never closed.
+      idleTimeoutMillis: isRunningOnLambda ? null : 1000, // null idleTimeoutMillis means the db connection is never closed. Be careful changing this.
       max: 1,
       password: process.env.POSTGRES_PASSWORD || 'example',
       port: 5432,

diff --git a/web-api/src/gateways/openSearch/openSearchSyncLocal.ts b/web-api/src/gateways/openSearch/openSearchSyncLocal.ts
@@ -1,4 +1,4 @@
-import { DatabaseSchema } from '@web-api/database-schema';
+import { DatabaseSchema } from '@web-api/persistence/postgres/database-schema';
 import { OpenSearchSyncMessage } from '@web-api/lambdas/openSearch/openSearchSyncHandler';
 
 export const openSearchSyncLocal = async ({

diff --git a/web-api/src/getConnection.ts b/web-api/src/getConnection.ts
diff --git a/web-api/src/getConnection1.test.ts b/web-api/src/getConnection1.test.ts
diff --git a/web-api/src/getConnection2.test.ts b/web-api/src/getConnection2.test.ts
diff --git a/web-api/src/getConnection3.test.ts b/web-api/src/getConnection3.test.ts