# Copyright 2011-2012 Amazon.com, Inc. or its affiliates. All Rights Reserved. # # Licensed under the Apache License, Version 2.0 (the "License"). You # may not use this file except in compliance with the License. A copy of # the License is located at # # http://aws.amazon.com/apache2.0/ # # or in the "license" file accompanying this file. This file is # distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF # ANY KIND, either express or implied. See the License for the specific # language governing permissions and limitations under the License. require 'openssl' require 'time' module AWS class SimpleWorkflow class Request < Core::Http::Request attr_accessor :body def add_authorization!(signer) self.access_key_id = signer.access_key_id headers["x-amz-date"] ||= (headers["date"] ||= Time.now.rfc822) headers["host"] ||= host #raise ArgumentError, "a security token is required" unless # signer.session_token #headers["x-amz-security-token"] = signer.session_token # compute the authorization request_hash = OpenSSL::Digest::SHA256.digest(string_to_sign) signature = signer.sign(request_hash) headers["x-amzn-authorization"] = "AWS3 "+ "AWSAccessKeyId=#{signer.access_key_id},"+ "Algorithm=HmacSHA256,"+ "SignedHeaders=#{headers_to_sign.join(';')},"+ "Signature=#{signature}" end def headers_to_sign headers.keys.select do |header| header == "host" || header =~ /^x-amz/ end end def canonical_headers headers_to_sign.map do |name| value = headers[name] "#{name.downcase.strip}:#{value.strip}\n" end.sort.join end def string_to_sign [http_method, "/", "", canonical_headers, body].join("\n") end def read_timeout # these two operations have long polling if headers['x-amz-target'] =~ /PollFor(Decision|Activity)Task/ 90 else @read_timeout end end end end end