Separated send from whatnow, similar to the previous commit.
[mmh] / uip / send.c
1 /*
2 ** send.c -- send a composed message
3 **
4 ** This code is Copyright (c) 2002, by the authors of nmh.  See the
5 ** COPYRIGHT file in the root directory of the nmh distribution for
6 ** complete copyright information.
7 */
8
9 #include <h/mh.h>
10 #include <fcntl.h>
11 #include <errno.h>
12 #include <signal.h>
13
14
15 static struct swit switches[] = {
16 #define ALIASW  0
17         { "alias aliasfile", 0 },
18 #define DEBUGSW  1
19         { "debug", -5 },
20 #define FILTSW  2
21         { "filter filterfile", 0 },
22 #define NFILTSW  3
23         { "nofilter", 0 },
24 #define FRMTSW  4
25         { "format", 0 },
26 #define NFRMTSW  5
27         { "noformat", 0 },
28 #define FORWSW  6
29         { "forward", 0 },
30 #define NFORWSW  7
31         { "noforward", 0 },
32 #define PUSHSW  8
33         { "push", 0 },
34 #define NPUSHSW  9
35         { "nopush", 0 },
36 #define VERBSW  10
37         { "verbose", 0 },
38 #define NVERBSW  11
39         { "noverbose", 0 },
40 #define WATCSW  12
41         { "watch", 0 },
42 #define NWATCSW  13
43         { "nowatch", 0 },
44 #define VERSIONSW  14
45         { "version", 0 },
46 #define HELPSW  15
47         { "help", 0 },
48         { NULL, 0 }
49 };
50
51 extern int debugsw;  /* from sendsbr.c */
52 extern int forwsw;
53 extern int inplace;
54 extern int pushsw;
55 extern int verbsw;
56
57 extern char *altmsg;  /*  .. */
58 extern char *annotext;
59 extern char *distfile;
60
61
62 int
63 main(int argc, char **argv)
64 {
65         int msgp = 0, msgp2 = 0, distsw = 0, vecp = 1;
66         int msgnum, status;
67         char *cp, *maildir = NULL;
68         char buf[BUFSIZ], **ap, **argp, **arguments;
69         char *msgs[MAXARGS], *vec[MAXARGS];
70         char *msgs2[MAXARGS];
71         struct msgs *mp;
72         struct stat st;
73
74 #ifdef LOCALE
75         setlocale(LC_ALL, "");
76 #endif
77         invo_name = mhbasename(argv[0]);
78
79         /* read user profile/context */
80         context_read();
81
82         arguments = getarguments(invo_name, argc, argv, 1);
83         argp = arguments;
84
85         vec[vecp++] = "-library";
86         vec[vecp++] = getcpy(toabsdir("+"));
87
88         while ((cp = *argp++)) {
89                 if (*cp == '-') {
90                         switch (smatch(++cp, switches)) {
91                         case AMBIGSW:
92                                 ambigsw(cp, switches);
93                                 done(1);
94                         case UNKWNSW:
95                                 adios(NULL, "-%s unknown\n", cp);
96
97                         case HELPSW:
98                                 snprintf(buf, sizeof(buf),
99                                                 "%s [file] [switches]",
100                                                 invo_name);
101                                 print_help(buf, switches, 1);
102                                 done(1);
103                         case VERSIONSW:
104                                 print_version(invo_name);
105                                 done(1);
106
107                         case PUSHSW:
108                                 pushsw++;
109                                 continue;
110                         case NPUSHSW:
111                                 pushsw = 0;
112                                 continue;
113
114                         case FORWSW:
115                                 forwsw++;
116                                 continue;
117                         case NFORWSW:
118                                 forwsw = 0;
119                                 continue;
120
121                         case VERBSW:
122                                 verbsw++;
123                                 vec[vecp++] = --cp;
124                                 continue;
125                         case NVERBSW:
126                                 verbsw = 0;
127                                 vec[vecp++] = --cp;
128                                 continue;
129
130                         case DEBUGSW:
131                                 debugsw++;  /* fall */
132                         case NFILTSW:
133                         case FRMTSW:
134                         case NFRMTSW:
135                         case WATCSW:
136                         case NWATCSW:
137                                 vec[vecp++] = --cp;
138                                 continue;
139
140                         case ALIASW:
141                         case FILTSW:
142                                 vec[vecp++] = --cp;
143                                 if (!(cp = *argp++) || *cp == '-')
144                                         adios(NULL, "missing argument to %s",
145                                                         argp[-2]);
146                                 vec[vecp++] = cp;
147                                 continue;
148
149                         }
150                 } else {
151                         msgs[msgp++] = cp;
152                 }
153         }
154
155         /*
156         ** check for "Aliasfile:" profile entry
157         */
158         if ((cp = context_find("Aliasfile"))) {
159                 char *dp = NULL;
160
161                 for (ap = brkstring(dp = getcpy(cp), " ", "\n"); ap && *ap;
162                                 ap++) {
163                         vec[vecp++] = "-alias";
164                         vec[vecp++] = getcpy(etcpath(*ap));
165                 }
166         }
167
168         if (!msgp)
169                 msgs[msgp++] = seq_cur;
170         maildir = toabsdir(draftfolder);
171
172         if (chdir(maildir) == NOTOK)
173                 adios(maildir, "unable to change directory to");
174
175         /* read folder and create message structure */
176         if (!(mp = folder_read(draftfolder)))
177                 adios(NULL, "unable to read draft folder %s", draftfolder);
178
179         /* check for empty folder */
180         if (mp->nummsg == 0)
181                 adios(NULL, "no messages in draft folder %s", draftfolder);
182
183         /* parse all the message ranges/sequences and set SELECTED */
184         msgp2 = 0;
185         for (msgnum = 0; msgnum < msgp; msgnum++) {
186                 if (*msgs[msgnum] == '/') {
187                         /* absolute path */
188                         msgs2[msgp2++] = msgs[msgnum];
189                         continue;
190                 }
191                 if (!m_convert(mp, msgs[msgnum])) {
192                         done(1);
193                 }
194         }
195         seq_setprev(mp);  /* set the previous-sequence */
196
197         for (msgp = 0, msgnum = mp->lowsel; msgnum <= mp->hghsel; msgnum++) {
198                 if (is_selected(mp, msgnum)) {
199                         msgs2[msgp2++] = getcpy(m_name(msgnum));
200                         unset_exists(mp, msgnum);
201                 }
202         }
203
204         mp->msgflags |= SEQMOD;
205         seq_save(mp);
206
207         if (!(cp = getenv("SIGNATURE")) || !*cp)
208                 if ((cp = context_find("signature")) && *cp)
209                         m_putenv("SIGNATURE", cp);
210
211         for (msgnum = 0; msgnum < msgp2; msgnum++)
212                 if (stat(msgs2[msgnum], &st) == NOTOK)
213                         adios(msgs2[msgnum], "unable to stat draft file");
214
215         if ((annotext = getenv("mhannotate")) == NULL || *annotext == 0)
216                 annotext = NULL;
217         if (annotext && ((cp = getenv("mhinplace")) != NULL && *cp != 0))
218                 inplace = atoi(cp);
219         if ((altmsg = getenv("mhaltmsg")) == NULL || *altmsg == 0)
220                 altmsg = NULL;  /* used by dist interface - see below */
221
222         if ((cp = getenv("mhdist")) && *cp && (distsw = atoi (cp)) && altmsg) {
223                 vec[vecp++] = "-dist";
224                 distfile = getcpy(m_mktemp2(altmsg, invo_name, NULL, NULL));
225                 if (link(altmsg, distfile) == NOTOK) {
226                         if (errno != EXDEV)
227                                 adios(distfile, "unable to link %s to",
228                                                 altmsg);
229                         free(distfile);
230                         distfile = getcpy(m_mktemp2(NULL, invo_name,
231                                         NULL, NULL));
232                         {
233                                 int in, out;
234                                 struct stat st;
235
236                                 if ((in = open(altmsg, O_RDONLY)) == NOTOK)
237                                         adios(altmsg, "unable to open");
238                                 fstat(in, &st);
239                                 if ((out = creat(distfile,
240                                                 (int) st.st_mode & 0777))
241                                                 == NOTOK)
242                                         adios(distfile, "unable to write");
243                                 cpydata(in, out, altmsg, distfile);
244                                 close(in);
245                                 close(out);
246                         }
247                 }
248         } else {
249                 distfile = NULL;
250         }
251
252         if (altmsg == NULL || stat(altmsg, &st) == NOTOK) {
253                 st.st_mtime = 0;
254                 st.st_dev = 0;
255                 st.st_ino = 0;
256         }
257         if (pushsw)
258                 push();
259
260         status = 0;
261         vec[0] = mhbasename(postproc);
262         closefds(3);
263
264         for (msgnum = 0; msgnum < msgp2; msgnum++) {
265                 switch (sendsbr(vec, vecp, msgs2[msgnum], &st, 1)) {
266                 case DONE:
267                         done(++status);
268                 case NOTOK:
269                         status++;  /* fall */
270                 case OK:
271                         break;
272                 }
273         }
274
275         context_save();  /* save the context file */
276         done(status);
277         return 1;
278 }