First complete working version

Author: thinkingserious

.gitignore

@@ -34,3 +34,4 @@ build/
 
 # unless supporting rvm < 1.11.0 or doing something fancy, ignore this:
 .rvmrc
+.env

Rakefile

@@ -0,0 +1,8 @@
+require 'rake/testtask'
+
+Rake::TestTask.new do |t|
+  t.libs << 'test'
+end
+
+desc "Run tests"
+task :default => :test

examples/example.rb

@@ -0,0 +1,73 @@
+require_relative '../lib/config'
+require_relative '../lib/ruby_http_client'
+
+Config.new
+headers = JSON.parse('
+  { 
+    "Authorization": "Bearer ' + ENV['SENDGRID_API_KEY'] + '",
+    "Content-Type": "application/json" 
+  }
+')
+host = ENV['HOST']
+client = SendGrid::Client.new(host: host, request_headers: headers)
+
+# GET Collection
+query_params = {"limit" => 100, "offset" => 0}
+response = client.version('v3').api_keys.get(query_params: query_params)
+puts response.status_code
+puts response.response_body
+puts response.response_headers
+
+# POST
+request_body = JSON.parse('
+    {
+        "name": "My API Key Ruby Test",
+        "scopes": [
+            "mail.send",
+            "alerts.create",
+            "alerts.read"
+        ]
+    }
+')
+response = client.version('v3').api_keys.post(request_body: request_body)
+puts response.status_code
+puts response.response_body
+puts response.response_headers
+api_key_id = JSON.parse(response.response_body)["api_key_id"]
+
+# GET Single
+response = client.version('v3').api_keys._(api_key_id).get()
+puts response.status_code
+puts response.response_body
+puts response.response_headers
+
+# PATCH
+request_body = JSON.parse('
+    {
+        "name": "A New Hope"
+    }
+')
+response = client.api_keys._(api_key_id).patch(request_body: request_body)
+puts response.status_code
+puts response.response_body
+puts response.response_headers
+
+# PUT
+request_body = JSON.parse('
+    {
+        "name": "A New Hope",
+        "scopes": [
+            "user.profile.read",
+            "user.profile.update"
+        ]
+    }
+')
+response = client.api_keys._(api_key_id).put(request_body: request_body)
+puts response.status_code
+puts response.response_body
+puts response.response_headers
+
+# DELETE
+response = client.api_keys._(api_key_id).delete()
+puts response.status_code
+puts response.response_headers

lib/config.rb

@@ -0,0 +1,9 @@
+class Config
+  def initialize()
+    File.open("./.env").readlines.each do |line|
+      key, value = line.split "=" 
+      ENV[key] = value.chomp
+    end
+    return ENV
+  end
+end

lib/ruby_http_client.rb

@@ -0,0 +1,117 @@
+require 'json'
+require 'net/http'
+require 'net/https'
+
+module SendGrid
+class Response
+  def initialize(response)
+    @status_code = response.code
+    @response_body = response.body
+    @response_headers = response.to_hash.inspect
+  end
+  
+  def status_code
+    @status_code
+  end
+  
+  def response_body
+    @response_body
+  end
+  
+  def response_headers
+    @response_headers
+  end
+end
+
+class Client
+  attr_reader :host, :request_headers, :url_path
+  def initialize(host:, request_headers: nil, version: nil, url_path: nil)
+    @host = host
+    @request_headers = request_headers ? request_headers : {} 
+    @version = version
+    @url_path = url_path ? url_path : []
+    @methods = ["delete", "get", "patch", "post", "put"]
+  end
+  
+  def update_headers(request_headers)
+    @request_headers = @request_headers.merge(request_headers)
+  end
+  
+  def build_url(query_params: nil)
+    url = ''
+    if @version
+      url.concat("/#{@version}")
+    end
+    @url_path.each do |x|
+      url.concat("/#{x}")
+    end
+    if query_params
+      url.concat("?")
+      count = 0
+      query_params.each do |key, value|
+        if count > 0
+          url.concat("&")
+        end
+        url.concat("#{key}=#{value}")
+        count = count +1
+      end
+    end
+    return "#{@host}#{url}"
+  end
+  
+  def _(name = nil)
+    url_path = name ? @url_path.push(name) : @url_path
+    @url_path = []
+    return Client.new(host: @host, request_headers: @request_headers, version: @version, url_path: url_path)
+  end
+  
+  def make_request(http, request)
+    response = http.request(request)
+    return Response.new(response)
+  end
+  
+  def method_missing(name, *args, &block)
+    
+    if name.to_s == "version"
+      @version = args[0]
+      return self._()
+    end
+    
+    if @methods.include?(name.to_s)
+      query_params = nil
+      request_body = nil
+      args.each do |value|
+        value.each do |key, value|
+           case key.to_s
+           when "query_params"
+             query_params = value
+           when "request_headers"
+             self.update_headers(value)
+           when "request_body"
+             request_body = value
+           else
+           end
+        end
+      end
+      uri = URI.parse(self.build_url(query_params: query_params))
+      http = Net::HTTP.new(uri.host, uri.port)
+      protocol = host.split(":")[0]
+      if protocol == "https"
+        http.use_ssl = true
+        http.verify_mode = OpenSSL::SSL::VERIFY_NONE 
+      end
+      net_http = Kernel.const_get('Net::HTTP::' + name.to_s.capitalize)
+      request = net_http.new(uri.request_uri)
+      @request_headers.each do |key, value|
+        request[key] = value
+      end
+      if request_body
+        request.body = request_body.to_json
+      end
+      return self.make_request(http, request)
+    end
+    
+    return self._(name)
+  end
+end
+end

test/test_ruby_http_client.rb

@@ -0,0 +1,74 @@
+require_relative '../lib/config'
+require_relative '../lib/ruby_http_client'
+require 'minitest/autorun'
+
+class MockResponse
+  attr_reader :status_code, :response_body, :response_headers
+  
+  def initialize(response)
+    @status_code = response['code']
+    @response_body = response['body']
+    @response_headers = response['headers']
+  end
+end
+
+class MockRequest < SendGrid::Client
+  def make_request(http, request)
+     response = {}
+     response['code'] = 200
+     response['body'] = {"message": "success"}
+     response['headers'] = {"headers" => "test"}
+     return MockResponse.new(response)
+  end
+end
+
+class TestClient < Minitest::Test
+  def setup
+    @headers = JSON.parse('
+            { 
+                "Authorization": "Bearer XXXXXXX",
+                "Content-Type": "application/json" 
+            }
+        ')
+    @host = 'http://localhost:4010'
+    @version = 'v3'
+    @client = MockRequest.new(host: @host, request_headers: @headers, version: @version)
+  end
+  
+  def test_init
+   assert_equal(@host, @client.host)
+   assert_equal(@headers, @client.request_headers)
+  end
+  
+  def test_update_headers
+    request_headers = {"X-Test" => "test"}
+    @client.update_headers(request_headers)
+    assert_equal(@headers.merge(request_headers), @client.request_headers)
+  end
+  
+  def test_url_builder
+    url1 = @client.my.path.to.the.endpoint
+    params = {"limit" => 100, "offset" => 0}
+    assert_equal(url1.build_url(query_params: params), @host + "/" + @version + "/my/path/to/the/endpoint?limit=100&offset=0")
+    
+    url1 = url1.one_more
+    params = {"limit" => 100, "offset" => 0}
+    assert_equal(url1.build_url(query_params: params), @host + "/" + @version + "/my/path/to/the/endpoint/one_more?limit=100&offset=0")
+    
+    url2 = @client.my.path._("to").the.endpoint
+    params = {"limit" => 100, "offset" => 0}
+    assert_equal(url2.build_url(query_params: params), @host + "/" + @version + "/my/path/to/the/endpoint?limit=100&offset=0")
+  end
+
+  def test__
+    url1 = @client._("test")
+    assert_equal(url1.url_path, ["test"])
+  end
+  
+  def test_method_missing
+    response = @client.get()
+    assert_equal(response.status_code, 200)
+    assert_equal(response.response_body, {"message": "success"})
+    assert_equal(response.response_headers, {"headers" => "test"})
+  end
+end