Attachment #146339 for bug #212306

View | Details | Raw Unified | Return to bug 212306 | Differences between
Collapse All | Expand All




# Copyright 1999-2008 Gentoo Foundation
# Distributed under the terms of the GNU General Public License v2
# $Header: /var/cvsroot/gentoo-x86/net-misc/asterisk/asterisk-1.2.21.1-r1.ebuild,v 1.5 2008/02/21 18:14:20 welp Exp $

inherit eutils multilib toolchain-funcs

IUSE="alsa bri curl debug doc gtk h323 hardened lowmem mmx \
	nosamples odbc osp postgres pri speex sqlite ssl zaptel \
	elibc_uclibc backports"

BRI_VERSION="0.3.0-PRE-1y-p"
AST_PATCHES="1.2.26.2-patches-1.0"
JB_PATCHES="1.2.11-jb"

MY_P="${P/_p/.}"

DESCRIPTION="Asterisk: A Modular Open Source PBX System"
HOMEPAGE="http://www.asterisk.org/"
SRC_URI="http://ftp.digium.com/pub/asterisk/releases/${MY_P}.tar.gz
	 http://www.netdomination.org/pub/asterisk/${PN}-${AST_PATCHES}.tar.bz2
	 mirror://gentoo/${PN}-${AST_PATCHES}.tar.bz2
	 bri? ( mirror://gentoo/${MY_P}-bristuff-${BRI_VERSION}.diff.bz2
		http://www.junghanns.net/downloads/bristuff-${BRI_VERSION}.tar.gz )"

S="${WORKDIR}/${MY_P}"
S_BRI="${WORKDIR}/bristuff-${BRI_VERSION}"

SLOT="0"
LICENSE="GPL-2"
KEYWORDS="~alpha amd64 ~hppa ~ppc sparc x86"

RDEPEND="dev-libs/newt
	media-sound/sox
	ssl? ( dev-libs/openssl )
	gtk? ( =x11-libs/gtk+-1.2* )
	pri? ( >=net-libs/libpri-1.2.5 )
	h323? ( >=dev-libs/pwlib-1.8.3
		>=net-libs/openh323-1.15.0 )
	alsa? ( media-libs/alsa-lib )
	curl? ( net-misc/curl )
	odbc? ( dev-db/unixODBC )
	backports? ( dev-db/unixODBC )
	speex? ( media-libs/speex )
	sqlite? ( <dev-db/sqlite-3.0.0 )
	zaptel? ( >=net-misc/zaptel-1.2.16 )
	postgres? ( dev-db/postgresql )
	osp? ( >=net-libs/osptoolkit-3.3.4 )
	bri? (  >=net-libs/libpri-1.2.5
		>=net-misc/zaptel-1.2.18 )"

DEPEND="${RDEPEND}
	sys-devel/flex
	sys-devel/bison
	doc? ( app-doc/doxygen )
	virtual/logger"

#asterisk uses special mpg123 functions and does not work with mpeg321, bug #42703
PDEPEND="|| ( media-sound/mpg123 net-misc/asterisk-addons )"

QA_TEXTRELS_x86="usr/lib/asterisk/modules/codec_gsm.so"
QA_EXECSTACK_x86="usr/lib/asterisk/modules/codec_gsm.so"

#
# List of modules to ignore during scan (because they have been removed in 1.2.x)
#
SCAN_IGNORE_MODS="
	app_qcall
	chan_modem
	chan_modem_i4l
	chan_modem_bestdata
	chan_modme_aopen"

#
# shortcuts
#
is_ast10update() {
	return $(has_version "=net-misc/asterisk-1.0*")
}

is_astupdate() {
	if ! is_ast10update; then
		return $(has_version "<net-misc/asterisk-${PV}")
	fi
	return 0
}

#
# Display a nice countdown...
#
countdown() {
	local n

	ebeep

	n=${1:-10}
	while [[ $n -gt 0 ]]; do
		echo -en "  Waiting $n second(s)...\r"
		sleep 1
		(( n-- ))
	done
}

#
# Scan for asterisk-1.0.x modules that will have to be updated
#
scan_modules() {
	local modules_list=""
	local n

	for x in $(ls -1 "${ROOT}"usr/$(get_libdir)/asterisk/modules/*.so); do
		echo -en "Scanning.... $(basename ${x})   \r"

		# skip blacklisted modules
		hasq $(basename ${x//.so}) ${SCAN_IGNORE_MODS} && continue

		if $(readelf -s "${x}" | grep -q "\(ast_load\|ast_destroy\)$"); then
			modules_list="${modules_list} $(basename ${x//.so})"
		fi
	done

	if [[ -n "${modules_list}" ]]; then
		echo  "   ========================================================"
		ewarn "Please update or unmerge the following modules:"
		echo

		n=0
		for x in ${modules_list}; do
			ewarn " -   ${x}"
			(( n++ ))
		done

		echo
		ewarn "Warning: $n outdated module(s) found!"
		ewarn "Warning: asterisk may not work if you don't update them!"
		echo  "   ========================================================"
		echo
		einfo "You can use the \"asterisk-updater\" script to update the modules"
		echo
		countdown
		echo
		return 1
	else
		einfo "No asterisk-1.0.x modules found!"
		return 0
	fi
}

pkg_setup() {
	local checkfailed=0 waitaftermsg=0

	if is_ast10update; then
		ewarn "                      Asterisk UPGRADE Warning"
		ewarn ""
		ewarn "- Please read ${ROOT}usr/share/doc/${PF}/UPGRADE.txt.gz after the installation!"
		ewarn ""
		ewarn "                      Asterisk UPGRADE Warning"
		echo
		waitaftermsg=1
	fi

	if use bri; then
		if ! built_with_use net-libs/libpri bri; then
			die "net-libs/libpri must be rebuilt ith USE=bri."
		fi
	elif use pri; then
		if built_with_use net-libs/libpri bri; then
			die "net-libs/libpri must be rebuilt without USE=bri."
		fi
	fi

	#
	# Regular checks
	#
	einfo "Running some pre-flight checks..."
	echo

}

src_unpack() {
	unpack ${A}
	cd "${S}"

	#
	# gentoo patchset
	#
	for x in $(grep -v "^#\| \+" "${WORKDIR}"/patches/patches.list); do
		epatch "${WORKDIR}"/patches/${x}
	done

	if use mmx; then
		if ! use hardened; then
			einfo "Enabling mmx optimization"
			sed -i -e "s:^#\(K6OPT[\t ]\+= -DK6OPT\):\1:" \
				Makefile
		else
			ewarn "Hardened use-flag is set, not enabling mmx optimization for codec_gsm!"
		fi
	fi

	if ! use debug; then
		einfo "Disabling debug support"
		sed -i -e "s:^\(DEBUG=\):#\1:" \
			Makefile
	fi

	if ! use ssl; then
		einfo "Disabling crypto support"
		sed -i -e 's:^#\(NOCRYPTO=yes\):\1:' \
			-e '/^LIBS+=-lssl/d' Makefile || die
	fi

	epatch "${FILESDIR}"/1.2.0/asterisk-1.2.21.1-h323-dumb-makefile.diff

	#
	# uclibc patch
	#
	if use elibc_uclibc; then
		einfo "Patching asterisk for uclibc..."
		epatch "${FILESDIR}"/1.0.0/${PN}-1.0.5-uclibc-dns.diff
		epatch "${FILESDIR}"/1.2.0/${PN}-1.2.1-uclibc-getloadavg.diff
	fi

	#
	# BRI patches
	#
	if use bri; then
		einfo "Patching asterisk w/ BRI stuff"

		epatch "${WORKDIR}"/${MY_P}-bristuff-${BRI_VERSION}.diff
		#epatch "${S_BRI}"/patches/asterisk.patch
	fi

	#
	# Disable AEL, security bug #171884
	# Re-enable at your own risk (no USE since it can be critical)
	#
	sed -i -e 's/pbx_ael.so//' pbx/Makefile || die

	#
	# Some useful backports
	#
	if use backports; then
		einfo "Adding func_odbc backport"
		# http://svncommunity.digium.com/view/func_odbc/1.2/
		cp "${FILESDIR}"/1.2.0/backports/func_odbc/*.c "${WORKDIR}"/${P}/funcs/
		cp "${FILESDIR}"/1.2.0/backports/func_odbc/*.h "${WORKDIR}"/${P}/include/
		cp "${FILESDIR}"/1.2.0/backports/func_odbc/*.sample "${WORKDIR}"/${P}/configs/

		einfo "Adding app_stack2 backport"
		# http://svncommunity.digium.com/view/app_stack/1.2/
		cp "${FILESDIR}"/1.2.0/backports/app_stack/*.c "${WORKDIR}"/${P}/apps/
		epatch "${FILESDIR}"/1.2.0/backports/app_stack/asterisk-app_stack2-makefile.diff
	fi

}

src_compile() {
	local myopts

	use lowmem && \
		myopts="-DLOW_MEMORY"

	if use h323; then
		einfo "Building H.323 wrapper lib..."
		make -C channels/h323 \
			NOTRACE=1 \
			PWLIBDIR=/usr/share/pwlib \
			OPENH323DIR=/usr/share/openh323 \
			libchanh323.a Makefile.ast || die "Make h323 failed"
	fi

	einfo "Building Asterisk..."
	make \
		CC=$(tc-getCC) \
		NOTRACE=1 \
		OPTIMIZE="${CFLAGS}" \
		PWLIBDIR=/usr/share/pwlib \
		OPENH323DIR=/usr/share/openh323 \
		OPTIONS="${myopts}" || die "Make failed"

	# create api docs
	use doc && \
		make progdocs

	# build bristuff's ISDNguard
	use bri && \
		make -C "${S_BRI}"/ISDNguard
}

src_install() {

	# install asterisk
	make DESTDIR="${D}" ASTLIBDIR="\$(INSTALL_PREFIX)/usr/$(get_libdir)/asterisk" install || die "Make install failed"
	make DESTDIR="${D}" ASTLIBDIR="\$(INSTALL_PREFIX)/usr/$(get_libdir)/asterisk" samples || die "Failed to create sample files"

	# remove bristuff capi
	use bri && \
		rm -f "${D}"usr/$(get_libdir)/asterisk/modules/{app,chan}_capi*.so 2>/dev/null

	# remove installed sample files if nosamples flag is set
	if use nosamples; then
		einfo "Skipping installation of sample files..."
		rm -rf "${D}"var/spool/asterisk/voicemail/default
		rm -f  "${D}"var/lib/asterisk/mohmp3/*
		rm -f  "${D}"var/lib/asterisk/sounds/demo-*
		rm -f  "${D}"var/lib/asterisk/agi-bin/*
	else
		einfo "Sample files have been installed"
		keepdir /var/spool/asterisk/voicemail/default/1234/INBOX
	fi

	# move sample configuration files to doc directory
	if is_ast10update; then
		elog "Updating from old (pre-1.2) asterisk version, new configuration files have been installed"
		elog "into ${ROOT}etc/asterisk, use etc-update or dispatch-conf to update them"
	elif has_version "net-misc/asterisk"; then
		elog "Configuration samples have been moved to: $ROOT/usr/share/doc/${PF}/conf"
		insinto /usr/share/doc/${PF}/conf
		doins "${D}"etc/asterisk/*.conf*
		rm -f "${D}"etc/asterisk/*.conf* 2>/dev/null
	fi

	# don't delete these directories, even if they are empty
	for x in voicemail meetme system dictate monitor tmp; do
		keepdir /var/spool/asterisk/${x}
	done
	keepdir /var/lib/asterisk/sounds/priv-callerintros
	keepdir /var/lib/asterisk/mohmp3
	keepdir /var/lib/asterisk/agi-bin
	keepdir /var/log/asterisk/cdr-csv
	keepdir /var/log/asterisk/cdr-custom
	keepdir /var/run/asterisk

	# install astxs
	dobin  contrib/scripts/astxs

	newinitd "${FILESDIR}"/1.2.0/asterisk.rc6 asterisk
	newconfd "${FILESDIR}"/1.2.0/asterisk.confd asterisk

	# install standard docs...
	dodoc BUGS CREDITS LICENSE ChangeLog HARDWARE README README.fpm
	dodoc SECURITY doc/CODING-GUIDELINES doc/linkedlists.README UPGRADE.txt
	dodoc doc/README.*
	dodoc doc/*.txt

	docinto scripts
	dodoc contrib/scripts/*

	docinto utils
	dodoc contrib/utils/*

	docinto configs
	dodoc configs/*

	# install api docs
	if use doc; then
		insinto /usr/share/doc/${PF}/api/html
		doins doc/api/html/*
	fi

	# install ISDNguard
	if use bri; then
		cd "${S_BRI}"/ISDNguard
		dosbin ISDNguard

		docinto ISDNguard
		dodoc INSTALL.ISDNguard

		cd "${S}"
	fi

	insinto /usr/share/doc/${PF}/cgi
	doins contrib/scripts/vmail.cgi
	doins images/*.gif

	# install asterisk-updater
	dosbin "${FILESDIR}"/1.2.0/asterisk-updater

	# install asterisk.h, a lot of external modules need this
	insinto /usr/include/asterisk
	doins   include/asterisk.h

	# make sure misdn/capi stuff is not installed, provided by asterisk-chan_..
	rm -f "${D}"/etc/asterisk/misdn.conf "${D}"/usr/lib/asterisk/modules/chan_misdn.so \
		"${D}"/usr/share/doc/${PF}/{conf/misdn.conf,configs/misdn.conf.sample.gz,README.misdn.gz}
	rm -f "${D}"/usr/include/asterisk/chan_capi{,_app}.h \
		"${D}"/usr/share/doc/${PF}/{conf/capi.conf,configs/capi.conf.sample.gz}
}

pkg_preinst() {
	enewgroup asterisk
	enewuser asterisk -1 -1 /var/lib/asterisk asterisk
}

pkg_postinst() {
	einfo "Fixing permissions"
	chown -R asterisk:asterisk "${ROOT}"var/log/asterisk
	chmod -R u=rwX,g=rX,o=     "${ROOT}"var/log/asterisk

	for x in lib run spool; do
		chown -R asterisk:asterisk "${ROOT}"var/${x}/asterisk
		chmod -R u=rwX,g=rwX,o=    "${ROOT}"var/${x}/asterisk
	done

	chown asterisk:asterisk "${ROOT}"etc/asterisk/
	chown asterisk:asterisk "${ROOT}"etc/asterisk/*.adsi
	chown asterisk:asterisk "${ROOT}"etc/asterisk/extensions.ael
	chmod u=rwX,g=rwX,o= "${ROOT}"etc/asterisk/
	chmod u=rwX,g=rwX,o= "${ROOT}"etc/asterisk/*.adsi
	chmod u=rwX,g=rwX,o= "${ROOT}"etc/asterisk/extensions.ael
	echo

	#
	# Announcements, warnings, reminders...
	#
	einfo "Asterisk has been installed"
	einfo ""
	elog "If you want to know more about asterisk, visit these sites:"
	elog "http://www.asteriskdocs.org/"
	elog "http://www.voip-info.org/wiki-Asterisk"
	elog
	elog "http://www.automated.it/guidetoasterisk.htm"
	elog
	elog "Gentoo VoIP IRC Channel:"
	elog "#gentoo-voip @ irc.freenode.net"
	elog
	elog "Please note that AEL is no longer built because of security bugs"
	elog "See http://bugs.gentoo.org/show_bug.cgi?id=171884"
	elog
	echo
	echo

	#
	# Warning about 1.0 -> 1.2 changes...
	#
	if is_ast10update; then
		ewarn ""
		ewarn "- Please read ${ROOT}usr/share/doc/${PF}/UPGRADE.txt.gz before continuing"
		ewarn ""
	fi

	if is_astupdate; then
		ewarn ""
		ewarn " - The initgroups patch has been dropped, please update your"
		ewarn "   \"conf.d/asterisk\" and \"init.d/asterisk\" file!"
		ewarn ""
	fi

	# scan for old modules
	if is_ast10update; then
		einfo "Asterisk has been updated from pre-1.2.x, scanning for old modules"
		scan_modules
	fi
}

pkg_config() {
	einfo "Do you want to reset file permissions and ownerships (y/N)?"

	read tmp
	tmp="$(echo $tmp | tr [:upper:] [:lower:])"

	if [[ "$tmp" = "y" ]] ||\
	   [[ "$tmp" = "yes" ]]
	then
		einfo "Resetting permissions to defaults..."

		for x in spool run lib log; do
			chown -R asterisk:asterisk "${ROOT}"var/${x}/asterisk
			chmod -R u=rwX,g=rX,o=     "${ROOT}"var/${x}/asterisk
		done

		chown -R root:asterisk "${ROOT}"etc/asterisk
		chmod -R u=rwX,g=rX,o= "${ROOT}"etc/asterisk

		einfo "done"
	else
		einfo "skipping"
	fi
}




/*
 * Asterisk -- An open source telephony toolkit.
 *
 * Copyright (c) 2004-2006 Tilghman Lesher <app_stack_v003@the-tilghman.com>.
 *
 * This code is released by the author with no restrictions on usage.
 *
 * 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 Stack applications Gosub, Return, etc.
 * 
 * \ingroup applications
 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>

#include "asterisk/options.h"
#include "asterisk/logger.h"
#include "asterisk/channel.h"
#include "asterisk/chanvars.h"
#include "asterisk/pbx.h"
#include "asterisk/module.h"
#include "asterisk/config.h"
#include "asterisk/app.h"

#define STACKVAR	"~GOSUB2~STACK~"

static const char *tdesc = "Stack Routines";

static const char *app_gosub = "Gosub2";
static const char *app_gosubif = "GosubIf2";
static const char *app_return = "Return2";
static const char *app_pop = "StackPop2";

static const char *gosub_synopsis = "Jump to label, saving return address";
static const char *gosubif_synopsis = "Jump to label, saving return address";
static const char *return_synopsis = "Return from gosub routine";
static const char *pop_synopsis = "Remove one address from gosub stack";

static const char *gosub_descrip =
"Gosub2([[context|]exten|]priority[(arg1[|...][|argN])])\n"
"  Jumps to the label specified, saving the return address.\n";
static const char *gosubif_descrip =
"GosubIf2(condition?labeliftrue[(arg1[|...])][:labeliffalse[(arg1[|...])]])\n"
"  If the condition is true, then jump to labeliftrue.  If false, jumps to\n"
"labeliffalse, if specified.  In either case, a jump saves the return point\n"
"in the dialplan, to be returned to with a Return.\n";
static const char *return_descrip =
"Return2([return-value])\n"
"  Jumps to the last label on the stack, removing it.  The return value, if\n"
"any, is saved in the channel variable GOSUB_RETVAL.\n";
static const char *pop_descrip =
"StackPop2()\n"
"  Removes last label on the stack, discarding it.\n";

STANDARD_LOCAL_USER;

LOCAL_USER_DECL;

static int pop_exec(struct ast_channel *chan, void *data)
{
	const char *frame = pbx_builtin_getvar_helper(chan, STACKVAR);
	int numargs = 0, i;
	char argname[15];

	/* Pop any arguments for this stack frame off the variable stack */
	if (frame) {
		numargs = atoi(frame);
		for (i = 1; i <= numargs; i++) {
			snprintf(argname, sizeof(argname), "ARG%d", i);
			pbx_builtin_setvar_helper(chan, argname, NULL);
		}
	}

	/* Remove the last frame from the Gosub stack */
	pbx_builtin_setvar_helper(chan, STACKVAR, NULL);

	return 0;
}

static int return_exec(struct ast_channel *chan, void *data)
{
	char *label = pbx_builtin_getvar_helper(chan, STACKVAR);
	char argname[15], *retval = data;
	int numargs, i;

	if (ast_strlen_zero(label)) {
		ast_log(LOG_ERROR, "Return2 without Gosub2: stack is empty\n");
		return -1;
	}

	/* Pop any arguments for this stack frame off the variable stack */
	numargs = atoi(label);
	for (i = 1; i <= numargs; i++) {
		snprintf(argname, sizeof(argname), "ARG%d", i);
		pbx_builtin_setvar_helper(chan, argname, NULL);
	}

	/* If the label exists, it will always have a ':' */
	label = strchr(label, ':') + 1;

	if (ast_parseable_goto(chan, label)) {
		ast_log(LOG_WARNING, "No next statement after Gosub2?\n");
		return -1;
	}

	/* Remove the current frame from the Gosub stack */
	pbx_builtin_setvar_helper(chan, STACKVAR, NULL);

	/* Set a return value, if any */
	pbx_builtin_setvar_helper(chan, "GOSUB_RETVAL", !ast_strlen_zero(retval) ? retval : "");
	return 0;
}

static int gosub_exec(struct ast_channel *chan, void *data)
{
	char newlabel[AST_MAX_EXTENSION + AST_MAX_CONTEXT + 11 + 11 + 4];
	char argname[15], *tmp = ast_strdupa(data), *label, *endparen;
	int i;
	struct localuser *u;
	AST_DECLARE_APP_ARGS(args2,
		AST_APP_ARG(argval)[100];
	);

	if (ast_strlen_zero(data)) {
		ast_log(LOG_ERROR, "Gosub2 requires an argument: Gosub2([[context|]exten|]priority[(arg1[|...][|argN])])\n");
		return -1;
	}

	LOCAL_USER_ADD(u);

	/* Separate the arguments from the label */
	/* NOTE:  you cannot use ast_app_separate_args for this, because '(' cannot be used as a delimiter. */
	label = strsep(&tmp, "(");
	if (tmp) {
		endparen = strrchr(tmp, ')');
		if (endparen)
			*endparen = '\0';
		else
			ast_log(LOG_WARNING, "Ouch.  No closing paren: '%s'?\n", (char *)data);
		AST_STANDARD_APP_ARGS(args2, tmp);
	} else
		args2.argc = 0;

	/* Create the return address, but don't save it until we know that the Gosub destination exists */
	snprintf(newlabel, sizeof(newlabel), "%d:%s|%s|%d", args2.argc == 2 ? args2.argc : 0, chan->context, chan->exten, chan->priority + 1);

	if (ast_parseable_goto(chan, data)) {
		ast_log(LOG_WARNING, "Destination '%s' does not exist in the dialplan\n", (char *)data);
		LOCAL_USER_REMOVE(u);
		return -1;
	}

	/* Now that we know for certain that we're going to a new location, set our arguments */
	for (i = 0; i < args2.argc; i++) {
		snprintf(argname, sizeof(argname), "ARG%d", i + 1);
		pbx_builtin_pushvar_helper(chan, argname, args2.argval[i]);
		ast_log(LOG_DEBUG, "Setting %s to '%s'\n", argname, args2.argval[i]);
	}

	/* And finally, save our return address */
	pbx_builtin_pushvar_helper(chan, STACKVAR, newlabel);
	ast_log(LOG_DEBUG, "Setting gosub return address to %s\n", newlabel);

	LOCAL_USER_REMOVE(u);

	return 0;
}

static int gosubif_exec(struct ast_channel *chan, void *data)
{
	struct localuser *u;
	char *args;
	int res=0;
	AST_DECLARE_APP_ARGS(cond,
		AST_APP_ARG(ition);
		AST_APP_ARG(labels);
	);
	AST_DECLARE_APP_ARGS(label,
		AST_APP_ARG(iftrue);
		AST_APP_ARG(iffalse);
	);

	if (ast_strlen_zero(data)) {
		ast_log(LOG_WARNING, "GosubIf2 requires an argument: GosubIf2(cond?label1(args):label2(args)\n");
		return 0;
	}

	LOCAL_USER_ADD(u);

	args = ast_strdupa((char *)data);
	/* AST_NONSTANDARD_APP_ARGS(cond, args, '?'); */
	cond.argc = ast_app_separate_args(args, '?', cond.argv, (sizeof(cond) - sizeof(cond.argc)) / sizeof(cond.argv[0]));
	if (cond.argc != 2) {
		ast_log(LOG_WARNING, "GosubIf2 requires an argument: GosubIf2(cond?label1(args):label2(args)\n");
		LOCAL_USER_REMOVE(u);
		return 0;
	}

	/* AST_NONSTANDARD_APP_ARGS(label, cond.labels, ':'); */
	label.argc = ast_app_separate_args(cond.labels, ':', label.argv, (sizeof(label) - sizeof(label.argc)) / sizeof(label.argv[0]));

	if (pbx_checkcondition(cond.ition)) {
		if (!ast_strlen_zero(label.iftrue))
			res = gosub_exec(chan, label.iftrue);
	} else if (!ast_strlen_zero(label.iffalse)) {
		res = gosub_exec(chan, label.iffalse);
	}

	LOCAL_USER_REMOVE(u);
	return res;
}

int unload_module(void)
{
	ast_unregister_application(app_return);
	ast_unregister_application(app_pop);
	ast_unregister_application(app_gosubif);
	ast_unregister_application(app_gosub);

	STANDARD_HANGUP_LOCALUSERS;

	return 0;
}

int load_module(void)
{
	ast_register_application(app_pop, pop_exec, pop_synopsis, pop_descrip);
	ast_register_application(app_return, return_exec, return_synopsis, return_descrip);
	ast_register_application(app_gosubif, gosubif_exec, gosubif_synopsis, gosubif_descrip);
	ast_register_application(app_gosub, gosub_exec, gosub_synopsis, gosub_descrip);

	return 0;
}

char *description(void)
{
	return (char *) tdesc;
}

int usecount(void)
{
	int res;

	STANDARD_USECOUNT(res);

	return res;
}

char *key()
{
	return ASTERISK_GPL_KEY;
}




--- asterisk-1.2.26.2-original/apps/Makefile	2006-04-30 15:38:22.000000000 +0200

/*
 * Asterisk -- An open source telephony toolkit.
 *
 * Copyright (C) 2005, Tilghman Lesher.
 *
 * 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 ARRAY dialplan function
 *
 * \author Tilghman Lesher
 */

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sched.h>

#include "asterisk.h"

ASTERISK_FILE_VERSION(__FILE__, "$Revision: 20003 $")

#include "asterisk/module.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/logger.h"
#include "asterisk/utils.h"
#include "asterisk/app.h"
#include "asterisk/localtime.h"
#include "asterisk/linkedlists.h"

#include "separate.h"

#define HASH_PREFIX	"~HASH~%s~"
#define HASH_FORMAT	HASH_PREFIX "%s~"

AST_MUTEX_DEFINE_STATIC(local_lock);
static int use_count = 0;

static char *app_clearhash = "ClearHash";
static char *syn_clearhash = "Clear the keys from a specified hashname";
static char *desc_clearhash =
"ClearHash(<hashname>)\n"
"  Clears all keys out of the specified hashname\n";

/* This function probably should migrate to main/pbx.c, as pbx_builtin_clearvar_prefix() */
static void clearvar_prefix(struct ast_channel *chan, const char *prefix)
{
	struct ast_var_t *newvar;
	int len = strlen(prefix);
	AST_LIST_TRAVERSE_SAFE_BEGIN(&chan->varshead, newvar, entries) {
		if (strncasecmp(prefix, ast_var_name(newvar), len) == 0) {
			AST_LIST_REMOVE_CURRENT(&chan->varshead, entries);
			free(newvar);
		}
	}
	AST_LIST_TRAVERSE_SAFE_END
}

static int exec_clearhash(struct ast_channel *chan, void *data)
{
	char prefix[80];
	snprintf(prefix, sizeof(prefix), HASH_PREFIX, data ? (char *)data : "null");
	clearvar_prefix(chan, prefix);
	return 0;
}

static void array(struct ast_channel *chan, char *cmd, char *var, const char *value)
{
	AST_DECLARE_APP_ARGS(arg1,
		AST_APP_ARG(var)[100];
	);
	AST_DECLARE_APP_ARGS(arg2,
		AST_APP_ARG(val)[100];
	);
	char *origvar = "", *value2, varname[256];
	int i, ishash = 0;

	value2 = ast_strdupa(value);
	if (!var || !value2)
		return;

	ast_mutex_lock(&local_lock);
	use_count++;
	ast_mutex_unlock(&local_lock);

	if (!strcmp(cmd, "HASH")) {
		const char *var2 = pbx_builtin_getvar_helper(chan, "~ODBCFIELDS~");
		origvar = var;
		if (var2)
			var = ast_strdupa(var2);
		else
			return;
		ishash = 1;
	}

	/* The functions this will generally be used with are SORT and ODBC_*, which
	 * both return comma-delimited lists.  However, if somebody uses literal lists,
	 * their commas will be translated to vertical bars by the load, and I don't
	 * want them to be surprised by the result.  Hence, we prefer commas as the
	 * delimiter, but we'll fall back to vertical bars if commas aren't found.
	 */
	ast_log(LOG_DEBUG, "array (%s=%s)\n", var, value2);
	if (strchr(var, ','))
		TRUNK_NONSTANDARD_APP_ARGS(arg1, var, ',');
	else
		TRUNK_STANDARD_APP_ARGS(arg1, var);

	if (strchr(value2, ','))
		TRUNK_NONSTANDARD_APP_ARGS(arg2, value2, ',');
	else
		TRUNK_STANDARD_APP_ARGS(arg2, value2);

	for (i = 0; i < arg1.argc; i++) {
		ast_log(LOG_DEBUG, "array set value (%s=%s)\n", arg1.var[i],
			arg2.val[i]);
		if (i < arg2.argc) {
			if (ishash) {
				snprintf(varname, sizeof(varname), HASH_FORMAT, origvar, arg1.var[i]);
				pbx_builtin_setvar_helper(chan, varname, arg2.val[i]);
			} else {
				pbx_builtin_setvar_helper(chan, arg1.var[i], arg2.val[i]);
			}
		} else {
			/* We could unset the variable, by passing a NULL, but due to
			 * pushvar semantics, that could create some undesired behavior. */
			if (ishash) {
				snprintf(varname, sizeof(varname), HASH_FORMAT, origvar, arg1.var[i]);
				pbx_builtin_setvar_helper(chan, varname, "");
			} else {
				pbx_builtin_setvar_helper(chan, arg1.var[i], "");
			}
		}
	}

	ast_mutex_lock(&local_lock);
	use_count--;
	ast_mutex_unlock(&local_lock);

	return;
}

static char *hashkeys_read(struct ast_channel *chan, char *cmd, char *data, char *buf, size_t len)
{
	struct ast_var_t *newvar;
	int plen;
	char prefix[80];
	snprintf(prefix, sizeof(prefix), HASH_PREFIX, data);
	plen = strlen(prefix);

	memset(buf, 0, len);
	AST_LIST_TRAVERSE(&chan->varshead, newvar, entries) {
		if (strncasecmp(prefix, ast_var_name(newvar), plen) == 0) {
			/* Copy everything after the prefix */
			strncat(buf, ast_var_name(newvar) + plen, len);
			/* Trim the trailing ~ */
			buf[strlen(buf) - 1] = ',';
		}
	}
	/* Trim the trailing comma */
	buf[strlen(buf) - 1] = '\0';
	return buf;
}

static void hash_write(struct ast_channel *chan, char *cmd, char *var, const char *value)
{
	char varname[256];
	AST_DECLARE_APP_ARGS(arg,
		AST_APP_ARG(hashname);
		AST_APP_ARG(hashkey);
	);

	ast_mutex_lock(&local_lock);
	use_count++;
	ast_mutex_unlock(&local_lock);

	if (!strchr(var, '|')) {
		/* Single argument version */
		array(chan, "HASH", var, value);
		return;
	}

	TRUNK_STANDARD_APP_ARGS(arg, var);
	snprintf(varname, sizeof(varname), HASH_FORMAT, arg.hashname, arg.hashkey);
	pbx_builtin_setvar_helper(chan, varname, value);

	ast_mutex_lock(&local_lock);
	use_count--;
	ast_mutex_unlock(&local_lock);
}

static char *hash_read(struct ast_channel *chan, char *cmd, char *data, char *buf, size_t len)
{
	char varname[256];
	const char *varvalue;
	AST_DECLARE_APP_ARGS(arg,
		AST_APP_ARG(hashname);
		AST_APP_ARG(hashkey);
	);

	ast_mutex_lock(&local_lock);
	use_count++;
	ast_mutex_unlock(&local_lock);

	TRUNK_STANDARD_APP_ARGS(arg, data);
	if (arg.argc == 2) {
		snprintf(varname, sizeof(varname), HASH_FORMAT, arg.hashname, arg.hashkey);
		varvalue = pbx_builtin_getvar_helper(chan, varname);
		if (varvalue)
			ast_copy_string(buf, varvalue, len);
		else
			*buf = '\0';
	} else if (arg.argc == 1) {
		char colnames[4096];
		int i;
		AST_DECLARE_APP_ARGS(arg2,
			AST_APP_ARG(col)[100];
		);

		/* Get column names, in no particular order */
		hashkeys_read(chan, "HASHKEYS", arg.hashname, colnames, sizeof(colnames));
		pbx_builtin_setvar_helper(chan, "~ODBCFIELDS~", colnames);

		TRUNK_NONSTANDARD_APP_ARGS(arg2, colnames, ',');
		*buf = '\0';

		/* Now get the corresponding column values, in exactly the same order */
		for (i = 0; i < arg2.argc; i++) {
			snprintf(varname, sizeof(varname), HASH_FORMAT, arg.hashname, arg2.col[i]);
			varvalue = pbx_builtin_getvar_helper(chan, varname);
			strncat(buf, varvalue, len);
			strncat(buf, ",", len);
		}

		/* Strip trailing comma */
		buf[strlen(buf) - 1] = '\0';
	}

	return buf;
}

static struct ast_custom_function array_function = {
	.name = "ARRAY",
	.synopsis = "Allows setting multiple variables at once",
	.syntax = "ARRAY(var1[|var2[...][|varN]])",
	.write = array,
	.desc =
		"The comma-separated list passed as a value to which the function is set will\n"
		"be interpreted as a set of values to which the comma-separated list of\n"
		"variable names in the argument should be set.\n"
		"Hence, Set(ARRAY(var1,var2)=1,2) will set var1 to 1 and var2 to 2\n"
		"Note: remember to either backslash your commas in extensions.conf or quote the\n"
		"entire argument, since Set can take multiple arguments itself.\n",
};

static struct ast_custom_function hash_function = {
	.name = "HASH",
	.synopsis = "Implementation of a dialplan associative array",
	.syntax = "HASH(hashname[|hashkey])",
	.write = hash_write,
	.read = hash_read,
	.desc =
		"In two argument mode, gets and sets values to corresponding keys within a named\n"
		"associative array.  The single-argument mode will only work when assigned to from\n"
		"a function defined by func_odbc.so.\n",
};

static struct ast_custom_function hashkeys_function = {
	.name = "HASHKEYS",
	.synopsis = "Retrieve the keys of a HASH()",
	.syntax = "HASHKEYS(<hashname>)",
	.read = hashkeys_read,
	.desc =
		"Returns a comma-delimited list of the current keys of an associative array\n"
	   	"defined by the HASH() function.  Note that if you iterate over the keys of\n"
		"the result, adding keys during iteration will cause the result of the HASHKEYS\n"
		"function to change.\n",
};

static char *tdesc = "String handling dialplan functions";

int unload_module(void)
{
	int res = 0;

	res |= ast_custom_function_unregister(&array_function);
	res |= ast_custom_function_unregister(&hash_function);
	res |= ast_custom_function_unregister(&hashkeys_function);
	res |= ast_unregister_application(app_clearhash);
	sched_yield(); /* Any remaining process gets time to clear out.  Increases safety if a force unload is attempted. */

	return res;
}

int load_module(void)
{
	int res = 0;

	res |= ast_custom_function_register(&array_function);
	res |= ast_custom_function_register(&hash_function);
	res |= ast_custom_function_register(&hashkeys_function);
	res |= ast_register_application(app_clearhash, exec_clearhash, syn_clearhash, desc_clearhash);

	return res;
}

char *description(void)
{
	return tdesc;
}

int usecount(void)
{
	return use_count;
}

char *key(void)
{
	return ASTERISK_GPL_KEY;
}





/*
 * Asterisk -- An open source telephony toolkit.
 *
 * Copyright (c) 2005 Tilghman Lesher
 *
 * Tilghman Lesher <func_odbc__200604@the-tilghman.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 ODBC lookups
 *
 * \author Tilghman Lesher <func_odbc__200604@the-tilghman.com>
 */

#include <sys/types.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>

#include "asterisk.h"

ASTERISK_FILE_VERSION(__FILE__, "$Revision$")

#include "asterisk/module.h"
#include "asterisk/file.h"
#include "asterisk/logger.h"
#include "asterisk/options.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/module.h"
#include "asterisk/config.h"
#include "asterisk/res_odbc.h"
#include "asterisk/app.h"

#include "separate.h"

static char *tdesc = "ODBC lookups";

static char *config = "func_odbc.conf";

enum {
	OPT_ESCAPECOMMAS =	(1 << 0),
} odbc_option_flags;

struct acf_odbc_query {
	AST_LIST_ENTRY(acf_odbc_query) list;
	char readhandle[5][30];
	char writehandle[5][30];
	char sql_read[2048];
	char sql_write[2048];
	unsigned int flags;
	struct ast_custom_function *acf;
};

AST_LIST_HEAD_STATIC(queries, acf_odbc_query);

#ifdef NEEDTRACE
static void acf_odbc_error(SQLHSTMT stmt, int res)
{
	char state[10] = "", diagnostic[256] = "";
	SQLINTEGER nativeerror = 0;
	SQLSMALLINT diagbytes = 0;
	SQLGetDiagRec(SQL_HANDLE_STMT, stmt, 1, state, &nativeerror, diagnostic, sizeof(diagnostic), &diagbytes);
	ast_log(LOG_WARNING, "SQL return value %d: error %s: %s (len %d)\n", res, state, diagnostic, diagbytes);
}
#endif

/*
 * Master control routine
 */
#define INCREMENT_DSN	if (++dsn < 5 && !ast_strlen_zero(query->writehandle[dsn])) goto retry_write
static void acf_odbc_write(struct ast_channel *chan, char *cmd, char *data, const char *value)
{
	odbc_obj *obj;
	struct acf_odbc_query *query;
	char *s, *t, buf[2048]="", varname[15];
	int res, i, dsn = 0, alloc, prepare, execute;
	SQLHSTMT stmt;
	SQLINTEGER nativeerror=0, numfields=0, rows=0;
	SQLSMALLINT diagbytes=0;
	unsigned char state[10], diagnostic[256];
	AST_DECLARE_APP_ARGS(args,
				AST_APP_ARG(arg)[100];
	);
	AST_DECLARE_APP_ARGS(values,
				AST_APP_ARG(val)[100];
	);
#ifdef NEEDTRACE
	SQLINTEGER enable = 1;
	char *tracefile = "/tmp/odbc.trace";
#endif

	AST_LIST_LOCK(&queries);
	AST_LIST_TRAVERSE(&queries, query, list) {
		if (!strcmp(query->acf->name, cmd)) {
			break;
		}
	}

	if (!query) {
		ast_log(LOG_ERROR, "No such function '%s'\n", cmd);
		AST_LIST_UNLOCK(&queries);
		return;
	}

	/* Parse our arguments */
	s = ast_strdupa(data);
	if (value) {
		t = ast_strdupa(value);
	} else {
		t = "";
	}

	if (!s || !t) {
		ast_log(LOG_ERROR, "Out of memory\n");
		AST_LIST_UNLOCK(&queries);
		return;
	}

	TRUNK_STANDARD_APP_ARGS(args, s);
	for (i = 0; i < args.argc; i++) {
		snprintf(varname, sizeof(varname), "ARG%d", i + 1);
		pbx_builtin_pushvar_helper(chan, varname, args.arg[i]);
	}

	TRUNK_NONSTANDARD_APP_ARGS(values, t, ',');
	for (i = 0; i < values.argc; i++) {
		snprintf(varname, sizeof(varname), "VAL%d", i + 1);
		pbx_builtin_pushvar_helper(chan, varname, values.val[i]);
	}

	/* Additionally set the value as a whole */
	/* Note that pbx_builtin_setvar_helper will quite happily take a NULL for the 3rd argument */
	pbx_builtin_pushvar_helper(chan, "VALUE", value ? value : "");

	pbx_substitute_variables_helper(chan, query->sql_write, buf, sizeof(buf) - 1);

	/* Restore prior values */
	for (i = 0; i < args.argc; i++) {
		snprintf(varname, sizeof(varname), "ARG%d", i + 1);
		pbx_builtin_setvar_helper(chan, varname, NULL);
	}

	for (i = 0; i < values.argc; i++) {
		snprintf(varname, sizeof(varname), "VAL%d", i + 1);
		pbx_builtin_setvar_helper(chan, varname, NULL);
	}
	pbx_builtin_setvar_helper(chan, "VALUE", NULL);

	AST_LIST_UNLOCK(&queries);

retry_write:
	obj = fetch_odbc_obj(query->writehandle[dsn], 0);

	if (!obj) {
		INCREMENT_DSN;
		ast_log(LOG_ERROR, "Unable to load ODBC write class (check res_odbc.conf)\n");
		return;
	}

#ifdef NEEDTRACE
	SQLSetConnectAttr(obj->con, SQL_ATTR_TRACE, &enable, SQL_IS_INTEGER);
	SQLSetConnectAttr(obj->con, SQL_ATTR_TRACEFILE, tracefile, strlen(tracefile));
#endif

	for (execute = 0; execute < 2; execute++) {
		for (prepare = 0; prepare < 2; prepare++) {
			for (alloc = 0; alloc < 2; alloc++) {
				res = SQLAllocHandle (SQL_HANDLE_STMT, obj->con, &stmt);
				if ((res == SQL_SUCCESS) || (res == SQL_SUCCESS_WITH_INFO))
					break;
				else if (alloc == 0)
					odbc_sanity_check(obj);
				else {
					INCREMENT_DSN;
					ast_log(LOG_WARNING, "SQL Alloc Handle failed!\n");
					pbx_builtin_setvar_helper(chan, "ODBCROWS", "-1");
					return;
				}
			}

			res = SQLPrepare(stmt, (unsigned char *)buf, SQL_NTS);
			if ((res == SQL_SUCCESS) || (res == SQL_SUCCESS_WITH_INFO))
				break;
			else if (prepare == 0)
				odbc_sanity_check(obj);
			else {
				INCREMENT_DSN;
				ast_log(LOG_WARNING, "SQL Prepare failed![%s]\n", buf);
				SQLCloseCursor(stmt);
				SQLFreeHandle (SQL_HANDLE_STMT, stmt);
				pbx_builtin_setvar_helper(chan, "ODBCROWS", "-1");
				return;
			}
		}

		res = SQLExecute(stmt);
		if ((res == SQL_SUCCESS) || (res == SQL_SUCCESS_WITH_INFO)) {
			/* Rows affected */
			SQLRowCount(stmt, &rows);
			break;
		} else if (execute == 0)
			odbc_sanity_check(obj);
		else {
			if (res == SQL_ERROR) {
				SQLGetDiagField(SQL_HANDLE_STMT, stmt, 1, SQL_DIAG_NUMBER, &numfields, SQL_IS_INTEGER, &diagbytes);
				for (i = 0; i <= numfields; i++) {
					SQLGetDiagRec(SQL_HANDLE_STMT, stmt, i + 1, state, &nativeerror, diagnostic, sizeof(diagnostic), &diagbytes);
					ast_log(LOG_WARNING, "SQL Execute returned an error %d: %s: %s (%d)\n", res, state, diagnostic, diagbytes);
					if (i > 10) {
						ast_log(LOG_WARNING, "Oh, that was good.  There are really %d diagnostics?\n", (int)numfields);
						break;
					}
				}
			}
			INCREMENT_DSN;

			if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
				ast_log(LOG_WARNING, "SQL Execute error!\n[%s]\n\n", buf);
			}
			rows = -1;
		}
	}

	/* Output the affected rows, for all cases.  In the event of failure, we
	 * flag this as -1 rows.  Note that this is different from 0 affected rows
	 * which would be the case if we succeeded in our query, but the values did
	 * not change. */
	snprintf(varname, sizeof(varname), "%d", (int)rows);
	pbx_builtin_setvar_helper(chan, "ODBCROWS", varname);

	SQLCloseCursor(stmt);
	SQLFreeHandle(SQL_HANDLE_STMT, stmt);
}
#undef INCREMENT_DSN

#define INCREMENT_DSN	if (++dsn < 5 && !ast_strlen_zero(query->readhandle[dsn])) goto restartread;
static char *acf_odbc_read(struct ast_channel *chan, char *cmd, char *data, char *buf, size_t len)
{
	odbc_obj *obj;
	struct acf_odbc_query *query;
	char *s, sql[2048] = "", varname[15], colnames[2048] = "";
	int res, x, buflen = 0, dsn = 0, escapecommas, alloc, prepare, execute;
	AST_DECLARE_APP_ARGS(args,
				AST_APP_ARG(arg)[100];
	);
	SQLHSTMT stmt;
	SQLSMALLINT colcount=0;
	SQLINTEGER indicator;
	SQLSMALLINT collength;
#ifdef NEEDTRACE
	SQLINTEGER enable = 1;
	char *tracefile = "/tmp/odbc.trace";
#endif

	AST_LIST_LOCK(&queries);
	AST_LIST_TRAVERSE(&queries, query, list) {
		if (!strcmp(query->acf->name, cmd)) {
			break;
		}
	}

	if (!query) {
		ast_log(LOG_ERROR, "No such function '%s'\n", cmd);
		AST_LIST_UNLOCK(&queries);
		return "";
	}

	/* Parse our arguments */
	if (!(s = ast_strdupa(data))) {
		AST_LIST_UNLOCK(&queries);
		return "";
	}

	TRUNK_STANDARD_APP_ARGS(args, s);
	for (x = 0; x < args.argc; x++) {
		snprintf(varname, sizeof(varname), "ARG%d", x + 1);
		pbx_builtin_pushvar_helper(chan, varname, args.arg[x]);
	}

	pbx_substitute_variables_helper(chan, query->sql_read, sql, sizeof(sql) - 1);

	/* Restore prior values */
	for (x = 0; x < args.argc; x++) {
		snprintf(varname, sizeof(varname), "ARG%d", x + 1);
		pbx_builtin_setvar_helper(chan, varname, NULL);
	}

	/* Save this flag, so we can release the lock */
	escapecommas = ast_test_flag(query, OPT_ESCAPECOMMAS);

	AST_LIST_UNLOCK(&queries);

restartread:
	obj = fetch_odbc_obj(query->readhandle[dsn], 0);

	if (!obj) {
		INCREMENT_DSN;
		ast_log(LOG_ERROR, "Unable to load ODBC read class (check res_odbc.conf)\n");
		return "";
	}

#ifdef NEEDTRACE
	SQLSetConnectAttr(obj->con, SQL_ATTR_TRACE, &enable, SQL_IS_INTEGER);
	SQLSetConnectAttr(obj->con, SQL_ATTR_TRACEFILE, tracefile, strlen(tracefile));
#endif

	for (execute = 0; execute < 2; execute++) {
		for (prepare = 0; prepare < 2; prepare++) {
			for (alloc = 0; alloc < 2; alloc++) {
				res = SQLAllocHandle(SQL_HANDLE_STMT, obj->con, &stmt);
				if ((res == SQL_SUCCESS) || (res == SQL_SUCCESS_WITH_INFO))
					break;
				else if (alloc == 0)
					odbc_sanity_check(obj);
				else {
					INCREMENT_DSN;
					ast_log(LOG_WARNING, "SQL Alloc Handle failed!\n");
					return "";
				}
			}

			res = SQLPrepare(stmt, (unsigned char *)sql, SQL_NTS);
			if ((res == SQL_SUCCESS) || (res == SQL_SUCCESS_WITH_INFO))
				break;
			else if (prepare == 0)
				odbc_sanity_check(obj);
			else {
				INCREMENT_DSN;
				SQLCloseCursor(stmt);
				SQLFreeHandle(SQL_HANDLE_STMT, stmt);
				ast_log(LOG_WARNING, "SQL Prepare failed![%s]\n", sql);
				return "";
			}
		}

		res = odbc_smart_execute(obj, stmt);
		if ((res == SQL_SUCCESS) || (res == SQL_SUCCESS_WITH_INFO))
			break;
		else if (execute == 0)
			odbc_sanity_check(obj);
		else {
			INCREMENT_DSN;
			SQLCloseCursor(stmt);
			SQLFreeHandle(SQL_HANDLE_STMT, stmt);
			ast_log(LOG_WARNING, "SQL Execute error!\n[%s]\n\n", sql);
			return "";
		}
	}

	res = SQLNumResultCols(stmt, &colcount);
	if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
		ast_log(LOG_WARNING, "SQL Column Count error!\n[%s]\n\n", sql);
		SQLCloseCursor(stmt);
		SQLFreeHandle (SQL_HANDLE_STMT, stmt);
		return "";
	}

	memset(buf, 0, len);

	res = SQLFetch(stmt);
	if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
		if (res == SQL_NO_DATA) {
			if (option_verbose > 3) {
				ast_verbose(VERBOSE_PREFIX_4 "Found no rows [%s]\n", sql);
			}
		} else if (option_verbose > 3) {
			ast_log(LOG_WARNING, "Error %d in FETCH [%s]\n", res, sql);
		}
		goto acf_out;
	}

	for (x = 0; x < colcount; x++) {
		int i, namelen;
		char coldata[256], colname[256];

		res = SQLDescribeCol(stmt, x + 1, (unsigned char *)colname, sizeof(colname), &collength, NULL, NULL, NULL, NULL);
		if (((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) || collength == 0) {
			snprintf(colname, sizeof(colname), "field%d", x);
		}

		if (!ast_strlen_zero(colnames))
			strncat(colnames, ",", sizeof(colnames) - 1);
		namelen = strlen(colnames);

		/* Copy data, encoding '\' and ',' for the argument parser */
		for (i = 0; i < sizeof(colname); i++) {
			if (escapecommas && (colname[i] == '\\' || colname[i] == ',')) {
				colnames[namelen++] = '\\';
			}
			colnames[namelen++] = colname[i];

			if (namelen >= sizeof(colnames) - 2) {
				colnames[namelen >= sizeof(colnames) ? sizeof(colnames) - 1 : namelen] = '\0';
				break;
			}

			if (colname[i] == '\0')
				break;
		}

		buflen = strlen(buf);
		res = SQLGetData(stmt, x + 1, SQL_CHAR, coldata, sizeof(coldata), &indicator);
		if (indicator == SQL_NULL_DATA) {
			coldata[0] = '\0';
			res = SQL_SUCCESS;
		}

		if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
			ast_log(LOG_WARNING, "SQL Get Data error!\n[%s]\n\n", sql);
			SQLCloseCursor(stmt);
			SQLFreeHandle(SQL_HANDLE_STMT, stmt);
			return "";
		}

		/* Copy data, encoding '\' and ',' for the argument parser */
		for (i = 0; i < sizeof(coldata); i++) {
			if (escapecommas && (coldata[i] == '\\' || coldata[i] == ',')) {
				buf[buflen++] = '\\';
			}
			buf[buflen++] = coldata[i];

			if (buflen >= len - 2) {
				buf[buflen >= len ? len - 1 : buflen] = '\0';
				break;
			}

			if (coldata[i] == '\0')
				break;
		}

		buf[buflen - 1] = ',';
	}
	/* Trim trailing comma */
	buf[buflen - 1] = '\0';

	pbx_builtin_setvar_helper(chan, "~ODBCFIELDS~", colnames);

