/*
 * Copyright (C) 2001-2003 FhG Fokus
 *
 * This file is part of Kamailio, a free SIP server.
 *
 * Kamailio is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version
 *
 * Kamailio is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 *
 */


#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <signal.h>

#include "../../core/mem/shm_mem.h"
#include "../../core/mem/mem.h"
#include "../../core/sr_module.h"
#include "../../core/str.h"
#include "../../core/ut.h"
#include "../../core/dprint.h"
#include "../../core/data_lump_rpl.h"
#include "../../core/pvar.h"
#include "../../core/mod_fix.h"
#include "../../core/parser/parse_uri.h"
#include "../../core/parser/parse_from.h"
#include "../../core/parser/parse_content.h"
#include "../../core/parser/parse_disposition.h"
#include "../../core/cfg/cfg_struct.h"
#include "../../lib/srdb1/db.h"
#include "../../modules/sl/sl.h"
#include "cpl_run.h"
#include "cpl_env.h"
#include "cpl_db.h"
#include "cpl_loader.h"
#include "cpl_parser.h"
#include "cpl_nonsig.h"
#include "loc_set.h"


#define MAX_PROXY_RECURSE 10
#define MAX_USERHOST_LEN 256


/* modules param variables */
static str db_url = str_init(DEFAULT_DB_URL); /* database url */
static str db_table = str_init("cpl");		  /* database table */
static char *dtd_file = 0; /* name of the DTD file for CPL parser */
static char *lookup_domain = 0;
static str timer_avp = STR_NULL; /* name of variable timer AVP */
static str proxy_route = STR_NULL;
static str redirect_route = STR_NULL;

struct cpl_environment cpl_env = {
		0,		  /* no cpl logging */
		0,		  /* recurse proxy level is 0 */
		0,		  /* no script route to be run before proxy */
		0,		  /* no script route to be run before redirect */
		0,		  /* by default handle 3xx responses */
		0,		  /* user part is not case sensitive */
		{0, 0},	  /* no domain prefix to be ignored */
		{-1, -1}, /* communication pipe to aux_process */
		{0, 0},	  /* original TZ \0 terminated "TZ=value" format */
		0,		  /* udomain */
		0,		  /* no branches on lookup */
		0,		  /* timer avp type */
		{0},	  /* timer avp name/ID */
		0		  /* use_domain */
};

struct cpl_functions cpl_fct;
static str cpl_ok_rpl = str_init("OK");


MODULE_VERSION


static int cpl_invoke_script(struct sip_msg *msg, char *str1, char *str2);
static int cpl_invoke_script3(
		struct sip_msg *msg, char *str1, char *str2, char *str3);
static int w_process_register(struct sip_msg *msg, char *str1, char *str2);
static int w_process_register_norpl(
		struct sip_msg *msg, char *str1, char *str2);
static int cpl_process_register(struct sip_msg *msg, int no_rpl);
static int fixup_cpl_run_script(void **param, int param_no);
static int fixup_cpl_run_script3(void **param, int param_no);
static int cpl_init(void);
static int cpl_child_init(int rank);
static void cpl_exit(void);
static void cpl_process(int rank);

/*
 * Exported functions
 */
static cmd_export_t cmds[] = {
		{"cpl_run_script", (cmd_function)cpl_invoke_script, 2,
				fixup_cpl_run_script, 0, REQUEST_ROUTE},
		{"cpl_run_script", (cmd_function)cpl_invoke_script3, 3,
				fixup_cpl_run_script3, 0, REQUEST_ROUTE},
		{"cpl_process_register", (cmd_function)w_process_register, 0, 0, 0,
				REQUEST_ROUTE},
		{"cpl_process_register_norpl", (cmd_function)w_process_register_norpl,
				0, 0, 0, REQUEST_ROUTE},
		{0, 0, 0, 0, 0, 0}};


/*
 * Exported parameters
 */
