Initial Commit

Author: kunal-saxena10

.gitignore

@@ -0,0 +1 @@
+wattx-task

.idea/codeStyleSettings.xml

@@ -0,0 +1,101 @@
+# Wattx-Task
+
+
+## Problem Statement
+
+Emulate a heating service in which sensors in a room records temperature and periodically publish readings in a specific format.
+After receiving the values, openness of the valve is determined and again published.
+
+## Solution
+ 
+ A message broker is used to publish and subscribe messages in the IOT environment. 
+ Some assumptions are made to emulate the real world scenario.
+ 
+ - A room consists of 10 sensors.
+ - Every sensors randomly publishes the recorded reading attached to a given topic.
+ - Every 20 seconds(periodically) a reading is published.
+ - Currently, the test scenario allows a total of 4 readings ina  single run.
+  
+## Execution
+  
+  Set mqtt broker up and running:
+ ```sh
+ $ docker run -d -p 1883:1883 -p 8883:8883 prologic/mosquitto
+
+ ``` 
+ 
+```
+Give examples
+```
+
+### Installing
+
+A step by step series of examples that tell you have to get a development env running
+
+Say what the step will be
+
+```
+Give the example
+```
+
+And repeat
+
+```
+until finished
+```
+
+End with an example of getting some data out of the system or using it for a little demo
+
+## Running the tests
+
+Explain how to run the automated tests for this system
+
+### Break down into end to end tests
+
+Explain what these tests test and why
+
+```
+Give an example
+```
+
+### And coding style tests
+
+Explain what these tests test and why
+
+```
+Give an example
+```
+
+## Deployment
+
+Add additional notes about how to deploy this on a live system
+
+## Built With
+
+* [Dropwizard](http://www.dropwizard.io/1.0.2/docs/) - The web framework used
+* [Maven](https://maven.apache.org/) - Dependency Management
+* [ROME](https://rometools.github.io/rome/) - Used to generate RSS Feeds
+
+## Contributing
+
+Please read [CONTRIBUTING.md](https://gist.github.com/PurpleBooth/b24679402957c63ec426) for details on our code of conduct, and the process for submitting pull requests to us.
+
+## Versioning
+
+We use [SemVer](http://semver.org/) for versioning. For the versions available, see the [tags on this repository](https://github.com/your/project/tags). 
+
+## Authors
+
+* **Billie Thompson** - *Initial work* - [PurpleBooth](https://github.com/PurpleBooth)
+
+See also the list of [contributors](https://github.com/your/project/contributors) who participated in this project.
+
+## License
+
+This project is licensed under the MIT License - see the [LICENSE.md](LICENSE.md) file for details
+
+## Acknowledgments
+
+* Hat tip to anyone who's code was used
+* Inspiration
+* etc

.idea/libraries/GOPATH__wattx_task_.xml

@@ -0,0 +1,12 @@
+package config
+
+import (
+
+	"github.com/eclipse/paho.mqtt.golang"
+)
+
+
+func Init(conn string) *mqtt.ClientOptions{
+
+	return mqtt.NewClientOptions().AddBroker(conn)
+}

.idea/libraries/Go_SDK.xml

@@ -0,0 +1,184 @@
+package helper
+
+import (
+	"errors"
+	"fmt"
+	log "github.com/Sirupsen/logrus"
+	"math/rand"
+	"strconv"
+	"time"
+	mqtt "github.com/eclipse/paho.mqtt.golang"
+	"github.com/wattx-task/models"
+	"os"
+	"encoding/json"
+
+)
+
+// Publish message on /acuators/room-1 topic
+func PubValveValue (str []byte, client mqtt.Client){
+
+	token := client.Publish("/actuators/room-1", 0, true, str)
+	token.Wait()
+	//str := strings.Replace(str, \,  " ", -1)
+	fmt.Printf("Publishing message on topic: /actuators/room-1 : %v \n", string(str))
+
+}
+
+
+// Unsubscribe from a topic
+func Unsubscribe (broker *models.BrokerSub,  client mqtt.Client) error{
+
+	if token := client.Unsubscribe(broker.Topic); token.Wait() && token.Error() != nil {
+		fmt.Println(token.Error())
+		return token.Error()
+	}
+	return nil
+}
+
+
+
+// Publish message on /readings/temperature
+func Publish(broker *models.BrokerPub, client mqtt.Client) error {
+
+	if broker.Action != "pub" {
+		err := errors.New("Invalid setting for action, must be pub")
+		return err
+	}
+
+	if broker.Topic == "" {
+		err := errors.New("Invalid setting for topic, must not be empty")
+		return err
+	}
+
+	token := client.Publish(broker.Topic, 0, true, broker.Payload)
+        token.Wait()
+
+	return nil
+
+}
+
+
+// Callback on subscriber after receiving message for a given topic
+func onMessageRecv(client mqtt.Client, message mqtt.Message){
+
+	var temp models.TempReading
+	if err := json.Unmarshal(message.Payload(), &temp); err != nil {
+		log.Println(err)
+		return
+	}
+
+	fmt.Printf("Received message on topic: %v  Message: %+v \n ", message.Topic(), string(message.Payload()))
+
+	valvePercent := RegulateTemp(temp.Value)
+	reqNum := fmt.Sprintf("%.2f", valvePercent)
+	out, err := json.Marshal(reqNum)
+	if err != nil {
+		log.Println(err)
+		return
+	}
+
+	PubValveValue(out,client )
+
+}
+
+// Specifies valve openness in percentages
+func RegulateTemp (value float64) float64{
+
+	if value> 22 {
+		return (22 * 100)/ value
+	}else if value < 22{
+              return 100.0
+	}
+
+	return 0.0
+}
+
+
+// Subscribes to a given topic
+func Subscribe(broker *models.BrokerSub, client mqtt.Client) error {
+
+	if broker.Topic == "" {
+		err := errors.New("Invalid setting for topic, must not be empty")
+		log.Errorln(err)
+		os.Exit(1)
+	}
+
+	if token := client.Subscribe(broker.Topic, 0, onMessageRecv); token.Wait() && token.Error() != nil {
+			fmt.Println(token.Error())
+			return token.Error()
+	}
+	return nil
+}
+
+
+// Generates periodic messages and call publisher
+func GenPeriodicTemp(d time.Duration, c mqtt.Client) error {
+
+	rand.Seed(time.Now().UTC().UnixNano())
+	ticker := time.NewTicker(time.Second * 5)
+
+	go func() {
+		for x := range ticker.C{
+
+			reqRandTemp := GetRandomfloat(18.0, 25.0)
+			randomInt := GetRandomInt(0, 10)
+			randomIntString := fmt.Sprintf("%d", randomInt)
+			sensorID := "sensorID" + "-" + randomIntString
+
+			temp := &models.TempReading{
+				SensorID: sensorID,
+				Type:     "Temperature",
+				Value:    reqRandTemp,
+			}
+
+			out, err := json.Marshal(temp)
+			if err != nil {
+				log.Println(err)
+				return
+			}
+
+			broker := &models.BrokerPub{
+				Topic:   "/readings/temperature",
+				Action:  "pub",
+				Payload: string(out),
+				Num:     1,
+			}
+
+			err = Publish(broker, c)
+			if err != nil {
+				err = errors.New("Unable to publish reading")
+				return
+			}
+			fmt.Printf("%+v  published  at %v \n", broker, x)
+
+		}
+
+	}()
+
+	time.Sleep(time.Second * 20)
+	ticker.Stop()
+
+	return nil
+}
+
+// Generates random integer
+func GetRandomInt(min int, max int) int {
+
+	return min + rand.Intn(max-min)
+}
+
+
+// Generates random float
+func GetRandomfloat(mint float64, max float64) float64 {
+
+	num := (rand.Float64() * 30) + 7
+	reqNum := fmt.Sprintf("%.2f", num)
+
+	i, err := strconv.ParseFloat(reqNum, 64)
+	if err != nil {
+		log.Println(err)
+		return 0.0
+	}
+	return i
+}
+