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$")
37 #include <sys/types.h>
46 #include "asterisk/channel.h"
47 #include "asterisk/cdr.h"
48 #include "asterisk/module.h"
49 #include "asterisk/config.h"
50 #include "asterisk/pbx.h"
51 #include "asterisk/logger.h"
52 #include "asterisk/utils.h"
54 #define CUSTOM_LOG_DIR "/cdr_custom"
56 #define DATE_FORMAT "%Y-%m-%d %T"
58 AST_MUTEX_DEFINE_STATIC(lock
);
60 static char *name
= "cdr-custom";
62 static FILE *mf
= NULL
;
64 static char master
[PATH_MAX
];
65 static char format
[1024]="";
67 static int load_config(int reload
)
69 struct ast_config
*cfg
;
70 struct ast_variable
*var
;
75 if((cfg
= ast_config_load("cdr_custom.conf"))) {
76 var
= ast_variable_browse(cfg
, "mappings");
78 ast_mutex_lock(&lock
);
79 if (!ast_strlen_zero(var
->name
) && !ast_strlen_zero(var
->value
)) {
80 if (strlen(var
->value
) > (sizeof(format
) - 2))
81 ast_log(LOG_WARNING
, "Format string too long, will be truncated, at line %d\n", var
->lineno
);
82 strncpy(format
, var
->value
, sizeof(format
) - 2);
84 snprintf(master
, sizeof(master
),"%s/%s/%s", ast_config_AST_LOG_DIR
, name
, var
->name
);
85 ast_mutex_unlock(&lock
);
87 ast_log(LOG_NOTICE
, "Mapping must have both filename and format at line %d\n", var
->lineno
);
89 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
);
92 ast_config_destroy(cfg
);
96 ast_log(LOG_WARNING
, "Failed to reload configuration file.\n");
98 ast_log(LOG_WARNING
, "Failed to load configuration file. Module not activated.\n");
106 static int custom_log(struct ast_cdr
*cdr
)
108 /* Make sure we have a big enough buf */
110 struct ast_channel dummy
;
112 /* Abort if no master file is specified */
113 if (ast_strlen_zero(master
))
116 memset(buf
, 0 , sizeof(buf
));
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 mf
= fopen(master
, "a");
127 ast_log(LOG_ERROR
, "Unable to re-open master file %s : %s\n", master
, strerror(errno
));
131 fflush(mf
); /* be particularly anal here */
138 static int unload_module(void)
142 ast_cdr_unregister(name
);
146 static int load_module(void)
150 if (!load_config(0)) {
151 res
= ast_cdr_register(name
, ast_module_info
->description
, custom_log
);
153 ast_log(LOG_ERROR
, "Unable to register custom CDR handling\n");
158 return AST_MODULE_LOAD_DECLINE
;
161 static int reload(void)
163 return load_config(1);
166 AST_MODULE_INFO(ASTERISK_GPL_KEY
, AST_MODFLAG_DEFAULT
, "Customizable Comma Separated Values CDR Backend",
168 .unload
= unload_module
,