acf_out:
	SQLCloseCursor(stmt);
	SQLFreeHandle(SQL_HANDLE_STMT, stmt);
	return buf;
}
#undef INCREMENT_DSN

static char *acf_escape(struct ast_channel *chan, char *cmd, char *data, char *buf, size_t len)
{
	char *in, *out = buf;
	for (in = data; *in && out - buf < len; in++) {
		if (*in == '\'') {
			*out = '\'';
			out++;
		}
		*out = *in;
		out++;
	}
	*out = '\0';
	return buf;
}

static struct ast_custom_function escape_function = {
	.name = "SQL_ESC",
	.synopsis = "Escapes single ticks for use in SQL statements",
	.syntax = "SQL_ESC(<string>)",
	.desc =
"Used in SQL templates to escape data which may contain single ticks (') which\n"
"are otherwise used to delimit data.  For example:\n"
"SELECT foo FROM bar WHERE baz='${SQL_ESC(${ARG1})}'\n",
	.read = acf_escape,
	.write = NULL,
};


static int init_acf_query(struct ast_config *cfg, char *catg, struct acf_odbc_query **query)
{
	const char *tmp;
	int i;

	if (!cfg || !catg) {
		return -1;
	}

	*query = calloc(1, sizeof(struct acf_odbc_query));
	if (! (*query))
		return ENOMEM;

	if (((tmp = ast_variable_retrieve(cfg, catg, "writehandle"))) || ((tmp = ast_variable_retrieve(cfg, catg, "dsn")))) {
		char *tmp2 = ast_strdupa(tmp);
		AST_DECLARE_APP_ARGS(write,
			AST_APP_ARG(dsn)[5];
		);
		TRUNK_NONSTANDARD_APP_ARGS(write, tmp2, ',');
		for (i = 0; i < 5; i++) {
			if (!ast_strlen_zero(write.dsn[i]))
				ast_copy_string((*query)->writehandle[i], write.dsn[i], sizeof((*query)->writehandle[i]));
		}
	}

	if ((tmp = ast_variable_retrieve(cfg, catg, "readhandle"))) {
		char *tmp2 = ast_strdupa(tmp);
		AST_DECLARE_APP_ARGS(read,
			AST_APP_ARG(dsn)[5];
		);
		TRUNK_NONSTANDARD_APP_ARGS(read, tmp2, ',');
		for (i = 0; i < 5; i++) {
			if (!ast_strlen_zero(read.dsn[i]))
				ast_copy_string((*query)->readhandle[i], read.dsn[i], sizeof((*query)->readhandle[i]));
		}
	} else {
		/* If no separate readhandle, then use the writehandle for reading */
		for (i = 0; i < 5; i++) {
			if (!ast_strlen_zero((*query)->writehandle[i]))
				ast_copy_string((*query)->readhandle[i], (*query)->writehandle[i], sizeof((*query)->readhandle[i]));
		}
	}

	if ((tmp = ast_variable_retrieve(cfg, catg, "read"))) {
		ast_log(LOG_WARNING, "Parameter 'read' is deprecated for category %s.  Please use 'readsql' instead.\n", catg);
		ast_copy_string((*query)->sql_read, tmp, sizeof((*query)->sql_read));
	} else if ((tmp = ast_variable_retrieve(cfg, catg, "readsql")))
		ast_copy_string((*query)->sql_read, tmp, sizeof((*query)->sql_read));

	if (!ast_strlen_zero((*query)->sql_read) && ast_strlen_zero((*query)->readhandle[0])) {
		free(*query);
		*query = NULL;
		ast_log(LOG_ERROR, "There is SQL, but no ODBC class to be used for reading: %s\n", catg);
		return EINVAL;
	}

	if ((tmp = ast_variable_retrieve(cfg, catg, "write"))) {
		ast_log(LOG_WARNING, "Parameter 'write' is deprecated for category %s.  Please use 'writesql' instead.\n", catg);
		ast_copy_string((*query)->sql_write, tmp, sizeof((*query)->sql_write));
	} else if ((tmp = ast_variable_retrieve(cfg, catg, "writesql")))
		ast_copy_string((*query)->sql_write, tmp, sizeof((*query)->sql_write));

	if (!ast_strlen_zero((*query)->sql_write) && ast_strlen_zero((*query)->writehandle[0])) {
		free(*query);
		*query = NULL;
		ast_log(LOG_ERROR, "There is SQL, but no ODBC class to be used for writing: %s\n", catg);
		return EINVAL;
	}

	/* Allow escaping of embedded commas in fields to be turned off */
	ast_set_flag((*query), OPT_ESCAPECOMMAS);
	if ((tmp = ast_variable_retrieve(cfg, catg, "escapecommas"))) {
		if (ast_false(tmp))
			ast_clear_flag((*query), OPT_ESCAPECOMMAS);
	}

	(*query)->acf = calloc(1, sizeof(struct ast_custom_function));
	if (! (*query)->acf) {
		free(*query);
		*query = NULL;
		return ENOMEM;
	}

	if ((tmp = ast_variable_retrieve(cfg, catg, "prefix")) && !ast_strlen_zero(tmp)) {
		asprintf((char **)&((*query)->acf->name), "%s_%s", tmp, catg);
	} else {
		asprintf((char **)&((*query)->acf->name), "ODBC_%s", catg);
	}

	if (!((*query)->acf->name)) {
		free((*query)->acf);
		free(*query);
		*query = NULL;
		return ENOMEM;
	}

	asprintf((char **)&((*query)->acf->syntax), "%s(<arg1>[...[,<argN>]])", (*query)->acf->name);

	if (!((*query)->acf->syntax)) {
		free((char *)(*query)->acf->name);
		free((*query)->acf);
		free(*query);
		*query = NULL;
		return ENOMEM;
	}

	(*query)->acf->synopsis = "Runs the referenced query with the specified arguments";
	if (!ast_strlen_zero((*query)->sql_read) && !ast_strlen_zero((*query)->sql_write)) {
		asprintf((char **)&((*query)->acf->desc),
					"Runs the following query, as defined in func_odbc.conf, performing\n"
				   	"substitution of the arguments into the query as specified by ${ARG1},\n"
					"${ARG2}, ... ${ARGn}.  When setting the function, the values are provided\n"
					"either in whole as ${VALUE} or parsed as ${VAL1}, ${VAL2}, ... ${VALn}.\n"
					"\nRead:\n%s\n\nWrite:\n%s\n",
					(*query)->sql_read,
					(*query)->sql_write);
	} else if (!ast_strlen_zero((*query)->sql_read)) {
		asprintf((char **)&((*query)->acf->desc),
					"Runs the following query, as defined in func_odbc.conf, performing\n"
				   	"substitution of the arguments into the query as specified by ${ARG1},\n"
					"${ARG2}, ... ${ARGn}.  This function may only be read, not set.\n\nSQL:\n%s\n",
					(*query)->sql_read);
	} else if (!ast_strlen_zero((*query)->sql_write)) {
		asprintf((char **)&((*query)->acf->desc),
					"Runs the following query, as defined in func_odbc.conf, performing\n"
				   	"substitution of the arguments into the query as specified by ${ARG1},\n"
					"${ARG2}, ... ${ARGn}.  The values are provided either in whole as\n"
					"${VALUE} or parsed as ${VAL1}, ${VAL2}, ... ${VALn}.\n"
					"This function may only be set.\nSQL:\n%s\n",
					(*query)->sql_write);
	} else {
		free((char *)(*query)->acf->syntax);
		free((char *)(*query)->acf->name);
		free((*query)->acf);
		free(*query);
		*query = NULL;
		ast_log(LOG_WARNING, "Section %s was found, but there was no SQL to execute.  Ignoring.\n", catg);
		return EINVAL;
	}

	/* Could be out of memory, or could be we have neither sql_read nor sql_write */
	if (! ((*query)->acf->desc)) {
		free((char *)(*query)->acf->syntax);
		free((char *)(*query)->acf->name);
		free((*query)->acf);
		free(*query);
		*query = NULL;
		return ENOMEM;
	}

	if (ast_strlen_zero((*query)->sql_read)) {
		(*query)->acf->read = NULL;
	} else {
		(*query)->acf->read = acf_odbc_read;
	}

	if (ast_strlen_zero((*query)->sql_write)) {
		(*query)->acf->write = NULL;
	} else {
		(*query)->acf->write = acf_odbc_write;
	}

	return 0;
}

