HMC/handmade-revolt-backend
6
0
Fork 0
forked from jmug/stoatchat
Code Pull Requests Actions Packages Releases 2 Activity

fix: add migration to update existing files to be animated

Browse Source 
Signed-off-by: Zomatree <me@zomatree.live>
This commit is contained in:
Zomatree
2026-03-30 15:09:46 +01:00
parent 1e80916b65
commit 4e1f1c116c
1 changed files with 28 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
crates/core/database/src/models/admin_migrations/ops/mongodb/scripts.rs
View File

@@ -25,7 +25,7 @@ struct MigrationInfo {
revision: i32, revision: i32,
} }
pub const LATEST_REVISION: i32 = 50; // MUST BE +1 to last migration pub const LATEST_REVISION: i32 = 51; // MUST BE +1 to last migration
pub async fn migrate_database(db: &MongoDb) { pub async fn migrate_database(db: &MongoDb) {
let migrations = db.col::<Document>("migrations"); let migrations = db.col::<Document>("migrations");
@@ -1085,7 +1085,7 @@ pub async fn run_migrations(db: &MongoDb, revision: i32) -> i32 {
enum Channel { enum Channel {
Group { owner: String }, Group { owner: String },
TextChannel { server: String }, TextChannel { server: String },
VoiceChannel { server: String } VoiceChannel { server: String },
} }
let webhooks = db let webhooks = db
@@ -1099,7 +1099,12 @@ pub async fn run_migrations(db: &MongoDb, revision: i32) -> i32 {
.await; .await;
for webhook in webhooks { for webhook in webhooks {
match db.col::<Channel>("channels").find_one(doc! { "_id": &webhook.channel_id }).await.unwrap() { match db
.col::<Channel>("channels")
.find_one(doc! { "_id": &webhook.channel_id })
.await
.unwrap()
{
Some(channel) => { Some(channel) => {
let creator_id = match channel { let creator_id = match channel {
Channel::Group { owner, .. } => owner, Channel::Group { owner, .. } => owner,
@@ -1240,7 +1245,7 @@ pub async fn run_migrations(db: &MongoDb, revision: i32) -> i32 {
"channel_type": "TextChannel", "channel_type": "TextChannel",
"voice": {} "voice": {}
} }
} },
) )
.await .await
.expect("Failed to update voice channels"); .expect("Failed to update voice channels");
@@ -1292,10 +1297,7 @@ pub async fn run_migrations(db: &MongoDb, revision: i32) -> i32 {
let mut doc = doc! {}; let mut doc = doc! {};
for id in server.roles.keys() { for id in server.roles.keys() {
doc.insert( doc.insert(format!("roles.{id}._id"), id);
format!("roles.{id}._id"),
id,
);
} }
db.db() db.db()
@@ -1306,6 +1308,24 @@ pub async fn run_migrations(db: &MongoDb, revision: i32) -> i32 {
} }
}; };
if revision <= 50 {
info!("Running migration [revision 50 / 30-03-2026]: Add animated to existing gifs");
db.db()
.collection::<Document>("attachment_hashes")
.update_many(
doc! {
"content_type": "image/gif",
"metadata.type": "Image",
},
doc! {
"metadata.animated": true
},
)
.await
.expect("Failed to update attachment_hashes");
};
// Reminder to update LATEST_REVISION when adding new migrations. // Reminder to update LATEST_REVISION when adding new migrations.
LATEST_REVISION.max(revision) LATEST_REVISION.max(revision)
} }