cdffdd25e1
Defines are defined in wsdefines.pas Removing SUPEROBJECT allow to release under MPL license (which i expect) Also fix * bug : framing encoding when sending a frame in multiple parts (fin=false) * bug : TIdIOHandlerWebsocket TIdIOHandlerWebsocket.ReadFrame _WaitByte ; may hang Other changes * Refactoring of TIdServerWebsocketHandling.ProcessServerCommandGet for inheritance * Add event (TIdServerWSContext) to accept or refuse upgrade (allow to check session cookie) * Change TWebsocketChannelRequest var aType:TWSDataType to allow receiving in a mode and answering in an other To use OpenSSL you need a modification in IdSSLOpenSSL to let overwrite TIdSSLIOHandlerSocketOpenSSL class
86 lines
2.8 KiB
ObjectPascal
86 lines
2.8 KiB
ObjectPascal
unit IdServerWebsocketContext;
|
|
interface
|
|
{$I wsdefines.pas}
|
|
uses
|
|
Classes, strUtils
|
|
, IdContext
|
|
, IdCustomTCPServer
|
|
, IdCustomHTTPServer
|
|
//
|
|
, IdIOHandlerWebsocket
|
|
, IdServerBaseHandling
|
|
, IdServerSocketIOHandling
|
|
;
|
|
|
|
type
|
|
TIdServerWSContext = class;
|
|
|
|
TWebSocketUpgradeEvent = procedure(const AContext: TIdServerWSContext; ARequestInfo: TIdHTTPRequestInfo; var Accept:boolean) of object;
|
|
TWebsocketChannelRequest = procedure(const AContext: TIdServerWSContext; var aType:TWSDataType; const strmRequest, strmResponse: TMemoryStream) of object;
|
|
|
|
TIdServerWSContext = class(TIdServerContext)
|
|
private
|
|
FWebSocketKey: string;
|
|
FWebSocketVersion: Integer;
|
|
FPath: string;
|
|
FWebSocketProtocol: string;
|
|
FResourceName: string;
|
|
FOrigin: string;
|
|
FQuery: string;
|
|
FHost: string;
|
|
FWebSocketExtensions: string;
|
|
FCookie: string;
|
|
//FSocketIOPingSend: Boolean;
|
|
fOnWebSocketUpgrade: TWebSocketUpgradeEvent;
|
|
FOnCustomChannelExecute: TWebsocketChannelRequest;
|
|
FSocketIO: TIdServerSocketIOHandling;
|
|
FOnDestroy: TIdContextEvent;
|
|
public
|
|
function IOHandler: TIdIOHandlerWebsocket;
|
|
public
|
|
function IsSocketIO: Boolean;
|
|
property SocketIO: TIdServerSocketIOHandling read FSocketIO write FSocketIO;
|
|
//property SocketIO: TIdServerBaseHandling read FSocketIO write FSocketIO;
|
|
property OnDestroy: TIdContextEvent read FOnDestroy write FOnDestroy;
|
|
public
|
|
destructor Destroy; override;
|
|
|
|
property Path : string read FPath write FPath;
|
|
property Query : string read FQuery write FQuery;
|
|
property ResourceName: string read FResourceName write FResourceName;
|
|
property Host : string read FHost write FHost;
|
|
property Origin : string read FOrigin write FOrigin;
|
|
property Cookie : string read FCookie write FCookie;
|
|
|
|
property WebSocketKey : string read FWebSocketKey write FWebSocketKey;
|
|
property WebSocketProtocol : string read FWebSocketProtocol write FWebSocketProtocol;
|
|
property WebSocketVersion : Integer read FWebSocketVersion write FWebSocketVersion;
|
|
property WebSocketExtensions: string read FWebSocketExtensions write FWebSocketExtensions;
|
|
public
|
|
property OnWebSocketUpgrade: TWebsocketUpgradeEvent read FOnWebSocketUpgrade write FOnWebSocketUpgrade;
|
|
property OnCustomChannelExecute: TWebsocketChannelRequest read FOnCustomChannelExecute write FOnCustomChannelExecute;
|
|
end;
|
|
|
|
implementation
|
|
|
|
{ TIdServerWSContext }
|
|
|
|
destructor TIdServerWSContext.Destroy;
|
|
begin
|
|
if Assigned(OnDestroy) then
|
|
OnDestroy(Self);
|
|
inherited;
|
|
end;
|
|
|
|
function TIdServerWSContext.IOHandler: TIdIOHandlerWebsocket;
|
|
begin
|
|
Result := Self.Connection.IOHandler as TIdIOHandlerWebsocket;
|
|
end;
|
|
|
|
function TIdServerWSContext.IsSocketIO: Boolean;
|
|
begin
|
|
//FDocument = '/socket.io/1/websocket/13412152'
|
|
Result := StartsText('/socket.io/1/websocket/', FPath);
|
|
end;
|
|
|
|
end.
|