ClientSuite: Add WorkerManager

GUIs.ClientSuite/Workers/HeartbeatWorker.vb

@@ -0,0 +1,63 @@
+Imports System.Timers
+Imports DigitalData.GUIs.ClientSuite
+Imports DigitalData.GUIs.ClientSuite.Base
+Imports DigitalData.Modules.EDMIAPI.IDBServiceReference
+Imports DigitalData.Modules.Logging
+Namespace Workers
+    Public Class HeartbeatWorker
+        Inherits BaseClass
+        Implements IWorker
+
+        Private _Channel As IIDBServiceChannel
+
+        Public Event OnlineChanged As OnlineChangedEventHandler
+        Public Delegate Sub OnlineChangedEventHandler(sender As Object, Online As Boolean)
+
+        Public ReadOnly Property Interval As Integer = 4000 Implements IWorker.Interval
+
+        Public Sub New(LogConfig As LogConfig)
+            MyBase.New(LogConfig)
+        End Sub
+
+        Public Sub Setup() Implements IWorker.Setup
+            _Channel = My.ChannelFactory.CreateChannel()
+            _Channel.Open()
+        End Sub
+
+        Public Async Sub Callback(manager As WorkerManager, e As ElapsedEventArgs) Implements IWorker.Callback
+            Try
+                Logger.Debug("Checking if Service is up...")
+
+                If _Channel.State = ServiceModel.CommunicationState.Faulted Then
+                    _Channel = My.ChannelFactory.CreateChannel()
+                End If
+
+                ' Connect to service and send hearbeat request
+                Dim oResult = Await _Channel.HeartbeatAsync()
+
+                Logger.Debug("Service is online")
+
+                SetOnlineState(True)
+            Catch ex As Exception
+                Logger.Debug("Service is offline!")
+                Logger.Error(ex)
+
+                SetOnlineState(False)
+            Finally
+                My.Application.Service.LastChecked = DateTime.Now
+            End Try
+        End Sub
+
+        Public Sub Teardown() Implements IWorker.Teardown
+            ' TODO: Close channel gracefully
+        End Sub
+
+        Private Sub SetOnlineState(NewState As Boolean)
+            If My.Application.Service.Online <> NewState Then
+                My.Application.Service.Online = NewState
+                RaiseEvent OnlineChanged(Me, NewState)
+            End If
+        End Sub
+    End Class
+End Namespace
+

GUIs.ClientSuite/Workers/IWorker.vb

@@ -0,0 +1,12 @@
+Imports System.Timers
+
+Namespace Workers
+    Public Interface IWorker
+        ReadOnly Property Interval As Integer
+
+        Sub Setup()
+        Sub Teardown()
+        Sub Callback(manager As WorkerManager, e As ElapsedEventArgs)
+    End Interface
+End Namespace
+

GUIs.ClientSuite/Workers/WorkerManager.vb

@@ -0,0 +1,70 @@
+Imports System.Timers
+Imports DigitalData.GUIs.ClientSuite.Base
+Imports DigitalData.Modules.Logging
+
+Namespace Workers
+    Public Class WorkerManager
+        Inherits BaseClass
+
+        ''' <summary>
+        ''' List of workers that will be started.
+        ''' </summary>
+        Private WorkerTypes As New List(Of Type) From {
+            GetType(HeartbeatWorker)
+        }
+        Private Workers As New List(Of IWorker)
+        Private TimerList As New List(Of Timer)
+
+        Public Sub New(LogConfig As LogConfig, SyncronizingObject As frmMain)
+            MyBase.New(LogConfig)
+
+            Workers = CreateWorkers()
+
+            For Each oWorker As IWorker In Workers
+                Dim oTimer = New Timer(oWorker.Interval) With {
+                    .SynchronizingObject = SyncronizingObject,
+                    .Enabled = True
+                }
+
+                AddHandler oTimer.Elapsed, Sub(sender As Object, e As ElapsedEventArgs)
+                                               Try
+                                                   oWorker.Callback(Me, e)
+                                               Catch ex As Exception
+                                                   Logger.Warn("Worker {0} threw an error in callback.", oWorker.GetType.Name)
+                                               End Try
+                                           End Sub
+
+                TimerList.Add(oTimer)
+            Next
+        End Sub
+
+        Public Function GetWorker(Of T)() As T
+            For Each oWorker In Workers
+                If TypeOf oWorker Is T Then
+                    Return oWorker
+                End If
+            Next
+
+            Return Nothing
+        End Function
+
+        Private Function CreateWorkers() As List(Of IWorker)
+            Dim oWorkers As New List(Of IWorker)
+
+            For Each oWorkerType In WorkerTypes
+                Try
+                    Dim oWorker As IWorker = Activator.CreateInstance(oWorkerType, New Object() {LogConfig})
+                    oWorker.Setup()
+                    oWorkers.Add(oWorker)
+                Catch ex As Exception
+                    Logger.Warn("Worker {0} threw an error while creating. Skipping.", oWorkerType.Name)
+                    Logger.Error(ex)
+                    Continue For
+                End Try
+            Next
+
+            Return oWorkers
+        End Function
+    End Class
+End Namespace
+

GUIs.ClientSuite/Workers/WorkflowWorker.vb

@@ -0,0 +1,29 @@
+Imports System.Timers
+Imports DigitalData.GUIs.ClientSuite.Base
+Imports DigitalData.Modules.Logging
+
+Namespace Workers
+    Public Class WorkflowWorker
+        Inherits BaseClass
+        Implements IWorker
+
+        Public Sub New(LogConfig As LogConfig)
+            MyBase.New(LogConfig)
+        End Sub
+
+        Public ReadOnly Property Interval As Integer = 60000 Implements IWorker.Interval
+
+        Public Sub Setup() Implements IWorker.Setup
+            Throw New NotImplementedException()
+        End Sub
+
+        Public Sub Teardown() Implements IWorker.Teardown
+            Throw New NotImplementedException()
+        End Sub
+
+        Public Sub Callback(manager As WorkerManager, e As ElapsedEventArgs) Implements IWorker.Callback
+            Throw New NotImplementedException()
+        End Sub
+    End Class
+End Namespace
+