From a87adc8e5471395a77401481443ff5e4ad8634cc Mon Sep 17 00:00:00 2001
From: Luca Faggianelli <luca.faggianelli@gmail.com>
Date: Tue, 15 Oct 2019 02:43:19 +0200
Subject: [PATCH 1/2] stripe trigger

webhook endpoint for stripe events
---
 packages/nodes-base/nodes/Stripe/README.md    |  27 +
 .../nodes/Stripe/StripeTrigger.node.ts        | 814 ++++++++++++++++++
 packages/nodes-base/nodes/Stripe/stripe.png   | Bin 0 -> 3152 bytes
 3 files changed, 841 insertions(+)
 create mode 100644 packages/nodes-base/nodes/Stripe/README.md
 create mode 100644 packages/nodes-base/nodes/Stripe/StripeTrigger.node.ts
 create mode 100644 packages/nodes-base/nodes/Stripe/stripe.png

diff --git a/packages/nodes-base/nodes/Stripe/README.md b/packages/nodes-base/nodes/Stripe/README.md
new file mode 100644
index 0000000000..775af06485
--- /dev/null
+++ b/packages/nodes-base/nodes/Stripe/README.md
@@ -0,0 +1,27 @@
+All Stripe webhook events are taken from docs:
+https://stripe.com/docs/api/events/types#event_types
+
+To get the entire list of events as a JS array, scrape the website:
+
+1. manually add the id #event-types to `<ul>` that contains all event types
+2. copy-paste the function in the JS console
+3. the result is copied into in the clipboard
+4. paste the prepared array in StripeTrigger.node.ts
+
+```js
+types = []
+$$('ul#event-types li').forEach(el => {
+  const value = el.querySelector('.method-list-item-label-name').innerText
+
+  types.push({
+    name: value
+      .replace(/(\.|_)/, ' ')
+      .split(' ')
+      .map((s) => s.charAt(0).toUpperCase() + s.substring(1))
+      .join(' '),
+    value,
+    description: el.querySelector('.method-list-item-description').innerText
+  })
+})
+copy(types)
+```
\ No newline at end of file
diff --git a/packages/nodes-base/nodes/Stripe/StripeTrigger.node.ts b/packages/nodes-base/nodes/Stripe/StripeTrigger.node.ts
new file mode 100644
index 0000000000..b27b3652a8
--- /dev/null
+++ b/packages/nodes-base/nodes/Stripe/StripeTrigger.node.ts
@@ -0,0 +1,814 @@
+import {
+  IWebhookFunctions,
+} from 'n8n-core';
+
+import {
+  IDataObject,
+  INodeTypeDescription,
+  INodeType,
+  IWebhookResponseData,
+} from 'n8n-workflow';
+
+
+export class StripeTrigger implements INodeType {
+  description: INodeTypeDescription = {
+    displayName: 'Stripe',
+    name: 'stripe',
+    icon: 'file:stripe.png',
+    group: ['trigger'],
+    version: 1,
+    description: 'Handle Stripe events via webhooks',
+    defaults: {
+      name: 'Stripe',
+      color: '#32325d',
+    },
+    inputs: [],
+    outputs: ['main'],
+    webhooks: [
+      {
+        name: 'default',
+        httpMethod: 'POST',
+        reponseMode: 'onReceived',
+        path: 'webhook',
+      },
+    ],
+    properties: [
+      {
+        displayName: 'Events',
+        name: 'events',
+        type: 'multiOptions',
+        required: true,
+        default: [],
+        description: 'The event to listen to.',
+        options: [
+          {
+            name: '*',
+            value: '*',
+            description: 'Any time any event is triggered (Wildcard Event).',
+          },
+          {
+            "name": "Account Updated",
+            "value": "account.updated",
+            "description": "Occurs whenever an account status or property has changed."
+          },
+          {
+            "name": "Account Application.authorized",
+            "value": "account.application.authorized",
+            "description": "Occurs whenever a user authorizes an application. Sent to the related application only."
+          },
+          {
+            "name": "Account Application.deauthorized",
+            "value": "account.application.deauthorized",
+            "description": "Occurs whenever a user deauthorizes an application. Sent to the related application only."
+          },
+          {
+            "name": "Account External_account.created",
+            "value": "account.external_account.created",
+            "description": "Occurs whenever an external account is created."
+          },
+          {
+            "name": "Account External_account.deleted",
+            "value": "account.external_account.deleted",
+            "description": "Occurs whenever an external account is deleted."
+          },
+          {
+            "name": "Account External_account.updated",
+            "value": "account.external_account.updated",
+            "description": "Occurs whenever an external account is updated."
+          },
+          {
+            "name": "Application Fee.created",
+            "value": "application_fee.created",
+            "description": "Occurs whenever an application fee is created on a charge."
+          },
+          {
+            "name": "Application Fee.refunded",
+            "value": "application_fee.refunded",
+            "description": "Occurs whenever an application fee is refunded, whether from refunding a charge or from refunding the application fee directly. This includes partial refunds."
+          },
+          {
+            "name": "Application Fee.refund.updated",
+            "value": "application_fee.refund.updated",
+            "description": "Occurs whenever an application fee refund is updated."
+          },
+          {
+            "name": "Balance Available",
+            "value": "balance.available",
+            "description": "Occurs whenever your Stripe balance has been updated (e.g., when a charge is available to be paid out). By default, Stripe automatically transfers funds in your balance to your bank account on a daily basis."
+          },
+          {
+            "name": "Capability Updated",
+            "value": "capability.updated",
+            "description": "Occurs whenever a capability has new requirements or a new status."
+          },
+          {
+            "name": "Charge Captured",
+            "value": "charge.captured",
+            "description": "Occurs whenever a previously uncaptured charge is captured."
+          },
+          {
+            "name": "Charge Expired",
+            "value": "charge.expired",
+            "description": "Occurs whenever an uncaptured charge expires."
+          },
+          {
+            "name": "Charge Failed",
+            "value": "charge.failed",
+            "description": "Occurs whenever a failed charge attempt occurs."
+          },
+          {
+            "name": "Charge Pending",
+            "value": "charge.pending",
+            "description": "Occurs whenever a pending charge is created."
+          },
+          {
+            "name": "Charge Refunded",
+            "value": "charge.refunded",
+            "description": "Occurs whenever a charge is refunded, including partial refunds."
+          },
+          {
+            "name": "Charge Succeeded",
+            "value": "charge.succeeded",
+            "description": "Occurs whenever a new charge is created and is successful."
+          },
+          {
+            "name": "Charge Updated",
+            "value": "charge.updated",
+            "description": "Occurs whenever a charge description or metadata is updated."
+          },
+          {
+            "name": "Charge Dispute.closed",
+            "value": "charge.dispute.closed",
+            "description": "Occurs when a dispute is closed and the dispute status changes to lost, warning_closed, or won."
+          },
+          {
+            "name": "Charge Dispute.created",
+            "value": "charge.dispute.created",
+            "description": "Occurs whenever a customer disputes a charge with their bank."
+          },
+          {
+            "name": "Charge Dispute.funds_reinstated",
+            "value": "charge.dispute.funds_reinstated",
+            "description": "Occurs when funds are reinstated to your account after a dispute is closed. This includes partially refunded payments."
+          },
+          {
+            "name": "Charge Dispute.funds_withdrawn",
+            "value": "charge.dispute.funds_withdrawn",
+            "description": "Occurs when funds are removed from your account due to a dispute."
+          },
+          {
+            "name": "Charge Dispute.updated",
+            "value": "charge.dispute.updated",
+            "description": "Occurs when the dispute is updated (usually with evidence)."
+          },
+          {
+            "name": "Charge Refund.updated",
+            "value": "charge.refund.updated",
+            "description": "Occurs whenever a refund is updated, on selected payment methods."
+          },
+          {
+            "name": "Checkout Session.completed",
+            "value": "checkout.session.completed",
+            "description": "Occurs when a Checkout Session has been successfully completed."
+          },
+          {
+            "name": "Coupon Created",
+            "value": "coupon.created",
+            "description": "Occurs whenever a coupon is created."
+          },
+          {
+            "name": "Coupon Deleted",
+            "value": "coupon.deleted",
+            "description": "Occurs whenever a coupon is deleted."
+          },
+          {
+            "name": "Coupon Updated",
+            "value": "coupon.updated",
+            "description": "Occurs whenever a coupon is updated."
+          },
+          {
+            "name": "Credit Note.created",
+            "value": "credit_note.created",
+            "description": "Occurs whenever a credit note is created."
+          },
+          {
+            "name": "Credit Note.updated",
+            "value": "credit_note.updated",
+            "description": "Occurs whenever a credit note is updated."
+          },
+          {
+            "name": "Credit Note.voided",
+            "value": "credit_note.voided",
+            "description": "Occurs whenever a credit note is voided."
+          },
+          {
+            "name": "Customer Created",
+            "value": "customer.created",
+            "description": "Occurs whenever a new customer is created."
+          },
+          {
+            "name": "Customer Deleted",
+            "value": "customer.deleted",
+            "description": "Occurs whenever a customer is deleted."
+          },
+          {
+            "name": "Customer Updated",
+            "value": "customer.updated",
+            "description": "Occurs whenever any property of a customer changes."
+          },
+          {
+            "name": "Customer Discount.created",
+            "value": "customer.discount.created",
+            "description": "Occurs whenever a coupon is attached to a customer."
+          },
+          {
+            "name": "Customer Discount.deleted",
+            "value": "customer.discount.deleted",
+            "description": "Occurs whenever a coupon is removed from a customer."
+          },
+          {
+            "name": "Customer Discount.updated",
+            "value": "customer.discount.updated",
+            "description": "Occurs whenever a customer is switched from one coupon to another."
+          },
+          {
+            "name": "Customer Source.created",
+            "value": "customer.source.created",
+            "description": "Occurs whenever a new source is created for a customer."
+          },
+          {
+            "name": "Customer Source.deleted",
+            "value": "customer.source.deleted",
+            "description": "Occurs whenever a source is removed from a customer."
+          },
+          {
+            "name": "Customer Source.expiring",
+            "value": "customer.source.expiring",
+            "description": "Occurs whenever a card or source will expire at the end of the month."
+          },
+          {
+            "name": "Customer Source.updated",
+            "value": "customer.source.updated",
+            "description": "Occurs whenever a source's details are changed."
+          },
+          {
+            "name": "Customer Subscription.created",
+            "value": "customer.subscription.created",
+            "description": "Occurs whenever a customer is signed up for a new plan."
+          },
+          {
+            "name": "Customer Subscription.deleted",
+            "value": "customer.subscription.deleted",
+            "description": "Occurs whenever a customer's subscription ends."
+          },
+          {
+            "name": "Customer Subscription.trial_will_end",
+            "value": "customer.subscription.trial_will_end",
+            "description": "Occurs three days before a subscription's trial period is scheduled to end, or when a trial is ended immediately (using trial_end=now)."
+          },
+          {
+            "name": "Customer Subscription.updated",
+            "value": "customer.subscription.updated",
+            "description": "Occurs whenever a subscription changes (e.g., switching from one plan to another, or changing the status from trial to active)."
+          },
+          {
+            "name": "Customer Tax_id.created",
+            "value": "customer.tax_id.created",
+            "description": "Occurs whenever a tax ID is created for a customer."
+          },
+          {
+            "name": "Customer Tax_id.deleted",
+            "value": "customer.tax_id.deleted",
+            "description": "Occurs whenever a tax ID is deleted from a customer."
+          },
+          {
+            "name": "Customer Tax_id.updated",
+            "value": "customer.tax_id.updated",
+            "description": "Occurs whenever a customer's tax ID is updated."
+          },
+          {
+            "name": "File Created",
+            "value": "file.created",
+            "description": "Occurs whenever a new Stripe-generated file is available for your account."
+          },
+          {
+            "name": "Invoice Created",
+            "value": "invoice.created",
+            "description": "Occurs whenever a new invoice is created. To learn how webhooks can be used with this event, and how they can affect it, see Using Webhooks with Subscriptions."
+          },
+          {
+            "name": "Invoice Deleted",
+            "value": "invoice.deleted",
+            "description": "Occurs whenever a draft invoice is deleted."
+          },
+          {
+            "name": "Invoice Finalized",
+            "value": "invoice.finalized",
+            "description": "Occurs whenever a draft invoice is finalized and updated to be an open invoice."
+          },
+          {
+            "name": "Invoice Marked_uncollectible",
+            "value": "invoice.marked_uncollectible",
+            "description": "Occurs whenever an invoice is marked uncollectible."
+          },
+          {
+            "name": "Invoice Payment_action_required",
+            "value": "invoice.payment_action_required",
+            "description": "Occurs whenever an invoice payment attempt requires further user action to complete."
+          },
+          {
+            "name": "Invoice Payment_failed",
+            "value": "invoice.payment_failed",
+            "description": "Occurs whenever an invoice payment attempt fails, due either to a declined payment or to the lack of a stored payment method."
+          },
+          {
+            "name": "Invoice Payment_succeeded",
+            "value": "invoice.payment_succeeded",
+            "description": "Occurs whenever an invoice payment attempt succeeds."
+          },
+          {
+            "name": "Invoice Sent",
+            "value": "invoice.sent",
+            "description": "Occurs whenever an invoice email is sent out."
+          },
+          {
+            "name": "Invoice Upcoming",
+            "value": "invoice.upcoming",
+            "description": "Occurs X number of days before a subscription is scheduled to create an invoice that is automatically charged—where X is determined by your subscriptions settings. Note: The received Invoice object will not have an invoice ID."
+          },
+          {
+            "name": "Invoice Updated",
+            "value": "invoice.updated",
+            "description": "Occurs whenever an invoice changes (e.g., the invoice amount)."
+          },
+          {
+            "name": "Invoice Voided",
+            "value": "invoice.voided",
+            "description": "Occurs whenever an invoice is voided."
+          },
+          {
+            "name": "Invoiceitem Created",
+            "value": "invoiceitem.created",
+            "description": "Occurs whenever an invoice item is created."
+          },
+          {
+            "name": "Invoiceitem Deleted",
+            "value": "invoiceitem.deleted",
+            "description": "Occurs whenever an invoice item is deleted."
+          },
+          {
+            "name": "Invoiceitem Updated",
+            "value": "invoiceitem.updated",
+            "description": "Occurs whenever an invoice item is updated."
+          },
+          {
+            "name": "Issuing Authorization.created",
+            "value": "issuing_authorization.created",
+            "description": "Occurs whenever an authorization is created."
+          },
+          {
+            "name": "Issuing Authorization.request",
+            "value": "issuing_authorization.request",
+            "description": "Represents a synchronous request for authorization, see Using your integration to handle authorization requests."
+          },
+          {
+            "name": "Issuing Authorization.updated",
+            "value": "issuing_authorization.updated",
+            "description": "Occurs whenever an authorization is updated."
+          },
+          {
+            "name": "Issuing Card.created",
+            "value": "issuing_card.created",
+            "description": "Occurs whenever a card is created."
+          },
+          {
+            "name": "Issuing Card.updated",
+            "value": "issuing_card.updated",
+            "description": "Occurs whenever a card is updated."
+          },
+          {
+            "name": "Issuing Cardholder.created",
+            "value": "issuing_cardholder.created",
+            "description": "Occurs whenever a cardholder is created."
+          },
+          {
+            "name": "Issuing Cardholder.updated",
+            "value": "issuing_cardholder.updated",
+            "description": "Occurs whenever a cardholder is updated."
+          },
+          {
+            "name": "Issuing Dispute.created",
+            "value": "issuing_dispute.created",
+            "description": "Occurs whenever a dispute is created."
+          },
+          {
+            "name": "Issuing Dispute.updated",
+            "value": "issuing_dispute.updated",
+            "description": "Occurs whenever a dispute is updated."
+          },
+          {
+            "name": "Issuing Settlement.created",
+            "value": "issuing_settlement.created",
+            "description": "Occurs whenever an issuing settlement is created."
+          },
+          {
+            "name": "Issuing Settlement.updated",
+            "value": "issuing_settlement.updated",
+            "description": "Occurs whenever an issuing settlement is updated."
+          },
+          {
+            "name": "Issuing Transaction.created",
+            "value": "issuing_transaction.created",
+            "description": "Occurs whenever an issuing transaction is created."
+          },
+          {
+            "name": "Issuing Transaction.updated",
+            "value": "issuing_transaction.updated",
+            "description": "Occurs whenever an issuing transaction is updated."
+          },
+          {
+            "name": "Order Created",
+            "value": "order.created",
+            "description": "Occurs whenever an order is created."
+          },
+          {
+            "name": "Order Payment_failed",
+            "value": "order.payment_failed",
+            "description": "Occurs whenever an order payment attempt fails."
+          },
+          {
+            "name": "Order Payment_succeeded",
+            "value": "order.payment_succeeded",
+            "description": "Occurs whenever an order payment attempt succeeds."
+          },
+          {
+            "name": "Order Updated",
+            "value": "order.updated",
+            "description": "Occurs whenever an order is updated."
+          },
+          {
+            "name": "Order Return.created",
+            "value": "order_return.created",
+            "description": "Occurs whenever an order return is created."
+          },
+          {
+            "name": "Payment Intent.amount_capturable_updated",
+            "value": "payment_intent.amount_capturable_updated",
+            "description": "Occurs when a PaymentIntent has funds to be captured. Check the amount_capturable property on the PaymentIntent to determine the amount that can be captured. You may capture the PaymentIntent with an amount_to_capture value up to the specified amount. Learn more about capturing PaymentIntents."
+          },
+          {
+            "name": "Payment Intent.canceled",
+            "value": "payment_intent.canceled",
+            "description": "Occurs when a PaymentIntent is canceled."
+          },
+          {
+            "name": "Payment Intent.created",
+            "value": "payment_intent.created",
+            "description": "Occurs when a new PaymentIntent is created."
+          },
+          {
+            "name": "Payment Intent.payment_failed",
+            "value": "payment_intent.payment_failed",
+            "description": "Occurs when a PaymentIntent has failed the attempt to create a source or a payment."
+          },
+          {
+            "name": "Payment Intent.succeeded",
+            "value": "payment_intent.succeeded",
+            "description": "Occurs when a PaymentIntent has been successfully fulfilled."
+          },
+          {
+            "name": "Payment Method.attached",
+            "value": "payment_method.attached",
+            "description": "Occurs whenever a new payment method is attached to a customer."
+          },
+          {
+            "name": "Payment Method.card_automatically_updated",
+            "value": "payment_method.card_automatically_updated",
+            "description": "Occurs whenever a card payment method's details are automatically updated by the network."
+          },
+          {
+            "name": "Payment Method.detached",
+            "value": "payment_method.detached",
+            "description": "Occurs whenever a payment method is detached from a customer."
+          },
+          {
+            "name": "Payment Method.updated",
+            "value": "payment_method.updated",
+            "description": "Occurs whenever a payment method is updated via the PaymentMethod update API."
+          },
+          {
+            "name": "Payout Canceled",
+            "value": "payout.canceled",
+            "description": "Occurs whenever a payout is canceled."
+          },
+          {
+            "name": "Payout Created",
+            "value": "payout.created",
+            "description": "Occurs whenever a payout is created."
+          },
+          {
+            "name": "Payout Failed",
+            "value": "payout.failed",
+            "description": "Occurs whenever a payout attempt fails."
+          },
+          {
+            "name": "Payout Paid",
+            "value": "payout.paid",
+            "description": "Occurs whenever a payout is expected to be available in the destination account. If the payout fails, a payout.failed notification is also sent, at a later time."
+          },
+          {
+            "name": "Payout Updated",
+            "value": "payout.updated",
+            "description": "Occurs whenever a payout is updated."
+          },
+          {
+            "name": "Person Created",
+            "value": "person.created",
+            "description": "Occurs whenever a person associated with an account is created."
+          },
+          {
+            "name": "Person Deleted",
+            "value": "person.deleted",
+            "description": "Occurs whenever a person associated with an account is deleted."
+          },
+          {
+            "name": "Person Updated",
+            "value": "person.updated",
+            "description": "Occurs whenever a person associated with an account is updated."
+          },
+          {
+            "name": "Plan Created",
+            "value": "plan.created",
+            "description": "Occurs whenever a plan is created."
+          },
+          {
+            "name": "Plan Deleted",
+            "value": "plan.deleted",
+            "description": "Occurs whenever a plan is deleted."
+          },
+          {
+            "name": "Plan Updated",
+            "value": "plan.updated",
+            "description": "Occurs whenever a plan is updated."
+          },
+          {
+            "name": "Product Created",
+            "value": "product.created",
+            "description": "Occurs whenever a product is created."
+          },
+          {
+            "name": "Product Deleted",
+            "value": "product.deleted",
+            "description": "Occurs whenever a product is deleted."
+          },
+          {
+            "name": "Product Updated",
+            "value": "product.updated",
+            "description": "Occurs whenever a product is updated."
+          },
+          {
+            "name": "Radar Early_fraud_warning.created",
+            "value": "radar.early_fraud_warning.created",
+            "description": "Occurs whenever an early fraud warning is created."
+          },
+          {
+            "name": "Radar Early_fraud_warning.updated",
+            "value": "radar.early_fraud_warning.updated",
+            "description": "Occurs whenever an early fraud warning is updated."
+          },
+          {
+            "name": "Recipient Created",
+            "value": "recipient.created",
+            "description": "Occurs whenever a recipient is created."
+          },
+          {
+            "name": "Recipient Deleted",
+            "value": "recipient.deleted",
+            "description": "Occurs whenever a recipient is deleted."
+          },
+          {
+            "name": "Recipient Updated",
+            "value": "recipient.updated",
+            "description": "Occurs whenever a recipient is updated."
+          },
+          {
+            "name": "Reporting Report_run.failed",
+            "value": "reporting.report_run.failed",
+            "description": "Occurs whenever a requested **ReportRun** failed to complete."
+          },
+          {
+            "name": "Reporting Report_run.succeeded",
+            "value": "reporting.report_run.succeeded",
+            "description": "Occurs whenever a requested **ReportRun** completed succesfully."
+          },
+          {
+            "name": "Reporting Report_type.updated",
+            "value": "reporting.report_type.updated",
+            "description": "Occurs whenever a **ReportType** is updated (typically to indicate that a new day's data has come available)."
+          },
+          {
+            "name": "Review Closed",
+            "value": "review.closed",
+            "description": "Occurs whenever a review is closed. The review's reason field indicates why: approved, disputed, refunded, or refunded_as_fraud."
+          },
+          {
+            "name": "Review Opened",
+            "value": "review.opened",
+            "description": "Occurs whenever a review is opened."
+          },
+          {
+            "name": "Setup Intent.canceled",
+            "value": "setup_intent.canceled",
+            "description": "Occurs when a SetupIntent is canceled."
+          },
+          {
+            "name": "Setup Intent.created",
+            "value": "setup_intent.created",
+            "description": "Occurs when a new SetupIntent is created."
+          },
+          {
+            "name": "Setup Intent.setup_failed",
+            "value": "setup_intent.setup_failed",
+            "description": "Occurs when a SetupIntent has failed the attempt to setup a payment method."
+          },
+          {
+            "name": "Setup Intent.succeeded",
+            "value": "setup_intent.succeeded",
+            "description": "Occurs when an SetupIntent has successfully setup a payment method."
+          },
+          {
+            "name": "Sigma Scheduled_query_run.created",
+            "value": "sigma.scheduled_query_run.created",
+            "description": "Occurs whenever a Sigma scheduled query run finishes."
+          },
+          {
+            "name": "Sku Created",
+            "value": "sku.created",
+            "description": "Occurs whenever a SKU is created."
+          },
+          {
+            "name": "Sku Deleted",
+            "value": "sku.deleted",
+            "description": "Occurs whenever a SKU is deleted."
+          },
+          {
+            "name": "Sku Updated",
+            "value": "sku.updated",
+            "description": "Occurs whenever a SKU is updated."
+          },
+          {
+            "name": "Source Canceled",
+            "value": "source.canceled",
+            "description": "Occurs whenever a source is canceled."
+          },
+          {
+            "name": "Source Chargeable",
+            "value": "source.chargeable",
+            "description": "Occurs whenever a source transitions to chargeable."
+          },
+          {
+            "name": "Source Failed",
+            "value": "source.failed",
+            "description": "Occurs whenever a source fails."
+          },
+          {
+            "name": "Source Mandate_notification",
+            "value": "source.mandate_notification",
+            "description": "Occurs whenever a source mandate notification method is set to manual."
+          },
+          {
+            "name": "Source Refund_attributes_required",
+            "value": "source.refund_attributes_required",
+            "description": "Occurs whenever the refund attributes are required on a receiver source to process a refund or a mispayment."
+          },
+          {
+            "name": "Source Transaction.created",
+            "value": "source.transaction.created",
+            "description": "Occurs whenever a source transaction is created."
+          },
+          {
+            "name": "Source Transaction.updated",
+            "value": "source.transaction.updated",
+            "description": "Occurs whenever a source transaction is updated."
+          },
+          {
+            "name": "Subscription Schedule.aborted",
+            "value": "subscription_schedule.aborted",
+            "description": "Occurs whenever a subscription schedule is canceled due to the underlying subscription being canceled because of delinquency."
+          },
+          {
+            "name": "Subscription Schedule.canceled",
+            "value": "subscription_schedule.canceled",
+            "description": "Occurs whenever a subscription schedule is canceled."
+          },
+          {
+            "name": "Subscription Schedule.completed",
+            "value": "subscription_schedule.completed",
+            "description": "Occurs whenever a new subscription schedule is completed."
+          },
+          {
+            "name": "Subscription Schedule.created",
+            "value": "subscription_schedule.created",
+            "description": "Occurs whenever a new subscription schedule is created."
+          },
+          {
+            "name": "Subscription Schedule.expiring",
+            "value": "subscription_schedule.expiring",
+            "description": "Occurs 7 days before a subscription schedule will expire."
+          },
+          {
+            "name": "Subscription Schedule.released",
+            "value": "subscription_schedule.released",
+            "description": "Occurs whenever a new subscription schedule is released."
+          },
+          {
+            "name": "Subscription Schedule.updated",
+            "value": "subscription_schedule.updated",
+            "description": "Occurs whenever a subscription schedule is updated."
+          },
+          {
+            "name": "Tax Rate.created",
+            "value": "tax_rate.created",
+            "description": "Occurs whenever a new tax rate is created."
+          },
+          {
+            "name": "Tax Rate.updated",
+            "value": "tax_rate.updated",
+            "description": "Occurs whenever a tax rate is updated."
+          },
+          {
+            "name": "Topup Canceled",
+            "value": "topup.canceled",
+            "description": "Occurs whenever a top-up is canceled."
+          },
+          {
+            "name": "Topup Created",
+            "value": "topup.created",
+            "description": "Occurs whenever a top-up is created."
+          },
+          {
+            "name": "Topup Failed",
+            "value": "topup.failed",
+            "description": "Occurs whenever a top-up fails."
+          },
+          {
+            "name": "Topup Reversed",
+            "value": "topup.reversed",
+            "description": "Occurs whenever a top-up is reversed."
+          },
+          {
+            "name": "Topup Succeeded",
+            "value": "topup.succeeded",
+            "description": "Occurs whenever a top-up succeeds."
+          },
+          {
+            "name": "Transfer Created",
+            "value": "transfer.created",
+            "description": "Occurs whenever a transfer is created."
+          },
+          {
+            "name": "Transfer Failed",
+            "value": "transfer.failed",
+            "description": "Occurs whenever a transfer failed."
+          },
+          {
+            "name": "Transfer Paid",
+            "value": "transfer.paid",
+            "description": "Occurs after a transfer is paid. For Instant Payouts, the event will be sent on the next business day, although the funds should be received well beforehand."
+          },
+          {
+            "name": "Transfer Reversed",
+            "value": "transfer.reversed",
+            "description": "Occurs whenever a transfer is reversed, including partial reversals."
+          },
+          {
+            "name": "Transfer Updated",
+            "value": "transfer.updated",
+            "description": "Occurs whenever a transfer's description or metadata is updated."
+          }
+        ]
+      }
+    ],
+  };
+
+  async webhook(this: IWebhookFunctions): Promise<IWebhookResponseData> {
+    const bodyData = this.getBodyData() as IDataObject;
+		const req = this.getRequestObject();
+
+		const events = this.getNodeParameter('events', []) as string[];
+
+		const eventType = bodyData.type as string | undefined;
+
+		if (eventType === undefined || !events.includes('*') && !events.includes(eventType)) {
+			// If not eventType is defined or when one is defined but we are not
+			// listening to it do not start the workflow.
+			return {};
+		}
+
+		return {
+			workflowData: [
+				this.helpers.returnJsonArray(req.body)
+			],
+		};
+  }
+}
diff --git a/packages/nodes-base/nodes/Stripe/stripe.png b/packages/nodes-base/nodes/Stripe/stripe.png
new file mode 100644
index 0000000000000000000000000000000000000000..a02065935ed32658f5a1df7b9fa67bffec74655f
GIT binary patch
literal 3152
zcmV-W46pNvP)<h;3K|Lk000e1NJLTq002Ay002A)0ssI2wVqBT00004XF*Lt006O%
z3;baP0000WV@Og>004R>004l5008;`004mK004C`008P>0026e000+ooVrmw00006
zVoOIv0RI600RN!9r;`8x00(qQO+^Re3J(Gm9U0)2*Z=?vR7pfZRA}C{n%|FAR~5&<
z-?jI-=ia$94ATOY7E+)sAUK5%V70Mnv{9QrnfPRUG%+b{YBVwNuP`w_=(|4Xqw%59
z>Z8SK3x#4;FhXf545dIBX70?r=j`Rf`LXx;H8W^Dxf#x{d(P*q{axR+&c5(FUwaLH
zA@hIzp0-T|E$t8lKxSVel>&k!vQKtBBHttc$xko#5Y*rtB_Y|FEG~umr9gZC#Ff+Y
z>%v2X#3U5Vk2X%uD662JG9b=YN_yD)BlhbhVtF&>#3*kWL?{~yDX=7uD-n)E8S>)F
z%@GTrH%m-HtJEcN5t4wo9CXQIDPiQ;NnGwn8!<EJ^@)SMtR5|H#yq;2Itif@264?P
zYQ$(GW(Q?;9d<Lsti&2n2bKH?sY0bdJY|TIU#?Ef@Ue4A)Iwg#<8nX1N+Na>LvvXG
zps0ypdumOUGDyVYdD>&#aDx`&b=GrDvq=m<sih2zidAD_tQre3H8)@Y>i4u8LJKkO
zhZv*{#$NM3Bq&Ow#;8~rs~Kgfxxyg4LcG~k(7TBn*49Z`QFFFwp#T*S6{BL{{|YF@
zRekuqwG~+81~FzGsMU-&%)f#gv}x2Y5kV=gmEA`J&D8kH@(~2DZQQ$0XqJz9!nJAx
zfOR$w%7pqawS=vH`x+31Bq>Fqt`!JCK`n=_t)>)ZXgy+(q2*QcJty{94EZXzqzEZY
zQ(YTtnmWzCEAUlFXf16-8<C{b0I0)^TZp};JJeYhZV;RB5J@py8|!%Nw#?c+`}(_f
z$J=*A)6>RA;+(Fn>C#gA$*tu2Vshg~a_4U9oc8--?7GCQY9=+)bZhq1u-X&?fLWq0
z-E)ub>3{k8xu=dzZ`&53d%3%mUb;L!cW&kE`PI8isYt77tV^6ny6#YIGH6qX7$zxH
z@vUz^^umh|*oXjBp{lB-jFIik^uJ}s%pV>cnIC-i^vX|vesega(@p1JSX^o;yh&mT
z(-hXqtKZ*scz);{oKxmmz^+KE!Z{V8wPmt)$hQ$`4UTSF)Ac5SNvbEm_weEQVUnmZ
zT!*z>NQjgs#lkC^ZHC{}wn)q7h#9I#3|E%j^Ix4?I5v}}nuqOv7J6T+<zEY8bJMPG
zZ8b9{0AZS9%U1jK7as)j$ki6-+QaOhZFAbtI(NQeH&2|0S-8C7=8q0{?1-F$NQ-cr
zJIja3H0?pPg(*9#^}v@;((ThgHO7IxIEVfF2N_{e#3~Ve=j_Uvvn!*K+K4kV=ArF&
z*RI~~N20+%vh!W$FBSQEVr|hzCH8hb;_9Aq#aP+#P_Gnc7)TMEKC|-UpDc>W-)gg*
ziz3d=*~j<wjy*N?`GtWo-gH~bM^nw=lh|e_RCY`)c}ap0!@*RG0#p^?N7p7viqCAf
zlSH*JQ3dYabANt&^u}AG$M*If-Wm0J;?SmzTKiEuDuv~>HDaB8CP-CHk`~EkN%`Ef
z)2Gjl{&`_F?n@k#LRBbWEu)@*_~4`D{i{j8FW&gVg4gIYRO<W9!u(5N7S=i;R*4CU
zaCJ=&9vtl5+gH`l?XuN4mM=U#+_o*cd(Yjz<5pG`L=*`HPN{&6B#O8hVl6^j37pU@
zJo%DOwQ7u;#96<VBp43O@#E7~X73)xaNnNZv(HQ)neWfen&lO}b;pe-==CT<MJQ0V
z%fQ=Mt_n4D7A`^>!7R+5tn$&Tf^}k$3R){SKS@p;pPrsJuG(gxXb9AS#N1YM=s^Fu
zXNCtJkCPNv7nAV>y;wBx=FS)!I7=77^^o-7BDjcZpay2)$&*3B3wvenrj=&^jOD#$
zx3uI=93QHBVR-K1T<7w@Z{KE5JT*9SxPSd-di8qJi`iD9eT>r>NepM97EVYB3k}S%
zBQJ;FscE{UzK{yUefjsLagyS5hX<J?n&@F}XY_Nk=1V6API>;qxEHZX?8QxC8bPhk
zG$kRKz5&84968z5a-eM4Do>J&B#wFhz18cBlY<BP{k|aYOIy%U4gBH#JypDWVI0Sy
zfdo<{oTZwezY}kTN|=QsFSnU-Nz5j3Im;3E<<k4(Q-4_j`S8vt?vc#Vy8@prho0zN
zxSU+Onf7`W<J0`Ua2C#h$mRhn#30SW(N|bB!j;Clme-+LilkOB?#tR(PoEpT`PS%@
z+v#vhw$2)nJgzNrXFeLUGji(envGZ^&OFXps34yL_Qd(g=Gf6!LZ%9FW9*s}E2<R3
zxG$?~`uBg0-}vjwx%bvqM*6^<8BWPM@t)fvZ@)MGbXlz-1bIY@x!_P90kMAxs1`ib
zh&^RUte^-<IE8|$FqShtQQ-22lZ%%pzx~6#XP=(>#tSopKAS>!ieAKBJMD)br*X`p
zo);ewR1}Ru?uk++N2Zs+jN2!#D#TQ<7jrz(<&jb-h7@Z40ElDRG9ym$o8RC2*)Q(2
z20NR9o0}B}?+Lz-6KL3Zizik>38_iBC6|lZQgllgt?I(jsUQ7d$DxD$NrI(iH=bxV
zmyk7g4iv-f+wA#^<7+pP(i3Y-WXtN!u=CWQhO77vRs(sIb-P6m6-)9@r6iwtEdJrE
z+pk=my!qD3yZ=~Q{5V}5IS53U&905cZvVdC_6JNJu*NbPYc@m`)k-0ca!-{w@29)W
zxY4FoYXP9Ddv-^AcF%q@)vMQ%OIIczUQcd+ny!u!Sw6DUe&ve;Yg;s(ZQi);#1xmx
zUfU#Svdb5_vU5W5=F<I3f){?nNwl~cGhefYkM4>d-PJx*QzOovVQJZYa3hT(IushH
z2SsyADYG+Ij;)8VG>T4Q-=zTlb+D`{D26nDrD_PnDGc$>#mUXPZhA^mZyh-ni7eq*
zHq-ExC6~wj5EmKU7S2`;)NMmy1Zxw0?akFFDg|As*otbCT_wi4?$P$Qs6lOJu<_!G
z(fHNtqbrN0Lsu(eqvI<c#&>zP9^+=t)pIc?NA^<f*s6g#t}C=e{Q8fh*WX?nPD!fu
z82kH%{YJ1}LRVd49c>gtZY*!!cK4Ru^iV>q=6pg%RsIIHcq{$o??$IDPNt`PjBBre
zfu>1>KJ7pJ?n{^88~<vU+v!2!BtgH=!w2Fchx$+KjUJpc(jDwcqL)5O|8#Ec)ZfOV
z35EmaF_!vkOKHYQq^Z$L7WoftL5v1*)rP_*35a?eCpdLx^^G%Y)6=qJo7uU;?s(8_
z-6Dg&SPSQ{vZl9}+_jtT%8hjKRyuK*8pzZDspjolJF&1rS*{C!VzP#H)mJj0tFov<
z42MIKOcftoPcL0fT$UK(WvYM}MiJv!`T_?ylnp1t;CbR;XU^a?oy*;BB<1F2ahvij
zOVBfn%l~2ErJ18Bs6;q5qqR#(<xufO1<H1czJ+q$JvKw!s9VUH0I23gtdfmci4KDo
zTAKuBOmD_o9xW&{U8te<sC}_*`L{8#vNd1B@nvP)n`T^-wFK=^R)kW8P%ROQP8l~8
zof6j<?fI90R{6GYSF;Bl`@4yy?JIyf<c+@(jj2;choS?c1JRgj^TJ-pqpOr`Ox(J^
zwY+6DqG}Ymm=r>d1hMEqbjrAaXiOI&pEJl#OERm?3yuBXiLnlG=_I-C^Tv&ahy<}g
z-{?RPi$=)8nZHY=Pz5x6ukp#!;T{d!)(+5?h=y5J{_i1ySi?vd8}tlfK~%nSLj`a^
z0vH62(OIo*D`M?2x{1+FEC4AY#u$l=M23+dl58f<2~^+|NCT6RfU+C6gzg|NxVwI>
zX^(NyNRXTvOw%%_G;mqZ?HX_!AvPCj5c9tzE~kR%rKv?bs-=P7KVpYG+RS*p-$ZI{
zWLMP7I1>L||Glm}&_PUWxPP5Q{QoWg0iN2n{b}(_Q~&?~C3HntbYx+4WjbSWWnpw>
z05UK!IV~|TEipAzFfuwaF*-6iD=;!TFfiuK-HiYM03~!qSaf7zbY(hiZ)9m^c>ppn
qF*z+UFfB1PR4_6+GBG+bIV&(SIxsMok!3Le0000<MNUMnLSTZDuLS)7

literal 0
HcmV?d00001


From 674dde28ee1590cf3a4499ebb2101925e4d45b7e Mon Sep 17 00:00:00 2001
From: Luca Faggianelli <luca.faggianelli@gmail.com>
Date: Tue, 15 Oct 2019 14:46:42 +0200
Subject: [PATCH 2/2] auto-creation of webhook via Stripe API

---
 .../credentials/StripeApi.credentials.ts      | 21 ++++
 .../nodes/Stripe/StripeTrigger.node.ts        | 99 +++++++++++++++++++
 packages/nodes-base/nodes/Stripe/helpers.ts   | 48 +++++++++
 packages/nodes-base/package.json              |  2 +
 4 files changed, 170 insertions(+)
 create mode 100644 packages/nodes-base/credentials/StripeApi.credentials.ts
 create mode 100644 packages/nodes-base/nodes/Stripe/helpers.ts

diff --git a/packages/nodes-base/credentials/StripeApi.credentials.ts b/packages/nodes-base/credentials/StripeApi.credentials.ts
new file mode 100644
index 0000000000..d59ecbfb73
--- /dev/null
+++ b/packages/nodes-base/credentials/StripeApi.credentials.ts
@@ -0,0 +1,21 @@
+import {
+	ICredentialType,
+	NodePropertyTypes,
+} from 'n8n-workflow';
+
+
+export class StripeApi implements ICredentialType {
+	name = 'stripeApi';
+	displayName = 'Stripe Api';
+	properties = [
+		// The credentials to get from user and save encrypted.
+		// Properties can be defined exactly in the same way
+		// as node properties.
+		{
+			displayName: 'Secret Key',
+			name: 'secretKey',
+			type: 'string' as NodePropertyTypes,
+			default: '',
+		},
+	];
+}
diff --git a/packages/nodes-base/nodes/Stripe/StripeTrigger.node.ts b/packages/nodes-base/nodes/Stripe/StripeTrigger.node.ts
index b27b3652a8..cec9c141e4 100644
--- a/packages/nodes-base/nodes/Stripe/StripeTrigger.node.ts
+++ b/packages/nodes-base/nodes/Stripe/StripeTrigger.node.ts
@@ -1,4 +1,5 @@
 import {
+  IHookFunctions,
   IWebhookFunctions,
 } from 'n8n-core';
 
@@ -9,6 +10,9 @@ import {
   IWebhookResponseData,
 } from 'n8n-workflow';
 
+import {
+  stripeApiRequest,
+} from './helpers';
 
 export class StripeTrigger implements INodeType {
   description: INodeTypeDescription = {
@@ -24,6 +28,12 @@ export class StripeTrigger implements INodeType {
     },
     inputs: [],
     outputs: ['main'],
+    credentials: [
+			{
+				name: 'stripeApi',
+				required: true,
+			}
+		],
     webhooks: [
       {
         name: 'default',
@@ -791,6 +801,95 @@ export class StripeTrigger implements INodeType {
     ],
   };
 
+  // @ts-ignore (because of request)
+	webhookMethods = {
+		default: {
+			async checkExists(this: IHookFunctions): Promise<boolean> {
+        const webhookData = this.getWorkflowStaticData('node');
+
+				if (webhookData.webhookId === undefined) {
+					// No webhook id is set so no webhook can exist
+					return false;
+				}
+
+				// Webhook got created before so check if it still exists
+				const endpoint = `/webhook_endpoints/${webhookData.webhookId}`;
+
+				try {
+					await stripeApiRequest.call(this, 'GET', endpoint, {});
+				} catch (e) {
+					if (e.message.includes('[404]:')) {
+						// Webhook does not exist
+						delete webhookData.webhookId;
+            delete webhookData.webhookEvents;
+            delete webhookData.webhookSecret;
+
+						return false;
+					}
+
+					// Some error occured
+					throw e;
+				}
+
+				// If it did not error then the webhook exists
+				return true;
+			},
+			async create(this: IHookFunctions): Promise<boolean> {
+				const webhookUrl = this.getNodeWebhookUrl('default');
+
+        const events = this.getNodeParameter('events', []);
+
+				const endpoint = '/webhook_endpoints';
+
+				const body = {
+					url: webhookUrl,
+					enabled_events: events,
+				};
+
+				let responseData;
+				try {
+					responseData = await stripeApiRequest.call(this, 'POST', endpoint, body);
+				} catch (e) {
+					throw e;
+				}
+
+				if (responseData.id === undefined || responseData.secret === undefined || responseData.status !== 'enabled') {
+					// Required data is missing so was not successful
+					throw new Error('Stripe webhook creation response did not contain the expected data.');
+				}
+
+				const webhookData = this.getWorkflowStaticData('node');
+				webhookData.webhookId = responseData.id as string;
+        webhookData.webhookEvents = responseData.enabled_events as string[];
+        webhookData.webhookSecret = responseData.secret as string;
+
+				return true;
+			},
+			async delete(this: IHookFunctions): Promise<boolean> {
+				const webhookData = this.getWorkflowStaticData('node');
+
+				if (webhookData.webhookId !== undefined) {
+					const endpoint = `/webhook_endpoints/${webhookData.webhookId}`;
+					const body = {};
+
+					try {
+						await stripeApiRequest.call(this, 'DELETE', endpoint, body);
+					} catch (e) {
+						return false;
+					}
+
+					// Remove from the static workflow data so that it is clear
+					// that no webhooks are registred anymore
+					delete webhookData.webhookId;
+          delete webhookData.webhookEvents;
+          delete webhookData.webhookSecret;
+				}
+
+				return true;
+			},
+		},
+	};
+
   async webhook(this: IWebhookFunctions): Promise<IWebhookResponseData> {
     const bodyData = this.getBodyData() as IDataObject;
 		const req = this.getRequestObject();
diff --git a/packages/nodes-base/nodes/Stripe/helpers.ts b/packages/nodes-base/nodes/Stripe/helpers.ts
new file mode 100644
index 0000000000..9bf86f22af
--- /dev/null
+++ b/packages/nodes-base/nodes/Stripe/helpers.ts
@@ -0,0 +1,48 @@
+import {
+	IExecuteFunctions,
+	IHookFunctions,
+} from 'n8n-core';
+
+/**
+ * Make an API request to Stripe
+ *
+ * @param {IHookFunctions} this
+ * @param {string} method
+ * @param {string} url
+ * @param {object} body
+ * @returns {Promise<any>}
+ */
+export async function stripeApiRequest(this: IHookFunctions | IExecuteFunctions, method: string, endpoint: string, body: object, query?: object): Promise<any> { // tslint:disable-line:no-any
+	const credentials = this.getCredentials('stripeApi');
+	if (credentials === undefined) {
+		throw new Error('No credentials got returned!');
+	}
+
+	const options = {
+		method,
+		auth: {
+      user: credentials.secretKey as string,
+		},
+		form: body,
+		qs: query,
+		uri: `https://api.stripe.com/v1${endpoint}`,
+		json: true
+	};
+
+	try {
+		return await this.helpers.request(options);
+	} catch (error) {
+		if (error.statusCode === 401) {
+			// Return a clear error
+			throw new Error('The Stripe credentials are not valid!');
+		}
+
+		if (error.response && error.response.body && error.response.body.message) {
+			// Try to return the error prettier
+			throw new Error(`Stripe error response [${error.statusCode}]: ${error.response.body.message}`);
+		}
+
+		// If that data does not exist for some reason return the actual error
+		throw error;
+	}
+}
diff --git a/packages/nodes-base/package.json b/packages/nodes-base/package.json
index 45c2414a86..7e30433c4e 100644
--- a/packages/nodes-base/package.json
+++ b/packages/nodes-base/package.json
@@ -46,6 +46,7 @@
             "dist/credentials/Redis.credentials.js",
             "dist/credentials/SlackApi.credentials.js",
             "dist/credentials/Smtp.credentials.js",
+            "dist/credentials/StripeApi.credentials.js",
             "dist/credentials/TelegramApi.credentials.js",
             "dist/credentials/TrelloApi.credentials.js",
             "dist/credentials/TwilioApi.credentials.js",
@@ -93,6 +94,7 @@
             "dist/nodes/Slack/Slack.node.js",
             "dist/nodes/SpreadsheetFile.node.js",
             "dist/nodes/Start.node.js",
+            "dist/nodes/Stripe/StripeTrigger.node.js",
             "dist/nodes/Telegram/Telegram.node.js",
             "dist/nodes/Telegram/TelegramTrigger.node.js",
             "dist/nodes/Trello/Trello.node.js",