fix: rename Events Streaming to Event Streaming

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": [],

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": [

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": [

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})

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": [],

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": [

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})

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')

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": [],

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,
 					},

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": [

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": [

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)

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"
 	}
 }
 

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

frappe/modules.txt

@@ -12,4 +12,4 @@ Data Migration
 Chat
 Social
 Automation
-Events Streaming
+Event Streaming