From fe6b0b3f15c32075f1f9157a02647e232e5d600e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Bj=C3=A4reholt?= Date: Mon, 15 Mar 2021 23:20:46 +0100 Subject: [PATCH 1/2] api: Make insert event never return anything This feature has not been used since our very old replace_last code before heartbeats were a thing. --- aw_server/api.py | 2 +- tests/test_client.py | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/aw_server/api.py b/aw_server/api.py index 52ecde71..2537d113 100644 --- a/aw_server/api.py +++ b/aw_server/api.py @@ -178,7 +178,7 @@ def create_events(self, bucket_id: str, events: List[Event]) -> Optional[Event]: """Create events for a bucket. Can handle both single events and multiple ones. Returns the inserted event when a single event was inserted, otherwise None.""" - return self.db[bucket_id].insert(events[0] if len(events) == 1 else events) + return self.db[bucket_id].insert(events) @check_bucket_exists def get_eventcount( diff --git a/tests/test_client.py b/tests/test_client.py index 5f4dc9c0..2e571cc7 100755 --- a/tests/test_client.py +++ b/tests/test_client.py @@ -168,9 +168,9 @@ def test_list_buckets(aw_client, bucket): def test_send_event(aw_client, bucket): event = Event(timestamp=datetime.now(tz=timezone.utc), data={"label": "test"}) - recv_event = aw_client.send_event(bucket, event) - assert recv_event.id is not None - assert recv_event == event + aw_client.send_event(bucket, event) + recv_events = aw_client.get_events(bucket, limit=1) + assert recv_events == [event] def test_send_events(aw_client, bucket): From 61b362a42629e13a6b9851d5a10f1c4ab25b896c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Bj=C3=A4reholt?= Date: Mon, 15 Mar 2021 23:32:34 +0100 Subject: [PATCH 2/2] chore: Fix linting issue --- aw_server/__about__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/aw_server/__about__.py b/aw_server/__about__.py index 7cc23f6c..cc203f0d 100644 --- a/aw_server/__about__.py +++ b/aw_server/__about__.py @@ -52,7 +52,7 @@ def detect_version(): return basever + ".dev+unknown" -__version__ = 'v0.10.dev+32e3624' +__version__ = "v0.10.dev+32e3624" def assign_static_version():