+++ /dev/null
-/*
- * FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
- * Copyright (C) 2005-2010, James Martelletti <james@nerdc0re.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
- * James Martelletti <james@nerdc0re.com>
- * Portions created by the Initial Developer are Copyright (C)
- * the Initial Developer. All Rights Reserved.
- *
- * Contributor(s):
- *
- * Tamas Cseke <tamas.cseke@vcc.live>
- *
- * mod_raven.c -- Raven Logging
- *
- */
-#include <switch.h>
-#include <zlib.h>
-#include <switch_curl.h>
-
-#define RAVEN_ZLIB_CHUNK 16384
-#define RAVEN_VERSION "5"
-#define RAVEN_UA "freeswitch-raven/1.0"
-
-SWITCH_MODULE_LOAD_FUNCTION(mod_raven_load);
-SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_raven_shutdown);
-SWITCH_MODULE_DEFINITION(mod_raven, mod_raven_load, mod_raven_shutdown, NULL);
-
-static switch_status_t load_config(void);
-
-static struct {
- char *uri;
- char *key;
- char *secret;
- char *project;
- switch_bool_t log_uuid;
- switch_log_level_t log_level;
-} globals;
-
-SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_uri, globals.uri);
-SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_key, globals.key);
-SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_secret, globals.secret);
-SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_project, globals.project);
-
-static switch_loadable_module_interface_t raven_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 encode(const char *raw, int raw_len, char **encoded_out)
-{
- z_stream stream;
- unsigned char *encoded = NULL, *compressed = NULL;
- int ret;
- switch_size_t compressed_size = 0, compressed_len = 0, need_bytes;
-
- stream.zalloc = Z_NULL;
- stream.zfree = Z_NULL;
- stream.opaque = Z_NULL;
- ret = deflateInit(&stream, Z_DEFAULT_COMPRESSION);
- if (ret != Z_OK) {
- return SWITCH_STATUS_FALSE;
- }
-
- stream.next_in = (unsigned char *)raw;
- stream.avail_in = raw_len;
-
- do {
- compressed_size += RAVEN_ZLIB_CHUNK;
- compressed = realloc(compressed, compressed_size + 1);
- switch_assert(compressed != NULL);
-
- stream.avail_out = compressed_size - compressed_len;
- stream.next_out = compressed + compressed_len;
-
- ret = deflate(&stream, Z_FINISH);
- assert(ret != Z_STREAM_ERROR);
- compressed_len = compressed_size - stream.avail_out;
- } while (stream.avail_in != 0);
-
- deflateEnd(&stream);
-
- need_bytes = compressed_len * 3 + 1;
- encoded = malloc(need_bytes);
- switch_assert(encoded);
- memset(encoded, 0, need_bytes);
- switch_b64_encode(compressed, compressed_len, encoded, need_bytes);
-
- switch_safe_free(compressed);
-
- *encoded_out = (char *)encoded;
-
- return SWITCH_STATUS_SUCCESS;
-}
-
-static switch_status_t raven_capture(const char *userdata, const char *message, const char *level, const char *file, const char *func, int line)
-{
- cJSON* json, *fingerprint;
- char *raw_body;
- char *encoded_body = NULL;
- switch_time_t timestamp = switch_micro_time_now();
- switch_status_t status = SWITCH_STATUS_SUCCESS;
- char uuid[SWITCH_UUID_FORMATTED_LENGTH + 1];
-
- switch_uuid_str(uuid, sizeof(uuid));
- json = cJSON_CreateObject();
- cJSON_AddStringToObject(json, "event_id", (const char *)uuid);
- cJSON_AddNumberToObject(json, "timestamp", timestamp);
- cJSON_AddStringToObject(json, "platform", RAVEN_UA);
- cJSON_AddStringToObject(json, "project", globals.project);
- cJSON_AddStringToObject(json, "server_name", switch_core_get_hostname());
- cJSON_AddStringToObject(json, "level", level);
-
- if (globals.log_uuid && !zstr(userdata)) {
- cJSON_AddItemToObject(json, "message", cJSON_CreateStringPrintf("%s %s", userdata, message));
- } else {
- cJSON_AddStringToObject(json, "message", message);
- }
-
- fingerprint = cJSON_CreateArray();
- cJSON_AddItemToArray(fingerprint, cJSON_CreateString(file));
- cJSON_AddItemToArray(fingerprint, cJSON_CreateString(func));
- cJSON_AddItemToArray(fingerprint, cJSON_CreateNumber(line));
- cJSON_AddItemToObject(json, "fingerprint", fingerprint);
-
- raw_body = cJSON_PrintUnformatted(json);
-
- if ((status = encode(raw_body, strlen(raw_body), &encoded_body)) == SWITCH_STATUS_SUCCESS) {
- int response;
- CURL *curl_handle = switch_curl_easy_init();
- switch_curl_slist_t * list = NULL;
- char *auth_header = switch_mprintf("X-Sentry-Auth: Sentry sentry_version=%s,"
- " sentry_client=%s,"
- " sentry_timestamp=%d,"
- " sentry_key=%s,"
- " sentry_secret=%s",
- RAVEN_VERSION, RAVEN_UA,
- timestamp, globals.key, globals.secret);
-
- char *url = switch_mprintf( "%s/api/%s/store/", globals.uri, globals.project);
- switch_curl_easy_setopt(curl_handle, CURLOPT_URL,url);
- switch_curl_easy_setopt(curl_handle, CURLOPT_POST, 1);
- switch_curl_easy_setopt(curl_handle, CURLOPT_NOSIGNAL, 1);
- switch_curl_easy_setopt(curl_handle, CURLOPT_POSTFIELDS, encoded_body);
- switch_curl_easy_setopt(curl_handle, CURLOPT_POSTFIELDSIZE, strlen(encoded_body));
-
- switch_curl_easy_setopt(curl_handle, CURLOPT_USERAGENT, RAVEN_UA);
-
- list = switch_curl_slist_append(list, auth_header);
- list = switch_curl_slist_append(list, "Content-Type: application/octet-stream");
- switch_curl_easy_setopt(curl_handle, CURLOPT_HTTPHEADER, list);
-
- if (!strncasecmp(globals.uri, "https", 5)) {
- switch_curl_easy_setopt(curl_handle, CURLOPT_SSL_VERIFYPEER, 0);
- switch_curl_easy_setopt(curl_handle, CURLOPT_SSL_VERIFYHOST, 0);
- }
-
- switch_curl_easy_perform(curl_handle);
- switch_curl_easy_getinfo(curl_handle, CURLINFO_RESPONSE_CODE, &response);
-
- if (response != 200) {
- status = SWITCH_STATUS_FALSE;
- }
-
- switch_curl_easy_cleanup(curl_handle);
- switch_curl_slist_free_all(list);
- switch_safe_free(url);
- switch_safe_free(auth_header);
- }
-
- switch_safe_free(raw_body);
- switch_safe_free(encoded_body);
- cJSON_Delete(json);
-
- return status;
-}
-
-
-static switch_status_t mod_raven_logger(const switch_log_node_t *node, switch_log_level_t level)
-{
- switch_status_t status = SWITCH_STATUS_SUCCESS;
-
- if (level != SWITCH_LOG_CONSOLE && !zstr(node->data)) {
- const char * raven_level;
-
- switch (level) {
- case SWITCH_LOG_DEBUG:
- raven_level = "debug";
- break;
- case SWITCH_LOG_INFO:
- raven_level = "info";
- break;
- case SWITCH_LOG_NOTICE:
- case SWITCH_LOG_WARNING:
- raven_level = "warning";
- break;
- case SWITCH_LOG_ERROR:
- raven_level = "error";
- break;
- case SWITCH_LOG_CRIT:
- case SWITCH_LOG_ALERT:
- raven_level = "fatal";
- break;
- default:
- raven_level = "debug";
- break;
- }
-
- status = raven_capture(node->userdata, node->data, raven_level, node->file, node->func, node->line);
- }
-
- return status;
-}
-
-static switch_status_t load_config(void)
-{
- char *cf = "raven.conf";
- switch_xml_t cfg, xml, settings, param;
-
- globals.log_level = SWITCH_LOG_WARNING;
- globals.log_uuid = SWITCH_TRUE;
-
- if (!(xml = switch_xml_open_cfg(cf, &cfg, NULL))) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Open of %s failed\n", cf);
- return SWITCH_STATUS_FALSE;
- }
-
- if ((settings = switch_xml_child(cfg, "settings"))) {
- for (param = switch_xml_child(settings, "param"); param; param = param->next) {
- char *var = (char *) switch_xml_attr_soft(param, "name");
- char *val = (char *) switch_xml_attr_soft(param, "value");
-
- if (!strcmp(var, "uri")) {
- set_global_uri(val);
- } else if (!strcmp(var, "key")) {
- set_global_key(val);
- } else if (!strcmp(var, "secret")) {
- set_global_secret(val);
- } else if (!strcmp(var, "project")) {
- set_global_project(val);
- } else if (!strcasecmp(var, "loglevel") && !zstr(val)) {
- globals.log_level = switch_log_str2level(val);
- if (globals.log_level == SWITCH_LOG_INVALID) {
- globals.log_level = SWITCH_LOG_WARNING;
- }
- } else if (!strcasecmp(var, "uuid")) {
- globals.log_uuid = switch_true(val);
- }
- }
- }
- switch_xml_free(xml);
-
- if (zstr(globals.uri) || zstr(globals.project) || zstr(globals.key) || zstr(globals.secret)) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Missing parameter\n");
- return SWITCH_STATUS_FALSE;
- }
-
- return SWITCH_STATUS_SUCCESS;
-}
-
-SWITCH_MODULE_LOAD_FUNCTION(mod_raven_load)
-{
- switch_status_t status;
- *module_interface = &raven_module_interface;
-
- memset(&globals, 0, sizeof(globals));
-
- if ((status = load_config()) != SWITCH_STATUS_SUCCESS) {
- return status;
- }
-
- switch_log_bind_logger(mod_raven_logger, globals.log_level, SWITCH_FALSE);
-
- return SWITCH_STATUS_SUCCESS;
-}
-
-SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_raven_shutdown)
-{
- switch_safe_free(globals.uri);
- switch_safe_free(globals.key);
- switch_safe_free(globals.secret);
- switch_safe_free(globals.project);
-
- switch_log_unbind_logger(mod_raven_logger);
-
- return SWITCH_STATUS_SUCCESS;
-}
-
-/* For Emacs:
- * Local Variables:
- * mode:c
- * indent-tabs-mode:t
- * tab-width:4
- * c-basic-offset:4
- * End:
- * For VIM:
- * vim:set softtabstop=4 shiftwidth=4 tabstop=4 noet:
- */
projects / thirdparty / freeswitch.git / commitdiff
