mirror of
https://github.com/suitenumerique/meet.git
synced 2026-09-04 06:35:38 +00:00
Compare commits
13 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 98d0b48015 | |||
| 7412c02341 | |||
| f2b3af6633 | |||
| 2aafd93b46 | |||
| 87931f50cd | |||
| 35cb114160 | |||
| c783fefa57 | |||
| 09a0238936 | |||
| 03870ad1fa | |||
| f37992a089 | |||
| c7c6d20b91 | |||
| 2a71e5b836 | |||
| 089d016d12 |
@@ -8,6 +8,28 @@ const IGNORED_EXCEPTION_PATTERNS = [
|
||||
// the close reason is already logged by the SDK.
|
||||
// See: https://github.com/livekit/client-sdk-js/issues/2062
|
||||
/^Event captured as exception with keys: isTrusted$/,
|
||||
// MediaPipe's WASM writes its native logs to stderr, which Emscripten
|
||||
// routes to console.error, which PostHog's console capture then promotes
|
||||
// to an $exception — even though nothing was thrown. Two flavors:
|
||||
//
|
||||
// 1. "INFO: ..." lines are purely informational. In particular
|
||||
// "INFO: Created TensorFlow Lite XNNPACK delegate for CPU." is a
|
||||
// SUCCESS message: TFLite prints it when it lazily initializes CPU
|
||||
// inference on the first segmented frame. It fires on every effects
|
||||
// init, on every browser and delegate (the GPU delegate still
|
||||
// instantiates the CPU/XNNPACK delegate for non-delegated ops), so it
|
||||
// was our single noisiest "error" while carrying zero signal.
|
||||
/^INFO: /,
|
||||
//
|
||||
// 2. absl-formatted log lines, e.g.
|
||||
// "E0901 19:21:45.443000 1880752 gl_graph_runner_internal.cc:260]
|
||||
// StartGraph failed: ..."
|
||||
// (severity letter E/W/I/F + MMDD + timestamp). These are the stderr
|
||||
// *copies* of failures that MediaPipe also raises as real JS
|
||||
// exceptions, which we already capture via reportError / thrown
|
||||
// errors. Dropping them de-duplicates each incident (previously
|
||||
// counted 2-3x) without losing the actual error report.
|
||||
/^[EWIF]\d{4} \d{2}:\d{2}:\d{2}\./,
|
||||
]
|
||||
|
||||
const shouldIgnoreException = (value: unknown): boolean =>
|
||||
|
||||
+305
-111
@@ -17,7 +17,7 @@ import {
|
||||
type ProcessorType,
|
||||
MEDIAPIPE_PATH_WASM,
|
||||
} from '.'
|
||||
import { captureEvent } from '@/features/analytics/telemetry.ts'
|
||||
import { captureEvent, reportError } from '@/features/analytics/telemetry'
|
||||
|
||||
const PROCESSING_WIDTH = 256
|
||||
const PROCESSING_HEIGHT = 144
|
||||
@@ -26,6 +26,40 @@ const SEGMENTATION_MASK_CANVAS_ID = 'background-blur-local-segmentation'
|
||||
const BLUR_CANVAS_ID = 'background-blur-local'
|
||||
|
||||
const DEFAULT_BLUR = '10'
|
||||
const CONCEALING_BLUR = '25'
|
||||
const FRAME_INTERVAL_MS = 1000 / 30
|
||||
|
||||
// After this many consecutive failed frames, stop segmenting and fall back to
|
||||
// publishing a fully blurred frame: the user keeps a live camera instead of a
|
||||
// frozen one, without ever exposing the surroundings they chose to conceal.
|
||||
const MAX_CONSECUTIVE_ERRORS = 5
|
||||
|
||||
let webgl2Supported: boolean | undefined
|
||||
|
||||
/**
|
||||
* MediaPipe's ImageSegmenter requires a WebGL2 context on the web even with
|
||||
* `delegate: 'CPU'` (only inference runs on CPU; the mask post-processing in
|
||||
* TensorsToSegmentationCalculator is GL-based). Without this check, machines
|
||||
* with WebGL disabled or blocklisted fail at StartGraph with
|
||||
* `emscripten_webgl_create_context() returned error 0`.
|
||||
*
|
||||
* The result is cached and the probe context is explicitly released so that
|
||||
* repeated support checks do not count against the browser's limit on live
|
||||
* WebGL contexts.
|
||||
*/
|
||||
const isWebGL2Supported = () => {
|
||||
if (webgl2Supported === undefined) {
|
||||
try {
|
||||
const canvas = document.createElement('canvas')
|
||||
const gl = canvas.getContext('webgl2')
|
||||
webgl2Supported = !!gl
|
||||
gl?.getExtension('WEBGL_lose_context')?.loseContext()
|
||||
} catch {
|
||||
webgl2Supported = false
|
||||
}
|
||||
}
|
||||
return webgl2Supported
|
||||
}
|
||||
|
||||
/**
|
||||
* This implementation of video blurring is made to be run on CPU for browser that are
|
||||
@@ -42,14 +76,12 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
source?: MediaStreamTrack
|
||||
sourceSettings?: MediaTrackSettings
|
||||
videoElement?: HTMLVideoElement
|
||||
videoElementLoaded?: boolean
|
||||
|
||||
// Canvas containing the video processing result, of which we extract as stream.
|
||||
outputCanvas?: HTMLCanvasElement
|
||||
outputCanvasCtx?: CanvasRenderingContext2D
|
||||
|
||||
imageSegmenter?: ImageSegmenter
|
||||
imageSegmenterResult?: ImageSegmenterResult
|
||||
|
||||
// Canvas used for resizing video source and projecting mask.
|
||||
segmentationMaskCanvas?: HTMLCanvasElement
|
||||
@@ -66,6 +98,13 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
type: ProcessorType
|
||||
virtualBackgroundImage?: HTMLImageElement
|
||||
|
||||
private virtualBackgroundImagePath?: string
|
||||
private destroyed = false
|
||||
private degraded = false
|
||||
private consecutiveErrors = 0
|
||||
private processing?: Promise<void>
|
||||
private onVideoLoaded?: () => void
|
||||
|
||||
constructor(opts: ProcessorConfig) {
|
||||
this.name = 'blur'
|
||||
this.options = opts
|
||||
@@ -73,7 +112,10 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
}
|
||||
|
||||
static get isSupported() {
|
||||
return navigator.userAgent.toLowerCase().includes('firefox')
|
||||
return (
|
||||
navigator.userAgent.toLowerCase().includes('firefox') &&
|
||||
isWebGL2Supported()
|
||||
)
|
||||
}
|
||||
|
||||
async init(opts: ProcessorOptions<Track.Kind>) {
|
||||
@@ -81,6 +123,10 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
throw new Error('Element is required for processing')
|
||||
}
|
||||
|
||||
this.destroyed = false
|
||||
this.degraded = false
|
||||
this.consecutiveErrors = 0
|
||||
|
||||
this.source = opts.track as MediaStreamTrack
|
||||
this.sourceSettings = this.source!.getSettings()
|
||||
this.videoElement = opts.element as HTMLVideoElement
|
||||
@@ -97,26 +143,56 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
this.processedTrack = tracks[0]
|
||||
|
||||
this.segmentationMask = new ImageData(PROCESSING_WIDTH, PROCESSING_HEIGHT)
|
||||
|
||||
const t0 = performance.now()
|
||||
await this.initSegmenter()
|
||||
const segmenterInitMs = Math.round(performance.now() - t0)
|
||||
|
||||
this._initWorker()
|
||||
|
||||
captureEvent('firefox-blurring-init', {})
|
||||
captureEvent('legacy-background-processor', {
|
||||
effect_type: this.options.type,
|
||||
hw_concurrency: navigator.hardwareConcurrency,
|
||||
video_width: this.videoElement?.videoWidth,
|
||||
video_height: this.videoElement?.videoHeight,
|
||||
segmenter_init_ms: segmenterInitMs,
|
||||
})
|
||||
}
|
||||
|
||||
_initVirtualBackgroundImage() {
|
||||
if (this.options.type !== 'virtual') {
|
||||
if (this.options.type !== 'virtual' || !this.options.imagePath) {
|
||||
return
|
||||
}
|
||||
|
||||
const needsUpdate =
|
||||
this.options.imagePath &&
|
||||
if (
|
||||
this.virtualBackgroundImage &&
|
||||
this.virtualBackgroundImage.src !== this.options.imagePath
|
||||
if (this.options.imagePath || needsUpdate) {
|
||||
this.virtualBackgroundImage = document.createElement('img')
|
||||
this.virtualBackgroundImage.crossOrigin = 'anonymous'
|
||||
this.virtualBackgroundImage.src = this.options.imagePath!
|
||||
this.virtualBackgroundImagePath === this.options.imagePath
|
||||
) {
|
||||
return
|
||||
}
|
||||
|
||||
const image = document.createElement('img')
|
||||
image.crossOrigin = 'anonymous'
|
||||
image.src = this.options.imagePath
|
||||
// Surface load failures once instead of letting drawImage throw on a
|
||||
// broken image inside the processing loop.
|
||||
image.decode().catch((error) => {
|
||||
reportError('effects_processor_failure', error, {
|
||||
context: 'Failed to load virtual background image',
|
||||
image_path:
|
||||
this.options.type === 'virtual' ? this.options.imagePath : undefined,
|
||||
})
|
||||
})
|
||||
this.virtualBackgroundImage = image
|
||||
this.virtualBackgroundImagePath = this.options.imagePath
|
||||
}
|
||||
|
||||
_isVirtualBackgroundImageReady() {
|
||||
return (
|
||||
!!this.virtualBackgroundImage &&
|
||||
this.virtualBackgroundImage.complete &&
|
||||
this.virtualBackgroundImage.naturalWidth > 0
|
||||
)
|
||||
}
|
||||
|
||||
async update(opts: ProcessorConfig): Promise<void> {
|
||||
@@ -129,26 +205,26 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
name: 'Blurring',
|
||||
})
|
||||
this.timerWorker.onmessage = (data) => this.onTimerMessage(data)
|
||||
// When hiding camera then showing it again, the onloadeddata callback is not fired again.
|
||||
if (this.videoElementLoaded) {
|
||||
this.timerWorker!.postMessage({
|
||||
id: SET_TIMEOUT,
|
||||
timeMs: 1000 / 30,
|
||||
})
|
||||
|
||||
const startLoop = () => {
|
||||
this.onVideoLoaded = undefined
|
||||
this._syncOutputCanvasSize()
|
||||
this._scheduleNextFrame()
|
||||
}
|
||||
|
||||
if (this.videoElement!.readyState >= HTMLMediaElement.HAVE_CURRENT_DATA) {
|
||||
startLoop()
|
||||
} else {
|
||||
this.videoElement!.onloadeddata = () => {
|
||||
this.videoElementLoaded = true
|
||||
this.timerWorker!.postMessage({
|
||||
id: SET_TIMEOUT,
|
||||
timeMs: 1000 / 30,
|
||||
})
|
||||
}
|
||||
this.onVideoLoaded = startLoop
|
||||
this.videoElement!.addEventListener('loadeddata', this.onVideoLoaded, {
|
||||
once: true,
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
onTimerMessage(response: { data: { id: number } }) {
|
||||
if (response.data.id === TIMEOUT_TICK) {
|
||||
this.process()
|
||||
this.processing = this.process()
|
||||
}
|
||||
}
|
||||
|
||||
@@ -194,30 +270,47 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
*/
|
||||
async segment() {
|
||||
const startTimeMs = performance.now()
|
||||
return new Promise<void>((resolve) => {
|
||||
this.imageSegmenter!.segmentForVideo(
|
||||
this.sourceImageData!,
|
||||
startTimeMs,
|
||||
(result: ImageSegmenterResult) => {
|
||||
this.imageSegmenterResult = result
|
||||
resolve()
|
||||
}
|
||||
)
|
||||
return new Promise<void>((resolve, reject) => {
|
||||
try {
|
||||
this.imageSegmenter!.segmentForVideo(
|
||||
this.sourceImageData!,
|
||||
startTimeMs,
|
||||
(result: ImageSegmenterResult) => {
|
||||
try {
|
||||
// The mask is only valid for the duration of this callback:
|
||||
// MediaPipe frees the underlying WASM memory as soon as it
|
||||
// returns, so the data must be copied out synchronously here.
|
||||
this._applyMaskToAlphaChannel(result)
|
||||
resolve()
|
||||
} catch (error) {
|
||||
reject(error)
|
||||
}
|
||||
}
|
||||
)
|
||||
} catch (error) {
|
||||
reject(error)
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
/**
|
||||
* TODO: future improvement with WebGL.
|
||||
*/
|
||||
async blur() {
|
||||
if (this.options.type !== 'blur') {
|
||||
throw new Error('Blurring is only supported for blur background')
|
||||
_applyMaskToAlphaChannel(result: ImageSegmenterResult) {
|
||||
const categoryMask = result.categoryMask
|
||||
if (!categoryMask) {
|
||||
return
|
||||
}
|
||||
const mask = this.imageSegmenterResult!.categoryMask!.getAsUint8Array()
|
||||
for (let i = 0; i < mask.length; ++i) {
|
||||
this.segmentationMask!.data[i * 4 + 3] = 255 - mask[i]
|
||||
const mask = categoryMask.getAsUint8Array()
|
||||
const alpha = this.segmentationMask!.data
|
||||
const length = Math.min(mask.length, alpha.length / 4)
|
||||
for (let i = 0; i < length; ++i) {
|
||||
alpha[i * 4 + 3] = 255 - mask[i]
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Composite the segmentation mask over the output canvas: mask first, then
|
||||
* the clear body, leaving the background to be filled by the caller.
|
||||
*/
|
||||
_compositeMaskAndBody() {
|
||||
this.segmentationMaskCanvasCtx!.putImageData(this.segmentationMask!, 0, 0)
|
||||
|
||||
this.outputCanvasCtx!.globalCompositeOperation = 'copy'
|
||||
@@ -240,6 +333,16 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
this.outputCanvasCtx!.globalCompositeOperation = 'source-in'
|
||||
this.outputCanvasCtx!.filter = 'none'
|
||||
this.outputCanvasCtx!.drawImage(this.videoElement!, 0, 0)
|
||||
}
|
||||
|
||||
/**
|
||||
* TODO: future improvement with WebGL.
|
||||
*/
|
||||
async blur() {
|
||||
if (this.options.type !== 'blur') {
|
||||
throw new Error('Blurring is only supported for blur background')
|
||||
}
|
||||
this._compositeMaskAndBody()
|
||||
|
||||
// Draw blurry background.
|
||||
this.outputCanvasCtx!.globalCompositeOperation = 'destination-over'
|
||||
@@ -251,87 +354,150 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
* TODO: future improvement with WebGL.
|
||||
*/
|
||||
async drawVirtualBackground() {
|
||||
const mask = this.imageSegmenterResult!.categoryMask!.getAsUint8Array()
|
||||
for (let i = 0; i < mask.length; ++i) {
|
||||
this.segmentationMask!.data[i * 4 + 3] = 255 - mask[i]
|
||||
}
|
||||
this._compositeMaskAndBody()
|
||||
|
||||
this.segmentationMaskCanvasCtx!.putImageData(this.segmentationMask!, 0, 0)
|
||||
|
||||
this.outputCanvasCtx!.globalCompositeOperation = 'copy'
|
||||
this.outputCanvasCtx!.filter = 'blur(8px)'
|
||||
|
||||
// Put opacity mask.
|
||||
this.outputCanvasCtx!.drawImage(
|
||||
this.segmentationMaskCanvas!,
|
||||
0,
|
||||
0,
|
||||
PROCESSING_WIDTH,
|
||||
PROCESSING_HEIGHT,
|
||||
0,
|
||||
0,
|
||||
this.videoElement!.videoWidth,
|
||||
this.videoElement!.videoHeight
|
||||
)
|
||||
|
||||
// Draw clear body.
|
||||
this.outputCanvasCtx!.globalCompositeOperation = 'source-in'
|
||||
this.outputCanvasCtx!.filter = 'none'
|
||||
this.outputCanvasCtx!.drawImage(this.videoElement!, 0, 0)
|
||||
|
||||
// Draw virtual background.
|
||||
this.outputCanvasCtx!.globalCompositeOperation = 'destination-over'
|
||||
this.outputCanvasCtx!.drawImage(
|
||||
this.virtualBackgroundImage!,
|
||||
0,
|
||||
0,
|
||||
this.outputCanvas!.width,
|
||||
this.outputCanvas!.height
|
||||
)
|
||||
this.outputCanvasCtx!.filter = 'none'
|
||||
if (this._isVirtualBackgroundImageReady()) {
|
||||
// Draw virtual background.
|
||||
this.outputCanvasCtx!.drawImage(
|
||||
this.virtualBackgroundImage!,
|
||||
0,
|
||||
0,
|
||||
this.outputCanvas!.width,
|
||||
this.outputCanvas!.height
|
||||
)
|
||||
} else {
|
||||
// Image not decoded (yet, or failed to load): fill the background with
|
||||
// a heavy blur instead. Never fall back to the raw video here — the
|
||||
// user selected this effect to conceal their surroundings, so the
|
||||
// fallback must keep concealing them.
|
||||
this.outputCanvasCtx!.filter = `blur(${CONCEALING_BLUR}px)`
|
||||
this.outputCanvasCtx!.drawImage(this.videoElement!, 0, 0)
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Draw the whole frame heavily blurred (person included). Used when
|
||||
* segmentation is broken: the outgoing video keeps flowing instead of
|
||||
* freezing on a stale frame, while the surroundings the user chose to
|
||||
* conceal stay concealed. Requires no segmenter, only one filtered draw.
|
||||
*/
|
||||
_drawDegradedFrame() {
|
||||
this.outputCanvasCtx!.globalCompositeOperation = 'copy'
|
||||
this.outputCanvasCtx!.filter = `blur(${CONCEALING_BLUR}px)`
|
||||
this.outputCanvasCtx!.drawImage(this.videoElement!, 0, 0)
|
||||
this.outputCanvasCtx!.filter = 'none'
|
||||
}
|
||||
|
||||
async process() {
|
||||
await this.sizeSource()
|
||||
await this.segment()
|
||||
|
||||
if (this.options.type === 'blur') {
|
||||
await this.blur()
|
||||
} else {
|
||||
await this.drawVirtualBackground()
|
||||
if (this.destroyed) {
|
||||
return
|
||||
}
|
||||
this.timerWorker!.postMessage({
|
||||
try {
|
||||
this._syncOutputCanvasSize()
|
||||
// No decoded frame available (e.g. right after a device switch): skip
|
||||
// this tick rather than processing a 0x0 source.
|
||||
if (
|
||||
!this.videoElement ||
|
||||
this.videoElement.videoWidth === 0 ||
|
||||
this.videoElement.videoHeight === 0
|
||||
) {
|
||||
this._scheduleNextFrame()
|
||||
return
|
||||
}
|
||||
|
||||
if (this.degraded) {
|
||||
this._drawDegradedFrame()
|
||||
this._scheduleNextFrame()
|
||||
return
|
||||
}
|
||||
|
||||
await this.sizeSource()
|
||||
await this.segment()
|
||||
|
||||
if (this.destroyed) {
|
||||
return
|
||||
}
|
||||
|
||||
if (this.options.type === 'blur') {
|
||||
await this.blur()
|
||||
} else {
|
||||
await this.drawVirtualBackground()
|
||||
}
|
||||
this.consecutiveErrors = 0
|
||||
} catch (error) {
|
||||
if (this.destroyed) {
|
||||
return
|
||||
}
|
||||
this.consecutiveErrors += 1
|
||||
if (this.consecutiveErrors >= MAX_CONSECUTIVE_ERRORS) {
|
||||
// Degrade to a fully blurred frame: a live camera beats a frozen
|
||||
// one, and concealment must survive the failure.
|
||||
this.degraded = true
|
||||
reportError('effects_processor_failure', error, {
|
||||
context:
|
||||
'Background processing failed repeatedly, falling back to fully blurred video',
|
||||
consecutive_errors: this.consecutiveErrors,
|
||||
})
|
||||
this.imageSegmenter?.close()
|
||||
this.imageSegmenter = undefined
|
||||
}
|
||||
}
|
||||
this._scheduleNextFrame()
|
||||
}
|
||||
|
||||
_scheduleNextFrame() {
|
||||
if (this.destroyed) {
|
||||
return
|
||||
}
|
||||
this.timerWorker?.postMessage({
|
||||
id: SET_TIMEOUT,
|
||||
timeMs: 1000 / 30,
|
||||
timeMs: FRAME_INTERVAL_MS,
|
||||
})
|
||||
}
|
||||
|
||||
_createMainCanvas() {
|
||||
this.outputCanvas = document.querySelector(
|
||||
'canvas#background-blur-local'
|
||||
) as HTMLCanvasElement
|
||||
if (!this.outputCanvas) {
|
||||
this.outputCanvas = this._createCanvas(
|
||||
BLUR_CANVAS_ID,
|
||||
this.sourceSettings!.width!,
|
||||
this.sourceSettings!.height!
|
||||
)
|
||||
/**
|
||||
* Keep the output canvas in sync with the actual decoded video dimensions.
|
||||
* `MediaStreamTrack.getSettings()` can be incomplete or stale on Firefox,
|
||||
* so the video element is the source of truth.
|
||||
*/
|
||||
_syncOutputCanvasSize() {
|
||||
const width = this.videoElement?.videoWidth
|
||||
const height = this.videoElement?.videoHeight
|
||||
if (!width || !height || !this.outputCanvas) {
|
||||
return
|
||||
}
|
||||
if (
|
||||
this.outputCanvas.width !== width ||
|
||||
this.outputCanvas.height !== height
|
||||
) {
|
||||
this.outputCanvas.width = width
|
||||
this.outputCanvas.height = height
|
||||
}
|
||||
}
|
||||
|
||||
_createMainCanvas() {
|
||||
const width =
|
||||
this.sourceSettings?.width || this.videoElement?.videoWidth || 1280
|
||||
const height =
|
||||
this.sourceSettings?.height || this.videoElement?.videoHeight || 720
|
||||
this.outputCanvas = this._createCanvas(BLUR_CANVAS_ID, width, height)
|
||||
this.outputCanvasCtx = this.outputCanvas.getContext('2d')!
|
||||
}
|
||||
|
||||
_createMaskCanvas() {
|
||||
this.segmentationMaskCanvas = document.querySelector(
|
||||
`#${SEGMENTATION_MASK_CANVAS_ID}`
|
||||
) as HTMLCanvasElement
|
||||
if (!this.segmentationMaskCanvas) {
|
||||
this.segmentationMaskCanvas = this._createCanvas(
|
||||
SEGMENTATION_MASK_CANVAS_ID,
|
||||
PROCESSING_WIDTH,
|
||||
PROCESSING_HEIGHT
|
||||
)
|
||||
}
|
||||
this.segmentationMaskCanvasCtx =
|
||||
this.segmentationMaskCanvas.getContext('2d')!
|
||||
this.segmentationMaskCanvas = this._createCanvas(
|
||||
SEGMENTATION_MASK_CANVAS_ID,
|
||||
PROCESSING_WIDTH,
|
||||
PROCESSING_HEIGHT
|
||||
)
|
||||
// getImageData is called on this canvas 30 times per second: opt out of
|
||||
// GPU backing to avoid a costly readback on every frame.
|
||||
this.segmentationMaskCanvasCtx = this.segmentationMaskCanvas.getContext(
|
||||
'2d',
|
||||
{ willReadFrequently: true }
|
||||
)!
|
||||
}
|
||||
|
||||
_createCanvas(id: string, width: number, height: number) {
|
||||
@@ -348,11 +514,39 @@ export class BackgroundCustomProcessor implements BackgroundProcessorInterface {
|
||||
}
|
||||
|
||||
async destroy() {
|
||||
this.destroyed = true
|
||||
|
||||
this.timerWorker?.postMessage({
|
||||
id: CLEAR_TIMEOUT,
|
||||
})
|
||||
|
||||
// Let any in-flight frame finish before releasing the resources it uses,
|
||||
// so segmentForVideo is never called on a closed segmenter.
|
||||
try {
|
||||
await this.processing
|
||||
} catch {
|
||||
// Failures are already handled inside process().
|
||||
}
|
||||
this.processing = undefined
|
||||
|
||||
if (this.onVideoLoaded && this.videoElement) {
|
||||
this.videoElement.removeEventListener('loadeddata', this.onVideoLoaded)
|
||||
}
|
||||
this.onVideoLoaded = undefined
|
||||
|
||||
this.timerWorker?.terminate()
|
||||
this.timerWorker = undefined
|
||||
|
||||
this.imageSegmenter?.close()
|
||||
this.imageSegmenter = undefined
|
||||
|
||||
this.processedTrack?.stop()
|
||||
this.processedTrack = undefined
|
||||
|
||||
this.outputCanvas = undefined
|
||||
this.outputCanvasCtx = undefined
|
||||
this.segmentationMaskCanvas = undefined
|
||||
this.segmentationMaskCanvasCtx = undefined
|
||||
this.sourceImageData = undefined
|
||||
}
|
||||
}
|
||||
|
||||
@@ -6,6 +6,7 @@ import type { Track, TrackProcessor } from 'livekit-client'
|
||||
import { BackgroundCustomProcessor } from './BackgroundCustomProcessor'
|
||||
import { UnifiedBackgroundTrackProcessor } from './UnifiedBackgroundTrackProcessor'
|
||||
import { FaceLandmarksOptions } from './FaceLandmarksProcessor'
|
||||
import { captureEvent } from '@/features/analytics/telemetry'
|
||||
|
||||
export const SELFIE_SEGMENTER_MODEL_PATH =
|
||||
'/assets/mediapipe/models/selfie_segmenter_landscape.tflite'
|
||||
@@ -31,15 +32,29 @@ export interface BackgroundProcessorInterface extends TrackProcessor<Track.Kind>
|
||||
options: ProcessorConfig
|
||||
}
|
||||
|
||||
let unsupportedReported = false
|
||||
|
||||
export class BackgroundProcessorFactory {
|
||||
private static _isSupported?: boolean
|
||||
|
||||
static hasModernApiSupport() {
|
||||
return ProcessorWrapper.hasModernApiSupport
|
||||
}
|
||||
|
||||
static isSupported() {
|
||||
return (
|
||||
supportsBackgroundProcessors() || BackgroundCustomProcessor.isSupported
|
||||
)
|
||||
if (this._isSupported === undefined) {
|
||||
this._isSupported =
|
||||
supportsBackgroundProcessors() || BackgroundCustomProcessor.isSupported
|
||||
}
|
||||
|
||||
if (!this._isSupported && !unsupportedReported) {
|
||||
unsupportedReported = true
|
||||
captureEvent('background-processor-unsupported', {
|
||||
path: 'isSupported',
|
||||
})
|
||||
}
|
||||
|
||||
return this._isSupported
|
||||
}
|
||||
|
||||
static getProcessor(
|
||||
@@ -48,6 +63,8 @@ export class BackgroundProcessorFactory {
|
||||
const isBlur = config.type === ProcessorType.BLUR
|
||||
const isVirtual = config.type === ProcessorType.VIRTUAL
|
||||
|
||||
return new BackgroundCustomProcessor(config)
|
||||
|
||||
if (!isBlur && !isVirtual) return undefined
|
||||
|
||||
if (supportsBackgroundProcessors()) {
|
||||
@@ -58,6 +75,12 @@ export class BackgroundProcessorFactory {
|
||||
return new BackgroundCustomProcessor(config)
|
||||
}
|
||||
|
||||
if (!unsupportedReported) {
|
||||
captureEvent('background-processor-unsupported', {
|
||||
path: 'getProcessor',
|
||||
})
|
||||
}
|
||||
|
||||
return undefined
|
||||
}
|
||||
|
||||
|
||||
+59
-5
@@ -25,7 +25,11 @@ import {
|
||||
} from '@/features/files/api/listFiles.ts'
|
||||
import { useCreateFile } from '@/features/files/api/createFile.ts'
|
||||
import { FileTrigger } from 'react-aria-components'
|
||||
import { RiDeleteBinLine, RiImageAddFill } from '@remixicon/react'
|
||||
import {
|
||||
RiDeleteBinLine,
|
||||
RiImageAddFill,
|
||||
RiProhibitedLine,
|
||||
} from '@remixicon/react'
|
||||
import { useDeleteFile } from '@/features/files/api/deleteFile.ts'
|
||||
import { useUser } from '@/features/auth/api/useUser'
|
||||
import { ApiFileItem } from '@/features/files/api/types.ts'
|
||||
@@ -197,10 +201,23 @@ export const EffectsConfiguration = ({
|
||||
*
|
||||
* We arrive in this condition when we enter the room with the camera already off.
|
||||
*/
|
||||
const newProcessorTmp = BackgroundProcessorFactory.getProcessor(config)!
|
||||
await toggle(true, {
|
||||
processor: newProcessorTmp,
|
||||
})
|
||||
try {
|
||||
const newProcessorTmp =
|
||||
BackgroundProcessorFactory.getProcessor(config)!
|
||||
await toggle(true, {
|
||||
processor: newProcessorTmp,
|
||||
})
|
||||
} catch (error) {
|
||||
reportError('effects_processor_failure', error, {
|
||||
context: 'Error applying effect while enabling camera:',
|
||||
})
|
||||
saveProcessorConfig(undefined)
|
||||
try {
|
||||
await toggle(true)
|
||||
} catch {
|
||||
// Camera errors are handled by the toggle's own error path.
|
||||
}
|
||||
}
|
||||
setTimeout(() => setProcessorPending(false))
|
||||
return
|
||||
}
|
||||
@@ -242,6 +259,14 @@ export const EffectsConfiguration = ({
|
||||
reportError('effects_processor_failure', error, {
|
||||
context: 'Error applying effect:',
|
||||
})
|
||||
try {
|
||||
if (videoTrack.getProcessor()) {
|
||||
await videoTrack.stopProcessor()
|
||||
}
|
||||
} catch {
|
||||
// Best effort: the processor may already be broken.
|
||||
}
|
||||
saveProcessorConfig(undefined)
|
||||
} finally {
|
||||
// Without setTimeout the DOM is not refreshing when updating the options.
|
||||
setTimeout(() => setProcessorPending(false))
|
||||
@@ -250,6 +275,24 @@ export const EffectsConfiguration = ({
|
||||
[enabled, selectedId, toggle, updateEffectStatusMessage, videoTrack]
|
||||
)
|
||||
|
||||
const clearEffect = useCallback(async () => {
|
||||
if (selectedId === 'none') return
|
||||
setProcessorPending(true)
|
||||
try {
|
||||
if (videoTrack?.getProcessor()) {
|
||||
await videoTrack.stopProcessor()
|
||||
}
|
||||
saveProcessorConfig(undefined)
|
||||
announceEffectStatusMessage(t('blur.status.none'))
|
||||
} catch (error) {
|
||||
reportError('effects_processor_failure', error, {
|
||||
context: 'Error clearing effect:',
|
||||
})
|
||||
} finally {
|
||||
setTimeout(() => setProcessorPending(false))
|
||||
}
|
||||
}, [announceEffectStatusMessage, selectedId, t, videoTrack])
|
||||
|
||||
const { data: appConfig } = useConfig()
|
||||
const { isLoggedIn } = useUser()
|
||||
const canUploadBackground =
|
||||
@@ -647,6 +690,17 @@ export const EffectsConfiguration = ({
|
||||
gap: '1.25rem',
|
||||
})}
|
||||
>
|
||||
<ToggleButton
|
||||
variant="bigSquare"
|
||||
aria-label={t('clear')}
|
||||
tooltip={t('clear')}
|
||||
isDisabled={processorOptions.isDisabled}
|
||||
onChange={clearEffect}
|
||||
isSelected={selectedId === 'none'}
|
||||
data-attr="toggle-effect-none"
|
||||
>
|
||||
<RiProhibitedLine />
|
||||
</ToggleButton>
|
||||
{processorOptions.blurBased.map(({ Icon, ...option }) => (
|
||||
<ToggleButton
|
||||
key={option.id}
|
||||
|
||||
@@ -22,10 +22,12 @@ import { VOICE_AUDIO_CONSTRAINTS } from '../utils/constants'
|
||||
import {
|
||||
saveAudioInputDeviceId,
|
||||
saveAudioInputEnabled,
|
||||
saveProcessorConfig,
|
||||
saveVideoInputDeviceId,
|
||||
saveVideoInputEnabled,
|
||||
userChoicesStore,
|
||||
} from '@/stores/userChoices'
|
||||
import { reportError } from '@/features/analytics/telemetry'
|
||||
import { useSyncTrackDeviceId } from './useSyncTrackDeviceId'
|
||||
|
||||
// Module-level: effect dependencies, must be referentially stable.
|
||||
@@ -221,15 +223,32 @@ export function useJoinTracks(): {
|
||||
[audioDeviceId]
|
||||
)
|
||||
|
||||
const createVideo = useCallback(
|
||||
() =>
|
||||
createLocalVideoTrack({
|
||||
const createVideo = useCallback(async () => {
|
||||
const processor =
|
||||
BackgroundProcessorFactory.fromProcessorConfig(processorConfig)
|
||||
if (!processor) {
|
||||
return createLocalVideoTrack({ deviceId: videoDeviceId })
|
||||
}
|
||||
try {
|
||||
return await createLocalVideoTrack({
|
||||
deviceId: videoDeviceId,
|
||||
processor:
|
||||
BackgroundProcessorFactory.fromProcessorConfig(processorConfig),
|
||||
}),
|
||||
[videoDeviceId, processorConfig]
|
||||
)
|
||||
processor,
|
||||
})
|
||||
} catch (error) {
|
||||
// A camera problem (permission, device missing/busy) is not the
|
||||
// effect's fault: let the normal media error handling deal with it
|
||||
// without touching the user's saved effect.
|
||||
const e = getMediaDeviceFailure(error as Error)
|
||||
if (e !== MediaDeviceFailure.Other && !!e) {
|
||||
throw error
|
||||
}
|
||||
reportError('effects_processor_failure', error, {
|
||||
context: 'Restoring saved effect failed, retrying without it',
|
||||
})
|
||||
saveProcessorConfig(undefined)
|
||||
return createLocalVideoTrack({ deviceId: videoDeviceId })
|
||||
}
|
||||
}, [videoDeviceId, processorConfig])
|
||||
|
||||
const audioTrack = useLocalTrack({
|
||||
ready: audioReady,
|
||||
|
||||
Reference in New Issue
Block a user