feat(plugin): improve worker readiness handling and fallback logic

Author: kalwalt

examples/simple-marker/index.html

@@ -72,29 +72,35 @@ <h3>Event Log:</h3>
             log('Creating ArtoolkitPlugin instance (dist build)…');
             plugin = new ArtoolkitPlugin({
                 worker: true,
-                cameraParametersUrl: '/examples/simple-marker/data/camera_para.dat',
-                // minConfidence: 0.6,
+                cameraParametersUrl: '/examples/simple-marker/data/camera_para.dat'
             });
-            await plugin.init(core);
-            await plugin.enable();
 
+            // Register listeners BEFORE enable to avoid missing early 'ready'
             eventBus.on('ar:workerReady', () => {
                 log('Worker ready');
                 setStatus('Worker ready. Start camera and then load marker.', 'success');
                 loadMarkerBtn.disabled = false;
             });
-
             eventBus.on('ar:workerError', e => {
                 log(`workerError: ${JSON.stringify(e)}`);
                 setStatus('Worker error (see console)', 'error');
             });
-
             eventBus.on('ar:getMarker', (e) => console.log('[example] ar:getMarker', e));
             eventBus.on('ar:markerFound', d => log(`markerFound: ${JSON.stringify(d)}`));
             eventBus.on('ar:markerUpdated', d => log(`markerUpdated: ${JSON.stringify(d)}`));
             eventBus.on('ar:markerLost', d => log(`markerLost: ${JSON.stringify(d)}`));
 
-            setStatus('Plugin initialized. Waiting for worker…', 'normal');
+            await plugin.init(core);
+            await plugin.enable();
+
+            // Fallback: if worker became ready during enable, honor it
+            if (plugin.workerReady) {
+                log('Worker was already ready (post-enable).');
+                setStatus('Worker ready. Start camera and then load marker.', 'success');
+                loadMarkerBtn.disabled = false;
+            } else {
+                setStatus('Plugin initialized. Waiting for worker…', 'normal');
+            }
         } catch (err) {
             log('Init error: ' + (err && err.message ? err.message : err));
             setStatus('Initialization error', 'error');

src/plugin.js

@@ -39,6 +39,7 @@ export class ArtoolkitPlugin {
         // Pending loadMarker requests: Map<requestId, { resolve, reject }>
         this._pendingMarkerLoads = new Map();
         this._nextLoadRequestId = 0;
+        this.workerReady = false;
     }
 
     async init(core) {
@@ -165,9 +166,13 @@ export class ArtoolkitPlugin {
                     wasmBaseUrl: this.options.wasmBaseUrl || null
                 }
             });
-        } catch (e) {
-            // ignore
-        }
+            // Watchdog: if 'ready' wasn’t received shortly, resend a no-op init once
+            setTimeout(() => {
+                if (!this.workerReady) {
+                    try { this._worker?.postMessage?.({ type: 'init', payload: {} }); } catch {}
+                }
+            }, 500);
+        } catch (e) {}
     }
 
     _stopWorker() {
@@ -197,6 +202,8 @@ export class ArtoolkitPlugin {
         const data = ev && ev.data !== undefined ? ev.data : ev;
         const { type, payload } = data || {};
         if (type === 'ready') {
+            console.log('[Plugin] Worker ready');
+            this.workerReady = true;
             this.core?.eventBus?.emit('ar:workerReady', {});
         } else if (type === 'detectionResult') {
             console.log('[Plugin] Received detectionResult:', payload);