Remove pgconfig since we only support real pg now

README.md

@@ -27,6 +27,11 @@ The server will correctly send to the requesting client the difference from its
 
 ## 1. Setup
 
+#### Install Postgres
+
+You will need a local Postgres database to use this sample.
+On MacOS, we recommend [Postgres.app](https://postgresapp.com/).
+
 #### Get your Replicache License Key
 
 ```bash
@@ -45,10 +50,18 @@ $ export VITE_REPLICACHE_LICENSE_KEY="<your license key>"
 $ npm install; npm run build;
 ```
 
-## 2. Start frontend and backend watcher
+## 2. Develop
+
+#### Create a new, empty database
+
+```bash
+psql -c 'create database todo'
+```
+
+### Start frontend and backend watcher
 
 ```bash
-$ npm run watch --ws
+$ DATABASE_URL='postgresql://localhost/todo' npm run watch --ws
 ```
 
 Provides an example integrating replicache with react in a simple todo application.

server/src/pg.ts

@@ -1,8 +1,8 @@
 // Low-level config and utilities for Postgres.
 
+import pg from 'pg';
 import type {Pool, QueryResult} from 'pg';
 import {createDatabase} from './schema.js';
-import {getDBConfig} from './pgconfig/pgconfig.js';
 
 const pool = getPool();
 
@@ -20,8 +20,21 @@ async function getPool() {
 async function initPool() {
   console.log('creating global pool');
 
-  const dbConfig = getDBConfig();
-  const pool = dbConfig.initPool();
+  const url = process.env.DATABASE_URL;
+  if (!url) {
+    throw new Error('Required env var DATABASE_URL not set');
+  }
+
+  const ssl =
+    process.env.NODE_ENV === 'production'
+      ? {
+          rejectUnauthorized: false,
+        }
+      : undefined;
+  const pool = new pg.Pool({
+    connectionString: url,
+    ssl,
+  });
 
   // the pool will emit an error on behalf of any idle clients
   // it contains if a backend error or network partition happens
@@ -39,7 +52,7 @@ async function initPool() {
 
   await withExecutorAndPool(async executor => {
     await transactWithExecutor(executor, async executor => {
-      await createDatabase(executor, dbConfig);
+      await createDatabase(executor);
     });
   }, pool);
 

server/src/schema.ts

@@ -1,11 +1,10 @@
-import type {PGConfig} from './pgconfig/pgconfig.js';
 import type {Executor} from './pg.js';
 
 const schemaVersion = 3;
 
-export async function createDatabase(executor: Executor, dbConfig: PGConfig) {
+export async function createDatabase(executor: Executor) {
   console.log('creating database');
-  const actualSchemaVersion = await dbConfig.getSchemaVersion(executor);
+  const actualSchemaVersion = await getSchemaVersion(executor);
   if (schemaVersion !== actualSchemaVersion) {
     await createSchema(executor);
   }
@@ -62,3 +61,15 @@ export async function createSchema(executor: Executor) {
     lastmodified timestamp(6) not null
     )`);
 }
+
+async function getSchemaVersion(executor: Executor) {
+  const metaExists = await executor(`select exists(
+    select from pg_tables where schemaname = 'public' and tablename = 'replicache_meta')`);
+  if (!metaExists.rows[0].exists) {
+    return 0;
+  }
+  const qr = await executor(
+    `select value from replicache_meta where key = 'schemaVersion'`,
+  );
+  return qr.rows[0].value;
+}