Skip to content

John McEleney / mailutils

Go to a project
Toggle navigation
Toggle navigation pinning
Commit 6d84a2bc 6d84a2bcdcfdb142acc08ce363fedd035b20715e by Sergey Poznyakoff
Options

Removed in favor of the general SQL interface

1 parent 272bea11
Inline Side-by-side
Showing 2 changed files with 0 additions and 610 deletions
/* GNU Mailutils -- a suite of utilities for electronic mail
Copyright (C) 2002, 2003 Free Software Foundation, Inc.
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2 of the License, or (at your option) any later version.
This library 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
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
#ifdef HAVE_CONFIG_H
# include <config.h>
#endif
#ifdef HAVE_MYSQL
#include <sql.h>
#include <mysql/mysql.h>
#define MFLAGS 0 /* Special user flags. It is safe to leave
this untouched */
int
mysql_auth_sql_by_name (struct mu_auth_data **return_data,
const void *key,
void *func_data ARG_UNUSED,
void *call_data ARG_UNUSED)
{
char *query_str = NULL;
MYSQL *m;
MYSQL_RES *res;
MYSQL_ROW row;
char *mailbox_name;
int rc;
if (!key)
{
errno = EINVAL;
return 1;
}
m = mysql_init (0);
if (!m)
return 1;
if (!mysql_real_connect (m,
mu_sql_host, mu_sql_user, mu_sql_passwd,
mu_sql_db, mu_sql_port,
mu_sql_socket, MFLAGS))
{
mu_error (_("MySQL: connect failed: %s"), mysql_error (m));
mysql_close (m);
return 1;
}
query_str = mu_sql_expand_query (mu_sql_getpwnam_query, key);
if (!query_str)
{
mysql_close (m);
return 1;
}
if (mysql_query (m, query_str) != 0)
{
mu_error (_("MySQL: query failed: %s"), mysql_error (m));
free (query_str);
mysql_close (m);
return 1;
}
free (query_str);
if ((res = mysql_store_result (m)) == NULL)
{
mu_error (_("MySQL: can't store result: %s"), mysql_error (m));
mysql_close (m);
return 1;
}
if ((row = mysql_fetch_row (res)) == NULL)
{
mu_error (_("MySQL: can't fetch row: %s"), mysql_error (m));
mysql_close (m);
return 1;
}
if (mysql_num_fields (res) == 7 && row[6])
mailbox_name = strdup (row[6]);
else
{
mailbox_name = malloc (strlen (mu_path_maildir) +
strlen (row[0]) + 1);
if (mailbox_name)
sprintf (mailbox_name, "%s%s", mu_path_maildir, row[0]);
}
if (mailbox_name)
rc = mu_auth_data_alloc (return_data,
row[0],
row[1],
atoi (row[2]),
atoi (row[3]),
"Mysql User",
row[4],
row[5],
mailbox_name,
1);
else
rc = 1;
free (mailbox_name);
mysql_free_result (res);
mysql_close (m);
return rc;
}
int
mysql_auth_sql_by_uid (struct mu_auth_data **return_data, void *key,
void *func_data ARG_UNUSED,
void *call_data ARG_UNUSED)
{
char *query_str = NULL;
MYSQL *m;
MYSQL_RES *res;
MYSQL_ROW row;
char uidstr[64];
char *mailbox_name;
int rc;
if (!key)
{
errno = EINVAL;
return 1;
}
m = mysql_init (0);
if (!m)
return 1;
if (!mysql_real_connect (m,
mu_sql_host, mu_sql_user,
mu_sql_passwd, mu_sql_db,
mu_sql_port, mu_sql_socket, MFLAGS))
{
mu_error (_("MySQL: connect failed: %s"), mysql_error (m));
mysql_close (m);
return 1;
}
snprintf (uidstr, sizeof (uidstr), "%u", *(uid_t*)key);
query_str = mu_sql_expand_query (mu_sql_getpwuid_query, uidstr);
if (!query_str)
{
mysql_close (m);
return 1;
}
if (mysql_query (m, query_str) != 0)
{
mu_error (_("MySQL: query failed: %s"), mysql_error (m));
free (query_str);
mysql_close (m);
return 1;
}
free (query_str);
if ((res = mysql_store_result (m)) == NULL)
{
mu_error (_("MySQL: can't store result: %s"), mysql_error (m));
mysql_close (m);
return 1;
}
if ((row = mysql_fetch_row (res)) == NULL)
{
mu_error (_("MySQL: can't fetch row: %s"), mysql_error (m));
mysql_close (m);
return 1;
}
if (mysql_num_fields (res) == 7 && row[6])
mailbox_name = strdup (row[6]);
else
{
mailbox_name = malloc (strlen (mu_path_maildir) +
strlen (row[0]) + 1);
if (mailbox_name)
sprintf (mailbox_name, "%s%s", mu_path_maildir, row[0]);
}
if (mailbox_name)
rc = mu_auth_data_alloc (return_data,
row[0],
row[1],
atoi (row[2]),
atoi (row[3]),
"Mysql User",
row[4],
row[5],
mailbox_name,
1);
else
rc = 1;
free (mailbox_name);
mysql_free_result (res);
mysql_close (m);
return rc;
}
int
mysql_sql_authenticate (struct mu_auth_data **return_data ARG_UNUSED,
const void *key,
void *func_data ARG_UNUSED, void *call_data)
{
struct mu_auth_data *auth_data = key;
char *pass = call_data;
char *query_str = NULL;
MYSQL *m;
MYSQL_RES *res;
MYSQL_ROW row;
int rc;
if (!auth_data)
return 1;
m = mysql_init (0);
if (!m)
return 1;
if (!mysql_real_connect (m,
mu_sql_host, mu_sql_user,
mu_sql_passwd, mu_sql_db,
mu_sql_port,
mu_sql_socket, MFLAGS))
{
mu_error (_("MySQL: connect failed: %s"), mysql_error (m));
mysql_close (m);
return 1;
}
query_str = mu_sql_expand_query (mu_sql_getpass_query, auth_data->name);
if (!query_str)
{
mysql_close (m);
return 1;
}
if (mysql_query (m, query_str) != 0)
{
mu_error (_("MySQL: query failed: %s"), mysql_error (m));
free (query_str);
mysql_close (m);
return 1;
}
free (query_str);
if ((res = mysql_store_result (m)) == NULL)
{
mu_error (_("MySQL: can't store result: %s"), mysql_error (m));
mysql_close (m);
return 1;
}
if ((row = mysql_fetch_row (res)) == NULL)
{
mu_error (_("MySQL: can't fetch row: %s"), mysql_error (m));
mysql_close (m);
return 1;
}
rc = strcmp (row[0], crypt (pass, row[0]));
mysql_free_result (res);
mysql_close (m);
return rc;
}
#endif
/* GNU Mailutils -- a suite of utilities for electronic mail
Copyright (C) 2003 Free Software Foundation, Inc.
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2 of the License, or (at your option) any later version.
This library 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
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
#ifdef HAVE_CONFIG_H
# include <config.h>
#endif
#ifdef HAVE_PGSQL
#include <sql.h>
#include <libpq-fe.h>
#include <ctype.h>
static PGconn *
pg_connect ()
{
PGconn *pgconn;
char portbuf[16];
char *portstr;
if (mu_sql_port == 0)
portstr = NULL;
else
{
portstr = portbuf;
snprintf (portbuf, sizeof (portbuf), "%d", mu_sql_port);
}
pgconn = PQsetdbLogin (mu_sql_host, portstr, NULL, NULL,
mu_sql_db, mu_sql_user, mu_sql_passwd);
if (PQstatus (pgconn) == CONNECTION_BAD)
{
mu_error("PQconnectStart: %s", PQerrorMessage (pgconn));
PQfinish (pgconn);
return NULL;
}
return pgconn;
}
static char *
chop (char *str)
{
int len;
for (len = strlen(str); len > 0 && isspace(str[len-1]); len--)
;
str[len] = 0;
return str;
}
static int
pg_auth_common (PGresult *res, char *query_str, struct mu_auth_data **auth)
{
char *user_name, *passwd, *homedir, *shell, *mailbox_name;
uid_t uid;
gid_t gid;
ExecStatusType stat;
int ntuples, nfields;
int rc = 1;
stat = PQresultStatus (res);
if (stat != PGRES_TUPLES_OK)
{
mu_error (_("PQexec status: %s"), PQresStatus(stat));
return 1;
}
ntuples = PQntuples (res);
nfields = PQnfields (res);
if ((ntuples > 1 && nfields) || ntuples == 0)
{
mu_error (ngettext("query returned %d tuple: %s",
"query returned %d tuples: %s",
ntuples),
ntuples, query_str);
if (ntuples == 0)
return 1;
}
if (nfields < 6)
{
mu_error (ngettext("query returned %d field: %s",
"query returned %d fields: %s",
nfields),
nfields, query_str);
return 1;
}
user_name = chop (PQgetvalue (res, 0, 0));
passwd = chop (PQgetvalue (res, 0, 1));
uid = strtoul (PQgetvalue (res, 0, 2), NULL, 0);
gid = strtoul (PQgetvalue (res, 0, 3), NULL, 0);
homedir = chop (PQgetvalue (res, 0, 4));
shell = chop (PQgetvalue (res, 0, 5));
if (nfields == 7)
{
mailbox_name = strdup (chop (PQgetvalue (res, 0, 6)));
}
else
{
mailbox_name = malloc (strlen (mu_path_maildir) +
strlen (user_name) + 1);
if (mailbox_name)
sprintf (mailbox_name, "%s%s", mu_path_maildir, user_name);
}
if (mailbox_name)
rc = mu_auth_data_alloc (auth,
user_name,
passwd,
uid,
gid,
"PGsql User",
homedir,
shell,
mailbox_name,
1);
free (mailbox_name);
return rc;
}
int
pg_auth_sql_by_name (struct mu_auth_data **return_data,
const void *key,
void *func_data ARG_UNUSED,
void *call_data ARG_UNUSED)
{
char *query_str = NULL;
int rc;
PGconn *conn;
PGresult *res = NULL;
if (!key)
{
errno = EINVAL;
return 1;
}
conn = pg_connect ();
if (!conn)
{
/* Error message already issued */
return 1;
}
query_str = mu_sql_expand_query (mu_sql_getpwnam_query, key);
if (!query_str)
{
PQfinish (conn);
return 1;
}
res = PQexec (conn, query_str);
if (res == NULL)
{
mu_error ("PQexec: %s", PQerrorMessage (conn));
rc = 1;
}
else
{
rc = pg_auth_common (res, query_str, return_data);
PQclear(res);
}
free (query_str);
PQfinish (conn);
return rc;
}
int
pg_auth_sql_by_uid (struct mu_auth_data **return_data,
const void *key,
void *func_data ARG_UNUSED,
void *call_data ARG_UNUSED)
{
char uidstr[64];
char *query_str = NULL;
int rc;
PGconn *conn;
PGresult *res = NULL;
if (!key)
{
errno = EINVAL;
return 1;
}
conn = pg_connect ();
if (!conn)
{
/* Error message already issued */
return 1;
}
snprintf (uidstr, sizeof (uidstr), "%u", *(uid_t*)key);
query_str = mu_sql_expand_query (mu_sql_getpwuid_query, uidstr);
if (!query_str)
{
PQfinish (conn);
return 1;
}
res = PQexec (conn, query_str);
if (res == NULL)
{
mu_error ("PQexec: %s", PQerrorMessage (conn));
rc = 1;
}
else
{
rc = pg_auth_common (res, query_str, return_data);
PQclear(res);
}
free (query_str);
PQfinish (conn);
return rc;
}
int
pg_sql_authenticate (struct mu_auth_data **return_data ARG_UNUSED,
const void *key,
void *func_data ARG_UNUSED, void *call_data)
{
PGconn *conn;
PGresult *res = NULL;
const struct mu_auth_data *auth_data = key;
char *pass = call_data;
char *query_str = NULL;
int rc = 1;
if (!auth_data)
return 1;
conn = pg_connect ();
if (!conn)
{
/* Error message already issued */
return 1;
}
query_str = mu_sql_expand_query (mu_sql_getpass_query, auth_data->name);
if (!query_str)
{
PQfinish (conn);
return 1;
}
res = PQexec (conn, query_str);
if (res == NULL)
{
mu_error ("PQexec: %s", PQerrorMessage (conn));
}
else
{
ExecStatusType stat = PQresultStatus (res);
if (stat != PGRES_TUPLES_OK)
mu_error (_("PQexec status: %s"), PQresStatus(stat));
else
{
char *p;
int ntuples = PQntuples (res);
int nfields = PQnfields (res);
if ((ntuples > 1 && nfields) || ntuples == 0)
{
mu_error (ngettext("query returned %d tuple: %s",
"query returned %d tuples: %s",
ntuples),
ntuples, query_str);
if (ntuples == 0)
return 1;
}
if (nfields > 1)
{
mu_error (ngettext("query returned %d field: %s",
"query returned %d fields: %s",
nfields),
nfields, query_str);
}
p = chop (PQgetvalue (res, 0, 0));
rc = strcmp (p, crypt (pass, p));
}
PQclear (res);
}
free (query_str);
PQfinish (conn);
return rc;
}
#endif