mirror of
https://gitlab.freedesktop.org/pipewire/wireplumber.git
synced 2026-01-21 07:20:24 +01:00
5fba8af1e6
When a stream gets added, we might have a situation where the device does not yet exist to actually link on the basis of intended role. For example this can be observed if no mic sources are present and then the mic appears after a bluetooth profile switch to HFP. To fix this, iterate over streams when a device connects in addition to iterating over devices when a stream connects.
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" }
|
|
}
|
|
}
|
|
|
|
local 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()
|