broken! feat: sqlx query get

This commit is contained in:
Zynh Ludwig 2024-11-15 23:39:36 -08:00
parent 47bc1b6016
commit a629485be9

View file

@ -13,6 +13,7 @@ use sanitize_filename_reader_friendly::sanitize;
use tokio::io;
use tokio_util::{compat::FuturesAsyncWriteCompatExt, io::StreamReader};
use tower_http::limit::RequestBodyLimitLayer;
use tracing::debug;
use crate::{askama::DownloadLinkFragment, cache, util, AppState, UploadRecord};
@ -75,6 +76,21 @@ async fn upload_to_zip(
let record = UploadRecord::new(archive_path);
let mut records = state.records.lock().await;
{
let mut conn = state.pool.acquire().await.unwrap();
let path = record.file.clone().into_os_string().into_string().unwrap();
let id = sqlx::query_file!("queries/records/new.sql", path, 5)
.execute(&mut *conn)
.await
.unwrap()
.last_insert_rowid();
// TODO: Looks like I actually gotta store cache_name lmfao
debug!("Saved Record {id}");
}
records.insert(cache_name.clone(), record.clone());
let records_cache = records.clone();