Initial work on lobbies + A clean up

1 files changed, 85 insertions, 0 deletions

diff --git a/src/matchmaking.rs b/src/matchmaking.rs
new file mode 100644
index 0000000..6844bc6
--- /dev/null
+++ b/src/matchmaking.rs
@@ -0,0 +1,85 @@
+
+use super::*;
+
+/// Access to the steam matchmaking interface
+pub struct Matchmaking {
+    pub(crate) mm: *mut sys::ISteamMatchmaking,
+    pub(crate) client: Arc<ClientInner>,
+}
+
+const CALLBACK_BASE_ID: i32 = 500;
+
+pub enum LobbyType {
+    Private,
+    FriendsOnly,
+    Public ,
+    Invisible,
+}
+
+#[derive(Debug)]
+pub struct LobbyId(u64);
+
+impl Matchmaking {
+
+    pub fn request_lobby_list<F>(&self, mut cb: F)
+        where F: FnMut(Result<Vec<LobbyId>, ()>) + 'static + Send + Sync // TODO
+    {
+        unsafe {
+            let api_call = sys::SteamAPI_ISteamMatchmaking_RequestLobbyList(self.mm);
+            Client::register_call_result::<sys::LobbyMatchList, _>(
+                &self.client, api_call, CALLBACK_BASE_ID + 10,
+                move |v, io_error| {
+                   cb(if io_error {
+                      Err(()) // TODO
+                   } else {
+                       let mut out = Vec::with_capacity(v.lobbies_matching as usize);
+                       for idx in 0 .. v.lobbies_matching {
+                           out.push(LobbyId(sys::SteamAPI_ISteamMatchmaking_GetLobbyByIndex(sys::steam_rust_get_matchmaking(), idx as _)));
+                       }
+                       Ok(out)
+                   })
+            });
+        }
+    }
+
+    pub fn create_lobby<F>(&self, ty: LobbyType, max_members: u32, mut cb: F)
+        where F: FnMut(Result<LobbyId, ()>) + 'static + Send + Sync
+    {
+        unsafe {
+            let ty = match ty {
+                LobbyType::Private => sys::LobbyType::Private,
+                LobbyType::FriendsOnly => sys::LobbyType::FriendsOnly,
+                LobbyType::Public => sys::LobbyType::Public,
+                LobbyType::Invisible => sys::LobbyType::Invisible,
+            };
+            let api_call = sys::SteamAPI_ISteamMatchmaking_CreateLobby(self.mm, ty, max_members as _);
+            Client::register_call_result::<sys::LobbyCreated, _>(
+                &self.client, api_call, CALLBACK_BASE_ID + 13,
+                move |v, io_error| {
+                    cb(if io_error || v.result != sys::SResult::Ok {
+                        Err(()) // TODO
+                    } else {
+                        Ok(LobbyId(v.lobby_steam_id))
+                    })
+            });
+        }
+    }
+}
+
+#[test]
+fn test_lobby() {
+    let client = Client::init().unwrap();
+    let mm = client.matchmaking();
+
+    mm.request_lobby_list(|v| {
+        println!("List: {:?}", v);
+    });
+    mm.create_lobby(LobbyType::Private, 4, |v| {
+        println!("Create: {:?}", v);
+    });
+
+    for _ in 0 .. 100 {
+        client.run_callbacks();
+        ::std::thread::sleep(::std::time::Duration::from_millis(100));
+    }
+}
\ No newline at end of file