Lora-Map/mqtt-map/Googlelocation.cs

using System;
using System.Collections.Generic;
using System.Net;
using System.Text;
using BlubbFish.Utils;
using BlubbFish.Utils.IoT.Bots;
using BlubbFish.Utils.IoT.Connector;
using BlubbFish.Utils.IoT.Events;
using Fraunhofer.Fit.IoT.LoraMap.Model;
using LitJson;

namespace Fraunhofer.Fit.IoT.LoraMap {


  class Googlelocation : Webserver
  {
    private readonly Dictionary<String, Botclient> locations = new Dictionary<String, Botclient>();
    
    public Googlelocation(ADataBackend backend, Dictionary<String, String> settings, InIReader requests) : base(backend, settings, requests) { }

    protected override void Backend_MessageIncomming(Object sender, BackendEvent e) {
      try {
        JsonData d = JsonMapper.ToObject(e.Message);
        if (d.ContainsKey("Rssi") && d["Rssi"].IsDouble
          && d.ContainsKey("Snr") && d["Snr"].IsDouble
          && d.ContainsKey("Receivedtime") && d["Receivedtime"].IsString
          && d.ContainsKey("BatteryLevel") && d["BatteryLevel"].IsDouble
          && d.ContainsKey("Gps") && d["Gps"].IsObject
          && d["Gps"].ContainsKey("Latitude") && d["Gps"]["Latitude"].IsDouble
          && d["Gps"].ContainsKey("Longitude") && d["Gps"]["Longitude"].IsDouble
          && d["Gps"].ContainsKey("LastLatitude") && d["Gps"]["LastLatitude"].IsDouble
          && d["Gps"].ContainsKey("LastLongitude") && d["Gps"]["LastLongitude"].IsDouble
          && d["Gps"].ContainsKey("Hdop") && d["Gps"]["Hdop"].IsDouble
          && d["Gps"].ContainsKey("Fix") && d["Gps"]["Fix"].IsBoolean
          && d["Gps"].ContainsKey("Height") && d["Gps"]["Height"].IsDouble
          && d.ContainsKey("Name") && d["Name"].IsString) {
          String name = (String)d["Name"];
          Botclient b = new Botclient(d);
          if (b.Fix || b.Longitude != 0 || b.Latitude != 0) {
            if (this.locations.ContainsKey(name)) {
              this.locations[name] = b;
            } else {
              this.locations.Add(name,b);
            }
            Console.WriteLine("Koodinate erhalten!");
          } else {
            Console.WriteLine("Daten erhalten! (Kein Fix)");
          }
        }
      } catch(Exception ex) {
        Helper.WriteError(ex.Message);
      }
    }

    protected override void SendResponse(HttpListenerContext cont) {
      if (cont.Request.Url.PathAndQuery.StartsWith("/loc")) {
        try {
          Dictionary<String, Object> ret = new Dictionary<String, Object>();
          Byte[] buf = Encoding.UTF8.GetBytes(JsonMapper.ToJson(this.locations));
          cont.Response.ContentLength64 = buf.Length;
          cont.Response.OutputStream.Write(buf, 0, buf.Length);
          Console.WriteLine("200 - " + cont.Request.Url.PathAndQuery);
          return;
        } catch (Exception e) {
          Helper.WriteError("500 - " + e.Message);
          cont.Response.StatusCode = 500;
          return;
        }
      }
      base.SendResponse(cont);
    }
  }
}