add Room struct

.gitignore

@@ -1,2 +1 @@
-/.idea/
+/.idea/
-/**/.DS_Store

practice/.gitignore

@@ -1 +0,0 @@
-/target/

practice/Cargo.lock

@@ -1,7 +0,0 @@
-# This file is automatically @generated by Cargo.
-# It is not intended for manual editing.
-version = 4
-
-[[package]]
-name = "practice"
-version = "0.0.0"

practice/Cargo.toml

@@ -1,6 +0,0 @@
-[package]
-name = "practice"
-version = "0.0.0"
-edition = "2024"
-
-[dependencies]

practice/src/bin/a_compare.rs

@@ -1,21 +0,0 @@
-// Напиúите функøиĀ compare<T: PartialOrd>(a: T, b: T) -> T, котораā:
-// ● Возвраûает наиболþúий из двух аргументов (a или b).
-// ● Исполþзуйте трейт PartialOrd длā сравнениā.
-
-#![allow(clippy::approx_constant)]
-
-fn compare<T>(a: T, b: T) -> T
-where
-    T: PartialOrd,
-{
-    if a >= b { a } else { b }
-}
-
-fn main() {
-    println!("{}", compare(5, 10)); // 10
-    println!("{}", compare('a', 'z')); // z
-
-    // Также работает с другими типами, реализующими PartialOrd
-    println!("{}", compare(3.14, 2.71)); // 3.14
-    println!("{}", compare("apple", "banana")); // "banana"
-}

practice/src/bin/b_pair.rs

@@ -1,35 +0,0 @@
-// Создайте структуру Pair<T, U> с двумā полāми разнýх типов:
-// ● Реализуйте метод new(first: T, second: U) -> Self.
-// ● Добавþте метод swap(self) -> Pair<U, T>, которýй менāет местами знаùениā полей.
-
-#![allow(clippy::approx_constant)]
-
-#[derive(Debug)]
-struct Pair<T, U> {
-    first: T,
-    second: U,
-}
-
-impl<T, U> Pair<T, U> {
-    // Создаем новую пару
-    fn new(first: T, second: U) -> Self {
-        Self { first, second }
-    }
-
-    // Меняем местами значения
-    fn swap(self) -> Pair<U, T> {
-        Pair::new(self.second, self.first)
-    }
-}
-
-fn main() {
-    let pair = Pair::new(42, "hello");
-    let swapped = pair.swap();
-
-    println!("{:?}", swapped); // Pair("hello", 42)
-
-    // Дополнительный пример с другими типами
-    let float_str_pair = Pair::new(3.14, "pi");
-    let swapped_pair = float_str_pair.swap();
-    println!("{:?}", swapped_pair); // Pair("pi", 3.14)
-}

practice/src/bin/c_area.rs

@@ -1,64 +0,0 @@
-// 1. Определите типаж Area с методом area(&self) -> f64.
-// 2. Реализуйте его длā структур Circle (с полем radius: f64) и Square (с полем side: f64).
-// 3. Напишите обобщенную функцию print_area<T: Area>(shape: T), которая печатает площадь фигуру.
-
-// Определяем типаж Area
-trait Area {
-    fn area(&self) -> f64;
-}
-
-// Структура Circle
-struct Circle {
-    radius: f64,
-}
-
-// Реализация Area для Circle
-impl Area for Circle {
-    fn area(&self) -> f64 {
-        std::f64::consts::PI * self.radius * self.radius
-    }
-}
-
-// Структура Square
-struct Square {
-    side: f64,
-}
-
-// Реализация Area для Square
-impl Area for Square {
-    fn area(&self) -> f64 {
-        self.side * self.side
-    }
-}
-
-// Обобщённая функция для вывода площади
-fn print_area(area: impl Area) {
-    println!("Area: {}", area.area())
-}
-
-fn main() {
-    let circle = Circle { radius: 5.0 };
-    let square = Square { side: 10.0 };
-
-    print_area(circle); // Area: 78.53981633974483
-    print_area(square); // Area: 100
-
-    // Можно добавить больше фигур, реализующих Area
-    let rectangle = Rectangle {
-        width: 4.0,
-        height: 6.0,
-    };
-    print_area(rectangle); // Area: 24
-}
-
-// Дополнительная структура для демонстрации расширяемости
-struct Rectangle {
-    width: f64,
-    height: f64,
-}
-
-impl Area for Rectangle {
-    fn area(&self) -> f64 {
-        self.width * self.height
-    }
-}

practice/src/bin/d_wrapper.rs

@@ -1,37 +0,0 @@
-// Создайте структуру Wrapper<T> с одним полем value: T:
-// ● Реализуйте метод map<U, F>(self, f: F) -> Wrapper<U>, где F: FnOnce(T) -> U.
-// ● Метод должен применāтþ функøиĀ f к value и возвраûатþ новýй Wrapper с резулþтатом.
-
-#![allow(clippy::approx_constant)]
-
-struct Wrapper<T> {
-    value: T,
-}
-
-impl<T> Wrapper<T> {
-    // Создаем новый Wrapper
-    fn new(value: T) -> Self {
-        Self { value }
-    }
-
-    // Применяем функцию к значению и возвращаем новый Wrapper
-    fn map<U>(self, f: impl FnOnce(T) -> U) -> Wrapper<U> {
-        Wrapper::new(f(self.value))
-    }
-}
-
-fn main() {
-    // Пример из задания
-    let w = Wrapper { value: 42 };
-    let w2 = w.map(|x| x.to_string());
-    println!("{}", w2.value); // "42"
-
-    // Дополнительные примеры
-    let w3 = Wrapper::<f64>::new(3.14);
-    let w4 = w3.map(|x| x.floor() as i32);
-    println!("{}", w4.value); // 3
-
-    let w5 = Wrapper::new("hello");
-    let w6 = w5.map(|s| s.len());
-    println!("{}", w6.value); // 5
-}

practice/src/bin/e_summary.rs

@@ -1,59 +0,0 @@
-// 1. Создайте типаж Summary с методом summarize(&self) -> String.
-// 2. Реализуйте его длā:
-// ○ Vec<T> (где T: ToString), метод должен соединять элементы через запятую.
-// ○ HashMap<K, V> (где K: ToString, V: ToString), метод должен выводить пары key:value.
-// 3. Напиúите функøиĀ print_summary<T: Summary>(item: T), которая печатает результат summarize().
-
-use std::collections::HashMap;
-
-// Определяем типаж Summary
-trait Summary {
-    fn summarize(&self) -> String;
-}
-
-// Реализация для Vec<T> где T: ToString
-impl<T: ToString> Summary for Vec<T> {
-    fn summarize(&self) -> String {
-        self.iter()
-            .map(|v| v.to_string())
-            .collect::<Vec<String>>()
-            .join(",")
-            .to_string()
-    }
-}
-
-// Реализация для HashMap<K, V> где K: ToString, V: ToString
-impl<K: ToString, V: ToString> Summary for HashMap<K, V> {
-    fn summarize(&self) -> String {
-        self.iter()
-            .map(|(k, v)| format!("{}:{}", k.to_string(), v.to_string()))
-            .collect::<Vec<String>>()
-            .join(", ")
-    }
-}
-
-// Обобщённая функция для вывода сводки
-fn print_summary(summary: impl Summary) {
-    println!("{}", summary.summarize())
-}
-
-fn main() {
-    // Пример с вектором
-    let vec = vec![1, 2, 3];
-    print_summary(vec); // "1, 2, 3"
-
-    // Пример с HashMap
-    let mut map = HashMap::new();
-    map.insert("name", "Alice");
-    map.insert("age", "30");
-    print_summary(map); // "name:Alice, age:30" (порядок может отличаться)
-
-    // Дополнительный пример с разными типами
-    let words = vec!["hello", "world"];
-    print_summary(words); // "hello, world"
-
-    let mut scores = HashMap::new();
-    scores.insert("math", 95);
-    scores.insert("science", 90);
-    print_summary(scores); // "math:95, science:90"
-}

practice/src/bin/f_largest_by_key.rs

@@ -1,55 +0,0 @@
-// Напиúите обобщенную функцию largest_by_key<T, F, K>(list: &[T], key: F) -> Option<&T>, где:
-// ● F: Fn(&T) -> K,
-// ● K: PartialOrd.
-// Функция должна возвращать элемент с максимальным значением key(item).
-
-fn largest_by_key<T, K: PartialOrd>(list: &[T], key: impl Fn(&T) -> K) -> Option<&T> {
-    let l_len = list.len();
-    if l_len < 1 {
-        return None;
-    } else if l_len == 1 {
-        return Some(&list[0]);
-    }
-    let mut max = &list[0];
-    let mut max_key = key(max);
-    for element in &list[1..] {
-        let element_key = key(element);
-        if element_key > max_key {
-            (max, max_key) = (element, element_key);
-        }
-    }
-    Some(max)
-}
-
-fn main() {
-    // Пример из задания
-    let words = ["apple", "banana", "cherry"];
-    let longest = largest_by_key(&words, |s| s.len());
-    println!("{:?}", longest); // Some("banana")
-
-    // Дополнительные примеры
-    let numbers = [1, 42, 3, 100, 5];
-    let largest_num = largest_by_key(&numbers, |&n| n);
-    println!("{:?}", largest_num); // Some(100)
-
-    struct Person {
-        name: String,
-        age: u32,
-    }
-    let people = [
-        Person {
-            name: "Alice".to_string(),
-            age: 30,
-        },
-        Person {
-            name: "Bob".to_string(),
-            age: 25,
-        },
-        Person {
-            name: "Charlie".to_string(),
-            age: 35,
-        },
-    ];
-    let oldest = largest_by_key(&people, |p| p.age);
-    println!("Oldest: {:?}", oldest.map(|p| &p.name)); // Some("Charlie")
-}

practice/src/bin/g_draw.rs

@@ -1,44 +0,0 @@
-// Определяем типаж Draw
-trait Draw {
-    fn draw(&self);
-}
-
-// Структура Circle
-struct Circle;
-
-// Реализация Draw для Circle
-impl Draw for Circle {
-    fn draw(&self) {
-        println!("Drawing circle")
-    }
-}
-
-// Структура Square
-struct Square;
-
-// Реализация Draw для Square
-impl Draw for Square {
-    fn draw(&self) {
-        println!("Drawing square")
-    }
-}
-
-fn main() {
-    // Создаем гетерогенную коллекцию фигур
-    let shapes: Vec<Box<dyn Draw>> = vec![Box::new(Circle), Box::new(Square)];
-
-    // Рисуем все фигуры
-    for shape in shapes {
-        shape.draw();
-    }
-
-    // Добавим еще фигур динамически
-    let mut more_shapes: Vec<Box<dyn Draw>> = Vec::new();
-    more_shapes.push(Box::new(Circle));
-    more_shapes.push(Box::new(Square));
-
-    println!("\nЕще фигуры:");
-    for shape in more_shapes {
-        shape.draw();
-    }
-}

