pyride_core/VideoToWebBridge.h at master · uts-magic-lab/pyride_core · 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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
/*
 *  VideoToWebBridge.h
 *  PyRIDE
 *
 *  Created by Xun Wang on 13/06/2017
 *
 */

#ifndef VIDEO_TO_WEB_BRIDGE_H
#define VIDEO_TO_WEB_BRIDGE_H

#include <vector>
#include <boost/shared_ptr.hpp>
#include <boost/thread/mutex.hpp>
#include <boost/thread/thread.hpp>

#include "async_web_server_cpp/http_server.hpp"
#include "async_web_server_cpp/http_request.hpp"
#include "async_web_server_cpp/http_connection.hpp"

#include "RTPDataReceiver.h"
#include "PyModuleStub.h"

namespace pyride {

using namespace pyride_remote;

class MultipartStream {
public:
  MultipartStream( async_web_server_cpp::HttpConnectionPtr& connection, const std::string& boundry="boundarydonotcross" );

  void sendInitialHeader();
  void sendPartHeader(const double time, const std::string& type, size_t payload_size);
  void sendPartFooter();
  void sendPartAndClear( const double time, const std::string & type, std::vector<unsigned char> & data );
  void sendPart(const double time, const std::string& type, const boost::asio::const_buffer &buffer,
    async_web_server_cpp::HttpConnection::ResourcePtr resource );

private:
  async_web_server_cpp::HttpConnectionPtr connection_;
  std::string boundry_;
};

class JpegImageStreamer
{
public:
  JpegImageStreamer( const async_web_server_cpp::HttpRequest &request,
    async_web_server_cpp::HttpConnectionPtr connection );

  void sendImage( const double time, std::vector<unsigned char> & data );

private:
  MultipartStream stream_;
};

class VideoToWebBridge
{
public:
  static VideoToWebBridge * instance();
  ~VideoToWebBridge();

  bool start();
  void stop( bool selfterminate = false );

  void setPyModuleExtension( PyModuleExtension * extension ) { pyExtension_ = extension; }

  bool handle_stream(const async_web_server_cpp::HttpRequest &request,
                     async_web_server_cpp::HttpConnectionPtr connection, const char* begin, const char* end);

  bool handle_stream_viewer(const async_web_server_cpp::HttpRequest &request,
                            async_web_server_cpp::HttpConnectionPtr connection, const char* begin, const char* end);

  bool handle_snapshot(const async_web_server_cpp::HttpRequest &request,
                       async_web_server_cpp::HttpConnectionPtr connection, const char* begin, const char* end);

  bool handle_list_streams(const async_web_server_cpp::HttpRequest &request,
                           async_web_server_cpp::HttpConnectionPtr connection, const char* begin, const char* end);

private:
  int port_;
  std::string address_;
  int server_threads_;
  bool isRunning_;
  long dataTS_;

  RTPDataReceiver * dataStream_;
  PyModuleExtension * pyExtension_;

  boost::thread * streaming_data_thread_;

  boost::shared_ptr<async_web_server_cpp::HttpServer> server_;
  async_web_server_cpp::HttpRequestHandlerGroup handler_group_;
  std::vector<boost::shared_ptr<JpegImageStreamer> > image_subscribers_;
  boost::mutex subscriber_mutex_;

  static VideoToWebBridge * s_pVideoToWebBridge;

  VideoToWebBridge();

  void grabAndDispatchVideoStreamData();
};

} // namespace pyride

#endif /* VIDEO_TO_WEB_BRIDGE_H */