@peerbit/document-interface - npm Package Compare versions

Comparing version 3.0.3 to 3.1.0

dist/src/query.js

@@ -1,9 +0,34 @@
-var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
-    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
-    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
-    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
-    return c > 3 && r && Object.defineProperty(target, key, r), r;
+var __esDecorate = (this && this.__esDecorate) || function (ctor, descriptorIn, decorators, contextIn, initializers, extraInitializers) {
+    function accept(f) { if (f !== void 0 && typeof f !== "function") throw new TypeError("Function expected"); return f; }
+    var kind = contextIn.kind, key = kind === "getter" ? "get" : kind === "setter" ? "set" : "value";
+    var target = !descriptorIn && ctor ? contextIn["static"] ? ctor : ctor.prototype : null;
+    var descriptor = descriptorIn || (target ? Object.getOwnPropertyDescriptor(target, contextIn.name) : {});
+    var _, done = false;
+    for (var i = decorators.length - 1; i >= 0; i--) {
+        var context = {};
+        for (var p in contextIn) context[p] = p === "access" ? {} : contextIn[p];
+        for (var p in contextIn.access) context.access[p] = contextIn.access[p];
+        context.addInitializer = function (f) { if (done) throw new TypeError("Cannot add initializers after decoration has completed"); extraInitializers.push(accept(f || null)); };
+        var result = (0, decorators[i])(kind === "accessor" ? { get: descriptor.get, set: descriptor.set } : descriptor[key], context);
+        if (kind === "accessor") {
+            if (result === void 0) continue;
+            if (result === null || typeof result !== "object") throw new TypeError("Object expected");
+            if (_ = accept(result.get)) descriptor.get = _;
+            if (_ = accept(result.set)) descriptor.set = _;
+            if (_ = accept(result.init)) initializers.unshift(_);
+        }
+        else if (_ = accept(result)) {
+            if (kind === "field") initializers.unshift(_);
+            else descriptor[key] = _;
+        }
+    }
+    if (target) Object.defineProperty(target, contextIn.name, descriptor);
+    done = true;
 };
-var __metadata = (this && this.__metadata) || function (k, v) {
-    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+var __runInitializers = (this && this.__runInitializers) || function (thisArg, initializers, value) {
+    var useValue = arguments.length > 2;
+    for (var i = 0; i < initializers.length; i++) {
+        value = useValue ? initializers[i].call(thisArg, value) : initializers[i].call(thisArg);
+    }
+    return useValue ? value : void 0;
 };
@@ -15,226 +40,313 @@ import { deserialize, field, variant, vec, } from "@dao-xyz/borsh";
 }
