From 6a102374c65c7f4ec74c3ee8b5ed47eccfd66b9e Mon Sep 17 00:00:00 2001 From: Leigh Morresi <275001+dgtlmoon@users.noreply.github.com> Date: Tue, 2 Feb 2021 17:50:05 +0100 Subject: [PATCH] Push newly created watches directly into the update check Queue. --- backend/backend.py | 5 ++++- backend/store.py | 5 +++-- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/backend/backend.py b/backend/backend.py index d0a962a1..b29edea7 100644 --- a/backend/backend.py +++ b/backend/backend.py @@ -310,7 +310,10 @@ def api_watch_add(): global messages # @todo add_watch should throw a custom Exception for validation etc - datastore.add_watch(url=request.form.get('url').strip(), tag=request.form.get('tag').strip()) + new_uuid = datastore.add_watch(url=request.form.get('url').strip(), tag=request.form.get('tag').strip()) + # Straight into the queue. + update_q.put(new_uuid) + messages.append({'class': 'ok', 'message': 'Watch added.'}) return redirect(url_for('main_page')) diff --git a/backend/store.py b/backend/store.py index c8cc5618..fa399796 100644 --- a/backend/store.py +++ b/backend/store.py @@ -128,15 +128,16 @@ class ChangeDetectionStore: validators.url(url) # @todo use a common generic version of this - + new_uuid = str(uuid_builder.uuid4()) _blank = self.generic_definition.copy() _blank.update({ 'url': url, 'tag': tag, - 'uuid': str(uuid_builder.uuid4()) + 'uuid': new_uuid }) self.data['watching'].update({_blank['uuid']: _blank}) + return new_uuid def sync_to_json(self):