🎨 (plugin) Added CLH Internal Data

Author: SydneyOwl

src/CloudlogHelper/Services/PluginService.cs

@@ -166,6 +166,9 @@ public async Task SendMessage<T>(T msg, CancellationToken token) where T: IMessa
             case RigData:
                 if (!Capabilities.Contains(Capability.RigData))return ;
                 break;
+            case ClhInternalMessage:
+                if (!Capabilities.Contains(Capability.ClhInternalData))return ;
+                break;
             default:
                 return ;
         }
@@ -180,7 +183,6 @@ public async Task SendMessage<T>(T msg, CancellationToken token) where T: IMessa
         }
         finally
         {
-            
             _cliLock.Release();
         }
     }

src/CloudlogHelper/Utils/PbMsgConverter.cs

@@ -272,4 +272,86 @@ private static ClearWindow MapClearWindow(WsjtxUtilsPatch.WsjtxMessages.Messages
             _ => ClearWindow.ClearBandActivity
         };
     }
+
+    /// <summary>
+    /// Convert CloudlogHelper RecordedCallsignDetail to protobuf RecordedCallsignDetail message.
+    /// </summary>
+    /// <param name="detail">The C# model to convert</param>
+    /// <returns>A protobuf RecordedCallsignDetail message</returns>
+    public static ClhInternalMessage ToPbRecordedCallsignDetail(RecordedCallsignDetail detail)
+    {
+        var pbDetail = new ClhQSOUploadStatusChanged()
+        {
+            OriginalCountryName = detail.OriginalCountryName ?? "",
+            CqZone = detail.CqZone,
+            ItuZone = detail.ItuZone,
+            Continent = detail.Continent ?? "",
+            Latitude = detail.Latitude,
+            Longitude = detail.Longitude,
+            GmtOffset = detail.GmtOffset,
+            Dxcc = detail.Dxcc ?? "",
+            DateTimeOff = Timestamp.FromDateTime(detail.DateTimeOff),
+            DxCall = detail.DXCall ?? "",
+            DxGrid = detail.DXGrid ?? "",
+            TxFrequencyInHz = detail.TXFrequencyInHz,
+            TxFrequencyInMeters = detail.TXFrequencyInMeters ?? "",
+            Mode = detail.Mode ?? "",
+            ParentMode = detail.ParentMode ?? "",
+            ReportSent = detail.ReportSent ?? "",
+            ReportReceived = detail.ReportReceived ?? "",
+            TxPower = detail.TXPower ?? "",
+            Comments = detail.Comments ?? "",
+            Name = detail.Name ?? "",
+            DateTimeOn = Timestamp.FromDateTime(detail.DateTimeOn),
+            OperatorCall = detail.OperatorCall ?? "",
+            MyCall = detail.MyCall ?? "",
+            MyGrid = detail.MyGrid ?? "",
+            ExchangeSent = detail.ExchangeSent ?? "",
+            ExchangeReceived = detail.ExchangeReceived ?? "",
+            AdifPropagationMode = detail.AdifPropagationMode ?? "",
+            ClientId = detail.ClientId ?? "",
+            RawData = detail.RawData?.ToString() ?? "",
+            FailReason = detail.FailReason ?? "",
+            UploadStatus = MapUploadStatus(detail.UploadStatus),
+            ForcedUpload = detail.ForcedUpload
+        };
+
+        // Copy uploaded services map
+        foreach (var kvp in detail.UploadedServices)
+        {
+            pbDetail.UploadedServices[kvp.Key] = kvp.Value;
+        }
+
+        // Copy uploaded services error message map
+        foreach (var kvp in detail.UploadedServicesErrorMessage)
+        {
+            pbDetail.UploadedServicesErrorMessage[kvp.Key] = kvp.Value;
+        }
+
+        var tmp = new ClhInternalMessage
+        {
+            Timestamp = Timestamp.FromDateTime(DateTime.UtcNow),
+            QsoUploadStatus = pbDetail
+        };
+
+        return tmp;
+    }
+
+    /// <summary>
+    /// Map CloudlogHelper UploadStatus enum to protobuf UploadStatus enum.
+    /// </summary>
+    /// <param name="status">The upload status to convert</param>
+    /// <returns>Converted protobuf UploadStatus</returns>
+    private static UploadStatus MapUploadStatus(Enums.UploadStatus status)
+    {
+        return status switch
+        {
+            Enums.UploadStatus.Pending => UploadStatus.Pending,
+            Enums.UploadStatus.Uploading => UploadStatus.Uploading,
+            Enums.UploadStatus.Success => UploadStatus.Success,
+            Enums.UploadStatus.Fail => UploadStatus.Fail,
+            Enums.UploadStatus.Ignored => UploadStatus.Ignored,
+            _ => UploadStatus.Unspecified
+        };
+    }
 }

src/CloudlogHelper/ViewModels/MainWindowViewModel.cs

@@ -49,7 +49,6 @@ public MainWindowViewModel(
         StatusLightUserControlViewModel statusLightUserControlViewModel,
         PolarChartWindowViewModel ignored1, // force init - DO NOT REMOVE IT!
         StationStatisticsChartWindowViewModel ignored2, // force init - DO NOT REMOVE IT!
-        IPluginService _, // force init - DO NOT REMOVE IT!
         CommandLineOptions cmd,
         IWindowManagerService wm,
         IInAppNotificationService inAppNotificationService

src/CloudlogHelper/ViewModels/UserControls/UDPLogInfoGroupboxUserControlViewModel.cs

@@ -195,6 +195,7 @@ public UDPLogInfoGroupboxUserControlViewModel(
                 .DisposeWith(compositeDisposable);
 
             SetupQsoRateCalculation(compositeDisposable);
+            SetupQsoList(compositeDisposable);
             SetupFilteringAndSorting(compositeDisposable);
 
             this.WhenAnyValue(
@@ -251,15 +252,44 @@ private void SetupQsoRateCalculation(CompositeDisposable disposables)
 
                 QsAvgMin = $"{rate:F2} Q's/m";
             }).DisposeWith(disposables);
-            
+    }
 
+    private void SetupQsoList(CompositeDisposable disposables)
+    {
         _allQsos.Connect()
             .WhenPropertyChanged(p => p.UploadStatus)
-            .Where(x => x.Value == UploadStatus.Success)
-            .Subscribe(x =>
+            .Subscribe(async void (x) =>
+            {
+                try
+                {
+                    await _pluginService.BroadcastMessageAsync(
+                        PbMsgConverter.ToPbRecordedCallsignDetail(x.Sender),
+                        CancellationToken.None);
+                    
+                    if (x.Value == UploadStatus.Success) UploadedQsosCount += 1;
+                }
+                catch (Exception ex)
+                {
+                    ClassLogger.Error(ex, "Error occurred. Ignored.");
+                }
+            })
+            .DisposeWith(disposables);
+
+        _allQsos.Connect()
+            .OnItemAdded(async void (x) =>
             {
-                UploadedQsosCount += 1;
+                try
+                {
+                    await _pluginService.BroadcastMessageAsync(
+                        PbMsgConverter.ToPbRecordedCallsignDetail(x),
+                        CancellationToken.None);
+                }
+                catch (Exception ex)
+                {
+                    ClassLogger.Error(ex, "Error occurred. Ignored.");
+                }
             })
+            .Subscribe()
             .DisposeWith(disposables);
     }