HttpRequest.h

Go to the documentation of this file.

#pragma once
 
#include <WiFi.h>
 
#include "HttpHeader.h"
// #include "Platform/AltClient.h"
#include "HttpChunkReader.h"
#include "WiFiClient.h"
 
namespace tiny_dlna {
 
class HttpRequest {
 public:
  HttpRequest() {
    DlnaLogger.log(DlnaLogLevel::Debug, "HttpRequest");
    // default_client.setInsecure();
    setClient(default_client);
  }
 
  HttpRequest(Client &client) {
    DlnaLogger.log(DlnaLogLevel::Debug, "HttpRequest");
    setClient(client);
  }
 
  ~HttpRequest() { stop(); }
 
  void setClient(Client &client) { this->client_ptr = &client; }
 
  // the requests usually need a host. This needs to be set if we did not
  // provide a URL
  void setHost(const char *host) {
    DlnaLogger.log(DlnaLogLevel::Info, "setHost", host);
    this->host_name = host;
  }
 
  operator bool() { return client_ptr != nullptr && (bool)*client_ptr; }
 
  virtual bool connected() { return client_ptr->connected(); }
 
  virtual int available() {
    if (reply_header.isChunked()) {
      return chunk_reader.available();
    }
    return client_ptr->available();
  }
 
  virtual void stop() {
    DlnaLogger.log(DlnaLogLevel::Info, "stop");
    client_ptr->stop();
  }
 
  virtual int post(Url &url, const char *mime, const char *data, int len = -1) {
    DlnaLogger.log(DlnaLogLevel::Info, "post %s", url.url());
    return process(T_POST, url, mime, data, len);
  }
 
  virtual int put(Url &url, const char *mime, const char *data, int len = -1) {
    DlnaLogger.log(DlnaLogLevel::Info, "put %s", url.url());
    return process(T_PUT, url, mime, data, len);
  }
 
  virtual int del(Url &url, const char *mime = nullptr,
                  const char *data = nullptr, int len = -1) {
    DlnaLogger.log(DlnaLogLevel::Info, "del %s", url.url());
    return process(T_DELETE, url, mime, data, len);
  }
 
  virtual int get(Url &url, const char *acceptMime = nullptr,
                  const char *data = nullptr, int len = -1) {
    DlnaLogger.log(DlnaLogLevel::Info, "get %s", str(url.url()));
    this->accept = acceptMime;
    return process(T_GET, url, nullptr, data, len);
  }
 
  virtual int head(Url &url, const char *acceptMime = nullptr,
                   const char *data = nullptr, int len = -1) {
    DlnaLogger.log(DlnaLogLevel::Info, "head %s", url.url());
    this->accept = acceptMime;
    return process(T_HEAD, url, nullptr, data, len);
  }
 
  virtual int subscribe(Url &url) {
    DlnaLogger.log(DlnaLogLevel::Info, "post %s", url.url());
    return process(T_SUBSCRIBE, url, nullptr, nullptr, 0);
  }
 
  // reads the reply data
  virtual int read(uint8_t *str, int len) {
    if (reply_header.isChunked()) {
      return chunk_reader.read(*client_ptr, str, len);
    } else {
      return client_ptr->read(str, len);
    }
  }
 
  // read the reply data up to the next new line. For Chunked data we provide
  // the full chunk!
  virtual int readln(uint8_t *str, int len, bool incl_nl = true) {
    if (reply_header.isChunked()) {
      return chunk_reader.readln(*client_ptr, str, len);
    } else {
      return chunk_reader.readlnInternal(*client_ptr, str, len, incl_nl);
    }
  }
 
  // provides the head information of the reply
  virtual HttpReplyHeader &reply() { return reply_header; }
 
  virtual HttpRequestHeader &request() { return request_header; }
 
  virtual void setAgent(const char *agent) { this->agent = agent; }
 
  virtual void setConnection(const char *connection) {
    this->connection = connection;
  }
 
  virtual void setAcceptsEncoding(const char *enc) {
    this->accept_encoding = enc;
  }
 
  Client *client() { return client_ptr; }
 
  void setTimeout(int ms) { client_ptr->setTimeout(ms); }
 
 protected:
  WiFiClient default_client;
  Client *client_ptr;
  Url url;
  HttpRequestHeader request_header;
  HttpReplyHeader reply_header;
  HttpChunkReader chunk_reader{reply_header};
  Str host_name;
  const char *agent = nullptr;
  const char *connection = CON_CLOSE;
  const char *accept = ACCEPT_ALL;
  const char *accept_encoding = nullptr;
 
  const char *str(const char *in) { return in == nullptr ? "" : in; }
 
  // opens a connection to the indicated host
  virtual int connect(const char *ip, uint16_t port) {
    DlnaLogger.log(DlnaLogLevel::Info, "connect %s", ip);
    int rc = this->client_ptr->connect(ip, port);
    uint64_t end = millis() + client_ptr->getTimeout();
    DlnaLogger.log(DlnaLogLevel::Info, "Connected: %s (rc=%d) with timeout %ld",
                   connected() ? "true" : "false", rc,
                   client_ptr->getTimeout());
    return rc;
  }
 
  // sends request and reads the reply_header from the server
  virtual int process(TinyMethodID action, Url &url, const char *mime,
                      const char *data, int len = -1) {
    if (!connected()) {
      DlnaLogger.log(DlnaLogLevel::Info, "Connecting to host %s port %d", url.host(),
                     url.port());
 
      connect(url.host(), url.port());
    }
 
    if (!connected()) {
      DlnaLogger.log(DlnaLogLevel::Info, "Connected: %s", connected() ? "true" : "false");
      return -1;
    }
 
    if (host_name.isEmpty()) {
      host_name = url.host();
      host_name.add(":");
      host_name.add(url.port());
    }
 
    request_header.setValues(action, url.path());
    if (len == -1 && data != nullptr) {
      len = strlen(data);
    }
    if (len > 0) {
      request_header.put(CONTENT_LENGTH, len);
    }
    if (!host_name.isEmpty()) {
      request_header.put(HOST_C, host_name.c_str());
    }
    if (agent != nullptr) {
      request_header.put(USER_AGENT, agent);
    }
    if (accept_encoding != nullptr) {
      request_header.put(ACCEPT_ENCODING, accept_encoding);
    }
    if (mime != nullptr) {
      request_header.put(CONTENT_TYPE, mime);
    }
 
    request_header.put(CONNECTION, connection);
    request_header.put(ACCEPT, accept);
 
    request_header.write(*client_ptr);
 
    if (len > 0) {
      DlnaLogger.log(DlnaLogLevel::Info, "process - writing data: %d bytes", len);
      client_ptr->write((const uint8_t *)data, len);
    }
 
    reply_header.read(*client_ptr);
 
    // if we use chunked tranfer we need to read the first chunked length
    if (reply_header.isChunked()) {
      chunk_reader.open(*client_ptr);
    };
 
    return reply_header.statusCode();
  }
};
 
using DLNAHttpRequest = tiny_dlna::HttpRequest;
 
}  // namespace tiny_dlna