/* * inetprot.h * * Internet Protocol ancestor channel class * * Portable Windows Library * * Copyright (c) 1993-2002 Equivalence Pty. Ltd. * * The contents of this file are subject to the Mozilla Public License * Version 1.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.mozilla.org/MPL/ * * Software distributed under the License is distributed on an "AS IS" * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See * the License for the specific language governing rights and limitations * under the License. * * The Original Code is Portable Windows Library. * * The Initial Developer of the Original Code is Equivalence Pty. Ltd. * * Contributor(s): ______________________________________. * * $Log: inetprot.h,v $ * Revision 1.19 2005/11/30 12:47:37 csoutheren * Removed tabs, reformatted some code, and changed tags for Doxygen * * Revision 1.18 2004/11/11 07:34:50 csoutheren * Added #include * * Revision 1.17 2002/11/06 22:47:24 robertj * Fixed header comment (copyright etc) * * Revision 1.16 2002/09/16 01:08:59 robertj * Added #define so can select if #pragma interface/implementation is used on * platform basis (eg MacOS) rather than compiler, thanks Robert Monaghan. * * Revision 1.15 2001/09/26 09:37:04 robertj * Added virtual keyword to a lot of functions so can be overridden. * * Revision 1.14 1999/03/09 08:01:46 robertj * Changed comments for doc++ support (more to come). * * Revision 1.13 1999/02/16 08:07:10 robertj * MSVC 6.0 compatibility changes. * * Revision 1.12 1998/09/23 06:19:40 robertj * Added open source copyright license. * * Revision 1.11 1996/09/14 13:09:13 robertj * Major upgrade: * rearranged sockets to help support IPX. * added indirect channel class and moved all protocols to descend from it, * separating the protocol from the low level byte transport. * * Revision 1.10 1996/05/15 10:07:00 robertj * Added access function to set intercharacter line read timeout. * * Revision 1.9 1996/05/09 12:14:02 robertj * Rewrote the "unread" buffer usage and then used it to improve ReadLine() performance. * * Revision 1.8 1996/03/31 08:43:38 robertj * Added version of WriteCommand() and ExecteCommand() without argument string. * * Revision 1.7 1996/03/16 04:35:32 robertj * Added PString parameter version of UnRead(). * Changed lastResponseCode to an integer. * Added ParseReponse() for splitting reponse line into code and info. * * Revision 1.6 1996/02/13 12:57:05 robertj * Added access to the last response in an application socket. * * Revision 1.5 1996/02/03 11:33:16 robertj * Changed RadCmd() so can distinguish between I/O error and unknown command. * * Revision 1.4 1996/01/23 13:08:43 robertj * Major rewrite for HTTP support. * * Revision 1.3 1995/06/17 11:12:15 robertj * Documentation update. * * Revision 1.2 1995/06/17 00:39:53 robertj * More implementation. * * Revision 1.1 1995/06/04 13:17:16 robertj * Initial revision * */ #ifndef _PINTERNETPROTOCOL #define _PINTERNETPROTOCOL #ifdef P_USE_PRAGMA #pragma interface #endif #include class PSocket; class PIPSocket; /** A TCP/IP socket for process/application layer high level protocols. All of these protocols execute commands and responses in a standard manner. A command consists of a line starting with a short, case insensitive command string terminated by a space or the end of the line. This may be followed by optional arguments. A response to a command is usually a number and/or a short string eg "OK". The response may be followed by additional information about the response but this is not typically used by the protocol. It is only for user information and may be tracked in log files etc. All command and reponse lines of the protocol are terminated by a CR/LF pair. A command or response line may be followed by additional data as determined by the protocol, but this data is "outside" the protocol specification as defined by this class. The default read timeout is to 10 minutes by the constructor. */ class PInternetProtocol : public PIndirectChannel { PCLASSINFO(PInternetProtocol, PIndirectChannel) protected: PInternetProtocol( const char * defaultServiceName, ///< Service name for the protocol. PINDEX cmdCount, ///< Number of command strings. char const * const * cmdNames ///< Strings for each command. ); // Create an unopened TCP/IP protocol socket channel. public: // Overrides from class PChannel. /** Low level read from the channel. This override also supports the mechanism in the UnRead() function allowing characters to be be "put back" into the data stream. This allows a look-ahead required by the logic of some protocols. This is completely independent of the standard iostream mechanisms which do not support the level of timeout control required by the protocols. @return TRUE if at least len bytes were written to the channel. */ virtual BOOL Read( void * buf, ///< Pointer to a block of memory to receive the read bytes. PINDEX len ///< Maximum number of bytes to read into the buffer. ); /** Low level write to the channel. This override assures that the sequence CR/LF/./CR/LF does not occur by byte stuffing an extra '.' character into the data stream, whenever a line begins with a '.' character. Note that this only occurs if the member variable stuffingState has been set to some value other than DontStuff, usually StuffIdle. Also, if the newLineToCRLF member variable is TRUE then all occurrences of a '\n' character will be translated to a CR/LF pair. @return TRUE if at least len bytes were written to the channel. */ virtual BOOL Write( const void * buf, ///< Pointer to a block of memory to write. PINDEX len ///< Number of bytes to write. ); /** Set the maximum timeout between characters within a line. Default value is 10 seconds. */ void SetReadLineTimeout( const PTimeInterval & t ); // New functions for class. /** Connect a socket to a remote host for the internet protocol. @return TRUE if the channel was successfully connected to the remote host. */ virtual BOOL Connect( const PString & address, ///< Address of remote machine to connect to. WORD port = 0 ///< Port number to use for the connection. ); virtual BOOL Connect( const PString & address, ///< Address of remote machine to connect to. const PString & service ///< Service name to use for the connection. ); /** Accept a server socket to a remote host for the internet protocol. @return TRUE if the channel was successfully connected to the remote host. */ virtual BOOL Accept( PSocket & listener ///< Address of remote machine to connect to. ); /** Get the default service name or port number to use in socket connections. @return string for the default service name. */ const PString & GetDefaultService() const; /** Get the eventual socket for the series of indirect channels that may be between the current protocol and the actual I/O channel. This will assert if the I/O channel is not an IP socket. @return TRUE if the string and CR/LF were completely written. */ PIPSocket * GetSocket() const; /** Write a string to the socket channel followed by a CR/LF pair. If there are any lone CR or LF characters in the line parameter string, then these are translated into CR/LF pairs. @return TRUE if the string and CR/LF were completely written. */ virtual BOOL WriteLine( const PString & line ///< String to write as a command line. ); /** Read a string from the socket channel up to a CR/LF pair. If the unstuffLine parameter is set then the function will remove the '.' character from the start of any line that begins with two consecutive '.' characters. A line that has is exclusively a '.' character will make the function return FALSE. Note this function will block for the time specified by the PChannel::SetReadTimeout() function for only the first character in the line. The rest of the characters must each arrive within the time set by the readLineTimeout member variable. The timeout is set back to the original setting when the function returns. @return TRUE if a CR/LF pair was received, FALSE if a timeout or error occurred. */ virtual BOOL ReadLine( PString & line, ///< String to receive a CR/LF terminated line. BOOL allowContinuation = FALSE ///< Flag to handle continued lines. ); /** Put back the characters into the data stream so that the next Read() function call will return them first. */ virtual void UnRead( int ch ///< Individual character to be returned. ); virtual void UnRead( const PString & str ///< String to be put back into data stream. ); virtual void UnRead( const void * buffer, ///< Characters to be put back into data stream. PINDEX len ///< Number of characters to be returned. ); /** Write a single line for a command. The command name for the command number is output, then a space, the the param string followed at the end with a CR/LF pair. If the cmdNumber parameter is outside of the range of valid command names, then the function does not send anything and returns FALSE. This function is typically used by client forms of the socket. @return TRUE if the command was completely written. */ virtual BOOL WriteCommand( PINDEX cmdNumber ///< Number of command to write. ); virtual BOOL WriteCommand( PINDEX cmdNumber, ///< Number of command to write. const PString & param ///< Extra parameters required by the command. ); /** Read a single line of a command which ends with a CR/LF pair. The command number for the command name is parsed from the input, then the remaining text on the line is returned in the args parameter. If the command does not match any of the command names then the entire line is placed in the args parameter and a value of P_MAX_INDEX is returned. Note this function will block for the time specified by the PChannel::SetReadTimeout() function. This function is typically used by server forms of the socket. @return TRUE if something was read, otherwise an I/O error occurred. */ virtual BOOL ReadCommand( PINDEX & num, ///< Number of the command parsed from the command line, or P_MAX_INDEX ///< if no match. PString & args ///< String to receive the arguments to the command. ); /** Write a response code followed by a text string describing the response to a command. The form of the response is to place the code string, then the info string. If the info parameter has multiple lines then each line has the response code at the start. A '-' character separates the code from the text on all lines but the last where a ' ' character is used. The first form assumes that the response code is a 3 digit numerical code. The second form allows for any arbitrary string to be the code. This function is typically used by server forms of the socket. @return TRUE if the response was completely written. */ virtual BOOL WriteResponse( unsigned numericCode, ///< Response code for command response. const PString & info ///< Extra information available after response code. ); virtual BOOL WriteResponse( const PString & code, ///< Response code for command response. const PString & info ///< Extra information available after response code. ); /** Read a response code followed by a text string describing the response to a command. The form of the response is to have the code string, then the info string. The response may have multiple lines in it. A '-' character separates the code from the text on all lines but the last where a ' ' character is used. The info parameter will have placed in it all of the response lines separated by a single '\n' character. The first form places the response code and info into the protected member variables lastResponseCode and lastResponseInfo. This function is typically used by client forms of the socket. @return TRUE if the response was completely read without a socket error. */ virtual BOOL ReadResponse(); virtual BOOL ReadResponse( int & code, ///< Response code for command response. PString & info ///< Extra information available after response code. ); /** Write a command to the socket, using WriteCommand() and await a response using ReadResponse(). The first character of the response is returned, as well as the entire response being saved into the protected member variables lastResponseCode and lastResponseInfo. This function is typically used by client forms of the socket. @return First character of response string or '\0' if a socket error occurred. */ virtual int ExecuteCommand( PINDEX cmdNumber ///< Number of command to write. ); virtual int ExecuteCommand( PINDEX cmdNumber, ///< Number of command to write. const PString & param ///< Extra parameters required by the command. ); /** Return the code associated with the last response received by the socket. @return Response code */ int GetLastResponseCode() const; /** Return the last response received by the socket. @return Response as a string */ PString GetLastResponseInfo() const; protected: /** Parse a response line string into a response code and any extra info on the line. Results are placed into the member variables lastResponseCode and lastResponseInfo. The default bahaviour looks for a space or a '-' and splits the code and info either side of that character, then returns FALSE. @return Position of continuation character in response, 0 if no continuation lines are possible. */ virtual PINDEX ParseResponse( const PString & line ///< Input response line to be parsed ); PString defaultServiceName; // Default Service name to use for the internet protocol socket. PStringArray commandNames; // Names of each of the command codes. PCharArray unReadBuffer; // Buffer for characters put back into the data stream. PINDEX unReadCount; // Buffer count for characters put back into the data stream. PTimeInterval readLineTimeout; // Time for characters in a line to be received. enum StuffState { DontStuff, StuffIdle, StuffCR, StuffCRLF, StuffCRLFdot, StuffCRLFdotCR } stuffingState; // Do byte stuffing of '.' characters in output to the socket channel. BOOL newLineToCRLF; // Translate \n characters to CR/LF pairs. int lastResponseCode; PString lastResponseInfo; // Responses private: BOOL AttachSocket(PIPSocket * socket); }; #endif // End Of File ///////////////////////////////////////////////////////////////