diff --git a/.env.development b/.env.development index d23eee3..3b09d01 100644 --- a/.env.development +++ b/.env.development @@ -5,14 +5,14 @@ PGDATABASE=db_dev PGHOST=localhost PGPORT=3999 -# For docker compose +# For docker compose and pgboss POSTGRES_PASSWORD=password POSTGRES_USER=user POSTGRES_DB=db_dev POSTGRES_HOST=localhost POSTGRES_PORT=3999 -# For prisma and pg-boss +# For prisma DATABASE_URL="postgresql://user:password@localhost:3999/db_dev" # Next-auth diff --git a/lib/job-queue.ts b/lib/job-queue.ts index a435da4..d11e379 100644 --- a/lib/job-queue.ts +++ b/lib/job-queue.ts @@ -1,13 +1,21 @@ import PgBoss from 'pg-boss' import { beeminderSyncCard, BeeminderSyncCardPayload } from './jobs/beeminder-sync-card' -import { error } from 'console' type Job = { tag: 'beeminder-sync-card' payload: BeeminderSyncCardPayload } -const boss = new PgBoss(process.env.DATABASE_URL!) +const boss = new PgBoss({ + user: process.env.POSTGRES_USER, + host: process.env.POSTGRES_HOST, + port: parseInt(process.env.POSTGRES_PORT!), + database: process.env.POSTGRES_DB, + password: process.env.POSTGRES_PASSWORD, + ...('POSTGRES_CA_CERT' in process.env + ? { ssl: { rejectUnauthorized: true, ca: process.env.POSTGRES_CA_CERT } } + : {}), +}) export async function addJob( tag: T,