admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-21 20:00:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

⚡ Added improvements

Browse Source
This commit is contained in:
ricardo
2020-03-27 15:17:10 -04:00
parent 9320d415d6
commit 1050f13d54
6 changed files with 1096 additions and 523 deletions
Download Patch File Download Diff File Expand all files Collapse all files

428
packages/nodes-base/nodes/Monday/Monday.node.ts
View File

@@ -1,7 +1,7 @@
import {
BINARY_ENCODING,
IExecuteFunctions,
} from 'n8n-core';
import {
IDataObject,
ILoadOptionsFunctions,
@@ -21,7 +21,24 @@ import {
boardOperations,
} from './BoardDescription';
import { snakeCase } from 'change-case';
import {
boardColumnFields,
boardColumnOperations,
} from './BoardColumnDescription';
import {
boardGroupFields,
boardGroupOperations,
} from './BoardGroupDescription';
import {
boardItemFields,
boardItemOperations,
} from './BoardItemDescription';
import {
snakeCase,
} from 'change-case';
interface IGraphqlBody {
query: string;
@@ -59,12 +76,34 @@ export class Monday implements INodeType {
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,
],
};
@@ -87,7 +126,7 @@ export class Monday implements INodeType {
page: 1,
},
};
const boards = await mondayApiRequestAllItems.call(this, 'boards', body);
const boards = await mondayApiRequestAllItems.call(this, 'data.boards', body);
for (const board of boards) {
const boardName = board.name;
const boardId = board.id;
@@ -100,6 +139,38 @@ export class Monday implements INodeType {
}
return returnData;
},
// Get all the available columns to display them to user so that he can
// select them easily
async getColumns(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
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<INodePropertyOptions[]> {
@@ -144,38 +215,6 @@ export class Monday implements INodeType {
const operation = this.getNodeParameter('operation', 0) as string;
for (let i = 0; i < length; i++) {
if (resource === 'board') {
if (operation === 'addColumn') {
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 === 'archive') {
const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10);
@@ -219,78 +258,6 @@ export class Monday implements INodeType {
responseData = await mondayApiRequest.call(this, body);
responseData = responseData.data.create_board;
}
if (operation === 'createGroup') {
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 === 'createItem') {
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 === 'deleteGroup') {
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 === 'get') {
const boardId = parseInt(this.getNodeParameter('boardId', i) as string, 10);
@@ -341,14 +308,48 @@ export class Monday implements INodeType {
};
if (returnAll === true) {
responseData = await mondayApiRequestAllItems.call(this, 'boards', body);
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 (operation === 'getColumns') {
}
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 = {
@@ -373,7 +374,49 @@ export class Monday implements INodeType {
responseData = await mondayApiRequest.call(this, body);
responseData = responseData.data.boards[0].columns;
}
if (operation === 'getGroups') {
}
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 = {
@@ -382,6 +425,7 @@ export class Monday implements INodeType {
boards (ids: $boardId, ){
id
groups() {
id
title
color
position
@@ -398,6 +442,170 @@ export class Monday implements INodeType {
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 {