features/step_definitions/keen_steps.rb in keen-0.2.0 vs features/step_definitions/keen_steps.rb in keen-0.2.2
- old
+ new
@@ -1,62 +1,26 @@
begin require 'rspec/expectations'; rescue LoadError; require 'spec/expectations'; end
require 'cucumber/formatter/unicode'
$:.unshift(File.dirname(__FILE__) + '/../../lib')
require 'keen'
-Given /^a Keen Client using Redis$/ do
- @client = Keen::Client.new(@project_id,
- @auth_token,
- :storage_class => Keen::Async::Storage::RedisHandler,
- :storage_namespace => "test",
- :cache_locally => true,
- :logging => false )
-
- @client.storage_handler.clear_active_queue
-
- @starting_queue_size = @client.storage_handler.count_active_queue
-end
-
Given /^a Keen Client in Direct Send mode$/ do
@client = Keen::Client.new(@project_id,
- @auth_token,
- :cache_locally => false,
+ @api_key,
:logging => false )
end
When /^I post an event$/ do
@result = @client.add_event("cucumber_events", {:hi_from => "cucumber!", :keen_version => Keen::VERSION})
end
-Then /^the size of the Redis queue should have gone up by (\d+)\.$/ do |n|
- @client.storage_handler.count_active_queue.should == n.to_i + @starting_queue_size
-end
-
Then /^the response from the server should be good\.$/ do
response = @result
response.should == {"created" => true}
end
When /^I post (\d+) events$/ do |n|
n.to_i.times do
@client.add_event("cucumber_events", {:hi_from => "cucumber!", :keen_version => Keen::VERSION})
end
-end
-
-When /^I process the queue$/ do
- worker = Keen::Async::Worker.new(@client)
- @result = worker.process_queue
-end
-
-Then /^the response from Keen should be (\d+) happy smiles$/ do |n|
- expectation = []
- n.to_i.times do
- expectation.push({"success" => true})
- end
-
- expectation = {"cucumber_events" => expectation}
-end
-
-Then /^the queue should be empty\.$/ do
- @client.storage_handler.count_active_queue.should == 0
end