generators/USAGE generators/templates/migration.rb generators/transaction_migration_generator.rb lib/amazon_fps_foo/pipeline.rb lib/amazon_fps_foo/transaction.rb @@ -5,7 +5,7 @@ require 'base64' require 'yaml' require 'rexml/document' -module AmazonFpsFoo +module AmazonFPSFoo $KCODE = "u" VERSION = "2007-01-08" SIGNATURE_VERSION = "1" @@ -21,7 +21,7 @@ module AmazonFpsFoo end ACCESS_KEY = config[:access_key] SECRET_ACCESS_KEY = config[:secret_access_key] - RETURN_BASE = config[:return_base] + SERVICE_NAME = config[:service_name] end begin @@ -29,5 +29,28 @@ module AmazonFpsFoo CALLER_TOKEN = config[:caller_token] RECIPIENT_TOKEN = config[:recipient_token] SENDER_TOKE = config[:sender_token] + rescue end + + class << self + + # Send a pay request to FPS + def pay(caller_token, recipient_token, sender_token, amount, payer, options = {}) + @transaction = Transaction.create!(:caller_token => caller_token, + :sender_token => sender_token, + :recipient_token => recipient_token, + :amount => amount, + :caller_reference => 'Order-' + Time.now.to_i.to_s, + :sender_reference => Time.now.to_i.to_s, + :recipient_reference => Time.now.to_i.to_s, + :payer => payer) + response = Query.do(call) + @transaction.update_attributes(:transaction_id => response[:transaction_response][:transaction_id], + :response_id => response[:response_id], + :state => Transaction.state_map[response[:transaction_response][:status]] + return @transaction.id + end + + end + end \ No newline at end of file lib/amazon_fps_foo.rb @@ -1,5 +1,8 @@ -module AmazonFpsFoo +module AmazonFPSFoo class Query + + class FPSError < StandardError; end + class << self include AmazonFPSFoo::Signature @@ -7,7 +10,12 @@ module AmazonFpsFoo def do params query = build_query params xml_response = send_query query - return parse(xml_response) + response = parse(xml_response) + if response[:status] == 'Success' + return response + else + raise FPSError, parse_error(response, params) + end end def build_query params @@ -15,7 +23,7 @@ module AmazonFpsFoo 'SignatureVersion' => SIGNATURE_VERSION, 'Version' => VERSION, 'Timestamp' => Time.now.gmtime.iso8601 } - params = params.merge defaults + params = params.camelize(:lower).merge defaults # case-insensitive sort params by Hash key, returns Array params = fps_sort(params) # create digest of concatenated params @@ -68,12 +76,16 @@ module AmazonFpsFoo node_name = node.name.underscore.to_sym case when node.has_elements? - node.elements.each{|e| parse_element(response, e) } + node.elements.each{|e| parse_element(response[node_name], e) } else response[node_name] = node.text end end + def parse_error(response, call) + "FPS Error (#{response[:service_error][:error_type]}): #{response[:service_error][:error_code]}\n#{response[:service_error][:reason_text]}\nOriginal Service Call: #{call.inspect}" + end + end end end \ No newline at end of file lib/amazon_fps_foo/query.rb @@ -1,4 +1,4 @@ -module AmazonFpsFoo +module AmazonFPSFoo module Signature # case-insensitive sort by Hash key lib/amazon_fps_foo/signature.rb @@ -1,4 +1,4 @@ -module AmazonFpsFoo +module AmazonFPSFoo module Version MAJOR = 0 MINOR = 1 lib/amazon_fps_foo/version.rb @@ -4,35 +4,47 @@ namespace :afps do # Generate 'Caller' token call = { 'Action' => 'InstallPaymentInstruction', 'PaymentInstruction' => "MyRole == 'Caller' orSay 'Role does not match';", - 'CallerReference' => Time.now.to_i.to_s, + 'CallerReference' => (Time.now.to_i + rand(100000)).to_s, 'TokenType' => 'Unrestricted' } - response = AmazonFpsFoo::Query.do(call) + response = AmazonFPSFoo::Query.do(call) if response[:status] && response[:status] == "Success" @caller_token_id = response[:token_id] + else + puts "Error requesting caller token:" + puts response.inspect + raise end # Generate 'Receiver' token call = {'Action' => 'InstallPaymentInstruction', 'PaymentInstruction' => "MyRole == 'Recipient' orSay 'Roles do not match';", - 'CallerReference' => Time.now.to_i.to_s, + 'CallerReference' => (Time.now.to_i + rand(100000)).to_s, 'TokenType' => 'Unrestricted' } - response = AmazonFpsFoo::Query.do(call) + response = AmazonFPSFoo::Query.do(call) if response[:status] && response[:status] == "Success" @receiver_token_id = response[:token_id] + else + puts "Error requesting receiver token:" + puts response.inspect + raise end # Generate 'Sender' token call = {'Action' => 'InstallPaymentInstruction', 'PaymentInstruction' => "MyRole == 'Sender' orSay 'Roles do not match';", - 'CallerReference' => Time.now.to_i.to_s, + 'CallerReference' => (Time.now.to_i + rand(100000)).to_s, 'TokenType' => 'Unrestricted' } - response = AmazonFpsFoo::Query.do(call) + response = AmazonFPSFoo::Query.do(call) if response[:status] && response[:status] == "Success" @sender_token_id = response[:token_id] + else + puts "Error requesting sender token:" + puts response.inspect + raise end # Dump tokens to config file - filename = "#{RAILS_ROOT}/coonfig/amazon_fps_tokens.yml" + filename = "#{RAILS_ROOT}/config/amazon_fps_tokens.yml" File.open(filename, 'w') do |file| file.write "caller_token: '#{@caller_token_id}'\n" file.write "receiver_token: '#{@receiver_token_id}'\n" tasks/amazon_fps_foo_tasks.rake @@ -1,19 +1,23 @@ development: - access_key_id: + access_key: secret_access_key: test: true + service_name: 'Application Name' test: - access_key_id: + access_key: secret_access_key: test: true + service_name: 'Application Name' staging: - access_key_id: + access_key: secret_access_key: test: true + service_name: 'Application Name' production: - access_key_id: + access_key: secret_access_key: - test: false \ No newline at end of file + test: false + service_name: 'Application Name' \ No newline at end of file templates/amazon_fps.yml.tpl lib/amazon_fps_foo/cbui.rb b7d3ac583bb6661e3328fd938c8800cdb74e9069 Matt Hodgson mhodgson@youcastr.com http://github.com/mhodgson/amazon_fps_foo/commit/a1b76186410a2a70d9367ab18d1ac1d0f038b712 a1b76186410a2a70d9367ab18d1ac1d0f038b712 2008-12-08T19:32:57-08:00 2008-12-08T19:32:57-08:00 Added database based transaction tracking f867751be0e9fe43b00f2f2290674f753434b386 Matt Hodgson mhodgson@youcastr.com