mirror of
https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git
synced 2025-12-17 10:02:05 +00:00
✨ Add Bitwarden node (#1401)
* Update package.json * Add first implementation of credentials * Add Bitwarden SVG file * Add first implementation of generic functions * Add scaffolding for resources and operations * Fill in events, groups and members * Fill in organizations and policies * Add collection description * Clean up credentials params * Implement collection:update * Add event description * Add group description * Add member description * Complete all descriptions * Remove OAuth2 from credentials name * Prevent excessive access token retrievals * Complete collection:update * Refactor getAll operations * Add group:getAll * Add group:create * Add group:update * Add group:updateMembers * Add user:create * Add member:updateGroups * Remove organization resource * Remove policy resource * Add member:update * Reposition divider comments * Refactor resource loaders * Document generic functions * Refactor returnAll and limit * Introduce minor improvements * ⚡ Improvements * ⚡ Minor improvements * ⚡ Remove not needed code Co-authored-by: ricardo <ricardoespinoza105@gmail.com> Co-authored-by: Jan Oberhauser <jan.oberhauser@gmail.com>
This commit is contained in:
Iván Ovejero
500
packages/nodes-base/nodes/Bitwarden/Bitwarden.node.ts
Normal file
500
packages/nodes-base/nodes/Bitwarden/Bitwarden.node.ts
Normal file
@@ -0,0 +1,500 @@
|
||||
import {
|
||||
IExecuteFunctions,
|
||||
} from 'n8n-core';
|
||||
|
||||
import {
|
||||
IDataObject,
|
||||
ILoadOptionsFunctions,
|
||||
INodeExecutionData,
|
||||
INodeType,
|
||||
INodeTypeDescription,
|
||||
} from 'n8n-workflow';
|
||||
|
||||
import {
|
||||
bitwardenApiRequest as tokenlessBitwardenApiRequest,
|
||||
getAccessToken,
|
||||
handleGetAll as tokenlessHandleGetAll,
|
||||
loadResource,
|
||||
} from './GenericFunctions';
|
||||
|
||||
import {
|
||||
collectionFields,
|
||||
collectionOperations,
|
||||
CollectionUpdateFields,
|
||||
} from './descriptions/CollectionDescription';
|
||||
|
||||
import {
|
||||
eventFields,
|
||||
eventOperations,
|
||||
} from './descriptions/EventDescription';
|
||||
|
||||
import {
|
||||
GroupCreationAdditionalFields,
|
||||
groupFields,
|
||||
groupOperations,
|
||||
GroupUpdateFields,
|
||||
} from './descriptions/GroupDescription';
|
||||
|
||||
import {
|
||||
MemberCreationAdditionalFields,
|
||||
memberFields,
|
||||
memberOperations,
|
||||
MemberUpdateFields,
|
||||
} from './descriptions/MemberDescription';
|
||||
|
||||
import {
|
||||
isEmpty,
|
||||
partialRight,
|
||||
} from 'lodash';
|
||||
|
||||
export class Bitwarden implements INodeType {
|
||||
description: INodeTypeDescription = {
|
||||
displayName: 'Bitwarden',
|
||||
name: 'bitwarden',
|
||||
icon: 'file:bitwarden.svg',
|
||||
group: ['transform'],
|
||||
version: 1,
|
||||
subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}',
|
||||
description: 'Consume the Bitwarden API',
|
||||
defaults: {
|
||||
name: 'Bitwarden',
|
||||
color: '#175DDC',
|
||||
},
|
||||
inputs: ['main'],
|
||||
outputs: ['main'],
|
||||
credentials: [
|
||||
{
|
||||
name: 'bitwardenApi',
|
||||
required: true,
|
||||
},
|
||||
],
|
||||
properties: [
|
||||
{
|
||||
displayName: 'Resource',
|
||||
name: 'resource',
|
||||
type: 'options',
|
||||
options: [
|
||||
{
|
||||
name: 'Collection',
|
||||
value: 'collection',
|
||||
},
|
||||
{
|
||||
name: 'Event',
|
||||
value: 'event',
|
||||
},
|
||||
{
|
||||
name: 'Group',
|
||||
value: 'group',
|
||||
},
|
||||
{
|
||||
name: 'Member',
|
||||
value: 'member',
|
||||
},
|
||||
],
|
||||
default: 'collection',
|
||||
description: 'Resource to consume',
|
||||
},
|
||||
...collectionOperations,
|
||||
...collectionFields,
|
||||
...eventOperations,
|
||||
...eventFields,
|
||||
...groupOperations,
|
||||
...groupFields,
|
||||
...memberOperations,
|
||||
...memberFields,
|
||||
],
|
||||
};
|
||||
|
||||
methods = {
|
||||
loadOptions: {
|
||||
async getGroups(this: ILoadOptionsFunctions) {
|
||||
return await loadResource.call(this, 'groups');
|
||||
},
|
||||
|
||||
async getCollections(this: ILoadOptionsFunctions) {
|
||||
return await loadResource.call(this, 'collections');
|
||||
},
|
||||
},
|
||||
};
|
||||
|
||||
async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
|
||||
const items = this.getInputData();
|
||||
|
||||
const resource = this.getNodeParameter('resource', 0) as string;
|
||||
const operation = this.getNodeParameter('operation', 0) as string;
|
||||
|
||||
let responseData;
|
||||
const returnData: IDataObject[] = [];
|
||||
|
||||
const token = await getAccessToken.call(this);
|
||||
const bitwardenApiRequest = partialRight(tokenlessBitwardenApiRequest, token);
|
||||
const handleGetAll = partialRight(tokenlessHandleGetAll, token);
|
||||
|
||||
for (let i = 0; i < items.length; i++) {
|
||||
|
||||
if (resource === 'collection') {
|
||||
|
||||
// *********************************************************************
|
||||
// collection
|
||||
// *********************************************************************
|
||||
|
||||
if (operation === 'delete') {
|
||||
|
||||
// ----------------------------------
|
||||
// collection: delete
|
||||
// ----------------------------------
|
||||
|
||||
const id = this.getNodeParameter('collectionId', i);
|
||||
const endpoint = `/public/collections/${id}`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'DELETE', endpoint, {}, {});
|
||||
responseData = { success: true };
|
||||
|
||||
} else if (operation === 'get') {
|
||||
|
||||
// ----------------------------------
|
||||
// collection: get
|
||||
// ----------------------------------
|
||||
|
||||
const id = this.getNodeParameter('collectionId', i);
|
||||
const endpoint = `/public/collections/${id}`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'GET', endpoint, {}, {});
|
||||
|
||||
} else if (operation === 'getAll') {
|
||||
|
||||
// ----------------------------------
|
||||
// collection: getAll
|
||||
// ----------------------------------
|
||||
|
||||
const endpoint = '/public/collections';
|
||||
responseData = await handleGetAll.call(this, i, 'GET', endpoint, {}, {});
|
||||
|
||||
} else if (operation === 'update') {
|
||||
|
||||
// ----------------------------------
|
||||
// collection: update
|
||||
// ----------------------------------
|
||||
|
||||
const updateFields = this.getNodeParameter('updateFields', i) as CollectionUpdateFields;
|
||||
|
||||
if (isEmpty(updateFields)) {
|
||||
throw new Error(`Please enter at least one field to update for the ${resource}.`);
|
||||
}
|
||||
|
||||
const { groups, externalId } = updateFields;
|
||||
|
||||
const body = {} as IDataObject;
|
||||
|
||||
if (groups) {
|
||||
body.groups = groups.map((groupId) => ({
|
||||
id: groupId,
|
||||
ReadOnly: false,
|
||||
}));
|
||||
}
|
||||
|
||||
if (externalId) {
|
||||
body.externalId = externalId;
|
||||
}
|
||||
|
||||
const id = this.getNodeParameter('collectionId', i);
|
||||
const endpoint = `/public/collections/${id}`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'PUT', endpoint, {}, body);
|
||||
|
||||
}
|
||||
|
||||
} else if (resource === 'event') {
|
||||
|
||||
// *********************************************************************
|
||||
// event
|
||||
// *********************************************************************
|
||||
|
||||
if (operation === 'getAll') {
|
||||
|
||||
// ----------------------------------
|
||||
// event: getAll
|
||||
// ----------------------------------
|
||||
|
||||
const filters = this.getNodeParameter('filters', i) as IDataObject;
|
||||
const qs = isEmpty(filters) ? {} : filters;
|
||||
const endpoint = '/public/events';
|
||||
responseData = await handleGetAll.call(this, i, 'GET', endpoint, qs, {});
|
||||
|
||||
}
|
||||
|
||||
} else if (resource === 'group') {
|
||||
|
||||
// *********************************************************************
|
||||
// group
|
||||
// *********************************************************************
|
||||
|
||||
if (operation === 'create') {
|
||||
|
||||
// ----------------------------------
|
||||
// group: create
|
||||
// ----------------------------------
|
||||
|
||||
const body = {
|
||||
name: this.getNodeParameter('name', i),
|
||||
AccessAll: this.getNodeParameter('accessAll', i),
|
||||
} as IDataObject;
|
||||
|
||||
const {
|
||||
collections,
|
||||
externalId,
|
||||
} = this.getNodeParameter('additionalFields', i) as GroupCreationAdditionalFields;
|
||||
|
||||
if (collections) {
|
||||
body.collections = collections.map((collectionId) => ({
|
||||
id: collectionId,
|
||||
ReadOnly: false,
|
||||
}));
|
||||
}
|
||||
|
||||
if (externalId) {
|
||||
body.externalId = externalId;
|
||||
}
|
||||
|
||||
const endpoint = '/public/groups';
|
||||
responseData = await bitwardenApiRequest.call(this, 'POST', endpoint, {}, body);
|
||||
|
||||
} else if (operation === 'delete') {
|
||||
|
||||
// ----------------------------------
|
||||
// group: delete
|
||||
// ----------------------------------
|
||||
|
||||
const id = this.getNodeParameter('groupId', i);
|
||||
const endpoint = `/public/groups/${id}`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'DELETE', endpoint, {}, {});
|
||||
responseData = { success: true };
|
||||
|
||||
} else if (operation === 'get') {
|
||||
|
||||
// ----------------------------------
|
||||
// group: get
|
||||
// ----------------------------------
|
||||
|
||||
const id = this.getNodeParameter('groupId', i);
|
||||
const endpoint = `/public/groups/${id}`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'GET', endpoint, {}, {});
|
||||
|
||||
} else if (operation === 'getAll') {
|
||||
|
||||
// ----------------------------------
|
||||
// group: getAll
|
||||
// ----------------------------------
|
||||
|
||||
const endpoint = '/public/groups';
|
||||
responseData = await handleGetAll.call(this, i, 'GET', endpoint, {}, {});
|
||||
|
||||
} else if (operation === 'getMembers') {
|
||||
|
||||
// ----------------------------------
|
||||
// group: getMembers
|
||||
// ----------------------------------
|
||||
|
||||
const id = this.getNodeParameter('groupId', i);
|
||||
const endpoint = `/public/groups/${id}/member-ids`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'GET', endpoint, {}, {});
|
||||
responseData = responseData.map((memberId: string) => ({ memberId }));
|
||||
|
||||
} else if (operation === 'update') {
|
||||
|
||||
// ----------------------------------
|
||||
// group: update
|
||||
// ----------------------------------
|
||||
|
||||
const body = {} as IDataObject;
|
||||
|
||||
const updateFields = this.getNodeParameter('updateFields', i) as GroupUpdateFields;
|
||||
|
||||
if (isEmpty(updateFields)) {
|
||||
throw new Error(`Please enter at least one field to update for the ${resource}.`);
|
||||
}
|
||||
|
||||
const { name, collections, externalId, accessAll } = updateFields;
|
||||
|
||||
if (collections) {
|
||||
body.collections = collections.map((collectionId) => ({
|
||||
id: collectionId,
|
||||
ReadOnly: false,
|
||||
}));
|
||||
}
|
||||
|
||||
if (name) {
|
||||
body.name = name;
|
||||
}
|
||||
|
||||
if (externalId) {
|
||||
body.externalId = externalId;
|
||||
}
|
||||
|
||||
if (accessAll !== undefined) {
|
||||
body.AccessAll = accessAll;
|
||||
}
|
||||
|
||||
const id = this.getNodeParameter('groupId', i);
|
||||
const endpoint = `/public/groups/${id}`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'PUT', endpoint, {}, body);
|
||||
|
||||
} else if (operation === 'updateMembers') {
|
||||
|
||||
// ----------------------------------
|
||||
// group: updateMembers
|
||||
// ----------------------------------
|
||||
|
||||
const memberIds = this.getNodeParameter('memberIds', i) as string;
|
||||
|
||||
const body = {
|
||||
memberIds: memberIds.includes(',') ? memberIds.split(',') : [memberIds],
|
||||
};
|
||||
|
||||
const groupId = this.getNodeParameter('groupId', i);
|
||||
const endpoint = `/public/groups/${groupId}/member-ids`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'PUT', endpoint, {}, body);
|
||||
responseData = { success: true };
|
||||
}
|
||||
|
||||
} else if (resource === 'member') {
|
||||
|
||||
// *********************************************************************
|
||||
// member
|
||||
// *********************************************************************
|
||||
|
||||
if (operation === 'create') {
|
||||
|
||||
// ----------------------------------
|
||||
// member: create
|
||||
// ----------------------------------
|
||||
|
||||
const body = {
|
||||
email: this.getNodeParameter('email', i),
|
||||
type: this.getNodeParameter('type', i),
|
||||
AccessAll: this.getNodeParameter('accessAll', i),
|
||||
} as IDataObject;
|
||||
|
||||
const {
|
||||
collections,
|
||||
externalId,
|
||||
} = this.getNodeParameter('additionalFields', i) as MemberCreationAdditionalFields;
|
||||
|
||||
if (collections) {
|
||||
body.collections = collections.map((collectionId) => ({
|
||||
id: collectionId,
|
||||
ReadOnly: false,
|
||||
}));
|
||||
}
|
||||
|
||||
if (externalId) {
|
||||
body.externalId = externalId;
|
||||
}
|
||||
|
||||
const endpoint = '/public/members/';
|
||||
responseData = await bitwardenApiRequest.call(this, 'POST', endpoint, {}, body);
|
||||
|
||||
} else if (operation === 'delete') {
|
||||
|
||||
// ----------------------------------
|
||||
// member: delete
|
||||
// ----------------------------------
|
||||
|
||||
const id = this.getNodeParameter('memberId', i);
|
||||
const endpoint = `/public/members/${id}`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'DELETE', endpoint, {}, {});
|
||||
responseData = { success: true };
|
||||
|
||||
} else if (operation === 'get') {
|
||||
|
||||
// ----------------------------------
|
||||
// member: get
|
||||
// ----------------------------------
|
||||
|
||||
const id = this.getNodeParameter('memberId', i);
|
||||
const endpoint = `/public/members/${id}`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'GET', endpoint, {}, {});
|
||||
|
||||
} else if (operation === 'getAll') {
|
||||
|
||||
// ----------------------------------
|
||||
// member: getAll
|
||||
// ----------------------------------
|
||||
|
||||
const endpoint = '/public/members';
|
||||
responseData = await handleGetAll.call(this, i, 'GET', endpoint, {}, {});
|
||||
|
||||
} else if (operation === 'getGroups') {
|
||||
|
||||
// ----------------------------------
|
||||
// member: getGroups
|
||||
// ----------------------------------
|
||||
|
||||
const id = this.getNodeParameter('memberId', i);
|
||||
const endpoint = `/public/members/${id}/group-ids`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'GET', endpoint, {}, {});
|
||||
responseData = responseData.map((groupId: string) => ({ groupId }));
|
||||
|
||||
} else if (operation === 'update') {
|
||||
|
||||
// ----------------------------------
|
||||
// member: update
|
||||
// ----------------------------------
|
||||
|
||||
const body = {} as IDataObject;
|
||||
|
||||
const updateFields = this.getNodeParameter('updateFields', i) as MemberUpdateFields;
|
||||
|
||||
if (isEmpty(updateFields)) {
|
||||
throw new Error(`Please enter at least one field to update for the ${resource}.`);
|
||||
}
|
||||
|
||||
const { accessAll, collections, externalId, type } = updateFields;
|
||||
|
||||
if (accessAll !== undefined) {
|
||||
body.AccessAll = accessAll;
|
||||
}
|
||||
|
||||
if (collections) {
|
||||
body.collections = collections.map((collectionId) => ({
|
||||
id: collectionId,
|
||||
ReadOnly: false,
|
||||
}));
|
||||
}
|
||||
|
||||
if (externalId) {
|
||||
body.externalId = externalId;
|
||||
}
|
||||
|
||||
if (type !== undefined) {
|
||||
body.Type = type;
|
||||
}
|
||||
|
||||
const id = this.getNodeParameter('memberId', i);
|
||||
const endpoint = `/public/members/${id}`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'PUT', endpoint, {}, body);
|
||||
|
||||
} else if (operation === 'updateGroups') {
|
||||
|
||||
// ----------------------------------
|
||||
// member: updateGroups
|
||||
// ----------------------------------
|
||||
|
||||
const groupIds = this.getNodeParameter('groupIds', i) as string;
|
||||
|
||||
const body = {
|
||||
groupIds: groupIds.includes(',') ? groupIds.split(',') : [groupIds],
|
||||
};
|
||||
|
||||
const memberId = this.getNodeParameter('memberId', i);
|
||||
const endpoint = `/public/members/${memberId}/group-ids`;
|
||||
responseData = await bitwardenApiRequest.call(this, 'PUT', endpoint, {}, body);
|
||||
responseData = { success: true };
|
||||
}
|
||||
}
|
||||
|
||||
Array.isArray(responseData)
|
||||
? returnData.push(...responseData)
|
||||
: returnData.push(responseData);
|
||||
}
|
||||
|
||||
return [this.helpers.returnJsonArray(returnData)];
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user