Method parse_checked_message

crates/buttplug_server/src/server.rs:324–406

(
    &self,
    msg: ButtplugCheckedClientMessageV4,
  )

  }

  pub fn parse_checked_message(
    &self,
    msg: ButtplugCheckedClientMessageV4,
  ) -> BoxFuture<'static, Result<ButtplugServerMessageV4, message::ErrorV0>> {
    trace!(
      "Buttplug Server {} received message to client parse: {:?}",
      self.server_name, msg
    );
    let id = msg.id();

    // Check connection state for message validity
    {
      let state = self.state.read().expect("State lock poisoned");
      let error = match &*state {
        ConnectionState::PingedOut => {
          // Connection lost due to ping timeout
          Some(message::ErrorV0::from(ButtplugError::from(
            ButtplugPingError::PingedOut,
          )))
        }
        ConnectionState::Disconnected => {
          // Already disconnected, no reconnection allowed
          Some(message::ErrorV0::from(ButtplugError::from(
            ButtplugHandshakeError::ReconnectDenied,
          )))
        }
        ConnectionState::AwaitingHandshake => {
          // Only RSI messages allowed before handshake
          if !matches!(msg, ButtplugCheckedClientMessageV4::RequestServerInfo(_)) {
            Some(message::ErrorV0::from(ButtplugError::from(
              ButtplugHandshakeError::RequestServerInfoExpected,
            )))
          } else {
            None
          }
        }
        ConnectionState::Connected { .. } => {
          // Connected, all messages allowed
          None
        }
      };
      if let Some(mut return_error) = error {
        return_error.set_id(msg.id());
        return future::ready(Err(return_error)).boxed();
      }
    }
    // Produce whatever future is needed to reply to the message, this may be a
    // device command future, or something the server handles. All futures will
    // return Result<ButtplugServerMessage, ButtplugError>, and we'll handle
    // tagging the result with the message id in the future we put out as the
    // return value from this method.
    let out_fut = if ButtplugDeviceManagerMessageUnion::try_from(msg.clone()).is_ok()
      || ButtplugDeviceCommandMessageUnionV4::try_from(msg.clone()).is_ok()
    {
      self.device_manager.parse_message(msg.clone())
    } else {
      match msg {
        ButtplugCheckedClientMessageV4::RequestServerInfo(rsi_msg) => {