![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to comsat.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSD / contrib / X / comsat|
Return to comsat.c CVS log | Up to [CSRG BSD Unix] / 43BSD / contrib / X / comsat |
1.1 ! root 1: /* ! 2: * fancied up comsat program..... ! 3: */ ! 4: ! 5: #ifndef lint ! 6: static char *rcsid_comsat_c = "$Header: comsat.c,v 10.3 86/02/01 15:18:47 tony Rel $"; ! 7: #endif lint ! 8: ! 9: #define XWIND ! 10: #define SHORTSWEET ! 11: ! 12: #ifndef lint ! 13: static char sccsid[] = "@(#)comsat.c 4.12 (Berkeley) 8/1/84"; ! 14: #endif ! 15: ! 16: #ifndef XWIND ! 17: #include <sys/types.h> ! 18: #include <sys/socket.h> ! 19: #else ! 20: #include <X/Xlib.h> ! 21: #include <ttyent.h> ! 22: #include <pwd.h> ! 23: char *indexs(); ! 24: extern char **environ; ! 25: #endif ! 26: #include <sys/stat.h> ! 27: #include <sys/wait.h> ! 28: #include <sys/file.h> ! 29: ! 30: #include <netinet/in.h> ! 31: ! 32: #include <stdio.h> ! 33: #include <sgtty.h> ! 34: #include <utmp.h> ! 35: #include <signal.h> ! 36: #include <errno.h> ! 37: #include <netdb.h> ! 38: #include <syslog.h> ! 39: ! 40: char *index(), *rindex(); ! 41: ! 42: /* ! 43: * comsat ! 44: */ ! 45: int debug = 0; ! 46: #define dprintf if (debug) printf ! 47: ! 48: #define MAXUTMP 100 /* down from init */ ! 49: ! 50: struct sockaddr_in sin = { AF_INET }; ! 51: extern errno; ! 52: ! 53: char hostname[32]; ! 54: struct utmp utmp[100]; ! 55: int nutmp; ! 56: int uf; ! 57: unsigned utmpmtime; /* last modification time for utmp */ ! 58: int onalrm(); ! 59: int reapchildren(); ! 60: long lastmsgtime; ! 61: ! 62: #define MAXIDLE 120 ! 63: #define NAMLEN (sizeof (uts[0].ut_name) + 1) ! 64: ! 65: main(argc, argv) ! 66: int argc; ! 67: char *argv[]; ! 68: { ! 69: register int cc; ! 70: char buf[BUFSIZ]; ! 71: char msgbuf[100]; ! 72: struct sockaddr_in from; ! 73: int fromlen; ! 74: ! 75: /* verify proper invocation */ ! 76: fromlen = sizeof (from); ! 77: if (getsockname(0, &from, &fromlen) < 0) { ! 78: fprintf(stderr, "%s: ", argv[0]); ! 79: perror("getsockname"); ! 80: _exit(1); ! 81: } ! 82: chdir("/usr/spool/mail"); ! 83: if ((uf = open("/etc/utmp",0)) < 0) { ! 84: openlog("comsat", 0, 0); ! 85: syslog(LOG_ERR, "/etc/utmp: %m"); ! 86: (void) recv(0, msgbuf, sizeof (msgbuf) - 1, 0); ! 87: exit(1); ! 88: } ! 89: lastmsgtime = time(0); ! 90: gethostname(hostname, sizeof (hostname)); ! 91: onalrm(); ! 92: signal(SIGALRM, onalrm); ! 93: signal(SIGTTOU, SIG_IGN); ! 94: signal(SIGCHLD, reapchildren); ! 95: for (;;) { ! 96: cc = recv(0, msgbuf, sizeof (msgbuf) - 1, 0); ! 97: if (cc <= 0) { ! 98: if (errno != EINTR) ! 99: sleep(1); ! 100: errno = 0; ! 101: continue; ! 102: } ! 103: sigblock(1<<SIGALRM); ! 104: msgbuf[cc] = 0; ! 105: lastmsgtime = time(0); ! 106: mailfor(msgbuf); ! 107: sigsetmask(0); ! 108: } ! 109: } ! 110: ! 111: reapchildren() ! 112: { ! 113: ! 114: while (wait3((struct wait *)0, WNOHANG, (struct rusage *)0) > 0) ! 115: ; ! 116: } ! 117: ! 118: onalrm() ! 119: { ! 120: struct stat statbf; ! 121: struct utmp *utp; ! 122: ! 123: if (time(0) - lastmsgtime >= MAXIDLE) ! 124: exit(0); ! 125: dprintf("alarm\n"); ! 126: alarm(15); ! 127: fstat(uf, &statbf); ! 128: if (statbf.st_mtime > utmpmtime) { ! 129: dprintf(" changed\n"); ! 130: utmpmtime = statbf.st_mtime; ! 131: lseek(uf, 0, 0); ! 132: nutmp = read(uf,utmp,sizeof(utmp))/sizeof(struct utmp); ! 133: } else ! 134: dprintf(" ok\n"); ! 135: } ! 136: ! 137: mailfor(name) ! 138: char *name; ! 139: { ! 140: register struct utmp *utp = &utmp[nutmp]; ! 141: register char *cp; ! 142: int offset; ! 143: ! 144: dprintf("mailfor %s\n", name); ! 145: cp = name; ! 146: while (*cp && *cp != '@') ! 147: cp++; ! 148: if (*cp == 0) { ! 149: dprintf("bad format\n"); ! 150: return; ! 151: } ! 152: *cp = 0; ! 153: offset = atoi(cp+1); ! 154: while (--utp >= utmp) ! 155: if (!strncmp(utp->ut_name, name, sizeof(utmp[0].ut_name))) ! 156: notify(utp, offset); ! 157: } ! 158: ! 159: char *cr; ! 160: ! 161: notify(utp, offset) ! 162: register struct utmp *utp; ! 163: { ! 164: int fd, flags, n, err, msglen; ! 165: struct sgttyb gttybuf; ! 166: char tty[sizeof (utmp[0].ut_line) + 6], msgbuf[BUFSIZ]; ! 167: char name[sizeof (utmp[0].ut_name) + 1]; ! 168: struct stat stb; ! 169: #ifdef XWIND ! 170: struct ttyent *te; ! 171: char *s; ! 172: char dname[260]; ! 173: #endif ! 174: ! 175: strcpy(tty, "/dev/"); ! 176: strncat(tty, utp->ut_line, sizeof(utp->ut_line)); ! 177: dprintf("notify %s on %s\n", utp->ut_name, tty); ! 178: if (stat(tty, &stb) == 0 && (stb.st_mode & 0100) == 0) { ! 179: dprintf("wrong mode\n"); ! 180: return; ! 181: } ! 182: strncpy(name, utp->ut_name, sizeof (utp->ut_name)); ! 183: name[sizeof (name) - 1] = '\0'; ! 184: #ifdef XWIND ! 185: te = getttynam(tty+5); ! 186: if ((s = indexs(te->ty_getty, "xterm")) && ! 187: (s = indexs(s, " -L ")) && ! 188: (s = index(s, ':'))) { ! 189: while (*(--s) != ' ') ; ! 190: s++; ! 191: if (*s == ':') { ! 192: gethostname(dname, sizeof (dname)); ! 193: strcat(dname, s); ! 194: } else ! 195: strcpy(dname, s); ! 196: Xprintf(msgbuf, name, offset); ! 197: if (fork()) ! 198: return; ! 199: Xnotify(name, dname, msgbuf); ! 200: } ! 201: #endif ! 202: if ((fd = open(tty, O_WRONLY|O_NDELAY)) < 0) { ! 203: dprintf("%s: open failed\n", tty); ! 204: return; ! 205: } ! 206: if ((flags = fcntl(fd, F_GETFL, 0)) == -1) { ! 207: dprintf("fcntl(F_GETFL) failed %d\n", errno); ! 208: return; ! 209: } ! 210: ioctl(fd, TIOCGETP, >tybuf); ! 211: cr = (gttybuf.sg_flags & CRMOD) ? "" : "\r"; ! 212: #ifdef SHORTSWEET ! 213: sprintf(msgbuf, "%s\n\007New mail from ", cr); ! 214: #else ! 215: sprintf(msgbuf, "%s\n\007New mail for %s@%s\007 has arrived:%s\n", ! 216: cr, name, hostname, cr); ! 217: #endif ! 218: jkfprintf(msgbuf+strlen(msgbuf), name, offset); ! 219: if (fcntl(fd, F_SETFL, flags | FNDELAY) == -1) ! 220: goto oldway; ! 221: msglen = strlen(msgbuf); ! 222: n = write(fd, msgbuf, msglen); ! 223: err = errno; ! 224: (void) fcntl(fd, F_SETFL, flags); ! 225: (void) close(fd); ! 226: if (n == msglen) ! 227: return; ! 228: if (err != EWOULDBLOCK) { ! 229: dprintf("write failed %d\n", errno); ! 230: return; ! 231: } ! 232: oldway: ! 233: if (fork()) { ! 234: (void) close(fd); ! 235: return; ! 236: } ! 237: signal(SIGALRM, SIG_DFL); ! 238: alarm(30); ! 239: (void) write(fd, msgbuf, msglen); ! 240: exit(0); ! 241: } ! 242: ! 243: #ifdef SHORTSWEET ! 244: jkfprintf(mp, name, offset) ! 245: register char *mp; ! 246: { ! 247: register FILE *fi; ! 248: char line[BUFSIZ]; ! 249: ! 250: dprintf("HERE %s's mail starting at %d\n", name, offset); ! 251: ! 252: if ((fi = fopen(name, "r")) == NULL) { ! 253: dprintf("Cant read the mail\n"); ! 254: return; ! 255: } ! 256: fseek(fi, offset, L_SET); ! 257: /* ! 258: * put the contents of the From: line into mp buffer ! 259: */ ! 260: while (fgets(line, sizeof (line), fi) != NULL) { ! 261: register char *cp; ! 262: ! 263: if (strncmp (line, "From:", 5) != 0) ! 264: continue; ! 265: cp = index(line, '\n'); ! 266: if (cp) ! 267: *cp = '\0'; ! 268: for (cp = line+5; (*cp == ' ' || *cp == '\t'); cp++); ! 269: sprintf(mp, "%s%s\n", cp, cr); ! 270: return; ! 271: } ! 272: /* didn't find the From: line */ ! 273: sprintf (mp, "???%s\n", cr); ! 274: } ! 275: #else ! 276: jkfprintf(mp, name, offset) ! 277: register char *mp; ! 278: { ! 279: register FILE *fi; ! 280: register int linecnt, charcnt; ! 281: char line[BUFSIZ]; ! 282: int inheader; ! 283: ! 284: dprintf("HERE %s's mail starting at %d\n", name, offset); ! 285: ! 286: if ((fi = fopen(name, "r")) == NULL) { ! 287: dprintf("Cant read the mail\n"); ! 288: return; ! 289: } ! 290: fseek(fi, offset, L_SET); ! 291: /* ! 292: * Print the first 7 lines or 560 characters of the new mail ! 293: * (whichever comes first). Skip header crap other than ! 294: * From, Subject, To, and Date. ! 295: */ ! 296: linecnt = 7; ! 297: charcnt = 560; ! 298: inheader = 1; ! 299: while (fgets(line, sizeof (line), fi) != NULL) { ! 300: register char *cp; ! 301: int cnt; ! 302: ! 303: if (linecnt <= 0 || charcnt <= 0) { ! 304: sprintf(mp, "...more...%s\n", cr); ! 305: mp += strlen(mp); ! 306: return; ! 307: } ! 308: if (strncmp(line, "From ", 5) == 0) ! 309: continue; ! 310: if (inheader && (line[0] == ' ' || line[0] == '\t')) ! 311: continue; ! 312: cp = index(line, ':'); ! 313: if (cp == 0 || (index(line, ' ') && index(line, ' ') < cp)) ! 314: inheader = 0; ! 315: else ! 316: cnt = cp - line; ! 317: if (inheader && ! 318: strncmp(line, "Date", cnt) && ! 319: strncmp(line, "From", cnt) && ! 320: strncmp(line, "Subject", cnt) && ! 321: strncmp(line, "To", cnt)) ! 322: continue; ! 323: cp = index(line, '\n'); ! 324: if (cp) ! 325: *cp = '\0'; ! 326: sprintf(mp, "%s%s\n", line, cr); ! 327: mp += strlen(mp); ! 328: linecnt--, charcnt -= strlen(line); ! 329: } ! 330: sprintf(mp, "----%s\n", cr); ! 331: mp += strlen(mp); ! 332: } ! 333: #endif ! 334: ! 335: #ifdef XWIND ! 336: char *indexs(s1, s2) ! 337: register char *s1, *s2; ! 338: { ! 339: register int z = strlen(s2); ! 340: while (*s1 && strncmp(s1, s2, z)) ! 341: s1++; ! 342: return(s1); ! 343: } ! 344: ! 345: Xprintf(mp, name, offset) ! 346: register char *mp; ! 347: { ! 348: register FILE *fi; ! 349: char line[BUFSIZ]; ! 350: ! 351: dprintf("HERE %s's mail starting at %d\n", name, offset); ! 352: ! 353: sprintf(mp, "You have new mail."); ! 354: if ((fi = fopen(name, "r")) == NULL) { ! 355: dprintf("Cant read the mail\n"); ! 356: return; ! 357: } ! 358: fseek(fi, offset, L_SET); ! 359: /* ! 360: * put the contents of the From: line into mp buffer ! 361: */ ! 362: while (fgets(line, sizeof (line), fi) != NULL) { ! 363: register char *cp; ! 364: ! 365: if (strncmp (line, "From:", 5) != 0) ! 366: continue; ! 367: cp = index(line, '\n'); ! 368: if (cp) ! 369: *cp = '\0'; ! 370: for (cp = line+5; (*cp == ' ' || *cp == '\t'); cp++); ! 371: sprintf(mp, "Mail from %s", cp); ! 372: break; ! 373: } ! 374: fclose(fi); ! 375: } ! 376: ! 377: short cursor[] = {0x0000, 0x7ffe, 0x4fc2, 0x4ffe, 0x7ffe, ! 378: 0x7ffe, 0x781e, 0x7ffe , 0x7ffe, 0x0000}; ! 379: ! 380: Xnotify (name, dname, notice) ! 381: char *name; ! 382: char *dname; ! 383: char *notice; ! 384: { ! 385: struct passwd *pwent; ! 386: char *envbuf[2]; ! 387: char homebuf[280]; ! 388: Display *dpy; ! 389: WindowInfo winfo; ! 390: FontInfo finfo; ! 391: Font font; ! 392: int width, height; ! 393: Window w; ! 394: XEvent rep; ! 395: int timeout = 0; ! 396: int reverse = 0; ! 397: int bwidth = 2; ! 398: int inner = 2; ! 399: int vertical = 2; ! 400: int volume = 0; ! 401: int forepix = BlackPixel; ! 402: int backpix = WhitePixel; ! 403: int brdrpix = BlackPixel; ! 404: int mouspix = BlackPixel; ! 405: char *option; ! 406: char *font_name = "8x13"; ! 407: char *fore_color = NULL; ! 408: char *back_color = NULL; ! 409: char *brdr_color = NULL; ! 410: char *mous_color = NULL; ! 411: Color cdef; ! 412: ! 413: if (!XOpenDisplay(dname)) ! 414: exit(0); ! 415: if (pwent = getpwnam(name)) { ! 416: strcpy(homebuf, "HOME="); ! 417: strcat(homebuf, pwent->pw_dir); ! 418: envbuf[0] = homebuf; ! 419: envbuf[1] = NULL; ! 420: environ = envbuf; ! 421: if (option = XGetDefault("biff", "BodyFont")) ! 422: font_name = option; ! 423: fore_color = XGetDefault("biff", "Foreground"); ! 424: back_color = XGetDefault("biff", "Background"); ! 425: brdr_color = XGetDefault("biff", "Border"); ! 426: mous_color = XGetDefault("biff", "Mouse"); ! 427: if (option = XGetDefault("biff", "BorderWidth")) ! 428: bwidth = atoi(option); ! 429: if (option = XGetDefault("biff", "InternalBorder")) ! 430: inner = atoi(option); ! 431: if (option = XGetDefault("biff", "Timeout")) ! 432: timeout = atoi(option); ! 433: if (option = XGetDefault("biff", "Volume")) ! 434: volume = atoi(option); ! 435: if (option = XGetDefault("biff", "Offset")) ! 436: vertical = atoi(option); ! 437: if ((option = XGetDefault("biff", "ReverseVideo")) && ! 438: strcmp(option, "on") == 0) ! 439: reverse = 1; ! 440: } ! 441: if (reverse) { ! 442: brdrpix = backpix; ! 443: backpix = forepix; ! 444: forepix = brdrpix; ! 445: mouspix = forepix; ! 446: } ! 447: ! 448: if ((font = XGetFont(font_name)) == NULL) ! 449: exit(0); ! 450: if (DisplayCells() > 2) { ! 451: if (back_color && XParseColor(back_color, &cdef) && ! 452: XGetHardwareColor(&cdef)) ! 453: backpix = cdef.pixel; ! 454: if (fore_color && XParseColor(fore_color, &cdef) && ! 455: XGetHardwareColor(&cdef)) ! 456: forepix = cdef.pixel; ! 457: if (brdr_color && XParseColor(brdr_color, &cdef) && ! 458: XGetHardwareColor(&cdef)) ! 459: brdrpix = cdef.pixel; ! 460: if (mous_color && XParseColor(mous_color, &cdef) && ! 461: XGetHardwareColor(&cdef)) ! 462: mouspix = cdef.pixel; ! 463: } ! 464: XQueryFont(font, &finfo); ! 465: XQueryWindow (RootWindow, &winfo); ! 466: width = XQueryWidth (notice, font) + (inner << 1); ! 467: height = finfo.height + (inner << 1); ! 468: if (vertical < 0) ! 469: vertical += winfo.height - height - (bwidth << 1); ! 470: w = XCreateWindow(RootWindow, (winfo.width - width - (bwidth << 1)) / 2, ! 471: vertical, width, height, bwidth, ! 472: XMakeTile(brdrpix), XMakeTile(backpix)); ! 473: XStoreName(w, notice); ! 474: XSelectInput(w, ButtonPressed|ButtonReleased|ExposeWindow); ! 475: XDefineCursor(w, XCreateCursor(16, 10, cursor, NULL, 7, 5, ! 476: mouspix, backpix, GXcopy)); ! 477: XMapWindow(w); ! 478: XFeep(volume); ! 479: if (timeout > 0) { ! 480: signal(SIGALRM, exit); ! 481: alarm(timeout * 60); ! 482: } ! 483: if (inner) inner--; ! 484: while (1) { ! 485: XText(w, inner, inner, notice, strlen(notice), ! 486: font, forepix, backpix); ! 487: XNextEvent(&rep); ! 488: if (rep.type == ButtonPressed) ! 489: exit(0); ! 490: } ! 491: } ! 492: #endif
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.