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

✨ Add query support to people:getAll - Google Contacts (#2552)

Browse Source 
* Add query support to people:getAll

* ⚡ Fix typo
This commit is contained in:
Ricardo Espinoza
2021-12-11 11:00:47 -05:00
committed by GitHub
parent 4adb9b83c5
commit 556e8e9417
2 changed files with 64 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
packages/nodes-base/nodes/Google/Contacts/GoogleContacts.node.ts
View File

@@ -24,6 +24,7 @@ import {
} from './ContactDescription';
import * as moment from 'moment';
import { IData } from '../Analytics/Interfaces';
export class GoogleContacts implements INodeType {
description: INodeTypeDescription = {
@@ -264,11 +265,19 @@ export class GoogleContacts implements INodeType {
responseData.contactId = responseData.resourceName.split('/')[1];
}
//https://developers.google.com/people/api/rest/v1/people.connections/list
//https://developers.google.com/people/api/rest/v1/people/searchContacts
if (operation === 'getAll') {
const returnAll = this.getNodeParameter('returnAll', i) as boolean;
const fields = this.getNodeParameter('fields', i) as string[];
const options = this.getNodeParameter('options', i) as IDataObject;
const options = this.getNodeParameter('options', i, {}) as IDataObject;
const rawData = this.getNodeParameter('rawData', i) as boolean;
const useQuery = this.getNodeParameter('useQuery', i) as boolean;
const endpoint = (useQuery) ? ':searchContacts' : '/me/connections';
if (useQuery) {
qs.query = this.getNodeParameter('query', i) as string;
}
if (options.sortOrder) {
qs.sortOrder = options.sortOrder as number;
@@ -280,25 +289,35 @@ export class GoogleContacts implements INodeType {
qs.personFields = (fields as string[]).join(',');
}
if (useQuery) {
qs.readMask = qs.personFields;
delete qs.personFields;
}
if (returnAll) {
responseData = await googleApiRequestAllItems.call(
this,
'connections',
(useQuery) ? 'results' : 'connections',
'GET',
`/people/me/connections`,
`/people${endpoint}`,
{},
qs,
);
if (useQuery) {
responseData = responseData.map((result: IDataObject) => result.person);
}
} else {
qs.pageSize = this.getNodeParameter('limit', i) as number;
responseData = await googleApiRequest.call(
this,
'GET',
`/people/me/connections`,
`/people${endpoint}`,
{},
qs,
);
responseData = responseData.connections;
responseData = responseData.connections || responseData.results.map((result: IDataObject) => result.person);
}
if (!rawData) {