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
|
imports.gi.versions.GLib = '2.0';
imports.gi.versions.GObject = '2.0';
imports.gi.versions.Gio = '2.0';
imports.gi.versions.Gdk = '3.0';
imports.gi.versions.Gtk = '3.0';
imports.gi.versions.Clutter = '1.0';
imports.gi.versions.Gst = '0.10';
imports.gi.versions.GstBase = '0.10';
imports.gi.versions.GstVideo = '0.10';
const Lang = imports.lang;
const Mainloop = imports.mainloop;
const GLib = imports.gi.GLib;
const GObject = imports.gi.GObject;
const Gio = imports.gi.Gio;
const Gdk = imports.gi.Gdk;
const Gtk = imports.gi.Gtk;
const Clutter = imports.gi.Clutter;
const ClutterGst = imports.gi.ClutterGst;
const Gst = imports.gi.Gst;
const GstBase = imports.gi.GstBase;
const GstApp = imports.gi.GstApp;
const GstVideo = imports.gi.GstVideo;
const KEYFRAME_INTERVAL = 64;
function IcecastClient() {
this._init.apply(this, arguments);
}
IcecastClient.prototype = {
_init: function(feeds) {
this._feeds = feeds;
this._pipeline = Gst.Pipeline.new('stream');
this._bus = this._pipeline.get_bus();
this._bus.add_signal_watch();
this._bus.connect('message::eos',
Lang.bind(this, this._onEndOfStream));
this._bus.connect('message::error',
Lang.bind(this, this._onErrorMessage));
_setupPipeline();
},
_findInputSource: function() {
let cameraSource = Gst.ElementFactory.make('camerabin',
'camera-source');
if (!cameraSource) {
return null;
}
cameraSource.video_capture_height = 0;
cameraSource.video_capture_width = 0;
return cameraSource;
},
_setupPipeline: function() {
this._inputSource = _findInputSource();
if (!this._inputSource)
throw new Error("could not find input source for stream");
this._pipeline.add(this._inputSource);
},
_onEndOfStream: function(bus, message) {
},
_onErrorMessage: function(bus, message) {
},
start: function() {
},
stop: function() {
}
}
|
