Imports System.Net, System.Net.Sockets
Imports System.Text
Imports System.Threading
Imports System.IO

Public Class cServerClient
    Dim clientSocket As Socket
    Dim byteData(1023) As Byte
    Dim doThis As String
    Public status As String = "begin"
    ' Private Sub Button1_Click(sender As Object, e As EventArgs) Handles Button1.Click
    '     begin()
    ' End Sub

    Public Event FunctionFinished(ByVal sender As Object, ByVal e As FunctionFinishedArgs)


    Public Sub begin(ip, doThis_tmp)
        doThis = doThis_tmp
        Dim timeOut As Integer = 60
        Select Case doThis
            Case "test" : timeOut = 5 ' nach 5 Sekunden wird abgebrochen
            Case "FSSAtlasStart" : timeOut = 120 ' nach 120 Sekunden wird abgebrochen
            Case "initAufschubkonten" : timeOut = 60 ' nach 60 Sekunden wird abgebrochen
        End Select

        'Ein Thread kontrolliert, ob die Funktion nach einer gewissen Zeit noch läuft und beendet diese ggf.
        Dim st As New Thread(AddressOf stopThread)
        st.IsBackground = True
        Dim param_obj(1) As Object
        'Übergabeparameter des 2. Threads
        param_obj(0) = timeOut
        st.Start(param_obj)


        clientSocket = New Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)
        Dim ipAddress As IPAddress = ipAddress.Parse(ip)

        ' Dim ipAddress As IPAddress = ipAddress.Parse("192.168.0.90")
        Dim ipEndPoint As IPEndPoint = New IPEndPoint(ipAddress, 8800)
        clientSocket.BeginConnect(ipEndPoint, New AsyncCallback(AddressOf OnConnect), Nothing)
        status = "beginConnect"
        '   endconnect(clientSocket)


    End Sub

    Public Sub waitTillFinished()
        While Not (status = "TaskError" Or status = "TaskSuccess")
            'wait
        End While
        'Return True
    End Sub

    Private Sub OnConnect(ByVal ar As IAsyncResult)
        Try
            clientSocket.EndConnect(ar)
            clientSocket.BeginReceive(byteData, 0, byteData.Length, SocketFlags.None, _
                                      New AsyncCallback(AddressOf OnRecieve), clientSocket)
        Catch ex As Exception
            '  MsgBox("Verbindung zum Server konnte nicht aufgebaut werden!")
        End Try
    End Sub

    Private Sub OnSend(ByVal ar As IAsyncResult)
        Dim client As Socket = ar.AsyncState
        client.EndSend(ar)
    End Sub
    Private Sub Send(ByVal msg As String, ByVal client As Socket)
        Dim sendBytes As Byte() = Encoding.BigEndianUnicode.GetBytes(msg)
        client.BeginSend(sendBytes, 0, sendBytes.Length, SocketFlags.None, New AsyncCallback(AddressOf OnSend), client)
    End Sub
    Private Sub Send(ByVal msg() As Byte, ByVal client As Socket)
        ' Dim sendBytes As Byte() = Encoding.BigEndianUnicode.GetBytes(msg)
        client.BeginSend(msg, 0, msg.Length, SocketFlags.None, New AsyncCallback(AddressOf OnSend), client)
    End Sub
    Public Function ByteArrayToTextString(ByRef Barr() As Byte) As String
        Dim enc As System.Text.Encoding = Encoding.BigEndianUnicode
        Return enc.GetString(Barr)
    End Function

    Public Sub UploadFileToDatenserver(FilePath As String, FileName As String, Kategorie As String, Ordner As String) ', ByVal client As Socket)

        Dim FStream As New FileStream(FilePath, FileMode.Open, FileAccess.Read, FileShare.Read)
        Dim SReader As New StreamReader(FStream)
        Dim sText As String = SReader.ReadToEnd
        Dim filedata As String = sText

        ' Dim laenge As String = filedata.Length + _
        'filedata.Length.ToString.Length(+2)
        'Dim data As String = "incomingfile|" & laenge

        Dim sendFile As String = "DATENSERVER_Upload" & "|||" & FileName & "|||" & Kategorie & "|||" & Ordner & "|||" & filedata
        Dim messageFile() As Byte = Encoding.ASCII.GetBytes(sendFile)

        Send(messageFile, clientSocket)
    End Sub


    Private Sub OnRecieve(ByVal ar As IAsyncResult)
        Try
            Dim client As Socket = ar.AsyncState
            client.EndReceive(ar)
            Dim bytesRec As Byte() = byteData
            Dim message As String = Encoding.BigEndianUnicode.GetString(bytesRec)
            '  MsgBox("FROM SERVER: " & message)
            Dim b(1023) As Byte

            ' MsgBox("SERVER RECIEVE: " & Encoding.BigEndianUnicode.GetString(b))

            byteData = b
            Read(message)
            clientSocket.BeginReceive(byteData, 0, byteData.Length, SocketFlags.None, _
                                      New AsyncCallback(AddressOf OnRecieve), clientSocket)

        Catch ex As Exception
            '   MsgBox("Verbindung zum Server wurde unterbrochen!")
        End Try
    End Sub

    Delegate Sub _Read(ByVal msg As String)
    Private Sub Read(ByVal msg As String)
        If frmHauptfenster.InvokeRequired Then
            frmHauptfenster.Invoke(New _Read(AddressOf Read), msg)
            Exit Sub
        End If

        'frmHauptfenster.icoVERAGMonitoring.Visible = False

        'if richtige nsachricht
        '  Dim asciis As Byte() = Encoding.BigEndianUnicode.GetBytes(msg)
        '  Dim a As Char = msg(msg.Length - 1)
        ' msg = msg.Replace(a, "")
        ' MsgBox(msg.Length)

        ' MsgBox(msg(msg.Length - 1))
        ' MsgBox(msg(msg.Length - 1))
        '      MsgBox(Asc(msg(msg.Length - 1)))
        ' MsgBox(Asc(msg(msg.Length - 2)))
        msg = msg.Replace(Convert.ToChar(0), "")
        Try

            '  MsgBox("-" & msg & "-" & vbNewLine & "ConSuccess" & "-")
            If msg = "ConSuccess" Then
                status = "ConSuccess"
                Select Case doThis
                    Case "test"
                        Send("test", clientSocket)
                        status = "sendTask"
                    Case "FSSAtlasStart"
                        Send("FSSAtlasStart", clientSocket)
                        status = "sendTask"
                    Case "initAufschubkonten"
                        Send("initAufschubkonten", clientSocket)
                        status = "sendTask"
                End Select

                '  MsgBox("!!!!!ConSuccess --> initAufschubkonten")
                '   Send("FSSAtlasStart", clientSocket)
                'Send("test", clientSocket)
                'Send("initAufschubkonten", clientSocket)

            ElseIf msg = "Task successful" Then
                status = "TaskSuccess"
                clientSocket.Disconnect(False)
                clientSocket.Shutdown(SocketShutdown.Both)
                clientSocket.Close()
                'endconnect(clientSocket)'geht ned
                '  MsgBox("Task erfolgreich!", vbSystemModal, doThis)
                RaiseEvent FunctionFinished(Me, New FunctionFinishedArgs(FunctionFinishedArgs.EventResult.OK, "Task erfolgreich!"))
            ElseIf msg = "Task not found" Then
                MsgBox("SERVERERROR: Der Dienst wurde nicht gefunden!", vbSystemModal, "FSSAtlas")
                status = "TaskError"
                RaiseEvent FunctionFinished(Me, New FunctionFinishedArgs(FunctionFinishedArgs.EventResult.ERR, "SERVERERROR: Der Dienst wurde nicht gefunden!"))
            ElseIf msg = "Task inactive" Then
                MsgBox("SERVERERROR: Der Dienste ist nicht aktiv!", vbSystemModal, "FSSAtlas")
                status = "TaskError"
                RaiseEvent FunctionFinished(Me, New FunctionFinishedArgs(FunctionFinishedArgs.EventResult.ERR, "SERVERERROR: Der Dienste ist nicht aktiv!"))
            ElseIf msg = "Task timeout" Then
                MsgBox("SERVERERROR: Der Dienst wurde wegen einer Zeitüberschreitung abgebrochen!", vbSystemModal, "FSSAtlas")
                status = "TaskError"
                RaiseEvent FunctionFinished(Me, New FunctionFinishedArgs(FunctionFinishedArgs.EventResult.ERR, "SERVERERROR: Der Dienst wurde wegen einer Zeitüberschreitung abgebrochen!"))
            ElseIf msg = "Task error" Then
                MsgBox("SERVERERROR: Server-Fehler!", vbSystemModal, "FSSAtlas")
                status = "TaskError"
                RaiseEvent FunctionFinished(Me, New FunctionFinishedArgs(FunctionFinishedArgs.EventResult.ERR, "SERVERERROR: Server-Fehler!"))
            Else
                MsgBox("SERVER_NACHRICHT NICHT VERSTANDEN: " & msg, vbSystemModal)
                status = "TaskError"
                RaiseEvent FunctionFinished(Me, New FunctionFinishedArgs(FunctionFinishedArgs.EventResult.ERR, "SERVER_NACHRICHT NICHT VERSTANDEN: " & msg))

                clientSocket.Shutdown(SocketShutdown.Both)
                clientSocket.Close()
            End If

        Catch ex As Exception
            MsgBox("Verbindungs-Fehler beim Senden", vbSystemModal)
            status = "TaskError"
            RaiseEvent FunctionFinished(Me, New FunctionFinishedArgs(FunctionFinishedArgs.EventResult.ERR, "Verbindungs-Fehler beim Senden"))
            clientSocket.Close()
        End Try
        ' byteData = Encoding.BigEndianUnicode.GetBytes("")

    End Sub


    Sub stopThread(param_obj As Object) 'Stoppt einen Hauptthread nach einer gewissen Anzahl von Sekunden; Übergabeparameter: Object { Tread, clientSocket, SekundenToTimeout }
        Thread.Sleep(param_obj(0) * 1000) ' Hier wird soviele Senkunden gewartet, wie in den Übergabeparametern definiert wurde.
        If status = "TaskError" Or status = "TaskSuccess" Then Exit Sub
        status = "TaskError"
        Try
            clientSocket.Disconnect(False)
            clientSocket.Shutdown(SocketShutdown.Both)
            clientSocket.Close()
        Catch ex As Exception
            MsgBox(ex.Message)
        End Try

        RaiseEvent FunctionFinished(Me, New FunctionFinishedArgs(FunctionFinishedArgs.EventResult.ERR, "Task wurde aufgrund eines Timeouts vom Client abgebrochen."))
        MsgBox("ERROR: Task wurde aufgrund eines Timeouts vom Client abgebrochen.") 'Log-Mittelung
    End Sub


End Class

Public Class FunctionFinishedArgs
    Inherits EventArgs
    'das was man später unter e sehen kann
    Public Result As EventResult
    'hier - als Beispiel - einfach eine Enum
    Public Enum EventResult
        OK
        ERR
    End Enum
    Public Message As String
    'Zum übergeben der Parameter
    Public Sub New(ByVal r As EventResult, m As String)
        Result = r
        Message = m
    End Sub
End Class