@glidemq/hapi - npm Package Compare versions

Comparing version 0.2.0 to 0.3.0

CHANGELOG.md

 # Changelog
 
+## 0.3.0
+
+- Added AI-native endpoints: flow usage, flow budget, job stream SSE
+- Added AI fields to job serialization: `usage`, `signals`, `budgetKey`, `fallbackIndex`, `tpmTokens`
+- Added AI event types to SSE: `usage`, `suspended`, `budget-exceeded`
+- Added `serializer` option to `GlideMQConfig` and `ProducerConfig`
+- Updated README to reflect merged routes API
+
 ## 0.2.0
@@ -4,0 +12,0 @@

dist/events.js

@@ -126,3 +126,3 @@ "use strict";
     const ac = new AbortController();
-    const eventTypes = ['completed', 'failed', 'progress', 'stalled', 'active', 'waiting'];
+    const eventTypes = ['completed', 'failed', 'progress', 'stalled', 'active', 'waiting', 'usage', 'suspended', 'budget-exceeded'];
     const listeners = [];
@@ -129,0 +129,0 @@ for (const eventType of eventTypes) {

dist/events.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"events.js","sourceRoot":"","sources":["../src/events.ts"],"names":[],"mappings":";;;;;AA6FA,kDAsCC;AAnID,mCAAqC;AAErC,sDAA8B;AAQ9B,MAAM,gBAAgB,GAAkD,CAAC,GAAG,EAAE;IAC5E,IAAI,CAAC;QACH,OAAQ,OAAO,CAAC,UAAU,CAAS,CAAC,WAAW,CAAC;IAClD,CAAC;IAAC,MAAM,CAAC;QACP,OAAO,IAAI,CAAC;IACd,CAAC;AACH,CAAC,CAAC,EAAE,CAAC;AAEL,SAAS,QAAQ,CAAC,MAAmB,EAAE,KAAa,EAAE,IAAY,EAAE,EAAU;IAC5E,IAAI,CAAC;QACH,IAAI,MAAM,CAAC,SAAS,IAAI,MAAM,CAAC,aAAa;YAAE,OAAO,KAAK,CAAC;QAC3D,OAAO,MAAM,CAAC,KAAK,CAAC,UAAU,KAAK,WAAW,IAAI,SAAS,EAAE,MAAM,CAAC,CAAC;IACvE,CAAC;IAAC,MAAM,CAAC;QACP,OAAO,KAAK,CAAC;IACf,CAAC;AACH,CAAC;AAED,SAAS,gBAAgB,CAAC,EAAU,EAAE,MAAmB;IACvD,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE;QAC7B,IAAI,MAAM,CAAC,OAAO;YAAE,OAAO,OAAO,EAAE,CAAC;QACrC,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE;YAC5B,MAAM,CAAC,mBAAmB,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;YAC7C,OAAO,EAAE,CAAC;QACZ,CAAC,EAAE,EAAE,CAAC,CAAC;QACP,SAAS,OAAO;YACd,YAAY,CAAC,KAAK,CAAC,CAAC;YACpB,OAAO,EAAE,CAAC;QACZ,CAAC;QACD,MAAM,CAAC,gBAAgB,CAAC,OAAO,EAAE,OAAO,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;IAC5D,CAAC,CAAC,CAAC;AACL,CAAC;AAED,SAAS,gBAAgB,CAAC,MAAc;IACtC,IAAI,CAAE,MAAM,CAAC,GAAW,CAAC,uBAAuB,EAAE,CAAC;QAChD,MAAM,CAAC,GAAW,CAAC,uBAAuB,GAAG,IAAI,GAAG,EAA6B,CAAC;IACrF,CAAC;IACD,OAAQ,MAAM,CAAC,GAAW,CAAC,uBAAuB,CAAC;AACrD,CAAC;AAED,SAAS,kBAAkB,CACzB,aAA6C,EAC7C,IAAY,EACZ,cAAmB,EACnB,MAAe;IAEf,MAAM,QAAQ,GAAG,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;IACzC,IAAI,QAAQ,EAAE,CAAC;QACb,QAAQ,CAAC,QAAQ,EAAE,CAAC;QACpB,OAAO,QAAQ,CAAC,WAAW,CAAC;IAC9B,CAAC;IAED,IAAI,CAAC,gBAAgB,EAAE,CAAC;QACtB,MAAM,IAAI,KAAK,CAAC,0CAA0C,CAAC,CAAC;IAC9D,CAAC;IAED,MAAM,WAAW,GAAG,IAAI,gBAAgB,CAAC,IAAI,EAAE;QAC7C,UAAU,EAAE,cAAc;QAC1B,MAAM;KACP,CAAC,CAAC;IAEH,aAAa,CAAC,GAAG,CAAC,IAAI,EAAE,EAAE,WAAW,EAAE,QAAQ,EAAE,CAAC,EAAE,CAAC,CAAC;IACtD,OAAO,WAAW,CAAC;AACrB,CAAC;AAED,SAAS,kBAAkB,CAAC,aAA6C,EAAE,IAAY;IACrF,MAAM,GAAG,GAAG,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;IACpC,IAAI,CAAC,GAAG;QAAE,OAAO;IACjB,GAAG,CAAC,QAAQ,EAAE,CAAC;IACf,IAAI,GAAG,CAAC,QAAQ,IAAI,CAAC,EAAE,CAAC;QACtB,GAAG,CAAC,WAAW,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC;QACxC,aAAa,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;IAC7B,CAAC;AACH,CAAC;AAED,SAAS,qBAAqB,CAAC,aAA6C;IAC1E,MAAM,MAAM,GAAoB,EAAE,CAAC;IACnC,KAAK,MAAM,GAAG,IAAI,aAAa,CAAC,MAAM,EAAE,EAAE,CAAC;QACzC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,WAAW,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC,CAAC;IACvD,CAAC;IACD,aAAa,CAAC,KAAK,EAAE,CAAC;IACtB,OAAO,OAAO,CAAC,UAAU,CAAC,MAAM,CAAC,CAAC,IAAI,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC;AACnD,CAAC;AAED,SAAgB,mBAAmB,CAAC,MAAc;IAChD,4CAA4C;IAC5C,MAAM,CAAC,GAAG,CAAC;QACT,IAAI,EAAE,YAAY;QAClB,MAAM,EAAE,KAAK,IAAI,EAAE;YACjB,MAAM,qBAAqB,CAAC,gBAAgB,CAAC,MAAM,CAAC,CAAC,CAAC;QACxD,CAAC;KACF,CAAC,CAAC;IAEH,OAAO,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;QACpD,MAAM,EAAE,IAAI,EAAE,GAAG,OAAO,CAAC,MAA0B,CAAC;QACpD,MAAM,QAAQ,GAAkB,OAAO,CAAC,OAAO,CAAC;QAEhD,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;YACxB,MAAM,cAAI,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC;QACzC,CAAC;QAED,MAAM,MAAM,GAAG,IAAI,oBAAW,EAAE,CAAC;QAEjC,MAAM,QAAQ,GAAG,CAAC;aACf,QAAQ,CAAC,MAAM,CAAC;aAChB,IAAI,CAAC,mBAAmB,CAAC;aACzB,MAAM,CAAC,eAAe,EAAE,UAAU,CAAC,CAAC;QAEvC,MAAM,CAAC,KAAK,CAAC,SAAS,CAAC,CAAC;QAExB,MAAM,OAAO,GAAG,QAAQ,CAAC,OAAO;YAC9B,CAAC,CAAC,gBAAgB,CAAC,OAAO,EAAE,MAAM,EAAE,QAAQ,EAAE,IAAI,CAAC;YACnD,CAAC,CAAC,aAAa,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,CAAC,MAAM,EAAE,QAAQ,EAAE,IAAI,CAAC,CAAC;QAEnE,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE;YACjB,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE,CAAC;gBAC1B,MAAM,CAAC,GAAG,EAAE,CAAC;YACf,CAAC;QACH,CAAC,CAAC,CAAC;QAEH,OAAO,QAAQ,CAAC;IAClB,CAAC,CAAC;AACJ,CAAC;AAED,KAAK,UAAU,aAAa,CAC1B,OAAgB,EAChB,MAAmB,EACnB,MAAc,EACd,QAAuB,EACvB,IAAY;IAEZ,MAAM,UAAU,GAAG,QAAQ,CAAC,aAAa,EAAE,CAAC;IAC5C,MAAM,MAAM,GAAG,QAAQ,CAAC,SAAS,EAAE,CAAC;IAEpC,IAAI,CAAC,UAAU,EAAE,CAAC;QAChB,QAAQ,CAAC,MAAM,EAAE,OAAO,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,OAAO,EAAE,0BAA0B,EAAE,CAAC,EAAE,GAAG,CAAC,CAAC;QACxF,MAAM,CAAC,GAAG,EAAE,CAAC;QACb,OAAO;IACT,CAAC;IAED,MAAM,aAAa,GAAG,gBAAgB,CAAC,MAAM,CAAC,CAAC;IAC/C,MAAM,WAAW,GAAG,kBAAkB,CAAC,aAAa,EAAE,IAAI,EAAE,UAAU,EAAE,MAAM,CAAC,CAAC;IAChF,IAAI,OAAO,GAAG,CAAC,CAAC;IAChB,IAAI,OAAO,GAAG,IAAI,CAAC;IACnB,MAAM,EAAE,GAAG,IAAI,eAAe,EAAE,CAAC;IAEjC,MAAM,UAAU,GAAG,CAAC,WAAW,EAAE,QAAQ,EAAE,UAAU,EAAE,SAAS,EAAE,QAAQ,EAAE,SAAS,CAAC,CAAC;IACvF,MAAM,SAAS,GAAgE,EAAE,CAAC;IAElF,KAAK,MAAM,SAAS,IAAI,UAAU,EAAE,CAAC;QACnC,MAAM,OAAO,GAAG,CAAC,IAAS,EAAE,EAAE;YAC5B,IAAI,CAAC,OAAO;gBAAE,OAAO;YACrB,QAAQ,CAAC,MAAM,EAAE,SAAS,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,GAAG,IAAI,EAAE,KAAK,EAAE,IAAI,EAAE,CAAC,EAAE,MAAM,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;QAC3F,CAAC,CAAC;QACF,WAAW,CAAC,EAAE,CAAC,SAAS,EAAE,OAAO,CAAC,CAAC;QACnC,SAAS,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,SAAS,EAAE,OAAO,EAAE,CAAC,CAAC;IAChD,CAAC;IAED,OAAO,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,GAAG,EAAE;QAC/B,OAAO,GAAG,KAAK,CAAC;QAChB,EAAE,CAAC,KAAK,EAAE,CAAC;IACb,CAAC,CAAC,CAAC;IAEH,IAAI,CAAC;QACH,OAAO,OAAO,EAAE,CAAC;YACf,IAAI,CAAC,QAAQ,CAAC,MAAM,EAAE,WAAW,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,IAAI,EAAE,IAAI,CAAC,GAAG,EAAE,EAAE,CAAC,EAAE,MAAM,CAAC,OAAO,EAAE,CAAC,CAAC,EAAE,CAAC;gBAC5F,MAAM;YACR,CAAC;YACD,MAAM,gBAAgB,CAAC,MAAM,EAAE,EAAE,CAAC,MAAM,CAAC,CAAC;QAC5C,CAAC;IACH,CAAC;YAAS,CAAC;QACT,KAAK,MAAM,EAAE,KAAK,EAAE,OAAO,EAAE,IAAI,SAAS,EAAE,CAAC;YAC3C,WAAW,CAAC,cAAc,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC;QAC7C,CAAC;QACD,kBAAkB,CAAC,aAAa,EAAE,IAAI,CAAC,CAAC;QACxC,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE,CAAC;YAC1B,MAAM,CAAC,GAAG,EAAE,CAAC;QACf,CAAC;IACH,CAAC;AACH,CAAC;AAED,KAAK,UAAU,gBAAgB,CAC7B,OAAgB,EAChB,MAAmB,EACnB,QAAuB,EACvB,IAAY;IAEZ,IAAI,OAAO,GAAG,CAAC,CAAC;IAChB,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;IACrC,IAAI,UAAU,GAAG,EAAE,OAAO,EAAE,CAAC,EAAE,MAAM,EAAE,CAAC,EAAE,SAAS,EAAE,CAAC,EAAE,MAAM,EAAE,CAAC,EAAE,OAAO,EAAE,CAAC,EAAE,CAAC;IAChF,IAAI,OAAO,GAAG,IAAI,CAAC;IACnB,MAAM,EAAE,GAAG,IAAI,eAAe,EAAE,CAAC;IAEjC,OAAO,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,GAAG,EAAE;QAC/B,OAAO,GAAG,KAAK,CAAC;QAChB,EAAE,CAAC,KAAK,EAAE,CAAC;IACb,CAAC,CAAC,CAAC;IAEH,OAAO,OAAO,EAAE,CAAC;QACf,IAAI,CAAC;YACH,MAAM,MAAM,GAAG,MAAM,KAAK,CAAC,YAAY,EAAE,CAAC;YAC1C,IAAI,CAAC,OAAO;gBAAE,MAAM;YAEpB,KAAK,MAAM,CAAC,KAAK,EAAE,KAAK,CAAC,IAAI,MAAM,CAAC,OAAO,CAAC,MAAM,CAAuB,EAAE,CAAC;gBAC1E,MAAM,IAAI,GAAI,UAAkB,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;gBAC7C,IAAI,KAAK,KAAK,IAAI,EAAE,CAAC;oBACnB,QAAQ,CAAC,MAAM,EAAE,QAAQ,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,KAAK,EAAE,IAAI,EAAE,KAAK,EAAE,KAAK,EAAE,IAAI,EAAE,CAAC,EAAE,MAAM,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;gBACrG,CAAC;YACH,CAAC;YACD,UAAU,GAAG,MAAM,CAAC;QACtB,CAAC;QAAC,MAAM,CAAC;YACP,MAAM;QACR,CAAC;QACD,MAAM,gBAAgB,CAAC,KAAK,EAAE,EAAE,CAAC,MAAM,CAAC,CAAC;IAC3C,CAAC;IAED,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE,CAAC;QAC1B,MAAM,CAAC,GAAG,EAAE,CAAC;IACf,CAAC;AACH,CAAC"}
+{"version":3,"file":"events.js","sourceRoot":"","sources":["../src/events.ts"],"names":[],"mappings":";;;;;AA6FA,kDAsCC;AAnID,mCAAqC;AAErC,sDAA8B;AAQ9B,MAAM,gBAAgB,GAAkD,CAAC,GAAG,EAAE;IAC5E,IAAI,CAAC;QACH,OAAQ,OAAO,CAAC,UAAU,CAAS,CAAC,WAAW,CAAC;IAClD,CAAC;IAAC,MAAM,CAAC;QACP,OAAO,IAAI,CAAC;IACd,CAAC;AACH,CAAC,CAAC,EAAE,CAAC;AAEL,SAAS,QAAQ,CAAC,MAAmB,EAAE,KAAa,EAAE,IAAY,EAAE,EAAU;IAC5E,IAAI,CAAC;QACH,IAAI,MAAM,CAAC,SAAS,IAAI,MAAM,CAAC,aAAa;YAAE,OAAO,KAAK,CAAC;QAC3D,OAAO,MAAM,CAAC,KAAK,CAAC,UAAU,KAAK,WAAW,IAAI,SAAS,EAAE,MAAM,CAAC,CAAC;IACvE,CAAC;IAAC,MAAM,CAAC;QACP,OAAO,KAAK,CAAC;IACf,CAAC;AACH,CAAC;AAED,SAAS,gBAAgB,CAAC,EAAU,EAAE,MAAmB;IACvD,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE;QAC7B,IAAI,MAAM,CAAC,OAAO;YAAE,OAAO,OAAO,EAAE,CAAC;QACrC,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE;YAC5B,MAAM,CAAC,mBAAmB,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;YAC7C,OAAO,EAAE,CAAC;QACZ,CAAC,EAAE,EAAE,CAAC,CAAC;QACP,SAAS,OAAO;YACd,YAAY,CAAC,KAAK,CAAC,CAAC;YACpB,OAAO,EAAE,CAAC;QACZ,CAAC;QACD,MAAM,CAAC,gBAAgB,CAAC,OAAO,EAAE,OAAO,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;IAC5D,CAAC,CAAC,CAAC;AACL,CAAC;AAED,SAAS,gBAAgB,CAAC,MAAc;IACtC,IAAI,CAAE,MAAM,CAAC,GAAW,CAAC,uBAAuB,EAAE,CAAC;QAChD,MAAM,CAAC,GAAW,CAAC,uBAAuB,GAAG,IAAI,GAAG,EAA6B,CAAC;IACrF,CAAC;IACD,OAAQ,MAAM,CAAC,GAAW,CAAC,uBAAuB,CAAC;AACrD,CAAC;AAED,SAAS,kBAAkB,CACzB,aAA6C,EAC7C,IAAY,EACZ,cAAmB,EACnB,MAAe;IAEf,MAAM,QAAQ,GAAG,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;IACzC,IAAI,QAAQ,EAAE,CAAC;QACb,QAAQ,CAAC,QAAQ,EAAE,CAAC;QACpB,OAAO,QAAQ,CAAC,WAAW,CAAC;IAC9B,CAAC;IAED,IAAI,CAAC,gBAAgB,EAAE,CAAC;QACtB,MAAM,IAAI,KAAK,CAAC,0CAA0C,CAAC,CAAC;IAC9D,CAAC;IAED,MAAM,WAAW,GAAG,IAAI,gBAAgB,CAAC,IAAI,EAAE;QAC7C,UAAU,EAAE,cAAc;QAC1B,MAAM;KACP,CAAC,CAAC;IAEH,aAAa,CAAC,GAAG,CAAC,IAAI,EAAE,EAAE,WAAW,EAAE,QAAQ,EAAE,CAAC,EAAE,CAAC,CAAC;IACtD,OAAO,WAAW,CAAC;AACrB,CAAC;AAED,SAAS,kBAAkB,CAAC,aAA6C,EAAE,IAAY;IACrF,MAAM,GAAG,GAAG,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;IACpC,IAAI,CAAC,GAAG;QAAE,OAAO;IACjB,GAAG,CAAC,QAAQ,EAAE,CAAC;IACf,IAAI,GAAG,CAAC,QAAQ,IAAI,CAAC,EAAE,CAAC;QACtB,GAAG,CAAC,WAAW,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC;QACxC,aAAa,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;IAC7B,CAAC;AACH,CAAC;AAED,SAAS,qBAAqB,CAAC,aAA6C;IAC1E,MAAM,MAAM,GAAoB,EAAE,CAAC;IACnC,KAAK,MAAM,GAAG,IAAI,aAAa,CAAC,MAAM,EAAE,EAAE,CAAC;QACzC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,WAAW,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC,CAAC;IACvD,CAAC;IACD,aAAa,CAAC,KAAK,EAAE,CAAC;IACtB,OAAO,OAAO,CAAC,UAAU,CAAC,MAAM,CAAC,CAAC,IAAI,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC;AACnD,CAAC;AAED,SAAgB,mBAAmB,CAAC,MAAc;IAChD,4CAA4C;IAC5C,MAAM,CAAC,GAAG,CAAC;QACT,IAAI,EAAE,YAAY;QAClB,MAAM,EAAE,KAAK,IAAI,EAAE;YACjB,MAAM,qBAAqB,CAAC,gBAAgB,CAAC,MAAM,CAAC,CAAC,CAAC;QACxD,CAAC;KACF,CAAC,CAAC;IAEH,OAAO,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;QACpD,MAAM,EAAE,IAAI,EAAE,GAAG,OAAO,CAAC,MAA0B,CAAC;QACpD,MAAM,QAAQ,GAAkB,OAAO,CAAC,OAAO,CAAC;QAEhD,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;YACxB,MAAM,cAAI,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC;QACzC,CAAC;QAED,MAAM,MAAM,GAAG,IAAI,oBAAW,EAAE,CAAC;QAEjC,MAAM,QAAQ,GAAG,CAAC;aACf,QAAQ,CAAC,MAAM,CAAC;aAChB,IAAI,CAAC,mBAAmB,CAAC;aACzB,MAAM,CAAC,eAAe,EAAE,UAAU,CAAC,CAAC;QAEvC,MAAM,CAAC,KAAK,CAAC,SAAS,CAAC,CAAC;QAExB,MAAM,OAAO,GAAG,QAAQ,CAAC,OAAO;YAC9B,CAAC,CAAC,gBAAgB,CAAC,OAAO,EAAE,MAAM,EAAE,QAAQ,EAAE,IAAI,CAAC;YACnD,CAAC,CAAC,aAAa,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,CAAC,MAAM,EAAE,QAAQ,EAAE,IAAI,CAAC,CAAC;QAEnE,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE;YACjB,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE,CAAC;gBAC1B,MAAM,CAAC,GAAG,EAAE,CAAC;YACf,CAAC;QACH,CAAC,CAAC,CAAC;QAEH,OAAO,QAAQ,CAAC;IAClB,CAAC,CAAC;AACJ,CAAC;AAED,KAAK,UAAU,aAAa,CAC1B,OAAgB,EAChB,MAAmB,EACnB,MAAc,EACd,QAAuB,EACvB,IAAY;IAEZ,MAAM,UAAU,GAAG,QAAQ,CAAC,aAAa,EAAE,CAAC;IAC5C,MAAM,MAAM,GAAG,QAAQ,CAAC,SAAS,EAAE,CAAC;IAEpC,IAAI,CAAC,UAAU,EAAE,CAAC;QAChB,QAAQ,CAAC,MAAM,EAAE,OAAO,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,OAAO,EAAE,0BAA0B,EAAE,CAAC,EAAE,GAAG,CAAC,CAAC;QACxF,MAAM,CAAC,GAAG,EAAE,CAAC;QACb,OAAO;IACT,CAAC;IAED,MAAM,aAAa,GAAG,gBAAgB,CAAC,MAAM,CAAC,CAAC;IAC/C,MAAM,WAAW,GAAG,kBAAkB,CAAC,aAAa,EAAE,IAAI,EAAE,UAAU,EAAE,MAAM,CAAC,CAAC;IAChF,IAAI,OAAO,GAAG,CAAC,CAAC;IAChB,IAAI,OAAO,GAAG,IAAI,CAAC;IACnB,MAAM,EAAE,GAAG,IAAI,eAAe,EAAE,CAAC;IAEjC,MAAM,UAAU,GAAG,CAAC,WAAW,EAAE,QAAQ,EAAE,UAAU,EAAE,SAAS,EAAE,QAAQ,EAAE,SAAS,EAAE,OAAO,EAAE,WAAW,EAAE,iBAAiB,CAAC,CAAC;IAChI,MAAM,SAAS,GAAgE,EAAE,CAAC;IAElF,KAAK,MAAM,SAAS,IAAI,UAAU,EAAE,CAAC;QACnC,MAAM,OAAO,GAAG,CAAC,IAAS,EAAE,EAAE;YAC5B,IAAI,CAAC,OAAO;gBAAE,OAAO;YACrB,QAAQ,CAAC,MAAM,EAAE,SAAS,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,GAAG,IAAI,EAAE,KAAK,EAAE,IAAI,EAAE,CAAC,EAAE,MAAM,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;QAC3F,CAAC,CAAC;QACF,WAAW,CAAC,EAAE,CAAC,SAAS,EAAE,OAAO,CAAC,CAAC;QACnC,SAAS,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,SAAS,EAAE,OAAO,EAAE,CAAC,CAAC;IAChD,CAAC;IAED,OAAO,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,GAAG,EAAE;QAC/B,OAAO,GAAG,KAAK,CAAC;QAChB,EAAE,CAAC,KAAK,EAAE,CAAC;IACb,CAAC,CAAC,CAAC;IAEH,IAAI,CAAC;QACH,OAAO,OAAO,EAAE,CAAC;YACf,IAAI,CAAC,QAAQ,CAAC,MAAM,EAAE,WAAW,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,IAAI,EAAE,IAAI,CAAC,GAAG,EAAE,EAAE,CAAC,EAAE,MAAM,CAAC,OAAO,EAAE,CAAC,CAAC,EAAE,CAAC;gBAC5F,MAAM;YACR,CAAC;YACD,MAAM,gBAAgB,CAAC,MAAM,EAAE,EAAE,CAAC,MAAM,CAAC,CAAC;QAC5C,CAAC;IACH,CAAC;YAAS,CAAC;QACT,KAAK,MAAM,EAAE,KAAK,EAAE,OAAO,EAAE,IAAI,SAAS,EAAE,CAAC;YAC3C,WAAW,CAAC,cAAc,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC;QAC7C,CAAC;QACD,kBAAkB,CAAC,aAAa,EAAE,IAAI,CAAC,CAAC;QACxC,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE,CAAC;YAC1B,MAAM,CAAC,GAAG,EAAE,CAAC;QACf,CAAC;IACH,CAAC;AACH,CAAC;AAED,KAAK,UAAU,gBAAgB,CAC7B,OAAgB,EAChB,MAAmB,EACnB,QAAuB,EACvB,IAAY;IAEZ,IAAI,OAAO,GAAG,CAAC,CAAC;IAChB,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;IACrC,IAAI,UAAU,GAAG,EAAE,OAAO,EAAE,CAAC,EAAE,MAAM,EAAE,CAAC,EAAE,SAAS,EAAE,CAAC,EAAE,MAAM,EAAE,CAAC,EAAE,OAAO,EAAE,CAAC,EAAE,CAAC;IAChF,IAAI,OAAO,GAAG,IAAI,CAAC;IACnB,MAAM,EAAE,GAAG,IAAI,eAAe,EAAE,CAAC;IAEjC,OAAO,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,GAAG,EAAE;QAC/B,OAAO,GAAG,KAAK,CAAC;QAChB,EAAE,CAAC,KAAK,EAAE,CAAC;IACb,CAAC,CAAC,CAAC;IAEH,OAAO,OAAO,EAAE,CAAC;QACf,IAAI,CAAC;YACH,MAAM,MAAM,GAAG,MAAM,KAAK,CAAC,YAAY,EAAE,CAAC;YAC1C,IAAI,CAAC,OAAO;gBAAE,MAAM;YAEpB,KAAK,MAAM,CAAC,KAAK,EAAE,KAAK,CAAC,IAAI,MAAM,CAAC,OAAO,CAAC,MAAM,CAAuB,EAAE,CAAC;gBAC1E,MAAM,IAAI,GAAI,UAAkB,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;gBAC7C,IAAI,KAAK,KAAK,IAAI,EAAE,CAAC;oBACnB,QAAQ,CAAC,MAAM,EAAE,QAAQ,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,KAAK,EAAE,IAAI,EAAE,KAAK,EAAE,KAAK,EAAE,IAAI,EAAE,CAAC,EAAE,MAAM,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;gBACrG,CAAC;YACH,CAAC;YACD,UAAU,GAAG,MAAM,CAAC;QACtB,CAAC;QAAC,MAAM,CAAC;YACP,MAAM;QACR,CAAC;QACD,MAAM,gBAAgB,CAAC,KAAK,EAAE,EAAE,CAAC,MAAM,CAAC,CAAC;IAC3C,CAAC;IAED,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE,CAAC;QAC1B,MAAM,CAAC,GAAG,EAAE,CAAC;IACf,CAAC;AACH,CAAC"}

