1 /*@ S-nail - a mail user agent derived from Berkeley Mail.
2 *@ Collect input from standard input, handling ~ escapes.
4 * Copyright (c) 2000-2004 Gunnar Ritter, Freiburg i. Br., Germany.
5 * Copyright (c) 2012 - 2016 Steffen (Daode) Nurpmeso <steffen@sdaoden.eu>.
8 * Copyright (c) 1980, 1993
9 * The Regents of the University of California. All rights reserved.
11 * Redistribution and use in source and binary forms, with or without
12 * modification, are permitted provided that the following conditions
14 * 1. Redistributions of source code must retain the above copyright
15 * notice, this list of conditions and the following disclaimer.
16 * 2. Redistributions in binary form must reproduce the above copyright
17 * notice, this list of conditions and the following disclaimer in the
18 * documentation and/or other materials provided with the distribution.
19 * 3. Neither the name of the University nor the names of its contributors
20 * may be used to endorse or promote products derived from this software
21 * without specific prior written permission.
23 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
24 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
25 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
26 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
28 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
29 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
30 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
32 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
36 #define n_FILE collect
38 #ifndef HAVE_AMALGAMATION
42 /* The following hookiness with global variables is so that on receipt of an
43 * interrupt signal, the partial message can be salted away on *DEAD* */
45 static sighandler_type _coll_saveint
; /* Previous SIGINT value */
46 static sighandler_type _coll_savehup
; /* Previous SIGHUP value */
47 static FILE *_coll_fp
; /* File for saving away */
48 static int volatile _coll_hadintr
; /* Have seen one SIGINT so far */
49 static sigjmp_buf _coll_jmp
; /* To get back to work */
50 static sigjmp_buf _coll_abort
; /* To end collection with error */
51 static sigjmp_buf _coll_pipejmp
; /* On broken pipe */
53 /* Handle `~:', `~_' and some hooks; hp may be NULL */
54 static void _execute_command(struct header
*hp
, char const *linebuf
,
57 /* If *interactive* is set and *doecho* is, too, also dump to *stdout* */
58 static int _include_file(char const *name
, int *linecount
,
59 int *charcount
, bool_t doecho
, bool_t indent
);
61 static void _collect_onpipe(int signo
);
63 /* Execute cmd and insert its standard output into fp */
64 static void insertcommand(FILE *fp
, char const *cmd
);
67 static void print_collf(FILE *collf
, struct header
*hp
);
69 /* Write a file, ex-like if f set */
70 static int exwrite(char const *name
, FILE *fp
, int f
);
72 /* Parse off the message header from fp and store relevant fields in hp,
73 * replace _coll_fp with a shiny new version without any header */
74 static enum okay
makeheader(FILE *fp
, struct header
*hp
, si8_t
*checkaddr_err
);
76 /* Edit the message being collected on fp. On return, make the edit file the
78 static void mesedit(int c
, struct header
*hp
);
80 /* Pipe the message through the command. Old message is on stdin of command,
81 * new message collected from stdout. Shell must return 0 to accept new msg */
82 static void mespipe(char *cmd
);
84 /* Interpolate the named messages into the current message, possibly doing
85 * indent stuff. The flag argument is one of the tilde escapes: [mMfFuU].
86 * Return a count of the number of characters now in the message, or -1 if an
87 * error is encountered writing the message temporary */
88 static int forward(char *ms
, FILE *fp
, int f
);
90 /* On interrupt, come here to save the partial message in ~/dead.letter.
91 * Then jump out of the collection loop */
92 static void _collint(int s
);
94 static void collhup(int s
);
96 static int putesc(char const *s
, FILE *stream
); /* TODO wysh set! */
98 /* call_compose_mode_hook() setter hook */
99 static void a_coll__hook_setter(void *arg
);
102 _execute_command(struct header
*hp
, char const *linebuf
, size_t linesize
){
103 /* The problem arises if there are rfc822 message attachments and the
104 * user uses `~:' to change the current file. TODO Unfortunately we
105 * TODO cannot simply keep a pointer to, or increment a reference count
106 * TODO of the current `file' (mailbox that is) object, because the
107 * TODO codebase doesn't deal with that at all; so, until some far
108 * TODO later time, copy the name of the path, and warn the user if it
109 * TODO changed; we COULD use the AC_TMPFILE attachment type, i.e.,
110 * TODO copy the message attachments over to temporary files, but that
111 * TODO would require more changes so that the user still can recognize
112 * TODO in `~@' etc. that its a rfc822 message attachment; see below */
114 struct attachment
*ap
;
115 char * volatile mnbuf
;
121 n_SIGMAN_ENTER_SWITCH(&sm
, n_SIGMAN_ALL
){
128 /* If the above todo is worked, remove or outsource to attachments.c! */
129 if(hp
!= NULL
&& (ap
= hp
->h_attach
) != NULL
) do
131 mnbuf
= sstrdup(mailname
);
134 while((ap
= ap
->a_flink
) != NULL
);
136 n_source_command(n_LEXINPUT_CTX_COMPOSE
, linebuf
);
138 n_sigman_cleanup_ping(&sm
);
141 if(strcmp(mnbuf
, mailname
))
142 n_err(_("Mailbox changed: it is likely that existing "
143 "rfc822 attachments became invalid!\n"));
147 n_sigman_leave(&sm
, n_SIGMAN_VIPSIGS_NTTYOUT
);
151 _include_file(char const *name
, int *linecount
, int *charcount
,
152 bool_t doecho
, bool_t indent
)
157 char *linebuf
= NULL
; /* TODO line pool */
158 size_t linesize
= 0, indl
, linelen
, cnt
;
161 if (name
== (char*)-1)
163 else if ((fbuf
= Fopen(name
, "r")) == NULL
) {
169 indb
= NULL
, indl
= 0;
171 if ((indb
= ok_vlook(indentprefix
)) == NULL
)
172 indb
= INDENT_DEFAULT
;
176 *linecount
= *charcount
= 0;
178 while (fgetline(&linebuf
, &linesize
, &cnt
, &linelen
, fbuf
, 0) != NULL
) {
179 if (indl
> 0 && fwrite(indb
, sizeof *indb
, indl
, _coll_fp
) != indl
)
181 if (fwrite(linebuf
, sizeof *linebuf
, linelen
, _coll_fp
) != linelen
)
184 (*charcount
) += linelen
+ indl
;
185 if ((options
& OPT_INTERACTIVE
) && doecho
) {
187 fwrite(indb
, sizeof *indb
, indl
, stdout
);
188 fwrite(linebuf
, sizeof *linebuf
, linelen
, stdout
);
191 if (fflush(_coll_fp
))
193 if ((options
& OPT_INTERACTIVE
) && doecho
)
200 if (fbuf
!= NULL
&& fbuf
!= stdin
)
207 _collect_onpipe(int signo
)
209 NYD_X
; /* Signal handler */
211 siglongjmp(_coll_pipejmp
, 1);
215 insertcommand(FILE *fp
, char const *cmd
)
221 if ((ibuf
= Popen(cmd
, "r", ok_vlook(SHELL
), NULL
, 0)) != NULL
) {
222 while ((c
= getc(ibuf
)) != EOF
) /* XXX bytewise, yuck! */
231 print_collf(FILE *cf
, struct header
*hp
)
233 char *lbuf
= NULL
; /* TODO line pool */
234 sighandler_type sigint
;
235 FILE * volatile obuf
= stdout
;
236 struct attachment
*ap
;
239 size_t linesize
= 0, linelen
, cnt
, cnt2
;
243 cnt
= cnt2
= (size_t)fsize(cf
);
245 sigint
= safe_signal(SIGINT
, SIG_IGN
);
247 if ((options
& OPT_INTERACTIVE
) && (cp
= ok_vlook(crt
)) != NULL
) {
251 if (hp
->h_to
!= NULL
)
253 if (hp
->h_subject
!= NULL
)
255 if (hp
->h_cc
!= NULL
)
257 if (hp
->h_bcc
!= NULL
)
259 if (hp
->h_attach
!= NULL
)
261 m
+= (hp
->h_from
!= NULL
|| myaddrs(hp
) != NULL
);
262 m
+= (hp
->h_sender
!= NULL
|| ok_vlook(sender
) != NULL
);
263 m
+= (hp
->h_replyto
!= NULL
|| ok_vlook(replyto
) != NULL
);
265 l
= (*cp
== '\0') ? (size_t)screensize() : strtoul(cp
, NULL
, 0);
270 for (m
= 0; fgetline(&lbuf
, &linesize
, &cnt2
, NULL
, cf
, 0); ++m
)
275 if (sigsetjmp(_coll_pipejmp
, 1))
277 if ((obuf
= n_pager_open()) == NULL
)
280 safe_signal(SIGPIPE
, &_collect_onpipe
);
284 fprintf(obuf
, _("-------\nMessage contains:\n"));
285 gf
= GIDENT
| GTO
| GSUBJECT
| GCC
| GBCC
| GNL
| GFILES
| GCOMMA
;
286 puthead(TRU1
, hp
, obuf
, gf
, SEND_TODISP
, CONV_NONE
, NULL
, NULL
);
287 while (fgetline(&lbuf
, &linesize
, &cnt
, &linelen
, cf
, 1))
288 prout(lbuf
, linelen
, obuf
);
289 if (hp
->h_attach
!= NULL
) {
290 fputs(_("-------\nAttachments:\n"), obuf
);
291 for (ap
= hp
->h_attach
; ap
!= NULL
; ap
= ap
->a_flink
) {
293 fprintf(obuf
, " - message %u\n", ap
->a_msgno
);
295 /* TODO after MIME/send layer rewrite we *know*
296 * TODO the details of the attachment here,
297 * TODO so adjust this again, then */
298 char const *cs
, *csi
= "-> ";
300 if ((cs
= ap
->a_charset
) == NULL
&&
301 (csi
= "<- ", cs
= ap
->a_input_charset
) == NULL
)
302 cs
= charset_get_lc();
303 if ((cp
= ap
->a_content_type
) == NULL
)
305 else if (ascncasecmp(cp
, "text/", 5))
307 fprintf(obuf
, " - [%s, %s%s] %s\n", cp
, csi
, cs
,
308 n_shexp_quote_cp(ap
->a_name
, FAL0
));
318 safe_signal(SIGINT
, sigint
);
323 exwrite(char const *name
, FILE *fp
, int f
)
331 printf("%s ", n_shexp_quote_cp(name
, FAL0
));
334 if ((of
= Fopen(name
, "a")) == NULL
) {
341 while ((c
= getc(fp
)) != EOF
) {
353 printf(_("%d/%ld\n"), lc
, cc
);
362 makeheader(FILE *fp
, struct header
*hp
, si8_t
*checkaddr_err
)
369 if ((nf
= Ftmp(NULL
, "colhead", OF_RDWR
| OF_UNLINK
| OF_REGISTER
)) ==NULL
) {
370 n_perr(_("temporary mail edit file"), 0);
374 extract_header(fp
, hp
, checkaddr_err
);
376 while ((c
= getc(fp
)) != EOF
) /* XXX bytewise, yuck! */
382 if (check_from_and_sender(hp
->h_from
, hp
->h_sender
) == NULL
)
391 mesedit(int c
, struct header
*hp
)
394 sighandler_type sigint
;
398 if(!(saved
= ok_blook(add_file_recipients
)))
399 ok_bset(add_file_recipients
);
401 sigint
= safe_signal(SIGINT
, SIG_IGN
);
402 nf
= run_editor(_coll_fp
, (off_t
)-1, c
, FAL0
, hp
, NULL
, SEND_MBOX
, sigint
);
406 makeheader(nf
, hp
, NULL
);
408 fseek(nf
, 0L, SEEK_END
);
413 safe_signal(SIGINT
, sigint
);
416 ok_bclear(add_file_recipients
);
424 sighandler_type sigint
;
427 sigint
= safe_signal(SIGINT
, SIG_IGN
);
429 if ((nf
= Ftmp(NULL
, "colpipe", OF_RDWR
| OF_UNLINK
| OF_REGISTER
)) ==NULL
) {
430 n_perr(_("temporary mail edit file"), 0);
434 /* stdin = current message. stdout = new message */
436 if (run_command(ok_vlook(SHELL
), 0, fileno(_coll_fp
), fileno(nf
), "-c",
437 cmd
, NULL
, NULL
) < 0) {
442 if (fsize(nf
) == 0) {
443 n_err(_("No bytes from %s !?\n"), n_shexp_quote_cp(cmd
, FAL0
));
449 fseek(nf
, 0L, SEEK_END
);
453 safe_signal(SIGINT
, sigint
);
458 forward(char *ms
, FILE *fp
, int f
)
461 struct ignoretab
*ig
;
463 enum sendaction action
;
466 msgvec
= salloc((size_t)(msgCount
+ 1) * sizeof *msgvec
);
467 if (getmsglist(ms
, msgvec
, 0) < 0)
470 *msgvec
= first(0, MMNORM
);
472 n_err(_("No appropriate messages\n"));
478 if (f
== 'f' || f
== 'F' || f
== 'u')
480 else if ((tabst
= ok_vlook(indentprefix
)) == NULL
)
481 tabst
= INDENT_DEFAULT
;
482 if (f
== 'u' || f
== 'U')
485 ig
= upperchar(f
) ? NULL
: ignore
;
486 action
= (upperchar(f
) && f
!= 'U') ? SEND_QUOTE_ALL
: SEND_QUOTE
;
488 printf(_("Interpolating:"));
489 for (; *msgvec
!= 0; ++msgvec
) {
490 struct message
*mp
= message
+ *msgvec
- 1;
493 printf(" %d", *msgvec
);
495 if (sendmp(mp
, fp
, ig
, tabst
, action
, NULL
) < 0) {
496 n_perr(_("temporary mail file"), 0);
510 NYD_X
; /* Signal handler */
512 /* the control flow is subtle, because we can be called from ~q */
513 if (_coll_hadintr
== 0) {
514 if (ok_blook(ignore
)) {
520 siglongjmp(_coll_jmp
, 1);
522 exit_status
|= EXIT_SEND_ERROR
;
524 savedeadletter(_coll_fp
, TRU1
);
525 /* Aborting message, no need to fflush() .. */
526 siglongjmp(_coll_abort
, 1);
532 NYD_X
; /* Signal handler */
535 savedeadletter(_coll_fp
, TRU1
);
536 /* Let's pretend nobody else wants to clean up, a true statement at
542 putesc(char const *s
, FILE *stream
)
547 while (s
[0] != '\0') {
550 if (putc('\t', stream
) == EOF
)
557 if (putc('\n', stream
) == EOF
)
564 if (putc(s
[0], stream
) == EOF
)
569 if (putc('\n', stream
) == EOF
)
578 a_coll__hook_setter(void *arg
){ /* TODO v15: drop */
585 if((val
= detract(hp
->h_from
, GNAMEONLY
)) == NULL
)
587 ok_vset(compose_from
, val
);
588 if((val
= detract(hp
->h_sender
, 0)) == NULL
)
590 ok_vset(compose_sender
, val
);
591 if((val
= detract(hp
->h_to
, GNAMEONLY
)) == NULL
)
593 ok_vset(compose_to
, val
);
594 if((val
= detract(hp
->h_cc
, GNAMEONLY
)) == NULL
)
596 ok_vset(compose_cc
, val
);
597 if((val
= detract(hp
->h_bcc
, GNAMEONLY
)) == NULL
)
599 ok_vset(compose_bcc
, val
);
600 if((val
= hp
->h_subject
) == NULL
)
602 ok_vset(compose_subject
, val
);
607 collect(struct header
*hp
, int printheaders
, struct message
*mp
,
608 char *quotefile
, int doprefix
, si8_t
*checkaddr_err
)
610 struct ignoretab
*quoteig
;
613 int volatile escape
, getfields
;
616 size_t i
, linesize
; /* TODO line pool */
618 enum sendaction action
;
620 FILE * volatile sigfp
;
628 /* Start catching signals from here, but we're still die on interrupts
629 * until we're in the main loop */
631 sigprocmask(SIG_BLOCK
, &nset
, &oset
);
632 /* FIXME have dropped handlerpush() and localized onintr() in lex.c! */
633 if ((_coll_saveint
= safe_signal(SIGINT
, SIG_IGN
)) != SIG_IGN
)
634 safe_signal(SIGINT
, &_collint
);
635 if ((_coll_savehup
= safe_signal(SIGHUP
, SIG_IGN
)) != SIG_IGN
)
636 safe_signal(SIGHUP
, collhup
);
637 if (sigsetjmp(_coll_abort
, 1))
639 if (sigsetjmp(_coll_jmp
, 1))
641 pstate
|= PS_RECURSED
;
642 sigprocmask(SIG_SETMASK
, &oset
, (sigset_t
*)NULL
);
645 if ((_coll_fp
= Ftmp(NULL
, "collect", OF_RDWR
| OF_UNLINK
| OF_REGISTER
)) ==
647 n_perr(_("temporary mail file"), 0);
651 /* If we are going to prompt for a subject, refrain from printing a newline
652 * after the headers (since some people mind) */
654 if (!(options
& OPT_t_FLAG
)) {
655 t
= GTO
| GSUBJECT
| GCC
| GNL
;
656 if (ok_blook(fullnames
))
659 if (options
& OPT_INTERACTIVE
) {
660 if (hp
->h_subject
== NULL
&& (ok_blook(ask
) || ok_blook(asksub
)))
661 t
&= ~GNL
, getfields
|= GSUBJECT
;
663 if (hp
->h_to
== NULL
)
664 t
&= ~GNL
, getfields
|= GTO
;
666 if (!ok_blook(bsdcompat
) && !ok_blook(askatend
)) {
667 if (hp
->h_bcc
== NULL
&& ok_blook(askbcc
))
668 t
&= ~GNL
, getfields
|= GBCC
;
669 if (hp
->h_cc
== NULL
&& ok_blook(askcc
))
670 t
&= ~GNL
, getfields
|= GCC
;
677 escape
= ((cp
= ok_vlook(escape
)) != NULL
) ? *cp
: ESCAPE
;
680 if (!sigsetjmp(_coll_jmp
, 1)) {
681 /* Ask for some headers first, as necessary */
683 grab_headers(n_LEXINPUT_CTX_COMPOSE
, hp
, getfields
, 1);
685 /* Execute compose-enter TODO completely v15-compat intermediate!! */
686 if((cp
= ok_vlook(on_compose_enter
)) != NULL
){
687 setup_from_and_sender(hp
);
688 call_compose_mode_hook(cp
, &a_coll__hook_setter
, hp
);
691 if(!(options
& OPT_Mm_FLAG
)){
692 char const *cp_obsolete
= ok_vlook(NAIL_HEAD
);
693 if(cp_obsolete
!= NULL
)
694 OBSOLETE(_("please use *message-inject-head* "
695 "instead of *NAIL_HEAD*"));
697 if(((cp
= ok_vlook(message_inject_head
)) != NULL
||
698 (cp
= cp_obsolete
) != NULL
) && putesc(cp
, _coll_fp
) < 0)
701 /* Quote an original message */
702 if (mp
!= NULL
&& (doprefix
|| (cp
= ok_vlook(quote
)) != NULL
)) {
707 if ((cp
= ok_vlook(fwdheading
)) == NULL
)
708 cp
= "-------- Original Message --------";
709 if (*cp
!= '\0' && fprintf(_coll_fp
, "%s\n", cp
) < 0)
711 } else if (!strcmp(cp
, "noheading")) {
713 } else if (!strcmp(cp
, "headers")) {
715 } else if (!strcmp(cp
, "allheaders")) {
717 action
= SEND_QUOTE_ALL
;
719 cp
= hfield1("from", mp
);
720 if (cp
!= NULL
&& (cnt
= (long)strlen(cp
)) > 0) {
721 if (xmime_write(cp
, cnt
, _coll_fp
, CONV_FROMHDR
, TD_NONE
) < 0)
723 if (fprintf(_coll_fp
, _(" wrote:\n\n")) < 0)
727 if (fflush(_coll_fp
))
731 else if ((cp
= ok_vlook(indentprefix
)) == NULL
)
733 if (sendmp(mp
, _coll_fp
, quoteig
, cp
, action
, NULL
) < 0)
738 if (quotefile
!= NULL
) {
739 if (_include_file(quotefile
, &lc
, &cc
,
740 !(options
& OPT_Mm_FLAG
), FAL0
) != 0)
744 if ((options
& (OPT_Mm_FLAG
| OPT_INTERACTIVE
)) == OPT_INTERACTIVE
) {
745 /* Print what we have sofar also on the terminal (if useful) */
746 if (!ok_blook(editalong
)) {
748 puthead(TRU1
, hp
, stdout
, t
, SEND_TODISP
, CONV_NONE
, NULL
, NULL
);
751 while ((c
= getc(_coll_fp
)) != EOF
) /* XXX bytewise, yuck! */
753 if (fseek(_coll_fp
, 0, SEEK_END
))
756 /* Ensure this is clean xxx not really necessary? */
761 /* As mandated by the Mail Reference Manual, print "(continue)" */
763 if(options
& OPT_INTERACTIVE
){
764 printf(_("(continue)\n"));
770 /* Come here for printing the after-signal message. Duplicate messages
771 * won't be printed because the write is aborted if we get a SIGTTOU */
773 n_err(_("\n(Interrupt -- one more to kill letter)\n"));
776 /* We're done with -M or -m */
777 if(options
& OPT_Mm_FLAG
)
779 /* No tilde escapes, interrupts not expected. Simply copy STDIN */
780 if (!(options
& (OPT_INTERACTIVE
| OPT_t_FLAG
| OPT_TILDE_FLAG
))) {
781 linebuf
= srealloc(linebuf
, linesize
= LINESIZE
);
782 while ((i
= fread(linebuf
, sizeof *linebuf
, linesize
, stdin
)) > 0) {
783 if (i
!= fwrite(linebuf
, sizeof *linebuf
, i
, _coll_fp
))
789 /* The interactive collect loop.
790 * All commands which come here are forbidden when sourcing! */
791 assert(_coll_hadintr
|| !(pstate
& PS_SOURCING
));
794 enum n_lexinput_flags lif
;
796 lif
= n_LEXINPUT_CTX_COMPOSE
;
797 if(options
& (OPT_INTERACTIVE
| OPT_TILDE_FLAG
)){
798 if(!(options
& OPT_t_FLAG
))
799 lif
|= n_LEXINPUT_NL_ESC
;
801 cnt
= n_lex_input(lif
, "", &linebuf
, &linesize
, NULL
);
805 assert(!(pstate
& PS_SOURCING
));
806 if (options
& OPT_t_FLAG
) {
807 fflush_rewind(_coll_fp
);
808 /* It is important to set PS_t_FLAG before extract_header() *and*
809 * keep OPT_t_FLAG for the first parse of the message, too! */
811 if (makeheader(_coll_fp
, hp
, checkaddr_err
) != OKAY
)
813 options
&= ~OPT_t_FLAG
;
815 } else if ((options
& OPT_INTERACTIVE
) && ok_blook(ignoreeof
)) {
816 printf(_("*ignoreeof* set, use `~.' to terminate letter\n"));
827 else if(!(options
& (OPT_INTERACTIVE
| OPT_TILDE_FLAG
)))
829 else if(cp
[0] == '.'){
830 if(cnt
== 1 && (ok_blook(dot
) || ok_blook(ignoreeof
)))
835 if(fwrite(cp
, sizeof *cp
, cnt
, _coll_fp
) != (size_t)cnt
)
837 /* TODO PS_READLINE_NL is a terrible hack to ensure that _in_all_-
838 * TODO _code_paths_ a file without trailing newline isn't modified
839 * TODO to continue one; the "saw-newline" needs to be part of an
840 * TODO I/O input machinery object */
842 if(pstate
& PS_READLINE_NL
){
843 if(putc('\n', _coll_fp
) == EOF
)
849 /* Cleanup the input string: like this we can perform a little bit of
850 * usage testing and also have somewhat normalized history entries */
851 for(cp
= &linebuf
[2]; (c
= *cp
) != '\0' && blankspacechar(c
); ++cp
)
857 i
= PTR2SIZE(cp
- linebuf
) - 3;
858 memmove(&linebuf
[3], cp
, (cnt
-= i
));
862 while(*cp
!= '\0') /* TODO trailing WS from lex_input */
866 if(!blankspacechar(c
))
869 ((char*)UNCONST(cp
))[0] = '\0';
870 cnt
= PTR2SIZE(cp
- linebuf
);
873 switch((c
= linebuf
[1])){
875 /* On double escape, send a single one. Otherwise, it's an error */
881 n_err(_("Unknown tilde escape: ~%c\n"), asciichar(c
) ? c
: '?');
884 n_err(_("Invalid tilde escape usage: %s\n"), linebuf
);
887 /* Shell escape, send the balance of line to sh -c */
890 c_shell(&linebuf
[3]);
895 /* Escape to command mode, but be nice! *//* TODO command expansion
896 * TODO should be handled here so that we have unique history! */
899 _execute_command(hp
, &linebuf
[3], cnt
-= 3);
902 /* Simulate end of file on input */
907 /* Same as 'q', but no *DEAD* saving */
910 /* Force a quit, act like an interrupt had happened */
914 _collint((c
== 'x') ? 0 : SIGINT
);
918 /* Grab a bunch of headers */
922 grab_headers(n_LEXINPUT_CTX_COMPOSE
, hp
,
923 (GTO
| GSUBJECT
| GCC
| GBCC
),
924 (ok_blook(bsdcompat
) && ok_blook(bsdorder
)));
925 while(hp
->h_to
== NULL
);
928 /* Grab extra headers */
932 grab_headers(n_LEXINPUT_CTX_COMPOSE
, hp
, GEXTRA
, 0);
933 while(check_from_and_sender(hp
->h_from
, hp
->h_sender
) == NULL
);
936 /* Add to the To: list */
939 hp
->h_to
= cat(hp
->h_to
,
940 checkaddrs(lextract(&linebuf
[3], GTO
| GFULL
), EACM_NORMAL
,
944 /* Set the Subject list */
947 hp
->h_subject
= savestr(&linebuf
[3]);
949 #ifdef HAVE_MEMORY_DEBUG
957 /* Edit the attachment list */
959 append_attachments(n_LEXINPUT_CTX_COMPOSE
, &hp
->h_attach
,
962 edit_attachments(n_LEXINPUT_CTX_COMPOSE
, &hp
->h_attach
);
965 /* Add to the CC list */
968 hp
->h_cc
= cat(hp
->h_cc
,
969 checkaddrs(lextract(&linebuf
[3], GCC
| GFULL
), EACM_NORMAL
,
973 /* Add stuff to blind carbon copies list */
976 hp
->h_bcc
= cat(hp
->h_bcc
,
977 checkaddrs(lextract(&linebuf
[3], GBCC
| GFULL
), EACM_NORMAL
,
983 cp
= n_getdeadletter();
989 /* Invoke a file: Search for the file name, then open it and copy
990 * the contents to _coll_fp */
992 n_err(_("Interpolate what file?\n"));
995 if(*(cp
= &linebuf
[3]) == '!'){
996 insertcommand(_coll_fp
, ++cp
);
999 if((cp
= file_expand(cp
)) == NULL
)
1003 n_err(_("%s: is a directory\n"), n_shexp_quote_cp(cp
, FAL0
));
1006 if(_include_file(cp
, &lc
, &cc
, FAL0
, (c
== 'R')) != 0){
1007 if(ferror(_coll_fp
))
1011 printf(_("%s %d/%d\n"), n_shexp_quote_cp(cp
, FAL0
), lc
, cc
);
1014 /* Insert a variable into the file */
1017 if((cp
= vok_vlook(&linebuf
[3])) == NULL
|| *cp
== '\0')
1019 if(putesc(cp
, _coll_fp
) < 0) /* TODO v15: user resp upon `set' time */
1021 if((options
& OPT_INTERACTIVE
) && putesc(cp
, stdout
) < 0)
1026 /* Insert the contents of a signature variable */
1029 cp
= (c
== 'a') ? ok_vlook(sign
) : ok_vlook(Sign
);
1030 if(cp
!= NULL
&& *cp
!= '\0'){
1031 if(putesc(cp
, _coll_fp
) < 0) /* TODO v15: user upon `set' time */
1033 if((options
& OPT_INTERACTIVE
) && putesc(cp
, stdout
) < 0)
1038 /* Write the message on a file */
1041 if((cp
= file_expand(&linebuf
[3])) == NULL
){
1042 n_err(_("Write what file!?\n"));
1046 if(exwrite(cp
, _coll_fp
, 1) < 0)
1055 /* Interpolate the named messages, if we are in receiving mail mode.
1056 * Does the standard list processing garbage. If ~f is given, we
1057 * don't shift over */
1060 if(forward(&linebuf
[3], _coll_fp
, c
) < 0)
1064 /* Print current state of the message without altering anything */
1067 print_collf(_coll_fp
, hp
);
1070 /* Pipe message through command. Collect output as new message */
1074 mespipe(&linebuf
[3]);
1078 /* Edit the current message. 'e' -> use EDITOR, 'v' -> use VISUAL */
1082 mesedit(c
, ok_blook(editheaders
) ? hp
: NULL
);
1085 /* Last the lengthy help string. (Very ugly, but take care for
1086 * compiler supported string lengths :() */
1088 "TILDE ESCAPES (to be placed after a newline) excerpt:\n"
1089 "~. Commit and send message\n"
1090 "~: <command> Execute a mail command\n"
1091 "~<! <command> Insert output of command\n"
1092 "~@ [<files>] Edit attachment list\n"
1093 "~A Insert *Sign* variable (`~a' inserts *sign*)\n"
1094 "~c <users> Add users to Cc: list (`~b' for Bcc:)\n"
1095 "~d Read in *DEAD* (dead.letter)\n"
1096 "~e Edit message via *EDITOR*"
1099 "~F <msglist> Read in with headers, don't *indentprefix* lines\n"
1100 "~f <msglist> Like ~F, but honour `ignore' / `retain' configuration\n"
1101 "~H Edit From:, Reply-To: and Sender:\n"
1102 "~h Prompt for Subject:, To:, Cc: and blind Bcc:\n"
1103 "~i <variable> Insert a value and a newline\n"
1104 "~M <msglist> Read in with headers, *indentprefix* (`~m': `retain' etc.)\n"
1105 "~p Print current message compose buffer\n"
1106 "~r <file> Read in a file (`~R' *indentprefix* lines)"
1109 "~s <subject> Set Subject:\n"
1110 "~t <users> Add users to To: list\n"
1111 "~u <msglist> Read in message(s) without headers (`~U' indents lines)\n"
1112 "~v Edit message via *VISUAL*\n"
1113 "~w <file> Write message onto file\n"
1114 "~x Abort composition, discard message (`~q' saves in *DEAD*)\n"
1115 "~| <command> Pipe message through shell filter"
1122 /* Finally place an entry in history as applicable */
1128 if(!(options
& OPT_t_FLAG
))
1129 n_tty_addhist(linebuf
, TRU1
);
1135 /* Execute compose-leave TODO completely v15-compat intermediate!! */
1136 if((cp
= ok_vlook(on_compose_leave
)) != NULL
){
1137 setup_from_and_sender(hp
);
1138 call_compose_mode_hook(cp
, &a_coll__hook_setter
, hp
);
1141 /* Final change to edit headers, if not already above */
1142 if (ok_blook(bsdcompat
) || ok_blook(askatend
)) {
1143 if (hp
->h_cc
== NULL
&& ok_blook(askcc
))
1144 grab_headers(n_LEXINPUT_CTX_COMPOSE
, hp
, GCC
, 1);
1145 if (hp
->h_bcc
== NULL
&& ok_blook(askbcc
))
1146 grab_headers(n_LEXINPUT_CTX_COMPOSE
, hp
, GBCC
, 1);
1148 if (hp
->h_attach
== NULL
&& ok_blook(askattach
))
1149 edit_attachments(n_LEXINPUT_CTX_COMPOSE
, &hp
->h_attach
);
1151 /* Add automatic receivers */
1152 if ((cp
= ok_vlook(autocc
)) != NULL
&& *cp
!= '\0')
1153 hp
->h_cc
= cat(hp
->h_cc
, checkaddrs(lextract(cp
, GCC
| GFULL
),
1154 EACM_NORMAL
, checkaddr_err
));
1155 if ((cp
= ok_vlook(autobcc
)) != NULL
&& *cp
!= '\0')
1156 hp
->h_bcc
= cat(hp
->h_bcc
, checkaddrs(lextract(cp
, GBCC
| GFULL
),
1157 EACM_NORMAL
, checkaddr_err
));
1158 if (*checkaddr_err
!= 0)
1161 if(options
& OPT_Mm_FLAG
)
1164 /* Place signature? */
1165 if((cp
= ok_vlook(signature
)) != NULL
&& *cp
!= '\0'){
1168 if((cpq
= file_expand(cp
)) == NULL
){
1169 n_err(_("*signature* expands to invalid file: %s\n"),
1170 n_shexp_quote_cp(cp
, FAL0
));
1173 cpq
= n_shexp_quote_cp(cp
= cpq
, FAL0
);
1175 if((sigfp
= Fopen(cp
, "r")) == NULL
){
1176 n_err(_("Can't open *signature* %s: %s\n"), cpq
, strerror(errno
));
1181 linebuf
= smalloc(linesize
= LINESIZE
);
1183 while((i
= fread(linebuf
, sizeof *linebuf
, linesize
, UNVOLATILE(sigfp
)))
1186 if(i
!= fwrite(linebuf
, sizeof *linebuf
, i
, _coll_fp
))
1191 FILE *x
= UNVOLATILE(sigfp
);
1192 int e
= errno
, ise
= ferror(x
);
1198 n_err(_("Errors while reading *signature* %s: %s\n"),
1204 if(c
!= '\0' && c
!= '\n')
1205 putc('\n', _coll_fp
);
1208 { char const *cp_obsolete
= ok_vlook(NAIL_TAIL
);
1210 if(cp_obsolete
!= NULL
)
1211 OBSOLETE(_("please use *message-inject-tail* instead of *NAIL_TAIL*"));
1213 if((cp
= ok_vlook(message_inject_tail
)) != NULL
||
1214 (cp
= cp_obsolete
) != NULL
){
1215 if(putesc(cp
, _coll_fp
) < 0)
1217 if((options
& OPT_INTERACTIVE
) && putesc(cp
, stdout
) < 0)
1223 if(fflush(_coll_fp
))
1228 if (linebuf
!= NULL
)
1232 sigprocmask(SIG_BLOCK
, &nset
, NULL
);
1233 pstate
&= ~PS_RECURSED
;
1234 safe_signal(SIGINT
, _coll_saveint
);
1235 safe_signal(SIGHUP
, _coll_savehup
);
1236 sigprocmask(SIG_SETMASK
, &oset
, NULL
);
1242 Fclose(UNVOLATILE(sigfp
));
1243 if (_coll_fp
!= NULL
) {