module Curl

def self.delete(url, params={}, &block)
  http :DELETE, url, postalize(params), nil, &block
end

def self.get(url, params={}, &block)
  http :GET, urlalize(url, params), nil, nil, &block
end

def self.head(url, params={}, &block)
  http :HEAD, urlalize(url, params), nil, nil, &block
end

def self.http(verb, url, post_body=nil, put_data=nil, &block)
  if Thread.current[:curb_curl_yielding]
    handle = Curl::Easy.new # we can't reuse this
  else
    handle = Thread.current[:curb_curl] ||= Curl::Easy.new
    handle.reset
  end
  handle.url = url
  handle.post_body = post_body if post_body
  handle.put_data = put_data if put_data
  if block_given?
    Thread.current[:curb_curl_yielding] = true
    yield handle
    Thread.current[:curb_curl_yielding] = false
  end
  handle.http(verb)
  handle
end

def self.options(url, params={}, &block)
  http :OPTIONS, urlalize(url, params), nil, nil, &block
end

def self.patch(url, params={}, &block)
  http :PATCH, url, postalize(params), nil, &block
end

def self.post(url, params={}, &block)
  http :POST, url, postalize(params), nil, &block
end

def self.postalize(params={})
  params.respond_to?(:map) ? URI.encode_www_form(params) : (params.respond_to?(:to_s) ? params.to_s : params)
end

def self.put(url, params={}, &block)
  http :PUT, url, nil, postalize(params), &block
end

def self.reset
  Thread.current[:curb_curl] = Curl::Easy.new
end

def self.urlalize(url, params={})
  uri = URI(url)
  # early return if we didn't specify any extra params
  return uri.to_s if (params || {}).empty?
  params_query = URI.encode_www_form(params || {})
  uri.query = [uri.query.to_s, params_query].reject(&:empty?).join('&')
  uri.to_s
end