unit foobot_utility;

{ Foobot Utilities

  Copyright (C)2016 Gordon Bamber minsadorada@charcodelvalle.com

  This source is free software; you can redistribute it and/or modify it under
  the terms of the GNU General Public License as published by the Free
  Software Foundation; either version 2 of the License, or (at your option)
  any later version.

  This code is distributed in the hope that it will be useful, but WITHOUT ANY
  WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
  details.

  A copy of the GNU General Public License is available on the World Wide Web
  at <http://www.gnu.org/copyleft/gpl.html>. You can also obtain it by writing
  to the Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  MA 02111-1307, USA.

VERSION HISTORY
===============
* HighLow routines
* Use GetAppGonfigFile for IniFile location
}

{$mode objfpc}{$H+}

interface

uses
  Classes, SysUtils, Dialogs,
  foobot_httpclient, foobot_objects, fpjson, fpjsonrtti, base64, variants,
  DateUtils, INIFiles;

const
  FOOBOT_USER_URL = 'https://api.foobot.io/v2/user/%s/login/';
  FOOBOT_IDENTITY_URL = 'https://api.foobot.io/v2/owner/%s/device/';
  FOOBOT_DATA_LAST_URL = 'https://api.foobot.io/v2/device/%s/datapoint/%s/%s/%s/';
  FOOBOT_DATA_START_FINISH_URL =
    'https://api.foobot.io/v2/device/%s/datapoint/%s/%s/%s/';

  // Used throughout in arrays, counts etc.
  C_TIME = 0;
  C_PM = 1;
  C_TMP = 2;
  C_HUM = 3;
  C_CO2 = 4;
  C_VOC = 5;
  C_ALLPOLLU = 6;
  // Used in Trigger functions
  C_HIGH = 0;
  C_LOW = 1;
    // Sensor recommended levels
  REC_PM = 25;
  REC_TMP = 23;
  REC_HUM = 60;
  REC_CO2 = 1300;
  REC_VOC = 300;
  REC_ALLPOLLU = 50;

type
  TDataFetchType = (dfLast, dfStartEnd); // FetchFoobotData

  // Unused
  TSensorType = (st_time, st_pm, st_tmp, st_hum, st_co2, st_voc, st_allpollu);
  // Unused
  TAlertType = (at_high, at_low);

  TAlertRec = record
    AlertTriggered: boolean;
    AlertTime: TDateTime;
    AlertType: Integer;
    AlertValue: variant;
  end;
  var
    RecommendedLevelsArray:Array[C_PM..C_ALLPOLLU] of Double;

function EncodeStringBase64(const s: string): string;
function FetchAuthenticationKey(aUsername, aUserPassword: string): boolean;

// Populates FoobotIdentityObject.TFoobotIdentityList collection
function FetchFoobotIdentity(aUsername, aSecretKey: string): boolean;

// Populates FoobotDataObject
function FetchFoobotData(DataFetchType: TDataFetchType = dfLast;
  iCurrentFoobot: integer = 0; iLastIntervalSeconds: integer = 3600;
  iLastAverageBySeconds: integer = 0; iStartTimeSeconds: int64 = 0;
  iEndTimeSeconds: int64 = 0; aSecretKey: string = 'unknown'): boolean;

// Populates datapoint arrays from FoobotIdentityObject for easy access
// - also populates HighLow arrays
function FoobotDataObjectToArrays: boolean;

// Gets/Sets internal FooBotTriggerArray which can be tested against in FoobotDataObjectToArrays
// aSensor use consts: C_PM,C_TMP etc.
function SetHighTrigger(const aSensor: integer; const aValue: variant): boolean;
function SetLowTrigger(const aSensor: integer; const aValue: variant): boolean;
function GetHighTrigger(Const aSensor:Integer):Variant;
function GetLowTrigger(Const aSensor:Integer):Variant;