static param_export_t params[] = {{"db_url", PARAM_STR, &db_url},
		{"db_table", PARAM_STR, &db_table},
		{"cpl_dtd_file", PARAM_STRING, &dtd_file},
		{"proxy_recurse", INT_PARAM, &cpl_env.proxy_recurse},
		{"proxy_route", PARAM_STR, &proxy_route},
		{"redirect_route", PARAM_STR, &redirect_route},
		{"ignore3xx", INT_PARAM, &cpl_env.ignore3xx},
		{"log_dir", PARAM_STRING, &cpl_env.log_dir},
		{"case_sensitive", INT_PARAM, &cpl_env.case_sensitive},
		{"realm_prefix", PARAM_STR, &cpl_env.realm_prefix},
		{"lookup_domain", PARAM_STRING, &lookup_domain},
		{"lookup_append_branches", INT_PARAM, &cpl_env.lu_append_branches},
		{"timer_avp", PARAM_STR, &timer_avp},
		{"username_column", PARAM_STR, &cpl_username_col},
		{"domain_column", PARAM_STR, &cpl_domain_col},
		{"cpl_xml_column", PARAM_STR, &cpl_xml_col},
		{"cpl_bin_column", PARAM_STR, &cpl_bin_col},
		{"use_domain", INT_PARAM, &cpl_env.use_domain}, {0, 0, 0}};


struct module_exports exports = {
		"cplc", DEFAULT_DLFLAGS, /* dlopen flags */
		cmds,					 /* exported functions */
		params,					 /* exported parameters */
		0,						 /* exported rpc functions */
		0,						 /* exported pseudo-variables */
		0,						 /* response handling function */
		cpl_init,				 /* module init function */
		cpl_child_init,			 /* child init function */
		cpl_exit				 /* module destroy function */
};


static int fixup_cpl_run_script(void **param, int param_no)
{
	long flag;

	if(param_no == 1) {
		if(!strcasecmp("incoming", *param))
			flag = CPL_RUN_INCOMING;
		else if(!strcasecmp("outgoing", *param))
			flag = CPL_RUN_OUTGOING;
		else {
			LM_ERR("script directive \"%s\" unknown!\n", (char *)*param);
			return E_UNSPEC;
		}
		pkg_free(*param);
		*param = (void *)flag;
		return 0;
	} else if(param_no == 2) {
		if(!strcasecmp("is_stateless", *param)) {
			flag = 0;
		} else if(!strcasecmp("is_stateful", *param)) {
			flag = CPL_IS_STATEFUL;
		} else if(!strcasecmp("force_stateful", *param)) {
			flag = CPL_FORCE_STATEFUL;
		} else {
			LM_ERR("flag \"%s\" (second param) unknown!\n", (char *)*param);
			return E_UNSPEC;
		}
		pkg_free(*param);
		*param = (void *)flag;
	}
	return 0;
}

static int fixup_cpl_run_script3(void **param, int param_no)
{
	if(param_no == 1 || param_no == 2) {
		return fixup_cpl_run_script(param, param_no);
	} else if(param_no == 3) {
		return fixup_spve_null(param, 1);
	}
	return 0;
}