practice/src/bin/h_plugins.rs

@@ -1,53 +0,0 @@
-use std::time::SystemTime;
-
-// Определяем типаж Plugin
-trait Plugin {
-    fn execute(&self) -> String;
-}
-
-// Плагин приветствия
-struct GreetPlugin;
-
-impl Plugin for GreetPlugin {
-    fn execute(&self) -> String {
-        "Hello, world!".to_string()
-    }
-}
-
-// Плагин времени
-struct TimePlugin;
-
-impl Plugin for TimePlugin {
-    fn execute(&self) -> String {
-        let now = SystemTime::now()
-            .duration_since(SystemTime::UNIX_EPOCH)
-            .unwrap();
-
-        let seconds = now.as_secs();
-        let minutes = seconds / 60;
-        let hours = (minutes / 60) % 24;
-        let minutes = minutes % 60;
-
-        format!("Current time: {:02}:{:02}", hours, minutes)
-    }
-}
-
-fn main() {
-    // Создаем коллекцию плагинов
-    let plugins = Vec::<Box<dyn Plugin>>::with_capacity(2);
-
-    // Выполняем все плагины
-    for plugin in plugins {
-        println!("{}", plugin.execute());
-    }
-
-    // Дополнительный пример с динамическим добавлением
-    let mut dynamic_plugins: Vec<Box<dyn Plugin>> = Vec::new();
-    dynamic_plugins.push(Box::new(GreetPlugin));
-    dynamic_plugins.push(Box::new(TimePlugin));
-
-    println!("\nDynamic execution:");
-    for plugin in dynamic_plugins {
-        println!("{}", plugin.execute());
-    }
-}

practice/src/bin/i_dyn_parser.rs

