add coin_store_deletion_event info to event_to_coin_type map

rust/processor/src/db/postgres/models/fungible_asset_models/v2_fungible_asset_utils.rs

@@ -20,6 +20,34 @@ use serde::{Deserialize, Serialize};
 const FUNGIBLE_ASSET_LENGTH: usize = 32;
 const FUNGIBLE_ASSET_SYMBOL: usize = 10;
 
+#[derive(Serialize, Deserialize, Debug, Clone)]
+pub struct CoinStoreDeletionEvent {
+    pub coin_type: String,
+    pub event_handle_creation_address: String,
+    #[serde(deserialize_with = "deserialize_from_string")]
+    pub deleted_deposit_event_handle_creation_number: u64,
+    #[serde(deserialize_with = "deserialize_from_string")]
+    pub deleted_withdraw_event_handle_creation_number: u64,
+}
+
+impl CoinStoreDeletionEvent {
+    pub fn from_event(data_type: &str, data: &str, txn_version: i64) -> Option<Self> {
+        if data_type == "0x1::coin::CoinStoreDeletion" {
+            let coin_store_deletion: CoinStoreDeletionEvent = serde_json::from_str(data).unwrap_or_else(|_| {
+                tracing::error!(
+                    transaction_version = txn_version,
+                    data = data,
+                    "failed to parse event for coin store deletion"
+                );
+                panic!();
+            });
+            Some(coin_store_deletion)
+        } else {
+            None
+        }
+    }
+}
+
 #[derive(Serialize, Deserialize, Debug, Clone)]
 pub struct FeeStatement {
     #[serde(deserialize_with = "deserialize_from_string")]

rust/processor/src/processors/fungible_asset_processor.rs

@@ -60,6 +60,8 @@ use diesel::{
 use rayon::prelude::*;
 use std::fmt::Debug;
 use tracing::error;
+use crate::db::postgres::models::coin_models::coin_utils::EventGuidResource;
+use crate::db::postgres::models::fungible_asset_models::v2_fungible_asset_utils::CoinStoreDeletionEvent;
 
 pub struct FungibleAssetProcessor {
     connection_pool: ArcDbPool,
@@ -683,6 +685,27 @@ pub async fn parse_v2_coin(
                 fungible_asset_activities.push(gas_event);
             }
 
+            // The CoinStoreDeletionEvent, only need for v1 with migration
+            if let Some(_) = user_request {
+                let coin_store_deletion_event = events.iter().find_map(|event| {
+                    let event_type = event.type_str.as_str();
+                    CoinStoreDeletionEvent::from_event(event_type, &event.data, txn_version)
+                });
+                if let Some(coin_store_deletion) = coin_store_deletion_event {
+                    let addr = standardize_address(coin_store_deletion.event_handle_creation_address.as_str());
+                    let deposit_event_guid = EventGuidResource {
+                        addr: addr.clone(),
+                        creation_num: coin_store_deletion.deleted_deposit_event_handle_creation_number as i64,
+                    };
+                    let withdraw_event_guid = EventGuidResource {
+                        addr,
+                        creation_num: coin_store_deletion.deleted_withdraw_event_handle_creation_number as i64,
+                    };
+                    event_to_v1_coin_type.insert(deposit_event_guid, coin_store_deletion.coin_type.clone());
+                    event_to_v1_coin_type.insert(withdraw_event_guid, coin_store_deletion.coin_type);
+                };
+            }
+
             // Loop 3 to handle events and collect additional metadata from events for v2
             for (index, event) in events.iter().enumerate() {
                 if let Some(v1_activity) = RawFungibleAssetActivity::get_v1_from_event(

rust/processor/src/processors/parquet_processors/parquet_fungible_asset_activities_processor.rs

@@ -41,6 +41,9 @@ use chrono::NaiveDateTime;
 use kanal::AsyncSender;
 use serde::{Deserialize, Serialize};
 use std::{fmt::Debug, time::Duration};
+use crate::db::postgres::models::coin_models::coin_utils::CoinResource::CoinStoreDeletion;
+use crate::db::postgres::models::coin_models::coin_utils::EventGuidResource;
+use crate::db::postgres::models::fungible_asset_models::v2_fungible_asset_utils::CoinStoreDeletionEvent;
 
 #[derive(Clone, Debug, Deserialize, Serialize)]
 #[serde(deny_unknown_fields)]
@@ -318,6 +321,27 @@ async fn parse_activities(
                     .or_insert(1);
             }
 
+            // The CoinStoreDeletionEvent, only need for v1 with migration
+            if let Some(_) = user_request {
+                let coin_store_deletion_event = events.iter().find_map(|event| {
+                    let event_type = event.type_str.as_str();
+                    CoinStoreDeletionEvent::from_event(event_type, &event.data, txn_version)
+                });
+                if let Some(coin_store_deletion) = coin_store_deletion_event {
+                    let addr = standardize_address(coin_store_deletion.event_handle_creation_address.as_str());
+                    let deposit_event_guid = EventGuidResource {
+                        addr: addr.clone(),
+                        creation_num: coin_store_deletion.deleted_deposit_event_handle_creation_number as i64,
+                    };
+                    let withdraw_event_guid = EventGuidResource {
+                        addr,
+                        creation_num: coin_store_deletion.deleted_withdraw_event_handle_creation_number as i64,
+                    };
+                    event_to_v1_coin_type.insert(deposit_event_guid, coin_store_deletion.coin_type.clone());
+                    event_to_v1_coin_type.insert(withdraw_event_guid, coin_store_deletion.coin_type);
+                };
+            }
+
             // Loop to handle events and collect additional metadata from events for v2
             for (index, event) in events.iter().enumerate() {
                 if let Some(v1_activity) = RawFungibleAssetActivity::get_v1_from_event(