// Buttplug Rust Source Code File - See https://buttplug.io for more info.
//
// Copyright 2016-2024 Nonpolynomial Labs LLC. All rights reserved.
//
// Licensed under the BSD 3-Clause license. See LICENSE file in the project root
// for full license information.

mod util;
/*
// The tests in this file can fail on CI if there isn't a timed retry. Seems to work reliably on
// windows, so lock it to that platform for now.
#[cfg(all(feature = "websockets", target_os = "windows"))]
mod websocket_connector_tests {
  use crate::util::ButtplugTestServer;
  use buttplug::{
    client::ButtplugClient,
    core::{
      connector::{
        ButtplugRemoteClientConnector,
        ButtplugRemoteServerConnector,
        ButtplugWebsocketClientTransport,
        ButtplugWebsocketServerTransport,
        ButtplugWebsocketServerTransportBuilder,
      },
      message::serializer::{ButtplugClientJSONSerializer, ButtplugServerJSONSerializer},
    },
    util::async_manager,
  };
  use std::{sync::Arc, time::Duration};
  use tokio::time::sleep;

  #[tokio::test]
  async fn test_client_ws_client_server_ws_server_insecure() {
    let test_server = ButtplugTestServer::default();
    let server = Arc::new(test_server);
    let server_clone = server.clone();
    async_manager::spawn(async move {
      let connector = ButtplugRemoteServerConnector::<
        ButtplugWebsocketServerTransport,
        ButtplugServerJSONSerializer,
      >::new(
        ButtplugWebsocketServerTransportBuilder::default()
          .port(12349)
          .finish(),
      );
      server_clone
        .start(connector)
        .await
        .expect("Test, assuming infallible.");
    });
    let mut connected = false;
    for _ in 0..10u8 {
      let connector = ButtplugRemoteClientConnector::<
        ButtplugWebsocketClientTransport,
        ButtplugClientJSONSerializer,
      >::new(ButtplugWebsocketClientTransport::new_insecure_connector(
        "ws://127.0.0.1:12349",
      ));

      let client = ButtplugClient::new("Test Client");
      if client.connect(connector).await.is_ok() {
        connected = true;
        break;
      }
      sleep(Duration::from_secs(1)).await;
    }
    assert!(connected);
    server
      .disconnect()
      .await
      .expect("Test, assuming infallible.");
  }

  #[tokio::test]
  async fn test_client_ws_server_server_ws_client_insecure() {
    let test_server = ButtplugTestServer::default();
    let server = Arc::new(test_server);
    let server_clone = server.clone();
    async_manager::spawn(async move {
      let connector = ButtplugRemoteServerConnector::<
        ButtplugWebsocketClientTransport,
        ButtplugServerJSONSerializer,
      >::new(ButtplugWebsocketClientTransport::new_insecure_connector(
        "ws://127.0.0.1:12347",
      ));
      server_clone
        .start(connector)
        .await
        .expect("Test, assuming infallible.");
    });

    let mut connected = false;
    for _ in 0..10u8 {
      let connector = ButtplugRemoteClientConnector::<
        ButtplugWebsocketServerTransport,
        ButtplugClientJSONSerializer,
      >::new(
        ButtplugWebsocketServerTransportBuilder::default()
          .port(12347)
          .finish(),
      );

      let client = ButtplugClient::new("Test Client");
      if client.connect(connector).await.is_ok() {
        connected = true;
        break;
      }
      sleep(Duration::from_secs(1)).await;
    }
    assert!(connected);
    server
      .disconnect()
      .await
      .expect("Test, assuming infallible.");
  }
}

// TODO Test disconnection event from server side
*/