126d99d366Add an adapter-selected AF_UNIX stream transport while preserving the pathname compatibility default and owner/mode identity checks.
73 lines
3 KiB
C++
73 lines
3 KiB
C++
#include "adapters/sage/guest_channel.hpp"
|
|
|
|
#include <cstdio>
|
|
#include <optional>
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
namespace {
|
|
|
|
#define REQUIRE(cond) \
|
|
do { \
|
|
if (!(cond)) { \
|
|
std::fprintf(stderr, "REQUIRE failed: %s @ %s:%d\n", #cond, __FILE__, __LINE__); \
|
|
return 1; \
|
|
} \
|
|
} while (0)
|
|
|
|
} // namespace
|
|
|
|
int main() {
|
|
auto built = glove::adapters::sage::guest_channel_host();
|
|
REQUIRE(built.has_value());
|
|
REQUIRE(*built != nullptr);
|
|
REQUIRE((*built)->frozen());
|
|
REQUIRE(!(*built)->empty());
|
|
REQUIRE((*built)->size() == 1U);
|
|
|
|
const auto* observation = (*built)->admits("sage.glove-observation.v1");
|
|
REQUIRE(observation != nullptr);
|
|
const glove::control::glove_observation_body observation_body{
|
|
.schema = "sage.glove-observation.v1",
|
|
.intent_id = "test-observation",
|
|
.observation = "capability-inventory",
|
|
.value_digest = std::string(64, 'a'),
|
|
.item_count = 4,
|
|
};
|
|
REQUIRE(observation->body_validator(observation_body));
|
|
|
|
auto binding = glove::adapters::sage::resolve_guest_channel_adapter(
|
|
"sage-observation", "sage.glove-observation.v1"
|
|
);
|
|
REQUIRE(binding.has_value());
|
|
REQUIRE((*binding)->adapter_id == "sage-observation");
|
|
REQUIRE((*binding)->channel_schema_id == "sage.glove-observation.v1");
|
|
REQUIRE((*binding)->runtime_ids == std::vector<std::string>{"pi"});
|
|
REQUIRE((*binding)->transport_id.empty());
|
|
REQUIRE(!(*binding)->service_alias.has_value());
|
|
REQUIRE(!(*binding)->service_alias_environment.has_value());
|
|
REQUIRE((*binding)->channels->admits("sage.glove-observation.v1") != nullptr);
|
|
auto inherited = glove::adapters::sage::resolve_guest_channel_adapter(
|
|
"sage-observation", "sage.glove-observation.v1", "inherited-stream-v1"
|
|
);
|
|
REQUIRE(inherited.has_value());
|
|
REQUIRE((*inherited)->transport_id == "inherited-stream-v1");
|
|
REQUIRE((*inherited)->service_alias == std::optional<std::string>{"sage-observe"});
|
|
REQUIRE(
|
|
(*inherited)->service_alias_environment ==
|
|
std::optional<std::string>{"GLOVE_GUEST_CHANNEL_SERVICE_ALIAS=sage-observe"}
|
|
);
|
|
REQUIRE(!glove::adapters::sage::resolve_guest_channel_adapter(
|
|
"sage-observation", "sage.glove-observation.v1", "unknown-v1"
|
|
)
|
|
.has_value());
|
|
REQUIRE(!glove::adapters::sage::resolve_guest_channel_adapter(
|
|
"unsupported", "sage.glove-observation.v1"
|
|
)
|
|
.has_value());
|
|
REQUIRE(
|
|
!glove::adapters::sage::resolve_guest_channel_adapter("sage-observation", "arbitrary.v1")
|
|
.has_value()
|
|
);
|
|
return 0;
|
|
}
|