generichid.c

/*
 *
 *  BlueZ - Bluetooth protocol stack for Linux
 *
 *  Copyright (C) 2006-2007  Nokia Corporation
 *  Copyright (C) 2004-2009  Marcel Holtmann <marcel@holtmann.org>
 *
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 *
 */

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <uinput.h>
#include <fcntl.h>

#include <bluetooth/bluetooth.h>
#include <bluetooth/hci.h>
#include <bluetooth/hci_lib.h>
#include <bluetooth/sdp.h>
#include <bluetooth/sdp_lib.h>

#include <gdbus.h>
#include <glib.h>
#include <dbus/dbus.h>

#include "dbus-common.h"
#include "plugin.h"
#include "adapter.h"
#include "error.h"
#include "log.h"
#include "glib-helper.h"
#include "btio.h"
#include "device.h"
#include "sdpd.h"

#include "../src/device.h"

#define GENERIC_HID_INTERFACE "org.bluez.GenericHID"
#define GENERIC_HID_DEVICE    "org.bluez.GenericHIDDevice"
#define GENERIC_INPUT_DEVICE  "org.bluez.GenericHIDInput"

#define L2CAP_UUID_STR	"00000100-0000-1000-8000-00805f9b34fb"

#define KEYB_MAJOR	0x25
#define KEYB_MINOR	0x40

#define HIDP_KEYB_SIZE	10

typedef int (*func_ptr)();

static GSList *adapters = NULL;

static DBusConnection *connection;

static const unsigned char keycode2hidp[256] = {
		0, 41, 30, 31, 32, 33, 34, 35, 36,
		37, 38, 39, 45, 46, 42, 43, 20,
		26, 8, 21, 23, 28, 24, 12, 18, 19,
		47, 48, 40, 224, 4, 22, 7, 9, 10, 11,
		13, 14, 15, 51, 52, 53, 225, 49, 29,
		27, 6, 25, 5, 17, 16, 54, 55, 56, 229,
		85, 226, 44, 57, 58, 59, 60, 61, 62,
		63, 64, 65, 66, 67, 83, 71, 95, 96, 97,
		86, 92, 93, 94, 87, 89, 90, 91, 98, 99,
		0, 148, 100, 68, 69, 135, 146, 147, 138,
		136, 139, 140, 88, 228, 84, 70, 230, 0,
		74, 82, 75, 80, 79, 77, 81, 78, 73, 76,
		0, 127, 129, 128, 102, 103, 0, 72, 0,
		133, 144, 145, 137, 227, 231, 101, 120,
		121, 118, 122, 119, 124, 116, 125, 126,
		123, 117, 0, 251, 0, 248, 0, 0, 0, 0, 0,
		0, 0, 240, 0, 249, 0, 0, 0, 0, 0, 241,
		242, 0, 236, 0, 235, 232, 234, 233, 0, 0,
		0, 0, 0, 0, 250, 0, 0, 247, 245, 246, 0,
		0, 0, 0, 104, 105, 106, 107, 108, 109,
		110, 111, 112, 113, 114, 115, 0, 0, 0, 0,
		0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
		0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
		0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
		0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0
		};

struct keyboard_state {
	unsigned char value[HIDP_KEYB_SIZE];
	unsigned char last_value;
};

struct mouse_state {
	unsigned char is_moving;
	unsigned char button;
	signed char x_axis;
	signed char y_axis;
	signed char wheel;
};

struct device_data {
	GIOChannel *ctrl;
	GIOChannel *intr;
	bdaddr_t dst;
	unsigned int intr_watch;
	char *input_path;
	struct keyboard_state keyboard;
	struct mouse_state mouse;
};

struct adapter_data {
	struct btd_adapter *adapter;
	struct device_data *dev;
	uint32_t sdp_record_handle;
	GIOChannel *listen_ctrl;
	GIOChannel *listen_intr;
	int pending;
	char active;
	uint32_t original_cod;
};

struct user_data {
	struct adapter_data *adapt;
	func_ptr func;
};


static void add_lang_attr(sdp_record_t *r)
{
	sdp_lang_attr_t base_lang;
	sdp_list_t *langs = 0;

	/* UTF-8 MIBenum (http://www.iana.org/assignments/character-sets) */
	base_lang.code_ISO639 = (0x65 << 8) | 0x6e;
	base_lang.encoding = 106;
	base_lang.base_offset = SDP_PRIMARY_LANG_BASE;
	langs = sdp_list_append(0, &base_lang);
	sdp_set_lang_attr(r, langs);
	sdp_list_free(langs, 0);
}

