Skip to content

Commit

Permalink
tweak unpack channel built-in, std::filesystem::path for tarball
Browse files Browse the repository at this point in the history
  • Loading branch information
Ericson2314 committed Sep 11, 2024
1 parent 04ce0e6 commit 193dc49
Show file tree
Hide file tree
Showing 3 changed files with 37 additions and 27 deletions.
36 changes: 21 additions & 15 deletions src/libstore/builtins/unpack-channel.cc
Original file line number Diff line number Diff line change
Expand Up @@ -3,46 +3,52 @@

namespace nix {

namespace fs { using namespace std::filesystem; }

void builtinUnpackChannel(
const BasicDerivation & drv,
const std::map<std::string, Path> & outputs)
{
auto getAttr = [&](const std::string & name) {
auto getAttr = [&](const std::string & name) -> const std::string & {
auto i = drv.env.find(name);
if (i == drv.env.end()) throw Error("attribute '%s' missing", name);
return i->second;
};

std::filesystem::path out(outputs.at("out"));
std::filesystem::path channelName(getAttr("channelName"));
auto src = getAttr("src");
fs::path out{outputs.at("out")};
auto & channelName = getAttr("channelName");
auto & src = getAttr("src");

if (channelName.filename() != channelName) {
if (fs::path{channelName}.filename().string() != channelName) {
throw Error("channelName is not allowed to contain filesystem seperators, got %1%", channelName);
}

createDirs(out);
try {
fs::create_directories(out);
} catch (fs::filesystem_error &) {
throw SysError("creating directory '%1%'", out.string());
}

unpackTarfile(src, out);

size_t fileCount;
std::string fileName;
try {
auto entries = std::filesystem::directory_iterator{out};
auto entries = fs::directory_iterator{out};
fileName = entries->path().string();
fileCount = std::distance(std::filesystem::begin(entries), std::filesystem::end(entries));
} catch (std::filesystem::filesystem_error &e) {
throw SysError("failed to read directory %1%", out);
fileCount = std::distance(fs::begin(entries), fs::end(entries));
} catch (fs::filesystem_error &) {
throw SysError("failed to read directory %1%", out.string());
}


if (fileCount != 1)
throw Error("channel tarball '%s' contains more than one file", src);
std::filesystem::path target(out / channelName);

auto target = out / channelName;
try {
std::filesystem::rename(fileName, target);
} catch (std::filesystem::filesystem_error &e) {
throw SysError("failed to rename %1% to %2%", fileName, target);
fs::rename(fileName, target);
} catch (fs::filesystem_error &) {
throw SysError("failed to rename %1% to %2%", fileName, target.string());
}
}

Expand Down
22 changes: 13 additions & 9 deletions src/libutil/tarfile.cc
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,10 @@

namespace nix {

namespace fs {
using namespace std::filesystem;
}

namespace {

int callback_open(struct archive *, void * self)
Expand Down Expand Up @@ -102,14 +106,14 @@ TarArchive::TarArchive(Source & source, bool raw, std::optional<std::string> com
"Failed to open archive (%s)");
}

TarArchive::TarArchive(const Path & path)
TarArchive::TarArchive(const fs::path & path)
: archive{archive_read_new()}
, buffer(defaultBufferSize)
{
archive_read_support_filter_all(archive);
enableSupportedFormats(archive);
archive_read_set_option(archive, NULL, "mac-ext", NULL);
check(archive_read_open_filename(archive, path.c_str(), 16384), "failed to open archive: %s");
check(archive_read_open_filename(archive, path.string().c_str(), 16384), "failed to open archive: %s");
}

void TarArchive::close()
Expand All @@ -123,7 +127,7 @@ TarArchive::~TarArchive()
archive_read_free(this->archive);
}

static void extract_archive(TarArchive & archive, const Path & destDir)
static void extract_archive(TarArchive & archive, const fs::path & destDir)
{
int flags = ARCHIVE_EXTRACT_TIME | ARCHIVE_EXTRACT_SECURE_SYMLINKS | ARCHIVE_EXTRACT_SECURE_NODOTDOT;

Expand All @@ -140,7 +144,7 @@ static void extract_archive(TarArchive & archive, const Path & destDir)
else
archive.check(r);

archive_entry_copy_pathname(entry, (destDir + "/" + name).c_str());
archive_entry_copy_pathname(entry, (destDir / name).string().c_str());

// sources can and do contain dirs with no rx bits
if (archive_entry_filetype(entry) == AE_IFDIR && (archive_entry_mode(entry) & 0500) != 0500)
Expand All @@ -149,7 +153,7 @@ static void extract_archive(TarArchive & archive, const Path & destDir)
// Patch hardlink path
const char * original_hardlink = archive_entry_hardlink(entry);
if (original_hardlink) {
archive_entry_copy_hardlink(entry, (destDir + "/" + original_hardlink).c_str());
archive_entry_copy_hardlink(entry, (destDir / original_hardlink).string().c_str());
}

archive.check(archive_read_extract(archive.archive, entry, flags));
Expand All @@ -158,19 +162,19 @@ static void extract_archive(TarArchive & archive, const Path & destDir)
archive.close();
}

void unpackTarfile(Source & source, const Path & destDir)
void unpackTarfile(Source & source, const fs::path & destDir)
{
auto archive = TarArchive(source);

createDirs(destDir);
fs::create_directories(destDir);
extract_archive(archive, destDir);
}

void unpackTarfile(const Path & tarFile, const Path & destDir)
void unpackTarfile(const fs::path & tarFile, const fs::path & destDir)
{
auto archive = TarArchive(tarFile);

createDirs(destDir);
fs::create_directories(destDir);
extract_archive(archive, destDir);
}

Expand Down
6 changes: 3 additions & 3 deletions src/libutil/tarfile.hh
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ struct TarArchive

void check(int err, const std::string & reason = "failed to extract archive (%s)");

explicit TarArchive(const Path & path);
explicit TarArchive(const std::filesystem::path & path);

/// @brief Create a generic archive from source.
/// @param source - Input byte stream.
Expand All @@ -37,9 +37,9 @@ struct TarArchive

int getArchiveFilterCodeByName(const std::string & method);

void unpackTarfile(Source & source, const Path & destDir);
void unpackTarfile(Source & source, const std::filesystem::path & destDir);

void unpackTarfile(const Path & tarFile, const Path & destDir);
void unpackTarfile(const std::filesystem::path & tarFile, const std::filesystem::path & destDir);

time_t unpackTarfileToSink(TarArchive & archive, ExtendedFileSystemObjectSink & parseSink);

Expand Down

0 comments on commit 193dc49

Please sign in to comment.