// 1. Drop TMorMotServer on form
// 2. Configure basic properties
procedure TServerForm.FormCreate(Sender: TObject);
begin
  MorMotServer1.Port := 8080;
  MorMotServer1.MaxConnections := 500;
  MorMotServer1.Active := True;  // Start server
end;

// 3. Handle incoming data
function TServerForm.MorMotServer1HandleCommand(Sender: TObject; 
  Client: TmMServerClient; aData: TBytes): TBytes;
var
  ReceivedText: string;
begin
  // Convert received bytes to string
  ReceivedText := StringOf(aData);
  ShowMessage('Received: ' + ReceivedText);
  
  // Echo back with confirmation
  Result := BytesOf('Echo: ' + ReceivedText);
end;

// 4. Handle client connections
procedure TServerForm.MorMotServer1Connect(Sender: TObject; 
  Client: TmMServerClient);
begin
  Memo1.Lines.Add(Format('Client connected: %s:%d', 
    [Client.PeerIP, Client.PeerPort]));
end;

// 1. Drop TMorMotClient on form
// 2. Configure connection
procedure TClientForm.FormCreate(Sender: TObject);
begin
  MorMotClient1.Host := '127.0.0.1';
  MorMotClient1.Port := 8080;
  MorMotClient1.AutoReconnect := True;
  MorMotClient1.ReconnectStrategy := rsBackoff;
end;

// 3. Connect to server
procedure TClientForm.ButtonConnectClick(Sender: TObject);
begin
  MorMotClient1.Active := True;
end;

// 4. Send data
procedure TClientForm.ButtonSendClick(Sender: TObject);
var
  Data: TBytes;
begin
  Data := BytesOf('Hello Server!');
  MorMotClient1.SendData(Data, False);  // Unencrypted
end;

// 5. Handle connection events
procedure TClientForm.MorMotClient1Connect(Sender: TObject);
begin
  ShowMessage('Connected to server!');
end;

procedure TServerForm.FormCreate(Sender: TObject);
begin
  // Configure encryption
  MorMotServer1.EncryptionKey := 'MySecretKey123!';
  MorMotServer1.EncryptionMode := amCBC;
  MorMotServer1.EncryptionKeySize := aks256;
  MorMotServer1.Active := True;
end;

// Send encrypted response
function TServerForm.MorMotServer1HandleCommand(Sender: TObject; 
  Client: TmMServerClient; aData: TBytes): TBytes;
begin
  // Process data...
  Result := BytesOf('Encrypted response');
  
  // Response will be encrypted automatically if client sent encrypted data
end;

// Send encrypted data to specific client
procedure TServerForm.SendEncryptedMessage(Client: TmMServerClient);
var
  Data: TBytes;
begin
  Data := BytesOf('Secret message');
  Client.SendData(Data, True);  // Encrypted = True
end;

procedure TClientForm.FormCreate(Sender: TObject);
begin
  // Must match server encryption settings
  MorMotClient1.EncryptionKey := 'MySecretKey123!';
  MorMotClient1.EncryptionMode := amCBC;
  MorMotClient1.EncryptionKeySize := aks256;
end;

// Send encrypted message
procedure TClientForm.SendEncryptedData;
var
  Data: TBytes;
begin
  Data := BytesOf('Top secret data');
  MorMotClient1.SendData(Data, True);  // Encrypted = True
end;

// Send unencrypted message (mixed mode)
procedure TClientForm.SendPlainData;
var
  Data: TBytes;
begin
  Data := BytesOf('Public data');
  MorMotClient1.SendData(Data, False);  // Encrypted = False
end;

procedure TServerForm.LoopAllClients;
var
  Client: TmMServerClient;
  ClientInfo: string;
begin
  Memo1.Lines.Clear;
  
  // Thread-safe iteration
  MorMotServer1.PropertyLock.Enter;
  try
    for Client in MorMotServer1.Clients.Values do
    begin
      ClientInfo := Format('Handle: %d, IP: %s, Connected: %s, Bytes: %d/%d',
        [Client.Handle, Client.PeerIP, 
         FormatDateTime('hh:nn:ss', Client.ConnectedAt),
         Client.BytesReceived, Client.BytesSent]);
      
      Memo1.Lines.Add(ClientInfo);
    end;
  finally
    MorMotServer1.PropertyLock.Leave;
  end;
  
  Caption := Format('Server - %d clients connected', 
    [MorMotServer1.ClientCount]);
