From d5777c0020afeb163ef1e22b7eebdf151785afe5 Mon Sep 17 00:00:00 2001
From: Samuele Locatelli <samuele@steamware.net>
Date: Thu, 15 Sep 2022 17:43:52 +0200
Subject: [PATCH] =?UTF-8?q?REDIS:=20-=20fix=20cache=20selezione=20flussi?=
 =?UTF-8?q?=20da=20macchina=20-=20rimosse=20modalit=C3=A0=20async=20lettur?=
 =?UTF-8?q?a/Scrittura=20redis?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 MP.SPEC/Data/MpDataService.cs | 18 +++++-------------
 1 file changed, 5 insertions(+), 13 deletions(-)

diff --git a/MP.SPEC/Data/MpDataService.cs b/MP.SPEC/Data/MpDataService.cs
index ee4f30bb..b20103a6 100644
--- a/MP.SPEC/Data/MpDataService.cs
+++ b/MP.SPEC/Data/MpDataService.cs
@@ -446,35 +446,27 @@ namespace MP.SPEC.Data
             Stopwatch stopWatch = new Stopwatch();
             stopWatch.Start();
             string readType = "DB";
-
-            result = await Task.FromResult(dbController.ParametriGetFilt(IdxMacchina));
-
-#if false
-            // 2 minuti valore cache
+            // 5 minuti valore cache
             int maxAgeMin = 5;
             string currKey = $"{redisFluxByMac}:{IdxMacchina}";
-
             // cerco in redis dato valore sel macchina...
-            RedisValue rawData = await redisDb.StringGetAsync(currKey);
-            if (!string.IsNullOrEmpty($"{rawData}"))
+            RedisValue rawData = redisDb.StringGet(currKey);
+            if (rawData.HasValue)
             {
                 result = JsonConvert.DeserializeObject<List<string>>($"{rawData}");
-                stopWatch.Stop();
-                TimeSpan ts = stopWatch.Elapsed;
-                Log.Debug($"ParametriGetFilt | Read from REDIS: {ts.TotalMilliseconds}ms");
+                readType = "REDIS";
             }
             else
             {
                 result = await Task.FromResult(dbController.ParametriGetFilt(IdxMacchina));
                 // serializzp e salvo...
                 rawData = JsonConvert.SerializeObject(result);
-                await redisDb.StringSetAsync(currKey, rawData, TimeSpan.FromMinutes(maxAgeMin));
+                redisDb.StringSet(currKey, rawData, TimeSpan.FromMinutes(maxAgeMin));
             }
             if (result == null)
             {
                 result = new List<string>();
             }
-#endif
             stopWatch.Stop();
             TimeSpan ts = stopWatch.Elapsed;
             Log.Debug($"ParametriGetFilt | Read from {readType}: {ts.TotalMilliseconds}ms");