received_message_processor.h

Go to the documentation of this file.

/*
 * Copyright 2023 MusicScience37 (Kenta Kabashima)
 *
 * 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.
 */
#pragma once
 
#include <memory>
#include <utility>
#include <variant>
 
#include "msgpack_rpc/clients/impl/call_list.h"
#include "msgpack_rpc/logging/logger.h"
#include "msgpack_rpc/messages/call_result.h"
#include "msgpack_rpc/messages/parsed_message.h"
#include "msgpack_rpc/messages/parsed_response.h"
#include "msgpack_rpc/util/format_msgpack_object.h"
 
namespace msgpack_rpc::clients::impl {

class ReceivedMessageProcessor {
public:
    ReceivedMessageProcessor(std::shared_ptr<logging::Logger> logger,
        std::shared_ptr<CallList> call_list)
        : logger_(std::move(logger)), call_list_(std::move(call_list)) {}

    void operator()(const messages::ParsedMessage& message) {
        const auto* response = std::get_if<messages::ParsedResponse>(&message);
        if (response == nullptr) {
            MSGPACK_RPC_WARN(logger_, "Received an invalid message.");
            return;
        }
        if (response->result().is_success()) {
            MSGPACK_RPC_DEBUG(logger_, "Received successful response (id: {})",
                response->id());
        } else {
            MSGPACK_RPC_DEBUG(logger_, "Received error response (id: {}): {}",
                response->id(),
                util::format_msgpack_object(response->result().object()));
        }
        call_list_->handle(*response);
    }
 
private:
    std::shared_ptr<logging::Logger> logger_;

    std::shared_ptr<CallList> call_list_;
};
 
}  // namespace msgpack_rpc::clients::impl