ffflow 0.1.1

FFmpeg workflow automation CLI/TUI with real-time progress tracking
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use std::process::{Command, Stdio};
use std::time::Instant;

use crate::core::command::FfmpegCommand;
use crate::core::job::{Job, JobStatus};
use crate::core::error::FfxError;

pub mod command;
pub mod job;
pub mod progress;
pub mod error;

pub fn run(command: FfmpegCommand) -> Result<Job, FfxError> {
    
let mut job = Job {
    id:0,
    status: JobStatus::Pending,
    started_at: None,
    ended_at: None,
};

job.status = JobStatus::Running;
job.started_at = Some(Instant::now());

let mut cmd = Command::new("ffmpeg");
cmd.args(command.to_args())
    .stderr(Stdio::piped());

let mut child = cmd.spawn().map_err(|e|
    if e.kind() == std::io::ErrorKind::NotFound {
        FfxError::BinaryNotFound
    } else {
        FfxError::ProcessFailed {
            exit_code: None,
            stderr: e.to_string(),
        }
    }
})?;


let output = child.wait_with_output().map.err(|e| {
    FfxError::ProcessFailed {
        exit_code: None,
        stderr: e.to_string(),
    }
})?;

job.ended_at = Some(Instant::now());

if output.status.success() {
    job.status = JobStatus::Finished;
    Ok(job)
} else {
    job.status = JobStatus::Failed;

    Err(FfxError::ProcessFailed {
        exit_code: output.status.code(),
        stderr: String::from_utf8_lossy(&oytput.stderr).to_string(),
    })
}
}