/* * Copyright (C) 1999-2002 Inter7 Internet Technologies, Inc. * * This program 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. * * This program 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 */#include <pwd.h>#include <unistd.h>#include <stdio.h>#include <stdlib.h>#include <sqlda.h>#include <sqlcpr.h>#include <sqlca.h>#include <sys/types.h>#include <string.h>#include <time.h>#include "config.h"#include "vpopmail.h"#include "vauth.h"#include "voracle.h"#include "vlimits.h"#ifndef SQL_CRSR#define SQL_CRSR  struct sql_cursor  {    unsigned int curocn;    void *ptr1;    void *ptr2;    unsigned int magic;  };  typedef struct sql_cursor sql_cursor;  typedef struct sql_cursor SQL_CURSOR;#endif /* SQL_CRSR *//* SQLLIB Prototypes */extern int sqlcxt (/*_ void **, unsigned int *,                   struct sqlexd *, struct sqlcxp * _*/);extern int sqlcx2t(/*_ void **, unsigned int ,                   struct sqlexd *, struct sqlcxp * _*/);extern int sqlbuft(/*_ void **, char * _*/);extern int sqlgs2t(/*_ void **, char * _*/);extern int sqlorat(/*_ void **, unsigned int *, void * _*/);typedef struct { unsigned short len; unsigned char arr[1]; } VARCHAR;static int update_open = 0;#define SQL_BUF_SIZE 2048EXEC SQL BEGIN DECLARE SECTION;  char SqlBufRead[SQL_BUF_SIZE];  char SqlBufUpdate[SQL_BUF_SIZE];  char SqlBufCreate[SQL_BUF_SIZE];  time_t Vauthtime;  char Vip_addr[18];  char Vpw_name[32];  char Vpw_domain[64];  char Vpw_passwd[40];  uid_t Vpw_uid;  uid_t Vpw_gid;  char Vpw_gecos[48];  char Vpw_dir[160];  char Vpw_shell[20];#ifdef CLEAR_PASS  char Vpw_clear_passwd[16];#endif#ifdef VALIAS  char Vpw_alias[32];  VARCHAR Vpw_alias_line[255];#endif  int cur_users;  int level_cur;  int level_max;  int level_start0;  int level_start1;  int level_start2;  int level_end0;  int level_end1;  int level_end2;  int level_mod0;  int level_mod1;  int level_mod2;  int level_index0;  int level_index1;  int level_index2;  char the_dir[160];EXEC SQL END DECLARE SECTION;#define UNAME_LEN 120#define PWD_LEN 16VARCHAR username[UNAME_LEN];VARCHAR password[PWD_LEN];#define SMALL_BUFF 200char IUser[SMALL_BUFF];char IPass[SMALL_BUFF];char IGecos[SMALL_BUFF];char IDir[SMALL_BUFF];char IShell[SMALL_BUFF];char IClearPass[SMALL_BUFF];void vcreate_dir_control(char *domain);void vcreate_vlog_table();#ifdef POP_AUTH_OPEN_RELAYvoid vcreate_relay_table();#endif#ifdef VALIASvoid vcreate_valias_table();#endif#ifdef ENABLE_AUTH_LOGGINGvoid vcreate_lastauth_table();#endifint vdel_limits( char *domain );void fix_name(char *name);void sql_error(msg)    char *msg;{/*    printf("\n%s", msg);    printf("\n%.*s\n",        sqlca.sqlerrm.sqlerrml, sqlca.sqlerrm.sqlerrmc);    printf("in \"%.*s...\"\n",        oraca.orastxt.orastxtl, oraca.orastxt.orastxtc);    printf("on line %d of %.*s.\n\n",        oraca.oraslnr, oraca.orasfnm.orasfnml,        oraca.orasfnm.orasfnmc);*//* Disable ORACLE error checking to avoid an infinite loop * should another error occur within this routine. */    EXEC SQL WHENEVER SQLERROR CONTINUE;/* Roll back any pending changes and * disconnect from Oracle.    EXEC SQL ROLLBACK RELEASE;    exit(EXIT_FAILURE);*/}/*  * Open a connection to oracle for updates */int vauth_open_update(){    if ( update_open != 0 ) return(0);    update_open = 1;    putenv(ORACLE_HOME);    sprintf((char *) username.arr, "%s@%s", ORACLE_USER, ORACLE_SERVICE);    username.len = (unsigned short)strlen((char *) username.arr);    strcpy((char *) password.arr, ORACLE_PASSWD);    password.len = (unsigned short) strlen((char *) password.arr);    EXEC SQL WHENEVER SQLERROR DO sql_error("Erro em ORACLE--\n");    EXEC SQL CONNECT :username IDENTIFIED by :password;    verrori = 0;    return(0);}int voracle_create_all(){ int err;  if ( (err=vauth_open_update()) != 0 ) return(err);  snprintf(SqlBufCreate, SQL_BUF_SIZE, "create table dir_control ( %s )",        DIR_CONTROL_TABLE_LAYOUT);  EXEC SQL PREPARE S FROM :SqlBufCreate;  EXEC SQL EXECUTE S;  EXEC SQL COMMIT;#ifdef POP_AUTH_OPEN_RELAY  vcreate_relay_table();#endif#ifdef ENABLE_AUTH_LOGGING  vcreate_lastauth_table();#endif#ifdef VALIAS  vcreate_valias_table(); #endif#ifdef IP_ALIAS_DOMAINS  vcreate_ip_map_table();#endif  return(0);}int voracle_drop_all(){ int err;        if ( (err=vauth_open_update()) != 0 ) return(err);    snprintf(SqlBufUpdate,SQL_BUF_SIZE, "drop table vpopmail");    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;    snprintf(SqlBufUpdate,SQL_BUF_SIZE, "drop table dir_control");    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;    snprintf(SqlBufUpdate,SQL_BUF_SIZE, "drop table relay");    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;    snprintf(SqlBufUpdate,SQL_BUF_SIZE, "drop table ip_alias_map");    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;    snprintf(SqlBufUpdate,SQL_BUF_SIZE, "drop table lastauth");    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;    snprintf(SqlBufUpdate,SQL_BUF_SIZE, "drop table valias");    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;  return(0);}int vauth_adddomain( char *domain ){ char *tmpstr = NULL; int err;        if ( (err=vauth_open_update()) != 0 ) return(err);    vset_default_domain( domain );#ifndef MANY_DOMAINS    tmpstr = vauth_munch_domain( domain );#else    tmpstr = ORACLE_DEFAULT_TABLE;#endif    snprintf(SqlBufUpdate,SQL_BUF_SIZE,        "create table %s ( %s )",tmpstr,TABLE_LAYOUT);    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;    voracle_create_all();    sprintf(SqlBufUpdate, "insert into dir_control ( \domain, cur_users, \level_cur, level_max, \level_start0, level_start1, level_start2, \level_end0, level_end1, level_end2, \level_mod0, level_mod1, level_mod2, \level_index0, level_index1, level_index2, the_dir ) values ( \'%s', '0', \'0', %d, \'0', '0', '0', \'%d', '%d', '%d', \'0', '2', '4', \'0', '0', '0', \'')",        domain, MAX_DIR_LEVELS, MAX_DIR_LIST-1, MAX_DIR_LIST-1, MAX_DIR_LIST-1);    printf("dir control insert:  %s\n", SqlBufUpdate);    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;    return(0);}int vauth_adduser(char *user, char *domain, char *pass, char *gecos,     char *dir, int apop ){ char *domstr; char dom_dir[156]; uid_t uid;  gid_t gid; char dirbuf[200]; char quota[30]; char Crypted[100]; int err;        if ( (err=vauth_open_update()) != 0 ) return(err);    vset_default_domain( domain );    strncpy( quota, "NOQUOTA", 30 );#ifndef MANY_DOMAINS    domstr = vauth_munch_domain( domain );#else    domstr = ORACLE_DEFAULT_TABLE;#endif    if ( domain == NULL || domain[0] == 0 ) {        domstr = ORACLE_LARGE_USERS_TABLE;    }    if ( strlen(domain) <= 0 ) {        if ( strlen(dir) > 0 ) {            snprintf(dirbuf, SQL_BUF_SIZE,                 "%s/users/%s/%s", VPOPMAILDIR, dir, user);        } else {            snprintf(dirbuf, SQL_BUF_SIZE, "%s/users/%s", VPOPMAILDIR, user);        }    } else {        vget_assign(domain, dom_dir, 156, &uid, &gid );        if ( strlen(dir) > 0 ) {            snprintf(dirbuf,SQL_BUF_SIZE, "%s/%s/%s", dom_dir, dir, user);        } else {            snprintf(dirbuf, SQL_BUF_SIZE, "%s/%s", dom_dir, user);        }    }    if ( pass[0] != 0 ) {        mkpasswd3(pass,Crypted, 100);    } else {        Crypted[0] = 0;    }    qnprintf( SqlBufUpdate, SQL_BUF_SIZE, INSERT,       domstr, user, #ifdef MANY_DOMAINS      domain,#endif      Crypted, apop, gecos, dirbuf, quota#ifdef CLEAR_PASS,pass#endif);printf("add user: %s\n", SqlBufUpdate);    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;    sprintf( SqlBufUpdate,       "insert into lastauth ( pw_user, pw_domain, remote_ip, timestamp ) values \('%s', '%s', '0.0.0.0', 0 )", user, domain);    EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;    return(0);}struct vqpasswd *vauth_getpw(char *user, char *domain){ char *domstr; static struct vqpasswd vpw; static char in_domain[156]; int err; uid_t myuid; uid_t uid; gid_t gid; struct vlimits limits;    if ( vget_assign(domain,NULL,156,&uid,&gid) == NULL ) return(NULL);    myuid = geteuid();    if ( myuid != 0 && myuid != uid ) return(NULL);    verrori = 0;    if ( (err=vauth_open_update()) != 0 ) {        verrori = err;        return(NULL);    }    lowerit(user);    lowerit(domain);    memset(in_domain,0,156);    strncpy(in_domain, domain, 155);    vset_default_domain( in_domain );#ifndef MANY_DOMAINS    domstr = vauth_munch_domain( in_domain );#else    domstr = ORACLE_DEFAULT_TABLE; #endif    if ( domstr == NULL || domstr[0] == 0 ) domstr = ORACLE_LARGE_USERS_TABLE;    qnprintf(SqlBufRead, SQL_BUF_SIZE, USER_SELECT, domstr, user#ifdef MANY_DOMAINS, in_domain#endif);/*printf("getpw: %s\n", SqlBufRead);*/    EXEC SQL PREPARE S FROM :SqlBufRead;    EXEC SQL DECLARE C CURSOR FOR S;    EXEC SQL OPEN C;    EXEC SQL FETCH C INTO :Vpw_name, :Vpw_passwd, :Vpw_uid,     :Vpw_gid, :Vpw_gecos, :Vpw_dir, :Vpw_shell, :Vpw_clear_passwd;/*printf("sqlcode = %d\n", sqlca.sqlcode);*/    if (sqlca.sqlcode == 1403 ||         sqlca.sqlcode == -1002 ) {      EXEC SQL CLOSE C;      EXEC SQL COMMIT;      return(NULL);    }/*printf("found it\n");*/    vpw.pw_name   = Vpw_name;    fix_name(vpw.pw_name);    vpw.pw_passwd = Vpw_passwd;    fix_name(vpw.pw_passwd);    vpw.pw_uid    = Vpw_uid;    vpw.pw_gid    = Vpw_gid;    vpw.pw_gecos  = Vpw_gecos;    fix_name(vpw.pw_gecos);    vpw.pw_dir    = Vpw_dir;    fix_name(vpw.pw_dir);    vpw.pw_shell  = Vpw_shell;    fix_name(vpw.pw_shell);#ifdef CLEAR_PASS    vpw.pw_clear_passwd  = Vpw_clear_passwd;    fix_name(vpw.pw_clear_passwd);#endif    EXEC SQL CLOSE C;    EXEC SQL COMMIT;    if ((! vpw.pw_gid && V_OVERRIDE)      && (vget_limits (in_domain, &limits) == 0)) {        vpw.pw_flags = vpw.pw_gid | vlimits_get_flag_mask (&limits);    } else vpw.pw_flags = vpw.pw_gid;    return(&vpw);}int vauth_deldomain( char *domain ){ char *tmpstr; int err;        if ( (err=vauth_open_update()) != 0 ) return(err);    vset_default_domain( domain );#ifndef MANY_DOMAINS    tmpstr = vauth_munch_domain( domain );    snprintf( SqlBufUpdate, SQL_BUF_SIZE, "drop table %s", tmpstr);#else    tmpstr = ORACLE_DEFAULT_TABLE;    qnprintf( SqlBufUpdate, SQL_BUF_SIZE, "delete from %s where pw_domain = '%s'",        tmpstr, domain );#endif     EXEC SQL PREPARE S FROM :SqlBufUpdate;    EXEC SQL EXECUTE S;    EXEC SQL COMMIT;#ifdef VALIAS     valias_delete_domain( domain);#endif