Merge pull request #261 from holaplex/espi/debu-loging-count-caches

test: add logs to help debug redis lookup errors
holaplex · Oct 18, 2023 · 37a2a0e · 37a2a0e
2 parents 7082d89 + 512fea9
commit 37a2a0e
Showing 1 changed file with 20 additions and 0 deletions.
diff --git a/api/src/dataloaders/collection.rs b/api/src/dataloaders/collection.rs
@@ -1,6 +1,7 @@
 use std::collections::HashMap;
 
 use async_graphql::{dataloader::Loader as DataLoader, FieldError, Result};
+use hub_core::tracing::info;
 use poem::async_trait;
 use redis::{AsyncCommands, Client as Redis};
 use sea_orm::{prelude::*, FromQueryResult, QueryFilter, QuerySelect};
@@ -76,8 +77,13 @@ impl DataLoader<Uuid> for TotalMintsLoader {
 
         for key in keys {
             let redis_key = format!("collection:{key}:total_mints");
+            info!("total mints loader - get: redis_key: {}", redis_key);
             match redis_connection.get::<_, i64>(&redis_key).await {
                 Ok(value) => {
+                    info!(
+                        "total mints loader - get: redis_key: {} value: {:?}",
+                        redis_key, value
+                    );
                     results.insert(*key, value);
                 },
                 Err(_) => {
@@ -113,6 +119,11 @@ impl DataLoader<Uuid> for TotalMintsLoader {
             let count = count_results.get(&key).copied().unwrap_or_default();
             let redis_key = format!("collection:{key}:total_mints");
 
+            info!(
+                "total mints loader - insert: redis_key: {} count: {:?}",
+                redis_key, count
+            );
+
             redis_connection
                 .set::<_, i64, Option<i64>>(&redis_key, count)
                 .await?;
@@ -156,8 +167,13 @@ impl DataLoader<Uuid> for SupplyLoader {
 
         for key in keys {
             let redis_key = format!("collection:{key}:supply");
+            info!("supply loader - get: redis_key: {}", redis_key);
             match redis_connection.get::<_, Option<i64>>(&redis_key).await {
                 Ok(value) => {
+                    info!(
+                        "supply loader - get: redis_key: {} value: {:?}",
+                        redis_key, value
+                    );
                     results.insert(*key, value);
                 },
                 Err(_) => {
@@ -217,6 +233,10 @@ impl DataLoader<Uuid> for SupplyLoader {
         for key in computed_supplies {
             let count = count_results.get(&key).copied();
             let redis_key = format!("collection:{key}:supply");
+            info!(
+                "supply loader - insert: redis_key: {} count: {:?}",
+                redis_key, count
+            );
 
             redis_connection
                 .set::<_, Option<i64>, Option<i64>>(&redis_key, count)