main.js

/**
 * cleveron adapter
 */

/* jshint -W097 */ // jshint strict:false
/*jslint node: true */
'use strict';

const utils = require('@iobroker/adapter-core'); // Get common adapter utils
const axios = require('axios');

let adapter;

const server = "https://server.cleveron.ch";
const apipath = "/apiv1/";
const buildingpath = "building?sessionToken=";
const roompath = "/room?sessionToken=";
const devicepath = "/devices?sessionToken=";
var tokenurl = "";


var sessiontoken;
var buildingid = [];
var building = "";
var room = "";
var roomid = [];
var devices = new Array();
var rooms = new Array();
var buildings = new Array();
var dataarray = new Array();

let polling;
var firstrun;
var testend;
var pollingtime;
var requestcounter = 0;


function startAdapter(options) {
  options = options || {};
  Object.assign(options, {
    name: 'cleveron'
  });

  adapter = new utils.Adapter(options);

  // when adapter shuts down
  adapter.on('unload', function(callback) {
    try {
      adapter.log.info('[END] Stopping CLEVERON adapter...');
      clearInterval(polling);
      //clearTimeout(setstatesstartup);
      adapter.setState('info.connection', false, true);
      callback();
    } catch (e) {
      adapter.log && adapter.log.warn("[END 7 catch] adapter stopped " + e);
      callback();
    }
  });

  /*
    adapter.on('objectChange', function(id, obj) {
      // Warning, obj can be null if it was deleted.
      adapter.log.info('objectChange ' + id + ' ' + JSON.stringify(obj));
    });

    adapter.on('stateChange', function(id, state) {
      // Warning, state can be null if it was deleted
      adapter.log.debug('stateChange ' + id + ' ' + JSON.stringify(state));
      // you can use the ack flag to detect if it is status (true) or command (false)

      if (state && !state.ack) {
        adapter.log.info('ack is not set!');
      }

    });

    // you can use the ack flag to detect if it is status (true) or command (false)



    // Some message was sent to adapter instance over message box. Used by email, pushover, text2speech, ...
    adapter.on('message', function(obj) {
      if (typeof obj === 'object' && obj.message) {
        if (obj.command === 'send') {
          // e.g. send email or pushover or whatever
          adapter.log('send command');

          // Send response in callback if required
          if (obj.callback) adapter.sendTo(obj.from, obj.command, 'Message received', obj.callback);
        }
      }
    });,

    */

  // is called when databases are connected and adapter received configuration.
  adapter.on('ready', function() {
    adapter.log.info('[START] Starting CLEVERON adapter');

    adapter.log.debug("ready - Adapter: databases are connected and adapter received configuration");

    adapter.setState('info.connection', true, true);

    main();



  });

  return adapter;
} // endStartAdapter


function main() {

  const user = adapter.config.user;
  const pass = adapter.config.userpw;

  pollingtime = (adapter.config.poll * 60000) || 300000;

  const loginpath = "login?username=" + user + "&password=" + pass;
  tokenurl = server + apipath + loginpath;
  //adapter.log.debug('Tokenurl: ' + tokenurl);

  try {
    firstrun = true;
    gettoken();

    if (!polling) {
      polling = setInterval(gettoken, pollingtime); // poll states every [30] seconds
    } // endIf

    //adapter.subscribeStates('*');

  } catch (e) {
    adapter.log.warn("Main connect error: " + e);
  }
} //endMain

function gettoken() {
  adapter.log.debug("Tokenurl= " + tokenurl);
  try {
    (async () => {
      try {
        const response = await axios(`${tokenurl}`);
        adapter.log.debug('Status-Code: ' + response.status);
        adapter.log.debug('Header: ' + JSON.stringify(response.headers));
        adapter.log.debug('Response.body= ' + JSON.stringify(response.data));
        var info = response.data; // info ist ein Objekt
        adapter.log.debug("info: " + JSON.stringify(info));
        adapter.log.debug('SessionToken= ' + info['sessionToken']);
        sessiontoken = info['sessionToken'].toString();
        getbuilding();

      } catch (error) {
        adapter.log.warn("gettoken - axios - error: " + error);

        if (requestcounter > 4) {
          adapter.log.warn('Mehrfach fehlerhafter gettoken, starte Adapter neu.')
          restartAdapter();
        } else if (requestcounter > 3) {
          adapter.log.info('Mehrfacher Fehler beim gettoken: Statuscode:' + error + '. Führe gettoken in 90 Sekunden erneut aus.')
          requestcounter++;
          setTimeout(function() {
            gettoken();
          }, 90000);
        } else {
          adapter.log.info('Fehler beim gettoken: Statuscode:' + error + '. Führe gettoken in 10 Sekunden erneut aus.')
          requestcounter++;
          setTimeout(function() {
            gettoken();
          }, 10000);
        }
      }
    })();
  } catch (e) {
    adapter.log.warn("gettoken error: " + e);
  }
} //end gettoken

