origin-sdk 0.2.0

use origin_sdk::{
    protocol::{
        game::GetAllGameInfo,
        profile::GetProfile,
        system::{GetConfig, GetInternetConnectedState},
    },
    sdk::{ClientConfig, OriginSdk, ORIGIN_SDK_PORT},
};
use std::error::Error;
use tracing::info;
use tracing_subscriber::{fmt, EnvFilter};

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    fmt()
        .with_env_filter(EnvFilter::new("trace"))
        .try_init()
        .unwrap();

    // This configuration defines the game to the Origin SDK server
    let game = ClientConfig {
        content_id: "Origin.OFR.50.0001000".to_string(),
        language: "en_US".to_string(),
        multiplayer_id: "1026480".to_string(),
        title: "Mirror's Edge™ Catalyst".to_string(),
        version_override: None,
    };

    // Connect to the Origin SDK server at the given address
    // Returns a client handle for sending requests and a channel for receiving events
    let (client, mut event_rx) = OriginSdk::connect(game, ORIGIN_SDK_PORT).await?;

    // Spawn a background task that continuously listens for server events
    // and logs them. Keeps the main thread free to send requests
    let _event_handle = tokio::spawn(async move {
        while let Some(event) = event_rx.recv().await {
            info!("Received event from channel");
            info!("{:#?}", event);
        }
    });

    // Query whether the SDK reports an active internet connection
    let state = client.request(GetInternetConnectedState {}).await?;
    info!("Connected to the internet?: {}", state.connected);

    // Fetch the first user profile (index 0 = current user)
    let profile = client.request(GetProfile { index: 0 }).await?;
    info!("Profile: {:#?}", profile);

    // Fetch Service -> Facility configuration.
    // This would be used to determine which facilities to send requests to,
    // but EA Desktop uses "EbisuSDK" for all its services
    let config = client.request(GetConfig {}).await?;
    info!("Config: {:#?}", config);

    let res = client.request(GetAllGameInfo {}).await?;
    info!("Games: {:#?}", res);

    // Block until Ctrl+C is pressed. This keeps the process alive
    // so background event handling continues until user termination
    tokio::signal::ctrl_c().await?;

    Ok(())
}