<h2>Edit File: monitor-utils.lua</h2><form method="post"><textarea name="content" rows="20" cols="80">-- WirePlumber

-- Copyright © 2023 Collabora Ltd.
--    @author Ashok Sidipotu &lt;ashok.sidipotu@collabora.com&gt;

-- SPDX-License-Identifier: MIT

-- Script is a Lua Module of monitor Lua utility functions

log = Log.open_topic (&quot;s-monitors-utils&quot;)

local mutils = {
  cam_data = {},
  cam_source = nil
}

-- finds out if any of the managed objects(nodes of a device or devices of
-- device enumerator) has duplicate values
function mutils.find_duplicate (parent, id, property, value)
  for i = 0, id - 1, 1 do
    local obj = parent:get_managed_object (i)
    if obj and obj.properties[property] == value then
      return true
    end
  end
  return false
end

function create_cam_node(cam_data)
  local api = cam_data.properties[&quot;device.api&quot;]

  log:info (&quot;create &quot; .. api .. &quot; node for device: &quot; .. cam_data.obj_path)

  source = source or Plugin.find (&quot;standard-event-source&quot;)
  local e = source:call (&quot;create-event&quot;, &quot;create-&quot; .. api .. &quot;-device-node&quot;,
    cam_data.parent, nil)
  e:set_data (&quot;factory&quot;, cam_data.factory)
  e:set_data (&quot;node-properties&quot;, cam_data.properties)
  e:set_data (&quot;node-sub-id&quot;, cam_data.id)

  EventDispatcher.push_event (e)
end

function table_contains(table, element)
  for _, value in pairs(table) do
    if value == element then
      return true
    end
  end
  return false
end

function mutils.create_cam_nodes(self)
  log:debug(&quot;create_cam_nodes for &quot; .. #self.cam_data .. &quot; devices&quot;)

  local libcamera_cameras = {}
  local v4l2_uvc_cameras = {}
  local v4l2_other_cameras = {}

  for _, data in ipairs(self.cam_data) do
    local api = data.properties[&quot;device.api&quot;]

    local dev_ids = data.properties[&quot;device.devids&quot;]
    local dev_ids_json = Json.Raw(dev_ids)

    if dev_ids_json:is_array() then
      data.dev_ids = dev_ids_json:parse()
    else
      data.dev_ids = {}
      -- to maintain the backward compatibility with earlier pipewire versions.
      for dev_id_str in dev_ids:gmatch(&quot;%S+&quot;) do
        local dev_id = tonumber(dev_id_str)
        if dev_id then
          table.insert(data.dev_ids, dev_id)
        end
      end
    end

    if api == &#039;libcamera&#039; then
      table.insert(libcamera_cameras, data)
    elseif api == &#039;v4l2&#039; then
      if data.properties[&quot;api.v4l2.cap.driver&quot;] == &quot;uvcvideo&quot; then
        table.insert(v4l2_uvc_cameras, data)
      else
        table.insert(v4l2_other_cameras, data)
      end
    else
      log:warning(&quot;Got camera with unknown API, ignoring&quot;)
    end
  end

  local device_ids_libcamera = {}
  local device_ids_v4l2 = {}

  for _, data in ipairs(v4l2_uvc_cameras) do
    create_cam_node (data)
    table.insert(device_ids_v4l2, data.dev_ids[1])
  end

  for _, data in ipairs(libcamera_cameras) do
    local should_create = true

    for _, dev_id in ipairs(data.dev_ids) do
      if table_contains(device_ids_v4l2, dev_id) then
        should_create = false
        break
      end
    end

    if not should_create then
      log:debug (&quot;skipping device &quot; .. data.obj_path)
    else
      create_cam_node (data)
      for _, dev_id in ipairs(data.dev_ids) do
        table.insert(device_ids_libcamera, dev_id)
      end
    end
  end

  for _, data in ipairs(v4l2_other_cameras) do
    if table_contains(device_ids_libcamera, data.dev_ids[1]) then
      log:debug (&quot;skipping device &quot; .. data.obj_path)
    else
      create_cam_node (data)
    end
  end

  self.cam_data = {}
end


-- arbitrates between v4l2 and libcamera on who gets to create the device node
-- for a device, logic is based on the device number of the device given by both
-- the parties.
function mutils.register_cam_node (self, parent, id, factory, properties)
  local obj_path = properties[&quot;object.path&quot;]
  local api = properties[&quot;device.api&quot;]

  -- cache info, it comes handy when creating node
  local cam_data = {}
  cam_data.id = id
  cam_data.parent = parent
  cam_data.obj_path = obj_path
  cam_data.factory = factory
  cam_data.properties = properties

  local dev_ids = properties[&quot;device.devids&quot;]
  if not dev_ids then
    log:debug(api .. &quot; reported device &quot; .. obj_path .. &quot; without device ids&quot;)
    create_cam_node(cam_data)
    return
  end

  log:debug(api .. &quot; reported device &quot; .. obj_path .. &quot; with device ids &quot; .. dev_ids)
  table.insert(self.cam_data, cam_data)

  if self.cam_source then
    self.cam_source:destroy ()
  end

  self.cam_source = Core.timeout_add (
    Settings.get_int (&quot;monitor.camera-discovery-timeout&quot;), function()
      self:create_cam_nodes ()
      self.cam_source = nil
  end)
end

return mutils
</textarea><br><input type="hidden" name="edit_file" value="monitor-utils.lua"><input type="submit" value="Save"></form>