diff --git a/packages/nodes-base/credentials/MondayApi.credentials.ts b/packages/nodes-base/credentials/MondayApi.credentials.ts new file mode 100644 index 0000000000..69ebed1398 --- /dev/null +++ b/packages/nodes-base/credentials/MondayApi.credentials.ts @@ -0,0 +1,17 @@ +import { + ICredentialType, + NodePropertyTypes, +} from 'n8n-workflow'; + +export class MondayApi implements ICredentialType { + name = 'mondayApi'; + displayName = 'Monday.com API'; + properties = [ + { + displayName: 'Token V2', + name: 'apiToken', + type: 'string' as NodePropertyTypes, + default: '', + }, + ]; +} diff --git a/packages/nodes-base/nodes/Monday/BoardColumnDescription.ts b/packages/nodes-base/nodes/Monday/BoardColumnDescription.ts new file mode 100644 index 0000000000..469444bebc --- /dev/null +++ b/packages/nodes-base/nodes/Monday/BoardColumnDescription.ts @@ -0,0 +1,230 @@ +import { + INodeProperties +} from "n8n-workflow"; + +export const boardColumnOperations = [ + { + displayName: 'Operation', + name: 'operation', + type: 'options', + displayOptions: { + show: { + resource: [ + 'boardColumn', + ], + }, + }, + options: [ + { + name: 'Create', + value: 'create', + description: 'Create a new column', + }, + { + name: 'Get All', + value: 'getAll', + description: 'Get all columns', + }, + ], + default: 'create', + description: 'The operation to perform.', + }, +] as INodeProperties[]; + +export const boardColumnFields = [ +/* -------------------------------------------------------------------------- */ +/* boardColumn:create */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'options', + default: '', + typeOptions: { + loadOptionsMethod: 'getBoards', + }, + required: true, + displayOptions: { + show: { + resource: [ + 'boardColumn', + ], + operation: [ + 'create', + ], + }, + }, + }, + { + displayName: 'Title', + name: 'title', + type: 'string', + default: '', + required: true, + displayOptions: { + show: { + resource: [ + 'boardColumn', + ], + operation: [ + 'create', + ], + }, + }, + }, + { + displayName: 'Column Type', + name: 'columnType', + type: 'options', + default: '', + options: [ + { + name: 'Country', + value: 'country', + }, + { + name: 'Checkbox', + value: 'checkbox', + }, + { + name: 'Date', + value: 'date', + }, + { + name: 'Dropdown', + value: 'dropdown', + }, + { + name: 'Email', + value: 'email', + }, + { + name: 'Hour', + value: 'hour', + }, + { + name: 'Link', + value: 'Link', + }, + { + name: 'Long Text', + value: 'longText', + }, + { + name: 'Numbers', + value: 'numbers', + }, + { + name: 'People', + value: 'people', + }, + { + name: 'Person', + value: 'person', + }, + { + name: 'Phone', + value: 'phone', + }, + { + name: 'Rating', + value: 'rating', + }, + { + name: 'Status', + value: 'status', + }, + { + name: 'Tags', + value: 'tags', + }, + { + name: 'Team', + value: 'team', + }, + { + name: 'Text', + value: 'text', + }, + { + name: 'Timeline', + value: 'timeline', + }, + { + name: 'Timezone', + value: 'timezone', + }, + { + name: 'Week', + value: 'week', + }, + { + name: 'World Clock', + value: 'worldClock', + }, + ], + required: true, + displayOptions: { + show: { + resource: [ + 'boardColumn', + ], + operation: [ + 'create', + ], + }, + }, + }, + { + displayName: 'Additional Fields', + name: 'additionalFields', + type: 'collection', + placeholder: 'Add Field', + displayOptions: { + show: { + resource: [ + 'boardColumn', + ], + operation: [ + 'create', + ], + }, + }, + default: {}, + options: [ + { + displayName: 'Defauls', + name: 'defaults', + type: 'json', + typeOptions: { + alwaysOpenEditWindow: true, + }, + default: '', + description: `The new column's defaults.`, + }, + ], + }, +/* -------------------------------------------------------------------------- */ +/* boardColumn:getAll */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'options', + default: '', + typeOptions: { + loadOptionsMethod: 'getBoards', + }, + required: true, + displayOptions: { + show: { + resource: [ + 'boardColumn', + ], + operation: [ + 'getAll', + ], + }, + }, + }, +] as INodeProperties[]; diff --git a/packages/nodes-base/nodes/Monday/BoardDescription.ts b/packages/nodes-base/nodes/Monday/BoardDescription.ts new file mode 100644 index 0000000000..4acf32284e --- /dev/null +++ b/packages/nodes-base/nodes/Monday/BoardDescription.ts @@ -0,0 +1,217 @@ +import { + INodeProperties, + } from "n8n-workflow"; + +export const boardOperations = [ + { + displayName: 'Operation', + name: 'operation', + type: 'options', + displayOptions: { + show: { + resource: [ + 'board', + ], + }, + }, + options: [ + { + name: 'Archive', + value: 'archive', + description: 'Archive a board', + }, + { + name: 'Create', + value: 'create', + description: 'Create a new board', + }, + { + name: 'Get', + value: 'get', + description: 'Get a board', + }, + { + name: 'Get All', + value: 'getAll', + description: 'Get all boards', + }, + ], + default: 'create', + description: 'The operation to perform.', + }, +] as INodeProperties[]; + +export const boardFields = [ + +/* -------------------------------------------------------------------------- */ +/* board:archive */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'options', + default: '', + typeOptions: { + loadOptionsMethod: 'getBoards', + }, + required: true, + displayOptions: { + show: { + resource: [ + 'board', + ], + operation: [ + 'archive', + ], + }, + }, + description: 'Board unique identifiers.', + }, +/* -------------------------------------------------------------------------- */ +/* board:create */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Name', + name: 'name', + type: 'string', + required: true, + displayOptions: { + show: { + operation: [ + 'create', + ], + resource: [ + 'board', + ], + }, + }, + default: '', + description: `The board's name`, + }, + { + displayName: 'Kind', + name: 'kind', + type: 'options', + options: [ + { + name: 'Share', + value: 'share', + }, + { + name: 'Public', + value: 'public', + }, + { + name: 'Private', + value: 'private', + }, + ], + required: true, + displayOptions: { + show: { + operation: [ + 'create', + ], + resource: [ + 'board', + ], + }, + }, + default: '', + description: `The board's kind (public / private / share)`, + }, + { + displayName: 'Additional Fields', + name: 'additionalFields', + type: 'collection', + placeholder: 'Add Field', + displayOptions: { + show: { + operation: [ + 'create', + ], + resource: [ + 'board', + ], + }, + }, + default: {}, + options: [ + { + displayName: 'Template ID', + name: 'templateId', + type: 'number', + typeOptions: { + minValue: 0, + }, + default: 0, + description: 'Optional board template id', + }, + ], + }, +/* -------------------------------------------------------------------------- */ +/* board:get */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'string', + default: '', + required: true, + displayOptions: { + show: { + resource: [ + 'board', + ], + operation: [ + 'get', + ], + }, + }, + description: 'Board unique identifiers.', + }, +/* -------------------------------------------------------------------------- */ +/* board:getAll */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Return All', + name: 'returnAll', + type: 'boolean', + displayOptions: { + show: { + resource: [ + 'board', + ], + operation: [ + 'getAll', + ], + }, + }, + default: false, + description: 'If all results should be returned or only up to a given limit.', + }, + { + displayName: 'Limit', + name: 'limit', + type: 'number', + displayOptions: { + show: { + resource: [ + 'board', + ], + operation: [ + 'getAll', + ], + returnAll: [ + false, + ], + }, + }, + typeOptions: { + minValue: 1, + maxValue: 100, + }, + default: 50, + description: 'How many results to return.', + }, +] as INodeProperties[]; diff --git a/packages/nodes-base/nodes/Monday/BoardGroupDescription.ts b/packages/nodes-base/nodes/Monday/BoardGroupDescription.ts new file mode 100644 index 0000000000..7fded3c0cf --- /dev/null +++ b/packages/nodes-base/nodes/Monday/BoardGroupDescription.ts @@ -0,0 +1,151 @@ +import { + INodeProperties, +} from "n8n-workflow"; + +export const boardGroupOperations = [ + { + displayName: 'Operation', + name: 'operation', + type: 'options', + displayOptions: { + show: { + resource: [ + 'boardGroup', + ], + }, + }, + options: [ + { + name: 'Delete', + value: 'delete', + description: 'Delete a group in a board', + }, + { + name: 'Create', + value: 'create', + description: 'Create a group in a board', + }, + { + name: 'Get All', + value: 'getAll', + description: `Get board's groups`, + }, + ], + default: 'create', + description: 'The operation to perform.', + }, +] as INodeProperties[]; + +export const boardGroupFields = [ + +/* -------------------------------------------------------------------------- */ +/* boardGroup:create */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'options', + default: '', + typeOptions: { + loadOptionsMethod: 'getBoards', + }, + required: true, + displayOptions: { + show: { + resource: [ + 'boardGroup', + ], + operation: [ + 'create', + ], + }, + }, + }, + { + displayName: 'Name', + name: 'name', + type: 'string', + required: true, + displayOptions: { + show: { + operation: [ + 'create', + ], + resource: [ + 'boardGroup', + ], + }, + }, + default: '', + description: `The group name`, + }, +/* -------------------------------------------------------------------------- */ +/* boardGroup:delete */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'options', + typeOptions: { + loadOptionsMethod: 'getBoards', + }, + default: '', + required: true, + displayOptions: { + show: { + resource: [ + 'boardGroup', + ], + operation: [ + 'delete', + ], + }, + }, + }, + { + displayName: 'Group ID', + name: 'groupId', + type: 'options', + default: '', + typeOptions: { + loadOptionsMethod: 'getGroups', + loadOptionsDependsOn: [ + 'boardId', + ], + }, + required: true, + displayOptions: { + show: { + resource: [ + 'boardGroup', + ], + operation: [ + 'delete', + ], + }, + }, + }, +/* -------------------------------------------------------------------------- */ +/* boardGroup:getAll */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'options', + default: '', + typeOptions: { + loadOptionsMethod: 'getBoards', + }, + required: true, + displayOptions: { + show: { + resource: [ + 'boardGroup', + ], + operation: [ + 'getAll', + ], + }, + }, + }, +] as INodeProperties[]; diff --git a/packages/nodes-base/nodes/Monday/BoardItemDescription.ts b/packages/nodes-base/nodes/Monday/BoardItemDescription.ts new file mode 100644 index 0000000000..7cf7df54eb --- /dev/null +++ b/packages/nodes-base/nodes/Monday/BoardItemDescription.ts @@ -0,0 +1,380 @@ +import { + INodeProperties, + } from "n8n-workflow"; + +export const boardItemOperations = [ + { + displayName: 'Operation', + name: 'operation', + type: 'options', + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + }, + }, + options: [ + { + name: 'Create', + value: 'create', + description: `Create an item in a board's group`, + }, + { + name: 'Delete', + value: 'delete', + description: `Delete an item`, + }, + { + name: 'Get', + value: 'get', + description: 'Get an item', + }, + { + name: 'Get All', + value: 'getAll', + description: 'Get all item', + }, + { + name: 'Get By Column Value', + value: 'getByColumnValue', + description: 'Get items by column value', + }, + ], + default: 'create', + description: 'The operation to perform.', + }, +] as INodeProperties[]; + +export const boardItemFields = [ + +/* -------------------------------------------------------------------------- */ +/* boardItem:create */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'options', + typeOptions: { + loadOptionsMethod: 'getBoards', + }, + default: '', + required: true, + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'create', + ], + }, + }, + }, + { + displayName: 'Group ID', + name: 'groupId', + type: 'options', + default: '', + typeOptions: { + loadOptionsMethod: 'getGroups', + loadOptionsDependsOn: [ + 'boardId' + ], + }, + required: true, + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'create', + ], + }, + }, + }, + { + displayName: 'Name', + name: 'name', + type: 'string', + required: true, + displayOptions: { + show: { + operation: [ + 'create', + ], + resource: [ + 'boardItem', + ], + }, + }, + default: '', + description: `The new item's name.`, + }, + { + displayName: 'Additional Fields', + name: 'additionalFields', + type: 'collection', + placeholder: 'Add Field', + displayOptions: { + show: { + operation: [ + 'create', + ], + resource: [ + 'boardItem', + ], + }, + }, + default: {}, + options: [ + { + displayName: 'Column Values', + name: 'columnValues', + type: 'json', + typeOptions: { + alwaysOpenEditWindow: true, + }, + default: '', + description: 'The column values of the new item', + }, + ], + }, +/* -------------------------------------------------------------------------- */ +/* boardItem:delete */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Item ID', + name: 'itemId', + type: 'string', + default: '', + required: true, + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'delete', + ], + }, + }, + description: `Item's ID` + }, +/* -------------------------------------------------------------------------- */ +/* boardItem:get */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Item ID', + name: 'itemId', + type: 'string', + default: '', + required: true, + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'get', + ], + }, + }, + description: `Item's ID (Multiple can be added separated by comma)` + }, +/* -------------------------------------------------------------------------- */ +/* boardItem:getAll */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'options', + default: '', + typeOptions: { + loadOptionsMethod: 'getBoards', + }, + required: true, + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'getAll', + ], + }, + }, + }, + { + displayName: 'Group ID', + name: 'groupId', + default: '', + type: 'options', + typeOptions: { + loadOptionsMethod: 'getGroups', + loadOptionsDependsOn: [ + 'boardId', + ], + }, + required: true, + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'getAll', + ], + }, + }, + }, + { + displayName: 'Return All', + name: 'returnAll', + type: 'boolean', + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'getAll', + ], + }, + }, + default: false, + description: 'If all results should be returned or only up to a given limit.', + }, + { + displayName: 'Limit', + name: 'limit', + type: 'number', + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'getAll', + ], + returnAll: [ + false, + ], + }, + }, + typeOptions: { + minValue: 1, + maxValue: 100, + }, + default: 50, + description: 'How many results to return.', + }, +/* -------------------------------------------------------------------------- */ +/* boardItem:getByColumnValue */ +/* -------------------------------------------------------------------------- */ + { + displayName: 'Board ID', + name: 'boardId', + type: 'options', + typeOptions: { + loadOptionsMethod: 'getBoards', + }, + default: '', + required: true, + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'getByColumnValue', + ], + }, + }, + description: 'The unique identifier of the board.', + }, + { + displayName: 'Column ID', + name: 'columnId', + type: 'options', + typeOptions: { + loadOptionsMethod: 'getColumns', + loadOptionsDependsOn: [ + 'boardId' + ], + }, + default: '', + required: true, + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'getByColumnValue', + ], + }, + }, + description: `The column's unique identifier.`, + }, + { + displayName: 'Column Value', + name: 'columnValue', + type: 'string', + required: true, + default: '', + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'getByColumnValue', + ], + }, + }, + description: 'The column value to search items by.' + }, + { + displayName: 'Return All', + name: 'returnAll', + type: 'boolean', + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'getByColumnValue', + ], + }, + }, + default: false, + description: 'If all results should be returned or only up to a given limit.', + }, + { + displayName: 'Limit', + name: 'limit', + type: 'number', + displayOptions: { + show: { + resource: [ + 'boardItem', + ], + operation: [ + 'getByColumnValue', + ], + returnAll: [ + false, + ], + }, + }, + typeOptions: { + minValue: 1, + maxValue: 100, + }, + default: 50, + description: 'How many results to return.', + }, +] as INodeProperties[]; diff --git a/packages/nodes-base/nodes/Monday/GenericFunctions.ts b/packages/nodes-base/nodes/Monday/GenericFunctions.ts new file mode 100644 index 0000000000..2836afde1a --- /dev/null +++ b/packages/nodes-base/nodes/Monday/GenericFunctions.ts @@ -0,0 +1,68 @@ +import { + OptionsWithUri, + } from 'request'; + +import { + IExecuteFunctions, + ILoadOptionsFunctions, +} from 'n8n-core'; + +import { + IDataObject, + IHookFunctions, + IWebhookFunctions +} from 'n8n-workflow'; + +import { + get, +} from 'lodash'; + +export async function mondayApiRequest(this: IExecuteFunctions | IWebhookFunctions | IHookFunctions | ILoadOptionsFunctions, body: any = {}, option: IDataObject = {}): Promise { // tslint:disable-line:no-any + + const credentials = this.getCredentials('mondayApi'); + + if (credentials === undefined) { + throw new Error('No credentials got returned!'); + } + + const endpoint = 'https://api.monday.com/v2/'; + + let options: OptionsWithUri = { + headers: { + 'Content-Type': 'application/json', + 'Authorization': credentials.apiToken, + }, + method: 'POST', + body, + uri: endpoint, + json: true + }; + options = Object.assign({}, options, option); + try { + return await this.helpers.request!(options); + } catch (error) { + if (error.response) { + const errorMessage = error.response.body.error_message; + throw new Error(`Monday error response [${error.statusCode}]: ${errorMessage}`); + } + throw error; + } +} + +export async function mondayApiRequestAllItems(this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions, propertyName: string, body: any = {}): Promise { // tslint:disable-line:no-any + + const returnData: IDataObject[] = []; + + let responseData; + body.variables.limit = 50; + body.variables.page = 1; + + do { + responseData = await mondayApiRequest.call(this, body); + returnData.push.apply(returnData, get(responseData, propertyName)); + body.variables.page++; + } while ( + get(responseData, propertyName).length > 0 + ); + return returnData; +} diff --git a/packages/nodes-base/nodes/Monday/Monday.node.ts b/packages/nodes-base/nodes/Monday/Monday.node.ts new file mode 100644 index 0000000000..5071996fb2 --- /dev/null +++ b/packages/nodes-base/nodes/Monday/Monday.node.ts @@ -0,0 +1,617 @@ +import { + IExecuteFunctions, +} from 'n8n-core'; + +import { + IDataObject, + ILoadOptionsFunctions, + INodeTypeDescription, + INodeExecutionData, + INodeType, + INodePropertyOptions, +} from 'n8n-workflow'; + +import { + mondayApiRequest, + mondayApiRequestAllItems, +} from './GenericFunctions'; + +import { + boardFields, + boardOperations, +} from './BoardDescription'; + +import { + boardColumnFields, + boardColumnOperations, +} from './BoardColumnDescription'; + +import { + boardGroupFields, + boardGroupOperations, +} from './BoardGroupDescription'; + +import { + boardItemFields, + boardItemOperations, +} from './BoardItemDescription'; + +import { + snakeCase, + } from 'change-case'; + +interface IGraphqlBody { + query: string; + variables: IDataObject; +} + +export class Monday implements INodeType { + description: INodeTypeDescription = { + displayName: 'Monday.com', + name: 'monday.com', + icon: 'file:monday.png', + group: ['output'], + version: 1, + subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}', + description: 'Consume Monday.com API', + defaults: { + name: 'Monday.com', + color: '#000000', + }, + inputs: ['main'], + outputs: ['main'], + credentials: [ + { + name: 'mondayApi', + required: true, + }, + ], + properties: [ + { + displayName: 'Resource', + name: 'resource', + type: 'options', + options: [ + { + name: 'Board', + value: 'board', + }, + { + name: 'Board Column', + value: 'boardColumn', + }, + { + name: 'Board Group', + value: 'boardGroup', + }, + { + name: 'Board Item', + value: 'boardItem', + }, + ], + default: 'board', + description: 'Resource to consume.', + }, + //BOARD + ...boardOperations, + ...boardFields, + // BOARD COLUMN + ...boardColumnOperations, + ...boardColumnFields, + // BOARD GROUP + ...boardGroupOperations, + ...boardGroupFields, + // BOARD ITEM + ...boardItemOperations, + ...boardItemFields, + ], + }; + + methods = { + loadOptions: { + // Get all the available boards to display them to user so that he can + // select them easily + async getBoards(this: ILoadOptionsFunctions): Promise { + const returnData: INodePropertyOptions[] = []; + const body = { + query: + `query ($page: Int, $limit: Int) { + boards (page: $page, limit: $limit){ + id + description + name + } + }`, + variables: { + page: 1, + }, + }; + const boards = await mondayApiRequestAllItems.call(this, 'data.boards', body); + for (const board of boards) { + const boardName = board.name; + const boardId = board.id; + const boardDescription = board.description; + returnData.push({ + name: boardName, + value: boardId, + description: boardDescription, + }); + } + return returnData; + }, + // Get all the available columns to display them to user so that he can + // select them easily + async getColumns(this: ILoadOptionsFunctions): Promise { + const returnData: INodePropertyOptions[] = []; + const boardId = parseInt(this.getCurrentNodeParameter('boardId') as string, 10); + const body: IGraphqlBody = { + query: + `query ($boardId: [Int]) { + boards (ids: $boardId){ + columns() { + id + title + } + } + }`, + variables: { + page: 1, + boardId, + }, + }; + const { data } = await mondayApiRequest.call(this, body); + const columns = data.boards[0].columns; + for (const column of columns) { + const columnName = column.title; + const columnId = column.id; + returnData.push({ + name: columnName, + value: columnId, + }); + } + return returnData; + }, + // Get all the available groups to display them to user so that he can + // select them easily + async getGroups(this: ILoadOptionsFunctions): Promise { + const returnData: INodePropertyOptions[] = []; + const boardId = parseInt(this.getCurrentNodeParameter('boardId') as string, 10); + const body = { + query: + `query ($boardId: Int!) { + boards ( ids: [$boardId]){ + groups () { + id + title + } + } + }`, + variables: { + boardId, + }, + }; + const { data } = await mondayApiRequest.call(this, body); + const groups = data.boards[0].groups; + for (const group of groups) { + const groupName = group.title; + const groupId = group.id; + returnData.push({ + name: groupName, + value: groupId, + }); + } + return returnData; + }, + }, + }; + + async execute(this: IExecuteFunctions): Promise { + const items = this.getInputData(); + const returnData: IDataObject[] = []; + const length = items.length as unknown as number; + let responseData; + const qs: IDataObject = {}; + const resource = this.getNodeParameter('resource', 0) as string; + const operation = this.getNodeParameter('operation', 0) as string; + for (let i = 0; i < length; i++) { + if (resource === 'board') { + if (operation === 'archive') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + + const body: IGraphqlBody = { + query: + `mutation ($id: Int!) { + archive_board (board_id: $id) { + id + } + }`, + variables: { + id: boardId, + }, + }; + + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.archive_board; + } + if (operation === 'create') { + const name = this.getNodeParameter('name', i) as string; + const kind = this.getNodeParameter('kind', i) as string; + const additionalFields = this.getNodeParameter('additionalFields', i) as IDataObject; + + const body: IGraphqlBody = { + query: + `mutation ($name: String!, $kind: BoardKind!, $templateId: Int) { + create_board (board_name: $name, board_kind: $kind, template_id: $templateId) { + id + } + }`, + variables: { + name, + kind, + }, + }; + + if (additionalFields.templateId) { + body.variables.templateId = additionalFields.templateId as number; + } + + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.create_board; + } + if (operation === 'get') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + + const body: IGraphqlBody = { + query: + `query ($id: [Int]) { + boards (ids: $id){ + id + name + description + state + board_folder_id + board_kind + owner() { + id + } + } + }`, + variables: { + id: boardId, + }, + }; + + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.boards; + } + if (operation === 'getAll') { + const returnAll = this.getNodeParameter('returnAll', i) as boolean; + + const body: IGraphqlBody = { + query: + `query ($page: Int, $limit: Int) { + boards (page: $page, limit: $limit){ + id + name + description + state + board_folder_id + board_kind + owner() { + id + } + } + }`, + variables: { + page: 1, + }, + }; + + if (returnAll === true) { + responseData = await mondayApiRequestAllItems.call(this, 'data.boards', body); + } else { + body.variables.limit = this.getNodeParameter('limit', i) as number, + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.boards; + } + } + } + if (resource === 'boardColumn') { + if (operation === 'create') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + const title = this.getNodeParameter('title', i) as string; + const columnType = this.getNodeParameter('columnType', i) as string; + const additionalFields = this.getNodeParameter('additionalFields', i) as IDataObject; + + const body: IGraphqlBody = { + query: + `mutation ($boardId: Int!, $title: String!, $columnType: ColumnType, $defaults: JSON ) { + create_column (board_id: $boardId, title: $title, column_type: $columnType, defaults: $defaults) { + id + } + }`, + variables: { + boardId, + title, + columnType: snakeCase(columnType), + }, + }; + + if (additionalFields.defaults) { + try { + JSON.parse(additionalFields.defaults as string); + } catch (e) { + throw new Error('Defauls must be a valid JSON'); + } + body.variables.defaults = JSON.stringify(JSON.parse(additionalFields.defaults as string)); + } + + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.create_column; + } + if (operation === 'getAll') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + + const body: IGraphqlBody = { + query: + `query ($boardId: [Int]) { + boards (ids: $boardId){ + columns() { + id + title + type + settings_str + archived + } + } + }`, + variables: { + page: 1, + boardId, + }, + }; + + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.boards[0].columns; + } + } + if (resource === 'boardGroup') { + if (operation === 'create') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + const name = this.getNodeParameter('name', i) as string; + + const body: IGraphqlBody = { + query: + `mutation ($boardId: Int!, $groupName: String!) { + create_group (board_id: $boardId, group_name: $groupName) { + id + } + }`, + variables: { + boardId, + groupName: name, + }, + }; + + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.create_group; + } + if (operation === 'delete') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + const groupId = this.getNodeParameter('groupId', i) as string; + + const body: IGraphqlBody = { + query: + `mutation ($boardId: Int!, $groupId: String!) { + delete_group (board_id: $boardId, group_id: $groupId) { + id + } + }`, + variables: { + boardId, + groupId, + }, + }; + + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.delete_group; + } + if (operation === 'getAll') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + + const body: IGraphqlBody = { + query: + `query ($boardId: [Int]) { + boards (ids: $boardId, ){ + id + groups() { + id + title + color + position + archived + } + } + }`, + variables: { + boardId, + }, + }; + + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.boards[0].groups; + } + } + if (resource === 'boardItem') { + if (operation === 'create') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + const groupId = this.getNodeParameter('groupId', i) as string; + const itemName = this.getNodeParameter('name', i) as string; + const additionalFields = this.getNodeParameter('additionalFields', i) as IDataObject; + + const body: IGraphqlBody = { + query: + `mutation ($boardId: Int!, $groupId: String!, $itemName: String!, $columnValues: JSON) { + create_item (board_id: $boardId, group_id: $groupId, item_name: $itemName, column_values: $columnValues) { + id + } + }`, + variables: { + boardId, + groupId, + itemName, + }, + }; + + if (additionalFields.columnValues) { + try { + JSON.parse(additionalFields.columnValues as string); + } catch (e) { + throw new Error('Custom Values must be a valid JSON'); + } + body.variables.columnValues = JSON.stringify(JSON.parse(additionalFields.columnValues as string)); + } + + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.create_item; + } + if (operation === 'delete') { + const itemId = parseInt((this.getNodeParameter('itemId', i) as string), 10); + + const body: IGraphqlBody = { + query: + `mutation ($itemId: Int!) { + delete_item (item_id: $itemId) { + id + } + }`, + variables: { + itemId, + }, + }; + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.delete_item; + } + if (operation === 'get') { + const itemIds = ((this.getNodeParameter('itemId', i) as string).split(',') as string[]).map((n) => parseInt(n, 10)); + + const body: IGraphqlBody = { + query: + `query ($itemId: [Int!]){ + items (ids: $itemId) { + id + name + created_at + state + column_values() { + id + text + title + type + value + additional_info + } + } + }`, + variables: { + itemId: itemIds, + }, + }; + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.items; + } + if (operation === 'getAll') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + const groupId = this.getNodeParameter('groupId', i) as string; + const returnAll = this.getNodeParameter('returnAll', i) as boolean; + + const body: IGraphqlBody = { + query: + `query ($boardId: [Int], $groupId: [String], $page: Int, $limit: Int) { + boards (ids: $boardId) { + groups (ids: $groupId) { + id + items(limit: $limit, page: $page) { + id + name + created_at + state + column_values() { + id + text + title + type + value + additional_info + } + } + } + } + }`, + variables: { + boardId, + groupId, + }, + }; + + if (returnAll) { + responseData = await mondayApiRequestAllItems.call(this, 'data.boards[0].groups[0].items', body); + } else { + body.variables.limit = this.getNodeParameter('limit', i) as number; + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.boards[0].groups[0].items; + } + + } + if (operation === 'getByColumnValue') { + const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10); + const columnId = this.getNodeParameter('columnId', i) as string; + const columnValue = this.getNodeParameter('columnValue', i) as string; + const returnAll = this.getNodeParameter('returnAll', i) as boolean; + + const body: IGraphqlBody = { + query: + `query ($boardId: Int!, $columnId: String!, $columnValue: String!, $page: Int, $limit: Int ){ + items_by_column_values (board_id: $boardId, column_id: $columnId, column_value: $columnValue, page: $page, limit: $limit) { + id + name + created_at + state + board { + id + } + column_values() { + id + text + title + type + value + additional_info + } + } + }`, + variables: { + boardId, + columnId, + columnValue, + }, + }; + + if (returnAll) { + responseData = await mondayApiRequestAllItems.call(this, 'data.items_by_column_values', body); + } else { + body.variables.limit = this.getNodeParameter('limit', i) as number; + responseData = await mondayApiRequest.call(this, body); + responseData = responseData.data.items_by_column_values; + } + } + } + if (Array.isArray(responseData)) { + returnData.push.apply(returnData, responseData as IDataObject[]); + } else { + returnData.push(responseData as IDataObject); + } + } + return [this.helpers.returnJsonArray(returnData)]; + } +} diff --git a/packages/nodes-base/nodes/Monday/monday.png b/packages/nodes-base/nodes/Monday/monday.png new file mode 100644 index 0000000000..4246ff07d5 Binary files /dev/null and b/packages/nodes-base/nodes/Monday/monday.png differ diff --git a/packages/nodes-base/package.json b/packages/nodes-base/package.json index 00498a6596..77171e0687 100644 --- a/packages/nodes-base/package.json +++ b/packages/nodes-base/package.json @@ -74,7 +74,8 @@ "dist/credentials/MandrillApi.credentials.js", "dist/credentials/MattermostApi.credentials.js", "dist/credentials/MauticApi.credentials.js", - "dist/credentials/MoceanApi.credentials.js", + "dist/credentials/MoceanApi.credentials.js", + "dist/credentials/MondayApi.credentials.js", "dist/credentials/MongoDb.credentials.js", "dist/credentials/Msg91Api.credentials.js", "dist/credentials/MySql.credentials.js", @@ -184,7 +185,8 @@ "dist/nodes/Mautic/Mautic.node.js", "dist/nodes/Mautic/MauticTrigger.node.js", "dist/nodes/Merge.node.js", - "dist/nodes/Mocean/Mocean.node.js", + "dist/nodes/Mocean/Mocean.node.js", + "dist/nodes/Monday/Monday.node.js", "dist/nodes/MongoDb/MongoDb.node.js", "dist/nodes/MoveBinaryData.node.js", "dist/nodes/Msg91/Msg91.node.js",