#NetPacketType_EndProg ; Завершить работу клиента.
#NetPacketType_Data    ; Данные.

Structure NetBuff_Param 
  *Buff 
  Len.l 
  Pos.l 
EndStructure 

EnableExplicit 

Procedure NetBuff_ReallocateMemory(*Buff.NetBuff_Param, AddBytes) ; Нужно ли увеличить память под данные, принимаемые от пира? 
  Protected Len, Pos, NewLen, *Point 
  Protected *NewPoint, i 
  
  Len = *Buff\Len 
  Pos = *Buff\Pos 
  *Point = *Buff\Buff 
  
  If AddBytes>0 
    NewLen = 0 
    If Pos>Len Or Len-Pos < AddBytes Or *Point=0; Нужно изменить (увеличить) размер памяти. 
      NewLen = Len+AddBytes+100 
    ElseIf Len-Pos > AddBytes+400 ; Памяти выдленено слишком много и надо уменьшить. 
      NewLen = AddBytes+Pos+80 
    EndIf 
    
    If NewLen > 0 
      For i=1 To 4 
        *NewPoint = ReAllocateMemory(*Point, NewLen) 
        If *NewPoint 
          *Buff\Buff = *NewPoint 
          *Buff\Len = NewLen 
          If *Buff\Len>NewLen 
            *Buff\Len=NewLen 
          EndIf 
          Len = NewLen 
          Break 
        Else 
          Delay(4) 
        EndIf 
      Next i 
    EndIf 
    
  EndIf 
  
  ProcedureReturn Len 
EndProcedure 


Procedure NetBuff_AddMem(*Buff.NetBuff_Param, *Mem, AddBytes) ; Добавление принятых жанных от пира, в память еще необработанных сообщений. 
  Protected NewLen 
  
  NewLen=NetBuff_ReallocateMemory(*Buff, AddBytes) ; Выделение памяти 
  If NewLen>0 And *Buff\Len >= AddBytes+*Buff\Pos ; Память выделена 
    CopyMemory(*Mem, *Buff\Buff+*Buff\Pos, AddBytes) 
    *Buff\Pos + AddBytes 
  EndIf 
  
EndProcedure 


Procedure NetBuff_DelMem(*Buff.NetBuff_Param, DelBytes) ; Удаление принятых данных от пира, из памяти после успешной обработки сообщения. 
  
  If *Buff\Buff 
    If *Buff\Pos <= DelBytes 
      *Buff\Pos = 0 
    Else 
      If *Buff\Pos>DelBytes 
        MoveMemory(*Buff\Buff+DelBytes, *Buff\Buff, *Buff\Pos-DelBytes) ; 
      EndIf 
      *Buff\Pos - DelBytes 
      If *Buff\Pos<0 
        *Buff\Pos=0 
      EndIf 
    EndIf 
  EndIf 
  
EndProcedure 


Enumeration 
  #NetPacketType_EndProg 
  #NetPacketType_Data 
EndEnumeration 

Structure NetPacket_Header 
  Size.u 
  Type.u 
EndStructure 

Structure NetPacket_EndData 
  Header.NetPacket_Header 
EndStructure 

Structure NetPacket_Data 
  Header.NetPacket_Header 
  Buff.a[0] 
EndStructure 


Procedure Net_InData(Connect, *Point, Size, *BuffInfo.NetBuff_Param) 
  Protected InBytes, *Header.NetPacket_Header 
  Protected Result 
  
  NetBuff_AddMem(*BuffInfo, *Point, Size) 
  Result = #False 
  
  Repeat 
    
    If *BuffInfo\Pos>=SizeOf(NetPacket_Header) 
      
      *Header = *BuffInfo\Buff 
      
      If *BuffInfo\Pos >= *Header\Size 
        
        Select *Header\Type 
          Case #NetPacketType_EndProg 
            Protected *EndData.NetPacket_EndData = *BuffInfo\Buff 
            
            Result = #True 
            
            NetBuff_DelMem(*BuffInfo, *Header\Size) 
            
          Case #NetPacketType_Data 
            Protected *Data.NetPacket_Data = *BuffInfo\Buff 
            
            Debug PeekS(@*Data\Buff[0], *Data\Header\Size-OffsetOf(NetPacket_Data\Buff)) 
            
            NetBuff_DelMem(*BuffInfo, *Header\Size) 
            
            
        EndSelect 
        
      Else 
        Break 
      EndIf 
      
    EndIf 
    
  Until *BuffInfo\Pos < SizeOf(NetPacket_Header) 
  
  ProcedureReturn Result 
  
