From 5f3d1e88804883820be669ed672a756394d1534a Mon Sep 17 00:00:00 2001 From: Gustavo Inacio Date: Thu, 24 Oct 2024 23:19:29 +0200 Subject: [PATCH] indexer-agent: update trigger and add needed variables Signed-off-by: Gustavo Inacio --- .../src/db/migrations/17-edit-cost-models-trigger.ts | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/packages/indexer-agent/src/db/migrations/17-edit-cost-models-trigger.ts b/packages/indexer-agent/src/db/migrations/17-edit-cost-models-trigger.ts index 62696ee82..849fbfe7e 100644 --- a/packages/indexer-agent/src/db/migrations/17-edit-cost-models-trigger.ts +++ b/packages/indexer-agent/src/db/migrations/17-edit-cost-models-trigger.ts @@ -31,10 +31,10 @@ export async function up({ context }: Context): Promise { PERFORM pg_notify('cost_models_update_notification', format('{"tg_op": "DELETE", "deployment": "%s"}', OLD.deployment)); RETURN OLD; ELSIF TG_OP = 'INSERT' THEN - PERFORM pg_notify('cost_models_update_notification', format('{"tg_op": "INSERT", "deployment": "%s", "model": "%s"}', NEW.deployment, NEW.model)); + PERFORM pg_notify('cost_models_update_notification', format('{"tg_op": "INSERT", "deployment": "%s", "model": "%s", "variables": "%s"}', NEW.deployment, NEW.model, NEW.variables)); RETURN NEW; ELSE - PERFORM pg_notify('cost_models_update_notification', format('{"tg_op": "%s", "deployment": "%s", "model": "%s"}', NEW.deployment, NEW.model)); + PERFORM pg_notify('cost_models_update_notification', format('{"tg_op": "%s", "deployment": "%s", "model": "%s", "variables": "%s" }', NEW.deployment, NEW.model, NEW.variables)); RETURN NEW; END IF; END; @@ -52,5 +52,11 @@ export async function up({ context }: Context): Promise { export async function down({ context }: Context): Promise { const { queryInterface, logger } = context logger.info(`Drop function, trigger, indices, and table`) - queryInterface.removeColumn('scalar_tap_receipts_invalid', 'error_log') + await queryInterface.sequelize.query( + 'DROP TRIGGER IF EXISTS cost_models_update ON "CostModelsHistory" CASCADE;', + ) + + await queryInterface.sequelize.query( + 'DROP FUNCTION IF EXISTS cost_models_update_notify() CASCADE;', + ) }