studio/tuwunel
2
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Workaround Mxc serialization assertion.

Browse Source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk
2026-03-12 02:10:16 +00:00
parent a656aba615
commit 529a2b91a4
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/service/media/data.rs
View File

@@ -68,11 +68,14 @@ impl Data {
let value = (unused_expires_at, user); let value = (unused_expires_at, user);
debug!(?mxc, ?user, ?unused_expires_at, "Inserting pending"); debug!(?mxc, ?user, ?unused_expires_at, "Inserting pending");
self.mediaid_pending.put(mxc, value); self.mediaid_pending
.raw_put(mxc.to_string(), value);
} }
/// Remove a pending MXC URI from the database /// Remove a pending MXC URI from the database
pub(super) fn remove_pending_mxc(&self, mxc: &Mxc<'_>) { self.mediaid_pending.del(mxc); } pub(super) fn remove_pending_mxc(&self, mxc: &Mxc<'_>) {
self.mediaid_pending.remove(&mxc.to_string());
}
/// Count the number of pending MXC URIs for a specific user /// Count the number of pending MXC URIs for a specific user
pub(super) async fn count_pending_mxc_for_user(&self, user_id: &UserId) -> (usize, u64) { pub(super) async fn count_pending_mxc_for_user(&self, user_id: &UserId) -> (usize, u64) {
@@ -96,7 +99,7 @@ impl Data {
type Value<'a> = (u64, OwnedUserId); type Value<'a> = (u64, OwnedUserId);
self.mediaid_pending self.mediaid_pending
.qry(mxc) .get(&mxc.to_string())
.await .await
.deserialized() .deserialized()
.map(|(expires_at, user_id): Value<'_>| (user_id, expires_at)) .map(|(expires_at, user_id): Value<'_>| (user_id, expires_at))