fix #439 (#445)

* fix #439

* add promote class

README.md

@@ -730,7 +730,7 @@ Slave settings:
 - **DESTROY_DATABASE_ON_RESTART**: Default is `True`. Set to 'False' to prevent this behavior. A
   replicant will always destroy its current database on restart, because it will try to sync again
   from `master` and avoid inconsistencies.
-- **PROMOTE_MASTER**: Default none. If set to any value then the current replicant
+- **PROMOTE_MASTER**: Default false. If set to `true` then the current replicant
   will be promoted to master. In some cases when the `master` container has failed, we might want
   to use our `replicant` as `master` for a while. However, the promoted replicant will break
   consistencies and is not able to revert to replicant anymore, unless it is destroyed and

scenario_tests/collations/docker-compose.yml

@@ -1,5 +1,5 @@
 
-version: '2.1'
+version: '3.9'
 
 volumes:
   pg-data-dir:
@@ -11,8 +11,6 @@ services:
   pg:
     image: 'kartoza/postgis:${TAG:-manual-build}'
     restart: 'always'
-    # You can optionally mount to volume, to play with the persistence and
-    # observe how the node will behave after restarts.
     volumes:
       - pg-data-dir:/var/lib/postgresql
       - ./tests:/tests
@@ -35,8 +33,6 @@ services:
   pg-new:
     image: 'kartoza/postgis:${TAG:-manual-build}'
     restart: 'always'
-    # You can optionally mount to volume, to play with the persistence and
-    # observe how the node will behave after restarts.
     volumes:
       - new-pg-data-dir:/opt/data/postgis
       - ./tests:/tests
@@ -62,8 +58,6 @@ services:
   pg-gosu:
     image: 'kartoza/postgis:${TAG:-manual-build}'
     restart: 'always'
-    # You can optionally mount to volume, to play with the persistence and
-    # observe how the node will behave after restarts.
     volumes:
       - pg-data-dir-gs:/var/lib/postgresql
       - ./tests:/tests

scenario_tests/datadir_init/docker-compose-gs.yml

@@ -1,4 +1,4 @@
-version: '2.1'
+version: '3.9'
 volumes:
   default-pg-data-dir:
   new-pg-data-dir:

scenario_tests/datadir_init/docker-compose.yml

@@ -1,4 +1,4 @@
-version: '2.1'
+version: '3.9'
 volumes:
   default-pg-data-dir:
   new-pg-data-dir:

scenario_tests/extensions/docker-compose.yml

@@ -1,5 +1,5 @@
 
-version: '2.1'
+version: '3.9'
 
 services:
   pg:

scenario_tests/init_scripts/docker-compose.yml

@@ -1,4 +1,4 @@
-version: '2.1'
+version: '3.9'
 volumes:
   default-pg-data-dir-md5:
   new-pg-data-dir:

scenario_tests/logical_replication/docker-compose-gs.yml

@@ -1,5 +1,5 @@
 
-version: '2.1'
+version: '3.9'
 
 volumes:
   pg-publisher-data-dir:

scenario_tests/logical_replication/docker-compose.yml

@@ -1,5 +1,5 @@
 
-version: '2.1'
+version: '3.9'
 
 volumes:
   pg-publisher-data-dir:

scenario_tests/multiple_databases/docker-compose.yml

@@ -1,5 +1,5 @@
 
-version: '2.1'
+version: '3.9'
 
 volumes:
   pg-db-data-dir:

scenario_tests/streaming_replication/docker-compose-gs-promote.yml

