backups/grapevine
1
0
Fork 0
mirror of https://gitlab.computer.surgery/matrix/grapevine.git synced 2025-12-17 07:41:23 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

enable same_name_method lint

Browse source
This commit is contained in:
Charles Hall 2024-05-12 18:43:00 -07:00
parent d144db8688
commit cc5977b4e4
No known key found for this signature in database
GPG key ID: 7B8E0645816E07CF
6 changed files with 14 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/api/client_server/message.rs
View file

@ -121,8 +121,8 @@ pub(crate) async fn get_message_events_route(
let from = match body.from.clone() {
Some(from) => PduCount::try_from_string(&from)?,
None => match body.dir {
ruma::api::Direction::Forward => PduCount::min(),
ruma::api::Direction::Backward => PduCount::max(),
ruma::api::Direction::Forward => PduCount::MIN,
ruma::api::Direction::Backward => PduCount::MAX,
},
};

12
src/api/client_server/relations.rs
View file

@ -18,8 +18,8 @@ pub(crate) async fn get_relating_events_with_rel_type_and_event_type_route(
Some(from) => PduCount::try_from_string(&from)?,
None => match ruma::api::Direction::Backward {
// TODO: fix ruma so `body.dir` exists
ruma::api::Direction::Forward => PduCount::min(),
ruma::api::Direction::Backward => PduCount::max(),
ruma::api::Direction::Forward => PduCount::MIN,
ruma::api::Direction::Backward => PduCount::MAX,
},
};
@ -69,8 +69,8 @@ pub(crate) async fn get_relating_events_with_rel_type_route(
Some(from) => PduCount::try_from_string(&from)?,
None => match ruma::api::Direction::Backward {
// TODO: fix ruma so `body.dir` exists
ruma::api::Direction::Forward => PduCount::min(),
ruma::api::Direction::Backward => PduCount::max(),
ruma::api::Direction::Forward => PduCount::MIN,
ruma::api::Direction::Backward => PduCount::MAX,
},
};
@ -118,8 +118,8 @@ pub(crate) async fn get_relating_events_route(
Some(from) => PduCount::try_from_string(&from)?,
None => match ruma::api::Direction::Backward {
// TODO: fix ruma so `body.dir` exists
ruma::api::Direction::Forward => PduCount::min(),
ruma::api::Direction::Backward => PduCount::max(),
ruma::api::Direction::Forward => PduCount::MIN,
ruma::api::Direction::Backward => PduCount::MAX,
},
};

2
src/api/client_server/sync.rs
View file

@ -1120,7 +1120,7 @@ fn load_timeline(
let mut non_timeline_pdus = services()
.rooms
.timeline
.pdus_until(sender_user, room_id, PduCount::max())?
.pdus_until(sender_user, room_id, PduCount::MAX)?
.filter_map(|r| {
// Filter out buggy events
if r.is_err() {

2
src/database/key_value/rooms/timeline.rs
View file

@ -19,7 +19,7 @@ impl service::rooms::timeline::Data for KeyValueDatabase {
{
hash_map::Entry::Vacant(v) => {
if let Some(last_count) = self
.pdus_until(sender_user, room_id, PduCount::max())?
.pdus_until(sender_user, room_id, PduCount::MAX)?
.find_map(|r| {
// Filter out buggy events
if r.is_err() {

10
src/service/rooms/timeline.rs
View file

@ -48,12 +48,8 @@ pub(crate) enum PduCount {
}
impl PduCount {
pub(crate) fn min() -> Self {
Self::Backfilled(u64::MAX)
}
pub(crate) fn max() -> Self {
Self::Normal(u64::MAX)
}
pub(crate) const MIN: Self = Self::Backfilled(u64::MAX);
pub(crate) const MAX: Self = Self::Normal(u64::MAX);
pub(crate) fn try_from_string(token: &str) -> Result<Self> {
if let Some(stripped) = token.strip_prefix('-') {
@ -1052,7 +1048,7 @@ impl Service {
user_id: &UserId,
room_id: &RoomId,
) -> Result<impl Iterator<Item = Result<(PduCount, PduEvent)>> + 'a> {
self.pdus_after(user_id, room_id, PduCount::min())
self.pdus_after(user_id, room_id, PduCount::MIN)
}
/// Returns an iterator over all events and their tokens in a room that happened before the