@@ -10,7 +10,7 @@ use core_protobuf_data_access::chariott::runtime::v1::{
10
10
} ;
11
11
use core_protobuf_data_access:: digital_twin:: v1:: digital_twin_server:: DigitalTwinServer ;
12
12
use env_logger:: { Builder , Target } ;
13
- use log:: { debug, info, LevelFilter } ;
13
+ use log:: { debug, error , info, LevelFilter } ;
14
14
use parking_lot:: RwLock ;
15
15
use std:: collections:: HashMap ;
16
16
use std:: net:: SocketAddr ;
@@ -54,13 +54,11 @@ pub async fn register_digital_twin_service_with_chariott(
54
54
55
55
let request = Request :: new ( RegisterRequest { service, intents } ) ;
56
56
57
- let response = client
57
+ let _response = client
58
58
. register ( request)
59
59
. await
60
60
. map_err ( |_| Status :: internal ( "Chariott register request failed" ) ) ?;
61
61
62
- info ! ( "{:?}" , response. into_inner( ) ) ;
63
-
64
62
Ok ( ( ) )
65
63
}
66
64
@@ -96,11 +94,21 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
96
94
// after 15 seconds unless the CHARIOTT_REGISTRY_TTL_SECS environment variable is set. Please make sure that
97
95
// it is set (and exported) in the shell running Chariott before Chariott has started.
98
96
if chariott_url_option. is_some ( ) {
99
- register_digital_twin_service_with_chariott (
97
+ match register_digital_twin_service_with_chariott (
100
98
& chariott_url_option. unwrap ( ) ,
101
99
& invehicle_digital_twin_address,
102
100
)
103
- . await ?;
101
+ . await
102
+ {
103
+ Ok ( ( ) ) => return Ok ( ( ) ) ,
104
+ Err ( error) => {
105
+ error ! ( "Failed to register this service with Chariott: '{error}'" ) ;
106
+ Err ( error) ?
107
+ }
108
+ } ;
109
+ info ! ( "This service is now registered with Chariott." ) ;
110
+ } else {
111
+ info ! ( "This service is not using Chariott." ) ;
104
112
}
105
113
106
114
server_future. await ?;
0 commit comments