# HG changeset patch
# User Goffi <goffi@goffi.org>
# Date 1657796130 -7200
# Node ID 4f9d4650eab5e3e1f6aa59c5bfb630bf77407adc
# Parent  65e5718e77106c9a45e5f06c1f3e8644913d326c
component AP gateway: use `createActivity` in `mbdata2APitem`

diff -r 65e5718e7710 -r 4f9d4650eab5 sat/plugins/plugin_comp_ap_gateway/__init__.py
--- a/sat/plugins/plugin_comp_ap_gateway/__init__.py	Thu Jul 14 12:55:30 2022 +0200
+++ b/sat/plugins/plugin_comp_ap_gateway/__init__.py	Thu Jul 14 12:55:30 2022 +0200
@@ -802,6 +802,7 @@
         actor_id: str,
         object_: Optional[Union[str, dict]] = None,
         target: Optional[Union[str, dict]] = None,
+        activity_id: Optional[str] = None,
         **kwargs,
     ) -> Dict[str, Any]:
         """Generate base data for an activity
@@ -818,7 +819,8 @@
             raise exceptions.InternalError(
                 f'"target" is mandatory for activity {activity!r}'
             )
-        activity_id = f"{actor_id}#{activity.lower()}_{shortuuid.uuid()}"
+        if activity_id is None:
+            activity_id = f"{actor_id}#{activity.lower()}_{shortuuid.uuid()}"
         data: Dict[str, Any] = {
             "@context": "https://www.w3.org/ns/activitystreams",
             "actor": actor_id,
@@ -1615,15 +1617,9 @@
                         mb_data
                     )
 
-        ap_item = {
-            "@context": "https://www.w3.org/ns/activitystreams",
-            "id": url_item,
-            "type": "Create",
-            "actor": url_actor,
-            "object": ap_object
-        }
-
-        return ap_item
+        return self.createActivity(
+            "Create", url_actor, ap_object, activity_id=url_item
+        )
 
     async def publishMessage(
         self,