feat(3p/nix/nix-daemon): Implement Worker::QueryMissing handler
Change-Id: I004a0c7969e1fe27b844adfed2d3ba3e6c5279bb Reviewed-on: https://cl.tvl.fyi/c/depot/+/1227 Tested-by: BuildkiteCI Reviewed-by: tazjin <mail@tazj.in>
This commit is contained in:
parent
5c9af8faee
commit
ec859afe95
1 changed files with 30 additions and 0 deletions
|
@ -76,6 +76,36 @@ class WorkerServiceImpl final : public Worker::Service {
|
|||
return Status::OK;
|
||||
}
|
||||
|
||||
Status QueryMissing(grpc::ServerContext* context, const StorePaths* request,
|
||||
nix::proto::QueryMissingResponse* response) override {
|
||||
std::set<Path> targets;
|
||||
for (auto& path : request->paths()) {
|
||||
targets.insert(path);
|
||||
}
|
||||
PathSet will_build;
|
||||
PathSet will_substitute;
|
||||
PathSet unknown;
|
||||
// TODO(grfn): Switch to concrete size type
|
||||
unsigned long long download_size;
|
||||
unsigned long long nar_size;
|
||||
|
||||
store_->queryMissing(targets, will_build, will_substitute, unknown,
|
||||
download_size, nar_size);
|
||||
for (auto& path : will_build) {
|
||||
response->add_will_build(path);
|
||||
}
|
||||
for (auto& path : will_substitute) {
|
||||
response->add_will_substitute(path);
|
||||
}
|
||||
for (auto& path : unknown) {
|
||||
response->add_unknown(path);
|
||||
}
|
||||
response->set_download_size(download_size);
|
||||
response->set_nar_size(nar_size);
|
||||
|
||||
return Status::OK;
|
||||
};
|
||||
|
||||
private:
|
||||
// TODO(tazjin): Who owns the store?
|
||||
nix::Store* store_;
|
||||
|
|
Loading…
Reference in a new issue