static int sdp_keyboard_service(struct adapter_data *adapt)
{
	bdaddr_t src;
	sdp_record_t *record;
	sdp_list_t *svclass_id, *pfseq, *apseq, *root;
	uuid_t root_uuid, hidkb_uuid, l2cap_uuid, hidp_uuid;
	sdp_profile_desc_t profile[1];
	sdp_list_t *aproto, *proto[3];
	sdp_data_t *psm, *lang_lst, *lang_lst2, *hid_spec_lst, *hid_spec_lst2;
	unsigned int i;
	uint8_t dtd = SDP_UINT16;
	uint8_t dtd2 = SDP_UINT8;
	uint8_t dtd_data = SDP_TEXT_STR8;
	void *dtds[2];
	void *values[2];
	void *dtds2[2];
	void *values2[2];
	int leng[2];
	uint8_t hid_spec_type = 0x22;
	uint16_t hid_attr_lang[] = { 0x409, 0x100 };
	static const uint16_t ctrl = 0x11;
	static const uint16_t intr = 0x13;
	static const uint16_t hid_attr[] = { 0x100, 0x111, 0x40,
						0x0d, 0x01, 0x01 };
	static const uint16_t hid_attr2[] = { 0x0, 0x01, 0x100,
						0x1f40, 0x01, 0x01 };
	const uint8_t hid_spec[] = {
		0x05, 0x01, /*	Usage Page (Generic Desktop)		*/
		0x09, 0x06, /*	Usage (Keyboard)			*/
		0xA1, 0x01, /*	Collection (Application)		*/
		0x85, 0x01, /*	Report ID				*/
		0x05, 0x07, /*	Usage (Key codes)			*/
		0x19, 0xE0, /*	Usage Minimum (224)			*/
		0x29, 0xE7, /*	Usage Maximum (231)			*/
		0x15, 0x00, /*	Logical Minimum (0)			*/
		0x25, 0x01, /*	Logical Maximum (1)			*/
		0x75, 0x01, /*	Report Size (1)				*/
		0x95, 0x08, /*	Report Count (8)			*/
		0x81, 0x02, /*	Input (Data, Variable, Absolute)	*/
		0x95, 0x01, /*	Report Count (1)			*/
		0x75, 0x08, /*	Report Size (8)				*/
		0x81, 0x01, /*	Input (Constant)    ;5 bit padding	*/
		0x95, 0x05, /*	Report Count (5)			*/
		0x75, 0x01, /*	Report Size (1)				*/
		0x05, 0x08, /*	Usage Page (Page# for LEDs)		*/
		0x19, 0x01, /*	Usage Minimum (01)			*/
		0x29, 0x05, /*	Usage Maximum (05)			*/
		0x91, 0x02, /*	Output (Data, Variable, Absolute)	*/
		0x95, 0x01, /*	Report Count (1)			*/
		0x75, 0x03, /*	Report Size (3)				*/
		0x91, 0x01, /*	Output (Constant)			*/
		0x95, 0x06, /*	Report Count (1)			*/
		0x75, 0x08, /*	Report Size (3)				*/
		0x15, 0x00, /*	Logical Minimum (0)			*/
		0x25, 0x65, /*	Logical Maximum (101)			*/
		0x05, 0x07, /*	Usage (Key codes)			*/
		0x19, 0x00, /*	Usage Minimum (00)			*/
		0x29, 0x65, /*	Usage Maximum (101)			*/
		0x81, 0x00, /*	Input (Data, Array)			*/
		0xC0,
		0x09, 0x02, /* mouse part starts here */
		0xa1, 0x01,
		0x09, 0x01,
		0xa1, 0x00,
		0x85, 0x02,
		0x05, 0x09,
		0x19, 0x01,
		0x29, 0x05,
		0x15, 0x00,
		0x25, 0x01,
		0x95, 0x05,
		0x75, 0x01,
		0x81, 0x02,
		0x95, 0x01,
		0x75, 0x03,
		0x81, 0x01,
		0x05, 0x01,
		0x09, 0x30,
		0x09, 0x31,
		0x09, 0x38,
		0x15, 0x81,
		0x25, 0x7f,
		0x75, 0x08,
		0x95, 0x03,
		0x81, 0x06,
		0x05, 0x0c,
		0x0a, 0x38, 0x02,
		0x15, 0x81,
		0x25, 0x7f,
		0x75, 0x08,
		0x95, 0x01,
		0x81, 0x06,
		0xc0,
		0xc0
	};

	record = sdp_record_alloc();
	memset(record, 0, sizeof(sdp_record_t));
	record->handle = 0xffffffff;
	bacpy(&src, BDADDR_ANY);

	sdp_uuid16_create(&root_uuid, PUBLIC_BROWSE_GROUP);
	root = sdp_list_append(0, &root_uuid);
	sdp_set_browse_groups(record, root);

	add_lang_attr(record);

	sdp_uuid16_create(&hidkb_uuid, HID_SVCLASS_ID);
	svclass_id = sdp_list_append(0, &hidkb_uuid);
	sdp_set_service_classes(record, svclass_id);

	sdp_uuid16_create(&profile[0].uuid, HID_PROFILE_ID);
	profile[0].version = 0x0100;
	pfseq = sdp_list_append(0, profile);
	sdp_set_profile_descs(record, pfseq);

	/* protocols */
	sdp_uuid16_create(&l2cap_uuid, L2CAP_UUID);
	proto[1] = sdp_list_append(0, &l2cap_uuid);
	psm = sdp_data_alloc(SDP_UINT16, &ctrl);
	proto[1] = sdp_list_append(proto[1], psm);
	apseq = sdp_list_append(0, proto[1]);

	sdp_uuid16_create(&hidp_uuid, HIDP_UUID);
	proto[2] = sdp_list_append(0, &hidp_uuid);
	apseq = sdp_list_append(apseq, proto[2]);

	aproto = sdp_list_append(0, apseq);
	sdp_set_access_protos(record, aproto);

	sdp_list_free(root, 0);
	sdp_list_free(aproto, 0);
	sdp_list_free(apseq, 0);
	sdp_list_free(proto[1], 0);
	sdp_list_free(proto[2], 0);
	sdp_data_free(psm);

	/* additional protocols */
	proto[1] = sdp_list_append(0, &l2cap_uuid);
	psm = sdp_data_alloc(SDP_UINT16, &intr);
	proto[1] = sdp_list_append(proto[1], psm);
	apseq = sdp_list_append(0, proto[1]);

	sdp_uuid16_create(&hidp_uuid, HIDP_UUID);
	proto[2] = sdp_list_append(0, &hidp_uuid);
	apseq = sdp_list_append(apseq, proto[2]);

	aproto = sdp_list_append(0, apseq);
	sdp_set_add_access_protos(record, aproto);

	sdp_list_free(svclass_id, 0);
	sdp_list_free(proto[1], 0);
	sdp_list_free(proto[2], 0);
	sdp_list_free(pfseq, 0);
	sdp_list_free(apseq, 0);
	sdp_list_free(aproto, 0);
	sdp_data_free(psm);

	sdp_set_info_attr(record, "HID Keyboard", NULL, NULL);

	for (i = 0; i < sizeof(hid_attr) / 2; i++)
		sdp_attr_add_new(record,
					SDP_ATTR_HID_DEVICE_RELEASE_NUMBER + i,
					SDP_UINT16, &hid_attr[i]);

	dtds[0] = &dtd2;
	values[0] = &hid_spec_type;
	dtds[1] = &dtd_data;
	values[1] = (uint8_t *) hid_spec;
	leng[0] = 0;
	leng[1] = sizeof(hid_spec);
	hid_spec_lst = sdp_seq_alloc_with_length(dtds, values, leng, 2);
	hid_spec_lst2 = sdp_data_alloc(SDP_SEQ8, hid_spec_lst);
	sdp_attr_add(record, SDP_ATTR_HID_DESCRIPTOR_LIST, hid_spec_lst2);

	for (i = 0; i < sizeof(hid_attr_lang) / 2; i++) {
		dtds2[i] = &dtd;
		values2[i] = &hid_attr_lang[i];
	}

	lang_lst = sdp_seq_alloc(dtds2, values2, sizeof(hid_attr_lang) / 2);
	lang_lst2 = sdp_data_alloc(SDP_SEQ8, lang_lst);
	sdp_attr_add(record, SDP_ATTR_HID_LANG_ID_BASE_LIST, lang_lst2);

	sdp_attr_add_new(record, SDP_ATTR_HID_SDP_DISABLE,
				SDP_UINT16, &hid_attr2[0]);

	for (i = 0; i < sizeof(hid_attr2) / 2 - 1; i++)
		sdp_attr_add_new(record, SDP_ATTR_HID_REMOTE_WAKEUP + i,
						SDP_UINT16, &hid_attr2[i + 1]);

	if (add_record_to_server(&src, record) < 0)
		return -1;

	adapt->sdp_record_handle = record->handle;

	btd_debug("HID service registered with record handle %x", record->handle);

	return 0;
}

