agent-tui-usecases 1.1.0

Use cases and ports for agent-tui terminal automation
Documentation 
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

//! Diagnostics use case.

use std::sync::Arc;

use crate::domain::TerminalWriteInput;
use crate::domain::TerminalWriteOutput;
use crate::usecases::ports::SessionError;
use crate::usecases::ports::SessionRepository;

pub trait TerminalWriteUseCase: Send + Sync {
    fn execute(&self, input: TerminalWriteInput) -> Result<TerminalWriteOutput, SessionError>;
}

pub struct TerminalWriteUseCaseImpl<R: SessionRepository> {
    repository: Arc<R>,
}

impl<R: SessionRepository> TerminalWriteUseCaseImpl<R> {
    pub fn new(repository: Arc<R>) -> Self {
        Self { repository }
    }
}

impl<R: SessionRepository> TerminalWriteUseCase for TerminalWriteUseCaseImpl<R> {
    fn execute(&self, input: TerminalWriteInput) -> Result<TerminalWriteOutput, SessionError> {
        let session = self.repository.resolve(input.session_id.as_ref())?;
        let bytes_len = input.data.len();
        session.terminal_write(&input.data)?;
        Ok(TerminalWriteOutput {
            session_id: session.session_id(),
            bytes_written: bytes_len,
            success: true,
        })
    }
}

#[cfg(test)]
#[path = "diagnostics_tests.rs"]
mod tests;