mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-01-12 13:27:31 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add deepdata integration connection support

Browse source
This commit is contained in:
quansenB 2019-11-03 22:25:45 +01:00
parent e029468171
commit 5ca6383048
1 changed files with 23 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

51
packages/nodes-base/nodes/ActiveCampaign/ActiveCampaign.node.ts
View file

@ -110,7 +110,7 @@ export class ActiveCampaign implements INodeType {
{
name: 'Connection',
value: 'connection'
}
},
{
name: 'E-commerce Order',
value: 'ecommerceOrder',
@ -272,7 +272,9 @@ export class ActiveCampaign implements INodeType {
endpoint = `/api/3/contacts/${contactId}`;
dataKey = 'contact';
body.contact = {} as IDataObject;
const updateFields = this.getNodeParameter('updateFields', i) as IDataObject;
addAdditionalFields(body.contact as IDataObject, updateFields);
@ -401,21 +403,30 @@ export class ActiveCampaign implements INodeType {
requestMethod = 'POST';
const updateIfExists = this.getNodeParameter('updateIfExists', i) as boolean;
if (updateIfExists === true) {
endpoint = '/api/3/connection/sync';
} else {
endpoint = '/api/3/connections';
}
dataKey = 'connection';
endpoint = '/api/3/connections';
body.connection = {
email: this.getNodeParameter('email', i) as string,
service: this.getNodeParameter('service', i) as string,
externalid: this.getNodeParameter('externalid', i) as string,
name: this.getNodeParameter('name', i) as string,
logoUrl: this.getNodeParameter('logoUrl', i) as string,
linkUrl: this.getNodeParameter('linkUrl', i) as string,
} as IDataObject;
const additionalFields = this.getNodeParameter('additionalFields', i) as IDataObject;
addAdditionalFields(body.connection as IDataObject, additionalFields);
} else if (operation === 'update') {
// ----------------------------------
// connection:update
// ----------------------------------
requestMethod = 'PUT';
const connectionId = this.getNodeParameter('connectionId', i) as number;
endpoint = `/api/3/connections/${connectionId}`;
body.connection = {} as IDataObject;
const updateFields = this.getNodeParameter('updateFields', i) as IDataObject;
addAdditionalFields(body.connection as IDataObject, updateFields);
} else if (operation === 'delete') {
// ----------------------------------
@ -449,24 +460,8 @@ export class ActiveCampaign implements INodeType {
qs.limit = this.getNodeParameter('limit', i) as number;
}
dataKey = 'connections';
endpoint = `/api/3/connections`;
} else if (operation === 'update') {
// ----------------------------------
// connection:update
// ----------------------------------
requestMethod = 'PUT';
const connectionId = this.getNodeParameter('connectionId', i) as number;
endpoint = `/api/3/connections/${connectionId}`;
dataKey = 'connection';
body.connection = {} as IDataObject;
const updateFields = this.getNodeParameter('updateFields', i) as IDataObject;
addAdditionalFields(body.connection as IDataObject, updateFields);
} else {
throw new Error(`The operation "${operation}" is not known`);
}