From ddcd4448111b31d20db1a4ab3689f9923896d375 Mon Sep 17 00:00:00 2001
From: sjwmoveon <sophie.waldman@moveon.org>
Date: Fri, 3 May 2024 14:23:29 -0400
Subject: [PATCH] Update campaign_contact.updated_at on change

---
 ...0240503180901_campaigncontactsupdatedat.js | 32 +++++++++++++++++++
 migrations/helpers/index.js                   |  8 +++++
 2 files changed, 40 insertions(+)
 create mode 100644 migrations/20240503180901_campaigncontactsupdatedat.js

diff --git a/migrations/20240503180901_campaigncontactsupdatedat.js b/migrations/20240503180901_campaigncontactsupdatedat.js
new file mode 100644
index 000000000..1ef891573
--- /dev/null
+++ b/migrations/20240503180901_campaigncontactsupdatedat.js
@@ -0,0 +1,32 @@
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+
+const { onUpdateTrigger } = require('./helpers/index')
+const ON_UPDATE_TIMESTAMP_FUNCTION = `
+  CREATE OR REPLACE FUNCTION on_update_timestamp()
+  RETURNS trigger AS $$
+  BEGIN
+    NEW.updated_at = now();
+    RETURN NEW;
+  END;
+$$ language 'plpgsql';
+`
+
+const DROP_ON_UPDATE_TIMESTAMP_FUNCTION = `DROP FUNCTION on_update_timestamp`
+
+exports.up = async function(knex) {
+    await knex.raw(ON_UPDATE_TIMESTAMP_FUNCTION);
+    await knex.raw(onUpdateTrigger('campaign_contact'));
+};
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.down = async function(knex) {
+    await knex.raw("DROP TRIGGER campaign_contact_updated_at on campaign_contact");
+    await knex.raw(DROP_ON_UPDATE_TIMESTAMP_FUNCTION);
+};
\ No newline at end of file
diff --git a/migrations/helpers/index.js b/migrations/helpers/index.js
index 5570a8aea..6eca405f0 100644
--- a/migrations/helpers/index.js
+++ b/migrations/helpers/index.js
@@ -11,3 +11,11 @@ exports.redefineSqliteTable = async (knex, tableName, newTableFn) => {
   await knex.schema.dropTable(tableName);
   await knex.schema.createTable(tableName, newTableFn);
 };
+
+
+exports.onUpdateTrigger = table => `
+CREATE TRIGGER ${table}_updated_at
+BEFORE UPDATE ON ${table}
+FOR EACH ROW
+EXECUTE PROCEDURE on_update_timestamp();
+`
\ No newline at end of file