/****************************************************************** * $Id: soap-server.c,v 1.25 2006/05/24 15:18:52 mrcsys Exp $ * * CSOAP Project: A SOAP client/server library in C * Copyright (C) 2003 Ferhat Ayaz * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Library General Public License for more details. * * You should have received a copy of the GNU Library General Public * License along with this library; if not, write to the * Free Software Foundation, Inc., 59 Temple Place - Suite 330, * Boston, MA 02111-1307, USA. * * Email: ayaz@jprogrammer.net ******************************************************************/ #ifdef HAVE_CONFIG_H #include #endif #ifdef HAVE_STRING_H #include #endif #ifdef HAVE_ERRNO_H #include #endif #ifdef WIN32 #define snprintf(buffer, num, s1, s2) sprintf(buffer, s1,s2) #endif #include #include "soap-admin.h" #include "soap-server.h" static SoapRouterNode *head = NULL; static SoapRouterNode *tail = NULL; // static SoapRouter *router_find(const char *context); static void _soap_server_send_env(http_output_stream_t * out, SoapEnv * env) { xmlBufferPtr buffer; if (env == NULL || env->root == NULL) return; buffer = xmlBufferCreate(); xmlNodeDump(buffer, env->root->doc, env->root, 1, 1); http_output_stream_write_string(out, (const char *) xmlBufferContent(buffer)); xmlBufferFree(buffer); return; } static void _soap_server_send_fault(httpd_conn_t * conn, const char *errmsg) { SoapEnv *envres; hpair_t *header; herror_t err; char buffer[45]; header = hpairnode_new(HEADER_CONTENT_TYPE, "text/xml", NULL); httpd_set_headers(conn, header); if ((err = httpd_send_header(conn, 500, "FAILED")) != H_OK) { /* WARNING: unhandled exception ! */ log_error4("%s():%s [%d]", herror_func(err), herror_message(err), herror_code(err)); herror_release(err); return; } err = soap_env_new_with_fault(Fault_Server, errmsg ? errmsg : "General error", "cSOAP_Server", NULL, &envres); if (err != H_OK) { log_error1(herror_message(err)); http_output_stream_write_string(conn->out, ""); http_output_stream_write_string(conn->out, "

Error

"); http_output_stream_write_string(conn->out, "Error while sending fault object:
Message: "); http_output_stream_write_string(conn->out, herror_message(err)); http_output_stream_write_string(conn->out, "
Function: "); http_output_stream_write_string(conn->out, herror_func(err)); http_output_stream_write_string(conn->out, "
Error code: "); sprintf(buffer, "%d", herror_code(err)); http_output_stream_write_string(conn->out, buffer); http_output_stream_write_string(conn->out, ""); herror_release(err); } else { _soap_server_send_env(conn->out, envres); } hpairnode_free(header); return; } static void _soap_server_send_ctx(httpd_conn_t * conn, SoapCtx * ctx) { static int counter = 1; xmlBufferPtr buffer; char strbuffer[32]; part_t *part; if (ctx->env == NULL || ctx->env->root == NULL || ctx->env->root->doc == NULL) return; xmlThrDefIndentTreeOutput(1); /* xmlKeepBlanksDefault(0);*/ buffer = xmlBufferCreate(); xmlNodeDump(buffer, ctx->env->root->doc, ctx->env->root, 1, 1); if (ctx->attachments) { sprintf(strbuffer, "000128590350940924234%d", counter++); httpd_mime_send_header(conn, strbuffer, "", "text/xml", 200, "OK"); httpd_mime_next(conn, strbuffer, "text/xml", "binary"); http_output_stream_write_string(conn->out, (const char *) xmlBufferContent(buffer)); part = ctx->attachments->parts; while (part) { httpd_mime_send_file(conn, part->id, part->content_type, part->transfer_encoding, part->filename); part = part->next; } httpd_mime_end(conn); } else { char buflen[100]; xmlXPathContextPtr xpathCtx; xmlXPathObjectPtr xpathObj; xpathCtx = xmlXPathNewContext(ctx->env->root->doc); xpathObj = xmlXPathEvalExpression("//Fault", xpathCtx); snprintf(buflen, 100, "%d", xmlBufferLength(buffer)); httpd_set_header(conn, HEADER_CONTENT_LENGTH, buflen); httpd_set_header(conn, HEADER_CONTENT_TYPE, "text/xml"); if ((xpathObj->nodesetval) ? xpathObj->nodesetval->nodeNr : 0) { httpd_send_header(conn, 500, "FAILED"); } else { httpd_send_header(conn, 200, "OK"); } http_output_stream_write_string(conn->out, (const char *) xmlBufferContent(buffer)); xmlXPathFreeObject(xpathObj); xmlXPathFreeContext(xpathCtx); } xmlBufferFree(buffer); return; } static void _soap_server_send_description(httpd_conn_t *conn, xmlDocPtr wsdl) { char length[16]; xmlBufferPtr buf; buf = xmlBufferCreate(); xmlNodeDump(buf, wsdl, xmlDocGetRootElement(wsdl), 0, 0); sprintf(length, "%d", xmlBufferLength(buf)); httpd_set_header(conn, HEADER_CONTENT_TYPE, "text/xml"); httpd_set_header(conn, HEADER_CONTENT_LENGTH, length); httpd_send_header(conn, 200, "OK"); http_output_stream_write_string(conn->out, xmlBufferContent(buf)); xmlBufferFree(buf); return; } static SoapRouterNode * router_node_new(SoapRouter * router, const char *context, SoapRouterNode * next) { const char *noname = "/lost_found"; SoapRouterNode *node; if (!(node = (SoapRouterNode *) malloc(sizeof(SoapRouterNode)))) { log_error2("malloc failed (%s)", strerror(errno)); return NULL; } if (context) { node->context = strdup(context); } else { log_warn2("context is null. Using '%s'", noname); node->context = strdup(noname); } node->router = router; node->next = next; return node; } SoapRouter * soap_server_find_router(const char *context) { SoapRouterNode *node; for (node = head; node; node = node->next) { if (!strcmp(node->context, context)) return node->router; } return NULL; } static void soap_server_entry(httpd_conn_t * conn, hrequest_t * req) { char buffer[1054]; char *urn; char *method; SoapCtx *ctx, *ctxres; SoapRouter *router; SoapService *service; SoapEnv *env; herror_t err; if (!(router = soap_server_find_router(req->path))) { _soap_server_send_fault(conn, "Cannot find router"); return; } else if (req->method == HTTP_REQUEST_GET && router->wsdl) { _soap_server_send_description(conn, router->wsdl); return; } if (req->method != HTTP_REQUEST_POST) { httpd_send_header(conn, 200, "OK"); http_output_stream_write_string(conn->out, "" "" "" "" "

