WIP: custom #ingest#protocol parser #23

Весь прикол в том, что допустим у тебя есть enum вариант с source: T1. Самого факта того, что у тебя что-то возвращает Result<..., T1> - мало, ибо у тебя в snafu может быть несколько вариантов с source: T1. Соответственно - .context() повзоляет указать какой из них тебя интересует. Конечно, когда у тебя только один вариант с source: T1 - то логично было бы автоматом impl From<T1> for ErrorEnum делать, но такого функционала у snafu нет, насколько я знаю. Мб оно и к лучшему, хз.

@DarkCat09 wrote in https://git.dc09.ru/iotishnik/server/pulls/23#issuecomment-372: > Во многих местах `.context()` выглядит громоздко. @nm17, можно как в thiserror просто конвертить в енум ошибки? В доках не нашёл Весь прикол в том, что допустим у тебя есть enum вариант с `source: T1`. Самого факта того, что у тебя что-то возвращает `Result<..., T1>` - мало, ибо у тебя в snafu может быть несколько вариантов с `source: T1`. Соответственно - `.context()` повзоляет указать какой из них тебя интересует. Конечно, когда у тебя только один вариант с `source: T1` - то логично было бы автоматом `impl From<T1> for ErrorEnum` делать, но такого функционала у snafu нет, насколько я знаю. Мб оно и к лучшему, хз.

nm17 requested changes 2025-01-11 13:14:12 +03:00

nm17 left a comment

Некоторое требует поправок и обсуждения

src/ingest_protocol/parser.rs Outdated

					
				@ -20,2 +11,3 @@

				use crate::ingest_protocol::{NMDeviceDataPacket, SensorValue};

				    let mut counter = 0;

				pub fn parse_packet(mut input: &[u8]) -> Result<NMDeviceDataPacket, Error> {

nm17 commented

2025-01-11 13:13:10 +03:00

Может быть всё-таки будем использовать Bytes для этого всего? Таким образом в Error сможем добавлять на каком именно куске всё пошло не по плану)

DarkCat09 commented

2025-01-12 17:06:52 +03:00

// из обсуждения в телеграме: я предлагал вариант с чтением напрямую из impl AsyncReadExt, но Даня верно заметил, что парсер не совсем этим должен заниматься => делаем с bytes::Bytes

// из обсуждения в телеграме: я предлагал вариант с чтением напрямую из impl AsyncReadExt, но Даня верно заметил, что парсер не совсем этим должен заниматься => делаем с `bytes::Bytes`

👍 1

src/ingest_protocol/parser.rs Outdated

					
				@ -136,0 +142,4 @@

				    Ok(packet)

				}

				pub fn parse_mac_address(input: &[u8]) -> Result<[u8; 6], Error> {

nm17 commented

2025-01-11 13:09:56 +03:00

Точно ли хорошая идея избавиться от nom-like нотации поглощения и возвращения результата и остатков? Она как минимум нужна будет если захотим сделать парсинг нескольких пакетов в одном TCP подключении ( #11 ).

DarkCat09 commented

2025-01-12 17:05:16 +03:00

Как это будет в коде тцп-сервера? По-моему ты там всё равно будешь читать из потока до ## и передавать вот эти байты в парсер, у него не будет остатков

Как это будет в коде тцп-сервера? По-моему ты там всё равно будешь читать из потока до `##` и передавать вот эти байты в парсер, у него не будет остатков

src/ingest_protocol/tests/mod.rs

					
				@ -29,3 +30,2 @@

				    assert_eq!(

				        parse_mac_address("12-34-AA-12-55-AA").unwrap(),

				        ("", [18, 52, 170, 18, 85, 170])

				        parse_mac_address(b"12-34-Aa-1255-fA").unwrap(),

nm17 commented

2025-01-11 13:03:41 +03:00

Хм, вижу решил сделать парсинг мака более универсальным, да?

DarkCat09 commented

2025-01-12 17:03:54 +03:00

Ага. Ну и лишние проверки при текущей логике парсера мака будут выглядеть некрасиво

DarkCat09 marked this conversation as resolved

src/web_server/old_device_sensor_api/qs_parser.rs

					
				@ -47,0 +40,4 @@

				impl From<Error> for QSParserError {

				    fn from(value: Error) -> Self {

				        QSParserError::Parsing {

				            context: format!("{:?}", value),

nm17 commented

2025-01-11 13:06:30 +03:00

Так, это вообще не пойдёт. Это было сделано как колхоз для того, чтобы не притягивать лайфтаймы в QSParserError, но теперь, так как у нас Error 'static, можно и нужно Error парсера перекидывать как source.

DarkCat09 commented

2025-01-12 17:02:41 +03:00

А, я это вообще не заметил, исправил только чтоб компилялось