type = station['type']
conf = station['conf']
port = station['port']
+ conf = get_conf_dict(station['conf'])
+
server_type = station['server_type']
server, c = StreamingServer.objects.get_or_create(host=status.ip, port=port, type=server_type)
+
station = Station(conference=conference, public_id=uuid)
station.setup(conf)
try:
except:
continue
station.save()
- stream = LiveStream(conference=conference, server=server,
- stream_type=type, streaming=True)
- stream.save()
- if server_type == 'stream-m':
- try:
- self.snapshot('http://localhost:8080/snapshot/monitor', station.output_dir)
- except:
- pass
+
+ video_ids = []
+ for conf_station in conf['deefuzzer']['station']:
+ if 'id' in conf_station:
+ video_ids.append(conf_station['id'])
+ if not video_ids:
+ video_ids = [None]
+
+ for video_id in video_ids:
+ stream = LiveStream(conference=conference, server=server,
+ stream_type=type, streaming=True, video_id=video_id)
+ stream.save()
+
if conference.streaming:
try:
live_message(self.conference)