package org.ibex.mail.protocol;
+import org.ibex.util.*;
+import org.ibex.io.*;
+import org.ibex.mail.*;
+import org.ibex.mail.target.*;
+import org.ibex.jinetd.*;
+import java.io.*;
+import java.net.*;
+import java.util.*;
+import java.text.*;
+
/** NNTP send/recieve */
-public class NNTP extends MessageProtocol {
+public class NNTP {
+
+ // FIXME: command lines limited to 512 chars
+
+ public static class No extends RuntimeException { int code = 0; } // 4xx response codes
+ public static class Bad extends RuntimeException { int code = 0; } // 5xx response codes
+
+ public static class Group {
+ public Group(String n, boolean p, int f, int l, int c) { this.name=n;this.post=p;this.first=f;this.last=l;this.count=c;}
+ public final String name;
+ public final boolean post;
+ public final int first;
+ public final int last;
+ public final int count;
+ }
+
+ public static class Article {
+ public Article(String messageid, int num, Message message) { this.message=message;this.messageid=messageid;this.num=num;}
+ public final String messageid;
+ public final int num;
+ public final Message message;
+ }
+
+ public static interface Server {
+ public Group group(String s);
+ public boolean ihave(String messageid);
+ public Article next();
+ public Article last();
+ public boolean post(Message m);
+ public Article article(String messageid, boolean head, boolean body);
+ public Article article(int messagenum, boolean head, boolean body);
+ public Group[] list();
+ public Group[] newgroups(Date d, String[] distributions);
+ public String[] newnews(String[] groups, Date d, String[] distributions);
+ }
+
+ public static class MailboxWrapper implements Server {
+ private final Mailbox root;
+ private Mailbox current;
+ private int ptr = 0;
+ public MailboxWrapper(Mailbox root) { this.root = root; }
+ public Group group(String s) { ptr = 0; setgroup(s); return getgroup(s); }
+ public boolean ihave(String messageid) { /* FEATURE */ return false; }
+ public boolean post(Message m) { /* FEATURE */ return false; }
+ public Article next() { return article(ptr++, false, false); }
+ public Article last() { return article(ptr--, false, false); }
+ public Article article(String i, boolean h, boolean b) { return article(Query.header("message-id",i),h,b); }
+ public Article article(int n, boolean h, boolean b) { ptr = n; return article(Query.messagenum(n,n),h,b); }
+ private Article article(Query q, boolean head, boolean body) {
+ Mailbox.Iterator it = current.iterator(q);
+ if (!it.next()) return null;
+ Message m = body ? it.cur() : it.head();
+ return new Article(m.messageid, it.num(), m);
+ }
+ public Group[] list() { return list(root, ""); }
+ private Group[] list(Mailbox who, String prefix) {
+ Vec v = new Vec();
+ String[] s = who.children();
+ for(int i=0; i<s.length; i++) {
+ v.addElement(new Group(prefix + s[i], true, 0, 0, 0)); // FIXME numbers
+ Group[] g2 = list(who.slash(s[i], false), prefix + s[i] + ".");
+ for(int j=0; j<g2.length; j++) v.addElement(g2[j]);
+ }
+ Group[] ret = new Group[v.size()];
+ v.copyInto(ret);
+ return ret;
+ }
+
+ private void setgroup(String s) {
+ current = root;
+ for(StringTokenizer st = new StringTokenizer(s, ".");
+ st.hasMoreTokens();
+ current = current.slash(st.nextToken(), false));
+ }
+ private Group getgroup(String s) {
+ Mailbox box = root;
+ for(StringTokenizer st = new StringTokenizer(s, "."); st.hasMoreTokens(); box = box.slash(st.nextToken(), false));
+ return new Group(s, true, 0, box.count(Query.all()), box.count(Query.all()));
+ }
+
+ public Group[] newgroups(Date d, String[] distributions) { /* FEATURE */ return new Group[] { }; }
+ public String[] newnews(String[] groups, Date d, String[] distributions) { /* FIXME */ return null; }
+ }
+
+ public static class Listener implements Worker {
+ private Server api;
+ private Connection conn;
+ private void article(String numOrMessageId, boolean head, boolean body) {
+ String s = numOrMessageId.trim();
+ Article a;
+ if (s.startsWith("<")) a = api.article(s.substring(0, s.length() - 1), head, body);
+ else a = api.article(Integer.parseInt(s), head, body);
+ int code = (head && body) ? 220 : head ? 221 : body ? 222 : 223;
+ conn.println(code + " " + a.num + " <" + a.messageid + "> get ready for some stuff...");
+ if (head) conn.println(a.message.allHeaders);
+ if (head && body) conn.println();
+ if (body) conn.println(a.message.body);
+ conn.println(".");
+ }
+ public void handleRequest(Connection conn) {
+ this.conn = conn;
+ api = new NNTP.MailboxWrapper(null); // FIXME
+ conn.setTimeout(30 * 60 * 1000);
+ conn.println("200 " + conn.vhost + " [" + NNTP.class.getName() + "]");
+ for(String line = conn.readln(); line != null; line = conn.readln()) try {
+ StringTokenizer st = new StringTokenizer(line, " ");
+ String command = st.nextToken().toUpperCase();
+ if (command.equals("ARTICLE")) { article(st.hasMoreTokens() ? st.nextToken() : null, true, true);
+ } else if (command.equals("HEAD")) { article(st.hasMoreTokens() ? st.nextToken() : null, true, false);
+ } else if (command.equals("BODY")) { article(st.hasMoreTokens() ? st.nextToken() : null, false, true);
+ } else if (command.equals("STAT")) { article(st.hasMoreTokens() ? st.nextToken() : null, false, false);
+ } else if (command.equals("HELP")) { conn.println("100 you are beyond help."); conn.println(".");
+ } else if (command.equals("SLAVE")) { conn.println("220 I don't care");
+ } else if (command.equals("LAST")) { Article a = api.last(); conn.println("223 "+a.num+" "+a.messageid+" ok");
+ } else if (command.equals("NEXT")) { Article a = api.next(); conn.println("223 "+a.num+" "+a.messageid+" ok");
+ } else if (command.equals("QUIT")) { conn.println("205 Bye."); conn.close(); return;
+ } else if (command.equals("GROUP")) {
+ Group g = api.group(st.nextToken().toLowerCase());
+ conn.println("221 " + g.count + " " + g.first + " " + g.last + " " + g.name);
+ } else if (command.equals("NEWGROUPS") || command.equals("NEWNEWS")) {
+ String groups = command.equals("NEWNEWS") ? st.nextToken() : null;
+ String datetime = st.nextToken() + " " + st.nextToken();
+ String gmt = st.nextToken();
+ String distributions = gmt.equals("GMT") ? (st.hasMoreTokens() ? st.nextToken() : null) : gmt;
+ while(st.hasMoreTokens()) distributions += " " + st.nextToken();
+ // FIXME deal with GMT
+ Date d = new Date();
+ try {
+ d = new SimpleDateFormat("YYMMDD HHMMSS").parse(gmt);
+ } catch (ParseException pe) {
+ Log.warn(this, pe);
+ }
+ distributions = distributions.trim();
+ if (distributions.startsWith("<")) distributions = distributions.substring(1, distributions.length() - 1);
+
+ st = new StringTokenizer(distributions, ",");
+ String[] dists = new String[st.countTokens()];
+ for(int i=0; st.hasMoreTokens(); i++) dists[i] = st.nextToken();
+
+ if (command.equals("NEWGROUPS")) {
+ Group[] g = api.newgroups(d, dists);
+ conn.println("231 list of groups follows");
+ for(int i=0; i<g.length; i++)
+ conn.println(g[i].name + " " + g[i].last + " " + g[i].first + " " + (g[i].post ? "y" : "n"));
+ conn.println(".");
+ } else {
+ st = new StringTokenizer(groups, ",");
+ String[] g = new String[st.countTokens()];
+ for(int i=0; st.hasMoreTokens(); i++) g[i] = st.nextToken();
+ String[] a = api.newnews(g, d, dists);
+ conn.println("230 list of article messageids follows");
+ for(int i=0; i<a.length; i++) conn.println(a[i]);
+ conn.println(".");
+ }
+
+ } else if (command.equals("POST")) {
+ // FIXME
+ /*
+ boolean postok = api.post();
+ if (!postok) {
+ conn.println("440 no posting allowed");
+ } else {
+ */
+ conn.println("340 send the article");
+ // FIME read the article here
+ conn.println("240 article posted ok");
+ //}
+
+ } else if (command.equals("LIST")) {
+ Group[] g = api.list();
+ conn.println("215 list of groups follows");
+ for(int i=0; i<g.length; i++)
+ conn.println(g[i].name + " " + g[i].last + " " + g[i].first + " " + (g[i].post ? "y" : "n"));
+ conn.println(".");
+
+ } else if (command.equals("IHAVE")) {
+ boolean want = api.ihave(st.nextToken());
+ if (!want) {
+ conn.println("435 No thanks");
+ } else {
+ conn.println("335 Proceed");
+ // FIXME read article here
+ conn.println("235 Got it");
+ }
+ }
+ } catch (No n) { conn.println(n.code + " " + n.getMessage());
+ } catch (Bad b) { conn.println(b.code + " " + b.getMessage()); Log.warn(this, b); }
+ conn.close();
+ }
+ }
}
projects / org.ibex.mail.git / blobdiff