{"version":3,"sources":["jsdelivr-header.js","/npm/@flowgram.ai/history@1.0.3/src/index.ts","/npm/@flowgram.ai/history@1.0.3/src/operation/operation-contribution.ts","/npm/@flowgram.ai/history@1.0.3/src/operation/operation-registry.ts","/npm/@flowgram.ai/history@1.0.3/src/operation/operation-service.ts","/npm/@flowgram.ai/history@1.0.3/src/history-context.ts","/npm/@flowgram.ai/history@1.0.3/src/history-config.ts","/npm/@flowgram.ai/history@1.0.3/src/history/undo-redo-service.ts","/npm/@flowgram.ai/history@1.0.3/src/history/types.ts","/npm/@flowgram.ai/history@1.0.3/src/history/history-service.ts","/npm/@flowgram.ai/history@1.0.3/src/history/stack-operation.ts","/npm/@flowgram.ai/history@1.0.3/src/history/history-manager.ts","/npm/@flowgram.ai/history@1.0.3/src/history/history-stack.ts","/npm/@flowgram.ai/history@1.0.3/src/history-container-module.ts","/npm/@flowgram.ai/history@1.0.3/src/create-history-plugin.ts"],"names":[],"mappings":"AAAA;AACA;AACA;AACA;AACA;AACA;AACA,qtBCNA,cAAA,GAAA,SAAA,cAAA,CAAA,cAAA,IAAA,cAAA,uBAAA,IAAA,uBAAA,eAAA,IAAA,eAAA,eAAA,IAAA,eAAA,sBAAA,IAAA,sBAAA,eAAA,IAAA,eAAA,aAAA,IAAA,aAAA,uBAAA,IAAA,uBAAA,sBAAA,IAAA,sBAAA,kBAAA,IAAA,kBAAA,iBAAA,IAAA,iBAAA,eAAA,IAAA,eAAA,mBAAA,IAAA,mBAAA,gBAAA,IAAA,gBAAA,oBAAA,IAAA,sBAAA,OAAA,QAAA,aAAA,eCOO,IAAM,sBAAwB,OAAO,yBCF5C,iBAAiE,QAAA,aACjE,aAAiD,QAAA,sBAMpC,kBAAN,iBAAA,GACL,KAAiB,gBAA8C,IAAI,IAInE,KAAmB,cAAyC,EAAC,CAGnD,IAAA,GACR,UAAW,KAAW,KAAK,cACzB,EAAQ,wBAAwB,KAEpC,CAOA,qBAAA,CAAsB,GACpB,GAAI,KAAK,gBAAgB,IAAI,EAAc,MAEzC,OADA,QAAQ,KAAK,oBAAoB,EAAc,+BACxC,aAAA,WAAW,KAGpB,OADkB,IAAI,aAAA,qBAAqB,KAAK,6BAA6B,GAE/E,CAOA,gBAAA,CAAiB,GACf,OAAO,KAAK,gBAAgB,IAAI,EAClC,CAEQ,4BAAA,CAA6B,GAEnC,OADA,KAAK,gBAAgB,IAAI,EAAc,KAAM,GACtC,CACL,QAAS,KACP,KAAK,gBAAgB,OAAO,EAAc,KAAI,EAGpD,GAvCmB,gBAAA,IAFlB,iBAAA,aAAY,wBAAqB,EACjC,iBAAA,aAJU,kBAKQ,UAAA,mBAGT,gBAAA,IADT,iBAAA,kBAPU,kBAQD,UAAA,UARC,kBAAN,gBAAA,IADN,iBAAA,eACY,mBCPb,IAAA,kBAAkD,QAAA,aAClD,cAA8C,QAAA,sBCD9C,kBAA2B,QAAA,aAGd,eAAN,QAAM,eAAN,gBAAA,IADN,kBAAA,eACY,gBCHb,IAAA,cAAuB,QAAA,UACvB,kBAA2B,QAAA,aAGd,cAAN,iBAAA,GACL,KAAA,WAA2B,OAAM,cAAA,UAEjC,KAAA,YAA6B,IAAM,KAHxB,cAAN,gBAAA,IADN,kBAAA,eACY,eFKN,IAAM,iBAAN,iBAAA,GAUL,KAAS,aAAe,IAAI,cAAA,QAE5B,KAAS,QAAU,KAAK,aAAa,MAErC,KAAQ,WAAa,IAAI,cAAA,oBAAqB,CAG9C,IAAA,GACE,KAAK,WAAW,KAAK,KAAK,aAC5B,CAOA,cAAA,CAAe,EAAe,GAC5B,MAAM,EAAO,KAAK,kBAAkB,iBAAiB,EAAG,MAExD,IAAK,EACH,MAAM,IAAI,MAAM,kBAAkB,EAAG,4BAGvC,IAAI,EAOJ,OANK,GAAS,UACZ,EAAM,EAAK,MAAM,EAAI,KAAK,QAAQ,SAGpC,KAAK,aAAa,KAAK,GAEhB,CACT,CAOA,iBAAA,CAAkB,GAChB,MAAM,EAAgB,KAAK,kBAAkB,iBAAiB,EAAU,MAExE,GAAI,GAAiB,EAAc,SACjC,OAAO,EAAc,SAAS,EAAW,KAAK,QAAQ,OAE1D,CAOA,uBAAA,CAAwB,GACtB,MAAM,EAAgB,KAAK,kBAAkB,iBAAiB,EAAU,MAExE,GAAI,GAAiB,EAAc,eACjC,OAAO,EAAc,eAAe,EAAW,KAAK,QAAQ,OAEhE,CAOA,iBAAA,CAAkB,GAChB,OAAO,EAAW,KAAI,GAAM,KAAK,iBAAiB,KAAK,SACzD,CAEA,gBAAA,CAAiB,GACf,MAAM,EAAO,KAAK,kBAAkB,iBAAiB,EAAG,MAExD,IAAK,EACH,MAAM,IAAI,MAAM,kBAAkB,EAAG,4BAEvC,OAAO,EAAK,QAAQ,EACtB,CAEA,OAAA,GACE,KAAK,WAAW,SAClB,GAvFS,gBAAA,IADR,kBAAA,QAAO,oBADG,iBAEF,UAAA,uBAGA,gBAAA,IADR,kBAAA,QAAO,iBAJG,iBAKF,UAAA,aAGT,gBAAA,IADC,kBAAA,QAAO,gBAPG,iBAQX,UAAA,YASA,gBAAA,IADC,kBAAA,kBAhBU,iBAiBX,UAAA,UAjBW,iBAAN,gBAAA,IADN,kBAAA,eACY,kBGTb,IAAA,kBAA2B,QAAA,aAC3B,cAA8C,QAAA,sBCmMlC,mBAAL,CAAK,IACV,EAAA,KAAO,OACP,EAAA,KAAO,OACP,EAAA,KAAO,OACP,EAAA,MAAQ,QAJE,GAAL,CAAK,oBAAA,IAoCA,uBAAL,CAAK,IACV,EAAA,IAAM,MACN,EAAA,OAAS,SACT,EAAA,MAAQ,QACR,EAAA,cAAgB,gBAChB,EAAA,iBAAmB,mBALT,GAAL,CAAK,wBAAA,IAgEA,sBAAL,CAAK,IACV,EAAA,IAAM,MACN,EAAA,OAAS,SAFC,GAAL,CAAK,uBAAA,ID5RC,gBAAN,MAiBL,WAAA,GAZA,KAAQ,UAAoB,EAE5B,KAAQ,UAAoB,EAE5B,KAAQ,OAAiB,IAEzB,KAAU,gBAAkB,IAAI,cAAA,QAEhC,KAAS,SAAW,KAAK,gBAAgB,MAEzC,KAAS,WAAa,IAAI,cAAA,qBAGxB,KAAK,WAAa,GAClB,KAAK,WAAa,GAClB,KAAK,WAAW,KAAK,KAAK,gBAC5B,CAEA,QAAA,CAAS,GACP,KAAK,OAAS,CAChB,CAEA,WAAA,CAAY,GACV,KAAK,WAAa,GAClB,KAAK,WAAW,KAAK,WAAY,GACjC,KAAK,WAAW,KAAK,GACrB,KAAK,YAAA,OAAqC,EAC5C,CAEA,YAAA,GACE,OAAO,KAAK,UACd,CAEA,YAAA,GACE,OAAO,KAAK,UACd,CAEA,cAAA,GACE,OAAO,KAAK,WAAW,KAAK,WAAW,OAAS,EAClD,CAMA,UAAM,GACJ,IAAK,KAAK,UACR,OAGF,GAAI,KAAK,SACP,OAEF,KAAK,UAAW,EAEhB,MAAM,EAAO,KAAK,WAAW,MAE7B,UACQ,EAAK,MACb,SACE,KAAK,WAAW,KAAK,WAAY,GACjC,KAAK,YAAA,OAAqC,GAC1C,KAAK,UAAW,CAClB,CACF,CAMA,UAAM,GACJ,IAAK,KAAK,UACR,OAGF,GAAI,KAAK,SACP,OAEF,KAAK,UAAW,EAEhB,MAAM,EAAO,KAAK,WAAW,MAE7B,UACQ,EAAK,MACb,SACE,KAAK,WAAW,KAAK,WAAY,GACjC,KAAK,YAAA,OAAqC,GAC1C,KAAK,UAAW,CAClB,CACF,CAMA,OAAA,GACE,OAAO,KAAK,WAAW,OAAS,CAClC,CAMA,OAAA,GACE,OAAO,KAAK,WAAW,OAAS,CAClC,CAMA,OAAA,GACE,OAAQ,KAAK,WAAa,KAAK,QACjC,CAKA,KAAA,GACE,KAAK,iBACL,KAAK,iBACL,KAAK,YAAA,QACP,CAKA,cAAA,GACE,KAAK,WAAW,SAAQ,IACtB,EAAQ,SAAQ,IAElB,KAAK,WAAa,EACpB,CAKA,cAAA,GACE,KAAK,WAAW,SAAQ,IACtB,EAAQ,SAAQ,IAElB,KAAK,WAAa,EACpB,CAKA,OAAA,GACE,KAAK,QACL,KAAK,WAAW,SAClB,CAEQ,UAAA,CAAW,EAA2B,GAC5C,EAAM,KAAK,GACP,EAAM,OAAS,KAAK,QACtB,EAAM,OAEV,CAEQ,WAAA,CAAY,EAA0B,GACxC,EACF,KAAK,gBAAgB,KAAK,CAAE,OAAM,YAElC,KAAK,gBAAgB,KAAK,CAAE,QAEhC,GA1KW,gBAAN,gBAAA,IADN,kBAAA,eACY,iBEZb,IAAA,kBAAqB,QAAA,aACrB,kBAAkD,QAAA,aAClD,cAA8C,QAAA,sBCF9C,iBAA0B,QAAA,aAC1B,cAAqC,QAAA,sBAMxB,eAAN,MAmBL,WAAA,CAAY,EAAoC,EAA0B,IAZ1E,KAAQ,WAAa,IAAI,cAAA,qBAEzB,KAAQ,WAAqB,KAAK,MAWhC,KAAK,kBAAoB,EACzB,KAAK,YAAc,EAAW,KAAK,GAAO,KAAK,WAAW,KAC1D,KAAK,IAAM,EAAiB,OAAO,YACrC,CARA,MAAI,GACF,OAAO,KAAK,GACd,CAQA,YAAA,GACE,OAAO,KAAK,UACd,CAEA,aAAA,CAAc,GACZ,MAAM,EAAK,KAAK,WAAW,GAE3B,OADA,KAAK,YAAY,KAAK,GACf,CACT,CAEA,aAAA,GACE,OAAO,KAAK,WACd,CAEA,mBAAA,CAAoB,GAClB,MAAI,SAAA,EACK,KAAK,kBAAkB,kBAAkB,KAAK,aAEhD,KAAK,WACd,CAEA,iBAAA,GACE,OAAO,KAAK,YAAY,EAC1B,CAEA,gBAAA,GACE,OAAO,KAAK,YAAY,KAAK,YAAY,OAAS,EACpD,CAEA,UAAM,GACJ,MAAM,EAAa,KAAK,kBAAkB,kBAAkB,KAAK,aAEjE,UAAW,KAAM,QACT,KAAK,OAAO,EAEtB,CAEA,UAAM,GACJ,UAAW,KAAM,KAAK,kBACd,KAAK,OAAO,EAEtB,CAEA,MAAA,CAAO,GACL,IAAI,EAA0B,KAAK,YAE/B,SAAA,IACF,EAAa,KAAK,YAAY,KAAK,GAAO,KAAK,SAAS,KAAK,WAG/D,UAAW,KAAM,EACf,KAAK,OAAO,EAEhB,CAEQ,QAAA,CAAS,GACf,OAAO,KAAK,kBAAkB,iBAAiB,EACjD,CAEA,YAAc,CAAO,SACb,KAAK,kBAAkB,eAAe,EAC9C,CAEQ,UAAA,CAAW,GACjB,MAAO,IACF,EACH,OAAA,EAAO,iBAAA,WAAU,EAAG,OACpB,GAAI,KAAK,kBAAkB,OAAO,aAEtC,CAEA,OAAA,GACE,KAAK,WAAW,SAClB,GCzGF,kBAAmC,QAAA,aACnC,cAAsD,QAAA,sBCDtD,kBAA0B,QAAA,aAC1B,kBAAmC,QAAA,aACnC,cAA8C,QAAA,sBAiBjC,aAAN,MAcL,WAAA,GAVA,KAAQ,OAAwB,GAEhC,KAAS,gBAAkB,IAAI,cAAA,QAE/B,KAAS,SAAW,KAAK,gBAAgB,MAEzC,KAAQ,WAAmC,IAAI,cAAA,qBAE/C,KAAA,MAAQ,IAGN,KAAK,WAAW,KAAK,KAAK,gBAC5B,CAEA,SAAI,GACF,OAAO,KAAK,MACd,CAEA,GAAA,CAAI,EAAyB,GAC3B,MAAM,EAAc,KAAK,gBAAgB,EAAS,GAUlD,OATA,KAAK,OAAO,QAAQ,GAChB,KAAK,OAAO,OAAS,KAAK,OAC5B,KAAK,OAAO,MAEd,KAAK,gBAAgB,KAAK,CACxB,KAAA,MACA,MAAO,EACP,YAEK,CACT,CAEA,QAAA,CAAS,GACP,OAAO,KAAK,OAAO,MAAM,GAAS,EAAK,KAAO,GAChD,CAEA,aAAA,CAAc,EAAe,EAAyB,GACpD,MAAM,EAAc,KAAK,gBAAgB,EAAS,GAClD,KAAK,OAAO,GAAS,EACrB,KAAK,gBAAgB,KAAK,CACxB,KAAA,SACA,MAAO,EACP,WAEJ,CAEA,YAAA,CAAa,EAAyB,EAAY,GAChD,MAAM,EAAc,KAAK,OAAO,MAAM,GAAS,EAAK,KAAO,IAC3D,IAAK,EAEH,YADA,QAAQ,KAAK,yBAIf,MAAM,EAAe,KAAK,qBAAqB,EAAS,GACxD,EAAY,WAAW,KAAK,GAE5B,KAAK,gBAAgB,KAAK,CACxB,KAAA,gBACA,MAAO,CACL,cACA,UAAW,GAEb,WAEJ,CAEA,eAAA,CAAgB,EAAyB,EAAY,GACnD,MAAM,EAAc,KAAK,OAAO,MAAM,GAAS,EAAK,KAAO,IAC3D,IAAK,EAEH,YADA,QAAQ,KAAK,yBAGf,MAAM,EAAQ,EAAY,WAAW,WAAW,GAAO,EAAG,IAAO,EAAG,KACpE,GAAI,EAAQ,EAEV,YADA,QAAQ,KAAK,sBAGf,MAAM,EAAe,KAAK,qBAAqB,EAAS,GACxD,EAAY,WAAW,OAAO,EAAO,EAAG,GACxC,KAAK,gBAAgB,KAAK,CACxB,KAAA,mBACA,MAAO,CACL,cACA,UAAW,GAEb,WAEJ,CAEA,KAAA,GACE,KAAK,OAAS,EAChB,CAEA,OAAA,GACE,KAAK,OAAS,GACd,KAAK,WAAW,SAClB,CAEQ,eAAA,CAAgB,EAAyB,GAC/C,MAAO,IACF,EACH,IAAK,EAAQ,QAAQ,IACrB,KAAM,aAAa,WAAW,EAAK,WACnC,WAAY,EAAK,WAAW,KAAK,GAC/B,KAAK,qBAAqB,EAAS,EAAS,SAAL,EAAK,QAGlD,CAEQ,oBAAA,CACN,EACA,EACA,GAAsB,GAEtB,IAAI,EACJ,GAAI,EACF,EAAK,KAAK,cAAc,iBACnB,CACL,MAAM,EAAS,EAAuB,GACtC,IAAK,EACH,MAAM,IAAI,MAAM,yBAElB,EAAK,CACP,CAEA,MAAO,KACL,EAAG,kBAAA,WAAU,GACb,KACA,MAAO,EAAQ,iBAAiB,kBAAkB,GAClD,YAAa,EAAQ,iBAAiB,wBAAwB,GAC9D,UAAW,KAAK,MAEpB,CAEA,iBAAO,CAAW,GAChB,OAAO,IAAI,KAAK,GAAW,gBAC7B,GA1IA,gBAAA,IADC,kBAAA,QAAO,gBADG,aAEX,UAAA,mBAFW,aAAN,gBAAA,IADN,kBAAA,eACY,cDDN,IAAM,eAAN,iBAAA,GAKL,KAAQ,iBAAmB,IAAI,IAE/B,KAAQ,WAAa,IAAI,cAAA,oBAAqB,CAE9C,sBAAA,CAAuB,GACrB,MAAM,EAAY,IAAI,cAAA,qBACtB,EAAU,QAAQ,CAChB,EAAQ,gBAAgB,UAAU,IAChC,GAAU,UAAN,EAAM,KACR,OAGF,MAAM,KAAE,EAAA,QAAM,GAAY,EACpB,EAAa,EAAQ,oBAAoB,GACzC,EAAqC,CACzC,GACE,SAAA,EACK,EAA2B,GAC5B,KAAK,cAAc,aACzB,OACA,IAAK,EAAQ,QAAQ,IACrB,aACA,UAAW,KAAK,OAElB,KAAK,aAAa,IAAI,EAAS,EAAgB,IAEjD,EAAQ,SAAS,IACf,KAAK,aAAa,EAAS,EAAK,MAGpC,KAAK,iBAAiB,IAAI,EAAS,GAEnC,KAAK,WAAW,KACd,EAAQ,eAAc,KACpB,KAAK,yBAAyB,EAAO,IAG3C,CAEA,wBAAA,CAAyB,GACvB,MAAM,EAAa,KAAK,iBAAiB,IAAI,GACxC,IAGL,EAAW,UACX,KAAK,iBAAiB,OAAO,GAC/B,CAEA,sBAAA,CAAuB,GACrB,UAAW,KAAW,KAAK,iBAAiB,OAC1C,GAAI,EAAQ,QAAQ,MAAQ,EAC1B,OAAO,CAGb,CAEA,sBAAA,GACE,UAAW,KAAW,KAAK,iBAAiB,OAC1C,OAAO,CAEX,CAEA,OAAA,GACE,KAAK,WAAW,UAChB,KAAK,aAAa,UAElB,KAAK,iBAAiB,SAAS,GAAY,EAAQ,YACnD,KAAK,iBAAiB,OACxB,CAEA,YAAA,CAAa,EAAyB,GACpC,MAAM,QAAE,EAAA,UAAS,GAAc,EAAM,MAExB,KAAK,aAAa,SAAU,EAA2B,MAM9D,EAA8B,IAK1B,WAAN,EAAM,MACR,KAAK,aAAa,gBAChB,EACC,EAA2B,GAC5B,GAIM,QAAN,EAAM,MACR,KAAK,aAAa,aAChB,EACC,EAA2B,GAC5B,IAhBF,QAAQ,KAAK,yBAmBjB,GAvG+B,gBAAA,IAA9B,kBAAA,QAAO,eADG,eACoB,UAAA,kBAEC,gBAAA,IAA/B,kBAAA,QAAO,gBAHG,eAGqB,UAAA,mBAHrB,eAAN,gBAAA,IADN,kBAAA,eACY,gBFGN,IAAM,eAAN,iBAAA,GAmBL,KAAQ,WAAa,IAAI,cAAA,qBAEzB,KAAQ,cAAwB,EAEhC,KAAQ,mBAA4C,KAEpD,KAAQ,SAAmB,EAE3B,KAAQ,oBAAsB,IAAI,cAAA,QAElC,KAAQ,cAAgB,IAAI,cAAA,QAE5B,KAAA,cAAgB,KAAK,oBAAoB,MAEzC,KAAA,QAAU,KAAK,cAAc,KAAA,CAE7B,WAAI,GACF,OAAO,KAAK,iBAAiB,OAC/B,CAGA,IAAA,GACE,KAAK,WAAW,KAAK,KAAK,qBAC1B,KAAK,WAAW,KAAK,KAAK,cAC5B,CAEA,KAAA,GACE,KAAK,SAAU,CACjB,CAEA,IAAA,GACE,KAAK,SAAU,CACjB,CAEA,KAAA,CAAM,GACJ,KAAK,gBAAgB,SAAS,EAChC,CAEA,gBAAA,GACE,GAAI,KAAK,aACP,OAGF,KAAK,cAAe,EACpB,MAAM,EAAiB,IAAI,eAAe,KAAK,iBAAkB,IACjE,KAAK,mBAAqB,CAC5B,CAEA,cAAA,GACE,MAAM,EAAiB,KAAK,mBACvB,IAGyC,IAA1C,EAAe,gBAAgB,QACjC,KAAK,oBAAoB,GAG3B,KAAK,mBAAqB,KAC1B,KAAK,cAAe,EACtB,CAEA,QAAA,CAAS,GACH,KAAK,eAGT,KAAK,mBACL,IACA,KAAK,iBACP,CAEA,aAAA,CAAc,EAAsB,GAClC,IAAK,KAAK,WACR,OAGF,MAAM,EAAO,KAAK,oBAAsB,KAAK,gBAAgB,iBACvD,EAAgB,KAAK,kBAAkB,iBAAiB,EAAU,MAExE,IAAK,EACH,MAAM,IAAI,MAAM,kBAAkB,EAAU,4BAG9C,GAAI,EAAc,aAAe,EAAc,WAAW,GACxD,OAAO,EAAc,MAAM,EAAW,KAAK,QAAQ,QAGrD,MAAM,EAAM,KAAK,iBAAiB,eAAe,EAAW,CAAE,QAAS,GAAS,UAE5E,EAAc,SAAW,EAAU,MACrC,EAAU,IAAM,EAAc,OAAO,EAAW,KAAK,QAAQ,SAG/D,MAAM,EAAc,KAAK,aAAa,EAAW,EAAM,GAEvD,GAAI,EACF,GAA2B,iBAAhB,EAA0B,CACnC,MAAM,EAAY,EAAK,mBACvB,EAAU,MAAQ,EAAY,MAC9B,KAAK,cAAc,KAAK,CACtB,KAAA,SACA,MAAO,CACL,QAAS,EACT,UAAW,EACX,MAAO,EAAY,QAGzB,KAAO,CACL,MAAM,EAAK,EAAK,cAAc,GAC9B,KAAK,cAAc,KAAK,CACtB,KAAA,MACA,MAAO,CACL,QAAS,EACT,UAAW,IAGjB,KACK,CACL,MAAM,EAAiB,IAAI,eAAe,KAAK,iBAAkB,CAAC,IAClE,KAAK,oBAAoB,EAC3B,CAEA,OAAO,CACT,CAEA,oBAAA,GACE,OAAO,KAAK,eAAe,aAAa,MACrC,UACA,KAAK,GACJ,EAAK,WAAW,KAAK,IAAA,KACnB,EAAG,kBAAA,MAAK,EAAG,CAAC,OAAQ,UACpB,MAAO,EAAE,OAAS,EAAE,WAGvB,MACL,CAEA,UAAM,SACE,KAAK,gBAAgB,MAC7B,CAEA,UAAM,SACE,KAAK,gBAAgB,MAC7B,CAEA,OAAA,GACE,OAAO,KAAK,gBAAgB,SAC9B,CAEA,OAAA,GACE,OAAO,KAAK,gBAAgB,SAC9B,CAEA,WAAA,GACE,OAAO,KAAK,OAAO,aACrB,CAEA,UAAA,GACE,MAAM,IAAI,MAAM,0BAClB,CAEA,OAAA,CAAQ,GACN,MAAM,IAAI,MAAM,0BAClB,CAEA,KAAA,GACE,KAAK,gBAAgB,OACvB,CAEA,OAAA,GACE,KAAK,oBAAoB,KAAK,MAC9B,KAAK,WAAW,SAClB,CAEQ,QAAA,GACN,OAAI,KAAK,SAGF,KAAK,gBAAgB,SAC9B,CAEQ,mBAAA,CAAoB,GAC1B,KAAK,gBAAgB,YAAY,GACjC,KAAK,gBAAgB,gBACvB,CAEQ,YAAA,CAAa,EAAsB,EAAwB,GACjE,QAAK,MAID,KAAK,cAIP,EAAc,aACd,EAAc,YAAY,EAAW,EAAK,mBAAoB,GAElE,GAtNS,gBAAA,IADR,kBAAA,QAAO,kBADG,eAEF,UAAA,qBAGA,gBAAA,IADR,kBAAA,QAAO,oBAJG,eAKF,UAAA,uBAGA,gBAAA,IADR,kBAAA,QAAO,mBAPG,eAQF,UAAA,sBAGA,gBAAA,IADR,kBAAA,QAAO,iBAVG,eAWF,UAAA,aAGA,gBAAA,IADR,kBAAA,QAAO,gBAbG,eAcF,UAAA,YAGT,gBAAA,IADC,kBAAA,QAAO,iBAhBG,eAiBX,UAAA,oBAuBA,gBAAA,IADC,kBAAA,kBAvCU,eAwCX,UAAA,UAxCW,eAAN,gBAAA,IADN,kBAAA,eACY,gBIrBb,IAAA,kBAAgC,QAAA,aAYnB,uBAAyB,IAAI,kBAAA,iBACxC,CAAC,EAAM,EAAS,EAAU,EAAS,EAAc,EAAc,KAC7D,EAAK,mBAAmB,SAAS,mBACjC,EAAK,kBAAkB,SAAS,mBAChC,EAAK,iBAAiB,SAAS,mBAC/B,EAAK,gBAAgB,SAAS,mBAC9B,EAAK,gBAAgB,SAAS,mBAC9B,EAAK,gBAAgB,SAAS,mBAC9B,EAAK,cAAc,SAAS,mBAC5B,EAAK,eAAe,SAAS,mBAE7B,EAAa,gBAAgB,CAAC,EAAK,KACjC,IAAI,EAQJ,OALE,EADE,EAAI,WAAW,QAAQ,QAAQ,gBAChB,EAAI,WAAW,QAAQ,IAAI,gBAE3B,EAAI,UAAU,IAAI,gBAGhC,GAIL,EAAe,eAAiB,EAChC,EAAe,uBAAuB,GAC/B,GALE,CAKF,GACR,ICvCL,YAAmD,QAAA,qBAWtC,qBAAA,EAAsB,YAAA,qBAA0C,CAC3E,OAAQ,CAAC,EAAK,KACR,EAAK,SACP,EAAI,IAAI,kBAAkB,QAAQ,EAAK,QAAQ,KAAK,KAAM,GAC5D,EAEF,iBAAkB,CAAC","file":"/npm/@flowgram.ai/history@1.0.3/dist/index.js","sourceRoot":"","sourcesContent":["/**\n * Minified by jsDelivr using Terser v5.39.0.\n * Original file: /npm/@flowgram.ai/history@1.0.3/dist/index.js\n *\n * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files\n */\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nexport * from './operation';\nexport * from './history';\nexport * from './history-container-module';\nexport * from './create-history-plugin';\nexport * from './history-context';\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { OperationRegistry } from './operation-registry';\n\nexport const OperationContribution = Symbol('OperationContribution');\n\nexport interface OperationContribution {\n registerOperationMeta?(operationRegistry: OperationRegistry): void;\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { injectable, multiInject, optional, postConstruct } from 'inversify';\nimport { Disposable, DisposableCollection } from '@flowgram.ai/utils';\n\nimport { OperationMeta } from './types';\nimport { OperationContribution } from './operation-contribution';\n\n@injectable()\nexport class OperationRegistry {\n private readonly _operationMetas: Map = new Map();\n\n @multiInject(OperationContribution)\n @optional()\n protected readonly contributions: OperationContribution[] = [];\n\n @postConstruct()\n protected init() {\n for (const contrib of this.contributions) {\n contrib.registerOperationMeta?.(this);\n }\n }\n\n /**\n * 注册操作的元数据\n * @param operationMeta 操作的元数据\n * @returns 销毁函数\n */\n registerOperationMeta(operationMeta: OperationMeta): Disposable {\n if (this._operationMetas.has(operationMeta.type)) {\n console.warn(`A operation meta ${operationMeta.type} is already registered.`);\n return Disposable.NULL;\n }\n const toDispose = new DisposableCollection(this._doRegisterOperationMetaMeta(operationMeta));\n return toDispose;\n }\n\n /**\n * 获取操作的元数据\n * @param type 操作类型\n * @returns 操作的元数据\n */\n getOperationMeta(type: string): OperationMeta | undefined {\n return this._operationMetas.get(type);\n }\n\n private _doRegisterOperationMetaMeta(operationMeta: OperationMeta): Disposable {\n this._operationMetas.set(operationMeta.type, operationMeta);\n return {\n dispose: () => {\n this._operationMetas.delete(operationMeta.type);\n },\n };\n }\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { injectable, inject, postConstruct } from 'inversify';\nimport { DisposableCollection, Emitter } from '@flowgram.ai/utils';\n\nimport { HistoryContext } from '../history-context';\nimport { HistoryConfig } from '../history-config';\nimport { Operation } from './types';\nimport { OperationRegistry } from './operation-registry';\n\n@injectable()\nexport class OperationService {\n @inject(OperationRegistry)\n readonly operationRegistry: OperationRegistry;\n\n @inject(HistoryContext)\n readonly context: HistoryContext;\n\n @inject(HistoryConfig)\n config: HistoryConfig;\n\n readonly applyEmitter = new Emitter();\n\n readonly onApply = this.applyEmitter.event;\n\n private _toDispose = new DisposableCollection();\n\n @postConstruct()\n init() {\n this._toDispose.push(this.applyEmitter);\n }\n\n /**\n * 执行操作\n * @param op\n * @returns\n */\n applyOperation(op: Operation, options?: { noApply?: boolean }): any {\n const meta = this.operationRegistry.getOperationMeta(op.type);\n\n if (!meta) {\n throw new Error(`Operation meta ${op.type} has not registered.`);\n }\n\n let res;\n if (!options?.noApply) {\n res = meta.apply(op, this.context.source);\n }\n\n this.applyEmitter.fire(op);\n\n return res;\n }\n\n /**\n * 根据操作类型获取操作的label\n * @param operation 操作\n * @returns\n */\n getOperationLabel(operation: Operation): string | undefined {\n const operationMeta = this.operationRegistry.getOperationMeta(operation.type);\n\n if (operationMeta && operationMeta.getLabel) {\n return operationMeta.getLabel(operation, this.context.source);\n }\n }\n\n /**\n * 根据操作类型获取操作的description\n * @param operation 操作\n * @returns\n */\n getOperationDescription(operation: Operation): string | undefined {\n const operationMeta = this.operationRegistry.getOperationMeta(operation.type);\n\n if (operationMeta && operationMeta.getDescription) {\n return operationMeta.getDescription(operation, this.context.source);\n }\n }\n\n /**\n * 操作取反\n * @param operations\n * @returns\n */\n inverseOperations(operations: Operation[]) {\n return operations.map(op => this.inverseOperation(op)).reverse();\n }\n\n inverseOperation(op: Operation): Operation {\n const meta = this.operationRegistry.getOperationMeta(op.type);\n\n if (!meta) {\n throw new Error(`Operation meta ${op.type} has not registered.`);\n }\n return meta.inverse(op);\n }\n\n dispose() {\n this._toDispose.dispose();\n }\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { injectable } from 'inversify';\n\n@injectable()\nexport class HistoryContext {\n /**\n * 所属uri\n */\n uri?: string;\n\n /**\n * 操作触发的源对象，如编辑器对象\n */\n source?: unknown;\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { nanoid } from 'nanoid';\nimport { injectable } from 'inversify';\n\n@injectable()\nexport class HistoryConfig {\n generateId: () => string = () => nanoid();\n\n getSnapshot: () => unknown = () => '';\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { injectable } from 'inversify';\nimport { Emitter, DisposableCollection } from '@flowgram.ai/utils';\n\nimport {\n IUndoRedoElement,\n IUndoRedoService,\n UndoRedoChangeType,\n UndoRedoChangeEvent,\n UndoRedoClearEvent,\n} from './types';\n\n@injectable()\nexport class UndoRedoService implements IUndoRedoService {\n private _undoStack: IUndoRedoElement[];\n\n private _redoStack: IUndoRedoElement[];\n\n private _undoing: boolean = false;\n\n private _redoing: boolean = false;\n\n private _limit: number = 100;\n\n protected onChangeEmitter = new Emitter();\n\n readonly onChange = this.onChangeEmitter.event;\n\n readonly _toDispose = new DisposableCollection();\n\n constructor() {\n this._undoStack = [];\n this._redoStack = [];\n this._toDispose.push(this.onChangeEmitter);\n }\n\n setLimit(limit: number) {\n this._limit = limit;\n }\n\n pushElement(element: IUndoRedoElement): void {\n this._redoStack = [];\n this._stackPush(this._undoStack, element);\n this._toDispose.push(element);\n this._emitChange(UndoRedoChangeType.PUSH, element);\n }\n\n getUndoStack() {\n return this._undoStack;\n }\n\n getRedoStack() {\n return this._redoStack;\n }\n\n getLastElement() {\n return this._undoStack[this._undoStack.length - 1];\n }\n\n /**\n * 执行undo\n * @returns void\n */\n async undo(): Promise {\n if (!this.canUndo()) {\n return;\n }\n\n if (this._undoing) {\n return;\n }\n this._undoing = true;\n\n const item = this._undoStack.pop() as IUndoRedoElement;\n\n try {\n await item.undo();\n } finally {\n this._stackPush(this._redoStack, item);\n this._emitChange(UndoRedoChangeType.UNDO, item);\n this._undoing = false;\n }\n }\n\n /**\n * 执行redo\n * @returns void\n */\n async redo(): Promise {\n if (!this.canRedo()) {\n return;\n }\n\n if (this._redoing) {\n return;\n }\n this._redoing = true;\n\n const item = this._redoStack.pop() as IUndoRedoElement;\n\n try {\n await item.redo();\n } finally {\n this._stackPush(this._undoStack, item);\n this._emitChange(UndoRedoChangeType.REDO, item);\n this._redoing = false;\n }\n }\n\n /**\n * 是否可undo\n * @returns true代表可以，false代表不可以\n */\n canUndo(): boolean {\n return this._undoStack.length > 0;\n }\n\n /**\n * 是否可redo\n * @returns true代表可以，false代表不可以\n */\n canRedo(): boolean {\n return this._redoStack.length > 0;\n }\n\n /**\n * 是否可以push\n * @returns true代表可以，false代表不可以\n */\n canPush(): boolean {\n return !this._redoing && !this._undoing;\n }\n\n /**\n * 清空\n */\n clear() {\n this.clearRedoStack();\n this.clearUndoStack();\n this._emitChange(UndoRedoChangeType.CLEAR);\n }\n\n /**\n * 清空redo栈\n */\n clearRedoStack(): void {\n this._redoStack.forEach(element => {\n element.dispose();\n });\n this._redoStack = [];\n }\n\n /**\n * 清空undo栈\n */\n clearUndoStack(): void {\n this._undoStack.forEach(element => {\n element.dispose();\n });\n this._undoStack = [];\n }\n\n /**\n * 销毁\n */\n dispose(): void {\n this.clear();\n this._toDispose.dispose();\n }\n\n private _stackPush(stack: IUndoRedoElement[], element: IUndoRedoElement) {\n stack.push(element);\n if (stack.length > this._limit) {\n stack.shift();\n }\n }\n\n private _emitChange(type: UndoRedoChangeType, element?: IUndoRedoElement) {\n if (element) {\n this.onChangeEmitter.fire({ type, element });\n } else {\n this.onChangeEmitter.fire({ type } as UndoRedoClearEvent);\n }\n }\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { Disposable } from '@flowgram.ai/utils';\n\nimport { HistoryOperation, Operation } from '../operation';\nimport { HistoryService } from './history-service';\n\nexport interface HistoryRecord {\n snapshot: any;\n stack: any[];\n}\n\nexport interface HistoryItem extends HistoryStackItem {\n id: string;\n time: string;\n operations: HistoryOperation[];\n}\n\n/**\n * 历史服务管理\n */\nexport interface IHistoryManager {\n /**\n * 注册历史服务\n * @param service 历史服务示例\n */\n registerHistoryService(service: IHistoryService): void;\n /**\n * 取消注册历史服务\n * @param service 历史服务示例\n */\n unregisterHistoryService(service: HistoryService): void;\n}\n\n/**\n * 历史服务\n */\nexport interface IHistoryService extends Disposable {\n /**\n * 添加操作\n * @param operation 操作\n */\n pushOperation(operation: Operation): void | Promise;\n /**\n * 获取所有历史操作\n */\n getHistoryOperations(): Operation[];\n /**\n * 撤回\n */\n undo(): void | Promise;\n /**\n * 重做\n */\n redo(): void | Promise;\n /**\n * 是否有可撤销的操作\n */\n canUndo(): boolean;\n /**\n * 是否有可重做的操作\n */\n canRedo(): boolean;\n /**\n * 获取历史记录\n */\n getRecords(): Promise;\n /**\n * 根据历史版本重新存储历史记录\n * @param historyRecord 历史记录\n */\n restore(historyRecord: HistoryRecord): Promise;\n /**\n * 清空undo/redo\n */\n clear(): void;\n /**\n * 最大数量限制\n * @param num 数量\n */\n limit(num: number): void;\n /**\n * 返回快照\n */\n getSnapshot(): unknown;\n}\n\nexport interface IOperationService {\n pushOperation(operation: Operation): void;\n}\n\n/**\n * UndoRedo服务\n */\nexport interface IUndoRedoService extends Disposable {\n /**\n * 添加一个undo/redo元素\n * @param element 可undo/redo的元素\n */\n pushElement(element: IUndoRedoElement): void;\n /**\n * 获取最后一个可undo的元素\n */\n getLastElement(): IUndoRedoElement;\n /**\n * 获取undo栈\n */\n getUndoStack(): IUndoRedoElement[];\n /**\n * 获取redo栈\n */\n getRedoStack(): IUndoRedoElement[];\n /**\n * 清空redo栈\n */\n clearRedoStack(): void;\n /**\n * 是否可undo\n */\n canUndo(): boolean;\n /**\n * 执行undo\n */\n undo(): Promise | void;\n /**\n * 是否可redo\n */\n canRedo(): boolean;\n /**\n * 执行redo\n */\n redo(): Promise | void;\n /**\n * 清空 undo和redo栈\n */\n clear(): void;\n}\n\n/**\n * UndoRedo元素\n */\nexport interface IUndoRedoElement extends Disposable {\n /**\n * 操作标题\n */\n readonly label?: string;\n /**\n * 操作描述\n */\n readonly description?: string;\n /**\n * 撤销\n */\n undo(): Promise | void;\n /**\n * 重做\n */\n redo(): Promise | void;\n /**\n * 添加一个操作\n * @param operation 操作\n */\n pushOperation(operation: Operation): Operation;\n /**\n * 获取所有操作\n */\n getOperations(): Operation[];\n /**\n * 获取第一个操作\n */\n getFirstOperation(): Operation;\n /**\n * 获取最后一个操作\n */\n getLastOperation(): Operation;\n /**\n * 获取修改的操作\n */\n getChangeOperations(type: UndoRedoChangeType): Operation[];\n}\n\n/**\n * 操作注册\n */\nexport interface IOperationRegistry {\n register(type: string, factory: IUndoRedoElementFactory): void;\n}\n\n/**\n * 操作工厂\n */\nexport type IUndoRedoElementFactory = (\n operation: Operation\n) => IUndoRedoElement;\n\n/**\n * undo redo 类型\n */\nexport enum UndoRedoChangeType {\n UNDO = 'undo',\n REDO = 'redo',\n PUSH = 'push',\n CLEAR = 'clear',\n}\n\n/**\n * 带element的事件\n */\nexport interface UndoRedoChangeElementEvent {\n type: UndoRedoChangeType.PUSH | UndoRedoChangeType.UNDO | UndoRedoChangeType.REDO;\n element: IUndoRedoElement;\n}\n/**\n * 清空事件\n */\nexport interface UndoRedoClearEvent {\n type: UndoRedoChangeType.CLEAR;\n}\n/**\n * undo redo变化事件\n */\nexport type UndoRedoChangeEvent = UndoRedoChangeElementEvent | UndoRedoClearEvent;\n\nexport interface HistoryStackItem {\n id: string;\n type: UndoRedoChangeType;\n timestamp: number;\n operations: Operation[];\n uri?: string;\n}\n\n/**\n * 历史栈变化类型\n */\nexport enum HistoryStackChangeType {\n ADD = 'add',\n UPDATE = 'update',\n CLEAR = 'clear',\n ADD_OPERATION = 'add_operation',\n UPDATE_OPERATION = 'update_operation',\n}\n\n/**\n * 历史栈变化事件基础\n */\nexport interface HistoryStackBaseEvent {\n type: HistoryStackChangeType;\n value?: any;\n service: HistoryService;\n}\n\n/**\n * 添加历史事件\n */\nexport interface HistoryStackAddEvent extends HistoryStackBaseEvent {\n type: HistoryStackChangeType.ADD;\n value: HistoryItem;\n}\n\n/**\n * 更新历史事件\n */\nexport interface HistoryStackUpdateEvent extends HistoryStackBaseEvent {\n type: HistoryStackChangeType.UPDATE;\n value: HistoryItem;\n}\n\n/**\n * 添加操作事件\n */\nexport interface HistoryStackAddOperationEvent extends HistoryStackBaseEvent {\n type: HistoryStackChangeType.ADD_OPERATION;\n value: {\n historyItem: HistoryItem;\n operation: HistoryOperation;\n };\n}\n\n/**\n * 更新操作事件\n */\nexport interface HistoryStackUpdateOperationEvent extends HistoryStackBaseEvent {\n type: HistoryStackChangeType.UPDATE_OPERATION;\n value: {\n historyItem: HistoryItem;\n operation: HistoryOperation;\n };\n}\n\n/**\n * 历史记录变化事件\n */\nexport type HistoryStackChangeEvent =\n | HistoryStackAddEvent\n | HistoryStackUpdateEvent\n | HistoryStackAddOperationEvent\n | HistoryStackUpdateOperationEvent;\n\nexport enum HistoryMergeEventType {\n ADD = 'ADD',\n UPDATE = 'UPDATE',\n}\n\n/**\n * 历史合并事件\n */\nexport type HistoryMergeEvent =\n | {\n type: HistoryMergeEventType.ADD;\n value: {\n element: IUndoRedoElement;\n operation: Operation;\n };\n }\n | {\n type: HistoryMergeEventType.UPDATE;\n value: {\n element: IUndoRedoElement;\n operation: Operation;\n value: any;\n };\n };\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { pick } from 'lodash-es';\nimport { injectable, inject, postConstruct } from 'inversify';\nimport { DisposableCollection, Emitter } from '@flowgram.ai/utils';\n\nimport { OperationService } from '../operation/operation-service';\nimport { OperationMeta, OperationRegistry, PushOperationOptions } from '../operation';\nimport { Operation } from '../operation';\nimport { HistoryContext } from '../history-context';\nimport { HistoryConfig } from '../history-config';\nimport { UndoRedoService } from './undo-redo-service';\nimport {\n HistoryMergeEvent,\n HistoryMergeEventType,\n HistoryRecord,\n IHistoryService,\n IUndoRedoElement,\n} from './types';\nimport { StackOperation } from './stack-operation';\nimport { HistoryManager } from './history-manager';\n\n@injectable()\nexport class HistoryService implements IHistoryService {\n @inject(UndoRedoService)\n readonly undoRedoService: UndoRedoService;\n\n @inject(OperationRegistry)\n readonly operationRegistry: OperationRegistry;\n\n @inject(OperationService)\n readonly operationService: OperationService;\n\n @inject(HistoryContext)\n readonly context: HistoryContext;\n\n @inject(HistoryConfig)\n readonly config: HistoryConfig;\n\n @inject(HistoryManager)\n historyManager: HistoryManager;\n\n private _toDispose = new DisposableCollection();\n\n private _transacting: boolean = false;\n\n private _transactOperation: StackOperation | null = null;\n\n private _locked: boolean = false;\n\n private _willDisposeEmitter = new Emitter();\n\n private _mergeEmitter = new Emitter();\n\n onWillDispose = this._willDisposeEmitter.event;\n\n onMerge = this._mergeEmitter.event;\n\n get onApply() {\n return this.operationService.onApply;\n }\n\n @postConstruct()\n init() {\n this._toDispose.push(this._willDisposeEmitter);\n this._toDispose.push(this._mergeEmitter);\n }\n\n start() {\n this._locked = false;\n }\n\n stop() {\n this._locked = true;\n }\n\n limit(num: number) {\n this.undoRedoService.setLimit(num);\n }\n\n startTransaction() {\n if (this._transacting) {\n return;\n }\n\n this._transacting = true;\n const stackOperation = new StackOperation(this.operationService, []);\n this._transactOperation = stackOperation;\n }\n\n endTransaction() {\n const stackOperation = this._transactOperation;\n if (!stackOperation) {\n return;\n }\n if (stackOperation.getOperations().length !== 0) {\n this._pushStackOperation(stackOperation);\n }\n\n this._transactOperation = null;\n this._transacting = false;\n }\n\n transact(transaction: () => void) {\n if (this._transacting) {\n return;\n }\n this.startTransaction();\n transaction();\n this.endTransaction();\n }\n\n pushOperation(operation: Operation, options?: PushOperationOptions): any {\n if (!this._canPush()) {\n return;\n }\n\n const prev = this._transactOperation || this.undoRedoService.getLastElement();\n const operationMeta = this.operationRegistry.getOperationMeta(operation.type) as OperationMeta;\n\n if (!operationMeta) {\n throw new Error(`Operation meta ${operation.type} has not registered.`);\n }\n\n if (operationMeta.shouldSave && !operationMeta.shouldSave(operation)) {\n return operationMeta.apply(operation, this.context.source);\n }\n\n const res = this.operationService.applyOperation(operation, { noApply: options?.noApply });\n\n if (operationMeta.getURI && !operation.uri) {\n operation.uri = operationMeta.getURI(operation, this.context.source);\n }\n\n const shouldMerge = this._shouldMerge(operation, prev, operationMeta);\n\n if (shouldMerge) {\n if (typeof shouldMerge === 'object') {\n const operation = prev.getLastOperation();\n operation.value = shouldMerge.value;\n this._mergeEmitter.fire({\n type: HistoryMergeEventType.UPDATE,\n value: {\n element: prev,\n operation: operation,\n value: shouldMerge.value,\n },\n });\n } else {\n const op = prev.pushOperation(operation);\n this._mergeEmitter.fire({\n type: HistoryMergeEventType.ADD,\n value: {\n element: prev,\n operation: op,\n },\n });\n }\n } else {\n const stackOperation = new StackOperation(this.operationService, [operation]);\n this._pushStackOperation(stackOperation);\n }\n\n return res;\n }\n\n getHistoryOperations(): Operation[] {\n return this.historyManager.historyStack.items\n .reverse()\n .map((item) =>\n item.operations.map((o) => ({\n ...pick(o, ['type', 'value']),\n label: o.label || o.type,\n }))\n )\n .flat();\n }\n\n async undo(): Promise {\n await this.undoRedoService.undo();\n }\n\n async redo(): Promise {\n await this.undoRedoService.redo();\n }\n\n canUndo(): boolean {\n return this.undoRedoService.canUndo();\n }\n\n canRedo(): boolean {\n return this.undoRedoService.canRedo();\n }\n\n getSnapshot(): unknown {\n return this.config.getSnapshot();\n }\n\n getRecords(): Promise {\n throw new Error('Method not implemented.');\n }\n\n restore(historyRecord: HistoryRecord): Promise {\n throw new Error('Method not implemented.');\n }\n\n clear() {\n this.undoRedoService.clear();\n }\n\n dispose(): void {\n this._willDisposeEmitter.fire(this);\n this._toDispose.dispose();\n }\n\n private _canPush() {\n if (this._locked) {\n return false;\n }\n return this.undoRedoService.canPush();\n }\n\n private _pushStackOperation(stackOperation: StackOperation) {\n this.undoRedoService.pushElement(stackOperation);\n this.undoRedoService.clearRedoStack();\n }\n\n private _shouldMerge(operation: Operation, prev: IUndoRedoElement, operationMeta: OperationMeta) {\n if (!prev) {\n return false;\n }\n\n if (this._transacting) {\n return true;\n }\n return (\n operationMeta.shouldMerge &&\n operationMeta.shouldMerge(operation, prev.getLastOperation(), prev as StackOperation)\n );\n }\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { cloneDeep } from 'lodash-es';\nimport { DisposableCollection } from '@flowgram.ai/utils';\n\nimport { OperationService } from '../operation/operation-service';\nimport { Operation, OperationWithId } from '../operation';\nimport { IUndoRedoElement, UndoRedoChangeType } from './types';\n\nexport class StackOperation implements IUndoRedoElement {\n label?: string | undefined;\n\n description?: string | undefined;\n\n private _operations: OperationWithId[];\n\n private _toDispose = new DisposableCollection();\n\n private _timestamp: number = Date.now();\n\n private _operationService: OperationService;\n\n private _id: string;\n\n get id() {\n return this._id;\n }\n\n constructor(operationService: OperationService, operations: Operation[] = []) {\n this._operationService = operationService;\n this._operations = operations.map((op) => this._operation(op));\n this._id = operationService.config.generateId();\n }\n\n getTimestamp(): number {\n return this._timestamp;\n }\n\n pushOperation(operation: Operation): OperationWithId {\n const op = this._operation(operation);\n this._operations.push(op);\n return op;\n }\n\n getOperations(): Operation[] {\n return this._operations;\n }\n\n getChangeOperations(type: UndoRedoChangeType): Operation[] {\n if (type === UndoRedoChangeType.UNDO) {\n return this._operationService.inverseOperations(this._operations);\n }\n return this._operations;\n }\n\n getFirstOperation(): Operation {\n return this._operations[0];\n }\n\n getLastOperation(): Operation {\n return this._operations[this._operations.length - 1];\n }\n\n async undo(): Promise {\n const inverseOps = this._operationService.inverseOperations(this._operations);\n\n for (const op of inverseOps) {\n await this._apply(op);\n }\n }\n\n async redo(): Promise {\n for (const op of this._operations) {\n await this._apply(op);\n }\n }\n\n revert(type: UndoRedoChangeType): void | Promise {\n let operations: Operation[] = this._operations;\n\n if (type !== UndoRedoChangeType.UNDO) {\n operations = this._operations.map((op) => this._inverse(op)).reverse();\n }\n\n for (const op of operations) {\n this._apply(op);\n }\n }\n\n private _inverse(op: Operation): Operation {\n return this._operationService.inverseOperation(op);\n }\n\n private async _apply(op: Operation) {\n await this._operationService.applyOperation(op);\n }\n\n private _operation(op: Operation) {\n return {\n ...op,\n value: cloneDeep(op.value),\n id: this._operationService.config.generateId(),\n };\n }\n\n dispose(): void {\n this._toDispose.dispose();\n }\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { inject, injectable } from 'inversify';\nimport { type Disposable, DisposableCollection } from '@flowgram.ai/utils';\n\nimport { OperationWithId } from '../operation';\nimport { HistoryConfig } from '../history-config';\nimport { type UndoRedoChangeEvent } from './types';\nimport {\n type IHistoryManager,\n type HistoryStackItem,\n UndoRedoChangeType,\n HistoryMergeEventType,\n HistoryMergeEvent,\n} from './types';\nimport { StackOperation } from './stack-operation';\nimport { HistoryStack } from './history-stack';\nimport { type HistoryService } from './history-service';\n\n@injectable()\nexport class HistoryManager implements IHistoryManager {\n @inject(HistoryStack) readonly historyStack: HistoryStack;\n\n @inject(HistoryConfig) readonly historyConfig: HistoryConfig;\n\n private _historyServices = new Map();\n\n private _toDispose = new DisposableCollection();\n\n registerHistoryService(service: HistoryService): void {\n const toDispose = new DisposableCollection();\n toDispose.pushAll([\n service.undoRedoService.onChange((event: UndoRedoChangeEvent) => {\n if (event.type === UndoRedoChangeType.CLEAR) {\n return;\n }\n\n const { type, element } = event;\n const operations = element.getChangeOperations(type);\n const historyStackItem: HistoryStackItem = {\n id:\n type === UndoRedoChangeType.PUSH\n ? (element as StackOperation).id\n : this.historyConfig.generateId(),\n type,\n uri: service.context.uri,\n operations,\n timestamp: Date.now(),\n };\n this.historyStack.add(service, historyStackItem);\n }),\n service.onMerge((event) => {\n this._handleMerge(service, event);\n }),\n ]);\n this._historyServices.set(service, toDispose);\n\n this._toDispose.push(\n service.onWillDispose(() => {\n this.unregisterHistoryService(service);\n })\n );\n }\n\n unregisterHistoryService(service: HistoryService): void {\n const disposable = this._historyServices.get(service);\n if (!disposable) {\n return;\n }\n disposable.dispose();\n this._historyServices.delete(service);\n }\n\n getHistoryServiceByURI(uri: string) {\n for (const service of this._historyServices.keys()) {\n if (service.context.uri === uri) {\n return service;\n }\n }\n }\n\n getFirstHistoryService() {\n for (const service of this._historyServices.keys()) {\n return service;\n }\n }\n\n dispose(): void {\n this._toDispose.dispose();\n this.historyStack.dispose();\n\n this._historyServices.forEach((service) => service.dispose());\n this._historyServices.clear();\n }\n\n _handleMerge(service: HistoryService, event: HistoryMergeEvent) {\n const { element, operation } = event.value;\n\n const find = this.historyStack.findById((element as StackOperation).id);\n\n if (!find) {\n return;\n }\n\n if (!(operation as OperationWithId).id) {\n console.warn('no operation id found');\n return;\n }\n\n if (event.type === HistoryMergeEventType.UPDATE) {\n this.historyStack.updateOperation(\n service,\n (element as StackOperation).id,\n operation as OperationWithId\n );\n }\n\n if (event.type === HistoryMergeEventType.ADD) {\n this.historyStack.addOperation(\n service,\n (element as StackOperation).id,\n operation as OperationWithId\n );\n }\n }\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { cloneDeep } from 'lodash-es';\nimport { injectable, inject } from 'inversify';\nimport { DisposableCollection, Emitter } from '@flowgram.ai/utils';\n\nimport { HistoryOperation, Operation, OperationWithId } from '../operation';\nimport { HistoryConfig } from '../history-config';\nimport {\n type HistoryItem,\n HistoryStackChangeType,\n type HistoryStackItem,\n HistoryStackChangeEvent,\n UndoRedoChangeType,\n} from './types';\nimport { type HistoryService } from './history-service';\n\n/**\n * 历史栈，聚合所有历史操作\n */\n@injectable()\nexport class HistoryStack {\n @inject(HistoryConfig)\n historyConfig: HistoryConfig;\n\n private _items: HistoryItem[] = [];\n\n readonly onChangeEmitter = new Emitter();\n\n readonly onChange = this.onChangeEmitter.event;\n\n private _toDispose: DisposableCollection = new DisposableCollection();\n\n limit = 100;\n\n constructor() {\n this._toDispose.push(this.onChangeEmitter);\n }\n\n get items(): HistoryItem[] {\n return this._items;\n }\n\n add(service: HistoryService, item: HistoryStackItem) {\n const historyItem = this._getHistoryItem(service, item);\n this._items.unshift(historyItem);\n if (this._items.length > this.limit) {\n this._items.pop();\n }\n this.onChangeEmitter.fire({\n type: HistoryStackChangeType.ADD,\n value: historyItem,\n service,\n });\n return historyItem;\n }\n\n findById(id: string): HistoryItem | undefined {\n return this._items.find((item) => item.id === id);\n }\n\n changeByIndex(index: number, service: HistoryService, item: HistoryStackItem) {\n const historyItem = this._getHistoryItem(service, item);\n this._items[index] = historyItem;\n this.onChangeEmitter.fire({\n type: HistoryStackChangeType.UPDATE,\n value: historyItem,\n service,\n });\n }\n\n addOperation(service: HistoryService, id: string, op: OperationWithId) {\n const historyItem = this._items.find((item) => item.id === id);\n if (!historyItem) {\n console.warn('no history item found');\n return;\n }\n\n const newOperatopn = this._getHistoryOperation(service, op);\n historyItem.operations.push(newOperatopn);\n\n this.onChangeEmitter.fire({\n type: HistoryStackChangeType.ADD_OPERATION,\n value: {\n historyItem,\n operation: newOperatopn,\n },\n service,\n });\n }\n\n updateOperation(service: HistoryService, id: string, op: OperationWithId) {\n const historyItem = this._items.find((item) => item.id === id);\n if (!historyItem) {\n console.warn('no history item found');\n return;\n }\n const index = historyItem.operations.findIndex((op) => op.id === op.id);\n if (index < 0) {\n console.warn('no operation found');\n return;\n }\n const newOperatopn = this._getHistoryOperation(service, op);\n historyItem.operations.splice(index, 1, newOperatopn);\n this.onChangeEmitter.fire({\n type: HistoryStackChangeType.UPDATE_OPERATION,\n value: {\n historyItem,\n operation: newOperatopn,\n },\n service,\n });\n }\n\n clear() {\n this._items = [];\n }\n\n dispose() {\n this._items = [];\n this._toDispose.dispose();\n }\n\n private _getHistoryItem(service: HistoryService, item: HistoryStackItem): HistoryItem {\n return {\n ...item,\n uri: service.context.uri,\n time: HistoryStack.dateFormat(item.timestamp),\n operations: item.operations.map((op) =>\n this._getHistoryOperation(service, op, item.type !== UndoRedoChangeType.PUSH)\n ),\n };\n }\n\n private _getHistoryOperation(\n service: HistoryService,\n op: Operation,\n generateId: boolean = false\n ): HistoryOperation {\n let id;\n if (generateId) {\n id = this.historyConfig.generateId();\n } else {\n const oldId = (op as OperationWithId).id;\n if (!oldId) {\n throw new Error('no operation id found');\n }\n id = oldId;\n }\n\n return {\n ...cloneDeep(op),\n id,\n label: service.operationService.getOperationLabel(op),\n description: service.operationService.getOperationDescription(op),\n timestamp: Date.now(),\n };\n }\n\n static dateFormat(timestamp: number) {\n return new Date(timestamp).toLocaleString();\n }\n}\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { ContainerModule } from 'inversify';\n\nimport { OperationRegistry, OperationService } from './operation';\nimport { HistoryContext } from './history-context';\nimport {\n HistoryService,\n HistoryStack,\n HistoryManager,\n UndoRedoService,\n HistoryConfig,\n} from './history';\n\nexport const HistoryContainerModule = new ContainerModule(\n (bind, _unbind, _isBound, _rebind, _unbindAsync, onActivation, _onDeactivation) => {\n bind(OperationRegistry).toSelf().inSingletonScope();\n bind(OperationService).toSelf().inSingletonScope();\n bind(UndoRedoService).toSelf().inSingletonScope();\n bind(HistoryService).toSelf().inSingletonScope();\n bind(HistoryContext).toSelf().inSingletonScope();\n bind(HistoryManager).toSelf().inSingletonScope();\n bind(HistoryStack).toSelf().inSingletonScope();\n bind(HistoryConfig).toSelf().inSingletonScope();\n\n onActivation(HistoryService, (ctx, historyService) => {\n let historyManager;\n\n if (ctx.container?.parent?.isBound(HistoryManager)) {\n historyManager = ctx.container?.parent?.get(HistoryManager);\n } else {\n historyManager = ctx.container.get(HistoryManager);\n }\n\n if (!historyManager) {\n return historyService;\n }\n\n historyService.historyManager = historyManager;\n historyManager.registerHistoryService(historyService);\n return historyService;\n });\n }\n);\n","/**\n * Copyright (c) 2025 Bytedance Ltd. and/or its affiliates\n * SPDX-License-Identifier: MIT\n */\n\nimport { definePluginCreator, PluginContext } from '@flowgram.ai/core';\n\nimport { Operation, OperationService } from './operation';\nimport { HistoryContainerModule } from './history-container-module';\n\nexport interface HistoryPluginOptions {\n enable?: boolean;\n enableChangeNode?: boolean;\n onApply?: (ctx: T, operation: Operation) => void;\n}\n\nexport const createHistoryPlugin = definePluginCreator({\n onInit: (ctx, opts) => {\n if (opts.onApply) {\n ctx.get(OperationService).onApply(opts.onApply.bind(null, ctx));\n }\n },\n containerModules: [HistoryContainerModule],\n});\n"]}