package main

import (
	"bytes"
	"encoding/json"
	"encoding/hex"
	"encoding/binary"
	"fmt"
	"os"
	"io/ioutil"
	"log"
	"net/http"
        "time"
)

const (
	MyDB = "beieliscaledb"
	username = "beieli"
	password = "beieli4president"
        outputfile = "/home/beieli/lorahandler/lorahandler.log"
)


type MessageProperties struct {
	Time string `json:"Time"`
	Payload_hex string `json:"payload_hex"`
        DevEUI string `json:"DevEUI"`
        DevAddr string `json:"DevAddr"`
        LrrLAT float32 `json:"LrrLAT"`
        LrrLON float32 `json:"LrrLON"`
}

type Message struct {
	Prop MessageProperties `json:"DevEUI_uplink"`
}

type payload_128 struct {
	Version uint8
        Vbat uint8
        H uint8
	T int16
        P uint8
	W1 int32
	W2 int32
	W uint16
}

type payload_129 struct {
	Version uint8
	Fw_version int32
        Vbat uint8
        H uint8
	T int16
        P uint8
	W1 int32
	W2 int32
	W uint16
}

type payload_1 struct {
	Version uint8
        Vbat uint8
        H1 uint8
        H2 uint8
        H3 uint8
        H4 uint8
        H5 uint8
        H6 uint8
        H7 uint8
        H8 uint8
	T int16
	TC1 int8
	TC2 int8
	TC3 int8
	TC4 int8
	TC5 int8
	TC6 int8
	TC7 int8
        P1 uint8
        P2 uint8
        P3 uint8
        P4 uint8
        P5 uint8
        P6 uint8
        P7 uint8
        P8 uint8
	W1 uint16
	W2 uint16
	W3 uint16
	W4 uint16
	W5 uint16
	W6 uint16
	W7 uint16
	W8 uint16
	O uint8
}

// Global variables
var file *os.File

var alertMap map[string]string
var alertLogMap map[string]string

