blah/blahrs
1
0
Fork 0
mirror of https://github.com/Blah-IM/blahrs.git synced 2025-10-29 18:11:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat(webapi): differentiate no-room-permission from not-a-member error

Browse source 
- If a user is not a room member, HTTP 404 code=not_found will be
  returned. This also happen for posting into not-joined public rooms,
  and it can be interpreted as "room member is not found".

- If a user is a member but lacks the member permission to perform an
  action, HTTP 403 code=permission_denied will be returned.
This commit is contained in:
oxalica 2024-09-10 07:56:25 -04:00
parent 35b5aace08
commit 1a0347337c
2 changed files with 45 additions and 25 deletions
Download patch file Download diff file Expand all files Collapse all files

46
blahd/src/lib.rs
View file

@ -603,7 +603,13 @@ fn get_room_if_readable<T>(
f,
)
.optional()?
.ok_or_else(|| error_response!(StatusCode::NOT_FOUND, "not_found", "room not found"))
.ok_or_else(|| {
error_response!(
StatusCode::NOT_FOUND,
"not_found",
"the room does not exist or the user is not a room member",
)
})
}
/// Get room items with pagination parameters,
@ -675,7 +681,7 @@ async fn room_item_post(
let (cid, txs) = {
let conn = st.db.get();
let Some((uid, _perm)) = conn
let (uid, perm) = conn
.query_row(
r"
SELECT `uid`, `room_member`.`permission`
@ -696,14 +702,21 @@ async fn room_item_post(
},
)
.optional()?
.filter(|(_, perm)| perm.contains(MemberPermission::POST_CHAT))
else {
.ok_or_else(|| {
error_response!(
StatusCode::NOT_FOUND,
"not_found",
"the room does not exist or the user is not a room member",
)
})?;
if !perm.contains(MemberPermission::POST_CHAT) {
return Err(error_response!(
StatusCode::FORBIDDEN,
"permission_denied",
"the user does not have permission to post in this room",
"the user does not have permission to post item in the room",
));
};
}
let cid = Id::gen();
conn.execute(
@ -825,7 +838,7 @@ async fn room_join(
return Err(error_response!(
StatusCode::NOT_FOUND,
"not_found",
"room does not exists or user is not allowed to join this room",
"the room does not exist or the user is not allowed to join the room",
));
}
@ -866,7 +879,7 @@ async fn room_leave(st: &AppState, rid: Id, user: UserKey) -> Result<(), ApiErro
let mut conn = st.db.get();
let txn = conn.transaction()?;
let Some(uid) = txn
let uid = txn
.query_row(
r"
SELECT `uid`
@ -882,13 +895,14 @@ async fn room_leave(st: &AppState, rid: Id, user: UserKey) -> Result<(), ApiErro
|row| row.get::<_, u64>("uid"),
)
.optional()?
else {
return Err(error_response!(
StatusCode::NOT_FOUND,
"not_found",
"room does not exists or user is not a room member",
));
};
.ok_or_else(|| {
error_response!(
StatusCode::NOT_FOUND,
"not_found",
"the room does not exist or user is not a room member",
)
})?;
txn.execute(
r"
DELETE FROM `room_member`
@ -929,7 +943,7 @@ async fn room_item_mark_seen(
return Err(error_response!(
StatusCode::NOT_FOUND,
"not_found",
"room does not exists or user is not a room member",
"the room does not exist or the user is not a room member",
));
}
Ok(StatusCode::NO_CONTENT)