dist/routes.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"routes.d.ts","sourceRoot":"","sources":["../src/routes.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,MAAM,EAA4B,MAAM,YAAY,CAAC;AAGnE,OAAO,KAAK,EAAE,oBAAoB,EAAE,aAAa,EAAE,MAAM,SAAS,CAAC;AAsBnE,wBAAgB,cAAc,CAAC,MAAM,EAAE,MAAM,EAAE,SAAS,EAAE,aAAa,EAAE,IAAI,EAAE,oBAAoB,GAAG,IAAI,CAkezG"}
+{"version":3,"file":"routes.d.ts","sourceRoot":"","sources":["../src/routes.ts"],"names":[],"mappings":"AACA,OAAO,KAAK,EAAE,MAAM,EAA4B,MAAM,YAAY,CAAC;AAGnE,OAAO,KAAK,EAAE,oBAAoB,EAAE,aAAa,EAAE,MAAM,SAAS,CAAC;AAwBnE,wBAAgB,cAAc,CAAC,MAAM,EAAE,MAAM,EAAE,SAAS,EAAE,aAAa,EAAE,IAAI,EAAE,oBAAoB,GAAG,IAAI,CAklBzG"}

dist/routes.js

@@ -7,2 +7,3 @@ "use strict";
 exports.registerRoutes = registerRoutes;
