SuperMarioOdysseyOnline/smo-multi-rs
1
0
Fork 0
mirror of https://github.com/speyejack/smo-multi-rs.git synced 2025-10-05 23:52:48 +02:00
Code Issues Packages Projects Releases Wiki Activity

Add shine sync

Browse Source
This commit is contained in:
Jack Garrard
2022-08-08 04:03:29 -07:00
parent 909efd3425
commit c871faf89f
1 changed files with 16 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
src/coordinator.rs
View File

@@ -53,23 +53,14 @@ impl Coordinator {
Command::Packet(packet) => {
match &packet.data {
PacketData::Costume(_) => {
self.sync_all_shines().await;
// TODO Sync client
}
PacketData::Shine { shine_id, .. } => {
self.shine_bag.write().await.insert(*shine_id);
let client = self
.clients
.get(&packet.id)
.ok_or(SMOError::InvalidID(packet.id))?;
let client = client.clone();
client_sync_shines(
self.get_channel(&packet.id)?.clone(),
self.shine_bag.clone(),
packet.id,
&client,
)
.await?;
// self.client_sync_shines(&client).await;
tracing::info!("Got moon {shine_id}");
self.sync_all_shines().await?;
return Ok(true);
}
PacketData::Game {
@@ -251,7 +242,18 @@ impl Coordinator {
}
async fn sync_all_shines(&mut self) -> Result<()> {
unimplemented!()
for (guid, client) in &self.clients {
let channel = self.to_clients.get(guid).unwrap();
let sender_guid = Guid::default();
client_sync_shines(
channel.clone(),
self.shine_bag.clone(),
&sender_guid,
client,
)
.await?;
}
Ok(())
}
async fn broadcast(&mut self, mut p: Packet) -> Result<()> {