Syncromsp node

packages/nodes-base/credentials/SyncroMspApi.credentials.ts

@@ -0,0 +1,24 @@
+import {
+	ICredentialType,
+	INodeProperties,
+} from 'n8n-workflow';
+
+export class SyncroMspApi implements ICredentialType {
+	name = 'syncroMspApi';
+	displayName = 'SyncroMSP API';
+	documentationUrl = 'syncromsp';
+	properties: INodeProperties[] = [
+		{
+			displayName: 'API Key',
+			name: 'apiKey',
+			type: 'string',
+			default: '',
+		},
+		{
+			displayName: 'Subdomain',
+			name: 'subdomain',
+			type: 'string',
+			default: '',
+		},
+	];
+}

packages/nodes-base/nodes/SyncroMSP/SyncroMsp.node.ts

@@ -0,0 +1,28 @@
+import {
+	INodeTypeBaseDescription,
+	INodeVersionedType,
+} from 'n8n-workflow';
+
+import { NodeVersionedType } from '../../src/NodeVersionedType';
+
+import { SyncroMspV1 } from './v1/SyncroMspV1.node';
+
+export class SyncroMsp extends NodeVersionedType {
+	constructor() {
+		const baseDescription: INodeTypeBaseDescription = {
+			displayName: 'SyncroMSP',
+			name: 'syncroMsp',
+			icon: 'file:syncromsp.png',
+			group: ['output'],
+			subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}',
+			description: 'Manage contacts, tickets and more from Syncro MSP',
+			defaultVersion: 1,
+		};
+
+		const nodeVersions: INodeVersionedType['nodeVersions'] = {
+			1: new SyncroMspV1(baseDescription),
+		};
+
+		super(nodeVersions, baseDescription);
+	}
+}

packages/nodes-base/nodes/SyncroMSP/v1/SyncroMspV1.node.ts

@@ -0,0 +1,57 @@
+import {
+	IExecuteFunctions,
+} from 'n8n-core';
+
+import {
+	ICredentialDataDecryptedObject,
+	ICredentialsDecrypted,
+	ICredentialTestFunctions,
+	INodeType,
+	INodeTypeBaseDescription,
+	INodeTypeDescription,
+	NodeCredentialTestResult,
+} from 'n8n-workflow';
+
+import { versionDescription } from './actions/versionDescription';
+import { loadOptions } from './methods';
+import { router } from './actions/router';
+import { validateCredentials } from './transport';
+
+export class SyncroMspV1 implements INodeType {
+
+	description: INodeTypeDescription;
+
+	constructor(baseDescription: INodeTypeBaseDescription) {
+		this.description = {
+			...baseDescription,
+			...versionDescription,
+		};
+	}
+
+	methods = {
+		loadOptions,
+		credentialTest: {
+			async syncroMspApiCredentialTest(this: ICredentialTestFunctions, credential: ICredentialsDecrypted): Promise<NodeCredentialTestResult> {
+				try {
+					await validateCredentials.call(this, credential.data as ICredentialDataDecryptedObject);
+				} catch (error) {
+					if (error.statusCode === 401) {
+						return {
+							status: 'Error',
+							message: 'The API Key included in the request is invalid',
+						};
+					}
+				}
+
+				return {
+					status: 'OK',
+					message: 'Connection successful!',
+				};
+			},
+		},
+	};
+
+	async execute(this: IExecuteFunctions) {
+		return await router.call(this);
+	}
+}

packages/nodes-base/nodes/SyncroMSP/v1/actions/Interfaces.ts

@@ -0,0 +1,33 @@
+import {
+	AllEntities,
+	Entity,
+	PropertiesOf,
+} from 'n8n-workflow';
+
+type SyncroMspMap = {
+	contact: 'create'|'delete'|'get'|'getAll'|'update';
+	customer: 'create'|'delete'|'get'|'getAll'|'update';
+	rmm: 'create'|'delete'|'get'|'getAll'|'mute' ;
+	ticket: 'create'|'delete'|'get'|'getAll'|'update';
+};
+
+export type SyncroMsp = AllEntities<SyncroMspMap>;
+
+export type SyncroMspMapContact = Entity<SyncroMspMap, 'contact'>;
+export type SyncroMspMapCustomer = Entity<SyncroMspMap, 'customer'>;
+export type SyncroMspMapRmm = Entity<SyncroMspMap, 'rmm'>;
+export type SyncroMspMapTicket = Entity<SyncroMspMap, 'ticket'>;
+
+export type ContactProperties = PropertiesOf<SyncroMspMapContact>;
+export type CustomerProperties = PropertiesOf<SyncroMspMapCustomer>;
+export type RmmProperties = PropertiesOf<SyncroMspMapRmm>;
+export type TicketProperties = PropertiesOf<SyncroMspMapTicket>;
+
+export interface IAttachment {
+	fields: {
+		item?: object[];
+	};
+	actions: {
+		item?: object[];
+	};
+}

packages/nodes-base/nodes/SyncroMSP/v1/actions/contact/create/description.ts

