Compare commits
3
Commits
3cda47aa0c
..
v1.2.3
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
55425d2afa | ||
|
|
7204003afb | ||
|
|
8811a949fe |
@@ -5,26 +5,16 @@ using System.Net;
|
|||||||
using System.Text;
|
using System.Text;
|
||||||
using System.Threading;
|
using System.Threading;
|
||||||
using System.Web;
|
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 : ABot
|
public abstract class AWebserver : ABot {
|
||||||
{
|
|
||||||
protected Dictionary<String, String> config;
|
protected Dictionary<String, String> config;
|
||||||
protected static InIReader requests;
|
|
||||||
protected HttpListener httplistener;
|
|
||||||
protected ABackend databackend;
|
|
||||||
|
|
||||||
public Webserver(ABackend backend, Dictionary<String, String> settings, InIReader requestslookup) {
|
protected HttpListener httplistener;
|
||||||
this.config = settings;
|
|
||||||
requests = requestslookup;
|
public AWebserver(Dictionary<String, String> settings) => this.config = settings;
|
||||||
this.databackend = backend;
|
|
||||||
}
|
|
||||||
|
|
||||||
protected void StartListen() {
|
protected void StartListen() {
|
||||||
this.databackend.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"]);
|
||||||
this.httplistener.Start();
|
this.httplistener.Start();
|
||||||
@@ -45,7 +35,57 @@ namespace BlubbFish.Utils.IoT.Bots {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
public static Boolean SendFileResponse(HttpListenerContext cont, String folder = "resources", Boolean printOutput = true) {
|
public override void Dispose() {
|
||||||
|
if(this.httplistener.IsListening) {
|
||||||
|
this.httplistener.Stop();
|
||||||
|
}
|
||||||
|
this.httplistener.Close();
|
||||||
|
base.Dispose();
|
||||||
|
}
|
||||||
|
|
||||||
|
protected abstract Boolean SendWebserverResponse(HttpListenerContext cont);
|
||||||
|
}
|
||||||
|
|
||||||
|
#region HttpListener* Extensions
|
||||||
|
public static class HttpListenerHelper {
|
||||||
|
private static InIReader requests;
|
||||||
|
|
||||||
|
public static Dictionary<String, String> GetPostParams(this HttpListenerRequest request) {
|
||||||
|
if(request.HttpMethod == "POST") {
|
||||||
|
if(request.HasEntityBody) {
|
||||||
|
StreamReader reader = new StreamReader(request.InputStream, request.ContentEncoding);
|
||||||
|
String rawData = reader.ReadToEnd();
|
||||||
|
request.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 static Boolean SendStringResponse(this HttpListenerContext cont, String obj) => cont.SendBinaryResponse(Encoding.UTF8.GetBytes(obj));
|
||||||
|
|
||||||
|
public static Boolean SendBinaryResponse(this HttpListenerContext cont, Byte[] buf) {
|
||||||
|
try {
|
||||||
|
cont.Response.ContentLength64 = buf.Length;
|
||||||
|
cont.Response.OutputStream.Write(buf, 0, buf.Length);
|
||||||
|
Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
|
||||||
|
return true;
|
||||||
|
} catch(Exception e) {
|
||||||
|
Helper.WriteError("500 - " + e.Message + "\n\n" + e.StackTrace);
|
||||||
|
cont.Response.StatusCode = 500;
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static Boolean SendFileResponse(this HttpListenerContext cont, String folder = "resources", Boolean printOutput = true) {
|
||||||
String restr = cont.Request.Url.PathAndQuery;
|
String restr = cont.Request.Url.PathAndQuery;
|
||||||
if(restr.StartsWith("/")) {
|
if(restr.StartsWith("/")) {
|
||||||
restr = restr.IndexOf("?") != -1 ? restr[1..restr.IndexOf("?")] : restr[1..];
|
restr = restr.IndexOf("?") != -1 ? restr[1..restr.IndexOf("?")] : restr[1..];
|
||||||
@@ -81,7 +121,7 @@ namespace BlubbFish.Utils.IoT.Bots {
|
|||||||
file = file.Replace("\"{%" + item.Key.ToUpper() + "%}\"", item.Value);
|
file = file.Replace("\"{%" + item.Key.ToUpper() + "%}\"", item.Value);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
file = file.Replace("{%REQUEST_URL_HOST%}", cont.Request.Url.Host+":"+cont.Request.Url.Port);
|
file = file.Replace("{%REQUEST_URL_HOST%}", cont.Request.Url.Host + ":" + cont.Request.Url.Port);
|
||||||
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) {
|
||||||
@@ -109,53 +149,7 @@ namespace BlubbFish.Utils.IoT.Bots {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static Boolean SendJsonResponse(Object data, HttpListenerContext cont) {
|
public static void SetRequestsOverride(InIReader requestslookup) => requests = requestslookup;
|
||||||
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(Exception e) {
|
|
||||||
Helper.WriteError("500 - " + e.Message + "\n\n" + e.StackTrace);
|
|
||||||
cont.Response.StatusCode = 500;
|
|
||||||
}
|
|
||||||
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() {
|
|
||||||
if(this.httplistener.IsListening) {
|
|
||||||
this.httplistener.Stop();
|
|
||||||
}
|
|
||||||
|
|
||||||
this.httplistener.Close();
|
|
||||||
if(this.databackend != null) {
|
|
||||||
this.databackend.Dispose();
|
|
||||||
}
|
|
||||||
base.Dispose();
|
|
||||||
}
|
|
||||||
|
|
||||||
protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e);
|
|
||||||
protected abstract Boolean SendWebserverResponse(HttpListenerContext cont);
|
|
||||||
}
|
}
|
||||||
|
#endregion
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,23 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
|
||||||
|
using BlubbFish.Utils.IoT.Connector;
|
||||||
|
using BlubbFish.Utils.IoT.Events;
|
||||||
|
|
||||||
|
namespace BlubbFish.Utils.IoT.Bots {
|
||||||
|
public abstract class AWebserverDataBackend : AWebserver {
|
||||||
|
protected ABackend databackend;
|
||||||
|
protected AWebserverDataBackend(ABackend backend, Dictionary<String, String> settings) : base(settings) => this.databackend = backend;
|
||||||
|
|
||||||
|
protected void StartDataBackend() => this.databackend.MessageIncomming += this.Backend_MessageIncomming;
|
||||||
|
|
||||||
|
protected abstract void Backend_MessageIncomming(Object sender, BackendEvent e);
|
||||||
|
|
||||||
|
public override void Dispose() {
|
||||||
|
if(this.databackend != null) {
|
||||||
|
this.databackend.Dispose();
|
||||||
|
}
|
||||||
|
base.Dispose();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -5,19 +5,21 @@
|
|||||||
<RootNamespace>BlubbFish.Utils.IoT.Bots</RootNamespace>
|
<RootNamespace>BlubbFish.Utils.IoT.Bots</RootNamespace>
|
||||||
<AssemblyName>Bot-Utils</AssemblyName>
|
<AssemblyName>Bot-Utils</AssemblyName>
|
||||||
<PackageId>Bots.IoT.Utils.BlubbFish</PackageId>
|
<PackageId>Bots.IoT.Utils.BlubbFish</PackageId>
|
||||||
<Version>1.2.1</Version>
|
<Version>1.2.3</Version>
|
||||||
<AssemblyVersion>1.2.1</AssemblyVersion>
|
<AssemblyVersion>1.2.3</AssemblyVersion>
|
||||||
<FileVersion>1.2.1</FileVersion>
|
<FileVersion>1.2.3</FileVersion>
|
||||||
<NeutralLanguage>de-DE</NeutralLanguage>
|
<NeutralLanguage>de-DE</NeutralLanguage>
|
||||||
<Description>Bot-Utils are helpers for programming a bot</Description>
|
<Description>Bot-Utils are helpers for programming a bot</Description>
|
||||||
<Authors>BlubbFish</Authors>
|
<Authors>BlubbFish</Authors>
|
||||||
<Company>BlubbFish</Company>
|
<Company>BlubbFish</Company>
|
||||||
<Copyright>Copyright © BlubbFish 2018 - 30.08.2019</Copyright>
|
<Copyright>Copyright © BlubbFish 2018 - 09.01.2022</Copyright>
|
||||||
<PackageLicenseFile>LICENSE</PackageLicenseFile>
|
<PackageLicenseFile>LICENSE</PackageLicenseFile>
|
||||||
<PackageProjectUrl>http://git.blubbfish.net/vs_utils/Bot-Utils</PackageProjectUrl>
|
<PackageProjectUrl>http://git.blubbfish.net/vs_utils/Bot-Utils</PackageProjectUrl>
|
||||||
<RepositoryUrl>http://git.blubbfish.net/vs_utils/Bot-Utils.git</RepositoryUrl>
|
<RepositoryUrl>http://git.blubbfish.net/vs_utils/Bot-Utils.git</RepositoryUrl>
|
||||||
<RepositoryType>git</RepositoryType>
|
<RepositoryType>git</RepositoryType>
|
||||||
<PackageReleaseNotes>1.2.1 When using Dispose, kill also mqtt connection and other tiny fixes
|
<PackageReleaseNotes>1.2.3 Tiny Refactoring
|
||||||
|
1.2.2 Going to netcore
|
||||||
|
1.2.1 When using Dispose, kill also mqtt connection and other tiny fixes
|
||||||
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.
|
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.
|
||||||
1.1.9 Modify Output of SendFileResponse
|
1.1.9 Modify Output of SendFileResponse
|
||||||
1.1.8 Add logger to Webserver Class
|
1.1.8 Add logger to Webserver Class
|
||||||
@@ -39,10 +41,11 @@
|
|||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<Content Include="../CHANGELOG.md" />
|
<Content Include="../CHANGELOG.md" />
|
||||||
<Content Include="../CONTRIBUTING.md" />
|
<Content Include="../CONTRIBUTING.md" />
|
||||||
<Content Include="../LICENSE" />
|
<Content Include="../LICENSE" />
|
||||||
<Content Include="../README.md" />
|
<Content Include="../README.md" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<None Include="..\LICENSE">
|
<None Include="..\LICENSE">
|
||||||
<Pack>True</Pack>
|
<Pack>True</Pack>
|
||||||
|
|||||||
@@ -25,13 +25,7 @@ namespace BlubbFish.Utils.IoT.Bots.Moduls {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
protected void Connect() {
|
protected void Connect() => this.mqtt = !this.config.ContainsKey("settings") ? throw new ArgumentException("Setting section [settings] is missing!") : ABackend.GetInstance(this.config["settings"], ABackend.BackendType.Data);
|
||||||
if(!this.config.ContainsKey("settings")) {
|
|
||||||
throw new ArgumentException("Setting section [settings] is missing!");
|
|
||||||
} else {
|
|
||||||
this.mqtt = ABackend.GetInstance(this.config["settings"], ABackend.BackendType.Data);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
protected void Disconnect() => this.mqtt.Dispose();
|
protected void Disconnect() => this.mqtt.Dispose();
|
||||||
#endregion
|
#endregion
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ namespace BlubbFish.Utils.IoT.Bots.Moduls {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
protected void SetValues(Object sender, String name, Dictionary<String, String> dictionary) {
|
protected void SetValues(Object sender, String _, Dictionary<String, String> dictionary) {
|
||||||
String from = dictionary["from"];
|
String from = dictionary["from"];
|
||||||
String[] source = from.Split(':');
|
String[] source = from.Split(':');
|
||||||
if (source.Length != 2) {
|
if (source.Length != 2) {
|
||||||
|
|||||||
@@ -0,0 +1,96 @@
|
|||||||
|
# Changelog
|
||||||
|
|
||||||
|
## 1.2.3 - 2022-01-09 - Tiny Refactoring
|
||||||
|
### New Features
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
* Cleanup Changelog
|
||||||
|
* Tiny Refactorings
|
||||||
|
|
||||||
|
## 1.2.2 - 2021-08-22 - Going to netcore
|
||||||
|
### New Features
|
||||||
|
* Split Wbserver to AWebserver and AWebserverDataBackend
|
||||||
|
* Add mp4 as binary content
|
||||||
|
* make a mirror of this repo on github
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
* change to c+ newer coding style
|
||||||
|
* mograde to c# netcore 3.1
|
||||||
|
|
||||||
|
## 1.2.1 - 2019-08-30 - When using Dispose, kill also mqtt connection and other tiny fixes
|
||||||
|
### New Features
|
||||||
|
* Add LICENSE, CONTRIBUTING.md and README.md
|
||||||
|
### Bugfixes
|
||||||
|
* When using Dispose, kill also mqtt connection
|
||||||
|
### Changes
|
||||||
|
* A bit more debugging
|
||||||
|
|
||||||
|
## 1.2.0 - 2019-05-27 - Refactor Bot to ABot and refere MultiSourceBot
|
||||||
|
### New Features
|
||||||
|
* Add MultiSourceBot*
|
||||||
|
* Refere MultiSourceBot, Webserver and Bot to it.
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
* Refactor Bot to ABot
|
||||||
|
* Rewrite Mqtt module so that it not need to watch the connection.
|
||||||
|
|
||||||
|
## 1.1.9 - 2019-04-21 - Modify Output of SendFileResponse
|
||||||
|
### New Features
|
||||||
|
* Modify Output of SendFileResponse
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
|
||||||
|
## 1.1.8 - 2019-04-15 - Add logger to Webserver Class
|
||||||
|
### New Features
|
||||||
|
* Add logger to Webserver Class
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
|
||||||
|
## 1.1.7 - 2019-04-14 - REQUEST_URL_HOST
|
||||||
|
### New Features
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
* Restrucutre loading, so that all is init and after the listener is started, REQUEST_URL_HOST gives now host and port
|
||||||
|
|
||||||
|
## 1.1.6 - 2019-04-03 - Refactoring and bugfixing
|
||||||
|
### New Features
|
||||||
|
* SendFileResponse with a parameter for the folder
|
||||||
|
* add function that parse post params
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
|
||||||
|
## 1.1.5 - 2019-03-27 - add a function to send an object as json directly
|
||||||
|
### New Features
|
||||||
|
* add a function to send an object as json directly
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
|
||||||
|
## 1.1.4 - 2019-03-13 - add Woff as Binary type
|
||||||
|
### New Features
|
||||||
|
* add Woff as Binary type
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
|
||||||
|
## 1.1.3 - 2019-03-10 - Variables parsing now as a String
|
||||||
|
### New Features
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
* Variables parsing now as a String
|
||||||
|
|
||||||
|
## 1.1.2 - 2019-03-08 - Fixing bug for Contenttype
|
||||||
|
### New Features
|
||||||
|
### Bugfixes
|
||||||
|
* Fixing bug for Contenttype
|
||||||
|
### Changes
|
||||||
|
|
||||||
|
## 1.1.1 - 2019-02-17 - Update to local librarys
|
||||||
|
### New Features
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
* Update to local librarys
|
||||||
|
|
||||||
|
## 1.1.0 - 2019-02-14 - Remove Helper from Bot-Utils
|
||||||
|
### New Features
|
||||||
|
* Remove Helper from Bot-Utils
|
||||||
|
### Bugfixes
|
||||||
|
### Changes
|
||||||
|
|||||||
@@ -1,11 +1,12 @@
|
|||||||
# BlubbFish.Utils.IoT.Bots (Bot-Utils)
|
# BlubbFish.Utils.IoT.Bots (Bot-Utils)
|
||||||
Library that makes it easier to create bots.
|
Library that makes it easier to create bots.
|
||||||
|
|
||||||
|
Maybe you find this Repo on Github. This is a mirror from [here](https://git.blubbfish.net/vs_utils/Bot-Utils).
|
||||||
|
|
||||||
## Linking to
|
## Linking to
|
||||||
### Internal
|
### Internal
|
||||||
* BlubbFish.Utils ([Utils](http://git.blubbfish.net/vs_utils/Utils))
|
* BlubbFish.Utils ([Utils](http://git.blubbfish.net/vs_utils/Utils))
|
||||||
* BlubbFish.Utils.IoT ([Utils-IoT](http://git.blubbfish.net/vs_utils/Utils-IoT))
|
* BlubbFish.Utils.IoT ([Utils-IoT](http://git.blubbfish.net/vs_utils/Utils-IoT))
|
||||||
|
|
||||||
### External
|
### External
|
||||||
* litjson
|
* litjson ([Used Fork](https://github.com/blubbfish/litjson), [Original](https://github.com/LitJSON/litjson))
|
||||||
* Mono.Posix
|
|
||||||
Reference in New Issue
Block a user