XMLification (wave 3)

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@1403 d0543943-73ff-0310-b7d9-9358b9ac24b2

src/mod/xml_int/mod_xml_rpc/mod_xml_rpc.c

@@ -0,0 +1,281 @@
+/* 
+ * FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
+ * Copyright (C) 2005/2006, Anthony Minessale II <anthmct@yahoo.com>
+ *
+ * Version: MPL 1.1
+ *
+ * The contents of this file are subject to the Mozilla Public License Version
+ * 1.1 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * http://www.mozilla.org/MPL/
+ *
+ * Software distributed under the License is distributed on an "AS IS" basis,
+ * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
+ * for the specific language governing rights and limitations under the
+ * License.
+ *
+ * The Original Code is FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
+ *
+ * The Initial Developer of the Original Code is
+ * Anthony Minessale II <anthmct@yahoo.com>
+ * Portions created by the Initial Developer are Copyright (C)
+ * the Initial Developer. All Rights Reserved.
+ *
+ * Contributor(s):
+ * 
+ * Anthony Minessale II <anthmct@yahoo.com>
+ *
+ *
+ * mod_xml_rpc.c -- XML RPC
+ *
+ */
+#include <switch.h>
+#include <xmlrpc-c/base.h>
+#include <xmlrpc-c/abyss.h>
+#include <xmlrpc-c/server.h>
+#include <xmlrpc-c/server_abyss.h>
+#include <curl/curl.h>
+
+
+
+static const char modname[] = "mod_xml_rpc";
+
+
+static struct {
+	int port;
+	uint8_t running;
+	char *url;
+} globals;
+
+SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_url, globals.url)
+
+struct config_data {
+	char *name;
+	int fd;
+};
+
+static size_t file_callback(void *ptr, size_t size, size_t nmemb, void *data)
+{
+	register unsigned int realsize = (unsigned int)(size * nmemb);
+	struct config_data *config_data = data;
+
+	write(config_data->fd, ptr, realsize);
+	return realsize;
+}
+
+
+static switch_xml_t xml_url_fetch(char *section,
+						   char *tag_name,
+						   char *key_name,
+						   char *key_value)
+{
+	char url[1024] = "", filename[1024] = "";
+	CURL *curl_handle = NULL;
+	struct config_data config_data;
+	switch_xml_t xml;
+
+	snprintf(url, sizeof(url), "%s?section=%s&tag_name=%s&key_name=%s&key_value=%s\n", globals.url, section, tag_name, key_name, key_value);
+	srand(time(NULL) + strlen(url));
+	snprintf(filename, sizeof(filename), "%s%04x.tmp", SWITCH_GLOBAL_dirs.temp_dir, (rand() & 0xffff));
+	curl_global_init(CURL_GLOBAL_ALL);
+	curl_handle = curl_easy_init();
+	if (!strncasecmp(url, "https", 5)) {
+		curl_easy_setopt(curl_handle, CURLOPT_SSL_VERIFYPEER, 0);
+		curl_easy_setopt(curl_handle, CURLOPT_SSL_VERIFYHOST, 0);
+	}
+		
+	config_data.name = filename;
+	if ((config_data.fd = open(filename, O_CREAT | O_RDWR | O_TRUNC)) > -1) {
+		curl_easy_setopt(curl_handle, CURLOPT_URL, url);
+		curl_easy_setopt(curl_handle, CURLOPT_WRITEFUNCTION, file_callback);
+		curl_easy_setopt(curl_handle, CURLOPT_WRITEDATA, (void *)&config_data);
+		curl_easy_setopt(curl_handle, CURLOPT_USERAGENT, "freeswitch-xml/1.0");
+		curl_easy_perform(curl_handle);
+		curl_easy_cleanup(curl_handle);
+		close(config_data.fd);
+	} else {
+		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error!\n");
+	}
+
+	if (!(xml = switch_xml_parse_file(filename))) {
+		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error Parsing Result!\n");
+	}
+
+	unlink(filename);
+	
+	return xml;
+}
+
+
+
+static switch_loadable_module_interface_t xml_rpc_module_interface = {
+	/*.module_name */ modname,
+	/*.endpoint_interface */ NULL,
+	/*.timer_interface */ NULL,
+	/*.dialplan_interface */ NULL,
+	/*.codec_interface */ NULL,
+	/*.application_interface */ NULL,
+	/*.api_interface */ NULL,
+	/*.file_interface */ NULL,
+	/*.speech_interface */ NULL,
+	/*.directory_interface */ NULL
+};
+
+static switch_status_t do_config(void) 
+{
+	char *cf = "xml_rpc.conf";
+	switch_xml_t cfg, xml, settings, param;
+	
+	if (!(xml = switch_xml_open_cfg(cf, &cfg))) {
+		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "open of %s failed\n", cf);
+		return SWITCH_STATUS_TERM;
+	}
+
+	if ((settings = switch_xml_child(cfg, "settings"))) {
+		for (param = switch_xml_child(settings, "param"); param; param = param->next) {
+			char *var = (char *) switch_xml_attr(param, "name");
+			char *val = (char *) switch_xml_attr(param, "value");
+
+			if (!strcasecmp(var, "gateway_url")) {
+				set_global_url(val);
+			} else if (!strcasecmp(var, "http_port")) {
+				globals.port = atoi(val);
+			}
+		}
+	}
+	
+	if (!globals.port) {
+		globals.port = 8080;
+	}
+
+	switch_xml_free(xml);
+
+	return globals.url ? SWITCH_STATUS_SUCCESS : SWITCH_STATUS_FALSE;
+}
+
+
+SWITCH_MOD_DECLARE(switch_status_t) switch_module_load(const switch_loadable_module_interface_t **module_interface, char *filename)
+{
+	/* connect my internal structure to the blank pointer passed to me */
+	*module_interface = &xml_rpc_module_interface;
+
+	memset(&globals, 0, sizeof(globals));
+
+	if (do_config() == SWITCH_STATUS_SUCCESS) {
+		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Binding XML Fetch Function [%s]\n", globals.url);
+		switch_xml_bind_search_function(xml_url_fetch);
+	}
+
+	/* indicate that the module should continue to be loaded */
+	return SWITCH_STATUS_SUCCESS;
+}
+
+
+#define CMDLEN 10240
+abyss_bool HandleHook(TSession *r)
+{
+    char *m = "text/html";
+	char *retbuf = malloc(CMDLEN);
+	char *command, *arg;
+	char *ret = NULL;
+
+	if(strncmp(r->uri, "/api/", 5)) {
+		return FALSE;
+	}
+
+	command = strdup(r->uri + 5);
+	if((arg = strchr(command, '/'))) {
+		*arg++ = '\0';
+	} else if((arg = strchr(command, '?'))) {
+		*arg++ = '\0';
+	}
+	ResponseChunked(r);
+	ResponseStatus(r,200);
+	memset(retbuf, 0, CMDLEN);
+	switch_api_execute(command, arg, retbuf, CMDLEN);
+	if (!strncasecmp(retbuf, "content-type: ", 14)) {
+
+		m = retbuf + 14;
+		if ((ret = strchr(m, '\n'))) {
+			*ret++ = '\0';
+		}
+	}
+
+	if (!ret) {
+		ret = retbuf;
+	}
+	ResponseContentType(r, m);
+    ResponseWrite(r);
+	HTTPWrite(r, ret , strlen(ret));
+	HTTPWriteEnd(r);
+	free(command);
+	free(retbuf);
+    return TRUE;
+}
+
+
+static xmlrpc_value *freeswitch_api(xmlrpc_env *const envP, xmlrpc_value *const paramArrayP, void *const userData) 
+{
+	char *command, *arg;
+	char *retbuf = malloc(CMDLEN);
+	xmlrpc_value *val;
+
+    /* Parse our argument array. */
+    xmlrpc_decompose_value(envP, paramArrayP, "(ss)", &command, &arg);
+    if (envP->fault_occurred) {
+        return NULL;
+	}
+
+	memset(retbuf, 0, CMDLEN);
+	switch_api_execute(command, arg, retbuf, CMDLEN);
+
+    /* Return our result. */
+    val = xmlrpc_build_value(envP, "s", retbuf);
+	free(retbuf);
+
+	return val;
+}
+
+SWITCH_MOD_DECLARE(switch_status_t) switch_module_runtime(void) 
+{
+    TServer abyssServer;
+    xmlrpc_registry * registryP;
+    xmlrpc_env env;
+	char logfile[512];
+
+	globals.running = 1;
+    
+    xmlrpc_env_init(&env);
+
+    registryP = xmlrpc_registry_new(&env);
+	
+    xmlrpc_registry_add_method(&env, registryP, NULL, "freeswitch.api", &freeswitch_api, NULL);
+
+    MIMETypeInit();
+	MIMETypeAdd("text/html", "html");
+
+	snprintf(logfile, sizeof(logfile), "%s/%s", SWITCH_GLOBAL_dirs.log_dir, "freeswitch_http.log");
+    ServerCreate(&abyssServer, "XmlRpcServer", globals.port, SWITCH_GLOBAL_dirs.htdocs_dir, logfile);
+    
+    xmlrpc_server_abyss_set_handler(&env, &abyssServer, "/RPC2", registryP);
+
+    ServerInit(&abyssServer);
+	ServerAddHandler(&abyssServer, HandleHook);
+	
+	switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Starting HTTP Port %d, DocRoot [%s]\n", globals.port, SWITCH_GLOBAL_dirs.htdocs_dir);
+    while (globals.running) {
+        ServerRunOnce2(&abyssServer, ABYSS_FOREGROUND);
+    }
+
+
+	return SWITCH_STATUS_SUCCESS;
+}
+
+
+
+SWITCH_MOD_DECLARE(switch_status_t) switch_module_shutdown(void)
+{
+	globals.running = 0;
+	return SWITCH_STATUS_SUCCESS;
+}
+