URLStream.h

#pragma once
 
#include "AudioToolsConfig.h"
 
#if defined(USE_WIFI)
# include "WiFiInclude.h"
#endif
 
#include "AudioTools/CoreAudio/AudioBasic/Str.h"
#include "AudioTools/Communication/HTTP/AbstractURLStream.h"
#include "AudioTools/Communication/HTTP/HttpRequest.h"
#include "AudioTools/Communication/HTTP/URLStreamBufferedT.h"
 
namespace audio_tools {
 
class URLStream : public AbstractURLStream {
 public:
  URLStream(int readBufferSize = DEFAULT_BUFFER_SIZE) {
    TRACED();
    setReadBufferSize(readBufferSize);
  }
 
  URLStream(Client& clientPar, int readBufferSize = DEFAULT_BUFFER_SIZE) {
    TRACED();
    setReadBufferSize(readBufferSize);
    setClient(clientPar);
  }
 
  URLStream(const char* network, const char* password,
            int readBufferSize = DEFAULT_BUFFER_SIZE) {
    TRACED();
    setReadBufferSize(readBufferSize);
    setSSID(network);
    setPassword(password);
  }
 
  URLStream(const URLStream&) = delete;
 
  ~URLStream() {
    TRACED();
    end();
    if (clientSecure != nullptr) {
      delete clientSecure;
      clientSecure = nullptr;
    }
    if (clientInsecure != nullptr) {
      delete clientInsecure;
      clientInsecure = nullptr;
    }
  }
 
  void setClient(Client& clientPar) override { client = &clientPar; }
 
  void setSSID(const char* ssid) override { this->network = ssid; }
 
  void setPassword(const char* password) override { this->password = password; }
 
  void setReadBufferSize(int readBufferSize) {
    read_buffer_size = readBufferSize;
  }
 
  virtual bool begin(const char* urlStr, const char* acceptMime = nullptr,
                     MethodID action = GET, const char* reqMime = "",
                     const char* reqData = "") override {
    LOGI("%s: %s", LOG_METHOD, urlStr);
    if (!preProcess(urlStr, acceptMime)) {
      LOGE("preProcess failed");
      return false;
    }
    int result = process<const char*>(action, url, reqMime, reqData);
    if (result > 0) {
      size = request.contentLength();
      LOGI("contentLength: %d", (int)size);
      if (size >= 0 && wait_for_data) {
        waitForData(clientTimeout);
      }
    }
    total_read = 0;
    active = result == 200;
    LOGI("==> http status: %d", result);
    return active;
  }
 
  virtual bool begin(const char* urlStr, const char* acceptMime,
                     MethodID action, const char* reqMime, Stream& reqData,
                     int len = -1) {
    LOGI("%s: %s", LOG_METHOD, urlStr);
    if (!preProcess(urlStr, acceptMime)) {
      LOGE("preProcess failed");
      return false;
    }
    int result = process<Stream&>(action, url, reqMime, reqData, len);
    if (result > 0) {
      size = request.contentLength();
      LOGI("size: %d", (int)size);
      if (size >= 0 && wait_for_data) {
        waitForData(clientTimeout);
      }
    }
    total_read = 0;
    active = result == 200;
    LOGI("==> http status: %d", result);
    return active;
  }
 
  virtual void end() override {
    if (active) request.stop();
    active = false;
    clear();
  }
 
  virtual int available() override {
    if (!active) return 0;
 
    int result = request.available();
    LOGD("available: %d", result);
    return result;
  }
 
  virtual size_t readBytes(uint8_t* data, size_t len) override {
    if (!active) return 0;
 
    int read = request.read((uint8_t*)&data[0], len);
    if (read < 0) {
      read = 0;
    }
    total_read += read;
    LOGD("readBytes %d -> %d", (int)len, read);
    return read;
  }
 
  virtual int read() override {
    if (!active) return -1;
    // lazy allocation since this is rarely used
    read_buffer.resize(read_buffer_size);
 
    fillBuffer();
    total_read++;
    return isEOS() ? -1 : read_buffer[read_pos++];
  }
 
  virtual int peek() override {
    if (!active) return -1;
    // lazy allocation since this is rarely used
    read_buffer.resize(read_buffer_size);
 
    fillBuffer();
    return isEOS() ? -1 : read_buffer[read_pos];
  }
 
  virtual void flush() override {}
 
  virtual size_t write(uint8_t) override { return not_supported(0); }
 
  virtual size_t write(const uint8_t*, size_t len) override {
    return not_supported(0);
  }
 
  virtual HttpRequest& httpRequest() override { return request; }
 
  operator bool() override { return active && request.isReady(); }
 
  virtual void setTimeout(int ms) { clientTimeout = ms; }
 
  void setPowerSave(bool ps) override { is_power_save = ps; }
 
  void setAutoCreateLines(bool flag) {
    httpRequest().reply().setAutoCreateLines(flag);
  }
 
  void setConnectionClose(bool close) override {
    httpRequest().setConnection(close ? CON_CLOSE : CON_KEEP_ALIVE);
  }
 
  void clear() {
    httpRequest().reply().clear();
    httpRequest().header().clear();
    read_buffer.resize(0);
    read_pos = 0;
    read_size = 0;
  }
 
  void addRequestHeader(const char* key, const char* value) override {
    request.header().put(key, value);
  }
 