static inline DBusMessage *invalid_mouse_action(DBusMessage *msg)
{
	return g_dbus_create_error(msg, ERROR_INTERFACE ".InvalidMouseAction",
					"Invalid mouse action");
}

static inline DBusMessage *invalid_mode(DBusMessage *msg)
{
	return g_dbus_create_error(msg, ERROR_INTERFACE ".InvalidMode",
					"Invalid profile mode");
}

static inline DBusMessage *connection_error(DBusMessage *msg)
{
	return g_dbus_create_error(msg, ERROR_INTERFACE ".ConnectionError",
					"Connection error");
}

static inline DBusMessage *pending_connection(DBusMessage *msg)
{
	return g_dbus_create_error(msg, ERROR_INTERFACE ".PendingConnection",
					"Pending Connection");
}

static inline DBusMessage *connection_active(DBusMessage *msg)
{
	return g_dbus_create_error(msg, ERROR_INTERFACE ".ConnectionActive",
					"Connection still active");
}

static inline DBusMessage *device_not_released(DBusMessage *msg)
{
	return g_dbus_create_error(msg, ERROR_INTERFACE ".DeviceNotReleased",
					"Device not released");
}

static inline DBusMessage *not_implemented(DBusMessage *msg)
{
	return g_dbus_create_error(msg, ERROR_INTERFACE ".NotImplemented",
					"Not Implemented (yet)");
}

static inline DBusMessage *plug_failed(DBusMessage *msg)
{
	return g_dbus_create_error(msg, ERROR_INTERFACE ".PlugFailed",
					"Failed to plug the device");
}

static inline DBusMessage *not_enough_memory(DBusMessage *msg)
{
	return g_dbus_create_error(msg, ERROR_INTERFACE ".NotEnoughMemory",
					"Not enough memory");
}

static int mouse_action(GIOChannel *chan, unsigned char btn,
				unsigned char mov_x, unsigned char mov_y,
				unsigned char wheel, unsigned char h_wheel)
{
	unsigned char data[7];
	int err;
	int fd;

	data[0] = 0xa1;
	data[1] = 0x02;
	data[2] = btn;
	data[3] = mov_x;
	data[4] = mov_y;
	data[5] = wheel;
	data[6] = h_wheel;

	if (chan == NULL)
		return -EINVAL;

	fd = g_io_channel_unix_get_fd(chan);

	err = write(fd, data, 7);
	if (err < 0)
		return -EIO;

	return err;
}

static void initiate_mouse(struct mouse_state *mouse)
{
	memset(mouse, 0, sizeof(struct mouse_state));
}

static DBusMessage *mouse_button_action(GIOChannel *chan, DBusMessage *msg,
		struct mouse_state *mouse, unsigned char button, char value)
{
	if (!value) {
		mouse->button &= ~button;

		if (mouse_action(chan, mouse->button, 0, 0, 0, 0) < 0)
			return connection_error(msg);

		return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
	}

