Skip to content

Commit

Permalink
lambda-select
Browse files Browse the repository at this point in the history
  • Loading branch information
inclyc committed Jul 23, 2024
1 parent 487f83a commit 220f86d
Show file tree
Hide file tree
Showing 4 changed files with 163 additions and 63 deletions.
13 changes: 13 additions & 0 deletions nixd/lib/Controller/AST.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -247,6 +247,19 @@ nixd::Selector nixd::mkSelector(const nixf::ExprSelect &Select,
return BaseSelector;
}

nixd::Selector nixd::mkSelector(const nixf::ExprSelect &Sel,
const nixf::VariableLookupAnalysis &VLA,
const nixf::ParentMapAnalysis &PM) {
if (Sel.expr().kind() != Node::NK_ExprVar)
throw NotVariableSelect();

const auto &Var = static_cast<ExprVar &>(Sel.expr());

auto BaseSelector = mkIdiomSelector(Var, VLA, PM);

return mkSelector(Sel, std::move(BaseSelector));
}

std::pair<std::vector<std::string>, std::string>
nixd::getScopeAndPrefix(const Node &N, const ParentMapAnalysis &PM) {
if (N.kind() != Node::NK_Identifer)
Expand Down
18 changes: 15 additions & 3 deletions nixd/lib/Controller/AST.h
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

#include "nixd/Protocol/AttrSet.h"

#include <nixf/Basic/Nodes/Expr.h>
#include <nixf/Sema/ParentMap.h>
#include <nixf/Sema/VariableLookup.h>

Expand Down Expand Up @@ -49,6 +50,8 @@ upEnv(const nixf::Node &Desc, const nixf::VariableLookupAnalysis &VLA,
std::pair<std::vector<std::string>, std::string>
getScopeAndPrefix(const nixf::Node &N, const nixf::ParentMapAnalysis &PM);

struct IdiomException : std::exception {};

/// \brief Exceptions scoped in nixd::mkIdiomSelector
struct IdiomSelectorException : std::exception {};

Expand All @@ -74,22 +77,31 @@ Selector mkIdiomSelector(const nixf::ExprVar &Var,
const nixf::VariableLookupAnalysis &VLA,
const nixf::ParentMapAnalysis &PM);

struct SelectorException : std::exception {};

/// \brief The attrpath has a dynamic name, thus it cannot be trivially
/// transformed to "static" selector.
struct DynamicNameException : SelectorException {
struct DynamicNameException : IdiomSelectorException {
[[nodiscard]] const char *what() const noexcept override {
return "dynamic attribute path encountered";
}
};

struct NotVariableSelect : IdiomSelectorException {
[[nodiscard]] const char *what() const noexcept override {
return "the base expression of the select is not a variable";
}
};

/// \brief Construct a nixd::Selector from \p AP.
Selector mkSelector(const nixf::AttrPath &AP, Selector BaseSelector);

/// \brief Construct a nixd::Selector from \p Select.
Selector mkSelector(const nixf::ExprSelect &Select, Selector BaseSelector);

/// \brief Construct a nixd::Selector from \p Select.
Selector mkSelector(const nixf::ExprSelect &Select,
const nixf::VariableLookupAnalysis &VLA,
const nixf::ParentMapAnalysis &PM);

enum class FindAttrPathResult {
OK,
Inherit,
Expand Down
8 changes: 1 addition & 7 deletions nixd/lib/Controller/Completion.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -351,17 +351,11 @@ void completeSelect(const nixf::ExprSelect &Select, AttrSetClient &Client,
// Ask nixpkgs provider to get idioms completion.
NixpkgsCompletionProvider NCP(Client);

const auto Handler = [](std::exception &E) noexcept {
log(DBG "skipped, reason: {0}", E.what());
};
try {
Selector Sel = mkSelector(Select, mkIdiomSelector(Var, VLA, PM));
NCP.completePackages(mkParams(Sel, IsComplete), List);
} catch (IdiomSelectorException &E) {
Handler(E);
return;
} catch (SelectorException &E) {
Handler(E);
log(DBG "skipped, reason: {0}", E.what());
return;
}

Expand Down
187 changes: 134 additions & 53 deletions nixd/lib/Controller/Definition.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,15 @@
#include <boost/asio/post.hpp>

#include <llvm/Support/Error.h>
#include <llvm/Support/JSON.h>

#include <nixf/Basic/Nodes/Attrs.h>
#include <nixf/Basic/Nodes/Basic.h>
#include <nixf/Basic/Nodes/Expr.h>
#include <nixf/Sema/ParentMap.h>
#include <nixf/Sema/VariableLookup.h>

#include <exception>
#include <semaphore>

using namespace nixd;
Expand Down Expand Up @@ -107,6 +111,24 @@ Expected<Location> staticDef(URIForFile URI, const Node &N,
};
}

struct NoLocationsFoundInNixpkgsException : std::exception {
[[nodiscard]] const char *what() const noexcept override {
return "no locations found in nixpkgs";
}
};

class WorkerReportedException : std::exception {
llvm::Error E;

public:
WorkerReportedException(llvm::Error E) : E(std::move(E)){};

llvm::Error takeError() { return std::move(E); }
[[nodiscard]] const char *what() const noexcept override {
return "worker reported some error";
}
};

/// \brief Resolve definition by invoking nixpkgs provider.
///
/// Useful for users inspecting nixpkgs packages. For example, someone clicks
Expand Down Expand Up @@ -138,8 +160,7 @@ class NixpkgsDefinitionProvider {
NixpkgsDefinitionProvider(AttrSetClient &NixpkgsClient)
: NixpkgsClient(NixpkgsClient) {}

Expected<lspserver::Location> resolvePackage(std::vector<std::string> Scope,
std::string Name) {
Locations resolveSelector(const nixd::Selector &Sel) {
std::binary_semaphore Ready(0);
Expected<AttrPathInfoResponse> Desc = error("not replied");
auto OnReply = [&Ready, &Desc](llvm::Expected<AttrPathInfoResponse> Resp) {
Expand All @@ -149,22 +170,21 @@ class NixpkgsDefinitionProvider {
Desc = Resp.takeError();
Ready.release();
};
Scope.emplace_back(std::move(Name));
NixpkgsClient.attrpathInfo(Scope, std::move(OnReply));
NixpkgsClient.attrpathInfo(Sel, std::move(OnReply));
Ready.acquire();

if (!Desc)
return Desc.takeError();
throw WorkerReportedException(Desc.takeError());

const std::optional<std::string> &Position = Desc->PackageDesc.Position;
if (!Position)
return error("meta.position is not available for this package");
// Prioritize package location if it exists.
if (const std::optional<std::string> &Position = Desc->PackageDesc.Position)
return Locations{parseLocation(*Position)};

try {
return parseLocation(*Position);
} catch (std::exception &E) {
return error(E.what());
}
// Use the location in "ValueMeta".
if (const auto &Loc = Desc->Meta.Location)
return Locations{*Loc};

throw NoLocationsFoundInNixpkgsException();
}
};

Expand Down Expand Up @@ -198,6 +218,79 @@ class OptionsDefinitionProvider {
}
};

/// \brief Get the locations of some attribute path.
///
/// Usually this function will return a list of option declarations via RPC
Locations defineAttrPath(const Node &N, const ParentMapAnalysis &PM,
std::mutex &OptionsLock,
Controller::OptionMapTy &Options) {
using PathResult = FindAttrPathResult;
std::vector<std::string> Scope;
auto R = findAttrPath(N, PM, Scope);
Locations Locs;
if (R == PathResult::OK) {
std::lock_guard _(OptionsLock);
// For each option worker, try to get it's decl position.
for (const auto &[_, Client] : Options) {
if (AttrSetClient *C = Client->client()) {
OptionsDefinitionProvider ODP(*C);
ODP.resolveLocations(Scope, Locs);
}
}
}
return Locs;
}

/// \brief Get nixpkgs definition from a selector.
Locations defineNixpkgsSelector(const Selector &Sel,
AttrSetClient &NixpkgsClient) {
try {
// Ask nixpkgs provider information about this selector.
NixpkgsDefinitionProvider NDP(NixpkgsClient);
return NDP.resolveSelector(Sel);
} catch (NoLocationsFoundInNixpkgsException &E) {
elog("definition/idiom: {0}", E.what());
} catch (WorkerReportedException &E) {
elog("definition/idiom/worker: {0}", E.takeError());
}
return {};
}

/// \brief Get definiton of select expressions.
Locations defineSelect(const ExprSelect &Sel, const VariableLookupAnalysis &VLA,
const ParentMapAnalysis &PM,
AttrSetClient &NixpkgsClient) {
// Currently we can only deal with idioms.
// Maybe more data-flow analysis will be added though.
try {
return defineNixpkgsSelector(mkSelector(Sel, VLA, PM), NixpkgsClient);
} catch (IdiomSelectorException &E) {
elog("defintion/idiom/selector: {0}", E.what());
}
return {};
}

/// \brief Squash a vector into smaller json variant.
template <class T> llvm::json::Value squash(std::vector<T> List) {
std::size_t Size = List.size();
switch (Size) {
case 0:
return nullptr;
case 1:
return std::move(List.back());
default:
break;
}
return std::move(List);
}

template <class T>
llvm::Expected<llvm::json::Value> squash(llvm::Expected<std::vector<T>> List) {
if (!List)
return List.takeError();
return squash(std::move(*List));
}

} // namespace

Expected<const Definition &>
Expand Down Expand Up @@ -232,54 +325,42 @@ void Controller::onDefinition(const TextDocumentPositionParams &Params,
if (std::shared_ptr<Node> AST = getAST(*TU, Reply)) [[likely]] {
const VariableLookupAnalysis &VLA = *TU->variableLookup();
const ParentMapAnalysis &PM = *TU->parentMap();
const Node *N = AST->descend({Pos, Pos});
Locations Locs;
if (!N) [[unlikely]] {
const Node *MaybeN = AST->descend({Pos, Pos});
if (!MaybeN) [[unlikely]] {
Reply(error("cannot find AST node on given position"));
return;
}
using PathResult = FindAttrPathResult;
std::vector<std::string> Scope;
auto R = findAttrPath(*N, PM, Scope);
if (R == PathResult::OK) {
std::lock_guard _(OptionsLock);
// For each option worker, try to get it's decl position.
for (const auto &[_, Client] : Options) {
if (AttrSetClient *C = Client->client()) {
OptionsDefinitionProvider ODP(*C);
ODP.resolveLocations(Scope, Locs);
}
}
}
if (havePackageScope(*N, VLA, PM) && nixpkgsClient()) {
// Ask nixpkgs client what's current package documentation.
NixpkgsDefinitionProvider NDP(*nixpkgsClient());
auto [Scope, Name] = getScopeAndPrefix(*N, PM);
if (Expected<Location> Loc =
NDP.resolvePackage(std::move(Scope), std::move(Name)))
Locs.emplace_back(*Loc);
else
elog("cannot get nixpkgs definition for package: {0}",
Loc.takeError());
}

if (Expected<Location> StaticLoc = staticDef(URI, *N, PM, VLA))
Locs.emplace_back(*StaticLoc);
else
elog("cannot get static def location: {0}", StaticLoc.takeError());

if (Locs.empty()) {
const Node &N = *MaybeN;
const Node *MaybeUpExpr = PM.upExpr(N);
if (!MaybeUpExpr) {
Reply(nullptr);
return;
}

if (Locs.size() == 1) {
Reply(Locs.back());
return;
}
const Node &UpExpr = *MaybeUpExpr;

return Reply(squash([&]() -> llvm::Expected<Locations> {
switch (UpExpr.kind()) {
case Node::NK_ExprSelect: {
const auto &Sel = static_cast<const ExprSelect &>(UpExpr);
return defineSelect(Sel, VLA, PM, *nixpkgsClient());
}
case Node::NK_ExprAttrs:
return defineAttrPath(N, PM, OptionsLock, Options);
default:
break;
}

Reply(std::move(Locs));
return;
// Get static locations.
// Likely this will fail, thus just logging errors.
return [&]() -> Locations {
Expected<Location> StaticLoc = staticDef(URI, *MaybeN, PM, VLA);
if (StaticLoc)
return {*StaticLoc};
elog("definition/static: {0}", StaticLoc.takeError());
return {};
}();
}()));
}
}
};
Expand Down

0 comments on commit 220f86d

Please sign in to comment.