@@ -0,0 +1,62 @@
+
+version: '2.1'
+
+volumes:
+  pg-master-data-dir:
+  pg-node-data-dir:
+
+services:
+  pg-master:
+    image: 'kartoza/postgis:${TAG:-manual-build}'
+    restart: 'always'
+
+    volumes:
+      - pg-master-data-dir:/var/lib/postgresql
+      - ./tests:/tests
+      - ../utils:/lib/utils
+      - ./scripts/setup-master.sql:/docker-entrypoint-initdb.d/setup-master.sql
+    environment:
+
+      ALLOW_IP_RANGE: '0.0.0.0/0'
+
+      # We can specify optional credentials
+      POSTGRES_PASS: 'docker'
+      REPLICATION_USER: 'replicator'
+      REPLICATION_PASS: 'replicator'
+      REPLICATION: 'true'
+      RUN_AS_ROOT: false
+    healthcheck:
+      interval: 60s
+      timeout: 30s
+      retries: 3
+      test: "pg_isready"
+
+  pg-node:
+    image: 'kartoza/postgis:${TAG:-manual-build}'
+    restart: 'always'
+
+    volumes:
+      - pg-node-data-dir:/var/lib/postgresql
+      - ./tests:/tests
+      - ../utils:/lib/utils
+
+    environment:
+
+      ALLOW_IP_RANGE: '0.0.0.0/0'
+      POSTGRES_PASS: 'docker'
+      REPLICATE_FROM: 'pg-master'
+      REPLICATION: 'true'
+      RUN_AS_ROOT: false
+      PROMOTE_MASTER: false
+      DESTROY_DATABASE_ON_RESTART: 'True'
+      REPLICATION_USER: 'replicator'
+      REPLICATION_PASS: 'replicator'
+    depends_on:
+        pg-master:
+          condition: service_healthy
+
+    healthcheck:
+      interval: 60s
+      timeout: 30s
+      retries: 3
+      test: "pg_isready"

scenario_tests/streaming_replication/docker-compose-gs.yml

@@ -1,5 +1,5 @@
 
-version: '2.1'
+version: '3.9'
 
 volumes:
   pg-master-data-dir:

scenario_tests/streaming_replication/docker-compose-root-promote.yml

@@ -0,0 +1,55 @@
+
+version: '2.1'
+
+volumes:
+  pg-master-data-dir:
+  pg-node-data-dir:
+
+services:
+  pg-master:
+    image: 'kartoza/postgis:${TAG:-manual-build}'
+    restart: 'always'
+    volumes:
+      - pg-master-data-dir:/var/lib/postgresql
+      - ./tests:/tests
+      - ../utils:/lib/utils
+      - ./scripts/setup-master.sql:/docker-entrypoint-initdb.d/setup-master.sql 
+    environment:
+      ALLOW_IP_RANGE: '0.0.0.0/0'
+      # We can specify optional credentials
+      POSTGRES_PASS: 'docker'
+      REPLICATION_USER: 'replicator'
+      REPLICATION_PASS: 'replicator'
+      REPLICATION: 'true'
+      RUN_AS_ROOT: true
+    healthcheck:
+      interval: 60s
+      timeout: 30s
+      retries: 3
+      test: "pg_isready"
+
+  pg-node:
+    image: 'kartoza/postgis:${TAG:-manual-build}'
+    restart: 'always'
+    volumes:
+      - pg-node-data-dir:/var/lib/postgresql
+      - ./tests:/tests
+      - ../utils:/lib/utils
+    environment:
+      ALLOW_IP_RANGE: '0.0.0.0/0'
+      POSTGRES_PASS: 'docker'
+      REPLICATE_FROM: 'pg-master'
+      REPLICATION: 'true'
+      RUN_AS_ROOT: true
+      PROMOTE_MASTER: false
+      DESTROY_DATABASE_ON_RESTART: 'True'
+      REPLICATION_USER: 'replicator'
+      REPLICATION_PASS: 'replicator'
+    depends_on:
+        pg-master:
+          condition: service_healthy
+    healthcheck:
+      interval: 60s
+      timeout: 30s
+      retries: 3
+      test: "pg_isready"

scenario_tests/streaming_replication/docker-compose.yml

@@ -1,5 +1,5 @@
 
-version: '2.1'
+version: '3.9'
 
 volumes:
   pg-master-data-dir:

scenario_tests/streaming_replication/scripts/setup-master.sql

