_eid.ino

/* 
 todo
  - apart proces van maken
  - UI: check expire claimcode + url (frontend)
*/

#ifndef EID
void handleEnergyID(){ }
#else

#include "./../../_secrets/energyid.h"

String  eid_webhook;
String  eid_header_auth;
String  eid_header_twinid;
String  eid_interval;
uint32_t eid_interval_sec = 300;

//String eid_claim_code = "",eid_claim_url = "";
//time_t eid_claim_exp;

DECLARE_TIMER_SEC(T_EID, 10);
DECLARE_TIMER_SEC(T_EID_CLAIM, 60*1);
DECLARE_TIMER_MIN(T_EID_REFRESH, 24*60);

void handleEnergyID(){  

  if ( !bEID_enabled ) return;
  
  if ( P1Status.eid_state == EID_ENROLLED ) {
    if ( !eid_webhook.length() ) EIDPostHello(); //get the webhook url
    else if ( DUE(T_EID) )  { //is enrolled and got webhook url
      PostEnergyID();
      CHANGE_INTERVAL_SEC(T_EID, eid_interval_sec);
    }
  }
  if ( P1Status.eid_state == EID_CLAIMING && DUE(T_EID_CLAIM) ) EIDPostHello(); //refresh every 5m
  
  if ( DUE(T_EID_REFRESH) ) EIDPostHello(); //refresh every 24h

  //do nothing on EID_IDLE

}

/*
curl --location 'https://hooks.energyid.eu/hello' \
--header 'X-Provisioning-Key: *********** \
--header 'X-Provisioning-Secret: ************************' \
--header 'Content-Type: application/json' \

--data '{
    "claimCode": "",
    "deviceId": "p1-dongle-pro-12345678",
    "deviceName": "P1 Dongle Pro",
    "firmwareVersion": "4.8.6",
    "ipAddress": "127.0.0.1",
    "macAddress": "34.AC.57.12",
    "localDeviceUrl": "http://p1-dongle-pro.local"
}'

response 

{
    "claimCode": "5363a3e6-a6b2-4f6b-97d9-xxxxxxxxxx",
    "claimUrl": "https://app.energyid.eu/integrations/8b20ade6-679c-4df1-ba6a-f36d2f4b0702/new?code=5363a3e6-a6b2-4f6b-97d9-xxxxxxxxxx",
    "exp": 1695822974

}
*/

void EIDPostHello(){
/*  
States
0) IDLE (enabled maar nog niet in claiming fase
1) CLAIMING (/hello opgevraagd maar niet niet geclaimed)
2) ENROLLED -> gekoppeld
 
 */  
   HTTPClient http;
  String payload;
  int httpResponseCode;
  StaticJsonDocument<3000> doc;

  http.begin( EID_PROV_URL );
  http.addHeader( "Content-Type"          , "application/json" );
  http.addHeader( "X-Provisioning-Key"    , EID_PROF_KEY );
  http.addHeader( "X-Provisioning-Secret" , EID_PROF_SECR );

  String json_data;
  String _hostname = String(settingHostname);
  _hostname.toLowerCase();
  
  json_data  = "{\"deviceId\": \"p1-dongle-pro-" + String(_getChipId()) + "\"";
  json_data += ",\"deviceName\": \"" + String(settingHostname) + "\"";
  json_data += ",\"firmwareVersion\": \"" _VERSION_ONLY  "\"";
  json_data += ",\"ipAddress\": \"" + String(IP_Address()) + "\"";
  json_data += ",\"macAddress\": \"" + String(macStr) + "\"";  
  json_data += ",\"localDeviceUrl\": \"http://" + _hostname + ".local\"";  
  json_data += "}";
  
  DebugT(F("Post URL:"));Debugln(EID_PROV_URL);
  DebugT(F("Post data:"));Debugln(json_data);

  httpResponseCode = http.POST(json_data);
  Debug(F("httpResponseCode: "));Debugln(httpResponseCode);
  
  if ( httpResponseCode == 200 ) {
    payload = http.getString();
    Debug(F("response body: "));Debugln(payload);     
  
    DeserializationError error = deserializeJson(doc, payload);
    if (error) {
      DebugTln(F("error parsing the paylod from claim response"));
      httpServer.send(400);
    } else {
      //well parsed
    const char* claim = doc["claimCode"];
    if ( claim ) {
    
//      eid_claim_code = (const char*)doc["claimCode"];
//      eid_claim_url  = (const char*)doc["claimUrl"];
//        eid_claim_exp  = (time_t) doc["exp"];
//
//      Debug(F("eid_claim_code: "));Debugln(eid_claim_code);     
//      Debug(F("eid_claim_url: "));Debugln(eid_claim_url);     
//      Debug(F("eid_claim_exp: "));Debugln(eid_claim_exp);
      Debugln(F("ClaimCode obtained"));
      P1Status.eid_state = EID_CLAIMING;
          
    } else {
      //webhook info
      Debugln(F("Webhook obtained"));
      eid_webhook = (const char*)doc["webhookUrl"];
      eid_header_auth = (const char*)doc["headers"]["authorization"];
      eid_header_twinid = (const char*)doc["headers"]["x-twin-id"];
      eid_interval = (const char*)doc["webhookPolicy"]["allowedInterval"];
      
      Debug(F("webhookUrl: "));Debugln(eid_webhook); 
      Debug(F("authorization: "));Debugln(eid_header_auth); 
      Debug(F("x-twin-id: "));Debugln(eid_header_twinid); 
      Debug(F("allowedInterval: "));Debugln(eid_interval); 

      //store configered
//      EIDWriteConfig(payload);
      EIDDetermineInterval(eid_interval);
      P1Status.eid_state = EID_ENROLLED;
    }
    httpServer.send(200, "application/json", payload );
    }
    http.end();
  } else{
    // != 200 response
    P1Status.eid_state = EID_CLAIMING;
    httpServer.send(400);
  } //httpResponseCode
}