static int cpl_init(void)
{
	bind_usrloc_t bind_usrloc;
	struct stat stat_t;
	char *ptr;
	int val;
	pv_spec_t avp_spec;
	unsigned short avp_type;

	if(cpl_rpc_init() < 0) {
		LM_ERR("failed to register RPC commands\n");
		return -1;
	}

	if(cpl_env.proxy_recurse > MAX_PROXY_RECURSE) {
		LM_CRIT("value of proxy_recurse param (%d) exceeds "
				"the maximum safety value (%d)\n",
				cpl_env.proxy_recurse, MAX_PROXY_RECURSE);
		goto error;
	}

	if(proxy_route.len > 0) {
		cpl_env.proxy_route = route_lookup(&main_rt, proxy_route.s);
		if(cpl_env.proxy_route == -1) {
			LM_CRIT("route <%s> defined in proxy_route does not exist\n",
					proxy_route.s);
			goto error;
		}
	}

	if(redirect_route.len > 0) {
		cpl_env.redirect_route = route_lookup(&main_rt, redirect_route.s);
		if(cpl_env.redirect_route == -1) {
			LM_CRIT("route <%s> defined in redirect_route does not exist\n",
					redirect_route.s);
			goto error;
		}
	}

	/* fix the timer_avp name */
	if(timer_avp.s && timer_avp.len > 0) {
		if(pv_parse_spec(&timer_avp, &avp_spec) == 0
				|| avp_spec.type != PVT_AVP) {
			LM_ERR("malformed or non AVP %.*s AVP definition\n", timer_avp.len,
					timer_avp.s);
			return -1;
		}

		if(pv_get_avp_name(0, &(avp_spec.pvp), &cpl_env.timer_avp, &avp_type)
				!= 0) {
			LM_ERR("[%.*s]- invalid AVP definition\n", timer_avp.len,
					timer_avp.s);
			return -1;
		}
		cpl_env.timer_avp_type = avp_type;
	}

	if(dtd_file == 0) {
		LM_CRIT("mandatory parameter \"cpl_dtd_file\" found empty\n");
		goto error;
	} else {
		/* check if the dtd file exists */
		if(stat(dtd_file, &stat_t) == -1) {
			LM_ERR("checking file \"%s\" status failed; stat returned %s\n",
					dtd_file, strerror(errno));
			goto error;
		}
		if(!S_ISREG(stat_t.st_mode)) {
			LM_ERR("dir \"%s\" is not a regular file!\n", dtd_file);
			goto error;
		}
		if(access(dtd_file, R_OK) == -1) {
			LM_ERR("checking file \"%s\" for permissions "
				   "failed; access returned %s\n",
					dtd_file, strerror(errno));
			goto error;
		}
	}

	if(cpl_env.log_dir == 0) {
		LM_INFO("log_dir param found empty -> logging disabled!\n");
	} else {
		if(strlen(cpl_env.log_dir) > MAX_LOG_DIR_SIZE) {
			LM_ERR("dir \"%s\" has a too long name :-(!\n", cpl_env.log_dir);
			goto error;
		}
		/* check if the dir exists */
		if(stat(cpl_env.log_dir, &stat_t) == -1) {
			LM_ERR("checking dir \"%s\" status failed;"
				   " stat returned %s\n",
					cpl_env.log_dir, strerror(errno));
			goto error;
		}
		if(!S_ISDIR(stat_t.st_mode)) {
			LM_ERR("dir \"%s\" is not a directory!\n", cpl_env.log_dir);
			goto error;
		}
		if(access(cpl_env.log_dir, R_OK | W_OK) == -1) {
			LM_ERR("checking dir \"%s\" for permissions failed; access "
				   "returned %s\n",
					cpl_env.log_dir, strerror(errno));
			goto error;
		}
	}

	/* bind to the mysql module */
	if(cpl_db_bind(&db_url, &db_table) < 0)
		goto error;

	/* load TM API */
	if(load_tm_api(&cpl_fct.tmb) != 0) {
		LM_ERR("can't load TM API\n");
		goto error;
	}
	/* bind the SL API */
	if(sl_load_api(&cpl_fct.slb) != 0) {
		LM_ERR("cannot bind to SL API\n");
		return -1;
	}

	/* bind to usrloc module if requested */
	if(lookup_domain) {
		/* import all usrloc functions */
		bind_usrloc = (bind_usrloc_t)find_export("ul_bind_usrloc", 1, 0);
		if(!bind_usrloc) {
			LM_ERR("can't bind usrloc\n");
			goto error;
		}
		if(bind_usrloc(&(cpl_fct.ulb)) < 0) {
			LM_ERR("importing usrloc failed\n");
			goto error;
		}
		/* convert lookup_domain from char* to udomain_t* pointer */
		if(cpl_fct.ulb.register_udomain(lookup_domain, &cpl_env.lu_domain)
				< 0) {
			LM_ERR("failed to register domain <%s>\n", lookup_domain);
			goto error;
		}
	} else {
		LM_NOTICE("no lookup_domain given -> disable lookup node\n");
	}

	/* build a pipe for sending commands to aux process */
	if(pipe(cpl_env.cmd_pipe) == -1) {
		LM_CRIT("cannot create command pipe: %s!\n", strerror(errno));
		goto error;
	}
	/* set the writing non blocking */
	if((val = fcntl(cpl_env.cmd_pipe[1], F_GETFL, 0)) < 0) {
		LM_ERR("getting flags from pipe[1] failed: fcntl said %s!\n",
				strerror(errno));
		goto error;
	}
	if(fcntl(cpl_env.cmd_pipe[1], F_SETFL, val | O_NONBLOCK)) {
		LM_ERR("setting flags to pipe[1] failed: fcntl said %s!\n",
				strerror(errno));
		goto error;
	}

	/* init the CPL parser */
	if(init_CPL_parser(dtd_file) != 1) {
		LM_ERR("init_CPL_parser failed!\n");
		goto error;
	}

	/* make a copy of the original TZ env. variable */
	ptr = getenv("TZ");
	cpl_env.orig_tz.len = 3 /*"TZ="*/ + (ptr ? (strlen(ptr) + 1) : 0);
	if((cpl_env.orig_tz.s = shm_malloc(cpl_env.orig_tz.len)) == 0) {
		SHM_MEM_ERROR_FMT("for saving TZ!\n");
		goto error;
	}
	memcpy(cpl_env.orig_tz.s, "TZ=", 3);
	if(ptr)
		strcpy(cpl_env.orig_tz.s + 3, ptr);

	/* convert realm_prefix from string null terminated to str */
	if(cpl_env.realm_prefix.s) {
		/* convert the realm_prefix to lower cases */
		strlower(&cpl_env.realm_prefix);
	}

	/* add space for one extra process */
	register_procs(1);
	/* add child to update local config framework structures */
	cfg_register_child(1);

	return 0;
error:
	return -1;
}