@@ -1,70 +0,0 @@
-// Определяем типаж Parser
-trait Parser {
-    fn parse(&self, input: &str) -> Result<String, String>;
-}
-
-
-
-// Парсер JSON
-struct JsonParser;
-
-impl Parser for JsonParser {
-    fn parse(&self, input: &str) -> Result<String, String> {
-        if input.trim().starts_with('{') && input.trim().ends_with('}') {
-            Ok("Parsed JSON".to_string())
-        } else {
-            Err("Invalid JSON format".to_string())
-        }
-    }
-}
-
-// Парсер CSV
-struct CsvParser;
-
-impl Parser for CsvParser {
-    fn parse(&self, input: &str) -> Result<String, String> {
-        if input.contains(',') {
-            Ok("Parsed CSV".to_string())
-        } else {
-            Err("Invalid CSV format".to_string())
-        }
-    }
-}
-
-// Функция для обработки данных парсером
-fn parse_data(parser: &dyn Parser, input: &str) -> Result<String, String> {
-    parser.parse(input)
-}
-
-
-
-fn main() {
-    // Пример использования JSON парсера
-    let json_parser = JsonParser;
-    let result = parse_data(&json_parser, r#"{ "name": "Alice" }"#);
-    println!("{:?}", result); // Ok("Parsed JSON")
-
-    // Пример использования CSV парсера
-    let csv_parser = CsvParser;
-    let result = parse_data(&csv_parser, "name,age,location");
-    println!("{:?}", result); // Ok("Parsed CSV")
-
-    // Пример обработки ошибок
-    let invalid_json = parse_data(&json_parser, "not a json");
-    println!("{:?}", invalid_json); // Err("Invalid JSON format")
-
-    let invalid_csv = parse_data(&csv_parser, "no commas here");
-    println!("{:?}", invalid_csv); // Err("Invalid CSV format")
-
-    // Динамический выбор парсера
-    let parsers: Vec<&dyn Parser> = vec![&json_parser, &csv_parser];
-    for parser in parsers {
-        println!("Testing parser:");
-        let test_input = if parser.parse("{").is_ok() {
-            r#"{ "test": "value" }"#
-        } else {
-            "field1,field2,field3"
-        };
-        println!("{:?}", parser.parse(test_input));
-    }
-}

practice/src/bin/j_sort_strategy.rs

@@ -1,89 +0,0 @@
-// Определяем типаж стратегии сортировки
-trait SortStrategy {
-    fn sort(&self, data: &mut [i32]);
-}
-
-
-// Реализация пузырьковой сортировки
-struct BubbleSort;
-
-impl SortStrategy for BubbleSort {
-    fn sort(&self, data: &mut [i32]) {
-        let len = data.len();
-        for i in 0..len {
-            for j in 0..len - i - 1 {
-                if data[j] > data[j + 1] {
-                    data.swap(j, j + 1);
-                }
-            }
-        }
-    }
-}
-
-// Реализация быстрой сортировки
-struct QuickSort;
-
-impl SortStrategy for QuickSort {
-    fn sort(&self, data: &mut [i32]) {
-        if data.len() <= 1 {
-            return;
-        }
-
-        let pivot = data.len() / 2;
-        let mut i = 0;
-        let mut j = data.len() - 1;
-
-        loop {
-            while data[i] < data[pivot] {
-                i += 1;
-            }
-            while data[j] > data[pivot] {
-                j -= 1;
-            }
-
-            if i >= j {
-                break;
-            }
-
-            data.swap(i, j);
-            i += 1;
-            j -= 1;
-        }
-
-        self.sort(&mut data[..i]);
-        self.sort(&mut data[i..]);
-    }
-}
-
-// Функция для применения стратегии сортировки
-fn sort_data(strategy: &dyn SortStrategy, data: &mut [i32]) {
-    strategy.sort(data)
-}
-
-
-
-fn main() {
-    // Тестируем пузырьковую сортировку
-    let mut data1 = [3, 1, 2, 5, 4];
-    let bubble = Box::new(BubbleSort);
-    sort_data(&*bubble, &mut data1);
-    println!("Bubble sort: {:?}", data1); // [1, 2, 3, 4, 5]
-
-    // Тестируем быструю сортировку
-    let mut data2 = [7, 3, 9, 2, 1];
-    let quick = Box::new(QuickSort);
-    sort_data(&*quick, &mut data2);
-    println!("Quick sort: {:?}", data2); // [1, 2, 3, 7, 9]
-
-    // Динамический выбор стратегии
-    let strategies: Vec<Box<dyn SortStrategy>> = vec![
-        Box::new(BubbleSort),
-        Box::new(QuickSort),
-    ];
-
-    for strategy in strategies {
-        let mut test_data = [5, 2, 4, 1, 3];
-        strategy.sort(&mut test_data);
-        println!("Sorted: {:?}", test_data);
-    }
-}

practice/src/bin/k_dyn_logger.rs

@@ -1,91 +0,0 @@
-// Уровни логирования
-#[derive(Debug, PartialEq, PartialOrd, Copy, Clone)]
-enum LogLevel {
-    Error,
-    Warn,
-    Info,
-    Debug,
-}
-
-// Типаж Logger
-trait Logger {
-    fn log(&self, message: &str);
-    fn level(&self) -> LogLevel;
-}
-
-// Логгер в консоль
-struct ConsoleLogger {
-    level: LogLevel,
-}
-
-impl ConsoleLogger {
-    fn new(level: LogLevel) -> Self {
-        ConsoleLogger { level }
-    }
-}
-
-impl Logger for ConsoleLogger {
-    fn log(&self, message: &str) {
-        println!("[Console] {}", message);
-    }
-
-    fn level(&self) -> LogLevel {
-        self.level
-    }
-}
-
-// Логгер в файл (упрощенная реализация)
-struct FileLogger {
-    level: LogLevel,
-    file_path: String,
-}
-
-impl FileLogger {
-    fn new(level: LogLevel, file_path: &str) -> Self {
-        FileLogger {
-            level,
-            file_path: file_path.to_string(),
-        }
-    }
-}
-
-impl Logger for FileLogger {
-    fn log(&self, message: &str) {
-        println!("[File: {}] {}", self.file_path, message);
-        // В реальной реализации здесь была бы запись в файл
-    }
-
-    fn level(&self) -> LogLevel {
-        self.level
-    }
-}
-
-// Функция для логирования сообщения с проверкой уровня
-fn log_message(logger: &dyn Logger, message: &str) {
-    if logger.level() >= LogLevel::Info {  // Пример: логируем только Info и выше
-        logger.log(message);
-    }
-}
-
-fn main() {
-    // Создаем логгеры
-    let console_logger = Box::new(ConsoleLogger::new(LogLevel::Info));
-    let file_logger = Box::new(FileLogger::new(LogLevel::Debug, "app.log"));
-
-    // Логируем сообщения
-    log_message(&*console_logger, "Application started");
-    log_message(&*file_logger, "Debug information");
-
-    // Сообщение, которое не будет залогировано (уровень ниже Info)
-    log_message(&*console_logger, "Trace information");
-
-    // Динамический выбор логгера
-    let loggers: Vec<Box<dyn Logger>> = vec![
-        Box::new(ConsoleLogger::new(LogLevel::Warn)),
-        Box::new(FileLogger::new(LogLevel::Error, "errors.log")),
-    ];
-
-    for logger in loggers {
-        log_message(&*logger, "Testing logger");
-    }
-}

practice/src/bin/l_event_handler.rs

@@ -1,80 +0,0 @@
-use std::collections::HashMap;
-
-// Определяем типаж обработчика событий
-trait EventHandler {
-    fn handle(&self, event: &str);
-}
-
-// Обработчик для отправки email
-struct EmailHandler;
-
-impl EventHandler for EmailHandler {
-    fn handle(&self, event: &str) {
-        println!("EmailHandler handling event '{}'", event)
-    }
-}
-
-// Обработчик для сохранения в базу данных
-struct DatabaseHandler;
-
-impl EventHandler for DatabaseHandler {
-    fn handle(&self, event: &str) {
-        println!("DatabaseHandler handling event '{}'", event)
-    }
-}
-
-// Обработчик для логирования
-struct LogHandler;
-
-impl EventHandler for LogHandler {
-    fn handle(&self, event: &str) {
-        println!("LogHandler handling event '{}'", event)
-    }
-}
-
-fn main() {
-    // Создаем реестр обработчиков событий
-    let mut handlers: HashMap<String, Box<dyn EventHandler>> = HashMap::new();
-
-    // Регистрируем обработчики
-    handlers.insert("email".to_string(), Box::new(EmailHandler));
-    handlers.insert("database".to_string(), Box::new(DatabaseHandler));
-    handlers.insert("log".to_string(), Box::new(LogHandler));
-
-    // Обрабатываем события
-    if let Some(handler) = handlers.get("email") {
-        handler.handle("New user registration");
-    }
-
-    if let Some(handler) = handlers.get("database") {
-        handler.handle("User data update");
-    }
-
-    // Динамическая обработка нескольких событий
-    let events = vec![
-        ("email", "Password reset requested"),
-        ("database", "Order completed"),
-        ("log", "System started"),
-        ("unknown", "This won't be processed"), // Не будет обработано
-    ];
-
-    for (event_type, event_data) in events {
-        if let Some(handler) = handlers.get(event_type) {
-            handler.handle(event_data);
-        } else {
-            println!("No handler registered for event type: {}", event_type);
-        }
-    }
-
-    // Добавление нового обработчика во время выполнения
-    struct NotificationHandler;
-
-    impl EventHandler for NotificationHandler {
-        fn handle(&self, event: &str) {
-            println!("Sending push notification: '{}'", event);
-        }
-    }
-
-    handlers.insert("notification".to_string(), Box::new(NotificationHandler));
-    handlers["notification"].handle("New message received");
-}

practice/src/bin/m_node.rs

@@ -1,45 +0,0 @@
-use std::cell::RefCell;
-use std::rc::{Rc, Weak};
-
-#[derive(Debug)]
-struct Node {
-    value: i32,
-    parent: RefCell<Option<Weak<Node>>>,                            // <-- weak ref to parent
-    children: RefCell<Vec<Rc<Node>>>,
-}
-
-impl Node {
-    fn new(value: i32) -> Rc<Self> {
-        Rc::new(Self {
-            value,
-            parent: Default::default(),
-            children: Default::default(),
-        })
-    }
-
-    fn set_parent(&self, parent: Rc<Node>) {
-        *self.parent.borrow_mut() = Some(Rc::downgrade(&parent));   // <-- create weak ref to parent
-    }
-
-    fn add_child(self: &Rc<Self>, child: Rc<Node>) {
-        child.set_parent(self.clone());
-        self.children.borrow_mut().push(child);
-    }
-}
-
-impl Drop for Node {
-    fn drop(&mut self) {
-        println!(
-            "Dropping node with value {} and {} children",
-            self.value,
-            self.children.borrow().len()
-        );
-    }
-}
-
-fn main() {
-    let tree = Node::new(1);
-    tree.add_child(Node::new(3));
-    tree.add_child(Node::new(5));
-    println!("Finishing program now");
-}

practice/src/main.rs

@@ -1,3 +0,0 @@
-fn main() {
-    println!("Hello, world!");
-}

smart-house/Cargo.lock

@@ -2,553 +2,6 @@
 # It is not intended for manual editing.
 version = 4
 
-[[package]]
-name = "anyhow"
-version = "1.0.102"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7f202df86484c868dbad7eaa557ef785d5c66295e41b460ef922eca0723b842c"
-
-[[package]]
-name = "bitflags"
-version = "2.11.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "843867be96c8daad0d758b57df9392b6d8d271134fce549de6ce169ff98a92af"
-
-[[package]]
-name = "bytes"
-version = "1.11.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b35204fbdc0b3f4446b89fc1ac2cf84a8a68971995d0bf2e925ec7cd960f9cb3"
-
-[[package]]
-name = "cfg-if"
-version = "1.0.4"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9330f8b2ff13f34540b44e946ef35111825727b38d33286ef986142615121801"
-
-[[package]]
-name = "chacha20"
-version = "0.10.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6f8d983286843e49675a4b7a2d174efe136dc93a18d69130dd18198a6c167601"
-dependencies = [
- "cfg-if",
- "cpufeatures",
- "rand_core",
-]
-
-[[package]]
-name = "cpufeatures"
-version = "0.3.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "8b2a41393f66f16b0823bb79094d54ac5fbd34ab292ddafb9a0456ac9f87d201"
-dependencies = [
- "libc",
-]
-
-[[package]]
-name = "equivalent"
-version = "1.0.2"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "877a4ace8713b0bcf2a4e7eec82529c029f1d0619886d18145fea96c3ffe5c0f"
-
-[[package]]
-name = "foldhash"
-version = "0.1.5"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d9c4f5dac5e15c24eb999c26181a6ca40b39fe946cbe4c263c7209467bc83af2"
-
-[[package]]
-name = "getrandom"
-version = "0.4.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "139ef39800118c7683f2fd3c98c1b23c09ae076556b435f8e9064ae108aaeeec"
-dependencies = [
- "cfg-if",
- "libc",
- "r-efi",
- "rand_core",
- "wasip2",
- "wasip3",
-]
-
-[[package]]
-name = "hashbrown"
-version = "0.15.5"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9229cfe53dfd69f0609a49f65461bd93001ea1ef889cd5529dd176593f5338a1"
-dependencies = [
- "foldhash",
-]
-
-[[package]]
-name = "hashbrown"
-version = "0.16.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "841d1cc9bed7f9236f321df977030373f4a4163ae1a7dbfe1a51a2c1a51d9100"
-
-[[package]]
-name = "heck"
-version = "0.5.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2304e00983f87ffb38b55b444b5e3b60a884b5d30c0fca7d82fe33449bbe55ea"
-
-[[package]]
-name = "id-arena"
-version = "2.3.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "3d3067d79b975e8844ca9eb072e16b31c3c1c36928edf9c6789548c524d0d954"
-
-[[package]]
-name = "indexmap"
-version = "2.13.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7714e70437a7dc3ac8eb7e6f8df75fd8eb422675fc7678aff7364301092b1017"
-dependencies = [
- "equivalent",
- "hashbrown 0.16.1",
- "serde",
- "serde_core",
-]
-
-[[package]]
-name = "itoa"
-version = "1.0.17"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "92ecc6618181def0457392ccd0ee51198e065e016d1d527a7ac1b6dc7c1f09d2"
-
-[[package]]
-name = "leb128fmt"
-version = "0.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "09edd9e8b54e49e587e4f6295a7d29c3ea94d469cb40ab8ca70b288248a81db2"
-
-[[package]]
-name = "libc"
-version = "0.2.178"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "37c93d8daa9d8a012fd8ab92f088405fb202ea0b6ab73ee2482ae66af4f42091"
-
-[[package]]
-name = "log"
-version = "0.4.29"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5e5032e24019045c762d3c0f28f5b6b8bbf38563a65908389bf7978758920897"
-
-[[package]]
-name = "memchr"
-version = "2.8.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f8ca58f447f06ed17d5fc4043ce1b10dd205e060fb3ce5b979b8ed8e59ff3f79"
-
-[[package]]
-name = "mio"
-version = "1.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "69d83b0086dc8ecf3ce9ae2874b2d1290252e2a30720bea58a5c6639b0092873"
-dependencies = [
- "libc",
- "wasi",
- "windows-sys 0.61.2",
-]
-
-[[package]]
-name = "pin-project-lite"
-version = "0.2.16"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "3b3cff922bd51709b605d9ead9aa71031d81447142d828eb4a6eba76fe619f9b"
-
-[[package]]
-name = "prettyplease"
-version = "0.2.37"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "479ca8adacdd7ce8f1fb39ce9ecccbfe93a3f1344b3d0d97f20bc0196208f62b"
-dependencies = [
- "proc-macro2",
- "syn",
-]
-
-[[package]]
-name = "proc-macro2"
-version = "1.0.106"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "8fd00f0bb2e90d81d1044c2b32617f68fcb9fa3bb7640c23e9c748e53fb30934"
-dependencies = [
- "unicode-ident",
-]
-
-[[package]]
-name = "quote"
-version = "1.0.44"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "21b2ebcf727b7760c461f091f9f0f539b77b8e87f2fd88131e7f1b433b3cece4"
-dependencies = [
- "proc-macro2",
-]
-
-[[package]]
-name = "r-efi"
-version = "5.3.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "69cdb34c158ceb288df11e18b4bd39de994f6657d83847bdffdbd7f346754b0f"
-
-[[package]]
-name = "rand"
-version = "0.10.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "bc266eb313df6c5c09c1c7b1fbe2510961e5bcd3add930c1e31f7ed9da0feff8"
-dependencies = [
- "chacha20",
- "getrandom",
- "rand_core",
-]
-
-[[package]]
-name = "rand_core"
-version = "0.10.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0c8d0fd677905edcbeedbf2edb6494d676f0e98d54d5cf9bda0b061cb8fb8aba"
-
-[[package]]
-name = "semver"
-version = "1.0.27"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d767eb0aabc880b29956c35734170f26ed551a859dbd361d140cdbeca61ab1e2"
-
-[[package]]
-name = "serde"
-version = "1.0.228"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9a8e94ea7f378bd32cbbd37198a4a91436180c5bb472411e48b5ec2e2124ae9e"
-dependencies = [
- "serde_core",
-]
-
-[[package]]
-name = "serde_core"
-version = "1.0.228"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "41d385c7d4ca58e59fc732af25c3983b67ac852c1a25000afe1175de458b67ad"
-dependencies = [
- "serde_derive",
-]
-
-[[package]]
-name = "serde_derive"
-version = "1.0.228"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d540f220d3187173da220f885ab66608367b6574e925011a9353e4badda91d79"
-dependencies = [
- "proc-macro2",
- "quote",
- "syn",
-]
-
-[[package]]
-name = "serde_json"
-version = "1.0.149"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "83fc039473c5595ace860d8c4fafa220ff474b3fc6bfdb4293327f1a37e94d86"
-dependencies = [
- "itoa",
- "memchr",
- "serde",
- "serde_core",
- "zmij",
-]
-
 [[package]]
 name = "smart-house"
 version = "0.0.0"
-dependencies = [
- "rand",
- "tokio",
-]
-
-[[package]]
-name = "socket2"
-version = "0.6.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "17129e116933cf371d018bb80ae557e889637989d8638274fb25622827b03881"
-dependencies = [
- "libc",
- "windows-sys 0.60.2",
-]
-
-[[package]]
-name = "syn"
-version = "2.0.117"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e665b8803e7b1d2a727f4023456bbbbe74da67099c585258af0ad9c5013b9b99"
-dependencies = [
- "proc-macro2",
- "quote",
- "unicode-ident",
-]
-
-[[package]]
-name = "tokio"
-version = "1.49.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "72a2903cd7736441aac9df9d7688bd0ce48edccaadf181c3b90be801e81d3d86"
-dependencies = [
- "bytes",
- "libc",
- "mio",
- "pin-project-lite",
- "socket2",
- "windows-sys 0.61.2",
-]
-
-[[package]]
-name = "unicode-ident"
-version = "1.0.24"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e6e4313cd5fcd3dad5cafa179702e2b244f760991f45397d14d4ebf38247da75"
-
-[[package]]
-name = "unicode-xid"
-version = "0.2.6"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ebc1c04c71510c7f702b52b7c350734c9ff1295c464a03335b00bb84fc54f853"
-
-[[package]]
-name = "wasi"
-version = "0.11.1+wasi-snapshot-preview1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ccf3ec651a847eb01de73ccad15eb7d99f80485de043efb2f370cd654f4ea44b"
-
-[[package]]
-name = "wasip2"
-version = "1.0.2+wasi-0.2.9"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9517f9239f02c069db75e65f174b3da828fe5f5b945c4dd26bd25d89c03ebcf5"
-dependencies = [
- "wit-bindgen",
-]
-
-[[package]]
-name = "wasip3"
-version = "0.4.0+wasi-0.3.0-rc-2026-01-06"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5428f8bf88ea5ddc08faddef2ac4a67e390b88186c703ce6dbd955e1c145aca5"
-dependencies = [
- "wit-bindgen",
-]
-
-[[package]]
-name = "wasm-encoder"
-version = "0.244.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "990065f2fe63003fe337b932cfb5e3b80e0b4d0f5ff650e6985b1048f62c8319"
-dependencies = [
- "leb128fmt",
- "wasmparser",
-]
-
-[[package]]
-name = "wasm-metadata"
-version = "0.244.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "bb0e353e6a2fbdc176932bbaab493762eb1255a7900fe0fea1a2f96c296cc909"
-dependencies = [
- "anyhow",
- "indexmap",
- "wasm-encoder",
- "wasmparser",
-]
-
-[[package]]
-name = "wasmparser"
-version = "0.244.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "47b807c72e1bac69382b3a6fb3dbe8ea4c0ed87ff5629b8685ae6b9a611028fe"
-dependencies = [
- "bitflags",
- "hashbrown 0.15.5",
- "indexmap",
- "semver",
-]
-
-[[package]]
-name = "windows-link"
-version = "0.2.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f0805222e57f7521d6a62e36fa9163bc891acd422f971defe97d64e70d0a4fe5"
-
-[[package]]
-name = "windows-sys"
-version = "0.60.2"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f2f500e4d28234f72040990ec9d39e3a6b950f9f22d3dba18416c35882612bcb"
-dependencies = [
- "windows-targets",
-]
-
-[[package]]
-name = "windows-sys"
-version = "0.61.2"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ae137229bcbd6cdf0f7b80a31df61766145077ddf49416a728b02cb3921ff3fc"
-dependencies = [
- "windows-link",
-]
-
-[[package]]
-name = "windows-targets"
-version = "0.53.5"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4945f9f551b88e0d65f3db0bc25c33b8acea4d9e41163edf90dcd0b19f9069f3"
-dependencies = [
- "windows-link",
- "windows_aarch64_gnullvm",
- "windows_aarch64_msvc",
- "windows_i686_gnu",
- "windows_i686_gnullvm",
- "windows_i686_msvc",
- "windows_x86_64_gnu",
- "windows_x86_64_gnullvm",
- "windows_x86_64_msvc",
-]
-
-[[package]]
-name = "windows_aarch64_gnullvm"
-version = "0.53.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a9d8416fa8b42f5c947f8482c43e7d89e73a173cead56d044f6a56104a6d1b53"
-
-[[package]]
-name = "windows_aarch64_msvc"
-version = "0.53.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b9d782e804c2f632e395708e99a94275910eb9100b2114651e04744e9b125006"
-
-[[package]]
-name = "windows_i686_gnu"
-version = "0.53.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "960e6da069d81e09becb0ca57a65220ddff016ff2d6af6a223cf372a506593a3"
-
-[[package]]
-name = "windows_i686_gnullvm"
-version = "0.53.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "fa7359d10048f68ab8b09fa71c3daccfb0e9b559aed648a8f95469c27057180c"
-
-[[package]]
-name = "windows_i686_msvc"
-version = "0.53.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1e7ac75179f18232fe9c285163565a57ef8d3c89254a30685b57d83a38d326c2"
-
-[[package]]
-name = "windows_x86_64_gnu"
-version = "0.53.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9c3842cdd74a865a8066ab39c8a7a473c0778a3f29370b5fd6b4b9aa7df4a499"
-
-[[package]]
-name = "windows_x86_64_gnullvm"
-version = "0.53.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0ffa179e2d07eee8ad8f57493436566c7cc30ac536a3379fdf008f47f6bb7ae1"
-
-[[package]]
-name = "windows_x86_64_msvc"
-version = "0.53.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d6bbff5f0aada427a1e5a6da5f1f98158182f26556f345ac9e04d36d0ebed650"
-
-[[package]]
-name = "wit-bindgen"
-version = "0.51.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d7249219f66ced02969388cf2bb044a09756a083d0fab1e566056b04d9fbcaa5"
-dependencies = [
- "wit-bindgen-rust-macro",
-]
-
-[[package]]
-name = "wit-bindgen-core"
-version = "0.51.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ea61de684c3ea68cb082b7a88508a8b27fcc8b797d738bfc99a82facf1d752dc"
-dependencies = [
- "anyhow",
- "heck",
- "wit-parser",
-]
-
-[[package]]
-name = "wit-bindgen-rust"
-version = "0.51.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b7c566e0f4b284dd6561c786d9cb0142da491f46a9fbed79ea69cdad5db17f21"
-dependencies = [
- "anyhow",
- "heck",
- "indexmap",
- "prettyplease",
- "syn",
- "wasm-metadata",
- "wit-bindgen-core",
- "wit-component",
-]
-
-[[package]]
-name = "wit-bindgen-rust-macro"
-version = "0.51.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0c0f9bfd77e6a48eccf51359e3ae77140a7f50b1e2ebfe62422d8afdaffab17a"
-dependencies = [
- "anyhow",
- "prettyplease",
- "proc-macro2",
- "quote",
- "syn",
- "wit-bindgen-core",
- "wit-bindgen-rust",
-]
-
-[[package]]
-name = "wit-component"
-version = "0.244.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9d66ea20e9553b30172b5e831994e35fbde2d165325bec84fc43dbf6f4eb9cb2"
-dependencies = [
- "anyhow",
- "bitflags",
- "indexmap",
- "log",
- "serde",
- "serde_derive",
- "serde_json",
- "wasm-encoder",
- "wasm-metadata",
- "wasmparser",
- "wit-parser",
-]
-
-[[package]]
-name = "wit-parser"
-version = "0.244.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ecc8ac4bc1dc3381b7f59c34f00b67e18f910c2c0f50015669dde7def656a736"
-dependencies = [
- "anyhow",
- "id-arena",
- "indexmap",
- "log",
- "semver",
- "serde",
- "serde_derive",
- "serde_json",
- "unicode-xid",
- "wasmparser",
-]
-
-[[package]]
-name = "zmij"
-version = "1.0.21"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b8848ee67ecc8aedbaf3e4122217aff892639231befc6a1b58d29fff4c2cabaa"

smart-house/Cargo.toml

@@ -4,5 +4,3 @@ name = "smart-house"
 version = "0.0.0"
 
 [dependencies]
-tokio = { version = "1.49.0", features = ["rt", "net", "io-util", "time"] }
-rand = { version = "0.10.0", features = ["std"] }

smart-house/README.md

@@ -35,122 +35,23 @@
     - [x] Можно получить ссылку на устройство по указанному индексу.
     - [x] Можно получить мутабельную ссылку на устройство по указанному индексу.
     - [x] Выводить в стандартный вывод отчёт о всех устройствах в комнате.
-- [x] Опишите тип: умный дом, содержащий массив комнат. Тип должен предоставлять следующий функционал:
+- [ ] Опишите тип: умный дом, содержащий массив комнат. Тип должен предоставлять следующий функционал:
-    - [x] Конструктор, принимающий массив комнат.
+    - [ ] Конструктор, принимающий массив комнат.
-    - [x] Можно получить ссылку на комнату по указанному индексу.
+    - [ ] Можно получить ссылку на комнату по указанному индексу.
-    - [x] Можно получить мутабельную ссылку на комнату по указанному индексу.
+    - [ ] Можно получить мутабельную ссылку на комнату по указанному индексу.
-    - [x] Выводить в стандартный вывод отчёт о всех комнатах.
+    - [ ] Выводить в стандартный вывод отчёт о всех комнатах.
 - Размеры массивов можно выбрать произвольно.
 - В случае, если указан индекс, выходящий за пределы массива, приложение должно аварийно завершаться (макрос `panic!()`).
 
 Для примера использования:
 
-- [x] Реализована в виде bin крейта.
+- [ ] Реализована в виде bin крейта.
-- [x] Создайте экземпляр умного дома и выведете отчёт о его содержимом.
+- [ ] Создайте экземпляр умного дома и выведете отчёт о его содержимом.
-- [x] Для уже созданного экземпляра дома выключите умную розетку в одной из комнат. Снова выведите отчёт.
+- [ ] Для уже созданного экземпляра дома выключите умную розетку в одной из комнат. Снова выведите отчёт.
 
-**Критерии оценки:**
+**Критерии оценки**:
 
 - Package успешно собирается.
 - Приложение-пример успешно выполняется и выводит отчёт о доме.
 - Команды cargo clippy и cargo fmt --check не выводят ошибок и предупреждений.
 - Присутствуют и успешно выполняются модульные тесты.
-
-## ДЗ 2026-01-20
-
-Дорабатываем умный дом
-
-### Цель:
-
-Дорабатываем функционал умного дома, используя возможности стандартной библиотеки.
-
-### Срок:
-
-Сдать до: **2026-02-11**
-
-### Описание/Пошаговая инструкция выполнения домашнего задания:
-
-Добавить обработку ошибок:
-- [x] Заменить паники на возврат Option в методах получения комнаты по ключу.
-- [x] Заменить паники на возврат Option в методах получения устройства по ключу.
-
-Доработать хранение объектов:
-- [x] Заменить массивы устройств и комнат на ассоциативные коллекции из std. В качестве ключей использовать строки.
-- [x] Реализовать трейт Debug на всех типах.
-- [x] Добавить возможность динамически добавлять/удалять устройства в комнату.
-- [x] Добавить возможность динамически добавлять/удалять комнату в дом.
-- [x] Добавить в тип умного дома метод, позволяющий сразу получить ссылку на умное устройство. Метод принимает имя комнаты
-      и имя устройства. В случае, если устройство или комната не найдены, возвращать тип ошибки, сообщающий, что именно
-      произошло. Тип ошибки должен реализовывать трейт `std::error::Error`.
-- [x] Добавить реализации трейта `From`, позволяющие преобразовывать объекты умной розетки и умного термометра в объект
-      умного устройства.
-- [x] Написать макрос для упрощенного создания комнаты, принимающий пары вида (ключ, объект умной розетки) или (ключ,
-      объект умного термометра) и возвращающий объект комнаты, содержащей все перечисленные устройства с
-      соответствующими ключами.
-
-Доработать формирование отчёта:
-- [x] Вынести метод формирования отчёта в трейт и реализовать его на всех типах, которые возвращают отчёт: умное устройство,
-      комната, дом.
-
-Привести тесты в соответствие с новым функционалом.
-
-Доработать приложение-пример:
-- [x] Продемонстрировать возможность динамического добавления/удаления комнат.
-- [x] Продемонстрировать возможность динамического добавления/удаления устройств.
-- [x] Добавить функцию, которая принимает любой объект, умеющий выводить отчёт. Вывести с её помощью отчёты о доме,
-      отдельной комнате, отдельном устройстве.
-- [x] Продемонстрировать возможность обработки ошибок.
-
-**Критерии оценки:**
-- Package успешно собирается.
-- Приложение-пример успешно выполняется и выводит отчёт о доме.
-- Команды cargo clippy и cargo fmt --check не выводят ошибок и предупреждений.
-- Присутствуют и успешно выполняются модульные тесты.
-
-## ДЗ 2026-02-12
-
-Дорабатываем умные устройства
-
-### Цель:
-
-Описать для умной розетки и умного термометра логику взаимодействия с удалённым устройством и написать имитаторы устройств для тестирования.
-
-### Срок:
-
-Сдать до: **2026-03-04**
-
-### Описание/Пошаговая инструкция выполнения домашнего задания:
-
-Для типа умной розетки:
-- [x] Функционал не изменяется: включение/выключение + запрос мощности.
-- [x] Взаимодействие организовано синхронно, через TCP.
-- [x] Розетка может использовать как реальный TCP-обмен, так и имитировать реальную работу (для тестов).
-
-Для имитатора умной розетки:
-- [x] Читает адрес для приёма TCP-соединений из аргументов командной строки.
-- [x] Реализован с использованием неблокирующего сетевого взаимодействия.
-- [x] Хранит состояние розетки.
-- [x] Позволяет управлять розеткой множеству клиентов одновременно.
-
-Для умного термометра:
-- [x] Функционал не изменяется: возвращает температуру.
-- [x] Получает значения температуры в виде UDP-пакетов в параллельном потоке.
-- [x] Параллельный поток запускается при создании объекта термометра и завершается при уничтожении этого объекта.
-- [x] Объект термометра возвращает последнее полученное значение температуры.
-- [x] Термометр может имитировать удалённое получение данных о температуре (для тестов).
-
-Для имитатора умного термометра:
-- [x] Реализован с использованием неблокирующего сетевого взаимодействия.
-- [x] Читает адрес для отправки UDP-пакетов и временной период отправки из файла.
-- [x] Отправляет произвольное значение температуры на указанный адрес с указанной периодичностью.
-
-Добавлен дополнительный пример умного дома с розетками и термометрами, которые работают с имитаторами. Данный пример должен запускаться и:
-- [x] Выводить отчёт о состоянии дома, если имитаторы запущены.
-- [x] Сообщать об ошибке, если устройству не удалось получить данные.
-
-**Критерии оценки:**
-
-- Package успешно собирается.
-- Приложение-пример успешно выполняется.
-- Команды cargo clippy и cargo fmt --check не выводят ошибок и предупреждений.
-- Присутствуют и успешно выполняются модульные тесты.

smart-house/src/bin/mocks_example.rs

@@ -1,25 +0,0 @@
-//! Пример работы умного дома с имитаторами
-
-use smart_house::{House, PowerSocket, PrintStatus, Room, Thermometer, room};
-
-fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let house = create_house_demo()?;
-    house.print_status();
-    Ok(())
-}
-
-fn create_house_demo() -> Result<House, Box<dyn std::error::Error>> {
-    println!("# Create new smart house");
-    let house = House::new(
-        [(
-            "Main".to_string(),
-            room!(
-                "PSocA" => PowerSocket::connect("127.0.0.1:10001")?,
-                "ThermA" => Thermometer::connect("127.0.0.1:10002")?,
-            ),
-        )]
-        .into_iter()
-        .collect(),
-    );
-    Ok(house)
-}

