imapext-2007

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

find changesets by author, revision, files, or words in the commit message
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: MX mail routines
yuuji@0 16 *
yuuji@0 17 * Author(s): Mark Crispin
yuuji@0 18 * Networks and Distributed Computing
yuuji@0 19 * Computing & Communications
yuuji@0 20 * University of Washington
yuuji@0 21 * Administration Building, AG-44
yuuji@0 22 * Seattle, WA 98195
yuuji@0 23 * Internet: MRC@CAC.Washington.EDU
yuuji@0 24 *
yuuji@0 25 * Date: 3 May 1996
yuuji@0 26 * Last Edited: 6 January 2008
yuuji@0 27 */
yuuji@0 28
yuuji@0 29
yuuji@0 30 #include <stdio.h>
yuuji@0 31 #include <ctype.h>
yuuji@0 32 #include <errno.h>
yuuji@0 33 extern int errno; /* just in case */
yuuji@0 34 #include "mail.h"
yuuji@0 35 #include "osdep.h"
yuuji@0 36 #include <pwd.h>
yuuji@0 37 #include <sys/stat.h>
yuuji@0 38 #include <sys/time.h>
yuuji@0 39 #include "misc.h"
yuuji@0 40 #include "dummy.h"
yuuji@0 41 #include "fdstring.h"
yuuji@0 42
yuuji@0 43 /* Index file */
yuuji@0 44
yuuji@0 45 #define MXINDEXNAME "/.mxindex"
yuuji@0 46 #define MXINDEX(d,s) strcat (mx_file (d,s),MXINDEXNAME)
yuuji@0 47
yuuji@0 48
yuuji@0 49 /* MX I/O stream local data */
yuuji@0 50
yuuji@0 51 typedef struct mx_local {
yuuji@0 52 int fd; /* file descriptor of open index */
yuuji@0 53 unsigned char *buf; /* temporary buffer */
yuuji@0 54 unsigned long buflen; /* current size of temporary buffer */
yuuji@0 55 unsigned long cachedtexts; /* total size of all cached texts */
yuuji@0 56 time_t scantime; /* last time directory scanned */
yuuji@0 57 } MXLOCAL;
yuuji@0 58
yuuji@0 59
yuuji@0 60 /* Convenient access to local data */
yuuji@0 61
yuuji@0 62 #define LOCAL ((MXLOCAL *) stream->local)
yuuji@0 63
yuuji@0 64
yuuji@0 65 /* Function prototypes */
yuuji@0 66
yuuji@0 67 DRIVER *mx_valid (char *name);
yuuji@0 68 int mx_isvalid (char *name,char *tmp);
yuuji@0 69 int mx_namevalid (char *name);
yuuji@0 70 void *mx_parameters (long function,void *value);
yuuji@0 71 long mx_dirfmttest (char *name);
yuuji@0 72 void mx_scan (MAILSTREAM *stream,char *ref,char *pat,char *contents);
yuuji@0 73 long mx_scan_contents (char *name,char *contents,unsigned long csiz,
yuuji@0 74 unsigned long fsiz);
yuuji@0 75 void mx_list (MAILSTREAM *stream,char *ref,char *pat);
yuuji@0 76 void mx_lsub (MAILSTREAM *stream,char *ref,char *pat);
yuuji@0 77 long mx_subscribe (MAILSTREAM *stream,char *mailbox);
yuuji@0 78 long mx_unsubscribe (MAILSTREAM *stream,char *mailbox);
yuuji@0 79 long mx_create (MAILSTREAM *stream,char *mailbox);
yuuji@0 80 long mx_delete (MAILSTREAM *stream,char *mailbox);
yuuji@0 81 long mx_rename (MAILSTREAM *stream,char *old,char *newname);
yuuji@0 82 int mx_rename_work (char *src,size_t srcl,char *dst,size_t dstl,char *name);
yuuji@0 83 MAILSTREAM *mx_open (MAILSTREAM *stream);
yuuji@0 84 void mx_close (MAILSTREAM *stream,long options);
yuuji@0 85 void mx_fast (MAILSTREAM *stream,char *sequence,long flags);
yuuji@0 86 char *mx_fast_work (MAILSTREAM *stream,MESSAGECACHE *elt);
yuuji@0 87 char *mx_header (MAILSTREAM *stream,unsigned long msgno,unsigned long *length,
yuuji@0 88 long flags);
yuuji@0 89 long mx_text (MAILSTREAM *stream,unsigned long msgno,STRING *bs,long flags);
yuuji@0 90 void mx_flag (MAILSTREAM *stream,char *sequence,char *flag,long flags);
yuuji@0 91 void mx_flagmsg (MAILSTREAM *stream,MESSAGECACHE *elt);
yuuji@0 92 long mx_ping (MAILSTREAM *stream);
yuuji@0 93 void mx_check (MAILSTREAM *stream);
yuuji@0 94 long mx_expunge (MAILSTREAM *stream,char *sequence,long options);
yuuji@0 95 long mx_copy (MAILSTREAM *stream,char *sequence,char *mailbox,
yuuji@0 96 long options);
yuuji@0 97 long mx_append (MAILSTREAM *stream,char *mailbox,append_t af,void *data);
yuuji@0 98 long mx_append_msg (MAILSTREAM *stream,char *flags,MESSAGECACHE *elt,
yuuji@0 99 STRING *st,SEARCHSET *set);
yuuji@0 100
yuuji@0 101 int mx_select (struct direct *name);
yuuji@0 102 int mx_numsort (const void *d1,const void *d2);
yuuji@0 103 char *mx_file (char *dst,char *name);
yuuji@0 104 long mx_lockindex (MAILSTREAM *stream);
yuuji@0 105 void mx_unlockindex (MAILSTREAM *stream);
yuuji@0 106 void mx_setdate (char *file,MESSAGECACHE *elt);
yuuji@0 107
yuuji@0 108
yuuji@0 109 /* MX mail routines */
yuuji@0 110
yuuji@0 111
yuuji@0 112 /* Driver dispatch used by MAIL */
yuuji@0 113
yuuji@0 114 DRIVER mxdriver = {
yuuji@0 115 "mx", /* driver name */
yuuji@0 116 /* driver flags */
yuuji@0 117 DR_MAIL|DR_LOCAL|DR_NOFAST|DR_CRLF|DR_LOCKING|DR_DIRFMT,
yuuji@0 118 (DRIVER *) NIL, /* next driver */
yuuji@0 119 mx_valid, /* mailbox is valid for us */
yuuji@0 120 mx_parameters, /* manipulate parameters */
yuuji@0 121 mx_scan, /* scan mailboxes */
yuuji@0 122 mx_list, /* find mailboxes */
yuuji@0 123 mx_lsub, /* find subscribed mailboxes */
yuuji@0 124 mx_subscribe, /* subscribe to mailbox */
yuuji@0 125 mx_unsubscribe, /* unsubscribe from mailbox */
yuuji@0 126 mx_create, /* create mailbox */
yuuji@0 127 mx_delete, /* delete mailbox */
yuuji@0 128 mx_rename, /* rename mailbox */
yuuji@0 129 mail_status_default, /* status of mailbox */
yuuji@0 130 mx_open, /* open mailbox */
yuuji@0 131 mx_close, /* close mailbox */
yuuji@0 132 mx_fast, /* fetch message "fast" attributes */
yuuji@0 133 NIL, /* fetch message flags */
yuuji@0 134 NIL, /* fetch overview */
yuuji@0 135 NIL, /* fetch message envelopes */
yuuji@0 136 mx_header, /* fetch message header only */
yuuji@0 137 mx_text, /* fetch message body only */
yuuji@0 138 NIL, /* fetch partial message test */
yuuji@0 139 NIL, /* unique identifier */
yuuji@0 140 NIL, /* message number */
yuuji@0 141 mx_flag, /* modify flags */
yuuji@0 142 mx_flagmsg, /* per-message modify flags */
yuuji@0 143 NIL, /* search for message based on criteria */
yuuji@0 144 NIL, /* sort messages */
yuuji@0 145 NIL, /* thread messages */
yuuji@0 146 mx_ping, /* ping mailbox to see if still alive */
yuuji@0 147 mx_check, /* check for new messages */
yuuji@0 148 mx_expunge, /* expunge deleted messages */
yuuji@0 149 mx_copy, /* copy messages to another mailbox */
yuuji@0 150 mx_append, /* append string message to mailbox */
yuuji@0 151 NIL /* garbage collect stream */
yuuji@0 152 };
yuuji@0 153
yuuji@0 154 /* prototype stream */
yuuji@0 155 MAILSTREAM mxproto = {&mxdriver};
yuuji@0 156
yuuji@0 157 /* MX mail validate mailbox
yuuji@0 158 * Accepts: mailbox name
yuuji@0 159 * Returns: our driver if name is valid, NIL otherwise
yuuji@0 160 */
yuuji@0 161
yuuji@0 162 DRIVER *mx_valid (char *name)
yuuji@0 163 {
yuuji@0 164 char tmp[MAILTMPLEN];
yuuji@0 165 return mx_isvalid (name,tmp) ? &mxdriver : NIL;
yuuji@0 166 }
yuuji@0 167
yuuji@0 168
yuuji@0 169 /* MX mail test for valid mailbox
yuuji@0 170 * Accepts: mailbox name
yuuji@0 171 * temporary buffer to use
yuuji@0 172 * Returns: T if valid, NIL otherwise with errno holding dir stat error
yuuji@0 173 */
yuuji@0 174
yuuji@0 175 int mx_isvalid (char *name,char *tmp)
yuuji@0 176 {
yuuji@0 177 struct stat sbuf;
yuuji@0 178 errno = NIL; /* zap error */
yuuji@0 179 if ((strlen (name) <= NETMAXMBX) && *mx_file (tmp,name) &&
yuuji@0 180 !stat (tmp,&sbuf) && ((sbuf.st_mode & S_IFMT) == S_IFDIR)) {
yuuji@0 181 /* name is directory; is it mx? */
yuuji@0 182 if (!stat (MXINDEX (tmp,name),&sbuf) &&
yuuji@0 183 ((sbuf.st_mode & S_IFMT) == S_IFREG)) return T;
yuuji@0 184 errno = NIL; /* directory but not mx */
yuuji@0 185 }
yuuji@0 186 else if (!compare_cstring (name,"INBOX")) errno = NIL;
yuuji@0 187 return NIL;
yuuji@0 188 }
yuuji@0 189
yuuji@0 190
yuuji@0 191 /* MX mail test for valid mailbox
yuuji@0 192 * Accepts: mailbox name
yuuji@0 193 * Returns: T if valid, NIL otherwise
yuuji@0 194 */
yuuji@0 195
yuuji@0 196 int mx_namevalid (char *name)
yuuji@0 197 {
yuuji@0 198 char *s = (*name == '/') ? name + 1 : name;
yuuji@0 199 while (s && *s) { /* make sure valid name */
yuuji@0 200 if (isdigit (*s)) s++; /* digit, check this node further... */
yuuji@0 201 else if (*s == '/') break; /* all digit node, barf */
yuuji@0 202 /* non-digit, skip to next node or return */
yuuji@0 203 else if (!((s = strchr (s+1,'/')) && *++s)) return T;
yuuji@0 204 }
yuuji@0 205 return NIL; /* all numeric or empty node */
yuuji@0 206 }
yuuji@0 207
yuuji@0 208 /* MX manipulate driver parameters
yuuji@0 209 * Accepts: function code
yuuji@0 210 * function-dependent value
yuuji@0 211 * Returns: function-dependent return value
yuuji@0 212 */
yuuji@0 213
yuuji@0 214 void *mx_parameters (long function,void *value)
yuuji@0 215 {
yuuji@0 216 void *ret = NIL;
yuuji@0 217 switch ((int) function) {
yuuji@0 218 case GET_INBOXPATH:
yuuji@0 219 if (value) ret = mailboxfile ((char *) value,"~/INBOX");
yuuji@0 220 break;
yuuji@0 221 case GET_DIRFMTTEST:
yuuji@0 222 ret = (void *) mx_dirfmttest;
yuuji@0 223 break;
yuuji@0 224 case GET_SCANCONTENTS:
yuuji@0 225 ret = (void *) mx_scan_contents;
yuuji@0 226 break;
yuuji@0 227 }
yuuji@0 228 return ret;
yuuji@0 229 }
yuuji@0 230
yuuji@0 231
yuuji@0 232 /* MX test for directory format internal node
yuuji@0 233 * Accepts: candidate node name
yuuji@0 234 * Returns: T if internal name, NIL otherwise
yuuji@0 235 */
yuuji@0 236
yuuji@0 237 long mx_dirfmttest (char *name)
yuuji@0 238 {
yuuji@0 239 int c;
yuuji@0 240 /* success if index name or all-numberic */
yuuji@0 241 if (strcmp (name,MXINDEXNAME+1))
yuuji@0 242 while (c = *name++) if (!isdigit (c)) return NIL;
yuuji@0 243 return LONGT;
yuuji@0 244 }
yuuji@0 245
yuuji@0 246 /* MX scan mailboxes
yuuji@0 247 * Accepts: mail stream
yuuji@0 248 * reference
yuuji@0 249 * pattern to search
yuuji@0 250 * string to scan
yuuji@0 251 */
yuuji@0 252
yuuji@0 253 void mx_scan (MAILSTREAM *stream,char *ref,char *pat,char *contents)
yuuji@0 254 {
yuuji@0 255 if (stream) dummy_scan (NIL,ref,pat,contents);
yuuji@0 256 }
yuuji@0 257
yuuji@0 258
yuuji@0 259 /* MX scan mailbox for contents
yuuji@0 260 * Accepts: mailbox name
yuuji@0 261 * desired contents
yuuji@0 262 * contents size
yuuji@0 263 * file size (ignored)
yuuji@0 264 * Returns: NIL if contents not found, T if found
yuuji@0 265 */
yuuji@0 266
yuuji@0 267 long mx_scan_contents (char *name,char *contents,unsigned long csiz,
yuuji@0 268 unsigned long fsiz)
yuuji@0 269 {
yuuji@0 270 long i,nfiles;
yuuji@0 271 void *a;
yuuji@0 272 char *s;
yuuji@0 273 long ret = NIL;
yuuji@0 274 size_t namelen = strlen (name);
yuuji@0 275 struct stat sbuf;
yuuji@0 276 struct direct **names = NIL;
yuuji@0 277 if ((nfiles = scandir (name,&names,mx_select,mx_numsort)) > 0)
yuuji@0 278 for (i = 0; i < nfiles; ++i) {
yuuji@0 279 if (!ret) {
yuuji@0 280 sprintf (s = (char *) fs_get (namelen + strlen (names[i]->d_name) + 2),
yuuji@0 281 "%s/%s",name,names[i]->d_name);
yuuji@0 282 if (!stat (s,&sbuf) && (csiz <= sbuf.st_size))
yuuji@0 283 ret = dummy_scan_contents (s,contents,csiz,sbuf.st_size);
yuuji@0 284 fs_give ((void **) &s);
yuuji@0 285 }
yuuji@0 286 fs_give ((void **) &names[i]);
yuuji@0 287 }
yuuji@0 288 /* free directory list */
yuuji@0 289 if (a = (void *) names) fs_give ((void **) &a);
yuuji@0 290 return ret;
yuuji@0 291 }
yuuji@0 292
yuuji@0 293 /* MX list mailboxes
yuuji@0 294 * Accepts: mail stream
yuuji@0 295 * reference
yuuji@0 296 * pattern to search
yuuji@0 297 */
yuuji@0 298
yuuji@0 299 void mx_list (MAILSTREAM *stream,char *ref,char *pat)
yuuji@0 300 {
yuuji@0 301 if (stream) dummy_list (NIL,ref,pat);
yuuji@0 302 }
yuuji@0 303
yuuji@0 304
yuuji@0 305 /* MX list subscribed mailboxes
yuuji@0 306 * Accepts: mail stream
yuuji@0 307 * reference
yuuji@0 308 * pattern to search
yuuji@0 309 */
yuuji@0 310
yuuji@0 311 void mx_lsub (MAILSTREAM *stream,char *ref,char *pat)
yuuji@0 312 {
yuuji@0 313 if (stream) dummy_lsub (NIL,ref,pat);
yuuji@0 314 }
yuuji@0 315
yuuji@0 316 /* MX mail subscribe to mailbox
yuuji@0 317 * Accepts: mail stream
yuuji@0 318 * mailbox to add to subscription list
yuuji@0 319 * Returns: T on success, NIL on failure
yuuji@0 320 */
yuuji@0 321
yuuji@0 322 long mx_subscribe (MAILSTREAM *stream,char *mailbox)
yuuji@0 323 {
yuuji@0 324 return sm_subscribe (mailbox);
yuuji@0 325 }
yuuji@0 326
yuuji@0 327
yuuji@0 328 /* MX mail unsubscribe to mailbox
yuuji@0 329 * Accepts: mail stream
yuuji@0 330 * mailbox to delete from subscription list
yuuji@0 331 * Returns: T on success, NIL on failure
yuuji@0 332 */
yuuji@0 333
yuuji@0 334 long mx_unsubscribe (MAILSTREAM *stream,char *mailbox)
yuuji@0 335 {
yuuji@0 336 return sm_unsubscribe (mailbox);
yuuji@0 337 }
yuuji@0 338
yuuji@0 339 /* MX mail create mailbox
yuuji@0 340 * Accepts: mail stream
yuuji@0 341 * mailbox name to create
yuuji@0 342 * Returns: T on success, NIL on failure
yuuji@0 343 */
yuuji@0 344
yuuji@0 345 long mx_create (MAILSTREAM *stream,char *mailbox)
yuuji@0 346 {
yuuji@0 347 DRIVER *test;
yuuji@0 348 int fd;
yuuji@0 349 char *s,tmp[MAILTMPLEN];
yuuji@0 350 int mask = umask (0);
yuuji@0 351 long ret = NIL;
yuuji@0 352 if (!mx_namevalid (mailbox)) /* validate name */
yuuji@0 353 sprintf (tmp,"Can't create mailbox %.80s: invalid MX-format name",mailbox);
yuuji@0 354 /* must not already exist */
yuuji@0 355 else if ((test = mail_valid (NIL,mailbox,NIL)) &&
yuuji@0 356 strcmp (test->name,"dummy"))
yuuji@0 357 sprintf (tmp,"Can't create mailbox %.80s: mailbox already exists",mailbox);
yuuji@0 358 /* create directory */
yuuji@0 359 else if (!dummy_create_path (stream,MXINDEX (tmp,mailbox),
yuuji@0 360 get_dir_protection (mailbox)))
yuuji@0 361 sprintf (tmp,"Can't create mailbox %.80s: %s",mailbox,strerror (errno));
yuuji@0 362 else { /* success */
yuuji@0 363 /* set index protection */
yuuji@0 364 set_mbx_protections (mailbox,tmp);
yuuji@0 365 /* tie off directory name */
yuuji@0 366 *(s = strrchr (tmp,'/') + 1) = '\0';
yuuji@0 367 /* set directory protection */
yuuji@0 368 set_mbx_protections (mailbox,tmp);
yuuji@0 369 ret = LONGT;
yuuji@0 370 }
yuuji@0 371 umask (mask); /* restore mask */
yuuji@0 372 if (!ret) MM_LOG (tmp,ERROR); /* some error */
yuuji@0 373 return ret;
yuuji@0 374 }
yuuji@0 375
yuuji@0 376 /* MX mail delete mailbox
yuuji@0 377 * mailbox name to delete
yuuji@0 378 * Returns: T on success, NIL on failure
yuuji@0 379 */
yuuji@0 380
yuuji@0 381 long mx_delete (MAILSTREAM *stream,char *mailbox)
yuuji@0 382 {
yuuji@0 383 DIR *dirp;
yuuji@0 384 struct direct *d;
yuuji@0 385 char *s;
yuuji@0 386 char tmp[MAILTMPLEN];
yuuji@0 387 if (!mx_isvalid (mailbox,tmp))
yuuji@0 388 sprintf (tmp,"Can't delete mailbox %.80s: no such mailbox",mailbox);
yuuji@0 389 /* delete index */
yuuji@0 390 else if (unlink (MXINDEX (tmp,mailbox)))
yuuji@0 391 sprintf (tmp,"Can't delete mailbox %.80s index: %s",
yuuji@0 392 mailbox,strerror (errno));
yuuji@0 393 else { /* get directory name */
yuuji@0 394 *(s = strrchr (tmp,'/')) = '\0';
yuuji@0 395 if (dirp = opendir (tmp)) { /* open directory */
yuuji@0 396 *s++ = '/'; /* restore delimiter */
yuuji@0 397 /* massacre messages */
yuuji@0 398 while (d = readdir (dirp)) if (mx_select (d)) {
yuuji@0 399 strcpy (s,d->d_name); /* make path */
yuuji@0 400 unlink (tmp); /* sayonara */
yuuji@0 401 }
yuuji@0 402 closedir (dirp); /* flush directory */
yuuji@0 403 *(s = strrchr (tmp,'/')) = '\0';
yuuji@0 404 if (rmdir (tmp)) { /* try to remove the directory */
yuuji@0 405 sprintf (tmp,"Can't delete name %.80s: %s",mailbox,strerror (errno));
yuuji@0 406 MM_LOG (tmp,WARN);
yuuji@0 407 }
yuuji@0 408 }
yuuji@0 409 return T; /* always success */
yuuji@0 410 }
yuuji@0 411 MM_LOG (tmp,ERROR); /* something failed */
yuuji@0 412 return NIL;
yuuji@0 413 }
yuuji@0 414
yuuji@0 415 /* MX mail rename mailbox
yuuji@0 416 * Accepts: MX mail stream
yuuji@0 417 * old mailbox name
yuuji@0 418 * new mailbox name
yuuji@0 419 * Returns: T on success, NIL on failure
yuuji@0 420 */
yuuji@0 421
yuuji@0 422 long mx_rename (MAILSTREAM *stream,char *old,char *newname)
yuuji@0 423 {
yuuji@0 424 char c,*s,tmp[MAILTMPLEN],tmp1[MAILTMPLEN];
yuuji@0 425 struct stat sbuf;
yuuji@0 426 if (!mx_isvalid (old,tmp))
yuuji@0 427 sprintf (tmp,"Can't rename mailbox %.80s: no such mailbox",old);
yuuji@0 428 else if (!mx_namevalid (newname))
yuuji@0 429 sprintf (tmp,"Can't rename to mailbox %.80s: invalid MX-format name",
yuuji@0 430 newname);
yuuji@0 431 /* new mailbox name must not be valid */
yuuji@0 432 else if (mx_isvalid (newname,tmp))
yuuji@0 433 sprintf (tmp,"Can't rename to mailbox %.80s: destination already exists",
yuuji@0 434 newname);
yuuji@0 435 else {
yuuji@0 436 mx_file (tmp,old); /* build old directory name */
yuuji@0 437 mx_file (tmp1,newname); /* and new directory name */
yuuji@0 438 /* easy if not INBOX */
yuuji@0 439 if (compare_cstring (old,"INBOX")) {
yuuji@0 440 /* found superior to destination name? */
yuuji@0 441 if (s = strrchr (mx_file (tmp1,newname),'/')) {
yuuji@0 442 c = *++s; /* remember first character of inferior */
yuuji@0 443 *s = '\0'; /* tie off to get just superior */
yuuji@0 444 /* name doesn't exist, create it */
yuuji@0 445 if ((stat (tmp1,&sbuf) || ((sbuf.st_mode & S_IFMT) != S_IFDIR)) &&
yuuji@0 446 !dummy_create_path (stream,tmp1,get_dir_protection (newname)))
yuuji@0 447 return NIL;
yuuji@0 448 *s = c; /* restore full name */
yuuji@0 449 }
yuuji@0 450 if (!rename (tmp,tmp1)) return LONGT;
yuuji@0 451 }
yuuji@0 452
yuuji@0 453 /* RFC 3501 requires this */
yuuji@0 454 else if (dummy_create_path (stream,strcat (tmp1,"/"),
yuuji@0 455 get_dir_protection (newname))) {
yuuji@0 456 void *a;
yuuji@0 457 int i,n,lasterror;
yuuji@0 458 struct direct **names = NIL;
yuuji@0 459 size_t srcl = strlen (tmp);
yuuji@0 460 size_t dstl = strlen (tmp1);
yuuji@0 461 /* rename each mx file to new directory */
yuuji@0 462 for (i = lasterror = 0,n = scandir (tmp,&names,mx_select,mx_numsort);
yuuji@0 463 i < n; ++i) {
yuuji@0 464 if (mx_rename_work (tmp,srcl,tmp1,dstl,names[i]->d_name))
yuuji@0 465 lasterror = errno;
yuuji@0 466 fs_give ((void **) &names[i]);
yuuji@0 467 }
yuuji@0 468 /* free directory list */
yuuji@0 469 if (a = (void *) names) fs_give ((void **) &a);
yuuji@0 470 if (lasterror || mx_rename_work (tmp,srcl,tmp1,dstl,MXINDEXNAME+1))
yuuji@0 471 errno = lasterror;
yuuji@0 472 else return mx_create (NIL,"INBOX");
yuuji@0 473 }
yuuji@0 474 sprintf (tmp,"Can't rename mailbox %.80s to %.80s: %s",
yuuji@0 475 old,newname,strerror (errno));
yuuji@0 476 }
yuuji@0 477 MM_LOG (tmp,ERROR); /* something failed */
yuuji@0 478 return NIL;
yuuji@0 479 }
yuuji@0 480
yuuji@0 481
yuuji@0 482 /* MX rename worker routine
yuuji@0 483 * Accepts: source directory name
yuuji@0 484 * source directory name length
yuuji@0 485 * destination directory name
yuuji@0 486 * destination directory name length
yuuji@0 487 * name of node to move
yuuji@0 488 * Returns: zero if success, non-zero if error
yuuji@0 489 */
yuuji@0 490
yuuji@0 491 int mx_rename_work (char *src,size_t srcl,char *dst,size_t dstl,char *name)
yuuji@0 492 {
yuuji@0 493 int ret;
yuuji@0 494 size_t len = strlen (name);
yuuji@0 495 char *s = (char *) fs_get (srcl + len + 2);
yuuji@0 496 char *d = (char *) fs_get (dstl + len + 1);
yuuji@0 497 sprintf (s,"%s/%s",src,name);
yuuji@0 498 sprintf (d,"%s%s",dst,name);
yuuji@0 499 ret = rename (s,d);
yuuji@0 500 fs_give ((void **) &s);
yuuji@0 501 fs_give ((void **) &d);
yuuji@0 502 return ret;
yuuji@0 503 }
yuuji@0 504
yuuji@0 505 /* MX mail open
yuuji@0 506 * Accepts: stream to open
yuuji@0 507 * Returns: stream on success, NIL on failure
yuuji@0 508 */
yuuji@0 509
yuuji@0 510 MAILSTREAM *mx_open (MAILSTREAM *stream)
yuuji@0 511 {
yuuji@0 512 char tmp[MAILTMPLEN];
yuuji@0 513 /* return prototype for OP_PROTOTYPE call */
yuuji@0 514 if (!stream) return user_flags (&mxproto);
yuuji@0 515 if (stream->local) fatal ("mx recycle stream");
yuuji@0 516 stream->local = fs_get (sizeof (MXLOCAL));
yuuji@0 517 /* note if an INBOX or not */
yuuji@0 518 stream->inbox = !compare_cstring (stream->mailbox,"INBOX");
yuuji@0 519 mx_file (tmp,stream->mailbox);/* get directory name */
yuuji@0 520 /* canonicalize mailbox name */
yuuji@0 521 fs_give ((void **) &stream->mailbox);
yuuji@0 522 stream->mailbox = cpystr (tmp);
yuuji@0 523 /* make temporary buffer */
yuuji@0 524 LOCAL->buf = (char *) fs_get (CHUNKSIZE);
yuuji@0 525 LOCAL->buflen = CHUNKSIZE - 1;
yuuji@0 526 LOCAL->scantime = 0; /* not scanned yet */
yuuji@0 527 LOCAL->fd = -1; /* no index yet */
yuuji@0 528 LOCAL->cachedtexts = 0; /* no cached texts */
yuuji@0 529 stream->sequence++; /* bump sequence number */
yuuji@0 530 /* parse mailbox */
yuuji@0 531 stream->nmsgs = stream->recent = 0;
yuuji@0 532 if (mx_ping (stream) && !(stream->nmsgs || stream->silent))
yuuji@0 533 MM_LOG ("Mailbox is empty",(long) NIL);
yuuji@0 534 stream->perm_seen = stream->perm_deleted = stream->perm_flagged =
yuuji@0 535 stream->perm_answered = stream->perm_draft = stream->rdonly ? NIL : T;
yuuji@0 536 stream->perm_user_flags = stream->rdonly ? NIL : 0xffffffff;
yuuji@0 537 stream->kwd_create = (stream->user_flags[NUSERFLAGS-1] || stream->rdonly) ?
yuuji@0 538 NIL : T; /* can we create new user flags? */
yuuji@0 539 return stream; /* return stream to caller */
yuuji@0 540 }
yuuji@0 541
yuuji@0 542 /* MX mail close
yuuji@0 543 * Accepts: MAIL stream
yuuji@0 544 * close options
yuuji@0 545 */
yuuji@0 546
yuuji@0 547 void mx_close (MAILSTREAM *stream,long options)
yuuji@0 548 {
yuuji@0 549 if (LOCAL) { /* only if a file is open */
yuuji@0 550 int silent = stream->silent;
yuuji@0 551 stream->silent = T; /* note this stream is dying */
yuuji@0 552 if (options & CL_EXPUNGE) mx_expunge (stream,NIL,NIL);
yuuji@0 553 /* free local scratch buffer */
yuuji@0 554 if (LOCAL->buf) fs_give ((void **) &LOCAL->buf);
yuuji@0 555 /* nuke the local data */
yuuji@0 556 fs_give ((void **) &stream->local);
yuuji@0 557 stream->dtb = NIL; /* log out the DTB */
yuuji@0 558 stream->silent = silent; /* reset silent state */
yuuji@0 559 }
yuuji@0 560 }
yuuji@0 561
yuuji@0 562 /* MX mail fetch fast information
yuuji@0 563 * Accepts: MAIL stream
yuuji@0 564 * sequence
yuuji@0 565 * option flags
yuuji@0 566 */
yuuji@0 567
yuuji@0 568 void mx_fast (MAILSTREAM *stream,char *sequence,long flags)
yuuji@0 569 {
yuuji@0 570 unsigned long i;
yuuji@0 571 MESSAGECACHE *elt;
yuuji@0 572 if (stream && LOCAL &&
yuuji@0 573 ((flags & FT_UID) ? mail_uid_sequence (stream,sequence) :
yuuji@0 574 mail_sequence (stream,sequence)))
yuuji@0 575 for (i = 1; i <= stream->nmsgs; i++)
yuuji@0 576 if ((elt = mail_elt (stream,i))->sequence) mx_fast_work (stream,elt);
yuuji@0 577 }
yuuji@0 578
yuuji@0 579
yuuji@0 580 /* MX mail fetch fast information
yuuji@0 581 * Accepts: MAIL stream
yuuji@0 582 * message cache element
yuuji@0 583 * Returns: name of message file
yuuji@0 584 */
yuuji@0 585
yuuji@0 586 char *mx_fast_work (MAILSTREAM *stream,MESSAGECACHE *elt)
yuuji@0 587 {
yuuji@0 588 struct stat sbuf;
yuuji@0 589 struct tm *tm;
yuuji@0 590 /* build message file name */
yuuji@0 591 sprintf (LOCAL->buf,"%s/%lu",stream->mailbox,elt->private.uid);
yuuji@0 592 /* have size yet? */
yuuji@0 593 if (!elt->rfc822_size && !stat (LOCAL->buf,&sbuf)) {
yuuji@0 594 /* make plausible IMAPish date string */
yuuji@0 595 tm = gmtime (&sbuf.st_mtime);
yuuji@0 596 elt->day = tm->tm_mday; elt->month = tm->tm_mon + 1;
yuuji@0 597 elt->year = tm->tm_year + 1900 - BASEYEAR;
yuuji@0 598 elt->hours = tm->tm_hour; elt->minutes = tm->tm_min;
yuuji@0 599 elt->seconds = tm->tm_sec;
yuuji@0 600 elt->zhours = 0; elt->zminutes = 0; elt->zoccident = 0;
yuuji@0 601 elt->rfc822_size = sbuf.st_size;
yuuji@0 602 }
yuuji@0 603 return (char *) LOCAL->buf; /* return file name */
yuuji@0 604 }
yuuji@0 605
yuuji@0 606 /* MX mail fetch message header
yuuji@0 607 * Accepts: MAIL stream
yuuji@0 608 * message # to fetch
yuuji@0 609 * pointer to returned header text length
yuuji@0 610 * option flags
yuuji@0 611 * Returns: message header in RFC822 format
yuuji@0 612 */
yuuji@0 613
yuuji@0 614 char *mx_header (MAILSTREAM *stream,unsigned long msgno,unsigned long *length,
yuuji@0 615 long flags)
yuuji@0 616 {
yuuji@0 617 unsigned long i;
yuuji@0 618 int fd;
yuuji@0 619 MESSAGECACHE *elt;
yuuji@0 620 *length = 0; /* default to empty */
yuuji@0 621 if (flags & FT_UID) return "";/* UID call "impossible" */
yuuji@0 622 elt = mail_elt (stream,msgno);/* get elt */
yuuji@0 623 if (!elt->private.msg.header.text.data) {
yuuji@0 624 /* purge cache if too big */
yuuji@0 625 if (LOCAL->cachedtexts > max (stream->nmsgs * 4096,2097152)) {
yuuji@0 626 mail_gc (stream,GC_TEXTS);/* just can't keep that much */
yuuji@0 627 LOCAL->cachedtexts = 0;
yuuji@0 628 }
yuuji@0 629 if ((fd = open (mx_fast_work (stream,elt),O_RDONLY,NIL)) < 0) return "";
yuuji@0 630 /* is buffer big enough? */
yuuji@0 631 if (elt->rfc822_size > LOCAL->buflen) {
yuuji@0 632 fs_give ((void **) &LOCAL->buf);
yuuji@0 633 LOCAL->buf = (char *) fs_get ((LOCAL->buflen = elt->rfc822_size) + 1);
yuuji@0 634 }
yuuji@0 635 /* slurp message */
yuuji@0 636 read (fd,LOCAL->buf,elt->rfc822_size);
yuuji@0 637 /* tie off file */
yuuji@0 638 LOCAL->buf[elt->rfc822_size] = '\0';
yuuji@0 639 close (fd); /* flush message file */
yuuji@0 640 /* find end of header */
yuuji@0 641 if (elt->rfc822_size < 4) i = 0;
yuuji@0 642 else for (i = 4; (i < elt->rfc822_size) &&
yuuji@0 643 !((LOCAL->buf[i - 4] == '\015') &&
yuuji@0 644 (LOCAL->buf[i - 3] == '\012') &&
yuuji@0 645 (LOCAL->buf[i - 2] == '\015') &&
yuuji@0 646 (LOCAL->buf[i - 1] == '\012')); i++);
yuuji@0 647 /* copy header */
yuuji@0 648 cpytxt (&elt->private.msg.header.text,LOCAL->buf,i);
yuuji@0 649 cpytxt (&elt->private.msg.text.text,LOCAL->buf+i,elt->rfc822_size - i);
yuuji@0 650 /* add to cached size */
yuuji@0 651 LOCAL->cachedtexts += elt->rfc822_size;
yuuji@0 652 }
yuuji@0 653 *length = elt->private.msg.header.text.size;
yuuji@0 654 return (char *) elt->private.msg.header.text.data;
yuuji@0 655 }
yuuji@0 656
yuuji@0 657 /* MX mail fetch message text (body only)
yuuji@0 658 * Accepts: MAIL stream
yuuji@0 659 * message # to fetch
yuuji@0 660 * pointer to returned stringstruct
yuuji@0 661 * option flags
yuuji@0 662 * Returns: T on success, NIL on failure
yuuji@0 663 */
yuuji@0 664
yuuji@0 665 long mx_text (MAILSTREAM *stream,unsigned long msgno,STRING *bs,long flags)
yuuji@0 666 {
yuuji@0 667 unsigned long i;
yuuji@0 668 MESSAGECACHE *elt;
yuuji@0 669 /* UID call "impossible" */
yuuji@0 670 if (flags & FT_UID) return NIL;
yuuji@0 671 elt = mail_elt (stream,msgno);
yuuji@0 672 /* snarf message if don't have it yet */
yuuji@0 673 if (!elt->private.msg.text.text.data) {
yuuji@0 674 mx_header (stream,msgno,&i,flags);
yuuji@0 675 if (!elt->private.msg.text.text.data) return NIL;
yuuji@0 676 }
yuuji@0 677 /* mark as seen */
yuuji@0 678 if (!(flags & FT_PEEK) && mx_lockindex (stream)) {
yuuji@0 679 elt->seen = T;
yuuji@0 680 mx_unlockindex (stream);
yuuji@0 681 MM_FLAGS (stream,msgno);
yuuji@0 682 }
yuuji@0 683 INIT (bs,mail_string,elt->private.msg.text.text.data,
yuuji@0 684 elt->private.msg.text.text.size);
yuuji@0 685 return T;
yuuji@0 686 }
yuuji@0 687
yuuji@0 688 /* MX mail modify flags
yuuji@0 689 * Accepts: MAIL stream
yuuji@0 690 * sequence
yuuji@0 691 * flag(s)
yuuji@0 692 * option flags
yuuji@0 693 */
yuuji@0 694
yuuji@0 695 void mx_flag (MAILSTREAM *stream,char *sequence,char *flag,long flags)
yuuji@0 696 {
yuuji@0 697 mx_unlockindex (stream); /* finished with index */
yuuji@0 698 }
yuuji@0 699
yuuji@0 700
yuuji@0 701 /* MX per-message modify flags
yuuji@0 702 * Accepts: MAIL stream
yuuji@0 703 * message cache element
yuuji@0 704 */
yuuji@0 705
yuuji@0 706 void mx_flagmsg (MAILSTREAM *stream,MESSAGECACHE *elt)
yuuji@0 707 {
yuuji@0 708 mx_lockindex (stream); /* lock index if not already locked */
yuuji@0 709 }
yuuji@0 710
yuuji@0 711 /* MX mail ping mailbox
yuuji@0 712 * Accepts: MAIL stream
yuuji@0 713 * Returns: T if stream alive, else NIL
yuuji@0 714 */
yuuji@0 715
yuuji@0 716 long mx_ping (MAILSTREAM *stream)
yuuji@0 717 {
yuuji@0 718 MAILSTREAM *sysibx = NIL;
yuuji@0 719 MESSAGECACHE *elt,*selt;
yuuji@0 720 struct stat sbuf;
yuuji@0 721 char *s,tmp[MAILTMPLEN];
yuuji@0 722 int fd;
yuuji@0 723 unsigned long i,j,r,old;
yuuji@0 724 long nmsgs = stream->nmsgs;
yuuji@0 725 long recent = stream->recent;
yuuji@0 726 int silent = stream->silent;
yuuji@0 727 if (stat (stream->mailbox,&sbuf)) return NIL;
yuuji@0 728 stream->silent = T; /* don't pass up exists events yet */
yuuji@0 729 if (sbuf.st_ctime != LOCAL->scantime) {
yuuji@0 730 struct direct **names = NIL;
yuuji@0 731 long nfiles = scandir (stream->mailbox,&names,mx_select,mx_numsort);
yuuji@0 732 if (nfiles < 0) nfiles = 0; /* in case error */
yuuji@0 733 old = stream->uid_last;
yuuji@0 734 /* note scanned now */
yuuji@0 735 LOCAL->scantime = sbuf.st_ctime;
yuuji@0 736 /* scan directory */
yuuji@0 737 for (i = 0; i < nfiles; ++i) {
yuuji@0 738 /* if newly seen, add to list */
yuuji@0 739 if ((j = atoi (names[i]->d_name)) > old) {
yuuji@0 740 /* swell the cache */
yuuji@0 741 mail_exists (stream,++nmsgs);
yuuji@0 742 stream->uid_last = (elt = mail_elt (stream,nmsgs))->private.uid = j;
yuuji@0 743 elt->valid = T; /* note valid flags */
yuuji@0 744 if (old) { /* other than the first pass? */
yuuji@0 745 elt->recent = T; /* yup, mark as recent */
yuuji@0 746 recent++; /* bump recent count */
yuuji@0 747 }
yuuji@0 748 }
yuuji@0 749 fs_give ((void **) &names[i]);
yuuji@0 750 }
yuuji@0 751 /* free directory */
yuuji@0 752 if (s = (void *) names) fs_give ((void **) &s);
yuuji@0 753 }
yuuji@0 754 stream->nmsgs = nmsgs; /* don't upset mail_uid() */
yuuji@0 755
yuuji@0 756 /* if INBOX, snarf from system INBOX */
yuuji@0 757 if (mx_lockindex (stream) && stream->inbox &&
yuuji@0 758 !strcmp (sysinbox (),stream->mailbox)) {
yuuji@0 759 old = stream->uid_last;
yuuji@0 760 MM_CRITICAL (stream); /* go critical */
yuuji@0 761 /* see if anything in system inbox */
yuuji@0 762 if (!stat (sysinbox (),&sbuf) && sbuf.st_size &&
yuuji@0 763 (sysibx = mail_open (sysibx,sysinbox (),OP_SILENT)) &&
yuuji@0 764 !sysibx->rdonly && (r = sysibx->nmsgs)) {
yuuji@0 765 for (i = 1; i <= r; ++i) {/* for each message in sysinbox mailbox */
yuuji@0 766 /* build file name we will use */
yuuji@0 767 sprintf (LOCAL->buf,"%s/%lu",stream->mailbox,++old);
yuuji@0 768 /* snarf message from Berkeley mailbox */
yuuji@0 769 selt = mail_elt (sysibx,i);
yuuji@0 770 if (((fd = open (LOCAL->buf,O_WRONLY|O_CREAT|O_EXCL,
yuuji@0 771 (long) mail_parameters (NIL,GET_MBXPROTECTION,NIL)))
yuuji@0 772 >= 0) &&
yuuji@0 773 (s = mail_fetchheader_full (sysibx,i,NIL,&j,FT_PEEK)) &&
yuuji@0 774 (write (fd,s,j) == j) &&
yuuji@0 775 (s = mail_fetchtext_full (sysibx,i,&j,FT_PEEK)) &&
yuuji@0 776 (write (fd,s,j) == j) && !fsync (fd) && !close (fd)) {
yuuji@0 777 /* swell the cache */
yuuji@0 778 mail_exists (stream,++nmsgs);
yuuji@0 779 stream->uid_last = /* create new elt, note its file number */
yuuji@0 780 (elt = mail_elt (stream,nmsgs))->private.uid = old;
yuuji@0 781 recent++; /* bump recent count */
yuuji@0 782 /* set up initial flags and date */
yuuji@0 783 elt->valid = elt->recent = T;
yuuji@0 784 elt->seen = selt->seen;
yuuji@0 785 elt->deleted = selt->deleted;
yuuji@0 786 elt->flagged = selt->flagged;
yuuji@0 787 elt->answered = selt->answered;
yuuji@0 788 elt->draft = selt->draft;
yuuji@0 789 elt->day = selt->day;elt->month = selt->month;elt->year = selt->year;
yuuji@0 790 elt->hours = selt->hours;elt->minutes = selt->minutes;
yuuji@0 791 elt->seconds = selt->seconds;
yuuji@0 792 elt->zhours = selt->zhours; elt->zminutes = selt->zminutes;
yuuji@0 793 elt->zoccident = selt->zoccident;
yuuji@0 794 mx_setdate (LOCAL->buf,elt);
yuuji@0 795 sprintf (tmp,"%lu",i);/* delete it from the sysinbox */
yuuji@0 796 mail_flag (sysibx,tmp,"\\Deleted",ST_SET);
yuuji@0 797 }
yuuji@0 798 else { /* failed to snarf */
yuuji@0 799 if (fd) { /* did it ever get opened? */
yuuji@0 800 close (fd); /* close descriptor */
yuuji@0 801 unlink (LOCAL->buf);/* flush this file */
yuuji@0 802 }
yuuji@0 803 sprintf (tmp,"Message copy to MX mailbox failed: %.80s",
yuuji@0 804 s,strerror (errno));
yuuji@0 805 MM_LOG (tmp,ERROR);
yuuji@0 806 r = 0; /* stop the snarf in its tracks */
yuuji@0 807 }
yuuji@0 808 }
yuuji@0 809 /* update scan time */
yuuji@0 810 if (!stat (stream->mailbox,&sbuf)) LOCAL->scantime = sbuf.st_ctime;
yuuji@0 811 mail_expunge (sysibx); /* now expunge all those messages */
yuuji@0 812 }
yuuji@0 813 if (sysibx) mail_close (sysibx);
yuuji@0 814 MM_NOCRITICAL (stream); /* release critical */
yuuji@0 815 }
yuuji@0 816 mx_unlockindex (stream); /* done with index */
yuuji@0 817 stream->silent = silent; /* can pass up events now */
yuuji@0 818 mail_exists (stream,nmsgs); /* notify upper level of mailbox size */
yuuji@0 819 mail_recent (stream,recent);
yuuji@0 820 return T; /* return that we are alive */
yuuji@0 821 }
yuuji@0 822
yuuji@0 823 /* MX mail check mailbox
yuuji@0 824 * Accepts: MAIL stream
yuuji@0 825 */
yuuji@0 826
yuuji@0 827 void mx_check (MAILSTREAM *stream)
yuuji@0 828 {
yuuji@0 829 if (mx_ping (stream)) MM_LOG ("Check completed",(long) NIL);
yuuji@0 830 }
yuuji@0 831
yuuji@0 832
yuuji@0 833 /* MX mail expunge mailbox
yuuji@0 834 * Accepts: MAIL stream
yuuji@0 835 * sequence to expunge if non-NIL
yuuji@0 836 * expunge options
yuuji@0 837 * Returns: T, always
yuuji@0 838 */
yuuji@0 839
yuuji@0 840 long mx_expunge (MAILSTREAM *stream,char *sequence,long options)
yuuji@0 841 {
yuuji@0 842 long ret;
yuuji@0 843 MESSAGECACHE *elt;
yuuji@0 844 unsigned long i = 1;
yuuji@0 845 unsigned long n = 0;
yuuji@0 846 unsigned long recent = stream->recent;
yuuji@0 847 if (ret = (sequence ? ((options & EX_UID) ?
yuuji@0 848 mail_uid_sequence (stream,sequence) :
yuuji@0 849 mail_sequence (stream,sequence)) : LONGT) &&
yuuji@0 850 mx_lockindex (stream)) { /* lock the index */
yuuji@0 851 MM_CRITICAL (stream); /* go critical */
yuuji@0 852 while (i <= stream->nmsgs) {/* for each message */
yuuji@0 853 elt = mail_elt (stream,i);/* if deleted, need to trash it */
yuuji@0 854 if (elt->deleted && (sequence ? elt->sequence : T)) {
yuuji@0 855 sprintf (LOCAL->buf,"%s/%lu",stream->mailbox,elt->private.uid);
yuuji@0 856 if (unlink (LOCAL->buf)) {/* try to delete the message */
yuuji@0 857 sprintf (LOCAL->buf,"Expunge of message %lu failed, aborted: %s",i,
yuuji@0 858 strerror (errno));
yuuji@0 859 MM_LOG (LOCAL->buf,(long) NIL);
yuuji@0 860 break;
yuuji@0 861 }
yuuji@0 862 /* note uncached */
yuuji@0 863 LOCAL->cachedtexts -= ((elt->private.msg.header.text.data ?
yuuji@0 864 elt->private.msg.header.text.size : 0) +
yuuji@0 865 (elt->private.msg.text.text.data ?
yuuji@0 866 elt->private.msg.text.text.size : 0));
yuuji@0 867 mail_gc_msg (&elt->private.msg,GC_ENV | GC_TEXTS);
yuuji@0 868 if(elt->recent)--recent;/* if recent, note one less recent message */
yuuji@0 869 mail_expunged(stream,i);/* notify upper levels */
yuuji@0 870 n++; /* count up one more expunged message */
yuuji@0 871 }
yuuji@0 872 else i++; /* otherwise try next message */
yuuji@0 873 }
yuuji@0 874 if (n) { /* output the news if any expunged */
yuuji@0 875 sprintf (LOCAL->buf,"Expunged %lu messages",n);
yuuji@0 876 MM_LOG (LOCAL->buf,(long) NIL);
yuuji@0 877 }
yuuji@0 878 else MM_LOG ("No messages deleted, so no update needed",(long) NIL);
yuuji@0 879 MM_NOCRITICAL (stream); /* release critical */
yuuji@0 880 mx_unlockindex (stream); /* finished with index */
yuuji@0 881 /* notify upper level of new mailbox size */
yuuji@0 882 mail_exists (stream,stream->nmsgs);
yuuji@0 883 mail_recent (stream,recent);
yuuji@0 884 }
yuuji@0 885 return ret;
yuuji@0 886 }
yuuji@0 887
yuuji@0 888 /* MX mail copy message(s)
yuuji@0 889 * Accepts: MAIL stream
yuuji@0 890 * sequence
yuuji@0 891 * destination mailbox
yuuji@0 892 * copy options
yuuji@0 893 * Returns: T if copy successful, else NIL
yuuji@0 894 */
yuuji@0 895
yuuji@0 896 long mx_copy (MAILSTREAM *stream,char *sequence,char *mailbox,long options)
yuuji@0 897 {
yuuji@0 898 FDDATA d;
yuuji@0 899 STRING st;
yuuji@0 900 MESSAGECACHE *elt;
yuuji@0 901 MAILSTREAM *astream;
yuuji@0 902 struct stat sbuf;
yuuji@0 903 int fd;
yuuji@0 904 unsigned long i,j,uid,uidv;
yuuji@0 905 char *t,tmp[MAILTMPLEN];
yuuji@0 906 long ret;
yuuji@0 907 mailproxycopy_t pc =
yuuji@0 908 (mailproxycopy_t) mail_parameters (stream,GET_MAILPROXYCOPY,NIL);
yuuji@0 909 /* make sure valid mailbox */
yuuji@0 910 if (!mx_valid (mailbox)) switch (errno) {
yuuji@0 911 case NIL: /* no error in stat() */
yuuji@0 912 if (pc) return (*pc) (stream,sequence,mailbox,options);
yuuji@0 913 sprintf (LOCAL->buf,"Not a MX-format mailbox: %.80s",mailbox);
yuuji@0 914 MM_LOG (LOCAL->buf,ERROR);
yuuji@0 915 return NIL;
yuuji@0 916 default: /* some stat() error */
yuuji@0 917 MM_NOTIFY (stream,"[TRYCREATE] Must create mailbox before copy",NIL);
yuuji@0 918 return NIL;
yuuji@0 919 }
yuuji@0 920 /* copy the messages */
yuuji@0 921 if (!(ret = ((options & CP_UID) ? mail_uid_sequence (stream,sequence) :
yuuji@0 922 mail_sequence (stream,sequence))));
yuuji@0 923 /* acquire stream to append to */
yuuji@0 924 else if (!(astream = mail_open (NIL,mailbox,OP_SILENT))) {
yuuji@0 925 MM_LOG ("Can't open copy mailbox",ERROR);
yuuji@0 926 ret = NIL;
yuuji@0 927 }
yuuji@0 928 else {
yuuji@0 929 MM_CRITICAL (stream); /* go critical */
yuuji@0 930 if (!(ret = mx_lockindex (astream)))
yuuji@0 931 MM_LOG ("Message copy failed: unable to lock index",ERROR);
yuuji@0 932 else {
yuuji@0 933
yuuji@0 934 copyuid_t cu = (copyuid_t) mail_parameters (NIL,GET_COPYUID,NIL);
yuuji@0 935 SEARCHSET *source = cu ? mail_newsearchset () : NIL;
yuuji@0 936 SEARCHSET *dest = cu ? mail_newsearchset () : NIL;
yuuji@0 937 for (i = 1,uid = uidv = 0; ret && (i <= stream->nmsgs); i++)
yuuji@0 938 if ((elt = mail_elt (stream,i))->sequence) {
yuuji@0 939 if (ret = ((fd = open (mx_fast_work (stream,elt),O_RDONLY,NIL))
yuuji@0 940 >= 0)) {
yuuji@0 941 fstat (fd,&sbuf); /* get size of message */
yuuji@0 942 d.fd = fd; /* set up file descriptor */
yuuji@0 943 d.pos = 0; /* start of file */
yuuji@0 944 d.chunk = LOCAL->buf;
yuuji@0 945 d.chunksize = CHUNKSIZE;
yuuji@0 946 INIT (&st,fd_string,&d,sbuf.st_size);
yuuji@0 947 /* init flag string */
yuuji@0 948 tmp[0] = tmp[1] = '\0';
yuuji@0 949 if (j = elt->user_flags) do
yuuji@0 950 if (t = stream->user_flags[find_rightmost_bit (&j)])
yuuji@0 951 strcat (strcat (tmp," "),t);
yuuji@0 952 while (j);
yuuji@0 953 if (elt->seen) strcat (tmp," \\Seen");
yuuji@0 954 if (elt->deleted) strcat (tmp," \\Deleted");
yuuji@0 955 if (elt->flagged) strcat (tmp," \\Flagged");
yuuji@0 956 if (elt->answered) strcat (tmp," \\Answered");
yuuji@0 957 if (elt->draft) strcat (tmp," \\Draft");
yuuji@0 958 tmp[0] = '('; /* open list */
yuuji@0 959 strcat (tmp,")"); /* close list */
yuuji@0 960 if (ret = mx_append_msg (astream,tmp,elt,&st,dest)) {
yuuji@0 961 /* add to source set if needed */
yuuji@0 962 if (source) mail_append_set (source,mail_uid (stream,i));
yuuji@0 963 /* delete if doing a move */
yuuji@0 964 if (options & CP_MOVE) elt->deleted = T;
yuuji@0 965 }
yuuji@0 966 }
yuuji@0 967 }
yuuji@0 968 /* return sets if doing COPYUID */
yuuji@0 969 if (cu && ret) (*cu) (stream,mailbox,astream->uid_validity,source,dest);
yuuji@0 970 else { /* flush any sets we may have built */
yuuji@0 971 mail_free_searchset (&source);
yuuji@0 972 mail_free_searchset (&dest);
yuuji@0 973 }
yuuji@0 974 mx_unlockindex (astream); /* unlock index */
yuuji@0 975 }
yuuji@0 976 MM_NOCRITICAL (stream);
yuuji@0 977 mail_close (astream); /* finished with append stream */
yuuji@0 978 }
yuuji@0 979 return ret; /* return success */
yuuji@0 980 }
yuuji@0 981
yuuji@0 982 /* MX mail append message from stringstruct
yuuji@0 983 * Accepts: MAIL stream
yuuji@0 984 * destination mailbox
yuuji@0 985 * append callback
yuuji@0 986 * data for callback
yuuji@0 987 * Returns: T if append successful, else NIL
yuuji@0 988 */
yuuji@0 989
yuuji@0 990 long mx_append (MAILSTREAM *stream,char *mailbox,append_t af,void *data)
yuuji@0 991 {
yuuji@0 992 MESSAGECACHE elt;
yuuji@0 993 MAILSTREAM *astream;
yuuji@0 994 char *flags,*date,tmp[MAILTMPLEN];
yuuji@0 995 STRING *message;
yuuji@0 996 long ret = LONGT;
yuuji@0 997 /* default stream to prototype */
yuuji@0 998 if (!stream) stream = user_flags (&mxproto);
yuuji@0 999 /* N.B.: can't use LOCAL->buf for tmp */
yuuji@0 1000 /* make sure valid mailbox */
yuuji@0 1001 if (!mx_isvalid (mailbox,tmp)) switch (errno) {
yuuji@0 1002 case ENOENT: /* no such file? */
yuuji@0 1003 if (!compare_cstring (mailbox,"INBOX")) mx_create (NIL,"INBOX");
yuuji@0 1004 else {
yuuji@0 1005 MM_NOTIFY (stream,"[TRYCREATE] Must create mailbox before append",NIL);
yuuji@0 1006 return NIL;
yuuji@0 1007 }
yuuji@0 1008 /* falls through */
yuuji@0 1009 case 0: /* merely empty file? */
yuuji@0 1010 break;
yuuji@0 1011 case EINVAL:
yuuji@0 1012 sprintf (tmp,"Invalid MX-format mailbox name: %.80s",mailbox);
yuuji@0 1013 MM_LOG (tmp,ERROR);
yuuji@0 1014 return NIL;
yuuji@0 1015 default:
yuuji@0 1016 sprintf (tmp,"Not a MX-format mailbox: %.80s",mailbox);
yuuji@0 1017 MM_LOG (tmp,ERROR);
yuuji@0 1018 return NIL;
yuuji@0 1019 }
yuuji@0 1020
yuuji@0 1021 /* get first message */
yuuji@0 1022 if (!MM_APPEND (af) (stream,data,&flags,&date,&message)) return NIL;
yuuji@0 1023 if (!(astream = mail_open (NIL,mailbox,OP_SILENT))) {
yuuji@0 1024 MM_LOG ("Can't open append mailbox",ERROR);
yuuji@0 1025 return NIL;
yuuji@0 1026 }
yuuji@0 1027 MM_CRITICAL (astream); /* go critical */
yuuji@0 1028 /* lock the index */
yuuji@0 1029 if (!(ret = mx_lockindex (astream)))
yuuji@0 1030 MM_LOG ("Message append failed: unable to lock index",ERROR);
yuuji@0 1031 else {
yuuji@0 1032 appenduid_t au = (appenduid_t) mail_parameters (NIL,GET_APPENDUID,NIL);
yuuji@0 1033 SEARCHSET *dst = au ? mail_newsearchset () : NIL;
yuuji@0 1034 do {
yuuji@0 1035 /* guard against zero-length */
yuuji@0 1036 if (!(ret = SIZE (message)))
yuuji@0 1037 MM_LOG ("Append of zero-length message",ERROR);
yuuji@0 1038 else if (date && !(ret = mail_parse_date (&elt,date))) {
yuuji@0 1039 sprintf (tmp,"Bad date in append: %.80s",date);
yuuji@0 1040 MM_LOG (tmp,ERROR);
yuuji@0 1041 }
yuuji@0 1042 else ret = mx_append_msg (astream,flags,date ? &elt : NIL,message,dst)&&
yuuji@0 1043 MM_APPEND (af) (stream,data,&flags,&date,&message);
yuuji@0 1044 } while (ret && message);
yuuji@0 1045 /* return sets if doing APPENDUID */
yuuji@0 1046 if (au && ret) (*au) (mailbox,astream->uid_validity,dst);
yuuji@0 1047 else mail_free_searchset (&dst);
yuuji@0 1048 mx_unlockindex (astream); /* unlock index */
yuuji@0 1049 }
yuuji@0 1050 MM_NOCRITICAL (astream); /* release critical */
yuuji@0 1051 mail_close (astream);
yuuji@0 1052 return ret;
yuuji@0 1053 }
yuuji@0 1054
yuuji@0 1055 /* MX mail append single message
yuuji@0 1056 * Accepts: MAIL stream
yuuji@0 1057 * flags for new message if non-NIL
yuuji@0 1058 * elt with source date if non-NIL
yuuji@0 1059 * stringstruct of message text
yuuji@0 1060 * searchset to place UID
yuuji@0 1061 * Returns: T if success, NIL if failure
yuuji@0 1062 */
yuuji@0 1063
yuuji@0 1064 long mx_append_msg (MAILSTREAM *stream,char *flags,MESSAGECACHE *elt,
yuuji@0 1065 STRING *st,SEARCHSET *set)
yuuji@0 1066 {
yuuji@0 1067 char tmp[MAILTMPLEN];
yuuji@0 1068 int fd;
yuuji@0 1069 unsigned long uf;
yuuji@0 1070 long f = mail_parse_flags (stream,flags,&uf);
yuuji@0 1071 /* make message file name */
yuuji@0 1072 sprintf (tmp,"%s/%lu",stream->mailbox,++stream->uid_last);
yuuji@0 1073 if ((fd = open (tmp,O_WRONLY|O_CREAT|O_EXCL,
yuuji@0 1074 (long) mail_parameters (NIL,GET_MBXPROTECTION,NIL))) < 0) {
yuuji@0 1075 sprintf (tmp,"Can't create append message: %s",strerror (errno));
yuuji@0 1076 MM_LOG (tmp,ERROR);
yuuji@0 1077 return NIL;
yuuji@0 1078 }
yuuji@0 1079 while (SIZE (st)) { /* copy the file */
yuuji@0 1080 if (st->cursize && (write (fd,st->curpos,st->cursize) < 0)) {
yuuji@0 1081 unlink (tmp); /* delete file */
yuuji@0 1082 close (fd); /* close the file */
yuuji@0 1083 sprintf (tmp,"Message append failed: %s",strerror (errno));
yuuji@0 1084 MM_LOG (tmp,ERROR);
yuuji@0 1085 return NIL;
yuuji@0 1086 }
yuuji@0 1087 SETPOS (st,GETPOS (st) + st->cursize);
yuuji@0 1088 }
yuuji@0 1089 close (fd); /* close the file */
yuuji@0 1090 if (elt) mx_setdate (tmp,elt);/* set file date */
yuuji@0 1091 /* swell the cache */
yuuji@0 1092 mail_exists (stream,++stream->nmsgs);
yuuji@0 1093 /* copy flags */
yuuji@0 1094 mail_append_set (set,(elt = mail_elt (stream,stream->nmsgs))->private.uid =
yuuji@0 1095 stream->uid_last);
yuuji@0 1096 if (f&fSEEN) elt->seen = T;
yuuji@0 1097 if (f&fDELETED) elt->deleted = T;
yuuji@0 1098 if (f&fFLAGGED) elt->flagged = T;
yuuji@0 1099 if (f&fANSWERED) elt->answered = T;
yuuji@0 1100 if (f&fDRAFT) elt->draft = T;
yuuji@0 1101 elt->user_flags |= uf;
yuuji@0 1102 return LONGT;
yuuji@0 1103 }
yuuji@0 1104
yuuji@0 1105 /* Internal routines */
yuuji@0 1106
yuuji@0 1107
yuuji@0 1108 /* MX file name selection test
yuuji@0 1109 * Accepts: candidate directory entry
yuuji@0 1110 * Returns: T to use file name, NIL to skip it
yuuji@0 1111 */
yuuji@0 1112
yuuji@0 1113 int mx_select (struct direct *name)
yuuji@0 1114 {
yuuji@0 1115 char c;
yuuji@0 1116 char *s = name->d_name;
yuuji@0 1117 while (c = *s++) if (!isdigit (c)) return NIL;
yuuji@0 1118 return T;
yuuji@0 1119 }
yuuji@0 1120
yuuji@0 1121
yuuji@0 1122 /* MX file name comparision
yuuji@0 1123 * Accepts: first candidate directory entry
yuuji@0 1124 * second candidate directory entry
yuuji@0 1125 * Returns: negative if d1 < d2, 0 if d1 == d2, postive if d1 > d2
yuuji@0 1126 */
yuuji@0 1127
yuuji@0 1128 int mx_numsort (const void *d1,const void *d2)
yuuji@0 1129 {
yuuji@0 1130 return atoi ((*(struct direct **) d1)->d_name) -
yuuji@0 1131 atoi ((*(struct direct **) d2)->d_name);
yuuji@0 1132 }
yuuji@0 1133
yuuji@0 1134
yuuji@0 1135 /* MX mail build file name
yuuji@0 1136 * Accepts: destination string
yuuji@0 1137 * source
yuuji@0 1138 * Returns: destination
yuuji@0 1139 */
yuuji@0 1140
yuuji@0 1141 char *mx_file (char *dst,char *name)
yuuji@0 1142 {
yuuji@0 1143 char *s;
yuuji@0 1144 /* empty string if mailboxfile fails */
yuuji@0 1145 if (!mailboxfile (dst,name)) *dst = '\0';
yuuji@0 1146 /* driver-selected INBOX */
yuuji@0 1147 else if (!*dst) mailboxfile (dst,"~/INBOX");
yuuji@0 1148 /* tie off unnecessary trailing / */
yuuji@0 1149 else if ((s = strrchr (dst,'/')) && !s[1]) *s = '\0';
yuuji@0 1150 return dst;
yuuji@0 1151 }
yuuji@0 1152
yuuji@0 1153 /* MX read and lock index
yuuji@0 1154 * Accepts: MAIL stream
yuuji@0 1155 * Returns: T if success, NIL if failure
yuuji@0 1156 */
yuuji@0 1157
yuuji@0 1158 long mx_lockindex (MAILSTREAM *stream)
yuuji@0 1159 {
yuuji@0 1160 unsigned long uf,sf,uid;
yuuji@0 1161 int k = 0;
yuuji@0 1162 unsigned long msgno = 1;
yuuji@0 1163 struct stat sbuf;
yuuji@0 1164 char *s,*t,*idx,tmp[2*MAILTMPLEN];
yuuji@0 1165 MESSAGECACHE *elt;
yuuji@0 1166 blocknotify_t bn = (blocknotify_t) mail_parameters (NIL,GET_BLOCKNOTIFY,NIL);
yuuji@0 1167 if ((LOCAL->fd < 0) && /* get index file, no-op if already have it */
yuuji@0 1168 (LOCAL->fd = open (strcat (strcpy (tmp,stream->mailbox),MXINDEXNAME),
yuuji@0 1169 O_RDWR|O_CREAT,
yuuji@0 1170 (long) mail_parameters (NIL,GET_MBXPROTECTION,NIL)))
yuuji@0 1171 >= 0) {
yuuji@0 1172 (*bn) (BLOCK_FILELOCK,NIL);
yuuji@0 1173 flock (LOCAL->fd,LOCK_EX); /* get exclusive lock */
yuuji@0 1174 (*bn) (BLOCK_NONE,NIL);
yuuji@0 1175 fstat (LOCAL->fd,&sbuf); /* get size of index */
yuuji@0 1176 /* slurp index */
yuuji@0 1177 read (LOCAL->fd,s = idx = (char *) fs_get (sbuf.st_size + 1),sbuf.st_size);
yuuji@0 1178 idx[sbuf.st_size] = '\0'; /* tie off index */
yuuji@0 1179 /* parse index */
yuuji@0 1180 if (sbuf.st_size) while (s && *s) switch (*s) {
yuuji@0 1181 case 'V': /* UID validity record */
yuuji@0 1182 stream->uid_validity = strtoul (s+1,&s,16);
yuuji@0 1183 break;
yuuji@0 1184 case 'L': /* UID last record */
yuuji@0 1185 stream->uid_last = strtoul (s+1,&s,16);
yuuji@0 1186 break;
yuuji@0 1187 case 'K': /* keyword */
yuuji@0 1188 /* find end of keyword */
yuuji@0 1189 if (s = strchr (t = ++s,'\n')) {
yuuji@0 1190 *s++ = '\0'; /* tie off keyword */
yuuji@0 1191 /* copy keyword */
yuuji@0 1192 if ((k < NUSERFLAGS) && !stream->user_flags[k] &&
yuuji@0 1193 (strlen (t) <= MAXUSERFLAG)) stream->user_flags[k] = cpystr (t);
yuuji@0 1194 k++; /* one more keyword */
yuuji@0 1195 }
yuuji@0 1196 break;
yuuji@0 1197
yuuji@0 1198 case 'M': /* message status record */
yuuji@0 1199 uid = strtoul (s+1,&s,16);/* get UID for this message */
yuuji@0 1200 if (*s == ';') { /* get user flags */
yuuji@0 1201 uf = strtoul (s+1,&s,16);
yuuji@0 1202 if (*s == '.') { /* get system flags */
yuuji@0 1203 sf = strtoul (s+1,&s,16);
yuuji@0 1204 while ((msgno <= stream->nmsgs) && (mail_uid (stream,msgno) < uid))
yuuji@0 1205 msgno++; /* find message number for this UID */
yuuji@0 1206 if ((msgno <= stream->nmsgs) && (mail_uid (stream,msgno) == uid)) {
yuuji@0 1207 (elt = mail_elt (stream,msgno))->valid = T;
yuuji@0 1208 elt->user_flags=uf; /* set user and system flags in elt */
yuuji@0 1209 if (sf & fSEEN) elt->seen = T;
yuuji@0 1210 if (sf & fDELETED) elt->deleted = T;
yuuji@0 1211 if (sf & fFLAGGED) elt->flagged = T;
yuuji@0 1212 if (sf & fANSWERED) elt->answered = T;
yuuji@0 1213 if (sf & fDRAFT) elt->draft = T;
yuuji@0 1214 }
yuuji@0 1215 break;
yuuji@0 1216 }
yuuji@0 1217 }
yuuji@0 1218 default: /* bad news */
yuuji@0 1219 sprintf (tmp,"Error in index: %.80s",s);
yuuji@0 1220 MM_LOG (tmp,ERROR);
yuuji@0 1221 *s = NIL; /* ignore remainder of index */
yuuji@0 1222 }
yuuji@0 1223 else { /* new index */
yuuji@0 1224 stream->uid_validity = time (0);
yuuji@0 1225 user_flags (stream); /* init stream with default user flags */
yuuji@0 1226 }
yuuji@0 1227 fs_give ((void **) &idx); /* flush index */
yuuji@0 1228 }
yuuji@0 1229 return (LOCAL->fd >= 0) ? T : NIL;
yuuji@0 1230 }
yuuji@0 1231
yuuji@0 1232 /* MX write and unlock index
yuuji@0 1233 * Accepts: MAIL stream
yuuji@0 1234 */
yuuji@0 1235
yuuji@0 1236 #define MXIXBUFLEN 2048
yuuji@0 1237
yuuji@0 1238 void mx_unlockindex (MAILSTREAM *stream)
yuuji@0 1239 {
yuuji@0 1240 unsigned long i,j;
yuuji@0 1241 off_t size = 0;
yuuji@0 1242 char *s,tmp[MXIXBUFLEN + 64];
yuuji@0 1243 MESSAGECACHE *elt;
yuuji@0 1244 if (LOCAL->fd >= 0) {
yuuji@0 1245 lseek (LOCAL->fd,0,L_SET); /* rewind file */
yuuji@0 1246 /* write header */
yuuji@0 1247 sprintf (s = tmp,"V%08lxL%08lx",stream->uid_validity,stream->uid_last);
yuuji@0 1248 for (i = 0; (i < NUSERFLAGS) && stream->user_flags[i]; ++i)
yuuji@0 1249 sprintf (s += strlen (s),"K%s\n",stream->user_flags[i]);
yuuji@0 1250 /* write messages */
yuuji@0 1251 for (i = 1; i <= stream->nmsgs; i++) {
yuuji@0 1252 /* filled buffer? */
yuuji@0 1253 if (((s += strlen (s)) - tmp) > MXIXBUFLEN) {
yuuji@0 1254 write (LOCAL->fd,tmp,j = s - tmp);
yuuji@0 1255 size += j;
yuuji@0 1256 *(s = tmp) = '\0'; /* dump out and restart buffer */
yuuji@0 1257 }
yuuji@0 1258 elt = mail_elt (stream,i);
yuuji@0 1259 sprintf(s,"M%08lx;%08lx.%04x",elt->private.uid,elt->user_flags,(unsigned)
yuuji@0 1260 ((fSEEN * elt->seen) + (fDELETED * elt->deleted) +
yuuji@0 1261 (fFLAGGED * elt->flagged) + (fANSWERED * elt->answered) +
yuuji@0 1262 (fDRAFT * elt->draft)));
yuuji@0 1263 }
yuuji@0 1264 /* write tail end of buffer */
yuuji@0 1265 if ((s += strlen (s)) != tmp) {
yuuji@0 1266 write (LOCAL->fd,tmp,j = s - tmp);
yuuji@0 1267 size += j;
yuuji@0 1268 }
yuuji@0 1269 ftruncate (LOCAL->fd,size);
yuuji@0 1270 flock (LOCAL->fd,LOCK_UN); /* unlock the index */
yuuji@0 1271 close (LOCAL->fd); /* finished with file */
yuuji@0 1272 LOCAL->fd = -1; /* no index now */
yuuji@0 1273 }
yuuji@0 1274 }
yuuji@0 1275
yuuji@0 1276 /* Set date for message
yuuji@0 1277 * Accepts: file name
yuuji@0 1278 * elt containing date
yuuji@0 1279 */
yuuji@0 1280
yuuji@0 1281 void mx_setdate (char *file,MESSAGECACHE *elt)
yuuji@0 1282 {
yuuji@0 1283 time_t tp[2];
yuuji@0 1284 tp[0] = time (0); /* atime is now */
yuuji@0 1285 tp[1] = mail_longdate (elt); /* modification time */
yuuji@0 1286 utime (file,tp); /* set the times */
yuuji@0 1287 }

UW-IMAP'd extensions by yuuji