X-Git-Url: http://git.dolda2000.com/gitweb/?a=blobdiff_plain;f=src%2Fdolda%2Fjsvc%2Futil%2FPerSession.java;fp=src%2Fdolda%2Fjsvc%2Futil%2FPerSession.java;h=7973e0ab78553e4952fcccb5d365dbb0fd1b1791;hb=c04f28ae77d5a372eb4afd0296c12014fdbcf96e;hp=0000000000000000000000000000000000000000;hpb=d5dd6a2dada08df30133b739d0ce1fa8f2a0d2e9;p=jsvc.git

diff --git a/src/dolda/jsvc/util/PerSession.java b/src/dolda/jsvc/util/PerSession.java
new file mode 100644
index 0000000..7973e0a
--- /dev/null
+++ b/src/dolda/jsvc/util/PerSession.java
@@ -0,0 +1,100 @@
+package dolda.jsvc.util;
+
+import dolda.jsvc.*;
+import java.lang.reflect.*;
+
+public class PerSession implements Responder {
+    private final Class<?> rcl;
+    private final Class<?> dcl;
+    
+    public PerSession(Class<?> rcl, Class<?> dcl) {
+	this.rcl = rcl;
+	this.dcl = dcl;
+    }
+    
+    public PerSession(Class<?> rcl) {
+	this(rcl, null);
+    }
+    
+    private Object makedata(Session sess) {
+	try {
+	    try {
+		return(dcl.getConstructor().newInstance());
+	    } catch(NoSuchMethodException e) {
+	    }
+	    try {
+		return(dcl.getConstructor(Session.class).newInstance(sess));
+	    } catch(NoSuchMethodException e) {
+	    }
+	} catch(InstantiationException e) {
+	    throw(new RuntimeException(e));
+	} catch(IllegalAccessException e) {
+	    throw(new RuntimeException(e));
+	} catch(InvocationTargetException e) {
+	    throw(new RuntimeException(e));
+	}
+	throw(new RuntimeException("Found no way to create an instance of " + dcl.getName()));
+    }
+
+    private Object getdata(Session sess) {
+	Object d = sess.get(dcl, null);
+	if(d == null) {
+	    d = makedata(sess);
+	    sess.put(dcl, d);
+	}
+	return(d);
+    }
+
+    private Responder create(Session sess) {
+	try {
+	    if(dcl != null) {
+		try {
+		    return((Responder)rcl.getMethod("responder", dcl).invoke(null, getdata(sess)));
+		} catch(NoSuchMethodException e) {
+		}
+	    }
+	    try {
+		return((Responder)rcl.getMethod("responder", Session.class).invoke(null, sess));
+	    } catch(NoSuchMethodException e) {
+	    }
+	    try {
+		return((Responder)rcl.getMethod("responder").invoke(null));
+	    } catch(NoSuchMethodException e) {
+	    }
+	    if(dcl != null) {
+		try {
+		    return((Responder)rcl.getConstructor(dcl).newInstance(getdata(sess)));
+		} catch(NoSuchMethodException e) {
+		}
+	    }
+	    try {
+		return((Responder)rcl.getConstructor(Session.class).newInstance(sess));
+	    } catch(NoSuchMethodException e) {
+	    }
+	    try {
+		return((Responder)rcl.getConstructor().newInstance());
+	    } catch(NoSuchMethodException e) {
+	    }
+	} catch(InstantiationException e) {
+	    throw(new RuntimeException(e));
+	} catch(IllegalAccessException e) {
+	    throw(new RuntimeException(e));
+	} catch(InvocationTargetException e) {
+	    throw(new RuntimeException(e));
+	}
+	throw(new RuntimeException("Found no way to create a responder from the class " + rcl.getName()));
+    }
+
+    public void respond(Request req) {
+	Session sess = Session.get(req);
+	Responder resp;
+	synchronized(sess) {
+	    resp = (Responder)sess.get(rcl, null);
+	    if(resp == null) {
+		resp = create(sess);
+		sess.put(rcl, resp);
+	    }
+	}
+	resp.respond(req);
+    }
+}