/*
 * Copyright (c) 2012-2013 Samsung Electronics Co., Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the License);
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an AS IS BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include <glib.h>
#include <string.h>
#include <stdlib.h>
#include <ctype.h>
#include <stdio.h>
#include <stdbool.h>
#include <dbus/dbus.h>
#include <unistd.h>
#include <sys/un.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <dlog.h>

#include "serial.h"
#include "serial_private.h"

#ifdef LOG_TAG
#undef LOG_TAG
#endif
#define LOG_TAG "CAPI_NETWORK_SERIAL"

#define DBG(fmt, args...) SLOGD(fmt, ##args)
#define ERR(fmt, args...) SLOGE(fmt, ##args)

#define SERIAL_SOCKET_PATH	"/tmp/.dr_common_stream"
#define SERIAL_BUF_SIZE		65536
#define SERIAL_INTERFACE		"User.Data.Router.Introspectable"

DBusConnection *dbus_connection = NULL;

/*
 *  Internal Functions
 */
static gboolean __g_io_client_handler(GIOChannel * io, GIOCondition cond, void *data)
{
	int fd;
	serial_s *pHandle = (serial_s *) data;
	if (pHandle == NULL)
		return FALSE;

	if (pHandle->data_handler.callback) {
		char buffer[SERIAL_BUF_SIZE] = { 0 };
		int len = 0;
		fd = g_io_channel_unix_get_fd(io);
		len = recv(fd, buffer, SERIAL_BUF_SIZE, 0);
		if (len <= 0) {
			ERR("Error occured or the peer is shutdownd. [%d]\n", len);
			((serial_state_changed_cb) pHandle->state_handler.callback)
				(SERIAL_ERROR_NONE, SERIAL_STATE_CLOSED, pHandle->state_handler.user_data);
			return FALSE;
		}

		((serial_data_received_cb) pHandle->data_handler.callback)
			(buffer, len, pHandle->data_handler.user_data);
	}
	return TRUE;
}

static void __init_client_giochannel(void *data)
{
	GIOChannel *io;
	serial_s *pHandle = (serial_s *) data;
	if (pHandle == NULL)
		return;

	io = g_io_channel_unix_new(pHandle->client_socket);
	g_io_channel_set_close_on_unref(io, TRUE);
	pHandle->g_watch_id = g_io_add_watch(io, G_IO_IN | G_IO_ERR | G_IO_HUP | G_IO_NVAL, __g_io_client_handler, pHandle);
	g_io_channel_unref(io);
	return;
}

static int __connect_to_serial_server(void *data)
{
	int client_socket = -1;
	struct sockaddr_un server_addr;
	serial_s *pHandle = (serial_s *) data;
	if (pHandle == NULL)
		return -1;

	client_socket = socket(AF_UNIX, SOCK_STREAM, 0);
	if (client_socket < 0) {
		ERR("Create socket failed\n");
		return -1;
	}

	memset(&server_addr, 0, sizeof(server_addr));
	server_addr.sun_family = AF_UNIX;
	g_strlcpy(server_addr.sun_path, SERIAL_SOCKET_PATH, sizeof(server_addr.sun_path));

	if (connect(client_socket, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
		ERR("Connect failed\n");
		close(client_socket);
		return -1;
	}
	pHandle->client_socket = client_socket;

	__init_client_giochannel(pHandle);

	return client_socket;
}

static DBusHandlerResult __dbus_event_filter(DBusConnection * sys_conn, DBusMessage * msg, void *data)
{
	static int socket = -1;
	const char *path = dbus_message_get_path(msg);

	if (dbus_message_get_type(msg) != DBUS_MESSAGE_TYPE_SIGNAL)
		return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;

	if (path == NULL || strcmp(path, "/") == 0)
		return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;

	if (dbus_message_is_signal(msg, SERIAL_INTERFACE, "serial_status")) {
		int res = 0;
		dbus_message_get_args(msg, NULL, DBUS_TYPE_INT32, &res, DBUS_TYPE_INVALID);

		serial_s *pHandle = (serial_s *) data;
		if (res == SERIAL_OPENED) {
			socket = __connect_to_serial_server(pHandle);
			if (socket < 0) {
				((serial_state_changed_cb) pHandle->state_handler.callback)
					(SERIAL_ERROR_OPERATION_FAILED, SERIAL_STATE_OPENED, pHandle->state_handler.user_data);
				return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
			}

			((serial_state_changed_cb) pHandle->state_handler.callback)
				(SERIAL_ERROR_NONE, SERIAL_STATE_OPENED, pHandle->state_handler.user_data);
		} else if (res == SERIAL_CLOSED) {
			if (socket < 0)
				return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;

			((serial_state_changed_cb) pHandle->state_handler.callback)
				(SERIAL_ERROR_NONE, SERIAL_STATE_CLOSED, pHandle->state_handler.user_data);
		}
	} else {
		return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
	}

	return DBUS_HANDLER_RESULT_HANDLED;
}

int __send_serial_ready_done_signal(void)
{
	DBusMessage *msg = NULL;
	const char *res = "OK";

	if (dbus_connection == NULL)
		return SERIAL_ERROR_INVALID_OPERATION;

	msg = dbus_message_new_signal("/Network/Serial", "Capi.Network.Serial", "ready_for_serial");
	if (!msg) {
		ERR("Unable to allocate D-Bus signal\n");
		return SERIAL_ERROR_OPERATION_FAILED;
	}

	if (!dbus_message_append_args(msg, DBUS_TYPE_STRING, &res, DBUS_TYPE_INVALID)) {
		ERR("Event sending failed\n");
		dbus_message_unref(msg);
		return SERIAL_ERROR_OPERATION_FAILED;
	}

	dbus_connection_send(dbus_connection, msg, NULL);
	dbus_message_unref(msg);
	return SERIAL_ERROR_NONE;
}

static int __serial_set_state_changed_cb(serial_h serial, void *callback, void *user_data)
{
	if (!serial) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}

	serial_s *pHandle = (serial_s *) serial;

	if (callback) {
		pHandle->state_handler.callback = callback;
		pHandle->state_handler.user_data = user_data;
	} else {
		pHandle->state_handler.callback = NULL;
		pHandle->state_handler.user_data = NULL;
	}

	return SERIAL_ERROR_NONE;
}

