mirror of
https://forgejo.ellis.link/continuwuation/continuwuity.git
synced 2026-05-26 20:49:55 +00:00
refactor: Fix errors in api/server/send_leave.rs
This commit is contained in:
@@ -1,5 +1,3 @@
|
|||||||
#![allow(deprecated)]
|
|
||||||
|
|
||||||
use std::{borrow::Borrow, time::Instant, vec};
|
use std::{borrow::Borrow, time::Instant, vec};
|
||||||
|
|
||||||
use axum::extract::State;
|
use axum::extract::State;
|
||||||
|
|||||||
@@ -1,5 +1,3 @@
|
|||||||
#![allow(deprecated)]
|
|
||||||
|
|
||||||
use axum::extract::State;
|
use axum::extract::State;
|
||||||
use conduwuit::{Err, Result, err, info, matrix::event::gen_event_id_canonical_json};
|
use conduwuit::{Err, Result, err, info, matrix::event::gen_event_id_canonical_json};
|
||||||
use conduwuit_service::Services;
|
use conduwuit_service::Services;
|
||||||
@@ -16,18 +14,6 @@ use serde_json::value::RawValue as RawJsonValue;
|
|||||||
|
|
||||||
use crate::Ruma;
|
use crate::Ruma;
|
||||||
|
|
||||||
/// # `PUT /_matrix/federation/v1/send_leave/{roomId}/{eventId}`
|
|
||||||
///
|
|
||||||
/// Submits a signed leave event.
|
|
||||||
pub(crate) async fn create_leave_event_v1_route(
|
|
||||||
State(services): State<crate::State>,
|
|
||||||
body: Ruma<create_leave_event::v1::Request>,
|
|
||||||
) -> Result<create_leave_event::v1::Response> {
|
|
||||||
create_leave_event(&services, body.origin(), &body.room_id, &body.pdu).await?;
|
|
||||||
|
|
||||||
Ok(create_leave_event::v1::Response::new())
|
|
||||||
}
|
|
||||||
|
|
||||||
/// # `PUT /_matrix/federation/v2/send_leave/{roomId}/{eventId}`
|
/// # `PUT /_matrix/federation/v2/send_leave/{roomId}/{eventId}`
|
||||||
///
|
///
|
||||||
/// Submits a signed leave event.
|
/// Submits a signed leave event.
|
||||||
@@ -72,8 +58,10 @@ async fn create_leave_event(
|
|||||||
|
|
||||||
// We do not add the event_id field to the pdu here because of signature and
|
// We do not add the event_id field to the pdu here because of signature and
|
||||||
// hashes checks
|
// hashes checks
|
||||||
let room_version_id = services.rooms.state.get_room_version(room_id).await?;
|
let room_version = services.rooms.state.get_room_version(room_id).await?;
|
||||||
let Ok((event_id, value)) = gen_event_id_canonical_json(pdu, &room_version_id) else {
|
let room_version_rules = room_version.rules().unwrap();
|
||||||
|
|
||||||
|
let Ok((event_id, value)) = gen_event_id_canonical_json(pdu, &room_version_rules) else {
|
||||||
// Event could not be converted to canonical json
|
// Event could not be converted to canonical json
|
||||||
return Err!(Request(BadJson("Could not convert event to canonical json.")));
|
return Err!(Request(BadJson("Could not convert event to canonical json.")));
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user