@@ -0,0 +1,11 @@
+-- Create a table
+CREATE TABLE IF NOT EXISTS sweets
+    (
+        id SERIAL,
+        name TEXT,
+        price DECIMAL,
+        CONSTRAINT sweets_pkey PRIMARY KEY (id)
+    );
+
+-- Inserts records into the table
+INSERT INTO sweets (name, price) VALUES ('strawberry', 4.50), ('Coffee', 6.20), ('lollipop', 3.80);

scenario_tests/streaming_replication/test.sh

@@ -11,8 +11,9 @@ if [[ $(dpkg -l | grep "docker-compose") > /dev/null ]];then
     VERSION='docker compose'
 fi
 
-
+####
 # Run service as root user
+####
 ${VERSION} up -d
 
 if [[ -n "${PRINT_TEST_LOGS}" ]]; then
@@ -39,7 +40,9 @@ ${VERSION} exec -T pg-node /bin/bash /tests/test_node.sh
 
 ${VERSION} down -v
 
+####
 # Run service as none root
+####
 ${VERSION} -f docker-compose-gs.yml up -d
 
 if [[ -n "${PRINT_TEST_LOGS}" ]]; then
@@ -64,4 +67,64 @@ done;
 # Execute tests
 ${VERSION} -f docker-compose-gs.yml exec -T pg-node /bin/bash /tests/test_node.sh
 
-${VERSION} -f docker-compose-gs.yml down -v
+${VERSION} -f docker-compose-gs.yml down -v
+
+
+####
+# Run service as root user for node promotion
+####
+${VERSION} -f docker-compose-root-promote.yml up -d
+
+if [[ -n "${PRINT_TEST_LOGS}" ]]; then
+  ${VERSION} -f docker-compose-root-promote.yml logs -f &
+fi
+
+sleep 30
+
+# Update env variable
+sed -i 's/\(PROMOTE_MASTER: \)false/\1true/'  docker-compose-root-promote.yml
+
+# Bring up node with option to promote node
+
+${VERSION} -f docker-compose-root-promote.yml up -d pg-node
+
+# Preparing node cluster
+until ${VERSION} -f docker-compose-root-promote.yml exec -T pg-node pg_isready; do
+  sleep 30
+done;
+
+# Execute tests
+${VERSION} -f docker-compose-root-promote.yml exec -T pg-node /bin/bash /tests/test_node_promotion.sh
+
+${VERSION} -f docker-compose-root-promote.yml down -v
+sed -i 's/\(PROMOTE_MASTER: \)true/\1false/'  docker-compose-root-promote.yml
+
+####
+# Run service as none root user for node promotion
+####
+${VERSION} -f docker-compose-gs-promote.yml up -d
+
+if [[ -n "${PRINT_TEST_LOGS}" ]]; then
+  ${VERSION} -f docker-compose-gs-promote.yml logs -f &
+fi
+
+sleep 30
+
+# Update env variable
+sed -i 's/\(PROMOTE_MASTER: \)false/\1true/'  docker-compose-gs-promote.yml
+
+# Bring up node with option to promote node
+
+${VERSION} -f docker-compose-gs-promote.yml up -d pg-node
+
+# Preparing node cluster
+until ${VERSION} -f docker-compose-gs-promote.yml exec -T pg-node pg_isready; do
+  sleep 30
+done;
+
+# Execute tests
+${VERSION} -f docker-compose-gs-promote.yml exec -T pg-node /bin/bash /tests/test_node_promotion.sh
+
+${VERSION} -f docker-compose-gs-promote.yml down -v
+sed -i 's/\(PROMOTE_MASTER: \)true/\1false/'  docker-compose-gs-promote.yml
+

scenario_tests/streaming_replication/tests/test_node_promotion.sh

@@ -0,0 +1,13 @@
+#!/usr/bin/env bash
+
+set -e
+
+source /scripts/env-data.sh
+
+# execute tests
+pushd /tests
+
+PGHOST=localhost \
+PGDATABASE=gis \
+PYTHONPATH=/lib \
+  python3 -m unittest -v test_replication.TestReplicationPromotion