/** * Author : Gérald FENOY * * Copyright 2008-2011 GeoLabs SARL. All rights reserved. * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal * in the Software without restriction, including without limitation the rights * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the Software is * furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN * THE SOFTWARE. */ #define length(x) (sizeof(x) / sizeof(x[0])) extern "C" int yylex(); extern "C" int crlex(); extern "C" { #include #include #include #include #include } #include "cgic.h" #include "ulinet.h" #include #include #include #include "service.h" #include "service_internal.h" #ifdef USE_PYTHON #include "service_internal_python.h" #endif #ifdef USE_JAVA #include "service_internal_java.h" #endif #ifdef USE_PHP #include "service_internal_php.h" #endif #ifdef USE_JS #include "service_internal_js.h" #endif #ifdef USE_PERL #include "service_internal_perl.h" #endif #include #include #include #ifndef WIN32 #include #include #else #include #include #endif #include #include #include #define _(String) dgettext ("zoo-kernel",String) void translateChar(char* str,char toReplace,char toReplaceBy){ int i=0,len=strlen(str); for(i=0;icontent,"serviceType"); #ifdef DEBUG fprintf(stderr,"LOAD A %s SERVICE PROVIDER \n",r_inputs->value); fflush(stderr); #endif if(strncasecmp(r_inputs->value,"C",1)==0){ r_inputs=getMap(request_inputs,"metapath"); if(r_inputs!=NULL) sprintf(tmps1,"%s/%s",ntmp,r_inputs->value); else sprintf(tmps1,"%s/",ntmp); char *altPath=strdup(tmps1); r_inputs=getMap(s1->content,"ServiceProvider"); sprintf(tmps1,"%s/%s",altPath,r_inputs->value); free(altPath); #ifdef DEBUG fprintf(stderr,"Trying to load %s\n",tmps1); #endif #ifdef WIN32 HINSTANCE so = LoadLibraryEx(tmps1,NULL,LOAD_WITH_ALTERED_SEARCH_PATH); #else void* so = dlopen(tmps1, RTLD_LAZY); #endif #ifdef DEBUG #ifdef WIN32 DWORD errstr; errstr = GetLastError(); fprintf(stderr,"%s loaded (%d) \n",tmps1,errstr); #else char *errstr; errstr = dlerror(); #endif #endif if( so != NULL ) { #ifdef DEBUG fprintf(stderr,"Library loaded %s \n",errstr); fprintf(stderr,"Service Shared Object = %s\n",r_inputs->value); #endif r_inputs=getMap(s1->content,"serviceType"); #ifdef DEBUG dumpMap(r_inputs); fprintf(stderr,"%s\n",r_inputs->value); fflush(stderr); #endif if(strncasecmp(r_inputs->value,"C-FORTRAN",9)==0){ r_inputs=getMap(request_inputs,"Identifier"); char fname[1024]; sprintf(fname,"%s_",r_inputs->value); #ifdef DEBUG fprintf(stderr,"Try to load function %s\n",fname); #endif #ifdef WIN32 typedef int (CALLBACK* execute_t)(char***,char***,char***); execute_t execute=(execute_t)GetProcAddress(so,fname); #else typedef int (*execute_t)(char***,char***,char***); execute_t execute=(execute_t)dlsym(so,fname); #endif #ifdef DEBUG #ifdef WIN32 errstr = GetLastError(); #else errstr = dlerror(); #endif fprintf(stderr,"Function loaded %s\n",errstr); #endif char main_conf[10][30][1024]; char inputs[10][30][1024]; char outputs[10][30][1024]; for(int i=0;i<10;i++){ for(int j=0;j<30;j++){ memset(main_conf[i][j],0,1024); memset(inputs[i][j],0,1024); memset(outputs[i][j],0,1024); } } mapsToCharXXX(m,(char***)main_conf); mapsToCharXXX(request_input_real_format,(char***)inputs); mapsToCharXXX(request_output_real_format,(char***)outputs); *eres=execute((char***)&main_conf[0],(char***)&inputs[0],(char***)&outputs[0]); #ifdef DEBUG fprintf(stderr,"Function run successfully \n"); #endif charxxxToMaps((char***)&outputs[0],&request_output_real_format); }else{ #ifdef DEBUG #ifdef WIN32 errstr = GetLastError(); fprintf(stderr,"Function %s failed to load because of %d\n",r_inputs->value,errstr); #endif #endif r_inputs=getMap(request_inputs,"Identifier"); #ifdef DEBUG fprintf(stderr,"Try to load function %s\n",r_inputs->value); #endif typedef int (*execute_t)(maps**,maps**,maps**); #ifdef WIN32 execute_t execute=(execute_t)GetProcAddress(so,r_inputs->value); #else execute_t execute=(execute_t)dlsym(so,r_inputs->value); #endif #ifdef DEBUG #ifdef WIN32 errstr = GetLastError(); #else errstr = dlerror(); #endif fprintf(stderr,"Function loaded %s\n",errstr); #endif #ifdef DEBUG fprintf(stderr,"Now run the function \n"); fflush(stderr); #endif *eres=execute(&m,&request_input_real_format,&request_output_real_format); #ifdef DEBUG fprintf(stderr,"Function loaded and returned %d\n",eres); fflush(stderr); #endif } #ifdef WIN32 *ioutputs=dupMaps(&request_output_real_format); FreeLibrary(so); #else dlclose(so); #endif } else { /** * Unable to load the specified shared library */ char tmps[1024]; #ifdef WIN32 DWORD errstr = GetLastError(); #else char* errstr = dlerror(); #endif sprintf(tmps,_("C Library can't be loaded %s \n"),errstr); map* tmps1=createMap("text",tmps); printExceptionReportResponse(m,tmps1); *eres=-1; } } else #ifdef USE_PYTHON if(strncasecmp(r_inputs->value,"PYTHON",6)==0){ *eres=zoo_python_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format); } else #endif #ifdef USE_JAVA if(strncasecmp(r_inputs->value,"JAVA",4)==0){ *eres=zoo_java_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format); } else #endif #ifdef USE_PHP if(strncasecmp(r_inputs->value,"PHP",3)==0){ *eres=zoo_php_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format); } else #endif #ifdef USE_PERL if(strncasecmp(r_inputs->value,"PERL",4)==0){ *eres=zoo_perl_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format); } else #endif #ifdef USE_JS if(strncasecmp(r_inputs->value,"JS",2)==0){ *eres=zoo_js_support(&m,request_inputs,s1,&request_input_real_format,&request_output_real_format); } else #endif { char tmpv[1024]; sprintf(tmpv,_("Programming Language (%s) set in ZCFG file is not currently supported by ZOO Kernel.\n"),r_inputs->value); map* tmps=createMap("text",tmpv); printExceptionReportResponse(m,tmps); *eres=-1; } *myMap=m; #ifndef WIN32 *ioutputs=request_output_real_format; #endif } #ifdef WIN32 /** * createProcess function: create a new process after setting some env variables */ void createProcess(maps* m,map* request_inputs,service* s1,char* opts,int cpid, maps* inputs,maps* outputs){ STARTUPINFO si; PROCESS_INFORMATION pi; ZeroMemory( &si, sizeof(si) ); si.cb = sizeof(si); ZeroMemory( &pi, sizeof(pi) ); char *tmp=(char *)malloc((1024+cgiContentLength)*sizeof(char)); char *tmpq=(char *)malloc((1024+cgiContentLength)*sizeof(char)); map *req=getMap(request_inputs,"request"); map *id=getMap(request_inputs,"identifier"); map *di=getMap(request_inputs,"DataInputs"); char *dataInputsKVP=getMapsAsKVP(inputs,cgiContentLength,0); char *dataOutputsKVP=getMapsAsKVP(outputs,cgiContentLength,1); fprintf(stderr,"DATAINPUTSKVP %s\n",dataInputsKVP); fprintf(stderr,"DATAOUTPUTSKVP %s\n",dataOutputsKVP); map *sid=getMapFromMaps(m,"lenv","sid"); map* r_inputs=getMapFromMaps(m,"main","tmpPath"); map* r_inputs1=getMap(s1->content,"ServiceProvider"); map* r_inputs2=getMap(s1->content,"ResponseDocument"); if(r_inputs2==NULL) r_inputs2=getMap(s1->content,"RawDataOutput"); map *tmpPath=getMapFromMaps(m,"lenv","cwd"); if(r_inputs2!=NULL){ sprintf(tmp,"\"request=%s&service=WPS&version=1.0.0&Identifier=%s&DataInputs=%s&%s=%s&cgiSid=%s\"",req->value,id->value,dataInputsKVP,r_inputs2->name,r_inputs2->value,sid->value); sprintf(tmpq,"request=%s&service=WPS&version=1.0.0&Identifier=%s&DataInputs=%s&%s=%s",req->value,id->value,dataInputsKVP,r_inputs2->name,dataOutputsKVP); } else{ sprintf(tmp,"\"request=%s&service=WPS&version=1.0.0&Identifier=%s&DataInputs=%s&cgiSid=%s\"",req->value,id->value,dataInputsKVP,sid->value); sprintf(tmpq,"request=%s&service=WPS&version=1.0.0&Identifier=%s&DataInputs=%s",req->value,id->value,dataInputsKVP,sid->value); } char *tmp1=strdup(tmp); sprintf(tmp,"zoo_loader.cgi %s \"%s\"",tmp1,sid->value); free(dataInputsKVP); free(dataOutputsKVP); fprintf(stderr,"REQUEST IS : %s \n",tmp); SetEnvironmentVariable("CGISID",TEXT(sid->value)); SetEnvironmentVariable("QUERY_STRING",TEXT(tmpq)); char clen[1000]; sprintf(clen,"%d",strlen(tmpq)); SetEnvironmentVariable("CONTENT_LENGTH",TEXT(clen)); if( !CreateProcess( NULL, // No module name (use command line) TEXT(tmp), // Command line NULL, // Process handle not inheritable NULL, // Thread handle not inheritable FALSE, // Set handle inheritance to FALSE CREATE_NO_WINDOW, // Apache won't wait until the end NULL, // Use parent's environment block NULL, // Use parent's starting directory &si, // Pointer to STARTUPINFO struct &pi ) // Pointer to PROCESS_INFORMATION struct ) { fprintf( stderr, "CreateProcess failed (%d).\n", GetLastError() ); return ; }else{ fprintf( stderr, "CreateProcess successfull (%d).\n\n\n\n", GetLastError() ); } CloseHandle( pi.hProcess ); CloseHandle( pi.hThread ); fprintf(stderr,"CreateProcess finished !\n"); } #endif int runRequest(map* request_inputs) { #ifndef USE_GDB (void) signal(SIGSEGV,sig_handler); (void) signal(SIGTERM,sig_handler); (void) signal(SIGINT,sig_handler); (void) signal(SIGILL,sig_handler); (void) signal(SIGFPE,sig_handler); (void) signal(SIGABRT,sig_handler); #endif map* r_inputs=NULL; maps* m=NULL; char* REQUEST=NULL; /** * Parsing service specfic configuration file */ m=(maps*)calloc(1,MAPS_SIZE); if(m == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } char ntmp[1024]; #ifndef WIN32 char *pntmp=getcwd(ntmp,1024); #else _getcwd(ntmp,1024); #endif r_inputs=getMapOrFill(request_inputs,"metapath",""); char conf_file[10240]; snprintf(conf_file,10240,"%s/%s/main.cfg",ntmp,r_inputs->value); conf_read(conf_file,m); #ifdef DEBUG fprintf(stderr, "***** BEGIN MAPS\n"); dumpMaps(m); fprintf(stderr, "***** END MAPS\n"); #endif bindtextdomain ("zoo-kernel","/usr/share/locale/"); bindtextdomain ("zoo-services","/usr/share/locale/"); if((r_inputs=getMap(request_inputs,"language"))!=NULL){ char *tmp=strdup(r_inputs->value); translateChar(tmp,'-','_'); setlocale (LC_ALL, tmp); free(tmp); setMapInMaps(m,"main","language",r_inputs->value); } else{ setlocale (LC_ALL, "en_US"); setMapInMaps(m,"main","language","en-US"); } setlocale (LC_NUMERIC, "en_US"); bind_textdomain_codeset("zoo-kernel","UTF-8"); textdomain("zoo-kernel"); bind_textdomain_codeset("zoo-services","UTF-8"); textdomain("zoo-services"); map* lsoap=getMap(request_inputs,"soap"); if(lsoap!=NULL && strcasecmp(lsoap->value,"true")==0) setMapInMaps(m,"main","isSoap","true"); else setMapInMaps(m,"main","isSoap","false"); /** * Check for minimum inputs */ r_inputs=getMap(request_inputs,"Request"); if(request_inputs==NULL || r_inputs==NULL){ errorException(m, _("Parameter was not specified"),"MissingParameterValue"); freeMaps(&m); free(m); freeMap(&request_inputs); free(request_inputs); free(REQUEST); return 1; } else{ REQUEST=strdup(r_inputs->value); if(strncasecmp(r_inputs->value,"GetCapabilities",15)!=0 && strncasecmp(r_inputs->value,"DescribeProcess",15)!=0 && strncasecmp(r_inputs->value,"Execute",7)!=0){ errorException(m, _("Unenderstood value. Please check that it was set to GetCapabilities, DescribeProcess or Execute."), "InvalidParameterValue"); freeMaps(&m); free(m); free(REQUEST); return 1; } } r_inputs=NULL; r_inputs=getMap(request_inputs,"Service"); if(r_inputs==NULLMAP){ errorException(m, _("Parameter was not specified"),"MissingParameterValue"); freeMaps(&m); free(m); free(REQUEST); return 1; } if(strncasecmp(REQUEST,"GetCapabilities",15)!=0){ r_inputs=getMap(request_inputs,"Version"); if(r_inputs==NULL){ errorException(m, _("Parameter was not specified"),"MissingParameterValue"); freeMaps(&m); free(m); free(REQUEST); return 1; } } r_inputs=getMap(request_inputs,"serviceprovider"); if(r_inputs==NULL){ addToMap(request_inputs,"serviceprovider",""); } maps* request_output_real_format=NULL; map* tmpm=getMapFromMaps(m,"main","serverAddress"); if(tmpm!=NULL) SERVICE_URL=strdup(tmpm->value); else SERVICE_URL=strdup(DEFAULT_SERVICE_URL); service* s1; int scount=0; #ifdef DEBUG dumpMap(r_inputs); #endif char conf_dir[1024]; int t; char tmps1[1024]; r_inputs=NULL; r_inputs=getMap(request_inputs,"metapath"); if(r_inputs!=NULL) snprintf(conf_dir,1024,"%s/%s",ntmp,r_inputs->value); else snprintf(conf_dir,1024,"%s",ntmp); if(strncasecmp(REQUEST,"GetCapabilities",15)==0){ struct dirent *dp; #ifdef DEBUG dumpMap(r_inputs); #endif DIR *dirp = opendir(conf_dir); if(dirp==NULL){ return errorException(m, _("The specified path doesn't exist."),"InvalidParameterValue"); } xmlDocPtr doc = xmlNewDoc(BAD_CAST "1.0"); r_inputs=NULL; r_inputs=getMap(request_inputs,"ServiceProvider"); xmlNodePtr n; if(r_inputs!=NULL) n = printGetCapabilitiesHeader(doc,r_inputs->value,m); else n = printGetCapabilitiesHeader(doc,"",m); /** * Here we need to close stdout to ensure that not supported chars * has been found in the zcfg and then printed on stdout */ int saved_stdout = dup(fileno(stdout)); dup2(fileno(stderr),fileno(stdout)); while ((dp = readdir(dirp)) != NULL) if(strstr(dp->d_name,".zcfg")!=0){ memset(tmps1,0,1024); snprintf(tmps1,1024,"%s/%s",conf_dir,dp->d_name); s1=(service*)calloc(1,SERVICE_SIZE); if(s1 == NULL){ return errorException(m, _("Unable to allocate memory."),"InternalError"); } #ifdef DEBUG fprintf(stderr,"#################\n%s\n#################\n",tmps1); #endif t=getServiceFromFile(tmps1,&s1); #ifdef DEBUG dumpService(s1); fflush(stdout); fflush(stderr); #endif printGetCapabilitiesForProcess(m,n,s1); freeService(&s1); free(s1); scount++; } (void)closedir(dirp); fflush(stdout); dup2(saved_stdout,fileno(stdout)); printDocument(m,doc,getpid()); freeMaps(&m); free(m); free(REQUEST); free(SERVICE_URL); fflush(stdout); return 0; } else{ r_inputs=getMap(request_inputs,"Identifier"); if(r_inputs==NULL || strlen(r_inputs->name)==0 || strlen(r_inputs->value)==0){ errorException(m, _("Mandatory was not specified"),"MissingParameterValue"); freeMaps(&m); free(m); free(REQUEST); free(SERVICE_URL); return 0; } struct dirent *dp; DIR *dirp = opendir(conf_dir); if(dirp==NULL){ errorException(m, _("The specified path path doesn't exist."),"InvalidParameterValue"); freeMaps(&m); free(m); free(REQUEST); free(SERVICE_URL); return 0; } if(strncasecmp(REQUEST,"DescribeProcess",15)==0){ /** * Loop over Identifier list */ xmlDocPtr doc = xmlNewDoc(BAD_CAST "1.0"); r_inputs=NULL; r_inputs=getMap(request_inputs,"ServiceProvider"); xmlNodePtr n; if(r_inputs!=NULL) n = printDescribeProcessHeader(doc,r_inputs->value,m); else n = printDescribeProcessHeader(doc,"",m); r_inputs=getMap(request_inputs,"Identifier"); char *tmps=strtok(r_inputs->value,","); char buff[256]; char buff1[1024]; int saved_stdout = dup(fileno(stdout)); dup2(fileno(stderr),fileno(stdout)); while(tmps){ memset(buff,0,256); snprintf(buff,256,"%s.zcfg",tmps); memset(buff1,0,1024); #ifdef DEBUG fprintf(stderr,"\n#######%s\n########\n",buff1); #endif while ((dp = readdir(dirp)) != NULL) if((strcasecmp("all.zcfg",buff)==0 && strstr(dp->d_name,".zcfg")>0) || strcasecmp(dp->d_name,buff)==0){ memset(buff1,0,1024); snprintf(buff1,1024,"%s/%s",conf_dir,dp->d_name); s1=(service*)calloc(1,SERVICE_SIZE); if(s1 == NULL){ return errorException(m, _("Unable to allocate memory."),"InternalError"); } #ifdef DEBUG fprintf(stderr,"#################\n%s\n#################\n",buff1); #endif t=getServiceFromFile(buff1,&s1); #ifdef DEBUG dumpService(s1); #endif printDescribeProcessForProcess(m,n,s1,1); freeService(&s1); free(s1); scount++; } rewinddir(dirp); tmps=strtok(NULL,","); } closedir(dirp); fflush(stdout); dup2(saved_stdout,fileno(stdout)); printDocument(m,doc,getpid()); freeMaps(&m); free(m); free(REQUEST); free(SERVICE_URL); fflush(stdout); #ifndef LINUX_FREE_ISSUE if(s1) free(s1); #endif return 0; } else if(strncasecmp(REQUEST,"Execute",strlen(REQUEST))!=0){ errorException(m, _("Unenderstood value. Please check that it was set to GetCapabilities, DescribeProcess or Execute."), "InvalidParameterValue"); #ifdef DEBUG fprintf(stderr,"No request found %s",REQUEST); #endif closedir(dirp); return 0; } closedir(dirp); } s1=NULL; s1=(service*)calloc(1,SERVICE_SIZE); if(s1 == NULL){ freeMaps(&m); free(m); free(REQUEST); free(SERVICE_URL); return errorException(m, _("Unable to allocate memory."),"InternalError"); } r_inputs=getMap(request_inputs,"MetaPath"); if(r_inputs!=NULL) snprintf(tmps1,1024,"%s/%s",ntmp,r_inputs->value); else snprintf(tmps1,1024,"%s/",ntmp); r_inputs=getMap(request_inputs,"Identifier"); char *ttmp=strdup(tmps1); snprintf(tmps1,1024,"%s/%s.zcfg",ttmp,r_inputs->value); free(ttmp); #ifdef DEBUG fprintf(stderr,"Trying to load %s\n", tmps1); #endif int saved_stdout = dup(fileno(stdout)); dup2(fileno(stderr),fileno(stdout)); t=getServiceFromFile(tmps1,&s1); fflush(stdout); dup2(saved_stdout,fileno(stdout)); if(t<0){ char *tmpMsg=(char*)malloc(2048+strlen(r_inputs->value)); sprintf(tmpMsg,_("The value for seems to be wrong (%s). Please, ensure that the process exist using the GetCapabilities request."),r_inputs->value); errorException(m, tmpMsg, "InvalidParameterValue"); free(tmpMsg); freeService(&s1); free(s1); freeMaps(&m); free(m); free(REQUEST); free(SERVICE_URL); return 0; } close(saved_stdout); #ifdef DEBUG dumpService(s1); #endif int j; /** * Create the input maps data structure */ int i=0; HINTERNET hInternet; HINTERNET res; hInternet=InternetOpen( #ifndef WIN32 (LPCTSTR) #endif "ZooWPSClient\0", INTERNET_OPEN_TYPE_PRECONFIG, NULL,NULL, 0); #ifndef WIN32 if(!CHECK_INET_HANDLE(hInternet)) fprintf(stderr,"WARNING : hInternet handle failed to initialize"); #endif maps* request_input_real_format=NULL; maps* tmpmaps = request_input_real_format; map* postRequest=NULL; postRequest=getMap(request_inputs,"xrequest"); if(postRequest==NULLMAP){ /** * Parsing outputs provided as KVP */ r_inputs=NULL; #ifdef DEBUG fprintf(stderr,"OUTPUT Parsing ... \n"); #endif r_inputs=getMap(request_inputs,"ResponseDocument"); if(r_inputs==NULL) r_inputs=getMap(request_inputs,"RawDataOutput"); #ifdef DEBUG fprintf(stderr,"OUTPUT Parsing ... \n"); #endif if(r_inputs!=NULL){ #ifdef DEBUG fprintf(stderr,"OUTPUT Parsing start now ... \n"); #endif char cursor_output[10240]; char *cotmp=strdup(r_inputs->value); snprintf(cursor_output,10240,"%s",cotmp); free(cotmp); j=0; /** * Put each Output into the outputs_as_text array */ char * pToken; maps* tmp_output=NULL; #ifdef DEBUG fprintf(stderr,"OUTPUT [%s]\n",cursor_output); #endif pToken=strtok(cursor_output,";"); char** outputs_as_text=(char**)calloc(128,sizeof(char*)); if(outputs_as_text == NULL) { return errorException(m, _("Unable to allocate memory"), "InternalError"); } i=0; while(pToken!=NULL){ #ifdef DEBUG fprintf(stderr,"***%s***\n",pToken); fflush(stderr); fprintf(stderr,"***%s***\n",pToken); #endif outputs_as_text[i]=(char*)calloc(strlen(pToken)+1,sizeof(char)); if(outputs_as_text[i] == NULL) { return errorException(m, _("Unable to allocate memory"), "InternalError"); } snprintf(outputs_as_text[i],strlen(pToken)+1,"%s",pToken); pToken = strtok(NULL,";"); i++; } for(j=0;jname=strdup(tmpc); tmp_output->content=NULL; tmp_output->next=NULL; } } else{ char *tmpv=strstr(tmpc,"="); char tmpn[256]; memset(tmpn,0,256); strncpy(tmpn,tmpc,(strlen(tmpc)-strlen(tmpv))*sizeof(char)); tmpn[strlen(tmpc)-strlen(tmpv)]=0; #ifdef DEBUG fprintf(stderr,"OUTPUT DEF [%s]=[%s]\n",tmpn,tmpv+1); #endif if(tmp_output->content==NULL){ tmp_output->content=createMap(tmpn,tmpv+1); tmp_output->content->next=NULL; } else addToMap(tmp_output->content,tmpn,tmpv+1); } k++; #ifdef DEBUG fprintf(stderr,"***%s***\n",tmpc); #endif tmpc=strtok(NULL,"@"); } if(request_output_real_format==NULL) request_output_real_format=dupMaps(&tmp_output); else addMapsToMaps(&request_output_real_format,tmp_output); freeMaps(&tmp_output); free(tmp_output); tmp_output=NULL; #ifdef DEBUG dumpMaps(tmp_output); fflush(stderr); #endif free(tmp); } free(outputs_as_text); } /** * Parsing inputs provided as KVP */ r_inputs=getMap(request_inputs,"DataInputs"); #ifdef DEBUG fprintf(stderr,"DATA INPUTS [%s]\n",r_inputs->value); #endif char cursor_input[40960]; if(r_inputs!=NULL) snprintf(cursor_input,40960,"%s",r_inputs->value); else{ errorException(m, _("Parameter was not specified"),"MissingParameterValue"); freeMaps(&m); free(m); free(REQUEST); free(SERVICE_URL); InternetCloseHandle(hInternet); freeService(&s1); free(s1); return 0; } j=0; /** * Put each DataInputs into the inputs_as_text array */ char * pToken; pToken=strtok(cursor_input,";"); char** inputs_as_text=(char**)calloc(100,sizeof(char*)); if(inputs_as_text == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } i=0; while(pToken!=NULL){ #ifdef DEBUG fprintf(stderr,"***%s***\n",pToken); #endif fflush(stderr); #ifdef DEBUG fprintf(stderr,"***%s***\n",pToken); #endif inputs_as_text[i]=(char*)calloc(strlen(pToken)+1,sizeof(char)); snprintf(inputs_as_text[i],strlen(pToken)+1,"%s",pToken); if(inputs_as_text[i] == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } pToken = strtok(NULL,";"); i++; } for(j=0;jname=strdup(tmpn); if(tmpv!=NULL) tmpmaps->content=createMap("value",tmpv+1); else tmpmaps->content=createMap("value","Reference"); tmpmaps->next=NULL; } tmpc=strtok(NULL,"@"); while(tmpc!=NULL){ #ifdef DEBUG fprintf(stderr,"*** KVP NON URL-ENCODED \n***%s***\n",tmpc); #endif char *tmpv1=strstr(tmpc,"="); #ifdef DEBUG fprintf(stderr,"*** VALUE NON URL-ENCODED \n***%s***\n",tmpv1+1); #endif char tmpn1[1024]; memset(tmpn1,0,1024); if(tmpv1!=NULL){ strncpy(tmpn1,tmpc,strlen(tmpc)-strlen(tmpv1)); tmpn1[strlen(tmpc)-strlen(tmpv1)]=0; addToMap(tmpmaps->content,tmpn1,tmpv1+1); } else{ strncpy(tmpn1,tmpc,strlen(tmpc)); tmpn1[strlen(tmpc)]=0; map* lmap=getLastMap(tmpmaps->content); char *tmpValue=(char*)calloc((strlen(lmap->value)+strlen(tmpc)+1),sizeof(char)); sprintf(tmpValue,"%s@%s",lmap->value,tmpc); free(lmap->value); lmap->value=strdup(tmpValue); free(tmpValue); tmpc=strtok(NULL,"@"); continue; } #ifdef DEBUG fprintf(stderr,"*** NAME NON URL-ENCODED \n***%s***\n",tmpn1); fprintf(stderr,"*** VALUE NON URL-ENCODED \n***%s***\n",tmpv1+1); #endif if(strcmp(tmpn1,"xlink:href")!=0) addToMap(tmpmaps->content,tmpn1,tmpv1+1); else if(tmpv1!=NULL){ if(strncasecmp(tmpv1+1,"http://",7)!=0 && strncasecmp(tmpv1+1,"ftp://",6)!=0){ char emsg[1024]; sprintf(emsg,_("Unable to find a valid protocol to download the remote file %s"),tmpv1+1); errorException(m,emsg,"InternalError"); freeMaps(&m); free(m); free(REQUEST); free(SERVICE_URL); InternetCloseHandle(hInternet); freeService(&s1); free(s1); return 0; } #ifdef DEBUG fprintf(stderr,"REQUIRE TO DOWNLOAD A FILE FROM A SERVER : url(%s)\n",tmpv1+1); #endif char *tmpx=url_encode(tmpv1+1); addToMap(tmpmaps->content,tmpn1,tmpx); #ifndef WIN32 if(CHECK_INET_HANDLE(hInternet)) #endif { loadRemoteFile(m,tmpmaps->content,hInternet,tmpv1+1); } char *tmpx1=url_encode(tmpv1+1); addToMap(tmpmaps->content,tmpn1,tmpx1); free(tmpx1); addToMap(tmpmaps->content,"Reference",tmpv1+1); } tmpc=strtok(NULL,"@"); } #ifdef DEBUG dumpMaps(tmpmaps); fflush(stderr); #endif if(request_input_real_format==NULL) request_input_real_format=dupMaps(&tmpmaps); else addMapsToMaps(&request_input_real_format,tmpmaps); freeMaps(&tmpmaps); free(tmpmaps); tmpmaps=NULL; free(tmp); } } free(inputs_as_text); } else { /** * Parse XML request */ xmlInitParser(); #ifdef DEBUG fflush(stderr); fprintf(stderr,"BEFORE %s\n",postRequest->value); fflush(stderr); #endif xmlDocPtr doc = xmlParseMemory(postRequest->value,cgiContentLength); #ifdef DEBUG fprintf(stderr,"AFTER\n"); fflush(stderr); #endif /** * Parse every Input in DataInputs node. */ xmlXPathObjectPtr tmpsptr=extractFromDoc(doc,"/*/*/*[local-name()='Input']"); xmlNodeSet* tmps=tmpsptr->nodesetval; #ifdef DEBUG fprintf(stderr,"*****%d*****\n",tmps->nodeNr); #endif for(int k=0;knodeNr;k++){ maps *tmpmaps=NULL; xmlNodePtr cur=tmps->nodeTab[k]; if(tmps->nodeTab[k]->type == XML_ELEMENT_NODE) { /** * A specific Input node. */ #ifdef DEBUG fprintf(stderr, "= element 0 node \"%s\"\n", cur->name); #endif xmlNodePtr cur2=cur->children; while(cur2!=NULL){ while(cur2!=NULL && cur2->type!=XML_ELEMENT_NODE) cur2=cur2->next; if(cur2==NULL) break; /** * Indentifier */ if(xmlStrncasecmp(cur2->name,BAD_CAST "Identifier",xmlStrlen(cur2->name))==0){ xmlChar *val= xmlNodeListGetString(doc,cur2->xmlChildrenNode,1); if(tmpmaps==NULL){ tmpmaps=(maps*)calloc(1,MAPS_SIZE); if(tmpmaps == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } tmpmaps->name=strdup((char*)val); tmpmaps->content=NULL; tmpmaps->next=NULL; } xmlFree(val); } /** * Title, Asbtract */ if(xmlStrncasecmp(cur2->name,BAD_CAST "Title",xmlStrlen(cur2->name))==0 || xmlStrncasecmp(cur2->name,BAD_CAST "Abstract",xmlStrlen(cur2->name))==0){ xmlChar *val= xmlNodeListGetString(doc,cur2->xmlChildrenNode,1); if(tmpmaps==NULL){ tmpmaps=(maps*)calloc(1,MAPS_SIZE); if(tmpmaps == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } tmpmaps->name=strdup("missingIndetifier"); tmpmaps->content=createMap((char*)cur2->name,(char*)val); tmpmaps->next=NULL; } else{ if(tmpmaps->content!=NULL) addToMap(tmpmaps->content, (char*)cur2->name,(char*)val); else tmpmaps->content= createMap((char*)cur2->name,(char*)val); } #ifdef DEBUG dumpMaps(tmpmaps); #endif xmlFree(val); } /** * InputDataFormChoice (Reference or Data ?) */ if(xmlStrcasecmp(cur2->name,BAD_CAST "Reference")==0){ /** * Get every attribute from a Reference node * mimeType, encoding, schema, href, method * Header and Body gesture should be added here */ #ifdef DEBUG fprintf(stderr,"REFERENCE\n"); #endif const char *refs[5]={"mimeType","encoding","schema","method","href"}; for(int l=0;l<5;l++){ #ifdef DEBUG fprintf(stderr,"*** %s ***",refs[l]); #endif xmlChar *val=xmlGetProp(cur2,BAD_CAST refs[l]); if(val!=NULL && xmlStrlen(val)>0){ if(tmpmaps->content!=NULL) addToMap(tmpmaps->content,refs[l],(char*)val); else tmpmaps->content=createMap(refs[l],(char*)val); map* ltmp=getMap(tmpmaps->content,"method"); if(l==4){ if(!(ltmp!=NULL && strcmp(ltmp->value,"POST")==0) && CHECK_INET_HANDLE(hInternet)){ loadRemoteFile(m,tmpmaps->content,hInternet,(char*)val); } } } #ifdef DEBUG fprintf(stderr,"%s\n",val); #endif xmlFree(val); } #ifdef POST_DEBUG fprintf(stderr,"Parse Header and Body from Reference \n"); #endif xmlNodePtr cur3=cur2->children; hInternet.header=NULL; while(cur3){ while(cur3!=NULL && cur3->type!=XML_ELEMENT_NODE) cur2=cur3->next; if(xmlStrcasecmp(cur3->name,BAD_CAST "Header")==0 ){ const char *ha[2]; ha[0]="key"; ha[1]="value"; int hai; char *has; char *key; for(hai=0;hai<2;hai++){ xmlChar *val=xmlGetProp(cur3,BAD_CAST ha[hai]); #ifdef POST_DEBUG fprintf(stderr,"%s = %s\n",ha[hai],(char*)val); #endif if(hai==0){ key=(char*)calloc((1+strlen((char*)val)),sizeof(char)); snprintf(key,1+strlen((char*)val),"%s",(char*)val); }else{ has=(char*)calloc((3+strlen((char*)val)+strlen(key)),sizeof(char)); if(has == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } snprintf(has,(3+strlen((char*)val)+strlen(key)),"%s: %s",key,(char*)val); #ifdef POST_DEBUG fprintf(stderr,"%s\n",has); #endif } } hInternet.header=curl_slist_append(hInternet.header, has); free(has); } else{ #ifdef POST_DEBUG fprintf(stderr,"Try to fetch the body part of the request ...\n"); #endif if(xmlStrcasecmp(cur3->name,BAD_CAST "Body")==0 ){ #ifdef POST_DEBUG fprintf(stderr,"Body part found !!!\n",(char*)cur3->content); #endif char *tmp=new char[cgiContentLength]; memset(tmp,0,cgiContentLength); xmlNodePtr cur4=cur3->children; while(cur4!=NULL){ while(cur4->type!=XML_ELEMENT_NODE) cur4=cur4->next; xmlDocPtr bdoc = xmlNewDoc(BAD_CAST "1.0"); bdoc->encoding = xmlCharStrdup ("UTF-8"); xmlDocSetRootElement(bdoc,cur4); xmlChar* btmps; int bsize; xmlDocDumpMemory(bdoc,&btmps,&bsize); #ifdef POST_DEBUG fprintf(stderr,"Body part found !!! %s %s\n",tmp,(char*)btmps); #endif if(btmps!=NULL) sprintf(tmp,"%s",(char*)btmps); xmlFreeDoc(bdoc); cur4=cur4->next; } map *btmp=getMap(tmpmaps->content,"href"); if(btmp!=NULL){ #ifdef POST_DEBUG fprintf(stderr,"%s %s\n",btmp->value,tmp); curl_easy_setopt(hInternet.handle, CURLOPT_VERBOSE, 1); #endif res=InternetOpenUrl(hInternet,btmp->value,tmp,strlen(tmp), INTERNET_FLAG_NO_CACHE_WRITE,0); char* tmpContent = (char*)calloc((res.nDataLen+1),sizeof(char)); if(tmpContent == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } size_t dwRead; InternetReadFile(res, (LPVOID)tmpContent, res.nDataLen, &dwRead); tmpContent[res.nDataLen]=0; if(hInternet.header!=NULL) curl_slist_free_all(hInternet.header); addToMap(tmpmaps->content,"value",tmpContent); #ifdef POST_DEBUG fprintf(stderr,"DL CONTENT : (%s)\n",tmpContent); #endif } } else if(xmlStrcasecmp(cur3->name,BAD_CAST "BodyReference")==0 ){ xmlChar *val=xmlGetProp(cur3,BAD_CAST "href"); HINTERNET bInternet,res1; bInternet=InternetOpen( #ifndef WIN32 (LPCTSTR) #endif "ZooWPSClient\0", INTERNET_OPEN_TYPE_PRECONFIG, NULL,NULL, 0); if(!CHECK_INET_HANDLE(bInternet)) fprintf(stderr,"WARNING : hInternet handle failed to initialize"); #ifdef POST_DEBUG curl_easy_setopt(bInternet.handle, CURLOPT_VERBOSE, 1); #endif res1=InternetOpenUrl(bInternet,(char*)val,NULL,0, INTERNET_FLAG_NO_CACHE_WRITE,0); char* tmp= (char*)calloc((res1.nDataLen+1),sizeof(char)); if(tmp == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } size_t bRead; InternetReadFile(res1, (LPVOID)tmp, res1.nDataLen, &bRead); tmp[res1.nDataLen]=0; InternetCloseHandle(bInternet); map *btmp=getMap(tmpmaps->content,"href"); if(btmp!=NULL){ #ifdef POST_DEBUG fprintf(stderr,"%s %s\n",btmp->value,tmp); curl_easy_setopt(hInternet.handle, CURLOPT_VERBOSE, 1); #endif res=InternetOpenUrl(hInternet,btmp->value,tmp, strlen(tmp), INTERNET_FLAG_NO_CACHE_WRITE,0); char* tmpContent = (char*)calloc((res.nDataLen+1),sizeof(char)); if(tmpContent == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } size_t dwRead; InternetReadFile(res, (LPVOID)tmpContent, res.nDataLen, &dwRead); tmpContent[res.nDataLen]=0; if(hInternet.header!=NULL) curl_slist_free_all(hInternet.header); addToMap(tmpmaps->content,"value",tmpContent); #ifdef POST_DEBUG fprintf(stderr,"DL CONTENT : (%s)\n",tmpContent); #endif } } } cur3=cur3->next; } #ifdef POST_DEBUG fprintf(stderr,"Header and Body was parsed from Reference \n"); #endif #ifdef DEBUG dumpMap(tmpmaps->content); fprintf(stderr, "= element 2 node \"%s\" = (%s)\n", cur2->name,cur2->content); #endif } else if(xmlStrcasecmp(cur2->name,BAD_CAST "Data")==0){ #ifdef DEBUG fprintf(stderr,"DATA\n"); #endif xmlNodePtr cur4=cur2->children; while(cur4!=NULL){ while(cur4!=NULL &&cur4->type!=XML_ELEMENT_NODE) cur4=cur4->next; if(cur4==NULL) break; if(xmlStrcasecmp(cur4->name, BAD_CAST "LiteralData")==0){ /** * Get every attribute from a LiteralData node * dataType , uom */ char *list[2]; list[0]=strdup("dataType"); list[1]=strdup("uom"); for(int l=0;l<2;l++){ #ifdef DEBUG fprintf(stderr,"*** LiteralData %s ***",list[l]); #endif xmlChar *val=xmlGetProp(cur4,BAD_CAST list[l]); if(val!=NULL && strlen((char*)val)>0){ if(tmpmaps->content!=NULL) addToMap(tmpmaps->content,list[l],(char*)val); else tmpmaps->content=createMap(list[l],(char*)val); #ifdef DEBUG fprintf(stderr,"%s\n",val); #endif } xmlFree(val); free(list[l]); } } else if(xmlStrcasecmp(cur4->name, BAD_CAST "ComplexData")==0){ /** * Get every attribute from a Reference node * mimeType, encoding, schema */ const char *coms[3]={"mimeType","encoding","schema"}; for(int l=0;l<3;l++){ #ifdef DEBUG fprintf(stderr,"*** ComplexData %s ***\n",coms[l]); #endif xmlChar *val=xmlGetProp(cur4,BAD_CAST coms[l]); if(val!=NULL && strlen((char*)val)>0){ if(tmpmaps->content!=NULL) addToMap(tmpmaps->content,coms[l],(char*)val); else tmpmaps->content=createMap(coms[l],(char*)val); #ifdef DEBUG fprintf(stderr,"%s\n",val); #endif } xmlFree(val); } } map* test=getMap(tmpmaps->content,"encoding"); if(test==NULL){ if(tmpmaps->content!=NULL) addToMap(tmpmaps->content,"encoding","utf-8"); else tmpmaps->content=createMap("encoding","utf-8"); test=getMap(tmpmaps->content,"encoding"); } if(strcasecmp(test->value,"base64")!=0){ xmlChar* mv=xmlNodeListGetString(doc,cur4->xmlChildrenNode,1); map* ltmp=getMap(tmpmaps->content,"mimeType"); if(mv==NULL || (xmlStrcasecmp(cur4->name, BAD_CAST "ComplexData")==0 && (ltmp==NULL || strncasecmp(ltmp->value,"text/xml",8)==0) )){ xmlDocPtr doc1=xmlNewDoc(BAD_CAST "1.0"); int buffersize; xmlNodePtr cur5=cur4->children; while(cur5!=NULL &&cur5->type!=XML_ELEMENT_NODE) cur5=cur5->next; xmlDocSetRootElement(doc1,cur5); xmlDocDumpFormatMemoryEnc(doc1, &mv, &buffersize, "utf-8", 1); char size[1024]; sprintf(size,"%d",buffersize); addToMap(tmpmaps->content,"size",size); } addToMap(tmpmaps->content,"value",(char*)mv); xmlFree(mv); }else{ xmlChar* tmp=xmlNodeListGetRawString(doc,cur4->xmlChildrenNode,0); addToMap(tmpmaps->content,"value",(char*)tmp); map* tmpv=getMap(tmpmaps->content,"value"); char *res=NULL; char *curs=tmpv->value; for(int i=0;i<=strlen(tmpv->value)/64;i++) { if(res==NULL) res=(char*)malloc(67*sizeof(char)); else res=(char*)realloc(res,(((i+1)*65)+i)*sizeof(char)); int csize=i*65; strncpy(res + csize,curs,64); if(i==xmlStrlen(tmp)/64) strcat(res,"\n\0"); else{ strncpy(res + (((i+1)*64)+i),"\n\0",2); curs+=64; } } free(tmpv->value); tmpv->value=strdup(res); free(res); xmlFree(tmp); } cur4=cur4->next; } } #ifdef DEBUG fprintf(stderr,"cur2 next \n"); fflush(stderr); #endif cur2=cur2->next; } #ifdef DEBUG fprintf(stderr,"ADD MAPS TO REQUEST MAPS !\n"); fflush(stderr); #endif addMapsToMaps(&request_input_real_format,tmpmaps); #ifdef DEBUG fprintf(stderr,"******TMPMAPS*****\n"); dumpMaps(tmpmaps); fprintf(stderr,"******REQUESTMAPS*****\n"); dumpMaps(request_input_real_format); #endif freeMaps(&tmpmaps); free(tmpmaps); tmpmaps=NULL; } #ifdef DEBUG dumpMaps(tmpmaps); #endif } #ifdef DEBUG fprintf(stderr,"Search for response document node\n"); #endif xmlXPathFreeObject(tmpsptr); tmpsptr=extractFromDoc(doc,"/*/*/*[local-name()='ResponseDocument']"); bool asRaw=false; tmps=tmpsptr->nodesetval; if(tmps->nodeNr==0){ tmpsptr=extractFromDoc(doc,"/*/*/*[local-name()='RawDataOutput']"); tmps=tmpsptr->nodesetval; asRaw=true; } #ifdef DEBUG fprintf(stderr,"*****%d*****\n",tmps->nodeNr); #endif for(int k=0;knodeNr;k++){ if(asRaw==true) addToMap(request_inputs,"RawDataOutput",""); else addToMap(request_inputs,"ResponseDocument",""); maps *tmpmaps=NULL; xmlNodePtr cur=tmps->nodeTab[k]; if(cur->type == XML_ELEMENT_NODE) { /** * A specific responseDocument node. */ if(tmpmaps==NULL){ tmpmaps=(maps*)calloc(1,MAPS_SIZE); if(tmpmaps == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } tmpmaps->name=strdup("unknownIdentifier"); tmpmaps->next=NULL; } /** * Get every attribute from a LiteralData node * storeExecuteResponse, lineage, status */ const char *ress[3]={"storeExecuteResponse","lineage","status"}; xmlChar *val; for(int l=0;l<3;l++){ #ifdef DEBUG fprintf(stderr,"*** %s ***\t",ress[l]); #endif val=xmlGetProp(cur,BAD_CAST ress[l]); if(val!=NULL && strlen((char*)val)>0){ if(tmpmaps->content!=NULL) addToMap(tmpmaps->content,ress[l],(char*)val); else tmpmaps->content=createMap(ress[l],(char*)val); addToMap(request_inputs,ress[l],(char*)val); } #ifdef DEBUG fprintf(stderr,"%s\n",val); #endif xmlFree(val); } xmlNodePtr cur1=cur->children; while(cur1){ /** * Indentifier */ if(xmlStrncasecmp(cur1->name,BAD_CAST "Identifier",xmlStrlen(cur1->name))==0){ xmlChar *val= xmlNodeListGetString(doc,cur1->xmlChildrenNode,1); if(tmpmaps==NULL){ tmpmaps=(maps*)calloc(1,MAPS_SIZE); if(tmpmaps == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } tmpmaps->name=strdup((char*)val); tmpmaps->content=NULL; tmpmaps->next=NULL; } else tmpmaps->name=strdup((char*)val);; xmlFree(val); } /** * Title, Asbtract */ else if(xmlStrncasecmp(cur1->name,BAD_CAST "Title",xmlStrlen(cur1->name))==0 || xmlStrncasecmp(cur1->name,BAD_CAST "Abstract",xmlStrlen(cur1->name))==0){ xmlChar *val= xmlNodeListGetString(doc,cur1->xmlChildrenNode,1); if(tmpmaps==NULL){ tmpmaps=(maps*)calloc(1,MAPS_SIZE); if(tmpmaps == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } tmpmaps->name=strdup("missingIndetifier"); tmpmaps->content=createMap((char*)cur1->name,(char*)val); tmpmaps->next=NULL; } else{ if(tmpmaps->content!=NULL) addToMap(tmpmaps->content, (char*)cur1->name,(char*)val); else tmpmaps->content= createMap((char*)cur1->name,(char*)val); } xmlFree(val); } else if(xmlStrncasecmp(cur1->name,BAD_CAST "Output",xmlStrlen(cur1->name))==0){ /** * Get every attribute from a Output node * mimeType, encoding, schema, uom, asReference */ const char *outs[5]={"mimeType","encoding","schema","uom","asReference"}; for(int l=0;l<5;l++){ #ifdef DEBUG fprintf(stderr,"*** %s ***\t",outs[l]); #endif val=xmlGetProp(cur1,BAD_CAST outs[l]); if(val!=NULL && strlen((char*)val)>0){ if(tmpmaps->content!=NULL) addToMap(tmpmaps->content,outs[l],(char*)val); else tmpmaps->content=createMap(outs[l],(char*)val); } #ifdef DEBUG fprintf(stderr,"%s\n",val); #endif xmlFree(val); } xmlNodePtr cur2=cur1->children; while(cur2){ /** * Indentifier */ if(xmlStrncasecmp(cur2->name,BAD_CAST "Identifier",xmlStrlen(cur2->name))==0){ xmlChar *val= xmlNodeListGetString(doc,cur2->xmlChildrenNode,1); if(tmpmaps==NULL){ tmpmaps=(maps*)calloc(1,MAPS_SIZE); if(tmpmaps == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } tmpmaps->name=strdup((char*)val); tmpmaps->content=NULL; tmpmaps->next=NULL; } else tmpmaps->name=strdup((char*)val);; xmlFree(val); } /** * Title, Asbtract */ else if(xmlStrncasecmp(cur2->name,BAD_CAST "Title",xmlStrlen(cur2->name))==0 || xmlStrncasecmp(cur2->name,BAD_CAST "Abstract",xmlStrlen(cur2->name))==0){ xmlChar *val= xmlNodeListGetString(doc,cur2->xmlChildrenNode,1); if(tmpmaps==NULL){ tmpmaps=(maps*)calloc(1,MAPS_SIZE); if(tmpmaps == NULL){ return errorException(m, _("Unable to allocate memory."), "InternalError"); } tmpmaps->name=strdup("missingIndetifier"); tmpmaps->content=createMap((char*)cur2->name,(char*)val); tmpmaps->next=NULL; } else{ if(tmpmaps->content!=NULL) addToMap(tmpmaps->content, (char*)cur2->name,(char*)val); else tmpmaps->content= createMap((char*)cur2->name,(char*)val); } xmlFree(val); } cur2=cur2->next; } } cur1=cur1->next; } } if(request_output_real_format==NULL) request_output_real_format=dupMaps(&tmpmaps); else addMapsToMaps(&request_output_real_format,tmpmaps); #ifdef DEBUG dumpMaps(tmpmaps); #endif freeMaps(&tmpmaps); free(tmpmaps); } xmlXPathFreeObject(tmpsptr); xmlCleanupParser(); } //if(CHECK_INET_HANDLE(hInternet)) InternetCloseHandle(hInternet); #ifdef DEBUG fprintf(stderr,"\n%i\n",i); dumpMaps(request_input_real_format); dumpMaps(request_output_real_format); dumpMap(request_inputs); fprintf(stderr,"\n%i\n",i); #endif /** * Ensure that each requested arguments are present in the request * DataInputs and ResponseDocument / RawDataOutput */ char *dfv=addDefaultValues(&request_input_real_format,s1->inputs,m,0); char *dfv1=addDefaultValues(&request_output_real_format,s1->outputs,m,1); if(strcmp(dfv1,"")!=0 || strcmp(dfv,"")!=0){ char tmps[1024]; if(strcmp(dfv,"")!=0){ snprintf(tmps,1024,_("The <%s> argument was not specified in DataInputs but defined as requested in ZOO ServicesProvider configuration file, please correct your query or the ZOO Configuration file."),dfv); } else if(strcmp(dfv1,"")!=0){ snprintf(tmps,1024,_("The <%s> argument was specified as Output identifier but not defined in the ZOO Configuration File. Please, correct your query or the ZOO Configuration File."),dfv1); } map* tmpe=createMap("text",tmps); addToMap(tmpe,"code","MissingParameterValue"); printExceptionReportResponse(m,tmpe); freeService(&s1); free(s1); freeMap(&tmpe); free(tmpe); freeMaps(&m); free(m); free(REQUEST); free(SERVICE_URL); freeMaps(&request_input_real_format); free(request_input_real_format); freeMaps(&request_output_real_format); free(request_output_real_format); freeMaps(&tmpmaps); free(tmpmaps); return 1; } ensureDecodedBase64(&request_input_real_format); #ifdef DEBUG fprintf(stderr,"REQUEST_INPUTS\n"); dumpMaps(request_input_real_format); fprintf(stderr,"REQUEST_OUTPUTS\n"); dumpMaps(request_output_real_format); #endif maps* curs=getMaps(m,"env"); if(curs!=NULL){ map* mapcs=curs->content; while(mapcs!=NULLMAP){ #ifndef WIN32 setenv(mapcs->name,mapcs->value,1); #else #ifdef DEBUG fprintf(stderr,"[ZOO: setenv (%s=%s)]\n",mapcs->name,mapcs->value); #endif if(mapcs->value[strlen(mapcs->value)-2]=='\r'){ #ifdef DEBUG fprintf(stderr,"[ZOO: Env var finish with \r]\n"); #endif mapcs->value[strlen(mapcs->value)-1]=0; } #ifdef DEBUG fflush(stderr); fprintf(stderr,"setting variable... %s\n", #endif SetEnvironmentVariable(mapcs->name,mapcs->value) #ifdef DEBUG ? "OK" : "FAILED"); #else ; #endif #ifdef DEBUG fflush(stderr); #endif #endif #ifdef DEBUG fprintf(stderr,"[ZOO: setenv (%s=%s)]\n",mapcs->name,mapcs->value); fflush(stderr); #endif mapcs=mapcs->next; } } #ifdef DEBUG dumpMap(request_inputs); #endif /** * Need to check if we need to fork to load a status enabled */ r_inputs=NULL; map* store=getMap(request_inputs,"storeExecuteResponse"); map* status=getMap(request_inputs,"status"); /** * 05-007r7 WPS 1.0.0 page 57 : * 'If status="true" and storeExecuteResponse is "false" then the service * shall raise an exception.' */ if(status!=NULL && strcmp(status->value,"true")==0 && store!=NULL && strcmp(store->value,"false")==0){ errorException(m, _("Status cannot be set to true with storeExecuteResponse to false. Please, modify your request parameters."), "InvalidParameterValue"); freeService(&s1); free(s1); freeMaps(&m); free(m); freeMaps(&request_input_real_format); free(request_input_real_format); freeMaps(&request_output_real_format); free(request_output_real_format); free(REQUEST); free(SERVICE_URL); return 1; } r_inputs=getMap(request_inputs,"storeExecuteResponse"); int eres=SERVICE_STARTED; int cpid=getpid(); maps *_tmpMaps=(maps*)malloc(MAPS_SIZE); _tmpMaps->name=strdup("lenv"); char tmpBuff[100]; sprintf(tmpBuff,"%i",cpid); _tmpMaps->content=createMap("sid",tmpBuff); _tmpMaps->next=NULL; addToMap(_tmpMaps->content,"status","0"); addToMap(_tmpMaps->content,"cwd",ntmp); map* ltmp=getMap(request_inputs,"soap"); if(ltmp!=NULL) addToMap(_tmpMaps->content,"soap",ltmp->value); else addToMap(_tmpMaps->content,"soap","false"); if(cgiCookie!=NULL && strlen(cgiCookie)>0){ addToMap(_tmpMaps->content,"sessid",strstr(cgiCookie,"=")+1); char session_file_path[1024]; map *tmpPath=getMapFromMaps(m,"main","sessPath"); if(tmpPath==NULL) tmpPath=getMapFromMaps(m,"main","tmpPath"); char *tmp1=strtok(cgiCookie,";"); if(tmp1!=NULL) sprintf(session_file_path,"%s/sess_%s.cfg",tmpPath->value,strstr(tmp1,"=")+1); else sprintf(session_file_path,"%s/sess_%s.cfg",tmpPath->value,strstr(cgiCookie,"=")+1); maps *tmpSess=(maps*)calloc(1,MAPS_SIZE); struct stat file_status; int istat = stat(session_file_path, &file_status); if(istat==0 && file_status.st_size>0){ conf_read(session_file_path,tmpSess); addMapsToMaps(&m,tmpSess); freeMaps(&tmpSess); } free(tmpSess); } addMapsToMaps(&m,_tmpMaps); freeMaps(&_tmpMaps); free(_tmpMaps); #ifdef DEBUG dumpMap(request_inputs); #endif #ifdef WIN32 char *cgiSidL=NULL; if(getenv("CGISID")!=NULL) addToMap(request_inputs,"cgiSid",getenv("CGISID")); map* test1=getMap(request_inputs,"cgiSid"); if(test1!=NULL){ cgiSid=test1->value; } if(cgiSid!=NULL){ addToMap(request_inputs,"storeExecuteResponse","true"); addToMap(request_inputs,"status","true"); status=getMap(request_inputs,"status"); fprintf(stderr,"cgiSID : %s",cgiSid); } #endif if(status!=NULL) if(strcasecmp(status->value,"false")==0) status=NULL; if(status==NULLMAP){ loadServiceAndRun(&m,s1,request_inputs,&request_input_real_format,&request_output_real_format,&eres); } else{ pid_t pid; #ifdef DEBUG fprintf(stderr,"\nPID : %d\n",cpid); #endif #ifndef WIN32 pid = fork (); #else if(cgiSid==NULL){ addToMap(request_inputs,"cgSid",cgiSid); createProcess(m,request_inputs,s1,NULL,cpid,request_input_real_format,request_output_real_format); pid = cpid; }else{ pid=0; cpid=atoi(cgiSid); } fflush(stderr); #endif if (pid > 0) { /** * dady : * set status to SERVICE_ACCEPTED */ #ifdef DEBUG fprintf(stderr,"father pid continue (origin %d) %d ...\n",cpid,getpid()); #endif eres=SERVICE_ACCEPTED; }else if (pid == 0) { /** * son : have to close the stdout, stdin and stderr to let the parent * process answer to http client. */ r_inputs=getMapFromMaps(m,"main","tmpPath"); map* r_inputs1=getMap(s1->content,"ServiceProvider"); char* fbkp=(char*)malloc((strlen(r_inputs->value)+strlen(r_inputs1->value)+100)*sizeof(char)); sprintf(fbkp,"%s/%s_%d.xml",r_inputs->value,r_inputs1->value,cpid); char* flog=(char*)malloc((strlen(r_inputs->value)+strlen(r_inputs1->value)+100)*sizeof(char)); sprintf(flog,"%s/%s_%d_error.log",r_inputs->value,r_inputs1->value,cpid); #ifdef DEBUG fprintf(stderr,"RUN IN BACKGROUND MODE \n"); fprintf(stderr,"son pid continue (origin %d) %d ...\n",cpid,getpid()); fprintf(stderr,"\nFILE TO STORE DATA %s\n",r_inputs->value); #endif freopen(flog,"w+",stderr); freopen(fbkp , "w+", stdout); fclose(stdin); free(fbkp); free(flog); /** * set status to SERVICE_STARTED and flush stdout to ensure full * content was outputed (the file used to store the ResponseDocument). * The rewind stdout to restart writing from the bgining of the file, * this way the data will be updated at the end of the process run. */ updateStatus(m); printProcessResponse(m,request_inputs,cpid, s1,r_inputs1->value,SERVICE_STARTED, request_input_real_format, request_output_real_format); #ifndef WIN32 fflush(stdout); rewind(stdout); #endif loadServiceAndRun(&m,s1,request_inputs,&request_input_real_format,&request_output_real_format,&eres); } else { /** * error server don't accept the process need to output a valid * error response here !!! */ eres=-1; errorException(m, _("Unable to run the child process properly"), "InternalError"); } } #ifdef DEBUG dumpMaps(request_output_real_format); fprintf(stderr,"Function loaded and returned %d\n",*eres); fflush(stderr); #endif if(eres!=-1) outputResponse(s1,request_input_real_format, request_output_real_format,request_inputs, cpid,m,eres); fflush(stdout); /** * Ensure that if error occurs when freeing memory, no signal will return * an ExceptionReport document as the result was already returned to the * client. */ #ifndef USE_GDB (void) signal(SIGSEGV,donothing); (void) signal(SIGTERM,donothing); (void) signal(SIGINT,donothing); (void) signal(SIGILL,donothing); (void) signal(SIGFPE,donothing); (void) signal(SIGABRT,donothing); #endif if(((int)getpid())!=cpid){ fclose(stdout); fclose(stderr); unhandleStatus(m); } freeService(&s1); free(s1); freeMaps(&m); free(m); freeMaps(&request_input_real_format); free(request_input_real_format); freeMaps(&request_output_real_format); free(request_output_real_format); free(REQUEST); free(SERVICE_URL); #ifdef DEBUG fprintf(stderr,"Processed response \n"); fflush(stdout); fflush(stderr); #endif return 0; }