Sorry!

" "

I only speak with 'POST' method

" "" ""); return; } if ((err = soap_env_new_from_stream(req->in, &env)) != H_OK) { _soap_server_send_fault(conn, herror_message(err)); herror_release(err); return; } if (env == NULL) { _soap_server_send_fault(conn, "Can not receive POST data!"); } else { ctx = soap_ctx_new(env); ctx->action = hpairnode_get_ignore_case(req->header, "SoapAction"); if (ctx->action) ctx->action = strdup(ctx->action); ctx->http = req; soap_ctx_add_files(ctx, req->attachments); if (ctx->env == NULL) { _soap_server_send_fault(conn, "Can not parse POST data!"); } else { /* soap_xml_doc_print(env->root->doc); */ if (!(urn=soap_env_find_urn(ctx->env))) { _soap_server_send_fault(conn, "No URN found!"); soap_ctx_free(ctx); return; } else { log_verbose2("urn: '%s'", urn); } if (!(method=soap_env_find_methodname(ctx->env))) { _soap_server_send_fault(conn, "No method found!"); soap_ctx_free(ctx); return; } else { log_verbose2("method: '%s'", method); } service = soap_router_find_service(router, urn, method); if (service == NULL) { sprintf(buffer, "URN '%s' not found", urn); _soap_server_send_fault(conn, buffer); soap_ctx_free(ctx); return; } else { log_verbose2("func: %p", service->func); ctxres = soap_ctx_new(NULL); /* ===================================== */ /* CALL SERVICE FUNCTION */ /* ===================================== */ if ((err = service->func(ctx, ctxres)) != H_OK) { sprintf(buffer, "Service returned following error message: '%s'", herror_message(err)); herror_release(err); _soap_server_send_fault(conn, buffer); soap_ctx_free(ctx); return; } if (ctxres->env == NULL) { sprintf(buffer, "Service '%s' returned no envelope", urn); _soap_server_send_fault(conn, buffer); soap_ctx_free(ctx); return; } else { /* httpd_send_header(conn, 200, "OK"); _soap_server_send_env(conn->out, ctxres->env); */ _soap_server_send_ctx(conn, ctxres); /* free envctx */ soap_ctx_free(ctxres); } } } soap_ctx_free(ctx); } } herror_t soap_server_init_args(int argc, char *argv[]) { herror_t err; if ((err = httpd_init(argc, argv)) != H_OK) return err; return soap_admin_init_args(argc, argv); } int soap_server_register_router(SoapRouter * router, const char *context) { if (!httpd_register_secure(context, soap_server_entry, router->auth)) { return 0; } if (tail == NULL) { head = tail = router_node_new(router, context, NULL); } else { tail->next = router_node_new(router, context, NULL); tail = tail->next; } return 1; } SoapRouterNode * soap_server_get_routers(void) { return head; } herror_t soap_server_run(void) { return httpd_run(); } int soap_server_get_port(void) { return httpd_get_port(); } const char * soap_server_get_protocol(void) { return httpd_get_protocol(); } void soap_server_destroy() { SoapRouterNode *node = head; SoapRouterNode *tmp; while (node != NULL) { tmp = node->next; log_verbose2("soap_router_free(%p)", node->router); soap_router_free(node->router); free(node->context); free(node); node = tmp; } httpd_destroy(); return; }