Merge 31c60bc into 39fcfa2

snowplow · Jul 25, 2019 · 80a2e19 · 80a2e19
2 parents 39fcfa2 + 31c60bc
commit 80a2e19
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/lib/snowplow-tracker/emitters.rb b/lib/snowplow-tracker/emitters.rb
@@ -28,6 +28,7 @@ class Emitter
     include Contracts
 
     @@ConfigHash = ({
+      :path => Maybe[String],
       :protocol => Maybe[Or['http', 'https']],
       :port => Maybe[Num],
       :method => Maybe[Or['get', 'post']],
@@ -50,7 +51,8 @@ class Emitter
     def initialize(endpoint, config={})
       config = @@DefaultConfig.merge(config)
       @lock = Monitor.new
-      @collector_uri = as_collector_uri(endpoint, config[:protocol], config[:port], config[:method])
+      path = config[:path].nil? ? config[:method] == 'get' ? '/i' : '/com.snowplowanalytics.snowplow/tp2' : config[:path]
+      @collector_uri = as_collector_uri(endpoint, config[:protocol], config[:port], path)
       @buffer = []
       if not config[:buffer_size].nil?
         @buffer_size = config[:buffer_size]
@@ -70,9 +72,8 @@ def initialize(endpoint, config={})
     # Build the collector URI from the configuration hash
     #
     Contract String, String, Maybe[Num], String => String
-    def as_collector_uri(endpoint, protocol, port, method)
+    def as_collector_uri(endpoint, protocol, port, path)
       port_string = port == nil ? '' : ":#{port.to_s}"
-      path = method == 'get' ? '/i' : '/com.snowplowanalytics.snowplow/tp2'
 
       "#{protocol}://#{endpoint}#{port_string}#{path}"
     end