// Utility functions
function ResetArrays: boolean;
function ResetObjects: boolean;
function ResetHighLows: boolean;
function SaveHighLows: boolean;
function LoadHighLows: boolean;
function SaveTriggers: boolean;
function LoadTriggers: boolean;
function SaveRecommendedLevels:boolean;
function LoadRecommendedLevels:boolean;
var
  // Used to fetch server data
  HttpClient: TFPHTTPClient;
  // Holds identity values for multiple Foobots (FoobotIdentityObject.FoobotIdentityList)
  FoobotIdentityObject: TFoobotIdentityObject;
  // Holds data for current Foobot
  FoobotDataObject: TFoobotDataObject;
  // Used in FetchAuthenticationKey
  sAuthenticationKey: string;
  // Boolean to enable/disable serialisation of HighLows.  Default = TRUE
  SaveLoadHighLows: boolean;
  // Boolean to enable/disable Trigger functions. Default = FALSE
  UseTriggers: boolean;
  // Used in data fetch
  TheCurrentFoobot: integer;
  // INIFile located in GetAppConfig(false) folder
  HLINI: TIniFile;
  // Dynamic arrays - easier access to datapoints
  // Call FoobotDataObjectToArrays to populate them
  FoobotData_time: array of TDateTime;
  FoobotData_pm: array of double;
  FoobotData_tmp: array of double;
  FoobotData_hum: array of double;
  FoobotData_co2: array of integer;
  FoobotData_voc: array of integer;
  FoobotData_allpollu: array of double;
  // Set in FoobotDataObjectToArrays
  FoobotDataHighs: array[C_TIME..C_ALLPOLLU] of variant;
  FoobotDataLows: array[C_TIME..C_ALLPOLLU] of variant;
  FoobotDataHighTimes: array[C_TIME..C_ALLPOLLU] of variant;
  FoobotDataLowTimes: array[C_TIME..C_ALLPOLLU] of variant;

  // [0=Low(at_low)..1=High(at_high), C_PM..C_ALLPOLLU]
  // Dynamic in case of future changes (e.g. more triggers)
  FooBotTriggerArray: array of array of variant;
  // Set by FoobotDataObjectToArrays
  AlertRec: array [C_TIME..C_ALLPOLLU] of TAlertRec;
  giCount: integer; // used in initialization

implementation

function SaveTriggers: boolean;
  // To foobotmonitor.ini
var
  sFoobotName: string;
begin
  Result:=FALSE; // assume failure
  if FoobotIdentityObject.FoobotIdentityList.Count = 0 then Exit(FALSE);
  sFoobotName := FoobotIdentityObject.FoobotIdentityList[TheCurrentFoobot].Name;
  if (sFoobotName = '') then
    Exit(False);
  if not Assigned(HLINI) then
    HLINI := TIniFile.Create(ChangeFileExt(GetAppConfigFile(False), '.ini'));
  try
    // Store current Foobot triggers
    with HLINI do
    begin
      WriteInteger('Foobot', 'CurrentFoobot', TheCurrentFoobot);
      WriteString('Foobot', 'CurrentFoobotName', sFoobotName);
      WriteFloat(sFoobotName, 'pmTriggerHigh',
        double(FooBotTriggerArray[C_HIGH, C_PM]));
      WriteFloat(sFoobotName, 'pmTriggerLow',
        double(FooBotTriggerArray[C_LOW, C_PM]));
      WriteFloat(sFoobotName, 'tmpTriggerHigh',
        double(FooBotTriggerArray[C_HIGH, C_TMP]));
      WriteFloat(sFoobotName, 'tmpTriggerLow',
        double(FooBotTriggerArray[C_LOW, C_TMP]));
      WriteFloat(sFoobotName, 'humTriggerHigh',
        double(FooBotTriggerArray[C_HIGH, C_HUM]));
      WriteFloat(sFoobotName, 'humTriggerLow',
        double(FooBotTriggerArray[C_LOW, C_HUM]));
      WriteFloat(sFoobotName, 'co2TriggerHigh',
        Integer(FooBotTriggerArray[C_HIGH, C_CO2]));
      WriteFloat(sFoobotName, 'co2TriggerLow',
        Integer(FooBotTriggerArray[C_LOW, C_CO2]));
      WriteFloat(sFoobotName, 'vocTriggerHigh',
        Integer(FooBotTriggerArray[C_HIGH, C_VOC]));
      WriteFloat(sFoobotName, 'vocTriggerLow',
        Integer(FooBotTriggerArray[C_LOW, C_VOC]));
      WriteFloat(sFoobotName, 'allpolluTriggerHigh',
        double(FooBotTriggerArray[C_HIGH, C_ALLPOLLU]));
      WriteFloat(sFoobotName, 'allpolluTriggerLow',
        double(FooBotTriggerArray[C_LOW, C_ALLPOLLU]));
    end;
    Result := True;
  except
    raise Exception.Create('Could not save Triggers');
  end;
end;

function LoadTriggers: boolean;
  // From foobotmonitor.ini
var
  sFoobotName: string;
