Update probe/remove callback and implement serial API

3 files changed, 48 insertions, 22 deletions

diff --git a/serial/main.c b/serial/main.c
index b042e2e7..60ce9d45 100644
--- a/serial/main.c
+++ b/serial/main.c
@@ -35,64 +35,84 @@
 
 #include "plugin.h"
 #include "device.h"
+#include "adapter.h"
 #include "logging.h"
 #include "manager.h"
+#include "port.h"
 
 #define SERIAL_PORT_UUID	"00001101-0000-1000-8000-00805F9B34FB"
 #define DIALUP_NET_UUID		"00001103-0000-1000-8000-00805F9B34FB"
 
-#define SERIAL_INTERFACE "org.bluez.Serial"
+#define SERIAL_INTERFACE     "org.bluez.Serial"
+#define ERROR_INVALID_ARGS   "org.bluez.Error.InvalidArguments"
+#define ERROR_DOES_NOT_EXIST "org.bluez.Error.DoesNotExist"
 
 static DBusMessage *serial_connect(DBusConnection *conn,
 					DBusMessage *msg, void *user_data)
 {
-	const char *target, *device = "/dev/rfcomm0";
+	struct btd_device *device = user_data;
+	const char *target;
+	char src[18], dst[18];
 
 	if (dbus_message_get_args(msg, NULL, DBUS_TYPE_STRING, &target,
 						DBUS_TYPE_INVALID) == FALSE)
 		return NULL;
 
-	return g_dbus_create_reply(msg, DBUS_TYPE_STRING, &device,
-							DBUS_TYPE_INVALID);
+	ba2str(&device->src, src);
+	ba2str(&device->dst, dst);
+
+	service_connect(conn, msg, src, dst, target);
+
+	return NULL;
 }
 
 static DBusMessage *serial_disconnect(DBusConnection *conn,
 					DBusMessage *msg, void *user_data)
 {
-	const char *device;
+	const char *device, *sender;
+	int err, id;
 
 	if (dbus_message_get_args(msg, NULL, DBUS_TYPE_STRING, &device,
 						DBUS_TYPE_INVALID) == FALSE)
 		return NULL;
 
+	sender = dbus_message_get_sender(msg);
+
+	if (sscanf(device, "/dev/rfcomm%d", &id) != 1)
+		return g_dbus_create_error(msg, ERROR_INVALID_ARGS, NULL);
+
+	err = port_remove_listener(sender, device);
+	if (err < 0)
+		return g_dbus_create_error(msg, ERROR_DOES_NOT_EXIST, NULL);
+
 	return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
 }
 
 static GDBusMethodTable serial_methods[] = {
-	{ "Connect",    "s", "s", serial_connect    },
+	{ "Connect",    "s", "s", serial_connect, G_DBUS_METHOD_FLAG_ASYNC },
 	{ "Disconnect", "s", "",  serial_disconnect },
 	{ }
 };
 
 static DBusConnection *conn;
 
-static int serial_probe(const char *path)
+static int serial_probe(struct btd_device *device)
 {
-	DBG("path %s", path);
+	DBG("path %s", device->path);
 
-	if (g_dbus_register_interface(conn, path, SERIAL_INTERFACE,
+	if (g_dbus_register_interface(conn, device->path, SERIAL_INTERFACE,
 						serial_methods, NULL, NULL,
-							NULL, NULL) == FALSE)
+							device, NULL) == FALSE)
 		return -1;
 
 	return 0;
 }
 
-static void serial_remove(const char *path)
+static void serial_remove(struct btd_device *device)
 {
-	DBG("path %s", path);
+	DBG("path %s", device->path);
 
-	g_dbus_unregister_interface(conn, path, SERIAL_INTERFACE);
+	g_dbus_unregister_interface(conn, device->path, SERIAL_INTERFACE);
 }
 
 static struct btd_device_driver serial_driver = {
diff --git a/serial/manager.c b/serial/manager.c
index f097b330..442c386e 100644
--- a/serial/manager.c
+++ b/serial/manager.c
@@ -1636,9 +1636,10 @@ static DBusMessage *connect_channel(DBusConnection *conn, DBusMessage *msg,
 	return connect_pending(conn, msg, pc);
 }
 
-static DBusMessage *service_connect(DBusConnection *conn, DBusMessage *msg,
-					const char *adapter, const char *address,
-					const char *pattern, void *data)
+DBusMessage *service_connect(DBusConnection *conn, DBusMessage *msg,
+						const char *adapter,
+						const char *address,
+						const char *pattern)
 {
 	int dev_id;
 	bdaddr_t src;
@@ -1658,13 +1659,13 @@ static DBusMessage *service_connect(DBusConnection *conn, DBusMessage *msg,
 
 	/* Friendly name or uuid128 */
 	if (pattern2uuid(pattern, &uuid) == 0)
-		return search_uuid(conn, msg, adp, address, pattern, &uuid,
-				data);
+		return search_uuid(conn, msg, adp, address,
+						pattern, &uuid, NULL);
 
 	/* RFCOMM Channel */
 	if (pattern2long(pattern, &val) == 0)
-		return connect_channel(conn, msg, adp, address, pattern,
-					val, data);
+		return connect_channel(conn, msg, adp, address,
+							pattern, val, NULL);
 
 	return invalid_arguments(msg, "Invalid Pattern");
 }
@@ -1680,7 +1681,7 @@ static DBusMessage *connect_service(DBusConnection *conn,
 				DBUS_TYPE_INVALID))
 		return NULL;
 
-	return service_connect(conn, msg, NULL, address, pattern, data);
+	return service_connect(conn, msg, NULL, address, pattern);
 }
 
 static DBusMessage *connect_service_from_adapter(DBusConnection *conn,
@@ -1695,7 +1696,7 @@ static DBusMessage *connect_service_from_adapter(DBusConnection *conn,
 				DBUS_TYPE_INVALID))
 		return NULL;
 
-	return service_connect(conn, msg, adapter, address, pattern, data);
+	return service_connect(conn, msg, adapter, address, pattern);
 }
 
 static DBusMessage *disconnect_service(DBusConnection *conn,
diff --git a/serial/manager.h b/serial/manager.h
index b25c2686..fdcc8ab9 100644
--- a/serial/manager.h
+++ b/serial/manager.h
@@ -27,3 +27,8 @@
 int serial_manager_init(DBusConnection *conn);
 void serial_manager_exit(void);
 int rfcomm_release(int16_t id);
+
+DBusMessage *service_connect(DBusConnection *conn, DBusMessage *msg,
+						const char *adapter,
+						const char *address,
+						const char *pattern);