import { GlCanvas } from './gl-canvas.js'; import { HLS, video_encoder_codec, videoBitsPerSecond } from './hls.js'; import shader from './example-shader.js'; import { supported_video_encoder_configs, max_video_encoder_config, } from './resolution.js'; const target_frame_rate = 30; const ingestion_url_el = document.getElementById('ingestion-url'); ingestion_url_el.value = localStorage.getItem('streamana-example-ingestion-url'); const go_live_el = document.getElementById('go-live'); go_live_el.disabled = false; go_live_el.addEventListener('click', function () { if (this.checked) { start(); } else { stop(); } }); let canvas_el = document.getElementById('canvas'); const canvas_el_parent = canvas_el.parentNode; const canvas_proto = canvas_el.cloneNode(); const waiting_el = document.getElementById('waiting'); const error_alert_el = document.getElementById('error-alert'); const error_alert_el_parent = error_alert_el.parentNode; const error_alert_el_nextSibling = error_alert_el.nextSibling; error_alert_el_parent.removeChild(error_alert_el); const ffmpeg_lib_url_el = document.getElementById('ffmpeg-lib-url'); const initial_ffmpeg_lib_url = (localStorage.getItem('streamana-ffmpeg-lib-url') || '').trim(); if (initial_ffmpeg_lib_url) { ffmpeg_lib_url_el.value = initial_ffmpeg_lib_url; } ffmpeg_lib_url_el.addEventListener('input', function () { localStorage.setItem('streamana-ffmpeg-lib-url', this.value); }); const zoom_video_el = document.getElementById('zoom-video'); zoom_video_el.checked = !!localStorage.getItem('streamana-zoom-video'); zoom_video_el.addEventListener('input', function () { localStorage.setItem('streamana-zoom-video', this.checked ? 'true' : ''); }); const lock_portrait_el = document.getElementById('lock-portrait'); lock_portrait_el.checked = !!localStorage.getItem('streamana-lock-portrait'); lock_portrait_el.addEventListener('input', function () { localStorage.setItem('streamana-lock-portrait', this.checked ? 'true' : ''); }); const greyscale_el = document.getElementById('greyscale'); greyscale_el.checked = !!localStorage.getItem('streamana-greyscale'); greyscale_el.addEventListener('input', function () { localStorage.setItem('streamana-greyscale', this.checked ? 'true' : ''); }); let facing_mode = localStorage.getItem('streamana-facing-mode') || 'user'; const reset_audio_el = document.getElementById('reset-audio'); reset_audio_el.checked = !!localStorage.getItem('streamana-reset-audio'); reset_audio_el.addEventListener('change', function () { localStorage.setItem('streamana-reset-audio', this.checked ? 'true' : ''); }); function collapse_nav() { const collapse = bootstrap.Collapse.getInstance(document.getElementById('navbarToggleExternalContent')); if (collapse) { collapse.hide(); } } document.body.addEventListener('click', function (ev) { if ((ev.target === document.body) || (ev.target === canvas_el_parent) || (ev.target.parentNode === canvas_el_parent)) { collapse_nav(); } }); const mic_el = document.getElementById('mic'); const mic_icon_el = document.getElementById('mic-icon'); if (!!localStorage.getItem('streamana-mic-on')) { mic_icon_el.classList.remove('off'); } mic_el.addEventListener('click', function () { mic_icon_el.classList.toggle('off'); }); function mic_save() { localStorage.setItem('streamana-mic-on', mic_icon_el.classList.contains('off') ? '' : 'true'); } mic_el.addEventListener('click', mic_save); const camera_el = document.getElementById('camera'); const camera_icon_el = document.getElementById('camera-icon'); if (!!localStorage.getItem('streamana-camera-on')) { camera_icon_el.classList.remove('off'); } camera_el.addEventListener('click', function () { camera_icon_el.classList.toggle('off'); }); function camera_save() { localStorage.setItem('streamana-camera-on', camera_icon_el.classList.contains('off') ? '' : 'true'); } camera_el.addEventListener('click', camera_save); const camera_swap_el = document.getElementById('camera-swap'); let video_encoder_config; let preferred_resolution = localStorage.getItem('streamana-resolution'); if (preferred_resolution) { video_encoder_config = await max_video_encoder_config({ ...JSON.parse(preferred_resolution), codec: video_encoder_codec, bitrate: videoBitsPerSecond }); } if (!video_encoder_config) { video_encoder_config = await max_video_encoder_config({ width: 1280, height: 720, ratio: 16/9, codec: video_encoder_codec, bitrate: videoBitsPerSecond }); } const resolution_el = document.getElementById('resolution'); const video_encoder_configs = new Map(); for (let config of (await supported_video_encoder_configs({ codec: video_encoder_codec, bitrate: videoBitsPerSecond })).filter(c => c.ratio >= 1)) { const option = document.createElement('option'); option.innerHTML = `${config.width}x${config.height} — ${config.label}`; option.selected = config.label === video_encoder_config.label; resolution_el.appendChild(option); video_encoder_configs.set(option.innerText, config); } resolution_el.addEventListener('change', function (ev) { video_encoder_config = video_encoder_configs.get(this.value); localStorage.setItem('streamana-resolution', JSON.stringify({ width: video_encoder_config.width, height: video_encoder_config.height, ratio: video_encoder_config.ratio })); }); let hls; async function start() { const ingestion_url = ingestion_url_el.value.trim(); if (!ingestion_url) { go_live_el.checked = false; return; } localStorage.setItem('streamana-example-ingestion-url', ingestion_url); const ffmpeg_lib_url = ffmpeg_lib_url_el.value.trim() || ffmpeg_lib_url_el.placeholder.trim(); go_live_el.disabled = true; ingestion_url_el.disabled = true; ingestion_url_el.parentNode.classList.add('d-none'); ffmpeg_lib_url_el.disabled = true; lock_portrait_el.disabled = true; zoom_video_el.disabled = true; reset_audio_el.disabled = true; resolution_el.disabled = true; waiting_el.classList.remove('d-none'); mic_el.removeEventListener('click', mic_save); camera_el.removeEventListener('click', camera_save); collapse_nav(); canvas_el_parent.removeChild(canvas_el); canvas_el = canvas_proto.cloneNode(); canvas_el.classList.add('invisible'); canvas_el_parent.appendChild(canvas_el); if (error_alert_el.parentNode) { error_alert_el_parent.removeChild(error_alert_el); } // get aspect ratio of encoder console.log(`encoder resolution: ${video_encoder_config.width}x${video_encoder_config.height}`); const ar_encoder = video_encoder_config.ratio; const ar_encoder_inv = 1/ar_encoder; const zoom_video = zoom_video_el.checked; const lock_portrait = /*screen.orientation.type.startsWith('portrait') &&*/ lock_portrait_el.checked; let video_el, video_track, silence, audio_source, audio_dest, gl_canvas, canvas_stream, done = false; function cleanup(err) { if (err) { console.error(err); } if (done) { return; } done = true; mic_el.removeEventListener('click', mic_toggle); if (!!localStorage.getItem('streamana-mic-on')) { mic_icon_el.classList.remove('off'); } else { mic_icon_el.classList.add('off'); } mic_el.addEventListener('click', mic_save); camera_el.removeEventListener('click', camera_toggle); if (!!localStorage.getItem('streamana-camera-on')) { camera_icon_el.classList.remove('off'); } else { camera_icon_el.classList.add('off'); } camera_el.addEventListener('click', camera_save); greyscale_el.removeEventListener('input', greyscale); camera_swap_el.classList.add('d-none'); camera_swap_el.removeEventListener('click', about_face); canvas_el_parent.classList.add('mx-auto'); if (lock_portrait) { screen.orientation.unlock(); if (document.fullscreenElement) { document.exitFullscreen(); } } if (err) { error_alert_el_parent.insertBefore(error_alert_el, error_alert_el_nextSibling); error_alert_el.classList.add('show'); } if (audio_source) { if (audio_source.mediaStream) { for (let track of audio_source.mediaStream.getAudioTracks()) { track.stop(); } } audio_source.disconnect(); } if (silence) { silence.stop(); } if (video_track) { video_track.stop(); } if (gl_canvas) { gl_canvas.destroy(); } if (canvas_stream) { for (let track of canvas_stream.getTracks()) { track.stop(); } } if (hls) { hls.end(!!err); } go_live_el.checked = false; go_live_el.disabled = false; ingestion_url_el.disabled = false; ingestion_url_el.parentNode.classList.remove('d-none'); ffmpeg_lib_url_el.disabled = false; lock_portrait_el.disabled = false; zoom_video_el.disabled = false; reset_audio_el.disabled = false; resolution_el.disabled = false; waiting_el.classList.add('d-none'); canvas_el.classList.add('d-none'); } function update() { // update the canvas if (!video_track) { gl_canvas.onLoop(); } else if ((video_el.videoWidth > 0) && (video_el.videoHeight > 0) && gl_canvas.onLoop()) { // get aspect ratio of video const ar_video = video_el.videoWidth / video_el.videoHeight; // Note: we need to use canvas_el_parent.parentNode.offsetWidth // to take into account margins let width, height; const ar_parent = canvas_el_parent.parentNode.offsetWidth / canvas_el_parent.offsetHeight; if (lock_portrait) { if (zoom_video) { if (ar_video < ar_encoder_inv) { if (ar_parent >= ar_video) { height = canvas_el_parent.offsetHeight * ar_encoder_inv; width = canvas_el_parent.offsetHeight; } else { height = canvas_el_parent.parentNode.offsetWidth / (video_encoder_config.width * ar_video / video_encoder_config.height); width = canvas_el_parent.parentNode.offsetWidth / ar_video; } } else if (ar_parent >= ar_video) { height = canvas_el_parent.offsetHeight * ar_video; width = canvas_el_parent.offsetHeight / (video_encoder_config.height / ar_video / video_encoder_config.width); } else { height = canvas_el_parent.parentNode.offsetWidth; width = canvas_el_parent.parentNode.offsetWidth / ar_encoder_inv; } } else if (ar_parent >= ar_encoder_inv) { height = canvas_el_parent.offsetHeight * ar_encoder_inv; width = canvas_el_parent.offsetHeight; } else { height = canvas_el_parent.parentNode.offsetWidth; width = canvas_el_parent.parentNode.offsetWidth / ar_encoder_inv; } } else if (zoom_video) { if (ar_video < ar_encoder) { if (ar_parent >= ar_video) { width = canvas_el_parent.offsetHeight * ar_encoder; height = canvas_el_parent.offsetHeight; } else { width = canvas_el_parent.parentNode.offsetWidth / (video_encoder_config.height * ar_video / video_encoder_config.width); height = canvas_el_parent.parentNode.offsetWidth / ar_video; } } else if (ar_parent >= ar_video) { width = canvas_el_parent.offsetHeight * ar_video; height = canvas_el_parent.offsetHeight / (video_encoder_config.width / ar_video / video_encoder_config.height); } else { width = canvas_el_parent.parentNode.offsetWidth; height = canvas_el_parent.parentNode.offsetWidth / ar_encoder; } } else if (ar_parent >= ar_encoder) { width = canvas_el_parent.offsetHeight * ar_encoder; height = canvas_el_parent.offsetHeight; } else { width = canvas_el_parent.parentNode.offsetWidth; height = canvas_el_parent.parentNode.offsetWidth / ar_encoder; } canvas_el.style.width = `${width}px`; canvas_el.style.height = `${height}px`; // TODO: // performance on mobile // webcodecs performance on PC is less fps than MediaRecorder // windows, iOS, find a mac to test } } async function start_media(requested_facing_mode) { mic_el.removeEventListener('click', mic_toggle); camera_el.removeEventListener('click', camera_toggle); camera_swap_el.removeEventListener('click', about_face); async function finish() { await hls.start(); mic_el.addEventListener('click', mic_toggle); camera_el.addEventListener('click', camera_toggle); camera_swap_el.addEventListener('click', about_face); } const need_audio = (audio_source === silence) && !mic_icon_el.classList.contains('off'); const need_video = !video_track && !camera_icon_el.classList.contains('off'); if (!need_audio && !need_video) { return await finish(); } const camera_video_constraints = { width: video_encoder_config.width, height: video_encoder_config.height, frameRate: { ideal: target_frame_rate, max: target_frame_rate }, facingMode: requested_facing_mode }; let media_stream; try { media_stream = await navigator.mediaDevices.getUserMedia({ audio: need_audio, video: need_video ? camera_video_constraints : false }); } catch (ex) { if (!need_audio) { throw ex; } // retry in case audio isn't available console.warn("Failed to get user media, retrying without audio"); media_stream = await navigator.mediaDevices.getUserMedia({ audio: false, video: camera_video_constraints }); } // wait for stream to load (must come after gl_canvas.setTexture() since it // registers a loadeddata handler which then registers a play handler) video_el.addEventListener('loadeddata', async function () { try { console.log(`video resolution: ${this.videoWidth}x${this.videoHeight}`); // start the stream this.play(); if (need_video) { const video_tracks = media_stream.getVideoTracks(); if (video_tracks.length > 0) { video_track = video_tracks[0]; facing_mode = video_track.getSettings().facingMode || 'user'; localStorage.setItem('streamana-facing-mode', facing_mode); gl_canvas.setUniform('u_active', true); } else { console.warn("No video present"); } } if (need_audio) { if (media_stream.getAudioTracks().length > 0) { audio_source.disconnect(); audio_source = audio_dest.context.createMediaStreamSource(media_stream); audio_source.connect(audio_dest); } else { console.warn("No audio present, using silence"); } } await finish(); } catch (ex) { cleanup(ex); } }, { once: true }); // pass the stream from the camera to the video so it can render the frames video_el.srcObject = media_stream; } function stop_camera() { if (video_track) { video_track.stop(); video_track = null; gl_canvas.setUniform('u_active', false); } } function stop_mic() { if (audio_source !== silence) { if (audio_source.mediaStream) { for (let track of audio_source.mediaStream.getAudioTracks()) { track.stop(); } } audio_source.disconnect(); audio_source = silence; audio_source.connect(audio_dest); } } function about_face() { stop_camera(); if (reset_audio_el.checked) { stop_mic(); } start_media(facing_mode == 'user' ? 'environment' : 'user'); } function camera_toggle() { if (camera_icon_el.classList.contains('off')) { stop_camera(); } start_media(facing_mode); } function mic_toggle() { if (mic_icon_el.classList.contains('off')) { stop_mic(); } start_media(facing_mode); } function greyscale() { gl_canvas.setUniform('u_greyscale', this.checked); } try { // create video element which will be used for grabbing the frames to // write to a canvas so we can apply webgl shaders // also used to get the native video dimensions video_el = document.createElement('video'); video_el.muted = true; video_el.playsInline = true; // Safari on iOS requires us to play() in the click handler and doesn't // track async calls. So we play a blank video first. After that, the video // element is blessed for script-driven playback. video_el.src = 'empty.mp4'; await video_el.play(); canvas_el.addEventListener('webglcontextlost', cleanup); // set canvas dimensions to same as encoder so its gets all the output canvas_el.width = video_encoder_config.width; canvas_el.height = video_encoder_config.height; // use glsl-canvas to make managing webgl stuff easier gl_canvas = new GlCanvas(canvas_el, { fragmentString: shader }); gl_canvas.on('error', cleanup); // tell canvas to use frames from video gl_canvas.setTexture('u_texture', video_el); // tell shader whether to greyscale gl_canvas.setUniform('u_greyscale', greyscale_el.checked); greyscale_el.addEventListener('input', greyscale); // tell shader camera hasn't started gl_canvas.setUniform('u_active', false); // check whether we're locking portrait mode or zooming (display without bars) if (lock_portrait) { // rotate the canvas canvas_el.classList.add('rotate'); canvas_el.classList.remove('mw-100', 'mh-100'); canvas_el_parent.classList.remove('mx-auto'); // lock to portrait mode try { await screen.orientation.lock('portrait'); } catch (ex) { if (ex.name === 'SecurityError') { if (!document.fullscreenElement) { await document.documentElement.requestFullscreen(); } await screen.orientation.lock('portrait'); } else if (ex.name !== 'NotSupportedError') { throw ex; } } } else if (zoom_video) { // we're going to remove the bars for local display only canvas_el.classList.add('zoom'); canvas_el.classList.remove('mw-100', 'mh-100'); canvas_el_parent.classList.remove('mx-auto'); } // if we're locked to portrait mode, tell the shader to rotate the video gl_canvas.setUniform('u_rotate', lock_portrait); // capture video from the canvas // Note: Safari on iOS doesn't get any data, might be related to // https://bugs.webkit.org/show_bug.cgi?id=181663 //const frame_rate = video_settings.frameRate; canvas_stream = canvas_el.captureStream(target_frame_rate); // add audio to canvas stream audio_dest = new AudioContext().createMediaStreamDestination(); canvas_stream.addTrack(audio_dest.stream.getAudioTracks()[0]); // Note: createBufferSource is supposed to be used to create silence // but it doesn't keep the page active if it's hidden. // Use createConstantSource instead. Since this is a constant value, // it won't generate something that changes (such as a sine or sawtooth // waveform) and so is inaudible. This passes the browser's silence // detection, which must just check for zero values. // Note: WebAudio destination stream output is bugged on Safari: // https://bugs.webkit.org/show_bug.cgi?id=173863 // https://bugs.webkit.org/show_bug.cgi?id=198284 //const silence = audio_dest.context.createBufferSource(); silence = audio_dest.context.createConstantSource(); silence.start(); audio_source = silence; audio_source.connect(audio_dest); // HLS from the canvas stream to the ingestion URL hls = new HLS(canvas_stream, ingestion_url, ffmpeg_lib_url, target_frame_rate, lock_portrait); hls.addEventListener('run', () => console.log('HLS running')); hls.addEventListener('exit', ev => { const msg = `HLS exited with status ${ev.detail.code}`; if (ev.detail.code === 0) { console.log(msg); cleanup(); } else { cleanup(msg); } }); hls.addEventListener('error', cleanup); hls.addEventListener('start', function () { if (done) { this.end(true); } waiting_el.classList.add('d-none'); camera_swap_el.classList.remove('d-none'); canvas_el.classList.remove('invisible'); go_live_el.disabled = false; update(); }); hls.addEventListener('update', update); await start_media(facing_mode); } catch (ex) { return cleanup(ex); } } function stop() { go_live_el.disabled = true; hls.end(); }