kenmirrors
/
freeswitch
mirror of https://github.com/signalwire/freeswitch.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Add raven logger module 

FS-9744 --resolve
This commit is contained in:
Tamas Cseke 2016-11-22 16:18:53 +01:00
parent 916ec2c68c
commit c06287da5b
5 changed files with 341 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
build/modules.conf.in
View File

@ -134,6 +134,7 @@ loggers/mod_console
#loggers/mod_graylog2
loggers/mod_logfile
loggers/mod_syslog
#loggers/mod_raven
#say/mod_say_de
say/mod_say_en
#say/mod_say_es

1
configure.ac
View File

@ -1887,6 +1887,7 @@ AC_CONFIG_FILES([Makefile
src/mod/loggers/mod_graylog2/Makefile
src/mod/loggers/mod_logfile/Makefile
src/mod/loggers/mod_syslog/Makefile
src/mod/loggers/mod_raven/Makefile
src/mod/say/mod_say_de/Makefile
src/mod/say/mod_say_en/Makefile
src/mod/say/mod_say_es/Makefile

8
src/mod/loggers/mod_raven/Makefile.am Normal file
View File

@ -0,0 +1,8 @@
include $(top_srcdir)/build/modmake.rulesam
MODNAME=mod_raven
mod_LTLIBRARIES = mod_raven.la
mod_raven_la_SOURCES = mod_raven.c
mod_raven_la_CFLAGS = $(AM_CFLAGS)
mod_raven_la_LIBADD = $(switch_builddir)/libfreeswitch.la
mod_raven_la_LDFLAGS = -avoid-version -module -no-undefined -shared

11
src/mod/loggers/mod_raven/conf/autoload_configs/raven.conf.xml Normal file
View File

@ -0,0 +1,11 @@
<configuration name="raven.conf" description="Raven Logger">
<settings>
<param name="uri" value=""/>
<param name="key" value=""/>
<param name="secret" value=""/>
<param name="key" value=""/>
<param name="project" value=""/>
<param name="loglevel" value="err"/>
<param name="uuid" value="true"/>
</settings>
</configuration>

320
src/mod/loggers/mod_raven/mod_raven.c Normal file
View File

@ -0,0 +1,320 @@
/*
* 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;
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:
*/