matthiasbeyer/imag
1
0
Fork 0
Code Releases Activity

replaced typedef with newtype

Browse source
This commit is contained in:
Kai Sickeler 2016-07-16 18:09:30 +02:00
parent 33db6da554
commit cd182c73f4
1 changed files with 19 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
libimagcounter/src/counter.rs
View file

@ -3,12 +3,15 @@ use std::ops::DerefMut;
use toml::Value; use toml::Value;
use std::collections::BTreeMap; use std::collections::BTreeMap;
use std::fmt;
use std::fmt::Display;
use libimagstore::store::Store; use libimagstore::store::Store;
use libimagstore::storeid::StoreIdIterator; use libimagstore::storeid::StoreIdIterator;
use libimagstore::store::FileLockEntry; use libimagstore::store::FileLockEntry;
use libimagstore::storeid::StoreId; use libimagstore::storeid::StoreId;
use libimagstore::storeid::IntoStoreId; use libimagstore::storeid::IntoStoreId;
use libimagerror::into::IntoError;
use module_path::ModuleEntryPath; use module_path::ModuleEntryPath;
use result::Result; use result::Result;
@ -16,7 +19,15 @@ use error::CounterError as CE;
use error::CounterErrorKind as CEK; use error::CounterErrorKind as CEK;
pub type CounterName = String; pub type CounterName = String;
pub type CounterUnit = String;
#[derive(Clone, Debug, Eq, PartialEq, Ord, PartialOrd)]
pub struct CounterUnit(pub String);
impl Display for CounterUnit {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(f, "({})", self.0)
}
}
pub struct Counter<'a> { pub struct Counter<'a> {
fle: FileLockEntry<'a>, fle: FileLockEntry<'a>,
@ -48,12 +59,8 @@ impl<'a> Counter<'a> {
return Err(CE::new(CEK::StoreWriteError, Some(Box::new(setres.unwrap_err())))); return Err(CE::new(CEK::StoreWriteError, Some(Box::new(setres.unwrap_err()))));
} }
let setres = header.set("counter.value", Value::Integer(init)); let setres = header.set("counter.value", Value::Integer(init))
if setres.is_err() { .and_then(|_| header.set("counter.unit", Value::String(unit.clone().0)));
return Err(CE::new(CEK::StoreWriteError, Some(Box::new(setres.unwrap_err()))));
}
let setres = header.set("counter.unit", Value::String(unit));
if setres.is_err() { if setres.is_err() {
return Err(CE::new(CEK::StoreWriteError, Some(Box::new(setres.unwrap_err())))); return Err(CE::new(CEK::StoreWriteError, Some(Box::new(setres.unwrap_err()))));
} }
@ -129,13 +136,13 @@ impl<'a> Counter<'a> {
pub fn unit(&self) -> Result<CounterUnit> { pub fn unit(&self) -> Result<CounterUnit> {
self.fle.get_header().read("counter.unit") self.fle.get_header().read("counter.unit")
.map_err(|e| CE::new(CEK::StoreWriteError, Some(Box::new(e)))) .map_err(|e| CEK::StoreWriteError.into_error_with_cause(Box::new(e)))
.and_then(|u| { .and_then(|u|
match u { match u {
Some(Value::String(s)) => Ok(s), Some(Value::String(s)) => Ok(CounterUnit(s)),
_ => Err(CE::new(CEK::HeaderTypeError, None)), _ => Err(CEK::HeaderTypeError.into_error())
} }
}) )
} }
pub fn load(name: CounterName, store: &Store) -> Result<Counter> { pub fn load(name: CounterName, store: &Store) -> Result<Counter> {