static int cpl_child_init(int rank)
{
	int pid;

	if(rank == PROC_MAIN) {
		pid = fork_process(PROC_RPC, "CPL Aux", 1);
		if(pid < 0)
			return -1; /* error */
		if(pid == 0) {
			/* child */
			/* initialize the config framework */
			if(cfg_child_init())
				return -1;

			cpl_process(1);
		}
	}

	if(rank == PROC_INIT || rank == PROC_MAIN || rank == PROC_TCP_MAIN)
		return 0; /* do nothing for the main process */

	return cpl_db_init(&db_url, &db_table);
}


static void cpl_process(int rank)
{
	cpl_aux_process(cpl_env.cmd_pipe[0], cpl_env.log_dir);
	exit(-1);
}


static void cpl_exit(void)
{
	/* free the TZ orig */
	if(cpl_env.orig_tz.s)
		shm_free(cpl_env.orig_tz.s);
}


static inline int build_user_AOR(str *username, str *domain, str *uh, int sip)
{
	unsigned char do_strip;
	char *p;
	int i;

	/* calculate the len (without terminating \0) */
	uh->len = 4 * (sip != 0) + username->len;
	do_strip = 0;

	if(sip || cpl_env.use_domain) {
		/* do we need to strip realm prefix? */
		if(cpl_env.realm_prefix.len && cpl_env.realm_prefix.len < domain->len) {
			for(i = cpl_env.realm_prefix.len - 1; i >= 0; i--)
				if(cpl_env.realm_prefix.s[i] != tolower(domain->s[i]))
					break;
			if(i == -1)
				do_strip = 1;
		}
		uh->len += 1 + domain->len - do_strip * cpl_env.realm_prefix.len;
	}

	uh->s = (char *)shm_malloc(uh->len + 1);
	if(!uh->s) {
		SHM_MEM_ERROR;
		return -1;
	}

	/* build user@host */
	p = uh->s;
	if(sip) {
		memcpy(uh->s, "sip:", 4);
		p += 4;
	}
	/* user part */
	if(cpl_env.case_sensitive) {
		memcpy(p, username->s, username->len);
		p += username->len;
	} else {
		for(i = 0; i < username->len; i++)
			*(p++) = tolower(username->s[i]);
	}
	if(sip || cpl_env.use_domain) {
		*(p++) = '@';
		/* host part in lower cases */
		for(i = do_strip * cpl_env.realm_prefix.len; i < domain->len; i++)
			*(p++) = tolower(domain->s[i]);
	}
	*(p++) = 0;

	/* sanity check */
	if(p - uh->s != uh->len + 1) {
		LM_CRIT("buffer overflow l=%d,w=%ld\n", uh->len, (long)(p - uh->s));
		return -1;
	}
	return 0;
}


