Mercurial > pidgin
view src/protocols/jabber/xstream.c @ 3718:fd3880c03f0d
[gaim-migrate @ 3851]
global.mak introduced
committer: Tailor Script <tailor@pidgin.im>
author | Herman Bloggs <hermanator12002@yahoo.com> |
---|---|
date | Wed, 16 Oct 2002 20:00:51 +0000 |
parents | fce1883cc608 |
children |
line wrap: on
line source
/* -------------------------------------------------------------------------- * * License * * The contents of this file are subject to the Jabber Open Source License * Version 1.0 (the "JOSL"). You may not copy or use this file, in either * source code or executable form, except in compliance with the JOSL. You * may obtain a copy of the JOSL at http://www.jabber.org/ or at * http://www.opensource.org/. * * Software distributed under the JOSL is distributed on an "AS IS" basis, * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the JOSL * for the specific language governing rights and limitations under the * JOSL. * * Copyrights * * Portions created by or assigned to Jabber.com, Inc. are * Copyright (c) 1999-2002 Jabber.com, Inc. All Rights Reserved. Contact * information for Jabber.com, Inc. is available at http://www.jabber.com/. * * Portions Copyright (c) 1998-1999 Jeremie Miller. * * Acknowledgements * * Special thanks to the Jabber Open Source Contributors for their * suggestions and support of Jabber. * * Alternatively, the contents of this file may be used under the terms of the * GNU General Public License Version 2 or later (the "GPL"), in which case * the provisions of the GPL are applicable instead of those above. If you * wish to allow use of your version of this file only under the terms of the * GPL and not to allow others to use your version of this file under the JOSL, * indicate your decision by deleting the provisions above and replace them * with the notice and other provisions required by the GPL. If you do not * delete the provisions above, a recipient may use your version of this file * under either the JOSL or the GPL. * * * --------------------------------------------------------------------------*/ #include "lib.h" /* xstream is a way to have a consistent method of handling incoming XML Stream based events... it doesn't handle the generation of an XML Stream, but provides some facilities to help do that */ /******* internal expat callbacks *********/ void _xstream_startElement(xstream xs, const char* name, const char** atts) { pool p; /* if xstream is bad, get outa here */ if(xs->status > XSTREAM_NODE) return; if(xs->node == NULL) { p = pool_heap(5*1024); /* 5k, typically 1-2k each plus copy of self and workspace */ xs->node = xmlnode_new_tag_pool(p,name); xmlnode_put_expat_attribs(xs->node, atts); if(xs->status == XSTREAM_ROOT) { xs->status = XSTREAM_NODE; /* flag status that we're processing nodes now */ (xs->f)(XSTREAM_ROOT, xs->node, xs->arg); /* send the root, f must free all nodes */ xs->node = NULL; } }else{ xs->node = xmlnode_insert_tag(xs->node, name); xmlnode_put_expat_attribs(xs->node, atts); } /* depth check */ xs->depth++; if(xs->depth > XSTREAM_MAXDEPTH) xs->status = XSTREAM_ERR; } void _xstream_endElement(xstream xs, const char* name) { xmlnode parent; /* if xstream is bad, get outa here */ if(xs->status > XSTREAM_NODE) return; /* if it's already NULL we've received </stream>, tell the app and we're outta here */ if(xs->node == NULL) { xs->status = XSTREAM_CLOSE; (xs->f)(XSTREAM_CLOSE, NULL, xs->arg); }else{ parent = xmlnode_get_parent(xs->node); /* we are the top-most node, feed to the app who is responsible to delete it */ if(parent == NULL) (xs->f)(XSTREAM_NODE, xs->node, xs->arg); xs->node = parent; } xs->depth--; } void _xstream_charData(xstream xs, const char *str, int len) { /* if xstream is bad, get outa here */ if(xs->status > XSTREAM_NODE) return; if(xs->node == NULL) { /* we must be in the root of the stream where CDATA is irrelevant */ return; } xmlnode_insert_cdata(xs->node, str, len); } void _xstream_cleanup(void *arg) { xstream xs = (xstream)arg; xmlnode_free(xs->node); /* cleanup anything left over */ XML_ParserFree(xs->parser); } /* creates a new xstream with given pool, xstream will be cleaned up w/ pool */ xstream xstream_new(pool p, xstream_onNode f, void *arg) { xstream newx; if(p == NULL || f == NULL) { fprintf(stderr,"Fatal Programming Error: xstream_new() was improperly called with NULL.\n"); return NULL; } newx = pmalloco(p, sizeof(_xstream)); newx->p = p; newx->f = f; newx->arg = arg; /* create expat parser and ensure cleanup */ newx->parser = XML_ParserCreate(NULL); XML_SetUserData(newx->parser, (void *)newx); XML_SetElementHandler(newx->parser, (void *)_xstream_startElement, (void *)_xstream_endElement); XML_SetCharacterDataHandler(newx->parser, (void *)_xstream_charData); pool_cleanup(p, _xstream_cleanup, (void *)newx); return newx; } /* attempts to parse the buff onto this stream firing events to the handler, returns the last known status */ int xstream_eat(xstream xs, char *buff, int len) { char *err = NULL; xmlnode xerr; static char maxerr[] = "maximum node size reached"; static char deeperr[] = "maximum node depth reached"; if(xs == NULL) { fprintf(stderr,"Fatal Programming Error: xstream_eat() was improperly called with NULL.\n"); return XSTREAM_ERR; } if(len == 0 || buff == NULL) return xs->status; if(len == -1) /* easy for hand-fed eat calls */ len = strlen(buff); if(!XML_Parse(xs->parser, buff, len, 0)) { err = (char *)XML_ErrorString(XML_GetErrorCode(xs->parser)); xs->status = XSTREAM_ERR; }else if(pool_size(xmlnode_pool(xs->node)) > XSTREAM_MAXNODE || xs->cdata_len > XSTREAM_MAXNODE){ err = maxerr; xs->status = XSTREAM_ERR; }else if(xs->status == XSTREAM_ERR){ /* set within expat handlers */ err = deeperr; } /* fire parsing error event, make a node containing the error string */ if(xs->status == XSTREAM_ERR) { xerr = xmlnode_new_tag("error"); xmlnode_insert_cdata(xerr,err,-1); (xs->f)(XSTREAM_ERR, xerr, xs->arg); } return xs->status; } /* STREAM CREATION UTILITIES */ /* give a standard template xmlnode to work from */ xmlnode xstream_header(char *namespace, char *to, char *from) { xmlnode x; char id[10]; sprintf(id,"%X",(int)time(NULL)); x = xmlnode_new_tag("stream:stream"); xmlnode_put_attrib(x, "xmlns:stream", "http://etherx.jabber.org/streams"); xmlnode_put_attrib(x, "id", id); if(namespace != NULL) xmlnode_put_attrib(x, "xmlns", namespace); if(to != NULL) xmlnode_put_attrib(x, "to", to); if(from != NULL) xmlnode_put_attrib(x, "from", from); return x; } /* trim the xmlnode to only the opening header :) [NO CHILDREN ALLOWED] */ char *xstream_header_char(xmlnode x) { spool s; char *fixr, *head; if(xmlnode_has_children(x)) { fprintf(stderr,"Fatal Programming Error: xstream_header_char() was sent a header with children!\n"); return NULL; } s = spool_new(xmlnode_pool(x)); spooler(s,"<?xml version='1.0'?>",xmlnode2str(x),s); head = spool_print(s); fixr = strstr(head,"/>"); *fixr = '>'; ++fixr; *fixr = '\0'; return head; }