#include "job.h"

#include <string>
#include "utils.h"

namespace slack {

/**
 * Returns true if the package isn't filtered out by the filters, false
 * otherwise.
 */
bool
filter_package (PkBitfield filters, bool is_installed)
{
	if ((is_installed && !pk_bitfield_contain (filters, PK_FILTER_ENUM_NOT_INSTALLED))
			|| (!is_installed && !pk_bitfield_contain (filters, PK_FILTER_ENUM_INSTALLED)))
	{
		return true;
	}
	return false;
}

static std::string
generate_query(PkBitfield filters)
{
	std::string query(
			"SELECT (p1.name || ';' || p1.ver || ';' || p1.arch || ';' || r.repo), p1.summary, "
			"p1.full_name FROM pkglist AS p1 NATURAL JOIN repos AS r "
			"WHERE p1.%s LIKE '%%%q%%' AND p1.ext NOT LIKE 'obsolete' AND p1.repo_order = "
			"(SELECT MIN(p2.repo_order) FROM pkglist AS p2 WHERE p2.name = p1.name GROUP BY p2.name)");

	if (pk_bitfield_contain (filters, PK_FILTER_ENUM_APPLICATION))
	{
		query.append(
				" AND EXISTS (SELECT filelist.full_name "
				"FROM filelist "
				"WHERE filelist.full_name = p1.full_name "
				"AND filelist.filename LIKE 'usr/share/applications/%%.desktop')");
	}
	else if (pk_bitfield_contain (filters, PK_FILTER_ENUM_NOT_APPLICATION))
	{
		query.append(
				" AND NOT EXISTS (SELECT filelist.full_name "
				"FROM filelist "
				"WHERE filelist.full_name = p1.full_name "
				"AND filelist.filename LIKE 'usr/share/applications/%%.desktop')");
	}
	return query;
}

}

void
pk_backend_search_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
{
	auto job_data = reinterpret_cast<slack::JobData *> (pk_backend_job_get_user_data (job));

	pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
	pk_backend_job_set_percentage (job, 0);

	gchar **vals;
	PkBitfield filters;
	g_variant_get (params, "(t^a&s)", &filters, &vals);
	gchar *search = g_strjoinv ("%", vals);

	gchar *query = sqlite3_mprintf (slack::generate_query(filters).c_str(),
			user_data, search);

	sqlite3_stmt *stmt;
	if ((sqlite3_prepare_v2 (job_data->db, query, -1, &stmt, NULL) == SQLITE_OK))
	{
		/* Now we're ready to output all packages */
		while (sqlite3_step (stmt) == SQLITE_ROW)
		{
			PkInfoEnum info = slack::is_installed (
					reinterpret_cast<const gchar *> (sqlite3_column_text (stmt, 2)));

			if ((info == PK_INFO_ENUM_INSTALLED || info == PK_INFO_ENUM_UPDATING)
					&& slack::filter_package (filters, true))
			{
				pk_backend_job_package (job, PK_INFO_ENUM_INSTALLED,
						reinterpret_cast<const gchar *> (sqlite3_column_text (stmt, 0)),
				        reinterpret_cast<const gchar *> (sqlite3_column_text (stmt, 1)));
			}
			else if (info == PK_INFO_ENUM_INSTALLING && slack::filter_package (filters, false))
			{
				pk_backend_job_package(job, PK_INFO_ENUM_AVAILABLE,
						reinterpret_cast<const gchar *> (sqlite3_column_text (stmt, 0)),
						reinterpret_cast<const gchar *> (sqlite3_column_text (stmt, 1)));
			}
		}
		sqlite3_finalize (stmt);
	}
	else
	{
		pk_backend_job_error_code (job, PK_ERROR_ENUM_CANNOT_GET_FILELIST,
				"%s", sqlite3_errmsg (job_data->db));
	}

	sqlite3_free (query);
	g_free (search);

	pk_backend_job_set_percentage (job, 100);
}