static inline int get_dest_user(struct sip_msg *msg, str *username, str *domain)
{
	struct sip_uri uri;

	/*  get the user_name from new_uri/RURI/To */
	LM_DBG("trying to get user from new_uri\n");
	if(!msg->new_uri.s || parse_uri(msg->new_uri.s, msg->new_uri.len, &uri) < 0
			|| !uri.user.len) {
		LM_DBG("trying to get user from R_uri\n");
		if(parse_uri(msg->first_line.u.request.uri.s,
				   msg->first_line.u.request.uri.len,
				   &uri) == -1
				|| !uri.user.len) {
			LM_DBG("trying to get user from To\n");
			if((!msg->to
					   && ((parse_headers(msg, HDR_TO_F, 0) == -1) || !msg->to))
					|| parse_uri(get_to(msg)->uri.s, get_to(msg)->uri.len, &uri)
							   < 0
					|| !uri.user.len) {
				LM_ERR("unable to extract user name from RURI or To header!\n");
				return -1;
			}
		}
	}
	*username = uri.user;
	*domain = uri.host;
	return 0;
}


static inline int get_orig_user(struct sip_msg *msg, str *username, str *domain)
{
	struct to_body *from;
	struct sip_uri uri;

	/* if it's outgoing -> get the user_name from From */
	/* parsing from header */
	LM_DBG("trying to get user from From\n");
	if(parse_from_header(msg) == -1) {
		LM_ERR("unable to extract URI from FROM header\n");
		return -1;
	}
	from = (struct to_body *)msg->from->parsed;
	/* parse the extracted uri from From */
	if(parse_uri(from->uri.s, from->uri.len, &uri) || !uri.user.len) {
		LM_ERR("unable to extract user name from URI (From header)\n");
		return -1;
	}
	*username = uri.user;
	*domain = uri.host;
	return 0;
}


/* Params:
 *   str1 - as unsigned int - can be CPL_RUN_INCOMING or CPL_RUN_OUTGOING
 *   str2 - as unsigned int - flags regarding state(less)|(ful)
 *   str3 - URI in SPVE structure
 */
static int cpl_invoke_script3(
		struct sip_msg *msg, char *str1, char *str2, char *str3)
{
	struct cpl_interpreter *cpl_intr;
	str username = {0, 0};
	str domain = {0, 0};
	str uri = {0, 0};
	sip_uri_t puri;
	str loc;
	str script;

	/* get the user_name */
	if(str3 == NULL) {
		if(((unsigned long)str1) & CPL_RUN_INCOMING) {
			/* if it's incoming -> get the destination user name */
			if(get_dest_user(msg, &username, &domain) == -1)
				goto error0;
		} else {
			/* if it's outgoing -> get the origin user name */
			if(get_orig_user(msg, &username, &domain) == -1)
				goto error0;
		}
	} else {
		if(fixup_get_svalue(msg, (gparam_p)str3, &uri) != 0) {
			LM_ERR("invalid uri parameter");
			goto error0;
		}
		if(parse_uri(uri.s, uri.len, &puri) || !puri.user.len) {
			LM_ERR("unable to extract user name from URI param\n");
			return -1;
		}
		username = puri.user;
		domain = puri.host;
	}