begin
  Result:=FALSE; // assume failure
  if FoobotIdentityObject.FoobotIdentityList.Count = 0 then Exit(FALSE);
  sFoobotName := FoobotIdentityObject.FoobotIdentityList[TheCurrentFoobot].Name;
  if (sFoobotName = '') then
    Exit(False);
  if not Assigned(HLINI) then
    HLINI := TIniFile.Create(ChangeFileExt(GetAppConfigFile(False), '.ini'));
  // Make sure the High-Lows are for the current Foobot
  if (HLINI.ReadString('Foobot', 'CurrentFoobotName', 'unknown') <> sFoobotName) then
    Exit(False);
  try
    // Load current Foobot triggers
    with HLINI do
    begin
      FooBotTriggerArray[C_HIGH, C_PM] := ReadFloat(sFoobotName, 'pmTriggerHigh', 0);
      FooBotTriggerArray[C_LOW, C_PM] := ReadFloat(sFoobotName, 'pmTriggerLow', 0);
      FooBotTriggerArray[C_HIGH, C_TMP] := ReadFloat(sFoobotName, 'tmpTriggerHigh', 0);
      FooBotTriggerArray[C_LOW, C_TMP] := ReadFloat(sFoobotName, 'tmpTriggerLow', 0);
      FooBotTriggerArray[C_HIGH, C_HUM] := ReadFloat(sFoobotName, 'humTriggerHigh', 0);
      FooBotTriggerArray[C_LOW, C_HUM] := ReadFloat(sFoobotName, 'humTriggerLow', 0);
      FooBotTriggerArray[C_HIGH, C_CO2] := ReadFloat(sFoobotName, 'co2TriggerHigh', 0);
      FooBotTriggerArray[C_LOW, C_CO2] := ReadFloat(sFoobotName, 'co2TriggerLow', 450);
      FooBotTriggerArray[C_HIGH, C_VOC] := ReadFloat(sFoobotName, 'vocTriggerHigh', 0);
      FooBotTriggerArray[C_LOW, C_VOC] := ReadFloat(sFoobotName, 'vocTriggerLow', 125);
      FooBotTriggerArray[C_HIGH, C_ALLPOLLU] :=
        ReadFloat(sFoobotName, 'allpolluTriggerHigh', 0);
      FooBotTriggerArray[C_LOW, C_ALLPOLLU] :=
        ReadFloat(sFoobotName, 'allpolluTriggerLow', 0);
    end;
    Result := True;
  except
    raise Exception.Create('Could not load Triggers');
  end;
end;

function SaveRecommendedLevels:boolean;
var
  sFoobotName: string;
begin
  Result:=FALSE; // assume failure
  if FoobotIdentityObject.FoobotIdentityList.Count = 0 then Exit(FALSE);
  sFoobotName := FoobotIdentityObject.FoobotIdentityList[TheCurrentFoobot].Name;
  if (sFoobotName = '') then
    Exit(False);
  if not Assigned(HLINI) then
    HLINI := TIniFile.Create(ChangeFileExt(GetAppConfigFile(False), '.ini'));
  // Make sure the High-Lows are for the current Foobot
  if (HLINI.ReadString('Foobot', 'CurrentFoobotName', 'unknown') <> sFoobotName) then
    Exit(False);
  try
    // Save current Foobot recommended levels
    with HLINI do
    begin
        WriteFloat(sFoobotName,'RecPM',RecommendedLevelsArray[C_PM]);
        WriteFloat(sFoobotName,'RecTMP',RecommendedLevelsArray[C_TMP]);
        WriteFloat(sFoobotName,'RecHUM',RecommendedLevelsArray[C_HUM]);
        WriteFloat(sFoobotName,'RecCO2',RecommendedLevelsArray[C_CO2]);
        WriteFloat(sFoobotName,'RecVOC',RecommendedLevelsArray[C_VOC]);
        WriteFloat(sFoobotName,'RecALLPOLLU',RecommendedLevelsArray[C_ALLPOLLU]);
    end;
    Result := True;
  except
    raise Exception.Create('Could not save recommended levels for ' + sFoobotName);
  end;
end;

function LoadRecommendedLevels:boolean;
var
  sFoobotName: string;
begin
  Result:=FALSE; // assume failure
  if FoobotIdentityObject.FoobotIdentityList.Count = 0 then Exit(FALSE);
  sFoobotName := FoobotIdentityObject.FoobotIdentityList[TheCurrentFoobot].Name;
  if (sFoobotName = '') then
    Exit(False);
  if not Assigned(HLINI) then
    HLINI := TIniFile.Create(ChangeFileExt(GetAppConfigFile(False), '.ini'));
  // Make sure the High-Lows are for the current Foobot
  if (HLINI.ReadString('Foobot', 'CurrentFoobotName', 'unknown') <> sFoobotName) then
    Exit(False);
  try
    // Load current Foobot recommended levels
    with HLINI do
    begin
        RecommendedLevelsArray[C_PM]:=ReadFloat(sFoobotName,'RecPM',REC_PM);
        RecommendedLevelsArray[C_TMP]:=ReadFloat(sFoobotName,'RecTMP',REC_TMP);
        RecommendedLevelsArray[C_HUM]:=ReadFloat(sFoobotName,'RecHUM',REC_HUM);
        RecommendedLevelsArray[C_CO2]:=ReadFloat(sFoobotName,'RecCO2',REC_CO2);
        RecommendedLevelsArray[C_VOC]:=ReadFloat(sFoobotName,'RecVOC',REC_VOC);
        RecommendedLevelsArray[C_ALLPOLLU]:=ReadFloat(sFoobotName,'RecALLPOLLU',REC_ALLPOLLU);
    end;
    Result := True;
  except
    raise Exception.Create('Could not load recommended levels for ' + sFoobotName);
  end;
end;

function SaveHighLows: boolean;
  // Save values to an INI data file
  // To foobotmonitor.ini
var
  sFoobotName: string;
