Struct NetworkActiveKnowledgeBase 

pub struct NetworkActiveKnowledgeBase { /* private fields */ }

An active knowledge base that communicates with a remote target via network

Implementations

impl NetworkActiveKnowledgeBase

pub fn new(target_host: String, target_port: u16, timeout: Duration) -> Self

Creates a new network knowledge base

Arguments

• target_host - Hostname or IP address of the target
• target_port - Port number of the target service
• timeout - Socket timeout duration

Examples found in repository

examples/network_custom_kb.rs (line 17)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Network Custom KB (ATM) Example ===\n");

    // Expects an independent ATM server running
    // (see examples/custom_kb_server.rs).
    let kb = NetworkActiveKnowledgeBase::new("127.0.0.1".to_string(), 3001, Duration::from_secs(5));

    let vocabulary = vec![
        "INSERT_CARD".to_string(),
        "ENTER_PIN".to_string(),
        "REQUEST_WITHDRAW".to_string(),
        "EJECT_CARD".to_string(),
        "TIMEOUT".to_string(),
    ];

    println!("Target Host: {}", kb.target_host());
    println!("Target Port: {}\n", kb.target_port());

    let kb: Arc<Mutex<dyn KnowledgeBaseTrait>> = Arc::new(Mutex::new(kb));
    let mut learner = LSTAR::new(vocabulary, kb, 8, None, None);

    match learner.learn() {
        Ok(automata) => {
            println!("\n=== Learned ATM Automaton from Network Target ===\n");
            println!("{}", automata.build_dot_code());
            println!(
                "\nStates: {}\nTransitions: {}",
                automata.get_states().len(),
                automata.transitions.len()
            );
        }
        Err(e) => {
            eprintln!("Learning error: {}", e);
            println!("\nTo run this example with a real connection:");
            println!("  1. Start ATM server: cargo run --example custom_kb_server");
            println!("  2. Run this example again: cargo run --example network_custom_kb");
        }
    }

    Ok(())
}

examples/network_kb.rs (line 14)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Network Active Knowledge Base Example ===\n");

    // This example expects an independent coffee server running
    // (see examples/coffee_server.rs).
    let kb = NetworkActiveKnowledgeBase::new("127.0.0.1".to_string(), 3000, Duration::from_secs(5));

    // Define input vocabulary
    let vocabulary = vec![
        "REFILL_WATER".to_string(),
        "REFILL_COFFEE".to_string(),
        "PRESS_BUTTON_A".to_string(),
        "PRESS_BUTTON_B".to_string(),
        "PRESS_BUTTON_C".to_string(),
    ];

    println!("Target Host: {}", kb.target_host());
    println!("Target Port: {}\n", kb.target_port());

    let kb: Arc<Mutex<dyn KnowledgeBaseTrait>> = Arc::new(Mutex::new(kb));

    // Create learner. The network KB connects per submitted word.
    let mut learner = LSTAR::new(vocabulary, kb, 4, None, None);

    match learner.learn() {
        Ok(automata) => {
            println!("\n=== Learned Automaton from Network Target ===\n");
            println!("{}", automata.build_dot_code());
            println!(
                "\nStates: {}\nTransitions: {}",
                automata.get_states().len(),
                automata.transitions.len()
            );
        }
        Err(e) => {
            eprintln!("Learning error: {}", e);
            println!("\nTo run this example with a real connection:");
            println!("  1. Start a coffee server: cargo run --example coffee_server");
            println!("  2. Run this example again");
        }
    }

    Ok(())
}

pub fn target_host(&self) -> &str

Gets the target hostname

Examples found in repository

examples/network_custom_kb.rs (line 27)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Network Custom KB (ATM) Example ===\n");

    // Expects an independent ATM server running
    // (see examples/custom_kb_server.rs).
    let kb = NetworkActiveKnowledgeBase::new("127.0.0.1".to_string(), 3001, Duration::from_secs(5));

    let vocabulary = vec![
        "INSERT_CARD".to_string(),
        "ENTER_PIN".to_string(),
        "REQUEST_WITHDRAW".to_string(),
        "EJECT_CARD".to_string(),
        "TIMEOUT".to_string(),
    ];

    println!("Target Host: {}", kb.target_host());
    println!("Target Port: {}\n", kb.target_port());

    let kb: Arc<Mutex<dyn KnowledgeBaseTrait>> = Arc::new(Mutex::new(kb));
    let mut learner = LSTAR::new(vocabulary, kb, 8, None, None);

    match learner.learn() {
        Ok(automata) => {
            println!("\n=== Learned ATM Automaton from Network Target ===\n");
            println!("{}", automata.build_dot_code());
            println!(
                "\nStates: {}\nTransitions: {}",
                automata.get_states().len(),
                automata.transitions.len()
            );
        }
        Err(e) => {
            eprintln!("Learning error: {}", e);
            println!("\nTo run this example with a real connection:");
            println!("  1. Start ATM server: cargo run --example custom_kb_server");
            println!("  2. Run this example again: cargo run --example network_custom_kb");
        }
    }

    Ok(())
}

