Create/modify example code and main code base

window_control/window_control.ino

@@ -24,60 +24,96 @@ void setup() {
   // Initalize buzzer pin
   pinMode(buzzer, OUTPUT);
   digitalWrite(buzzer, LOW);
+
+  // Initalize motor directions
+  pinMode(motorReverse, OUTPUT);
+  digitalWrite(motorReverse, LOW);
+  pinMode(motorForward, OUTPUT);
+  digitalWrite(motorForward, LOW);
+
+  // Initalize Sense Pin
+  pinMode(sense, INPUT);
+  // use "digitalRead(sense);" to read
 }
 
 void setup_wifi() {
   delay(10);
-  // We start by connecting to a WiFi network
-  Serial.println();
-  WiFi.hostname("ESP-" WINDOW_NAME);
-  Serial.print("Connecting to ");
-  Serial.println(WIFI_SSID);
 
+  // Set our hostname
+  WiFi.hostname("ESP-" WINDOW_NAME);
+
+  // Connect to the wifi!
   WiFi.begin(WIFI_SSID, WIFI_PASS);
 
+  // For as long as we're not connected..
   while (WiFi.status() != WL_CONNECTED) {
-    delay(950);
-    tone(buzzer, 1200, 50);
-    Serial.println("Not yet connected.. Waiting 1s to check again..");
+    delay(950); // Wait...
+    tone(buzzer, 1200, 50); // Beep...
+    //Serial.println("Not yet connected.. Waiting 1s to check again..");
   }
 
-  Serial.println("");
-  Serial.println("WiFi connected");
-  Serial.println("IP address: ");
-  Serial.println(WiFi.localIP());
+  //Serial.println("");
+  //Serial.println("WiFi connected");
+  //Serial.println("IP address: ");
+  //Serial.println(WiFi.localIP());
 }
 
 void reconnect() {
   // Loop until we're reconnected
   while (!client.connected()) {
-    Serial.print("Attempting MQTT connection...");
+    //Serial.print("Attempting MQTT connection...");
     // Attempt to connect
     if (client.connect("ESP8266Client", MQTT_USER, MQTT_PASS)) {
-      Serial.println("connected");
+      //Serial.println("connected");
+      ;
     } else {
-      Serial.print("failed, rc=");
-      Serial.print(client.state());
-      Serial.println(" try again in 5 seconds");
+      //Serial.print("failed, rc=");
+      //Serial.print(client.state());
+      //Serial.println(" try again in 5 seconds");
       // Wait 5 seconds before retrying
       delay(5000);
     }
   }
 }
 
-void callback(char* topic, byte* payload, unsigned int length) {
- Serial.print("Message arrived [");
- Serial.print(topic);
- Serial.print("] ");
- for (int i = 0; i < length; i++) {
-  char receivedChar = (char)payload[i];
-  Serial.print(receivedChar);
-  if (receivedChar == '0')
-   //digitalWrite(in_led, LOW);
-  if (receivedChar == '1')
-   //digitalWrite(in_led, HIGH);
- }
- Serial.println();
+void callback(char* topic, byte* message, unsigned int length) {
+  //Serial.print("Message arrived on topic: ");
+  //Serial.print(topic);
+  //Serial.print(". Message: ");
+  String messageString;
+
+  // Reconstruct a string from the mqtt contents.
+  for (int i = 0; i < length; i++) {
+    messageString += (char)message[i];
+  }
+
+  if (String(topic) == MQTT_ROOT "/request_state") {
+    //Serial.print("Changing output to ");
+    if(messageString == "open"){
+      //Serial.println("Opening window.");
+      digitalWrite(motorForward, HIGH);
+      digitalWrite(motorReverse, LOW);
+      tone(buzzer, 2000, 200);
+      delay(200);
+      tone(buzzer, 2000, 200);
+      delay(200);
+      tone(buzzer, 2000, 200);
+      delay(200);
+      client.publish(MQTT_ROOT "/current_state", "open", true);
+    }
+    else if(messageString == "close"){
+      //Serial.println("Closing window");
+      digitalWrite(motorForward, LOW);
+      digitalWrite(motorReverse, HIGH);
+      tone(buzzer, 2000, 200);
+      delay(200);
+      tone(buzzer, 2000, 200);
+      delay(200);
+      tone(buzzer, 2000, 200);
+      delay(200);
+      client.publish(MQTT_ROOT "/current_state", "close", true);
+    }
+  }
 }
 
 void loop() {
@@ -88,11 +124,7 @@ void loop() {
 
   // Run the client loop
   client.loop();
-
-  // Publishes a random 0 and 1 like someone switching off and on randomly (random(2))
-  client.publish(MQTT_ROOT "/random", String(random(2)).c_str(), true);
-  delay(1000);
-  client.subscribe(MQTT_ROOT "/in");
-  tone(buzzer, 2000, 500);
+  
+  client.subscribe(MQTT_ROOT "/request_state");
   delay(1000);
 }