+const stream_1 = require("stream");
 const boom_1 = __importDefault(require("@hapi/boom"));
@@ -428,2 +429,105 @@ const joi_1 = __importDefault(require("joi"));
     });
+    // --- AI-native endpoints ---
+    // GET /{name}/flows/{id}/usage - Get aggregated token/cost usage for a flow
+    server.route({
+        method: 'GET',
+        path: '/{name}/flows/{id}/usage',
+        options: {
+            validate: {
+                params: schemas_1.flowIdParamSchema,
+                failAction,
+            },
+        },
+        handler: async (request, h) => {
+            const { name, registry } = requireQueue(request);
+            const { queue } = registry.get(name);
+            const { id } = request.params;
+            const usage = await queue.getFlowUsage(id);
+            if (!usage)
+                throw boom_1.default.notFound('Flow not found');
+            return h.response(usage);
+        },
+    });
+    // GET /{name}/flows/{id}/budget - Get budget status for a flow
+    server.route({
+        method: 'GET',
+        path: '/{name}/flows/{id}/budget',
+        options: {
+            validate: {
+                params: schemas_1.flowIdParamSchema,
+                failAction,
+            },
+        },
+        handler: async (request, h) => {
+            const { name, registry } = requireQueue(request);
+            const { queue } = registry.get(name);
+            const { id } = request.params;
+            const budget = await queue.getFlowBudget(id);
+            if (!budget)
+                throw boom_1.default.notFound('Flow not found');
+            return h.response(budget);
+        },
+    });
+    // GET /{name}/jobs/{id}/stream - SSE stream for a single job's output chunks
+    server.route({
+        method: 'GET',
+        path: '/{name}/jobs/{id}/stream',
+        options: {
+            validate: {
+                params: schemas_1.jobStreamParamSchema,
+                failAction,
+            },
+            timeout: { server: false, socket: false },
+        },
+        handler: async (request, h) => {
+            const { name, registry } = requireQueue(request);
+            const { queue } = registry.get(name);
+            const { id } = request.params;
+            const stream = new stream_1.PassThrough();
+            const response = h
+                .response(stream)
+                .type('text/event-stream')
+                .header('Cache-Control', 'no-cache');
+            stream.write(':ok\n\n');
+            let lastId = request.headers['last-event-id']
+                || request.query.lastId
+                || undefined;
+            let running = true;
+            request.raw.req.on('close', () => {
+                running = false;
+            });
+            (async () => {
+                try {
+                    while (running) {
+                        const entries = await queue.readStream(id, { lastId, count: 100 });
+                        for (const entry of entries) {
+                            stream.write(`id: ${entry.id}\ndata: ${JSON.stringify(entry.fields)}\n\n`);
+                            lastId = entry.id;
+                        }
+                        const job = await queue.getJob(id);
+                        if (!job)
+                            break;
+                        const state = await job.getState();
+                        if (state === 'completed' || state === 'failed') {
+                            const trailing = await queue.readStream(id, { lastId, count: 100 });
+                            for (const entry of trailing) {
+                                stream.write(`id: ${entry.id}\ndata: ${JSON.stringify(entry.fields)}\n\n`);
+                            }
+                            break;
+                        }
+                        await new Promise((r) => setTimeout(r, 500));
+                    }
+                }
+                catch {
+                    // Connection lost or queue error - end gracefully
+                }
+                finally {
+                    if (!stream.writableEnded) {
+                        stream.end();
+                    }
+                }
+            })();
+            return response;
+        },
+    });
     // GET /{name}/events - SSE stream
@@ -430,0 +534,0 @@ const eventsHandler = (0, events_1.createEventsHandler)(server);

