working on discord RPC client

game/Cargo.toml

@@ -5,7 +5,16 @@ version = "0.1.0"
 edition = "2018"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
-
 [dependencies]
 cgmath = "0.18"
-discord-sdk = "0.1"
+discord-sdk = "0.1"
+tokio = { version = "1.0", features = ["macros", "rt-multi-thread"] }
+tracing = { version = "0.1", features = ["log"] }
+serde = { version = "1.0.126", features = ["derive"] }
+serde_json = "1.0.64"
+thiserror = "1.0"
+chrono = "0.4"
+
+[profile.release]
+lto = true
+codegen-units = 1

game/src/lib.rs

@@ -1,5 +1,7 @@
+#[macro_use]
+extern crate thiserror;
+
+mod utilities;
 
 /// The game entrypoint
-pub fn game_begin() {
-
-}
+pub fn game_begin() {}

game/src/utilities/discord.rs

@@ -1,9 +1,52 @@
 //! Discord Rich Presence utilities
 
-use discord_sdk::ds::{Discord, User, Wheel};
+use discord_sdk::{user::User, wheel::Wheel, Discord, DiscordApp, Subscriptions};
+use tracing::info;
+
+#[derive(Debug, Error)]
+pub enum DiscordError {
+    #[error(transparent)]
+    SdkError(#[from] discord_sdk::Error),
+    #[error(transparent)]
+    AwaitConnectionError(#[from] tokio::sync::watch::error::RecvError),
+}
 
 pub struct DiscordRpcClient {
     pub discord: Discord,
     pub user: User,
     pub wheel: Wheel,
-}
+}
+
+impl DiscordRpcClient {
+    pub async fn new(app_id: i64, subscriptions: Subscriptions) -> Result<Self, DiscordError> {
+        // Create a new wheel
+        let (wheel, handler) = Wheel::new(Box::new(|err| {
+            tracing::error!(error = ?err, "encountered an error");
+        }));
+        let mut user = wheel.user();
+
+        // Create the client
+        let discord = Discord::new(
+            DiscordApp::PlainId(app_id),
+            subscriptions,
+            Box::new(handler),
+        )?;
+
+        // Wait for the discord handshake
+        info!("Waiting for Discord client handshake");
+        user.0.changed().await?;
+        info!("Discord handshake success");
+
+        // Fetch the final user object
+        let user = match &*user.0.borrow() {
+            discord_sdk::wheel::UserState::Connected(u) => Ok(u.clone()),
+            discord_sdk::wheel::UserState::Disconnected(err) => Err(err),
+        }?;
+
+        Ok(Self {
+            discord,
+            user,
+            wheel,
+        })
+    }
+}

game/src/utilities/mod.rs

@@ -0,0 +1 @@
+pub mod discord;

rust-toolchain.toml

@@ -0,0 +1,2 @@
+[toolchain]
+channel = "beta"

wrapper/Cargo.toml

@@ -7,4 +7,5 @@ edition = "2018"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-game =  { version = "0.1", path = "../game"}
+game =  { version = "0.1", path = "../game"}
+tracing-subscriber = "0.2"

wrapper/src/main.rs

@@ -1,5 +1,9 @@
 use game::game_begin;
 
 fn main() {
+    // Enable logging
+    tracing_subscriber::fmt::init();
+
+    // Start the game
     game_begin();
 }