From 9013c493aa6e7194b06a8a597871b635a8eb1003 Mon Sep 17 00:00:00 2001 From: Andrew Kingston Date: Tue, 23 Feb 2021 14:07:19 +0000 Subject: [PATCH] Add new automation trigger for updating rows --- packages/server/src/api/controllers/row.js | 1 - packages/server/src/automations/triggers.js | 55 +++++++++++++++++++-- 2 files changed, 51 insertions(+), 5 deletions(-) diff --git a/packages/server/src/api/controllers/row.js b/packages/server/src/api/controllers/row.js index 43d831dc60..54f4e4508e 100644 --- a/packages/server/src/api/controllers/row.js +++ b/packages/server/src/api/controllers/row.js @@ -111,7 +111,6 @@ exports.patch = async function(ctx) { } row._rev = response.rev row.type = "row" - ctx.eventEmitter && ctx.eventEmitter.emitRow(`row:update`, appId, row, table) ctx.body = row ctx.status = 200 diff --git a/packages/server/src/automations/triggers.js b/packages/server/src/automations/triggers.js index e4c91e5610..fcdb8a7e83 100644 --- a/packages/server/src/automations/triggers.js +++ b/packages/server/src/automations/triggers.js @@ -13,11 +13,11 @@ const FAKE_DATETIME = "1970-01-01T00:00:00.000Z" const BUILTIN_DEFINITIONS = { ROW_SAVED: { - name: "Row Saved", + name: "Row Created", event: "row:save", icon: "ri-save-line", tagline: "Row is added to {{inputs.enriched.table.name}}", - description: "Fired when a row is saved to your database", + description: "Fired when a row is added to your database", stepId: "ROW_SAVED", inputs: {}, schema: { @@ -36,7 +36,47 @@ const BUILTIN_DEFINITIONS = { row: { type: "object", customType: "row", - description: "The new row that was saved", + description: "The new row that was created", + }, + id: { + type: "string", + description: "Row ID - can be used for updating", + }, + revision: { + type: "string", + description: "Revision of row", + }, + }, + required: ["row", "id"], + }, + }, + type: "TRIGGER", + }, + ROW_UPDATED: { + name: "Row Updated", + event: "row:update", + icon: "ri-save-line", + tagline: "Row is updated in {{inputs.enriched.table.name}}", + description: "Fired when a row is updated in your database", + stepId: "ROW_UPDATED", + inputs: {}, + schema: { + inputs: { + properties: { + tableId: { + type: "string", + customType: "table", + title: "Table", + }, + }, + required: ["tableId"], + }, + outputs: { + properties: { + row: { + type: "object", + customType: "row", + description: "The row that was updated", }, id: { type: "string", @@ -79,7 +119,7 @@ const BUILTIN_DEFINITIONS = { description: "The row that was deleted", }, }, - required: ["row", "id"], + required: ["row"], }, }, type: "TRIGGER", @@ -191,6 +231,13 @@ emitter.on("row:save", async function(event) { await queueRelevantRowAutomations(event, "row:save") }) +emitter.on("row:update", async function(event) { + if (!event || !event.row || !event.row.tableId) { + return + } + await queueRelevantRowAutomations(event, "row:update") +}) + emitter.on("row:delete", async function(event) { if (!event || !event.row || !event.row.tableId) { return