/* * Acme interface to nntpfs. */ #include #include #include #include #include "win.h" #include int canpost; int debug; int nshow = 20; int lo; /* next message to look at in dir */ int hi; /* current hi message in dir */ char *dir = "/mnt/news"; char *group; char *from; typedef struct Article Article; struct Article { Ref; Article *prev; Article *next; Window *w; int n; int dead; int dirtied; int sayspost; int headers; int ispost; }; Article *mlist; Window *root; int cistrncmp(char *a, char *b, int n) { while(n-- > 0){ if(tolower(*a++) != tolower(*b++)) return -1; } return 0; } int cistrcmp(char *a, char *b) { for(;;){ if(tolower(*a) != tolower(*b++)) return -1; if(*a++ == 0) break; } return 0; } char* skipwhite(char *p) { while(isspace(*p)) p++; return p; } int gethi(void) { Dir *d; int hi; if((d = dirstat(dir)) == nil) return -1; hi = d->qid.vers; free(d); return hi; } char* fixfrom(char *s) { char *r, *w; s = estrdup(s); /* remove quotes */ for(r=w=s; *r; r++) if(*r != '"') *w++ = *r; *w = '\0'; return s; } char *day[] = { "Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat", }; char *mon[] = { "Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec", }; char* fixdate(char *s) { char *f[10], *m, *t, *wd, tmp[40]; int d, i, j, nf, hh, mm; nf = tokenize(s, f, nelem(f)); wd = nil; d = 0; m = nil; t = nil; for(i=0; i=lo && ndata < 0) w->data = winopenfile(w, "data"); fprint(w->ctl, "dirty\n"); winopenbody(w, OWRITE); lo = adddir(w->body, hi, 0, nshow); winclean(w); } /* return 1 if handled, 0 otherwise */ static int iscmd(char *s, char *cmd) { int len; len = strlen(cmd); return strncmp(s, cmd, len)==0 && (s[len]=='\0' || s[len]==' ' || s[len]=='\t' || s[len]=='\n'); } static char* skip(char *s, char *cmd) { s += strlen(cmd); while(*s==' ' || *s=='\t' || *s=='\n') s++; return s; } void unlink(Article *m) { if(mlist == m) mlist = m->next; if(m->next) m->next->prev = m->prev; if(m->prev) m->prev->next = m->next; m->next = m->prev = nil; } int mesgopen(char*); int fillmesgwindow(int, Article*); Article *newpost(void); void replywindow(Article*); void mesgpost(Article*); /* * Depends on d.qid.vers being highest numbered message in dir. */ void acmetimer(Article *m, Window *w) { Biobuf *b; Dir *d; assert(m==nil && w==root); if((d = dirstat(dir))==nil | hi==d->qid.vers){ free(d); return; } if(w->data < 0) w->data = winopenfile(w, "data"); if(winsetaddr(w, "0", 0)) write(w->data, "", 0); b = emalloc(sizeof(*b)); Binit(b, w->data, OWRITE); adddir(b, d->qid.vers, hi+1, d->qid.vers); hi = d->qid.vers; Bterm(b); free(b); free(d); winselect(w, "0,.", 0); } int acmeload(Article*, Window*, char *s) { int nopen; //fprint(2, "load %s\n", s); nopen = 0; while(*s){ /* skip directory name */ if(strncmp(s, dir, strlen(dir))==0) s += strlen(dir); nopen += mesgopen(s); if((s = strchr(s, '\n')) == nil) break; s = skip(s, ""); } return nopen; } int acmecmd(Article *m, Window *w, char *s) { int n; Biobuf *b; //fprint(2, "cmd %s\n", s); s = skip(s, ""); if(iscmd(s, "Del")){ if(m == nil){ /* don't close dir until messages close */ if(mlist != nil){ ctlprint(mlist->w->ctl, "show\n"); return 1; } if(windel(w, 0)) threadexitsall(nil); return 1; }else{ if(windel(w, 0)) m->dead = 1; return 1; } } if(m==nil && iscmd(s, "More")){ s = skip(s, "More"); if(n = atoi(s)) nshow = n; if(w->data < 0) w->data = winopenfile(w, "data"); winsetaddr(w, "$", 1); fprint(w->ctl, "dirty\n"); b = emalloc(sizeof(*b)); Binit(b, w->data, OWRITE); lo = adddir(b, lo, 0, nshow); Bterm(b); free(b); winclean(w); winsetaddr(w, ".,", 0); } if(m!=nil && !m->ispost && iscmd(s, "Headers")){ m->headers = !m->headers; fillmesgwindow(-1, m); return 1; } if(iscmd(s, "Newpost")){ m = newpost(); winopenbody(m->w, OWRITE); Bprint(m->w->body, "%s\nsubject: \n\n", group); winclean(m->w); winselect(m->w, "$", 0); return 1; } if(m!=nil && !m->ispost && iscmd(s, "Reply")){ replywindow(m); return 1; } // if(m!=nil && iscmd(s, "Replymail")){ // fprint(2, "no replymail yet\n"); // return 1; // } if(iscmd(s, "Post")){ mesgpost(m); return 1; } return 0; } void acmeevent(Article *m, Window *w, Event *e) { Event *ea, *e2, *eq; char *s, *t, *buf; int na; //int n; //ulong q0, q1; switch(e->c1){ /* origin of action */ default: Unknown: fprint(2, "unknown message %c%c\n", e->c1, e->c2); break; case 'T': /* bogus timer event! */ acmetimer(m, w); break; case 'F': /* generated by our actions; ignore */ break; case 'E': /* write to body or tag; can't affect us */ break; case 'K': /* type away; we don't care */ if(m && (e->c2 == 'I' || e->c2 == 'D')){ m->dirtied = 1; if(!m->sayspost){ wintagwrite(w, "Post ", 5); m->sayspost = 1; } } break; case 'M': /* mouse event */ switch(e->c2){ /* type of action */ case 'x': /* mouse: button 2 in tag */ case 'X': /* mouse: button 2 in body */ ea = nil; //e2 = nil; s = e->b; if(e->flag & 2){ /* null string with non-null expansion */ e2 = recvp(w->cevent); if(e->nb==0) s = e2->b; } if(e->flag & 8){ /* chorded argument */ ea = recvp(w->cevent); /* argument */ na = ea->nb; recvp(w->cevent); /* ignore origin */ }else na = 0; /* append chorded arguments */ if(na){ t = emalloc(strlen(s)+1+na+1); sprint(t, "%s %s", s, ea->b); s = t; } /* if it's a known command, do it */ /* if it's a long message, it can't be for us anyway */ // DPRINT(2, "exec: %s\n", s); if(!acmecmd(m, w, s)) /* send it back */ winwriteevent(w, e); if(na) free(s); break; case 'l': /* mouse: button 3 in tag */ case 'L': /* mouse: button 3 in body */ //buf = nil; eq = e; if(e->flag & 2){ e2 = recvp(w->cevent); eq = e2; } s = eq->b; if(eq->q1>eq->q0 && eq->nb==0){ buf = emalloc((eq->q1-eq->q0)*UTFmax+1); winread(w, eq->q0, eq->q1, buf); s = buf; } if(!acmeload(m, w, s)) winwriteevent(w, e); break; case 'i': /* mouse: text inserted in tag */ case 'd': /* mouse: text deleted from tag */ break; case 'I': /* mouse: text inserted in body */ case 'D': /* mouse: text deleted from body */ if(m == nil) break; m->dirtied = 1; if(!m->sayspost){ wintagwrite(w, "Post ", 5); m->sayspost = 1; } break; default: goto Unknown; } } } void dirthread(void *v) { Event *e; Window *w; w = v; while(e = recvp(w->cevent)) acmeevent(nil, w, e); threadexitsall(nil); } void mesgthread(void *v) { Event *e; Article *m; m = v; while(!m->dead && (e = recvp(m->w->cevent))) acmeevent(m, m->w, e); //fprint(2, "msg %p exits\n", m); unlink(m); free(m->w); free(m); threadexits(nil); } /* Xref: news.research.att.com comp.os.plan9:7360 Newsgroups: comp.os.plan9 Path: news.research.att.com!batch0!uunet!ffx.uu.net!finch!news.mindspring.net!newsfeed.mathworks.com!fu-berlin.de!server1.netnews.ja.net!hgmp.mrc.ac.uk!pegasus.csx.cam.ac.uk!bath.ac.uk!ccsdhd From: Stephen Adam Subject: Future of Plan9 Approved: plan9mod@bath.ac.uk X-Newsreader: Microsoft Outlook Express 5.00.2014.211 X-Mimeole: Produced By Microsoft MimeOLE V5.00.2014.211 Sender: ccsdhd@bath.ac.uk (Dennis Davis) Nntp-Posting-Date: Wed, 13 Dec 2000 21:28:45 EST NNTP-Posting-Host: 203.54.121.233 Organization: Telstra BigPond Internet Services (http://www.bigpond.com) X-Date: Wed, 13 Dec 2000 20:43:37 +1000 Lines: 12 Message-ID: References: <95pghu$3lf$1@news.fas.harvard.edu> <95ph36$3m9$1@news.fas.harvard.edu> <95png6$4ln$1@news.fas.harvard.edu> <95poqg$4rq$1@news.fas.harvard.edu> <95q40h$66c$2@news.fas.harvard.edu> <95qjhu$8ke$1@news.fas.harvard.edu> <95riue$bu2$1@news.fas.harvard.edu> <95rnar$cbu$1@news.fas.harvard.edu> X-Msmail-Priority: Normal X-Trace: newsfeeds.bigpond.com 976703325 203.54.121.233 (Wed, 13 Dec 2000 21:28:45 EST) X-Priority: 3 Date: Wed, 13 Dec 2000 10:49:50 GMT */ char *skipheader[] = { "x-", "path:", "xref:", "approved:", "sender:", "nntp-", "organization:", "lines:", "message-id:", "references:", "reply-to:", "mime-", "content-", }; int fillmesgwindow(int fd, Article *m) { Biobuf *b; char *p, tmp[40]; int i, inhdr, copy, xfd; Window *w; xfd = -1; if(fd == -1){ sprint(tmp, "%d/article", m->n); p = estrstrdup(dir, tmp); if((xfd = open(p, OREAD)) < 0){ free(p); return 0; } free(p); fd = xfd; } w = m->w; if(w->data < 0) w->data = winopenfile(w, "data"); if(winsetaddr(w, ",", 0)) write(w->data, "", 0); winopenbody(m->w, OWRITE); b = emalloc(sizeof(*b)); Binit(b, fd, OREAD); inhdr = 1; copy = 1; while(p = Brdline(b, '\n')){ if(Blinelen(b)==1) inhdr = 0, copy=1; if(inhdr && !isspace(p[0])){ copy = 1; if(!m->headers){ if(cistrncmp(p, "from:", 5)==0){ p[Blinelen(b)-1] = '\0'; p = fixfrom(skip(p, "from:")); Bprint(m->w->body, "From: %s\n", p); free(p); copy = 0; continue; } for(i=0; iw->body, p, Blinelen(b)); } Bterm(b); free(b); winclean(m->w); if(xfd != -1) close(xfd); return 1; } Article* newpost(void) { Article *m; char *p, tmp[40]; static int nnew; m = emalloc(sizeof *m); sprint(tmp, "Post%d", ++nnew); p = estrstrdup(dir, tmp); m->w = newwindow(); proccreate(wineventproc, m->w, STACK); winname(m->w, p); wintagwrite(m->w, "Post ", 5); m->sayspost = 1; m->ispost = 1; threadcreate(mesgthread, m, STACK); if(mlist){ m->next = mlist; mlist->prev = m; } mlist = m; return m; } void replywindow(Article *m) { Biobuf *b; char *p, *ep, *q, tmp[40]; int fd, copy; Article *reply; sprint(tmp, "%d/article", m->n); p = estrstrdup(dir, tmp); if((fd = open(p, OREAD)) < 0){ free(p); return; } free(p); reply = newpost(); winopenbody(reply->w, OWRITE); b = emalloc(sizeof(*b)); Binit(b, fd, OREAD); copy = 0; while(p = Brdline(b, '\n')){ if(Blinelen(b)==1) break; ep = p+Blinelen(b); if(!isspace(*p)){ copy = 0; if(cistrncmp(p, "newsgroups:", 11)==0){ for(q=p+11; *q!='\n'; q++) if(*q==',') *q = ' '; copy = 1; }else if(cistrncmp(p, "subject:", 8)==0){ if(!strstr(p, " Re:") && !strstr(p, " RE:") && !strstr(p, " re:")){ p = skip(p, "subject:"); ep[-1] = '\0'; Bprint(reply->w->body, "Subject: Re: %s\n", p); }else copy = 1; }else if(cistrncmp(p, "message-id:", 11)==0){ Bprint(reply->w->body, "References: "); p += 11; copy = 1; } } if(copy) Bwrite(reply->w->body, p, ep-p); } Bterm(b); close(fd); free(b); Bprint(reply->w->body, "\n"); winclean(reply->w); winselect(reply->w, "$", 0); } char* skipbl(char *s, char *e) { while(s < e){ if(*s!=' ' && *s!='\t' && *s!=',') break; s++; } return s; } char* findbl(char *s, char *e) { while(s < e){ if(*s==' ' || *s=='\t' || *s==',') break; s++; } return s; } /* * comma-separate possibly blank-separated strings in line; e points before newline */ void commas(char *s, char *e) { char *t; /* may have initial blanks */ s = skipbl(s, e); while(s < e){ s = findbl(s, e); if(s == e) break; t = skipbl(s, e); if(t == e) /* no more words */ break; /* patch comma */ *s++ = ','; while(s < t) *s++ = ' '; } } void mesgpost(Article *m) { Biobuf *b; char *p, *ep; int isfirst, ishdr, havegroup, havefrom; p = estrstrdup(dir, "post"); if((b = Bopen(p, OWRITE)) == nil){ fprint(2, "cannot open %s: %r\n", p); free(p); return; } free(p); winopenbody(m->w, OREAD); ishdr = 1; isfirst = 1; havegroup = havefrom = 0; while(p = Brdline(m->w->body, '\n')){ ep = p+Blinelen(m->w->body); if(ishdr && p+1==ep){ if(!havegroup) Bprint(b, "Newsgroups: %s\n", group); if(!havefrom) Bprint(b, "From: %s\n", from); ishdr = 0; } if(ishdr){ ep[-1] = '\0'; if(isfirst && strchr(p, ':')==0){ /* group list */ commas(p, ep); Bprint(b, "newsgroups: %s\n", p); havegroup = 1; isfirst = 0; continue; } if(cistrncmp(p, "newsgroup:", 10)==0){ commas(skip(p, "newsgroup:"), ep); Bprint(b, "newsgroups: %s\n", skip(p, "newsgroup:")); havegroup = 1; continue; } if(cistrncmp(p, "newsgroups:", 11)==0){ commas(skip(p, "newsgroups:"), ep); Bprint(b, "newsgroups: %s\n", skip(p, "newsgroups:")); havegroup = 1; continue; } if(cistrncmp(p, "from:", 5)==0) havefrom = 1; ep[-1] = '\n'; } Bwrite(b, p, ep-p); } winclosebody(m->w); Bflush(b); if(write(Bfildes(b), "", 0) == 0) winclean(m->w); else fprint(2, "post: %r\n"); Bterm(b); } int mesgopen(char *s) { char *p, tmp[40]; int fd, n; Article *m; n = atoi(s); if(n==0) return 0; for(m=mlist; m; m=m->next){ if(m->n == n){ ctlprint(m->w->ctl, "show\n"); return 1; } } sprint(tmp, "%d/article", n); p = estrstrdup(dir, tmp); if((fd = open(p, OREAD)) < 0){ free(p); return 0; } m = emalloc(sizeof(*m)); m->w = newwindow(); m->n = n; proccreate(wineventproc, m->w, STACK); p[strlen(p)-strlen("article")] = '\0'; winname(m->w, p); if(canpost) wintagwrite(m->w, "Reply ", 6); wintagwrite(m->w, "Headers ", 8); free(p); if(mlist){ m->next = mlist; mlist->prev = m; } mlist = m; threadcreate(mesgthread, m, STACK); fillmesgwindow(fd, m); close(fd); windormant(m->w); return 1; } void usage(void) { fprint(2, "usage: News [-d /mnt/news] comp.os.plan9\n"); exits("usage"); } void timerproc(void *v) { Event e; Window *w; memset(&e, 0, sizeof e); e.c1 = 'T'; w = v; for(;;){ sleep(60*1000); sendp(w->cevent, &e); } } char* findfrom(void) { char *p, *u; Biobuf *b; u = getuser(); if(u==nil) return "glenda"; p = estrstrstrdup("/usr/", u, "/lib/newsfrom"); b = Bopen(p, OREAD); free(p); if(b){ p = Brdline(b, '\n'); if(p){ p[Blinelen(b)-1] = '\0'; p = estrdup(p); Bterm(b); return p; } Bterm(b); } p = estrstrstrdup("/mail/box/", u, "/headers"); b = Bopen(p, OREAD); free(p); if(b){ while(p = Brdline(b, '\n')){ p[Blinelen(b)-1] = '\0'; if(cistrncmp(p, "from:", 5)==0){ p = estrdup(skip(p, "from:")); Bterm(b); return p; } } Bterm(b); } return u; } void threadmain(int argc, char **argv) { char *p, *q; Dir *d; Window *w; ARGBEGIN{ case 'D': debug++; break; case 'd': dir = EARGF(usage()); break; default: usage(); break; }ARGEND if(argc != 1) usage(); from = findfrom(); group = estrdup(argv[0]); /* someone will be cute */ while(q=strchr(group, '/')) *q = '.'; p = estrdup(argv[0]); while(q=strchr(p, '.')) *q = '/'; p = estrstrstrdup(dir, "/", p); cleanname(p); if((d = dirstat(p)) == nil){ /* maybe it is a new group */ if((d = dirstat(dir)) == nil){ fprint(2, "dirstat(%s) fails: %r\n", dir); threadexitsall(nil); } if((d->mode&DMDIR)==0){ fprint(2, "%s not a directory\n", dir); threadexitsall(nil); } free(d); if((d = dirstat(p)) == nil){ fprint(2, "stat %s: %r\n", p); threadexitsall(nil); } } if((d->mode&DMDIR)==0){ fprint(2, "%s not a directory\n", dir); threadexitsall(nil); } free(d); dir = estrstrdup(p, "/"); q = estrstrdup(dir, "post"); canpost = access(q, AWRITE)==0; w = newwindow(); root = w; proccreate(wineventproc, w, STACK); proccreate(timerproc, w, STACK); winname(w, dir); if(canpost) wintagwrite(w, "Newpost ", 8); wintagwrite(w, "More ", 5); dirwindow(w); threadcreate(dirthread, w, STACK); threadexits(nil); }