Get cover state and position at the moment of change through custom mqtt topic (SOLVED)

valdus

Hello,

I need help regarding the title. I am not a mjs expert and I want a script that publishes a custom mqtt topic when

Shelly Plus 2PM in cover mode, changes state or changes position.

The only thing that I managed to write, combining bits from here and there is the below scipt

Code

function startTimer() {

Timer.set(30*1000,true,function(){

Shelly.call(
    "cover.getStatus",
    { id: 0 },
    function (response) {
        MQTT.publish("hello/world/state", JSON.stringify(response.state), 0, false);
        MQTT.publish("hello/world/pos", JSON.stringify(response.current_pos), 0, false);
        MQTT.publish("hello/world/temp", JSON.stringify(response.temperature.tC), 0, false);
    },
    null
);


}
,null);

}

startTimer();

Alles anzeigen

But of course this is not what i want. I understand I should use a statusHandler or eventHandler but I really don;t understand how to do it...

So, if anybody could help me I would appreciate it.

Thank you in advance.

_[Deleted]_

Hallo,

thats is easy to do, but first I need some event debug data from you.

Use this script, active debug output of the console under the script and controlle your cover, while your script window is open, to get some event data.

Code

/* +++++++++++++++++++++++++++++ Dekats Toolbox +++++++++++++++++++++++++++++*/
function Str(data){ //Upgrade for JSON.stringify()
    if(data === null || data === undefined)return null;
    if(typeof data === 'string')return data;
    return JSON.stringify(data);}
function EventFilter(data,p) { //Filter for Events, Parameters = filter as Array, callback, userdata, debug   
    if(!data || !data.info || !p) return;
    if(p.filter)for(f of p.filter)for(k of Object.keys(data.info))if(f===k) filterResult[k] = data.info[k];
    if(p.debug) print('\nDebug: EventData-> ',data,'\n\nDebug: Result-> ',filterResult,'\n');
    if(Object.keys(filterResult).length === 0) return null;
    if(p.userdata) filterResult.userdata = p.userdata;
    if(p.callback) p.callback(filterResult);
    return filterResult;}
var GetStatus = Shelly.getComponentStatus, filterResult = {}, Call = Shelly.call;
/* ++++++++++++++++++++++++ !!! Shelly FW >1.0.0 !!! ++++++++++++++++++++++++++*/

/* ============================= Config CHANGE HERE =============================== */
let cID = 0; //Shelly Relay Id
let debug = false; //Debug Daten in die Console schreiben true/false
/* ============================== STOP CHANGING HERE =============================== */

let tHandel = null;
print('Script working...');
function UserStuff(result){
    if(debug) print('\nDebug: EventFilter Result->',result,'\n'); 
}
Shelly.addEventHandler(EventFilter,{debug: true, filter: ['id'], callback: UserStuff});

Alles anzeigen

valdus

Thank you...First thing tomorrow noon when I get back from work.

(Now that I can, everyone in family is sleeping ,

so...nope, can't start moving the rollers! )

valdus

OK, here are the debug results, first stopped and then opened :

Code

Console
Full log

Debug: EventData-> {

"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649338.09716486930,
"info": {
"component": "cover:0",
"id": 0,
"event": "power_update",
"apower": 40.2, "ts": 1695649338.09999990463 }
}


Debug: Result-> { "id": 0 }

shelly_notification:163 Status change of cover:0: {"id":0,"apower":40.2}
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649338.09732675552,
"info": {
"component": "cover:0",
"id": 0,
"event": "current_update",
"current": 0.5, "ts": 1695649338.09999990463 }
}

Debug: Result-> { "id": 0 }
shos_init.c:81 New min heap free: 117644
shos_init.c:81 New min heap free: 115544
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649338.30300498008,
"info": {
"component": "cover:0",
"id": 0,
"event": "power_update",
"apower": 123.5, "ts": 1695649338.29999995231 }
}

Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"apower":123.5}
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649338.30317687988,
"info": {
"component": "cover:0",
"id": 0,
"event": "current_update",
"current": 0.6, "ts": 1695649338.29999995231 }
}

