+ def create_activity_by_object_id_query(ap_ids) do
+ from activity in Activity,
+ where: fragment("coalesce((?)->'object'->>'id', (?)->>'object') = ANY(?)", activity.data, activity.data, ^ap_ids),
+ where: fragment("(?)->>'type' = 'Create'", activity.data)
+ end
+