Work in progress

integration/src/tests.rs

@@ -3,11 +3,12 @@ use std::{
     thread,
 };
 
+use chrono::Utc;
+use log::*;
+
 use crate::client::prelude::*;
 use crate::console_logging;
 use crate::server::{self, prelude::*};
-use chrono::Utc;
-use log::*;
 
 use crate::harness::*;
 

lib/src/core/comms/message_writer.rs

@@ -8,7 +8,7 @@ use crate::types::{status_code::StatusCode, BinaryEncoder, EncodingResult};
 
 use super::{chunker::Chunker, secure_channel::SecureChannel, tcp_types::AcknowledgeMessage};
 
-use super::super::supported_message::SupportedMessage;
+use crate::core::supported_message::SupportedMessage;
 
 const DEFAULT_REQUEST_ID: u32 = 1000;
 const DEFAULT_SENT_SEQUENCE_NUMBER: u32 = 0;

lib/src/core/comms/secure_channel.rs

@@ -556,7 +556,7 @@ impl SecureChannel {
     }
 
     fn log_crypto_data(message: &str, data: &[u8]) {
-        use super::super::debug;
+        use crate::core::debug;
         debug::log_buffer(message, data);
     }
 

lib/src/lib.rs

@@ -59,14 +59,14 @@ macro_rules! trace_write_lock {
 }
 
 #[cfg(feature = "client")]
-mod client;
+pub mod client;
 #[cfg(feature = "console_logging")]
-mod console_logging;
-mod core;
-mod crypto;
+pub mod console_logging;
+pub mod core;
+pub mod crypto;
 #[cfg(feature = "server")]