	mouse->button |= button;

	if (mouse_action(chan, mouse->button, 0, 0, 0, 0) < 0)
		return connection_error(msg);

	return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
}

static DBusMessage *mouse_move_action(GIOChannel *chan, DBusMessage *msg,
		struct mouse_state *mouse, uint16_t code, char value)
{
	if (code == REL_X)
		mouse->x_axis = value;
	else
		mouse->y_axis = value;

	if (mouse->is_moving) {
		mouse->is_moving = 0;

		if (mouse_action(chan, mouse->button, mouse->x_axis,
				mouse->y_axis, 0, 0) < 0)
			return connection_error(msg);

		return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
	}

	mouse->is_moving = 1;

	return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
}

static DBusMessage *mouse_scroll_action(GIOChannel *chan, DBusMessage *msg,
		struct mouse_state *mouse, char value)
{
	if (mouse_action(chan, mouse->button, 0, 0, value, 0) < 0)
		return connection_error(msg);

	return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
}

static DBusMessage *mouse_horizontal_scroll_action(GIOChannel *chan,
							DBusMessage *msg,
							struct mouse_state *mouse,
							char value)
{
	if (mouse_action(chan, mouse->button, 0, 0, 0, value) < 0)
		return connection_error(msg);

	return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
}

static DBusMessage *mouse_event(GIOChannel *chan, DBusMessage *msg,
		struct mouse_state *mouse, uint16_t code, char value)
{
	switch (code) {
	case BTN_LEFT:
		return mouse_button_action(chan, msg, mouse, 0x01, value);

	case BTN_RIGHT:
		return mouse_button_action(chan, msg, mouse, 0x02, value);

	case BTN_MIDDLE:
		return mouse_button_action(chan, msg, mouse, 0x04, value);

	case BTN_FORWARD:
		return mouse_button_action(chan, msg, mouse, 0x10, value);

	case BTN_BACK:
		return mouse_button_action(chan, msg, mouse, 0x08, value);

	case REL_X:
	case REL_Y:
		return mouse_move_action(chan, msg, mouse, code,
						value);

	case REL_WHEEL:
		return mouse_scroll_action(chan, msg, mouse, value);
	case REL_HWHEEL:
		return mouse_horizontal_scroll_action(chan, msg, mouse,
						value);

	default:
		return invalid_mouse_action(msg);
	}
}

static void initiate_keyboard(struct keyboard_state *keyboard)
{
	keyboard->value[0] = 0xa1;
	keyboard->value[1] = 0x01;

	memset(&(keyboard->value[2]), 0, HIDP_KEYB_SIZE - 2);

	/*
	*	first 4 bytes in value are constant
	*	keys start at index 4
	*	last_value = 3 means no keys pressed
	*/
	keyboard->last_value = 3;
}

static char is_control(unsigned char code)
{
	unsigned char hidcode = keycode2hidp[code];

	if (hidcode >= 224 && hidcode <= 231)
		return 1;

	return 0;
}

static unsigned char mask(unsigned char code)
{
	unsigned char hidcode = keycode2hidp[code];

	return 1 << (hidcode - 224);
}

static int key_up(struct keyboard_state *keyboard, unsigned char code)
{
	unsigned char i;

	for (i = 4; i <= keyboard->last_value &&
			keyboard->value[i] != keycode2hidp[code]; i++)
		;

	if (i > keyboard->last_value)
		return -EINVAL;

	keyboard->value[i] = keyboard->value[keyboard->last_value];
	keyboard->value[keyboard->last_value] = 0;
	keyboard->last_value--;

	return 0;
}

static int key_down(struct keyboard_state *keyboard, unsigned char code)
{
	int i;
	unsigned char keycode;

	keycode = keycode2hidp[code];
	for (i = 4; i <= keyboard->last_value; i++)
		if (keyboard->value[i] == keycode)
			return 0;

	if (keyboard->last_value == HIDP_KEYB_SIZE - 1)
		return -EPERM;

	keyboard->last_value++;
	keyboard->value[keyboard->last_value] = keycode;

	return 0;
}

static DBusMessage *phantom_state(GIOChannel *chan,
		struct keyboard_state *keyboard, DBusMessage *msg)
{
	int fd, err;
	unsigned char value[10];

	value[0] = 0xa1;
	value[1] = 0x01;
	value[2] = value[3] = 0;

	/* phantom state */
	memset(&value[4], 1, 6);

	if (chan == NULL)
		return connection_error(msg);

	fd = g_io_channel_unix_get_fd(chan);

	err = write(fd, value, HIDP_KEYB_SIZE);
	if (err < 0)
		return connection_error(msg);

	return NULL;
}

static DBusMessage *send_report(GIOChannel *chan,
		struct keyboard_state *keyboard, DBusMessage *msg)
{
	int fd, err;

	if (chan == NULL)
		return connection_error(msg);;

	fd = g_io_channel_unix_get_fd(chan);

	err = write(fd, keyboard->value, HIDP_KEYB_SIZE);
	if (err < 0)
		return connection_error(msg);

	return NULL;
}

