@@ -25,6 +25,18 @@ void oai_send_audio_task(void *user_data) {
25
25
}
26
26
#endif
27
27
28
+ static void oai_ondatachannel_onmessage_task (char *msg, size_t len,
29
+ void *userdata, uint16_t sid) {
30
+ ESP_LOGI (LOG_TAG, " DataChannel Message: %s" , msg);
31
+ }
32
+
33
+ static void oai_ondatachannel_onopen_task (void *userdata) {
34
+ if (peer_connection_create_datachannel (peer_connection, DATA_CHANNEL_RELIABLE,
35
+ 0 , 0 , (char *)" " , (char *)" " ) == -1 ) {
36
+ ESP_LOGE (LOG_TAG, " Failed to create DataChannel" );
37
+ }
38
+ }
39
+
28
40
static void oai_onconnectionstatechange_task (PeerConnectionState state,
29
41
void *user_data) {
30
42
ESP_LOGI (LOG_TAG, " PeerConnectionState: %s" ,
@@ -56,7 +68,7 @@ void oai_webrtc() {
56
68
.ice_servers = {},
57
69
.audio_codec = CODEC_OPUS,
58
70
.video_codec = CODEC_NONE,
59
- .datachannel = DATA_CHANNEL_NONE ,
71
+ .datachannel = DATA_CHANNEL_STRING ,
60
72
.onaudiotrack = [](uint8_t *data, size_t size, void *userdata) -> void {
61
73
#ifndef LINUX_BUILD
62
74
oai_audio_decode (data, size);
@@ -78,6 +90,10 @@ void oai_webrtc() {
78
90
peer_connection_oniceconnectionstatechange (peer_connection,
79
91
oai_onconnectionstatechange_task);
80
92
peer_connection_onicecandidate (peer_connection, oai_on_icecandidate_task);
93
+ peer_connection_ondatachannel (peer_connection,
94
+ oai_ondatachannel_onmessage_task,
95
+ oai_ondatachannel_onopen_task, NULL );
96
+
81
97
peer_connection_create_offer (peer_connection);
82
98
83
99
while (1 ) {
0 commit comments