smart-house/src/bin/power_socket_client.rs

@@ -1,19 +0,0 @@
-//! Пример подключения нескольких клиентов к розетке. Изменение состояния любым из клиентов отражается на всех.
-
-use smart_house::PowerSocket;
-use std::time::Duration;
-
-fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let power_socket0 = PowerSocket::connect("127.0.0.1:10001")?;
-    let mut power_socket = PowerSocket::connect("127.0.0.1:10001")?;
-    println!("{}", power_socket0.display());
-    println!("{}", power_socket.display());
-
-    std::thread::sleep(Duration::from_secs(2));
-    power_socket.set_on(!power_socket.is_on());
-
-    println!("{}", power_socket0.display());
-    println!("{}", power_socket.display());
-
-    Ok(())
-}

smart-house/src/bin/power_socket_mock.rs

@@ -1,88 +0,0 @@
-//! Сервер-имитатор умной розетки
-
-use std::net::SocketAddr;
-use std::sync::{Arc, RwLock};
-use std::time::Duration;
-use tokio::io::{AsyncReadExt, AsyncWriteExt};
-
-fn parse_args() -> Result<SocketAddr, Box<dyn std::error::Error>> {
-    let mut args = std::env::args();
-    args.next();
-    Ok(args.next().ok_or(std::io::Error::other("no server address parameter specified"))?.parse()?)
-}
-
-struct RealPowerSocket {
-    power_rate: f32,
-    on: bool,
-}
-
-const CMD_GET_ON: u8 = 1;
-const CMD_TURN_ON: u8 = 2;
-const CMD_TURN_OFF: u8 = 3;
-const CMD_GET_POWER: u8 = 4;
-
-const TIMEOUT: Duration = Duration::from_secs(5);
-
-async fn handle_connection(mut socket: tokio::net::TcpStream, real_power_socket: Arc<RwLock<RealPowerSocket>>) -> Result<(), std::io::Error> {
-    let mut buf = [0u8; 1];
-    loop {
-        let read = tokio::time::timeout(TIMEOUT, socket.read(&mut buf)).await??;
-        if read == 0 {
-            println!("connection closed");
-            return Ok(());
-        }
-        match buf {
-            [CMD_GET_ON] => {
-                println!("handling CMD_GET_ON");
-                {
-                    let power_socket = real_power_socket.try_read().map_err(|_| std::io::Error::other("read lock failed"))?;
-                    buf = if power_socket.on { [1u8; 1] } else { [0u8; 1] };
-                }
-                let _ = tokio::time::timeout(TIMEOUT, socket.write(&buf)).await?;
-            }
-            [CMD_TURN_ON] => {
-                println!("handling CMD_TURN_ON");
-                {
-                    let mut power_socket = real_power_socket.try_write().map_err(|_| std::io::Error::other("write lock failed"))?;
-                    power_socket.on = true;
-                }
-                let _ = tokio::time::timeout(TIMEOUT, socket.write(&buf)).await?;
-            }
-            [CMD_TURN_OFF] => {
-                println!("handling CMD_TURN_OFF");
-                {
-                    let mut power_socket = real_power_socket.try_write().map_err(|_| std::io::Error::other("write lock failed"))?;
-                    power_socket.on = false;
-                }
-                let _ = tokio::time::timeout(TIMEOUT, socket.write(&buf)).await?;
-            }
-            [CMD_GET_POWER] => {
-                println!("handling CMD_GET_POWER");
-                let data_buf: [u8; 4];
-                {
-                    let power_socket = real_power_socket.try_read().map_err(|_| std::io::Error::other("read lock failed"))?;
-                    data_buf = power_socket.power_rate.to_le_bytes();
-                }
-                let _ = tokio::time::timeout(TIMEOUT, socket.write(&data_buf)).await?;
-            }
-            _ => {
-                println!("unknown command {} - ignore it", buf[0]);
-            }
-        }
-    }
-}
-
-fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let real_power_socket = Arc::new(RwLock::new(RealPowerSocket { power_rate: 12.0, on: false }));
-    let rt = tokio::runtime::Builder::new_current_thread().enable_all().build()?;
-    rt.block_on(async {
-        let listener = tokio::net::TcpListener::bind(parse_args()?).await?;
-
-        loop {
-            let (socket, _) = listener.accept().await?;
-            println!("new connection");
-            let real_power_socket = real_power_socket.clone();
-            tokio::spawn(async move { handle_connection(socket, real_power_socket).await });
-        }
-    })
-}

