Initial Commit

Author: acidtib

.editorconfig

@@ -0,0 +1,9 @@
+root = true
+
+[*.cr]
+charset = utf-8
+end_of_line = lf
+insert_final_newline = true
+indent_style = space
+indent_size = 2
+trim_trailing_whitespace = true

.gitignore

@@ -0,0 +1,10 @@
+/docs/
+/lib/
+/bin/
+/.shards/
+*.dwarf
+
+# Libraries don't need dependency lock
+# Dependencies will be locked in applications that use them
+/shard.lock
+test.cr

.travis.yml

@@ -0,0 +1,6 @@
+language: crystal
+
+# Uncomment the following if you'd like Travis to run specs and check code formatting
+# script:
+#   - crystal spec
+#   - crystal tool format --check

LICENSE

@@ -0,0 +1,21 @@
+The MIT License (MIT)
+
+Copyright (c) 2019 Dainel Vera
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

README.md

@@ -0,0 +1,39 @@
+# hunter.cr
+
+A Crystal-Lang wrapper for Hunter.io API V2
+
+## Installation
+
+1. Add the dependency to your `shard.yml`:
+
+   ```yaml
+   dependencies:
+     hunter:
+       github: arubinofaux/hunter.cr
+   ```
+
+2. Run `shards install`
+
+## Usage
+
+```crystal
+require "hunter"
+```
+
+TODO: Write usage instructions here
+
+## Development
+
+TODO: Write development instructions here
+
+## Contributing
+
+1. Fork it (<https://github.com/arubinofaux/hunter.cr/fork>)
+2. Create your feature branch (`git checkout -b my-new-feature`)
+3. Commit your changes (`git commit -am 'Add some feature'`)
+4. Push to the branch (`git push origin my-new-feature`)
+5. Create a new Pull Request
+
+## Contributors
+
+- [arubinofaux](https://github.com/arubinofaux) - creator and maintainer

shard.yml

@@ -0,0 +1,9 @@
+name: hunter
+version: 0.1.0
+
+authors:
+  - Dainel Vera <[email protected]>
+
+crystal: 0.31.1
+
+license: MIT

spec/hunter_spec.cr

@@ -0,0 +1,9 @@
+require "./spec_helper"
+
+describe Hunter do
+  # TODO: Write tests
+
+  it "works" do
+    false.should eq(true)
+  end
+end

spec/spec_helper.cr

@@ -0,0 +1,2 @@
+require "spec"
+require "../src/hunter"

src/hunter.cr

@@ -0,0 +1,12 @@
+require "http/client"
+require "json"
+
+require "./hunter/**"
+
+module Hunter
+  VERSION = "0.1.0"
+
+  def self.new(apiKey : String)
+    Client.new(apiKey)
+  end
+end

src/hunter/api.cr

@@ -0,0 +1,45 @@
+module Hunter
+  class Api
+    APIVersion = "v2"
+    Headers = HTTP::Headers{"Content-Type" => "application/json", "Accept" => "application/json", "User-Agent" => "hunter.cr"}
+
+    def initialize(@httpClient : HTTP::Client, @apiKey : String)
+    end
+
+    # 200 - OK / The request was successful
+    # 201 - Created / The request was successful and the resource was created
+    # 202 - Email verification in progress / The Email verification is still in progress. Feel free to make the same verification again as often as you want, it will only count as a single request until we return the response
+    # 204 - No content / The request was successful and no additional content was sent
+    # 222 - Email verification failed / The Email verification failed because of an unexpected response from the remote SMTP server. This failure is outside of our control. We advise you to retry later
+    # 400 - Bad request / Your request was not valid
+    # 401 - Unauthorized / No valid API key was provided
+    # 403 - Forbidden / You have reached the rate limit
+    # 404 - Not found / The requested resource does not exist
+    # 422 - Unprocessable entity / Your request is valid but the creation of the resource failed. Check the errors
+    # 429 - Too many requests / You have reached your usage limit. Upgrade your plan if necessary
+    # 451 - Unavailable for legal reasons / The person behind the requested resource has asked us directly or indirectly to stop the processing of this resource. For this reason, you shouldn't process this resource yourself in any way
+    # 5XX - Server errors / Something went wrong on Hunter's end
+    def handleResponse(response : HTTP::Client::Response)
+      case response.status_code
+      when 200, 201, 202, 222
+        JSON.parse(response.body)
+      when 204
+        {"ok"}
+      when 400, 401, 403, 404, 422, 429, 451
+        JSON.parse(response.body)
+      when 500
+        JSON.parse(response.body)
+      else
+        {
+          "errors": [
+            {
+              "id": "total_meltdown",
+              "code": 9000,
+              "details": "Something bad happened"
+            }
+          ]
+        }
+      end
+    end
+  end
+end

src/hunter/api/account.cr

@@ -0,0 +1,12 @@
+module Hunter
+  class Api::Account < Api
+    def me()
+      params = Hash(String, String).new
+      params["api_key"] = @apiKey
+      params = HTTP::Params.encode(params)
+
+      response = @httpClient.get("/#{APIVersion}/account?" + params, headers: Headers)
+      handleResponse(response)
+    end
+  end
+end

src/hunter/api/domain.cr

@@ -0,0 +1,19 @@
+module Hunter
+  class Api::Domain < Api
+    def search(domain = nil, company = nil, limit = nil, offset = nil, type = nil, seniority = nil, department = nil)
+      params = Hash(String, String).new
+      params["domain"] = domain if domain
+      params["company"] = company if company
+      params["limit"] = limit if limit
+      params["offset"] = offset if offset
+      params["type"] = type if type
+      params["seniority"] = seniority if seniority 
+      params["department"] = department if department
+      params["api_key"] = @apiKey
+      params = HTTP::Params.encode(params)
+
+      response = @httpClient.get("/#{APIVersion}/domain-search?" + params, headers: Headers)
+      handleResponse(response)
+    end
+  end
+end

src/hunter/api/email.cr

@@ -0,0 +1,38 @@
+module Hunter
+  class Api::Email < Api
+    def finder(domain = nil, company = nil, first_name = nil, last_name = nil, full_name = nil)
+      params = Hash(String, String).new
+      params["domain"] = domain if domain
+      params["company"] = company if company
+      params["first_name"] = first_name if first_name
+      params["last_name"] = last_name if last_name
+      params["full_name"] = full_name if full_name
+      params["api_key"] = @apiKey
+      params = HTTP::Params.encode(params)
+
+      response = @httpClient.get("/#{APIVersion}/email-finder?" + params, headers: Headers)
+      handleResponse(response)
+    end
+
+    def verifier(email = nil)
+      params = Hash(String, String).new
+      params["email"] = email if email
+      params["api_key"] = @apiKey
+      params = HTTP::Params.encode(params)
+
+      response = @httpClient.get("/#{APIVersion}/email-verifier?" + params, headers: Headers)
+      handleResponse(response)
+    end
+
+    def count(domain = nil, company = nil, type = nil)
+      params = Hash(String, String).new
+      params["domain"] = domain if domain
+      params["company"] = company if company
+      params["type"] = type if type
+      params = HTTP::Params.encode(params)
+
+      response = @httpClient.get("/#{APIVersion}/email-count?" + params, headers: Headers)
+      handleResponse(response)
+    end
+  end
+end

src/hunter/api/leads.cr

@@ -0,0 +1,104 @@
+module Hunter
+  class Api::Leads < Api
+    def all(limit = nil, lead_list_id = nil, email = nil, first_name = nil, last_name = nil, position = nil, company = nil, industry = nil, website = nil, country_code = nil, company_size = nil, source = nil, twitter = nil, linkedin_url = nil, phone_number = nil, sync_status = nil, sending_status = nil, last_activity_at = nil, query = nil, offset = nil)
+      params = Hash(String, String).new
+      params["limit"] = limit if limit
+      params["lead_list_id"] = lead_list_id if lead_list_id
+      params["email"] = email if email
+      params["first_name"] = first_name if first_name
+      params["last_name"] = last_name if last_name
+      params["position"] = position if position
+      params["company"] = company if company
+      params["industry"] = industry if industry
+      params["website"] = website if website
+      params["country_code"] = country_code if country_code
+      params["company_size"] = company_size if company_size
+      params["source"] = source if source
+      params["twitter"] = twitter if twitter
+      params["linkedin_url"] = linkedin_url if linkedin_url
+      params["phone_number"] = phone_number if phone_number
+      params["sync_status"] = sync_status if sync_status
+      params["sending_status"] = sending_status if sending_status
+      params["last_activity_at"] = last_activity_at if last_activity_at
+      params["query"] = query if query
+      params["offset"] = offset if offset
+      params["api_key"] = @apiKey
+      params = HTTP::Params.encode(params)
+
+      response = @httpClient.get("/#{APIVersion}/leads?" + params, headers: Headers)
+      handleResponse(response)
+    end
+
+    def get(id = nil)
+      params = Hash(String, String).new
+      params["api_key"] = @apiKey
+      params = HTTP::Params.encode(params)
+
+      response = @httpClient.get("/#{APIVersion}/leads/#{id}?" + params, headers: Headers)
+      handleResponse(response)
+    end
+
+    def create(email = nil, first_name = nil, last_name = nil, position = nil, company = nil, company_industry = nil, company_size = nil, confidence_score = nil, website = nil, country_code = nil, linkedin_url = nil, phone_number = nil, twitter = nil, notes = nil, source = nil, lead_list_id = nil)
+      params = Hash(String, String).new
+      params["api_key"] = @apiKey
+      params = HTTP::Params.encode(params)
+
+      body = Hash(String, String).new
+      body["email"] = email if email
+      body["first_name"] = first_name if first_name
+      body["last_name"] = last_name if last_name
+      body["position"] = position if position
+      body["company"] = company if company
+      body["company_industry"] = company_industry if company_industry
+      body["company_size"] = company_size if company_size
+      body["confidence_score"] = confidence_score if confidence_score
+      body["website"] = website if website
+      body["country_code"] = country_code if country_code
+      body["linkedin_url"] = linkedin_url if linkedin_url
+      body["phone_number"] = phone_number if phone_number
+      body["twitter"] = twitter if twitter
+      body["notes"] = notes if notes
+      body["source"] = source if source
+      body["lead_list_id"] = lead_list_id if lead_list_id
+
+      response = @httpClient.post("/#{APIVersion}/leads?" + params, headers: Headers, body: body.to_json)
+      handleResponse(response)
+    end
+
+    def update(id = nil, email = nil, first_name = nil, last_name = nil, position = nil, company = nil, company_industry = nil, company_size = nil, confidence_score = nil, website = nil, country_code = nil, linkedin_url = nil, phone_number = nil, twitter = nil, notes = nil, source = nil, lead_list_id = nil)
+      params = Hash(String, String).new
+      params["api_key"] = @apiKey
+      params = HTTP::Params.encode(params)
+
+      body = Hash(String, String).new
+      body["email"] = email if email
+      body["first_name"] = first_name if first_name
+      body["last_name"] = last_name if last_name
+      body["position"] = position if position
+      body["company"] = company if company
+      body["company_industry"] = company_industry if company_industry
+      body["company_size"] = company_size if company_size
+      body["confidence_score"] = confidence_score if confidence_score
+      body["website"] = website if website
+      body["country_code"] = country_code if country_code
+      body["linkedin_url"] = linkedin_url if linkedin_url
+      body["phone_number"] = phone_number if phone_number
+      body["twitter"] = twitter if twitter
+      body["notes"] = notes if notes
+      body["source"] = source if source
+      body["lead_list_id"] = lead_list_id if lead_list_id
+
+      response = @httpClient.put("/#{APIVersion}/leads/#{id}?" + params, headers: Headers, body: body.to_json)
+      handleResponse(response)
+    end
+
+    def delete(id = nil)
+      params = Hash(String, String).new
+      params["api_key"] = @apiKey
+      params = HTTP::Params.encode(params)
+
+      response = @httpClient.delete("/#{APIVersion}/leads/#{id}?" + params, headers: Headers)
+      handleResponse(response)
+    end
+  end
+end