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