smart-house/src/bin/stubs_example.rs

@@ -1,147 +0,0 @@
-//! Старый пример работы умного дома на заглушках
-
-use smart_house::{Device, House, PowerSocket, PrintStatus, Room, Thermometer, room};
-
-fn main() {
-    let mut house = create_house_demo();
-
-    switch_off_power_socket_in_hall_demo(&mut house);
-
-    add_new_room_in_house_demo(&mut house);
-
-    add_power_socket_to_closet_room_demo(&mut house);
-
-    remove_thermometer_from_closet_room_demo(&mut house);
-
-    remove_closet_room_demo(&mut house);
-
-    searching_devices_in_house_demo(&house);
-
-    universal_printing_function_demo(&house);
-}
-
-fn create_house_demo() -> House {
-    println!("# Create new smart house");
-    let house = House::new(
-        [
-            (
-                "Hall".to_string(),
-                room!(
-                    "PSocA" => PowerSocket::stub(9.5, true),
-                    "ThermA" => Thermometer::stub(20.1),
-                ),
-            ),
-            (
-                "Main".to_string(),
-                room!(
-                    "PSocB" => PowerSocket::stub(11.2, true),
-                    "ThermB" => Thermometer::stub(24.5),
-                    "PSocC" => PowerSocket::stub(10.4, true),
-                ),
-            ),
-            (
-                "Bedroom".to_string(),
-                room!(
-                    "ThermC" => Thermometer::stub(19.3),
-                    "PSocD" => PowerSocket::stub(12.1, true),
-                ),
-            ),
-        ]
-        .into_iter()
-        .collect(),
-    );
-    house.print_status();
-    house
-}
-
-fn switch_off_power_socket_in_hall_demo(house: &mut House) {
-    print!("# Switching off a power socket in Hall... ");
-    let Device::PowerSocket(power_socket) = house.get_room_mut("Hall").unwrap().get_device_mut("PSocA").unwrap() else {
-        println!("FAILED!");
-        return;
-    };
-    power_socket.set_on(false);
-    println!("SUCCESS");
-    house.print_status();
-}
-
-fn add_new_room_in_house_demo(house: &mut House) {
-    println!("# Add new room into house");
-    house.insert_room(
-        "Closet",
-        room!(
-            "ThermD" => Thermometer::stub(9.5)
-        ),
-    );
-    house.print_status();
-}
-
-fn add_power_socket_to_closet_room_demo(house: &mut House) {
-    println!("# Add power socket to 'Closet' room");
-    house
-        .get_room_mut("Closet")
-        .unwrap()
-        .insert_device("PSocE", PowerSocket::stub(8.0, true).into());
-    house.print_status();
-}
-
-fn remove_thermometer_from_closet_room_demo(house: &mut House) {
-    print!("# Removing thermometer from 'Closet' room... ");
-    let Some(_) = house.get_room_mut("Closet").unwrap().remove_device("ThermD") else {
-        println!("FAILED!");
-        return;
-    };
-    println!("SUCCESS");
-    house.print_status();
-}
-
-fn remove_closet_room_demo(house: &mut House) {
-    print!("# Removing 'Closet' room... ");
-    let Some(_) = house.remove_room("Closet") else {
-        println!("FAILED!");
-        return;
-    };
-    println!("SUCCESS");
-    house.print_status();
-}
-
-fn searching_devices_in_house_demo(house: &House) {
-    println!("# Searching dummy device in empty room");
-    find_device_handling_errors_demo(house, "empty", "dummy");
-
-    println!("# Searching dummy device in Bedroom");
-    find_device_handling_errors_demo(house, "Bedroom", "dummy");
-
-    println!("# Searching ThermA device in Hall room");
-    find_device_handling_errors_demo(house, "Hall", "ThermA");
-
-    println!();
-}
-
-fn find_device_handling_errors_demo(house: &House, room: &str, device: &str) {
-    match house.get_device(room, device) {
-        Err(error) => {
-            println!("FAIL. Error: {:?}", error);
-        }
-        Ok(device) => {
-            print!("SUCCESS. Device found: ");
-            device.print_status();
-        }
-    }
-}
-
-fn universal_printing_function_demo(house: &House) {
-    println!("# Print house using universal function");
-    print_status(house);
-
-    println!("# Print Main room using universal function");
-    print_status(house.get_room("Main").unwrap());
-
-    println!();
-    println!("# Print PSocC device from Main room using universal function");
-    print_status(house.get_device("Main", "PSocC").unwrap());
-}
-
-fn print_status(printable: &impl PrintStatus) {
-    printable.print_status();
-}

