require 'uri' require 'net/https' module Itamae module Resource class HttpRequest < File RedirectLimitExceeded = Class.new(StandardError) HTTPClientError = Class.new(StandardError) HTTPServerError = Class.new(StandardError) HTTPUnknownError = Class.new(StandardError) alias_method :_action_create, :action_create undef_method :action_create, :action_delete, :action_edit define_attribute :action, default: :get define_attribute :headers, type: Hash, default: {} define_attribute :message, type: String, default: "" define_attribute :redirect_limit, type: Integer, default: 10 define_attribute :url, type: String, required: true def pre_action attributes.exist = true attributes.content = fetch_content send_tempfile compare_file end def show_differences current.mode = current.mode.rjust(4, '0') if current.mode attributes.mode = attributes.mode.rjust(4, '0') if attributes.mode super show_content_diff end def fetch_content uri = URI.parse(attributes.url) response = nil redirects_followed = 0 loop do http = Net::HTTP.new(uri.host, uri.port) http.use_ssl = true if uri.scheme == "https" case attributes.action when :delete, :get, :options response = http.method(attributes.action).call(uri.request_uri, attributes.headers) when :post, :put response = http.method(attributes.action).call(uri.request_uri, attributes.message, attributes.headers) end case response when Net::HTTPSuccess break when Net::HTTPRedirection if redirects_followed < attributes.redirect_limit uri = URI.parse(response["location"]) redirects_followed += 1 Itamae.logger.debug "Following redirect #{redirects_followed}/#{attributes.redirect_limit}" else raise RedirectLimitExceeded end when Net::HTTPClientError raise HTTPClientError when Net::HTTPServerError raise HTTPServerError else raise HTTPUnknownError end end response.body end def action_delete(options) _action_create(options) end def action_get(options) _action_create(options) end def action_options(options) _action_create(options) end def action_post(options) _action_create(options) end def action_put(options) _action_create(options) end end end end