···

       
18
       
 
       
    await migrateDb.migrateToLatestOrThrow()

     

       
19
       
 
       
    await migrateDb.close()

     

       
20
       
 
       
  }

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
21
       
 
       
  // Use lower-credentialed user to run the app

     

       
22
       
 
       
  const db = Database.postgres({

     

       
23
       
 
       
    url: pgUrl(dbCreds),

     

       
24
       
 
       
    schema: dbSchema,

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
25
       
 
       
  })

     

       
26
       
-
       
  const port = parseInt(process.env.PORT)

     

       
27
       
 
       
  const plc = PlcServer.create({ db, port, version })

     

       
28
       
 
       
  const server = await plc.start()

     

       
29
       
 
       
  server.keepAliveTimeout = 90000

     
···

       
36
       
 
       
const pgUrl = ({ username = "postgres", password = "postgres", host = "localhost", port = "5432", database = "postgres", sslmode }) => {

     

       
37
       
 
       
  const enc = encodeURIComponent

     

       
38
       
 
       
  return `postgresql://${username}:${enc(password)}@${host}:${port}/${database}${sslmode ? `?sslmode=${enc(sslmode)}` : ''}`

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
39
       
 
       
}

     

       
40
       
 
       


     

       
41
       
 
       
main()

     

···

       
18
       
 
       
    await migrateDb.migrateToLatestOrThrow()

     

       
19
       
 
       
    await migrateDb.close()

     

       
20
       
 
       
  }

     

       
21
       
+
       
  const dbPoolSize = parseMaybeInt(process.env.DB_POOL_SIZE)

     

       
22
       
+
       
  const dbPoolMaxUses = parseMaybeInt(process.env.DB_POOL_MAX_USES)

     

       
23
       
+
       
  const dbPoolIdleTimeoutMs = parseMaybeInt(process.env.PDS_DB_POOL_IDLE_TIMEOUT_MS)

     

       
24
       
 
       
  // Use lower-credentialed user to run the app

     

       
25
       
 
       
  const db = Database.postgres({

     

       
26
       
 
       
    url: pgUrl(dbCreds),

     

       
27
       
 
       
    schema: dbSchema,

     

       
28
       
+
       
    poolSize: dbPoolSize,

     

       
29
       
+
       
    poolMaxUses: dbPoolMaxUses,

     

       
30
       
+
       
    poolIdleTimeoutMs: dbPoolIdleTimeoutMs,

     

       
31
       
 
       
  })

     

       
32
       
+
       
  const port = parseMaybeInt(process.env.PORT)

     

       
33
       
 
       
  const plc = PlcServer.create({ db, port, version })

     

       
34
       
 
       
  const server = await plc.start()

     

       
35
       
 
       
  server.keepAliveTimeout = 90000

     
···

       
42
       
 
       
const pgUrl = ({ username = "postgres", password = "postgres", host = "localhost", port = "5432", database = "postgres", sslmode }) => {

     

       
43
       
 
       
  const enc = encodeURIComponent

     

       
44
       
 
       
  return `postgresql://${username}:${enc(password)}@${host}:${port}/${database}${sslmode ? `?sslmode=${enc(sslmode)}` : ''}`

     

       
45
       
+
       
}

     

       
46
       
+
       


     

       
47
       
+
       
const parseMaybeInt = (str) => {

     

       
48
       
+
       
  return str ? parseInt(str, 10) : undefined

     

       
49
       
 
       
}

     

       
50
       
 
       


     

       
51
       
 
       
main()

     

···

       
26
       
 
       
    })

     

       
27
       
 
       
  }

     

       
28
       
 
       


     

       
29
       
-
       
  static postgres(opts: { url: string; schema?: string }): Database {

     

       
30
       
-
       
    const { url, schema } = opts

     

       
31
       
-
       
    const pool = new PgPool({ connectionString: url })

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
32
       
 
       


     

       
33
       
 
       
    // Select count(*) and other pg bigints as js integer

     

       
34
       
 
       
    pgTypes.setTypeParser(pgTypes.builtins.INT8, (n) => parseInt(n, 10))

     
···

       
230
       
 
       
      createdAt: row.createdAt.toISOString(),

     

       
231
       
 
       
    }))

     

       
232
       
 
       
  }

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
233
       
 
       
}

     

       
234
       
 
       


     

       
235
       
 
       
export default Database

     

···

       
26
       
 
       
    })

     

       
27
       
 
       
  }

     

       
28
       
 
       


     

       
29
       
+
       
  static postgres(opts: PgOptions): Database {

     

       
30
       
+
       
    const { schema } = opts

     

       
31
       
+
       
    const pool = new PgPool({

     

       
32
       
+
       
      connectionString: opts.url,

     

       
33
       
+
       
      max: opts.poolSize,

     

       
34
       
+
       
      maxUses: opts.poolMaxUses,

     

       
35
       
+
       
      idleTimeoutMillis: opts.poolIdleTimeoutMs,

     

       
36
       
+
       
    })

     

       
37
       
 
       


     

       
38
       
 
       
    // Select count(*) and other pg bigints as js integer

     

       
39
       
 
       
    pgTypes.setTypeParser(pgTypes.builtins.INT8, (n) => parseInt(n, 10))

     
···

       
235
       
 
       
      createdAt: row.createdAt.toISOString(),

     

       
236
       
 
       
    }))

     

       
237
       
 
       
  }

     

       
238
       
+
       
}

     

       
239
       
+
       


     

       
240
       
+
       
export type PgOptions = {

     

       
241
       
+
       
  url: string

     

       
242
       
+
       
  schema?: string

     

       
243
       
+
       
  poolSize?: number

     

       
244
       
+
       
  poolMaxUses?: number

     

       
245
       
+
       
  poolIdleTimeoutMs?: number

     

       
246
       
 
       
}

     

       
247
       
 
       


     

       
248
       
 
       
export default Database