httppars.cpp

著名的 helix realplayer 基于手机 symbian 系统的 播放器全套源代码

/* ***** BEGIN LICENSE BLOCK ***** 
 * Version: RCSL 1.0/RPSL 1.0 
 *  
 * Portions Copyright (c) 1995-2002 RealNetworks, Inc. All Rights Reserved. 
 *      
 * The contents of this file, and the files included with this file, are 
 * subject to the current version of the RealNetworks Public Source License 
 * Version 1.0 (the "RPSL") available at 
 * http://www.helixcommunity.org/content/rpsl unless you have licensed 
 * the file under the RealNetworks Community Source License Version 1.0 
 * (the "RCSL") available at http://www.helixcommunity.org/content/rcsl, 
 * in which case the RCSL will apply. You may also obtain the license terms 
 * directly from RealNetworks.  You may not use this file except in 
 * compliance with the RPSL or, if you have a valid RCSL with RealNetworks 
 * applicable to this file, the RCSL.  Please see the applicable RPSL or 
 * RCSL for the rights, obligations and limitations governing use of the 
 * contents of the file.  
 *  
 * This file is part of the Helix DNA Technology. RealNetworks is the 
 * developer of the Original Code and owns the copyrights in the portions 
 * it created. 
 *  
 * This file, and the files included with this file, is distributed and made 
 * available on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER 
 * EXPRESS OR IMPLIED, AND REALNETWORKS HEREBY DISCLAIMS ALL SUCH WARRANTIES, 
 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS 
 * FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. 
 * 
 * Technology Compatibility Kit Test Suite(s) Location: 
 *    http://www.helixcommunity.org/content/tck 
 * 
 * Contributor(s): 
 *  
 * ***** END LICENSE BLOCK ***** */ 

//#include "hlxclib/stdlib.h"

#include "hxcom.h"
#include "hxtypes.h"
#include "hxassert.h"
#include "debug.h"

#include "hxstrutl.h"
#include "hxstring.h"
#include "chxpckts.h"
#include "hxauth.h"

#include "httppars.h"
#include "httpmsg.h"

#include "hxheap.h"
#ifdef _DEBUG
#undef HX_THIS_FILE		
static const char HX_THIS_FILE[] = __FILE__;
#endif


HTTPParser::HTTPParser()
{
}

HTTPParser::~HTTPParser()
{
    clearMessageLines();
}

/*
 * Extract major/minor version info
 */
int 
HTTPParser::parseProtocolVersion(const CHXString& prot,
    int& majorVersion, int& minorVersion)
{
    if(strncasecmp(prot, "HTTP/", 5) != 0)
    	return 0;

    int nVerOffset = prot.Find('.');
    if(nVerOffset > 5)
    {
	CHXString majVersion = prot.Mid(5, nVerOffset-5);
	majorVersion = (int)strtol(majVersion, 0, 10);
	CHXString minVersion = prot.Mid(nVerOffset+1);
	minorVersion = (int)strtol(minVersion, 0, 10);
	return 1;
    }
    return 0;
}

/*
 * Parse option in form 'name[=value] *[;name[=value]]'
 */
int 
HTTPParser::parseHeaderValue(const char* pValue, MIMEHeader* pHeader)
{
    if(strlen(pValue) == 0)
	return 0;

    MIMEInputStream input(pValue, strlen(pValue));
    MIMEScanner scanner(input);

    MIMEHeaderValue* pHeaderValue = 0;

    MIMEToken tok = scanner.nextToken(";");
    while(tok.hasValue())
    {
	if(!pHeaderValue)
	{
	    CHXString attribute = tok.value();
	    pHeaderValue = new MIMEHeaderValue;
	    if(tok.lastChar() == '=')
	    {
		tok = scanner.nextToken(";");
		CHXString value = tok.value();
		pHeaderValue->addParameter(attribute, value);
	    }
	    else
	    {
		pHeaderValue->addParameter(attribute);
	    }
	}
	else if(tok.lastChar() == '=')
	{
	    CHXString attribute = tok.value();
	    tok = scanner.nextToken(";");
	    CHXString value = tok.value();
	    pHeaderValue->addParameter(attribute, value);
	}
	else
	{
	    CHXString attribute = tok.value();
	    pHeaderValue->addParameter(attribute, "");
	}
	tok = scanner.nextToken("=;");
    }
    if(pHeaderValue)
	pHeader->addHeaderValue(pHeaderValue);
    return 0;
}

