nlabapi 1.0.6

Communication with nLab devices
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

/***************************************************************************************************
 *
 *  nLabs, LLC
 *  https://getnlab.com
 *  Copyright(c) 2020. All Rights Reserved
 *
 *  This file is part of the nLab API
 *
 **************************************************************************************************/



use std::error::Error;
use std::sync::mpsc::Sender;

use log::debug;

use super::analog_output::AxRequest;
use super::data_requests::{DataRequest};
use super::pulse_output::PxRequest;

pub(super) const NULL_REQ: [u8; 2] = [0, 0xFF];

pub(super) trait ScopeCommand {
    fn fill_tx_buffer_legacy(&self, usb_buf: &mut [u8; 65]) -> Result<(), Box<dyn Error>>;
    fn fill_tx_buffer(&self, usb_buf: &mut [u8; 64]) -> Result<(), Box<dyn Error>>;
    fn handle_rx_legacy(&self, usb_buf: &[u8; 64]);
    fn handle_rx(&self, usb_buf: &[u8; 64]);
    fn is_finished(&self) -> bool;
}

// Build out featureset
// PWM_DUTY_REQUEST = 0x00, -- not for 1.0
// FINITE_DATA_REQUEST = 0x03, -- not for 1.0
// CONTINUOUS_DATA_REQUEST = 0x04 -- not for 1.0
// SCOPE_ROLL_REQUEST = 0x09 -- not for 1.0
// RESET_TO_BOOTLOADER = 0x10 -- not for 1.0


#[derive(Debug)]
pub(crate) enum Command {
    Quit,
    Initialize(bool, Sender<()>),
    SetAnalogOutput(AxRequest),
    SetPulseOutput(PxRequest),
    RequestData(DataRequest),
    StopData,
}

impl Command {
    pub(super) fn fill_tx_buffer_legacy(&mut self, usb_buf: &mut [u8; 65]) -> Result<(), Box<dyn Error>> {
        debug!("Processed command: {self:?}");
        match self {
            Command::Quit => { Ok(()) }
            Command::Initialize(power_on, _) => {
                if *power_on {
                    usb_buf[1] = 0x07;
                } else {
                    usb_buf[1] = 0x06;
                }
                Ok(())
            }
            Command::SetAnalogOutput(cmd) => { cmd.fill_tx_buffer_legacy(usb_buf) }
            Command::SetPulseOutput(cmd) => { cmd.fill_tx_buffer_legacy(usb_buf) }
            Command::RequestData(cmd) => { cmd.fill_tx_buffer_legacy(usb_buf) }
            Command::StopData => {
                usb_buf[1] = 0x05;
                Ok(())
            }
        }
    }

    pub(super) fn handle_rx_legacy(&self, buffer: &[u8; 64]) {
        match self {
            Command::Quit => {}
            Command::Initialize(_, _) => {}
            Command::SetAnalogOutput(cmd) => { cmd.handle_rx_legacy(buffer) }
            Command::SetPulseOutput(cmd) => { cmd.handle_rx_legacy(buffer) }
            Command::RequestData(cmd) => { cmd.handle_rx_legacy(buffer) }
            Command::StopData => {}
        }
    }

    pub(super) fn handle_rx(&self, buffer: &[u8; 64]) {
        match self {
            Command::Quit => {}
            Command::Initialize(_, sender) => { sender.send(()).unwrap() }
            Command::SetAnalogOutput(cmd) => { cmd.handle_rx(buffer) }
            Command::SetPulseOutput(cmd) => { cmd.handle_rx(buffer) }
            Command::RequestData(cmd) => { cmd.handle_rx(buffer) }
            Command::StopData => {  }
        }
    }

    pub(super) fn is_finished(&self) -> bool {
        match self {
            Command::Quit => { true }
            Command::Initialize(_, _) => { true }
            Command::SetAnalogOutput(cmd) => { cmd.is_finished() }
            Command::SetPulseOutput(cmd) => { cmd.is_finished() }
            Command::RequestData(cmd) => { cmd.is_finished() }
            Command::StopData => { true }
        }
    }

    pub(crate) fn id_byte(&self) -> u8 {
        match self {
            Command::Quit => { 0 }
            Command::Initialize(_, _) => { 1 }
            Command::SetAnalogOutput(_) => { 2 }
            Command::SetPulseOutput(_) => { 3 }
            Command::RequestData(_) => { 4 }
            Command::StopData => { 5 }
        }
    }
}