VPK.cpp

Go to the documentation of this file.

// ReSharper disable CppRedundantQualifier
 
#include <vpkpp/format/VPK.h>
 
#include <cstdio>
#include <filesystem>
#include <format>
 
#include <FileStream.h>
#include <kvpp/kvpp.h>
#include <sourcepp/crypto/CRC32.h>
#include <sourcepp/crypto/MD5.h>
#include <sourcepp/crypto/RSA.h>
#include <sourcepp/FS.h>
#include <sourcepp/String.h>
#include <tomcrypt.h>
#include <vpkpp/format/FPX.h>
 
#ifdef VPKPP_SUPPORT_VPK_V54
#include <zstd.h>
#endif
 
using namespace kvpp;
using namespace sourcepp;
using namespace vpkpp;

constexpr uint32_t VPK_FLAG_REUSING_CHUNK = 0x1;
 
namespace {
 
std::string removeVPKAndOrDirSuffix(const std::string& path, bool isFPX) {
    std::string filename = path;
    if (filename.length() >= 4 && filename.substr(filename.length() - 4) == (isFPX ? FPX_EXTENSION : VPK_EXTENSION)) {
        filename = filename.substr(0, filename.length() - 4);
    }
 
    // This indicates it's a dir VPK, but some people ignore this convention...
    // It should fail later if it's not a proper dir VPK
    if (filename.length() >= 4 && filename.substr(filename.length() - 4) == (isFPX ? FPX_DIR_SUFFIX : VPK_DIR_SUFFIX)) {
        filename = filename.substr(0, filename.length() - 4);
    }
 
    return filename;
}
 
bool isFPX(const VPK* vpk) {
    return dynamic_cast<const FPX*>(vpk);
}
 
} // namespace
 
std::unique_ptr<PackFile> VPK::create(const std::string& path, uint32_t version) {
    if (version != 0 && version != 1 && version != 2 && version != 54) {
        return nullptr;
    }
 
    {
        FileStream stream{path, FileStream::OPT_TRUNCATE | FileStream::OPT_CREATE_IF_NONEXISTENT};
 
        if (version > 0) {
            Header1 header1{};
            header1.signature = VPK_SIGNATURE;
            header1.version = version;
            header1.treeSize = 1;
            stream.write(header1);
        }
        if (version > 1) {
            Header2 header2{};
            header2.fileDataSectionSize = 0;
            header2.archiveMD5SectionSize = 0;
            header2.otherMD5SectionSize = 0;
            header2.signatureSectionSize = 0;
            stream.write(header2);
        }
 
        stream.write('\0');
    }
    return VPK::open(path);
}
 
std::unique_ptr<PackFile> VPK::open(const std::string& path, const EntryCallback& callback) {
    // Try loading the directory VPK first if this is a numbered archive and the dir exists
    if (path.length() >= 8) {
        const auto dirPath = path.substr(0, path.length() - 8) + "_dir.vpk";
        const auto pathEnd = path.substr(path.length() - 8, path.length());
        if (string::matches(pathEnd, "_%d%d%d.vpk") && std::filesystem::exists(dirPath)) {
            if (std::unique_ptr<PackFile> vpk = VPK::openInternal(dirPath, callback)) {
                return vpk;
            }
        }
    }
 
    return VPK::openInternal(path, callback);
}
 