static int free_acf_query(struct acf_odbc_query *query)
{
	if (query) {
		if (query->acf) {
			if (query->acf->name)
				free(query->acf->name);
			if (query->acf->syntax)
				free(query->acf->syntax);
			if (query->acf->desc)
				free(query->acf->desc);
			free(query->acf);
		}
		free(query);
	}
	return 0;
}

static int odbc_load_module(void)
{
	int res = 0;
	struct ast_config *cfg;
	char *catg;

	AST_LIST_LOCK(&queries);

	cfg = ast_config_load(config);
	if (!cfg) {
		ast_log(LOG_WARNING, "Unable to load config for func_odbc: %s\n", config);
		AST_LIST_UNLOCK(&queries);
		return -1;
	}

	for (catg = ast_category_browse(cfg, NULL);
	     catg;
	     catg = ast_category_browse(cfg, catg)) {
		struct acf_odbc_query *query = NULL;
		int err;

		if ((err = init_acf_query(cfg, catg, &query))) {
			if (err == ENOMEM)
				ast_log(LOG_ERROR, "Out of memory\n");
			else if (err == EINVAL)
				ast_log(LOG_ERROR, "Invalid parameters for category %s\n", catg);
			else
				ast_log(LOG_ERROR, "%s (%d)\n", strerror(err), err);
		} else {
			AST_LIST_INSERT_HEAD(&queries, query, list);
			ast_custom_function_register(query->acf);
		}
	}

	ast_config_destroy(cfg);
	ast_custom_function_register(&escape_function);

	AST_LIST_UNLOCK(&queries);
	return res;
}

