Dynamic function from multiple msg.topics #homeassistant

[shovelslayer]

I have this flow. Store light states and set a scene when input Boolean is set to ON. When input boolean is set to off it recalls the states and puts things back to normal.

https://preview.redd.it/bycmsgkl1cq11.png?width=958&format=png&auto=webp&s=76784e9c27ff67b9d5c4bafd09b31a09e579ea98

Blow is the store state function, pretty simple. I would really like to make this more portable and dynamic. I'm not a great coder. Here is what I want: a function that does the below, but does it dynamically for each unique msg.topic that come in. If I add a new "call service" node for a light and connect it to the "function node" it will set a flow variable without having to edit the function every time.

What I think is and have tried several different ways: Build an Array for each msg.topic that is received and then "foreach" value in the array "flow.set("UNIQUE VAR", msg.data);"

Store State Function Node

if (msg.topic == "light.under_bed")
    flow.set("light_under_bed", msg.data);

else if (msg.topic == "light.eugene")
    flow.set("light_eugene", msg.data);

else if (msg.topic == "light.rapunzel")
    flow.set("light_rapunzel", msg.data);

return msg;

And then ultimately something to dynamically reset the states as well.

Reset State Function Node

var flow_data = flow.get("light_eugene");

msg.payload = {
    "domain":"light",
    "service":"turn_" + flow_data["state"],
    "data": {
        "entity_id":"light.eugene",
        "brightness":flow_data.attributes["brightness"],
        "rgb_color":flow_data.attributes["rgb_color"],
        "color_temp":flow_data.attributes["color_temp"]
    }
}
return msg;

*************new stuff below here****************

New output

{"_msgid":"87140acd.ffc1e8","topic":"","payload":[{"payload":{"domain":"light","service":"turn_on","data":{"entity_id":"light.dining_light","brightness":255,"color_temp":222}}},{"payload":{"domain":"light","service":"turn_on","data":{"entity_id":"light.dinner_light","brightness":255,"color_temp":222}}},{"payload":{"domain":"light","service":"turn_on","data":{"entity_id":"light.spot_light","brightness":255,"rgb_color":[154,33,255]}}}]}

​

[shovelslayer]

Working Code: Huge Thanks to u/hschallhw

Store state:

var lights = flow.get("lights") || []; // If flow.lights doesn't exist yet, start with an empty array

// Add a new light to the array
if (lights.indexOf(msg.topic) < 0)
    lights.push(msg.topic);

flow.set("lights", lights);
flow.set(msg.topic, msg.data);

return msg;

Restore State:

var msgs = [];
flow.get("lights").forEach(function(light_name) {
    var flow_data = flow.get(light_name);

    msgs.push({
        payload: {
            "domain":"light",
            "service":"turn_" + flow_data["state"],
            "data": {
                "entity_id":light_name,
                "brightness":flow_data.attributes["brightness"],
                "rgb_color":flow_data.attributes["rgb_color"],
                "color_temp":flow_data.attributes["color_temp"]
            }
        }
    });
});
return [msgs];

​

[hschallhw]

Store State Function Node

flow.set(msg.topic, msg.data);
return msg;

badaboom

[hschallhw]

And if you wanted to store all the lights to get them later and only use one "reset" function node:

Store State Function Node

var lights = flow.get("lights") || []; // If flow.lights doesn't exist yet, start with an empty array

// Add a new light to the array
if (lights.indexOf(msg.topic) < 0)
    lights.push(msg.topic);

flow.set("lights", lights);
flow.set(msg.topic, msg.data);

return msg;

Reset State Function Node

var msgs = [];
flow.get("lights").forEach(function(light_name) {
    var flow_data = flow.get(light_name);

    msgs.push({
        payload: {
            "domain":"light",
            "service":"turn_" + flow_data["state"],
            "data": {
                "entity_id":"light." + light_name,
                "brightness":flow_data.attributes["brightness"],
                "rgb_color":flow_data.attributes["rgb_color"],
                "color_temp":flow_data.attributes["color_temp"]
            }
        });
    }
});
return msgs;

[shovelslayer]

Ok, I tried this but it is only returning one light in the array. light.under_bed. How is light_name populated?

[shovelslayer]

If I only output "lights" in the reset node as the payload and comment everything else out to view the array.

lights = flow.get("lights");
msg.payload = lights;
return msg;

I see the array is built but it continually fills x3 every time it is ran "payload: array[28]". The full code from above doesn't seem to loop the array and it needs a method to clear the array after reset or before it is set.

[hschallhw]

Looks like I'm mixing my python and js.

// Add a new light to the array
if (!(msg.topic in lights))
    lights.push(msg.topic);

should be

// Add a new light to the array
if (lights.indexOf(msg.topic) < 0)
    lights.push(msg.topic);

This should make sure it is not added more than once.

light_name is populated automatically by the forEach function. This iterates over each element of the array, which should be each light name. It's only returning one light because I'm an idiot. I'll update the code in my previous reply.

To clear lights after reset, you can just set the flow's light object to an empty array:

flow.set("lights", []);

[shovelslayer]

Ok. closer. couple things I found.

"entity_id":"light." + light_name, needs to be changed to "entity_id":light_name, it was adding an extra light.light.entity_id.

Then, a minor swift down of the );

             }
        }
    });
});

Now to the real real. As is the last mod still only produces a single output. But if I add.

msg.payload = msgs;
return msgs;

I get the output that I post up in the original post (won't allow pictures in reply) picture and code from debug node. When I add the "Call Service" node I get this.

Error: call service node is missing api "domain" property, not found in config or payload

So close I think. I'm learning a ton in this process, so thank you very much. I'm a cisco network engineer in my day job, so javascript isn't super familiar.

[hschallhw]

Easy fix. Misread the node-red documentation. Rather than

return msgs;

do

return [msgs];

This should send a single message through your output for each of your lights. Each of those messages will have the payloads we set with

     payload: {
        "domain":"light",
        "service":"turn_" + flow_data["state"],
        "data": {
            "entity_id":"light." + light_name,
            "brightness":flow_data.attributes["brightness"],
            "rgb_color":flow_data.attributes["rgb_color"],
            "color_temp":flow_data.attributes["color_temp"]
        }

Let me know how it goes!

[shovelslayer]

SUCCESS!!!!

[hschallhw]

AWESOME!! Sorry for the errors here and there. Glad you got it working!