ADD : NEW Format for all the code with prettier

src/main/java/Credentials/UserCredentials.java

@@ -1,11 +1,13 @@
 package Credentials;
 
 public class UserCredentials {
+
   private final String username = "kevin.shehu@hochschule-rhein-waal.de";
   private final String password = "DK7SxFkGJgnLhnU3";
   private final String baseURL = "https://api.whysor.com/";
   private final String devUrl = "https://api.dev.whysor.com/";
-    private static final String homeRoot = "D:\\WORK\\GGD\\src\\main\\java\\Data\\";
+  private static final String homeRoot =
+    "D:\\WORK\\GGD\\src\\main\\java\\Data\\";
 
   public static String getHomeRoot() {
     return homeRoot;
@@ -29,11 +31,21 @@ public class UserCredentials {
 
   @Override
   public String toString() {
-        return "UserCredentials{" +
+    return (
-                "username='" + username + '\'' +
+      "UserCredentials{" +
-                ", password='" + password + '\'' +
+      "username='" +
-                ", baseURL='" + baseURL + '\'' +
+      username +
-                ", devUrl='" + devUrl + '\'' +
+      '\'' +
-                '}';
+      ", password='" +
+      password +
+      '\'' +
+      ", baseURL='" +
+      baseURL +
+      '\'' +
+      ", devUrl='" +
+      devUrl +
+      '\'' +
+      '}'
+    );
   }
 }

src/main/java/Files/ReadFile.java

@@ -5,10 +5,10 @@ import java.io.File;  // Import the File class
 import java.util.Scanner; // Import the Scanner class to read text files
 
 public class ReadFile {
+
   public String data;
 
   public String ReadFromFile(String path) {
-
     try {
       File myObj = new File(path);
       Scanner myReader = new Scanner(myObj);
@@ -23,6 +23,4 @@ public class ReadFile {
     }
     return data;
   }
-
-
 }

src/main/java/Files/WriteFile.java

@@ -1,12 +1,11 @@
 package Files;
 
 import java.io.*;
-
-
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeoutException;
 
 public class WriteFile {
+
   BufferedWriter buffer = null;
 
   public void WriteFile(String path, String input) throws Exception {
@@ -19,20 +18,17 @@ public class WriteFile {
       FileWriter fileWriter = new FileWriter(path);
       buffer = new BufferedWriter(fileWriter);
       buffer.write(input);
-
     } catch (FileNotFoundException e) {
       e.printStackTrace();
     } catch (IOException e) {
       e.printStackTrace();
     } finally {
       try {
-                if (buffer != null)
+        if (buffer != null) buffer.flush();
-                    buffer.flush();
         //                    buffer.close();
       } catch (Exception ex) {
         System.out.println("Error in closing the BufferedWriter" + ex);
       }
     }
-
   }
 }

src/main/java/HttpCall/HttpGet.java

@@ -11,30 +11,36 @@ import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 
 public class HttpGet {
-    public String HttpGetCall (String baseURL, String token) throws InterruptedException, ExecutionException, TimeoutException {
+
-        var client = HttpClient.newBuilder()
+  public String HttpGetCall(String baseURL, String token)
+    throws InterruptedException, ExecutionException, TimeoutException {
+    var client = HttpClient
+      .newBuilder()
       .version(HttpClient.Version.HTTP_1_1)
       .followRedirects(HttpClient.Redirect.ALWAYS)
       .build();
     HttpRequest request = null;
     try {
-            request = HttpRequest.newBuilder(new URI(baseURL))
+      request =
+        HttpRequest
+          .newBuilder(new URI(baseURL))
           .setHeader("Authorization", token)
           //                        .setHeader("access_token", token)
           .setHeader("Content-Type", "application/json")
           .setHeader("Accept", "application/json")
           .header("Authority", "https://api.dev.whysor.com/")
           .build();
-
     } catch (URISyntaxException e) {
       e.printStackTrace();
     }
-        CompletableFuture<HttpResponse<String>> response = client.sendAsync(request, HttpResponse.BodyHandlers.ofString());
+    CompletableFuture<HttpResponse<String>> response = client.sendAsync(
-        String result = response.thenApply(HttpResponse::body).get(5, TimeUnit.SECONDS);
+      request,
-
+      HttpResponse.BodyHandlers.ofString()
-
+    );
+    String result = response
+      .thenApply(HttpResponse::body)
+      .get(5, TimeUnit.SECONDS);
 
     return result;
-
   }
 }

src/main/java/HttpCall/HttpPost.java

@@ -9,26 +9,33 @@ import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 
 public class HttpPost {
-    public String HttpCallPost(String baseUrl, String body) throws Exception {
 
-        var client = HttpClient.newBuilder()
+  public String HttpCallPost(String baseUrl, String body) throws Exception {
+    var client = HttpClient
+      .newBuilder()
       .version(HttpClient.Version.HTTP_1_1)
       .followRedirects(HttpClient.Redirect.ALWAYS)
       .build();
     HttpRequest request = null;
     try {
-            request = HttpRequest.newBuilder(new URI(baseUrl))
+      request =
+        HttpRequest
+          .newBuilder(new URI(baseUrl))
           .POST(HttpRequest.BodyPublishers.ofString(body))
           .setHeader("Content-Type", "application/json")
           .setHeader("Accept", "application/json")
           .build();
-
     } catch (URISyntaxException e) {
       e.printStackTrace();
     }
 
-        CompletableFuture<HttpResponse<String>> response = client.sendAsync(request, HttpResponse.BodyHandlers.ofString());
+    CompletableFuture<HttpResponse<String>> response = client.sendAsync(
-        String result = response.thenApply(HttpResponse::body).get(5, TimeUnit.SECONDS);
+      request,
+      HttpResponse.BodyHandlers.ofString()
+    );
+    String result = response
+      .thenApply(HttpResponse::body)
+      .get(5, TimeUnit.SECONDS);
     return result;
   }
 }

src/main/java/JSON_Unpack/GeneralCall4AllDevices.java

@@ -7,6 +7,7 @@ import org.json.JSONArray;
 
 //Get a list of all devices
 public class GeneralCall4AllDevices {
+
   public static String FetchAll(String token) throws Exception {
     String extension = "devices";
     UserCredentials userCredentials = new UserCredentials();
@@ -17,7 +18,10 @@ public class GeneralCall4AllDevices {
     String devUrl = userCredentials.getDevUrl();
     HttpGet httpCall = new HttpGet();
 
-        String fetchAll = httpCall.HttpGetCall(devUrl + extension + "?access_token=" + token, token);
+    String fetchAll = httpCall.HttpGetCall(
+      devUrl + extension + "?access_token=" + token,
+      token
+    );
     writingIntoFile.WriteFile(homeRoot + extension + "Output.json", fetchAll);
 
     return fetchAll;

src/main/java/JSON_Unpack/ReadSensors4Partner.java

@@ -1,19 +1,18 @@
-
 package JSON_Unpack;
 
 import Credentials.UserCredentials;
 import Files.WriteFile;
 import HttpCall.HttpGet;
+import java.util.ArrayList;
 import org.json.JSONArray;
 import org.json.JSONObject;
 
-import java.util.ArrayList;
-
 ///url/sensors/id/read
 
 public class ReadSensors4Partner {
-    public ArrayList<String> FetchSensor4Box(String companyName, String token) throws Exception {
 
+  public ArrayList<String> FetchSensor4Box(String companyName, String token)
+    throws Exception {
     switch (companyName) {
       case "Germes":
         return SensorRead("Germes", token);
@@ -27,7 +26,8 @@ public class ReadSensors4Partner {
     return null;
   }
 
-    protected ArrayList<String> SensorRead(String cName, String token) throws Exception {
+  protected ArrayList<String> SensorRead(String cName, String token)
+    throws Exception {
     UserCredentials userCredentials = new UserCredentials();
     HttpGet httpCall = new HttpGet();
     WriteFile writingIntoFile = new WriteFile();
@@ -44,32 +44,44 @@ public class ReadSensors4Partner {
     for (int i = 0; i < outputBox.size(); i++) {
       JSONArray jsonArray = new JSONArray(outputBox.get(i));
       for (int j = 0; j < jsonArray.length(); j++) {
-
         JSONObject jsonobject = jsonArray.getJSONObject(j);
         String jsonID = jsonobject.getString("id");
         String jsonTag = jsonobject.getString("tag");
         String deviceID = jsonobject.getString("deviceId");
-                String finalTag = ","+par+"deviceId"+par+":"+deviceID+","+par+"sensorTag"+par+":"+jsonTag+"}]";
+        String finalTag =
+          "," +
+          par +
+          "deviceId" +
+          par +
+          ":" +
+          deviceID +
+          "," +
+          par +
+          "sensorTag" +
+          par +
+          ":" +
+          jsonTag +
+          "}]";
 
-                String sensorOutput = httpCall.HttpGetCall(devUrl + "sensors/" + jsonID + "/read" + "?access_token=" + token, token);
+        String sensorOutput = httpCall.HttpGetCall(
+          devUrl + "sensors/" + jsonID + "/read" + "?access_token=" + token,
+          token
+        );
         if (sensorOutput.contains("error")) {
           System.out.println(sensorOutput);
-                }
+        } else {
-                else {
           String modification = sensorOutput.replace("}]", "");
           String finalSensorOutput = modification + finalTag;
           list.add(finalSensorOutput);
 
-                    writingIntoFile.WriteFile(homeRoot + jsonID + ".json", sensorOutput + jsonTag+","+deviceID);
+          writingIntoFile.WriteFile(
-                }
+            homeRoot + jsonID + ".json",
-
+            sensorOutput + jsonTag + "," + deviceID
-
+          );
+        }
       }
     }
-
 
     return list;
   }
-
-
 }

src/main/java/eu/hsrw/ias/ggd/ApiCall.java

@@ -3,22 +3,18 @@ package eu.hsrw.ias.ggd;
 import Credentials.UserCredentials;
 import Files.WriteFile;
 import JSON_Unpack.ReadSensors4Partner;
-import org.json.JSONArray;
-import org.json.JSONObject;
-
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.HashMap;
-
+import org.json.JSONArray;
+import org.json.JSONObject;
 
 public class ApiCall {
+
   private static String token = "0";
   private static String oldId = "1";
 
-
+  public static Greenhouse FetchDataFromApi() throws Exception {
-    public static HashMap<String, SensorData> FetchDataFromApi() throws Exception {
-
-
     UserCredentials userCredentials = new UserCredentials();
     final String username = userCredentials.getUsername();
     final String password = userCredentials.getPassword();
@@ -27,8 +23,8 @@ public class ApiCall {
     WriteFile writingIntoFile = new WriteFile();
     Date now; // to display current time
     now = new Date();
-        HashMap<String,
+    HashMap<String, Device> devices = new HashMap();
-                SensorData> finalOutput = new HashMap();
+
     if (token.equals(oldId)) {
       //do nothing
     } else {
@@ -43,8 +39,11 @@ public class ApiCall {
         e.printStackTrace();
       }
     }
+
     ReadSensors4Partner readSensors4Partner = new ReadSensors4Partner();
-        ArrayList<String> outputValue = (readSensors4Partner.FetchSensor4Box("Germes", token));
+    ArrayList<String> outputValue =
+      (readSensors4Partner.FetchSensor4Box("Germes", token));
+
     for (int i = 0; i < outputValue.size(); i++) {
       Device device;
       JSONArray sensorDatas = new JSONArray(outputValue.get(i));
@@ -70,8 +69,10 @@ public class ApiCall {
         }
       }
     }
-        return finalOutput;
+    Greenhouse greenhouse = new Greenhouse();
-
+    for (Device device : devices.values()) {
+      greenhouse.addDevice(device);
+    }
+    return greenhouse;
   }
-
 }

src/main/java/eu/hsrw/ias/ggd/Device.java

@@ -4,8 +4,11 @@ import java.util.LinkedList;
 import java.util.List;
 
 public class Device {
+
   private String id;
+  private String externalID;
   private List<SensorData> data;
+  private Severity state = Severity.Unknown;
 
   public Device(String identifier) {
     this.id = identifier;
@@ -28,6 +31,15 @@ public class Device {
     this.id = id;
     return id;
   }
+
+  public void setExternalID(String externalID) {
+    this.externalID = externalID;
+  }
+
+  public String getExternalID() {
+    return externalID;
+  }
+
   public String IdMapper(String id) {
     switch (id) {
       case "fd694041-581e-4c2c-9810-505e62b762e6":
@@ -80,4 +92,14 @@ public class Device {
     this.id = id;
     this.data = data;
   }
+
+  public void setState(Severity state) {
+    if (this.state != Severity.Critical) {
+      this.state = state;
+    }
+  }
+
+  public Severity getState() {
+    return state;
+  }
 }

src/main/java/eu/hsrw/ias/ggd/Greenhouse.java

@@ -0,0 +1,50 @@
+package eu.hsrw.ias.ggd;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class Greenhouse {
+
+  private String id = "8bdbe6ae-eafb-4e99-bb01-db8784dd9633";
+  private Severity state = Severity.Unknown;
+
+  public Greenhouse() {
+    this.devices = new ArrayList<>();
+  }
+
+  public Greenhouse(List<Device> devices) {
+    this.devices = devices;
+  }
+
+  public void addDevice(Device device) {
+    this.devices.add(device);
+  }
+
+  public String getId() {
+    return id;
+  }
+
+  public void setId(String id) {
+    this.id = id;
+  }
+
+  public Severity getState() {
+    return state;
+  }
+
+  public void setState(Severity state) {
+    if (this.state != Severity.Critical) {
+      this.state = state;
+    }
+  }
+
+  public List<Device> getDevices() {
+    return devices;
+  }
+
+  public void setDevices(List<Device> devices) {
+    this.devices = devices;
+  }
+
+  private List<Device> devices;
+}

src/main/java/eu/hsrw/ias/ggd/Isis.java

@@ -3,16 +3,24 @@ package eu.hsrw.ias.ggd;
 import HttpCall.HttpPost;
 
 public class Isis {
-    public static String OnCallMethod(String deviceName, String sensorName) throws Exception {
+
+  public static String OnCallMethod(String deviceName, String sensorName)
+    throws Exception {
     //CONFIG PARAMETERS:
     //BEGIN------------CONFIG PARAMETERS BELOW TO YOUR ENVIRONMENT---------------------------------------
-        String baseURL = "https://api.dev.whysor.com/devices/readValueFromSpeech?access_token=2MreqC9fqXxFHJBEcrCL38LKhEaVcEHmEi6o45CwTV9SSgTAuZ93oiMfY3HVc2fj";
+    String baseURL =
-        final String body = String.format("{\"deviceName\": \"%s\", \"sensorName\": \"%s\", \"domain\": \"my.yookr.org\"}", deviceName, sensorName);
+      "https://api.dev.whysor.com/devices/readValueFromSpeech?access_token=2MreqC9fqXxFHJBEcrCL38LKhEaVcEHmEi6o45CwTV9SSgTAuZ93oiMfY3HVc2fj";
+    final String body = String.format(
+      "{\"deviceName\": \"%s\", \"sensorName\": \"%s\", \"domain\": \"my.yookr.org\"}",
+      deviceName,
+      sensorName
+    );
     HttpPost httpMethodPost = new HttpPost();
     httpMethodPost.HttpCallPost(baseURL, body);
 
     return httpMethodPost.HttpCallPost(baseURL, body);
   }
+
   public static void main(String[] args) {
     try {
       String output = OnCallMethod("Greenhouse 1", "status");
@@ -20,6 +28,5 @@ public class Isis {
     } catch (Exception e) {
       e.printStackTrace();
     }
-
   }
 }

src/main/java/eu/hsrw/ias/ggd/MainExe.java

@@ -1,14 +1,12 @@
 package eu.hsrw.ias.ggd;
 
 import java.util.Timer;
-
+//Before pushing files to the git run : npx prettier --write "**/*.java"
 public class MainExe {
-    public static void main(String[] args){
 
+  public static void main(String[] args) {
     Timer time = new Timer(); // Instantiate Timer Object
     ScheduledTask scheduledTask = new ScheduledTask(); // Instantiate SheduledTask class
     time.schedule(scheduledTask, 0, 1000 * 60 * 1); // Create Repetitively task for every 2 min
   }
-
 }
-

src/main/java/eu/hsrw/ias/ggd/Notification.java

@@ -1,6 +1,7 @@
 package eu.hsrw.ias.ggd;
 
 public class Notification {
+
   private Severity severity = Severity.Optimal;
   private String type;
   private SensorData cause;

src/main/java/eu/hsrw/ias/ggd/SecurityToken.java

@@ -1,23 +1,23 @@
 package eu.hsrw.ias.ggd;
 
 import HttpCall.HttpPost;
-
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeoutException;
 
 public class SecurityToken {
-    public static String OnCallMethod(String username, String password) throws Exception {
+
+  public static String OnCallMethod(String username, String password)
+    throws Exception {
     //CONFIG PARAMETERS:
     //BEGIN------------CONFIG PARAMETERS BELOW TO YOUR ENVIRONMENT---------------------------------------
     String baseURL = "https://api.whysor.com/users/login";
     String devURL = "https://api.dev.whysor.com/users/login";
-        final String body = String.format("{\"email\": \"%s\", \"password\": \"%s\", \"domain\": \"my.dev.yookr.org\"}", username, password);
+    final String body = String.format(
+      "{\"email\": \"%s\", \"password\": \"%s\", \"domain\": \"my.dev.yookr.org\"}",
+      username,
+      password
+    );
     HttpPost httpMethodPost = new HttpPost();
     return httpMethodPost.HttpCallPost(devURL, body);
   }
 }
-
-
-
-
-

src/main/java/eu/hsrw/ias/ggd/SensorData.java

@@ -3,21 +3,22 @@ package eu.hsrw.ias.ggd;
 public class SensorData {
 
   private String sensorId;
+  private String tag;
   private double value;
-    private String deviceId;
+  private Severity state = Severity.Unknown;
 
-    public SensorData(String sensorId, double value,String deviceId) {
+  public SensorData(String sensorId, double value, String tag) {
     this.sensorId = sensorId;
     this.value = value;
-        this.deviceId = deviceId;
+    this.tag = tag;
   }
 
-    public String getSensorTag() {
+  public String getTag() {
-        return sensorId;
+    return tag;
   }
 
-    public void setSensorTag(String sensorTag) {
+  public void setTag(String tag) {
-        this.sensorId = sensorTag;
+    this.tag = tag;
   }
 
   public double getValue() {
@@ -28,8 +29,21 @@ public class SensorData {
     this.value = value;
   }
 
-    public String getDeviceId() {return  deviceId;}
+  public String getSensorId() {
+    return sensorId;
+  }
 
-    public void setDeviceId(String deviceTag){ this.deviceId = deviceTag;
+  public void setSensorId(String id) {
+    this.sensorId = id;
+  }
+
+  public Severity getState() {
+    return state;
+  }
+
+  public void setState(Severity state) {
+    if (this.state != Severity.Critical) {
+      this.state = state;
+    }
   }
 }

src/main/java/eu/hsrw/ias/ggd/SensorMap.java

@@ -3,6 +3,7 @@ package eu.hsrw.ias.ggd;
 import java.util.HashMap;
 
 public class SensorMap {
+
   private HashMap<String, Double> sensors = new HashMap<String, Double>();
 
   public HashMap<String, Double> getSensors() {
@@ -12,6 +13,4 @@ public class SensorMap {
   public void setSensors(HashMap<String, Double> sensors) {
     this.sensors = sensors;
   }
-
-
 }

src/main/java/eu/hsrw/ias/ggd/Severity.java

@@ -5,5 +5,6 @@ public enum Severity {
   Info,
   Warning,
   Error,
-    Critical
+  Critical,
+  Unknown,
 }

src/main/resources/rules/device-sensor-critical.drl

@@ -0,0 +1,31 @@
+import eu.hsrw.ias.ggd.Device;
+import eu.hsrw.ias.ggd.Severity;
+import eu.hsrw.ias.ggd.SensorData;
+
+rule "Sensor of device gone critical"
+when
+    sensorData: SensorData(state == Severity.Critical)
+    device: Device(sensorData contains(sensorData))
+then
+    modify(device){
+        setState(Severity.Critical)
+    }
+    System.out.println("Device: \n" +
+        "\tID: '" + device.getId() + "'" +
+        "\tState: '" + device.getState().toString() + "'"
+     );
+    // Do something the info that a device is gone critical
+end
+
+rule "Sensor of device gone optimal"
+when
+    sensorData: SensorData(state == Severity.Optimal)
+    device: Device(sensorData contains(sensorData))
+then
+    modify(device){
+        setState(Severity.Optimal)
+    }
+
+    // Device is gone optimal
+end
+

src/main/resources/rules/greenhouse_critical.drl

@@ -0,0 +1,25 @@
+import eu.hsrw.ias.ggd.Greenhouse;
+import eu.hsrw.ias.ggd.Device;
+import eu.hsrw.ias.ggd.Severity;
+
+rule "Device of greenhouse gone critical"
+when
+    device: Device(state == Severity.Critical)
+    greenhouse: Greenhouse(devices contains(device))
+    //greenhouse: Greenhouse(devices contains(Device(state == Severity.Critical)))
+then
+    modify(greenhouse){
+        setState(Severity.Critical)
+    }
+    System.out.println("Greenhouse: '" + greenhouse.getId() + "' is '" + greenhouse.getState().toString() + "'");
+end
+
+rule "Device of greenhouse has gone optimal"
+when
+    device: Device(state == Severity.Optimal)
+    greenhouse: Greenhouse(devices contains(device))
+then
+    modify(greenhouse){
+        setState(Severity.Optimal)
+    }
+end

target/classes/rules/CriticalPrecipitation.drl

@@ -0,0 +1,24 @@
+import java.util.HashMap;
+import java.util.Map;
+import eu.hsrw.ias.ggd.SensorData
+import javax.swing.JOptionPane
+import HttpCall.HttpPost
+import eu.hsrw.ias.ggd.Notification
+import eu.hsrw.ias.ggd.Severity;
+import eu.hsrw.ias.ggd.Device;
+
+rule "CriticalPrecipitation"
+    when
+            device: Device(sensorDatas: sensorData)
+            sensorData: SensorData(tag == "precipitation", value > 15.5) from sensorDatas
+    then
+            String greenhouse1="8bdbe6ae-eafb-4e99-bb01-db8784dd9633";
+            HttpPost httpPost = new HttpPost();
+            final String criticalPrecipitationOutput = String.format("{\"id\":\"%s\",\"data\":{\"measured\":[{ \"status\": \"Critical Precipitation %s in the following sensor %s \", \"precipitation\": %s}]}}",greenhouse1, sensorData.getValue(),sensorData.getTag(),sensorData.getValue());
+            httpPost.HttpCallPost("http://connector.dev.whysor.com/default/insert?access_token=3hosOhAeh4k0XmcuAMQGfYldvTuQDvtAj2PJJ4irKPBefD5Ijij6gnUkLtVLd4fW",criticalPrecipitationOutput);
+            insert(new Notification("precipitation", sensorData, Severity.Warning));
+
+//            modify(sensorData){
+//                setState(Severity.Critical)
+//            }
+end

target/classes/rules/CriticalSoilConductivity.drl

@@ -0,0 +1,7 @@
+package rules;
+dialect  "mvel"
+
+rule "CriticalSoilConductivity"
+    when
+    then
+end

target/classes/rules/CriticalSoilTemperature.drl

@@ -0,0 +1,7 @@
+package rules;
+dialect  "mvel"
+
+rule "CriticalSoilTemperature"
+    when
+    then
+end

target/classes/rules/device-sensor-critical.drl

@@ -0,0 +1,31 @@
+import eu.hsrw.ias.ggd.Device;
+import eu.hsrw.ias.ggd.Severity;
+import eu.hsrw.ias.ggd.SensorData;
+
+rule "Sensor of device gone critical"
+when
+    sensorData: SensorData(state == Severity.Critical)
+    device: Device(sensorData contains(sensorData))
+then
+    modify(device){
+        setState(Severity.Critical)
+    }
+    System.out.println("Device: \n" +
+        "\tID: '" + device.getId() + "'" +
+        "\tState: '" + device.getState().toString() + "'"
+     );
+    // Do something the info that a device is gone critical
+end
+
+rule "Sensor of device gone optimal"
+when
+    sensorData: SensorData(state == Severity.Optimal)
+    device: Device(sensorData contains(sensorData))
+then
+    modify(device){
+        setState(Severity.Optimal)
+    }
+
+    // Device is gone optimal
+end
+

target/classes/rules/greenhouse_critical.drl

@@ -0,0 +1,25 @@
+import eu.hsrw.ias.ggd.Greenhouse;
+import eu.hsrw.ias.ggd.Device;
+import eu.hsrw.ias.ggd.Severity;
+
+rule "Device of greenhouse gone critical"
+when
+    device: Device(state == Severity.Critical)
+    greenhouse: Greenhouse(devices contains(device))
+    //greenhouse: Greenhouse(devices contains(Device(state == Severity.Critical)))
+then
+    modify(greenhouse){
+        setState(Severity.Critical)
+    }
+    System.out.println("Greenhouse: '" + greenhouse.getId() + "' is '" + greenhouse.getState().toString() + "'");
+end
+
+rule "Device of greenhouse has gone optimal"
+when
+    device: Device(state == Severity.Optimal)
+    greenhouse: Greenhouse(devices contains(device))
+then
+    modify(greenhouse){
+        setState(Severity.Optimal)
+    }
+end

target/classes/rules/optimal.drl

@@ -0,0 +1,15 @@
+import eu.hsrw.ias.ggd.Notification;
+import eu.hsrw.ias.ggd.Severity
+import HttpCall.HttpPost;
+import eu.hsrw.ias.ggd.Device;
+
+rule "Green House Optimal"
+when
+    warning: Notification(severity == Severity.Optimal)
+
+then
+    HttpPost httpPost = new HttpPost();
+    final String optimalGreenhouse = String.format("{\"id\":\"germes-greenhouse-status\",\"data\":{\"measured\":[{ \"status\": \"The status of the greenhouse is optimal\"}]}}");
+//    httpPost.HttpCallPost("http://connector.dev.whysor.com/default/insert?access_token=3hosOhAeh4k0XmcuAMQGfYldvTuQDvtAj2PJJ4irKPBefD5Ijij6gnUkLtVLd4fW",optimalGreenhouse);
+    System.out.println("Green House optimal, because of: '"+warning.getType()+"'");
+end