iH1dZddlmZddlZddlmcmZddl Z e jjddddl Z ddl Z ddlmZmZddlmZmZmZmZddlZddlmZmZmZddlmZd Z d4 d5d Zd6d Zd7d Zd8d Z d9dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/e0dk(rddl1Z1de"fde#fd e$fd!e%fd"e&fd#e'fd$e(fd%e)fd&e*fd'e+fd(e,fd)e-fd*e.fd+e/fgZ2dZ3e4e2Z5e2D]\Z6Z7 e7e8d,e6e3d-z Z3e8d0e3d1e5d2e3e5k(r e8d3ye jxd-yy#e9$r)Z:e8d.e6d/e:e1jvYdZ:[:zdZ:[:wwxYw):u_ Tests for Story 6.05 (Track B): StagingArea — ProposedDelta Collection Hub Black Box tests (BB): verify the public contract from the outside — submit_delta stores a delta, collect_all returns all deltas, clear removes the hash, wait_for_all polls until complete or timeout. White Box tests (WB): verify internal mechanics — correct Redis key pattern, EXPIRE called with 600s TTL, bytes are decoded, partial results on timeout, STAGING_KEY_PREFIX constant value. Story: 6.05 File under test: core/coherence/staging_area.py ALL tests use mocks — NO real Redis connection is made. ) annotationsNz/mnt/e/genesis-system)datetimetimezone) AsyncMock MagicMockcallpatch) StagingAreaSTAGING_KEY_PREFIXSTAGING_TTL_SECONDS) StateDeltacHtjj|S)zrs9"# *+ ';;  2= " !    $     $+$ % Q3,0   3$4 %  & z FGz{ 68jk 8:hi CE|} >@xy 46cd +-^_ 9;vw 24UV 8:^_ :<]^ ACjk BDlm %'>? E"F JE"b " D IdV$ % aKF " Bvhawm ,-  89 G6 " IdV2cU+ , I   ! ! "s=EE5 E00E5