end;

// Broadcast unencrypted message to all clients
procedure TServerForm.BroadcastPlainMessage;
var
  Data: TBytes;
begin
  Data := BytesOf('Broadcast message to all!');
  MorMotServer1.BroadcastData(Data, False);  // Unencrypted
end;

// Broadcast encrypted message to all clients
procedure TServerForm.BroadcastEncryptedMessage;
var
  Data: TBytes;
begin
  Data := BytesOf('Secret broadcast!');
  MorMotServer1.BroadcastData(Data, True);   // Encrypted
end;

// Send to specific client by IP
procedure TServerForm.SendToClientByIP(const IP: string; const Msg: string);
var
  Client: TmMServerClient;
  Data: TBytes;
begin
  Client := MorMotServer1.FindClientByIP(IP);
  if Assigned(Client) then
  begin
    Data := BytesOf(Msg);
    Client.SendData(Data, False);
  end;
end;

// Disconnect all clients
procedure TServerForm.DisconnectAllClientsClick(Sender: TObject);
begin
  MorMotServer1.DisconnectAllClients;
  ShowMessage('All clients disconnected');
end;

// Disconnect specific client by IP
procedure TServerForm.DisconnectClientByIP(const IP: string);
var
  Client: TmMServerClient;
begin
  Client := MorMotServer1.FindClientByIP(IP);
  if Assigned(Client) then
  begin
    Client.Disconnect;
    ShowMessage('Client ' + IP + ' disconnected');
  end;
end;

// Disconnect client by handle
procedure TServerForm.DisconnectClientByHandle(Handle: TPollAsyncConnectionHandle);
begin
  MorMotServer1.DisconnectClient(Handle);
end;

// Update statistics display
procedure TServerForm.Timer1Timer(Sender: TObject);
begin
  StatusBar1.Panels[0].Text := Format('Clients: %d', [MorMotServer1.ClientCount]);
  StatusBar1.Panels[1].Text := Format('Total Connections: %d', [MorMotServer1.TotalConnections]);
  StatusBar1.Panels[2].Text := Format('Bytes Sent: %d', [MorMotServer1.TotalBytesSent]);
  StatusBar1.Panels[3].Text := Format('Bytes Received: %d', [MorMotServer1.TotalBytesReceived]);
  StatusBar1.Panels[4].Text := Format('Uptime: %d sec', [MorMotServer1.UpTime]);
end;

// Configure bulletproof reconnection
procedure TClientForm.SetupReconnection;
begin
  MorMotClient1.AutoReconnect := True;
  MorMotClient1.ReconnectStrategy := rsBackoff;
  MorMotClient1.ReconnectInterval := 1000;      // 1 second base
  MorMotClient1.ReconnectMaxAttempts := 20;     // 20 attempts
end;

// Manual reconnection reset
procedure TClientForm.ResetReconnectionClick(Sender: TObject);
begin
  MorMotClient1.ResetReconnectionState;
  ShowMessage('Reconnection state reset');
end;

// Handle reconnection events
procedure TClientForm.MorMotClient1Error(Sender: TObject; 
  const Error: string; ErrorCode: Integer);
begin
  if ErrorCode = -99 then  // Max attempts reached
  begin
    ShowMessage('Auto-reconnection disabled after max attempts');
  end
  else
  begin
    Memo1.Lines.Add('Error: ' + Error);
  end;
end;

// Configure event threading
procedure TForm1.FormCreate(Sender: TObject);
begin
  // Events fired in main thread (safe for UI updates)
  MorMotServer1.EventsUseMainThread := True;
  
  // Or handle events in background threads (faster)
  // MorMotServer1.EventsUseMainThread := False;
end;

// Handle state changes
procedure TServerForm.MorMotServer1StateChange(Sender: TObject; 
  OldState, NewState: TmMServerState);
const
  StateNames: array[TmMServerState] of string = 
    ('Disconnected', 'Starting', 'Listening', 'Stopping');
begin
  Memo1.Lines.Add(Format('State: %s → %s', 
    [StateNames[OldState], StateNames[NewState]]));
end;

+----------------+----------------+---------------+------------------+
| Magic (4 bytes)| DataSize (4)   | Encrypted (1) | Data (DataSize)  |
+----------------+----------------+---------------+------------------+
| 0xCAFEBABE     | Length of Data | 1=Yes, 0=No   | Actual Data      |
+----------------+----------------+---------------+------------------+