void EIDGetClaim(){

  if ( !bEID_enabled ) return;
   //get server parameters
//  DebugT(F("server action: "));Debugln( httpServer.arg("action") );
  if ( httpServer.arg("action") == "reset" ) P1Status.eid_state = EID_IDLE;
  EIDPostHello(); 
}

void EIDDetermineInterval(String interval){
  if ( interval == "PT1M" )       eid_interval_sec =  1*60;
  else if ( interval == "PT5M" )  eid_interval_sec =  5*60; 
  else if ( interval == "PT15M" ) eid_interval_sec = 15*60; 
  else if ( interval == "PT1H" )  eid_interval_sec = 60*60;
  else if ( interval == "P1D" )   eid_interval_sec = 60*60*24;
  else if ( interval == "P1M" )   eid_interval_sec = 60*60*24*30;
  DebugT(F("eid_interval_sec: "));Debugln(eid_interval_sec);
}

//bool EIDWriteConfig(String payload){
//  if (!FSmounted) return false;
//  File EIDFile = LittleFS.open(EID_CONF_FILE, "w"); // open for appending  
//  if (!EIDFile) {
//    DebugTln(F("open eid-config.json FAILED!!!--> Bailout\r\n"));
//    return false;
//  }
//  EIDFile.print(payload);
//  EIDFile.close();
//  DebugTln(F("EID Config file writen")); 
//  return true;
//}

//void EIDReadConfig(){
//  if (!FSmounted) return;
//  File EIDFile = LittleFS.open(EID_CONF_FILE, "r"); // open for appending  
//  if (!EIDFile) {
//    DebugTln(F("open config file FAILED!!!--> Bailout\r\n"));
//    return;
//  }
//  eid_token = EIDFile.readStringUntil('\r');
//  EIDFile.close();
//}
  
//void GETEnergyID(){
//
//  HTTPClient http;
//  snprintf( cMsg, sizeof( cMsg ), "%s%s",EID_BASE_URL, eid_token );
//  http.begin( cMsg );
//  
//  int httpResponseCode = http.GET();
//  if ( httpResponseCode<=0 ) { 
//    Debug(F("Error code: "));Debugln(httpResponseCode);
//    return;
//  }
//  
//  Debug(F("HTTP Response code: "));Debugln(httpResponseCode);
//  String payload = http.getString();
//  Debugln(payload);
//  http.end();
//
//}

String IsoTS () {
  // convert to this format -> 2023-06-16T08:01+0200
  
  String tmpTS = String(actTimestamp);
  String DateTime = "";
  DateTime   = "20" + tmpTS.substring(0, 2);    // YY
  DateTime  += "-"  + tmpTS.substring(2, 4);    // MM
  DateTime  += "-"  + tmpTS.substring(4, 6);    // DD
  DateTime  += "T";
  DateTime  += tmpTS.substring(6, 8);    // HH
  DateTime  += ":"  + tmpTS.substring(8, 10);   // MM
  DateTime  += ":"  + tmpTS.substring(10, 12);  // SS
  DateTime  += tmpTS[12]=='S' ? "+0200" : "+0100";
  return DateTime;
}

