From a8b4c3eb1f6133435aadcd58b64a90e12ee2b07a Mon Sep 17 00:00:00 2001
From: DevSnaith <65865554+DevSnaith@users.noreply.github.com>
Date: Fri, 14 Apr 2023 02:37:04 +0300
Subject: [PATCH] Edit the name

---
 bin/org/eu/lumiere/net/RequestListener.class  | Bin 0 -> 3306 bytes
 bin/org/eu/lumiere/utils/SimpleResponse.class | Bin 0 -> 1344 bytes
 src/org/eu/lumiere/net/RequestListener.java   |  90 ++++++++++++++++++
 src/org/eu/lumiere/utils/SimpleResponse.java  |  23 +++++
 4 files changed, 113 insertions(+)
 create mode 100644 bin/org/eu/lumiere/net/RequestListener.class
 create mode 100644 bin/org/eu/lumiere/utils/SimpleResponse.class
 create mode 100644 src/org/eu/lumiere/net/RequestListener.java
 create mode 100644 src/org/eu/lumiere/utils/SimpleResponse.java

diff --git a/bin/org/eu/lumiere/net/RequestListener.class b/bin/org/eu/lumiere/net/RequestListener.class
new file mode 100644
index 0000000000000000000000000000000000000000..6d7301fc6bf693f1744165c90aa4736a66e0b747
GIT binary patch
literal 3306
zcmb7GTXz%J75<JSdt@;t*jxgs2{K@8$pO(|6B1JjIM}F>ZDJD}aC#Zb2U%u35;G$Q
zO53El^pf7vdr9vv^-Eu9u*hY#YxRY!)z|)k{*FG>{q~G33)yYcwd^@(&g{L<-rxTA
z-um0WKKu)S0sP)TMB!k`Eo5{hV^@}n+SM6H`<Y37v!XpeSM+@CXxBhYVaKAiY-McA
zDP$(*7Ioe?(5le6aXMLX9Ba<j3d&aK$u-%vOND}Vz09axnzQU&@HV87@E2Td&5v74
zRP4-cn49w5qEnzmThSBKe4*uQ3az2WqtcfHE0m6vORi7BECoI7E^Ale@zAV9HWeIA
zmGU>VPie(VyPG}Tkh`#~9p9r|>*=CX^v@_f)3@2h|EZr%P1CXA(!5R}ihU+_;|Yam
zUursmE<9;qzrvwU0GEjaND`2O_Cx#>dizq%*KY}Q8<=Sm2I6rXR@j{jvz-hfN`{b%
z&=C`DNXV|w#5S0+OPhEMJ7o8iiJjP`@K~<s=<&+ZoOUmVIq%Gs@|HbqxkY)e9mf2H
zqNi}U*~Kk5CaH4*60}eGR{qAARSt|87<hzxAuSA?R5;KCS##bLT0Gx!eR2F*6YbdE
zh9P{$z-b23q`MVpbi0t#%i1<^2A@?hX3kBHXU9hsjx`7LU)6^UoFfUFseQguwCA;(
zzzGbScpevc!?I;p^u%?hp^;}{y$z){Q!jzD7!^KUWKJ7ZYSojPj^lF*JCj8(Y1vX}
zx07yIOrn}IF@|x{+bWl}Gp}%TD;t}xt$98qCN7zH5t9mWzZBl7u#22*4wkZAxNPDj
zuoPO$EN!1r-tPPVfZS}h;iQJr?B=6JcWP1wt`M=n%MIFuZ6SdfToX)ZNy$FeuJGsc
zCOXh5{Q07ZF9{o3E=*2NOd6PDVQoa4wQXIn>~n6Rvc%qT;Z|Ok{bI?9gXs2#-6tt6
zD!Ekg{N$YGpZ|*1PV#uta^{mK2M13KCU6}K2H5X*Zdk6HGEo%36YK(G+ViY}HgMyS
z8VQ?W0*hFZI2?skV_w%A^-u#+b-svJ*~Bx_p(6U0w2Cc!kZSe(Qdy)cCYD9IjXBk>
zTPgd3;4Krk<+LSlmpt~pI}*`X)*~vGGTDiGMD<G^J?14*l2t%|&BWIQ^jLO$WFn3?
z6wGAB<46dxOfW-lnfM02$r>Uqmx39<2AdU%ep^`nwn7(^*$_+^@&=a`zH7q66XN~%
zP5c1wNMYn9fpmMF(*aw;@v#kq_>qYp<0o{d<P4V_hhve+mJ$drYLJ#@zlfii_&I)|
z&|dVi>u_mOgT7vi<6VW0<bvgq6l8<|T$YcDJ+xz!K~i9<RB`iqq$opoSJTiwCTXK%
zS$gFT+m`2Pnu)LXG;|ZQDF0hH6e2Ph_?sXiy+2sl`Gb{BGg#UGgOx=PtegT|Td2Pq
zd-!~uZ-1wLjO(fN1ME$|k58?lJKcF`6+P+bDtgl$2i{plD&7Av66yQsSwXB{zU`O8
zr&iH_kGfGD<?{&r04>Mp#WptX4tlYN&;5KJ<y}u>FB!TI$0(H!??eX2`NrGvX~v*}
zop>1ucH)1OdZ2z}4JpJ7C<7-93=&`N*Z8UNEE0YvOe}>kK-J5D#oSwTzxUlBic=4f
z=3Dol@Z3i@dsX6kALk!nq%&K^3sp?0=${d-Vru4I`XkJUK<WXmuHxktj>S;(3;lnE
zbr<o@{0fZzDs)|kDvMXee$NBgs{}SCINrypDoXe0)F8*kD4Ruy+S5VKx`@?&{<?dT
zUk~#8AzZ{^Orr<$To=%XTMYlJ#O+P=2MF#7gQ_8T5lP&HOY4Hx09v;ndC|c2H4gp|
zlk2i}85mmQz3WHO@Q8^1lT7NCItoF<KWd;Y(eK{7A!r|ea?pZc{g6OPAh?g0AL5`a
zRlKr-y>$?)_;MXM0cQ-CS;=>5;2a~7z;L%S%mGqmkYo2WcjvepVUEY}EajiW6?Pk&
z^IoVG0<%;D<_gKQlfZ?*v>~?rh-Ki;E*^YsJz6zbi*|($k`%8tk>YidB3;FsReY<F
z8!I?30ZCz0@tqY6gyDTpV(Wj%8sXCa0e%?4e+rlq1h<_Fx$)DxYwvNl#r=1iNy*e7
zXT;Zt(;1n2b-Yfp?11wumtjf>LZg(sNU0b2mLpzcl%K#XE}=x3*D!@Y5JAB$Nz6f4
z!;&0f;r<f8B22SH@Mays1X_-_&kBM&_>H}rPiZ3=u2Q}&3?cPLZX!WXXblc$f(y)0
Zpmsq7zYe5+gWqzM+8^SNjo+Q!_ivr27D)gA

literal 0
HcmV?d00001

diff --git a/bin/org/eu/lumiere/utils/SimpleResponse.class b/bin/org/eu/lumiere/utils/SimpleResponse.class
new file mode 100644
index 0000000000000000000000000000000000000000..ce74134ebf4e8d9c0e15f4e4db8691fc35d030f0
GIT binary patch
literal 1344
zcma)6TTc@~6#k~$c1vAuEk%^OP<jDb?}|lCBr!Z7CX_T0AI!EL>Ed>`?#>eVDZZQV
ztPwOO`fB2j63^^bE~Sa~GCh0F%y+)?oiqLQ``Zrycd()&!Z72wJ39Au%Ws<8<+?9S
z%hStdvt{v3?zJ4-<0_&I1G~nap<9N%qd%|i@|sW)XDD_Yx4F<8LbUWXS~mGxpL=4>
zu<I6g8KPCEzR!?aKZPm_*R*#^480A}v|hRGj0|j>A--(drdVMZ&R;yTU8oS^s#E7l
zDCpO42?GpDzEDXZ#W3>3@XXrZ3Z_hN%JprVa`k{=NP~)mw1zeGAj#0bZrXgqZ&tax
zWmGLLSvobtsu->*pWDu;XqX;DcD<wQZmLmHF;`Ya#g&Cod-Kd_1u!Zm&dC{Sz%c08
zZN)ZujhlPC&ajd1Ow~={(mytZZ7fM?t}&>BzY}`aOJJ51lnfJ?BdbNtO=28*4FwcQ
z{@0G%Gz7y^7x`bF=}0&arNS9kyRS(sU{S?&hS?6qI?4zcYS3|mq0i%D)v*P)#nyg{
zdXecupiq(Ew=~?AN1`p?Yfx!!IC5QD)R8clOlnc$bmZp#Pem0=7q3k>bQOf3?jjUJ
zvh4V7jXyQzq@~Z_wnce6Fipd$&^Lw%y=hwM&PL>{2EUA^U886(J$)d*LciJK7xWcV
zgNH~Ll|y8T^FNU+en$EL(Rt|{Bj-ojsNgcKR}rUGLo@(QqMyJf(T7>GMkq2Bg5nD8
zl&@?+f(6zn(THG->>MJ;7=@yOsTikgOU5zzPaKgjLR=>aGGzRTQcK3Uh17KPJCqj+
z(agL@A~kb>SSnloirf+A7bN*3+&tyn7aU7t0z;TX<_yo=3C|q;wcVvelG{DpZ}WUC
md1l(Q9;h@qF<OYSiih+e&Lnq0H3-Jf1!)_FmkBb0M}Gk2jy{Y4

literal 0
HcmV?d00001

diff --git a/src/org/eu/lumiere/net/RequestListener.java b/src/org/eu/lumiere/net/RequestListener.java
new file mode 100644
index 0000000..6e7976c
--- /dev/null
+++ b/src/org/eu/lumiere/net/RequestListener.java
@@ -0,0 +1,90 @@
+package org.eu.lumiere.net;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+import org.eu.lumiere.loggers.GlobalLogger;
+import org.eu.lumiere.loggers.GlobalLogger.LogLevel;
+
+public class RequestListener implements Runnable {
+	
+	private GlobalLogger l = GlobalLogger.getLogger();
+	private String threadName = "Lumiere server thread";
+	private boolean isRunning = false;
+	private Thread thread;
+	
+	private int port = 8080;
+	private ServerSocket server;
+	private ServerEvents e;
+	
+	public RequestListener(String name, ServerEvents e, int port) {
+		this.threadName = name == null ? this.threadName : name;
+		this.port = port;
+		this.e = e;
+	}
+	
+	public synchronized void start() {
+		if(isRunning || thread != null) {
+			l.printf(LogLevel.WARNING, threadName + " is already running", null);
+			return;
+		}
+		
+		try {
+			server = new ServerSocket(port);
+		} catch (Exception ex) {
+			l.printf(LogLevel.ERROR, ex instanceof IllegalArgumentException ? 
+					"Server port must be between 0 and 65535" : ex.getMessage(), null);
+		}
+		
+		thread = new Thread(this, threadName);
+		isRunning = true;
+		thread.start();
+	}
+	
+	public synchronized void stop() {
+		if(!isRunning || thread == null) {
+			l.printf(LogLevel.WARNING, threadName + " is already running", null);
+			return;
+		}
+		
+		thread.interrupt();
+		isRunning = false;
+		thread = null;
+		
+		if(server != null) {
+			try {
+				server.close();
+			} catch (IOException e) {
+				l.printf(LogLevel.ERROR, e.getMessage(), null);
+			}
+		}
+	}
+	
+	@Override
+	public void run() {
+		l.printf(LogLevel.INFO, threadName + " using port " + getPort(), null);
+		while(isRunning && !thread.isInterrupted()) {
+			try {
+				
+				if(server == null) {
+					stop();
+					continue;
+				}
+				
+				Socket s = server.accept();
+				if(e != null)
+					e.onConnection(s);
+//				l.printf(LogLevel.INFO, "New Connection " + s.getInetAddress().getHostAddress(), null);
+			} catch (IOException ex) {
+				l.printf(LogLevel.ERROR, ex.getMessage(), null);
+			}			
+		}
+		l.printf(LogLevel.INFO, threadName + " has been stopped", null);
+	}
+	
+	public int getPort() {
+		return this.port;
+	}
+	
+}
diff --git a/src/org/eu/lumiere/utils/SimpleResponse.java b/src/org/eu/lumiere/utils/SimpleResponse.java
new file mode 100644
index 0000000..2c71951
--- /dev/null
+++ b/src/org/eu/lumiere/utils/SimpleResponse.java
@@ -0,0 +1,23 @@
+package org.eu.lumiere.utils;
+
+import org.eu.lumiere.net.http.HttpRequest;
+import org.eu.lumiere.net.http.HttpRequestHandler;
+import org.eu.lumiere.net.http.HttpResponse;
+
+public class SimpleResponse implements HttpRequestHandler {
+	
+	private String body = "BasicResponse is running";
+	private boolean html_response = false;
+	
+	public SimpleResponse(String body, boolean rhtml) {
+		this.body = body == null ? this.body : body;
+		this.html_response = rhtml;
+	}
+	
+	@Override
+	public void onRequestReceived(HttpRequest request, HttpResponse response) {
+		response.setContentType(String.format("text/%s", html_response ? "html" : "plan"));
+		response.push(body);
+	}	
+	
+}