// *************************************************************************** // // Delphi MVC Framework // // Copyright (c) 2010-2023 Daniele Teti and the DMVCFramework Team // // https://github.com/danieleteti/delphimvcframework // // Collaborators on this file: // Ezequiel Juliano Müller (ezequieljuliano@gmail.com) // João Antônio Duarte (https://github.com/joaoduarte19) // // *************************************************************************** // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // // *************************************************************************** } unit MVCFramework; {$I dmvcframework.inc} {$IF IOS} {$MESSAGE Fatal 'This unit is not compilable on iOS'} {$ENDIF} {$RTTI EXPLICIT METHODS(DefaultMethodRttiVisibility) FIELDS(DefaultFieldRttiVisibility) PROPERTIES(DefaultPropertyRttiVisibility)} {$WARNINGS OFF} interface uses System.Classes, System.SysUtils, System.TypInfo, System.IOUtils, System.SyncObjs, System.DateUtils, System.Generics.Collections, System.Rtti, JSONDataObjects, Data.DB, MVCFramework.Session, MVCFramework.DuckTyping, MVCFramework.Logger, MVCFramework.ApplicationSession, MVCFramework.Serializer.Intf, {$IF Defined(WEBAPACHEHTTP)} Web.ApacheHTTP, // Apache Support since XE6 http://docwiki.embarcadero.com/Libraries/XE6/de/Web.ApacheHTTP {$ENDIF} // Delphi XE4 (all update) and XE5 (with no update) don't contains this unit. Look for the bug in QC // https://quality.embarcadero.com/browse/RSP-17216 {$IF NOT Defined(MOBILE)} // file upload is not supported on mobile {$IF Defined(SeattleOrBetter)} Web.ReqMulti, {$ELSE} ReqMulti, {$ENDIF} {$ENDIF} Web.HTTPApp, {$IF Defined(MSWINDOWS)} Web.Win.IsapiHTTP, {$ENDIF} Web.WebReq, LoggerPro, IdGlobal, IdGlobalProtocols, Swag.Doc, Swag.Common.Types, MVCFramework.Commons, MVCFramework.Serializer.Commons; type TSessionData = TDictionary; TMVCCustomData = TSessionData; TMVCBaseViewEngine = class; TMVCViewEngineClass = class of TMVCBaseViewEngine; MVCBaseAttribute = class(TCustomAttribute) private { private declarations } protected { protected declarations } public { public declarations } end; MVCRequiresAuthenticationAttribute = class(MVCBaseAttribute) end; MVCHTTPMethodsAttribute = class(MVCBaseAttribute) private FMVCHTTPMethods: TMVCHTTPMethods; function GetMVCHTTPMethodsAsString: string; protected { protected declarations } public constructor Create(const AMVCHTTPMethods: TMVCHTTPMethods); property MVCHTTPMethods: TMVCHTTPMethods read FMVCHTTPMethods; property MVCHTTPMethodsAsString: string read GetMVCHTTPMethodsAsString; end; MVCHTTPMethodAttribute = MVCHTTPMethodsAttribute; MVCStringAttribute = class(MVCBaseAttribute) private FValue: string; protected { protected declarations } public constructor Create(const AValue: string); property Value: string read FValue; end; MVCIntegerAttribute = class(MVCBaseAttribute) private FValue: Int64; protected { protected declarations } public constructor Create(const AValue: Int64); property Value: Int64 read FValue; end; MVCConsumesAttribute = class(MVCStringAttribute) private { private declarations } protected { protected declarations } public { public declarations } end; MVCProducesAttribute = class(MVCStringAttribute) private FCharset: string; protected { protected declarations } public constructor Create(const AValue: string); overload; constructor Create(const AValue: string; const ACharset: string); overload; property Charset: string read FCharset; end; MVCDocAttribute = class(MVCStringAttribute) private { private declarations } protected { protected declarations } public { public declarations } end; MVCFormatAttribute = class(MVCStringAttribute) private { private declarations } protected { protected declarations } public { public declarations } end; MVCMaxLengthAttribute = class(MVCIntegerAttribute) private { private declarations } protected { protected declarations } public { public declarations } end; MVCMinimumAttribute = class(MVCIntegerAttribute) private { private declarations } protected { protected declarations } public { public declarations } end; MVCMaximumAttribute = class(MVCIntegerAttribute) private { private declarations } protected { protected declarations } public { public declarations } end; MVCInheritableAttribute = class(MVCBaseAttribute) private { private declarations } protected { protected declarations } public { public declarations } end; MVCPathAttribute = class(MVCBaseAttribute) private FPath: string; protected { protected declarations } public constructor Create(const APath: string); overload; property Path: string read FPath; end; MVCResponseAttribute = class(MVCBaseAttribute) private FStatusCode: Integer; FDescription: string; FResponseClass: TClass; protected { protected declarations } public constructor Create(inStatusCode: Integer; const inDescription: string; inResponseClass: TClass = nil); overload; property StatusCode: Integer read FStatusCode; property Description: string read FDescription; property ResponseClass: TClass read FResponseClass; end; MVCResponseListAttribute = class(MVCBaseAttribute) private FStatusCode: Integer; FDescription: string; FResponseClass: TClass; protected { protected declarations } public constructor Create(inStatusCode: Integer; const inDescription: string; inResponseClass: TClass = nil); overload; property StatusCode: Integer read FStatusCode; property Description: string read FDescription; property ResponseClass: TClass read FResponseClass; end; MVCPathParamAttribute = class(MVCBaseAttribute) private FType: TSwagTypeParameter; FFormat: string; FValue: string; public constructor Create(AType: TSwagTypeParameter; APattern: string = ''; AFormat: string = ''); property ParamType: TSwagTypeParameter read FType; property Format: string read FFormat; property Pattern: string read FValue; end; MVCParamAttribute = class(MVCStringAttribute) private FName: string; FLocation: TSwagRequestParameterInLocation; FType: TSwagTypeParameter; FClassType: TClass; FPattern: string; FFormat: string; public property name: string read FName write FName; property Location: TSwagRequestParameterInLocation read FLocation write FLocation; property ParamType: TSwagTypeParameter read FType write FType; property ClassType: TClass read FClassType write FClassType; property Pattern: string read FPattern write FPattern; property Format: string read FFormat write FFormat; constructor Create(name: string; Location: TSwagRequestParameterInLocation; AType: TSwagTypeParameter; APattern: string = ''; AFormat: string = ''); overload; constructor Create(name: string; Location: TSwagRequestParameterInLocation; AType: TClass; APattern: string = ''; AFormat: string = ''); overload; end; MVCPatternAttribute = class(MVCStringAttribute) end; MVCStringEnumAttribute = class(MVCBaseAttribute) private fValues: string; public constructor Create(const enumValue: string); property Values: string read fValues write fValues; end; MVCFromBodyAttribute = class(MVCBaseAttribute) private fRootNode: string; fDataType: TMVCDataType; public constructor Create(const RootNode: string = ''; const DataType: TMVCDataType = TMVCDataType.dtObject); function DataType: TMVCDataType; function RootNode: String; end; MVCInjectableParamAttribute = class(MVCBaseAttribute) private FParamName: string; FDefaultValueAsString: string; FCanBeUsedADefaultValue: Boolean; public constructor Create(const AParamName: string); overload; constructor Create(const AParamName: string; const DefaultAsString: string); overload; constructor Create(const AParamName: string; const DefaultAsInteger: Int64); overload; constructor Create(const AParamName: string; const DefaultAsBoolean: Boolean); overload; property ParamName: string read FParamName; property DefaultValueAsString: string read FDefaultValueAsString; property CanBeUsedADefaultValue: Boolean read FCanBeUsedADefaultValue; end; MVCFromQueryStringAttribute = class(MVCInjectableParamAttribute) end; MVCFromHeaderAttribute = class(MVCInjectableParamAttribute) end; MVCFromCookieAttribute = class(MVCInjectableParamAttribute) end; // test // TMVCHackHTTPAppRequest = class(TIdHTTPAppRequest) // private // function GetHeaders: TStringList; // public // property Headers: TStringList read GetHeaders; // end; // test-end TMVCWebRequest = class private FQueryParams: TDictionary; FContentFields: TDictionary; FWebRequest: TWebRequest; FSerializers: TDictionary; FBody: string; FContentType: string; FCharset: string; FParamsTable: TMVCRequestParamsTable; FContentMediaType: string; procedure DefineContentType; function GetContentFields: TDictionary; function GetQueryParams: TDictionary; function GetHeader(const AName: string): string; function GetPathInfo: string; function GetParams(const AParamName: string): string; function GetIsAjax: Boolean; function GetHTTPMethod: TMVCHTTPMethodType; function GetHTTPMethodAsString: string; function GetParamAsInteger(const AParamName: string): Integer; function GetParamAsInt64(const AParamName: string): Int64; function GetFiles: TAbstractWebRequestFiles; function GetParamNames: TArray; function GetParamsMulti(const AParamName: string): TArray; protected { protected declarations } procedure EnsureINDY; public constructor Create(const AWebRequest: TWebRequest; const ASerializers: TDictionary); destructor Destroy; override; function ClientIp: string; function ClientPrefer(const AMediaType: string): Boolean; function ClientPreferHTML: Boolean; function GetOverwrittenHTTPMethod: TMVCHTTPMethodType; function SegmentParam(const AParamName: string; out AValue: string): Boolean; function SegmentParamsCount: Integer; function ThereIsRequestBody: Boolean; procedure EnsureQueryParamExists(const AName: string); function QueryString: string; function QueryStringParam(const AName: string): string; function QueryStringParamExists(const AName: string): Boolean; function QueryStringParams: TStrings; function Accept: string; function BestAccept: string; function ContentParam(const AName: string): string; function Cookie(const AName: string): string; function Body: string; function BodyAs(const RootNode: string = ''): T; function BodyAsListOf(const RootNode: string = ''): TObjectList; procedure BodyFor(const AObject: T; const RootNode: string = ''); procedure BodyForListOf(const AObjectList: TObjectList; const RootNode: string = ''); // function HeaderNames: TArray; property RawWebRequest: TWebRequest read FWebRequest; property ContentMediaType: string read FContentMediaType; property ContentType: string read FContentType; property ContentCharset: string read FCharset; property ContentFields: TDictionary read GetContentFields; property QueryParams: TDictionary read GetQueryParams; property Headers[const AHeaderName: string]: string read GetHeader; property PathInfo: string read GetPathInfo; property ParamsTable: TMVCRequestParamsTable read FParamsTable write FParamsTable; property ParamNames: TArray read GetParamNames; property Params[const AParamName: string]: string read GetParams; property ParamsMulti[const AParamName: string]: TArray read GetParamsMulti; property ParamsAsInteger[const AParamName: string]: Integer read GetParamAsInteger; property ParamsAsInt64[const AParamName: string]: Int64 read GetParamAsInt64; property IsAjax: Boolean read GetIsAjax; property HTTPMethod: TMVCHTTPMethodType read GetHTTPMethod; property HTTPMethodAsString: string read GetHTTPMethodAsString; property Files: TAbstractWebRequestFiles read GetFiles; end; {$IF Defined(WEBAPACHEHTTP)} TMVCApacheWebRequest = class(TMVCWebRequest) private { private declarations } protected { protected declarations } public { public declarations } end; {$ENDIF} TMVCISAPIWebRequest = class(TMVCWebRequest) private { private declarations } protected { protected declarations } public { public declarations } end; TMVCIndyWebRequest = class(TMVCWebRequest) private { private declarations } protected { protected declarations } public // function RawHeaders: TStrings; override; end; TMVCWebResponse = class private FWebResponse: TWebResponse; FFlushOnDestroy: Boolean; function GetCustomHeaders: TStrings; function GetReasonString: string; function GetStatusCode: Integer; function GetCookies: TCookieCollection; function GetContentType: string; function GetLocation: string; function GetContent: string; procedure SetReasonString(const AValue: string); procedure SetStatusCode(const AValue: Integer); procedure SetContentType(const AValue: string); procedure SetLocation(const AValue: string); procedure SetContent(const AValue: string); public constructor Create(const AWebResponse: TWebResponse); destructor Destroy; override; procedure Flush; procedure SetCustomHeader(const AName, AValue: string); procedure SetContentStream(const AStream: TStream; const AContentType: string); property StatusCode: Integer read GetStatusCode write SetStatusCode; property ReasonString: string read GetReasonString write SetReasonString; property ContentType: string read GetContentType write SetContentType; property CustomHeaders: TStrings read GetCustomHeaders; property Cookies: TCookieCollection read GetCookies; property Location: string read GetLocation write SetLocation; property RawWebResponse: TWebResponse read FWebResponse; property Content: string read GetContent write SetContent; property FlushOnDestroy: Boolean read FFlushOnDestroy write FFlushOnDestroy; end; TUser = class private FUserName: string; FRoles: TList; FLoggedSince: TDateTime; FRealm: string; FCustomData: TMVCCustomData; procedure SetLoggedSince(const AValue: TDateTime); procedure SetCustomData(const Value: TMVCCustomData); public constructor Create; destructor Destroy; override; function IsValid: Boolean; procedure Clear; procedure SaveToSession(const AWebSession: TWebSession); function LoadFromSession(const AWebSession: TWebSession): Boolean; property UserName: string read FUserName write FUserName; property Roles: TList read FRoles; property LoggedSince: TDateTime read FLoggedSince write SetLoggedSince; property Realm: string read FRealm write FRealm; property CustomData: TMVCCustomData read FCustomData write SetCustomData; end; TWebContext = class private FRequest: TMVCWebRequest; FResponse: TMVCWebResponse; FConfig: TMVCConfig; FSerializers: TDictionary; FIsSessionStarted: Boolean; FSessionMustBeClose: Boolean; FLoggedUser: TUser; FWebSession: TWebSession; FData: TMVCStringDictionary; fIntfObject: IInterface; function GetWebSession: TWebSession; function GetLoggedUser: TUser; function GetParamsTable: TMVCRequestParamsTable; procedure SetParamsTable(const AValue: TMVCRequestParamsTable); function GetHostingFrameworkType: TMVCHostingFrameworkType; function GetIntfObject: IInterface; procedure SetIntfObject(const Value: IInterface); protected fActionQualifiedName: String; procedure Flush; virtual; procedure BindToSession(const ASessionId: string); function SendSessionCookie(const AContext: TWebContext): string; function AddSessionToTheSessionList(const ASessionType, ASessionId: string; const ASessionTimeout: Integer): TWebSession; function GetData: TMVCStringDictionary; public constructor Create(const ARequest: TWebRequest; const AResponse: TWebResponse; const AConfig: TMVCConfig; const ASerializers: TDictionary); destructor Destroy; override; procedure SessionStart; virtual; procedure SessionStop(const ARaiseExceptionIfExpired: Boolean = True); virtual; function SessionStarted: Boolean; function SessionId: string; function IsSessionStarted: Boolean; function SessionMustBeClose: Boolean; property HostingFrameworkType: TMVCHostingFrameworkType read GetHostingFrameworkType; property LoggedUser: TUser read GetLoggedUser; property Request: TMVCWebRequest read FRequest; property Response: TMVCWebResponse read FResponse; property Session: TWebSession read GetWebSession; property Config: TMVCConfig read FConfig; property Data: TMVCStringDictionary read GetData; property CustomIntfObject: IInterface read GetIntfObject write SetIntfObject; property ParamsTable: TMVCRequestParamsTable read GetParamsTable write SetParamsTable; property ActionQualifiedName: String read fActionQualifiedName; end; TMVCJSONRPCExceptionErrorInfo = record Code: Integer; Msg: string; Data: TValue; end; TMVCEngine = class; TMVCBase = class private FEngine: TMVCEngine; FApplicationSession: TWebApplicationSession; function GetEngine: TMVCEngine; function GetConfig: TMVCConfig; function GetApplicationSession: TWebApplicationSession; procedure SetApplicationSession(const AValue: TWebApplicationSession); procedure SetEngine(const AValue: TMVCEngine); protected class function GetApplicationFileName: string; static; class function GetApplicationFileNamePath: string; static; public property Engine: TMVCEngine read GetEngine write SetEngine; property Config: TMVCConfig read GetConfig; property ApplicationSession: TWebApplicationSession read GetApplicationSession write SetApplicationSession; end; TMVCResponse = class; TMVCErrorResponse = class; IMVCRenderer = interface ['{2FF6DAC8-2F19-4C78-B9EC-A86296847D39}'] procedure Render(const AContent: string); overload; procedure Render(const AObject: TObject); overload; procedure Render(const AObject: TObject; const AOwns: Boolean); overload; procedure Render(const AObject: TObject; const AOwns: Boolean; const AType: TMVCSerializationType); overload; procedure Render(const AStatusCode: Integer; AObject: TObject; const AOwns: Boolean; const ASerializationAction: TMVCSerializationAction = nil); overload; procedure Render(const ACollection: IMVCList); overload; procedure Render(const ACollection: IMVCList; const AType: TMVCSerializationType); overload; procedure Render(const ADataSet: TDataSet; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; procedure Render(const ADataSet: TDataSet; const AOwns: Boolean; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; procedure Render(const ADataSet: TDataSet; const AOwns: Boolean; const ASerializationType: TMVCDatasetSerializationType; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; procedure Render(const ADataSet: TDataSet; const AOwns: Boolean; const AIgnoredFields: TMVCIgnoredList; const ASerializationType: TMVCDatasetSerializationType; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; procedure Render(const ADataSet: TDataSet; const AOwns: Boolean; const AIgnoredFields: TMVCIgnoredList; const ANameCase: TMVCNameCase; const ASerializationType: TMVCDatasetSerializationType; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; procedure Render(const ATextWriter: TTextWriter; const AOwns: Boolean = True); overload; procedure Render(const AStream: TStream; const AOwns: Boolean = True); overload; procedure Render(const AErrorCode: Integer; const AErrorMessage: string; const AErrorClassName: string = ''); overload; procedure Render(const AException: Exception; AExceptionItems: TList = nil; const AOwns: Boolean = True); overload; procedure Render(const AResponse: TMVCResponse; const AOwns: Boolean = True); overload; // SSE Support procedure RenderSSE(const EventID: string; const EventData: string; EventName: string = ''; const Retry: Integer = TMVCConstants.SSE_RETRY_DEFAULT); procedure SendStream(const AStream: TStream; const AOwns: Boolean = True; const ARewind: Boolean = False); procedure SendFile(const AFileName: string); procedure RenderResponseStream; function ResponseStream: TStringBuilder; procedure Redirect(const AUrl: string); procedure ResponseStatus(const AStatusCode: Integer; const AReasonString: string = ''); procedure Render201Created(const Location: string = ''); // Serializer access function Serializer: IMVCSerializer; overload; function Serializer(const AContentType: string; const ARaiseExcpIfNotExists: Boolean = True) : IMVCSerializer; overload; end; IMVCAuthenticationHandler = interface ['{19B580EA-8A47-4364-A302-EEF3C6207A9F}'] procedure OnRequest(const AContext: TWebContext; const AControllerQualifiedClassName, AActionName: string; var AAuthenticationRequired: Boolean); procedure OnAuthentication(const AContext: TWebContext; const AUserName, APassword: string; AUserRoles: TList; var AIsValid: Boolean; const ASessionData: TDictionary); procedure OnAuthorization(const AContext: TWebContext; AUserRoles: TList; const AControllerQualifiedClassName: string; const AActionName: string; var AIsAuthorized: Boolean); end; TMVCRenderer = class(TMVCBase) protected FContext: TWebContext; FContentCharset: string; FResponseStream: TStringBuilder; function ToMVCList(const AObject: TObject; AOwnsObject: Boolean = False): IMVCList; public { this must be public because of entity processors } function GetContentType: string; function GetStatusCode: Integer; procedure SetContentType(const AValue: string); procedure SetStatusCode(const AValue: Integer); function GetContext: TWebContext; procedure Redirect(const AUrl: string); virtual; procedure ResponseStatus(const AStatusCode: Integer; const AReasonString: string = ''); virtual; /// /// HTTP Status 201 indicates that as a result of HTTP POST request, one or more new resources have been successfully created on server. /// The response may contain URI in Location header field in HTTP headers list, which can have reference to the newly created resource. Also, response payload also may include an entity containing a list of resource characteristics and location(s) from which the user or user agent can choose the one most appropriate. /// WARNING: The origin server MUST create the resource before returning the 201 status code. If the action cannot be carried out immediately, the server SHOULD respond with 202 (Accepted) response instead. /// /// /// https://restfulapi.net/http-status-201-created/ /// procedure Render201Created(const Location: string = ''; const Reason: string = ''); virtual; /// /// Allow a server to accept a request for some other process (perhaps a batch-oriented process that is only run once per day) without requiring that the user agent’s connection to the server persist until the process is completed. /// The entity returned with this response SHOULD describe the request’s current status and point to (or embed) a status monitor that can provide the user with (or without) an estimate of when the request will be fulfilled. /// /// /// https://restfulapi.net/http-status-202-accepted/ /// procedure Render202Accepted(const HREF: string; const ID: string; const Reason: string = 'Accepted'); virtual; /// /// HTTP Status 204 (No Content) indicates that the server has successfully fulfilled the request and that there is no content to send in the response payload body. The server might want to return updated meta information in the form of entity-headers, which if present SHOULD be applied to current document’s active view if any. /// The 204 response MUST NOT include a message-body and thus is always terminated by the first empty line after the header fields. /// procedure Render204NoContent(const Location: string = ''; const Reason: string = ''); virtual; function Serializer: IMVCSerializer; overload; function Serializer(const AContentType: string; const ARaiseExceptionIfNotExists: Boolean = True): IMVCSerializer; overload; procedure SendStream(const AStream: TStream; const AOwns: Boolean = True; const ARewind: Boolean = False); virtual; procedure SendFile(const AFileName: string); virtual; procedure RenderResponseStream; virtual; function ResponseStream: TStringBuilder; procedure Render(const AContent: string); overload; procedure Render(const AStatusCode: Integer; const AContent: string); overload; procedure Render(const AStatusCode: Integer); overload; // PODO renders procedure Render(const AStatusCode: Integer; const AObject: TObject; const ASerializationAction: TMVCSerializationAction = nil; const AIgnoredFields: TMVCIgnoredList = nil); overload; procedure Render(const AObject: TObject; const ASerializationAction: TMVCSerializationAction = nil; const AIgnoredFields: TMVCIgnoredList = nil); overload; procedure Render(const AObject: TObject; const AOwns: Boolean; const ASerializationAction: TMVCSerializationAction = nil; const AIgnoredFields: TMVCIgnoredList = nil); overload; procedure Render(const AObject: TObject; const AOwns: Boolean; const AType: TMVCSerializationType; const ASerializationAction: TMVCSerializationAction = nil; const AIgnoredFields: TMVCIgnoredList = nil); overload; procedure Render(const AStatusCode: Integer; AObject: TObject; const AOwns: Boolean; const ASerializationAction: TMVCSerializationAction = nil); overload; procedure Render(const AObject: IInterface; const ASerializationAction: TMVCSerializationAction = nil); overload; procedure Render(const AStatusCode: Integer; const AObject: IInterface; const ASerializationAction: TMVCSerializationAction = nil); overload; procedure Render(const AStatusCode: Integer; var ARecord: T); overload; // PODOs Collection render procedure Render(const ACollection: TObjectList; const ASerializationAction: TMVCSerializationAction = nil); overload; procedure Render(const ACollection: TObjectList; const AOwns: Boolean; const ASerializationAction: TMVCSerializationAction = nil); overload; procedure Render(const AStatusCode: Integer; const ACollection: TObjectList; const AOwns: Boolean; const ASerializationAction: TMVCSerializationAction = nil); overload; procedure Render(const ACollection: TObjectList; const AOwns: Boolean; const AType: TMVCSerializationType; const ASerializationAction: TMVCSerializationAction = nil); overload; procedure Render(const ACollection: IMVCList); overload; procedure Render(const ACollection: IMVCList; const AType: TMVCSerializationType); overload; procedure Render(const ATextWriter: TTextWriter; const AOwns: Boolean = True); overload; procedure Render(const AStream: TStream; const AOwns: Boolean = True); overload; procedure RenderStatusMessage(const AStatusCode: Integer; const AReasonMessage: string = ''; const AErrorClassName: string = ''; const ADataObject: TObject = nil); overload; procedure Render(const AException: Exception; AExceptionItems: TList = nil; const AOwns: Boolean = True); overload; procedure Render(const AResponse: TMVCResponse; const AOwns: Boolean = True); overload; // Dataset support procedure Render(const ADataSet: TDataSet; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; procedure Render(const ADataSet: TDataSet; const AOwns: Boolean; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; procedure Render(const ADataSet: TDataSet; const AOwns: Boolean; const ASerializationType: TMVCDatasetSerializationType; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; procedure Render(const ADataSet: TDataSet; const AOwns: Boolean; const AIgnoredFields: TMVCIgnoredList; const ASerializationType: TMVCDatasetSerializationType; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; procedure Render(const ADataSet: TDataSet; const AOwns: Boolean; const AIgnoredFields: TMVCIgnoredList; const ANameCase: TMVCNameCase; const ASerializationType: TMVCDatasetSerializationType; const ASerializationAction: TMVCDatasetSerializationAction = nil); overload; // SSE Support procedure RenderSSE(const EventID: string; const EventData: string; EventName: string = ''; const Retry: Integer = TMVCConstants.SSE_RETRY_DEFAULT); end; TMVCController = class(TMVCRenderer) private FViewModel: TMVCViewDataObject; FViewDataSets: TMVCViewDataSet; function GetSession: TWebSession; function GetViewData(const aModelName: string): TObject; function GetViewDataset(const aDataSetName: string): TDataSet; procedure SetViewData(const aModelName: string; const Value: TObject); procedure SetViewDataset(const aDataSetName: string; const Value: TDataSet); protected const CLIENTID_KEY = '__clientid'; protected procedure MVCControllerAfterCreate; virtual; procedure MVCControllerBeforeDestroy; virtual; procedure OnBeforeAction(AContext: TWebContext; const AActionName: string; var AHandled: Boolean); virtual; procedure OnAfterAction(AContext: TWebContext; const AActionName: string); virtual; function GetClientId: string; function GetCurrentWebModule: TWebModule; function GetViewModel: TMVCViewDataObject; function GetViewDataSets: TMVCViewDataSet; function GetRenderedView(const AViewNames: TArray): string; virtual; /// /// Load mustache view located in TMVCConfigKey.ViewsPath /// returns the rendered views and generates output using /// models pushed using Push* methods /// function LoadView(const AViewNames: TArray): string; virtual; /// /// Load a view fragment in the output render stream. The view fragment is appended to the /// ResponseStream verbatim. No processing happens. /// Useful when used with cache. /// It is equivalent to ResponseStream.Append(AViewFragment); /// procedure LoadViewFragment(const AViewFragment: string); function SessionAs: T; procedure RaiseSessionExpired; virtual; // Avoiding mid-air collisions - support procedure SetETag(const Data: String); function GetIfMatch(): String; procedure CheckIfMatch(const Data: String); // END - Avoiding mid-air collisions - support // Properties property Context: TWebContext read GetContext write FContext; property Session: TWebSession read GetSession; property ContentType: string read GetContentType write SetContentType; property StatusCode: Integer read GetStatusCode write SetStatusCode; procedure PushObjectToView(const aModelName: string; const AModel: TObject); deprecated 'Use "ViewData"'; procedure PushDataSetToView(const aModelName: string; const ADataSet: TDataSet); deprecated 'Use "ViewDataSet"'; property ViewData[const aModelName: string]: TObject read GetViewData write SetViewData; property ViewDataset[const aDataSetName: string]: TDataSet read GetViewDataset write SetViewDataset; public constructor Create; virtual; destructor Destroy; override; end; TMVCControllerClazz = class of TMVCController; TMVCControllerCreateAction = reference to function: TMVCController; TMVCObjectCreatorDelegate = reference to function: TObject; TMVCControllerDelegate = class private FClazz: TMVCControllerClazz; FCreateAction: TMVCControllerCreateAction; FURLSegment: string; protected { protected declarations } public constructor Create(const AClazz: TMVCControllerClazz; const ACreateAction: TMVCControllerCreateAction; const AURLSegment: string = ''); property Clazz: TMVCControllerClazz read FClazz; property CreateAction: TMVCControllerCreateAction read FCreateAction; property URLSegment: string read FURLSegment; end; TMVCStaticContents = class(TMVCController) private { private declarations } protected { protected declarations } public class procedure SendFile(const AFileName, AMediaType: string; AContext: TWebContext); class function IsStaticFile(const AViewPath, AWebRequestPath: string; out ARealFileName: string; out AIsDirectoryTraversalAttack: Boolean): Boolean; class function IsScriptableFile(const AStaticFileName: string; const AConfig: TMVCConfig): Boolean; end; /// /// Basis Interface for DMVC Middleware. /// IMVCMiddleware = interface ['{3278183A-124A-4214-AB4E-94CA4C22450D}'] /// /// Procedure is called before the MVCEngine routes the request to a specific controller/method. /// /// Webcontext which contains the complete request and response of the actual call. /// If set to True the Request would finished. Response must be set by the implementor. Default value is False. procedure OnBeforeRouting(AContext: TWebContext; var AHandled: Boolean); /// /// Procedure is called before the specific controller method is called. /// /// Webcontext which contains the complete request and response of the actual call. /// Qualified classname of the matching controller. /// Method name of the matching controller method. /// If set to True the Request would finished. Response must be set by the implementor. Default value is False. procedure OnBeforeControllerAction(AContext: TWebContext; const AControllerQualifiedClassName: string; const AActionName: string; var AHandled: Boolean); /// /// Procedure is called after the specific controller method was called. /// It is still possible to cancel or to completly modifiy the request. /// /// Webcontext which contains the complete request and response of the actual call. /// Method name of the matching controller method. /// If set to True the Request would finished. Response must be set by the implementor. Default value is False. procedure OnAfterControllerAction(AContext: TWebContext; const AControllerQualifiedClassName: string; const AActionName: string; const AHandled: Boolean); /// /// Procedure is called after the MVCEngine routes the request to a specific controller/method. /// /// Webcontext which contains the complete request and response of the actual call. /// If set to True the Request would finished. Response must be set by the implementor. Default value is False. procedure OnAfterRouting(AContext: TWebContext; const AHandled: Boolean); end; TMVCExceptionHandlerProc = reference to procedure(E: Exception; SelectedController: TMVCController; WebContext: TWebContext; var ExceptionHandled: Boolean); TMVCRouterLogState = (rlsRouteFound, rlsRouteNotFound); TMVCRouterLogHandlerProc = reference to procedure(const Router: TMVCCustomRouter; const RouterLogState: TMVCRouterLogState; const WebContext: TWebContext); TMVCJSONRPCExceptionHandlerProc = reference to procedure(E: Exception; { SelectedController: TMVCController; //YAGNI } WebContext: TWebContext; var ErrorInfo: TMVCJSONRPCExceptionErrorInfo; var ExceptionHandled: Boolean); TWebContextCreateEvent = reference to procedure(const AContext: TWebContext); TWebContextDestroyEvent = reference to procedure(const AContext: TWebContext); TMVCEngine = class(TComponent) private const ALLOWED_TYPED_ACTION_PARAMETERS_TYPES = 'Integer, Int64, Single, Double, Extended, Boolean, TDate, TTime, TDateTime, String and TGUID'; private FViewEngineClass: TMVCViewEngineClass; FWebModule: TWebModule; FConfig: TMVCConfig; FConfigCache_MaxRequestSize: Int64; FConfigCache_ExposeServerSignature: Boolean; FConfigCache_ServerSignature: string; FConfigCache_ExposeXPoweredBy: Boolean; FConfigCache_DefaultContentType: String; FConfigCache_DefaultContentCharset: String; FConfigCache_PathPrefix: String; FSerializers: TDictionary; FMiddlewares: TList; FControllers: TObjectList; FApplicationSession: TWebApplicationSession; FSavedOnBeforeDispatch: THTTPMethodEvent; FOnException: TMVCExceptionHandlerProc; fOnRouterLog: TMVCRouterLogHandlerProc; fWebContextCreateEvent: TWebContextCreateEvent; fWebContextDestroyEvent: TWebContextDestroyEvent; procedure FillActualParamsForAction(const ASelectedController: TMVCController; const AContext: TWebContext; const AActionFormalParams: TArray; const AActionName: string; var AActualParams: TArray; out ABodyParameter: TObject); procedure RegisterDefaultsSerializers; function GetViewEngineClass: TMVCViewEngineClass; procedure HandleDefaultValueForInjectedParameter(var InjectedParamValue: String; const InjectableParamAttribute: MVCInjectableParamAttribute); protected procedure DoWebContextCreateEvent(const AContext: TWebContext); inline; procedure DoWebContextDestroyEvent(const AContext: TWebContext); inline; function GetActualParam(const AFormalParam: TRttiParameter; const AStringValue: String): TValue; function CustomExceptionHandling(const Ex: Exception; const ASelectedController: TMVCController; const AContext: TWebContext): Boolean; procedure ConfigDefaultValues; virtual; procedure SaveCacheConfigValues; procedure LoadSystemControllers; virtual; procedure FixUpWebModule; procedure ExecuteBeforeRoutingMiddleware(const AContext: TWebContext; var AHandled: Boolean); procedure ExecuteBeforeControllerActionMiddleware(const AContext: TWebContext; const AControllerQualifiedClassName: string; const AActionName: string; var AHandled: Boolean); procedure ExecuteAfterControllerActionMiddleware(const AContext: TWebContext; const AControllerQualifiedClassName: string; const AActionName: string; const AHandled: Boolean); procedure ExecuteAfterRoutingMiddleware(const AContext: TWebContext; const AHandled: Boolean); procedure DefineDefaultResponseHeaders(const AContext: TWebContext); procedure OnBeforeDispatch(ASender: TObject; ARequest: TWebRequest; AResponse: TWebResponse; var AHandled: Boolean); virtual; procedure ResponseErrorPage(const AException: Exception; const ARequest: TWebRequest; const AResponse: TWebResponse); virtual; function ExecuteAction(const ASender: TObject; const ARequest: TWebRequest; const AResponse: TWebResponse): Boolean; virtual; public class function GetCurrentSession(const ASessionId: string; const ARaiseExceptionIfExpired: Boolean = True): TWebSession; static; class function ExtractSessionIdFromWebRequest(const AWebRequest: TWebRequest): string; static; class function SendSessionCookie(const AContext: TWebContext): string; overload; static; class function SendSessionCookie(const AContext: TWebContext; const ASessionId: string): string; overload; static; class procedure ClearSessionCookiesAlreadySet(const ACookies: TCookieCollection); static; public constructor Create(const AWebModule: TWebModule; const AConfigAction: TProc = nil; const ACustomLogger: ILogWriter = nil); reintroduce; destructor Destroy; override; function GetSessionBySessionId(const ASessionId: string): TWebSession; { webcontext events} procedure OnWebContextCreate(const WebContextCreateEvent: TWebContextCreateEvent); procedure OnWebContextDestroy(const WebContextDestroyEvent: TWebContextDestroyEvent); { end - webcontext events} function AddSerializer(const AContentType: string; const ASerializer: IMVCSerializer) : TMVCEngine; function AddMiddleware(const AMiddleware: IMVCMiddleware): TMVCEngine; function AddController(const AControllerClazz: TMVCControllerClazz; const AURLSegment: string = ''): TMVCEngine; overload; function AddController(const AControllerClazz: TMVCControllerClazz; const ACreateAction: TMVCControllerCreateAction; const AURLSegment: string = '') : TMVCEngine; overload; function PublishObject(const AObjectCreatorDelegate: TMVCObjectCreatorDelegate; const AURLSegment: string; ExceptionHandler: TMVCJSONRPCExceptionHandlerProc = nil): TMVCEngine; function SetViewEngine(const AViewEngineClass: TMVCViewEngineClass): TMVCEngine; function SetExceptionHandler(const AExceptionHandlerProc: TMVCExceptionHandlerProc): TMVCEngine; procedure HTTP404(const AContext: TWebContext); procedure HTTP500(const AContext: TWebContext; const AReasonString: string = ''); procedure SendRawHTTPStatus(const AContext: TWebContext; const HTTPStatusCode: Integer; const AReasonString: string; const AClassName: string = ''); property ViewEngineClass: TMVCViewEngineClass read GetViewEngineClass; property WebModule: TWebModule read FWebModule; property Config: TMVCConfig read FConfig; property Serializers: TDictionary read FSerializers; property Middlewares: TList read FMiddlewares; property Controllers: TObjectList read FControllers; property ApplicationSession: TWebApplicationSession read FApplicationSession write FApplicationSession; property OnRouterLog: TMVCRouterLogHandlerProc read fOnRouterLog write fOnRouterLog; end; [MVCNameCase(ncLowerCase)] TMVCErrorResponseItem = class private FMessage: string; protected { protected declarations } public constructor Create(const AMessage: string = ''); property message: string read FMessage write FMessage; end; [MVCNameCase(ncLowerCase)] TMVCResponse = class private FStatusCode: Integer; FReasonString: string; FMessage: string; fDataObject: TObject; protected { protected declarations } public constructor Create; overload; virtual; constructor Create(AStatusCode: Integer; AReasonString: string; AMessage: string); overload; destructor Destroy; override; property StatusCode: Integer read FStatusCode write FStatusCode; property ReasonString: string read FReasonString write FReasonString; property Message: string read FMessage write FMessage; property Data: TObject read fDataObject write fDataObject; end; [MVCNameCase(ncLowerCase)] TMVCErrorResponse = class(TMVCResponse) private FClassname: string; FItems: TObjectList; FAppErrorCode: Integer; FDetailedMessage: string; procedure SetAppErrorCode(const Value: Integer); public constructor Create; override; destructor Destroy; override; property Classname: string read FClassname write FClassname; property DetailedMessage: string read FDetailedMessage write FDetailedMessage; property AppErrorCode: Integer read FAppErrorCode write SetAppErrorCode; [MVCListOf(TMVCErrorResponseItem)] property Items: TObjectList read FItems; end; TMVCBaseViewEngine = class(TMVCBase) private FViewName: string; FWebContext: TWebContext; FViewModel: TMVCViewDataObject; FViewDataSets: TObjectDictionary; FContentType: string; FOutput: string; protected function GetRealFileName(const AViewName: string): string; virtual; function IsCompiledVersionUpToDate(const AFileName, ACompiledFileName: string): Boolean; virtual; abstract; public constructor Create(const AEngine: TMVCEngine; const AWebContext: TWebContext; const AViewModel: TMVCViewDataObject; const AViewDataSets: TObjectDictionary; const AContentType: string); virtual; destructor Destroy; override; procedure Execute(const ViewName: string; const OutputStream: TStream); virtual; abstract; property ViewName: string read FViewName; property WebContext: TWebContext read FWebContext; property ViewModel: TMVCViewDataObject read FViewModel; property ViewDataSets: TObjectDictionary read FViewDataSets; property ContentType: string read FContentType; property Output: string read FOutput; end; function IsShuttingDown: Boolean; procedure EnterInShutdownState; function CreateResponse(const StatusCode: UInt16; const ReasonString: string; const Message: string = ''): TMVCResponse; implementation uses IdURI, System.StrUtils, MVCFramework.SysControllers, MVCFramework.Serializer.JsonDataObjects, MVCFramework.JSONRPC, MVCFramework.Router, MVCFramework.Rtti.Utils, MVCFramework.Serializer.HTML, MVCFramework.Serializer.Abstract, MVCFramework.Utils; var gIsShuttingDown: Int64 = 0; gMVCGlobalActionParamsCache: TMVCStringObjectDictionary = nil; gHostingFramework: TMVCHostingFrameworkType = hftUnknown; function IsShuttingDown: Boolean; begin Result := TInterlocked.Read(gIsShuttingDown) = 1 end; procedure EnterInShutdownState; begin TInterlocked.Add(gIsShuttingDown, 1); end; function CreateResponse(const StatusCode: UInt16; const ReasonString: string; const Message: string = ''): TMVCResponse; begin Result := TMVCResponse.Create(StatusCode, ReasonString, message); end; function GetRequestShortDescription(const AWebRequest: TWebRequest): String; begin Result := Format('%s %s%s', [AWebRequest.Method, AWebRequest.PathInfo, ifthen(AWebRequest.Query = '', '', '?' + AWebRequest.Query)]); end; { MVCHTTPMethodsAttribute } constructor MVCHTTPMethodsAttribute.Create(const AMVCHTTPMethods: TMVCHTTPMethods); begin inherited Create; FMVCHTTPMethods := AMVCHTTPMethods; end; function MVCHTTPMethodsAttribute.GetMVCHTTPMethodsAsString: string; var I: TMVCHTTPMethodType; begin Result := ''; for I := low(TMVCHTTPMethodType) to high(TMVCHTTPMethodType) do if I in FMVCHTTPMethods then Result := Result + ',' + GetEnumName(TypeInfo(TMVCHTTPMethodType), Ord(I)); if Result <> EmptyStr then Result := Result.Remove(0, 1) else Result := 'any'; end; { MVCStringAttribute } constructor MVCStringAttribute.Create(const AValue: string); begin inherited Create; FValue := AValue; end; { MVCInjectableParamAttribute } constructor MVCInjectableParamAttribute.Create(const AParamName: string; const DefaultAsString: string); begin Create(AParamName); FCanBeUsedADefaultValue := True; FDefaultValueAsString := DefaultAsString; end; constructor MVCInjectableParamAttribute.Create(const AParamName: string); begin inherited Create; FParamName := AParamName; FCanBeUsedADefaultValue := False; end; constructor MVCInjectableParamAttribute.Create(const AParamName: string; const DefaultAsInteger: Int64); begin Create(AParamName, DefaultAsInteger.ToString); end; constructor MVCInjectableParamAttribute.Create(const AParamName: string; const DefaultAsBoolean: Boolean); begin Create(AParamName, iif(DefaultAsBoolean,'true','false')); end; { MVCProducesAttribute } constructor MVCProducesAttribute.Create(const AValue, ACharset: string); begin Create(AValue); FCharset := ACharset; end; constructor MVCProducesAttribute.Create(const AValue: string); begin inherited Create(AValue); FCharset := TMVCCharset.UTF_8; end; { MVCPathAttribute } constructor MVCPathAttribute.Create(const APath: string); begin inherited Create; FPath := APath; end; constructor MVCResponseAttribute.Create(inStatusCode: Integer; const inDescription: string; inResponseClass: TClass); begin FStatusCode := inStatusCode; FDescription := inDescription; FResponseClass := inResponseClass; end; { MVCResponseListAttribute } constructor MVCResponseListAttribute.Create(inStatusCode: Integer; const inDescription: string; inResponseClass: TClass); begin FStatusCode := inStatusCode; FDescription := inDescription; FResponseClass := inResponseClass; end; { MVCStringEnumAttribute } constructor MVCStringEnumAttribute.Create(const enumValue: string); begin fValues := enumValue; end; { TMVCWebRequest } function TMVCWebRequest.Accept: string; begin Result := FWebRequest.Accept; end; function TMVCWebRequest.BestAccept: string; begin if Accept.Contains(',') then begin Result := Accept.Split([','])[0]; end else begin Result := Accept; end; end; function TMVCWebRequest.Body: string; var lEncoding: TEncoding; {$IF not Defined(BERLINORBETTER)} lBuffer: TArray; {$ENDIF} begin { DONE -oEzequiel -cRefactoring : Refactoring the method TMVCWebRequest.Body } if (FBody = EmptyStr) then begin if FCharset = EmptyStr then lEncoding := TEncoding.GetEncoding('UTF-8') else lEncoding := TEncoding.GetEncoding(FCharset); try {$IF Defined(BERLINORBETTER)} FWebRequest.ReadTotalContent; // Otherwise ISAPI Raises "Empty BODY" FBody := lEncoding.GetString(FWebRequest.RawContent); {$ELSE} SetLength(lBuffer, FWebRequest.ContentLength); FWebRequest.ReadClient(lBuffer[0], FWebRequest.ContentLength); FBody := lEncoding.GetString(lBuffer); {$ENDIF} finally lEncoding.Free; end; end; Result := FBody; end; function TMVCWebRequest.BodyAs(const RootNode: string): T; var Obj: TObject; lSerializer: IMVCSerializer; begin Result := nil; if FSerializers.TryGetValue(ContentMediaType, lSerializer) then begin Obj := TMVCSerializerHelper.CreateObject(TClass(T).QualifiedClassName); try lSerializer.DeserializeObject(Body, Obj, TMVCSerializationType.stDefault, nil, RootNode); Result := Obj as T; except on E: Exception do begin FreeAndNil(Obj); raise; end; end; end else raise EMVCDeserializationException.CreateFmt('Body ContentType "%s" not supported', [ContentType]); end; function TMVCWebRequest.BodyAsListOf(const RootNode: string): TObjectList; var List: TObjectList; lSerializer: IMVCSerializer; begin Result := nil; if FSerializers.TryGetValue(ContentMediaType, lSerializer) then begin List := TObjectList.Create(True); try lSerializer.DeserializeCollection(Body, List, T, TMVCSerializationType.stDefault, nil, RootNode); Result := List; except FreeAndNil(List); raise; end; end else raise EMVCException.CreateFmt('Body ContentType "%s" not supported', [ContentType]); end; procedure TMVCWebRequest.BodyFor(const AObject: T; const RootNode: string); var lSerializer: IMVCSerializer; begin if Assigned(AObject) then begin if FSerializers.TryGetValue(ContentMediaType, lSerializer) then begin lSerializer.DeserializeObject(Body, AObject, TMVCSerializationType.stDefault, [], RootNode) end else begin raise EMVCException.CreateFmt('Body ContentType "%s" not supported', [ContentType]); end end; end; procedure TMVCWebRequest.BodyForListOf(const AObjectList: TObjectList; const RootNode: string); var lSerializer: IMVCSerializer; begin if Assigned(AObjectList) then begin if FSerializers.TryGetValue(ContentMediaType, lSerializer) then begin lSerializer.DeserializeCollection(Body, AObjectList, T, TMVCSerializationType.stDefault, [], RootNode) end else begin raise EMVCException.CreateFmt('Body ContentType "%s" not supported', [ContentType]); end; end; end; function TMVCWebRequest.ClientIp: string; var S: string; begin Result := EmptyStr; if FWebRequest.GetFieldByName('HTTP_CLIENT_IP') <> EmptyStr then Exit(FWebRequest.GetFieldByName('HTTP_CLIENT_IP')); for S in string(FWebRequest.GetFieldByName('HTTP_X_FORWARDED_FOR')).Split([',']) do if not S.Trim.IsEmpty then Exit(S.Trim); if FWebRequest.GetFieldByName('HTTP_X_FORWARDED') <> EmptyStr then Exit(FWebRequest.GetFieldByName('HTTP_X_FORWARDED')); if FWebRequest.GetFieldByName('HTTP_X_CLUSTER_CLIENT_IP') <> EmptyStr then Exit(FWebRequest.GetFieldByName('HTTP_X_CLUSTER_CLIENT_IP')); if FWebRequest.GetFieldByName('HTTP_FORWARDED_FOR') <> EmptyStr then Exit(FWebRequest.GetFieldByName('HTTP_FORWARDED_FOR')); if FWebRequest.GetFieldByName('HTTP_FORWARDED') <> EmptyStr then Exit(FWebRequest.GetFieldByName('HTTP_FORWARDED')); if FWebRequest.GetFieldByName('REMOTE_ADDR') <> EmptyStr then Exit(FWebRequest.GetFieldByName('REMOTE_ADDR')); if FWebRequest.RemoteIP <> EmptyStr then Exit(FWebRequest.RemoteIP); if FWebRequest.RemoteAddr <> EmptyStr then Exit(FWebRequest.RemoteAddr); if FWebRequest.RemoteHost <> EmptyStr then Exit(FWebRequest.RemoteHost); if FWebRequest.RemoteAddr <> EmptyStr then Exit(FWebRequest.RemoteAddr); if FWebRequest.RemoteIP <> EmptyStr then Exit(FWebRequest.RemoteIP); if FWebRequest.RemoteHost <> EmptyStr then Exit(FWebRequest.RemoteHost); end; function TMVCWebRequest.ClientPrefer(const AMediaType: string): Boolean; begin Result := AnsiPos(AMediaType, LowerCase(RawWebRequest.Accept)) = 1; end; function TMVCWebRequest.ClientPreferHTML: Boolean; begin Result := ClientPrefer(TMVCMediaType.TEXT_HTML); end; function TMVCWebRequest.ContentParam(const AName: string): string; begin Result := FWebRequest.ContentFields.Values[AName]; end; function TMVCWebRequest.Cookie(const AName: string): string; begin Result := FWebRequest.CookieFields.Values[AName]; end; constructor TMVCWebRequest.Create(const AWebRequest: TWebRequest; const ASerializers: TDictionary); begin inherited Create; FBody := EmptyStr; FCharset := TMVCConstants.DEFAULT_CONTENT_CHARSET; FWebRequest := AWebRequest; FSerializers := ASerializers; FParamsTable := nil; DefineContentType; end; procedure TMVCWebRequest.DefineContentType; begin { While not strictly required nor defined, DMVCFramework supports sending body data for all HTTP VERBS https://developer.mozilla.org/en-US/docs/Web/HTTP/Methods/GET } SplitContentMediaTypeAndCharset( FWebRequest.GetFieldByName('Content-Type'), FContentMediaType, FCharset); if FContentMediaType.IsEmpty then FContentMediaType := TMVCConstants.DEFAULT_CONTENT_TYPE; if FCharset.IsEmpty then FCharset := TMVCConstants.DEFAULT_CONTENT_CHARSET; FContentType := BuildContentType(FContentMediaType, FCharset); end; destructor TMVCWebRequest.Destroy; begin if Assigned(FContentFields) then begin FContentFields.Free; end; if Assigned(FQueryParams) then begin FQueryParams.Free; end; inherited Destroy; end; procedure TMVCWebRequest.EnsureINDY; begin if not(Self is TMVCIndyWebRequest) then begin raise EMVCException.Create(http_status.InternalServerError, 'Method available only in INDY implementation'); end; end; procedure TMVCWebRequest.EnsureQueryParamExists(const AName: string); begin if GetParams(AName).IsEmpty then raise EMVCException.CreateFmt('Parameter "%s" required', [AName]); end; function TMVCWebRequest.GetContentFields: TDictionary; var I: Integer; begin if not Assigned(FContentFields) then begin FContentFields := TDictionary.Create; for I := 0 to Pred(FWebRequest.ContentFields.Count) do begin FContentFields.AddOrSetValue(LowerCase(FWebRequest.ContentFields.Names[I]), FWebRequest.ContentFields.ValueFromIndex[I]); end; end; Result := FContentFields; end; function TMVCWebRequest.GetFiles: TAbstractWebRequestFiles; begin Result := FWebRequest.Files; end; function TMVCWebRequest.GetHeader(const AName: string): string; begin Result := FWebRequest.GetFieldByName(AName); end; function TMVCWebRequest.GetHTTPMethod: TMVCHTTPMethodType; begin Result := TMVCRouter.StringMethodToHTTPMetod(FWebRequest.Method); end; function TMVCWebRequest.GetHTTPMethodAsString: string; begin Result := FWebRequest.Method; end; function TMVCWebRequest.GetIsAjax: Boolean; begin Result := LowerCase(FWebRequest.GetFieldByName('X-Requested-With')) = 'xmlhttprequest'; end; function TMVCWebRequest.GetOverwrittenHTTPMethod: TMVCHTTPMethodType; var lOverriddenMethod: string; begin lOverriddenMethod := Headers[TMVCConstants.X_HTTP_Method_Override]; if lOverriddenMethod.IsEmpty then begin Exit(HTTPMethod); end else begin Result := TMVCRouter.StringMethodToHTTPMetod(FWebRequest.Method); end; end; function TMVCWebRequest.GetParamAsInt64(const AParamName: string): Int64; begin Result := StrToInt64(GetParams(AParamName)); end; function TMVCWebRequest.GetParamAsInteger(const AParamName: string): Integer; begin Result := StrToInt(GetParams(AParamName)); end; function TMVCWebRequest.GetParamNames: TArray; var I: Integer; Names: TList; N: string; begin Names := TList.Create; try if Assigned(FParamsTable) and (Length(FParamsTable.Keys.ToArray) > 0) then begin for N in FParamsTable.Keys.ToArray do begin Names.Add(N); end; end; if (FWebRequest.QueryFields.Count > 0) then begin for I := 0 to FWebRequest.QueryFields.Count - 1 do begin Names.Add(FWebRequest.QueryFields.Names[I]); end; end; if (FWebRequest.ContentFields.Count > 0) then begin for I := 0 to FWebRequest.ContentFields.Count - 1 do begin if Names.IndexOf(FWebRequest.ContentFields.Names[I]) = -1 then begin Names.Add(FWebRequest.ContentFields.Names[I]); end; end; end; if (FWebRequest.CookieFields.Count > 0) then begin for I := 0 to FWebRequest.CookieFields.Count - 1 do begin Names.Add(FWebRequest.CookieFields.Names[I]); end; end; Result := Names.ToArray; finally Names.Free; end; end; function TMVCWebRequest.GetParams(const AParamName: string): string; begin if (not Assigned(FParamsTable)) or (not FParamsTable.TryGetValue(AParamName, Result)) then begin Result := ''; if string(FWebRequest.ContentType).StartsWith(TMVCMediaType.APPLICATION_FORM_URLENCODED, True) or string(FWebRequest.ContentType).StartsWith(TMVCMediaType.MULTIPART_FORM_DATA, True) then Result := FWebRequest.ContentFields.Values[AParamName]; if Result.IsEmpty then Result := FWebRequest.QueryFields.Values[AParamName]; if Result.IsEmpty then Result := FWebRequest.CookieFields.Values[AParamName]; end; end; function TMVCWebRequest.GetParamsMulti(const AParamName: string): TArray; var lList: TList; procedure AddParamsToList(const AStrings: TStrings; const AList: TList); var I: Integer; begin for I := 0 to AStrings.Count - 1 do if SameText(AStrings.Names[I], AParamName) then AList.Add(AStrings.ValueFromIndex[I]); end; begin lList := TList.Create; try AddParamsToList(FWebRequest.ContentFields, lList); AddParamsToList(FWebRequest.QueryFields, lList); AddParamsToList(FWebRequest.CookieFields, lList); Result := lList.ToArray; finally lList.Free; end; end; function TMVCWebRequest.GetPathInfo: string; begin Result := FWebRequest.PathInfo; end; function TMVCWebRequest.GetQueryParams: TDictionary; var I: Integer; lRow: String; begin if not Assigned(FQueryParams) then begin FQueryParams := TDictionary.Create; for I := 0 to Pred(FWebRequest.QueryFields.Count) do begin lRow := FWebRequest.QueryFields[i]; if lRow.Contains('=') then begin FQueryParams.Add( LowerCase(Trim(FWebRequest.QueryFields.Names[I])), FWebRequest.QueryFields.ValueFromIndex[I]); end else begin FQueryParams.AddOrSetValue(LowerCase(lRow), ''); end; end; end; Result := FQueryParams; end; function TMVCWebRequest.QueryString: string; begin Result := FWebRequest.Query; end; function TMVCWebRequest.QueryStringParam(const AName: string): string; begin Result := FWebRequest.QueryFields.Values[AName]; end; function TMVCWebRequest.QueryStringParamExists(const AName: string): Boolean; begin Result := QueryStringParam(AName) <> EmptyStr; end; function TMVCWebRequest.QueryStringParams: TStrings; begin Result := FWebRequest.QueryFields; end; function TMVCWebRequest.SegmentParam(const AParamName: string; out AValue: string): Boolean; begin Result := False; if Assigned(FParamsTable) then Result := FParamsTable.TryGetValue(AParamName, AValue); end; function TMVCWebRequest.SegmentParamsCount: Integer; begin Result := 0; if Assigned(FParamsTable) then Result := FParamsTable.Count; end; function TMVCWebRequest.ThereIsRequestBody: Boolean; begin Result := (FWebRequest.Content <> EmptyStr); end; { TMVCWebResponse } constructor TMVCWebResponse.Create(const AWebResponse: TWebResponse); begin inherited Create; FWebResponse := AWebResponse; FFlushOnDestroy := True; end; destructor TMVCWebResponse.Destroy; begin if FFlushOnDestroy then begin try Flush; except // do nothing end; end; inherited Destroy; end; procedure TMVCWebResponse.Flush; begin if not FWebResponse.Sent then FWebResponse.SendResponse; end; function TMVCWebResponse.GetContent: string; begin Result := FWebResponse.Content; end; function TMVCWebResponse.GetContentType: string; begin Result := FWebResponse.ContentType; end; function TMVCWebResponse.GetCookies: TCookieCollection; begin Result := FWebResponse.Cookies; end; function TMVCWebResponse.GetCustomHeaders: TStrings; begin Result := FWebResponse.CustomHeaders; end; function TMVCWebResponse.GetLocation: string; begin Result := CustomHeaders.Values['location']; end; function TMVCWebResponse.GetReasonString: string; begin Result := FWebResponse.ReasonString; end; function TMVCWebResponse.GetStatusCode: Integer; begin Result := FWebResponse.StatusCode; end; procedure TMVCWebResponse.SetContent(const AValue: string); begin FWebResponse.Content := AValue; end; procedure TMVCWebResponse.SetContentStream(const AStream: TStream; const AContentType: string); begin ContentType := AContentType; FWebResponse.ContentStream := AStream; end; procedure TMVCWebResponse.SetContentType(const AValue: string); begin FWebResponse.ContentType := ''; FWebResponse.ContentType := AValue; end; procedure TMVCWebResponse.SetCustomHeader(const AName, AValue: string); begin FWebResponse.SetCustomHeader(AName, AValue); end; procedure TMVCWebResponse.SetLocation(const AValue: string); begin CustomHeaders.Values['location'] := AValue; end; procedure TMVCWebResponse.SetReasonString(const AValue: string); begin FWebResponse.ReasonString := AValue; end; procedure TMVCWebResponse.SetStatusCode(const AValue: Integer); begin FWebResponse.StatusCode := AValue; end; { TUser } procedure TUser.Clear; begin FUserName := EmptyStr; FLoggedSince := 0; FRealm := EmptyStr; FRoles.Clear; end; constructor TUser.Create; begin inherited Create; FRoles := TList.Create; FCustomData := nil; end; destructor TUser.Destroy; begin FRoles.Free; FreeAndNil(FCustomData); inherited Destroy; end; function TUser.IsValid: Boolean; begin Result := (not UserName.IsEmpty) and (LoggedSince > 0); end; function TUser.LoadFromSession(const AWebSession: TWebSession): Boolean; var SerObj: string; Pieces: TArray; I: Integer; begin if not Assigned(AWebSession) then Exit(False); SerObj := AWebSession[TMVCConstants.CURRENT_USER_SESSION_KEY]; Result := not SerObj.IsEmpty; if Result then begin Clear; Pieces := SerObj.Split(['$$'], TStringSplitOptions.None); UserName := Pieces[0]; LoggedSince := ISOTimeStampToDateTime(Pieces[1]); Realm := Pieces[2]; Roles.Clear; for I := 3 to Length(Pieces) - 1 do // https://github.com/danieleteti/delphimvcframework/issues/225 Roles.Add(Pieces[I]); end; end; procedure TUser.SaveToSession(const AWebSession: TWebSession); var LRoles: string; begin if (FRoles.Count > 0) then LRoles := string.Join('$$', FRoles.ToArray) else LRoles := ''; AWebSession[TMVCConstants.CURRENT_USER_SESSION_KEY] := FUserName + '$$' + DateTimeToISOTimeStamp(FLoggedSince) + '$$' + FRealm + '$$' + LRoles; end; procedure TUser.SetCustomData(const Value: TMVCCustomData); begin FCustomData := Value; end; procedure TUser.SetLoggedSince(const AValue: TDateTime); begin if (FLoggedSince = 0) then FLoggedSince := AValue else raise EMVCException.Create('TUser.LoggedSince already set.'); end; { TWebContext } function TWebContext.AddSessionToTheSessionList(const ASessionType, ASessionId: string; const ASessionTimeout: Integer): TWebSession; var Session: TWebSession; begin if (Trim(ASessionType) = EmptyStr) then raise EMVCException.Create('Empty Session Type'); TMonitor.Enter(GlobalSessionList); try Session := TMVCSessionFactory.GetInstance.CreateNewByType(ASessionType, ASessionId, ASessionTimeout); GlobalSessionList.Add(ASessionId, Session); Result := Session; Session.MarkAsUsed; finally TMonitor.Exit(GlobalSessionList); end; end; procedure TWebContext.BindToSession(const ASessionId: string); begin if not Assigned(FWebSession) then begin FWebSession := TMVCEngine.GetCurrentSession(ASessionId, False); if not Assigned(FWebSession) then raise EMVCException.Create('Invalid SessionID'); FWebSession.MarkAsUsed; TMVCEngine.SendSessionCookie(Self, ASessionId); end else raise EMVCException.Create('Session already bounded for this request'); end; constructor TWebContext.Create(const ARequest: TWebRequest; const AResponse: TWebResponse; const AConfig: TMVCConfig; const ASerializers: TDictionary); begin inherited Create; FIsSessionStarted := False; FSessionMustBeClose := False; FWebSession := nil; FRequest := nil; if not IsLibrary then begin FRequest := TMVCIndyWebRequest.Create(ARequest, ASerializers); end else begin {$IF Defined(WEBAPACHEHTTP)} if ARequest.ClassType = TApacheRequest then begin FRequest := TMVCApacheWebRequest.Create(ARequest, ASerializers) end else {$IF Defined(MSWINDOWS)} if ARequest.ClassType = TISAPIRequest then begin FRequest := TMVCISAPIWebRequest.Create(ARequest, ASerializers) end else {$ENDIF} //MSWINDOWS {$ENDIF} //WEBAPACHEHTTP begin FRequest := TMVCIndyWebRequest.Create(ARequest, ASerializers); end; end; FResponse := TMVCWebResponse.Create(AResponse); FConfig := AConfig; FSerializers := ASerializers; FData := nil; FLoggedUser := nil; fIntfObject := nil; end; destructor TWebContext.Destroy; begin try FResponse.Free; except end; try FRequest.Free; except end; try FData.Free; except end; fIntfObject := nil; try FLoggedUser.Free; except end; inherited Destroy; end; procedure TWebContext.Flush; begin FResponse.Flush; end; function TWebContext.GetData: TMVCStringDictionary; begin if fData = nil then begin fData := TMVCStringDictionary.Create; end; Result := fData; end; function TWebContext.GetHostingFrameworkType: TMVCHostingFrameworkType; begin {$IF Defined(WEBAPACHEHTTP)} if FRequest.ClassType = TApacheRequest then begin Exit(hftApache); end; {$ENDIF} {$IF Defined(MSWINDOWS)} if FRequest.ClassType = TISAPIRequest then begin Exit(hftISAPI); end; {$ENDIF} Exit(hftIndy); end; function TWebContext.GetIntfObject: IInterface; begin Result := fIntfObject; end; { MVCFromBodyAttribute } constructor MVCFromBodyAttribute.Create(const RootNode: string; const DataType: TMVCDataType); begin inherited Create; fRootNode := ''; fDataType := DataType; end; function MVCFromBodyAttribute.DataType: TMVCDataType; begin Result := fDataType; end; function MVCFromBodyAttribute.RootNode: String; begin Result := fRootNode; end; { TMVCErrorResponseItem } constructor TMVCErrorResponseItem.Create(const AMessage: string); begin inherited Create; FMessage := AMessage; end; function TWebContext.GetLoggedUser: TUser; begin if not Assigned(FLoggedUser) then FLoggedUser := TUser.Create; Result := FLoggedUser; end; function TWebContext.GetParamsTable: TMVCRequestParamsTable; begin Result := FRequest.ParamsTable; end; function TWebContext.GetWebSession: TWebSession; begin if not Assigned(FWebSession) then begin FWebSession := TMVCEngine.GetCurrentSession( TMVCEngine.ExtractSessionIdFromWebRequest(FRequest.RawWebRequest), False); if not Assigned(FWebSession) then SessionStart else TMVCEngine.SendSessionCookie(Self, FWebSession.SessionId); end; Result := FWebSession; Result.MarkAsUsed; end; function TWebContext.IsSessionStarted: Boolean; begin Result := FIsSessionStarted; end; function TWebContext.SendSessionCookie(const AContext: TWebContext): string; begin Result := TMVCEngine.SendSessionCookie(Self); end; function TWebContext.SessionId: string; begin if Assigned(FWebSession) then Exit(FWebSession.SessionId); Result := FRequest.Cookie(TMVCConstants.SESSION_TOKEN_NAME); end; function TWebContext.SessionMustBeClose: Boolean; begin Result := FSessionMustBeClose; end; procedure TWebContext.SessionStart; var ID: string; begin if not Assigned(FWebSession) then begin ID := TMVCEngine.SendSessionCookie(Self); FWebSession := AddSessionToTheSessionList(Config[TMVCConfigKey.SessionType], ID, StrToInt64(Config[TMVCConfigKey.SessionTimeout])); FIsSessionStarted := True; FSessionMustBeClose := False; end; end; function TWebContext.SessionStarted: Boolean; var SId: string; begin SId := SessionId; if SId.IsEmpty then Exit(False); TMonitor.Enter(GlobalSessionList); try Result := GlobalSessionList.ContainsKey(SId); finally TMonitor.Exit(GlobalSessionList); end; end; procedure TWebContext.SessionStop(const ARaiseExceptionIfExpired: Boolean); var Cookie: TCookie; SId: string; begin FResponse.Cookies.Clear; Cookie := FResponse.Cookies.Add; Cookie.name := TMVCConstants.SESSION_TOKEN_NAME; Cookie.Value := GUIDToString(TGUID.NewGuid) + 'invalid' + GUIDToString(TGUID.NewGuid); Cookie.Expires := EncodeDate(1970, 1, 1); Cookie.Path := '/'; TMonitor.Enter(GlobalSessionList); try SID := SessionId; if (SId = '') and (ARaiseExceptionIfExpired) then begin raise EMVCSessionExpiredException.Create('Session not started'); end; GlobalSessionList.Remove(SId); if SId <> '' then begin FWebSession := nil; end; finally TMonitor.Exit(GlobalSessionList); end; FIsSessionStarted := False; FSessionMustBeClose := True; end; procedure TWebContext.SetIntfObject(const Value: IInterface); begin fIntfObject := Value; end; procedure TWebContext.SetParamsTable(const AValue: TMVCRequestParamsTable); begin FRequest.ParamsTable := AValue; end; { TMVCEngine } function TMVCEngine.AddController(const AControllerClazz: TMVCControllerClazz; const AURLSegment: string): TMVCEngine; begin Result := AddController(AControllerClazz, nil, AURLSegment); end; function TMVCEngine.AddController(const AControllerClazz: TMVCControllerClazz; const ACreateAction: TMVCControllerCreateAction; const AURLSegment: string): TMVCEngine; begin FControllers.Add(TMVCControllerDelegate.Create(AControllerClazz, ACreateAction, AURLSegment)); Result := Self; end; function TMVCEngine.AddMiddleware(const AMiddleware: IMVCMiddleware): TMVCEngine; begin FMiddlewares.Add(AMiddleware); Result := Self; end; function TMVCEngine.AddSerializer(const AContentType: string; const ASerializer: IMVCSerializer) : TMVCEngine; begin FSerializers.AddOrSetValue(AContentType, ASerializer); Result := Self; end; class procedure TMVCEngine.ClearSessionCookiesAlreadySet(const ACookies: TCookieCollection); var I: Integer; SessionCookieName: string; Cookie: TCookie; begin SessionCookieName := TMVCConstants.SESSION_TOKEN_NAME.ToLower; I := 0; while True do begin if I = ACookies.Count then Break; Cookie := ACookies[I]; if LowerCase(Cookie.name) = SessionCookieName then ACookies.Delete(I) else Inc(I); end; end; procedure TMVCEngine.ConfigDefaultValues; begin Log.Info('ENTER: Config default values', LOGGERPRO_TAG); Config[TMVCConfigKey.SessionTimeout] := '30' { 30 minutes }; Config[TMVCConfigKey.DefaultContentType] := TMVCConstants.DEFAULT_CONTENT_TYPE; Config[TMVCConfigKey.DefaultContentCharset] := TMVCConstants.DEFAULT_CONTENT_CHARSET; Config[TMVCConfigKey.DefaultViewFileExtension] := 'html'; Config[TMVCConfigKey.ViewPath] := 'templates'; Config[TMVCConfigKey.PathPrefix] := ''; Config[TMVCConfigKey.AllowUnhandledAction] := 'false'; Config[TMVCConfigKey.ServerName] := 'DelphiMVCFramework'; Config[TMVCConfigKey.ExposeServerSignature] := 'true'; Config[TMVCConfigKey.ExposeXPoweredBy] := 'true'; Config[TMVCConfigKey.SessionType] := 'memory'; Config[TMVCConfigKey.MaxEntitiesRecordCount] := '20'; Config[TMVCConfigKey.MaxRequestSize] := IntToStr(TMVCConstants.DEFAULT_MAX_REQUEST_SIZE); Config[TMVCConfigKey.HATEOSPropertyName] := '_links'; Config[TMVCConfigKey.LoadSystemControllers] := 'true'; Log.Info('EXIT: Config default values', LOGGERPRO_TAG); fOnRouterLog := procedure(const Sender: TMVCCustomRouter; const RouterLogState: TMVCRouterLogState; const Context: TWebContext) begin case RouterLogState of rlsRouteFound: begin Log(TLogLevel.levNormal, Context.Request.HTTPMethodAsString + ':' + Context.Request.PathInfo + ' [' + Context.Request.ClientIp + '] -> ' + Sender.GetQualifiedActionName + ' - ' + IntToStr(Context.Response.StatusCode) + ' ' + Context.Response.ReasonString); end; rlsRouteNotFound: begin Log(TLogLevel.levNormal, Context.Request.HTTPMethodAsString + ':' + Context.Request.PathInfo + ' [' + Context.Request.ClientIp + '] -> {NOT FOUND} - ' + IntToStr(Context.Response.StatusCode) + ' ' + Context.Response.ReasonString); end; else raise EMVCException.Create('Invalid RouterLogState'); end; end; end; constructor TMVCEngine.Create(const AWebModule: TWebModule; const AConfigAction: TProc; const ACustomLogger: ILogWriter); begin inherited Create(AWebModule); FWebModule := AWebModule; FixUpWebModule; FConfig := TMVCConfig.Create; FSerializers := TDictionary.Create; FMiddlewares := TList.Create; FControllers := TObjectList.Create(True); FApplicationSession := nil; FSavedOnBeforeDispatch := nil; WebRequestHandler.CacheConnections := True; WebRequestHandler.MaxConnections := 4096; MVCFramework.Logger.SetDefaultLogger(ACustomLogger); ConfigDefaultValues; if Assigned(AConfigAction) then begin LogEnterMethod('Custom configuration method'); AConfigAction(FConfig); LogExitMethod('Custom configuration method'); end; FConfig.Freeze; SaveCacheConfigValues; RegisterDefaultsSerializers; LoadSystemControllers; end; function TMVCEngine.CustomExceptionHandling(const Ex: Exception; const ASelectedController: TMVCController; const AContext: TWebContext): Boolean; begin Result := False; if Assigned(FOnException) then begin FOnException(Ex, ASelectedController, AContext, Result); end; end; procedure TMVCEngine.DefineDefaultResponseHeaders(const AContext: TWebContext); begin if FConfigCache_ExposeServerSignature and (not IsLibrary) then AContext.Response.CustomHeaders.Values['Server'] := FConfigCache_ServerSignature; if FConfigCache_ExposeXPoweredBy then AContext.Response.CustomHeaders.Values['X-Powered-By'] := 'DMVCFramework ' + DMVCFRAMEWORK_VERSION; AContext.Response.RawWebResponse.Date := Now; end; destructor TMVCEngine.Destroy; begin FConfig.Free; FSerializers.Free; FMiddlewares.Free; FControllers.Free; inherited Destroy; end; procedure TMVCEngine.DoWebContextCreateEvent(const AContext: TWebContext); begin if Assigned(fWebContextCreateEvent) then begin fWebContextCreateEvent(AContext); end; end; procedure TMVCEngine.DoWebContextDestroyEvent(const AContext: TWebContext); begin if Assigned(fWebContextDestroyEvent) then begin fWebContextDestroyEvent(AContext); end; end; function TMVCEngine.ExecuteAction(const ASender: TObject; const ARequest: TWebRequest; const AResponse: TWebResponse): Boolean; var lParamsTable: TMVCRequestParamsTable; lContext: TWebContext; lRouter: TMVCRouter; lHandled: Boolean; lResponseContentMediaType: string; lResponseContentCharset: string; lRouterMethodToCallName: string; lRouterControllerClazzQualifiedClassName: string; lSelectedController: TMVCController; lActionFormalParams: TArray; lActualParams: TArray; lBodyParameter: TObject; begin Result := False; if ARequest.ContentLength > FConfigCache_MaxRequestSize then begin raise EMVCException.CreateFmt(http_status.RequestEntityTooLarge, 'Request size exceeded the max allowed size [%d KiB] (1)', [(FConfigCache_MaxRequestSize div 1024)]); end; {$IF Defined(BERLINORBETTER)} ARequest.ReadTotalContent; // Double check for malicious content-length header if ARequest.ContentLength > FConfigCache_MaxRequestSize then begin raise EMVCException.CreateFmt(http_status.RequestEntityTooLarge, 'Request size exceeded the max allowed size [%d KiB] (2)', [(FConfigCache_MaxRequestSize div 1024)]); end; {$ENDIF} lParamsTable := TMVCRequestParamsTable.Create; try lContext := TWebContext.Create(ARequest, AResponse, FConfig, FSerializers); try DefineDefaultResponseHeaders(lContext); DoWebContextCreateEvent(lContext); lHandled := False; lRouter := TMVCRouter.Create(FConfig, gMVCGlobalActionParamsCache); try // finally lSelectedController := nil; try // only for lSelectedController try // global exception handler ExecuteBeforeRoutingMiddleware(lContext, lHandled); if not lHandled then begin if lRouter.ExecuteRouting(ARequest.PathInfo, lContext.Request.GetOverwrittenHTTPMethod { lContext.Request.HTTPMethod } , ARequest.ContentType, ARequest.Accept, FControllers, FConfigCache_DefaultContentType, FConfigCache_DefaultContentCharset, FConfigCache_PathPrefix, lParamsTable, lResponseContentMediaType, lResponseContentCharset) then begin try if Assigned(lRouter.ControllerCreateAction) then lSelectedController := lRouter.ControllerCreateAction() else lSelectedController := lRouter.ControllerClazz.Create; except on Ex: Exception do begin Log.ErrorFmt('[%s] %s [PathInfo "%s"] (Custom message: "%s")', [Ex.Classname, Ex.Message, GetRequestShortDescription(ARequest), 'Cannot create controller'], LOGGERPRO_TAG); raise EMVCException.Create(http_status.InternalServerError, 'Cannot create controller'); end; end; lRouterMethodToCallName := lRouter.MethodToCall.Name; lRouterControllerClazzQualifiedClassName := lRouter.ControllerClazz.QualifiedClassName; MVCFramework.Logger.InitThreadVars; lContext.fActionQualifiedName := lRouterControllerClazzQualifiedClassName + '.'+ lRouterMethodToCallName; lSelectedController.Engine := Self; lSelectedController.Context := lContext; lSelectedController.ApplicationSession := FApplicationSession; lContext.ParamsTable := lParamsTable; ExecuteBeforeControllerActionMiddleware( lContext, lRouterControllerClazzQualifiedClassName, lRouterMethodToCallName, lHandled); if lHandled then Exit(True); lBodyParameter := nil; lSelectedController.MVCControllerAfterCreate; try lHandled := False; lSelectedController.ContentType := BuildContentType(lResponseContentMediaType, lResponseContentCharset); lActionFormalParams := lRouter.MethodToCall.GetParameters; if (Length(lActionFormalParams) = 0) then SetLength(lActualParams, 0) else if (Length(lActionFormalParams) = 1) and (SameText(lActionFormalParams[0].ParamType.QualifiedName, 'MVCFramework.TWebContext')) then begin SetLength(lActualParams, 1); lActualParams[0] := lContext; end else begin FillActualParamsForAction(lSelectedController, lContext, lActionFormalParams, lRouterMethodToCallName, lActualParams, lBodyParameter); end; lSelectedController.OnBeforeAction(lContext, lRouterMethodToCallName, lHandled); if not lHandled then begin try lRouter.MethodToCall.Invoke(lSelectedController, lActualParams); finally lSelectedController.OnAfterAction(lContext, lRouterMethodToCallName); end; end; finally try lBodyParameter.Free; except on E: Exception do begin LogE(Format('Cannot free Body object: [CLS: %s][MSG: %s]', [E.Classname, E.Message])); end; end; lSelectedController.MVCControllerBeforeDestroy; end; ExecuteAfterControllerActionMiddleware(lContext, lRouterControllerClazzQualifiedClassName, lRouterMethodToCallName, lHandled); lContext.Response.ContentType := lSelectedController.ContentType; fOnRouterLog(lRouter, rlsRouteFound, lContext); end else // execute-routing begin if Config[TMVCConfigKey.AllowUnhandledAction] = 'false' then begin lContext.Response.StatusCode := http_status.NotFound; lContext.Response.ReasonString := 'Not Found'; fOnRouterLog(lRouter, rlsRouteNotFound, lContext); raise EMVCException.Create(lContext.Response.ReasonString, lContext.Request.HTTPMethodAsString + ' ' + lContext.Request.PathInfo, 0, http_status.NotFound); end else begin lContext.Response.FlushOnDestroy := False; end; end; // end-execute-routing end; // if not handled by beforerouting except on ESess: EMVCSessionExpiredException do begin if not CustomExceptionHandling(ESess, lSelectedController, lContext) then begin Log.ErrorFmt('[%s] %s [PathInfo "%s"] (Custom message: "%s")', [ESess.Classname, ESess.Message, GetRequestShortDescription(ARequest), ESess.DetailedMessage], LOGGERPRO_TAG); lContext.SessionStop; lSelectedController.ResponseStatus(ESess.HTTPErrorCode); lSelectedController.Render(ESess); end; end; on E: EMVCException do begin if not CustomExceptionHandling(E, lSelectedController, lContext) then begin Log.ErrorFmt('[%s] %s [PathInfo "%s"] (Custom message: "%s")', [E.Classname, E.Message, GetRequestShortDescription(ARequest), E.DetailedMessage], LOGGERPRO_TAG); if Assigned(lSelectedController) then begin lSelectedController.ResponseStatus(E.HTTPErrorCode); lSelectedController.Render(E); end else begin SendRawHTTPStatus(lContext, E.HTTPErrorCode, Format('[%s] %s', [E.Classname, E.Message]), E.Classname); end; end; end; on EIO: EInvalidOp do begin if not CustomExceptionHandling(EIO, lSelectedController, lContext) then begin Log.ErrorFmt('[%s] %s [PathInfo "%s"] (Custom message: "%s")', [EIO.Classname, EIO.Message, GetRequestShortDescription(ARequest), 'Invalid Op'], LOGGERPRO_TAG); if Assigned(lSelectedController) then begin lSelectedController.ResponseStatus(http_status.InternalServerError); lSelectedController.Render(EIO); end else begin SendRawHTTPStatus(lContext, http_status.InternalServerError, Format('[%s] %s', [EIO.Classname, EIO.Message]), EIO.Classname); end; end; end; on Ex: Exception do begin if not CustomExceptionHandling(Ex, lSelectedController, lContext) then begin Log.ErrorFmt('[%s] %s [PathInfo "%s"] (Custom message: "%s")', [Ex.Classname, Ex.Message, GetRequestShortDescription(ARequest), 'Global Action Exception Handler'], LOGGERPRO_TAG); if Assigned(lSelectedController) then begin lSelectedController.ResponseStatus(http_status.InternalServerError); lSelectedController.Render(Ex); end else begin SendRawHTTPStatus(lContext, http_status.InternalServerError, Format('[%s] %s', [Ex.Classname, Ex.Message]), Ex.Classname); end; end; end; end; try ExecuteAfterRoutingMiddleware(lContext, lHandled); except on Ex: Exception do begin if not CustomExceptionHandling(Ex, lSelectedController, lContext) then begin Log.ErrorFmt('[%s] %s [PathInfo "%s"] (Custom message: "%s")', [Ex.Classname, Ex.Message, GetRequestShortDescription(ARequest), 'After Routing Exception Handler'], LOGGERPRO_TAG); if Assigned(lSelectedController) then begin { middlewares *must* not raise unhandled exceptions } lSelectedController.ResponseStatus(http_status.InternalServerError); lSelectedController.Render(Ex); end else begin SendRawHTTPStatus(lContext, http_status.InternalServerError, Format('[%s] %s', [Ex.Classname, Ex.Message]), Ex.Classname); end; end; end; end; finally FreeAndNil(lSelectedController); end; finally lRouter.Free; end; finally DoWebContextDestroyEvent(lContext); lContext.Free; end; finally lParamsTable.Free; end; end; procedure TMVCEngine.ExecuteAfterControllerActionMiddleware(const AContext: TWebContext; const AControllerQualifiedClassName: string; const AActionName: string; const AHandled: Boolean); var I: Integer; begin for I := 0 to FMiddlewares.Count - 1 do begin FMiddlewares[I].OnAfterControllerAction(AContext, AControllerQualifiedClassName, AActionName, AHandled); end; end; procedure TMVCEngine.ExecuteAfterRoutingMiddleware(const AContext: TWebContext; const AHandled: Boolean); var I: Integer; begin for I := 0 to FMiddlewares.Count - 1 do begin FMiddlewares[I].OnAfterRouting(AContext, AHandled); end; end; procedure TMVCEngine.ExecuteBeforeControllerActionMiddleware(const AContext: TWebContext; const AControllerQualifiedClassName: string; const AActionName: string; var AHandled: Boolean); var Middleware: IMVCMiddleware; begin if not AHandled then begin for Middleware in FMiddlewares do begin Middleware.OnBeforeControllerAction(AContext, AControllerQualifiedClassName, AActionName, AHandled); if AHandled then begin Break; end; end; end; end; procedure TMVCEngine.ExecuteBeforeRoutingMiddleware(const AContext: TWebContext; var AHandled: Boolean); var Middleware: IMVCMiddleware; begin if not AHandled then begin for Middleware in FMiddlewares do begin Middleware.OnBeforeRouting(AContext, AHandled); if AHandled then begin Break; end; end; end; end; class function TMVCEngine.ExtractSessionIdFromWebRequest(const AWebRequest: TWebRequest): string; begin Result := AWebRequest.CookieFields.Values[TMVCConstants.SESSION_TOKEN_NAME]; if not Result.IsEmpty then Result := TIdURI.URLDecode(Result); end; procedure TMVCEngine.FillActualParamsForAction(const ASelectedController: TMVCController; const AContext: TWebContext; const AActionFormalParams: TArray; const AActionName: string; var AActualParams: TArray; out ABodyParameter: TObject); var lParamName: string; I: Integer; lStrValue: string; lFromBodyAttribute: MVCFromBodyAttribute; lFromQueryStringAttribute: MVCFromQueryStringAttribute; lFromHeaderAttribute: MVCFromHeaderAttribute; lFromCookieAttribute: MVCFromCookieAttribute; lAttributeInjectedParamCount: Integer; lInjectedParamValue: string; lList: IMVCList; lItemClass: TClass; begin ABodyParameter := nil; lAttributeInjectedParamCount := 0; SetLength(AActualParams, Length(AActionFormalParams)); for I := 0 to Length(AActionFormalParams) - 1 do begin lParamName := AActionFormalParams[I].name; if Length(AActionFormalParams[I].GetAttributes) > 0 then begin // Let's check how to inject this parameter if TRttiUtils.HasAttribute(AActionFormalParams[I], lFromBodyAttribute) then begin Inc(lAttributeInjectedParamCount, 1); if AActionFormalParams[I].ParamType.QualifiedName <> 'System.string' then begin ABodyParameter := TRttiUtils.CreateObject(AActionFormalParams[I].ParamType.QualifiedName); if TDuckTypedList.CanBeWrappedAsList(ABodyParameter, lList) then begin lItemClass := TMVCAbstractSerializer(ASelectedController.Serializer).GetObjectTypeOfGenericList(ABodyParameter.ClassInfo); ASelectedController.Serializer.DeserializeCollection(ASelectedController.Context.Request.Body, ABodyParameter, lItemClass, stDefault, [], lFromBodyAttribute.RootNode); end else begin ASelectedController.Serializer.DeserializeObject(ASelectedController.Context.Request.Body, ABodyParameter, stDefault, [], lFromBodyAttribute.RootNode); end; AActualParams[I] := ABodyParameter; end else begin AActualParams[I] := ASelectedController.Context.Request.Body; Continue; end; end else if TRttiUtils.HasAttribute(AActionFormalParams[I], lFromQueryStringAttribute) then begin Inc(lAttributeInjectedParamCount, 1); lInjectedParamValue := AContext.Request.QueryStringParam (lFromQueryStringAttribute.ParamName); HandleDefaultValueForInjectedParameter(lInjectedParamValue, lFromQueryStringAttribute); AActualParams[I] := GetActualParam(AActionFormalParams[I], lInjectedParamValue); end else if TRttiUtils.HasAttribute(AActionFormalParams[I], lFromHeaderAttribute) then begin Inc(lAttributeInjectedParamCount, 1); lInjectedParamValue := AContext.Request.GetHeader(lFromHeaderAttribute.ParamName); HandleDefaultValueForInjectedParameter(lInjectedParamValue, lFromHeaderAttribute); AActualParams[I] := GetActualParam(AActionFormalParams[I], lInjectedParamValue); end else if TRttiUtils.HasAttribute(AActionFormalParams[I], lFromCookieAttribute) then begin Inc(lAttributeInjectedParamCount, 1); lInjectedParamValue := AContext.Request.Cookie(lFromCookieAttribute.ParamName); HandleDefaultValueForInjectedParameter(lInjectedParamValue, lFromCookieAttribute); AActualParams[I] := GetActualParam(AActionFormalParams[I], lInjectedParamValue); end else begin raise EMVCException.Create(http_status.InternalServerError, 'Unknown custom attribute on action parameter: ' + AActionFormalParams[I].name + '. [HINT: Allowed attributes are MVCFromBody, MVCFromQueryString, MVCFromHeader, MVCFromCookie]'); end; Continue; end; // From now on we'll check for url mapped parameters if not AContext.Request.SegmentParam(lParamName, lStrValue) then raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid parameter %s for action %s (Hint: Here parameters names are case-sensitive)', [lParamName, AActionName]); AActualParams[I] := GetActualParam(AActionFormalParams[I], lStrValue); end; if (AContext.Request.SegmentParamsCount + lAttributeInjectedParamCount) <> Length(AActionFormalParams) then raise EMVCException.CreateFmt(http_status.BadRequest, 'Parameters count mismatch (expected %d actual %d) for action "%s"', [Length(AActionFormalParams), AContext.Request.SegmentParamsCount, AActionName]); end; procedure TMVCEngine.FixUpWebModule; begin FSavedOnBeforeDispatch := FWebModule.BeforeDispatch; FWebModule.BeforeDispatch := OnBeforeDispatch; end; function TMVCEngine.GetActualParam(const AFormalParam: TRttiParameter; const AStringValue: String): TValue; var lWasDateTime: Boolean; lQualifiedName: String; lFormatSettings: TFormatSettings; begin case AFormalParam.ParamType.TypeKind of tkInteger: try Result := StrToInt(AStringValue); except on E: Exception do begin raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid Integer value for param [%s] - [CLASS: %s][MSG: %s]', [AFormalParam.name, E.Classname, E.Message]); end; end; tkInt64: try Result := StrToInt64(AStringValue); except on E: Exception do begin raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid Int64 value for param [%s] - [CLASS: %s][MSG: %s]', [AFormalParam.name, E.Classname, E.Message]); end; end; tkUString: begin Result := AStringValue; end; tkFloat: begin lWasDateTime := False; lQualifiedName := AFormalParam.ParamType.QualifiedName; if lQualifiedName = 'System.TDate' then begin try lWasDateTime := True; Result := ISODateToDate(AStringValue); except on E: Exception do begin raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid TDate value for param [%s] - [CLASS: %s][MSG: %s]', [AFormalParam.name, E.Classname, E.Message]); end; end; end else if lQualifiedName = 'System.TDateTime' then begin try lWasDateTime := True; Result := ISOTimeStampToDateTime(AStringValue); except on E: Exception do begin raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid TDateTime value for param [%s] - [CLASS: %s][MSG: %s]', [AFormalParam.name, E.Classname, E.Message]); end; end; end else if lQualifiedName = 'System.TTime' then begin try lWasDateTime := True; Result := ISOTimeToTime(AStringValue); except on E: Exception do begin raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid TTime value for param [%s] - [CLASS: %s][MSG: %s]', [AFormalParam.name, E.Classname, E.Message]); end; end; end; if not lWasDateTime then try lFormatSettings.DecimalSeparator := '.'; Result := StrToFloat(AStringValue, lFormatSettings); except on E: Exception do begin raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid Float value for param [%s] - [CLASS: %s][MSG: %s]', [AFormalParam.name, E.Classname, E.Message]); end; end; end; tkEnumeration: begin if AFormalParam.ParamType.QualifiedName = 'System.Boolean' then begin if SameText(AStringValue, 'true') or SameText(AStringValue, '1') then Result := True else if SameText(AStringValue, 'false') or SameText(AStringValue, '0') then Result := False else begin raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid boolean value for parameter %s. Boolean parameters accepts only "true"/"false" or "1"/"0".', [AFormalParam.name]); end; end else begin raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid type for parameter %s. Allowed types are ' + ALLOWED_TYPED_ACTION_PARAMETERS_TYPES, [AFormalParam.name]); end; end; tkRecord: begin if AFormalParam.ParamType.QualifiedName = 'System.TGUID' then begin try Result := TValue.From(TMVCGuidHelper.StringToGUIDEx(AStringValue)); except raise EMVCException.CreateFmt('Invalid Guid value for param [%s]', [AFormalParam.name]); end; end else raise EMVCException.CreateFmt('Invalid type for parameter %s. Allowed types are ' + ALLOWED_TYPED_ACTION_PARAMETERS_TYPES, [AFormalParam.name]); end else begin raise EMVCException.CreateFmt(http_status.BadRequest, 'Invalid type for parameter %s. Allowed types are ' + ALLOWED_TYPED_ACTION_PARAMETERS_TYPES, [AFormalParam.name]); end; end; end; class function TMVCEngine.GetCurrentSession(const ASessionId: string; const ARaiseExceptionIfExpired: Boolean): TWebSession; var lSessionList: TObjectDictionary; begin Result := nil; lSessionList := GlobalSessionList; TMonitor.Enter(lSessionList); try if not ASessionId.IsEmpty then begin if lSessionList.TryGetValue(ASessionId, Result) then begin { https://github.com/danieleteti/delphimvcframework/issues/355 } if Result.IsExpired then begin lSessionList.Remove(ASessionId); if ARaiseExceptionIfExpired then begin raise EMVCSessionExpiredException.Create('Session expired.') end else begin Result := nil; end; end else begin Result.MarkAsUsed; end; end; end; finally TMonitor.Exit(lSessionList); end; end; function TMVCEngine.GetSessionBySessionId(const ASessionId: string): TWebSession; begin Result := TMVCEngine.GetCurrentSession(ASessionId, False); if Assigned(Result) then Result.MarkAsUsed; end; function TMVCEngine.GetViewEngineClass: TMVCViewEngineClass; begin if FViewEngineClass = nil then raise EMVCConfigException.Create ('No View Engine configured. [HINT: Use TMVCEngine.SetViewEngine() to set a valid view engine]'); Result := FViewEngineClass; end; procedure TMVCEngine.HandleDefaultValueForInjectedParameter(var InjectedParamValue: String; const InjectableParamAttribute: MVCInjectableParamAttribute); begin if InjectedParamValue.IsEmpty then begin if InjectableParamAttribute.CanBeUsedADefaultValue then begin InjectedParamValue := InjectableParamAttribute.DefaultValueAsString; end else begin raise EMVCException.CreateFmt ('Required parameter "%s" injected using "%s" has not provided and cannot be used a default value for it', [InjectableParamAttribute.ParamName, InjectableParamAttribute.Classname]); end; end; end; procedure TMVCEngine.HTTP404(const AContext: TWebContext); begin AContext.Response.SetStatusCode(http_status.NotFound); AContext.Response.SetContentType(BuildContentType(TMVCMediaType.TEXT_PLAIN, AContext.Config[TMVCConfigKey.DefaultContentCharset])); AContext.Response.SetReasonString('Not Found'); AContext.Response.SetContent('Not Found' + sLineBreak + FConfigCache_ServerSignature); end; procedure TMVCEngine.HTTP500(const AContext: TWebContext; const AReasonString: string); begin AContext.Response.SetStatusCode(http_status.InternalServerError); AContext.Response.SetContentType(BuildContentType(TMVCMediaType.TEXT_PLAIN, AContext.Config[TMVCConfigKey.DefaultContentCharset])); AContext.Response.SetReasonString('Internal server error'); AContext.Response.SetContent('Internal server error' + sLineBreak + FConfigCache_ServerSignature + ': ' + AReasonString); end; procedure TMVCEngine.SendRawHTTPStatus(const AContext: TWebContext; const HTTPStatusCode: Integer; const AReasonString: string; const AClassName: string); var lSer: IMVCSerializer; lError: TMVCErrorResponse; begin lError := TMVCErrorResponse.Create; try lError.Classname := AClassName; lError.StatusCode := HTTPStatusCode; lError.Message := AReasonString; if AContext.Request.ClientPreferHTML then begin if not Serializers.TryGetValue(TMVCMediaType.TEXT_HTML, lSer) then begin raise EMVCConfigException.Create('Cannot find HTML serializer'); end; AContext.Response.SetContent(lSer.SerializeObject(lError)); AContext.Response.SetContentType(BuildContentType(TMVCMediaType.TEXT_HTML, AContext.Config[TMVCConfigKey.DefaultContentCharset])); end else if AContext.Request.ClientPrefer(AContext.Config[TMVCConfigKey.DefaultContentType]) and Serializers.TryGetValue(AContext.Config[TMVCConfigKey.DefaultContentType], lSer) then begin AContext.Response.SetContent(lSer.SerializeObject(lError)); AContext.Response.SetContentType (BuildContentType(AContext.Config[TMVCConfigKey.DefaultContentType], AContext.Config[TMVCConfigKey.DefaultContentCharset])); end else begin AContext.Response.SetContentType(BuildContentType(TMVCMediaType.TEXT_PLAIN, AContext.Config[TMVCConfigKey.DefaultContentCharset])); AContext.Response.SetContent(FConfigCache_ServerSignature + sLineBreak + 'HTTP ' + HTTPStatusCode.ToString + ': ' + AReasonString); end; AContext.Response.SetStatusCode(HTTPStatusCode); AContext.Response.SetReasonString(AReasonString); finally lError.Free; end; end; procedure TMVCEngine.LoadSystemControllers; begin if FConfig[TMVCConfigKey.LoadSystemControllers] = 'true' then begin Log(TLogLevel.levNormal, 'ENTER: LoadSystemControllers'); AddController(TMVCSystemController); Log(TLogLevel.levNormal, 'EXIT: LoadSystemControllers'); end; end; procedure TMVCEngine.OnBeforeDispatch(ASender: TObject; ARequest: TWebRequest; AResponse: TWebResponse; var AHandled: Boolean); begin AHandled := False; { there is a bug in WebBroker Linux on 10.2.1 tokyo } // if Assigned(FSavedOnBeforeDispatch) then // begin // FSavedOnBeforeDispatch(ASender, ARequest, AResponse, AHandled); // end; if IsShuttingDown then begin AResponse.StatusCode := http_status.ServiceUnavailable; AResponse.ContentType := TMVCMediaType.TEXT_PLAIN; AResponse.Content := 'Server is shutting down'; AHandled := True; end; if not AHandled then begin try AHandled := ExecuteAction(ASender, ARequest, AResponse); if not AHandled then begin AResponse.ContentStream := nil; end; except on E: Exception do begin Log.ErrorFmt('[%s] %s', [E.Classname, E.Message], LOGGERPRO_TAG); AResponse.StatusCode := http_status.InternalServerError; // default is Internal Server Error if E is EMVCException then begin AResponse.StatusCode := (E as EMVCException).HTTPErrorCode; end; AResponse.Content := E.Message; AResponse.SendResponse; AHandled := True; end; end; end; end; procedure TMVCEngine.OnWebContextCreate( const WebContextCreateEvent: TWebContextCreateEvent); begin fWebContextCreateEvent := WebContextCreateEvent; end; procedure TMVCEngine.OnWebContextDestroy( const WebContextDestroyEvent: TWebContextDestroyEvent); begin fWebContextDestroyEvent := WebContextDestroyEvent; end; function TMVCEngine.PublishObject(const AObjectCreatorDelegate: TMVCObjectCreatorDelegate; const AURLSegment: string; ExceptionHandler: TMVCJSONRPCExceptionHandlerProc = nil): TMVCEngine; begin Result := AddController(TMVCJSONRPCPublisher, function: TMVCController begin Result := TMVCJSONRPCPublisher.Create(AObjectCreatorDelegate(), True, ExceptionHandler); end, AURLSegment); end; procedure TMVCEngine.RegisterDefaultsSerializers; var lDefaultSerializerContentType: string; begin // lDefaultSerializerContentType := BuildContentType(TMVCMediaType.APPLICATION_JSON, TMVCCharset.UTF_8); // if not FSerializers.ContainsKey(lDefaultSerializerContentType) then // begin // FSerializers.Add(lDefaultSerializerContentType, TMVCJSONDataObjectsSerializer.Create); // end; // register the same serializer without the charset in the contenttype lDefaultSerializerContentType := BuildContentType(TMVCMediaType.APPLICATION_JSON, ''); if not FSerializers.ContainsKey(lDefaultSerializerContentType) then begin FSerializers.Add(lDefaultSerializerContentType, TMVCJSONDataObjectsSerializer.Create(Config)); end; // this is used only for exceptions (dt 2020-09-16) lDefaultSerializerContentType := BuildContentType(TMVCMediaType.TEXT_HTML, ''); if not FSerializers.ContainsKey(lDefaultSerializerContentType) then begin FSerializers.Add(lDefaultSerializerContentType, TMVCHTMLSerializer.Create(Config)); end; end; procedure TMVCEngine.ResponseErrorPage(const AException: Exception; const ARequest: TWebRequest; const AResponse: TWebResponse); begin AResponse.SetCustomHeader('x-mvc-error', AException.Classname + ': ' + AException.Message); AResponse.StatusCode := http_status.OK; begin AResponse.ContentType := TMVCMediaType.TEXT_PLAIN; AResponse.Content := Config[TMVCConfigKey.ServerName] + ' ERROR:' + sLineBreak + 'Exception raised of class: ' + AException.Classname + sLineBreak + '***********************************************' + sLineBreak + AException.Message + sLineBreak + '***********************************************'; end; end; class function TMVCEngine.SendSessionCookie(const AContext: TWebContext): string; var SId: string; begin SId := StringReplace(StringReplace(StringReplace('DT' + GUIDToString(TGUID.NewGuid), '}', '', []), '{', '', []), '-', '', [rfReplaceAll]); Result := SendSessionCookie(AContext, SId); end; procedure TMVCEngine.SaveCacheConfigValues; begin FConfigCache_MaxRequestSize := StrToInt64Def(Config[TMVCConfigKey.MaxRequestSize], TMVCConstants.DEFAULT_MAX_REQUEST_SIZE); FConfigCache_ExposeServerSignature := Config[TMVCConfigKey.ExposeServerSignature] = 'true'; FConfigCache_ServerSignature := Config[TMVCConfigKey.ServerName]; FConfigCache_ExposeXPoweredBy := Config[TMVCConfigKey.ExposeXPoweredBy] = 'true'; FConfigCache_DefaultContentType := Config[TMVCConfigKey.DefaultContentType]; FConfigCache_DefaultContentCharset := Config[TMVCConfigKey.DefaultContentCharset]; FConfigCache_PathPrefix := Config[TMVCConfigKey.PathPrefix]; end; class function TMVCEngine.SendSessionCookie(const AContext: TWebContext; const ASessionId: string): string; var Cookie: TCookie; SessionTimeout: Integer; begin ClearSessionCookiesAlreadySet(AContext.Response.Cookies); Cookie := AContext.Response.Cookies.Add; Cookie.name := TMVCConstants.SESSION_TOKEN_NAME; Cookie.Value := ASessionId; if not TryStrToInt(AContext.Config[TMVCConfigKey.SessionTimeout], SessionTimeout) then raise EMVCException.Create('[Config::Session Timeout] is not a valid integer'); if SessionTimeout = 0 then Cookie.Expires := 0 // session cookie else Cookie.Expires := Now + OneMinute * SessionTimeout; Cookie.Path := '/'; Result := ASessionId; end; function TMVCEngine.SetExceptionHandler(const AExceptionHandlerProc: TMVCExceptionHandlerProc) : TMVCEngine; begin FOnException := AExceptionHandlerProc; Result := Self; end; function TMVCEngine.SetViewEngine(const AViewEngineClass: TMVCViewEngineClass): TMVCEngine; begin FViewEngineClass := AViewEngineClass; Result := Self; end; { TMVCBase } class function TMVCBase.GetApplicationFileName: string; // var // Name: PChar; // Size: Integer; begin Result := GetModuleName(HInstance); // Result := EmptyStr; // Name := GetMemory(2048); // try // GetModuleName() // Size := GetModuleFileName(0, Name, 2048); // if Size > 0 then // Result := Name; // finally // FreeMem(Name, 2048); // end; end; class function TMVCBase.GetApplicationFileNamePath: string; begin Result := IncludeTrailingPathDelimiter(ExtractFilePath(GetApplicationFileName)); end; function TMVCBase.GetApplicationSession: TWebApplicationSession; begin if not Assigned(FApplicationSession) then raise EMVCException.CreateFmt('ApplicationSession not assigned to this %s instance.', [Classname]); Result := FApplicationSession; end; function TMVCBase.GetConfig: TMVCConfig; begin Result := Engine.Config; end; function TMVCBase.GetEngine: TMVCEngine; begin if not Assigned(FEngine) then raise EMVCException.CreateFmt('MVCEngine not assigned to this %s instance.', [Classname]); Result := FEngine; end; procedure TMVCBase.SetApplicationSession(const AValue: TWebApplicationSession); begin FApplicationSession := AValue; end; procedure TMVCBase.SetEngine(const AValue: TMVCEngine); begin FEngine := AValue; end; { TMVCControllerDelegate } constructor TMVCControllerDelegate.Create(const AClazz: TMVCControllerClazz; const ACreateAction: TMVCControllerCreateAction; const AURLSegment: string = ''); begin inherited Create; FClazz := AClazz; FCreateAction := ACreateAction; FURLSegment := AURLSegment; end; { TMVCStaticContents } class function TMVCStaticContents.IsScriptableFile(const AStaticFileName: string; const AConfig: TMVCConfig): Boolean; begin Result := TPath.GetExtension(AStaticFileName).ToLower = '.' + AConfig[TMVCConfigKey.DefaultViewFileExtension].ToLower; end; class function TMVCStaticContents.IsStaticFile(const AViewPath, AWebRequestPath: string; out ARealFileName: string; out AIsDirectoryTraversalAttack: Boolean): Boolean; var lFileName: string; lWebRoot: string; begin AIsDirectoryTraversalAttack := False; if TDirectory.Exists(AViewPath) then begin lWebRoot := TPath.GetFullPath(AViewPath); end else begin lWebRoot := TPath.GetFullPath(GetApplicationFileNamePath + AViewPath); end; lFileName := TPath.Combine(lWebRoot, AWebRequestPath.Replace('/', TPath.DirectorySeparatorChar)); if not TPath.HasValidPathChars(lFileName, True) then begin Exit(False); end; lFileName := TPath.GetFullPath(lFileName); if not lFileName.StartsWith(lWebRoot) then // AVOID PATH TRAVERSAL begin AIsDirectoryTraversalAttack := True; Exit(False); end; ARealFileName := lFileName; Result := TFile.Exists(ARealFileName); end; class procedure TMVCStaticContents.SendFile( const AFileName, AMediaType: string; AContext: TWebContext); var FileDate: TDateTime; IfModifiedSinceDate: TDateTime; lIfModifiedSince: string; begin if not FileExists(AFileName) then begin AContext.Response.StatusCode := 404; end else begin //https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/If-Modified-Since if AContext.Request.HTTPMethod in [httpGET, httpHEAD] then begin lIfModifiedSince := AContext.Request.Headers['If-Modified-Since']; if lIfModifiedSince <> '' then begin FileDate := IndyFileAge(AFileName); IfModifiedSinceDate := GMTToLocalDateTime(lIfModifiedSince); if (IfModifiedSinceDate <> 0) and (abs(IfModifiedSinceDate - FileDate) < 2 * (1 / (24 * 60 * 60))) then begin AContext.Response.ContentType := AMediaType; AContext.Response.StatusCode := 304; Exit; end end; AContext.Response.SetCustomHeader('Last-Modified', LocalDateTimeToHttpStr(FileDate)); AContext.Response.SetContentStream( TFileStream.Create(AFileName, fmOpenRead or fmShareDenyNone), AMediaType); end else begin AContext.Response.SetContentStream( TFileStream.Create(AFileName, fmOpenRead or fmShareDenyNone), AMediaType); end; end; end; { TMVCController } procedure TMVCController.CheckIfMatch(const Data: String); var lReqETag: String; begin if Data.IsEmpty then begin raise EMVCException.Create(HTTP_STATUS.InternalServerError, 'Cannot calculate ETag using empty value'); end; // https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/ETag#avoiding_mid-air_collisions lReqETag := GetIfMatch; if lReqETag.IsEmpty then begin raise EMVCException.Create(HTTP_STATUS.PreconditionFailed, 'If-Match header is empty'); end; if lReqETag <> GetSHA1HashFromString(Data) then begin raise EMVCException.Create(HTTP_STATUS.PreconditionFailed, 'mid-air collisions detected, cannot update or delete resource.'); end; end; constructor TMVCController.Create; begin inherited Create; FContext := nil; FContentCharset := TMVCConstants.DEFAULT_CONTENT_CHARSET; FResponseStream := nil; FViewModel := nil; FViewDataSets := nil; end; destructor TMVCController.Destroy; begin if Assigned(FResponseStream) then FResponseStream.Free; if Assigned(FViewModel) then FViewModel.Free; if Assigned(FViewDataSets) then FViewDataSets.Free; inherited Destroy; end; function TMVCController.GetClientId: string; begin Result := Session[CLIENTID_KEY]; if Result.IsEmpty then raise EMVCException.Create('Invalid ClientID' + sLineBreak + 'Hint: Messaging extensions require a valid clientid. Did you call /messages/clients/YOUR_CLIENT_ID ?'); end; function TMVCRenderer.GetContentType: string; begin Result := GetContext.Response.ContentType.Trim; if Result.IsEmpty then begin GetContext.Response.ContentType := FContext.FConfig [MVCFramework.Commons.TMVCConfigKey.DefaultContentType]; Result := GetContentType; end; end; function TMVCRenderer.GetContext: TWebContext; begin if not Assigned(FContext) then raise EMVCException.CreateFmt('Context is not set %s.', [Classname]); Result := FContext; end; function TMVCController.GetCurrentWebModule: TWebModule; begin Result := Engine.WebModule; end; function TMVCController.GetIfMatch: String; begin Result := Context.Request.GetHeader('If-Match'); end; function TMVCController.GetSession: TWebSession; begin Result := GetContext.Session; end; function TMVCRenderer.GetStatusCode: Integer; begin Result := GetContext.Response.StatusCode; end; function TMVCController.GetViewData(const aModelName: string): TObject; begin if not FViewModel.TryGetValue(aModelName, Result) then Result := nil; end; function TMVCController.GetViewDataset(const aDataSetName: string): TDataSet; begin if not FViewDataSets.TryGetValue(aDataSetName, Result) then Result := nil; end; function TMVCController.GetViewDataSets: TMVCViewDataSet; begin if not Assigned(FViewDataSets) then FViewDataSets := TMVCViewDataSet.Create; Result := FViewDataSets; end; function TMVCController.GetViewModel: TMVCViewDataObject; begin if not Assigned(FViewModel) then FViewModel := TMVCViewDataObject.Create; Result := FViewModel; end; function TMVCController.LoadView(const AViewNames: TArray): string; begin try Result := GetRenderedView(AViewNames); ResponseStream.Append(Result); except on E: Exception do begin Log.ErrorFmt('[%s] %s', [E.Classname, E.Message], LOGGERPRO_TAG); raise; end; end; end; procedure TMVCController.LoadViewFragment(const AViewFragment: string); begin ResponseStream.Append(AViewFragment); end; procedure TMVCController.MVCControllerAfterCreate; begin { Implement if need be. } end; procedure TMVCController.MVCControllerBeforeDestroy; begin { Implement if need be. } end; procedure TMVCController.OnAfterAction(AContext: TWebContext; const AActionName: string); begin { Implement if need be. } end; procedure TMVCController.OnBeforeAction(AContext: TWebContext; const AActionName: string; var AHandled: Boolean); begin AHandled := False; if ContentType.IsEmpty then ContentType := Config[TMVCConfigKey.DefaultContentType]; { Implement if need be. } end; procedure TMVCController.PushDataSetToView(const aModelName: string; const ADataSet: TDataSet); begin GetViewDataSets.Add(aModelName, ADataSet); end; procedure TMVCController.PushObjectToView(const aModelName: string; const AModel: TObject); begin GetViewModel.Add(aModelName, AModel); end; procedure TMVCController.RaiseSessionExpired; begin raise EMVCSessionExpiredException.Create('Session expired.'); end; procedure TMVCRenderer.Redirect(const AUrl: string); begin GetContext.Response.RawWebResponse.SendRedirect(AUrl); end; procedure TMVCRenderer.Render( const AObject: TObject; const AOwns: Boolean; const ASerializationAction: TMVCSerializationAction = nil; const AIgnoredFields: TMVCIgnoredList = nil); begin Render(AObject, AOwns, stDefault, ASerializationAction, AIgnoredFields); end; procedure TMVCRenderer.Render(const AStatusCode: Integer; const AContent: string); begin SetStatusCode(AStatusCode); Render(AContent); end; procedure TMVCRenderer.Render(const AStatusCode: Integer); begin RenderStatusMessage(AStatusCode, HTTP_STATUS.ReasonStringFor(AStatusCode)); end; procedure TMVCRenderer.Render(const AContent: string); var lContentType: string; lOutEncoding: TEncoding; lCharset: string; begin SplitContentMediaTypeAndCharset(GetContentType, lContentType, lCharset); if lCharset.IsEmpty then lCharset := TMVCConstants.DEFAULT_CONTENT_CHARSET; if lContentType.IsEmpty then lContentType := TMVCConstants.DEFAULT_CONTENT_TYPE; lContentType := BuildContentType(lContentType, lCharset); lOutEncoding := TEncoding.GetEncoding(lCharset); try if SameText('UTF-8', UpperCase(lCharset)) then GetContext.Response.SetContentStream(TStringStream.Create(AContent, TEncoding.UTF8), lContentType) else begin GetContext.Response.SetContentStream(TBytesStream.Create(TEncoding.Convert(TEncoding.Default, lOutEncoding, TEncoding.Default.GetBytes(AContent))), lContentType); end; finally lOutEncoding.Free; end; end; procedure TMVCRenderer.Render(const ACollection: TObjectList; const AOwns: Boolean; const ASerializationAction: TMVCSerializationAction); begin Self.Render(ACollection, AOwns, stDefault, ASerializationAction); end; procedure TMVCRenderer.Render202Accepted(const HREF: string; const ID: string; const Reason: string); begin if HREF.IsEmpty then begin raise EMVCException.Create('Cannot send 202 without provide an HREF'); end; ResponseStatus(http_status.Accepted, Reason); Render(TMVCAcceptedResponse.Create(HREF, ID)); end; procedure TMVCRenderer.Render201Created(const Location, Reason: string); begin if not Location.IsEmpty then begin {$IF defined(BERLINORBETTER)} FContext.Response.CustomHeaders.AddPair('location', Location); {$ELSE} FContext.Response.CustomHeaders.Add('location' + FContext.Response.CustomHeaders.NameValueSeparator + Location); {$ENDIF} end; ResponseStatus(http_status.Created, Reason); {$IF CompilerVersion >= 34} Render(''); // in 10.4 INDY requires something on the content {$ENDIF} end; procedure TMVCRenderer.Render204NoContent(const Location, Reason: string); begin if not Location.IsEmpty then begin {$IF defined(BERLINORBETTER)} FContext.Response.CustomHeaders.AddPair('location', Location); {$ELSE} FContext.Response.CustomHeaders.Add('location' + FContext.Response.CustomHeaders.NameValueSeparator + Location); {$ENDIF} end; ResponseStatus(http_status.NoContent, Reason); end; procedure TMVCRenderer.ResponseStatus(const AStatusCode: Integer; const AReasonString: string); begin SetStatusCode(AStatusCode); if AReasonString = '' then GetContext.Response.ReasonString := HTTP_STATUS.ReasonStringFor(AStatusCode) else GetContext.Response.ReasonString := AReasonString; end; function TMVCRenderer.ResponseStream: TStringBuilder; begin if not Assigned(FResponseStream) then FResponseStream := TStringBuilder.Create; Result := FResponseStream; end; function TMVCRenderer.Serializer: IMVCSerializer; begin Result := Serializer(GetContentType); end; procedure TMVCRenderer.SendFile(const AFileName: string); begin TMVCStaticContents.SendFile(AFileName, GetContentType, GetContext); end; procedure TMVCRenderer.SendStream(const AStream: TStream; const AOwns: Boolean; const ARewind: Boolean); var lTemp: TStream; begin if ARewind then begin AStream.Position := 0; end; lTemp := TMemoryStream.Create; try lTemp.CopyFrom(AStream, 0); lTemp.Position := 0; except lTemp.Free; raise; end; if AOwns then begin AStream.Free; end; GetContext.Response.RawWebResponse.Content := EmptyStr; GetContext.Response.RawWebResponse.ContentType := GetContentType; GetContext.Response.RawWebResponse.ContentStream := lTemp; GetContext.Response.RawWebResponse.FreeContentStream := True; end; function TMVCRenderer.Serializer(const AContentType: string; const ARaiseExceptionIfNotExists: Boolean): IMVCSerializer; var lContentMediaType: string; lContentCharSet: string; begin SplitContentMediaTypeAndCharset(AContentType.ToLower, lContentMediaType, lContentCharSet); if Engine.Serializers.ContainsKey(lContentMediaType) then begin Result := Engine.Serializers.Items[lContentMediaType]; end else begin if ARaiseExceptionIfNotExists then begin raise EMVCException.CreateFmt('The serializer for %s could not be found.', [lContentMediaType]); end else begin Result := nil; end; end; end; function TMVCController.SessionAs: T; begin Result := Session as T; end; procedure TMVCRenderer.SetContentType(const AValue: string); begin GetContext.Response.ContentType := AValue; end; procedure TMVCRenderer.SetStatusCode(const AValue: Integer); begin GetContext.Response.StatusCode := AValue; end; function TMVCRenderer.ToMVCList(const AObject: TObject; AOwnsObject: Boolean): IMVCList; begin Result := MVCFramework.DuckTyping.WrapAsList(AObject, AOwnsObject); end; procedure TMVCController.SetETag(const Data: String); begin Context.Response.SetCustomHeader('ETag', GetSHA1HashFromString(Data)); end; procedure TMVCController.SetViewData(const aModelName: string; const Value: TObject); begin GetViewModel.Add(aModelName, Value); end; procedure TMVCController.SetViewDataset(const aDataSetName: string; const Value: TDataSet); begin GetViewDataSets.Add(aDataSetName, Value); end; procedure TMVCRenderer.Render( const AObject: TObject; const AOwns: Boolean; const AType: TMVCSerializationType; const ASerializationAction: TMVCSerializationAction = nil; const AIgnoredFields: TMVCIgnoredList = nil); begin try Render(Serializer(GetContentType).SerializeObject(AObject, AType, AIgnoredFields, ASerializationAction)); finally if AOwns then AObject.Free; end; end; procedure TMVCRenderer.Render(const AStream: TStream; const AOwns: Boolean); begin SendStream(AStream, AOwns); end; procedure TMVCRenderer.RenderStatusMessage( const AStatusCode: Integer; const AReasonMessage, AErrorClassName: string; const ADataObject: TObject); var R: TMVCErrorResponse; begin ResponseStatus(AStatusCode, AReasonMessage); R := TMVCErrorResponse.Create; try R.StatusCode := AStatusCode; R.ReasonString := HTTP_STATUS.ReasonStringFor(AStatusCode); R.Message := AReasonMessage; R.Classname := AErrorClassName; R.Data := ADataObject; Render(R, False, stProperties); finally R.Free; end; end; procedure TMVCRenderer.Render(const ADataSet: TDataSet; const AOwns: Boolean; const AIgnoredFields: TMVCIgnoredList; const ANameCase: TMVCNameCase; const ASerializationType: TMVCDatasetSerializationType; const ASerializationAction: TMVCDatasetSerializationAction); begin if Assigned(ADataSet) then begin try case ASerializationType of dstSingleRecord: begin Render(Serializer(GetContentType).SerializeDataSetRecord(ADataSet, AIgnoredFields, ANameCase, ASerializationAction)) end; dstAllRecords: begin Render(Serializer(GetContentType).SerializeDataSet(ADataSet, AIgnoredFields, ANameCase, ASerializationAction)) end else begin raise EMVCSerializationException.Create('Invalid dataset serialization type'); end; end; // if ASerializationType = dstSingleRecord then // Render(Serializer(GetContentType).SerializeDataSetRecord(ADataSet, AIgnoredFields, ANameCase, // ASerializationAction)) // else // Render(Serializer(GetContentType).SerializeDataSet(ADataSet, AIgnoredFields, ANameCase, ASerializationAction)) finally if AOwns then ADataSet.Free; end; end else raise EMVCException.Create('Can not render an empty dataset.'); end; procedure TMVCRenderer.Render( const AStatusCode: Integer; const AObject: IInterface; const ASerializationAction: TMVCSerializationAction); begin SetStatusCode(AStatusCode); Render(AObject, ASerializationAction); end; procedure TMVCRenderer.Render( const AObject: IInterface; const ASerializationAction: TMVCSerializationAction); begin Render(TObject(AObject), False, ASerializationAction); end; procedure TMVCRenderer.Render(const AStatusCode: Integer; AObject: TObject; const AOwns: Boolean; const ASerializationAction: TMVCSerializationAction); begin ResponseStatus(AStatusCode); Render(AObject, AOwns, ASerializationAction); end; procedure TMVCRenderer.Render( const AStatusCode: Integer; const AObject: TObject; const ASerializationAction: TMVCSerializationAction; const AIgnoredFields: TMVCIgnoredList); begin ResponseStatus(AStatusCode); Render(AObject, True, stDefault, ASerializationAction, AIgnoredFields); end; procedure TMVCRenderer.Render(const ACollection: TObjectList; const AOwns: Boolean; const AType: TMVCSerializationType; const ASerializationAction: TMVCSerializationAction); var lSerializationAction: TMVCSerializationAction; begin if Assigned(ACollection) then begin try if Assigned(ASerializationAction) then begin lSerializationAction := procedure(const AObject: TObject; const Dict: IMVCLinks) begin ASerializationAction(T(AObject), Dict); end; end else begin lSerializationAction := nil; end; Render(Serializer(GetContentType).SerializeCollection(ACollection, AType, [], lSerializationAction)); finally if AOwns then ACollection.Free; end; end else raise EMVCException.Create('Can not render an empty collection.'); end; procedure TMVCRenderer.Render(const AStatusCode: Integer; var ARecord: T); begin SetStatusCode(AStatusCode); Render( Serializer(GetContentType) .SerializeRecord(@ARecord, TypeInfo(T), TMVCSerializationType.stFields,nil,nil)); end; procedure TMVCRenderer.Render(const AStatusCode: Integer; const ACollection: TObjectList; const AOwns: Boolean; const ASerializationAction: TMVCSerializationAction); begin SetStatusCode(AStatusCode); Render(ACollection, AOwns, ASerializationAction); end; function TMVCController.GetRenderedView(const AViewNames: TArray): string; var lView: TMVCBaseViewEngine; lViewName: string; lStrStream: TStringStream; begin lStrStream := TStringStream.Create('', TEncoding.UTF8); try lView := FEngine.ViewEngineClass.Create( Engine, Context, FViewModel, FViewDataSets, ContentType); try for lViewName in AViewNames do begin lView.Execute(lViewName, lStrStream); end; finally lView.Free; end; lStrStream.Position := 0; Result := lStrStream.DataString; finally lStrStream.Free; end; end; procedure TMVCRenderer.Render(const ACollection: TObjectList; const ASerializationAction: TMVCSerializationAction); begin Self.Render(ACollection, True, ASerializationAction); end; procedure TMVCRenderer.RenderResponseStream; begin Render(ResponseStream.ToString); end; procedure TMVCRenderer.RenderSSE(const EventID, EventData: string; EventName: string; const Retry: Integer); begin // setting up the correct SSE headers SetContentType('text/event-stream'); GetContext.Response.SetCustomHeader('Cache-Control', 'no-cache'); GetContext.Response.StatusCode := http_status.OK; // render the response using SSE compliant data format // current event id (the client will resend this number at the next request) ResponseStream.Append(Format('id: %s'#13, [EventID])); // The browser attempts to reconnect to the source roughly 3 seconds after // each connection is closed. You can change that timeout by including a line // beginning with "retry:", followed by the number of milliseconds to wait // before trying to reconnect. if Retry > -1 then begin ResponseStream.Append(Format('retry: %d'#13, [Retry])); end; if not EventName.IsEmpty then begin ResponseStream.Append(Format('event: %s'#13, [EventName])); end; // actual message ResponseStream.Append('data: ' + EventData + #13#13); // render all the stuff RenderResponseStream; end; procedure TMVCRenderer.Render(const ACollection: IMVCList); begin Render(ACollection, stDefault); end; procedure TMVCRenderer.Render(const ACollection: IMVCList; const AType: TMVCSerializationType); begin if Assigned(ACollection) then Render(Serializer(GetContentType).SerializeCollection(TObject(ACollection), AType)) else raise EMVCException.Create('Can not render an empty collection.'); end; procedure TMVCRenderer.Render(const ATextWriter: TTextWriter; const AOwns: Boolean); begin if Assigned(ATextWriter) then begin try Render(ATextWriter.ToString); finally if AOwns then ATextWriter.Free; end; end else raise EMVCException.Create('Can not render an empty textwriter.'); end; procedure TMVCRenderer.Render(const AException: Exception; AExceptionItems: TList; const AOwns: Boolean); var S: string; R: TMVCErrorResponse; I: TMVCErrorResponseItem; begin try if AException is EMVCException then ResponseStatus(EMVCException(AException).HTTPErrorCode, AException.Message + ' [' + AException.Classname + ']'); if (GetContext.Response.StatusCode = http_status.OK) then ResponseStatus(http_status.InternalServerError, AException.Message + ' [' + AException.Classname + ']'); // if (not GetContext.Request.IsAjax) and (GetContext.Request.ClientPrefer(TMVCMediaType.TEXT_HTML)) then // begin // SetContentType(TMVCMediaType.TEXT_HTML); // Render(AException, False); // exit; // ResponseStream.Clear; // ResponseStream.Append // ('') // .Append('

