fix(ci): material upstream flash + IndexedDB backup verify

Re-pulse legend upstream flash on pin clicks and reload material graphs
when actor data changes. Verify IDB writes before returning success.

Author: PabloTheThinker

CHANGELOG.md

@@ -4,6 +4,15 @@ Notable changes to Lotus Engine. Newest entries first.
 
 ---
 
+## 2026-06-14 — CI fix: material flash + IndexedDB round-trip
+
+### Fixed
+- `MaterialEditor` — reload graph when `actor.materialGraph` changes; re-pulse upstream flash on channel pin click (900ms timer expired before slow CI assertions)
+- `cloudSaveStub` — read-after-write verify on backup; reset cached IDB connection on errors
+- `smoke.spec.ts` — clear cloud IDB before wave 70 round-trip test
+
+---
+
 ## 2026-06-14 — CI fix: flaky Playwright tests on GitHub Actions
 
 ### Fixed

src/editor/panels/MaterialEditor.tsx

@@ -465,6 +465,7 @@ export function MaterialEditor() {
   const flashTimer = useRef<ReturnType<typeof setTimeout> | null>(null)
   const upstreamFlashTimer = useRef<ReturnType<typeof setTimeout> | null>(null)
   const lastActor = useRef<string | null>(null)
+  const lastGraphSig = useRef<string | null>(null)
   const canvasRef = useRef<HTMLDivElement>(null)
   const dragState = useRef<{ nodeId: string; dx: number; dy: number } | null>(null)
   const panState = useRef<{ startX: number; startY: number; ox: number; oy: number } | null>(null)
@@ -485,8 +486,15 @@ export function MaterialEditor() {
   }, [actor?.id])
 
   useEffect(() => {
-    if (actor && actor.id !== lastActor.current) {
+    if (!actor) {
+      lastActor.current = null
+      lastGraphSig.current = null
+      return
+    }
+    const graphSig = JSON.stringify(actor.materialGraph ?? null)
+    if (actor.id !== lastActor.current || graphSig !== lastGraphSig.current) {
       lastActor.current = actor.id
+      lastGraphSig.current = graphSig
       const g = actor.materialGraph
         ? (JSON.parse(JSON.stringify(actor.materialGraph)) as MaterialGraph)
         : emptyMaterialGraph()
@@ -495,7 +503,6 @@ export function MaterialEditor() {
       setDirty(false)
       setPendingFrom(null)
     }
-    if (!actor) lastActor.current = null
   }, [actor])
 
   const wiredChannels = useMemo(() => {
@@ -527,7 +534,7 @@ export function MaterialEditor() {
     const ids = nodesInSoloChannel(graph, isolateChannel)
     setUpstreamFlashIds(ids)
     if (upstreamFlashTimer.current) clearTimeout(upstreamFlashTimer.current)
-    upstreamFlashTimer.current = setTimeout(() => setUpstreamFlashIds(new Set()), 900)
+    upstreamFlashTimer.current = setTimeout(() => setUpstreamFlashIds(new Set()), 2500)
     return () => {
       if (upstreamFlashTimer.current) clearTimeout(upstreamFlashTimer.current)
     }
@@ -660,9 +667,18 @@ export function MaterialEditor() {
     panAnim.current = requestAnimationFrame(tick)
   }
 
+  const pulseUpstreamFlash = (ch: string) => {
+    if (!graph) return
+    const ids = nodesInSoloChannel(graph, ch)
+    setUpstreamFlashIds(ids)
+    if (upstreamFlashTimer.current) clearTimeout(upstreamFlashTimer.current)
+    upstreamFlashTimer.current = setTimeout(() => setUpstreamFlashIds(new Set()), 2500)
+  }
+
   const syncChannelPin = (ch: string) => {
     setIsolateChannel(ch)
     setPinnedMinimapChannel(ch)
+    pulseUpstreamFlash(ch)
   }
 
   const zoomAtGraph = (factor: number, gx: number, gy: number) => {

src/engine/cloudSaveStub.ts

@@ -37,7 +37,10 @@ function openDb(): Promise<IDBDatabase> {
         if (!db.objectStoreNames.contains(STORE)) db.createObjectStore(STORE)
       }
       req.onsuccess = () => resolve(req.result)
-      req.onerror = () => reject(req.error ?? new Error('IndexedDB open failed'))
+      req.onerror = () => {
+        dbPromise = null
+        reject(req.error ?? new Error('IndexedDB open failed'))
+      }
     })
   }
   return dbPromise
@@ -62,14 +65,27 @@ export async function backupCheckpointToIndexedDB(slot: string, data: unknown):
       slot: sanitizeSlot(slot),
       data,
     }
+    const key = cloudKey(slot)
     await new Promise<void>((resolve, reject) => {
       const tx = db.transaction(STORE, 'readwrite')
-      tx.objectStore(STORE).put(payload, cloudKey(slot))
+      tx.objectStore(STORE).put(payload, key)
       tx.oncomplete = () => resolve()
       tx.onerror = () => reject(tx.error ?? new Error('IDB put failed'))
     })
-    return true
+    // Read-after-write — IDB put can resolve before the row is visible to a follow-up get on slow runners.
+    for (let i = 0; i < 12; i++) {
+      const row = await new Promise<{ data?: unknown } | undefined>((resolve, reject) => {
+        const tx = db.transaction(STORE, 'readonly')
+        const req = tx.objectStore(STORE).get(key)
+        req.onsuccess = () => resolve(req.result as { data?: unknown } | undefined)
+        req.onerror = () => reject(req.error ?? new Error('IDB verify get failed'))
+      })
+      if (row?.data !== undefined) return true
+      await new Promise((r) => setTimeout(r, 25))
+    }
+    return false
   } catch {
+    dbPromise = null
     return false
   }
 }

tests/smoke.spec.ts

@@ -10744,6 +10744,15 @@ test('wave 70 backupCheckpointToIndexedDB round-trip stores lotus-engine.cloud.{
 }) => {
   await bootEditor(page)
 
+  await page.evaluate(async () => {
+    await new Promise<void>((resolve) => {
+      const req = indexedDB.deleteDatabase('lotus-engine-cloud-saves-v1')
+      req.onsuccess = () => resolve()
+      req.onblocked = () => resolve()
+      req.onerror = () => resolve()
+    })
+  })
+
   const result = await page.evaluate(async () => {
     const v = window.lotus! as typeof window.lotus & {
       world: { levelName: string; environment: { saveSlotsEnabled?: boolean; cloudSaveBackup?: boolean } }
@@ -10757,12 +10766,7 @@ test('wave 70 backupCheckpointToIndexedDB round-trip stores lotus-engine.cloud.{
     v.world.environment.saveSlotsEnabled = true
     v.world.environment.cloudSaveBackup = true
     const ok = await v.save.backupToCloud('cloud-a', { hp: 99, gems: 3 })
-    let restored: unknown = null
-    for (let i = 0; i < 20; i++) {
-      restored = await v.save.restoreFromCloud('cloud-a')
-      if (restored != null) break
-      await new Promise((r) => setTimeout(r, 25))
-    }
+    const restored = await v.save.restoreFromCloud('cloud-a')
     const slots = await v.save.listCloudSlots()
     return { ok, restored, slots }
   })