12 Commits
Author SHA1 Message Date
BlubbFish 8932867ed9 [1.2.0] Refactor Bot to ABot and refere MultiSourceBot, Webserver and Bot to it. Add MultiSourceBot. Rewrite Mqtt module so that it not need to watch the connection. 2019-05-27 17:23:31 +02:00
BlubbFish cf3413a3d7 [1.1.9] Modify Output of SendFileResponse 2019-04-21 15:01:14 +02:00
BlubbFish 9705663328 [1.1.8] Add logger to Webserver Class 2019-04-15 21:18:27 +02:00
BlubbFish 6840fced1c [1.1.7] Restrucutre loading, so that all is init and after the listener is started, REQUEST_URL_HOST gives now host and port 2019-04-14 17:23:32 +02:00
BlubbFish 39eac5222c forget changelog 2019-04-03 23:53:10 +02:00
BlubbFish 41c8ccfee7 [1.1.6] rename functions and make SendFileResponse with a parameter for the folder (default resources), also put returntype boolean, add function that parse post params, if path is a dictionary try to load index.html 2019-04-03 20:53:10 +02:00
BlubbFish b3d60ad1ae SendFileResponse as now the default parameter folder = "resources"
add a function GetPostParams
2019-04-02 23:31:28 +02:00
BlubbFish b8fb0e7278 rename functions and make SendFileResponse with a parameter for the folder, not finished yet 2019-04-01 18:15:22 +02:00
BlubbFish 031076b3ba [v1.1.5] add a function to send an object as json directly 2019-03-27 19:32:39 +01:00
BlubbFish 671388218e [1.1.4] add Woff as Binary type 2019-03-13 10:22:50 +01:00
BlubbFish 4a87299d98 [1.1.3] Variables parsing now as a String 2019-03-10 13:00:17 +01:00
BlubbFish ba1597ca3b [1.1.2] Fixing bug for Contenttype 2019-03-08 10:43:31 +01:00
8 changed files with 381 additions and 304 deletions
+48
View File
@@ -0,0 +1,48 @@
using System;
using System.Threading;
namespace BlubbFish.Utils.IoT.Bots {
public abstract class ABot {
private Thread sig_thread;
private Boolean RunningProcess = true;
protected ProgramLogger logger = new ProgramLogger();
private void SetupShutdown(Object sender, ConsoleCancelEventArgs e) {
e.Cancel = true;
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.SetupShutdown: Signalhandler Windows INT recieved.");
this.RunningProcess = false;
}
protected void WaitForShutdown() {
if(Type.GetType("Mono.Runtime") != null) {
this.sig_thread = new Thread(delegate () {
Mono.Unix.UnixSignal[] signals = new Mono.Unix.UnixSignal[] {
new Mono.Unix.UnixSignal(Mono.Unix.Native.Signum.SIGTERM),
new Mono.Unix.UnixSignal(Mono.Unix.Native.Signum.SIGINT)
};
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.WaitForShutdown: Signalhandler Mono attached.");
while(true) {
Int32 i = Mono.Unix.UnixSignal.WaitAny(signals, -1);
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.WaitForShutdown: Signalhandler Mono INT recieved " + i + ".");
this.RunningProcess = false;
break;
}
});
this.sig_thread.Start();
} else {
Console.CancelKeyPress += new ConsoleCancelEventHandler(this.SetupShutdown);
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.WaitForShutdown: Signalhandler Windows attached.");
}
while(this.RunningProcess) {
Thread.Sleep(100);
}
}
public virtual void Dispose() {
if(this.sig_thread != null && this.sig_thread.IsAlive) {
this.sig_thread.Abort();
}
}
}
}
+3
View File
@@ -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" />
@@ -45,6 +46,7 @@
<Reference Include="System.Xml" /> <Reference Include="System.Xml" />
</ItemGroup> </ItemGroup>
<ItemGroup> <ItemGroup>
<Compile Include="ABot.cs" />
<Compile Include="Bot.cs" /> <Compile Include="Bot.cs" />
<Compile Include="Events\CronEvent.cs" /> <Compile Include="Events\CronEvent.cs" />
<Compile Include="Events\ModulEventArgs.cs" /> <Compile Include="Events\ModulEventArgs.cs" />
@@ -58,6 +60,7 @@
<Compile Include="Moduls\Mqtt.cs" /> <Compile Include="Moduls\Mqtt.cs" />
<Compile Include="Moduls\Overtaker.cs" /> <Compile Include="Moduls\Overtaker.cs" />
<Compile Include="Moduls\Statuspolling.cs" /> <Compile Include="Moduls\Statuspolling.cs" />
<Compile Include="MultiSourceBot.cs" />
<Compile Include="Properties\AssemblyInfo.cs" /> <Compile Include="Properties\AssemblyInfo.cs" />
<Compile Include="Webserver.cs" /> <Compile Include="Webserver.cs" />
</ItemGroup> </ItemGroup>
+6 -45
View File
@@ -1,57 +1,20 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Reflection; using System.Reflection;
using System.Threading;
using BlubbFish.Utils.IoT.Bots.Moduls;
using BlubbFish.Utils.IoT.Bots.Events; using BlubbFish.Utils.IoT.Bots.Events;
using BlubbFish.Utils.IoT.Bots.Interfaces; using BlubbFish.Utils.IoT.Bots.Interfaces;
using BlubbFish.Utils.IoT.Bots.Moduls;
namespace BlubbFish.Utils.IoT.Bots { namespace BlubbFish.Utils.IoT.Bots {
public abstract class Bot<T> { public abstract class Bot<T> : ABot {
private Thread sig_thread; protected readonly Dictionary<String, AModul<T>> moduls = new Dictionary<String, AModul<T>>();
private Boolean RunningProcess = true;
protected ProgramLogger logger = new ProgramLogger();
protected readonly Dictionary<String, AModul<T>> moduls = new Dictionary<String, AModul<T>>();
protected void WaitForShutdown() {
if (Type.GetType("Mono.Runtime") != null) {
this.sig_thread = new Thread(delegate () {
Mono.Unix.UnixSignal[] signals = new Mono.Unix.UnixSignal[] {
new Mono.Unix.UnixSignal(Mono.Unix.Native.Signum.SIGTERM),
new Mono.Unix.UnixSignal(Mono.Unix.Native.Signum.SIGINT)
};
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.WaitForShutdown: Signalhandler Mono attached.");
while (true) {
Int32 i = Mono.Unix.UnixSignal.WaitAny(signals, -1);
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.WaitForShutdown: Signalhandler Mono INT recieved " + i + ".");
this.RunningProcess = false;
break;
}
});
this.sig_thread.Start();
} else {
Console.CancelKeyPress += new ConsoleCancelEventHandler(this.SetupShutdown);
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.WaitForShutdown: Signalhandler Windows attached.");
}
while (this.RunningProcess) {
Thread.Sleep(100);
}
}
private void SetupShutdown(Object sender, ConsoleCancelEventArgs e) {
e.Cancel = true;
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.SetupShutdown: Signalhandler Windows INT recieved.");
this.RunningProcess = false;
}
protected void ModulDispose() { protected void ModulDispose() {
foreach (KeyValuePair<String, AModul<T>> item in this.moduls) { foreach (KeyValuePair<String, AModul<T>> item in this.moduls) {
item.Value.Dispose(); item.Value.Dispose();
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.ModulDispose: Modul entladen: " + item.Key); Console.WriteLine("BlubbFish.Utils.IoT.Bots.Bot.ModulDispose: Modul entladen: " + item.Key);
} }
if (this.sig_thread != null && this.sig_thread.IsAlive) { this.Dispose();
this.sig_thread.Abort();
}
} }
protected void ModulLoader(String @namespace, Object library) { protected void ModulLoader(String @namespace, Object library) {
@@ -92,8 +55,6 @@ namespace BlubbFish.Utils.IoT.Bots {
} }
} }
protected void ModulUpdate(Object sender, ModulEventArgs e) { protected void ModulUpdate(Object sender, ModulEventArgs e) => Console.WriteLine(e.ToString());
Console.WriteLine(e.ToString());
}
} }
} }
+1 -3
View File
@@ -54,9 +54,7 @@ namespace BlubbFish.Utils.IoT.Bots.Moduls {
protected abstract void LibUpadteThread(Object state); protected abstract void LibUpadteThread(Object state);
protected void HandleLibUpdate(Object sender, EventArgs e) { protected void HandleLibUpdate(Object sender, EventArgs e) => ThreadPool.QueueUserWorkItem(this.LibUpadteThread, e);
ThreadPool.QueueUserWorkItem(this.LibUpadteThread, e);
}
public abstract void Dispose(); public abstract void Dispose();
+102 -119
View File
@@ -1,119 +1,102 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Text.RegularExpressions; using System.Text.RegularExpressions;
using System.Threading; using BlubbFish.Utils.IoT.Bots.Events;
using BlubbFish.Utils.IoT.Bots.Events; using BlubbFish.Utils.IoT.Connector;
using BlubbFish.Utils.IoT.Connector; using BlubbFish.Utils.IoT.Events;
using BlubbFish.Utils.IoT.Events; using LitJson;
using LitJson;
namespace BlubbFish.Utils.IoT.Bots.Moduls {
namespace BlubbFish.Utils.IoT.Bots.Moduls { public abstract class Mqtt<T> : AModul<T>, IDisposable {
public abstract class Mqtt<T> : AModul<T>, IDisposable { protected ABackend mqtt;
protected readonly Thread connectionWatcher; protected Dictionary<String, AModul<T>> modules;
protected ABackend mqtt;
protected Dictionary<String, AModul<T>> modules; #region Constructor
public Mqtt(T lib, InIReader settings) : base(lib, settings) => this.Connect();
#region Constructor #endregion
public Mqtt(T lib, InIReader settings) : base(lib, settings) {
if (this.config.ContainsKey("settings")) { #region Connection
this.connectionWatcher = new Thread(this.ConnectionWatcherRunner); protected void Reconnect() {
this.connectionWatcher.Start(); if(!this.config.ContainsKey("settings")) {
} else { throw new ArgumentException("Setting section [settings] is missing!");
throw new ArgumentException("Setting section [settings] is missing!"); } else {
} this.Disconnect();
} this.Connect();
#endregion }
}
#region Watcher
protected void ConnectionWatcherRunner() { protected void Connect() {
while (true) { if(!this.config.ContainsKey("settings")) {
try { throw new ArgumentException("Setting section [settings] is missing!");
if (this.mqtt == null || !this.mqtt.IsConnected) { } else {
this.Reconnect(); this.mqtt = ABackend.GetInstance(this.config["settings"], ABackend.BackendType.Data);
} }
Thread.Sleep(10000); }
} catch (Exception) { }
} protected void Disconnect() => this.mqtt.Dispose();
} #endregion
protected void Reconnect() { #region AModul
Console.WriteLine("BlubbFish.Utils.IoT.Bots.Moduls.Mqtt.Reconnect()"); public override void Interconnect(Dictionary<String, AModul<T>> moduls) => this.modules = moduls;
this.Disconnect();
this.Connect(); protected override void UpdateConfig() => this.Reconnect();
} #endregion
protected abstract void Connect(); protected Tuple<Boolean, MqttEvent> ChangeConfig(BackendEvent e, String topic) {
if (e.From.ToString().StartsWith(topic) && (e.From.ToString().EndsWith("/set") || e.From.ToString().EndsWith("/get"))) {
protected abstract void Disconnect(); Match m = new Regex("^"+ topic + "(\\w+)/[gs]et$|").Match(e.From.ToString());
#endregion if (!m.Groups[1].Success) {
return new Tuple<Boolean, MqttEvent>(false, null);
#region AModul }
public override void Interconnect(Dictionary<String, AModul<T>> moduls) { AModul<T> modul = null;
this.modules = moduls; foreach (KeyValuePair<String, AModul<T>> item in this.modules) {
} if (item.Key.ToLower() == m.Groups[1].Value) {
modul = item.Value;
protected override void UpdateConfig() { }
this.Reconnect(); }
} if (modul == null) {
#endregion return new Tuple<Boolean, MqttEvent>(false, null);
}
protected Tuple<Boolean, MqttEvent> ChangeConfig(BackendEvent e, String topic) { if (e.From.ToString().EndsWith("/get") && modul.HasConfig && modul.ConfigPublic) {
if (e.From.ToString().StartsWith(topic) && (e.From.ToString().EndsWith("/set") || e.From.ToString().EndsWith("/get"))) { String t = topic + m.Groups[1].Value;
Match m = new Regex("^"+ topic + "(\\w+)/[gs]et$|").Match(e.From.ToString()); String d = JsonMapper.ToJson(modul.GetConfig()).ToString();
if (!m.Groups[1].Success) { ((ADataBackend)this.mqtt).Send(t, d);
return new Tuple<Boolean, MqttEvent>(false, null); return new Tuple<Boolean, MqttEvent>(true, new MqttEvent(t, d));
} } else if (e.From.ToString().EndsWith("/set") && modul.HasConfig && modul.ConfigPublic) {
AModul<T> modul = null; try {
foreach (KeyValuePair<String, AModul<T>> item in this.modules) { JsonData a = JsonMapper.ToObject(e.Message);
if (item.Key.ToLower() == m.Groups[1].Value) { Dictionary<String, Dictionary<String, String>> newconf = new Dictionary<String, Dictionary<String, String>>();
modul = item.Value; foreach (String section in a.Keys) {
} Dictionary<String, String> sectiondata = new Dictionary<String, String>();
} foreach (String item in a[section].Keys) {
if (modul == null) { sectiondata.Add(item, a[section][item].ToString());
return new Tuple<Boolean, MqttEvent>(false, null); }
} newconf.Add(section, sectiondata);
if (e.From.ToString().EndsWith("/get") && modul.HasConfig && modul.ConfigPublic) { }
String t = topic + m.Groups[1].Value; modul.SetConfig(newconf);
String d = JsonMapper.ToJson(modul.GetConfig()).ToString(); return new Tuple<Boolean, MqttEvent>(true, new MqttEvent("New Config", "Write"));
((ADataBackend)this.mqtt).Send(t, d); } catch { }
return new Tuple<Boolean, MqttEvent>(true, new MqttEvent(t, d)); }
} else if (e.From.ToString().EndsWith("/set") && modul.HasConfig && modul.ConfigPublic) { }
try { return new Tuple<Boolean, MqttEvent>(false, null);
JsonData a = JsonMapper.ToObject(e.Message); }
Dictionary<String, Dictionary<String, String>> newconf = new Dictionary<String, Dictionary<String, String>>();
foreach (String section in a.Keys) { #region IDisposable Support
Dictionary<String, String> sectiondata = new Dictionary<String, String>(); private Boolean disposedValue = false;
foreach (String item in a[section].Keys) {
sectiondata.Add(item, a[section][item].ToString()); protected void Dispose(Boolean disposing) {
} if (!this.disposedValue) {
newconf.Add(section, sectiondata); if (disposing) {
} this.Disconnect();
modul.SetConfig(newconf); }
return new Tuple<Boolean, MqttEvent>(true, new MqttEvent("New Config", "Write")); this.disposedValue = true;
} catch (Exception) { } }
} }
}
return new Tuple<Boolean, MqttEvent>(false, null); public override void Dispose() {
} this.Dispose(true);
GC.SuppressFinalize(this);
#region IDisposable Support }
private Boolean disposedValue = false; #endregion
}
protected void Dispose(Boolean disposing) { }
if (!this.disposedValue) {
if (disposing) {
this.connectionWatcher.Abort();
while (this.connectionWatcher.ThreadState == ThreadState.Running) { Thread.Sleep(10); }
this.Disconnect();
}
this.disposedValue = true;
}
}
public override void Dispose() {
Dispose(true);
GC.SuppressFinalize(this);
}
#endregion
}
}
+18
View File
@@ -0,0 +1,18 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using BlubbFish.Utils.IoT.Connector;
namespace BlubbFish.Utils.IoT.Bots {
public abstract class MultiSourceBot : ABot {
protected Dictionary<String, ABackend> sources;
protected Dictionary<String, String> settings;
protected MultiSourceBot(Dictionary<String, ABackend> sources, Dictionary<String, String> settings) {
this.sources = sources;
this.settings = settings;
}
}
}
+50 -39
View File
@@ -1,41 +1,52 @@
using System.Reflection; using System.Reflection;
using System.Runtime.CompilerServices; using System.Resources;
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 - 27.05.2019")]
[assembly: AssemblyTrademark("© BlubbFish")]
[assembly: AssemblyCulture("")]
[assembly: NeutralResourcesLanguage("de-DE")]
// 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.2.0")]
[assembly: AssemblyFileVersion("1.2.0")]
/*
* 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
* 1.1.6 rename functions and make SendFileResponse with a parameter for the folder (default resources),
* also put returntype boolean, add function that parse post params, if path is a dictionary try to load index.html
* 1.1.7 Restrucutre loading, so that all is init and after the listener is started, REQUEST_URL_HOST gives now host and port
* 1.1.8 Add logger to Webserver Class
* 1.1.9 Modify Output of SendFileResponse
* 1.2.0 Refactor Bot to ABot and refere MultiSourceBot, Webserver and Bot to it. Add MultiSourceBot. Rewrite Mqtt module so that it not need to watch the connection.
*/ */
+153 -98
View File
@@ -1,98 +1,153 @@
using BlubbFish.Utils.IoT.Connector; using System;
using BlubbFish.Utils.IoT.Events; using System.Collections.Generic;
using System; using System.IO;
using System.Collections.Generic; using System.Net;
using System.IO; using System.Text;
using System.Linq; using System.Threading;
using System.Net; using System.Web;
using System.Text; using BlubbFish.Utils.IoT.Connector;
using System.Threading; using BlubbFish.Utils.IoT.Events;
using System.Threading.Tasks; using LitJson;
namespace BlubbFish.Utils.IoT.Bots namespace BlubbFish.Utils.IoT.Bots {
{ public abstract class Webserver : ABot
public abstract class Webserver {
{ protected Dictionary<String, String> config;
protected Dictionary<String, String> config; protected static InIReader requests;
protected InIReader requests; protected HttpListener httplistener;
protected HttpListener httplistener; protected ABackend databackend;
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; this.databackend = backend;
this.httplistener = new HttpListener(); }
this.httplistener.Prefixes.Add(this.config["prefix"]);
this.httplistener.Start(); protected void StartListen() {
ThreadPool.QueueUserWorkItem((o) => { this.databackend.MessageIncomming += this.Backend_MessageIncomming;
Console.WriteLine("Webserver is Running..."); this.httplistener = new HttpListener();
try { this.httplistener.Prefixes.Add(this.config["prefix"]);
while (this.httplistener.IsListening) { this.httplistener.Start();
ThreadPool.QueueUserWorkItem((state) => { ThreadPool.QueueUserWorkItem((o) => {
HttpListenerContext httplistenercontext = state as HttpListenerContext; Console.WriteLine("Webserver is Running...");
try { try {
this.SendResponse(httplistenercontext); while(this.httplistener.IsListening) {
} catch { } finally { ThreadPool.QueueUserWorkItem((state) => {
httplistenercontext.Response.OutputStream.Close(); HttpListenerContext httplistenercontext = state as HttpListenerContext;
} try {
}, this.httplistener.GetContext()); this.SendWebserverResponse(httplistenercontext);
} } catch { } finally {
} catch { }; httplistenercontext.Response.OutputStream.Close();
}); }
} }, this.httplistener.GetContext());
}
protected virtual void SendResponse(HttpListenerContext cont) { } catch { };
String restr = cont.Request.Url.PathAndQuery; });
if (restr.StartsWith("/")) { }
if(restr.IndexOf("?") != -1) {
restr = restr.Substring(1, restr.IndexOf("?")-1); public static Boolean SendFileResponse(HttpListenerContext cont, String folder = "resources", Boolean printOutput = true) {
} else { String restr = cont.Request.Url.PathAndQuery;
restr = restr.Substring(1); if(restr.StartsWith("/")) {
} if(restr.IndexOf("?") != -1) {
if(restr == "") { restr = restr.Substring(1, restr.IndexOf("?") - 1);
restr = "index.html"; } else {
} restr = restr.Substring(1);
String end = restr.IndexOf('.') != -1 ? restr.Substring(restr.IndexOf('.')+1) : ""; }
if (File.Exists("resources/"+ restr)) { if(Directory.Exists(folder + "/" + restr)) {
try { restr += "/index.html";
if (end == "png" || end == ".jpg" || end == ".jpeg" || end == ".ico") { }
Byte[] output = File.ReadAllBytes("resources/" + restr); String end = restr.IndexOf('.') != -1 ? restr.Substring(restr.IndexOf('.') + 1) : "";
cont.Response.OutputStream.Write(output, 0, output.Length); if(File.Exists(folder + "/" + restr)) {
cont.Response.ContentType = "image/"+end; try {
return; if(end == "png" || end == "jpg" || end == "jpeg" || end == "ico" || end == "woff") {
} else { Byte[] output = File.ReadAllBytes(folder + "/" + restr);
String file = File.ReadAllText("resources/" + restr); switch(end) {
if (this.requests.GetSections(false).Contains(restr)) { case "ico":
Dictionary<String, String> vars = this.requests.GetSection(restr); cont.Response.ContentType = "image/x-ico";
foreach (KeyValuePair<String, String> item in vars) { break;
file = file.Replace("{%" + item.Key.ToUpper() + "%}", item.Value); case "woff":
} cont.Response.ContentType = "font/woff";
} break;
file = file.Replace("{%REQUEST_URL_HOST%}", cont.Request.Url.Host); }
Byte[] buf = Encoding.UTF8.GetBytes(file); cont.Response.OutputStream.Write(output, 0, output.Length);
cont.Response.ContentLength64 = buf.Length; if(printOutput) {
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;
} } else {
} catch(Exception e) { String file = File.ReadAllText(folder + "/" + restr);
Helper.WriteError("500 - " + e.Message); if(requests.GetSections(false).Contains(restr)) {
cont.Response.StatusCode = 500; Dictionary<String, String> vars = requests.GetSection(restr);
return; foreach(KeyValuePair<String, String> item in vars) {
} file = file.Replace("\"{%" + item.Key.ToUpper() + "%}\"", item.Value);
} }
Helper.WriteError("404 - " + cont.Request.Url.PathAndQuery + " not found!"); }
cont.Response.StatusCode = 404; file = file.Replace("{%REQUEST_URL_HOST%}", cont.Request.Url.Host+":"+cont.Request.Url.Port);
return; Byte[] buf = Encoding.UTF8.GetBytes(file);
} cont.Response.ContentLength64 = buf.Length;
return; switch(end) {
} case "css":
cont.Response.ContentType = "text/css";
public void Dispose() { break;
this.httplistener.Stop(); }
this.httplistener.Close(); cont.Response.OutputStream.Write(buf, 0, buf.Length);
} if(printOutput) {
Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e); }
} return true;
} }
} catch(Exception e) {
Helper.WriteError("500 - " + e.Message);
cont.Response.StatusCode = 500;
return false;
}
}
}
if(printOutput) {
Helper.WriteError("404 - " + cont.Request.Url.PathAndQuery + " not found!");
}
cont.Response.StatusCode = 404;
return false;
}
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 override void Dispose() {
this.httplistener.Stop();
this.httplistener.Close();
base.Dispose();
}
protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e);
protected abstract Boolean SendWebserverResponse(HttpListenerContext cont);
}
}