int
HTTPParser::parseWWWAuthenticateHeaderValues(const char* pValue,
                                             MIMEHeader* pHeader)
{
    MIMEInputStream input(pValue, strlen(pValue));
    MIMEScanner scanner(input);
    IHXValues* authValues;

    /*
      char* pNonce = 0;
      char* pRealm = 0;
      char* pOpaque= 0;
      */

    MIMEToken nextTok = scanner.nextToken(" ");
    if(strcasecmp(nextTok.value(), "Digest") == 0)
    {
        authValues = new CHXHeader;
        authValues->AddRef();
        authValues->SetPropertyULONG32("AuthType", HX_AUTH_DIGEST);
        while(nextTok.hasValue())
        {
            nextTok = scanner.nextToken("=,");
            if(strcasecmp(nextTok.value(), "nonce") == 0)
            {
                nextTok = scanner.nextToken("=,");
		CHXBuffer* pBuf = new CHXBuffer;
		pBuf->AddRef();
		pBuf->Set((const BYTE*)(const char*)nextTok.value(),
		    nextTok.value().GetLength()+1);
                authValues->SetPropertyCString("Nonce", pBuf);
		pBuf->Release();
            }
            else if(strcasecmp(nextTok.value(), "realm") == 0)
            {
                nextTok = scanner.nextToken("=,");
		CHXBuffer* pBuf = new CHXBuffer;
		pBuf->AddRef();
		pBuf->Set((const BYTE*)(const char*)nextTok.value(),
		    nextTok.value().GetLength()+1);
                authValues->SetPropertyCString("Realm", pBuf);
		pBuf->Release();
            }
            else if(strcasecmp(nextTok.value(), "opaque") == 0)
            {
                nextTok = scanner.nextToken("=,");
		CHXBuffer* pBuf = new CHXBuffer;
		pBuf->AddRef();
		pBuf->Set((const BYTE*)(const char*)nextTok.value(),
		    nextTok.value().GetLength()+1);
                authValues->SetPropertyCString("Opaque", pBuf);
		pBuf->Release();
            }
        }
        pHeader->addHeaderValue
            (new HTTPAuthentication(authValues));
        authValues->Release();
    }
    else if(strcasecmp(nextTok.value(), "Basic") == 0)
    {
        authValues = new CHXHeader();
        authValues->AddRef();
        authValues->SetPropertyULONG32("AuthType", HX_AUTH_BASIC);
        while(nextTok.hasValue())
        {
            nextTok = scanner.nextToken("=,");
            if(strcasecmp(nextTok.value(), "realm") == 0)
            {
                nextTok = scanner.nextToken("=,");
                char * realmstr = new char[strlen(nextTok.value()) + 1];
                char* valstart, *valend;
                valstart = (char*)strchr(nextTok.value(), '\"');
                valend = (char*)strrchr(nextTok.value(), '\"');
                if(valstart && valend && valstart != valend)
                {
                    valstart++;
                    memcpy(realmstr, valstart, valend - valstart);
                    realmstr[valend - valstart] = 0;
                }
                else
                {
                    strcpy(realmstr, nextTok.value());
                }
		CHXBuffer* pBuf = new CHXBuffer;
		pBuf->AddRef();
		pBuf->Set((const BYTE*)realmstr, strlen(realmstr)+1);
                authValues->SetPropertyCString("Realm", pBuf);
		pBuf->Release();
                delete [] realmstr;
            }
        }
        pHeader->addHeaderValue(new HTTPAuthentication(authValues));
        authValues->Release();
    }
    else
    {
	// Just add un-parsed value
        pHeader->addHeaderValue(pValue);
    }
    return 0;
}

/*
 * Parse header values as list of comma separated values
 */