dist/routes.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"routes.js","sourceRoot":"","sources":["../src/routes.ts"],"names":[],"mappings":";;;;;AAyBA,wCAkeC;AA1fD,sDAA8B;AAC9B,8CAAsB;AAEtB,+CAA4D;AAC5D,uCAamB;AACnB,qCAA+C;AAE/C,MAAM,UAAU,GAAG,CAAC,QAAiB,EAAE,EAAmB,EAAE,GAAW,EAAE,EAAE;IACzE,MAAM,GAAG,CAAC;AACZ,CAAC,CAAC;AAEF,SAAgB,cAAc,CAAC,MAAc,EAAE,SAAwB,EAAE,IAA0B;IACjG,MAAM,aAAa,GAAG,IAAI,EAAE,MAAM,CAAC;IACnC,MAAM,gBAAgB,GAAG,IAAI,EAAE,SAAS,CAAC;IACzC,SAAS,YAAY,CAAC,OAAgB;QACpC,MAAM,EAAE,IAAI,EAAE,GAAG,OAAO,CAAC,MAA0B,CAAC;QACpD,MAAM,QAAQ,GAAG,OAAO,CAAC,OAAO,CAAC;QACjC,IAAI,aAAa,IAAI,CAAC,aAAa,CAAC,QAAQ,CAAC,IAAI,CAAC;YAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC;QAC3F,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC;YAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC;QAChE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC;IAC5B,CAAC;IAED,SAAS,eAAe,CAAC,OAAgB;QACvC,MAAM,EAAE,IAAI,EAAE,GAAG,OAAO,CAAC,MAA0B,CAAC;QACpD,MAAM,QAAQ,GAAG,OAAO,CAAC,OAAO,CAAC;QACjC,IAAI,gBAAgB,IAAI,CAAC,gBAAgB,CAAC,QAAQ,CAAC,IAAI,CAAC;YAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,oBAAoB,CAAC,CAAC;QACpG,IAAI,CAAC,QAAQ,CAAC,WAAW,CAAC,IAAI,CAAC;YAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,oBAAoB,CAAC,CAAC;QAC3E,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC;IAC5B,CAAC;IAED,gCAAgC;IAChC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,cAAc;QACpB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,sBAAY;gBACrB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,OAAO,CAAC,OAItD,CAAC;YAEF,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,IAAI,EAAE,OAAc,CAAC,CAAC;YAC3D,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,kBAAkB,CAAC,CAAC;YAClD,OAAO,CAAC,CAAC,QAAQ,CAAC,IAAA,0BAAY,EAAC,GAAG,CAAC,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QACjD,CAAC;KACF,CAAC,CAAC;IAEH,yDAAyD;IACzD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,mBAAmB;QACzB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,8BAAgB;gBACzB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,WAAW,EAAE,GAAG,OAAO,CAAC,OAKnE,CAAC;YAEF,MAAM,WAAW,GAAG,MAAO,KAAa,CAAC,UAAU,CAAC,OAAO,EAAE,IAAI,EAAE,OAAc,EAAE,WAAW,CAAC,CAAC;YAChG,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,WAAW,EAAE,CAAC,CAAC;QACrC,CAAC;KACF,CAAC,CAAC;IAEH,+BAA+B;IAC/B,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,cAAc;QACpB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,KAAK,EAAE,4BAAkB;gBACzB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,WAAW,EAAE,GAAG,OAAO,CAAC,KAKjD,CAAC;YAEF,MAAM,IAAI,GAAG,WAAW;gBACtB,CAAC,CAAC,MAAO,KAAa,CAAC,OAAO,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,EAAE,WAAW,EAAE,IAAI,EAAE,CAAC;gBACvE,CAAC,CAAC,MAAM,KAAK,CAAC,OAAO,CAAC,IAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;YACjD,OAAO,CAAC,CAAC,QAAQ,CAAC,IAAA,2BAAa,EAAC,IAAI,CAAC,CAAC,CAAC;QACzC,CAAC;KACF,CAAC,CAAC;IAEH,2CAA2C;IAC3C,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,mBAAmB;QACzB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,0BAAgB;gBACxB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACnC,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,eAAe,CAAC,CAAC;YAC/C,OAAO,CAAC,CAAC,QAAQ,CAAC,IAAA,0BAAY,EAAC,GAAG,CAAC,CAAC,CAAC;QACvC,CAAC;KACF,CAAC,CAAC;IAEH,wDAAwD;IACxD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,4BAA4B;QAClC,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,0BAAgB;gBACxB,OAAO,EAAE,kCAAoB;gBAC7B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACnC,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,eAAe,CAAC,CAAC;YAE/C,MAAM,EAAE,QAAQ,EAAE,GAAG,OAAO,CAAC,OAA+B,CAAC;YAC7D,MAAO,GAAW,CAAC,cAAc,CAAC,QAAQ,CAAC,CAAC;YAC5C,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;QAClC,CAAC;KACF,CAAC,CAAC;IAEH,kDAAkD;IAClD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,yBAAyB;QAC/B,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,0BAAgB;gBACxB,OAAO,EAAE,+BAAiB;gBAC1B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACnC,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,eAAe,CAAC,CAAC;YAE/C,MAAM,EAAE,KAAK,EAAE,GAAG,OAAO,CAAC,OAA4B,CAAC;YACvD,MAAO,GAAW,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;YACtC,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;QAClC,CAAC;KACF,CAAC,CAAC;IAEH,yDAAyD;IACzD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,2BAA2B;QACjC,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,0BAAgB;gBACxB,UAAU;aACX;YACD,OAAO,EAAE,EAAE,UAAU,EAAE,QAAiB,EAAE;SAC3C;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACnC,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,eAAe,CAAC,CAAC;YAE/C,MAAO,GAAW,CAAC,OAAO,EAAE,CAAC;YAC7B,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;QAClC,CAAC;KACF,CAAC,CAAC;IAEH,sCAAsC;IACtC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,gBAAgB;QACtB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,MAAM,GAAG,MAAM,KAAK,CAAC,YAAY,EAAE,CAAC;YAC1C,OAAO,CAAC,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC5B,CAAC;KACF,CAAC,CAAC;IAEH,0CAA0C;IAC1C,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,iBAAiB;QACvB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,KAAK,EAAE,4BAAkB;gBACzB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,GAAG,OAAO,CAAC,KAAgE,CAAC;YAEtG,MAAM,OAAO,GAAG,MAAO,KAAa,CAAC,UAAU,CAAC,IAAI,EAAE,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAC;YACtE,OAAO,CAAC,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC;QAC7B,CAAC;KACF,CAAC,CAAC;IAEH,mCAAmC;IACnC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,eAAe;QACrB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;YACD,OAAO,EAAE,EAAE,UAAU,EAAE,QAAiB,EAAE;SAC3C;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,KAAK,CAAC,KAAK,EAAE,CAAC;YACpB,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,qCAAqC;IACrC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,gBAAgB;QACtB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;YACD,OAAO,EAAE,EAAE,UAAU,EAAE,QAAiB,EAAE;SAC3C;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,KAAK,CAAC,MAAM,EAAE,CAAC;YACrB,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,mCAAmC;IACnC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,eAAe;QACrB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;YACD,OAAO,EAAE,EAAE,UAAU,EAAE,QAAiB,EAAE;SAC3C;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,KAAK,CAAC,KAAK,EAAE,CAAC;YACpB,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,yCAAyC;IACzC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,eAAe;QACrB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAAC,yBAAe,EAAE,aAAG,CAAC,GAAG,EAAE,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;gBACvE,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,KAAK,EAAE,GAAG,CAAC,OAAO,CAAC,OAAO,IAAI,EAAE,CAAuB,CAAC;YAEhE,MAAM,OAAO,GAAG,MAAM,KAAK,CAAC,SAAS,CAAC,KAAK,IAAI,IAAI,CAAC,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC;YAC7E,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,OAAO,EAAE,CAAC,CAAC;QACjC,CAAC;KACF,CAAC,CAAC;IAEH,wCAAwC;IACxC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,QAAQ;QAChB,IAAI,EAAE,eAAe;QACrB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,KAAK,EAAE,0BAAgB;gBACvB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,IAAI,EAAE,GAAG,OAAO,CAAC,KAAkE,CAAC;YAE1G,MAAM,OAAO,GAAG,MAAM,KAAK,CAAC,KAAK,CAAC,KAAK,EAAE,KAAK,EAAE,IAAW,CAAC,CAAC;YAC7D,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,OAAO,EAAE,OAAO,CAAC,MAAM,EAAE,CAAC,CAAC;QACjD,CAAC;KACF,CAAC,CAAC;IAEH,qCAAqC;IACrC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,iBAAiB;QACvB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,OAAO,GAAG,MAAM,KAAK,CAAC,UAAU,EAAE,CAAC;YACzC,OAAO,CAAC,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC;QAC7B,CAAC;KACF,CAAC,CAAC;IAEH,0EAA0E;IAC1E,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,iBAAiB;QACvB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,sBAAY;gBACrB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,eAAe,CAAC,OAAO,CAAC,CAAC;YACpD,MAAM,QAAQ,GAAG,QAAQ,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;YAC5C,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,OAAO,CAAC,OAItD,CAAC;YAEF,MAAM,EAAE,GAAG,MAAM,QAAQ,CAAC,GAAG,CAAC,OAAO,EAAE,IAAI,EAAE,OAAc,CAAC,CAAC;YAC7D,IAAI,CAAC,EAAE;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,kBAAkB,CAAC,CAAC;YACjD,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QACtC,CAAC;KACF,CAAC,CAAC;IAEH,8BAA8B;IAE9B,+CAA+C;IAC/C,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,oBAAoB;QAC1B,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,UAAU,GAAG,MAAO,KAAa,CAAC,iBAAiB,EAAE,CAAC;YAC5D,OAAO,CAAC,CAAC,QAAQ,CAAC,UAAU,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,6DAA6D;IAC7D,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,oCAAoC;QAC1C,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,aAAa,EAAE,GAAG,OAAO,CAAC,MAAiD,CAAC;YAEpF,MAAM,SAAS,GAAG,MAAO,KAAa,CAAC,eAAe,CAAC,aAAa,CAAC,CAAC;YACtE,IAAI,CAAC,SAAS;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,qBAAqB,CAAC,CAAC;YAC3D,OAAO,CAAC,CAAC,QAAQ,CAAC,SAAS,CAAC,CAAC;QAC/B,CAAC;KACF,CAAC,CAAC;IAEH,8DAA8D;IAC9D,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,oCAAoC;QAC1C,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,mCAAqB;gBAC9B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,aAAa,EAAE,GAAG,OAAO,CAAC,MAAiD,CAAC;YACpF,MAAM,EAAE,QAAQ,EAAE,QAAQ,EAAE,GAAG,OAAO,CAAC,OAGtC,CAAC;YAEF,MAAM,GAAG,GAAG,MAAO,KAAa,CAAC,kBAAkB,CAAC,aAAa,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAC;YACvF,OAAO,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,CAAC,CAAC,IAAA,0BAAY,EAAC,GAAG,CAAC,CAAC,CAAC,CAAC,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;QAC5D,CAAC;KACF,CAAC,CAAC;IAEH,iEAAiE;IACjE,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,QAAQ;QAChB,IAAI,EAAE,oCAAoC;QAC1C,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,aAAa,EAAE,GAAG,OAAO,CAAC,MAAiD,CAAC;YAEpF,MAAO,KAAa,CAAC,kBAAkB,CAAC,aAAa,CAAC,CAAC;YACvD,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,kCAAkC;IAClC,MAAM,aAAa,GAAG,IAAA,4BAAmB,EAAC,MAAM,CAAC,CAAC;IAClD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,gBAAgB;QACtB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;YACD,OAAO,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,MAAM,EAAE,KAAK,EAAE;SAC1C;QACD,OAAO,EAAE,aAAa;KACvB,CAAC,CAAC;AACL,CAAC"}
+{"version":3,"file":"routes.js","sourceRoot":"","sources":["../src/routes.ts"],"names":[],"mappings":";;;;;AA4BA,wCAklBC;AA9mBD,mCAAqC;AAErC,sDAA8B;AAC9B,8CAAsB;AAEtB,+CAA4D;AAC5D,uCAemB;AACnB,qCAA+C;AAE/C,MAAM,UAAU,GAAG,CAAC,QAAiB,EAAE,EAAmB,EAAE,GAAW,EAAE,EAAE;IACzE,MAAM,GAAG,CAAC;AACZ,CAAC,CAAC;AAEF,SAAgB,cAAc,CAAC,MAAc,EAAE,SAAwB,EAAE,IAA0B;IACjG,MAAM,aAAa,GAAG,IAAI,EAAE,MAAM,CAAC;IACnC,MAAM,gBAAgB,GAAG,IAAI,EAAE,SAAS,CAAC;IACzC,SAAS,YAAY,CAAC,OAAgB;QACpC,MAAM,EAAE,IAAI,EAAE,GAAG,OAAO,CAAC,MAA0B,CAAC;QACpD,MAAM,QAAQ,GAAG,OAAO,CAAC,OAAO,CAAC;QACjC,IAAI,aAAa,IAAI,CAAC,aAAa,CAAC,QAAQ,CAAC,IAAI,CAAC;YAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC;QAC3F,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC;YAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC;QAChE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC;IAC5B,CAAC;IAED,SAAS,eAAe,CAAC,OAAgB;QACvC,MAAM,EAAE,IAAI,EAAE,GAAG,OAAO,CAAC,MAA0B,CAAC;QACpD,MAAM,QAAQ,GAAG,OAAO,CAAC,OAAO,CAAC;QACjC,IAAI,gBAAgB,IAAI,CAAC,gBAAgB,CAAC,QAAQ,CAAC,IAAI,CAAC;YAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,oBAAoB,CAAC,CAAC;QACpG,IAAI,CAAC,QAAQ,CAAC,WAAW,CAAC,IAAI,CAAC;YAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,oBAAoB,CAAC,CAAC;QAC3E,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC;IAC5B,CAAC;IAED,gCAAgC;IAChC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,cAAc;QACpB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,sBAAY;gBACrB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,OAAO,CAAC,OAItD,CAAC;YAEF,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,IAAI,EAAE,OAAc,CAAC,CAAC;YAC3D,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,kBAAkB,CAAC,CAAC;YAClD,OAAO,CAAC,CAAC,QAAQ,CAAC,IAAA,0BAAY,EAAC,GAAG,CAAC,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QACjD,CAAC;KACF,CAAC,CAAC;IAEH,yDAAyD;IACzD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,mBAAmB;QACzB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,8BAAgB;gBACzB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,WAAW,EAAE,GAAG,OAAO,CAAC,OAKnE,CAAC;YAEF,MAAM,WAAW,GAAG,MAAO,KAAa,CAAC,UAAU,CAAC,OAAO,EAAE,IAAI,EAAE,OAAc,EAAE,WAAW,CAAC,CAAC;YAChG,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,WAAW,EAAE,CAAC,CAAC;QACrC,CAAC;KACF,CAAC,CAAC;IAEH,+BAA+B;IAC/B,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,cAAc;QACpB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,KAAK,EAAE,4BAAkB;gBACzB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,WAAW,EAAE,GAAG,OAAO,CAAC,KAKjD,CAAC;YAEF,MAAM,IAAI,GAAG,WAAW;gBACtB,CAAC,CAAC,MAAO,KAAa,CAAC,OAAO,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,EAAE,WAAW,EAAE,IAAI,EAAE,CAAC;gBACvE,CAAC,CAAC,MAAM,KAAK,CAAC,OAAO,CAAC,IAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;YACjD,OAAO,CAAC,CAAC,QAAQ,CAAC,IAAA,2BAAa,EAAC,IAAI,CAAC,CAAC,CAAC;QACzC,CAAC;KACF,CAAC,CAAC;IAEH,2CAA2C;IAC3C,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,mBAAmB;QACzB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,0BAAgB;gBACxB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACnC,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,eAAe,CAAC,CAAC;YAC/C,OAAO,CAAC,CAAC,QAAQ,CAAC,IAAA,0BAAY,EAAC,GAAG,CAAC,CAAC,CAAC;QACvC,CAAC;KACF,CAAC,CAAC;IAEH,wDAAwD;IACxD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,4BAA4B;QAClC,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,0BAAgB;gBACxB,OAAO,EAAE,kCAAoB;gBAC7B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACnC,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,eAAe,CAAC,CAAC;YAE/C,MAAM,EAAE,QAAQ,EAAE,GAAG,OAAO,CAAC,OAA+B,CAAC;YAC7D,MAAO,GAAW,CAAC,cAAc,CAAC,QAAQ,CAAC,CAAC;YAC5C,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;QAClC,CAAC;KACF,CAAC,CAAC;IAEH,kDAAkD;IAClD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,yBAAyB;QAC/B,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,0BAAgB;gBACxB,OAAO,EAAE,+BAAiB;gBAC1B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACnC,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,eAAe,CAAC,CAAC;YAE/C,MAAM,EAAE,KAAK,EAAE,GAAG,OAAO,CAAC,OAA4B,CAAC;YACvD,MAAO,GAAW,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;YACtC,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;QAClC,CAAC;KACF,CAAC,CAAC;IAEH,yDAAyD;IACzD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,2BAA2B;QACjC,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,0BAAgB;gBACxB,UAAU;aACX;YACD,OAAO,EAAE,EAAE,UAAU,EAAE,QAAiB,EAAE;SAC3C;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACnC,IAAI,CAAC,GAAG;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,eAAe,CAAC,CAAC;YAE/C,MAAO,GAAW,CAAC,OAAO,EAAE,CAAC;YAC7B,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;QAClC,CAAC;KACF,CAAC,CAAC;IAEH,sCAAsC;IACtC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,gBAAgB;QACtB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,MAAM,GAAG,MAAM,KAAK,CAAC,YAAY,EAAE,CAAC;YAC1C,OAAO,CAAC,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC5B,CAAC;KACF,CAAC,CAAC;IAEH,0CAA0C;IAC1C,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,iBAAiB;QACvB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,KAAK,EAAE,4BAAkB;gBACzB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,GAAG,OAAO,CAAC,KAAgE,CAAC;YAEtG,MAAM,OAAO,GAAG,MAAO,KAAa,CAAC,UAAU,CAAC,IAAI,EAAE,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAC;YACtE,OAAO,CAAC,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC;QAC7B,CAAC;KACF,CAAC,CAAC;IAEH,mCAAmC;IACnC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,eAAe;QACrB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;YACD,OAAO,EAAE,EAAE,UAAU,EAAE,QAAiB,EAAE;SAC3C;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,KAAK,CAAC,KAAK,EAAE,CAAC;YACpB,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,qCAAqC;IACrC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,gBAAgB;QACtB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;YACD,OAAO,EAAE,EAAE,UAAU,EAAE,QAAiB,EAAE;SAC3C;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,KAAK,CAAC,MAAM,EAAE,CAAC;YACrB,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,mCAAmC;IACnC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,eAAe;QACrB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;YACD,OAAO,EAAE,EAAE,UAAU,EAAE,QAAiB,EAAE;SAC3C;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,KAAK,CAAC,KAAK,EAAE,CAAC;YACpB,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,yCAAyC;IACzC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,eAAe;QACrB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAAC,yBAAe,EAAE,aAAG,CAAC,GAAG,EAAE,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;gBACvE,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,KAAK,EAAE,GAAG,CAAC,OAAO,CAAC,OAAO,IAAI,EAAE,CAAuB,CAAC;YAEhE,MAAM,OAAO,GAAG,MAAM,KAAK,CAAC,SAAS,CAAC,KAAK,IAAI,IAAI,CAAC,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC;YAC7E,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,OAAO,EAAE,CAAC,CAAC;QACjC,CAAC;KACF,CAAC,CAAC;IAEH,wCAAwC;IACxC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,QAAQ;QAChB,IAAI,EAAE,eAAe;QACrB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,KAAK,EAAE,0BAAgB;gBACvB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,IAAI,EAAE,GAAG,OAAO,CAAC,KAAkE,CAAC;YAE1G,MAAM,OAAO,GAAG,MAAM,KAAK,CAAC,KAAK,CAAC,KAAK,EAAE,KAAK,EAAE,IAAW,CAAC,CAAC;YAC7D,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,OAAO,EAAE,OAAO,CAAC,MAAM,EAAE,CAAC,CAAC;QACjD,CAAC;KACF,CAAC,CAAC;IAEH,qCAAqC;IACrC,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,iBAAiB;QACvB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,OAAO,GAAG,MAAM,KAAK,CAAC,UAAU,EAAE,CAAC;YACzC,OAAO,CAAC,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC;QAC7B,CAAC;KACF,CAAC,CAAC;IAEH,0EAA0E;IAC1E,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,MAAM;QACd,IAAI,EAAE,iBAAiB;QACvB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,sBAAY;gBACrB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,eAAe,CAAC,OAAO,CAAC,CAAC;YACpD,MAAM,QAAQ,GAAG,QAAQ,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;YAC5C,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,OAAO,CAAC,OAItD,CAAC;YAEF,MAAM,EAAE,GAAG,MAAM,QAAQ,CAAC,GAAG,CAAC,OAAO,EAAE,IAAI,EAAE,OAAc,CAAC,CAAC;YAC7D,IAAI,CAAC,EAAE;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,kBAAkB,CAAC,CAAC;YACjD,OAAO,CAAC,CAAC,QAAQ,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QACtC,CAAC;KACF,CAAC,CAAC;IAEH,8BAA8B;IAE9B,+CAA+C;IAC/C,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,oBAAoB;QAC1B,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAErC,MAAM,UAAU,GAAG,MAAO,KAAa,CAAC,iBAAiB,EAAE,CAAC;YAC5D,OAAO,CAAC,CAAC,QAAQ,CAAC,UAAU,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,6DAA6D;IAC7D,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,oCAAoC;QAC1C,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,aAAa,EAAE,GAAG,OAAO,CAAC,MAAiD,CAAC;YAEpF,MAAM,SAAS,GAAG,MAAO,KAAa,CAAC,eAAe,CAAC,aAAa,CAAC,CAAC;YACtE,IAAI,CAAC,SAAS;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,qBAAqB,CAAC,CAAC;YAC3D,OAAO,CAAC,CAAC,QAAQ,CAAC,SAAS,CAAC,CAAC;QAC/B,CAAC;KACF,CAAC,CAAC;IAEH,8DAA8D;IAC9D,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,oCAAoC;QAC1C,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,OAAO,EAAE,mCAAqB;gBAC9B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,aAAa,EAAE,GAAG,OAAO,CAAC,MAAiD,CAAC;YACpF,MAAM,EAAE,QAAQ,EAAE,QAAQ,EAAE,GAAG,OAAO,CAAC,OAGtC,CAAC;YAEF,MAAM,GAAG,GAAG,MAAO,KAAa,CAAC,kBAAkB,CAAC,aAAa,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAC;YACvF,OAAO,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,CAAC,CAAC,IAAA,0BAAY,EAAC,GAAG,CAAC,CAAC,CAAC,CAAC,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;QAC5D,CAAC;KACF,CAAC,CAAC;IAEH,iEAAiE;IACjE,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,QAAQ;QAChB,IAAI,EAAE,oCAAoC;QAC1C,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,aAAa,EAAE,GAAG,OAAO,CAAC,MAAiD,CAAC;YAEpF,MAAO,KAAa,CAAC,kBAAkB,CAAC,aAAa,CAAC,CAAC;YACvD,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;KACF,CAAC,CAAC;IAEH,8BAA8B;IAE9B,4EAA4E;IAC5E,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,0BAA0B;QAChC,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,2BAAiB;gBACzB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,KAAK,GAAG,MAAO,KAAa,CAAC,YAAY,CAAC,EAAE,CAAC,CAAC;YACpD,IAAI,CAAC,KAAK;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,gBAAgB,CAAC,CAAC;YAClD,OAAO,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC;QAC3B,CAAC;KACF,CAAC,CAAC;IAEH,+DAA+D;IAC/D,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,2BAA2B;QACjC,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,2BAAiB;gBACzB,UAAU;aACX;SACF;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,MAAM,GAAG,MAAO,KAAa,CAAC,aAAa,CAAC,EAAE,CAAC,CAAC;YACtD,IAAI,CAAC,MAAM;gBAAE,MAAM,cAAI,CAAC,QAAQ,CAAC,gBAAgB,CAAC,CAAC;YACnD,OAAO,CAAC,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC5B,CAAC;KACF,CAAC,CAAC;IAEH,6EAA6E;IAC7E,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,0BAA0B;QAChC,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;YACD,OAAO,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,MAAM,EAAE,KAAK,EAAE;SAC1C;QACD,OAAO,EAAE,KAAK,EAAE,OAAgB,EAAE,CAAkB,EAAE,EAAE;YACtD,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;YACjD,MAAM,EAAE,KAAK,EAAE,GAAG,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YACrC,MAAM,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,MAAsC,CAAC;YAE9D,MAAM,MAAM,GAAG,IAAI,oBAAW,EAAE,CAAC;YACjC,MAAM,QAAQ,GAAG,CAAC;iBACf,QAAQ,CAAC,MAAM,CAAC;iBAChB,IAAI,CAAC,mBAAmB,CAAC;iBACzB,MAAM,CAAC,eAAe,EAAE,UAAU,CAAC,CAAC;YAEvC,MAAM,CAAC,KAAK,CAAC,SAAS,CAAC,CAAC;YAExB,IAAI,MAAM,GAAI,OAAO,CAAC,OAAO,CAAC,eAAe,CAAY;mBACnD,OAAO,CAAC,KAAa,CAAC,MAAgB;mBACvC,SAAS,CAAC;YACf,IAAI,OAAO,GAAG,IAAI,CAAC;YAEnB,OAAO,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,GAAG,EAAE;gBAC/B,OAAO,GAAG,KAAK,CAAC;YAClB,CAAC,CAAC,CAAC;YAEH,CAAC,KAAK,IAAI,EAAE;gBACV,IAAI,CAAC;oBACH,OAAO,OAAO,EAAE,CAAC;wBACf,MAAM,OAAO,GAAG,MAAO,KAAa,CAAC,UAAU,CAAC,EAAE,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAC;wBAC5E,KAAK,MAAM,KAAK,IAAI,OAAO,EAAE,CAAC;4BAC5B,MAAM,CAAC,KAAK,CAAC,OAAO,KAAK,CAAC,EAAE,WAAW,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC;4BAC3E,MAAM,GAAG,KAAK,CAAC,EAAE,CAAC;wBACpB,CAAC;wBAED,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;wBACnC,IAAI,CAAC,GAAG;4BAAE,MAAM;wBAChB,MAAM,KAAK,GAAG,MAAO,GAAW,CAAC,QAAQ,EAAE,CAAC;wBAC5C,IAAI,KAAK,KAAK,WAAW,IAAI,KAAK,KAAK,QAAQ,EAAE,CAAC;4BAChD,MAAM,QAAQ,GAAG,MAAO,KAAa,CAAC,UAAU,CAAC,EAAE,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAC;4BAC7E,KAAK,MAAM,KAAK,IAAI,QAAQ,EAAE,CAAC;gCAC7B,MAAM,CAAC,KAAK,CAAC,OAAO,KAAK,CAAC,EAAE,WAAW,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC;4BAC7E,CAAC;4BACD,MAAM;wBACR,CAAC;wBAED,MAAM,IAAI,OAAO,CAAO,CAAC,CAAC,EAAE,EAAE,CAAC,UAAU,CAAC,CAAC,EAAE,GAAG,CAAC,CAAC,CAAC;oBACrD,CAAC;gBACH,CAAC;gBAAC,MAAM,CAAC;oBACP,kDAAkD;gBACpD,CAAC;wBAAS,CAAC;oBACT,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE,CAAC;wBAC1B,MAAM,CAAC,GAAG,EAAE,CAAC;oBACf,CAAC;gBACH,CAAC;YACH,CAAC,CAAC,EAAE,CAAC;YAEL,OAAO,QAAQ,CAAC;QAClB,CAAC;KACF,CAAC,CAAC;IAEH,kCAAkC;IAClC,MAAM,aAAa,GAAG,IAAA,4BAAmB,EAAC,MAAM,CAAC,CAAC;IAClD,MAAM,CAAC,KAAK,CAAC;QACX,MAAM,EAAE,KAAK;QACb,IAAI,EAAE,gBAAgB;QACtB,OAAO,EAAE;YACP,QAAQ,EAAE;gBACR,MAAM,EAAE,8BAAoB;gBAC5B,UAAU;aACX;YACD,OAAO,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,MAAM,EAAE,KAAK,EAAE;SAC1C;QACD,OAAO,EAAE,aAAa;KACvB,CAAC,CAAC;AACL,CAAC"}

