hydra-queue-runner: Support generating a signed binary cache

src/hydra-queue-runner/hydra-queue-runner.cc

@@ -33,7 +33,10 @@ ref<Store> State::getLocalStore()
 
 ref<Store> State::getDestStore()
 {
-    return make_ref<LocalBinaryCache>(getLocalStore(), "/tmp/binary-cache");
+    return make_ref<LocalBinaryCache>(getLocalStore(),
+        "/tmp/binary-cache",
+        "/home/eelco/Misc/Keys/test.nixos.org/secret",
+        "/home/eelco/Misc/Keys/test.nixos.org/public");
 }
 
 

src/hydra-queue-runner/local-binary-cache.cc

@@ -4,14 +4,30 @@
 #include "compression.hh"
 #include "derivations.hh"
 #include "globals.hh"
+#include "nar-info.hh"
 #include "worker-protocol.hh"
 
 namespace nix {
 
-LocalBinaryCache::LocalBinaryCache(ref<Store> localStore, const Path & binaryCacheDir)
+LocalBinaryCache::LocalBinaryCache(ref<Store> localStore, const Path & binaryCacheDir,
-    : localStore(localStore), binaryCacheDir(binaryCacheDir)
+    const Path & secretKeyFile, const Path & publicKeyFile)
+    : localStore(localStore)
+    , binaryCacheDir(binaryCacheDir)
 {
     createDirs(binaryCacheDir + "/nar");
+
+    Path cacheInfoFile = binaryCacheDir + "/nix-cache-info";
+    if (!pathExists(cacheInfoFile))
+        writeFile(cacheInfoFile, "StoreDir: " + settings.nixStore + "\n");
+
+    if (secretKeyFile != "")
+        secretKey = std::unique_ptr<SecretKey>(new SecretKey(readFile(secretKeyFile)));
+
+    if (publicKeyFile != "") {
+        publicKeys = std::unique_ptr<PublicKeys>(new PublicKeys);
+        auto key = PublicKey(readFile(publicKeyFile));
+        publicKeys->emplace(key.name, key);
+    }
 }
 
 Path LocalBinaryCache::narInfoFileFor(const Path & storePath)
@@ -36,103 +52,51 @@ void LocalBinaryCache::addToCache(const ValidPathInfo & info,
     Path narInfoFile = narInfoFileFor(info.path);
     if (pathExists(narInfoFile)) return;
 
-    size_t narSize = nar.size();
+    NarInfo narInfo(info);
-    Hash narHash = hashString(htSHA256, nar);
 
-    if (info.hash.type != htUnknown && info.hash != narHash)
+    narInfo.narSize = nar.size();
+    narInfo.narHash = hashString(htSHA256, nar);
+
+    if (info.narHash.type != htUnknown && info.narHash != narInfo.narHash)
         throw Error(format("refusing to copy corrupted path ‘%1%’ to binary cache") % info.path);
 
     printMsg(lvlTalkative, format("copying path ‘%1%’ (%2% bytes) to binary cache")
-        % info.path % narSize);
+        % info.path % info.narSize);
 
     /* Compress the NAR. */
+    narInfo.compression = "xz";
     string narXz = compressXZ(nar);
-    Hash narXzHash = hashString(htSHA256, narXz);
+    narInfo.fileHash = hashString(htSHA256, narXz);
+    narInfo.fileSize = narXz.size();
 
     /* Atomically write the NAR file. */
-    string narFileRel = "nar/" + printHash32(narXzHash) + ".nar.xz";
+    narInfo.url = "nar/" + printHash32(narInfo.fileHash) + ".nar.xz";
-    Path narFile = binaryCacheDir + "/" + narFileRel;
+    Path narFile = binaryCacheDir + "/" + narInfo.url;
     if (!pathExists(narFile)) atomicWrite(narFile, narXz);
 
     /* Atomically write the NAR info file.*/
-    Strings refs;
+    if (secretKey) narInfo.sign(*secretKey);
-    for (auto & r : info.references)
-        refs.push_back(baseNameOf(r));
 
-    std::string narInfo;
+    atomicWrite(narInfoFile, narInfo.to_string());
-    narInfo += "StorePath: " + info.path + "\n";
-    narInfo += "URL: " + narFileRel + "\n";
-    narInfo += "Compression: xz\n";
-    narInfo += "FileHash: sha256:" + printHash32(narXzHash) + "\n";
-    narInfo += "FileSize: " + std::to_string(narXz.size()) + "\n";
-    narInfo += "NarHash: sha256:" + printHash32(narHash) + "\n";
-    narInfo += "NarSize: " + std::to_string(narSize) + "\n";
-    narInfo += "References: " + concatStringsSep(" ", refs) + "\n";
-
-    // FIXME: add signature
-
-    atomicWrite(narInfoFile, narInfo);
 }
 