smart-house/src/bin/thermometer_mock.rs

@@ -1,53 +0,0 @@
-//! Имитатор термометра
-
-use rand::prelude::*;
-use std::io::Read;
-use std::net::{IpAddr, SocketAddr};
-use std::str::FromStr;
-use std::sync::Arc;
-use std::time::Duration;
-
-struct Params {
-    addr: SocketAddr,
-    interval: Duration,
-}
-
-const CONFIG_FILE: &str = "thermometer_mock.cfg";
-
-fn read_parameters_from_file() -> Result<Params, std::io::Error> {
-    let mut file = std::fs::File::open(CONFIG_FILE)?;
-    let mut content = String::new();
-    file.read_to_string(&mut content)?;
-    let lines = content.split("\n").collect::<Vec<&str>>();
-    let addr = lines
-        .first()
-        .map(|v| SocketAddr::from_str(v))
-        .ok_or(std::io::Error::other("no address found in config file"))?
-        .map_err(std::io::Error::other)?;
-    let interval = lines
-        .get(1)
-        .map(|v| v.parse::<u64>())
-        .ok_or(std::io::Error::other("no interval found in config file"))?
-        .map(Duration::from_millis)
-        .map_err(std::io::Error::other)?;
-    Ok(Params { addr, interval })
-}
-
-fn generate_temperature() -> f32 {
-    rand::rng().random_range(18.0..23.0)
-}
-
-fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let params = read_parameters_from_file()?;
-    let rt = tokio::runtime::Builder::new_current_thread().enable_all().build()?;
-    rt.block_on(async move {
-        let socket = Arc::new(tokio::net::UdpSocket::bind(SocketAddr::new(IpAddr::from([127, 0, 0, 1]), 10003)).await?);
-        let mut interval = tokio::time::interval(params.interval);
-        loop {
-            interval.tick().await;
-            let new_temperature = generate_temperature();
-            let data = new_temperature.to_le_bytes();
-            socket.send_to(&data, &params.addr).await?;
-        }
-    })
-}

smart-house/src/device.rs

@@ -1,71 +1,14 @@
-use crate::PrintStatus;
+#![allow(unused)]
-use std::fmt::Display;
 
