From 70563d87b66705bbb667462b84d58f21277041f9 Mon Sep 17 00:00:00 2001
From: arberkatellari <arberkatellari@live.com>
Date: Sun, 10 Aug 2025 09:26:37 +0200
Subject: [PATCH] Add cache handling for TrendProfile replication APIs

---
 apier/v1/replicator.go | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/apier/v1/replicator.go b/apier/v1/replicator.go
index 06180a5fa..eef731ae3 100644
--- a/apier/v1/replicator.go
+++ b/apier/v1/replicator.go
@@ -523,6 +523,10 @@ func (rplSv1 *ReplicatorSv1) SetTrendProfile(ctx *context.Context, sg *engine.Tr
 	if err = rplSv1.dm.DataDB().SetTrendProfileDrv(sg.TrendProfile); err != nil {
 		return
 	}
+	if err = rplSv1.v1.CallCache(utils.IfaceAsString(sg.APIOpts[utils.CacheOpt]),
+		sg.Tenant, utils.CacheTrendProfiles, sg.TenantID(), utils.EmptyString, nil, nil, sg.APIOpts); err != nil {
+		return
+	}
 	*reply = utils.OK
 	return
 }
@@ -1017,7 +1021,10 @@ func (rplSv1 *ReplicatorSv1) RemoveTrendProfile(ctx *context.Context, args *util
 	if err = rplSv1.dm.DataDB().RemTrendProfileDrv(args.Tenant, args.ID); err != nil {
 		return
 	}
-
+	if err = rplSv1.v1.CallCache(utils.IfaceAsString(args.APIOpts[utils.CacheOpt]),
+		args.Tenant, utils.CacheTrendProfiles, args.TenantIDConcatenated(), utils.EmptyString, nil, nil, args.APIOpts); err != nil {
+		return
+	}
 	*reply = utils.OK
 	return
 }