Aqualink Pool Automation in iobroker integrieren

Qlink

Im Nodered Forum hat jemand einen Flow gepostet mit dem es anscheinend auch funktionieren sollte die Daten der Zodiac Exo IQ auszulesen:

Hier ist der Flow:

[
    {
        "id": "6c519c18faf10a1e",
        "type": "tab",
        "label": "Zodiac Exo",
        "disabled": false,
        "info": "",
        "env": []
    },
    {
        "id": "1e47a52e3f1755e1",
        "type": "inject",
        "z": "6c519c18faf10a1e",
        "name": "Every hour",
        "repeat": "3540",
        "crontab": "",
        "once": true,
        "onceDelay": "60",
        "topic": "",
        "payload": "",
        "payloadType": "date",
        "x": 130,
        "y": 60,
        "wires": [
            [
                "6808aab954fc8b01"
            ]
        ]
    },
    {
        "id": "7849f0c750568181",
        "type": "http request",
        "z": "6c519c18faf10a1e",
        "name": "",
        "method": "use",
        "ret": "obj",
        "paytoqs": "ignore",
        "url": "",
        "tls": "",
        "persist": false,
        "proxy": "",
        "authType": "",
        "senderr": false,
        "x": 610,
        "y": 60,
        "wires": [
            [
                "18bf3f43ad2e6aa4"
            ]
        ]
    },
    {
        "id": "18bf3f43ad2e6aa4",
        "type": "change",
        "z": "6c519c18faf10a1e",
        "name": "IDToken",
        "rules": [
            {
                "t": "move",
                "p": "payload.userPoolOAuth.IdToken",
                "pt": "msg",
                "to": "payload",
                "tot": "msg"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 840,
        "y": 60,
        "wires": [
            [
                "ea244732498b9412"
            ]
        ]
    },
    {
        "id": "6808aab954fc8b01",
        "type": "function",
        "z": "6c519c18faf10a1e",
        "name": "Format Post Request",
        "func": "msg.method = 'POST';\nmsg.headers = {};\nmsg.headers['Host'] = 'prod.zodiac-io.com';\nmsg.headers['accept'] = 'application/json';\nmsg.headers['content-type'] = 'application/json';\nmsg.headers['accept-encoding'] = '*';\nmsg.headers['user-agent'] = 'okhttp/3.12.0';\nmsg.url = 'https://prod.zodiac-io.com/users/v1/login';\nmsg.payload = '{\"api_key\":\"yourapikeyhere\", \"email\":\"youremail@address.com\", \"password\":\"youriAqualinkpassword\"}';\nreturn msg;",
        "outputs": 1,
        "timeout": "",
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 380,
        "y": 60,
        "wires": [
            [
                "7849f0c750568181"
            ]
        ]
    },
    {
        "id": "ea244732498b9412",
        "type": "function",
        "z": "6c519c18faf10a1e",
        "name": "Set variable IDToken",
        "func": "global.set(\"IDToken\",msg.payload);\nreturn msg;",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1080,
        "y": 60,
        "wires": [
            []
        ]
    },
    {
        "id": "dcd9bc84914a71f6",
        "type": "http request",
        "z": "6c519c18faf10a1e",
        "name": "Chlorinator",
        "method": "use",
        "ret": "obj",
        "paytoqs": "ignore",
        "url": "",
        "tls": "",
        "persist": false,
        "proxy": "",
        "authType": "",
        "senderr": false,
        "x": 610,
        "y": 380,
        "wires": [
            [
                "02b59259a14e8461",
                "b8075e9783a1eb4f",
                "f0bb9145a81ce74a",
                "eba07f6046f035d6",
                "4ac01fee0ba334b1",
                "018a8ddf5da0b1f2",
                "9c4298d655076b55"
            ]
        ]
    },
    {
        "id": "9df6c312e595c863",
        "type": "function",
        "z": "6c519c18faf10a1e",
        "name": "Format Get Request",
        "func": "let bearer = global.get(\"IDToken\");\nmsg.method = 'GET';\nmsg.headers = {};\nmsg.headers['Host'] = 'prod.zodiac-io.com';\nmsg.headers['accept'] = 'application/json';\nmsg.headers['authorization'] = bearer;\nmsg.headers['accept-encoding'] = '*';\nmsg.headers['user-agent'] = 'okhttp/3.12.0';\nmsg.url = 'https://prod.zodiac-io.com/devices/v1/yourDeviceIDhere/shadow';\nreturn msg;",
        "outputs": 1,
        "timeout": "",
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 380,
        "y": 380,
        "wires": [
            [
                "dcd9bc84914a71f6"
            ]
        ]
    },
    {
        "id": "a56824124abf6deb",
        "type": "inject",
        "z": "6c519c18faf10a1e",
        "name": "Every 10 mins",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "600",
        "crontab": "",
        "once": true,
        "onceDelay": "300",
        "topic": "",
        "payloadType": "date",
        "x": 140,
        "y": 380,
        "wires": [
            [
                "9df6c312e595c863"
            ]
        ]
    },
    {
        "id": "02b59259a14e8461",
        "type": "change",
        "z": "6c519c18faf10a1e",
        "name": "ORP",
        "rules": [
            {
                "t": "move",
                "p": "payload.state.reported.equipment.swc_0.sns_2.value",
                "pt": "msg",
                "to": "payload",
                "tot": "msg"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 830,
        "y": 300,
        "wires": [
            []
        ]
    },
    {
        "id": "b8075e9783a1eb4f",
        "type": "change",
        "z": "6c519c18faf10a1e",
        "name": "pH",
        "rules": [
            {
                "t": "move",
                "p": "payload.state.reported.equipment.swc_0.sns_1.value",
                "pt": "msg",
                "to": "payload",
                "tot": "msg"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 830,
        "y": 140,
        "wires": [
            [
                "0e3f2e3e62511c3a"
            ]
        ]
    },
    {
        "id": "f0bb9145a81ce74a",
        "type": "change",
        "z": "6c519c18faf10a1e",
        "name": "Filter Temp",
        "rules": [
            {
                "t": "move",
                "p": "payload.state.reported.equipment.swc_0.sns_3.value",
                "pt": "msg",
                "to": "payload",
                "tot": "msg"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 850,
        "y": 460,
        "wires": [
            []
        ]
    },
    {
        "id": "0e3f2e3e62511c3a",
        "type": "range",
        "z": "6c519c18faf10a1e",
        "minin": "0",
        "maxin": "10",
        "minout": "0",
        "maxout": "1",
        "action": "scale",
        "round": false,
        "property": "payload",
        "name": "Divide by 10",
        "x": 1050,
        "y": 140,
        "wires": [
            []
        ]
    },
    {
        "id": "eba07f6046f035d6",
        "type": "change",
        "z": "6c519c18faf10a1e",
        "name": "ORP Setpoint",
        "rules": [
            {
                "t": "move",
                "p": "payload.state.reported.equipment.swc_0.orp_sp",
                "pt": "msg",
                "to": "payload",
                "tot": "msg"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 860,
        "y": 380,
        "wires": [
            []
        ]
    },
    {
        "id": "4ac01fee0ba334b1",
        "type": "change",
        "z": "6c519c18faf10a1e",
        "name": "pH Setpoint",
        "rules": [
            {
                "t": "move",
                "p": "payload.state.reported.equipment.swc_0.ph_sp",
                "pt": "msg",
                "to": "payload",
                "tot": "msg"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 850,
        "y": 220,
        "wires": [
            [
                "874e523fa6c7da37"
            ]
        ]
    },
    {
        "id": "874e523fa6c7da37",
        "type": "range",
        "z": "6c519c18faf10a1e",
        "minin": "0",
        "maxin": "10",
        "minout": "0",
        "maxout": "1",
        "action": "scale",
        "round": false,
        "property": "payload",
        "name": "Divide by 10",
        "x": 1050,
        "y": 220,
        "wires": [
            []
        ]
    },
    {
        "id": "018a8ddf5da0b1f2",
        "type": "change",
        "z": "6c519c18faf10a1e",
        "name": "Zodiac Error Code",
        "rules": [
            {
                "t": "move",
                "p": "payload.state.reported.equipment.swc_0.error_code",
                "pt": "msg",
                "to": "payload",
                "tot": "msg"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 870,
        "y": 540,
        "wires": [
            []
        ]
    },
    {
        "id": "9c4298d655076b55",
        "type": "change",
        "z": "6c519c18faf10a1e",
        "name": "Low Setting",
        "rules": [
            {
                "t": "move",
                "p": "payload.state.reported.equipment.swc_0.low",
                "pt": "msg",
                "to": "payload",
                "tot": "msg"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 850,
        "y": 620,
        "wires": [
            []
        ]
    }
]

und hier die Anleitung dazu:

Note that in the Function node (Format Post Request) preceeding the first HTTP Request , you will require three bits of info -

API Key (generic for all users) - EOOEMOW4YR6QNB11
Email
Password

In the Function node (Format Get Request) preceeding the Device, you will need 'yourDeviceIDhere' where specified. It's the serial number of the device and looks something like -

JT19000123
or
JX19100123

The post you originally linked to has the curl commands necessary to pull the DeviceID. They might also be physically printed on the device somewhere but I haven't looked.

PULL DEVICE ID:

The steps required to login to iAqualink are as follows (note the api_key is the same for all users)

curl  -X POST -H "Host:prod.zodiac-io.com" -H "accept:application/json" -H "content-type:application/json" -H "accept-encoding:gzip" -H "user-agent:okhttp/3.12.0" -d '{"api_key":"EOOEMOW4YR6QNB11", "email":"XXXX@XXXX", "password":"XXXXXX"}' "https://prod.zodiac-io.com/users/v1/login"

The iAqualink server returns a page of data (X's blank out personal data) -

{
    "username": "XXXXXXXXXXXXXXXXXX",
    "email": "XXXXXXXXXXX@gmail.com",
    "first_name": "XXX",
    "last_name": "XXXXXX",
    "address": "XXX\n, XXX, XX, au, XXX",
    "address_1": "XXXXXXXXXXX",
    "address_2": null,
    "city": "XXXXXXXXXXX",
    "state": "XX",
    "country": "au",
    "postal_code": "XXXX",
    "id": "XXXXXX",
    "authentication_token": "XXXXXXXXXXXXXXXXXXXX",
    "session_id": "XXXXXXXXXXXXXXXXXXXX",
    "created_at": "2019-12-09T03:12:57.000Z",
    "updated_at": "2019-12-09T03:12:57.000Z",
    "time_zone": "Australia/XXXXXX",
    "phone": "XXXXXXXXXX",
    "opt_in_1": "1",
    "opt_in_2": "0",
    "role": "customer",
    "cognitoPool": {
        "appClientId": "XXXXXXXXXXXXXXXXXXXXX",
        "poolId": "us-east-1_XXXXXXXXX",
        "region": "us-east-1"
    },
    "credentials": {
        "AccessKeyId": "XXXXXXXXXXXXXXXXXXXX",
        "SecretKey": "XXXXXXXXXXXXXXXXXXXXXX",
        "SessionToken": "XXXXXX.............XXXXXXXX",
        "Expiration": "2020-04-26T05:24:59.000Z",
        "IdentityId": "us-east-1:XXXXXXXXXXXXXXXX"
    },
    "userPoolOAuth": {
        "AccessToken": "XXXXXXX...............XXXXXXX",
        "ExpiresIn": 3600,
        "TokenType": "Bearer",
        "RefreshToken": "XXXXXX..........XXXXXXXXX",
        "IdToken": "XXXXXXXXXX.........XXXXXXXXXXX"
    
}

The important fields in the preceeding data block are -

"id": (a 6 digit number that remains the same across logins),

"authentication_token": (a 20 character field that remains the same across logins),

"IdToken": (a 1740 character field that expires in 3600 seconds).

Armed with this data, a second command will elicit the device serial numbers registered to the user's account (user_id = id from block above) -

curl 'https://support.iaqualink.com/devices.json?api_key=EOOEMOW4YR6QNB07&authentication_token=XXXXXXXXXXXXXXXXXXXX&user_id=XXXXXX' -H "Host:support.iaqualink.com" -H "accept:application/json" -H "user-agent:okhttp/3.12.0" -H "content-type:application/json"

This is the returned data block for the two devices I have (a chlorinator and a heat pump) -

[
{
"id":"XXXXXX",
"serial_number":"XXXXXXXXXX",
"created_at":"2020-01-07T09:41:41.000Z",
"updated_at":"2020-01-07T09:41:41.000Z",
"name":"Z400 iQ TD7",
"device_type":"hpm",
"owner_id":null,
"updating":false,
"firmware_version":null,
"target_firmware_version":null,
"update_firmware_start_at":null,
"last_activity_at":null
},
{
"id":"XXXXXX",
"serial_number":"XXXXXXXXXX",
"created_at":"2019-12-09T03:18:18.000Z",
"updated_at":"2019-12-09T03:18:18.000Z",
"name":"eXO-Pro iQ",
"device_type":"exo",
"owner_id":null,
"updating":false,
"firmware_version":null,
"target_firmware_version":null,
"update_firmware_start_at":null,
"last_activity_at":null
}
]

INFORMATION RETRIEVAL AND CONTROL

With the DEVICE_SERIAL_NUMBER ("serial_number" in the block above), and ID_TOKEN ("IdToken" from the first block of data) the next GET command can be populated to retrieve the pH and ORP values for the chlorinator -

curl -X GET -H "Host:prod.zodiac-io.com" -H "accept:application/json" -H "authorization:ID_TOKEN" -H "accept-encoding:gzip" -H "user-agent:okhttp/3.12.0" "https://prod.zodiac-io.com/devices/v1/DEVICE_SERIAL_NUMBER/shadow"

Control of the chlorinator production (On/Off) can done using a POST command ("production" to be set to 0 or 1) -

curl -X POST -H "Host:prod.zodiac-io.com" -H "accept:application/json" -H "authorization:ID_TOKEN" -H "content-type:application/json; charset=UTF-8" -H "content-length:62" -H "accept-encoding:gzip" -H "user-agent:okhttp/3.12.0" -d '{"state":{"desired":{"equipment":{"swc_0":{"production":0}}}}}' "https://prod.zodiac-io.com/devices/v1/DEVICE_SERIAL_NUMBER/shadow"

I have the DEVICE_SERIAL_NUMBER for the components in my system (this value is fixed).
I now need a mechanism to record the variable ID_TOKEN and subsequently plug this into the commands above.

Kann das eventuell mal jemand testen, der eine Zodiac Exo im Einsatz hat ?

Hexagon

@qlink

Besten Dank für die Info.
Anhand dieser konnte ich per Javascript die Pool-Daten auslesen und im iobroker als object ablegen. Danach habe ich mit weiteren scripts die entsprechenden Daten ausgefiltert und diese ebenfalls in ein Object abgelegt.

const axios = require('axios');
// Daten für die POST-Anfrage
const daten = {
    api_key: "EOOEMOW4YR6QNB11",
    email: "xxxxxxxxxxxx",
    password: "xxxxxxxxxxxx"
};
// Erste Anfrage zur Authentifizierung
axios.post('https://prod.zodiac-io.com/users/v1/login', daten, {
    headers: {
        'Host': 'prod.zodiac-io.com',
        'accept': 'application/json',
        'Content-Type': 'application/json',
        'accept-encoding': 'gzip',
        'user-agent': 'okhttp/3.12.0'
    }
}).then((response) => {
    setState('javascript.0.iAquaLink.IdToken', JSON.stringify(response.data), true);
    console.log('Daten erfolgreich in ioBroker gespeichert.');
    // Extrahieren des idTokens
    let jsonObject = response.data;
    let idToken = jsonObject.userPoolOAuth.IdToken;
    if (idToken) {
        console.log("idToken extrahiert:", idToken);
        setState('javascript.0.iAquaLink.IdToken_clean', idToken, true);
        // Zweite Anfrage unter Verwendung des idTokens
        const options = {
            method: 'GET',
            url: 'https://prod.zodiac-io.com/devices/v1/serialnumberxxxxxx/shadow',
            headers: {
                'Host': 'prod.zodiac-io.com',
                'accept': 'application/json',
                'authorization': idToken,
                'accept-encoding': 'gzip',
                'user-agent': 'okhttp/3.12.0'
            }
        };
        return axios.request(options);
    } else {
        throw new Error("Kein idToken gefunden!");
    }
}).then(response => {
    console.log(response.data);
    setState('0_userdata.0.Pool.Pooldata', response.data, true);
}).catch(error => {
    console.error('Fehler:', error);
});

Negalein

@hexagon

Hallo

welchen Typ benötigen diese DP?

javascript.0.iAquaLink.IdToken
javascript.0.iAquaLink.IdToken_clean
0_userdata.0.Pool.Pooldata

Hexagon

@negalein

Alle DPs => Typ: "String" und Rolle: "State"
Am besten alle DP in 0_userdata.0.xxxx vorab anlegen.

Negalein

@hexagon

ich bekomm einen Fehler.
Ist nicht ersichtlich woher.

javascript.0	14:59:13.580	info	Start JavaScript script.js.Pool.iAqualink (Javascript/js)
javascript.0	14:59:13.589	info	registered 0 subscriptions, 0 schedules, 0 messages, 0 logs and 0 file subscriptions
javascript.0	14:59:14.322	error	Fehler:

Hexagon

@negalein

Zeile 29: Richtige bzw. eigene Serien Nr. verwendet ?

Negalein

@hexagon sagte in Aqualink Pool Automation in iobroker integrieren:

Zeile 29: Richtige bzw. eigene Serien Nr. verwendet ?

ahhhhh, übersehn

jetzt kommen Daten, aber mit Warn.

DP werden befüllt

javascript.0	15:35:55.780	info	Start JavaScript script.js.Pool.iAqualink (Javascript/js)
javascript.0	15:35:55.789	info	registered 0 subscriptions, 0 schedules, 0 messages, 0 logs and 0 file subscriptions
javascript.0	15:35:56.600	info	Daten erfolgreich in ioBroker gespeichert.
javascript.0	15:35:56.600	info	idToken extrahiert:
javascript.0	15:35:56.886	info	
{
  state: {
    reported: {
      aws: [Object],
      vr: 'V85E4',
      vr_esp: 'V85E4',
      equipment: [Object],
      schedules: [Object]
    }
  },
  deviceId: 'JT22008430',
  ts: 1747056956
}
javascript.0	15:35:56.889	warn    at script.js.Pool.iAqualink:45:5

Hexagon

@negalein

ok prima, jetzt kannst du mit entsprechenden Filterungen weitere Datenpunkte befüllen, je nachdem was du benötigst:

Beispiel für ORP Werte:

// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.Pool.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.Pool.Pooldata_ORP";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_2` extrahieren
        let sns_2 = jsonObject.state.reported.equipment.swc_0.sns_2.value;
        if (sns_2) {
            console.log("sns_2 extrahiert:", sns_2);
            // sns_2 in das neue ioBroker-Objekt speichern
            setState(targetObject, sns_2, true);
        } else {
            console.log("Kein sns_2 gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});

Negalein

@hexagon sagte in Aqualink Pool Automation in iobroker integrieren:

ok prima, jetzt kannst du mit entsprechenden Filterungen weitere Datenpunkte befüllen, je nachdem was du benötigst:

Danke

hast du auch noch für pH, Chlorination und Temp?

Hexagon

@negalein

ORP Wert entspricht bereits dem Chlorinator

Für PH Wert ist es genau das gleiche nur der Sensor 1 => sns_1:
Die Kommastelle kannst du dann mit dem VIS Editor entsprechend setzen.

// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.Pool.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.Pool.Pooldata_PH";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_1` extrahieren
        let sns_1 = jsonObject.state.reported.equipment.swc_0.sns_1.value;
        if (sns_1) {
            console.log("sns_1 extrahiert:", sns_1);
            // sns_1 in das neue ioBroker-Objekt speichern
            setState(targetObject, sns_1, true);
        } else {
            console.log("Kein sns_1 gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});

Nach diesem Muster kannst du dir auch die Temp Werte bauen.

Negalein

@hexagon sagte in Aqualink Pool Automation in iobroker integrieren:

ORP Wert entspricht bereits dem Chlorinator

schaut in der App so aus

Meinte Salzelektrolysegerät (Pumpe)

sns_3 ist dann die Temp?

oder wie finde ich das raus?

Hexagon

@negalein

Schau dir die Werte im DP Pooldata an:
0_userdata.0.Pool.Pooldata

Dort sollten alle Daten ersichtlich sein:

Beispiel Temperatur:

"sns_3": {
            "sensor_type": "Water temp",
            "state": 1,
            "value": 25

Negalein

@hexagon sagte in Aqualink Pool Automation in iobroker integrieren:

Dort sollten alle Daten ersichtlich sein:

ahhh, ich war blind. hab nur die ersten paar zeilen gesehn.

und die gewünschten pack ich alle in das Script von dir?

Negalein

@hexagon

die Pumpe scheint so auf:

          "filter_pump": {
            "state": 1,
            "type": 1
          },

Binde ich die dann so ein?

// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.Pool.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.Pool.Pooldata_Pumpe";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_2` extrahieren
        let sns_2 = jsonObject.state.reported.equipment.swc_0.filter_pump.value;
        if (sns_2) {
            console.log("sns_2 extrahiert:", filter_pump);
            // sns_2 in das neue ioBroker-Objekt speichern
            setState(targetObject, filter_pump, true);
        } else {
            console.log("Kein filter_pump gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});

Und alle 4 in 1 Script?

const axios = require('axios');
// Daten für die POST-Anfrage
const daten = {
    api_key: "EOOEMOW4YR6QNB11",
    email: "xxxxxxxx@xxxxxx.xx",
    password: "xxxxxxxxxxx"
};
// Erste Anfrage zur Authentifizierung
axios.post('https://prod.zodiac-io.com/users/v1/login', daten, {
    headers: {
        'Host': 'prod.zodiac-io.com',
        'accept': 'application/json',
        'Content-Type': 'application/json',
        'accept-encoding': 'gzip',
        'user-agent': 'okhttp/3.12.0'
    }
}).then((response) => {
    setState('0_userdata.0.iAquaLink.IdToken', JSON.stringify(response.data), true);
    console.log('Daten erfolgreich in ioBroker gespeichert.');
    // Extrahieren des idTokens
    let jsonObject = response.data;
    let idToken = jsonObject.userPoolOAuth.IdToken;
    if (idToken) {
        console.log("idToken extrahiert:", idToken);
        setState('0_userdata.0.iAquaLink.IdToken_clean', idToken, true);
        // Zweite Anfrage unter Verwendung des idTokens
        const options = {
            method: 'GET',
            url: 'https://prod.zodiac-io.com/devices/v1/JT22005060/shadow',
            headers: {
                'Host': 'prod.zodiac-io.com',
                'accept': 'application/json',
                'authorization': idToken,
                'accept-encoding': 'gzip',
                'user-agent': 'okhttp/3.12.0'
            }
        };
        return axios.request(options);
    } else {
        throw new Error("Kein idToken gefunden!");
    }
}).then(response => {
    console.log(response.data);
    setState('0_userdata.0.iAquaLink.Pooldata', response.data, true);
}).catch(error => {
    console.error('Fehler:', error);
});

// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.Pool.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.Pool.Pooldata_PH";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_1` extrahieren
        let sns_1 = jsonObject.state.reported.equipment.swc_0.sns_1.value;
        if (sns_1) {
            console.log("sns_1 extrahiert:", sns_1);
            // sns_1 in das neue ioBroker-Objekt speichern
            setState(targetObject, sns_1, true);
        } else {
            console.log("Kein sns_1 gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});

// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.Pool.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.Pool.Pooldata_ORP";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_2` extrahieren
        let sns_2 = jsonObject.state.reported.equipment.swc_0.sns_2.value;
        if (sns_2) {
            console.log("sns_2 extrahiert:", sns_2);
            // sns_2 in das neue ioBroker-Objekt speichern
            setState(targetObject, sns_2, true);
        } else {
            console.log("Kein sns_2 gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});
 
// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.Pool.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.Pool.Pooldata_Pumpe";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_2` extrahieren
        let sns_2 = jsonObject.state.reported.equipment.swc_0.filter_pump.value;
        if (sns_2) {
            console.log("sns_2 extrahiert:", filter_pump);
            // sns_2 in das neue ioBroker-Objekt speichern
            setState(targetObject, filter_pump, true);
        } else {
            console.log("Kein filter_pump gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});

Negalein

@hexagon

Guten Morgen

hab einen Fehler.
Kannst du bitte mal drüberschaun?

javascript.0	08:51:34.699	info	Start JavaScript script.js.Pool.iAqualink (Javascript/js)
javascript.0	08:51:34.700	error script.js.Pool.iAqualink compile failed: at script.js.Pool.iAqualink:79

const axios = require('axios');
// Daten für die POST-Anfrage
const daten = {
    api_key: "EOOEMOW4YR6QNB11",
    email: "xxxxxxxxx@xxxxxxx.at",
    password: "xxxxxxxxx"
};
// Erste Anfrage zur Authentifizierung
axios.post('https://prod.zodiac-io.com/users/v1/login', daten, {
    headers: {
        'Host': 'prod.zodiac-io.com',
        'accept': 'application/json',
        'Content-Type': 'application/json',
        'accept-encoding': 'gzip',
        'user-agent': 'okhttp/3.12.0'
    }
}).then((response) => {
    setState('0_userdata.0.iAquaLink.IdToken', JSON.stringify(response.data), true);
    console.log('Daten erfolgreich in ioBroker gespeichert.');
    // Extrahieren des idTokens
    let jsonObject = response.data;
    let idToken = jsonObject.userPoolOAuth.IdToken;
    if (idToken) {
        console.log("idToken extrahiert:", idToken);
        setState('0_userdata.0.iAquaLink.IdToken_clean', idToken, true);
        // Zweite Anfrage unter Verwendung des idTokens
        const options = {
            method: 'GET',
            url: 'https://prod.zodiac-io.com/devices/v1/JT22005060/shadow',
            headers: {
                'Host': 'prod.zodiac-io.com',
                'accept': 'application/json',
                'authorization': idToken,
                'accept-encoding': 'gzip',
                'user-agent': 'okhttp/3.12.0'
            }
        };
        return axios.request(options);
    } else {
        throw new Error("Kein idToken gefunden!");
    }
}).then(response => {
    console.log(response.data);
    setState('0_userdata.0.iAquaLink.Pooldata', response.data, true);
}).catch(error => {
    console.error('Fehler:', error);
});

// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.iAquaLink.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.iAquaLink.Pooldata_PH";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_1` extrahieren
        let sns_1 = jsonObject.state.reported.equipment.swc_0.sns_1.value;
        if (sns_1) {
            console.log("sns_1 extrahiert:", sns_1);
            // sns_1 in das neue ioBroker-Objekt speichern
            setState(targetObject, sns_1, true);
        } else {
            console.log("Kein sns_1 gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});

// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.iAquaLink.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.iAquaLink.Pooldata_ORP";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_2` extrahieren
        let sns_2 = jsonObject.state.reported.equipment.swc_0.sns_2.value;
        if (sns_2) {
            console.log("sns_2 extrahiert:", sns_2);
            // sns_2 in das neue ioBroker-Objekt speichern
            setState(targetObject, sns_2, true);
        } else {
            console.log("Kein sns_2 gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});
 
// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.iAquaLink.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.iAquaLink.Pooldata_Pumpe";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_2` extrahieren
        let sns_2 = jsonObject.state.reported.equipment.swc_0.filter_pump.value;
        if (sns_2) {
            console.log("sns_2 extrahiert:", filter_pump);
            // sns_2 in das neue ioBroker-Objekt speichern
            setState(targetObject, filter_pump, true);
        } else {
            console.log("Kein filter_pump gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});

Hexagon

@negalein

Der Pfad in Zeile 120 stimmt nicht.
Es gibt unter filter_pump kein "value" sondern nur "state" oder "type"

Zudem hast du im Rest vom script alles auf "sns_2" belassen. sns_2 verwendest du bereits für ORP. Du willst aber jetzt den Status der Pumpe auslesen. Also => sns_2 in filter_pump umbenennen.

Negalein

@hexagon sagte in Aqualink Pool Automation in iobroker integrieren:

Es gibt unter filter_pump kein "value" sondern nur "state" oder "type"

Danke

muss ich dann let filter_pump = jsonObject.state.reported.equipment.swc_0.filter_pump.state; verwenden, um zu sehen, ob die Pumpe läuft?

Hexagon

@negalein

genau, und darunter ebenfalls alles noch umbenennen wo sns_2 auftaucht.

Negalein

@hexagon sagte in Aqualink Pool Automation in iobroker integrieren:

genau, und darunter ebenfalls alles noch umbenennen wo sns_2 auftaucht.

es kommt noch immer der Error

javascript.0	15:35:21.966	info	Start JavaScript script.js.Pool.iAqualink (Javascript/js)
javascript.0	15:35:21.967	error	script.js.Pool.iAqualink compile failed: at script.js.Pool.iAqualink:79

const axios = require('axios');
// Daten für die POST-Anfrage
const daten = {
    api_key: "EOOEMOW4YR6QNB11",
    email: "mail",
    password: "pwd"
};
// Erste Anfrage zur Authentifizierung
axios.post('https://prod.zodiac-io.com/users/v1/login', daten, {
    headers: {
        'Host': 'prod.zodiac-io.com',
        'accept': 'application/json',
        'Content-Type': 'application/json',
        'accept-encoding': 'gzip',
        'user-agent': 'okhttp/3.12.0'
    }
}).then((response) => {
    setState('0_userdata.0.iAquaLink.IdToken', JSON.stringify(response.data), true);
    console.log('Daten erfolgreich in ioBroker gespeichert.');
    // Extrahieren des idTokens
    let jsonObject = response.data;
    let idToken = jsonObject.userPoolOAuth.IdToken;
    if (idToken) {
        console.log("idToken extrahiert:", idToken);
        setState('0_userdata.0.iAquaLink.IdToken_clean', idToken, true);
        // Zweite Anfrage unter Verwendung des idTokens
        const options = {
            method: 'GET',
            url: 'https://prod.zodiac-io.com/devices/v1/JT22008430/shadow',
            headers: {
                'Host': 'prod.zodiac-io.com',
                'accept': 'application/json',
                'authorization': idToken,
                'accept-encoding': 'gzip',
                'user-agent': 'okhttp/3.12.0'
            }
        };
        return axios.request(options);
    } else {
        throw new Error("Kein idToken gefunden!");
    }
}).then(response => {
    console.log(response.data);
    setState('0_userdata.0.iAquaLink.Pooldata', response.data, true);
}).catch(error => {
    console.error('Fehler:', error);
});

// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.iAquaLink.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.iAquaLink.Pooldata_PH";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_1` extrahieren
        let sns_1 = jsonObject.state.reported.equipment.swc_0.sns_1.value;
        if (sns_1) {
            console.log("sns_1 extrahiert:", sns_1);
            // sns_1 in das neue ioBroker-Objekt speichern
            setState(targetObject, sns_1, true);
        } else {
            console.log("Kein sns_1 gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});

// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.iAquaLink.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.iAquaLink.Pooldata_ORP";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `sns_2` extrahieren
        let sns_2 = jsonObject.state.reported.equipment.swc_0.sns_2.value;
        if (sns_2) {
            console.log("sns_2 extrahiert:", sns_2);
            // sns_2 in das neue ioBroker-Objekt speichern
            setState(targetObject, sns_2, true);
        } else {
            console.log("Kein sns_2 gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});
 
// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.iAquaLink.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.iAquaLink.Pooldata_Pumpe";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `filter_pump` extrahieren
        let filter_pump = jsonObject.state.reported.equipment.swc_0.filter_pump.value;
        if (filter_pump) {
            console.log("filter_pump extrahiert:", filter_pump);
            // filter_pump in das neue ioBroker-Objekt speichern
            setState(targetObject, filter_pump, true);
        } else {
            console.log("Kein filter_pump gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});
 
// Name des Quell-Objekts im ioBroker, das den JSON-String enthält
let sourceObject = "0_userdata.0.iAquaLink.Pooldata";
// Name des Ziel-Objekts, in das das idToken gespeichert werden soll
let targetObject = "0_userdata.0.iAquaLink.Pooldata_Temp";
// JSON-String aus ioBroker-Objekt abrufen
getState(sourceObject, function (err, state) {
    if (err || !state || !state.val) {
        console.log("Fehler beim Abrufen des JSON-Strings oder Objekt ist leer.");
        return;
    }
    try {
        // JSON-String in ein Objekt konvertieren
        let jsonObject = JSON.parse(state.val);
        
        // `Water temp` extrahieren
        let Water temp = jsonObject.state.reported.equipment.swc_0.Water temp.value;
        if (Water temp) {
            console.log("Water temp extrahiert:", Water temp);
            // Water temp in das neue ioBroker-Objekt speichern
            setState(targetObject, Water temp, true);
        } else {
            console.log("Kein Water temp gefunden!");
        }
    } catch (error) {
        console.log("Fehler beim Parsen des JSON-Strings:", error);
    }
});

EDIT: das steht im ioB Log


javascript.0
2025-05-13 15:39:33.464	error	at processImmediate (node:internal/timers:485:21)

javascript.0
2025-05-13 15:39:33.464	error	at Immediate._onImmediate (/opt/iobroker/node_modules/iobroker.javascript/main.js:1732:17)

javascript.0
2025-05-13 15:39:33.464	error	at /opt/iobroker/node_modules/iobroker.javascript/main.js:2322:17

javascript.0
2025-05-13 15:39:33.464	error	at prepareScript (/opt/iobroker/node_modules/iobroker.javascript/main.js:2224:37)

javascript.0
2025-05-13 15:39:33.464	error	at createVM (/opt/iobroker/node_modules/iobroker.javascript/main.js:1956:21)

javascript.0
2025-05-13 15:39:33.464	error	at new Script (node:vm:117:7)

javascript.0
2025-05-13 15:39:33.464	error	SyntaxError: Identifier 'sourceObject' has already been declared

javascript.0
2025-05-13 15:39:33.464	error	^

javascript.0
2025-05-13 15:39:33.464	error	let sourceObject = "0_userdata.0.iAquaLink.Pooldata";

javascript.0
2025-05-13 15:39:33.464	error	script.js.Pool.iAqualink compile failed: at script.js.Pool.iAqualink:79

muss da zwischen Token und sns Abfrage eine Pause rein?

Negalein

@Hexagon

kannst du dir das noch anschaun?

@negalein sagte in Aqualink Pool Automation in iobroker integrieren:

es kommt noch immer der Error

@negalein sagte in Aqualink Pool Automation in iobroker integrieren:

muss da zwischen Token und sns Abfrage eine Pause rein?

NEWS

Aqualink Pool Automation in iobroker integrieren

Support us

748
Online

31.7k
Users

79.8k
Topics

1.3m
Posts

NEWS

Aqualink Pool Automation in iobroker integrieren

Support us

748Online

31.7kUsers

79.8kTopics

1.3mPosts

748
Online

31.7k
Users

79.8k
Topics

1.3m
Posts