-mod server;
-mod types;
+pub mod server;
+pub mod types;
 
 mod prelude {
     #[cfg(feature = "client")]

lib/src/server/address_space/address_space.rs

@@ -15,7 +15,7 @@ use crate::types::{
     *,
 };
 
-use super::super::{
+use crate::server::{
     address_space::{
         node::{HasNodeId, NodeType},
         object::{Object, ObjectBuilder},

lib/src/server/address_space/method.rs

@@ -15,7 +15,7 @@ use super::{
     variable::VariableBuilder,
 };
 
-use super::super::session::SessionManager;
+use crate::server::session::SessionManager;
 
 node_builder_impl!(MethodBuilder, Method);
 node_builder_impl_component_of!(MethodBuilder);

lib/src/server/address_space/method_impls.rs

@@ -10,7 +10,7 @@ use crate::types::{
     *,
 };
 
-use super::super::{callbacks::Method, session::SessionManager};
+use crate::server::{callbacks::Method, session::SessionManager};
 
 /// Count the number of provided input arguments, comparing them to the expected number.
 fn ensure_input_argument_count(

lib/src/server/comms/tcp_transport.rs

@@ -43,7 +43,7 @@ use crate::core::{
 use crate::crypto::CertificateStore;
 use crate::types::status_code::StatusCode;
 
-use super::super::{
+use crate::server::{
     address_space::types::AddressSpace,
     comms::{secure_channel_service::SecureChannelService, transport::*},
     constants,

lib/src/server/comms/transport.rs

@@ -13,7 +13,7 @@ use std::{
 
 use crate::types::status_code::StatusCode;
 
-use super::super::session::SessionManager;
+use crate::server::session::SessionManager;
 
 #[derive(Clone, Copy, Debug, PartialEq)]
 pub enum TransportState {

lib/src/server/events/event_filter.rs

@@ -14,7 +14,7 @@ use crate::types::{
     AttributeId, DateTimeUtc, NodeId, Variant,
 };
 
-use super::super::{
+use crate::server::{
     address_space::{address_space::AddressSpace, node::NodeType, relative_path::*},
     events::event::events_for_object,
     events::operator,

lib/src/server/events/operator.rs

@@ -16,7 +16,7 @@ use crate::types::{
     VariantTypeId,
 };
 
-use super::super::address_space::{
+use crate::server::address_space::{
     node::{NodeBase, NodeType},
     relative_path::find_node_from_browse_path,
     AddressSpace,

lib/src/server/services/attribute.rs

@@ -12,7 +12,7 @@ use crate::{
     types::{status_code::StatusCode, *},
 };
 
-use super::super::{
+use crate::server::{
     address_space::{
         node::{HasNodeId, NodeBase, NodeType},
         variable::Variable,

lib/src/server/services/discovery.rs

@@ -4,12 +4,12 @@
 
 use std::sync::{Arc, RwLock};
 
-use crate::core::supported_message::SupportedMessage;
+use crate::core::{config::Config, supported_message::SupportedMessage};
 use crate::types::{status_code::StatusCode, *};
 
-use super::super::state::ServerState;
+use crate::server::state::ServerState;
+
 use super::Service;
-use crate::prelude::Config;
 
 /// The discovery service. Allows a server to return the endpoints that it supports.
 pub(crate) struct DiscoveryService;

lib/src/server/services/message_handler.rs

@@ -12,7 +12,7 @@ use crate::core::supported_message::SupportedMessage;
 use crate::crypto::CertificateStore;
 use crate::types::{status_code::StatusCode, *};
 
-use super::super::{
+use crate::server::{
     address_space::AddressSpace,
     comms::tcp_transport::MessageSender,
     services::{

lib/src/server/services/method.rs

@@ -7,7 +7,7 @@ use std::sync::{Arc, RwLock};
 use crate::core::supported_message::SupportedMessage;
 use crate::types::{status_code::StatusCode, *};
 
-use super::super::{
+use crate::server::{
     address_space::AddressSpace, services::Service, session::SessionManager, state::ServerState,
 };
 

lib/src/server/services/monitored_item.rs

@@ -7,7 +7,7 @@ use std::sync::{Arc, RwLock};
 use crate::core::supported_message::SupportedMessage;
 use crate::types::{status_code::StatusCode, *};
 
-use super::super::{
+use crate::server::{
     address_space::AddressSpace, services::Service, session::Session, state::ServerState,
 };
 

lib/src/server/services/node_management.rs

@@ -10,7 +10,7 @@ use std::{
 use crate::core::supported_message::SupportedMessage;
 use crate::types::{node_ids::ObjectId, status_code::StatusCode, *};
 
-use super::super::{
+use crate::server::{
     address_space::{relative_path, types::*, AddressSpace},
     services::Service,
     session::Session,

lib/src/server/services/query.rs

@@ -7,7 +7,7 @@ use std::sync::{Arc, RwLock};
 use crate::core::supported_message::SupportedMessage;
 use crate::types::{status_code::StatusCode, *};
 
-use super::super::{
+use crate::server::{
     address_space::AddressSpace, services::Service, session::Session, state::ServerState,
 };
 

lib/src/server/services/session.rs

@@ -9,7 +9,7 @@ use crate::core::supported_message::SupportedMessage;
 use crate::crypto::{self as crypto, random, CertificateStore, SecurityPolicy};
 use crate::types::{status_code::StatusCode, *};
 
-use super::super::{
+use crate::server::{
     address_space::address_space::AddressSpace,
     constants,
     identity_token::IdentityToken,

lib/src/server/services/subscription.rs

@@ -7,7 +7,7 @@ use std::sync::{Arc, RwLock};
 use crate::core::supported_message::SupportedMessage;
 use crate::types::{status_code::StatusCode, *};
 
-use super::super::{
+use crate::server::{
     address_space::AddressSpace, services::Service, session::Session, state::ServerState,
     subscriptions::subscription::Subscription,
 };

lib/src/server/services/view.rs

@@ -9,7 +9,7 @@ use crate::core::supported_message::SupportedMessage;
 use crate::crypto::random;
 use crate::types::{node_ids::ReferenceTypeId, status_code::StatusCode, *};
 
-use super::super::{
+use crate::server::{
     address_space::{relative_path, AddressSpace},
     continuation_point::BrowseContinuationPoint,
     services::Service,

samples/chess-server/src/main.rs

@@ -7,7 +7,7 @@ use std::path::PathBuf;
 use std::sync::{Arc, Mutex};
 use std::thread;
 
-use crate::server::prelude::*;
+use opcua::server::prelude::*;
 
 mod game;
 

samples/demo-server/src/control.rs

@@ -2,7 +2,7 @@
 // SPDX-License-Identifier: MPL-2.0
 // Copyright (C) 2017-2022 Adam Lock
 
-use crate::server::prelude::*;
+use opcua::server::prelude::*;
 
 pub fn add_control_switches(server: &mut Server, ns: u16) {
     // The address space is guarded so obtain a lock to change it

samples/demo-server/src/historical.rs

@@ -5,7 +5,7 @@
 //! Implementations of HistoricalDataProvider and HistoricalEventProvider
 use std::sync::{Arc, RwLock};
 
-use crate::server::prelude::*;
+use opcua::server::prelude::*;
 
 // Register some historical data providers
 pub fn add_providers(server: &mut Server) {

samples/demo-server/src/machine.rs

@@ -10,7 +10,7 @@ use std::sync::{
 use chrono;
 use rand;
 
-use crate::server::{events::event::*, prelude::*};
+use opcua::server::{events::event::*, prelude::*};
 
 pub fn add_machinery(server: &mut Server, ns: u16, raise_event: bool) {
     let address_space = server.address_space();

samples/demo-server/src/main.rs

@@ -22,7 +22,7 @@ extern crate log;
 
 use std::path::PathBuf;
 
-use crate::server::{http, prelude::*};
+use opcua::server::{http, prelude::*};
 
 mod control;
 mod historical;

samples/demo-server/src/methods.rs

@@ -6,7 +6,7 @@
 
 use std::sync::{Arc, RwLock};
 
-use crate::server::{
+use opcua::server::{
     address_space::method::MethodBuilder, callbacks, prelude::*, session::SessionManager,
 };
 

samples/demo-server/src/scalar.rs

@@ -5,7 +5,7 @@
 use rand::distributions::Alphanumeric;
 use rand::Rng;
 
-use crate::server::prelude::*;
+use opcua::server::prelude::*;
 
 pub fn add_scalar_variables(server: &mut Server, ns: u16) {
     let (static_folder_id, dynamic_folder_id) = {

samples/discovery-client/src/main.rs

@@ -5,7 +5,7 @@
 //! This is a sample that calls find servers on a OPC UA discovery server
 use std::str::FromStr;
 
-use crate::client::prelude::*;
+use opcua::client::prelude::*;
 
 struct Args {
     help: bool,
@@ -46,7 +46,7 @@ fn main() -> Result<(), ()> {
 
         println!("Attempting to connect to discovery server {} ...", url);
         // Optional - enable OPC UA logging
-        opcua_console_logging::init();
+        opcua::console_logging::init();
 
         // The client API has a simple `find_servers` function that connects and returns servers for us.
         let mut client = Client::new(ClientConfig::new("DiscoveryClient", "urn:DiscoveryClient"));

samples/event-client/src/main.rs

@@ -10,7 +10,7 @@
 use std::str::FromStr;
 use std::sync::{Arc, RwLock};
 
-use crate::client::prelude::*;
+use opcua::client::prelude::*;
 
 struct Args {
     help: bool,
@@ -60,7 +60,7 @@ fn main() -> Result<(), ()> {
         Args::usage();
     } else {
         // Optional - enable OPC UA logging
-        opcua_console_logging::init();
+        opcua::console_logging::init();
 
         // Make the client configuration
         let mut client = ClientBuilder::new()

samples/modbus-server/src/config.rs

@@ -4,7 +4,7 @@
 
 use std::{fs::File, io::Read, path::Path};
 
-use crate::server::prelude::*;
+use opcua::server::prelude::*;
 
 use crate::Table;
 

samples/modbus-server/src/main.rs

@@ -113,7 +113,7 @@ fn main() -> Result<(), ()> {
             std::process::exit(1);
         };
 
-        opcua_console_logging::init();
+        opcua::console_logging::init();
         run(config, args.run_demo_slave);
     }
     Ok(())

samples/modbus-server/src/opcua.rs

@@ -9,7 +9,7 @@ use std::{
     u16,
 };
 
-use crate::server::prelude::*;
+use opcua::server::prelude::*;
 
 use crate::{
     config::{Alias, AliasType, TableConfig},

samples/mqtt-client/src/main.rs

@@ -12,7 +12,7 @@ use std::{
 
 use rumqtt::{MqttClient, MqttOptions, QoS};
 
-use crate::client::prelude::*;
+use opcua::client::prelude::*;
 
 struct Args {
     help: bool,
@@ -79,7 +79,7 @@ fn main() -> Result<(), ()> {
         let endpoint_id = args.endpoint_id;
 
         // Optional - enable OPC UA logging
-        opcua_console_logging::init();
+        opcua::console_logging::init();
 
         // The way this will work is the mqtt connection will live in its own thread, listening for
         // events that are sent to it.

samples/simple-client/src/main.rs

@@ -9,7 +9,7 @@
 //! 3. Subscribe to values and loop forever printing out their values
 use std::sync::{Arc, RwLock};
 
-use crate::client::prelude::*;
+use opcua::client::prelude::*;
 
 struct Args {
     help: bool,
@@ -47,7 +47,7 @@ fn main() -> Result<(), ()> {
         Args::usage();
     } else {
         // Optional - enable OPC UA logging
-        opcua_console_logging::init();
+        opcua::console_logging::init();
 
         // Make the client configuration
         let mut client = ClientBuilder::new()

samples/simple-server/src/main.rs

@@ -8,12 +8,12 @@
 use std::path::PathBuf;
 use std::sync::{Arc, Mutex};
 
-use crate::server::prelude::*;
+use opcua::server::prelude::*;
 
 fn main() {
     // This enables logging via env_logger & log crate macros. If you don't need logging or want
     // to implement your own, omit this line.
-    opcua_console_logging::init();
+    opcua::console_logging::init();
 
     // Create an OPC UA server with sample configuration and default node set
     let mut server = Server::new(ServerConfig::load(&PathBuf::from("../server.conf")).unwrap());

samples/web-client/src/main.rs

@@ -19,7 +19,7 @@ use actix_web::{
     ws, App, Error, HttpRequest, HttpResponse,
 };
 
-use crate::client::prelude::*;
+use opcua::client::prelude::*;
 
 struct Args {
     help: bool,