diff --git a/.gitignore b/.gitignore
deleted file mode 100644
index 95d1bf6..0000000
--- a/.gitignore
+++ /dev/null
@@ -1,7 +0,0 @@
-lib
-node_modules
-
-.vscode
-.idea
-.vs
-.package-lock.json
\ No newline at end of file
diff --git a/lib/index.d.ts b/lib/index.d.ts
new file mode 100644
index 0000000..22986d9
--- /dev/null
+++ b/lib/index.d.ts
@@ -0,0 +1,144 @@
+import { DocumentClient, ConnectionPolicy, NewDocument, RequestOptions, DocumentOptions, FeedOptions, SqlQuerySpec } from 'documentdb';
+export default class DocumentDBClient<TEntity extends NewDocument> {
+    private host;
+    private key;
+    private databaseId;
+    private collectionId;
+    private _client;
+    private _policy;
+    private offerSelfLink;
+    private offerReserved;
+    private _washDocuments;
+    constructor(host: string, key: string, databaseId: string, collectionId: string);
+    readonly policy: ConnectionPolicy;
+    washDocuments: boolean;
+    /**
+     * Fetches entities from an asynchronious iterator
+     * @param iterator an async iterable iterator
+     * @param quantity number of items to fetch, any number below zero will fetch all
+     */
+    static fromAsyncIterable<TEntity>(iterator: AsyncIterableIterator<TEntity>, quantity?: number): Promise<TEntity[]>;
+    /**
+     * Reads a document by its id
+     * @param id
+     * @param options
+     */
+    readDocument(id: string, options?: RequestOptions): Promise<{
+        resource: TEntity;
+        etag: string;
+        headers: any;
+    }>;
+    /**
+     * Reads a document by its document id
+     * @param document
+     * @param options
+     */
+    readDocument(document: TEntity, options?: RequestOptions): Promise<{
+        resource: TEntity;
+        etag: string;
+        headers: any;
+    }>;
+    /**
+     * Query for the documents with paging using ContinuationToken
+     * @param query
+     * @param options
+     */
+    queryDocuments(query: string | SqlQuerySpec, options?: FeedOptions): Promise<{
+        resources: TEntity[];
+        continuationToken: string;
+        headers: any;
+    }>;
+    /**
+     * Iterate through documents asynchronious with `for await()`
+     * @param query
+     * @param options
+     */
+    iterateDocuments(query: string | SqlQuerySpec, options?: FeedOptions): AsyncIterableIterator<TEntity>;
+    /**
+     * Creates a new document that doesn't exists.
+     * @param document
+     * @param options
+     */
+    createDocument(document: TEntity, options?: DocumentOptions): Promise<{
+        resource: TEntity;
+        headers: any;
+    }>;
+    /**
+     * Updates a document that exists by patching the changes, will retry 3 times before giving up.
+     * @param document
+     * @param options
+     */
+    updateDocument(document: Partial<TEntity>, options?: RequestOptions): Promise<{
+        resource: TEntity;
+        headers: any;
+    }>;
+    /**
+     * Replaces a document that exists.
+     * @param document
+     * @param options
+     */
+    replaceDocument(document: TEntity, options?: RequestOptions): Promise<{
+        resource: TEntity;
+        headers: any;
+    }>;
+    /**
+     * Creates a new document or replacing it if it exists
+     * @param document
+     * @param options
+     */
+    upsertDocument(document: TEntity, options?: DocumentOptions): Promise<{
+        resource: TEntity;
+        headers: any;
+    }>;
+    /**
+     * Deletes a document by its document id
+     * @param document
+     */
+    deleteDocument(document: TEntity, options?: RequestOptions): Promise<{
+        resource: void;
+        headers: any;
+    }>;
+    /**
+     * Deletes a document by its id
+     * @param id
+     */
+    deleteDocument(id: string, options?: RequestOptions): Promise<{
+        resource: void;
+        headers: any;
+    }>;
+    /**
+     * Get the current throughput (RU/s)
+     */
+    getThroughput(): Promise<number>;
+    /**
+     * Set the throughput (RU/s) to any number between 400 and 10000
+     * @param value RU/s
+     */
+    setThroughput(value: number): Promise<boolean>;
+    /**
+     * Increase the throughput (RU/s), defaults to 200. Will never exceed 10000
+     * @param value RU/s
+     */
+    increaseThroughput(value?: number): Promise<number>;
+    /**
+     * Decrease the throughput (RU/s), defaults to 200. Will never go below 400
+     * @param value RU/s
+     */
+    decreaseThroughput(value?: number): Promise<number>;
+    private reserveOffer;
+    private getOffer;
+    protected readonly client: DocumentClient;
+    protected createDatabaseLink(): string;
+    protected createCollectionLink(): string;
+    protected createDocumentLink(id: string): string;
+    protected createDocumentLink(document: TEntity): string;
+    private executeNext;
+    private makeEntity;
+    private makeDocument;
+    private delay;
+    private transformError;
+    private validateOptions;
+    private getHeaders;
+    private apply;
+    private isClass;
+}
diff --git a/lib/index.js b/lib/index.js
new file mode 100644
index 0000000..2e94d69
--- /dev/null
+++ b/lib/index.js
@@ -0,0 +1,606 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const tslib_1 = require("tslib");
+if (!Symbol.asyncIterator)
+    Symbol.asyncIterator = Symbol.asyncIterator || "__@@asyncIterator__";
+const documentdb_1 = require("documentdb");
+const lib_1 = require("documentdb/lib");
+const Constants = require("documentdb/lib/constants");
+class DocumentDBClient {
+    constructor(host, key, databaseId, collectionId) {
+        this.host = host;
+        this.key = key;
+        this.databaseId = databaseId;
+        this.collectionId = collectionId;
+        this.offerReserved = false;
+        this._washDocuments = true;
+    }
+    get policy() {
+        if (this._policy == null) {
+            this._policy = new lib_1.DocumentBase.ConnectionPolicy();
+            if (process.env.NODE_ENV == 'development')
+                this._policy.DisableSSLVerification = true;
+        }
+        return this._policy;
+    }
+    get washDocuments() {
+        return this.washDocuments;
+    }
+    set washDocuments(value) {
+        this._washDocuments = !!value;
+    }
+    /**
+     * Fetches entities from an asynchronious iterator
+     * @param iterator an async iterable iterator
+     * @param quantity number of items to fetch, any number below zero will fetch all
+     */
+    static async fromAsyncIterable(iterator, quantity = 100) {
+        let entities = new Array(), idx = 0;
+        do {
+            let result = await iterator.next();
+            if (result.done || (quantity >= 0 && quantity <= idx++))
+                break;
+            entities.push(result.value);
+        } while (true);
+        return entities;
+    }
+    readDocument(idordoc, options = undefined) {
+        return new Promise((resolve, reject) => {
+            try {
+                this.validateOptions(options);
+                this.client.readDocument(`${this.createDocumentLink(idordoc)}`, options, (error, resource, headers) => {
+                    if (error) {
+                        switch (error.code) {
+                            case 404:
+                                return resolve({ resource: null, etag: null, headers });
+                            default:
+                                return reject(this.transformError(error));
+                        }
+                    }
+                    try {
+                        resolve({ resource: this.makeEntity(resource), etag: resource._etag, headers });
+                    }
+                    catch (ex) {
+                        reject(ex);
+                    }
+                });
+            }
+            catch (ex) {
+                reject(ex);
+            }
+        });
+    }
+    /**
+     * Query for the documents with paging using ContinuationToken
+     * @param query
+     * @param options
+     */
+    queryDocuments(query, options) {
+        return new Promise(async (resolve, reject) => {
+            try {
+                this.validateOptions(options);
+                let iterator = this.client.queryDocuments(this.createCollectionLink(), query, options);
+                let { resources, headers } = await this.executeNext(iterator);
+                resolve({
+                    resources,
+                    continuationToken: resources !== undefined ? headers['x-ms-continuation'] : null,
+                    headers
+                });
+            }
+            catch (ex) {
+                reject(ex);
+            }
+        });
+    }
+    /**
+     * Iterate through documents asynchronious with `for await()`
+     * @param query
+     * @param options
+     */
+    iterateDocuments(query, options) {
+        return tslib_1.__asyncGenerator(this, arguments, function* iterateDocuments_1() {
+            this.validateOptions(options);
+            let iterator = this.client.queryDocuments(this.createCollectionLink(), query, options);
+            do {
+                let { resources, headers } = yield tslib_1.__await(this.executeNext(iterator));
+                if (resources === undefined)
+                    break;
+                yield tslib_1.__await(yield* tslib_1.__asyncDelegator(tslib_1.__asyncValues(resources)));
+            } while (true);
+        });
+    }
+    /**
+     * Creates a new document that doesn't exists.
+     * @param document
+     * @param options
+     */
+    createDocument(document, options = undefined) {
+        return new Promise((resolve, reject) => {
+            try {
+                let opts = Object.assign({}, options);
+                this.validateOptions(options);
+                this.client.createDocument(this.createCollectionLink(), document, options, (error, resource, headers) => {
+                    if (error)
+                        return reject(this.transformError(error));
+                    try {
+                        resolve({ resource: this.makeEntity(resource), headers });
+                    }
+                    catch (ex) {
+                        reject(ex);
+                    }
+                });
+            }
+            catch (ex) {
+                reject(ex);
+            }
+        });
+    }
+    /**
+     * Updates a document that exists by patching the changes, will retry 3 times before giving up.
+     * @param document
+     * @param options
+     */
+    updateDocument(document, options = undefined) {
+        return new Promise(async (resolve, reject) => {
+            try {
+                if (document.id == null)
+                    throw new Error(`Document is missing property id`);
+                this.validateOptions(options);
+                for (let retry = 0; retry < 4; retry++) {
+                    let { resource, etag } = await this.readDocument(document.id, options);
+                    if (resource == null)
+                        throw new Error(`Document "${this.createDocumentLink(document)}" does not exist.`);
+                    let newDocument = this.apply(resource, document);
+                    try {
+                        let { resource: newResource, headers } = await this.replaceDocument(newDocument, Object.assign(options || {}, {
+                            accessCondition: { type: 'IfMatch', condition: etag }
+                        }));
+                        resolve({ resource: newResource, headers });
+                    }
+                    catch (ex) {
+                        if (ex.statusCode != 412 || retry == 4)
+                            throw ex;
+                        // try again but wait a bit
+                        await this.delay(100 + (200 * (retry - 1)));
+                    }
+                }
+            }
+            catch (ex) {
+                reject(ex);
+            }
+        });
+    }
+    /**
+     * Replaces a document that exists.
+     * @param document
+     * @param options
+     */
+    replaceDocument(document, options = undefined) {
+        return new Promise((resolve, reject) => {
+            try {
+                this.validateOptions(options);
+                this.client.replaceDocument(this.createDocumentLink(document), document, options, (error, resource, headers) => {
+                    if (error)
+                        return reject(this.transformError(error));
+                    try {
+                        resolve({
+                            resource: this.makeEntity(resource),
+                            headers
+                        });
+                    }
+                    catch (ex) {
+                        reject(ex);
+                    }
+                });
+            }
+            catch (ex) {
+                reject(ex);
+            }
+        });
+    }
+    /**
+     * Creates a new document or replacing it if it exists
+     * @param document
+     * @param options
+     */
+    upsertDocument(document, options = undefined) {
+        return new Promise((resolve, reject) => {
+            try {
+                this.validateOptions(options);
+                this.client.upsertDocument(this.createCollectionLink(), document, options, (error, resource, headers) => {
+                    if (error)
+                        return reject(this.transformError(error));
+                    try {
+                        resolve({
+                            resource: this.makeEntity(resource),
+                            headers
+                        });
+                    }
+                    catch (ex) {
+                        reject(ex);
+                    }
+                });
+            }
+            catch (err) {
+                reject(err);
+            }
+        });
+    }
+    deleteDocument(idordoc, options = undefined) {
+        return new Promise((resolve, reject) => {
+            try {
+                this.client.deleteDocument(this.createDocumentLink(idordoc), options, (error, resource, headers) => {
+                    if (error)
+                        return reject(this.transformError(error));
+                    resolve({
+                        resource: null,
+                        headers
+                    });
+                });
+            }
+            catch (ex) {
+                reject(ex);
+            }
+        });
+    }
+    /**
+     * Get the current throughput (RU/s)
+     */
+    async getThroughput() {
+        return new Promise(async (resolve, reject) => {
+            try {
+                let offer = await this.getOffer();
+                if (!offer.content)
+                    throw new Error(`Offer for collection "${this.createCollectionLink()}" is missing content`);
+                resolve(offer.content.offerThroughput);
+            }
+            catch (ex) {
+                reject(ex);
+            }
+        });
+    }
+    /**
+     * Set the throughput (RU/s) to any number between 400 and 10000
+     * @param value RU/s
+     */
+    async setThroughput(value) {
+        return new Promise(async (resolve, reject) => {
+            try {
+                if (value < 400)
+                    value = 400;
+                if (value > 10000)
+                    value = 10000;
+                if (await this.reserveOffer() == true) {
+                    let offer = await this.getOffer();
+                    if (!offer.content)
+                        throw new Error(`Offer for collection "${this.createCollectionLink()}" is missing content`);
+                    offer.content.offerThroughput = value;
+                    this.client.replaceOffer(offer._self, offer, (error, resource) => {
+                        if (error)
+                            return reject(this.transformError(error));
+                        resolve(true);
+                        this.offerReserved = false;
+                    });
+                }
+                else {
+                    resolve(false);
+                    this.offerReserved = false;
+                }
+            }
+            catch (ex) {
+                reject(ex);
+                this.offerReserved = false;
+            }
+        });
+    }
+    /**
+     * Increase the throughput (RU/s), defaults to 200. Will never exceed 10000
+     * @param value RU/s
+     */
+    async increaseThroughput(value = 200) {
+        return new Promise(async (resolve, reject) => {
+            try {
+                if (value < 0)
+                    value = 200;
+                if (await this.reserveOffer() == true) {
+                    let offer = await this.getOffer();
+                    if (!offer.content)
+                        throw new Error(`Offer for collection "${this.createCollectionLink()}" is missing content`);
+                    offer.content.offerThroughput = Math.min((offer.content.offerThroughput + value), 10000);
+                    this.client.replaceOffer(offer._self, offer, (error, resource) => {
+                        if (error)
+                            return reject(this.transformError(error));
+                        resolve(offer.content.offerThroughput);
+                        this.offerReserved = false;
+                    });
+                }
+                else {
+                    resolve(undefined);
+                    this.offerReserved = false;
+                }
+            }
+            catch (ex) {
+                reject(ex);
+                this.offerReserved = false;
+            }
+        });
+    }
+    /**
+     * Decrease the throughput (RU/s), defaults to 200. Will never go below 400
+     * @param value RU/s
+     */
+    async decreaseThroughput(value = 200) {
+        return new Promise(async (resolve, reject) => {
+            try {
+                if (value < 0)
+                    value = 200;
+                if (await this.reserveOffer() == true) {
+                    let offer = await this.getOffer();
+                    if (!offer.content)
+                        throw new Error(`Offer for collection "${this.createCollectionLink()}" is missing content`);
+                    offer.content.offerThroughput = Math.max(offer.content.offerThroughput - value, 400);
+                    this.client.replaceOffer(offer._self, offer, (error, resource) => {
+                        if (error)
+                            return reject(this.transformError(error));
+                        resolve(offer.content.offerThroughput);
+                        this.offerReserved = false;
+                    });
+                }
+                else {
+                    resolve(undefined);
+                    this.offerReserved = false;
+                }
+            }
+            catch (ex) {
+                reject(ex);
+                this.offerReserved = false;
+            }
+        });
+    }
+    reserveOffer(timeout = 15000) {
+        return new Promise((resolve, reject) => {
+            let time = timeout, interval = 50, thread = setInterval(() => {
+                if (this.offerReserved == false) {
+                    clearTimeout(thread);
+                    resolve(true);
+                }
+                else if ((time -= interval) < 0) {
+                    clearTimeout(thread);
+                    resolve(false);
+                }
+            }, interval);
+        });
+    }
+    getOffer() {
+        let getCollectionSelfLink = async () => {
+            return new Promise((resolve, reject) => {
+                try {
+                    this.client.readCollection(this.createCollectionLink(), async (err, resource) => {
+                        resolve(resource._self);
+                    });
+                }
+                catch (ex) {
+                    reject(ex);
+                }
+            });
+        };
+        return new Promise(async (resolve, reject) => {
+            try {
+                if (!this.offerSelfLink) {
+                    let iterator = this.client.queryOffers({
+                        query: 'SELECT * FROM r WHERE r.resource = @selfLink',
+                        parameters: [
+                            { name: '@selfLink', value: await getCollectionSelfLink() }
+                        ]
+                    });
+                    iterator.executeNext((error, resources, headers) => {
+                        if (error)
+                            return reject(this.transformError(error));
+                        if (resources.length != 1)
+                            return reject(new Error(`Offer for collection "${this.createCollectionLink()}" is not found`));
+                        this.offerSelfLink = resources[0]._self;
+                        resolve(resources[0]);
+                    });
+                }
+                else {
+                    this.client.readOffer(this.offerSelfLink, (error, resource) => {
+                        if (error)
+                            return reject(this.transformError(error));
+                        resolve(resource);
+                    });
+                }
+            }
+            catch (ex) {
+                reject(ex);
+            }
+        });
+    }
+    get client() {
+        if (this._client == null)
+            this._client = new documentdb_1.DocumentClient(this.host, {
+                masterKey: this.key
+            }, this.policy);
+        return this._client;
+    }
+    createDatabaseLink() {
+        return documentdb_1.UriFactory.createDatabaseUri(this.databaseId);
+    }
+    createCollectionLink() {
+        return documentdb_1.UriFactory.createDocumentCollectionUri(this.databaseId, this.collectionId);
+    }
+    createDocumentLink(document) {
+        return documentdb_1.UriFactory.createDocumentUri(this.databaseId, this.collectionId, typeof document == 'object' ? document.id : document);
+    }
+    executeNext(iterator) {
+        return new Promise((resolve, reject) => {
+            try {
+                iterator.executeNext((error, resources, headers) => {
+                    if (error)
+                        return reject(this.transformError(error));
+                    if (error === undefined && resources === undefined)
+                        return resolve({ resources: undefined, headers: undefined });
+                    resolve({
+                        resources: resources.map(r => this.makeEntity(r)),
+                        headers
+                    });
+                });
+            }
+            catch (ex) {
+                reject(ex);
+            }
+        });
+    }
+    makeEntity(doc) {
+        return this.makeDocument(doc);
+    }
+    makeDocument(resource) {
+        if (typeof resource != 'object' || resource == null)
+            return null;
+        if (this._washDocuments == false)
+            return resource;
+        let document = { id: resource.id };
+        for (let propertyName of Object.getOwnPropertyNames(resource)) {
+            switch (propertyName) {
+                case '_rid':
+                case '_self':
+                case '_etag':
+                case '_attachments':
+                case '_ts':
+                    break;
+                default:
+                    document[propertyName] = resource[propertyName];
+                    break;
+            }
+        }
+        return document;
+    }
+    delay(ms = 1000) {
+        return new Promise((resolve, reject) => {
+            setTimeout(resolve, Number(ms) || 1000);
+        });
+    }
+    transformError(err) {
+        try {
+            if (err.message == null) {
+                let json = typeof err.body == 'string' ? JSON.parse(err.body) : err;
+                if (json && json.message)
+                    [err.message] = json.message.split(/\r\n/);
+            }
+        }
+        catch (ex) {
+        }
+        return err;
+    }
+    validateOptions(options) {
+        for (let [key, value] of Object.entries(this.getHeaders(options))) {
+            if (value === undefined)
+                throw new TypeError(`Invalid value "${value}" for header "${key}"`);
+        }
+    }
+    getHeaders(options) {
+        var headers = {};
+        options = options || {};
+        if (options.continuation) {
+            headers[Constants.HttpHeaders.Continuation] = options.continuation;
+        }
+        if (options.preTriggerInclude) {
+            headers[Constants.HttpHeaders.PreTriggerInclude] = options.preTriggerInclude.constructor === Array ? options.preTriggerInclude.join(",") : options.preTriggerInclude;
+        }
+        if (options.postTriggerInclude) {
+            headers[Constants.HttpHeaders.PostTriggerInclude] = options.postTriggerInclude.constructor === Array ? options.postTriggerInclude.join(",") : options.postTriggerInclude;
+        }
+        if (options.offerType) {
+            headers[Constants.HttpHeaders.OfferType] = options.offerType;
+        }
+        if (options.offerThroughput) {
+            headers[Constants.HttpHeaders.OfferThroughput] = options.offerThroughput;
+        }
+        if (options.maxItemCount) {
+            headers[Constants.HttpHeaders.PageSize] = options.maxItemCount;
+        }
+        if (options.accessCondition) {
+            if (options.accessCondition.type === "IfMatch") {
+                headers[Constants.HttpHeaders.IfMatch] = options.accessCondition.condition;
+            }
+            else {
+                headers[Constants.HttpHeaders.IfNoneMatch] = options.accessCondition.condition;
+            }
+        }
+        if (options.indexingDirective) {
+            headers[Constants.HttpHeaders.IndexingDirective] = options.indexingDirective;
+        }
+        // TODO: add consistency level validation.
+        if (options.consistencyLevel) {
+            headers[Constants.HttpHeaders.ConsistencyLevel] = options.consistencyLevel;
+        }
+        if (options.resourceTokenExpirySeconds) {
+            headers[Constants.HttpHeaders.ResourceTokenExpiry] = options.resourceTokenExpirySeconds;
+        }
+        // TODO: add session token automatic handling in case of session consistency.
+        if (options.sessionToken) {
+            headers[Constants.HttpHeaders.SessionToken] = options.sessionToken;
+        }
+        if (options.enableScanInQuery) {
+            headers[Constants.HttpHeaders.EnableScanInQuery] = options.enableScanInQuery;
+        }
+        if (options.enableCrossPartitionQuery) {
+            headers[Constants.HttpHeaders.EnableCrossPartitionQuery] = options.enableCrossPartitionQuery;
+        }
+        if (options.maxDegreeOfParallelism != undefined) {
+            headers[Constants.HttpHeaders.ParallelizeCrossPartitionQuery] = true;
+        }
+        if (options.populateQuotaInfo) {
+            headers[Constants.HttpHeaders.PopulateQuotaInfo] = true;
+        }
+        if (options.enableScriptLogging) {
+            headers[Constants.HttpHeaders.EnableScriptLogging] = options.enableScriptLogging;
+        }
+        if (options.offerEnableRUPerMinuteThroughput) {
+            headers[Constants.HttpHeaders.OfferIsRUPerMinuteThroughputEnabled] = true;
+        }
+        if (options.disableRUPerMinuteUsage) {
+            headers[Constants.HttpHeaders.DisableRUPerMinuteUsage] = true;
+        }
+        return headers;
+    }
+    apply(target, source) {
+        let targetProto = this.isClass(target) == true ? Object.getPrototypeOf(target) : target, sourceProto = this.isClass(source) == true ? Object.getPrototypeOf(source) : source, destination = Object.assign({}, target);
+        for (let property of Object.getOwnPropertyNames(sourceProto)) {
+            if (source[property] === undefined)
+                continue;
+            if (targetProto.hasOwnProperty(property)) {
+                if (target[property] !== undefined && target[property] !== null) {
+                    switch (target[property].constructor) {
+                        case Function:
+                            break;
+                        case Array:
+                        case Date:
+                        case Boolean:
+                        case Number:
+                        case String:
+                            destination[property] = source[property];
+                            break;
+                        case Object:
+                        default:
+                            destination[property] = this.apply(destination[property], source[property]);
+                            break;
+                    }
+                    continue;
+                }
+            }
+            destination[property] = source[property];
+        }
+        return destination;
+    }
+    isClass(obj) {
+        const isCtorClass = obj.constructor && obj.constructor.toString().substring(0, 5) === 'class';
+        if (obj.prototype === undefined)
+            return isCtorClass;
+        const isPrototypeCtorClass = obj.prototype.constructor
+            && obj.prototype.constructor.toString
+            && obj.prototype.constructor.toString().substring(0, 5) === 'class';
+        return isCtorClass || isPrototypeCtorClass;
+    }
+}
+exports.default = DocumentDBClient;
+//# sourceMappingURL=index.js.map
\ No newline at end of file
diff --git a/lib/index.js.map b/lib/index.js.map
new file mode 100644
index 0000000..8bfab53
--- /dev/null
+++ b/lib/index.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;AAAA,IAAG,CAAC,MAAM,CAAC,aAAa;IACnB,MAAc,CAAC,aAAa,GAAG,MAAM,CAAC,aAAa,IAAI,qBAAqB,CAAC;AAElF,2CAAoL;AACpL,wCAA6C;AAC7C,sDAAqD;AAGrD;IASI,YAAoB,IAAY,EAAU,GAAW,EAAU,UAAkB,EAAU,YAAoB;QAA3F,SAAI,GAAJ,IAAI,CAAQ;QAAU,QAAG,GAAH,GAAG,CAAQ;QAAU,eAAU,GAAV,UAAU,CAAQ;QAAU,iBAAY,GAAZ,YAAY,CAAQ;QAJvG,kBAAa,GAAY,KAAK,CAAA;QAE9B,mBAAc,GAAY,IAAI,CAAA;IAItC,CAAC;IAED,IAAW,MAAM;QACb,IAAG,IAAI,CAAC,OAAO,IAAI,IAAI,EAAE;YACrB,IAAI,CAAC,OAAO,GAAG,IAAI,kBAAY,CAAC,gBAAgB,EAAE,CAAA;YAElD,IAAG,OAAO,CAAC,GAAG,CAAC,QAAQ,IAAI,aAAa;gBACpC,IAAI,CAAC,OAAO,CAAC,sBAAsB,GAAG,IAAI,CAAA;SACjD;QAED,OAAO,IAAI,CAAC,OAAO,CAAA;IACvB,CAAC;IAED,IAAW,aAAa;QACpB,OAAO,IAAI,CAAC,aAAa,CAAA;IAC7B,CAAC;IAED,IAAW,aAAa,CAAC,KAAc;QACnC,IAAI,CAAC,cAAc,GAAG,CAAC,CAAC,KAAK,CAAA;IACjC,CAAC;IAED;;;;OAIG;IACI,MAAM,CAAC,KAAK,CAAC,iBAAiB,CAAU,QAAwC,EAAE,WAAmB,GAAG;QAC3G,IAAI,QAAQ,GAAG,IAAI,KAAK,EAAW,EAC/B,GAAG,GAAG,CAAC,CAAA;QAEX,GAAG;YACC,IAAI,MAAM,GAAG,MAAM,QAAQ,CAAC,IAAI,EAAE,CAAA;YAElC,IAAG,MAAM,CAAC,IAAI,IAAI,CAAC,QAAQ,IAAI,CAAC,IAAI,QAAQ,IAAI,GAAG,EAAE,CAAC;gBAClD,MAAM;YAEV,QAAQ,CAAC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,CAAA;SAC9B,QACK,IAAI,EAAC;QAEX,OAAO,QAAQ,CAAC;IACpB,CAAC;IAcM,YAAY,CAAC,OAAY,EAAE,UAA0B,SAAS;QACjE,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI;gBACA,IAAI,CAAC,eAAe,CAAC,OAAO,CAAC,CAAA;gBAE7B,IAAI,CAAC,MAAM,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,kBAAkB,CAAC,OAAO,CAAC,EAAE,EAAE,OAAO,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,OAAO,EAAE,EAAE;oBAClG,IAAG,KAAK,EAAE;wBACN,QAAO,KAAK,CAAC,IAAI,EAAE;4BACf,KAAK,GAAG;gCACJ,OAAO,OAAO,CAAC,EAAE,QAAQ,EAAE,IAAI,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,CAAC,CAAA;4BAE3D;gCACI,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;yBAChD;qBACJ;oBAED,IAAI;wBACA,OAAO,CAAC,EAAC,QAAQ,EAAE,IAAI,CAAC,UAAU,CAAC,QAAQ,CAAC,EAAE,IAAI,EAAE,QAAQ,CAAC,KAAK,EAAE,OAAO,EAAC,CAAC,CAAA;qBAChF;oBACD,OAAM,EAAE,EAAE;wBACN,MAAM,CAAC,EAAE,CAAC,CAAA;qBACb;gBACL,CAAC,CAAC,CAAA;aACL;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;aACb;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED;;;;OAIG;IACI,cAAc,CAAC,KAA4B,EAAE,OAAqB;QACrE,OAAO,IAAI,OAAO,CAAC,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;YACzC,IAAI;gBACA,IAAI,CAAC,eAAe,CAAC,OAAO,CAAC,CAAA;gBAE7B,IAAI,QAAQ,GAAG,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,EAAE,KAAK,EAAE,OAAO,CAAC,CAAA;gBAEtF,IAAI,EAAE,SAAS,EAAE,OAAO,EAAE,GAAG,MAAM,IAAI,CAAC,WAAW,CAAC,QAAQ,CAAC,CAAA;gBAE7D,OAAO,CAAC;oBACJ,SAAS;oBACT,iBAAiB,EAAE,SAAS,KAAK,SAAS,CAAC,CAAC,CAAC,OAAO,CAAC,mBAAmB,CAAC,CAAC,CAAC,CAAC,IAAI;oBAChF,OAAO;iBACV,CAAC,CAAA;aACL;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;aACb;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED;;;;OAIG;IACY,gBAAgB,CAAC,KAA4B,EAAE,OAAqB;;YAC/E,IAAI,CAAC,eAAe,CAAC,OAAO,CAAC,CAAA;YAE7B,IAAI,QAAQ,GAAG,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,EAAE,KAAK,EAAE,OAAO,CAAC,CAAA;YAEtF,GACA;gBACI,IAAI,EAAE,SAAS,EAAE,OAAO,EAAE,GAAG,sBAAM,IAAI,CAAC,WAAW,CAAC,QAAQ,CAAC,CAAA,CAAA;gBAE7D,IAAG,SAAS,KAAK,SAAS;oBACtB,MAAM;gBAEV,sBAAA,KAAM,CAAC,CAAA,yBAAA,sBAAA,SAAS,CAAA,CAAA,CAAA,CAAA;aAEnB,QAAO,IAAI,EAAC;QACjB,CAAC;KAAA;IAED;;;;OAIG;IACI,cAAc,CAAC,QAAiB,EAAE,UAA2B,SAAS;QACzE,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI;gBACA,IAAI,IAAI,GAAoB,MAAM,CAAC,MAAM,CAAC,EACzC,EAAE,OAAO,CAAC,CAAA;gBAEX,IAAI,CAAC,eAAe,CAAC,OAAO,CAAC,CAAA;gBAE7B,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,EAAE,QAAQ,EAAE,OAAO,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,OAAO,EAAE,EAAE;oBACpG,IAAG,KAAK;wBACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;oBAE7C,IAAI;wBACA,OAAO,CAAC,EAAE,QAAQ,EAAE,IAAI,CAAC,UAAU,CAAC,QAAQ,CAAC,EAAE,OAAO,EAAE,CAAC,CAAA;qBAC5D;oBACD,OAAM,EAAE,EAAE;wBACN,MAAM,CAAC,EAAE,CAAC,CAAA;qBACb;gBACL,CAAC,CAAC,CAAA;aACL;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAC;aACd;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED;;;;OAIG;IACI,cAAc,CAAC,QAA0B,EAAE,UAA0B,SAAS;QACjF,OAAO,IAAI,OAAO,CAAC,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;YACzC,IAAI;gBACA,IAAG,QAAQ,CAAC,EAAE,IAAI,IAAI;oBAClB,MAAM,IAAI,KAAK,CAAC,iCAAiC,CAAC,CAAA;gBAEtD,IAAI,CAAC,eAAe,CAAC,OAAO,CAAC,CAAA;gBAE7B,KAAI,IAAI,KAAK,GAAG,CAAC,EAAE,KAAK,GAAG,CAAC,EAAE,KAAK,EAAE,EAAE;oBACnC,IAAI,EAAE,QAAQ,EAAE,IAAI,EAAE,GAAG,MAAM,IAAI,CAAC,YAAY,CAAC,QAAQ,CAAC,EAAE,EAAE,OAAO,CAAC,CAAA;oBAEtE,IAAG,QAAQ,IAAI,IAAI;wBACf,MAAM,IAAI,KAAK,CAAC,aAAa,IAAI,CAAC,kBAAkB,CAAU,QAAQ,CAAC,mBAAmB,CAAC,CAAA;oBAE/F,IAAI,WAAW,GAAG,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC;oBAEjD,IAAI;wBACA,IAAI,EAAE,QAAQ,EAAE,WAAW,EAAE,OAAO,EAAE,GAAG,MAAM,IAAI,CAAC,eAAe,CAAC,WAAW,EAAE,MAAM,CAAC,MAAM,CAAC,OAAO,IAAI,EAAE,EAAE;4BAC1G,eAAe,EAAG,EAAE,IAAI,EAAE,SAAS,EAAE,SAAS,EAAE,IAAI,EAAE;yBACzD,CAAC,CAAC,CAAA;wBAEH,OAAO,CAAC,EAAE,QAAQ,EAAE,WAAW,EAAE,OAAO,EAAE,CAAC,CAAA;qBAC9C;oBACD,OAAM,EAAE,EAAE;wBACN,IAAG,EAAE,CAAC,UAAU,IAAI,GAAG,IAAI,KAAK,IAAI,CAAC;4BACjC,MAAM,EAAE,CAAC;wBAEb,2BAA2B;wBAC3B,MAAM,IAAI,CAAC,KAAK,CAAC,GAAG,GAAG,CAAC,GAAG,GAAG,CAAC,KAAK,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC;qBAC/C;iBACJ;aACJ;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;aACb;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED;;;;OAIG;IACI,eAAe,CAAC,QAAiB,EAAE,UAA0B,SAAS;QACzE,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI;gBACA,IAAI,CAAC,eAAe,CAAC,OAAO,CAAC,CAAA;gBAE7B,IAAI,CAAC,MAAM,CAAC,eAAe,CAAC,IAAI,CAAC,kBAAkB,CAAC,QAAQ,CAAC,EAAE,QAAQ,EAAE,OAAO,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,OAAO,EAAE,EAAE;oBAC3G,IAAG,KAAK;wBACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;oBAE7C,IAAI;wBACA,OAAO,CAAC;4BACJ,QAAQ,EAAE,IAAI,CAAC,UAAU,CAAC,QAAQ,CAAC;4BACnC,OAAO;yBACV,CAAC,CAAA;qBACL;oBACD,OAAM,EAAE,EAAE;wBACN,MAAM,CAAC,EAAE,CAAC,CAAA;qBACb;gBACL,CAAC,CAAC,CAAA;aACL;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;aACb;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED;;;;OAIG;IACI,cAAc,CAAC,QAAiB,EAAE,UAA2B,SAAS;QACzE,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI;gBACA,IAAI,CAAC,eAAe,CAAC,OAAO,CAAC,CAAA;gBAE7B,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,EAAE,QAAQ,EAAE,OAAO,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,OAAO,EAAE,EAAE;oBACpG,IAAG,KAAK;wBACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;oBAE7C,IAAI;wBACA,OAAO,CAAC;4BACJ,QAAQ,EAAE,IAAI,CAAC,UAAU,CAAC,QAAQ,CAAC;4BACnC,OAAO;yBACV,CAAC,CAAA;qBACL;oBACD,OAAM,EAAE,EAAE;wBACN,MAAM,CAAC,EAAE,CAAC,CAAA;qBACb;gBACL,CAAC,CAAC,CAAA;aACL;YACD,OAAM,GAAG,EAAE;gBACP,MAAM,CAAC,GAAG,CAAC,CAAA;aACd;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAYM,cAAc,CAAC,OAAY,EAAE,UAA0B,SAAS;QACnE,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI;gBACA,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,IAAI,CAAC,kBAAkB,CAAC,OAAO,CAAC,EAAE,OAAO,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,OAAO,EAAE,EAAE;oBAC/F,IAAG,KAAK;wBACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;oBAE7C,OAAO,CAAC;wBACJ,QAAQ,EAAE,IAAI;wBACd,OAAO;qBACV,CAAC,CAAA;gBACN,CAAC,CAAC,CAAA;aACL;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;aACb;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED;;OAEG;IACI,KAAK,CAAC,aAAa;QACtB,OAAO,IAAI,OAAO,CAAS,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;YACjD,IAAI;gBACA,IAAI,KAAK,GAAG,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAA;gBAEjC,IAAG,CAAC,KAAK,CAAC,OAAO;oBACb,MAAM,IAAI,KAAK,CAAC,yBAAyB,IAAI,CAAC,oBAAoB,EAAE,sBAAsB,CAAC,CAAC;gBAEhG,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC,eAAe,CAAC,CAAA;aACzC;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;aACb;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED;;;OAGG;IACI,KAAK,CAAC,aAAa,CAAC,KAAa;QACpC,OAAO,IAAI,OAAO,CAAU,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;YAClD,IAAI;gBACA,IAAG,KAAK,GAAG,GAAG;oBAAE,KAAK,GAAG,GAAG,CAAA;gBAC3B,IAAG,KAAK,GAAG,KAAK;oBAAE,KAAK,GAAG,KAAK,CAAA;gBAE/B,IAAG,MAAM,IAAI,CAAC,YAAY,EAAE,IAAI,IAAI,EAAE;oBAClC,IAAI,KAAK,GAAG,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAA;oBAEjC,IAAG,CAAC,KAAK,CAAC,OAAO;wBACb,MAAM,IAAI,KAAK,CAAC,yBAAyB,IAAI,CAAC,oBAAoB,EAAE,sBAAsB,CAAC,CAAC;oBAEhG,KAAK,CAAC,OAAO,CAAC,eAAe,GAAG,KAAK,CAAC;oBAEtC,IAAI,CAAC,MAAM,CAAC,YAAY,CAAC,KAAK,CAAC,KAAK,EAAE,KAAK,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,EAAE;wBAC7D,IAAG,KAAK;4BACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;wBAE7C,OAAO,CAAC,IAAI,CAAC,CAAA;wBAEb,IAAI,CAAC,aAAa,GAAG,KAAK,CAAA;oBAC9B,CAAC,CAAC,CAAA;iBACL;qBACI;oBACD,OAAO,CAAC,KAAK,CAAC,CAAA;oBAEd,IAAI,CAAC,aAAa,GAAG,KAAK,CAAA;iBAC7B;aACJ;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;gBAEV,IAAI,CAAC,aAAa,GAAG,KAAK,CAAA;aAC7B;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED;;;OAGG;IACI,KAAK,CAAC,kBAAkB,CAAC,QAAgB,GAAG;QAC/C,OAAO,IAAI,OAAO,CAAS,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;YACjD,IAAI;gBACA,IAAG,KAAK,GAAG,CAAC;oBAAE,KAAK,GAAG,GAAG,CAAA;gBAEzB,IAAG,MAAM,IAAI,CAAC,YAAY,EAAE,IAAI,IAAI,EAAE;oBAClC,IAAI,KAAK,GAAG,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAA;oBAEjC,IAAG,CAAC,KAAK,CAAC,OAAO;wBACb,MAAM,IAAI,KAAK,CAAC,yBAAyB,IAAI,CAAC,oBAAoB,EAAE,sBAAsB,CAAC,CAAC;oBAEhG,KAAK,CAAC,OAAO,CAAC,eAAe,GAAG,IAAI,CAAC,GAAG,CAAE,CAAC,KAAK,CAAC,OAAO,CAAC,eAAe,GAAG,KAAK,CAAC,EAAE,KAAK,CAAC,CAAA;oBAEzF,IAAI,CAAC,MAAM,CAAC,YAAY,CAAC,KAAK,CAAC,KAAK,EAAE,KAAK,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,EAAE;wBAC7D,IAAG,KAAK;4BACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;wBAE7C,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC,eAAe,CAAC,CAAA;wBAEtC,IAAI,CAAC,aAAa,GAAG,KAAK,CAAA;oBAC9B,CAAC,CAAC,CAAA;iBACL;qBACI;oBACD,OAAO,CAAC,SAAS,CAAC,CAAA;oBAElB,IAAI,CAAC,aAAa,GAAG,KAAK,CAAA;iBAC7B;aACJ;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;gBAEV,IAAI,CAAC,aAAa,GAAG,KAAK,CAAA;aAC7B;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED;;;OAGG;IACI,KAAK,CAAC,kBAAkB,CAAC,QAAgB,GAAG;QAC/C,OAAO,IAAI,OAAO,CAAS,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;YACjD,IAAI;gBACA,IAAG,KAAK,GAAG,CAAC;oBAAE,KAAK,GAAG,GAAG,CAAA;gBAEzB,IAAG,MAAM,IAAI,CAAC,YAAY,EAAE,IAAI,IAAI,EAAE;oBAClC,IAAI,KAAK,GAAG,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAA;oBAEjC,IAAG,CAAC,KAAK,CAAC,OAAO;wBACb,MAAM,IAAI,KAAK,CAAC,yBAAyB,IAAI,CAAC,oBAAoB,EAAE,sBAAsB,CAAC,CAAC;oBAEhG,KAAK,CAAC,OAAO,CAAC,eAAe,GAAG,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,OAAO,CAAC,eAAe,GAAG,KAAK,EAAE,GAAG,CAAC,CAAC;oBAErF,IAAI,CAAC,MAAM,CAAC,YAAY,CAAC,KAAK,CAAC,KAAK,EAAE,KAAK,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,EAAE;wBAC7D,IAAG,KAAK;4BACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;wBAE7C,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC,eAAe,CAAC,CAAA;wBAEtC,IAAI,CAAC,aAAa,GAAG,KAAK,CAAA;oBAC9B,CAAC,CAAC,CAAA;iBACL;qBACI;oBACD,OAAO,CAAC,SAAS,CAAC,CAAA;oBAElB,IAAI,CAAC,aAAa,GAAG,KAAK,CAAA;iBAC7B;aACJ;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;gBAEV,IAAI,CAAC,aAAa,GAAG,KAAK,CAAA;aAC7B;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,YAAY,CAAC,UAAkB,KAAK;QACxC,OAAO,IAAI,OAAO,CAAU,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YAC5C,IAAI,IAAI,GAAG,OAAO,EACd,QAAQ,GAAG,EAAE,EAEb,MAAM,GAAG,WAAW,CAAC,GAAG,EAAE;gBACtB,IAAG,IAAI,CAAC,aAAa,IAAI,KAAK,EAAE;oBAC5B,YAAY,CAAC,MAAM,CAAC,CAAA;oBACpB,OAAO,CAAC,IAAI,CAAC,CAAA;iBAChB;qBACI,IAAI,CAAC,IAAI,IAAI,QAAQ,CAAC,GAAG,CAAC,EAAE;oBAC7B,YAAY,CAAC,MAAM,CAAC,CAAC;oBACrB,OAAO,CAAC,KAAK,CAAC,CAAC;iBAClB;YAEL,CAAC,EAAE,QAAQ,CAAC,CAAC;QACrB,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,QAAQ;QACZ,IAAI,qBAAqB,GAAG,KAAK,IAAI,EAAE;YACnC,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;gBACnC,IAAI;oBACA,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,EAAE,KAAK,EAAE,GAAG,EAAE,QAAQ,EAAE,EAAE;wBAC5E,OAAO,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAA;oBAC3B,CAAC,CAAC,CAAC;iBACN;gBACD,OAAM,EAAE,EAAE;oBACN,MAAM,CAAC,EAAE,CAAC,CAAA;iBACb;YACL,CAAC,CAAC,CAAA;QACN,CAAC,CAAA;QAED,OAAO,IAAI,OAAO,CAAC,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;YACzC,IAAI;gBACA,IAAG,CAAC,IAAI,CAAC,aAAa,EAAE;oBACpB,IAAI,QAAQ,GAAG,IAAI,CAAC,MAAM,CAAC,WAAW,CAAC;wBACnC,KAAK,EAAE,8CAA8C;wBACrD,UAAU,EAAE;4BACR,EAAE,IAAI,EAAE,WAAW,EAAE,KAAK,EAAE,MAAM,qBAAqB,EAAE,EAAE;yBAC9D;qBACJ,CAAC,CAAC;oBAEH,QAAQ,CAAC,WAAW,CAAC,CAAC,KAAK,EAAE,SAAS,EAAE,OAAO,EAAE,EAAE;wBAC/C,IAAG,KAAK;4BACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;wBAE7C,IAAG,SAAS,CAAC,MAAM,IAAI,CAAC;4BACpB,OAAO,MAAM,CAAC,IAAI,KAAK,CAAC,yBAAyB,IAAI,CAAC,oBAAoB,EAAE,gBAAgB,CAAC,CAAC,CAAA;wBAElG,IAAI,CAAC,aAAa,GAAG,SAAS,CAAC,CAAC,CAAC,CAAC,KAAK,CAAA;wBAEvC,OAAO,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC,CAAA;oBACzB,CAAC,CAAC,CAAA;iBACL;qBACI;oBACD,IAAI,CAAC,MAAM,CAAC,SAAS,CAAC,IAAI,CAAC,aAAa,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,EAAE;wBAC1D,IAAG,KAAK;4BACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;wBAE7C,OAAO,CAAC,QAAQ,CAAC,CAAA;oBACrB,CAAC,CAAC,CAAA;iBACL;aACJ;YAAC,OAAM,EAAE,EAAE;gBACR,MAAM,CAAC,EAAE,CAAC,CAAA;aACb;QACL,CAAC,CAAC,CAAA;IAEN,CAAC;IAED,IAAc,MAAM;QAChB,IAAG,IAAI,CAAC,OAAO,IAAI,IAAI;YACnB,IAAI,CAAC,OAAO,GAAG,IAAI,2BAAc,CAAC,IAAI,CAAC,IAAI,EAAE;gBACzC,SAAS,EAAE,IAAI,CAAC,GAAG;aACtB,EAAE,IAAI,CAAC,MAAM,CAAC,CAAA;QAEnB,OAAO,IAAI,CAAC,OAAO,CAAA;IACvB,CAAC;IAES,kBAAkB;QACxB,OAAO,uBAAU,CAAC,iBAAiB,CAAC,IAAI,CAAC,UAAU,CAAC,CAAA;IACxD,CAAC;IAES,oBAAoB;QAC1B,OAAO,uBAAU,CAAC,2BAA2B,CAAC,IAAI,CAAC,UAAU,EAAE,IAAI,CAAC,YAAY,CAAC,CAAA;IACrF,CAAC;IAIS,kBAAkB,CAAC,QAAa;QACtC,OAAO,uBAAU,CAAC,iBAAiB,CAAC,IAAI,CAAC,UAAU,EAAE,IAAI,CAAC,YAAY,EAAE,OAAO,QAAQ,IAAI,QAAQ,CAAC,CAAC,CAAC,QAAQ,CAAC,EAAE,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAA;IACjI,CAAC;IAEO,WAAW,CAAC,QAA0C;QAC1D,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI;gBACA,QAAQ,CAAC,WAAW,CAAC,CAAC,KAAK,EAAE,SAAS,EAAE,OAAO,EAAE,EAAE;oBAC/C,IAAG,KAAK;wBACJ,OAAO,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,CAAA;oBAE7C,IAAG,KAAK,KAAK,SAAS,IAAI,SAAS,KAAK,SAAS;wBAC7C,OAAO,OAAO,CAAC,EAAE,SAAS,EAAE,SAAS,EAAE,OAAO,EAAE,SAAS,EAAE,CAAC,CAAA;oBAEhE,OAAO,CAAC;wBACJ,SAAS,EAAE,SAAS,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC;wBACjD,OAAO;qBACV,CAAC,CAAA;gBACN,CAAC,CAAC,CAAA;aAEL;YACD,OAAM,EAAE,EAAE;gBACN,MAAM,CAAC,EAAE,CAAC,CAAA;aACb;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,UAAU,CAAwB,GAAM;QAC5C,OAAgB,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,CAAA;IAC1C,CAAC;IAKO,YAAY,CAAwB,QAAW;QACnD,IAAG,OAAO,QAAQ,IAAI,QAAQ,IAAI,QAAQ,IAAI,IAAI;YAC9C,OAAO,IAAI,CAAA;QAEf,IAAG,IAAI,CAAC,cAAc,IAAI,KAAK;YAC3B,OAAO,QAAQ,CAAC;QAEpB,IAAI,QAAQ,GAAgB,EAAE,EAAE,EAAE,QAAQ,CAAC,EAAE,EAAE,CAAA;QAE/C,KAAI,IAAI,YAAY,IAAI,MAAM,CAAC,mBAAmB,CAAC,QAAQ,CAAC,EAAE;YAC1D,QAAO,YAAY,EAAE;gBACjB,KAAK,MAAM,CAAC;gBACZ,KAAK,OAAO,CAAC;gBACb,KAAK,OAAO,CAAC;gBACb,KAAK,cAAc,CAAC;gBACpB,KAAK,KAAK;oBACN,MAAK;gBAET;oBACI,QAAQ,CAAC,YAAY,CAAC,GAAG,QAAQ,CAAC,YAAY,CAAC,CAAA;oBAC/C,MAAK;aACZ;SACJ;QAED,OAAO,QAAQ,CAAA;IACnB,CAAC;IAEO,KAAK,CAAC,KAAa,IAAI;QAC3B,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,UAAU,CAAC,OAAO,EAAE,MAAM,CAAC,EAAE,CAAC,IAAI,IAAI,CAAC,CAAA;QAC3C,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,cAAc,CAAC,GAAG;QACtB,IAAI;YACA,IAAG,GAAG,CAAC,OAAO,IAAI,IAAI,EAAE;gBACpB,IAAI,IAAI,GAAG,OAAO,GAAG,CAAC,IAAI,IAAI,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,GAAG,CAAA;gBAEnE,IAAG,IAAI,IAAI,IAAI,CAAC,OAAO;oBACnB,CAAE,GAAG,CAAC,OAAO,CAAE,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;aACnD;SACJ;QACD,OAAM,EAAE,EAAE;SACT;QAED,OAAO,GAAG,CAAA;IACd,CAAC;IAEO,eAAe,CAAC,OAAuD;QAC3E,KAAI,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,IAAI,MAAM,CAAC,OAAO,CAAC,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,EAChE;YACI,IAAG,KAAK,KAAK,SAAS;gBAClB,MAAM,IAAI,SAAS,CAAC,kBAAkB,KAAK,iBAAiB,GAAG,GAAG,CAAC,CAAA;SAC1E;IACL,CAAC;IAKO,UAAU,CAAC,OAAY;QAC3B,IAAI,OAAO,GAAG,EAAE,CAAA;QACZ,OAAO,GAAG,OAAO,IAAI,EAAE,CAAC;QAE5B,IAAI,OAAO,CAAC,YAAY,EAAE;YACtB,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,YAAY,CAAC,GAAG,OAAO,CAAC,YAAY,CAAC;SACtE;QAED,IAAI,OAAO,CAAC,iBAAiB,EAAE;YAC3B,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,iBAAiB,CAAC,GAAG,OAAO,CAAC,iBAAiB,CAAC,WAAW,KAAK,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,iBAAiB,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,iBAAiB,CAAC;SACxK;QAED,IAAI,OAAO,CAAC,kBAAkB,EAAE;YAC5B,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,kBAAkB,CAAC,GAAG,OAAO,CAAC,kBAAkB,CAAC,WAAW,KAAK,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,kBAAkB,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,kBAAkB,CAAC;SAC5K;QAED,IAAI,OAAO,CAAC,SAAS,EAAE;YACnB,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,SAAS,CAAC,GAAG,OAAO,CAAC,SAAS,CAAC;SAChE;QAED,IAAI,OAAO,CAAC,eAAe,EAAE;YACzB,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,eAAe,CAAC,GAAG,OAAO,CAAC,eAAe,CAAC;SAC5E;QAED,IAAI,OAAO,CAAC,YAAY,EAAE;YACtB,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,QAAQ,CAAC,GAAG,OAAO,CAAC,YAAY,CAAC;SAClE;QAED,IAAI,OAAO,CAAC,eAAe,EAAE;YACzB,IAAI,OAAO,CAAC,eAAe,CAAC,IAAI,KAAK,SAAS,EAAE;gBAC5C,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,OAAO,CAAC,GAAG,OAAO,CAAC,eAAe,CAAC,SAAS,CAAC;aAC9E;iBAAM;gBACH,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,WAAW,CAAC,GAAG,OAAO,CAAC,eAAe,CAAC,SAAS,CAAC;aAClF;SACJ;QAED,IAAI,OAAO,CAAC,iBAAiB,EAAE;YAC3B,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,iBAAiB,CAAC,GAAG,OAAO,CAAC,iBAAiB,CAAC;SAChF;QAED,0CAA0C;QAC1C,IAAI,OAAO,CAAC,gBAAgB,EAAE;YAC1B,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,gBAAgB,CAAC,GAAG,OAAO,CAAC,gBAAgB,CAAC;SAC9E;QAED,IAAI,OAAO,CAAC,0BAA0B,EAAE;YACpC,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,mBAAmB,CAAC,GAAG,OAAO,CAAC,0BAA0B,CAAC;SAC3F;QAED,6EAA6E;QAC7E,IAAI,OAAO,CAAC,YAAY,EAAE;YACtB,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,YAAY,CAAC,GAAG,OAAO,CAAC,YAAY,CAAC;SACtE;QAED,IAAI,OAAO,CAAC,iBAAiB,EAAE;YAC3B,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,iBAAiB,CAAC,GAAG,OAAO,CAAC,iBAAiB,CAAC;SAChF;QAED,IAAI,OAAO,CAAC,yBAAyB,EAAE;YACnC,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,yBAAyB,CAAC,GAAG,OAAO,CAAC,yBAAyB,CAAC;SAChG;QAED,IAAI,OAAO,CAAC,sBAAsB,IAAI,SAAS,EAAE;YAC7C,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,8BAA8B,CAAC,GAAG,IAAI,CAAC;SACxE;QAED,IAAI,OAAO,CAAC,iBAAiB,EAAE;YAC3B,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,iBAAiB,CAAC,GAAG,IAAI,CAAC;SAC3D;QAED,IAAI,OAAO,CAAC,mBAAmB,EAAE;YAC7B,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,mBAAmB,CAAC,GAAG,OAAO,CAAC,mBAAmB,CAAC;SACpF;QAED,IAAI,OAAO,CAAC,gCAAgC,EAAE;YAC1C,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,mCAAmC,CAAC,GAAG,IAAI,CAAC;SAC7E;QAED,IAAI,OAAO,CAAC,uBAAuB,EAAE;YACjC,OAAO,CAAC,SAAS,CAAC,WAAW,CAAC,uBAAuB,CAAC,GAAG,IAAI,CAAC;SACjE;QAED,OAAO,OAAO,CAAC;IACnB,CAAC;IAEO,KAAK,CAAU,MAAe,EAAE,MAAwB;QAC5D,IAAI,WAAW,GAAW,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,IAAI,CAAC,CAAC,CAAC,MAAM,CAAC,cAAc,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,MAAM,EAC3F,WAAW,GAAW,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,IAAI,CAAC,CAAC,CAAC,MAAM,CAAC,cAAc,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,MAAM,EAC3F,WAAW,GAAG,MAAM,CAAC,MAAM,CAAC,EAAE,EAAE,MAAM,CAAC,CAAA;QAE3C,KAAK,IAAI,QAAQ,IAAI,MAAM,CAAC,mBAAmB,CAAC,WAAW,CAAC,EAAE;YAC1D,IAAI,MAAM,CAAC,QAAQ,CAAC,KAAK,SAAS;gBAC9B,SAAQ;YAEZ,IAAI,WAAW,CAAC,cAAc,CAAC,QAAQ,CAAC,EAAE;gBACtC,IAAG,MAAM,CAAC,QAAQ,CAAC,KAAK,SAAS,IAAI,MAAM,CAAC,QAAQ,CAAC,KAAK,IAAI,EAAE;oBAC5D,QAAO,MAAM,CAAC,QAAQ,CAAC,CAAC,WAAW,EAAE;wBACjC,KAAK,QAAQ;4BACT,MAAK;wBAET,KAAK,KAAK,CAAC;wBACX,KAAK,IAAI,CAAC;wBACV,KAAK,OAAO,CAAC;wBACb,KAAK,MAAM,CAAC;wBACZ,KAAK,MAAM;4BACP,WAAW,CAAC,QAAQ,CAAC,GAAG,MAAM,CAAC,QAAQ,CAAC,CAAA;4BACxC,MAAK;wBAET,KAAK,MAAM,CAAC;wBACZ;4BACI,WAAW,CAAC,QAAQ,CAAC,GAAG,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,QAAQ,CAAC,EAAE,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAA;4BAC3E,MAAK;qBACZ;oBAED,SAAQ;iBACX;aACJ;YAED,WAAW,CAAC,QAAQ,CAAC,GAAG,MAAM,CAAC,QAAQ,CAAC,CAAC;SAC5C;QAED,OAAO,WAAW,CAAC;IACvB,CAAC;IAEO,OAAO,CAAC,GAAQ;QACpB,MAAM,WAAW,GAAG,GAAG,CAAC,WAAW,IAAI,GAAG,CAAC,WAAW,CAAC,QAAQ,EAAE,CAAC,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,KAAK,OAAO,CAAC;QAE9F,IAAI,GAAG,CAAC,SAAS,KAAK,SAAS;YAC3B,OAAO,WAAW,CAAA;QAEtB,MAAM,oBAAoB,GAAG,GAAG,CAAC,SAAS,CAAC,WAAW;eAC/C,GAAG,CAAC,SAAS,CAAC,WAAW,CAAC,QAAQ;eAClC,GAAG,CAAC,SAAS,CAAC,WAAW,CAAC,QAAQ,EAAE,CAAC,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,KAAK,OAAO,CAAA;QAEvE,OAAO,WAAW,IAAI,oBAAoB,CAAA;IAC9C,CAAC;CACJ;AA/vBD,mCA+vBC"}
\ No newline at end of file
diff --git a/lib/test/basic.d.ts b/lib/test/basic.d.ts
new file mode 100644
index 0000000..cb0ff5c
--- /dev/null
+++ b/lib/test/basic.d.ts
@@ -0,0 +1 @@
+export {};
diff --git a/lib/test/basic.js b/lib/test/basic.js
new file mode 100644
index 0000000..18cf99e
--- /dev/null
+++ b/lib/test/basic.js
@@ -0,0 +1,28 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const assert = require("assert");
+describe("When doing basic logic", () => {
+    beforeEach(() => {
+    });
+    it("should handle flattening of two-dimensional arrays", () => {
+        var ar = [
+            [1, 2, 3],
+            [5, 6]
+        ];
+        var flatten = [].concat.apply([], ar);
+        assert.equal(flatten.length, 5);
+        assert.deepEqual(flatten, [1, 2, 3, 5, 6]);
+    });
+    it("should handle flattening of two-dimensional arrays and combining", () => {
+        var master, ar;
+        master = [0, 4];
+        ar = [
+            [1, 2, 3],
+            [5, 6]
+        ];
+        var combined = [].concat.apply(master, ar);
+        assert.equal(combined.length, 7);
+        assert.deepEqual(combined, [0, 4, 1, 2, 3, 5, 6]);
+    });
+});
+//# sourceMappingURL=basic.js.map
\ No newline at end of file
diff --git a/lib/test/basic.js.map b/lib/test/basic.js.map
new file mode 100644
index 0000000..ba54d6b
--- /dev/null
+++ b/lib/test/basic.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"basic.js","sourceRoot":"","sources":["../../src/test/basic.ts"],"names":[],"mappings":";;AAAA,iCAAkC;AAElC,QAAQ,CAAC,wBAAwB,EAAE,GAAG,EAAE;IAEpC,UAAU,CAAC,GAAG,EAAE;IAEhB,CAAC,CAAC,CAAA;IAEF,EAAE,CAAC,oDAAoD,EAAE,GAAG,EAAE;QAC1D,IAAI,EAAE,GAAG;YACL,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC;YACT,CAAC,CAAC,EAAE,CAAC,CAAC;SACT,CAAC;QAEF,IAAI,OAAO,GAAG,EAAE,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC;QAEtC,MAAM,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC;QAChC,MAAM,CAAC,SAAS,CAAC,OAAO,EAAE,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC,CAAC;IAC/C,CAAC,CAAC,CAAA;IAEF,EAAE,CAAC,kEAAkE,EAAE,GAAG,EAAE;QACxE,IAAI,MAAqB,EAAE,EAAwB,CAAC;QAGpD,MAAM,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;QAChB,EAAE,GAAG;YACD,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC;YACT,CAAC,CAAC,EAAE,CAAC,CAAC;SACT,CAAC;QAEF,IAAI,QAAQ,GAAkB,EAAE,CAAC,MAAM,CAAC,KAAK,CAAC,MAAM,EAAE,EAAE,CAAC,CAAC;QAE1D,MAAM,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC;QACjC,MAAM,CAAC,SAAS,CAAC,QAAQ,EAAE,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC,CAAC;IACtD,CAAC,CAAC,CAAA;AACN,CAAC,CAAC,CAAA"}
\ No newline at end of file
diff --git a/package.json b/package.json
index 6a9bb2c..4d07fc8 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "tfso-cosmosdb",
-  "version": "0.0.0",
+  "version": "1.0.11",
   "description": "Promise wrapper for CosmosDB with simplified usage ",
   "scripts": {
     "test": "node node_modules/mocha/bin/_mocha --reporter spec --recursive lib/test/*.js"