Compare commits
4
Commits
v1.1.1
..
031076b3ba
| Author | SHA1 | Date | |
|---|---|---|---|
 BlubbFish
|
031076b3ba | ||
|
BlubbFish
|
671388218e | ||
|
BlubbFish
|
4a87299d98 | ||
|
BlubbFish
|
ba1597ca3b |
@@ -1,41 +1,45 @@
|
|||||||
using System.Reflection;
|
using System.Reflection;
|
||||||
using System.Runtime.CompilerServices;
|
using System.Runtime.CompilerServices;
|
||||||
using System.Runtime.InteropServices;
|
using System.Runtime.InteropServices;
|
||||||
|
|
||||||
// Allgemeine Informationen über eine Assembly werden über die folgenden
|
|
||||||
// Attribute gesteuert. Ändern Sie diese Attributwerte, um die Informationen zu ändern,
|
|
||||||
// die einer Assembly zugeordnet sind.
|
|
||||||
[assembly: AssemblyTitle("Bot-Utils")]
|
|
||||||
[assembly: AssemblyDescription("")]
|
|
||||||
[assembly: AssemblyConfiguration("")]
|
|
||||||
[assembly: AssemblyCompany("")]
|
|
||||||
[assembly: AssemblyProduct("Bot-Utils")]
|
|
||||||
[assembly: AssemblyCopyright("Copyright © 2018 - 17.02.2019")]
|
|
||||||
[assembly: AssemblyTrademark("")]
|
|
||||||
[assembly: AssemblyCulture("")]
|
|
||||||
|
|
||||||
// Durch Festlegen von ComVisible auf FALSE werden die Typen in dieser Assembly
|
|
||||||
// für COM-Komponenten unsichtbar. Wenn Sie auf einen Typ in dieser Assembly von
|
|
||||||
// COM aus zugreifen müssen, sollten Sie das ComVisible-Attribut für diesen Typ auf "True" festlegen.
|
|
||||||
[assembly: ComVisible(false)]
|
|
||||||
|
|
||||||
// Die folgende GUID bestimmt die ID der Typbibliothek, wenn dieses Projekt für COM verfügbar gemacht wird
|
|
||||||
[assembly: Guid("bb7bfcb5-3db0-49e1-802a-3ce3eecc59f9")]
|
|
||||||
|
|
||||||
// Versionsinformationen für eine Assembly bestehen aus den folgenden vier Werten:
|
|
||||||
//
|
|
||||||
// Hauptversion
|
|
||||||
// Nebenversion
|
|
||||||
// Buildnummer
|
|
||||||
// Revision
|
|
||||||
//
|
|
||||||
// Sie können alle Werte angeben oder Standardwerte für die Build- und Revisionsnummern verwenden,
|
|
||||||
// indem Sie "*" wie unten gezeigt eingeben:
|
|
||||||
// [assembly: AssemblyVersion("1.0.*")]
|
|
||||||
[assembly: AssemblyVersion("1.1.1")]
|
|
||||||
[assembly: AssemblyFileVersion("1.1.1")]
|
|
||||||
|
|
||||||
/*
|
// Allgemeine Informationen über eine Assembly werden über die folgenden
|
||||||
* 1.1.0 Remove Helper from Bot-Utils
|
// Attribute gesteuert. Ändern Sie diese Attributwerte, um die Informationen zu ändern,
|
||||||
* 1.1.1 Update to local librarys
|
// die einer Assembly zugeordnet sind.
|
||||||
|
[assembly: AssemblyTitle("Bot-Utils")]
|
||||||
|
[assembly: AssemblyDescription("Bot-Utils are helpers for programming a bot")]
|
||||||
|
[assembly: AssemblyConfiguration("")]
|
||||||
|
[assembly: AssemblyCompany("BlubbFish")]
|
||||||
|
[assembly: AssemblyProduct("Bot-Utils")]
|
||||||
|
[assembly: AssemblyCopyright("Copyright © 2018 - 12.03.2019")]
|
||||||
|
[assembly: AssemblyTrademark("© BlubbFish")]
|
||||||
|
[assembly: AssemblyCulture("")]
|
||||||
|
|
||||||
|
// Durch Festlegen von ComVisible auf FALSE werden die Typen in dieser Assembly
|
||||||
|
// für COM-Komponenten unsichtbar. Wenn Sie auf einen Typ in dieser Assembly von
|
||||||
|
// COM aus zugreifen müssen, sollten Sie das ComVisible-Attribut für diesen Typ auf "True" festlegen.
|
||||||
|
[assembly: ComVisible(false)]
|
||||||
|
|
||||||
|
// Die folgende GUID bestimmt die ID der Typbibliothek, wenn dieses Projekt für COM verfügbar gemacht wird
|
||||||
|
[assembly: Guid("bb7bfcb5-3db0-49e1-802a-3ce3eecc59f9")]
|
||||||
|
|
||||||
|
// Versionsinformationen für eine Assembly bestehen aus den folgenden vier Werten:
|
||||||
|
//
|
||||||
|
// Hauptversion
|
||||||
|
// Nebenversion
|
||||||
|
// Buildnummer
|
||||||
|
// Revision
|
||||||
|
//
|
||||||
|
// Sie können alle Werte angeben oder Standardwerte für die Build- und Revisionsnummern verwenden,
|
||||||
|
// indem Sie "*" wie unten gezeigt eingeben:
|
||||||
|
// [assembly: AssemblyVersion("1.0.*")]
|
||||||
|
[assembly: AssemblyVersion("1.1.5")]
|
||||||
|
[assembly: AssemblyFileVersion("1.1.5")]
|
||||||
|
|
||||||
|
/*
|
||||||
|
* 1.1.0 Remove Helper from Bot-Utils
|
||||||
|
* 1.1.1 Update to local librarys
|
||||||
|
* 1.1.2 Fixing bug for Contenttype
|
||||||
|
* 1.1.3 Variables parsing now as a String
|
||||||
|
* 1.1.4 add Woff as Binary type
|
||||||
|
* 1.1.5 add a function to send an object as json directly
|
||||||
*/
|
*/
|
||||||
|
|||||||
+112
-98
@@ -1,98 +1,112 @@
|
|||||||
using BlubbFish.Utils.IoT.Connector;
|
using BlubbFish.Utils.IoT.Connector;
|
||||||
using BlubbFish.Utils.IoT.Events;
|
using BlubbFish.Utils.IoT.Events;
|
||||||
using System;
|
using LitJson;
|
||||||
using System.Collections.Generic;
|
using System;
|
||||||
using System.IO;
|
using System.Collections.Generic;
|
||||||
using System.Linq;
|
using System.IO;
|
||||||
using System.Net;
|
using System.Linq;
|
||||||
using System.Text;
|
using System.Net;
|
||||||
using System.Threading;
|
using System.Text;
|
||||||
using System.Threading.Tasks;
|
using System.Threading;
|
||||||
|
using System.Threading.Tasks;
|
||||||
namespace BlubbFish.Utils.IoT.Bots
|
|
||||||
{
|
namespace BlubbFish.Utils.IoT.Bots
|
||||||
public abstract class Webserver
|
{
|
||||||
{
|
public abstract class Webserver
|
||||||
protected Dictionary<String, String> config;
|
{
|
||||||
protected InIReader requests;
|
protected Dictionary<String, String> config;
|
||||||
protected HttpListener httplistener;
|
protected InIReader requests;
|
||||||
|
protected HttpListener httplistener;
|
||||||
public Webserver(ABackend backend, Dictionary<String, String> settings, InIReader requests) {
|
|
||||||
this.config = settings;
|
public Webserver(ABackend backend, Dictionary<String, String> settings, InIReader requests) {
|
||||||
this.requests = requests;
|
this.config = settings;
|
||||||
backend.MessageIncomming += this.Backend_MessageIncomming;
|
this.requests = requests;
|
||||||
this.httplistener = new HttpListener();
|
backend.MessageIncomming += this.Backend_MessageIncomming;
|
||||||
this.httplistener.Prefixes.Add(this.config["prefix"]);
|
this.httplistener = new HttpListener();
|
||||||
this.httplistener.Start();
|
this.httplistener.Prefixes.Add(this.config["prefix"]);
|
||||||
ThreadPool.QueueUserWorkItem((o) => {
|
this.httplistener.Start();
|
||||||
Console.WriteLine("Webserver is Running...");
|
ThreadPool.QueueUserWorkItem((o) => {
|
||||||
try {
|
Console.WriteLine("Webserver is Running...");
|
||||||
while (this.httplistener.IsListening) {
|
try {
|
||||||
ThreadPool.QueueUserWorkItem((state) => {
|
while (this.httplistener.IsListening) {
|
||||||
HttpListenerContext httplistenercontext = state as HttpListenerContext;
|
ThreadPool.QueueUserWorkItem((state) => {
|
||||||
try {
|
HttpListenerContext httplistenercontext = state as HttpListenerContext;
|
||||||
this.SendResponse(httplistenercontext);
|
try {
|
||||||
} catch { } finally {
|
this.SendResponse(httplistenercontext);
|
||||||
httplistenercontext.Response.OutputStream.Close();
|
} catch { } finally {
|
||||||
}
|
httplistenercontext.Response.OutputStream.Close();
|
||||||
}, this.httplistener.GetContext());
|
}
|
||||||
}
|
}, this.httplistener.GetContext());
|
||||||
} catch { };
|
}
|
||||||
});
|
} catch { };
|
||||||
}
|
});
|
||||||
|
}
|
||||||
protected virtual void SendResponse(HttpListenerContext cont) {
|
|
||||||
String restr = cont.Request.Url.PathAndQuery;
|
protected virtual void SendResponse(HttpListenerContext cont) {
|
||||||
if (restr.StartsWith("/")) {
|
String restr = cont.Request.Url.PathAndQuery;
|
||||||
if(restr.IndexOf("?") != -1) {
|
if (restr.StartsWith("/")) {
|
||||||
restr = restr.Substring(1, restr.IndexOf("?")-1);
|
if(restr.IndexOf("?") != -1) {
|
||||||
} else {
|
restr = restr.Substring(1, restr.IndexOf("?")-1);
|
||||||
restr = restr.Substring(1);
|
} else {
|
||||||
}
|
restr = restr.Substring(1);
|
||||||
if(restr == "") {
|
}
|
||||||
restr = "index.html";
|
if(restr == "") {
|
||||||
}
|
restr = "index.html";
|
||||||
String end = restr.IndexOf('.') != -1 ? restr.Substring(restr.IndexOf('.')+1) : "";
|
}
|
||||||
if (File.Exists("resources/"+ restr)) {
|
String end = restr.IndexOf('.') != -1 ? restr.Substring(restr.IndexOf('.')+1) : "";
|
||||||
try {
|
if (File.Exists("resources/"+ restr)) {
|
||||||
if (end == "png" || end == ".jpg" || end == ".jpeg" || end == ".ico") {
|
try {
|
||||||
Byte[] output = File.ReadAllBytes("resources/" + restr);
|
if (end == "png" || end == "jpg" || end == "jpeg" || end == "ico" || end == "woff") {
|
||||||
cont.Response.OutputStream.Write(output, 0, output.Length);
|
Byte[] output = File.ReadAllBytes("resources/" + restr);
|
||||||
cont.Response.ContentType = "image/"+end;
|
switch(end) {
|
||||||
return;
|
case "ico": cont.Response.ContentType = "image/x-ico"; break;
|
||||||
} else {
|
case "woff": cont.Response.ContentType = "font/woff"; break;
|
||||||
String file = File.ReadAllText("resources/" + restr);
|
}
|
||||||
if (this.requests.GetSections(false).Contains(restr)) {
|
cont.Response.OutputStream.Write(output, 0, output.Length);
|
||||||
Dictionary<String, String> vars = this.requests.GetSection(restr);
|
return;
|
||||||
foreach (KeyValuePair<String, String> item in vars) {
|
} else {
|
||||||
file = file.Replace("{%" + item.Key.ToUpper() + "%}", item.Value);
|
String file = File.ReadAllText("resources/" + restr);
|
||||||
}
|
if (this.requests.GetSections(false).Contains(restr)) {
|
||||||
}
|
Dictionary<String, String> vars = this.requests.GetSection(restr);
|
||||||
file = file.Replace("{%REQUEST_URL_HOST%}", cont.Request.Url.Host);
|
foreach (KeyValuePair<String, String> item in vars) {
|
||||||
Byte[] buf = Encoding.UTF8.GetBytes(file);
|
file = file.Replace("\"{%" + item.Key.ToUpper() + "%}\"", item.Value);
|
||||||
cont.Response.ContentLength64 = buf.Length;
|
}
|
||||||
cont.Response.OutputStream.Write(buf, 0, buf.Length);
|
}
|
||||||
Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
|
file = file.Replace("{%REQUEST_URL_HOST%}", cont.Request.Url.Host);
|
||||||
return;
|
Byte[] buf = Encoding.UTF8.GetBytes(file);
|
||||||
}
|
cont.Response.ContentLength64 = buf.Length;
|
||||||
} catch(Exception e) {
|
switch(end) {
|
||||||
Helper.WriteError("500 - " + e.Message);
|
case "css": cont.Response.ContentType = "text/css"; break;
|
||||||
cont.Response.StatusCode = 500;
|
}
|
||||||
return;
|
cont.Response.OutputStream.Write(buf, 0, buf.Length);
|
||||||
}
|
Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
|
||||||
}
|
return;
|
||||||
Helper.WriteError("404 - " + cont.Request.Url.PathAndQuery + " not found!");
|
}
|
||||||
cont.Response.StatusCode = 404;
|
} catch(Exception e) {
|
||||||
return;
|
Helper.WriteError("500 - " + e.Message);
|
||||||
}
|
cont.Response.StatusCode = 500;
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
}
|
||||||
public void Dispose() {
|
Helper.WriteError("404 - " + cont.Request.Url.PathAndQuery + " not found!");
|
||||||
this.httplistener.Stop();
|
cont.Response.StatusCode = 404;
|
||||||
this.httplistener.Close();
|
return;
|
||||||
}
|
}
|
||||||
|
return;
|
||||||
protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e);
|
}
|
||||||
}
|
|
||||||
}
|
protected void SendJsonResponse(Object data, HttpListenerContext cont) {
|
||||||
|
Byte[] buf = Encoding.UTF8.GetBytes(JsonMapper.ToJson(data));
|
||||||
|
cont.Response.ContentLength64 = buf.Length;
|
||||||
|
cont.Response.OutputStream.Write(buf, 0, buf.Length);
|
||||||
|
Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Dispose() {
|
||||||
|
this.httplistener.Stop();
|
||||||
|
this.httplistener.Close();
|
||||||
|
}
|
||||||
|
|
||||||
|
protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user