+TITLE: Notas de desarrollo.

• Data

  La estructura Data contiene toda la información que podría generar un sensor base.

  Se necesita construir lo siguiente.

* DONE ValuePair * DONE Point * DONE Equipment * DONE DT_GEN Format ** DONE Data

Todo está definido bajo una estrucura de directorios.

+begin_src shell :results output

tree src

+end_src

+RESULTS:

+begin_example

src ├── elements │   ├── data.rs │   ├── dtgenformat.rs │   ├── equipment.rs │   ├── mod.rs │   ├── point.rs │   └── valuepair.rs ├── generators.rs ├── lib.rs ├── main.rs └── stream ├── asyncread.rs ├── asyncread.rs~ ├── asyncwrite.rs ├── asyncwrite.rs~ ├── mod.rs ├── read.rs ├── write.rs ├── write.rs~ └── writeto_stream.rs

2 directories, 18 files

+end_example

• Random data gen

Es la serie de funciones que construyen aleatoriamente datos a solicitud.

En generators.rs tenemos la función create_data que genera una instancia de Data aleatoria.

• Stream I/O

Creación de comando que permite una entrada y deserializarla. Sea un stream o de un archivo.

Hay dos funciones síncronas que permite leer o escribir desde un stream.

• read_io
• write-io

De estas dos derivan las asociadas a archivos, para leer o escribir a archivos.

• read_file
• write_file

Asímismo, de manera asíncrona se usa tokio para crear las funciones que toman leen desde un buffer y lo envían por un canal y viceversa.

• rendertostream
• streamtowriter

Estas funcionalidades son claves para que este módulo se pueda utilizar, por ejemplo, en servidores tcp o servicios generadores de datos para simular sensores.

** Lectura de archivos

En stream.rs -> read_file se implementa una función sencilla que toma un archivo completo y lo deserializa directamente para convertirlo en un array de Data.

Esto es solo para un archivo de tipo json.

+begin_src rust

pub fn readfile>( path: P) -> Result, Box> { // open file if exists path let file = File::open(path)?; // set file to buffer let reader = BufReader::new(file); // read the json contents let jsondata = serdejson::fromreader(reader)?; // Return Data Ok(json_data) }

+end_src

** Lectura de stream y entrega de vector

Si el origen del dato viene de un stream, entonces se usa read_io que toma la serie de valores (o de un archivo no json)

+begin_src rust

pub fn readioflag: &String, print: bool) -> Result, Box> { let mut lines: Vec = vec![]; let mut dataset: Vec = vec![]; for value in input.lines() { let line = value?; if line.asstr().trim() == endflag { let newvalue = lines.join(""); let newdata = Data::jsonloads(&newvalue); if print { println!("{}", newdata); } dataset.push(newdata); lines.clear(); } else { if !line.trim().is_empty() { lines.push(line); } } } Ok(dataset) }