feat(app): add entry count to cache table

Author: johnbchron

crates/site-app/src/pages/dashboard/cache.rs

@@ -7,8 +7,11 @@ use crate::{
     CacheItemLink, CreateCacheButton, DataTableRefreshButton,
     LockClosedHeroIcon,
   },
+  formatting_utils::ThousandsSeparated,
   hooks::OrgHook,
-  resources::cache::caches_in_org_query_scope,
+  resources::cache::{
+    caches_in_org_query_scope, entry_count_in_cache_query_scope,
+  },
 };
 
 #[island]
@@ -51,6 +54,7 @@ pub(super) fn CacheTable() -> impl IntoView {
         <thead>
           <th>"Name"</th>
           <th>"Visibility"</th>
+          <th>"Entry Count"</th>
         </thead>
         <Transition fallback=|| ()>
           { suspend }
@@ -62,6 +66,21 @@ pub(super) fn CacheTable() -> impl IntoView {
 
 #[component]
 fn CacheDataRow(cache: PvCache) -> impl IntoView {
+  let query_client = expect_context::<QueryClient>();
+
+  let entry_count_query_scope = entry_count_in_cache_query_scope();
+  let entry_count_key = move || cache.id;
+  let entry_count_resource =
+    query_client.resource(entry_count_query_scope, entry_count_key);
+  let entry_count_suspend = move || {
+    Suspend::new(async move {
+      match entry_count_resource.await {
+        Ok(count) => ThousandsSeparated(count).to_string().into_any(),
+        Err(_) => "[error]".into_any(),
+      }
+    })
+  };
+
   view! {
     <tr>
       <th scope="row"><CacheItemLink id=cache.id extra_class="text-link-primary"/></th>
@@ -71,6 +90,9 @@ fn CacheDataRow(cache: PvCache) -> impl IntoView {
           <LockClosedHeroIcon {..} class="size-4 stroke-base-11/75 stroke-[2.0]" />
         })}
       </td>
+      <td><Transition fallback=|| "[loading]">
+        { entry_count_suspend }
+      </Transition></td>
     </tr>
   }
 }

crates/site-app/src/resources/cache.rs

@@ -1,6 +1,6 @@
 use leptos::prelude::*;
 use leptos_fetch::{QueryClient, QueryScope};
-use models::{dvf::RecordId, model::Model, Cache, Org, PvCache};
+use models::{dvf::RecordId, model::Model, Cache, Entry, Org, PvCache};
 
 #[cfg(feature = "ssr")]
 use crate::resources::{authenticate, authorize_for_org};
@@ -122,3 +122,41 @@ pub async fn check_if_cache_name_is_available(
 
   Ok(!occupied)
 }
+
+pub fn entry_count_in_cache_query_scope(
+) -> QueryScope<RecordId<Cache>, Result<u32, ServerFnError>> {
+  QueryScope::new(count_entries_in_cache).with_invalidation_link(move |s| {
+    [
+      Cache::TABLE_NAME.to_string(),
+      s.to_string(),
+      Entry::TABLE_NAME.to_string(),
+    ]
+  })
+}
+
+#[server(prefix = "/api/sfn")]
+pub async fn count_entries_in_cache(
+  cache: RecordId<Cache>,
+) -> Result<u32, ServerFnError> {
+  use prime_domain::PrimeDomainService;
+
+  let prime_domain_service: PrimeDomainService = expect_context();
+  let cache = prime_domain_service
+    .fetch_cache_by_id(cache)
+    .await
+    .map_err(|e| {
+      tracing::error!("failed to fetch cache: {e}");
+      ServerFnError::new("internal error")
+    })?
+    .ok_or(ServerFnError::new("cache does not exist"))?;
+
+  authorize_for_org(cache.org)?;
+
+  prime_domain_service
+    .count_entries_in_cache(cache.id)
+    .await
+    .map_err(|e| {
+      tracing::error!("failed to count entries in cache ({}): {e}", cache.id);
+      ServerFnError::new("internal error")
+    })
+}