activemerchant/active_merchant

require 'json'

module ActiveMerchant #:nodoc:
  module Billing #:nodoc:
    class WebpayGateway < StripeGateway
      self.live_url = 'https://api.webpay.jp/v1/'

      self.supported_countries = ['JP']
      self.default_currency = 'JPY'
      self.money_format = :cents
      self.supported_cardtypes = %i[visa master american_express jcb diners_club]

      self.homepage_url = 'https://webpay.jp/'
      self.display_name = 'WebPay'

      def capture(money, authorization, options = {})
        post = {}
        add_amount(post, money, options)
        add_application_fee(post, options)
        commit(:post, "charges/#{CGI.escape(authorization)}/capture", post)
      end

      def refund(money, identification, options = {})
        post = {}
        add_amount(post, money, options)
        MultiResponse.run do |r|
          r.process { commit(:post, "charges/#{CGI.escape(identification)}/refund", post, options) }

          return r unless options[:refund_fee_amount]

          r.process { fetch_application_fees(identification, options) }
          r.process { refund_application_fee(options[:refund_fee_amount], application_fee_from_response(r), options) }
        end
      end

      def refund_fee(identification, options, meta)
        raise NotImplementedError.new
      end

      def add_customer(post, creditcard, options)
        post[:customer] = options[:customer] if options[:customer] && !creditcard.respond_to?(:number)
      end

      def store(creditcard, options = {})
        post = {}
        add_creditcard(post, creditcard, options)
        post[:description] = options[:description]
        post[:email] = options[:email]

        if options[:customer]
          MultiResponse.run(:first) do |r|
            r.process { commit(:post, "customers/#{CGI.escape(options[:customer])}/", post, options) }

            return r unless options[:set_default] && r.success? && !r.params['id'].blank?

            r.process { update_customer(options[:customer], default_card: r.params['id']) }
          end
        else
          commit(:post, 'customers', post, options)
        end
      end

      def update(customer_id, creditcard, options = {})
        post = {}
        add_creditcard(post, creditcard, options)
        commit(:post, "customers/#{CGI.escape(customer_id)}", post, options)
      end

      private

      def create_post_for_auth_or_purchase(money, creditcard, options)
        stripe_post = super
        stripe_post[:description] ||= stripe_post.delete(:metadata).try(:[], :email)
        stripe_post
      end

      def json_error(raw_response)
        msg = 'Invalid response received from the WebPay API.  Please contact support@webpay.jp if you continue to receive this message.'
        msg += "  (The raw response returned by the API was #{raw_response.inspect})"
        {
          'error' => {
            'message' => msg
          }
        }
      end

      def headers(options = {})
        {
          'Authorization' => 'Basic ' + Base64.encode64(@api_key.to_s + ':').strip,
          'User-Agent' => "Webpay/v1 ActiveMerchantBindings/#{ActiveMerchant::VERSION}",
          'X-Webpay-Client-User-Agent' => user_agent,
          'X-Webpay-Client-User-Metadata' => { ip: options[:ip] }.to_json
        }
      end
    end
  end
end