unit ServerMainForm;

interface

uses
  Winapi.Windows, Winapi.Messages, System.SysUtils, System.Variants, 
  System.Classes, Vcl.Graphics, Vcl.Controls, Vcl.Forms, Vcl.Dialogs,
  Vcl.StdCtrls, Vcl.ExtCtrls, mMServer;

type
  TForm1 = class(TForm)
    MorMotServer1: TMorMotServer;
    Memo1: TMemo;
    Panel1: TPanel;
    ButtonStart: TButton;
    ButtonStop: TButton;
    ButtonDisconnectAll: TButton;
    Timer1: TTimer;
    StatusBar1: TStatusBar;
    
    procedure FormCreate(Sender: TObject);
    procedure ButtonStartClick(Sender: TObject);
    procedure ButtonStopClick(Sender: TObject);
    procedure ButtonDisconnectAllClick(Sender: TObject);
    procedure Timer1Timer(Sender: TObject);
    
    // Server events
    function MorMotServer1HandleCommand(Sender: TObject; 
      Client: TmMServerClient; aData: TBytes): TBytes;
    procedure MorMotServer1Connect(Sender: TObject; Client: TmMServerClient);
    procedure MorMotServer1Disconnect(Sender: TObject; Client: TmMServerClient);
    procedure MorMotServer1Error(Sender: TObject; Client: TmMServerClient; 
      const Error: string; ErrorCode: Integer);
  end;

var
  Form1: TForm1;

implementation

{$R *.dfm}

procedure TForm1.FormCreate(Sender: TObject);
begin
  // Configure server
  MorMotServer1.Port := 8080;
  MorMotServer1.MaxConnections := 1000;
  MorMotServer1.EncryptionKey := 'MySecretKey123!';
  MorMotServer1.EncryptionMode := amCBC;
  
  // Start timer for statistics
  Timer1.Interval := 1000;
  Timer1.Enabled := True;
  
  Memo1.Lines.Add('Echo Server Ready - Click Start to begin');
end;

procedure TForm1.ButtonStartClick(Sender: TObject);
begin
  MorMotServer1.Active := True;
  Memo1.Lines.Add('Server started on port ' + IntToStr(MorMotServer1.Port));
end;

procedure TForm1.ButtonStopClick(Sender: TObject);
begin
  MorMotServer1.Active := False;
  Memo1.Lines.Add('Server stopped');
end;

procedure TForm1.ButtonDisconnectAllClick(Sender: TObject);
begin
  MorMotServer1.DisconnectAllClients;
  Memo1.Lines.Add('All clients disconnected');
end;

function TForm1.MorMotServer1HandleCommand(Sender: TObject; 
  Client: TmMServerClient; aData: TBytes): TBytes;
var
  ReceivedText: string;
  Response: string;
begin
  ReceivedText := StringOf(aData);
  Response := 'Echo: ' + ReceivedText;
  
  Memo1.Lines.Add(Format('[%s] %s', [Client.PeerIP, ReceivedText]));
  
  // Return echo response
  Result := BytesOf(Response);
end;

procedure TForm1.MorMotServer1Connect(Sender: TObject; Client: TmMServerClient);
begin
  Memo1.Lines.Add(Format('✅ Client connected: %s:%d (Handle: %d)', 
    [Client.PeerIP, Client.PeerPort, Client.Handle]));
end;

procedure TForm1.MorMotServer1Disconnect(Sender: TObject; Client: TmMServerClient);
begin
  Memo1.Lines.Add(Format('❌ Client disconnected: %s (Handle: %d)', 
    [Client.PeerIP, Client.Handle]));
end;

procedure TForm1.MorMotServer1Error(Sender: TObject; Client: TmMServerClient; 
  const Error: string; ErrorCode: Integer);
begin
  if Assigned(Client) then
    Memo1.Lines.Add(Format('⚠️ Error [%s]: %s', [Client.PeerIP, Error]))
  else
    Memo1.Lines.Add('⚠️ Server Error: ' + Error);
end;

procedure TForm1.Timer1Timer(Sender: TObject);
begin
  Caption := Format('Echo Server - %d clients, %d total connections', 
    [MorMotServer1.ClientCount, MorMotServer1.TotalConnections]);
end;

end.