std::unique_ptr<PackFile> VPK::openInternal(const std::string& path, const EntryCallback& callback) {
    if (!std::filesystem::exists(path)) {
        // File does not exist
        return nullptr;
    }
 
    auto* vpk = new VPK{path};
    auto packFile = std::unique_ptr<PackFile>{vpk};
 
    FileStream reader{vpk->fullFilePath};
    reader.seek_in(0);
    reader.read(vpk->header1);
    if (vpk->header1.signature != VPK_SIGNATURE) {
        reader.seek_in(3, std::ios::end);
        if (reader.read<char>() == '\0' && reader.read<char>() == '\0' && reader.read<char>() == '\0') {
            // hack: if file is 9 bytes long it's probably an empty VTMB VPK and we should bail so that code can pick it up
            // either way a 9 byte long VPK should not have any files in it
            if (std::filesystem::file_size(vpk->fullFilePath) == 9) {
                return nullptr;
            }
 
            // File is one of those shitty ancient VPKs
            vpk->header1.signature = VPK_SIGNATURE;
            vpk->header1.version = 0;
            vpk->header1.treeSize = 0;
 
            reader.seek_in(0);
        } else {
            // File is not a VPK
            return nullptr;
        }
    }
    if (vpk->hasExtendedHeader()) {
        reader.read(vpk->header2);
    } else if (vpk->header1.version != 0 && vpk->header1.version != 1) {
        // Apex Legends, Titanfall, etc. are not supported
        return nullptr;
    }
 
    // Extensions
    while (true) {
        std::string extension;
        reader.read(extension);
        if (extension.empty())
            break;
 
        // Directories
        while (true) {
            std::string directory;
            reader.read(directory);
            if (directory.empty())
                break;
 
            std::string fullDir;
            if (directory == " ") {
                fullDir = "";
            } else {
                fullDir = directory;
            }
 
            // Files
            while (true) {
                std::string entryName;
                reader.read(entryName);
                if (entryName.empty())
                    break;
 
                Entry entry = createNewEntry();
 
                std::string entryPath;
                if (extension == " ") {
                    entryPath = fullDir.empty() ? "" : fullDir + '/';
                    entryPath += entryName;
                } else {
                    entryPath = fullDir.empty() ? "" : fullDir + '/';
                    entryPath += entryName + '.';
                    entryPath += extension;
                }
                entryPath = vpk->cleanEntryPath(entryPath);
 
                reader.read(entry.crc32);
                const auto preloadedDataSize = reader.read<uint16_t>();
                entry.archiveIndex = reader.read<uint16_t>();
                entry.offset = reader.read<uint32_t>();
                entry.length = reader.read<uint32_t>();
 
                if (vpk->hasCompression()) {
                    entry.compressedLength = reader.read<uint32_t>();
                }
 
                if (reader.read<uint16_t>() != VPK_ENTRY_TERM) {
                    // Invalid terminator!
                    return nullptr;
                }
 
                if (preloadedDataSize > 0) {
                    entry.extraData = reader.read_bytes(preloadedDataSize);
                    entry.length += preloadedDataSize;
                }
 
                if (entry.archiveIndex != VPK_DIR_INDEX && std::cmp_greater(entry.archiveIndex, vpk->numArchives)) {
                    vpk->numArchives = static_cast<int32_t>(entry.archiveIndex);
                }
 
 
                vpk->entries.emplace(entryPath, entry);
 
                if (callback) {
                    callback(entryPath, entry);
                }
            }
        }
    }
 
    // If there are no archives, -1 will be incremented to 0
    vpk->numArchives++;
 
    // VPK v1 has nothing else for us
    if (!vpk->hasExtendedHeader()) {
        return packFile;
    }
 
    // Skip over file data, if any
    reader.seek_in(vpk->header2.fileDataSectionSize, std::ios::cur);
 
    if (vpk->header2.archiveMD5SectionSize % sizeof(MD5Entry) != 0) {
        return nullptr;
    }
 
    vpk->md5Entries.clear();
    const unsigned int entryNum = vpk->header2.archiveMD5SectionSize / sizeof(MD5Entry);
    for (unsigned int i = 0; i < entryNum; i++) {
        vpk->md5Entries.push_back(reader.read<MD5Entry>());
    }
 
    if (vpk->header2.otherMD5SectionSize != 48) {
        // This should always be 48
        return packFile;
    }
 
    vpk->footer2.treeChecksum = reader.read_bytes<16>();
    vpk->footer2.md5EntriesChecksum = reader.read_bytes<16>();
    vpk->footer2.wholeFileChecksum = reader.read_bytes<16>();
 
    if (!vpk->header2.signatureSectionSize) {
        return packFile;
    }
 
    const auto publicKeySize = reader.read<int32_t>();
    if (vpk->header2.signatureSectionSize == 20 && publicKeySize == VPK_SIGNATURE) {
        // CS2 beta VPK, ignore it
        return packFile;
    }
 
    vpk->footer2.publicKey = reader.read_bytes(publicKeySize);
    vpk->footer2.signature = reader.read_bytes(reader.read<int32_t>());
 
    return packFile;
}
 
std::vector<std::string> VPK::verifyEntryChecksums() const {
    return this->verifyEntryChecksumsUsingCRC32();
}
 
bool VPK::hasPackFileChecksum() const {
    return this->hasExtendedHeader();
}
 
bool VPK::verifyPackFileChecksum() const {
    // File checksums aren't in v1
    if (!this->hasExtendedHeader()) {
        return true;
    }
 
    FileStream stream{this->getFilepath().data()};
 
    stream.seek_in(this->getHeaderLength());
    if (this->footer2.treeChecksum != crypto::computeMD5(stream.read_bytes(this->header1.treeSize))) {
        return false;
    }
 
    stream.seek_in(this->getHeaderLength() + this->header1.treeSize + this->header2.fileDataSectionSize);
    if (this->footer2.md5EntriesChecksum != crypto::computeMD5(stream.read_bytes(this->header2.archiveMD5SectionSize))) {
        return false;
    }
 
    stream.seek_in(0);
    if (this->footer2.wholeFileChecksum != crypto::computeMD5(stream.read_bytes(this->getHeaderLength() + this->header1.treeSize + this->header2.fileDataSectionSize + this->header2.archiveMD5SectionSize + this->header2.otherMD5SectionSize - sizeof(this->footer2.wholeFileChecksum)))) {
        return false;
    }
 
    return true;
}
 
