blob: f19d15c6955239b838b7cf41560842f8f8e59494 [file] [log] [blame]
// Copyright 2019 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "quiche/common/structured_headers.h"
#include <cmath>
#include <string>
#include <utility>
#include "absl/algorithm/container.h"
#include "absl/container/flat_hash_set.h"
#include "absl/strings/ascii.h"
#include "absl/strings/escaping.h"
#include "absl/strings/numbers.h"
#include "absl/strings/str_format.h"
#include "absl/strings/string_view.h"
#include "absl/types/span.h"
#include "quiche/common/platform/api/quiche_logging.h"
namespace quiche {
namespace structured_headers {
namespace {
#define DIGIT "0123456789"
#define LCALPHA "abcdefghijklmnopqrstuvwxyz"
#define UCALPHA "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
#define TCHAR DIGIT LCALPHA UCALPHA "!#$%&'*+-.^_`|~"
// https://tools.ietf.org/html/draft-ietf-httpbis-header-structure-09#section-3.9
constexpr char kTokenChars09[] = DIGIT UCALPHA LCALPHA "_-.:%*/";
// https://www.rfc-editor.org/rfc/rfc8941.html#section-3.3.4
constexpr char kTokenChars[] = TCHAR ":/";
// https://tools.ietf.org/html/draft-ietf-httpbis-header-structure-09#section-3.1
constexpr char kKeyChars09[] = DIGIT LCALPHA "_-";
// https://www.rfc-editor.org/rfc/rfc8941.html#section-3.1.2
constexpr char kKeyChars[] = DIGIT LCALPHA "_-.*";
constexpr char kSP[] = " ";
constexpr char kOWS[] = " \t";
#undef DIGIT
#undef LCALPHA
#undef UCALPHA
// https://www.rfc-editor.org/rfc/rfc8941.html#section-3.3.1
constexpr int64_t kMaxInteger = 999'999'999'999'999L;
constexpr int64_t kMinInteger = -999'999'999'999'999L;
// Smallest value which is too large for an sh-decimal. This is the smallest
// double which will round up to 1e12 when serialized, which exceeds the range
// for sh-decimal. Any float less than this should round down. This behaviour is
// verified by unit tests.
constexpr double kTooLargeDecimal = 1e12 - 0.0005;
// Removes characters in remove from the beginning of s.
void StripLeft(absl::string_view& s, absl::string_view remove) {
size_t i = 0;
while (i < s.size() && memchr(remove.data(), s[i], remove.size())) {
++i;
}
if (i > 0) s.remove_prefix(i);
}
// Parser for (a subset of) Structured Headers for HTTP defined in [SH09] and
// [RFC8941]. [SH09] compatibility is retained for use by Web Packaging, and can
// be removed once that spec is updated, and users have migrated to new headers.
// [SH09] https://tools.ietf.org/html/draft-ietf-httpbis-header-structure-09
// [RFC8941] https://www.rfc-editor.org/rfc/rfc8941.html
class StructuredHeaderParser {
public:
enum DraftVersion {
kDraft09,
kFinal,
};
explicit StructuredHeaderParser(absl::string_view str, DraftVersion version)
: input_(str), version_(version) {
// [SH09] 4.2 Step 1.
// Discard any leading OWS from input_string.
// [RFC8941] 4.2 Step 2.
// Discard any leading SP characters from input_string.
SkipWhitespaces();
}
StructuredHeaderParser(const StructuredHeaderParser&) = delete;
StructuredHeaderParser& operator=(const StructuredHeaderParser&) = delete;
// Callers should call this after ReadSomething(), to check if parser has
// consumed all the input successfully.
bool FinishParsing() {
// [SH09] 4.2 Step 7.
// Discard any leading OWS from input_string.
// [RFC8941] 4.2 Step 6.
// Discard any leading SP characters from input_string.
SkipWhitespaces();
// [SH09] 4.2 Step 8. [RFC8941] 4.2 Step 7.
// If input_string is not empty, fail parsing.
return input_.empty();
}
// Parses a List of Lists ([SH09] 4.2.4).
absl::optional<ListOfLists> ReadListOfLists() {
QUICHE_CHECK_EQ(version_, kDraft09);
ListOfLists result;
while (true) {
std::vector<Item> inner_list;
while (true) {
absl::optional<Item> item(ReadBareItem());
if (!item) return absl::nullopt;
inner_list.push_back(std::move(*item));
SkipWhitespaces();
if (!ConsumeChar(';')) break;
SkipWhitespaces();
}
result.push_back(std::move(inner_list));
SkipWhitespaces();
if (!ConsumeChar(',')) break;
SkipWhitespaces();
}
return result;
}
// Parses a List ([RFC8941] 4.2.1).
absl::optional<List> ReadList() {
QUICHE_CHECK_EQ(version_, kFinal);
List members;
while (!input_.empty()) {
absl::optional<ParameterizedMember> member(ReadItemOrInnerList());
if (!member) return absl::nullopt;
members.push_back(std::move(*member));
SkipOWS();
if (input_.empty()) break;
if (!ConsumeChar(',')) return absl::nullopt;
SkipOWS();
if (input_.empty()) return absl::nullopt;
}
return members;
}
// Parses an Item ([RFC8941] 4.2.3).
absl::optional<ParameterizedItem> ReadItem() {
absl::optional<Item> item = ReadBareItem();
if (!item) return absl::nullopt;
absl::optional<Parameters> parameters = ReadParameters();
if (!parameters) return absl::nullopt;
return ParameterizedItem(std::move(*item), std::move(*parameters));
}
// Parses a bare Item ([RFC8941] 4.2.3.1, though this is also the algorithm
// for parsing an Item from [SH09] 4.2.7).
absl::optional<Item> ReadBareItem() {
if (input_.empty()) {
QUICHE_DVLOG(1) << "ReadBareItem: unexpected EOF";
return absl::nullopt;
}
switch (input_.front()) {
case '"':
return ReadString();
case '*':
if (version_ == kDraft09) return ReadByteSequence();
return ReadToken();
case ':':
if (version_ == kFinal) return ReadByteSequence();
return absl::nullopt;
case '?':
return ReadBoolean();
default:
if (input_.front() == '-' || absl::ascii_isdigit(input_.front()))
return ReadNumber();
if (absl::ascii_isalpha(input_.front())) return ReadToken();
return absl::nullopt;
}
}
// Parses a Dictionary ([RFC8941] 4.2.2).
absl::optional<Dictionary> ReadDictionary() {
QUICHE_CHECK_EQ(version_, kFinal);
Dictionary members;
while (!input_.empty()) {
absl::optional<std::string> key(ReadKey());
if (!key) return absl::nullopt;
absl::optional<ParameterizedMember> member;
if (ConsumeChar('=')) {
member = ReadItemOrInnerList();
if (!member) return absl::nullopt;
} else {
absl::optional<Parameters> parameters;
parameters = ReadParameters();
if (!parameters) return absl::nullopt;
member = ParameterizedMember{Item(true), std::move(*parameters)};
}
members[*key] = std::move(*member);
SkipOWS();
if (input_.empty()) break;
if (!ConsumeChar(',')) return absl::nullopt;
SkipOWS();
if (input_.empty()) return absl::nullopt;
}
return members;
}
// Parses a Parameterised List ([SH09] 4.2.5).
absl::optional<ParameterisedList> ReadParameterisedList() {
QUICHE_CHECK_EQ(version_, kDraft09);
ParameterisedList items;
while (true) {
absl::optional<ParameterisedIdentifier> item =
ReadParameterisedIdentifier();
if (!item) return absl::nullopt;
items.push_back(std::move(*item));
SkipWhitespaces();
if (!ConsumeChar(',')) return items;
SkipWhitespaces();
}
}
private:
// Parses a Parameterised Identifier ([SH09] 4.2.6).
absl::optional<ParameterisedIdentifier> ReadParameterisedIdentifier() {
QUICHE_CHECK_EQ(version_, kDraft09);
absl::optional<Item> primary_identifier = ReadToken();
if (!primary_identifier) return absl::nullopt;
ParameterisedIdentifier::Parameters parameters;
SkipWhitespaces();
while (ConsumeChar(';')) {
SkipWhitespaces();
absl::optional<std::string> name = ReadKey();
if (!name) return absl::nullopt;
Item value;
if (ConsumeChar('=')) {
auto item = ReadBareItem();
if (!item) return absl::nullopt;
value = std::move(*item);
}
if (!parameters.emplace(*name, value).second) {
QUICHE_DVLOG(1) << "ReadParameterisedIdentifier: duplicated parameter: "
<< *name;
return absl::nullopt;
}
SkipWhitespaces();
}
return ParameterisedIdentifier(std::move(*primary_identifier),
std::move(parameters));
}
// Parses an Item or Inner List ([RFC8941] 4.2.1.1).
absl::optional<ParameterizedMember> ReadItemOrInnerList() {
QUICHE_CHECK_EQ(version_, kFinal);
std::vector<Item> member;
bool member_is_inner_list = (!input_.empty() && input_.front() == '(');
if (member_is_inner_list) {
return ReadInnerList();
} else {
auto item = ReadItem();
if (!item) return absl::nullopt;
return ParameterizedMember(std::move(item->item),
std::move(item->params));
}
}
// Parses Parameters ([RFC8941] 4.2.3.2)
absl::optional<Parameters> ReadParameters() {
Parameters parameters;
absl::flat_hash_set<std::string> keys;
while (ConsumeChar(';')) {
SkipWhitespaces();
absl::optional<std::string> name = ReadKey();
if (!name) return absl::nullopt;
bool is_duplicate_key = !keys.insert(*name).second;
Item value{true};
if (ConsumeChar('=')) {
auto item = ReadBareItem();
if (!item) return absl::nullopt;
value = std::move(*item);
}
if (is_duplicate_key) {
for (auto& param : parameters) {
if (param.first == name) {
param.second = std::move(value);
break;
}
}
} else {
parameters.emplace_back(std::move(*name), std::move(value));
}
}
return parameters;
}
// Parses an Inner List ([RFC8941] 4.2.1.2).
absl::optional<ParameterizedMember> ReadInnerList() {
QUICHE_CHECK_EQ(version_, kFinal);
if (!ConsumeChar('(')) return absl::nullopt;
std::vector<ParameterizedItem> inner_list;
while (true) {
SkipWhitespaces();
if (ConsumeChar(')')) {
absl::optional<Parameters> parameters;
parameters = ReadParameters();
if (!parameters) return absl::nullopt;
return ParameterizedMember(std::move(inner_list), true,
std::move(*parameters));
}
auto item = ReadItem();
if (!item) return absl::nullopt;
inner_list.push_back(std::move(*item));
if (input_.empty() || (input_.front() != ' ' && input_.front() != ')'))
return absl::nullopt;
}
QUICHE_NOTREACHED();
return absl::nullopt;
}
// Parses a Key ([SH09] 4.2.2, [RFC8941] 4.2.3.3).
absl::optional<std::string> ReadKey() {
if (version_ == kDraft09) {
if (input_.empty() || !absl::ascii_islower(input_.front())) {
LogParseError("ReadKey", "lcalpha");
return absl::nullopt;
}
} else {
if (input_.empty() ||
(!absl::ascii_islower(input_.front()) && input_.front() != '*')) {
LogParseError("ReadKey", "lcalpha | *");
return absl::nullopt;
}
}
const char* allowed_chars =
(version_ == kDraft09 ? kKeyChars09 : kKeyChars);
size_t len = input_.find_first_not_of(allowed_chars);
if (len == absl::string_view::npos) len = input_.size();
std::string key(input_.substr(0, len));
input_.remove_prefix(len);
return key;
}
// Parses a Token ([SH09] 4.2.10, [RFC8941] 4.2.6).
absl::optional<Item> ReadToken() {
if (input_.empty() ||
!(absl::ascii_isalpha(input_.front()) || input_.front() == '*')) {
LogParseError("ReadToken", "ALPHA");
return absl::nullopt;
}
size_t len = input_.find_first_not_of(version_ == kDraft09 ? kTokenChars09
: kTokenChars);
if (len == absl::string_view::npos) len = input_.size();
std::string token(input_.substr(0, len));
input_.remove_prefix(len);
return Item(std::move(token), Item::kTokenType);
}
// Parses a Number ([SH09] 4.2.8, [RFC8941] 4.2.4).
absl::optional<Item> ReadNumber() {
bool is_negative = ConsumeChar('-');
bool is_decimal = false;
size_t decimal_position = 0;
size_t i = 0;
for (; i < input_.size(); ++i) {
if (i > 0 && input_[i] == '.' && !is_decimal) {
is_decimal = true;
decimal_position = i;
continue;
}
if (!absl::ascii_isdigit(input_[i])) break;
}
if (i == 0) {
LogParseError("ReadNumber", "DIGIT");
return absl::nullopt;
}
if (!is_decimal) {
// [RFC8941] restricts the range of integers further.
if (version_ == kFinal && i > 15) {
LogParseError("ReadNumber", "integer too long");
return absl::nullopt;
}
} else {
if (version_ != kFinal && i > 16) {
LogParseError("ReadNumber", "float too long");
return absl::nullopt;
}
if (version_ == kFinal && decimal_position > 12) {
LogParseError("ReadNumber", "decimal too long");
return absl::nullopt;
}
if (i - decimal_position > (version_ == kFinal ? 4 : 7)) {
LogParseError("ReadNumber", "too many digits after decimal");
return absl::nullopt;
}
if (i == decimal_position) {
LogParseError("ReadNumber", "no digits after decimal");
return absl::nullopt;
}
}
std::string output_number_string(input_.substr(0, i));
input_.remove_prefix(i);
if (is_decimal) {
// Convert to a 64-bit double, and return if the conversion is
// successful.
double f;
if (!absl::SimpleAtod(output_number_string, &f)) return absl::nullopt;
return Item(is_negative ? -f : f);
} else {
// Convert to a 64-bit signed integer, and return if the conversion is
// successful.
int64_t n;
if (!absl::SimpleAtoi(output_number_string, &n)) return absl::nullopt;
QUICHE_CHECK(version_ != kFinal ||
(n <= kMaxInteger && n >= kMinInteger));
return Item(is_negative ? -n : n);
}
}
// Parses a String ([SH09] 4.2.9, [RFC8941] 4.2.5).
absl::optional<Item> ReadString() {
std::string s;
if (!ConsumeChar('"')) {
LogParseError("ReadString", "'\"'");
return absl::nullopt;
}
while (!ConsumeChar('"')) {
size_t i = 0;
for (; i < input_.size(); ++i) {
if (!absl::ascii_isprint(input_[i])) {
QUICHE_DVLOG(1) << "ReadString: non printable-ASCII character";
return absl::nullopt;
}
if (input_[i] == '"' || input_[i] == '\\') break;
}
if (i == input_.size()) {
QUICHE_DVLOG(1) << "ReadString: missing closing '\"'";
return absl::nullopt;
}
s.append(std::string(input_.substr(0, i)));
input_.remove_prefix(i);
if (ConsumeChar('\\')) {
if (input_.empty()) {
QUICHE_DVLOG(1) << "ReadString: backslash at string end";
return absl::nullopt;
}
if (input_[0] != '"' && input_[0] != '\\') {
QUICHE_DVLOG(1) << "ReadString: invalid escape";
return absl::nullopt;
}
s.push_back(input_.front());
input_.remove_prefix(1);
}
}
return s;
}
// Parses a Byte Sequence ([SH09] 4.2.11, [RFC8941] 4.2.7).
absl::optional<Item> ReadByteSequence() {
char delimiter = (version_ == kDraft09 ? '*' : ':');
if (!ConsumeChar(delimiter)) {
LogParseError("ReadByteSequence", "delimiter");
return absl::nullopt;
}
size_t len = input_.find(delimiter);
if (len == absl::string_view::npos) {
QUICHE_DVLOG(1) << "ReadByteSequence: missing closing delimiter";
return absl::nullopt;
}
std::string base64(input_.substr(0, len));
// Append the necessary padding characters.
base64.resize((base64.size() + 3) / 4 * 4, '=');
std::string binary;
if (!absl::Base64Unescape(base64, &binary)) {
QUICHE_DVLOG(1) << "ReadByteSequence: failed to decode base64: "
<< base64;
return absl::nullopt;
}
input_.remove_prefix(len);
ConsumeChar(delimiter);
return Item(std::move(binary), Item::kByteSequenceType);
}
// Parses a Boolean ([RFC8941] 4.2.8).
// Note that this only parses ?0 and ?1 forms from SH version 10+, not the
// previous ?F and ?T, which were not needed by any consumers of SH version 9.
absl::optional<Item> ReadBoolean() {
if (!ConsumeChar('?')) {
LogParseError("ReadBoolean", "'?'");
return absl::nullopt;
}
if (ConsumeChar('1')) {
return Item(true);
}
if (ConsumeChar('0')) {
return Item(false);
}
return absl::nullopt;
}
// There are several points in the specs where the handling of whitespace
// differs between Draft 9 and the final RFC. In those cases, Draft 9 allows
// any OWS character, while the RFC allows only a U+0020 SPACE.
void SkipWhitespaces() {
if (version_ == kDraft09) {
StripLeft(input_, kOWS);
} else {
StripLeft(input_, kSP);
}
}
void SkipOWS() { StripLeft(input_, kOWS); }
bool ConsumeChar(char expected) {
if (!input_.empty() && input_.front() == expected) {
input_.remove_prefix(1);
return true;
}
return false;
}
void LogParseError(const char* func, const char* expected) {
QUICHE_DVLOG(1) << func << ": " << expected << " expected, got "
<< (input_.empty()
? "EOS"
: "'" + std::string(input_.substr(0, 1)) + "'");
}
absl::string_view input_;
DraftVersion version_;
};
// Serializer for (a subset of) Structured Field Values for HTTP defined in
// [RFC8941]. Note that this serializer does not attempt to support [SH09].
class StructuredHeaderSerializer {
public:
StructuredHeaderSerializer() = default;
~StructuredHeaderSerializer() = default;
StructuredHeaderSerializer(const StructuredHeaderSerializer&) = delete;
StructuredHeaderSerializer& operator=(const StructuredHeaderSerializer&) =
delete;
std::string Output() { return output_.str(); }
// Serializes a List ([RFC8941] 4.1.1).
bool WriteList(const List& value) {
bool first = true;
for (const auto& member : value) {
if (!first) output_ << ", ";
if (!WriteParameterizedMember(member)) return false;
first = false;
}
return true;
}
// Serializes an Item ([RFC8941] 4.1.3).
bool WriteItem(const ParameterizedItem& value) {
if (!WriteBareItem(value.item)) return false;
return WriteParameters(value.params);
}
// Serializes an Item ([RFC8941] 4.1.3).
bool WriteBareItem(const Item& value) {
if (value.is_string()) {
// Serializes a String ([RFC8941] 4.1.6).
output_ << "\"";
for (const char& c : value.GetString()) {
if (!absl::ascii_isprint(c)) return false;
if (c == '\\' || c == '\"') output_ << "\\";
output_ << c;
}
output_ << "\"";
return true;
}
if (value.is_token()) {
// Serializes a Token ([RFC8941] 4.1.7).
if (value.GetString().empty() ||
!(absl::ascii_isalpha(value.GetString().front()) ||
value.GetString().front() == '*'))
return false;
if (value.GetString().find_first_not_of(kTokenChars) != std::string::npos)
return false;
output_ << value.GetString();
return true;
}
if (value.is_byte_sequence()) {
// Serializes a Byte Sequence ([RFC8941] 4.1.8).
output_ << ":";
output_ << absl::Base64Escape(value.GetString());
output_ << ":";
return true;
}
if (value.is_integer()) {
// Serializes an Integer ([RFC8941] 4.1.4).
if (value.GetInteger() > kMaxInteger || value.GetInteger() < kMinInteger)
return false;
output_ << value.GetInteger();
return true;
}
if (value.is_decimal()) {
// Serializes a Decimal ([RFC8941] 4.1.5).
double decimal_value = value.GetDecimal();
if (!std::isfinite(decimal_value) ||
fabs(decimal_value) >= kTooLargeDecimal)
return false;
// Handle sign separately to simplify the rest of the formatting.
if (decimal_value < 0) output_ << "-";
// Unconditionally take absolute value to ensure that -0 is serialized as
// "0.0", with no negative sign, as required by spec. (4.1.5, step 2).
decimal_value = fabs(decimal_value);
double remainder = fmod(decimal_value, 0.002);
if (remainder == 0.0005) {
// Value ended in exactly 0.0005, 0.0025, 0.0045, etc. Round down.
decimal_value -= 0.0005;
} else if (remainder == 0.0015) {
// Value ended in exactly 0.0015, 0.0035, 0,0055, etc. Round up.
decimal_value += 0.0005;
} else {
// Standard rounding will work in all other cases.
decimal_value = round(decimal_value * 1000.0) / 1000.0;
}
// Use standard library functions to write the decimal, and then truncate
// if necessary to conform to spec.
// Maximum is 12 integer digits, one decimal point, three fractional
// digits, and a null terminator.
char buffer[17];
absl::SNPrintF(buffer, std::size(buffer), "%#.3f", decimal_value);
// Strip any trailing 0s after the decimal point, but leave at least one
// digit after it in all cases. (So 1.230 becomes 1.23, but 1.000 becomes
// 1.0.)
absl::string_view formatted_number(buffer);
auto truncate_index = formatted_number.find_last_not_of('0');
if (formatted_number[truncate_index] == '.') truncate_index++;
output_ << formatted_number.substr(0, truncate_index + 1);
return true;
}
if (value.is_boolean()) {
// Serializes a Boolean ([RFC8941] 4.1.9).
output_ << (value.GetBoolean() ? "?1" : "?0");
return true;
}
return false;
}
// Serializes a Dictionary ([RFC8941] 4.1.2).
bool WriteDictionary(const Dictionary& value) {
bool first = true;
for (const auto& [dict_key, dict_value] : value) {
if (!first) output_ << ", ";
if (!WriteKey(dict_key)) return false;
first = false;
if (!dict_value.member_is_inner_list && !dict_value.member.empty() &&
dict_value.member.front().item.is_boolean() &&
dict_value.member.front().item.GetBoolean()) {
if (!WriteParameters(dict_value.params)) return false;
} else {
output_ << "=";
if (!WriteParameterizedMember(dict_value)) return false;
}
}
return true;
}
private:
bool WriteParameterizedMember(const ParameterizedMember& value) {
// Serializes a parameterized member ([RFC8941] 4.1.1).
if (value.member_is_inner_list) {
if (!WriteInnerList(value.member)) return false;
} else {
QUICHE_CHECK_EQ(value.member.size(), 1UL);
if (!WriteItem(value.member[0])) return false;
}
return WriteParameters(value.params);
}
bool WriteInnerList(const std::vector<ParameterizedItem>& value) {
// Serializes an inner list ([RFC8941] 4.1.1.1).
output_ << "(";
bool first = true;
for (const ParameterizedItem& member : value) {
if (!first) output_ << " ";
if (!WriteItem(member)) return false;
first = false;
}
output_ << ")";
return true;
}
bool WriteParameters(const Parameters& value) {
// Serializes a parameter list ([RFC8941] 4.1.1.2).
for (const auto& param_name_and_value : value) {
const std::string& param_name = param_name_and_value.first;
const Item& param_value = param_name_and_value.second;
output_ << ";";
if (!WriteKey(param_name)) return false;
if (!param_value.is_null()) {
if (param_value.is_boolean() && param_value.GetBoolean()) continue;
output_ << "=";
if (!WriteBareItem(param_value)) return false;
}
}
return true;
}
bool WriteKey(const std::string& value) {
// Serializes a Key ([RFC8941] 4.1.1.3).
if (value.empty()) return false;
if (value.find_first_not_of(kKeyChars) != std::string::npos) return false;
if (!absl::ascii_islower(value[0]) && value[0] != '*') return false;
output_ << value;
return true;
}
std::ostringstream output_;
};
} // namespace
Item::Item() {}
Item::Item(const std::string& value, Item::ItemType type)
: type_(type), string_value_(value) {}
Item::Item(std::string&& value, Item::ItemType type)
: type_(type), string_value_(std::move(value)) {
QUICHE_CHECK(type_ == kStringType || type_ == kTokenType ||
type_ == kByteSequenceType);
}
Item::Item(const char* value, Item::ItemType type)
: Item(std::string(value), type) {}
Item::Item(int64_t value) : type_(kIntegerType), integer_value_(value) {}
Item::Item(double value) : type_(kDecimalType), decimal_value_(value) {}
Item::Item(bool value) : type_(kBooleanType), boolean_value_(value) {}
bool operator==(const Item& lhs, const Item& rhs) {
if (lhs.type_ != rhs.type_) return false;
switch (lhs.type_) {
case Item::kNullType:
return true;
case Item::kStringType:
case Item::kTokenType:
case Item::kByteSequenceType:
return lhs.string_value_ == rhs.string_value_;
case Item::kIntegerType:
return lhs.integer_value_ == rhs.integer_value_;
case Item::kDecimalType:
return lhs.decimal_value_ == rhs.decimal_value_;
case Item::kBooleanType:
return lhs.boolean_value_ == rhs.boolean_value_;
}
QUICHE_NOTREACHED();
return false;
}
ParameterizedItem::ParameterizedItem(const ParameterizedItem&) = default;
ParameterizedItem& ParameterizedItem::operator=(const ParameterizedItem&) =
default;
ParameterizedItem::ParameterizedItem(Item id, const Parameters& ps)
: item(std::move(id)), params(ps) {}
ParameterizedItem::~ParameterizedItem() = default;
ParameterizedMember::ParameterizedMember() = default;
ParameterizedMember::ParameterizedMember(const ParameterizedMember&) = default;
ParameterizedMember& ParameterizedMember::operator=(
const ParameterizedMember&) = default;
ParameterizedMember::ParameterizedMember(std::vector<ParameterizedItem> id,
bool member_is_inner_list,
const Parameters& ps)
: member(std::move(id)),
member_is_inner_list(member_is_inner_list),
params(ps) {}
ParameterizedMember::ParameterizedMember(std::vector<ParameterizedItem> id,
const Parameters& ps)
: member(std::move(id)), member_is_inner_list(true), params(ps) {}
ParameterizedMember::ParameterizedMember(Item id, const Parameters& ps)
: member({{std::move(id), {}}}), member_is_inner_list(false), params(ps) {}
ParameterizedMember::~ParameterizedMember() = default;
ParameterisedIdentifier::ParameterisedIdentifier(
const ParameterisedIdentifier&) = default;
ParameterisedIdentifier& ParameterisedIdentifier::operator=(
const ParameterisedIdentifier&) = default;
ParameterisedIdentifier::ParameterisedIdentifier(Item id, const Parameters& ps)
: identifier(std::move(id)), params(ps) {}
ParameterisedIdentifier::~ParameterisedIdentifier() = default;
Dictionary::Dictionary() = default;
Dictionary::Dictionary(const Dictionary&) = default;
Dictionary::Dictionary(std::vector<DictionaryMember> members)
: members_(std::move(members)) {}
Dictionary::~Dictionary() = default;
std::vector<DictionaryMember>::iterator Dictionary::begin() {
return members_.begin();
}
std::vector<DictionaryMember>::const_iterator Dictionary::begin() const {
return members_.begin();
}
std::vector<DictionaryMember>::iterator Dictionary::end() {
return members_.end();
}
std::vector<DictionaryMember>::const_iterator Dictionary::end() const {
return members_.end();
}
ParameterizedMember& Dictionary::operator[](std::size_t idx) {
return members_[idx].second;
}
const ParameterizedMember& Dictionary::operator[](std::size_t idx) const {
return members_[idx].second;
}
ParameterizedMember& Dictionary::at(std::size_t idx) { return (*this)[idx]; }
const ParameterizedMember& Dictionary::at(std::size_t idx) const {
return (*this)[idx];
}
ParameterizedMember& Dictionary::operator[](absl::string_view key) {
auto it = absl::c_find_if(
members_, [key](const auto& member) { return member.first == key; });
if (it != members_.end()) return it->second;
members_.push_back({std::string(key), ParameterizedMember()});
return members_.back().second;
}
ParameterizedMember& Dictionary::at(absl::string_view key) {
auto it = absl::c_find_if(
members_, [key](const auto& member) { return member.first == key; });
QUICHE_CHECK(it != members_.end()) << "Provided key not found in dictionary";
return it->second;
}
const ParameterizedMember& Dictionary::at(absl::string_view key) const {
auto it = absl::c_find_if(
members_, [key](const auto& member) { return member.first == key; });
QUICHE_CHECK(it != members_.end()) << "Provided key not found in dictionary";
return it->second;
}
bool Dictionary::empty() const { return members_.empty(); }
std::size_t Dictionary::size() const { return members_.size(); }
bool Dictionary::contains(absl::string_view key) const {
for (auto& member : members_) {
if (member.first == key) return true;
}
return false;
}
absl::optional<ParameterizedItem> ParseItem(absl::string_view str) {
StructuredHeaderParser parser(str, StructuredHeaderParser::kFinal);
absl::optional<ParameterizedItem> item = parser.ReadItem();
if (item && parser.FinishParsing()) return item;
return absl::nullopt;
}
absl::optional<Item> ParseBareItem(absl::string_view str) {
StructuredHeaderParser parser(str, StructuredHeaderParser::kFinal);
absl::optional<Item> item = parser.ReadBareItem();
if (item && parser.FinishParsing()) return item;
return absl::nullopt;
}
absl::optional<ParameterisedList> ParseParameterisedList(
absl::string_view str) {
StructuredHeaderParser parser(str, StructuredHeaderParser::kDraft09);
absl::optional<ParameterisedList> param_list = parser.ReadParameterisedList();
if (param_list && parser.FinishParsing()) return param_list;
return absl::nullopt;
}
absl::optional<ListOfLists> ParseListOfLists(absl::string_view str) {
StructuredHeaderParser parser(str, StructuredHeaderParser::kDraft09);
absl::optional<ListOfLists> list_of_lists = parser.ReadListOfLists();
if (list_of_lists && parser.FinishParsing()) return list_of_lists;
return absl::nullopt;
}
absl::optional<List> ParseList(absl::string_view str) {
StructuredHeaderParser parser(str, StructuredHeaderParser::kFinal);
absl::optional<List> list = parser.ReadList();
if (list && parser.FinishParsing()) return list;
return absl::nullopt;
}
absl::optional<Dictionary> ParseDictionary(const absl::string_view& str) {
StructuredHeaderParser parser(str, StructuredHeaderParser::kFinal);
absl::optional<Dictionary> dictionary = parser.ReadDictionary();
if (dictionary && parser.FinishParsing()) return dictionary;
return absl::nullopt;
}
absl::optional<std::string> SerializeItem(const Item& value) {
StructuredHeaderSerializer s;
if (s.WriteItem(ParameterizedItem(value, {}))) return s.Output();
return absl::nullopt;
}
absl::optional<std::string> SerializeItem(const ParameterizedItem& value) {
StructuredHeaderSerializer s;
if (s.WriteItem(value)) return s.Output();
return absl::nullopt;
}
absl::optional<std::string> SerializeList(const List& value) {
StructuredHeaderSerializer s;
if (s.WriteList(value)) return s.Output();
return absl::nullopt;
}
absl::optional<std::string> SerializeDictionary(const Dictionary& value) {
StructuredHeaderSerializer s;
if (s.WriteDictionary(value)) return s.Output();
return absl::nullopt;
}
} // namespace structured_headers
} // namespace quiche