getmail.c

/* Synchronet DLL-exported mail-related routines */

/****************************************************************************
 * @format.tab-size 4		(Plain Text/Source Code File Header)			*
 * @format.use-tabs true	(see http://www.synchro.net/ptsc_hdr.html)		*
 *																			*
 * Copyright Rob Swindell - http://www.synchro.net/copyright.html			*
 *																			*
 * 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.					*
 * See the GNU General Public License for more details: gpl.txt or			*
 * http://www.fsf.org/copyleft/gpl.html										*
 *																			*
 * For Synchronet coding style and modification guidelines, see				*
 * http://www.synchro.net/source.html										*
 *																			*
 * Note: If this box doesn't appear square, then you need to fix your tabs.	*
 ****************************************************************************/

#include "getmail.h"

/****************************************************************************/
/* Returns the number of pieces of mail waiting for usernumber              */
/* If sent is non-zero, it returns the number of mail sent by usernumber    */
/* If usernumber is 0, it returns all mail on the system                    */
/****************************************************************************/
int getmail(scfg_t* cfg, int usernumber, bool sent, int attr)
{
	char     path[MAX_PATH + 1];
	int      i = 0;
	long     l;
	idxrec_t idx;
	smb_t    smb;

	ZERO_VAR(smb);
	SAFEPRINTF(smb.file, "%smail", cfg->data_dir);
	smb.retry_time = 1;   //cfg->smb_retry_time;
	SAFEPRINTF(path, "%s.sid", smb.file);
	l = (long)flength(path);
	if (l < (long)sizeof(idxrec_t))
		return 0;
	if (usernumber == 0 && attr == 0)
		return l / sizeof(idxrec_t);  /* Total system e-mail */
	smb.subnum = INVALID_SUB;

	if (smb_open_fp(&smb, &smb.sid_fp, SH_DENYNO) != 0)
		return 0;

	while (!smb_feof(smb.sid_fp)) {
		if (smb_fread(&smb, &idx, sizeof(idx), smb.sid_fp) != sizeof(idx))
			break;
		if (idx.number == 0)   /* invalid message number, ignore */
			continue;
		if (idx.attr & MSG_DELETE)
			continue;
		if (attr < 0 && (idx.attr & (~attr)) != 0)
			continue;
		if (attr > 0 && (idx.attr & attr) != attr)
			continue;
		if (usernumber == 0
		    || (!sent && idx.to == usernumber)
		    || (sent && idx.from == usernumber))
			i++;
	}
	smb_close(&smb);
	return i;
}


/***************************/
/* Delete file attachments */
/***************************/
bool delfattach(scfg_t* cfg, smbmsg_t* msg)
{
	char  dir[MAX_PATH + 1];
	char  path[MAX_PATH + 1];
	char  files[128];
	char *tp, *sp, *p;

	if (msg->idx.to == 0)  /* netmail */
		SAFEPRINTF2(dir, "%sfile/%04u.out", cfg->data_dir, msg->idx.from);
	else
		SAFEPRINTF2(dir, "%sfile/%04u.in", cfg->data_dir, msg->idx.to);

	SAFECOPY(files, msg->subj);
	tp = files;
	while (1) {
		p = strchr(tp, ' ');
		if (p)
			*p = 0;
		sp = strrchr(tp, '/');              /* sp is slash pointer */
		if (!sp)
			sp = strrchr(tp, '\\');
		if (sp)
			tp = sp + 1;
		if (strcspn(tp, ILLEGAL_FILENAME_CHARS) == strlen(tp)) {
			SAFEPRINTF2(path, "%s/%s", dir, tp);
			if (fexist(path) && remove(path) != 0)
				return false;
		}
		if (!p)
			break;
		tp = p + 1;
	}
	rmdir(dir);                     /* remove the dir if it's empty */
	return true;
}

/****************************************************************************/
/* Loads mail waiting for user number 'usernumber' into the mail array of   */
/* of pointers to mail_t (message numbers and attributes)                   */
/* smb_open(&smb) must be called prior										*/
/****************************************************************************/
mail_t* loadmail(smb_t* smb, uint32_t* msgs, uint usernumber
                 , int which, long mode)
{
	ulong    l = 0;
	idxrec_t idx;
	mail_t*  mail = NULL;

	if (msgs == NULL)
		return NULL;

	*msgs = 0;

	if (smb == NULL)
		return NULL;

	if (smb_locksmbhdr(smb) != 0)                  /* Be sure noone deletes or */
		return NULL;                          /* adds while we're reading */

	smb_rewind(smb->sid_fp);
	while (!smb_feof(smb->sid_fp)) {
		if (smb_fread(smb, &idx, sizeof(idx), smb->sid_fp) != sizeof(idx))
			break;
		if (idx.number == 0)   /* invalid message number, ignore */
			continue;
		if ((which == MAIL_SENT && idx.from != usernumber)
		    || (which == MAIL_YOUR && idx.to != usernumber)
		    || (which == MAIL_ANY && idx.from != usernumber && idx.to != usernumber))
			continue;
		if (idx.attr & MSG_DELETE && !(mode & LM_INCDEL))    /* Don't included deleted msgs */
			continue;
		if (mode & LM_UNREAD && idx.attr & MSG_READ)
			continue;
		if (mode & LM_NOSPAM && idx.attr & MSG_SPAM)
			continue;
		if (mode & LM_SPAMONLY && !(idx.attr & MSG_SPAM))
			continue;
		mail_t* np;
		if ((np = realloc(mail, sizeof(mail_t) * (l + 1))) == NULL) {
			free(mail);
			smb_unlocksmbhdr(smb);
			return NULL;
		}
		mail = np;
		mail[l] = idx;
		l++;
	}
	smb_unlocksmbhdr(smb);
	*msgs = l;
	if (l && (mode & LM_REVERSE)) {
		mail_t* reversed = malloc(sizeof(mail_t) * l);
		if (reversed == NULL) {
			free(mail);
			return NULL;
		}
		for (ulong n = 0; n < l; n++)
			reversed[n] = mail[l - (n + 1)];
		free(mail);
		mail = reversed;
	}
	return mail;
}

void freemail(mail_t* mail)
{
	if (mail != NULL)
		free(mail);
}