feat(payment_providers): Add Cashfree

app/controllers/webhooks_controller.rb

@@ -20,6 +20,26 @@ def stripe
     head(:ok)
   end
 
+  def cashfree
+    result = PaymentProviders::CashfreeService.new.handle_incoming_webhook(
+      organization_id: params[:organization_id],
+      code: params[:code].presence,
+      body: request.body.read,
+      timestamp: request.headers['X-Cashfree-Timestamp'],
+      signature: request.headers['X-Cashfree-Signature']
+    )
+
+    unless result.success?
+      if result.error.is_a?(BaseService::ServiceFailure) && result.error.code == 'webhook_error'
+        return head(:bad_request)
+      end
+
+      result.raise_if_error!
+    end
+
+    head(:ok)
+  end
+
   def gocardless
     result = PaymentProviders::Gocardless::HandleIncomingWebhookService.call(
       organization_id: params[:organization_id],

app/graphql/mutations/payment_providers/cashfree/base.rb

@@ -0,0 +1,20 @@
+# frozen_string_literal: true
+
+module Mutations
+  module PaymentProviders
+    module Cashfree
+      class Base < BaseMutation
+        include AuthenticableApiUser
+        include RequiredOrganization
+
+        def resolve(**args)
+          result = ::PaymentProviders::CashfreeService
+            .new(context[:current_user])
+            .create_or_update(**args.merge(organization: current_organization))
+
+          result.success? ? result.cashfree_provider : result_error(result)
+        end
+      end
+    end
+  end
+end

app/graphql/mutations/payment_providers/cashfree/create.rb

@@ -0,0 +1,18 @@
+# frozen_string_literal: true
+
+module Mutations
+  module PaymentProviders
+    module Cashfree
+      class Create < Base
+        REQUIRED_PERMISSION = 'organization:integrations:create'
+
+        graphql_name 'AddCashfreePaymentProvider'
+        description 'Add or update Cashfree payment provider'
+
+        input_object_class Types::PaymentProviders::CashfreeInput
+
+        type Types::PaymentProviders::Cashfree
+      end
+    end
+  end
+end

app/graphql/mutations/payment_providers/cashfree/update.rb

@@ -0,0 +1,18 @@
+# frozen_string_literal: true
+
+module Mutations
+  module PaymentProviders
+    module Cashfree
+      class Update < Base
+        REQUIRED_PERMISSION = 'organization:integrations:update'
+
+        graphql_name 'UpdateCashfreePaymentProvider'
+        description 'Update Cashfree payment provider'
+
+        input_object_class Types::PaymentProviders::UpdateInput
+
+        type Types::PaymentProviders::Cashfree
+      end
+    end
+  end
+end

app/graphql/resolvers/payment_providers_resolver.rb

@@ -31,6 +31,8 @@ def provider_type(type)
         PaymentProviders::StripeProvider.to_s
       when 'gocardless'
         PaymentProviders::GocardlessProvider.to_s
+      when 'cashfree'
+        PaymentProviders::CashfreeProvider.to_s
       else
         raise(NotImplementedError)
       end

app/graphql/types/customers/object.rb

@@ -126,6 +126,8 @@ def provider_customer
           object.stripe_customer
         when :gocardless
           object.gocardless_customer
+        when :cashfree
+          object.cashfree_customer
         when :adyen
           object.adyen_customer
         end

app/graphql/types/mutation_type.rb

@@ -47,10 +47,12 @@ class MutationType < Types::BaseObject
     field :update_add_on, mutation: Mutations::AddOns::Update
 
     field :add_adyen_payment_provider, mutation: Mutations::PaymentProviders::Adyen::Create
+    field :add_cashfree_payment_provider, mutation: Mutations::PaymentProviders::Cashfree::Create
     field :add_gocardless_payment_provider, mutation: Mutations::PaymentProviders::Gocardless::Create
     field :add_stripe_payment_provider, mutation: Mutations::PaymentProviders::Stripe::Create
 
     field :update_adyen_payment_provider, mutation: Mutations::PaymentProviders::Adyen::Update
+    field :update_cashfree_payment_provider, mutation: Mutations::PaymentProviders::Cashfree::Update
     field :update_gocardless_payment_provider, mutation: Mutations::PaymentProviders::Gocardless::Update
     field :update_stripe_payment_provider, mutation: Mutations::PaymentProviders::Stripe::Update
 

app/graphql/types/organizations/current_organization_type.rb

@@ -47,6 +47,7 @@ class CurrentOrganizationType < BaseOrganizationType
       field :taxes, [Types::Taxes::Object], resolver: Resolvers::TaxesResolver, permission: 'organization:taxes:view'
 
       field :adyen_payment_providers, [Types::PaymentProviders::Adyen], permission: 'organization:integrations:view'
+      field :cashfree_payment_providers, [Types::PaymentProviders::Cashfree], permission: 'organization:integrations:view'
       field :gocardless_payment_providers, [Types::PaymentProviders::Gocardless], permission: 'organization:integrations:view'
       field :stripe_payment_providers, [Types::PaymentProviders::Stripe], permission: 'organization:integrations:view'
 

app/graphql/types/payment_providers/cashfree.rb

@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+module Types
+  module PaymentProviders
+    class Cashfree < Types::BaseObject
+      graphql_name 'CashfreeProvider'
+
+      field :code, String, null: false
+      field :id, ID, null: false
+      field :name, String, null: false
+
+      field :client_id, String, null: true, permission: 'organization:integrations:view'
+      field :client_secret, String, null: true, permission: 'organization:integrations:view'
+      field :success_redirect_url, String, null: true, permission: 'organization:integrations:view'
+    end
+  end
+end

app/graphql/types/payment_providers/cashfree_input.rb

@@ -0,0 +1,15 @@
+# frozen_string_literal: true
+
+module Types
+  module PaymentProviders
+    class CashfreeInput < BaseInputObject
+      description 'Cashfree input arguments'
+
+      argument :client_id, String, required: true
+      argument :client_secret, String, required: true
+      argument :code, String, required: true
+      argument :name, String, required: true
+      argument :success_redirect_url, String, required: false
+    end
+  end
+end

app/graphql/types/payment_providers/object.rb

@@ -7,7 +7,8 @@ class Object < Types::BaseUnion
 
       possible_types Types::PaymentProviders::Adyen,
         Types::PaymentProviders::Gocardless,
-        Types::PaymentProviders::Stripe
+        Types::PaymentProviders::Stripe,
+        Types::PaymentProviders::Cashfree
 
       def self.resolve_type(object, _context)
         case object.class.to_s
@@ -17,6 +18,8 @@ def self.resolve_type(object, _context)
           Types::PaymentProviders::Stripe
         when 'PaymentProviders::GocardlessProvider'
           Types::PaymentProviders::Gocardless
+        when 'PaymentProviders::CashfreeProvider'
+          Types::PaymentProviders::Cashfree
         else
           raise "Unexpected Payment provider type: #{object.inspect}"
         end

app/jobs/payment_providers/cashfree/handle_event_job.rb

@@ -0,0 +1,16 @@
+# frozen_string_literal: true
+
+module PaymentProviders
+  module Cashfree
+    class HandleEventJob < ApplicationJob
+      queue_as "providers"
+
+      def perform(organization:, event:)
+        PaymentProviders::Cashfree::HandleEventService.call!(
+          organization:,
+          event_json: event
+        )
+      end
+    end
+  end
+end

app/models/customer.rb

@@ -60,14 +60,15 @@ class Customer < ApplicationRecord
 
   has_one :stripe_customer, class_name: 'PaymentProviderCustomers::StripeCustomer'
   has_one :gocardless_customer, class_name: 'PaymentProviderCustomers::GocardlessCustomer'
+  has_one :cashfree_customer, class_name: 'PaymentProviderCustomers::CashfreeCustomer'
   has_one :adyen_customer, class_name: 'PaymentProviderCustomers::AdyenCustomer'
   has_one :netsuite_customer, class_name: 'IntegrationCustomers::NetsuiteCustomer'
   has_one :anrok_customer, class_name: 'IntegrationCustomers::AnrokCustomer'
   has_one :xero_customer, class_name: 'IntegrationCustomers::XeroCustomer'
   has_one :hubspot_customer, class_name: 'IntegrationCustomers::HubspotCustomer'
   has_one :salesforce_customer, class_name: 'IntegrationCustomers::SalesforceCustomer'
 
-  PAYMENT_PROVIDERS = %w[stripe gocardless adyen].freeze
+  PAYMENT_PROVIDERS = %w[stripe gocardless cashfree adyen].freeze
 
   default_scope -> { kept }
   sequenced scope: ->(customer) { customer.organization.customers.with_discarded },
@@ -151,6 +152,8 @@ def provider_customer
       stripe_customer
     when :gocardless
       gocardless_customer
+    when :cashfree
+      cashfree_customer
     when :adyen
       adyen_customer
     end

app/models/organization.rb

@@ -39,9 +39,10 @@ class Organization < ApplicationRecord
   has_many :error_details
   has_many :dunning_campaigns
 
-  has_many :stripe_payment_providers, class_name: "PaymentProviders::StripeProvider"
-  has_many :gocardless_payment_providers, class_name: "PaymentProviders::GocardlessProvider"
-  has_many :adyen_payment_providers, class_name: "PaymentProviders::AdyenProvider"
+  has_many :stripe_payment_providers, class_name: 'PaymentProviders::StripeProvider'
+  has_many :gocardless_payment_providers, class_name: 'PaymentProviders::GocardlessProvider'
+  has_many :cashfree_payment_providers, class_name: 'PaymentProviders::CashfreeProvider'
+  has_many :adyen_payment_providers, class_name: 'PaymentProviders::AdyenProvider'
 
   has_many :hubspot_integrations, class_name: "Integrations::HubspotIntegration"
   has_many :netsuite_integrations, class_name: "Integrations::NetsuiteIntegration"
@@ -124,7 +125,9 @@ def payment_provider(provider)
       stripe_payment_provider
     when "gocardless"
       gocardless_payment_provider
-    when "adyen"
+    when 'cashfree'
+      cashfree_payment_provider
+    when 'adyen'
       adyen_payment_provider
     end
   end

app/models/payment_provider_customers/cashfree_customer.rb

@@ -0,0 +1,32 @@
+# frozen_string_literal: true
+
+module PaymentProviderCustomers
+  class CashfreeCustomer < BaseCustomer
+  end
+end
+
+# == Schema Information
+#
+# Table name: payment_provider_customers
+#
+#  id                   :uuid             not null, primary key
+#  deleted_at           :datetime
+#  settings             :jsonb            not null
+#  type                 :string           not null
+#  created_at           :datetime         not null
+#  updated_at           :datetime         not null
+#  customer_id          :uuid             not null
+#  payment_provider_id  :uuid
+#  provider_customer_id :string
+#
+# Indexes
+#
+#  index_payment_provider_customers_on_customer_id_and_type  (customer_id,type) UNIQUE WHERE (deleted_at IS NULL)
+#  index_payment_provider_customers_on_payment_provider_id   (payment_provider_id)
+#  index_payment_provider_customers_on_provider_customer_id  (provider_customer_id)
+#
+# Foreign Keys
+#
+#  fk_rails_...  (customer_id => customers.id)
+#  fk_rails_...  (payment_provider_id => payment_providers.id)
+#

app/models/payment_providers/cashfree_provider.rb

@@ -0,0 +1,42 @@
+# frozen_string_literal: true
+
+module PaymentProviders
+  class CashfreeProvider < BaseProvider
+    CashfreePayment = Data.define(:id, :status, :metadata)
+
+    SUCCESS_REDIRECT_URL = "https://cashfree.com/"
+    API_VERSION = "2023-08-01"
+    BASE_URL = (Rails.env.production? ? "https://api.cashfree.com/pg/links" : "https://sandbox.cashfree.com/pg/links")
+
+    validates :client_id, presence: true
+    validates :client_secret, presence: true
+    validates :success_redirect_url, url: true, allow_nil: true, length: {maximum: 1024}
+
+    secrets_accessors :client_id, :client_secret
+  end
+end
+
+# == Schema Information
+#
+# Table name: payment_providers
+#
+#  id              :uuid             not null, primary key
+#  code            :string           not null
+#  deleted_at      :datetime
+#  name            :string           not null
+#  secrets         :string
+#  settings        :jsonb            not null
+#  type            :string           not null
+#  created_at      :datetime         not null
+#  updated_at      :datetime         not null
+#  organization_id :uuid             not null
+#
+# Indexes
+#
+#  index_payment_providers_on_code_and_organization_id  (code,organization_id) UNIQUE WHERE (deleted_at IS NULL)
+#  index_payment_providers_on_organization_id           (organization_id)
+#
+# Foreign Keys
+#
+#  fk_rails_...  (organization_id => organizations.id)
+#

app/serializers/v1/customer_serializer.rb

@@ -71,6 +71,9 @@ def billing_configuration
       when :gocardless
         configuration[:provider_customer_id] = model.gocardless_customer&.provider_customer_id
         configuration.merge!(model.gocardless_customer&.settings || {})
+      when :cashfree
+        configuration[:provider_customer_id] = model.cashfree_customer&.provider_customer_id
+        configuration.merge!(model.cashfree_customer&.settings || {})
       when :adyen
         configuration[:provider_customer_id] = model.adyen_customer&.provider_customer_id
         configuration.merge!(model.adyen_customer&.settings || {})