Rename EventTracker to EventHub.

Author: chengtao

.gitignore

@@ -20,3 +20,5 @@ tmp
 *.o
 *.a
 mkmf.log
+bundler/
+*.swp

Gemfile

@@ -1,4 +1,4 @@
 source 'https://rubygems.org'
 
-# Specify your gem's dependencies in event_tracker_client.gemspec
+# Specify your gem's dependencies in event_hub_client.gemspec
 gemspec

README.md

@@ -1,46 +1,46 @@
-# EventTrackerClient
+# EventHubClient
 
-The EventTrackerClient gem is a simple wrapper of EventTracker HTTP APIs.
+The EventHubClient gem is a simple wrapper of EventHub HTTP APIs.
 
 ## Installation
 
 Add this line to your application's Gemfile:
 
-    gem 'event_tracker_client'
+    gem 'event_hub_client'
 
 And then execute:
 
     $ bundle
 
 Or install it yourself as:
 
-    $ gem install event_tracker_client
+    $ gem install event_hub_client
 
 ## Usage
 
-By the nature of the gem is supposed be used from the backend, The gem only supports two apis, track and alias. More details of about EventTracker can be found at https://github.com/Codecademy/EventTracker/
+By the nature of the gem is supposed be used from the backend, The gem only supports two apis, track and alias. More details of about EventHub can be found at https://github.com/Codecademy/EventHub/
 
 ```ruby
-event_tracker_client = EventTrackerClient::EventTrackerClient.new(host, port, EventTrackerClient::Worker.new)
-event_tracker_client.track(event_type, user_id, event_properties)
-event_tracker_client.alias(from_id, to_id)
+event_hub_client = EventHubClient::EventHubClient.new(host, port, EventHubClient::Worker.new)
+event_hub_client.track(event_type, user_id, event_properties)
+event_hub_client.alias(from_id, to_id)
 ```
 
-If the throughput from EventTrackerClient::EventTrackerClient is not good enough, consider using EventTrackerClient::BatchEventTrackerClient which batch send the requests. Please notice that you need to explicitly flush the BatchEventTrackerClient when your service is shutting down or there might be events buffered in the queue and those events might not get sent to the event tracker server.
+If the throughput from EventHubClient::EventHubClient is not good enough, consider using EventHubClient::BatchEventHubClient which batch send the requests. Please notice that you need to explicitly flush the BatchEventHubClient when your service is shutting down or there might be events buffered in the queue and those events might not get sent to the event hub server.
 
 ```ruby
-base_event_tracker_client = EventTrackerClient::EventTrackerClient.new(host, port, EventTrackerClient::Worker.new)
+base_event_hub_client = EventHubClient::EventHubClient.new(host, port, EventHubClient::Worker.new)
 queue = []
 batch_size = 10
-batch_event_tracker_client = EventTrackerClient::BatchEventTrackerClient.new(base_event_tracker_client, queue, batch_size)
-event_tracker_client.track(event_type, user_id, event_properties)
-event_tracker_client.alias(from_id, to_id)
-event_tracker_client.flush
+batch_event_hub_client = EventHubClient::BatchEventHubClient.new(base_event_hub_client, queue, batch_size)
+event_hub_client.track(event_type, user_id, event_properties)
+event_hub_client.alias(from_id, to_id)
+event_hub_client.flush
 ```
 
 ## Contributing
 
