···

       
1
       
1
       
-
       
DB_POSTGRES_URL="postgres://bsky:yksb@localhost/plc_dev"

     

       
1
       
1
       
+
       
DATABASE_URL="postgres://bsky:yksb@localhost/plc_dev"

     

       
2
       
2
       
 
       
DEBUG_MODE=1

     

       
3
       
3
       
 
       
LOG_ENABLED="true"

     

       
4
       
4
       
 
       
LOG_LEVEL=debug

     

···

       
8
       
8
       
 
       


     

       
9
       
9
       
 
       
This script allows you to run any command with a fresh, ephemeral/single-use postgres database available. When the script starts a Dockerized postgres container starts-up, and when the script completes that container is removed.

     

       
10
       
10
       
 
       


     

       
11
       
11
       
-
       
The environment variable `DB_POSTGRES_URL` will be set with a connection string that can be used to connect to the database. The [`PG*` environment variables](https://www.postgresql.org/docs/current/libpq-envars.html) that are recognized by libpq (i.e. used by the `psql` client) are also set.

     

       
11
       
11
       
+
       
The environment variable `DATABASE_URL` will be set with a connection string that can be used to connect to the database. The [`PG*` environment variables](https://www.postgresql.org/docs/current/libpq-envars.html) that are recognized by libpq (i.e. used by the `psql` client) are also set.

     

       
12
       
12
       
 
       


     

       
13
       
13
       
 
       
**Example**

     

       
14
       
14
       
 
       


     

···

       
22
       
22
       
 
       
export PGUSER=pg

     

       
23
       
23
       
 
       
export PGPASSWORD=password

     

       
24
       
24
       
 
       
export PGDATABASE=postgres

     

       
25
       
25
       
-
       
export DB_POSTGRES_URL="postgresql://pg:password@localhost:5433/postgres"

     

       
25
       
25
       
+
       
export DATABASE_URL="postgresql://pg:password@localhost:5433/postgres"

     

       
26
       
26
       
 
       
"$@"

     

       
27
       
27
       
 
       
code=$?

     

       
28
       
28
       
 
       


     

···

       
3
       
3
       
 
       
import PlcServer from '.'

     

       
4
       
4
       
 
       


     

       
5
       
5
       
 
       
const run = async () => {

     

       
6
       
6
       
-
       
  const dbPostgresUrl = process.env.DB_POSTGRES_URL

     

       
6
       
6
       
+
       
  const dbUrl = process.env.DATABASE_URL

     

       
7
       
7
       
 
       


     

       
8
       
8
       
 
       
  let db: PlcDatabase

     

       
9
       
9
       
-
       
  if (dbPostgresUrl) {

     

       
10
       
10
       
-
       
    const pgDb = Database.postgres({ url: dbPostgresUrl })

     

       
9
       
9
       
+
       
  if (dbUrl) {

     

       
10
       
10
       
+
       
    const pgDb = Database.postgres({ url: dbUrl })

     

       
11
       
11
       
 
       
    await pgDb.migrateToLatestOrThrow()

     

       
12
       
12
       
 
       
    db = pgDb

     

       
13
       
13
       
 
       
  } else {

     

···

       
8
       
8
       
 
       
    .addColumn('cid', 'text', (col) => col.notNull())

     

       
9
       
9
       
 
       
    .addColumn('nullified', 'boolean', (col) => col.notNull())

     

       
10
       
10
       
 
       
    .addColumn('createdAt', 'timestamptz', (col) =>

     

       
11
       
11
       
-
       
      col.defaultTo(sql`current_timestamp`),

     

       
11
       
11
       
+
       
      col.notNull().defaultTo(sql`current_timestamp`),

     

       
12
       
12
       
 
       
    )

     

       
13
       
13
       
 
       
    .addPrimaryKeyConstraint('operations_primary_key', ['did', 'cid'])

     

       
14
       
14
       
 
       
    .execute()

     

···

       
11
       
11
       
 
       
}

     

       
12
       
12
       
 
       


     

       
13
       
13
       
 
       
export const runTestServer = async (opts: {

     

       
14
       
14
       
-
       
  dbPostgresSchema: string

     

       
14
       
14
       
+
       
  dbSchema: string

     

       
15
       
15
       
 
       
}): Promise<TestServerInfo> => {

     

       
16
       
16
       
-
       
  const { dbPostgresSchema } = opts

     

       
17
       
17
       
-
       
  const dbPostgresUrl = process.env.DB_POSTGRES_URL

     

       
18
       
18
       
-
       
  if (!dbPostgresUrl) {

     

       
16
       
16
       
+
       
  const { dbSchema } = opts

     

       
17
       
17
       
+
       
  const dbUrl = process.env.DATABASE_URL

     

       
18
       
18
       
+
       
  if (!dbUrl) {

     

       
19
       
19
       
 
       
    throw new Error('No postgres url provided')

     

       
20
       
20
       
 
       
  }

     

       
21
       
21
       
 
       


     

       
22
       
22
       
 
       
  const db = Database.postgres({

     

       
23
       
23
       
-
       
    url: dbPostgresUrl,

     

       
24
       
24
       
-
       
    schema: dbPostgresSchema,

     

       
23
       
23
       
+
       
    url: dbUrl,

     

       
24
       
24
       
+
       
    schema: dbSchema,

     

       
25
       
25
       
 
       
  })

     

       
26
       
26
       
 
       
  await db.migrateToLatestOrThrow()

     

       
27
       
27
       
 
       


     

···

       
9
       
9
       
 
       
  let rawDb: Kysely<any>

     

       
10
       
10
       
 
       


     

       
11
       
11
       
 
       
  beforeAll(async () => {

     

       
12
       
12
       
-
       
    const dbPostgresUrl = process.env.DB_POSTGRES_URL

     

       
13
       
13
       
-
       
    if (!dbPostgresUrl) {

     

       
12
       
12
       
+
       
    const dbUrl = process.env.DATABASE_URL

     

       
13
       
13
       
+
       
    if (!dbUrl) {

     

       
14
       
14
       
 
       
      throw new Error('No postgres url provided')

     

       
15
       
15
       
 
       
    }

     

       
16
       
16
       
 
       
    db = Database.postgres({

     

       
17
       
17
       
-
       
      url: dbPostgresUrl,

     

       
17
       
17
       
+
       
      url: dbUrl,

     

       
18
       
18
       
 
       
      schema: 'migration_refactor',

     

       
19
       
19
       
 
       
    })

     

       
20
       
20
       
 
       


     

···

       
22
       
22
       
 
       


     

       
23
       
23
       
 
       
  beforeAll(async () => {

     

       
24
       
24
       
 
       
    const server = await runTestServer({

     

       
25
       
25
       
-
       
      dbPostgresSchema: 'server',

     

       
25
       
25
       
+
       
      dbSchema: 'server',

     

       
26
       
26
       
 
       
    })

     

       
27
       
27
       
 
       


     

       
28
       
28
       
 
       
    db = server.db