From 9158c0b83d89333e52c59a429c761edde3b7a1a9 Mon Sep 17 00:00:00 2001 From: Sandy Walsh Date: Wed, 4 Mar 2015 09:26:35 -0800 Subject: [PATCH] Support for the new /events resource. Also fixes up the delete_stream() call. Renames get_streams() to find_streams() as per find_events(). Change-Id: Idf7c35b2ef79e170221e86987dd632744b5433b2 --- quince/v1_impl.py | 23 +++++++++++++++++++---- setup.cfg | 2 +- 2 files changed, 20 insertions(+), 5 deletions(-) diff --git a/quince/v1_impl.py b/quince/v1_impl.py index c98571e..ff24f51 100644 --- a/quince/v1_impl.py +++ b/quince/v1_impl.py @@ -54,7 +54,7 @@ class Impl(object): self.winchester_config = scratchpad['quincy_config'] self.driver = scratchpad['quincy_driver'] - def get_streams(self, count=False, state=None, older_than=None, + def find_streams(self, count=False, state=None, older_than=None, younger_than=None, trigger_name=None, distinguishing_traits=None, mark=None, limit=None): @@ -77,8 +77,23 @@ class Impl(object): include_events=details) def delete_stream(self, stream_id): - pass + stream_id = int(stream_id) + stream = self.driver.get_stream_by_id(stream_id) + self.driver.purge_stream(stream) def reset_stream(self, stream_id): - stream = int(stream_id) - self.driver.reset_stream(stream_id) + stream_id = int(stream_id) + stream = self.driver.get_stream_by_id(stream_id) + self.driver.reset_stream(stream) + + def find_events(self, from_datetime=None, to_datetime=None, + event_name=None, traits=[], + mark=None, limit=None): + return self.driver.find_events(from_datetime=from_datetime, + to_datetime=to_datetime, + event_name=event_name, + traits=traits, + mark=mark, limit=limit) + + def get_event(self, message_id): + return self.driver.get_event_by_message_id(message_id) diff --git a/setup.cfg b/setup.cfg index b116b4f..ddcada6 100644 --- a/setup.cfg +++ b/setup.cfg @@ -1,6 +1,6 @@ [metadata] name = quince -version = 1.0 +version = 0.2 author = Dark Secret Software Inc. author-email = admin@darksecretsoftware.com summary = Default implementation for Quincy