44import com .sun .net .httpserver .HttpServer ;
55import com .sun .net .httpserver .HttpsConfigurator ;
66import com .sun .net .httpserver .HttpsServer ;
7- import express .events .Action ;
8- import express .events .HttpRequest ;
9- import express .expressfilter .ExpressFilterImpl ;
10- import express .expressfilter .ExpressFilterTask ;
11- import express .expressfilter .ExpressFilterWorker ;
12- import express .expressfilter .FilterLayerHandler ;
7+ import express .http .HttpRequest ;
8+ import express .filter .FilterImpl ;
9+ import express .filter .FilterTask ;
10+ import express .filter .FilterWorker ;
11+ import express .filter .FilterLayerHandler ;
1312import express .middleware .ExpressMiddleware ;
1413
1514import java .io .IOException ;
@@ -30,7 +29,7 @@ public class Express extends ExpressMiddleware implements Router {
3029 private final ConcurrentHashMap <String , HttpRequest > PARAMETER_LISTENER ;
3130 private final ConcurrentHashMap <Object , Object > LOCALS ;
3231
33- private final ArrayList <ExpressFilterWorker > WORKER ;
32+ private final ArrayList <FilterWorker > WORKER ;
3433 private final FilterLayerHandler HANDLER ;
3534
3635 private Executor executor ;
@@ -169,47 +168,47 @@ public void use(@NotNull String context, @NotNull String requestMethod, @NotNull
169168
170169 // Internal service to handle middleware
171170 private void addMiddleware (@ NotNull String requestMethod , @ NotNull String context , HttpRequest middleware ) {
172- if (middleware instanceof ExpressFilterTask ) {
173- WORKER .add (new ExpressFilterWorker (( ExpressFilterTask ) middleware ));
171+ if (middleware instanceof FilterTask ) {
172+ WORKER .add (new FilterWorker (( FilterTask ) middleware ));
174173 }
175174
176- HANDLER .add (0 , new ExpressFilterImpl (requestMethod , context , middleware ));
175+ HANDLER .add (0 , new FilterImpl (requestMethod , context , middleware ));
177176 }
178177
179178 public void all (@ NotNull HttpRequest request ) {
180- HANDLER .add (1 , new ExpressFilterImpl ("*" , "*" , request ));
179+ HANDLER .add (1 , new FilterImpl ("*" , "*" , request ));
181180 }
182181
183182 public void all (@ NotNull String context , @ NotNull HttpRequest request ) {
184- HANDLER .add (1 , new ExpressFilterImpl ("*" , context , request ));
183+ HANDLER .add (1 , new FilterImpl ("*" , context , request ));
185184 }
186185
187186 public void all (@ NotNull String context , @ NotNull String requestMethod , @ NotNull HttpRequest request ) {
188- HANDLER .add (1 , new ExpressFilterImpl (requestMethod , context , request ));
187+ HANDLER .add (1 , new FilterImpl (requestMethod , context , request ));
189188 }
190189
191190 public void get (@ NotNull String context , @ NotNull HttpRequest request ) {
192- HANDLER .add (1 , new ExpressFilterImpl ("GET" , context , request ));
191+ HANDLER .add (1 , new FilterImpl ("GET" , context , request ));
193192 }
194193
195194 public void post (@ NotNull String context , @ NotNull HttpRequest request ) {
196- HANDLER .add (1 , new ExpressFilterImpl ("POST" , context , request ));
195+ HANDLER .add (1 , new FilterImpl ("POST" , context , request ));
197196 }
198197
199198 public void put (@ NotNull String context , @ NotNull HttpRequest request ) {
200- HANDLER .add (1 , new ExpressFilterImpl ("PUT" , context , request ));
199+ HANDLER .add (1 , new FilterImpl ("PUT" , context , request ));
201200 }
202201
203202 public void delete (@ NotNull String context , @ NotNull HttpRequest request ) {
204- HANDLER .add (1 , new ExpressFilterImpl ("DELETE" , context , request ));
203+ HANDLER .add (1 , new FilterImpl ("DELETE" , context , request ));
205204 }
206205
207206 public void patch (@ NotNull String context , @ NotNull HttpRequest request ) {
208- HANDLER .add (1 , new ExpressFilterImpl ("PATCH" , context , request ));
207+ HANDLER .add (1 , new FilterImpl ("PATCH" , context , request ));
209208 }
210209
211210 public void on (@ NotNull String context , @ NotNull String requestMethod , @ NotNull HttpRequest request ) {
212- HANDLER .add (1 , new ExpressFilterImpl (requestMethod , context , request ));
211+ HANDLER .add (1 , new FilterImpl (requestMethod , context , request ));
213212 }
214213
215214 /**
@@ -240,7 +239,7 @@ public void listen(int port) throws IOException {
240239 * @param onStart An listener which will be fired after the server is stardet.
241240 * @throws IOException - If an IO-Error occurs, eg. the port is already in use.
242241 */
243- public void listen (Action onStart ) throws IOException {
242+ public void listen (ExpressListener onStart ) throws IOException {
244243 listen (onStart , 80 );
245244 }
246245
@@ -252,11 +251,11 @@ public void listen(Action onStart) throws IOException {
252251 * @param port The port.
253252 * @throws IOException - If an IO-Error occurs, eg. the port is already in use.
254253 */
255- public void listen (Action onStart , int port ) throws IOException {
254+ public void listen (ExpressListener onStart , int port ) throws IOException {
256255 new Thread (() -> {
257256 try {
258257 // Fire worker threads
259- WORKER .forEach (ExpressFilterWorker ::start );
258+ WORKER .forEach (FilterWorker ::start );
260259
261260 InetSocketAddress socketAddress = new InetSocketAddress (this .hostname , port );
262261
@@ -303,7 +302,7 @@ public void stop() {
303302 httpServer .stop (0 );
304303
305304 // Stop worker threads
306- WORKER .forEach (ExpressFilterWorker ::stop );
305+ WORKER .forEach (FilterWorker ::stop );
307306 }
308307 }
309308}
0 commit comments