begin
  Result:=FALSE; // assume failure
  if SaveLoadHighLows = False then
    Exit(False);
  if FoobotIdentityObject.FoobotIdentityList.Count = 0 then Exit(FALSE);
  sFoobotName := FoobotIdentityObject.FoobotIdentityList[TheCurrentFoobot].Name;
  if (sFoobotName = '') then
    Exit(False);
  if not Assigned(HLINI) then
    HLINI := TIniFile.Create(ChangeFileExt(GetAppConfigFile(False), '.ini'));
  // Store current Foobot info
  try
    with HLINI do
    begin
      WriteInteger('Foobot', 'CurrentFoobot', TheCurrentFoobot);
      WriteString('Foobot', 'CurrentFoobotName', sFoobotName);

      // Particulates
      WriteFloat(sFoobotName, 'pmHigh', double(FoobotDataHighs[C_PM]));
      WriteDateTime(sFoobotName, 'pmHighTime', TDateTime(FoobotDataHighTimes[C_PM]));
      WriteFloat(sFoobotName, 'pmLow', double(FoobotDataLows[C_PM]));
      WriteDateTime(sFoobotName, 'pmLowTime', TDateTime(FoobotDataLowTimes[C_PM]));
      // Temp
      WriteFloat(sFoobotName, 'tmpHigh', double(FoobotDataHighs[C_TMP]));
      WriteDateTime(sFoobotName, 'tmpHighTime', TDateTime(FoobotDataHighTimes[C_TMP]));
      WriteFloat(sFoobotName, 'tmpLow', double(FoobotDataLows[C_TMP]));
      WriteDateTime(sFoobotName, 'tmpLowTime', TDateTime(FoobotDataLowTimes[C_TMP]));
      // Humidity
      WriteFloat(sFoobotName, 'humHigh', double(FoobotDataHighs[C_HUM]));
      WriteDateTime(sFoobotName, 'humHighTime', TDateTime(FoobotDataHighTimes[C_HUM]));
      WriteFloat(sFoobotName, 'humLow', double(FoobotDataLows[C_HUM]));
      WriteDateTime(sFoobotName, 'humLowTime', TDateTime(FoobotDataLowTimes[C_HUM]));
      // CO2
      WriteInteger(sFoobotName, 'co2High', integer(FoobotDataHighs[C_CO2]));
      WriteDateTime(sFoobotName, 'co2HighTime', TDateTime(FoobotDataHighTimes[C_CO2]));
      WriteInteger(sFoobotName, 'co2Low', integer(FoobotDataLows[C_CO2]));
      WriteDateTime(sFoobotName, 'co2LowTime', TDateTime(FoobotDataLowTimes[C_CO2]));
      //  Volatile Compounds
      WriteInteger(sFoobotName, 'vocHigh', integer(FoobotDataHighs[C_VOC]));
      WriteDateTime(sFoobotName, 'vocHighTime', TDateTime(FoobotDataHighTimes[C_VOC]));
      WriteInteger(sFoobotName, 'vocLow', integer(FoobotDataLows[C_VOC]));
      WriteDateTime(sFoobotName, 'vocLowTime', TDateTime(FoobotDataLowTimes[C_VOC]));
      // All Pollution
      WriteFloat(sFoobotName, 'allpolluHigh', double(FoobotDataHighs[C_ALLPOLLU]));
      WriteDateTime(sFoobotName, 'allpolluHighTime',
        TDateTime(FoobotDataHighTimes[C_ALLPOLLU]));
      WriteFloat(sFoobotName, 'allpolluLow', double(FoobotDataLows[C_ALLPOLLU]));
      WriteDateTime(sFoobotName, 'allpolluLowTime',
        TDateTime(FoobotDataLowTimes[C_ALLPOLLU]));
      Result := True;
    end;
  except
    raise Exception.Create('Could not save HighLows');
  end;
end;

function LoadHighLows: boolean;
  // Load values from an INI data file
  // From foobotmonitor.ini
var
  sFoobotName: string;
