Add parameter listener

Author: simonwep

src/express/Express.java

@@ -26,6 +26,7 @@
  */
 public class Express extends ExpressMiddleware {
 
+  private final ConcurrentHashMap<String, HttpRequest> PARAMETER_LISTENER = new ConcurrentHashMap<>();
   private final ConcurrentHashMap<Object, Object> LOCALS = new ConcurrentHashMap<>();
 
   private final ArrayList<ExpressFilterWorker> WORKER = new ArrayList<>();
@@ -55,6 +56,20 @@ public Express(String hostname) {
   public Express() {
   }
 
+  /**
+   * Add an listener which will be called when an url with this parameter is called.
+   *
+   * @param param   The parameter name.
+   * @param request An request handler.
+   */
+  public void onParam(String param, HttpRequest request) {
+    PARAMETER_LISTENER.put(param, request);
+  }
+
+  public ConcurrentHashMap<String, HttpRequest> getParameterListener() {
+    return PARAMETER_LISTENER;
+  }
+
   /**
    * Add an key-val pair to the express app, can be used
    * to store data. Uses ConcurrentHashMap so it's thread save.
@@ -127,7 +142,7 @@ private void addMiddleware(String requestMethod, String context, HttpRequest mid
       WORKER.add(new ExpressFilterWorker((ExpressFilterTask) middleware));
     }
 
-    MIDDLEWARE_CHAIN.add(new ExpressFilterImpl(requestMethod, context, middleware));
+    MIDDLEWARE_CHAIN.add(new ExpressFilterImpl(this, requestMethod, context, middleware));
   }
 
   /**
@@ -137,7 +152,7 @@ private void addMiddleware(String requestMethod, String context, HttpRequest mid
    * @param request An listener which will be fired if the context matches the requestpath.
    */
   public void all(String context, HttpRequest request) {
-    FILTER_CHAIN.add(new ExpressFilterImpl("*", context, request));
+    FILTER_CHAIN.add(new ExpressFilterImpl(this, "*", context, request));
   }
 
   /**
@@ -147,7 +162,7 @@ public void all(String context, HttpRequest request) {
    * @param request An listener which will be fired if the context matches the requestpath.
    */
   public void get(String context, HttpRequest request) {
-    FILTER_CHAIN.add(new ExpressFilterImpl("GET", context, request));
+    FILTER_CHAIN.add(new ExpressFilterImpl(this, "GET", context, request));
   }
 
   /**
@@ -157,7 +172,7 @@ public void get(String context, HttpRequest request) {
    * @param request An listener which will be fired if the context matches the requestpath.
    */
   public void post(String context, HttpRequest request) {
-    FILTER_CHAIN.add(new ExpressFilterImpl("POST", context, request));
+    FILTER_CHAIN.add(new ExpressFilterImpl(this, "POST", context, request));
   }
 
   /**
@@ -167,7 +182,7 @@ public void post(String context, HttpRequest request) {
    * @param request An listener which will be fired if the context matches the requestpath.
    */
   public void put(String context, HttpRequest request) {
-    FILTER_CHAIN.add(new ExpressFilterImpl("PUT", context, request));
+    FILTER_CHAIN.add(new ExpressFilterImpl(this, "PUT", context, request));
   }
 
   /**
@@ -177,7 +192,7 @@ public void put(String context, HttpRequest request) {
    * @param request An listener which will be fired if the context matches the requestpath.
    */
   public void delete(String context, HttpRequest request) {
-    FILTER_CHAIN.add(new ExpressFilterImpl("DELETE", context, request));
+    FILTER_CHAIN.add(new ExpressFilterImpl(this, "DELETE", context, request));
   }
 
   /**
@@ -187,7 +202,7 @@ public void delete(String context, HttpRequest request) {
    * @param request An listener which will be fired if the context matches the requestpath.
    */
   public void patch(String context, HttpRequest request) {
-    FILTER_CHAIN.add(new ExpressFilterImpl("PATCH", context, request));
+    FILTER_CHAIN.add(new ExpressFilterImpl(this, "PATCH", context, request));
   }
 
   /**
@@ -198,7 +213,7 @@ public void patch(String context, HttpRequest request) {
    * @param request       An listener which will be fired if the context matches the requestpath.
    */
   public void on(String requestMethod, String context, HttpRequest request) {
-    FILTER_CHAIN.add(new ExpressFilterImpl(requestMethod, context, request));
+    FILTER_CHAIN.add(new ExpressFilterImpl(this, requestMethod, context, request));
   }
 
   /**
@@ -211,7 +226,7 @@ public void on(String requestMethod, String context, HttpRequest request) {
    */
   public void on(String requestMethod, HttpRequest request, String... contexts) {
     for (String c : contexts)
-      FILTER_CHAIN.add(new ExpressFilterImpl(requestMethod, c, request));
+      FILTER_CHAIN.add(new ExpressFilterImpl(this, requestMethod, c, request));
   }
 
   /**

src/express/expressfilter/ExpressFilterImpl.java

@@ -1,10 +1,12 @@
 package express.expressfilter;
 
+import express.Express;
 import express.events.HttpRequest;
 import express.http.request.Request;
 import express.http.response.Response;
 
 import java.util.HashMap;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * @author Simon Reinisch
@@ -14,13 +16,16 @@
  */
 public class ExpressFilterImpl implements HttpRequest {
 
+  private final Express APP;
+
   private final HttpRequest REQUEST;
   private final String REQ;
   private final String CONTEXT;
   private final boolean REQ_ALL;
   private final boolean CONTEXT_ALL;
 
-  public ExpressFilterImpl(String requestMethod, String context, HttpRequest httpRequest) {
+  public ExpressFilterImpl(Express app, String requestMethod, String context, HttpRequest httpRequest) {
+    this.APP = app;
     this.REQ = requestMethod;
     this.REQUEST = httpRequest;
     this.CONTEXT = context;
@@ -48,7 +53,21 @@ public void handle(Request req, Response res) {
     if (params == null)
       return;
 
+    // Save parameter to request object
     req.setParams(params);
+    
+    // Check parameter lsitener
+    params.forEach((s, s2) -> {
+      HttpRequest hreq = APP.getParameterListener().get(s);
+      if (hreq != null)
+        hreq.handle(req, res);
+    });
+
+    // Check if the response is closed
+    if (res.isClosed())
+      return;
+
+    // Handle request
     REQUEST.handle(req, res);
   }
 

src/express/http/Cookie.java

@@ -19,7 +19,6 @@ public class Cookie {
 
   /**
    * Creates an new http-cookie
-   * *
    *
    * @param name  Cookie name
    * @param value Cookie value