Решение на упр.06 задача 1 от Димитър Колев
Резултати
- 4 точки от тестове
- 1 бонус точка
- 5 точки общо
- 4 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::collections::HashMap;
use std::error::Error;
use std::fs::File;
use std::io;
use std::io::Read;
use std::path::Path;
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
enum LogLevel {
Error,
Warn,
Info,
Debug,
}
#[derive(Debug)]
enum ParseLogError {
Read(io::Error),
ParseLine,
}
impl std::fmt::Display for ParseLogError {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
match &self {
ParseLogError::Read(e) => write!(f, "unable to read logfile: {e}"),
ParseLogError::ParseLine => write!(f, "unable to parse a line of the logfile"),
}
}
}
impl Error for ParseLogError {}
fn parse_log_file<R>(file: R, map: &mut HashMap<LogLevel, usize>) -> Result<(), ParseLogError>
where
R: Read,
{
let buf = io::read_to_string(file).map_err(ParseLogError::Read)?;
for l in buf.lines() {
match l.split(' ').next().ok_or(ParseLogError::ParseLine)? {
"ERROR" => map
.entry(LogLevel::Error)
.and_modify(|e| *e += 1)
.or_insert(1),
"WARN" => map
.entry(LogLevel::Warn)
.and_modify(|e| *e += 1)
.or_insert(1),
"INFO" => map
.entry(LogLevel::Info)
.and_modify(|e| *e += 1)
.or_insert(1),
"DEBUG" => map
.entry(LogLevel::Debug)
.and_modify(|e| *e += 1)
.or_insert(1),
_ => return Err(ParseLogError::ParseLine),
};
}
Ok(())
}
struct AggregateInfo {
log_counts: HashMap<LogLevel, usize>,
skipped_files: Vec<String>,
}
fn aggregate_logs(dir: &Path) -> Result<AggregateInfo, Box<dyn Error>> {
let mut result = AggregateInfo {
log_counts: HashMap::new(),
skipped_files: Vec::new(),
};
for p in dir.read_dir()? {
let p = p?.path();
if p.extension().unwrap_or(std::ffi::OsStr::new("")) != "log" {
result.skipped_files.push(p.display().to_string());
continue;
}
let mut f = File::open(p)?;
let mut buf = [0u8; 10 * 1024];
loop {
let n = f.read(&mut buf[..])?;
if n == 0 {
break;
}
parse_log_file(&buf[..n], &mut result.log_counts)?;
}
}
Ok(result)
}
fn main() -> Result<(), Box<dyn Error>> {
let logs = std::env::args()
.nth(1)
.ok_or("you didn't give me any logs to parse :face_holding_back_tears:")?;
let logs = Path::new(&logs);
aggregate_logs(logs).map(|x| {
for x in x.skipped_files {
eprintln!("warning: skipping {}", x);
}
for level in [
(LogLevel::Debug, "Debug"),
(LogLevel::Info, "Info"),
(LogLevel::Warn, "Warn"),
(LogLevel::Error, "Error"),
] {
println!("{}: {}", level.1, x.log_counts.get(&level.0).unwrap_or(&0));
}
})
}
Лог от изпълнението
Updating crates.io index
Locking 17 packages to latest compatible versions
Compiling proc-macro2 v1.0.103
Compiling quote v1.0.42
Compiling unicode-ident v1.0.22
Compiling futures-core v0.3.31
Compiling futures-sink v0.3.31
Compiling futures-channel v0.3.31
Compiling pin-project-lite v0.2.16
Compiling futures-task v0.3.31
Compiling syn v2.0.110
Compiling pin-utils v0.1.0
Compiling slab v0.4.11
Compiling memchr v2.7.6
Compiling futures-io v0.3.31
Compiling solution v0.1.0 (/tmp/d20251120-1757769-1io73zz/solution)
warning: enum `LogLevel` is never used
--> src/lib.rs:9:6
|
9 | enum LogLevel {
| ^^^^^^^^
|
= note: `#[warn(dead_code)]` on by default
warning: enum `ParseLogError` is never used
--> src/lib.rs:17:6
|
17 | enum ParseLogError {
| ^^^^^^^^^^^^^
warning: function `parse_log_file` is never used
--> src/lib.rs:33:4
|
33 | fn parse_log_file<R>(file: R, map: &mut HashMap<LogLevel, usize>) -> Result<(), ParseLogError>
| ^^^^^^^^^^^^^^
warning: struct `AggregateInfo` is never constructed
--> src/lib.rs:64:8
|
64 | struct AggregateInfo {
| ^^^^^^^^^^^^^
warning: function `aggregate_logs` is never used
--> src/lib.rs:69:4
|
69 | fn aggregate_logs(dir: &Path) -> Result<AggregateInfo, Box<dyn Error>> {
| ^^^^^^^^^^^^^^
warning: function `main` is never used
--> src/lib.rs:98:4
|
98 | fn main() -> Result<(), Box<dyn Error>> {
| ^^^^
warning: `solution` (lib) generated 6 warnings
Compiling futures-macro v0.3.31
Compiling futures-util v0.3.31
Compiling futures-executor v0.3.31
Compiling futures v0.3.31
warning: function `main` is never used
--> tests/../src/lib.rs:98:4
|
98 | fn main() -> Result<(), Box<dyn Error>> {
| ^^^^
|
= note: `#[warn(dead_code)]` on by default
warning: `solution` (test "solution_test") generated 1 warning
Finished `test` profile [unoptimized + debuginfo] target(s) in 8.63s
Running tests/solution_test.rs (target/debug/deps/solution_test-f75e629a1d90e17c)
running 4 tests
test solution_test::test_parse_log_basic ... ok
test solution_test::test_aggregate ... ok
test solution_test::test_parse_log_big_data ... ok
test solution_test::test_parse_log_invalid ... ok
test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s