begin
  Result:=FALSE; // assume failure
  if SaveLoadHighLows = False then
  begin
    ShowMessage('Unable to load All-Time stats');
    Exit(False);
  end;
  if FoobotIdentityObject.FoobotIdentityList.Count = 0 then Exit(FALSE);
  sFoobotName := FoobotIdentityObject.FoobotIdentityList[TheCurrentFoobot].Name;
  if (sFoobotName = '') then
    Exit(False);
  if not Assigned(HLINI) then
    HLINI := TIniFile.Create(ChangeFileExt(GetAppConfigFile(False), '.ini'));
  // Make sure the High-Lows are for the current Foobot
  if (HLINI.ReadString('Foobot', 'CurrentFoobotName', 'unknown') <> sFoobotName) then
    Exit(False);
  try
    with HLINI do
    begin
      // Particulates
      FoobotDataHighs[C_PM] := ReadFloat(sFoobotName, 'pmHigh', 0);
      FoobotDataHighTimes[C_PM] := ReadDateTime(sFoobotName, 'pmHighTime', Now);
      FoobotDataLows[C_PM] := ReadFloat(sFoobotName, 'pmLow', 0);
      FoobotDataLowTimes[C_PM] := ReadDateTime(sFoobotName, 'pmLowTime', Now);
      // Temp
      FoobotDataHighs[C_TMP] := ReadFloat(sFoobotName, 'tmpHigh', 0);
      FoobotDataHighTimes[C_TMP] := ReadDateTime(sFoobotName, 'tmpHighTime', Now);
      FoobotDataLows[C_TMP] := ReadFloat(sFoobotName, 'tmpLow', 0);
      FoobotDataLowTimes[C_TMP] := ReadDateTime(sFoobotName, 'tmpLowTime', Now);
      // Humidity
      FoobotDataHighs[C_HUM] := ReadFloat(sFoobotName, 'humHigh', 0);
      FoobotDataHighTimes[C_HUM] := ReadDateTime(sFoobotName, 'humHighTime', Now);
      FoobotDataLows[C_HUM] := ReadFloat(sFoobotName, 'humLow', 0);
      FoobotDataLowTimes[C_HUM] := ReadDateTime(sFoobotName, 'humLowTime', Now);
      // CO2
      FoobotDataHighs[C_CO2] := ReadInteger(sFoobotName, 'co2High', 0);
      FoobotDataHighTimes[C_CO2] := ReadDateTime(sFoobotName, 'co2HighTime', Now);
      FoobotDataLows[C_CO2] := ReadInteger(sFoobotName, 'co2Low', 0);
      FoobotDataLowTimes[C_CO2] := ReadDateTime(sFoobotName, 'co2LowTime', Now);
      // Volatile Compounds
      FoobotDataHighs[C_VOC] := ReadInteger(sFoobotName, 'vocHigh', 0);
      FoobotDataHighTimes[C_VOC] := ReadDateTime(sFoobotName, 'vocHighTime', Now);
      FoobotDataLows[C_VOC] := ReadInteger(sFoobotName, 'vocLow', 0);
      FoobotDataLowTimes[C_VOC] := ReadDateTime(sFoobotName, 'vocLowTime', Now);
      // All Pollution
      FoobotDataHighs[C_ALLPOLLU] := ReadFloat(sFoobotName, 'allpolluHigh', 0);
      FoobotDataHighTimes[C_ALLPOLLU] :=
        ReadDateTime(sFoobotName, 'allpolluHighTime', Now);
      FoobotDataLows[C_ALLPOLLU] := ReadFloat(sFoobotName, 'allpolluLow', 0);
      FoobotDataLowTimes[C_ALLPOLLU] :=
        ReadDateTime(sFoobotName, 'allpolluLowTime', Now);
      Result := True;
    end;
  except
    raise Exception.Create('Could not Load HighLows');
  end;
end;

// Use FoobotDataObjectToArrays function to make the Foobot data accessible
//  after a call to FetchFoobotData
// * Sets the HighLow array values
// * Sets triggers
{
Here's calling code to use the triggers:
// Process Trigger Alerts on each call to FoobotDataObjectToArrays
if UseTriggers then
  // Look for alerts in each sensor
  for iCount := C_PM to C_ALLPOLLU do
  begin
    if (AlertRec[iCount].AlertTriggered=TRUE) then
    begin
      // Alert found.  High or low?
      if (AlertRec[iCount].AlertType = C_HIGH) then
      begin
        // A high alert - do something
        DoHighTriggerAlert(iCount,AlertRec[iCount].AlertValue);
      end
      else
      begin
        // A low alert - do something
        DoLowTriggerAlert(iCount,AlertRec[iCount].AlertValue);
      end;
    end;
  end;
}
function FoobotDataObjectToArrays: boolean;
var
  J, K: integer;
  Mydatapoint: variant;
  iUnixSecs: int64;
  // ========= Internal routines start ===========
  procedure SetHigh(iMember: integer; aValue: variant; aDateTime: TDateTime);
  begin
    // Do High/Low
    if aValue > FoobotDataHighs[iMember] then
    begin
      FoobotDataHighs[iMember] := aValue;
      FoobotDataHighTimes[iMember] := aDateTime;
      SaveHighLows;
    end;
    if ((UseTriggers = True) and (FooBotTriggerArray[C_HIGH, iMember] <> 0)) then
    begin
      // Do High Trigger
      // Sets AlertRec record
        if (aValue > FooBotTriggerArray[C_HIGH, iMember]) then
        begin
          AlertRec[iMember].AlertTriggered := True;
          AlertRec[iMember].AlertTime := aDateTime;
          AlertRec[iMember].AlertType := C_HIGH;
          AlertRec[iMember].AlertValue := aValue;
        end;
    end;
  end;

  procedure SetLow(iMember: integer; aValue: variant; aDateTime: TDateTime);
  begin
    // Do High/Low
    if (aValue < FoobotDataLows[iMember]) or (FoobotDataLows[iMember] = 0) then
    begin
      FoobotDataLows[iMember] := aValue;
      FoobotDataLowTimes[iMember] := aDateTime;
      SaveHighLows;
    end;
    if ((UseTriggers = True) and (FooBotTriggerArray[C_LOW, iMember] <> 0)) then
    begin
      // Do Low Trigger
      // Sets AlertRec record
      if (aValue < FooBotTriggerArray[C_LOW, iMember]) then
      begin
        AlertRec[iMember].AlertTriggered := True;
        AlertRec[iMember].AlertTime := aDateTime;
        AlertRec[iMember].AlertType :=C_LOW;
        AlertRec[iMember].AlertValue := aValue;
      end;
    end;
  end;

  procedure ClearTriggers;
  Var iCount:Integer;
  begin
   for iCount := C_PM to C_ALLPOLLU do
   begin
     AlertRec[iCount].AlertTriggered:=False;
     AlertRec[iCount].AlertValue := 0;
   end;
  end;
  // ========== Internal routines end =============
