{"version":3,"file":"communication-DGC02tEU.cjs","names":["MessageType$","Struct","UnknownFieldHandler","WireType","Span","Timestamp","key: keyof GetMockRequest[\"tags\"] | undefined","val: GetMockRequest[\"tags\"][any] | undefined","MatchLevel","key: keyof EnvVarResponse[\"envVars\"] | undefined","val: EnvVarResponse[\"envVars\"][any] | undefined","key: keyof CoverageSnapshotResponse[\"coverage\"] | undefined","val: CoverageSnapshotResponse[\"coverage\"][any] | undefined","key: keyof FileCoverageData[\"lines\"] | undefined","val: FileCoverageData[\"lines\"][any] | undefined","key: keyof FileCoverageData[\"branches\"] | undefined","val: FileCoverageData[\"branches\"][any] | undefined","ServiceType"],"sources":["../generated/ts/core/communication.ts"],"sourcesContent":["// @generated by protobuf-ts 2.11.1 with parameter generate_dependencies\n// @generated from protobuf file \"core/communication.proto\" (package \"tusk.drift.core.v1\", syntax proto3)\n// tslint:disable\nimport { ServiceType } from \"@protobuf-ts/runtime-rpc\";\nimport type { BinaryWriteOptions } from \"@protobuf-ts/runtime\";\nimport type { IBinaryWriter } from \"@protobuf-ts/runtime\";\nimport { WireType } from \"@protobuf-ts/runtime\";\nimport type { BinaryReadOptions } from \"@protobuf-ts/runtime\";\nimport type { IBinaryReader } from \"@protobuf-ts/runtime\";\nimport { UnknownFieldHandler } from \"@protobuf-ts/runtime\";\nimport type { PartialMessage } from \"@protobuf-ts/runtime\";\nimport { reflectionMergePartial } from \"@protobuf-ts/runtime\";\nimport { MessageType as MessageType$ } from \"@protobuf-ts/runtime\";\nimport { MatchLevel } from \"./span\";\nimport { Timestamp } from \"../google/protobuf/timestamp\";\nimport { Span } from \"./span\";\nimport { Struct } from \"../google/protobuf/struct\";\n/**\n * SDK connection handshake\n *\n * @generated from protobuf message tusk.drift.core.v1.ConnectRequest\n */\nexport interface ConnectRequest {\n /**\n * @generated from protobuf field: string service_id = 1\n */\n serviceId: string;\n /**\n * @generated from protobuf field: string sdk_version = 2\n */\n sdkVersion: string;\n /**\n * @generated from protobuf field: string min_cli_version = 3\n */\n minCliVersion: string;\n /**\n * @generated from protobuf field: google.protobuf.Struct metadata = 4\n */\n metadata?: Struct; // Additional metadata (JSON-serializable)\n /**\n * @generated from protobuf field: tusk.drift.core.v1.Runtime runtime = 5\n */\n runtime: Runtime; // SDK runtime (node, python)\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.ConnectResponse\n */\nexport interface ConnectResponse {\n /**\n * @generated from protobuf field: bool success = 1\n */\n success: boolean;\n /**\n * @generated from protobuf field: string error = 2\n */\n error: string;\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.GetMockRequest\n */\nexport interface GetMockRequest {\n /**\n * @generated from protobuf field: string request_id = 1\n */\n requestId: string; // For async correlation (used in CLI)\n /**\n * @generated from protobuf field: string test_id = 2\n */\n testId: string; // Trace/test identifier\n /**\n * @generated from protobuf field: tusk.drift.core.v1.Span outbound_span = 3\n */\n outboundSpan?: Span;\n /**\n * @generated from protobuf field: string stack_trace = 4\n */\n stackTrace: string;\n /**\n * @generated from protobuf field: string operation = 5\n */\n operation: string; // \"GET\", \"query\", \"execute\", \"get\", etc.\n /**\n * @generated from protobuf field: map tags = 6\n */\n tags: {\n [key: string]: string;\n }; // Generic key-value metadata\n /**\n * @generated from protobuf field: google.protobuf.Timestamp requested_at = 7\n */\n requestedAt?: Timestamp;\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.GetMockResponse\n */\nexport interface GetMockResponse {\n /**\n * @generated from protobuf field: string request_id = 1\n */\n requestId: string; // Correlate with request\n /**\n * @generated from protobuf field: bool found = 2\n */\n found: boolean; // Whether mock was found\n /**\n * Opaque response data - CLI returns as-is from stored spans\n *\n * @generated from protobuf field: google.protobuf.Struct response_data = 3\n */\n responseData?: Struct; // Response payload\n /**\n * @generated from protobuf field: google.protobuf.Struct metadata = 4\n */\n metadata?: Struct; // Response metadata (headers, status, etc.)\n /**\n * Error information\n *\n * @generated from protobuf field: string error = 5\n */\n error: string; // Error message if not found\n /**\n * @generated from protobuf field: string error_code = 6\n */\n errorCode: string; // Error classification\n /**\n * Mock metadata\n *\n * @generated from protobuf field: string matched_span_id = 7\n */\n matchedSpanId: string; // Which span was matched\n /**\n * @generated from protobuf field: google.protobuf.Timestamp matched_at = 8\n */\n matchedAt?: Timestamp; // When the match occurred\n /**\n * Match information (populated when found=true)\n *\n * @generated from protobuf field: optional tusk.drift.core.v1.MatchLevel match_level = 9\n */\n matchLevel?: MatchLevel;\n}\n/**\n * Message types for the Unix socket protocol\n *\n * @generated from protobuf message tusk.drift.core.v1.SDKMessage\n */\nexport interface SDKMessage {\n /**\n * @generated from protobuf field: tusk.drift.core.v1.MessageType type = 1\n */\n type: MessageType;\n /**\n * @generated from protobuf field: string request_id = 2\n */\n requestId: string;\n /**\n * @generated from protobuf oneof: payload\n */\n payload: {\n oneofKind: \"connectRequest\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.ConnectRequest connect_request = 3\n */\n connectRequest: ConnectRequest;\n } | {\n oneofKind: \"getMockRequest\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.GetMockRequest get_mock_request = 4\n */\n getMockRequest: GetMockRequest;\n } | {\n oneofKind: \"sendInboundSpanForReplayRequest\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.SendInboundSpanForReplayRequest send_inbound_span_for_replay_request = 5\n */\n sendInboundSpanForReplayRequest: SendInboundSpanForReplayRequest;\n } | {\n oneofKind: \"sendAlertRequest\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.SendAlertRequest send_alert_request = 6\n */\n sendAlertRequest: SendAlertRequest;\n } | {\n oneofKind: \"envVarRequest\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.EnvVarRequest env_var_request = 7\n */\n envVarRequest: EnvVarRequest;\n } | {\n oneofKind: \"setTimeTravelResponse\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.SetTimeTravelResponse set_time_travel_response = 8\n */\n setTimeTravelResponse: SetTimeTravelResponse;\n } | {\n oneofKind: \"coverageSnapshotResponse\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.CoverageSnapshotResponse coverage_snapshot_response = 9\n */\n coverageSnapshotResponse: CoverageSnapshotResponse;\n } | {\n oneofKind: undefined;\n };\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.CLIMessage\n */\nexport interface CLIMessage {\n /**\n * @generated from protobuf field: tusk.drift.core.v1.MessageType type = 1\n */\n type: MessageType;\n /**\n * @generated from protobuf field: string request_id = 2\n */\n requestId: string;\n /**\n * @generated from protobuf oneof: payload\n */\n payload: {\n oneofKind: \"connectResponse\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.ConnectResponse connect_response = 3\n */\n connectResponse: ConnectResponse;\n } | {\n oneofKind: \"getMockResponse\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.GetMockResponse get_mock_response = 4\n */\n getMockResponse: GetMockResponse;\n } | {\n oneofKind: \"sendInboundSpanForReplayResponse\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.SendInboundSpanForReplayResponse send_inbound_span_for_replay_response = 5\n */\n sendInboundSpanForReplayResponse: SendInboundSpanForReplayResponse;\n } | {\n oneofKind: \"envVarResponse\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.EnvVarResponse env_var_response = 6\n */\n envVarResponse: EnvVarResponse;\n } | {\n oneofKind: \"setTimeTravelRequest\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.SetTimeTravelRequest set_time_travel_request = 7\n */\n setTimeTravelRequest: SetTimeTravelRequest;\n } | {\n oneofKind: \"coverageSnapshotRequest\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.CoverageSnapshotRequest coverage_snapshot_request = 8\n */\n coverageSnapshotRequest: CoverageSnapshotRequest;\n } | {\n oneofKind: undefined;\n };\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.SendInboundSpanForReplayRequest\n */\nexport interface SendInboundSpanForReplayRequest {\n /**\n * @generated from protobuf field: tusk.drift.core.v1.Span span = 1\n */\n span?: Span;\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.SendInboundSpanForReplayResponse\n */\nexport interface SendInboundSpanForReplayResponse {\n /**\n * @generated from protobuf field: bool success = 1\n */\n success: boolean;\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.SendAlertRequest\n */\nexport interface SendAlertRequest {\n /**\n * @generated from protobuf oneof: alert\n */\n alert: {\n oneofKind: \"versionMismatch\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.InstrumentationVersionMismatchAlert version_mismatch = 1\n */\n versionMismatch: InstrumentationVersionMismatchAlert;\n } | {\n oneofKind: \"unpatchedDependency\";\n /**\n * @generated from protobuf field: tusk.drift.core.v1.UnpatchedDependencyAlert unpatched_dependency = 2\n */\n unpatchedDependency: UnpatchedDependencyAlert;\n } | {\n oneofKind: undefined;\n };\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.InstrumentationVersionMismatchAlert\n */\nexport interface InstrumentationVersionMismatchAlert {\n /**\n * @generated from protobuf field: string module_name = 1\n */\n moduleName: string;\n /**\n * @generated from protobuf field: string requested_version = 2\n */\n requestedVersion: string; // Can be empty if version not found\n /**\n * @generated from protobuf field: repeated string supported_versions = 3\n */\n supportedVersions: string[];\n /**\n * @generated from protobuf field: string sdk_version = 4\n */\n sdkVersion: string;\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.UnpatchedDependencyAlert\n */\nexport interface UnpatchedDependencyAlert {\n /**\n * @generated from protobuf field: string stack_trace = 1\n */\n stackTrace: string;\n /**\n * @generated from protobuf field: string trace_test_server_span_id = 2\n */\n traceTestServerSpanId: string;\n /**\n * @generated from protobuf field: string sdk_version = 3\n */\n sdkVersion: string;\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.EnvVarRequest\n */\nexport interface EnvVarRequest {\n /**\n * @generated from protobuf field: string trace_test_server_span_id = 1\n */\n traceTestServerSpanId: string;\n}\n/**\n * @generated from protobuf message tusk.drift.core.v1.EnvVarResponse\n */\nexport interface EnvVarResponse {\n /**\n * @generated from protobuf field: map env_vars = 1\n */\n envVars: {\n [key: string]: string;\n };\n}\n/**\n * Request from CLI to SDK to start time travel before request replay\n * Currently only used for python SDK\n *\n * @generated from protobuf message tusk.drift.core.v1.SetTimeTravelRequest\n */\nexport interface SetTimeTravelRequest {\n /**\n * Unix timestamp in seconds (can include fractional seconds)\n *\n * @generated from protobuf field: double timestamp_seconds = 1\n */\n timestampSeconds: number;\n /**\n * The trace ID this time travel is for (for debugging/logging)\n *\n * @generated from protobuf field: string trace_id = 2\n */\n traceId: string;\n /**\n * Description of why this timestamp was chosen: \"first_span\" or \"server_span\"\n *\n * @generated from protobuf field: string timestamp_source = 3\n */\n timestampSource: string;\n}\n/**\n * Response from SDK acknowledging time travel was set\n *\n * @generated from protobuf message tusk.drift.core.v1.SetTimeTravelResponse\n */\nexport interface SetTimeTravelResponse {\n /**\n * @generated from protobuf field: bool success = 1\n */\n success: boolean;\n /**\n * @generated from protobuf field: string error = 2\n */\n error: string;\n}\n/**\n * Request from CLI to SDK to take a coverage snapshot.\n * CLI sends this between tests to collect per-test coverage data.\n *\n * @generated from protobuf message tusk.drift.core.v1.CoverageSnapshotRequest\n */\nexport interface CoverageSnapshotRequest {\n /**\n * If true, returns ALL coverable lines (including uncovered at count=0)\n * for computing the total coverage denominator.\n * If false, returns only lines executed since the last snapshot (per-test data).\n *\n * @generated from protobuf field: bool baseline = 1\n */\n baseline: boolean;\n}\n/**\n * Response from SDK with coverage data.\n *\n * @generated from protobuf message tusk.drift.core.v1.CoverageSnapshotResponse\n */\nexport interface CoverageSnapshotResponse {\n /**\n * @generated from protobuf field: bool success = 1\n */\n success: boolean;\n /**\n * @generated from protobuf field: string error = 2\n */\n error: string;\n /**\n * Per-file coverage data. File paths are absolute (CLI normalizes to repo-relative).\n *\n * @generated from protobuf field: map coverage = 3\n */\n coverage: {\n [key: string]: FileCoverageData;\n };\n}\n/**\n * Coverage data for a single file.\n *\n * @generated from protobuf message tusk.drift.core.v1.FileCoverageData\n */\nexport interface FileCoverageData {\n /**\n * Line-level coverage: lineNumber (as string) -> execution count.\n * count > 0 = covered, count = 0 = coverable but uncovered (baseline only).\n *\n * @generated from protobuf field: map lines = 1\n */\n lines: {\n [key: string]: number;\n };\n /**\n * Branch coverage aggregate for this file.\n *\n * @generated from protobuf field: int32 total_branches = 2\n */\n totalBranches: number;\n /**\n * @generated from protobuf field: int32 covered_branches = 3\n */\n coveredBranches: number;\n /**\n * Per-line branch detail (e.g., \"line 5: 1/2 branches taken\").\n *\n * @generated from protobuf field: map branches = 4\n */\n branches: {\n [key: string]: BranchInfo;\n };\n}\n/**\n * Branch coverage at a specific line.\n *\n * @generated from protobuf message tusk.drift.core.v1.BranchInfo\n */\nexport interface BranchInfo {\n /**\n * @generated from protobuf field: int32 total = 1\n */\n total: number; // total branches at this line (usually 2 for if/else)\n /**\n * @generated from protobuf field: int32 covered = 2\n */\n covered: number; // branches with count > 0\n}\n/**\n * SDK runtime environment\n *\n * @generated from protobuf enum tusk.drift.core.v1.Runtime\n */\nexport enum Runtime {\n /**\n * @generated from protobuf enum value: RUNTIME_UNSPECIFIED = 0;\n */\n UNSPECIFIED = 0,\n /**\n * @generated from protobuf enum value: RUNTIME_NODE = 1;\n */\n NODE = 1,\n /**\n * @generated from protobuf enum value: RUNTIME_PYTHON = 2;\n */\n PYTHON = 2\n}\n/**\n * @generated from protobuf enum tusk.drift.core.v1.MessageType\n */\nexport enum MessageType {\n /**\n * @generated from protobuf enum value: MESSAGE_TYPE_UNSPECIFIED = 0;\n */\n UNSPECIFIED = 0,\n /**\n * @generated from protobuf enum value: MESSAGE_TYPE_SDK_CONNECT = 1;\n */\n SDK_CONNECT = 1,\n /**\n * @generated from protobuf enum value: MESSAGE_TYPE_MOCK_REQUEST = 2;\n */\n MOCK_REQUEST = 2,\n /**\n * @generated from protobuf enum value: MESSAGE_TYPE_INBOUND_SPAN = 3;\n */\n INBOUND_SPAN = 3,\n /**\n * @generated from protobuf enum value: MESSAGE_TYPE_ALERT = 4;\n */\n ALERT = 4,\n /**\n * @generated from protobuf enum value: MESSAGE_TYPE_ENV_VAR_REQUEST = 5;\n */\n ENV_VAR_REQUEST = 5,\n /**\n * @generated from protobuf enum value: MESSAGE_TYPE_SET_TIME_TRAVEL = 6;\n */\n SET_TIME_TRAVEL = 6,\n /**\n * @generated from protobuf enum value: MESSAGE_TYPE_COVERAGE_SNAPSHOT = 7;\n */\n COVERAGE_SNAPSHOT = 7\n}\n// @generated message type with reflection information, may provide speed optimized methods\nclass ConnectRequest$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.ConnectRequest\", [\n { no: 1, name: \"service_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 2, name: \"sdk_version\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 3, name: \"min_cli_version\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 4, name: \"metadata\", kind: \"message\", T: () => Struct },\n { no: 5, name: \"runtime\", kind: \"enum\", T: () => [\"tusk.drift.core.v1.Runtime\", Runtime, \"RUNTIME_\"] }\n ]);\n }\n create(value?: PartialMessage): ConnectRequest {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.serviceId = \"\";\n message.sdkVersion = \"\";\n message.minCliVersion = \"\";\n message.runtime = 0;\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ConnectRequest): ConnectRequest {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* string service_id */ 1:\n message.serviceId = reader.string();\n break;\n case /* string sdk_version */ 2:\n message.sdkVersion = reader.string();\n break;\n case /* string min_cli_version */ 3:\n message.minCliVersion = reader.string();\n break;\n case /* google.protobuf.Struct metadata */ 4:\n message.metadata = Struct.internalBinaryRead(reader, reader.uint32(), options, message.metadata);\n break;\n case /* tusk.drift.core.v1.Runtime runtime */ 5:\n message.runtime = reader.int32();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: ConnectRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* string service_id = 1; */\n if (message.serviceId !== \"\")\n writer.tag(1, WireType.LengthDelimited).string(message.serviceId);\n /* string sdk_version = 2; */\n if (message.sdkVersion !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.sdkVersion);\n /* string min_cli_version = 3; */\n if (message.minCliVersion !== \"\")\n writer.tag(3, WireType.LengthDelimited).string(message.minCliVersion);\n /* google.protobuf.Struct metadata = 4; */\n if (message.metadata)\n Struct.internalBinaryWrite(message.metadata, writer.tag(4, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.Runtime runtime = 5; */\n if (message.runtime !== 0)\n writer.tag(5, WireType.Varint).int32(message.runtime);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.ConnectRequest\n */\nexport const ConnectRequest = new ConnectRequest$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass ConnectResponse$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.ConnectResponse\", [\n { no: 1, name: \"success\", kind: \"scalar\", T: 8 /*ScalarType.BOOL*/ },\n { no: 2, name: \"error\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ }\n ]);\n }\n create(value?: PartialMessage): ConnectResponse {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.success = false;\n message.error = \"\";\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ConnectResponse): ConnectResponse {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* bool success */ 1:\n message.success = reader.bool();\n break;\n case /* string error */ 2:\n message.error = reader.string();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: ConnectResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* bool success = 1; */\n if (message.success !== false)\n writer.tag(1, WireType.Varint).bool(message.success);\n /* string error = 2; */\n if (message.error !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.error);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.ConnectResponse\n */\nexport const ConnectResponse = new ConnectResponse$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass GetMockRequest$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.GetMockRequest\", [\n { no: 1, name: \"request_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 2, name: \"test_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 3, name: \"outbound_span\", kind: \"message\", T: () => Span },\n { no: 4, name: \"stack_trace\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 5, name: \"operation\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 6, name: \"tags\", kind: \"map\", K: 9 /*ScalarType.STRING*/, V: { kind: \"scalar\", T: 9 /*ScalarType.STRING*/ } },\n { no: 7, name: \"requested_at\", kind: \"message\", T: () => Timestamp }\n ]);\n }\n create(value?: PartialMessage): GetMockRequest {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.requestId = \"\";\n message.testId = \"\";\n message.stackTrace = \"\";\n message.operation = \"\";\n message.tags = {};\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetMockRequest): GetMockRequest {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* string request_id */ 1:\n message.requestId = reader.string();\n break;\n case /* string test_id */ 2:\n message.testId = reader.string();\n break;\n case /* tusk.drift.core.v1.Span outbound_span */ 3:\n message.outboundSpan = Span.internalBinaryRead(reader, reader.uint32(), options, message.outboundSpan);\n break;\n case /* string stack_trace */ 4:\n message.stackTrace = reader.string();\n break;\n case /* string operation */ 5:\n message.operation = reader.string();\n break;\n case /* map tags */ 6:\n this.binaryReadMap6(message.tags, reader, options);\n break;\n case /* google.protobuf.Timestamp requested_at */ 7:\n message.requestedAt = Timestamp.internalBinaryRead(reader, reader.uint32(), options, message.requestedAt);\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n private binaryReadMap6(map: GetMockRequest[\"tags\"], reader: IBinaryReader, options: BinaryReadOptions): void {\n let len = reader.uint32(), end = reader.pos + len, key: keyof GetMockRequest[\"tags\"] | undefined, val: GetMockRequest[\"tags\"][any] | undefined;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case 1:\n key = reader.string();\n break;\n case 2:\n val = reader.string();\n break;\n default: throw new globalThis.Error(\"unknown map entry field for tusk.drift.core.v1.GetMockRequest.tags\");\n }\n }\n map[key ?? \"\"] = val ?? \"\";\n }\n internalBinaryWrite(message: GetMockRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* string request_id = 1; */\n if (message.requestId !== \"\")\n writer.tag(1, WireType.LengthDelimited).string(message.requestId);\n /* string test_id = 2; */\n if (message.testId !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.testId);\n /* tusk.drift.core.v1.Span outbound_span = 3; */\n if (message.outboundSpan)\n Span.internalBinaryWrite(message.outboundSpan, writer.tag(3, WireType.LengthDelimited).fork(), options).join();\n /* string stack_trace = 4; */\n if (message.stackTrace !== \"\")\n writer.tag(4, WireType.LengthDelimited).string(message.stackTrace);\n /* string operation = 5; */\n if (message.operation !== \"\")\n writer.tag(5, WireType.LengthDelimited).string(message.operation);\n /* map tags = 6; */\n for (let k of globalThis.Object.keys(message.tags))\n writer.tag(6, WireType.LengthDelimited).fork().tag(1, WireType.LengthDelimited).string(k).tag(2, WireType.LengthDelimited).string(message.tags[k]).join();\n /* google.protobuf.Timestamp requested_at = 7; */\n if (message.requestedAt)\n Timestamp.internalBinaryWrite(message.requestedAt, writer.tag(7, WireType.LengthDelimited).fork(), options).join();\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.GetMockRequest\n */\nexport const GetMockRequest = new GetMockRequest$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass GetMockResponse$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.GetMockResponse\", [\n { no: 1, name: \"request_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 2, name: \"found\", kind: \"scalar\", T: 8 /*ScalarType.BOOL*/ },\n { no: 3, name: \"response_data\", kind: \"message\", T: () => Struct },\n { no: 4, name: \"metadata\", kind: \"message\", T: () => Struct },\n { no: 5, name: \"error\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 6, name: \"error_code\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 7, name: \"matched_span_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 8, name: \"matched_at\", kind: \"message\", T: () => Timestamp },\n { no: 9, name: \"match_level\", kind: \"message\", T: () => MatchLevel }\n ]);\n }\n create(value?: PartialMessage): GetMockResponse {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.requestId = \"\";\n message.found = false;\n message.error = \"\";\n message.errorCode = \"\";\n message.matchedSpanId = \"\";\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetMockResponse): GetMockResponse {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* string request_id */ 1:\n message.requestId = reader.string();\n break;\n case /* bool found */ 2:\n message.found = reader.bool();\n break;\n case /* google.protobuf.Struct response_data */ 3:\n message.responseData = Struct.internalBinaryRead(reader, reader.uint32(), options, message.responseData);\n break;\n case /* google.protobuf.Struct metadata */ 4:\n message.metadata = Struct.internalBinaryRead(reader, reader.uint32(), options, message.metadata);\n break;\n case /* string error */ 5:\n message.error = reader.string();\n break;\n case /* string error_code */ 6:\n message.errorCode = reader.string();\n break;\n case /* string matched_span_id */ 7:\n message.matchedSpanId = reader.string();\n break;\n case /* google.protobuf.Timestamp matched_at */ 8:\n message.matchedAt = Timestamp.internalBinaryRead(reader, reader.uint32(), options, message.matchedAt);\n break;\n case /* optional tusk.drift.core.v1.MatchLevel match_level */ 9:\n message.matchLevel = MatchLevel.internalBinaryRead(reader, reader.uint32(), options, message.matchLevel);\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: GetMockResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* string request_id = 1; */\n if (message.requestId !== \"\")\n writer.tag(1, WireType.LengthDelimited).string(message.requestId);\n /* bool found = 2; */\n if (message.found !== false)\n writer.tag(2, WireType.Varint).bool(message.found);\n /* google.protobuf.Struct response_data = 3; */\n if (message.responseData)\n Struct.internalBinaryWrite(message.responseData, writer.tag(3, WireType.LengthDelimited).fork(), options).join();\n /* google.protobuf.Struct metadata = 4; */\n if (message.metadata)\n Struct.internalBinaryWrite(message.metadata, writer.tag(4, WireType.LengthDelimited).fork(), options).join();\n /* string error = 5; */\n if (message.error !== \"\")\n writer.tag(5, WireType.LengthDelimited).string(message.error);\n /* string error_code = 6; */\n if (message.errorCode !== \"\")\n writer.tag(6, WireType.LengthDelimited).string(message.errorCode);\n /* string matched_span_id = 7; */\n if (message.matchedSpanId !== \"\")\n writer.tag(7, WireType.LengthDelimited).string(message.matchedSpanId);\n /* google.protobuf.Timestamp matched_at = 8; */\n if (message.matchedAt)\n Timestamp.internalBinaryWrite(message.matchedAt, writer.tag(8, WireType.LengthDelimited).fork(), options).join();\n /* optional tusk.drift.core.v1.MatchLevel match_level = 9; */\n if (message.matchLevel)\n MatchLevel.internalBinaryWrite(message.matchLevel, writer.tag(9, WireType.LengthDelimited).fork(), options).join();\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.GetMockResponse\n */\nexport const GetMockResponse = new GetMockResponse$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass SDKMessage$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.SDKMessage\", [\n { no: 1, name: \"type\", kind: \"enum\", T: () => [\"tusk.drift.core.v1.MessageType\", MessageType, \"MESSAGE_TYPE_\"] },\n { no: 2, name: \"request_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 3, name: \"connect_request\", kind: \"message\", oneof: \"payload\", T: () => ConnectRequest },\n { no: 4, name: \"get_mock_request\", kind: \"message\", oneof: \"payload\", T: () => GetMockRequest },\n { no: 5, name: \"send_inbound_span_for_replay_request\", kind: \"message\", oneof: \"payload\", T: () => SendInboundSpanForReplayRequest },\n { no: 6, name: \"send_alert_request\", kind: \"message\", oneof: \"payload\", T: () => SendAlertRequest },\n { no: 7, name: \"env_var_request\", kind: \"message\", oneof: \"payload\", T: () => EnvVarRequest },\n { no: 8, name: \"set_time_travel_response\", kind: \"message\", oneof: \"payload\", T: () => SetTimeTravelResponse },\n { no: 9, name: \"coverage_snapshot_response\", kind: \"message\", oneof: \"payload\", T: () => CoverageSnapshotResponse }\n ]);\n }\n create(value?: PartialMessage): SDKMessage {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.type = 0;\n message.requestId = \"\";\n message.payload = { oneofKind: undefined };\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SDKMessage): SDKMessage {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* tusk.drift.core.v1.MessageType type */ 1:\n message.type = reader.int32();\n break;\n case /* string request_id */ 2:\n message.requestId = reader.string();\n break;\n case /* tusk.drift.core.v1.ConnectRequest connect_request */ 3:\n message.payload = {\n oneofKind: \"connectRequest\",\n connectRequest: ConnectRequest.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).connectRequest)\n };\n break;\n case /* tusk.drift.core.v1.GetMockRequest get_mock_request */ 4:\n message.payload = {\n oneofKind: \"getMockRequest\",\n getMockRequest: GetMockRequest.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).getMockRequest)\n };\n break;\n case /* tusk.drift.core.v1.SendInboundSpanForReplayRequest send_inbound_span_for_replay_request */ 5:\n message.payload = {\n oneofKind: \"sendInboundSpanForReplayRequest\",\n sendInboundSpanForReplayRequest: SendInboundSpanForReplayRequest.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).sendInboundSpanForReplayRequest)\n };\n break;\n case /* tusk.drift.core.v1.SendAlertRequest send_alert_request */ 6:\n message.payload = {\n oneofKind: \"sendAlertRequest\",\n sendAlertRequest: SendAlertRequest.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).sendAlertRequest)\n };\n break;\n case /* tusk.drift.core.v1.EnvVarRequest env_var_request */ 7:\n message.payload = {\n oneofKind: \"envVarRequest\",\n envVarRequest: EnvVarRequest.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).envVarRequest)\n };\n break;\n case /* tusk.drift.core.v1.SetTimeTravelResponse set_time_travel_response */ 8:\n message.payload = {\n oneofKind: \"setTimeTravelResponse\",\n setTimeTravelResponse: SetTimeTravelResponse.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).setTimeTravelResponse)\n };\n break;\n case /* tusk.drift.core.v1.CoverageSnapshotResponse coverage_snapshot_response */ 9:\n message.payload = {\n oneofKind: \"coverageSnapshotResponse\",\n coverageSnapshotResponse: CoverageSnapshotResponse.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).coverageSnapshotResponse)\n };\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: SDKMessage, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* tusk.drift.core.v1.MessageType type = 1; */\n if (message.type !== 0)\n writer.tag(1, WireType.Varint).int32(message.type);\n /* string request_id = 2; */\n if (message.requestId !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.requestId);\n /* tusk.drift.core.v1.ConnectRequest connect_request = 3; */\n if (message.payload.oneofKind === \"connectRequest\")\n ConnectRequest.internalBinaryWrite(message.payload.connectRequest, writer.tag(3, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.GetMockRequest get_mock_request = 4; */\n if (message.payload.oneofKind === \"getMockRequest\")\n GetMockRequest.internalBinaryWrite(message.payload.getMockRequest, writer.tag(4, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.SendInboundSpanForReplayRequest send_inbound_span_for_replay_request = 5; */\n if (message.payload.oneofKind === \"sendInboundSpanForReplayRequest\")\n SendInboundSpanForReplayRequest.internalBinaryWrite(message.payload.sendInboundSpanForReplayRequest, writer.tag(5, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.SendAlertRequest send_alert_request = 6; */\n if (message.payload.oneofKind === \"sendAlertRequest\")\n SendAlertRequest.internalBinaryWrite(message.payload.sendAlertRequest, writer.tag(6, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.EnvVarRequest env_var_request = 7; */\n if (message.payload.oneofKind === \"envVarRequest\")\n EnvVarRequest.internalBinaryWrite(message.payload.envVarRequest, writer.tag(7, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.SetTimeTravelResponse set_time_travel_response = 8; */\n if (message.payload.oneofKind === \"setTimeTravelResponse\")\n SetTimeTravelResponse.internalBinaryWrite(message.payload.setTimeTravelResponse, writer.tag(8, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.CoverageSnapshotResponse coverage_snapshot_response = 9; */\n if (message.payload.oneofKind === \"coverageSnapshotResponse\")\n CoverageSnapshotResponse.internalBinaryWrite(message.payload.coverageSnapshotResponse, writer.tag(9, WireType.LengthDelimited).fork(), options).join();\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.SDKMessage\n */\nexport const SDKMessage = new SDKMessage$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass CLIMessage$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.CLIMessage\", [\n { no: 1, name: \"type\", kind: \"enum\", T: () => [\"tusk.drift.core.v1.MessageType\", MessageType, \"MESSAGE_TYPE_\"] },\n { no: 2, name: \"request_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 3, name: \"connect_response\", kind: \"message\", oneof: \"payload\", T: () => ConnectResponse },\n { no: 4, name: \"get_mock_response\", kind: \"message\", oneof: \"payload\", T: () => GetMockResponse },\n { no: 5, name: \"send_inbound_span_for_replay_response\", kind: \"message\", oneof: \"payload\", T: () => SendInboundSpanForReplayResponse },\n { no: 6, name: \"env_var_response\", kind: \"message\", oneof: \"payload\", T: () => EnvVarResponse },\n { no: 7, name: \"set_time_travel_request\", kind: \"message\", oneof: \"payload\", T: () => SetTimeTravelRequest },\n { no: 8, name: \"coverage_snapshot_request\", kind: \"message\", oneof: \"payload\", T: () => CoverageSnapshotRequest }\n ]);\n }\n create(value?: PartialMessage): CLIMessage {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.type = 0;\n message.requestId = \"\";\n message.payload = { oneofKind: undefined };\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CLIMessage): CLIMessage {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* tusk.drift.core.v1.MessageType type */ 1:\n message.type = reader.int32();\n break;\n case /* string request_id */ 2:\n message.requestId = reader.string();\n break;\n case /* tusk.drift.core.v1.ConnectResponse connect_response */ 3:\n message.payload = {\n oneofKind: \"connectResponse\",\n connectResponse: ConnectResponse.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).connectResponse)\n };\n break;\n case /* tusk.drift.core.v1.GetMockResponse get_mock_response */ 4:\n message.payload = {\n oneofKind: \"getMockResponse\",\n getMockResponse: GetMockResponse.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).getMockResponse)\n };\n break;\n case /* tusk.drift.core.v1.SendInboundSpanForReplayResponse send_inbound_span_for_replay_response */ 5:\n message.payload = {\n oneofKind: \"sendInboundSpanForReplayResponse\",\n sendInboundSpanForReplayResponse: SendInboundSpanForReplayResponse.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).sendInboundSpanForReplayResponse)\n };\n break;\n case /* tusk.drift.core.v1.EnvVarResponse env_var_response */ 6:\n message.payload = {\n oneofKind: \"envVarResponse\",\n envVarResponse: EnvVarResponse.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).envVarResponse)\n };\n break;\n case /* tusk.drift.core.v1.SetTimeTravelRequest set_time_travel_request */ 7:\n message.payload = {\n oneofKind: \"setTimeTravelRequest\",\n setTimeTravelRequest: SetTimeTravelRequest.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).setTimeTravelRequest)\n };\n break;\n case /* tusk.drift.core.v1.CoverageSnapshotRequest coverage_snapshot_request */ 8:\n message.payload = {\n oneofKind: \"coverageSnapshotRequest\",\n coverageSnapshotRequest: CoverageSnapshotRequest.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).coverageSnapshotRequest)\n };\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: CLIMessage, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* tusk.drift.core.v1.MessageType type = 1; */\n if (message.type !== 0)\n writer.tag(1, WireType.Varint).int32(message.type);\n /* string request_id = 2; */\n if (message.requestId !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.requestId);\n /* tusk.drift.core.v1.ConnectResponse connect_response = 3; */\n if (message.payload.oneofKind === \"connectResponse\")\n ConnectResponse.internalBinaryWrite(message.payload.connectResponse, writer.tag(3, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.GetMockResponse get_mock_response = 4; */\n if (message.payload.oneofKind === \"getMockResponse\")\n GetMockResponse.internalBinaryWrite(message.payload.getMockResponse, writer.tag(4, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.SendInboundSpanForReplayResponse send_inbound_span_for_replay_response = 5; */\n if (message.payload.oneofKind === \"sendInboundSpanForReplayResponse\")\n SendInboundSpanForReplayResponse.internalBinaryWrite(message.payload.sendInboundSpanForReplayResponse, writer.tag(5, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.EnvVarResponse env_var_response = 6; */\n if (message.payload.oneofKind === \"envVarResponse\")\n EnvVarResponse.internalBinaryWrite(message.payload.envVarResponse, writer.tag(6, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.SetTimeTravelRequest set_time_travel_request = 7; */\n if (message.payload.oneofKind === \"setTimeTravelRequest\")\n SetTimeTravelRequest.internalBinaryWrite(message.payload.setTimeTravelRequest, writer.tag(7, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.CoverageSnapshotRequest coverage_snapshot_request = 8; */\n if (message.payload.oneofKind === \"coverageSnapshotRequest\")\n CoverageSnapshotRequest.internalBinaryWrite(message.payload.coverageSnapshotRequest, writer.tag(8, WireType.LengthDelimited).fork(), options).join();\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.CLIMessage\n */\nexport const CLIMessage = new CLIMessage$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass SendInboundSpanForReplayRequest$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.SendInboundSpanForReplayRequest\", [\n { no: 1, name: \"span\", kind: \"message\", T: () => Span }\n ]);\n }\n create(value?: PartialMessage): SendInboundSpanForReplayRequest {\n const message = globalThis.Object.create((this.messagePrototype!));\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SendInboundSpanForReplayRequest): SendInboundSpanForReplayRequest {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* tusk.drift.core.v1.Span span */ 1:\n message.span = Span.internalBinaryRead(reader, reader.uint32(), options, message.span);\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: SendInboundSpanForReplayRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* tusk.drift.core.v1.Span span = 1; */\n if (message.span)\n Span.internalBinaryWrite(message.span, writer.tag(1, WireType.LengthDelimited).fork(), options).join();\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.SendInboundSpanForReplayRequest\n */\nexport const SendInboundSpanForReplayRequest = new SendInboundSpanForReplayRequest$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass SendInboundSpanForReplayResponse$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.SendInboundSpanForReplayResponse\", [\n { no: 1, name: \"success\", kind: \"scalar\", T: 8 /*ScalarType.BOOL*/ }\n ]);\n }\n create(value?: PartialMessage): SendInboundSpanForReplayResponse {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.success = false;\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SendInboundSpanForReplayResponse): SendInboundSpanForReplayResponse {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* bool success */ 1:\n message.success = reader.bool();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: SendInboundSpanForReplayResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* bool success = 1; */\n if (message.success !== false)\n writer.tag(1, WireType.Varint).bool(message.success);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.SendInboundSpanForReplayResponse\n */\nexport const SendInboundSpanForReplayResponse = new SendInboundSpanForReplayResponse$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass SendAlertRequest$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.SendAlertRequest\", [\n { no: 1, name: \"version_mismatch\", kind: \"message\", oneof: \"alert\", T: () => InstrumentationVersionMismatchAlert },\n { no: 2, name: \"unpatched_dependency\", kind: \"message\", oneof: \"alert\", T: () => UnpatchedDependencyAlert }\n ]);\n }\n create(value?: PartialMessage): SendAlertRequest {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.alert = { oneofKind: undefined };\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SendAlertRequest): SendAlertRequest {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* tusk.drift.core.v1.InstrumentationVersionMismatchAlert version_mismatch */ 1:\n message.alert = {\n oneofKind: \"versionMismatch\",\n versionMismatch: InstrumentationVersionMismatchAlert.internalBinaryRead(reader, reader.uint32(), options, (message.alert as any).versionMismatch)\n };\n break;\n case /* tusk.drift.core.v1.UnpatchedDependencyAlert unpatched_dependency */ 2:\n message.alert = {\n oneofKind: \"unpatchedDependency\",\n unpatchedDependency: UnpatchedDependencyAlert.internalBinaryRead(reader, reader.uint32(), options, (message.alert as any).unpatchedDependency)\n };\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: SendAlertRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* tusk.drift.core.v1.InstrumentationVersionMismatchAlert version_mismatch = 1; */\n if (message.alert.oneofKind === \"versionMismatch\")\n InstrumentationVersionMismatchAlert.internalBinaryWrite(message.alert.versionMismatch, writer.tag(1, WireType.LengthDelimited).fork(), options).join();\n /* tusk.drift.core.v1.UnpatchedDependencyAlert unpatched_dependency = 2; */\n if (message.alert.oneofKind === \"unpatchedDependency\")\n UnpatchedDependencyAlert.internalBinaryWrite(message.alert.unpatchedDependency, writer.tag(2, WireType.LengthDelimited).fork(), options).join();\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.SendAlertRequest\n */\nexport const SendAlertRequest = new SendAlertRequest$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass InstrumentationVersionMismatchAlert$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.InstrumentationVersionMismatchAlert\", [\n { no: 1, name: \"module_name\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 2, name: \"requested_version\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 3, name: \"supported_versions\", kind: \"scalar\", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ },\n { no: 4, name: \"sdk_version\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ }\n ]);\n }\n create(value?: PartialMessage): InstrumentationVersionMismatchAlert {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.moduleName = \"\";\n message.requestedVersion = \"\";\n message.supportedVersions = [];\n message.sdkVersion = \"\";\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: InstrumentationVersionMismatchAlert): InstrumentationVersionMismatchAlert {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* string module_name */ 1:\n message.moduleName = reader.string();\n break;\n case /* string requested_version */ 2:\n message.requestedVersion = reader.string();\n break;\n case /* repeated string supported_versions */ 3:\n message.supportedVersions.push(reader.string());\n break;\n case /* string sdk_version */ 4:\n message.sdkVersion = reader.string();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: InstrumentationVersionMismatchAlert, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* string module_name = 1; */\n if (message.moduleName !== \"\")\n writer.tag(1, WireType.LengthDelimited).string(message.moduleName);\n /* string requested_version = 2; */\n if (message.requestedVersion !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.requestedVersion);\n /* repeated string supported_versions = 3; */\n for (let i = 0; i < message.supportedVersions.length; i++)\n writer.tag(3, WireType.LengthDelimited).string(message.supportedVersions[i]);\n /* string sdk_version = 4; */\n if (message.sdkVersion !== \"\")\n writer.tag(4, WireType.LengthDelimited).string(message.sdkVersion);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.InstrumentationVersionMismatchAlert\n */\nexport const InstrumentationVersionMismatchAlert = new InstrumentationVersionMismatchAlert$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass UnpatchedDependencyAlert$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.UnpatchedDependencyAlert\", [\n { no: 1, name: \"stack_trace\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 2, name: \"trace_test_server_span_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 3, name: \"sdk_version\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ }\n ]);\n }\n create(value?: PartialMessage): UnpatchedDependencyAlert {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.stackTrace = \"\";\n message.traceTestServerSpanId = \"\";\n message.sdkVersion = \"\";\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: UnpatchedDependencyAlert): UnpatchedDependencyAlert {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* string stack_trace */ 1:\n message.stackTrace = reader.string();\n break;\n case /* string trace_test_server_span_id */ 2:\n message.traceTestServerSpanId = reader.string();\n break;\n case /* string sdk_version */ 3:\n message.sdkVersion = reader.string();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: UnpatchedDependencyAlert, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* string stack_trace = 1; */\n if (message.stackTrace !== \"\")\n writer.tag(1, WireType.LengthDelimited).string(message.stackTrace);\n /* string trace_test_server_span_id = 2; */\n if (message.traceTestServerSpanId !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.traceTestServerSpanId);\n /* string sdk_version = 3; */\n if (message.sdkVersion !== \"\")\n writer.tag(3, WireType.LengthDelimited).string(message.sdkVersion);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.UnpatchedDependencyAlert\n */\nexport const UnpatchedDependencyAlert = new UnpatchedDependencyAlert$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass EnvVarRequest$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.EnvVarRequest\", [\n { no: 1, name: \"trace_test_server_span_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ }\n ]);\n }\n create(value?: PartialMessage): EnvVarRequest {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.traceTestServerSpanId = \"\";\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: EnvVarRequest): EnvVarRequest {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* string trace_test_server_span_id */ 1:\n message.traceTestServerSpanId = reader.string();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: EnvVarRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* string trace_test_server_span_id = 1; */\n if (message.traceTestServerSpanId !== \"\")\n writer.tag(1, WireType.LengthDelimited).string(message.traceTestServerSpanId);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.EnvVarRequest\n */\nexport const EnvVarRequest = new EnvVarRequest$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass EnvVarResponse$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.EnvVarResponse\", [\n { no: 1, name: \"env_vars\", kind: \"map\", K: 9 /*ScalarType.STRING*/, V: { kind: \"scalar\", T: 9 /*ScalarType.STRING*/ } }\n ]);\n }\n create(value?: PartialMessage): EnvVarResponse {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.envVars = {};\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: EnvVarResponse): EnvVarResponse {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* map env_vars */ 1:\n this.binaryReadMap1(message.envVars, reader, options);\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n private binaryReadMap1(map: EnvVarResponse[\"envVars\"], reader: IBinaryReader, options: BinaryReadOptions): void {\n let len = reader.uint32(), end = reader.pos + len, key: keyof EnvVarResponse[\"envVars\"] | undefined, val: EnvVarResponse[\"envVars\"][any] | undefined;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case 1:\n key = reader.string();\n break;\n case 2:\n val = reader.string();\n break;\n default: throw new globalThis.Error(\"unknown map entry field for tusk.drift.core.v1.EnvVarResponse.env_vars\");\n }\n }\n map[key ?? \"\"] = val ?? \"\";\n }\n internalBinaryWrite(message: EnvVarResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* map env_vars = 1; */\n for (let k of globalThis.Object.keys(message.envVars))\n writer.tag(1, WireType.LengthDelimited).fork().tag(1, WireType.LengthDelimited).string(k).tag(2, WireType.LengthDelimited).string(message.envVars[k]).join();\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.EnvVarResponse\n */\nexport const EnvVarResponse = new EnvVarResponse$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass SetTimeTravelRequest$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.SetTimeTravelRequest\", [\n { no: 1, name: \"timestamp_seconds\", kind: \"scalar\", T: 1 /*ScalarType.DOUBLE*/ },\n { no: 2, name: \"trace_id\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 3, name: \"timestamp_source\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ }\n ]);\n }\n create(value?: PartialMessage): SetTimeTravelRequest {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.timestampSeconds = 0;\n message.traceId = \"\";\n message.timestampSource = \"\";\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTimeTravelRequest): SetTimeTravelRequest {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* double timestamp_seconds */ 1:\n message.timestampSeconds = reader.double();\n break;\n case /* string trace_id */ 2:\n message.traceId = reader.string();\n break;\n case /* string timestamp_source */ 3:\n message.timestampSource = reader.string();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: SetTimeTravelRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* double timestamp_seconds = 1; */\n if (message.timestampSeconds !== 0)\n writer.tag(1, WireType.Bit64).double(message.timestampSeconds);\n /* string trace_id = 2; */\n if (message.traceId !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.traceId);\n /* string timestamp_source = 3; */\n if (message.timestampSource !== \"\")\n writer.tag(3, WireType.LengthDelimited).string(message.timestampSource);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.SetTimeTravelRequest\n */\nexport const SetTimeTravelRequest = new SetTimeTravelRequest$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass SetTimeTravelResponse$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.SetTimeTravelResponse\", [\n { no: 1, name: \"success\", kind: \"scalar\", T: 8 /*ScalarType.BOOL*/ },\n { no: 2, name: \"error\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ }\n ]);\n }\n create(value?: PartialMessage): SetTimeTravelResponse {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.success = false;\n message.error = \"\";\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTimeTravelResponse): SetTimeTravelResponse {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* bool success */ 1:\n message.success = reader.bool();\n break;\n case /* string error */ 2:\n message.error = reader.string();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: SetTimeTravelResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* bool success = 1; */\n if (message.success !== false)\n writer.tag(1, WireType.Varint).bool(message.success);\n /* string error = 2; */\n if (message.error !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.error);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.SetTimeTravelResponse\n */\nexport const SetTimeTravelResponse = new SetTimeTravelResponse$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass CoverageSnapshotRequest$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.CoverageSnapshotRequest\", [\n { no: 1, name: \"baseline\", kind: \"scalar\", T: 8 /*ScalarType.BOOL*/ }\n ]);\n }\n create(value?: PartialMessage): CoverageSnapshotRequest {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.baseline = false;\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CoverageSnapshotRequest): CoverageSnapshotRequest {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* bool baseline */ 1:\n message.baseline = reader.bool();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: CoverageSnapshotRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* bool baseline = 1; */\n if (message.baseline !== false)\n writer.tag(1, WireType.Varint).bool(message.baseline);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.CoverageSnapshotRequest\n */\nexport const CoverageSnapshotRequest = new CoverageSnapshotRequest$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass CoverageSnapshotResponse$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.CoverageSnapshotResponse\", [\n { no: 1, name: \"success\", kind: \"scalar\", T: 8 /*ScalarType.BOOL*/ },\n { no: 2, name: \"error\", kind: \"scalar\", T: 9 /*ScalarType.STRING*/ },\n { no: 3, name: \"coverage\", kind: \"map\", K: 9 /*ScalarType.STRING*/, V: { kind: \"message\", T: () => FileCoverageData } }\n ]);\n }\n create(value?: PartialMessage): CoverageSnapshotResponse {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.success = false;\n message.error = \"\";\n message.coverage = {};\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CoverageSnapshotResponse): CoverageSnapshotResponse {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* bool success */ 1:\n message.success = reader.bool();\n break;\n case /* string error */ 2:\n message.error = reader.string();\n break;\n case /* map coverage */ 3:\n this.binaryReadMap3(message.coverage, reader, options);\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n private binaryReadMap3(map: CoverageSnapshotResponse[\"coverage\"], reader: IBinaryReader, options: BinaryReadOptions): void {\n let len = reader.uint32(), end = reader.pos + len, key: keyof CoverageSnapshotResponse[\"coverage\"] | undefined, val: CoverageSnapshotResponse[\"coverage\"][any] | undefined;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case 1:\n key = reader.string();\n break;\n case 2:\n val = FileCoverageData.internalBinaryRead(reader, reader.uint32(), options);\n break;\n default: throw new globalThis.Error(\"unknown map entry field for tusk.drift.core.v1.CoverageSnapshotResponse.coverage\");\n }\n }\n map[key ?? \"\"] = val ?? FileCoverageData.create();\n }\n internalBinaryWrite(message: CoverageSnapshotResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* bool success = 1; */\n if (message.success !== false)\n writer.tag(1, WireType.Varint).bool(message.success);\n /* string error = 2; */\n if (message.error !== \"\")\n writer.tag(2, WireType.LengthDelimited).string(message.error);\n /* map coverage = 3; */\n for (let k of globalThis.Object.keys(message.coverage)) {\n writer.tag(3, WireType.LengthDelimited).fork().tag(1, WireType.LengthDelimited).string(k);\n writer.tag(2, WireType.LengthDelimited).fork();\n FileCoverageData.internalBinaryWrite(message.coverage[k], writer, options);\n writer.join().join();\n }\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.CoverageSnapshotResponse\n */\nexport const CoverageSnapshotResponse = new CoverageSnapshotResponse$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass FileCoverageData$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.FileCoverageData\", [\n { no: 1, name: \"lines\", kind: \"map\", K: 9 /*ScalarType.STRING*/, V: { kind: \"scalar\", T: 5 /*ScalarType.INT32*/ } },\n { no: 2, name: \"total_branches\", kind: \"scalar\", T: 5 /*ScalarType.INT32*/ },\n { no: 3, name: \"covered_branches\", kind: \"scalar\", T: 5 /*ScalarType.INT32*/ },\n { no: 4, name: \"branches\", kind: \"map\", K: 9 /*ScalarType.STRING*/, V: { kind: \"message\", T: () => BranchInfo } }\n ]);\n }\n create(value?: PartialMessage): FileCoverageData {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.lines = {};\n message.totalBranches = 0;\n message.coveredBranches = 0;\n message.branches = {};\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: FileCoverageData): FileCoverageData {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* map lines */ 1:\n this.binaryReadMap1(message.lines, reader, options);\n break;\n case /* int32 total_branches */ 2:\n message.totalBranches = reader.int32();\n break;\n case /* int32 covered_branches */ 3:\n message.coveredBranches = reader.int32();\n break;\n case /* map branches */ 4:\n this.binaryReadMap4(message.branches, reader, options);\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n private binaryReadMap1(map: FileCoverageData[\"lines\"], reader: IBinaryReader, options: BinaryReadOptions): void {\n let len = reader.uint32(), end = reader.pos + len, key: keyof FileCoverageData[\"lines\"] | undefined, val: FileCoverageData[\"lines\"][any] | undefined;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case 1:\n key = reader.string();\n break;\n case 2:\n val = reader.int32();\n break;\n default: throw new globalThis.Error(\"unknown map entry field for tusk.drift.core.v1.FileCoverageData.lines\");\n }\n }\n map[key ?? \"\"] = val ?? 0;\n }\n private binaryReadMap4(map: FileCoverageData[\"branches\"], reader: IBinaryReader, options: BinaryReadOptions): void {\n let len = reader.uint32(), end = reader.pos + len, key: keyof FileCoverageData[\"branches\"] | undefined, val: FileCoverageData[\"branches\"][any] | undefined;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case 1:\n key = reader.string();\n break;\n case 2:\n val = BranchInfo.internalBinaryRead(reader, reader.uint32(), options);\n break;\n default: throw new globalThis.Error(\"unknown map entry field for tusk.drift.core.v1.FileCoverageData.branches\");\n }\n }\n map[key ?? \"\"] = val ?? BranchInfo.create();\n }\n internalBinaryWrite(message: FileCoverageData, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* map lines = 1; */\n for (let k of globalThis.Object.keys(message.lines))\n writer.tag(1, WireType.LengthDelimited).fork().tag(1, WireType.LengthDelimited).string(k).tag(2, WireType.Varint).int32(message.lines[k]).join();\n /* int32 total_branches = 2; */\n if (message.totalBranches !== 0)\n writer.tag(2, WireType.Varint).int32(message.totalBranches);\n /* int32 covered_branches = 3; */\n if (message.coveredBranches !== 0)\n writer.tag(3, WireType.Varint).int32(message.coveredBranches);\n /* map branches = 4; */\n for (let k of globalThis.Object.keys(message.branches)) {\n writer.tag(4, WireType.LengthDelimited).fork().tag(1, WireType.LengthDelimited).string(k);\n writer.tag(2, WireType.LengthDelimited).fork();\n BranchInfo.internalBinaryWrite(message.branches[k], writer, options);\n writer.join().join();\n }\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.FileCoverageData\n */\nexport const FileCoverageData = new FileCoverageData$Type();\n// @generated message type with reflection information, may provide speed optimized methods\nclass BranchInfo$Type extends MessageType$ {\n constructor() {\n super(\"tusk.drift.core.v1.BranchInfo\", [\n { no: 1, name: \"total\", kind: \"scalar\", T: 5 /*ScalarType.INT32*/ },\n { no: 2, name: \"covered\", kind: \"scalar\", T: 5 /*ScalarType.INT32*/ }\n ]);\n }\n create(value?: PartialMessage): BranchInfo {\n const message = globalThis.Object.create((this.messagePrototype!));\n message.total = 0;\n message.covered = 0;\n if (value !== undefined)\n reflectionMergePartial(this, message, value);\n return message;\n }\n internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: BranchInfo): BranchInfo {\n let message = target ?? this.create(), end = reader.pos + length;\n while (reader.pos < end) {\n let [fieldNo, wireType] = reader.tag();\n switch (fieldNo) {\n case /* int32 total */ 1:\n message.total = reader.int32();\n break;\n case /* int32 covered */ 2:\n message.covered = reader.int32();\n break;\n default:\n let u = options.readUnknownField;\n if (u === \"throw\")\n throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);\n let d = reader.skip(wireType);\n if (u !== false)\n (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);\n }\n }\n return message;\n }\n internalBinaryWrite(message: BranchInfo, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {\n /* int32 total = 1; */\n if (message.total !== 0)\n writer.tag(1, WireType.Varint).int32(message.total);\n /* int32 covered = 2; */\n if (message.covered !== 0)\n writer.tag(2, WireType.Varint).int32(message.covered);\n let u = options.writeUnknownFields;\n if (u !== false)\n (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);\n return writer;\n }\n}\n/**\n * @generated MessageType for protobuf message tusk.drift.core.v1.BranchInfo\n */\nexport const BranchInfo = new BranchInfo$Type();\n/**\n * @generated ServiceType for protobuf service tusk.drift.core.v1.MockService\n */\nexport const MockService = new ServiceType(\"tusk.drift.core.v1.MockService\", [\n { name: \"Connect\", options: {}, I: ConnectRequest, O: ConnectResponse },\n { name: \"GetMock\", options: {}, I: GetMockRequest, O: GetMockResponse },\n { name: \"SendInboundSpanForReplay\", options: {}, I: SendInboundSpanForReplayRequest, O: SendInboundSpanForReplayResponse }\n]);\n"],"mappings":";;;;;;;;;;;;;;;AA4eA,IAAY,8CAAL;;;;AAIH;;;;AAIA;;;;AAIA;;;;;;AAKJ,IAAY,sDAAL;;;;AAIH;;;;AAIA;;;;AAIA;;;;AAIA;;;;AAIA;;;;AAIA;;;;AAIA;;;;AAIA;;;AAGJ,IAAM,sBAAN,cAAkCA,kCAA6B;CAC3D,cAAc;AACV,QAAM,qCAAqC;GACvC;IAAE,IAAI;IAAG,MAAM;IAAc,MAAM;IAAU,GAAG;IAAyB;GACzE;IAAE,IAAI;IAAG,MAAM;IAAe,MAAM;IAAU,GAAG;IAAyB;GAC1E;IAAE,IAAI;IAAG,MAAM;IAAmB,MAAM;IAAU,GAAG;IAAyB;GAC9E;IAAE,IAAI;IAAG,MAAM;IAAY,MAAM;IAAW,SAASC;IAAQ;GAC7D;IAAE,IAAI;IAAG,MAAM;IAAW,MAAM;IAAQ,SAAS;KAAC;KAA8B;KAAS;KAAW;IAAE;GACzG,CAAC;;CAEN,OAAO,OAAwD;EAC3D,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,YAAY;AACpB,UAAQ,aAAa;AACrB,UAAQ,gBAAgB;AACxB,UAAQ,UAAU;AAClB,MAAI,UAAU,OACV,mDAAuC,MAAM,SAAS,MAAM;AAChE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAyC;EAC3H,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAA6B;AACzB,aAAQ,YAAY,OAAO,QAAQ;AACnC;IACJ,KAA8B;AAC1B,aAAQ,aAAa,OAAO,QAAQ;AACpC;IACJ,KAAkC;AAC9B,aAAQ,gBAAgB,OAAO,QAAQ;AACvC;IACJ,KAA2C;AACvC,aAAQ,WAAWA,sBAAO,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAS,QAAQ,SAAS;AAChG;IACJ,KAA8C;AAC1C,aAAQ,UAAU,OAAO,OAAO;AAChC;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOC,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAAyB,QAAuB,SAA4C;AAE5G,MAAI,QAAQ,cAAc,GACtB,QAAO,IAAI,GAAGC,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,UAAU;AAErE,MAAI,QAAQ,eAAe,GACvB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,WAAW;AAEtE,MAAI,QAAQ,kBAAkB,GAC1B,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,cAAc;AAEzE,MAAI,QAAQ,SACR,uBAAO,oBAAoB,QAAQ,UAAU,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAEhH,MAAI,QAAQ,YAAY,EACpB,QAAO,IAAI,GAAGA,+BAAS,OAAO,CAAC,MAAM,QAAQ,QAAQ;EACzD,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,iBAAiB,IAAI,qBAAqB;AAEvD,IAAM,uBAAN,cAAmCF,kCAA8B;CAC7D,cAAc;AACV,QAAM,sCAAsC,CACxC;GAAE,IAAI;GAAG,MAAM;GAAW,MAAM;GAAU,GAAG;GAAuB,EACpE;GAAE,IAAI;GAAG,MAAM;GAAS,MAAM;GAAU,GAAG;GAAyB,CACvE,CAAC;;CAEN,OAAO,OAA0D;EAC7D,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,UAAU;AAClB,UAAQ,QAAQ;AAChB,MAAI,UAAU,OACV,mDAAwC,MAAM,SAAS,MAAM;AACjE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAA2C;EAC7H,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAwB;AACpB,aAAQ,UAAU,OAAO,MAAM;AAC/B;IACJ,KAAwB;AACpB,aAAQ,QAAQ,OAAO,QAAQ;AAC/B;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAA0B,QAAuB,SAA4C;AAE7G,MAAI,QAAQ,YAAY,MACpB,QAAO,IAAI,GAAGC,+BAAS,OAAO,CAAC,KAAK,QAAQ,QAAQ;AAExD,MAAI,QAAQ,UAAU,GAClB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,MAAM;EACjE,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,kBAAkB,IAAI,sBAAsB;AAEzD,IAAM,sBAAN,cAAkCF,kCAA6B;CAC3D,cAAc;AACV,QAAM,qCAAqC;GACvC;IAAE,IAAI;IAAG,MAAM;IAAc,MAAM;IAAU,GAAG;IAAyB;GACzE;IAAE,IAAI;IAAG,MAAM;IAAW,MAAM;IAAU,GAAG;IAAyB;GACtE;IAAE,IAAI;IAAG,MAAM;IAAiB,MAAM;IAAW,SAASI;IAAM;GAChE;IAAE,IAAI;IAAG,MAAM;IAAe,MAAM;IAAU,GAAG;IAAyB;GAC1E;IAAE,IAAI;IAAG,MAAM;IAAa,MAAM;IAAU,GAAG;IAAyB;GACxE;IAAE,IAAI;IAAG,MAAM;IAAQ,MAAM;IAAO,GAAG;IAAyB,GAAG;KAAE,MAAM;KAAU,GAAG;KAAyB;IAAE;GACnH;IAAE,IAAI;IAAG,MAAM;IAAgB,MAAM;IAAW,SAASC;IAAW;GACvE,CAAC;;CAEN,OAAO,OAAwD;EAC3D,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,YAAY;AACpB,UAAQ,SAAS;AACjB,UAAQ,aAAa;AACrB,UAAQ,YAAY;AACpB,UAAQ,OAAO,EAAE;AACjB,MAAI,UAAU,OACV,mDAAuC,MAAM,SAAS,MAAM;AAChE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAyC;EAC3H,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAA6B;AACzB,aAAQ,YAAY,OAAO,QAAQ;AACnC;IACJ,KAA0B;AACtB,aAAQ,SAAS,OAAO,QAAQ;AAChC;IACJ,KAAiD;AAC7C,aAAQ,eAAeD,kBAAK,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAS,QAAQ,aAAa;AACtG;IACJ,KAA8B;AAC1B,aAAQ,aAAa,OAAO,QAAQ;AACpC;IACJ,KAA4B;AACxB,aAAQ,YAAY,OAAO,QAAQ;AACnC;IACJ,KAAoC;AAChC,UAAK,eAAe,QAAQ,MAAM,QAAQ,QAAQ;AAClD;IACJ,KAAkD;AAC9C,aAAQ,cAAcC,4BAAU,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAS,QAAQ,YAAY;AACzG;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOH,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,AAAQ,eAAe,KAA6B,QAAuB,SAAkC;EACzG,IAAI,MAAM,OAAO,QAAQ,EAAE,MAAM,OAAO,MAAM,KAAKI,KAA+CC;AAClG,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAK;AACD,WAAM,OAAO,QAAQ;AACrB;IACJ,KAAK;AACD,WAAM,OAAO,QAAQ;AACrB;IACJ,QAAS,OAAM,IAAI,WAAW,MAAM,qEAAqE;;;AAGjH,MAAI,OAAO,MAAM,OAAO;;CAE5B,oBAAoB,SAAyB,QAAuB,SAA4C;AAE5G,MAAI,QAAQ,cAAc,GACtB,QAAO,IAAI,GAAGJ,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,UAAU;AAErE,MAAI,QAAQ,WAAW,GACnB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,OAAO;AAElE,MAAI,QAAQ,aACR,mBAAK,oBAAoB,QAAQ,cAAc,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAElH,MAAI,QAAQ,eAAe,GACvB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,WAAW;AAEtE,MAAI,QAAQ,cAAc,GACtB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,UAAU;AAErE,OAAK,IAAI,KAAK,WAAW,OAAO,KAAK,QAAQ,KAAK,CAC9C,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,CAAC,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,EAAE,CAAC,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,KAAK,GAAG,CAAC,MAAM;AAE7J,MAAI,QAAQ,YACR,6BAAU,oBAAoB,QAAQ,aAAa,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;EACtH,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,iBAAiB,IAAI,qBAAqB;AAEvD,IAAM,uBAAN,cAAmCF,kCAA8B;CAC7D,cAAc;AACV,QAAM,sCAAsC;GACxC;IAAE,IAAI;IAAG,MAAM;IAAc,MAAM;IAAU,GAAG;IAAyB;GACzE;IAAE,IAAI;IAAG,MAAM;IAAS,MAAM;IAAU,GAAG;IAAuB;GAClE;IAAE,IAAI;IAAG,MAAM;IAAiB,MAAM;IAAW,SAASC;IAAQ;GAClE;IAAE,IAAI;IAAG,MAAM;IAAY,MAAM;IAAW,SAASA;IAAQ;GAC7D;IAAE,IAAI;IAAG,MAAM;IAAS,MAAM;IAAU,GAAG;IAAyB;GACpE;IAAE,IAAI;IAAG,MAAM;IAAc,MAAM;IAAU,GAAG;IAAyB;GACzE;IAAE,IAAI;IAAG,MAAM;IAAmB,MAAM;IAAU,GAAG;IAAyB;GAC9E;IAAE,IAAI;IAAG,MAAM;IAAc,MAAM;IAAW,SAASI;IAAW;GAClE;IAAE,IAAI;IAAG,MAAM;IAAe,MAAM;IAAW,SAASG;IAAY;GACvE,CAAC;;CAEN,OAAO,OAA0D;EAC7D,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,YAAY;AACpB,UAAQ,QAAQ;AAChB,UAAQ,QAAQ;AAChB,UAAQ,YAAY;AACpB,UAAQ,gBAAgB;AACxB,MAAI,UAAU,OACV,mDAAwC,MAAM,SAAS,MAAM;AACjE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAA2C;EAC7H,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAA6B;AACzB,aAAQ,YAAY,OAAO,QAAQ;AACnC;IACJ,KAAsB;AAClB,aAAQ,QAAQ,OAAO,MAAM;AAC7B;IACJ,KAAgD;AAC5C,aAAQ,eAAeP,sBAAO,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAS,QAAQ,aAAa;AACxG;IACJ,KAA2C;AACvC,aAAQ,WAAWA,sBAAO,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAS,QAAQ,SAAS;AAChG;IACJ,KAAwB;AACpB,aAAQ,QAAQ,OAAO,QAAQ;AAC/B;IACJ,KAA6B;AACzB,aAAQ,YAAY,OAAO,QAAQ;AACnC;IACJ,KAAkC;AAC9B,aAAQ,gBAAgB,OAAO,QAAQ;AACvC;IACJ,KAAgD;AAC5C,aAAQ,YAAYI,4BAAU,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAS,QAAQ,UAAU;AACrG;IACJ,KAA8D;AAC1D,aAAQ,aAAaG,wBAAW,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAS,QAAQ,WAAW;AACxG;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAON,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAA0B,QAAuB,SAA4C;AAE7G,MAAI,QAAQ,cAAc,GACtB,QAAO,IAAI,GAAGC,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,UAAU;AAErE,MAAI,QAAQ,UAAU,MAClB,QAAO,IAAI,GAAGA,+BAAS,OAAO,CAAC,KAAK,QAAQ,MAAM;AAEtD,MAAI,QAAQ,aACR,uBAAO,oBAAoB,QAAQ,cAAc,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAEpH,MAAI,QAAQ,SACR,uBAAO,oBAAoB,QAAQ,UAAU,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAEhH,MAAI,QAAQ,UAAU,GAClB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,MAAM;AAEjE,MAAI,QAAQ,cAAc,GACtB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,UAAU;AAErE,MAAI,QAAQ,kBAAkB,GAC1B,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,cAAc;AAEzE,MAAI,QAAQ,UACR,6BAAU,oBAAoB,QAAQ,WAAW,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAEpH,MAAI,QAAQ,WACR,yBAAW,oBAAoB,QAAQ,YAAY,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;EACtH,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,kBAAkB,IAAI,sBAAsB;AAEzD,IAAM,kBAAN,cAA8BF,kCAAyB;CACnD,cAAc;AACV,QAAM,iCAAiC;GACnC;IAAE,IAAI;IAAG,MAAM;IAAQ,MAAM;IAAQ,SAAS;KAAC;KAAkC;KAAa;KAAgB;IAAE;GAChH;IAAE,IAAI;IAAG,MAAM;IAAc,MAAM;IAAU,GAAG;IAAyB;GACzE;IAAE,IAAI;IAAG,MAAM;IAAmB,MAAM;IAAW,OAAO;IAAW,SAAS;IAAgB;GAC9F;IAAE,IAAI;IAAG,MAAM;IAAoB,MAAM;IAAW,OAAO;IAAW,SAAS;IAAgB;GAC/F;IAAE,IAAI;IAAG,MAAM;IAAwC,MAAM;IAAW,OAAO;IAAW,SAAS;IAAiC;GACpI;IAAE,IAAI;IAAG,MAAM;IAAsB,MAAM;IAAW,OAAO;IAAW,SAAS;IAAkB;GACnG;IAAE,IAAI;IAAG,MAAM;IAAmB,MAAM;IAAW,OAAO;IAAW,SAAS;IAAe;GAC7F;IAAE,IAAI;IAAG,MAAM;IAA4B,MAAM;IAAW,OAAO;IAAW,SAAS;IAAuB;GAC9G;IAAE,IAAI;IAAG,MAAM;IAA8B,MAAM;IAAW,OAAO;IAAW,SAAS;IAA0B;GACtH,CAAC;;CAEN,OAAO,OAAgD;EACnD,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,OAAO;AACf,UAAQ,YAAY;AACpB,UAAQ,UAAU,EAAE,WAAW,QAAW;AAC1C,MAAI,UAAU,OACV,mDAAmC,MAAM,SAAS,MAAM;AAC5D,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAiC;EACnH,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAA+C;AAC3C,aAAQ,OAAO,OAAO,OAAO;AAC7B;IACJ,KAA6B;AACzB,aAAQ,YAAY,OAAO,QAAQ;AACnC;IACJ,KAA6D;AACzD,aAAQ,UAAU;MACd,WAAW;MACX,gBAAgB,eAAe,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,eAAe;MAC/H;AACD;IACJ,KAA8D;AAC1D,aAAQ,UAAU;MACd,WAAW;MACX,gBAAgB,eAAe,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,eAAe;MAC/H;AACD;IACJ,KAAmG;AAC/F,aAAQ,UAAU;MACd,WAAW;MACX,iCAAiC,gCAAgC,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,gCAAgC;MAClL;AACD;IACJ,KAAkE;AAC9D,aAAQ,UAAU;MACd,WAAW;MACX,kBAAkB,iBAAiB,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,iBAAiB;MACrI;AACD;IACJ,KAA4D;AACxD,aAAQ,UAAU;MACd,WAAW;MACX,eAAe,cAAc,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,cAAc;MAC5H;AACD;IACJ,KAA6E;AACzE,aAAQ,UAAU;MACd,WAAW;MACX,uBAAuB,sBAAsB,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,sBAAsB;MACpJ;AACD;IACJ,KAAkF;AAC9E,aAAQ,UAAU;MACd,WAAW;MACX,0BAA0B,yBAAyB,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,yBAAyB;MAC7J;AACD;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAAqB,QAAuB,SAA4C;AAExG,MAAI,QAAQ,SAAS,EACjB,QAAO,IAAI,GAAGC,+BAAS,OAAO,CAAC,MAAM,QAAQ,KAAK;AAEtD,MAAI,QAAQ,cAAc,GACtB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,UAAU;AAErE,MAAI,QAAQ,QAAQ,cAAc,iBAC9B,gBAAe,oBAAoB,QAAQ,QAAQ,gBAAgB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAEtI,MAAI,QAAQ,QAAQ,cAAc,iBAC9B,gBAAe,oBAAoB,QAAQ,QAAQ,gBAAgB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAEtI,MAAI,QAAQ,QAAQ,cAAc,kCAC9B,iCAAgC,oBAAoB,QAAQ,QAAQ,iCAAiC,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAExK,MAAI,QAAQ,QAAQ,cAAc,mBAC9B,kBAAiB,oBAAoB,QAAQ,QAAQ,kBAAkB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAE1I,MAAI,QAAQ,QAAQ,cAAc,gBAC9B,eAAc,oBAAoB,QAAQ,QAAQ,eAAe,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAEpI,MAAI,QAAQ,QAAQ,cAAc,wBAC9B,uBAAsB,oBAAoB,QAAQ,QAAQ,uBAAuB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAEpJ,MAAI,QAAQ,QAAQ,cAAc,2BAC9B,0BAAyB,oBAAoB,QAAQ,QAAQ,0BAA0B,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;EAC1J,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,aAAa,IAAI,iBAAiB;AAE/C,IAAM,kBAAN,cAA8BF,kCAAyB;CACnD,cAAc;AACV,QAAM,iCAAiC;GACnC;IAAE,IAAI;IAAG,MAAM;IAAQ,MAAM;IAAQ,SAAS;KAAC;KAAkC;KAAa;KAAgB;IAAE;GAChH;IAAE,IAAI;IAAG,MAAM;IAAc,MAAM;IAAU,GAAG;IAAyB;GACzE;IAAE,IAAI;IAAG,MAAM;IAAoB,MAAM;IAAW,OAAO;IAAW,SAAS;IAAiB;GAChG;IAAE,IAAI;IAAG,MAAM;IAAqB,MAAM;IAAW,OAAO;IAAW,SAAS;IAAiB;GACjG;IAAE,IAAI;IAAG,MAAM;IAAyC,MAAM;IAAW,OAAO;IAAW,SAAS;IAAkC;GACtI;IAAE,IAAI;IAAG,MAAM;IAAoB,MAAM;IAAW,OAAO;IAAW,SAAS;IAAgB;GAC/F;IAAE,IAAI;IAAG,MAAM;IAA2B,MAAM;IAAW,OAAO;IAAW,SAAS;IAAsB;GAC5G;IAAE,IAAI;IAAG,MAAM;IAA6B,MAAM;IAAW,OAAO;IAAW,SAAS;IAAyB;GACpH,CAAC;;CAEN,OAAO,OAAgD;EACnD,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,OAAO;AACf,UAAQ,YAAY;AACpB,UAAQ,UAAU,EAAE,WAAW,QAAW;AAC1C,MAAI,UAAU,OACV,mDAAmC,MAAM,SAAS,MAAM;AAC5D,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAiC;EACnH,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAA+C;AAC3C,aAAQ,OAAO,OAAO,OAAO;AAC7B;IACJ,KAA6B;AACzB,aAAQ,YAAY,OAAO,QAAQ;AACnC;IACJ,KAA+D;AAC3D,aAAQ,UAAU;MACd,WAAW;MACX,iBAAiB,gBAAgB,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,gBAAgB;MAClI;AACD;IACJ,KAAgE;AAC5D,aAAQ,UAAU;MACd,WAAW;MACX,iBAAiB,gBAAgB,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,gBAAgB;MAClI;AACD;IACJ,KAAqG;AACjG,aAAQ,UAAU;MACd,WAAW;MACX,kCAAkC,iCAAiC,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,iCAAiC;MACrL;AACD;IACJ,KAA8D;AAC1D,aAAQ,UAAU;MACd,WAAW;MACX,gBAAgB,eAAe,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,eAAe;MAC/H;AACD;IACJ,KAA2E;AACvE,aAAQ,UAAU;MACd,WAAW;MACX,sBAAsB,qBAAqB,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,qBAAqB;MACjJ;AACD;IACJ,KAAgF;AAC5E,aAAQ,UAAU;MACd,WAAW;MACX,yBAAyB,wBAAwB,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,QAAgB,wBAAwB;MAC1J;AACD;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAAqB,QAAuB,SAA4C;AAExG,MAAI,QAAQ,SAAS,EACjB,QAAO,IAAI,GAAGC,+BAAS,OAAO,CAAC,MAAM,QAAQ,KAAK;AAEtD,MAAI,QAAQ,cAAc,GACtB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,UAAU;AAErE,MAAI,QAAQ,QAAQ,cAAc,kBAC9B,iBAAgB,oBAAoB,QAAQ,QAAQ,iBAAiB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAExI,MAAI,QAAQ,QAAQ,cAAc,kBAC9B,iBAAgB,oBAAoB,QAAQ,QAAQ,iBAAiB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAExI,MAAI,QAAQ,QAAQ,cAAc,mCAC9B,kCAAiC,oBAAoB,QAAQ,QAAQ,kCAAkC,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAE1K,MAAI,QAAQ,QAAQ,cAAc,iBAC9B,gBAAe,oBAAoB,QAAQ,QAAQ,gBAAgB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAEtI,MAAI,QAAQ,QAAQ,cAAc,uBAC9B,sBAAqB,oBAAoB,QAAQ,QAAQ,sBAAsB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAElJ,MAAI,QAAQ,QAAQ,cAAc,0BAC9B,yBAAwB,oBAAoB,QAAQ,QAAQ,yBAAyB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;EACxJ,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,aAAa,IAAI,iBAAiB;AAE/C,IAAM,uCAAN,cAAmDF,kCAA8C;CAC7F,cAAc;AACV,QAAM,sDAAsD,CACxD;GAAE,IAAI;GAAG,MAAM;GAAQ,MAAM;GAAW,SAASI;GAAM,CAC1D,CAAC;;CAEN,OAAO,OAA0F;EAC7F,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,MAAI,UAAU,OACV,mDAAwD,MAAM,SAAS,MAAM;AACjF,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAA2E;EAC7J,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAwC;AACpC,aAAQ,OAAOA,kBAAK,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAS,QAAQ,KAAK;AACtF;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOF,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAA0C,QAAuB,SAA4C;AAE7H,MAAI,QAAQ,KACR,mBAAK,oBAAoB,QAAQ,MAAM,OAAO,IAAI,GAAGC,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;EAC1G,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,kCAAkC,IAAI,sCAAsC;AAEzF,IAAM,wCAAN,cAAoDF,kCAA+C;CAC/F,cAAc;AACV,QAAM,uDAAuD,CACzD;GAAE,IAAI;GAAG,MAAM;GAAW,MAAM;GAAU,GAAG;GAAuB,CACvE,CAAC;;CAEN,OAAO,OAA4F;EAC/F,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,UAAU;AAClB,MAAI,UAAU,OACV,mDAAyD,MAAM,SAAS,MAAM;AAClF,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAA6E;EAC/J,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAwB;AACpB,aAAQ,UAAU,OAAO,MAAM;AAC/B;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAA2C,QAAuB,SAA4C;AAE9H,MAAI,QAAQ,YAAY,MACpB,QAAO,IAAI,GAAGC,+BAAS,OAAO,CAAC,KAAK,QAAQ,QAAQ;EACxD,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,mCAAmC,IAAI,uCAAuC;AAE3F,IAAM,wBAAN,cAAoCF,kCAA+B;CAC/D,cAAc;AACV,QAAM,uCAAuC,CACzC;GAAE,IAAI;GAAG,MAAM;GAAoB,MAAM;GAAW,OAAO;GAAS,SAAS;GAAqC,EAClH;GAAE,IAAI;GAAG,MAAM;GAAwB,MAAM;GAAW,OAAO;GAAS,SAAS;GAA0B,CAC9G,CAAC;;CAEN,OAAO,OAA4D;EAC/D,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,QAAQ,EAAE,WAAW,QAAW;AACxC,MAAI,UAAU,OACV,mDAAyC,MAAM,SAAS,MAAM;AAClE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAA6C;EAC/H,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAmF;AAC/E,aAAQ,QAAQ;MACZ,WAAW;MACX,iBAAiB,oCAAoC,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,MAAc,gBAAgB;MACpJ;AACD;IACJ,KAA4E;AACxE,aAAQ,QAAQ;MACZ,WAAW;MACX,qBAAqB,yBAAyB,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,SAAU,QAAQ,MAAc,oBAAoB;MACjJ;AACD;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAA2B,QAAuB,SAA4C;AAE9G,MAAI,QAAQ,MAAM,cAAc,kBAC5B,qCAAoC,oBAAoB,QAAQ,MAAM,iBAAiB,OAAO,IAAI,GAAGC,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;AAE1J,MAAI,QAAQ,MAAM,cAAc,sBAC5B,0BAAyB,oBAAoB,QAAQ,MAAM,qBAAqB,OAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,EAAE,QAAQ,CAAC,MAAM;EACnJ,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,mBAAmB,IAAI,uBAAuB;AAE3D,IAAM,2CAAN,cAAuDF,kCAAkD;CACrG,cAAc;AACV,QAAM,0DAA0D;GAC5D;IAAE,IAAI;IAAG,MAAM;IAAe,MAAM;IAAU,GAAG;IAAyB;GAC1E;IAAE,IAAI;IAAG,MAAM;IAAqB,MAAM;IAAU,GAAG;IAAyB;GAChF;IAAE,IAAI;IAAG,MAAM;IAAsB,MAAM;IAAU,QAAQ;IAA2B,GAAG;IAAyB;GACpH;IAAE,IAAI;IAAG,MAAM;IAAe,MAAM;IAAU,GAAG;IAAyB;GAC7E,CAAC;;CAEN,OAAO,OAAkG;EACrG,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,aAAa;AACrB,UAAQ,mBAAmB;AAC3B,UAAQ,oBAAoB,EAAE;AAC9B,UAAQ,aAAa;AACrB,MAAI,UAAU,OACV,mDAA4D,MAAM,SAAS,MAAM;AACrF,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAmF;EACrK,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAA8B;AAC1B,aAAQ,aAAa,OAAO,QAAQ;AACpC;IACJ,KAAoC;AAChC,aAAQ,mBAAmB,OAAO,QAAQ;AAC1C;IACJ,KAA8C;AAC1C,aAAQ,kBAAkB,KAAK,OAAO,QAAQ,CAAC;AAC/C;IACJ,KAA8B;AAC1B,aAAQ,aAAa,OAAO,QAAQ;AACpC;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAA8C,QAAuB,SAA4C;AAEjI,MAAI,QAAQ,eAAe,GACvB,QAAO,IAAI,GAAGC,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,WAAW;AAEtE,MAAI,QAAQ,qBAAqB,GAC7B,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,iBAAiB;AAE5E,OAAK,IAAI,IAAI,GAAG,IAAI,QAAQ,kBAAkB,QAAQ,IAClD,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,kBAAkB,GAAG;AAEhF,MAAI,QAAQ,eAAe,GACvB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,WAAW;EACtE,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,sCAAsC,IAAI,0CAA0C;AAEjG,IAAM,gCAAN,cAA4CF,kCAAuC;CAC/E,cAAc;AACV,QAAM,+CAA+C;GACjD;IAAE,IAAI;IAAG,MAAM;IAAe,MAAM;IAAU,GAAG;IAAyB;GAC1E;IAAE,IAAI;IAAG,MAAM;IAA6B,MAAM;IAAU,GAAG;IAAyB;GACxF;IAAE,IAAI;IAAG,MAAM;IAAe,MAAM;IAAU,GAAG;IAAyB;GAC7E,CAAC;;CAEN,OAAO,OAA4E;EAC/E,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,aAAa;AACrB,UAAQ,wBAAwB;AAChC,UAAQ,aAAa;AACrB,MAAI,UAAU,OACV,mDAAiD,MAAM,SAAS,MAAM;AAC1E,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAA6D;EAC/I,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAA8B;AAC1B,aAAQ,aAAa,OAAO,QAAQ;AACpC;IACJ,KAA4C;AACxC,aAAQ,wBAAwB,OAAO,QAAQ;AAC/C;IACJ,KAA8B;AAC1B,aAAQ,aAAa,OAAO,QAAQ;AACpC;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAAmC,QAAuB,SAA4C;AAEtH,MAAI,QAAQ,eAAe,GACvB,QAAO,IAAI,GAAGC,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,WAAW;AAEtE,MAAI,QAAQ,0BAA0B,GAClC,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,sBAAsB;AAEjF,MAAI,QAAQ,eAAe,GACvB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,WAAW;EACtE,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,2BAA2B,IAAI,+BAA+B;AAE3E,IAAM,qBAAN,cAAiCF,kCAA4B;CACzD,cAAc;AACV,QAAM,oCAAoC,CACtC;GAAE,IAAI;GAAG,MAAM;GAA6B,MAAM;GAAU,GAAG;GAAyB,CAC3F,CAAC;;CAEN,OAAO,OAAsD;EACzD,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,wBAAwB;AAChC,MAAI,UAAU,OACV,mDAAsC,MAAM,SAAS,MAAM;AAC/D,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAuC;EACzH,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAA4C;AACxC,aAAQ,wBAAwB,OAAO,QAAQ;AAC/C;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAAwB,QAAuB,SAA4C;AAE3G,MAAI,QAAQ,0BAA0B,GAClC,QAAO,IAAI,GAAGC,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,sBAAsB;EACjF,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,gBAAgB,IAAI,oBAAoB;AAErD,IAAM,sBAAN,cAAkCF,kCAA6B;CAC3D,cAAc;AACV,QAAM,qCAAqC,CACvC;GAAE,IAAI;GAAG,MAAM;GAAY,MAAM;GAAO,GAAG;GAAyB,GAAG;IAAE,MAAM;IAAU,GAAG;IAAyB;GAAE,CAC1H,CAAC;;CAEN,OAAO,OAAwD;EAC3D,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,UAAU,EAAE;AACpB,MAAI,UAAU,OACV,mDAAuC,MAAM,SAAS,MAAM;AAChE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAyC;EAC3H,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAwC;AACpC,UAAK,eAAe,QAAQ,SAAS,QAAQ,QAAQ;AACrD;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,AAAQ,eAAe,KAAgC,QAAuB,SAAkC;EAC5G,IAAI,MAAM,OAAO,QAAQ,EAAE,MAAM,OAAO,MAAM,KAAKO,KAAkDC;AACrG,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAK;AACD,WAAM,OAAO,QAAQ;AACrB;IACJ,KAAK;AACD,WAAM,OAAO,QAAQ;AACrB;IACJ,QAAS,OAAM,IAAI,WAAW,MAAM,yEAAyE;;;AAGrH,MAAI,OAAO,MAAM,OAAO;;CAE5B,oBAAoB,SAAyB,QAAuB,SAA4C;AAE5G,OAAK,IAAI,KAAK,WAAW,OAAO,KAAK,QAAQ,QAAQ,CACjD,QAAO,IAAI,GAAGP,+BAAS,gBAAgB,CAAC,MAAM,CAAC,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,EAAE,CAAC,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,QAAQ,GAAG,CAAC,MAAM;EAChK,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,iBAAiB,IAAI,qBAAqB;AAEvD,IAAM,4BAAN,cAAwCF,kCAAmC;CACvE,cAAc;AACV,QAAM,2CAA2C;GAC7C;IAAE,IAAI;IAAG,MAAM;IAAqB,MAAM;IAAU,GAAG;IAAyB;GAChF;IAAE,IAAI;IAAG,MAAM;IAAY,MAAM;IAAU,GAAG;IAAyB;GACvE;IAAE,IAAI;IAAG,MAAM;IAAoB,MAAM;IAAU,GAAG;IAAyB;GAClF,CAAC;;CAEN,OAAO,OAAoE;EACvE,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,mBAAmB;AAC3B,UAAQ,UAAU;AAClB,UAAQ,kBAAkB;AAC1B,MAAI,UAAU,OACV,mDAA6C,MAAM,SAAS,MAAM;AACtE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAqD;EACvI,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAoC;AAChC,aAAQ,mBAAmB,OAAO,QAAQ;AAC1C;IACJ,KAA2B;AACvB,aAAQ,UAAU,OAAO,QAAQ;AACjC;IACJ,KAAmC;AAC/B,aAAQ,kBAAkB,OAAO,QAAQ;AACzC;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAA+B,QAAuB,SAA4C;AAElH,MAAI,QAAQ,qBAAqB,EAC7B,QAAO,IAAI,GAAGC,+BAAS,MAAM,CAAC,OAAO,QAAQ,iBAAiB;AAElE,MAAI,QAAQ,YAAY,GACpB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,QAAQ;AAEnE,MAAI,QAAQ,oBAAoB,GAC5B,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,gBAAgB;EAC3E,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,uBAAuB,IAAI,2BAA2B;AAEnE,IAAM,6BAAN,cAAyCF,kCAAoC;CACzE,cAAc;AACV,QAAM,4CAA4C,CAC9C;GAAE,IAAI;GAAG,MAAM;GAAW,MAAM;GAAU,GAAG;GAAuB,EACpE;GAAE,IAAI;GAAG,MAAM;GAAS,MAAM;GAAU,GAAG;GAAyB,CACvE,CAAC;;CAEN,OAAO,OAAsE;EACzE,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,UAAU;AAClB,UAAQ,QAAQ;AAChB,MAAI,UAAU,OACV,mDAA8C,MAAM,SAAS,MAAM;AACvE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAuD;EACzI,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAwB;AACpB,aAAQ,UAAU,OAAO,MAAM;AAC/B;IACJ,KAAwB;AACpB,aAAQ,QAAQ,OAAO,QAAQ;AAC/B;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAAgC,QAAuB,SAA4C;AAEnH,MAAI,QAAQ,YAAY,MACpB,QAAO,IAAI,GAAGC,+BAAS,OAAO,CAAC,KAAK,QAAQ,QAAQ;AAExD,MAAI,QAAQ,UAAU,GAClB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,MAAM;EACjE,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,wBAAwB,IAAI,4BAA4B;AAErE,IAAM,+BAAN,cAA2CF,kCAAsC;CAC7E,cAAc;AACV,QAAM,8CAA8C,CAChD;GAAE,IAAI;GAAG,MAAM;GAAY,MAAM;GAAU,GAAG;GAAuB,CACxE,CAAC;;CAEN,OAAO,OAA0E;EAC7E,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,WAAW;AACnB,MAAI,UAAU,OACV,mDAAgD,MAAM,SAAS,MAAM;AACzE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAA2D;EAC7I,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAyB;AACrB,aAAQ,WAAW,OAAO,MAAM;AAChC;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAAkC,QAAuB,SAA4C;AAErH,MAAI,QAAQ,aAAa,MACrB,QAAO,IAAI,GAAGC,+BAAS,OAAO,CAAC,KAAK,QAAQ,SAAS;EACzD,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,0BAA0B,IAAI,8BAA8B;AAEzE,IAAM,gCAAN,cAA4CF,kCAAuC;CAC/E,cAAc;AACV,QAAM,+CAA+C;GACjD;IAAE,IAAI;IAAG,MAAM;IAAW,MAAM;IAAU,GAAG;IAAuB;GACpE;IAAE,IAAI;IAAG,MAAM;IAAS,MAAM;IAAU,GAAG;IAAyB;GACpE;IAAE,IAAI;IAAG,MAAM;IAAY,MAAM;IAAO,GAAG;IAAyB,GAAG;KAAE,MAAM;KAAW,SAAS;KAAkB;IAAE;GAC1H,CAAC;;CAEN,OAAO,OAA4E;EAC/E,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,UAAU;AAClB,UAAQ,QAAQ;AAChB,UAAQ,WAAW,EAAE;AACrB,MAAI,UAAU,OACV,mDAAiD,MAAM,SAAS,MAAM;AAC1E,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAA6D;EAC/I,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAwB;AACpB,aAAQ,UAAU,OAAO,MAAM;AAC/B;IACJ,KAAwB;AACpB,aAAQ,QAAQ,OAAO,QAAQ;AAC/B;IACJ,KAAqE;AACjE,UAAK,eAAe,QAAQ,UAAU,QAAQ,QAAQ;AACtD;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,AAAQ,eAAe,KAA2C,QAAuB,SAAkC;EACvH,IAAI,MAAM,OAAO,QAAQ,EAAE,MAAM,OAAO,MAAM,KAAKS,KAA6DC;AAChH,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAK;AACD,WAAM,OAAO,QAAQ;AACrB;IACJ,KAAK;AACD,WAAM,iBAAiB,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,QAAQ;AAC3E;IACJ,QAAS,OAAM,IAAI,WAAW,MAAM,mFAAmF;;;AAG/H,MAAI,OAAO,MAAM,OAAO,iBAAiB,QAAQ;;CAErD,oBAAoB,SAAmC,QAAuB,SAA4C;AAEtH,MAAI,QAAQ,YAAY,MACpB,QAAO,IAAI,GAAGT,+BAAS,OAAO,CAAC,KAAK,QAAQ,QAAQ;AAExD,MAAI,QAAQ,UAAU,GAClB,QAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,QAAQ,MAAM;AAEjE,OAAK,IAAI,KAAK,WAAW,OAAO,KAAK,QAAQ,SAAS,EAAE;AACpD,UAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,CAAC,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,EAAE;AACzF,UAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM;AAC9C,oBAAiB,oBAAoB,QAAQ,SAAS,IAAI,QAAQ,QAAQ;AAC1E,UAAO,MAAM,CAAC,MAAM;;EAExB,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,2BAA2B,IAAI,+BAA+B;AAE3E,IAAM,wBAAN,cAAoCF,kCAA+B;CAC/D,cAAc;AACV,QAAM,uCAAuC;GACzC;IAAE,IAAI;IAAG,MAAM;IAAS,MAAM;IAAO,GAAG;IAAyB,GAAG;KAAE,MAAM;KAAU,GAAG;KAAwB;IAAE;GACnH;IAAE,IAAI;IAAG,MAAM;IAAkB,MAAM;IAAU,GAAG;IAAwB;GAC5E;IAAE,IAAI;IAAG,MAAM;IAAoB,MAAM;IAAU,GAAG;IAAwB;GAC9E;IAAE,IAAI;IAAG,MAAM;IAAY,MAAM;IAAO,GAAG;IAAyB,GAAG;KAAE,MAAM;KAAW,SAAS;KAAY;IAAE;GACpH,CAAC;;CAEN,OAAO,OAA4D;EAC/D,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,QAAQ,EAAE;AAClB,UAAQ,gBAAgB;AACxB,UAAQ,kBAAkB;AAC1B,UAAQ,WAAW,EAAE;AACrB,MAAI,UAAU,OACV,mDAAyC,MAAM,SAAS,MAAM;AAClE,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAA6C;EAC/H,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAoC;AAChC,UAAK,eAAe,QAAQ,OAAO,QAAQ,QAAQ;AACnD;IACJ,KAAgC;AAC5B,aAAQ,gBAAgB,OAAO,OAAO;AACtC;IACJ,KAAkC;AAC9B,aAAQ,kBAAkB,OAAO,OAAO;AACxC;IACJ,KAA+D;AAC3D,UAAK,eAAe,QAAQ,UAAU,QAAQ,QAAQ;AACtD;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,AAAQ,eAAe,KAAgC,QAAuB,SAAkC;EAC5G,IAAI,MAAM,OAAO,QAAQ,EAAE,MAAM,OAAO,MAAM,KAAKW,KAAkDC;AACrG,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAK;AACD,WAAM,OAAO,QAAQ;AACrB;IACJ,KAAK;AACD,WAAM,OAAO,OAAO;AACpB;IACJ,QAAS,OAAM,IAAI,WAAW,MAAM,wEAAwE;;;AAGpH,MAAI,OAAO,MAAM,OAAO;;CAE5B,AAAQ,eAAe,KAAmC,QAAuB,SAAkC;EAC/G,IAAI,MAAM,OAAO,QAAQ,EAAE,MAAM,OAAO,MAAM,KAAKC,KAAqDC;AACxG,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAK;AACD,WAAM,OAAO,QAAQ;AACrB;IACJ,KAAK;AACD,WAAM,WAAW,mBAAmB,QAAQ,OAAO,QAAQ,EAAE,QAAQ;AACrE;IACJ,QAAS,OAAM,IAAI,WAAW,MAAM,2EAA2E;;;AAGvH,MAAI,OAAO,MAAM,OAAO,WAAW,QAAQ;;CAE/C,oBAAoB,SAA2B,QAAuB,SAA4C;AAE9G,OAAK,IAAI,KAAK,WAAW,OAAO,KAAK,QAAQ,MAAM,CAC/C,QAAO,IAAI,GAAGb,+BAAS,gBAAgB,CAAC,MAAM,CAAC,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,EAAE,CAAC,IAAI,GAAGA,+BAAS,OAAO,CAAC,MAAM,QAAQ,MAAM,GAAG,CAAC,MAAM;AAEpJ,MAAI,QAAQ,kBAAkB,EAC1B,QAAO,IAAI,GAAGA,+BAAS,OAAO,CAAC,MAAM,QAAQ,cAAc;AAE/D,MAAI,QAAQ,oBAAoB,EAC5B,QAAO,IAAI,GAAGA,+BAAS,OAAO,CAAC,MAAM,QAAQ,gBAAgB;AAEjE,OAAK,IAAI,KAAK,WAAW,OAAO,KAAK,QAAQ,SAAS,EAAE;AACpD,UAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM,CAAC,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,OAAO,EAAE;AACzF,UAAO,IAAI,GAAGA,+BAAS,gBAAgB,CAAC,MAAM;AAC9C,cAAW,oBAAoB,QAAQ,SAAS,IAAI,QAAQ,QAAQ;AACpE,UAAO,MAAM,CAAC,MAAM;;EAExB,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,mBAAmB,IAAI,uBAAuB;AAE3D,IAAM,kBAAN,cAA8BF,kCAAyB;CACnD,cAAc;AACV,QAAM,iCAAiC,CACnC;GAAE,IAAI;GAAG,MAAM;GAAS,MAAM;GAAU,GAAG;GAAwB,EACnE;GAAE,IAAI;GAAG,MAAM;GAAW,MAAM;GAAU,GAAG;GAAwB,CACxE,CAAC;;CAEN,OAAO,OAAgD;EACnD,MAAM,UAAU,WAAW,OAAO,OAAQ,KAAK,iBAAmB;AAClE,UAAQ,QAAQ;AAChB,UAAQ,UAAU;AAClB,MAAI,UAAU,OACV,mDAAmC,MAAM,SAAS,MAAM;AAC5D,SAAO;;CAEX,mBAAmB,QAAuB,QAAgB,SAA4B,QAAiC;EACnH,IAAI,UAAU,UAAU,KAAK,QAAQ,EAAE,MAAM,OAAO,MAAM;AAC1D,SAAO,OAAO,MAAM,KAAK;GACrB,IAAI,CAAC,SAAS,YAAY,OAAO,KAAK;AACtC,WAAQ,SAAR;IACI,KAAuB;AACnB,aAAQ,QAAQ,OAAO,OAAO;AAC9B;IACJ,KAAyB;AACrB,aAAQ,UAAU,OAAO,OAAO;AAChC;IACJ;KACI,IAAI,IAAI,QAAQ;AAChB,SAAI,MAAM,QACN,OAAM,IAAI,WAAW,MAAM,iBAAiB,QAAQ,cAAc,SAAS,QAAQ,KAAK,WAAW;KACvG,IAAI,IAAI,OAAO,KAAK,SAAS;AAC7B,SAAI,MAAM,MACN,EAAC,MAAM,OAAOE,0CAAoB,SAAS,GAAG,KAAK,UAAU,SAAS,SAAS,UAAU,EAAE;;;AAG3G,SAAO;;CAEX,oBAAoB,SAAqB,QAAuB,SAA4C;AAExG,MAAI,QAAQ,UAAU,EAClB,QAAO,IAAI,GAAGC,+BAAS,OAAO,CAAC,MAAM,QAAQ,MAAM;AAEvD,MAAI,QAAQ,YAAY,EACpB,QAAO,IAAI,GAAGA,+BAAS,OAAO,CAAC,MAAM,QAAQ,QAAQ;EACzD,IAAI,IAAI,QAAQ;AAChB,MAAI,MAAM,MACN,EAAC,KAAK,OAAOD,0CAAoB,UAAU,GAAG,KAAK,UAAU,SAAS,OAAO;AACjF,SAAO;;;;;;AAMf,MAAa,aAAa,IAAI,iBAAiB;;;;AAI/C,MAAa,cAAc,IAAIe,sCAAY,kCAAkC;CACzE;EAAE,MAAM;EAAW,SAAS,EAAE;EAAE,GAAG;EAAgB,GAAG;EAAiB;CACvE;EAAE,MAAM;EAAW,SAAS,EAAE;EAAE,GAAG;EAAgB,GAAG;EAAiB;CACvE;EAAE,MAAM;EAA4B,SAAS,EAAE;EAAE,GAAG;EAAiC,GAAG;EAAkC;CAC7H,CAAC"}