chore: migrate to sql-tools library (#26400)

Co-authored-by: Jason Rasmussen <jason@rasm.me>

server/src/utils/database.ts

@@ -1,3 +1,4 @@
+import { createPostgres, DatabaseConnectionParams } from '@immich/sql-tools';
 import {
   AliasedRawBuilder,
   DeduplicateJoinsPlugin,
@@ -14,90 +15,24 @@ import {
 } from 'kysely';
 import { PostgresJSDialect } from 'kysely-postgres-js';
 import { jsonArrayFrom, jsonObjectFrom } from 'kysely/helpers/postgres';
-import { parse } from 'pg-connection-string';
-import postgres, { Notice, PostgresError } from 'postgres';
+import { Notice, PostgresError } from 'postgres';
 import { columns, Exif, lockableProperties, LockableProperty, Person } from 'src/database';
 import { AssetEditActionItem } from 'src/dtos/editing.dto';
-import { AssetFileType, AssetVisibility, DatabaseExtension, DatabaseSslMode } from 'src/enum';
+import { AssetFileType, AssetVisibility, DatabaseExtension } from 'src/enum';
 import { AssetSearchBuilderOptions } from 'src/repositories/search.repository';
 import { DB } from 'src/schema';
-import { DatabaseConnectionParams, VectorExtension } from 'src/types';
-
-type Ssl = 'require' | 'allow' | 'prefer' | 'verify-full' | boolean | object;
-
-const isValidSsl = (ssl?: string | boolean | object): ssl is Ssl =>
-  typeof ssl !== 'string' || ssl === 'require' || ssl === 'allow' || ssl === 'prefer' || ssl === 'verify-full';
-
-export const asPostgresConnectionConfig = (params: DatabaseConnectionParams) => {
-  if (params.connectionType === 'parts') {
-    return {
-      host: params.host,
-      port: params.port,
-      username: params.username,
-      password: params.password,
-      database: params.database,
-      ssl: params.ssl === DatabaseSslMode.Disable ? false : params.ssl,
-    };
-  }
-
-  const { host, port, user, password, database, ...rest } = parse(params.url);
-  let ssl: Ssl | undefined;
-  if (rest.ssl) {
-    if (!isValidSsl(rest.ssl)) {
-      throw new Error(`Invalid ssl option: ${rest.ssl}`);
-    }
-    ssl = rest.ssl;
-  }
-
-  return {
-    host: host ?? undefined,
-    port: port ? Number(port) : undefined,
-    username: user,
-    password,
-    database: database ?? undefined,
-    ssl,
-  };
-};
-
-export const getKyselyConfig = (
-  params: DatabaseConnectionParams,
-  options: Partial<postgres.Options<Record<string, postgres.PostgresType>>> = {},
-): KyselyConfig => {
-  const config = asPostgresConnectionConfig(params);
+import { VectorExtension } from 'src/types';
 
+export const getKyselyConfig = (connection: DatabaseConnectionParams): KyselyConfig => {
   return {
     dialect: new PostgresJSDialect({
-      postgres: postgres({
-        onnotice: (notice: Notice) => {
+      postgres: createPostgres({
+        connection,
+        onNotice: (notice: Notice) => {
           if (notice['severity'] !== 'NOTICE') {
             console.warn('Postgres notice:', notice);
           }
         },
-        max: 10,
-        types: {
-          date: {
-            to: 1184,
-            from: [1082, 1114, 1184],
-            serialize: (x: Date | string) => (x instanceof Date ? x.toISOString() : x),
-            parse: (x: string) => new Date(x),
-          },
-          bigint: {
-            to: 20,
-            from: [20, 1700],
-            parse: (value: string) => Number.parseInt(value),
-            serialize: (value: number) => value.toString(),
-          },
-        },
-        connection: {
-          TimeZone: 'UTC',
-        },
-        host: config.host,
-        port: config.port,
-        username: config.username,
-        password: config.password,
-        database: config.database,
-        ssl: config.ssl,
-        ...options,
       }),
     }),
     log(event) {