mirror of
https://gitlab.freedesktop.org/pipewire/wireplumber.git
synced 2026-01-22 19:30:23 +01:00
43aa2d4952
Since all scripts run in a sandbox with their own global environment, it means that they don't interfere with each other's global variables. Therefore, all file-wide variables can be declared global without any change in behavior. In my understanding, it is better to do so because this means that any code accessing those variables is going to access them directly from the global environment table with a simple lookup rather than having each variable referenced in the local closure of each function separately.
74 lines
2 KiB
Lua
74 lines
2 KiB
Lua
-- WirePlumber
|
|
--
|
|
-- Copyright © 2021 Asymptotic
|
|
-- @author Arun Raghavan <arun@asymptotic.io>
|
|
--
|
|
-- SPDX-License-Identifier: MIT
|
|
--
|
|
-- Route streams of a given role (media.role property) to devices that are
|
|
-- intended for that role (device.intended-roles property)
|
|
|
|
metadata_om = ObjectManager {
|
|
Interest {
|
|
type = "metadata",
|
|
Constraint { "metadata.name", "=", "default" },
|
|
}
|
|
}
|
|
|
|
devices_om = ObjectManager {
|
|
Interest {
|
|
type = "node",
|
|
Constraint { "media.class", "matches", "Audio/*", type = "pw-global" },
|
|
Constraint { "device.intended-roles", "is-present", type = "pw" },
|
|
}
|
|
}
|
|
|
|
streams_om = ObjectManager {
|
|
Interest {
|
|
type = "node",
|
|
Constraint { "media.class", "matches", "Stream/*/Audio", type = "pw-global" },
|
|
Constraint { "media.role", "is-present", type = "pw-global" }
|
|
}
|
|
}
|
|
|
|
function routeUsingIntendedRole(stream, dev)
|
|
local stream_role = stream.properties["media.role"]
|
|
local is_input = stream.properties["media.class"]:find("Input") ~= nil
|
|
|
|
local is_source = dev.properties["media.class"]:find("Source") ~= nil
|
|
local dev_roles = dev.properties["device.intended-roles"]
|
|
|
|
-- Make sure the stream and device direction match
|
|
if is_input ~= is_source then
|
|
return
|
|
end
|
|
|
|
for role in dev_roles:gmatch("(%a+)") do
|
|
if role == stream_role then
|
|
Log.info(stream,
|
|
string.format("Routing stream '%s' (%d) with role '%s' to '%s' (%d)",
|
|
stream.properties["node.name"], stream["bound-id"], stream_role,
|
|
dev.properties["node.name"], dev["bound-id"])
|
|
)
|
|
|
|
local metadata = metadata_om:lookup()
|
|
metadata:set(stream["bound-id"], "target.node", "Spa:Id", dev["bound-id"])
|
|
end
|
|
end
|
|
end
|
|
|
|
streams_om:connect("object-added", function (streams_om, stream)
|
|
for dev in devices_om:iterate() do
|
|
routeUsingIntendedRole(stream, dev)
|
|
end
|
|
end)
|
|
|
|
devices_om:connect("object-added", function (devices_om, dev)
|
|
for stream in streams_om:iterate() do
|
|
routeUsingIntendedRole(stream, dev)
|
|
end
|
|
end)
|
|
|
|
metadata_om:activate()
|
|
devices_om:activate()
|
|
streams_om:activate()
|