function getbuilding() {
  try {
    adapter.log.debug("Sessiontoken: " + sessiontoken);
    var options = server + apipath + buildingpath + sessiontoken;
    adapter.log.debug("Options: " + options);
    (async () => {
      try {
        const response = await axios(`${options}`);
        adapter.log.debug('Status-Code: ' + response.status);
        adapter.log.debug('Header: ' + JSON.stringify(response.headers));
        adapter.log.debug('Response.body= ' + JSON.stringify(response.data));
        var infob = response.data; // info ist ein Objekt
        adapter.log.debug("infob: " + JSON.stringify(infob));
        for (let ib = 0; ib < infob.length; ib++) {
          adapter.log.debug(JSON.stringify(infob[ib]));
          adapter.log.debug('BuildingID: ' + infob[ib]['objectId']);
          buildingid[ib] = infob[ib]['objectId'];
          dataarray[ib] = new Object();
          dataarray[ib] = infob[ib];
          adapter.log.debug("Dataarray:" + JSON.stringify(dataarray));
        }

        for (let bi = 0; bi < buildingid.length; bi++) {
          getrooms(buildingid[bi], bi)
        }
      } catch (error) {
        adapter.log.warn("Error.Code: " + error.response.status);
        if (error.response.status == 500) {
          adapter.log.warn("getbuilding - Fehler: " + error + ", " + JSON.parse(error.response.data).message);
        } else {
          adapter.log.warn("getbuilding - Fehler: " + error + ", " + error.response.data);
        }

        if (requestcounter > 4) {
          adapter.log.warn('Mehrfach fehlerhafter getbuilding, starte Adapter neu.')
          restartAdapter();
        } else if (requestcounter > 3) {
          adapter.log.info('Mehrfacher Fehler beim getbuilding: Statuscode:' + error + '. Führe getbuilding in 90 Sekunden erneut aus.')
          requestcounter++;
          setTimeout(function() {
            getbuilding();
          }, 90000);
        } else {
          adapter.log.info('Fehler beim getbuilding: Statuscode:' + error + '. Führe getbuilding in 10 Sekunden erneut aus.')
          requestcounter++;
          setTimeout(function() {
            getbuilding();
          }, 10000);
        }
      }
    })();
  } catch (e) {
    adapter.log.warn("getbuilding error: " + e);
  }
} //end getbuilding

function getrooms(building, bi) {
  try {
    adapter.log.debug("SesstionToken: " + sessiontoken + " BuildingID: " + building + " BuildingNr: " + bi);
    var options = server + apipath + "building/" + building + roompath + sessiontoken;
    adapter.log.debug("Options: " + options);
    (async () => {
      try {
        const response = await axios(options);
        adapter.log.debug('Status-Code: ' + response.status);
        adapter.log.debug('Header: ' + JSON.stringify(response.headers));
        adapter.log.debug('Response.body= ' + JSON.stringify(response.data));
        var infor = response.data; // info ist ein Objekt
        adapter.log.debug("infor: " + JSON.stringify(infor));
        var rooms = new Array()
        for (let ir = 0; ir < infor.length; ir++) {
          adapter.log.debug("RaumID: " + infor[ir]['objectId']);
          rooms[ir] = infor[ir]['objectId'];
          dataarray[bi]['Rooms'] = new Array();
          dataarray[bi]['Rooms'][ir] = infor[ir];
          adapter.log.debug("Dataarray:" + JSON.stringify(dataarray));
        }
        adapter.log.debug("Räume im Gebäude: " + rooms);
        roomid[bi] = rooms;
        adapter.log.debug("Räume: " + JSON.stringify(roomid));

        for (let ri = 0; ri < rooms.length; ri++) {
          getdevices(rooms[ri], ri, building);
        }
      } catch (error) {
        adapter.log.warn("Error.Code: " + error.response.status);
        if (error.response.status == 500) {
          adapter.log.warn("getrooms - Fehler: " + error + ", " + JSON.parse(error.response.data).message);
        } else {
          adapter.log.warn("getrooms - Fehler: " + error + ", " + error.response.data);
        }

        if (requestcounter > 4) {
          adapter.log.warn('Mehrfach fehlerhafter getrooms, starte Adapter neu.')
          restartAdapter();
        } else if (requestcounter > 3) {
          adapter.log.info('Mehrfacher Fehler beim getrooms: Statuscode:' + error + '. Führe getrooms in 90 Sekunden erneut aus.')
          requestcounter++;
          setTimeout(function() {
            getrooms(building, bi);
          }, 90000);
        } else {
          adapter.log.info('Fehler beim getrooms: Statuscode:' + error + '. Führe getrooms in 10 Sekunden erneut aus.')
          requestcounter++;
          setTimeout(function() {
            getrooms(building, bi);
          }, 10000);
        }
      }
    })();
  } catch (e) {
    adapter.log.warn("getrooms error: " + e);
  }
} //getrooms

