/*
 * Copyright (c) 2000 - 2016 Samsung Electronics Co., Ltd. All rights reserved.
 *
 * 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 <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include <sqlite3.h>
#include <aul.h>
#include <dlog.h>

#include "rua_util.h"
#include "rua.h"
#include "db-schema.h"
#include "rua_dbus.h"
#include "rua_private.h"

API int rua_add_history_for_uid(char *pkg_name, char *app_path, char *arg, uid_t uid)
{
	int r;
	char time_str[32] = {0,};
	bundle *b = NULL;

	if (pkg_name == NULL || app_path == NULL) {
		LOGE("invalid param");
		return -1;
	}

	r = _rua_util_check_uid(uid);
	if (r == -1)
		return r;

	b = bundle_create();
	if (b == NULL) {
		LOGE("bundle_create fail out of memory.");
		return -1;
	}
	snprintf(time_str, sizeof(time_str), "%d", (int)time(NULL));
	bundle_add_str(b, AUL_K_RUA_PKGNAME, pkg_name);
	bundle_add_str(b, AUL_K_RUA_APPPATH, app_path);
	bundle_add_str(b, AUL_K_RUA_ARG, arg);
	bundle_add_str(b, AUL_K_RUA_TIME, time_str);

	r = aul_add_rua_history_for_uid(b, uid);
	LOGI("rua_add_history_for_uid result : %d ", r);
	bundle_free(b);
	return r;
}

API int rua_delete_history_with_pkgname_for_uid(char *pkg_name, uid_t uid)
{
	int r;
	bundle *b;

	r = _rua_util_check_uid(uid);
	if (r == -1)
		return r;

	b = bundle_create();
	if (b == NULL) {
		LOGE("bundle_create fail out of memory.");
		return -1;
	}
	bundle_add_str(b, AUL_K_RUA_PKGNAME, pkg_name);
	r = aul_delete_rua_history_for_uid(b, uid);
	LOGI("rua_delete_history_with_pkgname result : %d ", r);
	bundle_free(b);
	return r;
}

API int rua_delete_history_with_pkgname(char *pkg_name)
{
	return rua_delete_history_with_pkgname_for_uid(pkg_name, getuid());
}

API int rua_delete_history_with_apppath_for_uid(char *app_path, uid_t uid)
{
	int r;
	bundle *b;

	r = _rua_util_check_uid(uid);
	if (r == -1)
		return r;

	b = bundle_create();
	if (b == NULL) {
		LOGE("bundle_create fail out of memory.");
		return -1;
	}
	bundle_add_str(b, AUL_K_RUA_APPPATH, app_path);
	r = aul_delete_rua_history_for_uid(b, uid);
	LOGI("rua_delete_history_with_apppath result : %d ", r);
	bundle_free(b);
	return r;
}

API int rua_delete_history_with_apppath(char *app_path)
{
	return rua_delete_history_with_apppath_for_uid(app_path, getuid());
}

API int rua_clear_history_for_uid(uid_t uid)
{
	int r;

	r = _rua_util_check_uid(uid);
	if (r == -1)
		return r;

	r = aul_delete_rua_history_for_uid(NULL, uid);
	LOGI("rua_clear_history result : %d ", r);
	return r;
}

API int rua_clear_history(void)
{
	return rua_clear_history_for_uid(getuid());
}

API int rua_history_load_db_for_uid(char ***table, int *nrows, int *ncols, uid_t uid)
{
	static const char query[] = "SELECT "
		"pkg_name, app_path, arg, launch_time, instance_id, "
		"instance_name, icon, uri, image, comp_id "
		"FROM rua_history ORDER BY launch_time DESC";
	int r;
	char *db_err = NULL;
	char **db_result = NULL;
	sqlite3 *db = NULL;

	if (table == NULL || nrows == NULL || ncols == NULL) {
		LOGE("invalid parameter");
		return -1;
	}

	r = _rua_util_check_uid(uid);
	if (r == -1)
		return r;

	r = _rua_util_open_db(&db, SQLITE_OPEN_READONLY, uid, RUA_DB_NAME);
	if (r != SQLITE_OK)
		return -1;

	r = sqlite3_get_table(db, query, &db_result, nrows, ncols, &db_err);
	if (r != SQLITE_OK) {
		LOGE("get table failed: %s", db_err);
		sqlite3_free(db_err);
		sqlite3_close_v2(db);
		return -1;
	}

	*table = db_result;

	sqlite3_close_v2(db);

	return r;
}

API int rua_history_load_db(char ***table, int *nrows, int *ncols)
{
	return rua_history_load_db_for_uid(table, nrows, ncols, getuid());
}

API int rua_register_update_cb_for_uid(rua_history_update_cb callback, void *user_data, int *callback_id, uid_t uid)
{
	int r;

	if (callback == NULL)
		return -1;

	r = _rua_util_check_uid(uid);
	if (r == -1)
		return r;

	r = rua_dbus_signal_subscribe(callback, user_data, callback_id);

	return r;
}

API int rua_register_update_cb(rua_history_update_cb callback, void *user_data, int *callback_id)
{
	return rua_register_update_cb_for_uid(callback, user_data, callback_id, getuid());
}

API int rua_unregister_update_cb_for_uid(int callback_id, uid_t uid)
{
	int r;

	r = _rua_util_check_uid(uid);
	if (r == -1)
		return r;

	r = rua_dbus_signal_unsubscribe(callback_id);

	return r;
}

API int rua_unregister_update_cb(int callback_id)
{
	return rua_unregister_update_cb_for_uid(callback_id, getuid());
}

API int rua_history_get_rec(struct rua_rec *rec, char **table, int nrows, int ncols,
			int row)
{
	char **db_result = NULL;
	char *tmp = NULL;

	if (rec == NULL)
		return -1;
	if (table == NULL)
		return -1;
	if (row >= nrows)
		return -1;

	db_result = table + ((row + 1) * ncols);

	tmp = db_result[RUA_COL_PKGNAME];
	if (tmp) {
		rec->pkg_name = tmp;
		LOGI("get rec pkg_name %s", rec->pkg_name);
	}

	tmp = db_result[RUA_COL_APPPATH];
	if (tmp)
		rec->app_path = tmp;

	tmp = db_result[RUA_COL_ARG];
	if (tmp)
		rec->arg = tmp;

	tmp = db_result[RUA_COL_LAUNCHTIME];
	if (tmp)
		rec->launch_time = atoi(tmp);

	tmp = db_result[RUA_COL_COMP_ID];
	if (tmp && tmp[0] != '\0')
		rec->comp_id = tmp;
	else
		rec->comp_id = NULL;

	tmp = db_result[RUA_COL_INSTANCE_ID];
	if (tmp && tmp[0] != '\0')
		rec->instance_id = tmp;
	else
		rec->instance_id = NULL;

	tmp = db_result[RUA_COL_INSTANCE_NAME];
	if (tmp && tmp[0] != '\0')
		rec->instance_name = tmp;
	else
		rec->instance_name = NULL;

	tmp = db_result[RUA_COL_ICON];
	if (tmp && tmp[0] != '\0')
		rec->icon = tmp;
	else
		rec->icon = NULL;

	tmp = db_result[RUA_COL_URI];
	if (tmp && tmp[0] != '\0')
		rec->uri = tmp;
	else
		rec->uri = NULL;

	tmp = db_result[RUA_COL_IMAGE];
	if (tmp && tmp[0] != '\0')
		rec->image = tmp;
	else
		rec->image = NULL;

	tmp = db_result[RUA_COL_COMP_ID];
	if (tmp && tmp[0] != '\0')
		rec->comp_id = tmp;
	else
		rec->comp_id = NULL;

	return 0;
}

API int rua_history_unload_db(char ***table)
{
	if (*table) {
		sqlite3_free_table(*table);
		*table = NULL;
		return 0;
	}
	return -1;
}

API int rua_is_latest_app_for_uid(const char *pkg_name, uid_t uid)
{
	static const char query[] =
		"SELECT pkg_name FROM rua_history "
		"ORDER BY launch_time DESC LIMIT 1";
	int r = -1;
	sqlite3_stmt *stmt;
	const unsigned char *ct;
	sqlite3 *db = NULL;

	if (!pkg_name)
		return -1;

	r = _rua_util_check_uid(uid);
	if (r == -1)
		return r;

	r = _rua_util_open_db(&db, SQLITE_OPEN_READONLY, uid, RUA_DB_NAME);
	if (r != SQLITE_OK)
		return -1;

	r = sqlite3_prepare(db, query, strlen(query), &stmt, NULL);
	if (r != SQLITE_OK) {
		sqlite3_close_v2(db);
		return -1;
	}

	r = sqlite3_step(stmt);
	if (r != SQLITE_ROW) {
		if (r != SQLITE_DONE)
			LOGE("step failed: %s", sqlite3_errmsg(db));
		sqlite3_finalize(stmt);
		sqlite3_close_v2(db);
		return -1;
	}

	ct = sqlite3_column_text(stmt, 0);
	if (ct == NULL || ct[0] == '\0')
		r = -1;
	else if (strncmp(pkg_name, (const char *)ct, strlen(pkg_name)) == 0)
		r = 0;
	else
		r = -1;

	sqlite3_finalize(stmt);
	sqlite3_close_v2(db);

	return r;
}

API int rua_is_latest_app(const char *pkg_name)
{
	return rua_is_latest_app_for_uid(pkg_name, getuid());
}

API int rua_init(void)
{
	return 0;
}

API int rua_fini(void)
{
	return 0;
}

API int rua_delete_history_with_instance_id(const char *app_id,
		const char *instance_id)
{
	int ret;
	bundle *b;

	if (app_id == NULL) {
		LOGE("Invalid parameter");
		return -1;
	}

	b = bundle_create();
	if (b == NULL) {
		LOGE("Out of memory");
		return -1;
	}

	bundle_add_str(b, AUL_K_RUA_PKGNAME, app_id);
	if (instance_id)
		bundle_add_str(b, AUL_K_RUA_INSTANCE_ID, instance_id);

	ret = aul_delete_rua_history_for_uid(b, getuid());
	bundle_free(b);
	if (ret < 0) {
		LOGE("Failed to delete rua history - result(%d)", ret);
		return -1;
	}

	return 0;
}