	/* get the script for this user */
	if(get_user_script(&username, cpl_env.use_domain ? &domain : 0, &script,
			   &cpl_bin_col)
			== -1)
		goto error0;

	/* has the user a non-empty script? if not, return normally, allowing the
	 * script execution to continue */
	if(!script.s || !script.len)
		return 1;

	/* build a new script interpreter */
	if((cpl_intr = new_cpl_interpreter(msg, &script)) == 0)
		goto error1;
	/* set the flags */
	cpl_intr->flags =
			(unsigned int)((unsigned long)str1) | ((unsigned long)str2);
	/* build user AOR */
	if(build_user_AOR(&username, &domain, &(cpl_intr->user), 0) != 0)
		goto error2;
	/* for OUTGOING we need also the destination user for init. with him
	 * the location set */
	if(((unsigned long)str1) & CPL_RUN_OUTGOING) {
		/* build user initial location -> get the destination user name */
		if(get_dest_user(msg, &username, &domain) == -1)
			goto error2;
		if(build_user_AOR(&username, &domain, &loc, 1) != 0)
			goto error2;
		if(add_location(&(cpl_intr->loc_set), &loc, 0, 10, 0 /*no dup*/) == -1)
			goto error2;
	}

	/* run the script */
	switch(cpl_run_script(cpl_intr)) {
		case SCRIPT_DEFAULT:
			free_cpl_interpreter(cpl_intr);
			return 1; /* execution of ser's script will continue */
		case SCRIPT_END:
			free_cpl_interpreter(cpl_intr);
		case SCRIPT_TO_BE_CONTINUED:
			return 0; /* break the SER script */
		case SCRIPT_RUN_ERROR:
		case SCRIPT_FORMAT_ERROR:
			goto error2;
	}

	return 1;
error2:
	free_cpl_interpreter(cpl_intr);
	return -1;
error1:
	shm_free(script.s);
error0:
	return -1;
}

/* Params:
 *   str1 - as unsigned int - can be CPL_RUN_INCOMING or CPL_RUN_OUTGOING
 *   str2 - as unsigned int - flags regarding state(less)|(ful)
 */
static int cpl_invoke_script(struct sip_msg *msg, char *str1, char *str2)
{
	return cpl_invoke_script3(msg, str1, str2, NULL);
}


#define CPL_SCRIPT "script"
#define CPL_SCRIPT_LEN (sizeof(CPL_SCRIPT) - 1)
#define ACTION_PARAM "action"
#define ACTION_PARAM_LEN (sizeof(ACTION_PARAM) - 1)
#define STORE_ACTION "store"
#define STORE_ACTION_LEN (sizeof(STORE_ACTION) - 1)
#define REMOVE_ACTION "remove"
#define REMOVE_ACTION_LEN (sizeof(REMOVE_ACTION) - 1)

#define REMOVE_SCRIPT 0xcaca
#define STORE_SCRIPT 0xbebe

#define CONTENT_TYPE_HDR ("Content-Type: application/cpl-xml" CRLF)
#define CONTENT_TYPE_HDR_LEN (sizeof(CONTENT_TYPE_HDR) - 1)

struct cpl_error
{
	int err_code;
	str err_msg;
};

static struct cpl_error bad_req = {400, str_init("Bad request")};
static struct cpl_error intern_err = {500, str_init("Internal server error")};
static struct cpl_error bad_cpl = {400, str_init("Bad CPL script")};

static struct cpl_error *cpl_err = &bad_req;


