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 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292
/// Iteration item for option values
///
/// An implementation needs to allow the user to get the value as a memory slice. This is trivial
/// for messages that are stored in serialized form. Implementations that store options
/// semantically (eg. as a `struct Block { n: usize, m: bool, szx: u8 }`) will typically make their
/// MessageOption large enough to contain serialized options, or heap-allocate for them.
pub trait MessageOption {
/// Numeric option number
///
/// See [OptionNumber] on how to interpret them.
fn number(&self) -> u16;
/// Obtain the option's raw value
///
/// This can be used directly for options with opaque value semantics; for other semantics, see
/// the [value_str]() and [value_uint]() helper methods.
#[doc(alias = "opaque")]
fn value(&self) -> &[u8];
/// Obtain the option's value as a text string, or None if the option contains invalid UTF-8.
///
/// Implementations can override this to reduce the string checking overhead if they already
/// have the value as a string internally.
#[doc(alias = "string")]
fn value_str(&self) -> Option<&str> {
core::str::from_utf8(self.value()).ok()
}
/// Obtain the option's value as a number following the `uint` [value
/// format](https://tools.ietf.org/html/rfc7252#section-3.2), or None if the option is too
/// long.
///
/// Implementations can override this to reduce conversion overhead if they already have a
/// numeric value internally as soon as U's type is replaced with an equally capable public num
/// trait.
#[doc(alias = "uint")]
fn value_uint<U>(&self) -> Option<U>
where
U: num_traits::sign::Unsigned + num_traits::ops::bytes::FromBytes,
U::Bytes: Sized + Default,
{
let mut bufarray: U::Bytes = Default::default();
let buf = bufarray.as_mut();
let buflen = buf.len();
let val = self.value();
if val.len() > buflen {
return None;
}
buf[buflen - val.len()..].copy_from_slice(val);
Some(U::from_be_bytes(&bufarray))
}
}
/// Marker trait that indicates that ReadableMessage::options are produced in ascending
/// sequence.
pub trait WithSortedOptions: ReadableMessage {}
/// A CoAP message whose code, options and payload can be read
pub trait ReadableMessage {
/// See [code](); also used with [MinimalWritableMessage::set_code()]
type Code: crate::numbers::Code;
/// Type of an individual option, indiciating its option number and value
type MessageOption<'a>: MessageOption
where
Self: 'a;
/// See [options]()
type OptionsIter<'a>: Iterator<Item = Self::MessageOption<'a>>
where
Self: 'a;
/// Get the code (request method or response code) of the message
///
/// See [Code] for its meaning.
fn code(&self) -> Self::Code;
/// Get the payload set in the message
///
/// This is necessarily empty for messages of some codes.
fn payload(&self) -> &[u8];
/// Produce all options in arbitrary order as an iterator
///
/// If your options are always produced in an ordered fashion, consider implementing the
/// ``WithSortedOptions`` trait as well. This should be the case for most CoAP
/// message backends. Examples of backends where it is not implemented are single-pass reads
/// over in-place decrypted OSCORE messages.
fn options(&self) -> Self::OptionsIter<'_>;
}
// It would be nice to have more type state in here (for headers, last option number and whether
// payload has been set); this is a first step that can easily wrap jnet and maybe gcoap. Taking
// the next step is likely to happen soon, given that jnet coap has already moved to type state.
/// A message that can be written to, creating a CoAP request or response.
///
/// This is the bare minimum a message needs to provide to be populated as a request or response by
/// a generic program; it is up to the program to ensure the valid sequence of operations:
///
/// * Exactly one call to `set_code`
/// * Any number of calls to `add_option`, with monotonically increasing option numbers
/// * Zero or one call to `set_payload`
///
/// Steps that can reasonably fail at runtime are fallible -- for example, a payload to be set may
/// simply not fit within the message size. Adding options in the wrong sequence is also an
/// expected source, when uncommon code paths are triggered together.
///
/// Other errors in the sequence, such as failure to call `set_code`, or adding an option after the
/// payload has been set, may be implemented in a panic. (When occurring in a fallible operation,
/// the implementation may also choose to report an error instead).
///
/// Failed operations may be retried (eg. with shorter values); the failed attempt must not have an
/// effect on the message.
///
/// Implementations may tolerate erroneous call sequences as long as they can produce messages that
/// are likely to match the caller's expectations -- no need to keep track of usage errors just to
/// produce correct errors. Users may wrap messages in dedicated checkers for more strictness.
pub trait MinimalWritableMessage {
/// Error type into which either of the other errors, as well as the errors for conversion of
/// the `Code` and `OptionNumber`, can be `.into()`ed.
///
/// For many implementations it can make sense to use a single error type for all of those, in
/// which case the From bounds are trivially fulfilled.
type UnionError: crate::error::RenderableOnMinimal
+ core::fmt::Debug
+ From<Self::AddOptionError>
+ From<Self::SetPayloadError>
+ From<<Self::Code as crate::numbers::Code>::Error>
+ From<<Self::OptionNumber as crate::numbers::OptionNumber>::Error>;
/// Error returned when an option can not be added (eg. for lack of space, or because an option
/// of a higher number or even the payload was already set)
type AddOptionError: crate::error::RenderableOnMinimal + core::fmt::Debug;
/// Error returned when setting the payload (eg. for lack of space)
type SetPayloadError: crate::error::RenderableOnMinimal + core::fmt::Debug;
type Code: crate::numbers::Code;
type OptionNumber: crate::numbers::OptionNumber;
fn set_code(&mut self, code: Self::Code);
/// Add an option to the message
///
/// Calls to this method need to happen in ascending numeric sequence.
///
/// This works on option values as they are encoded in messages. Under the aspect of [option
/// value formats](https://tools.ietf.org/html/rfc7252#section-3.2), this adds opaque options
/// (but may just as well be used for adding options in another format when they are
/// pre-encoded).
// completely ignoring error handling here, pending typestateification
fn add_option(
&mut self,
number: Self::OptionNumber,
value: &[u8],
) -> Result<(), Self::AddOptionError>;
// error handling as in add_option
fn set_payload(&mut self, data: &[u8]) -> Result<(), Self::SetPayloadError>;
/// Copy code, options and payload in from a readable message
///
/// Implementations can override this for cases where it can be done more efficiently than
/// iterating over the options and appending them.
fn set_from_message<M>(&mut self, msg: &M) -> Result<(), Self::UnionError>
where
M: ReadableMessage,
{
use crate::numbers::{Code, OptionNumber};
self.set_code(Self::Code::new(msg.code().into())?);
for opt in msg.options() {
self.add_option(Self::OptionNumber::new(opt.number())?, opt.value())?;
}
self.set_payload(msg.payload())?;
Ok(())
}
/// Shortcut for `add_option(self, number, value.as_bytes())`.
///
/// Implementations with type checked options can provide more efficient implementations (ie.
/// ones that don't need to UTF-8-check when they feed the resulting bytes back into a string
/// field), but must still accept string options via the generic
/// [`add_option()`](MinimalWritableMessage::add_option)
/// method.
fn add_option_str(
&mut self,
number: Self::OptionNumber,
value: &str,
) -> Result<(), Self::AddOptionError> {
self.add_option(number, value.as_bytes())
}
/// Shortcut for `add_option` on a buffer containing the uint encoded value
///
/// Implementations with type checked options can provide more efficient implementations (ie.
/// ones that don't need to decode the uint when reading it into a uint field), but must still
/// accept integer options via the generic [`add_option()`](MinimalWritableMessage::add_option)
/// method.
///
/// While the trait under U is hidden (pending the use of a more generic one num-types based
/// one), own implementations are not possible.
fn add_option_uint<U: num_traits::sign::Unsigned + num_traits::ops::bytes::ToBytes>(
&mut self,
number: Self::OptionNumber,
value: U,
) -> Result<(), Self::AddOptionError> {
// This would be much easier with https://github.com/rust-num/num-traits/issues/189 solved
let value = value.to_be_bytes();
let mut value = value.as_ref();
while let Some(&0) = value.first() {
value = &value[1..];
}
self.add_option(number, value)
}
}
/// A message that allows later manipulation of a once set payload, and later truncation.
///
/// This is a bit of an unsorted bag that needs further cleanup (FIXME) -- most of this is
/// motivated by block-wise and write-in-place. Might need a bit of reshape, possibly something
/// like a once-callable ``.write_payload(|d: &mut [u8]| { write_to(d); Ok(bytes_written)})``. Does
/// this need a hint of the length to allocate for implementations that don't pre-allocate the
/// message? Is 1024 a good enough value to not pass it?
///
/// The available_space is only needed where applications want to use up the last byte by not
/// zero-padding the Block2 option to its szx=0 equivalent.
///
/// Can that be efficiently be replaced with something like this, and can it be optimized down to
/// the hand-written counting-of-option-bytes that's involved in the use of available_space?
///
/// ```ignore
/// let mut m = allocated_message;
/// for szx in 6..0 {
/// snap = m.snapshot();
/// m.add_option(BLOCK2, ...);
/// m.add_option(..., ...);
///
/// if let Ok(_) = m.write_payload(|p| {
/// if (p.len() < 1 << (4 + szx)) {
/// return Err(());
/// }
///
/// let written = write_block(...);
///
/// Ok(written)
/// }) {
/// break;
/// } else {
/// m = m.revert_to(snap);
/// }
/// } else {
/// panic!("Allocated space doesn't even suffice for 16 byte payload");
/// }
/// ```
///
pub trait MutableWritableMessage: MinimalWritableMessage {
/// Number of bytes available for additional options, payload marker and payload
fn available_space(&self) -> usize;
/// Memory-map `len` bytes of the payload for writing
///
/// If a payload has been set previously, that payload will be available in the slice; in that
/// case, the caller must make sure to not exceed its length.
///
/// If no payload has been set previously, and the requested length exceeds the available
/// buffer space, the longest possible payload should be mapped.
///
/// It is a provided method for compatibility with older implementations; new ones should (and
/// ones without preallocated memory need to) implement this instead.
fn payload_mut_with_len(&mut self, len: usize) -> Result<&mut [u8], Self::SetPayloadError>;
/// Truncate an already-set payload to the given length; that payload must have been written to
/// before using [`MinimalWritableMessage::set_payload`], or with a suitable [`MutableWritableMessage::payload_mut_with_len`] call.
fn truncate(&mut self, len: usize) -> Result<(), Self::SetPayloadError>;
/// Apply a callback to all options in sequence
///
/// This is a possibly inefficient but generic way achieve "allocate first, set when done"
/// pattern typically found for options like ETag.
fn mutate_options<F>(&mut self, callback: F)
where
F: FnMut(Self::OptionNumber, &mut [u8]);
}
/// Marker trait that indicates that the sequence of calling set_code, add_option and set_payload
/// is not fixed. The sequence of calls only has meaning in that later set_code and set_payload
/// calls override earlier ones, and that add_option on the same option number are stored in their
/// sequence.
// FIXME: Look into whether there's any implementation where it'd make sense to only have some of
// the relaxation but not all (eg. all options must be out, then comes the code).
pub trait SeekWritableMessage {
// FIXME: Provide a more generic set_from_message that does not demand
// WithSortedOptions. It can even have just the same code.
}