Avii/Radicale
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Refactoring

Browse Source
This commit is contained in:
Tuna Celik
2020-08-17 03:01:21 +02:00
parent df80a7f6ef
commit b2fc8bbb0c
2 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
radicale/app/put.py
View File

@@ -196,7 +196,9 @@ class ApplicationPutMixin:
path, prepared_items, props).etag path, prepared_items, props).etag
for item in prepared_items: for item in prepared_items:
hook_notification_item = HookNotificationItem( hook_notification_item = HookNotificationItem(
HookNotificationItemTypes.UPSERT, item.serialize()) HookNotificationItemTypes.UPSERT,
item.serialize()
)
self._hook.notify(hook_notification_item) self._hook.notify(hook_notification_item)
except ValueError as e: except ValueError as e:
logger.warning( logger.warning(
@@ -214,7 +216,9 @@ class ApplicationPutMixin:
try: try:
etag = parent_item.upload(href, prepared_item).etag etag = parent_item.upload(href, prepared_item).etag
hook_notification_item = HookNotificationItem( hook_notification_item = HookNotificationItem(
HookNotificationItemTypes.UPSERT, prepared_item.serialize()) HookNotificationItemTypes.UPSERT,
prepared_item.serialize()
)
self._hook.notify(hook_notification_item) self._hook.notify(hook_notification_item)
except ValueError as e: except ValueError as e:
logger.warning( logger.warning(

3
radicale/hook/rabbitmq/__init__.py
View File

@@ -28,4 +28,5 @@ class Hook(hook.BaseHook):
self.channel.basic_publish( self.channel.basic_publish(
exchange='', exchange='',
routing_key=self.topic, routing_key=self.topic,
body=notification_item.to_json().encode(encoding=self.encoding)) body=notification_item.to_json().encode(encoding=self.encoding)
)