From 65e79010de1e8b78aa697e5aa4d231d039c68287 Mon Sep 17 00:00:00 2001 From: mpw Date: Wed, 13 Sep 2023 00:11:50 -0300 Subject: [PATCH] add label with mint status --- api/src/events.rs | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/api/src/events.rs b/api/src/events.rs index e6b6fba..58d9c62 100644 --- a/api/src/events.rs +++ b/api/src/events.rs @@ -1,6 +1,7 @@ use hub_core::{ chrono::{DateTime, NaiveDateTime, Offset, Utc}, credits::{CreditsClient, TransactionId}, + metrics::KeyValue, prelude::*, producer::Producer, thiserror, @@ -775,15 +776,6 @@ impl Processor { let mut creation_status = NftCreationStatus::Completed; if let MintResult::Success(MintTransaction { signature, address }) = payload { - let now = Utc::now(); - let elapsed_millis = now - .signed_duration_since(collection_mint.created_at) - .num_milliseconds(); - - self.metrics - .mint_duration_ms_bucket - .record(elapsed_millis, &[]); - mint_history_am.status = Set(CreationStatus::Created); mint_history_am.tx_signature = Set(Some(signature.clone())); collection_mint_active_model.creation_status = Set(CreationStatus::Created); @@ -803,6 +795,15 @@ impl Processor { creation_status = NftCreationStatus::Failed; } + let now = Utc::now(); + let elapsed = now + .signed_duration_since(collection_mint.created_at) + .num_milliseconds(); + self.metrics.mint_duration_ms_bucket.record( + elapsed, + &[KeyValue::new("status", creation_status.as_str_name())], + ); + self.producer .send( Some(&NftEvents {