Function main

examples/src/bin/application.rs:79–236

()

#[tokio::main]
async fn main() -> anyhow::Result<()> {
  println!("===========================================");
  println!("  Buttplug Rust Application Example");
  println!("===========================================\n");

  // Step 1: Create a client
  // The client name identifies your application to the server.
  let client = ButtplugClient::new("My Buttplug Application");

  // Step 2: Set up event handlers
  // Get the event stream BEFORE connecting to avoid missing events.
  let mut events = client.event_stream();

  tokio::spawn(async move {
    while let Some(event) = events.next().await {
      match event {
        ButtplugClientEvent::DeviceAdded(device) => {
          println!("[+] Device connected: {}", device.name());
        }
        ButtplugClientEvent::DeviceRemoved(info) => {
          println!("[-] Device disconnected: {}", info.name());
        }
        ButtplugClientEvent::ServerDisconnect => {
          println!("[!] Server connection lost!");
        }
        ButtplugClientEvent::Error(err) => {
          println!("[!] Error: {}", err);
        }
        _ => {}
      }
    }
  });

  // Step 3: Connect to the server
  println!("Connecting to Intiface Central...");
  let connector = ButtplugRemoteClientConnector::<
    ButtplugWebsocketClientTransport,
    ButtplugClientJSONSerializer,
  >::new(ButtplugWebsocketClientTransport::new_insecure_connector(
    "ws://127.0.0.1:12345",
  ));

  if let Err(e) = client.connect(connector).await {
    match e {
      ButtplugClientError::ButtplugConnectorError(error) => {
        println!("ERROR: Could not connect to Intiface Central!");
        println!("Make sure Intiface Central is running and the server is started.");
        println!("Default address: ws://127.0.0.1:12345");
        println!("Error: {}", error);
        return Ok(());
      }
      _ => return Err(e.into()),
    }
  }
  println!("Connected!\n");

  // Step 4: Scan for devices
  println!("Scanning for devices...");