/* -*- Mode: C++; tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- */ /* * Copyright 2020-2021 Couchbase, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include "cmd_hello.hxx" #include "core/utils/binary.hxx" #include "core/utils/byteswap.hxx" #include #include #include namespace couchbase::core::protocol { bool hello_response_body::parse(key_value_status_code status, const header_buffer& header, std::uint8_t framing_extras_size, std::uint16_t key_size, std::uint8_t extras_size, const std::vector& body, const cmd_info& /* info */) { Expects(header[1] == static_cast(opcode)); if (status == key_value_status_code::success) { std::vector::difference_type offset = framing_extras_size + key_size + extras_size; size_t value_size = body.size() - static_cast(offset); Expects(value_size % 2 == 0); size_t num_features = value_size / 2; supported_features_.reserve(num_features); const auto* value = body.data() + offset; for (size_t i = 0; i < num_features; i++) { std::uint16_t field = 0; std::memcpy(&field, value + i * 2, sizeof(std::uint16_t)); field = utils::byte_swap(field); if (is_valid_hello_feature(field)) { supported_features_.push_back(static_cast(field)); } } return true; } return false; } void hello_request_body::fill_body() { value_.resize(2 * features_.size()); for (std::size_t idx = 0; idx < features_.size(); idx++) { value_[idx * 2] = std::byte{ 0 }; // we don't need this byte while feature codes fit the 8-bit value_[idx * 2 + 1] = static_cast(features_[idx]); } } void hello_request_body::user_agent(std::string_view val) { key_.reserve(val.size()); utils::to_binary(val, std::back_insert_iterator(key_)); } } // namespace couchbase::core::protocol