arangojs - npm Package Compare versions

Comparing version 7.1.1 to 7.2.0

CHANGELOG.md

		@@ -17,2 +17,11 @@ # Changelog

		## [7.2.0] - 2020-12-02

		### Added

		- Added `db.waitForPropagation` method

		This method helps with setting up databases in a cluster scenario by waiting
		for a request to succeed on every known coordinator.

		## [7.1.1] - 2020-11-30
		@@ -1121,2 +1130,3 @@

		[7.2.0]: https://github.com/arangodb/arangojs/compare/v7.1.1...v7.2.0
		[7.1.1]: https://github.com/arangodb/arangojs/compare/v7.1.0...v7.1.1
		@@ -1123,0 +1133,0 @@ [7.1.0]: https://github.com/arangodb/arangojs/compare/v7.0.2...v7.1.0

connection.d.ts

		@@ -548,2 +548,13 @@ /// <reference types="node" />
		*
		* Waits for propagation.
		*
		* See {@link Database.waitForPropagation}.
		*
		* @param request - Request to perform against each coordinator.
		* @param timeout - Maximum number of milliseconds to wait for propagation.
		*/
		waitForPropagation(request: RequestOptions, timeout?: number): Promise<void>;
		/**
		* @internal
		*
		* Performs a request using the arangojs connection pool.
		@@ -550,0 +561,0 @@ */

connection.js

		@@ -304,2 +304,39 @@ "use strict";
		*
		* Waits for propagation.
		*
		* See {@link Database.waitForPropagation}.
		*
		* @param request - Request to perform against each coordinator.
		* @param timeout - Maximum number of milliseconds to wait for propagation.
		*/
		async waitForPropagation(request, timeout = Infinity) {
		const numHosts = this._hosts.length;
		const propagated = [];
		const started = Date.now();
		let host = 0;
		while (true) {
		if (propagated.length === numHosts) {
		return;
		}
		while (propagated.includes(host)) {
		host = (host + 1) % numHosts;
		}
		try {
		await this.request({ ...request, host });
		}
		catch (e) {
		if (started + timeout < Date.now()) {
		throw e;
		}
		await new Promise((resolve) => setTimeout(resolve, 1000));
		continue;
		}
		if (!propagated.includes(host)) {
		propagated.push(host);
		}
		}
		}
		/**
		* @internal
		*
		* Performs a request using the arangojs connection pool.
		@@ -306,0 +343,0 @@ */

database.js

		@@ -220,2 +220,5 @@ "use strict";
		}
		async waitForPropagation({ basePath, ...request }, timeout) {
		await this._connection.waitForPropagation({ ...request, basePath: `/_db/${this.name}${basePath \|\| ""}` }, timeout);
		}
		//#endregion
		@@ -222,0 +225,0 @@ //#region auth

documents.d.ts

		/**
		* ```ts
		* import type { Document, Edge } from "arangojs/document";
		* import type { Document, Edge } from "arangojs/documents";
		* ```
		*
		* The "document" module provides document/edge related types for TypeScript.
		* The "documents" module provides document/edge related types for TypeScript.
		*
		@@ -8,0 +8,0 @@ * @packageDocumentation

documents.js

		"use strict";
		/**
		* ```ts
		* import type { Document, Edge } from "arangojs/document";
		* import type { Document, Edge } from "arangojs/documents";
		* ```
		*
		* The "document" module provides document/edge related types for TypeScript.
		* The "documents" module provides document/edge related types for TypeScript.
		*
		@@ -9,0 +9,0 @@ * @packageDocumentation

package.json

connection.d.ts.map