176 lines
3.7 KiB
C++
176 lines
3.7 KiB
C++
#include <curl/curl.h>
|
|
#include <sqlite3.h>
|
|
#include "pkgtools.h"
|
|
#include "utils.h"
|
|
|
|
namespace slack {
|
|
|
|
/**
|
|
* slack::Pkgtools::download:
|
|
* @job: A #PkBackendJob.
|
|
* @dest_dir_name: Destination directory.
|
|
* @pkg_name: Package name.
|
|
*
|
|
* Download a package.
|
|
*
|
|
* Returns: %TRUE on success, %FALSE otherwise.
|
|
**/
|
|
gboolean
|
|
Pkgtools::download (PkBackendJob *job,
|
|
gchar *dest_dir_name, gchar *pkg_name) noexcept
|
|
{
|
|
gchar *dest_filename, *source_url;
|
|
gboolean ret = FALSE;
|
|
sqlite3_stmt *statement = NULL;
|
|
CURL *curl = NULL;
|
|
auto job_data = static_cast<JobData *> (pk_backend_job_get_user_data(job));
|
|
|
|
if ((sqlite3_prepare_v2(job_data->db,
|
|
"SELECT location, (full_name || '.' || ext) FROM pkglist "
|
|
"WHERE name LIKE @name AND repo_order = @repo_order",
|
|
-1,
|
|
&statement,
|
|
NULL) != SQLITE_OK))
|
|
return FALSE;
|
|
|
|
sqlite3_bind_text(statement, 1, pkg_name, -1, SQLITE_TRANSIENT);
|
|
sqlite3_bind_int(statement, 2, this->get_order ());
|
|
|
|
if (sqlite3_step(statement) == SQLITE_ROW)
|
|
{
|
|
dest_filename = g_build_filename(dest_dir_name, sqlite3_column_text(statement, 1), NULL);
|
|
source_url = g_strconcat(this->get_mirror (),
|
|
sqlite3_column_text(statement, 0),
|
|
"/",
|
|
sqlite3_column_text(statement, 1),
|
|
NULL);
|
|
|
|
if (!g_file_test(dest_filename, G_FILE_TEST_EXISTS))
|
|
{
|
|
if (get_file(&curl, source_url, dest_filename) == CURLE_OK)
|
|
{
|
|
ret = TRUE;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
ret = TRUE;
|
|
}
|
|
|
|
if (curl)
|
|
{
|
|
curl_easy_cleanup(curl);
|
|
}
|
|
g_free(source_url);
|
|
g_free(dest_filename);
|
|
}
|
|
sqlite3_finalize(statement);
|
|
|
|
return ret;
|
|
}
|
|
|
|
/**
|
|
* slack::Pkgtools::install:
|
|
* @job: A #PkBackendJob.
|
|
* @pkg_name: Package name.
|
|
*
|
|
* Install a package.
|
|
**/
|
|
void
|
|
Pkgtools::install (PkBackendJob *job, gchar *pkg_name) noexcept
|
|
{
|
|
gchar *pkg_filename, *cmd_line;
|
|
sqlite3_stmt *statement = NULL;
|
|
auto job_data = static_cast<JobData *> (pk_backend_job_get_user_data(job));
|
|
|
|
if ((sqlite3_prepare_v2(job_data->db,
|
|
"SELECT (full_name || '.' || ext) FROM pkglist "
|
|
"WHERE name LIKE @name AND repo_order = @repo_order",
|
|
-1,
|
|
&statement,
|
|
NULL) != SQLITE_OK))
|
|
{
|
|
return;
|
|
}
|
|
|
|
sqlite3_bind_text(statement, 1, pkg_name, -1, SQLITE_TRANSIENT);
|
|
sqlite3_bind_int(statement, 2, this->get_order ());
|
|
|
|
if (sqlite3_step(statement) == SQLITE_ROW)
|
|
{
|
|
pkg_filename = g_build_filename(LOCALSTATEDIR,
|
|
"cache",
|
|
"PackageKit",
|
|
"downloads",
|
|
sqlite3_column_text(statement, 0),
|
|
NULL);
|
|
cmd_line = g_strconcat("/sbin/upgradepkg --install-new ", pkg_filename, NULL);
|
|
g_spawn_command_line_sync(cmd_line, NULL, NULL, NULL, NULL);
|
|
g_free(cmd_line);
|
|
|
|
g_free(pkg_filename);
|
|
}
|
|
sqlite3_finalize(statement);
|
|
}
|
|
|
|
Pkgtools::~Pkgtools () noexcept
|
|
{
|
|
}
|
|
|
|
/**
|
|
* slack::Pkgtools::get_name:
|
|
*
|
|
* Retrieves the repository name.
|
|
*
|
|
* Returns: Repository name.
|
|
**/
|
|
const gchar *
|
|
Pkgtools::get_name () const noexcept
|
|
{
|
|
return this->name;
|
|
}
|
|
|
|
/**
|
|
* slack::Pkgtools::get_mirror:
|
|
*
|
|
* Retrieves the repository mirror.
|
|
*
|
|
* Returns: Repository mirror.
|
|
**/
|
|
const gchar *
|
|
Pkgtools::get_mirror () const noexcept
|
|
{
|
|
return this->mirror;
|
|
}
|
|
|
|
/**
|
|
* slack::Pkgtools::get_order:
|
|
*
|
|
* Retrieves the repository order.
|
|
*
|
|
* Returns: Repository order.
|
|
**/
|
|
guint8
|
|
Pkgtools::get_order () const noexcept
|
|
{
|
|
return this->order;
|
|
}
|
|
|
|
/**
|
|
* slack::Pkgtools:is_blacklisted:
|
|
* @pkg: Package name to check for.
|
|
*
|
|
* Checks whether a package is blacklisted.
|
|
*
|
|
* Returns: %TRUE if the package is blacklisted, %FALSE otherwise.
|
|
**/
|
|
gboolean
|
|
Pkgtools::is_blacklisted (const gchar *pkg) const noexcept
|
|
{
|
|
return this->blacklist
|
|
&& g_regex_match (this->blacklist,
|
|
pkg, static_cast<GRegexMatchFlags> (0), NULL);
|
|
}
|
|
|
|
}
|