clear cache event

AplinkosMinisterija · Apr 10, 2024 · fce9748 · fce9748
1 parent c645412
commit fce9748
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 12 deletions.
diff --git a/services/fishStockings.service.ts b/services/fishStockings.service.ts
@@ -417,11 +417,6 @@ export type FishStocking<
       all: ['beforeSelect', 'handleSort'],
       export: ['beforeSelect', 'handleSort'],
     },
-    after: {
-      review: ['handleCache'],
-      updateFishStocking: ['handleCache'],
-      remove: ['handleCache'],
-    },
   },
   actions: {
     remove: {
@@ -1336,9 +1331,4 @@ export default class FishStockingsService extends moleculer.Service {
       );
     }
   }
-
-  @Method
-  async handleCache() {
-    await this.broker.cacher.clean('public.**');
-  }
 }
diff --git a/services/public.service.ts b/services/public.service.ts
@@ -2,10 +2,11 @@
 
 import { format } from 'date-fns';
 import moleculer, { Context } from 'moleculer';
-import { Action, Method, Service } from 'moleculer-decorators';
-import { RestrictionType } from '../types';
+import { Action, Event, Method, Service } from 'moleculer-decorators';
+import { EntityChangedParams, RestrictionType } from '../types';
 import { FishStocking } from './fishStockings.service';
 import { CompletedFishBatch, FishStockingsCompleted } from './fishStockingsCompleted.service';
+import { TenantUser } from './tenantUsers.service';
 
 const uetkStatisticsParams = {
   date: [
@@ -245,4 +246,14 @@ export default class FishAgesService extends moleculer.Service {
       return aggregate;
     }, {} as BatchesById);
   }
+
+  @Event()
+  async 'fishStockings.*'(ctx: Context<EntityChangedParams<TenantUser>>) {
+    switch (ctx.params.type) {
+      case 'create':
+      case 'update':
+      case 'remove':
+        await this.broker.cacher.clean('public.**');
+    }
+  }
 }