logos-storage/logos-storage-proofs
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-proofs.git synced 2026-01-08 08:23:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

chunks

Browse Source
This commit is contained in:
Jaremy Creechley 2023-12-07 22:46:05 -07:00
parent e3708b19a0
commit 88b9bc270e
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/ffi.rs
View File

@ -204,6 +204,8 @@ mod tests {
let mut buf = Vec::new(); let mut buf = Vec::new();
let val = Value::from("le message"); let val = Value::from("le message");
// example of serializing the random chunk data
// we build them up in mpack Value enums
let data = (0..4) let data = (0..4)
.map(|_| { .map(|_| {
let rng = ThreadRng::default(); let rng = ThreadRng::default();
@ -220,7 +222,7 @@ mod tests {
let chunks = data.iter() let chunks = data.iter()
.map(|c| { .map(|c| {
let x = c.0.iter() let x = c.0.iter()
.map(|c| Value::Ext(50, c.to_le_bytes_vec()[0..3].to_vec())) .map(|c| Value::Ext(50, c.to_le_bytes_vec()))
.collect::<Vec<Value>>(); .collect::<Vec<Value>>();
Value::Array(x) Value::Array(x)
}) })
@ -229,12 +231,9 @@ mod tests {
let mut data = Value::Map(vec![(Value::String("chunks".into()), chunks.clone() )]); let mut data = Value::Map(vec![(Value::String("chunks".into()), chunks.clone() )]);
println!("Debug: chunks: {:?}", chunks[0][0]); println!("Debug: chunks: {:?}", chunks[0][0]);
// println!("Debug: data: {:?}", data["chunks"]);
// println!("Debug: data: {:?}", data);
// Serialize the value types to an array pointer
write_value(&mut buf, &data).unwrap(); write_value(&mut buf, &data).unwrap();
// assert_eq!(vec![0xaa, 0x6c, 0x65, 0x20, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65], buf);
// let buf = [0xaa, 0x6c, 0x65, 0x20, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65];
let mut rd = &buf[..]; let mut rd = &buf[..];
let args = read_value(&mut rd).unwrap(); let args = read_value(&mut rd).unwrap();
@ -242,18 +241,27 @@ mod tests {
assert!(Value::is_map(&args)); assert!(Value::is_map(&args));
assert!(Value::is_array(&args["chunks"])); assert!(Value::is_array(&args["chunks"]));
assert!(Value::is_array(&args["chunks"][0])); assert!(Value::is_array(&args["chunks"][0]));
let mut arg_chunks: Vec<Vec<Value>> = Vec::new(); let mut arg_chunks: Vec<Vec<U256>> = Vec::new();
// deserialize the data back into u256's
args["chunks"] args["chunks"]
.as_array() .as_array()
.unwrap() .unwrap()
.iter() .iter()
.for_each(|c| { .for_each(|c| {
let x = c.as_array().unwrap(); let x = c.as_array().unwrap();
x; let mut vals: Vec<U256> = Vec::new();
// .map(|c| Value::Ext(50, c.to_le_bytes_vec()[0..3].to_vec())) x.iter().for_each(|n| {
let b = n.as_ext().unwrap();
// ensure it's a LE uin256 which we've set as ext 50
assert_eq!(b.0, 50);
vals.push(U256::try_from_le_slice(b.1).unwrap());
});
arg_chunks.push(vals);
}); });
assert_eq!(arg_chunks.len(), 4);
assert_eq!(arg_chunks[0].len(), 256);
} }