func DecodePayload(s string, deveui string, devaddr string, lrrlat float32, lrrlon float32, write2file bool) {
  var ba []byte
  var pl_1 payload_1
  var pl_128 payload_128
  var pl_129 payload_129
  ba, _ = hex.DecodeString(s)
  pl_1 = payload_1{}
  pl_128 = payload_128{}
  pl_129 = payload_129{}
  br := bytes.NewReader(ba)
  if (s[0:2] == "01") {
    err := binary.Read(br, binary.LittleEndian, &pl_1)
    if err != nil {
	fmt.Println(err)
    }
  } else if (s[0:2] == "80") {
    err := binary.Read(br, binary.LittleEndian, &pl_128)
    if err != nil {
	fmt.Println(err)
    }
  } else if (s[0:2] == "81") {
    err := binary.Read(br, binary.LittleEndian, &pl_129)
    if err != nil {
	fmt.Println(err)
    }
  } else {
    fmt.Printf("Payload String is unknown: %s\n",s)
  }
  if (s[0:2] == "01") {
    fmt.Printf("{\n")
    fmt.Printf("  version: %d,\n", pl_1.Version)
    fmt.Printf("  vbat: %d,\n", pl_1.Vbat)
    fmt.Printf("  offset: %d\n",pl_1.O)
    fmt.Printf("  humidity: [%d,%d,%d,%d,%d,%d,%d,%d],\n",pl_1.H1,pl_1.H2,pl_1.H3,pl_1.H4,pl_1.H5,pl_1.H6,pl_1.H7,pl_1.H8)
    fmt.Printf("  pressure: [%d,%d,%d,%d,%d,%d,%d,%d],\n",pl_1.P1,pl_1.P2,pl_1.P3,pl_1.P4,pl_1.P5,pl_1.P6,pl_1.P7,pl_1.P8)
    fmt.Printf("  weight: [%d,%d,%d,%d,%d,%d,%d,%d],\n",pl_1.W1,pl_1.W2,pl_1.W3,pl_1.W4,pl_1.W5,pl_1.W6,pl_1.W7,pl_1.W8)
    fmt.Printf("  temp: %d,\n",pl_1.T)
    fmt.Printf("  temp_change: [%d,%d,%d,%d,%d,%d,%d],\n",pl_1.TC1,pl_1.TC2,pl_1.TC3,pl_1.TC4,pl_1.TC5,pl_1.TC6,pl_1.TC7)
    fmt.Printf("}\n")
    if write2file {
       // Time of first Packet
       var tfp = (time.Now().Unix() / 60) - int64(pl_1.O)
       var step = int64(pl_1.O / 7)
      
       // the first temperature is usually too high (maybe becaus of lorawan send, so we take
       // the second measurement as first..., the same for humidity, which is usually too low...
       t := pl_1.T
       t = t + int16(pl_1.TC1)
       WriteDatapoint(tfp,deveui,devaddr,pl_1.Vbat,pl_1.H2,pl_1.P1,pl_1.W1,0,0,t,lrrlat,lrrlon,0)
       //t = t + int16(pl_1.TC1)
       WriteDatapoint(tfp + (step),deveui,devaddr,0,pl_1.H2,pl_1.P2,pl_1.W2,0,0,t,lrrlat,lrrlon,0)
       t = t + int16(pl_1.TC2)
       WriteDatapoint(tfp + (2 * step),deveui,devaddr,0,pl_1.H3,pl_1.P3,pl_1.W3,0,0,t,lrrlat,lrrlon,0)
       t = t + int16(pl_1.TC3)
       WriteDatapoint(tfp + (3 * step),deveui,devaddr,0,pl_1.H4,pl_1.P4,pl_1.W4,0,0,t,lrrlat,lrrlon,0)
       t = t + int16(pl_1.TC4)
       WriteDatapoint(tfp + (4 * step),deveui,devaddr,0,pl_1.H5,pl_1.P5,pl_1.W5,0,0,t,lrrlat,lrrlon,0)
       t = t + int16(pl_1.TC5)
       WriteDatapoint(tfp + (5 * step),deveui,devaddr,0,pl_1.H6,pl_1.P6,pl_1.W6,0,0,t,lrrlat,lrrlon,0)
       t = t + int16(pl_1.TC6)
       WriteDatapoint(tfp + (6 * step),deveui,devaddr,0,pl_1.H7,pl_1.P7,pl_1.W7,0,0,t,lrrlat,lrrlon,0)
       t = t + int16(pl_1.TC7)
       WriteDatapoint(tfp + (7 * step),deveui,devaddr,0,pl_1.H8,pl_1.P8,pl_1.W8,0,0,t,lrrlat,lrrlon,0)
    }
  } else if (s[0:2] == "80") {
    fmt.Printf("{\n")
    fmt.Printf("  version: %d,\n", pl_128.Version)
    fmt.Printf("  vbat: %d,\n", pl_128.Vbat)
    fmt.Printf("  humidity: %d\n",pl_128.H)
    fmt.Printf("  pressure: %d\n",pl_128.P)
    fmt.Printf("  weight1: %d\n",pl_128.W1)
    fmt.Printf("  weight2: %d\n",pl_128.W2)
    fmt.Printf("  weight: %d\n",pl_128.W)
    fmt.Printf("  temp: %d\n",pl_128.T)
    fmt.Printf("}\n")
    if write2file {
       // Time of Packet received
       var tfp = (time.Now().Unix() / 60)
  
       WriteDatapoint(tfp,deveui,devaddr,pl_128.Vbat,pl_128.H,pl_128.P,pl_128.W,pl_128.W1,pl_128.W2,pl_128.T,lrrlat,lrrlon,0)
    }
  } else if (s[0:2] == "81") {
    fmt.Printf("{\n")
    fmt.Printf("  version: %d,\n", pl_129.Version)
    fmt.Printf("  fw_version: %d,\n", pl_129.Fw_version)
    fmt.Printf("  vbat: %d,\n", pl_129.Vbat)
    fmt.Printf("  humidity: %d\n",pl_129.H)
    fmt.Printf("  pressure: %d\n",pl_129.P)
    fmt.Printf("  weight1: %d\n",pl_129.W1)
    fmt.Printf("  weight2: %d\n",pl_129.W2)
    fmt.Printf("  weight: %d\n",pl_129.W)
    fmt.Printf("  temp: %d\n",pl_129.T)
    fmt.Printf("}\n")
    if write2file {
       // Time of Packet received
       var tfp = (time.Now().Unix() / 60)
  
       WriteDatapoint(tfp,deveui,devaddr,pl_129.Vbat,pl_129.H,pl_129.P,pl_129.W,pl_129.W1,pl_129.W2,pl_129.T,lrrlat,lrrlon,pl_129.Fw_version)
    }
  }
  // Send alert if necessary
  if val, ok := alertMap[deveui]; ok {
    sendAlert(deveui,val)
    delete(alertMap,deveui)
    // alte Werte loeschen
    deleteValues(deveui)
  }
  if val2, ok2 := alertLogMap[deveui]; ok2 {
    WriteStringToFile(val2)
    delete(alertLogMap,deveui)
  }
}

