import type { IExecuteFunctions, IDataObject, ILoadOptionsFunctions, INodeExecutionData, INodePropertyOptions, INodeType, INodeTypeDescription, } from 'n8n-workflow'; import { linkFields, linkOperations } from './LinkDescription'; import { bitlyApiRequest, bitlyApiRequestAllItems } from './GenericFunctions'; export class Bitly implements INodeType { description: INodeTypeDescription = { displayName: 'Bitly', name: 'bitly', icon: 'file:bitly.svg', group: ['output'], version: 1, subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}', description: 'Consume Bitly API', defaults: { name: 'Bitly', }, inputs: ['main'], outputs: ['main'], credentials: [ { name: 'bitlyApi', required: true, displayOptions: { show: { authentication: ['accessToken'], }, }, }, { name: 'bitlyOAuth2Api', required: true, displayOptions: { show: { authentication: ['oAuth2'], }, }, }, ], properties: [ { displayName: 'Authentication', name: 'authentication', type: 'options', options: [ { name: 'Access Token', value: 'accessToken', }, { name: 'OAuth2', value: 'oAuth2', }, ], default: 'accessToken', }, { displayName: 'Resource', name: 'resource', type: 'options', noDataExpression: true, options: [ { name: 'Link', value: 'link', }, ], default: 'link', }, ...linkOperations, ...linkFields, ], }; methods = { loadOptions: { // Get all the available groups to display them to user so that they can // select them easily async getGroups(this: ILoadOptionsFunctions): Promise { const returnData: INodePropertyOptions[] = []; const groups = await bitlyApiRequestAllItems.call(this, 'groups', 'GET', '/groups'); for (const group of groups) { const groupName = group.name; const groupId = group.guid; returnData.push({ name: groupName, value: groupId, }); } return returnData; }, // Get all the available tags to display them to user so that they can // select them easily async getTags(this: ILoadOptionsFunctions): Promise { const groupId = this.getCurrentNodeParameter('group') as string; const returnData: INodePropertyOptions[] = []; const tags = await bitlyApiRequestAllItems.call( this, 'tags', 'GET', `groups/${groupId}/tags`, ); for (const tag of tags) { const tagName = tag; const tagId = tag; returnData.push({ name: tagName, value: tagId, }); } return returnData; }, }, }; async execute(this: IExecuteFunctions): Promise { const items = this.getInputData(); const returnData: INodeExecutionData[] = []; const length = items.length; let responseData; const resource = this.getNodeParameter('resource', 0); const operation = this.getNodeParameter('operation', 0); for (let i = 0; i < length; i++) { try { if (resource === 'link') { if (operation === 'create') { const longUrl = this.getNodeParameter('longUrl', i) as string; const additionalFields = this.getNodeParameter('additionalFields', i); const body: IDataObject = { long_url: longUrl, }; if (additionalFields.title) { body.title = additionalFields.title as string; } if (additionalFields.domain) { body.domain = additionalFields.domain as string; } if (additionalFields.group) { body.group = additionalFields.group as string; } if (additionalFields.tags) { body.tags = additionalFields.tags as string[]; } const deeplinks = (this.getNodeParameter('deeplink', i) as IDataObject) .deeplinkUi as IDataObject[]; if (deeplinks) { for (const deeplink of deeplinks) { //@ts-ignore body.deeplinks.push({ app_uri_path: deeplink.appUriPath, install_type: deeplink.installType, install_url: deeplink.installUrl, app_id: deeplink.appId, }); } } responseData = await bitlyApiRequest.call(this, 'POST', '/bitlinks', body); } if (operation === 'update') { const linkId = this.getNodeParameter('id', i) as string; const updateFields = this.getNodeParameter('updateFields', i); const body: IDataObject = {}; if (updateFields.longUrl) { body.long_url = updateFields.longUrl as string; } if (updateFields.title) { body.title = updateFields.title as string; } if (updateFields.archived !== undefined) { body.archived = updateFields.archived as boolean; } if (updateFields.group) { body.group = updateFields.group as string; } if (updateFields.tags) { body.tags = updateFields.tags as string[]; } const deeplinks = (this.getNodeParameter('deeplink', i) as IDataObject) .deeplinkUi as IDataObject[]; if (deeplinks) { for (const deeplink of deeplinks) { //@ts-ignore body.deeplinks.push({ app_uri_path: deeplink.appUriPath, install_type: deeplink.installType, install_url: deeplink.installUrl, app_id: deeplink.appId, }); } } responseData = await bitlyApiRequest.call(this, 'PATCH', `/bitlinks/${linkId}`, body); } if (operation === 'get') { const linkId = this.getNodeParameter('id', i) as string; responseData = await bitlyApiRequest.call(this, 'GET', `/bitlinks/${linkId}`); } } const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray(responseData as IDataObject[]), { itemData: { item: i } }, ); returnData.push(...executionData); } catch (error) { if (this.continueOnFail(error)) { returnData.push({ error: error.message, json: {}, itemIndex: i }); continue; } throw error; } } return [returnData]; } }