LemmyNet
/
pict-rs
mirror of https://git.asonix.dog/asonix/pict-rs
2
0
Fork 0
Code Releases Activity

Log on successful migration

This commit is contained in:
asonix 2023-06-29 11:45:06 -05:00
parent 52bb786ce7
commit e6f17cbac6
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/lib.rs
View File

@ -226,7 +226,7 @@ impl<R: FullRepo, S: Store + 'static> FormData for Import<R, S> {
} }
} }
/// Handle responding to succesful uploads /// Handle responding to successful uploads
#[tracing::instrument(name = "Uploaded files", skip(value, repo, store))] #[tracing::instrument(name = "Uploaded files", skip(value, repo, store))]
async fn upload<R: FullRepo, S: Store + 'static>( async fn upload<R: FullRepo, S: Store + 'static>(
Multipart(Upload(value)): Multipart<Upload<R, S>>, Multipart(Upload(value)): Multipart<Upload<R, S>>,
@ -236,7 +236,7 @@ async fn upload<R: FullRepo, S: Store + 'static>(
handle_upload(value, repo, store).await handle_upload(value, repo, store).await
} }
/// Handle responding to succesful uploads /// Handle responding to successful uploads
#[tracing::instrument(name = "Imported files", skip(value, repo, store))] #[tracing::instrument(name = "Imported files", skip(value, repo, store))]
async fn import<R: FullRepo, S: Store + 'static>( async fn import<R: FullRepo, S: Store + 'static>(
Multipart(Import(value)): Multipart<Import<R, S>>, Multipart(Import(value)): Multipart<Import<R, S>>,
@ -246,7 +246,7 @@ async fn import<R: FullRepo, S: Store + 'static>(
handle_upload(value, repo, store).await handle_upload(value, repo, store).await
} }
/// Handle responding to succesful uploads /// Handle responding to successful uploads
#[tracing::instrument(name = "Uploaded files", skip(value, repo, store))] #[tracing::instrument(name = "Uploaded files", skip(value, repo, store))]
async fn handle_upload<R: FullRepo, S: Store + 'static>( async fn handle_upload<R: FullRepo, S: Store + 'static>(
value: Value<Session<R, S>>, value: Value<Session<R, S>>,
@ -1538,6 +1538,8 @@ where
// clean up the migration key to avoid interfering with future migrations // clean up the migration key to avoid interfering with future migrations
repo.remove(STORE_MIGRATION_PROGRESS).await?; repo.remove(STORE_MIGRATION_PROGRESS).await?;
tracing::warn!("Migration completed successfully");
Ok(()) Ok(())
} }