1 /*@ S-nail - a mail user agent derived from Berkeley Mail.
2 *@ Maildir folder support. FIXME rewrite - why do we chdir(2)??
3 *@ FIXME Simply truncating paths isn't really it.
5 * Copyright (c) 2000-2004 Gunnar Ritter, Freiburg i. Br., Germany.
6 * Copyright (c) 2012 - 2018 Steffen (Daode) Nurpmeso <steffen@sdaoden.eu>.
7 * SPDX-License-Identifier: BSD-4-Clause
11 * Gunnar Ritter. All rights reserved.
13 * Redistribution and use in source and binary forms, with or without
14 * modification, are permitted provided that the following conditions
16 * 1. Redistributions of source code must retain the above copyright
17 * notice, this list of conditions and the following disclaimer.
18 * 2. Redistributions in binary form must reproduce the above copyright
19 * notice, this list of conditions and the following disclaimer in the
20 * documentation and/or other materials provided with the distribution.
21 * 3. All advertising materials mentioning features or use of this software
22 * must display the following acknowledgement:
23 * This product includes software developed by Gunnar Ritter
24 * and his contributors.
25 * 4. Neither the name of Gunnar Ritter nor the names of his contributors
26 * may be used to endorse or promote products derived from this software
27 * without specific prior written permission.
29 * THIS SOFTWARE IS PROVIDED BY GUNNAR RITTER AND CONTRIBUTORS ``AS IS'' AND
30 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
31 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
32 * ARE DISCLAIMED. IN NO EVENT SHALL GUNNAR RITTER OR CONTRIBUTORS BE LIABLE
33 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
34 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
35 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
36 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
37 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
38 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
42 #define n_FILE maildir
44 #ifndef HAVE_AMALGAMATION
55 /* a_maildir_tbl should be a hash-indexed array of trees! */
56 static struct message
**a_maildir_tbl
, **a_maildir_tbl_top
;
57 static ui32_t a_maildir_tbl_prime
, a_maildir_tbl_maxdist
;
58 static sigjmp_buf _maildir_jmp
;
60 static void __maildircatch(int s
);
61 static void __maildircatch_hold(int s
);
63 /* Do some cleanup in the tmp/ subdir */
64 static void _cleantmp(void);
66 static int _maildir_setfile1(char const *name
, enum fedit_mode fm
,
69 static int a_maildir_cmp(void const *a
, void const *b
);
71 static int _maildir_subdir(char const *name
, char const *sub
,
74 static void _maildir_append(char const *name
, char const *sub
,
77 static void readin(char const *name
, struct message
*m
);
79 static void maildir_update(void);
81 static void _maildir_move(struct n_timespec
const *tsp
,
84 static char * mkname(struct n_timespec
const *tsp
, enum mflag f
,
87 static enum okay
maildir_append1(struct n_timespec
const *tsp
,
88 char const *name
, FILE *fp
, off_t off1
,
89 long size
, enum mflag flag
);
91 static enum okay
trycreate(char const *name
);
93 static enum okay
mkmaildir(char const *name
);
95 static struct message
* mdlook(char const *name
, struct message
*data
);
97 static void mktable(void);
99 static enum okay
subdir_remove(char const *name
, char const *sub
);
102 __maildircatch(int s
)
104 NYD_X
; /* Signal handler */
105 siglongjmp(_maildir_jmp
, s
);
109 __maildircatch_hold(int s
)
111 NYD_X
; /* Signal handler */
113 /* TODO no STDIO in signal handler, no _() tr's -- pre-translate interrupt
115 n_err_sighdl(_("\nImportant operation in progress: "
116 "interrupt again to forcefully abort\n"));
117 safe_signal(SIGINT
, &__maildircatch
);
124 struct n_string s
, *sp
;
130 if ((dirp
= opendir("tmp")) == NULL
)
133 now
= n_time_now(FAL0
)->ts_sec
;
134 sp
= n_string_creat_auto(&s
);
136 while ((dp
= readdir(dirp
)) != NULL
) {
137 if (dp
->d_name
[0] == '.')
140 sp
= n_string_trunc(sp
, 0);
141 sp
= n_string_push_buf(sp
, "tmp/", sizeof("tmp/") -1);
142 sp
= n_string_push_cp(sp
, dp
->d_name
);
143 if (stat(n_string_cp(sp
), &st
) == -1)
145 if (st
.st_atime
+ 36*3600 < now
)
154 _maildir_setfile1(char const *name
, enum fedit_mode fm
, int omsgCount
)
159 if (!(fm
& FEDIT_NEWMAIL
))
162 mb
.mb_perm
= ((n_poption
& n_PO_R_FLAG
) || (fm
& FEDIT_RDONLY
))
164 if ((i
= _maildir_subdir(name
, "cur", fm
)) != 0)
166 if ((i
= _maildir_subdir(name
, "new", fm
)) != 0)
168 _maildir_append(name
, NULL
, NULL
);
170 n_autorec_relax_create();
171 for (i
= ((fm
& FEDIT_NEWMAIL
) ? omsgCount
: 0); i
< msgCount
; ++i
) {
172 readin(name
, message
+ i
);
173 n_autorec_relax_unroll();
175 n_autorec_relax_gut();
177 if (fm
& FEDIT_NEWMAIL
) {
178 if (msgCount
> omsgCount
)
179 qsort(&message
[omsgCount
], msgCount
- omsgCount
, sizeof *message
,
182 qsort(message
, msgCount
, sizeof *message
, &a_maildir_cmp
);
190 a_maildir_cmp(void const *xa
, void const *xb
){
191 char const *cpa
, *cpa_pid
, *cpb
, *cpb_pid
;
192 union {struct message
const *mp
; char const *cp
;} a
, b
;
200 /* We could have parsed the time somewhen in the past, do a quick shot */
201 at
= (si64_t
)a
.mp
->m_time
;
202 bt
= (si64_t
)b
.mp
->m_time
;
203 if(at
!= 0 && bt
!= 0 && (at
-= bt
) != 0)
206 /* Otherwise we need to parse the name */
207 a
.cp
= &a
.mp
->m_maildir_file
[4];
208 b
.cp
= &b
.mp
->m_maildir_file
[4];
210 /* Interpret time stored in name, and use it for comparison */
211 if(((n_idec_si64_cp(&at
, a
.cp
, 10, &cpa
)
212 ) & n_IDEC_STATE_EMASK
) != n_IDEC_STATE_EBASE
|| *cpa
!= '.' ||
214 goto jm1
; /* Fishy */
215 if(((n_idec_si64_cp(&bt
, b
.cp
, 10, &cpb
)
216 ) & n_IDEC_STATE_EMASK
) != n_IDEC_STATE_EBASE
|| *cpb
!= '.' ||
223 /* If the seconds part does not work, go deeper.
224 * We use de-facto standard "maildir — E-mail directory" from the Courier
225 * mail server, also used by, e.g., Dovecot: sec.MusecPpid.hostname:2,flags.
226 * However, a different name convention exists which uses
227 * sec.pid_counter.hostname:2,flags.
228 * First go for usec/counter, then pid */
230 /* A: exact "standard"? */
233 if((rv
= *a
.cp
) == 'M')
236 else if(digitchar(rv
)){
238 while((rv
= *a
.cp
) != '\0' && rv
!= '_')
241 goto jm1
; /* Fishy */
243 /* This is compatible to what dovecot does, it surely does not do so
244 * for nothing, but i have no idea, but am too stupid to ask */
245 else for(;; rv
= *++a
.cp
){
248 if(rv
== '\0' || rv
== '.' || rv
== n_MAILDIR_SEPARATOR
)
249 goto jm1
; /* Fishy */
252 if(((n_idec_si64_cp(&at
, a
.cp
, 10, &cpa
)
253 ) & n_IDEC_STATE_EMASK
) != n_IDEC_STATE_EBASE
)
254 goto jm1
; /* Fishy */
259 if((rv
= *b
.cp
) == 'M')
261 else if(digitchar(rv
)){
263 while((rv
= *b
.cp
) != '\0' && rv
!= '_')
267 }else for(;; rv
= *++b
.cp
){
270 if(rv
== '\0' || rv
== '.' || rv
== n_MAILDIR_SEPARATOR
)
274 if(((n_idec_si64_cp(&bt
, b
.cp
, 10, &cpb
)
275 ) & n_IDEC_STATE_EMASK
) != n_IDEC_STATE_EBASE
)
281 /* So this gets hairy: sort by PID, then hostname */
288 goto jm1
; /* Fishy */
290 if(((n_idec_si64_cp(&at
, a
.cp
, 10, &cpa
)
291 ) & n_IDEC_STATE_EMASK
) != n_IDEC_STATE_EBASE
)
292 goto jm1
; /* Fishy */
302 if(((n_idec_si64_cp(&bt
, b
.cp
, 10, &cpb
)
303 ) & n_IDEC_STATE_EMASK
) != n_IDEC_STATE_EBASE
)
304 goto jm1
; /* Fishy */
310 a
.cp
= (cpa_pid
!= NULL
) ? xa
: cpa
;
311 b
.cp
= (cpb_pid
!= NULL
) ? xb
: cpb
;
312 for(;; ++a
.cp
, ++b
.cp
){
316 at
= (ac
!= '\0' && ac
!= n_MAILDIR_SEPARATOR
);
318 bt
= (bc
!= '\0' && bc
!= n_MAILDIR_SEPARATOR
);
329 rv
= (at
== 0 ? 0 : (at
< 0 ? -1 : 1));
342 _maildir_subdir(char const *name
, char const *sub
, enum fedit_mode fm
)
349 if ((dirp
= opendir(sub
)) == NULL
) {
350 n_err(_("Cannot open directory %s\n"),
351 n_shexp_quote_cp(savecatsep(name
, '/', sub
), FAL0
));
355 if (access(sub
, W_OK
) == -1)
357 while ((dp
= readdir(dirp
)) != NULL
) {
358 if (dp
->d_name
[0] == '.' && (dp
->d_name
[1] == '\0' ||
359 (dp
->d_name
[1] == '.' && dp
->d_name
[2] == '\0')))
361 if (dp
->d_name
[0] == '.')
363 if (!(fm
& FEDIT_NEWMAIL
) || mdlook(dp
->d_name
, NULL
) == NULL
)
364 _maildir_append(name
, sub
, dp
->d_name
);
374 _maildir_append(char const *name
, char const *sub
, char const *fn
)
378 enum mflag f
= MUSED
| MNOFROM
| MNEWEST
;
383 if (fn
!= NULL
&& sub
!= NULL
) {
384 if (!strcmp(sub
, "new"))
390 (void)/*TODO*/n_idec_si64_cp(&tib
, fn
, 10, &xp
);
394 if ((cp
= strrchr(xp
, ',')) != NULL
&& PTRCMP(cp
, >, xp
+ 2) &&
395 cp
[-1] == '2' && cp
[-2] == n_MAILDIR_SEPARATOR
) {
396 while (*++cp
!= '\0') {
418 /* Ensure room (and a NULLified last entry) */
420 message_append(NULL
);
423 if (fn
== NULL
|| sub
== NULL
)
426 m
= &message
[msgCount
++];
433 m
->m_maildir_file
= tmp
= n_alloc(sz
+ 1 + i
);
434 memcpy(tmp
, sub
, sz
);
436 memcpy(&tmp
[sz
], fn
, i
);
440 m
->m_maildir_hash
= n_torek_hash(fn
);
447 readin(char const *name
, struct message
*m
)
450 size_t bufsize
, buflen
, cnt
;
451 long size
= 0, lines
= 0;
457 if ((fp
= Fopen(m
->m_maildir_file
, "r")) == NULL
) {
458 n_err(_("Cannot read %s for message %lu\n"),
459 n_shexp_quote_cp(savecatsep(name
, '/', m
->m_maildir_file
), FAL0
),
460 (ul_i
)PTR2SIZE(m
- message
+ 1));
461 m
->m_flag
|= MHIDDEN
;
466 fseek(mb
.mb_otf
, 0L, SEEK_END
);
467 offset
= ftell(mb
.mb_otf
);
468 buf
= n_alloc(bufsize
= LINESIZE
);
470 while (fgetline(&buf
, &bufsize
, &cnt
, &buflen
, fp
, 1) != NULL
) {
471 /* Since we simply copy over data without doing any transfer
472 * encoding reclassification/adjustment we *have* to perform
473 * RFC 4155 compliant From_ quoting here */
474 if (emptyline
&& is_head(buf
, buflen
, FAL0
)) {
475 putc('>', mb
.mb_otf
);
478 size
+= fwrite(buf
, 1, buflen
, mb
.mb_otf
);/*XXX err hdling*/
479 emptyline
= (*buf
== '\n');
484 /* TODO we need \n\n for mbox format.
485 * TODO That is to say we do it wrong here in order to get it right
486 * TODO when send.c stuff or with MBOX handling, even though THIS
487 * TODO line is solely a property of the MBOX database format! */
488 putc('\n', mb
.mb_otf
);
495 m
->m_size
= m
->m_xsize
= size
;
496 m
->m_lines
= m
->m_xlines
= lines
;
497 m
->m_block
= mailx_blockof(offset
);
498 m
->m_offset
= mailx_offsetof(offset
);
508 struct n_timespec
const *tsp
;
509 int dodel
, c
, gotcha
= 0, held
= 0, modflags
= 0;
515 if (!(n_pstate
& n_PS_EDIT
)) {
517 for (m
= message
, c
= 0; PTRCMP(m
, <, message
+ msgCount
); ++m
) {
518 if (m
->m_flag
& MBOX
)
522 if (makembox() == STOP
)
526 tsp
= n_time_now(TRU1
); /* TODO FAL0, eventloop update! */
528 n_autorec_relax_create();
529 for (m
= message
, gotcha
= 0, held
= 0; PTRCMP(m
, <, message
+ msgCount
);
531 if (n_pstate
& n_PS_EDIT
)
532 dodel
= m
->m_flag
& MDELETED
;
534 dodel
= !((m
->m_flag
& MPRESERVE
) || !(m
->m_flag
& MTOUCH
));
536 if (unlink(m
->m_maildir_file
) < 0)
537 n_err(_("Cannot delete file %s for message %lu\n"),
538 n_shexp_quote_cp(savecatsep(mailname
, '/', m
->m_maildir_file
),
539 FAL0
), (ul_i
)PTR2SIZE(m
- message
+ 1));
543 if ((m
->m_flag
& (MREAD
| MSTATUS
)) == (MREAD
| MSTATUS
) ||
544 (m
->m_flag
& (MNEW
| MBOXED
| MSAVED
| MSTATUS
| MFLAG
|
545 MUNFLAG
| MANSWER
| MUNANSWER
| MDRAFT
| MUNDRAFT
))) {
546 _maildir_move(tsp
, m
);
547 n_autorec_relax_unroll();
553 n_autorec_relax_gut();
556 if ((gotcha
|| modflags
) && (n_pstate
& n_PS_EDIT
)) {
557 fprintf(n_stdout
, "%s %s\n",
558 n_shexp_quote_cp(displayname
, FAL0
),
559 ((ok_blook(bsdcompat
) || ok_blook(bsdmsgs
))
560 ? _("complete") : _("updated.")));
561 } else if (held
&& !(n_pstate
& n_PS_EDIT
) && mb
.mb_perm
!= 0) {
563 fprintf(n_stdout
, _("Held 1 message in %s\n"), displayname
);
565 fprintf(n_stdout
, _("Held %d messages in %s\n"), held
, displayname
);
569 for (m
= message
; PTRCMP(m
, <, message
+ msgCount
); ++m
)
570 n_free(n_UNCONST(m
->m_maildir_file
));
575 _maildir_move(struct n_timespec
const *tsp
, struct message
*m
)
580 fn
= mkname(tsp
, m
->m_flag
, m
->m_maildir_file
+ 4);
581 newfn
= savecat("cur/", fn
);
582 if (!strcmp(m
->m_maildir_file
, newfn
))
584 if (link(m
->m_maildir_file
, newfn
) == -1) {
585 n_err(_("Cannot link %s to %s: message %lu not touched\n"),
586 n_shexp_quote_cp(savecatsep(mailname
, '/', m
->m_maildir_file
), FAL0
),
587 n_shexp_quote_cp(savecatsep(mailname
, '/', newfn
), FAL0
),
588 (ul_i
)PTR2SIZE(m
- message
+ 1));
591 if (unlink(m
->m_maildir_file
) == -1)
592 n_err(_("Cannot unlink %s\n"),
593 n_shexp_quote_cp(savecatsep(mailname
, '/', m
->m_maildir_file
), FAL0
));
599 mkname(struct n_timespec
const *tsp
, enum mflag f
, char const *pref
)
602 static struct n_timespec ts
;
615 cp
= n_nodename(FAL0
);
618 if (UICMP(32, n
, <, size
+ 8))
619 node
= n_realloc(node
, size
+= 20);
622 node
[n
++] = '\\', node
[n
++] = '0',
623 node
[n
++] = '5', node
[n
++] = '7';
626 node
[n
++] = '\\', node
[n
++] = '0',
627 node
[n
++] = '7', node
[n
++] = '2';
632 } while (*cp
++ != '\0');
635 /* Problem: Courier spec uses microseconds, not nanoseconds */
636 if((s
= tsp
->ts_sec
) > ts
.ts_sec
){
638 ts
.ts_nsec
= tsp
->ts_nsec
/ (n_DATE_NANOSSEC
/ n_DATE_MICROSSEC
);
640 s
= tsp
->ts_nsec
/ (n_DATE_NANOSSEC
/ n_DATE_MICROSSEC
);
643 if(s
< n_DATE_MICROSSEC
)
651 /* Create a name according to Courier spec */
652 size
= 60 + strlen(node
);
653 cp
= n_autorec_alloc(size
);
654 n
= snprintf(cp
, size
, "%" PRId64
".M%" PRIdZ
"P%ld.%s:2,",
655 ts
.ts_sec
, ts
.ts_nsec
, (long)n_pid
, node
);
657 size
= (n
= strlen(pref
)) + 13;
658 cp
= n_autorec_alloc(size
);
659 memcpy(cp
, pref
, n
+1);
660 for (i
= n
; i
> 3; --i
)
661 if (cp
[i
- 1] == ',' && cp
[i
- 2] == '2' &&
662 cp
[i
- 3] == n_MAILDIR_SEPARATOR
) {
667 memcpy(cp
+ n
, ":2,", 3 +1);
689 maildir_append1(struct n_timespec
const *tsp
, char const *name
, FILE *fp
,
690 off_t off1
, long size
, enum mflag flag
)
692 char buf
[4096], *fn
, *tfn
, *nfn
;
695 size_t nlen
, flen
, n
;
701 /* Create a unique temporary file */
702 for (nfn
= (char*)0xA /* XXX no magic */;; n_msleep(500, FAL0
)) {
703 flen
= strlen(fn
= mkname(tsp
, flag
, NULL
));
704 tfn
= n_autorec_alloc(n
= nlen
+ flen
+ 6);
705 snprintf(tfn
, n
, "%s/tmp/%s", name
, fn
);
707 /* Use "wx" for O_EXCL XXX stat(2) rather redundant; coverity:TOCTOU */
708 if ((!stat(tfn
, &st
) || n_err_no
== n_ERR_NOENT
) &&
709 (op
= Fopen(tfn
, "wx")) != NULL
)
712 nfn
= (char*)(PTR2SIZE(nfn
) - 1);
714 n_err(_("Can't create an unique file name in %s\n"),
715 n_shexp_quote_cp(savecat(name
, "/tmp"), FAL0
));
720 if (fseek(fp
, off1
, SEEK_SET
) == -1)
723 size_t z
= UICMP(z
, size
, >, sizeof buf
) ? sizeof buf
: (size_t)size
;
725 if (z
!= (n
= fread(buf
, 1, z
, fp
)) || n
!= fwrite(buf
, 1, n
, op
)) {
727 n_err(_("Error writing to %s\n"), n_shexp_quote_cp(tfn
, FAL0
));
735 nfn
= n_autorec_alloc(n
= nlen
+ flen
+ 6);
736 snprintf(nfn
, n
, "%s/new/%s", name
, fn
);
737 if (link(tfn
, nfn
) == -1) {
738 n_err(_("Cannot link %s to %s\n"), n_shexp_quote_cp(tfn
, FAL0
),
739 n_shexp_quote_cp(nfn
, FAL0
));
744 if (unlink(tfn
) == -1)
745 n_err(_("Cannot unlink %s\n"), n_shexp_quote_cp(tfn
, FAL0
));
752 trycreate(char const *name
)
758 if (!stat(name
, &st
)) {
759 if (!S_ISDIR(st
.st_mode
)) {
760 n_err(_("%s is not a directory\n"), n_shexp_quote_cp(name
, FAL0
));
763 } else if (!n_path_mkdir(name
)) {
764 n_err(_("Cannot create directory %s\n"), n_shexp_quote_cp(name
, FAL0
));
774 mkmaildir(char const *name
) /* TODO proper cleanup on error; use path[] loop */
781 if (trycreate(name
) == OKAY
) {
782 np
= n_lofi_alloc((sz
= strlen(name
)) + 4 +1);
783 memcpy(np
, name
, sz
);
784 memcpy(np
+ sz
, "/tmp", 4 +1);
785 if (trycreate(np
) == OKAY
) {
786 memcpy(np
+ sz
, "/new", 4 +1);
787 if (trycreate(np
) == OKAY
) {
788 memcpy(np
+ sz
, "/cur", 4 +1);
798 static struct message
*
799 mdlook(char const *name
, struct message
*data
)
801 struct message
**mpp
, *mp
;
806 i
= data
->m_maildir_hash
;
808 i
= n_torek_hash(name
);
810 mpp
= &a_maildir_tbl
[i
%= a_maildir_tbl_prime
];
813 if((mp
= *mpp
) == NULL
){
814 if(n_UNLIKELY(data
!= NULL
)){
816 if(i
> a_maildir_tbl_maxdist
)
817 a_maildir_tbl_maxdist
= i
;
820 }else if(mp
->m_maildir_hash
== h
&& !strcmp(&mp
->m_maildir_file
[4], name
))
823 if(n_UNLIKELY(mpp
++ == a_maildir_tbl_top
))
825 if(++i
> a_maildir_tbl_maxdist
&& n_UNLIKELY(data
== NULL
)){
841 i
= a_maildir_tbl_prime
= msgCount
;
844 a_maildir_tbl_prime
= n_prime_next(a_maildir_tbl_prime
);
845 while(a_maildir_tbl_prime
< i
);
846 a_maildir_tbl
= n_calloc(a_maildir_tbl_prime
, sizeof *a_maildir_tbl
);
847 a_maildir_tbl_top
= &a_maildir_tbl
[a_maildir_tbl_prime
- 1];
848 a_maildir_tbl_maxdist
= 0;
849 for(mp
= message
, i
= msgCount
; i
-- != 0; ++mp
)
850 mdlook(&mp
->m_maildir_file
[4], mp
);
855 subdir_remove(char const *name
, char const *sub
)
858 int pathsize
, pathend
, namelen
, sublen
, n
;
864 namelen
= strlen(name
);
865 sublen
= strlen(sub
);
866 path
= n_alloc(pathsize
= namelen
+ sublen
+ 30 +1);
867 memcpy(path
, name
, namelen
);
869 memcpy(path
+ namelen
+ 1, sub
, sublen
);
870 path
[namelen
+ sublen
+ 1] = '/';
871 path
[pathend
= namelen
+ sublen
+ 2] = '\0';
873 if ((dirp
= opendir(path
)) == NULL
) {
877 while ((dp
= readdir(dirp
)) != NULL
) {
878 if (dp
->d_name
[0] == '.' && (dp
->d_name
[1] == '\0' ||
879 (dp
->d_name
[1] == '.' && dp
->d_name
[2] == '\0')))
881 if (dp
->d_name
[0] == '.')
883 n
= strlen(dp
->d_name
);
884 if (UICMP(32, pathend
+ n
+1, >, pathsize
))
885 path
= n_realloc(path
, pathsize
= pathend
+ n
+ 30);
886 memcpy(path
+ pathend
, dp
->d_name
, n
+1);
887 if (unlink(path
) == -1) {
895 path
[pathend
] = '\0';
896 if (rmdir(path
) == -1) {
908 maildir_setfile(char const *who
, char const * volatile name
,
911 sighandler_type
volatile saveint
;
918 omsgCount
= msgCount
;
919 if (cwget(&cw
) == STOP
) {
920 n_alert(_("Cannot open current directory"));
924 if (!(fm
& FEDIT_NEWMAIL
) && !quit(FAL0
))
927 saveint
= safe_signal(SIGINT
, SIG_IGN
);
929 if (!(fm
& FEDIT_NEWMAIL
)) {
930 if (fm
& FEDIT_SYSBOX
)
931 n_pstate
&= ~n_PS_EDIT
;
933 n_pstate
|= n_PS_EDIT
;
943 mb
.mb_type
= MB_MAILDIR
;
946 if(!n_is_dir(name
, FAL0
)){
947 emsg
= N_("Not a maildir: %s\n");
949 }else if(chdir(name
) < 0){
950 emsg
= N_("Cannot enter maildir://%s\n");
952 n_err(V_(emsg
), n_shexp_quote_cp(name
, FAL0
));
953 mb
.mb_type
= MB_VOID
;
957 safe_signal(SIGINT
, saveint
);
961 a_maildir_tbl
= NULL
;
962 if (sigsetjmp(_maildir_jmp
, 1) == 0) {
963 if (fm
& FEDIT_NEWMAIL
)
965 if (saveint
!= SIG_IGN
)
966 safe_signal(SIGINT
, &__maildircatch
);
967 i
= _maildir_setfile1(name
, fm
, omsgCount
);
969 if ((fm
& FEDIT_NEWMAIL
) && a_maildir_tbl
!= NULL
)
970 n_free(a_maildir_tbl
);
972 safe_signal(SIGINT
, saveint
);
975 mb
.mb_type
= MB_VOID
;
980 if (cwret(&cw
) == STOP
)
981 n_panic(_("Cannot change back to current directory"));
985 if ((fm
& FEDIT_NEWMAIL
) && mb
.mb_sorted
&& msgCount
> omsgCount
) {
990 if (!(fm
& FEDIT_NEWMAIL
)) {
991 n_pstate
&= ~n_PS_SAW_COMMAND
;
992 n_pstate
|= n_PS_SETFILE_OPENED
;
995 if ((n_poption
& n_PO_EXISTONLY
) && !(n_poption
& n_PO_HEADERLIST
)) {
1000 if (!(fm
& FEDIT_NEWMAIL
) && (fm
& FEDIT_SYSBOX
) && msgCount
== 0) {
1001 if (mb
.mb_type
== MB_MAILDIR
/* XXX ?? */ && !ok_blook(emptystart
))
1002 n_err(_("No mail for %s at %s\n"), who
, n_shexp_quote_cp(name
, FAL0
));
1007 if ((fm
& FEDIT_NEWMAIL
) && msgCount
> omsgCount
)
1008 newmailinfo(omsgCount
);
1016 maildir_quit(bool_t hold_sigs_on
)
1018 sighandler_type saveint
;
1028 if (cwget(&cw
) == STOP
) {
1029 n_alert(_("Cannot open current directory"));
1033 saveint
= safe_signal(SIGINT
, SIG_IGN
);
1035 if (chdir(mailname
) == -1) {
1036 n_err(_("Cannot change directory to %s\n"),
1037 n_shexp_quote_cp(mailname
, FAL0
));
1039 safe_signal(SIGINT
, saveint
);
1043 if (sigsetjmp(_maildir_jmp
, 1) == 0) {
1044 if (saveint
!= SIG_IGN
)
1045 safe_signal(SIGINT
, &__maildircatch_hold
);
1049 safe_signal(SIGINT
, saveint
);
1051 if (cwret(&cw
) == STOP
)
1052 n_panic(_("Cannot change back to current directory"));
1063 maildir_append(char const *name
, FILE *fp
, long offset
)
1065 struct n_timespec
const *tsp
;
1066 char *buf
, *bp
, *lp
;
1067 size_t bufsize
, buflen
, cnt
;
1068 off_t off1
= -1, offs
;
1071 enum {_NONE
= 0, _INHEAD
= 1<<0, _NLSEP
= 1<<1} state
;
1075 if ((rv
= mkmaildir(name
)) != OKAY
)
1078 buf
= n_alloc(bufsize
= LINESIZE
); /* TODO line pool; signals */
1081 offs
= offset
/* BSD will move due to O_APPEND! ftell(fp) */;
1083 tsp
= n_time_now(TRU1
); /* TODO -> eventloop */
1085 n_autorec_relax_create();
1086 for (flag
= MNEW
, state
= _NLSEP
;;) {
1087 bp
= fgetline(&buf
, &bufsize
, &cnt
, &buflen
, fp
, 1);
1090 ((state
& (_INHEAD
| _NLSEP
)) == _NLSEP
&&
1091 is_head(buf
, buflen
, FAL0
))) {
1092 if (off1
!= (off_t
)-1) {
1093 if ((rv
= maildir_append1(tsp
, name
, fp
, off1
, size
, flag
)) == STOP
)
1095 n_autorec_relax_unroll();
1096 if (fseek(fp
, offs
+ buflen
, SEEK_SET
) == -1) {
1101 off1
= offs
+ buflen
;
1113 if (buf
[0] == '\n') {
1116 } else if (state
& _INHEAD
) {
1117 if (!ascncasecmp(buf
, "status", 6)) {
1119 while (whitechar(*lp
))
1122 while (*++lp
!= '\0')
1131 } else if (!ascncasecmp(buf
, "x-status", 8)) {
1133 while (whitechar(*lp
))
1136 while (*++lp
!= '\0')
1154 n_autorec_relax_gut();
1162 maildir_remove(char const *name
)
1164 enum okay rv
= STOP
;
1167 if (subdir_remove(name
, "tmp") == STOP
||
1168 subdir_remove(name
, "new") == STOP
||
1169 subdir_remove(name
, "cur") == STOP
)
1171 if (rmdir(name
) == -1) {
1180 #endif /* HAVE_MAILDIR */