-let Context = class Context {
-    created;
-    modified;
-    head;
-    gid;
-    size; // bytes, we index this so we can query documents and understand their representation sizes
-    constructor(properties) {
-        this.created = properties.created;
-        this.modified = properties.modified;
-        this.head = properties.head;
-        this.gid = properties.gid;
-        this.size = properties.size;
-    }
-};
-__decorate([
-    field({ type: "u64" }),
-    __metadata("design:type", BigInt)
-], Context.prototype, "created", void 0);
-__decorate([
-    field({ type: "u64" }),
-    __metadata("design:type", BigInt)
-], Context.prototype, "modified", void 0);
-__decorate([
-    field({ type: "string" }),
-    __metadata("design:type", String)
-], Context.prototype, "head", void 0);
-__decorate([
-    field({ type: "string" }),
-    __metadata("design:type", String)
-], Context.prototype, "gid", void 0);
-__decorate([
-    field({ type: "u32" }),
-    __metadata("design:type", Number)
-], Context.prototype, "size", void 0);
-Context = __decorate([
-    variant(0),
-    __metadata("design:paramtypes", [Object])
-], Context);
+let Context = (() => {
+    let _classDecorators = [variant(0)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _created_decorators;
+    let _created_initializers = [];
+    let _created_extraInitializers = [];
+    let _modified_decorators;
+    let _modified_initializers = [];
+    let _modified_extraInitializers = [];
+    let _head_decorators;
+    let _head_initializers = [];
+    let _head_extraInitializers = [];
+    let _gid_decorators;
+    let _gid_initializers = [];
+    let _gid_extraInitializers = [];
+    let _size_decorators;
+    let _size_initializers = [];
+    let _size_extraInitializers = [];
+    var Context = class {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(null) : void 0;
+            _created_decorators = [field({ type: "u64" })];
+            _modified_decorators = [field({ type: "u64" })];
+            _head_decorators = [field({ type: "string" })];
+            _gid_decorators = [field({ type: "string" })];
+            _size_decorators = [field({ type: "u32" })];
+            __esDecorate(null, null, _created_decorators, { kind: "field", name: "created", static: false, private: false, access: { has: obj => "created" in obj, get: obj => obj.created, set: (obj, value) => { obj.created = value; } }, metadata: _metadata }, _created_initializers, _created_extraInitializers);
+            __esDecorate(null, null, _modified_decorators, { kind: "field", name: "modified", static: false, private: false, access: { has: obj => "modified" in obj, get: obj => obj.modified, set: (obj, value) => { obj.modified = value; } }, metadata: _metadata }, _modified_initializers, _modified_extraInitializers);
+            __esDecorate(null, null, _head_decorators, { kind: "field", name: "head", static: false, private: false, access: { has: obj => "head" in obj, get: obj => obj.head, set: (obj, value) => { obj.head = value; } }, metadata: _metadata }, _head_initializers, _head_extraInitializers);
+            __esDecorate(null, null, _gid_decorators, { kind: "field", name: "gid", static: false, private: false, access: { has: obj => "gid" in obj, get: obj => obj.gid, set: (obj, value) => { obj.gid = value; } }, metadata: _metadata }, _gid_initializers, _gid_extraInitializers);
+            __esDecorate(null, null, _size_decorators, { kind: "field", name: "size", static: false, private: false, access: { has: obj => "size" in obj, get: obj => obj.size, set: (obj, value) => { obj.size = value; } }, metadata: _metadata }, _size_initializers, _size_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            Context = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        created = __runInitializers(this, _created_initializers, void 0);
+        modified = (__runInitializers(this, _created_extraInitializers), __runInitializers(this, _modified_initializers, void 0));
+        head = (__runInitializers(this, _modified_extraInitializers), __runInitializers(this, _head_initializers, void 0));
+        gid = (__runInitializers(this, _head_extraInitializers), __runInitializers(this, _gid_initializers, void 0));
+        size = (__runInitializers(this, _gid_extraInitializers), __runInitializers(this, _size_initializers, void 0)); // bytes, we index this so we can query documents and understand their representation sizes
+        constructor(properties) {
+            __runInitializers(this, _size_extraInitializers);
+            this.created = properties.created;
+            this.modified = properties.modified;
+            this.head = properties.head;
+            this.gid = properties.gid;
+            this.size = properties.size;
+        }
+    };
+    return Context = _classThis;
+})();
 export { Context };
-let ResultValue = class ResultValue extends Result {
-    _source;
-    context;
-    _type;
-    constructor(opts) {
-        super();
-        this._source = opts.source;
-        this.context = opts.context;
-        this._value = opts.value;
-        this.indexed = opts.indexed;
-    }
-    init(type) {
-        this._type = type;
-    }
-    _value;
-    get value() {
-        if (this._value) {
+let ResultValue = (() => {
+    let _classDecorators = [variant(0)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = Result;
+    let __source_decorators;
+    let __source_initializers = [];
+    let __source_extraInitializers = [];
+    let _context_decorators;
+    let _context_initializers = [];
+    let _context_extraInitializers = [];
+    var ResultValue = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            __source_decorators = [field({ type: Uint8Array })];
+            _context_decorators = [field({ type: Context })];
+            __esDecorate(null, null, __source_decorators, { kind: "field", name: "_source", static: false, private: false, access: { has: obj => "_source" in obj, get: obj => obj._source, set: (obj, value) => { obj._source = value; } }, metadata: _metadata }, __source_initializers, __source_extraInitializers);
+            __esDecorate(null, null, _context_decorators, { kind: "field", name: "context", static: false, private: false, access: { has: obj => "context" in obj, get: obj => obj.context, set: (obj, value) => { obj.context = value; } }, metadata: _metadata }, _context_initializers, _context_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            ResultValue = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        _source = __runInitializers(this, __source_initializers, void 0);
+        context = (__runInitializers(this, __source_extraInitializers), __runInitializers(this, _context_initializers, void 0));
+        _type = __runInitializers(this, _context_extraInitializers);
+        constructor(opts) {
+            super();
+            this._source = opts.source;
+            this.context = opts.context;
+            this._value = opts.value;
+            this.indexed = opts.indexed;
+        }
+        init(type) {
+            this._type = type;
+        }
+        _value;
+        get value() {
+            if (this._value) {
+                return this._value;
+            }
+            if (!this._source) {
+                throw new Error("Missing source binary");
+            }
+            this._value = deserialize(this._source, this._type);
             return this._value;
         }
-        if (!this._source) {
-            throw new Error("Missing source binary");
+        // we never send this over the wire since we can always reconstruct it from value
+        indexed;
+    };
+    return ResultValue = _classThis;
+})();
+export { ResultValue };
+let ResultIndexedValue = (() => {
+    let _classDecorators = [variant(1)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = Result;
+    let __source_decorators;
+    let __source_initializers = [];
+    let __source_extraInitializers = [];
+    let _entries_decorators;
+    let _entries_initializers = [];
+    let _entries_extraInitializers = [];
+    let _context_decorators;
+    let _context_initializers = [];
+    let _context_extraInitializers = [];
+    var ResultIndexedValue = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            __source_decorators = [field({ type: Uint8Array })];
+            _entries_decorators = [field({ type: vec(Entry) })];
+            _context_decorators = [field({ type: Context })];
+            __esDecorate(null, null, __source_decorators, { kind: "field", name: "_source", static: false, private: false, access: { has: obj => "_source" in obj, get: obj => obj._source, set: (obj, value) => { obj._source = value; } }, metadata: _metadata }, __source_initializers, __source_extraInitializers);
+            __esDecorate(null, null, _entries_decorators, { kind: "field", name: "entries", static: false, private: false, access: { has: obj => "entries" in obj, get: obj => obj.entries, set: (obj, value) => { obj.entries = value; } }, metadata: _metadata }, _entries_initializers, _entries_extraInitializers);
+            __esDecorate(null, null, _context_decorators, { kind: "field", name: "context", static: false, private: false, access: { has: obj => "context" in obj, get: obj => obj.context, set: (obj, value) => { obj.context = value; } }, metadata: _metadata }, _context_initializers, _context_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            ResultIndexedValue = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
         }
-        this._value = deserialize(this._source, this._type);
-        return this._value;
-    }
-    // we never send this over the wire since we can always reconstruct it from value
-    indexed;
-};
-__decorate([
-    field({ type: Uint8Array }),
-    __metadata("design:type", Uint8Array)
-], ResultValue.prototype, "_source", void 0);
-__decorate([
-    field({ type: Context }),
-    __metadata("design:type", Context)
-], ResultValue.prototype, "context", void 0);
-ResultValue = __decorate([
-    variant(0),
-    __metadata("design:paramtypes", [Object])
-], ResultValue);
-export { ResultValue };
-let ResultIndexedValue = class ResultIndexedValue extends Result {
-    _source;
-    entries;
-    context;
-    _type;
-    constructor(opts) {
-        super();
-        this._source = opts.source;
-        this.context = opts.context;
-        this.indexed = opts.indexed;
-        this.entries = opts.entries;
-        this._value = opts.indexed;
-    }
-    init(type) {
-        this._type = type;
-    }
-    _value;
-    get value() {
-        if (this._value) {
+        _source = __runInitializers(this, __source_initializers, void 0);
+        entries = (__runInitializers(this, __source_extraInitializers), __runInitializers(this, _entries_initializers, void 0));
+        context = (__runInitializers(this, _entries_extraInitializers), __runInitializers(this, _context_initializers, void 0));
+        _type = __runInitializers(this, _context_extraInitializers);
+        constructor(opts) {
+            super();
+            this._source = opts.source;
+            this.context = opts.context;
+            this.indexed = opts.indexed;
+            this.entries = opts.entries;
+            this._value = opts.indexed;
+        }
+        init(type) {
+            this._type = type;
+        }
+        _value;
+        get value() {
+            if (this._value) {
+                return this._value;
+            }
+            if (!this._source) {
+                throw new Error("Missing source binary");
+            }
+            this._value = deserialize(this._source, this._type);
             return this._value;
         }
-        if (!this._source) {
-            throw new Error("Missing source binary");
+        // we never send this over the wire since we can always reconstruct it from value
+        indexed;
+    };
+    return ResultIndexedValue = _classThis;
+})();
+export { ResultIndexedValue };
+let _ResultValueWithIndexedResultValue = (() => {
+    let _classDecorators = [variant(2)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = Result;
+    let __sourceValue_decorators;
+    let __sourceValue_initializers = [];
+    let __sourceValue_extraInitializers = [];
+    let __sourceIndexed_decorators;
+    let __sourceIndexed_initializers = [];
+    let __sourceIndexed_extraInitializers = [];
+    let _entries_decorators;
+    let _entries_initializers = [];
+    let _entries_extraInitializers = [];
+    let _context_decorators;
+    let _context_initializers = [];
+    let _context_extraInitializers = [];
+    var _ResultValueWithIndexedResultValue = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            __sourceValue_decorators = [field({ type: Uint8Array })];
+            __sourceIndexed_decorators = [field({ type: Uint8Array })];
+            _entries_decorators = [field({ type: vec(Entry) })];
+            _context_decorators = [field({ type: Context })];
+            __esDecorate(null, null, __sourceValue_decorators, { kind: "field", name: "_sourceValue", static: false, private: false, access: { has: obj => "_sourceValue" in obj, get: obj => obj._sourceValue, set: (obj, value) => { obj._sourceValue = value; } }, metadata: _metadata }, __sourceValue_initializers, __sourceValue_extraInitializers);
+            __esDecorate(null, null, __sourceIndexed_decorators, { kind: "field", name: "_sourceIndexed", static: false, private: false, access: { has: obj => "_sourceIndexed" in obj, get: obj => obj._sourceIndexed, set: (obj, value) => { obj._sourceIndexed = value; } }, metadata: _metadata }, __sourceIndexed_initializers, __sourceIndexed_extraInitializers);
+            __esDecorate(null, null, _entries_decorators, { kind: "field", name: "entries", static: false, private: false, access: { has: obj => "entries" in obj, get: obj => obj.entries, set: (obj, value) => { obj.entries = value; } }, metadata: _metadata }, _entries_initializers, _entries_extraInitializers);
+            __esDecorate(null, null, _context_decorators, { kind: "field", name: "context", static: false, private: false, access: { has: obj => "context" in obj, get: obj => obj.context, set: (obj, value) => { obj.context = value; } }, metadata: _metadata }, _context_initializers, _context_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            _ResultValueWithIndexedResultValue = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
         }
-        this._value = deserialize(this._source, this._type);
-        return this._value;
-    }
-    // we never send this over the wire since we can always reconstruct it from value
-    indexed;
-};
-__decorate([
-    field({ type: Uint8Array }),
-    __metadata("design:type", Uint8Array)
-], ResultIndexedValue.prototype, "_source", void 0);
-__decorate([
-    field({ type: vec(Entry) }),
-    __metadata("design:type", Array)
-], ResultIndexedValue.prototype, "entries", void 0);
-__decorate([
-    field({ type: Context }),
-    __metadata("design:type", Context)
-], ResultIndexedValue.prototype, "context", void 0);
-ResultIndexedValue = __decorate([
-    variant(1),
-    __metadata("design:paramtypes", [Object])
-], ResultIndexedValue);
-export { ResultIndexedValue };
-let ResultValueWithIndexedResultValue = class ResultValueWithIndexedResultValue extends Result {
-    // not used yet, but
-    _sourceValue;
-    _sourceIndexed;
-    entries;
-    context;
-    _type;
-    _indexedtype;
-    constructor(opts) {
-        super();
-        this._sourceValue = opts.source;
-        this._sourceIndexed = opts.sourceIndexed;
-        this.context = opts.context;
-        this._value = opts.value;
-        this.entries = opts.entries;
-        this.indexed = opts.indexed;
-    }
-    init({ type, indexedType, }) {
-        this._type = type;
-        this._indexedtype = indexedType;
-    }
-    _value;
-    get value() {
-        if (this._value) {
+        // not used yet, but
+        _sourceValue = __runInitializers(this, __sourceValue_initializers, void 0);
+        _sourceIndexed = (__runInitializers(this, __sourceValue_extraInitializers), __runInitializers(this, __sourceIndexed_initializers, void 0));
+        entries = (__runInitializers(this, __sourceIndexed_extraInitializers), __runInitializers(this, _entries_initializers, void 0));
+        context = (__runInitializers(this, _entries_extraInitializers), __runInitializers(this, _context_initializers, void 0));
+        _type = __runInitializers(this, _context_extraInitializers);
+        _indexedtype;
+        constructor(opts) {
+            super();
+            this._sourceValue = opts.source;
+            this._sourceIndexed = opts.sourceIndexed;
+            this.context = opts.context;
+            this._value = opts.value;
+            this.entries = opts.entries;
+            this.indexed = opts.indexed;
+        }
+        init({ type, indexedType, }) {
+            this._type = type;
+            this._indexedtype = indexedType;
+        }
+        _value;
+        get value() {
+            if (this._value) {
+                return this._value;
+            }
+            if (!this._sourceValue) {
+                throw new Error("Missing source binary");
+            }
+            this._value = deserialize(this._sourceValue, this._type);
             return this._value;
         }
-        if (!this._sourceValue) {
-            throw new Error("Missing source binary");
-        }
-        this._value = deserialize(this._sourceValue, this._type);
-        return this._value;
-    }
-    indexed;
-    get indexedValue() {
-        if (this.indexed) {
+        indexed;
+        get indexedValue() {
+            if (this.indexed) {
+                return this.indexed;
+            }
+            if (!this._sourceIndexed) {
+                throw new Error("Missing source binary for indexed value");
+            }
+            this.indexed = deserialize(this._sourceIndexed, this._indexedtype);
             return this.indexed;
         }
-        if (!this._sourceIndexed) {
-            throw new Error("Missing source binary for indexed value");
-        }
-        this.indexed = deserialize(this._sourceIndexed, this._indexedtype);
-        return this.indexed;
-    }
-};
-__decorate([
-    field({ type: Uint8Array }),
-    __metadata("design:type", Uint8Array)
-], ResultValueWithIndexedResultValue.prototype, "_sourceValue", void 0);
-__decorate([
-    field({ type: Uint8Array }),
-    __metadata("design:type", Uint8Array)
-], ResultValueWithIndexedResultValue.prototype, "_sourceIndexed", void 0);
-__decorate([
-    field({ type: vec(Entry) }),
-    __metadata("design:type", Array)
-], ResultValueWithIndexedResultValue.prototype, "entries", void 0);
-__decorate([
-    field({ type: Context }),
-    __metadata("design:type", Context)
-], ResultValueWithIndexedResultValue.prototype, "context", void 0);
-ResultValueWithIndexedResultValue = __decorate([
-    variant(2)
-    // eslint-disable-next-line @typescript-eslint/no-unused-vars
-    // @ts-ignore
-    ,
-    __metadata("design:paramtypes", [Object])
-], ResultValueWithIndexedResultValue);
+    };
+    return _ResultValueWithIndexedResultValue = _classThis;
+})();
 // eslint-disable-next-line @typescript-eslint/no-unused-vars
 export class AbstractSearchResult {
 }
-let Results = class Results extends AbstractSearchResult {
-    results;
-    kept; // how many results that were not sent, but can be collected later
-    constructor(properties) {
-        super();
-        this.kept = properties.kept;
-        this.results = properties.results;
-    }
-};
-__decorate([
-    field({ type: vec(Result) }),
-    __metadata("design:type", Array)
-], Results.prototype, "results", void 0);
-__decorate([
-    field({ type: "u64" }),
-    __metadata("design:type", BigInt)
-], Results.prototype, "kept", void 0);
-Results = __decorate([
-    variant(0),
-    __metadata("design:paramtypes", [Object])
-], Results);
+let Results = (() => {
+    let _classDecorators = [variant(0)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractSearchResult;
+    let _results_decorators;
+    let _results_initializers = [];
+    let _results_extraInitializers = [];
+    let _kept_decorators;
+    let _kept_initializers = [];
+    let _kept_extraInitializers = [];
+    var Results = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _results_decorators = [field({ type: vec(Result) })];
+            _kept_decorators = [field({ type: "u64" })];
+            __esDecorate(null, null, _results_decorators, { kind: "field", name: "results", static: false, private: false, access: { has: obj => "results" in obj, get: obj => obj.results, set: (obj, value) => { obj.results = value; } }, metadata: _metadata }, _results_initializers, _results_extraInitializers);
+            __esDecorate(null, null, _kept_decorators, { kind: "field", name: "kept", static: false, private: false, access: { has: obj => "kept" in obj, get: obj => obj.kept, set: (obj, value) => { obj.kept = value; } }, metadata: _metadata }, _kept_initializers, _kept_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            Results = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        results = __runInitializers(this, _results_initializers, void 0);
+        kept = (__runInitializers(this, _results_extraInitializers), __runInitializers(this, _kept_initializers, void 0)); // how many results that were not sent, but can be collected later
+        constructor(properties) {
+            super();
+            __runInitializers(this, _kept_extraInitializers);
+            this.kept = properties.kept;
+            this.results = properties.results;
+        }
+    };
+    return Results = _classThis;
+})();
 export { Results };
-let NoAccess = class NoAccess extends AbstractSearchResult {
-};
-NoAccess = __decorate([
-    variant(1)
-], NoAccess);
+let NoAccess = (() => {
+    let _classDecorators = [variant(1)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractSearchResult;
+    var NoAccess = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            NoAccess = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+    };
+    return NoAccess = _classThis;
+})();
 export { NoAccess };
@@ -241,0 +353,0 @@ /* @variant(5)

dist/src/query.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"query.js","sourceRoot":"","sources":["../../src/query.ts"],"names":[],"mappings":";;;;;;;;;AAAA,OAAO,EAEN,WAAW,EACX,KAAK,EACL,OAAO,EACP,GAAG,GACH,MAAM,gBAAgB,CAAC;AACxB,OAAO,EAAE,KAAK,EAAE,MAAM,cAAc,CAAC;AAErC,uBAAuB;AAEvB,MAAM,OAAgB,MAAM;CAAG;AAGxB,IAAM,OAAO,GAAb,MAAM,OAAO;IAEnB,OAAO,CAAS;IAGhB,QAAQ,CAAS;IAGjB,IAAI,CAAS;IAGb,GAAG,CAAS;IAGZ,IAAI,CAAS,CAAC,2FAA2F;IAEzG,YAAY,UAMX;QACA,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;QAClC,IAAI,CAAC,QAAQ,GAAG,UAAU,CAAC,QAAQ,CAAC;QACpC,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;QAC5B,IAAI,CAAC,GAAG,GAAG,UAAU,CAAC,GAAG,CAAC;QAC1B,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;IAC7B,CAAC;CACD,CAAA;AA3BA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;wCACP;AAGhB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;yCACN;AAGjB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC;;qCACb;AAGb;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC;;oCACd;AAGZ;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;qCACV;AAdD,OAAO;IADnB,OAAO,CAAC,CAAC,CAAC;;GACE,OAAO,CA6BnB;;AAGM,IAAM,WAAW,GAAjB,MAAM,WAAwC,SAAQ,MAAM;IAElE,OAAO,CAAa;IAGpB,OAAO,CAAU;IAEjB,KAAK,CAAkB;IACvB,YAAY,IAKX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,MAAM,CAAC;QAC3B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC5B,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC;QACzB,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;IAC7B,CAAC;IAED,IAAI,CAAC,IAAqB;QACzB,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC;IACnB,CAAC;IAED,MAAM,CAAK;IACX,IAAI,KAAK;QACR,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YACjB,OAAO,IAAI,CAAC,MAAM,CAAC;QACpB,CAAC;QACD,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;YACnB,MAAM,IAAI,KAAK,CAAC,uBAAuB,CAAC,CAAC;QAC1C,CAAC;QACD,IAAI,CAAC,MAAM,GAAG,WAAW,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,KAAK,CAAC,CAAC;QACpD,OAAO,IAAI,CAAC,MAAM,CAAC;IACpB,CAAC;IAED,iFAAiF;IACjF,OAAO,CAAK;CACZ,CAAA;AArCA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;8BACnB,UAAU;4CAAC;AAGpB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,OAAO,EAAE,CAAC;8BAChB,OAAO;4CAAC;AALL,WAAW;IADvB,OAAO,CAAC,CAAC,CAAC;;GACE,WAAW,CAuCvB;;AAGM,IAAM,kBAAkB,GAAxB,MAAM,kBAAsB,SAAQ,MAAM;IAEhD,OAAO,CAAa;IAGpB,OAAO,CAAe;IAGtB,OAAO,CAAU;IAEjB,KAAK,CAAkB;IAEvB,YAAY,IAKX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,MAAM,CAAC;QAC3B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC5B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC5B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC5B,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,OAAO,CAAC;IAC5B,CAAC;IAED,IAAI,CAAC,IAAqB;QACzB,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC;IACnB,CAAC;IAED,MAAM,CAAK;IACX,IAAI,KAAK;QACR,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YACjB,OAAO,IAAI,CAAC,MAAM,CAAC;QACpB,CAAC;QACD,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;YACnB,MAAM,IAAI,KAAK,CAAC,uBAAuB,CAAC,CAAC;QAC1C,CAAC;QACD,IAAI,CAAC,MAAM,GAAG,WAAW,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,KAAK,CAAC,CAAC;QACpD,OAAO,IAAI,CAAC,MAAM,CAAC;IACpB,CAAC;IAED,iFAAiF;IACjF,OAAO,CAAK;CACZ,CAAA;AA1CA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;8BACnB,UAAU;mDAAC;AAGpB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;;mDACN;AAGtB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,OAAO,EAAE,CAAC;8BAChB,OAAO;mDAAC;AARL,kBAAkB;IAD9B,OAAO,CAAC,CAAC,CAAC;;GACE,kBAAkB,CA4C9B;;AAED,IAGM,iCAAiC,GAHvC,MAGM,iCAAwC,SAAQ,MAAM;IAC3D,oBAAoB;IAEpB,YAAY,CAAa;IAGzB,cAAc,CAAa;IAG3B,OAAO,CAAe;IAGtB,OAAO,CAAU;IAEjB,KAAK,CAAkB;IACvB,YAAY,CAAkB;IAE9B,YAAY,IAQX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,YAAY,GAAG,IAAI,CAAC,MAAM,CAAC;QAChC,IAAI,CAAC,cAAc,GAAG,IAAI,CAAC,aAAa,CAAC;QACzC,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC5B,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC;QACzB,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC5B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;IAC7B,CAAC;IAED,IAAI,CAAC,EACJ,IAAI,EACJ,WAAW,GAIX;QACA,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC;QAClB,IAAI,CAAC,YAAY,GAAG,WAAW,CAAC;IACjC,CAAC;IAED,MAAM,CAAK;IACX,IAAI,KAAK;QACR,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YACjB,OAAO,IAAI,CAAC,MAAM,CAAC;QACpB,CAAC;QACD,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC;YACxB,MAAM,IAAI,KAAK,CAAC,uBAAuB,CAAC,CAAC;QAC1C,CAAC;QACD,IAAI,CAAC,MAAM,GAAG,WAAW,CAAC,IAAI,CAAC,YAAY,EAAE,IAAI,CAAC,KAAK,CAAC,CAAC;QACzD,OAAO,IAAI,CAAC,MAAM,CAAC;IACpB,CAAC;IAED,OAAO,CAAK;IACZ,IAAI,YAAY;QACf,IAAI,IAAI,CAAC,OAAO,EAAE,CAAC;YAClB,OAAO,IAAI,CAAC,OAAO,CAAC;QACrB,CAAC;QACD,IAAI,CAAC,IAAI,CAAC,cAAc,EAAE,CAAC;YAC1B,MAAM,IAAI,KAAK,CAAC,yCAAyC,CAAC,CAAC;QAC5D,CAAC;QACD,IAAI,CAAC,OAAO,GAAG,WAAW,CAAC,IAAI,CAAC,cAAc,EAAE,IAAI,CAAC,YAAY,CAAC,CAAC;QACnE,OAAO,IAAI,CAAC,OAAO,CAAC;IACrB,CAAC;CACD,CAAA;AAlEA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;8BACd,UAAU;uEAAC;AAGzB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;8BACZ,UAAU;yEAAC;AAG3B;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;;kEACN;AAGtB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,OAAO,EAAE,CAAC;8BAChB,OAAO;kEAAC;AAZZ,iCAAiC;IAHtC,OAAO,CAAC,CAAC,CAAC;IACX,6DAA6D;IAC7D,aAAa;;;GACP,iCAAiC,CAqEtC;AAED,6DAA6D;AAC7D,MAAM,OAAgB,oBAAoB;CAAG;AAGtC,IAAM,OAAO,GAAb,MAAM,OAA0B,SAAQ,oBAAoB;IAElE,OAAO,CAAM;IAGb,IAAI,CAAS,CAAC,kEAAkE;IAEhF,YAAY,UAA0C;QACrD,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;QAC5B,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;IACnC,CAAC;CACD,CAAA;AAVA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,MAAM,CAAC,EAAE,CAAC;;wCAChB;AAGb;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;qCACV;AALD,OAAO;IADnB,OAAO,CAAC,CAAC,CAAC;;GACE,OAAO,CAYnB;;AAGM,IAAM,QAAQ,GAAd,MAAM,QAAS,SAAQ,oBAAoB;CAAG,CAAA;AAAxC,QAAQ;IADpB,OAAO,CAAC,CAAC,CAAC;GACE,QAAQ,CAAgC;;AAErD;0CAC0C;AAE1C;;GAEG;AACH;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAwDG"}
+{"version":3,"file":"query.js","sourceRoot":"","sources":["../../src/query.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,OAAO,EAEN,WAAW,EACX,KAAK,EACL,OAAO,EACP,GAAG,GACH,MAAM,gBAAgB,CAAC;AACxB,OAAO,EAAE,KAAK,EAAE,MAAM,cAAc,CAAC;AAErC,uBAAuB;AAEvB,MAAM,OAAgB,MAAM;CAAG;IAGlB,OAAO;4BADnB,OAAO,CAAC,CAAC,CAAC;;;;;;;;;;;;;;;;;;;;;;;mCAET,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;oCAGtB,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;gCAGtB,KAAK,CAAC,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC;+BAGzB,KAAK,CAAC,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC;gCAGzB,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;YAXvB,uKAAA,OAAO,6BAAP,OAAO,yFAAS;YAGhB,0KAAA,QAAQ,6BAAR,QAAQ,2FAAS;YAGjB,8JAAA,IAAI,6BAAJ,IAAI,mFAAS;YAGb,2JAAA,GAAG,6BAAH,GAAG,iFAAS;YAGZ,8JAAA,IAAI,6BAAJ,IAAI,mFAAS;YAdd,6KA6BC;;;YA7BY,uDAAO;;QAEnB,OAAO,0DAAS;QAGhB,QAAQ,kHAAS;QAGjB,IAAI,+GAAS;QAGb,GAAG,0GAAS;QAGZ,IAAI,0GAAS,CAAC,2FAA2F;QAEzG,YAAY,UAMX;;YACA,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;YAClC,IAAI,CAAC,QAAQ,GAAG,UAAU,CAAC,QAAQ,CAAC;YACpC,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;YAC5B,IAAI,CAAC,GAAG,GAAG,UAAU,CAAC,GAAG,CAAC;YAC1B,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;SAC5B;;;;SA5BW,OAAO;IAgCP,WAAW;4BADvB,OAAO,CAAC,CAAC,CAAC;;;;sBACkD,MAAM;;;;;;;2BAAd,SAAQ,WAAM;;;;mCACjE,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;mCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,OAAO,EAAE,CAAC;YAFzB,uKAAA,OAAO,6BAAP,OAAO,yFAAa;YAGpB,uKAAA,OAAO,6BAAP,OAAO,yFAAU;YALlB,6KAuCC;;;YAvCY,uDAAW;;QAEvB,OAAO,0DAAa;QAGpB,OAAO,iHAAU;QAEjB,KAAK,uDAAkB;QACvB,YAAY,IAKX;YACA,KAAK,EAAE,CAAC;YACR,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,MAAM,CAAC;YAC3B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;YAC5B,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC;YACzB,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC7B,CAAC;QAED,IAAI,CAAC,IAAqB;YACzB,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC;QACnB,CAAC;QAED,MAAM,CAAK;QACX,IAAI,KAAK;YACR,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;gBACjB,OAAO,IAAI,CAAC,MAAM,CAAC;YACpB,CAAC;YACD,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;gBACnB,MAAM,IAAI,KAAK,CAAC,uBAAuB,CAAC,CAAC;YAC1C,CAAC;YACD,IAAI,CAAC,MAAM,GAAG,WAAW,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,KAAK,CAAC,CAAC;YACpD,OAAO,IAAI,CAAC,MAAM,CAAC;QACpB,CAAC;QAED,iFAAiF;QACjF,OAAO,CAAK;;;;SAtCA,WAAW;IA0CX,kBAAkB;4BAD9B,OAAO,CAAC,CAAC,CAAC;;;;sBACgC,MAAM;;;;;;;;;;kCAAd,SAAQ,WAAM;;;;mCAC/C,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;mCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;mCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,OAAO,EAAE,CAAC;YALzB,uKAAA,OAAO,6BAAP,OAAO,yFAAa;YAGpB,uKAAA,OAAO,6BAAP,OAAO,yFAAe;YAGtB,uKAAA,OAAO,6BAAP,OAAO,yFAAU;YARlB,6KA4CC;;;YA5CY,uDAAkB;;QAE9B,OAAO,0DAAa;QAGpB,OAAO,iHAAe;QAGtB,OAAO,iHAAU;QAEjB,KAAK,uDAAkB;QAEvB,YAAY,IAKX;YACA,KAAK,EAAE,CAAC;YACR,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,MAAM,CAAC;YAC3B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;YAC5B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;YAC5B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;YAC5B,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,OAAO,CAAC;QAC5B,CAAC;QAED,IAAI,CAAC,IAAqB;YACzB,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC;QACnB,CAAC;QAED,MAAM,CAAK;QACX,IAAI,KAAK;YACR,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;gBACjB,OAAO,IAAI,CAAC,MAAM,CAAC;YACpB,CAAC;YACD,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;gBACnB,MAAM,IAAI,KAAK,CAAC,uBAAuB,CAAC,CAAC;YAC1C,CAAC;YACD,IAAI,CAAC,MAAM,GAAG,WAAW,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,KAAK,CAAC,CAAC;YACpD,OAAO,IAAI,CAAC,MAAM,CAAC;QACpB,CAAC;QAED,iFAAiF;QACjF,OAAO,CAAK;;;;SA3CA,kBAAkB;IAiDzB,kCAAkC;4BAHvC,OAAO,CAAC,CAAC,CAAC;;;;sBAG4C,MAAM;;;;;;;;;;;;;kDAAd,SAAQ,WAAM;;;;wCAE3D,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;0CAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;mCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;mCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,OAAO,EAAE,CAAC;YARzB,sLAAA,YAAY,6BAAZ,YAAY,mGAAa;YAGzB,4LAAA,cAAc,6BAAd,cAAc,uGAAa;YAG3B,uKAAA,OAAO,6BAAP,OAAO,yFAAe;YAGtB,uKAAA,OAAO,6BAAP,OAAO,yFAAU;YAZlB,6KAqEC;;;YArEK,uDAAkC;;QACvC,oBAAoB;QAEpB,YAAY,+DAAa;QAGzB,cAAc,6HAAa;QAG3B,OAAO,wHAAe;QAGtB,OAAO,iHAAU;QAEjB,KAAK,uDAAkB;QACvB,YAAY,CAAkB;QAE9B,YAAY,IAQX;YACA,KAAK,EAAE,CAAC;YACR,IAAI,CAAC,YAAY,GAAG,IAAI,CAAC,MAAM,CAAC;YAChC,IAAI,CAAC,cAAc,GAAG,IAAI,CAAC,aAAa,CAAC;YACzC,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;YAC5B,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC;YACzB,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;YAC5B,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC7B,CAAC;QAED,IAAI,CAAC,EACJ,IAAI,EACJ,WAAW,GAIX;YACA,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC;YAClB,IAAI,CAAC,YAAY,GAAG,WAAW,CAAC;QACjC,CAAC;QAED,MAAM,CAAK;QACX,IAAI,KAAK;YACR,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;gBACjB,OAAO,IAAI,CAAC,MAAM,CAAC;YACpB,CAAC;YACD,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC;gBACxB,MAAM,IAAI,KAAK,CAAC,uBAAuB,CAAC,CAAC;YAC1C,CAAC;YACD,IAAI,CAAC,MAAM,GAAG,WAAW,CAAC,IAAI,CAAC,YAAY,EAAE,IAAI,CAAC,KAAK,CAAC,CAAC;YACzD,OAAO,IAAI,CAAC,MAAM,CAAC;QACpB,CAAC;QAED,OAAO,CAAK;QACZ,IAAI,YAAY;YACf,IAAI,IAAI,CAAC,OAAO,EAAE,CAAC;gBAClB,OAAO,IAAI,CAAC,OAAO,CAAC;YACrB,CAAC;YACD,IAAI,CAAC,IAAI,CAAC,cAAc,EAAE,CAAC;gBAC1B,MAAM,IAAI,KAAK,CAAC,yCAAyC,CAAC,CAAC;YAC5D,CAAC;YACD,IAAI,CAAC,OAAO,GAAG,WAAW,CAAC,IAAI,CAAC,cAAc,EAAE,IAAI,CAAC,YAAY,CAAC,CAAC;YACnE,OAAO,IAAI,CAAC,OAAO,CAAC;QACrB,CAAC;;;;AAGF,6DAA6D;AAC7D,MAAM,OAAgB,oBAAoB;CAAG;IAGhC,OAAO;4BADnB,OAAO,CAAC,CAAC,CAAC;;;;sBACoC,oBAAoB;;;;;;;uBAA5B,SAAQ,WAAoB;;;;mCACjE,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,MAAM,CAAC,EAAE,CAAC;gCAG5B,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;YAFvB,uKAAA,OAAO,6BAAP,OAAO,yFAAM;YAGb,8JAAA,IAAI,6BAAJ,IAAI,mFAAS;YALd,6KAYC;;;YAZY,uDAAO;;QAEnB,OAAO,0DAAM;QAGb,IAAI,8GAAS,CAAC,kEAAkE;QAEhF,YAAY,UAA0C;YACrD,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;YAC5B,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;SAClC;;;;SAXW,OAAO;IAeP,QAAQ;4BADpB,OAAO,CAAC,CAAC,CAAC;;;;sBACmB,oBAAoB;wBAA5B,SAAQ,WAAoB;;;;YAAlD,6KAAqD;;;YAAxC,uDAAQ;;;;;SAAR,QAAQ;AAErB;0CAC0C;AAE1C;;GAEG;AACH;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAwDG"}

dist/src/request.d.ts

@@ -52,3 +52,3 @@ import { Query, Sort } from "@peerbit/indexer-interface";
 }
-export declare class PredictedSearchRequest<R extends Result> extends AbstractSearchRequest {
+export declare class PredictedSearchRequest<_R extends Result> extends AbstractSearchRequest {
     id: Uint8Array;
@@ -63,2 +63,6 @@ request: SearchRequest | SearchRequestIndexed | IterationRequest;
 }
+export declare enum PushUpdatesMode {
+    NOTIFY = 0,
+    STREAM = 1
+}
 export declare class IterationRequest extends AbstractSearchRequest {
@@ -72,3 +76,3 @@ id: Uint8Array;
     keepAliveTtl?: bigint;
-    pushUpdates?: boolean;
+    pushUpdates?: PushUpdatesMode;
     mergeUpdates?: boolean;
@@ -82,3 +86,3 @@ constructor(properties?: {
         keepAliveTtl?: number | bigint;
-        pushUpdates?: boolean;
+        pushUpdates?: boolean | PushUpdatesMode;
         mergeUpdates?: boolean;
@@ -85,0 +89,0 @@ });

dist/src/request.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"request.d.ts","sourceRoot":"","sources":["../../src/request.ts"],"names":[],"mappings":"AAEA,OAAO,EAAE,KAAK,EAAE,IAAI,EAAW,MAAM,4BAA4B,CAAC;AAClE,OAAO,EACN,oBAAoB,EACpB,KAAK,MAAM,EACX,KAAK,kBAAkB,EACvB,KAAK,WAAW,EAChB,MAAM,YAAY,CAAC;AAGpB,MAAM,MAAM,qBAAqB,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,IAAI,CAAC,SAAS,aAAa,GACjE,WAAW,CAAC,CAAC,CAAC,GACd,CAAC,SAAS,oBAAoB,GAC7B,kBAAkB,CAAC,CAAC,CAAC,GACrB,CAAC,SAAS,gBAAgB,GACzB,WAAW,CAAC,CAAC,CAAC,GAAG,kBAAkB,CAAC,CAAC,CAAC,GACtC,WAAW,CAAC,CAAC,CAAC,GAAG,kBAAkB,CAAC,CAAC,CAAC,CAAC;AAS5C,8BAAsB,qBAAqB;IAC1C,QAAQ,KAAK,EAAE,CAAC,EAAE,EAAE,UAAU,EAAE;IAChC,QAAQ,KAAK,EAAE,IAAI,UAAU,CAAC;IAE9B,OAAO,CAAC,SAAS,CAAS;IAC1B,OAAO,CAAC,YAAY,CAAa;IACjC,IAAI,QAAQ,IAAI,MAAM,CAMrB;CACD;AAED,qBACa,aAAc,SAAQ,qBAAqB;IAEvD,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;IAGf,IAAI,EAAE,IAAI,EAAE,CAAC;IAGb,KAAK,EAAE,MAAM,CAAC;gBAEF,KAAK,CAAC,EAAE;QACnB,KAAK,CAAC,EACH,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;QACL,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,IAAI,CAAC;QACrB,KAAK,CAAC,EAAE,MAAM,CAAC;KACf;CAOD;AAED,qBACa,oBAAqB,SAAQ,qBAAqB;IAE9D,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;IAGf,IAAI,EAAE,IAAI,EAAE,CAAC;IAGb,KAAK,EAAE,MAAM,CAAC;IAGd,SAAS,EAAE,OAAO,CAAC;gBAEP,KAAK,CAAC,EAAE;QACnB,KAAK,CAAC,EACH,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;QACL,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,IAAI,CAAC;QACrB,KAAK,CAAC,EAAE,MAAM,CAAC;QACf,SAAS,CAAC,EAAE,OAAO,CAAC;KACpB;CAQD;AAED;;GAEG;AAEH,qBACa,kBAAmB,SAAQ,qBAAqB;IAE5D,EAAE,EAAE,UAAU,CAAC;IAGf,MAAM,EAAE,MAAM,CAAC;gBAEH,UAAU,EAAE;QAAE,EAAE,EAAE,UAAU,CAAC;QAAC,MAAM,EAAE,MAAM,CAAA;KAAE;CAK1D;AAED,qBACa,oBAAqB,SAAQ,qBAAqB;IAE9D,EAAE,EAAE,UAAU,CAAC;gBAEH,UAAU,EAAE;QAAE,EAAE,EAAE,UAAU,CAAA;KAAE;CAI1C;AAED,qBACa,sBAAsB,CAClC,CAAC,SAAS,MAAM,CACf,SAAQ,qBAAqB;IAE9B,EAAE,EAAE,UAAU,CAAC;IAGf,OAAO,EAAE,aAAa,GAAG,oBAAoB,GAAG,gBAAgB,CAAC;IAGjE,OAAO,EAAE,oBAAoB,CAAC;gBAElB,UAAU,EAAE;QACvB,EAAE,CAAC,EAAE,UAAU,CAAC;QAChB,OAAO,EAAE,aAAa,GAAG,oBAAoB,GAAG,gBAAgB,CAAC;QACjE,OAAO,EAAE,oBAAoB,CAAC;KAC9B;CAMD;AAED,qBACa,gBAAiB,SAAQ,qBAAqB;IAE1D,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;IAGf,IAAI,EAAE,IAAI,EAAE,CAAC;IAGb,KAAK,EAAE,MAAM,CAAC;IAGd,OAAO,EAAE,OAAO,CAAC;IAGjB,SAAS,EAAE,OAAO,CAAC;IAGnB,YAAY,CAAC,EAAE,MAAM,CAAC;IAGtB,WAAW,CAAC,EAAE,OAAO,CAAC;IAGtB,YAAY,CAAC,EAAE,OAAO,CAAC;gBAEX,UAAU,CAAC,EAAE;QACxB,KAAK,CAAC,EACH,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;QACL,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,IAAI,CAAC;QACrB,KAAK,CAAC,EAAE,MAAM,CAAC;QACf,OAAO,CAAC,EAAE,OAAO,CAAC;QAClB,SAAS,CAAC,EAAE,OAAO,CAAC;QACpB,YAAY,CAAC,EAAE,MAAM,GAAG,MAAM,CAAC;QAC/B,WAAW,CAAC,EAAE,OAAO,CAAC;QACtB,YAAY,CAAC,EAAE,OAAO,CAAC;KACvB;CAeD;AAED,8BAAsB,qBAAqB;CAAG;AAE9C,qBACa,aAAc,SAAQ,qBAAqB;IAEvD,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;gBAEH,KAAK,EAAE;QAClB,KAAK,EACF,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;KACL;CAKD;AAED,8BAAsB,0BAA0B;CAAG;AAEnD,qBACa,UAAW,SAAQ,0BAA0B;IAEzD,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;IAGf,GAAG,EAAE,MAAM,EAAE,CAAC;gBAEF,KAAK,EAAE;QAClB,KAAK,CAAC,EACH,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;QACL,GAAG,EAAE,MAAM,EAAE,GAAG,MAAM,CAAC;KACvB;CAMD;AAED,8BAAsB,oBAAoB;CAAG;AAE7C,qBACa,YAAa,SAAQ,oBAAoB;IAErD,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;gBAGd,KAAK,GAAE;QACN,KAAK,EACF,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;KACW;CAMlB"}
+{"version":3,"file":"request.d.ts","sourceRoot":"","sources":["../../src/request.ts"],"names":[],"mappings":"AAEA,OAAO,EAAE,KAAK,EAAE,IAAI,EAAW,MAAM,4BAA4B,CAAC;AAClE,OAAO,EACN,oBAAoB,EACpB,KAAK,MAAM,EACX,KAAK,kBAAkB,EACvB,KAAK,WAAW,EAChB,MAAM,YAAY,CAAC;AAGpB,MAAM,MAAM,qBAAqB,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,IAAI,CAAC,SAAS,aAAa,GACjE,WAAW,CAAC,CAAC,CAAC,GACd,CAAC,SAAS,oBAAoB,GAC7B,kBAAkB,CAAC,CAAC,CAAC,GACrB,CAAC,SAAS,gBAAgB,GACzB,WAAW,CAAC,CAAC,CAAC,GAAG,kBAAkB,CAAC,CAAC,CAAC,GACtC,WAAW,CAAC,CAAC,CAAC,GAAG,kBAAkB,CAAC,CAAC,CAAC,CAAC;AAS5C,8BAAsB,qBAAqB;IAC1C,QAAQ,KAAK,EAAE,CAAC,EAAE,EAAE,UAAU,EAAE;IAChC,QAAQ,KAAK,EAAE,IAAI,UAAU,CAAC;IAE9B,OAAO,CAAC,SAAS,CAAS;IAC1B,OAAO,CAAC,YAAY,CAAa;IACjC,IAAI,QAAQ,IAAI,MAAM,CAMrB;CACD;AAED,qBACa,aAAc,SAAQ,qBAAqB;IAEvD,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;IAGf,IAAI,EAAE,IAAI,EAAE,CAAC;IAGb,KAAK,EAAE,MAAM,CAAC;gBAEF,KAAK,CAAC,EAAE;QACnB,KAAK,CAAC,EACH,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;QACL,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,IAAI,CAAC;QACrB,KAAK,CAAC,EAAE,MAAM,CAAC;KACf;CAOD;AAED,qBACa,oBAAqB,SAAQ,qBAAqB;IAE9D,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;IAGf,IAAI,EAAE,IAAI,EAAE,CAAC;IAGb,KAAK,EAAE,MAAM,CAAC;IAGd,SAAS,EAAE,OAAO,CAAC;gBAEP,KAAK,CAAC,EAAE;QACnB,KAAK,CAAC,EACH,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;QACL,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,IAAI,CAAC;QACrB,KAAK,CAAC,EAAE,MAAM,CAAC;QACf,SAAS,CAAC,EAAE,OAAO,CAAC;KACpB;CAQD;AAED;;GAEG;AAEH,qBACa,kBAAmB,SAAQ,qBAAqB;IAE5D,EAAE,EAAE,UAAU,CAAC;IAGf,MAAM,EAAE,MAAM,CAAC;gBAEH,UAAU,EAAE;QAAE,EAAE,EAAE,UAAU,CAAC;QAAC,MAAM,EAAE,MAAM,CAAA;KAAE;CAK1D;AAED,qBACa,oBAAqB,SAAQ,qBAAqB;IAE9D,EAAE,EAAE,UAAU,CAAC;gBAEH,UAAU,EAAE;QAAE,EAAE,EAAE,UAAU,CAAA;KAAE;CAI1C;AAED,qBACa,sBAAsB,CAClC,EAAE,SAAS,MAAM,CAChB,SAAQ,qBAAqB;IAE9B,EAAE,EAAE,UAAU,CAAC;IAGf,OAAO,EAAE,aAAa,GAAG,oBAAoB,GAAG,gBAAgB,CAAC;IAGjE,OAAO,EAAE,oBAAoB,CAAC;gBAElB,UAAU,EAAE;QACvB,EAAE,CAAC,EAAE,UAAU,CAAC;QAChB,OAAO,EAAE,aAAa,GAAG,oBAAoB,GAAG,gBAAgB,CAAC;QACjE,OAAO,EAAE,oBAAoB,CAAC;KAC9B;CAMD;AAED,oBAAY,eAAe;IAC1B,MAAM,IAAI;IACV,MAAM,IAAI;CACV;AAED,qBACa,gBAAiB,SAAQ,qBAAqB;IAE1D,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;IAGf,IAAI,EAAE,IAAI,EAAE,CAAC;IAGb,KAAK,EAAE,MAAM,CAAC;IAGd,OAAO,EAAE,OAAO,CAAC;IAGjB,SAAS,EAAE,OAAO,CAAC;IAGnB,YAAY,CAAC,EAAE,MAAM,CAAC;IAGtB,WAAW,CAAC,EAAE,eAAe,CAAC;IAG9B,YAAY,CAAC,EAAE,OAAO,CAAC;gBAEX,UAAU,CAAC,EAAE;QACxB,KAAK,CAAC,EACH,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;QACL,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,IAAI,CAAC;QACrB,KAAK,CAAC,EAAE,MAAM,CAAC;QACf,OAAO,CAAC,EAAE,OAAO,CAAC;QAClB,SAAS,CAAC,EAAE,OAAO,CAAC;QACpB,YAAY,CAAC,EAAE,MAAM,GAAG,MAAM,CAAC;QAC/B,WAAW,CAAC,EAAE,OAAO,GAAG,eAAe,CAAC;QACxC,YAAY,CAAC,EAAE,OAAO,CAAC;KACvB;CAoBD;AAED,8BAAsB,qBAAqB;CAAG;AAE9C,qBACa,aAAc,SAAQ,qBAAqB;IAEvD,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;gBAEH,KAAK,EAAE;QAClB,KAAK,EACF,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;KACL;CAKD;AAED,8BAAsB,0BAA0B;CAAG;AAEnD,qBACa,UAAW,SAAQ,0BAA0B;IAEzD,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;IAGf,GAAG,EAAE,MAAM,EAAE,CAAC;gBAEF,KAAK,EAAE;QAClB,KAAK,CAAC,EACH,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;QACL,GAAG,EAAE,MAAM,EAAE,GAAG,MAAM,CAAC;KACvB;CAMD;AAED,8BAAsB,oBAAoB;CAAG;AAE7C,qBACa,YAAa,SAAQ,oBAAoB;IAErD,EAAE,EAAE,UAAU,CAAC;IAGf,KAAK,EAAE,KAAK,EAAE,CAAC;gBAGd,KAAK,GAAE;QACN,KAAK,EACF,KAAK,EAAE,GACP,KAAK,GACL,MAAM,CACN,MAAM,EACN,MAAM,GAAG,MAAM,GAAG,MAAM,GAAG,UAAU,GAAG,OAAO,GAAG,IAAI,GAAG,SAAS,CACjE,CAAC;KACW;CAMlB"}

dist/src/request.js

@@ -1,9 +0,34 @@
-var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
-    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
-    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
-    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
-    return c > 3 && r && Object.defineProperty(target, key, r), r;
+var __esDecorate = (this && this.__esDecorate) || function (ctor, descriptorIn, decorators, contextIn, initializers, extraInitializers) {
+    function accept(f) { if (f !== void 0 && typeof f !== "function") throw new TypeError("Function expected"); return f; }
+    var kind = contextIn.kind, key = kind === "getter" ? "get" : kind === "setter" ? "set" : "value";
+    var target = !descriptorIn && ctor ? contextIn["static"] ? ctor : ctor.prototype : null;
+    var descriptor = descriptorIn || (target ? Object.getOwnPropertyDescriptor(target, contextIn.name) : {});
+    var _, done = false;
+    for (var i = decorators.length - 1; i >= 0; i--) {
+        var context = {};
+        for (var p in contextIn) context[p] = p === "access" ? {} : contextIn[p];
+        for (var p in contextIn.access) context.access[p] = contextIn.access[p];
+        context.addInitializer = function (f) { if (done) throw new TypeError("Cannot add initializers after decoration has completed"); extraInitializers.push(accept(f || null)); };
+        var result = (0, decorators[i])(kind === "accessor" ? { get: descriptor.get, set: descriptor.set } : descriptor[key], context);
+        if (kind === "accessor") {
+            if (result === void 0) continue;
+            if (result === null || typeof result !== "object") throw new TypeError("Object expected");
+            if (_ = accept(result.get)) descriptor.get = _;
+            if (_ = accept(result.set)) descriptor.set = _;
+            if (_ = accept(result.init)) initializers.unshift(_);
+        }
+        else if (_ = accept(result)) {
+            if (kind === "field") initializers.unshift(_);
+            else descriptor[key] = _;
+        }
+    }
+    if (target) Object.defineProperty(target, contextIn.name, descriptor);
+    done = true;
 };
-var __metadata = (this && this.__metadata) || function (k, v) {
-    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+var __runInitializers = (this && this.__runInitializers) || function (thisArg, initializers, value) {
+    var useValue = arguments.length > 2;
+    for (var i = 0; i < initializers.length; i++) {
+        value = useValue ? initializers[i].call(thisArg, value) : initializers[i].call(thisArg);
+    }
+    return useValue ? value : void 0;
 };
@@ -29,75 +54,110 @@ import { field, fixedArray, option, variant, vec } from "@dao-xyz/borsh";
 }
-let SearchRequest = class SearchRequest extends AbstractSearchRequest {
-    id; // Session id
-    query;
-    sort;
-    fetch;
-    constructor(props) {
-        super();
-        this.id = randomBytes(32);
-        this.query = props?.query ? toQuery(props.query) : [];
-        this.sort = toArray(props?.sort);
-        this.fetch = props?.fetch ?? 10; // default fetch 10 documents
-    }
-};
-__decorate([
-    field({ type: fixedArray("u8", 32) }),
-    __metadata("design:type", Uint8Array)
-], SearchRequest.prototype, "id", void 0);
-__decorate([
-    field({ type: vec(Query) }),
-    __metadata("design:type", Array)
-], SearchRequest.prototype, "query", void 0);
-__decorate([
-    field({ type: vec(Sort) }),
-    __metadata("design:type", Array)
-], SearchRequest.prototype, "sort", void 0);
-__decorate([
-    field({ type: "u32" }),
-    __metadata("design:type", Number)
-], SearchRequest.prototype, "fetch", void 0);
-SearchRequest = __decorate([
-    variant(0),
-    __metadata("design:paramtypes", [Object])
-], SearchRequest);
+let SearchRequest = (() => {
+    let _classDecorators = [variant(0)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractSearchRequest;
+    let _id_decorators;
+    let _id_initializers = [];
+    let _id_extraInitializers = [];
+    let _query_decorators;
+    let _query_initializers = [];
+    let _query_extraInitializers = [];
+    let _sort_decorators;
+    let _sort_initializers = [];
+    let _sort_extraInitializers = [];
+    let _fetch_decorators;
+    let _fetch_initializers = [];
+    let _fetch_extraInitializers = [];
+    var SearchRequest = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _id_decorators = [field({ type: fixedArray("u8", 32) })];
+            _query_decorators = [field({ type: vec(Query) })];
+            _sort_decorators = [field({ type: vec(Sort) })];
+            _fetch_decorators = [field({ type: "u32" })];
+            __esDecorate(null, null, _id_decorators, { kind: "field", name: "id", static: false, private: false, access: { has: obj => "id" in obj, get: obj => obj.id, set: (obj, value) => { obj.id = value; } }, metadata: _metadata }, _id_initializers, _id_extraInitializers);
+            __esDecorate(null, null, _query_decorators, { kind: "field", name: "query", static: false, private: false, access: { has: obj => "query" in obj, get: obj => obj.query, set: (obj, value) => { obj.query = value; } }, metadata: _metadata }, _query_initializers, _query_extraInitializers);
+            __esDecorate(null, null, _sort_decorators, { kind: "field", name: "sort", static: false, private: false, access: { has: obj => "sort" in obj, get: obj => obj.sort, set: (obj, value) => { obj.sort = value; } }, metadata: _metadata }, _sort_initializers, _sort_extraInitializers);
+            __esDecorate(null, null, _fetch_decorators, { kind: "field", name: "fetch", static: false, private: false, access: { has: obj => "fetch" in obj, get: obj => obj.fetch, set: (obj, value) => { obj.fetch = value; } }, metadata: _metadata }, _fetch_initializers, _fetch_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            SearchRequest = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        id = __runInitializers(this, _id_initializers, void 0); // Session id
+        query = (__runInitializers(this, _id_extraInitializers), __runInitializers(this, _query_initializers, void 0));
+        sort = (__runInitializers(this, _query_extraInitializers), __runInitializers(this, _sort_initializers, void 0));
+        fetch = (__runInitializers(this, _sort_extraInitializers), __runInitializers(this, _fetch_initializers, void 0));
+        constructor(props) {
+            super();
+            __runInitializers(this, _fetch_extraInitializers);
+            this.id = randomBytes(32);
+            this.query = props?.query ? toQuery(props.query) : [];
+            this.sort = toArray(props?.sort);
+            this.fetch = props?.fetch ?? 10; // default fetch 10 documents
+        }
+    };
+    return SearchRequest = _classThis;
+})();
 export { SearchRequest };
-let SearchRequestIndexed = class SearchRequestIndexed extends AbstractSearchRequest {
-    id; // Session id
-    query;
-    sort;
-    fetch;
-    replicate; // is the intent to replicate?
-    constructor(props) {
-        super();
-        this.id = randomBytes(32);
-        this.query = props?.query ? toQuery(props.query) : [];
-        this.sort = toArray(props?.sort);
-        this.fetch = props?.fetch ?? 10; // default fetch 10 documents
-        this.replicate = props.replicate ?? false;
-    }
-};
-__decorate([
-    field({ type: fixedArray("u8", 32) }),
-    __metadata("design:type", Uint8Array)
-], SearchRequestIndexed.prototype, "id", void 0);
-__decorate([
-    field({ type: vec(Query) }),
-    __metadata("design:type", Array)
-], SearchRequestIndexed.prototype, "query", void 0);
-__decorate([
-    field({ type: vec(Sort) }),
-    __metadata("design:type", Array)
-], SearchRequestIndexed.prototype, "sort", void 0);
-__decorate([
-    field({ type: "u32" }),
-    __metadata("design:type", Number)
-], SearchRequestIndexed.prototype, "fetch", void 0);
-__decorate([
-    field({ type: "bool" }),
-    __metadata("design:type", Boolean)
-], SearchRequestIndexed.prototype, "replicate", void 0);
-SearchRequestIndexed = __decorate([
-    variant(1),
-    __metadata("design:paramtypes", [Object])
-], SearchRequestIndexed);
+let SearchRequestIndexed = (() => {
+    let _classDecorators = [variant(1)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractSearchRequest;
+    let _id_decorators;
+    let _id_initializers = [];
+    let _id_extraInitializers = [];
+    let _query_decorators;
+    let _query_initializers = [];
+    let _query_extraInitializers = [];
+    let _sort_decorators;
+    let _sort_initializers = [];
+    let _sort_extraInitializers = [];
+    let _fetch_decorators;
+    let _fetch_initializers = [];
+    let _fetch_extraInitializers = [];
+    let _replicate_decorators;
+    let _replicate_initializers = [];
+    let _replicate_extraInitializers = [];
+    var SearchRequestIndexed = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _id_decorators = [field({ type: fixedArray("u8", 32) })];
+            _query_decorators = [field({ type: vec(Query) })];
+            _sort_decorators = [field({ type: vec(Sort) })];
+            _fetch_decorators = [field({ type: "u32" })];
+            _replicate_decorators = [field({ type: "bool" })];
+            __esDecorate(null, null, _id_decorators, { kind: "field", name: "id", static: false, private: false, access: { has: obj => "id" in obj, get: obj => obj.id, set: (obj, value) => { obj.id = value; } }, metadata: _metadata }, _id_initializers, _id_extraInitializers);
+            __esDecorate(null, null, _query_decorators, { kind: "field", name: "query", static: false, private: false, access: { has: obj => "query" in obj, get: obj => obj.query, set: (obj, value) => { obj.query = value; } }, metadata: _metadata }, _query_initializers, _query_extraInitializers);
+            __esDecorate(null, null, _sort_decorators, { kind: "field", name: "sort", static: false, private: false, access: { has: obj => "sort" in obj, get: obj => obj.sort, set: (obj, value) => { obj.sort = value; } }, metadata: _metadata }, _sort_initializers, _sort_extraInitializers);
+            __esDecorate(null, null, _fetch_decorators, { kind: "field", name: "fetch", static: false, private: false, access: { has: obj => "fetch" in obj, get: obj => obj.fetch, set: (obj, value) => { obj.fetch = value; } }, metadata: _metadata }, _fetch_initializers, _fetch_extraInitializers);
+            __esDecorate(null, null, _replicate_decorators, { kind: "field", name: "replicate", static: false, private: false, access: { has: obj => "replicate" in obj, get: obj => obj.replicate, set: (obj, value) => { obj.replicate = value; } }, metadata: _metadata }, _replicate_initializers, _replicate_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            SearchRequestIndexed = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        id = __runInitializers(this, _id_initializers, void 0); // Session id
+        query = (__runInitializers(this, _id_extraInitializers), __runInitializers(this, _query_initializers, void 0));
+        sort = (__runInitializers(this, _query_extraInitializers), __runInitializers(this, _sort_initializers, void 0));
+        fetch = (__runInitializers(this, _sort_extraInitializers), __runInitializers(this, _fetch_initializers, void 0));
+        replicate = (__runInitializers(this, _fetch_extraInitializers), __runInitializers(this, _replicate_initializers, void 0)); // is the intent to replicate?
+        constructor(props) {
+            super();
+            __runInitializers(this, _replicate_extraInitializers);
+            this.id = randomBytes(32);
+            this.query = props?.query ? toQuery(props.query) : [];
+            this.sort = toArray(props?.sort);
+            this.fetch = props?.fetch ?? 10; // default fetch 10 documents
+            this.replicate = props.replicate ?? false;
+        }
+    };
+    return SearchRequestIndexed = _classThis;
+})();
 export { SearchRequestIndexed };
@@ -107,213 +167,336 @@ /**
  */
-let CollectNextRequest = class CollectNextRequest extends AbstractSearchRequest {
-    id; // collect with id
-    amount; // number of documents to ask for
-    constructor(properties) {
-        super();
-        this.id = properties.id;
-        this.amount = properties.amount;
-    }
-};
-__decorate([
-    field({ type: fixedArray("u8", 32) }),
-    __metadata("design:type", Uint8Array)
-], CollectNextRequest.prototype, "id", void 0);
-__decorate([
-    field({ type: "u32" }),
-    __metadata("design:type", Number)
-], CollectNextRequest.prototype, "amount", void 0);
-CollectNextRequest = __decorate([
-    variant(2),
-    __metadata("design:paramtypes", [Object])
-], CollectNextRequest);
+let CollectNextRequest = (() => {
+    let _classDecorators = [variant(2)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractSearchRequest;
+    let _id_decorators;
+    let _id_initializers = [];
+    let _id_extraInitializers = [];
+    let _amount_decorators;
+    let _amount_initializers = [];
+    let _amount_extraInitializers = [];
+    var CollectNextRequest = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _id_decorators = [field({ type: fixedArray("u8", 32) })];
+            _amount_decorators = [field({ type: "u32" })];
+            __esDecorate(null, null, _id_decorators, { kind: "field", name: "id", static: false, private: false, access: { has: obj => "id" in obj, get: obj => obj.id, set: (obj, value) => { obj.id = value; } }, metadata: _metadata }, _id_initializers, _id_extraInitializers);
+            __esDecorate(null, null, _amount_decorators, { kind: "field", name: "amount", static: false, private: false, access: { has: obj => "amount" in obj, get: obj => obj.amount, set: (obj, value) => { obj.amount = value; } }, metadata: _metadata }, _amount_initializers, _amount_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            CollectNextRequest = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        id = __runInitializers(this, _id_initializers, void 0); // collect with id
+        amount = (__runInitializers(this, _id_extraInitializers), __runInitializers(this, _amount_initializers, void 0)); // number of documents to ask for
+        constructor(properties) {
+            super();
+            __runInitializers(this, _amount_extraInitializers);
+            this.id = properties.id;
+            this.amount = properties.amount;
+        }
+    };
+    return CollectNextRequest = _classThis;
+})();
 export { CollectNextRequest };
-let CloseIteratorRequest = class CloseIteratorRequest extends AbstractSearchRequest {
-    id; // collect with id
-    constructor(properties) {
-        super();
-        this.id = properties.id;
-    }
-};
-__decorate([
-    field({ type: fixedArray("u8", 32) }),
-    __metadata("design:type", Uint8Array)
-], CloseIteratorRequest.prototype, "id", void 0);
-CloseIteratorRequest = __decorate([
-    variant(3),
-    __metadata("design:paramtypes", [Object])
-], CloseIteratorRequest);
+let CloseIteratorRequest = (() => {
+    let _classDecorators = [variant(3)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractSearchRequest;
+    let _id_decorators;
+    let _id_initializers = [];
+    let _id_extraInitializers = [];
+    var CloseIteratorRequest = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _id_decorators = [field({ type: fixedArray("u8", 32) })];
+            __esDecorate(null, null, _id_decorators, { kind: "field", name: "id", static: false, private: false, access: { has: obj => "id" in obj, get: obj => obj.id, set: (obj, value) => { obj.id = value; } }, metadata: _metadata }, _id_initializers, _id_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            CloseIteratorRequest = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        id = __runInitializers(this, _id_initializers, void 0); // collect with id
+        constructor(properties) {
+            super();
+            __runInitializers(this, _id_extraInitializers);
+            this.id = properties.id;
+        }
+    };
+    return CloseIteratorRequest = _classThis;
+})();
 export { CloseIteratorRequest };
-let PredictedSearchRequest = class PredictedSearchRequest extends AbstractSearchRequest {
-    id; // collect with id
-    request;
-    results;
-    constructor(properties) {
-        super();
-        this.id = properties.id || randomBytes(32);
-        this.request = properties.request;
-        this.results = properties.results;
-    }
-};
-__decorate([
-    field({ type: fixedArray("u8", 32) }),
-    __metadata("design:type", Uint8Array)
-], PredictedSearchRequest.prototype, "id", void 0);
-__decorate([
-    field({ type: AbstractSearchRequest }),
-    __metadata("design:type", Object)
-], PredictedSearchRequest.prototype, "request", void 0);
-__decorate([
-    field({ type: AbstractSearchResult }),
-    __metadata("design:type", AbstractSearchResult)
-], PredictedSearchRequest.prototype, "results", void 0);
-PredictedSearchRequest = __decorate([
-    variant(4),
-    __metadata("design:paramtypes", [Object])
-], PredictedSearchRequest);
+let PredictedSearchRequest = (() => {
+    let _classDecorators = [variant(4)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractSearchRequest;
+    let _id_decorators;
+    let _id_initializers = [];
+    let _id_extraInitializers = [];
+    let _request_decorators;
+    let _request_initializers = [];
+    let _request_extraInitializers = [];
+    let _results_decorators;
+    let _results_initializers = [];
+    let _results_extraInitializers = [];
+    var PredictedSearchRequest = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _id_decorators = [field({ type: fixedArray("u8", 32) })];
+            _request_decorators = [field({ type: AbstractSearchRequest })];
+            _results_decorators = [field({ type: AbstractSearchResult })];
+            __esDecorate(null, null, _id_decorators, { kind: "field", name: "id", static: false, private: false, access: { has: obj => "id" in obj, get: obj => obj.id, set: (obj, value) => { obj.id = value; } }, metadata: _metadata }, _id_initializers, _id_extraInitializers);
+            __esDecorate(null, null, _request_decorators, { kind: "field", name: "request", static: false, private: false, access: { has: obj => "request" in obj, get: obj => obj.request, set: (obj, value) => { obj.request = value; } }, metadata: _metadata }, _request_initializers, _request_extraInitializers);
+            __esDecorate(null, null, _results_decorators, { kind: "field", name: "results", static: false, private: false, access: { has: obj => "results" in obj, get: obj => obj.results, set: (obj, value) => { obj.results = value; } }, metadata: _metadata }, _results_initializers, _results_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            PredictedSearchRequest = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        id = __runInitializers(this, _id_initializers, void 0); // collect with id
+        request = (__runInitializers(this, _id_extraInitializers), __runInitializers(this, _request_initializers, void 0));
+        results = (__runInitializers(this, _request_extraInitializers), __runInitializers(this, _results_initializers, void 0));
+        constructor(properties) {
+            super();
+            __runInitializers(this, _results_extraInitializers);
+            this.id = properties.id || randomBytes(32);
+            this.request = properties.request;
+            this.results = properties.results;
+        }
+    };
+    return PredictedSearchRequest = _classThis;
+})();
 export { PredictedSearchRequest };
-let IterationRequest = class IterationRequest extends AbstractSearchRequest {
-    id;
-    query;
-    sort;
-    fetch;
-    resolve;
-    replicate;
-    keepAliveTtl;
-    pushUpdates;
-    mergeUpdates;
-    constructor(properties) {
-        super();
-        this.id = randomBytes(32);
-        this.query = properties?.query ? toQuery(properties.query) : [];
-        this.sort = toArray(properties?.sort);
-        this.fetch = properties?.fetch ?? 10;
-        this.resolve = properties?.resolve ?? true;
-        this.replicate = properties?.replicate ?? false;
-        this.keepAliveTtl =
-            properties?.keepAliveTtl != null
-                ? BigInt(properties.keepAliveTtl)
-                : undefined;
-        this.pushUpdates = properties?.pushUpdates;
-        this.mergeUpdates = properties?.mergeUpdates;
-    }
-};
-__decorate([
-    field({ type: fixedArray("u8", 32) }),
-    __metadata("design:type", Uint8Array)
-], IterationRequest.prototype, "id", void 0);
-__decorate([
-    field({ type: vec(Query) }),
-    __metadata("design:type", Array)
-], IterationRequest.prototype, "query", void 0);
-__decorate([
-    field({ type: vec(Sort) }),
-    __metadata("design:type", Array)
-], IterationRequest.prototype, "sort", void 0);
-__decorate([
-    field({ type: "u32" }),
-    __metadata("design:type", Number)
-], IterationRequest.prototype, "fetch", void 0);
-__decorate([
-    field({ type: "bool" }),
-    __metadata("design:type", Boolean)
-], IterationRequest.prototype, "resolve", void 0);
-__decorate([
-    field({ type: "bool" }),
-    __metadata("design:type", Boolean)
-], IterationRequest.prototype, "replicate", void 0);
-__decorate([
-    field({ type: option("u64") }),
-    __metadata("design:type", BigInt)
-], IterationRequest.prototype, "keepAliveTtl", void 0);
-__decorate([
-    field({ type: option("bool") }),
-    __metadata("design:type", Boolean)
-], IterationRequest.prototype, "pushUpdates", void 0);
-__decorate([
-    field({ type: option("bool") }),
-    __metadata("design:type", Boolean)
-], IterationRequest.prototype, "mergeUpdates", void 0);
-IterationRequest = __decorate([
-    variant(5),
-    __metadata("design:paramtypes", [Object])
-], IterationRequest);
+export var PushUpdatesMode;
+(function (PushUpdatesMode) {
+    PushUpdatesMode[PushUpdatesMode["NOTIFY"] = 0] = "NOTIFY";
+    PushUpdatesMode[PushUpdatesMode["STREAM"] = 1] = "STREAM";
+})(PushUpdatesMode || (PushUpdatesMode = {}));
+let IterationRequest = (() => {
+    let _classDecorators = [variant(5)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractSearchRequest;
+    let _id_decorators;
+    let _id_initializers = [];
+    let _id_extraInitializers = [];
+    let _query_decorators;
+    let _query_initializers = [];
+    let _query_extraInitializers = [];
+    let _sort_decorators;
+    let _sort_initializers = [];
+    let _sort_extraInitializers = [];
+    let _fetch_decorators;
+    let _fetch_initializers = [];
+    let _fetch_extraInitializers = [];
+    let _resolve_decorators;
+    let _resolve_initializers = [];
+    let _resolve_extraInitializers = [];
+    let _replicate_decorators;
+    let _replicate_initializers = [];
+    let _replicate_extraInitializers = [];
+    let _keepAliveTtl_decorators;
+    let _keepAliveTtl_initializers = [];
+    let _keepAliveTtl_extraInitializers = [];
+    let _pushUpdates_decorators;
+    let _pushUpdates_initializers = [];
+    let _pushUpdates_extraInitializers = [];
+    let _mergeUpdates_decorators;
+    let _mergeUpdates_initializers = [];
+    let _mergeUpdates_extraInitializers = [];
+    var IterationRequest = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _id_decorators = [field({ type: fixedArray("u8", 32) })];
+            _query_decorators = [field({ type: vec(Query) })];
+            _sort_decorators = [field({ type: vec(Sort) })];
+            _fetch_decorators = [field({ type: "u32" })];
+            _resolve_decorators = [field({ type: "bool" })];
+            _replicate_decorators = [field({ type: "bool" })];
+            _keepAliveTtl_decorators = [field({ type: option("u64") })];
+            _pushUpdates_decorators = [field({ type: option("u8") })];
+            _mergeUpdates_decorators = [field({ type: option("bool") })];
+            __esDecorate(null, null, _id_decorators, { kind: "field", name: "id", static: false, private: false, access: { has: obj => "id" in obj, get: obj => obj.id, set: (obj, value) => { obj.id = value; } }, metadata: _metadata }, _id_initializers, _id_extraInitializers);
+            __esDecorate(null, null, _query_decorators, { kind: "field", name: "query", static: false, private: false, access: { has: obj => "query" in obj, get: obj => obj.query, set: (obj, value) => { obj.query = value; } }, metadata: _metadata }, _query_initializers, _query_extraInitializers);
+            __esDecorate(null, null, _sort_decorators, { kind: "field", name: "sort", static: false, private: false, access: { has: obj => "sort" in obj, get: obj => obj.sort, set: (obj, value) => { obj.sort = value; } }, metadata: _metadata }, _sort_initializers, _sort_extraInitializers);
+            __esDecorate(null, null, _fetch_decorators, { kind: "field", name: "fetch", static: false, private: false, access: { has: obj => "fetch" in obj, get: obj => obj.fetch, set: (obj, value) => { obj.fetch = value; } }, metadata: _metadata }, _fetch_initializers, _fetch_extraInitializers);
+            __esDecorate(null, null, _resolve_decorators, { kind: "field", name: "resolve", static: false, private: false, access: { has: obj => "resolve" in obj, get: obj => obj.resolve, set: (obj, value) => { obj.resolve = value; } }, metadata: _metadata }, _resolve_initializers, _resolve_extraInitializers);
+            __esDecorate(null, null, _replicate_decorators, { kind: "field", name: "replicate", static: false, private: false, access: { has: obj => "replicate" in obj, get: obj => obj.replicate, set: (obj, value) => { obj.replicate = value; } }, metadata: _metadata }, _replicate_initializers, _replicate_extraInitializers);
+            __esDecorate(null, null, _keepAliveTtl_decorators, { kind: "field", name: "keepAliveTtl", static: false, private: false, access: { has: obj => "keepAliveTtl" in obj, get: obj => obj.keepAliveTtl, set: (obj, value) => { obj.keepAliveTtl = value; } }, metadata: _metadata }, _keepAliveTtl_initializers, _keepAliveTtl_extraInitializers);
+            __esDecorate(null, null, _pushUpdates_decorators, { kind: "field", name: "pushUpdates", static: false, private: false, access: { has: obj => "pushUpdates" in obj, get: obj => obj.pushUpdates, set: (obj, value) => { obj.pushUpdates = value; } }, metadata: _metadata }, _pushUpdates_initializers, _pushUpdates_extraInitializers);
+            __esDecorate(null, null, _mergeUpdates_decorators, { kind: "field", name: "mergeUpdates", static: false, private: false, access: { has: obj => "mergeUpdates" in obj, get: obj => obj.mergeUpdates, set: (obj, value) => { obj.mergeUpdates = value; } }, metadata: _metadata }, _mergeUpdates_initializers, _mergeUpdates_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            IterationRequest = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        id = __runInitializers(this, _id_initializers, void 0);
+        query = (__runInitializers(this, _id_extraInitializers), __runInitializers(this, _query_initializers, void 0));
+        sort = (__runInitializers(this, _query_extraInitializers), __runInitializers(this, _sort_initializers, void 0));
+        fetch = (__runInitializers(this, _sort_extraInitializers), __runInitializers(this, _fetch_initializers, void 0));
+        resolve = (__runInitializers(this, _fetch_extraInitializers), __runInitializers(this, _resolve_initializers, void 0));
+        replicate = (__runInitializers(this, _resolve_extraInitializers), __runInitializers(this, _replicate_initializers, void 0));
+        keepAliveTtl = (__runInitializers(this, _replicate_extraInitializers), __runInitializers(this, _keepAliveTtl_initializers, void 0));
+        pushUpdates = (__runInitializers(this, _keepAliveTtl_extraInitializers), __runInitializers(this, _pushUpdates_initializers, void 0));
+        mergeUpdates = (__runInitializers(this, _pushUpdates_extraInitializers), __runInitializers(this, _mergeUpdates_initializers, void 0));
+        constructor(properties) {
+            super();
+            __runInitializers(this, _mergeUpdates_extraInitializers);
+            this.id = randomBytes(32);
+            this.query = properties?.query ? toQuery(properties.query) : [];
+            this.sort = toArray(properties?.sort);
+            this.fetch = properties?.fetch ?? 10;
+            this.resolve = properties?.resolve ?? true;
+            this.replicate = properties?.replicate ?? false;
+            this.keepAliveTtl =
+                properties?.keepAliveTtl != null
+                    ? BigInt(properties.keepAliveTtl)
+                    : undefined;
+            this.pushUpdates =
+                typeof properties?.pushUpdates === "number"
+                    ? properties.pushUpdates
+                    : properties?.pushUpdates
+                        ? PushUpdatesMode.STREAM
+                        : undefined;
+            this.mergeUpdates = properties?.mergeUpdates;
+        }
+    };
+    return IterationRequest = _classThis;
+})();
 export { IterationRequest };
 export class AbstractDeleteRequest {
 }
-let DeleteRequest = class DeleteRequest extends AbstractDeleteRequest {
-    id; // Session id
-    query;
-    constructor(props) {
-        super();
-        this.id = randomBytes(32);
-        this.query = toQuery(props.query);
-    }
-};
-__decorate([
-    field({ type: fixedArray("u8", 32) }),
-    __metadata("design:type", Uint8Array)
-], DeleteRequest.prototype, "id", void 0);
-__decorate([
-    field({ type: vec(Query) }),
-    __metadata("design:type", Array)
-], DeleteRequest.prototype, "query", void 0);
-DeleteRequest = __decorate([
-    variant(0),
-    __metadata("design:paramtypes", [Object])
-], DeleteRequest);
+let DeleteRequest = (() => {
+    let _classDecorators = [variant(0)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractDeleteRequest;
+    let _id_decorators;
+    let _id_initializers = [];
+    let _id_extraInitializers = [];
+    let _query_decorators;
+    let _query_initializers = [];
+    let _query_extraInitializers = [];
+    var DeleteRequest = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _id_decorators = [field({ type: fixedArray("u8", 32) })];
+            _query_decorators = [field({ type: vec(Query) })];
+            __esDecorate(null, null, _id_decorators, { kind: "field", name: "id", static: false, private: false, access: { has: obj => "id" in obj, get: obj => obj.id, set: (obj, value) => { obj.id = value; } }, metadata: _metadata }, _id_initializers, _id_extraInitializers);
+            __esDecorate(null, null, _query_decorators, { kind: "field", name: "query", static: false, private: false, access: { has: obj => "query" in obj, get: obj => obj.query, set: (obj, value) => { obj.query = value; } }, metadata: _metadata }, _query_initializers, _query_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            DeleteRequest = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        id = __runInitializers(this, _id_initializers, void 0); // Session id
+        query = (__runInitializers(this, _id_extraInitializers), __runInitializers(this, _query_initializers, void 0));
+        constructor(props) {
+            super();
+            __runInitializers(this, _query_extraInitializers);
+            this.id = randomBytes(32);
+            this.query = toQuery(props.query);
+        }
+    };
+    return DeleteRequest = _classThis;
+})();
 export { DeleteRequest };
 export class AbstractAggregationRequest {
 }
-let SumRequest = class SumRequest extends AbstractAggregationRequest {
-    id;
-    query;
-    key;
-    constructor(props) {
-        super();
-        this.id = randomBytes(32);
-        this.query = props.query ? toQuery(props.query) : [];
-        this.key = Array.isArray(props.key) ? props.key : [props.key];
-    }
-};
-__decorate([
-    field({ type: fixedArray("u8", 32) }),
-    __metadata("design:type", Uint8Array)
-], SumRequest.prototype, "id", void 0);
-__decorate([
-    field({ type: vec(Query) }),
-    __metadata("design:type", Array)
-], SumRequest.prototype, "query", void 0);
-__decorate([
-    field({ type: vec("string") }),
-    __metadata("design:type", Array)
-], SumRequest.prototype, "key", void 0);
-SumRequest = __decorate([
-    variant(0),
-    __metadata("design:paramtypes", [Object])
-], SumRequest);
+let SumRequest = (() => {
+    let _classDecorators = [variant(0)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractAggregationRequest;
+    let _id_decorators;
+    let _id_initializers = [];
+    let _id_extraInitializers = [];
+    let _query_decorators;
+    let _query_initializers = [];
+    let _query_extraInitializers = [];
+    let _key_decorators;
+    let _key_initializers = [];
+    let _key_extraInitializers = [];
+    var SumRequest = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _id_decorators = [field({ type: fixedArray("u8", 32) })];
+            _query_decorators = [field({ type: vec(Query) })];
+            _key_decorators = [field({ type: vec("string") })];
+            __esDecorate(null, null, _id_decorators, { kind: "field", name: "id", static: false, private: false, access: { has: obj => "id" in obj, get: obj => obj.id, set: (obj, value) => { obj.id = value; } }, metadata: _metadata }, _id_initializers, _id_extraInitializers);
+            __esDecorate(null, null, _query_decorators, { kind: "field", name: "query", static: false, private: false, access: { has: obj => "query" in obj, get: obj => obj.query, set: (obj, value) => { obj.query = value; } }, metadata: _metadata }, _query_initializers, _query_extraInitializers);
+            __esDecorate(null, null, _key_decorators, { kind: "field", name: "key", static: false, private: false, access: { has: obj => "key" in obj, get: obj => obj.key, set: (obj, value) => { obj.key = value; } }, metadata: _metadata }, _key_initializers, _key_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            SumRequest = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        id = __runInitializers(this, _id_initializers, void 0);
+        query = (__runInitializers(this, _id_extraInitializers), __runInitializers(this, _query_initializers, void 0));
+        key = (__runInitializers(this, _query_extraInitializers), __runInitializers(this, _key_initializers, void 0));
+        constructor(props) {
+            super();
+            __runInitializers(this, _key_extraInitializers);
+            this.id = randomBytes(32);
+            this.query = props.query ? toQuery(props.query) : [];
+            this.key = Array.isArray(props.key) ? props.key : [props.key];
+        }
+    };
+    return SumRequest = _classThis;
+})();
 export { SumRequest };
 export class AbstractCountRequest {
 }
-let CountRequest = class CountRequest extends AbstractCountRequest {
-    id; // Session id
-    query;
-    constructor(props = { query: [] }) {
-        super();
-        this.id = randomBytes(32);
-        this.query = toQuery(props.query);
-    }
-};
-__decorate([
-    field({ type: fixedArray("u8", 32) }),
-    __metadata("design:type", Uint8Array)
-], CountRequest.prototype, "id", void 0);
-__decorate([
-    field({ type: vec(Query) }),
-    __metadata("design:type", Array)
-], CountRequest.prototype, "query", void 0);
-CountRequest = __decorate([
-    variant(0),
-    __metadata("design:paramtypes", [Object])
-], CountRequest);
+let CountRequest = (() => {
+    let _classDecorators = [variant(0)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = AbstractCountRequest;
+    let _id_decorators;
+    let _id_initializers = [];
+    let _id_extraInitializers = [];
+    let _query_decorators;
+    let _query_initializers = [];
+    let _query_extraInitializers = [];
+    var CountRequest = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _id_decorators = [field({ type: fixedArray("u8", 32) })];
+            _query_decorators = [field({ type: vec(Query) })];
+            __esDecorate(null, null, _id_decorators, { kind: "field", name: "id", static: false, private: false, access: { has: obj => "id" in obj, get: obj => obj.id, set: (obj, value) => { obj.id = value; } }, metadata: _metadata }, _id_initializers, _id_extraInitializers);
+            __esDecorate(null, null, _query_decorators, { kind: "field", name: "query", static: false, private: false, access: { has: obj => "query" in obj, get: obj => obj.query, set: (obj, value) => { obj.query = value; } }, metadata: _metadata }, _query_initializers, _query_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            CountRequest = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
+        }
+        id = __runInitializers(this, _id_initializers, void 0); // Session id
+        query = (__runInitializers(this, _id_extraInitializers), __runInitializers(this, _query_initializers, void 0));
+        constructor(props = { query: [] }) {
+            super();
+            __runInitializers(this, _query_extraInitializers);
+            this.id = randomBytes(32);
+            this.query = toQuery(props.query);
+        }
+    };
+    return CountRequest = _classThis;
+})();
 export { CountRequest };
 //# sourceMappingURL=request.js.map

dist/src/request.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"request.js","sourceRoot":"","sources":["../../src/request.ts"],"names":[],"mappings":";;;;;;;;;AAAA,OAAO,EAAE,KAAK,EAAE,UAAU,EAAE,MAAM,EAAE,OAAO,EAAE,GAAG,EAAE,MAAM,gBAAgB,CAAC;AACzE,OAAO,EAAE,WAAW,EAAE,gBAAgB,EAAE,MAAM,iBAAiB,CAAC;AAChE,OAAO,EAAE,KAAK,EAAE,IAAI,EAAE,OAAO,EAAE,MAAM,4BAA4B,CAAC;AAClE,OAAO,EACN,oBAAoB,GAIpB,MAAM,YAAY,CAAC;AAWpB;;GAEG;AAEH,MAAM,OAAO,GAAG,CAAI,GAAwB,EAAE,EAAE,CAC/C,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,SAAS,CAAC,IAAI,EAAE,CAAC;AAE9D,MAAM,OAAgB,qBAAqB;IAIlC,SAAS,CAAS;IAClB,YAAY,CAAa;IACjC,IAAI,QAAQ;QACX,IAAI,IAAI,CAAC,EAAE,KAAK,IAAI,CAAC,YAAY,EAAE,CAAC;YACnC,IAAI,CAAC,SAAS,GAAG,SAAS,CAAC;QAC5B,CAAC;QACD,IAAI,CAAC,YAAY,GAAG,IAAI,CAAC,EAAE,CAAC;QAC5B,OAAO,IAAI,CAAC,SAAS,IAAI,CAAC,IAAI,CAAC,SAAS,GAAG,gBAAgB,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC,CAAC;IACvE,CAAC;CACD;AAGM,IAAM,aAAa,GAAnB,MAAM,aAAc,SAAQ,qBAAqB;IAEvD,EAAE,CAAa,CAAC,aAAa;IAG7B,KAAK,CAAU;IAGf,IAAI,CAAS;IAGb,KAAK,CAAS;IAEd,YAAY,KAUX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;QAC1B,IAAI,CAAC,KAAK,GAAG,KAAK,EAAE,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QACtD,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,KAAK,EAAE,IAAI,CAAC,CAAC;QACjC,IAAI,CAAC,KAAK,GAAG,KAAK,EAAE,KAAK,IAAI,EAAE,CAAC,CAAC,6BAA6B;IAC/D,CAAC;CACD,CAAA;AA5BA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;8BAClC,UAAU;yCAAC;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;;4CACb;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;;2CACd;AAGb;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;4CACT;AAXF,aAAa;IADzB,OAAO,CAAC,CAAC,CAAC;;GACE,aAAa,CA8BzB;;AAGM,IAAM,oBAAoB,GAA1B,MAAM,oBAAqB,SAAQ,qBAAqB;IAE9D,EAAE,CAAa,CAAC,aAAa;IAG7B,KAAK,CAAU;IAGf,IAAI,CAAS;IAGb,KAAK,CAAS;IAGd,SAAS,CAAU,CAAC,8BAA8B;IAElD,YAAY,KAWX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;QAC1B,IAAI,CAAC,KAAK,GAAG,KAAK,EAAE,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QACtD,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,KAAK,EAAE,IAAI,CAAC,CAAC;QACjC,IAAI,CAAC,KAAK,GAAG,KAAK,EAAE,KAAK,IAAI,EAAE,CAAC,CAAC,6BAA6B;QAC9D,IAAI,CAAC,SAAS,GAAG,KAAK,CAAC,SAAS,IAAI,KAAK,CAAC;IAC3C,CAAC;CACD,CAAA;AAjCA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;8BAClC,UAAU;gDAAC;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;;mDACb;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;;kDACd;AAGb;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;mDACT;AAGd;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;;uDACL;AAdP,oBAAoB;IADhC,OAAO,CAAC,CAAC,CAAC;;GACE,oBAAoB,CAmChC;;AAED;;GAEG;AAGI,IAAM,kBAAkB,GAAxB,MAAM,kBAAmB,SAAQ,qBAAqB;IAE5D,EAAE,CAAa,CAAC,kBAAkB;IAGlC,MAAM,CAAS,CAAC,iCAAiC;IAEjD,YAAY,UAA8C;QACzD,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,EAAE,GAAG,UAAU,CAAC,EAAE,CAAC;QACxB,IAAI,CAAC,MAAM,GAAG,UAAU,CAAC,MAAM,CAAC;IACjC,CAAC;CACD,CAAA;AAVA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;8BAClC,UAAU;8CAAC;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;kDACR;AALH,kBAAkB;IAD9B,OAAO,CAAC,CAAC,CAAC;;GACE,kBAAkB,CAY9B;;AAGM,IAAM,oBAAoB,GAA1B,MAAM,oBAAqB,SAAQ,qBAAqB;IAE9D,EAAE,CAAa,CAAC,kBAAkB;IAElC,YAAY,UAA8B;QACzC,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,EAAE,GAAG,UAAU,CAAC,EAAE,CAAC;IACzB,CAAC;CACD,CAAA;AANA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;8BAClC,UAAU;gDAAC;AAFH,oBAAoB;IADhC,OAAO,CAAC,CAAC,CAAC;;GACE,oBAAoB,CAQhC;;AAGM,IAAM,sBAAsB,GAA5B,MAAM,sBAEX,SAAQ,qBAAqB;IAE9B,EAAE,CAAa,CAAC,kBAAkB;IAGlC,OAAO,CAA0D;IAGjE,OAAO,CAAuB;IAE9B,YAAY,UAIX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,EAAE,GAAG,UAAU,CAAC,EAAE,IAAI,WAAW,CAAC,EAAE,CAAC,CAAC;QAC3C,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;QAClC,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;IACnC,CAAC;CACD,CAAA;AAlBA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;8BAClC,UAAU;kDAAC;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,qBAAqB,EAAE,CAAC;;uDAC0B;AAGjE;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,oBAAoB,EAAE,CAAC;8BAC7B,oBAAoB;uDAAC;AAVlB,sBAAsB;IADlC,OAAO,CAAC,CAAC,CAAC;;GACE,sBAAsB,CAsBlC;;AAGM,IAAM,gBAAgB,GAAtB,MAAM,gBAAiB,SAAQ,qBAAqB;IAE1D,EAAE,CAAa;IAGf,KAAK,CAAU;IAGf,IAAI,CAAS;IAGb,KAAK,CAAS;IAGd,OAAO,CAAU;IAGjB,SAAS,CAAU;IAGnB,YAAY,CAAU;IAGtB,WAAW,CAAW;IAGtB,YAAY,CAAW;IAEvB,YAAY,UAeX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;QAC1B,IAAI,CAAC,KAAK,GAAG,UAAU,EAAE,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QAChE,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,UAAU,EAAE,IAAI,CAAC,CAAC;QACtC,IAAI,CAAC,KAAK,GAAG,UAAU,EAAE,KAAK,IAAI,EAAE,CAAC;QACrC,IAAI,CAAC,OAAO,GAAG,UAAU,EAAE,OAAO,IAAI,IAAI,CAAC;QAC3C,IAAI,CAAC,SAAS,GAAG,UAAU,EAAE,SAAS,IAAI,KAAK,CAAC;QAChD,IAAI,CAAC,YAAY;YAChB,UAAU,EAAE,YAAY,IAAI,IAAI;gBAC/B,CAAC,CAAC,MAAM,CAAC,UAAU,CAAC,YAAY,CAAC;gBACjC,CAAC,CAAC,SAAS,CAAC;QACd,IAAI,CAAC,WAAW,GAAG,UAAU,EAAE,WAAW,CAAC;QAC3C,IAAI,CAAC,YAAY,GAAG,UAAU,EAAE,YAAY,CAAC;IAC9C,CAAC;CACD,CAAA;AAxDA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;8BAClC,UAAU;4CAAC;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;;+CACb;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;;8CACd;AAGb;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;+CACT;AAGd;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;;iDACP;AAGjB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;;mDACL;AAGnB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,CAAC,KAAK,CAAC,EAAE,CAAC;;sDACT;AAGtB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,CAAC,MAAM,CAAC,EAAE,CAAC;;qDACV;AAGtB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,CAAC,MAAM,CAAC,EAAE,CAAC;;sDACT;AA1BX,gBAAgB;IAD5B,OAAO,CAAC,CAAC,CAAC;;GACE,gBAAgB,CA0D5B;;AAED,MAAM,OAAgB,qBAAqB;CAAG;AAGvC,IAAM,aAAa,GAAnB,MAAM,aAAc,SAAQ,qBAAqB;IAEvD,EAAE,CAAa,CAAC,aAAa;IAG7B,KAAK,CAAU;IAEf,YAAY,KAQX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;QAC1B,IAAI,CAAC,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;IACnC,CAAC;CACD,CAAA;AAlBA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;8BAClC,UAAU;yCAAC;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;;4CACb;AALH,aAAa;IADzB,OAAO,CAAC,CAAC,CAAC;;GACE,aAAa,CAoBzB;;AAED,MAAM,OAAgB,0BAA0B;CAAG;AAG5C,IAAM,UAAU,GAAhB,MAAM,UAAW,SAAQ,0BAA0B;IAEzD,EAAE,CAAa;IAGf,KAAK,CAAU;IAGf,GAAG,CAAW;IAEd,YAAY,KASX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;QAC1B,IAAI,CAAC,KAAK,GAAG,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QACrD,IAAI,CAAC,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;IAC/D,CAAC;CACD,CAAA;AAvBA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;8BAClC,UAAU;sCAAC;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;;yCACb;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;;uCACjB;AARF,UAAU;IADtB,OAAO,CAAC,CAAC,CAAC;;GACE,UAAU,CAyBtB;;AAED,MAAM,OAAgB,oBAAoB;CAAG;AAGtC,IAAM,YAAY,GAAlB,MAAM,YAAa,SAAQ,oBAAoB;IAErD,EAAE,CAAa,CAAC,aAAa;IAG7B,KAAK,CAAU;IAEf,YACC,QAQI,EAAE,KAAK,EAAE,EAAE,EAAE;QAEjB,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;QAC1B,IAAI,CAAC,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;IACnC,CAAC;CACD,CAAA;AApBA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;8BAClC,UAAU;wCAAC;AAGf;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;;2CACb;AALH,YAAY;IADxB,OAAO,CAAC,CAAC,CAAC;;GACE,YAAY,CAsBxB"}
+{"version":3,"file":"request.js","sourceRoot":"","sources":["../../src/request.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,OAAO,EAAE,KAAK,EAAE,UAAU,EAAE,MAAM,EAAE,OAAO,EAAE,GAAG,EAAE,MAAM,gBAAgB,CAAC;AACzE,OAAO,EAAE,WAAW,EAAE,gBAAgB,EAAE,MAAM,iBAAiB,CAAC;AAChE,OAAO,EAAE,KAAK,EAAE,IAAI,EAAE,OAAO,EAAE,MAAM,4BAA4B,CAAC;AAClE,OAAO,EACN,oBAAoB,GAIpB,MAAM,YAAY,CAAC;AAWpB;;GAEG;AAEH,MAAM,OAAO,GAAG,CAAI,GAAwB,EAAE,EAAE,CAC/C,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,SAAS,CAAC,IAAI,EAAE,CAAC;AAE9D,MAAM,OAAgB,qBAAqB;IAIlC,SAAS,CAAS;IAClB,YAAY,CAAa;IACjC,IAAI,QAAQ;QACX,IAAI,IAAI,CAAC,EAAE,KAAK,IAAI,CAAC,YAAY,EAAE,CAAC;YACnC,IAAI,CAAC,SAAS,GAAG,SAAS,CAAC;QAC5B,CAAC;QACD,IAAI,CAAC,YAAY,GAAG,IAAI,CAAC,EAAE,CAAC;QAC5B,OAAO,IAAI,CAAC,SAAS,IAAI,CAAC,IAAI,CAAC,SAAS,GAAG,gBAAgB,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC,CAAC;IACvE,CAAC;CACD;IAGY,aAAa;4BADzB,OAAO,CAAC,CAAC,CAAC;;;;sBACwB,qBAAqB;;;;;;;;;;;;;6BAA7B,SAAQ,WAAqB;;;;8BACtD,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;iCAGrC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;gCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;iCAG1B,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;YARvB,wJAAA,EAAE,6BAAF,EAAE,+EAAa;YAGf,iKAAA,KAAK,6BAAL,KAAK,qFAAU;YAGf,8JAAA,IAAI,6BAAJ,IAAI,mFAAS;YAGb,iKAAA,KAAK,6BAAL,KAAK,qFAAS;YAXf,6KA8BC;;;YA9BY,uDAAa;;QAEzB,EAAE,qDAAa,CAAC,aAAa;QAG7B,KAAK,0GAAU;QAGf,IAAI,4GAAS;QAGb,KAAK,4GAAS;QAEd,YAAY,KAUX;YACA,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;YAC1B,IAAI,CAAC,KAAK,GAAG,KAAK,EAAE,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;YACtD,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,KAAK,EAAE,IAAI,CAAC,CAAC;YACjC,IAAI,CAAC,KAAK,GAAG,KAAK,EAAE,KAAK,IAAI,EAAE,CAAC,CAAC,6BAA6B;SAC9D;;;;SA7BW,aAAa;IAiCb,oBAAoB;4BADhC,OAAO,CAAC,CAAC,CAAC;;;;sBAC+B,qBAAqB;;;;;;;;;;;;;;;;oCAA7B,SAAQ,WAAqB;;;;8BAC7D,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;iCAGrC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;gCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;iCAG1B,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;qCAGtB,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;YAXxB,wJAAA,EAAE,6BAAF,EAAE,+EAAa;YAGf,iKAAA,KAAK,6BAAL,KAAK,qFAAU;YAGf,8JAAA,IAAI,6BAAJ,IAAI,mFAAS;YAGb,iKAAA,KAAK,6BAAL,KAAK,qFAAS;YAGd,6KAAA,SAAS,6BAAT,SAAS,6FAAU;YAdpB,6KAmCC;;;YAnCY,uDAAoB;;QAEhC,EAAE,qDAAa,CAAC,aAAa;QAG7B,KAAK,0GAAU;QAGf,IAAI,4GAAS;QAGb,KAAK,4GAAS;QAGd,SAAS,iHAAU,CAAC,8BAA8B;QAElD,YAAY,KAWX;YACA,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;YAC1B,IAAI,CAAC,KAAK,GAAG,KAAK,EAAE,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;YACtD,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,KAAK,EAAE,IAAI,CAAC,CAAC;YACjC,IAAI,CAAC,KAAK,GAAG,KAAK,EAAE,KAAK,IAAI,EAAE,CAAC,CAAC,6BAA6B;YAC9D,IAAI,CAAC,SAAS,GAAG,KAAK,CAAC,SAAS,IAAI,KAAK,CAAC;SAC1C;;;;SAlCW,oBAAoB;AAqCjC;;GAEG;IAGU,kBAAkB;4BAD9B,OAAO,CAAC,CAAC,CAAC;;;;sBAC6B,qBAAqB;;;;;;;kCAA7B,SAAQ,WAAqB;;;;8BAC3D,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;kCAGrC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;YAFvB,wJAAA,EAAE,6BAAF,EAAE,+EAAa;YAGf,oKAAA,MAAM,6BAAN,MAAM,uFAAS;YALhB,6KAYC;;;YAZY,uDAAkB;;QAE9B,EAAE,qDAAa,CAAC,kBAAkB;QAGlC,MAAM,2GAAS,CAAC,iCAAiC;QAEjD,YAAY,UAA8C;YACzD,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,EAAE,GAAG,UAAU,CAAC,EAAE,CAAC;YACxB,IAAI,CAAC,MAAM,GAAG,UAAU,CAAC,MAAM,CAAC;SAChC;;;;SAXW,kBAAkB;IAelB,oBAAoB;4BADhC,OAAO,CAAC,CAAC,CAAC;;;;sBAC+B,qBAAqB;;;;oCAA7B,SAAQ,WAAqB;;;;8BAC7D,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;YACtC,wJAAA,EAAE,6BAAF,EAAE,+EAAa;YAFhB,6KAQC;;;YARY,uDAAoB;;QAEhC,EAAE,qDAAa,CAAC,kBAAkB;QAElC,YAAY,UAA8B;YACzC,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,EAAE,GAAG,UAAU,CAAC,EAAE,CAAC;SACxB;;;;SAPW,oBAAoB;IAWpB,sBAAsB;4BADlC,OAAO,CAAC,CAAC,CAAC;;;;sBAGD,qBAAqB;;;;;;;;;;sCAA7B,SAAQ,WAAqB;;;;8BAC7B,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;mCAGrC,KAAK,CAAC,EAAE,IAAI,EAAE,qBAAqB,EAAE,CAAC;mCAGtC,KAAK,CAAC,EAAE,IAAI,EAAE,oBAAoB,EAAE,CAAC;YALtC,wJAAA,EAAE,6BAAF,EAAE,+EAAa;YAGf,uKAAA,OAAO,6BAAP,OAAO,yFAA0D;YAGjE,uKAAA,OAAO,6BAAP,OAAO,yFAAuB;YAV/B,6KAsBC;;;YAtBY,uDAAsB;;QAIlC,EAAE,qDAAa,CAAC,kBAAkB;QAGlC,OAAO,4GAA0D;QAGjE,OAAO,iHAAuB;QAE9B,YAAY,UAIX;YACA,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,EAAE,GAAG,UAAU,CAAC,EAAE,IAAI,WAAW,CAAC,EAAE,CAAC,CAAC;YAC3C,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;YAClC,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;SAClC;;;;SArBW,sBAAsB;AAwBnC,MAAM,CAAN,IAAY,eAGX;AAHD,WAAY,eAAe;IAC1B,yDAAU,CAAA;IACV,yDAAU,CAAA;AACX,CAAC,EAHW,eAAe,KAAf,eAAe,QAG1B;IAGY,gBAAgB;4BAD5B,OAAO,CAAC,CAAC,CAAC;;;;sBAC2B,qBAAqB;;;;;;;;;;;;;;;;;;;;;;;;;;;;gCAA7B,SAAQ,WAAqB;;;;8BACzD,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;iCAGrC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;gCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;iCAG1B,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;mCAGtB,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;qCAGvB,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;wCAGvB,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,CAAC,KAAK,CAAC,EAAE,CAAC;uCAG9B,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC;wCAG7B,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,CAAC,MAAM,CAAC,EAAE,CAAC;YAvBhC,wJAAA,EAAE,6BAAF,EAAE,+EAAa;YAGf,iKAAA,KAAK,6BAAL,KAAK,qFAAU;YAGf,8JAAA,IAAI,6BAAJ,IAAI,mFAAS;YAGb,iKAAA,KAAK,6BAAL,KAAK,qFAAS;YAGd,uKAAA,OAAO,6BAAP,OAAO,yFAAU;YAGjB,6KAAA,SAAS,6BAAT,SAAS,6FAAU;YAGnB,sLAAA,YAAY,6BAAZ,YAAY,mGAAU;YAGtB,mLAAA,WAAW,6BAAX,WAAW,iGAAmB;YAG9B,sLAAA,YAAY,6BAAZ,YAAY,mGAAW;YA1BxB,6KA+DC;;;YA/DY,uDAAgB;;QAE5B,EAAE,qDAAa;QAGf,KAAK,0GAAU;QAGf,IAAI,4GAAS;QAGb,KAAK,4GAAS;QAGd,OAAO,+GAAU;QAGjB,SAAS,mHAAU;QAGnB,YAAY,wHAAU;QAGtB,WAAW,0HAAmB;QAG9B,YAAY,0HAAW;QAEvB,YAAY,UAeX;YACA,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;YAC1B,IAAI,CAAC,KAAK,GAAG,UAAU,EAAE,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;YAChE,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,UAAU,EAAE,IAAI,CAAC,CAAC;YACtC,IAAI,CAAC,KAAK,GAAG,UAAU,EAAE,KAAK,IAAI,EAAE,CAAC;YACrC,IAAI,CAAC,OAAO,GAAG,UAAU,EAAE,OAAO,IAAI,IAAI,CAAC;YAC3C,IAAI,CAAC,SAAS,GAAG,UAAU,EAAE,SAAS,IAAI,KAAK,CAAC;YAChD,IAAI,CAAC,YAAY;gBAChB,UAAU,EAAE,YAAY,IAAI,IAAI;oBAC/B,CAAC,CAAC,MAAM,CAAC,UAAU,CAAC,YAAY,CAAC;oBACjC,CAAC,CAAC,SAAS,CAAC;YACd,IAAI,CAAC,WAAW;gBACf,OAAO,UAAU,EAAE,WAAW,KAAK,QAAQ;oBAC1C,CAAC,CAAC,UAAU,CAAC,WAAW;oBACxB,CAAC,CAAC,UAAU,EAAE,WAAW;wBACxB,CAAC,CAAC,eAAe,CAAC,MAAM;wBACxB,CAAC,CAAC,SAAS,CAAC;YACf,IAAI,CAAC,YAAY,GAAG,UAAU,EAAE,YAAY,CAAC;SAC7C;;;;SA9DW,gBAAgB;AAiE7B,MAAM,OAAgB,qBAAqB;CAAG;IAGjC,aAAa;4BADzB,OAAO,CAAC,CAAC,CAAC;;;;sBACwB,qBAAqB;;;;;;;6BAA7B,SAAQ,WAAqB;;;;8BACtD,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;iCAGrC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;YAF5B,wJAAA,EAAE,6BAAF,EAAE,+EAAa;YAGf,iKAAA,KAAK,6BAAL,KAAK,qFAAU;YALhB,6KAoBC;;;YApBY,uDAAa;;QAEzB,EAAE,qDAAa,CAAC,aAAa;QAG7B,KAAK,0GAAU;QAEf,YAAY,KAQX;YACA,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;YAC1B,IAAI,CAAC,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;SAClC;;;;SAnBW,aAAa;AAsB1B,MAAM,OAAgB,0BAA0B;CAAG;IAGtC,UAAU;4BADtB,OAAO,CAAC,CAAC,CAAC;;;;sBACqB,0BAA0B;;;;;;;;;;0BAAlC,SAAQ,WAA0B;;;;8BACxD,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;iCAGrC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;+BAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;YAL/B,wJAAA,EAAE,6BAAF,EAAE,+EAAa;YAGf,iKAAA,KAAK,6BAAL,KAAK,qFAAU;YAGf,2JAAA,GAAG,6BAAH,GAAG,iFAAW;YARf,6KAyBC;;;YAzBY,uDAAU;;QAEtB,EAAE,qDAAa;QAGf,KAAK,0GAAU;QAGf,GAAG,2GAAW;QAEd,YAAY,KASX;YACA,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;YAC1B,IAAI,CAAC,KAAK,GAAG,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;YACrD,IAAI,CAAC,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;SAC9D;;;;SAxBW,UAAU;AA2BvB,MAAM,OAAgB,oBAAoB;CAAG;IAGhC,YAAY;4BADxB,OAAO,CAAC,CAAC,CAAC;;;;sBACuB,oBAAoB;;;;;;;4BAA5B,SAAQ,WAAoB;;;;8BACpD,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,CAAC,IAAI,EAAE,EAAE,CAAC,EAAE,CAAC;iCAGrC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;YAF5B,wJAAA,EAAE,6BAAF,EAAE,+EAAa;YAGf,iKAAA,KAAK,6BAAL,KAAK,qFAAU;YALhB,6KAsBC;;;YAtBY,uDAAY;;QAExB,EAAE,qDAAa,CAAC,aAAa;QAG7B,KAAK,0GAAU;QAEf,YACC,QAQI,EAAE,KAAK,EAAE,EAAE,EAAE;YAEjB,KAAK,EAAE,CAAC;;YACR,IAAI,CAAC,EAAE,GAAG,WAAW,CAAC,EAAE,CAAC,CAAC;YAC1B,IAAI,CAAC,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;SAClC;;;;SArBW,YAAY"}

package.json

 {
   "name": "@peerbit/document-interface",
-  "version": "3.0.3",
+  "version": "3.1.0",
   "description": "Document store interface",
@@ -55,6 +55,6 @@ "sideEffects": false,
   "dependencies": {
-    "@dao-xyz/borsh": "^5.2.3",
-    "@peerbit/indexer-interface": "2.0.14",
-    "@peerbit/crypto": "2.3.13",
-    "@peerbit/log": "4.1.11"
+    "@dao-xyz/borsh": "^6.0.0",
+    "@peerbit/crypto": "2.4.0",
+    "@peerbit/indexer-interface": "2.1.0",
+    "@peerbit/log": "4.2.0"
   },
@@ -61,0 +61,0 @@ "scripts": {

src/query.ts

@@ -138,3 +138,3 @@ import {
 // @ts-ignore
-class ResultValueWithIndexedResultValue<T, I> extends Result {
+class _ResultValueWithIndexedResultValue<T, I> extends Result {
 	// not used yet, but
@@ -141,0 +141,0 @@ @field({ type: Uint8Array })

src/request.ts

@@ -145,3 +145,3 @@ import { field, fixedArray, option, variant, vec } from "@dao-xyz/borsh";
 export class PredictedSearchRequest<
-	R extends Result,
+	_R extends Result,
 > extends AbstractSearchRequest {
@@ -169,2 +169,7 @@ @field({ type: fixedArray("u8", 32) })
 
+export enum PushUpdatesMode {
+	NOTIFY = 0,
+	STREAM = 1,
+}
+
 @variant(5)
@@ -193,4 +198,4 @@ export class IterationRequest extends AbstractSearchRequest {
 
-	@field({ type: option("bool") })
-	pushUpdates?: boolean;
+	@field({ type: option("u8") })
+	pushUpdates?: PushUpdatesMode;
 
@@ -213,3 +218,3 @@ @field({ type: option("bool") })
 		keepAliveTtl?: number | bigint;
-		pushUpdates?: boolean;
+		pushUpdates?: boolean | PushUpdatesMode;
 		mergeUpdates?: boolean;
@@ -228,3 +233,8 @@ }) {
 				: undefined;
-		this.pushUpdates = properties?.pushUpdates;
+		this.pushUpdates =
+			typeof properties?.pushUpdates === "number"
+				? properties.pushUpdates
+				: properties?.pushUpdates
+					? PushUpdatesMode.STREAM
+					: undefined;
 		this.mergeUpdates = properties?.mergeUpdates;
@@ -231,0 +241,0 @@ }

New alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

109800

54.27%

Lines of code

1653

24.75%

Worsened metrics

Number of medium supply chain risk alerts

43

26.47%

Dependency changes

• + Added

  @dao-xyz/borsh@6.0.1
  (transitive)

• + Added

  @peerbit/any-store@2.2.0
  (transitive)

• + Added

  @peerbit/any-store-interface@1.1.0
  (transitive)

• + Added

  @peerbit/any-store-opfs@1.1.0
  (transitive)

• + Added

  @peerbit/blocks@3.1.0
  (transitive)

• + Added

  @peerbit/blocks-interface@1.5.0
  (transitive)

• + Added

  @peerbit/build-assets@1.1.0
  (transitive)

• + Added

  @peerbit/cache@2.2.0
  (transitive)

• + Added

  @peerbit/crypto@2.4.0
  (transitive)

• + Added

  @peerbit/indexer-interface@2.1.0
  (transitive)

• + Added

  @peerbit/indexer-simple@1.2.0
  (transitive)

• + Added

  @peerbit/indexer-sqlite3@1.3.0
  (transitive)

• + Added

  @peerbit/keychain@1.2.0
  (transitive)

• + Added

  @peerbit/log@4.2.0
  (transitive)

• + Added

  @peerbit/logger@2.0.0
  (transitive)

• + Added

  @peerbit/pubsub-interface@4.1.0
  (transitive)

• + Added

  @peerbit/stream@4.5.0
  (transitive)

• + Added

  @peerbit/stream-interface@5.3.0
  (transitive)

• + Added

  @peerbit/time@2.3.0
  (transitive)

• + Added

  @sqlite.org/sqlite-wasm@3.51.1-build2
  (transitive)

• - Removed

  @dao-xyz/borsh@5.2.4
  (transitive)

• - Removed

  @peerbit/any-store@2.1.16
  (transitive)

• - Removed

  @peerbit/any-store-interface@1.0.1
  (transitive)

• - Removed

  @peerbit/any-store-opfs@1.0.15
  (transitive)

• - Removed

  @peerbit/blocks@3.0.15
  (transitive)

• - Removed

  @peerbit/blocks-interface@1.4.14
  (transitive)

• - Removed

  @peerbit/build-assets@1.0.0
  (transitive)

• - Removed

  @peerbit/cache@2.1.5
  (transitive)

• - Removed

  @peerbit/crypto@2.3.13
  (transitive)

• - Removed

  @peerbit/indexer-interface@2.0.14
  (transitive)

• - Removed

  @peerbit/indexer-simple@1.1.21
  (transitive)

• - Removed

  @peerbit/indexer-sqlite3@1.2.30
  (transitive)

• - Removed

  @peerbit/keychain@1.1.2
  (transitive)

• - Removed

  @peerbit/log@4.1.11
  (transitive)

• - Removed

  @peerbit/logger@1.0.4
  (transitive)

• - Removed

  @peerbit/pubsub-interface@4.0.9
  (transitive)

• - Removed

  @peerbit/stream@4.4.7
  (transitive)

• - Removed

  @peerbit/stream-interface@5.2.10
  (transitive)

• - Removed

  @peerbit/time@2.2.0
  (transitive)

• - Removed

  @sqlite.org/sqlite-wasm@3.50.4-build1
  (transitive)

• - Removed

  abort-controller@3.0.0
  (transitive)

• - Removed

  event-target-shim@5.0.1
  (transitive)

• - Removed

  events@3.3.0
  (transitive)

• - Removed

  fast-redact@3.5.0
  (transitive)

• - Removed

  pino@8.21.0
  (transitive)

• - Removed

  pino-abstract-transport@1.2.0
  (transitive)

• - Removed

  pino-std-serializers@6.2.2
  (transitive)

• - Removed

  process@0.11.10
  (transitive)

• - Removed

  process-warning@3.0.0
  (transitive)

• - Removed

  readable-stream@4.7.0
  (transitive)

• - Removed

  sonic-boom@3.8.1
  (transitive)

• - Removed

  thread-stream@2.7.0
  (transitive)

• Updated

  @dao-xyz/borsh@^6.0.0

• Updated

  @peerbit/crypto@2.4.0

• Updated

  @peerbit/indexer-interface@2.1.0

• Updated

  @peerbit/log@4.2.0