AudioSourceURL.h

 
 
#pragma once
#include "AudioToolsConfig.h"
#include "AudioSource.h"
#include "AudioTools/CoreAudio/AudioHttp/AbstractURLStream.h"
 
namespace audio_tools {
 
class AudioSourceURL : public AudioSource {
 public:
  template <typename T, size_t N>
  AudioSourceURL(AbstractURLStream& urlStream, T (&urlArray)[N],
                 const char* mime, int startPos = 0) {
    TRACED();
    this->actual_stream = &urlStream;
    this->mime = mime;
    this->urlArray = urlArray;
    this->max = N;
    this->pos = startPos - 1;
    this->timeout_auto_next_value = 20000;
  }
 
  virtual bool begin() override {
    TRACED();
    this->pos = 0;
    return true;
  }
 
  Stream* selectStream(int idx) override {
    pos = idx;
    if (pos < 0) {
      pos = 0;
      LOGI("url array out of limits: %d -> %d", idx, pos);
    }
    if (pos >= size()) {
      pos = size() - 1;
      LOGI("url array out of limits: %d -> %d", idx, pos);
    }
    LOGI("selectStream: %d/%d -> %s", pos, size() - 1, value(pos));
    if (started) actual_stream->end();
    actual_stream->begin(value(pos), mime);
    started = true;
    return actual_stream;
  }
 
  Stream* nextStream(int offset) override {
    pos += offset;
    if (pos < 0 || pos >= size()) {
      pos = 0;
    }
    LOGI("nextStream: %d/%d -> %s", pos, max - 1, value(pos));
    return selectStream(pos);
  }
 
  Stream* previousStream(int offset) override {
    pos -= offset;
    if (pos < 0 || pos >= size()) {
      pos = size() - 1;
    }
    LOGI("previousStream: %d/%d -> %s", pos, size() - 1, value(pos));
    return selectStream(pos);
  }
 
  Stream* selectStream(const char* path) override {
    LOGI("selectStream: %s", path);
    if (started) actual_stream->end();
    actual_stream->begin(path, mime);
    started = true;
    return actual_stream;
  }
 
  int index() { return pos; }
 
  const char* toStr() { return value(pos); }
 
  void setTimeout(int millisec) { actual_stream->setTimeout(millisec); }
 
  // provides go not to the next on error
  virtual bool isAutoNext() { return true; };
 
  // only the ICYStream supports this
  bool setMetadataCallback(void (*fn)(MetaDataType info, const char* str,
                                      int len),
                           ID3TypeSelection sel = SELECT_ICY) {
    TRACEI();
    return actual_stream->setMetadataCallback(fn);
  }
 
 protected:
  AbstractURLStream* actual_stream = nullptr;
  const char** urlArray = nullptr;
  int pos = 0;
  int max = 0;
  const char* mime = nullptr;
  bool started = false;
 
  AudioSourceURL() = default;
 
  virtual const char* value(int pos) {
    if (urlArray == nullptr) return nullptr;
    return urlArray[pos];
  }
 
  virtual int size() { return max; }
};
 
class AudioSourceDynamicURL : public AudioSourceURL {
 public:
  template <typename T, size_t N>
  AudioSourceDynamicURL(AbstractURLStream& urlStream, T (&urlArray)[N],
                        const char* mime, int startPos = 0) {
    this->actual_stream = &urlStream;
    this->mime = mime;
    this->pos = startPos - 1;
    this->timeout_auto_next_value = 20000;
    for (int j = 0; j < N; j++) {
      addURL(urlArray[j]);
    }
  }
 
  AudioSourceDynamicURL(AbstractURLStream& urlStream, const char* mime,
                        int startPos = 0) {
    this->actual_stream = &urlStream;
    this->mime = mime;
    this->pos = startPos - 1;
    this->timeout_auto_next_value = 20000;
  }
 
  void addURL(const char* url) { url_vector.push_back(url); }
 
  void clear() { url_vector.clear(); }
 
 protected:
  Vector<Str> url_vector;
 
  const char* value(int pos) override { return url_vector[pos].c_str(); }
 
  int size() override { return url_vector.size(); }
};
 
}  // namespace audio_tools