Module: Maremma
- Defined in:
- lib/maremma.rb,
lib/maremma/version.rb
Constant Summary collapse
- DEFAULT_TIMEOUT =
60
- ALLOWED_CONTENT_TAGS =
%w(strong em b i code pre sub sup br).freeze
- NETWORKABLE_EXCEPTIONS =
[Faraday::ClientError, Faraday::TimeoutError, Faraday::ResourceNotFound, Faraday::SSLError, Faraday::ConnectionFailed, URI::InvalidURIError, Encoding::UndefinedConversionError, ArgumentError, NoMethodError, TypeError].freeze
- VERSION =
"4.9.9".freeze
Class Method Summary collapse
- .delete(url, options = {}) ⇒ Object
- .faraday_conn(options = {}) ⇒ Object
- .from_json(string) ⇒ Object
- .from_string(string) ⇒ Object
-
.from_xml(string) ⇒ Object
keep XML attributes, stackoverflow.com/a/10794044 escape tags allowed in content.
- .get(url, options = {}) ⇒ Object
-
.get_rate_limit_remaining(headers) ⇒ Object
currently supported by Twitter and Github with slightly different header names use arbitrary high value if not supported.
- .head(url, options = {}) ⇒ Object
- .is_valid_url?(url) ⇒ Boolean
- .method(url, options = {}) ⇒ Object
- .parse_error_response(string) ⇒ Object
- .parse_response(string, options = {}) ⇒ Object
- .parse_success_response(string, options = {}) ⇒ Object
- .patch(url, options = {}) ⇒ Object
-
.post(url, options = {}) ⇒ Object
ActiveSupport::XmlMini.backend = “Nokogiri”.
- .put(url, options = {}) ⇒ Object
- .rescue_faraday_error(error, response) ⇒ Object
- .set_request_headers(_url, options = {}) ⇒ Object
Class Method Details
.delete(url, options = {}) ⇒ Object
45 46 47 |
# File 'lib/maremma.rb', line 45 def self.delete(url, = {}) method(url, .merge(method: "delete")) end |
.faraday_conn(options = {}) ⇒ Object
121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 |
# File 'lib/maremma.rb', line 121 def self.faraday_conn( = {}) # make sure we have headers [:headers] ||= {} # set redirect limit limit = [:limit] || 10 Faraday.new do |c| c.ssl.verify = false if [:ssl_self_signed] c..params_encoder = Faraday::FlatParamsEncoder c.headers["Content-type"] = [:headers]["Content-type"] if [:headers]["Content-type"].present? c.headers["Accept"] = [:headers]["Accept"] c.headers["User-Agent"] = [:headers]["User-Agent"] c.request :gzip c.request :multipart c.request :json if [:headers]["Accept"] == "application/json" c.response :follow_redirects, limit: limit, cookie: :all if limit > 0 c.response :encoding c.adapter :excon end end |
.from_json(string) ⇒ Object
271 272 273 274 275 |
# File 'lib/maremma.rb', line 271 def self.from_json(string) JSON.parse(string) rescue JSON::ParserError nil end |
.from_string(string) ⇒ Object
277 278 279 |
# File 'lib/maremma.rb', line 277 def self.from_string(string) string.gsub(/\s+\n/, "\n").strip end |
.from_xml(string) ⇒ Object
keep XML attributes, stackoverflow.com/a/10794044 escape tags allowed in content
260 261 262 263 264 265 266 267 268 269 |
# File 'lib/maremma.rb', line 260 def self.from_xml(string) ALLOWED_CONTENT_TAGS.each do |tag| string.gsub!("<#{tag}>", "<#{tag}>") string.gsub!("</#{tag}>", "</#{tag}>") end if Nokogiri::XML(string, nil, "UTF-8").errors.empty? Hash.from_xml(string) end end |
.get(url, options = {}) ⇒ Object
49 50 51 |
# File 'lib/maremma.rb', line 49 def self.get(url, = {}) method(url, .merge(method: "get")) end |
.get_rate_limit_remaining(headers) ⇒ Object
currently supported by Twitter and Github with slightly different header names use arbitrary high value if not supported
254 255 256 |
# File 'lib/maremma.rb', line 254 def self.get_rate_limit_remaining(headers) (headers["X-Rate-Limit-Remaining"] || headers["X-RateLimit-Remaining"] || 100).to_i end |
.head(url, options = {}) ⇒ Object
53 54 55 |
# File 'lib/maremma.rb', line 53 def self.head(url, = {}) method(url, .merge(method: "head")) end |
.is_valid_url?(url) ⇒ Boolean
143 144 145 146 |
# File 'lib/maremma.rb', line 143 def self.is_valid_url?(url) parsed = Addressable::URI.parse(url) raise TypeError, "Invalid URL: #{url}" unless %w(http https).include?(parsed.scheme) end |
.method(url, options = {}) ⇒ Object
57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 |
# File 'lib/maremma.rb', line 57 def self.method(url, = {}) is_valid_url?(url) # normalize url url = Addressable::URI.parse(url).normalize [:data] ||= {} [:headers] = set_request_headers(url, ) conn = faraday_conn() conn.[:timeout] = [:timeout] || DEFAULT_TIMEOUT response = case [:method] when "get" conn.get url, {}, [:headers] do |request| request.headers["Host"] = URI.parse(url.to_s).host end when "post" conn.post url, {}, [:headers] do |request| request.body = [:data] request.headers["Host"] = URI.parse(url.to_s).host end when "put" conn.put url, {}, [:headers] do |request| request.body = [:data] request.headers["Host"] = URI.parse(url.to_s).host end when "patch" conn.patch url, {}, [:headers] do |request| request.body = [:data] request.headers["Host"] = URI.parse(url.to_s).host end when "delete" conn.delete url, {}, [:headers] when "head" conn.head url, {}, [:headers] end # return error if we are close to the rate limit, if supported in headers if get_rate_limit_remaining(response.headers) < 3 return OpenStruct.new(body: { "errors" => [{ "status" => 429, "title" => "Too many requests" }] }, headers: response.headers, status: response.status) end # raise errors now and not in faraday_conn so that we can collect more information raise Faraday::ConnectionFailed if response.status == 403 raise Faraday::ResourceNotFound, "Not found" if response.status == 404 raise Faraday::TimeoutError if response.status == 408 raise Faraday::ClientError if response.status >= 400 OpenStruct.new(body: parse_success_response(response.body, ), headers: response.headers, status: response.status, url: response.env[:url].to_s) rescue *NETWORKABLE_EXCEPTIONS => e error_response = rescue_faraday_error(e, response) OpenStruct.new(body: error_response, status: error_response.fetch("errors", {}).first.fetch("status", 400), headers: response ? response.headers : nil, url: response ? response.env[:url].to_s : nil) end |
.parse_error_response(string) ⇒ Object
219 220 221 222 223 224 225 226 227 228 229 230 231 |
# File 'lib/maremma.rb', line 219 def self.parse_error_response(string) string = parse_response(string) string = string["hash"] if string.is_a?(Hash) && string["hash"] if string.is_a?(Hash) && string["error"] string["error"] elsif string.is_a?(Hash) && string["errors"] string.dig("errors", 0, "title") else string end end |
.parse_response(string, options = {}) ⇒ Object
233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 |
# File 'lib/maremma.rb', line 233 def self.parse_response(string, = {}) string = string.dup string = if [:skip_encoding] string else string.encode( Encoding.find("UTF-8"), invalid: :replace, undef: :replace, replace: "?" ) end return string if [:raw] from_json(string) || from_xml(string) || from_string(string) end |
.parse_success_response(string, options = {}) ⇒ Object
203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 |
# File 'lib/maremma.rb', line 203 def self.parse_success_response(string, = {}) return nil if [:method] == "head" string = parse_response(string, ) if string.blank? { "data" => nil } elsif string.is_a?(Hash) && string["hash"] { "data" => string["hash"] } elsif string.is_a?(Hash) && string["data"] string else { "data" => string } end end |
.patch(url, options = {}) ⇒ Object
41 42 43 |
# File 'lib/maremma.rb', line 41 def self.patch(url, = {}) method(url, .merge(method: "patch")) end |
.post(url, options = {}) ⇒ Object
ActiveSupport::XmlMini.backend = “Nokogiri”
33 34 35 |
# File 'lib/maremma.rb', line 33 def self.post(url, = {}) method(url, .merge(method: "post")) end |
.put(url, options = {}) ⇒ Object
37 38 39 |
# File 'lib/maremma.rb', line 37 def self.put(url, = {}) method(url, .merge(method: "put")) end |
.rescue_faraday_error(error, response) ⇒ Object
186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 |
# File 'lib/maremma.rb', line 186 def self.rescue_faraday_error(error, response) if error.is_a?(Faraday::ResourceNotFound) { "errors" => [{ "status" => 404, "title" => "Not found" }] } elsif error. == "the server responded with status 401" || error.try(:response) && error.response[:status] == 401 { "errors" => [{ "status" => 401, "title" => "Unauthorized" }] } elsif error.is_a?(Faraday::ConnectionFailed) { "errors" => [{ "status" => 403, "title" => parse_error_response(error.) }] } elsif error.is_a?(Faraday::TimeoutError) || (error.try(:response) && error.response[:status] == 408) { "errors" => [{ "status" => 408, "title" => "Request timeout" }] } else status = response ? response.status : 400 title = response ? parse_error_response(response.body) : parse_error_response(error.) { "errors" => [{ "status" => status, "title" => title }] } end end |
.set_request_headers(_url, options = {}) ⇒ Object
148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 |
# File 'lib/maremma.rb', line 148 def self.set_request_headers(_url, = {}) = { "html" => "text/html;charset=UTF-8", "xml" => "application/xml;charset=UTF-8", "json" => "application/json;charset=UTF-8" } headers = [:headers] ||= {} # set useragent headers["User-Agent"] = ENV["USER_AGENT"] || "Mozilla/5.0 (compatible; Maremma/#{Maremma::VERSION}; +https://github.com/datacite/maremma)" # set host, needed for some services behind proxy # headers["Host"] = URI.parse(url).host #if options[:host] # set Content-Type headers["Content-type"] = .fetch([:content_type], [:content_type]) if [:content_type].present? if [:accept].present? headers["Accept"] = .fetch([:accept], [:accept]) else # accept all content headers["Accept"] ||= "text/html,application/json,application/xml;q=0.9, text/plain;q=0.8,image/png,*/*;q=0.5" end if [:bearer].present? headers["Authorization"] = "Bearer #{[:bearer]}" elsif [:token].present? headers["Authorization"] = "Token token=#{[:token]}" elsif [:github_token].present? # GitHub uses different format for token authentication headers["Authorization"] = "Token #{[:github_token]}" elsif [:username].present? basic = Base64.strict_encode64("#{[:username]}:#{[:password]}").chomp headers["Authorization"] = "Basic #{basic}" end headers end |