BrowserClient/RtspParse.test.js at master · WebRTSP/BrowserClient · GitHub

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
"use strict"

const assert = require('assert');

suite("RTSP Response parse", () => {
    var Parse = null;
    var Method = null;
    var Protocol = null;

    setup(async () => {
         Parse = await import("./RtspParse.mjs");
         Method = await import("./RtspMethod.mjs");
         Protocol = await import("./RtspProtocol.mjs");
    });

    test("OPTIONS request", () => {
        let buffer =
            "OPTIONS * WEBRTSP/0.2\r\n" +
            "CSeq: 1\r\n";
        let request = Parse.ParseRequest(buffer);
        assert.ok(request);
        assert.ok(request.method === Method.OPTIONS);
        assert.ok(request.uri == "*");
        assert.ok(request.protocol === Protocol.WEBRTSP_0_2);
        assert.ok(request.cseq === 1);
        assert.ok(request.headerFields.size == 0);
        assert.ok(!request.body);
    });

    test("PLAY request", () => {
        let buffer =
            "PLAY rtsp://example.com/meida.ogg WEBRTSP/0.2\r\n" +
            "CSeq: 3\r\n" +
            "Content-Type: application/sdp\r\n" +
            "\r\n" +
            "<sdp>\r\n";
        let request = Parse.ParseRequest(buffer);
        assert.ok(request);
        assert.ok(request.method === Method.SETUP);
        assert.ok(request.uri == "rtsp://example.com/meida.ogg");
        assert.ok(request.protocol === Protocol.WEBRTSP_0_2);
        assert.ok(request.cseq === 3);
        assert.ok(request.headerFields.size == 1);
        assert.ok(request.headerFields.has("content-type"));
        assert.strictEqual(request.headerFields.get("content-type"), "application/sdp")
        assert.strictEqual(request.body, "<sdp>\r\n")
    });
});

suite("RTSP Response parse", () => {
    var Parse = null;
    var Method = null;
    var Protocol = null;

    setup(async () => {
         Parse = await import("./RtspParse.mjs");
         Method = await import("./RtspMethod.mjs");
         Protocol = await import("./RtspProtocol.mjs");
    });

    test("Minimal response", () => {
        let buffer =
            "WEBRTSP/0.2 200 OK\r\n" +
            "CSeq: 9\r\n"
        let response = Parse.ParseResponse(buffer);
        assert.ok(response);
        assert.ok(response.protocol === Protocol.WEBRTSP_0_2);
        assert.ok(response.statusCode === 200);
        assert.ok(response.reasonPhrase === "OK");
        assert.ok(response.cseq === 9);
        assert.ok(response.headerFields.size == 0);
        assert.ok(!response.body);
    });

    test("Response with header field", () => {
        let buffer =
            "WEBRTSP/0.2 200 OK\r\n" +
            "CSeq: 9\r\n" +
            "Content-Type: text/parameters\r\n"
        let response = Parse.ParseResponse(buffer);
        assert.ok(response);
        assert.ok(response.protocol === Protocol.WEBRTSP_0_2);
        assert.ok(response.statusCode === 200);
        assert.ok(response.reasonPhrase === "OK");
        assert.ok(response.cseq === 9);
        assert.ok(response.headerFields.size == 1);
        assert.ok(response.headerFields.has("content-type"));
        assert.strictEqual(response.headerFields.get("content-type"), "text/parameters")
        assert.ok(!response.body);
    });
});