static inline int do_script_action(struct sip_msg *msg, int action)
{
	str body = {0, 0};
	str bin = {0, 0};
	str log = {0, 0};
	str username = {0, 0};
	str domain = {0, 0};

	/* content-length (if present) */
	if(!msg->content_length
			&& ((parse_headers(msg, HDR_CONTENTLENGTH_F, 0) == -1)
					|| !msg->content_length)) {
		LM_ERR("no Content-Length hdr found!\n");
		goto error;
	}
	body.len = get_content_length(msg);

	/* get the user name */
	if(get_dest_user(msg, &username, &domain) == -1)
		goto error;

	/* we have the script and the user */
	switch(action) {
		case STORE_SCRIPT:
			/* check the len -> it must not be 0 */
			if(body.len == 0) {
				LM_ERR("0 content-len found for store\n");
				goto error_1;
			}
			/* get the message's body */
			body.s = get_body(msg);
			if(body.s == 0) {
				LM_ERR("cannot extract body from msg!\n");
				goto error_1;
			}
			/* now compile the script and place it into database */
			/* get the binary coding for the XML file */
			if(encodeCPL(&body, &bin, &log) != 1) {
				cpl_err = &bad_cpl;
				goto error_1;
			}

			/* write both the XML and binary formats into database */
			if(write_to_db(
					   &username, cpl_env.use_domain ? &domain : 0, &body, &bin)
					!= 1) {
				cpl_err = &intern_err;
				goto error_1;
			}
			break;
		case REMOVE_SCRIPT:
			/* check the len -> it must be 0 */
			if(body.len != 0) {
				LM_ERR("non-0 content-len found for remove\n");
				goto error_1;
			}
			/* remove the script for the user */
			if(rmv_from_db(&username, cpl_env.use_domain ? &domain : 0) != 1) {
				cpl_err = &intern_err;
				goto error_1;
			}
			break;
	}

	if(log.s)
		pkg_free(log.s);
	return 0;
error_1:
	if(log.s)
		pkg_free(log.s);
error:
	return -1;
}


static inline int do_script_download(struct sip_msg *msg)
{
	str username = {0, 0};
	str domain = {0, 0};
	str script = {0, 0};

	/* get the destination user name */
	if(get_dest_user(msg, &username, &domain) != 0)
		goto error;

	/* get the user's xml script from the database */
	if(get_user_script(&username, cpl_env.use_domain ? &domain : 0, &script,
			   &cpl_xml_col)
			== -1)
		goto error;

	/* add a lump with content-type hdr */
	if(add_lump_rpl(msg, CONTENT_TYPE_HDR, CONTENT_TYPE_HDR_LEN, LUMP_RPL_HDR)
			== 0) {
		LM_ERR("cannot build hdr lump\n");
		cpl_err = &intern_err;
		goto error;
	}

	if(script.s != 0) {
		/* user has a script -> add a body lump */
		if(add_lump_rpl(msg, script.s, script.len, LUMP_RPL_BODY) == 0) {
			LM_ERR("cannot build body lump\n");
			cpl_err = &intern_err;
			goto error;
		}
		/* build_lump_rpl duplicates the added text, so free the original */
		shm_free(script.s);
	}

	return 0;
error:
	if(script.s)
		shm_free(script.s);
	return -1;
}


static int w_process_register(struct sip_msg *msg, char *str, char *str2)
{
	return cpl_process_register(msg, 0);
}


static int w_process_register_norpl(struct sip_msg *msg, char *str, char *str2)
{
	return cpl_process_register(msg, 1);
}


