message-queue: remove (*)

message-queue/src/main.rs

@@ -59,7 +59,7 @@ pub(crate) fn queue_message(
   sig: SchnorrSignature<Ristretto>,
 ) {
   {
-    let from = (*KEYS).read().unwrap()[&meta.from];
+    let from = KEYS.read().unwrap()[&meta.from];
     assert!(
       sig.verify(from, message_challenge(meta.from, from, meta.to, &meta.intent, &msg, sig.R))
     );
@@ -89,7 +89,7 @@ pub(crate) fn queue_message(
   DbTxn::put(&mut txn, intent_key, []);
 
   // Queue it
-  let id = (*QUEUES).read().unwrap()[&(meta.from, meta.to)].write().unwrap().queue_message(
+  let id = QUEUES.read().unwrap()[&(meta.from, meta.to)].write().unwrap().queue_message(
     &mut txn,
     QueuedMessage {
       from: meta.from,
@@ -113,7 +113,7 @@ pub(crate) fn queue_message(
   should be no sensitive data on this server.
 */
 pub(crate) fn get_next_message(from: Service, to: Service) -> Option<QueuedMessage> {
-  let queue_outer = (*QUEUES).read().unwrap();
+  let queue_outer = QUEUES.read().unwrap();
   let queue = queue_outer[&(from, to)].read().unwrap();
   let next = queue.last_acknowledged().map(|i| i + 1).unwrap_or(0);
   queue.get_message(next)
@@ -126,7 +126,7 @@ pub(crate) fn get_next_message(from: Service, to: Service) -> Option<QueuedMessa
 */
 pub(crate) fn ack_message(from: Service, to: Service, id: u64, sig: SchnorrSignature<Ristretto>) {
   {
-    let to_key = (*KEYS).read().unwrap()[&to];
+    let to_key = KEYS.read().unwrap()[&to];
     assert!(sig.verify(to_key, ack_challenge(to, to_key, from, id, sig.R)));
   }
 
@@ -139,7 +139,7 @@ pub(crate) fn ack_message(from: Service, to: Service, id: u64, sig: SchnorrSigna
 
   log::info!("Acknowledging From: {:?} To: {:?} ID: {}", from, to, id);
 
-  (*QUEUES).read().unwrap()[&(from, to)].write().unwrap().ack_message(id)
+  QUEUES.read().unwrap()[&(from, to)].write().unwrap().ack_message(id)
 }
 
 #[tokio::main(flavor = "current_thread")]
@@ -186,8 +186,8 @@ async fn main() {
   };
 
   let register_service = |service, key| {
-    (*KEYS).write().unwrap().insert(service, key);
-    let mut queues = (*QUEUES).write().unwrap();
+    KEYS.write().unwrap().insert(service, key);
+    let mut queues = QUEUES.write().unwrap();
     if service == Service::Coordinator {
       for network in serai_primitives::NETWORKS {
         if network == NetworkId::Serai {