asyncweb.hpp

Go to the documentation of this file.

#ifndef ESP32CAM_ASYNCWEB_HPP
#define ESP32CAM_ASYNCWEB_HPP
 
#if __has_include(<ESPAsyncWebServer.h>)
#include "camera.hpp"
#include <ESPAsyncWebServer.h>
 
namespace esp32cam {
namespace detail {
 
class CaptureTask {
public:
  explicit CaptureTask(uint32_t queueLength, uint32_t priority = 1, bool continuous = false);
 
  ~CaptureTask();
 
  explicit operator bool() const {
    return m_queue != nullptr && m_task != nullptr;
  }
 
  void request();
 
  std::unique_ptr<Frame> retrieve();
 
private:
  static void run0(void* ctx);
 
  void run();
 
private:
  void* m_queue = nullptr;
  void* m_task = nullptr;
  bool m_continuous;
};
 
} // namespace detail
 
namespace asyncweb {
 
class StillResponse : public AsyncAbstractResponse {
public:
  explicit StillResponse();
 
  ~StillResponse() override;
 
  bool _sourceValid() const override {
    return true;
  }
 
  size_t _fillBuffer(uint8_t* buf, size_t buflen) override;
 
private:
  detail::CaptureTask m_task;
  std::unique_ptr<Frame> m_frame;
  size_t m_index = 0;
};
 
inline void
handleStill(AsyncWebServerRequest* request) {
  request->send(new StillResponse());
}
 
class MjpegResponse : public AsyncAbstractResponse {
public:
  explicit MjpegResponse(const MjpegConfig& cfg = MjpegConfig());
 
  ~MjpegResponse() override;
 
  bool _sourceValid() const override {
    return true;
  }
 
  size_t _fillBuffer(uint8_t* buf, size_t buflen) override;
 
private:
  size_t sendPart(uint8_t* buf, size_t buflen);
 
private:
  detail::CaptureTask m_task;
  using Ctrl = detail::MjpegController;
  Ctrl m_ctrl;
  detail::MjpegHeader m_hdr;
 
  enum SendItem {
    SINone,
    SIBoundary,
    SIFrame,
  };
  SendItem m_sendNext = SINone;
  const uint8_t* m_sendBuf = nullptr;
  size_t m_sendRemain = 0;
  unsigned long m_createTime = millis();
  unsigned long m_sendSince = 0;
};
 
inline void
handleMjpeg(AsyncWebServerRequest* request) {
  request->send(new MjpegResponse());
}
 
} // namespace asyncweb
} // namespace esp32cam
 
#endif // __has_include(<ESPAsyncWebServer.h>)
#endif // ESP32CAM_ASYNCWEB_HPP