replace dashmap with hashmap

indexer/Cargo.toml

@@ -25,7 +25,6 @@ solana-program = "1.14"
 anchor-lang = "0.26.0"
 yellowstone-grpc-client = { git = "https://github.com/rpcpool/yellowstone-grpc", tag = "v1.7.1+solana.1.16.1" }
 yellowstone-grpc-proto = { git = "https://github.com/rpcpool/yellowstone-grpc", tag = "v1.7.1+solana.1.16.1" }
-dashmap = "5.4.0"
 spl-token = "=3.5.0"
 solana-client = "1.14"
 backoff = { version = "0.4.0", features = ["tokio"] }

indexer/src/handler.rs

@@ -1,6 +1,5 @@
 use std::sync::Arc;
 
-use dashmap::DashMap;
 use futures::{sink::SinkExt, stream::StreamExt};
 use holaplex_hub_nfts_solana_core::{db::Connection, proto::SolanaNftEvents};
 use hub_core::{
@@ -64,7 +63,7 @@ impl MessageHandler {
     async fn connect(&self, request: SubscribeRequest) -> Result<()> {
         (|| async {
             let (mut subscribe_tx, mut stream) = self.connector.subscribe().await?;
-            let dashmap = DashMap::new();
+            let mut hashmap = std::collections::HashMap::new();
             subscribe_tx
                 .send(request.clone())
                 .await
@@ -74,10 +73,10 @@ impl MessageHandler {
                 match message {
                     Ok(msg) => match msg.update_oneof {
                         Some(UpdateOneof::Transaction(tx)) => {
-                            dashmap.entry(tx.slot).or_insert(Vec::new()).push(tx);
+                            hashmap.entry(tx.slot).or_insert(Vec::new()).push(tx);
                         },
                         Some(UpdateOneof::Slot(slot)) => {
-                            if let Some((_, transactions)) = dashmap.remove(&slot.slot) {
+                            if let Some(transactions) = hashmap.remove(&slot.slot) {
                                 for tx in transactions {
                                     self.tx.send(tx)?;
                                 }