Split_Circuit_MPU6050.ino

//--------------------Importing Packages--------------------
#include <WiFi.h>
#include <WiFiMulti.h>
#include <FirebaseESP32.h>
#include <Adafruit_MPU6050.h> 
#include <Adafruit_SSD1306.h> 
#include <Adafruit_Sensor.h> 



//--------------------Accessing to Google Firebase--------------------
//Provide the token generation process info.
#include "addons/TokenHelper.h"
//Provide the RTDB payload printing info and other helper functions.
#include "addons/RTDBHelper.h"
// Insert Firebase project API Key
#define API_KEY "AIzaSyDH9SMbhwEBF9rRmpaPMHSakGDCtrobFf4"
// Insert RTDB URLefine the RTDB URL */
#define DATABASE_URL "https://morphine-64cdd-default-rtdb.asia-southeast1.firebasedatabase.app/" 
// Insert Authorized Email and Corresponding Password
#define USER_EMAIL "nusmedtech.morphine@gmail.com"
#define USER_PASSWORD "MorphineAddicts"

/** 5. Define the database secret (optional)
 *
 * This database secret needed only for this example to modify the database rules
 *
 * If you edit the database rules yourself, this is not required.
 */
#define DATABASE_SECRET "DATABASE_SECRET"



//--------------------Define Firebase Data object--------------------
FirebaseData fbdo; //Define Firebase Object
FirebaseJson json; //Firebase store data as JSON objects
FirebaseAuth auth; //FirebaseAuth data for authentication data
FirebaseConfig config; //FirebaseConfig data for config data
FirebaseJsonData result;



//-------------------Define multi wifi object-------------------------
WiFiMulti wifiMulti;
const char* ssid = "SLZ";
const char* password =  "12345678";



//--------------------Define variables--------------------
#define button_pin 15
unsigned long sendDataPrevMillis = 0;
int count = 0;
bool signupOK = false;
float LoopCodeStartTime = 0;
float LoopCodeEndTime = 0;
float StartUpload = 0;
float EndUpload = 0;
float UploadSpeed = 0;
float LoopSpeed = 0;
const uint32_t connectTimeoutMs = 10000; // WiFi connect timeout per AP. Increase when connecting takes longer.
String StringValue = "";
String panic_state = "";