int 
HTTPParser::defaultParseHeaderValues(const char* pValue, MIMEHeader* pHeader)
{
    MIMEInputStream input(pValue, strlen(pValue));
    MIMEScanner scanner(input);
    
    MIMEToken nextTok = scanner.nextToken(",");
    while(nextTok.hasValue())
    {
	parseHeaderValue(nextTok.value(), pHeader);
	if((nextTok.lastChar() == MIMEToken::T_EOL) ||
	   (nextTok.lastChar() == MIMEToken::T_EOF))
	    return 0;
	nextTok = scanner.nextToken(",");
    }
    return 0;
}

/*
 * construct an MIMEHeader and add header values to it
 * format: 'HeaderName: option, option=value, option'
 */
MIMEHeader* 
HTTPParser::parseHeader(CHXString& str)
{
    MIMEHeader* pHeader = 0;
    MIMEInputStream input(str);
    MIMEScanner scanner(input);
    MIMEToken nextTok = scanner.nextToken(":");

    if(nextTok.hasValue())
    {
	pHeader = new MIMEHeader(nextTok.value());
	nextTok = scanner.nextToken("\n");
	if(strcasecmp(pHeader->name(), "WWW-Authenticate") == 0)
	{
	    parseWWWAuthenticateHeaderValues(nextTok.value(), pHeader);
	}
	else
	{
	    defaultParseHeaderValues(nextTok.value(), pHeader);
	}
    }
    return pHeader;
}

/*
 * Parse request line in format 'METHOD URL VERSION SEQ_NO'
 */
HTTPRequestMessage*
HTTPParser::parseRequestLine(CHXString& str)
{
    int majorVersion, minorVersion;
    HTTPRequestMessage* pReqMsg = 0;
    MIMEInputStream input(str);
    MIMEScanner scanner(input);

    // build message
    MIMEToken nextTok = scanner.nextToken();

    if(strcasecmp(nextTok.value(), "GET") == 0)
    {
	pReqMsg = new HTTPGetMessage;
    }
    else if(strcasecmp(nextTok.value(), "HEAD") == 0)
    {
	pReqMsg = new HTTPHeadMessage;
    }
    else if(strcasecmp(nextTok.value(), "POST") == 0)
    {
	pReqMsg = new HTTPPostMessage;
    }
    else
    {
	pReqMsg = new HTTPUnknownMessage;
    }

    // get URL
    nextTok = scanner.nextToken("\t \n");
    pReqMsg->setURL(nextTok.value());

    // get version info
    nextTok = scanner.nextToken();
    if(parseProtocolVersion(nextTok.value(), majorVersion, minorVersion))
    {
	pReqMsg->setVersion(majorVersion, minorVersion);
    }
    else
    {
	pReqMsg->setVersion(0,0);
    }
    return pReqMsg;
}

/*
 * Parse response line in format 'VERSION ERR_CODE SEQ_NO ERR_MSG'
 */
HTTPResponseMessage*
HTTPParser::parseResponseLine(CHXString& str)
{
    int majorVersion, minorVersion;
    HTTPResponseMessage* pRespMsg = 0;

    MIMEInputStream input(str);
    MIMEScanner scanner(input);

    MIMEToken nextTok = scanner.nextToken();

    pRespMsg = new HTTPResponseMessage;
    if(parseProtocolVersion(nextTok.value(), 
	majorVersion, minorVersion))
    {
	pRespMsg->setVersion(majorVersion, minorVersion);
    }
    else
    {
	pRespMsg->setVersion(0,0);
    }

    // get error code
    nextTok = scanner.nextToken();
    pRespMsg->setErrorCode(nextTok.value());

    // get error message
    nextTok = scanner.nextToken("\n");	// go to EOL
    pRespMsg->setErrorMsg(nextTok.value());

    return pRespMsg;
}

/*
 * Parse response message
 */
HTTPMessage* 
HTTPParser::parseResponse()
{
    HTTPResponseMessage* pRespMsg = 0;
    
    LISTPOSITION pos = m_msglines.GetHeadPosition();
    CHXString* pStr = (CHXString*)m_msglines.GetNext(pos);
    pRespMsg = parseResponseLine(*pStr);
    if(!pRespMsg)
	return 0;
    while(pos)
    {
	pStr = (CHXString*)m_msglines.GetNext(pos);
	MIMEHeader* pHeader = parseHeader(*pStr);
	if(pHeader)
	    pRespMsg->addHeader(pHeader);
    }
    return pRespMsg;
}