String JsonEnergyID ( const char* id, const char* metric, double sm_value, const char* unit, const char* type ){
/*  
  {
    "remoteId": "p1-dongle-pro",
    "remoteName": "P1 Dongle Pro",
    "metric": "electricityExport",
    "readingType": "counter",
    "unit": "kWh",    
    "data": [
        ["2023-06-10T08:01+0200", 1.123]
    ]
}
*/  
  
  String Json;
  Json  = "{\"remoteId\": \"p1-dongle-pro-" + String(id) + "\"";
  Json += ",\"remoteName\": \"P1 " + String(id) + "\"";
  Json += ",\"metric\":\"" + String(metric) + "\"";
  Json += ",\"readingType\": \"counter\"";
  Json += ",\"unit\": \"" + String(unit) + "\"";
  Json += ",\"interval\": \"" + eid_interval + "\"";  
  if ( strlen(type) > 0 ) Json += ",\"register\": \"" + String(type) + "\"";
  Json += ",\"data\":[";
  //data 
  Json +="[\"" + IsoTS() + "\"," + sm_value + "]";
  Json += "]}";

  Debug("JsonEnergyID : "); Debugln(Json);
  
  return Json;

}

String JsonBuildMBus(String key, time_t epoch, long value ){
/*  
    {
        "ts": 1695887917,
        "g": 123456.001
    },
 */
  String Json;
  Json  = ",{\"ts\":" + String(epoch);
  Json += ",\"" + key + "\":" + String(value);
  Json += "}";
  
  Debug("Mbus Json : "); Debugln(Json);
  
  return Json;
}

void PostEnergyID(){
/*
[
    {
        "ts": 1695887917,
        "t1": 3206.454,
        "t2": 3856.175,
        "t1-i": 0,
        "t2-i": 0,
        "pwr": 0.464,
       "pwr-i": 0,
    },
    {
        "ts": 1695887917,
        "g": 123456.001
    },
    {
        "ts": 1695887917,
        "w": 123456.001
    },
    {
        "ts":1695887917,
        "high-pp": 123456.001
    }
]


*/

  String payload;
  int httpResponseCode;
  String Json = "[{";
  
  HTTPClient http;
//  snprintf( cMsg, sizeof( cMsg ), "%s%s",EID_BASE_URL, eid_token.c_str() );  
  http.begin( eid_webhook );
  http.addHeader("Content-Type", "application/json");
  http.addHeader("authorization", eid_header_auth);
  http.addHeader("x-twin-id", eid_header_twinid);

  DebugT(F("Post URL:"));Debugln(eid_webhook);
  uint16_t utc_comp = 3600;
  if ( actTimestamp[12] == 'S') utc_comp = 7200;
  
  Json += "\"ts\":" + String( actT - utc_comp );
  
  if ( DSMRdata.energy_delivered_tariff1_present ) {
    Json += ",\"t1\":" + String((int)(DSMRdata.energy_delivered_tariff1*1000.0));
  }
  
  if ( DSMRdata.energy_delivered_tariff2_present ) {
    Json += ",\"t2\":" + String((int)(DSMRdata.energy_delivered_tariff2*1000.0));
  }

  if ( DSMRdata.energy_returned_tariff1_present ) {
    Json += ",\"t1-i\":" + String((int)(DSMRdata.energy_returned_tariff1*1000.0));
  }

  if ( DSMRdata.energy_returned_tariff2_present ) {
    Json += ",\"t2-i\":" + String((int)(DSMRdata.energy_returned_tariff2*1000.0));
  }
  if ( DSMRdata.power_delivered_present ) {
    Json += ",\"pwr\":" + String((int)(DSMRdata.power_delivered*1000.0));
  }
  if ( DSMRdata.power_returned_present ) {
    Json += ",\"pwr-i\":" + String((int)(DSMRdata.power_returned*1000.0));
  }
  
  Json += "}";
  
  if ( mbusGas ) {
    Json += JsonBuildMBus("g", epoch(gasDeliveredTimestamp.c_str(), 10, false) - utc_comp, (int)(gasDelivered*1000.0));
  }

  if ( mbusWater ) {
    Json += JsonBuildMBus("w", epoch(waterDeliveredTimestamp.c_str(), 10, false) - utc_comp, (int)(waterDelivered*1000.0));
  }

  if ( DSMRdata.highest_peak_pwr_present ) {
    Json += JsonBuildMBus("high-pp", epoch(DSMRdata.highest_peak_pwr.timestamp.c_str(), 10, false), 0);   
  } 
  
  Json += "]";
  
  Debug("Json payload: "); Debugln(Json);

  httpResponseCode = http.POST(Json);
  Debug(F("httpResponseCode: "));Debugln(httpResponseCode);
  payload = http.getString();
  Debug(F("response body: "));Debugln(payload); 
    if ( httpResponseCode != 201 ) { 
      DebugTln(F("Response Error"));
      P1Status.eid_state = EID_CLAIMING; //try /hello within 5min
    }
  
  http.end();
}

#endif