Add new automation trigger for updating rows

This commit is contained in:
Andrew Kingston 2021-02-23 14:07:19 +00:00
parent ee47ece8ef
commit 19566d9b7d
2 changed files with 51 additions and 5 deletions

View File

@ -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

View File

@ -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