ESP2.ino

#include <HTTPClient.h>
#include <Wire.h>
#include "max32664.h"
#include <PubSubClient.h>
#include <WiFi.h>
#include <ThingSpeak.h>

#define mqttport 1883

char ssid[] = "Sonam gupta bewafa he";
char password[] = "mujhekyametohhuhinhi";
const char* server = "mqtt3.thingspeak.com";
char mqttUserName[] = "FCoPExU9MAUQISkGCBEDCz0";
char mqttClientID[] = "FCoPExU9MAUQISkGCBEDCz0";
char mqttpass[] = "OwEpA4RuSjFFfZNzg6fGoBXa";
int writeChannelID = 2151521;
char writeAPIKey[] = "XVEHO8NYR0DRP5KQ";


WiFiClient client;
PubSubClient mqttClient(server, mqttport, client);

#define CSE_IP "192.168.151.251"
#define CSE_PORT 5089
#define OM2M_ORGIN "admin:admin"
#define OM2M_MN "/~/in-cse/in-name/"
#define OM2M_AE "AE-TEST"
#define OM2M_DATA_CONT "User-Patterns"

#define RESET_PIN 4
#define MFIO_PIN 5
// SCL 22
// SDA 21
#define RAWDATA_BUFFLEN 250

max32664 MAX32664(RESET_PIN, MFIO_PIN, RAWDATA_BUFFLEN);
HTTPClient http;


void mfioInterruptHndlr(){
  //Serial.println("i");
}

void enableInterruptPin(){

  //pinMode(mfioPin, INPUT_PULLUP);
  attachInterrupt(digitalPinToInterrupt(MAX32664.mfioPin), mfioInterruptHndlr, FALLING);

}

void loadAlgomodeParameters(){

  algomodeInitialiser algoParameters;
  /*  Replace the predefined values with the calibration values taken with a reference spo2 device in a controlled environt.
      Please have a look here for more information, https://pdfserv.maximintegrated.com/en/an/an6921-measuring-blood-pressure-MAX32664D.pdf
      https://github.com/Protocentral/protocentral-pulse-express/blob/master/docs/SpO2-Measurement-Maxim-MAX32664-Sensor-Hub.pdf
  */

  algoParameters.calibValSys[0] = 120;
  algoParameters.calibValSys[1] = 122;
  algoParameters.calibValSys[2] = 125;

  algoParameters.calibValDia[0] = 80;
  algoParameters.calibValDia[1] = 81;
  algoParameters.calibValDia[2] = 82;

  algoParameters.spo2CalibCoefA = 1.5958422;
  algoParameters.spo2CalibCoefB = -34.659664;
  algoParameters.spo2CalibCoefC = 112.68987;

  MAX32664.loadAlgorithmParameters(&algoParameters);
}


#define flexSensorpin 32
#define sound_pin 33

void setup(){

  Serial.begin(115200);
  pinMode(flexSensorpin,INPUT);
  pinMode(sound_pin,INPUT);
  // pinMode(piezoelectric_sensor,INPUT);
  // pinMode(emg_pin,INPUT);  
  WiFi.begin(ssid ,password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.println("Connecting to WiFi...");
  }

  Serial.println("Connected to WiFi");
  Serial.print("Local IP address: ");
  Serial.println(WiFi.localIP());

  mqttClient.setServer(server, mqttport);
}

void mqttConnect(){
  while (!mqttClient.connected()) {
    Serial.println("Connecting to MQTT...");
    if (mqttClient.connect(mqttClientID, mqttUserName, mqttpass )) {
      Serial.println("connected");
    } else {
      Serial.print("failed with state ");
      Serial.print(mqttClient.state());
      delay(2000);
    }
  }
}

void mqttPublish(long writeChannelID, char* pubWriteAPIKey,String dataString){
  // int index = 0;
  // String dataString = "";

  // while(fieldArray[index] == 1){
  // dataString = "field1="+String(hr)+"&field2="+String(systole)+"&field3="+String(diastole)+"&field4="+String(spo2);
  // index++;
  // Serial.println(dataString);
  String topicString = "channels/" + String( writeChannelID ) + "/publish";
  // Serial.println(topicString);
  mqttClient.publish(topicString.c_str(), dataString.c_str());
  // Serial.println(writeChannelID);
}

void publish_to_om2m(String data,String label)
{
    //   String label = "Label";
    // String data;
    String server = "http://" + String() + CSE_IP + ":" + String() + CSE_PORT + String() + OM2M_MN + String() + OM2M_AE + "/" + String() + OM2M_DATA_CONT + "/";
    
    if (label=="Label-1")
      server += "Flex_Sensor";

    else if(label=="Label-4")
      server += "Microphone";

    Serial.println(server);

    http.begin(server);    

    http.addHeader("X-M2M-Origin", OM2M_ORGIN);
    http.addHeader("Content-Type", "application/json;ty=4");
    // http.addHeader("Content-Length", "100");

    // data = "[" + String(systole) + ", " + String(diastole) + ", " + String(hr) + ", " + String(spo2) + "]"; 
    String req_data = String() + "{\"m2m:cin\": {"

      +
      "\"con\": \"" + "[" + data + "]" + "\","

      +
      "\"lbl\": \"" + label + "\""

      // + "\"rn\": \"" + "Entry "+String(i++) + "\","

      // +
      // "\"cnf\": \"text\""

      +
      "}}";
      Serial.println(req_data);
    int code = http.POST(req_data);
    http.end();
    Serial.println(code);
}

void loop(){

  // Serial.println("start in estimation mode");
  float VCC = 4.98; // Measured voltage of Ardunio 5V line
  float R_DIV = 11000.0; // Measured resistance of 3.3k resistor

  // Upload the code, then try to adjust these values to more
  // accurately calculate bend degree.
  float STRAIGHT_RESISTANCE = 38600.0; // resistance when straight
  float BEND_RESISTANCE = 108000.0; // resistance at 90 deg
  int flexADC = analogRead(flexSensorpin);
  float flexV = flexADC * VCC / 1023.0;
  float flexR = R_DIV * (VCC / flexV - 1.0);
  // Serial.println("Resistance: " + String(flexR) + " ohms");

  // Use the calculated resistance to estimate the sensor's
  // bend angle:
  // float angle = map(flexR, STRAIGHT_RESISTANCE, BEND_RESISTANCE, 0, 90.0);
  // Serial.println("Bend: " + String(angle) + " degrees");
  // Serial.println();

  int flex_sensor_value=analogRead(flexSensorpin);
  // Serial.print("Flex Sensor value: ");
  // Serial.println(angle);
  // Serial.println(flex_sensor_value);


  int sound_value=analogRead(sound_pin);
  // Serial.print("Electronic Microphone Value: ");
  Serial.println(sound_value);

  String sound_publish=String(sound_value);
  String flex_to_publish=String(flex_sensor_value);

  publish_to_om2m(sound_publish,"Label-4");
  publish_to_om2m(flex_to_publish,"Label-1");

  // publish to mqtt

  delay(50);
}