/*
 * Parse request message
 */
HTTPMessage* 
HTTPParser::parseRequest()
{
    HTTPRequestMessage* pReqMsg = 0;
    
    LISTPOSITION pos = m_msglines.GetHeadPosition();
    CHXString* pStr = (CHXString*)m_msglines.GetNext(pos);
    pReqMsg = parseRequestLine(*pStr);
    if(!pReqMsg)
	return 0;

    if(pReqMsg->majorVersion() < 0)
	return pReqMsg;

    while(pos)
    {
	pStr = (CHXString*)m_msglines.GetNext(pos);
	MIMEHeader* pHeader = parseHeader(*pStr);
	if(pHeader)
	    pReqMsg->addHeader(pHeader);
    }
    return pReqMsg;
}

/*
 * Add each line in message to list m_msglines.
 * Look for two carriage returns to delimit
 * message header.
 */
int 
HTTPParser::scanMessageHeader(const char* pMsg, UINT32 nMsgLen)
{
    // first, get rid of any leading whitespace and <CR><LF> chars

    const char* pCh = pMsg;
    while(*pCh == '\n' || *pCh == '\r' || *pCh == ' ' || *pCh == '\t')
    {
	pCh++;
    }
    UINT32 offset = pCh - pMsg;
    if(offset > nMsgLen)
    {
	return 0;
    }

    MIMEInputStream input(pMsg, nMsgLen - offset);
    MIMEScanner scanner(input);

    MIMEToken tok;
    int gotEOL = 0;
    UINT32 scanOffset = 0;
    do
    {
	tok = scanner.nextToken("\n");
	m_msglines.AddTail((void*)(new CHXString((const char*)tok.value())));
	if(tok.lastChar() == MIMEToken::T_EOL)
	{
	    if(gotEOL && !tok.hasValue())
	    {
		scanOffset = scanner.offset();
		break;
	    }
	    else
	    {
		gotEOL = 1;
	    }
	}
	else
	{
	    gotEOL = 0;
	}
    } while(tok.lastChar() != MIMEToken::T_EOF);

    if(scanOffset == 0)
    {
	return 0;
    }
    else
    {
	return HX_SAFEINT(scanOffset + offset);
    }
}

/*
 * Parse message pointed to by pMsg with length nMsgLen.
 * If not a complete message, return 0, otherwise return
 * HTTPMessage pointer.
 */
HTTPMessage* 
HTTPParser::parse(const char* pMsg, UINT32& nMsgLen)
{
    HTTPMessage* pHTTPMsg = 0;
    clearMessageLines();
    int msgOffset = scanMessageHeader(pMsg, nMsgLen);
    if(msgOffset > 0)
    {
	if(m_msglines.GetCount() == 0)
	{
	    nMsgLen = 0;
	    return 0;
	}
	CHXString* str = (CHXString*)m_msglines.GetHead();
	if(strncasecmp((*str), "HTTP/", 5) == 0)
	{
	    pHTTPMsg = parseResponse();
	}
	else 
	{
	    pHTTPMsg = parseRequest();
	}

	if(pHTTPMsg)
	{
	    nMsgLen = msgOffset;
	}
    }
    else
    {
	//nMsgLen = 0;

	/* Might be a HTTP/0.9 request.  No extra blank line. Drat. */
	if(m_msglines.GetCount() == 0)
	{
	    nMsgLen = 0;
	    return 0;
	}
	CHXString* str = (CHXString*)m_msglines.GetHead();
	pHTTPMsg = parseRequest();
	if(!pHTTPMsg || pHTTPMsg->majorVersion() > 0)
	{
	    nMsgLen = 0;
	    delete pHTTPMsg;
	    pHTTPMsg = 0;
	}
    }
    return pHTTPMsg;
}

/*
 * Delete contents of m_msglines
 */
void 
HTTPParser::clearMessageLines()
{
    LISTPOSITION pos = m_msglines.GetHeadPosition();
    while(pos)
    {
	CHXString* str = (CHXString*)m_msglines.GetNext(pos);
	delete str;
    }
    m_msglines.RemoveAll();
}