csstream.c

www工具包. 这是W3C官方支持的www支撑库. 其中提供通用目的的客户端的WebAPI: complete HTTP/1.1 (with caching, pipelining, PUT, POS

/*								      CSParse.c
**	PICS CONFIGURATION MANAGER FOR CLIENTS AND SERVERS
**
**	(c) COPYRIGHT MIT 1995.
**	Please first read the full copyright statement in the file COPYRIGHT.
**
**	This module converts application/xpics streams (files or network) to PICS_ class data
**
** History:
**	 4 Dec 95  EGP  start
**
** BUGS: no code yet; doesn't actually do anything
*/

/* Library include files */
#include "WWWLib.h"
#include "HTProxy.h"
#include "CSLUtils.h"
#include "CSMR.h"
#include "CSUser.h"
#include "CSLL.h"
#include "CSLApp.h"
#include "CSParse.h"

struct _HTStream {
    const HTStreamClass * isa;
    HTRequest *		  request;
    HTStream *		  target;
    CSParse_t *		  pCSParse;
};

PRIVATE int CSParse_put_block (HTStream * me, const char * b, int l)
{
    if (PICS_TRACE) {
        char * ptr;
	if ((ptr = (char *) HT_MALLOC(l+1)) == NULL)
	    HT_OUTOFMEM("diagnostic buffer");
	strncpy(ptr, b, l);
	ptr[l] = 0;
	HTTRACE(PICS_TRACE, "PICS: parser %p parsing block \"%s\"\n" _ me->pCSParse _ ptr);
	HT_FREE(ptr);
    }
    if (CSParse_parseChunk(me->pCSParse, b, l, 0) == CSDoMore_error)
        return HT_ERROR;
    return HT_OK;
}

PRIVATE int CSParse_put_character (HTStream * me, char c)
{
    return CSParse_put_block(me, &c, 1);
}

PRIVATE int CSParse_put_string (HTStream * me, const char * s)
{
    return CSParse_put_block(me, s, (int) strlen(s));
}

PRIVATE int CSParse_flush (HTStream * me)
{
    return (*me->target->isa->flush)(me->target);
}

PRIVATE int CSParse_free (HTStream * me)
{
    int status = HT_OK;
    if (me->target) {
	if ((status = (*me->target->isa->_free)(me->target)) == HT_WOULD_BLOCK)
	    return HT_WOULD_BLOCK;
    }
    HTTRACE(APP_TRACE, "Parser....... FREEING....\n");
    HTTRACE(PICS_TRACE, "PICS: freeing parser %p.\n" _ me->pCSParse);
    CSParse_delete(me->pCSParse);
    return status;
}
#if 0
PRIVATE int CSParse_abort (HTStream * me, HTList * e)
{
    int status = HT_ERROR;
    if (me->target) status = (*me->target->isa->abort)(me->target, e);
    HTTRACE(APP_TRACE, "Rules....... ABORTING...\n");
    HT_FREE(me);
    return status;
}

PRIVATE const HTStreamClass CSParseClass =
{		
    "PICSParser",
    CSParse_flush,
    CSParse_free,
    CSParse_abort,
    CSParse_put_character,
    CSParse_put_string,
    CSParse_put_block
};
#endif
PRIVATE HTStream * CSParseConverter_new (HTRequest *	request,
			                             HTStream *	output_stream)
{
    HTStream * me;
    if ((me = (HTStream *) HT_CALLOC(1, sizeof(HTStream))) == NULL)
        HT_OUTOFMEM("CSParse");
    me->request = request;
    me->target = output_stream;
    return me;
}

PRIVATE int CSParseMachRead_free (HTStream * me)
{
    int status = CSParse_free(me);
    CSParse_deleteMachRead(me->pCSParse);
    return status;
}

PRIVATE int CSParseMachRead_abort (HTStream * me, HTList * e)
{
    int status = CSParse_free(me);
        CSParse_deleteMachRead(me->pCSParse);
    return status;
}

PRIVATE const HTStreamClass CSParseClass_machRead =
{		
    "PICSParser",
    CSParse_flush,
    CSParseMachRead_free,
    CSParseMachRead_abort,
    CSParse_put_character,
    CSParse_put_string,
    CSParse_put_block
};

PUBLIC HTStream * CSParseMachRead (HTRequest *	request,
				   void *	param,
				   HTFormat  	input_format,
				   HTFormat     output_format,
				   HTStream *	output_stream)
{
    HTStream * me = CSParseConverter_new(request, output_stream);
    me->isa = &CSParseClass_machRead;
    me->pCSParse = CSParse_newMachRead(0, 0);
    HTTRACE(PICS_TRACE, "PICS: creating MachRead parser %p.\n" _ me->pCSParse);
    return me;
}

PRIVATE int CSParseUser_free (HTStream * me)
{
/*    CSParse_deleteUser(me->pCSParse); */
    char * addr = HTAnchor_address((HTAnchor *)HTRequest_anchor(me->request));
    CSLoadedUser_add(CSParse_getUser(me->pCSParse), addr);
    HT_FREE(addr);
    CSParse_free(me);
    HT_FREE(me);
    return HT_OK;
}

PRIVATE int CSParseUser_abort (HTStream * me, HTList * e)
{
    CSParse_deleteUser(me->pCSParse);
    HT_FREE(me);
    return HT_OK;
}

PRIVATE const HTStreamClass CSParseClass_user =
{		
    "PICSParser",
    CSParse_flush,
    CSParseUser_free,
    CSParseUser_abort,
    CSParse_put_character,
    CSParse_put_string,
    CSParse_put_block
};

PUBLIC HTStream * CSParseUser (HTRequest *  request,
			       void *	    param,
			       HTFormat     input_format,
			       HTFormat	    output_format,
			       HTStream *   output_stream)
{
    HTStream * me = CSParseConverter_new(request, output_stream);
    me->isa = &CSParseClass_user;
    me->pCSParse = CSParse_newUser();
    me->request = request;
/*
    if (HTRequest_context(request))
        *((CSUser_t **)HTRequest_context(request)) = CSParse_getUser(me->pCSParse);
*/
    HTTRACE(PICS_TRACE, "PICS: creating user parser %p.\n" _ me->pCSParse);
    return me;
}

PRIVATE int CSParseLabel_free (HTStream * me)
{
    CSApp_label(me->request, CSParse_getLabel(me->pCSParse));
/*    CSParse_deleteLabel(me->pCSParse); keep it around and let CSApp free it */
    CSParse_free(me);
    HT_FREE(me);
    return HT_OK;
}

PRIVATE int CSParseLabel_abort (HTStream * me, HTList * e)
{
    CSParse_deleteLabel(me->pCSParse);
    CSParse_free(me);
    HT_FREE(me);
    return HT_OK;
}

PRIVATE const HTStreamClass CSParseClass_label =
{		
    "PICSParser",
    CSParse_flush,
    CSParseLabel_free,
    CSParseLabel_abort,
    CSParse_put_character,
    CSParse_put_string,
    CSParse_put_block
};

PRIVATE StateRet_t parseErrorHandler(CSLabel_t * pCSLabel, 
				     CSParse_t * pCSParse, 
				     const char * token, char demark, 
				     StateRet_t errorCode)
{
    char space[256];
if (PICS_TRACE)
    printf("%20s - %s:", pCSParse->pTargetObject->note, 
	   pCSParse->currentSubState == SubState_X ? "SubState_X" : 
	   pCSParse->currentSubState == SubState_N ? "SubState_N" : 
	   pCSParse->currentSubState == SubState_A ? "SubState_A" : 
	   pCSParse->currentSubState == SubState_B ? "SubState_B" : 
	   pCSParse->currentSubState == SubState_C ? "SubState_C" : 
	   pCSParse->currentSubState == SubState_D ? "SubState_D" : 
	   pCSParse->currentSubState == SubState_E ? "SubState_E" : 
	   pCSParse->currentSubState == SubState_F ? "SubState_F" : 
	   pCSParse->currentSubState == SubState_G ? "SubState_G" : 
	   pCSParse->currentSubState == SubState_H ? "SubState_H" : 
	   "???");

    switch (errorCode) {
        case StateRet_WARN_NO_MATCH:
            if (token)
	        sprintf(space, "Unexpected token \"%s\".\n", token);
	    else
	        sprintf(space, "Unexpected lack of token.\n");
            break;
        case StateRet_WARN_BAD_PUNCT:
            sprintf(space, "Unextected punctuation \"%c\"", demark);
	    if (token)
	        printf("after token \"%s\".\n", token);
	    else
	        printf(".\n");
            break;
        case StateRet_ERROR_BAD_CHAR:
            sprintf(space, "Unextected character \"%c\" in token \"%s\".\n", 
		    *pCSParse->pParseContext->pTokenError, token);
            break;
        default:
            sprintf(space, "Internal error: demark:\"%c\" token:\"%s\".\n", 
		    demark, token);
            break;
    }
    HTTRACE(PICS_TRACE, "%s" _ space); /* make sure %s don't get interpretted */
    return errorCode;
}

PUBLIC HTStream * CSParseLabel (HTRequest *	request,
           			            void *	    param,
			                    HTFormat  	input_format,
            			        HTFormat	    output_format,
			                    HTStream *	output_stream)
{
    HTStream * me = CSParseConverter_new(request, output_stream);
    me->isa = &CSParseClass_label;
    me->pCSParse = CSParse_newLabel(0, &parseErrorHandler);
    HTTRACE(PICS_TRACE, "PICS: creating label parser %p.\n" _ me->pCSParse);
    return me;
}