static DBusMessage *keyboard_event(GIOChannel *chan, DBusMessage *msg,
					struct keyboard_state *keyboard,
					unsigned char code,
					char value)
{
	DBusMessage *ret_msg;
	int err = 0;

	if (is_control(code)) {

		if (value)
			keyboard->value[2] |= mask(code);
		else
			keyboard->value[2] &= ~mask(code);

	} else {

		if (value)
			err = key_down(keyboard, code);
		else
			err = key_up(keyboard, code);
	}

	if (err < 0) {

		ret_msg = phantom_state(chan, keyboard, msg);

		if (ret_msg)
			return ret_msg;

		return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
	}

	ret_msg = send_report(chan, keyboard, msg);

	if (ret_msg)
		return ret_msg;

	return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
}

static DBusMessage *send_event(DBusConnection *conn,
		DBusMessage *msg, void *data)
{
	DBusMessageIter iter;
	char mode, value;
	unsigned int code;
	struct adapter_data *adapt = data;
	struct device_data *dev = adapt->dev;

	if (!dbus_message_iter_init(msg, &iter))
			return btd_error_invalid_args(msg);

	if (dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_BYTE)
		return btd_error_invalid_args(msg);

	dbus_message_iter_get_basic(&iter, &mode);
	dbus_message_iter_next(&iter);

	if (dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_UINT16)
		return btd_error_invalid_args(msg);

	dbus_message_iter_get_basic(&iter, &code);
	dbus_message_iter_next(&iter);

	if (dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_BYTE)
		return btd_error_invalid_args(msg);

	dbus_message_iter_get_basic(&iter, &value);

	if (dev->intr == NULL)
		return connection_error(msg);

	if (mode == EV_KEY) /* keboard */
		return keyboard_event(dev->intr, msg,
					&(dev->keyboard),
					(unsigned char) code, value);

	if (mode == EV_REL) /*	mouse */
		return mouse_event(dev->intr, msg,
					&(dev->mouse), code, value);

	return invalid_mode(msg);
}

static DBusMessage *get_properties(DBusConnection *conn,
		DBusMessage *msg, void *data)
{
	return not_implemented(msg);
}


static gboolean set_protocol_listener(GIOChannel *chan, GIOCondition condition,
					gpointer data)
{
    unsigned char b;
    unsigned char ok;
	struct device_data *dev = data;
    int fd;
    int outfd;
    int err;
    b = 0;
    ok = 0;

    fd = g_io_channel_unix_get_fd(chan);
    err = read(fd, &b, 1);
    if (err < 0)
        error("Error %d: failed to read set_protocol/set_idle", err);
    if ((b == 0x71) || (b == 0x90)) {
        // set_protocol(report) or set_idle
        outfd = g_io_channel_unix_get_fd(dev->intr);
        err = write(outfd, &ok, 1);
        if (err < 0)
            error("Error %d: failed to acknowledge set_protocol/set_idle", err);
    } else {
        btd_debug("possibly discarding important protocol traffic %x", b);
    }
	return TRUE;
}


static gboolean channel_listener(GIOChannel *chan, GIOCondition condition,
					gpointer data)
{
	struct device_data *dev = data;

	if (dev->intr != NULL) {
		g_io_channel_unref(dev->intr);
		dev->intr = NULL;
	}

	if (dev->ctrl != NULL) {
		g_io_channel_unref(dev->ctrl);
		dev->ctrl = NULL;
	}

	g_dbus_emit_signal(connection,  dev->input_path,
				GENERIC_INPUT_DEVICE, "Disconnected",
				DBUS_TYPE_INVALID);
    btd_debug("Channel listener");
	return FALSE;
}

static void interrupt_connect_cb(GIOChannel *chan, GError *conn_err,
					void *data)
{
	unsigned int w;
	func_ptr reg_interface;
	struct user_data *info = data;
	struct adapter_data *adapt = info->adapt;
	struct device_data *dev = adapt->dev;

	if (conn_err) {
		error("%s", conn_err->message);
		goto failed;
	}

	/* Connect */
	if (info->func != NULL) {
		reg_interface = info->func;
		btd_debug("Registering device");

		if ((*reg_interface)(adapt) < 0)
			goto failed;

	/* Reconnect */
	} else {
		g_dbus_emit_signal(connection,  dev->input_path,
					GENERIC_INPUT_DEVICE, "Reconnected",
					DBUS_TYPE_INVALID);
	}

	adapt->pending = 0;

	w = g_io_add_watch(dev->intr, G_IO_HUP | G_IO_ERR,
				channel_listener, dev);
	dev->intr_watch = w;

	g_free(info);

	return;

failed:
	g_free(info);
	info = NULL;
	g_io_channel_unref(dev->intr);
	dev->intr = NULL;

	if (dev->ctrl != NULL) {
		g_io_channel_unref(dev->ctrl);
		dev->ctrl = NULL;
	}
}

static void control_connect_cb(GIOChannel *chan, GError *conn_err,
					void *data)
{
	GIOChannel *io;
	GError *err;
	bdaddr_t src;
	struct user_data *info = data;
	struct adapter_data *adapt = info->adapt;
	struct device_data *dev = adapt->dev;

	if (conn_err) {
		error("%s", conn_err->message);
		goto failed;
	}

	adapter_get_address(adapt->adapter, &src);

	io = bt_io_connect(BT_IO_L2CAP, interrupt_connect_cb, data,
				NULL, &err,
				BT_IO_OPT_SOURCE_BDADDR, &src,
				BT_IO_OPT_DEST_BDADDR, &dev->dst,
				BT_IO_OPT_PSM, L2CAP_PSM_HIDP_INTR,
				BT_IO_OPT_INVALID);

	if (io == NULL) {
		error("%s", err->message);
		g_error_free(err);
		goto failed;
	}

	dev->intr = io;

	return;

failed:
	g_free(info);
	info = NULL;
	g_io_channel_unref(dev->ctrl);
	dev->ctrl = NULL;
}