dist/schemas.d.ts

@@ -14,3 +14,5 @@ import Joi from 'joi';
 export declare const metricsQuerySchema: Joi.ObjectSchema<any>;
+export declare const flowIdParamSchema: Joi.ObjectSchema<any>;
+export declare const jobStreamParamSchema: Joi.ObjectSchema<any>;
 export declare const optionsSchema: Joi.ObjectSchema<any>;
 //# sourceMappingURL=schemas.d.ts.map

dist/schemas.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"schemas.d.ts","sourceRoot":"","sources":["../src/schemas.ts"],"names":[],"mappings":"AAAA,OAAO,GAAG,MAAM,KAAK,CAAC;AA2CtB,eAAO,MAAM,oBAAoB,uBAE/B,CAAC;AAEH,eAAO,MAAM,gBAAgB,uBAG3B,CAAC;AAEH,eAAO,MAAM,oBAAoB,uBAG/B,CAAC;AAIH,eAAO,MAAM,YAAY,uBAIvB,CAAC;AAEH,eAAO,MAAM,oBAAoB,uBAK/B,CAAC;AAEH,eAAO,MAAM,wBAAwB,uBAEnC,CAAC;AAEH,eAAO,MAAM,qBAAqB,uBAEhC,CAAC;AAEH,eAAO,MAAM,eAAe,uBAE1B,CAAC;AAEH,eAAO,MAAM,yBAAyB,uBAepC,CAAC;AAIH,eAAO,MAAM,kBAAkB,uBAO7B,CAAC;AAEH,eAAO,MAAM,gBAAgB,uBAI3B,CAAC;AAEH,eAAO,MAAM,kBAAkB,uBAI7B,CAAC;AAIH,eAAO,MAAM,aAAa,uBA2BxB,CAAC"}
+{"version":3,"file":"schemas.d.ts","sourceRoot":"","sources":["../src/schemas.ts"],"names":[],"mappings":"AAAA,OAAO,GAAG,MAAM,KAAK,CAAC;AA2CtB,eAAO,MAAM,oBAAoB,uBAE/B,CAAC;AAEH,eAAO,MAAM,gBAAgB,uBAG3B,CAAC;AAEH,eAAO,MAAM,oBAAoB,uBAG/B,CAAC;AAIH,eAAO,MAAM,YAAY,uBAIvB,CAAC;AAEH,eAAO,MAAM,oBAAoB,uBAK/B,CAAC;AAEH,eAAO,MAAM,wBAAwB,uBAEnC,CAAC;AAEH,eAAO,MAAM,qBAAqB,uBAEhC,CAAC;AAEH,eAAO,MAAM,eAAe,uBAE1B,CAAC;AAEH,eAAO,MAAM,yBAAyB,uBAepC,CAAC;AAIH,eAAO,MAAM,kBAAkB,uBAO7B,CAAC;AAEH,eAAO,MAAM,gBAAgB,uBAI3B,CAAC;AAEH,eAAO,MAAM,kBAAkB,uBAI7B,CAAC;AAIH,eAAO,MAAM,iBAAiB,uBAG5B,CAAC;AAEH,eAAO,MAAM,oBAAoB,uBAG/B,CAAC;AAIH,eAAO,MAAM,aAAa,uBA2BxB,CAAC"}

dist/schemas.js

@@ -6,3 +6,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.optionsSchema = exports.metricsQuerySchema = exports.cleanQuerySchema = exports.getJobsQuerySchema = exports.upsertSchedulerBodySchema = exports.retryBodySchema = exports.changeDelayBodySchema = exports.changePriorityBodySchema = exports.addAndWaitBodySchema = exports.addJobSchema = exports.schedulerParamSchema = exports.jobIdParamSchema = exports.queueNameParamSchema = void 0;
+exports.optionsSchema = exports.jobStreamParamSchema = exports.flowIdParamSchema = exports.metricsQuerySchema = exports.cleanQuerySchema = exports.getJobsQuerySchema = exports.upsertSchedulerBodySchema = exports.retryBodySchema = exports.changeDelayBodySchema = exports.changePriorityBodySchema = exports.addAndWaitBodySchema = exports.addJobSchema = exports.schedulerParamSchema = exports.jobIdParamSchema = exports.queueNameParamSchema = void 0;
 const joi_1 = __importDefault(require("joi"));
@@ -109,2 +109,11 @@ // --- Reusable fragments ---
 });
+// --- AI-native param schemas ---
+exports.flowIdParamSchema = joi_1.default.object({
+    name: joi_1.default.string().pattern(/^[a-zA-Z0-9_-]{1,128}$/).required(),
+    id: joi_1.default.string().required(),
+});
+exports.jobStreamParamSchema = joi_1.default.object({
+    name: joi_1.default.string().pattern(/^[a-zA-Z0-9_-]{1,128}$/).required(),
+    id: joi_1.default.string().required(),
+});
 // --- Plugin options schema ---
