Use cache for month txn

src/server/cache/transaction-cache.ts

@@ -0,0 +1,64 @@
+import { COLLECTION } from '@/types/database';
+import {
+  unstable_cacheLife as cacheLife,
+  unstable_cacheTag as cacheTag,
+  revalidateTag,
+} from 'next/cache';
+import { monthFilter } from '../utils/transaction-filters';
+import { aggregateSum, fetch } from '../firebase-admin/firestore';
+
+/**
+ * Cache keys
+ */
+const getTxnByMonthYearKey = (userId: string, month: number, year: number) =>
+  `transactions-month-year-${userId}-${month}-${year}`;
+
+const getMontlyTxnSumKey = (userId: string, month: number, year: number) =>
+  `monthly-sum-${userId}-${month}-${year}`;
+
+/**
+ * Cache flush methods
+ */
+export const clearMonthYearTxnCache = (
+  userId: string,
+  month: number,
+  year: number
+) => {
+  revalidateTag(getTxnByMonthYearKey(userId, month, year));
+  revalidateTag(getMontlyTxnSumKey(userId, month, year));
+};
+
+/**
+ * Cache methods
+ */
+export const getTxnByMonthYearCache = async (
+  userId: string,
+  month: number,
+  year: number
+) => {
+  'use cache';
+  cacheTag(getTxnByMonthYearKey(userId, month, year));
+  cacheLife('max');
+
+  return fetch({
+    userId,
+    collection: COLLECTION.TRANSACTIONS,
+    conditions: monthFilter(month, year),
+  });
+};
+
+export const getMonthTotalSumCache = async (
+  userId: string,
+  month: number,
+  year: number
+) => {
+  'use cache';
+  cacheTag(getMontlyTxnSumKey(userId, month, year));
+  cacheLife('max');
+
+  return await aggregateSum({
+    userId,
+    collection: COLLECTION.TRANSACTIONS,
+    conditions: monthFilter(month, year),
+  });
+};

src/server/services/transaction-service.ts

@@ -1,57 +1,26 @@
-import { COLLECTION, TCondition } from '@/types/database';
+import { COLLECTION } from '@/types/database';
 import { TCardTransactionForm } from '@/types/form';
 import { TRPCError } from '@trpc/server';
 import { UserRecord } from 'firebase-admin/auth';
 import {
   addToCollection,
-  aggregateSum,
   fetch,
   fetchExists,
 } from '../firebase-admin/firestore';
 import { MONTHS } from '@/app/constants';
+import { cardFilter, monthFilter } from '../utils/transaction-filters';
 import {
-  unstable_cacheLife as cacheLife,
-  unstable_cacheTag as cacheTag,
-  revalidateTag,
-} from 'next/cache';
-import { getMontlySumCacheKey } from '../utils/cache';
-
-const monthFilter = (
-  month: number,
-  year: number
-): TCondition<COLLECTION.TRANSACTIONS>[] => {
-  const startDate = new Date(year, month, 1).getTime();
-  const endDate = new Date(year, month + 1, 1).getTime();
-  return [
-    {
-      fieldPath: 'date',
-      opStr: '>=',
-      value: startDate,
-    },
-    {
-      fieldPath: 'date',
-      opStr: '<',
-      value: endDate,
-    },
-  ];
-};
-
-const cardFilter = (cardId: string): TCondition<COLLECTION.TRANSACTIONS> => ({
-  fieldPath: 'cardId',
-  opStr: '==',
-  value: cardId,
-});
+  clearMonthYearTxnCache,
+  getMonthTotalSumCache,
+  getTxnByMonthYearCache,
+} from '../cache/transaction-cache';
 
 export const getTransactionsByMonthYear = async (
   user: UserRecord,
   month: number,
   year: number
 ) => {
-  return fetch({
-    userId: user.uid,
-    collection: COLLECTION.TRANSACTIONS,
-    conditions: monthFilter(month, year),
-  });
+  return getTxnByMonthYearCache(user.uid, month, year);
 };
 
 export const getPaginatedTransactions = async (
@@ -68,22 +37,6 @@ export const getPaginatedTransactions = async (
   });
 };
 
-const getMonthTotalSumCache = async (
-  userId: string,
-  month: number,
-  year: number
-) => {
-  'use cache';
-  cacheTag(getMontlySumCacheKey(userId, month, year));
-  cacheLife('max');
-
-  return await aggregateSum({
-    userId,
-    collection: COLLECTION.TRANSACTIONS,
-    conditions: monthFilter(month, year),
-  });
-};
-
 export const getAnnualSummary = async (user: UserRecord, year: number) => {
   const promises = MONTHS.map(async (month) => {
     const sum = await getMonthTotalSumCache(user.uid, month.value, year);
@@ -116,7 +69,5 @@ export const saveTransaction = async (
 
   await addToCollection(user, COLLECTION.TRANSACTIONS, transaction);
 
-  revalidateTag(
-    getMontlySumCacheKey(user.uid, date.getMonth(), date.getFullYear())
-  );
+  clearMonthYearTxnCache(user.uid, date.getMonth(), date.getFullYear());
 };

src/server/utils/transaction-filters.ts

@@ -0,0 +1,29 @@
+import { COLLECTION, TCondition } from '@/types/database';
+
+export const monthFilter = (
+  month: number,
+  year: number
+): TCondition<COLLECTION.TRANSACTIONS>[] => {
+  const startDate = new Date(year, month, 1).getTime();
+  const endDate = new Date(year, month + 1, 1).getTime();
+  return [
+    {
+      fieldPath: 'date',
+      opStr: '>=',
+      value: startDate,
+    },
+    {
+      fieldPath: 'date',
+      opStr: '<',
+      value: endDate,
+    },
+  ];
+};
+
+export const cardFilter = (
+  cardId: string
+): TCondition<COLLECTION.TRANSACTIONS> => ({
+  fieldPath: 'cardId',
+  opStr: '==',
+  value: cardId,
+});