Struct MessageEncoder 

pub struct MessageEncoder<'a> { /* private fields */ }

Implementations

impl<'a> MessageEncoder<'a>

pub fn new( method: Method, transaction_id: &'a [u8; 12], bytes: &'a mut BytesMut, ) -> Self

pub fn extend( method: Method, reader: &Message<'a>, bytes: &'a mut BytesMut, ) -> Self

rely on old message to create new message.

Test

use bytes::BytesMut;
use std::convert::TryFrom;
use turn_server::codec::message::methods::*;
use turn_server::codec::message::*;
use turn_server::codec::*;

let buffer = [
    0x00u8, 0x01, 0x00, 0x00, 0x21, 0x12, 0xa4, 0x42, 0x72, 0x6d, 0x49,
    0x42, 0x72, 0x52, 0x64, 0x48, 0x57, 0x62, 0x4b, 0x2b,
];

let mut attributes = Attributes::default();
let mut buf = BytesMut::new();
let old = Message::decode(&buffer[..], &mut attributes).unwrap();
MessageEncoder::extend(Method::Binding(MethodType::Request), &old, &mut buf);

assert_eq!(&buf[..], &buffer[..]);

pub fn append<'c, T: Attribute<'c>>(&'c mut self, value: T::Item)

append attribute.

append attribute to message attribute list.

Test

use bytes::BytesMut;
use std::convert::TryFrom;
use turn_server::codec::message::attributes::*;
use turn_server::codec::message::methods::*;
use turn_server::codec::message::*;
use turn_server::codec::*;

let buffer = [
    0x00u8, 0x01, 0x00, 0x00, 0x21, 0x12, 0xa4, 0x42, 0x72, 0x6d, 0x49,
    0x42, 0x72, 0x52, 0x64, 0x48, 0x57, 0x62, 0x4b, 0x2b,
];

let new_buf = [
    0x00u8, 0x01, 0x00, 0x00, 0x21, 0x12, 0xa4, 0x42, 0x72, 0x6d, 0x49,
    0x42, 0x72, 0x52, 0x64, 0x48, 0x57, 0x62, 0x4b, 0x2b, 0x00, 0x06, 0x00,
    0x05, 0x70, 0x61, 0x6e, 0x64, 0x61, 0x00, 0x00, 0x00,
];

let mut buf = BytesMut::new();
let mut attributes = Attributes::default();
let old = Message::decode(&buffer[..], &mut attributes).unwrap();
let mut message =
    MessageEncoder::extend(Method::Binding(MethodType::Request), &old, &mut buf);

message.append::<UserName>("panda");

assert_eq!(&new_buf[..], &buf[..]);

pub fn flush(&mut self, password: Option<&Password>) -> Result<(), Error>

try decoder bytes as message.

Test

use bytes::BytesMut;
use std::convert::TryFrom;
use turn_server::codec::message::methods::*;
use turn_server::codec::message::*;
use turn_server::codec::*;

let buffer = [
    0x00u8, 0x01, 0x00, 0x00, 0x21, 0x12, 0xa4, 0x42, 0x72, 0x6d, 0x49,
    0x42, 0x72, 0x52, 0x64, 0x48, 0x57, 0x62, 0x4b, 0x2b,
];

let result = [
    0, 1, 0, 32, 33, 18, 164, 66, 114, 109, 73, 66, 114, 82, 100, 72, 87,
    98, 75, 43, 0, 8, 0, 20, 69, 14, 110, 68, 82, 30, 232, 222, 44, 240,
    250, 182, 156, 92, 25, 23, 152, 198, 217, 222, 128, 40, 0, 4, 74, 165,
    171, 86,
];

let mut attributes = Attributes::default();
let mut buf = BytesMut::with_capacity(1280);
let old = Message::decode(&buffer[..], &mut attributes).unwrap();
let mut message =
    MessageEncoder::extend(Method::Binding(MethodType::Request), &old, &mut buf);

message
    .flush(Some(&turn_server::codec::crypto::generate_password(
        "panda",
        "panda",
        "raspberry",
        turn_server::codec::message::attributes::PasswordAlgorithm::Md5,
    )))
    .unwrap();

assert_eq!(&buf[..], &result);