@@ -2,6 +2,7 @@ use device::manager::{CreateStruct, DeviceRequestStruct, UuidWrapper};
2
2
use serde:: { Deserialize , Serialize } ;
3
3
use serde_json:: json;
4
4
use tracing:: info;
5
+ use uuid:: Uuid ;
5
6
6
7
#[ macro_use]
7
8
extern crate lazy_static;
@@ -39,6 +40,58 @@ async fn main() {
39
40
}
40
41
}
41
42
43
+ let requests = vec ! [
44
+ crate :: device:: manager:: Request :: Ping (
45
+ DeviceRequestStruct {
46
+ uuid: Uuid :: parse_str( "00000000-0000-0000-001e-10da679f8cee" ) . unwrap( ) ,
47
+ device_request: crate :: device:: devices:: PingRequest :: Ping360 (
48
+ crate :: device:: devices:: Ping360Request :: Transducer (
49
+ bluerobotics_ping:: ping360:: TransducerStruct {
50
+ mode: 1 ,
51
+ gain_setting: 2 ,
52
+ angle: 0 ,
53
+ transmit_duration: 500 ,
54
+ sample_period: 80 ,
55
+ transmit_frequency: 700 ,
56
+ number_of_samples: 1200 ,
57
+ transmit: 1 ,
58
+ reserved: 1 ,
59
+ } ,
60
+ ) ,
61
+ ) ,
62
+ } ,
63
+ ) ,
64
+ crate :: device:: manager:: Request :: EnableContinuousMode (
65
+ UuidWrapper {
66
+ uuid: Uuid :: parse_str( "00000000-0000-0000-001e-10da679f8cee" ) . unwrap( ) ,
67
+ }
68
+ ) ,
69
+ crate :: device:: manager:: Request :: List ,
70
+ crate :: device:: manager:: Request :: Create ( CreateStruct {
71
+ source: device:: manager:: SourceSelection :: SerialStream (
72
+ device:: manager:: SourceSerialStruct {
73
+ path: "/dev/ttyUSB0" . to_string( ) ,
74
+ baudrate: 115200 ,
75
+ }
76
+ ) ,
77
+ device_selection: device:: manager:: DeviceSelection :: Auto ,
78
+ } ) ,
79
+ crate :: device:: manager:: Request :: Create ( CreateStruct {
80
+ source: device:: manager:: SourceSelection :: UdpStream (
81
+ device:: manager:: SourceUdpStruct {
82
+ ip: "192.168.0.1" . parse( ) . unwrap( ) ,
83
+ port: 9092 ,
84
+ }
85
+ ) ,
86
+ device_selection: device:: manager:: DeviceSelection :: Auto ,
87
+ } ) ,
88
+ ] ;
89
+
90
+ // Print each request as JSON
91
+ for request in requests {
92
+ println ! ( "{}" , json!( Command { module : ModuleType :: DeviceManager ( request) } ) ) ;
93
+ }
94
+
42
95
tokio:: spawn ( async move { manager. run ( ) . await } ) ;
43
96
44
97
server:: manager:: run ( & cli:: manager:: server_address ( ) , handler)
0 commit comments