From 5a000e6b42afbfc9599a6c7818a97fe1a49cbb83 Mon Sep 17 00:00:00 2001 From: Zynh Ludwig Date: Fri, 15 Nov 2024 23:39:36 -0800 Subject: [PATCH] feat: upload creates db record --- src/router/upload.rs | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/src/router/upload.rs b/src/router/upload.rs index 634179c..03f61e7 100644 --- a/src/router/upload.rs +++ b/src/router/upload.rs @@ -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();