[FROZEN][Bridge][Optional] Restored the PostgreSQL store.

scripts/streams_live_lane.sh

@@ -20,6 +20,9 @@
 #   STREAMS_ARCHIVE_S3_URL  an `s3://bucket/prefix` the archive cases write to, with the `AWS_*`
 #                      settings the stream runtime reads. Without it, the script starts MinIO in
 #                      Docker on a free port and removes the container at the end.
+#   STREAMS_POSTGRES_URL  a PostgreSQL 14 or later database the Postgres cases use. Each case makes
+#                      a schema of its own. Without it, the script starts PostgreSQL 17 in Docker
+#                      on a free port and removes the container at the end.
 #   WORK_DIR           where to build and keep logs (default: a new temporary directory)
 #   PYTEST_TARGETS     the tests to run (default: the stream and Nexus tests). A narrower run fails
 #                      the gate, since the gated ids outside it don't run.
@@ -241,6 +244,22 @@ if [[ -z "${STREAMS_ARCHIVE_S3_URL:-}" ]]; then
     "import boto3; boto3.client('s3').create_bucket(Bucket='streams-archive')")
 fi
 
+if [[ -z "${STREAMS_POSTGRES_URL:-}" ]]; then
+  pg_port=$(python3 -c 'import socket; s = socket.socket(); s.bind(("127.0.0.1", 0)); print(s.getsockname()[1])')
+  pg=streams-lane-pg-$$
+  # Many cases connect at once, each with a pool and a listener.
+  docker run -d --rm --name "$pg" -p "127.0.0.1:$pg_port:5432" \
+    -e POSTGRES_USER=streams -e POSTGRES_PASSWORD=streams -e POSTGRES_DB=streams \
+    postgres:17 -c max_connections=1000 >/dev/null
+  containers+=("$pg")
+  for _ in $(seq 60); do
+    docker exec "$pg" pg_isready -q -U streams -d streams -h 127.0.0.1 && break
+    sleep 1
+  done
+  export STREAMS_POSTGRES_URL="postgres://streams:streams@127.0.0.1:$pg_port/streams"
+  STREAMS_POSTGRES_URL+="?sslmode=disable"
+fi
+
 cd "$SDK_DIR"
 export PYTHONPATH="$SDK_DIR${PYTHONPATH:+:$PYTHONPATH}"
 
@@ -302,7 +321,7 @@ uv run --no-sync pytest ${PYTEST_TARGETS:-${default_targets[*]}} \
 
 # A live test that skips here proves nothing, so a skip for a missing notifier, missing Nexus
 # progress or a missing store fails the lane.
-gated='no stream notifier|refused Nexus progress|STREAMS_REDIS_URL|STREAMS_REDIS_CLUSTER_URL|no NexusHandler callbacks|STREAMS_ARCHIVE_S3_URL'
+gated='no stream notifier|refused Nexus progress|STREAMS_REDIS_URL|STREAMS_REDIS_CLUSTER_URL|no NexusHandler callbacks|STREAMS_ARCHIVE_S3_URL|STREAMS_POSTGRES_URL'
 if grep -oE "<skipped [^>]*message=\"[^\"]*($gated)[^\"]*\"" "$WORK_DIR/junit.xml"; then
   echo "live lane: live tests skipped, see above" >&2
   status=1