imapext-2007: src/osdep/unix/mix.c annotate

imapext-2007

annotate src/osdep/unix/mix.c @ 0:ada5e610ab86

imap-2007e

author	yuuji@gentei.org
date	Mon, 14 Sep 2009 15:17:45 +0900
parents
children

rev	line source
yuuji@0	1 /* ========================================================================
yuuji@0	2 * Copyright 1988-2008 University of Washington
yuuji@0	3 *
yuuji@0	4 * Licensed under the Apache License, Version 2.0 (the "License");
yuuji@0	5 * you may not use this file except in compliance with the License.
yuuji@0	6 * You may obtain a copy of the License at
yuuji@0	7 *
yuuji@0	8 * http://www.apache.org/licenses/LICENSE-2.0
yuuji@0	9 *
yuuji@0	10 *
yuuji@0	11 * ========================================================================
yuuji@0	12 */
yuuji@0	13
yuuji@0	14 /*
yuuji@0	15 * Program: MIX mail routines
yuuji@0	16 *
yuuji@0	17 * Author(s): Mark Crispin
yuuji@0	18 * UW Technology
yuuji@0	19 * University of Washington
yuuji@0	20 * Seattle, WA 98195
yuuji@0	21 * Internet: MRC@Washington.EDU
yuuji@0	22 *
yuuji@0	23 * Date: 1 March 2006
yuuji@0	24 * Last Edited: 7 May 2008
yuuji@0	25 */
yuuji@0	26
yuuji@0	27
yuuji@0	28 #include <stdio.h>
yuuji@0	29 #include <ctype.h>
yuuji@0	30 #include <errno.h>
yuuji@0	31 extern int errno; /* just in case */
yuuji@0	32 #include "mail.h"
yuuji@0	33 #include "osdep.h"
yuuji@0	34 #include <pwd.h>
yuuji@0	35 #include <sys/stat.h>
yuuji@0	36 #include <sys/time.h>
yuuji@0	37 #include "misc.h"
yuuji@0	38 #include "dummy.h"
yuuji@0	39 #include "fdstring.h"
yuuji@0	40
yuuji@0	41 /* MIX definitions */
yuuji@0	42
yuuji@0	43 #define MEGABYTE (1024*1024)
yuuji@0	44
yuuji@0	45 #define MIXDATAROLL MEGABYTE /* size at which we roll to a new file */
yuuji@0	46
yuuji@0	47
yuuji@0	48 /* MIX files */
yuuji@0	49
yuuji@0	50 #define MIXNAME ".mix" /* prefix for all MIX file names */
yuuji@0	51 #define MIXMETA "meta" /* suffix for metadata */
yuuji@0	52 #define MIXINDEX "index" /* suffix for index */
yuuji@0	53 #define MIXSTATUS "status" /* suffix for status */
yuuji@0	54 #define MIXSORTCACHE "sortcache"/* suffix for sortcache */
yuuji@0	55 #define METAMAX (MEGABYTE-1) /* maximum metadata file size (sanity check) */
yuuji@0	56
yuuji@0	57
yuuji@0	58 /* MIX file formats */
yuuji@0	59
yuuji@0	60 /* sequence format (all but msg files) */
yuuji@0	61 #define SEQFMT "S%08lx\015\012"
yuuji@0	62 /* metadata file format */
yuuji@0	63 #define MTAFMT "V%08lx\015\012L%08lx\015\012N%08lx\015\012"
yuuji@0	64 /* index file record format */
yuuji@0	65 #define IXRFMT ":%08lx:%04d%02d%02d%02d%02d%02d%c%02d%02d:%08lx:%08lx:%08lx:%08lx:%08lx:\015\012"
yuuji@0	66 /* status file record format */
yuuji@0	67 #define STRFMT ":%08lx:%08lx:%04x:%08lx:\015\012"
yuuji@0	68 /* message file header format */
yuuji@0	69 #define MSRFMT "%s%08lx:%04d%02d%02d%02d%02d%02d%c%02d%02d:%08lx:\015\012"
yuuji@0	70 #define MSGTOK ":msg:"
yuuji@0	71 #define MSGTSZ (sizeof(MSGTOK)-1)
yuuji@0	72 /* sortcache file record format */
yuuji@0	73 #define SCRFMT ":%08lx:%08lx:%08lx:%08lx:%08lx:%c%08lx:%08lx:%08lx:\015\012"
yuuji@0	74
yuuji@0	75 /* MIX I/O stream local data */
yuuji@0	76
yuuji@0	77 typedef struct mix_local {
yuuji@0	78 unsigned long curmsg; /* current message file number */
yuuji@0	79 unsigned long newmsg; /* current new message file number */
yuuji@0	80 time_t lastsnarf; /* last snarf time */
yuuji@0	81 int msgfd; /* file description of current msg file */
yuuji@0	82 int mfd; /* file descriptor of open metadata */
yuuji@0	83 unsigned long metaseq; /* metadata sequence */
yuuji@0	84 char index; / mailbox index name */
yuuji@0	85 unsigned long indexseq; /* index sequence */
yuuji@0	86 char status; / mailbox status name */
yuuji@0	87 unsigned long statusseq; /* status sequence */
yuuji@0	88 char sortcache; / mailbox sortcache name */
yuuji@0	89 unsigned long sortcacheseq; /* sortcache sequence */
yuuji@0	90 unsigned char buf; / temporary buffer */
yuuji@0	91 unsigned long buflen; /* current size of temporary buffer */
yuuji@0	92 unsigned int expok : 1; /* non-zero if expunge reports OK */
yuuji@0	93 unsigned int internal : 1; /* internally opened, do not validate */
yuuji@0	94 } MIXLOCAL;
yuuji@0	95
yuuji@0	96
yuuji@0	97 #define MIXBURP struct mix_burp
yuuji@0	98
yuuji@0	99 MIXBURP {
yuuji@0	100 unsigned long fileno; /* message file number */
yuuji@0	101 char name; / message file name */
yuuji@0	102 SEARCHSET tail; / tail of ranges */
yuuji@0	103 SEARCHSET set; /* set of retained ranges */
yuuji@0	104 MIXBURP next; / next file to burp */
yuuji@0	105 };
yuuji@0	106
yuuji@0	107
yuuji@0	108 /* Convenient access to local data */
yuuji@0	109
yuuji@0	110 #define LOCAL ((MIXLOCAL *) stream->local)
yuuji@0	111
yuuji@0	112 /* Function prototypes */
yuuji@0	113
yuuji@0	114 DRIVER mix_valid (char name);
yuuji@0	115 long mix_isvalid (char name,char meta);
yuuji@0	116 void mix_parameters (long function,void value);
yuuji@0	117 long mix_dirfmttest (char *name);
yuuji@0	118 void mix_scan (MAILSTREAM stream,char ref,char pat,char contents);
yuuji@0	119 long mix_scan_contents (char name,char contents,unsigned long csiz,
yuuji@0	120 unsigned long fsiz);
yuuji@0	121 void mix_list (MAILSTREAM stream,char ref,char *pat);
yuuji@0	122 void mix_lsub (MAILSTREAM stream,char ref,char *pat);
yuuji@0	123 long mix_subscribe (MAILSTREAM stream,char mailbox);
yuuji@0	124 long mix_unsubscribe (MAILSTREAM stream,char mailbox);
yuuji@0	125 long mix_create (MAILSTREAM stream,char mailbox);
yuuji@0	126 long mix_delete (MAILSTREAM stream,char mailbox);
yuuji@0	127 long mix_rename (MAILSTREAM stream,char old,char *newname);
yuuji@0	128 int mix_rselect (struct direct *name);
yuuji@0	129 MAILSTREAM mix_open (MAILSTREAM stream);
yuuji@0	130 void mix_close (MAILSTREAM *stream,long options);
yuuji@0	131 void mix_abort (MAILSTREAM *stream);
yuuji@0	132 char mix_header (MAILSTREAM stream,unsigned long msgno,unsigned long *length,
yuuji@0	133 long flags);
yuuji@0	134 long mix_text (MAILSTREAM stream,unsigned long msgno,STRING bs,long flags);
yuuji@0	135 void mix_flag (MAILSTREAM stream,char sequence,char *flag,long flags);
yuuji@0	136 unsigned long mix_sort (MAILSTREAM stream,char charset,SEARCHPGM spg,
yuuji@0	137 SORTPGM *pgm,long flags);
yuuji@0	138 THREADNODE mix_thread (MAILSTREAM stream,char type,char charset,
yuuji@0	139 SEARCHPGM *spg,long flags);
yuuji@0	140 long mix_ping (MAILSTREAM *stream);
yuuji@0	141 void mix_check (MAILSTREAM *stream);
yuuji@0	142 long mix_expunge (MAILSTREAM stream,char sequence,long options);
yuuji@0	143 int mix_select (struct direct *name);
yuuji@0	144 int mix_msgfsort (const void d1,const void d2);
yuuji@0	145 long mix_addset (SEARCHSET **set,unsigned long start,unsigned long size);
yuuji@0	146 long mix_burp (MAILSTREAM stream,MIXBURP burp,unsigned long *reclaimed);
yuuji@0	147 long mix_burp_check (SEARCHSET set,size_t size,char file);
yuuji@0	148 long mix_copy (MAILSTREAM stream,char sequence,char *mailbox,
yuuji@0	149 long options);
yuuji@0	150 long mix_append (MAILSTREAM stream,char mailbox,append_t af,void *data);
yuuji@0	151 long mix_append_msg (MAILSTREAM stream,FILE f,char flags,MESSAGECACHE delt,
yuuji@0	152 STRING msg,SEARCHSET set,unsigned long seq);
yuuji@0	153
yuuji@0	154 FILE mix_parse (MAILSTREAM stream,FILE **idxf,long iflags,long sflags);
yuuji@0	155 char mix_meta_slurp (MAILSTREAM stream,unsigned long *seq);
yuuji@0	156 long mix_meta_update (MAILSTREAM *stream);
yuuji@0	157 long mix_index_update (MAILSTREAM stream,FILE idxf,long flag);
yuuji@0	158 long mix_status_update (MAILSTREAM stream,FILE statf,long flag);
yuuji@0	159 FILE mix_data_open (MAILSTREAM stream,int fd,long size,
yuuji@0	160 unsigned long newsize);
yuuji@0	161 FILE mix_sortcache_open (MAILSTREAM stream);
yuuji@0	162 long mix_sortcache_update (MAILSTREAM stream,FILE *sortcache);
yuuji@0	163 char mix_read_record (FILE f,char buf,unsigned long buflen,char type);
yuuji@0	164 unsigned long mix_read_sequence (FILE *f);
yuuji@0	165 char mix_dir (char dst,char *name);
yuuji@0	166 char mix_file (char dst,char dir,char name);
yuuji@0	167 char mix_file_data (char dst,char *dir,unsigned long data);
yuuji@0	168 unsigned long mix_modseq (unsigned long oldseq);
yuuji@0	169
yuuji@0	170 /* MIX mail routines */
yuuji@0	171
yuuji@0	172
yuuji@0	173 /* Driver dispatch used by MAIL */
yuuji@0	174
yuuji@0	175 DRIVER mixdriver = {
yuuji@0	176 "mix", /* driver name */
yuuji@0	177 /* driver flags */
yuuji@0	178 DR_MAIL\|DR_LOCAL\|DR_NOFAST\|DR_CRLF\|DR_LOCKING\|DR_DIRFMT\|DR_MODSEQ,
yuuji@0	179 (DRIVER ) NIL, / next driver */
yuuji@0	180 mix_valid, /* mailbox is valid for us */
yuuji@0	181 mix_parameters, /* manipulate parameters */
yuuji@0	182 mix_scan, /* scan mailboxes */
yuuji@0	183 mix_list, /* find mailboxes */
yuuji@0	184 mix_lsub, /* find subscribed mailboxes */
yuuji@0	185 mix_subscribe, /* subscribe to mailbox */
yuuji@0	186 mix_unsubscribe, /* unsubscribe from mailbox */
yuuji@0	187 mix_create, /* create mailbox */
yuuji@0	188 mix_delete, /* delete mailbox */
yuuji@0	189 mix_rename, /* rename mailbox */
yuuji@0	190 mail_status_default, /* status of mailbox */
yuuji@0	191 mix_open, /* open mailbox */
yuuji@0	192 mix_close, /* close mailbox */
yuuji@0	193 NIL, /* fetch message "fast" attributes */
yuuji@0	194 NIL, /* fetch message flags */
yuuji@0	195 NIL, /* fetch overview */
yuuji@0	196 NIL, /* fetch message envelopes */
yuuji@0	197 mix_header, /* fetch message header only */
yuuji@0	198 mix_text, /* fetch message body only */
yuuji@0	199 NIL, /* fetch partial message test */
yuuji@0	200 NIL, /* unique identifier */
yuuji@0	201 NIL, /* message number */
yuuji@0	202 mix_flag, /* modify flags */
yuuji@0	203 NIL, /* per-message modify flags */
yuuji@0	204 NIL, /* search for message based on criteria */
yuuji@0	205 mix_sort, /* sort messages */
yuuji@0	206 mix_thread, /* thread messages */
yuuji@0	207 mix_ping, /* ping mailbox to see if still alive */
yuuji@0	208 mix_check, /* check for new messages */
yuuji@0	209 mix_expunge, /* expunge deleted messages */
yuuji@0	210 mix_copy, /* copy messages to another mailbox */
yuuji@0	211 mix_append, /* append string message to mailbox */
yuuji@0	212 NIL /* garbage collect stream */
yuuji@0	213 };
yuuji@0	214
yuuji@0	215 /* prototype stream */
yuuji@0	216 MAILSTREAM mixproto = {&mixdriver};
yuuji@0	217
yuuji@0	218 /* MIX mail validate mailbox
yuuji@0	219 * Accepts: mailbox name
yuuji@0	220 * Returns: our driver if name is valid, NIL otherwise
yuuji@0	221 */
yuuji@0	222
yuuji@0	223 DRIVER mix_valid (char name)
yuuji@0	224 {
yuuji@0	225 char tmp[MAILTMPLEN];
yuuji@0	226 return mix_isvalid (name,tmp) ? &mixdriver : NIL;
yuuji@0	227 }
yuuji@0	228
yuuji@0	229
yuuji@0	230 /* MIX mail test for valid mailbox
yuuji@0	231 * Accepts: mailbox name
yuuji@0	232 * buffer to return meta name
yuuji@0	233 * Returns: T if valid, NIL otherwise, metadata name written in both cases
yuuji@0	234 */
yuuji@0	235
yuuji@0	236 long mix_isvalid (char name,char meta)
yuuji@0	237 {
yuuji@0	238 char dir[MAILTMPLEN];
yuuji@0	239 struct stat sbuf;
yuuji@0	240 /* validate name as directory */
yuuji@0	241 if (!(errno = ((strlen (name) > NETMAXMBX) ? ENAMETOOLONG : NIL)) &&
yuuji@0	242 *mix_dir (dir,name) && mix_file (meta,dir,MIXMETA) &&
yuuji@0	243 !stat (dir,&sbuf) && ((sbuf.st_mode & S_IFMT) == S_IFDIR)) {
yuuji@0	244 /* name is directory; is it mix? */
yuuji@0	245 if (!stat (meta,&sbuf) && ((sbuf.st_mode & S_IFMT) == S_IFREG))
yuuji@0	246 return LONGT;
yuuji@0	247 else errno = NIL; /* directory but not mix */
yuuji@0	248 }
yuuji@0	249 return NIL;
yuuji@0	250 }
yuuji@0	251
yuuji@0	252 /* MIX manipulate driver parameters
yuuji@0	253 * Accepts: function code
yuuji@0	254 * function-dependent value
yuuji@0	255 * Returns: function-dependent return value
yuuji@0	256 */
yuuji@0	257
yuuji@0	258 void mix_parameters (long function,void value)
yuuji@0	259 {
yuuji@0	260 void *ret = NIL;
yuuji@0	261 switch ((int) function) {
yuuji@0	262 case GET_INBOXPATH:
yuuji@0	263 if (value) ret = mailboxfile ((char *) value,"~/INBOX");
yuuji@0	264 break;
yuuji@0	265 case GET_DIRFMTTEST:
yuuji@0	266 ret = (void *) mix_dirfmttest;
yuuji@0	267 break;
yuuji@0	268 case GET_SCANCONTENTS:
yuuji@0	269 ret = (void *) mix_scan_contents;
yuuji@0	270 break;
yuuji@0	271 case SET_ONETIMEEXPUNGEATPING:
yuuji@0	272 if (value) ((MIXLOCAL ) ((MAILSTREAM ) value)->local)->expok = T;
yuuji@0	273 case GET_ONETIMEEXPUNGEATPING:
yuuji@0	274 if (value) ret = (void *)
yuuji@0	275 (((MIXLOCAL ) ((MAILSTREAM ) value)->local)->expok ? VOIDT : NIL);
yuuji@0	276 break;
yuuji@0	277 }
yuuji@0	278 return ret;
yuuji@0	279 }
yuuji@0	280
yuuji@0	281
yuuji@0	282 /* MIX test for directory format internal node
yuuji@0	283 * Accepts: candidate node name
yuuji@0	284 * Returns: T if internal name, NIL otherwise
yuuji@0	285 */
yuuji@0	286
yuuji@0	287 long mix_dirfmttest (char *name)
yuuji@0	288 {
yuuji@0	289 /* belongs to MIX if starts with .mix */
yuuji@0	290 return strncmp (name,MIXNAME,sizeof (MIXNAME) - 1) ? NIL : LONGT;
yuuji@0	291 }
yuuji@0	292
yuuji@0	293 /* MIX mail scan mailboxes
yuuji@0	294 * Accepts: mail stream
yuuji@0	295 * reference
yuuji@0	296 * pattern to search
yuuji@0	297 * string to scan
yuuji@0	298 */
yuuji@0	299
yuuji@0	300 void mix_scan (MAILSTREAM stream,char ref,char pat,char contents)
yuuji@0	301 {
yuuji@0	302 if (stream) dummy_scan (NIL,ref,pat,contents);
yuuji@0	303 }
yuuji@0	304
yuuji@0	305
yuuji@0	306 /* MIX scan mailbox for contents
yuuji@0	307 * Accepts: mailbox name
yuuji@0	308 * desired contents
yuuji@0	309 * contents size
yuuji@0	310 * file size (ignored)
yuuji@0	311 * Returns: NIL if contents not found, T if found
yuuji@0	312 */
yuuji@0	313
yuuji@0	314 long mix_scan_contents (char name,char contents,unsigned long csiz,
yuuji@0	315 unsigned long fsiz)
yuuji@0	316 {
yuuji@0	317 long i,nfiles;
yuuji@0	318 void *a;
yuuji@0	319 char *s;
yuuji@0	320 long ret = NIL;
yuuji@0	321 size_t namelen = strlen (name);
yuuji@0	322 struct stat sbuf;
yuuji@0	323 struct direct **names = NIL;
yuuji@0	324 if ((nfiles = scandir (name,&names,mix_select,mix_msgfsort)) > 0)
yuuji@0	325 for (i = 0; i < nfiles; ++i) {
yuuji@0	326 if (!ret) {
yuuji@0	327 sprintf (s = (char *) fs_get (namelen + strlen (names[i]->d_name) + 2),
yuuji@0	328 "%s/%s",name,names[i]->d_name);
yuuji@0	329 if (!stat (s,&sbuf) && (csiz <= sbuf.st_size))
yuuji@0	330 ret = dummy_scan_contents (s,contents,csiz,sbuf.st_size);
yuuji@0	331 fs_give ((void **) &s);
yuuji@0	332 }
yuuji@0	333 fs_give ((void **) &names[i]);
yuuji@0	334 }
yuuji@0	335 /* free directory list */
yuuji@0	336 if (a = (void ) names) fs_give ((void *) &a);
yuuji@0	337 return ret;
yuuji@0	338 }
yuuji@0	339
yuuji@0	340 /* MIX list mailboxes
yuuji@0	341 * Accepts: mail stream
yuuji@0	342 * reference
yuuji@0	343 * pattern to search
yuuji@0	344 */
yuuji@0	345
yuuji@0	346 void mix_list (MAILSTREAM stream,char ref,char *pat)
yuuji@0	347 {
yuuji@0	348 if (stream) dummy_list (NIL,ref,pat);
yuuji@0	349 }
yuuji@0	350
yuuji@0	351
yuuji@0	352 /* MIX list subscribed mailboxes
yuuji@0	353 * Accepts: mail stream
yuuji@0	354 * reference
yuuji@0	355 * pattern to search
yuuji@0	356 */
yuuji@0	357
yuuji@0	358 void mix_lsub (MAILSTREAM stream,char ref,char *pat)
yuuji@0	359 {
yuuji@0	360 if (stream) dummy_lsub (NIL,ref,pat);
yuuji@0	361 }
yuuji@0	362
yuuji@0	363 /* MIX mail subscribe to mailbox
yuuji@0	364 * Accepts: mail stream
yuuji@0	365 * mailbox to add to subscription list
yuuji@0	366 * Returns: T on success, NIL on failure
yuuji@0	367 */
yuuji@0	368
yuuji@0	369 long mix_subscribe (MAILSTREAM stream,char mailbox)
yuuji@0	370 {
yuuji@0	371 return sm_subscribe (mailbox);
yuuji@0	372 }
yuuji@0	373
yuuji@0	374
yuuji@0	375 /* MIX mail unsubscribe to mailbox
yuuji@0	376 * Accepts: mail stream
yuuji@0	377 * mailbox to delete from subscription list
yuuji@0	378 * Returns: T on success, NIL on failure
yuuji@0	379 */
yuuji@0	380
yuuji@0	381 long mix_unsubscribe (MAILSTREAM stream,char mailbox)
yuuji@0	382 {
yuuji@0	383 return sm_unsubscribe (mailbox);
yuuji@0	384 }
yuuji@0	385
yuuji@0	386 /* MIX mail create mailbox
yuuji@0	387 * Accepts: mail stream
yuuji@0	388 * mailbox name to create
yuuji@0	389 * Returns: T on success, NIL on failure
yuuji@0	390 */
yuuji@0	391
yuuji@0	392 long mix_create (MAILSTREAM stream,char mailbox)
yuuji@0	393 {
yuuji@0	394 DRIVER *test;
yuuji@0	395 FILE *f;
yuuji@0	396 int c,i;
yuuji@0	397 char *t,tmp[MAILTMPLEN],file[MAILTMPLEN];
yuuji@0	398 char *s = strrchr (mailbox,'/');
yuuji@0	399 unsigned long now = time (NIL);
yuuji@0	400 long ret = NIL;
yuuji@0	401 /* always create \NoSelect if trailing / */
yuuji@0	402 if (s && !s[1]) return dummy_create (stream,mailbox);
yuuji@0	403 /* validate name */
yuuji@0	404 if (mix_dirfmttest (s ? s + 1 : mailbox))
yuuji@0	405 sprintf(tmp,"Can't create mailbox %.80s: invalid MIX-format name",mailbox);
yuuji@0	406 /* must not already exist */
yuuji@0	407 else if ((test = mail_valid (NIL,mailbox,NIL)) &&
yuuji@0	408 strcmp (test->name,"dummy"))
yuuji@0	409 sprintf (tmp,"Can't create mailbox %.80s: mailbox already exists",mailbox);
yuuji@0	410 /* create directory and metadata */
yuuji@0	411 else if (!dummy_create_path (stream,
yuuji@0	412 mix_file (file,mix_dir (tmp,mailbox),MIXMETA),
yuuji@0	413 get_dir_protection (mailbox)))
yuuji@0	414 sprintf (tmp,"Can't create mailbox %.80s: %.80s",mailbox,strerror (errno));
yuuji@0	415 else if (!(f = fopen (file,"w")))
yuuji@0	416 sprintf (tmp,"Can't re-open metadata %.80s: %.80s",mailbox,
yuuji@0	417 strerror (errno));
yuuji@0	418 else { /* success, write initial metadata */
yuuji@0	419 fprintf (f,SEQFMT,now);
yuuji@0	420 fprintf (f,MTAFMT,now,0,now);
yuuji@0	421 for (i = 0, c = 'K'; (i < NUSERFLAGS) &&
yuuji@0	422 (t = (stream && stream->user_flags[i]) ? stream->user_flags[i] :
yuuji@0	423 default_user_flag (i)) && *t; ++i) {
yuuji@0	424 putc (c,f); /* write another keyword */
yuuji@0	425 fputs (t,f);
yuuji@0	426 c = ' '; /* delimiter is now space */
yuuji@0	427 }
yuuji@0	428 fclose (f);
yuuji@0	429 set_mbx_protections (mailbox,file);
yuuji@0	430 /* point to suffix */
yuuji@0	431 s = file + strlen (file) - (sizeof (MIXMETA) - 1);
yuuji@0	432 strcpy (s,MIXINDEX); /* create index */
yuuji@0	433 if (!dummy_create_path (stream,file,get_dir_protection (mailbox)))
yuuji@0	434 sprintf (tmp,"Can't create mix mailbox index: %.80s",strerror (errno));
yuuji@0	435 else {
yuuji@0	436 set_mbx_protections (mailbox,file);
yuuji@0	437 strcpy (s,MIXSTATUS); /* create status */
yuuji@0	438 if (!dummy_create_path (stream,file,get_dir_protection (mailbox)))
yuuji@0	439 sprintf (tmp,"Can't create mix mailbox status: %.80s",
yuuji@0	440 strerror (errno));
yuuji@0	441 else {
yuuji@0	442 set_mbx_protections (mailbox,file);
yuuji@0	443 sprintf (s,"%08lx",now);/* message file */
yuuji@0	444 if (!dummy_create_path (stream,file,get_dir_protection (mailbox)))
yuuji@0	445 sprintf (tmp,"Can't create mix mailbox data: %.80s",
yuuji@0	446 strerror (errno));
yuuji@0	447 else {
yuuji@0	448 set_mbx_protections (mailbox,file);
yuuji@0	449 ret = LONGT; /* declare success at this point */
yuuji@0	450 }
yuuji@0	451 }
yuuji@0	452 }
yuuji@0	453 }
yuuji@0	454 if (!ret) MM_LOG (tmp,ERROR); /* some error */
yuuji@0	455 return ret;
yuuji@0	456 }
yuuji@0	457
yuuji@0	458 /* MIX mail delete mailbox
yuuji@0	459 * mailbox name to delete
yuuji@0	460 * Returns: T on success, NIL on failure
yuuji@0	461 */
yuuji@0	462
yuuji@0	463 long mix_delete (MAILSTREAM stream,char mailbox)
yuuji@0	464 {
yuuji@0	465 DIR *dirp;
yuuji@0	466 struct direct *d;
yuuji@0	467 int fd = -1;
yuuji@0	468 char *s,tmp[MAILTMPLEN];
yuuji@0	469 if (!mix_isvalid (mailbox,tmp))
yuuji@0	470 sprintf (tmp,"Can't delete mailbox %.80s: no such mailbox",mailbox);
yuuji@0	471 else if (((fd = open (tmp,O_RDWR,NIL)) < 0) \|\| flock (fd,LOCK_EX\|LOCK_NB))
yuuji@0	472 sprintf (tmp,"Can't lock mailbox for delete: %.80s",mailbox);
yuuji@0	473 /* delete metadata */
yuuji@0	474 else if (unlink (tmp)) sprintf (tmp,"Can't delete mailbox %.80s index: %80s",
yuuji@0	475 mailbox,strerror (errno));
yuuji@0	476 else {
yuuji@0	477 close (fd); /* close descriptor on deleted metadata */
yuuji@0	478 /* get directory name */
yuuji@0	479 *(s = strrchr (tmp,'/')) = '\0';
yuuji@0	480 if (dirp = opendir (tmp)) { /* open directory */
yuuji@0	481 s++ = '/'; / restore delimiter */
yuuji@0	482 /* massacre messages */
yuuji@0	483 while (d = readdir (dirp)) if (mix_dirfmttest (d->d_name)) {
yuuji@0	484 strcpy (s,d->d_name); /* make path */
yuuji@0	485 unlink (tmp); /* sayonara */
yuuji@0	486 }
yuuji@0	487 closedir (dirp); /* flush directory */
yuuji@0	488 *(s = strrchr (tmp,'/')) = '\0';
yuuji@0	489 if (rmdir (tmp)) { /* try to remove the directory */
yuuji@0	490 sprintf (tmp,"Can't delete name %.80s: %.80s",
yuuji@0	491 mailbox,strerror (errno));
yuuji@0	492 MM_LOG (tmp,WARN);
yuuji@0	493 }
yuuji@0	494 }
yuuji@0	495 return T; /* always success */
yuuji@0	496 }
yuuji@0	497 if (fd >= 0) close (fd); /* close any descriptor on metadata */
yuuji@0	498 MM_LOG (tmp,ERROR); /* something failed */
yuuji@0	499 return NIL;
yuuji@0	500 }
yuuji@0	501
yuuji@0	502 /* MIX mail rename mailbox
yuuji@0	503 * Accepts: MIX mail stream
yuuji@0	504 * old mailbox name
yuuji@0	505 * new mailbox name
yuuji@0	506 * Returns: T on success, NIL on failure
yuuji@0	507 */
yuuji@0	508
yuuji@0	509 long mix_rename (MAILSTREAM stream,char old,char *newname)
yuuji@0	510 {
yuuji@0	511 char c,*s,tmp[MAILTMPLEN],tmp1[MAILTMPLEN];
yuuji@0	512 struct stat sbuf;
yuuji@0	513 int fd = -1;
yuuji@0	514 if (!mix_isvalid (old,tmp))
yuuji@0	515 sprintf (tmp,"Can't rename mailbox %.80s: no such mailbox",old);
yuuji@0	516 else if (((fd = open (tmp,O_RDWR,NIL)) < 0) \|\| flock (fd,LOCK_EX\|LOCK_NB))
yuuji@0	517 sprintf (tmp,"Can't lock mailbox for rename: %.80s",old);
yuuji@0	518 else if (mix_dirfmttest ((s = strrchr (newname,'/')) ? s + 1 : newname))
yuuji@0	519 sprintf (tmp,"Can't rename to mailbox %.80s: invalid MIX-format name",
yuuji@0	520 newname);
yuuji@0	521 /* new mailbox name must not be valid */
yuuji@0	522 else if (mix_isvalid (newname,tmp))
yuuji@0	523 sprintf (tmp,"Can't rename to mailbox %.80s: destination already exists",
yuuji@0	524 newname);
yuuji@0	525 else {
yuuji@0	526 mix_dir (tmp,old); /* build old directory name */
yuuji@0	527 mix_dir (tmp1,newname); /* and new directory name */
yuuji@0	528 /* easy if not INBOX */
yuuji@0	529 if (compare_cstring (old,"INBOX")) {
yuuji@0	530 /* found superior to destination name? */
yuuji@0	531 if (s = strrchr (tmp1,'/')) {
yuuji@0	532 c = ++s; / remember first character of inferior */
yuuji@0	533 s = '\0'; / tie off to get just superior */
yuuji@0	534 /* name doesn't exist, create it */
yuuji@0	535 if ((stat (tmp1,&sbuf) \|\| ((sbuf.st_mode & S_IFMT) != S_IFDIR)) &&
yuuji@0	536 !dummy_create_path (stream,tmp1,get_dir_protection (newname)))
yuuji@0	537 return NIL;
yuuji@0	538 s = c; / restore full name */
yuuji@0	539 }
yuuji@0	540 if (!rename (tmp,tmp1)) {
yuuji@0	541 close (fd); /* close descriptor on metadata */
yuuji@0	542 return LONGT;
yuuji@0	543 }
yuuji@0	544 }
yuuji@0	545
yuuji@0	546 /* RFC 3501 requires this */
yuuji@0	547 else if (dummy_create_path (stream,strcat (tmp1,"/"),
yuuji@0	548 get_dir_protection (newname))) {
yuuji@0	549 void *a;
yuuji@0	550 int i,n,lasterror;
yuuji@0	551 char src,dst;
yuuji@0	552 struct direct **names = NIL;
yuuji@0	553 size_t srcl = strlen (tmp);
yuuji@0	554 size_t dstl = strlen (tmp1);
yuuji@0	555 /* rename each mix file to new directory */
yuuji@0	556 for (i = lasterror = 0,n = scandir (tmp,&names,mix_rselect,alphasort);
yuuji@0	557 i < n; ++i) {
yuuji@0	558 size_t len = strlen (names[i]->d_name);
yuuji@0	559 sprintf (src = (char *) fs_get (srcl + len + 2),"%s/%s",
yuuji@0	560 tmp,names[i]->d_name);
yuuji@0	561 sprintf (dst = (char *) fs_get (dstl + len + 1),"%s%s",
yuuji@0	562 tmp1,names[i]->d_name);
yuuji@0	563 if (rename (src,dst)) lasterror = errno;
yuuji@0	564 fs_give ((void **) &src);
yuuji@0	565 fs_give ((void **) &dst);
yuuji@0	566 fs_give ((void **) &names[i]);
yuuji@0	567 }
yuuji@0	568 /* free directory list */
yuuji@0	569 if (a = (void ) names) fs_give ((void *) &a);
yuuji@0	570 if (lasterror) errno = lasterror;
yuuji@0	571 else {
yuuji@0	572 close (fd); /* close descriptor on metadata */
yuuji@0	573 return mix_create (NIL,"INBOX");
yuuji@0	574 }
yuuji@0	575 }
yuuji@0	576 sprintf (tmp,"Can't rename mailbox %.80s to %.80s: %.80s",
yuuji@0	577 old,newname,strerror (errno));
yuuji@0	578 }
yuuji@0	579 if (fd >= 0) close (fd); /* close any descriptor on metadata */
yuuji@0	580 MM_LOG (tmp,ERROR); /* something failed */
yuuji@0	581 return NIL;
yuuji@0	582 }
yuuji@0	583
yuuji@0	584
yuuji@0	585 /* MIX test for mix name
yuuji@0	586 * Accepts: candidate directory name
yuuji@0	587 * Returns: T if mix file name, NIL otherwise
yuuji@0	588 */
yuuji@0	589
yuuji@0	590 int mix_rselect (struct direct *name)
yuuji@0	591 {
yuuji@0	592 return mix_dirfmttest (name->d_name);
yuuji@0	593 }
yuuji@0	594
yuuji@0	595 /* MIX mail open
yuuji@0	596 * Accepts: stream to open
yuuji@0	597 * Returns: stream on success, NIL on failure
yuuji@0	598 */
yuuji@0	599
yuuji@0	600 MAILSTREAM mix_open (MAILSTREAM stream)
yuuji@0	601 {
yuuji@0	602 short silent;
yuuji@0	603 /* return prototype for OP_PROTOTYPE call */
yuuji@0	604 if (!stream) return user_flags (&mixproto);
yuuji@0	605 if (stream->local) fatal ("mix recycle stream");
yuuji@0	606 stream->local = memset (fs_get (sizeof (MIXLOCAL)),0,sizeof (MIXLOCAL));
yuuji@0	607 /* note if an INBOX or not */
yuuji@0	608 stream->inbox = !compare_cstring (stream->mailbox,"INBOX");
yuuji@0	609 /* make temporary buffer */
yuuji@0	610 LOCAL->buf = (char *) fs_get (CHUNKSIZE);
yuuji@0	611 LOCAL->buflen = CHUNKSIZE - 1;
yuuji@0	612 /* set stream->mailbox to be directory name */
yuuji@0	613 mix_dir (LOCAL->buf,stream->mailbox);
yuuji@0	614 fs_give ((void **) &stream->mailbox);
yuuji@0	615 stream->mailbox = cpystr (LOCAL->buf);
yuuji@0	616 LOCAL->msgfd = -1; /* currently no file open */
yuuji@0	617 if (!(((!stream->rdonly && /* open metadata file */
yuuji@0	618 ((LOCAL->mfd = open (mix_file (LOCAL->buf,stream->mailbox,MIXMETA),
yuuji@0	619 O_RDWR,NIL)) >= 0)) \|\|
yuuji@0	620 ((stream->rdonly = T) &&
yuuji@0	621 ((LOCAL->mfd = open (mix_file (LOCAL->buf,stream->mailbox,MIXMETA),
yuuji@0	622 O_RDONLY,NIL)) >= 0))) &&
yuuji@0	623 !flock (LOCAL->mfd,LOCK_SH))) {
yuuji@0	624 MM_LOG ("Error opening mix metadata file",ERROR);
yuuji@0	625 mix_abort (stream);
yuuji@0	626 stream = NIL; /* open fails */
yuuji@0	627 }
yuuji@0	628 else { /* metadata open, complete open */
yuuji@0	629 LOCAL->index = cpystr (mix_file (LOCAL->buf,stream->mailbox,MIXINDEX));
yuuji@0	630 LOCAL->status = cpystr (mix_file (LOCAL->buf,stream->mailbox,MIXSTATUS));
yuuji@0	631 LOCAL->sortcache = cpystr (mix_file (LOCAL->buf,stream->mailbox,
yuuji@0	632 MIXSORTCACHE));
yuuji@0	633 stream->sequence++; /* bump sequence number */
yuuji@0	634 /* parse mailbox */
yuuji@0	635 stream->nmsgs = stream->recent = 0;
yuuji@0	636 if (silent = stream->silent) LOCAL->internal = T;
yuuji@0	637 stream->silent = T;
yuuji@0	638 if (mix_ping (stream)) { /* do initial ping */
yuuji@0	639 /* try burping in case we are exclusive */
yuuji@0	640 if (!stream->rdonly) mix_expunge (stream,"",NIL);
yuuji@0	641 if (!(stream->nmsgs \|\| stream->silent))
yuuji@0	642 MM_LOG ("Mailbox is empty",(long) NIL);
yuuji@0	643 stream->silent = silent; /* now notify upper level */
yuuji@0	644 mail_exists (stream,stream->nmsgs);
yuuji@0	645 stream->perm_seen = stream->perm_deleted = stream->perm_flagged =
yuuji@0	646 stream->perm_answered = stream->perm_draft = stream->rdonly ? NIL : T;
yuuji@0	647 stream->perm_user_flags = stream->rdonly ? NIL : 0xffffffff;
yuuji@0	648 stream->kwd_create = /* can we create new user flags? */
yuuji@0	649 (stream->user_flags[NUSERFLAGS-1] \|\| stream->rdonly) ? NIL : T;
yuuji@0	650 }
yuuji@0	651 else { /* got murdelyzed in ping */
yuuji@0	652 mix_abort (stream);
yuuji@0	653 stream = NIL;
yuuji@0	654 }
yuuji@0	655 }
yuuji@0	656 return stream; /* return stream to caller */
yuuji@0	657 }
yuuji@0	658
yuuji@0	659 /* MIX mail close
yuuji@0	660 * Accepts: MAIL stream
yuuji@0	661 * close options
yuuji@0	662 */
yuuji@0	663
yuuji@0	664 void mix_close (MAILSTREAM *stream,long options)
yuuji@0	665 {
yuuji@0	666 if (LOCAL) { /* only if a file is open */
yuuji@0	667 int silent = stream->silent;
yuuji@0	668 stream->silent = T; /* note this stream is dying */
yuuji@0	669 /* burp-only or expunge */
yuuji@0	670 mix_expunge (stream,(options & CL_EXPUNGE) ? NIL : "",NIL);
yuuji@0	671 mix_abort (stream);
yuuji@0	672 stream->silent = silent; /* reset silent state */
yuuji@0	673 }
yuuji@0	674 }
yuuji@0	675
yuuji@0	676
yuuji@0	677 /* MIX mail abort stream
yuuji@0	678 * Accepts: MAIL stream
yuuji@0	679 */
yuuji@0	680
yuuji@0	681 void mix_abort (MAILSTREAM *stream)
yuuji@0	682 {
yuuji@0	683 if (LOCAL) { /* only if a file is open */
yuuji@0	684 /* close current message file if open */
yuuji@0	685 if (LOCAL->msgfd >= 0) close (LOCAL->msgfd);
yuuji@0	686 /* close current metadata file if open */
yuuji@0	687 if (LOCAL->mfd >= 0) close (LOCAL->mfd);
yuuji@0	688 if (LOCAL->index) fs_give ((void **) &LOCAL->index);
yuuji@0	689 if (LOCAL->status) fs_give ((void **) &LOCAL->status);
yuuji@0	690 if (LOCAL->sortcache) fs_give ((void **) &LOCAL->sortcache);
yuuji@0	691 /* free local scratch buffer */
yuuji@0	692 if (LOCAL->buf) fs_give ((void **) &LOCAL->buf);
yuuji@0	693 /* nuke the local data */
yuuji@0	694 fs_give ((void **) &stream->local);
yuuji@0	695 stream->dtb = NIL; /* log out the DTB */
yuuji@0	696 }
yuuji@0	697 }
yuuji@0	698
yuuji@0	699 /* MIX mail fetch message header
yuuji@0	700 * Accepts: MAIL stream
yuuji@0	701 * message # to fetch
yuuji@0	702 * pointer to returned header text length
yuuji@0	703 * option flags
yuuji@0	704 * Returns: message header in RFC822 format
yuuji@0	705 */
yuuji@0	706
yuuji@0	707 char mix_header (MAILSTREAM stream,unsigned long msgno,unsigned long *length,
yuuji@0	708 long flags)
yuuji@0	709 {
yuuji@0	710 unsigned long i,j,k;
yuuji@0	711 int fd;
yuuji@0	712 char *s,tmp[MAILTMPLEN];
yuuji@0	713 MESSAGECACHE *elt;
yuuji@0	714 if (length) length = 0; / default return */
yuuji@0	715 if (flags & FT_UID) return "";/* UID call "impossible" */
yuuji@0	716 elt = mail_elt (stream,msgno);/* get elt */
yuuji@0	717 /* is message in current message file? */
yuuji@0	718 if ((LOCAL->msgfd < 0) \|\| (elt->private.spare.data != LOCAL->curmsg)) {
yuuji@0	719 if (LOCAL->msgfd >= 0) close (LOCAL->msgfd);
yuuji@0	720 if ((LOCAL->msgfd = open (mix_file_data (LOCAL->buf,stream->mailbox,
yuuji@0	721 elt->private.spare.data),
yuuji@0	722 O_RDONLY,NIL)) < 0) return "";
yuuji@0	723 /* got file */
yuuji@0	724 LOCAL->curmsg = elt->private.spare.data;
yuuji@0	725 }
yuuji@0	726 lseek (LOCAL->msgfd,elt->private.special.offset,L_SET);
yuuji@0	727 /* size of special data and header */
yuuji@0	728 j = elt->private.msg.header.offset + elt->private.msg.header.text.size;
yuuji@0	729 if (j > LOCAL->buflen) { /* is buffer big enough? */
yuuji@0	730 /* no, make one that is */
yuuji@0	731 fs_give ((void **) &LOCAL->buf);
yuuji@0	732 LOCAL->buf = (char *) fs_get ((LOCAL->buflen = j) + 1);
yuuji@0	733 }
yuuji@0	734 /* Maybe someday validate internaldate too */
yuuji@0	735 /* slurp special data + header, validate */
yuuji@0	736 if ((read (LOCAL->msgfd,LOCAL->buf,j) == j) &&
yuuji@0	737 !strncmp (LOCAL->buf,MSGTOK,MSGTSZ) &&
yuuji@0	738 (elt->private.uid == strtoul ((char *) LOCAL->buf + MSGTSZ,&s,16)) &&
yuuji@0	739 (*s++ == ':') && (s = strchr (s,':')) &&
yuuji@0	740 (k = strtoul (s+1,&s,16)) && (*s++ == ':') &&
yuuji@0	741 (s < (char *) (LOCAL->buf + elt->private.msg.header.offset))) {
yuuji@0	742 /* won, set offset and size of message */
yuuji@0	743 i = elt->private.msg.header.offset;
yuuji@0	744 *length = elt->private.msg.header.text.size;
yuuji@0	745 if (k != elt->rfc822_size) {
yuuji@0	746 sprintf (tmp,"Inconsistency in mix message size, uid=%lx (%lu != %lu)",
yuuji@0	747 elt->private.uid,elt->rfc822_size,k);
yuuji@0	748 MM_LOG (tmp,WARN);
yuuji@0	749 }
yuuji@0	750 }
yuuji@0	751 else { /* document the problem */
yuuji@0	752 LOCAL->buf[100] = '\0'; /* tie off buffer at no more than 100 octets */
yuuji@0	753 /* or at newline, whichever is first */
yuuji@0	754 if (s = strpbrk (LOCAL->buf,"\015\012")) *s = '\0';
yuuji@0	755 sprintf (tmp,"Error reading mix message header, uid=%lx, s=%.0lx, h=%s",
yuuji@0	756 elt->private.uid,elt->rfc822_size,LOCAL->buf);
yuuji@0	757 MM_LOG (tmp,ERROR);
yuuji@0	758 length = i = j = 0; / default to empty */
yuuji@0	759 }
yuuji@0	760 LOCAL->buf[j] = '\0'; /* tie off buffer at the end */
yuuji@0	761 return (char *) LOCAL->buf + i;
yuuji@0	762 }
yuuji@0	763
yuuji@0	764 /* MIX mail fetch message text (body only)
yuuji@0	765 * Accepts: MAIL stream
yuuji@0	766 * message # to fetch
yuuji@0	767 * pointer to returned stringstruct
yuuji@0	768 * option flags
yuuji@0	769 * Returns: T on success, NIL on failure
yuuji@0	770 */
yuuji@0	771
yuuji@0	772 long mix_text (MAILSTREAM stream,unsigned long msgno,STRING bs,long flags)
yuuji@0	773 {
yuuji@0	774 unsigned long i;
yuuji@0	775 FDDATA d;
yuuji@0	776 MESSAGECACHE *elt;
yuuji@0	777 /* UID call "impossible" */
yuuji@0	778 if (flags & FT_UID) return NIL;
yuuji@0	779 elt = mail_elt (stream,msgno);
yuuji@0	780 /* is message in current message file? */
yuuji@0	781 if ((LOCAL->msgfd < 0) \|\| (elt->private.spare.data != LOCAL->curmsg)) {
yuuji@0	782 if (LOCAL->msgfd >= 0) close (LOCAL->msgfd);
yuuji@0	783 if ((LOCAL->msgfd = open (mix_file_data (LOCAL->buf,stream->mailbox,
yuuji@0	784 elt->private.spare.data),
yuuji@0	785 O_RDONLY,NIL)) < 0) return NIL;
yuuji@0	786 /* got file */
yuuji@0	787 LOCAL->curmsg = elt->private.spare.data;
yuuji@0	788 }
yuuji@0	789 /* doing non-peek fetch? */
yuuji@0	790 if (!(flags & FT_PEEK) && !elt->seen) {
yuuji@0	791 FILE idxf; / yes, process metadata/index/status */
yuuji@0	792 FILE *statf = mix_parse (stream,&idxf,NIL,LONGT);
yuuji@0	793 elt->seen = T; /* mark as seen */
yuuji@0	794 MM_FLAGS (stream,elt->msgno);
yuuji@0	795 /* update status file if possible */
yuuji@0	796 if (statf && !stream->rdonly) {
yuuji@0	797 elt->private.mod = LOCAL->statusseq = mix_modseq (LOCAL->statusseq);
yuuji@0	798 mix_status_update (stream,statf,NIL);
yuuji@0	799 }
yuuji@0	800 if (idxf) fclose (idxf); /* release index and status file */
yuuji@0	801 if (statf) fclose (statf);
yuuji@0	802 }
yuuji@0	803 d.fd = LOCAL->msgfd; /* set up file descriptor */
yuuji@0	804 /* offset of message text */
yuuji@0	805 d.pos = elt->private.special.offset + elt->private.msg.header.offset +
yuuji@0	806 elt->private.msg.header.text.size;
yuuji@0	807 d.chunk = LOCAL->buf; /* initial buffer chunk */
yuuji@0	808 d.chunksize = CHUNKSIZE; /* chunk size */
yuuji@0	809 INIT (bs,fd_string,&d,elt->rfc822_size - elt->private.msg.header.text.size);
yuuji@0	810 return T;
yuuji@0	811 }
yuuji@0	812
yuuji@0	813 /* MIX mail modify flags
yuuji@0	814 * Accepts: MAIL stream
yuuji@0	815 * sequence
yuuji@0	816 * flag(s)
yuuji@0	817 * option flags
yuuji@0	818 */
yuuji@0	819
yuuji@0	820 void mix_flag (MAILSTREAM stream,char sequence,char *flag,long flags)
yuuji@0	821 {
yuuji@0	822 MESSAGECACHE *elt;
yuuji@0	823 unsigned long i,uf,ffkey;
yuuji@0	824 long f;
yuuji@0	825 short nf;
yuuji@0	826 FILE *idxf;
yuuji@0	827 FILE *statf = mix_parse (stream,&idxf,NIL,LONGT);
yuuji@0	828 unsigned long seq = mix_modseq (LOCAL->statusseq);
yuuji@0	829 /* find first free key */
yuuji@0	830 for (ffkey = 0; (ffkey < NUSERFLAGS) && stream->user_flags[ffkey]; ++ffkey);
yuuji@0	831 /* parse sequence and flags */
yuuji@0	832 if (((flags & ST_UID) ? mail_uid_sequence (stream,sequence) :
yuuji@0	833 mail_sequence (stream,sequence)) &&
yuuji@0	834 ((f = mail_parse_flags (stream,flag,&uf)) \|\| uf)) {
yuuji@0	835 /* alter flags */
yuuji@0	836 for (i = 1,nf = (flags & ST_SET) ? T : NIL; i <= stream->nmsgs; i++)
yuuji@0	837 if ((elt = mail_elt (stream,i))->sequence) {
yuuji@0	838 struct { /* old flags */
yuuji@0	839 unsigned int seen : 1;
yuuji@0	840 unsigned int deleted : 1;
yuuji@0	841 unsigned int flagged : 1;
yuuji@0	842 unsigned int answered : 1;
yuuji@0	843 unsigned int draft : 1;
yuuji@0	844 unsigned long user_flags;
yuuji@0	845 } old;
yuuji@0	846 old.seen = elt->seen; old.deleted = elt->deleted;
yuuji@0	847 old.flagged = elt->flagged; old.answered = elt->answered;
yuuji@0	848 old.draft = elt->draft; old.user_flags = elt->user_flags;
yuuji@0	849 if (f&fSEEN) elt->seen = nf;
yuuji@0	850 if (f&fDELETED) elt->deleted = nf;
yuuji@0	851 if (f&fFLAGGED) elt->flagged = nf;
yuuji@0	852 if (f&fANSWERED) elt->answered = nf;
yuuji@0	853 if (f&fDRAFT) elt->draft = nf;
yuuji@0	854 /* user flags */
yuuji@0	855 if (flags & ST_SET) elt->user_flags \|= uf;
yuuji@0	856 else elt->user_flags &= ~uf;
yuuji@0	857 if ((old.seen != elt->seen) \|\| (old.deleted != elt->deleted) \|\|
yuuji@0	858 (old.flagged != elt->flagged) \|\|
yuuji@0	859 (old.answered != elt->answered) \|\| (old.draft != elt->draft) \|\|
yuuji@0	860 (old.user_flags != elt->user_flags)) {
yuuji@0	861 if (!stream->rdonly) elt->private.mod = LOCAL->statusseq = seq;
yuuji@0	862 MM_FLAGS (stream,elt->msgno);
yuuji@0	863 }
yuuji@0	864 }
yuuji@0	865 /* update status file after change */
yuuji@0	866 if (statf && (seq == LOCAL->statusseq))
yuuji@0	867 mix_status_update (stream,statf,NIL);
yuuji@0	868 /* update metadata if created a keyword */
yuuji@0	869 if ((ffkey < NUSERFLAGS) && stream->user_flags[ffkey] &&
yuuji@0	870 !mix_meta_update (stream))
yuuji@0	871 MM_LOG ("Error updating mix metadata after keyword creation",ERROR);
yuuji@0	872 }
yuuji@0	873 if (statf) fclose (statf); /* release status file if still open */
yuuji@0	874 if (idxf) fclose (idxf); /* release index file */
yuuji@0	875 }
yuuji@0	876
yuuji@0	877 /* MIX mail sort messages
yuuji@0	878 * Accepts: mail stream
yuuji@0	879 * character set
yuuji@0	880 * search program
yuuji@0	881 * sort program
yuuji@0	882 * option flags
yuuji@0	883 * Returns: vector of sorted message sequences or NIL if error
yuuji@0	884 */
yuuji@0	885
yuuji@0	886 unsigned long mix_sort (MAILSTREAM stream,char charset,SEARCHPGM spg,
yuuji@0	887 SORTPGM *pgm,long flags)
yuuji@0	888 {
yuuji@0	889 unsigned long *ret;
yuuji@0	890 FILE *sortcache = mix_sortcache_open (stream);
yuuji@0	891 ret = mail_sort_msgs (stream,charset,spg,pgm,flags);
yuuji@0	892 mix_sortcache_update (stream,&sortcache);
yuuji@0	893 return ret;
yuuji@0	894 }
yuuji@0	895
yuuji@0	896
yuuji@0	897 /* MIX mail thread messages
yuuji@0	898 * Accepts: mail stream
yuuji@0	899 * thread type
yuuji@0	900 * character set
yuuji@0	901 * search program
yuuji@0	902 * option flags
yuuji@0	903 * Returns: thread node tree or NIL if error
yuuji@0	904 */
yuuji@0	905
yuuji@0	906 THREADNODE mix_thread (MAILSTREAM stream,char type,char charset,
yuuji@0	907 SEARCHPGM *spg,long flags)
yuuji@0	908 {
yuuji@0	909 THREADNODE *ret;
yuuji@0	910 FILE *sortcache = mix_sortcache_open (stream);
yuuji@0	911 ret = mail_thread_msgs (stream,type,charset,spg,flags,mail_sort_msgs);
yuuji@0	912 mix_sortcache_update (stream,&sortcache);
yuuji@0	913 return ret;
yuuji@0	914 }
yuuji@0	915
yuuji@0	916 /* MIX mail ping mailbox
yuuji@0	917 * Accepts: MAIL stream
yuuji@0	918 * Returns: T if stream alive, else NIL
yuuji@0	919 */
yuuji@0	920
yuuji@0	921 static int snarfing = 0; /* lock against recursive snarfing */
yuuji@0	922
yuuji@0	923 long mix_ping (MAILSTREAM *stream)
yuuji@0	924 {
yuuji@0	925 FILE idxf,statf;
yuuji@0	926 struct stat sbuf;
yuuji@0	927 STRING msg;
yuuji@0	928 MESSAGECACHE *elt;
yuuji@0	929 int mfd,ifd,sfd;
yuuji@0	930 unsigned long i,msglen;
yuuji@0	931 char *message,date[MAILTMPLEN],flags[MAILTMPLEN];
yuuji@0	932 MAILSTREAM *sysibx = NIL;
yuuji@0	933 long ret = NIL;
yuuji@0	934 long snarfok = LONGT;
yuuji@0	935 /* time to snarf? */
yuuji@0	936 if (stream->inbox && !stream->rdonly && !snarfing &&
yuuji@0	937 (time (0) >= (LOCAL->lastsnarf +
yuuji@0	938 (time_t) mail_parameters (NIL,GET_SNARFINTERVAL,NIL)))) {
yuuji@0	939 appenduid_t au = (appenduid_t) mail_parameters (NIL,GET_APPENDUID,NIL);
yuuji@0	940 copyuid_t cu = (copyuid_t) mail_parameters (NIL,GET_COPYUID,NIL);
yuuji@0	941 MM_CRITICAL (stream); /* go critical */
yuuji@0	942 snarfing = T; /* don't recursively snarf */
yuuji@0	943 /* disable APPENDUID/COPYUID callbacks */
yuuji@0	944 mail_parameters (NIL,SET_APPENDUID,NIL);
yuuji@0	945 mail_parameters (NIL,SET_COPYUID,NIL);
yuuji@0	946 /* sizes match and anything in sysinbox? */
yuuji@0	947 if (!stat (sysinbox (),&sbuf) && ((sbuf.st_mode & S_IFMT) == S_IFREG) &&
yuuji@0	948 sbuf.st_size && (sysibx = mail_open (sysibx,sysinbox (),OP_SILENT)) &&
yuuji@0	949 !sysibx->rdonly && sysibx->nmsgs) {
yuuji@0	950 /* for each message in sysibx mailbox */
yuuji@0	951 for (i = 1; snarfok && (i <= sysibx->nmsgs); ++i)
yuuji@0	952 if (!(elt = mail_elt (sysibx,i))->deleted &&
yuuji@0	953 (message = mail_fetch_message (sysibx,i,&msglen,FT_PEEK)) &&
yuuji@0	954 msglen) {
yuuji@0	955 mail_date (date,elt); /* make internal date string */
yuuji@0	956 /* make flag string */
yuuji@0	957 flags[0] = flags[1] = '\0';
yuuji@0	958 if (elt->seen) strcat (flags," \\Seen");
yuuji@0	959 if (elt->flagged) strcat (flags," \\Flagged");
yuuji@0	960 if (elt->answered) strcat (flags," \\Answered");
yuuji@0	961 if (elt->draft) strcat (flags," \\Draft");
yuuji@0	962 flags[0] = '(';
yuuji@0	963 strcat (flags,")");
yuuji@0	964 INIT (&msg,mail_string,message,msglen);
yuuji@0	965 if (snarfok = mail_append_full (stream,"INBOX",flags,date,&msg)) {
yuuji@0	966 char sequence[15];
yuuji@0	967 sprintf (sequence,"%lu",i);
yuuji@0	968 mail_flag (sysibx,sequence,"\\Deleted",ST_SET);
yuuji@0	969 }
yuuji@0	970 }
yuuji@0	971
yuuji@0	972 /* now expunge all those messages */
yuuji@0	973 if (snarfok) mail_expunge (sysibx);
yuuji@0	974 else {
yuuji@0	975 sprintf (LOCAL->buf,"Can't copy new mail at message: %lu",i - 1);
yuuji@0	976 MM_LOG (LOCAL->buf,WARN);
yuuji@0	977 }
yuuji@0	978 }
yuuji@0	979 if (sysibx) mail_close (sysibx);
yuuji@0	980 /* reenable APPENDUID/COPYUID */
yuuji@0	981 mail_parameters (NIL,SET_APPENDUID,(void *) au);
yuuji@0	982 mail_parameters (NIL,SET_COPYUID,(void *) cu);
yuuji@0	983 snarfing = NIL; /* no longer snarfing */
yuuji@0	984 MM_NOCRITICAL (stream); /* release critical */
yuuji@0	985 LOCAL->lastsnarf = time (0);/* note time of last snarf */
yuuji@0	986 }
yuuji@0	987 /* expunging OK if global flag set */
yuuji@0	988 if (mail_parameters (NIL,GET_EXPUNGEATPING,NIL)) LOCAL->expok = T;
yuuji@0	989 /* process metadata/index/status */
yuuji@0	990 if (statf = mix_parse (stream,&idxf,LONGT,
yuuji@0	991 (LOCAL->internal ? NIL : LONGT))) {
yuuji@0	992 fclose (statf); /* just close the status file */
yuuji@0	993 ret = LONGT; /* declare success */
yuuji@0	994 }
yuuji@0	995 if (idxf) fclose (idxf); /* release index file */
yuuji@0	996 LOCAL->expok = NIL; /* expunge no longer OK */
yuuji@0	997 if (!ret) mix_abort (stream); /* murdelyze stream if ping fails */
yuuji@0	998 return ret;
yuuji@0	999 }
yuuji@0	1000
yuuji@0	1001
yuuji@0	1002 /* MIX mail checkpoint mailbox (burp only)
yuuji@0	1003 * Accepts: MAIL stream
yuuji@0	1004 */
yuuji@0	1005
yuuji@0	1006 void mix_check (MAILSTREAM *stream)
yuuji@0	1007 {
yuuji@0	1008 if (stream->rdonly) /* won't do on readonly files! */
yuuji@0	1009 MM_LOG ("Checkpoint ignored on readonly mailbox",NIL);
yuuji@0	1010 /* do burp-only expunge action */
yuuji@0	1011 if (mix_expunge (stream,"",NIL)) MM_LOG ("Check completed",(long) NIL);
yuuji@0	1012 }
yuuji@0	1013
yuuji@0	1014 /* MIX mail expunge mailbox
yuuji@0	1015 * Accepts: MAIL stream
yuuji@0	1016 * sequence to expunge if non-NIL, empty string for burp only
yuuji@0	1017 * expunge options
yuuji@0	1018 * Returns: T on success, NIL if failure
yuuji@0	1019 */
yuuji@0	1020
yuuji@0	1021 long mix_expunge (MAILSTREAM stream,char sequence,long options)
yuuji@0	1022 {
yuuji@0	1023 FILE *idxf = NIL;
yuuji@0	1024 FILE *statf = NIL;
yuuji@0	1025 MESSAGECACHE *elt;
yuuji@0	1026 int ifd,sfd;
yuuji@0	1027 long ret;
yuuji@0	1028 unsigned long i;
yuuji@0	1029 unsigned long nexp = 0;
yuuji@0	1030 unsigned long reclaimed = 0;
yuuji@0	1031 int burponly = (sequence && !*sequence);
yuuji@0	1032 LOCAL->expok = T; /* expunge during ping is OK */
yuuji@0	1033 if (!(ret = burponly \|\| !sequence \|\|
yuuji@0	1034 ((options & EX_UID) ?
yuuji@0	1035 mail_uid_sequence (stream,sequence) :
yuuji@0	1036 mail_sequence (stream,sequence))) \|\| stream->rdonly);
yuuji@0	1037 /* read index and open status exclusive */
yuuji@0	1038 else if (statf = mix_parse (stream,&idxf,LONGT,
yuuji@0	1039 LOCAL->internal ? NIL : LONGT)) {
yuuji@0	1040 /* expunge unless just burping */
yuuji@0	1041 if (!burponly) for (i = 1; i <= stream->nmsgs;) {
yuuji@0	1042 elt = mail_elt (stream,i);/* need to expunge this message? */
yuuji@0	1043 if (sequence ? elt->sequence : elt->deleted) {
yuuji@0	1044 ++nexp; /* yes, make it so */
yuuji@0	1045 mail_expunged (stream,i);
yuuji@0	1046 }
yuuji@0	1047 else ++i; /* otherwise advance to next message */
yuuji@0	1048 }
yuuji@0	1049
yuuji@0	1050 /* burp if can get exclusive access */
yuuji@0	1051 if (!flock (LOCAL->mfd,LOCK_EX\|LOCK_NB)) {
yuuji@0	1052 void *a;
yuuji@0	1053 struct direct **names = NIL;
yuuji@0	1054 long nfiles = scandir (stream->mailbox,&names,mix_select,mix_msgfsort);
yuuji@0	1055 if (nfiles > 0) { /* if have message files */
yuuji@0	1056 MIXBURP burp,cur;
yuuji@0	1057 /* initialize burp list */
yuuji@0	1058 for (i = 0, burp = cur = NIL; i < nfiles; ++i) {
yuuji@0	1059 MIXBURP nxt = (MIXBURP ) memset (fs_get (sizeof (MIXBURP)),0,
yuuji@0	1060 sizeof (MIXBURP));
yuuji@0	1061 /* another file found */
yuuji@0	1062 if (cur) cur = cur->next = nxt;
yuuji@0	1063 else cur = burp = nxt;
yuuji@0	1064 cur->name = names[i]->d_name;
yuuji@0	1065 cur->fileno = strtoul (cur->name + sizeof (MIXNAME) - 1,NIL,16);
yuuji@0	1066 cur->tail = &cur->set;
yuuji@0	1067 fs_give ((void **) &names[i]);
yuuji@0	1068 }
yuuji@0	1069 /* now load ranges */
yuuji@0	1070 for (i = 1, cur = burp; ret && (i <= stream->nmsgs); i++) {
yuuji@0	1071 /* is this message in current set? */
yuuji@0	1072 elt = mail_elt (stream,i);
yuuji@0	1073 if (cur && (elt->private.spare.data != cur->fileno)) {
yuuji@0	1074 /* restart if necessary */
yuuji@0	1075 if (elt->private.spare.data < cur->fileno) cur = burp;
yuuji@0	1076 /* hunt for appropriate mailbox */
yuuji@0	1077 while (cur && (elt->private.spare.data > cur->fileno))
yuuji@0	1078 cur = cur->next;
yuuji@0	1079 /* ought to have found it now... */
yuuji@0	1080 if (cur && (elt->private.spare.data != cur->fileno)) cur = NIL;
yuuji@0	1081 }
yuuji@0	1082 /* if found, add to set */
yuuji@0	1083 if (cur) ret = mix_addset (&cur->tail,elt->private.special.offset,
yuuji@0	1084 elt->private.msg.header.offset +
yuuji@0	1085 elt->rfc822_size);
yuuji@0	1086 else { /* uh-oh */
yuuji@0	1087 sprintf (LOCAL->buf,"Can't locate mix message file %.08lx",
yuuji@0	1088 elt->private.spare.data);
yuuji@0	1089 MM_LOG (LOCAL->buf,ERROR);
yuuji@0	1090 ret = NIL;
yuuji@0	1091 }
yuuji@0	1092 }
yuuji@0	1093 if (ret) /* if no errors, burp all files */
yuuji@0	1094 for (cur = burp; ret && cur; cur = cur->next) {
yuuji@0	1095 /* if non-empty, burp it */
yuuji@0	1096 if (cur->set.last) ret = mix_burp (stream,cur,&reclaimed);
yuuji@0	1097 /* empty, delete it unless new msg file */
yuuji@0	1098 else if (mix_file_data (LOCAL->buf,stream->mailbox,cur->fileno) &&
yuuji@0	1099 ((cur->fileno == LOCAL->newmsg) ?
yuuji@0	1100 truncate (LOCAL->buf,0) : unlink (LOCAL->buf))) {
yuuji@0	1101 sprintf (LOCAL->buf,
yuuji@0	1102 "Can't delete empty message file %.80s: %.80s",
yuuji@0	1103 cur->name,strerror (errno));
yuuji@0	1104 MM_LOG (LOCAL->buf,WARN);
yuuji@0	1105 }
yuuji@0	1106 }
yuuji@0	1107 }
yuuji@0	1108 else MM_LOG ("No mix message files found during expunge",WARN);
yuuji@0	1109 /* free directory list */
yuuji@0	1110 if (a = (void ) names) fs_give ((void *) &a);
yuuji@0	1111 }
yuuji@0	1112
yuuji@0	1113 /* either way, re-acquire shared lock */
yuuji@0	1114 if (flock (LOCAL->mfd,LOCK_SH\|LOCK_NB))
yuuji@0	1115 fatal ("Unable to re-acquire metadata shared lock!");
yuuji@0	1116 /* Do this step even if ret is NIL (meaning some burp problem)! */
yuuji@0	1117 if (nexp \|\| reclaimed) { /* rewrite index and status if changed */
yuuji@0	1118 LOCAL->indexseq = mix_modseq (LOCAL->indexseq);
yuuji@0	1119 if (mix_index_update (stream,idxf,NIL)) {
yuuji@0	1120 LOCAL->statusseq = mix_modseq (LOCAL->statusseq);
yuuji@0	1121 /* set failure if update fails */
yuuji@0	1122 ret = mix_status_update (stream,statf,NIL);
yuuji@0	1123 }
yuuji@0	1124 }
yuuji@0	1125 }
yuuji@0	1126 if (statf) fclose (statf); /* close status if still open */
yuuji@0	1127 if (idxf) fclose (idxf); /* close index if still open */
yuuji@0	1128 LOCAL->expok = NIL; /* cancel expok */
yuuji@0	1129 if (ret) { /* only if success */
yuuji@0	1130 char *s = NIL;
yuuji@0	1131 if (nexp) sprintf (s = LOCAL->buf,"Expunged %lu messages",nexp);
yuuji@0	1132 else if (reclaimed)
yuuji@0	1133 sprintf (s=LOCAL->buf,"Reclaimed %lu bytes of expunged space",reclaimed);
yuuji@0	1134 else if (!burponly)
yuuji@0	1135 s = stream->rdonly ? "Expunge ignored on readonly mailbox" :
yuuji@0	1136 "No messages deleted, so no update needed";
yuuji@0	1137 if (s) MM_LOG (s,(long) NIL);
yuuji@0	1138 }
yuuji@0	1139 return ret;
yuuji@0	1140 }
yuuji@0	1141
yuuji@0	1142 /* MIX test for message file name
yuuji@0	1143 * Accepts: candidate directory name
yuuji@0	1144 * Returns: T if message file name, NIL otherwise
yuuji@0	1145 *
yuuji@0	1146 * ".mix" with no suffix was used by experimental versions
yuuji@0	1147 */
yuuji@0	1148
yuuji@0	1149 int mix_select (struct direct *name)
yuuji@0	1150 {
yuuji@0	1151 char c,*s;
yuuji@0	1152 /* make sure name has prefix */
yuuji@0	1153 if (mix_dirfmttest (name->d_name)) {
yuuji@0	1154 for (c = *(s = name->d_name + sizeof (MIXNAME) - 1); c && isxdigit (c);
yuuji@0	1155 c = *s++);
yuuji@0	1156 if (!c) return T; /* all-hex or no suffix */
yuuji@0	1157 }
yuuji@0	1158 return NIL; /* not suffix or non-hex */
yuuji@0	1159 }
yuuji@0	1160
yuuji@0	1161
yuuji@0	1162 /* MIX msg file name comparision
yuuji@0	1163 * Accepts: first candidate directory entry
yuuji@0	1164 * second candidate directory entry
yuuji@0	1165 * Returns: -1 if d1 < d2, 0 if d1 == d2, 1 d1 > d2
yuuji@0	1166 */
yuuji@0	1167
yuuji@0	1168 int mix_msgfsort (const void d1,const void d2)
yuuji@0	1169 {
yuuji@0	1170 char n1 = ((struct direct **) d1)->d_name + sizeof (MIXNAME) - 1;
yuuji@0	1171 char n2 = ((struct direct **) d2)->d_name + sizeof (MIXNAME) - 1;
yuuji@0	1172 return compare_ulong (*n1 ? strtoul (n1,NIL,16) : 0,
yuuji@0	1173 *n2 ? strtoul (n2,NIL,16) : 0);
yuuji@0	1174 }
yuuji@0	1175
yuuji@0	1176
yuuji@0	1177 /* MIX add a range to a set
yuuji@0	1178 * Accepts: pointer to set to add
yuuji@0	1179 * start of set
yuuji@0	1180 * size of set
yuuji@0	1181 * Returns: T if success, set updated, NIL otherwise
yuuji@0	1182 */
yuuji@0	1183
yuuji@0	1184 long mix_addset (SEARCHSET **set,unsigned long start,unsigned long size)
yuuji@0	1185 {
yuuji@0	1186 SEARCHSET s = set;
yuuji@0	1187 if (start < s->last) { /* sanity check */
yuuji@0	1188 char tmp[MAILTMPLEN];
yuuji@0	1189 sprintf (tmp,"Backwards-running mix index %lu < %lu",start,s->last);
yuuji@0	1190 MM_LOG (tmp,ERROR);
yuuji@0	1191 return NIL;
yuuji@0	1192 }
yuuji@0	1193 /* range initially empty? */
yuuji@0	1194 if (!s->last) s->first = start;
yuuji@0	1195 else if (start > s->last) /* no, start new range if can't append */
yuuji@0	1196 (*set = s = s->next = mail_newsearchset ())->first = start;
yuuji@0	1197 s->last = start + size; /* end of current range */
yuuji@0	1198 return LONGT;
yuuji@0	1199 }
yuuji@0	1200
yuuji@0	1201 /* MIX burp message file
yuuji@0	1202 * Accepts: MAIL stream
yuuji@0	1203 * current burp block for this message
yuuji@0	1204 * Returns: T if successful, NIL if failed
yuuji@0	1205 */
yuuji@0	1206
yuuji@0	1207 static char *staterr = "Error in stat of mix message file %.80s: %.80s";
yuuji@0	1208 static char *truncerr = "Error truncating mix message file %.80s: %.80s";
yuuji@0	1209
yuuji@0	1210 long mix_burp (MAILSTREAM stream,MIXBURP burp,unsigned long *reclaimed)
yuuji@0	1211 {
yuuji@0	1212 MESSAGECACHE *elt;
yuuji@0	1213 SEARCHSET *set;
yuuji@0	1214 struct stat sbuf;
yuuji@0	1215 off_t rpos,wpos;
yuuji@0	1216 size_t size,wsize,wpending,written;
yuuji@0	1217 int fd;
yuuji@0	1218 FILE *f;
yuuji@0	1219 void *s;
yuuji@0	1220 unsigned long i;
yuuji@0	1221 long ret = NIL;
yuuji@0	1222 /* build file name */
yuuji@0	1223 mix_file_data (LOCAL->buf,stream->mailbox,burp->fileno);
yuuji@0	1224 /* need to burp at start or multiple ranges? */
yuuji@0	1225 if (!burp->set.first && !burp->set.next) {
yuuji@0	1226 /* easy case, single range at start of file */
yuuji@0	1227 if (stat (LOCAL->buf,&sbuf)) {
yuuji@0	1228 sprintf (LOCAL->buf,staterr,burp->name,strerror (errno));
yuuji@0	1229 MM_LOG (LOCAL->buf,ERROR);
yuuji@0	1230 }
yuuji@0	1231 /* is this range sane? */
yuuji@0	1232 else if (mix_burp_check (&burp->set,sbuf.st_size,LOCAL->buf)) {
yuuji@0	1233 /* if matches range then no burp needed! */
yuuji@0	1234 if (burp->set.last == sbuf.st_size) ret = LONGT;
yuuji@0	1235 /* just need to remove cruft at end */
yuuji@0	1236 else if (ret = !truncate (LOCAL->buf,burp->set.last))
yuuji@0	1237 *reclaimed += sbuf.st_size - burp->set.last;
yuuji@0	1238 else {
yuuji@0	1239 sprintf (LOCAL->buf,truncerr,burp->name,strerror (errno));
yuuji@0	1240 MM_LOG (LOCAL->buf,ERROR);
yuuji@0	1241 }
yuuji@0	1242 }
yuuji@0	1243 }
yuuji@0	1244 /* have to do more work, get the file */
yuuji@0	1245 else if (((fd = open (LOCAL->buf,O_RDWR,NIL)) < 0) \|\|
yuuji@0	1246 !(f = fdopen (fd,"r+b"))) {
yuuji@0	1247 sprintf (LOCAL->buf,"Error opening mix message file %.80s: %.80s",
yuuji@0	1248 burp->name,strerror (errno));
yuuji@0	1249 MM_LOG (LOCAL->buf,ERROR);
yuuji@0	1250 if (fd >= 0) close (fd); /* in case fdopen() failure */
yuuji@0	1251 }
yuuji@0	1252 else if (fstat (fd,&sbuf)) { /* get file size */
yuuji@0	1253 sprintf (LOCAL->buf,staterr,burp->name,strerror (errno));
yuuji@0	1254 MM_LOG (LOCAL->buf,ERROR);
yuuji@0	1255 fclose (f);
yuuji@0	1256 }
yuuji@0	1257
yuuji@0	1258 /* only if sane */
yuuji@0	1259 else if (mix_burp_check (&burp->set,sbuf.st_size,LOCAL->buf)) {
yuuji@0	1260 /* make sure each range starts with token */
yuuji@0	1261 for (set = &burp->set; set; set = set->next)
yuuji@0	1262 if (fseek (f,set->first,SEEK_SET) \|\|
yuuji@0	1263 (fread (LOCAL->buf,1,MSGTSZ,f) != MSGTSZ) \|\|
yuuji@0	1264 strncmp (LOCAL->buf,MSGTOK,MSGTSZ)) {
yuuji@0	1265 sprintf (LOCAL->buf,"Bad message token in mix message file at %lu",
yuuji@0	1266 set->first);
yuuji@0	1267 MM_LOG (LOCAL->buf,ERROR);
yuuji@0	1268 fclose (f);
yuuji@0	1269 return NIL; /* burp fails for this file */
yuuji@0	1270 }
yuuji@0	1271 /* burp out each old message */
yuuji@0	1272 for (set = &burp->set, wpos = 0; set; set = set->next) {
yuuji@0	1273 /* move down this range */
yuuji@0	1274 for (rpos = set->first, size = set->last - set->first;
yuuji@0	1275 size; size -= wsize) {
yuuji@0	1276 if (rpos != wpos) { /* data to skip at start? */
yuuji@0	1277 /* no, slide this buffer down */
yuuji@0	1278 wsize = min (size,LOCAL->buflen);
yuuji@0	1279 /* failure is not an option here */
yuuji@0	1280 while (fseek (f,rpos,SEEK_SET) \|\|
yuuji@0	1281 (fread (LOCAL->buf,1,wsize,f) != wsize)) {
yuuji@0	1282 MM_NOTIFY (stream,strerror (errno),WARN);
yuuji@0	1283 MM_DISKERROR (stream,errno,T);
yuuji@0	1284 }
yuuji@0	1285 /* nor here */
yuuji@0	1286 while (fseek (f,wpos,SEEK_SET)) {
yuuji@0	1287 MM_NOTIFY (stream,strerror (errno),WARN);
yuuji@0	1288 MM_DISKERROR (stream,errno,T);
yuuji@0	1289 }
yuuji@0	1290 /* and especially not here */
yuuji@0	1291 for (s = LOCAL->buf, wpending = wsize; wpending; wpending -= written)
yuuji@0	1292 if (!(written = fwrite (LOCAL->buf,1,wpending,f))) {
yuuji@0	1293 MM_NOTIFY (stream,strerror (errno),WARN);
yuuji@0	1294 MM_DISKERROR (stream,errno,T);
yuuji@0	1295 }
yuuji@0	1296 }
yuuji@0	1297 else wsize = size; /* nothing to skip, say we wrote it all */
yuuji@0	1298 rpos += wsize; wpos += wsize;
yuuji@0	1299 }
yuuji@0	1300 }
yuuji@0	1301
yuuji@0	1302 while (fflush (f)) { /* failure also not an option here... */
yuuji@0	1303 MM_NOTIFY (stream,strerror (errno),WARN);
yuuji@0	1304 MM_DISKERROR (stream,errno,T);
yuuji@0	1305 }
yuuji@0	1306 if (ftruncate (fd,wpos)) { /* flush cruft at end of file */
yuuji@0	1307 sprintf (LOCAL->buf,truncerr,burp->name,strerror (errno));
yuuji@0	1308 MM_LOG (LOCAL->buf,WARN);
yuuji@0	1309 }
yuuji@0	1310 else *reclaimed += rpos - wpos;
yuuji@0	1311 ret = !fclose (f); /* close file */
yuuji@0	1312 /* slide down message positions in index */
yuuji@0	1313 for (i = 1,rpos = 0; i <= stream->nmsgs; ++i)
yuuji@0	1314 if ((elt = mail_elt (stream,i))->private.spare.data == burp->fileno) {
yuuji@0	1315 elt->private.special.offset = rpos;
yuuji@0	1316 rpos += elt->private.msg.header.offset + elt->rfc822_size;
yuuji@0	1317 }
yuuji@0	1318 /* debugging */
yuuji@0	1319 if (rpos != wpos) fatal ("burp size consistency check!");
yuuji@0	1320 }
yuuji@0	1321 return ret;
yuuji@0	1322 }
yuuji@0	1323
yuuji@0	1324
yuuji@0	1325 /* MIX burp sanity check to make sure not burping off end of file
yuuji@0	1326 * Accepts: burp set
yuuji@0	1327 * file size
yuuji@0	1328 * file name
yuuji@0	1329 * Returns: T if sane, NIL if insane
yuuji@0	1330 */
yuuji@0	1331
yuuji@0	1332 long mix_burp_check (SEARCHSET set,size_t size,char file)
yuuji@0	1333 {
yuuji@0	1334 do if (set->last > size) { /* sanity check */
yuuji@0	1335 char tmp[MAILTMPLEN];
yuuji@0	1336 sprintf (tmp,"Unexpected short mix message file %.80s %lu < %lu",
yuuji@0	1337 file,size,set->last);
yuuji@0	1338 MM_LOG (tmp,ERROR);
yuuji@0	1339 return NIL; /* don't burp this file at all */
yuuji@0	1340 } while (set = set->next);
yuuji@0	1341 return LONGT;
yuuji@0	1342 }
yuuji@0	1343
yuuji@0	1344 /* MIX mail copy message(s)
yuuji@0	1345 * Accepts: MAIL stream
yuuji@0	1346 * sequence
yuuji@0	1347 * destination mailbox
yuuji@0	1348 * copy options
yuuji@0	1349 * Returns: T if copy successful, else NIL
yuuji@0	1350 */
yuuji@0	1351
yuuji@0	1352 long mix_copy (MAILSTREAM stream,char sequence,char *mailbox,long options)
yuuji@0	1353 {
yuuji@0	1354 FDDATA d;
yuuji@0	1355 STRING st;
yuuji@0	1356 char tmp[2*MAILTMPLEN];
yuuji@0	1357 long ret = mix_isvalid (mailbox,LOCAL->buf);
yuuji@0	1358 mailproxycopy_t pc =
yuuji@0	1359 (mailproxycopy_t) mail_parameters (stream,GET_MAILPROXYCOPY,NIL);
yuuji@0	1360 MAILSTREAM *astream = NIL;
yuuji@0	1361 FILE *idxf = NIL;
yuuji@0	1362 FILE *msgf = NIL;
yuuji@0	1363 FILE *statf = NIL;
yuuji@0	1364 if (!ret) switch (errno) { /* make sure valid mailbox */
yuuji@0	1365 case NIL: /* no error in stat() */
yuuji@0	1366 if (pc) return (*pc) (stream,sequence,mailbox,options);
yuuji@0	1367 sprintf (tmp,"Not a MIX-format mailbox: %.80s",mailbox);
yuuji@0	1368 MM_LOG (tmp,ERROR);
yuuji@0	1369 break;
yuuji@0	1370 default: /* some stat() error */
yuuji@0	1371 MM_NOTIFY (stream,"[TRYCREATE] Must create mailbox before copy",NIL);
yuuji@0	1372 break;
yuuji@0	1373 }
yuuji@0	1374 /* get sequence to copy */
yuuji@0	1375 else if (!(ret = ((options & CP_UID) ? mail_uid_sequence (stream,sequence) :
yuuji@0	1376 mail_sequence (stream,sequence))));
yuuji@0	1377 /* acquire stream to append */
yuuji@0	1378 else if (ret = ((astream = mail_open (NIL,mailbox,OP_SILENT)) &&
yuuji@0	1379 !astream->rdonly &&
yuuji@0	1380 (((MIXLOCAL *) astream->local)->expok = T) &&
yuuji@0	1381 (statf = mix_parse (astream,&idxf,LONGT,NIL))) ?
yuuji@0	1382 LONGT : NIL) {
yuuji@0	1383 int fd;
yuuji@0	1384 unsigned long i;
yuuji@0	1385 MESSAGECACHE *elt;
yuuji@0	1386 unsigned long newsize,hdrsize,size;
yuuji@0	1387 MIXLOCAL local = (MIXLOCAL ) astream->local;
yuuji@0	1388 unsigned long seq = mix_modseq (local->metaseq);
yuuji@0	1389 /* make sure new modseq fits */
yuuji@0	1390 if (local->indexseq > seq) seq = local->indexseq + 1;
yuuji@0	1391 if (local->statusseq > seq) seq = local->statusseq + 1;
yuuji@0	1392 /* calculate size of per-message header */
yuuji@0	1393 sprintf (local->buf,MSRFMT,MSGTOK,0,0,0,0,0,0,0,'+',0,0,0);
yuuji@0	1394 hdrsize = strlen (local->buf);
yuuji@0	1395
yuuji@0	1396 MM_CRITICAL (stream); /* go critical */
yuuji@0	1397 astream->silent = T; /* no events here */
yuuji@0	1398 /* calculate size that will be added */
yuuji@0	1399 for (i = 1, newsize = 0; i <= stream->nmsgs; ++i)
yuuji@0	1400 if ((elt = mail_elt (stream,i))->sequence)
yuuji@0	1401 newsize += hdrsize + elt->rfc822_size;
yuuji@0	1402 /* open data file */
yuuji@0	1403 if (msgf = mix_data_open (astream,&fd,&size,newsize)) {
yuuji@0	1404 char *t;
yuuji@0	1405 unsigned long j,uid,uidv;
yuuji@0	1406 copyuid_t cu = (copyuid_t) mail_parameters (NIL,GET_COPYUID,NIL);
yuuji@0	1407 SEARCHSET *source = cu ? mail_newsearchset () : NIL;
yuuji@0	1408 SEARCHSET *dest = cu ? mail_newsearchset () : NIL;
yuuji@0	1409 for (i = 1,uid = uidv = 0; ret && (i <= stream->nmsgs); ++i)
yuuji@0	1410 if (((elt = mail_elt (stream,i))->sequence) && elt->rfc822_size) {
yuuji@0	1411 /* is message in current message file? */
yuuji@0	1412 if ((LOCAL->msgfd < 0) \|\|
yuuji@0	1413 (elt->private.spare.data != LOCAL->curmsg)) {
yuuji@0	1414 if (LOCAL->msgfd >= 0) close (LOCAL->msgfd);
yuuji@0	1415 if ((LOCAL->msgfd = open (mix_file_data (LOCAL->buf,
yuuji@0	1416 stream->mailbox,
yuuji@0	1417 elt->private.spare.data),
yuuji@0	1418 O_RDONLY,NIL)) >= 0)
yuuji@0	1419 LOCAL->curmsg = elt->private.spare.data;
yuuji@0	1420 }
yuuji@0	1421 if (LOCAL->msgfd < 0) ret = NIL;
yuuji@0	1422 else { /* got file */
yuuji@0	1423 d.fd = LOCAL->msgfd;/* set up file descriptor */
yuuji@0	1424 /* start of message */
yuuji@0	1425 d.pos = elt->private.special.offset +
yuuji@0	1426 elt->private.msg.header.offset;
yuuji@0	1427 d.chunk = LOCAL->buf;
yuuji@0	1428 d.chunksize = CHUNKSIZE;
yuuji@0	1429 INIT (&st,fd_string,&d,elt->rfc822_size);
yuuji@0	1430 /* init flag string */
yuuji@0	1431 tmp[0] = tmp[1] = '\0';
yuuji@0	1432 if (j = elt->user_flags) do
yuuji@0	1433 if ((t = stream->user_flags[find_rightmost_bit (&j)]) && *t)
yuuji@0	1434 strcat (strcat (tmp," "),t);
yuuji@0	1435 while (j);
yuuji@0	1436 if (elt->seen) strcat (tmp," \\Seen");
yuuji@0	1437 if (elt->deleted) strcat (tmp," \\Deleted");
yuuji@0	1438 if (elt->flagged) strcat (tmp," \\Flagged");
yuuji@0	1439 if (elt->answered) strcat (tmp," \\Answered");
yuuji@0	1440 if (elt->draft) strcat (tmp," \\Draft");
yuuji@0	1441 tmp[0] = '('; /* wrap list */
yuuji@0	1442 strcat (tmp,")");
yuuji@0	1443 /* if append OK, add to source set */
yuuji@0	1444 if ((ret = mix_append_msg (astream,msgf,tmp,elt,&st,dest,
yuuji@0	1445 seq)) && source)
yuuji@0	1446 mail_append_set (source,mail_uid (stream,i));
yuuji@0	1447 }
yuuji@0	1448 }
yuuji@0	1449
yuuji@0	1450 /* finish write if success */
yuuji@0	1451 if (ret && (ret = !fflush (msgf))) {
yuuji@0	1452 fclose (msgf); /* all good, close the msg file now */
yuuji@0	1453 /* write new metadata, index, and status */
yuuji@0	1454 local->metaseq = local->indexseq = local->statusseq = seq;
yuuji@0	1455 if (ret = (mix_meta_update (astream) &&
yuuji@0	1456 mix_index_update (astream,idxf,LONGT))) {
yuuji@0	1457 /* success, delete if doing a move */
yuuji@0	1458 if (options & CP_MOVE)
yuuji@0	1459 for (i = 1; i <= stream->nmsgs; i++)
yuuji@0	1460 if ((elt = mail_elt (stream,i))->sequence) {
yuuji@0	1461 elt->deleted = T;
yuuji@0	1462 if (!stream->rdonly) elt->private.mod = LOCAL->statusseq = seq;
yuuji@0	1463 MM_FLAGS (stream,elt->msgno);
yuuji@0	1464 }
yuuji@0	1465 /* done with status file now */
yuuji@0	1466 mix_status_update (astream,statf,LONGT);
yuuji@0	1467 /* return sets if doing COPYUID */
yuuji@0	1468 if (cu) (*cu) (stream,mailbox,astream->uid_validity,source,dest);
yuuji@0	1469 source = dest = NIL; /* don't free these sets now */
yuuji@0	1470 }
yuuji@0	1471 }
yuuji@0	1472 else { /* error */
yuuji@0	1473 if (errno) { /* output error message if system call error */
yuuji@0	1474 sprintf (tmp,"Message copy failed: %.80s",strerror (errno));
yuuji@0	1475 MM_LOG (tmp,ERROR);
yuuji@0	1476 }
yuuji@0	1477 ftruncate (fd,size); /* revert file */
yuuji@0	1478 close (fd); /* make sure that fclose doesn't corrupt us */
yuuji@0	1479 fclose (msgf); /* free the stdio resources */
yuuji@0	1480 }
yuuji@0	1481 /* flush any sets remaining */
yuuji@0	1482 mail_free_searchset (&source);
yuuji@0	1483 mail_free_searchset (&dest);
yuuji@0	1484 }
yuuji@0	1485 else { /* message file open failed */
yuuji@0	1486 sprintf (tmp,"Error opening copy message file: %.80s",
yuuji@0	1487 strerror (errno));
yuuji@0	1488 MM_LOG (tmp,ERROR);
yuuji@0	1489 ret = NIL;
yuuji@0	1490 }
yuuji@0	1491 MM_NOCRITICAL (stream);
yuuji@0	1492 }
yuuji@0	1493 else MM_LOG ("Can't open copy mailbox",ERROR);
yuuji@0	1494 if (statf) fclose (statf); /* close status if still open */
yuuji@0	1495 if (idxf) fclose (idxf); /* close index if still open */
yuuji@0	1496 /* finished with append stream */
yuuji@0	1497 if (astream) mail_close (astream);
yuuji@0	1498 return ret; /* return state */
yuuji@0	1499 }
yuuji@0	1500
yuuji@0	1501 /* MIX mail append message from stringstruct
yuuji@0	1502 * Accepts: MAIL stream
yuuji@0	1503 * destination mailbox
yuuji@0	1504 * append callback
yuuji@0	1505 * data for callback
yuuji@0	1506 * Returns: T if append successful, else NIL
yuuji@0	1507 */
yuuji@0	1508
yuuji@0	1509 long mix_append (MAILSTREAM stream,char mailbox,append_t af,void *data)
yuuji@0	1510 {
yuuji@0	1511 STRING *message;
yuuji@0	1512 char flags,date,tmp[MAILTMPLEN];
yuuji@0	1513 /* N.B.: can't use LOCAL->buf for tmp */
yuuji@0	1514 long ret = mix_isvalid (mailbox,tmp);
yuuji@0	1515 /* default stream to prototype */
yuuji@0	1516 if (!stream) stream = user_flags (&mixproto);
yuuji@0	1517 if (!ret) switch (errno) { /* if not valid mailbox */
yuuji@0	1518 case ENOENT: /* no such file? */
yuuji@0	1519 if (ret = compare_cstring (mailbox,"INBOX") ?
yuuji@0	1520 NIL : mix_create (NIL,"INBOX"))
yuuji@0	1521 break;
yuuji@0	1522 MM_NOTIFY (stream,"[TRYCREATE] Must create mailbox before append",NIL);
yuuji@0	1523 break;
yuuji@0	1524 default:
yuuji@0	1525 sprintf (tmp,"Not a MIX-format mailbox: %.80s",mailbox);
yuuji@0	1526 MM_LOG (tmp,ERROR);
yuuji@0	1527 break;
yuuji@0	1528 }
yuuji@0	1529
yuuji@0	1530 /* get first message */
yuuji@0	1531 if (ret && MM_APPEND (af) (stream,data,&flags,&date,&message)) {
yuuji@0	1532 MAILSTREAM *astream;
yuuji@0	1533 FILE *idxf = NIL;
yuuji@0	1534 FILE *msgf = NIL;
yuuji@0	1535 FILE *statf = NIL;
yuuji@0	1536 if (ret = ((astream = mail_open (NIL,mailbox,OP_SILENT)) &&
yuuji@0	1537 !astream->rdonly &&
yuuji@0	1538 (((MIXLOCAL *) astream->local)->expok = T) &&
yuuji@0	1539 (statf = mix_parse (astream,&idxf,LONGT,NIL))) ?
yuuji@0	1540 LONGT : NIL) {
yuuji@0	1541 int fd;
yuuji@0	1542 unsigned long size,hdrsize;
yuuji@0	1543 MESSAGECACHE elt;
yuuji@0	1544 MIXLOCAL local = (MIXLOCAL ) astream->local;
yuuji@0	1545 unsigned long seq = mix_modseq (local->metaseq);
yuuji@0	1546 /* make sure new modseq fits */
yuuji@0	1547 if (local->indexseq > seq) seq = local->indexseq + 1;
yuuji@0	1548 if (local->statusseq > seq) seq = local->statusseq + 1;
yuuji@0	1549 /* calculate size of per-message header */
yuuji@0	1550 sprintf (local->buf,MSRFMT,MSGTOK,0,0,0,0,0,0,0,'+',0,0,0);
yuuji@0	1551 hdrsize = strlen (local->buf);
yuuji@0	1552 MM_CRITICAL (astream); /* go critical */
yuuji@0	1553 astream->silent = T; /* no events here */
yuuji@0	1554 /* open data file */
yuuji@0	1555 if (msgf = mix_data_open (astream,&fd,&size,hdrsize + SIZE (message))) {
yuuji@0	1556 appenduid_t au = (appenduid_t) mail_parameters (NIL,GET_APPENDUID,NIL);
yuuji@0	1557 SEARCHSET *dst = au ? mail_newsearchset () : NIL;
yuuji@0	1558 while (ret && message) {/* while good to go and have messages */
yuuji@0	1559 errno = NIL; /* in case one of these causes failure */
yuuji@0	1560 /* guard against zero-length */
yuuji@0	1561 if (!(ret = SIZE (message)))
yuuji@0	1562 MM_LOG ("Append of zero-length message",ERROR);
yuuji@0	1563 else if (date && !(ret = mail_parse_date (&elt,date))) {
yuuji@0	1564 sprintf (tmp,"Bad date in append: %.80s",date);
yuuji@0	1565 MM_LOG (tmp,ERROR);
yuuji@0	1566 }
yuuji@0	1567 else {
yuuji@0	1568 if (!date) { /* if date not specified, use now */
yuuji@0	1569 internal_date (tmp);
yuuji@0	1570 mail_parse_date (&elt,tmp);
yuuji@0	1571 }
yuuji@0	1572 ret = mix_append_msg (astream,msgf,flags,&elt,message,dst,seq) &&
yuuji@0	1573 MM_APPEND (af) (stream,data,&flags,&date,&message);
yuuji@0	1574 }
yuuji@0	1575 }
yuuji@0	1576
yuuji@0	1577 /* finish write if success */
yuuji@0	1578 if (ret && (ret = !fflush (msgf))) {
yuuji@0	1579 fclose (msgf); /* all good, close the msg file now */
yuuji@0	1580 /* write new metadata, index, and status */
yuuji@0	1581 local->metaseq = local->indexseq = local->statusseq = seq;
yuuji@0	1582 if ((ret = (mix_meta_update (astream) &&
yuuji@0	1583 mix_index_update (astream,idxf,LONGT) &&
yuuji@0	1584 mix_status_update (astream,statf,LONGT))) && au) {
yuuji@0	1585 (*au) (mailbox,astream->uid_validity,dst);
yuuji@0	1586 dst = NIL; /* don't free this set now */
yuuji@0	1587 }
yuuji@0	1588 }
yuuji@0	1589 else { /* failure */
yuuji@0	1590 if (errno) { /* output error message if system call error */
yuuji@0	1591 sprintf (tmp,"Message append failed: %.80s",strerror (errno));
yuuji@0	1592 MM_LOG (tmp,ERROR);
yuuji@0	1593 }
yuuji@0	1594 ftruncate (fd,size); /* revert all writes to file*/
yuuji@0	1595 close (fd); /* make sure that fclose doesn't corrupt us */
yuuji@0	1596 fclose (msgf); /* free the stdio resources */
yuuji@0	1597 }
yuuji@0	1598 /* flush any set remaining */
yuuji@0	1599 mail_free_searchset (&dst);
yuuji@0	1600 }
yuuji@0	1601 else { /* message file open failed */
yuuji@0	1602 sprintf (tmp,"Error opening append message file: %.80s",
yuuji@0	1603 strerror (errno));
yuuji@0	1604 MM_LOG (tmp,ERROR);
yuuji@0	1605 ret = NIL;
yuuji@0	1606 }
yuuji@0	1607 MM_NOCRITICAL (astream); /* release critical */
yuuji@0	1608 }
yuuji@0	1609 else MM_LOG ("Can't open append mailbox",ERROR);
yuuji@0	1610 if (statf) fclose (statf); /* close status if still open */
yuuji@0	1611 if (idxf) fclose (idxf); /* close index if still open */
yuuji@0	1612 if (astream) mail_close (astream);
yuuji@0	1613 }
yuuji@0	1614 return ret;
yuuji@0	1615 }
yuuji@0	1616
yuuji@0	1617 /* MIX mail append single message
yuuji@0	1618 * Accepts: MAIL stream
yuuji@0	1619 * flags for new message if non-NIL
yuuji@0	1620 * elt with source date if non-NIL
yuuji@0	1621 * stringstruct of message text
yuuji@0	1622 * searchset to place UID
yuuji@0	1623 * modseq of message
yuuji@0	1624 * Returns: T if success, NIL if failure
yuuji@0	1625 */
yuuji@0	1626
yuuji@0	1627 long mix_append_msg (MAILSTREAM stream,FILE f,char flags,MESSAGECACHE delt,
yuuji@0	1628 STRING msg,SEARCHSET set,unsigned long seq)
yuuji@0	1629 {
yuuji@0	1630 MESSAGECACHE *elt;
yuuji@0	1631 int c,cs;
yuuji@0	1632 unsigned long i,j,k,uf,hoff;
yuuji@0	1633 long sf;
yuuji@0	1634 stream->kwd_create = NIL; /* don't copy unknown keywords */
yuuji@0	1635 sf = mail_parse_flags (stream,flags,&uf);
yuuji@0	1636 /* swell the cache */
yuuji@0	1637 mail_exists (stream,++stream->nmsgs);
yuuji@0	1638 /* assign new UID from metadata */
yuuji@0	1639 (elt = mail_elt (stream,stream->nmsgs))->private.uid = ++stream->uid_last;
yuuji@0	1640 elt->private.mod = seq; /* set requested modseq in status */
yuuji@0	1641 elt->rfc822_size = SIZE (msg);/* copy message size and date to index */
yuuji@0	1642 elt->year = delt->year; elt->month = delt->month; elt->day = delt->day;
yuuji@0	1643 elt->hours = delt->hours; elt->minutes = delt->minutes;
yuuji@0	1644 elt->seconds = delt->seconds; elt->zoccident = delt->zoccident;
yuuji@0	1645 elt->zhours = delt->zhours; elt->zminutes = delt->zminutes;
yuuji@0	1646 /*
yuuji@0	1647 * Do NOT set elt->valid here! mix_status_update() uses it to determine
yuuji@0	1648 * whether a message should be marked as old.
yuuji@0	1649 */
yuuji@0	1650 if (sf&fSEEN) elt->seen = T; /* copy flags to status */
yuuji@0	1651 if (sf&fDELETED) elt->deleted = T;
yuuji@0	1652 if (sf&fFLAGGED) elt->flagged = T;
yuuji@0	1653 if (sf&fANSWERED) elt->answered = T;
yuuji@0	1654 if (sf&fDRAFT) elt->draft = T;
yuuji@0	1655 elt->user_flags \|= uf;
yuuji@0	1656 /* message is in new message file */
yuuji@0	1657 elt->private.spare.data = LOCAL->newmsg;
yuuji@0	1658
yuuji@0	1659 /* offset to message internal header */
yuuji@0	1660 elt->private.special.offset = ftell (f);
yuuji@0	1661 /* build header for message */
yuuji@0	1662 fprintf (f,MSRFMT,MSGTOK,elt->private.uid,
yuuji@0	1663 elt->year + BASEYEAR,elt->month,elt->day,
yuuji@0	1664 elt->hours,elt->minutes,elt->seconds,
yuuji@0	1665 elt->zoccident ? '-' : '+',elt->zhours,elt->zminutes,
yuuji@0	1666 elt->rfc822_size);
yuuji@0	1667 /* offset to header from internal header */
yuuji@0	1668 elt->private.msg.header.offset = ftell (f) - elt->private.special.offset;
yuuji@0	1669 for (cs = 0; SIZE (msg); ) { /* copy message */
yuuji@0	1670 if (elt->private.msg.header.text.size) {
yuuji@0	1671 if (msg->cursize) /* blat entire chunk if have it */
yuuji@0	1672 for (j = msg->cursize; j; j -= k)
yuuji@0	1673 if (!(k = fwrite (msg->curpos,1,j,f))) return NIL;
yuuji@0	1674 SETPOS (msg,GETPOS (msg) + msg->cursize);
yuuji@0	1675 }
yuuji@0	1676 else { /* still searching for delimiter */
yuuji@0	1677 c = 0xff & SNX (msg); /* get source character */
yuuji@0	1678 if (putc (c,f) == EOF) return NIL;
yuuji@0	1679 switch (cs) { /* decide what to do based on state */
yuuji@0	1680 case 0: /* previous char ordinary */
yuuji@0	1681 if (c == '\015') cs = 1;/* advance if CR */
yuuji@0	1682 break;
yuuji@0	1683 case 1: /* previous CR, advance if LF */
yuuji@0	1684 cs = (c == '\012') ? 2 : 0;
yuuji@0	1685 break;
yuuji@0	1686 case 2: /* previous CRLF, advance if CR */
yuuji@0	1687 cs = (c == '\015') ? 3 : 0;
yuuji@0	1688 break;
yuuji@0	1689 case 3: /* previous CRLFCR, done if LF */
yuuji@0	1690 if (c == '\012') elt->private.msg.header.text.size =
yuuji@0	1691 elt->rfc822_size - SIZE (msg);
yuuji@0	1692 cs = 0; /* reset mechanism */
yuuji@0	1693 break;
yuuji@0	1694 }
yuuji@0	1695 }
yuuji@0	1696 }
yuuji@0	1697 /* if no delimiter, header is entire msg */
yuuji@0	1698 if (!elt->private.msg.header.text.size)
yuuji@0	1699 elt->private.msg.header.text.size = elt->rfc822_size;
yuuji@0	1700 /* add this message to set */
yuuji@0	1701 mail_append_set (set,elt->private.uid);
yuuji@0	1702 return LONGT; /* success */
yuuji@0	1703 }
yuuji@0	1704
yuuji@0	1705 /* MIX mail read metadata, index, and status
yuuji@0	1706 * Accepts: MAIL stream
yuuji@0	1707 * returned index file
yuuji@0	1708 * index file flags (non-NIL if want to add/remove messages)
yuuji@0	1709 * status file flags (non-NIL if want to update elt->valid and old)
yuuji@0	1710 * Returns: open status file, or NIL if failure
yuuji@0	1711 *
yuuji@0	1712 * Note that this routine can return an open index file even if it fails!
yuuji@0	1713 */
yuuji@0	1714
yuuji@0	1715 static char *shortmsg =
yuuji@0	1716 "message %lu (UID=%.08lx) truncated by %lu byte(s) (%lu < %lu)";
yuuji@0	1717
yuuji@0	1718 FILE mix_parse (MAILSTREAM stream,FILE **idxf,long iflags,long sflags)
yuuji@0	1719 {
yuuji@0	1720 int fd;
yuuji@0	1721 unsigned long i;
yuuji@0	1722 char s,t;
yuuji@0	1723 struct stat sbuf;
yuuji@0	1724 FILE *statf = NIL;
yuuji@0	1725 short metarepairneeded = 0;
yuuji@0	1726 short indexrepairneeded = 0;
yuuji@0	1727 short silent = stream->silent;
yuuji@0	1728 idxf = NIL; / in case error */
yuuji@0	1729 /* readonly means no updates */
yuuji@0	1730 if (stream->rdonly) iflags = sflags = NIL;
yuuji@0	1731 /* open index file */
yuuji@0	1732 if ((fd = open (LOCAL->index,iflags ? O_RDWR : O_RDONLY,NIL)) < 0)
yuuji@0	1733 MM_LOG ("Error opening mix index file",ERROR);
yuuji@0	1734 /* acquire exclusive access and FILE */
yuuji@0	1735 else if (!flock (fd,iflags ? LOCK_EX : LOCK_SH) &&
yuuji@0	1736 !(*idxf = fdopen (fd,iflags ? "r+b" : "rb"))) {
yuuji@0	1737 MM_LOG ("Error obtaining stream on mix index file",ERROR);
yuuji@0	1738 flock (fd,LOCK_UN); /* relinquish lock */
yuuji@0	1739 close (fd);
yuuji@0	1740 }
yuuji@0	1741
yuuji@0	1742 /* slurp metadata */
yuuji@0	1743 else if (s = mix_meta_slurp (stream,&i)) {
yuuji@0	1744 unsigned long j = 0; /* non-zero if UIDVALIDITY/UIDLAST changed */
yuuji@0	1745 if (i != LOCAL->metaseq) { /* metadata changed? */
yuuji@0	1746 char t,k;
yuuji@0	1747 LOCAL->metaseq = i; /* note new metadata sequence */
yuuji@0	1748 while (s && s) { / parse entire metadata file */
yuuji@0	1749 /* locate end of line */
yuuji@0	1750 if (s = strstr (t = s,"\015\012")) {
yuuji@0	1751 s = '\0'; / tie off line */
yuuji@0	1752 s += 2; /* skip past CRLF */
yuuji@0	1753 switch (t++) { / parse line */
yuuji@0	1754 case 'V': /* UIDVALIDITY */
yuuji@0	1755 if (!isxdigit (*t) \|\| !(i = strtoul (t,&t,16))) {
yuuji@0	1756 MM_LOG ("Error in mix metadata file UIDVALIDITY record",ERROR);
yuuji@0	1757 return NIL; /* give up */
yuuji@0	1758 }
yuuji@0	1759 if (i != stream->uid_validity) j = stream->uid_validity = i;
yuuji@0	1760 break;
yuuji@0	1761 case 'L': /* new UIDLAST */
yuuji@0	1762 if (!isxdigit (*t)) {
yuuji@0	1763 MM_LOG ("Error in mix metadata file UIDLAST record",ERROR);
yuuji@0	1764 return NIL; /* give up */
yuuji@0	1765 }
yuuji@0	1766 if ((i = strtoul (t,&t,16)) != stream->uid_last)
yuuji@0	1767 j = stream->uid_last = i;
yuuji@0	1768 break;
yuuji@0	1769 case 'N': /* new message file */
yuuji@0	1770 if (!isxdigit (*t)) {
yuuji@0	1771 MM_LOG ("Error in mix metadata file new msg record",ERROR);
yuuji@0	1772 return NIL; /* give up */
yuuji@0	1773 }
yuuji@0	1774 if ((i = strtoul (t,&t,16)) != stream->uid_last)
yuuji@0	1775 LOCAL->newmsg = i;
yuuji@0	1776 break;
yuuji@0	1777 case 'K': /* new keyword list */
yuuji@0	1778 for (i = 0; t && *t && (i < NUSERFLAGS); ++i) {
yuuji@0	1779 if (t = strchr (k = t,' ')) *t++ = '\0';
yuuji@0	1780 /* make sure keyword non-empty */
yuuji@0	1781 if (*k && (strlen (k) <= MAXUSERFLAG)) {
yuuji@0	1782 /* in case value changes (shouldn't happen) */
yuuji@0	1783 if (stream->user_flags[i] && strcmp (stream->user_flags[i],k)){
yuuji@0	1784 char tmp[MAILTMPLEN];
yuuji@0	1785 sprintf (tmp,"flag rename old=%.80s new=%.80s",
yuuji@0	1786 stream->user_flags[i],k);
yuuji@0	1787 MM_LOG (tmp,WARN);
yuuji@0	1788 fs_give ((void **) &stream->user_flags[i]);
yuuji@0	1789 }
yuuji@0	1790 if (!stream->user_flags[i]) stream->user_flags[i] = cpystr (k);
yuuji@0	1791 }
yuuji@0	1792 else break; /* empty keyword */
yuuji@0	1793 }
yuuji@0	1794 if ((i < NUSERFLAGS) && stream->user_flags[i]) {
yuuji@0	1795 MM_LOG ("Error in mix metadata file keyword record",ERROR);
yuuji@0	1796 return NIL; /* give up */
yuuji@0	1797 }
yuuji@0	1798 else if (i == NUSERFLAGS) stream->kwd_create = NIL;
yuuji@0	1799 break;
yuuji@0	1800 }
yuuji@0	1801 }
yuuji@0	1802 if (t && t) { / junk in line */
yuuji@0	1803 MM_LOG ("Error in mix metadata record",ERROR);
yuuji@0	1804 return NIL; /* give up */
yuuji@0	1805 }
yuuji@0	1806 }
yuuji@0	1807 }
yuuji@0	1808
yuuji@0	1809 /* get sequence */
yuuji@0	1810 if (!(i = mix_read_sequence (*idxf)) \|\| (i < LOCAL->indexseq)) {
yuuji@0	1811 MM_LOG ("Error in mix index file sequence record",ERROR);
yuuji@0	1812 return NIL; /* give up */
yuuji@0	1813 }
yuuji@0	1814 /* sequence changed from last time? */
yuuji@0	1815 else if (j \|\| (i > LOCAL->indexseq)) {
yuuji@0	1816 unsigned long uid,nmsgs,curfile,curfilesize,curpos;
yuuji@0	1817 char t,msg,tmp[MAILTMPLEN];
yuuji@0	1818 /* start with no messages */
yuuji@0	1819 curfile = curfilesize = curpos = nmsgs = 0;
yuuji@0	1820 /* update sequence iff expunging OK */
yuuji@0	1821 if (LOCAL->expok) LOCAL->indexseq = i;
yuuji@0	1822 /* get first elt */
yuuji@0	1823 while ((s = mix_read_record (*idxf,LOCAL->buf,LOCAL->buflen,"index")) &&
yuuji@0	1824 *s)
yuuji@0	1825 switch (*s) {
yuuji@0	1826 case ':': /* message record */
yuuji@0	1827 if (!(isxdigit (*++s) && (uid = strtoul (s,&t,16)))) msg = "UID";
yuuji@0	1828 else if (!((t++ == ':') && isdigit (t) && isdigit (t[1]) &&
yuuji@0	1829 isdigit (t[2]) && isdigit (t[3]) && isdigit (t[4]) &&
yuuji@0	1830 isdigit (t[5]) && isdigit (t[6]) && isdigit (t[7]) &&
yuuji@0	1831 isdigit (t[8]) && isdigit (t[9]) && isdigit (t[10]) &&
yuuji@0	1832 isdigit (t[11]) && isdigit (t[12]) && isdigit (t[13]) &&
yuuji@0	1833 ((t[14] == '+') \|\| (t[14] == '-')) &&
yuuji@0	1834 isdigit (t[15]) && isdigit (t[16]) && isdigit (t[17]) &&
yuuji@0	1835 isdigit (t[18]))) msg = "internaldate";
yuuji@0	1836 else if (((s = t+19) != ':') \|\| !isxdigit (++s)) msg = "size";
yuuji@0	1837 else {
yuuji@0	1838 unsigned int y = (((t - '0') 1000) + ((t[1] - '0') * 100) +
yuuji@0	1839 ((t[2] - '0') * 10) + t[3] - '0') - BASEYEAR;
yuuji@0	1840 unsigned int m = ((t[4] - '0') * 10) + t[5] - '0';
yuuji@0	1841 unsigned int d = ((t[6] - '0') * 10) + t[7] - '0';
yuuji@0	1842 unsigned int hh = ((t[8] - '0') * 10) + t[9] - '0';
yuuji@0	1843 unsigned int mm = ((t[10] - '0') * 10) + t[11] - '0';
yuuji@0	1844 unsigned int ss = ((t[12] - '0') * 10) + t[13] - '0';
yuuji@0	1845 unsigned int z = (t[14] == '-') ? 1 : 0;
yuuji@0	1846 unsigned int zh = ((t[15] - '0') * 10) + t[16] - '0';
yuuji@0	1847 unsigned int zm = ((t[17] - '0') * 10) + t[18] - '0';
yuuji@0	1848 unsigned long size = strtoul (s,&s,16);
yuuji@0	1849 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	1850 unsigned long file = strtoul (s,&s,16);
yuuji@0	1851 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	1852 unsigned long pos = strtoul (s,&s,16);
yuuji@0	1853 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	1854 unsigned long hpos = strtoul (s,&s,16);
yuuji@0	1855 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	1856 unsigned long hsiz = strtoul (s,&s,16);
yuuji@0	1857 if (uid > stream->uid_last) {
yuuji@0	1858 sprintf (tmp,"mix index invalid UID (%08lx < %08lx)",
yuuji@0	1859 uid,stream->uid_last);
yuuji@0	1860 if (stream->rdonly) {
yuuji@0	1861 MM_LOG (tmp,ERROR);
yuuji@0	1862 return NIL;
yuuji@0	1863 }
yuuji@0	1864 strcat (tmp,", repaired");
yuuji@0	1865 MM_LOG (tmp,WARN);
yuuji@0	1866 stream->uid_last = uid;
yuuji@0	1867 metarepairneeded = T;
yuuji@0	1868 }
yuuji@0	1869
yuuji@0	1870 /* ignore expansion values */
yuuji@0	1871 if (*s++ == ':') {
yuuji@0	1872 MESSAGECACHE *elt;
yuuji@0	1873 ++nmsgs; /* this is another mesage */
yuuji@0	1874 /* within current known range of messages? */
yuuji@0	1875 while (nmsgs <= stream->nmsgs) {
yuuji@0	1876 /* yes, get corresponding elt */
yuuji@0	1877 elt = mail_elt (stream,nmsgs);
yuuji@0	1878 /* existing message with matching data? */
yuuji@0	1879 if (uid == elt->private.uid) {
yuuji@0	1880 /* beware of Dracula's resurrection */
yuuji@0	1881 if (elt->private.ghost) {
yuuji@0	1882 sprintf (tmp,"mix index data unexpunged UID: %lx",
yuuji@0	1883 uid);
yuuji@0	1884 MM_LOG (tmp,ERROR);
yuuji@0	1885 return NIL;
yuuji@0	1886 }
yuuji@0	1887 /* also of static data changing */
yuuji@0	1888 if ((size != elt->rfc822_size) \|\|
yuuji@0	1889 (file != elt->private.spare.data) \|\|
yuuji@0	1890 (pos != elt->private.special.offset) \|\|
yuuji@0	1891 (hpos != elt->private.msg.header.offset) \|\|
yuuji@0	1892 (hsiz != elt->private.msg.header.text.size) \|\|
yuuji@0	1893 (y != elt->year) \|\| (m != elt->month) \|\|
yuuji@0	1894 (d != elt->day) \|\| (hh != elt->hours) \|\|
yuuji@0	1895 (mm != elt->minutes) \|\| (ss != elt->seconds) \|\|
yuuji@0	1896 (z != elt->zoccident) \|\| (zh != elt->zhours) \|\|
yuuji@0	1897 (zm != elt->zminutes)) {
yuuji@0	1898 sprintf (tmp,"mix index data mismatch: %lx",uid);
yuuji@0	1899 MM_LOG (tmp,ERROR);
yuuji@0	1900 return NIL;
yuuji@0	1901 }
yuuji@0	1902 break;
yuuji@0	1903 }
yuuji@0	1904 /* existing msg with lower UID is expunged */
yuuji@0	1905 else if (uid > elt->private.uid) {
yuuji@0	1906 if (LOCAL->expok) mail_expunged (stream,nmsgs);
yuuji@0	1907 else {/* message expunged, but not yet for us */
yuuji@0	1908 ++nmsgs;
yuuji@0	1909 elt->private.ghost = T;
yuuji@0	1910 }
yuuji@0	1911 }
yuuji@0	1912 else { /* unexpected message record */
yuuji@0	1913 sprintf (tmp,"mix index UID mismatch (%lx < %lx)",
yuuji@0	1914 uid,elt->private.uid);
yuuji@0	1915 MM_LOG (tmp,ERROR);
yuuji@0	1916 return NIL;
yuuji@0	1917 }
yuuji@0	1918 }
yuuji@0	1919
yuuji@0	1920 /* time to create a new message? */
yuuji@0	1921 if (nmsgs > stream->nmsgs) {
yuuji@0	1922 /* defer announcing until later */
yuuji@0	1923 stream->silent = T;
yuuji@0	1924 mail_exists (stream,nmsgs);
yuuji@0	1925 stream->silent = silent;
yuuji@0	1926 (elt = mail_elt (stream,nmsgs))->recent = T;
yuuji@0	1927 elt->private.uid = uid; elt->rfc822_size = size;
yuuji@0	1928 elt->private.spare.data = file;
yuuji@0	1929 elt->private.special.offset = pos;
yuuji@0	1930 elt->private.msg.header.offset = hpos;
yuuji@0	1931 elt->private.msg.header.text.size = hsiz;
yuuji@0	1932 elt->year = y; elt->month = m; elt->day = d;
yuuji@0	1933 elt->hours = hh; elt->minutes = mm;
yuuji@0	1934 elt->seconds = ss; elt->zoccident = z;
yuuji@0	1935 elt->zhours = zh; elt->zminutes = zm;
yuuji@0	1936 /* message in same file? */
yuuji@0	1937 if (curfile == file) {
yuuji@0	1938 if (pos < curpos) {
yuuji@0	1939 MESSAGECACHE *plt = mail_elt (stream,elt->msgno-1);
yuuji@0	1940 /* uh-oh, calculate delta? */
yuuji@0	1941 i = curpos - pos;
yuuji@0	1942 sprintf (tmp,shortmsg,plt->msgno,plt->private.uid,
yuuji@0	1943 i,pos,curpos);
yuuji@0	1944 /* possible to fix? */
yuuji@0	1945 if (!stream->rdonly && LOCAL->expok &&
yuuji@0	1946 (i < plt->rfc822_size)) {
yuuji@0	1947 plt->rfc822_size -= i;
yuuji@0	1948 if (plt->rfc822_size <
yuuji@0	1949 plt->private.msg.header.text.size)
yuuji@0	1950 plt->private.msg.header.text.size =
yuuji@0	1951 plt->rfc822_size;
yuuji@0	1952 strcat (tmp,", repaired");
yuuji@0	1953 indexrepairneeded = T;
yuuji@0	1954 }
yuuji@0	1955 MM_LOG (tmp,WARN);
yuuji@0	1956 }
yuuji@0	1957 }
yuuji@0	1958 else { /* new file, restart */
yuuji@0	1959 if (stat (mix_file_data (LOCAL->buf,stream->mailbox,
yuuji@0	1960 curfile = file),&sbuf)) {
yuuji@0	1961 sprintf (tmp,"Missing mix data file: %.500s",
yuuji@0	1962 LOCAL->buf);
yuuji@0	1963 MM_LOG (tmp,ERROR);
yuuji@0	1964 return NIL;
yuuji@0	1965 }
yuuji@0	1966 curfile = file;
yuuji@0	1967 curfilesize = sbuf.st_size;
yuuji@0	1968 }
yuuji@0	1969
yuuji@0	1970 /* position of message in file */
yuuji@0	1971 curpos = pos + elt->private.msg.header.offset +
yuuji@0	1972 elt->rfc822_size;
yuuji@0	1973 /* short file? */
yuuji@0	1974 if (curfilesize < curpos) {
yuuji@0	1975 /* uh-oh, calculate delta? */
yuuji@0	1976 i = curpos - curfilesize;
yuuji@0	1977 sprintf (tmp,shortmsg,elt->msgno,elt->private.uid,
yuuji@0	1978 i,curfilesize,curpos);
yuuji@0	1979 /* possible to fix? */
yuuji@0	1980 if (!stream->rdonly && LOCAL->expok &&
yuuji@0	1981 (i < elt->rfc822_size)) {
yuuji@0	1982 elt->rfc822_size -= i;
yuuji@0	1983 if (elt->rfc822_size <
yuuji@0	1984 elt->private.msg.header.text.size)
yuuji@0	1985 elt->private.msg.header.text.size =
yuuji@0	1986 elt->rfc822_size;
yuuji@0	1987 strcat (tmp,", repaired");
yuuji@0	1988 indexrepairneeded = T;
yuuji@0	1989 }
yuuji@0	1990 MM_LOG (tmp,WARN);
yuuji@0	1991 }
yuuji@0	1992 }
yuuji@0	1993 break;
yuuji@0	1994 }
yuuji@0	1995 else msg = "expansion";
yuuji@0	1996 }
yuuji@0	1997 else msg = "header size";
yuuji@0	1998 }
yuuji@0	1999 else msg = "header position";
yuuji@0	2000 }
yuuji@0	2001 else msg = "message position";
yuuji@0	2002 }
yuuji@0	2003 else msg = "file#";
yuuji@0	2004 }
yuuji@0	2005 sprintf (tmp,"Error in %s in mix index file: %.500s",msg,s);
yuuji@0	2006 MM_LOG (tmp,ERROR);
yuuji@0	2007 return NIL;
yuuji@0	2008 default:
yuuji@0	2009 sprintf (tmp,"Unknown record in mix index file: %.500s",s);
yuuji@0	2010 MM_LOG (tmp,ERROR);
yuuji@0	2011 return NIL;
yuuji@0	2012 }
yuuji@0	2013 if (!s) return NIL; /* barfage from mix_read_record() */
yuuji@0	2014 /* expunge trailing messages not in index */
yuuji@0	2015 if (LOCAL->expok) while (nmsgs < stream->nmsgs)
yuuji@0	2016 mail_expunged (stream,stream->nmsgs);
yuuji@0	2017 }
yuuji@0	2018
yuuji@0	2019 /* repair metadata and index if needed */
yuuji@0	2020 if ((metarepairneeded ? mix_meta_update (stream) : T) &&
yuuji@0	2021 (indexrepairneeded ? mix_index_update (stream,*idxf,NIL) : T)) {
yuuji@0	2022 MESSAGECACHE *elt;
yuuji@0	2023 int fd;
yuuji@0	2024 unsigned long uid,uf,sf,mod;
yuuji@0	2025 char *s;
yuuji@0	2026 int updatep = NIL;
yuuji@0	2027 /* open status file */
yuuji@0	2028 if ((fd = open (LOCAL->status,
yuuji@0	2029 stream->rdonly ? O_RDONLY : O_RDWR,NIL)) < 0)
yuuji@0	2030 MM_LOG ("Error opening mix status file",ERROR);
yuuji@0	2031 /* acquire exclusive access and FILE */
yuuji@0	2032 else if (!flock (fd,stream->rdonly ? LOCK_SH : LOCK_EX) &&
yuuji@0	2033 !(statf = fdopen (fd,stream->rdonly ? "rb" : "r+b"))) {
yuuji@0	2034 MM_LOG ("Error obtaining stream on mix status file",ERROR);
yuuji@0	2035 flock (fd,LOCK_UN); /* relinquish lock */
yuuji@0	2036 close (fd);
yuuji@0	2037 }
yuuji@0	2038 /* get sequence */
yuuji@0	2039 else if (!(i = mix_read_sequence (statf)) \|\|
yuuji@0	2040 ((i < LOCAL->statusseq) && stream->nmsgs && (i != 1))) {
yuuji@0	2041 sprintf (LOCAL->buf,
yuuji@0	2042 "Error in mix status sequence record, i=%lx, seq=%lx",
yuuji@0	2043 i,LOCAL->statusseq);
yuuji@0	2044 MM_LOG (LOCAL->buf,ERROR);
yuuji@0	2045 }
yuuji@0	2046 /* sequence changed from last time? */
yuuji@0	2047 else if (i != LOCAL->statusseq) {
yuuji@0	2048 /* update sequence, get first elt */
yuuji@0	2049 if (i > LOCAL->statusseq) LOCAL->statusseq = i;
yuuji@0	2050 if (stream->nmsgs) {
yuuji@0	2051 elt = mail_elt (stream,i = 1);
yuuji@0	2052
yuuji@0	2053 /* read message records */
yuuji@0	2054 while ((t = s = mix_read_record (statf,LOCAL->buf,LOCAL->buflen,
yuuji@0	2055 "status")) && s && (s++ == ':') &&
yuuji@0	2056 isxdigit (*s)) {
yuuji@0	2057 uid = strtoul (s,&s,16);
yuuji@0	2058 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	2059 uf = strtoul (s,&s,16);
yuuji@0	2060 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	2061 sf = strtoul (s,&s,16);
yuuji@0	2062 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	2063 mod = strtoul (s,&s,16);
yuuji@0	2064 /* ignore expansion values */
yuuji@0	2065 if (*s++ == ':') {
yuuji@0	2066 /* need to move ahead to next elt? */
yuuji@0	2067 while ((uid > elt->private.uid) && (i < stream->nmsgs))
yuuji@0	2068 elt = mail_elt (stream,++i);
yuuji@0	2069 /* update elt if altered */
yuuji@0	2070 if ((uid == elt->private.uid) &&
yuuji@0	2071 (!elt->valid \|\| (mod != elt->private.mod))) {
yuuji@0	2072 elt->user_flags = uf;
yuuji@0	2073 elt->private.mod = mod;
yuuji@0	2074 elt->seen = (sf & fSEEN) ? T : NIL;
yuuji@0	2075 elt->deleted = (sf & fDELETED) ? T : NIL;
yuuji@0	2076 elt->flagged = (sf & fFLAGGED) ? T : NIL;
yuuji@0	2077 elt->answered = (sf & fANSWERED) ? T : NIL;
yuuji@0	2078 elt->draft = (sf & fDRAFT) ? T : NIL;
yuuji@0	2079 /* announce if altered existing message */
yuuji@0	2080 if (elt->valid) MM_FLAGS (stream,elt->msgno);
yuuji@0	2081 /* first time, is old message? */
yuuji@0	2082 else if (sf & fOLD) {
yuuji@0	2083 /* yes, clear recent and set valid */
yuuji@0	2084 elt->recent = NIL;
yuuji@0	2085 elt->valid = T;
yuuji@0	2086 }
yuuji@0	2087 /* recent, allowed to update its status? */
yuuji@0	2088 else if (sflags) {
yuuji@0	2089 /* yes, set valid and check in status */
yuuji@0	2090 elt->valid = T;
yuuji@0	2091 elt->private.mod = mix_modseq (elt->private.mod);
yuuji@0	2092 updatep = T;
yuuji@0	2093 }
yuuji@0	2094 /* leave valid unset and recent if sflags not set */
yuuji@0	2095 }
yuuji@0	2096 continue; /* everything looks good */
yuuji@0	2097 }
yuuji@0	2098 }
yuuji@0	2099 }
yuuji@0	2100 }
yuuji@0	2101 break; /* error somewhere */
yuuji@0	2102 }
yuuji@0	2103
yuuji@0	2104 if (t && t) { / non-null means bogus record */
yuuji@0	2105 char msg[MAILTMPLEN];
yuuji@0	2106 sprintf (msg,"Error in mix status file message record%s: %.80s",
yuuji@0	2107 stream->rdonly ? "" : ", fixing",t);
yuuji@0	2108 MM_LOG (msg,WARN);
yuuji@0	2109 /* update it if not readonly */
yuuji@0	2110 if (!stream->rdonly) updatep = T;
yuuji@0	2111 }
yuuji@0	2112 if (updatep) { /* need to update? */
yuuji@0	2113 LOCAL->statusseq = mix_modseq (LOCAL->statusseq);
yuuji@0	2114 mix_status_update (stream,statf,LONGT);
yuuji@0	2115 }
yuuji@0	2116 }
yuuji@0	2117 }
yuuji@0	2118 }
yuuji@0	2119 }
yuuji@0	2120 if (statf) { /* still happy? */
yuuji@0	2121 unsigned long j;
yuuji@0	2122 stream->silent = silent; /* now notify upper level */
yuuji@0	2123 mail_exists (stream,stream->nmsgs);
yuuji@0	2124 for (i = 1, j = 0; i <= stream->nmsgs; ++i)
yuuji@0	2125 if (mail_elt (stream,i)->recent) ++j;
yuuji@0	2126 mail_recent (stream,j);
yuuji@0	2127 }
yuuji@0	2128 return statf;
yuuji@0	2129 }
yuuji@0	2130
yuuji@0	2131 /* MIX metadata file routines */
yuuji@0	2132
yuuji@0	2133 /* MIX read metadata
yuuji@0	2134 * Accepts: MAIL stream
yuuji@0	2135 * return pointer for modseq
yuuji@0	2136 * Returns: pointer to metadata after modseq or NIL if failure
yuuji@0	2137 */
yuuji@0	2138
yuuji@0	2139 char mix_meta_slurp (MAILSTREAM stream,unsigned long *seq)
yuuji@0	2140 {
yuuji@0	2141 struct stat sbuf;
yuuji@0	2142 char *s;
yuuji@0	2143 char *ret = NIL;
yuuji@0	2144 if (fstat (LOCAL->mfd,&sbuf))
yuuji@0	2145 MM_LOG ("Error obtaining size of mix metatdata file",ERROR);
yuuji@0	2146 if (sbuf.st_size > LOCAL->buflen) {
yuuji@0	2147 /* should be just a few dozen bytes */
yuuji@0	2148 if (sbuf.st_size > METAMAX) fatal ("absurd mix metadata file size");
yuuji@0	2149 fs_give ((void **) &LOCAL->buf);
yuuji@0	2150 LOCAL->buf = (char *) fs_get ((LOCAL->buflen = sbuf.st_size) + 1);
yuuji@0	2151 }
yuuji@0	2152 /* read current metadata file */
yuuji@0	2153 LOCAL->buf[sbuf.st_size] = '\0';
yuuji@0	2154 if (lseek (LOCAL->mfd,0,L_SET) \|\|
yuuji@0	2155 (read (LOCAL->mfd,s = LOCAL->buf,sbuf.st_size) != sbuf.st_size))
yuuji@0	2156 MM_LOG ("Error reading mix metadata file",ERROR);
yuuji@0	2157 else if ((*s != 'S') \|\| !isxdigit (s[1]) \|\|
yuuji@0	2158 ((*seq = strtoul (s+1,&s,16)) < LOCAL->metaseq) \|\|
yuuji@0	2159 (s++ != '\015') \|\| (s++ != '\012'))
yuuji@0	2160 MM_LOG ("Error in mix metadata file sequence record",ERROR);
yuuji@0	2161 else ret = s;
yuuji@0	2162 return ret;
yuuji@0	2163 }
yuuji@0	2164
yuuji@0	2165 /* MIX update metadata
yuuji@0	2166 * Accepts: MAIL stream
yuuji@0	2167 * Returns: T on success, NIL if error
yuuji@0	2168 *
yuuji@0	2169 * Index MUST be locked!!
yuuji@0	2170 */
yuuji@0	2171
yuuji@0	2172 long mix_meta_update (MAILSTREAM *stream)
yuuji@0	2173 {
yuuji@0	2174 long ret;
yuuji@0	2175 /* do nothing if stream readonly */
yuuji@0	2176 if (stream->rdonly) ret = LONGT;
yuuji@0	2177 else {
yuuji@0	2178 unsigned char c,s,ss,*t;
yuuji@0	2179 unsigned long i;
yuuji@0	2180 /* The worst-case metadata is limited to:
yuuji@0	2181 * 4 * (1 + 8 + 2) + (NUSERFLAGS * (MAXUSERFLAG + 1))
yuuji@0	2182 * which comes out to 1994 octets. This is much smaller than the normal
yuuji@0	2183 * CHUNKSIZE definition of 64K, and CHUNKSIZE is the smallest size of
yuuji@0	2184 * LOCAL->buf.
yuuji@0	2185 *
yuuji@0	2186 * If more stuff gets added to the metadata, or if you change the value
yuuji@0	2187 * of NUSERFLAGS, MAXUSERFLAG or CHUNKSIZE, be sure to recalculate the
yuuji@0	2188 * above assertation.
yuuji@0	2189 */
yuuji@0	2190 sprintf (LOCAL->buf,SEQFMT,LOCAL->metaseq = mix_modseq (LOCAL->metaseq));
yuuji@0	2191 sprintf (LOCAL->buf + strlen (LOCAL->buf),MTAFMT,
yuuji@0	2192 stream->uid_validity,stream->uid_last,LOCAL->newmsg);
yuuji@0	2193 for (i = 0, c = 'K', s = ss = LOCAL->buf + strlen (LOCAL->buf);
yuuji@0	2194 (i < NUSERFLAGS) && (t = stream->user_flags[i]); ++i) {
yuuji@0	2195 if (!*t) fatal ("impossible empty keyword");
yuuji@0	2196 s++ = c; / write delimiter */
yuuji@0	2197 while (t) s++ = t++; / write keyword */
yuuji@0	2198 c = ' '; /* delimiter is now space */
yuuji@0	2199 }
yuuji@0	2200 if (s != ss) { /* tie off keywords line */
yuuji@0	2201 s++ = '\015'; s++ = '\012';
yuuji@0	2202 }
yuuji@0	2203 /* calculate length of metadata */
yuuji@0	2204 if ((i = s - LOCAL->buf) > LOCAL->buflen)
yuuji@0	2205 fatal ("impossible buffer overflow");
yuuji@0	2206 lseek (LOCAL->mfd,0,L_SET); /* rewind file */
yuuji@0	2207 /* write new metadata */
yuuji@0	2208 ret = (write (LOCAL->mfd,LOCAL->buf,i) == i) ? LONGT : NIL;
yuuji@0	2209 ftruncate (LOCAL->mfd,i); /* and tie off at that point */
yuuji@0	2210 }
yuuji@0	2211 return ret;
yuuji@0	2212 }
yuuji@0	2213
yuuji@0	2214 /* MIX index file routines */
yuuji@0	2215
yuuji@0	2216
yuuji@0	2217 /* MIX update index
yuuji@0	2218 * Accepts: MAIL stream
yuuji@0	2219 * open FILE
yuuji@0	2220 * expansion check flag
yuuji@0	2221 * Returns: T on success, NIL if error
yuuji@0	2222 */
yuuji@0	2223
yuuji@0	2224 long mix_index_update (MAILSTREAM stream,FILE idxf,long flag)
yuuji@0	2225 {
yuuji@0	2226 unsigned long i;
yuuji@0	2227 long ret = LONGT;
yuuji@0	2228 if (!stream->rdonly) { /* do nothing if stream readonly */
yuuji@0	2229 if (flag) { /* need to do expansion check? */
yuuji@0	2230 char tmp[MAILTMPLEN];
yuuji@0	2231 size_t size;
yuuji@0	2232 struct stat sbuf;
yuuji@0	2233 /* calculate file size we need */
yuuji@0	2234 for (i = 1, size = 0; i <= stream->nmsgs; ++i)
yuuji@0	2235 if (!mail_elt (stream,i)->private.ghost) ++size;
yuuji@0	2236 if (size) { /* Winston Smith's first dairy entry */
yuuji@0	2237 sprintf (tmp,IXRFMT,0,14,4,4,13,0,0,'+',0,0,0,0,0,0,0);
yuuji@0	2238 size *= strlen (tmp);
yuuji@0	2239 }
yuuji@0	2240 /* calculate file size we need */
yuuji@0	2241 sprintf (tmp,SEQFMT,LOCAL->indexseq);
yuuji@0	2242 size += strlen (tmp);
yuuji@0	2243 /* get current file size */
yuuji@0	2244 if (fstat (fileno (idxf),&sbuf)) {
yuuji@0	2245 MM_LOG ("Error getting size of mix index file",ERROR);
yuuji@0	2246 ret = NIL;
yuuji@0	2247 }
yuuji@0	2248 /* need to write additional space? */
yuuji@0	2249 else if (sbuf.st_size < size) {
yuuji@0	2250 void *buf = fs_get (size -= sbuf.st_size);
yuuji@0	2251 memset (buf,0,size);
yuuji@0	2252 if (fseek (idxf,0,SEEK_END) \|\| (fwrite (buf,1,size,idxf) != size) \|\|
yuuji@0	2253 fflush (idxf)) {
yuuji@0	2254 fseek (idxf,sbuf.st_size,SEEK_SET);
yuuji@0	2255 ftruncate (fileno (idxf),sbuf.st_size);
yuuji@0	2256 MM_LOG ("Error extending mix index file",ERROR);
yuuji@0	2257 ret = NIL;
yuuji@0	2258 }
yuuji@0	2259 fs_give ((void **) &buf);
yuuji@0	2260 }
yuuji@0	2261 }
yuuji@0	2262
yuuji@0	2263 if (ret) { /* if still good to go */
yuuji@0	2264 rewind (idxf); /* let's start at the very beginning */
yuuji@0	2265 /* write modseq first */
yuuji@0	2266 fprintf (idxf,SEQFMT,LOCAL->indexseq);
yuuji@0	2267 /* then write all messages */
yuuji@0	2268 for (i = 1; ret && (i <= stream->nmsgs); i++) {
yuuji@0	2269 MESSAGECACHE *elt = mail_elt (stream,i);
yuuji@0	2270 if (!elt->private.ghost)/* only write living messages */
yuuji@0	2271 fprintf (idxf,IXRFMT,elt->private.uid,
yuuji@0	2272 elt->year + BASEYEAR,elt->month,elt->day,
yuuji@0	2273 elt->hours,elt->minutes,elt->seconds,
yuuji@0	2274 elt->zoccident ? '-' : '+',elt->zhours,elt->zminutes,
yuuji@0	2275 elt->rfc822_size,elt->private.spare.data,
yuuji@0	2276 elt->private.special.offset,
yuuji@0	2277 elt->private.msg.header.offset,
yuuji@0	2278 elt->private.msg.header.text.size);
yuuji@0	2279 if (ferror (idxf)) {
yuuji@0	2280 MM_LOG ("Error updating mix index file",ERROR);
yuuji@0	2281 ret = NIL;
yuuji@0	2282 }
yuuji@0	2283 }
yuuji@0	2284 if (fflush (idxf)) {
yuuji@0	2285 MM_LOG ("Error flushing mix index file",ERROR);
yuuji@0	2286 ret = NIL;
yuuji@0	2287 }
yuuji@0	2288 if (ret) ftruncate (fileno (idxf),ftell (idxf));
yuuji@0	2289 }
yuuji@0	2290 }
yuuji@0	2291 return ret;
yuuji@0	2292 }
yuuji@0	2293
yuuji@0	2294 /* MIX status file routines */
yuuji@0	2295
yuuji@0	2296
yuuji@0	2297 /* MIX update status
yuuji@0	2298 * Accepts: MAIL stream
yuuji@0	2299 * pointer to open FILE
yuuji@0	2300 * expansion check flag
yuuji@0	2301 * Returns: T on success, NIL if error
yuuji@0	2302 */
yuuji@0	2303
yuuji@0	2304 long mix_status_update (MAILSTREAM stream,FILE statf,long flag)
yuuji@0	2305 {
yuuji@0	2306 unsigned long i;
yuuji@0	2307 char tmp[MAILTMPLEN];
yuuji@0	2308 long ret = LONGT;
yuuji@0	2309 if (!stream->rdonly) { /* do nothing if stream readonly */
yuuji@0	2310 if (flag) { /* need to do expansion check? */
yuuji@0	2311 char tmp[MAILTMPLEN];
yuuji@0	2312 size_t size;
yuuji@0	2313 struct stat sbuf;
yuuji@0	2314 /* calculate file size we need */
yuuji@0	2315 for (i = 1, size = 0; i <= stream->nmsgs; ++i)
yuuji@0	2316 if (!mail_elt (stream,i)->private.ghost) ++size;
yuuji@0	2317 if (size) { /* number of living messages */
yuuji@0	2318 sprintf (tmp,STRFMT,0,0,0,0);
yuuji@0	2319 size *= strlen (tmp);
yuuji@0	2320 }
yuuji@0	2321 sprintf (tmp,SEQFMT,LOCAL->statusseq);
yuuji@0	2322 size += strlen (tmp);
yuuji@0	2323 /* get current file size */
yuuji@0	2324 if (fstat (fileno (statf),&sbuf)) {
yuuji@0	2325 MM_LOG ("Error getting size of mix status file",ERROR);
yuuji@0	2326 ret = NIL;
yuuji@0	2327 }
yuuji@0	2328 /* need to write additional space? */
yuuji@0	2329 else if (sbuf.st_size < size) {
yuuji@0	2330 void *buf = fs_get (size -= sbuf.st_size);
yuuji@0	2331 memset (buf,0,size);
yuuji@0	2332 if (fseek (statf,0,SEEK_END) \|\| (fwrite (buf,1,size,statf) != size) \|\|
yuuji@0	2333 fflush (statf)) {
yuuji@0	2334 fseek (statf,sbuf.st_size,SEEK_SET);
yuuji@0	2335 ftruncate (fileno (statf),sbuf.st_size);
yuuji@0	2336 MM_LOG ("Error extending mix status file",ERROR);
yuuji@0	2337 ret = NIL;
yuuji@0	2338 }
yuuji@0	2339 fs_give ((void **) &buf);
yuuji@0	2340 }
yuuji@0	2341 }
yuuji@0	2342
yuuji@0	2343 if (ret) { /* if still good to go */
yuuji@0	2344 rewind (statf); /* let's start at the very beginning */
yuuji@0	2345 /* write sequence */
yuuji@0	2346 fprintf (statf,SEQFMT,LOCAL->statusseq);
yuuji@0	2347 /* write message status records */
yuuji@0	2348 for (i = 1; ret && (i <= stream->nmsgs); ++i) {
yuuji@0	2349 MESSAGECACHE *elt = mail_elt (stream,i);
yuuji@0	2350 /* make sure all messages have a modseq */
yuuji@0	2351 if (!elt->private.mod) elt->private.mod = LOCAL->statusseq;
yuuji@0	2352 if (!elt->private.ghost)/* only write living messages */
yuuji@0	2353 fprintf (statf,STRFMT,elt->private.uid,elt->user_flags,
yuuji@0	2354 (fSEEN * elt->seen) + (fDELETED * elt->deleted) +
yuuji@0	2355 (fFLAGGED * elt->flagged) + (fANSWERED * elt->answered) +
yuuji@0	2356 (fDRAFT * elt->draft) + (elt->valid ? fOLD : NIL),
yuuji@0	2357 elt->private.mod);
yuuji@0	2358 if (ferror (statf)) {
yuuji@0	2359 sprintf (tmp,"Error updating mix status file: %.80s",
yuuji@0	2360 strerror (errno));
yuuji@0	2361 MM_LOG (tmp,ERROR);
yuuji@0	2362 ret = NIL;
yuuji@0	2363 }
yuuji@0	2364 }
yuuji@0	2365 if (ret && fflush (statf)) {
yuuji@0	2366 MM_LOG ("Error flushing mix status file",ERROR);
yuuji@0	2367 ret = NIL;
yuuji@0	2368 }
yuuji@0	2369 if (ret) ftruncate (fileno (statf),ftell (statf));
yuuji@0	2370 }
yuuji@0	2371 }
yuuji@0	2372 return ret;
yuuji@0	2373 }
yuuji@0	2374
yuuji@0	2375 /* MIX data file routines */
yuuji@0	2376
yuuji@0	2377
yuuji@0	2378 /* MIX open data file
yuuji@0	2379 * Accepts: MAIL stream
yuuji@0	2380 * pointer to returned fd if success
yuuji@0	2381 * pointer to returned size if success
yuuji@0	2382 * size of new data to be added
yuuji@0	2383 * Returns: open FILE, or NIL if failure
yuuji@0	2384 *
yuuji@0	2385 * The curend test assumes that the last message of the mailbox is the furthest
yuuji@0	2386 * point that the current data file extends, and thus that is all that needs to
yuuji@0	2387 * be tested for short file prevention.
yuuji@0	2388 */
yuuji@0	2389
yuuji@0	2390 FILE mix_data_open (MAILSTREAM stream,int fd,long size,
yuuji@0	2391 unsigned long newsize)
yuuji@0	2392 {
yuuji@0	2393 FILE *msgf = NIL;
yuuji@0	2394 struct stat sbuf;
yuuji@0	2395 MESSAGECACHE *elt = stream->nmsgs ? mail_elt (stream,stream->nmsgs) : NIL;
yuuji@0	2396 unsigned long curend = (elt && (elt->private.spare.data == LOCAL->newmsg)) ?
yuuji@0	2397 elt->private.special.offset + elt->private.msg.header.offset +
yuuji@0	2398 elt->rfc822_size : 0;
yuuji@0	2399 /* allow create if curend 0 */
yuuji@0	2400 if ((*fd = open (mix_file_data (LOCAL->buf,stream->mailbox,LOCAL->newmsg),
yuuji@0	2401 O_RDWR \| (curend ? NIL : O_CREAT),NIL)) >= 0) {
yuuji@0	2402 fstat (fd,&sbuf); / get current file size */
yuuji@0	2403 /* can we use this file? */
yuuji@0	2404 if ((curend <= sbuf.st_size) &&
yuuji@0	2405 (!sbuf.st_size \|\| ((sbuf.st_size + newsize) <= MIXDATAROLL)))
yuuji@0	2406 size = sbuf.st_size; / yes, return current size */
yuuji@0	2407 else { /* short file or becoming too long */
yuuji@0	2408 if (curend > sbuf.st_size) {
yuuji@0	2409 char tmp[MAILTMPLEN];
yuuji@0	2410 sprintf (tmp,"short mix message file %.08lx (%ld > %ld), rolling",
yuuji@0	2411 LOCAL->newmsg,curend,sbuf.st_size);
yuuji@0	2412 MM_LOG (tmp,WARN); /* shouldn't happen */
yuuji@0	2413 }
yuuji@0	2414 close (fd); / roll to a new file */
yuuji@0	2415 while ((*fd = open (mix_file_data
yuuji@0	2416 (LOCAL->buf,stream->mailbox,
yuuji@0	2417 LOCAL->newmsg = mix_modseq (LOCAL->newmsg)),
yuuji@0	2418 O_RDWR \| O_CREAT \| O_EXCL,sbuf.st_mode)) < 0);
yuuji@0	2419 size = 0; / brand new file */
yuuji@0	2420 fchmod (fd,sbuf.st_mode);/ with same mode as previous file */
yuuji@0	2421 }
yuuji@0	2422 }
yuuji@0	2423 if (fd >= 0) { / have a data file? */
yuuji@0	2424 /* yes, get stdio and set position */
yuuji@0	2425 if (msgf = fdopen (fd,"r+b")) fseek (msgf,size,SEEK_SET);
yuuji@0	2426 else close (fd); / fdopen() failed? */
yuuji@0	2427 }
yuuji@0	2428 return msgf; /* return results */
yuuji@0	2429 }
yuuji@0	2430
yuuji@0	2431 /* MIX open sortcache
yuuji@0	2432 * Accepts: MAIL stream
yuuji@0	2433 * Returns: open FILE, or NIL if failure or could only get readonly sortcache
yuuji@0	2434 */
yuuji@0	2435
yuuji@0	2436 FILE mix_sortcache_open (MAILSTREAM stream)
yuuji@0	2437 {
yuuji@0	2438 int fd,refwd;
yuuji@0	2439 unsigned long i,uid,sentdate,fromlen,tolen,cclen,subjlen,msgidlen,reflen;
yuuji@0	2440 char s,t,*msg,tmp[MAILTMPLEN];
yuuji@0	2441 MESSAGECACHE *elt;
yuuji@0	2442 SORTCACHE *sc;
yuuji@0	2443 STRINGLIST *sl;
yuuji@0	2444 struct stat sbuf;
yuuji@0	2445 int rdonly = NIL;
yuuji@0	2446 FILE *srtcf = NIL;
yuuji@0	2447 mailcache_t mc = (mailcache_t) mail_parameters (NIL,GET_CACHE,NIL);
yuuji@0	2448 fstat (LOCAL->mfd,&sbuf);
yuuji@0	2449 if (!stream->nmsgs); /* do nothing if mailbox empty */
yuuji@0	2450 /* open sortcache file */
yuuji@0	2451 else if (((fd = open (LOCAL->sortcache,O_RDWR\|O_CREAT,sbuf.st_mode)) < 0) &&
yuuji@0	2452 !(rdonly = ((fd = open (LOCAL->sortcache,O_RDONLY,NIL)) >= 0)))
yuuji@0	2453 MM_LOG ("Error opening mix sortcache file",WARN);
yuuji@0	2454 /* acquire lock and FILE */
yuuji@0	2455 else if (!flock (fd,rdonly ? LOCK_SH : LOCK_EX) &&
yuuji@0	2456 !(srtcf = fdopen (fd,rdonly ? "rb" : "r+b"))) {
yuuji@0	2457 MM_LOG ("Error obtaining stream on mix sortcache file",WARN);
yuuji@0	2458 flock (fd,LOCK_UN); /* relinquish lock */
yuuji@0	2459 close (fd);
yuuji@0	2460 }
yuuji@0	2461 else if (!(i = mix_read_sequence (srtcf)) \|\| (i < LOCAL->sortcacheseq))
yuuji@0	2462 MM_LOG ("Error in mix sortcache file sequence record",WARN);
yuuji@0	2463 /* sequence changed from last time? */
yuuji@0	2464 else if (i > LOCAL->sortcacheseq) {
yuuji@0	2465 LOCAL->sortcacheseq = i; /* update sequence */
yuuji@0	2466 while ((s = t = mix_read_record (srtcf,LOCAL->buf,LOCAL->buflen,
yuuji@0	2467 "sortcache")) && *s &&
yuuji@0	2468 (msg = "uid") && (s++ == ':') && isxdigit (s)) {
yuuji@0	2469 uid = strtoul (s,&s,16);
yuuji@0	2470 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	2471 sentdate = strtoul (s,&s,16);
yuuji@0	2472 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	2473 fromlen = strtoul (s,&s,16);
yuuji@0	2474 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	2475 tolen = strtoul (s,&s,16);
yuuji@0	2476 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	2477 cclen = strtoul (s,&s,16);
yuuji@0	2478 if ((s++ == ':') && ((s == 'R') \|\| (*s == ' ')) &&
yuuji@0	2479 isxdigit (s[1])) {
yuuji@0	2480 refwd = (*s++ == 'R') ? T : NIL;
yuuji@0	2481 subjlen = strtoul (s,&s,16);
yuuji@0	2482 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	2483 msgidlen = strtoul (s,&s,16);
yuuji@0	2484 if ((s++ == ':') && isxdigit (s)) {
yuuji@0	2485 reflen = strtoul (s,&s,16);
yuuji@0	2486 /* ignore expansion values */
yuuji@0	2487 if (*s++ == ':') {
yuuji@0	2488
yuuji@0	2489 if (i = mail_msgno (stream,uid)) {
yuuji@0	2490 sc = (SORTCACHE ) (mc) (stream,i,CH_SORTCACHE);
yuuji@0	2491 sc->size = (elt = mail_elt (stream,i))->rfc822_size;
yuuji@0	2492 sc->date = sentdate;
yuuji@0	2493 sc->arrival = elt->day ? mail_longdate (elt) : 1;
yuuji@0	2494 if (refwd) sc->refwd = T;
yuuji@0	2495 if (fromlen) {
yuuji@0	2496 if (sc->from) fseek (srtcf,fromlen + 2,SEEK_CUR);
yuuji@0	2497 else if ((getc (srtcf) != 'F') \|\|
yuuji@0	2498 (fread (sc->from = (char *) fs_get(fromlen),
yuuji@0	2499 1,fromlen-1,srtcf) != (fromlen-1))\|\|
yuuji@0	2500 (sc->from[fromlen-1] = '\0') \|\|
yuuji@0	2501 (getc (srtcf) != '\015') \|\|
yuuji@0	2502 (getc (srtcf) != '\012')) {
yuuji@0	2503 msg = "from data";
yuuji@0	2504 break;
yuuji@0	2505 }
yuuji@0	2506 }
yuuji@0	2507 if (tolen) {
yuuji@0	2508 if (sc->to) fseek (srtcf,tolen + 2,SEEK_CUR);
yuuji@0	2509 else if ((getc (srtcf) != 'T') \|\|
yuuji@0	2510 (fread (sc->to = (char *) fs_get (tolen),
yuuji@0	2511 1,tolen-1,srtcf) != (tolen - 1)) \|\|
yuuji@0	2512 (sc->to[tolen-1] = '\0') \|\|
yuuji@0	2513 (getc (srtcf) != '\015') \|\|
yuuji@0	2514 (getc (srtcf) != '\012')) {
yuuji@0	2515 msg = "to data";
yuuji@0	2516 break;
yuuji@0	2517 }
yuuji@0	2518 }
yuuji@0	2519 if (cclen) {
yuuji@0	2520 if (sc->cc) fseek (srtcf,cclen + 2,SEEK_CUR);
yuuji@0	2521 else if ((getc (srtcf) != 'C') \|\|
yuuji@0	2522 (fread (sc->cc = (char *) fs_get (cclen),
yuuji@0	2523 1,cclen-1,srtcf) != (cclen - 1)) \|\|
yuuji@0	2524 (sc->cc[cclen-1] = '\0') \|\|
yuuji@0	2525 (getc (srtcf) != '\015') \|\|
yuuji@0	2526 (getc (srtcf) != '\012')) {
yuuji@0	2527 msg = "cc data";
yuuji@0	2528 break;
yuuji@0	2529 }
yuuji@0	2530 }
yuuji@0	2531 if (subjlen) {
yuuji@0	2532 if (sc->subject) fseek (srtcf,subjlen + 2,SEEK_CUR);
yuuji@0	2533 else if ((getc (srtcf) != 'S') \|\|
yuuji@0	2534 (fread (sc->subject =
yuuji@0	2535 (char *) fs_get (subjlen),1,
yuuji@0	2536 subjlen-1,srtcf) != (subjlen-1))\|\|
yuuji@0	2537 (sc->subject[subjlen-1] = '\0') \|\|
yuuji@0	2538 (getc (srtcf) != '\015') \|\|
yuuji@0	2539 (getc (srtcf) != '\012')) {
yuuji@0	2540 msg = "subject data";
yuuji@0	2541 break;
yuuji@0	2542 }
yuuji@0	2543 }
yuuji@0	2544
yuuji@0	2545 if (msgidlen) {
yuuji@0	2546 if (sc->message_id)
yuuji@0	2547 fseek (srtcf,msgidlen + 2,SEEK_CUR);
yuuji@0	2548 else if ((getc (srtcf) != 'M') \|\|
yuuji@0	2549 (fread (sc->message_id =
yuuji@0	2550 (char *) fs_get (msgidlen),1,
yuuji@0	2551 msgidlen-1,srtcf) != (msgidlen-1))\|\|
yuuji@0	2552 (sc->message_id[msgidlen-1] = '\0') \|\|
yuuji@0	2553 (getc (srtcf) != '\015') \|\|
yuuji@0	2554 (getc (srtcf) != '\012')) {
yuuji@0	2555 msg = "message-id data";
yuuji@0	2556 break;
yuuji@0	2557 }
yuuji@0	2558 }
yuuji@0	2559 if (reflen) {
yuuji@0	2560 if (sc->references) fseek(srtcf,reflen + 2,SEEK_CUR);
yuuji@0	2561 /* make sure it fits */
yuuji@0	2562 else {
yuuji@0	2563 if (reflen >= LOCAL->buflen) {
yuuji@0	2564 fs_give ((void **) &LOCAL->buf);
yuuji@0	2565 LOCAL->buf = (char *)
yuuji@0	2566 fs_get ((LOCAL->buflen = reflen) + 1);
yuuji@0	2567 }
yuuji@0	2568 if ((getc (srtcf) != 'R') \|\|
yuuji@0	2569 (fread (LOCAL->buf,1,reflen-1,srtcf) !=
yuuji@0	2570 (reflen - 1)) \|\|
yuuji@0	2571 (LOCAL->buf[reflen-1] = '\0') \|\|
yuuji@0	2572 (getc (srtcf) != '\015') \|\|
yuuji@0	2573 (getc (srtcf) != '\012')) {
yuuji@0	2574 msg = "references data";
yuuji@0	2575 break;
yuuji@0	2576 }
yuuji@0	2577 for (s = LOCAL->buf,sl = NIL,
yuuji@0	2578 sc->references = mail_newstringlist ();
yuuji@0	2579 s && *s; s += i + 1) {
yuuji@0	2580 if ((i = strtoul (s,&s,16)) && (*s++ == ':') &&
yuuji@0	2581 (s[i] == ':')) {
yuuji@0	2582 if (sl) sl = sl->next = mail_newstringlist();
yuuji@0	2583 else sl = sc->references;
yuuji@0	2584 s[i] = '\0';
yuuji@0	2585 sl->text.data = cpystr (s);
yuuji@0	2586 sl->text.size = i;
yuuji@0	2587 }
yuuji@0	2588 else s = NIL;
yuuji@0	2589 }
yuuji@0	2590 if (!s \|\| *s \|\|
yuuji@0	2591 (s != ((char *) LOCAL->buf + reflen - 1))) {
yuuji@0	2592 msg = "references length consistency check";
yuuji@0	2593 break;
yuuji@0	2594 }
yuuji@0	2595 }
yuuji@0	2596 }
yuuji@0	2597 }
yuuji@0	2598
yuuji@0	2599 /* UID not found, ignore this message */
yuuji@0	2600 else fseek (srtcf,((fromlen ? fromlen + 2 : 0) +
yuuji@0	2601 (tolen ? tolen + 2 : 0) +
yuuji@0	2602 (cclen ? cclen + 2 : 0) +
yuuji@0	2603 (subjlen ? subjlen + 2 : 0) +
yuuji@0	2604 (msgidlen ? msgidlen + 2 : 0) +
yuuji@0	2605 (reflen ? reflen + 2 : 0)),
yuuji@0	2606 SEEK_CUR);
yuuji@0	2607 continue;
yuuji@0	2608 }
yuuji@0	2609 else msg = "expansion";
yuuji@0	2610 }
yuuji@0	2611 else msg = "references";
yuuji@0	2612 }
yuuji@0	2613 else msg = "message-id";
yuuji@0	2614 }
yuuji@0	2615 else msg = "subject";
yuuji@0	2616 }
yuuji@0	2617 else msg = "cc";
yuuji@0	2618 }
yuuji@0	2619 else msg = "to";
yuuji@0	2620 }
yuuji@0	2621 else msg = "from";
yuuji@0	2622 }
yuuji@0	2623 else msg = "sentdate";
yuuji@0	2624 break; /* error somewhere */
yuuji@0	2625 }
yuuji@0	2626 if (!t \|\| t) { / error detected? */
yuuji@0	2627 if (t) { /* non-null means bogus record */
yuuji@0	2628 sprintf (tmp,"Error in %s in mix sortcache record: %.500s",msg,t);
yuuji@0	2629 MM_LOG (tmp,WARN);
yuuji@0	2630 }
yuuji@0	2631 fclose (srtcf); /* either way, must punt */
yuuji@0	2632 srtcf = NIL;
yuuji@0	2633 }
yuuji@0	2634 }
yuuji@0	2635 if (rdonly && srtcf) { /* can't update if readonly */
yuuji@0	2636 unlink (LOCAL->sortcache); /* try deleting it */
yuuji@0	2637 fclose (srtcf); /* so close it and return as if error */
yuuji@0	2638 srtcf = NIL;
yuuji@0	2639 }
yuuji@0	2640 else fchmod (fd,sbuf.st_mode);
yuuji@0	2641 return srtcf;
yuuji@0	2642 }
yuuji@0	2643
yuuji@0	2644 /* MIX update and close sortcache
yuuji@0	2645 * Accepts: MAIL stream
yuuji@0	2646 * pointer to open FILE (if FILE is NIL, do nothing)
yuuji@0	2647 * Returns: T on success, NIL on error
yuuji@0	2648 */
yuuji@0	2649
yuuji@0	2650 long mix_sortcache_update (MAILSTREAM stream,FILE *sortcache)
yuuji@0	2651 {
yuuji@0	2652 FILE f = sortcache;
yuuji@0	2653 long ret = LONGT;
yuuji@0	2654 if (f) { /* ignore if no file */
yuuji@0	2655 unsigned long i,j;
yuuji@0	2656 mailcache_t mc = (mailcache_t) mail_parameters (NIL,GET_CACHE,NIL);
yuuji@0	2657 for (i = 1; (i <= stream->nmsgs) &&
yuuji@0	2658 !((SORTCACHE ) (mc) (stream,i,CH_SORTCACHE))->dirty; ++i);
yuuji@0	2659 if (i <= stream->nmsgs) { /* only update if some entry is dirty */
yuuji@0	2660 rewind (f); /* let's start at the very beginning */
yuuji@0	2661 /* write sequence */
yuuji@0	2662 fprintf (f,SEQFMT,LOCAL->sortcacheseq = mix_modseq(LOCAL->sortcacheseq));
yuuji@0	2663 for (i = 1; ret && (i <= stream->nmsgs); ++i) {
yuuji@0	2664 MESSAGECACHE *elt = mail_elt (stream,i);
yuuji@0	2665 SORTCACHE s = (SORTCACHE ) (*mc) (stream,i,CH_SORTCACHE);
yuuji@0	2666 STRINGLIST *sl;
yuuji@0	2667 s->dirty = NIL; /* no longer dirty */
yuuji@0	2668 if (sl = s->references) /* count length of references */
yuuji@0	2669 for (j = 1; sl && sl->text.data; sl = sl->next)
yuuji@0	2670 j += 10 + sl->text.size;
yuuji@0	2671 else j = 0; /* no references yet */
yuuji@0	2672 fprintf (f,SCRFMT,elt->private.uid,s->date,
yuuji@0	2673 s->from ? strlen (s->from) + 1 : 0,
yuuji@0	2674 s->to ? strlen (s->to) + 1 : 0,s->cc ? strlen (s->cc) + 1 : 0,
yuuji@0	2675 s->refwd ? 'R' : ' ',s->subject ? strlen (s->subject) + 1: 0,
yuuji@0	2676 s->message_id ? strlen (s->message_id) + 1 : 0,j);
yuuji@0	2677 if (s->from) fprintf (f,"F%s\015\012",s->from);
yuuji@0	2678 if (s->to) fprintf (f,"T%s\015\012",s->to);
yuuji@0	2679 if (s->cc) fprintf (f,"C%s\015\012",s->cc);
yuuji@0	2680 if (s->subject) fprintf (f,"S%s\015\012",s->subject);
yuuji@0	2681 if (s->message_id) fprintf (f,"M%s\015\012",s->message_id);
yuuji@0	2682 if (j) { /* any references to write? */
yuuji@0	2683 fputc ('R',f); /* yes, do so */
yuuji@0	2684 for (sl = s->references; sl && sl->text.data; sl = sl->next)
yuuji@0	2685 fprintf (f,"%08lx:%s:",sl->text.size,sl->text.data);
yuuji@0	2686 fputs ("\015\012",f);
yuuji@0	2687 }
yuuji@0	2688 if (ferror (f)) {
yuuji@0	2689 MM_LOG ("Error updating mix sortcache file",WARN);
yuuji@0	2690 ret = NIL;
yuuji@0	2691 }
yuuji@0	2692 }
yuuji@0	2693 if (ret && fflush (f)) {
yuuji@0	2694 MM_LOG ("Error flushing mix sortcache file",WARN);
yuuji@0	2695 ret = NIL;
yuuji@0	2696 }
yuuji@0	2697 if (ret) ftruncate (fileno (f),ftell (f));
yuuji@0	2698 }
yuuji@0	2699 if (fclose (f)) {
yuuji@0	2700 MM_LOG ("Error closing mix sortcache file",WARN);
yuuji@0	2701 ret = NIL;
yuuji@0	2702 }
yuuji@0	2703 }
yuuji@0	2704 return ret;
yuuji@0	2705 }
yuuji@0	2706
yuuji@0	2707 /* MIX generic file routines */
yuuji@0	2708
yuuji@0	2709 /* MIX read record
yuuji@0	2710 * Accepts: open FILE
yuuji@0	2711 * buffer
yuuji@0	2712 * buffer length
yuuji@0	2713 * record type
yuuji@0	2714 * Returns: buffer if success, else NIL (zero-length buffer means EOF)
yuuji@0	2715 */
yuuji@0	2716
yuuji@0	2717 char mix_read_record (FILE f,char buf,unsigned long buflen,char type)
yuuji@0	2718 {
yuuji@0	2719 char *s,tmp[MAILTMPLEN];
yuuji@0	2720 /* ensure string tied off */
yuuji@0	2721 buf[buflen-2] = buf[buflen-1] = '\0';
yuuji@0	2722 while (fgets (buf,buflen-1,f)) {
yuuji@0	2723 if (s = strchr (buf,'\012')) {
yuuji@0	2724 if ((s != buf) && (s[-1] == '\015')) --s;
yuuji@0	2725 s = '\0'; / tie off buffer */
yuuji@0	2726 if (s != buf) return buf; /* return if non-empty buffer */
yuuji@0	2727 sprintf (tmp,"Empty mix %s record",type);
yuuji@0	2728 MM_LOG (tmp,WARN);
yuuji@0	2729 }
yuuji@0	2730 else if (buf[buflen-2]) { /* overlong record is bad news */
yuuji@0	2731 sprintf (tmp,"Oversize mix %s record: %.512s",type,buf);
yuuji@0	2732 MM_LOG (tmp,ERROR);
yuuji@0	2733 return NIL;
yuuji@0	2734 }
yuuji@0	2735 else {
yuuji@0	2736 sprintf (tmp,"Truncated mix %s record: %.512s",type,buf);
yuuji@0	2737 MM_LOG (tmp,WARN);
yuuji@0	2738 return buf; /* pass to caller anyway */
yuuji@0	2739 }
yuuji@0	2740 }
yuuji@0	2741 buf[0] = '\0'; /* return empty buffer on EOF */
yuuji@0	2742 return buf;
yuuji@0	2743 }
yuuji@0	2744
yuuji@0	2745 /* MIX read sequence record
yuuji@0	2746 * Accepts: open FILE
yuuji@0	2747 * Returns: sequence value, or NIL if failure
yuuji@0	2748 */
yuuji@0	2749
yuuji@0	2750 unsigned long mix_read_sequence (FILE *f)
yuuji@0	2751 {
yuuji@0	2752 unsigned long ret;
yuuji@0	2753 char *s,tmp[MAILTMPLEN];
yuuji@0	2754 if (!mix_read_record (f,tmp,MAILTMPLEN-1,"sequence")) return NIL;
yuuji@0	2755 switch (tmp[0]) { /* examine record */
yuuji@0	2756 case '\0': /* end of file */
yuuji@0	2757 ret = 1; /* start a new sequence regime */
yuuji@0	2758 break;
yuuji@0	2759 case 'S': /* sequence record */
yuuji@0	2760 if (isxdigit (tmp[1])) { /* must be followed by hex value */
yuuji@0	2761 ret = strtoul (tmp+1,&s,16);
yuuji@0	2762 if (!s) break; / and nothing more */
yuuji@0	2763 }
yuuji@0	2764 /* drop into default case */
yuuji@0	2765 default: /* anything else is an error */
yuuji@0	2766 return NIL; /* return error */
yuuji@0	2767 }
yuuji@0	2768 return ret;
yuuji@0	2769 }
yuuji@0	2770
yuuji@0	2771 /* MIX internal routines */
yuuji@0	2772
yuuji@0	2773
yuuji@0	2774 /* MIX mail build directory name
yuuji@0	2775 * Accepts: destination string
yuuji@0	2776 * source
yuuji@0	2777 * Returns: destination or empty string if error
yuuji@0	2778 */
yuuji@0	2779
yuuji@0	2780 char mix_dir (char dst,char *name)
yuuji@0	2781 {
yuuji@0	2782 char *s;
yuuji@0	2783 /* empty string if mailboxfile fails */
yuuji@0	2784 if (!mailboxfile (dst,name)) *dst = '\0';
yuuji@0	2785 /* driver-selected INBOX */
yuuji@0	2786 else if (!*dst) mailboxfile (dst,"~/INBOX");
yuuji@0	2787 /* tie off unnecessary trailing / */
yuuji@0	2788 else if ((s = strrchr (dst,'/')) && !s[1]) *s = '\0';
yuuji@0	2789 return dst;
yuuji@0	2790 }
yuuji@0	2791
yuuji@0	2792
yuuji@0	2793 /* MIX mail build file name
yuuji@0	2794 * Accepts: destination string
yuuji@0	2795 * directory name
yuuji@0	2796 * file name
yuuji@0	2797 * Returns: destination
yuuji@0	2798 */
yuuji@0	2799
yuuji@0	2800 char mix_file (char dst,char dir,char name)
yuuji@0	2801 {
yuuji@0	2802 sprintf (dst,"%.500s/%.80s%.80s",dir,MIXNAME,name);
yuuji@0	2803 return dst;
yuuji@0	2804 }
yuuji@0	2805
yuuji@0	2806
yuuji@0	2807 /* MIX mail build file name from data file number
yuuji@0	2808 * Accepts: destination string
yuuji@0	2809 * directory name
yuuji@0	2810 * data file number
yuuji@0	2811 * Returns: destination
yuuji@0	2812 */
yuuji@0	2813
yuuji@0	2814 char mix_file_data (char dst,char *dir,unsigned long data)
yuuji@0	2815 {
yuuji@0	2816 char tmp[MAILTMPLEN];
yuuji@0	2817 if (data) sprintf (tmp,"%08lx",data);
yuuji@0	2818 else tmp[0] = '\0'; /* compatibility with experimental version */
yuuji@0	2819 return mix_file (dst,dir,tmp);
yuuji@0	2820 }
yuuji@0	2821
yuuji@0	2822 /* MIX mail get new modseq
yuuji@0	2823 * Accepts: old modseq
yuuji@0	2824 * Returns: new modseq value
yuuji@0	2825 */
yuuji@0	2826
yuuji@0	2827 unsigned long mix_modseq (unsigned long oldseq)
yuuji@0	2828 {
yuuji@0	2829 /* normally time now */
yuuji@0	2830 unsigned long ret = (unsigned long) time (NIL);
yuuji@0	2831 /* ensure that modseq doesn't go backwards */
yuuji@0	2832 if (ret <= oldseq) ret = oldseq + 1;
yuuji@0	2833 return ret;
yuuji@0	2834 }