/*
* $Id: cpl_loader.c,v 1.11 2004/12/08 20:43:23 bogdan Exp $
*
* Copyright (C) 2001-2003 FhG Fokus
*
* This file is part of ser, a free SIP server.
*
* ser 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
*
* For a license to use the ser software under conditions
* other than those described here, or to purchase support for this
* software, please contact iptel.org by e-mail at the following addresses:
* info@iptel.org
*
* ser 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
*
* History:
* -------
* 2003-08-21: cpl_remove() added (bogdan)
* 2003-06-24: file created (bogdan)
*/
#include <stdio.h>
#include <sys/uio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/uio.h>
#include <errno.h>
#include <string.h>
#include <ctype.h>
#include "../../str.h"
#include "../../dprint.h"
#include "../../fifo_server.h"
#include "../../mem/mem.h"
#include "../../mem/shm_mem.h"
#include "cpl_db.h"
#include "cpl_parser.h"
#include "cpl_loader.h"
#define MAX_STATIC_BUF 256
extern db_con_t* db_hdl;
#if 0
/* debug function -> write into a file the content of a str struct. */
int write_to_file(char *filename, str *buf)
{
int fd;
int ret;
fd = open(filename,O_WRONLY|O_CREAT|O_TRUNC,0644);
if (!fd) {
LOG(L_ERR,"ERROR:cpl-c:write_to_file: cannot open file : %s\n",
strerror(errno));
goto error;
}
while ( (ret=write( fd, buf->s, buf->len))!=buf->len) {
if ((ret==-1 && errno!=EINTR)|| ret!=-1) {
LOG(L_ERR,"ERROR:cpl-c:write_to_file:cannot write to file:"
"%s write_ret=%d\n",strerror(errno), ret );
goto error;
}
}
close(fd);
return 0;
error:
return -1;
}
#endif
/* Loads a file into a buffer; first the file length will be determined for
* allocated an exact buffer len for storing the file content into.
* Returns: 1 - success
* -1 - error
*/
int load_file( char *filename, str *xml)
{
int n;
int offset;
int fd;
xml->s = 0;
xml->len = 0;
/* open the file for reading */
fd = open(filename,O_RDONLY);
if (fd==-1) {
LOG(L_ERR,"ERROR:cpl-c:load_file: cannot open file for reading:"
" %s\n",strerror(errno));
goto error;
}
/* get the file length */
if ( (xml->len=lseek(fd,0,SEEK_END))==-1) {
LOG(L_ERR,"ERROR:cpl-c:load_file: cannot get file length (lseek):"
" %s\n", strerror(errno));
goto error;
}
DBG("DEBUG:cpl-c:load_file: file size = %d\n",xml->len);
if ( lseek(fd,0,SEEK_SET)==-1 ) {
LOG(L_ERR,"ERROR:cpl-c:load_file: cannot go to beginning (lseek):"
" %s\n",strerror(errno));
goto error;
}
/* get some memory */
xml->s = (char*)pkg_malloc( xml->len+1/*null terminated*/ );
if (!xml->s) {
LOG(L_ERR,"ERROR:cpl-c:load_file: no more free pkg memory\n");
goto error;
}
/*start reading */
offset = 0;
while ( offset<xml->len ) {
n=read( fd, xml->s+offset, xml->len-offset);
if (n==-1) {
if (errno!=EINTR) {
LOG(L_ERR,"ERROR:cpl-c:load_file: read failed:"
" %s\n", strerror(errno));
goto error;
}
} else {
if (n==0) break;
offset += n;
}
}
if (xml->len!=offset) {
LOG(L_ERR,"ERROR:cpl-c:load_file: couldn't read all file!\n");
goto error;
}
xml->s[xml->len] = 0;
close(fd);
return 1;
error:
if (fd!=-1) close(fd);
if (xml->s) pkg_free( xml->s);
return -1;
}
/* Writes an array of texts into the given response file.
* Accepts also empty texts, case in which it will be created an empty
* response file.
*/
void write_to_file( char *file, str *txt, int n )
{
int fd;
/* open file for write */
fd = open( file, O_WRONLY|O_CREAT|O_TRUNC/*|O_NOFOLLOW*/, 0600 );
if (fd==-1) {
LOG(L_ERR,"ERROR:cpl-c:write_to_file: cannot open response file "
"<%s>: %s\n", file, strerror(errno));
return;
}
/* write the txt, if any */
if (n>0) {
again:
if ( writev( fd, (struct iovec*)txt, n)==-1) {
if (errno==EINTR) {
goto again;
} else {
LOG(L_ERR,"ERROR:cpl-c:write_logs_to_file: writev failed: "
"%s\n", strerror(errno) );
}
}
}
/* close the file*/
close( fd );
return;
}
static inline int check_userhost( char *p, char *end)
{
char *p1;
int dot;
/* parse user name */
p1 = p;
while (p<end && (isalnum((int)*p) || *p=='-' || *p=='_' || *p=='.' ))
p++;
if (p==p1 || p==end || *p!='@')
return -1;
p++;
/* parse the host part */
dot = 1;
p1 = p;
while (p<end) {
if (*p=='.') {
if (dot) return -1; /* dot after dot */
dot = 1;
} else if (isalnum((int)*p) || *p=='-' || *p=='_' ) {
dot = 0;
} else {
return -1;
}
p++;
}
if (p1==p || dot)
return -1;
return 0;
}
/* Triggered by fifo server -> implements LOAD_CPL command
* Command format:
* -----------------------
* :LOAD_CPL:
* username
* cpl_filename
* <empty line>
* -----------------------
* For the given user, loads the XML cpl file, compile it into binary format
* and store both format into database
*/
#define FILE_LOAD_ERR "Error: Cannot read CPL file.\n"
#define DB_SAVE_ERR "Error: Cannot save CPL to database.\n"
#define USRHOST_ERR "Error: Bad user@host.\n"
int cpl_load( FILE *fifo_stream, char *response_file )
{
static char user[MAX_STATIC_BUF];
static char cpl_file[MAX_STATIC_BUF];
int user_len;
int cpl_file_len;
str xml = {0,0};
str bin = {0,0};
str enc_log = {0,0};
str logs[2];
DBG("DEBUG:cpl-c:cpl_load: \"LOAD_CPL\" FIFO command received!\n");
/* check the name of the response file */
if (response_file==0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_load: no reply file received from "
"FIFO command\n");
goto error;
}
/* first line must be the username */
if (read_line( user, MAX_STATIC_BUF-1 , fifo_stream, &user_len )!=1 ||
user_len<=0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_load: unable to read username from "
"FIFO command\n");
goto error;
}
user[user_len] = 0;
DBG("DEBUG:cpl_load: user@host=%.*s\n",user_len,user);
/* second line must be the cpl file */
if (read_line( cpl_file, MAX_STATIC_BUF-1,fifo_stream,&cpl_file_len)!=1 ||
cpl_file_len<=0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_load: unable to read cpl_file name from "
"FIFO command\n");
goto error;
}
cpl_file[cpl_file_len] = 0;
DBG("DEBUG:cpl-c:cpl_load: cpl file=%.*s\n",cpl_file_len,cpl_file);
/* check user+host */
if (check_userhost( user, user+user_len)!=0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_load: invalid user@host [%.*s]\n",
user_len,user);
logs[1].s = USRHOST_ERR;
logs[1].len = strlen( USRHOST_ERR );
goto error1;
}
/* load the xml file - this function will allocated a buff for the loading
* the cpl file and attach it to xml.s -> don't forget to free it! */
if (load_file( cpl_file, &xml)!=1) {
logs[1].s = FILE_LOAD_ERR;
logs[1].len = strlen( FILE_LOAD_ERR );
goto error1;
}
/* get the binary coding for the XML file */
if (encodeCPL( &xml, &bin, &enc_log)!=1) {
logs[1] = enc_log;
goto error1;
}
logs[1] = enc_log;
/* write both the XML and binary formats into database */
if (write_to_db(user, &xml, &bin)!=1) {
logs[1].s = DB_SAVE_ERR;
logs[1].len = strlen( DB_SAVE_ERR );
goto error1;
}
/* free the memory used for storing the cpl script in XML format */
pkg_free( xml.s );
/* everything was OK -> dump the logs into response file */
logs[0].s = "OK\n";
logs[0].len = 3;
write_to_file( response_file, logs, 2);
if (enc_log.s) pkg_free ( enc_log.s );
return 1;
error1:
logs[0].s = "ERROR\n";
logs[0].len = 6;
write_to_file( response_file, logs, 2);
if (enc_log.s) pkg_free ( enc_log.s );
if (xml.s) pkg_free ( xml.s );
error:
return -1;
}
/* Triggered by fifo server -> implements REMOVE_CPL command
* Command format:
* -----------------------
* :REMOVE_CPL:
* username
* <empty line>
* -----------------------
* For the given user, remove the entire database record
* (XML cpl and binary cpl); user with empty cpl scripts are not accepted
*/
#define DB_RMV_ERR "Error: Database remove failed.\n"
int cpl_remove( FILE *fifo_stream, char *response_file )
{
static char user[MAX_STATIC_BUF];
int user_len;
str logs[2];
DBG("DEBUG:cpl-c:cpl_remove: \"REMOVE_CPL\" FIFO command received!\n");
/* check the name of the response file */
if (response_file==0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_remove: no reply file received from "
"FIFO command\n");
goto error;
}
/* first line must be the username */
if (read_line( user, MAX_STATIC_BUF-1 , fifo_stream, &user_len )!=1 ||
user_len<=0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_remove: unable to read username from "
"FIFO command\n");
goto error;
}
user[user_len] = 0;
DBG("DEBUG:cpl-c:cpl_remove: user=%.*s\n",user_len,user);
/* check user+host */
if (check_userhost( user, user+user_len)!=0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_remove: invalid user@host [%.*s]\n",
user_len,user);
logs[1].s = USRHOST_ERR;
logs[1].len = strlen( USRHOST_ERR );
goto error1;
}
if (rmv_from_db(user)!=1) {
logs[1].s = DB_RMV_ERR;
logs[1].len = sizeof(DB_RMV_ERR);
goto error1;
}
logs[0].s = "OK\n";
logs[0].len = 3;
write_to_file( response_file, logs, 1);
return 1;
error1:
logs[0].s = "ERROR\n";
logs[0].len = 6;
write_to_file( response_file, logs, 2);
error:
return -1;
}
/* Triggered by fifo server -> implements GET_CPL command
* Command format:
* -----------------------
* :GET_CPL:
* username
* <empty line>
* -----------------------
* For the given user, return the CPL script in XML format
*/
#define DB_GET_ERR "Error: Database query failed.\n"
int cpl_get( FILE *fifo_stream, char *response_file )
{
static char user_s[MAX_STATIC_BUF];
str user = {user_s,0};
str script = {0,0};
str logs[2];
/* check the name of the response file */
if (response_file==0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_get: no reply file received from "
"FIFO command\n");
goto error;
}
/* first line must be the username */
if (read_line( user.s, MAX_STATIC_BUF-1 , fifo_stream, &user.len )!=1 ||
user.len<=0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_get: unable to read username from "
"FIFO command\n");
goto error;
}
DBG("DEBUG:cpl-c:cpl_get: user=%.*s\n",user.len,user.s);
/* check user+host */
if (check_userhost( user.s, user.s+user.len)!=0) {
LOG(L_ERR,"ERROR:cpl-c:cpl_load: invalid user@host [%.*s]\n",
user.len,user.s);
logs[1].s = USRHOST_ERR;
logs[1].len = strlen( USRHOST_ERR );
goto error1;
}
/* get the script for this user */
if (get_user_script(&user, &script, "cpl_xml")==-1) {
logs[1].s = DB_GET_ERR;
logs[1].len = strlen( DB_GET_ERR );
goto error1;
}
/* write the response into response file - even if script is null */
write_to_file( response_file, &script, !(script.len==0) );
if (script.s) shm_free( script.s );
return 1;
error1:
logs[0].s = "ERROR\n";
logs[0].len = 6;
write_to_file( response_file, logs, 2);
error:
return -1;
}
#undef MAX_STATIC_BUF
syntax highlighted by Code2HTML, v. 0.9.1