shenjack/openbmclapi-rs
2
2
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

NB

Browse Source
This commit is contained in:
shenjack 2024-01-27 01:02:01 +08:00
parent 72eb29244c
commit a9d8ed9817
Signed by: shenjack
GPG Key ID: 7B1134A979775551
2 changed files with 7 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/cluster.rs
View File

@ -7,7 +7,6 @@ use serde::Deserialize;
use zstd::stream::decode_all;
#[derive(Deserialize, Debug, Clone)]
#[serde(rename = "fileinfo")]
pub struct SyncFile {
pub path: String,
pub hash: String,
@ -16,7 +15,7 @@ pub struct SyncFile {
#[derive(Deserialize, Debug, Clone)]
pub struct SyncFileList {
pub fileinfo: Vec<SyncFile>,
pub file: Vec<SyncFile>,
}
pub struct Cluster {

21
src/utils.rs
View File

@ -59,7 +59,7 @@ pub const SYNC_FILE_LIST_SCHEMA: &str = r#"
"type": "array",
"items": {
"type": "record",
"name": "SyncFile",
"name": "file",
"fields": [
{"name": "path", "type": "string"},
{"name": "hash", "type": "string"},
@ -78,29 +78,20 @@ pub fn avro_data_to_file_list(data: Vec<u8>) -> apache_avro::AvroResult<Vec<Sync
return Err(reader.err().unwrap());
}
let value = reader.unwrap();
println!("{:?}", value.validate(&chema));
match &value {
Value::Array(arr) => {
println!("array len: {}", arr.len());
let mut files = Vec::with_capacity(arr.len());
for i in 0..arr.len() {
let item = &arr[i];
let try_item = from_value::<SyncFile>(item);
if try_item.is_err() {
println!("parse item error: {}", try_item.err().unwrap());
}
let try_item = from_value::<SyncFile>(item).unwrap();
files.push(try_item);
}
Ok(files)
}
_ => {
println!("not array");
panic!("invalid avro data, expect array")
}
}
let files = from_value::<SyncFileList>(&value);
if files.is_err() {
// return Err(files.err().unwrap());
panic!("parse file list error: ");
}
let files = files.unwrap();
Ok(files.fileinfo)
}
#[test]