function getdevices(room, ri, building) {
  try {
    adapter.log.debug("SessionToken: " + sessiontoken + "BuildingID: " + building + "RoomID: " + room + "RoomNr: " + ri);
    var options = server + apipath + "room/" + room + devicepath + sessiontoken;
    adapter.log.debug("Options getdevices: " + options);
    (async () => {
      try {
        const response = await axios(options);
        adapter.log.debug('Status-Code: ' + response.status);
        adapter.log.debug('Header: ' + JSON.stringify(response.headers));
        adapter.log.debug('Response.body= ' + JSON.stringify(response.data));
        var infod = response.data; // info ist ein Objekt
        adapter.log.debug("infod: " + JSON.stringify(infod));
        for (let id = 0; id < infod.length; id++) {
          adapter.log.debug(infod[id]['objectId']);
          adapter.log.debug("Gebäudenummer: " + buildingid.indexOf(building));
          adapter.log.debug("Raumnummer: " + roomid[buildingid.indexOf(building)].indexOf(room));
          dataarray[buildingid.indexOf(building)]['Rooms'][ri]['Devices'] = new Array();
          dataarray[buildingid.indexOf(building)]['Rooms'][ri]['Devices'][id] = infod[id];
          adapter.log.debug("Dataarray:" + JSON.stringify(dataarray));
          //adapter.log.debug("Länge Datenarray: " + dataarray.length);
          if (firstrun == true) {
            adapter.log.debug("firstrun = " + firstrun + " Lege wenn nötige Objekte an und setzte alle Werte");
            firstrun = false;
            setobjectsfirstrun(dataarray);
          } else {
            adapter.log.debug("firstrun = " + firstrun + " setze laufende Werte neu");
            setstates(dataarray);
          }
        }
      } catch (error) {
        adapter.log.warn("Error.Code: " + error.response.status);
        if (error.response.status == 500) {
          adapter.log.warn("getdevices - Fehler: " + error + ", " + JSON.parse(error.response.data).message);
        } else {
          adapter.log.warn("getdevices - Fehler: " + error + ", " + error.response.data);
        }

        if (requestcounter > 4) {
          adapter.log.warn('Mehrfach fehlerhafter getdevices, starte Adapter neu.')
          restartAdapter();
        } else if (requestcounter > 3) {
          adapter.log.info('Mehrfacher Fehler beim getdevices: Statuscode:' + error + '. Führe getdevices in 90 Sekunden erneut aus.')
          requestcounter++;
          setTimeout(function() {
            getdevices(room, ri, building);
          }, 90000);
        } else {
          adapter.log.info('Fehler beim getdevices: Statuscode:' + error + '. Führe getdevices in 10 Sekunden erneut aus.')
          requestcounter++;
          setTimeout(function() {
            getdevices(room, ri, building);
          }, 10000);
        }
      }
    })();
  } catch (e) {
    adapter.log.warn("getdevices error: " + e);
  }
} //end getdevices

