2 * Asterisk -- An open source telephony toolkit.
4 * Copyright (C) 1999 - 2005, Digium, Inc.
6 * Mark Spencer <markster@digium.com>
8 * Includes code and algorithms from the Zapata library.
10 * See http://www.asterisk.org for more information about
11 * the Asterisk project. Please do not directly contact
12 * any of the maintainers of this project for assistance;
13 * the project provides a web site, mailing lists and IRC
14 * channels for your use.
16 * This program is free software, distributed under the terms of
17 * the GNU General Public License Version 2. See the LICENSE file
18 * at the top of the source tree.
23 * \brief Custom Comma Separated Value CDR records.
25 * \author Mark Spencer <markster@digium.com>
27 * \arg See also \ref AstCDR
29 * Logs in LOG_DIR/cdr_custom
30 * \ingroup cdr_drivers
35 ASTERISK_FILE_VERSION(__FILE__
, "$Revision$")
39 #include "asterisk/paths.h" /* use ast_config_AST_LOG_DIR */
40 #include "asterisk/channel.h"
41 #include "asterisk/cdr.h"
42 #include "asterisk/module.h"
43 #include "asterisk/config.h"
44 #include "asterisk/pbx.h"
45 #include "asterisk/utils.h"
46 #include "asterisk/lock.h"
48 #define CUSTOM_LOG_DIR "/cdr_custom"
50 #define DATE_FORMAT "%Y-%m-%d %T"
52 AST_MUTEX_DEFINE_STATIC(lock
);
53 AST_MUTEX_DEFINE_STATIC(mf_lock
);
55 static char *name
= "cdr-custom";
57 static char master
[PATH_MAX
];
58 static char format
[1024]="";
60 static int load_config(int reload
)
62 struct ast_config
*cfg
;
63 struct ast_variable
*var
;
64 struct ast_flags config_flags
= { reload
? CONFIG_FLAG_FILEUNCHANGED
: 0 };
67 if ((cfg
= ast_config_load("cdr_custom.conf", config_flags
)) == CONFIG_STATUS_FILEUNCHANGED
)
72 ast_mutex_lock(&lock
);
74 var
= ast_variable_browse(cfg
, "mappings");
76 if (!ast_strlen_zero(var
->name
) && !ast_strlen_zero(var
->value
)) {
77 if (strlen(var
->value
) > (sizeof(format
) - 1))
78 ast_log(LOG_WARNING
, "Format string too long, will be truncated, at line %d\n", var
->lineno
);
79 ast_copy_string(format
, var
->value
, sizeof(format
) - 1);
81 snprintf(master
, sizeof(master
),"%s/%s/%s", ast_config_AST_LOG_DIR
, name
, var
->name
);
83 ast_log(LOG_NOTICE
, "Sorry, only one mapping is supported at this time, mapping '%s' will be ignored at line %d.\n", var
->next
->name
, var
->next
->lineno
);
87 ast_log(LOG_NOTICE
, "Mapping must have both filename and format at line %d\n", var
->lineno
);
90 ast_config_destroy(cfg
);
94 ast_log(LOG_WARNING
, "Failed to reload configuration file.\n");
96 ast_log(LOG_WARNING
, "Failed to load configuration file. Module not activated.\n");
98 ast_mutex_unlock(&lock
);
105 static int custom_log(struct ast_cdr
*cdr
)
109 /* Make sure we have a big enough buf */
111 struct ast_channel dummy
;
113 /* Abort if no master file is specified */
114 if (ast_strlen_zero(master
))
117 /* Quite possibly the first use of a static struct ast_channel, we need it so the var funcs will work */
118 memset(&dummy
, 0, sizeof(dummy
));
120 pbx_substitute_variables_helper(&dummy
, format
, buf
, sizeof(buf
) - 1);
122 /* because of the absolutely unconditional need for the
123 highest reliability possible in writing billing records,
124 we open write and close the log file each time */
125 ast_mutex_lock(&mf_lock
);
126 mf
= fopen(master
, "a");
129 fflush(mf
); /* be particularly anal here */
132 ast_mutex_unlock(&mf_lock
);
134 ast_log(LOG_ERROR
, "Unable to re-open master file %s : %s\n", master
, strerror(errno
));
135 ast_mutex_unlock(&mf_lock
);
141 static int unload_module(void)
143 ast_cdr_unregister(name
);
147 static int load_module(void)
151 if (!load_config(0)) {
152 res
= ast_cdr_register(name
, ast_module_info
->description
, custom_log
);
154 ast_log(LOG_ERROR
, "Unable to register custom CDR handling\n");
157 return AST_MODULE_LOAD_DECLINE
;
160 static int reload(void)
162 return load_config(1);
165 AST_MODULE_INFO(ASTERISK_GPL_KEY
, AST_MODFLAG_DEFAULT
, "Customizable Comma Separated Values CDR Backend",
167 .unload
= unload_module
,