  const char* getReplyHeader(const char* key) override {
    return request.reply().get(key);
  }
 
  void setOnConnectCallback(void (*callback)(
      HttpRequest& request, Url& url, HttpRequestHeader& request_header)) {
    request.setOnConnectCallback(callback);
  }
 
  void setWaitForData(bool flag) { wait_for_data = flag; }
 
  int contentLength() override { return size; }
 
  size_t totalRead() override { return total_read; }
  bool waitForData (int timeout) override{
    TRACED();
    uint32_t end = millis() + timeout;
    if (request.available() == 0) {
      LOGI("Request written ... waiting for reply");
      while (request.available() == 0) {
        if (millis() > end) break;
        // stop waiting if we got an error
        if (request.reply().statusCode() >= 300) {
          LOGE("Error code recieved ... stop waiting for reply");
          break;
        }
        delay(500);
      }
    }
    int avail = request.available();
    LOGD("available: %d", avail);
    return avail > 0;
  }
 
 
  const char* urlStr() override { return url_str.c_str(); }
 
  void setCACert(const char* cert) override{
    if (clientSecure!=nullptr) clientSecure->setCACert(cert);
  }
 
 protected:
  HttpRequest request;
  Str url_str;
  Url url;
  long size;
  long total_read;
  // buffered single byte read
  Vector<uint8_t> read_buffer{0};
  uint16_t read_buffer_size = DEFAULT_BUFFER_SIZE;
  uint16_t read_pos;
  uint16_t read_size;
  bool active = false;
  bool wait_for_data = true;
  // optional
  const char* network = nullptr;
  const char* password = nullptr;
  Client* client = nullptr; // client defined via setClient
  WiFiClient* clientInsecure = nullptr; // wifi client for http
  WiFiClientSecure* clientSecure = nullptr; // wifi client for https
  int clientTimeout = URL_CLIENT_TIMEOUT;                  // 60000;
  unsigned long handshakeTimeout = URL_HANDSHAKE_TIMEOUT;  // 120000
  bool is_power_save = false;
 
  bool preProcess(const char* urlStr, const char* acceptMime) {
    TRACED();
    url_str = urlStr;
    url.setUrl(url_str.c_str());
    int result = -1;
 
    // close it - if we have an active connection
    if (active) end();
 
    // optional: login if necessary if no external client is defined
    if (client == nullptr){
      if (!login()){
        LOGE("Not connected");
        return false;
      }
    }
 
    // request.reply().setAutoCreateLines(false);
    if (acceptMime != nullptr) {
      request.setAcceptMime(acceptMime);
    }
 
    // setup client
    Client& client = getClient(url.isSecure());
    request.setClient(client);
 
    // set timeout
    client.setTimeout(clientTimeout / 1000);
    request.setTimeout(clientTimeout);
 
#if defined(ESP32)
    // There is a bug in IDF 4!
    if (clientSecure != nullptr) {
      clientSecure->setHandshakeTimeout(handshakeTimeout);
    }
 
    // Performance optimization for ESP32
    if (!is_power_save) {
      esp_wifi_set_ps(WIFI_PS_NONE);
    }
#endif
 
    return true;
  }
 
  template <typename T>
  int process(MethodID action, Url& url, const char* reqMime, T reqData,
              int len = -1) {
    TRACED();
    // keep icy across redirect requests ?
    const char* icy = request.header().get("Icy-MetaData");
 
    int status_code = request.process(action, url, reqMime, reqData, len);
    // redirect
    while (request.reply().isRedirectStatus()) {
      const char* redirect_url = request.reply().get(LOCATION);
      if (redirect_url != nullptr) {
        LOGW("Redirected to: %s", redirect_url);
        url.setUrl(redirect_url);
        Client* p_client = &getClient(url.isSecure());
        p_client->stop();
        request.setClient(*p_client);
        if (icy) {
          request.header().put("Icy-MetaData", icy);
        }
        status_code = request.process(action, url, reqMime, reqData, len);
      } else {
        LOGE("Location is null");
        break;
      }
    }
    return status_code;
  }
 
  Client& getClient(bool isSecure) {
    if (isSecure) {
      if (clientSecure == nullptr) {
        clientSecure = new WiFiClientSecure();
        clientSecure->setInsecure();
      }
      LOGI("WiFiClientSecure");
      return *clientSecure;
    }
    if (clientInsecure == nullptr) {
      clientInsecure = new WiFiClient();
      LOGI("WiFiClient");
    }
    return *clientInsecure;
  }
 
  inline void fillBuffer() {
    if (isEOS()) {
      // if we consumed all bytes we refill the buffer
      read_size = readBytes(&read_buffer[0], read_buffer_size);
      read_pos = 0;
    }
  }
 
  inline bool isEOS() { return read_pos >= read_size; }
 
  bool login() {
    if (network != nullptr && password != nullptr &&
        WiFi.status() != WL_CONNECTED) {
      TRACEI();
      WiFi.begin(network, password);
      while (WiFi.status() != WL_CONNECTED) {
        Serial.print(".");
        delay(500);
      }
      Serial.println();
      delay(10);
      return WiFi.status() == WL_CONNECTED;
    }
    return WiFi.status() == WL_CONNECTED;
  }
};
 
 
#if defined(USE_CONCURRENCY)
using URLStreamBuffered = URLStreamBufferedT<URLStream>;
 
#endif
 
}  // namespace audio_tools