From 52ed427c53ab95fa945b58fd050b82f51c6a38ce Mon Sep 17 00:00:00 2001
From: krehermann <keith.rehermann@smartcontract.com>
Date: Wed, 10 Jan 2024 14:58:07 -0700
Subject: [PATCH] include migration

---
 .../0218_drop_log_topic_trigger.sql           | 27 +++++++++++++++++++
 1 file changed, 27 insertions(+)
 create mode 100644 core/store/migrate/migrations/0218_drop_log_topic_trigger.sql

diff --git a/core/store/migrate/migrations/0218_drop_log_topic_trigger.sql b/core/store/migrate/migrations/0218_drop_log_topic_trigger.sql
new file mode 100644
index 00000000000..ea80cccd2b5
--- /dev/null
+++ b/core/store/migrate/migrations/0218_drop_log_topic_trigger.sql
@@ -0,0 +1,27 @@
+-- +goose Up
+-- +goose StatementBegin
+DROP TRIGGER IF EXISTS notify_insert_on_logs_topics ON EVM.logs;
+DROP FUNCTION IF EXISTS evm.notifysavedlogtopics();
+
+-- +goose StatementEnd
+
+
+-- +goose Down
+-- +goose StatementBegin
+
+CREATE FUNCTION evm.notifysavedlogtopics() RETURNS trigger
+    LANGUAGE plpgsql
+AS $$
+BEGIN
+    PERFORM pg_notify(
+        'evm.insert_on_logs'::text,
+        -- hex encoded address plus comma separated list of hex encoded topic values
+        -- e.g. "<address>:<topicVal1>,<topicVal2>"
+        encode(NEW.address, 'hex') || ':' || array_to_string(array(SELECT encode(unnest(NEW.topics), 'hex')), ',')
+    );
+    RETURN NULL;
+END
+$$;
+
+CREATE TRIGGER notify_insert_on_logs_topics AFTER INSERT ON evm.logs FOR EACH ROW EXECUTE PROCEDURE evm.notifysavedlogtopics();
+-- +goose StatementEnd