fmt

dojoengine · Sep 19, 2024 · f795c3a · f795c3a
1 parent 51d507b
commit f795c3a
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 34 deletions.
diff --git a/crates/torii/core/src/query_queue.rs b/crates/torii/core/src/query_queue.rs
@@ -115,10 +115,8 @@ impl QueryQueue {
                     .fetch_one(&mut *tx)
                     .await?;
                     let mut entity_updated = EntityUpdated::from_row(&row)?;
-                    entity_updated.updated_model = Some(Ty::Struct(Struct {
-                        name: entity.ty.name(),
-                        children: vec![],
-                    }));
+                    entity_updated.updated_model =
+                        Some(Ty::Struct(Struct { name: entity.ty.name(), children: vec![] }));
 
                     let count = sqlx::query_scalar::<_, i64>(
                         "SELECT count(*) FROM entity_model WHERE entity_id = ?",

diff --git a/crates/torii/grpc/src/server/mod.rs b/crates/torii/grpc/src/server/mod.rs
@@ -106,13 +106,11 @@ impl DojoWorld {
             Arc::clone(&state_diff_manager),
         ));
 
-        tokio::task::spawn(subscriptions::entity::Service::new(
-            Arc::clone(&entity_manager),
-        ));
+        tokio::task::spawn(subscriptions::entity::Service::new(Arc::clone(&entity_manager)));
 
-        tokio::task::spawn(subscriptions::event_message::Service::new(
-            Arc::clone(&event_message_manager),
-        ));
+        tokio::task::spawn(subscriptions::event_message::Service::new(Arc::clone(
+            &event_message_manager,
+        )));
 
         tokio::task::spawn(subscriptions::event::Service::new(Arc::clone(&event_manager)));
 

diff --git a/crates/torii/grpc/src/server/subscriptions/entity.rs b/crates/torii/grpc/src/server/subscriptions/entity.rs
@@ -82,19 +82,11 @@ pub struct Service {
 }
 
 impl Service {
-    pub fn new(
-        subs_manager: Arc<EntityManager>,
-    ) -> Self {
-        Self {
-            subs_manager,
-            simple_broker: Box::pin(SimpleBroker::<Entity>::subscribe()),
-        }
+    pub fn new(subs_manager: Arc<EntityManager>) -> Self {
+        Self { subs_manager, simple_broker: Box::pin(SimpleBroker::<Entity>::subscribe()) }
     }
 
-    async fn publish_updates(
-        subs: Arc<EntityManager>,
-        entity: &Entity,
-    ) -> Result<(), Error> {
+    async fn publish_updates(subs: Arc<EntityManager>, entity: &Entity) -> Result<(), Error> {
         let mut closed_stream = Vec::new();
         let hashed = Felt::from_str(&entity.id).map_err(ParseError::FromStr)?;
         let keys = entity
@@ -196,9 +188,7 @@ impl Service {
             let resp = proto::world::SubscribeEntityResponse {
                 entity: Some(proto::types::Entity {
                     hashed_keys: hashed.to_bytes_be().to_vec(),
-                    models: vec![
-                        model.into()
-                    ],
+                    models: vec![model.into()],
                 }),
                 subscription_id: *idx,
             };

diff --git a/crates/torii/grpc/src/server/subscriptions/event_message.rs b/crates/torii/grpc/src/server/subscriptions/event_message.rs
@@ -76,13 +76,8 @@ pub struct Service {
 }
 
 impl Service {
-    pub fn new(
-        subs_manager: Arc<EventMessageManager>,
-    ) -> Self {
-        Self {
-            subs_manager,
-            simple_broker: Box::pin(SimpleBroker::<EventMessage>::subscribe()),
-        }
+    pub fn new(subs_manager: Arc<EventMessageManager>) -> Self {
+        Self { subs_manager, simple_broker: Box::pin(SimpleBroker::<EventMessage>::subscribe()) }
     }
 
     async fn publish_updates(
@@ -174,9 +169,7 @@ impl Service {
             let resp = proto::world::SubscribeEntityResponse {
                 entity: Some(proto::types::Entity {
                     hashed_keys: hashed.to_bytes_be().to_vec(),
-                    models: vec![
-                        model.into()
-                    ],
+                    models: vec![model.into()],
                 }),
                 subscription_id: *idx,
             };