--- /dev/null
+commit b0ef064fb549eb7cb5ee1040494b50f473f8cc2c
+Author: Marcin Banasiak <marcin.banasiak@gmail.com>
+Date: Wed Oct 3 11:02:58 2012 +0200
+
+ poldek: remove UpdateSystem method
+
+diff --git a/backends/poldek/pk-backend-poldek.c b/backends/poldek/pk-backend-poldek.c
+index d167e07..f6c182f 100644
+--- a/backends/poldek/pk-backend-poldek.c
++++ b/backends/poldek/pk-backend-poldek.c
+@@ -1,6 +1,6 @@
+ /* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*-
+ *
+- * Copyright (C) 2008-2011 Marcin Banasiak <megabajt@pld-linux.org>
++ * Copyright (C) 2008-2012 Marcin Banasiak <megabajt@pld-linux.org>
+ *
+ * Licensed under the GNU General Public License Version 2
+ *
+@@ -1791,17 +1791,15 @@ static void
+ update_packages_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ {
+ struct vf_progress vf_progress;
+- gboolean update_system;
+ guint i, toupdate = 0;
+ gchar **package_ids, *command;
+ GString *cmd;
+
+- update_system = pk_backend_get_bool (backend, "update_system");
+ /* FIXME: support only_trusted */
+ package_ids = pk_backend_get_strv (backend, "package_ids");
+
+ /* sth goes wrong. package_ids has to be set in UpdatePackages */
+- if (update_system == FALSE && package_ids == NULL) {
++ if (package_ids == NULL) {
+ g_warning ("package_ids cannot be NULL in UpdatePackages method.");
+ pk_backend_job_finished (job);
+ return;
+@@ -1816,40 +1814,17 @@ update_packages_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+
+ cmd = g_string_new ("upgrade ");
+
+- if (update_system) {
+- tn_array *packages = NULL;
+-
+- if ((packages = execute_packages_command ("cd /all-avail; ls -q -u")) != NULL) {
+- /* UpdateSystem updates to the newest available packages */
+- do_newest (packages);
+-
+- for (i = 0; i < n_array_size (packages); i++) {
+- struct pkg *pkg = n_array_nth (packages, i);
+-
+- /* don't try to update blocked packages */
+- if (!(pkg->flags & PKG_HELD)) {
+- g_string_append_printf (cmd, "%s-%s-%s.%s ", pkg->name,
+- pkg->ver, pkg->rel, pkg_arch (pkg));
+-
+- toupdate++;
+- }
+- }
+-
+- n_array_free (packages);
+- }
+- } else {
+- for (i = 0; i < g_strv_length (package_ids); i++) {
+- struct pkg *pkg;
++ for (i = 0; i < g_strv_length (package_ids); i++) {
++ struct pkg *pkg;
+
+- pkg = poldek_get_pkg_from_package_id (package_ids[i]);
++ pkg = poldek_get_pkg_from_package_id (package_ids[i]);
+
+- g_string_append_printf (cmd, "%s-%s-%s.%s ", pkg->name,
+- pkg->ver, pkg->rel, pkg_arch (pkg));
++ g_string_append_printf (cmd, "%s-%s-%s.%s ", pkg->name,
++ pkg->ver, pkg->rel, pkg_arch (pkg));
+
+- toupdate++;
++ toupdate++;
+
+- pkg_free (pkg);
+- }
++ pkg_free (pkg);
+ }
+
+ command = g_string_free (cmd, FALSE);
+@@ -3187,27 +3162,6 @@ pk_backend_update_packages (PkBackend *backend, PkBackendJob *job, PkBitfield tr
+ }
+
+ /**
+- * pk_backend_update_system:
+- **/
+-void
+-pk_backend_update_system (PkBackend *backend, PkBackendJob *job, PkBitfield transaction_flags)
+-{
+- if (!pk_backend_is_online (backend)) {
+- pk_backend_job_error_code (job, PK_ERROR_ENUM_NO_NETWORK, "Cannot update system when offline!");
+- pk_backend_job_finished (job);
+- return;
+- }
+-
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
+- pb_error_clean ();
+-
+- poldek_backend_percentage_data_create (backend);
+- pk_backend_set_uint (backend, "ts_type", TS_TYPE_ENUM_UPDATE);
+- pk_backend_set_bool (backend, "update_system", TRUE);
+- pk_backend_job_thread_create (job, update_packages_thread, NULL, NULL);
+-}
+-
+-/**
+ * pk_backend_get_repo_list:
+ */
+ void
+commit 58c7e00f5f0889c5d44ac9ba68e50d25752cf9b9
+Author: Marcin Banasiak <marcin.banasiak@gmail.com>
+Date: Sun Oct 7 00:28:54 2012 +0200
+
+ poldek: port to the new API
+
+diff --git a/backends/poldek/pk-backend-poldek.c b/backends/poldek/pk-backend-poldek.c
+index f6c182f..7fe3d12 100644
+--- a/backends/poldek/pk-backend-poldek.c
++++ b/backends/poldek/pk-backend-poldek.c
+@@ -19,6 +19,9 @@
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ */
+
++#include <sys/types.h>
++#include <pwd.h>
++
+ #include <pk-backend.h>
+
+ #include <log.h>
+@@ -36,32 +39,45 @@
+ #include <sigint/sigint.h>
+
+ static gchar* poldek_pkg_evr (const struct pkg *pkg);
+-static void poldek_backend_package (PkBackend *backend, struct pkg *pkg, PkInfoEnum infoenum, PkBitfield filters);
++static void poldek_backend_package (PkBackendJob *job, struct pkg *pkg, PkInfoEnum infoenum, PkBitfield filters);
+ static long do_get_bytes_to_download (struct poldek_ts *ts, tn_array *pkgs);
+ static gint do_get_files_to_download (const struct poldek_ts *ts, const gchar *mark);
+-static void pb_load_packages (PkBackend *backend);
+-static void poldek_backend_set_allow_cancel (PkBackend *backend, gboolean allow_cancel, gboolean reset);
++static void pb_load_packages (PkBackendJob *job);
++static void poldek_backend_set_allow_cancel (PkBackendJob *job, gboolean allow_cancel, gboolean reset);
+
+-static void pb_error_show (PkBackend *backend, PkErrorEnum errorcode);
++static void pb_error_show (PkBackendJob *job, PkErrorEnum errorcode);
+ static void pb_error_clean (void);
+-static void poldek_backend_percentage_data_destroy (PkBackend *backend);
+
+-typedef enum {
+- TS_TYPE_ENUM_INSTALL,
+- TS_TYPE_ENUM_UPDATE,
+- TS_TYPE_ENUM_REMOVE,
+- TS_TYPE_ENUM_REFRESH_CACHE
+-} TsType;
+-
+-enum {
+- SEARCH_ENUM_NONE,
+- SEARCH_ENUM_NAME,
+- SEARCH_ENUM_GROUP,
+- SEARCH_ENUM_DETAILS,
+- SEARCH_ENUM_FILE,
+- SEARCH_ENUM_PROVIDES,
+- SEARCH_ENUM_RESOLVE
+-};
++typedef struct {
++ gint step; // current step
++
++ /* Numer of sources to update. It's used only by refresh cache,
++ * as each source can have multiple files to download. I don't
++ * know how to get numer of files which will be downloaded. */
++ guint nsources;
++
++ long bytesget;
++ long bytesdownload;
++
++ /* how many files I have already downloaded or which I'm currently
++ * downloading */
++ guint filesget;
++ /* how many files I have to download */
++ guint filesdownload;
++
++ gint percentage;
++ gint subpercentage;
++} PkBackendPoldekProgressData;
++
++typedef struct {
++ PkBackendPoldekProgressData *progress_data;
++
++ tn_array *to_install_pkgs;
++ tn_array *to_update_pkgs;
++ tn_array *to_remove_pkgs;
++
++ guint to_install;
++} PkBackendPoldekJobData;
+
+ typedef struct {
+ PkGroupEnum group;
+@@ -89,27 +105,6 @@ static PLDGroupRegex group_perlre[] = {
+ { 0, NULL }
+ };
+
+-typedef struct {
+- gint step; // current step
+-
+- /* Numer of sources to update. It's used only by refresh cache,
+- * as each source can have multiple files to download. I don't
+- * know how to get numer of files which will be downloaded. */
+- guint nsources;
+-
+- long bytesget;
+- long bytesdownload;
+-
+- /* how many files I have already downloaded or which I'm currently
+- * downloading */
+- guint filesget;
+- /* how many files I have to download */
+- guint filesdownload;
+-
+- gint percentage;
+- gint subpercentage;
+-} PercentageData;
+-
+ typedef enum {
+ PB_RPM_STATE_ENUM_NONE = 0,
+ PB_RPM_STATE_ENUM_INSTALLING = (1 << 1),
+@@ -255,7 +250,7 @@ cut_country_code (const gchar *lang)
+ * "pl.UTF-8", "pl_PL" and "pl". This array is needed by pkg_xuinf().
+ **/
+ static tn_array*
+-get_locale_variants (PkBackend *backend, const gchar *lang)
++get_locale_variants (const gchar *lang)
+ {
+ tn_array *langs;
+ gchar *copy;
+@@ -306,7 +301,7 @@ get_locale_variants (PkBackend *backend, const gchar *lang)
+ * Returns pointer to struct pkguinf with localized summary and description.
+ **/
+ static struct pkguinf*
+-pkg_uinf_i18n (PkBackend *backend, struct pkg *pkg)
++pkg_uinf_i18n (PkBackendJob *job, struct pkg *pkg)
+ {
+ struct pkguinf *pkgu = NULL;
+ gchar *lang = NULL;
+@@ -316,7 +311,7 @@ pkg_uinf_i18n (PkBackend *backend, struct pkg *pkg)
+ if (lang) {
+ tn_array *langs;
+
+- langs = get_locale_variants (backend, lang);
++ langs = get_locale_variants (lang);
+ pkgu = pkg_xuinf (pkg, langs);
+ } else {
+ pkgu = pkg_uinf (pkg);
+@@ -420,12 +415,14 @@ do_get_bytes_to_download (struct poldek_ts *ts, tn_array *pkgs)
+ * VF_PROGRESS
+ */
+ static void*
+-poldek_vf_progress_new (void *data, const gchar *label)
++poldek_vf_progress_new (void *user_data, const gchar *label)
+ {
+- PkBackend *backend = (PkBackend*) data;
+- guint ts_type = pk_backend_get_uint (backend, "ts_type");
++ PkBackendJob *job = (PkBackendJob *) user_data;
++ PkRoleEnum role;
++
++ role = pk_backend_job_get_role (job);
+
+- if (ts_type == TS_TYPE_ENUM_INSTALL || ts_type == TS_TYPE_ENUM_UPDATE) {
++ if (role == PK_ROLE_ENUM_INSTALL_PACKAGES || role == PK_ROLE_ENUM_UPDATE_PACKAGES) {
+ gchar *filename = g_path_get_basename (label), *pkgname;
+ tn_array *packages = NULL;
+
+@@ -436,7 +433,7 @@ poldek_vf_progress_new (void *data, const gchar *label)
+ if ((packages = execute_packages_command ("cd /all-avail; ls -q %s", pkgname)) != NULL) {
+ struct pkg *pkg = n_array_nth (packages, 0);
+
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_DOWNLOADING, PK_FILTER_ENUM_NONE);
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_DOWNLOADING, PK_FILTER_ENUM_NONE);
+
+ n_array_free (packages);
+ }
+@@ -445,17 +442,20 @@ poldek_vf_progress_new (void *data, const gchar *label)
+ g_free (filename);
+ }
+
+- return data;
++ return user_data;
+ }
+
+ static void
+-poldek_vf_progress (void *bar, long total, long amount)
++poldek_vf_progress (void *user_data, long total, long amount)
+ {
+- PkBackend *backend = (PkBackend*) bar;
+- PercentageData *pd = pk_backend_get_pointer (backend, "percentage_ptr");
+- guint ts_type = pk_backend_get_uint (backend, "ts_type");
++ PkBackendJob *job = (PkBackendJob *) user_data;
++ PkBackendPoldekJobData *job_data = pk_backend_job_get_user_data (job);
++ PkBackendPoldekProgressData *pd = job_data->progress_data;
++ PkRoleEnum role;
+
+- if (ts_type == TS_TYPE_ENUM_INSTALL || ts_type == TS_TYPE_ENUM_UPDATE) {
++ role = pk_backend_job_get_role (job);
++
++ if (role == PK_ROLE_ENUM_INSTALL_PACKAGES || role == PK_ROLE_ENUM_UPDATE_PACKAGES) {
+ float frac = (float)amount / (float)total;
+
+ /* file already downloaded */
+@@ -470,9 +470,9 @@ poldek_vf_progress (void *bar, long total, long amount)
+ pd->subpercentage = (gint)(frac * 100);
+ }
+
+- pk_backend_set_sub_percentage (backend, pd->subpercentage);
++ //pk_backend_set_sub_percentage (backend, pd->subpercentage);
+
+- } else if (ts_type == TS_TYPE_ENUM_REFRESH_CACHE) {
++ } else if (role == PK_ROLE_ENUM_REFRESH_CACHE) {
+ if (pd->step == 0)
+ pd->percentage = 1;
+ else
+@@ -483,11 +483,12 @@ poldek_vf_progress (void *bar, long total, long amount)
+ }
+
+ static void
+-poldek_vf_progress_reset (void *bar)
++poldek_vf_progress_reset (void *user_data)
+ {
+- PkBackend *backend = (PkBackend *) bar;
+- PercentageData *pd = pk_backend_get_pointer (backend, "percentage_ptr");
+- pd->subpercentage = 0;
++ PkBackendJob *job = (PkBackendJob *) user_data;
++ PkBackendPoldekJobData *job_data = pk_backend_job_get_user_data (job);
++
++ job_data->progress_data->subpercentage = 0;
+ }
+
+ /**
+@@ -525,21 +526,24 @@ poldek_pkg_in_array (const struct pkg *pkg, const tn_array *array, tn_fn_cmp cmp
+ }
+
+ static void
+-get_ts_summary (TsType type, tn_array *ipkgs, tn_array *dpkgs, tn_array *rpkgs,
++get_ts_summary (PkBackendJob *job, tn_array *ipkgs, tn_array *dpkgs, tn_array *rpkgs,
+ tn_array **install_pkgs, tn_array **update_pkgs, tn_array **remove_pkgs)
+ {
++ PkRoleEnum role;
+ guint i;
+
+- if (type == TS_TYPE_ENUM_INSTALL || type == TS_TYPE_ENUM_UPDATE) {
++ role = pk_backend_job_get_role (job);
++
++ if (role == PK_ROLE_ENUM_INSTALL_PACKAGES || role == PK_ROLE_ENUM_UPDATE_PACKAGES) {
+ *install_pkgs = n_array_new (2, (tn_fn_free)pkg_free, (tn_fn_cmp)pkg_cmp_name_evr);
+ *update_pkgs = n_array_new (2, (tn_fn_free)pkg_free, (tn_fn_cmp)pkg_cmp_name_evr);
+ }
+
+ *remove_pkgs = n_array_new (2, (tn_fn_free)pkg_free, (tn_fn_cmp)pkg_cmp_name_evr);
+
+- switch (type) {
+- case TS_TYPE_ENUM_INSTALL:
+- case TS_TYPE_ENUM_UPDATE:
++ switch (role) {
++ case PK_ROLE_ENUM_INSTALL_PACKAGES:
++ case PK_ROLE_ENUM_UPDATE_PACKAGES:
+ if (rpkgs) {
+ for (i = 0; i < n_array_size (rpkgs); i++) {
+ struct pkg *rpkg = n_array_nth (rpkgs, i);
+@@ -572,7 +576,7 @@ get_ts_summary (TsType type, tn_array *ipkgs, tn_array *dpkgs, tn_array *rpkgs,
+ }
+ }
+ break;
+- case TS_TYPE_ENUM_REMOVE:
++ case PK_ROLE_ENUM_REMOVE_PACKAGES:
+ /* copy packages from rpkgs and dpkgs to remove_pkgs */
+ if (rpkgs)
+ n_array_concat_ex (*remove_pkgs, rpkgs, (tn_fn_dup)pkg_link);
+@@ -582,7 +586,7 @@ get_ts_summary (TsType type, tn_array *ipkgs, tn_array *dpkgs, tn_array *rpkgs,
+
+ break;
+ default:
+- g_error ("Unknown ts_type value: %d", type);
++ g_error ("Unknown role value: %d", role);
+ }
+
+ /* return sorted arrays */
+@@ -604,8 +608,10 @@ get_ts_summary (TsType type, tn_array *ipkgs, tn_array *dpkgs, tn_array *rpkgs,
+ static int
+ ts_confirm (void *data, struct poldek_ts *ts)
+ {
++ PkBackendJob *job = (PkBackendJob *) data;
++ PkBackendPoldekJobData *job_data = pk_backend_job_get_user_data (job);
++ PkBackendPoldekProgressData *pd = job_data->progress_data;
+ tn_array *ipkgs, *dpkgs, *rpkgs;
+- PkBackend *backend = (PkBackend *)data;
+ size_t i = 0;
+ gint result = 1;
+
+@@ -615,7 +621,6 @@ ts_confirm (void *data, struct poldek_ts *ts)
+
+ if (poldek_ts_get_type (ts) == POLDEK_TS_TYPE_INSTALL) {
+ tn_array *update_pkgs, *remove_pkgs, *install_pkgs;
+- PercentageData *pd = pk_backend_get_pointer (backend, "percentage_ptr");
+ guint to_install = 0;
+
+ update_pkgs = n_array_new (4, (tn_fn_free)pkg_free, NULL);
+@@ -668,13 +673,23 @@ ts_confirm (void *data, struct poldek_ts *ts)
+ to_install = n_array_size (install_pkgs);
+ to_install += n_array_size (update_pkgs);
+
+- pk_backend_set_uint (backend, "to_install", to_install);
++ job_data->to_install = to_install;
+
+- pk_backend_set_pointer (backend, "to_update_pkgs", update_pkgs);
+- pk_backend_set_pointer (backend, "to_remove_pkgs", remove_pkgs);
+- pk_backend_set_pointer (backend, "to_install_pkgs", install_pkgs);
++ job_data->to_update_pkgs = update_pkgs;
++ job_data->to_remove_pkgs = remove_pkgs;
++ job_data->to_install_pkgs = install_pkgs;
+ } else if (poldek_ts_get_type (ts) == POLDEK_TS_TYPE_UNINSTALL) {
+- gboolean allow_deps = pk_backend_get_bool (backend, "allow_deps");
++ GVariant *params = pk_backend_job_get_parameters (job);
++ PkBitfield transaction_flags;
++ gchar **package_ids;
++ gboolean allow_deps;
++ gboolean autoremove;
++
++ g_variant_get (params, "(t^a&sbb)",
++ &transaction_flags,
++ &package_ids,
++ &allow_deps,
++ &autoremove);
+
+ /* check if transaction can be performed */
+ if (allow_deps == FALSE) {
+@@ -687,13 +702,13 @@ ts_confirm (void *data, struct poldek_ts *ts)
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_REMOVE);
+
+ /* we shouldn't cancel remove proccess */
+- poldek_backend_set_allow_cancel (backend, FALSE, FALSE);
++ poldek_backend_set_allow_cancel (job, FALSE, FALSE);
+
+ if (dpkgs) {
+ for (i = 0; i < n_array_size (dpkgs); i++) {
+ struct pkg *pkg = n_array_nth (dpkgs, i);
+
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_REMOVING, PK_FILTER_ENUM_NONE);
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_REMOVING, PK_FILTER_ENUM_NONE);
+ }
+ }
+
+@@ -701,7 +716,7 @@ ts_confirm (void *data, struct poldek_ts *ts)
+ for (i = 0; i < n_array_size (rpkgs); i++) {
+ struct pkg *pkg = n_array_nth (rpkgs, i);
+
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_REMOVING, PK_FILTER_ENUM_NONE);
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_REMOVING, PK_FILTER_ENUM_NONE);
+ }
+ }
+ }
+@@ -728,9 +743,9 @@ suggests_callback (void *data, const struct poldek_ts *ts, const struct pkg *pkg
+ * setup_vf_progress:
+ */
+ static void
+-setup_vf_progress (struct vf_progress *vf_progress, PkBackend *backend)
++setup_vf_progress (struct vf_progress *vf_progress, PkBackendJob *job)
+ {
+- vf_progress->data = backend;
++ vf_progress->data = job;
+ vf_progress->new = poldek_vf_progress_new;
+ vf_progress->progress = poldek_vf_progress;
+ vf_progress->reset = poldek_vf_progress_reset;
+@@ -792,14 +807,10 @@ pkg_is_installed (struct pkg *pkg)
+ {
+ struct pkgdb *db;
+ gint cmprc, is_installed = 0;
+- struct poldek_ts *ts;
+
+ g_return_val_if_fail (pkg != NULL, FALSE);
+
+- /* XXX: I don't know how to get ctx->rootdir */
+- ts = poldek_ts_new (ctx, 0);
+-
+- db = pkgdb_open (ts->pmctx, ts->rootdir, NULL, O_RDONLY, NULL);
++ db = pkgdb_open (poldek_get_pmctx (ctx), NULL, NULL, O_RDONLY, NULL);
+
+ if (db) {
+ is_installed = pkgdb_is_pkg_installed (db, pkg, &cmprc);
+@@ -807,8 +818,6 @@ pkg_is_installed (struct pkg *pkg)
+ pkgdb_free (db);
+ }
+
+- poldek_ts_free (ts);
+-
+ return is_installed ? TRUE : FALSE;
+ }
+
+@@ -1205,15 +1214,12 @@ do_filtering (tn_array *packages, PkBitfield filters)
+ */
+ static void
+ do_requires (tn_array *installed, tn_array *available, tn_array *requires,
+- struct pkg *pkg, PkBackend *backend)
++ struct pkg *pkg, PkBitfield filters, gboolean recursive)
+ {
+ tn_array *tmp = NULL;
+ size_t i;
+- PkBitfield filters;
+- gboolean recursive;
+
+ tmp = n_array_new (2, NULL, NULL);
+- filters = pk_backend_get_uint (backend, "filters");
+
+ /* if ~installed doesn't exists in filters, we can query installed */
+ if (!pk_bitfield_contain (filters, PK_FILTER_ENUM_NOT_INSTALLED)) {
+@@ -1284,11 +1290,10 @@ do_requires (tn_array *installed, tn_array *available, tn_array *requires,
+
+ /* FIXME: recursive takes too much time for available packages, so don't use it */
+ if (pk_bitfield_contain (filters, PK_FILTER_ENUM_INSTALLED)) {
+- recursive = pk_backend_get_bool (backend, "recursive");
+ if (recursive && tmp && n_array_size (tmp) > 0) {
+ for (i = 0; i < n_array_size (tmp); i++) {
+ struct pkg *p = n_array_nth (tmp, i);
+- do_requires (installed, available, requires, p, backend);
++ do_requires (installed, available, requires, p, filters, recursive);
+ }
+ }
+ }
+@@ -1300,17 +1305,13 @@ do_requires (tn_array *installed, tn_array *available, tn_array *requires,
+ * do_depends:
+ */
+ static void
+-do_depends (tn_array *installed, tn_array *available, tn_array *depends, struct pkg *pkg, PkBackend *backend)
++do_depends (tn_array *installed, tn_array *available, tn_array *depends, struct pkg *pkg, PkBitfield filters, gboolean recursive)
+ {
+ tn_array *reqs = pkg->reqs;
+ tn_array *tmp = NULL;
+ size_t i;
+- PkBitfield filters;
+- gboolean recursive;
+
+ tmp = n_array_new (2, NULL, NULL);
+- filters = pk_backend_get_uint (backend, "filters");
+- recursive = pk_backend_get_bool (backend, "recursive");
+
+ /* nothing to do */
+ if (!reqs || (reqs && n_array_size (reqs) < 1))
+@@ -1403,7 +1404,7 @@ do_depends (tn_array *installed, tn_array *available, tn_array *depends, struct
+ for (i = 0; i < n_array_size (tmp); i++) {
+ struct pkg *p = n_array_nth (tmp, i);
+
+- do_depends (installed, available, depends, p, backend);
++ do_depends (installed, available, depends, p, filters, recursive);
+ }
+ }
+
+@@ -1451,7 +1452,7 @@ package_id_from_pkg (struct pkg *pkg, const gchar *repo, PkBitfield filters)
+ * poldek_backend_package:
+ */
+ static void
+-poldek_backend_package (PkBackend *backend, struct pkg *pkg, PkInfoEnum infoenum, PkBitfield filters)
++poldek_backend_package (PkBackendJob *job, struct pkg *pkg, PkInfoEnum infoenum, PkBitfield filters)
+ {
+ struct pkguinf *pkgu = NULL;
+ gchar *package_id;
+@@ -1472,7 +1473,7 @@ poldek_backend_package (PkBackend *backend, struct pkg *pkg, PkInfoEnum infoenum
+
+ package_id = package_id_from_pkg (pkg, NULL, filters);
+
+- if ((pkgu = pkg_uinf_i18n (backend, pkg))) {
++ if ((pkgu = pkg_uinf_i18n (job, pkg))) {
+ pk_backend_job_package (job, infoenum, package_id, pkguinf_get (pkgu, PKGUINF_SUMMARY));
+
+ pkguinf_free (pkgu);
+@@ -1564,30 +1565,39 @@ do_search_details (const gchar *tree, gchar **values)
+ static void
+ search_package_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ {
++ GPtrArray *array = NULL;
+ PkBitfield filters;
+- PkProvidesEnum provides;
++ PkRoleEnum role;
+ gchar *search_cmd_available = NULL;
+ gchar *search_cmd_installed = NULL;
+ tn_array *pkgs = NULL;
+ gchar **values = NULL;
+ gchar *search;
+- guint mode;
+
+- pb_load_packages (backend);
++ role = pk_backend_job_get_role (job);
+
+- mode = pk_backend_get_uint (backend, "mode");
+- filters = pk_backend_get_uint (backend, "filters");
++ if (role == PK_ROLE_ENUM_WHAT_PROVIDES) {
++ array = (GPtrArray *) user_data;
+
+- values = pk_backend_get_strv (backend, "search");
++ g_ptr_array_add (array, NULL);
+
+- if (values == NULL) {
+- pk_backend_job_error_code (job, PK_ERROR_ENUM_INTERNAL_ERROR,
+- "failed to get 'search'");
+- goto out;
++ values = (gchar **) array->pdata;
++
++ g_variant_get (params, "(t)",
++ &filters);
++
++ g_ptr_array_free (array, FALSE);
++ } else {
++ g_variant_get (params, "(t^a&s)",
++ &filters,
++ &values);
+ }
+
++
++ pb_load_packages (job);
++
+ /* SearchName */
+- if (mode == SEARCH_ENUM_NAME) {
++ if (role == PK_ROLE_ENUM_SEARCH_NAME) {
+ search = g_strjoinv ("*", values);
+
+ search_cmd_installed = g_strdup_printf ("ls -q *%s*", search);
+@@ -1595,7 +1605,7 @@ search_package_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+
+ g_free (search);
+ /* SearchGroup */
+- } else if (mode == SEARCH_ENUM_GROUP) {
++ } else if (role == PK_ROLE_ENUM_SEARCH_GROUP) {
+ GString *command;
+ guint i;
+
+@@ -1624,7 +1634,7 @@ search_package_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ search_cmd_installed = g_string_free (command, FALSE);
+ search_cmd_available = g_strdup (search_cmd_installed);
+ /* SearchFile */
+- } else if (mode == SEARCH_ENUM_FILE) {
++ } else if (role == PK_ROLE_ENUM_SEARCH_FILE) {
+ GString *local_pkgs = NULL;
+ GString *installed_pkgs = NULL;
+ GString *available_pkgs = NULL;
+@@ -1676,7 +1686,7 @@ search_package_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ search_cmd_available = g_string_free (available_pkgs, FALSE);
+
+ /* WhatProvides */
+- } else if (mode == SEARCH_ENUM_PROVIDES) {
++ } else if (role == PK_ROLE_ENUM_WHAT_PROVIDES) {
+ search = g_strjoinv ("\\|", values);
+
+ search_cmd_installed = g_strdup_printf ("search -qp --perlre /%s/", search);
+@@ -1684,7 +1694,7 @@ search_package_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+
+ g_free (search);
+ /* Resolve */
+- } else if (mode == SEARCH_ENUM_RESOLVE) {
++ } else if (role == PK_ROLE_ENUM_RESOLVE) {
+ search = g_strjoinv(" ", values);
+
+ search_cmd_installed = g_strdup_printf ("ls -q %s", search);
+@@ -1693,19 +1703,19 @@ search_package_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ g_free (search);
+ }
+
+- if ((search_cmd_installed != NULL && search_cmd_available != NULL) || mode == SEARCH_ENUM_DETAILS) {
++ if ((search_cmd_installed != NULL && search_cmd_available != NULL) || role == PK_ROLE_ENUM_SEARCH_DETAILS) {
+ tn_array *installed = NULL;
+ tn_array *available = NULL;
+
+ if (!pk_bitfield_contain (filters, PK_FILTER_ENUM_NOT_INSTALLED)) {
+- if (mode == SEARCH_ENUM_DETAILS)
++ if (role == PK_ROLE_ENUM_SEARCH_DETAILS)
+ installed = do_search_details ("cd /installed", values);
+ else
+ installed = execute_packages_command ("cd /installed; %s", search_cmd_installed);
+ }
+
+ if (!pk_bitfield_contain (filters, PK_FILTER_ENUM_INSTALLED)) {
+- if (mode == SEARCH_ENUM_DETAILS)
++ if (role == PK_ROLE_ENUM_SEARCH_DETAILS)
+ available = do_search_details ("cd /all-avail", values);
+ else
+ available = execute_packages_command ("cd /all-avail; %s", search_cmd_available);
+@@ -1759,7 +1769,7 @@ search_package_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ if (sigint_reached ())
+ break;
+
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_UNKNOWN, filters);
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_UNKNOWN, filters);
+ }
+ n_array_free (pkgs);
+ } else {
+@@ -1767,12 +1777,12 @@ search_package_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ }
+
+ if (sigint_reached ()) {
+- switch (mode) {
+- case SEARCH_ENUM_NAME:
+- case SEARCH_ENUM_GROUP:
+- case SEARCH_ENUM_DETAILS:
+- case SEARCH_ENUM_FILE:
+- case SEARCH_ENUM_RESOLVE:
++ switch (role) {
++ case PK_ROLE_ENUM_SEARCH_NAME:
++ case PK_ROLE_ENUM_SEARCH_GROUP:
++ case PK_ROLE_ENUM_SEARCH_DETAILS:
++ case PK_ROLE_ENUM_SEARCH_FILE:
++ case PK_ROLE_ENUM_RESOLVE:
+ pk_backend_job_error_code (job, PK_ERROR_ENUM_TRANSACTION_CANCELLED, "Search cancelled.");
+ break;
+ default:
+@@ -1784,6 +1794,9 @@ search_package_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ g_free (search_cmd_available);
+
+ out:
++ if (array)
++ g_ptr_array_unref (array);
++
+ pk_backend_job_finished (job);
+ }
+
+@@ -1794,26 +1807,25 @@ update_packages_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ guint i, toupdate = 0;
+ gchar **package_ids, *command;
+ GString *cmd;
++ PkBitfield transaction_flags;
+
+- /* FIXME: support only_trusted */
+- package_ids = pk_backend_get_strv (backend, "package_ids");
+-
+- /* sth goes wrong. package_ids has to be set in UpdatePackages */
+- if (package_ids == NULL) {
+- g_warning ("package_ids cannot be NULL in UpdatePackages method.");
+- pk_backend_job_finished (job);
+- return;
+- }
++ g_variant_get (params, "(t^a&s)",
++ &transaction_flags,
++ &package_ids);
+
+- setup_vf_progress (&vf_progress, backend);
++ setup_vf_progress (&vf_progress, job);
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_DEP_RESOLVE);
+ pb_error_clean ();
+
+ cmd = g_string_new ("upgrade ");
+
++ if (pk_bitfield_contain (transaction_flags, PK_TRANSACTION_FLAG_ENUM_ONLY_DOWNLOAD)) {
++ g_string_append_printf (cmd, "--fetch ");
++ }
++
+ for (i = 0; i < g_strv_length (package_ids); i++) {
+ struct pkg *pkg;
+
+@@ -1831,35 +1843,144 @@ update_packages_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+
+ if (toupdate > 0) {
+ if (execute_command (command) == FALSE) {
+- pb_error_show (backend, PK_ERROR_ENUM_TRANSACTION_ERROR);
++ pb_error_show (job, PK_ERROR_ENUM_TRANSACTION_ERROR);
+ }
+ }
+
+- poldek_backend_percentage_data_destroy (backend);
+-
+ g_free (command);
+
+ pk_backend_job_finished (job);
+ }
+
++/**
++ * do_simulate_packages:
++ */
++static void
++do_simulate_packages (PkBackendJob *job, GVariant *params, gpointer user_data)
++{
++ struct poclidek_rcmd *rcmd = NULL;
++ struct poldek_ts *ts = NULL;
++ GString *buf = NULL;
++ gchar *cmd = NULL;
++ gchar **package_ids = NULL;
++ const gchar *command = NULL;
++ guint i;
++ PkRoleEnum role;
++ PkBitfield transaction_flags;
++ gboolean allow_deps = FALSE;
++ gboolean autoremove = FALSE;
++
++ role = pk_backend_job_get_role (job);
++
++ if (role == PK_ROLE_ENUM_INSTALL_PACKAGES) {
++ command = "cd /all-avail; install --test";
++
++ g_variant_get (params, "(t^a&s)",
++ &transaction_flags,
++ &package_ids);
++ } else if (role == PK_ROLE_ENUM_UPDATE_PACKAGES) {
++ command = "cd /all-avail; upgrade --test";
++
++ g_variant_get (params, "(t^a&s)",
++ &transaction_flags,
++ &package_ids);
++ } else if (role == PK_ROLE_ENUM_REMOVE_PACKAGES) {
++ command = "cd /all-avail; uninstall --test";
++
++ g_variant_get (params, "(t^a&sbb)",
++ &transaction_flags,
++ &package_ids,
++ &allow_deps,
++ &autoremove);
++ }
++
++ pk_backend_job_set_status (job, PK_STATUS_ENUM_DEP_RESOLVE);
++
++ buf = g_string_new (command);
++
++ for (i = 0; i < g_strv_length (package_ids); i++) {
++ gchar *nvra = poldek_get_nvra_from_package_id (package_ids[i]);
++
++ g_string_append_c (buf, ' ');
++ g_string_append (buf, nvra);
++
++ g_free (nvra);
++ }
++
++ cmd = g_string_free (buf, FALSE);
++
++ ts = poldek_ts_new (ctx, 0);
++ rcmd = poclidek_rcmd_new (cctx, ts);
++
++ ts->setop(ts, POLDEK_OP_PARTICLE, 0);
++
++ if (poclidek_rcmd_execline (rcmd, cmd)) {
++ tn_array *ipkgs = NULL, *dpkgs = NULL, *rpkgs = NULL;
++ tn_array *install_pkgs = NULL, *update_pkgs = NULL, *remove_pkgs = NULL;
++
++ ipkgs = poldek_ts_get_summary (ts, "I");
++ dpkgs = poldek_ts_get_summary (ts, "D");
++ rpkgs = poldek_ts_get_summary (ts, "R");
++
++ get_ts_summary (job, ipkgs, dpkgs, rpkgs, &install_pkgs, &update_pkgs, &remove_pkgs);
++
++ if (install_pkgs) {
++ for (i = 0; i < n_array_size (install_pkgs); i++) {
++ struct pkg *pkg = n_array_nth (install_pkgs, i);
++
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_INSTALLING, PK_FILTER_ENUM_NONE);
++ }
++
++ n_array_free (install_pkgs);
++ }
++
++ if (update_pkgs) {
++ for (i = 0; i < n_array_size (update_pkgs); i++) {
++ struct pkg *pkg = n_array_nth (update_pkgs, i);
++
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_UPDATING, PK_FILTER_ENUM_NONE);
++ }
++
++ n_array_free (update_pkgs);
++ }
++
++ if (remove_pkgs) {
++ for (i = 0; i < n_array_size (remove_pkgs); i++) {
++ struct pkg *pkg = n_array_nth (remove_pkgs, i);
++
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_REMOVING, PK_FILTER_ENUM_NONE);
++ }
++
++ n_array_free (remove_pkgs);
++ }
++ }
++
++ g_free (cmd);
++
++ poclidek_rcmd_free (rcmd);
++ poldek_ts_free (ts);
++
++ pk_backend_job_finished (job);
++}
++
+ static void
+-pb_load_packages (PkBackend *backend)
++pb_load_packages (PkBackendJob *job)
+ {
+- gboolean allow_cancel = pk_backend_job_get_allow_cancel (backend);
++ gboolean allow_cancel = pk_backend_job_get_allow_cancel (job);
+
+ /* this operation can't be cancelled, so if enabled, set allow_cancel to FALSE */
+ if (allow_cancel)
+- poldek_backend_set_allow_cancel (backend, FALSE, FALSE);
++ poldek_backend_set_allow_cancel (job, FALSE, FALSE);
+
+ /* load information about installed and available packages */
+ poclidek_load_packages (cctx, POCLIDEK_LOAD_ALL);
+
+ if (allow_cancel)
+- poldek_backend_set_allow_cancel (backend, TRUE, FALSE);
++ poldek_backend_set_allow_cancel (job, TRUE, FALSE);
+ }
+
+ static void
+-pb_error_show (PkBackend *backend, PkErrorEnum errorcode)
++pb_error_show (PkBackendJob *job, PkErrorEnum errorcode)
+ {
+ if (sigint_reached()) {
+ pk_backend_job_error_code (job, PK_ERROR_ENUM_TRANSACTION_CANCELLED, "Action cancelled.");
+@@ -1883,7 +2004,7 @@ pb_error_show (PkBackend *backend, PkErrorEnum errorcode)
+ * This function checks if it happens and if yes, emits error_code and returns TRUE.
+ **/
+ static gboolean
+-pb_error_check (PkBackend *backend)
++pb_error_check (PkBackendJob *job)
+ {
+ PkErrorEnum errorcode = PK_ERROR_ENUM_UNKNOWN;
+
+@@ -1919,25 +2040,24 @@ pkg_n_strncmp (struct pkg *p, gchar *name)
+ }
+
+ static void
+-show_rpm_progress (PkBackend *backend, gchar *message)
++show_rpm_progress (PkBackendJob *job, gchar *message)
+ {
++ PkBackendPoldekJobData *job_data = pk_backend_job_get_user_data (job);
++
+ g_return_if_fail (message != NULL);
+
+ if (pberror->rpmstate & PB_RPM_STATE_ENUM_REPACKAGING) {
+ g_debug ("repackaging '%s'", message);
+ } else if (pberror->rpmstate & PB_RPM_STATE_ENUM_INSTALLING) {
+ tn_array *upkgs, *ipkgs, *rpkgs, *arr = NULL;
+- guint to_install;
+ PkInfoEnum pkinfo;
+ gint n = -2;
+
+ g_debug ("installing or updating '%s'", message);
+
+- to_install = pk_backend_get_uint (backend, "to_install");
+-
+- ipkgs = pk_backend_get_pointer (backend, "to_install_pkgs");
+- upkgs = pk_backend_get_pointer (backend, "to_update_pkgs");
+- rpkgs = pk_backend_get_pointer (backend, "to_remove_pkgs");
++ ipkgs = job_data->to_install_pkgs;
++ upkgs = job_data->to_update_pkgs;
++ rpkgs = job_data->to_remove_pkgs;
+
+ /* emit remove for packages marked for removal */
+ if (rpkgs) {
+@@ -1947,7 +2067,7 @@ show_rpm_progress (PkBackend *backend, gchar *message)
+ for (i = 0; i < n_array_size (rpkgs); i++) {
+ struct pkg *pkg = n_array_nth (rpkgs, i);
+
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_REMOVING, PK_FILTER_ENUM_NONE);
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_REMOVING, PK_FILTER_ENUM_NONE);
+
+ n_array_remove_nth (rpkgs, i);
+ }
+@@ -1973,7 +2093,7 @@ show_rpm_progress (PkBackend *backend, gchar *message)
+ struct pkg *pkg = n_array_nth (arr, n);
+ guint in_arrays = 0;
+
+- poldek_backend_package (backend, pkg, pkinfo, PK_FILTER_ENUM_NONE);
++ poldek_backend_package (job, pkg, pkinfo, PK_FILTER_ENUM_NONE);
+
+ n_array_remove_nth (arr, n);
+
+@@ -1984,7 +2104,7 @@ show_rpm_progress (PkBackend *backend, gchar *message)
+ in_arrays += n_array_size (ipkgs);
+ }
+
+- pk_backend_job_set_percentage (job, (gint)(((float)(to_install - in_arrays) / (float)to_install) * 100));
++ pk_backend_job_set_percentage (job, (gint)(((float)(job_data->to_install - in_arrays) / (float)job_data->to_install) * 100));
+ }
+ }
+ }
+@@ -2022,7 +2142,7 @@ get_filename_from_message (char *message)
+ static void
+ poldek_backend_log (void *data, int pri, char *message)
+ {
+- PkBackend *backend = (PkBackend*)data;
++ PkBackendJob *job = (PkBackendJob *) data;
+
+ /* skip messages that we don't want to show */
+ if (g_str_has_prefix (message, "Nothing")) // 'Nothing to do'
+@@ -2063,7 +2183,7 @@ poldek_backend_log (void *data, int pri, char *message)
+ pberror->rpmstate |= PB_RPM_STATE_ENUM_INSTALLING;
+
+ /* we shouldn't cancel install / update proccess */
+- poldek_backend_set_allow_cancel (backend, FALSE, FALSE);
++ poldek_backend_set_allow_cancel (job, FALSE, FALSE);
+ } else if (strstr (message, "Repackaging...")) {
+ pberror->rpmstate |= PB_RPM_STATE_ENUM_REPACKAGING;
+
+@@ -2078,22 +2198,22 @@ poldek_backend_log (void *data, int pri, char *message)
+ return;
+
+ if ((pberror->rpmstate & PB_RPM_STATE_ENUM_REPACKAGING) == FALSE) {
+- guint ts_type = pk_backend_get_uint (backend, "ts_type");
++ PkRoleEnum role = pk_backend_job_get_role (job);
+
+ /* set proper status */
+- if (ts_type == TS_TYPE_ENUM_INSTALL) {
++ if (role == PK_ROLE_ENUM_INSTALL_PACKAGES) {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_INSTALL);
+- } else if (ts_type == TS_TYPE_ENUM_UPDATE) {
++ } else if (role == PK_ROLE_ENUM_UPDATE_PACKAGES) {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_UPDATE);
+ }
+ }
+
+- show_rpm_progress (backend, fn);
++ show_rpm_progress (job, fn);
+ }
+ }
+
+ static void
+-poldek_backend_set_allow_cancel (PkBackend *backend, gboolean allow_cancel, gboolean reset)
++poldek_backend_set_allow_cancel (PkBackendJob *job, gboolean allow_cancel, gboolean reset)
+ {
+ if (reset)
+ sigint_reset ();
+@@ -2102,34 +2222,6 @@ poldek_backend_set_allow_cancel (PkBackend *backend, gboolean allow_cancel, gboo
+ }
+
+ static void
+-poldek_backend_percentage_data_create (PkBackend *backend)
+-{
+- PercentageData *data;
+-
+- data = g_new0 (PercentageData, 1);
+- pk_backend_set_pointer (backend, "percentage_ptr", data);
+-}
+-
+-static void
+-poldek_backend_percentage_data_destroy (PkBackend *backend)
+-{
+- PercentageData *data;
+- tn_array *upkgs, *ipkgs, *rpkgs;
+-
+- data = (gpointer) pk_backend_get_pointer (backend, "percentage_ptr");
+-
+- upkgs = (gpointer) pk_backend_get_pointer (backend, "to_update_pkgs");
+- ipkgs = (gpointer) pk_backend_get_pointer (backend, "to_install_pkgs");
+- rpkgs = (gpointer) pk_backend_get_pointer (backend, "to_remove_pkgs");
+-
+- n_array_cfree (&upkgs);
+- n_array_cfree (&ipkgs);
+- n_array_cfree (&rpkgs);
+-
+- g_free (data);
+-}
+-
+-static void
+ do_poldek_init (PkBackend *backend)
+ {
+ poldeklib_init ();
+@@ -2147,8 +2239,6 @@ do_poldek_init (PkBackend *backend)
+ poldek_configure (ctx, POLDEK_CONF_LOGFILE, NULL);
+ poldek_configure (ctx, POLDEK_CONF_LOGTTY, NULL);
+
+- poldek_log_set_appender ("PackageKit", (void *)backend, NULL, 0, (poldek_vlog_fn)poldek_backend_log);
+-
+ /* disable unique package names */
+ poldek_configure (ctx, POLDEK_CONF_OPT, POLDEK_OP_UNIQN, 0);
+
+@@ -2160,7 +2250,6 @@ do_poldek_init (PkBackend *backend)
+ /* (...), but we don't need choose_equiv callback */
+ poldek_configure (ctx, POLDEK_CONF_OPT, POLDEK_OP_EQPKG_ASKUSER, 0);
+
+- poldek_configure (ctx, POLDEK_CONF_TSCONFIRM_CB, ts_confirm, backend);
+ /* Install all suggested packages by default */
+ poldek_configure (ctx, POLDEK_CONF_CHOOSESUGGESTS_CB, suggests_callback, NULL);
+
+@@ -2179,12 +2268,12 @@ do_poldek_destroy (PkBackend *backend)
+ }
+
+ static void
+-poldek_reload (PkBackend *backend, gboolean load_packages) {
+- do_poldek_destroy (backend);
+- do_poldek_init (backend);
++poldek_reload (PkBackendJob *job, gboolean load_packages) {
++ do_poldek_destroy (pk_backend_job_get_backend (job));
++ do_poldek_init (pk_backend_job_get_backend (job));
+
+ if (load_packages)
+- pb_load_packages (backend);
++ pb_load_packages (job);
+ }
+
+ /**
+@@ -2211,15 +2300,18 @@ pk_backend_get_author (PkBackend *backend)
+ void
+ pk_backend_initialize (PkBackend *backend)
+ {
++ struct passwd *uid_ent = NULL;
++
+ g_debug ("backend initalize start");
+
+- clv = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, (GDestroyNotify)n_array_free);
++ /* looks like rpm5 needs HOME to be set */
++ if ((uid_ent = getpwuid (getuid ())) == NULL) {
++ g_error ("Failed to set HOME");
++ }
++
++ setenv ("HOME", uid_ent->pw_dir, 0);
+
+- /* BACKEND MAINTAINER: feel free to remove this when you've
+- * added support for ONLY_DOWNLOAD and merged the simulate
+- * methods as specified in backends/PORTING.txt */
+- g_error ("Backend needs to be ported to 0.8.x -- "
+- "see backends/PORTING.txt for details");
++ clv = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, (GDestroyNotify)n_array_free);
+
+ pberror = g_new0 (PbError, 1);
+ pberror->tslog = g_string_new ("");
+@@ -2246,6 +2338,44 @@ pk_backend_destroy (PkBackend *backend)
+ }
+
+ /**
++ * pk_backend_start_job:
++ */
++void
++pk_backend_start_job (PkBackend *backend, PkBackendJob *job)
++{
++ PkBackendPoldekJobData *job_data;
++
++ job_data = g_new0 (PkBackendPoldekJobData, 1);
++ pk_backend_job_set_user_data (job, job_data);
++
++ job_data->progress_data = g_new0 (PkBackendPoldekProgressData, 1);
++
++ poldek_log_set_appender ("PackageKit", (void *) job, NULL, 0, (poldek_vlog_fn) poldek_backend_log);
++
++ poldek_configure (ctx, POLDEK_CONF_TSCONFIRM_CB, ts_confirm, job);
++}
++
++/**
++ * pk_backend_stop_job:
++ */
++void
++pk_backend_stop_job (PkBackend *backend, PkBackendJob *job)
++{
++ PkBackendPoldekJobData *job_data = pk_backend_job_get_user_data (job);
++
++ if (job_data->progress_data != NULL)
++ g_free (job_data->progress_data);
++
++ n_array_cfree (&job_data->to_install_pkgs);
++ n_array_cfree (&job_data->to_update_pkgs);
++ n_array_cfree (&job_data->to_remove_pkgs);
++
++ g_free (job_data);
++
++ pk_backend_job_set_user_data (job, NULL);
++}
++
++/**
+ * pk_backend_get_groups:
+ */
+ PkBitfield
+@@ -2315,24 +2445,26 @@ pk_backend_cancel (PkBackend *backend, PkBackendJob *job)
+ static void
+ backend_download_packages_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ {
+- PercentageData *pd = pk_backend_get_pointer (backend, "percentage_ptr");
++ PkBackendPoldekJobData *job_data = pk_backend_job_get_user_data (job);
++ PkBackendPoldekProgressData *pd = job_data->progress_data;
+ struct poldek_ts *ts;
+ struct vf_progress vf_progress;
+ tn_array *pkgs;
+ gchar **package_ids;
+ const gchar *destdir;
+- size_t i;
++ guint i;
+
+- package_ids = pk_backend_get_strv (backend, "package_ids");
+- destdir = pk_backend_get_string (backend, "directory");
++ g_variant_get (params, "(^a&ss)",
++ &package_ids,
++ &destdir);
+
+ pkgs = n_array_new (10, (tn_fn_free)pkg_free, NULL);
+
+ ts = poldek_ts_new (ctx, 0);
+
+- setup_vf_progress (&vf_progress, backend);
++ setup_vf_progress (&vf_progress, job);
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ for (i = 0; i < g_strv_length (package_ids); i++) {
+ struct pkg *pkg = poldek_get_pkg_from_package_id (package_ids[i]);
+@@ -2346,34 +2478,24 @@ backend_download_packages_thread (PkBackendJob *job, GVariant *params, gpointer
+ pd->bytesdownload = poldek_get_bytes_to_download (ts, pkgs);
+
+ if (packages_fetch (poldek_get_pmctx (ts->ctx), pkgs, destdir, 1)) {
+- GString *filelist = NULL;
+- gchar *result = NULL;
+-
+- filelist = g_string_new ("");
+-
+- /* emit the file list we downloaded */
+ for (i = 0; i < n_array_size (pkgs); i++) {
+ struct pkg *pkg = n_array_nth (pkgs, i);
++ gchar *package_id;
++ gchar *path;
+ gchar buf[256];
+
+- if (i > 0)
+- g_string_append_c (filelist, ';');
+-
+- g_string_append_printf (filelist, "%s/%s", destdir,
+- pkg_filename (pkg, buf, sizeof(buf)));
+- }
++ package_id = package_id_from_pkg (pkg, NULL, PK_FILTER_ENUM_NONE);
++ path = g_build_filename (destdir, pkg_filename (pkg, buf, sizeof (buf)), NULL);
+
+- result = g_string_free (filelist, FALSE);
++ pk_backend_job_files (job, package_id, path);
+
+- pk_backend_job_files (job, NULL, result);
+-
+- g_free (result);
++ g_free (package_id);
++ g_free (path);
++ }
+ }
+
+ poldek_ts_free (ts);
+
+- poldek_backend_percentage_data_destroy (backend);
+-
+ pk_backend_job_finished (job);
+ }
+
+@@ -2382,10 +2504,9 @@ pk_backend_download_packages (PkBackend *backend, PkBackendJob *job, gchar **pac
+ const gchar *directory)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_DOWNLOAD);
+- poldek_backend_set_allow_cancel (backend, FALSE, TRUE);
++ poldek_backend_set_allow_cancel (job, FALSE, TRUE);
+ pb_error_clean ();
+
+- poldek_backend_percentage_data_create (backend);
+ pk_backend_job_thread_create (job, backend_download_packages_thread, NULL, NULL);
+ }
+
+@@ -2395,29 +2516,35 @@ pk_backend_download_packages (PkBackend *backend, PkBackendJob *job, gchar **pac
+ static void
+ backend_get_depends_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ {
+- struct pkg *pkg;
+- tn_array *deppkgs, *available, *installed;
+- size_t i;
++ PkBitfield filters;
++ gboolean recursive;
+ gchar **package_ids;
++ struct pkg *pkg;
++ tn_array *deppkgs, *available, *installed;
++ size_t i;
++
++ g_variant_get (params, "(t^a&sb)",
++ &filters,
++ &package_ids,
++ &recursive);
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ deppkgs = n_array_new (2, NULL, NULL);
+
+ installed = poldek_get_installed_packages ();
+ available = poldek_get_avail_packages (ctx);
+- package_ids = pk_backend_get_strv (backend, "package_ids");
+
+ pkg = poldek_get_pkg_from_package_id (package_ids[0]);
+
+- do_depends (installed, available, deppkgs, pkg, backend);
++ do_depends (installed, available, deppkgs, pkg, filters, recursive);
+
+ n_array_sort_ex(deppkgs, (tn_fn_cmp)pkg_cmp_name_evr_rev);
+
+ for (i = 0; i < n_array_size (deppkgs); i++) {
+ struct pkg *p = n_array_nth (deppkgs, i);
+
+- poldek_backend_package (backend, p, PK_INFO_ENUM_UNKNOWN, pk_backend_get_uint (backend, "filters"));
++ poldek_backend_package (job, p, PK_INFO_ENUM_UNKNOWN, filters);
+ }
+
+ pkg_free (pkg);
+@@ -2433,7 +2560,7 @@ void
+ pk_backend_get_depends (PkBackend *backend, PkBackendJob *job, PkBitfield filters, gchar **package_ids, gboolean recursive)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, FALSE, TRUE);
++ poldek_backend_set_allow_cancel (job, FALSE, TRUE);
+ pb_error_clean ();
+
+ pk_backend_job_thread_create (job, backend_get_depends_thread, NULL, NULL);
+@@ -2448,9 +2575,10 @@ backend_get_details_thread (PkBackendJob *job, GVariant *params, gpointer user_d
+ gchar **package_ids;
+ guint n;
+
+- package_ids = pk_backend_get_strv (backend, "package_ids");
++ g_variant_get (params, "(^a&s)",
++ &package_ids);
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ for (n = 0; n < g_strv_length (package_ids); n++) {
+ struct pkg *pkg = NULL;
+@@ -2461,7 +2589,7 @@ backend_get_details_thread (PkBackendJob *job, GVariant *params, gpointer user_d
+
+ group = pld_group_to_enum (pkg_group (pkg));
+
+- if ((pkgu = pkg_uinf_i18n (backend, pkg)) != NULL) {
++ if ((pkgu = pkg_uinf_i18n (job, pkg)) != NULL) {
+ pk_backend_job_details (job,
+ package_ids[n],
+ pkguinf_get (pkgu, PKGUINF_LICENSE),
+@@ -2491,7 +2619,7 @@ void
+ pk_backend_get_details (PkBackend *backend, PkBackendJob *job, gchar **package_ids)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, FALSE, TRUE);
++ poldek_backend_set_allow_cancel (job, FALSE, TRUE);
+ pb_error_clean ();
+
+ pk_backend_job_thread_create (job, backend_get_details_thread, NULL, NULL);
+@@ -2506,9 +2634,10 @@ backend_get_files_thread (PkBackendJob *job, GVariant *params, gpointer user_dat
+ gchar **package_ids;
+ size_t n;
+
+- package_ids = pk_backend_get_strv (backend, "package_ids");
++ g_variant_get (params, "(^a&s)",
++ &package_ids);
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ for (n = 0; n < g_strv_length (package_ids); n++) {
+ struct pkg *pkg;
+@@ -2567,7 +2696,7 @@ void
+ pk_backend_get_files (PkBackend *backend, PkBackendJob *job, gchar **package_ids)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, FALSE, TRUE);
++ poldek_backend_set_allow_cancel (job, FALSE, TRUE);
+ pb_error_clean ();
+
+ pk_backend_job_thread_create (job, backend_get_files_thread, NULL, NULL);
+@@ -2585,11 +2714,12 @@ backend_get_packages_thread (PkBackendJob *job, GVariant *params, gpointer user_
+ tn_array *packages = NULL;
+ guint i;
+
+- filters = pk_backend_get_uint (backend, "filters");
++ g_variant_get (params, "(t)",
++ &filters);
+
+ pk_backend_job_set_percentage (job, 0);
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ if (pk_bitfield_contain (filters, PK_FILTER_ENUM_NOT_INSTALLED) == FALSE)
+ installed = poldek_get_installed_packages ();
+@@ -2614,7 +2744,7 @@ backend_get_packages_thread (PkBackendJob *job, GVariant *params, gpointer user_
+
+ pk_backend_job_set_percentage (job, (guint)(10 + (90 * (float)(i + 1) / n_array_size (packages))));
+
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_UNKNOWN, filters);
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_UNKNOWN, filters);
+ }
+ }
+
+@@ -2634,7 +2764,7 @@ void
+ pk_backend_get_packages (PkBackend *backend, PkBackendJob *job, PkBitfield filters)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+
+ pk_backend_job_thread_create (job, backend_get_packages_thread, NULL, NULL);
+@@ -2650,17 +2780,23 @@ backend_get_requires_thread (PkBackendJob *job, GVariant *params, gpointer user_
+ tn_array *reqpkgs, *available, *installed;
+ size_t i;
+ gchar **package_ids;
++ PkBitfield filters;
++ gboolean recursive;
++
++ g_variant_get (params, "(t^a&sb)",
++ &filters,
++ &package_ids,
++ &recursive);
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ reqpkgs = n_array_new (2, NULL, NULL);
+
+- package_ids = pk_backend_get_strv (backend, "package_ids");
+ pkg = poldek_get_pkg_from_package_id (package_ids[0]);
+ installed = poldek_get_installed_packages ();
+ available = poldek_get_avail_packages (ctx);
+
+- do_requires (installed, available, reqpkgs, pkg, backend);
++ do_requires (installed, available, reqpkgs, pkg, filters, recursive);
+
+ /* sort output */
+ n_array_sort_ex(reqpkgs, (tn_fn_cmp)pkg_cmp_name_evr_rev);
+@@ -2668,7 +2804,7 @@ backend_get_requires_thread (PkBackendJob *job, GVariant *params, gpointer user_
+ for (i = 0; i < n_array_size (reqpkgs); i++) {
+ struct pkg *p = n_array_nth (reqpkgs, i);
+
+- poldek_backend_package (backend, p, PK_INFO_ENUM_UNKNOWN, pk_backend_get_uint (backend, "filters"));
++ poldek_backend_package (job, p, PK_INFO_ENUM_UNKNOWN, filters);
+ }
+
+ n_array_free (reqpkgs);
+@@ -2682,7 +2818,7 @@ void
+ pk_backend_get_requires (PkBackend *backend, PkBackendJob *job, PkBitfield filters, gchar **package_ids, gboolean recursive)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, FALSE, TRUE);
++ poldek_backend_set_allow_cancel (job, FALSE, TRUE);
+ pb_error_clean ();
+
+ pk_backend_job_thread_create (job, backend_get_requires_thread, NULL, NULL);
+@@ -2691,15 +2827,17 @@ pk_backend_get_requires (PkBackend *backend, PkBackendJob *job, PkBitfield filte
+ /**
+ * pk_backend_get_update_detail:
+ */
+-static gchar*
++static GPtrArray *
+ get_obsoletedby_pkg (struct pkg *pkg)
+ {
++ GPtrArray *obsoletes = NULL;
+ tn_array *dbpkgs;
+- GString *obsoletes = NULL;
+ size_t i;
+
+ g_return_val_if_fail (pkg != NULL, NULL);
+
++ obsoletes = g_ptr_array_new ();
++
+ /* get installed packages */
+ dbpkgs = poclidek_get_dent_packages (cctx, POCLIDEK_INSTALLEDDIR);
+
+@@ -2710,22 +2848,13 @@ get_obsoletedby_pkg (struct pkg *pkg)
+ struct pkg *dbpkg = n_array_nth (dbpkgs, i);
+
+ if (pkg_caps_obsoletes_pkg_caps (pkg, dbpkg)) {
+- gchar *package_id = package_id_from_pkg (dbpkg, "installed", 0);
+-
+- if (obsoletes) {
+- obsoletes = g_string_append_c (obsoletes, '^');
+- obsoletes = g_string_append (obsoletes, package_id);
+- } else {
+- obsoletes = g_string_new (package_id);
+- }
+-
+- g_free (package_id);
++ g_ptr_array_add (obsoletes, package_id_from_pkg (dbpkg, "installed", 0));
+ }
+ }
+
+ n_array_free (dbpkgs);
+
+- return obsoletes ? g_string_free (obsoletes, FALSE) : NULL;
++ return obsoletes;
+ }
+
+ static void
+@@ -2734,9 +2863,10 @@ backend_get_update_detail_thread (PkBackendJob *job, GVariant *params, gpointer
+ gchar **package_ids = NULL;
+ guint n;
+
+- package_ids = pk_backend_get_strv (backend, "package_ids");
++ g_variant_get (params, "(^a&s)",
++ &package_ids);
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ for (n = 0; n < g_strv_length (package_ids); n++) {
+ tn_array *packages = NULL;
+@@ -2753,71 +2883,67 @@ backend_get_update_detail_thread (PkBackendJob *job, GVariant *params, gpointer
+ pkg = n_array_nth (packages, 0);
+
+ if (strcmp (pkg->name, parts[PK_PACKAGE_ID_NAME]) == 0) {
+- gchar *updates = NULL;
+- gchar *obsoletes = NULL;
+- gchar *cve_url = NULL;
++ GPtrArray *obsoletes = NULL;
++ GPtrArray *updates = NULL;
++ GPtrArray *cve_urls = NULL;
+ const gchar *changes = NULL;
+ tn_array *cves = NULL;
+ struct pkguinf *upkg_uinf = NULL;
+
+- updates = package_id_from_pkg (pkg, "installed", 0);
+-
+ upkg = poldek_get_pkg_from_package_id (package_ids[n]);
+
++ updates = g_ptr_array_new ();
++ g_ptr_array_add (updates, package_id_from_pkg (pkg, "installed", 0));
++
+ obsoletes = get_obsoletedby_pkg (upkg);
+
+ if ((upkg_uinf = pkg_uinf (upkg)) != NULL) {
+ changes = pkguinf_get_changelog (upkg_uinf, pkg->btime);
+ }
+
++ cve_urls = g_ptr_array_new ();
+ if ((cves = poldek_pkg_get_cves_from_pld_changelog (upkg, pkg->btime))) {
+- GString *string;
+ guint i;
+
+- string = g_string_new ("");
+-
+ for (i = 0; i < n_array_size (cves); i++) {
+ gchar *cve = n_array_nth (cves, i);
+
+- g_string_append_printf (string,
+- "http://nvd.nist.gov/nvd.cfm?cvename=%s;%s",
+- cve, cve);
+-
+- if ((i + 1) < n_array_size (cves))
+- g_string_append_printf (string, ";");
++ g_ptr_array_add (cve_urls,
++ g_strdup_printf ("http://web.nvd.nist.gov/view/vuln/detail?vulnId=%s", cve));
+ }
+-
+- cve_url = g_string_free (string, FALSE);
+ }
+
++ g_ptr_array_add (updates, NULL);
++ g_ptr_array_add (obsoletes, NULL);
++ g_ptr_array_add (cve_urls, NULL);
++
+ pk_backend_job_update_detail (job,
+ package_ids[n],
+- updates,
+- obsoletes ? obsoletes : "",
+- "",
+- "",
+- cve_url ? cve_url : "",
++ (gchar **) updates->pdata,
++ (gchar **) obsoletes->pdata,
++ NULL, // vendor urls
++ NULL, // bugzilla urls
++ (gchar **) cve_urls->pdata,
+ PK_RESTART_ENUM_NONE,
+- "", changes, PK_UPDATE_STATE_ENUM_UNKNOWN, NULL, NULL);
++ "", // update text
++ changes,
++ PK_UPDATE_STATE_ENUM_UNKNOWN,
++ NULL, // issued
++ NULL); // updated
+
+- g_free (updates);
+- g_free (obsoletes);
+- g_free (cve_url);
++ g_ptr_array_unref (updates);
++ g_ptr_array_unref (obsoletes);
++ g_ptr_array_unref (cve_urls);
+
+ n_array_cfree (&cves);
+ }
+
+ n_array_free (packages);
+ } else {
+- pk_backend_job_update_detail (job,
+- package_ids[n],
+- "",
+- "",
+- "",
+- "",
+- "",
+- PK_RESTART_ENUM_NONE,
+- "", NULL, PK_UPDATE_STATE_ENUM_UNKNOWN, NULL, NULL);
++ pk_backend_job_error_code (job,
++ PK_ERROR_ENUM_PACKAGE_NOT_FOUND,
++ "failed to find package %s",
++ package_ids[n]);
+ }
+
+ g_strfreev (parts);
+@@ -2830,7 +2956,7 @@ void
+ pk_backend_get_update_detail (PkBackend *backend, PkBackendJob *job, gchar **package_ids)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, FALSE, TRUE);
++ poldek_backend_set_allow_cancel (job, FALSE, TRUE);
+ pb_error_clean ();
+
+ pk_backend_job_thread_create (job, backend_get_update_detail_thread, NULL, NULL);
+@@ -2844,7 +2970,7 @@ backend_get_updates_thread (PkBackendJob *job, GVariant *params, gpointer user_d
+ {
+ tn_array *packages = NULL;
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ if ((packages = execute_packages_command ("cd /all-avail; ls -q -u")) != NULL) {
+ tn_array *secupgrades = NULL;
+@@ -2863,11 +2989,11 @@ backend_get_updates_thread (PkBackendJob *job, GVariant *params, gpointer user_d
+
+ /* mark held packages as blocked */
+ if (pkg->flags & PKG_HELD)
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_BLOCKED, PK_FILTER_ENUM_NONE);
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_BLOCKED, PK_FILTER_ENUM_NONE);
+ else if (poldek_pkg_in_array (pkg, secupgrades, (tn_fn_cmp)pkg_cmp_name_evr))
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_SECURITY, PK_FILTER_ENUM_NONE);
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_SECURITY, PK_FILTER_ENUM_NONE);
+ else
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_NORMAL, PK_FILTER_ENUM_NONE);
++ poldek_backend_package (job, pkg, PK_INFO_ENUM_NORMAL, PK_FILTER_ENUM_NONE);
+ }
+
+ n_array_cfree (&secupgrades);
+@@ -2884,7 +3010,7 @@ void
+ pk_backend_get_updates (PkBackend *backend, PkBackendJob *job, PkBitfield filters)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+
+ pk_backend_job_thread_create (job, backend_get_updates_thread, NULL, NULL);
+@@ -2899,20 +3025,25 @@ backend_install_packages_thread (PkBackendJob *job, GVariant *params, gpointer u
+ gchar *command;
+ struct vf_progress vf_progress;
+ gchar **package_ids;
++ PkBitfield transaction_flags;
+ GString *cmd;
+ size_t i;
+
+- pk_backend_set_uint (backend, "ts_type", TS_TYPE_ENUM_INSTALL);
+-
+ /* FIXME: support only_trusted */
+- package_ids = pk_backend_get_strv (backend, "package_ids");
++ g_variant_get (params, "(t^a&s)",
++ &transaction_flags,
++ &package_ids);
+
+- setup_vf_progress (&vf_progress, backend);
++ setup_vf_progress (&vf_progress, job);
+
+- pb_load_packages (backend);
++ pb_load_packages (job);
+
+ cmd = g_string_new ("install ");
+
++ if (pk_bitfield_contain (transaction_flags, PK_TRANSACTION_FLAG_ENUM_ONLY_DOWNLOAD)) {
++ g_string_append_printf (cmd, "--fetch ");
++ }
++
+ /* prepare command */
+ for (i = 0; i < g_strv_length (package_ids); i++) {
+ gchar *nvra = poldek_get_nvra_from_package_id (package_ids[i]);
+@@ -2927,20 +3058,20 @@ backend_install_packages_thread (PkBackendJob *job, GVariant *params, gpointer u
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_DEP_RESOLVE);
+
+ if (execute_command (command)) {
+- pb_error_check (backend);
++ pb_error_check (job);
+ } else {
+- pb_error_show (backend, PK_ERROR_ENUM_TRANSACTION_ERROR);
++ pb_error_show (job, PK_ERROR_ENUM_TRANSACTION_ERROR);
+ }
+
+ g_free (command);
+
+- poldek_backend_percentage_data_destroy (backend);
+-
+ pk_backend_job_finished (job);
+ }
+
+ void
+-pk_backend_install_packages (PkBackend *backend, PkBackendJob *job, PkBitfield transaction_flags, gchar **package_ids)
++pk_backend_install_packages (PkBackend *backend, PkBackendJob *job,
++ PkBitfield transaction_flags,
++ gchar **package_ids)
+ {
+ if (!pk_backend_is_online (backend)) {
+ pk_backend_job_error_code (job, PK_ERROR_ENUM_NO_NETWORK, "Cannot install package when offline!");
+@@ -2948,11 +3079,14 @@ pk_backend_install_packages (PkBackend *backend, PkBackendJob *job, PkBitfield t
+ return;
+ }
+
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+
+- poldek_backend_percentage_data_create (backend);
+- pk_backend_job_thread_create (job, backend_install_packages_thread, NULL, NULL);
++ if (pk_bitfield_contain (transaction_flags, PK_TRANSACTION_FLAG_ENUM_SIMULATE)) {
++ pk_backend_job_thread_create (job, do_simulate_packages, NULL, NULL);
++ } else {
++ pk_backend_job_thread_create (job, backend_install_packages_thread, NULL, NULL);
++ }
+ }
+
+ /**
+@@ -2962,11 +3096,12 @@ pk_backend_install_packages (PkBackend *backend, PkBackendJob *job, PkBitfield t
+ static void
+ backend_refresh_cache_thread (PkBackendJob *job, GVariant *params, gpointer user_data)
+ {
++ PkBackendPoldekJobData *job_data = pk_backend_job_get_user_data (job);
++ PkBackendPoldekProgressData *pd = job_data->progress_data;
+ tn_array *sources = NULL;
+ struct vf_progress vfpro;
+- PercentageData *pd = pk_backend_get_pointer (backend, "percentage_ptr");
+
+- setup_vf_progress (&vfpro, backend);
++ setup_vf_progress (&vfpro, job);
+
+ pk_backend_job_set_percentage (job, 1);
+
+@@ -2975,7 +3110,6 @@ backend_refresh_cache_thread (PkBackendJob *job, GVariant *params, gpointer user
+ if (sources) {
+ size_t i;
+
+- pk_backend_set_uint (backend, "ts_type", TS_TYPE_ENUM_REFRESH_CACHE);
+ pd->step = 0;
+ pd->nsources = 0;
+
+@@ -3003,12 +3137,10 @@ backend_refresh_cache_thread (PkBackendJob *job, GVariant *params, gpointer user
+ n_array_free (sources);
+ }
+
+- poldek_reload (backend, TRUE);
++ poldek_reload (job, TRUE);
+
+ pk_backend_job_set_percentage (job, 100);
+
+- poldek_backend_percentage_data_destroy (backend);
+-
+ pk_backend_job_finished (job);
+ }
+
+@@ -3022,10 +3154,9 @@ pk_backend_refresh_cache (PkBackend *backend, PkBackendJob *job, gboolean force)
+ }
+
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_REFRESH_CACHE);
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+
+- poldek_backend_percentage_data_create (backend);
+ pk_backend_job_thread_create (job, backend_refresh_cache_thread, NULL, NULL);
+ }
+
+@@ -3037,11 +3168,19 @@ backend_remove_packages_thread (PkBackendJob *job, GVariant *params, gpointer us
+ {
+ GString *cmd;
+ gchar *command;
++ PkBitfield transaction_flags;
+ gchar **package_ids;
++ gboolean allow_deps;
++ gboolean autoremove;
+ size_t i;
+
+- package_ids = pk_backend_get_strv (backend, "package_ids");
+- pb_load_packages (backend);
++ g_variant_get (params, "(t^a&sbb)",
++ &transaction_flags,
++ &package_ids,
++ &allow_deps,
++ &autoremove);
++
++ pb_load_packages (job);
+
+ cmd = g_string_new ("uninstall ");
+
+@@ -3068,11 +3207,20 @@ backend_remove_packages_thread (PkBackendJob *job, GVariant *params, gpointer us
+ }
+
+ void
+-pk_backend_remove_packages (PkBackend *backend, PkBackendJob *job, gchar **package_ids, gboolean allow_deps, gboolean autoremove)
++pk_backend_remove_packages (PkBackend *backend, PkBackendJob *job,
++ PkBitfield transaction_flags,
++ gchar **package_ids,
++ gboolean allow_deps,
++ gboolean autoremove)
+ {
+- poldek_backend_set_allow_cancel (backend, FALSE, TRUE);
++ poldek_backend_set_allow_cancel (job, FALSE, TRUE);
+ pb_error_clean ();
+- pk_backend_job_thread_create (job, backend_remove_packages_thread, NULL, NULL);
++
++ if (pk_bitfield_contain (transaction_flags, PK_TRANSACTION_FLAG_ENUM_SIMULATE)) {
++ pk_backend_job_thread_create (job, do_simulate_packages, NULL, NULL);
++ } else {
++ pk_backend_job_thread_create (job, backend_remove_packages_thread, NULL, NULL);
++ }
+ }
+
+ /**
+@@ -3082,10 +3230,8 @@ void
+ pk_backend_resolve (PkBackend *backend, PkBackendJob *job, PkBitfield filters, gchar **packages)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+
+- pk_backend_set_uint (backend, "mode", SEARCH_ENUM_RESOLVE);
+- pk_backend_set_strv (backend, "search", packages);
+ pk_backend_job_thread_create (job, search_package_thread, NULL, NULL);
+ }
+
+@@ -3096,9 +3242,8 @@ void
+ pk_backend_search_details (PkBackend *backend, PkBackendJob *job, PkBitfield filters, gchar **search)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+- pk_backend_set_uint (backend, "mode", SEARCH_ENUM_DETAILS);
+ pk_backend_job_thread_create (job, search_package_thread, NULL, NULL);
+ }
+
+@@ -3109,9 +3254,8 @@ void
+ pk_backend_search_files (PkBackend *backend, PkBackendJob *job, PkBitfield filters, gchar **search)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+- pk_backend_set_uint (backend, "mode", SEARCH_ENUM_FILE);
+ pk_backend_job_thread_create (job, search_package_thread, NULL, NULL);
+ }
+
+@@ -3122,9 +3266,8 @@ void
+ pk_backend_search_groups (PkBackend *backend, PkBackendJob *job, PkBitfield filters, gchar **search)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+- pk_backend_set_uint (backend, "mode", SEARCH_ENUM_GROUP);
+ pk_backend_job_thread_create (job, search_package_thread, NULL, NULL);
+ }
+
+@@ -3135,9 +3278,8 @@ void
+ pk_backend_search_names (PkBackend *backend, PkBackendJob *job, PkBitfield filters, gchar **search)
+ {
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+- pk_backend_set_uint (backend, "mode", SEARCH_ENUM_NAME);
+ pk_backend_job_thread_create (job, search_package_thread, NULL, NULL);
+ }
+
+@@ -3153,12 +3295,14 @@ pk_backend_update_packages (PkBackend *backend, PkBackendJob *job, PkBitfield tr
+ return;
+ }
+
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+
+- poldek_backend_percentage_data_create (backend);
+- pk_backend_set_uint (backend, "ts_type", TS_TYPE_ENUM_UPDATE);
+- pk_backend_job_thread_create (job, update_packages_thread, NULL, NULL);
++ if (pk_bitfield_contain (transaction_flags, PK_TRANSACTION_FLAG_ENUM_SIMULATE)) {
++ pk_backend_job_thread_create (job, do_simulate_packages, NULL, NULL);
++ } else {
++ pk_backend_job_thread_create (job, update_packages_thread, NULL, NULL);
++ }
+ }
+
+ /**
+@@ -3170,7 +3314,7 @@ pk_backend_get_repo_list (PkBackend *backend, PkBackendJob *job, PkBitfield filt
+ tn_array *sources = NULL;
+
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, FALSE, TRUE);
++ poldek_backend_set_allow_cancel (job, FALSE, TRUE);
+ pb_error_clean ();
+
+ sources = poldek_get_sources (ctx);
+@@ -3201,15 +3345,12 @@ void
+ pk_backend_what_provides (PkBackend *backend, PkBackendJob *job, PkBitfield filters, PkProvidesEnum provides, gchar **values)
+ {
+ GPtrArray *array = NULL;
+- gchar **search = NULL;
+ guint i;
+
+ pk_backend_job_set_status (job, PK_STATUS_ENUM_QUERY);
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
++ poldek_backend_set_allow_cancel (job, TRUE, TRUE);
+ pb_error_clean ();
+
+- pk_backend_set_uint (backend, "mode", SEARCH_ENUM_PROVIDES);
+-
+ /* prepare array of commands */
+ array = g_ptr_array_new_with_free_func (g_free);
+
+@@ -3225,136 +3366,9 @@ pk_backend_what_provides (PkBackend *backend, PkBackendJob *job, PkBitfield filt
+ } else {
+ pk_backend_job_error_code (job, PK_ERROR_ENUM_PROVIDE_TYPE_NOT_SUPPORTED,
+ "provide type '%s' not supported",
+- pk_provides_enum_to_text (provides));
++ pk_provides_enum_to_string (provides));
+ }
+ }
+
+- search = pk_ptr_array_to_strv (array);
+- pk_backend_set_strv (backend, "search", search);
+- pk_backend_job_thread_create (job, search_package_thread, NULL, NULL);
+- g_strfreev (search);
+- g_ptr_array_unref (array);
+-}
+-
+-static gboolean do_simulate_packages (PkBackend *backend)
+-{
+- struct poclidek_rcmd *rcmd = NULL;
+- struct poldek_ts *ts = NULL;
+- GString *buf = NULL;
+- gchar *cmd = NULL;
+- gchar **package_ids = NULL;
+- const gchar *command = NULL;
+- guint i;
+- guint ts_type;
+-
+- package_ids = pk_backend_get_strv (backend, "package_ids");
+- command = pk_backend_get_string (backend, "command");
+- ts_type = pk_backend_get_uint (backend, "ts_type");
+-
+- pk_backend_job_set_status (job, PK_STATUS_ENUM_DEP_RESOLVE);
+-
+- buf = g_string_new (command);
+-
+- for (i = 0; i < g_strv_length (package_ids); i++) {
+- gchar *nvra = poldek_get_nvra_from_package_id (package_ids[i]);
+-
+- g_string_append_c (buf, ' ');
+- g_string_append (buf, nvra);
+-
+- g_free (nvra);
+- }
+-
+- cmd = g_string_free (buf, FALSE);
+-
+- ts = poldek_ts_new (ctx, 0);
+- rcmd = poclidek_rcmd_new (cctx, ts);
+-
+- ts->setop(ts, POLDEK_OP_PARTICLE, 0);
+-
+- if (poclidek_rcmd_execline (rcmd, cmd)) {
+- tn_array *ipkgs = NULL, *dpkgs = NULL, *rpkgs = NULL;
+- tn_array *install_pkgs = NULL, *update_pkgs = NULL, *remove_pkgs = NULL;
+-
+- ipkgs = poldek_ts_get_summary (ts, "I");
+- dpkgs = poldek_ts_get_summary (ts, "D");
+- rpkgs = poldek_ts_get_summary (ts, "R");
+-
+- get_ts_summary (ts_type, ipkgs, dpkgs, rpkgs, &install_pkgs, &update_pkgs, &remove_pkgs);
+-
+- if (install_pkgs) {
+- for (i = 0; i < n_array_size (install_pkgs); i++) {
+- struct pkg *pkg = n_array_nth (install_pkgs, i);
+-
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_INSTALLING, PK_FILTER_ENUM_NONE);
+- }
+-
+- n_array_free (install_pkgs);
+- }
+-
+- if (update_pkgs) {
+- for (i = 0; i < n_array_size (update_pkgs); i++) {
+- struct pkg *pkg = n_array_nth (update_pkgs, i);
+-
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_UPDATING, PK_FILTER_ENUM_NONE);
+- }
+-
+- n_array_free (update_pkgs);
+- }
+-
+- if (remove_pkgs) {
+- for (i = 0; i < n_array_size (remove_pkgs); i++) {
+- struct pkg *pkg = n_array_nth (remove_pkgs, i);
+-
+- poldek_backend_package (backend, pkg, PK_INFO_ENUM_REMOVING, PK_FILTER_ENUM_NONE);
+- }
+-
+- n_array_free (remove_pkgs);
+- }
+- }
+-
+- g_free (cmd);
+-
+- poclidek_rcmd_free (rcmd);
+- poldek_ts_free (ts);
+-
+- pk_backend_job_finished (job);
+-}
+-
+-/**
+- * pk_backend_simulate_install_packages:
+- */
+-void
+-pk_backend_simulate_install_packages (PkBackend *backend, gchar **package_ids)
+-{
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
+- pb_error_clean ();
+- pk_backend_set_uint (backend, "ts_type", TS_TYPE_ENUM_INSTALL);
+- pk_backend_set_string (backend, "command", "cd /all-avail; install --test");
+- pk_backend_job_thread_create (job, do_simulate_packages);
+-}
+-
+-/**
+- * pk_backend_simulate_remove_packages:
+- */
+-void
+-pk_backend_simulate_remove_packages (PkBackend *backend, gchar **package_ids, gboolean autoremove)
+-{
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
+- pb_error_clean ();
+- pk_backend_set_uint (backend, "ts_type", TS_TYPE_ENUM_REMOVE);
+- pk_backend_set_string (backend, "command", "cd /all-avail; uninstall --test");
+- pk_backend_job_thread_create (job, do_simulate_packages);
+-}
+-
+-/**
+- * pk_backend_simulate_update_packages:
+- */
+-void
+-pk_backend_simulate_update_packages (PkBackend *backend, gchar **package_ids)
+-{
+- poldek_backend_set_allow_cancel (backend, TRUE, TRUE);
+- pb_error_clean ();
+- pk_backend_set_uint (backend, "ts_type", TS_TYPE_ENUM_UPDATE);
+- pk_backend_set_string (backend, "command", "cd /all-avail; upgrade --test");
+- pk_backend_job_thread_create (job, do_simulate_packages);
++ pk_backend_job_thread_create (job, search_package_thread, array, NULL);
+ }
+commit c0a687645059f7a15c95c5affa6bbad7374d0dc9
+Author: Marcin Banasiak <marcin.banasiak@gmail.com>
+Date: Sun Oct 7 20:00:43 2012 +0200
+
+ poldek: keep pkgdb open through the whole transaction
+
+ It will speed up GetPackages() several times.
+
+diff --git a/backends/poldek/pk-backend-poldek.c b/backends/poldek/pk-backend-poldek.c
+index 7fe3d12..ced514d 100644
+--- a/backends/poldek/pk-backend-poldek.c
++++ b/backends/poldek/pk-backend-poldek.c
+@@ -80,6 +80,12 @@ typedef struct {
+ } PkBackendPoldekJobData;
+
+ typedef struct {
++ struct poldek_ctx *ctx;
++ struct poclidek_ctx *cctx;
++ struct pkgdb *db;
++} PkBackendPoldekPriv;
++
++typedef struct {
+ PkGroupEnum group;
+ const gchar *regex;
+ } PLDGroupRegex;
+@@ -132,8 +138,7 @@ static PbError *pberror;
+ /* cached locale variants */
+ static GHashTable *clv;
+
+-static struct poldek_ctx *ctx = NULL;
+-static struct poclidek_ctx *cctx = NULL;
++static PkBackendPoldekPriv *priv = NULL;
+
+ /**
+ * execute_command:
+@@ -155,8 +160,8 @@ execute_command (const gchar *format, ...)
+ command = g_strdup_vprintf (format, args);
+ va_end (args);
+
+- ts = poldek_ts_new (ctx, 0);
+- rcmd = poclidek_rcmd_new (cctx, ts);
++ ts = poldek_ts_new (priv->ctx, 0);
++ rcmd = poclidek_rcmd_new (priv->cctx, ts);
+
+ ts->setop(ts, POLDEK_OP_PARTICLE, 0);
+
+@@ -192,7 +197,7 @@ execute_packages_command (const gchar *format, ...)
+ command = g_strdup_vprintf (format, args);
+ va_end (args);
+
+- rcmd = poclidek_rcmd_new (cctx, NULL);
++ rcmd = poclidek_rcmd_new (priv->cctx, NULL);
+
+ if (poclidek_rcmd_execline (rcmd, command)) {
+ packages = poclidek_rcmd_get_packages (rcmd);
+@@ -754,7 +759,7 @@ setup_vf_progress (struct vf_progress *vf_progress, PkBackendJob *job)
+ vfile_configure (VFILE_CONF_VERBOSE, &verbose);
+ vfile_configure (VFILE_CONF_STUBBORN_NRETRIES, 5);
+
+- poldek_configure (ctx, POLDEK_CONF_VFILEPROGRESS, vf_progress);
++ poldek_configure (priv->ctx, POLDEK_CONF_VFILEPROGRESS, vf_progress);
+ }
+
+ static gint
+@@ -802,20 +807,26 @@ do_post_search_process (tn_array *installed, tn_array *available)
+ return packages;
+ }
+
++static void
++pk_backend_poldek_open_pkgdb (void)
++{
++ if (priv->db == NULL) {
++ priv->db = pkgdb_open (poldek_get_pmctx (priv->ctx),
++ NULL, NULL, O_RDONLY, NULL);
++ }
++}
++
+ static gboolean
+ pkg_is_installed (struct pkg *pkg)
+ {
+- struct pkgdb *db;
+ gint cmprc, is_installed = 0;
+
+ g_return_val_if_fail (pkg != NULL, FALSE);
+
+- db = pkgdb_open (poldek_get_pmctx (ctx), NULL, NULL, O_RDONLY, NULL);
+-
+- if (db) {
+- is_installed = pkgdb_is_pkg_installed (db, pkg, &cmprc);
++ pk_backend_poldek_open_pkgdb ();
+
+- pkgdb_free (db);
++ if (priv->db) {
++ is_installed = pkgdb_is_pkg_installed (priv->db, pkg, &cmprc);
+ }
+
+ return is_installed ? TRUE : FALSE;
+@@ -833,20 +844,20 @@ pkg_is_installed (struct pkg *pkg)
+ static gchar *
+ get_pkgid_from_localpath (const gchar *localpath)
+ {
+- struct pkgdb *db = NULL;
+ struct poldek_ts *ts = NULL;
+ gchar *pkgid = NULL;
+
+ g_return_val_if_fail (localpath != NULL, NULL);
+
+- ts = poldek_ts_new (ctx, 0);
+- db = pkgdb_open (ts->pmctx, ts->rootdir, NULL, O_RDONLY, NULL);
++ ts = poldek_ts_new (priv->ctx, 0);
+
+- if (db) {
++ pk_backend_poldek_open_pkgdb ();
++
++ if (priv->db) {
+ const struct pm_dbrec *ldbrec;
+ struct pkgdb_it it;
+
+- pkgdb_it_init (db, &it, PMTAG_FILE, localpath);
++ pkgdb_it_init (priv->db, &it, PMTAG_FILE, localpath);
+
+ /* get only one package */
+ if ((ldbrec = pkgdb_it_get (&it)) != NULL) {
+@@ -859,8 +870,6 @@ get_pkgid_from_localpath (const gchar *localpath)
+ }
+
+ pkgdb_it_destroy (&it);
+- /* it calls pkgdb_close (db) */
+- pkgdb_free (db);
+ }
+
+ poldek_ts_free (ts);
+@@ -1015,7 +1024,7 @@ poldek_get_nvra_from_package_id (const gchar* package_id)
+ static tn_array*
+ poldek_get_installed_packages (void)
+ {
+- return poclidek_get_dent_packages (cctx, POCLIDEK_INSTALLEDDIR);
++ return poclidek_get_dent_packages (priv->cctx, POCLIDEK_INSTALLEDDIR);
+ }
+
+ static tn_array*
+@@ -1909,8 +1918,8 @@ do_simulate_packages (PkBackendJob *job, GVariant *params, gpointer user_data)
+
+ cmd = g_string_free (buf, FALSE);
+
+- ts = poldek_ts_new (ctx, 0);
+- rcmd = poclidek_rcmd_new (cctx, ts);
++ ts = poldek_ts_new (priv->ctx, 0);
++ rcmd = poclidek_rcmd_new (priv->cctx, ts);
+
+ ts->setop(ts, POLDEK_OP_PARTICLE, 0);
+
+@@ -1973,7 +1982,7 @@ pb_load_packages (PkBackendJob *job)
+ poldek_backend_set_allow_cancel (job, FALSE, FALSE);
+
+ /* load information about installed and available packages */
+- poclidek_load_packages (cctx, POCLIDEK_LOAD_ALL);
++ poclidek_load_packages (priv->cctx, POCLIDEK_LOAD_ALL);
+
+ if (allow_cancel)
+ poldek_backend_set_allow_cancel (job, TRUE, FALSE);
+@@ -2226,32 +2235,32 @@ do_poldek_init (PkBackend *backend)
+ {
+ poldeklib_init ();
+
+- ctx = poldek_new (0);
++ priv->ctx = poldek_new (0);
+
+- poldek_load_config (ctx, "/etc/poldek/poldek.conf", NULL, 0);
++ poldek_load_config (priv->ctx, "/etc/poldek/poldek.conf", NULL, 0);
+
+- poldek_setup (ctx);
++ poldek_setup (priv->ctx);
+
+- cctx = poclidek_new (ctx);
++ priv->cctx = poclidek_new (priv->ctx);
+
+ poldek_set_verbose (1);
+ /* disable LOGFILE and LOGTTY logging */
+- poldek_configure (ctx, POLDEK_CONF_LOGFILE, NULL);
+- poldek_configure (ctx, POLDEK_CONF_LOGTTY, NULL);
++ poldek_configure (priv->ctx, POLDEK_CONF_LOGFILE, NULL);
++ poldek_configure (priv->ctx, POLDEK_CONF_LOGTTY, NULL);
+
+ /* disable unique package names */
+- poldek_configure (ctx, POLDEK_CONF_OPT, POLDEK_OP_UNIQN, 0);
++ poldek_configure (priv->ctx, POLDEK_CONF_OPT, POLDEK_OP_UNIQN, 0);
+
+- poldek_configure (ctx, POLDEK_CONF_OPT, POLDEK_OP_LDALLDESC, 1);
++ poldek_configure (priv->ctx, POLDEK_CONF_OPT, POLDEK_OP_LDALLDESC, 1);
+
+ /* poldek has to ask. Otherwise callbacks won't be used */
+- poldek_configure (ctx, POLDEK_CONF_OPT, POLDEK_OP_CONFIRM_INST, 1);
+- poldek_configure (ctx, POLDEK_CONF_OPT, POLDEK_OP_CONFIRM_UNINST, 1);
++ poldek_configure (priv->ctx, POLDEK_CONF_OPT, POLDEK_OP_CONFIRM_INST, 1);
++ poldek_configure (priv->ctx, POLDEK_CONF_OPT, POLDEK_OP_CONFIRM_UNINST, 1);
+ /* (...), but we don't need choose_equiv callback */
+- poldek_configure (ctx, POLDEK_CONF_OPT, POLDEK_OP_EQPKG_ASKUSER, 0);
++ poldek_configure (priv->ctx, POLDEK_CONF_OPT, POLDEK_OP_EQPKG_ASKUSER, 0);
+
+ /* Install all suggested packages by default */
+- poldek_configure (ctx, POLDEK_CONF_CHOOSESUGGESTS_CB, suggests_callback, NULL);
++ poldek_configure (priv->ctx, POLDEK_CONF_CHOOSESUGGESTS_CB, suggests_callback, NULL);
+
+ sigint_init ();
+ }
+@@ -2261,8 +2270,13 @@ do_poldek_destroy (PkBackend *backend)
+ {
+ sigint_destroy ();
+
+- poclidek_free (cctx);
+- poldek_free (ctx);
++ if (priv->db != NULL) {
++ pkgdb_close (priv->db);
++ priv->db = NULL;
++ }
++
++ poclidek_free (priv->cctx);
++ poldek_free (priv->ctx);
+
+ poldeklib_destroy ();
+ }
+@@ -2316,6 +2330,8 @@ pk_backend_initialize (PkBackend *backend)
+ pberror = g_new0 (PbError, 1);
+ pberror->tslog = g_string_new ("");
+
++ priv = g_new0 (PkBackendPoldekPriv, 1);
++
+ do_poldek_init (backend);
+
+ g_debug ("backend initalize end");
+@@ -2328,6 +2344,8 @@ pk_backend_destroy (PkBackend *backend)
+ {
+ do_poldek_destroy (backend);
+
++ g_free (priv);
++
+ /* release PbError struct */
+ g_free (pberror->vfffmsg);
+ g_string_free (pberror->tslog, TRUE);
+@@ -2352,7 +2370,7 @@ pk_backend_start_job (PkBackend *backend, PkBackendJob *job)
+
+ poldek_log_set_appender ("PackageKit", (void *) job, NULL, 0, (poldek_vlog_fn) poldek_backend_log);
+
+- poldek_configure (ctx, POLDEK_CONF_TSCONFIRM_CB, ts_confirm, job);
++ poldek_configure (priv->ctx, POLDEK_CONF_TSCONFIRM_CB, ts_confirm, job);
+ }
+
+ /**
+@@ -2372,6 +2390,12 @@ pk_backend_stop_job (PkBackend *backend, PkBackendJob *job)
+
+ g_free (job_data);
+
++ // close pkgdb as well
++ if (priv->db != NULL) {
++ pkgdb_close (priv->db);
++ priv->db = NULL;
++ }
++
+ pk_backend_job_set_user_data (job, NULL);
+ }
+
+@@ -2460,7 +2484,7 @@ backend_download_packages_thread (PkBackendJob *job, GVariant *params, gpointer
+
+ pkgs = n_array_new (10, (tn_fn_free)pkg_free, NULL);
+
+- ts = poldek_ts_new (ctx, 0);
++ ts = poldek_ts_new (priv->ctx, 0);
+
+ setup_vf_progress (&vf_progress, job);
+
+@@ -2533,7 +2557,7 @@ backend_get_depends_thread (PkBackendJob *job, GVariant *params, gpointer user_d
+ deppkgs = n_array_new (2, NULL, NULL);
+
+ installed = poldek_get_installed_packages ();
+- available = poldek_get_avail_packages (ctx);
++ available = poldek_get_avail_packages (priv->ctx);
+
+ pkg = poldek_get_pkg_from_package_id (package_ids[0]);
+
+@@ -2725,7 +2749,7 @@ backend_get_packages_thread (PkBackendJob *job, GVariant *params, gpointer user_
+ installed = poldek_get_installed_packages ();
+
+ if (pk_bitfield_contain (filters, PK_FILTER_ENUM_INSTALLED) == FALSE)
+- available = poldek_get_avail_packages (ctx);
++ available = poldek_get_avail_packages (priv->ctx);
+
+ pk_backend_job_set_percentage (job, 4);
+
+@@ -2794,7 +2818,7 @@ backend_get_requires_thread (PkBackendJob *job, GVariant *params, gpointer user_
+
+ pkg = poldek_get_pkg_from_package_id (package_ids[0]);
+ installed = poldek_get_installed_packages ();
+- available = poldek_get_avail_packages (ctx);
++ available = poldek_get_avail_packages (priv->ctx);
+
+ do_requires (installed, available, reqpkgs, pkg, filters, recursive);
+
+@@ -2839,7 +2863,7 @@ get_obsoletedby_pkg (struct pkg *pkg)
+ obsoletes = g_ptr_array_new ();
+
+ /* get installed packages */
+- dbpkgs = poclidek_get_dent_packages (cctx, POCLIDEK_INSTALLEDDIR);
++ dbpkgs = poclidek_get_dent_packages (priv->cctx, POCLIDEK_INSTALLEDDIR);
+
+ if (dbpkgs == NULL)
+ return NULL;
+@@ -3105,7 +3129,7 @@ backend_refresh_cache_thread (PkBackendJob *job, GVariant *params, gpointer user
+
+ pk_backend_job_set_percentage (job, 1);
+
+- sources = poldek_get_sources (ctx);
++ sources = poldek_get_sources (priv->ctx);
+
+ if (sources) {
+ size_t i;
+@@ -3317,7 +3341,7 @@ pk_backend_get_repo_list (PkBackend *backend, PkBackendJob *job, PkBitfield filt
+ poldek_backend_set_allow_cancel (job, FALSE, TRUE);
+ pb_error_clean ();
+
+- sources = poldek_get_sources (ctx);
++ sources = poldek_get_sources (priv->ctx);
+
+ if (sources) {
+ size_t i;
projects / packages / PackageKit.git / commitdiff