Return to Unit Reference
Description
Ultibo POP3 interface unit
To be documented
Constants
[Expand]
POP3 specific constants POP3_*
POP3_LINE_END = Chr(13) + Chr(10);
|
CR LF
|
|
|
POP3_BUFFER_SIZE = SIZE_4K;
|
|
[Expand]
POP3 status POP3_STATUS_*
POP3_STATUS_NONE = 0;
|
|
POP3_STATUS_CONN = 1;
|
|
POP3_STATUS_USER = 2;
|
|
POP3_STATUS_PASS = 3;
|
|
POP3_STATUS_APOP = 4;
|
|
POP3_STATUS_DATA = 5;
|
|
POP3_STATUS_QUIT = 6;
|
|
|
|
POP3_MAX_STATUS = 6;
|
|
[Expand]
POP3 command POP3_COMMAND_*
POP3_COMMAND_STAT = 'STAT';
|
|
POP3_COMMAND_LIST = 'LIST';
|
|
POP3_COMMAND_RETR = 'RETR';
|
|
POP3_COMMAND_DELE = 'DELE';
|
|
POP3_COMMAND_NOOP = 'NOOP';
|
|
POP3_COMMAND_RSET = 'RSET';
|
|
POP3_COMMAND_QUIT = 'QUIT';
|
|
|
|
POP3_COMMAND_TOP = 'TOP';
|
|
POP3_COMMAND_UIDL = 'UIDL';
|
|
POP3_COMMAND_USER = 'USER';
|
|
POP3_COMMAND_PASS = 'PASS';
|
|
POP3_COMMAND_APOP = 'APOP';
|
|
[Expand]
POP3 string POP3_STRING_*
POP3_STRING_SUCCESS = '+OK ';
|
|
POP3_STRING_FAILURE = '-ERR ';
|
|
POP3_STRING_COMPLETE = '.';
|
|
|
|
POP3_STRING_SIGNON = 'Ultibo POP3 server (version ' + ULTIBO_RELEASE_VERSION + ')';
|
|
POP3_STRING_SIGNOFF = 'Ultibo POP3 server closing connection';
|
|
POP3_STRING_EMPTY_STAT = '0 0';
|
|
POP3_STRING_EMPTY_LIST = '0 messages (0 octets)';
|
|
POP3_STRING_BAD_COMMAND = 'Bad command';
|
|
POP3_STRING_BAD_MESSAGE = 'No such message';
|
|
POP3_STRING_BAD_USERNAME = 'Invalid username or password';
|
|
POP3_STRING_BAD_PASSWORD = 'Invalid username or password';
|
|
POP3_STRING_NO_PERMISSION = 'Permission denied';
|
|
[Expand]
POP3 logging POP3_LOG_*
POP3_LOG_LEVEL_DEBUG = LOG_LEVEL_DEBUG;
|
POP3 debugging messages
|
POP3_LOG_LEVEL_INFO = LOG_LEVEL_INFO;
|
POP3 informational messages
|
POP3_LOG_LEVEL_ERROR = LOG_LEVEL_ERROR;
|
POP3 error messages
|
POP3_LOG_LEVEL_NONE = LOG_LEVEL_NONE;
|
No POP3 messages
|
Type definitions
POP3 client notify event
TPOP3ClientNotifyEvent = procedure(const ARequest:String) of Object;
|
|
POP3 host event
TPOP3HostEvent = function(AConnection:TPOP3Connection):Boolean of Object;
|
|
POP3 count event
TPOP3CountEvent = function(AConnection:TPOP3Connection):Boolean of Object;
|
|
POP3 notify event
TPOP3NotifyEvent = procedure(AConnection:TPOP3Connection; const ARequest:String) of Object;
|
|
POP3 request event
TPOP3RequestEvent = function(AConnection:TPOP3Connection; const ARequest:String; var AReply:String):Boolean of Object;
|
|
POP3 request extended event
TPOP3RequestExEvent = function(AConnection:TPOP3Connection; const ARequest,AData:String; var AReply:String):Boolean of Object;
|
|
POP3 connection event
TPOP3ConnectionEvent = procedure(AConnection:TPOP3Connection) of Object;
|
|
Class definitions
POP3 buffer
[Expand]
TPOP3Buffer = class(TObject)
public
|
constructor Create(ASize:LongWord);
|
|
destructor Destroy; override;
|
|
private
|
FLock:TCriticalSectionHandle;
|
|
|
|
FData:Pointer;
|
|
FSize:LongWord;
|
|
FCount:LongWord;
|
|
FStart:LongWord;
|
|
|
|
function AcquireLock:Boolean;
|
|
function ReleaseLock:Boolean;
|
|
|
|
function GetCount:LongWord;
|
|
public
|
property Count:LongWord read GetCount;
|
|
|
|
function ReadData:Char;
|
|
function WriteData(AChar:Char):Boolean;
|
|
|
|
function WriteLock(var ASize:LongWord):Pointer;
|
|
function WriteUnlock(ACount:LongWord):Boolean;
|
|
POP3 client
[Expand]
TPOP3Client = class(TWinsock2TCPClient)
public
|
constructor Create;
|
|
destructor Destroy; override;
|
|
private
|
FOnRequest:TPOP3ClientNotifyEvent;
|
|
FOnReply:TPOP3ClientNotifyEvent;
|
|
|
|
FOnRequestStart:TNotifyEvent;
|
|
FOnRequestEnd:TNotifyEvent;
|
|
|
|
FBuffer:TPOP3Buffer;
|
Buffer for received data
|
protected
|
function GetReply(var AReply:String):Boolean;
|
|
function SendRequest(const ARequest:String):Boolean;
|
|
public
|
property OnRequest:TPOP3ClientNotifyEvent read FOnRequest write FOnRequest;
|
|
property OnReply:TPOP3ClientNotifyEvent read FOnReply write FOnReply;
|
|
|
|
property OnRequestStart:TNotifyEvent read FOnRequestStart write FOnRequestStart;
|
|
property OnRequestEnd:TNotifyEvent read FOnRequestEnd write FOnRequestEnd;
|
|
|
|
property Buffer:TPOP3Buffer read FBuffer;
|
|
|
|
function DoConn(const AHost,APort:String; var AReply:String):Boolean;
|
|
function DoStat(var AReply:String):Boolean;
|
|
function DoList(const AMessage:String; var AReply:String):Boolean;
|
|
function DoRetr(const AMessage:String; var AReply:String):Boolean;
|
|
function DoDele(const AMessage:String; var AReply:String):Boolean;
|
|
function DoNoop(var AReply:String):Boolean;
|
|
function DoRset(var AReply:String):Boolean;
|
|
function DoQuit(var AReply:String):Boolean;
|
|
|
|
function DoTop(const AMessage,ACount:String; var AReply:String):Boolean;
|
|
function DoUidl(const AMessage:String; var AReply:String):Boolean;
|
|
function DoUser(const AUsername:String; var AReply:String):Boolean;
|
|
function DoPass(const APassword:String; var AReply:String):Boolean;
|
|
function DoApop(const AUsername,ADigest:String; var AReply:String):Boolean;
|
|
POP3 connection
[Expand]
TPOP3Connection = class(TListObject)
public
|
constructor Create;
|
|
destructor Destroy; override;
|
|
private
|
FLock:TCriticalSectionHandle;
|
|
|
|
FHandle:LongWord;
|
|
FRxByteCount:Int64;
|
Bytes Recv Count from Connection
|
FTxByteCount:Int64;
|
Bytes Sent Count to Connection
|
FRequestCount:Int64;
|
Requests Recv Count from Connection
|
FReplyCount:Int64;
|
Replies Sent Count to Connection
|
FRequestTime:TDateTime;
|
Last Request Time
|
FReplyTime:TDateTime;
|
Last Reply Time
|
FRemoteAddress:String;
|
Address of Remote Client
|
FStatus:LongWord;
|
None,Conn,User,Data etc
|
FUsername:String;
|
Current Username
|
FPassword:String;
|
Current Password
|
FTimestamp:String;
|
Timestamp for APOP authentication
|
|
|
FThread:TThread;
|
TWinsock2TCPServerThread
|
FBuffer:TPOP3Buffer;
|
Buffer for received data
|
|
|
function AcquireLock:Boolean;
|
|
function ReleaseLock:Boolean;
|
|
|
|
procedure SetHandle(AHandle:LongWord);
|
|
function GetRxByteCount:Int64;
|
|
procedure SetRxByteCount(const ARxByteCount:Int64);
|
|
function GetTxByteCount:Int64;
|
|
procedure SetTxByteCount(const ATxByteCount:Int64);
|
|
function GetRequestCount:Int64;
|
|
procedure SetRequestCount(const ARequestCount:Int64);
|
|
function GetReplyCount:Int64;
|
|
procedure SetReplyCount(const AReplyCount:Int64);
|
|
function GetRequestTime:TDateTime;
|
|
procedure SetRequestTime(const ARequestTime:TDateTime);
|
|
function GetReplyTime:TDateTime;
|
|
procedure SetReplyTime(const AReplyTime:TDateTime);
|
|
function GetRemoteAddress:String;
|
|
procedure SetRemoteAddress(const ARemoteAddress:String);
|
|
procedure SetStatus(AStatus:LongWord);
|
|
function GetUsername:String;
|
|
procedure SetUsername(const AUsername:String);
|
|
function GetPassword:String;
|
|
procedure SetPassword(const APassword:String);
|
|
function GetTimestamp:String;
|
|
procedure SetTimestamp(const ATimestamp:String);
|
|
|
|
procedure SetThread(AThread:TThread);
|
|
public
|
property Handle:LongWord read FHandle write SetHandle;
|
|
property RxByteCount:Int64 read GetRxByteCount write SetRxByteCount;
|
|
property TxByteCount:Int64 read GetTxByteCount write SetTxByteCount;
|
|
property RequestCount:Int64 read GetRequestCount write SetRequestCount;
|
|
property ReplyCount:Int64 read GetReplyCount write SetReplyCount;
|
|
property RequestTime:TDateTime read GetRequestTime write SetRequestTime;
|
|
property ReplyTime:TDateTime read GetReplyTime write SetReplyTime;
|
|
property RemoteAddress:String read GetRemoteAddress write SetRemoteAddress;
|
|
property Status:LongWord read FStatus write SetStatus;
|
|
property Username:String read GetUsername write SetUsername;
|
|
property Password:String read GetPassword write SetPassword;
|
|
property Timestamp:String read GetTimestamp write SetTimestamp;
|
|
|
|
property Thread:TThread read FThread write SetThread;
|
|
property Buffer:TPOP3Buffer read FBuffer;
|
|
|
|
procedure IncrementRxByteCount(const ARxByteCount:Int64);
|
|
procedure IncrementTxByteCount(const ATxByteCount:Int64);
|
|
procedure IncrementRequestCount;
|
|
procedure IncrementReplyCount;
|
|
POP3 listener
[Expand]
TPOP3Listener = class(TWinsock2TCPListener)
public
|
constructor Create;
|
|
private
|
FOnConnected:TPOP3ConnectionEvent;
|
|
FOnDisconnected:TPOP3ConnectionEvent;
|
|
|
|
FOnCheckHost:TPOP3HostEvent;
|
|
FOnCheckCount:TPOP3CountEvent;
|
|
|
|
FOnRequest:TPOP3NotifyEvent;
|
|
FOnReply:TPOP3NotifyEvent;
|
|
|
|
FOnConn:TPOP3RequestEvent;
|
|
FOnStat:TPOP3RequestEvent;
|
|
FOnList:TPOP3RequestEvent;
|
|
FOnRetr:TPOP3RequestEvent;
|
|
FOnDele:TPOP3RequestEvent;
|
|
FOnNoop:TPOP3RequestEvent;
|
|
FOnRset:TPOP3RequestEvent;
|
|
FOnQuit:TPOP3RequestEvent;
|
|
|
|
FOnTop:TPOP3RequestExEvent;
|
|
FOnUidl:TPOP3RequestEvent;
|
|
FOnUser:TPOP3RequestEvent;
|
|
FOnPass:TPOP3RequestEvent;
|
|
FOnApop:TPOP3RequestExEvent;
|
|
protected
|
procedure DoConnect(AThread:TWinsock2TCPServerThread); override;
|
|
procedure DoDisconnect(AThread:TWinsock2TCPServerThread); override;
|
|
|
|
function DoCheckHost(AThread:TWinsock2TCPServerThread):Boolean; virtual;
|
|
function DoCheckCount(AThread:TWinsock2TCPServerThread):Boolean; virtual;
|
|
|
|
function DoExecute(AThread:TWinsock2TCPServerThread):Boolean; override;
|
|
|
|
procedure DoConn(AThread:TWinsock2TCPServerThread);
|
|
procedure DoStat(AThread:TWinsock2TCPServerThread);
|
|
procedure DoList(AThread:TWinsock2TCPServerThread; const AMessage:String);
|
|
procedure DoRetr(AThread:TWinsock2TCPServerThread; const AMessage:String);
|
|
procedure DoDele(AThread:TWinsock2TCPServerThread; const AMessage:String);
|
|
procedure DoNoop(AThread:TWinsock2TCPServerThread);
|
|
procedure DoRset(AThread:TWinsock2TCPServerThread);
|
|
procedure DoQuit(AThread:TWinsock2TCPServerThread);
|
|
|
|
procedure DoTop(AThread:TWinsock2TCPServerThread; const AMessage,ACount:String);
|
|
procedure DoUidl(AThread:TWinsock2TCPServerThread; const AMessage:String);
|
|
procedure DoUser(AThread:TWinsock2TCPServerThread; const AUsername:String);
|
|
procedure DoPass(AThread:TWinsock2TCPServerThread; const APassword:String);
|
|
procedure DoApop(AThread:TWinsock2TCPServerThread; const AUsername,ADigest:String);
|
|
|
|
function GetRequest(AThread:TWinsock2TCPServerThread; var ARequest:String):Boolean;
|
|
function SendReply(AThread:TWinsock2TCPServerThread; const AReply:String):Boolean;
|
|
public
|
property OnConnected:TPOP3ConnectionEvent read FOnConnected write FOnConnected;
|
|
property OnDisconnected:TPOP3ConnectionEvent read FOnDisconnected write FOnDisconnected;
|
|
|
|
property OnCheckHost:TPOP3HostEvent read FOnCheckHost write FOnCheckHost;
|
|
property OnCheckCount:TPOP3CountEvent read FOnCheckCount write FOnCheckCount;
|
|
|
|
property OnRequest:TPOP3NotifyEvent read FOnRequest write FOnRequest;
|
|
property OnReply:TPOP3NotifyEvent read FOnReply write FOnReply;
|
|
|
|
property OnConn:TPOP3RequestEvent read FOnConn write FOnConn;
|
|
property OnStat:TPOP3RequestEvent read FOnStat write FOnStat;
|
|
property OnList:TPOP3RequestEvent read FOnList write FOnList;
|
|
property OnRetr:TPOP3RequestEvent read FOnRetr write FOnRetr;
|
|
property OnDele:TPOP3RequestEvent read FOnDele write FOnDele;
|
|
property OnNoop:TPOP3RequestEvent read FOnNoop write FOnNoop;
|
|
property OnRset:TPOP3RequestEvent read FOnRset write FOnRset;
|
|
property OnQuit:TPOP3RequestEvent read FOnQuit write FOnQuit;
|
|
|
|
property OnTop:TPOP3RequestExEvent read FOnTop write FOnTop;
|
|
property OnUidl:TPOP3RequestEvent read FOnUidl write FOnUidl;
|
|
property OnUser:TPOP3RequestEvent read FOnUser write FOnUser;
|
|
property OnPass:TPOP3RequestEvent read FOnPass write FOnPass;
|
|
property OnApop:TPOP3RequestExEvent read FOnApop write FOnApop;
|
|
Public variables
POP3 logging
POP3_DEFAULT_LOG_LEVEL:LongWord = POP3_LOG_LEVEL_DEBUG;
|
Minimum level for POP3 messages. Only messages with level greater than or equal to this will be printed.
|
POP3_LOG_ENABLED:Boolean;
|
|
Function declarations
Initialization functions
[Expand]
procedure POP3Init;
Description: To be documented
POP3 helper functions
[Expand]
procedure POP3Log(Level:LongWord; const AText:String);
Description: To be documented
[Expand]
procedure POP3LogInfo(const AText:String);
Description: To be documented
[Expand]
procedure POP3LogError(const AText:String);
Description: To be documented
[Expand]
procedure POP3LogDebug(const AText:String);
Description: To be documented
Return to Unit Reference
