Mirrors/continuwuity
0
0 Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2026-11-14 12:46:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: Make unembed_unsigned_info infallible

Browse Source
This commit is contained in:
Ginger authored and Ellis Git committed 2026-10-01 18:43:54 +00:00
1 parent a6fae7498d
commit cb7af18bc2
1 file changed
+2 -6
Download Patch File Download Diff File Expand all files Collapse all files
src/service/migrations.rs
+2 -6
View File
@@ -149,9 +149,7 @@ migration!(stringify!($name) => $name)
let timeline = services.rooms.timeline.clone(); let timeline = services.rooms.timeline.clone();
services.server.runtime().spawn(async move { services.server.runtime().spawn(async move {
unembed_unsigned_info(metadata, timeline).await.expect( unembed_unsigned_info(metadata, timeline).await;
"unembed_unsigned_info failed! your database is broken, sorry >.>",
);
db["global"].insert(b"unembed_unsigned_info", []); db["global"].insert(b"unembed_unsigned_info", []);
}); });
} }
@@ -871,7 +869,7 @@ async fn obliterate_roomsynctoken_shortstatehash_with_extreme_prejudice(
async fn unembed_unsigned_info( async fn unembed_unsigned_info(
metadata: Arc<rooms::metadata::Service>, metadata: Arc<rooms::metadata::Service>,
timeline: Arc<rooms::timeline::Service>, timeline: Arc<rooms::timeline::Service>,
) -> Result { ) {
type Map = BTreeMap<String, Box<serde_json::value::RawValue>>; type Map = BTreeMap<String, Box<serde_json::value::RawValue>>;
info!( info!(
"Starting background migration. This may take a long time, and may cause your server to \ "Starting background migration. This may take a long time, and may cause your server to \
@@ -929,8 +927,6 @@ async fn unembed_unsigned_info(
} }
info!(elapsed=?start.elapsed(), total_migrated_pdus=total_migrated, "Finished migration."); info!(elapsed=?start.elapsed(), total_migrated_pdus=total_migrated, "Finished migration.");
Ok(())
} }
async fn drop_server_signingkeys(services: &Services) -> Result<()> { async fn drop_server_signingkeys(services: &Services) -> Result<()> {