diff --git a/app.py b/app.py index 10c0785..099f4c8 100644 --- a/app.py +++ b/app.py @@ -111,7 +111,18 @@ def get_file(): files.append(i.name) return jsonify(files) +@app.route('/api/recreate/room', methods=['GET']) +def create_room(): + rms = Room.objects.all() + for i in rms: + jan = Janus(os.environ.get('JANUS_URL'), app.config['JANUS_ADMIN_KEY']) + jan.connect() + room_id = jan.create_room(name=i.room_name, video_codec="vp8", audio_codec="opus", + publisher_count=int(16), bitrate=128*1000, data=False) + i.room_id = room_id + i.save() + return "ok" @app.route('/api/create/room', methods=['POST']) @jwt_required diff --git a/forward_stream.py b/forward_stream.py index bb6e7f3..899df56 100644 --- a/forward_stream.py +++ b/forward_stream.py @@ -121,6 +121,8 @@ async def subscribe(session, room, feed): ) # apply offer + print(response["jsep"]["sdp"]) + print(response["jsep"]["type"]) await pc.setRemoteDescription( RTCSessionDescription( sdp=response["jsep"]["sdp"], type=response["jsep"]["type"] @@ -139,6 +141,7 @@ async def subscribe(session, room, feed): }, } ) + print(pc.localDescription.sdp) print("recorder start") await recorder.start()