bool VPK::hasPackFileSignature() const {
    if (!this->hasExtendedHeader()) {
        return false;
    }
    if (this->footer2.publicKey.empty() || this->footer2.signature.empty()) {
        return false;
    }
    return true;
}
 
bool VPK::verifyPackFileSignature() const {
    // Signatures aren't in v1
    if (!this->hasExtendedHeader()) {
        return true;
    }
 
    if (this->footer2.publicKey.empty() || this->footer2.signature.empty()) {
        return true;
    }
    auto dirFileBuffer = fs::readFileBuffer(this->getFilepath().data());
    const auto signatureSectionSize = this->footer2.publicKey.size() + this->footer2.signature.size() + sizeof(uint32_t) * 2;
    if (dirFileBuffer.size() <= signatureSectionSize) {
        return false;
    }
    dirFileBuffer.resize(dirFileBuffer.size() - signatureSectionSize);
    return crypto::verifySHA256PublicKey(dirFileBuffer, this->footer2.publicKey, this->footer2.signature);
}
 
// NOLINTNEXTLINE(*-no-recursion)
std::optional<std::vector<std::byte>> VPK::readEntry(const std::string& path_) const {
    const auto path = this->cleanEntryPath(path_);
    auto entry = this->findEntry(path);
    if (!entry) {
        return std::nullopt;
    }
    if (entry->unbaked) {
        return readUnbakedEntry(*entry);
    }
 
    const auto entryLength = this->hasCompression() && entry->compressedLength ? entry->compressedLength : entry->length;
    if (entryLength == 0) {
        return std::vector<std::byte>{};
    }
    std::vector out(entryLength, static_cast<std::byte>(0));
 
    if (!entry->extraData.empty()) {
        std::ranges::copy(entry->extraData, out.begin());
    }
    if (entryLength != entry->extraData.size()) {
        if (entry->archiveIndex != VPK_DIR_INDEX) {
            // Stored in a numbered archive
            FileStream stream{this->getTruncatedFilepath() + '_' + string::padNumber(entry->archiveIndex, 3) + std::string{::isFPX(this) ? FPX_EXTENSION : VPK_EXTENSION}};
            if (!stream) {
                return std::nullopt;
            }
            stream.seek_in_u(entry->offset);
            auto bytes = stream.read_bytes(entryLength - entry->extraData.size());
            std::ranges::copy(bytes, out.begin() + static_cast<long long>(entry->extraData.size()));
        } else {
            // Stored in this directory VPK
            FileStream stream{this->fullFilePath};
            if (!stream) {
                return std::nullopt;
            }
            stream.seek_in_u(this->getHeaderLength() + this->header1.treeSize + entry->offset);
            auto bytes = stream.read_bytes(entry->length - entry->extraData.size());
            std::ranges::copy(bytes, out.begin() + static_cast<long long>(entry->extraData.size()));
        }
    }
 
#ifndef VPKPP_SUPPORT_VPK_V54
    return out;
#else
    if (!this->hasCompression() || !entry->compressedLength) {
        return out;
    }
 
    const auto decompressionDict = this->readEntry(this->getTruncatedFilestem() + ".dict");
    if (!decompressionDict) {
        return std::nullopt;
    }
 
    const std::unique_ptr<ZSTD_DDict, void(*)(void*)> dDict{
        ZSTD_createDDict(decompressionDict->data(), decompressionDict->size()),
        [](void* dDict_) { ZSTD_freeDDict(static_cast<ZSTD_DDict*>(dDict_)); },
    };
    if (!dDict) {
        return std::nullopt;
    }
 
    const std::unique_ptr<ZSTD_DCtx, void(*)(void*)> dCtx{
        ZSTD_createDCtx(),
        [](void* dCtx_) { ZSTD_freeDCtx(static_cast<ZSTD_DCtx*>(dCtx_)); },
    };
    if (!dCtx) {
        return std::nullopt;
    }
 
    std::vector<std::byte> decompressedData;
    decompressedData.resize(entry->length);
 
    if (ZSTD_isError(ZSTD_decompress_usingDDict(dCtx.get(), decompressedData.data(), decompressedData.size(), out.data(), out.size(), dDict.get()))) {
        return {};
    }
    return decompressedData;
#endif
}
 