-LocalBinaryCache::NarInfo LocalBinaryCache::readNarInfo(const Path & storePath)
+NarInfo LocalBinaryCache::readNarInfo(const Path & storePath)
 {
-    NarInfo res;
-
     Path narInfoFile = narInfoFileFor(storePath);
-    if (!pathExists(narInfoFile))
+    NarInfo narInfo = NarInfo(readFile(narInfoFile), narInfoFile);
-        abort();
+    assert(narInfo.path == storePath);
-    std::string narInfo = readFile(narInfoFile);
 
-    auto corrupt = [&]() {
+    if (publicKeys) {
-        throw Error(format("corrupt NAR info file ‘%1%’") % narInfoFile);
+        if (!narInfo.checkSignature(*publicKeys))
-    };
+            throw Error(format("invalid signature on NAR info file ‘%1%’") % narInfoFile);
-
-    size_t pos = 0;
-    while (pos < narInfo.size()) {
-
-        size_t colon = narInfo.find(':', pos);
-        if (colon == std::string::npos) corrupt();
-
-        std::string name(narInfo, pos, colon - pos);
-
-        size_t eol = narInfo.find('\n', colon + 2);
-        if (eol == std::string::npos) corrupt();
-
-        std::string value(narInfo, colon + 2, eol - colon - 2);
-
-        if (name == "StorePath") {
-            res.info.path = value;
-            if (value != storePath) corrupt();
-            res.info.path = value;
-        }
-        else if (name == "References") {
-            auto refs = tokenizeString<Strings>(value, " ");
-            if (!res.info.references.empty()) corrupt();
-            for (auto & r : refs)
-                res.info.references.insert(settings.nixStore + "/" + r);
-        }
-        else if (name == "URL") {
-            res.narUrl = value;
-        }
-        else if (name == "Compression") {
-            res.compression = value;
     }
 
-        pos = eol + 1;
+    return narInfo;
-    }
-
-    if (res.info.path.empty() || res.narUrl.empty()) corrupt();
-
-    return res;
 }
 
 bool LocalBinaryCache::isValidPath(const Path & storePath)
 {
-    Path narInfoFile = narInfoFileFor(storePath);
+    return pathExists(narInfoFileFor(storePath));
-
-    printMsg(lvlDebug, format("checking %1% -> %2%") % storePath % narInfoFile);
-
-    return pathExists(narInfoFile);
 }
 
 void LocalBinaryCache::exportPath(const Path & storePath, bool sign, Sink & sink)
@@ -141,7 +105,7 @@ void LocalBinaryCache::exportPath(const Path & storePath, bool sign, Sink & sink
 
     auto res = readNarInfo(storePath);
 
-    auto nar = readFile(binaryCacheDir + "/" + res.narUrl);
+    auto nar = readFile(binaryCacheDir + "/" + res.url);
 
     /* Decompress the NAR. FIXME: would be nice to have the remote
        side do this. */
@@ -160,7 +124,7 @@ void LocalBinaryCache::exportPath(const Path & storePath, bool sign, Sink & sink
 
     // FIXME: check integrity of NAR.
 
-    sink << exportMagic << storePath << res.info.references << res.info.deriver << 0;
+    sink << exportMagic << storePath << res.references << res.deriver << 0;
 }
 
 Paths LocalBinaryCache::importPaths(bool requireSignature, Source & source)
@@ -225,7 +189,7 @@ Path LocalBinaryCache::importPath(Source & source)
 
 ValidPathInfo LocalBinaryCache::queryPathInfo(const Path & storePath)
 {
-    return readNarInfo(storePath).info;
+    return ValidPathInfo(readNarInfo(storePath));
 }
 
 void LocalBinaryCache::querySubstitutablePathInfos(const PathSet & paths,

src/hydra-queue-runner/local-binary-cache.hh

@@ -1,18 +1,25 @@
 #pragma once
 
+#include "crypto.hh"
 #include "store-api.hh"
 
 namespace nix {
 
+struct NarInfo;
+
 class LocalBinaryCache : public nix::Store
 {
 private:
     ref<Store> localStore;
     Path binaryCacheDir;
 
+    std::unique_ptr<SecretKey> secretKey;
+    std::unique_ptr<PublicKeys> publicKeys;
+
 public:
 
-    LocalBinaryCache(ref<Store> localStore, const Path & binaryCacheDir);
+    LocalBinaryCache(ref<Store> localStore, const Path & binaryCacheDir,
+        const Path & secretKeyFile, const Path & publicKeyFile);
 
 private:
 
@@ -20,13 +27,6 @@ private:
 
     void addToCache(const ValidPathInfo & info, const string & nar);
 
-    struct NarInfo
-    {
-        ValidPathInfo info;
-        std::string narUrl;
-        std::string compression = "none";
-    };
-
     NarInfo readNarInfo(const Path & storePath);
 
 public: