Oleksandr Bondar

include ActiveMerchant::Billing

# simple extension to ActiveMerchant for basic support of recurring payments with Express Checkout API

module ActiveMerchant #:nodoc:

  module Billing #:nodoc:

    class PaypalExpressRecurringGateway < Gateway

      include PaypalCommonAPI
      LIVE_REDIRECT_URL = 'https://www.paypal.com/cgibin/webscr?cmd=_customer-billing-agreement&token='
      TEST_REDIRECT_URL = 'https://www.sandbox.paypal.com/cgi-bin/webscr?cmd=_customer-billing-agreement&token='
      def redirect_url
        test? ? TEST_REDIRECT_URL : LIVE_REDIRECT_URL
      end
      def redirect_url_for(token)
        "#{redirect_url}#{token}"
      end

      def setup_agreement(description, return_url, cancel_url)
        commit 'SetCustomerBillingAgreement', build_setup_request(description, return_url, cancel_url)
      end

      def create_profile(token, description, cycles, amount, next_billing_date)
        commit 'CreateRecurringPaymentsProfile', build_create_profile_request(token, description, cycles, amount, next_billing_date)
      end
  
      def update_profile(profile_id, description, amount)
        commit 'UpdateRecurringPaymentsProfile', build_change_profile_request(profile_id, description, amount)
      end

      def cancel_profile(profile_id)
        commit 'ManageRecurringPaymentsProfileStatus', manage_profile_request(profile_id, 'Cancel')
      end

      def get_profile_details(profile_id)
        commit 'GetRecurringPaymentsProfileDetails', build_get_profile_details_request(profile_id)
      end

    private
      def build_setup_request(description, return_url, cancel_url)
        xml = Builder::XmlMarkup.new :indent => 2
        xml.tag! 'SetCustomerBillingAgreementReq', 'xmlns' => PAYPAL_NAMESPACE do
          xml.tag! 'SetCustomerBillingAgreementRequest', 'xmlns:n2' => EBAY_NAMESPACE do
            xml.tag! 'n2:Version', 50
            xml.tag! 'n2:SetCustomerBillingAgreementRequestDetails' do
              xml.tag! 'n2:BillingAgreementDetails' do
                xml.tag! 'n2:BillingType', 'RecurringPayments'
                xml.tag! 'n2:BillingAgreementDescription', description
              end
              xml.tag! 'n2:ReturnURL', return_url
              xml.tag! 'n2:CancelURL', cancel_url
            end
          end
        end
        xml.target!
      end

      def build_create_profile_request(token, description, cycles, amount, billing_start_date, currency='USD')
        xml = Builder::XmlMarkup.new :indent => 2
        xml.tag! 'CreateRecurringPaymentsProfileReq', 'xmlns' => PAYPAL_NAMESPACE do
          xml.tag! 'CreateRecurringPaymentsProfileRequest', 'xmlns:n2' => EBAY_NAMESPACE do
            xml.tag! 'n2:Version', 50
            xml.tag! 'n2:CreateRecurringPaymentsProfileRequestDetails' do
              xml.tag! 'Token', token
              xml.tag! 'n2:RecurringPaymentsProfileDetails' do
                xml.tag! 'n2:BillingStartDate', billing_start_date
              end
              xml.tag! 'n2:ScheduleDetails' do
                xml.tag! 'n2:Description', description
                xml.tag! 'n2:PaymentPeriod' do
                  xml.tag! 'n2:BillingPeriod', 'Month'
                  xml.tag! 'n2:BillingFrequency', cycles
                  xml.tag! 'n2:TotalBillingCycles', 0
                  xml.tag! 'n2:Amount', amount, 'currencyID' => currency
                end
              end
            end
          end
        end
        xml.target!
      end

      def build_change_profile_request(profile_id, description, amount)
        xml = Builder::XmlMarkup.new :indent => 2
        xml.tag! 'UpdateRecurringPaymentsProfileReq', 'xmlns' => PAYPAL_NAMESPACE do
          xml.tag! 'UpdateRecurringPaymentsProfileRequest', 'xmlns:n2' => EBAY_NAMESPACE do
            xml.tag! 'n2:Version', 50
            xml.tag! 'n2:UpdateRecurringPaymentsProfileRequestDetails' do
              xml.tag! 'ProfileID', profile_id
              xml.tag! 'n2:ScheduleDetails' do
                xml.tag! 'n2:Description', description
                xml.tag! 'n2:PaymentPeriod' do
                  xml.tag! 'n2:Amount', amount
                end
              end
            end
          end
        end
        xml.target!
      end
      
      def manage_profile_request(profile_id, action)
        xml = Builder::XmlMarkup.new :indent => 2
        xml.tag! 'ManageRecurringPaymentsProfileStatusReq', 'xmlns' => PAYPAL_NAMESPACE do
          xml.tag! 'ManageRecurringPaymentsProfileStatusRequest', 'xmlns:n2' => EBAY_NAMESPACE do
            xml.tag! 'n2:Version', 50
            xml.tag! 'n2:ManageRecurringPaymentsProfileStatusRequestDetails' do
              xml.tag! 'ProfileID', profile_id
              xml.tag! 'n2:Action', action
            end
          end
        end
        xml.target!
      end

      def build_get_profile_details_request(profile_id)
        xml = Builder::XmlMarkup.new :indent => 2
        xml.tag! 'GetRecurringPaymentsProfileDetailsReq', 'xmlns' => PAYPAL_NAMESPACE do
          xml.tag! 'GetRecurringPaymentsProfileDetailsRequest', 'xmlns:n2' => EBAY_NAMESPACE do
            xml.tag! 'n2:Version', 50
            xml.tag! 'ProfileID', profile_id
          end
        end
        xml.target!
      end

      def build_response(success, message, response, options = {})
        PaypalExpressProfileResponse.new(success, message, response, options)
      end
   end

    class PaypalExpressProfileResponse < PaypalExpressResponse
      def profile_id
        @params['profile_id']
      end

      def next_billing_date
        @params['next_billing_date']
      end

      def active?
         @params["profile_status"]=="ActiveProfile"
      end
    end
  end
end

require 'dl/import'
require 'dl/struct'
module User32
      extend DL::Importable
    
      typealias "BOOL", "int"
      typealias "UINT", "unsigned int"
      typealias "PVOID", "void *"
      typealias "LONG", "long"
      typealias "HWND", "void *"
      typealias "LPCTSTR", "char *"
      typealias "LPVOID", "void *"
      typealias "LPCTSTR", "char *"
      typealias "FILEOP_FLAGS", "long"
    
    SHFileOperation = struct [
    "HWND hwnd",
    "UINT wFunc",
    "LPCTSTR pFrom",
    "LPCTSTR pTo",
    "FILEOP_FLAGS fFlags",
    "BOOL fAnyOperationsAborted",
    "LPVOID hNameMappings",
    "LPCTSTR lpszProgressTitle"
    ]
    
    dlload "shell32.dll"
    extern "BOOL SHFileOperation(PVOID)"

        FO_DELETE          = 3;
        FOF_ALLOWUNDO      = 64;
        FOF_NOCONFIRMATION = 16;
        
    def self.trash_file(file)
                file_info = User32::SHFileOperation::malloc
                file_info.wFunc = FO_DELETE
                file_info.pFrom = file
                file_info.pTo = file
                file_info.fFlags = FOF_ALLOWUNDO | FOF_NOCONFIRMATION
                file_info.wFunc = FO_DELETE
                puts file_info.pFrom
                if File.readable?(file)
                        sHFileOperation(file_info.to_ptr)
                end
        end
end