1 #include "mod_rest_gateway.h"
3 char* ils_rest_gateway_config_file;
5 static const char* ils_gateway_set_config(cmd_parms *parms, void *config, const char *arg) {
6 ils_gateway_config *cfg;
8 cfg = ap_get_module_config(parms->server->module_config, &ils_rest_gateway_module);
10 cfg->configfile = (char*) arg;
11 ils_rest_gateway_config_file = (char*) arg;
16 /* tell apache about our commands */
17 static const command_rec ils_gateway_cmds[] = {
18 AP_INIT_TAKE1( GATEWAY_CONFIG, ils_gateway_set_config, NULL, RSRC_CONF, "gateway config file"),
22 /* build the config object */
23 static void* ils_gateway_create_config( apr_pool_t* p, server_rec* s) {
24 ils_gateway_config* cfg = (ils_gateway_config*) apr_palloc(p, sizeof(ils_gateway_config));
25 cfg->configfile = GATEWAY_DEFAULT_CONFIG;
30 static void mod_ils_gateway_child_init(apr_pool_t *p, server_rec *s) {
32 char* cfg = ils_rest_gateway_config_file;
34 if( ! osrf_system_bootstrap_client( cfg, CONFIG_CONTEXT) ) {
35 //osrfLogError("Unable to load gateway config file...");
38 fprintf(stderr, "Bootstrapping %d\n", getpid() );
42 static int mod_ils_gateway_method_handler (request_rec *r) {
44 /* make sure we're needed first thing*/
45 if (strcmp(r->handler, MODULE_NAME ))
48 apr_pool_t *p = r->pool; /* memory pool */
49 char* arg = r->args; /* url query string */
51 char* service = NULL; /* service to connect to */
52 char* method = NULL; /* method to perform */
54 //json* exception = NULL; /* returned in error conditions */
55 //jsonObject* exception = NULL; /* returned in error conditions */
56 string_array* sarray = init_string_array(12); /* method parameters */
58 growing_buffer* buffer = NULL; /* POST data */
59 growing_buffer* tmp_buf = NULL; /* temp buffer */
61 char* key = NULL; /* query item name */
62 char* val = NULL; /* query item value */
64 jsonObject* response = jsonParseString("{\"status\":0,\"debug\":\"\"}");
65 jsonObject* payload = jsonParseString("[]");
66 jsonObjectSetKey(response, "payload", payload );
68 /* verify we are connected */
69 if(!osrf_system_get_transport_client()) {
70 //osrfLogError("Bootstrap Failed, no transport client");
71 return HTTP_INTERNAL_SERVER_ERROR;
76 /* gather the post args and append them to the url query string */
77 if( !strcmp(r->method,"POST") ) {
79 ap_setup_client_block(r,REQUEST_CHUNKED_DECHUNK);
81 if(! ap_should_client_block(r)) {
82 //osrfLogWarning("No Post Body");
87 buffer = buffer_init(1025);
89 while(ap_get_client_block(r, body, 1024)) {
90 //osrfLogDebug("Apache read POST block data: %s\n", body);
91 buffer_add( buffer, body );
96 tmp_buf = buffer_init(1024);
97 buffer_add(tmp_buf,arg);
98 buffer_add(tmp_buf,buffer->buf);
99 arg = (char*) apr_pstrdup(p, tmp_buf->buf);
100 buffer_free(tmp_buf);
102 arg = (char*) apr_pstrdup(p, buffer->buf);
108 //osrfLogDebug("params args are %s", arg);
111 if( ! arg || !arg[0] ) { /* we received no request */
112 //osrfLogWarning("No Args");
116 r->allowed |= (AP_METHOD_BIT << M_GET);
117 r->allowed |= (AP_METHOD_BIT << M_POST);
120 while( arg && (val = ap_getword(p, (const char**) &arg, '&'))) {
122 key = ap_getword(r->pool, (const char**) &val, '=');
126 ap_unescape_url((char*)key);
127 ap_unescape_url((char*)val);
129 if(!strcmp(key,"service"))
132 if(!strcmp(key,"method"))
135 if(!strcmp(key,"param"))
136 string_array_add(sarray, val);
140 //osrfLogInfo("Performing(%d): service %s | method %s | \n",
141 // getpid(), service, method );
144 for( k = 0; k!= sarray->size; k++ ) {
145 //osrfLogInfo( "param %s", string_array_get_string(sarray,k));
148 osrf_app_session* session = osrf_app_client_session_init(service);
150 //osrfLogDebug("MOD session service: %s", session->remote_service );
152 int req_id = osrf_app_session_make_req( session, NULL, method, 1, sarray );
153 string_array_destroy(sarray);
155 osrf_message* omsg = NULL;
157 //growing_buffer* result_data = buffer_init(256);
158 //buffer_add(result_data, "[");
160 /* gather result data */
162 while((omsg = osrf_app_session_request_recv( session, req_id, 60 ))) {
164 if( omsg->_result_content ) {
165 char* content = jsonObjectToJSON(omsg->_result_content);
166 buffer_add(result_data, content);
167 buffer_add( result_data, ",");
173 growing_buffer* exc_buffer = buffer_init(256);
174 buffer_add( exc_buffer, "\nReceived Exception:\nName: " );
175 buffer_add( exc_buffer, omsg->status_name );
176 buffer_add( exc_buffer, "\nStatus: " );
177 buffer_add( exc_buffer, omsg->status_text );
178 buffer_add( exc_buffer, "\nStatus: " );
182 sprintf( code, "%d", omsg->status_code );
183 buffer_add( exc_buffer, code );
185 exception = json_parse_string("{}");
186 jsonObjectSetKey(exception, "is_err", json_parse_string("1"));
187 jsonObjectSetKey(exception, "err_msg", jsonNewObject(exc_buffer->buf) );
189 //osrfLogWarning("*** Looks like we got a "
190 // "server exception\n%s", exc_buffer->buf );
192 buffer_free(exc_buffer);
193 osrf_message_free(omsg);
197 osrf_message_free(omsg);
202 while((omsg = osrf_app_session_request_recv( session, req_id, 60 ))) {
204 jsonObjectSetKey(response, "status", jsonNewNumberObject(omsg->status_code));
206 if( omsg->_result_content ) {
207 jsonObjectPush( payload, jsonObjectClone(omsg->_result_content));
211 char* s = omsg->status_name ? omsg->status_name : "Unknown Error";
212 char* t = omsg->status_text ? omsg->status_text : "No Error Message";
213 jsonObjectSetKey(response, "debug", jsonNewObject("\n\n%s:\n%s\n", s, t));
214 //osrfLogError( "Gateway received error: %s",
215 // jsonObjectGetString(jsonObjectGetKey(response, "debug")));
219 osrf_message_free(omsg);
223 char* content = jsonObjectToJSON(response);
224 char* xml = json_string_to_xml( content );
229 /* set content type to text/xml for passing around XML objects */
230 ap_set_content_type(r, "text/xml");
234 osrf_app_session_request_finish( session, req_id );
235 //osrfLogDebug("gateway process message successfully");
238 osrf_app_session_destroy(session);
240 jsonObjectFree(response);
246 static void mod_ils_gateway_register_hooks (apr_pool_t *p) {
247 ap_hook_handler(mod_ils_gateway_method_handler, NULL, NULL, APR_HOOK_MIDDLE);
248 ap_hook_child_init(mod_ils_gateway_child_init,NULL,NULL,APR_HOOK_MIDDLE);
252 module AP_MODULE_DECLARE_DATA ils_rest_gateway_module = {
253 STANDARD20_MODULE_STUFF,
256 ils_gateway_create_config,
259 mod_ils_gateway_register_hooks,