async function setobjectsfirstrun(dataarray) {
  try {
    adapter.log.debug("Lege " + dataarray.length + " Gebäude an.");
    for (var sofb = 0; sofb < dataarray.length; sofb++) {

      await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'], {
        type: 'folder',
        role: 'info.name',
        common: {
          name: "Gebäude"
        },
        native: {}
      });

      adapter.log.debug("Lege Gebäude " + dataarray[sofb]['homeName'] + " an.");
      await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + ".objectId", {
        type: 'state',
        common: {
          name: 'ObjektID Gebäude',
          desc: 'Objekt-ID alphanummerisch, eindeutig Gebäude',
          type: 'string',
          role: "state",
          read: true,
          write: false
        },
        native: {}
      });

      await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + ".city", {
        type: 'state',
        common: {
          name: 'Standort',
          desc: 'Objektstandort (Stadt/Gemeinde)',
          type: 'string',
          role: "info.address",
          read: true,
          write: false
        },
        native: {}
      });



      adapter.log.debug("Lege " + dataarray[sofb]['Rooms'].length + " Räume im " + (sofb + 1) + "ten Gebäude an.");
      for (var sofr = 0; sofr < dataarray[sofb]['Rooms'].length; sofr++) {
        adapter.log.debug("Lege Raum " + dataarray[sofb]['Rooms'][sofr]['roomName'] + " im Gebäude " + dataarray[sofb]['homeName'] + " an.");

        await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'], {
          type: 'device',
          role: 'info.name',
          common: {
            name: "Raum"
          },
          native: {}
        });


        await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + ".objectId", {
          type: 'state',
          common: {
            name: 'ObjektID Raum',
            desc: 'Objekt-ID alphanummerisch, eindeutig Raum',
            type: 'string',
            role: "info.name",
            read: true,
            write: false
          },
          native: {}
        });
        await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + ".floor", {
          type: 'state',
          common: {
            name: 'Etage',
            desc: 'Etagennummer des Raums',
            type: 'number',
            role: "info.address",
            read: true,
            write: false
          },
          native: {}
        });

        for (var sofd = 0; sofd < dataarray[sofb]['Rooms'][sofr]['Devices'].length; sofd++) {
          adapter.log.debug("Lege Gerät " + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + " im Raum " + dataarray[sofb]['Rooms'][sofr]['roomName'] + " im Gebäude " + dataarray[sofb]['homeName'] + " an.");
          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'], {
            type: 'channel',
            role: 'info.name',
            common: {
              name: "Gerät"
            },
            native: {}
          });

          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + ".objectId", {
            type: 'state',
            common: {
              name: 'ObjektID Gerät',
              desc: 'Objekt-ID alphanummerisch, eindeutig Gerät',
              type: 'string',
              role: "info.name",
              read: true,
              write: false
            },
            native: {}
          });
          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + ".macAddress", {
            type: 'state',
            common: {
              name: 'MAC-Adresse Gerät',
              desc: 'MAC-Adresse Gerät',
              type: 'string',
              role: "info.mac",
              read: true,
              write: false
            },
            native: {}
          });
          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + ".batteryVoltage", {
            type: 'state',
            common: {
              name: 'Batteriespannung',
              desc: 'Batteriespannung (-1 bei Netzanschluss)',
              type: 'number',
              role: "value.battery",
              read: true,
              write: false,
              unit: "V"
            },
            native: {}
          });
          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + ".co2", {
            type: 'state',
            common: {
              name: 'Messwert CO2',
              desc: 'CO2 - Messwert in ppm',
              type: 'number',
              role: "value",
              read: true,
              write: false,
              unit: "ppm"
            },
            native: {}
          });
          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + ".lastMeasurement", {
            type: 'state',
            common: {
              name: 'Letzte Messung',
              desc: 'Datum und Uhrzeit der letzten Messung',
              type: 'string',
              role: "date",
              read: true,
              write: false
            },
            native: {}
          });
          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + ".temperature", {
            type: 'state',
            common: {
              name: 'Temperatur',
              desc: 'Temperaturwert',
              type: 'number',
              role: "value.temperature",
              read: true,
              write: false,
              unit: "°C"
            },
            native: {}
          });
          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + ".humidity", {
            type: 'state',
            common: {
              name: 'Feuchtigkeit',
              desc: 'Relative Feuchte in %',
              type: 'number',
              role: "value.humidity",
              read: true,
              write: false,
              unit: "%"
            },
            native: {}
          });
          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + ".wifiStrength", {
            type: 'state',
            common: {
              name: 'Signalstärke WIFI',
              desc: 'Sträke des WLAN - Signals',
              type: 'number',
              role: "state",
              read: true,
              write: false
            },
            native: {}
          });
          await adapter.setObjectNotExistsAsync(dataarray[sofb]['homeName'] + "." + dataarray[sofb]['Rooms'][sofr]['roomName'] + "." + dataarray[sofb]['Rooms'][sofr]['Devices'][sofd]['serialNumber'] + ".deviceType", {
            type: 'state',
            common: {
              name: 'Gerätetyp',
              desc: 'Gerätetyp, Art des Sensors',
              type: 'string',
              role: "info.name",
              read: true,
              write: false
            },
            native: {}
          });

          //setTimeout(setstatesstartup, 2000);
        } //end rotation devices
      } //end rotation rooms
    } //end rotation Buildings


    setstatesstartup();



  } catch (e) {
    adapter.log.warn("setobjectsfirstrun error: " + e);
  }

} //end setobjectsfirstrun

