voracle.pc

相当优秀的 UNIX 进程管理工具

/*
 * 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 2048
EXEC 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 16

VARCHAR username[UNAME_LEN];
VARCHAR password[PWD_LEN];


#define SMALL_BUFF 200
char 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_RELAY
void vcreate_relay_table();
#endif

#ifdef VALIAS
void vcreate_valias_table();
#endif

#ifdef ENABLE_AUTH_LOGGING
void vcreate_lastauth_table();
#endif

int 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