static int cpl_process_register(struct sip_msg *msg, int no_rpl)
{
	struct disposition *disp;
	struct disposition_param *param;
	int ret;
	int mime;
	int *mimes;

	/* make sure that is a REGISTER ??? */

	/* here should be the CONTACT- hack */

	/* is there a CONTENT-TYPE hdr ? */
	mime = parse_content_type_hdr(msg);
	if(mime == -1)
		goto error;

	/* check the mime type */
	LM_DBG("Content-Type mime found %u, %u\n", mime >> 16, mime & 0x00ff);
	if(mime && mime == (TYPE_APPLICATION << 16) + SUBTYPE_CPLXML) {
		/* can be an upload or remove -> check for the content-purpose and
		 * content-action headers */
		LM_DBG("carrying CPL -> look at Content-Disposition\n");
		if(parse_content_disposition(msg) != 0) {
			LM_ERR("Content-Disposition missing or corrupted\n");
			goto error;
		}
		disp = get_content_disposition(msg);
		print_disposition(disp); /* just for DEBUG */
		/* check if the type of disposition is SCRIPT */
		if(disp->type.len != CPL_SCRIPT_LEN
				|| strncasecmp(disp->type.s, CPL_SCRIPT, CPL_SCRIPT_LEN)) {
			LM_ERR("bogus message - Content-Type"
				   "says CPL_SCRIPT, but Content-Disposition something else\n");
			goto error;
		}
		/* disposition type is OK -> look for action parameter */
		for(param = disp->params; param; param = param->next) {
			if(param->name.len == ACTION_PARAM_LEN
					&& !strncasecmp(
							param->name.s, ACTION_PARAM, ACTION_PARAM_LEN))
				break;
		}
		if(param == 0) {
			LM_ERR("bogus message - "
				   "Content-Disposition has no action param\n");
			goto error;
		}
		/* action param found -> check its value: store or remove */
		if(param->body.len == STORE_ACTION_LEN
				&& !strncasecmp(
						param->body.s, STORE_ACTION, STORE_ACTION_LEN)) {
			/* it's a store action -> get the script from body message and store
			 * it into database (CPL and BINARY format) */
			if(do_script_action(msg, STORE_SCRIPT) == -1)
				goto error;
		} else if(param->body.len == REMOVE_ACTION_LEN
				  && !strncasecmp(
						  param->body.s, REMOVE_ACTION, REMOVE_ACTION_LEN)) {
			/* it's a remove action -> remove the script from database */
			if(do_script_action(msg, REMOVE_SCRIPT) == -1)
				goto error;
		} else {
			LM_ERR("unknown action <%.*s>\n", param->body.len, param->body.s);
			goto error;
		}

		/* do I have to send to reply? */
		if(no_rpl)
			goto resume_script;

		/* send a 200 OK reply back */
		cpl_fct.slb.freply(msg, 200, &cpl_ok_rpl);
		/* I send the reply and I don't want to return to script execution, so
		 * I return 0 to do break */
		goto stop_script;
	}

	/* is there an ACCEPT hdr ? */
	if((ret = parse_accept_hdr(msg)) < 0)
		goto error;
	if(ret == 0 || (mimes = get_accept(msg)) == 0)
		/* accept header not present or no mimes found */
		goto resume_script;

	/* looks if the REGISTER accepts cpl-xml or * */
	while(*mimes) {
		LM_DBG("accept mime found %u, %u\n", (*mimes) >> 16, (*mimes) & 0x00ff);
		if(*mimes == (TYPE_ALL << 16) + SUBTYPE_ALL
				|| *mimes == (TYPE_APPLICATION << 16) + SUBTYPE_CPLXML)
			break;
		mimes++;
	}
	if(*mimes == 0)
		/* no accept mime that matched cpl */
		goto resume_script;

	/* get the user name from msg, retrieve the script from db
	 * and appended to reply */
	if(do_script_download(msg) == -1)
		goto error;

	/* do I have to send to reply? */
	if(no_rpl)
		goto resume_script;

	/* send a 200 OK reply back */
	cpl_fct.slb.freply(msg, 200, &cpl_ok_rpl);

stop_script:
	return 0;
resume_script:
	return 1;
error:
	/* send an error reply back */
	cpl_fct.slb.freply(msg, cpl_err->err_code, &cpl_err->err_msg);
	/* I don't want to return to script execution, so I return 0 to do break */
	return 0;
}
