1 #include "mod_ils_gateway.h"
4 char* ils_gateway_config_file = NULL;
5 char* ils_rest_gateway_config_file = NULL;
7 static const char* ils_gateway_set_config(cmd_parms *parms, void *config, const char *arg) {
8 ils_gateway_config *cfg;
9 cfg = ap_get_module_config(parms->server->module_config, &ils_gateway_module);
10 cfg->configfile = (char*) arg;
11 ils_gateway_config_file = (char*) arg;
15 /* tell apache about our commands */
16 static const command_rec ils_gateway_cmds[] = {
17 AP_INIT_TAKE1( GATEWAY_CONFIG, ils_gateway_set_config, NULL, RSRC_CONF, "gateway config file"),
21 /* build the config object */
22 static void* ils_gateway_create_config( apr_pool_t* p, server_rec* s) {
23 ils_gateway_config* cfg = (ils_gateway_config*) apr_palloc(p, sizeof(ils_gateway_config));
24 cfg->configfile = GATEWAY_DEFAULT_CONFIG;
29 static void mod_ils_gateway_child_init(apr_pool_t *p, server_rec *s) {
31 char* cfg = ils_gateway_config_file;
32 if( ! osrf_system_bootstrap_client( cfg, CONFIG_CONTEXT) ) {
33 osrfLogError("Unable to bootstrap client in gateway...");
36 fprintf(stderr, "Bootstrapping %d\n", getpid() );
40 static int mod_ils_gateway_method_handler (request_rec *r) {
42 /* make sure we're needed first thing*/
43 if (strcmp(r->handler, MODULE_NAME ))
46 osrfLogSetAppname("osrf_json_gw");
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 string_array* sarray = init_string_array(12); /* method parameters */
56 growing_buffer* buffer = NULL; /* POST data */
57 growing_buffer* tmp_buf = NULL; /* temp buffer */
59 char* key = NULL; /* query item name */
60 char* val = NULL; /* query item value */
62 jsonObject* response = jsonParseString("{ }");
63 jsonObject* payload = jsonParseString("[ ]");
64 jsonObjectSetKey(response, "payload", payload );
66 /* verify we are connected */
67 if(!osrf_system_get_transport_client()) {
68 osrfLogError("Bootstrap Failed, no transport client");
69 return HTTP_INTERNAL_SERVER_ERROR;
72 ap_set_content_type(r, "text/plain");
73 osrfLogDebug("Apache request method: %s", r->method );
75 /* gather the post args and append them to the url query string */
76 if( !strcmp(r->method,"POST") ) {
78 ap_setup_client_block(r,REQUEST_CHUNKED_DECHUNK);
80 if(! ap_should_client_block(r)) {
81 osrfLogWarning("No Post Body");
89 buffer = buffer_init(BUFL);
91 while(ap_get_client_block(r, body, BUFL - 1 )) {
92 buffer_add( buffer, body );
96 if( buffer->n_used < 1 ) {
97 osrfLogWarning("No Post Body");
102 if(arg && strlen(arg) > 0 ) {
103 tmp_buf = buffer_init(BUFL);
104 buffer_add(tmp_buf,arg);
105 buffer_add(tmp_buf,buffer->buf);
106 arg = (char*) apr_pstrdup(p, tmp_buf->buf);
107 buffer_free(tmp_buf);
109 arg = (char*) apr_pstrdup(p, buffer->buf);
115 if( ! arg || strlen(arg) == 0 ) { /* we received no request */
116 osrfLogWarning("No Args");
121 ap_log_rerror( APLOG_MARK, APLOG_DEBUG, 0, r, "URL: %s", arg );
123 r->allowed |= (AP_METHOD_BIT << M_GET);
124 r->allowed |= (AP_METHOD_BIT << M_POST);
126 while( arg && (val = ap_getword(p, (const char**) &arg, '&'))) {
128 key = ap_getword(r->pool, (const char**) &val, '=');
132 ap_unescape_url((char*)key);
133 ap_unescape_url((char*)val);
135 if(!strcmp(key,"service"))
138 if(!strcmp(key,"method"))
141 if(!strcmp(key,"param"))
142 string_array_add(sarray, val);
146 osrfLogInfo("\r\nPerforming(%d): service %s "
147 "| method %s |", getpid(), service, method );
150 for( k = 0; k!= sarray->size; k++ ) {
151 osrfLogInfo( "param %s", string_array_get_string(sarray,k));
154 osrf_app_session* session = osrf_app_client_session_init(service);
156 osrfLogDebug("session service: %s", session->remote_service );
158 int req_id = osrf_app_session_make_req( session, NULL, method, 1, sarray );
159 string_array_destroy(sarray);
161 osrf_message* omsg = NULL;
163 while((omsg = osrf_app_session_request_recv( session, req_id, 60 ))) {
165 jsonObjectSetKey(response, "status", jsonNewNumberObject(omsg->status_code));
167 if( omsg->_result_content ) {
168 jsonObjectPush( payload, jsonObjectClone(omsg->_result_content));
172 if( omsg->status_code > 299 ) {
173 char* s = omsg->status_name ? omsg->status_name : "Unknown Error";
174 char* t = omsg->status_text ? omsg->status_text : "No Error Message";
175 jsonObjectSetKey(response, "debug", jsonNewObject("\n\n%s:\n%s\n", s, t));
176 osrfLogError( "Gateway received error: %s",
177 jsonObjectGetString(jsonObjectGetKey(response, "debug")));
182 osrf_message_free(omsg);
186 char* content = jsonObjectToJSON(response);
188 osrfLogInfo( "Gateway responding with: %s", content );
192 jsonObjectFree(response);
194 osrf_app_session_request_finish( session, req_id );
195 osrfLogDebug("gateway processed message successfully");
197 osrf_app_session_destroy(session);
201 static void mod_ils_gateway_register_hooks (apr_pool_t *p) {
202 ap_hook_handler(mod_ils_gateway_method_handler, NULL, NULL, APR_HOOK_MIDDLE);
203 ap_hook_child_init(mod_ils_gateway_child_init,NULL,NULL,APR_HOOK_MIDDLE);
207 module AP_MODULE_DECLARE_DATA ils_gateway_module = {
208 STANDARD20_MODULE_STUFF,
211 ils_gateway_create_config,
214 mod_ils_gateway_register_hooks,