Régys Borges da Silveira

program ServerLifecycleDemo;

{$APPTYPE CONSOLE}

uses
  System.SysUtils,
  Horse;

type
  TServerEventListener = class
  public
    // Método de objeto compatível com THorseServerLifecycleMethod
    procedure OnBeforeListen(const AInstance: THorseInstance);
    procedure OnAfterStop(const AInstance: THorseInstance);
  end;

{ TServerEventListener }

procedure TServerEventListener.OnBeforeListen(const AInstance: THorseInstance);
begin
  Writeln(' -> [MÉTODO] 1. Antes de escutar: Configurando firewalls locais no host...');
end;

procedure TServerEventListener.OnAfterStop(const AInstance: THorseInstance);
begin
  Writeln(' -> [MÉTODO] 4. Após parar: Conexões encerradas de forma limpa.');
end;

var
  LListener: TServerEventListener;

begin
  try
    LListener := TServerEventListener.Create;
    try
      // ========================================================
      // 1. REGISTRO VIA MÉTODOS DE OBJETO (Method of Object)
      // ========================================================
      THorse.AddOnBeforeListen(LListener.OnBeforeListen);
      THorse.AddOnAfterStop(LListener.OnAfterStop);

      // ========================================================
      // 2. REGISTRO VIA PROCEDIMENTOS ANÔNIMOS (Anonymous Proc)
      // ========================================================
      
      // Executa imediatamente após o socket abrir na rede
      THorse.AddOnAfterListen(
        procedure(const AInstance: THorseInstance)
        begin
          Writeln(' -> [ANÔNIMO] 2. Servidor online! Escutando em http://', AInstance.Host, ':', AInstance.Port);
        end);

      // Executa assim que a sinalização de Stop é recebida, antes de fechar o socket
      THorse.AddOnBeforeStop(
        procedure(const AInstance: THorseInstance)
        begin
          Writeln(' -> [ANÔNIMO] 3. Sinal de parada capturado! Iniciando drenagem de requisições...');
        end);

      // Rota de teste
      THorse.Get('/ping',
        procedure(Req: THorseRequest; Res: THorseResponse; Next: TNextProc)
        begin
          Res.Send('pong');
        end);

      // Inicializa a escuta física (dispara OnBeforeListen e OnAfterListen)
      THorse.Listen(9000);

    finally
      LListener.Free;
    end;
  except
    on E: Exception do
      Writeln(E.ClassName, ': ', E.Message);
  end;
end.

unit Startup;

interface

uses
  Horse, System.SysUtils;

type
  TMyStartup = class(TInterfacedObject, IHorseStartup)
  private
    procedure RegisterMiddlewares(const AInstance: THorseInstance);
    procedure RegisterRoutes(const AInstance: THorseInstance);
    procedure RegisterLifecycleHooks(const AInstance: THorseInstance);
  public
    procedure Configure(const AInstance: THorseInstance);
  end;

implementation

{ TMyStartup }

procedure TMyStartup.Configure(const AInstance: THorseInstance);
begin
  // Configurações Globais da Instância
  ReportMemoryLeaksOnShutdown := True;

  RegisterLifecycleHooks(AInstance);
  RegisterMiddlewares(AInstance);
  RegisterRoutes(AInstance);
end;

procedure TMyStartup.RegisterLifecycleHooks(const AInstance: THorseInstance);
begin
  // Monitoramento físico do ciclo de vida
  AInstance.AddOnBeforeListen(
    procedure(const AInst: THorseInstance)
    begin
      Writeln(' -> [LOG] Preparando para abrir o socket físico...');
    end);

  AInstance.AddOnAfterListen(
    procedure(const AInst: THorseInstance)
    begin
      Writeln(' -> [LOG] Servidor online e ativo na porta: ', AInst.Port);
    end);

  AInstance.AddOnBeforeStop(
    procedure(const AInst: THorseInstance)
    begin
      Writeln(' -> [LOG] Iniciando Graceful Shutdown (aguardando finalização de requisições ativas)...');
    end);
end;

procedure TMyStartup.RegisterMiddlewares(const AInstance: THorseInstance);
begin
  // Adicione seus middlewares favoritos aqui (JSON Parser, CORS, etc.)
  // AInstance.Use(HorseJhonson);
end;

procedure TMyStartup.RegisterRoutes(const AInstance: THorseInstance);
begin
  AInstance.Get('/ping',
    procedure(Req: THorseRequest; Res: THorseResponse; Next: TNextProc)
    begin
      Res.Send('pong');
    end);

  AInstance.Get('/api/v1/status',
    procedure(Req: THorseRequest; Res: THorseResponse; Next: TNextProc)
    begin
      Res.Send('{"status":"online"}');
    end);
end;

end.

program AppServer;

{$APPTYPE CONSOLE}

uses
  System.SysUtils,
  Horse,
  Startup in 'Startup.pas';

var
  LStartup: IHorseStartup;
begin
  try
    Writeln('====================================================');
    Writeln('    Servidor Corporativo Delphi (UseStartup)        ');
    Writeln('====================================================');

    // Instanciamos o configurador isolado
    LStartup := TMyStartup.Create;

    // Injetamos a inicialização e ativamos a escuta
    THorse.UseStartup(LStartup).Listen(9000);

  except
    on E: Exception do
      Writeln(E.ClassName, ': ', E.Message);
  end;
end.