Run monitorFn always on start #26 (#28)

* Run monitorFn on start #26 + bugfix

src/baseentity.js

@@ -17,6 +17,7 @@ class BaseEntity {
 		this.connection = connection;
 		this.apiToClientNames = {};
 		this.clientToApiNames = {};
+		this.lastRefreshTime = 0;
 		this.extra = {};
 		for(let i in properties) {
 			let backend, client;
@@ -59,9 +60,19 @@ class BaseEntity {
 				this[this.apiToClientNames[name]] = metadata[name];
 			}
 		}
+		this.lastRefreshTime = Date.now();
 		return this;
 	}
 
+	/**
+	 * Returns the age of the data in seconds.
+	 * 
+	 * @returns {integer}
+	 */
+	getDataAge() {
+		return (Date.now() - this.lastRefreshTime) / 1000;
+	}
+
 	/**
 	 * Returns all data in the model.
 	 * 

src/job.js

@@ -95,8 +95,8 @@ class Job extends BaseEntity {
 	 * Checks for status changes and new log entries every x seconds.
 	 * 
 	 * On every status change observed or on new log entries (if supported by the back-end),
-	 * the callback is executed.
-	 * The callback receives the job (this object) and the logs (array) passed.
+	 * the callback is executed. It may also be executed once at the beginning.
+	 * The callback receives the updated job (this object) and the logs (array) passed.
 	 * 
 	 * The monitoring stops once the job has finished, was canceled or errored out.
 	 * 
@@ -125,7 +125,9 @@ class Job extends BaseEntity {
 			logIterator = this.debugJob();
 		}
 		let monitorFn = async () => {
-			await this.describeJob();
+			if (this.getDataAge() > 1) {
+				await this.describeJob();
+			}
 			let logs = logIterator ? await logIterator.nextLogs() : [];
 			if (lastStatus !== this.status || logs.length > 0) {
 				callback(this, logs);
@@ -135,7 +137,8 @@ class Job extends BaseEntity {
 				stopFn();
 			}
 		};
-		intervalId = setTimeout(monitorFn, interval * 1000);
+		setTimeout(monitorFn, 0);
+		intervalId = setInterval(monitorFn, interval * 1000);
 		let stopFn = () => {
 			if (intervalId) {
 				clearInterval(intervalId);

src/service.js

@@ -81,8 +81,8 @@ class Service extends BaseEntity {
 	 * Checks for new log entries every x seconds.
 	 * 
 	 * On every status change (enabled/disabled) observed or on new log entries (if supported by the back-end),
-	 * the callback is executed.
-	 * The callback receives the service (this object) and the logs (array) passed.
+	 * the callback is executed. It may also be executed once at the beginning.
+	 * The callback receives the updated service (this object) and the logs (array) passed.
 	 * 
 	 * Returns a function that can be called to stop monitoring the service manually.
 	 * The monitoring must be stopped manually, otherwise it runs forever.
@@ -110,14 +110,17 @@ class Service extends BaseEntity {
 			logIterator = this.debugService();
 		}
 		let monitorFn = async () => {
-			await this.describeService();
+			if (this.getDataAge() > 1) {
+				await this.describeService();
+			}
 			let logs = logIterator ? await logIterator.nextLogs() : [];
 			if (wasEnabled !== this.enabled || logs.length > 0) {
 				callback(this, logs);
 			}
 			wasEnabled = this.enabled;
 		};
-		intervalId = setTimeout(monitorFn, interval * 1000);
+		setTimeout(monitorFn, 0);
+		intervalId = setInterval(monitorFn, interval * 1000);
 		let stopFn = () => {
 			if (intervalId) {
 				clearInterval(intervalId);