[ezmlm] / sub_mysql / checktag.c

/*$Id: checktag.c,v 1.11 1999/11/10 04:08:27 lindberg Exp $*/
/*$Name: ezmlm-idx-040 $*/
#include "stralloc.h"
#include "scan.h"
#include "fmt.h"
#include "cookie.h"
#include "makehash.h"
#include "strerr.h"
#include "errtxt.h"
#include "subscribe.h"
#include <mysql.h>

static stralloc key = {0};
static stralloc line = {0};
static stralloc quoted = {0};
static char strnum[FMT_ULONG];
static char newcookie[COOKIE];

char *checktag (dir,num,listno,action,seed,hash)
/* reads dir/sql. If not present, returns success (NULL). If dir/sql is    */
/* present, checks hash against the cookie table. If match, returns success*/
/* (NULL), else returns "". If error, returns error string. */

char *dir;				/* the db base dir */
unsigned long num;			/* message number */
unsigned long listno;			/* bottom of range => slave */
char *action;
char *seed;				/* cookie base */
char *hash;				/* cookie */
{
  MYSQL_RES *result;
  MYSQL_ROW row;
  char *table = (char *) 0;
  char *r;

  if ((r = opensql(dir,&table))) {
    if (*r) return r;
    if (!seed) return (char *) 0;		/* no data - accept */

    strnum[fmt_ulong(strnum,num)] = '\0';	/* message nr ->string*/

    switch(slurp("key",&key,32)) {
      case -1:
	return ERR_READ_KEY;
      case 0:
	return ERR_NOEXIST_KEY;
    }

    cookie(newcookie,key.s,key.len,strnum,seed,action);
    if (byte_diff(hash,COOKIE,newcookie)) return "";
    else return (char *) 0;

  } else {

/* SELECT msgnum FROM table_cookie WHERE msgnum=num and cookie='hash' */
/* succeeds only is everything correct. 'hash' is quoted since it is  */
/*  potentially hostile. */
    if (listno) {			/* only for slaves */
      if (!stralloc_copys(&line,"SELECT listno FROM ")) return ERR_NOMEM;
      if (!stralloc_cats(&line,table)) return ERR_NOMEM;
      if (!stralloc_cats(&line,"_mlog WHERE listno=")) return ERR_NOMEM;
      if (!stralloc_catb(&line,strnum,fmt_ulong(strnum,listno)))
	return ERR_NOMEM;
      if (!stralloc_cats(&line," AND msgnum=")) return ERR_NOMEM;
      if (!stralloc_catb(&line,strnum,fmt_ulong(strnum,num))) return ERR_NOMEM;
      if (!stralloc_cats(&line," AND done > 3")) return ERR_NOMEM;
      if (mysql_real_query((MYSQL *) psql,line.s,line.len) != 0)
	return mysql_error((MYSQL *) psql);			/* query */
      if (!(result = mysql_use_result((MYSQL *) psql)))		/* use result */
	return mysql_error((MYSQL *) psql);
      if ((row = mysql_fetch_row(result)))
	return "";					/*already done */
      else						/* no result */
        if (!mysql_eof(result))
	  return mysql_error((MYSQL *) psql);
      mysql_free_result(result);			/* free res */
    }

    if (!stralloc_copys(&line,"SELECT msgnum FROM ")) return ERR_NOMEM;
    if (!stralloc_cats(&line,table)) return ERR_NOMEM;
    if (!stralloc_cats(&line,"_cookie WHERE msgnum=")) return ERR_NOMEM;
    if (!stralloc_catb(&line,strnum,fmt_ulong(strnum,num))) return ERR_NOMEM;
    if (!stralloc_cats(&line," and cookie='")) return ERR_NOMEM;
    if (!stralloc_ready(&quoted,COOKIE * 2 + 1)) return ERR_NOMEM;
    quoted.len = mysql_escape_string(quoted.s,hash,COOKIE);
    if (!stralloc_cat(&line,&quoted)) return ERR_NOMEM;
    if (!stralloc_cats(&line,"'")) return ERR_NOMEM;

    if (mysql_real_query((MYSQL *) psql,line.s,line.len) != 0)	/* select */
	return mysql_error((MYSQL *) psql);
    if (!(result = mysql_use_result((MYSQL *) psql)))
	return mysql_error((MYSQL *) psql);
    if (!mysql_fetch_row(result)) {
    if (!mysql_eof(result))		/* some error occurred */
	return mysql_error((MYSQL *) psql);
      mysql_free_result(result);	/* eof => query ok, but null result*/
      return "";			/* not parent => perm error */
    }
    mysql_free_result(result);		/* success! cookie matches */
    if (listno)
      (void) logmsg(dir,num,listno,0L,3);	/* non-ess mysql logging */
    return (char *)0;
  }
}
Commit	Line	Data
f8beb284 MW	1	/$Id: checktag.c,v 1.11 1999/11/10 04:08:27 lindberg Exp $/
	2	/$Name: ezmlm-idx-040 $/
	3	#include "stralloc.h"
	4	#include "scan.h"
	5	#include "fmt.h"
	6	#include "cookie.h"
	7	#include "makehash.h"
	8	#include "strerr.h"
	9	#include "errtxt.h"
	10	#include "subscribe.h"
	11	#include <mysql.h>
	12
	13	static stralloc key = {0};
	14	static stralloc line = {0};
	15	static stralloc quoted = {0};
	16	static char strnum[FMT_ULONG];
	17	static char newcookie[COOKIE];
	18
	19	char *checktag (dir,num,listno,action,seed,hash)
	20	/* reads dir/sql. If not present, returns success (NULL). If dir/sql is */
	21	/* present, checks hash against the cookie table. If match, returns success*/
	22	/* (NULL), else returns "". If error, returns error string. */
	23
	24	char dir; / the db base dir */
	25	unsigned long num; /* message number */
	26	unsigned long listno; /* bottom of range => slave */
	27	char *action;
	28	char seed; / cookie base */
	29	char hash; / cookie */
	30	{
	31	MYSQL_RES *result;
	32	MYSQL_ROW row;
	33	char table = (char ) 0;
	34	char *r;
	35
	36	if ((r = opensql(dir,&table))) {
	37	if (*r) return r;
	38	if (!seed) return (char ) 0; / no data - accept */
	39
	40	strnum[fmt_ulong(strnum,num)] = '\0'; /* message nr ->string*/
	41
	42	switch(slurp("key",&key,32)) {
	43	case -1:
	44	return ERR_READ_KEY;
	45	case 0:
	46	return ERR_NOEXIST_KEY;
	47	}
	48
	49	cookie(newcookie,key.s,key.len,strnum,seed,action);
	50	if (byte_diff(hash,COOKIE,newcookie)) return "";
	51	else return (char *) 0;
	52
	53	} else {
	54
	55	/* SELECT msgnum FROM table_cookie WHERE msgnum=num and cookie='hash' */
	56	/* succeeds only is everything correct. 'hash' is quoted since it is */
	57	/* potentially hostile. */
	58	if (listno) { /* only for slaves */
	59	if (!stralloc_copys(&line,"SELECT listno FROM ")) return ERR_NOMEM;
	60	if (!stralloc_cats(&line,table)) return ERR_NOMEM;
	61	if (!stralloc_cats(&line,"_mlog WHERE listno=")) return ERR_NOMEM;
	62	if (!stralloc_catb(&line,strnum,fmt_ulong(strnum,listno)))
	63	return ERR_NOMEM;
	64	if (!stralloc_cats(&line," AND msgnum=")) return ERR_NOMEM;
65	if (!stralloc_catb(&line,strnum,fmt_ulong(strnum,num))) return ERR_NOMEM;
66	if (!stralloc_cats(&line," AND done > 3")) return ERR_NOMEM;
67	if (mysql_real_query((MYSQL *) psql,line.s,line.len) != 0)
68	return mysql_error((MYSQL ) psql); / query */
69	if (!(result = mysql_use_result((MYSQL ) psql))) / use result */
70	return mysql_error((MYSQL *) psql);
71	if ((row = mysql_fetch_row(result)))
72	return ""; /already done /
73	else /* no result */
74	if (!mysql_eof(result))
75	return mysql_error((MYSQL *) psql);
76	mysql_free_result(result); /* free res */
77	}
78
79	if (!stralloc_copys(&line,"SELECT msgnum FROM ")) return ERR_NOMEM;
80	if (!stralloc_cats(&line,table)) return ERR_NOMEM;
81	if (!stralloc_cats(&line,"_cookie WHERE msgnum=")) return ERR_NOMEM;
82	if (!stralloc_catb(&line,strnum,fmt_ulong(strnum,num))) return ERR_NOMEM;
83	if (!stralloc_cats(&line," and cookie='")) return ERR_NOMEM;
84	if (!stralloc_ready(&quoted,COOKIE * 2 + 1)) return ERR_NOMEM;
85	quoted.len = mysql_escape_string(quoted.s,hash,COOKIE);
86	if (!stralloc_cat(&line,&quoted)) return ERR_NOMEM;
87	if (!stralloc_cats(&line,"'")) return ERR_NOMEM;
88
89	if (mysql_real_query((MYSQL ) psql,line.s,line.len) != 0) / select */
90	return mysql_error((MYSQL *) psql);
91	if (!(result = mysql_use_result((MYSQL *) psql)))
92	return mysql_error((MYSQL *) psql);
93	if (!mysql_fetch_row(result)) {
94	if (!mysql_eof(result)) /* some error occurred */
95	return mysql_error((MYSQL *) psql);
96	mysql_free_result(result); /* eof => query ok, but null result*/
97	return ""; /* not parent => perm error */
98	}
99	mysql_free_result(result); /* success! cookie matches */
100	if (listno)
101	(void) logmsg(dir,num,listno,0L,3); /* non-ess mysql logging */
102	return (char *)0;
103	}
104	}