MindWorkAI/AI-Studio
MindWorkAI/AI-Studio
1
0
Fork 0
mirror of https://github.com/MindWorkAI/AI-Studio.git synced 2025-07-27 21:42:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added logging

Browse Source
This commit is contained in:
Thorsten Sommer 2025-06-30 20:31:44 +02:00
parent aaedf667fe
commit 42be87c473
Signed by: tsommer
GPG Key ID: 371BBA77A02C0108
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
runtime/src/file_data.rs
View File

@ -16,6 +16,7 @@ use rocket::tokio::select;
use rocket::Shutdown;
use std::path::Path;
use std::pin::Pin;
use log::{debug, error};
use tokio::io::AsyncBufReadExt;
use tokio::sync::mpsc;
use tokio_stream::wrappers::ReceiverStream;
@ -117,6 +118,7 @@ pub async fn extract_data(_token: APIToken, path: String, stream_id: String, mut
async fn stream_data(file_path: &str) -> Result<ChunkStream> {
if !Path::new(file_path).exists() {
error!("File does not exist: '{file_path}'");
return Err("File does not exist.".into());
}
@ -126,6 +128,8 @@ async fn stream_data(file_path: &str) -> Result<ChunkStream> {
}).await??;
let ext = file_path.split('.').next_back().unwrap_or("");
debug!("Extracting data from file: '{file_path}', format: '{fmt:?}', extension: '{ext}'");
let stream = match ext {
DOCX | ODT => {
let from = if ext == DOCX { "docx" } else { "odt" };