begin
  ResetArrays;
  Result := True;
  LoadHighLows;
  if FoobotIdentityObject.FoobotIdentityList.Count = 0 then
    Exit(False);
  if FooBotDataObject.sensors.Count = 0 then
    Exit(False);
  if FooBotDataObject.units.Count = 0 then
    Exit(False);
  // Reset all triggers (if on)
  If UseTriggers then ClearTriggers;
  // J=Column, K=Row
  for K := VarArrayLowBound(FoobotDataObject.datapoints, 1)
    to VarArrayHighBound(FoobotDataObject.datapoints, 1) do
  begin
    for J := VarArrayLowBound(FoobotDataObject.datapoints[K], 1)
      to VarArrayHighBound(FoobotDataObject.datapoints[K], 1) do
    begin
      Mydatapoint := FoobotDataObject.datapoints[K][J];
      case J of
        C_TIME: // First field is a DateTime
        begin
          iUnixSecs := int64(Mydatapoint);
          SetLength(FoobotData_time, K + 1);
          FoobotData_time[K] := UnixToDateTime(iUnixSecs);
        end;
        C_PM: // Particulate matter
        begin
          SetLength(FoobotData_pm, K + 1);
          FoobotData_pm[K] := double(MyDataPoint);
          SetHigh(J, FoobotData_pm[K], FoobotData_time[K]);
          SetLow(J, FoobotData_pm[K], FoobotData_time[K]);
        end;
        C_TMP: // Temperature
        begin
          SetLength(FoobotData_tmp, K + 1);
          FoobotData_tmp[K] := double(MyDataPoint);
          SetHigh(J, FoobotData_tmp[K], FoobotData_time[K]);
          SetLow(J, FoobotData_tmp[K], FoobotData_time[K]);
        end;
        C_HUM: // Humidity
        begin
          SetLength(FoobotData_hum, K + 1);
          FoobotData_hum[K] := double(MyDataPoint);
          SetHigh(J, FoobotData_hum[K], FoobotData_time[K]);
          SetLow(J, FoobotData_hum[K], FoobotData_time[K]);
        end;
        C_CO2: // CO2
        begin
          SetLength(FoobotData_co2, K + 1);
          FoobotData_co2[K] := integer(MyDataPoint);
          SetHigh(J, FoobotData_co2[K], FoobotData_time[K]);
          SetLow(J, FoobotData_co2[K], FoobotData_time[K]);
        end;
        C_VOC: // Volatile compounds
        begin
          SetLength(FoobotData_voc, K + 1);
          FoobotData_voc[K] := integer(MyDataPoint);
          SetHigh(J, FoobotData_voc[K], FoobotData_time[K]);
          SetLow(J, FoobotData_voc[K], FoobotData_time[K]);
        end;
        C_ALLPOLLU: // All Pollution
        begin
          SetLength(FoobotData_allpollu, K + 1);
          FoobotData_allpollu[K] := double(MyDataPoint);
          SetHigh(J, FoobotData_allpollu[K], FoobotData_time[K]);
          SetLow(J, FoobotData_allpollu[K], FoobotData_time[K]);
        end;
        else
          raise Exception.Create('Error in FoobotDataObjectToArrays Case');
      end; // of Case
    end;
  end;

end;

function GetHighTrigger(Const aSensor:Integer):Variant;
begin
  Result:=0;
  if UseTriggers = False then Exit;
  If ((aSensor < C_PM) or (aSensor > C_ALLPOLLU)) then exit;
  Result:=FooBotTriggerArray[C_HIGH, aSensor];
end;

function GetLowTrigger(Const aSensor:Integer):Variant;
begin
 Result:=0;
 if UseTriggers = False then Exit;
 If ((aSensor < C_PM) or (aSensor > C_ALLPOLLU)) then exit;
 Result:=FooBotTriggerArray[C_LOW, aSensor];
end;