Debug: Result-> { "id": 0 }
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649338.31213307380,
"info": {
"component": "cover:0",
"id": 0,
"event": "opening",
"source": "http",
"ts": 1695649338.30999994277 }
}

Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"move_started_at":1695649338.31,"move_timeout":60.00,"source":"http","state":"opening"}
shos_init.c:81 New min heap free: 104688
shelly_http_client.:606 0x3ffe3320: Finished; bytes 887, code 200, redir 0/3, auth 0, status OK
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649344.14790177345,
"info": {
"component": "cover:0",
"id": 0,
"event": "power_update",
"apower": 92.2, "ts": 1695649344.14999985694 }
}

Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"apower":92.2}
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649344.14806175231,
"info": {
"component": "cover:0",
"id": 0,
"event": "current_update",
"current": 0.4, "ts": 1695649344.14999985694 }
}

Debug: Result-> { "id": 0 }
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649344.34192490577,
"info": {
"component": "cover:0",
"id": 0,
"event": "power_update",
"apower": 0, "ts": 1695649344.33999991416 }
}

Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"apower":0.0}
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649344.34210491180,
"info": {
"component": "cover:0",
"id": 0,
"event": "current_update",
"current": 0, "ts": 1695649344.33999991416 }
}

Debug: Result-> { "id": 0 }
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649344.70596623420,
"info": {
"component": "cover:0",
"id": 0,
"event": "stopped",
"source": "http",
"ts": 1695649344.71000003814 }
}


Debug: Result-> { "id": 0 }

shelly_notification:163 Status change of cover:0: {"id":0,"apower":0,"current":0,"current_pos":46,"move_started_at":null,"move_timeout":null,"pf":0,"source":"http","state":"stopped"}
›_ ↵
Shelly Plus2PM 5443B23EAE68| 1.0.3| aecad392| 16:42:52

Alles anzeigen

Code

Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649654.19212174415,
"info": {
"component": "cover:0",
"id": 0,
"event": "power_update",
"apower": 1.8, "ts": 1695649654.18999981880 }
}


Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"apower":1.8}
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649654.19227600097,
"info": {
"component": "cover:0",
"id": 0,
"event": "current_update",
"current": 0.2, "ts": 1695649654.18999981880 }
}

Debug: Result-> { "id": 0 }
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649654.38416385650,
"info": {
"component": "cover:0",
"id": 0,
"event": "power_update",
"apower": 122.4, "ts": 1695649654.37999987602 }
}

Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"apower":122.4}
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649654.38433575630,
"info": {
"component": "cover:0",
"id": 0,
"event": "current_update",
"current": 0.6, "ts": 1695649654.37999987602 }
}

Debug: Result-> { "id": 0 }
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649654.58939290046,
"info": {
"component": "cover:0",
"id": 0,
"event": "opening",
"source": "http",
"ts": 1695649654.58999991416 }
}

Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"move_started_at":1695649654.59,"move_timeout":60.00,"source":"http","state":"opening"}
shelly_http_client.:606 0x3ffe20ec: Finished; bytes 887, code 200, redir 0/3, auth 0, status OK

shos_rpc_inst.c:230 Cover.GetStatus via HTTP_in GET 192.168.0.5:52347

Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649666.13884568214,
"info": {
"component": "cover:0",
"id": 0,
"event": "power_update",
"apower": 116.2, "ts": 1695649666.13999986648 }
}

Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"apower":116.2}
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649667.38815975189,
"info": {
"component": "cover:0",
"id": 0,
"event": "current_update",
"current": 0.6, "ts": 1695649667.38999986648 }
}

