summaryrefslogtreecommitdiff
path: root/src/audio/include/audio_decoder.hpp
blob: aa83825f63618258a725dedf809e83c080ee4183 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
#pragma once

#include <cstddef>
#include <cstdint>
#include <memory>

#include "chunk.hpp"
#include "ff.h"
#include "span.hpp"

#include "audio_element.hpp"
#include "codec.hpp"

namespace audio {

/*
 * An audio element that accepts various kinds of encoded audio streams as
 * input, and converts them to uncompressed PCM output.
 */
class AudioDecoder : public IAudioElement {
 public:
  AudioDecoder();
  ~AudioDecoder();

  auto StackSizeBytes() const -> std::size_t override { return 10 * 1024; };

  auto InputMinChunkSize() const -> std::size_t override {
    // 128 kbps MPEG-1 @ 44.1 kHz is approx. 418 bytes according to the
    // internet.
    // TODO(jacqueline): tune as more codecs are added.
    return 1024;
  }

  auto HasUnprocessedInput() -> bool override;

  auto ProcessStreamInfo(const StreamInfo& info)
      -> cpp::result<void, AudioProcessingError> override;
  auto ProcessChunk(const cpp::span<std::byte>& chunk)
      -> cpp::result<std::size_t, AudioProcessingError> override;
  auto ProcessEndOfStream() -> void override;
  auto Process() -> cpp::result<void, AudioProcessingError> override;

  AudioDecoder(const AudioDecoder&) = delete;
  AudioDecoder& operator=(const AudioDecoder&) = delete;

 private:
  std::unique_ptr<codecs::ICodec> current_codec_;
  std::optional<StreamInfo> stream_info_;
  std::optional<ChunkReader> chunk_reader_;

  bool has_sent_stream_info_;
  std::size_t chunk_size_;
  bool has_samples_to_send_;
  bool needs_more_input_;
};

}  // namespace audio