libervia-pubsub: sat_pubsub/backend.py comparison

backend: fixed publishing with "consistent_publisher" when no item was previously available

comparison

equal deleted inserted replaced

-:ccb2a22ea0fc
+:4179ed660a85
 if item.getAttribute('id')]
 if affiliation == 'owner' or self.isAdmin(requestor):
 if configuration[const.OPT_CONSISTENT_PUBLISHER]:
 pub_map = yield node.getItemsPublishers(itemIdentifiers)
-publishers = set(pub_map.values())
+if pub_map:
-if len(publishers) != 1:
+# if we have existing items, we replace publishers with
-# TODO: handle multiple items publishing (from several
+# original one to stay consistent
-#       publishers)
+publishers = set(pub_map.values())
-raise error.NoPublishing(
+if len(publishers) != 1:
-"consistent_publisher is currently only possible when "
+# TODO: handle multiple items publishing (from several
-"publishing items from a single publisher. Try to "
+#       publishers)
-"publish one item at a time")
+raise error.NoPublishing(
-# we replace requestor and new payload's publisher by original
+"consistent_publisher is currently only possible when "
-# item publisher to keep publisher consistent
+"publishing items from a single publisher. Try to "
-requestor = publishers.pop()
+"publish one item at a time")
-for item in items:
+# we replace requestor and new payload's publisher by original
-item['publisher'] = requestor.full()
+# item publisher to keep publisher consistent
+requestor = publishers.pop()
+for item in items:
+item['publisher'] = requestor.full()
 else:
 # we don't want a publisher to overwrite the item
 # of an other publisher
 yield self._checkOverwrite(node, itemIdentifiers, requestor)

Mercurial > libervia-pubsub