{"version":3,"sources":["../src/internal/clock.ts","../src/AudioEngine.ts","../src/internal/uuid.ts","../src/CrossFrameBridge.ts","../src/EventBus.ts","../src/KeyboardController.ts","../src/QueueManager.ts","../src/internal/storage.ts","../src/SessionManager.ts","../src/PlayerController.ts"],"names":["el","target"],"mappings":";AAYO,IAAM,WAAA,GAAqB;AAAA,EAChC,GAAA,EAAK,MAAM,WAAA,CAAY,GAAA,EAAI;AAAA,EAC3B,MAAA,EAAQ,MAAA,iBAAM,IAAI,IAAA,IAAO,WAAA;AAC3B,CAAA;;;ACQO,IAAM,cAAN,MAAkB;AAAA,EAgBvB,WAAA,CACmB,GAAA,EACA,KAAA,GAAe,WAAA,EAChC;AAFiB,IAAA,IAAA,CAAA,GAAA,GAAA,GAAA;AACA,IAAA,IAAA,CAAA,KAAA,GAAA,KAAA;AAAA,EAChB;AAAA,EAFgB,GAAA;AAAA,EACA,KAAA;AAAA,EAjBX,OAAA,GAAmC,IAAA;AAAA,EACnC,UAAA,GAAoD,IAAA;AAAA,EAC3C,WAAuD,EAAC;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAQjE,aAAA,GAAgB,CAAA;AAAA,EAChB,cAAA,GAAiB,KAAA;AAAA;AAAA,EAEjB,eAAA,GAAkB,KAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAW1B,OAAO,OAAA,EAAiC;AACtC,IAAA,IAAI,IAAA,CAAK,YAAY,OAAA,EAAS;AAC9B,IAAA,IAAI,IAAA,CAAK,OAAA,EAAS,IAAA,CAAK,MAAA,EAAO;AAC9B,IAAA,IAAA,CAAK,OAAA,GAAU,OAAA;AACf,IAAA,IAAA,CAAK,gBAAgB,MAAA,CAAO,QAAA,CAAS,QAAQ,WAAW,CAAA,GAAI,QAAQ,WAAA,GAAc,CAAA;AAClF,IAAA,IAAA,CAAK,kBAAkB,OAAO,CAAA;AAC9B,IAAA,IAAI,OAAO,QAAA,CAAS,OAAA,CAAQ,QAAQ,CAAA,IAAK,OAAA,CAAQ,WAAW,CAAA,EAAG;AAC7D,MAAA,MAAM,WAAW,OAAA,CAAQ,QAAA;AAIzB,MAAA,OAAA,CAAQ,OAAA,EAAQ,CAAE,IAAA,CAAK,MAAM;AAC3B,QAAA,IAAI,IAAA,CAAK,YAAY,OAAA,EAAS;AAC5B,UAAA,IAAA,CAAK,GAAA,CAAI,IAAA,CAAK,uBAAA,EAAyB,EAAE,UAAU,CAAA;AAAA,QACrD;AAAA,MACF,CAAC,CAAA;AAAA,IACH;AAAA,EACF;AAAA,EAEA,MAAA,GAAe;AACb,IAAA,IAAI,CAAC,KAAK,OAAA,EAAS;AACnB,IAAA,KAAA,MAAW,EAAE,IAAA,EAAM,EAAA,EAAG,IAAK,KAAK,QAAA,EAAU;AACxC,MAAA,IAAA,CAAK,OAAA,CAAQ,mBAAA,CAAoB,IAAA,EAAM,EAAE,CAAA;AAAA,IAC3C;AACA,IAAA,IAAA,CAAK,SAAS,MAAA,GAAS,CAAA;AACvB,IAAA,IAAA,CAAK,QAAA,EAAS;AACd,IAAA,IAAA,CAAK,OAAA,GAAU,IAAA;AAAA,EACjB;AAAA;AAAA,EAGA,UAAA,GAAsC;AACpC,IAAA,OAAO,IAAA,CAAK,OAAA;AAAA,EACd;AAAA;AAAA,EAIA,MAAM,IAAA,GAAsB;AAC1B,IAAA,IAAI,CAAC,IAAA,CAAK,OAAA,EAAS,MAAM,IAAI,MAAM,kCAAkC,CAAA;AAGrE,IAAA,MAAM,IAAA,CAAK,QAAQ,IAAA,EAAK;AAAA,EAC1B;AAAA,EAEA,KAAA,GAAc;AACZ,IAAA,IAAA,CAAK,SAAS,KAAA,EAAM;AAAA,EACtB;AAAA,EAEA,KAAK,SAAA,EAAyB;AAC5B,IAAA,IAAI,CAAC,KAAK,OAAA,EAAS;AACnB,IAAA,IAAI,CAAC,MAAA,CAAO,QAAA,CAAS,SAAS,CAAA,EAAG;AAC/B,MAAA,MAAM,IAAI,KAAA,CAAM,CAAA,gDAAA,EAAmD,SAAS,CAAA,CAAE,CAAA;AAAA,IAChF;AAIA,IAAA,IAAA,CAAK,OAAA,CAAQ,WAAA,GAAc,IAAA,CAAK,GAAA,CAAI,GAAG,SAAS,CAAA;AAAA,EAClD;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EASA,aAAA,CAAc,GAAA,EAAa,QAAA,GAAW,CAAA,EAAS;AAC7C,IAAA,MAAM,KAAK,IAAA,CAAK,OAAA;AAChB,IAAA,IAAI,CAAC,EAAA,EAAI;AACT,IAAA,MAAM,KAAK,MAAA,CAAO,QAAA,CAAS,QAAQ,CAAA,IAAK,QAAA,GAAW,IAAI,QAAA,GAAW,CAAA;AAClE,IAAA,IAAA,CAAK,aAAA,GAAgB,EAAA;AACrB,IAAA,IAAA,CAAK,kBAAkB,EAAA,GAAK,CAAA;AAC5B,IAAA,EAAA,CAAG,GAAA,GAAM,GAAA;AACT,IAAA,IAAI,KAAK,CAAA,EAAG;AACV,MAAA,EAAA,CAAG,gBAAA;AAAA,QACD,gBAAA;AAAA,QACA,MAAM;AACJ,UAAA,IAAI,IAAA,CAAK,OAAA,KAAY,EAAA,EAAI,EAAA,CAAG,WAAA,GAAc,EAAA;AAAA,QAC5C,CAAA;AAAA,QACA,EAAE,MAAM,IAAA;AAAK,OACf;AAAA,IACF;AAAA,EACF;AAAA,EAEA,UAAU,MAAA,EAAsB;AAC9B,IAAA,IAAI,CAAC,KAAK,OAAA,EAAS;AACnB,IAAA,IAAI,CAAC,MAAA,CAAO,QAAA,CAAS,MAAM,CAAA,EAAG;AAC5B,MAAA,MAAM,IAAI,KAAA,CAAM,CAAA,kDAAA,EAAqD,MAAM,CAAA,CAAE,CAAA;AAAA,IAC/E;AACA,IAAA,IAAA,CAAK,OAAA,CAAQ,SAAS,IAAA,CAAK,GAAA,CAAI,GAAG,IAAA,CAAK,GAAA,CAAI,CAAA,EAAG,MAAM,CAAC,CAAA;AAAA,EACvD;AAAA;AAAA,EAIQ,kBAAkB,EAAA,EAA4B;AACpD,IAAA,MAAM,GAAA,GAAM,CAAC,IAAA,EAAc,EAAA,KAA4B;AACrD,MAAA,EAAA,CAAG,gBAAA,CAAiB,MAAM,EAAE,CAAA;AAC5B,MAAA,IAAA,CAAK,QAAA,CAAS,IAAA,CAAK,EAAE,IAAA,EAAM,IAAI,CAAA;AAAA,IACjC,CAAA;AAEA,IAAA,GAAA,CAAI,kBAAkB,MAAM;AAC1B,MAAA,IAAA,CAAK,IAAI,IAAA,CAAK,uBAAA,EAAyB,EAAE,QAAA,EAAU,EAAA,CAAG,UAAU,CAAA;AAAA,IAClE,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,QAAQ,MAAM;AAChB,MAAA,IAAA,CAAK,gBAAgB,EAAA,CAAG,WAAA;AACxB,MAAA,IAAA,CAAK,GAAA,CAAI,IAAA,CAAK,aAAA,EAAe,EAAE,WAAA,EAAa,EAAA,CAAG,WAAA,EAAa,EAAA,EAAI,IAAA,CAAK,KAAA,CAAM,GAAA,EAAI,EAAG,CAAA;AAClF,MAAA,IAAA,CAAK,UAAU,EAAE,CAAA;AAAA,IACnB,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,SAAS,MAAM;AACjB,MAAA,IAAA,CAAK,gBAAgB,EAAA,CAAG,WAAA;AACxB,MAAA,IAAA,CAAK,GAAA,CAAI,IAAA,CAAK,cAAA,EAAgB,EAAE,WAAA,EAAa,EAAA,CAAG,WAAA,EAAa,EAAA,EAAI,IAAA,CAAK,KAAA,CAAM,GAAA,EAAI,EAAG,CAAA;AACnF,MAAA,IAAA,CAAK,QAAA,EAAS;AAAA,IAChB,CAAC,CAAA;AAYD,IAAA,GAAA,CAAI,cAAc,MAAM;AACtB,MAAA,IAAI,KAAK,cAAA,EAAgB;AACzB,MAAA,IAAI,GAAG,OAAA,EAAS;AAChB,MAAA,IAAA,CAAK,gBAAgB,EAAA,CAAG,WAAA;AAAA,IAC1B,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,WAAW,MAAM;AACnB,MAAA,IAAA,CAAK,cAAA,GAAiB,IAAA;AACtB,MAAA,IAAI,KAAK,eAAA,EAAiB;AAC1B,MAAA,IAAA,CAAK,GAAA,CAAI,KAAK,gBAAA,EAAkB;AAAA,QAC9B,MAAM,IAAA,CAAK,aAAA;AAAA,QACX,IAAI,EAAA,CAAG,WAAA;AAAA,QACP,EAAA,EAAI,IAAA,CAAK,KAAA,CAAM,GAAA;AAAI,OACpB,CAAA;AAAA,IACH,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,UAAU,MAAM;AAClB,MAAA,IAAI,KAAK,eAAA,EAAiB;AACxB,QAAA,IAAA,CAAK,eAAA,GAAkB,KAAA;AACvB,QAAA,IAAA,CAAK,gBAAgB,EAAA,CAAG,WAAA;AACxB,QAAA,IAAA,CAAK,cAAA,GAAiB,KAAA;AACtB,QAAA;AAAA,MACF;AACA,MAAA,IAAA,CAAK,GAAA,CAAI,KAAK,eAAA,EAAiB;AAAA,QAC7B,MAAM,IAAA,CAAK,aAAA;AAAA,QACX,IAAI,EAAA,CAAG,WAAA;AAAA,QACP,EAAA,EAAI,IAAA,CAAK,KAAA,CAAM,GAAA;AAAI,OACpB,CAAA;AACD,MAAA,IAAA,CAAK,gBAAgB,EAAA,CAAG,WAAA;AACxB,MAAA,IAAA,CAAK,cAAA,GAAiB,KAAA;AAAA,IACxB,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,SAAS,MAAM;AACjB,MAAA,IAAA,CAAK,GAAA,CAAI,KAAK,cAAA,EAAgB,EAAE,IAAI,IAAA,CAAK,KAAA,CAAM,GAAA,EAAI,EAAG,CAAA;AACtD,MAAA,IAAA,CAAK,QAAA,EAAS;AAAA,IAChB,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,WAAW,MAAM;AACnB,MAAA,IAAA,CAAK,GAAA,CAAI,KAAK,gBAAA,EAAkB,EAAE,IAAI,IAAA,CAAK,KAAA,CAAM,GAAA,EAAI,EAAG,CAAA;AAAA,IAC1D,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,WAAW,MAAM;AACnB,MAAA,IAAA,CAAK,GAAA,CAAI,KAAK,gBAAA,EAAkB,EAAE,IAAI,IAAA,CAAK,KAAA,CAAM,GAAA,EAAI,EAAG,CAAA;AAAA,IAC1D,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,gBAAgB,MAAM;AACxB,MAAA,IAAA,CAAK,GAAA,CAAI,IAAA,CAAK,qBAAA,EAAuB,EAAE,MAAA,EAAQ,GAAG,MAAA,EAAQ,KAAA,EAAO,EAAA,CAAG,KAAA,EAAO,CAAA;AAAA,IAC7E,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,cAAc,MAAM;AACtB,MAAA,IAAA,CAAK,IAAI,IAAA,CAAK,mBAAA,EAAqB,EAAE,IAAA,EAAM,EAAA,CAAG,cAAc,CAAA;AAAA,IAC9D,CAAC,CAAA;AAED,IAAA,GAAA,CAAI,SAAS,MAAM;AACjB,MAAA,MAAM,MAAM,EAAA,CAAG,KAAA;AACf,MAAA,IAAA,CAAK,GAAA,CAAI,KAAK,cAAA,EAAgB;AAAA,QAC5B,IAAA,EAAM,KAAK,IAAA,IAAQ,CAAA;AAAA,QACnB,OAAA,EAAS,KAAK,OAAA,IAAW;AAAA,OAC1B,CAAA;AAAA,IACH,CAAC,CAAA;AAAA,EACH;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EASQ,UAAU,EAAA,EAA4B;AAC5C,IAAA,IAAI,KAAK,UAAA,EAAY;AACrB,IAAA,IAAA,CAAK,UAAA,GAAa,YAAY,MAAM;AAElC,MAAA,IAAI,EAAA,CAAG,MAAA,IAAU,EAAA,CAAG,KAAA,IAAS,KAAK,eAAA,EAAiB;AACnD,MAAA,IAAA,CAAK,GAAA,CAAI,KAAK,mBAAA,EAAqB;AAAA,QACjC,aAAa,EAAA,CAAG,WAAA;AAAA,QAChB,EAAA,EAAI,IAAA,CAAK,KAAA,CAAM,GAAA;AAAI,OACpB,CAAA;AAAA,IACH,GAAG,GAAI,CAAA;AAAA,EACT;AAAA,EAEQ,QAAA,GAAiB;AACvB,IAAA,IAAI,KAAK,UAAA,EAAY;AACnB,MAAA,aAAA,CAAc,KAAK,UAAU,CAAA;AAC7B,MAAA,IAAA,CAAK,UAAA,GAAa,IAAA;AAAA,IACpB;AAAA,EACF;AACF;;;ACzPO,SAAS,MAAA,GAAiB;AAE/B,EAAA,MAAM,IAAK,UAAA,CAAmB,MAAA;AAC9B,EAAA,IAAI,CAAA,IAAK,OAAO,CAAA,CAAE,UAAA,KAAe,UAAA,EAAY;AAC3C,IAAA,OAAO,EAAE,UAAA,EAAW;AAAA,EACtB;AACA,EAAA,IAAI,CAAC,CAAA,IAAK,OAAO,CAAA,CAAE,oBAAoB,UAAA,EAAY;AACjD,IAAA,MAAM,IAAI,KAAA;AAAA,MACR;AAAA,KAEF;AAAA,EACF;AACA,EAAA,MAAM,KAAA,GAAQ,IAAI,UAAA,CAAW,EAAE,CAAA;AAC/B,EAAA,CAAA,CAAE,gBAAgB,KAAK,CAAA;AAEvB,EAAA,KAAA,CAAM,CAAC,CAAA,GAAK,KAAA,CAAM,CAAC,IAAK,EAAA,GAAQ,EAAA;AAEhC,EAAA,KAAA,CAAM,CAAC,CAAA,GAAK,KAAA,CAAM,CAAC,IAAK,EAAA,GAAQ,GAAA;AAChC,EAAA,MAAM,GAAA,GAAM,KAAA,CAAM,IAAA,CAAK,KAAA,EAAO,CAAC,CAAA,KAAM,CAAA,CAAE,QAAA,CAAS,EAAE,CAAA,CAAE,QAAA,CAAS,CAAA,EAAG,GAAG,CAAC,CAAA;AACpE,EAAA,OAAO,CAAA,EAAG,IAAI,KAAA,CAAM,CAAA,EAAG,CAAC,CAAA,CAAE,IAAA,CAAK,EAAE,CAAC,CAAA,CAAA,EAAI,IAAI,KAAA,CAAM,CAAA,EAAG,CAAC,CAAA,CAAE,IAAA,CAAK,EAAE,CAAC,CAAA,CAAA,EAAI,IAAI,KAAA,CAAM,CAAA,EAAG,CAAC,CAAA,CAAE,IAAA,CAAK,EAAE,CAAC,CAAA,CAAA,EAAI,IAC3F,KAAA,CAAM,CAAA,EAAG,EAAE,CAAA,CACX,IAAA,CAAK,EAAE,CAAC,CAAA,CAAA,EAAI,IAAI,KAAA,CAAM,EAAA,EAAI,EAAE,CAAA,CAAE,IAAA,CAAK,EAAE,CAAC,CAAA,CAAA;AAC3C;;;ACMA,IAAM,YAAA,GAAe,aAAA;AACrB,IAAM,gBAAA,GAAmB,CAAA;AAOzB,SAAS,iBAAiB,IAAA,EAAuC;AAC/D,EAAA,OACE,OAAO,SAAS,QAAA,IAChB,IAAA,KAAS,QACR,IAAA,CAAiC,YAAY,CAAA,KAAM,gBAAA,IACpD,SAAA,IAAc,IAAA;AAElB;AAEO,IAAM,yBAAN,MAAwD;AAAA,EAC5C,QAAA,uBAAe,GAAA,EAAwC;AAAA,EACvD,QAAA;AAAA,EACA,MAAA;AAAA,EACA,MAAA;AAAA,EACA,OAAA;AAAA,EACA,YAAA;AAAA,EACT,MAAA,GAAS,KAAA;AAAA,EAEjB,YAAY,OAAA,EAAwC;AAClD,IAAA,IAAI,OAAA,CAAQ,cAAA,CAAe,MAAA,KAAW,CAAA,EAAG;AACvC,MAAA,MAAM,IAAI,MAAM,yEAAyE,CAAA;AAAA,IAC3F;AACA,IAAA,IAAI,OAAA,CAAQ,cAAA,CAAe,QAAA,CAAS,GAAG,CAAA,EAAG;AACxC,MAAA,MAAM,IAAI,KAAA;AAAA,QACR;AAAA,OACF;AAAA,IACF;AACA,IAAA,IAAI,QAAQ,YAAA,KAAiB,MAAA,IAAa,OAAA,CAAQ,cAAA,CAAe,SAAS,CAAA,EAAG;AAC3E,MAAA,MAAM,IAAI,KAAA;AAAA,QACR;AAAA,OACF;AAAA,IACF;AACA,IAAA,MAAM,YAAA,GAAe,OAAA,CAAQ,YAAA,IAAiB,OAAA,CAAQ,eAAe,CAAC,CAAA;AACtE,IAAA,IAAI,iBAAiB,GAAA,EAAK;AACxB,MAAA,MAAM,IAAI,MAAM,0DAA0D,CAAA;AAAA,IAC5E;AACA,IAAA,IAAI,CAAC,OAAA,CAAQ,cAAA,CAAe,QAAA,CAAS,YAAY,CAAA,EAAG;AAClD,MAAA,MAAM,IAAI,KAAA;AAAA,QACR,yCAAyC,YAAY,CAAA,+BAAA;AAAA,OACvD;AAAA,IACF;AACA,IAAA,IAAA,CAAK,SAAS,OAAA,CAAQ,MAAA;AACtB,IAAA,IAAA,CAAK,MAAA,GAAS,QAAQ,MAAA,IAAW,UAAA;AACjC,IAAA,IAAA,CAAK,OAAA,GAAU,IAAI,GAAA,CAAI,OAAA,CAAQ,cAAc,CAAA;AAC7C,IAAA,IAAA,CAAK,YAAA,GAAe,YAAA;AACpB,IAAA,IAAA,CAAK,QAAA,GAAW,CAAC,KAAA,KAAwB;AACvC,MAAA,IAAI,CAAC,IAAA,CAAK,OAAA,CAAQ,GAAA,CAAI,KAAA,CAAM,MAAM,CAAA,EAAG;AAGrC,MAAA,IAAI,KAAA,CAAM,MAAA,KAAW,IAAA,CAAK,MAAA,EAAQ;AAClC,MAAA,IAAI,CAAC,gBAAA,CAAiB,KAAA,CAAM,IAAI,CAAA,EAAG;AACnC,MAAA,KAAA,MAAW,EAAA,IAAM,KAAK,QAAA,EAAU;AAC9B,QAAA,IAAI;AACF,UAAA,EAAA,CAAG,KAAA,CAAM,KAAK,OAAO,CAAA;AAAA,QACvB,SAAS,GAAA,EAAK;AACZ,UAAA,OAAA,CAAQ,KAAA,CAAM,8CAA8C,GAAG,CAAA;AAAA,QACjE;AAAA,MACF;AAAA,IACF,CAAA;AACA,IAAA,IAAA,CAAK,MAAA,CAAO,gBAAA,CAAiB,SAAA,EAAW,IAAA,CAAK,QAAQ,CAAA;AAAA,EACvD;AAAA,EAEA,KAAK,QAAA,EAAgC;AACnC,IAAA,IAAI,KAAK,MAAA,EAAQ;AACjB,IAAA,MAAM,UAA0B,EAAE,CAAC,YAAY,GAAG,gBAAA,EAAkB,SAAS,QAAA,EAAS;AACtF,IAAA,IAAA,CAAK,MAAA,CAAO,WAAA,CAAY,OAAA,EAAS,IAAA,CAAK,YAAY,CAAA;AAAA,EACpD;AAAA,EAEA,UAAU,OAAA,EAAyD;AACjE,IAAA,IAAA,CAAK,QAAA,CAAS,IAAI,OAAO,CAAA;AACzB,IAAA,OAAO,MAAM,IAAA,CAAK,QAAA,CAAS,MAAA,CAAO,OAAO,CAAA;AAAA,EAC3C;AAAA,EAEA,KAAA,GAAc;AACZ,IAAA,IAAI,KAAK,MAAA,EAAQ;AACjB,IAAA,IAAA,CAAK,MAAA,GAAS,IAAA;AACd,IAAA,IAAA,CAAK,MAAA,CAAO,mBAAA,CAAoB,SAAA,EAAW,IAAA,CAAK,QAAQ,CAAA;AACxD,IAAA,IAAA,CAAK,SAAS,KAAA,EAAM;AAAA,EACtB;AACF;AAeO,IAAM,uBAAN,MAAsD;AAAA,EAC3D,WAAA,GAAc;AACZ,IAAA,MAAM,IAAI,KAAA;AAAA,MACR;AAAA,KAGF;AAAA,EACF;AAAA,EACA,IAAA,GAAa;AACX,IAAA,MAAM,IAAI,MAAM,uCAAuC,CAAA;AAAA,EACzD;AAAA,EACA,SAAA,GAAwB;AACtB,IAAA,MAAM,IAAI,MAAM,uCAAuC,CAAA;AAAA,EACzD;AAAA,EACA,KAAA,GAAc;AAAA,EAEd;AACF;AAcO,IAAM,mBAAN,MAAuB;AAAA,EAK5B,YACmB,GAAA,EACA,MAAA,EACA,SAAA,EACjB,OAAA,GAAmC,EAAC,EACpC;AAJiB,IAAA,IAAA,CAAA,GAAA,GAAA,GAAA;AACA,IAAA,IAAA,CAAA,MAAA,GAAA,MAAA;AACA,IAAA,IAAA,CAAA,SAAA,GAAA,SAAA;AAGjB,IAAA,IAAA,CAAK,OAAA,GAAU,IAAI,GAAA,CAAI,OAAA,CAAQ,iBAAiB,wBAAwB,CAAA;AACxE,IAAA,IAAA,CAAK,YAAA,EAAa;AAClB,IAAA,IAAA,CAAK,WAAA,EAAY;AAAA,EACnB;AAAA,EARmB,GAAA;AAAA,EACA,MAAA;AAAA,EACA,SAAA;AAAA,EAPF,OAAA;AAAA,EACA,SAA4B,EAAC;AAAA,EACtC,YAAA,GAAoC,IAAA;AAAA,EAa5C,KAAA,GAAc;AACZ,IAAA,KAAA,MAAW,GAAA,IAAO,IAAA,CAAK,MAAA,EAAQ,GAAA,EAAI;AACnC,IAAA,IAAA,CAAK,OAAO,MAAA,GAAS,CAAA;AACrB,IAAA,IAAA,CAAK,YAAA,IAAe;AACpB,IAAA,IAAA,CAAK,UAAU,KAAA,EAAM;AAAA,EACvB;AAAA,EAEQ,YAAA,GAAqB;AAC3B,IAAA,KAAA,MAAW,IAAA,IAAQ,KAAK,OAAA,EAAS;AAC/B,MAAA,MAAM,MAAM,IAAA,CAAK,GAAA,CAAI,EAAA,CAAG,IAAA,EAAM,CAAC,OAAA,KAAY;AACzC,QAAA,IAAA,CAAK,UAAU,IAAA,CAAK,EAAE,MAAM,OAAA,EAAS,IAAA,EAAM,SAAS,CAAA;AAAA,MACtD,CAAC,CAAA;AACD,MAAA,IAAA,CAAK,MAAA,CAAO,KAAK,GAAG,CAAA;AAAA,IACtB;AAAA,EACF;AAAA,EAEQ,WAAA,GAAoB;AAC1B,IAAA,IAAA,CAAK,YAAA,GAAe,IAAA,CAAK,SAAA,CAAU,SAAA,CAAU,CAAC,QAAA,KAAa;AACzD,MAAA,IAAI,QAAA,CAAS,SAAS,SAAA,EAAW;AACjC,MAAA,IAAA,CAAK,YAAA,CAAa,QAAA,CAAS,IAAA,EAAM,QAAA,CAAS,IAAI,EAC3C,IAAA,CAAK,MAAM,IAAA,CAAK,SAAA,CAAU,IAAA,CAAK,EAAE,MAAM,KAAA,EAAO,EAAA,EAAI,QAAA,CAAS,EAAA,EAAI,EAAA,EAAI,IAAA,EAAM,CAAC,CAAA,CAC1E,KAAA,CAAM,CAAC,GAAA,KAAiB;AACvB,QAAA,MAAM,UAAU,GAAA,YAAe,KAAA,GAAQ,GAAA,CAAI,OAAA,GAAU,OAAO,GAAG,CAAA;AAC/D,QAAA,IAAA,CAAK,SAAA,CAAU,IAAA,CAAK,EAAE,IAAA,EAAM,KAAA,EAAO,EAAA,EAAI,QAAA,CAAS,EAAA,EAAI,EAAA,EAAI,KAAA,EAAO,KAAA,EAAO,OAAA,EAAS,CAAA;AAAA,MACjF,CAAC,CAAA;AAAA,IACL,CAAC,CAAA;AAAA,EACH;AAAA,EAEA,MAAc,YAAA,CAAa,IAAA,EAAyB,IAAA,EAA8B;AAChF,IAAA,QAAQ,IAAA;AAAM,MACZ,KAAK,MAAA;AACH,QAAA,MAAM,IAAA,CAAK,OAAO,IAAA,EAAK;AACvB,QAAA;AAAA,MACF,KAAK,OAAA;AACH,QAAA,IAAA,CAAK,OAAO,KAAA,EAAM;AAClB,QAAA;AAAA,MACF,KAAK,MAAA,EAAQ;AACX,QAAA,MAAM,CAAA,GAAI,IAAA;AACV,QAAA,IAAI,OAAO,GAAG,EAAA,KAAO,QAAA,IAAY,CAAC,MAAA,CAAO,QAAA,CAAS,CAAA,CAAE,EAAE,CAAA,EAAG;AACvD,UAAA,MAAM,IAAI,MAAM,wCAAwC,CAAA;AAAA,QAC1D;AACA,QAAA,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,CAAA,CAAE,EAAE,CAAA;AACrB,QAAA;AAAA,MACF;AAAA,MACA,KAAK,WAAA,EAAa;AAChB,QAAA,MAAM,CAAA,GAAI,IAAA;AACV,QAAA,IAAI,OAAO,GAAG,MAAA,KAAW,QAAA,IAAY,CAAC,MAAA,CAAO,QAAA,CAAS,CAAA,CAAE,MAAM,CAAA,EAAG;AAC/D,UAAA,MAAM,IAAI,MAAM,iDAAiD,CAAA;AAAA,QACnE;AACA,QAAA,IAAA,CAAK,MAAA,CAAO,SAAA,CAAU,CAAA,CAAE,MAAM,CAAA;AAC9B,QAAA;AAAA,MACF;AAAA,MACA,KAAK,MAAA;AAIH,QAAA,MAAM,IAAI,MAAM,+BAA+B,CAAA;AAAA,MACjD,SAAS;AACP,QAAA,MAAM,UAAA,GAAoB,IAAA;AAC1B,QAAA,MAAM,IAAI,KAAA,CAAM,CAAA,wBAAA,EAA2B,MAAA,CAAO,UAAU,CAAC,CAAA,CAAE,CAAA;AAAA,MACjE;AAAA;AACF,EACF;AACF;AAOA,IAAM,wBAAA,GAA8D;AAAA,EAClE,aAAA;AAAA,EACA,cAAA;AAAA,EACA,mBAAA;AAAA,EACA,cAAA;AAAA,EACA,cAAA;AAAA,EACA,qBAAA;AAAA,EACA,oBAAA;AAAA,EACA,gBAAA;AAAA,EACA;AACF,CAAA;AAGO,SAAS,YAAA,GAAuB;AACrC,EAAA,OAAO,MAAA,EAAO;AAChB;;;AC5PO,IAAM,WAAN,MAAmC;AAAA,EACvB,SAAA,uBAAgB,GAAA,EAAqC;AAAA;AAAA;AAAA;AAAA,EAKtE,EAAA,CAAsB,MAAS,EAAA,EAAgC;AAC7D,IAAA,IAAI,GAAA,GAAM,IAAA,CAAK,SAAA,CAAU,GAAA,CAAI,IAAI,CAAA;AACjC,IAAA,IAAI,CAAC,GAAA,EAAK;AACR,MAAA,GAAA,uBAAU,GAAA,EAAI;AACd,MAAA,IAAA,CAAK,SAAA,CAAU,GAAA,CAAI,IAAA,EAAM,GAAG,CAAA;AAAA,IAC9B;AACA,IAAA,GAAA,CAAI,IAAI,EAAuB,CAAA;AAC/B,IAAA,OAAO,MAAM;AACX,MAAA,MAAM,CAAA,GAAI,IAAA,CAAK,SAAA,CAAU,GAAA,CAAI,IAAI,CAAA;AACjC,MAAA,CAAA,EAAG,OAAO,EAAuB,CAAA;AACjC,MAAA,IAAI,CAAA,IAAK,CAAA,CAAE,IAAA,KAAS,CAAA,EAAG;AACrB,QAAA,IAAA,CAAK,SAAA,CAAU,OAAO,IAAI,CAAA;AAAA,MAC5B;AAAA,IACF,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,IAAA,CAAwB,MAAS,EAAA,EAAgC;AAC/D,IAAA,MAAM,GAAA,GAAM,IAAA,CAAK,EAAA,CAAG,IAAA,EAAM,CAAC,OAAA,KAAY;AACrC,MAAA,GAAA,EAAI;AACJ,MAAA,EAAA,CAAG,OAAO,CAAA;AAAA,IACZ,CAAC,CAAA;AACD,IAAA,OAAO,GAAA;AAAA,EACT;AAAA;AAAA;AAAA;AAAA;AAAA,EAMA,IAAA,CAAwB,MAAS,OAAA,EAAqB;AACpD,IAAA,MAAM,GAAA,GAAM,IAAA,CAAK,SAAA,CAAU,GAAA,CAAI,IAAI,CAAA;AACnC,IAAA,IAAI,CAAC,GAAA,IAAO,GAAA,CAAI,IAAA,KAAS,CAAA,EAAG;AAE5B,IAAA,KAAA,MAAW,EAAA,IAAM,KAAA,CAAM,IAAA,CAAK,GAAG,CAAA,EAAG;AAChC,MAAA,IAAI;AACF,QAAA;AAAC,QAAC,GAAsB,OAAO,CAAA;AAAA,MACjC,SAAS,GAAA,EAAK;AACZ,QAAA,OAAA,CAAQ,MAAM,CAAA,oCAAA,EAAuC,MAAA,CAAO,IAAI,CAAC,WAAW,GAAG,CAAA;AAAA,MACjF;AAAA,IACF;AAAA,EACF;AAAA;AAAA,EAGA,cAAiC,IAAA,EAAiB;AAChD,IAAA,OAAO,IAAA,CAAK,SAAA,CAAU,GAAA,CAAI,IAAI,GAAG,IAAA,IAAQ,CAAA;AAAA,EAC3C;AAAA;AAAA,EAGA,KAAA,GAAc;AACZ,IAAA,IAAA,CAAK,UAAU,KAAA,EAAM;AAAA,EACvB;AACF;;;ACxCA,IAAM,QAAA,GAAuC;AAAA,EAC3C,UAAA,EAAY,GAAA;AAAA,EACZ,QAAA,EAAU,WAAA;AAAA,EACV,WAAA,EAAa,YAAA;AAAA,EACb,QAAA,EAAU,SAAA;AAAA,EACV,UAAA,EAAY,WAAA;AAAA,EACZ,SAAA,EAAW,GAAA;AAAA,EACX,SAAA,EAAW;AACb,CAAA;AAWO,IAAM,qBAAN,MAAyB;AAAA,EAU9B,WAAA,CACmB,MAAA,EACA,KAAA,EACjB,OAAA,GAAqC,EAAC,EACtC;AAHiB,IAAA,IAAA,CAAA,MAAA,GAAA,MAAA;AACA,IAAA,IAAA,CAAA,KAAA,GAAA,KAAA;AAGjB,IAAA,IAAA,CAAK,WAAA,GAAc,QAAQ,WAAA,IAAe,CAAA;AAC1C,IAAA,IAAA,CAAK,UAAA,GAAa,QAAQ,UAAA,IAAc,GAAA;AACxC,IAAA,IAAA,CAAK,cAAA,GAAiB,QAAQ,cAAA,IAAkB,KAAA;AAChD,IAAA,IAAA,CAAK,YAAA,GAAe,QAAQ,YAAA,IAAgB,UAAA;AAC5C,IAAA,IAAA,CAAK,WAAW,EAAE,GAAG,QAAA,EAAU,GAAG,QAAQ,QAAA,EAAS;AAAA,EACrD;AAAA,EATmB,MAAA;AAAA,EACA,KAAA;AAAA,EAXX,QAAA,GAAW,KAAA;AAAA,EACX,OAAA,GAAgC,IAAA;AAAA,EAChC,MAAA;AAAA,EACS,QAAA;AAAA,EACA,WAAA;AAAA,EACA,UAAA;AAAA,EACA,cAAA;AAAA,EACA,YAAA;AAAA,EAcjB,OAAO,MAAA,EAA4B;AACjC,IAAA,IAAI,KAAK,QAAA,EAAU;AACnB,IAAA,IAAA,CAAK,QAAA,GAAW,IAAA;AAChB,IAAA,IAAA,CAAK,OAAA,GAAU,CAAC,KAAA,KAAiB,IAAA,CAAK,MAAM,KAAsB,CAAA;AAClE,IAAA,IAAA,CAAK,MAAA,GAAS,UAAU,IAAA,CAAK,YAAA;AAC7B,IAAA,IAAA,CAAK,MAAA,CAAO,gBAAA,CAAiB,SAAA,EAAW,IAAA,CAAK,OAAO,CAAA;AAAA,EACtD;AAAA,EAEA,MAAA,GAAe;AACb,IAAA,IAAI,CAAC,IAAA,CAAK,QAAA,IAAY,CAAC,KAAK,OAAA,EAAS;AACrC,IAAA,IAAA,CAAK,MAAA,EAAQ,mBAAA,CAAoB,SAAA,EAAW,IAAA,CAAK,OAAO,CAAA;AACxD,IAAA,IAAA,CAAK,OAAA,GAAU,IAAA;AACf,IAAA,IAAA,CAAK,MAAA,GAAS,MAAA;AACd,IAAA,IAAA,CAAK,QAAA,GAAW,KAAA;AAAA,EAClB;AAAA,EAEQ,MAAM,KAAA,EAA4B;AAGxC,IAAA,IAAI,MAAM,WAAA,EAAa;AACvB,IAAA,IAAI,KAAA,CAAM,OAAA,IAAW,KAAA,CAAM,OAAA,IAAW,MAAM,MAAA,EAAQ;AAEpD,IAAA,IAAI,KAAK,cAAA,EAAgB;AACvB,MAAA,MAAMA,GAAAA,GAAK,IAAA,CAAK,MAAA,CAAO,UAAA,EAAW;AAClC,MAAA,IAAI,CAACA,GAAAA,IAAM,QAAA,CAAS,aAAA,KAAkBA,GAAAA,EAAI;AAAA,IAC5C;AAEA,IAAA,MAAM,IAAI,KAAA,CAAM,MAAA;AAChB,IAAA,IAAI,GAAG,OAAA,KAAY,OAAA,IAAW,GAAG,OAAA,KAAY,UAAA,IAAc,GAAG,iBAAA,EAAmB;AAC/E,MAAA;AAAA,IACF;AACA,IAAA,MAAM,EAAA,GAAK,IAAA,CAAK,MAAA,CAAO,UAAA,EAAW;AAClC,IAAA,IAAI,CAAC,EAAA,EAAI;AAET,IAAA,QAAQ,MAAM,GAAA;AAAK,MACjB,KAAK,KAAK,QAAA,CAAS,UAAA;AACjB,QAAA,KAAA,CAAM,cAAA,EAAe;AACrB,QAAA,IAAI,GAAG,MAAA,EAAQ;AACb,UAAA,KAAK,IAAA,CAAK,OAAO,IAAA,EAAK;AAAA,QACxB,CAAA,MAAO;AACL,UAAA,IAAA,CAAK,OAAO,KAAA,EAAM;AAAA,QACpB;AACA,QAAA;AAAA,MACF,KAAK,KAAK,QAAA,CAAS,QAAA;AACjB,QAAA,KAAA,CAAM,cAAA,EAAe;AACrB,QAAA,IAAA,CAAK,MAAA,CAAO,KAAK,IAAA,CAAK,GAAA,CAAI,GAAG,EAAA,CAAG,WAAA,GAAc,IAAA,CAAK,WAAW,CAAC,CAAA;AAC/D,QAAA;AAAA,MACF,KAAK,KAAK,QAAA,CAAS,WAAA;AACjB,QAAA,KAAA,CAAM,cAAA,EAAe;AACrB,QAAA,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,EAAA,CAAG,WAAA,GAAc,KAAK,WAAW,CAAA;AAClD,QAAA;AAAA,MACF,KAAK,KAAK,QAAA,CAAS,QAAA;AACjB,QAAA,KAAA,CAAM,cAAA,EAAe;AACrB,QAAA,IAAA,CAAK,MAAA,CAAO,UAAU,IAAA,CAAK,GAAA,CAAI,GAAG,EAAA,CAAG,MAAA,GAAS,IAAA,CAAK,UAAU,CAAC,CAAA;AAC9D,QAAA;AAAA,MACF,KAAK,KAAK,QAAA,CAAS,UAAA;AACjB,QAAA,KAAA,CAAM,cAAA,EAAe;AACrB,QAAA,IAAA,CAAK,MAAA,CAAO,UAAU,IAAA,CAAK,GAAA,CAAI,GAAG,EAAA,CAAG,MAAA,GAAS,IAAA,CAAK,UAAU,CAAC,CAAA;AAC9D,QAAA;AAAA,MACF,KAAK,KAAK,QAAA,CAAS,SAAA;AACjB,QAAA,KAAA,CAAM,cAAA,EAAe;AACrB,QAAA,IAAA,CAAK,MAAM,IAAA,EAAK;AAChB,QAAA;AAAA,MACF,KAAK,KAAK,QAAA,CAAS,SAAA;AACjB,QAAA,KAAA,CAAM,cAAA,EAAe;AACrB,QAAA,IAAA,CAAK,MAAM,IAAA,EAAK;AAChB,QAAA;AAAA;AACJ,EACF;AACF;;;AC1IO,IAAM,YAAA,GAAN,MAAM,aAAA,CAAa;AAAA,EAmBxB,YAA6B,GAAA,EAA6B;AAA7B,IAAA,IAAA,CAAA,GAAA,GAAA,GAAA;AAAA,EAA8B;AAAA,EAA9B,GAAA;AAAA;AAAA,EAjB7B,OAAgB,SAAA,GAAY,CAAA;AAAA;AAAA,EAE5B,OAAgB,OAAO,MAAA,CAAO,iBAAA;AAAA,EAEtB,SAAqB,EAAC;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAOtB,YAAsB,EAAC;AAAA,EACvB,KAAA,GAAQ,EAAA;AAAA,EACR,MAAA,GAAqB,KAAA;AAAA,EACrB,cAAA,GAAiB,KAAA;AAAA,EACjB,eAAyB,EAAC;AAAA;AAAA,EAMlC,IAAA,CAAK,MAAA,EAAoB,UAAA,GAAa,CAAA,EAAS;AAC7C,IAAA,IAAI,MAAA,CAAO,WAAW,CAAA,EAAG;AACvB,MAAA,MAAM,IAAI,MAAM,6CAA6C,CAAA;AAAA,IAC/D;AACA,IAAA,IAAI,UAAA,GAAa,CAAA,IAAK,UAAA,IAAc,MAAA,CAAO,MAAA,EAAQ;AACjD,MAAA,MAAM,IAAI,KAAA,CAAM,CAAA,8BAAA,EAAiC,UAAU,CAAA,aAAA,CAAe,CAAA;AAAA,IAC5E;AACA,IAAA,MAAM,QAAA,GAAW,KAAK,OAAA,EAAQ;AAC9B,IAAA,IAAA,CAAK,MAAA,GAAS,CAAC,GAAG,MAAM,CAAA;AACxB,IAAA,IAAA,CAAK,SAAA,GAAY,MAAA,CAAO,GAAA,CAAI,MAAM,CAAC,CAAA;AACnC,IAAA,IAAA,CAAK,mBAAA,EAAoB;AACzB,IAAA,IAAA,CAAK,KAAA,GAAQ,UAAA;AACb,IAAA,MAAM,IAAA,GAAO,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,KAAK,CAAA;AACnC,IAAA,IAAI,IAAA,EAAM;AACR,MAAA,IAAA,CAAK,GAAA,CAAI,IAAA,CAAK,oBAAA,EAAsB,EAAE,IAAA,EAAM,UAAU,EAAA,EAAI,IAAA,EAAM,MAAA,EAAQ,MAAA,EAAQ,CAAA;AAAA,IAClF;AAAA,EACF;AAAA,EAEA,MAAA,CAAO,KAAA,EAAiB,KAAA,GAAQ,CAAA,EAAS;AACvC,IAAA,IAAA,CAAK,MAAA,CAAO,KAAK,KAAK,CAAA;AACtB,IAAA,IAAA,CAAK,SAAA,CAAU,KAAK,IAAA,CAAK,GAAA,CAAI,GAAG,IAAA,CAAK,KAAA,CAAM,KAAK,CAAC,CAAC,CAAA;AAClD,IAAA,IAAI,KAAK,cAAA,EAAgB;AAIvB,MAAA,MAAM,MAAA,GAAS,IAAA,CAAK,YAAA,CAAa,OAAA,CAAQ,KAAK,KAAK,CAAA;AACnD,MAAA,MAAM,YAAY,MAAA,GAAS,CAAA;AAC3B,MAAA,MAAM,KAAA,GAAQ,IAAA,CAAK,YAAA,CAAa,MAAA,GAAS,CAAA,GAAI,SAAA;AAC7C,MAAA,MAAM,KAAK,SAAA,GAAY,IAAA,CAAK,MAAM,IAAA,CAAK,MAAA,KAAW,KAAK,CAAA;AACvD,MAAA,IAAA,CAAK,aAAa,MAAA,CAAO,EAAA,EAAI,GAAG,IAAA,CAAK,MAAA,CAAO,SAAS,CAAC,CAAA;AAAA,IACxD;AAAA,EACF;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAOA,WAAW,KAAA,EAAuB;AAChC,IAAA,IAAI,IAAA,CAAK,MAAA,CAAO,MAAA,KAAW,CAAA,EAAG;AAC5B,MAAA,IAAA,CAAK,OAAO,KAAK,CAAA;AACjB,MAAA;AAAA,IACF;AACA,IAAA,MAAM,EAAA,GAAK,KAAK,KAAA,GAAQ,CAAA;AACxB,IAAA,IAAA,CAAK,MAAA,CAAO,MAAA,CAAO,EAAA,EAAI,CAAA,EAAG,KAAK,CAAA;AAC/B,IAAA,IAAA,CAAK,SAAA,CAAU,MAAA,CAAO,EAAA,EAAI,CAAA,EAAG,CAAC,CAAA;AAC9B,IAAA,IAAI,KAAK,cAAA,EAAgB;AAGvB,MAAA,IAAA,CAAK,YAAA,GAAe,IAAA,CAAK,YAAA,CAAa,GAAA,CAAI,CAAC,MAAO,CAAA,IAAK,EAAA,GAAK,CAAA,GAAI,CAAA,GAAI,CAAE,CAAA;AACtE,MAAA,MAAM,MAAA,GAAS,IAAA,CAAK,YAAA,CAAa,OAAA,CAAQ,KAAK,KAAK,CAAA;AACnD,MAAA,IAAA,CAAK,YAAA,CAAa,MAAA,CAAO,MAAA,GAAS,CAAA,EAAG,GAAG,EAAE,CAAA;AAAA,IAC5C;AAAA,EACF;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAYA,OAAO,KAAA,EAAgC;AACrC,IAAA,IAAI,QAAQ,CAAA,IAAK,KAAA,IAAS,IAAA,CAAK,MAAA,CAAO,QAAQ,OAAO,IAAA;AACrD,IAAA,MAAM,OAAA,GAAU,IAAA,CAAK,MAAA,CAAO,KAAK,CAAA;AACjC,IAAA,MAAM,UAAA,GAAa,UAAU,IAAA,CAAK,KAAA;AAClC,IAAA,MAAM,SAAS,IAAA,CAAK,cAAA,GAAiB,KAAK,YAAA,CAAa,OAAA,CAAQ,KAAK,CAAA,GAAI,EAAA;AAExE,IAAA,IAAA,CAAK,MAAA,CAAO,MAAA,CAAO,KAAA,EAAO,CAAC,CAAA;AAC3B,IAAA,IAAA,CAAK,SAAA,CAAU,MAAA,CAAO,KAAA,EAAO,CAAC,CAAA;AAC9B,IAAA,IAAA,CAAK,eAAe,IAAA,CAAK,YAAA,CACtB,MAAA,CAAO,CAAC,MAAM,CAAA,KAAM,KAAK,CAAA,CACzB,GAAA,CAAI,CAAC,CAAA,KAAO,CAAA,GAAI,KAAA,GAAQ,CAAA,GAAI,IAAI,CAAE,CAAA;AAErC,IAAA,IAAI,IAAA,CAAK,MAAA,CAAO,MAAA,KAAW,CAAA,EAAG;AAC5B,MAAA,IAAA,CAAK,KAAA,GAAQ,EAAA;AACb,MAAA,IAAA,CAAK,IAAI,IAAA,CAAK,gBAAA,EAAkB,EAAE,SAAA,EAAW,SAAS,CAAA;AACtD,MAAA,OAAO,OAAA;AAAA,IACT;AACA,IAAA,IAAI,CAAC,UAAA,EAAY;AACf,MAAA,IAAI,KAAA,GAAQ,IAAA,CAAK,KAAA,EAAO,IAAA,CAAK,KAAA,IAAS,CAAA;AACtC,MAAA,OAAO,OAAA;AAAA,IACT;AAEA,IAAA,MAAM,EAAA,GAAK,KAAK,cAAA,GACX,IAAA,CAAK,aAAa,IAAA,CAAK,GAAA,CAAI,QAAQ,IAAA,CAAK,YAAA,CAAa,SAAS,CAAC,CAAC,IACjE,IAAA,CAAK,GAAA,CAAI,OAAO,IAAA,CAAK,MAAA,CAAO,SAAS,CAAC,CAAA;AAC1C,IAAA,IAAA,CAAK,KAAA,GAAQ,EAAA;AACb,IAAA,IAAA,CAAK,GAAA,CAAI,IAAA,CAAK,oBAAA,EAAsB,EAAE,IAAA,EAAM,OAAA,EAAS,EAAA,EAAI,IAAA,CAAK,MAAA,CAAO,EAAE,CAAA,EAAe,MAAA,EAAQ,QAAQ,CAAA;AACtG,IAAA,OAAO,OAAA;AAAA,EACT;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAUA,OAAA,CAAQ,KAAA,EAAe,CAAA,GAAI,CAAA,EAAW;AACpC,IAAA,IAAI,QAAQ,CAAA,IAAK,KAAA,IAAS,IAAA,CAAK,MAAA,CAAO,QAAQ,OAAO,CAAA;AACrD,IAAA,MAAM,IAAA,GAAO,IAAA,CAAK,SAAA,CAAU,KAAK,CAAA,IAAK,CAAA;AACtC,IAAA,IAAI,IAAA,IAAQ,cAAa,SAAA,EAAW;AAClC,MAAA,IAAA,CAAK,SAAA,CAAU,KAAK,CAAA,GAAI,aAAA,CAAa,IAAA;AACrC,MAAA,OAAO,aAAA,CAAa,IAAA;AAAA,IACtB;AACA,IAAA,MAAM,IAAA,GAAO,IAAA,CAAK,GAAA,CAAI,aAAA,CAAa,SAAA,EAAW,IAAA,GAAO,IAAA,CAAK,GAAA,CAAI,CAAA,EAAG,IAAA,CAAK,KAAA,CAAM,CAAC,CAAC,CAAC,CAAA;AAC/E,IAAA,IAAA,CAAK,SAAA,CAAU,KAAK,CAAA,GAAI,IAAA;AACxB,IAAA,OAAO,IAAA;AAAA,EACT;AAAA;AAAA,EAGA,QAAA,CAAS,OAAe,CAAA,EAAiB;AACvC,IAAA,IAAI,KAAA,GAAQ,CAAA,IAAK,KAAA,IAAS,IAAA,CAAK,OAAO,MAAA,EAAQ;AAC9C,IAAA,IAAA,CAAK,SAAA,CAAU,KAAK,CAAA,GAAI,CAAA,KAAM,cAAa,IAAA,GAAO,aAAA,CAAa,IAAA,GAAO,IAAA,CAAK,GAAA,CAAI,CAAA,EAAG,IAAA,CAAK,KAAA,CAAM,CAAC,CAAC,CAAA;AAAA,EACjG;AAAA;AAAA,EAGA,UAAU,KAAA,EAAwB;AAChC,IAAA,OAAO,IAAA,CAAK,SAAA,CAAU,KAAK,CAAA,KAAM,aAAA,CAAa,IAAA;AAAA,EAChD;AAAA;AAAA,EAGA,QAAQ,KAAA,EAAuB;AAC7B,IAAA,OAAO,IAAA,CAAK,SAAA,CAAU,KAAK,CAAA,IAAK,CAAA;AAAA,EAClC;AAAA;AAAA,EAGA,QAAQ,SAAA,EAA2B;AACjC,IAAA,OAAO,KAAK,MAAA,CAAO,SAAA,CAAU,CAAC,CAAA,KAAM,CAAA,CAAE,cAAc,SAAS,CAAA;AAAA,EAC/D;AAAA,EAEA,KAAA,GAAc;AACZ,IAAA,IAAA,CAAK,SAAS,EAAC;AACf,IAAA,IAAA,CAAK,YAAY,EAAC;AAClB,IAAA,IAAA,CAAK,eAAe,EAAC;AACrB,IAAA,IAAA,CAAK,KAAA,GAAQ,EAAA;AAAA,EACf;AAAA;AAAA,EAIA,OAAA,GAA2B;AACzB,IAAA,OAAO,IAAA,CAAK,SAAS,CAAA,GAAK,IAAA,CAAK,OAAO,IAAA,CAAK,KAAK,KAAK,IAAA,GAAQ,IAAA;AAAA,EAC/D;AAAA,EAEA,IAAA,GAAe;AACb,IAAA,OAAO,KAAK,MAAA,CAAO,MAAA;AAAA,EACrB;AAAA,EAEA,QAAA,GAAmB;AACjB,IAAA,OAAO,IAAA,CAAK,KAAA;AAAA,EACd;AAAA;AAAA,EAIA,UAAU,IAAA,EAAwB;AAChC,IAAA,IAAA,CAAK,MAAA,GAAS,IAAA;AAAA,EAChB;AAAA,EAEA,WAAW,OAAA,EAAwB;AACjC,IAAA,IAAA,CAAK,cAAA,GAAiB,OAAA;AACtB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,IAAA,CAAK,mBAAA,EAAoB;AAAA,IAC3B;AAAA,EACF;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAQA,IAAA,CAAK,SAA4B,MAAA,EAAyB;AACxD,IAAA,IAAI,IAAA,CAAK,MAAA,CAAO,MAAA,KAAW,CAAA,EAAG,OAAO,IAAA;AACrC,IAAA,MAAM,IAAA,GAAO,KAAK,OAAA,EAAQ;AAI1B,IAAA,IAAI,IAAA,CAAK,MAAA,KAAW,KAAA,IAAS,MAAA,KAAW,MAAA,EAAQ;AAC9C,MAAA,IAAI,IAAA,EAAM,IAAA,CAAK,GAAA,CAAI,IAAA,CAAK,oBAAA,EAAsB,EAAE,IAAA,EAAM,EAAA,EAAI,IAAA,EAAM,MAAA,EAAQ,CAAA;AACxE,MAAA,OAAO,IAAA;AAAA,IACT;AAMA,IAAA,IAAI,MAAA,KAAW,WAAW,IAAA,CAAK,SAAA,CAAU,KAAK,KAAK,CAAA,IAAK,KAAK,CAAA,EAAG;AAE9D,MAAA,IAAI,KAAK,SAAA,CAAU,IAAA,CAAK,KAAK,CAAA,KAAM,cAAa,IAAA,EAAM;AACpD,QAAA,IAAA,CAAK,SAAA,CAAU,KAAK,KAAK,CAAA,GAAA,CAAK,KAAK,SAAA,CAAU,IAAA,CAAK,KAAK,CAAA,IAAK,CAAA,IAAK,CAAA;AAAA,MACnE;AACA,MAAA,IAAI,IAAA,EAAM,IAAA,CAAK,GAAA,CAAI,IAAA,CAAK,oBAAA,EAAsB,EAAE,IAAA,EAAM,EAAA,EAAI,IAAA,EAAM,MAAA,EAAQ,CAAA;AACxE,MAAA,OAAO,IAAA;AAAA,IACT;AACA,IAAA,IAAI,KAAK,KAAA,IAAS,CAAA,OAAQ,SAAA,CAAU,IAAA,CAAK,KAAK,CAAA,GAAI,CAAA;AAElD,IAAA,MAAM,SAAA,GAAY,IAAA,CAAK,YAAA,CAAa,CAAE,CAAA;AACtC,IAAA,IAAI,cAAc,EAAA,EAAI;AACpB,MAAA,IAAI,IAAA,OAAW,GAAA,CAAI,IAAA,CAAK,kBAAkB,EAAE,SAAA,EAAW,MAAM,CAAA;AAC7D,MAAA,OAAO,IAAA;AAAA,IACT;AACA,IAAA,IAAA,CAAK,KAAA,GAAQ,SAAA;AACb,IAAA,MAAM,EAAA,GAAK,IAAA,CAAK,MAAA,CAAO,SAAS,CAAA;AAChC,IAAA,IAAA,CAAK,IAAI,IAAA,CAAK,oBAAA,EAAsB,EAAE,IAAA,EAAM,EAAA,EAAI,QAAQ,CAAA;AACxD,IAAA,OAAO,EAAA;AAAA,EACT;AAAA,EAEA,IAAA,CAAK,SAA4B,MAAA,EAAyB;AACxD,IAAA,IAAI,IAAA,CAAK,MAAA,CAAO,MAAA,KAAW,CAAA,EAAG,OAAO,IAAA;AACrC,IAAA,MAAM,IAAA,GAAO,KAAK,OAAA,EAAQ;AAC1B,IAAA,MAAM,SAAA,GAAY,IAAA,CAAK,YAAA,CAAa,EAAE,CAAA;AACtC,IAAA,IAAI,SAAA,KAAc,IAAI,OAAO,IAAA;AAC7B,IAAA,IAAA,CAAK,SAAA,CAAU,IAAA,CAAK,KAAK,CAAA,GAAI,CAAA;AAC7B,IAAA,IAAA,CAAK,KAAA,GAAQ,SAAA;AACb,IAAA,MAAM,EAAA,GAAK,IAAA,CAAK,MAAA,CAAO,SAAS,CAAA;AAChC,IAAA,IAAA,CAAK,IAAI,IAAA,CAAK,oBAAA,EAAsB,EAAE,IAAA,EAAM,EAAA,EAAI,QAAQ,CAAA;AACxD,IAAA,OAAO,EAAA;AAAA,EACT;AAAA;AAAA,EAGA,MAAA,CAAO,KAAA,EAAe,MAAA,GAA4B,MAAA,EAAkB;AAClE,IAAA,IAAI,KAAA,GAAQ,CAAA,IAAK,KAAA,IAAS,IAAA,CAAK,OAAO,MAAA,EAAQ;AAC5C,MAAA,MAAM,IAAI,KAAA,CAAM,CAAA,2BAAA,EAA8B,KAAK,CAAA,aAAA,CAAe,CAAA;AAAA,IACpE;AACA,IAAA,MAAM,IAAA,GAAO,KAAK,OAAA,EAAQ;AAC1B,IAAA,IAAI,IAAA,CAAK,KAAA,IAAS,CAAA,IAAK,IAAA,CAAK,KAAA,KAAU,OAAO,IAAA,CAAK,SAAA,CAAU,IAAA,CAAK,KAAK,CAAA,GAAI,CAAA;AAC1E,IAAA,IAAA,CAAK,KAAA,GAAQ,KAAA;AACb,IAAA,MAAM,EAAA,GAAK,IAAA,CAAK,MAAA,CAAO,KAAK,CAAA;AAC5B,IAAA,IAAA,CAAK,IAAI,IAAA,CAAK,oBAAA,EAAsB,EAAE,IAAA,EAAM,EAAA,EAAI,QAAQ,CAAA;AACxD,IAAA,OAAO,EAAA;AAAA,EACT;AAAA;AAAA,EAIQ,aAAa,KAAA,EAAuB;AAC1C,IAAA,IAAI,KAAK,cAAA,EAAgB;AACvB,MAAA,MAAM,IAAA,GAAO,IAAA,CAAK,YAAA,CAAa,OAAA,CAAQ,KAAK,KAAK,CAAA;AACjD,MAAA,MAAMC,UAAS,IAAA,GAAO,KAAA;AACtB,MAAA,IAAIA,OAAAA,GAAS,GAAG,OAAO,EAAA;AACvB,MAAA,IAAIA,OAAAA,IAAU,IAAA,CAAK,YAAA,CAAa,MAAA,EAAQ;AACtC,QAAA,IAAI,IAAA,CAAK,MAAA,KAAW,KAAA,EAAO,OAAO,EAAA;AAElC,QAAA,IAAA,CAAK,mBAAA,EAAoB;AACzB,QAAA,OAAO,IAAA,CAAK,YAAA,CAAa,CAAC,CAAA,IAAK,EAAA;AAAA,MACjC;AACA,MAAA,OAAO,IAAA,CAAK,YAAA,CAAaA,OAAM,CAAA,IAAK,EAAA;AAAA,IACtC;AACA,IAAA,MAAM,MAAA,GAAS,KAAK,KAAA,GAAQ,KAAA;AAC5B,IAAA,IAAI,MAAA,GAAS,GAAG,OAAO,EAAA;AACvB,IAAA,IAAI,MAAA,IAAU,IAAA,CAAK,MAAA,CAAO,MAAA,EAAQ;AAChC,MAAA,OAAO,IAAA,CAAK,MAAA,KAAW,KAAA,GAAQ,CAAA,GAAI,EAAA;AAAA,IACrC;AACA,IAAA,OAAO,MAAA;AAAA,EACT;AAAA,EAEQ,mBAAA,GAA4B;AAClC,IAAA,MAAM,QAAQ,IAAA,CAAK,MAAA,CAAO,IAAI,CAAC,CAAA,EAAG,MAAM,CAAC,CAAA;AAGzC,IAAA,KAAA,IAAS,IAAI,KAAA,CAAM,MAAA,GAAS,CAAA,EAAG,CAAA,GAAI,GAAG,CAAA,EAAA,EAAK;AACzC,MAAA,MAAM,IAAI,IAAA,CAAK,KAAA,CAAM,KAAK,MAAA,EAAO,IAAK,IAAI,CAAA,CAAE,CAAA;AAC5C,MAAA,MAAM,CAAA,GAAI,MAAM,CAAC,CAAA;AACjB,MAAA,MAAM,CAAA,GAAI,MAAM,CAAC,CAAA;AACjB,MAAA,KAAA,CAAM,CAAC,CAAA,GAAI,CAAA;AACX,MAAA,KAAA,CAAM,CAAC,CAAA,GAAI,CAAA;AAAA,IACb;AACA,IAAA,IAAA,CAAK,YAAA,GAAe,KAAA;AAAA,EACtB;AACF;;;ACrSA,IAAM,cAAN,MAA2C;AAAA,EACxB,GAAA,uBAAU,GAAA,EAAoB;AAAA,EAC/C,IAAI,GAAA,EAA4B;AAC9B,IAAA,OAAO,IAAA,CAAK,GAAA,CAAI,GAAA,CAAI,GAAG,CAAA,IAAK,IAAA;AAAA,EAC9B;AAAA,EACA,GAAA,CAAI,KAAa,KAAA,EAAqB;AACpC,IAAA,IAAA,CAAK,GAAA,CAAI,GAAA,CAAI,GAAA,EAAK,KAAK,CAAA;AAAA,EACzB;AAAA,EACA,OAAO,GAAA,EAAmB;AACxB,IAAA,IAAA,CAAK,GAAA,CAAI,OAAO,GAAG,CAAA;AAAA,EACrB;AACF,CAAA;AAEA,IAAM,oBAAN,MAAiD;AAAA,EAC/C,YAA6B,OAAA,EAAkB;AAAlB,IAAA,IAAA,CAAA,OAAA,GAAA,OAAA;AAAA,EAAmB;AAAA,EAAnB,OAAA;AAAA,EAC7B,IAAI,GAAA,EAA4B;AAC9B,IAAA,IAAI;AACF,MAAA,OAAO,IAAA,CAAK,OAAA,CAAQ,OAAA,CAAQ,GAAG,CAAA;AAAA,IACjC,CAAA,CAAA,MAAQ;AACN,MAAA,OAAO,IAAA;AAAA,IACT;AAAA,EACF;AAAA,EACA,GAAA,CAAI,KAAa,KAAA,EAAqB;AACpC,IAAA,IAAI;AACF,MAAA,IAAA,CAAK,OAAA,CAAQ,OAAA,CAAQ,GAAA,EAAK,KAAK,CAAA;AAAA,IACjC,CAAA,CAAA,MAAQ;AAAA,IAGR;AAAA,EACF;AAAA,EACA,OAAO,GAAA,EAAmB;AACxB,IAAA,IAAI;AACF,MAAA,IAAA,CAAK,OAAA,CAAQ,WAAW,GAAG,CAAA;AAAA,IAC7B,CAAA,CAAA,MAAQ;AAAA,IAER;AAAA,EACF;AACF,CAAA;AAOO,SAAS,mBAAA,GAAqC;AACnD,EAAA,IAAI;AACF,IAAA,MAAM,IAAI,UAAA,CAAW,cAAA;AACrB,IAAA,IAAI,CAAA,EAAG;AAEL,MAAA,MAAM,KAAA,GAAQ,uBAAA;AACd,MAAA,CAAA,CAAE,OAAA,CAAQ,OAAO,GAAG,CAAA;AACpB,MAAA,CAAA,CAAE,WAAW,KAAK,CAAA;AAClB,MAAA,OAAO,IAAI,kBAAkB,CAAC,CAAA;AAAA,IAChC;AAAA,EACF,CAAA,CAAA,MAAQ;AAAA,EAER;AACA,EAAA,OAAO,IAAI,WAAA,EAAY;AACzB;;;ACnEA,IAAM,WAAA,GAAc,wBAAA;AAwCb,IAAM,iBAAN,MAAqB;AAAA,EAK1B,WAAA,CACmB,GAAA,EACjB,OAAA,GAAiC,EAAC,EAClC;AAFiB,IAAA,IAAA,CAAA,GAAA,GAAA,GAAA;AAGjB,IAAA,IAAA,CAAK,KAAA,GAAQ,OAAA,CAAQ,KAAA,IAAS,mBAAA,EAAoB;AAClD,IAAA,IAAA,CAAK,KAAA,GAAQ,QAAQ,KAAA,IAAS,WAAA;AAC9B,IAAA,IAAA,CAAK,OAAA,GAAU,QAAQ,aAAA,GACnB,IAAA,CAAK,UAAU,OAAA,CAAQ,aAAa,CAAA,GACpC,IAAA,CAAK,UAAA,EAAW;AAAA,EACtB;AAAA,EARmB,GAAA;AAAA,EALX,OAAA;AAAA,EACS,KAAA;AAAA,EACA,KAAA;AAAA;AAAA,EAcjB,YAAA,GAAuB;AACrB,IAAA,OAAO,KAAK,OAAA,CAAQ,SAAA;AAAA,EACtB;AAAA;AAAA,EAGA,UAAA,GAA0B;AACxB,IAAA,OAAO,EAAE,GAAG,IAAA,CAAK,OAAA,EAAQ;AAAA,EAC3B;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAQA,KAAA,GAAqB;AACnB,IAAA,MAAM,YAAA,GAAe,KAAK,OAAA,CAAQ,SAAA;AAClC,IAAA,MAAM,IAAA,GAAyB;AAAA,MAC7B,WAAW,MAAA,EAAO;AAAA,MAClB,SAAA,EAAW,IAAA,CAAK,KAAA,CAAM,MAAA,EAAO;AAAA,MAC7B,iBAAA,EAAmB;AAAA,KACrB;AACA,IAAA,IAAA,CAAK,OAAA,GAAU,IAAA;AACf,IAAA,IAAA,CAAK,QAAQ,IAAI,CAAA;AACjB,IAAA,IAAA,CAAK,GAAA,CAAI,KAAK,eAAA,EAAiB,EAAE,cAAc,YAAA,EAAc,IAAA,CAAK,WAAW,CAAA;AAC7E,IAAA,OAAO,KAAK,UAAA,EAAW;AAAA,EACzB;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAQQ,UAAU,aAAA,EAAoC;AACpD,IAAA,MAAM,MAAA,GAA2B;AAAA,MAC/B,SAAA,EAAW,aAAA;AAAA,MACX,SAAA,EAAW,IAAA,CAAK,KAAA,CAAM,MAAA;AAAO,KAC/B;AACA,IAAA,MAAM,GAAA,GAAM,IAAA,CAAK,KAAA,CAAM,GAAA,CAAI,WAAW,CAAA;AACtC,IAAA,IAAI,GAAA,EAAK;AACP,MAAA,IAAI;AACF,QAAA,MAAM,MAAA,GAAS,IAAA,CAAK,KAAA,CAAM,GAAG,CAAA;AAC7B,QAAA,IAAI,OAAO,SAAA,KAAc,aAAA,IAAiB,OAAO,MAAA,CAAO,cAAc,QAAA,EAAU;AAC9E,UAAA,MAAA,CAAO,YAAY,MAAA,CAAO,SAAA;AAAA,QAC5B;AAAA,MACF,CAAA,CAAA,MAAQ;AAAA,MAER;AAAA,IACF;AACA,IAAA,IAAA,CAAK,QAAQ,MAAM,CAAA;AACnB,IAAA,OAAO,MAAA;AAAA,EACT;AAAA,EAEQ,UAAA,GAA0B;AAChC,IAAA,MAAM,GAAA,GAAM,IAAA,CAAK,KAAA,CAAM,GAAA,CAAI,WAAW,CAAA;AACtC,IAAA,IAAI,GAAA,EAAK;AACP,MAAA,IAAI;AACF,QAAA,MAAM,MAAA,GAAS,IAAA,CAAK,KAAA,CAAM,GAAG,CAAA;AAC7B,QAAA,IAAI,OAAO,MAAA,CAAO,SAAA,KAAc,YAAY,OAAO,MAAA,CAAO,cAAc,QAAA,EAAU;AAGhF,UAAA,OAAO,MAAA;AAAA,QACT;AAAA,MACF,CAAA,CAAA,MAAQ;AAAA,MAER;AAAA,IACF;AACA,IAAA,MAAM,KAAA,GAA0B;AAAA,MAC9B,WAAW,MAAA,EAAO;AAAA,MAClB,SAAA,EAAW,IAAA,CAAK,KAAA,CAAM,MAAA;AAAO,KAC/B;AACA,IAAA,IAAA,CAAK,QAAQ,KAAK,CAAA;AAOlB,IAAA,OAAA,CAAQ,OAAA,EAAQ,CAAE,IAAA,CAAK,MAAM;AAC3B,MAAA,IAAA,CAAK,IAAI,IAAA,CAAK,eAAA,EAAiB,EAAE,SAAA,EAAW,KAAA,CAAM,WAAW,CAAA;AAAA,IAC/D,CAAC,CAAA;AACD,IAAA,OAAO,KAAA;AAAA,EACT;AAAA,EAEQ,QAAQ,CAAA,EAA2B;AACzC,IAAA,IAAA,CAAK,MAAM,GAAA,CAAI,WAAA,EAAa,IAAA,CAAK,SAAA,CAAU,CAAC,CAAC,CAAA;AAAA,EAC/C;AACF;;;ACnGO,IAAM,mBAAN,MAAuB;AAAA,EACnB,GAAA;AAAA,EACA,MAAA;AAAA,EACA,KAAA;AAAA,EACA,OAAA;AAAA,EACQ,QAAA;AAAA,EACA,MAAA;AAAA,EACA,QAAA;AAAA,EACT,iBAAA,GAAyC,IAAA;AAAA,EACzC,eAAA,GAAwD,IAAA;AAAA,EAEhE,WAAA,CAAY,OAAA,GAAmC,EAAC,EAAG;AACjD,IAAA,MAAM,KAAA,GAAQ,QAAQ,KAAA,IAAS,WAAA;AAC/B,IAAA,IAAA,CAAK,GAAA,GAAM,IAAI,QAAA,EAAuB;AACtC,IAAA,IAAA,CAAK,MAAA,GAAS,IAAI,WAAA,CAAY,IAAA,CAAK,KAAK,KAAK,CAAA;AAC7C,IAAA,IAAA,CAAK,KAAA,GAAQ,IAAI,YAAA,CAAa,IAAA,CAAK,GAAG,CAAA;AACtC,IAAA,IAAA,CAAK,OAAA,GAAU,IAAI,cAAA,CAAe,IAAA,CAAK,GAAA,EAAK;AAAA,MAC1C,GAAI,QAAQ,YAAA,KAAiB,MAAA,GAAY,EAAE,KAAA,EAAO,OAAA,CAAQ,YAAA,EAAa,GAAI,EAAC;AAAA,MAC5E,GAAI,QAAQ,aAAA,KAAkB,MAAA,GAAY,EAAE,aAAA,EAAe,OAAA,CAAQ,aAAA,EAAc,GAAI,EAAC;AAAA,MACtF;AAAA,KACD,CAAA;AAED,IAAA,IAAI,QAAQ,QAAA,EAAU;AACpB,MAAA,MAAM,aAAa,OAAA,CAAQ,QAAA,KAAa,IAAA,GAAO,KAAK,OAAA,CAAQ,QAAA;AAC5D,MAAA,IAAA,CAAK,WAAW,IAAI,kBAAA,CAAmB,KAAK,MAAA,EAAQ,IAAA,CAAK,OAAO,UAAU,CAAA;AAAA,IAC5E,CAAA,MAAO;AACL,MAAA,IAAA,CAAK,QAAA,GAAW,IAAA;AAAA,IAClB;AAEA,IAAA,IAAA,CAAK,MAAA,GAAS,OAAA,CAAQ,MAAA,GAClB,IAAI,gBAAA,CAAiB,IAAA,CAAK,GAAA,EAAK,IAAA,CAAK,MAAA,EAAQ,OAAA,CAAQ,MAAM,CAAA,GAC1D,IAAA;AAIJ,IAAA,IAAA,CAAK,QAAA,GAAW,IAAA,CAAK,GAAA,CAAI,EAAA,CAAG,gBAAgB,MAAM;AAChD,MAAA,IAAA,CAAK,KAAA,CAAM,KAAK,MAAM,CAAA;AAAA,IACxB,CAAC,CAAA;AAED,IAAA,IAAA,CAAK,cAAA,EAAe;AAAA,EACtB;AAAA;AAAA,EAGA,OAAO,OAAA,EAAiC;AACtC,IAAA,IAAA,CAAK,MAAA,CAAO,OAAO,OAAO,CAAA;AAC1B,IAAA,IAAA,CAAK,UAAU,MAAA,EAAO;AAAA,EACxB;AAAA;AAAA,EAGA,MAAA,GAAe;AACb,IAAA,IAAA,CAAK,UAAU,MAAA,EAAO;AACtB,IAAA,IAAA,CAAK,OAAO,MAAA,EAAO;AAAA,EACrB;AAAA;AAAA,EAGA,MAAM,IAAA,GAAsB;AAC1B,IAAA,MAAM,IAAA,CAAK,OAAO,IAAA,EAAK;AAAA,EACzB;AAAA,EAEA,KAAA,GAAc;AACZ,IAAA,IAAA,CAAK,OAAO,KAAA,EAAM;AAAA,EACpB;AAAA;AAAA;AAAA;AAAA;AAAA,EAMA,KAAK,OAAA,EAAuB;AAC1B,IAAA,IAAA,CAAK,MAAA,CAAO,KAAK,OAAO,CAAA;AAAA,EAC1B;AAAA;AAAA,EAGA,aAAA,CAAc,GAAA,EAAa,QAAA,GAAW,CAAA,EAAS;AAC7C,IAAA,IAAA,CAAK,MAAA,CAAO,aAAA,CAAc,GAAA,EAAK,QAAQ,CAAA;AAAA,EACzC;AAAA;AAAA,EAGA,YAAA,GAAgC;AAC9B,IAAA,OAAO,IAAA,CAAK,MAAM,OAAA,EAAQ;AAAA,EAC5B;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAYA,MAAM,WAAA,GAAgC;AACpC,IAAA,MAAM,MAAM,UAAA,CAAW,SAAA;AAKvB,IAAA,IAAI,GAAA,IAAO,OAAO,GAAA,CAAI,iBAAA,KAAsB,UAAA,EAAY;AACtD,MAAA,IAAI;AACF,QAAA,OAAO,GAAA,CAAI,iBAAA,CAAkB,cAAc,CAAA,KAAM,SAAA;AAAA,MACnD,CAAA,CAAA,MAAQ;AAAA,MAER;AAAA,IACF;AACA,IAAA,IAAI,OAAO,QAAA,KAAa,WAAA,EAAa,OAAO,KAAA;AAC5C,IAAA,MAAM,KAAA,GAAQ,QAAA,CAAS,aAAA,CAAc,OAAO,CAAA;AAC5C,IAAA,KAAA,CAAM,KAAA,GAAQ,IAAA;AACd,IAAA,KAAA,CAAM,GAAA,GAAM,oFAAA;AACZ,IAAA,IAAI;AACF,MAAA,MAAM,MAAM,IAAA,EAAK;AACjB,MAAA,KAAA,CAAM,KAAA,EAAM;AACZ,MAAA,OAAO,IAAA;AAAA,IACT,CAAA,CAAA,MAAQ;AACN,MAAA,OAAO,KAAA;AAAA,IACT;AAAA,EACF;AAAA;AAAA;AAAA;AAAA;AAAA,EAMA,OAAA,GAAgB;AACd,IAAA,IAAA,CAAK,QAAA,IAAW;AAChB,IAAA,IAAA,CAAK,QAAQ,KAAA,EAAM;AACnB,IAAA,IAAA,CAAK,UAAU,MAAA,EAAO;AACtB,IAAA,IAAA,CAAK,OAAO,MAAA,EAAO;AACnB,IAAA,IAAI,OAAO,QAAA,KAAa,WAAA,IAAe,IAAA,CAAK,iBAAA,EAAmB;AAC7D,MAAA,QAAA,CAAS,mBAAA,CAAoB,kBAAA,EAAoB,IAAA,CAAK,iBAAiB,CAAA;AAAA,IACzE;AACA,IAAA,IAAA,CAAK,iBAAA,GAAoB,IAAA;AACzB,IAAA,IAAI,KAAK,eAAA,EAAiB;AACxB,MAAA,YAAA,CAAa,KAAK,eAAe,CAAA;AACjC,MAAA,IAAA,CAAK,eAAA,GAAkB,IAAA;AAAA,IACzB;AACA,IAAA,IAAA,CAAK,IAAI,KAAA,EAAM;AAAA,EACjB;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAQQ,cAAA,GAAuB;AAC7B,IAAA,IAAI,OAAO,aAAa,WAAA,EAAa;AACrC,IAAA,IAAI,WAAA,GAA8B,IAAA;AAClC,IAAA,MAAM,OAAO,MAAY;AACvB,MAAA,IAAA,CAAK,eAAA,GAAkB,IAAA;AACvB,MAAA,MAAM,SAAS,QAAA,CAAS,MAAA;AACxB,MAAA,IAAI,WAAW,WAAA,EAAa;AAC5B,MAAA,WAAA,GAAc,MAAA;AACd,MAAA,IAAA,CAAK,GAAA,CAAI,KAAK,mBAAA,EAAqB,EAAE,QAAQ,EAAA,EAAI,WAAA,CAAY,GAAA,EAAI,EAAG,CAAA;AAAA,IACtE,CAAA;AACA,IAAA,IAAA,CAAK,oBAAoB,MAAY;AACnC,MAAA,IAAI,IAAA,CAAK,eAAA,EAAiB,YAAA,CAAa,IAAA,CAAK,eAAe,CAAA;AAC3D,MAAA,IAAA,CAAK,eAAA,GAAkB,UAAA,CAAW,IAAA,EAAM,GAAG,CAAA;AAAA,IAC7C,CAAA;AACA,IAAA,QAAA,CAAS,gBAAA,CAAiB,kBAAA,EAAoB,IAAA,CAAK,iBAAiB,CAAA;AAAA,EACtE;AACF","file":"index.js","sourcesContent":["/**\n * Thin clock abstraction. Indirection exists so tests can swap a fake clock\n * for deterministic `at` timestamps without monkey-patching globals.\n */\n\nexport interface Clock {\n  /** Monotonic timestamp in milliseconds. Use for `at` fields on the bus. */\n  now(): number\n  /** Wall-clock ISO-8601 UTC string. Use for `played_at` / `client_emitted_at`. */\n  isoNow(): string\n}\n\nexport const systemClock: Clock = {\n  now: () => performance.now(),\n  isoNow: () => new Date().toISOString(),\n}\n","import type { EventBus } from './EventBus'\nimport type { Clock } from './internal/clock'\nimport { systemClock } from './internal/clock'\nimport type { PlayerEvents } from './types'\n\n/**\n * Wraps an HTMLAudioElement and emits the `engine:*` events on the shared bus.\n *\n * Edge cases this normalizes (plan §5):\n * - `timeupdate` throttles to <1Hz when the tab is hidden; we replace the\n *   browser's `timeupdate` with an internal 1s tick that fires while playing,\n *   visible or not — listening with the tab in the background is listening\n *   (telemetry marks each event `background` instead of dropping it). Timers\n *   in a tab that is playing audio aren't throttled below 1s. The raw browser\n *   `timeupdate` is intentionally NOT subscribed — collectors that need\n *   progress get it from `engine:timeupdate`.\n * - Programmatic seeks emit `seeking`/`seeked` like user gestures; downstream\n *   debouncing lives in the SeekCollector, not here.\n * - `waiting` / `playing` map to \"buffer stall start / end\". Note: HTML5's\n *   `playing` event also fires when starting playback for the first time; the\n *   stall semantics in this layer treat ANY `playing` after a `waiting` as a\n *   recovery, which is the behavior collectors want.\n */\nexport class AudioEngine {\n  private element: HTMLAudioElement | null = null\n  private tickHandle: ReturnType<typeof setInterval> | null = null\n  private readonly handlers: Array<{ type: string; fn: EventListener }> = []\n  /**\n   * Last known currentTime before the current seek. Updated continuously from\n   * the raw browser `timeupdate` (used internally only — we don't emit on it).\n   * Captured this way so user-initiated seeks (clicking the scrubber) get a\n   * correct `from` value; by the time `seeking` fires, `el.currentTime` is\n   * already the destination.\n   */\n  private lastKnownTime = 0\n  private seekInProgress = false\n  /** A {@link replaceSource} is putting the new source back at its place: that seek isn't the listener's. */\n  private swapSeekPending = false\n\n  constructor(\n    private readonly bus: EventBus<PlayerEvents>,\n    private readonly clock: Clock = systemClock,\n  ) {}\n\n  /**\n   * Attach to an <audio> element. Idempotent: re-attaching the same element\n   * is a no-op; attaching a different element detaches the previous one first.\n   */\n  attach(element: HTMLAudioElement): void {\n    if (this.element === element) return\n    if (this.element) this.detach()\n    this.element = element\n    this.lastKnownTime = Number.isFinite(element.currentTime) ? element.currentTime : 0\n    this.registerListeners(element)\n    if (Number.isFinite(element.duration) && element.duration > 0) {\n      const duration = element.duration\n      // Defer: the caller has just constructed this engine and may not have\n      // subscribed to `bus` yet. Promise.resolve().then() (not queueMicrotask)\n      // so tests using `vi.useFakeTimers()` still see the deferred emit.\n      Promise.resolve().then(() => {\n        if (this.element === element) {\n          this.bus.emit('engine:loadedmetadata', { duration })\n        }\n      })\n    }\n  }\n\n  detach(): void {\n    if (!this.element) return\n    for (const { type, fn } of this.handlers) {\n      this.element.removeEventListener(type, fn)\n    }\n    this.handlers.length = 0\n    this.stopTick()\n    this.element = null\n  }\n\n  /** Current attached element, or null. Telemetry observes this via `attach()`. */\n  getElement(): HTMLAudioElement | null {\n    return this.element\n  }\n\n  // ---- Playback control --------------------------------------------------\n\n  async play(): Promise<void> {\n    if (!this.element) throw new Error('AudioEngine: no element attached')\n    // The browser may reject (NotAllowedError) on autoplay restrictions. We let\n    // it propagate — PlayerController surfaces it on `engine:error`.\n    await this.element.play()\n  }\n\n  pause(): void {\n    this.element?.pause()\n  }\n\n  seek(toSeconds: number): void {\n    if (!this.element) return\n    if (!Number.isFinite(toSeconds)) {\n      throw new Error(`AudioEngine.seek: toSeconds must be finite, got ${toSeconds}`)\n    }\n    // `from` is taken from lastKnownTime (the value before the seek), not from\n    // el.currentTime, so programmatic and user-initiated seeks both report the\n    // pre-seek position to collectors.\n    this.element.currentTime = Math.max(0, toSeconds)\n  }\n\n  /**\n   * Swap in a fresh URL for the SAME audio (a renewed signed link) and carry\n   * on from `resumeAt`. Putting the new source back at its place takes a seek,\n   * but it is the engine's, not the listener's: its `seeking`/`seeked` never\n   * reach the bus and the tick holds still until it lands, so collectors see\n   * one listen carrying on where it was — not a skip, a seek or a restart.\n   */\n  replaceSource(url: string, resumeAt = 0): void {\n    const el = this.element\n    if (!el) return\n    const at = Number.isFinite(resumeAt) && resumeAt > 0 ? resumeAt : 0\n    this.lastKnownTime = at\n    this.swapSeekPending = at > 0\n    el.src = url\n    if (at > 0) {\n      el.addEventListener(\n        'loadedmetadata',\n        () => {\n          if (this.element === el) el.currentTime = at\n        },\n        { once: true },\n      )\n    }\n  }\n\n  setVolume(volume: number): void {\n    if (!this.element) return\n    if (!Number.isFinite(volume)) {\n      throw new Error(`AudioEngine.setVolume: volume must be finite, got ${volume}`)\n    }\n    this.element.volume = Math.min(1, Math.max(0, volume))\n  }\n\n  // ---- Internals ---------------------------------------------------------\n\n  private registerListeners(el: HTMLAudioElement): void {\n    const add = (type: string, fn: EventListener): void => {\n      el.addEventListener(type, fn)\n      this.handlers.push({ type, fn })\n    }\n\n    add('loadedmetadata', () => {\n      this.bus.emit('engine:loadedmetadata', { duration: el.duration })\n    })\n\n    add('play', () => {\n      this.lastKnownTime = el.currentTime\n      this.bus.emit('engine:play', { currentTime: el.currentTime, at: this.clock.now() })\n      this.startTick(el)\n    })\n\n    add('pause', () => {\n      this.lastKnownTime = el.currentTime\n      this.bus.emit('engine:pause', { currentTime: el.currentTime, at: this.clock.now() })\n      this.stopTick()\n    })\n\n    // Subscribe to the browser's raw `timeupdate` purely to maintain\n    // lastKnownTime — we do NOT emit on this path. Engine:timeupdate is driven\n    // exclusively by the visibility-gated 1s tick (see startTick).\n    //\n    // Skip when `el.seeking` is true: the browser fires `timeupdate` BEFORE\n    // the `seeking` event when the user drags the scrubber (currentTime is\n    // already at the destination by then), so honouring that update would\n    // clobber the pre-seek value the `seeking`/`seeked` handlers need for\n    // `from`. The native `seeking` IDL attribute flips to true at the start\n    // of the browser's seek algorithm, before any of its events fire.\n    add('timeupdate', () => {\n      if (this.seekInProgress) return\n      if (el.seeking) return\n      this.lastKnownTime = el.currentTime\n    })\n\n    add('seeking', () => {\n      this.seekInProgress = true\n      if (this.swapSeekPending) return\n      this.bus.emit('engine:seeking', {\n        from: this.lastKnownTime,\n        to: el.currentTime,\n        at: this.clock.now(),\n      })\n    })\n\n    add('seeked', () => {\n      if (this.swapSeekPending) {\n        this.swapSeekPending = false\n        this.lastKnownTime = el.currentTime\n        this.seekInProgress = false\n        return\n      }\n      this.bus.emit('engine:seeked', {\n        from: this.lastKnownTime,\n        to: el.currentTime,\n        at: this.clock.now(),\n      })\n      this.lastKnownTime = el.currentTime\n      this.seekInProgress = false\n    })\n\n    add('ended', () => {\n      this.bus.emit('engine:ended', { at: this.clock.now() })\n      this.stopTick()\n    })\n\n    add('waiting', () => {\n      this.bus.emit('engine:waiting', { at: this.clock.now() })\n    })\n\n    add('playing', () => {\n      this.bus.emit('engine:playing', { at: this.clock.now() })\n    })\n\n    add('volumechange', () => {\n      this.bus.emit('engine:volumechange', { volume: el.volume, muted: el.muted })\n    })\n\n    add('ratechange', () => {\n      this.bus.emit('engine:ratechange', { rate: el.playbackRate })\n    })\n\n    add('error', () => {\n      const err = el.error\n      this.bus.emit('engine:error', {\n        code: err?.code ?? 0,\n        message: err?.message ?? 'unknown media error',\n      })\n    })\n  }\n\n  /**\n   * Internal 1s tick — replaces the browser's `timeupdate` for progress\n   * accounting. Plan §5 item 1: browser `timeupdate` throttles to <1Hz when\n   * the tab is hidden, so we tick ourselves. It used to stop while hidden,\n   * which made every background listen record no seconds and no progress:\n   * a fan with the tab in the background could never \"hear it through\".\n   */\n  private startTick(el: HTMLAudioElement): void {\n    if (this.tickHandle) return\n    this.tickHandle = setInterval(() => {\n      // Only emit while actually playing (paused, ended, seeking states skip).\n      if (el.paused || el.ended || this.swapSeekPending) return\n      this.bus.emit('engine:timeupdate', {\n        currentTime: el.currentTime,\n        at: this.clock.now(),\n      })\n    }, 1000)\n  }\n\n  private stopTick(): void {\n    if (this.tickHandle) {\n      clearInterval(this.tickHandle)\n      this.tickHandle = null\n    }\n  }\n}\n","/**\n * UUID v4 generator. Uses `crypto.randomUUID()` where available (every modern\n * browser since 2022) and falls back to an RFC 4122 v4 implementation backed\n * by `crypto.getRandomValues` for older environments that expose `Crypto` but\n * not `randomUUID` directly.\n *\n * No `Math.random` fallback: this id is the listener session identifier on\n * the wire — predictability would weaken anti-fraud guarantees downstream.\n * If neither API is present we throw so consumers fail loudly rather than\n * silently emitting unsafe ids.\n */\nexport function uuidV4(): string {\n  // biome-ignore lint/suspicious/noExplicitAny: optional API detection\n  const c = (globalThis as any).crypto as Crypto | undefined\n  if (c && typeof c.randomUUID === 'function') {\n    return c.randomUUID()\n  }\n  if (!c || typeof c.getRandomValues !== 'function') {\n    throw new Error(\n      '@delistening/player: no Web Crypto available. uuidV4 requires either ' +\n        'crypto.randomUUID or crypto.getRandomValues.',\n    )\n  }\n  const bytes = new Uint8Array(16)\n  c.getRandomValues(bytes)\n  // biome-ignore lint/style/noNonNullAssertion: indices are in-bounds by construction\n  bytes[6] = (bytes[6]! & 0x0f) | 0x40\n  // biome-ignore lint/style/noNonNullAssertion: indices are in-bounds by construction\n  bytes[8] = (bytes[8]! & 0x3f) | 0x80\n  const hex = Array.from(bytes, (b) => b.toString(16).padStart(2, '0'))\n  return `${hex.slice(0, 4).join('')}-${hex.slice(4, 6).join('')}-${hex.slice(6, 8).join('')}-${hex\n    .slice(8, 10)\n    .join('')}-${hex.slice(10, 16).join('')}`\n}\n","import type { AudioEngine } from './AudioEngine'\nimport type { EventBus } from './EventBus'\nimport { uuidV4 } from './internal/uuid'\nimport type { BridgeCommandName, BridgeEnvelope, BridgeTransport, PlayerEvents } from './types'\n\n/**\n * CrossFrameBridge — connects a player instance to a remote host across a\n * frame boundary. Transport-agnostic by design (see types.ts `BridgeTransport`).\n *\n * Two real transports:\n *   - `WindowMessageTransport`  — iframe ↔ parent page (cross-origin)\n *   - `NativeShellTransport`    — web inside native WebView (stub for now)\n *\n * Wire envelope (`BridgeEnvelope` in types.ts) is shared across both. Commands\n * flow IN, events flow OUT, `ack` confirms a command was applied.\n *\n * Origin validation is mandatory for `WindowMessageTransport`. We reject\n * `'*'` at construction time — accepting any origin would defeat the point.\n */\n\n// ===========================================================================\n// WindowMessageTransport — iframe ↔ parent\n// ===========================================================================\n\nexport interface WindowMessageTransportOptions {\n  /** The remote window to send to (e.g. `window.parent` from inside an iframe). */\n  target: Window\n  /** Explicit allowlist of origins this transport will trust. `'*'` is rejected. */\n  allowedOrigins: string[]\n  /**\n   * Origin to use when sending. Required when `allowedOrigins.length > 1`;\n   * inferred from `allowedOrigins[0]` when there's exactly one. Must be one\n   * of `allowedOrigins`. `'*'` is rejected.\n   */\n  targetOrigin?: string\n  /** Local window to listen on. Default: `globalThis`. */\n  source?: Window & typeof globalThis\n}\n\nconst ENVELOPE_TAG = 'delistening' as const\nconst ENVELOPE_VERSION = 1 as const\n\ninterface WrappedMessage {\n  [ENVELOPE_TAG]: typeof ENVELOPE_VERSION\n  payload: BridgeEnvelope\n}\n\nfunction isWrappedMessage(data: unknown): data is WrappedMessage {\n  return (\n    typeof data === 'object' &&\n    data !== null &&\n    (data as Record<string, unknown>)[ENVELOPE_TAG] === ENVELOPE_VERSION &&\n    'payload' in (data as Record<string, unknown>)\n  )\n}\n\nexport class WindowMessageTransport implements BridgeTransport {\n  private readonly handlers = new Set<(envelope: BridgeEnvelope) => void>()\n  private readonly listener: (event: MessageEvent) => void\n  private readonly source: Window & typeof globalThis\n  private readonly target: Window\n  private readonly allowed: Set<string>\n  private readonly targetOrigin: string\n  private closed = false\n\n  constructor(options: WindowMessageTransportOptions) {\n    if (options.allowedOrigins.length === 0) {\n      throw new Error('WindowMessageTransport: allowedOrigins must contain at least one origin')\n    }\n    if (options.allowedOrigins.includes('*')) {\n      throw new Error(\n        \"WindowMessageTransport: '*' is not an allowed origin. List explicit origins.\",\n      )\n    }\n    if (options.targetOrigin === undefined && options.allowedOrigins.length > 1) {\n      throw new Error(\n        'WindowMessageTransport: targetOrigin is required when allowedOrigins has more than one entry',\n      )\n    }\n    const targetOrigin = options.targetOrigin ?? (options.allowedOrigins[0] as string)\n    if (targetOrigin === '*') {\n      throw new Error(\"WindowMessageTransport: targetOrigin '*' is not allowed.\")\n    }\n    if (!options.allowedOrigins.includes(targetOrigin)) {\n      throw new Error(\n        `WindowMessageTransport: targetOrigin '${targetOrigin}' must be one of allowedOrigins`,\n      )\n    }\n    this.target = options.target\n    this.source = options.source ?? (globalThis as Window & typeof globalThis)\n    this.allowed = new Set(options.allowedOrigins)\n    this.targetOrigin = targetOrigin\n    this.listener = (event: MessageEvent) => {\n      if (!this.allowed.has(event.origin)) return\n      // Pin source: reject messages from other windows even if they share an\n      // allowlisted origin. Defensive against same-origin cross-tab confusion.\n      if (event.source !== this.target) return\n      if (!isWrappedMessage(event.data)) return\n      for (const fn of this.handlers) {\n        try {\n          fn(event.data.payload)\n        } catch (err) {\n          console.error('[@delistening/player] bridge handler threw', err)\n        }\n      }\n    }\n    this.source.addEventListener('message', this.listener)\n  }\n\n  send(envelope: BridgeEnvelope): void {\n    if (this.closed) return\n    const wrapped: WrappedMessage = { [ENVELOPE_TAG]: ENVELOPE_VERSION, payload: envelope }\n    this.target.postMessage(wrapped, this.targetOrigin)\n  }\n\n  onMessage(handler: (envelope: BridgeEnvelope) => void): () => void {\n    this.handlers.add(handler)\n    return () => this.handlers.delete(handler)\n  }\n\n  close(): void {\n    if (this.closed) return\n    this.closed = true\n    this.source.removeEventListener('message', this.listener)\n    this.handlers.clear()\n  }\n}\n\n// ===========================================================================\n// NativeShellTransport — STUB\n// ===========================================================================\n\n/**\n * Placeholder for the native mobile WebView bridge.\n *\n * The interface is stable (see `BridgeTransport` in types.ts). The concrete\n * implementation lands when the native runtime is chosen — see ARCHITECTURE.md\n * lines 364-376 (\"Runtime / framework choice deferred\").\n *\n * Throwing on construction (rather than on `send`) catches misuse early.\n */\nexport class NativeShellTransport implements BridgeTransport {\n  constructor() {\n    throw new Error(\n      'NativeShellTransport is not yet implemented. ' +\n        'The native runtime is still being chosen (see ARCHITECTURE.md:364-376). ' +\n        'Use WindowMessageTransport for iframe embeds in the meantime.',\n    )\n  }\n  send(): void {\n    throw new Error('NativeShellTransport: not implemented')\n  }\n  onMessage(): () => void {\n    throw new Error('NativeShellTransport: not implemented')\n  }\n  close(): void {\n    /* unreachable */\n  }\n}\n\n// ===========================================================================\n// CrossFrameBridge — wires a transport to a player\n// ===========================================================================\n\nexport interface CrossFrameBridgeOptions {\n  /**\n   * Subset of PlayerEvents to forward to the remote peer. Default: all.\n   * Useful when the remote chrome only cares about play/pause/timeupdate.\n   */\n  forwardEvents?: Array<keyof PlayerEvents>\n}\n\nexport class CrossFrameBridge {\n  private readonly forward: Set<keyof PlayerEvents>\n  private readonly offFns: Array<() => void> = []\n  private offTransport: (() => void) | null = null\n\n  constructor(\n    private readonly bus: EventBus<PlayerEvents>,\n    private readonly engine: AudioEngine,\n    private readonly transport: BridgeTransport,\n    options: CrossFrameBridgeOptions = {},\n  ) {\n    this.forward = new Set(options.forwardEvents ?? DEFAULT_FORWARDED_EVENTS)\n    this.wireOutbound()\n    this.wireInbound()\n  }\n\n  close(): void {\n    for (const off of this.offFns) off()\n    this.offFns.length = 0\n    this.offTransport?.()\n    this.transport.close()\n  }\n\n  private wireOutbound(): void {\n    for (const name of this.forward) {\n      const off = this.bus.on(name, (payload) => {\n        this.transport.send({ kind: 'event', name, payload })\n      })\n      this.offFns.push(off)\n    }\n  }\n\n  private wireInbound(): void {\n    this.offTransport = this.transport.onMessage((envelope) => {\n      if (envelope.kind !== 'command') return\n      this.applyCommand(envelope.name, envelope.args)\n        .then(() => this.transport.send({ kind: 'ack', id: envelope.id, ok: true }))\n        .catch((err: unknown) => {\n          const message = err instanceof Error ? err.message : String(err)\n          this.transport.send({ kind: 'ack', id: envelope.id, ok: false, error: message })\n        })\n    })\n  }\n\n  private async applyCommand(name: BridgeCommandName, args: unknown): Promise<void> {\n    switch (name) {\n      case 'play':\n        await this.engine.play()\n        return\n      case 'pause':\n        this.engine.pause()\n        return\n      case 'seek': {\n        const a = args as { to?: number } | undefined\n        if (typeof a?.to !== 'number' || !Number.isFinite(a.to)) {\n          throw new Error('seek: args.to (finite number) required')\n        }\n        this.engine.seek(a.to)\n        return\n      }\n      case 'setVolume': {\n        const a = args as { volume?: number } | undefined\n        if (typeof a?.volume !== 'number' || !Number.isFinite(a.volume)) {\n          throw new Error('setVolume: args.volume (finite number) required')\n        }\n        this.engine.setVolume(a.volume)\n        return\n      }\n      case 'load':\n        // Loading new media is QueueManager's job; not handled at the bridge\n        // layer in v0.1. Hosts can implement track changes by sending a\n        // future `load` extension.\n        throw new Error('load: not implemented in v0.1')\n      default: {\n        const exhaustive: never = name\n        throw new Error(`Unknown bridge command: ${String(exhaustive)}`)\n      }\n    }\n  }\n}\n\n/**\n * Default outbound event set. Chrome on the host side typically only needs\n * lifecycle + progress + visibility to render its UI; the full firehose stays\n * inside the iframe where collectors live.\n */\nconst DEFAULT_FORWARDED_EVENTS: ReadonlyArray<keyof PlayerEvents> = [\n  'engine:play',\n  'engine:pause',\n  'engine:timeupdate',\n  'engine:ended',\n  'engine:error',\n  'engine:volumechange',\n  'queue:track_change',\n  'queue:complete',\n  'visibility:change',\n]\n\n/** Convenience: create a unique command id for outbound commands. */\nexport function newCommandId(): string {\n  return uuidV4()\n}\n","/**\n * Typed pub/sub. Single integration seam between @delistening/player and\n * @delistening/telemetry.\n *\n * Design notes\n * ------------\n * - Generic over an event-map type: `EventBus<PlayerEvents>` gives full\n *   compile-time payload typing per event name.\n * - `on(name, fn)` returns an unsubscribe function — callers don't track\n *   ids, and there is no separate `off` API to forget to wire up.\n * - Listener errors are caught and reported via console.error so a buggy\n *   collector cannot wedge the player. Telemetry sees the same event\n *   regardless of whether other collectors threw.\n * - `emit` snapshots listeners before iterating so a listener that\n *   unsubscribes mid-iteration doesn't shift indices.\n */\n\nexport type EventMap = Record<string, unknown>\n\nexport type Listener<P> = (payload: P) => void\n\nexport class EventBus<E extends EventMap> {\n  private readonly listeners = new Map<keyof E, Set<Listener<unknown>>>()\n\n  /**\n   * Subscribe to `name`. Returns an unsubscribe function.\n   */\n  on<K extends keyof E>(name: K, fn: Listener<E[K]>): () => void {\n    let set = this.listeners.get(name)\n    if (!set) {\n      set = new Set()\n      this.listeners.set(name, set)\n    }\n    set.add(fn as Listener<unknown>)\n    return () => {\n      const s = this.listeners.get(name)\n      s?.delete(fn as Listener<unknown>)\n      if (s && s.size === 0) {\n        this.listeners.delete(name)\n      }\n    }\n  }\n\n  /**\n   * Subscribe once. Auto-unsubscribes after the first delivery.\n   */\n  once<K extends keyof E>(name: K, fn: Listener<E[K]>): () => void {\n    const off = this.on(name, (payload) => {\n      off()\n      fn(payload)\n    })\n    return off\n  }\n\n  /**\n   * Emit `name` with `payload`. Listener throws are swallowed (logged) so a\n   * single failing consumer cannot prevent siblings from receiving the event.\n   */\n  emit<K extends keyof E>(name: K, payload: E[K]): void {\n    const set = this.listeners.get(name)\n    if (!set || set.size === 0) return\n    // Snapshot to be safe against in-iteration mutation.\n    for (const fn of Array.from(set)) {\n      try {\n        ;(fn as Listener<E[K]>)(payload)\n      } catch (err) {\n        console.error(`[@delistening/player] listener for \"${String(name)}\" threw`, err)\n      }\n    }\n  }\n\n  /** Number of listeners currently subscribed to `name`. Diagnostic only. */\n  listenerCount<K extends keyof E>(name: K): number {\n    return this.listeners.get(name)?.size ?? 0\n  }\n\n  /** Remove all listeners. Used by PlayerController.detach(). */\n  clear(): void {\n    this.listeners.clear()\n  }\n}\n","import type { AudioEngine } from './AudioEngine'\nimport type { QueueManager } from './QueueManager'\n\nexport interface KeyboardBindings {\n  /** Toggle play/pause. Default: ' ' (space). */\n  togglePlay?: string\n  /** Seek backward by `seekSeconds`. Default: 'ArrowLeft'. */\n  seekBack?: string\n  /** Seek forward by `seekSeconds`. Default: 'ArrowRight'. */\n  seekForward?: string\n  /** Volume up. Default: 'ArrowUp'. */\n  volumeUp?: string\n  /** Volume down. Default: 'ArrowDown'. */\n  volumeDown?: string\n  /** Next track. Default: 'n'. */\n  nextTrack?: string\n  /** Previous track. Default: 'p'. */\n  prevTrack?: string\n}\n\nexport interface KeyboardControllerOptions {\n  /** How many seconds each arrow press scrubs. Default: 5. */\n  seekSeconds?: number\n  /** Volume delta per arrow press (0-1). Default: 0.1. */\n  volumeStep?: number\n  /**\n   * Only respond when an attached element has focus. Default: false (global).\n   * Set true to avoid hijacking shortcuts when a text input or other widget\n   * has focus.\n   */\n  scopeToElement?: boolean\n  /**\n   * EventTarget that receives the `keydown` listener. Default: `globalThis`.\n   * Embedded players that want to scope to a container element (rather than\n   * the whole window) can pass it here.\n   */\n  attachTarget?: EventTarget\n  bindings?: KeyboardBindings\n}\n\nconst defaults: Required<KeyboardBindings> = {\n  togglePlay: ' ',\n  seekBack: 'ArrowLeft',\n  seekForward: 'ArrowRight',\n  volumeUp: 'ArrowUp',\n  volumeDown: 'ArrowDown',\n  nextTrack: 'n',\n  prevTrack: 'p',\n}\n\n/**\n * Optional keyboard layer. Constructed by PlayerController only when the\n * caller passes `keyboard: true` (default: off) — we don't hijack global\n * shortcuts in embedded contexts unless the host opts in.\n *\n * `scopeToElement: true` is the iframe-embed default; the parent host owns\n * the chrome and we don't want space-to-pause stealing input from forms on\n * the parent page.\n */\nexport class KeyboardController {\n  private attached = false\n  private handler: EventListener | null = null\n  private target: EventTarget | undefined\n  private readonly bindings: Required<KeyboardBindings>\n  private readonly seekSeconds: number\n  private readonly volumeStep: number\n  private readonly scopeToElement: boolean\n  private readonly attachTarget: EventTarget\n\n  constructor(\n    private readonly engine: AudioEngine,\n    private readonly queue: QueueManager,\n    options: KeyboardControllerOptions = {},\n  ) {\n    this.seekSeconds = options.seekSeconds ?? 5\n    this.volumeStep = options.volumeStep ?? 0.1\n    this.scopeToElement = options.scopeToElement ?? false\n    this.attachTarget = options.attachTarget ?? globalThis\n    this.bindings = { ...defaults, ...options.bindings }\n  }\n\n  attach(target?: EventTarget): void {\n    if (this.attached) return\n    this.attached = true\n    this.handler = (event: Event) => this.onKey(event as KeyboardEvent)\n    this.target = target ?? this.attachTarget\n    this.target.addEventListener('keydown', this.handler)\n  }\n\n  detach(): void {\n    if (!this.attached || !this.handler) return\n    this.target?.removeEventListener('keydown', this.handler)\n    this.handler = null\n    this.target = undefined\n    this.attached = false\n  }\n\n  private onKey(event: KeyboardEvent): void {\n    // Bail on IME composition and modifier-keyed shortcuts so the player\n    // doesn't fight Cmd+ArrowLeft (browser back), Cmd+Space (Spotlight), etc.\n    if (event.isComposing) return\n    if (event.ctrlKey || event.metaKey || event.altKey) return\n\n    if (this.scopeToElement) {\n      const el = this.engine.getElement()\n      if (!el || document.activeElement !== el) return\n    }\n    // Don't fight form inputs even in global mode.\n    const t = event.target as HTMLElement | null\n    if (t?.tagName === 'INPUT' || t?.tagName === 'TEXTAREA' || t?.isContentEditable) {\n      return\n    }\n    const el = this.engine.getElement()\n    if (!el) return\n\n    switch (event.key) {\n      case this.bindings.togglePlay:\n        event.preventDefault()\n        if (el.paused) {\n          void this.engine.play()\n        } else {\n          this.engine.pause()\n        }\n        break\n      case this.bindings.seekBack:\n        event.preventDefault()\n        this.engine.seek(Math.max(0, el.currentTime - this.seekSeconds))\n        break\n      case this.bindings.seekForward:\n        event.preventDefault()\n        this.engine.seek(el.currentTime + this.seekSeconds)\n        break\n      case this.bindings.volumeUp:\n        event.preventDefault()\n        this.engine.setVolume(Math.min(1, el.volume + this.volumeStep))\n        break\n      case this.bindings.volumeDown:\n        event.preventDefault()\n        this.engine.setVolume(Math.max(0, el.volume - this.volumeStep))\n        break\n      case this.bindings.nextTrack:\n        event.preventDefault()\n        this.queue.next()\n        break\n      case this.bindings.prevTrack:\n        event.preventDefault()\n        this.queue.prev()\n        break\n    }\n  }\n}\n","import type { EventBus } from './EventBus'\nimport type { PlayerEvents, QueueChangeReason, TrackRef } from './types'\n\n/**\n * Manages the ordered list of tracks for a session.\n *\n * Repeat / shuffle are kept off the AudioEngine; they're queue-level decisions.\n * Auto-advance (when a track ends) is triggered externally by PlayerController\n * subscribing to `engine:ended` and calling `next('auto')`.\n */\nexport type RepeatMode = 'off' | 'one' | 'all'\n\nexport class QueueManager {\n  /** Most queued repeats an entry holds; one more request turns it into a loop. */\n  static readonly MAX_PLAYS = 5\n  /** Sentinel for \"replay until the listener skips or removes it\". */\n  static readonly LOOP = Number.POSITIVE_INFINITY\n\n  private tracks: TrackRef[] = []\n  /**\n   * Plays left per entry, index-aligned with `tracks`. 1 = play once. A\n   * listener who queues the same track again bumps this instead of adding a\n   * duplicate row (see {@link addPlay}); auto-advance replays the entry\n   * until it reaches 1, then moves on. Manual navigation abandons the rest.\n   */\n  private playsLeft: number[] = []\n  private index = -1\n  private repeat: RepeatMode = 'off'\n  private shuffleEnabled = false\n  private shuffleOrder: number[] = []\n\n  constructor(private readonly bus: EventBus<PlayerEvents>) {}\n\n  // ---- Queue mutation ----------------------------------------------------\n\n  load(tracks: TrackRef[], startIndex = 0): void {\n    if (tracks.length === 0) {\n      throw new Error('QueueManager.load: tracks must not be empty')\n    }\n    if (startIndex < 0 || startIndex >= tracks.length) {\n      throw new Error(`QueueManager.load: startIndex ${startIndex} out of range`)\n    }\n    const previous = this.current()\n    this.tracks = [...tracks]\n    this.playsLeft = tracks.map(() => 1)\n    this.rebuildShuffleOrder()\n    this.index = startIndex\n    const next = this.tracks[this.index]\n    if (next) {\n      this.bus.emit('queue:track_change', { from: previous, to: next, reason: 'jump' })\n    }\n  }\n\n  append(track: TrackRef, plays = 1): void {\n    this.tracks.push(track)\n    this.playsLeft.push(Math.max(1, Math.floor(plays)))\n    if (this.shuffleEnabled) {\n      // Insert at a random position AFTER the cursor so unplayed tracks remain\n      // shuffled. Inserting at the end defeats the point — listeners would\n      // hear appended tracks in their append order even with shuffle on.\n      const cursor = this.shuffleOrder.indexOf(this.index)\n      const minInsert = cursor + 1\n      const range = this.shuffleOrder.length + 1 - minInsert\n      const at = minInsert + Math.floor(Math.random() * range)\n      this.shuffleOrder.splice(at, 0, this.tracks.length - 1)\n    }\n  }\n\n  /**\n   * Insert a track to play *immediately after* the current one (\"play next\"),\n   * as opposed to {@link append} which adds to the end. On an empty queue this\n   * behaves like append.\n   */\n  insertNext(track: TrackRef): void {\n    if (this.tracks.length === 0) {\n      this.append(track)\n      return\n    }\n    const at = this.index + 1\n    this.tracks.splice(at, 0, track)\n    this.playsLeft.splice(at, 0, 1)\n    if (this.shuffleEnabled) {\n      // Splicing shifted every existing index >= `at` up by one; remap the\n      // shuffle order, then schedule the new index right after the cursor.\n      this.shuffleOrder = this.shuffleOrder.map((i) => (i >= at ? i + 1 : i))\n      const cursor = this.shuffleOrder.indexOf(this.index)\n      this.shuffleOrder.splice(cursor + 1, 0, at)\n    }\n  }\n\n  /**\n   * Remove the track at `index`. Returns it, or null when out of range.\n   *\n   * Removing an upcoming or already-played track leaves playback alone (the\n   * cursor shifts down when the removed slot sat before it). Removing the\n   * CURRENT track hands playback to the track that would have played next\n   * (`queue:track_change`, reason 'jump') — or, when it was the last one,\n   * to the new last track — and emits `queue:complete` when the queue is\n   * left empty, exactly as running off the end does.\n   */\n  remove(index: number): TrackRef | null {\n    if (index < 0 || index >= this.tracks.length) return null\n    const removed = this.tracks[index] as TrackRef\n    const wasCurrent = index === this.index\n    const cursor = this.shuffleEnabled ? this.shuffleOrder.indexOf(index) : -1\n\n    this.tracks.splice(index, 1)\n    this.playsLeft.splice(index, 1)\n    this.shuffleOrder = this.shuffleOrder\n      .filter((i) => i !== index)\n      .map((i) => (i > index ? i - 1 : i))\n\n    if (this.tracks.length === 0) {\n      this.index = -1\n      this.bus.emit('queue:complete', { lastTrack: removed })\n      return removed\n    }\n    if (!wasCurrent) {\n      if (index < this.index) this.index -= 1\n      return removed\n    }\n\n    const to = this.shuffleEnabled\n      ? (this.shuffleOrder[Math.min(cursor, this.shuffleOrder.length - 1)] as number)\n      : Math.min(index, this.tracks.length - 1)\n    this.index = to\n    this.bus.emit('queue:track_change', { from: removed, to: this.tracks[to] as TrackRef, reason: 'jump' })\n    return removed\n  }\n\n  /**\n   * Queue the entry at `index` for `n` more plays. Returns the entry's total\n   * plays left (including the one in progress when it is current), or 0 when\n   * out of range. This is what \"+\" does for a track that is already queued.\n   * Counts cap at {@link MAX_PLAYS}; a request past the cap converts the\n   * entry into a replay loop ({@link LOOP}) that plays until the listener\n   * skips or removes it.\n   */\n  addPlay(index: number, n = 1): number {\n    if (index < 0 || index >= this.tracks.length) return 0\n    const have = this.playsLeft[index] ?? 1\n    if (have >= QueueManager.MAX_PLAYS) {\n      this.playsLeft[index] = QueueManager.LOOP\n      return QueueManager.LOOP\n    }\n    const next = Math.min(QueueManager.MAX_PLAYS, have + Math.max(1, Math.floor(n)))\n    this.playsLeft[index] = next\n    return next\n  }\n\n  /** Set the entry's plays left outright (1 ends a loop or a count). No-op out of range. */\n  setPlays(index: number, n: number): void {\n    if (index < 0 || index >= this.tracks.length) return\n    this.playsLeft[index] = n === QueueManager.LOOP ? QueueManager.LOOP : Math.max(1, Math.floor(n))\n  }\n\n  /** Whether the entry at `index` is a replay loop. */\n  isLooping(index: number): boolean {\n    return this.playsLeft[index] === QueueManager.LOOP\n  }\n\n  /** Plays left for the entry at `index` (1 = once); 0 when out of range. */\n  playsAt(index: number): number {\n    return this.playsLeft[index] ?? 0\n  }\n\n  /** First index holding this track, or -1. */\n  indexOf(trackUuid: string): number {\n    return this.tracks.findIndex((t) => t.trackUuid === trackUuid)\n  }\n\n  clear(): void {\n    this.tracks = []\n    this.playsLeft = []\n    this.shuffleOrder = []\n    this.index = -1\n  }\n\n  // ---- Read state --------------------------------------------------------\n\n  current(): TrackRef | null {\n    return this.index >= 0 ? (this.tracks[this.index] ?? null) : null\n  }\n\n  size(): number {\n    return this.tracks.length\n  }\n\n  position(): number {\n    return this.index\n  }\n\n  // ---- Configuration -----------------------------------------------------\n\n  setRepeat(mode: RepeatMode): void {\n    this.repeat = mode\n  }\n\n  setShuffle(enabled: boolean): void {\n    this.shuffleEnabled = enabled\n    if (enabled) {\n      this.rebuildShuffleOrder()\n    }\n  }\n\n  // ---- Navigation --------------------------------------------------------\n\n  /**\n   * Advance to the next track. Returns the new current track, or null when\n   * the queue has completed (and emits `queue:complete`).\n   */\n  next(reason: QueueChangeReason = 'next'): TrackRef | null {\n    if (this.tracks.length === 0) return null\n    const from = this.current()\n\n    // Repeat-one stays on the same index. Reason still propagates so the\n    // collector can tell auto-replay (`auto`) from a manual \"next\" tap.\n    if (this.repeat === 'one' && reason === 'auto') {\n      if (from) this.bus.emit('queue:track_change', { from, to: from, reason })\n      return from\n    }\n\n    // Queued repeats: the entry plays again until its count runs down. Same\n    // event shape as repeat-one, so the bar restarts the track and the\n    // collector reads it as a replay. Only auto-advance honours it —\n    // a manual next abandons the rest (below).\n    if (reason === 'auto' && (this.playsLeft[this.index] ?? 1) > 1) {\n      // A loop never counts down; a finite count does.\n      if (this.playsLeft[this.index] !== QueueManager.LOOP) {\n        this.playsLeft[this.index] = (this.playsLeft[this.index] ?? 1) - 1\n      }\n      if (from) this.bus.emit('queue:track_change', { from, to: from, reason })\n      return from\n    }\n    if (this.index >= 0) this.playsLeft[this.index] = 1\n\n    const nextIndex = this.advanceIndex(+1)\n    if (nextIndex === -1) {\n      if (from) this.bus.emit('queue:complete', { lastTrack: from })\n      return null\n    }\n    this.index = nextIndex\n    const to = this.tracks[nextIndex] as TrackRef\n    this.bus.emit('queue:track_change', { from, to, reason })\n    return to\n  }\n\n  prev(reason: QueueChangeReason = 'prev'): TrackRef | null {\n    if (this.tracks.length === 0) return null\n    const from = this.current()\n    const prevIndex = this.advanceIndex(-1)\n    if (prevIndex === -1) return from\n    this.playsLeft[this.index] = 1\n    this.index = prevIndex\n    const to = this.tracks[prevIndex] as TrackRef\n    this.bus.emit('queue:track_change', { from, to, reason })\n    return to\n  }\n\n  /** Jump to an arbitrary index. Out-of-range throws. */\n  jumpTo(index: number, reason: QueueChangeReason = 'jump'): TrackRef {\n    if (index < 0 || index >= this.tracks.length) {\n      throw new Error(`QueueManager.jumpTo: index ${index} out of range`)\n    }\n    const from = this.current()\n    if (this.index >= 0 && this.index !== index) this.playsLeft[this.index] = 1\n    this.index = index\n    const to = this.tracks[index] as TrackRef\n    this.bus.emit('queue:track_change', { from, to, reason })\n    return to\n  }\n\n  // ---- Internals ---------------------------------------------------------\n\n  private advanceIndex(delta: 1 | -1): number {\n    if (this.shuffleEnabled) {\n      const here = this.shuffleOrder.indexOf(this.index)\n      const target = here + delta\n      if (target < 0) return -1\n      if (target >= this.shuffleOrder.length) {\n        if (this.repeat !== 'all') return -1\n        // Reshuffle at the loop boundary so the next pass isn't the same order.\n        this.rebuildShuffleOrder()\n        return this.shuffleOrder[0] ?? -1\n      }\n      return this.shuffleOrder[target] ?? -1\n    }\n    const target = this.index + delta\n    if (target < 0) return -1\n    if (target >= this.tracks.length) {\n      return this.repeat === 'all' ? 0 : -1\n    }\n    return target\n  }\n\n  private rebuildShuffleOrder(): void {\n    const order = this.tracks.map((_, i) => i)\n    // Fisher-Yates. Deterministic enough for tests when callers want it —\n    // they can spy on Math.random or seed it.\n    for (let i = order.length - 1; i > 0; i--) {\n      const j = Math.floor(Math.random() * (i + 1))\n      const a = order[i] as number\n      const b = order[j] as number\n      order[i] = b\n      order[j] = a\n    }\n    this.shuffleOrder = order\n  }\n}\n","/**\n * Storage adapter. Indirection exists so SessionManager works in three\n * environments: a real browser (sessionStorage), an iframe in a partitioned-\n * storage browser (also sessionStorage but with reduced quota), and tests\n * (in-memory fallback when happy-dom's sessionStorage isn't configured).\n *\n * Plan §4: session_id is in sessionStorage, NOT localStorage. Reload preserves;\n * new tab gets a fresh session.\n */\nexport interface KeyValueStore {\n  get(key: string): string | null\n  set(key: string, value: string): void\n  remove(key: string): void\n}\n\nclass MemoryStore implements KeyValueStore {\n  private readonly map = new Map<string, string>()\n  get(key: string): string | null {\n    return this.map.get(key) ?? null\n  }\n  set(key: string, value: string): void {\n    this.map.set(key, value)\n  }\n  remove(key: string): void {\n    this.map.delete(key)\n  }\n}\n\nclass WebStorageAdapter implements KeyValueStore {\n  constructor(private readonly storage: Storage) {}\n  get(key: string): string | null {\n    try {\n      return this.storage.getItem(key)\n    } catch {\n      return null\n    }\n  }\n  set(key: string, value: string): void {\n    try {\n      this.storage.setItem(key, value)\n    } catch {\n      // QuotaExceededError, partitioned storage refusal, private-mode Safari, etc.\n      // Sessions are best-effort durable; we don't crash playback for storage.\n    }\n  }\n  remove(key: string): void {\n    try {\n      this.storage.removeItem(key)\n    } catch {\n      // ignore — see set()\n    }\n  }\n}\n\n/**\n * Return sessionStorage if it's usable in this realm, otherwise an in-memory\n * fallback. Browsers can throw on `sessionStorage` access in sandboxed iframes\n * even before any get/set — we treat that as \"no storage\" and degrade.\n */\nexport function defaultSessionStore(): KeyValueStore {\n  try {\n    const s = globalThis.sessionStorage\n    if (s) {\n      // Probe — some browsers expose sessionStorage but throw on access.\n      const probe = '__delistening_probe__'\n      s.setItem(probe, '1')\n      s.removeItem(probe)\n      return new WebStorageAdapter(s)\n    }\n  } catch {\n    // fall through to memory\n  }\n  return new MemoryStore()\n}\n\nexport const _internal = { MemoryStore, WebStorageAdapter }\n","import type { EventBus } from './EventBus'\nimport { type Clock, systemClock } from './internal/clock'\nimport { type KeyValueStore, defaultSessionStore } from './internal/storage'\nimport { uuidV4 } from './internal/uuid'\nimport type { PlayerEvents, SessionInfo } from './types'\n\nconst SESSION_KEY = 'delistening.session.v1'\n\ninterface PersistedSession {\n  sessionId: string\n  startedAt: string\n  previousSessionId?: string\n}\n\nexport interface SessionManagerOptions {\n  store?: KeyValueStore\n  clock?: Clock\n  /**\n   * Adopt a server-authoritative session id instead of minting/rehydrating one.\n   *\n   * When the page is served with a server play-session (the `dl_psid` cookie,\n   * surfaced as the `ingestion-session-id` meta tag), the ingestion JWT's `sid`\n   * claim is bound to it and the Rust service rejects any event whose\n   * `session_id` differs. Seeding here keeps the emitted `session_id` equal to\n   * that `sid`. The seed wins over any stored session; `startedAt` is preserved\n   * if the stored session already had this id.\n   */\n  seedSessionId?: string\n}\n\n/**\n * Owns the anonymous `session_id`.\n *\n * Plan §5 item 4 decision: store in **sessionStorage**, NOT localStorage.\n *   - Reload preserves the session (sessionStorage survives F5).\n *   - New tab gets a fresh session.\n *   - Closing the tab destroys it.\n * This is the right semantic for \"anonymous play sessions\" — a fresh tab is\n * a fresh listener intent. **This likely differs from the MVP**; flag during\n * back-test.\n *\n * Anonymous → authenticated stitching: when a listener signs in mid-session,\n * call `reset()` to mint a new session_id and emit `session:reset` carrying\n * the old id. Ingestion uses both ids to stitch the pre- and post-auth plays\n * into a single listener intent.\n */\nexport class SessionManager {\n  private session: SessionInfo\n  private readonly store: KeyValueStore\n  private readonly clock: Clock\n\n  constructor(\n    private readonly bus: EventBus<PlayerEvents>,\n    options: SessionManagerOptions = {},\n  ) {\n    this.store = options.store ?? defaultSessionStore()\n    this.clock = options.clock ?? systemClock\n    this.session = options.seedSessionId\n      ? this.adoptSeed(options.seedSessionId)\n      : this.loadOrMint()\n  }\n\n  /** Current session_id. Stable for the lifetime of the tab unless reset(). */\n  getSessionId(): string {\n    return this.session.sessionId\n  }\n\n  /** Full session info (id, startedAt, optional previousSessionId). */\n  getSession(): SessionInfo {\n    return { ...this.session }\n  }\n\n  /**\n   * Mint a new session_id and persist it. Emits `session:reset` carrying the\n   * old id so downstream consumers can stitch.\n   *\n   * Use case: anonymous listener completes sign-up mid-session.\n   */\n  reset(): SessionInfo {\n    const oldSessionId = this.session.sessionId\n    const next: PersistedSession = {\n      sessionId: uuidV4(),\n      startedAt: this.clock.isoNow(),\n      previousSessionId: oldSessionId,\n    }\n    this.session = next\n    this.persist(next)\n    this.bus.emit('session:reset', { oldSessionId, newSessionId: next.sessionId })\n    return this.getSession()\n  }\n\n  /**\n   * Adopt a server-authoritative session id. Persists it so a same-tab reload\n   * stays consistent, preserving `startedAt` when the stored session already\n   * carried this id. Does not emit `session:start` — the server owns the\n   * session lifecycle, so each page render is a continuation, not a new start.\n   */\n  private adoptSeed(seedSessionId: string): SessionInfo {\n    const seeded: PersistedSession = {\n      sessionId: seedSessionId,\n      startedAt: this.clock.isoNow(),\n    }\n    const raw = this.store.get(SESSION_KEY)\n    if (raw) {\n      try {\n        const parsed = JSON.parse(raw) as PersistedSession\n        if (parsed.sessionId === seedSessionId && typeof parsed.startedAt === 'string') {\n          seeded.startedAt = parsed.startedAt\n        }\n      } catch {\n        // Corrupt entry — overwrite with the seed.\n      }\n    }\n    this.persist(seeded)\n    return seeded\n  }\n\n  private loadOrMint(): SessionInfo {\n    const raw = this.store.get(SESSION_KEY)\n    if (raw) {\n      try {\n        const parsed = JSON.parse(raw) as PersistedSession\n        if (typeof parsed.sessionId === 'string' && typeof parsed.startedAt === 'string') {\n          // Don't emit session:start on rehydrate — it's the same session\n          // continuing across a reload.\n          return parsed\n        }\n      } catch {\n        // Corrupt entry — fall through to mint.\n      }\n    }\n    const fresh: PersistedSession = {\n      sessionId: uuidV4(),\n      startedAt: this.clock.isoNow(),\n    }\n    this.persist(fresh)\n    // Defer to a microtask: the SessionManager constructor runs inside\n    // `new PlayerController()`, before the caller has had a chance to\n    // subscribe to `player.bus`. A synchronous emit here would be lost.\n    // We use `Promise.resolve().then(...)` rather than `queueMicrotask` so\n    // tests that call `vi.useFakeTimers()` (which mocks queueMicrotask by\n    // default) still observe the emission via a normal `await`.\n    Promise.resolve().then(() => {\n      this.bus.emit('session:start', { sessionId: fresh.sessionId })\n    })\n    return fresh\n  }\n\n  private persist(s: PersistedSession): void {\n    this.store.set(SESSION_KEY, JSON.stringify(s))\n  }\n}\n","import { AudioEngine } from './AudioEngine'\nimport { CrossFrameBridge } from './CrossFrameBridge'\nimport { EventBus } from './EventBus'\nimport { KeyboardController, type KeyboardControllerOptions } from './KeyboardController'\nimport { QueueManager } from './QueueManager'\nimport { SessionManager } from './SessionManager'\nimport type { Clock } from './internal/clock'\nimport { systemClock } from './internal/clock'\nimport type { KeyValueStore } from './internal/storage'\nimport type { BridgeTransport, PlayerEvents, TrackRef } from './types'\n\nexport interface PlayerControllerOptions {\n  /** Override the wall-clock / perf clock. Tests use this for determinism. */\n  clock?: Clock\n  /** Override session storage. Tests use an in-memory store. */\n  sessionStore?: KeyValueStore\n  /**\n   * Enable keyboard shortcuts. Default: `false` — embedded players don't\n   * hijack global keys unless the host opts in.\n   */\n  keyboard?: boolean | KeyboardControllerOptions\n  /**\n   * Wire a CrossFrameBridge transport (iframe parent, native shell). The\n   * bridge composes onto the same player and forwards events out / commands in.\n   */\n  bridge?: BridgeTransport\n  /**\n   * Server-authoritative play-session id to adopt (from the\n   * `ingestion-session-id` meta tag / `dl_psid` cookie), so emitted\n   * `session_id`s match the ingestion JWT's `sid`. See\n   * {@link SessionManagerOptions.seedSessionId}.\n   */\n  seedSessionId?: string\n}\n\n/**\n * Public façade of @delistening/player. Composes the modules and owns the\n * EventBus.\n *\n * Lifecycle:\n *\n *   const player = new PlayerController()\n *   player.attach(audioElement)\n *   player.queue.load([{ trackUuid, artistUuid }])\n *   await player.play()\n *   …\n *   player.detach()\n *\n * The EventBus is exposed as `player.bus` so @delistening/telemetry can\n * subscribe. Telemetry NEVER reaches into the engine or queue directly — the\n * bus is the only contract.\n */\nexport class PlayerController {\n  readonly bus: EventBus<PlayerEvents>\n  readonly engine: AudioEngine\n  readonly queue: QueueManager\n  readonly session: SessionManager\n  private readonly keyboard: KeyboardController | null\n  private readonly bridge: CrossFrameBridge | null\n  private readonly offEnded: (() => void) | null\n  private visibilityHandler: (() => void) | null = null\n  private visibilityTimer: ReturnType<typeof setTimeout> | null = null\n\n  constructor(options: PlayerControllerOptions = {}) {\n    const clock = options.clock ?? systemClock\n    this.bus = new EventBus<PlayerEvents>()\n    this.engine = new AudioEngine(this.bus, clock)\n    this.queue = new QueueManager(this.bus)\n    this.session = new SessionManager(this.bus, {\n      ...(options.sessionStore !== undefined ? { store: options.sessionStore } : {}),\n      ...(options.seedSessionId !== undefined ? { seedSessionId: options.seedSessionId } : {}),\n      clock,\n    })\n\n    if (options.keyboard) {\n      const kbdOptions = options.keyboard === true ? {} : options.keyboard\n      this.keyboard = new KeyboardController(this.engine, this.queue, kbdOptions)\n    } else {\n      this.keyboard = null\n    }\n\n    this.bridge = options.bridge\n      ? new CrossFrameBridge(this.bus, this.engine, options.bridge)\n      : null\n\n    // Auto-advance on natural end. Skip events (forward seeks past threshold)\n    // don't trigger this — they emit `engine:seeked`, not `engine:ended`.\n    this.offEnded = this.bus.on('engine:ended', () => {\n      this.queue.next('auto')\n    })\n\n    this.wireVisibility()\n  }\n\n  /** Attach to an <audio> element. Idempotent. */\n  attach(element: HTMLAudioElement): void {\n    this.engine.attach(element)\n    this.keyboard?.attach()\n  }\n\n  /** Detach from the current element and release listeners. */\n  detach(): void {\n    this.keyboard?.detach()\n    this.engine.detach()\n  }\n\n  /** Begin playback. Rejects if the browser blocks (e.g. autoplay policy). */\n  async play(): Promise<void> {\n    await this.engine.play()\n  }\n\n  pause(): void {\n    this.engine.pause()\n  }\n\n  /**\n   * Seek to a position in seconds. Negative values clamp to 0; seeking past\n   * the end is allowed (the browser will fire `ended`).\n   */\n  seek(seconds: number): void {\n    this.engine.seek(seconds)\n  }\n\n  /** Swap in a renewed URL for the current audio, carrying on from `resumeAt` (see AudioEngine.replaceSource). */\n  replaceSource(url: string, resumeAt = 0): void {\n    this.engine.replaceSource(url, resumeAt)\n  }\n\n  /** Get the current attached track, if any. */\n  currentTrack(): TrackRef | null {\n    return this.queue.current()\n  }\n\n  /**\n   * Detect autoplay support without actually playing. Useful for adapters\n   * that want to render a \"tap to play\" overlay on mobile Safari.\n   *\n   * Prefers `navigator.getAutoplayPolicy('mediaelement')` when available\n   * (Chrome 100+, Firefox 102+); falls back to a muted-audio probe. The probe\n   * may be blocked by strict CSP (`media-src` excluding `data:`); in that\n   * case this returns `false` even when autoplay would actually work — callers\n   * who care should also feature-detect their CSP.\n   */\n  async canAutoplay(): Promise<boolean> {\n    const nav = globalThis.navigator as\n      | (Navigator & {\n          getAutoplayPolicy?: (type: string) => 'allowed' | 'allowed-muted' | 'disallowed'\n        })\n      | undefined\n    if (nav && typeof nav.getAutoplayPolicy === 'function') {\n      try {\n        return nav.getAutoplayPolicy('mediaelement') === 'allowed'\n      } catch {\n        // fall through to probe\n      }\n    }\n    if (typeof document === 'undefined') return false\n    const probe = document.createElement('audio')\n    probe.muted = true\n    probe.src = 'data:audio/wav;base64,UklGRiQAAABXQVZFZm10IBAAAAABAAEAQB8AAEAfAAABAAgAZGF0YQAAAAA='\n    try {\n      await probe.play()\n      probe.pause()\n      return true\n    } catch {\n      return false\n    }\n  }\n\n  /**\n   * Release all listeners and resources. Call before discarding the player\n   * (e.g. on SPA route change).\n   */\n  destroy(): void {\n    this.offEnded?.()\n    this.bridge?.close()\n    this.keyboard?.detach()\n    this.engine.detach()\n    if (typeof document !== 'undefined' && this.visibilityHandler) {\n      document.removeEventListener('visibilitychange', this.visibilityHandler)\n    }\n    this.visibilityHandler = null\n    if (this.visibilityTimer) {\n      clearTimeout(this.visibilityTimer)\n      this.visibilityTimer = null\n    }\n    this.bus.clear()\n  }\n\n  // ---- Internals ---------------------------------------------------------\n\n  /**\n   * Visibility tracking. Plan §5 item 10: debounce 500ms so a quick alt-tab\n   * doesn't spam events. The debounced final state wins.\n   */\n  private wireVisibility(): void {\n    if (typeof document === 'undefined') return\n    let lastEmitted: boolean | null = null\n    const fire = (): void => {\n      this.visibilityTimer = null\n      const hidden = document.hidden\n      if (hidden === lastEmitted) return\n      lastEmitted = hidden\n      this.bus.emit('visibility:change', { hidden, at: performance.now() })\n    }\n    this.visibilityHandler = (): void => {\n      if (this.visibilityTimer) clearTimeout(this.visibilityTimer)\n      this.visibilityTimer = setTimeout(fire, 500)\n    }\n    document.addEventListener('visibilitychange', this.visibilityHandler)\n  }\n}\n"]}