void VPK::addEntryInternal(Entry& entry, const std::string&, std::vector<std::byte>& buffer, EntryOptions options) {
    if (this->hasCompression()) {
        // I don't feel like getting this to work right now
        options.vpk_preloadBytes = 0;
    }
 
    entry.crc32 = crypto::computeCRC32(buffer);
    entry.length = buffer.size();
 
    // Offset will be reset when it's baked, assuming we're not replacing an existing chunk (when flags = 1)
    // Compressed entries will not replace existing chunks, since their size is unknown
    entry.flags = 0;
    entry.offset = 0;
    entry.archiveIndex = options.vpk_saveToDirectory ? VPK_DIR_INDEX : this->numArchives;
    if (!options.vpk_saveToDirectory && !this->freedChunks.empty() && !this->hasCompression()) {
        int64_t bestChunkIndex = -1;
        std::size_t currentChunkGap = SIZE_MAX;
        for (int64_t i = 0; i < this->freedChunks.size(); i++) {
            if (
                (bestChunkIndex < 0 && this->freedChunks[i].length >= entry.length) ||
                (bestChunkIndex >= 0 && this->freedChunks[i].length >= entry.length && this->freedChunks[i].length - entry.length < currentChunkGap)
            ) {
                bestChunkIndex = i;
                currentChunkGap = this->freedChunks[i].length - entry.length;
            }
        }
        if (bestChunkIndex >= 0) {
            entry.flags |= VPK_FLAG_REUSING_CHUNK;
            entry.offset = this->freedChunks[bestChunkIndex].offset;
            entry.archiveIndex = this->freedChunks[bestChunkIndex].archiveIndex;
            this->freedChunks.erase(this->freedChunks.begin() + bestChunkIndex);
            if (currentChunkGap < SIZE_MAX && currentChunkGap > 0) {
                // Add the remaining free space as a free chunk
                this->freedChunks.push_back({
                    .offset = entry.offset + entry.length,
                    .length = currentChunkGap,
                    .archiveIndex = entry.archiveIndex,
                });
            }
        }
    }
 
    if (options.vpk_preloadBytes > 0) {
        const auto clampedPreloadBytes = std::clamp<uint16_t>(options.vpk_preloadBytes, 0, buffer.size() > VPK_MAX_PRELOAD_BYTES ? VPK_MAX_PRELOAD_BYTES : static_cast<uint16_t>(buffer.size()));
        entry.extraData.resize(clampedPreloadBytes);
        std::memcpy(entry.extraData.data(), buffer.data(), clampedPreloadBytes);
        buffer.erase(buffer.begin(), buffer.begin() + clampedPreloadBytes);
    }
 
    // Now that archive index is calculated for this entry, check if it needs to be incremented
    if (!options.vpk_saveToDirectory && !(entry.flags & VPK_FLAG_REUSING_CHUNK)) {
        entry.offset = this->currentlyFilledChunkSize;
        this->currentlyFilledChunkSize += static_cast<int>(buffer.size());
        if (this->currentlyFilledChunkSize > this->chunkSize) {
            this->currentlyFilledChunkSize = 0;
            this->numArchives++;
        }
    }
}
 
bool VPK::removeEntry(const std::string& filename_) {
    const auto filename = this->cleanEntryPath(filename_);
    if (const auto entry = this->findEntry(filename); entry && (!entry->unbaked || entry->flags & VPK_FLAG_REUSING_CHUNK)) {
        this->freedChunks.push_back({
            .offset = entry->offset,
            .length = entry->length,
            .archiveIndex = entry->archiveIndex,
        });
    }
    return PackFile::removeEntry(filename);
}
 
std::size_t VPK::removeDirectory(const std::string& dirName_) {
    auto dirName = this->cleanEntryPath(dirName_);
    if (!dirName.empty()) {
        dirName += '/';
    }
    this->runForAllEntries([this, &dirName](const std::string& path, const Entry& entry) {
        if (path.starts_with(dirName) && (!entry.unbaked || entry.flags & VPK_FLAG_REUSING_CHUNK)) {
            this->freedChunks.push_back({
                .offset = entry.offset,
                .length = entry.length,
                .archiveIndex = entry.archiveIndex,
            });
        }
    });
    return PackFile::removeDirectory(dirName_);
}
 
