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
147
|
// Copyright (C) 2018 Sebastian Dröge <sebastian@centricular.com>
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Library General Public
// License as published by the Free Software Foundation; either
// version 2 of the License, or (at your option) any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
// Library General Public License for more details.
//
// You should have received a copy of the GNU Library General Public
// License along with this library; if not, write to the
// Free Software Foundation, Inc., 51 Franklin Street, Suite 500,
// Boston, MA 02110-1335, USA.
use gst::glib;
use gst::prelude::*;
use pretty_assertions::assert_eq;
fn init() {
use std::sync::Once;
static INIT: Once = Once::new();
INIT.call_once(|| {
gst::init().unwrap();
gstrsclosedcaption::plugin_register_static().expect("mccenc test");
});
}
/// Encode a single CDP packet and compare the output
#[test]
fn test_encode() {
init();
let input = [
0x96, 0x69, 0x52, 0x4f, 0x67, 0x00, 0x00, 0x72, 0xf4, 0xfc, 0x80, 0x80, 0xfd, 0x80, 0x80,
0xff, 0x02, 0x22, 0xfe, 0x8c, 0xff, 0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00,
0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00,
0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00,
0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00, 0xfa, 0x00, 0x00, 0x73, 0x91, 0x81, 0x65, 0x6e, 0x67,
0x81, 0x7f, 0xff, 0x74, 0x00, 0x00, 0x1c,
];
let expected_output = b"File Format=MacCaption_MCC V1.0\r\n\
\r\n\
///////////////////////////////////////////////////////////////////////////////////\r\n\
// Computer Prompting and Captioning Company\r\n\
// Ancillary Data Packet Transfer File\r\n\
//\r\n\
// Permission to generate this format is granted provided that\r\n\
// 1. This ANC Transfer file format is used on an as-is basis and no warranty is given, and\r\n\
// 2. This entire descriptive information text is included in a generated .mcc file.\r\n\
//\r\n\
// General file format:\r\n\
// HH:MM:SS:FF(tab)[Hexadecimal ANC data in groups of 2 characters]\r\n\
// Hexadecimal data starts with the Ancillary Data Packet DID (Data ID defined in S291M)\r\n\
// and concludes with the Check Sum following the User Data Words.\r\n\
// Each time code line must contain at most one complete ancillary data packet.\r\n\
// To transfer additional ANC Data successive lines may contain identical time code.\r\n\
// Time Code Rate=[24, 25, 30, 30DF, 50, 60]\r\n\
//\r\n\
// ANC data bytes may be represented by one ASCII character according to the following schema:\r\n\
// G FAh 00h 00h\r\n\
// H 2 x (FAh 00h 00h)\r\n\
// I 3 x (FAh 00h 00h)\r\n\
// J 4 x (FAh 00h 00h)\r\n\
// K 5 x (FAh 00h 00h)\r\n\
// L 6 x (FAh 00h 00h)\r\n\
// M 7 x (FAh 00h 00h)\r\n\
// N 8 x (FAh 00h 00h)\r\n\
// O 9 x (FAh 00h 00h)\r\n\
// P FBh 80h 80h\r\n\
// Q FCh 80h 80h\r\n\
// R FDh 80h 80h\r\n\
// S 96h 69h\r\n\
// T 61h 01h\r\n\
// U E1h 00h 00h 00h\r\n\
// Z 00h\r\n\
//\r\n\
///////////////////////////////////////////////////////////////////////////////////\r\n\
\r\n\
UUID=14720C04-857D-40E2-86FC-F080DE44CE74\r\n\
Creation Program=GStreamer MCC Encoder 0.7.0\r\n\
Creation Date=Thursday, December 27, 2018\r\n\
Creation Time=17:34:47\r\n\
Time Code Rate=30DF\r\n\
\r\n\
11:12:13;14 T52S524F67ZZ72F4QRFF0222FE8CFFOM739181656E67817FFF74ZZ1CZ\r\n";
let mut h = gst_check::Harness::new("mccenc");
{
let enc = h.element().expect("could not create encoder");
enc.set_property("uuid", &"14720C04-857D-40E2-86FC-F080DE44CE74")
.unwrap();
enc.set_property(
"creation-date",
&glib::DateTime::new_utc(2018, 12, 27, 17, 34, 47.0).unwrap(),
)
.unwrap();
}
h.set_src_caps_str(
"closedcaption/x-cea-708, format=(string)cdp, framerate=(fraction)30000/1001",
);
let tc = gst_video::ValidVideoTimeCode::new(
gst::Fraction::new(30000, 1001),
None,
gst_video::VideoTimeCodeFlags::DROP_FRAME,
11,
12,
13,
14,
0,
)
.unwrap();
let buf = {
let mut buf = gst::Buffer::from_mut_slice(Vec::from(input));
let buf_ref = buf.get_mut().unwrap();
gst_video::VideoTimeCodeMeta::add(buf_ref, &tc);
buf_ref.set_pts(gst::ClockTime::from_seconds(0));
buf
};
assert_eq!(h.push(buf), Ok(gst::FlowSuccess::Ok));
h.push_event(gst::event::Eos::new());
let buf = h.pull().expect("Couldn't pull buffer");
let timecode = buf
.meta::<gst_video::VideoTimeCodeMeta>()
.expect("No timecode for buffer")
.tc();
assert_eq!(timecode, tc);
let pts = buf.pts().unwrap();
assert_eq!(pts, gst::ClockTime::ZERO);
let map = buf.map_readable().expect("Couldn't map buffer readable");
assert_eq!(
std::str::from_utf8(map.as_ref()),
std::str::from_utf8(expected_output.as_ref())
);
}
|