async function setstatesstartup() {
  try {

    adapter.log.debug("Jetzt werden die statischen Werte gesetzt");
    for (var ssb = 0; ssb < dataarray.length; ssb++) {

      await adapter.setStateAsync(dataarray[ssb]['homeName'] + ".objectId", dataarray[ssb]['objectId'], true);
      await adapter.setStateAsync(dataarray[ssb]['homeName'] + ".city", dataarray[ssb]['city'], true);


      for (var ssr = 0; ssr < dataarray[ssb]['Rooms'].length; ssr++) {
        await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + ".objectId", dataarray[ssb]['Rooms'][ssr]['objectId'], true);
        await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + ".floor", dataarray[ssb]['Rooms'][ssr]['floor'], true);

        for (var ssd = 0; ssd < dataarray[ssb]['Rooms'][ssr]['Devices'].length; ssd++) {
          await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".objectId", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['objectId'], true);
          await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".macAddress", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['macAddress'], true);
          //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".batteryVoltage", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['batteryVoltage'], true);
          //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".co2", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['co2'], true);
          //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".lastMeasurement", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['lastMeasurementDate']['iso'], true);

          //Temperature Data not provided by API: Reported to developer.
          //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".temperature", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['temperature'], true);

          //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".humidity", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['humidity'], true);
          //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".wifiStrength", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['wifiStrength'], true);
          await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".deviceType", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['deviceType'], true);


        } //end rotation devices
      } //end rotation rooms
    } //end rotation Buildings


    setstates();


  } catch (e) {
    adapter.log.warn("setstatesstartup error: " + e);
  }
} //end setstatesstartup

async function setstates() {
  try {

    adapter.log.debug("Jetzt werden die laufenden Werte gesetzt");
    for (var ssb = 0; ssb < dataarray.length; ssb++) {

      //await adapter.setStateAsync(dataarray[ssb]['homeName'] + ".objectId", dataarray[ssb]['objectId'], true);
      //await adapter.setStateAsync(dataarray[ssb]['homeName'] + ".city", dataarray[ssb]['city'], true);


      for (var ssr = 0; ssr < dataarray[ssb]['Rooms'].length; ssr++) {
        //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + ".objectId", dataarray[ssb]['Rooms'][ssr]['objectId'], true);
        //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + ".floor", dataarray[ssb]['Rooms'][ssr]['floor'], true);

        for (var ssd = 0; ssd < dataarray[ssb]['Rooms'][ssr]['Devices'].length; ssd++) {
          adapter.log.debug(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + " Gerätedaten: " + JSON.stringify(dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]));
          //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".objectId", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['objectId'], true);
          //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".macAddress", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['macAddress'], true);
          await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".batteryVoltage", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['batteryVoltage'], true);
          await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".co2", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['co2'], true);
          await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".lastMeasurement", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['lastMeasurementDate']['iso'], true);
          await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".temperature", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['temperature'], true);
          await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".humidity", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['humidity'], true);
          await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".wifiStrength", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['wifiStrength'], true);
          //await adapter.setStateAsync(dataarray[ssb]['homeName'] + "." + dataarray[ssb]['Rooms'][ssr]['roomName'] + "." + dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['serialNumber'] + ".deviceType", dataarray[ssb]['Rooms'][ssr]['Devices'][ssd]['deviceType'], true);


        } //end rotation devices
      } //end rotation rooms
    } //end rotation Buildings





  } catch (e) {
    adapter.log.warn("setstates error: " + e);
  }
} //end setstates

function restartAdapter() {
  adapter.getForeignObject('system.adapter.' + adapter.namespace, (err, obj) => {
    if (obj) adapter.setForeignObject('system.adapter.' + adapter.namespace, obj);
  });
} // endFunctionRestartAdapter

// If started as allInOne/compact mode => return function to create instance
if (module && module.parent) {
  module.exports = startAdapter;
} else {
  // or start the instance directly
  startAdapter();
} // endElse