bool VPK::bake(const std::string& outputDir_, BakeOptions options, const EntryCallback& callback) {
    // Get the proper file output folder
    std::string outputDir = this->getBakeOutputDir(outputDir_);
    std::string outputPath = outputDir + '/' + this->getFilename();
 
#ifdef VPKPP_SUPPORT_VPK_V54
    // Store compression dictionary
    std::optional<std::vector<std::byte>> compressionDict;
    std::unique_ptr<ZSTD_CDict, void(*)(void*)> cDict{nullptr, nullptr};
    std::unique_ptr<ZSTD_CCtx, void(*)(void*)> cCtx{nullptr, nullptr};
    if (this->hasCompression()) {
        compressionDict = this->readEntry(this->getTruncatedFilestem() + ".dict");
        if (!compressionDict) {
            return false;
        }
 
        cDict = {
            ZSTD_createCDict(compressionDict->data(), compressionDict->size(), options.zip_compressionStrength),
            [](void* cDict_) { ZSTD_freeCDict(static_cast<ZSTD_CDict*>(cDict_)); },
        };
        if (!cDict) {
            return false;
        }
 
        cCtx = {
            ZSTD_createCCtx(),
            [](void* cCtx_) { ZSTD_freeCCtx(static_cast<ZSTD_CCtx*>(cCtx_)); },
        };
        if (!cCtx) {
            return false;
        }
    }
#endif
 
    // Reconstruct data so we're not looping over it a ton of times
    std::unordered_map<std::string, std::unordered_map<std::string, std::vector<std::pair<std::string, Entry*>>>> temp;
    this->runForAllEntriesInternal([&temp](const std::string& path, Entry& entry) {
        const auto fsPath = std::filesystem::path{path};
        auto extension = fsPath.extension().string();
        if (extension.starts_with('.')) {
            extension = extension.substr(1);
        }
        const auto parentDir = fsPath.parent_path().string();
 
        if (extension.empty()) {
            extension = " ";
        }
        if (!temp.contains(extension)) {
            temp[extension] = {};
        }
        if (!temp.at(extension).contains(parentDir)) {
            temp.at(extension)[parentDir] = {};
        }
        temp.at(extension).at(parentDir).emplace_back(path, &entry);
    });
 
    // Temporarily store baked file data that's stored in the directory VPK since it's getting overwritten
    std::vector<std::byte> dirVPKEntryData;
    std::size_t newDirEntryOffset = 0;
    this->runForAllEntriesInternal([this, &dirVPKEntryData, &newDirEntryOffset](const std::string& path, Entry& entry) {
        if (entry.archiveIndex != VPK_DIR_INDEX || entry.length == entry.extraData.size()) {
            return;
        }
 
        auto binData = this->readEntry(path);
        if (!binData) {
            return;
        }
        dirVPKEntryData.reserve(dirVPKEntryData.size() + entry.length - entry.extraData.size());
        dirVPKEntryData.insert(dirVPKEntryData.end(), binData->begin() + static_cast<std::vector<std::byte>::difference_type>(entry.extraData.size()), binData->end());
 
        entry.offset = newDirEntryOffset;
        newDirEntryOffset += entry.length - entry.extraData.size();
    }, false);
 
    // Helper
    const auto getArchiveFilename = [this](const std::string& filename_, uint32_t archiveIndex) {
        std::string out{filename_ + '_' + string::padNumber(archiveIndex, 3) + std::string{::isFPX(this) ? FPX_EXTENSION : VPK_EXTENSION}};
        string::normalizeSlashes(out);
        return out;
    };
 
    // Copy external binary blobs to the new dir
    if (!outputDir_.empty()) {
        for (uint32_t archiveIndex = 0; archiveIndex < this->numArchives; archiveIndex++) {
            std::string from = getArchiveFilename(this->getTruncatedFilepath(), archiveIndex);
            if (!std::filesystem::exists(from)) {
                continue;
            }
            std::string dest = getArchiveFilename(outputDir + '/' + this->getTruncatedFilestem(), archiveIndex);
            if (from == dest) {
                continue;
            }
            std::filesystem::copy_file(from, dest, std::filesystem::copy_options::overwrite_existing);
        }
    }
 
    FileStream outDir{outputPath, FileStream::OPT_READ | FileStream::OPT_TRUNCATE | FileStream::OPT_CREATE_IF_NONEXISTENT};
    outDir.seek_in(0);
    outDir.seek_out(0);
 
    // Dummy header
    if (this->header1.version > 0) {
        outDir.write(this->header1);
        if (this->hasExtendedHeader()) {
            outDir.write(this->header2);
        }
    }
 
    // File tree data
    for (auto& [ext, dirs] : temp) {
        outDir.write(ext);
 
        for (auto& [dir, tempEntries] : dirs) {
            outDir.write(!dir.empty() ? dir : " ");
 
            for (auto& [path, entry] : tempEntries) {
                // Calculate entry offset if it's unbaked and upload the data
                if (entry->unbaked) {
                    auto entryData = readUnbakedEntry(*entry);
                    if (!entryData) {
                        continue;
                    }
 
                    if (entry->length == entry->extraData.size() && !this->hasCompression()) {
                        // Override the archive index, no need for an archive VPK
                        entry->archiveIndex = VPK_DIR_INDEX;
                        entry->offset = dirVPKEntryData.size();
                    } else if (entry->archiveIndex != VPK_DIR_INDEX && entry->flags & VPK_FLAG_REUSING_CHUNK) {
                        // The entry is replacing pre-existing data in a VPK archive - it's not compressed
                        auto archiveFilename = getArchiveFilename(::removeVPKAndOrDirSuffix(outputPath, ::isFPX(this)), entry->archiveIndex);
                        FileStream stream{archiveFilename, FileStream::OPT_READ | FileStream::OPT_WRITE | FileStream::OPT_CREATE_IF_NONEXISTENT};
                        stream.seek_out_u(entry->offset);
                        stream.write(*entryData);
                    } else if (entry->archiveIndex != VPK_DIR_INDEX) {
                        // The entry is being appended to a newly created VPK archive
                        auto archiveFilename = getArchiveFilename(::removeVPKAndOrDirSuffix(outputPath, ::isFPX(this)), entry->archiveIndex);
                        entry->offset = std::filesystem::exists(archiveFilename) ? std::filesystem::file_size(archiveFilename) : 0;
                        FileStream stream{archiveFilename, FileStream::OPT_APPEND | FileStream::OPT_CREATE_IF_NONEXISTENT};
#ifndef VPKPP_SUPPORT_VPK_V54
                        stream.write(*entryData);
#else
                        if (!this->hasCompression() || path == this->getTruncatedFilestem() + ".dict") {
                            stream.write(*entryData);
                        } else {
                            std::vector<std::byte> compressedData;
                            compressedData.resize(ZSTD_compressBound(entryData->size()));
                            auto compressedSize = ZSTD_compress_usingCDict(cCtx.get(), compressedData.data(), compressedData.size(), entryData->data(), entryData->size(), cDict.get());
                            if (ZSTD_isError(compressedSize) || compressedData.size() < compressedSize) {
                                return false;
                            }
                            stream.write(std::span{compressedData.data(), compressedSize});
                            entry->compressedLength = compressedSize;
                        }
#endif
                    } else {
                        // The entry will be added to the directory VPK
                        entry->offset = dirVPKEntryData.size();
#ifndef VPKPP_SUPPORT_VPK_V54
                        dirVPKEntryData.insert(dirVPKEntryData.end(), entryData->data(), entryData->data() + entryData->size());
#else
                        if (!this->hasCompression() || path == this->getTruncatedFilestem() + ".dict") {
                            dirVPKEntryData.insert(dirVPKEntryData.end(), entryData->data(), entryData->data() + entryData->size());
                        } else {
                            std::vector<std::byte> compressedData;
                            compressedData.resize(ZSTD_compressBound(entryData->size()));
                            auto compressedSize = ZSTD_compress_usingCDict(cCtx.get(), compressedData.data(), compressedData.size(), entryData->data(), entryData->size(), cDict.get());
                            if (ZSTD_isError(compressedSize) || compressedData.size() < compressedSize) {
                                return false;
                            }
                            dirVPKEntryData.insert(dirVPKEntryData.end(), compressedData.data(), compressedData.data() + compressedSize);
                            entry->compressedLength = compressedSize;
                        }
#endif
                    }
 
                    // Clear flags
                    entry->flags = 0;
                }
 
                outDir.write(std::filesystem::path{path}.stem().string());
                outDir.write(entry->crc32);
                outDir.write<uint16_t>(entry->extraData.size());
                outDir.write<uint16_t>(entry->archiveIndex);
                outDir.write<uint32_t>(entry->offset);
                outDir.write<uint32_t>(entry->length - entry->extraData.size());
 
                if (this->hasCompression()) {
                    outDir.write<uint32_t>(entry->compressedLength - entry->extraData.size());
                }
 
                outDir.write(VPK_ENTRY_TERM);
 
                if (!entry->extraData.empty()) {
                    outDir.write(entry->extraData);
                }
 
                if (callback) {
                    callback(path, *entry);
                }
            }
            outDir.write('\0');
        }
        outDir.write('\0');
    }
    outDir.write('\0');
 
    // Put files copied from the dir archive back
    if (!dirVPKEntryData.empty()) {
        outDir.write(dirVPKEntryData);
    }
 
    // Merge unbaked into baked entries
    this->mergeUnbakedEntries();
 
    // Calculate Header1
    this->header1.treeSize = outDir.tell_out() - dirVPKEntryData.size() - this->getHeaderLength();
 
    // Non-v1 stuff
    if (this->hasExtendedHeader()) {
        // Calculate hashes for all entries
        this->md5Entries.clear();
        if (options.vpk_generateMD5Entries) {
            this->runForAllEntries([this](const std::string& path, const Entry& entry) {
                const auto binData = this->readEntry(path);
                if (!binData) {
                    return;
                }
                const MD5Entry md5Entry{
                    .archiveIndex = entry.archiveIndex,
                    .offset = static_cast<uint32_t>(entry.offset),
                    .length = static_cast<uint32_t>(entry.length - entry.extraData.size()),
                    .checksum = crypto::computeMD5(*binData),
                };
                this->md5Entries.push_back(md5Entry);
            }, false);
        }
 
        // Calculate Header2
        this->header2.fileDataSectionSize = dirVPKEntryData.size();
        this->header2.archiveMD5SectionSize = this->md5Entries.size() * sizeof(MD5Entry);
        this->header2.otherMD5SectionSize = 48;
        this->header2.signatureSectionSize = 0;
 
        // Calculate Footer2
        hash_state wholeFileChecksumMD5;
        md5_init(&wholeFileChecksumMD5);
        {
            // Only the tree is updated in the file right now
            md5_process(&wholeFileChecksumMD5, reinterpret_cast<const unsigned char*>(&this->header1), sizeof(this->header1));
            md5_process(&wholeFileChecksumMD5, reinterpret_cast<const unsigned char*>(&this->header2), sizeof(this->header2));
        }
        {
            outDir.seek_in(sizeof(Header1) + sizeof(Header2));
            if (this->header1.treeSize > 0) {
                std::vector<std::byte> treeData = outDir.read_bytes(this->header1.treeSize);
                md5_process(&wholeFileChecksumMD5, reinterpret_cast<const unsigned char*>(treeData.data()), treeData.size());
                this->footer2.treeChecksum = crypto::computeMD5(treeData);
            } else {
                this->footer2.treeChecksum = {};
            }
        }
        if (!dirVPKEntryData.empty()) {
            md5_process(&wholeFileChecksumMD5, reinterpret_cast<const unsigned char*>(dirVPKEntryData.data()), dirVPKEntryData.size());
        }
        {
            if (!this->md5Entries.empty()) {
                md5_process(&wholeFileChecksumMD5, reinterpret_cast<const unsigned char*>(this->md5Entries.data()), this->md5Entries.size() * sizeof(MD5Entry));
                this->footer2.md5EntriesChecksum = crypto::computeMD5({reinterpret_cast<const std::byte*>(this->md5Entries.data()), this->md5Entries.size() * sizeof(MD5Entry)});
            } else {
                this->footer2.md5EntriesChecksum = {};
            }
        }
        if (!this->footer2.treeChecksum.empty()) {
            md5_process(&wholeFileChecksumMD5, reinterpret_cast<const unsigned char*>(this->footer2.treeChecksum.data()), this->footer2.treeChecksum.size());
        }
        if (!this->footer2.md5EntriesChecksum.empty()) {
            md5_process(&wholeFileChecksumMD5, reinterpret_cast<const unsigned char*>(this->footer2.md5EntriesChecksum.data()), this->footer2.md5EntriesChecksum.size());
        }
        md5_done(&wholeFileChecksumMD5, reinterpret_cast<unsigned char*>(this->footer2.wholeFileChecksum.data()));
 
        // We can't recalculate the signature without the private key
        this->footer2.publicKey.clear();
        this->footer2.signature.clear();
    }
 
    // Ancient crap VPK with no header
    if (this->header1.version == 0) {
        PackFile::setFullFilePath(outputDir);
        return true;
    }
 
    // Write new headers
    outDir.seek_out(0);
    outDir.write(this->header1);
 
    // MD5 hashes, file signature
    if (!this->hasExtendedHeader()) {
        PackFile::setFullFilePath(outputDir);
        return true;
    }
 
    outDir.write(this->header2);
 
    // Add MD5 hashes
    outDir.seek_out_u(sizeof(Header1) + sizeof(Header2) + this->header1.treeSize + dirVPKEntryData.size());
    outDir.write(this->md5Entries);
    outDir.write(this->footer2.treeChecksum);
    outDir.write(this->footer2.md5EntriesChecksum);
    outDir.write(this->footer2.wholeFileChecksum);
 
    // The signature section is not present
    PackFile::setFullFilePath(outputDir);
    return true;
}
 
