n8n/packages/nodes-base/nodes/N8nTrigger.node.ts
Omar Ajoue 81d8a9f332
💥 Deprecate Activation Trigger and add two new replacement nodes (#1680)
* Add Workflow & n8n Trigger nodes

* Update nodes descriptions & icons

* Remove Activation Trigger node

* Update nodes descriptions & Add timestamp and workflow_id

* Added breaking change notice and types to events

*  Minor improvements

Co-authored-by: dali <servfrdali@yahoo.fr>
Co-authored-by: Jan Oberhauser <jan.oberhauser@gmail.com>
2021-04-24 23:14:06 +02:00

72 lines
1.8 KiB
TypeScript

import { ITriggerFunctions } from 'n8n-core';
import {
INodeType,
INodeTypeDescription,
ITriggerResponse,
} from 'n8n-workflow';
type eventType = 'Instance started' | undefined;
export class N8nTrigger implements INodeType {
description: INodeTypeDescription = {
displayName: 'n8n Trigger',
name: 'n8nTrigger',
icon: 'file:n8nTrigger.svg',
group: ['trigger'],
version: 1,
description: 'Handle events from your n8n instance',
defaults: {
name: 'n8n Trigger',
color: '#ff6d5a',
},
inputs: [],
outputs: ['main'],
properties: [
{
displayName: 'Events',
name: 'events',
type: 'multiOptions',
required: true,
default: [],
description: 'Specifies under which conditions an execution should happen:<br />' +
'- <b>Instance started</b>: Triggers when this n8n instance is started or re-started',
options: [
{
name: 'Instance started',
value: 'init',
description: 'Triggers when this n8n instance is started or re-started',
},
],
},
],
};
async trigger(this: ITriggerFunctions): Promise<ITriggerResponse> {
const events = this.getNodeParameter('events', []) as string[];
const activationMode = this.getActivationMode();
if (events.includes(activationMode)) {
let event: eventType;
if (activationMode === 'init') {
event = 'Instance started';
}
this.emit([
this.helpers.returnJsonArray([
{ event, timestamp: (new Date()).toISOString(), workflow_id: this.getWorkflow().id },
]),
]);
}
const self = this;
async function manualTriggerFunction() {
self.emit([self.helpers.returnJsonArray([{ event: 'Manual execution', timestamp: (new Date()).toISOString(), workflow_id: self.getWorkflow().id }])]);
}
return {
manualTriggerFunction,
};
}
}