static DBusMessage *reconnect_device(DBusConnection *conn, DBusMessage *msg,
					gpointer data)
{
	GError *err = NULL;
	GIOChannel *io;
	bdaddr_t src;
	struct adapter_data *adapt = data;
	struct device_data *dev = adapt->dev;
	struct user_data *info;

	if (adapt->pending)
		return pending_connection(msg);

	if (dev->intr != NULL)
		return btd_error_already_connected(msg);

	info = g_try_new(struct user_data, 1);
	if (info == NULL)
		return not_enough_memory(msg);

	info->adapt = adapt;
	info->func = NULL;

	adapter_get_address(adapt->adapter, &src);

	io = bt_io_connect(BT_IO_L2CAP, control_connect_cb, info,
				NULL, &err,
				BT_IO_OPT_SOURCE_BDADDR, &src,
				BT_IO_OPT_DEST_BDADDR, &(dev->dst),
				BT_IO_OPT_PSM, L2CAP_PSM_HIDP_CTRL,
				BT_IO_OPT_INVALID);

	/* TODO: treat plug failed even with errors from cb */
	if (err != NULL)
		error("%s", err->message);

	if (io == NULL) {
		if (info != NULL)
			g_free(info);

		return plug_failed(msg);
	}

	dev->ctrl = io;
	return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
}

static DBusMessage *disconnect_device(DBusConnection *conn, DBusMessage *msg,
					gpointer data)
{
	struct adapter_data *adapt = data;
	struct device_data *dev = adapt->dev;

	if (dev->intr != NULL) {
		g_io_channel_shutdown(dev->intr, TRUE, NULL);
		g_io_channel_unref(dev->intr);
		dev->intr = NULL;

		g_source_remove(dev->intr_watch);
	}

	if (dev->ctrl != NULL) {
		g_io_channel_shutdown(dev->ctrl, TRUE, NULL);
		g_io_channel_unref(dev->ctrl);
		dev->ctrl = NULL;
	}

	g_dbus_unregister_interface(conn, dev->input_path,
					GENERIC_INPUT_DEVICE);

	if (dev->input_path != NULL) {
		g_free(dev->input_path);
		dev->input_path = NULL;
	}

	g_dbus_emit_signal(connection, adapter_get_path(adapt->adapter),
				GENERIC_HID_INTERFACE, "DeviceReleased",
				DBUS_TYPE_INVALID);

	return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
}

static const GDBusSignalTable ghid_input_device_signals[] = {
	{ GDBUS_SIGNAL("Reconnected", NULL)	},
	{ GDBUS_SIGNAL("Disconnected", NULL) },
	{ }
};

static const GDBusMethodTable ghid_input_device_methods[] = {
	{ GDBUS_METHOD("SendEvent", GDBUS_ARGS({"event", "yqy"}), NULL, send_event) },
	{ GDBUS_METHOD("GetProperties",	NULL, GDBUS_ARGS({"properties", "a{sv}"}),	get_properties) },
	{ GDBUS_METHOD("Reconnect", NULL, NULL, reconnect_device) },
	{ GDBUS_METHOD("Disconnect", NULL, NULL, disconnect_device)	},
	{}
};

static void generic_input_device_path(char *path, struct btd_adapter *adapter)
{
	char *adapt;
	strcpy(path, "/org/bluez/input");

	/* adding the adapter name */
	adapt = strrchr(adapter_get_path(adapter), '/');
	strcat(path, adapt);

	strcat(path, "/device1");
}

static int register_input_device(struct adapter_data *adapt)
{
	struct device_data *dev = adapt->dev;

	dev->input_path = g_try_new0(char, MAX_PATH_LENGTH);
	if (dev->input_path == NULL)
		return -ENOMEM;

	generic_input_device_path(dev->input_path,
					adapt->adapter);

	initiate_keyboard(&dev->keyboard);
	initiate_mouse(&dev->mouse);

	btd_debug("input path is %s", dev->input_path);

	if (g_dbus_register_interface(connection,
					dev->input_path,
					GENERIC_INPUT_DEVICE,
					ghid_input_device_methods,
					ghid_input_device_signals, NULL,
					adapt, NULL) == FALSE) {
		error("D-Bus failed to register %s interface",
				GENERIC_INPUT_DEVICE);
		g_free(dev->input_path);
		return -1;
	}

	g_dbus_emit_signal(connection,  adapter_get_path(adapt->adapter),
				GENERIC_HID_INTERFACE, "IncomingConnection",
				DBUS_TYPE_INVALID);

	return 0;
}

