/*
 *
 *	Copyright (C) 1988, 1989 by the Massachusetts Institute of Technology
 *    	Developed by the MIT Student Information Processing Board (SIPB).
 *    	For copying information, see the file mit-copyright.h in this release.
 *
 */
/*
 *	$Source: /afs/sipb.mit.edu/project/discuss/.cvsroot/discuss/source/libds/dsname.c,v $
 *	$Id: dsname.c,v 1.27 1995/03/18 07:23:20 srz Exp $
 *
 */

/*
 * db: Implements user's meetings database.
 *
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif /* HAVE_CONFIG_H */

#include <stdio.h>
#include <string.h>
#include <pwd.h>
#include <sys/file.h>
#include <sys/param.h>
#include <errno.h>
#include <assert.h>
#include <discuss/dsname.h>
#include <discuss/dsc_et.h>
#if HAVE_UNISTD_H
#include <unistd.h>
#endif
#include "ansi.h"

#ifndef lint
static const char rcsid_dsname_c[] =
    "$Header: /afs/sipb.mit.edu/project/discuss/.cvsroot/discuss/source/libds/dsname.c,v 1.27 1995/03/18 07:23:20 srz Exp $";
#endif

extern char *malloc (), *local_realm (), *getenv ();
extern int errno;

/*
 * Format of data file:
 *    status:last_time:last_seen:uid:name1,name2name3,....,nameN:
 */

static FILE *db = (FILE *)NULL;
static char *db_file = (char *)NULL;
static char *db_user_id = (char *)NULL;

static server_name_blk current = {
    (char *)NULL, (char *)NULL, (char *)NULL, 0, 0, 0
};

static char disrcbuf[MAXPATHLEN]; /* user's MEETINGS file */
static char *disrcfile = NULL;	/* pointer to above */
static char *me = NULL;		/* user's own user_id field */

static char mtgs[] = "/.meetings";

#ifdef __GNUC__
#define INLINE inline
#else
#define INLINE
#endif

/*
 * ds() -- duplicate a string.  a useful utility routine...
 */

INLINE static char * ds(s)
    const char *s;
{
    register int len = strlen (s) + 1;
    register char *ns = malloc (len);
    memcpy(ns, s, len);
    return (ns);
}

/*
 * Attempt to locate user's .meetings file.  This is intended to be
 * used as a test routine from an application.
 *
 * search path is:
 *	$MEETINGS environment variable
 *	$HOME/.meetings
 *	<pw->pw_dir>/.meetings
 * This function is "sticky"; it only evaluates the filename once.
 */

int find_rc_filename()
{
    struct passwd *pw = NULL;
    register char *cp;

    if (disrcfile)
	return 0;

    pw = getpwuid(getuid());
    if (!pw)
	return NO_SUCH_USER;
    me = malloc(strlen(pw->pw_name)+2+
		strlen(local_realm()));
    strcpy(me, pw->pw_name);
    strcat(me, "@");
    strcat(me, local_realm());

    cp = getenv("MEETINGS");
    if (cp)
	strcpy(disrcbuf, cp);
    if (!cp) {
	cp = getenv("HOME");
	if (cp) {
	    strcpy(disrcbuf, cp);
	    strcat(disrcbuf, mtgs);
	}
    }
    if (!cp) {
	strcpy(disrcbuf, pw->pw_dir);
	strcat(disrcbuf, mtgs);
    }
    if (!access(disrcbuf, R_OK|W_OK)) {
	disrcfile = disrcbuf;
	return 0;
    }
    return errno;
}

static int set_rc_filename(auser_id, buf, len)
    const char *auser_id;
    char *buf;
    int len;
{
    struct passwd *pw = NULL;
    register char *cp = NULL;

    if ((auser_id == NULL) ||
	(auser_id[0] == '\0') ||
	(me && !strcmp(auser_id, me))) {
	if (!disrcfile) {
	    register int code;
	    if (code = find_rc_filename())
		return code;
	}
	strncpy(buf, disrcbuf, MAXPATHLEN-1);
	return 0;
    }
    cp = strchr(auser_id, '@');
    if (cp)
	*cp = '\0';
    pw = getpwnam(auser_id);
    if (cp)
	*cp = '@';
    if (!pw) {
	return NO_SUCH_USER;
    }
    strncpy(buf, pw->pw_dir, len);
    strncat(buf, mtgs, len - strlen(buf));
    return (access(buf, R_OK)? NO_MTGS_FILE : 0);
}