static int odbc_unload_module(void)
{
	struct acf_odbc_query *query;

	AST_LIST_LOCK(&queries);
	while (!AST_LIST_EMPTY(&queries)) {
		query = AST_LIST_REMOVE_HEAD(&queries, list);
		ast_custom_function_unregister(query->acf);
		free_acf_query(query);
	}

	ast_custom_function_unregister(&escape_function);

	/* Allow any threads waiting for this lock to pass (avoids a race) */
	AST_LIST_UNLOCK(&queries);
	AST_LIST_LOCK(&queries);

	AST_LIST_UNLOCK(&queries);
	return 0;
}

int reload(void)
{
	int res = 0;
	struct ast_config *cfg;
	struct acf_odbc_query *oldquery;
	char *catg;

	AST_LIST_LOCK(&queries);

	while (!AST_LIST_EMPTY(&queries)) {
		oldquery = AST_LIST_REMOVE_HEAD(&queries, list);
		ast_custom_function_unregister(oldquery->acf);
		free_acf_query(oldquery);
	}

	cfg = ast_config_load(config);
	if (!cfg) {
		ast_log(LOG_WARNING, "Unable to load config for func_odbc: %s\n", config);
		goto reload_out;
	}

	for (catg = ast_category_browse(cfg, NULL);
	     catg;
	     catg = ast_category_browse(cfg, catg)) {
		struct acf_odbc_query *query = NULL;

		if (init_acf_query(cfg, catg, &query)) {
			ast_log(LOG_ERROR, "Cannot initialize query %s\n", catg);
		} else {
			AST_LIST_INSERT_HEAD(&queries, query, list);
			ast_custom_function_register(query->acf);
		}
	}

	ast_config_destroy(cfg);
reload_out:
	AST_LIST_UNLOCK(&queries);
	return res;
}

