nix-super/src/libstore/ssh-store.cc

93 lines
2.8 KiB
C++
Raw Normal View History

2016-09-12 15:03:29 +03:00
#include "store-api.hh"
#include "remote-store.hh"
2016-09-02 21:31:38 +03:00
#include "remote-fs-accessor.hh"
#include "archive.hh"
#include "worker-protocol.hh"
#include "pool.hh"
#include "ssh.hh"
2016-09-02 21:31:38 +03:00
namespace nix {
struct SSHStoreConfig : virtual RemoteStoreConfig
2016-09-12 15:03:29 +03:00
{
using RemoteStoreConfig::RemoteStoreConfig;
const Setting<Path> sshKey{(StoreConfig*) this, "", "ssh-key", "path to an SSH private key"};
const Setting<std::string> sshPublicHostKey{(StoreConfig*) this, "", "base64-ssh-public-host-key", "The public half of the host's SSH key"};
const Setting<bool> compress{(StoreConfig*) this, false, "compress", "whether to compress the connection"};
const Setting<Path> remoteProgram{(StoreConfig*) this, "nix-daemon", "remote-program", "path to the nix-daemon executable on the remote system"};
const Setting<std::string> remoteStore{(StoreConfig*) this, "", "remote-store", "URI of the store on the remote system"};
const std::string name() override { return "SSH Store"; }
};
2017-02-07 20:20:15 +02:00
class SSHStore : public virtual SSHStoreConfig, public virtual RemoteStore
2016-09-12 15:03:29 +03:00
{
public:
2020-09-14 15:12:47 +03:00
SSHStore(const std::string & scheme, const std::string & host, const Params & params)
: StoreConfig(params)
, RemoteStoreConfig(params)
, SSHStoreConfig(params)
, Store(params)
, RemoteStore(params)
, host(host)
, master(
host,
sshKey,
sshPublicHostKey,
// Use SSH master only if using more than 1 connection.
connections->capacity() > 1,
compress)
{
}
2016-09-12 15:03:29 +03:00
static std::set<std::string> uriSchemes() { return {"ssh-ng"}; }
std::string getUri() override
{
return *uriSchemes().begin() + "://" + host;
}
2016-09-12 15:03:29 +03:00
2019-11-26 22:07:44 +02:00
bool sameMachine() override
{ return false; }
2016-09-12 15:03:29 +03:00
private:
struct Connection : RemoteStore::Connection
{
std::unique_ptr<SSHMaster::Connection> sshConn;
2016-09-12 15:03:29 +03:00
};
ref<RemoteStore::Connection> openConnection() override;
std::string host;
SSHMaster master;
void setOptions(RemoteStore::Connection & conn) override
{
/* TODO Add a way to explicitly ask for some options to be
forwarded. One option: A way to query the daemon for its
settings, and then a series of params to SSHStore like
forward-cores or forward-overridden-cores that only
override the requested settings.
*/
};
2016-09-12 15:03:29 +03:00
};
2016-09-02 21:31:38 +03:00
ref<RemoteStore::Connection> SSHStore::openConnection()
{
auto conn = make_ref<Connection>();
conn->sshConn = master.startCommand(
fmt("%s --stdio", remoteProgram)
+ (remoteStore.get() == "" ? "" : " --store " + shellEscape(remoteStore.get())));
conn->to = FdSink(conn->sshConn->in.get());
conn->from = FdSource(conn->sshConn->out.get());
2016-09-02 21:31:38 +03:00
return conn;
}
static RegisterStoreImplementation<SSHStore, SSHStoreConfig> regSSHStore;
2016-09-02 21:31:38 +03:00
}