test/plugin/test_out_mixpanel.rb in fluent-plugin-mixpanel-0.0.2 vs test/plugin/test_out_mixpanel.rb in fluent-plugin-mixpanel-0.0.3
- old
+ new
@@ -39,10 +39,19 @@
assert_equal 'test_token', d.instance.project_token
assert_equal 'user_id', d.instance.distinct_id_key
assert_equal 'event', d.instance.event_key
end
+ def test_configure_with_ip_key
+ d = create_driver(CONFIG + 'ip_key ip')
+
+ assert_equal 'test_token', d.instance.project_token
+ assert_equal 'user_id', d.instance.distinct_id_key
+ assert_equal 'event', d.instance.event_key
+ assert_equal 'ip', d.instance.ip_key
+ end
+
def test_write
stub_mixpanel
d = create_driver
time = Time.new('2014-01-01T01:23:45+00:00')
d.emit(sample_record, time)
@@ -75,9 +84,24 @@
assert_equal "event1", @out[1]['event']
assert_equal time2.to_i, @out[1]['properties']['time']
assert_equal "value1", @out[1]['properties']['key1']
assert_equal "value2", @out[1]['properties']['key2']
assert_equal "value2", @out[1]['properties']['key2']
+ end
+
+ def test_write_with_ip_key
+ stub_mixpanel
+ d = create_driver(CONFIG + 'ip_key ip_address')
+ time = Time.new('2014-01-01T01:23:45+00:00')
+ d.emit(sample_record.merge('ip_address' => '192.168.0.2'), time)
+ d.run
+
+ assert_equal "123", @out[0]['properties']['distinct_id']
+ assert_equal "event1", @out[0]['event']
+ assert_equal time.to_i, @out[0]['properties']['time']
+ assert_equal "192.168.0.2", @out[0]['properties']['ip']
+ assert_equal "value1", @out[0]['properties']['key1']
+ assert_equal "value2", @out[0]['properties']['key2']
end
def test_request_error
stub_mixpanel_unavailable
d = create_driver