Fix rimozione message pipe MON da SPEC

MP.Data/MessagePipe.cs

@@ -90,7 +90,7 @@ namespace MP.Data
             //Subscribe to the channel named messages
             sub.Subscribe(_channel, (channel, message) =>
             {
-                Log.Trace($"ch {channel} | {message}");
+                Log.Trace($"req setup ch {channel} | {message}");
                 // messaggio
                 PubSubEventArgs mea = new PubSubEventArgs(message);
                 // se qualcuno ascolta sollevo evento nuovo valore...

MP.SPEC/Data/MpDataService.cs

@@ -29,10 +29,6 @@ namespace MP.SPEC.Data
 
             _logger.LogInformation("Redis INIT");
 
-            // setup canali pub/sub
-            dataPipe = new MessagePipe(redisConn, Constants.ACT_MSE_DATA_KEY);
-            blinkPipe = new MessagePipe(redisConn, Constants.ACT_BLINK_KEY);
-
             // conf DB
             string connStr = _configuration.GetConnectionString("Mp.Data");
             if (string.IsNullOrEmpty(connStr))
@@ -52,14 +48,11 @@ namespace MP.SPEC.Data
 
         public static MP.Data.Controllers.MpSpecController dbController { get; set; } = null!;
 
-        public MessagePipe blinkPipe { get; set; } = null!;
-
         /// <summary>
         /// Dizionario dei tag configurati per IOB
         /// </summary>
         public Dictionary<string, List<TagData>> currTagConf { get; set; } = new Dictionary<string, List<TagData>>();
 
-        public MessagePipe dataPipe { get; set; } = null!;
 
         #endregion Public Properties
 
@@ -100,15 +93,14 @@ namespace MP.SPEC.Data
         {
             Stopwatch stopWatch = new Stopwatch();
             stopWatch.Start();
+            string source = "DB";
             List<ListValues>? result = new List<ListValues>();
             // cerco in redis...
             RedisValue rawData = await redisDb.StringGetAsync(redisTipoArt);
             if (!string.IsNullOrEmpty($"{rawData}"))
             {
                 result = JsonConvert.DeserializeObject<List<ListValues>>($"{rawData}");
-                stopWatch.Stop();
-                TimeSpan ts = stopWatch.Elapsed;
-                Log.Debug($"AnagTipoArtLV Read from REDIS: {ts.TotalMilliseconds}ms");
+                source = "REDIS";
             }
             else
             {
@@ -116,10 +108,10 @@ namespace MP.SPEC.Data
                 // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
                 await redisDb.StringSetAsync(redisTipoArt, rawData, getRandTOut(redisLongTimeCache));
-                stopWatch.Stop();
-                TimeSpan ts = stopWatch.Elapsed;
-                Log.Debug($"AnagTipoArtLV Read from DB: {ts.TotalMilliseconds}ms");
             }
+            stopWatch.Stop();
+            TimeSpan ts = stopWatch.Elapsed;
+            Log.Debug($"AnagTipoArtLV Read from {source}: {ts.TotalMilliseconds}ms");
             if (result == null)
             {
                 result = new List<ListValues>();
@@ -197,7 +189,7 @@ namespace MP.SPEC.Data
                 result = await Task.FromResult(dbController.ArticoliGetSearch(numRecord, azienda, searchVal));
                 // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
-                redisDb.StringSet(currKey, rawData, getRandTOut(redisLongTimeCache/5));
+                redisDb.StringSet(currKey, rawData, getRandTOut(redisLongTimeCache / 5));
             }
             if (result == null)
             {

MP.SPEC/MP.SPEC.csproj

@@ -5,7 +5,7 @@
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
     <RootNamespace>MP.SPEC</RootNamespace>
-    <Version>6.16.2210.2017</Version>
+    <Version>6.16.2210.2109</Version>
   </PropertyGroup>
 
   <ItemGroup>

MP.SPEC/NLog.config

@@ -39,7 +39,7 @@
     Write all events with minimal level of Debug (So Debug, Info, Warn, Error and Fatal, but not Trace)  to "f"
     <logger name="*" minlevel="Debug" writeTo="f" />
     -->
-        <logger name="*" minlevel="Debug" writeTo="consoleTarget" />
+        <logger name="*" minlevel="Trace" writeTo="consoleTarget" />
         <!--<logger name="Microsoft.*" maxlevel="Info" final="true" />-->
         <logger name="*" minlevel="Info" writeTo="fileTarget" />
     </rules>

MP.SPEC/Resources/ChangeLog.html

@@ -1,6 +1,6 @@
 <body>
     <i>Modulo MAPOSPEC </i>
-    <h4>Versione: 6.16.2210.2017</h4>
+    <h4>Versione: 6.16.2210.2109</h4>
     <br /> Note di rilascio:
     <ul>
         <li>

MP.SPEC/Resources/VersNum.txt

@@ -1 +1 @@
-6.16.2210.2017
+6.16.2210.2109

MP.SPEC/Resources/manifest.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <item>
-  <version>6.16.2210.2017</version>
+  <version>6.16.2210.2109</version>
   <url>https://nexus.steamware.net/repository/SWS/MP-SPEC/stable/LAST/MP.SPEC.zip</url>
   <changelog>https://nexus.steamware.net/repository/SWS/MP-SPEC/stable/LAST/ChangeLog.html</changelog>
   <mandatory>false</mandatory>

MP.SPEC/appsettings.json

@@ -14,8 +14,8 @@
   },
   "ServerConf": {
     "maxAge": "2000",
-    "cacheCheckArtUsato": 2,
-    "redisLongTimeCache": 15,
+    "cacheCheckArtUsato": "2",
+    "redisLongTimeCache": "15",
     "MpIoBaseUrl": "http://localhost:20967/"
   }
 }