{"version":3,"sources":["../src/admin/user.ts","../src/shared/attributes.ts","../src/utils/console.ts","../src/shared/tajriba_connection.ts","../src/utils/object.ts","../src/admin/attributes.ts","../src/admin/connection.ts","../src/admin/observables.ts","../src/admin/events.ts","../src/admin/participants.ts","../src/admin/promises.ts","../src/admin/scopes.ts","../src/shared/scopes.ts","../src/admin/subscriptions.ts","../src/admin/transitions.ts"],"sourcesContent":["export { Attribute } from \"../shared/attributes\";\nexport type { AttributeOptions } from \"../shared/attributes\";\nexport type { ScopeUpdate } from \"../shared/scopes\";\nexport { TajribaConnection } from \"../shared/tajriba_connection\";\nexport { Attributes } from \"./attributes\";\nexport { AdminConnection } from \"./connection\";\nexport { EventContext, ListenersCollector, TajribaEvent } from \"./events\";\nexport type { Subscriber } from \"./events\";\nexport { participantsSub } from \"./participants\";\nexport type { Participant } from \"./participants\";\nexport { Scope, Scopes } from \"./scopes\";\nexport { Subscriptions } from \"./subscriptions\";\nexport type { ScopeSubscriptionInput, Subs } from \"./subscriptions\";\nexport { transitionsSub } from \"./transitions\";\nexport type { Transition } from \"./transitions\";\n","import { SetAttributeInput } from \"@empirica/tajriba\";\nimport { BehaviorSubject, Observable } from \"rxjs\";\nimport { error, trace } from \"../utils/console\";\nimport { JsonValue } from \"../utils/json\";\n\nexport interface AttributeChange {\n /** deleted is true with the attribute was deleted. */\n deleted?: boolean;\n /** deletedAt is the time when the Attribute was deleted. int64 Date + Time\n * value given in Epoch with ns precision */\n deletedAt?: number;\n /** createdAt is the time the Attribute was created. int64 Date + Time\n * value given in Epoch with ns precision */\n createdAt?: string;\n /** id is the identifier for the Attribute. */\n id: string;\n /** index is the index of the attribute if the value is a vector. */\n index?: number | null;\n /** isNew is true if the Attribute was just created. */\n isNew?: boolean;\n /** key is the attribute key being updated. */\n key: string;\n /** nodeID is the identifier for the Attribute's Node. */\n nodeID?: string;\n /** node is the Attribute's Node. */\n node?: {\n __typename: \"Scope\";\n id: string;\n kind?: string;\n name?: string;\n };\n /** value is the value of the updated attribute. */\n val?: string | null;\n /** vector indicates whether the value is a vector. */\n vector: boolean;\n /** version is the version number of this Attribute, starting at 1. */\n version: number;\n}\n\nexport interface AttributeUpdate {\n attribute: AttributeChange;\n removed: boolean;\n}\n\nexport class Attributes {\n protected attrs = new Map>();\n protected updates = new Map>();\n\n constructor(\n attributesObs: Observable,\n donesObs: Observable,\n readonly setAttributes: (input: SetAttributeInput[]) => Promise\n ) {\n attributesObs.subscribe({\n next: ({ attribute, removed }) => {\n this.update(attribute, removed);\n },\n });\n\n donesObs.subscribe({\n next: (scopeIDs) => {\n this.next(scopeIDs);\n },\n });\n }\n\n attribute(scopeID: string, key: string): Attribute {\n let scopeMap = this.attrs.get(scopeID);\n if (!scopeMap) {\n scopeMap = new Map();\n this.attrs.set(scopeID, scopeMap);\n }\n\n let attr = scopeMap.get(key);\n if (!attr) {\n attr = new Attribute(this.setAttributes, scopeID, key);\n scopeMap.set(key, attr);\n }\n\n return attr;\n }\n\n attributes(scopeID: string): Attribute[] {\n let scopeMap = this.attrs.get(scopeID);\n if (!scopeMap) {\n scopeMap = new Map();\n this.attrs.set(scopeID, scopeMap);\n }\n\n return Array.from(scopeMap.values());\n }\n\n attributePeek(scopeID: string, key: string): Attribute | undefined {\n let scopeUpdateMap = this.updates.get(scopeID);\n if (scopeUpdateMap) {\n const updated = scopeUpdateMap.get(key);\n if (updated) {\n if (typeof updated === \"boolean\") {\n return;\n } else {\n if (!updated.val) {\n return;\n } else {\n const attr = new Attribute(this.setAttributes, scopeID, key);\n attr._update(updated);\n return attr;\n }\n }\n }\n }\n\n let scopeMap = this.attrs.get(scopeID);\n if (!scopeMap) {\n return;\n }\n\n let attr = scopeMap.get(key);\n if (!attr) {\n return;\n }\n\n if (attr.value === undefined) {\n return;\n }\n\n return attr;\n }\n\n nextAttributeValue(scopeID: string, key: string): JsonValue | undefined {\n const attr = this.attributePeek(scopeID, key);\n if (!attr) {\n return;\n }\n\n return attr.value;\n }\n\n private update(attr: AttributeChange, removed: boolean) {\n let nodeID = attr.nodeID;\n if (!nodeID) {\n if (!attr.node?.id) {\n error(`new attribute without node ID`);\n return;\n }\n nodeID = attr.node.id;\n }\n\n let scopeMap = this.updates.get(nodeID);\n if (!scopeMap) {\n scopeMap = new Map();\n this.updates.set(nodeID, scopeMap);\n }\n\n if (removed) {\n scopeMap.set(attr.key, true);\n } else {\n let key = attr.key;\n if (attr.index !== undefined && attr.index !== null) {\n key = `${key}[${attr.index}]`;\n }\n scopeMap.set(key, attr);\n }\n }\n\n scopeWasUpdated(scopeID?: string): boolean {\n if (!scopeID) {\n return false;\n }\n\n return this.updates.has(scopeID);\n }\n\n protected next(scopeIDs: string[]) {\n for (const [scopeID, attrs] of this.updates) {\n if (!scopeIDs.includes(scopeID)) {\n continue;\n }\n\n let scopeMap = this.attrs.get(scopeID);\n\n if (!scopeMap) {\n scopeMap = new Map();\n this.attrs.set(scopeID, scopeMap);\n }\n\n for (const [key, attrOrDel] of attrs) {\n if (typeof attrOrDel === \"boolean\") {\n let attr = scopeMap.get(key);\n if (attr) {\n attr._update(undefined);\n }\n } else {\n let attr = scopeMap.get(attrOrDel.key);\n if (!attr) {\n attr = new Attribute(this.setAttributes, scopeID, attrOrDel.key);\n scopeMap.set(attrOrDel.key, attr);\n }\n\n attr._update(attrOrDel);\n }\n }\n }\n\n for (const scopeID of scopeIDs) {\n this.updates.delete(scopeID);\n }\n }\n}\n\nexport interface AttributeOptions {\n /**\n * Private indicates the attribute will not be visible to other Participants.\n */\n private: boolean;\n /**\n * Protected indicates the attribute will not be updatable by other\n * Participants.\n */\n protected: boolean;\n /** Immutable creates an Attribute that cannot be updated. */\n immutable: boolean;\n /** ephemeral indicates the Attribute should not be persisted. Ephemeral\n * Attributes are not stored in the database and are only synced to the\n * connected clients. An ephemeral Attribute cannot become non-ephemeral and\n * vice versa. */\n ephemeral: boolean;\n /**\n * Index, only used if the Attribute is a vector, indicates which index to\n * update the value at.\n */\n index: number | null;\n /**\n * Append, only used if the Attribute is a vector, indicates to append the\n * attribute to the vector.\n */\n append: boolean | null;\n}\n\nexport class Attribute {\n private attr?: AttributeChange;\n private attrs?: Attribute[];\n\n private val = new BehaviorSubject(undefined);\n private serVal?: string;\n\n constructor(\n private setAttributes: (input: SetAttributeInput[]) => Promise,\n readonly scopeID: string,\n readonly key: string\n ) {}\n\n get id() {\n return this.attr?.id;\n }\n\n get createdAt() {\n return this.attr ? new Date(this.attr!.createdAt!) : null;\n }\n\n get obs(): Observable {\n return this.val;\n }\n\n get value() {\n return this.val.getValue();\n }\n\n get nodeID() {\n return this.scopeID;\n }\n\n // items returns the attribute changes for the current attribute, if it is a\n // vector. Otherwise it returns null;\n get items() {\n if (!this.attrs) {\n return null;\n }\n\n return this.attrs;\n }\n\n set(value: JsonValue, ao?: Partial) {\n const attrProps = this._prepSet(value, ao);\n if (!attrProps) {\n return;\n }\n\n this.setAttributes([attrProps]);\n trace(`SET ${this.key} = ${value} (${this.scopeID})`);\n }\n\n _prepSet(\n value: JsonValue,\n ao?: Partial,\n item?: boolean\n ): SetAttributeInput | undefined {\n if (ao?.append !== undefined && ao!.index !== undefined) {\n error(`cannot set both append and index`);\n\n throw new Error(`cannot set both append and index`);\n }\n\n const serVal = JSON.stringify(value);\n\n if (!item && (ao?.index !== undefined || ao?.append)) {\n let index = ao!.index || 0;\n if (ao?.append) {\n index = this.attrs?.length || 0;\n }\n\n if (!this.attrs) {\n this.attrs = [];\n }\n\n // if (index + 1 > (this.attrs?.length || 0)) {\n // this.attrs.length = index! + 1;\n // }\n\n if (!this.attrs[index]) {\n this.attrs[index] = new Attribute(\n this.setAttributes,\n this.scopeID,\n this.key\n );\n } else {\n const existing = this.attrs[index];\n if (existing && existing.serVal === serVal) {\n return;\n }\n }\n\n this.attrs![index]!._prepSet(value, ao, true);\n const v = this._recalcVectorVal();\n this.val.next(v);\n } else {\n if (this.serVal === serVal) {\n return;\n }\n\n this.val.next(value);\n }\n\n this.serVal = serVal;\n\n const attrProps: SetAttributeInput = {\n key: this.key,\n nodeID: this.scopeID,\n val: serVal,\n };\n\n if (ao) {\n // TODO Fix this. Should check if compatible with existing attribute and\n // only set fields set on ao.\n attrProps.private = ao.private;\n attrProps.protected = ao.protected;\n attrProps.immutable = ao.immutable;\n attrProps.ephemeral = ao.ephemeral;\n attrProps.append = ao.append;\n attrProps.index = ao.index;\n }\n\n return attrProps;\n }\n\n private _recalcVectorVal(): JsonValue {\n return this.attrs!.map((a) =>\n !a || a.val == undefined ? null : a.value || null\n );\n }\n\n // internal only\n _update(attr?: AttributeChange, item?: boolean) {\n if (attr && this.attr && this.attr.id === attr.id) {\n return;\n }\n\n if (attr && attr.vector && !item) {\n // TODO check if is vector\n\n if (attr.index === undefined) {\n error(`vector attribute missing index`);\n return;\n }\n\n if (this.attrs == undefined) {\n this.attrs = [];\n }\n\n while (this.attrs.length < attr.index! + 1) {\n const newAttr = new Attribute(\n this.setAttributes,\n this.scopeID,\n this.key\n );\n this.attrs.push(newAttr);\n }\n\n const newAttr = new Attribute(this.setAttributes, this.scopeID, this.key);\n newAttr._update(attr, true);\n this.attrs[attr.index!] = newAttr;\n const value = this._recalcVectorVal();\n this.val.next(value);\n\n return;\n }\n\n this.attr = attr;\n this.serVal = attr?.val === undefined || attr?.val === null ? \"\" : attr.val;\n let value: JsonValue | undefined = undefined;\n if (this.attr?.val) {\n value = JSON.parse(this.attr.val);\n }\n this.val.next(value);\n }\n}\n","/* c8 ignore start */\n\nconst isBrowser =\n typeof window !== \"undefined\" && typeof window.document !== \"undefined\";\n\nenum Color {\n Bold = 1,\n\n Black = 30,\n Red,\n Green,\n Yellow,\n Blue,\n Magenta,\n Cyan,\n White,\n\n DarkGray = 90,\n}\n\nexport type LogLine = { level: string; args: any[] };\nexport class LogsMock {\n public logs: LogLine[] = [];\n\n log(line: LogLine) {\n this.logs.push(line);\n }\n\n clear() {\n this.logs = [];\n }\n}\n\nlet logsMock: LogsMock | undefined;\nexport function captureLogs(cb: () => void): LogLine[] {\n const lm = mockLogging();\n cb();\n const ret = lm.logs;\n stopMockLogging();\n\n return ret;\n}\n\nexport async function captureLogsAsync(\n cb: () => Promise\n): Promise {\n const lm = mockLogging();\n await cb();\n const ret = lm.logs;\n stopMockLogging();\n\n return ret;\n}\n\nexport function mockLogging() {\n if (!logsMock) {\n logsMock = new LogsMock();\n }\n\n return logsMock;\n}\n\nexport function stopMockLogging() {\n logsMock = undefined;\n}\n\nconst colorHex = {\n [Color.Bold]: \"font-weight: bold\",\n [Color.Black]: \"color: #000000\",\n [Color.Red]: \"color: #cc0000\",\n [Color.Green]: \"color: #4e9a06\",\n [Color.Yellow]: \"color: #c4a000\",\n [Color.Blue]: \"color: #729fcf\",\n [Color.Magenta]: \"color: #75507b\",\n [Color.Cyan]: \"color: #06989a\",\n [Color.White]: \"color: #d3d7cf\",\n [Color.DarkGray]: \"color: #555753\",\n};\n\nexport const levels: { [key: string]: number } = {\n trace: 0,\n debug: 1,\n log: 2,\n info: 2,\n warn: 3,\n error: 4,\n};\n\nconst reversLevels: { [key: number]: string } = {};\nfor (const key in levels) {\n reversLevels[levels[key]!] = key;\n}\n\nlet currentLevel = 2;\n\nexport function setLogLevel(level: keyof typeof levels) {\n const lvl = levels[level];\n if (lvl === undefined) {\n return;\n }\n\n currentLevel = lvl;\n}\n\nfunction formatConsoleDate(date: Date, level: string[]) {\n var hour = date.getHours();\n var minutes = date.getMinutes();\n var seconds = date.getSeconds();\n var milliseconds = date.getMilliseconds();\n\n const str =\n (hour < 10 ? \"0\" + hour : hour) +\n \":\" +\n (minutes < 10 ? \"0\" + minutes : minutes) +\n \":\" +\n (seconds < 10 ? \"0\" + seconds : seconds) +\n \".\" +\n (\"00\" + milliseconds).slice(-3);\n\n if (isBrowser) {\n const ts = colorize(str, Color.DarkGray).concat(level);\n return [ts[0] + \" \" + level[0], ts[1], level[1]];\n }\n\n return colorize(str, Color.DarkGray).concat(level);\n}\n\nconst createLogger = (lvl: number, level: string[]) => {\n return (...args: any[]) => {\n if (lvl < currentLevel) {\n return;\n }\n\n if (logsMock) {\n logsMock.log({ level: reversLevels[lvl]!, args: args });\n\n return;\n }\n\n if (args.length === 1) {\n switch (typeof args[0]) {\n case \"string\":\n for (const line of args[0].split(\"\\n\")) {\n console.log(...formatConsoleDate(new Date(), level).concat(line));\n }\n return;\n\n case \"object\":\n if (args[0] instanceof Error) {\n const error = args[0] as Error;\n const prettyErr =\n error.name +\n \": \" +\n error.message.replace(new RegExp(`^${error.name}[: ]*`), \"\") +\n \"\\n\" +\n (error.stack || \"\")\n .split(\"\\n\")\n .map((line) => line.trim())\n .map((line) => {\n if (line.startsWith(error.name + \": \" + error.message))\n return null;\n\n if (line.startsWith(\"at\")) {\n return \" \" + line;\n }\n\n return line;\n })\n .filter(Boolean)\n .join(\"\\n\");\n\n for (const line of prettyErr.split(\"\\n\")) {\n console.log(...formatConsoleDate(new Date(), level).concat(line));\n }\n\n return;\n }\n }\n }\n\n console.log(...formatConsoleDate(new Date(), level).concat(args));\n };\n};\n\nfunction colorize(s: string, ...cc: Color[]): string[] {\n if (isBrowser) {\n const attr = [];\n for (const c of cc) {\n attr.push(colorHex[c]);\n }\n\n return [`%c${s}`, attr.join(\"; \")];\n }\n\n let out = \"\";\n for (const c of cc) {\n out += `\\x1b[${c}m`;\n }\n out += `${s}\\x1b[0m`;\n\n return [out];\n}\n\nexport const trace = createLogger(0, colorize(\"TRC\", Color.Magenta));\nexport const debug = createLogger(1, colorize(\"DBG\", Color.Yellow));\nexport const log = createLogger(2, colorize(\"LOG\", Color.Yellow));\nexport const info = createLogger(2, colorize(\"INF\", Color.Green));\nexport const warn = createLogger(3, colorize(\"WRN\", Color.Cyan));\nexport const error = createLogger(4, colorize(\"ERR\", Color.Red, Color.Bold));\n\n// export {\n// trace,\n// debug,\n// log,\n// info,\n// warn,\n// error,\n// };\n\n// export function warn(...args: string[]) {}\n","import { ParticipantIdent, Tajriba } from \"@empirica/tajriba\";\nimport { BehaviorSubject } from \"rxjs\";\nimport { error } from \"../utils/console\";\nimport { bs } from \"../utils/object\";\n\nexport const ErrNotConnected = new Error(\"not connected\");\n\nexport class TajribaConnection {\n readonly tajriba: Tajriba;\n private _connected = bs(false);\n private _connecting: BehaviorSubject = bs(true);\n private _stopped = bs(false);\n\n constructor(private url: string) {\n this.tajriba = Tajriba.connect(this.url);\n this._connected.next(this.tajriba.connected);\n\n this.tajriba.on(\"connected\", () => {\n this._connected.next(true);\n this._connecting.next(false);\n });\n\n this.tajriba.on(\"disconnected\", () => {\n if (this._connected.getValue()) {\n this._connected.next(false);\n }\n if (!this._connecting.getValue()) {\n this._connecting.next(true);\n }\n });\n\n this.tajriba.on(\"error\", (err) => {\n error(\"connection error\", err);\n });\n }\n\n get connecting() {\n return this._connecting;\n }\n\n get connected() {\n return this._connected;\n }\n\n get stopped() {\n return this._stopped;\n }\n\n async sessionParticipant(token: string, pident: ParticipantIdent) {\n if (!this._connected.getValue()) {\n throw ErrNotConnected;\n }\n\n return await this.tajriba.sessionParticipant(token, pident);\n }\n\n async sessionAdmin(token: string) {\n if (!this._connected.getValue()) {\n throw ErrNotConnected;\n }\n\n return await this.tajriba.sessionAdmin(token);\n }\n\n stop() {\n if (this._stopped.getValue()) {\n return;\n }\n\n if (this.tajriba) {\n this.tajriba.removeAllListeners(\"connected\");\n this.tajriba.removeAllListeners(\"disconnected\");\n this.tajriba.stop();\n }\n\n this._connecting.next(false);\n this._connected.next(false);\n this._stopped.next(true);\n }\n}\n","/* c8 ignore start */\n\nimport { BehaviorSubject } from \"rxjs\";\n\nexport function bs(init: T) {\n return new BehaviorSubject(init);\n}\n\nexport function bsu(init: T | undefined = undefined) {\n return new BehaviorSubject(init);\n}\n\nexport function deepEqual(obj1: any, obj2: any) {\n if (obj1 === obj2)\n // it's just the same object. No need to compare.\n return true;\n\n if (isPrimitive(obj1) && isPrimitive(obj2))\n // compare primitives\n return obj1 === obj2;\n\n if (Object.keys(obj1).length !== Object.keys(obj2).length) return false;\n\n // compare objects with same number of keys\n for (let key in obj1) {\n if (!(key in obj2)) return false; //other object doesn't have this prop\n if (!deepEqual(obj1[key], obj2[key])) return false;\n }\n\n return true;\n}\n\n//check if value is primitive\nfunction isPrimitive(obj: any) {\n return obj !== Object(obj);\n}\n","import { Observable, ReplaySubject } from \"rxjs\";\nimport {\n Attribute,\n AttributeChange,\n Attributes as SharedAttributes,\n} from \"../shared/attributes\";\nimport { warn } from \"../utils/console\";\n\nexport type AttributeMsg = {\n attribute?: Attribute;\n done: boolean;\n};\n\nexport class Attributes extends SharedAttributes {\n protected attrsByKind = new Map<\n string,\n Map>\n >();\n private attribSubs = new Map<\n string,\n Map>\n >();\n\n subscribeAttribute(kind: string, key: string): Observable {\n if (!this.attribSubs.has(kind)) {\n this.attribSubs.set(kind, new Map>());\n }\n\n const keyMap = this.attribSubs.get(kind)!;\n let sub = keyMap.get(key);\n if (!sub) {\n sub = new ReplaySubject();\n keyMap.set(key, sub);\n\n const attrByScopeID = this.attrsByKind.get(kind);\n\n setTimeout(() => {\n if (!attrByScopeID) {\n sub!.next({ done: true });\n return;\n }\n\n let attrs = [];\n for (const [_, attrByKey] of attrByScopeID?.entries()) {\n for (const [_, attr] of attrByKey) {\n if (attr.key === key) {\n attrs.push(attr);\n }\n }\n }\n\n if (attrs.length > 0) {\n let count = 0;\n for (const attr of attrs) {\n count++;\n sub!.next({ attribute: attr, done: count == attrs.length });\n }\n } else {\n sub!.next({ done: true });\n }\n }, 0);\n }\n\n return sub!;\n }\n\n protected next(scopeIDs: string[]) {\n const byKind = new Map();\n\n for (const [scopeID, attrs] of this.updates) {\n if (!scopeIDs.includes(scopeID)) {\n continue;\n }\n\n for (const [_, attr] of attrs) {\n if (typeof attr === \"boolean\") {\n continue;\n }\n\n const kind = attr.node?.kind;\n if (kind) {\n let kindAttrs = byKind.get(kind);\n if (!kindAttrs) {\n kindAttrs = [];\n byKind.set(kind, kindAttrs);\n }\n\n kindAttrs.push(attr);\n }\n }\n }\n\n const updates: [string, string, AttributeChange][] = [];\n for (const [kind, attrs] of byKind) {\n for (const attr of attrs) {\n // This is very difficult to reproduce in tests since this.updates\n // cannot contain an AttributeChange that would satisfy this.\n /* c8 ignore next 4 */\n if (!attr.nodeID && !attr.node?.id) {\n warn(`found attribute change without node ID`);\n continue;\n }\n\n if (!scopeIDs.includes(attr.nodeID || attr.node!.id)) {\n continue;\n }\n\n updates.push([kind, attr.key, attr]);\n }\n }\n\n super.next(scopeIDs);\n\n for (const [kind, key, attrChange] of updates) {\n // Forcing nodeID because we already tested it above.\n const nodeID = attrChange.nodeID || attrChange.node!.id;\n\n if (!scopeIDs.includes(nodeID)) {\n continue;\n }\n\n const attr = this.attrs.get(nodeID)!.get(key)!;\n const sub = this.attribSubs.get(kind)?.get(key);\n if (sub) {\n sub.next({ attribute: attr, done: true });\n } else {\n let kAttrs = this.attrsByKind.get(kind);\n if (!kAttrs) {\n kAttrs = new Map>();\n this.attrsByKind.set(kind, kAttrs);\n }\n\n let kkAttrs = kAttrs!.get(nodeID);\n if (!kkAttrs) {\n kkAttrs = new Map();\n kAttrs!.set(nodeID, kkAttrs);\n }\n\n kkAttrs.set(key, attr);\n }\n }\n }\n}\n","import { TajribaAdmin } from \"@empirica/tajriba\";\nimport { BehaviorSubject, merge, SubscriptionLike } from \"rxjs\";\nimport {\n ErrNotConnected,\n TajribaConnection,\n} from \"../shared/tajriba_connection\";\nimport { bs, bsu } from \"../utils/object\";\nimport { subscribeAsync } from \"./observables\";\nimport { error } from \"../utils/console\";\n\nexport class AdminConnection {\n private _tajriba = bsu();\n private _connected = bs(false);\n private _connecting = bs(false);\n private _stopped = bs(false);\n private sub: SubscriptionLike;\n\n constructor(\n taj: TajribaConnection,\n tokens: BehaviorSubject,\n private resetToken: () => void\n ) {\n let token: string | null | undefined;\n let connected = false;\n\n this.sub = subscribeAsync(\n merge(taj.connected, tokens),\n async (tokenOrConnected) => {\n if (typeof tokenOrConnected === \"boolean\") {\n connected = tokenOrConnected;\n } else {\n token = tokenOrConnected;\n }\n\n if (!token || !connected) {\n return;\n }\n\n if (this._connected.getValue()) {\n return;\n }\n\n this._connecting.next(true);\n\n try {\n const tajAdmin = await taj.sessionAdmin(token);\n\n this._tajriba.next(tajAdmin);\n this._connected.next(true);\n\n tajAdmin.on(\"connected\", () => {\n if (!this._connected.getValue()) {\n this._connected.next(true);\n }\n });\n tajAdmin.on(\"error\", (err) => {\n error(\"connection error\", err);\n });\n tajAdmin.on(\"disconnected\", () => {\n if (this._connected.getValue()) {\n this._connected.next(false);\n }\n });\n tajAdmin.on(\"accessDenied\", () => {\n if (this._connected.getValue()) {\n this._connected.next(false);\n }\n this.resetToken();\n });\n } catch (error) {\n if (error !== ErrNotConnected) {\n this.resetToken();\n }\n }\n\n this._connecting.next(false);\n }\n );\n }\n\n stop() {\n if (this._stopped.getValue()) {\n return;\n }\n\n const taj = this._tajriba.getValue();\n if (taj) {\n taj.removeAllListeners(\"connected\");\n taj.removeAllListeners(\"disconnected\");\n taj.stop();\n this._tajriba.next(undefined);\n }\n\n this.sub.unsubscribe();\n\n this._connecting.next(false);\n this._connected.next(false);\n this._stopped.next(true);\n }\n\n get connecting() {\n return this._connecting;\n }\n\n get connected() {\n return this._connected;\n }\n\n get stopped() {\n return this._stopped;\n }\n\n get admin() {\n return this._tajriba;\n }\n}\n","import { E_CANCELED, Mutex } from \"async-mutex\";\nimport { Observable, Subject, concatMap, takeUntil } from \"rxjs\";\nimport { warn } from \"../utils/console\";\n\nexport async function awaitObsValue(\n obs: Observable,\n value: T\n): Promise {\n let res: (value: T) => void;\n const prom = new Promise((r) => {\n res = r;\n });\n\n const unsub = obs.subscribe((val) => {\n if (val === value) {\n res(val);\n }\n });\n\n const val = await prom;\n unsub.unsubscribe();\n\n return val;\n}\n\nexport async function awaitObsValueExist(obs: Observable): Promise {\n let res: (value: T) => void;\n const prom = new Promise((r) => {\n res = r;\n });\n\n const unsub = obs.subscribe((val) => {\n if (val) {\n res(val);\n }\n });\n\n const val = await prom;\n unsub.unsubscribe();\n\n return val;\n}\n\nexport async function awaitObsValueChange(obs: Observable): Promise {\n let res: (value: T) => void;\n const prom = new Promise((r) => {\n res = r;\n });\n\n let once = false;\n let v: T;\n const unsub = obs.subscribe((val) => {\n if (once && val !== v) {\n res(val);\n }\n once = true;\n v = val;\n });\n\n const val = await prom;\n unsub.unsubscribe();\n\n return val;\n}\n\n// Subscribe to an observable and use the lock for sequential execution of async\n// functions.\nexport function lockedAsyncSubscribe(\n mutex: Mutex,\n obs: Observable,\n fn: (val: T) => Promise\n) {\n return obs.subscribe({\n next: async (val) => {\n try {\n const release = await mutex.acquire();\n try {\n await fn(val);\n } catch (err) {\n console.error(\"error in async observable subscription\");\n console.error(err);\n } finally {\n release();\n }\n } catch (err) {\n if (err !== E_CANCELED) {\n console.error(\n \"error acquiring lock in async observable subscription\"\n );\n console.error(err);\n }\n }\n },\n });\n}\n\n// This does not behave correctly with a ReplaySubject\nexport function subscribeAsync(\n obs: Observable,\n fn: (val: T) => Promise\n) {\n const cancel = new Subject();\n obs.pipe(concatMap(fn), takeUntil(cancel)).subscribe();\n return {\n closed: false,\n unsubscribe() {\n if (this.closed) {\n warn(\"closing a closed async observable subscription\");\n return;\n }\n this.closed = true;\n cancel.next();\n cancel.unsubscribe();\n },\n };\n}\n\nexport interface AsyncObserver {\n next: (value: T) => void;\n error: (err: any) => void;\n complete: () => void;\n}\n\nexport interface Unsubscribable {\n unsubscribe(): void;\n}\n\nexport interface AsyncSubscribable {\n subscribe(observer: Partial>): Promise;\n}\n\n// A ReplaySubject that supports async subscribers\nexport class AsyncReplaySubject {\n private values: T[] = [];\n private subscribers: ((val: T) => Promise)[] = [];\n\n async next(value: T) {\n this.values.push(value);\n for (const sub of this.subscribers) {\n await sub(value);\n }\n }\n\n async subscribe({ next }: { next: (val: T) => Promise }) {\n this.subscribers.push(next);\n for (const v of this.values) {\n await next(v);\n }\n\n let closed = false;\n return {\n get closed() {\n return closed;\n },\n unsubscribe: () => {\n if (closed) {\n warn(\"closing a closed async observable subscription\");\n return;\n }\n\n closed = true;\n this.subscribers = this.subscribers.filter((s) => s !== next);\n },\n };\n }\n}\n\n// A Subject that supports async subscribers\nexport class AsyncSubject {\n private subscribers: ((val: T) => Promise)[] = [];\n\n constructor(private value: T) {}\n\n async next(value: T) {\n for (const sub of this.subscribers) {\n await sub(value);\n }\n }\n\n async subscribe({ next }: { next: (val: T) => Promise }) {\n this.subscribers.push(next);\n await next(this.value);\n\n let closed = false;\n return {\n get closed() {\n return closed;\n },\n unsubscribe: () => {\n if (closed) {\n warn(\"closing a closed async observable subscription\");\n return;\n }\n\n closed = true;\n this.subscribers = this.subscribers.filter((s) => s !== next);\n },\n };\n }\n}\n","import {\n AddGroupInput,\n AddScopeInput,\n AddStepInput,\n LinkInput,\n TransitionInput,\n} from \"@empirica/tajriba\";\nimport { Attribute } from \"../shared/attributes\";\nimport { ScopeConstructor } from \"../shared/scopes\";\nimport { Finalizer, TajribaAdminAccess } from \"./context\";\nimport { Scope, Scopes } from \"./scopes\";\nimport { ScopeSubscriptionInput } from \"./subscriptions\";\n\nexport type Subscriber<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> = (subs: ListenersCollector) => void;\n\nexport enum TajribaEvent {\n TransitionAdd = \"TRANSITION_ADD\",\n ParticipantConnect = \"PARTICIPANT_CONNECT\",\n ParticipantDisconnect = \"PARTICIPANT_DISCONNECT\",\n}\n\nexport enum ListernerPlacement {\n Before,\n None, // Not before or after\n After,\n}\n\nconst placementString = new Map();\nplacementString.set(ListernerPlacement.Before, \"before\");\nplacementString.set(ListernerPlacement.None, \"on\");\nplacementString.set(ListernerPlacement.After, \"after\");\n\nexport function PlacementString(placement: ListernerPlacement): string {\n return placementString.get(placement)!;\n}\n\nexport type SimpleListener<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> = {\n placement: ListernerPlacement;\n callback: (ctx: EventContext) => void;\n};\n\nexport type TajEventListener = {\n placement: ListernerPlacement;\n event: TajribaEvent;\n callback: Callback;\n};\n\nexport type KindEventListener = {\n placement: ListernerPlacement;\n kind: string;\n callback: Callback;\n};\n\nexport type AttributeEventListener = {\n placement: ListernerPlacement;\n kind: string;\n key: string;\n callback: Callback;\n};\n\nexport type EvtCtxCallback<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> = (ctx: EventContext, props: any) => void;\n\nfunction unique<\n Context,\n Kinds extends { [key: string]: ScopeConstructor },\n K extends keyof Kinds\n>(\n kind: K,\n placement: ListernerPlacement,\n callback: EvtCtxCallback\n) {\n return async (ctx: EventContext, props: any) => {\n const attr = props.attribute as Attribute;\n const scope = props[kind] as Scope;\n if (\n !attr.id ||\n scope.get(`ran-${PlacementString(placement)}-${props.attrId}`)\n ) {\n return;\n }\n\n await callback(ctx, props);\n\n scope.set(`ran-${PlacementString(placement)}-${props.attrId}`, true);\n };\n}\n\n// Collects event listeners.\nexport class ListenersCollector<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> {\n /** @internal */\n readonly starts: SimpleListener[] = [];\n /** @internal */\n readonly readys: SimpleListener[] = [];\n /** @internal */\n readonly tajEvents: TajEventListener>[] = [];\n /** @internal */\n readonly kindListeners: KindEventListener>[] =\n [];\n /** @internal */\n readonly attributeListeners: AttributeEventListener<\n EvtCtxCallback\n >[] = [];\n\n /** @internal */\n private flusher: Flusher | undefined;\n\n /** @internal */\n setFlusher(flusher: Flusher) {\n this.flusher = flusher;\n }\n\n async flush(): Promise {\n if (!this.flusher) {\n return;\n }\n\n await this.flusher.flush();\n }\n\n flushAfter(cb: () => Promise): (() => Promise) | void {\n if (!this.flusher) {\n return;\n }\n\n return this.flusher.flushAfter(cb);\n }\n\n get unique() {\n return new ListenersCollectorProxy(this);\n }\n\n // start: first callback called.\n // ready: callback called when initial loading is finished.\n on(\n kind: \"start\" | \"ready\",\n callback: (ctx: EventContext) => void\n ): void;\n\n // Attach to Tajriba Hooks.\n on(event: TajribaEvent, callback: EvtCtxCallback): void;\n\n // Receive Scopes by Kind as they are fetched.\n on(\n kind: Kind,\n callback: EvtCtxCallback\n ): void;\n\n // Receive Scope attributes as they are fetched.\n on(\n kind: Kind,\n key: string,\n callback: EvtCtxCallback,\n uniqueCall?: boolean\n ): void;\n\n on(\n kindOrEvent: string,\n keyOrNodeIDOrEventOrCallback?:\n | string\n | TajribaEvent\n | EvtCtxCallback\n | ((ctx: EventContext) => void),\n callback?: EvtCtxCallback\n ): void {\n this.registerListerner(\n ListernerPlacement.None,\n kindOrEvent,\n keyOrNodeIDOrEventOrCallback,\n callback\n );\n }\n\n before(\n kindOrEvent: string,\n keyOrNodeIDOrEventOrCallback?:\n | string\n | TajribaEvent\n | EvtCtxCallback\n | ((ctx: EventContext) => void),\n callback?: EvtCtxCallback,\n uniqueCall?: boolean\n ): void {\n this.registerListerner(\n ListernerPlacement.Before,\n kindOrEvent,\n keyOrNodeIDOrEventOrCallback,\n callback,\n uniqueCall\n );\n }\n\n after(\n kindOrEvent: string,\n keyOrNodeIDOrEventOrCallback?:\n | string\n | TajribaEvent\n | EvtCtxCallback\n | ((ctx: EventContext) => void),\n callback?: EvtCtxCallback,\n uniqueCall?: boolean\n ): void {\n this.registerListerner(\n ListernerPlacement.After,\n kindOrEvent,\n keyOrNodeIDOrEventOrCallback,\n callback,\n uniqueCall\n );\n }\n\n protected registerListerner(\n placement: ListernerPlacement,\n kindOrEvent: string,\n keyOrNodeIDOrEventOrCallback?:\n | string\n | TajribaEvent\n | EvtCtxCallback\n | ((ctx: EventContext) => void),\n callback?: EvtCtxCallback,\n uniqueCall = false\n ): void {\n if (kindOrEvent === \"start\") {\n if (callback) {\n throw new Error(\"start event only accepts 2 arguments\");\n }\n\n if (typeof keyOrNodeIDOrEventOrCallback !== \"function\") {\n throw new Error(\"second argument expected to be a callback\");\n }\n\n this.starts.push({\n placement,\n callback: keyOrNodeIDOrEventOrCallback as (\n ctx: EventContext\n ) => void,\n });\n\n return;\n }\n\n if (kindOrEvent === \"ready\") {\n if (callback) {\n throw new Error(\"ready event only accepts 2 arguments\");\n }\n\n if (typeof keyOrNodeIDOrEventOrCallback !== \"function\") {\n throw new Error(\"second argument expected to be a callback\");\n }\n\n this.readys.push({\n placement,\n callback: keyOrNodeIDOrEventOrCallback as (\n ctx: EventContext\n ) => void,\n });\n\n return;\n }\n\n if (Object.values(TajribaEvent).includes(kindOrEvent as any)) {\n if (typeof keyOrNodeIDOrEventOrCallback !== \"function\") {\n throw new Error(\"second argument expected to be a callback\");\n }\n\n this.tajEvents.push({\n placement,\n event: kindOrEvent,\n callback: keyOrNodeIDOrEventOrCallback,\n });\n\n return;\n }\n\n if (typeof keyOrNodeIDOrEventOrCallback === \"function\") {\n this.kindListeners.push({\n placement,\n kind: kindOrEvent,\n callback: keyOrNodeIDOrEventOrCallback,\n });\n } else {\n if (typeof keyOrNodeIDOrEventOrCallback !== \"string\") {\n throw new Error(\"second argument expected to be an attribute key\");\n }\n if (typeof callback !== \"function\") {\n throw new Error(\"third argument expected to be a callback\");\n }\n\n if (uniqueCall) {\n callback = unique(kindOrEvent, placement, callback);\n }\n\n this.attributeListeners.push({\n placement,\n kind: kindOrEvent,\n key: keyOrNodeIDOrEventOrCallback,\n callback,\n });\n }\n }\n}\n\n// Collects event listeners.\nexport class ListenersCollectorProxy<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> extends ListenersCollector {\n constructor(private coll: ListenersCollector) {\n super();\n }\n\n protected registerListerner(\n placement: ListernerPlacement,\n kindOrEvent: string,\n keyOrNodeIDOrEventOrCallback?:\n | string\n | TajribaEvent\n | EvtCtxCallback\n | ((ctx: EventContext) => void),\n callback?: EvtCtxCallback\n ): void {\n if (\n kindOrEvent === \"start\" ||\n kindOrEvent === \"ready\" ||\n Object.values(TajribaEvent).includes(kindOrEvent as any) ||\n typeof keyOrNodeIDOrEventOrCallback === \"function\"\n ) {\n throw new Error(\"only attribute listeners can be unique\");\n }\n\n super.registerListerner(\n placement,\n kindOrEvent,\n keyOrNodeIDOrEventOrCallback,\n callback,\n true\n );\n\n while (true) {\n const listener = this.attributeListeners.pop();\n if (!listener) {\n break;\n }\n\n this.coll.attributeListeners.push(listener);\n }\n }\n}\n\n// Context passed to listerners on new event allowing to subscrive to more data\n// and access data.\nexport interface SubscriptionCollector {\n scopeSub: (...inputs: Partial[]) => void;\n participantsSub: () => void;\n transitionsSub: (stepID: string) => void;\n}\n\n// Context passed to listerners on new event allowing to subscrive to more data\n// and access data.\nexport class EventContext<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> {\n constructor(\n /** @internal */\n private subs: SubscriptionCollector,\n /** @internal */\n private taj: TajribaAdminAccess,\n /** @internal */\n private scopes: Scopes,\n /** @internal */\n private flusher: Flusher\n ) {}\n\n async flush(): Promise {\n await this.flusher.flush();\n }\n\n flushAfter(cb: () => Promise): (() => Promise) | void {\n return this.flusher.flushAfter(cb);\n }\n\n scopesByKind>(kind: keyof Kinds) {\n return this.scopes.byKind(kind) as Map;\n }\n\n scopesByKindID>(\n kind: keyof Kinds,\n id: string\n ) {\n return this.scopes.byKind(kind).get(id);\n }\n\n scopesByKindMatching>(\n kind: keyof Kinds,\n key: string,\n val: string\n ): T[] {\n const scopes = Array.from(this.scopes.byKind(kind).values());\n return scopes.filter((s) => s.get(key) === val) as T[];\n }\n\n scopeSub(...inputs: Partial[]) {\n for (const input of inputs) {\n this.subs.scopeSub(input);\n }\n }\n\n participantsSub() {\n this.subs.participantsSub();\n }\n\n transitionsSub(stepID: string) {\n this.subs.transitionsSub(stepID);\n }\n\n // c8 ignore: the TajribaAdminAccess proxy functions are tested elswhere\n /* c8 ignore next 3 */\n addScopes(input: AddScopeInput[]) {\n return this.taj.addScopes(input);\n }\n\n /* c8 ignore next 3 */\n addGroups(input: AddGroupInput[]) {\n return this.taj.addGroups(input);\n }\n\n /* c8 ignore next 3 */\n addLinks(input: LinkInput[]) {\n return this.taj.addLinks(input);\n }\n\n /* c8 ignore next 3 */\n addSteps(input: AddStepInput[]) {\n return this.taj.addSteps(input);\n }\n\n /* c8 ignore next 3 */\n addTransitions(input: TransitionInput[]) {\n return this.taj.addTransitions(input);\n }\n\n protected addFinalizer(cb: Finalizer) {\n this.taj.addFinalizer(cb);\n }\n\n /* c8 ignore next 3 */\n get globals() {\n return this.taj.globals;\n }\n}\n\nexport class Flusher {\n constructor(\n /** @internal */\n private postCallback: (() => Promise) | undefined\n ) {}\n\n async flush(): Promise {\n if (!this.postCallback) {\n return;\n }\n\n await this.postCallback();\n }\n\n flushAfter(cb: () => Promise): (() => Promise) | void {\n if (!this.postCallback) {\n cb();\n return;\n }\n\n return async () => {\n await cb();\n if (this.postCallback) {\n await this.postCallback();\n }\n };\n }\n}\n","import { EventType, TajribaAdmin } from \"@empirica/tajriba\";\nimport { Subject } from \"rxjs\";\nimport { error } from \"../utils/console\";\nimport { PromiseHandle, promiseHandle } from \"./promises\";\n\nexport interface Participant {\n id: string;\n identifier: string;\n}\n\nexport interface Connection {\n participant: Participant;\n connected: boolean;\n}\n\nexport interface ConnectionMsg {\n connection?: Connection;\n done: boolean;\n}\n\nexport async function participantsSub(\n taj: TajribaAdmin,\n connections: Subject,\n participants: Map\n) {\n let handle: PromiseHandle | undefined = promiseHandle();\n taj.onEvent({ eventTypes: [EventType.ParticipantConnected] }).subscribe({\n next({ node, done }) {\n if (!node) {\n if (done) {\n if (handle) {\n handle?.result();\n\n connections.next({ done: true });\n }\n\n return;\n }\n error(`received no participant on connected`);\n\n return;\n }\n\n if (node.__typename !== \"Participant\") {\n error(`received non-participant on connected`);\n\n return;\n }\n\n const part = {\n id: node.id,\n identifier: node.identifier,\n };\n\n participants.set(node.id, part);\n\n connections.next({\n connection: {\n participant: part,\n connected: true,\n },\n done,\n });\n\n if (handle && done) {\n handle.result();\n }\n },\n });\n\n taj.onEvent({ eventTypes: [EventType.ParticipantDisconnect] }).subscribe({\n next({ node }) {\n if (!node) {\n error(`received no participant on disconnect`);\n\n return;\n }\n\n if (node.__typename !== \"Participant\") {\n error(`received non-participant on disconnect`);\n\n return;\n }\n\n participants.delete(node.id);\n\n connections.next({\n connection: {\n participant: {\n id: node.id,\n identifier: node.identifier,\n },\n connected: false,\n },\n done: true,\n });\n },\n });\n\n await handle.promise;\n handle = undefined;\n}\n","export interface PromiseHandle {\n promise: Promise;\n result: (value: T) => void;\n}\n\nexport function promiseHandle(): PromiseHandle {\n let ret = {} as PromiseHandle;\n ret.promise = new Promise((r) => {\n ret.result = r;\n });\n\n return ret;\n}\n","import {\n AddGroupInput,\n AddScopeInput,\n AddStepInput,\n LinkInput,\n TransitionInput,\n} from \"@empirica/tajriba\";\nimport { Observable, ReplaySubject } from \"rxjs\";\nimport {\n Scope as SharedScope,\n ScopeConstructor,\n ScopeIdent,\n Scopes as SharedScopes,\n ScopeUpdate,\n} from \"../shared/scopes\";\nimport { Attributes } from \"./attributes\";\nimport { Finalizer, TajribaAdminAccess } from \"./context\";\n\nexport type ScopeMsg<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> = {\n scope?: Scope;\n done: boolean;\n};\n\nexport class Scopes<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> extends SharedScopes> {\n private kindSubs = new Map<\n keyof Kinds,\n ReplaySubject>\n >();\n\n constructor(\n scopesObs: Observable,\n donesObs: Observable,\n ctx: Context,\n kinds: Kinds,\n attributes: Attributes,\n readonly taj: TajribaAdminAccess\n ) {\n super(scopesObs, donesObs, ctx, kinds, attributes);\n }\n\n /** @internal */\n subscribeKind(kind: keyof Kinds): Observable> {\n let sub = this.kindSubs.get(kind);\n if (!sub) {\n sub = new ReplaySubject>();\n this.kindSubs.set(kind, sub);\n\n const scopes = this.byKind(kind);\n\n setTimeout(() => {\n if (scopes.size === 0) {\n sub!.next({ done: true });\n\n return;\n }\n\n let count = 0;\n for (const [_, scope] of scopes) {\n count++;\n sub!.next({ scope, done: scopes.size === count });\n }\n }, 0);\n }\n\n return sub!;\n }\n\n protected next(scopeIDs: string[]) {\n for (const [_, scopeReplaySubject] of this.scopes) {\n const scope = scopeReplaySubject.getValue();\n if (this.newScopes.get(scope.id) && scopeIDs.includes(scope.id)) {\n const kindSub = this.kindSubs.get(scope.kind);\n if (kindSub) {\n kindSub.next({ scope, done: true });\n }\n this.newScopes.set(scope.id, false);\n }\n }\n\n super.next(scopeIDs);\n }\n\n protected create(\n scopeClass: ScopeConstructor,\n scope: ScopeIdent\n ) {\n return new scopeClass!(this.ctx, scope, this, this.attributes) as Scope<\n Context,\n Kinds\n >;\n }\n}\n\nexport class Scope<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> extends SharedScope {\n /**\n * @internal\n */\n readonly taj: TajribaAdminAccess;\n\n constructor(\n ctx: Context,\n scope: ScopeIdent,\n private scopes: Scopes,\n attributes: Attributes\n ) {\n super(ctx, scope, attributes);\n this.taj = scopes.taj;\n }\n\n protected scopeByID>(\n id: string\n ): T | undefined {\n return this.scopes.scope(id) as T | undefined;\n }\n\n protected scopeByKey>(\n key: string\n ): T | undefined {\n const id = this.get(key);\n if (!id || typeof id !== \"string\") {\n return;\n }\n\n return this.scopes.scope(id) as T | undefined;\n }\n\n protected scopesByKind>(\n kind: keyof Kinds\n ): Map {\n return this.scopes.byKind(kind) as Map;\n }\n\n protected scopesByKindID>(\n kind: keyof Kinds,\n id: string\n ): T | undefined {\n return this.scopes.byKind(kind).get(id);\n }\n\n protected scopesByKindMatching>(\n kind: keyof Kinds,\n key: string,\n val: string\n ): T[] {\n const scopes = Array.from(this.scopes.byKind(kind).values());\n return scopes.filter((s) => s.get(key) === val) as T[];\n }\n\n protected addScopes(input: AddScopeInput[]) {\n return this.taj.addScopes(input);\n }\n\n protected addGroups(input: AddGroupInput[]) {\n return this.taj.addGroups(input);\n }\n\n protected addLinks(input: LinkInput[]) {\n return this.taj.addLinks(input);\n }\n\n protected addSteps(input: AddStepInput[]) {\n return this.taj.addSteps(input);\n }\n\n protected addTransitions(input: TransitionInput[]) {\n return this.taj.addTransitions(input);\n }\n\n protected addFinalizer(cb: Finalizer) {\n this.taj.addFinalizer(cb);\n }\n\n /**\n * @internal\n */\n get globals() {\n return this.taj.globals;\n }\n}\n","import { BehaviorSubject, Observable } from \"rxjs\";\nimport { Attribute, AttributeOptions, Attributes } from \"../shared/attributes\";\nimport { Constructor } from \"../shared/helpers\";\nimport { warn } from \"../utils/console\";\nimport { JsonValue } from \"../utils/json\";\n\nexport type Attributable = {\n get: (key: string) => JsonValue | undefined;\n getAttribute: (key: string) => Attribute | undefined;\n set: (key: string, value: JsonValue, ao?: Partial) => void;\n append: (\n key: string,\n value: JsonValue,\n ao?: Partial\n ) => void;\n};\n\nexport interface ScopeIdent {\n id: string;\n kind: string;\n}\n\nexport interface ScopeUpdate {\n scope: ScopeIdent;\n removed: boolean;\n}\n\nexport type ScopeConstructor<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> = Constructor>;\n\nexport class Scopes<\n Context,\n Kinds extends { [key: string]: ScopeConstructor },\n Skope extends Scope = Scope\n> {\n protected scopes = new Map>();\n // newScopes is used to track scopes that have appeared for the first time.\n protected newScopes = new Map();\n protected scopesByKind = new Map>();\n protected kindUpdated = new Set();\n\n constructor(\n scopesObs: Observable,\n donesObs: Observable,\n protected ctx: Context,\n protected kinds: Kinds,\n protected attributes: Attributes\n ) {\n scopesObs.subscribe({\n next: ({ scope, removed }) => {\n this.update(scope, removed);\n },\n });\n\n donesObs.subscribe({\n next: (scopeIDs) => {\n this.next(scopeIDs);\n },\n });\n }\n\n scope(id: string): Skope | undefined {\n return this.scopes.get(id)?.getValue();\n }\n\n scopeObs(id: string): Observable | undefined {\n return this.scopes.get(id);\n }\n\n byKind(kind: keyof Kinds) {\n let map = this.scopesByKind.get(kind);\n if (!map) {\n map = new Map();\n this.scopesByKind.set(kind, map);\n }\n\n return map! as Map;\n }\n\n kindWasUpdated(kind: keyof Kinds): boolean {\n return this.kindUpdated.has(kind);\n }\n\n protected next(scopeIDs: string[]) {\n this.kindUpdated.clear();\n for (const [_, scopeSubject] of this.scopes) {\n const scope = scopeSubject.getValue();\n if (\n (scope._updated || this.attributes.scopeWasUpdated(scope.id)) &&\n scopeIDs.includes(scope.id)\n ) {\n scope._updated = false;\n scopeSubject.next(scope);\n }\n }\n }\n\n protected update(scope: ScopeIdent, removed: boolean) {\n const existing = this.scopes.get(scope.id)?.getValue();\n\n if (removed) {\n if (!existing) {\n warn(\"scopes: missing scope on removal\", scope.id, scope.kind);\n\n return;\n }\n\n existing._deleted = true;\n existing._updated = true;\n this.scopes.delete(scope.id);\n\n if (!scope.kind) {\n warn(\"scopes: scope missing kind on scope on removal\");\n\n return;\n }\n\n const kind = scope.kind as keyof Kinds;\n\n // Using ! because scopes by kind must exist, since this scope was found.\n this.scopesByKind.get(kind)!.delete(scope.id);\n\n this.kindUpdated.add(kind);\n\n return;\n }\n\n if (existing) {\n existing._deleted = false;\n return;\n }\n\n if (!scope.kind) {\n warn(\"scopes: scope missing kind on scope\");\n\n return;\n }\n\n const kind = scope.kind as keyof Kinds;\n const scopeClass = this.kinds[kind];\n if (!scopeClass) {\n warn(`scopes: unknown scope kind: ${scope.kind}`);\n\n return;\n }\n\n const obj = this.create(scopeClass, scope);\n const subj = new BehaviorSubject(obj);\n this.scopes.set(scope.id, subj);\n this.newScopes.set(scope.id, true);\n\n let skm = this.scopesByKind.get(kind);\n if (!skm) {\n skm = new Map();\n this.scopesByKind.set(kind, skm);\n }\n\n skm.set(scope.id, obj);\n\n obj._updated = true;\n this.kindUpdated.add(kind);\n }\n\n protected create(\n scopeClass: ScopeConstructor,\n scope: ScopeIdent\n ) {\n return new scopeClass!(this.ctx, scope, this.attributes) as Skope;\n }\n}\n\nexport type AttributeInput = {\n key: string;\n value: JsonValue;\n ao?: Partial;\n};\n\nexport class Scope<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> {\n /**\n * @internal\n */\n _deleted = false;\n\n /**\n * @internal\n */\n _updated = false;\n\n constructor(\n /**\n * @internal\n */\n readonly ctx: Context,\n /**\n * @internal\n */\n readonly scope: ScopeIdent,\n /**\n * @internal\n */\n protected attributes: Attributes\n ) {}\n\n get id() {\n return this.scope.id;\n }\n\n /**\n * @internal\n */\n get kind() {\n // Using ! because we don't allow scopes without kind\n return this.scope.kind!;\n }\n\n get(key: string): JsonValue | undefined {\n return this.attributes.attribute(this.scope.id, key).value;\n }\n\n getAttribute(key: string): Attribute | undefined {\n return this.attributes.attribute(this.scope.id, key);\n }\n\n obs(key: string): Observable {\n return this.attributes.attribute(this.scope.id, key).obs;\n }\n\n set(values: AttributeInput[]): void;\n set(key: string, value: JsonValue, ao?: Partial): void;\n set(\n keyOrAttributes: string | AttributeInput[],\n value?: JsonValue,\n ao?: Partial\n ) {\n if (typeof keyOrAttributes === \"string\") {\n if (value === undefined) {\n value = null;\n }\n\n return this.attributes\n .attribute(this.scope.id, keyOrAttributes)\n .set(value, ao);\n }\n\n const nextProps = [];\n for (const attr of keyOrAttributes) {\n const at = this.attributes\n .attribute(this.scope.id, attr.key)\n ._prepSet(attr.value, attr.ao);\n if (!at) {\n continue;\n }\n\n nextProps.push(at);\n }\n\n if (nextProps.length === 0) {\n return;\n }\n\n this.attributes.setAttributes(nextProps);\n }\n\n append(key: string, value: JsonValue, ao?: Partial) {\n if (!ao) {\n ao = {};\n }\n ao.append = true;\n\n return this.attributes.attribute(this.scope.id, key).set(value, ao);\n }\n\n inspect() {\n const attrs = this.attributes.attributes(this.scope.id);\n\n const out: { [key: string]: JsonValue | undefined } = {};\n for (const attr of attrs) {\n out[attr.key] = attr.value;\n }\n\n return out;\n }\n\n /**\n * @internal\n */\n hasUpdated() {\n return this._updated || this.attributes.scopeWasUpdated(this.id);\n }\n}\n","import { ScopeConstructor } from \"../shared/scopes\";\n\nexport type KV = {\n key: string;\n val: string;\n};\n\nfunction kvstr(kv: KV) {\n return kv.key + \"-\" + kv.val;\n}\n\nexport interface ScopeSubscriptionInput {\n /** ids of the matching Scopes. */\n ids: string[];\n /** kinds of the matching Scopes. */\n kinds: string[];\n /** keys to Attributes in matching Scope. */\n keys: string[];\n /** kvs to Attributes in matching Scope. */\n kvs: KV[];\n /** names of the matching Scopes. */\n names: string[];\n}\n\nexport interface Subs {\n participants: boolean;\n scopes: {\n ids: string[];\n kinds: string[];\n names: string[];\n keys: string[];\n kvs: KV[];\n };\n transitions: string[];\n}\n\n// Tracks what data should be subscribed to.\nexport class Subscriptions<\n Context,\n Kinds extends { [key: string]: ScopeConstructor }\n> {\n private scopeKinds = new Set();\n private scopeIDs = new Set();\n private scopeNames = new Set();\n private scopeKeys = new Set();\n private scopeKVSet = new Set();\n private scopeKVs: KV[] = [];\n private participantSub = false;\n private transitionsSubs = new Set();\n private dirty = false;\n public last: Subs = {\n participants: false,\n scopes: {\n ids: [],\n kinds: [],\n names: [],\n keys: [],\n kvs: [],\n },\n transitions: [],\n };\n\n get subs(): Subs {\n return {\n participants: this.participantSub,\n scopes: {\n kinds: Array.from(this.scopeKinds.values()),\n ids: Array.from(this.scopeIDs.values()),\n names: Array.from(this.scopeNames.values()),\n keys: Array.from(this.scopeKeys.values()),\n kvs: [...this.scopeKVs],\n },\n transitions: Array.from(this.transitionsSubs.values()),\n };\n }\n\n // newSubs will return only new subs since the last call.\n newSubs(): Subs | undefined {\n if (!this.dirty) {\n return;\n }\n\n const current = this.subs;\n const {\n scopes: { ids, kinds, names, keys, kvs },\n participants,\n transitions,\n } = this.last;\n\n const kvsstrs = kvs.map((kv) => kvstr(kv));\n\n const next = {\n participants: this.participantSub && !participants,\n scopes: {\n ids: current.scopes.ids.filter((id) => !ids.includes(id)),\n kinds: current.scopes.kinds.filter((kind) => !kinds.includes(kind)),\n names: current.scopes.names.filter((name) => !names.includes(name)),\n keys: current.scopes.keys.filter((key) => !keys.includes(key)),\n kvs: current.scopes.kvs.filter((kv) => !kvsstrs.includes(kvstr(kv))),\n },\n transitions: current.transitions.filter(\n (id) => !transitions.includes(id)\n ),\n };\n\n this.last = current;\n this.dirty = false;\n\n return next;\n }\n\n scopeSub(input: Partial) {\n if (input.ids) {\n for (const id of input.ids) {\n if (!this.scopeIDs.has(id)) {\n this.scopeIDs.add(id);\n this.dirty = true;\n }\n }\n }\n\n if (input.kinds) {\n for (const id of input.kinds) {\n if (!this.scopeKinds.has(id)) {\n this.scopeKinds.add(id);\n this.dirty = true;\n }\n }\n }\n\n if (input.names) {\n for (const name of input.names) {\n if (!this.scopeNames.has(name)) {\n this.scopeNames.add(name);\n this.dirty = true;\n }\n }\n }\n\n if (input.keys) {\n for (const key of input.keys) {\n if (!this.scopeKeys.has(key)) {\n this.scopeKeys.add(key);\n this.dirty = true;\n }\n }\n }\n\n if (input.kvs) {\n for (const kv of input.kvs) {\n const kvKey = kvstr(kv);\n if (!this.scopeKVSet.has(kvKey)) {\n this.scopeKVSet.add(kvKey);\n this.scopeKVs.push(kv);\n this.dirty = true;\n }\n }\n }\n }\n\n participantsSub() {\n if (!this.participantSub) {\n this.dirty = true;\n this.participantSub = true;\n }\n }\n\n transitionsSub(nodeID: string) {\n if (!this.transitionsSubs.has(nodeID)) {\n this.transitionsSubs.add(nodeID);\n this.dirty = true;\n }\n }\n}\n","import { EventType, State, TajribaAdmin } from \"@empirica/tajriba\";\nimport { Subject } from \"rxjs\";\nimport { error } from \"../utils/console\";\n\nexport interface Step {\n id: string;\n state: State;\n duration: number;\n startedAt?: number;\n endedAt?: number;\n}\n\nexport interface Transition {\n id: string;\n from: State;\n to: State;\n step: Step;\n}\n\nexport function transitionsSub(\n taj: TajribaAdmin,\n transitions: Subject,\n nodeID: string\n) {\n taj.onEvent({ eventTypes: [EventType.TransitionAdd], nodeID }).subscribe({\n next({ node }) {\n if (!node) {\n return;\n }\n\n if (node.__typename !== \"Transition\") {\n error(`received non-transition`);\n\n return;\n }\n\n if (node.node.__typename !== \"Step\") {\n error(`received non-step transition`, node.node);\n\n return;\n }\n\n transitions.next({\n id: node.id,\n to: node.to,\n from: node.from,\n step: {\n id: node.node.id,\n duration: node.node.duration,\n state: node.node.state,\n },\n });\n },\n });\n}\n"],"mappings":";;;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA,oBAAAA;AAAA,EAAA;AAAA;AAAA,eAAAC;AAAA,EAAA,cAAAC;AAAA,EAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;;;ACCA,kBAA4C;;;ACC5C,IAAM,YACJ,OAAO,WAAW,eAAe,OAAO,OAAO,aAAa;AA8B9D,IAAI;AAiCJ,IAAM,WAAW;AAAA,EACf,CAAC,YAAU,GAAG;AAAA,EACd,CAAC,cAAW,GAAG;AAAA,EACf,CAAC,YAAS,GAAG;AAAA,EACb,CAAC,cAAW,GAAG;AAAA,EACf,CAAC,eAAY,GAAG;AAAA,EAChB,CAAC,aAAU,GAAG;AAAA,EACd,CAAC,gBAAa,GAAG;AAAA,EACjB,CAAC,aAAU,GAAG;AAAA,EACd,CAAC,cAAW,GAAG;AAAA,EACf,CAAC,iBAAc,GAAG;AACpB;AAEO,IAAM,SAAoC;AAAA,EAC/C,OAAO;AAAA,EACP,OAAO;AAAA,EACP,KAAK;AAAA,EACL,MAAM;AAAA,EACN,MAAM;AAAA,EACN,OAAO;AACT;AAEA,IAAM,eAA0C,CAAC;AACjD,WAAW,OAAO,QAAQ;AACxB,eAAa,OAAO,GAAG,CAAE,IAAI;AAC/B;AAEA,IAAI,eAAe;AAWnB,SAAS,kBAAkB,MAAY,OAAiB;AACtD,MAAI,OAAO,KAAK,SAAS;AACzB,MAAI,UAAU,KAAK,WAAW;AAC9B,MAAI,UAAU,KAAK,WAAW;AAC9B,MAAI,eAAe,KAAK,gBAAgB;AAExC,QAAM,OACH,OAAO,KAAK,MAAM,OAAO,QAC1B,OACC,UAAU,KAAK,MAAM,UAAU,WAChC,OACC,UAAU,KAAK,MAAM,UAAU,WAChC,OACC,OAAO,cAAc,MAAM,EAAE;AAEhC,MAAI,WAAW;AACb,UAAM,KAAK,SAAS,KAAK,iBAAc,EAAE,OAAO,KAAK;AACrD,WAAO,CAAC,GAAG,CAAC,IAAI,MAAM,MAAM,CAAC,GAAG,GAAG,CAAC,GAAG,MAAM,CAAC,CAAC;AAAA,EACjD;AAEA,SAAO,SAAS,KAAK,iBAAc,EAAE,OAAO,KAAK;AACnD;AAEA,IAAM,eAAe,CAAC,KAAa,UAAoB;AACrD,SAAO,IAAI,SAAgB;AACzB,QAAI,MAAM,cAAc;AACtB;AAAA,IACF;AAEA,QAAI,UAAU;AACZ,eAAS,IAAI,EAAE,OAAO,aAAa,GAAG,GAAI,KAAW,CAAC;AAEtD;AAAA,IACF;AAEA,QAAI,KAAK,WAAW,GAAG;AACrB,cAAQ,OAAO,KAAK,CAAC,GAAG;AAAA,QACtB,KAAK;AACH,qBAAW,QAAQ,KAAK,CAAC,EAAE,MAAM,IAAI,GAAG;AACtC,oBAAQ,IAAI,GAAG,kBAAkB,oBAAI,KAAK,GAAG,KAAK,EAAE,OAAO,IAAI,CAAC;AAAA,UAClE;AACA;AAAA,QAEF,KAAK;AACH,cAAI,KAAK,CAAC,aAAa,OAAO;AAC5B,kBAAMC,SAAQ,KAAK,CAAC;AACpB,kBAAM,YACJA,OAAM,OACN,OACAA,OAAM,QAAQ,QAAQ,IAAI,OAAO,IAAIA,OAAM,WAAW,GAAG,EAAE,IAC3D,QACCA,OAAM,SAAS,IACb,MAAM,IAAI,EACV,IAAI,CAAC,SAAS,KAAK,KAAK,CAAC,EACzB,IAAI,CAAC,SAAS;AACb,kBAAI,KAAK,WAAWA,OAAM,OAAO,OAAOA,OAAM,OAAO;AACnD,uBAAO;AAET,kBAAI,KAAK,WAAW,IAAI,GAAG;AACzB,uBAAO,OAAO;AAAA,cAChB;AAEA,qBAAO;AAAA,YACT,CAAC,EACA,OAAO,OAAO,EACd,KAAK,IAAI;AAEd,uBAAW,QAAQ,UAAU,MAAM,IAAI,GAAG;AACxC,sBAAQ,IAAI,GAAG,kBAAkB,oBAAI,KAAK,GAAG,KAAK,EAAE,OAAO,IAAI,CAAC;AAAA,YAClE;AAEA;AAAA,UACF;AAAA,MACJ;AAAA,IACF;AAEA,YAAQ,IAAI,GAAG,kBAAkB,oBAAI,KAAK,GAAG,KAAK,EAAE,OAAO,IAAI,CAAC;AAAA,EAClE;AACF;AAEA,SAAS,SAAS,MAAc,IAAuB;AACrD,MAAI,WAAW;AACb,UAAM,OAAO,CAAC;AACd,eAAW,KAAK,IAAI;AAClB,WAAK,KAAK,SAAS,CAAC,CAAC;AAAA,IACvB;AAEA,WAAO,CAAC,KAAK,KAAK,KAAK,KAAK,IAAI,CAAC;AAAA,EACnC;AAEA,MAAI,MAAM;AACV,aAAW,KAAK,IAAI;AAClB,WAAO,QAAQ;AAAA,EACjB;AACA,SAAO,GAAG;AAEV,SAAO,CAAC,GAAG;AACb;AAEO,IAAM,QAAQ,aAAa,GAAG,SAAS,OAAO,gBAAa,CAAC;AAC5D,IAAM,QAAQ,aAAa,GAAG,SAAS,OAAO,eAAY,CAAC;AAC3D,IAAM,MAAM,aAAa,GAAG,SAAS,OAAO,eAAY,CAAC;AACzD,IAAM,OAAO,aAAa,GAAG,SAAS,OAAO,cAAW,CAAC;AACzD,IAAM,OAAO,aAAa,GAAG,SAAS,OAAO,aAAU,CAAC;AACxD,IAAM,QAAQ,aAAa,GAAG,SAAS,OAAO,cAAW,YAAU,CAAC;;;ADpKpE,IAAM,aAAN,MAAiB;AAAA,EAItB,YACE,eACA,UACS,eACT;AADS;AANX,SAAU,QAAQ,oBAAI,IAAoC;AAC1D,SAAU,UAAU,oBAAI,IAAoD;AAO1E,kBAAc,UAAU;AAAA,MACtB,MAAM,CAAC,EAAE,WAAW,QAAQ,MAAM;AAChC,aAAK,OAAO,WAAW,OAAO;AAAA,MAChC;AAAA,IACF,CAAC;AAED,aAAS,UAAU;AAAA,MACjB,MAAM,CAAC,aAAa;AAClB,aAAK,KAAK,QAAQ;AAAA,MACpB;AAAA,IACF,CAAC;AAAA,EACH;AAAA,EAEA,UAAU,SAAiB,KAAwB;AACjD,QAAI,WAAW,KAAK,MAAM,IAAI,OAAO;AACrC,QAAI,CAAC,UAAU;AACb,iBAAW,oBAAI,IAAI;AACnB,WAAK,MAAM,IAAI,SAAS,QAAQ;AAAA,IAClC;AAEA,QAAI,OAAO,SAAS,IAAI,GAAG;AAC3B,QAAI,CAAC,MAAM;AACT,aAAO,IAAI,UAAU,KAAK,eAAe,SAAS,GAAG;AACrD,eAAS,IAAI,KAAK,IAAI;AAAA,IACxB;AAEA,WAAO;AAAA,EACT;AAAA,EAEA,WAAW,SAA8B;AACvC,QAAI,WAAW,KAAK,MAAM,IAAI,OAAO;AACrC,QAAI,CAAC,UAAU;AACb,iBAAW,oBAAI,IAAI;AACnB,WAAK,MAAM,IAAI,SAAS,QAAQ;AAAA,IAClC;AAEA,WAAO,MAAM,KAAK,SAAS,OAAO,CAAC;AAAA,EACrC;AAAA,EAEA,cAAc,SAAiB,KAAoC;AACjE,QAAI,iBAAiB,KAAK,QAAQ,IAAI,OAAO;AAC7C,QAAI,gBAAgB;AAClB,YAAM,UAAU,eAAe,IAAI,GAAG;AACtC,UAAI,SAAS;AACX,YAAI,OAAO,YAAY,WAAW;AAChC;AAAA,QACF,OAAO;AACL,cAAI,CAAC,QAAQ,KAAK;AAChB;AAAA,UACF,OAAO;AACL,kBAAMC,QAAO,IAAI,UAAU,KAAK,eAAe,SAAS,GAAG;AAC3D,YAAAA,MAAK,QAAQ,OAAO;AACpB,mBAAOA;AAAA,UACT;AAAA,QACF;AAAA,MACF;AAAA,IACF;AAEA,QAAI,WAAW,KAAK,MAAM,IAAI,OAAO;AACrC,QAAI,CAAC,UAAU;AACb;AAAA,IACF;AAEA,QAAI,OAAO,SAAS,IAAI,GAAG;AAC3B,QAAI,CAAC,MAAM;AACT;AAAA,IACF;AAEA,QAAI,KAAK,UAAU,QAAW;AAC5B;AAAA,IACF;AAEA,WAAO;AAAA,EACT;AAAA,EAEA,mBAAmB,SAAiB,KAAoC;AACtE,UAAM,OAAO,KAAK,cAAc,SAAS,GAAG;AAC5C,QAAI,CAAC,MAAM;AACT;AAAA,IACF;AAEA,WAAO,KAAK;AAAA,EACd;AAAA,EAEQ,OAAO,MAAuB,SAAkB;AACtD,QAAI,SAAS,KAAK;AAClB,QAAI,CAAC,QAAQ;AACX,UAAI,CAAC,KAAK,MAAM,IAAI;AAClB,cAAM,+BAA+B;AACrC;AAAA,MACF;AACA,eAAS,KAAK,KAAK;AAAA,IACrB;AAEA,QAAI,WAAW,KAAK,QAAQ,IAAI,MAAM;AACtC,QAAI,CAAC,UAAU;AACb,iBAAW,oBAAI,IAAI;AACnB,WAAK,QAAQ,IAAI,QAAQ,QAAQ;AAAA,IACnC;AAEA,QAAI,SAAS;AACX,eAAS,IAAI,KAAK,KAAK,IAAI;AAAA,IAC7B,OAAO;AACL,UAAI,MAAM,KAAK;AACf,UAAI,KAAK,UAAU,UAAa,KAAK,UAAU,MAAM;AACnD,cAAM,GAAG,OAAO,KAAK;AAAA,MACvB;AACA,eAAS,IAAI,KAAK,IAAI;AAAA,IACxB;AAAA,EACF;AAAA,EAEA,gBAAgB,SAA2B;AACzC,QAAI,CAAC,SAAS;AACZ,aAAO;AAAA,IACT;AAEA,WAAO,KAAK,QAAQ,IAAI,OAAO;AAAA,EACjC;AAAA,EAEU,KAAK,UAAoB;AACjC,eAAW,CAAC,SAAS,KAAK,KAAK,KAAK,SAAS;AAC3C,UAAI,CAAC,SAAS,SAAS,OAAO,GAAG;AAC/B;AAAA,MACF;AAEA,UAAI,WAAW,KAAK,MAAM,IAAI,OAAO;AAErC,UAAI,CAAC,UAAU;AACb,mBAAW,oBAAI,IAAI;AACnB,aAAK,MAAM,IAAI,SAAS,QAAQ;AAAA,MAClC;AAEA,iBAAW,CAAC,KAAK,SAAS,KAAK,OAAO;AACpC,YAAI,OAAO,cAAc,WAAW;AAClC,cAAI,OAAO,SAAS,IAAI,GAAG;AAC3B,cAAI,MAAM;AACR,iBAAK,QAAQ,MAAS;AAAA,UACxB;AAAA,QACF,OAAO;AACL,cAAI,OAAO,SAAS,IAAI,UAAU,GAAG;AACrC,cAAI,CAAC,MAAM;AACT,mBAAO,IAAI,UAAU,KAAK,eAAe,SAAS,UAAU,GAAG;AAC/D,qBAAS,IAAI,UAAU,KAAK,IAAI;AAAA,UAClC;AAEA,eAAK,QAAQ,SAAS;AAAA,QACxB;AAAA,MACF;AAAA,IACF;AAEA,eAAW,WAAW,UAAU;AAC9B,WAAK,QAAQ,OAAO,OAAO;AAAA,IAC7B;AAAA,EACF;AACF;AA+BO,IAAM,YAAN,MAAgB;AAAA,EAOrB,YACU,eACC,SACA,KACT;AAHQ;AACC;AACA;AANX,SAAQ,MAAM,IAAI,4BAAuC,MAAS;AAAA,EAO/D;AAAA,EAEH,IAAI,KAAK;AACP,WAAO,KAAK,MAAM;AAAA,EACpB;AAAA,EAEA,IAAI,YAAY;AACd,WAAO,KAAK,OAAO,IAAI,KAAK,KAAK,KAAM,SAAU,IAAI;AAAA,EACvD;AAAA,EAEA,IAAI,MAAyC;AAC3C,WAAO,KAAK;AAAA,EACd;AAAA,EAEA,IAAI,QAAQ;AACV,WAAO,KAAK,IAAI,SAAS;AAAA,EAC3B;AAAA,EAEA,IAAI,SAAS;AACX,WAAO,KAAK;AAAA,EACd;AAAA;AAAA;AAAA,EAIA,IAAI,QAAQ;AACV,QAAI,CAAC,KAAK,OAAO;AACf,aAAO;AAAA,IACT;AAEA,WAAO,KAAK;AAAA,EACd;AAAA,EAEA,IAAI,OAAkB,IAAgC;AACpD,UAAM,YAAY,KAAK,SAAS,OAAO,EAAE;AACzC,QAAI,CAAC,WAAW;AACd;AAAA,IACF;AAEA,SAAK,cAAc,CAAC,SAAS,CAAC;AAC9B,UAAM,OAAO,KAAK,SAAS,UAAU,KAAK,UAAU;AAAA,EACtD;AAAA,EAEA,SACE,OACA,IACA,MAC+B;AAC/B,QAAI,IAAI,WAAW,UAAa,GAAI,UAAU,QAAW;AACvD,YAAM,kCAAkC;AAExC,YAAM,IAAI,MAAM,kCAAkC;AAAA,IACpD;AAEA,UAAM,SAAS,KAAK,UAAU,KAAK;AAEnC,QAAI,CAAC,SAAS,IAAI,UAAU,UAAa,IAAI,SAAS;AACpD,UAAI,QAAQ,GAAI,SAAS;AACzB,UAAI,IAAI,QAAQ;AACd,gBAAQ,KAAK,OAAO,UAAU;AAAA,MAChC;AAEA,UAAI,CAAC,KAAK,OAAO;AACf,aAAK,QAAQ,CAAC;AAAA,MAChB;AAMA,UAAI,CAAC,KAAK,MAAM,KAAK,GAAG;AACtB,aAAK,MAAM,KAAK,IAAI,IAAI;AAAA,UACtB,KAAK;AAAA,UACL,KAAK;AAAA,UACL,KAAK;AAAA,QACP;AAAA,MACF,OAAO;AACL,cAAM,WAAW,KAAK,MAAM,KAAK;AACjC,YAAI,YAAY,SAAS,WAAW,QAAQ;AAC1C;AAAA,QACF;AAAA,MACF;AAEA,WAAK,MAAO,KAAK,EAAG,SAAS,OAAO,IAAI,IAAI;AAC5C,YAAM,IAAI,KAAK,iBAAiB;AAChC,WAAK,IAAI,KAAK,CAAC;AAAA,IACjB,OAAO;AACL,UAAI,KAAK,WAAW,QAAQ;AAC1B;AAAA,MACF;AAEA,WAAK,IAAI,KAAK,KAAK;AAAA,IACrB;AAEA,SAAK,SAAS;AAEd,UAAM,YAA+B;AAAA,MACnC,KAAK,KAAK;AAAA,MACV,QAAQ,KAAK;AAAA,MACb,KAAK;AAAA,IACP;AAEA,QAAI,IAAI;AAGN,gBAAU,UAAU,GAAG;AACvB,gBAAU,YAAY,GAAG;AACzB,gBAAU,YAAY,GAAG;AACzB,gBAAU,YAAY,GAAG;AACzB,gBAAU,SAAS,GAAG;AACtB,gBAAU,QAAQ,GAAG;AAAA,IACvB;AAEA,WAAO;AAAA,EACT;AAAA,EAEQ,mBAA8B;AACpC,WAAO,KAAK,MAAO;AAAA,MAAI,CAAC,MACtB,CAAC,KAAK,EAAE,OAAO,SAAY,OAAO,EAAE,SAAS;AAAA,IAC/C;AAAA,EACF;AAAA;AAAA,EAGA,QAAQ,MAAwB,MAAgB;AAC9C,QAAI,QAAQ,KAAK,QAAQ,KAAK,KAAK,OAAO,KAAK,IAAI;AACjD;AAAA,IACF;AAEA,QAAI,QAAQ,KAAK,UAAU,CAAC,MAAM;AAGhC,UAAI,KAAK,UAAU,QAAW;AAC5B,cAAM,gCAAgC;AACtC;AAAA,MACF;AAEA,UAAI,KAAK,SAAS,QAAW;AAC3B,aAAK,QAAQ,CAAC;AAAA,MAChB;AAEA,aAAO,KAAK,MAAM,SAAS,KAAK,QAAS,GAAG;AAC1C,cAAMC,WAAU,IAAI;AAAA,UAClB,KAAK;AAAA,UACL,KAAK;AAAA,UACL,KAAK;AAAA,QACP;AACA,aAAK,MAAM,KAAKA,QAAO;AAAA,MACzB;AAEA,YAAM,UAAU,IAAI,UAAU,KAAK,eAAe,KAAK,SAAS,KAAK,GAAG;AACxE,cAAQ,QAAQ,MAAM,IAAI;AAC1B,WAAK,MAAM,KAAK,KAAM,IAAI;AAC1B,YAAMC,SAAQ,KAAK,iBAAiB;AACpC,WAAK,IAAI,KAAKA,MAAK;AAEnB;AAAA,IACF;AAEA,SAAK,OAAO;AACZ,SAAK,SAAS,MAAM,QAAQ,UAAa,MAAM,QAAQ,OAAO,KAAK,KAAK;AACxE,QAAI,QAA+B;AACnC,QAAI,KAAK,MAAM,KAAK;AAClB,cAAQ,KAAK,MAAM,KAAK,KAAK,GAAG;AAAA,IAClC;AACA,SAAK,IAAI,KAAK,KAAK;AAAA,EACrB;AACF;;;AE9ZA,qBAA0C;;;ACE1C,IAAAC,eAAgC;AAEzB,SAAS,GAAM,MAAS;AAC7B,SAAO,IAAI,6BAAmB,IAAI;AACpC;AAEO,SAAS,IAAO,OAAsB,QAAW;AACtD,SAAO,IAAI,6BAA+B,IAAI;AAChD;;;ADLO,IAAM,kBAAkB,IAAI,MAAM,eAAe;AAEjD,IAAM,oBAAN,MAAwB;AAAA,EAM7B,YAAoB,KAAa;AAAb;AAJpB,SAAQ,aAAa,GAAG,KAAK;AAC7B,SAAQ,cAAwC,GAAG,IAAI;AACvD,SAAQ,WAAW,GAAG,KAAK;AAGzB,SAAK,UAAU,uBAAQ,QAAQ,KAAK,GAAG;AACvC,SAAK,WAAW,KAAK,KAAK,QAAQ,SAAS;AAE3C,SAAK,QAAQ,GAAG,aAAa,MAAM;AACjC,WAAK,WAAW,KAAK,IAAI;AACzB,WAAK,YAAY,KAAK,KAAK;AAAA,IAC7B,CAAC;AAED,SAAK,QAAQ,GAAG,gBAAgB,MAAM;AACpC,UAAI,KAAK,WAAW,SAAS,GAAG;AAC9B,aAAK,WAAW,KAAK,KAAK;AAAA,MAC5B;AACA,UAAI,CAAC,KAAK,YAAY,SAAS,GAAG;AAChC,aAAK,YAAY,KAAK,IAAI;AAAA,MAC5B;AAAA,IACF,CAAC;AAED,SAAK,QAAQ,GAAG,SAAS,CAAC,QAAQ;AAChC,YAAM,oBAAoB,GAAG;AAAA,IAC/B,CAAC;AAAA,EACH;AAAA,EAEA,IAAI,aAAa;AACf,WAAO,KAAK;AAAA,EACd;AAAA,EAEA,IAAI,YAAY;AACd,WAAO,KAAK;AAAA,EACd;AAAA,EAEA,IAAI,UAAU;AACZ,WAAO,KAAK;AAAA,EACd;AAAA,EAEA,MAAM,mBAAmB,OAAe,QAA0B;AAChE,QAAI,CAAC,KAAK,WAAW,SAAS,GAAG;AAC/B,YAAM;AAAA,IACR;AAEA,WAAO,MAAM,KAAK,QAAQ,mBAAmB,OAAO,MAAM;AAAA,EAC5D;AAAA,EAEA,MAAM,aAAa,OAAe;AAChC,QAAI,CAAC,KAAK,WAAW,SAAS,GAAG;AAC/B,YAAM;AAAA,IACR;AAEA,WAAO,MAAM,KAAK,QAAQ,aAAa,KAAK;AAAA,EAC9C;AAAA,EAEA,OAAO;AACL,QAAI,KAAK,SAAS,SAAS,GAAG;AAC5B;AAAA,IACF;AAEA,QAAI,KAAK,SAAS;AAChB,WAAK,QAAQ,mBAAmB,WAAW;AAC3C,WAAK,QAAQ,mBAAmB,cAAc;AAC9C,WAAK,QAAQ,KAAK;AAAA,IACpB;AAEA,SAAK,YAAY,KAAK,KAAK;AAC3B,SAAK,WAAW,KAAK,KAAK;AAC1B,SAAK,SAAS,KAAK,IAAI;AAAA,EACzB;AACF;;;AE/EA,IAAAC,eAA0C;AAanC,IAAMC,cAAN,cAAyB,WAAiB;AAAA,EAA1C;AAAA;AACL,SAAU,cAAc,oBAAI,IAG1B;AACF,SAAQ,aAAa,oBAAI,IAGvB;AAAA;AAAA,EAEF,mBAAmB,MAAc,KAAuC;AACtE,QAAI,CAAC,KAAK,WAAW,IAAI,IAAI,GAAG;AAC9B,WAAK,WAAW,IAAI,MAAM,oBAAI,IAAyC,CAAC;AAAA,IAC1E;AAEA,UAAM,SAAS,KAAK,WAAW,IAAI,IAAI;AACvC,QAAI,MAAM,OAAO,IAAI,GAAG;AACxB,QAAI,CAAC,KAAK;AACR,YAAM,IAAI,2BAA4B;AACtC,aAAO,IAAI,KAAK,GAAG;AAEnB,YAAM,gBAAgB,KAAK,YAAY,IAAI,IAAI;AAE/C,iBAAW,MAAM;AACf,YAAI,CAAC,eAAe;AAClB,cAAK,KAAK,EAAE,MAAM,KAAK,CAAC;AACxB;AAAA,QACF;AAEA,YAAI,QAAQ,CAAC;AACb,mBAAW,CAAC,GAAG,SAAS,KAAK,eAAe,QAAQ,GAAG;AACrD,qBAAW,CAACC,IAAG,IAAI,KAAK,WAAW;AACjC,gBAAI,KAAK,QAAQ,KAAK;AACpB,oBAAM,KAAK,IAAI;AAAA,YACjB;AAAA,UACF;AAAA,QACF;AAEA,YAAI,MAAM,SAAS,GAAG;AACpB,cAAI,QAAQ;AACZ,qBAAW,QAAQ,OAAO;AACxB;AACA,gBAAK,KAAK,EAAE,WAAW,MAAM,MAAM,SAAS,MAAM,OAAO,CAAC;AAAA,UAC5D;AAAA,QACF,OAAO;AACL,cAAK,KAAK,EAAE,MAAM,KAAK,CAAC;AAAA,QAC1B;AAAA,MACF,GAAG,CAAC;AAAA,IACN;AAEA,WAAO;AAAA,EACT;AAAA,EAEU,KAAK,UAAoB;AACjC,UAAM,SAAS,oBAAI,IAA+B;AAElD,eAAW,CAAC,SAAS,KAAK,KAAK,KAAK,SAAS;AAC3C,UAAI,CAAC,SAAS,SAAS,OAAO,GAAG;AAC/B;AAAA,MACF;AAEA,iBAAW,CAAC,GAAG,IAAI,KAAK,OAAO;AAC7B,YAAI,OAAO,SAAS,WAAW;AAC7B;AAAA,QACF;AAEA,cAAM,OAAO,KAAK,MAAM;AACxB,YAAI,MAAM;AACR,cAAI,YAAY,OAAO,IAAI,IAAI;AAC/B,cAAI,CAAC,WAAW;AACd,wBAAY,CAAC;AACb,mBAAO,IAAI,MAAM,SAAS;AAAA,UAC5B;AAEA,oBAAU,KAAK,IAAI;AAAA,QACrB;AAAA,MACF;AAAA,IACF;AAEA,UAAM,UAA+C,CAAC;AACtD,eAAW,CAAC,MAAM,KAAK,KAAK,QAAQ;AAClC,iBAAW,QAAQ,OAAO;AAIxB,YAAI,CAAC,KAAK,UAAU,CAAC,KAAK,MAAM,IAAI;AAClC,eAAK,wCAAwC;AAC7C;AAAA,QACF;AAEA,YAAI,CAAC,SAAS,SAAS,KAAK,UAAU,KAAK,KAAM,EAAE,GAAG;AACpD;AAAA,QACF;AAEA,gBAAQ,KAAK,CAAC,MAAM,KAAK,KAAK,IAAI,CAAC;AAAA,MACrC;AAAA,IACF;AAEA,UAAM,KAAK,QAAQ;AAEnB,eAAW,CAAC,MAAM,KAAK,UAAU,KAAK,SAAS;AAE7C,YAAM,SAAS,WAAW,UAAU,WAAW,KAAM;AAErD,UAAI,CAAC,SAAS,SAAS,MAAM,GAAG;AAC9B;AAAA,MACF;AAEA,YAAM,OAAO,KAAK,MAAM,IAAI,MAAM,EAAG,IAAI,GAAG;AAC5C,YAAM,MAAM,KAAK,WAAW,IAAI,IAAI,GAAG,IAAI,GAAG;AAC9C,UAAI,KAAK;AACP,YAAI,KAAK,EAAE,WAAW,MAAM,MAAM,KAAK,CAAC;AAAA,MAC1C,OAAO;AACL,YAAI,SAAS,KAAK,YAAY,IAAI,IAAI;AACtC,YAAI,CAAC,QAAQ;AACX,mBAAS,oBAAI,IAAoC;AACjD,eAAK,YAAY,IAAI,MAAM,MAAM;AAAA,QACnC;AAEA,YAAI,UAAU,OAAQ,IAAI,MAAM;AAChC,YAAI,CAAC,SAAS;AACZ,oBAAU,oBAAI,IAAuB;AACrC,iBAAQ,IAAI,QAAQ,OAAO;AAAA,QAC7B;AAEA,gBAAQ,IAAI,KAAK,IAAI;AAAA,MACvB;AAAA,IACF;AAAA,EACF;AACF;;;AC7IA,IAAAC,eAAyD;;;ACDzD,yBAAkC;AAClC,IAAAC,eAA0D;AAgGnD,SAAS,eACd,KACA,IACA;AACA,QAAM,SAAS,IAAI,qBAAc;AACjC,MAAI,SAAK,wBAAU,EAAE,OAAG,wBAAU,MAAM,CAAC,EAAE,UAAU;AACrD,SAAO;AAAA,IACL,QAAQ;AAAA,IACR,cAAc;AACZ,UAAI,KAAK,QAAQ;AACf,aAAK,gDAAgD;AACrD;AAAA,MACF;AACA,WAAK,SAAS;AACd,aAAO,KAAK;AACZ,aAAO,YAAY;AAAA,IACrB;AAAA,EACF;AACF;;;ADzGO,IAAM,kBAAN,MAAsB;AAAA,EAO3B,YACE,KACA,QACQ,YACR;AADQ;AATV,SAAQ,WAAW,IAAkB;AACrC,SAAQ,aAAa,GAAG,KAAK;AAC7B,SAAQ,cAAc,GAAG,KAAK;AAC9B,SAAQ,WAAW,GAAG,KAAK;AAQzB,QAAI;AACJ,QAAI,YAAY;AAEhB,SAAK,MAAM;AAAA,UACT,oBAAM,IAAI,WAAW,MAAM;AAAA,MAC3B,OAAO,qBAAqB;AAC1B,YAAI,OAAO,qBAAqB,WAAW;AACzC,sBAAY;AAAA,QACd,OAAO;AACL,kBAAQ;AAAA,QACV;AAEA,YAAI,CAAC,SAAS,CAAC,WAAW;AACxB;AAAA,QACF;AAEA,YAAI,KAAK,WAAW,SAAS,GAAG;AAC9B;AAAA,QACF;AAEA,aAAK,YAAY,KAAK,IAAI;AAE1B,YAAI;AACF,gBAAM,WAAW,MAAM,IAAI,aAAa,KAAK;AAE7C,eAAK,SAAS,KAAK,QAAQ;AAC3B,eAAK,WAAW,KAAK,IAAI;AAEzB,mBAAS,GAAG,aAAa,MAAM;AAC7B,gBAAI,CAAC,KAAK,WAAW,SAAS,GAAG;AAC/B,mBAAK,WAAW,KAAK,IAAI;AAAA,YAC3B;AAAA,UACF,CAAC;AACD,mBAAS,GAAG,SAAS,CAAC,QAAQ;AAC5B,kBAAM,oBAAoB,GAAG;AAAA,UAC/B,CAAC;AACD,mBAAS,GAAG,gBAAgB,MAAM;AAChC,gBAAI,KAAK,WAAW,SAAS,GAAG;AAC9B,mBAAK,WAAW,KAAK,KAAK;AAAA,YAC5B;AAAA,UACF,CAAC;AACD,mBAAS,GAAG,gBAAgB,MAAM;AAChC,gBAAI,KAAK,WAAW,SAAS,GAAG;AAC9B,mBAAK,WAAW,KAAK,KAAK;AAAA,YAC5B;AACA,iBAAK,WAAW;AAAA,UAClB,CAAC;AAAA,QACH,SAASC,QAAP;AACA,cAAIA,WAAU,iBAAiB;AAC7B,iBAAK,WAAW;AAAA,UAClB;AAAA,QACF;AAEA,aAAK,YAAY,KAAK,KAAK;AAAA,MAC7B;AAAA,IACF;AAAA,EACF;AAAA,EAEA,OAAO;AACL,QAAI,KAAK,SAAS,SAAS,GAAG;AAC5B;AAAA,IACF;AAEA,UAAM,MAAM,KAAK,SAAS,SAAS;AACnC,QAAI,KAAK;AACP,UAAI,mBAAmB,WAAW;AAClC,UAAI,mBAAmB,cAAc;AACrC,UAAI,KAAK;AACT,WAAK,SAAS,KAAK,MAAS;AAAA,IAC9B;AAEA,SAAK,IAAI,YAAY;AAErB,SAAK,YAAY,KAAK,KAAK;AAC3B,SAAK,WAAW,KAAK,KAAK;AAC1B,SAAK,SAAS,KAAK,IAAI;AAAA,EACzB;AAAA,EAEA,IAAI,aAAa;AACf,WAAO,KAAK;AAAA,EACd;AAAA,EAEA,IAAI,YAAY;AACd,WAAO,KAAK;AAAA,EACd;AAAA,EAEA,IAAI,UAAU;AACZ,WAAO,KAAK;AAAA,EACd;AAAA,EAEA,IAAI,QAAQ;AACV,WAAO,KAAK;AAAA,EACd;AACF;;;AEjGO,IAAK,eAAL,kBAAKC,kBAAL;AACL,EAAAA,cAAA,mBAAgB;AAChB,EAAAA,cAAA,wBAAqB;AACrB,EAAAA,cAAA,2BAAwB;AAHd,SAAAA;AAAA,GAAA;AAYZ,IAAM,kBAAkB,oBAAI,IAAgC;AAC5D,gBAAgB,IAAI,gBAA2B,QAAQ;AACvD,gBAAgB,IAAI,cAAyB,IAAI;AACjD,gBAAgB,IAAI,eAA0B,OAAO;AAE9C,SAAS,gBAAgB,WAAuC;AACrE,SAAO,gBAAgB,IAAI,SAAS;AACtC;AAkCA,SAAS,OAKP,MACA,WACA,UACA;AACA,SAAO,OAAO,KAAmC,UAAe;AAC9D,UAAM,OAAO,MAAM;AACnB,UAAM,QAAQ,MAAM,IAAI;AACxB,QACE,CAAC,KAAK,MACN,MAAM,IAAI,OAAO,gBAAgB,SAAS,KAAK,MAAM,QAAQ,GAC7D;AACA;AAAA,IACF;AAEA,UAAM,SAAS,KAAK,KAAK;AAEzB,UAAM,IAAI,OAAO,gBAAgB,SAAS,KAAK,MAAM,UAAU,IAAI;AAAA,EACrE;AACF;AAGO,IAAM,qBAAN,MAGL;AAAA,EAHK;AAKL;AAAA,SAAS,SAA2C,CAAC;AAErD;AAAA,SAAS,SAA2C,CAAC;AAErD;AAAA,SAAS,YAAgE,CAAC;AAE1E;AAAA,SAAS,gBACP,CAAC;AAEH;AAAA,SAAS,qBAEH,CAAC;AAAA;AAAA;AAAA,EAMP,WAAW,SAAkB;AAC3B,SAAK,UAAU;AAAA,EACjB;AAAA,EAEA,MAAM,QAAuB;AAC3B,QAAI,CAAC,KAAK,SAAS;AACjB;AAAA,IACF;AAEA,UAAM,KAAK,QAAQ,MAAM;AAAA,EAC3B;AAAA,EAEA,WAAW,IAAuD;AAChE,QAAI,CAAC,KAAK,SAAS;AACjB;AAAA,IACF;AAEA,WAAO,KAAK,QAAQ,WAAW,EAAE;AAAA,EACnC;AAAA,EAEA,IAAI,SAAS;AACX,WAAO,IAAI,wBAAwC,IAAI;AAAA,EACzD;AAAA,EA0BA,GACE,aACA,8BAKA,UACM;AACN,SAAK;AAAA,MACH;AAAA,MACA;AAAA,MACA;AAAA,MACA;AAAA,IACF;AAAA,EACF;AAAA,EAEA,OACE,aACA,8BAKA,UACA,YACM;AACN,SAAK;AAAA,MACH;AAAA,MACA;AAAA,MACA;AAAA,MACA;AAAA,MACA;AAAA,IACF;AAAA,EACF;AAAA,EAEA,MACE,aACA,8BAKA,UACA,YACM;AACN,SAAK;AAAA,MACH;AAAA,MACA;AAAA,MACA;AAAA,MACA;AAAA,MACA;AAAA,IACF;AAAA,EACF;AAAA,EAEU,kBACR,WACA,aACA,8BAKA,UACA,aAAa,OACP;AACN,QAAI,gBAAgB,SAAS;AAC3B,UAAI,UAAU;AACZ,cAAM,IAAI,MAAM,sCAAsC;AAAA,MACxD;AAEA,UAAI,OAAO,iCAAiC,YAAY;AACtD,cAAM,IAAI,MAAM,2CAA2C;AAAA,MAC7D;AAEA,WAAK,OAAO,KAAK;AAAA,QACf;AAAA,QACA,UAAU;AAAA,MAGZ,CAAC;AAED;AAAA,IACF;AAEA,QAAI,gBAAgB,SAAS;AAC3B,UAAI,UAAU;AACZ,cAAM,IAAI,MAAM,sCAAsC;AAAA,MACxD;AAEA,UAAI,OAAO,iCAAiC,YAAY;AACtD,cAAM,IAAI,MAAM,2CAA2C;AAAA,MAC7D;AAEA,WAAK,OAAO,KAAK;AAAA,QACf;AAAA,QACA,UAAU;AAAA,MAGZ,CAAC;AAED;AAAA,IACF;AAEA,QAAI,OAAO,OAAO,YAAY,EAAE,SAAS,WAAkB,GAAG;AAC5D,UAAI,OAAO,iCAAiC,YAAY;AACtD,cAAM,IAAI,MAAM,2CAA2C;AAAA,MAC7D;AAEA,WAAK,UAAU,KAAK;AAAA,QAClB;AAAA,QACA,OAAqB;AAAA,QACrB,UAAU;AAAA,MACZ,CAAC;AAED;AAAA,IACF;AAEA,QAAI,OAAO,iCAAiC,YAAY;AACtD,WAAK,cAAc,KAAK;AAAA,QACtB;AAAA,QACA,MAAM;AAAA,QACN,UAAU;AAAA,MACZ,CAAC;AAAA,IACH,OAAO;AACL,UAAI,OAAO,iCAAiC,UAAU;AACpD,cAAM,IAAI,MAAM,iDAAiD;AAAA,MACnE;AACA,UAAI,OAAO,aAAa,YAAY;AAClC,cAAM,IAAI,MAAM,0CAA0C;AAAA,MAC5D;AAEA,UAAI,YAAY;AACd,mBAAW,OAAO,aAAa,WAAW,QAAQ;AAAA,MACpD;AAEA,WAAK,mBAAmB,KAAK;AAAA,QAC3B;AAAA,QACA,MAAM;AAAA,QACN,KAAK;AAAA,QACL;AAAA,MACF,CAAC;AAAA,IACH;AAAA,EACF;AACF;AAGO,IAAM,0BAAN,cAGG,mBAAmC;AAAA,EAC3C,YAAoB,MAA0C;AAC5D,UAAM;AADY;AAAA,EAEpB;AAAA,EAEU,kBACR,WACA,aACA,8BAKA,UACM;AACN,QACE,gBAAgB,WAChB,gBAAgB,WAChB,OAAO,OAAO,YAAY,EAAE,SAAS,WAAkB,KACvD,OAAO,iCAAiC,YACxC;AACA,YAAM,IAAI,MAAM,wCAAwC;AAAA,IAC1D;AAEA,UAAM;AAAA,MACJ;AAAA,MACA;AAAA,MACA;AAAA,MACA;AAAA,MACA;AAAA,IACF;AAEA,WAAO,MAAM;AACX,YAAM,WAAW,KAAK,mBAAmB,IAAI;AAC7C,UAAI,CAAC,UAAU;AACb;AAAA,MACF;AAEA,WAAK,KAAK,mBAAmB,KAAK,QAAQ;AAAA,IAC5C;AAAA,EACF;AACF;AAYO,IAAM,eAAN,MAGL;AAAA,EACA,YAEU,MAEA,KAEA,QAEA,SACR;AAPQ;AAEA;AAEA;AAEA;AAAA,EACP;AAAA,EAEH,MAAM,QAAuB;AAC3B,UAAM,KAAK,QAAQ,MAAM;AAAA,EAC3B;AAAA,EAEA,WAAW,IAAuD;AAChE,WAAO,KAAK,QAAQ,WAAW,EAAE;AAAA,EACnC;AAAA,EAEA,aAA8C,MAAmB;AAC/D,WAAO,KAAK,OAAO,OAAU,IAAI;AAAA,EACnC;AAAA,EAEA,eACE,MACA,IACA;AACA,WAAO,KAAK,OAAO,OAAU,IAAI,EAAE,IAAI,EAAE;AAAA,EAC3C;AAAA,EAEA,qBACE,MACA,KACA,KACK;AACL,UAAM,SAAS,MAAM,KAAK,KAAK,OAAO,OAAO,IAAI,EAAE,OAAO,CAAC;AAC3D,WAAO,OAAO,OAAO,CAAC,MAAM,EAAE,IAAI,GAAG,MAAM,GAAG;AAAA,EAChD;AAAA,EAEA,YAAY,QAA2C;AACrD,eAAW,SAAS,QAAQ;AAC1B,WAAK,KAAK,SAAS,KAAK;AAAA,IAC1B;AAAA,EACF;AAAA,EAEA,kBAAkB;AAChB,SAAK,KAAK,gBAAgB;AAAA,EAC5B;AAAA,EAEA,eAAe,QAAgB;AAC7B,SAAK,KAAK,eAAe,MAAM;AAAA,EACjC;AAAA;AAAA;AAAA,EAIA,UAAU,OAAwB;AAChC,WAAO,KAAK,IAAI,UAAU,KAAK;AAAA,EACjC;AAAA;AAAA,EAGA,UAAU,OAAwB;AAChC,WAAO,KAAK,IAAI,UAAU,KAAK;AAAA,EACjC;AAAA;AAAA,EAGA,SAAS,OAAoB;AAC3B,WAAO,KAAK,IAAI,SAAS,KAAK;AAAA,EAChC;AAAA;AAAA,EAGA,SAAS,OAAuB;AAC9B,WAAO,KAAK,IAAI,SAAS,KAAK;AAAA,EAChC;AAAA;AAAA,EAGA,eAAe,OAA0B;AACvC,WAAO,KAAK,IAAI,eAAe,KAAK;AAAA,EACtC;AAAA,EAEU,aAAa,IAAe;AACpC,SAAK,IAAI,aAAa,EAAE;AAAA,EAC1B;AAAA;AAAA,EAGA,IAAI,UAAU;AACZ,WAAO,KAAK,IAAI;AAAA,EAClB;AACF;;;AC7cA,IAAAC,kBAAwC;;;ACKjC,SAAS,gBAA4C;AAC1D,MAAI,MAAM,CAAC;AACX,MAAI,UAAU,IAAI,QAAW,CAAC,MAAM;AAClC,QAAI,SAAS;AAAA,EACf,CAAC;AAED,SAAO;AACT;;;ADQA,eAAsB,gBACpB,KACA,aACA,cACA;AACA,MAAI,SAAoC,cAAc;AACtD,MAAI,QAAQ,EAAE,YAAY,CAAC,0BAAU,oBAAoB,EAAE,CAAC,EAAE,UAAU;AAAA,IACtE,KAAK,EAAE,MAAM,KAAK,GAAG;AACnB,UAAI,CAAC,MAAM;AACT,YAAI,MAAM;AACR,cAAI,QAAQ;AACV,oBAAQ,OAAO;AAEf,wBAAY,KAAK,EAAE,MAAM,KAAK,CAAC;AAAA,UACjC;AAEA;AAAA,QACF;AACA,cAAM,sCAAsC;AAE5C;AAAA,MACF;AAEA,UAAI,KAAK,eAAe,eAAe;AACrC,cAAM,uCAAuC;AAE7C;AAAA,MACF;AAEA,YAAM,OAAO;AAAA,QACX,IAAI,KAAK;AAAA,QACT,YAAY,KAAK;AAAA,MACnB;AAEA,mBAAa,IAAI,KAAK,IAAI,IAAI;AAE9B,kBAAY,KAAK;AAAA,QACf,YAAY;AAAA,UACV,aAAa;AAAA,UACb,WAAW;AAAA,QACb;AAAA,QACA;AAAA,MACF,CAAC;AAED,UAAI,UAAU,MAAM;AAClB,eAAO,OAAO;AAAA,MAChB;AAAA,IACF;AAAA,EACF,CAAC;AAED,MAAI,QAAQ,EAAE,YAAY,CAAC,0BAAU,qBAAqB,EAAE,CAAC,EAAE,UAAU;AAAA,IACvE,KAAK,EAAE,KAAK,GAAG;AACb,UAAI,CAAC,MAAM;AACT,cAAM,uCAAuC;AAE7C;AAAA,MACF;AAEA,UAAI,KAAK,eAAe,eAAe;AACrC,cAAM,wCAAwC;AAE9C;AAAA,MACF;AAEA,mBAAa,OAAO,KAAK,EAAE;AAE3B,kBAAY,KAAK;AAAA,QACf,YAAY;AAAA,UACV,aAAa;AAAA,YACX,IAAI,KAAK;AAAA,YACT,YAAY,KAAK;AAAA,UACnB;AAAA,UACA,WAAW;AAAA,QACb;AAAA,QACA,MAAM;AAAA,MACR,CAAC;AAAA,IACH;AAAA,EACF,CAAC;AAED,QAAM,OAAO;AACb,WAAS;AACX;;;AE9FA,IAAAC,eAA0C;;;ACP1C,IAAAC,eAA4C;AAgCrC,IAAM,SAAN,MAIL;AAAA,EAOA,YACE,WACA,UACU,KACA,OACA,YACV;AAHU;AACA;AACA;AAXZ,SAAU,SAAS,oBAAI,IAAoC;AAE3D;AAAA,SAAU,YAAY,oBAAI,IAAqB;AAC/C,SAAU,eAAe,oBAAI,IAAqC;AAClE,SAAU,cAAc,oBAAI,IAAiB;AAS3C,cAAU,UAAU;AAAA,MAClB,MAAM,CAAC,EAAE,OAAO,QAAQ,MAAM;AAC5B,aAAK,OAAO,OAAO,OAAO;AAAA,MAC5B;AAAA,IACF,CAAC;AAED,aAAS,UAAU;AAAA,MACjB,MAAM,CAAC,aAAa;AAClB,aAAK,KAAK,QAAQ;AAAA,MACpB;AAAA,IACF,CAAC;AAAA,EACH;AAAA,EAEA,MAAM,IAA+B;AACnC,WAAO,KAAK,OAAO,IAAI,EAAE,GAAG,SAAS;AAAA,EACvC;AAAA,EAEA,SAAS,IAA2C;AAClD,WAAO,KAAK,OAAO,IAAI,EAAE;AAAA,EAC3B;AAAA,EAEA,OAAwB,MAAmB;AACzC,QAAI,MAAM,KAAK,aAAa,IAAI,IAAI;AACpC,QAAI,CAAC,KAAK;AACR,YAAM,oBAAI,IAAI;AACd,WAAK,aAAa,IAAI,MAAM,GAAG;AAAA,IACjC;AAEA,WAAO;AAAA,EACT;AAAA,EAEA,eAAe,MAA4B;AACzC,WAAO,KAAK,YAAY,IAAI,IAAI;AAAA,EAClC;AAAA,EAEU,KAAK,UAAoB;AACjC,SAAK,YAAY,MAAM;AACvB,eAAW,CAAC,GAAG,YAAY,KAAK,KAAK,QAAQ;AAC3C,YAAM,QAAQ,aAAa,SAAS;AACpC,WACG,MAAM,YAAY,KAAK,WAAW,gBAAgB,MAAM,EAAE,MAC3D,SAAS,SAAS,MAAM,EAAE,GAC1B;AACA,cAAM,WAAW;AACjB,qBAAa,KAAK,KAAK;AAAA,MACzB;AAAA,IACF;AAAA,EACF;AAAA,EAEU,OAAO,OAAmB,SAAkB;AACpD,UAAM,WAAW,KAAK,OAAO,IAAI,MAAM,EAAE,GAAG,SAAS;AAErD,QAAI,SAAS;AACX,UAAI,CAAC,UAAU;AACb,aAAK,oCAAoC,MAAM,IAAI,MAAM,IAAI;AAE7D;AAAA,MACF;AAEA,eAAS,WAAW;AACpB,eAAS,WAAW;AACpB,WAAK,OAAO,OAAO,MAAM,EAAE;AAE3B,UAAI,CAAC,MAAM,MAAM;AACf,aAAK,gDAAgD;AAErD;AAAA,MACF;AAEA,YAAMC,QAAO,MAAM;AAGnB,WAAK,aAAa,IAAIA,KAAI,EAAG,OAAO,MAAM,EAAE;AAE5C,WAAK,YAAY,IAAIA,KAAI;AAEzB;AAAA,IACF;AAEA,QAAI,UAAU;AACZ,eAAS,WAAW;AACpB;AAAA,IACF;AAEA,QAAI,CAAC,MAAM,MAAM;AACf,WAAK,qCAAqC;AAE1C;AAAA,IACF;AAEA,UAAM,OAAO,MAAM;AACnB,UAAM,aAAa,KAAK,MAAM,IAAI;AAClC,QAAI,CAAC,YAAY;AACf,WAAK,+BAA+B,MAAM,MAAM;AAEhD;AAAA,IACF;AAEA,UAAM,MAAM,KAAK,OAAO,YAAY,KAAK;AACzC,UAAM,OAAO,IAAI,6BAAgB,GAAG;AACpC,SAAK,OAAO,IAAI,MAAM,IAAI,IAAI;AAC9B,SAAK,UAAU,IAAI,MAAM,IAAI,IAAI;AAEjC,QAAI,MAAM,KAAK,aAAa,IAAI,IAAI;AACpC,QAAI,CAAC,KAAK;AACR,YAAM,oBAAI,IAAI;AACd,WAAK,aAAa,IAAI,MAAM,GAAG;AAAA,IACjC;AAEA,QAAI,IAAI,MAAM,IAAI,GAAG;AAErB,QAAI,WAAW;AACf,SAAK,YAAY,IAAI,IAAI;AAAA,EAC3B;AAAA,EAEU,OACR,YACA,OACA;AACA,WAAO,IAAI,WAAY,KAAK,KAAK,OAAO,KAAK,UAAU;AAAA,EACzD;AACF;AAQO,IAAM,QAAN,MAGL;AAAA,EAWA,YAIW,KAIA,OAIC,YACV;AATS;AAIA;AAIC;AAnBZ;AAAA;AAAA;AAAA,oBAAW;AAKX;AAAA;AAAA;AAAA,oBAAW;AAAA,EAeR;AAAA,EAEH,IAAI,KAAK;AACP,WAAO,KAAK,MAAM;AAAA,EACpB;AAAA;AAAA;AAAA;AAAA,EAKA,IAAI,OAAO;AAET,WAAO,KAAK,MAAM;AAAA,EACpB;AAAA,EAEA,IAAI,KAAoC;AACtC,WAAO,KAAK,WAAW,UAAU,KAAK,MAAM,IAAI,GAAG,EAAE;AAAA,EACvD;AAAA,EAEA,aAAa,KAAoC;AAC/C,WAAO,KAAK,WAAW,UAAU,KAAK,MAAM,IAAI,GAAG;AAAA,EACrD;AAAA,EAEA,IAAI,KAAgD;AAClD,WAAO,KAAK,WAAW,UAAU,KAAK,MAAM,IAAI,GAAG,EAAE;AAAA,EACvD;AAAA,EAIA,IACE,iBACA,OACA,IACA;AACA,QAAI,OAAO,oBAAoB,UAAU;AACvC,UAAI,UAAU,QAAW;AACvB,gBAAQ;AAAA,MACV;AAEA,aAAO,KAAK,WACT,UAAU,KAAK,MAAM,IAAI,eAAe,EACxC,IAAI,OAAO,EAAE;AAAA,IAClB;AAEA,UAAM,YAAY,CAAC;AACnB,eAAW,QAAQ,iBAAiB;AAClC,YAAM,KAAK,KAAK,WACb,UAAU,KAAK,MAAM,IAAI,KAAK,GAAG,EACjC,SAAS,KAAK,OAAO,KAAK,EAAE;AAC/B,UAAI,CAAC,IAAI;AACP;AAAA,MACF;AAEA,gBAAU,KAAK,EAAE;AAAA,IACnB;AAEA,QAAI,UAAU,WAAW,GAAG;AAC1B;AAAA,IACF;AAEA,SAAK,WAAW,cAAc,SAAS;AAAA,EACzC;AAAA,EAEA,OAAO,KAAa,OAAkB,IAAgC;AACpE,QAAI,CAAC,IAAI;AACP,WAAK,CAAC;AAAA,IACR;AACA,OAAG,SAAS;AAEZ,WAAO,KAAK,WAAW,UAAU,KAAK,MAAM,IAAI,GAAG,EAAE,IAAI,OAAO,EAAE;AAAA,EACpE;AAAA,EAEA,UAAU;AACR,UAAM,QAAQ,KAAK,WAAW,WAAW,KAAK,MAAM,EAAE;AAEtD,UAAM,MAAgD,CAAC;AACvD,eAAW,QAAQ,OAAO;AACxB,UAAI,KAAK,GAAG,IAAI,KAAK;AAAA,IACvB;AAEA,WAAO;AAAA,EACT;AAAA;AAAA;AAAA;AAAA,EAKA,aAAa;AACX,WAAO,KAAK,YAAY,KAAK,WAAW,gBAAgB,KAAK,EAAE;AAAA,EACjE;AACF;;;AD5QO,IAAMC,UAAN,cAGG,OAAoD;AAAA,EAM5D,YACE,WACA,UACA,KACA,OACA,YACS,KACT;AACA,UAAM,WAAW,UAAU,KAAK,OAAO,UAAU;AAFxC;AAXX,SAAQ,WAAW,oBAAI,IAGrB;AAAA,EAWF;AAAA;AAAA,EAGA,cAAc,MAAyD;AACrE,QAAI,MAAM,KAAK,SAAS,IAAI,IAAI;AAChC,QAAI,CAAC,KAAK;AACR,YAAM,IAAI,2BAAwC;AAClD,WAAK,SAAS,IAAI,MAAM,GAAG;AAE3B,YAAM,SAAS,KAAK,OAAO,IAAI;AAE/B,iBAAW,MAAM;AACf,YAAI,OAAO,SAAS,GAAG;AACrB,cAAK,KAAK,EAAE,MAAM,KAAK,CAAC;AAExB;AAAA,QACF;AAEA,YAAI,QAAQ;AACZ,mBAAW,CAAC,GAAG,KAAK,KAAK,QAAQ;AAC/B;AACA,cAAK,KAAK,EAAE,OAAO,MAAM,OAAO,SAAS,MAAM,CAAC;AAAA,QAClD;AAAA,MACF,GAAG,CAAC;AAAA,IACN;AAEA,WAAO;AAAA,EACT;AAAA,EAEU,KAAK,UAAoB;AACjC,eAAW,CAAC,GAAG,kBAAkB,KAAK,KAAK,QAAQ;AACjD,YAAM,QAAQ,mBAAmB,SAAS;AAC1C,UAAI,KAAK,UAAU,IAAI,MAAM,EAAE,KAAK,SAAS,SAAS,MAAM,EAAE,GAAG;AAC/D,cAAM,UAAU,KAAK,SAAS,IAAI,MAAM,IAAI;AAC5C,YAAI,SAAS;AACX,kBAAQ,KAAK,EAAE,OAAO,MAAM,KAAK,CAAC;AAAA,QACpC;AACA,aAAK,UAAU,IAAI,MAAM,IAAI,KAAK;AAAA,MACpC;AAAA,IACF;AAEA,UAAM,KAAK,QAAQ;AAAA,EACrB;AAAA,EAEU,OACR,YACA,OACA;AACA,WAAO,IAAI,WAAY,KAAK,KAAK,OAAO,MAAM,KAAK,UAAU;AAAA,EAI/D;AACF;AAEO,IAAMC,SAAN,cAGG,MAA4B;AAAA,EAMpC,YACE,KACA,OACQ,QACR,YACA;AACA,UAAM,KAAK,OAAO,UAAU;AAHpB;AAIR,SAAK,MAAM,OAAO;AAAA,EACpB;AAAA,EAEU,UACR,IACe;AACf,WAAO,KAAK,OAAO,MAAM,EAAE;AAAA,EAC7B;AAAA,EAEU,WACR,KACe;AACf,UAAM,KAAK,KAAK,IAAI,GAAG;AACvB,QAAI,CAAC,MAAM,OAAO,OAAO,UAAU;AACjC;AAAA,IACF;AAEA,WAAO,KAAK,OAAO,MAAM,EAAE;AAAA,EAC7B;AAAA,EAEU,aACR,MACgB;AAChB,WAAO,KAAK,OAAO,OAAU,IAAI;AAAA,EACnC;AAAA,EAEU,eACR,MACA,IACe;AACf,WAAO,KAAK,OAAO,OAAU,IAAI,EAAE,IAAI,EAAE;AAAA,EAC3C;AAAA,EAEU,qBACR,MACA,KACA,KACK;AACL,UAAM,SAAS,MAAM,KAAK,KAAK,OAAO,OAAO,IAAI,EAAE,OAAO,CAAC;AAC3D,WAAO,OAAO,OAAO,CAAC,MAAM,EAAE,IAAI,GAAG,MAAM,GAAG;AAAA,EAChD;AAAA,EAEU,UAAU,OAAwB;AAC1C,WAAO,KAAK,IAAI,UAAU,KAAK;AAAA,EACjC;AAAA,EAEU,UAAU,OAAwB;AAC1C,WAAO,KAAK,IAAI,UAAU,KAAK;AAAA,EACjC;AAAA,EAEU,SAAS,OAAoB;AACrC,WAAO,KAAK,IAAI,SAAS,KAAK;AAAA,EAChC;AAAA,EAEU,SAAS,OAAuB;AACxC,WAAO,KAAK,IAAI,SAAS,KAAK;AAAA,EAChC;AAAA,EAEU,eAAe,OAA0B;AACjD,WAAO,KAAK,IAAI,eAAe,KAAK;AAAA,EACtC;AAAA,EAEU,aAAa,IAAe;AACpC,SAAK,IAAI,aAAa,EAAE;AAAA,EAC1B;AAAA;AAAA;AAAA;AAAA,EAKA,IAAI,UAAU;AACZ,WAAO,KAAK,IAAI;AAAA,EAClB;AACF;;;AEpLA,SAAS,MAAM,IAAQ;AACrB,SAAO,GAAG,MAAM,MAAM,GAAG;AAC3B;AA4BO,IAAM,gBAAN,MAGL;AAAA,EAHK;AAIL,SAAQ,aAAa,oBAAI,IAAY;AACrC,SAAQ,WAAW,oBAAI,IAAY;AACnC,SAAQ,aAAa,oBAAI,IAAY;AACrC,SAAQ,YAAY,oBAAI,IAAY;AACpC,SAAQ,aAAa,oBAAI,IAAY;AACrC,SAAQ,WAAiB,CAAC;AAC1B,SAAQ,iBAAiB;AACzB,SAAQ,kBAAkB,oBAAI,IAAY;AAC1C,SAAQ,QAAQ;AAChB,SAAO,OAAa;AAAA,MAClB,cAAc;AAAA,MACd,QAAQ;AAAA,QACN,KAAK,CAAC;AAAA,QACN,OAAO,CAAC;AAAA,QACR,OAAO,CAAC;AAAA,QACR,MAAM,CAAC;AAAA,QACP,KAAK,CAAC;AAAA,MACR;AAAA,MACA,aAAa,CAAC;AAAA,IAChB;AAAA;AAAA,EAEA,IAAI,OAAa;AACf,WAAO;AAAA,MACL,cAAc,KAAK;AAAA,MACnB,QAAQ;AAAA,QACN,OAAO,MAAM,KAAK,KAAK,WAAW,OAAO,CAAC;AAAA,QAC1C,KAAK,MAAM,KAAK,KAAK,SAAS,OAAO,CAAC;AAAA,QACtC,OAAO,MAAM,KAAK,KAAK,WAAW,OAAO,CAAC;AAAA,QAC1C,MAAM,MAAM,KAAK,KAAK,UAAU,OAAO,CAAC;AAAA,QACxC,KAAK,CAAC,GAAG,KAAK,QAAQ;AAAA,MACxB;AAAA,MACA,aAAa,MAAM,KAAK,KAAK,gBAAgB,OAAO,CAAC;AAAA,IACvD;AAAA,EACF;AAAA;AAAA,EAGA,UAA4B;AAC1B,QAAI,CAAC,KAAK,OAAO;AACf;AAAA,IACF;AAEA,UAAM,UAAU,KAAK;AACrB,UAAM;AAAA,MACJ,QAAQ,EAAE,KAAK,OAAO,OAAO,MAAM,IAAI;AAAA,MACvC;AAAA,MACA;AAAA,IACF,IAAI,KAAK;AAET,UAAM,UAAU,IAAI,IAAI,CAAC,OAAO,MAAM,EAAE,CAAC;AAEzC,UAAM,OAAO;AAAA,MACX,cAAc,KAAK,kBAAkB,CAAC;AAAA,MACtC,QAAQ;AAAA,QACN,KAAK,QAAQ,OAAO,IAAI,OAAO,CAAC,OAAO,CAAC,IAAI,SAAS,EAAE,CAAC;AAAA,QACxD,OAAO,QAAQ,OAAO,MAAM,OAAO,CAAC,SAAS,CAAC,MAAM,SAAS,IAAI,CAAC;AAAA,QAClE,OAAO,QAAQ,OAAO,MAAM,OAAO,CAAC,SAAS,CAAC,MAAM,SAAS,IAAI,CAAC;AAAA,QAClE,MAAM,QAAQ,OAAO,KAAK,OAAO,CAAC,QAAQ,CAAC,KAAK,SAAS,GAAG,CAAC;AAAA,QAC7D,KAAK,QAAQ,OAAO,IAAI,OAAO,CAAC,OAAO,CAAC,QAAQ,SAAS,MAAM,EAAE,CAAC,CAAC;AAAA,MACrE;AAAA,MACA,aAAa,QAAQ,YAAY;AAAA,QAC/B,CAAC,OAAO,CAAC,YAAY,SAAS,EAAE;AAAA,MAClC;AAAA,IACF;AAEA,SAAK,OAAO;AACZ,SAAK,QAAQ;AAEb,WAAO;AAAA,EACT;AAAA,EAEA,SAAS,OAAwC;AAC/C,QAAI,MAAM,KAAK;AACb,iBAAW,MAAM,MAAM,KAAK;AAC1B,YAAI,CAAC,KAAK,SAAS,IAAI,EAAE,GAAG;AAC1B,eAAK,SAAS,IAAI,EAAE;AACpB,eAAK,QAAQ;AAAA,QACf;AAAA,MACF;AAAA,IACF;AAEA,QAAI,MAAM,OAAO;AACf,iBAAW,MAAM,MAAM,OAAO;AAC5B,YAAI,CAAC,KAAK,WAAW,IAAI,EAAE,GAAG;AAC5B,eAAK,WAAW,IAAI,EAAE;AACtB,eAAK,QAAQ;AAAA,QACf;AAAA,MACF;AAAA,IACF;AAEA,QAAI,MAAM,OAAO;AACf,iBAAW,QAAQ,MAAM,OAAO;AAC9B,YAAI,CAAC,KAAK,WAAW,IAAI,IAAI,GAAG;AAC9B,eAAK,WAAW,IAAI,IAAI;AACxB,eAAK,QAAQ;AAAA,QACf;AAAA,MACF;AAAA,IACF;AAEA,QAAI,MAAM,MAAM;AACd,iBAAW,OAAO,MAAM,MAAM;AAC5B,YAAI,CAAC,KAAK,UAAU,IAAI,GAAG,GAAG;AAC5B,eAAK,UAAU,IAAI,GAAG;AACtB,eAAK,QAAQ;AAAA,QACf;AAAA,MACF;AAAA,IACF;AAEA,QAAI,MAAM,KAAK;AACb,iBAAW,MAAM,MAAM,KAAK;AAC1B,cAAM,QAAQ,MAAM,EAAE;AACtB,YAAI,CAAC,KAAK,WAAW,IAAI,KAAK,GAAG;AAC/B,eAAK,WAAW,IAAI,KAAK;AACzB,eAAK,SAAS,KAAK,EAAE;AACrB,eAAK,QAAQ;AAAA,QACf;AAAA,MACF;AAAA,IACF;AAAA,EACF;AAAA,EAEA,kBAAkB;AAChB,QAAI,CAAC,KAAK,gBAAgB;AACxB,WAAK,QAAQ;AACb,WAAK,iBAAiB;AAAA,IACxB;AAAA,EACF;AAAA,EAEA,eAAe,QAAgB;AAC7B,QAAI,CAAC,KAAK,gBAAgB,IAAI,MAAM,GAAG;AACrC,WAAK,gBAAgB,IAAI,MAAM;AAC/B,WAAK,QAAQ;AAAA,IACf;AAAA,EACF;AACF;;;AC7KA,IAAAC,kBAA+C;AAmBxC,SAAS,eACd,KACA,aACA,QACA;AACA,MAAI,QAAQ,EAAE,YAAY,CAAC,0BAAU,aAAa,GAAG,OAAO,CAAC,EAAE,UAAU;AAAA,IACvE,KAAK,EAAE,KAAK,GAAG;AACb,UAAI,CAAC,MAAM;AACT;AAAA,MACF;AAEA,UAAI,KAAK,eAAe,cAAc;AACpC,cAAM,yBAAyB;AAE/B;AAAA,MACF;AAEA,UAAI,KAAK,KAAK,eAAe,QAAQ;AACnC,cAAM,gCAAgC,KAAK,IAAI;AAE/C;AAAA,MACF;AAEA,kBAAY,KAAK;AAAA,QACf,IAAI,KAAK;AAAA,QACT,IAAI,KAAK;AAAA,QACT,MAAM,KAAK;AAAA,QACX,MAAM;AAAA,UACJ,IAAI,KAAK,KAAK;AAAA,UACd,UAAU,KAAK,KAAK;AAAA,UACpB,OAAO,KAAK,KAAK;AAAA,QACnB;AAAA,MACF,CAAC;AAAA,IACH;AAAA,EACF,CAAC;AACH;","names":["Attributes","Scope","Scopes","error","attr","newAttr","value","import_rxjs","import_rxjs","Attributes","_","import_rxjs","import_rxjs","error","TajribaEvent","import_tajriba","import_rxjs","import_rxjs","kind","Scopes","Scope","import_tajriba"]}