function SetHighTrigger(const aSensor: integer; const aValue: variant): boolean;
begin
  Result := False;
  if UseTriggers = False then
    Exit;
  if aValue <> FooBotTriggerArray[C_HIGH, aSensor] then
  begin
    FooBotTriggerArray[C_HIGH, aSensor] := aValue;
    Result := True;
  end;
end;

function SetLowTrigger(const aSensor: integer; const aValue: variant): boolean;
begin
  Result := False;
  if UseTriggers = False then
    Exit;
  if aValue <> FooBotTriggerArray[C_LOW, Ord(aSensor)] then
  begin
    FooBotTriggerArray[C_LOW, aSensor] := aValue;
    Result := True;
  end;
end;

// Data cleaning functions
function ResetHighLows: boolean;
var
  iCount: integer;
begin
  for iCount := C_TIME to C_ALLPOLLU do
  begin
    FoobotDataHighs[iCount] := 0;
    FoobotDataLows[iCount] := 0;
  end;
  Result := True;
end;

function ResetArrays: boolean;
begin
  Result := True;
  try
    SetLength(FoobotData_time, 0);
    SetLength(FoobotData_pm, 0);
    SetLength(FoobotData_tmp, 0);
    SetLength(FoobotData_hum, 0);
    SetLength(FoobotData_co2, 0);
    SetLength(FoobotData_voc, 0);
    SetLength(FoobotData_allpollu, 0);
  except
    Result := False;
    raise;
  end;
end;

function ResetObjects: boolean;
var
  J, K: integer;
begin
  Result := True;
  try
    for K := VarArrayLowBound(FoobotDataObject.datapoints, 1)
      to VarArrayHighBound(FoobotDataObject.datapoints, 1) do
      for J := VarArrayLowBound(FoobotDataObject.datapoints[K], 1)
        to VarArrayHighBound(FoobotDataObject.datapoints[K], 1) do
        FoobotDataObject.datapoints[K][J] := 0;
    FooBotDataObject.sensors.Clear;
    FooBotDataObject.units.Clear;
    FoobotIdentityObject.FoobotIdentityList.Clear;
  except
    Result := False;
    raise;
  end;
end;

// Authentication functions
function EncodeStringBase64(const s: string): string;

var
  outstream: TStringStream;
  encoder: TBase64EncodingStream;
begin
  outstream := TStringStream.Create('');
  try
    encoder := TBase64EncodingStream.Create(outstream);
    try
      encoder.Write(s[1], length(s));
    finally
      encoder.Free;
    end;
    outstream.position := 0;
    Result := outstream.readstring(outstream.size);
  finally
    outstream.Free;
  end;
end;

function FetchAuthenticationKey(aUsername, aUserPassword: string): boolean;
var
  sRequestURL: string;
  iCount: integer;
  JSON: TJSONStringType;
begin
  //  FOOBOT_USER_URL = 'http://api.foobot.io/v2/user/%s/login/';
  //  sAuthenticationKey
  //  Looking for "x-auth-token"
  Result := False;
  try
    with httpclient do
    begin
      ResponseHeaders.NameValueSeparator := ':';
      AddHeader('password', aUserPassword);
      // ShowMessage(EncodeURLElement(aUsername));
      sRequestURL := Format(FOOBOT_USER_URL, [EncodeURLElement(aUsername)]);
      try
        JSON := Get(sRequestURL);
        if ResponseStatusCode <> 200 then
        begin
          ShowMessageFmt('Failed - Foobot server refused with code %d',
            [ResponseStatusCode]);
          Exit(False);
        end;
      finally
        ShowMessage(JSON);
        for iCount := 0 to Pred(ResponseHeaders.Count) do
          ShowMessage(ResponseHeaders[iCount]);
      end;
      Result := True;
    end;
  finally
    // Empty
  end;

end;

// This function must succeed before calling FetchFoobotData
function FetchFoobotIdentity(aUsername, aSecretKey: string): boolean;
var
  sUserNameURL: string;
  JSON: TJSONStringType;
  DeStreamer: TJSONDeStreamer;
begin
  Result := True; // Assume success: Look for failure
  sAuthenticationKey := aSecretKey;
  try
    with httpclient do
    begin
      DeStreamer := TJSONDeStreamer.Create(nil);
      DeStreamer.Options := [jdoIgnorePropertyErrors];
      sUserNameURL := Format(FOOBOT_IDENTITY_URL, [aUsername]);
      ResponseHeaders.NameValueSeparator := ':';
      AddHeader('Accept', 'application/json;charset=UTF-8');
      AddHeader('X-API-KEY-TOKEN', aSecretKey);
      JSON := Get(sUserNameURL);
      if (ResponseStatusCode <> 200) then
        case ResponseStatusCode of
          429:
          begin
            ShowMessageFmt('Cannot retieve data - too many requests to the Foobot server%s%s',
              [LineEnding, JSON]);
            Exit(False);
          end;
          else
          begin
            ShowMessageFmt('Cannot retieve data - Foobot server refused with code %d',
              [ResponseStatusCode]);
            Exit(False);
          end;
        end;
      try
        // Stream it to the object list
        DeStreamer.JSONToObject(JSON, FoobotIdentityObject.FoobotIdentityList);
      except
        On E: Exception do
          showmessagefmt('Cannot retieve data - Foobot server refused with code %s',
            [E.Message]);
        On E: Exception do
          Result := False;
      end;
    end;
  finally
    DeStreamer.Free;
  end;