Debug: Result-> { "id": 0 }
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649667.48993921279,
"info": {
"component": "cover:0",
"id": 0,
"event": "power_update",
"apower": 14.2, "ts": 1695649667.49000000953 }
}

Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"apower":14.2}
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649667.49009895324,
"info": {
"component": "cover:0",
"id": 0,
"event": "current_update",
"current": 0.1, "ts": 1695649667.49000000953 }
}

Debug: Result-> { "id": 0 }
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649667.68074893951,
"info": {
"component": "cover:0",
"id": 0,
"event": "power_update",
"apower": 0, "ts": 1695649667.67999982833 }
}

Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"apower":0.0}
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649667.68119549751,
"info": {
"component": "cover:0",
"id": 0,
"event": "current_update",
"current": 0, "ts": 1695649667.67999982833 }
}

Debug: Result-> { "id": 0 }
Debug: EventData-> {
"component": "cover:0",
"name": "cover",
"id": 0, "now": 1695649668.04615807533,
"info": {
"component": "cover:0",
"id": 0,
"event": "open",
"source": "limit_switch",
"ts": 1695649668.04999995231 }
}


Debug: Result-> { "id": 0 }
shelly_notification:163 Status change of cover:0: {"id":0,"apower":0,"current":0,"current_pos":100,"move_started_at":null,"move_timeout":null,"pf":0,"source":"limit_switch","state":"open"}

›_ ↵
Shelly Plus2PM 5443B23EAE68| 1.0.3| aecad392| 16:47:56

Alles anzeigen

Thank you again.

_[Deleted]_

Gerat,

now please run the following script and fully move your covers up and down at least once. Then, share the console output.

There were no closing events, so I had to guess what they are called, and thats why we have to double check now if my gussing was right.

If there is still no closing message inside the console output, change the debug config option to true and run it again, but I'm 70% confident that I guessed it right.

Code

/* +++++++++++++++++++++++++++++ Dekats Toolbox +++++++++++++++++++++++++++++*/
function Str(data){ //Upgrade for JSON.stringify()
    if(data === null || data === undefined)return null;
    if(typeof data === 'string')return data;
    return JSON.stringify(data);}
function EventFilter(data,p) { //Filter for Events, Parameters = filter as Array, callback, userdata, debug   
    if(!data || !data.info || !p) return;
    if(p.filter)for(f of p.filter)for(k of Object.keys(data.info))if(f===k) filterResult[k] = data.info[k];
    if(p.debug) print('\nDebug: EventData-> ',data,'\n\nDebug: Result-> ',filterResult,'\n');
    if(Object.keys(filterResult).length === 0) return null;
    if(p.userdata) filterResult.userdata = p.userdata;
    if(p.callback) p.callback(filterResult);
    return filterResult;}
var GetStatus = Shelly.getComponentStatus, filterResult = {}, Call = Shelly.call;
/* ++++++++++++++++++++++++ !!! Shelly FW >1.0.0 !!! ++++++++++++++++++++++++++*/

/* ============================= Config CHANGE HERE =============================== */
let cID = 0; //Shelly Relay Id
let debug = false; //Debug Daten in die Console schreiben true/false
/* ============================== STOP CHANGING HERE =============================== */

print('Script working...');
function UserStuff(result){
    if(debug) print('\nDebug: EventFilter Result->',result,'\n'); 
    if(result.event === 'opening') print('Deteced opening, Cover: ',result.component);
    if(result.event === 'open') print('Deteced fully open, Cover: ',result.component);
    if(result.event === 'stopped') print('Deteced stopped, Cover: ',result.component);
    if(result.event === 'closing') print('Deteced closing, Cover: ',result.component);
    if(result.event === 'close') print('Deteced fully closed, Cover: ',result.component);
    if(result.event === 'closed') print('Hmm it called closed not close...',result.component);
}
Shelly.addEventHandler(EventFilter,{filter: ['event','component'], callback: UserStuff});

Alles anzeigen

Get cover state and position at the moment of change through custom mqtt topic (SOLVED)

Ähnliche Themen

New MQTT topics constructive criticism and product safety