let private_message =
PrivateMessage::from_apub(¬e, context, expected_domain, request_counter, false).await?;
- let message = blocking(&context.pool(), move |conn| {
+ let message = blocking(context.pool(), move |conn| {
PrivateMessageView::read(conn, private_message.id)
})
.await??;
PrivateMessage::from_apub(¬e, context, expected_domain, request_counter, false).await?;
let private_message_id = private_message.id;
- let message = blocking(&context.pool(), move |conn| {
+ let message = blocking(context.pool(), move |conn| {
PrivateMessageView::read(conn, private_message_id)
})
.await??;
})
.await??;
- let message = blocking(&context.pool(), move |conn| {
- PrivateMessageView::read(&conn, deleted_private_message.id)
+ let message = blocking(context.pool(), move |conn| {
+ PrivateMessageView::read(conn, deleted_private_message.id)
})
.await??;
})
.await??;
- let message = blocking(&context.pool(), move |conn| {
- PrivateMessageView::read(&conn, deleted_private_message.id)
+ let message = blocking(context.pool(), move |conn| {
+ PrivateMessageView::read(conn, deleted_private_message.id)
})
.await??;
.context(location_info!())?;
check_is_apub_id_valid(&person_id, false)?;
// check that the sender is a person, not a community
- get_or_fetch_and_upsert_person(&person_id, &context, request_counter).await?;
+ get_or_fetch_and_upsert_person(&person_id, context, request_counter).await?;
Ok(())
}