Add currently existing PackageKit backend

1 files changed, 104 insertions, 0 deletions

diff --git a/backend/job.cc b/backend/job.cc
new file mode 100644
index 0000000..86468ea
--- /dev/null
+++ b/backend/job.cc
@@ -0,0 +1,104 @@
+#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);
+}