From d1a76e00fc92d1550e748fd1b393eaf0f10f7112 Mon Sep 17 00:00:00 2001
From: Stuart Stock <stuart@int08h.com>
Date: Sun, 30 Sep 2018 17:43:27 -0500
Subject: Separate trait objects for file- and environment-based server config

---
 src/config/file.rs | 127 +++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 127 insertions(+)
 create mode 100644 src/config/file.rs

(limited to 'src/config/file.rs')

diff --git a/src/config/file.rs b/src/config/file.rs
new file mode 100644
index 0000000..24011bb
--- /dev/null
+++ b/src/config/file.rs
@@ -0,0 +1,127 @@
+// Copyright 2017-2018 int08h LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+extern crate hex;
+
+use std::fs::File;
+use std::io::Read;
+use std::net::SocketAddr;
+use std::time::Duration;
+use yaml_rust::YamlLoader;
+
+use Error;
+use config::ServerConfig;
+use config::{DEFAULT_BATCH_SIZE, DEFAULT_STATUS_INTERVAL};
+
+///
+/// Read a Roughenough server configuration ([ServerConfig](trait.ServerConfig.html))
+/// from a YAML file.
+///
+/// Example config:
+///
+/// ```yaml
+/// interface: 127.0.0.1
+/// port: 8686
+/// seed: f61075c988feb9cb700a4a6a3291bfbc9cab11b9c9eca8c802468eb38a43d7d3
+/// ```
+///
+pub struct FileConfig {
+    port: u16,
+    interface: String,
+    seed: Vec<u8>,
+    batch_size: u8,
+    status_interval: Duration,
+}
+
+impl FileConfig {
+    pub fn from_file(config_file: &str) -> Result<Self, Error> {
+        let mut infile = File::open(config_file).expect("failed to open config file");
+
+        let mut contents = String::new();
+        infile
+            .read_to_string(&mut contents)
+            .expect("could not read config file");
+
+        let cfg = YamlLoader::load_from_str(&contents).expect("could not parse config file");
+
+        if cfg.len() != 1 {
+            return Err(Error::InvalidConfiguration(
+                "Empty or malformed config file".to_string(),
+            ));
+        }
+
+        let mut config = FileConfig {
+            port: 0,
+            interface: "".to_string(),
+            seed: Vec::new(),
+            batch_size: DEFAULT_BATCH_SIZE,
+            status_interval: DEFAULT_STATUS_INTERVAL,
+        };
+
+        for (key, value) in cfg[0].as_hash().unwrap() {
+            match key.as_str().unwrap() {
+                "port" => config.port = value.as_i64().unwrap() as u16,
+                "interface" => config.interface = value.as_str().unwrap().to_string(),
+                "batch_size" => config.batch_size = value.as_i64().unwrap() as u8,
+                "seed" => {
+                    let val = value.as_str().unwrap().to_string();
+                    config.seed = hex::decode(val)
+                        .expect("seed value invalid; 'seed' should be 32 byte hex value");
+                }
+                "status_interval" => {
+                    let val = value.as_i64().expect("status_interval value invalid");
+                    config.status_interval = Duration::from_secs(val as u64)
+                }
+                unknown => {
+                    return Err(Error::InvalidConfiguration(format!(
+                        "unknown config key: {}",
+                        unknown
+                    )));
+                }
+            }
+        }
+
+        Ok(config)
+    }
+}
+
+impl ServerConfig for FileConfig {
+    fn interface(&self) -> &str {
+        self.interface.as_ref()
+    }
+
+    fn port(&self) -> u16 {
+        self.port
+    }
+
+    fn seed(&self) -> &[u8] {
+        &self.seed
+    }
+
+    fn batch_size(&self) -> u8 {
+        self.batch_size
+    }
+
+    fn status_interval(&self) -> Duration {
+        self.status_interval
+    }
+
+    fn socket_addr(&self) -> Result<SocketAddr, Error> {
+        let addr = format!("{}:{}", self.interface, self.port);
+        match addr.parse() {
+            Ok(v) => Ok(v),
+            Err(_) => Err(Error::InvalidConfiguration(addr)),
+        }
+    }
+}
-- 
cgit v1.2.3