feat(Venafi TLS Protect Cloud): add Venafi TLS Protect Cloud (#4253)

* ✨ Venafi TTL Protect Cloud * ⚡ Improvements * ⚡ Add authenticate generic type * ⚡ Add paired items * ⚡ Add codex * ⚡ Update package.json
2022-10-07 09:48:45 -04:00
parent 7abc7e6408
commit d36e920997
11 changed files with 1646 additions and 0 deletions
--- a/packages/nodes-base/nodes/Venafi/ProtectCloud/VenafiTlsProtectCloudTrigger.node.ts
+++ b/packages/nodes-base/nodes/Venafi/ProtectCloud/VenafiTlsProtectCloudTrigger.node.ts
@@ -0,0 +1,101 @@
+import { IPollFunctions } from 'n8n-core';
+
+import { INodeExecutionData, INodeType, INodeTypeDescription } from 'n8n-workflow';
+
+import moment from 'moment';
+
+import { venafiApiRequest } from './GenericFunctions';
+
+export class VenafiTlsProtectCloudTrigger implements INodeType {
+	description: INodeTypeDescription = {
+		displayName: 'Venafi TLS Protect Cloud Trigger',
+		name: 'venafiTlsProtectCloudTrigger',
+		icon: 'file:../venafi.svg',
+		group: ['trigger'],
+		version: 1,
+		subtitle: '={{$parameter["triggerOn"]}}',
+		description: 'Starts the workflow when Venafi events occure',
+		defaults: {
+			name: 'Venafi TLS Protect Cloud',
+			color: '#000000',
+		},
+		credentials: [
+			{
+				name: 'venafiTlsProtectCloudApi',
+				required: true,
+			},
+		],
+		polling: true,
+		inputs: [],
+		outputs: ['main'],
+		properties: [
+			{
+				displayName: 'Trigger On',
+				name: 'trigger On',
+				type: 'options',
+				options: [
+					{
+						name: 'Certificate Expired',
+						value: 'certificateExpired',
+					},
+				],
+				required: true,
+				default: 'certificateExpired',
+			},
+		],
+	};
+
+	async poll(this: IPollFunctions): Promise<INodeExecutionData[][] | null> {
+		const webhookData = this.getWorkflowStaticData('node');
+		const event = this.getNodeParameter('event') as string;
+
+		const now = moment().format();
+
+		const startDate = webhookData.lastTimeChecked || now;
+		const endDate = now;
+
+		const { certificates: certificates } = await venafiApiRequest.call(
+			this,
+			'POST',
+			`/outagedetection/v1/certificatesearch`,
+			{
+				expression: {
+					operands: [
+						{
+							operator: 'AND',
+							operands: [
+								{
+									field: 'validityEnd',
+									operator: 'LTE',
+									values: [endDate],
+								},
+								{
+									field: 'validityEnd',
+									operator: 'GTE',
+									values: [startDate],
+								},
+							],
+						},
+					],
+				},
+				ordering: {
+					orders: [
+						{
+							field: 'certificatInstanceModificationDate',
+							direction: 'DESC',
+						},
+					],
+				},
+			},
+			{},
+		);
+
+		webhookData.lastTimeChecked = endDate;
+
+		if (Array.isArray(certificates) && certificates.length) {
+			return [this.helpers.returnJsonArray(certificates)];
+		}
+
+		return null;
+	}
+}