Imports DigitalData.Modules.Database
Imports DigitalData.Modules.Logging
Imports ECM.JobRunner.Windows.Scheduler
Imports System.Runtime.Serialization

Public Class RunJob
    Public Class RunJobMethod
        Inherits Base.BaseMethod

        Private ReadOnly Scheduler As JobScheduler

        Public Sub New(pLogConfig As LogConfig, pDatabase As MSSQLServer, pState As State, pScheduler As JobScheduler)
            MyBase.New(pLogConfig, pDatabase, pState)
            Scheduler = pScheduler
        End Sub

        Public Function Run(pData As RunJobRequest) As RunJobResponse
            ' This is calling the async function ScheduleJob synchronous, so that we can return a value to the caller
            ' This means that the job might or might not be scheduled when this method returns.
#Disable Warning BC42358 ' Da auf diesen Aufruf nicht gewartet wird, wird die Ausführung der aktuellen Methode vor Abschluss des Aufrufs fortgesetzt.
            Scheduler.ScheduleJob(pData.JobId)
#Enable Warning BC42358 ' Da auf diesen Aufruf nicht gewartet wird, wird die Ausführung der aktuellen Methode vor Abschluss des Aufrufs fortgesetzt.

            Return New RunJobResponse()
        End Function

    End Class

    Public Class RunJobRequest
        Public Property JobId As Integer
    End Class

    Public Class RunJobResponse
        Inherits Base.BaseResponse
    End Class
End Class