@@ -111,0 +120,0 @@ exports.optionsSchema = joi_1.default.object({

dist/schemas.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"schemas.js","sourceRoot":"","sources":["../src/schemas.ts"],"names":[],"mappings":";;;;;;AAAA,8CAAsB;AAEtB,6BAA6B;AAE7B,MAAM,cAAc,GAAG,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAC3C,aAAG,CAAC,OAAO,EAAE,EACb,aAAG,CAAC,MAAM,EAAE,EACZ,aAAG,CAAC,MAAM,CAAC,EAAE,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,EAAE,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,EAAE,CAAC,CAC7E,CAAC;AAEF,MAAM,aAAa,GAAG,aAAG,CAAC,MAAM,CAAC;IAC/B,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE;IACnB,QAAQ,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,IAAI,CAAC;IACjD,QAAQ,EAAE,aAAG,CAAC,MAAM,EAAE;IACtB,OAAO,EAAE,aAAG,CAAC,MAAM,EAAE;IACrB,gBAAgB,EAAE,cAAc;IAChC,YAAY,EAAE,cAAc;IAC5B,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE;IACnB,IAAI,EAAE,aAAG,CAAC,OAAO,EAAE;IACnB,aAAa,EAAE,aAAG,CAAC,MAAM,CAAC;QACxB,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC3B,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE;QACjB,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC,QAAQ,EAAE,UAAU,EAAE,UAAU,CAAC;KAC3D,CAAC;IACF,QAAQ,EAAE,aAAG,CAAC,MAAM,CAAC;QACnB,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC5B,WAAW,EAAE,aAAG,CAAC,MAAM,EAAE;KAC1B,CAAC;IACF,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE;IAClB,OAAO,EAAE,aAAG,CAAC,MAAM,CAAC;QAClB,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC7B,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC9B,MAAM,EAAE,aAAG,CAAC,MAAM,EAAE;KACrB,CAAC;IACF,MAAM,EAAE,aAAG,CAAC,MAAM,CAAC;QACjB,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC9B,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;KAC5B,CAAC;IACF,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE;CAClB,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,OAAO,CAAC,EAAE,CAAC,CAAC;AAE7B,wBAAwB;AAEX,QAAA,oBAAoB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC7C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,wBAAwB,CAAC,CAAC,QAAQ,EAAE;CAChE,CAAC,CAAC;AAEU,QAAA,gBAAgB,GAAG,aAAG,CAAC,MAAM,CAAC;IACzC,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,wBAAwB,CAAC,CAAC,QAAQ,EAAE;IAC/D,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CAC5B,CAAC,CAAC;AAEU,QAAA,oBAAoB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC7C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,wBAAwB,CAAC,CAAC,QAAQ,EAAE;IAC/D,aAAa,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,2BAA2B,CAAC,CAAC,QAAQ,EAAE;CAC5E,CAAC,CAAC;AAEH,iCAAiC;AAEpB,QAAA,YAAY,GAAG,aAAG,CAAC,MAAM,CAAC;IACrC,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,QAAQ,EAAE;IACpC,IAAI,EAAE,aAAG,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,EAAE,CAAC;IAC3B,IAAI,EAAE,aAAa;CACpB,CAAC,CAAC;AAEU,QAAA,oBAAoB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC7C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,QAAQ,EAAE;IACpC,IAAI,EAAE,aAAG,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,EAAE,CAAC;IAC3B,IAAI,EAAE,aAAa;IACnB,WAAW,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CACrC,CAAC,CAAC;AAEU,QAAA,wBAAwB,GAAG,aAAG,CAAC,MAAM,CAAC;IACjD,QAAQ,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,QAAQ,EAAE;CAC7D,CAAC,CAAC;AAEU,QAAA,qBAAqB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC9C,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,QAAQ,EAAE;CAChD,CAAC,CAAC;AAEU,QAAA,eAAe,GAAG,aAAG,CAAC,MAAM,CAAC;IACxC,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC;CACrC,CAAC,CAAC;AAEU,QAAA,yBAAyB,GAAG,aAAG,CAAC,MAAM,CAAC;IAClD,QAAQ,EAAE,aAAG,CAAC,MAAM,CAAC;QACnB,OAAO,EAAE,aAAG,CAAC,MAAM,EAAE;QACrB,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE;QACnB,mBAAmB,EAAE,aAAG,CAAC,OAAO,EAAE;QAClC,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE;QAChB,SAAS,EAAE,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAAC,aAAG,CAAC,MAAM,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC;QAC7D,OAAO,EAAE,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAAC,aAAG,CAAC,MAAM,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC;QAC3D,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE;KACpB,CAAC,CAAC,QAAQ,EAAE;IACb,QAAQ,EAAE,aAAG,CAAC,MAAM,CAAC;QACnB,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE;QAClB,IAAI,EAAE,aAAG,CAAC,GAAG,EAAE;QACf,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;KACjC,CAAC;CACH,CAAC,CAAC;AAEH,wBAAwB;AAEX,QAAA,kBAAkB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC3C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE;SACf,KAAK,CAAC,SAAS,EAAE,QAAQ,EAAE,SAAS,EAAE,WAAW,EAAE,QAAQ,CAAC;SAC5D,OAAO,CAAC,SAAS,CAAC;IACrB,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,CAAC,CAAC;IAC9B,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;IAC7B,WAAW,EAAE,aAAG,CAAC,OAAO,EAAE,CAAC,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,KAAK,CAAC,OAAO,EAAE,GAAG,CAAC,CAAC,OAAO,CAAC,KAAK,CAAC;CAClF,CAAC,CAAC;AAEU,QAAA,gBAAgB,GAAG,aAAG,CAAC,MAAM,CAAC;IACzC,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC;IAC/C,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC;IACjD,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC,OAAO,CAAC,WAAW,CAAC;CACrE,CAAC,CAAC;AAEU,QAAA,kBAAkB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC3C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC,QAAQ,EAAE;IAC1D,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,CAAC,CAAC;IAC9B,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;CAC9B,CAAC,CAAC;AAEH,gCAAgC;AAEnB,QAAA,aAAa,GAAG,aAAG,CAAC,MAAM,CAAC;IACtC,UAAU,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;IACtC,MAAM,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAC1B,aAAG,CAAC,MAAM,EAAE,EACZ,aAAG,CAAC,MAAM,CAAC;QACT,SAAS,EAAE,aAAG,CAAC,QAAQ,EAAE;QACzB,WAAW,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC;QAC1C,UAAU,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;KACvC,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CACjB;IACD,SAAS,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAC7B,aAAG,CAAC,MAAM,EAAE,EACZ,aAAG,CAAC,MAAM,CAAC;QACT,WAAW,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC,MAAM,EAAE,MAAM,CAAC;QAC/C,UAAU,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;KACvC,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CACjB;IACD,MAAM,EAAE,aAAG,CAAC,MAAM,EAAE;IACpB,OAAO,EAAE,aAAG,CAAC,OAAO,EAAE;IACtB,UAAU,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;IACtC,MAAM,EAAE,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAC5B,aAAG,CAAC,OAAO,EAAE,EACb,aAAG,CAAC,MAAM,CAAC;QACT,MAAM,EAAE,aAAG,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,aAAG,CAAC,MAAM,EAAE,CAAC;QACvC,SAAS,EAAE,aAAG,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,aAAG,CAAC,MAAM,EAAE,CAAC;KAC3C,CAAC,CACH;CACF,CAAC,CAAC"}
+{"version":3,"file":"schemas.js","sourceRoot":"","sources":["../src/schemas.ts"],"names":[],"mappings":";;;;;;AAAA,8CAAsB;AAEtB,6BAA6B;AAE7B,MAAM,cAAc,GAAG,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAC3C,aAAG,CAAC,OAAO,EAAE,EACb,aAAG,CAAC,MAAM,EAAE,EACZ,aAAG,CAAC,MAAM,CAAC,EAAE,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,EAAE,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,EAAE,CAAC,CAC7E,CAAC;AAEF,MAAM,aAAa,GAAG,aAAG,CAAC,MAAM,CAAC;IAC/B,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE;IACnB,QAAQ,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,IAAI,CAAC;IACjD,QAAQ,EAAE,aAAG,CAAC,MAAM,EAAE;IACtB,OAAO,EAAE,aAAG,CAAC,MAAM,EAAE;IACrB,gBAAgB,EAAE,cAAc;IAChC,YAAY,EAAE,cAAc;IAC5B,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE;IACnB,IAAI,EAAE,aAAG,CAAC,OAAO,EAAE;IACnB,aAAa,EAAE,aAAG,CAAC,MAAM,CAAC;QACxB,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC3B,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE;QACjB,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC,QAAQ,EAAE,UAAU,EAAE,UAAU,CAAC;KAC3D,CAAC;IACF,QAAQ,EAAE,aAAG,CAAC,MAAM,CAAC;QACnB,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC5B,WAAW,EAAE,aAAG,CAAC,MAAM,EAAE;KAC1B,CAAC;IACF,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE;IAClB,OAAO,EAAE,aAAG,CAAC,MAAM,CAAC;QAClB,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC7B,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC9B,MAAM,EAAE,aAAG,CAAC,MAAM,EAAE;KACrB,CAAC;IACF,MAAM,EAAE,aAAG,CAAC,MAAM,CAAC;QACjB,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;QAC9B,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;KAC5B,CAAC;IACF,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE;CAClB,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,OAAO,CAAC,EAAE,CAAC,CAAC;AAE7B,wBAAwB;AAEX,QAAA,oBAAoB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC7C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,wBAAwB,CAAC,CAAC,QAAQ,EAAE;CAChE,CAAC,CAAC;AAEU,QAAA,gBAAgB,GAAG,aAAG,CAAC,MAAM,CAAC;IACzC,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,wBAAwB,CAAC,CAAC,QAAQ,EAAE;IAC/D,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CAC5B,CAAC,CAAC;AAEU,QAAA,oBAAoB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC7C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,wBAAwB,CAAC,CAAC,QAAQ,EAAE;IAC/D,aAAa,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,2BAA2B,CAAC,CAAC,QAAQ,EAAE;CAC5E,CAAC,CAAC;AAEH,iCAAiC;AAEpB,QAAA,YAAY,GAAG,aAAG,CAAC,MAAM,CAAC;IACrC,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,QAAQ,EAAE;IACpC,IAAI,EAAE,aAAG,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,EAAE,CAAC;IAC3B,IAAI,EAAE,aAAa;CACpB,CAAC,CAAC;AAEU,QAAA,oBAAoB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC7C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,QAAQ,EAAE;IACpC,IAAI,EAAE,aAAG,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,EAAE,CAAC;IAC3B,IAAI,EAAE,aAAa;IACnB,WAAW,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CACrC,CAAC,CAAC;AAEU,QAAA,wBAAwB,GAAG,aAAG,CAAC,MAAM,CAAC;IACjD,QAAQ,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,QAAQ,EAAE;CAC7D,CAAC,CAAC;AAEU,QAAA,qBAAqB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC9C,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,QAAQ,EAAE;CAChD,CAAC,CAAC;AAEU,QAAA,eAAe,GAAG,aAAG,CAAC,MAAM,CAAC;IACxC,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC;CACrC,CAAC,CAAC;AAEU,QAAA,yBAAyB,GAAG,aAAG,CAAC,MAAM,CAAC;IAClD,QAAQ,EAAE,aAAG,CAAC,MAAM,CAAC;QACnB,OAAO,EAAE,aAAG,CAAC,MAAM,EAAE;QACrB,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE;QACnB,mBAAmB,EAAE,aAAG,CAAC,OAAO,EAAE;QAClC,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE;QAChB,SAAS,EAAE,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAAC,aAAG,CAAC,MAAM,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC;QAC7D,OAAO,EAAE,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAAC,aAAG,CAAC,MAAM,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC;QAC3D,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE;KACpB,CAAC,CAAC,QAAQ,EAAE;IACb,QAAQ,EAAE,aAAG,CAAC,MAAM,CAAC;QACnB,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE;QAClB,IAAI,EAAE,aAAG,CAAC,GAAG,EAAE;QACf,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;KACjC,CAAC;CACH,CAAC,CAAC;AAEH,wBAAwB;AAEX,QAAA,kBAAkB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC3C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE;SACf,KAAK,CAAC,SAAS,EAAE,QAAQ,EAAE,SAAS,EAAE,WAAW,EAAE,QAAQ,CAAC;SAC5D,OAAO,CAAC,SAAS,CAAC;IACrB,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,CAAC,CAAC;IAC9B,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;IAC7B,WAAW,EAAE,aAAG,CAAC,OAAO,EAAE,CAAC,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,KAAK,CAAC,OAAO,EAAE,GAAG,CAAC,CAAC,OAAO,CAAC,KAAK,CAAC;CAClF,CAAC,CAAC;AAEU,QAAA,gBAAgB,GAAG,aAAG,CAAC,MAAM,CAAC;IACzC,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC;IAC/C,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC;IACjD,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC,OAAO,CAAC,WAAW,CAAC;CACrE,CAAC,CAAC;AAEU,QAAA,kBAAkB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC3C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC,QAAQ,EAAE;IAC1D,KAAK,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,CAAC,CAAC;IAC9B,GAAG,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;CAC9B,CAAC,CAAC;AAEH,kCAAkC;AAErB,QAAA,iBAAiB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC1C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,wBAAwB,CAAC,CAAC,QAAQ,EAAE;IAC/D,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CAC5B,CAAC,CAAC;AAEU,QAAA,oBAAoB,GAAG,aAAG,CAAC,MAAM,CAAC;IAC7C,IAAI,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,wBAAwB,CAAC,CAAC,QAAQ,EAAE;IAC/D,EAAE,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CAC5B,CAAC,CAAC;AAEH,gCAAgC;AAEnB,QAAA,aAAa,GAAG,aAAG,CAAC,MAAM,CAAC;IACtC,UAAU,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;IACtC,MAAM,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAC1B,aAAG,CAAC,MAAM,EAAE,EACZ,aAAG,CAAC,MAAM,CAAC;QACT,SAAS,EAAE,aAAG,CAAC,QAAQ,EAAE;QACzB,WAAW,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC;QAC1C,UAAU,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;KACvC,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CACjB;IACD,SAAS,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAC7B,aAAG,CAAC,MAAM,EAAE,EACZ,aAAG,CAAC,MAAM,CAAC;QACT,WAAW,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC,MAAM,EAAE,MAAM,CAAC;QAC/C,UAAU,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;KACvC,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CACjB;IACD,MAAM,EAAE,aAAG,CAAC,MAAM,EAAE;IACpB,OAAO,EAAE,aAAG,CAAC,OAAO,EAAE;IACtB,UAAU,EAAE,aAAG,CAAC,MAAM,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC;IACtC,MAAM,EAAE,aAAG,CAAC,YAAY,EAAE,CAAC,GAAG,CAC5B,aAAG,CAAC,OAAO,EAAE,EACb,aAAG,CAAC,MAAM,CAAC;QACT,MAAM,EAAE,aAAG,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,aAAG,CAAC,MAAM,EAAE,CAAC;QACvC,SAAS,EAAE,aAAG,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,aAAG,CAAC,MAAM,EAAE,CAAC;KAC3C,CAAC,CACH;CACF,CAAC,CAAC"}

dist/serializers.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"serializers.d.ts","sourceRoot":"","sources":["../src/serializers.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,GAAG,EAAE,MAAM,UAAU,CAAC;AACpC,OAAO,KAAK,EAAE,WAAW,EAAE,MAAM,SAAS,CAAC;AAE3C;;GAEG;AACH,wBAAgB,YAAY,CAAC,GAAG,EAAE,GAAG,GAAG,WAAW,CAuBlD;AAED;;GAEG;AACH,wBAAgB,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,WAAW,EAAE,CAExD"}
+{"version":3,"file":"serializers.d.ts","sourceRoot":"","sources":["../src/serializers.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,GAAG,EAAE,MAAM,UAAU,CAAC;AACpC,OAAO,KAAK,EAAE,WAAW,EAAE,MAAM,SAAS,CAAC;AAE3C;;GAEG;AACH,wBAAgB,YAAY,CAAC,GAAG,EAAE,GAAG,GAAG,WAAW,CA4BlD;AAED;;GAEG;AACH,wBAAgB,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,WAAW,EAAE,CAExD"}

dist/serializers.js

@@ -33,2 +33,12 @@ "use strict";
         result.schedulerName = jobAny.schedulerName;
+    if (jobAny.usage)
+        result.usage = jobAny.usage;
+    if (jobAny.signals?.length)
+        result.signals = jobAny.signals;
+    if (jobAny.budgetKey)
+        result.budgetKey = jobAny.budgetKey;
+    if (jobAny.fallbackIndex)
+        result.fallbackIndex = jobAny.fallbackIndex;
+    if (jobAny.tpmTokens != null)
+        result.tpmTokens = jobAny.tpmTokens;
     return result;
@@ -35,0 +45,0 @@ }

dist/serializers.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"serializers.js","sourceRoot":"","sources":["../src/serializers.ts"],"names":[],"mappings":";;AAMA,oCAuBC;AAKD,sCAEC;AAjCD;;GAEG;AACH,SAAgB,YAAY,CAAC,GAAQ;IACnC,MAAM,MAAM,GAAgB;QAC1B,EAAE,EAAE,GAAG,CAAC,EAAE;QACV,IAAI,EAAE,GAAG,CAAC,IAAI;QACd,IAAI,EAAE,GAAG,CAAC,IAAI;QACd,IAAI,EAAE,GAAG,CAAC,IAA+B;QACzC,YAAY,EAAE,GAAG,CAAC,YAAY;QAC9B,WAAW,EAAE,GAAG,CAAC,WAAW;QAC5B,YAAY,EAAE,GAAG,CAAC,YAAY;QAC9B,QAAQ,EAAE,GAAG,CAAC,QAAQ;QACtB,SAAS,EAAE,GAAG,CAAC,SAAS;QACxB,UAAU,EAAE,GAAG,CAAC,UAAU;QAC1B,WAAW,EAAE,GAAG,CAAC,WAAW;KAC7B,CAAC;IAEF,MAAM,MAAM,GAAG,GAAU,CAAC;IAC1B,IAAI,MAAM,CAAC,QAAQ,IAAI,IAAI;QAAE,MAAM,CAAC,QAAQ,GAAG,MAAM,CAAC,QAAQ,CAAC;IAC/D,IAAI,MAAM,CAAC,WAAW,IAAI,IAAI;QAAE,MAAM,CAAC,WAAW,GAAG,MAAM,CAAC,WAAW,CAAC;IACxE,IAAI,MAAM,CAAC,WAAW,IAAI,IAAI;QAAE,MAAM,CAAC,WAAW,GAAG,MAAM,CAAC,WAAW,CAAC;IACxE,IAAI,MAAM,CAAC,IAAI,IAAI,IAAI;QAAE,MAAM,CAAC,IAAI,GAAG,MAAM,CAAC,IAAI,CAAC;IACnD,IAAI,MAAM,CAAC,aAAa,IAAI,IAAI;QAAE,MAAM,CAAC,aAAa,GAAG,MAAM,CAAC,aAAa,CAAC;IAE9E,OAAO,MAAM,CAAC;AAChB,CAAC;AAED;;GAEG;AACH,SAAgB,aAAa,CAAC,IAAW;IACvC,OAAO,IAAI,CAAC,GAAG,CAAC,YAAY,CAAC,CAAC;AAChC,CAAC"}
+{"version":3,"file":"serializers.js","sourceRoot":"","sources":["../src/serializers.ts"],"names":[],"mappings":";;AAMA,oCA4BC;AAKD,sCAEC;AAtCD;;GAEG;AACH,SAAgB,YAAY,CAAC,GAAQ;IACnC,MAAM,MAAM,GAAgB;QAC1B,EAAE,EAAE,GAAG,CAAC,EAAE;QACV,IAAI,EAAE,GAAG,CAAC,IAAI;QACd,IAAI,EAAE,GAAG,CAAC,IAAI;QACd,IAAI,EAAE,GAAG,CAAC,IAA+B;QACzC,YAAY,EAAE,GAAG,CAAC,YAAY;QAC9B,WAAW,EAAE,GAAG,CAAC,WAAW;QAC5B,YAAY,EAAE,GAAG,CAAC,YAAY;QAC9B,QAAQ,EAAE,GAAG,CAAC,QAAQ;QACtB,SAAS,EAAE,GAAG,CAAC,SAAS;QACxB,UAAU,EAAE,GAAG,CAAC,UAAU;QAC1B,WAAW,EAAE,GAAG,CAAC,WAAW;KAC7B,CAAC;IAEF,MAAM,MAAM,GAAG,GAAU,CAAC;IAC1B,IAAI,MAAM,CAAC,QAAQ,IAAI,IAAI;QAAE,MAAM,CAAC,QAAQ,GAAG,MAAM,CAAC,QAAQ,CAAC;IAC/D,IAAI,MAAM,CAAC,WAAW,IAAI,IAAI;QAAE,MAAM,CAAC,WAAW,GAAG,MAAM,CAAC,WAAW,CAAC;IACxE,IAAI,MAAM,CAAC,WAAW,IAAI,IAAI;QAAE,MAAM,CAAC,WAAW,GAAG,MAAM,CAAC,WAAW,CAAC;IACxE,IAAI,MAAM,CAAC,IAAI,IAAI,IAAI;QAAE,MAAM,CAAC,IAAI,GAAG,MAAM,CAAC,IAAI,CAAC;IACnD,IAAI,MAAM,CAAC,aAAa,IAAI,IAAI;QAAE,MAAM,CAAC,aAAa,GAAG,MAAM,CAAC,aAAa,CAAC;IAC9E,IAAI,MAAM,CAAC,KAAK;QAAE,MAAM,CAAC,KAAK,GAAG,MAAM,CAAC,KAAK,CAAC;IAC9C,IAAI,MAAM,CAAC,OAAO,EAAE,MAAM;QAAE,MAAM,CAAC,OAAO,GAAG,MAAM,CAAC,OAAO,CAAC;IAC5D,IAAI,MAAM,CAAC,SAAS;QAAE,MAAM,CAAC,SAAS,GAAG,MAAM,CAAC,SAAS,CAAC;IAC1D,IAAI,MAAM,CAAC,aAAa;QAAE,MAAM,CAAC,aAAa,GAAG,MAAM,CAAC,aAAa,CAAC;IACtE,IAAI,MAAM,CAAC,SAAS,IAAI,IAAI;QAAE,MAAM,CAAC,SAAS,GAAG,MAAM,CAAC,SAAS,CAAC;IAElE,OAAO,MAAM,CAAC;AAChB,CAAC;AAED;;GAEG;AACH,SAAgB,aAAa,CAAC,IAAW;IACvC,OAAO,IAAI,CAAC,GAAG,CAAC,YAAY,CAAC,CAAC;AAChC,CAAC"}

