SmallDesktopDisplay/src/remote/HttpFrameClient.h at main · iola1999/SmallDesktopDisplay · GitHub

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
#ifndef REMOTE_HTTP_FRAME_CLIENT_H
#define REMOTE_HTTP_FRAME_CLIENT_H

#include "remote/FrameProtocol.h"
#include "ui/TftFrameSink.h"

#include <Arduino.h>
#include <ESP8266HTTPClient.h>
#include <WiFiClient.h>
#include <cstdint>

#include "app/FrameDiagnostics.h"
#include "app/RemoteKeepAlivePolicy.h"

namespace remote
{

enum class FrameFetchResult
{
  Updated,
  NotModified,
  Failed,
};

class HttpFrameClient
{
public:
  explicit HttpFrameClient(ui::TftFrameSink &sink) : sink_(sink)
  {
  }
  ~HttpFrameClient();

  FrameFetchResult fetchLatest(const String &baseUrl, const String &deviceId, uint32_t haveFrameId, uint32_t waitMs,
                               uint32_t &outFrameId);

private:
  void resetConnection();

  bool readExact(WiFiClient &stream, uint8_t *buffer, std::size_t length);
  bool readExact(WiFiClient &stream, uint8_t *buffer, std::size_t length, uint32_t &elapsedMs);
  bool readExact(WiFiClient &stream, uint8_t *buffer, std::size_t length, uint32_t &elapsedMs,
                 app::FrameDiagnostics &diagnostics);
  bool consumeFrame(WiFiClient &stream, const FrameHeader &header, app::FrameDiagnostics &diagnostics);
  bool consumeRawRect(WiFiClient &stream, const RectHeader &rect, uint32_t &crc, app::FrameDiagnostics &diagnostics,
                      uint16_t *rowBuffer, uint16_t maxBatchRows);
  bool consumeRleRect(WiFiClient &stream, const RectHeader &rect, uint32_t &crc, app::FrameDiagnostics &diagnostics,
                      uint16_t *rowBuffer, uint16_t maxBatchRows);

  ui::TftFrameSink &sink_;
  WiFiClient client_;
  HTTPClient http_;
  app::RemoteKeepAlivePolicy keepAlivePolicy_;
};

} // namespace remote

#endif // REMOTE_HTTP_FRAME_CLIENT_H