import { IExecuteFunctions } from 'n8n-core'; import { IDataObject, ILoadOptionsFunctions, INodeExecutionData, INodePropertyOptions, INodeType, INodeTypeDescription, } from 'n8n-workflow'; import { collectionFields, collectionOperations, } from './CollectionDescription'; import { createCollectionEntry, getAllCollectionEntries, getAllCollectionNames, } from './CollectionFunctions'; import { formFields, formOperations } from './FormDescription'; import { submitForm } from './FormFunctions'; import { createDataFromParameters } from './GenericFunctions'; import { singletonFields, singletonOperations, } from './SingletonDescription'; import { getAllSingletonNames, getSingleton, } from './SingletonFunctions'; export class Cockpit implements INodeType { description: INodeTypeDescription = { displayName: 'Cockpit', name: 'cockpit', icon: 'file:cockpit.png', group: ['output'], version: 1, subtitle: '={{ $parameter["operation"] + ": " + $parameter["resource"] }}', description: 'Consume Cockpit API', defaults: { name: 'Cockpit', color: '#000000', }, inputs: ['main'], outputs: ['main'], credentials: [ { name: 'cockpitApi', required: true, }, ], properties: [ { displayName: 'Resource', name: 'resource', type: 'options', default: 'collection', description: 'Resource to consume.', options: [ { name: 'Collection', value: 'collection', }, { name: 'Form', value: 'form', }, { name: 'Singleton', value: 'singleton', }, ], }, ...collectionOperations, ...collectionFields, ...formOperations, ...formFields, ...singletonOperations, ...singletonFields, ], }; methods = { loadOptions: { async getCollections(this: ILoadOptionsFunctions): Promise { const collections = await getAllCollectionNames.call(this); return collections.map(itemName => { return { name: itemName, value: itemName, }; }); }, async getSingletons(this: ILoadOptionsFunctions): Promise { const singletons = await getAllSingletonNames.call(this); return singletons.map(itemName => { return { name: itemName, value: itemName, }; }); }, }, }; async execute(this: IExecuteFunctions): Promise { const items = this.getInputData(); const returnData: IDataObject[] = []; const length = items.length as unknown as number; const resource = this.getNodeParameter('resource', 0) as string; const operation = this.getNodeParameter('operation', 0) as string; let responseData; for (let i = 0; i < length; i++) { if (resource === 'collection') { const collectionName = this.getNodeParameter('collection', i) as string; if (operation === 'create') { const data = createDataFromParameters.call(this, i); responseData = await createCollectionEntry.call(this, collectionName, data); } else if (operation === 'getAll') { const options = this.getNodeParameter('options', i) as IDataObject; const returnAll = this.getNodeParameter('returnAll', i) as boolean; if (!returnAll) { options.limit = this.getNodeParameter('limit', i) as number; } responseData = await getAllCollectionEntries.call(this, collectionName, options); } else if (operation === 'update') { const id = this.getNodeParameter('id', i) as string; const data = createDataFromParameters.call(this, i); responseData = await createCollectionEntry.call(this, collectionName, data, id); } } else if (resource === 'form') { const formName = this.getNodeParameter('form', i) as string; if (operation === 'submit') { const form = createDataFromParameters.call(this, i); responseData = await submitForm.call(this, formName, form); } } else if (resource === 'singleton') { const singletonName = this.getNodeParameter('singleton', i) as string; if (operation === 'get') { responseData = await getSingleton.call(this, singletonName); } } if (Array.isArray(responseData)) { returnData.push.apply(returnData, responseData as IDataObject[]); } else { returnData.push(responseData as IDataObject); } } return [this.helpers.returnJsonArray(returnData)]; } }