-1. Fork it ( https://github.com/Codecademy/event_tracker_client/fork )
+1. Fork it ( https://github.com/Codecademy/EventHubClient/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`)

event_tracker_client.gemspec renamed to event_hub_client.gemspec

@@ -1,15 +1,15 @@
 # coding: utf-8
 lib = File.expand_path('../lib', __FILE__)
 $LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
-require 'event_tracker_client/version'
+require 'event_hub_client/version'
 
 Gem::Specification.new do |spec|
-  spec.name          = "event_tracker_client"
-  spec.version       = EventTrackerClient::VERSION
+  spec.name          = "event_hub_client"
+  spec.version       = EventHubClient::VERSION
   spec.authors       = ["Cheng-Tao Chu"]
   spec.email         = ["chengtao@codecademy.com"]
-  spec.summary       = %q{Client for EventTracker.}
-  spec.description   = %q{More details of EventTracker available at http://github.com/Codecademy/EventTracker.}
+  spec.summary       = %q{Client for EventHub.}
+  spec.description   = %q{More details of EventHub available at http://github.com/Codecademy/EventHub.}
   spec.homepage      = ""
   spec.license       = "MIT"
 

lib/event_tracker_client.rb renamed to lib/event_hub_client.rb

@@ -1,16 +1,16 @@
-require "event_tracker_client/version"
+require "event_hub_client/version"
 require "net/http"
 require "typhoeus"
 require 'json'
 
-module EventTrackerClient
+module EventHubClient
   class Worker
     def perform(url, body)
       Typhoeus::Request.post(url, body: body)
     end
   end
 
-  class BatchEventTrackerClient
+  class BatchEventHubClient
     attr_reader :client, :queue, :batch_size
 
     def initialize(client, queue, batch_size)
@@ -30,7 +30,7 @@ def track(event_type, user_id, event_properties)
         @queue = []
       end
     end
-  
+
     def flush
       client.send_request("events/batch_track", { "events" => queue.to_json })
       @queue = []
@@ -41,36 +41,36 @@ def alias(from_id, to_id)
     end
   end
 
-  class EventTrackerClient
+  class EventHubClient
     attr_reader :host, :port, :worker
 
     def initialize(host, port, worker)
       @host = host
       @port = port
       @worker = worker
     end
-  
+
     def track(event_type, user_id, event_properties)
       path = "events/track"
-  
+
       params = {}.merge(event_properties).merge({
         "event_type" => event_type,
         "external_user_id" => user_id,
       })
-  
+
       send_request(path, params)
     end
-  
+
     def alias(from_id, to_id)
       path = "users/alias"
       params = {
         "from_external_user_id" => from_id,
         "to_external_user_id" => to_id
       }
-  
+
       send_request(path, params)
     end
-  
+
     def send_request(path, body)
       worker.perform("http://#{@host}:#{@port}/#{path}", body)
     end

lib/event_hub_client/version.rb

@@ -0,0 +1,3 @@
+module EventHubClient
+  VERSION = "0.0.1"
+end

lib/event_tracker_client/version.rb

@@ -1,15 +1,15 @@
 require "spec_helper"
 
-describe EventTrackerClient do
+describe EventHubClient do
   let(:host) { "localhost" }
   let(:port) { 3000 }
 
-  context "for BatchEventTrackerClient" do
+  context "for BatchEventHubClient" do
     let(:queue) { Array.new }
     let(:batch_size) { 2 }
-    let(:event_tracker_client) {
-      EventTrackerClient::BatchEventTrackerClient.new(
-        EventTrackerClient::EventTrackerClient.new(host, port, EventTrackerClient::Worker.new), queue, batch_size)
+    let(:event_hub_client) {
+      EventHubClient::BatchEventHubClient.new(
+        EventHubClient::EventHubClient.new(host, port, EventHubClient::Worker.new), queue, batch_size)
     }
 
     it "send direct http request when alias" do
@@ -21,7 +21,7 @@
           "from_external_user_id" => from_id,
           "to_external_user_id" => to_id
       }}).once
-      event_tracker_client.alias(from_id, to_id)
+      event_hub_client.alias(from_id, to_id)
     end
 
     it "batch track requests" do
@@ -72,15 +72,15 @@
       }}).once
 
       (0..4).each do |i|
-        event_tracker_client.track(event_types[i], user_ids[i], event_properties[i])
+        event_hub_client.track(event_types[i], user_ids[i], event_properties[i])
       end
-      event_tracker_client.flush
+      event_hub_client.flush
     end
   end
 
-  context "for EventTrackerClient" do
-    let(:event_tracker_client) {
-      EventTrackerClient::EventTrackerClient.new(host, port, EventTrackerClient::Worker.new)
+  context "for EventHubClient" do
+    let(:event_hub_client) {
+      EventHubClient::EventHubClient.new(host, port, EventHubClient::Worker.new)
     }
 
     it "send direct http request when alias" do
@@ -92,7 +92,7 @@
           "from_external_user_id" => from_id,
           "to_external_user_id" => to_id
       }}).once
-      event_tracker_client.alias(from_id, to_id)
+      event_hub_client.alias(from_id, to_id)
     end
 
     it "send direct http request when track" do
@@ -106,7 +106,7 @@
           "external_user_id" => user_id,
           "foo" => "bar"
       }}).once
-      event_tracker_client.track(event_type, user_id, event_properties)
+      event_hub_client.track(event_type, user_id, event_properties)
     end
   end
 end

spec/event_tracker_client_spec.rb renamed to spec/event_hub_client_spec.rb

@@ -1,7 +1,7 @@
 require 'bundler/setup'
 Bundler.setup
 
-require 'event_tracker_client'
+require 'event_hub_client'
 
 RSpec.configure do |config|
 end