From 589772f7bd38806e53f692edded0ec28a948d3ce Mon Sep 17 00:00:00 2001 From: Rucha Mahabal Date: Thu, 26 Dec 2019 14:29:08 +0530 Subject: [PATCH] fix: rename Events Streaming to Event Streaming --- frappe/{events_streaming => event_streaming}/__init__.py | 0 .../doctype/__init__.py | 0 .../doctype/document_type_field_mapping/__init__.py | 0 .../document_type_field_mapping.json | 2 +- .../document_type_field_mapping.py | 0 .../doctype/document_type_mapping/__init__.py | 0 .../doctype/document_type_mapping/document_type_mapping.js | 0 .../document_type_mapping/document_type_mapping.json | 2 +- .../doctype/document_type_mapping/document_type_mapping.py | 0 .../document_type_mapping/test_document_type_mapping.py | 0 .../doctype/event_consumer/__init__.py | 0 .../doctype/event_consumer/event_consumer.js | 0 .../doctype/event_consumer/event_consumer.json | 2 +- .../doctype/event_consumer/event_consumer.py | 6 +++--- .../doctype/event_consumer/test_event_consumer.py | 0 .../doctype/event_consumer_document_type/__init__.py | 0 .../event_consumer_document_type.json | 2 +- .../event_consumer_document_type.py | 0 .../doctype/event_producer/__init__.py | 0 .../doctype/event_producer/event_producer.js | 0 .../doctype/event_producer/event_producer.json | 2 +- .../doctype/event_producer/event_producer.py | 4 ++-- .../doctype/event_producer/test_event_producer.py | 2 +- .../doctype/event_producer_document_type/__init__.py | 0 .../event_producer_document_type.json | 2 +- .../event_producer_document_type.py | 0 .../doctype/event_sync_log/__init__.py | 0 .../doctype/event_sync_log/event_sync_log.js | 2 +- .../doctype/event_sync_log/event_sync_log.json | 2 +- .../doctype/event_sync_log/event_sync_log.py | 0 .../doctype/event_sync_log/event_sync_log_list.js | 0 .../doctype/event_sync_log/test_event_sync_log.py | 0 .../doctype/event_update_log/__init__.py | 0 .../doctype/event_update_log/event_update_log.js | 0 .../doctype/event_update_log/event_update_log.json | 2 +- .../doctype/event_update_log/event_update_log.py | 2 +- .../doctype/event_update_log/test_event_update_log.py | 0 frappe/hooks.py | 2 +- frappe/model/document.py | 2 +- frappe/modules.txt | 2 +- 40 files changed, 19 insertions(+), 19 deletions(-) rename frappe/{events_streaming => event_streaming}/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/document_type_field_mapping/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/document_type_field_mapping/document_type_field_mapping.json (97%) rename frappe/{events_streaming => event_streaming}/doctype/document_type_field_mapping/document_type_field_mapping.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/document_type_mapping/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/document_type_mapping/document_type_mapping.js (100%) rename frappe/{events_streaming => event_streaming}/doctype/document_type_mapping/document_type_mapping.json (97%) rename frappe/{events_streaming => event_streaming}/doctype/document_type_mapping/document_type_mapping.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/document_type_mapping/test_document_type_mapping.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_consumer/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_consumer/event_consumer.js (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_consumer/event_consumer.json (98%) rename frappe/{events_streaming => event_streaming}/doctype/event_consumer/event_consumer.py (93%) rename frappe/{events_streaming => event_streaming}/doctype/event_consumer/test_event_consumer.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_consumer_document_type/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_consumer_document_type/event_consumer_document_type.json (96%) rename frappe/{events_streaming => event_streaming}/doctype/event_consumer_document_type/event_consumer_document_type.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_producer/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_producer/event_producer.js (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_producer/event_producer.json (98%) rename frappe/{events_streaming => event_streaming}/doctype/event_producer/event_producer.py (98%) rename frappe/{events_streaming => event_streaming}/doctype/event_producer/test_event_producer.py (98%) rename frappe/{events_streaming => event_streaming}/doctype/event_producer_document_type/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_producer_document_type/event_producer_document_type.json (97%) rename frappe/{events_streaming => event_streaming}/doctype/event_producer_document_type/event_producer_document_type.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_sync_log/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_sync_log/event_sync_log.js (85%) rename frappe/{events_streaming => event_streaming}/doctype/event_sync_log/event_sync_log.json (98%) rename frappe/{events_streaming => event_streaming}/doctype/event_sync_log/event_sync_log.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_sync_log/event_sync_log_list.js (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_sync_log/test_event_sync_log.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_update_log/__init__.py (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_update_log/event_update_log.js (100%) rename frappe/{events_streaming => event_streaming}/doctype/event_update_log/event_update_log.json (97%) rename frappe/{events_streaming => event_streaming}/doctype/event_update_log/event_update_log.py (96%) rename frappe/{events_streaming => event_streaming}/doctype/event_update_log/test_event_update_log.py (100%) diff --git a/frappe/events_streaming/__init__.py b/frappe/event_streaming/__init__.py similarity index 100% rename from frappe/events_streaming/__init__.py rename to frappe/event_streaming/__init__.py diff --git a/frappe/events_streaming/doctype/__init__.py b/frappe/event_streaming/doctype/__init__.py similarity index 100% rename from frappe/events_streaming/doctype/__init__.py rename to frappe/event_streaming/doctype/__init__.py diff --git a/frappe/events_streaming/doctype/document_type_field_mapping/__init__.py b/frappe/event_streaming/doctype/document_type_field_mapping/__init__.py similarity index 100% rename from frappe/events_streaming/doctype/document_type_field_mapping/__init__.py rename to frappe/event_streaming/doctype/document_type_field_mapping/__init__.py diff --git a/frappe/events_streaming/doctype/document_type_field_mapping/document_type_field_mapping.json b/frappe/event_streaming/doctype/document_type_field_mapping/document_type_field_mapping.json similarity index 97% rename from frappe/events_streaming/doctype/document_type_field_mapping/document_type_field_mapping.json rename to frappe/event_streaming/doctype/document_type_field_mapping/document_type_field_mapping.json index 86a154a348..bc36aa6dfc 100644 --- a/frappe/events_streaming/doctype/document_type_field_mapping/document_type_field_mapping.json +++ b/frappe/event_streaming/doctype/document_type_field_mapping/document_type_field_mapping.json @@ -41,7 +41,7 @@ "istable": 1, "modified": "2019-10-09 08:26:06.457122", "modified_by": "Administrator", - "module": "Events Streaming", + "module": "Event Streaming", "name": "Document Type Field Mapping", "owner": "Administrator", "permissions": [], diff --git a/frappe/events_streaming/doctype/document_type_field_mapping/document_type_field_mapping.py b/frappe/event_streaming/doctype/document_type_field_mapping/document_type_field_mapping.py similarity index 100% rename from frappe/events_streaming/doctype/document_type_field_mapping/document_type_field_mapping.py rename to frappe/event_streaming/doctype/document_type_field_mapping/document_type_field_mapping.py diff --git a/frappe/events_streaming/doctype/document_type_mapping/__init__.py b/frappe/event_streaming/doctype/document_type_mapping/__init__.py similarity index 100% rename from frappe/events_streaming/doctype/document_type_mapping/__init__.py rename to frappe/event_streaming/doctype/document_type_mapping/__init__.py diff --git a/frappe/events_streaming/doctype/document_type_mapping/document_type_mapping.js b/frappe/event_streaming/doctype/document_type_mapping/document_type_mapping.js similarity index 100% rename from frappe/events_streaming/doctype/document_type_mapping/document_type_mapping.js rename to frappe/event_streaming/doctype/document_type_mapping/document_type_mapping.js diff --git a/frappe/events_streaming/doctype/document_type_mapping/document_type_mapping.json b/frappe/event_streaming/doctype/document_type_mapping/document_type_mapping.json similarity index 97% rename from frappe/events_streaming/doctype/document_type_mapping/document_type_mapping.json rename to frappe/event_streaming/doctype/document_type_mapping/document_type_mapping.json index 62d1de5c23..6a59cf3b70 100644 --- a/frappe/events_streaming/doctype/document_type_mapping/document_type_mapping.json +++ b/frappe/event_streaming/doctype/document_type_mapping/document_type_mapping.json @@ -47,7 +47,7 @@ ], "modified": "2019-10-09 08:36:04.621397", "modified_by": "Administrator", - "module": "Events Streaming", + "module": "Event Streaming", "name": "Document Type Mapping", "owner": "Administrator", "permissions": [ diff --git a/frappe/events_streaming/doctype/document_type_mapping/document_type_mapping.py b/frappe/event_streaming/doctype/document_type_mapping/document_type_mapping.py similarity index 100% rename from frappe/events_streaming/doctype/document_type_mapping/document_type_mapping.py rename to frappe/event_streaming/doctype/document_type_mapping/document_type_mapping.py diff --git a/frappe/events_streaming/doctype/document_type_mapping/test_document_type_mapping.py b/frappe/event_streaming/doctype/document_type_mapping/test_document_type_mapping.py similarity index 100% rename from frappe/events_streaming/doctype/document_type_mapping/test_document_type_mapping.py rename to frappe/event_streaming/doctype/document_type_mapping/test_document_type_mapping.py diff --git a/frappe/events_streaming/doctype/event_consumer/__init__.py b/frappe/event_streaming/doctype/event_consumer/__init__.py similarity index 100% rename from frappe/events_streaming/doctype/event_consumer/__init__.py rename to frappe/event_streaming/doctype/event_consumer/__init__.py diff --git a/frappe/events_streaming/doctype/event_consumer/event_consumer.js b/frappe/event_streaming/doctype/event_consumer/event_consumer.js similarity index 100% rename from frappe/events_streaming/doctype/event_consumer/event_consumer.js rename to frappe/event_streaming/doctype/event_consumer/event_consumer.js diff --git a/frappe/events_streaming/doctype/event_consumer/event_consumer.json b/frappe/event_streaming/doctype/event_consumer/event_consumer.json similarity index 98% rename from frappe/events_streaming/doctype/event_consumer/event_consumer.json rename to frappe/event_streaming/doctype/event_consumer/event_consumer.json index 14ab6b2f70..341fd07982 100644 --- a/frappe/events_streaming/doctype/event_consumer/event_consumer.json +++ b/frappe/event_streaming/doctype/event_consumer/event_consumer.json @@ -80,7 +80,7 @@ "links": [], "modified": "2019-12-26 13:05:08.020129", "modified_by": "Administrator", - "module": "Events Streaming", + "module": "Event Streaming", "name": "Event Consumer", "owner": "Administrator", "permissions": [ diff --git a/frappe/events_streaming/doctype/event_consumer/event_consumer.py b/frappe/event_streaming/doctype/event_consumer/event_consumer.py similarity index 93% rename from frappe/events_streaming/doctype/event_consumer/event_consumer.py rename to frappe/event_streaming/doctype/event_consumer/event_consumer.py index 84f92596b0..dae3e7b704 100644 --- a/frappe/events_streaming/doctype/event_consumer/event_consumer.py +++ b/frappe/event_streaming/doctype/event_consumer/event_consumer.py @@ -9,7 +9,7 @@ import json import requests from frappe.model.document import Document from frappe.frappeclient import FrappeClient -from frappe.events_streaming.doctype.event_producer.event_producer import get_current_node +from frappe.event_streaming.doctype.event_producer.event_producer import get_current_node from frappe.utils.background_jobs import get_jobs class EventConsumer(Document): @@ -107,7 +107,7 @@ def notify(consumer): try: client = get_consumer_site(consumer.callback_url) client.post_request({ - 'cmd': 'frappe.events_streaming.doctype.event_producer.event_producer.new_event_notification', + 'cmd': 'frappe.event_streaming.doctype.event_producer.event_producer.new_event_notification', 'producer_url': get_current_node() }) consumer.flags.notified = True @@ -118,7 +118,7 @@ def notify(consumer): #enqueue another job if the site was not notified if not consumer.flags.notified: - enqueued_method = 'frappe.events_streaming.doctype.event_consumer.event_consumer.notify' + enqueued_method = 'frappe.event_streaming.doctype.event_consumer.event_consumer.notify' jobs = get_jobs() if not jobs or enqueued_method not in jobs[frappe.local.site] and not consumer.flags.notifed: frappe.enqueue(enqueued_method, queue = 'long', enqueue_after_commit = True, **{'consumer': consumer}) \ No newline at end of file diff --git a/frappe/events_streaming/doctype/event_consumer/test_event_consumer.py b/frappe/event_streaming/doctype/event_consumer/test_event_consumer.py similarity index 100% rename from frappe/events_streaming/doctype/event_consumer/test_event_consumer.py rename to frappe/event_streaming/doctype/event_consumer/test_event_consumer.py diff --git a/frappe/events_streaming/doctype/event_consumer_document_type/__init__.py b/frappe/event_streaming/doctype/event_consumer_document_type/__init__.py similarity index 100% rename from frappe/events_streaming/doctype/event_consumer_document_type/__init__.py rename to frappe/event_streaming/doctype/event_consumer_document_type/__init__.py diff --git a/frappe/events_streaming/doctype/event_consumer_document_type/event_consumer_document_type.json b/frappe/event_streaming/doctype/event_consumer_document_type/event_consumer_document_type.json similarity index 96% rename from frappe/events_streaming/doctype/event_consumer_document_type/event_consumer_document_type.json rename to frappe/event_streaming/doctype/event_consumer_document_type/event_consumer_document_type.json index 210106bdec..7463a518ba 100644 --- a/frappe/events_streaming/doctype/event_consumer_document_type/event_consumer_document_type.json +++ b/frappe/event_streaming/doctype/event_consumer_document_type/event_consumer_document_type.json @@ -29,7 +29,7 @@ "istable": 1, "modified": "2019-10-29 15:26:32.436528", "modified_by": "Administrator", - "module": "Events Streaming", + "module": "Event Streaming", "name": "Event Consumer Document Type", "owner": "Administrator", "permissions": [], diff --git a/frappe/events_streaming/doctype/event_consumer_document_type/event_consumer_document_type.py b/frappe/event_streaming/doctype/event_consumer_document_type/event_consumer_document_type.py similarity index 100% rename from frappe/events_streaming/doctype/event_consumer_document_type/event_consumer_document_type.py rename to frappe/event_streaming/doctype/event_consumer_document_type/event_consumer_document_type.py diff --git a/frappe/events_streaming/doctype/event_producer/__init__.py b/frappe/event_streaming/doctype/event_producer/__init__.py similarity index 100% rename from frappe/events_streaming/doctype/event_producer/__init__.py rename to frappe/event_streaming/doctype/event_producer/__init__.py diff --git a/frappe/events_streaming/doctype/event_producer/event_producer.js b/frappe/event_streaming/doctype/event_producer/event_producer.js similarity index 100% rename from frappe/events_streaming/doctype/event_producer/event_producer.js rename to frappe/event_streaming/doctype/event_producer/event_producer.js diff --git a/frappe/events_streaming/doctype/event_producer/event_producer.json b/frappe/event_streaming/doctype/event_producer/event_producer.json similarity index 98% rename from frappe/events_streaming/doctype/event_producer/event_producer.json rename to frappe/event_streaming/doctype/event_producer/event_producer.json index 2e3fbed455..8eba1924f5 100644 --- a/frappe/events_streaming/doctype/event_producer/event_producer.json +++ b/frappe/event_streaming/doctype/event_producer/event_producer.json @@ -76,7 +76,7 @@ "links": [], "modified": "2019-12-26 13:04:11.438349", "modified_by": "Administrator", - "module": "Events Streaming", + "module": "Event Streaming", "name": "Event Producer", "owner": "Administrator", "permissions": [ diff --git a/frappe/events_streaming/doctype/event_producer/event_producer.py b/frappe/event_streaming/doctype/event_producer/event_producer.py similarity index 98% rename from frappe/events_streaming/doctype/event_producer/event_producer.py rename to frappe/event_streaming/doctype/event_producer/event_producer.py index 3480474901..db26c0f976 100644 --- a/frappe/events_streaming/doctype/event_producer/event_producer.py +++ b/frappe/event_streaming/doctype/event_producer/event_producer.py @@ -37,7 +37,7 @@ class EventProducer(Document): if self.is_producer_online(): producer_site = FrappeClient(self.producer_url, verify=False) response = producer_site.post_api( - 'frappe.events_streaming.doctype.event_consumer.event_consumer.register_consumer', + 'frappe.event_streaming.doctype.event_consumer.event_consumer.register_consumer', params = {'data': json.dumps(self.get_request_data())} ) response = json.loads(response) @@ -355,7 +355,7 @@ def get_mapped_update(update): @frappe.whitelist() def new_event_notification(producer_url): '''Pull data from producer when notified''' - enqueued_method = 'frappe.events_streaming.doctype.event_producer.event_producer.pull_from_node' + enqueued_method = 'frappe.event_streaming.doctype.event_producer.event_producer.pull_from_node' jobs = get_jobs() if not jobs or enqueued_method not in jobs[frappe.local.site]: frappe.enqueue(enqueued_method, queue = 'default', **{'event_producer': producer_url}) diff --git a/frappe/events_streaming/doctype/event_producer/test_event_producer.py b/frappe/event_streaming/doctype/event_producer/test_event_producer.py similarity index 98% rename from frappe/events_streaming/doctype/event_producer/test_event_producer.py rename to frappe/event_streaming/doctype/event_producer/test_event_producer.py index 4bf194f194..9c04c1e4b8 100644 --- a/frappe/events_streaming/doctype/event_producer/test_event_producer.py +++ b/frappe/event_streaming/doctype/event_producer/test_event_producer.py @@ -7,7 +7,7 @@ import frappe import unittest import time from frappe.frappeclient import FrappeClient -from frappe.events_streaming.doctype.event_producer.event_producer import pull_from_node, get_current_node +from frappe.event_streaming.doctype.event_producer.event_producer import pull_from_node, get_current_node def create_event_producer(producer_url): event_producer = frappe.new_doc('Event Producer') diff --git a/frappe/events_streaming/doctype/event_producer_document_type/__init__.py b/frappe/event_streaming/doctype/event_producer_document_type/__init__.py similarity index 100% rename from frappe/events_streaming/doctype/event_producer_document_type/__init__.py rename to frappe/event_streaming/doctype/event_producer_document_type/__init__.py diff --git a/frappe/events_streaming/doctype/event_producer_document_type/event_producer_document_type.json b/frappe/event_streaming/doctype/event_producer_document_type/event_producer_document_type.json similarity index 97% rename from frappe/events_streaming/doctype/event_producer_document_type/event_producer_document_type.json rename to frappe/event_streaming/doctype/event_producer_document_type/event_producer_document_type.json index 3651c6865c..8f747a5e22 100644 --- a/frappe/events_streaming/doctype/event_producer_document_type/event_producer_document_type.json +++ b/frappe/event_streaming/doctype/event_producer_document_type/event_producer_document_type.json @@ -54,7 +54,7 @@ "istable": 1, "modified": "2019-10-29 15:12:53.962591", "modified_by": "Administrator", - "module": "Events Streaming", + "module": "Event Streaming", "name": "Event Producer Document Type", "owner": "Administrator", "permissions": [], diff --git a/frappe/events_streaming/doctype/event_producer_document_type/event_producer_document_type.py b/frappe/event_streaming/doctype/event_producer_document_type/event_producer_document_type.py similarity index 100% rename from frappe/events_streaming/doctype/event_producer_document_type/event_producer_document_type.py rename to frappe/event_streaming/doctype/event_producer_document_type/event_producer_document_type.py diff --git a/frappe/events_streaming/doctype/event_sync_log/__init__.py b/frappe/event_streaming/doctype/event_sync_log/__init__.py similarity index 100% rename from frappe/events_streaming/doctype/event_sync_log/__init__.py rename to frappe/event_streaming/doctype/event_sync_log/__init__.py diff --git a/frappe/events_streaming/doctype/event_sync_log/event_sync_log.js b/frappe/event_streaming/doctype/event_sync_log/event_sync_log.js similarity index 85% rename from frappe/events_streaming/doctype/event_sync_log/event_sync_log.js rename to frappe/event_streaming/doctype/event_sync_log/event_sync_log.js index 487f2efe86..5199e3f02d 100644 --- a/frappe/events_streaming/doctype/event_sync_log/event_sync_log.js +++ b/frappe/event_streaming/doctype/event_sync_log/event_sync_log.js @@ -6,7 +6,7 @@ frappe.ui.form.on('Event Sync Log', { if (frm.doc.status == 'Failed') { frm.add_custom_button(__('Resync'), function() { frappe.call({ - method: "frappe.events_streaming.doctype.event_producer.event_producer.resync", + method: "frappe.event_streaming.doctype.event_producer.event_producer.resync", args: { update: frm.doc, }, diff --git a/frappe/events_streaming/doctype/event_sync_log/event_sync_log.json b/frappe/event_streaming/doctype/event_sync_log/event_sync_log.json similarity index 98% rename from frappe/events_streaming/doctype/event_sync_log/event_sync_log.json rename to frappe/event_streaming/doctype/event_sync_log/event_sync_log.json index 6fe71260a6..f82128bd7b 100644 --- a/frappe/events_streaming/doctype/event_sync_log/event_sync_log.json +++ b/frappe/event_streaming/doctype/event_sync_log/event_sync_log.json @@ -113,7 +113,7 @@ "in_create": 1, "modified": "2019-10-07 13:22:10.401479", "modified_by": "Administrator", - "module": "Events Streaming", + "module": "Event Streaming", "name": "Event Sync Log", "owner": "Administrator", "permissions": [ diff --git a/frappe/events_streaming/doctype/event_sync_log/event_sync_log.py b/frappe/event_streaming/doctype/event_sync_log/event_sync_log.py similarity index 100% rename from frappe/events_streaming/doctype/event_sync_log/event_sync_log.py rename to frappe/event_streaming/doctype/event_sync_log/event_sync_log.py diff --git a/frappe/events_streaming/doctype/event_sync_log/event_sync_log_list.js b/frappe/event_streaming/doctype/event_sync_log/event_sync_log_list.js similarity index 100% rename from frappe/events_streaming/doctype/event_sync_log/event_sync_log_list.js rename to frappe/event_streaming/doctype/event_sync_log/event_sync_log_list.js diff --git a/frappe/events_streaming/doctype/event_sync_log/test_event_sync_log.py b/frappe/event_streaming/doctype/event_sync_log/test_event_sync_log.py similarity index 100% rename from frappe/events_streaming/doctype/event_sync_log/test_event_sync_log.py rename to frappe/event_streaming/doctype/event_sync_log/test_event_sync_log.py diff --git a/frappe/events_streaming/doctype/event_update_log/__init__.py b/frappe/event_streaming/doctype/event_update_log/__init__.py similarity index 100% rename from frappe/events_streaming/doctype/event_update_log/__init__.py rename to frappe/event_streaming/doctype/event_update_log/__init__.py diff --git a/frappe/events_streaming/doctype/event_update_log/event_update_log.js b/frappe/event_streaming/doctype/event_update_log/event_update_log.js similarity index 100% rename from frappe/events_streaming/doctype/event_update_log/event_update_log.js rename to frappe/event_streaming/doctype/event_update_log/event_update_log.js diff --git a/frappe/events_streaming/doctype/event_update_log/event_update_log.json b/frappe/event_streaming/doctype/event_update_log/event_update_log.json similarity index 97% rename from frappe/events_streaming/doctype/event_update_log/event_update_log.json rename to frappe/event_streaming/doctype/event_update_log/event_update_log.json index 3b627db2a0..452a656b8b 100644 --- a/frappe/events_streaming/doctype/event_update_log/event_update_log.json +++ b/frappe/event_streaming/doctype/event_update_log/event_update_log.json @@ -44,7 +44,7 @@ "in_create": 1, "modified": "2019-09-24 23:16:07.207707", "modified_by": "Administrator", - "module": "Events Streaming", + "module": "Event Streaming", "name": "Event Update Log", "owner": "Administrator", "permissions": [ diff --git a/frappe/events_streaming/doctype/event_update_log/event_update_log.py b/frappe/event_streaming/doctype/event_update_log/event_update_log.py similarity index 96% rename from frappe/events_streaming/doctype/event_update_log/event_update_log.py rename to frappe/event_streaming/doctype/event_update_log/event_update_log.py index 16be6d772a..7ef2e29508 100644 --- a/frappe/events_streaming/doctype/event_update_log/event_update_log.py +++ b/frappe/event_streaming/doctype/event_update_log/event_update_log.py @@ -13,7 +13,7 @@ class EventUpdateLog(Document): def notify_consumers(doc, method=None): '''Send update notification updates to event consumers whenever update log is generated''' - enqueued_method = 'frappe.events_streaming.doctype.event_consumer.event_consumer.notify_event_consumers' + enqueued_method = 'frappe.event_streaming.doctype.event_consumer.event_consumer.notify_event_consumers' jobs = get_jobs() if not jobs or enqueued_method not in jobs[frappe.local.site]: frappe.enqueue(enqueued_method, doctype=doc.ref_doctype, queue='long', enqueue_after_commit=True) diff --git a/frappe/events_streaming/doctype/event_update_log/test_event_update_log.py b/frappe/event_streaming/doctype/event_update_log/test_event_update_log.py similarity index 100% rename from frappe/events_streaming/doctype/event_update_log/test_event_update_log.py rename to frappe/event_streaming/doctype/event_update_log/test_event_update_log.py diff --git a/frappe/hooks.py b/frappe/hooks.py index 288369ff3e..0256a3d2d2 100644 --- a/frappe/hooks.py +++ b/frappe/hooks.py @@ -156,7 +156,7 @@ doc_events = { "after_save": "frappe.cache_manager.build_domain_restriced_page_cache", }, "Event Update Log": { - "after_insert": "frappe.events_streaming.doctype.event_update_log.event_update_log.notify_consumers" + "after_insert": "frappe.event_streaming.doctype.event_update_log.event_update_log.notify_consumers" } } diff --git a/frappe/model/document.py b/frappe/model/document.py index f8ec784db3..12609041bb 100644 --- a/frappe/model/document.py +++ b/frappe/model/document.py @@ -952,7 +952,7 @@ class Document(BaseDocument): make_event_update_log(self, update_type = 'Create') self.flags.update_log_for_doc_creation = False else: - from frappe.events_streaming.doctype.event_update_log.event_update_log import get_update + from frappe.event_streaming.doctype.event_update_log.event_update_log import get_update diff = get_update(self._doc_before_save, self) if diff: doc = self diff --git a/frappe/modules.txt b/frappe/modules.txt index 3833971f20..ae10c3ad55 100644 --- a/frappe/modules.txt +++ b/frappe/modules.txt @@ -12,4 +12,4 @@ Data Migration Chat Social Automation -Events Streaming \ No newline at end of file +Event Streaming \ No newline at end of file