' + Config[TMVCConfigKey.ServerName] + ': Error Raised

') // .AppendFormat('
HTTP Return Code: %d' + sLineBreak,
    // [GetContext.Response.StatusCode]).AppendFormat('HTTP Reason Text: "%s"
', // [GetContext.Response.ReasonString]) // .Append('

').AppendFormat('Exception Class Name : %s' + sLineBreak, [AException.Classname])
    // .AppendFormat('Exception Message    : %s' + sLineBreak, [AException.Message]).Append('

'); // if Assigned(AExceptionItems) and (AExceptionItems.Count > 0) then // begin // ResponseStream.Append('

');
    // for S in AExceptionItems do
    // ResponseStream.AppendLine('- ' + S);
    // ResponseStream.Append('

'); // end // else // begin // ResponseStream.AppendLine('
No other information available
'); // end; // ResponseStream.Append(''); // RenderResponseStream; // end // else begin R := TMVCErrorResponse.Create; try R.StatusCode := GetContext.Response.StatusCode; R.ReasonString := HTTP_STATUS.ReasonStringFor(R.StatusCode); R.Message := AException.Message; R.Classname := AException.Classname; if AException is EMVCException then begin R.AppErrorCode := EMVCException(AException).ApplicationErrorCode; R.DetailedMessage := EMVCException(AException).DetailedMessage; for S in EMVCException(AException).ErrorItems do begin R.Items.Add(TMVCErrorResponseItem.Create(S)); end; end; if Assigned(AExceptionItems) and (AExceptionItems.Count > 0) then begin for S in AExceptionItems do begin I := TMVCErrorResponseItem.Create; I.Message := S; R.Items.Add(I); end; end; if Serializer(GetContentType, False) = nil then begin if Serializer(FContext.Request.BestAccept, False) <> nil then GetContext.Response.ContentType := FContext.Request.BestAccept else GetContext.Response.ContentType := GetConfig[TMVCConfigKey.DefaultContentType]; end; Render(R, False); finally R.Free; end; end; finally if AOwns then AExceptionItems.Free; end; end; procedure TMVCRenderer.Render(const AResponse: TMVCResponse; const AOwns: Boolean); begin if Assigned(AResponse) then begin try GetContext.Response.StatusCode := AResponse.StatusCode; GetContext.Response.ReasonString := HTTP_STATUS.ReasonStringFor(AResponse.StatusCode); Render(AResponse, False, stProperties); finally if AOwns then AResponse.Free; end; end else raise EMVCException.Create('Cannot render an empty response object.'); end; procedure TMVCRenderer.Render(const ADataSet: TDataSet; const ASerializationAction: TMVCDatasetSerializationAction); begin Render(ADataSet, True, ASerializationAction); end; procedure TMVCRenderer.Render( const ADataSet: TDataSet; const AOwns: Boolean; const ASerializationAction: TMVCDatasetSerializationAction); begin Render(ADataSet, AOwns, dstAllRecords, ASerializationAction); end; procedure TMVCRenderer.Render( const AObject: TObject; const ASerializationAction: TMVCSerializationAction = nil; const AIgnoredFields: TMVCIgnoredList = nil); begin Render(AObject, True, stDefault, ASerializationAction, AIgnoredFields); end; procedure TMVCRenderer.Render(const ADataSet: TDataSet; const AOwns: Boolean; const AIgnoredFields: TMVCIgnoredList; const ASerializationType: TMVCDatasetSerializationType; const ASerializationAction: TMVCDatasetSerializationAction); begin Render(ADataSet, AOwns, AIgnoredFields, ncLowerCase, ASerializationType, ASerializationAction); end; procedure TMVCRenderer.Render(const ADataSet: TDataSet; const AOwns: Boolean; const ASerializationType: TMVCDatasetSerializationType; const ASerializationAction: TMVCDatasetSerializationAction); begin Render(ADataSet, AOwns, [], ASerializationType, ASerializationAction); end; constructor TMVCResponse.Create; begin inherited Create; fDataObject := nil; end; constructor TMVCErrorResponse.Create; begin inherited Create; FItems := TObjectList.Create(True); end; constructor TMVCResponse.Create(AStatusCode: Integer; AReasonString, AMessage: string); begin Create; StatusCode := AStatusCode; ReasonString := AReasonString; message := AMessage; end; destructor TMVCResponse.Destroy; begin fDataObject.Free; inherited; end; destructor TMVCErrorResponse.Destroy; begin FItems.Free; inherited Destroy; end; procedure TMVCErrorResponse.SetAppErrorCode(const Value: Integer); begin FAppErrorCode := Value; end; { TMVCBaseView } constructor TMVCBaseViewEngine.Create(const AEngine: TMVCEngine; const AWebContext: TWebContext; const AViewModel: TMVCViewDataObject; const AViewDataSets: TObjectDictionary; const AContentType: string); begin inherited Create; Engine := AEngine; FWebContext := AWebContext; FViewModel := AViewModel; FViewDataSets := AViewDataSets; FContentType := AContentType; FOutput := EmptyStr; end; destructor TMVCBaseViewEngine.Destroy; begin inherited Destroy; end; function TMVCBaseViewEngine.GetRealFileName(const AViewName: string): string; var lFileName: string; lDefaultViewFileExtension: string; begin lDefaultViewFileExtension := Config[TMVCConfigKey.DefaultViewFileExtension]; lFileName := StringReplace(AViewName, '/', '\', [rfReplaceAll]); if (lFileName = '\') then begin lFileName := '\index.' + lDefaultViewFileExtension end else begin lFileName := lFileName + '.' + lDefaultViewFileExtension; end; if DirectoryExists(Config[TMVCConfigKey.ViewPath]) then begin lFileName := ExpandFileName(IncludeTrailingPathDelimiter(Config.Value[TMVCConfigKey.ViewPath]) + lFileName) end else begin lFileName := ExpandFileName(IncludeTrailingPathDelimiter(GetApplicationFileNamePath + Config.Value[TMVCConfigKey.ViewPath]) + lFileName); end; if FileExists(lFileName) then Result := lFileName else Result := EmptyStr; end; { MVCIntegerAttribute } constructor MVCIntegerAttribute.Create(const AValue: Int64); begin FValue := AValue; end; { MVCPathParamAttribute } constructor MVCPathParamAttribute.Create(AType: TSwagTypeParameter; APattern, AFormat: string); begin FType := AType; FValue := APattern; FFormat := AFormat; end; { MVCParamAttribute } constructor MVCParamAttribute.Create(name: string; Location: TSwagRequestParameterInLocation; AType: TSwagTypeParameter; APattern, AFormat: string); begin FName := name; FLocation := Location; FType := AType; FPattern := APattern; FFormat := AFormat; end; constructor MVCParamAttribute.Create(name: string; Location: TSwagRequestParameterInLocation; AType: TClass; APattern, AFormat: string); begin FName := name; FLocation := Location; FClassType := AType; FPattern := APattern; FFormat := AFormat; end; initialization // https://quality.embarcadero.com/browse/RSP-38281 TRttiContext.KeepContext; gIsShuttingDown := 0; gMVCGlobalActionParamsCache := TMVCStringObjectDictionary.Create; finalization FreeAndNil(gMVCGlobalActionParamsCache); // https://quality.embarcadero.com/browse/RSP-38281 TRttiContext.DropContext; end.