stynx-code-tools 3.12.1

Tool implementations for bash and file operations
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
40

use std::sync::{Arc, Mutex};

use tokio::sync::{mpsc, oneshot};

pub struct QuestionRequest {
    pub question: String,
    pub responder: oneshot::Sender<Option<String>>,
}

#[derive(Clone)]
pub struct QuestionBridge {
    sender: mpsc::UnboundedSender<QuestionRequest>,
}

impl QuestionBridge {
    pub fn new() -> (Self, mpsc::UnboundedReceiver<QuestionRequest>) {
        let (tx, rx) = mpsc::unbounded_channel();
        (Self { sender: tx }, rx)
    }

    pub async fn ask(&self, question: String) -> Option<String> {
        let (tx, rx) = oneshot::channel();
        let req = QuestionRequest { question, responder: tx };
        if self.sender.send(req).is_err() {
            return None;
        }
        rx.await.ok().flatten()
    }
}

#[derive(Default)]
pub struct OptionalQuestionBridge(Mutex<Option<QuestionBridge>>);

impl OptionalQuestionBridge {
    pub fn new() -> Self { Self(Mutex::new(None)) }
    pub fn set(&self, b: QuestionBridge) { *self.0.lock().unwrap() = Some(b); }
    pub fn get(&self) -> Option<QuestionBridge> { self.0.lock().unwrap().clone() }
}

pub type SharedQuestionBridge = Arc<OptionalQuestionBridge>;