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

Refactor Pandoc command to use the PandocProcessBuilder

Browse Source
This commit is contained in:
Thorsten Sommer 2025-05-30 22:32:00 +02:00
parent b3a9c2057b
commit 746d103274
Signed by: tsommer
GPG Key ID: 371BBA77A02C0108
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
runtime/src/file_data.rs
View File

@ -7,7 +7,6 @@ use file_format::{FileFormat, Kind};
use futures::{Stream, StreamExt}; use futures::{Stream, StreamExt};
use pdfium_render::prelude::Pdfium; use pdfium_render::prelude::Pdfium;
use tokio::io::AsyncBufReadExt; use tokio::io::AsyncBufReadExt;
use tokio::process::Command;
use tokio::sync::mpsc; use tokio::sync::mpsc;
use tokio_stream::wrappers::ReceiverStream; use tokio_stream::wrappers::ReceiverStream;
use rocket::Shutdown; use rocket::Shutdown;
@ -16,6 +15,7 @@ use rocket::tokio::select;
use rocket::serde::Serialize; use rocket::serde::Serialize;
use rocket::get; use rocket::get;
use crate::api_token::APIToken; use crate::api_token::APIToken;
use crate::pandoc::PandocProcessBuilder;
use crate::pdfium::PdfiumInit; use crate::pdfium::PdfiumInit;
#[derive(Debug, Serialize)] #[derive(Debug, Serialize)]
@ -255,11 +255,12 @@ async fn convert_with_pandoc(
from: &str, from: &str,
to: &str, to: &str,
) -> Result<ChunkStream> { ) -> Result<ChunkStream> {
let output = Command::new("pandoc") let output = PandocProcessBuilder::new()
.arg(file_path) .with_input_file(file_path)
.args(["-f", from, "-t", to]) .with_input_format(from)
.output() .with_output_format(to)
.await?; .build()
.command.output().await?;
let stream = stream! { let stream = stream! {
if output.status.success() { if output.status.success() {