func WriteDatapoint(mytime int64, deveui string, devaddr string, v uint8, h uint8, p uint8, w uint16, w1 int32, w2 int32, t int16, lrrlat float32, lrrlon float32, fw_version int32) {
     // wir nehmen humidity als Referenz, wenn diese > 0 ist, dann ist es
     // eine gueltige Messung
     var vp uint8  // Voltage in %
     if (h > 0) {
         vp = v - 70
         if vp < 0 { 
           vp = 0
         } else if vp > 100 {
           vp = 100
         }

         s := ""
         if (v > 0) {
             s = fmt.Sprintf("measurement,deveui=%s devaddr=\"%s\",v=%di,vp=%di,h=%di,p=%di,w=%di,w1=%di,w2=%di,t=%.1f,lrrlat=%f,lrrlon=%f,fw_version=%di %d\n",deveui,devaddr,int32(v)*7+2510,vp,h,int32(p)+825,w*5,w1,w2,float32(t)/10,lrrlat,lrrlon,fw_version,mytime*60*1000*1000*1000)
         } else {
             s = fmt.Sprintf("measurement,deveui=%s devaddr=\"%s\",h=%di,p=%di,w=%di,w1=%di,w2=%di,t=%.1f,lrrlat=%f,lrrlon=%f,fw_version=%di %d\n",deveui,devaddr,h,int32(p)+825,w*5,w1,w2,float32(t)/10,lrrlat,lrrlon,fw_version,mytime*60*1000*1000*1000)
         }

         WriteStringToFile(s)

         w_gram := w*5
         addValue(deveui,w_gram)
         w_loss := getMaxValue(deveui) - w_gram;
         if (w_loss > 500) { 
           // Schwarmalarm!
           alertLogMap[deveui] = fmt.Sprintf("alert,deveui=%s reason=\"swarmalarm\",w=%di,w_loss=%di %d\n",deveui,w_gram,w_loss,mytime*60*1000*1000*1000)
           location, _ := time.LoadLocation("Europe/Zurich")
           alertMap[deveui] = fmt.Sprintf("*** Schwarmalarm ***\n%s\n%s\nGewichtsverlust: %d g",getDevAlias(deveui),time.Unix(mytime*60,0).In(location).Format("02.01.2006 15:04"),w_loss)
         }
     }
}

func WriteStringToFile(s string) {
	n, err := file.WriteString(s)
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}
	if n != len(s) {
		fmt.Println("failed to write data")
		os.Exit(1)
	}
}

func main() {
        // Init Redis
        initDB()

        // Init alertMap
        alertMap = make(map[string]string)
        alertLogMap = make(map[string]string)

        // Open Output File
	f, err := os.OpenFile(outputfile,os.O_CREATE|os.O_APPEND|os.O_WRONLY, 0644)
        file = f
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}
	defer file.Close()

	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		var u Message
		if r.Body == nil {
			http.Error(w, "Please send a request body", 400)
			return
		}

		buf, bodyErr := ioutil.ReadAll(r.Body)
		if bodyErr != nil {
			log.Print("bodyErr ", bodyErr.Error())
			http.Error(w, bodyErr.Error(), http.StatusInternalServerError)
			return
		}

		rdr1 := ioutil.NopCloser(bytes.NewBuffer(buf))
		rdr2 := ioutil.NopCloser(bytes.NewBuffer(buf))
		log.Printf("BODY: %s", rdr1)
		r.Body = rdr2

		err := json.NewDecoder(r.Body).Decode(&u)
		if err != nil {
			http.Error(w, err.Error(), 400)
			return
		}
		fmt.Println("Time:        " + u.Prop.Time)
		fmt.Println("Payload Hex: " + u.Prop.Payload_hex)
		fmt.Println("DevEUI:     " + u.Prop.DevEUI)
		fmt.Println("DevAddr:     " + u.Prop.DevAddr)
		fmt.Printf("LrrLAT:     %f\n",u.Prop.LrrLAT)
		fmt.Printf("LrrLON:     %f\n",u.Prop.LrrLON)
                DecodePayload(u.Prop.Payload_hex, u.Prop.DevEUI, u.Prop.DevAddr, u.Prop.LrrLAT, u.Prop.LrrLON, true)
	})
	log.Fatal(http.ListenAndServe(":8080", nil))
}