taler-local: sync

1 files changed, 19 insertions, 1 deletions

diff --git a/bin/taler-local b/bin/taler-local
index 314b2ab..3f77d1a 100755
--- a/bin/taler-local
+++ b/bin/taler-local
@@ -1218,6 +1218,12 @@ def prepare(x_forwarded_host, x_forwarded_proto, postgres_db_name):
             cmd = f"{TALER_PREFIX}/bin/taler-merchant-httpd -L DEBUG -c {CFG_OUTDIR / 'taler.conf'}",
             env = TALER_UNIT_FILES_DIR / "taler-local-postgres.env" if os.environ.get("PGPORT") else None
         ))
+    with open(TALER_UNIT_FILES_DIR / "taler-local-sync.service", "w") as sync_unit:
+        sync_unit.write(unit_file_content(
+            description = "Taler Sync",
+            cmd = f"{TALER_PREFIX}/bin/sync-httpd -L DEBUG -c {CFG_OUTDIR / 'sync.conf'}",
+            env = TALER_UNIT_FILES_DIR / "taler-local-postgres.env" if os.environ.get("PGPORT") else None
+        ))
     with open(TALER_UNIT_FILES_DIR / "taler-local-merchant-backend-token.service", "w") as merchant_token_unit:
         merchant_token_unit.write(unit_file_content(
             description = "Taler Merchant backend with auth token to allow default instance creation.",
@@ -1746,7 +1752,9 @@ def prepare(x_forwarded_host, x_forwarded_proto, postgres_db_name):
         wire_method = WIRE_METHOD,
         auth_token=FRONTENDS_API_TOKEN
     )
-
+    print_nn("Stopping the merchant with TALER_MERCHANT_TOKEN into the env...")
+    subprocess.run(["systemctl", "--user", "stop", "taler-local-merchant-backend-token.service"], check=True)
+    print(" OK")
     print_nn("Restarting the merchant WITHOUT the auth-token in the env...")
     subprocess.run(["systemctl", "--user", "start", "taler-local-merchant-backend.service"], check=True)
     if not is_serving(REV_PROXY_URL + "/merchant-backend/config"):
@@ -1776,6 +1784,15 @@ def prepare(x_forwarded_host, x_forwarded_proto, postgres_db_name):
     time.sleep(2)
     print(" OK")
 
+    # Configure Sync.
+    print_nn("Reset and init Sync DB..")
+    Command([
+        f"{TALER_PREFIX}/bin/sync-dbinit",
+        "-c", CFG_OUTDIR / "sync.conf",
+        "--reset"]
+    ).run()
+    print(" OK")
+
 @cli.command()
 def launch():
     subprocess.run(["systemctl", "--user", "start", "taler-local-port-redirect.service"], check=True)
@@ -1788,6 +1805,7 @@ def launch():
     subprocess.run(["systemctl", "--user", "start", "taler-local-exchange-aggregator.service"], check=True)
     subprocess.run(["systemctl", "--user", "start", "taler-local-exchange-transfer.service"], check=True)
     subprocess.run(["systemctl", "--user", "start", "taler-local-merchant-backend.service"], check=True)
+    subprocess.run(["systemctl", "--user", "start", "taler-local-sync.service"], check=True)
     subprocess.run(["systemctl", "--user", "start", "taler-local-sandbox.service"], check=True)
     subprocess.run(["systemctl", "--user", "start", "taler-local-nexus.service"], check=True)
     subprocess.run(["systemctl", "--user", "start", "taler-local-donations.service"], check=True)