import { IHookFunctions, IWebhookFunctions, } from 'n8n-core'; import { IDataObject, INodeTypeDescription, INodeType, IWebhookResponseData, } from 'n8n-workflow'; import { gumroadApiRequest, } from './GenericFunctions'; export class GumroadTrigger implements INodeType { description: INodeTypeDescription = { displayName: 'Gumroad Trigger', name: 'gumroadTrigger', icon: 'file:gumroad.png', group: ['trigger'], version: 1, description: 'Handle Gumroad events via webhooks', defaults: { name: 'Gumroad Trigger', color: '#60c2cd', }, inputs: [], outputs: ['main'], credentials: [ { name: 'gumroadApi', required: true, } ], webhooks: [ { name: 'default', httpMethod: 'POST', responseMode: 'onReceived', path: 'webhook', }, ], properties: [ { displayName: 'Resource', name: 'resource', type: 'options', required: true, default: '', options: [ { name: 'Sale', value: 'sale', description: `When subscribed to this resource, you will be notified of the user's sales`, }, { name: 'Refund', value: 'refund', description: `When subscribed to this resource, you will be notified of refunds to the user's sales`, }, { name: 'Dispute', value: 'dispute', description: `When subscribed to this resource, you will be notified of the disputes raised against user's sales`, }, { name: 'Dispute Won', value: 'dispute_won', description: `When subscribed to this resource, you will be notified of the sale disputes won`, }, { name: 'Cancellation', value: 'cancellation', description: `When subscribed to this resource, you will be notified of cancellations of the user's subscribers`, }, ], description: 'The resource is gonna fire the event', }, ], }; // @ts-ignore webhookMethods = { default: { async checkExists(this: IHookFunctions): Promise { const webhookData = this.getWorkflowStaticData('node'); if (webhookData.webhookId === undefined) { return false; } const endpoint = '/resource_subscriptions'; const { resource_subscriptions } = await gumroadApiRequest.call(this, 'GET', endpoint); if (Array.isArray(resource_subscriptions)) { for (const resource of resource_subscriptions) { if (resource.id === webhookData.webhookId) { return true; } } } return false; }, async create(this: IHookFunctions): Promise { const webhookUrl = this.getNodeWebhookUrl('default'); const webhookData = this.getWorkflowStaticData('node'); const resource = this.getNodeParameter('resource') as string; const endpoint = '/resource_subscriptions'; const body: IDataObject = { post_url: webhookUrl, resource_name: resource, }; const { resource_subscription } = await gumroadApiRequest.call(this, 'PUT', endpoint, body); webhookData.webhookId = resource_subscription.id; return true; }, async delete(this: IHookFunctions): Promise { let responseData; const webhookData = this.getWorkflowStaticData('node'); const endpoint = `/resource_subscriptions/${webhookData.webhookId}`; try { responseData = await gumroadApiRequest.call(this, 'DELETE', endpoint); } catch(error) { return false; } if (!responseData.success) { return false; } delete webhookData.webhookId; return true; }, }, }; async webhook(this: IWebhookFunctions): Promise { const req = this.getRequestObject(); return { workflowData: [ this.helpers.returnJsonArray(req.body), ], }; } }