const BaseEntity = require('./baseentity');
const Logs = require('./logs');
/**
* A Secondary Web Service.
*
* @class
* @extends BaseEntity
*/
class Service extends BaseEntity {
/**
* Creates an object representing a secondary web service stored at the back-end.
*
* @param {Connection} connection - A Connection object representing an established connection to an openEO back-end.
* @param {string} serviceId - The service ID.
* @constructor
*/
constructor(connection, serviceId) {
super(connection, ["id", "title", "description", "process", "url", "type", "enabled", "configuration", "attributes", "created", "plan", "costs", "budget"]);
this.serviceId = serviceId;
}
/**
* Updates the data stored in this object by requesting the secondary web service metadata from the back-end.
*
* @async
* @returns {Service} The updates service object (this).
* @throws {Error}
*/
async describeService() {
let response = await this.connection._get('/services/' + this.serviceId);
return this.setAll(response.data);
}
/**
* Modifies the secondary web service at the back-end and afterwards updates this object, too.
*
* @async
* @param {object} parameters - An object with properties to update, each of them is optional, but at least one of them must be specified. Additional properties can be set if the server supports them.
* @param {object} parameters.process - A new process.
* @param {string} parameters.title - A new title.
* @param {string} parameters.description - A new description.
* @param {boolean} parameters.enabled - Enables (`true`) or disables (`false`) the service.
* @param {object} parameters.configuration - A new set of configuration parameters to set for the service.
* @param {string} parameters.plan - A new plan.
* @param {number} parameters.budget - A new budget.
* @returns {Service} The updated service object (this).
* @throws {Error}
*/
async updateService(parameters) {
await this.connection._patch('/services/' + this.serviceId, this._convertToRequest(parameters));
if (this._supports('describeService')) {
return await this.describeService();
}
else {
return this.setAll(parameters);
}
}
/**
* Deletes the secondary web service from the back-end.
*
* @async
* @throws {Error}
*/
async deleteService() {
await this.connection._delete('/services/' + this.serviceId);
}
/**
* Get logs for the secondary web service from the back-end.
*
* @returns {Logs}
*/
debugService() {
return new Logs(this.connection, '/services/' + this.serviceId + '/logs');
}
/**
* 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. It is also executed once at the beginning.
* The callback receives the 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.
*
* This is only supported if describeService is supported by the back-end.
*
* @param {function} callback
* @param {integer} [interval=60]
* @returns {function}
* @throws {Error}
*/
monitorService(callback, interval = 60) {
if (typeof callback !== 'function' || interval < 1) {
return;
}
let capabilities = this.connection.capabilities();
if (!capabilities.hasFeature('describeService')) {
throw new Error('Monitoring Services not supported by the back-end.');
}
let wasEnabled = null;
let intervalId = null;
let logIterator = null;
if (capabilities.hasFeature('debugService')) {
logIterator = this.debugService();
}
let monitorFn = async () => {
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);
let stopFn = () => {
if (intervalId) {
clearInterval(intervalId);
intervalId = null;
}
};
return stopFn;
}
}
module.exports = Service;