summaryrefslogtreecommitdiff
path: root/lib/libalpm/add.c
diff options
context:
space:
mode:
authorJudd Vinet <judd@archlinux.org>2005-03-15 01:51:43 +0000
committerJudd Vinet <judd@archlinux.org>2005-03-15 01:51:43 +0000
commitd04baabafa2ebbad92741d1f87e6ff32999f894a (patch)
tree5a2280176812b80c28ca77bfa8e0655c16f4db7e /lib/libalpm/add.c
downloadpacman-d04baabafa2ebbad92741d1f87e6ff32999f894a.tar.xz
Initial revision
Diffstat (limited to 'lib/libalpm/add.c')
-rw-r--r--lib/libalpm/add.c580
1 files changed, 580 insertions, 0 deletions
diff --git a/lib/libalpm/add.c b/lib/libalpm/add.c
new file mode 100644
index 00000000..2c883f10
--- /dev/null
+++ b/lib/libalpm/add.c
@@ -0,0 +1,580 @@
+/*
+ * add.c
+ *
+ * Copyright (c) 2002-2005 by Judd Vinet <jvinet@zeroflux.org>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307,
+ * USA.
+ */
+
+#include "config.h"
+#include <stdlib.h>
+#include <errno.h>
+#include <time.h>
+#include <fcntl.h>
+#include <string.h>
+#include <zlib.h>
+#include <libtar.h>
+/* pacman */
+#include "util.h"
+#include "error.h"
+#include "list.h"
+#include "cache.h"
+#include "rpmvercmp.h"
+#include "md5.h"
+#include "log.h"
+#include "backup.h"
+#include "package.h"
+#include "db.h"
+#include "provide.h"
+#include "trans.h"
+#include "deps.h"
+#include "add.h"
+#include "remove.h"
+#include "handle.h"
+
+extern pmhandle_t *handle;
+
+int add_loadtarget(pmdb_t *db, pmtrans_t *trans, char *name)
+{
+ pmpkg_t *info, *dummy;
+ PMList *j;
+
+ ASSERT(db != NULL, PM_RET_ERR(PM_ERR_DB_NULL, -1));
+ ASSERT(trans != NULL, PM_RET_ERR(PM_ERR_TRANS_NULL, -1));
+ ASSERT(name != NULL, PM_RET_ERR(PM_ERR_WRONG_ARGS, -1));
+
+ /* ORE
+ load_pkg should be done only if pkg has to be added to the transaction */
+
+ _alpm_log(PM_LOG_FLOW2, "reading %s...", name);
+ info = pkg_load(name);
+ if(info == NULL) {
+ /* pm_errno is already set by pkg_load() */
+ return(-1);
+ }
+
+ /* no additional hyphens in version strings */
+ if(strchr(info->version, '-') != strrchr(info->version, '-')) {
+ FREEPKG(info);
+ pm_errno = PM_ERR_INVALID_NAME;
+ return(-1);
+ }
+
+ dummy = db_get_pkgfromcache(db, info->name);
+ /* only freshen this package if it is already installed and at a lesser version */
+ if(trans->flags & PM_TRANS_FLAG_FRESHEN) {
+ if(dummy == NULL || rpmvercmp(dummy->version, info->version) >= 0) {
+ FREEPKG(info);
+ PM_RET_ERR(PM_ERR_PKG_CANT_FRESH, -1);
+ }
+ }
+ /* only install this package if it is not already installed */
+ if(trans->type != PM_TRANS_TYPE_UPGRADE) {
+ if(dummy) {
+ FREEPKG(info);
+ PM_RET_ERR(PM_ERR_PKG_INSTALLED, -1);
+ }
+ }
+
+ /* check if an older version of said package is already in transaction packages.
+ * if so, replace it in the list */
+ /* ORE
+ we'd better do it before load_pkg. */
+ for(j = trans->packages; j; j = j->next) {
+ pmpkg_t *pkg = j->data;
+
+ if(strcmp(pkg->name, info->name) != 0) {
+ if(rpmvercmp(pkg->version, info->version) < 0) {
+ _alpm_log(PM_LOG_WARNING, "replacing older version of %s in target list", pkg->name);
+ FREEPKG(j->data);
+ j->data = info;
+ }
+ }
+ }
+
+ /* add the package to the transaction */
+ trans->packages = pm_list_add(trans->packages, info);
+
+ return(0);
+}
+
+int add_prepare(pmdb_t *db, pmtrans_t *trans, PMList **data)
+{
+ PMList *lp;
+
+ *data = NULL;
+
+ ASSERT(db != NULL, PM_RET_ERR(PM_ERR_DB_NULL, -1));
+ ASSERT(trans != NULL, PM_RET_ERR(PM_ERR_TRANS_NULL, -1));
+ ASSERT(data != NULL, PM_RET_ERR(PM_ERR_WRONG_ARGS, -1));
+
+ /* ORE ???
+ No need to check deps if pacman_add was called during a sync:
+ it is already done in pacman_sync */
+
+ /* Check dependencies
+ */
+
+ if(!(trans->flags & PM_TRANS_FLAG_NODEPS)) {
+ PMList *j;
+
+ TRANS_CB(trans, PM_TRANS_CB_DEPS_START, NULL, NULL);
+
+ lp = checkdeps(db, trans->type, trans->packages);
+ if(lp != NULL) {
+ int errorout = 0;
+
+ /* look for unsatisfied dependencies */
+ _alpm_log(PM_LOG_FLOW2, "looking for unsatisfied dependencies...");
+ for(j = lp; j; j = j->next) {
+ pmdepmissing_t* miss = j->data;
+
+ if(miss->type == PM_DEP_DEPEND || miss->type == PM_DEP_REQUIRED) {
+ if(!errorout) {
+ errorout = 1;
+ }
+ if((miss = (pmdepmissing_t *)malloc(sizeof(pmdepmissing_t))) == NULL) {
+ FREELIST(lp);
+ /* ORE, needed or not ?
+ FREELIST(*data);*/
+ PM_RET_ERR(PM_ERR_MEMORY, -1);
+ }
+ *miss = *(pmdepmissing_t*)j->data;
+ *data = pm_list_add(*data, miss);
+ }
+ }
+ if(errorout) {
+ FREELIST(lp);
+ PM_RET_ERR(PM_ERR_UNSATISFIED_DEPS, -1);
+ }
+
+ /* no unsatisfied deps, so look for conflicts */
+ _alpm_log(PM_LOG_FLOW2, "looking for conflicts...");
+ for(j = lp; j; j = j->next) {
+ pmdepmissing_t* miss = (pmdepmissing_t *)j->data;
+ if(miss->type == PM_DEP_CONFLICT) {
+ if(!errorout) {
+ errorout = 1;
+ }
+ MALLOC(miss, sizeof(pmdepmissing_t));
+ *miss = *(pmdepmissing_t*)j->data;
+ *data = pm_list_add(*data, miss);
+ }
+ }
+ if(errorout) {
+ FREELIST(lp);
+ PM_RET_ERR(PM_ERR_CONFLICTING_DEPS, -1);
+ }
+ FREELIST(lp);
+ }
+
+ /* re-order w.r.t. dependencies */
+ _alpm_log(PM_LOG_FLOW2, "sorting by dependencies...");
+ lp = sortbydeps(trans->packages);
+ /* free the old alltargs */
+ for(j = trans->packages; j; j = j->next) {
+ j->data = NULL;
+ }
+ FREELIST(trans->packages);
+ trans->packages = lp;
+
+ TRANS_CB(trans, PM_TRANS_CB_DEPS_DONE, NULL, NULL);
+ }
+
+ /* Check for file conflicts
+ */
+ if(!(trans->flags & PM_TRANS_FLAG_FORCE)) {
+ TRANS_CB(trans, PM_TRANS_CB_CONFLICTS_START, NULL, NULL);
+
+ lp = db_find_conflicts(db, trans->packages, handle->root);
+ if(lp != NULL) {
+ *data = lp;
+ PM_RET_ERR(PM_ERR_FILE_CONFLICTS, -1);
+ }
+
+ TRANS_CB(trans, PM_TRANS_CB_CONFLICTS_DONE, NULL, NULL);
+ }
+
+ return(0);
+}
+
+int add_commit(pmdb_t *db, pmtrans_t *trans)
+{
+ int i, ret = 0, errors = 0;
+ TAR *tar = NULL;
+ char expath[PATH_MAX];
+ time_t t;
+ pmpkg_t *info = NULL;
+ PMList *targ, *lp;
+
+ ASSERT(db != NULL, PM_RET_ERR(PM_ERR_DB_NULL, -1));
+ ASSERT(trans != NULL, PM_RET_ERR(PM_ERR_TRANS_NULL, -1));
+
+ if(trans->packages == NULL) {
+ return(0);
+ }
+
+ for(targ = trans->packages; targ; targ = targ->next) {
+ tartype_t gztype = {
+ (openfunc_t)_alpm_gzopen_frontend,
+ (closefunc_t)gzclose,
+ (readfunc_t)gzread,
+ (writefunc_t)gzwrite
+ };
+ unsigned short pmo_upgrade = (trans->type == PM_TRANS_TYPE_UPGRADE) ? 1 : 0;
+ char pm_install[PATH_MAX];
+ pmpkg_t *oldpkg = NULL;
+ info = (pmpkg_t *)targ->data;
+ errors = 0;
+
+ /* see if this is an upgrade. if so, remove the old package first */
+ if(pmo_upgrade) {
+ if(pkg_isin(info, db_get_pkgcache(db))) {
+ TRANS_CB(trans, PM_TRANS_CB_UPGRADE_START, info, NULL);
+
+ /* we'll need the full record for backup checks later */
+ if((oldpkg = db_scan(db, info->name, INFRQ_ALL)) != NULL) {
+ pmtrans_t *tr;
+
+ _alpm_log(PM_LOG_FLOW2, "removing old package first...\n");
+ /* ORE
+ set flags to something, but what (nodeps?) ??? */
+ tr = trans_new();
+ if(tr == NULL) {
+ PM_RET_ERR(PM_ERR_TRANS_ABORT, -1);
+ }
+ if(trans_init(tr, PM_TRANS_TYPE_UPGRADE, 0, NULL) == -1) {
+ FREETRANS(tr);
+ PM_RET_ERR(PM_ERR_TRANS_ABORT, -1);
+ }
+ if(remove_loadtarget(db, tr, info->name) == -1) {
+ FREETRANS(tr);
+ PM_RET_ERR(PM_ERR_TRANS_ABORT, -1);
+ }
+ if(remove_commit(db, tr) == -1) {
+ FREETRANS(tr);
+ PM_RET_ERR(PM_ERR_TRANS_ABORT, -1);
+ }
+ FREETRANS(tr);
+ }
+ } else {
+ /* no previous package version is installed, so this is actually just an
+ * install
+ */
+ pmo_upgrade = 0;
+ }
+ }
+ if(!pmo_upgrade) {
+ TRANS_CB(trans, PM_TRANS_CB_ADD_START, info, NULL);
+ }
+
+ /* Add the package to the database */
+ t = time(NULL);
+
+ /* Update the requiredby field by scaning the whole database
+ * looking for packages depending on the package to add */
+ for(lp = db_get_pkgcache(db); lp; lp = lp->next) {
+ pmpkg_t *tmpp = NULL;
+ PMList *tmppm = NULL;
+
+ tmpp = db_scan(db, ((pmpkg_t *)lp->data)->name, INFRQ_DEPENDS);
+ if(tmpp == NULL) {
+ continue;
+ }
+ for(tmppm = tmpp->depends; tmppm; tmppm = tmppm->next) {
+ pmdepend_t depend;
+ splitdep(tmppm->data, &depend);
+ if(tmppm->data && !strcmp(depend.name, info->name)) {
+ info->requiredby = pm_list_add(info->requiredby, strdup(tmpp->name));
+ continue;
+ }
+ }
+ }
+
+ _alpm_log(PM_LOG_FLOW2, "updating database...");
+ /* Figure out whether this package was installed explicitly by the user
+ * or installed as a dependency for another package
+ */
+ /* ORE
+ info->reason = PM_PKG_REASON_EXPLICIT;
+ if(pm_list_is_strin(dependonly, info->data)) {
+ info->reason = PM_PKG_REASON_DEPEND;
+ }*/
+ /* make an install date (in UTC) */
+ strncpy(info->installdate, asctime(gmtime(&t)), sizeof(info->installdate));
+ if(db_write(db, info, INFRQ_ALL)) {
+ _alpm_log(PM_LOG_ERROR, "could not update database for %s", info->name);
+ alpm_logaction(NULL, "error updating database for %s!", info->name);
+ PM_RET_ERR(PM_ERR_DB_WRITE, -1);
+ }
+
+ /* update dependency packages' REQUIREDBY fields */
+ for(lp = info->depends; lp; lp = lp->next) {
+ pmpkg_t *depinfo = NULL;
+ pmdepend_t depend;
+
+ splitdep(lp->data, &depend);
+ depinfo = db_scan(db, depend.name, INFRQ_DESC|INFRQ_DEPENDS);
+ if(depinfo == NULL) {
+ /* look for a provides package */
+ PMList *provides = _alpm_db_whatprovides(db, depend.name);
+ if(provides) {
+ /* use the first one */
+ depinfo = db_scan(db, ((pmpkg_t *)provides->data)->name, INFRQ_DEPENDS);
+ if(depinfo == NULL) {
+ PMList *lp;
+ /* wtf */
+ for(lp = provides; lp; lp = lp->next) {
+ lp->data = NULL;
+ }
+ pm_list_free(provides);
+ continue;
+ }
+ } else {
+ continue;
+ }
+ }
+ depinfo->requiredby = pm_list_add(depinfo->requiredby, strdup(info->name));
+ db_write(db, depinfo, INFRQ_DEPENDS);
+ FREEPKG(depinfo);
+ }
+
+ /* Extract the .tar.gz package */
+ if(tar_open(&tar, info->data, &gztype, O_RDONLY, 0, TAR_GNU) == -1) {
+ PM_RET_ERR(PM_ERR_PKG_OPEN, -1);
+ }
+ _alpm_log(PM_LOG_DEBUG, "extracting files...");
+ for(i = 0; !th_read(tar); i++) {
+ int nb = 0;
+ int notouch = 0;
+ char *md5_orig = NULL;
+ char pathname[PATH_MAX];
+ struct stat buf;
+
+ strncpy(pathname, th_get_pathname(tar), PATH_MAX);
+
+ if(!strcmp(pathname, ".PKGINFO") || !strcmp(pathname, ".FILELIST")) {
+ tar_skip_regfile(tar);
+ continue;
+ }
+
+ if(!strcmp(pathname, "._install") || !strcmp(pathname, ".INSTALL")) {
+ /* the install script goes inside the db */
+ snprintf(expath, PATH_MAX, "%s/%s-%s/install", db->path, info->name, info->version);
+ } else {
+ /* build the new pathname relative to handle->root */
+ snprintf(expath, PATH_MAX, "%s%s", handle->root, pathname);
+ }
+
+ if(!stat(expath, &buf) && !S_ISDIR(buf.st_mode)) {
+ /* file already exists */
+ if(pm_list_is_strin(pathname, handle->noupgrade)) {
+ notouch = 1;
+ } else {
+ if(!pmo_upgrade || oldpkg == NULL) {
+ nb = pm_list_is_strin(pathname, info->backup) ? 1 : 0;
+ } else {
+ /* op == PM_UPGRADE */
+ if((md5_orig = _alpm_needbackup(pathname, oldpkg->backup)) != 0) {
+ nb = 1;
+ }
+ }
+ }
+ }
+
+ if(nb) {
+ char *temp;
+ char *md5_local, *md5_pkg;
+
+ md5_local = MDFile(expath);
+ /* extract the package's version to a temporary file and md5 it */
+ temp = strdup("/tmp/pacman_XXXXXX");
+ mkstemp(temp);
+ if(tar_extract_file(tar, temp)) {
+ alpm_logaction("could not extract %s: %s", pathname, strerror(errno));
+ errors++;
+ continue;
+ }
+ md5_pkg = MDFile(temp);
+ /* append the new md5 hash to it's respective entry in info->backup
+ * (it will be the new orginal)
+ */
+ for(lp = info->backup; lp; lp = lp->next) {
+ char *fn;
+
+ if(!lp->data) continue;
+ if(!strcmp((char*)lp->data, pathname)) {
+ /* 32 for the hash, 1 for the terminating NULL, and 1 for the tab delimiter */
+ MALLOC(fn, strlen(lp->data)+34);
+ sprintf(fn, "%s\t%s", (char*)lp->data, md5_pkg);
+ FREE(lp->data);
+ lp->data = fn;
+ }
+ }
+
+ _alpm_log(PM_LOG_FLOW2, " checking md5 hashes for %s", expath);
+ _alpm_log(PM_LOG_FLOW2, " current: %s", md5_local);
+ _alpm_log(PM_LOG_FLOW2, " new: %s", md5_pkg);
+ if(md5_orig) {
+ _alpm_log(PM_LOG_FLOW2, " original: %s", md5_orig);
+ }
+
+ if(!pmo_upgrade) {
+ /* PM_ADD */
+
+ /* if a file already exists with a different md5 hash,
+ * then we rename it to a .pacorig extension and continue */
+ if(strcmp(md5_local, md5_pkg)) {
+ char newpath[PATH_MAX];
+ snprintf(newpath, PATH_MAX, "%s.pacorig", expath);
+ if(rename(expath, newpath)) {
+ _alpm_log(PM_LOG_ERROR, "could not rename %s: %s", expath, strerror(errno));
+ alpm_logaction("error: could not rename %s: %s", expath, strerror(errno));
+ }
+ if(_alpm_copyfile(temp, expath)) {
+ _alpm_log(PM_LOG_ERROR, "could not copy %s to %s: %s", temp, expath, strerror(errno));
+ alpm_logaction("error: could not copy %s to %s: %s", temp, expath, strerror(errno));
+ errors++;
+ } else {
+ _alpm_log(PM_LOG_WARNING, "warning: %s saved as %s", expath, newpath);
+ alpm_logaction("warning: %s saved as %s", expath, newpath);
+ }
+ }
+ } else if(md5_orig) {
+ /* PM_UPGRADE */
+ int installnew = 0;
+
+ /* the fun part */
+ if(!strcmp(md5_orig, md5_local)) {
+ if(!strcmp(md5_local, md5_pkg)) {
+ _alpm_log(PM_LOG_FLOW2, " action: installing new file");
+ installnew = 1;
+ } else {
+ _alpm_log(PM_LOG_FLOW2, " action: installing new file");
+ installnew = 1;
+ }
+ } else if(!strcmp(md5_orig, md5_pkg)) {
+ _alpm_log(PM_LOG_FLOW2, " action: leaving existing file in place");
+ } else if(!strcmp(md5_local, md5_pkg)) {
+ _alpm_log(PM_LOG_FLOW2, " action: installing new file");
+ installnew = 1;
+ } else {
+ char newpath[PATH_MAX];
+ _alpm_log(PM_LOG_FLOW2, " action: saving current file and installing new one");
+ installnew = 1;
+ snprintf(newpath, PATH_MAX, "%s.pacsave", expath);
+ if(rename(expath, newpath)) {
+ _alpm_log(PM_LOG_ERROR, "could not rename %s: %s", expath, strerror(errno));
+ alpm_logaction("error: could not rename %s: %s", expath, strerror(errno));
+ } else {
+ _alpm_log(PM_LOG_WARNING, "warning: %s saved as %s", expath, newpath);
+ alpm_logaction("warning: %s saved as %s", expath, newpath);
+ }
+ }
+
+ if(installnew) {
+ /*_alpm_log(PM_LOG_FLOW2, " %s", expath);*/
+ if(_alpm_copyfile(temp, expath)) {
+ _alpm_log(PM_LOG_ERROR, "could not copy %s to %s: %s", temp, expath, strerror(errno));
+ errors++;
+ }
+ }
+ }
+
+ FREE(md5_local);
+ FREE(md5_pkg);
+ FREE(md5_orig);
+ unlink(temp);
+ FREE(temp);
+ } else {
+ if(!notouch) {
+ _alpm_log(PM_LOG_FLOW2, "%s", pathname);
+ } else {
+ _alpm_log(PM_LOG_FLOW2, "%s is in NoUpgrade - skipping", pathname);
+ strncat(expath, ".pacnew", PATH_MAX);
+ _alpm_log(PM_LOG_WARNING, "warning: extracting %s%s as %s", handle->root, pathname, expath);
+ alpm_logaction("warning: extracting %s%s as %s", handle->root, pathname, expath);
+ tar_skip_regfile(tar);
+ }
+ if(trans->flags & PM_TRANS_FLAG_FORCE) {
+ /* if FORCE was used, then unlink() each file (whether it's there
+ * or not) before extracting. this prevents the old "Text file busy"
+ * error that crops up if one tries to --force a glibc or pacman
+ * upgrade.
+ */
+ unlink(expath);
+ }
+ if(tar_extract_file(tar, expath)) {
+ _alpm_log(PM_LOG_ERROR, "could not extract %s: %s", pathname, strerror(errno));
+ alpm_logaction("could not extract %s: %s", pathname, strerror(errno));
+ errors++;
+ }
+ /* calculate an md5 hash if this is in info->backup */
+ for(lp = info->backup; lp; lp = lp->next) {
+ char *fn, *md5;
+ char path[PATH_MAX];
+
+ if(!lp->data) continue;
+ if(!strcmp((char*)lp->data, pathname)) {
+ snprintf(path, PATH_MAX, "%s%s", handle->root, (char*)lp->data);
+ md5 = MDFile(path);
+ /* 32 for the hash, 1 for the terminating NULL, and 1 for the tab delimiter */
+ MALLOC(fn, strlen(lp->data)+34);
+ sprintf(fn, "%s\t%s", (char*)lp->data, md5);
+ FREE(lp->data);
+ lp->data = fn;
+ }
+ }
+ }
+ }
+ tar_close(tar);
+
+ if(errors) {
+ ret = 1;
+ _alpm_log(PM_LOG_ERROR, "errors occurred while %s %s",
+ (pmo_upgrade ? "upgrading" : "installing"), info->name);
+ alpm_logaction("errors occurred while %s %s",
+ (pmo_upgrade ? "upgrading" : "installing"), info->name);
+ }
+
+ /* run the post-install script if it exists */
+ snprintf(pm_install, PATH_MAX, "%s%s/%s/%s-%s/install", handle->root, handle->dbpath, db->treename, info->name, info->version);
+ if(pmo_upgrade) {
+ _alpm_runscriptlet(handle->root, pm_install, "post_upgrade", info->version, oldpkg ? oldpkg->version : NULL);
+ } else {
+ _alpm_runscriptlet(handle->root, pm_install, "post_install", info->version, NULL);
+ }
+
+ if(pmo_upgrade && oldpkg) {
+ TRANS_CB(trans, PM_TRANS_CB_UPGRADE_DONE, info, NULL);
+ alpm_logaction("upgraded %s (%s -> %s)", info->name,
+ oldpkg->version, info->version);
+ } else {
+ TRANS_CB(trans, PM_TRANS_CB_ADD_DONE, info, NULL);
+ alpm_logaction("installed %s (%s)", info->name, info->version);
+ }
+
+ FREEPKG(oldpkg);
+ }
+
+ /* run ldconfig if it exists */
+ _alpm_log(PM_LOG_FLOW2, "running \"%ssbin/ldconfig -r %s\"", handle->root, handle->root);
+ _alpm_ldconfig(handle->root);
+
+ return(0);
+}
+
+/* vim: set ts=2 sw=2 noet: */