dist/types.d.ts

@@ -83,2 +83,21 @@ import type { Queue, Worker, Job, Producer, ConnectionOptions, Serializer } from 'glide-mq';
     schedulerName?: string;
+    usage?: {
+        model?: string;
+        provider?: string;
+        tokens?: Record<string, number>;
+        totalTokens?: number;
+        costs?: Record<string, number>;
+        totalCost?: number;
+        costUnit?: string;
+        latencyMs?: number;
+        cached?: boolean;
+    };
+    signals?: Array<{
+        name: string;
+        data: any;
+        receivedAt: number;
+    }>;
+    budgetKey?: string;
+    fallbackIndex?: number;
+    tpmTokens?: number;
 }
@@ -85,0 +104,0 @@ export interface JobCountsResponse {

dist/types.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"types.d.ts","sourceRoot":"","sources":["../src/types.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,EAAE,GAAG,EAAE,QAAQ,EAAE,iBAAiB,EAAE,UAAU,EAAE,MAAM,UAAU,CAAC;AAI5F,MAAM,WAAW,WAAW,CAAC,CAAC,GAAG,GAAG,EAAE,CAAC,GAAG,GAAG;IAC3C,qEAAqE;IACrE,SAAS,CAAC,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,KAAK,OAAO,CAAC,CAAC,CAAC,CAAC;IAC3C,qCAAqC;IACrC,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,8EAA8E;IAC9E,UAAU,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACtC;AAED,MAAM,WAAW,cAAc;IAC7B,mEAAmE;IACnE,WAAW,CAAC,EAAE,MAAM,GAAG,MAAM,CAAC;IAC9B,qDAAqD;IACrD,UAAU,CAAC,EAAE,UAAU,CAAC;CACzB;AAED,MAAM,WAAW,aAAa;IAC5B,sEAAsE;IACtE,UAAU,CAAC,EAAE,iBAAiB,CAAC;IAC/B,sCAAsC;IACtC,MAAM,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,WAAW,CAAC,CAAC;IACrC,uEAAuE;IACvE,SAAS,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,cAAc,CAAC,CAAC;IAC3C,kDAAkD;IAClD,MAAM,CAAC,EAAE,MAAM,CAAC;IAChB,uDAAuD;IACvD,OAAO,CAAC,EAAE,OAAO,CAAC;IAClB,qDAAqD;IACrD,UAAU,CAAC,EAAE,UAAU,CAAC;CACzB;AAID,MAAM,WAAW,YAAY,CAAC,CAAC,GAAG,GAAG,EAAE,CAAC,GAAG,GAAG;IAC5C,KAAK,EAAE,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACnB,MAAM,EAAE,MAAM,CAAC,CAAC,EAAE,CAAC,CAAC,GAAG,IAAI,CAAC;CAC7B;AAED,MAAM,WAAW,aAAa;IAC5B,mDAAmD;IACnD,GAAG,CAAC,CAAC,GAAG,GAAG,EAAE,CAAC,GAAG,GAAG,EAAE,IAAI,EAAE,MAAM,GAAG,YAAY,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACxD,0CAA0C;IAC1C,GAAG,CAAC,IAAI,EAAE,MAAM,GAAG,OAAO,CAAC;IAC3B,sCAAsC;IACtC,KAAK,IAAI,MAAM,EAAE,CAAC;IAClB,8CAA8C;IAC9C,WAAW,CAAC,CAAC,GAAG,GAAG,EAAE,IAAI,EAAE,MAAM,GAAG,QAAQ,CAAC,CAAC,CAAC,CAAC;IAChD,6CAA6C;IAC7C,WAAW,CAAC,IAAI,EAAE,MAAM,GAAG,OAAO,CAAC;IACnC,yCAAyC;IACzC,aAAa,IAAI,MAAM,EAAE,CAAC;IAC1B,+CAA+C;IAC/C,QAAQ,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;IAC1B,qCAAqC;IACrC,QAAQ,CAAC,OAAO,EAAE,OAAO,CAAC;IAC1B,6DAA6D;IAC7D,aAAa,IAAI,iBAAiB,GAAG,SAAS,CAAC;IAC/C,yBAAyB;IACzB,SAAS,IAAI,MAAM,GAAG,SAAS,CAAC;CACjC;AAID,MAAM,WAAW,oBAAqB,SAAQ,aAAa;IACzD,+FAA+F;IAC/F,MAAM,CAAC,EAAE,OAAO,GAAG,oBAAoB,CAAC;CACzC;AAED,MAAM,WAAW,oBAAoB;IACnC,4EAA4E;IAC5E,MAAM,CAAC,EAAE,MAAM,EAAE,CAAC;IAClB,0FAA0F;IAC1F,SAAS,CAAC,EAAE,MAAM,EAAE,CAAC;CACtB;AAID,MAAM,WAAW,WAAW;IAC1B,EAAE,EAAE,MAAM,CAAC;IACX,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,EAAE,OAAO,CAAC;IACd,IAAI,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IAC9B,YAAY,EAAE,MAAM,CAAC;IACrB,WAAW,EAAE,OAAO,CAAC;IACrB,YAAY,EAAE,MAAM,GAAG,SAAS,CAAC;IACjC,QAAQ,EAAE,MAAM,GAAG,MAAM,CAAC;IAC1B,SAAS,EAAE,MAAM,CAAC;IAClB,UAAU,EAAE,MAAM,GAAG,SAAS,CAAC;IAC/B,WAAW,EAAE,MAAM,GAAG,SAAS,CAAC;IAChC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,IAAI,CAAC,EAAE,MAAM,CAAC;IACd,aAAa,CAAC,EAAE,MAAM,CAAC;CACxB;AAED,MAAM,WAAW,iBAAiB;IAChC,OAAO,EAAE,MAAM,CAAC;IAChB,MAAM,EAAE,MAAM,CAAC;IACf,OAAO,EAAE,MAAM,CAAC;IAChB,SAAS,EAAE,MAAM,CAAC;IAClB,MAAM,EAAE,MAAM,CAAC;CAChB;AAED,MAAM,WAAW,kBAAkB;IACjC,EAAE,EAAE,MAAM,CAAC;IACX,IAAI,EAAE,MAAM,CAAC;IACb,GAAG,EAAE,MAAM,CAAC;IACZ,SAAS,EAAE,MAAM,CAAC;IAClB,GAAG,EAAE,MAAM,CAAC;IACZ,UAAU,EAAE,MAAM,CAAC;CACpB;AAID,OAAO,QAAQ,YAAY,CAAC;IAC1B,UAAU,MAAM;QACd,4DAA4D;QAC5D,OAAO,EAAE,aAAa,CAAC;KACxB;IACD,UAAU,OAAO;QACf,oEAAoE;QACpE,OAAO,EAAE,aAAa,CAAC;KACxB;CACF"}
+{"version":3,"file":"types.d.ts","sourceRoot":"","sources":["../src/types.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,EAAE,GAAG,EAAE,QAAQ,EAAE,iBAAiB,EAAE,UAAU,EAAE,MAAM,UAAU,CAAC;AAI5F,MAAM,WAAW,WAAW,CAAC,CAAC,GAAG,GAAG,EAAE,CAAC,GAAG,GAAG;IAC3C,qEAAqE;IACrE,SAAS,CAAC,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,KAAK,OAAO,CAAC,CAAC,CAAC,CAAC;IAC3C,qCAAqC;IACrC,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,8EAA8E;IAC9E,UAAU,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACtC;AAED,MAAM,WAAW,cAAc;IAC7B,mEAAmE;IACnE,WAAW,CAAC,EAAE,MAAM,GAAG,MAAM,CAAC;IAC9B,qDAAqD;IACrD,UAAU,CAAC,EAAE,UAAU,CAAC;CACzB;AAED,MAAM,WAAW,aAAa;IAC5B,sEAAsE;IACtE,UAAU,CAAC,EAAE,iBAAiB,CAAC;IAC/B,sCAAsC;IACtC,MAAM,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,WAAW,CAAC,CAAC;IACrC,uEAAuE;IACvE,SAAS,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,cAAc,CAAC,CAAC;IAC3C,kDAAkD;IAClD,MAAM,CAAC,EAAE,MAAM,CAAC;IAChB,uDAAuD;IACvD,OAAO,CAAC,EAAE,OAAO,CAAC;IAClB,qDAAqD;IACrD,UAAU,CAAC,EAAE,UAAU,CAAC;CACzB;AAID,MAAM,WAAW,YAAY,CAAC,CAAC,GAAG,GAAG,EAAE,CAAC,GAAG,GAAG;IAC5C,KAAK,EAAE,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACnB,MAAM,EAAE,MAAM,CAAC,CAAC,EAAE,CAAC,CAAC,GAAG,IAAI,CAAC;CAC7B;AAED,MAAM,WAAW,aAAa;IAC5B,mDAAmD;IACnD,GAAG,CAAC,CAAC,GAAG,GAAG,EAAE,CAAC,GAAG,GAAG,EAAE,IAAI,EAAE,MAAM,GAAG,YAAY,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACxD,0CAA0C;IAC1C,GAAG,CAAC,IAAI,EAAE,MAAM,GAAG,OAAO,CAAC;IAC3B,sCAAsC;IACtC,KAAK,IAAI,MAAM,EAAE,CAAC;IAClB,8CAA8C;IAC9C,WAAW,CAAC,CAAC,GAAG,GAAG,EAAE,IAAI,EAAE,MAAM,GAAG,QAAQ,CAAC,CAAC,CAAC,CAAC;IAChD,6CAA6C;IAC7C,WAAW,CAAC,IAAI,EAAE,MAAM,GAAG,OAAO,CAAC;IACnC,yCAAyC;IACzC,aAAa,IAAI,MAAM,EAAE,CAAC;IAC1B,+CAA+C;IAC/C,QAAQ,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;IAC1B,qCAAqC;IACrC,QAAQ,CAAC,OAAO,EAAE,OAAO,CAAC;IAC1B,6DAA6D;IAC7D,aAAa,IAAI,iBAAiB,GAAG,SAAS,CAAC;IAC/C,yBAAyB;IACzB,SAAS,IAAI,MAAM,GAAG,SAAS,CAAC;CACjC;AAID,MAAM,WAAW,oBAAqB,SAAQ,aAAa;IACzD,+FAA+F;IAC/F,MAAM,CAAC,EAAE,OAAO,GAAG,oBAAoB,CAAC;CACzC;AAED,MAAM,WAAW,oBAAoB;IACnC,4EAA4E;IAC5E,MAAM,CAAC,EAAE,MAAM,EAAE,CAAC;IAClB,0FAA0F;IAC1F,SAAS,CAAC,EAAE,MAAM,EAAE,CAAC;CACtB;AAID,MAAM,WAAW,WAAW;IAC1B,EAAE,EAAE,MAAM,CAAC;IACX,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,EAAE,OAAO,CAAC;IACd,IAAI,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IAC9B,YAAY,EAAE,MAAM,CAAC;IACrB,WAAW,EAAE,OAAO,CAAC;IACrB,YAAY,EAAE,MAAM,GAAG,SAAS,CAAC;IACjC,QAAQ,EAAE,MAAM,GAAG,MAAM,CAAC;IAC1B,SAAS,EAAE,MAAM,CAAC;IAClB,UAAU,EAAE,MAAM,GAAG,SAAS,CAAC;IAC/B,WAAW,EAAE,MAAM,GAAG,SAAS,CAAC;IAChC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,IAAI,CAAC,EAAE,MAAM,CAAC;IACd,aAAa,CAAC,EAAE,MAAM,CAAC;IACvB,KAAK,CAAC,EAAE;QACN,KAAK,CAAC,EAAE,MAAM,CAAC;QACf,QAAQ,CAAC,EAAE,MAAM,CAAC;QAClB,MAAM,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,MAAM,CAAC,CAAC;QAChC,WAAW,CAAC,EAAE,MAAM,CAAC;QACrB,KAAK,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,MAAM,CAAC,CAAC;QAC/B,SAAS,CAAC,EAAE,MAAM,CAAC;QACnB,QAAQ,CAAC,EAAE,MAAM,CAAC;QAClB,SAAS,CAAC,EAAE,MAAM,CAAC;QACnB,MAAM,CAAC,EAAE,OAAO,CAAC;KAClB,CAAC;IACF,OAAO,CAAC,EAAE,KAAK,CAAC;QAAE,IAAI,EAAE,MAAM,CAAC;QAAC,IAAI,EAAE,GAAG,CAAC;QAAC,UAAU,EAAE,MAAM,CAAA;KAAE,CAAC,CAAC;IACjE,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,aAAa,CAAC,EAAE,MAAM,CAAC;IACvB,SAAS,CAAC,EAAE,MAAM,CAAC;CACpB;AAED,MAAM,WAAW,iBAAiB;IAChC,OAAO,EAAE,MAAM,CAAC;IAChB,MAAM,EAAE,MAAM,CAAC;IACf,OAAO,EAAE,MAAM,CAAC;IAChB,SAAS,EAAE,MAAM,CAAC;IAClB,MAAM,EAAE,MAAM,CAAC;CAChB;AAED,MAAM,WAAW,kBAAkB;IACjC,EAAE,EAAE,MAAM,CAAC;IACX,IAAI,EAAE,MAAM,CAAC;IACb,GAAG,EAAE,MAAM,CAAC;IACZ,SAAS,EAAE,MAAM,CAAC;IAClB,GAAG,EAAE,MAAM,CAAC;IACZ,UAAU,EAAE,MAAM,CAAC;CACpB;AAID,OAAO,QAAQ,YAAY,CAAC;IAC1B,UAAU,MAAM;QACd,4DAA4D;QAC5D,OAAO,EAAE,aAAa,CAAC;KACxB;IACD,UAAU,OAAO;QACf,oEAAoE;QACpE,OAAO,EAAE,aAAa,CAAC;KACxB;CACF"}

package.json

 {
   "name": "@glidemq/hapi",
-  "version": "0.2.0",
+  "version": "0.3.0",
   "description": "Hapi plugin for glide-mq - queue management REST API and SSE events",
@@ -54,7 +54,7 @@ "main": "dist/index.js",
   },
-  "homepage": "https://github.com/avifenesh/glidemq-hapi#readme",
+  "homepage": "https://avifenesh.github.io/glide-mq.dev/integrations/hapi",
   "sideEffects": false,
   "peerDependencies": {
     "@hapi/hapi": ">=21.0.0",
-    "glide-mq": ">=0.9.0",
+    "glide-mq": ">=0.14.0",
     "joi": ">=17.0.0"
@@ -61,0 +61,0 @@ },

README.md

@@ -6,22 +6,17 @@ # @glidemq/hapi
 
-REST API and real-time SSE for [glide-mq](https://github.com/avifenesh/glide-mq) job queues, as a Hapi.js plugin. Two registrations -- declare queues, get 21 endpoints.
+Hapi v21 plugin that turns [glide-mq](https://github.com/avifenesh/glide-mq) queues into a REST API with real-time SSE - one registration, 24 endpoints. Works as a general-purpose job queue API and as an AI orchestration layer with built-in usage tracking, budget monitoring, and streaming endpoints.
 
-Turns a Hapi v21 server into a queue management gateway. Built for teams that run Hapi in production and need to expose queue operations to dashboards, CLI tools, or other services.
+## Why
 
-> If glide-mq is useful to you, consider [giving it a star](https://github.com/avifenesh/glide-mq). It helps others discover the project.
+- **Zero route boilerplate** - declare queues, get job CRUD, metrics, schedulers, and SSE endpoints
+- **Testable without Valkey** - `createTestApp` builds an in-memory Hapi server for `server.inject()` assertions
+- **Joi validation** - all request bodies and query params validated with structured error messages
 
-## Why @glidemq/hapi
-
-- Use this when you need HTTP endpoints to manage glide-mq queues without writing route handlers yourself.
-- Use this when you want live SSE streams of job events for dashboards or monitoring.
-- Use this when serverless functions only need to enqueue jobs through lightweight Producer endpoints.
-- Use this when you need to test queue logic in CI without a running Valkey instance.
-
 ## Install
 
 ```bash
-npm install @glidemq/hapi glide-mq @hapi/hapi
+npm install @glidemq/hapi glide-mq @hapi/hapi joi
 ```
 
-Requires **glide-mq 0.9+**.
+Requires **glide-mq >= 0.14.0** and **Hapi 21+**.
 
@@ -32,3 +27,3 @@ ## Quick start
 import Hapi from "@hapi/hapi";
-import { glideMQPlugin, glideMQRoutes } from "@glidemq/hapi";
+import { glideMQPlugin } from "@glidemq/hapi";
 
@@ -44,3 +39,3 @@ const server = Hapi.server({ port: 3000 });
         processor: async (job) => {
-          console.log("Sending to", job.data.to);
+          await sendEmail(job.data.to, job.data.subject);
           return { sent: true };
@@ -50,52 +45,26 @@ },
     },
+    routes: true, // mounts REST + SSE endpoints
   },
 });
 
-await server.register({ plugin: glideMQRoutes });
 await server.start();
+// POST /emails/jobs to enqueue, GET /emails/events for SSE
 ```
 
-The server now accepts `POST /emails/jobs` to enqueue jobs and `GET /emails/events` for live SSE. See the full endpoint table below.
+`glideMQPlugin` creates a registry on `server.glidemq` and optionally mounts routes. The `onPostStop` hook handles graceful shutdown.
 
-## How it works
+## AI-native endpoints
 
-`glideMQPlugin` creates a `QueueRegistry`, decorates `server.glidemq` so every route handler can access it, eagerly initializes configured producers, and registers an `onPostStop` hook that closes all queues, workers, and producers on shutdown. `glideMQRoutes` depends on the core plugin and mounts 21 REST endpoints under an optional path prefix. Queue and worker instances are created lazily on first request; producers are created eagerly so connection errors surface at startup.
+glide-mq 0.14+ provides AI orchestration primitives - token/cost tracking, real-time streaming, human-in-the-loop suspend/signal, model failover chains, budget caps, dual-axis rate limiting, and vector search. This plugin exposes them as REST/SSE endpoints:
 
-## Endpoints
+| Method | Path | Description |
+|--------|------|-------------|
+| `GET` | `/{name}/flows/{id}/usage` | Aggregated token/cost usage for a flow |
+| `GET` | `/{name}/flows/{id}/budget` | Budget status and remaining limits for a flow |
+| `GET` | `/{name}/jobs/{id}/stream` | SSE stream of a job's output chunks |
 
-| Method | Route | Description |
-|--------|-------|-------------|
-| POST | `/{name}/jobs` | Add a job to a queue |
-| POST | `/{name}/jobs/wait` | Add a job and wait for result |
-| GET | `/{name}/jobs` | List jobs by state |
-| GET | `/{name}/jobs/{id}` | Get a single job |
-| POST | `/{name}/jobs/{id}/priority` | Change job priority |
-| POST | `/{name}/jobs/{id}/delay` | Change job delay |
-| POST | `/{name}/jobs/{id}/promote` | Promote a delayed job |
-| GET | `/{name}/counts` | Get job counts by state |
-| GET | `/{name}/metrics` | Get completed or failed metrics |
-| POST | `/{name}/pause` | Pause a queue |
-| POST | `/{name}/resume` | Resume a paused queue |
-| POST | `/{name}/drain` | Drain all waiting jobs |
-| POST | `/{name}/retry` | Retry failed jobs |
-| DELETE | `/{name}/clean` | Clean old completed or failed jobs |
-| GET | `/{name}/workers` | List active workers |
-| POST | `/{name}/produce` | Add a job via Producer |
-| GET | `/{name}/schedulers` | List all schedulers |
-| GET | `/{name}/schedulers/{schedulerName}` | Get a single scheduler |
-| PUT | `/{name}/schedulers/{schedulerName}` | Upsert a scheduler |
-| DELETE | `/{name}/schedulers/{schedulerName}` | Remove a scheduler |
-| GET | `/{name}/events` | SSE event stream |
+Job serialization includes AI fields when present: `usage`, `signals`, `budgetKey`, `fallbackIndex`, `tpmTokens`. SSE events include `usage`, `suspended`, and `budget-exceeded` event types.
 
-## Features
+All AI features are also accessible programmatically via the `server.glidemq` registry. See the [glide-mq docs](https://github.com/avifenesh/glide-mq) for details.
 
-- **SSE event streaming** -- subscribe to `completed`, `failed`, `progress`, `active`, `waiting`, `stalled`, and `heartbeat` events on any queue via `GET /{name}/events`. Uses `PassThrough` streams with shared `QueueEvents` instances (ref-counted per queue).
-- **Lightweight producers** -- configure `producers` for serverless or edge environments that only need to enqueue jobs. The `POST /{name}/produce` endpoint returns a job ID without requiring a worker.
-- **Scheduler CRUD** -- create, read, update, and delete repeatable jobs through four endpoints. Supports cron patterns, fixed intervals, and `repeatAfterComplete` mode.
-- **Testing without Valkey** -- `createTestApp` from `@glidemq/hapi/testing` spins up an in-memory server backed by `TestQueue` and `TestWorker`. Use `server.inject()` for assertions with no external dependencies.
-- **Joi validation** -- all request bodies, query parameters, and plugin options are validated with Joi schemas and structured error messages.
-- **Queue access control** -- pass `allowedQueues` or `allowedProducers` arrays in `GlideMQRoutesOptions` to restrict which queues the API exposes. Requests to unlisted queues return 404.
-- **Route prefix** -- set `prefix` in `GlideMQRoutesOptions` to mount all 21 endpoints under a path like `/api/queues`.
-- **Automatic cleanup** -- the `onPostStop` lifecycle hook closes workers first (to drain in-progress jobs), then queues and producers, using `Promise.allSettled` for reliability.
-
 ## Configuration
@@ -108,25 +77,22 @@
   producers?: Record<string, ProducerConfig>;
-  prefix?: string;       // Key prefix for Valkey keys (default: 'glide')
-  testing?: boolean;     // Use TestQueue/TestWorker, no Valkey needed
-  serializer?: Serializer;
+  prefix?: string;    // Valkey key prefix (default: "glide")
+  testing?: boolean;  // In-memory mode, no Valkey needed
+  routes?: boolean | GlideMQRoutesOptions; // Mount REST + SSE endpoints
 }
+```
 
-interface QueueConfig {
-  processor?: (job: Job) => Promise<any>; // Omit for producer-only queues
-  concurrency?: number;                   // Default: 1
-  workerOpts?: Record<string, unknown>;
-}
+Route access control via `GlideMQRoutesOptions`:
 
-interface ProducerConfig {
-  compression?: "none" | "gzip";
-  serializer?: Serializer;
-}
-```
-
 ```ts
-interface GlideMQRoutesOptions {
-  queues?: string[];     // Restrict API to these queue names
-  producers?: string[];  // Restrict produce API to these producer names
-  prefix?: string;       // Route path prefix (e.g. '/api/queues')
-}
+await server.register({
+  plugin: glideMQPlugin,
+  options: {
+    connection: { addresses: [{ host: "localhost", port: 6379 }] },
+    queues: { emails: { processor: async (job) => ({ sent: true }) } },
+    routes: {
+      queues: ["emails"],    // restrict to specific queues
+      producers: ["emails"], // restrict to specific producers
+    },
+  },
+});
 ```
@@ -148,3 +114,3 @@
 });
-expect(res.statusCode).toBe(201);
+// res.statusCode === 201
 
@@ -154,39 +120,17 @@ await server.stop();
 
-## Direct registry access
-
-```ts
-server.route({
-  method: "GET",
-  path: "/pending-count",
-  handler: async (request, h) => {
-    const { queue } = request.server.glidemq.get("emails");
-    const counts = await queue.getJobCounts();
-    return h.response({ waiting: counts.waiting });
-  },
-});
-```
-
 ## Limitations
 
-- Requires a running Valkey or Redis instance for production use. Testing mode uses in-memory stubs only.
-- No built-in authentication or authorization. Add Hapi auth strategies or gateway-level controls separately.
-- `addAndWait` (the `POST /{name}/jobs/wait` endpoint) is not available in testing mode because `TestQueue` does not support it.
-- Producers are not supported in testing mode. Use queue-based endpoints for test assertions.
+- No built-in authentication. Add Hapi auth strategies or gateway-level controls separately.
+- `addAndWait` (`POST /{name}/jobs/wait`) is not available in testing mode.
+- Producers are not supported in testing mode.
 
-## Ecosystem
+## Links
 
-| Package | Description |
-|---------|-------------|
-| [glide-mq](https://github.com/avifenesh/glide-mq) | Core queue library |
-| [@glidemq/hono](https://github.com/avifenesh/glidemq-hono) | Hono REST + SSE middleware |
-| [@glidemq/fastify](https://github.com/avifenesh/glidemq-fastify) | Fastify REST + SSE plugin |
-| [@glidemq/nestjs](https://github.com/avifenesh/glidemq-nestjs) | NestJS module with decorators |
-| [@glidemq/dashboard](https://github.com/avifenesh/glidemq-dashboard) | Web UI for queue monitoring |
+- [glide-mq](https://github.com/avifenesh/glide-mq) - core library
+- [Full documentation](https://avifenesh.github.io/glide-mq.dev/integrations/hapi)
+- [Issues](https://github.com/avifenesh/glidemq-hapi/issues)
+- [@glidemq/hono](https://github.com/avifenesh/glidemq-hono) | [@glidemq/fastify](https://github.com/avifenesh/glidemq-fastify) | [@glidemq/nestjs](https://github.com/avifenesh/glidemq-nestjs) | [@glidemq/dashboard](https://github.com/avifenesh/glidemq-dashboard)
 
-## Contributing
-
-Issues and pull requests are welcome at [github.com/avifenesh/glidemq-hapi](https://github.com/avifenesh/glidemq-hapi). Run `npm test` before submitting. See [CHANGELOG.md](./CHANGELOG.md) for release history.
-
 ## License
 
-Apache-2.0
+[Apache-2.0](./LICENSE)

Fixed alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

115664

6.67%

Lines of code

1334

12.1%

Number of medium supply chain risk alerts

0

-100%

Worsened metrics

Number of lines in readme file

130

-30.11%

No dependency changes