Imports System.Windows.Forms
Imports System.IO
 
Public Class MDI
 
    Dim AR
    Dim dTime As String, dDate As String
    Dim BidQTY, AskQty As Double
    Dim I As Integer
 
    Public bMarketClosed As Boolean, bConnectionError As Boolean, iReconnectingTimes As Integer
 
    Dim dtQuotes_Master As New DataTable
 
    Public dsQuotes_Master As New DataSet
    Public sXML_Quotes_Master As String = Application.StartupPath & "\quotes_master.xml"
    Public bXML_Quotes_Master_Exists As Boolean
 
    Private WithEvents wsClient As New SocketsClient()
 
    Delegate Sub UpdateTextHandler(ByVal message As String)
    Public Sub UpdateText(ByVal message As String)
        Me.Text = message
    End Sub
 
    Delegate Sub OnFly_TS_DataArrival_Delegate(ByVal AR)
    Public Sub OnFly_TS_DataArrival(ByVal AR)
        OnFly_TS.DataArrival(AR)
    End Sub
 
    Delegate Sub OnFly_Q_DataArrival_Delegate(ByVal AR)
    Public Sub OnFly_Q_DataArrival(ByVal AR)
        OnFly_Q.DataArrival(AR)
    End Sub
 
    Delegate Sub OnFly_OB_DataArrival_Delegate(ByVal AR)
    Public Sub OnFly_OB_DataArrival(ByVal AR)
        OnFly_OB.DataArrival(AR)
    End Sub
 
 
    Private Sub Default_OnFly_Load(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles MyBase.Load
 
        With dtQuotes_Master
            .Columns.Add(New DataColumn("Row", GetType(System.Double)))
            .Columns.Add(New DataColumn("StockID", GetType(System.Double)))
            .Columns.Add(New DataColumn("Stock_E", GetType(System.String)))
            .Columns.Add(New DataColumn("Stock_A", GetType(System.String)))
        End With
 
        If File.Exists(sXML_Quotes_Master) Then
            bXML_Quotes_Master_Exists = True
            dsQuotes_Master.ReadXml(sXML_Quotes_Master)
        Else
            bXML_Quotes_Master_Exists = False
            dsQuotes_Master.Tables.Add(dtQuotes_Master)
        End If
 
        With OnFly_TS
            .MdiParent = Me
            .Show()
        End With
 
        With OnFly_Q
            .MdiParent = Me
            .Show()
        End With
 
        With OnFly_OB
            .MdiParent = Me
            .Show()
        End With
 
    End Sub
 
    Sub EJ_QuotesMaster_Refresh()
        If File.Exists(sXML_Quotes_Master) Then
            dsQuotes_Master.ReadXml(sXML_Quotes_Master)
        End If
    End Sub
 
    Private Sub tmrFeed_Tick(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles tmrFeed.Tick
        iReconnectingTimes = iReconnectingTimes + 1
        ReConnect(True, CStr(iReconnectingTimes))
    End Sub
 
    Sub ReConnect(ByVal bReconnecting As Boolean, Optional ByVal iCount As String = "")
 
        Dim sText As String
        If bReconnecting = True Then
            sText = "Reconnecting"
            Me.Winsock1.Close()
        Else
            sText = "Connecting"
        End If
 
        Me.Text = vbCrLf & _
                          "------------------------------------------------------------------------------" & _
                          vbCrLf & _
                          sText & " @ " & Now & _
                          vbCrLf & _
                          "------------------------------------------------------------------------------" & _
                          vbCrLf & _
                          Me.Text
 
        wsClient.Connect("192.0.3.18", 5555)
 
    End Sub
 
    Private Sub wsClient_onConnect() Handles wsClient.onConnect
        Me.tmrFeed.Enabled = False
        iReconnectingTimes = 0
        bConnectionError = False
    End Sub
 
    Private Sub wsClient_onDisconnect() Handles wsClient.onDisconnect
        Me.tmrFeed.Enabled = True
    End Sub
 
    Private Sub wsClient_onDataArrival(ByVal Data() As Byte, ByVal TotalBytes As Integer) Handles wsClient.onDataArrival
        Try
            Dim sText As String = wsClient.BytestoString(Data)
 
            Dim arCR
 
            arCR = Split(sText, vbCrLf)
            If Not (Trim(sText) = "" Or UBound(arCR) = 1) Then
 
                For I = 0 To UBound(arCR) - 1
 
                    If (Trim(arCR(0)) <> "") And (Len(arCR(0)) > 1) Then
 
                        arCR(I) = Trim(Mid(Trim(arCR(I)), 1, Len(Trim(arCR(I))) - 2))
                        Dim displayText = IIf(bMarketClosed, "Market Closed", "Market Open") & "   -   " & arCR(I)
                        Me.Invoke(New UpdateTextHandler(AddressOf UpdateText), New Object() {displayText})
 
 
                        AR = Split(arCR(I), "|")
                        If UBound(AR) > 0 Then
 
                            Select Case AR(0)
 
                                Case "$MM"
                                    If AR(3) = 4 Then
                                        bMarketClosed = False
                                    Else
                                        bMarketClosed = True
                                    End If
 
                                Case "$CH"
                                    If AR(11) = 4 Then
                                        bMarketClosed = False
                                    Else
                                        bMarketClosed = True
                                    End If
                                Case "$LL"
                                    'If dsQuotes_Master.Tables.Count = 1 Then ' to make sure it's not added more than 1 table
                                    'If File.Exists(Me.sXML_Quotes_Master) Then
                                    'If bXML_Quotes_Master_Exists Then
                                    '>>>> Why do you need to check?? You have already added a table to the dataset!
                                    Dim arRows() As DataRow = dsQuotes_Master.Tables(0).Select("ROW=" & Val(AR(2)))
                                    If arRows.Length <> 0 Then dsQuotes_Master.Tables(0).Rows.Remove(arRows(0))
                                    'End If
 
                                    Dim Row1 As DataRow
 
                                    'Row1 = dtQuotes_Master.NewRow()
                                    Row1 = dsQuotes_Master.Tables(0).NewRow
 
                                    Row1("Row") = AR(2)
                                    Row1("StockID") = AR(3)
                                    Row1("Stock_E") = AR(4)
                                    Row1("Stock_A") = AR(5)
 
                                    'dtQuotes_Master.Rows.Add(Row1)
                                    dsQuotes_Master.Tables(0).Rows.Add(Row1)
 
                                    'dsQuotes_Master.Tables.Add(dtQuotes_Master)
                                    File.Delete(Me.sXML_Quotes_Master)
                                    dsQuotes_Master.WriteXml(Me.sXML_Quotes_Master) '>>> You should not write the file on every hit PLUS need to delet existing as well
                                    'dsQuotes_Master.Tables.Remove(dtQuotes_Master)
 
                                Case "$TT"
                                    'Application.DoEvents()
                                    'OnFly_TS.DataArrival(AR)
                                    Me.Invoke(New OnFly_TS_DataArrival_Delegate(AddressOf OnFly_TS_DataArrival), New Object() {AR})
                                Case "$QQ"
                                    'Application.DoEvents()
                                    'OnFly_Q.DataArrival(AR)
                                    Me.Invoke(New OnFly_Q_DataArrival_Delegate(AddressOf OnFly_Q_DataArrival), New Object() {AR})
                                Case "$XX"
                                    'Application.DoEvents()
                                    'OnFly_Q.DataArrival(AR)
                                    Me.Invoke(New OnFly_Q_DataArrival_Delegate(AddressOf OnFly_Q_DataArrival), New Object() {AR})
                                Case "$KB"
                                    If bMarketClosed Then Exit Select
                                    'OnFly_OB.DataArrival(AR)
                                    Me.Invoke(New OnFly_OB_DataArrival_Delegate(AddressOf OnFly_OB_DataArrival), New Object() {AR})
                                Case "$KS"
                                    If bMarketClosed Then Exit Select
                                    'OnFly_OB.DataArrival(AR)
                                    Me.Invoke(New OnFly_OB_DataArrival_Delegate(AddressOf OnFly_OB_DataArrival), New Object() {AR})
                            End Select
                        End If
                    End If
                Next
            End If
        Catch ex As Exception
            Text = ex.Message
        End Try
 
    End Sub
 
End Class