Skip to content
Snippets Groups Projects
mock-input-device.c 14.8 KiB
Newer Older
/*
 * Mock input device monitor, loosely based on SDL code.
 *
 * Copyright © 1997-2020 Sam Lantinga <slouken@libsdl.org>
 * Copyright © 2020 Collabora Ltd.
 *
 * SPDX-License-Identifier: Zlib
 *
 * This software is provided 'as-is', without any express or implied
 * warranty.  In no event will the authors be held liable for any damages
 * arising from the use of this software.
 *
 * Permission is granted to anyone to use this software for any purpose,
 * including commercial applications, and to alter it and redistribute it
 * freely, subject to the following restrictions:
 *
 * 1. The origin of this software must not be misrepresented; you must not
 *    claim that you wrote the original software. If you use this software
 *    in a product, an acknowledgment in the product documentation would be
 *    appreciated but is not required.
 * 2. Altered source versions must be plainly marked as such, and must not be
 *    misrepresented as being the original software.
 * 3. This notice may not be removed or altered from any source distribution.
 */

#include "mock-input-device.h"

#include <linux/input.h>

#include <glib-unix.h>
#include <libglnx.h>

#include "steam-runtime-tools/glib-backports-internal.h"
#include "steam-runtime-tools/input-device.h"
#include "steam-runtime-tools/input-device-internal.h"
#include "steam-runtime-tools/utils-internal.h"

#define VENDOR_VALVE 0x28de
#define PRODUCT_VALVE_STEAM_CONTROLLER 0x1142

/* These aren't in the real vendor/product IDs, but we add them here
 * to make the test able to distinguish. They look a bit like HID,
 * EVDE(v) and USB, if you squint. */
#define HID_MARKER 0x41D00000
#define EVDEV_MARKER 0xE7DE0000
#define USB_MARKER 0x05B00000

static void mock_input_device_iface_init (SrtInputDeviceInterface *iface);
static void mock_input_device_monitor_iface_init (SrtInputDeviceMonitorInterface *iface);

G_DEFINE_TYPE_WITH_CODE (MockInputDevice,
                         mock_input_device,
                         G_IMPLEMENT_INTERFACE (SRT_TYPE_INPUT_DEVICE,
                                                mock_input_device_iface_init))

G_DEFINE_TYPE_WITH_CODE (MockInputDeviceMonitor,
                         mock_input_device_monitor,
                         G_TYPE_OBJECT,
                         G_IMPLEMENT_INTERFACE (SRT_TYPE_INPUT_DEVICE_MONITOR,
                                                mock_input_device_monitor_iface_init))

static void
mock_input_device_init (MockInputDevice *self)
{
}

