#include "php_soap.h" typedef struct sdlCtx { sdlPtr root; HashTable messages; HashTable bindings; HashTable portTypes; HashTable services; } sdlCtx; static void delete_binding(void *binding); static void delete_function(void *function); static void delete_paramater(void *paramater); static void delete_document(void *doc_ptr); encodePtr get_encoder_from_prefix(sdlPtr sdl, xmlNodePtr data, const char *type) { encodePtr enc = NULL; TSRMLS_FETCH(); enc = get_conversion_from_type(data, type); if (enc == NULL && sdl) { enc = get_conversion_from_type_ex(sdl->encoders, data, type); } if (enc == NULL) { enc = get_conversion(UNKNOWN_TYPE); } return enc; } static encodePtr get_encoder_from_element(sdlPtr sdl, xmlNodePtr node, const char *type) { encodePtr enc = NULL; TSRMLS_FETCH(); if (sdl && sdl->elements) { xmlNsPtr nsptr; char *ns, *cptype; sdlTypePtr *sdl_type; parse_namespace(type, &cptype, &ns); nsptr = xmlSearchNs(node->doc, node, ns); if (nsptr != NULL) { smart_str nscat = {0}; smart_str_appends(&nscat, nsptr->href); smart_str_appendc(&nscat, ':'); smart_str_appends(&nscat, cptype); smart_str_0(&nscat); if (zend_hash_find(sdl->elements, nscat.c, nscat.len + 1, (void **)&sdl_type) == SUCCESS) { enc = (*sdl_type)->encode; } else if (zend_hash_find(sdl->elements, (char*)type, strlen(type) + 1, (void **)&sdl_type) == SUCCESS) { enc = (*sdl_type)->encode; } smart_str_free(&nscat); } else { if (zend_hash_find(sdl->elements, (char*)type, strlen(type) + 1, (void **)&sdl_type) == SUCCESS) { enc = (*sdl_type)->encode; } } if (cptype) {efree(cptype);} if (ns) {efree(ns);} } if (enc == NULL) { enc = get_conversion(UNKNOWN_TYPE); } return enc; } encodePtr get_encoder(sdlPtr sdl, const char *ns, const char *type) { encodePtr enc = NULL; char *nscat; nscat = emalloc(strlen(ns) + strlen(type) + 2); sprintf(nscat, "%s:%s", ns, type); enc = get_encoder_ex(sdl, nscat); efree(nscat); return enc; } encodePtr get_encoder_ex(sdlPtr sdl, const char *nscat) { encodePtr enc = NULL; TSRMLS_FETCH(); enc = get_conversion_from_href_type(nscat); if (enc == NULL && sdl) { enc = get_conversion_from_href_type_ex(sdl->encoders, nscat, strlen(nscat)); } if (enc == NULL) { enc = get_conversion(UNKNOWN_TYPE); } return enc; } encodePtr get_create_encoder(sdlPtr sdl, sdlTypePtr cur_type, const char *ns, const char *type) { encodePtr enc = NULL; smart_str nscat = {0}; TSRMLS_FETCH(); smart_str_appends(&nscat, ns); smart_str_appendc(&nscat, ':'); smart_str_appends(&nscat, type); smart_str_0(&nscat); enc = get_conversion_from_href_type(nscat.c); if (enc == NULL) { enc = get_conversion_from_href_type_ex(sdl->encoders, nscat.c, nscat.len); } if (enc == NULL) { enc = create_encoder(sdl, cur_type, ns, type); } smart_str_free(&nscat); return enc; } encodePtr create_encoder(sdlPtr sdl, sdlTypePtr cur_type, const char *ns, const char *type) { smart_str nscat = {0}; encodePtr enc, *enc_ptr; if (sdl->encoders == NULL) { sdl->encoders = malloc(sizeof(HashTable)); zend_hash_init(sdl->encoders, 0, NULL, delete_encoder, 1); } smart_str_appends(&nscat, ns); smart_str_appendc(&nscat, ':'); smart_str_appends(&nscat, type); smart_str_0(&nscat); if (zend_hash_find(sdl->encoders, nscat.c, nscat.len + 1, (void**)&enc_ptr) == SUCCESS) { enc = *enc_ptr; if (enc->details.ns) { free(enc->details.ns); } if (enc->details.type_str) { free(enc->details.type_str); } } else { enc_ptr = NULL; enc = malloc(sizeof(encode)); } memset(enc, 0, sizeof(encode)); enc->details.ns = strdup(ns); enc->details.type_str = strdup(type); enc->details.sdl_type = cur_type; enc->to_xml = sdl_guess_convert_xml; enc->to_zval = sdl_guess_convert_zval; if (enc_ptr == NULL) { zend_hash_update(sdl->encoders, nscat.c, nscat.len + 1, &enc, sizeof(encodePtr), NULL); } smart_str_free(&nscat); return enc; } static zval* to_zval_list(encodeType enc, xmlNodePtr data) { zval *ret; MAKE_STD_ZVAL(ret); FIND_XML_NULL(data, ret); if (data && data->children) { if (data->children->type == XML_TEXT_NODE && data->children->next == NULL) { whiteSpace_collapse(data->children->content); ZVAL_STRING(ret, data->children->content, 1); } else { php_error(E_ERROR,"Violation of encoding rules"); } } else { ZVAL_EMPTY_STRING(ret); } return ret; } static xmlNodePtr to_xml_list(encodeType enc, zval *data, int style) { xmlNodePtr ret; ret = xmlNewNode(NULL, "BOGUS"); FIND_ZVAL_NULL(data, ret, style); if (Z_TYPE_P(data) == IS_ARRAY) { zval **tmp; smart_str list = {0}; HashTable *ht = Z_ARRVAL_P(data); zend_hash_internal_pointer_reset(ht); while (zend_hash_get_current_data(ht, (void**)&tmp) == SUCCESS) { if (list.len != 0) { smart_str_appendc(&list, ' '); } if (Z_TYPE_PP(tmp) == IS_STRING) { smart_str_appendl(&list, Z_STRVAL_PP(tmp), Z_STRLEN_PP(tmp)); } else { zval copy = **tmp; zval_copy_ctor(©); convert_to_string(©); smart_str_appendl(&list, Z_STRVAL(copy), Z_STRLEN(copy)); zval_dtor(©); } zend_hash_move_forward(ht); } smart_str_0(&list); xmlNodeSetContentLen(ret, list.c, list.len); smart_str_free(&list); } else if (Z_TYPE_P(data) == IS_STRING) { xmlNodeSetContentLen(ret, Z_STRVAL_P(data), Z_STRLEN_P(data)); } else { zval tmp = *data; zval_copy_ctor(&tmp); convert_to_string(&tmp); xmlNodeSetContentLen(ret, Z_STRVAL(tmp), Z_STRLEN(tmp)); zval_dtor(&tmp); } return ret; } static zval* to_zval_union(encodeType enc, xmlNodePtr data) { /*FIXME*/ return to_zval_list(enc, data); } static xmlNodePtr to_xml_union(encodeType enc, zval *data, int style) { /*FIXME*/ return to_xml_list(enc,data,style); } zval *sdl_guess_convert_zval(encodeType enc, xmlNodePtr data) { sdlTypePtr type; type = enc.sdl_type; if (type && type->restrictions && data && data->children && data->children->content) { if (type->restrictions->whiteSpace && type->restrictions->whiteSpace->value) { if (strcmp(type->restrictions->whiteSpace->value,"replace") == 0) { whiteSpace_replace(data->children->content); } else if (strcmp(type->restrictions->whiteSpace->value,"collapse") == 0) { whiteSpace_collapse(data->children->content); } } if (type->restrictions->enumeration) { if (!zend_hash_exists(type->restrictions->enumeration,data->children->content,strlen(data->children->content)+1)) { php_error(E_WARNING,"Restriction: invalid enumeration value \"%s\"",data->children->content); } } if (type->restrictions->minLength && strlen(data->children->content) < type->restrictions->minLength->value) { php_error(E_WARNING,"Restriction: length less then 'minLength'"); } if (type->restrictions->maxLength && strlen(data->children->content) > type->restrictions->maxLength->value) { php_error(E_WARNING,"Restriction: length greater then 'maxLength'"); } if (type->restrictions->length && strlen(data->children->content) != type->restrictions->length->value) { php_error(E_WARNING,"Restriction: length is not equal to 'length'"); } } if (type->kind == XSD_TYPEKIND_SIMPLE) { if (type->encode && memcmp(&type->encode->details,&enc,sizeof(enc))!=0) { return master_to_zval(type->encode, data); } } else if (type->kind == XSD_TYPEKIND_LIST) { return to_zval_list(enc, data); } else if (type->kind == XSD_TYPEKIND_UNION) { return to_zval_union(enc, data); } else if (type->kind == XSD_TYPEKIND_COMPLEX) { if (type->encode && (type->encode->details.type == IS_ARRAY || type->encode->details.type == SOAP_ENC_ARRAY)) { return to_zval_array(enc, data); } if (type->encode && (type->encode->details.type == IS_OBJECT || type->encode->details.type == SOAP_ENC_OBJECT)) { return to_zval_array(enc, data); } if (type->model || type->attributes) { return to_zval_object(enc, data); } if (type->encode && memcmp(&type->encode->details,&enc,sizeof(enc))!=0) { return master_to_zval(type->encode, data); } } return guess_zval_convert(enc, data); } xmlNodePtr sdl_guess_convert_xml(encodeType enc, zval *data, int style) { sdlTypePtr type; xmlNodePtr ret = NULL; type = enc.sdl_type; if (type) { if (type->restrictions && Z_TYPE_P(data) == IS_STRING) { if (type->restrictions->enumeration) { if (!zend_hash_exists(type->restrictions->enumeration,Z_STRVAL_P(data),Z_STRLEN_P(data)+1)) { php_error(E_WARNING,"Restriction: invalid enumeration value \"%s\".",Z_STRVAL_P(data)); } } if (type->restrictions->minLength && Z_STRLEN_P(data) < type->restrictions->minLength->value) { php_error(E_WARNING,"Restriction: length less then 'minLength'"); } if (type->restrictions->maxLength && Z_STRLEN_P(data) > type->restrictions->maxLength->value) { php_error(E_WARNING,"Restriction: length greater then 'maxLength'"); } if (type->restrictions->length && Z_STRLEN_P(data) != type->restrictions->length->value) { php_error(E_WARNING,"Restriction: length is not equal to 'length'"); } } } if (type->kind == XSD_TYPEKIND_SIMPLE) { if (type->encode && memcmp(&type->encode->details,&enc,sizeof(enc))!=0) { ret = master_to_xml(type->encode, data, style); } } else if (type->kind == XSD_TYPEKIND_LIST) { ret = to_xml_list(enc, data, style); } else if (type->kind == XSD_TYPEKIND_UNION) { ret = to_xml_union(enc, data, style); } else if (type->kind == XSD_TYPEKIND_COMPLEX) { if (type->encode && (type->encode->details.type == IS_ARRAY || type->encode->details.type == SOAP_ENC_ARRAY)) { ret = to_xml_array(enc, data, style); } else if (type->encode && (type->encode->details.type == IS_OBJECT || type->encode->details.type == SOAP_ENC_OBJECT)) { ret = to_xml_object(enc, data, style); } else if (type->model || type->attributes) { ret = to_xml_object(enc, data, style); } else if (type->encode && memcmp(&type->encode->details,&enc,sizeof(enc))!=0) { ret = master_to_xml(type->encode, data, style); } } if (ret == NULL) { ret = guess_xml_convert(enc, data, style); } if (style == SOAP_ENCODED) { set_ns_and_type(ret, enc); } return ret; } sdlBindingPtr get_binding_from_type(sdlPtr sdl, int type) { sdlBindingPtr *binding; if (sdl == NULL) { return NULL; } for (zend_hash_internal_pointer_reset(sdl->bindings); zend_hash_get_current_data(sdl->bindings, (void **) &binding) == SUCCESS; zend_hash_move_forward(sdl->bindings)) { if ((*binding)->bindingType == type) { return *binding; } } return NULL; } sdlBindingPtr get_binding_from_name(sdlPtr sdl, char *name, char *ns) { sdlBindingPtr binding = NULL; smart_str key = {0}; smart_str_appends(&key, ns); smart_str_appendc(&key, ':'); smart_str_appends(&key, name); smart_str_0(&key); zend_hash_find(sdl->bindings, key.c, key.len, (void **)&binding); smart_str_free(&key); return binding; } static void load_wsdl_ex(char *struri, sdlCtx *ctx, int include) { sdlPtr tmpsdl = ctx->root; xmlDocPtr wsdl; xmlNodePtr root, definitions, trav; xmlAttrPtr targetNamespace; int old_error_reporting; TSRMLS_FETCH(); /* TODO: WSDL Caching */ old_error_reporting = EG(error_reporting); EG(error_reporting) &= ~(E_WARNING|E_NOTICE|E_USER_WARNING|E_USER_NOTICE); wsdl = xmlParseFile(struri); xmlCleanupParser(); EG(error_reporting) = old_error_reporting; if (!wsdl) { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: Couldn't load from %s", struri); } zend_hash_next_index_insert(&tmpsdl->docs, (void**)&wsdl, sizeof(xmlDocPtr), NULL); root = wsdl->children; definitions = get_node(root, "definitions"); if (!definitions) { if (include) { xmlNodePtr schema = get_node(root, "schema"); if (schema) { load_schema(tmpsdl, schema); return; } } php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: Couldn't find \"definitions\" in %s", struri); } if (!include) { targetNamespace = get_attribute(definitions->properties, "targetNamespace"); if (targetNamespace) { tmpsdl->target_ns = strdup(targetNamespace->children->content); } } trav = definitions->children; while (trav != NULL) { if (trav->type == XML_ELEMENT_NODE) { if (strcmp(trav->name,"types") == 0) { /* TODO: Only one "types" is allowed */ xmlNodePtr trav2 = trav->children; xmlNodePtr schema; FOREACHNODE(trav2, "schema", schema) { load_schema(tmpsdl, schema); } ENDFOREACH(trav2); } else if (strcmp(trav->name,"import") == 0) { /* TODO: namespace ??? */ xmlAttrPtr tmp = get_attribute(trav->properties, "location"); if (tmp) { load_wsdl_ex(tmp->children->content, ctx, 1); } } else if (strcmp(trav->name,"message") == 0) { xmlAttrPtr name = get_attribute(trav->properties, "name"); if (name && name->children && name->children->content) { zend_hash_add(&ctx->messages, name->children->content, strlen(name->children->content)+1,&trav, sizeof(xmlNodePtr), NULL); /* TODO: redeclaration handling */ } else { php_error(E_ERROR,"SOAP-ERROR: Parsing WSDL: hasn't name attribute"); } } else if (strcmp(trav->name,"portType") == 0) { xmlAttrPtr name = get_attribute(trav->properties, "name"); if (name && name->children && name->children->content) { zend_hash_add(&ctx->portTypes, name->children->content, strlen(name->children->content)+1,&trav, sizeof(xmlNodePtr), NULL); /* TODO: redeclaration handling */ } else { php_error(E_ERROR,"SOAP-ERROR: Parsing WSDL: hasn't name attribute"); } } else if (strcmp(trav->name,"binding") == 0) { xmlAttrPtr name = get_attribute(trav->properties, "name"); if (name && name->children && name->children->content) { zend_hash_add(&ctx->bindings, name->children->content, strlen(name->children->content)+1,&trav, sizeof(xmlNodePtr), NULL); /* TODO: redeclaration handling */ } else { php_error(E_ERROR,"SOAP-ERROR: Parsing WSDL: hasn't name attribute"); } } else if (strcmp(trav->name,"service") == 0) { xmlAttrPtr name = get_attribute(trav->properties, "name"); if (name && name->children && name->children->content) { zend_hash_add(&ctx->services, name->children->content, strlen(name->children->content)+1,&trav, sizeof(xmlNodePtr), NULL); /* TODO: redeclaration handling */ } else { php_error(E_ERROR,"SOAP-ERROR: Parsing WSDL: hasn't name attribute"); } } else { /* TODO: extensibility elements */ } } trav = trav->next; } } static sdlPtr load_wsdl(char *struri) { sdlCtx ctx; int i,n; ctx.root = malloc(sizeof(sdl)); memset(ctx.root, 0, sizeof(sdl)); ctx.root->source = strdup(struri); zend_hash_init(&ctx.root->docs, 0, NULL, delete_document, 1); zend_hash_init(&ctx.root->functions, 0, NULL, delete_function, 1); zend_hash_init(&ctx.messages, 0, NULL, NULL, 0); zend_hash_init(&ctx.bindings, 0, NULL, NULL, 0); zend_hash_init(&ctx.portTypes, 0, NULL, NULL, 0); zend_hash_init(&ctx.services, 0, NULL, NULL, 0); load_wsdl_ex(struri,&ctx, 0); schema_pass2(ctx.root); n = zend_hash_num_elements(&ctx.services); if (n > 0) { zend_hash_internal_pointer_reset(&ctx.services); for (i = 0; i < n; i++) { xmlNodePtr *tmp, service; /* xmlAttrPtr name; */ xmlNodePtr trav, port; zend_hash_get_current_data(&ctx.services, (void **)&tmp); service = *tmp; /* name = get_attribute(service->properties, "name"); if (!name) { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: No name associated with service"); } */ trav = service->children; FOREACHNODE(trav, "port", port) { xmlAttrPtr type, name, bindingAttr, location; xmlNodePtr portType, operation; xmlNodePtr address, binding, trav2; char *ns, *ctype; sdlBindingPtr tmpbinding; char *wsdl_soap_namespace = NULL; tmpbinding = malloc(sizeof(sdlBinding)); memset(tmpbinding, 0, sizeof(sdlBinding)); /* name = get_attribute(port->properties, "name"); if (!name) { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: No name associated with port"); } */ bindingAttr = get_attribute(port->properties, "binding"); if (bindingAttr == NULL) { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: No binding associated with port"); } /* find address and figure out binding type */ address = get_node(port->children, "address"); if (!address) { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: No address associated with port"); } location = get_attribute(address->properties, "location"); if (!location) { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: No location associated with port"); } tmpbinding->location = strdup(location->children->content); if (address->ns && !strcmp(address->ns->href, WSDL_SOAP11_NAMESPACE)) { wsdl_soap_namespace = WSDL_SOAP11_NAMESPACE; tmpbinding->bindingType = BINDING_SOAP; } else if (address->ns && !strcmp(address->ns->href, WSDL_SOAP12OLD_NAMESPACE)) { wsdl_soap_namespace = WSDL_SOAP12OLD_NAMESPACE; tmpbinding->bindingType = BINDING_SOAP; } else if (address->ns && !strcmp(address->ns->href, WSDL_SOAP12_NAMESPACE)) { wsdl_soap_namespace = WSDL_SOAP12_NAMESPACE; tmpbinding->bindingType = BINDING_SOAP; } else if (address->ns && !strcmp(address->ns->href, WSDL_HTTP11_NAMESPACE)) { tmpbinding->bindingType = BINDING_HTTP; } else if (address->ns && !strcmp(address->ns->href, WSDL_HTTP12_NAMESPACE)) { tmpbinding->bindingType = BINDING_HTTP; } else { if (address->ns) { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: PHP-SOAP doesn't support binding '%s'",address->ns->href); } else { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: Unknown binding type"); } } parse_namespace(bindingAttr->children->content, &ctype, &ns); if (zend_hash_find(&ctx.bindings, ctype, strlen(ctype)+1, (void*)&tmp) != SUCCESS) { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: No binding element with name \"%s\"", ctype); } binding = *tmp; if (ns) {efree(ns);} if (ctype) {efree(ctype);} if (tmpbinding->bindingType == BINDING_SOAP) { sdlSoapBindingPtr soapBinding; xmlNodePtr soapBindingNode; xmlAttrPtr tmp; soapBinding = malloc(sizeof(sdlSoapBinding)); memset(soapBinding, 0, sizeof(sdlSoapBinding)); soapBinding->style = SOAP_DOCUMENT; soapBindingNode = get_node_ex(binding->children, "binding", wsdl_soap_namespace); if (soapBindingNode) { tmp = get_attribute(soapBindingNode->properties, "style"); if (tmp && !strcmp(tmp->children->content, "rpc")) { soapBinding->style = SOAP_RPC; } tmp = get_attribute(soapBindingNode->properties, "transport"); if (tmp) { if (strcmp(tmp->children->content, WSDL_HTTP_TRANSPORT)) { php_error(E_ERROR, "SOAP-ERROR: Parsing WSDL: PHP-SOAP doesn't support transport '%s'", tmp->children->content); } soapBinding->transport = strdup(tmp->children->content); } } tmpbinding->bindingAttributes = (void *)soapBinding; } name = get_attribute(binding->properties, "name"); if (name == NULL) { php_error(E_ERROR, "Error parsing wsdl (Missing \"name\" attribute for \"binding\")"); } tmpbinding->name = strdup(name->children->content); type = get_attribute(binding->properties, "type"); if (type == NULL) { php_error(E_ERROR, "Error parsing wsdl (Missing \"type\" attribute for \"binding\")"); } parse_namespace(type->children->content, &ctype, &ns); if (zend_hash_find(&ctx.portTypes, ctype, strlen(ctype)+1, (void**)&tmp) != SUCCESS) { php_error(E_ERROR, "Error parsing wsdl (Missing \"portType\" with name \"%s\")", name->children->content); } portType = *tmp; if (ctype) {efree(ctype);} if (ns) {efree(ns);} trav2 = binding->children; FOREACHNODE(trav2, "operation", operation) { sdlFunctionPtr function; xmlNodePtr input, output, fault, portTypeOperation, portTypeInput, portTypeOutput, msgInput, msgOutput; xmlAttrPtr op_name, paramOrder; op_name = get_attribute(operation->properties, "name"); if (op_name == NULL) { php_error(E_ERROR, "Error parsing wsdl (Missing \"name\" attribute for \"operation\")"); } portTypeOperation = get_node_with_attribute(portType->children, "operation", "name", op_name->children->content); if (portTypeOperation == NULL) { php_error(E_ERROR, "Error parsing wsdl (Missing \"portType/operation\" with name \"%s\")", op_name->children->content); } function = malloc(sizeof(sdlFunction)); function->functionName = strdup(op_name->children->content); function->requestParameters = NULL; function->responseParameters = NULL; function->responseName = NULL; function->requestName = NULL; function->bindingAttributes = NULL; if (tmpbinding->bindingType == BINDING_SOAP) { sdlSoapBindingFunctionPtr soapFunctionBinding; sdlSoapBindingPtr soapBinding; xmlNodePtr soapOperation; xmlAttrPtr tmp; soapFunctionBinding = malloc(sizeof(sdlSoapBindingFunction)); memset(soapFunctionBinding, 0, sizeof(sdlSoapBindingFunction)); soapBinding = (sdlSoapBindingPtr)tmpbinding->bindingAttributes; soapFunctionBinding->style = soapBinding->style; soapOperation = get_node_ex(operation->children, "operation", wsdl_soap_namespace); if (soapOperation) { tmp = get_attribute(soapOperation->properties, "soapAction"); if (tmp) { soapFunctionBinding->soapAction = strdup(tmp->children->content); } tmp = get_attribute(soapOperation->properties, "style"); if (tmp) { if (!strcmp(tmp->children->content, "rpc")) { soapFunctionBinding->style = SOAP_RPC; } else { soapFunctionBinding->style = SOAP_DOCUMENT; } } else { soapFunctionBinding->style = soapBinding->style; } } function->bindingAttributes = (void *)soapFunctionBinding; } input = get_node(operation->children, "input"); portTypeInput = get_node(portTypeOperation->children, "input"); output = get_node(operation->children, "output"); portTypeOutput = get_node(portTypeOperation->children, "output"); if (input != NULL) { xmlAttrPtr message, name; xmlNodePtr part, trav3; char *ns, *ctype; if (portTypeInput) { message = get_attribute(portTypeInput->properties, "message"); if (message == NULL) { php_error(E_ERROR, "Error parsing wsdl (Missing name for \"input\" of \"%s\")", op_name->children->content); } name = get_attribute(portTypeInput->properties, "name"); if (name != NULL) { function->requestName = strdup(name->children->content); } else { function->requestName = strdup(function->functionName); } function->requestParameters = malloc(sizeof(HashTable)); zend_hash_init(function->requestParameters, 0, NULL, delete_paramater, 1); parse_namespace(message->children->content, &ctype, &ns); if (zend_hash_find(&ctx.messages, ctype, strlen(ctype)+1, (void**)&tmp) != SUCCESS) { php_error(E_ERROR, "Error parsing wsdl (Missing \"message\" with name \"%s\")", message->children->content); } msgInput = *tmp; if (ctype) {efree(ctype);} if (ns) {efree(ns);} if (tmpbinding->bindingType == BINDING_SOAP) { sdlSoapBindingFunctionPtr soapFunctionBinding = function->bindingAttributes; xmlNodePtr body; xmlAttrPtr tmp; body = get_node_ex(input->children, "body", wsdl_soap_namespace); if (body) { tmp = get_attribute(body->properties, "use"); if (tmp && !strcmp(tmp->children->content, "literal")) { soapFunctionBinding->input.use = SOAP_LITERAL; } else { soapFunctionBinding->input.use = SOAP_ENCODED; } tmp = get_attribute(body->properties, "namespace"); if (tmp) { soapFunctionBinding->input.ns = strdup(tmp->children->content); } tmp = get_attribute(body->properties, "parts"); if (tmp) { soapFunctionBinding->input.parts = strdup(tmp->children->content); } tmp = get_attribute(body->properties, "encodingStyle"); if (tmp) { soapFunctionBinding->input.encodingStyle = strdup(tmp->children->content); } } } trav3 = msgInput->children; FOREACHNODE(trav3, "part", part) { xmlAttrPtr element, type, name; sdlParamPtr param; param = malloc(sizeof(sdlParam)); memset(param,0,sizeof(sdlParam)); param->order = 0; name = get_attribute(part->properties, "name"); if (name == NULL) { php_error(E_ERROR, "Error parsing wsdl (No name associated with part \"%s\")", msgInput->name); } param->paramName = strdup(name->children->content); type = get_attribute(part->properties, "type"); if (type != NULL) { param->encode = get_encoder_from_prefix(ctx.root, part, type->children->content); } else { element = get_attribute(part->properties, "element"); if (element != NULL) { param->encode = get_encoder_from_element(ctx.root, part, element->children->content); } } zend_hash_next_index_insert(function->requestParameters, ¶m, sizeof(sdlParamPtr), NULL); } ENDFOREACH(trav3); } } if (output != NULL) { xmlAttrPtr message, name; xmlNodePtr part, trav3; char *ns, *ctype; if (portTypeOutput) { name = get_attribute(portTypeOutput->properties, "name"); if (name != NULL) { function->responseName = strdup(name->children->content); } else if (input == NULL) { function->responseName = strdup(function->functionName); } else { function->responseName = malloc(strlen(function->functionName) + strlen("Response") + 1); sprintf(function->responseName, "%sResponse", function->functionName); } function->responseParameters = malloc(sizeof(HashTable)); zend_hash_init(function->responseParameters, 0, NULL, delete_paramater, 1); message = get_attribute(portTypeOutput->properties, "message"); if (message == NULL) { php_error(E_ERROR, "Error parsing wsdl (Missing name for \"output\" of \"%s\")", op_name->children->content); } parse_namespace(message->children->content, &ctype, &ns); if (zend_hash_find(&ctx.messages, ctype, strlen(ctype)+1, (void**)&tmp) != SUCCESS) { php_error(E_ERROR, "Error parsing wsdl (Missing \"message\" with name \"%s\")", message->children->content); } msgOutput = *tmp; if (ctype) {efree(ctype);} if (ns) {efree(ns);} if (tmpbinding->bindingType == BINDING_SOAP) { sdlSoapBindingFunctionPtr soapFunctionBinding = function->bindingAttributes; xmlNodePtr body; xmlAttrPtr tmp; body = get_node_ex(output->children, "body", wsdl_soap_namespace); if (body) { tmp = get_attribute(body->properties, "use"); if (tmp && !strcmp(tmp->children->content, "literal")) { soapFunctionBinding->output.use = SOAP_LITERAL; } else { soapFunctionBinding->output.use = SOAP_ENCODED; } tmp = get_attribute(body->properties, "namespace"); if (tmp) { soapFunctionBinding->output.ns = strdup(tmp->children->content); } tmp = get_attribute(body->properties, "parts"); if (tmp) { soapFunctionBinding->output.parts = strdup(tmp->children->content); } tmp = get_attribute(body->properties, "encodingStyle"); if (tmp) { soapFunctionBinding->output.encodingStyle = strdup(tmp->children->content); } } } trav3 = msgOutput->children; FOREACHNODE(trav3, "part", part) { sdlParamPtr param; xmlAttrPtr element, type, name; param = malloc(sizeof(sdlParam)); memset(param, 0, sizeof(sdlParam)); param->order = 0; name = get_attribute(part->properties, "name"); if (name == NULL) { php_error(E_ERROR, "Error parsing wsdl (No name associated with part \"%s\")", msgOutput->name); } param->paramName = strdup(name->children->content); type = get_attribute(part->properties, "type"); if (type) { param->encode = get_encoder_from_prefix(ctx.root, part, type->children->content); } else { element = get_attribute(part->properties, "element"); if (element) { param->encode = get_encoder_from_element(ctx.root, part, element->children->content); } } zend_hash_next_index_insert(function->responseParameters, ¶m, sizeof(sdlParamPtr), NULL); } ENDFOREACH(trav3); } } paramOrder = get_attribute(portTypeOperation->properties, "parameterOrder"); if (paramOrder) { /* FIXME: */ } fault = get_node(operation->children, "fault"); if (!fault) { } function->binding = tmpbinding; { char *tmp = estrdup(function->functionName); int len = strlen(tmp); zend_hash_add(&ctx.root->functions, php_strtolower(tmp, len), len+1, &function, sizeof(sdlFunctionPtr), NULL); efree(tmp); if (function->requestName != NULL && strcmp(function->requestName,function->functionName) != 0) { if (ctx.root->requests == NULL) { ctx.root->requests = malloc(sizeof(HashTable)); zend_hash_init(ctx.root->requests, 0, NULL, NULL, 1); } tmp = estrdup(function->requestName); len = strlen(tmp); zend_hash_add(ctx.root->requests, php_strtolower(tmp, len), len+1, &function, sizeof(sdlFunctionPtr), NULL); efree(tmp); } } } ENDFOREACH(trav2); if (!ctx.root->bindings) { ctx.root->bindings = malloc(sizeof(HashTable)); zend_hash_init(ctx.root->bindings, 0, NULL, delete_binding, 1); } zend_hash_add(ctx.root->bindings, tmpbinding->name, strlen(tmpbinding->name), &tmpbinding, sizeof(sdlBindingPtr), NULL); } ENDFOREACH(trav); zend_hash_move_forward(&ctx.services); } } else { php_error(E_ERROR, "Error parsing wsdl (\"Couldn't bind to service\")"); } schema_pass3(ctx.root); zend_hash_destroy(&ctx.messages); zend_hash_destroy(&ctx.bindings); zend_hash_destroy(&ctx.portTypes); zend_hash_destroy(&ctx.services); return ctx.root; } sdlPtr get_sdl(char *uri) { sdlPtr tmp, *hndl; TSRMLS_FETCH(); tmp = NULL; hndl = NULL; if (zend_hash_find(SOAP_GLOBAL(sdls), uri, strlen(uri), (void **)&hndl) == FAILURE) { tmp = load_wsdl(uri); zend_hash_add(SOAP_GLOBAL(sdls), uri, strlen(uri), &tmp, sizeof(sdlPtr), NULL); } else { tmp = *hndl; } return tmp; } /* Deletes */ void delete_sdl(void *handle) { sdlPtr tmp = *((sdlPtr*)handle); zend_hash_destroy(&tmp->docs); zend_hash_destroy(&tmp->functions); if (tmp->source) { free(tmp->source); } if (tmp->target_ns) { free(tmp->target_ns); } if (tmp->encoders) { zend_hash_destroy(tmp->encoders); free(tmp->encoders); } if (tmp->types) { zend_hash_destroy(tmp->types); free(tmp->types); } if (tmp->elements) { zend_hash_destroy(tmp->elements); free(tmp->elements); } if (tmp->attributes) { zend_hash_destroy(tmp->attributes); free(tmp->attributes); } if (tmp->attributeGroups) { zend_hash_destroy(tmp->attributeGroups); free(tmp->attributeGroups); } if (tmp->groups) { zend_hash_destroy(tmp->groups); free(tmp->groups); } if (tmp->bindings) { zend_hash_destroy(tmp->bindings); free(tmp->bindings); } if (tmp->requests) { zend_hash_destroy(tmp->requests); free(tmp->requests); } free(tmp); } static void delete_binding(void *data) { sdlBindingPtr binding = *((sdlBindingPtr*)data); if (binding->location) { free(binding->location); } if (binding->name) { free(binding->name); } if (binding->bindingType == BINDING_SOAP) { sdlSoapBindingPtr soapBind = binding->bindingAttributes; if (soapBind && soapBind->transport) { free(soapBind->transport); } } } static void delete_sdl_soap_binding_function_body(sdlSoapBindingFunctionBody body) { if (body.ns) { free(body.ns); } if (body.parts) { free(body.parts); } if (body.encodingStyle) { free(body.encodingStyle); } } static void delete_function(void *data) { sdlFunctionPtr function = *((sdlFunctionPtr*)data); if (function->functionName) { free(function->functionName); } if (function->requestName) { free(function->requestName); } if (function->responseName) { free(function->responseName); } if (function->requestParameters) { zend_hash_destroy(function->requestParameters); free(function->requestParameters); } if (function->responseParameters) { zend_hash_destroy(function->responseParameters); free(function->responseParameters); } if (function->bindingAttributes && function->binding && function->binding->bindingType == BINDING_SOAP) { sdlSoapBindingFunctionPtr soapFunction = function->bindingAttributes; if (soapFunction->soapAction) { free(soapFunction->soapAction); } delete_sdl_soap_binding_function_body(soapFunction->input); delete_sdl_soap_binding_function_body(soapFunction->output); delete_sdl_soap_binding_function_body(soapFunction->falut); } } static void delete_paramater(void *data) { sdlParamPtr param = *((sdlParamPtr*)data); if (param->paramName) { free(param->paramName); } free(param); } void delete_mapping(void *data) { soapMappingPtr map = (soapMappingPtr)data; if (map->ns) { efree(map->ns); } if (map->ctype) { efree(map->ctype); } if (map->type == SOAP_MAP_FUNCTION) { if (map->map_functions.to_xml_before) { zval_ptr_dtor(&map->map_functions.to_xml_before); } if (map->map_functions.to_xml) { zval_ptr_dtor(&map->map_functions.to_xml); } if (map->map_functions.to_xml_after) { zval_ptr_dtor(&map->map_functions.to_xml_after); } if (map->map_functions.to_zval_before) { zval_ptr_dtor(&map->map_functions.to_zval_before); } if (map->map_functions.to_zval) { zval_ptr_dtor(&map->map_functions.to_zval); } if (map->map_functions.to_zval_after) { zval_ptr_dtor(&map->map_functions.to_zval_after); } } efree(map); } void delete_type(void *data) { sdlTypePtr type = *((sdlTypePtr*)data); if (type->name) { free(type->name); } if (type->namens) { free(type->namens); } if (type->elements) { zend_hash_destroy(type->elements); free(type->elements); } if (type->attributes) { zend_hash_destroy(type->attributes); free(type->attributes); } if (type->restrictions) { delete_restriction_var_int(&type->restrictions->minExclusive); delete_restriction_var_int(&type->restrictions->minInclusive); delete_restriction_var_int(&type->restrictions->maxExclusive); delete_restriction_var_int(&type->restrictions->maxInclusive); delete_restriction_var_int(&type->restrictions->totalDigits); delete_restriction_var_int(&type->restrictions->fractionDigits); delete_restriction_var_int(&type->restrictions->length); delete_restriction_var_int(&type->restrictions->minLength); delete_restriction_var_int(&type->restrictions->maxLength); delete_schema_restriction_var_char(&type->restrictions->whiteSpace); delete_schema_restriction_var_char(&type->restrictions->pattern); if (type->restrictions->enumeration) { zend_hash_destroy(type->restrictions->enumeration); free(type->restrictions->enumeration); } free(type->restrictions); } free(type); } void delete_attribute(void *attribute) { sdlAttributePtr attr = *((sdlAttributePtr*)attribute); if (attr->def) { free(attr->def); } if (attr->fixed) { free(attr->fixed); } if (attr->form) { free(attr->form); } if (attr->id) { free(attr->id); } if (attr->name) { free(attr->name); } if (attr->ref) { free(attr->ref); } if (attr->use) { free(attr->use); } if (attr->extraAttributes) { zend_hash_destroy(attr->extraAttributes); free(attr->extraAttributes); } } void delete_restriction_var_int(void *rvi) { sdlRestrictionIntPtr ptr = *((sdlRestrictionIntPtr*)rvi); if (ptr) { if (ptr->id) { free(ptr->id); } free(ptr); } } void delete_schema_restriction_var_char(void *srvc) { sdlRestrictionCharPtr ptr = *((sdlRestrictionCharPtr*)srvc); if (ptr) { if (ptr->id) { free(ptr->id); } if (ptr->value) { free(ptr->value); } free(ptr); } } static void delete_document(void *doc_ptr) { xmlDocPtr doc = *((xmlDocPtr*)doc_ptr); xmlFreeDoc(doc); }