@@ -0,0 +1,81 @@
+import {
+	ContactProperties,
+} from '../../Interfaces';
+
+import {
+	addressFixedCollection
+} from '../../../methods/sharedFields';
+
+export const contactCreateDescription: ContactProperties = [
+	{
+		displayName: 'Customer ID',
+		name: 'customerId',
+		type: 'string',
+		required: true,
+		displayOptions: {
+			show: {
+				resource: [
+					'contact',
+				],
+				operation: [
+					'create',
+				],
+			},
+		},
+		default: '',
+	},
+	{
+		displayName: 'Email',
+		name: 'email',
+		type: 'string',
+		displayOptions: {
+			show: {
+				resource: [
+					'contact',
+				],
+				operation: [
+					'create',
+				],
+			},
+		},
+		default: '',
+	},
+	{
+		displayName: 'Additional Fields',
+		name: 'additionalFields',
+		type: 'collection',
+		placeholder: 'Add Field',
+		displayOptions: {
+			show: {
+				resource: [
+					'contact',
+				],
+				operation: [
+					'create',
+				],
+			},
+		},
+		default: {},
+		options: [
+			addressFixedCollection,
+			{
+				displayName: 'Name',
+				name: 'name',
+				type: 'string',
+				default: '',
+			},
+			{
+				displayName: 'Notes',
+				name: 'notes',
+				type: 'string',
+				default: '',
+			},
+			{
+				displayName: 'Phone',
+				name: 'phone',
+				type: 'string',
+				default: '',
+			},
+		],
+	},
+];

packages/nodes-base/nodes/SyncroMSP/v1/actions/contact/create/execute.ts

@@ -0,0 +1,44 @@
+import {
+	IExecuteFunctions,
+} from 'n8n-core';
+
+import {
+	IDataObject,
+	INodeExecutionData,
+} from 'n8n-workflow';
+
+import {
+	apiRequest,
+} from '../../../transport';
+
+
+export async function createContact(this: IExecuteFunctions, index: number): Promise<INodeExecutionData[]> {
+	const id = this.getNodeParameter('customerId', index) as IDataObject;
+	const email = this.getNodeParameter('email', index) as IDataObject;
+	const { address, notes, phone, name } = this.getNodeParameter('additionalFields', index) as IDataObject;
+
+	const qs = {} as IDataObject;
+	const requestMethod = 'POST';
+	const endpoint = 'contacts';
+	let body = {} as IDataObject;
+	let addressData = address as IDataObject;
+
+	if (addressData) {
+		addressData = addressData['addressFields'] as IDataObject;
+		addressData.address1 = addressData.address;
+	}
+
+	body = {
+		...addressData,
+		customer_id: id,
+		email,
+		name,
+		notes,
+		phone,
+	};
+
+	let responseData;
+	responseData = await apiRequest.call(this, requestMethod, endpoint, body, qs);
+
+	return this.helpers.returnJsonArray(responseData);
+}

packages/nodes-base/nodes/SyncroMSP/v1/actions/contact/create/index.ts

@@ -0,0 +1,7 @@
+import { createContact as execute } from './execute';
+import { contactCreateDescription as description } from './description';
+
+export {
+	description,
+	execute,
+};

packages/nodes-base/nodes/SyncroMSP/v1/actions/contact/del/description.ts

@@ -0,0 +1,24 @@
+import {
+	ContactProperties,
+} from '../../Interfaces';
+
+export const contactDeleteDescription: ContactProperties = [
+	{
+		displayName: 'Contact ID',
+		name: 'contactId',
+		type: 'string',
+		required: true,
+		displayOptions: {
+			show: {
+				resource: [
+					'contact',
+				],
+				operation: [
+					'delete',
+				],
+			},
+		},
+		default: '',
+		description: 'Delete a specific contact by ID',
+	},
+];

packages/nodes-base/nodes/SyncroMSP/v1/actions/contact/del/execute.ts

@@ -0,0 +1,26 @@
+import {
+	IExecuteFunctions,
+} from 'n8n-core';
+
+import {
+	IDataObject,
+	INodeExecutionData,
+} from 'n8n-workflow';
+
+import {
+	apiRequest
+} from '../../../transport';
+
+
+export async function deleteContact(this: IExecuteFunctions, index: number): Promise<INodeExecutionData[]> {
+	const id = this.getNodeParameter('contactId', index) as string;
+
+	const qs = {} as IDataObject;
+	const requestMethod = 'DELETE';
+	const endpoint = `contacts/${id}`;
+	const body = {} as IDataObject;
+
+	let responseData;
+	responseData = await apiRequest.call(this, requestMethod, endpoint, body, qs);
+	return this.helpers.returnJsonArray(responseData);
+}

packages/nodes-base/nodes/SyncroMSP/v1/actions/contact/del/index.ts

@@ -0,0 +1,7 @@
+import { deleteContact as execute } from './execute';
+import { contactDeleteDescription as description } from './description';
+
+export {
+	description,
+	execute,
+};

packages/nodes-base/nodes/SyncroMSP/v1/actions/contact/get/description.ts

@@ -0,0 +1,24 @@
+import {
+	ContactProperties,
+} from '../../Interfaces';
+
+export const contactGetDescription: ContactProperties = [
+	{
+		displayName: 'Contact ID',
+		name: 'contactId',
+		type: 'string',
+		required: true,
+		displayOptions: {
+			show: {
+				resource: [
+					'contact',
+				],
+				operation: [
+					'get',
+				],
+			},
+		},
+		default: '',
+		description: 'Get specific contact by ID',
+	},
+];

packages/nodes-base/nodes/SyncroMSP/v1/actions/contact/get/execute.ts

@@ -0,0 +1,26 @@
+import {
+	IExecuteFunctions,
+} from 'n8n-core';
+
+import {
+	IDataObject,
+	INodeExecutionData,
+} from 'n8n-workflow';
+
+import {
+	apiRequest
+} from '../../../transport';
+
+
+export async function getContact(this: IExecuteFunctions, index: number): Promise<INodeExecutionData[]> {
+	const id = this.getNodeParameter('contactId', index) as string;
+
+	const qs = {} as IDataObject;
+	const requestMethod = 'GET';
+	const endpoint = `contacts/${id}`;
+	const body = {} as IDataObject;
+
+	let responseData;
+	responseData = await apiRequest.call(this, requestMethod, endpoint, body, qs);
+	return this.helpers.returnJsonArray(responseData);
+}