static void clear_current () {
    if (current.hostname) {
	free (current.hostname);
	current.hostname = (char *) NULL;
    }
    if (current.pathname) {
	free (current.pathname);
	current.pathname = (char *) NULL;
    }
    if (current.alias_list) {
	free (current.alias_list);
	current.alias_list = (char *) NULL;
    }
    if (current.spare) {
	free (current.spare);
	current.spare = (char *) NULL;
    }
}

static void enddbent()
{
    if (db) {
	fclose(db);
	db = (FILE *)NULL;
	free(db_file);
	db_file = (char *)NULL;
	free(db_user_id);
	db_user_id = (char *)NULL;
    }
    clear_current ();
}

/*
 * getdbent() -- get the next entry out of the file.  returns
 * zero on end of file or uncorrectable error, one on success, minus
 * one on correctable error.
 */

static int getdbent()
{
    char buffer[BUFSIZ];
    char *bufp, *cp;

    if (!db) {
	errno = NO_MTGS_FILE;
	return(0);
    }
    if (!fgets(buffer, BUFSIZ, db)) {
	return 0;
    }

    bufp = strchr(buffer, '\n');
    if (bufp)
	*bufp = '\0';
    bufp = buffer;

    /* meeting status flags (per-user) */
    current.status = atoi(bufp);
    bufp = strchr(bufp, ':');
    if (!bufp) {
    bad_fmt:
	errno = BAD_MTGS_FILE;
	return(-1);
    }
    else
	bufp++;

    /* date user last attended meeting */
    current.date_attended = atoi(bufp);
    bufp = strchr(bufp, ':');
    if (!bufp)
	goto bad_fmt;
    else
	bufp++;

    /* last transaction seen */
    current.last = atoi(bufp);
    bufp = strchr(bufp, ':');
    if (!bufp)
	goto bad_fmt;
    else
	bufp++;

    /* hostname of meeting */
    if (current.hostname)
	free(current.hostname);
    cp = strchr(bufp, ':');
    if (cp == NULL) goto bad_fmt;
    else {
	*cp = '\0';
	current.hostname = ds(bufp);
	bufp = cp+1;
    }

    /* pathname of meeting on remote host */
    if (current.pathname)
	free(current.pathname);
    cp = strchr(bufp, ':');
    if (cp == NULL) goto bad_fmt;
    else {
	*cp = '\0';
	current.pathname = ds(bufp);
	bufp = cp+1;
    }

    /* list of aliases for meeting */
    if (current.alias_list)
	free(current.alias_list);
    cp = strchr(bufp, ':');
    if (cp == NULL) goto bad_fmt;
    else {
	*cp = '\0';
	current.alias_list = ds(bufp);
	bufp = cp+1;
    }

    if (current.spare)
	free(current.spare);
    current.spare = ds(bufp);

    return(1);
}

static int setdbent(user_id)
    const char *user_id;
{
    char *auid;
    register int code;

    enddbent();

    if (!user_id)
	user_id = "";
    if (!db_file)
	db_file = malloc(MAXPATHLEN);
    if (code = set_rc_filename(user_id, db_file, MAXPATHLEN))
	return code;

    db = fopen(db_file, "r");
    if (!db)
	return(errno);
    if (db_user_id)
	free(db_user_id);
    db_user_id = ds(user_id);
    if (current.user_id)
	free(current.user_id);
    current.user_id = ds(user_id);
    return(0);
}

static int is_a_name(name)
    register char *name;
{
    register int len;
    register char *ns = current.alias_list;

    if (*name == '*')
	return(1);
    len = strlen(name);

    while (1) {
	if (!strncmp(name, ns, len) && (!ns[len] || ns[len] == ',')) {
	    return(1);
	}
	ns = strchr(ns+1, ',');
	if (!ns || !ns[1]) {
	    return(0);
	}
	ns++;
    }
}

static char ** expand(list)
    char *list;
{
    char *calloc();
    register int num = 2;
    register char *cp;
    register char **rv, **rv1;
    for (cp = list; cp;) {
	num++;
	cp = strchr(cp, ',');
	if (cp)
	    cp++;
    }
    rv = (char **) calloc (num, sizeof(char *));
    rv1 = rv;
    while (list && *list) {
	while (*list == ',')
	    list++;
	cp = strchr(list, ',');
	if (cp)
	    *cp = '\0';
	*rv1 = ds(list);
	rv1++;
	if (cp) {
	    *cp = ',';
	    cp++;
	    list = cp;
	}
	else list = (char *) NULL;
    }
    *rv1 = (char *) NULL;
    return(rv);
}