static int __serial_set_data_received_cb(serial_h serial, void *callback, void *user_data)
{
	if (!serial) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}

	serial_s *pHandle = (serial_s *) serial;

	if (callback) {
		pHandle->data_handler.callback = callback;
		pHandle->data_handler.user_data = user_data;
	} else {
		pHandle->data_handler.callback = NULL;
		pHandle->data_handler.user_data = NULL;
	}

	return SERIAL_ERROR_NONE;
}

/*
 *  Public Functions
 */

int serial_create(serial_h * serial)
{
	DBG("%s\n", __FUNCTION__);

	DBusError dbus_error;
	serial_s *pHandle = NULL;

	if (serial == NULL)
		return SERIAL_ERROR_INVALID_PARAMETER;

	pHandle = (serial_s *) g_try_malloc0(sizeof(serial_s));
	if (pHandle == NULL)
		return SERIAL_ERROR_OUT_OF_MEMORY;
#if !GLIB_CHECK_VERSION(2, 35, 3)
	g_type_init();
#endif

	dbus_connection = dbus_bus_get(DBUS_BUS_SYSTEM, NULL);
	if (!dbus_connection) {
		ERR("Couldn't connect to the System bus");
		g_free(pHandle);
		return SERIAL_ERROR_OPERATION_FAILED;
	}

	/* Add the filter for network client functions */
	dbus_error_init(&dbus_error);
	dbus_connection_add_filter(dbus_connection, __dbus_event_filter, pHandle, NULL);
	dbus_bus_add_match(dbus_connection, "type=signal,interface=" SERIAL_INTERFACE ",member=serial_status", &dbus_error);
	if (dbus_error_is_set(&dbus_error)) {
		ERR("Fail to add dbus filter signal\n");
		dbus_error_free(&dbus_error);
		g_free(pHandle);
		return SERIAL_ERROR_OPERATION_FAILED;
	}

	pHandle->client_bus = dbus_connection;

	*serial = (serial_h) pHandle;

	return SERIAL_ERROR_NONE;
}

int serial_open(serial_h serial)
{
	DBG("%s\n", __FUNCTION__);

	if (!serial) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}

	return __send_serial_ready_done_signal();
}

int serial_close(serial_h serial)
{
	DBG("%s\n", __FUNCTION__);

	if (!serial) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}

	serial_s *pHandle = (serial_s *) serial;

	if (pHandle->client_socket > 0) {
		if (close(pHandle->client_socket) < 0)
			return SERIAL_ERROR_OPERATION_FAILED;

		pHandle->client_socket = -1;

		return SERIAL_ERROR_NONE;
	} else {
		return SERIAL_ERROR_INVALID_OPERATION;
	}
}

int serial_destroy(serial_h serial)
{
	DBG("%s\n", __FUNCTION__);

	if (!serial) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}

	serial_s *pHandle = (serial_s *) serial;

	if (dbus_connection != NULL) {
		dbus_connection_remove_filter(dbus_connection, __dbus_event_filter, pHandle);
		dbus_connection = NULL;
	}

	if (pHandle->client_bus != NULL) {
		dbus_connection_unref(pHandle->client_bus);
		pHandle->client_bus = NULL;
	}

	if (pHandle->g_watch_id > 0) {
		g_source_remove(pHandle->g_watch_id);
		pHandle->g_watch_id = -1;
	}

	if (pHandle->client_socket > 0) {
		close(pHandle->client_socket);
		pHandle->client_socket = -1;
	}

	g_free(pHandle);
	serial = NULL;

	return SERIAL_ERROR_NONE;
}

int serial_write(serial_h serial, const char *data, int data_length)
{
	if (!serial) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}
	int ret;
	serial_s *pHandle = (serial_s *) serial;

	ret = send(pHandle->client_socket, data, data_length, MSG_EOR);
	if (ret == -1) {
		ERR("Send failed. ");
		return SERIAL_ERROR_OPERATION_FAILED;
	}

	return ret;
}

int serial_set_state_changed_cb(serial_h serial, serial_state_changed_cb callback, void *user_data)
{
	DBG("%s\n", __FUNCTION__);

	if (!serial || !callback) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}

	return (__serial_set_state_changed_cb(serial, callback, user_data));
}

int serial_unset_state_changed_cb(serial_h serial)
{
	DBG("%s\n", __FUNCTION__);

	if (!serial) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}

	return (__serial_set_state_changed_cb(serial, NULL, NULL));
}

int serial_set_data_received_cb(serial_h serial, serial_data_received_cb callback, void *user_data)
{
	DBG("%s\n", __FUNCTION__);

	if (!serial || !callback) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}

	return (__serial_set_data_received_cb(serial, callback, user_data));
}

int serial_unset_data_received_cb(serial_h serial)
{
	DBG("%s\n", __FUNCTION__);

	if (!serial) {
		ERR("Invalid parameter\n");
		return SERIAL_ERROR_INVALID_PARAMETER;
	}

	return (__serial_set_data_received_cb(serial, NULL, NULL));
}