Method parse_message

crates/buttplug_server/src/server.rs:242–322

Sends a [ButtplugClientMessage] to be parsed by the server (for handshake or ping), or passed into the server's [DeviceManager] for communication with devices.

(
    &self,
    msg: ButtplugClientMessageVariant,
  )

  /// Sends a [ButtplugClientMessage] to be parsed by the server (for handshake or ping), or passed
  /// into the server's [DeviceManager] for communication with devices.
  pub fn parse_message(
    &self,
    msg: ButtplugClientMessageVariant,
  ) -> BoxFuture<'static, Result<ButtplugServerMessageVariant, ButtplugServerMessageVariant>> {
    let features = self.device_manager().feature_map();
    let msg_id = msg.id();
    trace!("Server received: {:?}", msg);
    let v = msg.version();
    let spec_version = if let Some(current_version) = self.spec_version() {
      current_version
    } else {
      info!("Setting Buttplug Server Message Spec version to {}", v);
      v
    };
    match msg {
      ButtplugClientMessageVariant::V4(msg) => {
        let internal_msg =
          match ButtplugCheckedClientMessageV4::try_from_client_message(msg, &features) {
            Ok(m) => m,
            Err(e) => {
              let mut err_msg = ErrorV0::from(e);
              err_msg.set_id(msg_id);
              return future::ready(Err(ButtplugServerMessageVariant::from(
                ButtplugServerMessageV4::from(err_msg),
              )))
              .boxed();
            }
          };
        let fut = self.parse_checked_message(internal_msg);
        async move {
          Ok(
            fut
              .await
              .map_err(|e| ButtplugServerMessageVariant::from(ButtplugServerMessageV4::from(e)))?
              .into(),
          )
        }
        .boxed()
      }
      msg => {
        let converter = ButtplugServerMessageConverter::new(Some(msg.clone()));
        match ButtplugCheckedClientMessageV4::try_from_client_message(msg, &features) {
          Ok(converted_msg) => {
            trace!("Converted message: {:?}", converted_msg);
            let fut = self.parse_checked_message(converted_msg);
            async move {
              let result = fut.await.map_err(|e| {
                converter
                  .convert_outgoing(&e.into(), &spec_version)
                  .unwrap()
              })?;
              let out_msg = converter
                .convert_outgoing(&result, &spec_version)
                .map_err(|e| {
                  converter
                    .convert_outgoing(
                      &ButtplugServerMessageV4::from(ErrorV0::from(e)),
                      &spec_version,