std::string VPK::getTruncatedFilestem() const {
    std::string filestem = this->getFilestem();
    // This indicates it's a dir VPK, but some people ignore this convention...
    if (filestem.length() >= 4 && filestem.substr(filestem.length() - 4) == (::isFPX(this) ? FPX_DIR_SUFFIX : VPK_DIR_SUFFIX)) {
        filestem = filestem.substr(0, filestem.length() - 4);
    }
    return filestem;
}
 
Attribute VPK::getSupportedEntryAttributes() const {
    using enum Attribute;
    return LENGTH | VPK_PRELOADED_DATA | ARCHIVE_INDEX | CRC32;
}
 
VPK::operator std::string() const {
    return PackFile::operator std::string() + std::format(" | Version v{}", this->header1.version);
}
 
bool VPK::generateKeyPairFiles(const std::string& name) {
    const auto [privateKey, publicKey] = crypto::computeSHA256KeyPair(1024);
    {
        const auto privateKeyPath = name + ".privatekey.vdf";
        FileStream stream{privateKeyPath, FileStream::OPT_TRUNCATE | FileStream::OPT_CREATE_IF_NONEXISTENT};
 
        std::string output;
        // Template size, remove %s and %s, add key sizes, add null terminator size
        output.resize(VPK_KEYPAIR_PRIVATE_KEY_TEMPLATE.size() - 4 + privateKey.size() + publicKey.size() + 1);
        if (std::sprintf(output.data(), VPK_KEYPAIR_PRIVATE_KEY_TEMPLATE.data(), privateKey.data(), publicKey.data()) < 0) {
            return false;
        }
        output.pop_back();
        stream.write(output, false);
    }
    {
        const auto publicKeyPath = name + ".publickey.vdf";
        FileStream stream{publicKeyPath, FileStream::OPT_TRUNCATE | FileStream::OPT_CREATE_IF_NONEXISTENT};
 
        std::string output;
        // Template size, remove %s, add key size, add null terminator size
        output.resize(VPK_KEYPAIR_PUBLIC_KEY_TEMPLATE.size() - 2 + publicKey.size() + 1);
        if (std::sprintf(output.data(), VPK_KEYPAIR_PUBLIC_KEY_TEMPLATE.data(), publicKey.data()) < 0) {
            return false;
        }
        output.pop_back();
        stream.write(output, false);
    }
    return true;
}
 