static DBusMessage *connect_device(DBusConnection *conn, DBusMessage *msg,
					gpointer data)
{
	GError *err = NULL;
	GIOChannel *io;
	DBusMessageIter iter;
	char *str, addr[18];
	bdaddr_t src;
	struct adapter_data *adapt = data;
	struct device_data *dev = adapt->dev;
	struct user_data *info;

	if (adapt->pending)
		return pending_connection(msg);

	if (dev->input_path != NULL)
		return btd_error_already_connected(msg);

		info = g_try_new(struct user_data, 1);

	if (!dbus_message_iter_init(msg, &iter))
			return btd_error_invalid_args(msg);

	if (dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_STRING)
		return btd_error_invalid_args(msg);

	if (info == NULL)
		return not_enough_memory(msg);

	info->adapt = adapt;
	info->func = register_input_device;

	dbus_message_iter_get_basic(&iter, &str);

	strcpy(addr, str);
	str2ba(addr, &(dev->dst));

	btd_debug("Request connection to %s", addr);

	adapter_get_address(adapt->adapter, &src);

	io = bt_io_connect(BT_IO_L2CAP, control_connect_cb, info,
				NULL, &err,
				BT_IO_OPT_SOURCE_BDADDR, &src,
				BT_IO_OPT_DEST_BDADDR, &(dev->dst),
				BT_IO_OPT_PSM, L2CAP_PSM_HIDP_CTRL,
				BT_IO_OPT_INVALID);

	if (err != NULL)
		error("%s", err->message);

	if (io == NULL) {
		if (info != NULL)
			g_free(info);

		return plug_failed(msg);
	}

	dev->ctrl = io;
	return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
}


static const GDBusSignalTable ghid_adapter_signals[] = {
	{ GDBUS_SIGNAL("IncomingConnection", NULL) },
	{ GDBUS_SIGNAL("DeviceReleased", NULL) },
	{ }
};

static const GDBusMethodTable ghid_adapter_methods[] = {
	{ GDBUS_METHOD("Connect", GDBUS_ARGS({"path", "s"}), NULL, connect_device) },
	{ }
};

static void register_interface(const char *path, struct adapter_data *adapt)
{
	if (g_dbus_register_interface(connection, path, GENERIC_HID_INTERFACE,
					ghid_adapter_methods, ghid_adapter_signals,
					NULL, adapt, NULL) == FALSE) {
		error("D-Bus failed to register %s interface",
				GENERIC_HID_INTERFACE);
		return;
	}

	btd_debug("Registered interface %s path %s", GENERIC_HID_INTERFACE, path);

}

static void unregister_interface(const char *path)
{
	btd_debug("path %s", path);

	g_dbus_unregister_interface(connection, path, GENERIC_HID_INTERFACE);
}

static void connect_cb(GIOChannel *chan, GError *err, gpointer data)
{
	uint16_t psm;
	bdaddr_t dst;
	GError *gerr = NULL;
	unsigned int w;
	int ret;
	struct adapter_data *adapt = data;
	struct device_data *dev = adapt->dev;

	if (err)
		btd_debug("%s\n", err->message);

	bt_io_get(chan, BT_IO_L2CAP, &gerr,
			BT_IO_OPT_DEST_BDADDR, &dst,
			BT_IO_OPT_PSM, &psm,
			BT_IO_OPT_INVALID);

	if (gerr) {
		btd_debug("Error on PSM %d: %s\n", psm, gerr->message);
		g_error_free(gerr);
		g_io_channel_shutdown(chan, TRUE, NULL);
		return;
	}

	btd_debug("Accept on PSM %d\n", psm);

	if (psm == 17) {
		dev->ctrl = g_io_channel_ref(chan);
		return;
	}

	dev->intr = g_io_channel_ref(chan);

	if (dev->input_path == NULL) {

		ret = register_input_device(adapt);

		if (ret < 0)
			goto failed;

		bacpy(&dev->dst, &dst);

	} else {
		g_dbus_emit_signal(connection,  dev->input_path,
					GENERIC_INPUT_DEVICE, "Reconnected",
					DBUS_TYPE_INVALID);
	}

	w = g_io_add_watch(dev->intr, G_IO_HUP | G_IO_ERR,
				channel_listener, dev);
    g_io_add_watch(dev->ctrl, G_IO_IN, set_protocol_listener, dev);
    btd_debug("Added watch in connect_cb to set_protocol_listener");
	dev->intr_watch = w;
	adapt->pending = 0;

	return;

failed:
	if (dev->intr != NULL) {
		g_io_channel_shutdown(dev->intr, TRUE, NULL);
		g_io_channel_unref(dev->intr);
		dev->intr = NULL;
	}

	if (dev->ctrl != NULL) {
		g_io_channel_shutdown(dev->ctrl, TRUE, NULL);
		g_io_channel_unref(dev->ctrl);
		dev->ctrl = NULL;
	}
}

static void confirm_event_cb(GIOChannel *chan, GError *err, gpointer data)
{
	uint16_t psm;
	GError *gerr = NULL;
	bdaddr_t dst;
	struct adapter_data *adapt = data;
	struct device_data *dev = adapt->dev;

	if (err) {
		error("%s\n", err->message);
		return;
	}

	bt_io_get(chan, BT_IO_L2CAP, &gerr,
			BT_IO_OPT_DEST_BDADDR, &dst,
			BT_IO_OPT_PSM, &psm,
			BT_IO_OPT_INVALID);
	if (gerr) {
		error("%s on PSM %d\n", gerr->message, psm);
		g_error_free(gerr);
		g_io_channel_shutdown(chan, TRUE, NULL);
		return;
	}

	if (dev->input_path != NULL &&
			(bacmp(&(dev->dst), &dst) != 0 ||
			dev->intr != NULL)) {

		btd_debug("Incoming request blocked due to existing input device");
		g_io_channel_shutdown(chan, TRUE, NULL);
		return;
	}

	btd_debug("Incoming connection on PSM number %d", psm);

	if (psm == 17)
		adapt->pending = 1;

	if (!bt_io_accept(chan, connect_cb, data, NULL, NULL))
		btd_debug("Can not accept connection on psm %d", psm);
}

