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
|
/*
* Copyright (c) 2025 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 API_DATA_CHANNEL_EVENT_OBSERVER_INTERFACE_H_
#define API_DATA_CHANNEL_EVENT_OBSERVER_INTERFACE_H_
#include <cstdint>
#include <string>
#include <vector>
#include "absl/strings/string_view.h"
#include "api/array_view.h"
namespace webrtc {
// TODO: issues.chromium.org/407785197 - Maybe update the observer to also
// notify on controll messages as well.
// TODO: issues.chromium.org/407785197 - Remove comment below when DataChannel
// logging has been launched.
// NOTE: This class is still under development and may change without notice.
class DataChannelEventObserverInterface {
public:
virtual ~DataChannelEventObserverInterface() = default;
class Message {
public:
enum class Direction { kSend, kReceive };
enum class DataType { kString, kBinary };
// When `direction` is `kSend` the timestamp represent when the message was
// handed over to the transport, if `direction` is `kReceive` then it
// represent when the message was received from the transport.
int64_t unix_timestamp_ms() const { return unix_timestamp_; }
void set_unix_timestamp_ms(int64_t timestamp) {
unix_timestamp_ = timestamp;
}
int datachannel_id() const { return datachannel_id_; }
void set_datachannel_id(int id) { datachannel_id_ = id; }
absl::string_view label() const { return label_; }
void set_label(absl::string_view label) { label_ = std::string(label); }
Direction direction() const { return direction_; }
void set_direction(Direction direction) { direction_ = direction; }
DataType data_type() const { return data_type_; }
void set_data_type(DataType type) { data_type_ = type; }
const std::vector<uint8_t>& data() const { return data_; }
void set_data(ArrayView<const uint8_t> d) {
data_.assign(d.begin(), d.end());
}
private:
int64_t unix_timestamp_;
int datachannel_id_;
std::string label_;
Direction direction_;
DataType data_type_;
std::vector<uint8_t> data_;
};
virtual void OnMessage(const Message& message) = 0;
};
} // namespace webrtc
#endif // API_DATA_CHANNEL_EVENT_OBSERVER_INTERFACE_H_
|
