path: root/lib/libalpm/be_sync.c

/*
 *  be_sync.c : backend for sync databases
 *
 *  Copyright (c) 2006-2011 Pacman Development Team <pacman-dev@archlinux.org>
 *  Copyright (c) 2002-2006 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, see <http://www.gnu.org/licenses/>.
 */

#include "config.h"

#include <errno.h>
#include <sys/stat.h>
#include <unistd.h>

/* libarchive */
#include <archive.h>
#include <archive_entry.h>

/* libalpm */
#include "util.h"
#include "log.h"
#include "alpm.h"
#include "alpm_list.h"
#include "package.h"
#include "handle.h"
#include "delta.h"
#include "deps.h"
#include "dload.h"

static char *get_sync_dir(alpm_handle_t *handle)
{
  size_t len = strlen(handle->dbpath) + 6;
  char *syncpath;
  struct stat buf;

  MALLOC(syncpath, len, RET_ERR(handle, ALPM_ERR_MEMORY, NULL));
  sprintf(syncpath, "%s%s", handle->dbpath, "sync/");

  if(stat(syncpath, &buf) != 0) {
    _alpm_log(handle, ALPM_LOG_DEBUG, "database dir '%s' does not exist, creating it\n",
        syncpath);
    if(_alpm_makepath(syncpath) != 0) {
      free(syncpath);
      RET_ERR(handle, ALPM_ERR_SYSTEM, NULL);
    }
  } else if(!S_ISDIR(buf.st_mode)) {
    _alpm_log(handle, ALPM_LOG_WARNING, _("removing invalid file: %s\n"), syncpath);
    if(unlink(syncpath) != 0 || _alpm_makepath(syncpath) != 0) {
      free(syncpath);
      RET_ERR(handle, ALPM_ERR_SYSTEM, NULL);
    }
  }

  return syncpath;
}

static int sync_db_validate(alpm_db_t *db)
{
  alpm_siglevel_t level;
  const char *dbpath;

  if(db->status & DB_STATUS_VALID || db->status & DB_STATUS_MISSING) {
    return 0;
  }
  if(db->status & DB_STATUS_INVALID) {
    db->handle->pm_errno = ALPM_ERR_DB_INVALID_SIG;
    return -1;
  }

  dbpath = _alpm_db_path(db);
  if(!dbpath) {
    /* pm_errno set in _alpm_db_path() */
    return -1;