2018-05-08 21:57:20 +09:00
|
|
|
#![macro_use]
|
|
|
|
|
|
|
|
#[macro_export]
|
|
|
|
macro_rules! test_msg {
|
2018-06-16 23:11:37 -04:00
|
|
|
($MsgType: path, $data: ident) => {
|
2018-05-08 21:57:20 +09:00
|
|
|
{
|
2018-09-14 17:50:48 -04:00
|
|
|
use lightning::util::ser::{Writeable, Readable};
|
|
|
|
let mut r = ::std::io::Cursor::new($data);
|
2018-09-01 16:21:39 +09:00
|
|
|
if let Ok(msg) = <$MsgType as Readable<::std::io::Cursor<&[u8]>>>::read(&mut r) {
|
2018-09-14 17:50:48 -04:00
|
|
|
let p = r.position() as usize;
|
|
|
|
let mut w = ::std::io::Cursor::new(vec![]);
|
2018-09-01 16:21:39 +09:00
|
|
|
msg.write(&mut w).unwrap();
|
|
|
|
|
2018-09-14 17:50:48 -04:00
|
|
|
let buf = w.into_inner();
|
2018-09-01 16:21:39 +09:00
|
|
|
assert_eq!(buf.len(), p);
|
2018-09-14 17:50:48 -04:00
|
|
|
assert_eq!(&r.into_inner()[..p], &buf[..p]);
|
2018-09-01 16:21:39 +09:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
#[macro_export]
|
|
|
|
macro_rules! test_msg_simple {
|
|
|
|
($MsgType: path, $data: ident) => {
|
|
|
|
{
|
2018-09-14 17:50:48 -04:00
|
|
|
use lightning::util::ser::{Writeable, Readable};
|
|
|
|
let mut r = ::std::io::Cursor::new($data);
|
2018-09-01 16:21:39 +09:00
|
|
|
if let Ok(msg) = <$MsgType as Readable<::std::io::Cursor<&[u8]>>>::read(&mut r) {
|
2018-09-14 17:50:48 -04:00
|
|
|
msg.write(&mut ::std::io::Cursor::new(vec![])).unwrap();
|
2018-05-08 21:57:20 +09:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2018-08-29 15:56:48 -04:00
|
|
|
|
|
|
|
#[macro_export]
|
|
|
|
macro_rules! test_msg_exact {
|
|
|
|
($MsgType: path, $data: ident) => {
|
|
|
|
{
|
2018-09-14 17:50:48 -04:00
|
|
|
use lightning::util::ser::{Writeable, Readable};
|
|
|
|
let mut r = ::std::io::Cursor::new($data);
|
2018-09-01 16:21:39 +09:00
|
|
|
if let Ok(msg) = <$MsgType as Readable<::std::io::Cursor<&[u8]>>>::read(&mut r) {
|
2018-09-14 17:50:48 -04:00
|
|
|
let mut w = ::std::io::Cursor::new(vec![]);
|
2018-09-01 16:21:39 +09:00
|
|
|
msg.write(&mut w).unwrap();
|
|
|
|
|
2018-09-14 17:50:48 -04:00
|
|
|
let buf = w.into_inner();
|
|
|
|
assert_eq!(&r.into_inner()[..], &buf[..]);
|
2018-08-29 15:56:48 -04:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
#[macro_export]
|
|
|
|
macro_rules! test_msg_hole {
|
|
|
|
($MsgType: path, $data: ident, $hole: expr, $hole_len: expr) => {
|
|
|
|
{
|
2018-09-14 17:50:48 -04:00
|
|
|
use lightning::util::ser::{Writeable, Readable};
|
|
|
|
let mut r = ::std::io::Cursor::new($data);
|
2018-09-01 16:21:39 +09:00
|
|
|
if let Ok(msg) = <$MsgType as Readable<::std::io::Cursor<&[u8]>>>::read(&mut r) {
|
2018-09-14 17:50:48 -04:00
|
|
|
let mut w = ::std::io::Cursor::new(vec![]);
|
2018-09-01 16:21:39 +09:00
|
|
|
msg.write(&mut w).unwrap();
|
2018-09-14 17:50:48 -04:00
|
|
|
let p = w.position() as usize;
|
2018-09-01 16:21:39 +09:00
|
|
|
|
2018-09-14 17:50:48 -04:00
|
|
|
let buf = w.into_inner();
|
2018-09-01 16:21:39 +09:00
|
|
|
assert_eq!(buf.len(),p);
|
2018-09-14 17:50:48 -04:00
|
|
|
assert_eq!(&r.get_ref()[..$hole], &buf[..$hole]);
|
|
|
|
assert_eq!(&r.get_ref()[$hole+$hole_len..p], &buf[$hole+$hole_len..]);
|
2018-08-29 15:56:48 -04:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|