Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
41c8ccfee7 | ||
|
|
b3d60ad1ae | ||
|
|
b8fb0e7278 | ||
|
|
031076b3ba | ||
|
|
671388218e |
@@ -37,6 +37,7 @@
|
|||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<Reference Include="System" />
|
<Reference Include="System" />
|
||||||
<Reference Include="System.Core" />
|
<Reference Include="System.Core" />
|
||||||
|
<Reference Include="System.Web" />
|
||||||
<Reference Include="System.Xml.Linq" />
|
<Reference Include="System.Xml.Linq" />
|
||||||
<Reference Include="System.Data.DataSetExtensions" />
|
<Reference Include="System.Data.DataSetExtensions" />
|
||||||
<Reference Include="Microsoft.CSharp" />
|
<Reference Include="Microsoft.CSharp" />
|
||||||
|
|||||||
@@ -10,7 +10,7 @@ using System.Runtime.InteropServices;
|
|||||||
[assembly: AssemblyConfiguration("")]
|
[assembly: AssemblyConfiguration("")]
|
||||||
[assembly: AssemblyCompany("BlubbFish")]
|
[assembly: AssemblyCompany("BlubbFish")]
|
||||||
[assembly: AssemblyProduct("Bot-Utils")]
|
[assembly: AssemblyProduct("Bot-Utils")]
|
||||||
[assembly: AssemblyCopyright("Copyright © 2018 - 09.03.2019")]
|
[assembly: AssemblyCopyright("Copyright © 2018 - 12.03.2019")]
|
||||||
[assembly: AssemblyTrademark("© BlubbFish")]
|
[assembly: AssemblyTrademark("© BlubbFish")]
|
||||||
[assembly: AssemblyCulture("")]
|
[assembly: AssemblyCulture("")]
|
||||||
|
|
||||||
@@ -32,12 +32,15 @@ using System.Runtime.InteropServices;
|
|||||||
// Sie können alle Werte angeben oder Standardwerte für die Build- und Revisionsnummern verwenden,
|
// Sie können alle Werte angeben oder Standardwerte für die Build- und Revisionsnummern verwenden,
|
||||||
// indem Sie "*" wie unten gezeigt eingeben:
|
// indem Sie "*" wie unten gezeigt eingeben:
|
||||||
// [assembly: AssemblyVersion("1.0.*")]
|
// [assembly: AssemblyVersion("1.0.*")]
|
||||||
[assembly: AssemblyVersion("1.1.3")]
|
[assembly: AssemblyVersion("1.1.6")]
|
||||||
[assembly: AssemblyFileVersion("1.1.3")]
|
[assembly: AssemblyFileVersion("1.1.6")]
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* 1.1.0 Remove Helper from Bot-Utils
|
* 1.1.0 Remove Helper from Bot-Utils
|
||||||
* 1.1.1 Update to local librarys
|
* 1.1.1 Update to local librarys
|
||||||
* 1.1.2 Fixing bug for Contenttype
|
* 1.1.2 Fixing bug for Contenttype
|
||||||
* 1.1.3 Variables parsing now as a String
|
* 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
|
||||||
|
* 1.1.6 rename functions and make SendFileResponse with a parameter for the folder,
|
||||||
*/
|
*/
|
||||||
|
|||||||
+64
-27
@@ -1,25 +1,24 @@
|
|||||||
using BlubbFish.Utils.IoT.Connector;
|
using System;
|
||||||
using BlubbFish.Utils.IoT.Events;
|
|
||||||
using System;
|
|
||||||
using System.Collections.Generic;
|
using System.Collections.Generic;
|
||||||
using System.IO;
|
using System.IO;
|
||||||
using System.Linq;
|
|
||||||
using System.Net;
|
using System.Net;
|
||||||
using System.Text;
|
using System.Text;
|
||||||
using System.Threading;
|
using System.Threading;
|
||||||
using System.Threading.Tasks;
|
using System.Web;
|
||||||
|
using BlubbFish.Utils.IoT.Connector;
|
||||||
|
using BlubbFish.Utils.IoT.Events;
|
||||||
|
using LitJson;
|
||||||
|
|
||||||
namespace BlubbFish.Utils.IoT.Bots
|
namespace BlubbFish.Utils.IoT.Bots {
|
||||||
{
|
|
||||||
public abstract class Webserver
|
public abstract class Webserver
|
||||||
{
|
{
|
||||||
protected Dictionary<String, String> config;
|
protected Dictionary<String, String> config;
|
||||||
protected InIReader requests;
|
protected static InIReader requests;
|
||||||
protected HttpListener httplistener;
|
protected HttpListener httplistener;
|
||||||
|
|
||||||
public Webserver(ABackend backend, Dictionary<String, String> settings, InIReader requests) {
|
public Webserver(ABackend backend, Dictionary<String, String> settings, InIReader requestslookup) {
|
||||||
this.config = settings;
|
this.config = settings;
|
||||||
this.requests = requests;
|
requests = requestslookup;
|
||||||
backend.MessageIncomming += this.Backend_MessageIncomming;
|
backend.MessageIncomming += this.Backend_MessageIncomming;
|
||||||
this.httplistener = new HttpListener();
|
this.httplistener = new HttpListener();
|
||||||
this.httplistener.Prefixes.Add(this.config["prefix"]);
|
this.httplistener.Prefixes.Add(this.config["prefix"]);
|
||||||
@@ -31,7 +30,7 @@ namespace BlubbFish.Utils.IoT.Bots
|
|||||||
ThreadPool.QueueUserWorkItem((state) => {
|
ThreadPool.QueueUserWorkItem((state) => {
|
||||||
HttpListenerContext httplistenercontext = state as HttpListenerContext;
|
HttpListenerContext httplistenercontext = state as HttpListenerContext;
|
||||||
try {
|
try {
|
||||||
this.SendResponse(httplistenercontext);
|
this.SendWebserverResponse(httplistenercontext);
|
||||||
} catch { } finally {
|
} catch { } finally {
|
||||||
httplistenercontext.Response.OutputStream.Close();
|
httplistenercontext.Response.OutputStream.Close();
|
||||||
}
|
}
|
||||||
@@ -41,7 +40,7 @@ namespace BlubbFish.Utils.IoT.Bots
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
protected virtual void SendResponse(HttpListenerContext cont) {
|
public static Boolean SendFileResponse(HttpListenerContext cont, String folder = "resources") {
|
||||||
String restr = cont.Request.Url.PathAndQuery;
|
String restr = cont.Request.Url.PathAndQuery;
|
||||||
if(restr.StartsWith("/")) {
|
if(restr.StartsWith("/")) {
|
||||||
if(restr.IndexOf("?") != -1) {
|
if(restr.IndexOf("?") != -1) {
|
||||||
@@ -49,23 +48,28 @@ namespace BlubbFish.Utils.IoT.Bots
|
|||||||
} else {
|
} else {
|
||||||
restr = restr.Substring(1);
|
restr = restr.Substring(1);
|
||||||
}
|
}
|
||||||
if(restr == "") {
|
if(Directory.Exists(folder + "/" + restr)) {
|
||||||
restr = "index.html";
|
restr += "/index.html";
|
||||||
}
|
}
|
||||||
String end = restr.IndexOf('.') != -1 ? restr.Substring(restr.IndexOf('.') + 1) : "";
|
String end = restr.IndexOf('.') != -1 ? restr.Substring(restr.IndexOf('.') + 1) : "";
|
||||||
if (File.Exists("resources/"+ restr)) {
|
if(File.Exists(folder + "/" + restr)) {
|
||||||
try {
|
try {
|
||||||
if (end == "png" || end == "jpg" || end == "jpeg" || end == "ico") {
|
if(end == "png" || end == "jpg" || end == "jpeg" || end == "ico" || end == "woff") {
|
||||||
Byte[] output = File.ReadAllBytes("resources/" + restr);
|
Byte[] output = File.ReadAllBytes(folder + "/" + restr);
|
||||||
switch(end) {
|
switch(end) {
|
||||||
case "ico": cont.Response.ContentType = "image/x-ico"; break;
|
case "ico":
|
||||||
|
cont.Response.ContentType = "image/x-ico";
|
||||||
|
break;
|
||||||
|
case "woff":
|
||||||
|
cont.Response.ContentType = "font/woff";
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
cont.Response.OutputStream.Write(output, 0, output.Length);
|
cont.Response.OutputStream.Write(output, 0, output.Length);
|
||||||
return;
|
return true;
|
||||||
} else {
|
} else {
|
||||||
String file = File.ReadAllText("resources/" + restr);
|
String file = File.ReadAllText(folder + "/" + restr);
|
||||||
if (this.requests.GetSections(false).Contains(restr)) {
|
if(requests.GetSections(false).Contains(restr)) {
|
||||||
Dictionary<String, String> vars = this.requests.GetSection(restr);
|
Dictionary<String, String> vars = requests.GetSection(restr);
|
||||||
foreach(KeyValuePair<String, String> item in vars) {
|
foreach(KeyValuePair<String, String> item in vars) {
|
||||||
file = file.Replace("\"{%" + item.Key.ToUpper() + "%}\"", item.Value);
|
file = file.Replace("\"{%" + item.Key.ToUpper() + "%}\"", item.Value);
|
||||||
}
|
}
|
||||||
@@ -74,23 +78,55 @@ namespace BlubbFish.Utils.IoT.Bots
|
|||||||
Byte[] buf = Encoding.UTF8.GetBytes(file);
|
Byte[] buf = Encoding.UTF8.GetBytes(file);
|
||||||
cont.Response.ContentLength64 = buf.Length;
|
cont.Response.ContentLength64 = buf.Length;
|
||||||
switch(end) {
|
switch(end) {
|
||||||
case "css": cont.Response.ContentType = "text/css"; break;
|
case "css":
|
||||||
|
cont.Response.ContentType = "text/css";
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
cont.Response.OutputStream.Write(buf, 0, buf.Length);
|
cont.Response.OutputStream.Write(buf, 0, buf.Length);
|
||||||
Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
|
Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
|
||||||
return;
|
return true;
|
||||||
}
|
}
|
||||||
} catch(Exception e) {
|
} catch(Exception e) {
|
||||||
Helper.WriteError("500 - " + e.Message);
|
Helper.WriteError("500 - " + e.Message);
|
||||||
cont.Response.StatusCode = 500;
|
cont.Response.StatusCode = 500;
|
||||||
return;
|
return false;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Helper.WriteError("404 - " + cont.Request.Url.PathAndQuery + " not found!");
|
Helper.WriteError("404 - " + cont.Request.Url.PathAndQuery + " not found!");
|
||||||
cont.Response.StatusCode = 404;
|
cont.Response.StatusCode = 404;
|
||||||
return;
|
return false;
|
||||||
}
|
}
|
||||||
return;
|
|
||||||
|
public static Boolean SendJsonResponse(Object data, HttpListenerContext cont) {
|
||||||
|
try {
|
||||||
|
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);
|
||||||
|
return true;
|
||||||
|
} catch { }
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static Dictionary<String, String> GetPostParams(HttpListenerRequest req) {
|
||||||
|
if(req.HttpMethod == "POST") {
|
||||||
|
if(req.HasEntityBody) {
|
||||||
|
StreamReader reader = new StreamReader(req.InputStream, req.ContentEncoding);
|
||||||
|
String rawData = reader.ReadToEnd();
|
||||||
|
req.InputStream.Close();
|
||||||
|
reader.Close();
|
||||||
|
Dictionary<String, String> ret = new Dictionary<String, String>();
|
||||||
|
foreach(String param in rawData.Split('&')) {
|
||||||
|
String[] kvPair = param.Split('=');
|
||||||
|
if(!ret.ContainsKey(kvPair[0])) {
|
||||||
|
ret.Add(kvPair[0], HttpUtility.UrlDecode(kvPair[1]));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return new Dictionary<String, String>();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void Dispose() {
|
public void Dispose() {
|
||||||
@@ -99,5 +135,6 @@ namespace BlubbFish.Utils.IoT.Bots
|
|||||||
}
|
}
|
||||||
|
|
||||||
protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e);
|
protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e);
|
||||||
|
protected abstract Boolean SendWebserverResponse(HttpListenerContext cont);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user