spec/utils/db_poller_spec.rb in deimos-ruby-1.18.1 vs spec/utils/db_poller_spec.rb in deimos-ruby-1.18.2
- old
+ new
@@ -331,9 +331,24 @@
min_id: last_widget.id)
expect(Deimos.config.logger).to have_received(:info).
with('Poll my-topic-with-id complete at 2015-05-05 00:59:58 -0400 (3 batches, 0 errored batches, 7 processed messages)')
end
+ it 'should update PollInfo timestamp after processing' do
+ poll_before = Deimos::PollInfo.last
+ poller.process_updates
+ poll_after = Deimos::PollInfo.last
+ expect(poll_after.last_sent).to be >= poll_before.last_sent
+ end
+
+ it 'should update PollInfo timestamp when there are no records to process' do
+ allow(poller).to receive(:fetch_results).and_return([])
+ poll_before = Deimos::PollInfo.last
+ poller.process_updates
+ poll_after = Deimos::PollInfo.last
+ expect(poll_after.last_sent).to be >= poll_before.last_sent
+ end
+
describe 'errors' do
before(:each) do
poller.config.retries = 0
allow(Deimos.config.logger).to receive(:info)
end