Function MakeStackMachinePath

eval/eval/create_struct_step_test.cc:73–143

using ::testing::Pointwise;

absl::StatusOr<ExecutionPath> MakeStackMachinePath(absl::string_view field) {
  ExecutionPath path;

  CEL_ASSIGN_OR_RETURN(auto step0, CreateIdentStep("message", /*expr_id=*/-1));

  auto step1 = CreateCreateStructStep("google.api.expr.runtime.TestMessage",
                                      {std::string(field)},
                                      /*optional_indices=*/{},

                                      /*id=*/-1);

  path.push_back(std::move(step0));
  path.push_back(std::move(step1));

  return path;
}

absl::StatusOr<ExecutionPath> MakeRecursivePath(absl::string_view field) {
  ExecutionPath path;

  std::vector<std::unique_ptr<DirectExpressionStep>> deps;
  deps.push_back(CreateDirectIdentStep("message", -1));

  auto step1 =
      CreateDirectCreateStructStep("google.api.expr.runtime.TestMessage",
                                   {std::string(field)}, std::move(deps),
                                   /*optional_indices=*/{},

                                   /*id=*/-1);

  path.push_back(std::make_unique<WrappedDirectStep>(std::move(step1), -1));

  return path;
}

// Helper method. Creates simple pipeline containing CreateStruct step that
// builds message and runs it.
absl::StatusOr<CelValue> RunExpression(
    const absl_nonnull std::shared_ptr<const RuntimeEnv>& env,
    absl::string_view field, const CelValue& value, google::protobuf::Arena* arena,
    bool enable_unknowns, bool enable_recursive_planning) {
  google::protobuf::LinkMessageReflection<google::api::expr::runtime::TestMessage>();
  CEL_ASSIGN_OR_RETURN(auto maybe_type,
                       env->type_registry.GetComposedTypeProvider().FindType(
                           "google.api.expr.runtime.TestMessage"));
  if (!maybe_type.has_value()) {
    return absl::Status(absl::StatusCode::kFailedPrecondition,
                        "missing proto message type");
  }

  cel::RuntimeOptions options;
  if (enable_unknowns) {
    options.unknown_processing = cel::UnknownProcessingOptions::kAttributeOnly;
  }
  ExecutionPath path;

  if (enable_recursive_planning) {
    CEL_ASSIGN_OR_RETURN(path, MakeRecursivePath(field));