static char * compress(list)
    char **list;
{
    int len;
    char **cp;
    char *rv;
    len = 1;
    for (cp = list; *cp; cp++)
	len += 1 + strlen(*cp);
    rv = malloc (len);
    strcpy(rv, *list);
    for (cp = list+1; *cp; cp++) {
	strcat(rv, ",");
	strcat(rv, *cp);
    }
    return (rv);
}

dsc_expand_mtg_set(user_id, name, set, num, result)
    char *user_id;		/* userid to do lookup for */
    char *name;			/* user's name for meeting */
    name_blk **set;		/* returned values */
    int *num;			/* number of returned meetings */
    int *result;		/* return code */
{
    int count;
    register int r;

    *set = 0;
    *num = 0;
    *result = 0;

    if (!user_id)
	user_id = "";
    if (!name) {
	*result = EINVAL;
	*num = 0;
	return;
    }
    r = setdbent(user_id);
    if (r) {
	*result = r;
	return;
    }
    count = 0;
    while ((r=getdbent()) > 0) {
	if (is_a_name(name))
	    count++;
    }
    if (r) {			/* getdbent returns -1 */
	*result = errno;
	return;
    }
    r = setdbent(user_id);
    if (r) {
	*result = r;
	return;
    }
    *set = (name_blk *) malloc(count * sizeof(name_blk));
    if (*set == (name_blk *)NULL) {
	*result = errno;
	return;
    }
    while ((r=getdbent()) > 0)
	if (is_a_name(name)) {
	    register name_blk *nb = *set + (*num)++;
	    memset((char *)nb, 0, sizeof(*nb));
	    nb->date_attended = current.date_attended;
	    nb->last = current.last;
	    nb->status = current.status;
	    nb->hostname = ds(current.hostname);
	    nb->pathname = ds(current.pathname);
	    nb->aliases = expand(current.alias_list);
	    nb->spare = ds(current.spare);
	    nb->user_id = ds(user_id);
	}
    if (r)
	*result = r;
}

void dsc_copy_name_blk (src, dest)
    register name_blk *src, *dest;
{
    char **cpp;
    char **dpp;
    int count;

    *dest = *src;
    dest->hostname = ds(dest->hostname);
    dest->pathname = ds(dest->pathname);
    dest->user_id = ds(dest->user_id);
    dest->spare = ds(dest->spare);

    for (count=1, cpp = src->aliases; *cpp; cpp++) {
	count++;
    }
    dpp = dest->aliases = (char **)malloc ((count+1) * sizeof (char *));
    for (cpp = src->aliases; *cpp; cpp++, dpp++)
	*dpp = ds (*cpp);
    *dpp = NULL;
}
/*
 * Free all allocated storage associated with *nbp;
 * Note: this does not free the nbp itself.
 */
void dsc_destroy_name_blk(nbp)
    name_blk *nbp;
{
    if (nbp->aliases) {
	register char **alp = nbp->aliases;
	while (*alp) {
	    free (*alp);
	    alp++;
	}
	free (nbp->aliases);
	nbp->aliases = 0;
    }
    if (nbp->hostname) {
	free(nbp->hostname);
	nbp->hostname = 0;
    }
    if (nbp->pathname) {
	free(nbp->pathname);
	nbp->pathname = 0;
    }
    if (nbp->spare) {
	free(nbp->spare);
	nbp->spare = 0;
    }
    if (nbp->user_id) {
	free (nbp->user_id);
	nbp->user_id = 0;
    }
}

void dsc_destroy_mtg_set(nbp, count)
    register name_blk *nbp;
    register int count;
{
    register int i;

    if (nbp == NULL) return;
    for (i=0; i<count; i++)
	dsc_destroy_name_blk(&nbp[i]);

    free((char *)nbp);
}

