From 8b593939e56642b73614cae66d02b6db45807115 Mon Sep 17 00:00:00 2001 From: Mikhail Mitrofanov Date: Wed, 16 Sep 2026 11:03:43 +0300 Subject: [PATCH] Found some bugs --- src/main.rs | 2 +- src/server/handling.rs | 5 ++++- src/server/mod.rs | 12 ++++++++---- 3 files changed, 13 insertions(+), 6 deletions(-) diff --git a/src/main.rs b/src/main.rs index b2d77ec..7a40d31 100644 --- a/src/main.rs +++ b/src/main.rs @@ -6,7 +6,7 @@ use std::io::Read; use std::net::UdpSocket; use std::sync::mpsc::*; -const LISTEN: &str = "127.0.0.1:8080"; +const LISTEN: &str = "127.0.0.1:5555"; fn main() { let (cw, cr) = channel::(); diff --git a/src/server/handling.rs b/src/server/handling.rs index fefe7b3..4019204 100644 --- a/src/server/handling.rs +++ b/src/server/handling.rs @@ -3,11 +3,14 @@ use crate::server::{Command, NoteContext, StoredData}; use litemap::LiteMap; use std::io::Write; use std::string::String; +use log::info; impl NoteContext { pub fn execute_command(&mut self, command: Command) { match command { - Command::Unknown => {} + Command::Unknown => { + println!("Unknown command"); + } Command::Set(key, value) => self.set(key, value), Command::Define(key, schema) => self.define(key, schema), Command::Push(key, value) => self.push(key, value), diff --git a/src/server/mod.rs b/src/server/mod.rs index c3bafff..798bbdc 100644 --- a/src/server/mod.rs +++ b/src/server/mod.rs @@ -2,11 +2,11 @@ mod handling; mod testing; use litemap::LiteMap; -use minicbor::Decoder; use minicbor::data::Type; use minicbor::decode::Error; +use minicbor::Decoder; use std::collections::HashMap; -use std::fmt::{Display, Formatter }; +use std::fmt::{Display, Formatter}; use std::io::Write; pub enum Command { @@ -73,7 +73,10 @@ impl Display for Line { impl From<&[u8]> for Command { fn from(value: &[u8]) -> Self { - parse_command(value).unwrap_or(Command::Unknown) + parse_command(value).unwrap_or_else(|e| { + println!("{}", e); + Command::Unknown + }) } } @@ -87,6 +90,7 @@ fn parse_command(data: &[u8]) -> Result { return Ok(Command::Set(id, value)); } if data.starts_with(b"PUSH:") { + println!("{}", String::from_utf8_lossy(data)); let payload = &data[b"PUSH:".len()..]; let mut decoder = Decoder::new(&payload); decoder.array()?; @@ -152,7 +156,7 @@ pub struct NoteContext { impl NoteContext { pub fn default() -> Self { - Self{ + Self { entries: Default::default(), output: Box::new(std::io::stdout()), }