src/media/audio/audio_core/usage_gain_reporter_impl.h

// Copyright 2020 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#ifndef SRC_MEDIA_AUDIO_AUDIO_CORE_USAGE_GAIN_REPORTER_IMPL_H_
#define SRC_MEDIA_AUDIO_AUDIO_CORE_USAGE_GAIN_REPORTER_IMPL_H_

#include <fuchsia/media/cpp/fidl.h>
#include <lib/fidl/cpp/binding_set.h>

#include <unordered_set>

#include "src/media/audio/audio_core/context.h"
#include "src/media/audio/audio_core/loudness_transform.h"
#include "src/media/audio/audio_core/process_config.h"
#include "src/media/audio/audio_core/stream_volume_manager.h"

namespace media::audio {

// TODO(50073): Serve on the FIDL thread
class UsageGainReporterImpl : public fuchsia::media::UsageGainReporter {
 public:
  explicit UsageGainReporterImpl(Context* context)
      : process_config_(context->process_config()),
        stream_volume_manager_(context->volume_manager()) {
    FX_DCHECK(context);
  }

  fidl::InterfaceRequestHandler<fuchsia::media::UsageGainReporter> GetFidlRequestHandler();

  // |fuchsia::media::UsageGainReporter|
  void RegisterListener(
      std::string device_unique_id, fuchsia::media::Usage usage,
      fidl::InterfaceHandle<fuchsia::media::UsageGainListener> usage_gain_listener_handler) final;

 private:
  class Listener final : public StreamVolume {
   public:
    Listener(std::shared_ptr<LoudnessTransform> loudness_transform, fuchsia::media::Usage usage,
             fuchsia::media::UsageGainListenerPtr usage_gain_listener)
        : loudness_transform_(loudness_transform),
          usage_(std::move(usage)),
          usage_gain_listener_(std::move(usage_gain_listener)) {}

   private:
    // |media::audio::StreamVolume|
    fuchsia::media::Usage GetStreamUsage() const final { return fidl::Clone(usage_); }
    bool GetStreamMute() const final { return false; }
    void RealizeVolume(VolumeCommand volume_command) final;

    std::shared_ptr<LoudnessTransform> loudness_transform_;
    fuchsia::media::Usage usage_;
    fuchsia::media::UsageGainListenerPtr usage_gain_listener_;
    size_t unacked_messages_ = 0;
  };

  // TODO(50074): Queue a function on the async loop to periodically execute and
  // clean up any listeners with too many unacked messages

  const ProcessConfig& process_config_;
  StreamVolumeManager& stream_volume_manager_;
  std::unordered_set<std::unique_ptr<Listener>> listeners_;
  fidl::BindingSet<fuchsia::media::UsageGainReporter, UsageGainReporterImpl*> bindings_;
};

}  // namespace media::audio

#endif  // SRC_MEDIA_AUDIO_AUDIO_CORE_USAGE_GAIN_REPORTER_IMPL_H_