int unload_module(void)
{
	return odbc_unload_module();
}

int load_module(void)
{
	return odbc_load_module();
}

char *description(void)
{
	return tdesc;
}

int usecount(void)
{
	if (! ast_mutex_trylock(&(&queries)->lock)) {
		ast_mutex_unlock(&(&queries)->lock);
		return 0;
	} else {
		return 1;
	}
}

char *key()
{
	return ASTERISK_GPL_KEY;
}




;
; func_odbc.conf
;
; Each context is a separately defined function.  By convention, all
; functions are entirely uppercase, so the defined contexts should also
; be all-uppercase, but there is nothing that enforces this.  All functions
; are case-sensitive, however.
;
; For substitution, you have ${ARG1}, ${ARG2} ... ${ARGn}
; for the arguments to each SQL statement.
;
; In addition, for write statements, you have ${VAL1}, ${VAL2} ... ${VALn}
; parsed, just like arguments, for the values.  In addition, if you want the
; whole value, never mind the parsing, you can get that with ${VALUE}.
;
;
; If you have data which may potentially contain single ticks, you may wish
; to use the dialplan function SQL_ESC() to escape the data prior to its
; inclusion in the SQL statement.


; ODBC_SQL - Allow an SQL statement to be built entirely in the dialplan
[SQL]
readhandle=mysql1
readsql=${ARG1}

; ODBC_ANTIGF - A blacklist.
[ANTIGF]
readhandle=mysql1
readsql=SELECT COUNT(*) FROM exgirlfriends WHERE callerid='${SQL_ESC(${ARG1})}'

; ODBC_PRESENCE - Retrieve and update presence
[PRESENCE]
readhandle=mysql1
writehandle=mysql1
readsql=SELECT location FROM presence WHERE id='${SQL_ESC(${ARG1})}'
writesql=UPDATE presence SET location='${SQL_ESC(${VAL1})}' WHERE id='${SQL_ESC(${ARG1})}'
;
;prefix=OFFICE		; Changes this function from ODBC_PRESENCE to OFFICE_PRESENCE
;escapecommas=no	; Normally, commas within a field are escaped such that each
			; field may be separated into individual variables with ARRAY or HASH.
			; This option turns that behavior off [default=yes].





#define TRUNK_STANDARD_APP_ARGS(args, parse) \
	args.argc = trunk_app_separate_args(parse, '|', args.argv, (sizeof(args) - sizeof(args.argc)) / sizeof(args.argv[0]))
#define TRUNK_NONSTANDARD_APP_ARGS(args, parse, sep) \
	args.argc = trunk_app_separate_args(parse, sep, args.argv, (sizeof(args) - sizeof(args.argc)) / sizeof(args.argv[0]))

static unsigned int trunk_app_separate_args(char *buf, char delim, char **array, int arraylen)
{
	int argc;
	char *scan;
	int paren = 0, quote = 0;

	if (!buf || !array || !arraylen)
		return 0;

	memset(array, 0, arraylen * sizeof(*array));

	scan = buf;

	for (argc = 0; *scan && (argc < arraylen - 1); argc++) {
		array[argc] = scan;
		for (; *scan; scan++) {
			if (*scan == '(')
				paren++;
			else if (*scan == ')') {
				if (paren)
					paren--;
			} else if (*scan == '"') {
				quote = quote ? 0 : 1;
				/* Remove quote character from argument */
				memmove(scan, scan + 1, strlen(scan));
				scan--;
			} else if (*scan == '\\') {
				/* Literal character, don't parse */
				memmove(scan, scan + 1, strlen(scan));
			} else if ((*scan == delim) && !paren && !quote) {
				*scan++ = '\0';
				break;
			}
		}
	}

	if (*scan)
		array[argc++] = scan;

	return argc;
}


Return to bug 212306

Line 0 Link Here