static int adapt_start(struct adapter_data *adapt)
{
	GError *err = NULL;
	bdaddr_t src;
	struct device_data *dev = adapt->dev;

	adapter_get_address(adapt->adapter, &src);

	adapt->listen_ctrl = bt_io_listen(BT_IO_L2CAP, confirm_event_cb,
						NULL, adapt, NULL, &err,
						BT_IO_OPT_SOURCE_BDADDR, &src,
						BT_IO_OPT_PSM, L2CAP_PSM_HIDP_CTRL,
						BT_IO_OPT_INVALID);
	if (!adapt->listen_ctrl) {
		error("Failed to listen on control channel");
		g_error_free(err);
		g_free(adapt);
		return -ENOTCONN;
	}

	adapt->listen_intr = bt_io_listen(BT_IO_L2CAP, confirm_event_cb,
						NULL, adapt, NULL, &err,
						BT_IO_OPT_SOURCE_BDADDR, &src,
						BT_IO_OPT_PSM, L2CAP_PSM_HIDP_INTR,
						BT_IO_OPT_INVALID);
	if (!adapt->listen_intr) {
		error("Failed to listen on interrupt channel");
		/* TODO: fix this */
		g_io_channel_unref(dev->ctrl);
		dev->ctrl = NULL;
		g_error_free(err);
		g_free(adapt);
		return -ENOTCONN;
	}

	return 0;
}

static void adapt_stop(struct adapter_data *adapt)
{
	struct device_data *dev = adapt->dev;

	if (adapt->listen_intr != NULL) {
		g_io_channel_shutdown(adapt->listen_intr, TRUE, NULL);
		g_io_channel_unref(adapt->listen_intr);
	}

	if (adapt->listen_intr != NULL) {
		g_io_channel_shutdown(adapt->listen_ctrl, TRUE, NULL);
		g_io_channel_unref(adapt->listen_ctrl);
	}

	if (dev->intr != NULL) {
		g_io_channel_shutdown(dev->intr, TRUE, NULL);
		g_io_channel_unref(dev->intr);

		g_source_remove(dev->intr_watch);
	}

	if (dev->ctrl != NULL) {
		g_io_channel_shutdown(dev->ctrl, TRUE, NULL);
		g_io_channel_unref(dev->ctrl);
	}
}

static void cleanup(struct adapter_data *adapt)
{
	adapt_stop(adapt);

	if (adapt->dev != NULL)
		g_free(adapt->dev);

	if (adapt != NULL)
		g_free(adapt);
}

static gint adapter_cmp(gconstpointer con, gconstpointer user_data)
{
	const struct adapter_data *adapt = con;
	const struct btd_adapter *adapter = user_data;

    return (adapter == adapt->adapter); 
    // why would we have multiple copies of the adapter struct for the same adapter
	
    /*return memcmp(adapter, adapt->adapter,
			sizeof(struct btd_adapter));*/
}

static int ghid_probe(struct btd_adapter *adapter)
{
	struct adapter_data *adapt;

	adapt = g_try_new0(struct adapter_data, 1);
	if (adapt == NULL)
		return -ENOMEM;

	adapt->dev = g_try_new0(struct device_data, 1);
	if (adapt->dev == NULL) {
		g_free(adapt);
		return -ENOMEM;
	}

	adapt->pending = 0;
	adapt->adapter = adapter;
	adapt->active = 0;

	if (sdp_keyboard_service(adapt) < 0) {
		btd_debug("Adding HID SDP service failed");
		g_free(adapt);
		return -1;
	}

	if (adapt_start(adapt) < 0)
		return -ENOTCONN;

	register_interface(adapter_get_path(adapter), adapt);

	adapters = g_slist_append(adapters, adapt);

	return 0;
}

static void ghid_remove(struct btd_adapter *adapter)
{
	struct adapter_data *adapt;
	struct device_data *dev;
	GSList *l;

	l = g_slist_find_custom(adapters, adapter, adapter_cmp);

	if (l == NULL)
		return;

	adapt = l->data;
	dev = adapt->dev;

	adapters = g_slist_remove(adapters, adapt);

	if (dev->input_path != NULL) {
		g_dbus_unregister_interface(connection,
						dev->input_path,
						GENERIC_INPUT_DEVICE);

		g_dbus_emit_signal(connection,  adapter_get_path(adapter),
					GENERIC_HID_INTERFACE, "DeviceReleased",
					DBUS_TYPE_INVALID);

		g_free(dev->input_path);

	}

	remove_record_from_server(adapt->sdp_record_handle);
	cleanup(adapt);

	unregister_interface(adapter_get_path(adapter));
}

static struct btd_adapter_driver ghid_driver = {
	.name	= "generic-hid",
	.probe	= ghid_probe,
	.remove	= ghid_remove,
};

static int generic_hid_init(void)
{
	int err;

	connection = dbus_bus_get(DBUS_BUS_SYSTEM, NULL);
	if (connection == NULL)
		return -EIO;

	err = btd_register_adapter_driver(&ghid_driver);
	if (err < 0) {
		dbus_connection_unref(connection);
		return err;
	}

	return 0;
}

static void generic_hid_exit(void)
{
	btd_unregister_adapter_driver(&ghid_driver);

	dbus_connection_unref(connection);
}

BLUETOOTH_PLUGIN_DEFINE(generichid, VERSION,
		BLUETOOTH_PLUGIN_PRIORITY_LOW, generic_hid_init, generic_hid_exit)