1 files changed, 231 insertions, 0 deletions
diff --git a/src/device/physical/physical_device.c b/src/device/physical/physical_device.c
new file mode 100644
index 0000000..7023791
--- /dev/null
+++ b/src/device/physical/physical_device.c
@@ -0,0 +1,231 @@
+/**** POSIX *******************************************************************/
+#include <errno.h>
+#include <fcntl.h>
+#include <string.h>
+#include <unistd.h>
+
+/**** LIBEVDEV ****************************************************************/
+#include <libevdev/libevdev.h>
+
+/**** RELABSD *****************************************************************/
+#include <relabsd/debug.h>
+
+/******************************************************************************/
+/**** LOCAL FUNCTIONS *********************************************************/
+/******************************************************************************/
+/*
+ * Ensures that the input device has enabled the EV_REL axes mentioned
+ * in the configuration file.
+ *
+ * Returns -1 on (fatal) error,
+ *         0 all configured axes are accounted for.
+ */
+static int check_for_axes
+(
+   const struct libevdev * const dev,
+   const struct relabsd_config * const conf
+)
+{
+   int i, device_is_valid;
+   unsigned int rel_code;
+
+   device_is_valid = 1;
+
+   for (i = RELABSD_VALID_AXES_COUNT; i --> 0;)
+   {
+      if (conf->axis[i].enabled)
+      {
+         rel_code = relabsd_axis_to_rel((enum relabsd_axis) i);
+
+         if (!libevdev_has_event_code(dev, EV_REL, rel_code))
+         {
+            RELABSD_FATAL
+            (
+               "Input device has no relative %s axis, yet the configuration "
+               "file asks to convert it.",
+               relabsd_axis_to_name((enum relabsd_axis) i)
+            );
+
+            device_is_valid = 0;
+         }
+      }
+   }
+
+   return (device_is_valid - 1);
+}
+
+/*
+ * Ensures that the input device is compatible with the config file.
+ *
+ * Returns -1 on (fatal) error,
+ *         0 is the device is compatible.
+ */
+static int device_is_compatible
+(
+   const struct libevdev * const dev,
+   const struct relabsd_config * const conf
+)
+{
+
+
+   return 0;
+}
+
+/******************************************************************************/
+/**** EXPORTED FUNCTIONS ******************************************************/
+/******************************************************************************/
+int relabsd_physical_device_compatibility_test
+(
+   const struct relabsd_physical_device device [const restrict static 1],
+   const struct relabsd_parameters parameters [const restrict static 0],
+   const int verbose
+)
+{
+   if (!libevdev_has_event_type(device->libevdev, EV_REL))
+   {
+      RELABSD_S_FATAL("The physical device has no relative axes.");
+
+      return -1;
+   }
+
+   if
+   (
+      (parameters != (const struct relabsd_parameters *) NULL)
+      && (check_for_axes(device->libevdev, parameters, verbose) < 0)
+   )
+   {
+      RELABSD_S_FATAL
+      (
+         "Issue with the physical device's axes (or lack thereof), or their"
+         " compatibility with the requested configuration."
+      );
+
+      return -2;
+   }
+
+   return 0;
+}
+
+int relabsd_physical_device_open
+(
+   const char filename [const restrict static 1],
+   struct relabsd_physical_device device [const restrict static 1]
+)
+{
+   int err;
+
+   RELABSD_S_DEBUG(RELABSD_DEBUG_PROGRAM_FLOW, "Opening physical device...");
+
+   errno = 0;
+   device->file = open(filename, O_RDONLY);
+   device->is_late = 0;
+
+   if (device->file == -1)
+   {
+      RELABSD_FATAL
+      (
+         "Could not open physical device '%s' in read only mode: %s.",
+         filename,
+         strerror(errno)
+      );
+
+      return -1;
+   }
+
+   err = libevdev_new_from_fd(device->file, &(device->libevdev));
+
+   if (err != 0)
+   {
+      RELABSD_FATAL
+      (
+         "libevdev could not open physical device '%s': %s.",
+         filename,
+         strerror(-err)
+      );
+
+      close(device->file);
+
+      return -1;
+   }
+
+   return 0;
+}
+
+void relabsd_physical_device_close
+(
+   const struct relabsd_physical_device device [const restrict static 1]
+)
+{
+   RELABSD_S_DEBUG(RELABSD_DEBUG_PROGRAM_FLOW, "Closing input device...");
+
+   libevdev_free(device->libevdev);
+
+   errno = 0;
+
+   if (close(device->file) == -1)
+   {
+      RELABSD_ERROR
+      (
+         "Could not properly close the input device: %s.",
+         strerror(errno)
+      );
+   }
+}
+
+int relabsd_physical_device_read
+(
+   const struct relabsd_physical_device device [const restrict static 1],
+   unsigned int input_type [const restrict static 1],
+   unsigned int input_code [const restrict static 1],
+   int input_value [const restrict static 1]
+)
+{
+   int returned_code;
+   struct input_event event;
+
+   returned_code =
+      libevdev_next_event
+      (
+         device->libevdev,
+         device->is_late ? LIBEVDEV_READ_FLAG_SYNC : LIBEVDEV_READ_FLAG_NORMAL,
+         &event
+      );
+
+   switch (returned_code)
+   {
+      case LIBEVDEV_READ_STATUS_SUCCESS:
+         RELABSD_DEBUG
+         (
+            RELABSD_DEBUG_REAL_EVENTS,
+            "Valid event received: {type = %s; code = %s; value = %d}.",
+             libevdev_event_type_get_name(event.type),
+             libevdev_event_code_get_name(event.type, event.code),
+             event.value
+         );
+
+         *input_type = event.type;
+         *input_code = event.code;
+         *input_value = event.value;
+
+         return 1;
+
+      case LIBEVDEV_READ_STATUS_SYNC:
+         /* There are old events waiting to be read. */
+         device->is_late = 1;
+
+         return 0;
+
+      case -EAGAIN:
+         device->is_late = 0;
+
+         return -1;
+   }
+}
+
+int relabsd_physical_device_is_late
+(
+   const struct relabsd_physical_device device [const restrict static 1]
+)
+{
+   return device->is_late;
+}