import { IExecuteFunctions, } from 'n8n-core'; import { IDataObject, ILoadOptionsFunctions, INodeExecutionData, INodePropertyOptions, INodeType, INodeTypeDescription, } from 'n8n-workflow'; import { formatBlocks, formatTitle, getBlockTypes, mapFilters, mapProperties, mapSorting, notionApiRequest, notionApiRequestAllItems, simplifyObjects, } from './GenericFunctions'; import { databaseFields, databaseOperations, } from './DatabaseDescription'; import { userFields, userOperations, } from './UserDescription'; import { pageFields, pageOperations, } from './PageDescription'; import { blockFields, blockOperations, } from './BlockDescription'; import { databasePageFields, databasePageOperations, } from './DatabasePageDescription'; export class Notion implements INodeType { description: INodeTypeDescription = { displayName: 'Notion (Beta)', name: 'notion', icon: 'file:notion.svg', group: ['output'], version: 1, subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}', description: 'Consume Notion API (Beta)', defaults: { name: 'Notion', color: '#000000', }, inputs: ['main'], outputs: ['main'], credentials: [ { name: 'notionApi', required: true, // displayOptions: { // show: { // authentication: [ // 'apiKey', // ], // }, // }, }, // { // name: 'notionOAuth2Api', // required: true, // displayOptions: { // show: { // authentication: [ // 'oAuth2', // ], // }, // }, // }, ], properties: [ // { // displayName: 'Authentication', // name: 'authentication', // type: 'options', // options: [ // { // name: 'API Key', // value: 'apiKey', // }, // { // name: 'OAuth2', // value: 'oAuth2', // }, // ], // default: 'apiKey', // description: 'The resource to operate on.', // }, { displayName: 'Resource', name: 'resource', type: 'options', options: [ { name: 'Block', value: 'block', }, { name: 'Database', value: 'database', }, { name: 'Database Page', value: 'databasePage', }, { name: 'Page', value: 'page', }, { name: 'User', value: 'user', }, ], default: 'page', description: 'Resource to consume.', }, ...blockOperations, ...blockFields, ...databaseOperations, ...databaseFields, ...databasePageOperations, ...databasePageFields, ...pageOperations, ...pageFields, ...userOperations, ...userFields, ], }; methods = { loadOptions: { async getDatabases(this: ILoadOptionsFunctions): Promise { const returnData: INodePropertyOptions[] = []; const body: IDataObject = { page_size: 100, filter: { property: 'object', value: 'database' }, }; const databases = await notionApiRequestAllItems.call(this, 'results', 'POST', `/search`, body); for (const database of databases) { returnData.push({ name: database.title[0]?.plain_text || database.id, value: database.id, }); } returnData.sort((a, b) => { if (a.name.toLocaleLowerCase() < b.name.toLocaleLowerCase()) { return -1; } if (a.name.toLocaleLowerCase() > b.name.toLocaleLowerCase()) { return 1; } return 0; }); return returnData; }, async getDatabaseProperties(this: ILoadOptionsFunctions): Promise { const returnData: INodePropertyOptions[] = []; const databaseId = this.getCurrentNodeParameter('databaseId') as string; const { properties } = await notionApiRequest.call(this, 'GET', `/databases/${databaseId}`); for (const key of Object.keys(properties)) { //remove parameters that cannot be set from the API. if (!['created_time', 'last_edited_time', 'created_by', 'last_edited_by', 'formula', 'files'].includes(properties[key].type)) { returnData.push({ name: `${key} - (${properties[key].type})`, value: `${key}|${properties[key].type}`, }); } } returnData.sort((a, b) => { if (a.name.toLocaleLowerCase() < b.name.toLocaleLowerCase()) { return -1; } if (a.name.toLocaleLowerCase() > b.name.toLocaleLowerCase()) { return 1; } return 0; }); return returnData; }, async getFilterProperties(this: ILoadOptionsFunctions): Promise { const returnData: INodePropertyOptions[] = []; const databaseId = this.getCurrentNodeParameter('databaseId') as string; const { properties } = await notionApiRequest.call(this, 'GET', `/databases/${databaseId}`); for (const key of Object.keys(properties)) { returnData.push({ name: `${key} - (${properties[key].type})`, value: `${key}|${properties[key].type}`, }); } returnData.sort((a, b) => { if (a.name.toLocaleLowerCase() < b.name.toLocaleLowerCase()) { return -1; } if (a.name.toLocaleLowerCase() > b.name.toLocaleLowerCase()) { return 1; } return 0; }); return returnData; }, async getBlockTypes(this: ILoadOptionsFunctions): Promise { return getBlockTypes(); }, async getPropertySelectValues(this: ILoadOptionsFunctions): Promise { const [name, type] = (this.getCurrentNodeParameter('&key') as string).split('|'); const databaseId = this.getCurrentNodeParameter('databaseId') as string; const resource = this.getCurrentNodeParameter('resource') as string; const operation = this.getCurrentNodeParameter('operation') as string; const { properties } = await notionApiRequest.call(this, 'GET', `/databases/${databaseId}`); if (resource === 'databasePage') { if (['multi_select', 'select'].includes(type) && operation === 'getAll') { return (properties[name][type].options) .map((option: IDataObject) => ({ name: option.name, value: option.name })); } else if (['multi_select'].includes(type) && ['create', 'update'].includes(operation)) { return (properties[name][type].options) .map((option: IDataObject) => ({ name: option.name, value: option.name })); } } return (properties[name][type].options).map((option: IDataObject) => ({ name: option.name, value: option.id })); }, async getUsers(this: ILoadOptionsFunctions): Promise { const returnData: INodePropertyOptions[] = []; const users = await notionApiRequestAllItems.call(this, 'results', 'GET', '/users'); for (const user of users) { returnData.push({ name: user.name, value: user.id, }); } return returnData; }, async getDatabaseIdFromPage(this: ILoadOptionsFunctions): Promise { const returnData: INodePropertyOptions[] = []; const pageId = this.getCurrentNodeParameter('pageId') as string; const { parent: { database_id: databaseId } } = await notionApiRequest.call(this, 'GET', `/pages/${pageId}`); const { properties } = await notionApiRequest.call(this, 'GET', `/databases/${databaseId}`); for (const key of Object.keys(properties)) { //remove parameters that cannot be set from the API. if (!['created_time', 'last_edited_time', 'created_by', 'last_edited_by', 'formula', 'files'].includes(properties[key].type)) { returnData.push({ name: `${key} - (${properties[key].type})`, value: `${key}|${properties[key].type}`, }); } } returnData.sort((a, b) => { if (a.name.toLocaleLowerCase() < b.name.toLocaleLowerCase()) { return -1; } if (a.name.toLocaleLowerCase() > b.name.toLocaleLowerCase()) { return 1; } return 0; }); return returnData; }, async getDatabaseOptionsFromPage(this: ILoadOptionsFunctions): Promise { const pageId = this.getCurrentNodeParameter('pageId') as string; const [name, type] = (this.getCurrentNodeParameter('&key') as string).split('|'); const { parent: { database_id: databaseId } } = await notionApiRequest.call(this, 'GET', `/pages/${pageId}`); const { properties } = await notionApiRequest.call(this, 'GET', `/databases/${databaseId}`); return (properties[name][type].options).map((option: IDataObject) => ({ name: option.name, value: option.id })); }, }, }; 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 timezone = this.getTimezone(); const resource = this.getNodeParameter('resource', 0) as string; const operation = this.getNodeParameter('operation', 0) as string; if (resource === 'block') { if (operation === 'append') { for (let i = 0; i < length; i++) { const blockId = this.getNodeParameter('blockId', i) as string; const body: IDataObject = { children: formatBlocks(this.getNodeParameter('blockUi.blockValues', i, []) as IDataObject[]), }; const block = await notionApiRequest.call(this, 'PATCH', `/blocks/${blockId}/children`, body); returnData.push(block); } } if (operation === 'getAll') { for (let i = 0; i < length; i++) { const blockId = this.getNodeParameter('blockId', i) as string; const returnAll = this.getNodeParameter('returnAll', i) as boolean; if (returnAll) { responseData = await notionApiRequestAllItems.call(this, 'results', 'GET', `/blocks/${blockId}/children`, {}); } else { qs.page_size = this.getNodeParameter('limit', i) as number; responseData = await notionApiRequest.call(this, 'GET', `/blocks/${blockId}/children`, {}); responseData = responseData.results; } returnData.push.apply(returnData, responseData); } } } if (resource === 'database') { if (operation === 'get') { for (let i = 0; i < length; i++) { const databaseId = this.getNodeParameter('databaseId', i) as string; responseData = await notionApiRequest.call(this, 'GET', `/databases/${databaseId}`); returnData.push(responseData); } } if (operation === 'getAll') { for (let i = 0; i < length; i++) { const body: IDataObject = { filter: { property: 'object', value: 'database' }, }; const returnAll = this.getNodeParameter('returnAll', i) as boolean; if (returnAll) { responseData = await notionApiRequestAllItems.call(this, 'results', 'POST', `/search`, body); } else { body['page_size'] = this.getNodeParameter('limit', i) as number; responseData = await notionApiRequest.call(this, 'POST', `/search`, body); responseData = responseData.results; } returnData.push.apply(returnData, responseData); } } } if (resource === 'databasePage') { if (operation === 'create') { for (let i = 0; i < length; i++) { const simple = this.getNodeParameter('simple', i) as boolean; // tslint:disable-next-line: no-any const body: { [key: string]: any } = { parent: {}, properties: {}, }; body.parent['database_id'] = this.getNodeParameter('databaseId', i) as string; const properties = this.getNodeParameter('propertiesUi.propertyValues', i, []) as IDataObject[]; if (properties.length !== 0) { body.properties = mapProperties(properties, timezone) as IDataObject; } body.children = formatBlocks(this.getNodeParameter('blockUi.blockValues', i, []) as IDataObject[]); responseData = await notionApiRequest.call(this, 'POST', '/pages', body); if (simple === true) { responseData = simplifyObjects(responseData); } returnData.push.apply(returnData, Array.isArray(responseData) ? responseData : [responseData]); } } if (operation === 'getAll') { for (let i = 0; i < length; i++) { const simple = this.getNodeParameter('simple', 0) as boolean; const databaseId = this.getNodeParameter('databaseId', i) as string; const returnAll = this.getNodeParameter('returnAll', i) as boolean; const filters = this.getNodeParameter('options.filter', i, {}) as IDataObject; const sort = this.getNodeParameter('options.sort.sortValue', i, []) as IDataObject[]; const body: IDataObject = { filter: {}, }; if (filters.singleCondition) { body['filter'] = mapFilters([filters.singleCondition] as IDataObject[], timezone); } if (filters.multipleCondition) { const { or, and } = (filters.multipleCondition as IDataObject).condition as IDataObject; if (Array.isArray(or) && or.length !== 0) { Object.assign(body.filter, { or: (or as IDataObject[]).map((data) => mapFilters([data], timezone)) }); } if (Array.isArray(and) && and.length !== 0) { Object.assign(body.filter, { and: (and as IDataObject[]).map((data) => mapFilters([data], timezone)) }); } } if (!Object.keys(body.filter as IDataObject).length) { delete body.filter; } if (sort) { //@ts-expect-error body['sorts'] = mapSorting(sort); } if (returnAll) { responseData = await notionApiRequestAllItems.call(this, 'results', 'POST', `/databases/${databaseId}/query`, body, {}); } else { body.page_size = this.getNodeParameter('limit', i) as number; responseData = await notionApiRequest.call(this, 'POST', `/databases/${databaseId}/query`, body, qs); responseData = responseData.results; } if (simple === true) { responseData = simplifyObjects(responseData); } returnData.push.apply(returnData, responseData); } } if (operation === 'update') { for (let i = 0; i < length; i++) { const pageId = this.getNodeParameter('pageId', i) as string; const simple = this.getNodeParameter('simple', i) as boolean; const properties = this.getNodeParameter('propertiesUi.propertyValues', i, []) as IDataObject[]; // tslint:disable-next-line: no-any const body: { [key: string]: any } = { properties: {}, }; if (properties.length !== 0) { body.properties = mapProperties(properties, timezone) as IDataObject; } responseData = await notionApiRequest.call(this, 'PATCH', `/pages/${pageId}`, body); if (simple === true) { responseData = simplifyObjects(responseData); } returnData.push.apply(returnData, Array.isArray(responseData) ? responseData : [responseData]); } } } if (resource === 'user') { if (operation === 'get') { for (let i = 0; i < length; i++) { const userId = this.getNodeParameter('userId', i) as string; responseData = await notionApiRequest.call(this, 'GET', `/users/${userId}`); returnData.push(responseData); } } if (operation === 'getAll') { for (let i = 0; i < length; i++) { const returnAll = this.getNodeParameter('returnAll', i) as boolean; if (returnAll) { responseData = await notionApiRequestAllItems.call(this, 'results', 'GET', '/users'); } else { qs.limit = this.getNodeParameter('limit', i) as number; responseData = await notionApiRequestAllItems.call(this, 'results', 'GET', '/users'); responseData = responseData.splice(0, qs.limit); } returnData.push.apply(returnData, responseData); } } } if (resource === 'page') { if (operation === 'create') { for (let i = 0; i < length; i++) { const simple = this.getNodeParameter('simple', i) as boolean; // tslint:disable-next-line: no-any const body: { [key: string]: any } = { parent: {}, properties: {}, }; body.parent['page_id'] = this.getNodeParameter('pageId', i) as string; body.properties = formatTitle(this.getNodeParameter('title', i) as string); body.children = formatBlocks(this.getNodeParameter('blockUi.blockValues', i, []) as IDataObject[]); responseData = await notionApiRequest.call(this, 'POST', '/pages', body); if (simple === true) { responseData = simplifyObjects(responseData); } returnData.push.apply(returnData, Array.isArray(responseData) ? responseData : [responseData]); } } if (operation === 'get') { for (let i = 0; i < length; i++) { const pageId = this.getNodeParameter('pageId', i) as string; const simple = this.getNodeParameter('simple', i) as boolean; responseData = await notionApiRequest.call(this, 'GET', `/pages/${pageId}`); if (simple === true) { responseData = simplifyObjects(responseData); } returnData.push.apply(returnData, Array.isArray(responseData) ? responseData : [responseData]); } } if (operation === 'search') { for (let i = 0; i < length; i++) { const text = this.getNodeParameter('text', i) as string; const options = this.getNodeParameter('options', i) as IDataObject; const returnAll = this.getNodeParameter('returnAll', i) as boolean; const simple = this.getNodeParameter('simple', i) as boolean; const body: IDataObject = {}; if (text) { body['query'] = text; } if (options.filter) { const filter = (options.filter as IDataObject || {}).filters as IDataObject[] || []; body['filter'] = filter; } if (options.sort) { const sort = (options.sort as IDataObject || {}).sortValue as IDataObject || {}; body['sort'] = sort; } if (returnAll) { responseData = await notionApiRequestAllItems.call(this, 'results', 'POST', '/search', body); } else { qs.limit = this.getNodeParameter('limit', i) as number; responseData = await notionApiRequestAllItems.call(this, 'results', 'POST', '/search', body); responseData = responseData.splice(0, qs.limit); } if (simple === true) { responseData = simplifyObjects(responseData); } returnData.push.apply(returnData, responseData); } } } return [this.helpers.returnJsonArray(returnData)]; } }