fetch_track_handler.h

Go to the documentation of this file.

// SPDX-FileCopyrightText: Copyright (c) 2024 Cisco Systems
// SPDX-License-Identifier: BSD-2-Clause
 
#pragma once
 
#include <quicr/detail/messages.h>
#include <quicr/metrics.h>
#include <quicr/subscribe_track_handler.h>
 
namespace quicr {
    class FetchTrackHandler : public SubscribeTrackHandler
    {
      protected:
        FetchTrackHandler(const FullTrackName& full_track_name,
                          messages::SubscriberPriority priority,
                          messages::GroupOrder group_order,
                          messages::GroupId start_group,
                          messages::GroupId end_group,
                          messages::GroupId start_object,
                          messages::GroupId end_object)
          : SubscribeTrackHandler(full_track_name, priority, group_order, messages::FilterType::kNextGroupStart)
          , start_group_(start_group)
          , start_object_(start_object)
          , end_group_(end_group)
          , end_object_(end_object)
        {
        }
 
      public:
        static std::shared_ptr<FetchTrackHandler> Create(const FullTrackName& full_track_name,
                                                         messages::SubscriberPriority priority,
                                                         messages::GroupOrder group_order,
                                                         messages::GroupId start_group,
                                                         messages::GroupId end_group,
                                                         messages::GroupId start_object,
                                                         messages::GroupId end_object)
        {
            return std::shared_ptr<FetchTrackHandler>(new FetchTrackHandler(
              full_track_name, priority, group_order, start_group, end_group, start_object, end_object));
        }

        constexpr const messages::GroupId& GetStartGroup() const noexcept { return start_group_; }

        constexpr const messages::GroupId& GetEndGroup() const noexcept { return end_group_; }

        constexpr const messages::GroupId& GetStartObject() const noexcept { return start_object_; }

        constexpr const messages::GroupId& GetEndObject() const noexcept { return end_object_; }
 
        void StreamDataRecv(bool is_start,
                            uint64_t stream_id,
                            std::shared_ptr<const std::vector<uint8_t>> data) override;
 
      private:
        messages::GroupId start_group_;
        messages::GroupId start_object_;
        messages::GroupId end_group_;
        messages::GroupId end_object_;
 
        friend class Transport;
        friend class Client;
        friend class Server;
    };
 
} // namespace moq