EndProcedure 

InitNetwork() 

Define Connect = OpenNetworkConnection("127.0.0.1", 2222, #PB_Network_TCP) 
If Connect 
  
  Define *Point = AllocateMemory(65536) 
  If *Point 
    Define BuffInfo.NetBuff_Param\Buff = AllocateMemory(10) 
    BuffInfo\Len=10 
    BuffInfo\Pos=0 
    If BuffInfo\Buff 
      
      Repeat 
        Define NetEvent = NetworkClientEvent(Connect) 
        If NetEvent = #PB_NetworkEvent_Data 
          Define InBytes = ReceiveNetworkData(Connect, *Point, 65536) 
          If Net_InData(Connect, *Point, InBytes, @BuffInfo) 
            Break 
          EndIf 
        Else 
          Delay(10) 
        EndIf 
      ForEver 
      
      CloseNetworkConnection(Connect) 
      
      FreeMemory(BuffInfo\Buff) 
    EndIf 
    FreeMemory(*Point) 
  EndIf 
Else 
  Debug "Нет связи" 
EndIf

Enumeration 
  #NetPacketType_EndProg 
  #NetPacketType_Data 
EndEnumeration 

Structure NetPacket_Header 
  Size.u 
  Type.u 
EndStructure 

Structure NetPacket_EndData 
  Header.NetPacket_Header 
EndStructure 

Structure NetPacket_Data 
  Header.NetPacket_Header 
  Buff.a[0] 
EndStructure 

;Header.NetPacket_Header 
EndData.NetPacket_EndData 


Procedure Send(Connect, String.s) 
  NetPacket_Data.NetPacket_Data 
  
  NetPacket_Data\Header\Size = SizeOf(NetPacket_Header)+StringByteLength(String) 
  NetPacket_Data\Header\Type = #NetPacketType_Data 
  
  SendNetworkData(Connect, @NetPacket_Data\Header, SizeOf(NetPacket_Header)) 
  SendNetworkData(Connect, @String, StringByteLength(String)) 
  
EndProcedure 

If InitNetwork() = 0 
  MessageRequester("Error", "Can't initialize the network !", 0) 
  End 
EndIf 

Port = 2222 
*Buffer = AllocateMemory(1000) 

If CreateNetworkServer(0, Port) 
  
  Repeat 
    
    SEvent = NetworkServerEvent() 
    
    If SEvent 
      
      ClientID = EventClient() 
      
      Select SEvent 
          
        Case #PB_NetworkEvent_Connect 
          
          Send(ClientID, "Первая строка") 
          Send(ClientID, "Еще строка") 
          Send(ClientID, "Строка № 3") 
          Send(ClientID, "Больше нет строк") 
          
          EndData\Header\Size = SizeOf(NetPacket_Header) 
          EndData\Header\Type = #NetPacketType_EndProg 
          SendNetworkData(ClientID, @EndData, SizeOf(NetPacket_Header)) 
          
        Case #PB_NetworkEvent_Disconnect 
          MessageRequester("PureBasic - Server", "Client "+Str(ClientID)+" has closed the connection...", 0) 
          Quit = 1 
          
      EndSelect 
    EndIf 
    
  Until Quit = 1 
  
  MessageRequester("PureBasic - Server", "Click to quit the server.", 0) 
  
  CloseNetworkServer(0) 
Else 
  MessageRequester("Error", "Can't create the server (port in use ?).", 0) 
EndIf 


End