static void
mock_input_device_class_init (MockInputDeviceClass *cls)
{
static int
mock_input_device_open_device (SrtInputDevice *device,
                               int flags,
                               GError **error)
{
  SrtInputDeviceInterfaceFlags iface_flags;
  const char *devnode = NULL;
  int fd = -1;

  if (!_srt_input_device_check_open_flags (flags, error))
    return -1;

  iface_flags = srt_input_device_get_interface_flags (device);
  devnode = srt_input_device_get_dev_node (device);

  if (devnode == NULL)
    {
      glnx_throw (error, "Device has no device node");
      return -1;
    }

  /* We aren't really going to open the device node, so provide a somewhat
   * realistic permissions check. */
  switch (flags & (O_RDONLY | O_RDWR | O_WRONLY))
    {
      case O_RDONLY:
        if (!(iface_flags & SRT_INPUT_DEVICE_INTERFACE_FLAGS_READABLE))
          {
            g_set_error (error, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED,
                         "Device node cannot be read");
            return -1;
          }

        break;

      case O_RDWR:
      case O_WRONLY:
        if (!(iface_flags & SRT_INPUT_DEVICE_INTERFACE_FLAGS_READ_WRITE))
          {
            g_set_error (error, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED,
                         "Device node cannot be written");
            return -1;
          }

        break;

      default:
        /* _srt_input_device_check_open_flags should have caught this */
        g_return_val_if_reached (-1);
    }

  /* This is a mock device, so open /dev/null instead of the real
   * device node. */
  fd = open ("/dev/null", flags | _SRT_INPUT_DEVICE_ALWAYS_OPEN_FLAGS);

  if (fd < 0)
    {
      glnx_throw_errno_prefix (error,
                               "Unable to open device node \"%s\"",
                               devnode);
      return -1;
    }

  return fd;
}

static void
mock_input_device_iface_init (SrtInputDeviceInterface *iface)
{
#define IMPLEMENT(x) iface->x = mock_input_device_ ## x

  IMPLEMENT (open_device);

#undef IMPLEMENT
}

MockInputDevice *
mock_input_device_new (void)
{
  return g_object_new (MOCK_TYPE_INPUT_DEVICE,
                       NULL);
}

typedef enum
{
  PROP_0,
  PROP_FLAGS,
  PROP_IS_ACTIVE,
  N_PROPERTIES
} Property;

static void
mock_input_device_monitor_init (MockInputDeviceMonitor *self)
{
  self->monitor_context = g_main_context_ref_thread_default ();
  self->state = NOT_STARTED;
  self->devices = g_hash_table_new_full (NULL,
                                         NULL,
                                         g_object_unref,
                                         NULL);
}

static void
mock_input_device_monitor_get_property (GObject *object,
                                        guint prop_id,
                                        GValue *value,
                                        GParamSpec *pspec)
{
  MockInputDeviceMonitor *self = MOCK_INPUT_DEVICE_MONITOR (object);

  switch ((Property) prop_id)
    {
      case PROP_IS_ACTIVE:
        g_value_set_boolean (value, (self->state == STARTED));
        break;

      case PROP_FLAGS:
        g_value_set_flags (value, self->flags);
        break;

      case PROP_0:
      case N_PROPERTIES:
      default:
        G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
    }
}

static void
mock_input_device_monitor_set_property (GObject *object,
                                        guint prop_id,
                                        const GValue *value,
                                        GParamSpec *pspec)
{
  MockInputDeviceMonitor *self = MOCK_INPUT_DEVICE_MONITOR (object);

  switch ((Property) prop_id)
    {
      case PROP_FLAGS:
        /* Construct-only */
        g_return_if_fail (self->flags == 0);
        self->flags = g_value_get_flags (value);
        break;

      case PROP_IS_ACTIVE:
      case PROP_0:
      case N_PROPERTIES:
      default:
        G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
    }
}

static void
mock_input_device_monitor_dispose (GObject *object)
{
  srt_input_device_monitor_stop (SRT_INPUT_DEVICE_MONITOR (object));
  G_OBJECT_CLASS (mock_input_device_monitor_parent_class)->dispose (object);
}

static void
mock_input_device_monitor_finalize (GObject *object)
{
  srt_input_device_monitor_stop (SRT_INPUT_DEVICE_MONITOR (object));
  G_OBJECT_CLASS (mock_input_device_monitor_parent_class)->finalize (object);
}

static void
mock_input_device_monitor_class_init (MockInputDeviceMonitorClass *cls)
{
  GObjectClass *object_class = G_OBJECT_CLASS (cls);

  object_class->get_property = mock_input_device_monitor_get_property;
  object_class->set_property = mock_input_device_monitor_set_property;
  object_class->dispose = mock_input_device_monitor_dispose;
  object_class->finalize = mock_input_device_monitor_finalize;

  g_object_class_override_property (object_class, PROP_IS_ACTIVE, "is-active");
  g_object_class_override_property (object_class, PROP_FLAGS, "flags");
}

MockInputDeviceMonitor *
mock_input_device_monitor_new (SrtInputDeviceMonitorFlags flags)
{
  return g_object_new (MOCK_TYPE_INPUT_DEVICE_MONITOR,
                       "flags", flags,
                       NULL);
}

void
mock_input_device_monitor_add (MockInputDeviceMonitor *self,
                               MockInputDevice *device)
{
  /* Ref it first in case the last ref to it is in the hash table */
  g_autoptr(MockInputDevice) ref = g_object_ref (device);

  mock_input_device_monitor_remove (self, device);

  g_hash_table_add (self->devices, g_steal_pointer (&ref));

  _srt_input_device_monitor_emit_added (SRT_INPUT_DEVICE_MONITOR (self),
                                        SRT_INPUT_DEVICE (device));
}

void
mock_input_device_monitor_remove (MockInputDeviceMonitor *self,
                                  MockInputDevice *device)
{
  if (g_hash_table_steal (self->devices, device))
    {
      _srt_input_device_monitor_emit_removed (SRT_INPUT_DEVICE_MONITOR (self),
                                              SRT_INPUT_DEVICE (device));
      g_object_unref (device);
    }
}

static void
add_steam_controller (MockInputDeviceMonitor *self,
                      const char *tail,
  g_autoptr(MockInputDevice) mock = mock_input_device_new ();
  SrtSimpleInputDevice *device = SRT_SIMPLE_INPUT_DEVICE (mock);
  g_autoptr(GPtrArray) arr = g_ptr_array_new_full (1, g_free);
  device->iface_flags = SRT_INPUT_DEVICE_INTERFACE_FLAGS_EVENT;

  if (can_open)
    device->iface_flags |= (SRT_INPUT_DEVICE_INTERFACE_FLAGS_READABLE
                            | SRT_INPUT_DEVICE_INTERFACE_FLAGS_READ_WRITE);

  device->dev_node = g_strdup_printf ("/dev/input/event%s", tail);
  device->sys_path = g_strdup_printf ("/sys/devices/mock/usb/hid/input/input0/event%s",
                                      tail);
  device->subsystem = g_strdup ("input");
  device->uevent = g_strdup ("ONE=1\nTWO=2\n");
  device->hid_ancestor.sys_path = g_strdup ("/sys/devices/mock/usb/hid");
  device->hid_ancestor.uevent = g_strdup ("HID=yes\n");

  device->input_ancestor.sys_path = g_strdup ("/sys/devices/mock/usb/hid/input");
  device->input_ancestor.uevent = g_strdup ("INPUT=yes\n");

  device->usb_device_ancestor.sys_path = g_strdup ("/sys/devices/mock/usb");
  device->usb_device_ancestor.uevent = g_strdup ("USB=usb_device\n");

  g_ptr_array_add (arr, g_strdup ("ID_INPUT_JOYSTICK=1"));
  g_ptr_array_add (arr, NULL);
  device->udev_properties = (gchar **) g_ptr_array_free (g_steal_pointer (&arr), FALSE);

  /* This is a semi-realistic Steam Controller. */
  device->type_flags = SRT_INPUT_DEVICE_TYPE_FLAGS_JOYSTICK;
  device->bus_type = BUS_USB;
  device->vendor_id = VENDOR_VALVE;
  device->product_id = PRODUCT_VALVE_STEAM_CONTROLLER;
  device->version = 0x0111;
  /* We don't set all the bits, just enough to be vaguely realistic */
  set_bit (EV_KEY, device->evdev_caps.ev);
  set_bit (EV_ABS, device->evdev_caps.ev);
  set_bit (BTN_A, device->evdev_caps.keys);
  set_bit (BTN_B, device->evdev_caps.keys);
  set_bit (BTN_X, device->evdev_caps.keys);
  set_bit (BTN_Y, device->evdev_caps.keys);
  set_bit (ABS_X, device->evdev_caps.abs);
  set_bit (ABS_Y, device->evdev_caps.abs);
  set_bit (ABS_RX, device->evdev_caps.abs);
  set_bit (ABS_RY, device->evdev_caps.abs);
  /* This is unrealistic, but it's hard to test the properties if their
   * value is zero */
  set_bit (INPUT_PROP_POINTER, device->evdev_caps.props);

  /* The part in square brackets isn't present on the real device, but
   * makes this test more thorough by letting us distinguish. */
  device->hid_ancestor.name = g_strdup ("Valve Software Steam Controller");
  device->hid_ancestor.phys = g_strdup ("[hid]usb-0000:00:14.0-1.2/input1");
  device->hid_ancestor.uniq = g_strdup ("");
  device->hid_ancestor.bus_type = HID_MARKER | BUS_USB;
  device->hid_ancestor.vendor_id = HID_MARKER | VENDOR_VALVE;
  device->hid_ancestor.product_id = HID_MARKER | PRODUCT_VALVE_STEAM_CONTROLLER;

  device->input_ancestor.name = g_strdup ("Wireless Steam Controller");
  device->input_ancestor.phys = g_strdup ("[input]usb-0000:00:14.0-1.2/input1");
  device->input_ancestor.uniq = g_strdup ("12345678");
  device->input_ancestor.bus_type = EVDEV_MARKER | BUS_USB;
  device->input_ancestor.vendor_id = EVDEV_MARKER | VENDOR_VALVE;
  device->input_ancestor.product_id = EVDEV_MARKER | PRODUCT_VALVE_STEAM_CONTROLLER;
  device->input_ancestor.version = EVDEV_MARKER | 0x0111;

  device->usb_device_ancestor.vendor_id = USB_MARKER | VENDOR_VALVE;
  device->usb_device_ancestor.product_id = USB_MARKER | PRODUCT_VALVE_STEAM_CONTROLLER;
  device->usb_device_ancestor.device_version = USB_MARKER | 0x0001;
  device->usb_device_ancestor.manufacturer = g_strdup ("Valve Software");
  device->usb_device_ancestor.product = g_strdup ("Steam Controller");
  device->usb_device_ancestor.serial = NULL;
  mock_input_device_monitor_add (self, mock);
}

static gboolean
briefly_add_steam_controller_in_idle_cb (gpointer user_data)
{
  MockInputDeviceMonitor *self = MOCK_INPUT_DEVICE_MONITOR (user_data);
  g_autoptr(MockInputDevice) device = NULL;

  add_steam_controller (self, "-connected-briefly", FALSE, &device);
  mock_input_device_monitor_remove (self, device);
  return G_SOURCE_REMOVE;
}

static gboolean
enumerate_cb (gpointer user_data)
{
  MockInputDeviceMonitor *self = MOCK_INPUT_DEVICE_MONITOR (user_data);

  add_steam_controller (self, "0", TRUE, NULL);
  _srt_input_device_monitor_emit_all_for_now (SRT_INPUT_DEVICE_MONITOR (self));
  return G_SOURCE_REMOVE;
}

static gboolean
mock_input_device_monitor_start (SrtInputDeviceMonitor *monitor,
                                 GError **error)
{
  MockInputDeviceMonitor *self = MOCK_INPUT_DEVICE_MONITOR (monitor);

  g_return_val_if_fail (MOCK_IS_INPUT_DEVICE_MONITOR (monitor), FALSE);
  g_return_val_if_fail (self->state == NOT_STARTED, FALSE);
  g_return_val_if_fail (error == NULL || *error == NULL, FALSE);

  self->state = STARTED;

  /* Make sure the signals for the initial batch of devices are emitted in
   * the correct main-context */
  g_main_context_invoke_full (self->monitor_context, G_PRIORITY_DEFAULT,
                              enumerate_cb, g_object_ref (self),
                              g_object_unref);

  if ((self->flags & SRT_INPUT_DEVICE_MONITOR_FLAGS_ONCE) == 0)
    {
      GSource *source = g_idle_source_new ();

      g_source_set_callback (source,
                             briefly_add_steam_controller_in_idle_cb,
                             self, NULL);
      g_source_set_priority (source, G_PRIORITY_DEFAULT);
      g_source_attach (source, self->monitor_context);
      self->sources = g_list_prepend (self->sources, g_steal_pointer (&source));
    }

  return TRUE;
}

static void
mock_input_device_monitor_stop (SrtInputDeviceMonitor *monitor)
{
  MockInputDeviceMonitor *self = MOCK_INPUT_DEVICE_MONITOR (monitor);

  self->state = STOPPED;

  while (self->sources != NULL)
    {
      GSource *s = self->sources->data;

      self->sources = g_list_delete_link (self->sources, self->sources);
      g_source_destroy (s);
      g_source_unref (s);
    }

  g_clear_pointer (&self->monitor_context, g_main_context_unref);
  g_clear_pointer (&self->devices, g_hash_table_unref);
}

static void
mock_input_device_monitor_iface_init (SrtInputDeviceMonitorInterface *iface)
{
#define IMPLEMENT(x) iface->x = mock_input_device_monitor_ ## x
  IMPLEMENT (start);
  IMPLEMENT (stop);
#undef IMPLEMENT
}