end;

// Function FetchFoobotIdentity must be called before this one
function FetchFoobotData(DataFetchType: TDataFetchType;
  iCurrentFoobot, iLastIntervalSeconds, iLastAverageBySeconds: integer;
  iStartTimeSeconds, iEndTimeSeconds: int64; aSecretKey: string): boolean;
var
  sUserNameURL: string;
  JSON: TJSONStringType;
  DeStreamer: TJSONDeStreamer;
  uuid: string;
  //FOOBOT_DATA_LAST_URL = 'http://api.foobot.io/v2/device/%s/datapoint/%s/%s/%s/';
  //FOOBOT_DATA_START_FINISH_URL = 'http://api.foobot.io/v2/device/%s/datapoint/%s/%s/%s/';
begin
  Result := True; // Assume success: Look for failure
  TheCurrentFoobot := iCurrentFoobot;
  // Checks for integrity
  if (FoobotIdentityObject.FoobotIdentityList.Count = 0) then
    Exit(False);
  if (DataFetchType = dfStartEnd) and ((iStartTimeSeconds = 0) or
    (iEndTimeSeconds = 0)) then
    Exit(False);
  if (aSecretKey = 'unknown') then
    Exit(False);

  try
    with httpclient do
    begin
      DeStreamer := TJSONDeStreamer.Create(nil);
      DeStreamer.Options := [jdoIgnorePropertyErrors];
      // secretkey := INI.ReadString('Foobot', 'Secret Key', '');
      uuid := FoobotIdentityObject.FoobotIdentityList.Items[iCurrentFoobot].uuid;
      case DataFetchType of
        dfLast:
          sUserNameURL := Format(FOOBOT_DATA_LAST_URL,
            [uuid, IntToStr(iLastIntervalSeconds), 'last',
            IntToStr(iLastAverageBySeconds)]);
        dfStartEnd:
          sUserNameURL := Format(FOOBOT_DATA_START_FINISH_URL,
            [uuid, IntToStr(iStartTimeSeconds), IntToStr(iEndTimeSeconds),
            IntToStr(iLastAverageBySeconds)]);
        else
        begin
          Result := False;
          Exit;
        end;
      end;
      ResponseHeaders.NameValueSeparator := ':';

      AddHeader('Accept', 'application/json;charset=UTF-8');
      AddHeader('X-API-KEY-TOKEN', aSecretKey);
      JSON := Get(sUserNameURL);
      if (ResponseStatusCode <> 200) then
        case ResponseStatusCode of
          429:
          begin
            ShowMessageFmt('Failed - Too many requests to the Foobot server%s%s',
              [LineEnding, JSON]);
            Exit(False);
          end;
          else
          begin
            ShowMessageFmt('Failed - Foobot server refused with code %d',
              [ResponseStatusCode]);
            Exit(False);
          end;
        end;
      try
        // Stream it to the object list
        DeStreamer.JSONToObject(JSON, FoobotDataObject);
      except
        On E: Exception do
          showmessagefmt('Failed - Foobot server refused with code %s', [E.Message]);
        On E: Exception do
          Result := False;
      end;
    end;
  finally
    DeStreamer.Free;
  end;
end;

initialization
  begin
    HttpClient := TFPHTTPClient.Create(nil);
    FoobotIdentityObject := TFoobotIdentityObject.Create;
    FoobotDataObject := TFoobotDataObject.Create;
    TheCurrentFoobot := 0;
    SetLength(FooBotTriggerArray, 2, Succ(C_ALLPOLLU));
    SaveLoadHighLows := True; // Default
    UseTriggers := False; // Default
    for giCount := C_PM to C_ALLPOLLU do
    begin
      AlertRec[giCount].AlertTriggered := False;
      AlertRec[giCount].AlertTime := Now;
      AlertRec[giCount].AlertType := 0;
      AlertRec[giCount].AlertValue := 0;
    end;
  end;

finalization
  begin
    if Assigned(HLINI) then
      FreeAndNil(HLINI);
    FreeAndNil(HttpClient);
    FreeAndNil(FoobotIdentityObject);
    FreeAndNil(FoobotDataObject);
    SetLength(FoobotData_time, 0);
    SetLength(FoobotData_pm, 0);
    SetLength(FoobotData_tmp, 0);
    SetLength(FoobotData_hum, 0);
    SetLength(FoobotData_co2, 0);
    SetLength(FoobotData_voc, 0);
    SetLength(FoobotData_allpollu, 0);
    SetLength(FooBotTriggerArray, 0, 0);
  end;

end.