wtx 0.50.0

A collection of different transport implementations and related tools focused primarily on web technologies.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

// https://datatracker.ietf.org/doc/html/rfc7301

use crate::{
  codec::{Decode, Encode},
  collections::ArrayVectorCopy,
  misc::counter_writer::{CounterWriterBytesTy, CounterWriterIterTy, u8_write, u16_write_iter},
  tls::{
    MAX_ALPN_LEN, TlsError,
    de::De,
    misc::{u8_chunk, u16_chunk},
    tls_decode_wrapper::TlsDecodeWrapper,
    tls_encode_wrapper::TlsEncodeWrapper,
  },
};

/// Application-Layer Protocol Negotiation Extension
///
/// <https://datatracker.ietf.org/doc/html/rfc7301>
#[derive(Clone, Debug, Default)]
pub struct Alpn {
  /// List of names
  pub protocol_name_list: ArrayVectorCopy<ArrayVectorCopy<u8, 8>, MAX_ALPN_LEN>,
}

impl<'de> Decode<'de, De> for Alpn {
  #[inline]
  fn decode(dw: &mut TlsDecodeWrapper<'de>) -> crate::Result<Self> {
    let err = TlsError::InvalidOfferedPsks;
    let mut protocol_name_list = ArrayVectorCopy::new();
    u16_chunk(dw, err, |local_dw| {
      while !local_dw.bytes().is_empty() {
        u8_chunk(local_dw, err, |local_local_dw| {
          protocol_name_list.push(local_local_dw.bytes().try_into()?)?;
          Ok(())
        })?;
      }
      Ok(())
    })?;
    Ok(Self { protocol_name_list })
  }
}

impl Encode<De> for Alpn {
  #[inline]
  fn encode(&self, ew: &mut TlsEncodeWrapper<'_>) -> crate::Result<()> {
    u16_write_iter(
      CounterWriterIterTy::Bytes(CounterWriterBytesTy::IgnoresLen),
      self.protocol_name_list.iter(),
      None,
      ew,
      |elem, local_ew| {
        u8_write(CounterWriterBytesTy::IgnoresLen, None, local_ew, |local_local_ew| {
          local_local_ew.buffer().extend_from_copyable_slice(elem)?;
          crate::Result::Ok(())
        })
      },
    )?;
    Ok(())
  }
}