//--------------------Initialising Components--------------------
Adafruit_MPU6050 mpu; 
Adafruit_SSD1306 display = Adafruit_SSD1306(128, 64, &Wire); 




 
void setup() {
  Serial.begin(115200);
//--------------------Panic Button-------------------- 
  pinMode(button_pin, INPUT_PULLUP);

//--------------------Wifi Connection-------------------- 
  WiFi.mode(WIFI_STA);
  
  // Add list of wifi networks
  wifiMulti.addAP("Lakshmi's Galaxy S21", "wbmt3054"); //Lakshmi's hotspot
  wifiMulti.addAP("Galaxy S10+f6dc" , "kism8575"); //Lakshmi's hotspot 2
  wifiMulti.addAP("Syarwina's iPhone", "nowifiagain"); //Syarwina's hotspot
  wifiMulti.addAP("kai Jun's phone", "12345678"); //Zhe Li's hotspot
  wifiMulti.addAP("SLZ", "12345678"); //LieZhou's hotspot
  wifiMulti.addAP("Rigel wifi", "12345678"); //Rigel's hotspot
  wifiMulti.addAP("Neh", "1235abcd"); //Ernest's hotspot

  
 

  // WiFi.scanNetworks will return the number of networks found
  int n = WiFi.scanNetworks();
  Serial.println("scan done");
  if (n == 0) {
      Serial.println("no networks found");
  } 
  else {
    Serial.print(n);
    Serial.println(" networks found");
    for (int i = 0; i < n; ++i) {
      // Print SSID and RSSI for each network found
      Serial.print(i + 1);
      Serial.print(": ");
      Serial.print(WiFi.SSID(i));
      Serial.print(" (");
      Serial.print(WiFi.RSSI(i));
      Serial.print(")");
      Serial.println((WiFi.encryptionType(i) == WIFI_AUTH_OPEN)?" ":"*");
      delay(10);
    }
  }

  // Connect to Wi-Fi using wifiMulti (connects to the SSID with strongest connection)
  Serial.println("Connecting Wifi...");
  if(wifiMulti.run() == WL_CONNECTED) {
    Serial.println("");
    Serial.println("WiFi connected");
    Serial.println("IP address: ");
    Serial.println(WiFi.localIP());
  }

  
//--------------------Firebase login-------------------- 

  /* Assign the api key (required) */
  config.api_key = API_KEY;
  /* Assign the user sign in credentials */
  auth.user.email = USER_EMAIL;
  auth.user.password = USER_PASSWORD;
  /* Assign the RTDB URL (required) */
  config.database_url = DATABASE_URL;
  Firebase.reconnectWiFi(true);
  fbdo.setResponseSize(4096);
  /* Assign the callback function for the long running token generation task */
  config.token_status_callback = tokenStatusCallback; //see addons/TokenHelper.h
  Firebase.begin(&config, &auth);


  String base_path = "/UsersData/";
  /** Now modify the database rules (if not yet modified)
   *
   * The user, <user uid> in this case will be granted to read and write
   * at the certain location i.e. "/UsersData/<user uid>".
   *
   * If you database rules has been modified, please comment this code out.
   *
   * The character $ is to make a wildcard variable (can be any name) represents any node key
   * which located at some level in the rule structure and use as reference variable
   * in .read, .write and .validate rules
   *
   * For this case $userId represents any <user uid> node that places under UsersData node i.e.
   * /UsersData/<user uid> which <user uid> is user UID.
   *
   * Please check your the database rules to see the changes after run the below code.
   */
  String var = "$userId";
  String val = "($userId === auth.uid && auth.token.premium_account === true && auth.token.admin === true)";
  Firebase.setReadWriteRules(fbdo, base_path, var, val, val, DATABASE_SECRET);


//--------------------MPU6050 Set-up-------------------- 
  Serial.println("MPU6050 OLED Demo");

  if (!mpu.begin()) {
    Serial.println("MPU6050 init failed");
    while (1)
      yield();
  }
  Serial.println("Found a MPU-6050 sensor"); 


//--------------------SSD1306 Set-up--------------------  
  if (!display.begin(SSD1306_SWITCHCAPVCC, 0x3C)) { // Address 0x3C for 128x32 
    Serial.println(F("SSD1306 allocation failed")); 
    for (;;) 
      ; // Don't proceed, loop forever 
  } 
  display.clearDisplay(); 
  display.setTextSize(0.5); 
  display.setCursor(0,0); 
} 

 
void loop() {
  LoopCodeStartTime = millis();
  String path = "/Users Data/";
  path += "Token UID:";
  path += auth.token.uid.c_str();
  path += "/Split Circuit/MPU6050";
  String user_path_accounter = path + "/MPU6050 Accounter";
  String user_path_datapoints = path + "/MPU6050 Datapoints";
  String UploadSpeedPath = path + "/MPU6050 UploadSpeedArr";
  String LoopSpeedPath = path + "/MPU6050 LoopSpeedArr";
  String Fall_indicator_path = path + "/MPU6050 Fall";
  String Panic_path = path + "/Panic Button";

  //if the connection to the stongest hotstop is lost, it will connect to the next network on the list
  if (wifiMulti.run() != WL_CONNECTED) {
    Serial.print("WiFi not connected: ");
  }


  if (Firebase.ready() && (millis() - sendDataPrevMillis > 0.0001 || sendDataPrevMillis == 0)){
  
    sendDataPrevMillis = millis();

    Serial.println("--------------------");
    Serial.println("Sending data to cloud......");
    //append data to string format
    int i = 0;
    int max_samples = 20;
    String datapoints = "";
    FirebaseJsonArray DatapointsArr;
    FirebaseJsonArray IndicatorArr;
    FirebaseJsonArray PanicArr;
    IndicatorArr.add("  ");

    //--------------------Panic state--------------------
    if (digitalRead(button_pin) == 1){
      panic_state = "False";
    } else {
      panic_state = "True";
    }
    PanicArr.add(panic_state);

    
    while (i<max_samples)
    {
      float SetStartTime = millis();
      sensors_event_t a, g, temp;
      mpu.getEvent(&a, &g, &temp);
      datapoints += "Set: ";
      datapoints += String(i);
      datapoints += " ";
      datapoints += "Ax: ";
      datapoints += String(a.acceleration.x);
      datapoints += " ";
      datapoints += "Ay: ";
      datapoints += String(a.acceleration.y);
      datapoints += " ";
      datapoints += "Az: ";
      datapoints += String(a.acceleration.z);
      datapoints += " ";

      datapoints += "gx: ";
      datapoints += String(g.gyro.x);
      datapoints += " ";
      datapoints += "gy: ";
      datapoints += String(g.gyro.y);
      datapoints += " ";
      datapoints += "gz: ";
      datapoints += String(g.gyro.z);
      datapoints += " ";

      datapoints += "temp: ";
      datapoints += String(temp.temperature);
      datapoints += " ";

      float SetEndTime = millis();
      float SetSpeed = SetEndTime - SetStartTime;
      
      datapoints += "timing for this set: ";
      datapoints += String(SetSpeed);
      datapoints += " ";
      
      i++;
    }
    DatapointsArr.add(datapoints);
    
    StartUpload = millis();
    
    Serial.printf("Uploading Accounter Value... %s\n", Firebase.RTDB.setInt(&fbdo, user_path_accounter, count) ? "ok" : fbdo.errorReason().c_str());
    Serial.printf("Uploading Data Array ... %s\n", Firebase.RTDB.setArray(&fbdo, user_path_datapoints, &DatapointsArr) ? "ok" : fbdo.errorReason().c_str());
    Serial.printf("Set Fall indication... %s\n", Firebase.RTDB.setArray(&fbdo, Fall_indicator_path, &IndicatorArr) ? "ok" : fbdo.errorReason().c_str());
    Serial.printf("Set Panic indication... %s\n", Firebase.RTDB.setArray(&fbdo, Panic_path, &PanicArr) ? "ok" : fbdo.errorReason().c_str());

    EndUpload = millis();
    
    count++;
    Serial.print("Accounter: ");
    Serial.println(count);
  }   

  //-----------For testing speed (remove in final code)-----------
  float UploadSpeed = EndUpload - StartUpload;
  Serial.print("DataBase Upload Speed: ");
  Serial.println(UploadSpeed);
 
  LoopCodeEndTime = millis();
  float LoopSpeed = LoopCodeEndTime - LoopCodeStartTime;
  Serial.print("Loop Code Speed: ");
  Serial.println(LoopSpeed);

  FirebaseJsonArray UploadSpeedArr;
  FirebaseJsonArray LoopSpeedArr;

  UploadSpeedArr.add(UploadSpeed);
  LoopSpeedArr.add(LoopSpeed);
  Serial.printf("Set Upload Speed array... %s\n", Firebase.RTDB.setArray(&fbdo, UploadSpeedPath, &UploadSpeedArr) ? "ok" : fbdo.errorReason().c_str());
  Serial.printf("Set Loop Speed array... %s\n", Firebase.RTDB.setArray(&fbdo, LoopSpeedPath, &LoopSpeedArr) ? "ok" : fbdo.errorReason().c_str());

  Serial.println("");
  //-----------For testing speed (remove in final code)-----------
  
}