- {:validate_object, ObjectValidator.validate(object, meta)},
- {_, {:ok, mrfd_object}} <- {:mrf_object, MRF.filter(validated_object)},
- {_, {:ok, %Activity{} = activity, meta}} <-
- {:persist_object, ActivityPub.persist(mrfd_object, meta)},
- {_, {:ok, %Activity{} = activity, meta}} <-
- {:execute_side_effects, SideEffects.handle(activity, meta)},
+ {:validate_object, @object_validator.validate(object, meta)},
+ {_, {:ok, mrfd_object, meta}} <-
+ {:mrf_object, @mrf.pipeline_filter(validated_object, meta)},
+ {_, {:ok, activity, meta}} <-
+ {:persist_object, @activity_pub.persist(mrfd_object, meta)},
+ {_, {:ok, activity, meta}} <-
+ {:execute_side_effects, @side_effects.handle(activity, meta)},