bool VPK::sign(const std::string& filename_) {
    if (!this->hasExtendedHeader() || !std::filesystem::exists(filename_) || std::filesystem::is_directory(filename_)) {
        return false;
    }
 
    const KV1 fileKV{fs::readFileText(filename_)};
 
    const auto privateKeyHex = fileKV["private_key"]["rsa_private_key"].getValue();
    if (privateKeyHex.empty()) {
        return false;
    }
    const auto publicKeyHex = fileKV["private_key"]["public_key"]["rsa_public_key"].getValue();
    if (publicKeyHex.empty()) {
        return false;
    }
 
    return this->sign(string::decodeHex(privateKeyHex), string::decodeHex(publicKeyHex));
}
 
bool VPK::sign(const std::vector<std::byte>& privateKey, const std::vector<std::byte>& publicKey) {
    if (!this->hasExtendedHeader()) {
        return false;
    }
 
    this->header2.signatureSectionSize = this->footer2.publicKey.size() + this->footer2.signature.size() + sizeof(uint32_t) * 2;
    {
        FileStream stream{std::string{this->getFilepath()}, FileStream::OPT_READ | FileStream::OPT_WRITE};
        stream.seek_out(sizeof(Header1));
        stream.write(this->header2);
    }
 
    auto dirFileBuffer = fs::readFileBuffer(std::string{this->getFilepath()});
    if (dirFileBuffer.size() <= this->header2.signatureSectionSize) {
        return false;
    }
    for (int i = 0; i < this->header2.signatureSectionSize; i++) {
        dirFileBuffer.pop_back();
    }
    this->footer2.publicKey = publicKey;
    this->footer2.signature = crypto::signDataWithSHA256PrivateKey(dirFileBuffer, privateKey);
 
    {
        FileStream stream{std::string{this->getFilepath()}, FileStream::OPT_READ | FileStream::OPT_WRITE};
        stream.seek_out(this->getHeaderLength() + this->header1.treeSize + this->header2.fileDataSectionSize + this->header2.archiveMD5SectionSize + this->header2.otherMD5SectionSize);
        stream.write(static_cast<uint32_t>(this->footer2.publicKey.size()));
        stream.write(this->footer2.publicKey);
        stream.write(static_cast<uint32_t>(this->footer2.signature.size()));
        stream.write(this->footer2.signature);
    }
    return true;
}
 
uint32_t VPK::getVersion() const {
    return this->header1.version;
}
 
void VPK::setVersion(uint32_t version) {
    // Version must be supported, we cannot be an FPX, and version must be different
    if ((version != 0 && version != 1 && version != 2 && version != 54) || ::isFPX(this) || version == this->header1.version) {
        return;
    }
    this->header1.version = version;
 
    // Clearing these isn't necessary, but might as well
    this->header2 = {};
    this->footer2 = {};
    this->md5Entries.clear();
}
 
uint32_t VPK::getChunkSize() const {
    return this->chunkSize;
}
 
void VPK::setChunkSize(uint32_t newChunkSize) {
    this->chunkSize = newChunkSize;
}
 
bool VPK::hasExtendedHeader() const {
    return this->header1.version == 2 || this->header1.version == 54;
}
 
bool VPK::hasCompression() const {
    return this->header1.version == 54;
}
 
uint32_t VPK::getHeaderLength() const {
    if (!this->hasExtendedHeader()) {
        return sizeof(Header1);
    }
    return sizeof(Header1) + sizeof(Header2);
}