examples/network_kb.rs (line 25)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Network Active Knowledge Base Example ===\n");

    // This example expects an independent coffee server running
    // (see examples/coffee_server.rs).
    let kb = NetworkActiveKnowledgeBase::new("127.0.0.1".to_string(), 3000, Duration::from_secs(5));

    // Define input vocabulary
    let vocabulary = vec![
        "REFILL_WATER".to_string(),
        "REFILL_COFFEE".to_string(),
        "PRESS_BUTTON_A".to_string(),
        "PRESS_BUTTON_B".to_string(),
        "PRESS_BUTTON_C".to_string(),
    ];

    println!("Target Host: {}", kb.target_host());
    println!("Target Port: {}\n", kb.target_port());

    let kb: Arc<Mutex<dyn KnowledgeBaseTrait>> = Arc::new(Mutex::new(kb));

    // Create learner. The network KB connects per submitted word.
    let mut learner = LSTAR::new(vocabulary, kb, 4, None, None);

    match learner.learn() {
        Ok(automata) => {
            println!("\n=== Learned Automaton from Network Target ===\n");
            println!("{}", automata.build_dot_code());
            println!(
                "\nStates: {}\nTransitions: {}",
                automata.get_states().len(),
                automata.transitions.len()
            );
        }
        Err(e) => {
            eprintln!("Learning error: {}", e);
            println!("\nTo run this example with a real connection:");
            println!("  1. Start a coffee server: cargo run --example coffee_server");
            println!("  2. Run this example again");
        }
    }

    Ok(())
}

pub fn target_port(&self) -> u16

Gets the target port

Examples found in repository

examples/network_custom_kb.rs (line 28)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Network Custom KB (ATM) Example ===\n");

    // Expects an independent ATM server running
    // (see examples/custom_kb_server.rs).
    let kb = NetworkActiveKnowledgeBase::new("127.0.0.1".to_string(), 3001, Duration::from_secs(5));

    let vocabulary = vec![
        "INSERT_CARD".to_string(),
        "ENTER_PIN".to_string(),
        "REQUEST_WITHDRAW".to_string(),
        "EJECT_CARD".to_string(),
        "TIMEOUT".to_string(),
    ];

    println!("Target Host: {}", kb.target_host());
    println!("Target Port: {}\n", kb.target_port());

    let kb: Arc<Mutex<dyn KnowledgeBaseTrait>> = Arc::new(Mutex::new(kb));
    let mut learner = LSTAR::new(vocabulary, kb, 8, None, None);

    match learner.learn() {
        Ok(automata) => {
            println!("\n=== Learned ATM Automaton from Network Target ===\n");
            println!("{}", automata.build_dot_code());
            println!(
                "\nStates: {}\nTransitions: {}",
                automata.get_states().len(),
                automata.transitions.len()
            );
        }
        Err(e) => {
            eprintln!("Learning error: {}", e);
            println!("\nTo run this example with a real connection:");
            println!("  1. Start ATM server: cargo run --example custom_kb_server");
            println!("  2. Run this example again: cargo run --example network_custom_kb");
        }
    }

    Ok(())
}

examples/network_kb.rs (line 26)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Network Active Knowledge Base Example ===\n");

    // This example expects an independent coffee server running
    // (see examples/coffee_server.rs).
    let kb = NetworkActiveKnowledgeBase::new("127.0.0.1".to_string(), 3000, Duration::from_secs(5));

    // Define input vocabulary
    let vocabulary = vec![
        "REFILL_WATER".to_string(),
        "REFILL_COFFEE".to_string(),
        "PRESS_BUTTON_A".to_string(),
        "PRESS_BUTTON_B".to_string(),
        "PRESS_BUTTON_C".to_string(),
    ];

    println!("Target Host: {}", kb.target_host());
    println!("Target Port: {}\n", kb.target_port());

    let kb: Arc<Mutex<dyn KnowledgeBaseTrait>> = Arc::new(Mutex::new(kb));

    // Create learner. The network KB connects per submitted word.
    let mut learner = LSTAR::new(vocabulary, kb, 4, None, None);

    match learner.learn() {
        Ok(automata) => {
            println!("\n=== Learned Automaton from Network Target ===\n");
            println!("{}", automata.build_dot_code());
            println!(
                "\nStates: {}\nTransitions: {}",
                automata.get_states().len(),
                automata.transitions.len()
            );
        }
        Err(e) => {
            eprintln!("Learning error: {}", e);
            println!("\nTo run this example with a real connection:");
            println!("  1. Start a coffee server: cargo run --example coffee_server");
            println!("  2. Run this example again");
        }
    }

    Ok(())
}

pub fn timeout(&self) -> Duration

Gets the socket timeout

pub fn set_timeout(&mut self, timeout: Duration)

Sets the socket timeout

impl NetworkActiveKnowledgeBase

pub fn stats(&self) -> &KnowledgeBaseStats

Trait Implementations

impl ActiveKnowledgeBase for NetworkActiveKnowledgeBase

fn start_target(&mut self) -> Result<(), String>

Starts the target system for querying

fn stop_target(&mut self) -> Result<(), String>

Stops the target system after querying

fn submit_word(&mut self, word: &Word) -> Result<Word, String>

Submits a word to the target and returns the output

fn is_target_running(&self) -> bool

Gets the current state of the target (started or stopped)

impl KnowledgeBaseTrait for NetworkActiveKnowledgeBase

fn resolve_query(&mut self, query: &mut OutputQuery) -> Result<(), String>

fn add_word( &mut self, input_word: &Word, output_word: &Word, ) -> Result<(), String>