secop-modules 0.1.3

A Rust framework for a hardware server speaking the SECoP protocol (modules package)
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

// -----------------------------------------------------------------------------
// Rust SECoP playground
//
// This program is free software; you can redistribute it and/or modify it under
// the terms of the GNU General Public License as published by the Free Software
// Foundation; either version 2 of the License, or (at your option) any later
// version.
//
// This program is distributed in the hope that it will be useful, but WITHOUT
// ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
// FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
// details.
//
// You should have received a copy of the GNU General Public License along with
// this program; if not, write to the Free Software Foundation, Inc.,
// 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
//
// Module authors:
//   Georg Brandl <g.brandl@fz-juelich.de>
//
// -----------------------------------------------------------------------------
//
//! Module to communicate with a Toellner power supply via serial port.

use log::*;
use serde_json::json;

use secop_core::prelude::*;
use secop_derive::ModuleBase;


#[derive(ModuleBase)]
#[param(name="status", doc="status", datatype="StatusType", readonly=true)]
#[param(name="value", doc="current value", datatype="Double", readonly=true)]
#[param(name="target", doc="target value", datatype="Double", readonly=false)]
#[param(name="iomod", doc="module name of port", datatype="Str(64)", readonly=true,
        mandatory=true, swonly=true, visibility="none")]
#[param(name="channel", doc="channel to control", datatype="Int(1, 2)", readonly=true,
        default="1", swonly=true, visibility="none")]
pub struct ToellnerPS {
    internals: ModInternals,
    cache: ToellnerPSParamCache,
    io: Client,
}

impl Module for ToellnerPS {
    fn create(internals: ModInternals) -> Result<Self> {
        let iomod = internals.config().extract_param("iomod", &Str(64)).unwrap();
        Ok(ToellnerPS { internals,
                        cache: Default::default(),
                        io: Client::new(&iomod).map_err(
                            |e| e.amend(&format!(" (connecting to submodule {})", iomod)))? })
    }

    fn setup(&mut self) -> Result<()> {
        Ok(())
    }

    fn teardown(&mut self) {}
}

impl ToellnerPS {
    fn read_value(&mut self) -> Result<f64> {
        let reply = self.io.command("communicate", json!("MV1?"))?;
        reply[0].as_str().and_then(|v| v.parse().ok()).ok_or_else(
            || Error::comm_failed(format!("invalid comm reply: {}", reply[0])))
    }

    fn read_status(&mut self) -> Result<Status> {
        Ok((StatusConst::Idle, "idle".into()))
    }

    fn read_target(&mut self) -> Result<f64> {
        Ok(0.0)
    }

    fn write_target(&mut self, _tgt: f64) -> Result<f64> {
        Err(Error::bad_value("not implemented yet"))
    }
}