enigma-rtc 0.1.0

WebRTC signaling and session management for Enigma Messenger
Documentation 
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

use std::sync::Arc;

use crate::config::RtcConfig;
use crate::error::EnigmaRtcError;
use crate::session::CallSession;
use crate::signaling::encode_signaling;
use crate::types::SignalingMessage;
use crate::MockWebRtcEngine;

#[test]
fn cannot_create_multiple_offers() {
    let config = RtcConfig::default();
    let engine = Arc::new(MockWebRtcEngine::new());
    let session = CallSession::with_engine(config, engine).unwrap();
    session.create_offer().unwrap();
    let err = session.create_offer().unwrap_err();
    assert!(matches!(err, EnigmaRtcError::InvalidState));
}

#[test]
fn cannot_accept_answer_before_offer() {
    let config = RtcConfig::default();
    let engine = Arc::new(MockWebRtcEngine::new());
    let session = CallSession::with_engine(config, engine).unwrap();
    let err = session.accept_answer("remote-answer").unwrap_err();
    assert!(matches!(err, EnigmaRtcError::InvalidState));
}

#[test]
fn invalid_candidate_json_is_rejected() {
    let config = RtcConfig::default();
    let engine = Arc::new(MockWebRtcEngine::new());
    let session = CallSession::with_engine(config, engine).unwrap();
    session.create_offer().unwrap();
    session.accept_answer("remote-answer").unwrap();
    let err = session.add_ice_candidate("not-json").unwrap_err();
    assert!(matches!(err, EnigmaRtcError::JsonError(_)));
}

#[test]
fn hangup_twice_fails() {
    let config = RtcConfig::default();
    let engine = Arc::new(MockWebRtcEngine::new());
    let session = CallSession::with_engine(config, engine).unwrap();
    session.create_offer().unwrap();
    session.accept_answer("remote-answer").unwrap();
    session.hangup(None).unwrap();
    let err = session.hangup(None).unwrap_err();
    assert!(matches!(err, EnigmaRtcError::InvalidState));
}

#[test]
fn add_invalid_candidate_payload() {
    let config = RtcConfig::default();
    let engine = Arc::new(MockWebRtcEngine::new());
    let session = CallSession::with_engine(config, engine).unwrap();
    session.create_offer().unwrap();
    session.accept_answer("remote-answer").unwrap();
    let message = SignalingMessage::Offer {
        sdp: "bad".to_string(),
    };
    let payload = encode_signaling(&message);
    let err = session.add_ice_candidate(&payload).unwrap_err();
    assert!(matches!(err, EnigmaRtcError::InvalidCandidate));
}