(-)asterisk.original/asterisk-1.2.26.2.ebuild (+479 lines)
		1	# Copyright 1999-2008 Gentoo Foundation
		2	# Distributed under the terms of the GNU General Public License v2
		3	# $Header: /var/cvsroot/gentoo-x86/net-misc/asterisk/asterisk-1.2.21.1-r1.ebuild,v 1.5 2008/02/21 18:14:20 welp Exp $
		4
		5	inherit eutils multilib toolchain-funcs
		6
		7	IUSE="alsa bri curl debug doc gtk h323 hardened lowmem mmx \
		8	nosamples odbc osp postgres pri speex sqlite ssl zaptel \
		9	elibc_uclibc backports"
		10
		11	BRI_VERSION="0.3.0-PRE-1y-p"
		12	AST_PATCHES="1.2.26.2-patches-1.0"
		13	JB_PATCHES="1.2.11-jb"
		14
		15	MY_P="${P/_p/.}"
		16
		17	DESCRIPTION="Asterisk: A Modular Open Source PBX System"
		18	HOMEPAGE="http://www.asterisk.org/"
		19	SRC_URI="http://ftp.digium.com/pub/asterisk/releases/${MY_P}.tar.gz
		20	http://www.netdomination.org/pub/asterisk/${PN}-${AST_PATCHES}.tar.bz2
		21	mirror://gentoo/${PN}-${AST_PATCHES}.tar.bz2
		22	bri? ( mirror://gentoo/${MY_P}-bristuff-${BRI_VERSION}.diff.bz2
		23	http://www.junghanns.net/downloads/bristuff-${BRI_VERSION}.tar.gz )"
		24
		25	S="${WORKDIR}/${MY_P}"
		26	S_BRI="${WORKDIR}/bristuff-${BRI_VERSION}"
		27
		28	SLOT="0"
		29	LICENSE="GPL-2"
		30	KEYWORDS="~alpha amd64 ~hppa ~ppc sparc x86"
		31
		32	RDEPEND="dev-libs/newt
		33	media-sound/sox
		34	ssl? ( dev-libs/openssl )
		35	gtk? ( =x11-libs/gtk+-1.2* )
		36	pri? ( >=net-libs/libpri-1.2.5 )
		37	h323? ( >=dev-libs/pwlib-1.8.3
		38	>=net-libs/openh323-1.15.0 )
		39	alsa? ( media-libs/alsa-lib )
		40	curl? ( net-misc/curl )
		41	odbc? ( dev-db/unixODBC )
		42	backports? ( dev-db/unixODBC )
		43	speex? ( media-libs/speex )
		44	sqlite? ( <dev-db/sqlite-3.0.0 )
		45	zaptel? ( >=net-misc/zaptel-1.2.16 )
		46	postgres? ( dev-db/postgresql )
		47	osp? ( >=net-libs/osptoolkit-3.3.4 )
		48	bri? ( >=net-libs/libpri-1.2.5
		49	>=net-misc/zaptel-1.2.18 )"
		50
		51	DEPEND="${RDEPEND}
		52	sys-devel/flex
		53	sys-devel/bison
		54	doc? ( app-doc/doxygen )
		55	virtual/logger"
		56
		57	#asterisk uses special mpg123 functions and does not work with mpeg321, bug #42703
		58	PDEPEND="\|\| ( media-sound/mpg123 net-misc/asterisk-addons )"
		59
		60	QA_TEXTRELS_x86="usr/lib/asterisk/modules/codec_gsm.so"
		61	QA_EXECSTACK_x86="usr/lib/asterisk/modules/codec_gsm.so"
		62
		63	#
		64	# List of modules to ignore during scan (because they have been removed in 1.2.x)
65	#
66	SCAN_IGNORE_MODS="
67	app_qcall
68	chan_modem
69	chan_modem_i4l
70	chan_modem_bestdata
71	chan_modme_aopen"
72
73	#
74	# shortcuts
75	#
76	is_ast10update() {
77	return $(has_version "=net-misc/asterisk-1.0*")
78	}
79
80	is_astupdate() {
81	if ! is_ast10update; then
82	return $(has_version "<net-misc/asterisk-${PV}")
83	fi
84	return 0
85	}
86
87	#
88	# Display a nice countdown...
89	#
90	countdown() {
91	local n
92
93	ebeep
94
95	n=${1:-10}
96	while [[ $n -gt 0 ]]; do
97	echo -en " Waiting $n second(s)...\r"
98	sleep 1
99	(( n-- ))
100	done
101	}
102
103	#
104	# Scan for asterisk-1.0.x modules that will have to be updated
105	#
106	scan_modules() {
107	local modules_list=""
108	local n
109
110	for x in $(ls -1 "${ROOT}"usr/$(get_libdir)/asterisk/modules/*.so); do
111	echo -en "Scanning.... $(basename ${x}) \r"
112
113	# skip blacklisted modules
114	hasq $(basename ${x//.so}) ${SCAN_IGNORE_MODS} && continue
115
116	if $(readelf -s "${x}" \| grep -q "\(ast_load\\|ast_destroy\)$"); then
117	modules_list="${modules_list} $(basename ${x//.so})"
118	fi
119	done
120
121	if [[ -n "${modules_list}" ]]; then
122	echo " ========================================================"
123	ewarn "Please update or unmerge the following modules:"
124	echo
125
126	n=0
127	for x in ${modules_list}; do
128	ewarn " - ${x}"
129	(( n++ ))
130	done
131
132	echo
133	ewarn "Warning: $n outdated module(s) found!"
134	ewarn "Warning: asterisk may not work if you don't update them!"
135	echo " ========================================================"
136	echo
137	einfo "You can use the \"asterisk-updater\" script to update the modules"
138	echo
139	countdown
140	echo
141	return 1
142	else
143	einfo "No asterisk-1.0.x modules found!"
144	return 0
145	fi
146	}
147
148	pkg_setup() {
149	local checkfailed=0 waitaftermsg=0
150
151	if is_ast10update; then
152	ewarn " Asterisk UPGRADE Warning"
153	ewarn ""
154	ewarn "- Please read ${ROOT}usr/share/doc/${PF}/UPGRADE.txt.gz after the installation!"
155	ewarn ""
156	ewarn " Asterisk UPGRADE Warning"
157	echo
158	waitaftermsg=1
159	fi
160
161	if use bri; then
162	if ! built_with_use net-libs/libpri bri; then
163	die "net-libs/libpri must be rebuilt ith USE=bri."
164	fi
165	elif use pri; then
166	if built_with_use net-libs/libpri bri; then
167	die "net-libs/libpri must be rebuilt without USE=bri."
168	fi
169	fi
170
171	#
172	# Regular checks
173	#
174	einfo "Running some pre-flight checks..."
175	echo
176
177	}
178
179	src_unpack() {
180	unpack ${A}
181	cd "${S}"
182
183	#
184	# gentoo patchset
185	#
186	for x in $(grep -v "^#\\| \+" "${WORKDIR}"/patches/patches.list); do
187	epatch "${WORKDIR}"/patches/${x}
188	done
189
190	if use mmx; then
191	if ! use hardened; then
192	einfo "Enabling mmx optimization"
193	sed -i -e "s:^#\(K6OPT[\t ]\+= -DK6OPT\):\1:" \
194	Makefile
195	else
196	ewarn "Hardened use-flag is set, not enabling mmx optimization for codec_gsm!"
197	fi
198	fi
199
200	if ! use debug; then
201	einfo "Disabling debug support"
202	sed -i -e "s:^\(DEBUG=\):#\1:" \
203	Makefile
204	fi
205
206	if ! use ssl; then
207	einfo "Disabling crypto support"
208	sed -i -e 's:^#\(NOCRYPTO=yes\):\1:' \
209	-e '/^LIBS+=-lssl/d' Makefile \|\| die
210	fi
211
212	epatch "${FILESDIR}"/1.2.0/asterisk-1.2.21.1-h323-dumb-makefile.diff
213
214	#
215	# uclibc patch
216	#
217	if use elibc_uclibc; then
218	einfo "Patching asterisk for uclibc..."
219	epatch "${FILESDIR}"/1.0.0/${PN}-1.0.5-uclibc-dns.diff
220	epatch "${FILESDIR}"/1.2.0/${PN}-1.2.1-uclibc-getloadavg.diff
221	fi
222
223	#
224	# BRI patches
225	#
226	if use bri; then
227	einfo "Patching asterisk w/ BRI stuff"
228
229	epatch "${WORKDIR}"/${MY_P}-bristuff-${BRI_VERSION}.diff
230	#epatch "${S_BRI}"/patches/asterisk.patch
231	fi
232
233	#
234	# Disable AEL, security bug #171884
235	# Re-enable at your own risk (no USE since it can be critical)
236	#
237	sed -i -e 's/pbx_ael.so//' pbx/Makefile \|\| die
238
239	#
240	# Some useful backports
241	#
242	if use backports; then
243	einfo "Adding func_odbc backport"
244	# http://svncommunity.digium.com/view/func_odbc/1.2/
245	cp "${FILESDIR}"/1.2.0/backports/func_odbc/*.c "${WORKDIR}"/${P}/funcs/
246	cp "${FILESDIR}"/1.2.0/backports/func_odbc/*.h "${WORKDIR}"/${P}/include/
247	cp "${FILESDIR}"/1.2.0/backports/func_odbc/*.sample "${WORKDIR}"/${P}/configs/
248
249	einfo "Adding app_stack2 backport"
250	# http://svncommunity.digium.com/view/app_stack/1.2/
251	cp "${FILESDIR}"/1.2.0/backports/app_stack/*.c "${WORKDIR}"/${P}/apps/
252	epatch "${FILESDIR}"/1.2.0/backports/app_stack/asterisk-app_stack2-makefile.diff
253	fi
254
255	}
256
257	src_compile() {
258	local myopts
259
260	use lowmem && \
261	myopts="-DLOW_MEMORY"
262
263	if use h323; then
264	einfo "Building H.323 wrapper lib..."
265	make -C channels/h323 \
266	NOTRACE=1 \
267	PWLIBDIR=/usr/share/pwlib \
268	OPENH323DIR=/usr/share/openh323 \
269	libchanh323.a Makefile.ast \|\| die "Make h323 failed"
270	fi
271
272	einfo "Building Asterisk..."
273	make \
274	CC=$(tc-getCC) \
275	NOTRACE=1 \
276	OPTIMIZE="${CFLAGS}" \
277	PWLIBDIR=/usr/share/pwlib \
278	OPENH323DIR=/usr/share/openh323 \
279	OPTIONS="${myopts}" \|\| die "Make failed"
280
281	# create api docs
282	use doc && \
283	make progdocs
284
285	# build bristuff's ISDNguard
286	use bri && \
287	make -C "${S_BRI}"/ISDNguard
288	}
289
290	src_install() {
291
292	# install asterisk
293	make DESTDIR="${D}" ASTLIBDIR="\$(INSTALL_PREFIX)/usr/$(get_libdir)/asterisk" install \|\| die "Make install failed"
294	make DESTDIR="${D}" ASTLIBDIR="\$(INSTALL_PREFIX)/usr/$(get_libdir)/asterisk" samples \|\| die "Failed to create sample files"
295
296	# remove bristuff capi
297	use bri && \
298	rm -f "${D}"usr/$(get_libdir)/asterisk/modules/{app,chan}_capi*.so 2>/dev/null
299
300	# remove installed sample files if nosamples flag is set
301	if use nosamples; then
302	einfo "Skipping installation of sample files..."
303	rm -rf "${D}"var/spool/asterisk/voicemail/default
304	rm -f "${D}"var/lib/asterisk/mohmp3/*
305	rm -f "${D}"var/lib/asterisk/sounds/demo-*
306	rm -f "${D}"var/lib/asterisk/agi-bin/*
307	else
308	einfo "Sample files have been installed"
309	keepdir /var/spool/asterisk/voicemail/default/1234/INBOX
310	fi
311
312	# move sample configuration files to doc directory
313	if is_ast10update; then
314	elog "Updating from old (pre-1.2) asterisk version, new configuration files have been installed"
315	elog "into ${ROOT}etc/asterisk, use etc-update or dispatch-conf to update them"
316	elif has_version "net-misc/asterisk"; then
317	elog "Configuration samples have been moved to: $ROOT/usr/share/doc/${PF}/conf"
318	insinto /usr/share/doc/${PF}/conf
319	doins "${D}"etc/asterisk/.conf
320	rm -f "${D}"etc/asterisk/.conf 2>/dev/null
321	fi
322
323	# don't delete these directories, even if they are empty
324	for x in voicemail meetme system dictate monitor tmp; do
325	keepdir /var/spool/asterisk/${x}
326	done
327	keepdir /var/lib/asterisk/sounds/priv-callerintros
328	keepdir /var/lib/asterisk/mohmp3
329	keepdir /var/lib/asterisk/agi-bin
330	keepdir /var/log/asterisk/cdr-csv
331	keepdir /var/log/asterisk/cdr-custom
332	keepdir /var/run/asterisk
333
334	# install astxs
335	dobin contrib/scripts/astxs
336
337	newinitd "${FILESDIR}"/1.2.0/asterisk.rc6 asterisk
338	newconfd "${FILESDIR}"/1.2.0/asterisk.confd asterisk
339
340	# install standard docs...
341	dodoc BUGS CREDITS LICENSE ChangeLog HARDWARE README README.fpm
342	dodoc SECURITY doc/CODING-GUIDELINES doc/linkedlists.README UPGRADE.txt
343	dodoc doc/README.*
344	dodoc doc/*.txt
345
346	docinto scripts
347	dodoc contrib/scripts/*
348
349	docinto utils
350	dodoc contrib/utils/*
351
352	docinto configs
353	dodoc configs/*
354
355	# install api docs
356	if use doc; then
357	insinto /usr/share/doc/${PF}/api/html
358	doins doc/api/html/*
359	fi
360
361	# install ISDNguard
362	if use bri; then
363	cd "${S_BRI}"/ISDNguard
364	dosbin ISDNguard
365
366	docinto ISDNguard
367	dodoc INSTALL.ISDNguard
368
369	cd "${S}"
370	fi
371
372	insinto /usr/share/doc/${PF}/cgi
373	doins contrib/scripts/vmail.cgi
374	doins images/*.gif
375
376	# install asterisk-updater
377	dosbin "${FILESDIR}"/1.2.0/asterisk-updater
378
379	# install asterisk.h, a lot of external modules need this
380	insinto /usr/include/asterisk
381	doins include/asterisk.h
382
383	# make sure misdn/capi stuff is not installed, provided by asterisk-chan_..
384	rm -f "${D}"/etc/asterisk/misdn.conf "${D}"/usr/lib/asterisk/modules/chan_misdn.so \
385	"${D}"/usr/share/doc/${PF}/{conf/misdn.conf,configs/misdn.conf.sample.gz,README.misdn.gz}
386	rm -f "${D}"/usr/include/asterisk/chan_capi{,_app}.h \
387	"${D}"/usr/share/doc/${PF}/{conf/capi.conf,configs/capi.conf.sample.gz}
388	}
389
390	pkg_preinst() {
391	enewgroup asterisk
392	enewuser asterisk -1 -1 /var/lib/asterisk asterisk
393	}
394
395	pkg_postinst() {
396	einfo "Fixing permissions"
397	chown -R asterisk:asterisk "${ROOT}"var/log/asterisk
398	chmod -R u=rwX,g=rX,o= "${ROOT}"var/log/asterisk
399
400	for x in lib run spool; do
401	chown -R asterisk:asterisk "${ROOT}"var/${x}/asterisk
402	chmod -R u=rwX,g=rwX,o= "${ROOT}"var/${x}/asterisk
403	done
404
405	chown asterisk:asterisk "${ROOT}"etc/asterisk/
406	chown asterisk:asterisk "${ROOT}"etc/asterisk/*.adsi
407	chown asterisk:asterisk "${ROOT}"etc/asterisk/extensions.ael
408	chmod u=rwX,g=rwX,o= "${ROOT}"etc/asterisk/
409	chmod u=rwX,g=rwX,o= "${ROOT}"etc/asterisk/*.adsi
410	chmod u=rwX,g=rwX,o= "${ROOT}"etc/asterisk/extensions.ael
411	echo
412
413	#
414	# Announcements, warnings, reminders...
415	#
416	einfo "Asterisk has been installed"
417	einfo ""
418	elog "If you want to know more about asterisk, visit these sites:"
419	elog "http://www.asteriskdocs.org/"
420	elog "http://www.voip-info.org/wiki-Asterisk"
421	elog
422	elog "http://www.automated.it/guidetoasterisk.htm"
423	elog
424	elog "Gentoo VoIP IRC Channel:"
425	elog "#gentoo-voip @ irc.freenode.net"
426	elog
427	elog "Please note that AEL is no longer built because of security bugs"
428	elog "See http://bugs.gentoo.org/show_bug.cgi?id=171884"
429	elog
430	echo
431	echo
432
433	#
434	# Warning about 1.0 -> 1.2 changes...
435	#
436	if is_ast10update; then
437	ewarn ""
438	ewarn "- Please read ${ROOT}usr/share/doc/${PF}/UPGRADE.txt.gz before continuing"
439	ewarn ""
440	fi
441
442	if is_astupdate; then
443	ewarn ""
444	ewarn " - The initgroups patch has been dropped, please update your"
445	ewarn " \"conf.d/asterisk\" and \"init.d/asterisk\" file!"
446	ewarn ""
447	fi
448
449	# scan for old modules
450	if is_ast10update; then
451	einfo "Asterisk has been updated from pre-1.2.x, scanning for old modules"
452	scan_modules
453	fi
454	}
455
456	pkg_config() {
457	einfo "Do you want to reset file permissions and ownerships (y/N)?"
458
459	read tmp
460	tmp="$(echo $tmp \| tr [:upper:] [:lower:])"
461
462	if [[ "$tmp" = "y" ]] \|\|\
463	[[ "$tmp" = "yes" ]]
464	then
465	einfo "Resetting permissions to defaults..."
466
467	for x in spool run lib log; do
468	chown -R asterisk:asterisk "${ROOT}"var/${x}/asterisk
469	chmod -R u=rwX,g=rX,o= "${ROOT}"var/${x}/asterisk
470	done
471
472	chown -R root:asterisk "${ROOT}"etc/asterisk
473	chmod -R u=rwX,g=rX,o= "${ROOT}"etc/asterisk
474
475	einfo "done"
476	else
477	einfo "skipping"
478	fi
479	}

Line 0 Link Here

(-)asterisk.original/files/1.2.0/backports/app_stack/app_stack2.c (+267 lines)
		1	/*
		2	* Asterisk -- An open source telephony toolkit.
		3	*
		4	* Copyright (c) 2004-2006 Tilghman Lesher <app_stack_v003@the-tilghman.com>.
		5	*
		6	* This code is released by the author with no restrictions on usage.
		7	*
		8	* See http://www.asterisk.org for more information about
		9	* the Asterisk project. Please do not directly contact
		10	* any of the maintainers of this project for assistance;
		11	* the project provides a web site, mailing lists and IRC
		12	* channels for your use.
		13	*
		14	* This program is free software, distributed under the terms of
		15	* the GNU General Public License Version 2. See the LICENSE file
		16	* at the top of the source tree.
		17	*/
		18
		19	/*! \file
		20	*
		21	* \brief Stack applications Gosub, Return, etc.
		22	*
		23	* \ingroup applications
		24	*/
		25
		26	#include <stdio.h>
		27	#include <stdlib.h>
		28	#include <unistd.h>
		29	#include <string.h>
		30
		31	#include "asterisk/options.h"
		32	#include "asterisk/logger.h"
		33	#include "asterisk/channel.h"
		34	#include "asterisk/chanvars.h"
		35	#include "asterisk/pbx.h"
		36	#include "asterisk/module.h"
		37	#include "asterisk/config.h"
		38	#include "asterisk/app.h"
		39
		40	#define STACKVAR "~GOSUB2~STACK~"
		41
		42	static const char *tdesc = "Stack Routines";
		43
		44	static const char *app_gosub = "Gosub2";
		45	static const char *app_gosubif = "GosubIf2";
		46	static const char *app_return = "Return2";
		47	static const char *app_pop = "StackPop2";
		48
		49	static const char *gosub_synopsis = "Jump to label, saving return address";
		50	static const char *gosubif_synopsis = "Jump to label, saving return address";
		51	static const char *return_synopsis = "Return from gosub routine";
		52	static const char *pop_synopsis = "Remove one address from gosub stack";
		53
		54	static const char *gosub_descrip =
		55	"Gosub2([[context\|]exten\|]priority[(arg1[\|...][\|argN])])\n"
		56	" Jumps to the label specified, saving the return address.\n";
		57	static const char *gosubif_descrip =
		58	"GosubIf2(condition?labeliftrue[(arg1[\|...])][:labeliffalse[(arg1[\|...])]])\n"
		59	" If the condition is true, then jump to labeliftrue. If false, jumps to\n"
		60	"labeliffalse, if specified. In either case, a jump saves the return point\n"
		61	"in the dialplan, to be returned to with a Return.\n";
		62	static const char *return_descrip =
		63	"Return2([return-value])\n"
		64	" Jumps to the last label on the stack, removing it. The return value, if\n"
65	"any, is saved in the channel variable GOSUB_RETVAL.\n";
66	static const char *pop_descrip =
67	"StackPop2()\n"
68	" Removes last label on the stack, discarding it.\n";
69
70	STANDARD_LOCAL_USER;
71
72	LOCAL_USER_DECL;
73
74	static int pop_exec(struct ast_channel chan, void data)
75	{
76	const char *frame = pbx_builtin_getvar_helper(chan, STACKVAR);
77	int numargs = 0, i;
78	char argname[15];
79
80	/* Pop any arguments for this stack frame off the variable stack */
81	if (frame) {
82	numargs = atoi(frame);
83	for (i = 1; i <= numargs; i++) {
84	snprintf(argname, sizeof(argname), "ARG%d", i);
85	pbx_builtin_setvar_helper(chan, argname, NULL);
86	}
87	}
88
89	/* Remove the last frame from the Gosub stack */
90	pbx_builtin_setvar_helper(chan, STACKVAR, NULL);
91
92	return 0;
93	}
94
95	static int return_exec(struct ast_channel chan, void data)
96	{
97	char *label = pbx_builtin_getvar_helper(chan, STACKVAR);
98	char argname[15], *retval = data;
99	int numargs, i;
100
101	if (ast_strlen_zero(label)) {
102	ast_log(LOG_ERROR, "Return2 without Gosub2: stack is empty\n");
103	return -1;
104	}
105
106	/* Pop any arguments for this stack frame off the variable stack */
107	numargs = atoi(label);
108	for (i = 1; i <= numargs; i++) {
109	snprintf(argname, sizeof(argname), "ARG%d", i);
110	pbx_builtin_setvar_helper(chan, argname, NULL);
111	}
112
113	/* If the label exists, it will always have a ':' */
114	label = strchr(label, ':') + 1;
115
116	if (ast_parseable_goto(chan, label)) {
117	ast_log(LOG_WARNING, "No next statement after Gosub2?\n");
118	return -1;
119	}
120
121	/* Remove the current frame from the Gosub stack */
122	pbx_builtin_setvar_helper(chan, STACKVAR, NULL);
123
124	/* Set a return value, if any */
125	pbx_builtin_setvar_helper(chan, "GOSUB_RETVAL", !ast_strlen_zero(retval) ? retval : "");
126	return 0;
127	}
128
129	static int gosub_exec(struct ast_channel chan, void data)
130	{
131	char newlabel[AST_MAX_EXTENSION + AST_MAX_CONTEXT + 11 + 11 + 4];
132	char argname[15], tmp = ast_strdupa(data), label, *endparen;
133	int i;
134	struct localuser *u;
135	AST_DECLARE_APP_ARGS(args2,
136	AST_APP_ARG(argval)[100];
137	);
138
139	if (ast_strlen_zero(data)) {
140	ast_log(LOG_ERROR, "Gosub2 requires an argument: Gosub2([[context\|]exten\|]priority[(arg1[\|...][\|argN])])\n");
141	return -1;
142	}
143
144	LOCAL_USER_ADD(u);
145
146	/* Separate the arguments from the label */
147	/* NOTE: you cannot use ast_app_separate_args for this, because '(' cannot be used as a delimiter. */
148	label = strsep(&tmp, "(");
149	if (tmp) {
150	endparen = strrchr(tmp, ')');
151	if (endparen)
152	*endparen = '\0';
153	else
154	ast_log(LOG_WARNING, "Ouch. No closing paren: '%s'?\n", (char *)data);
155	AST_STANDARD_APP_ARGS(args2, tmp);
156	} else
157	args2.argc = 0;
158
159	/* Create the return address, but don't save it until we know that the Gosub destination exists */
160	snprintf(newlabel, sizeof(newlabel), "%d:%s\|%s\|%d", args2.argc == 2 ? args2.argc : 0, chan->context, chan->exten, chan->priority + 1);
161
162	if (ast_parseable_goto(chan, data)) {
163	ast_log(LOG_WARNING, "Destination '%s' does not exist in the dialplan\n", (char *)data);
164	LOCAL_USER_REMOVE(u);
165	return -1;
166	}
167
168	/* Now that we know for certain that we're going to a new location, set our arguments */
169	for (i = 0; i < args2.argc; i++) {
170	snprintf(argname, sizeof(argname), "ARG%d", i + 1);
171	pbx_builtin_pushvar_helper(chan, argname, args2.argval[i]);
172	ast_log(LOG_DEBUG, "Setting %s to '%s'\n", argname, args2.argval[i]);
173	}
174
175	/* And finally, save our return address */
176	pbx_builtin_pushvar_helper(chan, STACKVAR, newlabel);
177	ast_log(LOG_DEBUG, "Setting gosub return address to %s\n", newlabel);
178
179	LOCAL_USER_REMOVE(u);
180
181	return 0;
182	}
183
184	static int gosubif_exec(struct ast_channel chan, void data)
185	{
186	struct localuser *u;
187	char *args;
188	int res=0;
189	AST_DECLARE_APP_ARGS(cond,
190	AST_APP_ARG(ition);
191	AST_APP_ARG(labels);
192	);
193	AST_DECLARE_APP_ARGS(label,
194	AST_APP_ARG(iftrue);
195	AST_APP_ARG(iffalse);
196	);
197
198	if (ast_strlen_zero(data)) {
199	ast_log(LOG_WARNING, "GosubIf2 requires an argument: GosubIf2(cond?label1(args):label2(args)\n");
200	return 0;
201	}
202
203	LOCAL_USER_ADD(u);
204
205	args = ast_strdupa((char *)data);
206	/* AST_NONSTANDARD_APP_ARGS(cond, args, '?'); */
207	cond.argc = ast_app_separate_args(args, '?', cond.argv, (sizeof(cond) - sizeof(cond.argc)) / sizeof(cond.argv[0]));
208	if (cond.argc != 2) {
209	ast_log(LOG_WARNING, "GosubIf2 requires an argument: GosubIf2(cond?label1(args):label2(args)\n");
210	LOCAL_USER_REMOVE(u);
211	return 0;
212	}
213
214	/* AST_NONSTANDARD_APP_ARGS(label, cond.labels, ':'); */
215	label.argc = ast_app_separate_args(cond.labels, ':', label.argv, (sizeof(label) - sizeof(label.argc)) / sizeof(label.argv[0]));
216
217	if (pbx_checkcondition(cond.ition)) {
218	if (!ast_strlen_zero(label.iftrue))
219	res = gosub_exec(chan, label.iftrue);
220	} else if (!ast_strlen_zero(label.iffalse)) {
221	res = gosub_exec(chan, label.iffalse);
222	}
223
224	LOCAL_USER_REMOVE(u);
225	return res;
226	}
227
228	int unload_module(void)
229	{
230	ast_unregister_application(app_return);
231	ast_unregister_application(app_pop);
232	ast_unregister_application(app_gosubif);
233	ast_unregister_application(app_gosub);
234
235	STANDARD_HANGUP_LOCALUSERS;
236
237	return 0;
238	}
239
240	int load_module(void)
241	{
242	ast_register_application(app_pop, pop_exec, pop_synopsis, pop_descrip);
243	ast_register_application(app_return, return_exec, return_synopsis, return_descrip);
244	ast_register_application(app_gosubif, gosubif_exec, gosubif_synopsis, gosubif_descrip);
245	ast_register_application(app_gosub, gosub_exec, gosub_synopsis, gosub_descrip);
246
247	return 0;
248	}
249
250	char *description(void)
251	{
252	return (char *) tdesc;
253	}
254
255	int usecount(void)
256	{
257	int res;
258
259	STANDARD_USECOUNT(res);
260
261	return res;
262	}
263
264	char *key()
265	{
266	return ASTERISK_GPL_KEY;
267	}

Line 0 Link Here

(-)asterisk.original/files/1.2.0/backports/func_odbc/func_array.c (+333 lines)
		1	--- asterisk-1.2.26.2-original/apps/Makefile 2006-04-30 15:38:22.000000000 +0200
Line 0 Link Here
		1	/*
		2	* Asterisk -- An open source telephony toolkit.
		3	*
		4	* Copyright (C) 2005, Tilghman Lesher.
		5	*
		6	* See http://www.asterisk.org for more information about
		7	* the Asterisk project. Please do not directly contact
		8	* any of the maintainers of this project for assistance;
		9	* the project provides a web site, mailing lists and IRC
		10	* channels for your use.
		11	*
		12	* This program is free software, distributed under the terms of
		13	* the GNU General Public License Version 2. See the LICENSE file
		14	* at the top of the source tree.
		15	*/
		16
		17	/*! \file
		18	*
		19	* \brief ARRAY dialplan function
		20	*
		21	* \author Tilghman Lesher
		22	*/
		23
		24	#include <stdlib.h>
		25	#include <stdio.h>
		26	#include <string.h>
		27	#include <sys/types.h>
		28	#include <sched.h>
		29
		30	#include "asterisk.h"
		31
		32	ASTERISK_FILE_VERSION(__FILE__, "$Revision: 20003 $")
		33
		34	#include "asterisk/module.h"
		35	#include "asterisk/channel.h"
		36	#include "asterisk/pbx.h"
		37	#include "asterisk/logger.h"
		38	#include "asterisk/utils.h"
		39	#include "asterisk/app.h"
		40	#include "asterisk/localtime.h"
		41	#include "asterisk/linkedlists.h"
		42
		43	#include "separate.h"
		44
		45	#define HASH_PREFIX "~HASH~%s~"
		46	#define HASH_FORMAT HASH_PREFIX "%s~"
		47
		48	AST_MUTEX_DEFINE_STATIC(local_lock);
		49	static int use_count = 0;
		50
		51	static char *app_clearhash = "ClearHash";
		52	static char *syn_clearhash = "Clear the keys from a specified hashname";
		53	static char *desc_clearhash =
		54	"ClearHash(<hashname>)\n"
		55	" Clears all keys out of the specified hashname\n";
		56
		57	/* This function probably should migrate to main/pbx.c, as pbx_builtin_clearvar_prefix() */
		58	static void clearvar_prefix(struct ast_channel chan, const char prefix)
		59	{
		60	struct ast_var_t *newvar;
		61	int len = strlen(prefix);
		62	AST_LIST_TRAVERSE_SAFE_BEGIN(&chan->varshead, newvar, entries) {
		63	if (strncasecmp(prefix, ast_var_name(newvar), len) == 0) {
		64	AST_LIST_REMOVE_CURRENT(&chan->varshead, entries);
65	free(newvar);
66	}
67	}
68	AST_LIST_TRAVERSE_SAFE_END
69	}
70
71	static int exec_clearhash(struct ast_channel chan, void data)
72	{
73	char prefix[80];
74	snprintf(prefix, sizeof(prefix), HASH_PREFIX, data ? (char *)data : "null");
75	clearvar_prefix(chan, prefix);
76	return 0;
77	}
78
79	static void array(struct ast_channel chan, char cmd, char var, const char value)
80	{
81	AST_DECLARE_APP_ARGS(arg1,
82	AST_APP_ARG(var)[100];
83	);
84	AST_DECLARE_APP_ARGS(arg2,
85	AST_APP_ARG(val)[100];
86	);
87	char origvar = "", value2, varname[256];
88	int i, ishash = 0;
89
90	value2 = ast_strdupa(value);
91	if (!var \|\| !value2)
92	return;
93
94	ast_mutex_lock(&local_lock);
95	use_count++;
96	ast_mutex_unlock(&local_lock);
97
98	if (!strcmp(cmd, "HASH")) {
99	const char *var2 = pbx_builtin_getvar_helper(chan, "~ODBCFIELDS~");
100	origvar = var;
101	if (var2)
102	var = ast_strdupa(var2);
103	else
104	return;
105	ishash = 1;
106	}
107
108	/* The functions this will generally be used with are SORT and ODBC_*, which
109	* both return comma-delimited lists. However, if somebody uses literal lists,
110	* their commas will be translated to vertical bars by the load, and I don't
111	* want them to be surprised by the result. Hence, we prefer commas as the
112	* delimiter, but we'll fall back to vertical bars if commas aren't found.
113	*/
114	ast_log(LOG_DEBUG, "array (%s=%s)\n", var, value2);
115	if (strchr(var, ','))
116	TRUNK_NONSTANDARD_APP_ARGS(arg1, var, ',');
117	else
118	TRUNK_STANDARD_APP_ARGS(arg1, var);
119
120	if (strchr(value2, ','))
121	TRUNK_NONSTANDARD_APP_ARGS(arg2, value2, ',');
122	else
123	TRUNK_STANDARD_APP_ARGS(arg2, value2);
124
125	for (i = 0; i < arg1.argc; i++) {
126	ast_log(LOG_DEBUG, "array set value (%s=%s)\n", arg1.var[i],
127	arg2.val[i]);
128	if (i < arg2.argc) {
129	if (ishash) {
130	snprintf(varname, sizeof(varname), HASH_FORMAT, origvar, arg1.var[i]);
131	pbx_builtin_setvar_helper(chan, varname, arg2.val[i]);
132	} else {
133	pbx_builtin_setvar_helper(chan, arg1.var[i], arg2.val[i]);
134	}
135	} else {
136	/* We could unset the variable, by passing a NULL, but due to
137	* pushvar semantics, that could create some undesired behavior. */
138	if (ishash) {
139	snprintf(varname, sizeof(varname), HASH_FORMAT, origvar, arg1.var[i]);
140	pbx_builtin_setvar_helper(chan, varname, "");
141	} else {
142	pbx_builtin_setvar_helper(chan, arg1.var[i], "");
143	}
144	}
145	}
146
147	ast_mutex_lock(&local_lock);
148	use_count--;
149	ast_mutex_unlock(&local_lock);
150
151	return;
152	}
153
154	static char hashkeys_read(struct ast_channel chan, char cmd, char data, char *buf, size_t len)
155	{
156	struct ast_var_t *newvar;
157	int plen;
158	char prefix[80];
159	snprintf(prefix, sizeof(prefix), HASH_PREFIX, data);
160	plen = strlen(prefix);
161
162	memset(buf, 0, len);
163	AST_LIST_TRAVERSE(&chan->varshead, newvar, entries) {
164	if (strncasecmp(prefix, ast_var_name(newvar), plen) == 0) {
165	/* Copy everything after the prefix */
166	strncat(buf, ast_var_name(newvar) + plen, len);
167	/* Trim the trailing ~ */
168	buf[strlen(buf) - 1] = ',';
169	}
170	}
171	/* Trim the trailing comma */
172	buf[strlen(buf) - 1] = '\0';
173	return buf;
174	}
175
176	static void hash_write(struct ast_channel chan, char cmd, char var, const char value)
177	{
178	char varname[256];
179	AST_DECLARE_APP_ARGS(arg,
180	AST_APP_ARG(hashname);
181	AST_APP_ARG(hashkey);
182	);
183
184	ast_mutex_lock(&local_lock);
185	use_count++;
186	ast_mutex_unlock(&local_lock);
187
188	if (!strchr(var, '\|')) {
189	/* Single argument version */
190	array(chan, "HASH", var, value);
191	return;
192	}
193
194	TRUNK_STANDARD_APP_ARGS(arg, var);
195	snprintf(varname, sizeof(varname), HASH_FORMAT, arg.hashname, arg.hashkey);
196	pbx_builtin_setvar_helper(chan, varname, value);
197
198	ast_mutex_lock(&local_lock);
199	use_count--;
200	ast_mutex_unlock(&local_lock);
201	}
202
203	static char hash_read(struct ast_channel chan, char cmd, char data, char *buf, size_t len)
204	{
205	char varname[256];
206	const char *varvalue;
207	AST_DECLARE_APP_ARGS(arg,
208	AST_APP_ARG(hashname);
209	AST_APP_ARG(hashkey);
210	);
211
212	ast_mutex_lock(&local_lock);
213	use_count++;
214	ast_mutex_unlock(&local_lock);
215
216	TRUNK_STANDARD_APP_ARGS(arg, data);
217	if (arg.argc == 2) {
218	snprintf(varname, sizeof(varname), HASH_FORMAT, arg.hashname, arg.hashkey);
219	varvalue = pbx_builtin_getvar_helper(chan, varname);
220	if (varvalue)
221	ast_copy_string(buf, varvalue, len);
222	else
223	*buf = '\0';
224	} else if (arg.argc == 1) {
225	char colnames[4096];
226	int i;
227	AST_DECLARE_APP_ARGS(arg2,
228	AST_APP_ARG(col)[100];
229	);
230
231	/* Get column names, in no particular order */
232	hashkeys_read(chan, "HASHKEYS", arg.hashname, colnames, sizeof(colnames));
233	pbx_builtin_setvar_helper(chan, "~ODBCFIELDS~", colnames);
234
235	TRUNK_NONSTANDARD_APP_ARGS(arg2, colnames, ',');
236	*buf = '\0';
237
238	/* Now get the corresponding column values, in exactly the same order */
239	for (i = 0; i < arg2.argc; i++) {
240	snprintf(varname, sizeof(varname), HASH_FORMAT, arg.hashname, arg2.col[i]);
241	varvalue = pbx_builtin_getvar_helper(chan, varname);
242	strncat(buf, varvalue, len);
243	strncat(buf, ",", len);
244	}
245
246	/* Strip trailing comma */
247	buf[strlen(buf) - 1] = '\0';
248	}
249
250	return buf;
251	}
252
253	static struct ast_custom_function array_function = {
254	.name = "ARRAY",
255	.synopsis = "Allows setting multiple variables at once",
256	.syntax = "ARRAY(var1[\|var2[...][\|varN]])",
257	.write = array,
258	.desc =
259	"The comma-separated list passed as a value to which the function is set will\n"
260	"be interpreted as a set of values to which the comma-separated list of\n"
261	"variable names in the argument should be set.\n"
262	"Hence, Set(ARRAY(var1,var2)=1,2) will set var1 to 1 and var2 to 2\n"
263	"Note: remember to either backslash your commas in extensions.conf or quote the\n"
264	"entire argument, since Set can take multiple arguments itself.\n",
265	};
266
267	static struct ast_custom_function hash_function = {
268	.name = "HASH",
269	.synopsis = "Implementation of a dialplan associative array",
270	.syntax = "HASH(hashname[\|hashkey])",
271	.write = hash_write,
272	.read = hash_read,
273	.desc =
274	"In two argument mode, gets and sets values to corresponding keys within a named\n"
275	"associative array. The single-argument mode will only work when assigned to from\n"
276	"a function defined by func_odbc.so.\n",
277	};
278
279	static struct ast_custom_function hashkeys_function = {
280	.name = "HASHKEYS",
281	.synopsis = "Retrieve the keys of a HASH()",
282	.syntax = "HASHKEYS(<hashname>)",
283	.read = hashkeys_read,
284	.desc =
285	"Returns a comma-delimited list of the current keys of an associative array\n"
286	"defined by the HASH() function. Note that if you iterate over the keys of\n"
287	"the result, adding keys during iteration will cause the result of the HASHKEYS\n"
288	"function to change.\n",
289	};
290
291	static char *tdesc = "String handling dialplan functions";
292
293	int unload_module(void)
294	{
295	int res = 0;
296
297	res \|= ast_custom_function_unregister(&array_function);
298	res \|= ast_custom_function_unregister(&hash_function);
299	res \|= ast_custom_function_unregister(&hashkeys_function);
300	res \|= ast_unregister_application(app_clearhash);
301	sched_yield(); /* Any remaining process gets time to clear out. Increases safety if a force unload is attempted. */
302
303	return res;
304	}
305
306	int load_module(void)
307	{
308	int res = 0;
309
310	res \|= ast_custom_function_register(&array_function);
311	res \|= ast_custom_function_register(&hash_function);
312	res \|= ast_custom_function_register(&hashkeys_function);
313	res \|= ast_register_application(app_clearhash, exec_clearhash, syn_clearhash, desc_clearhash);
314
315	return res;
316	}
317
318	char *description(void)
319	{
320	return tdesc;
321	}
322
323	int usecount(void)
324	{
325	return use_count;
326	}
327
328	char *key(void)
329	{
330	return ASTERISK_GPL_KEY;
331	}
332

Line 0 Link Here

(-)asterisk.original/files/1.2.0/backports/func_odbc/func_odbc.conf.sample (+43 lines)
	1	;
	2	; func_odbc.conf
	3	;
	4	; Each context is a separately defined function. By convention, all
	5	; functions are entirely uppercase, so the defined contexts should also
	6	; be all-uppercase, but there is nothing that enforces this. All functions
	7	; are case-sensitive, however.
	8	;
	9	; For substitution, you have ${ARG1}, ${ARG2} ... ${ARGn}
	10	; for the arguments to each SQL statement.
	11	;
	12	; In addition, for write statements, you have ${VAL1}, ${VAL2} ... ${VALn}
	13	; parsed, just like arguments, for the values. In addition, if you want the
	14	; whole value, never mind the parsing, you can get that with ${VALUE}.
	15	;
	16	;
	17	; If you have data which may potentially contain single ticks, you may wish
	18	; to use the dialplan function SQL_ESC() to escape the data prior to its
	19	; inclusion in the SQL statement.
	20
	21
	22	; ODBC_SQL - Allow an SQL statement to be built entirely in the dialplan
	23	[SQL]
	24	readhandle=mysql1
	25	readsql=${ARG1}
	26
	27	; ODBC_ANTIGF - A blacklist.
	28	[ANTIGF]
	29	readhandle=mysql1
	30	readsql=SELECT COUNT(*) FROM exgirlfriends WHERE callerid='${SQL_ESC(${ARG1})}'
	31
	32	; ODBC_PRESENCE - Retrieve and update presence
	33	[PRESENCE]
	34	readhandle=mysql1
	35	writehandle=mysql1
	36	readsql=SELECT location FROM presence WHERE id='${SQL_ESC(${ARG1})}'
	37	writesql=UPDATE presence SET location='${SQL_ESC(${VAL1})}' WHERE id='${SQL_ESC(${ARG1})}'
	38	;
	39	;prefix=OFFICE ; Changes this function from ODBC_PRESENCE to OFFICE_PRESENCE
	40	;escapecommas=no ; Normally, commas within a field are escaped such that each
	41	; field may be separated into individual variables with ARRAY or HASH.
	42	; This option turns that behavior off [default=yes].
	43

Line 0 Link Here

(-)asterisk.original/files/1.2.0/backports/func_odbc/separate.h (+47 lines)
	1	#define TRUNK_STANDARD_APP_ARGS(args, parse) \
	2	args.argc = trunk_app_separate_args(parse, '\|', args.argv, (sizeof(args) - sizeof(args.argc)) / sizeof(args.argv[0]))
	3	#define TRUNK_NONSTANDARD_APP_ARGS(args, parse, sep) \
	4	args.argc = trunk_app_separate_args(parse, sep, args.argv, (sizeof(args) - sizeof(args.argc)) / sizeof(args.argv[0]))
	5
	6	static unsigned int trunk_app_separate_args(char buf, char delim, char *array, int arraylen)
	7	{
	8	int argc;
	9	char *scan;
	10	int paren = 0, quote = 0;
	11
	12	if (!buf \|\| !array \|\| !arraylen)
	13	return 0;
	14
	15	memset(array, 0, arraylen * sizeof(*array));
	16
	17	scan = buf;
	18
	19	for (argc = 0; *scan && (argc < arraylen - 1); argc++) {
	20	array[argc] = scan;
	21	for (; *scan; scan++) {
	22	if (*scan == '(')
	23	paren++;
	24	else if (*scan == ')') {
	25	if (paren)
	26	paren--;
	27	} else if (*scan == '"') {
	28	quote = quote ? 0 : 1;
	29	/* Remove quote character from argument */
	30	memmove(scan, scan + 1, strlen(scan));
	31	scan--;
	32	} else if (*scan == '\\') {
	33	/* Literal character, don't parse */
	34	memmove(scan, scan + 1, strlen(scan));
	35	} else if ((*scan == delim) && !paren && !quote) {
	36	*scan++ = '\0';
	37	break;
	38	}
	39	}
	40	}
	41
	42	if (*scan)
	43	array[argc++] = scan;
	44
	45	return argc;
	46	}
	47