From cdf99d42a1931279d49f57a197897bccb81b54a8 Mon Sep 17 00:00:00 2001
From: Varik Matevosyan <varikmatevosyan@gmail.com>
Date: Fri, 21 Jun 2024 21:05:19 +0400
Subject: [PATCH] fix ddl log trigger to work with replica events

---
 model/lantern/lantern_resource.rb | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/model/lantern/lantern_resource.rb b/model/lantern/lantern_resource.rb
index 345f5af9d..ac9fb34d4 100644
--- a/model/lantern/lantern_resource.rb
+++ b/model/lantern/lantern_resource.rb
@@ -125,6 +125,7 @@ def create_ddl_log
   def listen_ddl_log
     commands = <<SQL
    DROP EVENT TRIGGER IF EXISTS log_ddl_trigger;
+   TRUNCATE TABLE ddl_log RESTART IDENTITY;
    CREATE OR REPLACE FUNCTION execute_ddl_command()
    RETURNS TRIGGER AS $$
    BEGIN
@@ -138,6 +139,7 @@ def listen_ddl_log
    AFTER INSERT ON ddl_log
    FOR EACH ROW
    EXECUTE FUNCTION execute_ddl_command();
+   ALTER TABLE ddl_log ENABLE REPLICA TRIGGER execute_ddl_after_insert;
 SQL
     representative_server.run_query_all(commands)
   end
@@ -155,6 +157,7 @@ def create_and_enable_subscription
       WITH (
         copy_data = false,
         create_slot = false,
+        binary = true,
         enabled = true,
         synchronous_commit = false,
         connect = true,
@@ -171,8 +174,8 @@ def disable_logical_subscription
 
   def create_logical_replica(lantern_version: nil, extras_version: nil, minor_version: nil)
     ubid = LanternResource.generate_ubid
-    create_publication("pub_#{ubid}")
     create_ddl_log
+    create_publication("pub_#{ubid}")
     slot_lsn = create_replication_slot("slot_#{ubid}")
     Prog::Lantern::LanternResourceNexus.assemble(
       project_id: project_id,