[1.1.7] Restrucutre loading, so that all is init and after the listener is started, REQUEST_URL_HOST gives now host and port

add a function GetPostParams

Bot-Utils/Bot-Utils.csproj

@@ -37,6 +37,7 @@
   <ItemGroup>
     <Reference Include="System" />
     <Reference Include="System.Core" />
+    <Reference Include="System.Web" />
     <Reference Include="System.Xml.Linq" />
     <Reference Include="System.Data.DataSetExtensions" />
     <Reference Include="Microsoft.CSharp" />

Bot-Utils/Properties/AssemblyInfo.cs

@@ -1,41 +1,48 @@
-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 - 14.04.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.7")]
+[assembly: AssemblyFileVersion("1.1.7")]
+
+/*
+ * 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
  */

Bot-Utils/Webserver.cs

@@ -1,98 +1,145 @@
-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
-  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") {
-        } 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;
+              return true;
-              cont.Response.OutputStream.Write(buf, 0, buf.Length);
+            } else {
-              Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
+              String file = File.ReadAllText(folder + "/" + restr);
-              return;
+              if(requests.GetSections(false).Contains(restr)) {
-            }
+                Dictionary<String, String> vars = requests.GetSection(restr);
-          } catch(Exception e) {
+                foreach(KeyValuePair<String, String> item in vars) {
-            Helper.WriteError("500 - " + e.Message);
+                  file = file.Replace("\"{%" + item.Key.ToUpper() + "%}\"", item.Value);
-            cont.Response.StatusCode = 500;
+                }
-            return;
+              }
-          }
+              file = file.Replace("{%REQUEST_URL_HOST%}", cont.Request.Url.Host+":"+cont.Request.Url.Port);
-        }
+              Byte[] buf = Encoding.UTF8.GetBytes(file);
-        Helper.WriteError("404 - " + cont.Request.Url.PathAndQuery + " not found!");
+              cont.Response.ContentLength64 = buf.Length;
-        cont.Response.StatusCode = 404;
+              switch(end) {
-        return;
+                case "css":
-      }
+                  cont.Response.ContentType = "text/css";
-      return;
+                  break;
-    }
+              }
-
+              cont.Response.OutputStream.Write(buf, 0, buf.Length);
-    public void Dispose() {
+              Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
-      this.httplistener.Stop();
+              return true;
-      this.httplistener.Close();
+            }
-    }
+          } catch(Exception e) {
-
+            Helper.WriteError("500 - " + e.Message);
-    protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e);
+            cont.Response.StatusCode = 500;
-  }
+            return false;
-}
+          }
+        }
+      }
+      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 void Dispose() {
+      this.httplistener.Stop();
+      this.httplistener.Close();
+    }
+
+    protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e);
+    protected abstract Boolean SendWebserverResponse(HttpListenerContext cont);
+  }
+}