blob: 83d1b73920ab0e2b6afcbc3b2060168e3312231b [file] [log] [blame]
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001/*
Donald E Curtisa8736442015-08-05 15:48:13 -07002 * Copyright 2012 The WebRTC Project Authors. All rights reserved.
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003 *
Donald E Curtisa8736442015-08-05 15:48:13 -07004 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
henrike@webrtc.org28e20752013-07-10 00:45:36 +00009 */
10
Mirko Bonadei92ea95e2017-09-15 06:47:31 +020011#ifndef EXAMPLES_PEERCONNECTION_CLIENT_CONDUCTOR_H_
12#define EXAMPLES_PEERCONNECTION_CLIENT_CONDUCTOR_H_
henrike@webrtc.org28e20752013-07-10 00:45:36 +000013
14#include <deque>
15#include <map>
deadbeef112b2e92017-02-10 20:13:37 -080016#include <memory>
henrike@webrtc.org28e20752013-07-10 00:45:36 +000017#include <string>
Steve Antonc06ed702018-04-17 12:53:02 -070018#include <vector>
henrike@webrtc.org28e20752013-07-10 00:45:36 +000019
Mirko Bonadei92ea95e2017-09-15 06:47:31 +020020#include "api/mediastreaminterface.h"
21#include "api/peerconnectioninterface.h"
22#include "examples/peerconnection/client/main_wnd.h"
23#include "examples/peerconnection/client/peer_connection_client.h"
henrike@webrtc.org28e20752013-07-10 00:45:36 +000024
25namespace webrtc {
26class VideoCaptureModule;
27} // namespace webrtc
28
29namespace cricket {
30class VideoRenderer;
31} // namespace cricket
32
33class Conductor
34 : public webrtc::PeerConnectionObserver,
35 public webrtc::CreateSessionDescriptionObserver,
36 public PeerConnectionClientObserver,
37 public MainWndCallback {
38 public:
39 enum CallbackID {
40 MEDIA_CHANNELS_INITIALIZED = 1,
41 PEER_CONNECTION_CLOSED,
42 SEND_MESSAGE_TO_PEER,
Steve Antonc06ed702018-04-17 12:53:02 -070043 NEW_TRACK_ADDED,
44 TRACK_REMOVED,
henrike@webrtc.org28e20752013-07-10 00:45:36 +000045 };
46
47 Conductor(PeerConnectionClient* client, MainWindow* main_wnd);
48
49 bool connection_active() const;
50
Patrik Höglunda4251842018-02-20 16:03:41 +010051 void Close() override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000052
53 protected:
54 ~Conductor();
55 bool InitializePeerConnection();
braveyao@webrtc.orga742cb12015-01-29 04:23:01 +000056 bool ReinitializePeerConnectionForLoopback();
57 bool CreatePeerConnection(bool dtls);
henrike@webrtc.org28e20752013-07-10 00:45:36 +000058 void DeletePeerConnection();
59 void EnsureStreamingUI();
Steve Antonc06ed702018-04-17 12:53:02 -070060 void AddTracks();
deadbeef112b2e92017-02-10 20:13:37 -080061 std::unique_ptr<cricket::VideoCapturer> OpenVideoCaptureDevice();
henrike@webrtc.org28e20752013-07-10 00:45:36 +000062
63 //
64 // PeerConnectionObserver implementation.
65 //
perkjdfb769d2016-02-09 03:09:43 -080066
67 void OnSignalingChange(
68 webrtc::PeerConnectionInterface::SignalingState new_state) override{};
Steve Antonc06ed702018-04-17 12:53:02 -070069 void OnAddTrack(
70 rtc::scoped_refptr<webrtc::RtpReceiverInterface> receiver,
71 const std::vector<rtc::scoped_refptr<webrtc::MediaStreamInterface>>&
72 streams) override;
73 void OnRemoveTrack(
74 rtc::scoped_refptr<webrtc::RtpReceiverInterface> receiver) override;
Taylor Brandstetter98cde262016-05-31 13:02:21 -070075 void OnDataChannel(
76 rtc::scoped_refptr<webrtc::DataChannelInterface> channel) override {}
perkjdfb769d2016-02-09 03:09:43 -080077 void OnRenegotiationNeeded() override {}
78 void OnIceConnectionChange(
79 webrtc::PeerConnectionInterface::IceConnectionState new_state) override{};
80 void OnIceGatheringChange(
81 webrtc::PeerConnectionInterface::IceGatheringState new_state) override{};
82 void OnIceCandidate(const webrtc::IceCandidateInterface* candidate) override;
83 void OnIceConnectionReceivingChange(bool receiving) override {}
henrike@webrtc.org28e20752013-07-10 00:45:36 +000084
85 //
86 // PeerConnectionClientObserver implementation.
87 //
88
nisse63b14b72017-01-31 03:34:01 -080089 void OnSignedIn() override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000090
nisse63b14b72017-01-31 03:34:01 -080091 void OnDisconnected() override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000092
nisse63b14b72017-01-31 03:34:01 -080093 void OnPeerConnected(int id, const std::string& name) override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000094
nisse63b14b72017-01-31 03:34:01 -080095 void OnPeerDisconnected(int id) override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000096
nisse63b14b72017-01-31 03:34:01 -080097 void OnMessageFromPeer(int peer_id, const std::string& message) override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000098
nisse63b14b72017-01-31 03:34:01 -080099 void OnMessageSent(int err) override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000100
nisse63b14b72017-01-31 03:34:01 -0800101 void OnServerConnectionFailure() override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000102
103 //
104 // MainWndCallback implementation.
105 //
106
nisse63b14b72017-01-31 03:34:01 -0800107 void StartLogin(const std::string& server, int port) override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000108
nisse63b14b72017-01-31 03:34:01 -0800109 void DisconnectFromServer() override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000110
nisse63b14b72017-01-31 03:34:01 -0800111 void ConnectToPeer(int peer_id) override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000112
nisse63b14b72017-01-31 03:34:01 -0800113 void DisconnectFromCurrentPeer() override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000114
nisse63b14b72017-01-31 03:34:01 -0800115 void UIThreadCallback(int msg_id, void* data) override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000116
117 // CreateSessionDescriptionObserver implementation.
nisse63b14b72017-01-31 03:34:01 -0800118 void OnSuccess(webrtc::SessionDescriptionInterface* desc) override;
119 void OnFailure(const std::string& error) override;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000120
121 protected:
122 // Send a message to the remote peer.
123 void SendMessage(const std::string& json_object);
124
125 int peer_id_;
braveyao@webrtc.orga742cb12015-01-29 04:23:01 +0000126 bool loopback_;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000127 rtc::scoped_refptr<webrtc::PeerConnectionInterface> peer_connection_;
128 rtc::scoped_refptr<webrtc::PeerConnectionFactoryInterface>
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000129 peer_connection_factory_;
130 PeerConnectionClient* client_;
131 MainWindow* main_wnd_;
132 std::deque<std::string*> pending_messages_;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000133 std::string server_;
134};
135
Mirko Bonadei92ea95e2017-09-15 06:47:31 +0200136#endif // EXAMPLES_PEERCONNECTION_CLIENT_CONDUCTOR_H_