msgs.c revision 1.17 1 1.17 mjl /* $NetBSD: msgs.c,v 1.17 2001/07/01 00:20:47 mjl Exp $ */
2 1.7 tls
3 1.1 cgd /*-
4 1.7 tls * Copyright (c) 1980, 1993
5 1.7 tls * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * Redistribution and use in source and binary forms, with or without
8 1.1 cgd * modification, are permitted provided that the following conditions
9 1.1 cgd * are met:
10 1.1 cgd * 1. Redistributions of source code must retain the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer.
12 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 cgd * notice, this list of conditions and the following disclaimer in the
14 1.1 cgd * documentation and/or other materials provided with the distribution.
15 1.1 cgd * 3. All advertising materials mentioning features or use of this software
16 1.1 cgd * must display the following acknowledgement:
17 1.1 cgd * This product includes software developed by the University of
18 1.1 cgd * California, Berkeley and its contributors.
19 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
20 1.1 cgd * may be used to endorse or promote products derived from this software
21 1.1 cgd * without specific prior written permission.
22 1.1 cgd *
23 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
24 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
25 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
26 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
28 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
29 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
30 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
32 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
33 1.1 cgd * SUCH DAMAGE.
34 1.1 cgd */
35 1.1 cgd
36 1.10 lukem #include <sys/cdefs.h>
37 1.1 cgd #ifndef lint
38 1.10 lukem __COPYRIGHT("@(#) Copyright (c) 1980, 1993\n\
39 1.10 lukem The Regents of the University of California. All rights reserved.\n");
40 1.1 cgd #endif /* not lint */
41 1.1 cgd
42 1.1 cgd #ifndef lint
43 1.7 tls #if 0
44 1.7 tls static char sccsid[] = "@(#)msgs.c 8.2 (Berkeley) 4/28/95";
45 1.7 tls #else
46 1.17 mjl __RCSID("$NetBSD: msgs.c,v 1.17 2001/07/01 00:20:47 mjl Exp $");
47 1.7 tls #endif
48 1.1 cgd #endif /* not lint */
49 1.1 cgd
50 1.1 cgd /*
51 1.1 cgd * msgs - a user bulletin board program
52 1.1 cgd *
53 1.1 cgd * usage:
54 1.5 mycroft * msgs [fhlopqr] [[-]number] to read messages
55 1.1 cgd * msgs -s to place messages
56 1.1 cgd * msgs -c [-days] to clean up the bulletin board
57 1.1 cgd *
58 1.1 cgd * prompt commands are:
59 1.1 cgd * y print message
60 1.1 cgd * n flush message, go to next message
61 1.1 cgd * q flush message, quit
62 1.1 cgd * p print message, turn on 'pipe thru more' mode
63 1.1 cgd * P print message, turn off 'pipe thru more' mode
64 1.1 cgd * - reprint last message
65 1.1 cgd * s[-][<num>] [<filename>] save message
66 1.1 cgd * m[-][<num>] mail with message in temp mbox
67 1.1 cgd * x exit without flushing this message
68 1.1 cgd * <num> print message number <num>
69 1.1 cgd */
70 1.1 cgd
71 1.1 cgd #define V7 /* will look for TERM in the environment */
72 1.1 cgd #define OBJECT /* will object to messages without Subjects */
73 1.10 lukem #define REJECT /* will reject messages without Subjects
74 1.1 cgd (OBJECT must be defined also) */
75 1.10 lukem /*#define UNBUFFERED */ /* use unbuffered output */
76 1.1 cgd
77 1.1 cgd #include <sys/param.h>
78 1.7 tls #include <sys/ioctl.h>
79 1.1 cgd #include <sys/stat.h>
80 1.14 mrg
81 1.10 lukem #include <ctype.h>
82 1.4 jtc #include <dirent.h>
83 1.14 mrg #include <err.h>
84 1.1 cgd #include <errno.h>
85 1.1 cgd #include <pwd.h>
86 1.1 cgd #include <setjmp.h>
87 1.1 cgd #include <signal.h>
88 1.1 cgd #include <stdio.h>
89 1.1 cgd #include <stdlib.h>
90 1.1 cgd #include <string.h>
91 1.10 lukem #include <termcap.h>
92 1.7 tls #include <termios.h>
93 1.1 cgd #include <time.h>
94 1.6 cgd #include <unistd.h>
95 1.14 mrg
96 1.1 cgd #include "pathnames.h"
97 1.1 cgd
98 1.6 cgd #define CMODE 0664 /* bounds file creation mode */
99 1.1 cgd #define NO 0
100 1.1 cgd #define YES 1
101 1.1 cgd #define SUPERUSER 0 /* superuser uid */
102 1.1 cgd #define DAEMON 1 /* daemon uid */
103 1.1 cgd #define NLINES 24 /* default number of lines/crt screen */
104 1.1 cgd #define NDAYS 21 /* default keep time for messages */
105 1.1 cgd #define DAYS *24*60*60 /* seconds/day */
106 1.1 cgd #define MSGSRC ".msgsrc" /* user's rc file */
107 1.1 cgd #define BOUNDS "bounds" /* message bounds file */
108 1.1 cgd #define NEXT "Next message? [yq]"
109 1.1 cgd #define MORE "More? [ynq]"
110 1.1 cgd #define NOMORE "(No more) [q] ?"
111 1.1 cgd
112 1.1 cgd typedef char bool;
113 1.1 cgd
114 1.1 cgd FILE *msgsrc;
115 1.1 cgd FILE *newmsg;
116 1.1 cgd char *sep = "-";
117 1.1 cgd char inbuf[BUFSIZ];
118 1.16 ad char fname[MAXPATHLEN];
119 1.16 ad char cmdbuf[MAXPATHLEN + 16];
120 1.1 cgd char subj[128];
121 1.1 cgd char from[128];
122 1.1 cgd char date[128];
123 1.1 cgd char *ptr;
124 1.1 cgd char *in;
125 1.1 cgd bool local;
126 1.1 cgd bool ruptible;
127 1.1 cgd bool totty;
128 1.1 cgd bool seenfrom;
129 1.1 cgd bool seensubj;
130 1.1 cgd bool blankline;
131 1.1 cgd bool printing = NO;
132 1.1 cgd bool mailing = NO;
133 1.1 cgd bool quitit = NO;
134 1.1 cgd bool sending = NO;
135 1.1 cgd bool intrpflg = NO;
136 1.7 tls bool restricted = NO;
137 1.1 cgd int uid;
138 1.1 cgd int msg;
139 1.1 cgd int prevmsg;
140 1.1 cgd int lct;
141 1.1 cgd int nlines;
142 1.1 cgd int Lpp = 0;
143 1.1 cgd time_t t;
144 1.1 cgd time_t keep;
145 1.1 cgd
146 1.10 lukem void ask __P((char *));
147 1.10 lukem void gfrsub __P((FILE *));
148 1.10 lukem int linecnt __P((FILE *));
149 1.10 lukem int main __P((int, char *[]));
150 1.10 lukem int next __P((char *));
151 1.10 lukem char *nxtfld __P((char *));
152 1.10 lukem void onintr __P((int));
153 1.10 lukem void onsusp __P((int));
154 1.10 lukem void prmesg __P((int));
155 1.1 cgd
156 1.1 cgd /* option initialization */
157 1.1 cgd bool hdrs = NO;
158 1.1 cgd bool qopt = NO;
159 1.1 cgd bool hush = NO;
160 1.1 cgd bool send_msg = NO;
161 1.1 cgd bool locomode = NO;
162 1.1 cgd bool use_pager = NO;
163 1.1 cgd bool clean = NO;
164 1.1 cgd bool lastcmd = NO;
165 1.1 cgd jmp_buf tstpbuf;
166 1.1 cgd
167 1.10 lukem int
168 1.1 cgd main(argc, argv)
169 1.10 lukem int argc; char *argv[];
170 1.1 cgd {
171 1.1 cgd bool newrc, already;
172 1.1 cgd int rcfirst = 0; /* first message to print (from .rc) */
173 1.1 cgd int rcback = 0; /* amount to back off of rcfirst */
174 1.1 cgd int firstmsg, nextmsg, lastmsg = 0;
175 1.1 cgd int blast = 0;
176 1.1 cgd FILE *bounds;
177 1.12 mycroft struct passwd *pw;
178 1.1 cgd
179 1.1 cgd #ifdef UNBUFFERED
180 1.1 cgd setbuf(stdout, NULL);
181 1.1 cgd #endif
182 1.1 cgd
183 1.1 cgd time(&t);
184 1.1 cgd setuid(uid = getuid());
185 1.1 cgd ruptible = (signal(SIGINT, SIG_IGN) == SIG_DFL);
186 1.1 cgd if (ruptible)
187 1.1 cgd signal(SIGINT, SIG_DFL);
188 1.1 cgd
189 1.1 cgd argc--, argv++;
190 1.1 cgd while (argc > 0) {
191 1.13 christos if (isdigit((unsigned char)argv[0][0])) {/* starting message # */
192 1.1 cgd rcfirst = atoi(argv[0]);
193 1.1 cgd }
194 1.13 christos else if (isdigit((unsigned char)argv[0][1])) {/* backward offset */
195 1.1 cgd rcback = atoi( &( argv[0][1] ) );
196 1.1 cgd }
197 1.1 cgd else {
198 1.1 cgd ptr = *argv;
199 1.1 cgd while (*ptr) switch (*ptr++) {
200 1.1 cgd
201 1.1 cgd case '-':
202 1.1 cgd break;
203 1.1 cgd
204 1.1 cgd case 'c':
205 1.1 cgd if (uid != SUPERUSER && uid != DAEMON) {
206 1.1 cgd fprintf(stderr, "Sorry\n");
207 1.1 cgd exit(1);
208 1.1 cgd }
209 1.1 cgd clean = YES;
210 1.1 cgd break;
211 1.1 cgd
212 1.1 cgd case 'f': /* silently */
213 1.1 cgd hush = YES;
214 1.1 cgd break;
215 1.1 cgd
216 1.1 cgd case 'h': /* headers only */
217 1.1 cgd hdrs = YES;
218 1.1 cgd break;
219 1.1 cgd
220 1.1 cgd case 'l': /* local msgs only */
221 1.1 cgd locomode = YES;
222 1.1 cgd break;
223 1.1 cgd
224 1.1 cgd case 'o': /* option to save last message */
225 1.1 cgd lastcmd = YES;
226 1.1 cgd break;
227 1.1 cgd
228 1.1 cgd case 'p': /* pipe thru 'more' during long msgs */
229 1.1 cgd use_pager = YES;
230 1.1 cgd break;
231 1.1 cgd
232 1.1 cgd case 'q': /* query only */
233 1.1 cgd qopt = YES;
234 1.1 cgd break;
235 1.1 cgd
236 1.7 tls case 'r': /* restricted */
237 1.7 tls restricted = YES;
238 1.7 tls break;
239 1.8 pk
240 1.5 mycroft
241 1.1 cgd case 's': /* sending TO msgs */
242 1.1 cgd send_msg = YES;
243 1.1 cgd break;
244 1.1 cgd
245 1.1 cgd default:
246 1.1 cgd fprintf(stderr,
247 1.17 mjl "usage: msgs [cfhlopqrs] [[-]number]\n");
248 1.1 cgd exit(1);
249 1.1 cgd }
250 1.1 cgd }
251 1.1 cgd argc--, argv++;
252 1.1 cgd }
253 1.1 cgd
254 1.1 cgd /*
255 1.1 cgd * determine current message bounds
256 1.1 cgd */
257 1.16 ad snprintf(fname, sizeof (fname), "%s/%s", _PATH_MSGS, BOUNDS);
258 1.1 cgd bounds = fopen(fname, "r");
259 1.1 cgd
260 1.1 cgd if (bounds != NULL) {
261 1.9 phil if (fscanf(bounds, "%d %d\n", &firstmsg, &lastmsg) < 2)
262 1.9 phil firstmsg = lastmsg = 0;
263 1.1 cgd fclose(bounds);
264 1.1 cgd blast = lastmsg; /* save upper bound */
265 1.1 cgd }
266 1.1 cgd
267 1.1 cgd if (clean)
268 1.1 cgd keep = t - (rcback? rcback : NDAYS) DAYS;
269 1.1 cgd
270 1.1 cgd if (clean || bounds == NULL) { /* relocate message bounds */
271 1.4 jtc struct dirent *dp;
272 1.1 cgd struct stat stbuf;
273 1.1 cgd bool seenany = NO;
274 1.1 cgd DIR *dirp;
275 1.1 cgd
276 1.1 cgd dirp = opendir(_PATH_MSGS);
277 1.1 cgd if (dirp == NULL) {
278 1.1 cgd perror(_PATH_MSGS);
279 1.1 cgd exit(errno);
280 1.1 cgd }
281 1.7 tls chmod(fname, CMODE);
282 1.1 cgd
283 1.1 cgd firstmsg = 32767;
284 1.1 cgd lastmsg = 0;
285 1.1 cgd
286 1.1 cgd for (dp = readdir(dirp); dp != NULL; dp = readdir(dirp)){
287 1.11 lukem char *cp = dp->d_name;
288 1.11 lukem int i = 0;
289 1.1 cgd
290 1.1 cgd if (dp->d_ino == 0)
291 1.1 cgd continue;
292 1.13 christos #ifndef __SVR4
293 1.1 cgd if (dp->d_namlen == 0)
294 1.1 cgd continue;
295 1.13 christos #endif
296 1.1 cgd
297 1.1 cgd if (clean)
298 1.16 ad snprintf(inbuf, sizeof (inbuf), "%s/%s",
299 1.16 ad _PATH_MSGS, cp);
300 1.1 cgd
301 1.13 christos while (isdigit((unsigned char)*cp))
302 1.1 cgd i = i * 10 + *cp++ - '0';
303 1.1 cgd if (*cp)
304 1.1 cgd continue; /* not a message! */
305 1.1 cgd
306 1.1 cgd if (clean) {
307 1.1 cgd if (stat(inbuf, &stbuf) != 0)
308 1.1 cgd continue;
309 1.1 cgd if (stbuf.st_mtime < keep
310 1.1 cgd && stbuf.st_mode&S_IWRITE) {
311 1.1 cgd unlink(inbuf);
312 1.1 cgd continue;
313 1.1 cgd }
314 1.1 cgd }
315 1.1 cgd
316 1.1 cgd if (i > lastmsg)
317 1.1 cgd lastmsg = i;
318 1.1 cgd if (i < firstmsg)
319 1.1 cgd firstmsg = i;
320 1.1 cgd seenany = YES;
321 1.1 cgd }
322 1.1 cgd closedir(dirp);
323 1.1 cgd
324 1.1 cgd if (!seenany) {
325 1.1 cgd if (blast != 0) /* never lower the upper bound! */
326 1.1 cgd lastmsg = blast;
327 1.1 cgd firstmsg = lastmsg + 1;
328 1.1 cgd }
329 1.1 cgd else if (blast > lastmsg)
330 1.1 cgd lastmsg = blast;
331 1.1 cgd
332 1.1 cgd if (!send_msg) {
333 1.1 cgd bounds = fopen(fname, "w");
334 1.1 cgd if (bounds == NULL) {
335 1.1 cgd perror(fname);
336 1.1 cgd exit(errno);
337 1.1 cgd }
338 1.1 cgd chmod(fname, CMODE);
339 1.1 cgd fprintf(bounds, "%d %d\n", firstmsg, lastmsg);
340 1.1 cgd fclose(bounds);
341 1.1 cgd }
342 1.1 cgd }
343 1.1 cgd
344 1.1 cgd if (send_msg) {
345 1.1 cgd /*
346 1.1 cgd * Send mode - place msgs in _PATH_MSGS
347 1.1 cgd */
348 1.1 cgd bounds = fopen(fname, "w");
349 1.1 cgd if (bounds == NULL) {
350 1.1 cgd perror(fname);
351 1.1 cgd exit(errno);
352 1.1 cgd }
353 1.1 cgd
354 1.1 cgd nextmsg = lastmsg + 1;
355 1.16 ad snprintf(fname, sizeof (fname), "%s/%d", _PATH_MSGS, nextmsg);
356 1.1 cgd newmsg = fopen(fname, "w");
357 1.1 cgd if (newmsg == NULL) {
358 1.1 cgd perror(fname);
359 1.1 cgd exit(errno);
360 1.1 cgd }
361 1.1 cgd chmod(fname, 0644);
362 1.1 cgd
363 1.1 cgd fprintf(bounds, "%d %d\n", firstmsg, nextmsg);
364 1.1 cgd fclose(bounds);
365 1.1 cgd
366 1.1 cgd sending = YES;
367 1.1 cgd if (ruptible)
368 1.1 cgd signal(SIGINT, onintr);
369 1.1 cgd
370 1.1 cgd if (isatty(fileno(stdin))) {
371 1.12 mycroft pw = getpwuid(uid);
372 1.12 mycroft if (!pw) {
373 1.12 mycroft fprintf(stderr, "Who are you?\n");
374 1.12 mycroft exit(1);
375 1.12 mycroft }
376 1.1 cgd printf("Message %d:\nFrom %s %sSubject: ",
377 1.12 mycroft nextmsg, pw->pw_name, ctime(&t));
378 1.1 cgd fflush(stdout);
379 1.1 cgd fgets(inbuf, sizeof inbuf, stdin);
380 1.1 cgd putchar('\n');
381 1.1 cgd fflush(stdout);
382 1.1 cgd fprintf(newmsg, "From %s %sSubject: %s\n",
383 1.1 cgd ptr, ctime(&t), inbuf);
384 1.1 cgd blankline = seensubj = YES;
385 1.1 cgd }
386 1.1 cgd else
387 1.1 cgd blankline = seensubj = NO;
388 1.1 cgd for (;;) {
389 1.1 cgd fgets(inbuf, sizeof inbuf, stdin);
390 1.1 cgd if (feof(stdin) || ferror(stdin))
391 1.1 cgd break;
392 1.1 cgd blankline = (blankline || (inbuf[0] == '\n'));
393 1.1 cgd seensubj = (seensubj || (!blankline && (strncmp(inbuf, "Subj", 4) == 0)));
394 1.1 cgd fputs(inbuf, newmsg);
395 1.1 cgd }
396 1.1 cgd #ifdef OBJECT
397 1.1 cgd if (!seensubj) {
398 1.1 cgd printf("NOTICE: Messages should have a Subject field!\n");
399 1.1 cgd #ifdef REJECT
400 1.1 cgd unlink(fname);
401 1.1 cgd #endif
402 1.1 cgd exit(1);
403 1.1 cgd }
404 1.1 cgd #endif
405 1.1 cgd exit(ferror(stdin));
406 1.1 cgd }
407 1.1 cgd if (clean)
408 1.1 cgd exit(0);
409 1.1 cgd
410 1.1 cgd /*
411 1.1 cgd * prepare to display messages
412 1.1 cgd */
413 1.1 cgd totty = (isatty(fileno(stdout)) != 0);
414 1.1 cgd use_pager = use_pager && totty;
415 1.1 cgd
416 1.17 mjl {
417 1.17 mjl char *home = getenv("HOME");
418 1.17 mjl if(home == NULL || *home == '\0')
419 1.17 mjl errx(1, "$HOME not set");
420 1.17 mjl snprintf(fname, sizeof (fname), "%s/%s", home, MSGSRC);
421 1.17 mjl }
422 1.6 cgd msgsrc = fopen(fname, "r");
423 1.1 cgd if (msgsrc) {
424 1.1 cgd newrc = NO;
425 1.7 tls fscanf(msgsrc, "%d\n", &nextmsg);
426 1.7 tls fclose(msgsrc);
427 1.7 tls if (nextmsg > lastmsg+1) {
428 1.1 cgd printf("Warning: bounds have been reset (%d, %d)\n",
429 1.1 cgd firstmsg, lastmsg);
430 1.1 cgd truncate(fname, (off_t)0);
431 1.1 cgd newrc = YES;
432 1.1 cgd }
433 1.1 cgd else if (!rcfirst)
434 1.1 cgd rcfirst = nextmsg - rcback;
435 1.1 cgd }
436 1.7 tls else
437 1.7 tls newrc = YES;
438 1.7 tls msgsrc = fopen(fname, "r+");
439 1.7 tls if (msgsrc == NULL)
440 1.7 tls msgsrc = fopen(fname, "w");
441 1.1 cgd if (msgsrc == NULL) {
442 1.1 cgd perror(fname);
443 1.1 cgd exit(errno);
444 1.1 cgd }
445 1.1 cgd if (rcfirst) {
446 1.1 cgd if (rcfirst > lastmsg+1) {
447 1.1 cgd printf("Warning: the last message is number %d.\n",
448 1.1 cgd lastmsg);
449 1.1 cgd rcfirst = nextmsg;
450 1.1 cgd }
451 1.1 cgd if (rcfirst > firstmsg)
452 1.1 cgd firstmsg = rcfirst; /* don't set below first msg */
453 1.1 cgd }
454 1.1 cgd if (newrc) {
455 1.1 cgd nextmsg = firstmsg;
456 1.1 cgd fseek(msgsrc, 0L, 0);
457 1.1 cgd fprintf(msgsrc, "%d\n", nextmsg);
458 1.1 cgd fflush(msgsrc);
459 1.1 cgd }
460 1.1 cgd
461 1.1 cgd #ifdef V7
462 1.1 cgd if (totty) {
463 1.1 cgd struct winsize win;
464 1.1 cgd if (ioctl(fileno(stdout), TIOCGWINSZ, &win) != -1)
465 1.1 cgd Lpp = win.ws_row;
466 1.1 cgd if (Lpp <= 0) {
467 1.1 cgd if (tgetent(inbuf, getenv("TERM")) <= 0
468 1.1 cgd || (Lpp = tgetnum("li")) <= 0) {
469 1.1 cgd Lpp = NLINES;
470 1.1 cgd }
471 1.1 cgd }
472 1.1 cgd }
473 1.1 cgd #endif
474 1.1 cgd Lpp -= 6; /* for headers, etc. */
475 1.1 cgd
476 1.1 cgd already = NO;
477 1.1 cgd prevmsg = firstmsg;
478 1.1 cgd printing = YES;
479 1.1 cgd if (ruptible)
480 1.1 cgd signal(SIGINT, onintr);
481 1.1 cgd
482 1.1 cgd /*
483 1.1 cgd * Main program loop
484 1.1 cgd */
485 1.1 cgd for (msg = firstmsg; msg <= lastmsg; msg++) {
486 1.1 cgd
487 1.16 ad snprintf(fname, sizeof (fname), "%s/%d", _PATH_MSGS, msg);
488 1.1 cgd newmsg = fopen(fname, "r");
489 1.1 cgd if (newmsg == NULL)
490 1.1 cgd continue;
491 1.1 cgd
492 1.1 cgd gfrsub(newmsg); /* get From and Subject fields */
493 1.1 cgd if (locomode && !local) {
494 1.1 cgd fclose(newmsg);
495 1.1 cgd continue;
496 1.1 cgd }
497 1.1 cgd
498 1.1 cgd if (qopt) { /* This has to be located here */
499 1.1 cgd printf("There are new messages.\n");
500 1.1 cgd exit(0);
501 1.1 cgd }
502 1.1 cgd
503 1.1 cgd if (already && !hdrs)
504 1.1 cgd putchar('\n');
505 1.1 cgd
506 1.1 cgd /*
507 1.1 cgd * Print header
508 1.1 cgd */
509 1.1 cgd if (totty)
510 1.1 cgd signal(SIGTSTP, onsusp);
511 1.1 cgd (void) setjmp(tstpbuf);
512 1.1 cgd already = YES;
513 1.1 cgd nlines = 2;
514 1.1 cgd if (seenfrom) {
515 1.1 cgd printf("Message %d:\nFrom %s %s", msg, from, date);
516 1.1 cgd nlines++;
517 1.1 cgd }
518 1.1 cgd if (seensubj) {
519 1.1 cgd printf("Subject: %s", subj);
520 1.1 cgd nlines++;
521 1.1 cgd }
522 1.1 cgd else {
523 1.1 cgd if (seenfrom) {
524 1.1 cgd putchar('\n');
525 1.1 cgd nlines++;
526 1.1 cgd }
527 1.1 cgd while (nlines < 6
528 1.1 cgd && fgets(inbuf, sizeof inbuf, newmsg)
529 1.1 cgd && inbuf[0] != '\n') {
530 1.1 cgd fputs(inbuf, stdout);
531 1.1 cgd nlines++;
532 1.1 cgd }
533 1.1 cgd }
534 1.1 cgd
535 1.1 cgd lct = linecnt(newmsg);
536 1.1 cgd if (lct)
537 1.1 cgd printf("(%d%slines) ", lct, seensubj? " " : " more ");
538 1.1 cgd
539 1.1 cgd if (hdrs) {
540 1.1 cgd printf("\n-----\n");
541 1.1 cgd fclose(newmsg);
542 1.1 cgd continue;
543 1.1 cgd }
544 1.1 cgd
545 1.1 cgd /*
546 1.1 cgd * Ask user for command
547 1.1 cgd */
548 1.1 cgd if (totty)
549 1.1 cgd ask(lct? MORE : (msg==lastmsg? NOMORE : NEXT));
550 1.1 cgd else
551 1.1 cgd inbuf[0] = 'y';
552 1.1 cgd if (totty)
553 1.1 cgd signal(SIGTSTP, SIG_DFL);
554 1.1 cgd cmnd:
555 1.1 cgd in = inbuf;
556 1.1 cgd switch (*in) {
557 1.1 cgd case 'x':
558 1.1 cgd case 'X':
559 1.1 cgd exit(0);
560 1.1 cgd
561 1.1 cgd case 'q':
562 1.1 cgd case 'Q':
563 1.1 cgd quitit = YES;
564 1.1 cgd printf("--Postponed--\n");
565 1.1 cgd exit(0);
566 1.1 cgd /* intentional fall-thru */
567 1.1 cgd case 'n':
568 1.1 cgd case 'N':
569 1.1 cgd if (msg >= nextmsg) sep = "Flushed";
570 1.1 cgd prevmsg = msg;
571 1.1 cgd break;
572 1.1 cgd
573 1.1 cgd case 'p':
574 1.1 cgd case 'P':
575 1.1 cgd use_pager = (*in++ == 'p');
576 1.1 cgd /* intentional fallthru */
577 1.1 cgd case '\n':
578 1.1 cgd case 'y':
579 1.1 cgd default:
580 1.1 cgd if (*in == '-') {
581 1.1 cgd msg = prevmsg-1;
582 1.1 cgd sep = "replay";
583 1.1 cgd break;
584 1.1 cgd }
585 1.13 christos if (isdigit((unsigned char)*in)) {
586 1.1 cgd msg = next(in);
587 1.1 cgd sep = in;
588 1.1 cgd break;
589 1.1 cgd }
590 1.1 cgd
591 1.1 cgd prmesg(nlines + lct + (seensubj? 1 : 0));
592 1.1 cgd prevmsg = msg;
593 1.1 cgd
594 1.1 cgd }
595 1.1 cgd
596 1.1 cgd printf("--%s--\n", sep);
597 1.1 cgd sep = "-";
598 1.1 cgd if (msg >= nextmsg) {
599 1.1 cgd nextmsg = msg + 1;
600 1.1 cgd fseek(msgsrc, 0L, 0);
601 1.1 cgd fprintf(msgsrc, "%d\n", nextmsg);
602 1.1 cgd fflush(msgsrc);
603 1.1 cgd }
604 1.1 cgd if (newmsg)
605 1.1 cgd fclose(newmsg);
606 1.1 cgd if (quitit)
607 1.1 cgd break;
608 1.1 cgd }
609 1.1 cgd
610 1.1 cgd /*
611 1.1 cgd * Make sure .rc file gets updated
612 1.1 cgd */
613 1.1 cgd if (--msg >= nextmsg) {
614 1.1 cgd nextmsg = msg + 1;
615 1.1 cgd fseek(msgsrc, 0L, 0);
616 1.1 cgd fprintf(msgsrc, "%d\n", nextmsg);
617 1.1 cgd fflush(msgsrc);
618 1.1 cgd }
619 1.1 cgd if (already && !quitit && lastcmd && totty) {
620 1.1 cgd /*
621 1.1 cgd * save or reply to last message?
622 1.1 cgd */
623 1.1 cgd msg = prevmsg;
624 1.1 cgd ask(NOMORE);
625 1.13 christos if (inbuf[0] == '-' || isdigit((unsigned char)inbuf[0]))
626 1.1 cgd goto cmnd;
627 1.1 cgd }
628 1.1 cgd if (!(already || hush || qopt))
629 1.1 cgd printf("No new messages.\n");
630 1.1 cgd exit(0);
631 1.1 cgd }
632 1.1 cgd
633 1.10 lukem void
634 1.1 cgd prmesg(length)
635 1.10 lukem int length;
636 1.1 cgd {
637 1.1 cgd FILE *outf;
638 1.5 mycroft char *env_pager;
639 1.1 cgd
640 1.1 cgd if (use_pager && length > Lpp) {
641 1.1 cgd signal(SIGPIPE, SIG_IGN);
642 1.1 cgd signal(SIGQUIT, SIG_IGN);
643 1.15 kleink if ((env_pager = getenv("PAGER")) == NULL ||
644 1.15 kleink env_pager[0] == '\0') {
645 1.16 ad snprintf(cmdbuf, sizeof(cmdbuf), "%s -z%d",
646 1.16 ad _PATH_PAGER, Lpp);
647 1.7 tls } else {
648 1.16 ad strlcpy(cmdbuf, env_pager, sizeof (cmdbuf));
649 1.7 tls }
650 1.1 cgd outf = popen(cmdbuf, "w");
651 1.1 cgd if (!outf)
652 1.1 cgd outf = stdout;
653 1.1 cgd else
654 1.1 cgd setbuf(outf, (char *)NULL);
655 1.1 cgd }
656 1.1 cgd else
657 1.1 cgd outf = stdout;
658 1.1 cgd
659 1.1 cgd if (seensubj)
660 1.1 cgd putc('\n', outf);
661 1.1 cgd
662 1.1 cgd while (fgets(inbuf, sizeof inbuf, newmsg)) {
663 1.1 cgd fputs(inbuf, outf);
664 1.1 cgd if (ferror(outf)) {
665 1.1 cgd clearerr(outf);
666 1.1 cgd break;
667 1.1 cgd }
668 1.1 cgd }
669 1.1 cgd
670 1.1 cgd if (outf != stdout) {
671 1.1 cgd pclose(outf);
672 1.1 cgd signal(SIGPIPE, SIG_DFL);
673 1.1 cgd signal(SIGQUIT, SIG_DFL);
674 1.1 cgd }
675 1.1 cgd else {
676 1.1 cgd fflush(stdout);
677 1.1 cgd }
678 1.1 cgd
679 1.1 cgd /* trick to force wait on output */
680 1.7 tls tcdrain(fileno(stdout));
681 1.1 cgd }
682 1.1 cgd
683 1.1 cgd void
684 1.10 lukem onintr(dummy)
685 1.10 lukem int dummy;
686 1.1 cgd {
687 1.1 cgd signal(SIGINT, onintr);
688 1.1 cgd if (mailing)
689 1.1 cgd unlink(fname);
690 1.1 cgd if (sending) {
691 1.1 cgd unlink(fname);
692 1.1 cgd puts("--Killed--");
693 1.1 cgd exit(1);
694 1.1 cgd }
695 1.1 cgd if (printing) {
696 1.1 cgd putchar('\n');
697 1.1 cgd if (hdrs)
698 1.1 cgd exit(0);
699 1.1 cgd sep = "Interrupt";
700 1.1 cgd if (newmsg)
701 1.1 cgd fseek(newmsg, 0L, 2);
702 1.1 cgd intrpflg = YES;
703 1.1 cgd }
704 1.1 cgd }
705 1.1 cgd
706 1.1 cgd /*
707 1.1 cgd * We have just gotten a susp. Suspend and prepare to resume.
708 1.1 cgd */
709 1.1 cgd void
710 1.10 lukem onsusp(dummy)
711 1.10 lukem int dummy;
712 1.1 cgd {
713 1.1 cgd
714 1.1 cgd signal(SIGTSTP, SIG_DFL);
715 1.1 cgd sigsetmask(0);
716 1.1 cgd kill(0, SIGTSTP);
717 1.1 cgd signal(SIGTSTP, onsusp);
718 1.1 cgd if (!mailing)
719 1.1 cgd longjmp(tstpbuf, 0);
720 1.1 cgd }
721 1.1 cgd
722 1.10 lukem int
723 1.1 cgd linecnt(f)
724 1.10 lukem FILE *f;
725 1.1 cgd {
726 1.1 cgd off_t oldpos = ftell(f);
727 1.1 cgd int l = 0;
728 1.1 cgd char lbuf[BUFSIZ];
729 1.1 cgd
730 1.1 cgd while (fgets(lbuf, sizeof lbuf, f))
731 1.1 cgd l++;
732 1.1 cgd clearerr(f);
733 1.1 cgd fseek(f, oldpos, 0);
734 1.1 cgd return (l);
735 1.1 cgd }
736 1.1 cgd
737 1.10 lukem int
738 1.1 cgd next(buf)
739 1.10 lukem char *buf;
740 1.1 cgd {
741 1.1 cgd int i;
742 1.1 cgd sscanf(buf, "%d", &i);
743 1.16 ad snprintf(buf, sizeof (buf), "Goto %d", i);
744 1.1 cgd return(--i);
745 1.1 cgd }
746 1.1 cgd
747 1.10 lukem void
748 1.1 cgd ask(prompt)
749 1.10 lukem char *prompt;
750 1.1 cgd {
751 1.1 cgd char inch;
752 1.1 cgd int n, cmsg;
753 1.1 cgd off_t oldpos;
754 1.1 cgd FILE *cpfrom, *cpto;
755 1.1 cgd
756 1.1 cgd printf("%s ", prompt);
757 1.1 cgd fflush(stdout);
758 1.1 cgd intrpflg = NO;
759 1.1 cgd (void) fgets(inbuf, sizeof inbuf, stdin);
760 1.1 cgd if ((n = strlen(inbuf)) > 0 && inbuf[n - 1] == '\n')
761 1.1 cgd inbuf[n - 1] = '\0';
762 1.1 cgd if (intrpflg)
763 1.1 cgd inbuf[0] = 'x';
764 1.1 cgd
765 1.1 cgd /*
766 1.1 cgd * Handle 'mail' and 'save' here.
767 1.1 cgd */
768 1.7 tls if (((inch = inbuf[0]) == 's' || inch == 'm') && !restricted) {
769 1.1 cgd if (inbuf[1] == '-')
770 1.1 cgd cmsg = prevmsg;
771 1.13 christos else if (isdigit((unsigned char)inbuf[1]))
772 1.1 cgd cmsg = atoi(&inbuf[1]);
773 1.1 cgd else
774 1.1 cgd cmsg = msg;
775 1.16 ad snprintf(fname, sizeof (fname), "%s/%d", _PATH_MSGS, cmsg);
776 1.1 cgd
777 1.1 cgd oldpos = ftell(newmsg);
778 1.1 cgd
779 1.1 cgd cpfrom = fopen(fname, "r");
780 1.1 cgd if (!cpfrom) {
781 1.1 cgd printf("Message %d not found\n", cmsg);
782 1.1 cgd ask (prompt);
783 1.1 cgd return;
784 1.1 cgd }
785 1.1 cgd
786 1.1 cgd if (inch == 's') {
787 1.1 cgd in = nxtfld(inbuf);
788 1.1 cgd if (*in) {
789 1.1 cgd for (n=0; in[n] > ' '; n++) { /* sizeof fname? */
790 1.1 cgd fname[n] = in[n];
791 1.1 cgd }
792 1.8 pk fname[n] = '\0';
793 1.1 cgd }
794 1.1 cgd else
795 1.16 ad strlcpy(fname, "Messages", sizeof(fname));
796 1.1 cgd }
797 1.1 cgd else {
798 1.14 mrg int fd;
799 1.14 mrg
800 1.16 ad strlcpy(fname, _PATH_TMP, sizeof(fname));
801 1.14 mrg fd = mkstemp(fname);
802 1.14 mrg if (fd == -1)
803 1.14 mrg err(1, "mkstemp failed");
804 1.14 mrg close(fd);
805 1.16 ad snprintf(cmdbuf, sizeof (cmdbuf), _PATH_MAIL, fname);
806 1.1 cgd mailing = YES;
807 1.1 cgd }
808 1.1 cgd cpto = fopen(fname, "a");
809 1.1 cgd if (!cpto) {
810 1.1 cgd perror(fname);
811 1.1 cgd mailing = NO;
812 1.1 cgd fseek(newmsg, oldpos, 0);
813 1.1 cgd ask(prompt);
814 1.1 cgd return;
815 1.1 cgd }
816 1.1 cgd
817 1.10 lukem while ((n = fread(inbuf, 1, sizeof inbuf, cpfrom)) != 0)
818 1.1 cgd fwrite(inbuf, 1, n, cpto);
819 1.1 cgd
820 1.1 cgd fclose(cpfrom);
821 1.1 cgd fclose(cpto);
822 1.1 cgd fseek(newmsg, oldpos, 0); /* reposition current message */
823 1.1 cgd if (inch == 's')
824 1.1 cgd printf("Message %d saved in \"%s\"\n", cmsg, fname);
825 1.1 cgd else {
826 1.1 cgd system(cmdbuf);
827 1.1 cgd unlink(fname);
828 1.1 cgd mailing = NO;
829 1.1 cgd }
830 1.1 cgd ask(prompt);
831 1.1 cgd }
832 1.1 cgd }
833 1.1 cgd
834 1.10 lukem void
835 1.1 cgd gfrsub(infile)
836 1.10 lukem FILE *infile;
837 1.1 cgd {
838 1.1 cgd off_t frompos;
839 1.1 cgd
840 1.1 cgd seensubj = seenfrom = NO;
841 1.1 cgd local = YES;
842 1.8 pk subj[0] = from[0] = date[0] = 0;
843 1.1 cgd
844 1.1 cgd /*
845 1.1 cgd * Is this a normal message?
846 1.1 cgd */
847 1.1 cgd if (fgets(inbuf, sizeof inbuf, infile)) {
848 1.1 cgd if (strncmp(inbuf, "From", 4)==0) {
849 1.1 cgd /*
850 1.1 cgd * expected form starts with From
851 1.1 cgd */
852 1.1 cgd seenfrom = YES;
853 1.1 cgd frompos = ftell(infile);
854 1.1 cgd ptr = from;
855 1.1 cgd in = nxtfld(inbuf);
856 1.1 cgd if (*in) while (*in && *in > ' ') {
857 1.1 cgd if (*in == ':' || *in == '@' || *in == '!')
858 1.1 cgd local = NO;
859 1.1 cgd *ptr++ = *in++;
860 1.1 cgd /* what about sizeof from ? */
861 1.1 cgd }
862 1.8 pk *ptr = '\0';
863 1.1 cgd if (*(in = nxtfld(in)))
864 1.1 cgd strncpy(date, in, sizeof date);
865 1.1 cgd else {
866 1.1 cgd date[0] = '\n';
867 1.8 pk date[1] = '\0';
868 1.1 cgd }
869 1.1 cgd }
870 1.1 cgd else {
871 1.1 cgd /*
872 1.1 cgd * not the expected form
873 1.1 cgd */
874 1.1 cgd fseek(infile, 0L, 0);
875 1.1 cgd return;
876 1.1 cgd }
877 1.1 cgd }
878 1.1 cgd else
879 1.1 cgd /*
880 1.1 cgd * empty file ?
881 1.1 cgd */
882 1.1 cgd return;
883 1.1 cgd
884 1.1 cgd /*
885 1.1 cgd * look for Subject line until EOF or a blank line
886 1.1 cgd */
887 1.1 cgd while (fgets(inbuf, sizeof inbuf, infile)
888 1.1 cgd && !(blankline = (inbuf[0] == '\n'))) {
889 1.1 cgd /*
890 1.1 cgd * extract Subject line
891 1.1 cgd */
892 1.1 cgd if (!seensubj && strncmp(inbuf, "Subj", 4)==0) {
893 1.1 cgd seensubj = YES;
894 1.1 cgd frompos = ftell(infile);
895 1.1 cgd strncpy(subj, nxtfld(inbuf), sizeof subj);
896 1.1 cgd }
897 1.1 cgd }
898 1.1 cgd if (!blankline)
899 1.1 cgd /*
900 1.1 cgd * ran into EOF
901 1.1 cgd */
902 1.1 cgd fseek(infile, frompos, 0);
903 1.1 cgd
904 1.1 cgd if (!seensubj)
905 1.1 cgd /*
906 1.1 cgd * for possible use with Mail
907 1.1 cgd */
908 1.1 cgd strncpy(subj, "(No Subject)\n", sizeof subj);
909 1.1 cgd }
910 1.1 cgd
911 1.1 cgd char *
912 1.1 cgd nxtfld(s)
913 1.10 lukem char *s;
914 1.1 cgd {
915 1.1 cgd if (*s) while (*s && *s > ' ') s++; /* skip over this field */
916 1.1 cgd if (*s) while (*s && *s <= ' ') s++; /* find start of next field */
917 1.1 cgd return (s);
918 1.1 cgd }
919