class Upyun::Purge::Client
Attributes
bucket_name[RW]
operator_name[RW]
operator_password[RW]
urls[RW]
Public Class Methods
new(option = {})
click to toggle source
# File lib/upyun/purge/client.rb, line 8 def initialize(option = {}) @bucket_name = option[:bucket_name] || Upyun::Purge.bucket_name @operator_name = option[:operator_name] || Upyun::Purge.operator_name @operator_password = option[:operator_password] || Upyun::Purge.operator_password end
Public Instance Methods
auth_header(datetime)
click to toggle source
# File lib/upyun/purge/client.rb, line 41 def auth_header(datetime) "UpYun #{@bucket_name}:#{@operator_name}:#{make_signature(datetime)}" end
make_signature(datetime)
click to toggle source
# File lib/upyun/purge/client.rb, line 34 def make_signature(datetime) _urls = @urls.join("\n") second_str = [_urls, @bucket_name, datetime, md5(@operator_password)].join('&') sign = md5(second_str) sign end
md5(str)
click to toggle source
# File lib/upyun/purge/client.rb, line 45 def md5(str) Digest::MD5.hexdigest str end
purge(urls = nil)
click to toggle source
# File lib/upyun/purge/client.rb, line 14 def purge(urls = nil) @urls = urls.is_a?(Array) ? urls : [urls] @urls = @urls.compact uri = URI(Upyun::Purge.api_server) http = Net::HTTP.new(uri.host, uri.port) datetime = Time.now.gmtime.httpdate request = Net::HTTP::Post.new(uri.request_uri) request.set_form_data(purge: @urls.join("\n")) request['Authorization'] = auth_header(datetime) request['Date'] = datetime response = http.request(request) case response when Net::HTTPSuccess return JSON.parse(response.body) else raise Exception, "\n\tRequest uri:#{uri.request_uri} \n\tResponse code: #{response.code} \n\tMessage: #{response.body}" end end