refactor(processors): parralelize dojo events by world (#368)

Author: Larkooo

crates/processors/src/processors/event_message.rs

@@ -34,6 +34,7 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         let keys = Vec::<Felt>::cairo_deserialize(&event.data, 0).unwrap_or_else(|e| {
             panic!("Expected EventEmitted keys to be well formed: {:?}", e);
         });
@@ -47,6 +48,7 @@ where
 
     fn task_dependencies(&self, event: &Event) -> Vec<TaskId> {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         // selector
         event.keys[1].hash(&mut hasher);
         vec![hasher.finish()]

crates/processors/src/processors/register_event.rs

@@ -52,6 +52,7 @@ where
         };
 
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         selector.hash(&mut hasher);
         hasher.finish()
     }

crates/processors/src/processors/register_model.rs

@@ -56,6 +56,7 @@ where
         };
 
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         selector.hash(&mut hasher);
         hasher.finish()
     }

crates/processors/src/processors/store_del_record.rs

@@ -30,13 +30,15 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         event.keys[1].hash(&mut hasher);
         event.keys[2].hash(&mut hasher);
         hasher.finish()
     }
 
     fn task_dependencies(&self, event: &Event) -> Vec<TaskId> {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         event.keys[1].hash(&mut hasher); // Use the model selector to create a unique ID
         vec![hasher.finish()] // Return the dependency on the register_model task
     }

crates/processors/src/processors/store_set_record.rs

@@ -32,13 +32,15 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         event.keys[1].hash(&mut hasher);
         event.keys[2].hash(&mut hasher);
         hasher.finish()
     }
 
     fn task_dependencies(&self, event: &Event) -> Vec<TaskId> {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         event.keys[1].hash(&mut hasher); // Use the model selector to create a unique ID
         vec![hasher.finish()] // Return the dependency on the register_model task
     }

crates/processors/src/processors/store_update_member.rs

@@ -35,6 +35,7 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         // model selector
         event.keys[1].hash(&mut hasher);
         // entity id
@@ -44,6 +45,7 @@ where
 
     fn task_dependencies(&self, event: &Event) -> Vec<TaskId> {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         event.keys[1].hash(&mut hasher); // Use the model selector to create a unique ID
         vec![hasher.finish()] // Return the dependency on the register_model task
     }

crates/processors/src/processors/store_update_record.rs

@@ -33,6 +33,7 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         // model selector
         event.keys[1].hash(&mut hasher);
         // entity id
@@ -42,6 +43,7 @@ where
 
     fn task_dependencies(&self, event: &Event) -> Vec<TaskId> {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         event.keys[1].hash(&mut hasher); // Use the model selector to create a unique ID
         vec![hasher.finish()] // Return the dependency on the register_model task
     }

crates/processors/src/processors/upgrade_event.rs

@@ -37,6 +37,7 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         event.keys[1].hash(&mut hasher); // Use the event selector to create a unique ID
         hasher.finish()
     }

crates/processors/src/processors/upgrade_model.rs

@@ -38,6 +38,7 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
+        event.from_address.hash(&mut hasher);
         event.keys[1].hash(&mut hasher); // Use the model selector to create a unique ID
         hasher.finish()
     }