pub use decoder::WebSocketResponseDecoder;
pub use encoder::WebSocketResponseEncoder;
use super::*;
pub use super::{SBE_SCHEMA_ID, SBE_SCHEMA_VERSION, SBE_SEMANTIC_VERSION};
pub const SBE_BLOCK_LENGTH: u16 = 3;
pub const SBE_TEMPLATE_ID: u16 = 50;
pub mod encoder {
use message_header_codec::*;
use super::*;
#[derive(Debug, Default)]
pub struct WebSocketResponseEncoder<'a> {
buf: WriteBuf<'a>,
initial_offset: usize,
offset: usize,
limit: usize,
}
impl<'a> Writer<'a> for WebSocketResponseEncoder<'a> {
#[inline]
fn get_buf_mut(&mut self) -> &mut WriteBuf<'a> {
&mut self.buf
}
}
impl<'a> Encoder<'a> for WebSocketResponseEncoder<'a> {
#[inline]
fn get_limit(&self) -> usize {
self.limit
}
#[inline]
fn set_limit(&mut self, limit: usize) {
self.limit = limit;
}
}
impl<'a> WebSocketResponseEncoder<'a> {
pub fn wrap(mut self, buf: WriteBuf<'a>, offset: usize) -> Self {
let limit = offset + SBE_BLOCK_LENGTH as usize;
self.buf = buf;
self.initial_offset = offset;
self.offset = offset;
self.limit = limit;
self
}
#[inline]
pub fn encoded_length(&self) -> usize {
self.limit - self.offset
}
pub fn header(self, offset: usize) -> MessageHeaderEncoder<Self> {
let mut header = MessageHeaderEncoder::default().wrap(self, offset);
header.block_length(SBE_BLOCK_LENGTH);
header.template_id(SBE_TEMPLATE_ID);
header.schema_id(SBE_SCHEMA_ID);
header.version(SBE_SCHEMA_VERSION);
header
}
#[inline]
pub fn sbe_schema_id_version_deprecated(&mut self, value: bool_enum::BoolEnum) {
let offset = self.offset;
self.get_buf_mut().put_u8_at(offset, value as u8)
}
#[inline]
pub fn status(&mut self, value: u16) {
let offset = self.offset + 1;
self.get_buf_mut().put_u16_at(offset, value);
}
#[inline]
pub fn rate_limits_encoder(
self,
count: u16,
rate_limits_encoder: RateLimitsEncoder<Self>,
) -> RateLimitsEncoder<Self> {
rate_limits_encoder.wrap(self, count)
}
#[inline]
pub fn id(&mut self, value: &str) {
let limit = self.get_limit();
let data_length = value.len();
self.set_limit(limit + 1 + data_length);
self.get_buf_mut().put_u8_at(limit, data_length as u8);
self.get_buf_mut().put_slice_at(limit + 1, value.as_bytes());
}
#[inline]
pub fn result(&mut self, value: &[u8]) {
let limit = self.get_limit();
let data_length = value.len();
self.set_limit(limit + 4 + data_length);
self.get_buf_mut().put_u32_at(limit, data_length as u32);
self.get_buf_mut().put_slice_at(limit + 4, value);
}
}
#[derive(Debug, Default)]
pub struct RateLimitsEncoder<P> {
parent: Option<P>,
count: u16,
index: usize,
offset: usize,
initial_limit: usize,
}
impl<'a, P> Writer<'a> for RateLimitsEncoder<P>
where
P: Writer<'a> + Default,
{
#[inline]
fn get_buf_mut(&mut self) -> &mut WriteBuf<'a> {
if let Some(parent) = self.parent.as_mut() {
parent.get_buf_mut()
} else {
panic!("parent was None")
}
}
}
impl<'a, P> Encoder<'a> for RateLimitsEncoder<P>
where
P: Encoder<'a> + Default,
{
#[inline]
fn get_limit(&self) -> usize {
self.parent.as_ref().expect("parent missing").get_limit()
}
#[inline]
fn set_limit(&mut self, limit: usize) {
self.parent
.as_mut()
.expect("parent missing")
.set_limit(limit);
}
}
impl<'a, P> RateLimitsEncoder<P>
where
P: Encoder<'a> + Default,
{
#[inline]
pub fn wrap(mut self, mut parent: P, count: u16) -> Self {
let initial_limit = parent.get_limit();
parent.set_limit(initial_limit + 4);
parent
.get_buf_mut()
.put_u16_at(initial_limit, Self::block_length());
parent.get_buf_mut().put_u16_at(initial_limit + 2, count);
self.parent = Some(parent);
self.count = count;
self.index = usize::MAX;
self.offset = usize::MAX;
self.initial_limit = initial_limit;
self
}
#[inline]
pub fn block_length() -> u16 {
19
}
#[inline]
pub fn parent(&mut self) -> SbeResult<P> {
self.parent.take().ok_or(SbeErr::ParentNotSet)
}
#[inline]
pub fn advance(&mut self) -> SbeResult<Option<usize>> {
let index = self.index.wrapping_add(1);
if index >= self.count as usize {
return Ok(None);
}
if let Some(parent) = self.parent.as_mut() {
self.offset = parent.get_limit();
parent.set_limit(self.offset + Self::block_length() as usize);
self.index = index;
Ok(Some(index))
} else {
Err(SbeErr::ParentNotSet)
}
}
#[inline]
pub fn rate_limit_type(&mut self, value: rate_limit_type::RateLimitType) {
let offset = self.offset;
self.get_buf_mut().put_u8_at(offset, value as u8)
}
#[inline]
pub fn interval(&mut self, value: rate_limit_interval::RateLimitInterval) {
let offset = self.offset + 1;
self.get_buf_mut().put_u8_at(offset, value as u8)
}
#[inline]
pub fn interval_num(&mut self, value: u8) {
let offset = self.offset + 2;
self.get_buf_mut().put_u8_at(offset, value);
}
#[inline]
pub fn rate_limit(&mut self, value: i64) {
let offset = self.offset + 3;
self.get_buf_mut().put_i64_at(offset, value);
}
#[inline]
pub fn current(&mut self, value: i64) {
let offset = self.offset + 11;
self.get_buf_mut().put_i64_at(offset, value);
}
}
}
pub mod decoder {
use message_header_codec::*;
use super::*;
#[derive(Clone, Copy, Debug, Default)]
pub struct WebSocketResponseDecoder<'a> {
buf: ReadBuf<'a>,
initial_offset: usize,
offset: usize,
limit: usize,
pub acting_block_length: u16,
pub acting_version: u16,
}
impl ActingVersion for WebSocketResponseDecoder<'_> {
#[inline]
fn acting_version(&self) -> u16 {
self.acting_version
}
}
impl<'a> Reader<'a> for WebSocketResponseDecoder<'a> {
#[inline]
fn get_buf(&self) -> &ReadBuf<'a> {
&self.buf
}
}
impl<'a> Decoder<'a> for WebSocketResponseDecoder<'a> {
#[inline]
fn get_limit(&self) -> usize {
self.limit
}
#[inline]
fn set_limit(&mut self, limit: usize) {
self.limit = limit;
}
}
impl<'a> WebSocketResponseDecoder<'a> {
pub fn wrap(
mut self,
buf: ReadBuf<'a>,
offset: usize,
acting_block_length: u16,
acting_version: u16,
) -> Self {
let limit = offset + acting_block_length as usize;
self.buf = buf;
self.initial_offset = offset;
self.offset = offset;
self.limit = limit;
self.acting_block_length = acting_block_length;
self.acting_version = acting_version;
self
}
#[inline]
pub fn encoded_length(&self) -> usize {
self.limit - self.offset
}
pub fn header(self, mut header: MessageHeaderDecoder<ReadBuf<'a>>, offset: usize) -> Self {
debug_assert_eq!(SBE_TEMPLATE_ID, header.template_id());
let acting_block_length = header.block_length();
let acting_version = header.version();
self.wrap(
header.parent().unwrap(),
offset + message_header_codec::ENCODED_LENGTH,
acting_block_length,
acting_version,
)
}
#[inline]
pub fn sbe_schema_id_version_deprecated(&self) -> bool_enum::BoolEnum {
self.get_buf().get_u8_at(self.offset).into()
}
#[inline]
pub fn status(&self) -> u16 {
self.get_buf().get_u16_at(self.offset + 1)
}
#[inline]
pub fn rate_limits_decoder(self) -> RateLimitsDecoder<Self> {
RateLimitsDecoder::default().wrap(self)
}
#[inline]
pub fn id_decoder(&mut self) -> (usize, usize) {
let offset = self.get_limit();
let data_length = self.get_buf().get_u8_at(offset) as usize;
self.set_limit(offset + 1 + data_length);
(offset + 1, data_length)
}
#[inline]
pub fn id_slice(&'a self, coordinates: (usize, usize)) -> &'a [u8] {
debug_assert!(self.get_limit() >= coordinates.0 + coordinates.1);
self.get_buf().get_slice_at(coordinates.0, coordinates.1)
}
#[inline]
pub fn result_decoder(&mut self) -> (usize, usize) {
let offset = self.get_limit();
let data_length = self.get_buf().get_u32_at(offset) as usize;
self.set_limit(offset + 4 + data_length);
(offset + 4, data_length)
}
#[inline]
pub fn result_slice(&'a self, coordinates: (usize, usize)) -> &'a [u8] {
debug_assert!(self.get_limit() >= coordinates.0 + coordinates.1);
self.get_buf().get_slice_at(coordinates.0, coordinates.1)
}
}
#[derive(Debug, Default)]
pub struct RateLimitsDecoder<P> {
parent: Option<P>,
block_length: u16,
count: u16,
index: usize,
offset: usize,
}
impl<'a, P> ActingVersion for RateLimitsDecoder<P>
where
P: Reader<'a> + ActingVersion + Default,
{
#[inline]
fn acting_version(&self) -> u16 {
self.parent.as_ref().unwrap().acting_version()
}
}
impl<'a, P> Reader<'a> for RateLimitsDecoder<P>
where
P: Reader<'a> + Default,
{
#[inline]
fn get_buf(&self) -> &ReadBuf<'a> {
self.parent.as_ref().expect("parent missing").get_buf()
}
}
impl<'a, P> Decoder<'a> for RateLimitsDecoder<P>
where
P: Decoder<'a> + ActingVersion + Default,
{
#[inline]
fn get_limit(&self) -> usize {
self.parent.as_ref().expect("parent missing").get_limit()
}
#[inline]
fn set_limit(&mut self, limit: usize) {
self.parent
.as_mut()
.expect("parent missing")
.set_limit(limit);
}
}
impl<'a, P> RateLimitsDecoder<P>
where
P: Decoder<'a> + ActingVersion + Default,
{
pub fn wrap(mut self, mut parent: P) -> Self {
let initial_offset = parent.get_limit();
let block_length = parent.get_buf().get_u16_at(initial_offset);
let count = parent.get_buf().get_u16_at(initial_offset + 2);
parent.set_limit(initial_offset + 4);
self.parent = Some(parent);
self.block_length = block_length;
self.count = count;
self.index = usize::MAX;
self.offset = 0;
self
}
#[inline]
pub fn parent(&mut self) -> SbeResult<P> {
self.parent.take().ok_or(SbeErr::ParentNotSet)
}
#[inline]
pub fn acting_version(&mut self) -> u16 {
self.parent.as_ref().unwrap().acting_version()
}
#[inline]
pub fn count(&self) -> u16 {
self.count
}
pub fn advance(&mut self) -> SbeResult<Option<usize>> {
let index = self.index.wrapping_add(1);
if index >= self.count as usize {
return Ok(None);
}
if let Some(parent) = self.parent.as_mut() {
self.offset = parent.get_limit();
parent.set_limit(self.offset + self.block_length as usize);
self.index = index;
Ok(Some(index))
} else {
Err(SbeErr::ParentNotSet)
}
}
#[inline]
pub fn rate_limit_type(&self) -> rate_limit_type::RateLimitType {
self.get_buf().get_u8_at(self.offset).into()
}
#[inline]
pub fn interval(&self) -> rate_limit_interval::RateLimitInterval {
self.get_buf().get_u8_at(self.offset + 1).into()
}
#[inline]
pub fn interval_num(&self) -> u8 {
self.get_buf().get_u8_at(self.offset + 2)
}
#[inline]
pub fn rate_limit(&self) -> i64 {
self.get_buf().get_i64_at(self.offset + 3)
}
#[inline]
pub fn current(&self) -> i64 {
self.get_buf().get_i64_at(self.offset + 11)
}
}
}