remove obsolete stuff
git-svn-id: http://svn.digium.com/svn/asterisk/trunk@9124 f38db490-d61c-443f-a65b-d21fe96a405b
This commit is contained in:
kpfleming
parent
e2230d0f19
commit
1168220a4d
|
|
@ -26,12 +26,6 @@ APPS=app_adsiprog.so app_alarmreceiver.so app_authenticate.so app_cdr.so \
|
|||
app_userevent.so app_url.so app_verbose.so app_voicemail.so \
|
||||
app_waitforring.so app_waitforsilence.so app_while.so app_zapateller.so \
|
||||
app_morsecode.so
|
||||
|
||||
#
|
||||
# Obsolete things...
|
||||
#
|
||||
#APPS+=app_sql_postgres.so
|
||||
#APPS+=app_sql_odbc.so
|
||||
|
||||
#
|
||||
# Experimental things
|
||||
|
|
|
|||
|
|
@ -1,236 +0,0 @@
|
|||
/*
|
||||
* Asterisk -- An open source telephony toolkit.
|
||||
*
|
||||
* Copyright (C) 1999 - 2005, Digium, Inc.
|
||||
*
|
||||
* Mark Spencer <markster@digium.com>
|
||||
*
|
||||
* See http://www.asterisk.org for more information about
|
||||
* the Asterisk project. Please do not directly contact
|
||||
* any of the maintainers of this project for assistance;
|
||||
* the project provides a web site, mailing lists and IRC
|
||||
* channels for your use.
|
||||
*
|
||||
* This program is free software, distributed under the terms of
|
||||
* the GNU General Public License Version 2. See the LICENSE file
|
||||
* at the top of the source tree.
|
||||
*/
|
||||
|
||||
/*! \file
|
||||
*
|
||||
* \brief Use /dev/dsp as an intercom.
|
||||
*
|
||||
* \author Mark Spencer <markster@digium.com>
|
||||
*
|
||||
* \ingroup applications
|
||||
*/
|
||||
|
||||
#include <stdio.h>
|
||||
#include <unistd.h>
|
||||
#include <errno.h>
|
||||
#include <sys/ioctl.h>
|
||||
#include <string.h>
|
||||
#include <stdlib.h>
|
||||
#include <sys/time.h>
|
||||
#include <netinet/in.h>
|
||||
|
||||
#if defined(__linux__)
|
||||
#include <linux/soundcard.h>
|
||||
#elif defined(__FreeBSD__)
|
||||
#include <sys/soundcard.h>
|
||||
#else
|
||||
#include <soundcard.h>
|
||||
#endif
|
||||
|
||||
#include "asterisk.h"
|
||||
|
||||
ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
|
||||
|
||||
#include "asterisk/lock.h"
|
||||
#include "asterisk/file.h"
|
||||
#include "asterisk/frame.h"
|
||||
#include "asterisk/logger.h"
|
||||
#include "asterisk/channel.h"
|
||||
#include "asterisk/pbx.h"
|
||||
#include "asterisk/module.h"
|
||||
#include "asterisk/translate.h"
|
||||
|
||||
#ifdef __OpenBSD__
|
||||
#define DEV_DSP "/dev/audio"
|
||||
#else
|
||||
#define DEV_DSP "/dev/dsp"
|
||||
#endif
|
||||
|
||||
/* Number of 32 byte buffers -- each buffer is 2 ms */
|
||||
#define BUFFER_SIZE 32
|
||||
|
||||
static char *tdesc = "Intercom using /dev/dsp for output";
|
||||
|
||||
static char *app = "Intercom";
|
||||
|
||||
static char *synopsis = "(Obsolete) Send to Intercom";
|
||||
static char *descrip =
|
||||
" Intercom(): Sends the user to the intercom (i.e. /dev/dsp). This program\n"
|
||||
"is generally considered obselete by the chan_oss module. User can terminate\n"with a DTMF tone, or by hangup.\n";
|
||||
|
||||
STANDARD_LOCAL_USER;
|
||||
|
||||
LOCAL_USER_DECL;
|
||||
|
||||
AST_MUTEX_DEFINE_STATIC(sound_lock);
|
||||
static int sound = -1;
|
||||
|
||||
static int write_audio(short *data, int len)
|
||||
{
|
||||
int res;
|
||||
struct audio_buf_info info;
|
||||
ast_mutex_lock(&sound_lock);
|
||||
if (sound < 0) {
|
||||
ast_log(LOG_WARNING, "Sound device closed?\n");
|
||||
ast_mutex_unlock(&sound_lock);
|
||||
return -1;
|
||||
}
|
||||
if (ioctl(sound, SNDCTL_DSP_GETOSPACE, &info)) {
|
||||
ast_log(LOG_WARNING, "Unable to read output space\n");
|
||||
ast_mutex_unlock(&sound_lock);
|
||||
return -1;
|
||||
}
|
||||
res = write(sound, data, len);
|
||||
ast_mutex_unlock(&sound_lock);
|
||||
return res;
|
||||
}
|
||||
|
||||
static int create_audio(void)
|
||||
{
|
||||
int fmt, desired, res, fd;
|
||||
fd = open(DEV_DSP, O_WRONLY);
|
||||
if (fd < 0) {
|
||||
ast_log(LOG_WARNING, "Unable to open %s: %s\n", DEV_DSP, strerror(errno));
|
||||
close(fd);
|
||||
return -1;
|
||||
}
|
||||
fmt = AFMT_S16_LE;
|
||||
res = ioctl(fd, SNDCTL_DSP_SETFMT, &fmt);
|
||||
if (res < 0) {
|
||||
ast_log(LOG_WARNING, "Unable to set format to 16-bit signed\n");
|
||||
close(fd);
|
||||
return -1;
|
||||
}
|
||||
fmt = 0;
|
||||
res = ioctl(fd, SNDCTL_DSP_STEREO, &fmt);
|
||||
if (res < 0) {
|
||||
ast_log(LOG_WARNING, "Failed to set audio device to mono\n");
|
||||
close(fd);
|
||||
return -1;
|
||||
}
|
||||
/* 8000 Hz desired */
|
||||
desired = 8000;
|
||||
fmt = desired;
|
||||
res = ioctl(fd, SNDCTL_DSP_SPEED, &fmt);
|
||||
if (res < 0) {
|
||||
ast_log(LOG_WARNING, "Failed to set audio device to mono\n");
|
||||
close(fd);
|
||||
return -1;
|
||||
}
|
||||
if (fmt != desired) {
|
||||
ast_log(LOG_WARNING, "Requested %d Hz, got %d Hz -- sound may be choppy\n", desired, fmt);
|
||||
}
|
||||
#if 1
|
||||
/* 2 bytes * 15 units of 2^5 = 32 bytes per buffer */
|
||||
fmt = ((BUFFER_SIZE) << 16) | (0x0005);
|
||||
res = ioctl(fd, SNDCTL_DSP_SETFRAGMENT, &fmt);
|
||||
if (res < 0) {
|
||||
ast_log(LOG_WARNING, "Unable to set fragment size -- sound may be choppy\n");
|
||||
}
|
||||
#endif
|
||||
sound = fd;
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int intercom_exec(struct ast_channel *chan, void *data)
|
||||
{
|
||||
int res = 0;
|
||||
struct localuser *u;
|
||||
struct ast_frame *f;
|
||||
int oreadformat;
|
||||
LOCAL_USER_ADD(u);
|
||||
/* Remember original read format */
|
||||
oreadformat = chan->readformat;
|
||||
/* Set mode to signed linear */
|
||||
res = ast_set_read_format(chan, AST_FORMAT_SLINEAR);
|
||||
if (res < 0) {
|
||||
ast_log(LOG_WARNING, "Unable to set format to signed linear on channel %s\n", chan->name);
|
||||
LOCAL_USER_REMOVE(u);
|
||||
return -1;
|
||||
}
|
||||
/* Read packets from the channel */
|
||||
while(!res) {
|
||||
res = ast_waitfor(chan, -1);
|
||||
if (res > 0) {
|
||||
res = 0;
|
||||
f = ast_read(chan);
|
||||
if (f) {
|
||||
if (f->frametype == AST_FRAME_DTMF) {
|
||||
ast_frfree(f);
|
||||
break;
|
||||
} else {
|
||||
if (f->frametype == AST_FRAME_VOICE) {
|
||||
if (f->subclass == AST_FORMAT_SLINEAR) {
|
||||
res = write_audio(f->data, f->datalen);
|
||||
if (res > 0)
|
||||
res = 0;
|
||||
} else
|
||||
ast_log(LOG_DEBUG, "Unable to handle non-signed linear frame (%d)\n", f->subclass);
|
||||
}
|
||||
}
|
||||
ast_frfree(f);
|
||||
} else
|
||||
res = -1;
|
||||
}
|
||||
}
|
||||
|
||||
if (!res)
|
||||
ast_set_read_format(chan, oreadformat);
|
||||
|
||||
LOCAL_USER_REMOVE(u);
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
int unload_module(void)
|
||||
{
|
||||
int res;
|
||||
|
||||
if (sound > -1)
|
||||
close(sound);
|
||||
|
||||
res = ast_unregister_application(app);
|
||||
|
||||
STANDARD_HANGUP_LOCALUSERS;
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
int load_module(void)
|
||||
{
|
||||
if (create_audio())
|
||||
return -1;
|
||||
return ast_register_application(app, intercom_exec, synopsis, descrip);
|
||||
}
|
||||
|
||||
char *description(void)
|
||||
{
|
||||
return tdesc;
|
||||
}
|
||||
|
||||
int usecount(void)
|
||||
{
|
||||
int res;
|
||||
STANDARD_USECOUNT(res);
|
||||
return res;
|
||||
}
|
||||
|
||||
char *key()
|
||||
{
|
||||
return ASTERISK_GPL_KEY;
|
||||
}
|
||||
|
|
@ -1,541 +0,0 @@
|
|||
/*
|
||||
* Asterisk -- An open source telephony toolkit.
|
||||
*
|
||||
* Copyright (C) 2002, Christos Ricudis
|
||||
*
|
||||
* Christos Ricudis <ricudis@itc.auth.gr>
|
||||
*
|
||||
* See http://www.asterisk.org for more information about
|
||||
* the Asterisk project. Please do not directly contact
|
||||
* any of the maintainers of this project for assistance;
|
||||
* the project provides a web site, mailing lists and IRC
|
||||
* channels for your use.
|
||||
*
|
||||
* This program is free software, distributed under the terms of
|
||||
* the GNU General Public License Version 2. See the LICENSE file
|
||||
* at the top of the source tree.
|
||||
*/
|
||||
|
||||
/*! \file
|
||||
*
|
||||
* \brief Connect to PostgreSQL
|
||||
*
|
||||
* \author Christos Ricudis <ricudis@itc.auth.gr>
|
||||
*
|
||||
* \ingroup applications
|
||||
*/
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <unistd.h>
|
||||
#include <string.h>
|
||||
#include <sys/types.h>
|
||||
#include <stdio.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#include "asterisk.h"
|
||||
|
||||
ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
|
||||
|
||||
#include "asterisk/file.h"
|
||||
#include "asterisk/logger.h"
|
||||
#include "asterisk/channel.h"
|
||||
#include "asterisk/pbx.h"
|
||||
#include "asterisk/module.h"
|
||||
#include "asterisk/linkedlists.h"
|
||||
#include "asterisk/chanvars.h"
|
||||
#include "asterisk/lock.h"
|
||||
#include "asterisk/utils.h"
|
||||
|
||||
#include "libpq-fe.h"
|
||||
|
||||
static char *tdesc = "Simple PostgreSQL Interface";
|
||||
|
||||
static char *app = "PGSQL";
|
||||
|
||||
static char *synopsis = "Do several SQLy things";
|
||||
|
||||
static char *descrip =
|
||||
"PGSQL(): Do several SQLy things\n"
|
||||
"Syntax:\n"
|
||||
" PGSQL(Connect var option-string)\n"
|
||||
" Connects to a database. Option string contains standard PostgreSQL\n"
|
||||
" parameters like host=, dbname=, user=. Connection identifier returned\n"
|
||||
" in ${var}.\n"
|
||||
" PGSQL(Query var ${connection_identifier} query-string)\n"
|
||||
" Executes standard SQL query contained in query-string using established\n"
|
||||
" connection identified by ${connection_identifier}. Result of query is\n"
|
||||
" stored in ${var}.\n"
|
||||
" PGSQL(Fetch statusvar ${result_identifier} var1 var2 ... varn)\n"
|
||||
" Fetches a single row from a result set contained in ${result_identifier}.\n"
|
||||
" Assigns returned fields to ${var1} ... ${varn}. ${statusvar} is set TRUE\n"
|
||||
" if additional rows exist in result set.\n"
|
||||
" PGSQL(Clear ${result_identifier})\n"
|
||||
" Frees memory and data structures associated with result set.\n"
|
||||
" PGSQL(Disconnect ${connection_identifier})\n"
|
||||
" Disconnects from named connection to PostgreSQL.\n" ;
|
||||
|
||||
/*
|
||||
|
||||
Syntax of SQL commands :
|
||||
|
||||
Connect var option-string
|
||||
|
||||
Connects to a database using the option-string and stores the
|
||||
connection identifier in ${var}
|
||||
|
||||
|
||||
Query var ${connection_identifier} query-string
|
||||
|
||||
Submits query-string to database backend and stores the result
|
||||
identifier in ${var}
|
||||
|
||||
|
||||
Fetch statusvar ${result_identifier} var1 var2 var3 ... varn
|
||||
|
||||
Fetches a row from the query and stores end-of-table status in
|
||||
${statusvar} and columns in ${var1} ... ${varn}
|
||||
|
||||
|
||||
Clear ${result_identifier}
|
||||
|
||||
Clears data structures associated with ${result_identifier}
|
||||
|
||||
|
||||
Disconnect ${connection_identifier}
|
||||
|
||||
Disconnects from named connection
|
||||
|
||||
|
||||
EXAMPLES OF USE :
|
||||
|
||||
exten => s,2,PGSQL(Connect connid host=localhost user=asterisk dbname=credit)
|
||||
exten => s,3,PGSQL(Query resultid ${connid} SELECT username,credit FROM credit WHERE callerid=${CALLERIDNUM})
|
||||
exten => s,4,PGSQL(Fetch fetchid ${resultid} datavar1 datavar2)
|
||||
exten => s,5,GotoIf(${fetchid}?6:8)
|
||||
exten => s,6,Festival("User ${datavar1} currently has credit balance of ${datavar2} dollars.")
|
||||
exten => s,7,Goto(s,4)
|
||||
exten => s,8,PGSQL(Clear ${resultid})
|
||||
exten => s,9,PGSQL(Disconnect ${connid})
|
||||
|
||||
*/
|
||||
|
||||
STANDARD_LOCAL_USER;
|
||||
|
||||
LOCAL_USER_DECL;
|
||||
|
||||
enum id_type {
|
||||
AST_PGSQL_ID_DUMMY = 0,
|
||||
AST_PGSQL_ID_CONNID,
|
||||
AST_PGSQL_ID_RESID,
|
||||
AST_PGSQL_ID_FETCHID
|
||||
};
|
||||
|
||||
struct ast_PGSQL_id {
|
||||
enum id_type identifier_type; /* 0 = dummy, 1 = connid, 2 = resultid, 3 = fetchid */
|
||||
int identifier;
|
||||
void *data;
|
||||
AST_LIST_ENTRY(ast_PGSQL_id) entries;
|
||||
} *ast_PGSQL_id;
|
||||
|
||||
AST_LIST_HEAD(PGSQLidshead, ast_PGSQL_id) PGSQLidshead;
|
||||
|
||||
static void *find_identifier(const int identifier, const enum id_type identifier_type)
|
||||
{
|
||||
struct PGSQLidshead *headp;
|
||||
struct ast_PGSQL_id *i;
|
||||
void *res = NULL;
|
||||
int found = 0;
|
||||
|
||||
headp = &PGSQLidshead;
|
||||
|
||||
if (AST_LIST_LOCK(headp)) {
|
||||
ast_log(LOG_WARNING, "Unable to lock identifiers list\n");
|
||||
} else {
|
||||
AST_LIST_TRAVERSE(headp, i, entries) {
|
||||
if ((i->identifier == identifier) && (i->identifier_type == identifier_type)) {
|
||||
found = 1;
|
||||
res = i->data;
|
||||
break;
|
||||
}
|
||||
}
|
||||
if (!found) {
|
||||
ast_log(LOG_WARNING, "Identifier %d, identifier_type %d not found in identifier list\n", identifier, identifier_type);
|
||||
}
|
||||
AST_LIST_UNLOCK(headp);
|
||||
}
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
static int add_identifier(const enum id_type identifier_type, void *data)
|
||||
{
|
||||
struct ast_PGSQL_id *i, *j;
|
||||
struct PGSQLidshead *headp;
|
||||
int maxidentifier = 0;
|
||||
|
||||
headp = &PGSQLidshead;
|
||||
i = NULL;
|
||||
j = NULL;
|
||||
|
||||
if (AST_LIST_LOCK(headp)) {
|
||||
ast_log(LOG_WARNING, "Unable to lock identifiers list\n");
|
||||
return -1;
|
||||
}
|
||||
|
||||
if (!(i = ast_malloc(sizeof(*i)))) {
|
||||
AST_LIST_UNLOCK(headp);
|
||||
return -1;
|
||||
}
|
||||
|
||||
AST_LIST_TRAVERSE(headp, j, entries) {
|
||||
if (j->identifier > maxidentifier)
|
||||
maxidentifier = j->identifier;
|
||||
}
|
||||
i->identifier = maxidentifier + 1;
|
||||
i->identifier_type = identifier_type;
|
||||
i->data = data;
|
||||
AST_LIST_INSERT_HEAD(headp, i, entries);
|
||||
AST_LIST_UNLOCK(headp);
|
||||
|
||||
return i->identifier;
|
||||
}
|
||||
|
||||
static int del_identifier(const int identifier, const enum id_type identifier_type)
|
||||
{
|
||||
struct ast_PGSQL_id *i;
|
||||
struct PGSQLidshead *headp;
|
||||
int found = 0;
|
||||
|
||||
headp = &PGSQLidshead;
|
||||
|
||||
if (AST_LIST_LOCK(headp)) {
|
||||
ast_log(LOG_WARNING, "Unable to lock identifiers list\n");
|
||||
} else {
|
||||
AST_LIST_TRAVERSE(headp, i, entries) {
|
||||
if ((i->identifier == identifier) && (i->identifier_type == identifier_type)) {
|
||||
AST_LIST_REMOVE(headp, i, entries);
|
||||
free(i);
|
||||
found = 1;
|
||||
break;
|
||||
}
|
||||
}
|
||||
AST_LIST_UNLOCK(headp);
|
||||
}
|
||||
|
||||
if (!found) {
|
||||
ast_log(LOG_WARNING, "Could not find identifier %d, identifier_type %d in list to delete\n", identifier, identifier_type);
|
||||
return -1;
|
||||
} else {
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
static int aPGSQL_connect(struct ast_channel *chan, void *data)
|
||||
{
|
||||
char s[100] = "";
|
||||
char *optionstring;
|
||||
char *var;
|
||||
int res = 0;
|
||||
PGconn *PGSQLconn;
|
||||
int id;
|
||||
char *stringp = NULL;
|
||||
|
||||
if (!(stringp = ast_strdupa(data)))
|
||||
return -1;
|
||||
|
||||
strsep(&stringp, " "); /* eat the first token, we already know it :P */
|
||||
var = strsep(&stringp, " ");
|
||||
optionstring = strsep(&stringp, "\n");
|
||||
|
||||
PGSQLconn = PQconnectdb(optionstring);
|
||||
if (PQstatus(PGSQLconn) == CONNECTION_BAD) {
|
||||
ast_log(LOG_WARNING, "Connection to database using '%s' failed. postgress reports : %s\n", optionstring, PQerrorMessage(PGSQLconn));
|
||||
res = -1;
|
||||
} else {
|
||||
ast_log(LOG_WARNING, "Adding identifier\n");
|
||||
id = add_identifier(AST_PGSQL_ID_CONNID, PGSQLconn);
|
||||
snprintf(s, sizeof(s), "%d", id);
|
||||
pbx_builtin_setvar_helper(chan, var, s);
|
||||
}
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
static int aPGSQL_query(struct ast_channel *chan, void *data)
|
||||
{
|
||||
char *s2, *s3;
|
||||
char s[100] = "";
|
||||
char *querystring;
|
||||
char *var;
|
||||
int res = 0, nres;
|
||||
PGconn *PGSQLconn;
|
||||
PGresult *PGSQLres;
|
||||
int id, id1;
|
||||
char *stringp = NULL;
|
||||
|
||||
if (!(stringp = ast_strdupa(data)))
|
||||
return -1;
|
||||
|
||||
strsep(&stringp, " "); /* eat the first token, we already know it :P */
|
||||
s2 = strsep(&stringp, " ");
|
||||
while (1) { /* ugly trick to make branches with break; */
|
||||
var = s2;
|
||||
s3 = strsep(&stringp, " ");
|
||||
id = atoi(s3);
|
||||
querystring = strsep(&stringp, "\n");
|
||||
if (!(PGSQLconn = find_identifier(id, AST_PGSQL_ID_CONNID))) {
|
||||
ast_log(LOG_WARNING, "Invalid connection identifier %d passed in aPGSQL_query\n", id);
|
||||
res = -1;
|
||||
break;
|
||||
}
|
||||
if (!(PGSQLres = PQexec(PGSQLconn, querystring))) {
|
||||
ast_log(LOG_WARNING, "aPGSQL_query: Connection Error (connection identifier = %d, error message : %s)\n", id, PQerrorMessage(PGSQLconn));
|
||||
res = -1;
|
||||
break;
|
||||
}
|
||||
if (PQresultStatus(PGSQLres) == PGRES_BAD_RESPONSE ||
|
||||
PQresultStatus(PGSQLres) == PGRES_NONFATAL_ERROR ||
|
||||
PQresultStatus(PGSQLres) == PGRES_FATAL_ERROR) {
|
||||
ast_log(LOG_WARNING, "aPGSQL_query: Query Error (connection identifier : %d, error message : %s)\n", id, PQcmdStatus(PGSQLres));
|
||||
res = -1;
|
||||
break;
|
||||
}
|
||||
nres = PQnfields(PGSQLres);
|
||||
id1 = add_identifier(AST_PGSQL_ID_RESID, PGSQLres);
|
||||
snprintf(s, sizeof(s), "%d", id1);
|
||||
pbx_builtin_setvar_helper(chan, var, s);
|
||||
break;
|
||||
}
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
static int aPGSQL_fetch(struct ast_channel *chan, void *data)
|
||||
{
|
||||
char *s2, *s3, *s4, *fetchid_var;
|
||||
const char *s5 = NULL;
|
||||
char s[100];
|
||||
char *var;
|
||||
int res = 0;
|
||||
PGresult *PGSQLres;
|
||||
int id, id1, i, j, fnd;
|
||||
int *identp = NULL;
|
||||
int nres;
|
||||
struct ast_var_t *variables;
|
||||
struct varshead *headp;
|
||||
char *stringp = NULL;
|
||||
|
||||
headp = &chan->varshead;
|
||||
|
||||
if (!(stringp = ast_strdupa(data)))
|
||||
return -1;
|
||||
|
||||
strsep(&stringp, " "); /* eat the first token, we already know it :P */
|
||||
fetchid_var = strsep(&stringp, " ");
|
||||
while (1) { /* ugly trick to make branches with break; */
|
||||
var = fetchid_var; /* fetchid */
|
||||
fnd = 0;
|
||||
|
||||
AST_LIST_TRAVERSE(headp, variables, entries) {
|
||||
if (!(strncasecmp(ast_var_name(variables), fetchid_var, strlen(fetchid_var)))) {
|
||||
s5 = ast_var_value(variables);
|
||||
fnd = 1;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (!fnd) {
|
||||
s5 = "0";
|
||||
pbx_builtin_setvar_helper(chan, fetchid_var, s5);
|
||||
}
|
||||
|
||||
s2 = strsep(&stringp, " ");
|
||||
id = atoi(s2); /* resultid */
|
||||
if (!(PGSQLres = find_identifier(id, AST_PGSQL_ID_RESID))) {
|
||||
ast_log(LOG_WARNING, "Invalid result identifier %d passed in aPGSQL_fetch\n", id);
|
||||
res = -1;
|
||||
break;
|
||||
}
|
||||
id = atoi(s5); /*fetchid */
|
||||
if (!(identp = find_identifier(id, AST_PGSQL_ID_FETCHID))) {
|
||||
i = 0; /* fetching the very first row */
|
||||
} else {
|
||||
i = *identp;
|
||||
free(identp);
|
||||
del_identifier(id, AST_PGSQL_ID_FETCHID); /* will re-add it a bit later */
|
||||
}
|
||||
|
||||
if (i < PQntuples(PGSQLres)) {
|
||||
nres = PQnfields(PGSQLres);
|
||||
ast_log(LOG_WARNING, "ast_PGSQL_fetch : nres = %d i = %d ;\n", nres, i);
|
||||
for (j = 0; j < nres; j++) {
|
||||
if (!(s3 = strsep(&stringp, " "))) {
|
||||
ast_log(LOG_WARNING, "ast_PGSQL_fetch : More tuples (%d) than variables (%d)\n", nres, j);
|
||||
break;
|
||||
}
|
||||
if (!(s4 = PQgetvalue(PGSQLres, i, j))) {
|
||||
ast_log(LOG_WARNING, "PQgetvalue(res, %d, %d) returned NULL in ast_PGSQL_fetch\n", i, j);
|
||||
break;
|
||||
}
|
||||
ast_log(LOG_WARNING, "===setting variable '%s' to '%s'\n", s3, s4);
|
||||
pbx_builtin_setvar_helper(chan, s3, s4);
|
||||
}
|
||||
if (!(identp = ast_malloc(sizeof(int))))
|
||||
return -1;
|
||||
*identp = ++i; /* advance to the next row */
|
||||
id1 = add_identifier(AST_PGSQL_ID_FETCHID, identp);
|
||||
} else {
|
||||
ast_log(LOG_WARNING, "ast_PGSQL_fetch : EOF\n");
|
||||
id1 = 0; /* no more rows */
|
||||
}
|
||||
snprintf(s, sizeof(s), "%d", id1);
|
||||
ast_log(LOG_WARNING, "Setting var '%s' to value '%s'\n", fetchid_var, s);
|
||||
pbx_builtin_setvar_helper(chan, fetchid_var, s);
|
||||
break;
|
||||
}
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
static int aPGSQL_reset(struct ast_channel *chan, void *data)
|
||||
{
|
||||
char *s;
|
||||
PGconn *PGSQLconn;
|
||||
int id;
|
||||
char *stringp = NULL;
|
||||
|
||||
if (!(stringp = ast_strdupa(data)))
|
||||
return -1;
|
||||
|
||||
strsep(&stringp, " "); /* eat the first token, we already know it :P */
|
||||
s = strsep(&stringp, " ");
|
||||
id = atoi(s);
|
||||
if (!(PGSQLconn = find_identifier(id, AST_PGSQL_ID_CONNID))) {
|
||||
ast_log(LOG_WARNING, "Invalid connection identifier %d passed in aPGSQL_reset\n", id);
|
||||
} else {
|
||||
PQreset(PGSQLconn);
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int aPGSQL_clear(struct ast_channel *chan, void *data)
|
||||
{
|
||||
char *s;
|
||||
PGresult *PGSQLres;
|
||||
int id;
|
||||
char *stringp = NULL;
|
||||
|
||||
if (!(stringp = ast_strdupa(data)))
|
||||
return -1;
|
||||
|
||||
strsep(&stringp, " "); /* eat the first token, we already know it :P */
|
||||
s = strsep(&stringp, " ");
|
||||
id = atoi(s);
|
||||
if (!(PGSQLres = find_identifier(id, AST_PGSQL_ID_RESID))) {
|
||||
ast_log(LOG_WARNING, "Invalid result identifier %d passed in aPGSQL_clear\n", id);
|
||||
} else {
|
||||
PQclear(PGSQLres);
|
||||
del_identifier(id, AST_PGSQL_ID_RESID);
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int aPGSQL_disconnect(struct ast_channel *chan, void *data)
|
||||
{
|
||||
char *s;
|
||||
PGconn *PGSQLconn;
|
||||
int id;
|
||||
char *stringp = NULL;
|
||||
|
||||
if (!(stringp = ast_strdupa(data)))
|
||||
return -1;
|
||||
|
||||
strsep(&stringp, " "); /* eat the first token, we already know it :P */
|
||||
s = strsep(&stringp, " ");
|
||||
id = atoi(s);
|
||||
if (!(PGSQLconn = find_identifier(id, AST_PGSQL_ID_CONNID))) {
|
||||
ast_log(LOG_WARNING, "Invalid connection identifier %d passed in aPGSQL_disconnect\n", id);
|
||||
} else {
|
||||
PQfinish(PGSQLconn);
|
||||
del_identifier(id, AST_PGSQL_ID_CONNID);
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int aPGSQL_debug(struct ast_channel *chan, void *data)
|
||||
{
|
||||
ast_log(LOG_WARNING, "Debug : %s\n", (char *)data);
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int PGSQL_exec(struct ast_channel *chan, void *data)
|
||||
{
|
||||
struct localuser *u;
|
||||
int result;
|
||||
|
||||
if (ast_strlen_zero(data)) {
|
||||
ast_log(LOG_WARNING, "APP_PGSQL requires an argument (see manual)\n");
|
||||
return -1;
|
||||
}
|
||||
|
||||
LOCAL_USER_ADD(u);
|
||||
|
||||
result = 0;
|
||||
|
||||
if (!(strncasecmp("connect", data, strlen("connect")))) {
|
||||
result = (aPGSQL_connect(chan, data));
|
||||
} else if (!(strncasecmp("query", data, strlen("query")))) {
|
||||
result = (aPGSQL_query(chan, data));
|
||||
} else if (!(strncasecmp("fetch", data, strlen("fetch")))) {
|
||||
result = (aPGSQL_fetch(chan, data));
|
||||
} else if (!(strncasecmp("reset", data, strlen("reset")))) {
|
||||
result = (aPGSQL_reset(chan, data));
|
||||
} else if (!(strncasecmp("clear", data, strlen("clear")))) {
|
||||
result = (aPGSQL_clear(chan, data));
|
||||
} else if (!(strncasecmp("debug", data, strlen("debug")))) {
|
||||
result = (aPGSQL_debug(chan, data));
|
||||
} else if (!(strncasecmp("disconnect", data, strlen("disconnect")))) {
|
||||
result = (aPGSQL_disconnect(chan, data));
|
||||
} else {
|
||||
ast_log(LOG_WARNING, "Unknown APP_PGSQL argument : %s\n", (char *)data);
|
||||
result = -1;
|
||||
}
|
||||
|
||||
LOCAL_USER_REMOVE(u);
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
int unload_module(void)
|
||||
{
|
||||
int res = ast_unregister_application(app);
|
||||
STANDARD_HANGUP_LOCALUSERS;
|
||||
return res;
|
||||
}
|
||||
|
||||
int load_module(void)
|
||||
{
|
||||
struct PGSQLidshead *headp = &PGSQLidshead;
|
||||
AST_LIST_HEAD_INIT(headp);
|
||||
return ast_register_application(app, PGSQL_exec, synopsis, descrip);
|
||||
}
|
||||
|
||||
char *description(void)
|
||||
{
|
||||
return tdesc;
|
||||
}
|
||||
|
||||
int usecount(void)
|
||||
{
|
||||
int res;
|
||||
STANDARD_USECOUNT(res);
|
||||
return res;
|
||||
}
|
||||
|
||||
char *key()
|
||||
{
|
||||
return ASTERISK_GPL_KEY;
|
||||
}
|
||||
Reference in New Issue