|
|
@ -159,11 +159,12 @@ pub async fn get_message_events_route(
|
|
|
|
.map(|(_, pdu)| pdu.to_room_event())
|
|
|
|
.map(|(_, pdu)| pdu.to_room_event())
|
|
|
|
.collect();
|
|
|
|
.collect();
|
|
|
|
|
|
|
|
|
|
|
|
let mut resp = get_message_events::Response::new();
|
|
|
|
let resp = get_message_events::Response {
|
|
|
|
resp.start = body.from.to_owned();
|
|
|
|
start: body.from.to_owned(),
|
|
|
|
resp.end = end_token;
|
|
|
|
end: end_token,
|
|
|
|
resp.chunk = events_after;
|
|
|
|
chunk: events_after,
|
|
|
|
resp.state = Vec::new();
|
|
|
|
state: Vec::new(),
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
Ok(resp.into())
|
|
|
|
Ok(resp.into())
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -189,11 +190,12 @@ pub async fn get_message_events_route(
|
|
|
|
.map(|(_, pdu)| pdu.to_room_event())
|
|
|
|
.map(|(_, pdu)| pdu.to_room_event())
|
|
|
|
.collect();
|
|
|
|
.collect();
|
|
|
|
|
|
|
|
|
|
|
|
let mut resp = get_message_events::Response::new();
|
|
|
|
let resp = get_message_events::Response {
|
|
|
|
resp.start = body.from.to_owned();
|
|
|
|
start: body.from.to_owned(),
|
|
|
|
resp.end = start_token;
|
|
|
|
end: start_token,
|
|
|
|
resp.chunk = events_before;
|
|
|
|
chunk: events_before,
|
|
|
|
resp.state = Vec::new();
|
|
|
|
state: Vec::new(),
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
Ok(resp.into())
|
|
|
|
Ok(resp.into())
|
|
|
|
}
|
|
|
|
}
|
|
|
|