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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
/*
* Copyright (c) 2019 The WebRTC project authors. All Rights Reserved.
*
* Use of this source code is governed by a BSD-style license
* that can be found in the LICENSE file in the root of the source
* tree. An additional intellectual property rights grant can be found
* in the file PATENTS. All contributing project authors may
* be found in the AUTHORS file in the root of the source tree.
*/
#ifndef TEST_PC_E2E_SDP_SDP_CHANGER_H_
#define TEST_PC_E2E_SDP_SDP_CHANGER_H_
#include <map>
#include <string>
#include <vector>
#include "absl/strings/string_view.h"
#include "absl/types/optional.h"
#include "api/array_view.h"
#include "api/jsep.h"
#include "api/rtp_parameters.h"
#include "api/test/pclf/media_configuration.h"
#include "media/base/rid_description.h"
#include "pc/session_description.h"
#include "pc/simulcast_description.h"
namespace webrtc {
namespace webrtc_pc_e2e {
// Creates list of capabilities, which can be set on RtpTransceiverInterface via
// RtpTransceiverInterface::SetCodecPreferences(...) to negotiate use of codecs
// from list of `supported_codecs` which will match `video_codecs`. If flags
// `ulpfec` or `flexfec` set to true corresponding FEC codec will be added.
// FEC and RTX codecs will be added after required codecs.
//
// All codecs will be added only if they exists in the list of
// `supported_codecs`. If multiple codecs from this list will match
// `video_codecs`, then all of them will be added to the output
// vector and they will be added in the same order, as they were in
// `supported_codecs`.
std::vector<RtpCodecCapability> FilterVideoCodecCapabilities(
rtc::ArrayView<const VideoCodecConfig> video_codecs,
bool use_rtx,
bool use_ulpfec,
bool use_flexfec,
rtc::ArrayView<const RtpCodecCapability> supported_codecs);
struct LocalAndRemoteSdp {
LocalAndRemoteSdp(std::unique_ptr<SessionDescriptionInterface> local_sdp,
std::unique_ptr<SessionDescriptionInterface> remote_sdp)
: local_sdp(std::move(local_sdp)), remote_sdp(std::move(remote_sdp)) {}
// Sdp, that should be as local description on the peer, that created it.
std::unique_ptr<SessionDescriptionInterface> local_sdp;
// Sdp, that should be set as remote description on the peer opposite to the
// one, who created it.
std::unique_ptr<SessionDescriptionInterface> remote_sdp;
};
struct PatchingParams {
PatchingParams(
bool use_conference_mode,
std::map<std::string, int> stream_label_to_simulcast_streams_count)
: use_conference_mode(use_conference_mode),
stream_label_to_simulcast_streams_count(
stream_label_to_simulcast_streams_count) {}
bool use_conference_mode;
std::map<std::string, int> stream_label_to_simulcast_streams_count;
};
class SignalingInterceptor {
public:
explicit SignalingInterceptor(PatchingParams params) : params_(params) {}
LocalAndRemoteSdp PatchOffer(
std::unique_ptr<SessionDescriptionInterface> offer,
const VideoCodecConfig& first_codec);
LocalAndRemoteSdp PatchAnswer(
std::unique_ptr<SessionDescriptionInterface> answer,
const VideoCodecConfig& first_codec);
std::vector<std::unique_ptr<IceCandidateInterface>> PatchOffererIceCandidates(
rtc::ArrayView<const IceCandidateInterface* const> candidates);
std::vector<std::unique_ptr<IceCandidateInterface>>
PatchAnswererIceCandidates(
rtc::ArrayView<const IceCandidateInterface* const> candidates);
private:
// Contains information about simulcast section, that is required to perform
// modified offer/answer and ice candidates exchange.
struct SimulcastSectionInfo {
SimulcastSectionInfo(const std::string& mid,
cricket::MediaProtocolType media_protocol_type,
const std::vector<cricket::RidDescription>& rids_desc);
const std::string mid;
const cricket::MediaProtocolType media_protocol_type;
std::vector<std::string> rids;
cricket::SimulcastDescription simulcast_description;
webrtc::RtpExtension mid_extension;
webrtc::RtpExtension rid_extension;
webrtc::RtpExtension rrid_extension;
cricket::TransportDescription transport_description;
};
struct SignalingContext {
SignalingContext() = default;
// SignalingContext is not copyable and movable.
SignalingContext(SignalingContext&) = delete;
SignalingContext& operator=(SignalingContext&) = delete;
SignalingContext(SignalingContext&&) = delete;
SignalingContext& operator=(SignalingContext&&) = delete;
void AddSimulcastInfo(const SimulcastSectionInfo& info);
bool HasSimulcast() const { return !simulcast_infos.empty(); }
std::vector<SimulcastSectionInfo> simulcast_infos;
std::map<std::string, SimulcastSectionInfo*> simulcast_infos_by_mid;
std::map<std::string, SimulcastSectionInfo*> simulcast_infos_by_rid;
std::vector<std::string> mids_order;
};
LocalAndRemoteSdp PatchVp8Offer(
std::unique_ptr<SessionDescriptionInterface> offer);
LocalAndRemoteSdp PatchVp9Offer(
std::unique_ptr<SessionDescriptionInterface> offer);
LocalAndRemoteSdp PatchVp8Answer(
std::unique_ptr<SessionDescriptionInterface> answer);
LocalAndRemoteSdp PatchVp9Answer(
std::unique_ptr<SessionDescriptionInterface> answer);
void FillSimulcastContext(SessionDescriptionInterface* offer);
std::unique_ptr<cricket::SessionDescription> RestoreMediaSectionsOrder(
std::unique_ptr<cricket::SessionDescription> source);
PatchingParams params_;
SignalingContext context_;
};
} // namespace webrtc_pc_e2e
} // namespace webrtc
#endif // TEST_PC_E2E_SDP_SDP_CHANGER_H_
|