-#[derive(Debug)]
+mod power_socket;
-pub enum Device {
+mod thermometer;
-    Thermometer(super::Thermometer),
+
-    PowerSocket(super::PowerSocket),
+pub trait Device {
+    fn print_status(&self);
+    fn as_any(&self) -> &dyn Any;
+    fn as_mut_any(&mut self) -> &mut dyn Any;
 }
 
-impl Device {
+pub use power_socket::PowerSocket;
-    pub fn display(&self) -> impl Display {
+use std::any::Any;
-        match self {
+pub use thermometer::Thermometer;
-            Device::Thermometer(thermometer) => {
-                format!("DEV:{}", thermometer.display())
-            }
-            Device::PowerSocket(power_socket) => {
-                format!("DEV:{}", power_socket.display())
-            }
-        }
-    }
-}
-
-impl From<super::Thermometer> for Device {
-    fn from(value: super::Thermometer) -> Self {
-        Device::Thermometer(value)
-    }
-}
-
-impl From<super::PowerSocket> for Device {
-    fn from(value: super::PowerSocket) -> Self {
-        Device::PowerSocket(value)
-    }
-}
-
-impl PrintStatus for Device {
-    fn print_status(&self) {
-        println!("{}", self.display());
-    }
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-    use crate::{PowerSocket, Thermometer};
-
-    #[test]
-    fn smoke_test() {
-        let dev_thermometer = Device::Thermometer(Thermometer::stub(20.1));
-        let dev_power_socket = Device::PowerSocket(PowerSocket::stub(11.2, false));
-
-        dev_thermometer.print_status();
-        dev_power_socket.print_status();
-
-        let Device::Thermometer(thermometer) = dev_thermometer else { unreachable!() };
-        let Device::PowerSocket(power_socket) = dev_power_socket else {
-            unreachable!()
-        };
-
-        assert_eq!(format!("{}", thermometer.display()), "Thermometer[ 20.1 ]");
-        assert_eq!(format!("{}", power_socket.display()), "PowerSocket[ OFF : 0.0 ]");
-    }
-
-    #[test]
-    fn display_test() {
-        let dev_thermometer = Device::Thermometer(Thermometer::stub(20.1));
-        let dev_power_socket = Device::PowerSocket(PowerSocket::stub(11.2, false));
-
-        assert_eq!(format!("{}", dev_thermometer.display()), "DEV:Thermometer[ 20.1 ]");
-        assert_eq!(format!("{}", dev_power_socket.display()), "DEV:PowerSocket[ OFF : 0.0 ]");
-    }
-}

smart-house/src/device/power_socket.rs

@@ -0,0 +1,72 @@
+#![allow(unused)]
+
+use crate::device::Device;
+use std::any::Any;
+use std::fmt::Display;
+
+pub struct PowerSocket {
+    power_rate: f32,
+    on: bool,
+}
+
+impl PowerSocket {
+    pub fn new(power_rate: f32, on: bool) -> Self {
+        Self { power_rate, on }
+    }
+
+    pub fn is_on(&self) -> bool {
+        self.on
+    }
+
+    pub fn set_on(&mut self, on: bool) {
+        self.on = on
+    }
+
+    pub fn get_power(&self) -> f32 {
+        if self.on { self.power_rate } else { 0.0 }
+    }
+
+    pub fn display(&self) -> impl Display {
+        let state = if self.is_on() { "ON" } else { "OFF" };
+        format!("PowerSocket[ {} : {:02.1} ]", state, self.get_power())
+    }
+}
+
+impl Device for PowerSocket {
+    fn print_status(&self) {
+        println!("{}", self.display())
+    }
+
+    fn as_any(&self) -> &dyn Any {
+        self
+    }
+
+    fn as_mut_any(&mut self) -> &mut dyn Any {
+        self
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn smoke_test() {
+        let mut power_socket = PowerSocket::new(12.4, false);
+        assert_eq!(power_socket.power_rate, 12.4);
+        assert!(!power_socket.on);
+        assert!(!power_socket.is_on());
+        assert_eq!(power_socket.get_power(), 0.0);
+
+        power_socket.set_on(true);
+        assert!(power_socket.is_on());
+        assert_eq!(power_socket.get_power(), 12.4);
+    }
+
+    #[test]
+    fn display_test() {
+        assert_eq!(format!("{}", PowerSocket::new(11.549, false).display()), "PowerSocket[ OFF : 0.0 ]");
+        assert_eq!(format!("{}", PowerSocket::new(11.549, true).display()), "PowerSocket[ ON : 11.5 ]");
+        assert_eq!(format!("{}", PowerSocket::new(11.550, true).display()), "PowerSocket[ ON : 11.6 ]");
+    }
+}

smart-house/src/device/thermometer.rs

@@ -0,0 +1,54 @@
+#![allow(unused)]
+
+use std::any::Any;
+use std::fmt::Display;
+
+pub struct Thermometer {
+    temperature: f32,
+}
+
+impl Thermometer {
+    pub fn new(temperature: f32) -> Self {
+        Self { temperature }
+    }
+
+    pub fn get_temperature(&self) -> f32 {
+        self.temperature
+    }
+
+    pub fn display(&self) -> impl Display {
+        format!("Thermometer[ {:02.1} ]", self.get_temperature())
+    }
+}
+
+impl super::Device for Thermometer {
+    fn print_status(&self) {
+        println!("{}", self.display())
+    }
+
+    fn as_any(&self) -> &dyn Any {
+        self
+    }
+
+    fn as_mut_any(&mut self) -> &mut dyn Any {
+        self
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn smoke_test() {
+        let thermometer = Thermometer::new(20.0);
+        assert_eq!(thermometer.temperature, 20.0);
+        assert_eq!(thermometer.get_temperature(), 20.0);
+    }
+
+    #[test]
+    fn display_test() {
+        assert_eq!(format!("{}", Thermometer::new(19.550).display()), "Thermometer[ 19.5 ]");
+        assert_eq!(format!("{}", Thermometer::new(19.551).display()), "Thermometer[ 19.6 ]");
+    }
+}

smart-house/src/error.rs

@@ -1,23 +0,0 @@
-use std::fmt::{Display, Formatter};
-
-#[derive(Debug)]
-pub struct Error {
-    message: String,
-}
-
-impl Error {
-    pub fn new(message: impl AsRef<str>) -> Self {
-        Self {
-            message: message.as_ref().to_string(),
-        }
-    }
-}
-
-impl Display for Error {
-    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
-        f.write_fmt(format_args!("{}", self.message))?;
-        Ok(())
-    }
-}
-
-impl std::error::Error for Error {}

smart-house/src/house.rs

@@ -1,151 +1 @@
-use crate::{Device, Error, PrintStatus, Room};
-use std::collections::HashMap;
 
-#[derive(Debug)]
-pub struct House {
-    rooms: HashMap<String, Room>,
-}
-
-impl House {
-    pub fn new(rooms: HashMap<String, Room>) -> Self {
-        Self { rooms }
-    }
-
-    pub fn get_room(&self, key: &str) -> Option<&Room> {
-        self.rooms.get(key)
-    }
-
-    pub fn get_room_mut(&mut self, key: &str) -> Option<&mut Room> {
-        self.rooms.get_mut(key)
-    }
-
-    pub fn insert_room(&mut self, name: &str, room: Room) -> Option<Room> {
-        self.rooms.insert(name.to_string(), room)
-    }
-
-    pub fn remove_room(&mut self, key: &str) -> Option<Room> {
-        self.rooms.remove(key)
-    }
-
-    pub fn get_device(&self, room_name: &str, device_name: &str) -> Result<&Device, Error> {
-        let Some(room) = self.get_room(room_name) else {
-            return Err(Error::new(format!("no room named '{}' found", room_name)));
-        };
-        let Some(device) = room.get_device(device_name) else {
-            return Err(Error::new(format!("no device named '{}' found in room '{}'", device_name, room_name)));
-        };
-        Ok(device)
-    }
-}
-
-impl PrintStatus for House {
-    fn print_status(&self) {
-        for (room_name, room) in self.rooms.iter() {
-            println!("{}:", room_name);
-            println!("{}", "-".repeat(32));
-            room.print_status();
-            println!();
-        }
-    }
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-    use crate::{Device, PowerSocket, Thermometer};
-
-    fn create_test_house() -> House {
-        House::new(
-            [
-                (
-                    "main".to_string(),
-                    Room::new(
-                        [
-                            ("ThermA".to_string(), Thermometer::stub(20.0).into()),
-                            ("PSocA".to_string(), PowerSocket::stub(12.34, false).into()),
-                            ("PSocB".to_string(), PowerSocket::stub(10.01, true).into()),
-                        ]
-                        .into_iter()
-                        .collect(),
-                    ),
-                ),
-                (
-                    "bedroom".to_string(),
-                    Room::new(
-                        [
-                            ("PSocC".to_string(), PowerSocket::stub(11.11, true).into()),
-                            ("ThermB".to_string(), Thermometer::stub(17.99).into()),
-                        ]
-                        .into_iter()
-                        .collect(),
-                    ),
-                ),
-            ]
-            .into_iter()
-            .collect(),
-        )
-    }
-
-    #[test]
-    fn smoke_test() {
-        let mut house = create_test_house();
-        assert_eq!(house.rooms.len(), 2);
-        house.print_status();
-
-        assert_eq!(
-            format!("{}", house.get_room("main").unwrap().get_device("ThermA").unwrap().display()),
-            "DEV:Thermometer[ 20.0 ]"
-        );
-        assert_eq!(
-            format!("{}", house.get_room("main").unwrap().get_device("PSocA").unwrap().display()),
-            "DEV:PowerSocket[ OFF : 0.0 ]"
-        );
-        assert_eq!(
-            format!("{}", house.get_room("bedroom").unwrap().get_device("PSocC").unwrap().display()),
-            "DEV:PowerSocket[ ON : 11.1 ]"
-        );
-
-        let Device::PowerSocket(powers_socket) = house.get_room_mut("main").unwrap().get_device_mut("PSocA").unwrap() else {
-            unreachable!()
-        };
-        powers_socket.set_on(true);
-
-        assert_eq!(
-            format!("{}", house.get_room("main").unwrap().get_device("PSocA").unwrap().display()),
-            "DEV:PowerSocket[ ON : 12.3 ]"
-        );
-    }
-
-    #[test]
-    fn check_out_of_bounds() {
-        let house = create_test_house();
-        assert!(house.get_room("absent").is_none());
-    }
-
-    #[test]
-    fn test_add_remove() {
-        let mut house = create_test_house();
-        let room = Room::new(HashMap::new());
-
-        let result = house.insert_room("empty", room);
-        assert!(result.is_none());
-        assert_eq!(house.rooms.len(), 3);
-
-        let Some(result) = house.remove_room("bedroom") else { unreachable!() };
-        assert_eq!(result.get_device("ThermB").unwrap().display().to_string(), "DEV:Thermometer[ 18.0 ]");
-    }
-
-    #[test]
-    fn test_get_device() {
-        let house = create_test_house();
-
-        let result = house.get_device("empty", "dummy");
-        assert_eq!(result.unwrap_err().to_string(), "no room named 'empty' found");
-
-        let result = house.get_device("main", "dummy");
-        assert_eq!(result.unwrap_err().to_string(), "no device named 'dummy' found in room 'main'");
-
-        let result = house.get_device("main", "ThermA");
-        assert_eq!(result.unwrap().display().to_string(), "DEV:Thermometer[ 20.0 ]");
-    }
-}

smart-house/src/lib.rs

@@ -1,16 +1,3 @@
 mod device;
-mod error;
 mod house;
-mod power_socket;
-#[macro_use]
 mod room;
-mod print_status;
-mod thermometer;
-
-pub use device::Device;
-pub use error::Error;
-pub use house::House;
-pub use power_socket::PowerSocket;
-pub use print_status::PrintStatus;
-pub use room::Room;
-pub use thermometer::Thermometer;

smart-house/src/power_socket.rs

@@ -1,146 +0,0 @@
-use std::cell::RefCell;
-use std::fmt::{Debug, Display};
-use std::io;
-use std::io::{Read, Write};
-use std::net::{SocketAddr, TcpStream};
-use std::time::Duration;
-
-#[derive(Debug)]
-pub struct PowerSocket {
-    handle: Box<dyn PowerSocketHandle>,
-}
-
-impl PowerSocket {
-    pub fn stub(power_rate: f32, on: bool) -> Self {
-        Self {
-            handle: Box::new(PowerSocketStub::new(power_rate, on)),
-        }
-    }
-
-    pub fn connect(addr: &str) -> Result<Self, io::Error> {
-        let handle = PowerSocketClient::new(addr)?;
-        Ok(Self { handle: Box::new(handle) })
-    }
-
-    pub fn is_on(&self) -> bool {
-        self.handle.is_on()
-    }
-
-    pub fn set_on(&mut self, on: bool) {
-        self.handle.set_on(on)
-    }
-
-    pub fn get_power(&self) -> f32 {
-        self.handle.get_power()
-    }
-
-    pub fn display(&self) -> impl Display {
-        let state = if self.is_on() { "ON" } else { "OFF" };
-        format!("PowerSocket[ {} : {:02.1} ]", state, self.get_power())
-    }
-}
-
-trait PowerSocketHandle: Debug {
-    fn is_on(&self) -> bool;
-
-    fn set_on(&mut self, on: bool);
-
-    fn get_power(&self) -> f32;
-}
-
-#[derive(Debug)]
-struct PowerSocketStub {
-    power_rate: f32,
-    on: bool,
-}
-
-impl PowerSocketStub {
-    pub fn new(power_rate: f32, on: bool) -> Self {
-        Self { power_rate, on }
-    }
-}
-
-impl PowerSocketHandle for PowerSocketStub {
-    fn is_on(&self) -> bool {
-        self.on
-    }
-
-    fn set_on(&mut self, on: bool) {
-        self.on = on
-    }
-
-    fn get_power(&self) -> f32 {
-        if self.on { self.power_rate } else { 0.0 }
-    }
-}
-
-const TIMEOUT: Duration = Duration::from_secs(5);
-
-#[derive(Debug)]
-struct PowerSocketClient {
-    stream: RefCell<TcpStream>,
-}
-
-impl PowerSocketClient {
-    fn new(addr: &str) -> Result<Self, io::Error> {
-        let addr: SocketAddr = addr.parse().map_err(io::Error::other)?;
-        let stream = TcpStream::connect_timeout(&addr, TIMEOUT)?;
-        stream.set_write_timeout(Some(TIMEOUT))?;
-        stream.set_read_timeout(Some(TIMEOUT))?;
-        Ok(Self { stream: RefCell::new(stream) })
-    }
-}
-
-const CMD_GET_ON: u8 = 1;
-const CMD_TURN_ON: u8 = 2;
-const CMD_TURN_OFF: u8 = 3;
-const CMD_GET_POWER: u8 = 4;
-
-impl PowerSocketHandle for PowerSocketClient {
-    fn is_on(&self) -> bool {
-        let mut buf = [CMD_GET_ON; 1];
-        self.stream.borrow_mut().write_all(&buf).expect("CMD_GET_ON request should be sent");
-        self.stream.borrow_mut().read_exact(&mut buf).expect("CMD_GET_ON response should be received");
-        !matches!(buf, [0])
-    }
-
-    fn set_on(&mut self, on: bool) {
-        let cmd = if on { CMD_TURN_ON } else { CMD_TURN_OFF };
-        let mut buf = [cmd; 1];
-        self.stream.borrow_mut().write_all(&buf).expect("change state request should be sent");
-        self.stream.borrow_mut().read_exact(&mut buf).expect("change state response should be received");
-    }
-
-    fn get_power(&self) -> f32 {
-        let mut buf = [CMD_GET_POWER; 4];
-        self.stream.borrow_mut().write_all(&buf[0..1]).expect("CMD_GET_POWER request should be sent");
-        self.stream
-            .borrow_mut()
-            .read_exact(&mut buf)
-            .expect("CMD_GET_POWER response should be received");
-        f32::from_le_bytes(buf)
-    }
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-
-    #[test]
-    fn smoke_test() {
-        let mut power_socket = PowerSocket::stub(12.4, false);
-        assert!(!power_socket.is_on());
-        assert_eq!(power_socket.get_power(), 0.0);
-
-        power_socket.set_on(true);
-        assert!(power_socket.is_on());
-        assert_eq!(power_socket.get_power(), 12.4);
-    }
-
-    #[test]
-    fn display_test() {
-        assert_eq!(format!("{}", PowerSocket::stub(11.549, false).display()), "PowerSocket[ OFF : 0.0 ]");
-        assert_eq!(format!("{}", PowerSocket::stub(11.549, true).display()), "PowerSocket[ ON : 11.5 ]");
-        assert_eq!(format!("{}", PowerSocket::stub(11.550, true).display()), "PowerSocket[ ON : 11.6 ]");
-    }
-}

smart-house/src/print_status.rs

@@ -1,3 +0,0 @@
-pub trait PrintStatus {
-    fn print_status(&self);
-}

smart-house/src/room.rs

@@ -1,98 +1,77 @@
-use crate::{Device, PrintStatus};
+#![allow(unused)]
-use std::collections::HashMap;
+use crate::device::Device;
 
-#[derive(Debug)]
+struct Room<'a> {
-pub struct Room {
+    name: String,
-    devices: HashMap<String, Device>,
+    devices: &'a mut [Box<dyn Device>],
 }
 
-impl Room {
+impl<'a> Room<'a> {
-    pub fn new(devices: HashMap<String, Device>) -> Self {
+    pub fn new(name: impl AsRef<str>, devices: &'a mut [Box<dyn Device>]) -> Self {
-        Self { devices }
+        Self {
-    }
+            name: name.as_ref().to_string(),
-
+            devices,
-    pub fn get_device(&self, name: &str) -> Option<&Device> {
-        self.devices.get(name)
-    }
-
-    pub fn get_device_mut(&mut self, name: &str) -> Option<&mut Device> {
-        self.devices.get_mut(name)
-    }
-
-    pub fn insert_device(&mut self, name: &str, device: Device) -> Option<Device> {
-        self.devices.insert(name.to_string(), device)
-    }
-
-    pub fn remove_device(&mut self, name: &str) -> Option<Device> {
-        self.devices.remove(name)
-    }
-}
-
-impl PrintStatus for Room {
-    fn print_status(&self) {
-        for (name, device) in self.devices.iter() {
-            print!("{} => ", name);
-            device.print_status();
         }
     }
-}
 
-#[macro_export]
+    pub fn get(&'a self, idx: usize) -> &'a dyn Device {
-macro_rules! room {
+        if idx >= self.devices.len() {
-    ($($key:expr => $dev:expr),* $(,)?) => {
+            panic!("Index is out of bounds")
-        Room::new([$(
+        }
-            ($key.to_string(), $dev.into()),
+        self.devices[idx].as_ref()
-        )*].into_iter().collect())
+    }
-    };
+
+    pub fn get_mut(&'a mut self, idx: usize) -> &'a mut dyn Device {
+        if idx >= self.devices.len() {
+            panic!("Index is out of bounds")
+        }
+        self.devices[idx].as_mut()
+    }
+
+    pub fn print(&self) {
+        println!("{}", "=".repeat(16));
+        println!("{}:", self.name);
+        println!("{}", "-".repeat(16));
+        for d in self.devices.iter() {
+            d.print_status();
+        }
+        println!("{}", "=".repeat(16));
+    }
 }
 
 #[cfg(test)]
 mod tests {
     use super::*;
-    use crate::{PowerSocket, Thermometer};
+    use crate::device::{PowerSocket, Thermometer};
-
+    use std::fmt::format;
-    fn create_test_room() -> Room {
+    use std::mem;
-        room!(
-            "PSoc" => PowerSocket::stub(12.34, false),
-            "Therm" => Thermometer::stub(21.56),
-        )
-    }
 
     #[test]
     fn smoke_test() {
-        let mut room = create_test_room();
+        let mut devices = Box::new([Box::new(PowerSocket::new(12.34, false)) as Box<dyn Device>, Box::new(Thermometer::new(21.56))]);
-        assert_eq!(room.devices.len(), 2);
+        let mut room = Room::new("test_room", &mut *devices);
-        room.print_status();
+        assert_eq!(room.name, "test_room");
+        room.print();
 
-        assert_eq!(format!("{}", room.get_device("PSoc").unwrap().display()), "DEV:PowerSocket[ OFF : 0.0 ]");
+        assert_eq!(
-        assert_eq!(format!("{}", room.get_device("Therm").unwrap().display()), "DEV:Thermometer[ 21.6 ]");
+            format!("{}", room.get(0).as_any().downcast_ref::<PowerSocket>().unwrap().display()),
+            "PowerSocket[ OFF : 0.0 ]"
+        );
+        assert_eq!(
+            format!("{}", room.get(1).as_any().downcast_ref::<Thermometer>().unwrap().display()),
+            "Thermometer[ 21.6 ]"
+        );
 
-        let Device::PowerSocket(power_socket) = room.get_device_mut("PSoc").unwrap() else {
+        room.get_mut(0).as_mut_any().downcast_mut::<PowerSocket>().unwrap().set_on(true);
-            unreachable!()
-        };
-        power_socket.set_on(true);
 
-        assert_eq!(format!("{}", room.get_device("PSoc").unwrap().display()), "DEV:PowerSocket[ ON : 12.3 ]");
+        // room.print(); // TODO satisfy compiler
-        assert_eq!(format!("{}", room.get_device("Therm").unwrap().display()), "DEV:Thermometer[ 21.6 ]");
     }
 
     #[test]
-    fn check_out_of_bounds() {
+    #[should_panic(expected = "Index is out of bounds")]
-        let room = create_test_room();
+    fn panic_test() {
-        assert!(room.get_device("dummy").is_none());
+        let mut devices = [Box::new(PowerSocket::new(12.34, false)) as Box<dyn Device>, Box::new(Thermometer::new(21.56))];
-    }
+        let mut room = Room::new("test_room", &mut devices);
-
+        room.get(2);
-    #[test]
-    fn test_add_remove() {
-        let mut room = create_test_room();
-        let result = room.insert_device("NewTerm", Thermometer::stub(20.0).into());
-        assert!(result.is_none());
-        assert_eq!(room.devices.len(), 3);
-
-        let Some(Device::Thermometer(removed)) = room.remove_device("Therm") else {
-            unreachable!()
-        };
-        assert_eq!(removed.get_temperature(), 21.56);
-        assert_eq!(room.devices.len(), 2);
     }
 }

smart-house/src/thermometer.rs

@@ -1,114 +0,0 @@
-use std::fmt::{Debug, Display};
-use std::net::UdpSocket;
-use std::sync::Arc;
-use std::sync::atomic::{AtomicU32, Ordering};
-use std::time::Duration;
-
-#[derive(Debug)]
-pub struct Thermometer {
-    handle: Box<dyn ThermometerHandle>,
-}
-
-impl Thermometer {
-    pub fn stub(temperature: f32) -> Self {
-        Self {
-            handle: Box::new(ThermometerHandleStub::new(temperature)),
-        }
-    }
-
-    pub fn connect(addr: &str) -> std::io::Result<Self> {
-        let handle = ThermometerClient::new(addr)?;
-        Ok(Self { handle: Box::new(handle) })
-    }
-
-    pub fn get_temperature(&self) -> f32 {
-        self.handle.get_temperature()
-    }
-
-    pub fn display(&self) -> impl Display {
-        format!("Thermometer[ {:02.1} ]", self.get_temperature())
-    }
-}
-
-trait ThermometerHandle: Debug {
-    fn get_temperature(&self) -> f32;
-}
-
-#[derive(Debug)]
-struct ThermometerHandleStub {
-    temperature: f32,
-}
-
-impl ThermometerHandleStub {
-    fn new(temperature: f32) -> Self {
-        Self { temperature }
-    }
-}
-
-impl ThermometerHandle for ThermometerHandleStub {
-    fn get_temperature(&self) -> f32 {
-        self.temperature
-    }
-}
-
-const TIMEOUT: Duration = Duration::from_secs(5);
-
-#[derive(Debug)]
-struct ThermometerClient {
-    value: Arc<AtomicU32>,
-}
-
-impl ThermometerClient {
-    fn read(socket: &UdpSocket) -> std::io::Result<u32> {
-        let mut buf = [0u8; 4];
-        let result = socket.recv_from(&mut buf);
-        result.map(|_| Ok(u32::from_le_bytes(buf)))?
-    }
-
-    fn new(addr: &str) -> std::io::Result<Self> {
-        let value = Arc::new(AtomicU32::new(u32::from_le_bytes(f32::NAN.to_le_bytes())));
-        let socket = UdpSocket::bind(addr)?;
-        socket.set_read_timeout(Some(TIMEOUT))?;
-
-        let data = ThermometerClient::read(&socket)?;
-        value.store(data, Ordering::Relaxed);
-
-        let weak_value = Arc::downgrade(&value);
-        std::thread::spawn(move || {
-            while let Some(value) = weak_value.upgrade() {
-                let result = ThermometerClient::read(&socket);
-                match result {
-                    Ok(data) => value.store(data, Ordering::Relaxed),
-                    Err(e) => {
-                        eprintln!("receiving data failed: {:?}", e);
-                        break;
-                    }
-                };
-            }
-        });
-        Ok(Self { value })
-    }
-}
-
-impl ThermometerHandle for ThermometerClient {
-    fn get_temperature(&self) -> f32 {
-        f32::from_le_bytes(self.value.load(Ordering::Relaxed).to_le_bytes())
-    }
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-
-    #[test]
-    fn smoke_test() {
-        let thermometer = Thermometer::stub(20.0);
-        assert_eq!(thermometer.get_temperature(), 20.0);
-    }
-
-    #[test]
-    fn display_test() {
-        assert_eq!(format!("{}", Thermometer::stub(19.550).display()), "Thermometer[ 19.5 ]");
-        assert_eq!(format!("{}", Thermometer::stub(19.551).display()), "Thermometer[ 19.6 ]");
-    }
-}

smart-house/thermometer_mock.cfg

@@ -1,2 +0,0 @@
-127.0.0.1:10002
-500