+async fn receive_create(
+ context: &LemmyContext,
+ activity: AnyBase,
+ expected_domain: Url,
+ request_counter: &mut i32,
+) -> Result<(), LemmyError> {
+ let create = Create::from_any_base(activity)?.context(location_info!())?;
+ verify_activity_domains_valid(&create, &expected_domain, true)?;
+ if is_addressed_to_public(&create).is_ok() {
+ receive_create_comment(create, context, request_counter).await
+ } else {
+ receive_create_private_message(&context, create, expected_domain, request_counter).await
+ }
+}
+
+async fn receive_update(
+ context: &LemmyContext,
+ activity: AnyBase,
+ expected_domain: Url,
+ request_counter: &mut i32,
+) -> Result<(), LemmyError> {
+ let update = Update::from_any_base(activity)?.context(location_info!())?;
+ verify_activity_domains_valid(&update, &expected_domain, true)?;
+ if is_addressed_to_public(&update).is_ok() {
+ receive_update_comment(update, context, request_counter).await
+ } else {
+ receive_update_private_message(&context, update, expected_domain, request_counter).await
+ }
+}
+