feat: add cache for complex queries

src/consts/cache.ts

@@ -0,0 +1 @@
+export const DEFAULT_CACHE_TIMEOUT = 5 * (60 * 1000); // 5min

src/consts/index.ts

@@ -0,0 +1 @@
+export * from './cache';

src/services/review-product.service.spec.ts

@@ -48,10 +48,14 @@ describe('ReviewProductService', () => {
     it('should return the average', async () => {
       connection
         .getRepository(ReviewProductEntity)
-        .createQueryBuilder('review_product')
-        .select('AVG(stars)', 'starasync s')
-        .where('state = :state', { state: 'Authorized' })
-        .getRawOne.mockImplementation(async () => ({ stars: 5 }));
+        // @ts-ignore
+        .createQueryBuilder.mockImplementation(() => ({
+          select: jest.fn().mockReturnThis(),
+          leftJoin: jest.fn().mockReturnThis(),
+          where: jest.fn().mockReturnThis(),
+          cache: jest.fn().mockReturnThis(),
+          getRawOne: jest.fn().mockImplementation(async () => ({ stars: 5 }))
+        }));
       await expect(resolver.getAvgStars()).resolves.toBe(5);
     });
   });
@@ -77,6 +81,7 @@ describe('ReviewProductService', () => {
           select: jest.fn().mockReturnThis(),
           leftJoin: jest.fn().mockReturnThis(),
           andWhere: jest.fn().mockReturnThis(),
+          cache: jest.fn().mockReturnThis(),
           getCount: jest.fn().mockImplementationOnce(async () => 1)
         }));
 
@@ -111,6 +116,7 @@ describe('ReviewProductService', () => {
           select: jest.fn().mockReturnThis(),
           leftJoin: jest.fn().mockReturnThis(),
           andWhere: jest.fn().mockReturnThis(),
+          cache: jest.fn().mockReturnThis(),
           getCount: jest.fn().mockImplementationOnce(async () => 0)
         }));
 
@@ -136,6 +142,7 @@ describe('ReviewProductService', () => {
           setParameters: jest.fn().mockReturnThis(),
           getParameters: jest.fn().mockReturnThis(),
           leftJoin: jest.fn().mockReturnThis(),
+          cache: jest.fn().mockReturnThis(),
           andWhere: jest.fn().mockReturnThis(),
           getRawMany: jest
             .fn()

src/services/review-product.service.ts

@@ -15,6 +15,7 @@ import {
 } from '@vendure/core';
 import { ReviewService } from '../helpers';
 import { ReviewProductStateTransitionEvent } from '../events';
+import { DEFAULT_CACHE_TIMEOUT } from '../consts';
 import { ListQueryOptions } from '@vendure/core/dist/common/types/common-types';
 
 @Injectable()
@@ -45,6 +46,7 @@ export class ReviewProductService extends ReviewService<
       .createQueryBuilder('review_product')
       .select('AVG(stars)', 'stars')
       .where('state = :state', { state: 'Authorized' })
+      .cache(DEFAULT_CACHE_TIMEOUT)
       .getRawOne();
     return stars ? stars : 0;
   }
@@ -112,6 +114,7 @@ export class ReviewProductService extends ReviewService<
         `productVariant.productId NOT IN (${customerReviewQb.getQuery()})`
       )
       .setParameters(customerReviewQb.getParameters())
+      .cache(DEFAULT_CACHE_TIMEOUT)
       .getRawMany<{
         productId: ID;
       }>();

src/services/review-store.service.test.ts

@@ -170,10 +170,14 @@ describe('ReviewStoreService', () => {
       it('should return the average', async () => {
         connection
           .getRepository(ReviewStoreEntity)
-          .createQueryBuilder('review_store')
-          .select('AVG(nps)', 'nps')
-          .where('state = :state', { state: 'Authorized' })
-          .getRawOne.mockImplementation(async () => ({ nps: 10 }));
+          // @ts-ignore
+          .createQueryBuilder.mockImplementation(() => ({
+            select: jest.fn().mockReturnThis(),
+            leftJoin: jest.fn().mockReturnThis(),
+            where: jest.fn().mockReturnThis(),
+            cache: jest.fn().mockReturnThis(),
+            getRawOne: jest.fn().mockImplementation(async () => ({ nps: 10 }))
+          }));
         await expect(resolver.getNPSAvg()).resolves.toBe(10);
       });
     });

src/services/review-store.service.ts

@@ -10,6 +10,7 @@ import {
   Customer
 } from '@vendure/core';
 import { ReviewService } from '../helpers';
+import { DEFAULT_CACHE_TIMEOUT } from '../consts';
 import { ReviewStoreStateTransitionEvent } from '../events';
 
 @Injectable()
@@ -48,6 +49,7 @@ export class ReviewStoreService extends ReviewService<
       .createQueryBuilder('review_store')
       .select('AVG(nps)', 'nps')
       .where('state = :state', { state: 'Authorized' })
+      .cache(DEFAULT_CACHE_TIMEOUT)
       .getRawOne();
     return nps ? nps : 0;
   }