dsc_get_mtg (user_id, name, nbp, result)
    char *user_id;
    char *name;
    name_blk *nbp;
    int *result;
{
    name_blk *set = NULL;
    int num;

    if (!name) {
	*result = EINVAL;
    }
    dsc_expand_mtg_set(user_id, name, &set, &num, result);
    if (num == 0) {
	if (!*result)
	    *result = NO_SUCH_MTG;
	goto bad;
    } else if (num > 1) {
	register int i;
	for (i = 1; i < num; i++) {
	    dsc_destroy_name_blk(&set[i]);
	}
    }
    memcpy(nbp, &set[0], sizeof(name_blk));

bad:
    if (set)
	free((char *)set);
}

static const char format[] = "%d:%d:%d:%s:%s:%s:%s\n";

void dsc_update_mtg_set(user_id, set, num, result)
    char const *user_id;	/* input */
    name_blk *set;		/* array of name_blk's */
    int num;			/* number in set */
    int *result;		/* error code */
{
    name_blk *nbp;
    int i;
    register int r;
    char *touched;		/* array of booleans */
    char *new_name;
    FILE *new_file = NULL;
    char *old_name;

    if (!num) {
	*result = 0;
	return;
    }
    else if (!set) {
	*result = EINVAL;
	return;
    }
    if (*result = setdbent(user_id)) {
	if (*result != NO_MTGS_FILE && *result != ENOENT)
	    return;
	else
	    *result = 0;
    }

    new_name = malloc(strlen(db_file) + 2);
    strcpy (new_name, db_file);
    strcat (new_name, "~");		/* emacsish, but who cares? */
    old_name = malloc(strlen(db_file) + 1);
    strcpy (old_name, db_file);

    new_file = fopen (new_name, "w+");
    if (new_file == NULL) {
	*result = errno;
	free(old_name);
	free (new_name);
	return;
    }

    touched = malloc (num);
    for (i = 0; i < num; i++)
	touched[i] = 0;

    while ((r=getdbent()) != 0) {
	if (r == -1) {	/* if bad format, we complain loudly */
	     *result = BAD_MTGS_FILE;
	     goto punt;
	}
	/* walk through user structures, look for matching entries */
	for (i = 0, nbp = set;  i < num; i++, nbp++) {
	    if (!strcmp (current.hostname, nbp -> hostname) &&
		!strcmp(current.pathname, nbp->pathname)) {
		/* match, update */
		current.last = nbp -> last;
		current.date_attended =
		    nbp -> date_attended;
		current.status = nbp -> status;
		if (current.alias_list != NULL)
		    free (current.alias_list);
		current.alias_list = compress(nbp -> aliases);
		if (current.spare)
		    free (current.spare);
		current.spare = ds(nbp->spare);
		touched[i] = 1;
	    }
	}
	if (current.status & DSC_ST_DELETED) continue;

	if (fprintf(new_file, format,
		    current.status, current.date_attended, current.last,
		    current.hostname, current.pathname,
		    current.alias_list, current.spare) == EOF)
	    goto punt;
    }

    clear_current ();

    /* clean up ones we haven't touched in memory yet */
    for (i = 0, nbp = set; i < num; i++, nbp++) {
	if (!touched[i]) {
	    char *temp = compress (nbp->aliases);

	    assert (nbp->hostname != 0 && nbp->pathname != 0);
	    assert (nbp->spare != 0);
	    if (fprintf (new_file, format,
			 nbp->status, nbp->date_attended, nbp->last,
			 nbp->hostname, nbp->pathname,
			 temp, nbp->spare) == EOF) {
		free (temp);
		goto punt;
	    }
	    free (temp);
	}
    }
    enddbent();
    /* Fsync the file, just to be sure */
    fflush(new_file);
    if (fsync (fileno (new_file)) == -1)
	 goto punt;
    if (ferror (new_file)) {
	 *result = CANT_WRITE_TEMP;
	 goto punt;
    }
    if (fclose (new_file)) {
	 *result = CANT_WRITE_TEMP;
	 goto punt;
    }
    new_file = NULL;
    *result = (rename(new_name, old_name) < 0) ? errno : 0;
    if (*result)
	(void) unlink (new_name);
    new_file = NULL;
    free(new_name);
    free(old_name);
    free(touched);
    return;

punt:
    if (new_file)
	fclose(new_file);
    enddbent();
    unlink(new_name);
    free(new_name);
    free(old_name);
    free(touched);
    return;
}

void
dsc_set_mtgs_name(fname)
char *fname;
{
     strncpy(disrcbuf, fname, sizeof(disrcbuf)-1);
     disrcbuf[sizeof(disrcbuf)-1] = '\0';
     disrcfile = disrcbuf;
     return;
}