'use strict';
//region Imports
var util = require('util');
var config = require('./shared/configuration-reader.js');
var Argument = require('./system/argument-check.js');
var Enumeration = require('./system/enumeration.js');
var ModelBase = require('./model-base.js');
var ModelError = require('./shared/model-error.js');
var ExtensionManager = require('./shared/extension-manager.js');
var EventHandlerList = require('./shared/event-handler-list.js');
var DataStore = require('./shared/data-store.js');
var DataType = require('./data-types/data-type.js');
var PropertyInfo = require('./shared/property-info.js');
var PropertyManager = require('./shared/property-manager.js');
var PropertyContext = require('./shared/property-context.js');
var ValidationContext = require('./rules/validation-context.js');
var TransferContext = require('./shared/transfer-context.js');
var RuleManager = require('./rules/rule-manager.js');
var DataTypeRule = require('./rules/data-type-rule.js');
var BrokenRuleList = require('./rules/broken-rule-list.js');
var RuleSeverity = require('./rules/rule-severity.js');
var AuthorizationAction = require('./rules/authorization-action.js');
var AuthorizationContext = require('./rules/authorization-context.js');
var DataPortalAction = require('./shared/data-portal-action.js');
var DataPortalContext = require('./shared/data-portal-context.js');
var DataPortalEvent = require('./shared/data-portal-event.js');
var DataPortalEventArgs = require('./shared/data-portal-event-args.js');
var DataPortalError = require('./shared/data-portal-error.js');
var MODEL_STATE = require('./shared/model-state.js');
var CLASS_NAME = 'EditableChildModel';
var MODEL_DESC = 'Editable child model';
var M_FETCH = DataPortalAction.getName(DataPortalAction.fetch);
//endregion
/**
* Factory method to create definitions of asynchronous editable child models.
*
* Valid child model types are:
*
* * ReadOnlyChildCollection
* * ReadOnlyChildModel
*
* @function bo.EditableChildModel
* @param {bo.shared.PropertyManager} properties - The property definitions.
* @param {bo.shared.RuleManager} rules - The validation and authorization rules.
* @param {bo.shared.ExtensionManager} extensions - The customization of the model.
* @returns {EditableChildModel} The constructor of an asynchronous editable child model.
*
* @throws {@link bo.system.ArgumentError Argument error}: The properties must be a PropertyManager object.
* @throws {@link bo.system.ArgumentError Argument error}: The rules must be a RuleManager object.
* @throws {@link bo.system.ArgumentError Argument error}: The extensions must be a ExtensionManager object.
*
* @throws {@link bo.shared.ModelError Model error}:
* The child objects must be EditableChildCollection or EditableChildModel instances.
*/
var EditableChildModelFactory = function (properties, rules, extensions) {
var check = Argument.inConstructor(CLASS_NAME);
properties = check(properties).forMandatory('properties').asType(PropertyManager);
rules = check(rules).forMandatory('rules').asType(RuleManager);
extensions = check(extensions).forMandatory('extensions').asType(ExtensionManager);
// Verify the model types of child models.
properties.verifyChildTypes([ 'EditableChildCollection', 'EditableChildModel' ]);
// Get data access object.
var dao = extensions.getDataAccessObject(properties.name);
/**
* @classdesc
* Represents the definition of an asynchronous editable child model.
* @description
* Creates a new asynchronous editable child model instance.
*
* _The name of the model type available as:
* __<instance>.constructor.modelType__, returns 'EditableChildModel'._
*
* Valid parent model types are:
*
* * EditableChildCollection
* * EditableRootModel
* * EditableChildModel
*
* @name EditableChildModel
* @constructor
* @param {object} parent - The parent business object.
* @param {bo.shared.EventHandlerList} [eventHandlers] - The event handlers of the instance.
*
* @extends ModelBase
*
* @throws {@link bo.system.ArgumentError Argument error}:
* The parent object must be an EditableChildCollection, EditableRootModel or
* EditableChildModel instance.
* @throws {@link bo.system.ArgumentError Argument error}:
* The event handlers must be an EventHandlerList object or null.
*
* @fires EditableChildModel#preCreate
* @fires EditableChildModel#postCreate
* @fires EditableChildModel#preFetch
* @fires EditableChildModel#postFetch
* @fires EditableChildModel#preInsert
* @fires EditableChildModel#postInsert
* @fires EditableChildModel#preUpdate
* @fires EditableChildModel#postUpdate
* @fires EditableChildModel#preRemove
* @fires EditableChildModel#postRemove
*/
var EditableChildModel = function (parent, eventHandlers) {
ModelBase.call(this);
var check = Argument.inConstructor(properties.name);
// Verify the model type of the parent model.
parent = check(parent).for('parent').asModelType([
'EditableRootCollection',
'EditableChildCollection',
'EditableRootModel',
'EditableChildModel'
]);
eventHandlers = check(eventHandlers).forOptional('eventHandlers').asType(EventHandlerList);
var self = this;
var state = null;
var isDirty = false;
var store = new DataStore();
var brokenRules = new BrokenRuleList(properties.name);
var isValidated = false;
var propertyContext = null;
var dataContext = null;
// Set up business rules.
rules.initialize(config.noAccessBehavior);
// Set up event handlers.
if (eventHandlers)
eventHandlers.setup(self);
//region Mark object state
/*
* From: To: | pri | cre | cha | mfr | rem
* -------------------------------------------------
* NULL | + | + | N | N | N
* -------------------------------------------------
* pristine | o | - | + | + | -
* -------------------------------------------------
* created | + | o | o | (-) | +
* -------------------------------------------------
* changed | + | - | o | + | -
* -------------------------------------------------
* markedForRemoval | - | - | o | o | +
* -------------------------------------------------
* removed | - | - | - | - | o
* -------------------------------------------------
*
* Explanation:
* + : possible transition
* - : not allowed transition, throws exception
* o : no change, no action
* N : impossible start up, throws exception
*/
function markAsPristine() {
if (state === MODEL_STATE.markedForRemoval || state === MODEL_STATE.removed)
illegal(MODEL_STATE.pristine);
else if (state !== MODEL_STATE.pristine) {
state = MODEL_STATE.pristine;
isDirty = false;
}
}
function markAsCreated() {
if (state === null) {
state = MODEL_STATE.created;
isDirty = true;
propagateChange(); // up to the parent
}
else if (state !== MODEL_STATE.created)
illegal(MODEL_STATE.created);
}
function markAsChanged(itself) {
if (state === MODEL_STATE.pristine) {
state = MODEL_STATE.changed;
isDirty = isDirty || itself;
propagateChange(); // up to the parent
isValidated = false;
}
else if (state === MODEL_STATE.created) {
isDirty = isDirty || itself;
propagateChange(); // up to the parent
isValidated = false;
}
else if (state === MODEL_STATE.removed)
illegal(MODEL_STATE.changed);
}
function markForRemoval() {
if (state === MODEL_STATE.pristine || state === MODEL_STATE.changed) {
state = MODEL_STATE.markedForRemoval;
isDirty = true;
propagateRemoval(); // down to children
propagateChange(); // up to the parent
}
else if (state === MODEL_STATE.created)
state = MODEL_STATE.removed;
else if (state !== MODEL_STATE.markedForRemoval)
illegal(MODEL_STATE.markedForRemoval);
}
function markAsRemoved() {
if (state === MODEL_STATE.created || state === MODEL_STATE.markedForRemoval) {
state = MODEL_STATE.removed;
isDirty = false;
}
else if (state !== MODEL_STATE.removed)
illegal(MODEL_STATE.removed);
}
function illegal(newState) {
throw new ModelError('transition',
(state == null ? 'NULL' : MODEL_STATE.getName(state)),
MODEL_STATE.getName(newState));
}
function propagateChange() {
parent.childHasChanged();
}
/**
* Notes that a child object has changed.
* <br/>_This method is called by child objects._
*
* @function EditableChildModel#childHasChanged
* @protected
*/
this.childHasChanged = function() {
markAsChanged(false);
};
function propagateRemoval() {
properties.children().forEach(function(property) {
var child = getPropertyValue(property);
child.remove();
});
}
//endregion
//region Show object state
/**
* Gets the state of the model. Valid states are:
* pristine, created, changed, markedForRemoval and removed.
*
* @function EditableChildModel#getModelState
* @returns {string} The state of the model.
*/
this.getModelState = function () {
return MODEL_STATE.getName(state);
};
/**
* Indicates whether the business object has been created newly and
* not has been yet saved, i.e. its state is created.
*
* @function EditableChildModel#isNew
* @returns {boolean} True when the business object is new, otherwise false.
*/
this.isNew = function () {
return state === MODEL_STATE.created;
};
/**
* Indicates whether the business object itself or any of its child objects differs the one
* that is stored in the repository, i.e. its state is created, changed or markedForRemoval.
*
* @function EditableChildModel#isDirty
* @returns {boolean} True when the business object has been changed, otherwise false.
*/
this.isDirty = function () {
return state === MODEL_STATE.created ||
state === MODEL_STATE.changed ||
state === MODEL_STATE.markedForRemoval;
};
/**
* Indicates whether the business object itself, ignoring its child objects, differs the one
* that is stored in the repository.
*
* @function EditableChildModel#isSelfDirty
* @returns {boolean} True when the business object itself has been changed, otherwise false.
*/
this.isSelfDirty = function () {
return isDirty;
};
/**
* Indicates whether the business object will be deleted from the repository,
* i.e. its state is markedForRemoval.
*
* @function EditableChildModel#isDeleted
* @returns {boolean} True when the business object will be deleted, otherwise false.
*/
this.isDeleted = function () {
return state === MODEL_STATE.markedForRemoval;
};
//endregion
//region Transfer object methods
function getTransferContext (authorize) {
return authorize ?
new TransferContext(properties.toArray(), readPropertyValue, writePropertyValue) :
new TransferContext(properties.toArray(), getPropertyValue, setPropertyValue);
}
function baseToDto() {
var dto = {};
properties.filter(function (property) {
return property.isOnDto;
}).forEach(function (property) {
dto[property.name] = getPropertyValue(property);
});
return dto;
}
function toDto () {
if (extensions.toDto)
return extensions.toDto.call(self, getTransferContext(false));
else
return baseToDto();
}
function baseFromDto(dto) {
properties.filter(function (property) {
return property.isOnDto;
}).forEach(function (property) {
if (dto.hasOwnProperty(property.name) && typeof dto[property.name] !== 'function') {
setPropertyValue(property, dto[property.name]);
}
});
}
function fromDto (dto) {
if (extensions.fromDto)
extensions.fromDto.call(self, getTransferContext(false), dto);
else
baseFromDto(dto);
}
function baseToCto() {
var cto = {};
properties.filter(function (property) {
return property.isOnCto;
}).forEach(function (property) {
cto[property.name] = readPropertyValue(property);
});
return cto;
}
/**
* Transforms the business object to a plain object to send to the client.
* <br/>_This method is usually called by the parent object._
*
* @function EditableChildModel#toCto
* @returns {object} The client transfer object.
*/
this.toCto = function () {
var cto = {};
if (extensions.toCto)
cto = extensions.toCto.call(self, getTransferContext(true));
else
cto = baseToCto();
properties.children().forEach(function(property) {
var child = getPropertyValue(property);
cto[property.name] = child.toCto();
});
return cto;
};
function baseFromCto(cto) {
if (cto && typeof cto === 'object') {
properties.filter(function (property) {
return property.isOnCto;
}).forEach(function (property) {
if (cto.hasOwnProperty(property.name) && typeof cto[property.name] !== 'function') {
writePropertyValue(property, cto[property.name]);
}
});
}
}
/**
* Rebuilds the business object from a plain object sent by the client.
* <br/>_This method is usually called by the parent object._
*
* @function EditableChildModel#fromCto
* @param {object} cto - The client transfer object.
* @param {external.cbFromCto} callback - Returns the eventual error.
*/
this.fromCto = function (cto, callback) {
if (extensions.fromCto)
extensions.fromCto.call(self, getTransferContext(true), cto);
else
baseFromCto(cto);
// Build children.
var count = properties.childCount();
var error = null;
function finish (err) {
if (err)
error = error || err;
if (--count == 0)
callback(error);
}
if (count)
properties.children().forEach(function (property) {
var child = getPropertyValue(property);
if (cto[property.name])
child.fromCto(cto[property.name], finish);
else
finish(null);
});
else
callback(null);
};
/**
* Determines that the passed data contains current values of the model key.
*
* @function EditableChildModel#keyEquals
* @protected
* @param {object} data - Data object whose properties can contain the values of the model key.
* @param {internal~getValue} getPropertyValue - A function that returns
* the current value of the given property.
* @returns {boolean} True when the values are equal, false otherwise.
*/
this.keyEquals = function (data) {
return properties.keyEquals(data, getPropertyValue);
};
//endregion
//region Permissions
function getAuthorizationContext(action, targetName) {
return new AuthorizationContext(action, targetName || '', brokenRules);
}
function canBeRead (property) {
return rules.hasPermission(
getAuthorizationContext(AuthorizationAction.readProperty, property.name)
);
}
function canBeWritten (property) {
return rules.hasPermission(
getAuthorizationContext(AuthorizationAction.writeProperty, property.name)
);
}
function canDo (action) {
return rules.hasPermission(
getAuthorizationContext(action)
);
}
function canExecute (methodName) {
return rules.hasPermission(
getAuthorizationContext(AuthorizationAction.executeMethod, methodName)
);
}
//endregion
//region Child methods
function fetchChildren(dto, callback) {
var count = 0;
var error = null;
function finish (err) {
error = error || err;
// Check if all children are done.
if (++count === properties.childCount()) {
callback(error);
}
}
if (properties.childCount()) {
properties.children().forEach(function(property) {
var child = getPropertyValue(property);
if (child instanceof ModelBase)
child.fetch(dto[property.name], undefined, finish);
else
child.fetch(dto[property.name], finish);
});
} else
callback(null);
}
function insertChildren(connection, callback) {
saveChildren(connection, callback);
}
function updateChildren(connection, callback) {
saveChildren(connection, callback);
}
function removeChildren(connection, callback) {
saveChildren(connection, callback);
}
function saveChildren(connection, callback) {
var count = 0;
var error = null;
if (properties.childCount()) {
properties.children().forEach(function (property) {
var child = getPropertyValue(property);
child.save(connection, function (err) {
error = error || err;
// Check if all children are done.
if (++count === properties.childCount()) {
callback(error);
}
});
});
} else
callback(null);
}
function childrenAreValid() {
return properties.children().every(function(property) {
var child = getPropertyValue(property);
return child.isValid();
});
}
function checkChildRules() {
properties.children().forEach(function(property) {
var child = getPropertyValue(property);
child.checkRules();
});
}
function getChildBrokenRules (namespace, bro) {
properties.children().forEach(function (property) {
var child = getPropertyValue(property);
var childBrokenRules = child.getBrokenRules(namespace);
if (childBrokenRules) {
if (childBrokenRules instanceof Array)
bro.addChildren(property.name, childBrokenRules);
else
bro.addChild(property.name, childBrokenRules);
}
});
return bro;
}
//endregion
//region Data portal methods
//region Helper
function getDataContext (connection) {
if (!dataContext)
dataContext = new DataPortalContext(
dao, properties.toArray(), getPropertyValue, setPropertyValue
);
return dataContext.setState(connection, isDirty);
}
function raiseEvent (event, methodName, error) {
self.emit(
DataPortalEvent.getName(event),
new DataPortalEventArgs(event, properties.name, null, methodName, error)
);
}
function wrapError (action, error) {
return new DataPortalError(MODEL_DESC, properties.name, action, error);
}
function runStatements (main, action, callback) {
// Open connection.
config.connectionManager.openConnection(
extensions.dataSource, function (errOpen, connection) {
if (errOpen)
callback(wrapError(action, errOpen));
else
main(connection, function (err, result) {
// Close connection.
config.connectionManager.closeConnection(
extensions.dataSource, connection, function (errClose, connClosed) {
connection = connClosed;
if (err)
callback(wrapError(action, err));
else if (errClose)
callback(wrapError(action, errClose));
else
callback(null, result);
});
});
});
}
//endregion
//region Create
function data_create (callback) {
var hasConnection = false;
// Helper callback for post-creation actions.
function finish (cb) {
markAsCreated();
// Launch finish event.
/**
* The event arises after the business object instance has been initialized in the repository.
* @event EditableChildModel#postCreate
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} newObject - The instance of the model after the data portal action.
*/
raiseEvent(DataPortalEvent.postCreate);
cb(null, self);
}
// Helper callback for failure.
function failed (err, cb) {
if (hasConnection) {
// Launch finish event.
var dpError = wrapError(DataPortalAction.create, err);
raiseEvent(DataPortalEvent.postCreate, null, dpError);
}
cb(err);
}
// Main activity.
function main (connection, cb) {
hasConnection = connection !== null;
// Launch start event.
/**
* The event arises before the business object instance will be initialized in the repository.
* @event EditableChildModel#preCreate
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} oldObject - The instance of the model before the data portal action.
*/
raiseEvent(DataPortalEvent.preCreate);
// Execute creation.
if (extensions.dataCreate) {
// *** Custom creation.
extensions.dataCreate.call(self, getDataContext(connection), function (err) {
if (err)
failed(err, cb);
else
finish(cb);
});
} else {
// *** Standard creation.
dao.$runMethod('create', connection, function (err, dto) {
if (err)
failed(err, cb);
else {
fromDto.call(self, dto);
finish(cb);
}
});
}
}
if (extensions.dataCreate || dao.$hasCreate()) {
runStatements(main, DataPortalAction.create, callback);
}
}
//endregion
//region Fetch
function data_fetch (data, method, callback) {
// Helper function for post-fetch actions.
function finish (dto, cb) {
// Fetch children as well.
fetchChildren(dto, function (err) {
if (err)
failed(err, cb);
else {
markAsPristine();
// Launch finish event.
/**
* The event arises after the business object instance has been retrieved from the repository.
* @event EditableChildModel#postFetch
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} newObject - The instance of the model after the data portal action.
*/
raiseEvent(DataPortalEvent.postFetch, method);
cb(null, self);
}
});
}
// Helper callback for failure.
function failed (err, cb) {
// Launch finish event.
var dpError = wrapError(DataPortalAction.fetch, err);
raiseEvent(DataPortalEvent.postFetch, method, dpError);
cb(err);
}
// Check permissions.
if (method === M_FETCH ? canDo(AuthorizationAction.fetchObject) : canExecute(method)) {
// Launch start event.
/**
* The event arises before the business object instance will be retrieved from the repository.
* @event EditableChildModel#preFetch
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} oldObject - The instance of the model before the data portal action.
*/
raiseEvent(DataPortalEvent.preFetch, method);
// Execute fetch.
if (extensions.dataFetch) {
// *** Custom fetch.
extensions.dataFetch.call(self, getDataContext(null), data, method, function (err, dto) {
if (err)
failed(err, callback);
else
finish(dto, callback);
});
} else {
// *** Standard fetch.
// Child element gets data from parent.
fromDto.call(self, data);
finish(data, callback);
}
} else
callback(null, self);
}
//endregion
//region Insert
function data_insert (connection, callback) {
// Helper function for post-insert actions.
function finish (conn, cb) {
// Insert children as well.
insertChildren(conn, function (err) {
if (err)
failed(err, cb);
else {
markAsPristine();
// Launch finish event.
/**
* The event arises after the business object instance has been created in the repository.
* @event EditableChildModel#postInsert
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} newObject - The instance of the model after the data portal action.
*/
raiseEvent(DataPortalEvent.postInsert);
cb(null, self);
}
});
}
// Helper callback for failure.
function failed (err, cb) {
// Launch finish event.
var dpError = wrapError(DataPortalAction.insert, err);
raiseEvent(DataPortalEvent.postInsert, null, dpError);
cb(err);
}
// Main activity.
function main (conn, cb) {
// Launch start event.
/**
* The event arises before the business object instance will be created in the repository.
* @event EditableChildModel#preInsert
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} oldObject - The instance of the model before the data portal action.
*/
raiseEvent(DataPortalEvent.preInsert);
// Execute insert.
if (extensions.dataInsert) {
// *** Custom insert.
extensions.dataInsert.call(self, getDataContext(conn), function (err) {
if (err)
failed(err, cb);
else
finish(conn, cb);
});
} else {
// *** Standard insert.
var dto = toDto.call(self);
dao.$runMethod('insert', conn, dto, function (err, dto) {
if (err)
failed(err, cb);
else {
fromDto.call(self, dto);
finish(conn, cb);
}
});
}
}
// Check permissions.
if (canDo(AuthorizationAction.createObject)) {
// Copy the values of parent keys.
var references = properties.filter(function (property) {
return property.isParentKey;
});
for (var i = 0; i < references.length; i++) {
var referenceProperty = references[i];
var parentValue = parent[referenceProperty.name];
if (parentValue !== undefined)
setPropertyValue(referenceProperty, parentValue);
}
// Execute insert.
main(connection, callback);
} else
callback(null, self);
}
//endregion
//region Update
function data_update (connection, callback) {
// Helper function for post-update actions.
function finish (conn, cb) {
// Update children as well.
updateChildren(conn, function (err) {
if (err)
failed(err, cb);
else {
markAsPristine();
// Launch finish event.
/**
* The event arises after the business object instance has been updated in the repository.
* @event EditableChildModel#postUpdate
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} newObject - The instance of the model after the data portal action.
*/
raiseEvent(DataPortalEvent.postUpdate);
cb(null, self);
}
});
}
// Helper callback for failure.
function failed (err, cb) {
// Launch finish event.
var dpError = wrapError(DataPortalAction.update, err);
raiseEvent(DataPortalEvent.postUpdate, null, dpError);
cb(err);
}
// Main activity.
function main (conn, cb) {
// Launch start event.
/**
* The event arises before the business object instance will be updated in the repository.
* @event EditableChildModel#preUpdate
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} oldObject - The instance of the model before the data portal action.
*/
raiseEvent(DataPortalEvent.preUpdate);
// Execute update.
if (extensions.dataUpdate) {
// *** Custom update.
extensions.dataUpdate.call(self, getDataContext(conn), function (err) {
if (err)
failed(err, cb);
else
finish(conn, cb);
});
} else if (isDirty) {
// *** Standard update.
var dto = toDto.call(self);
dao.$runMethod('update', conn, dto, function (err, dto) {
if (err)
failed(err, cb);
else {
fromDto.call(self, dto);
finish(conn, cb);
}
});
} else {
// Update children only.
finish(conn, cb);
}
}
// Check permissions.
if (canDo(AuthorizationAction.updateObject))
main(connection, callback);
else
callback(null, self);
}
//endregion
//region Remove
function data_remove (connection, callback) {
// Helper callback for post-removal actions.
function finish (cb) {
markAsRemoved();
// Launch finish event.
/**
* The event arises after the business object instance has been removed from the repository.
* @event EditableChildModel#postRemove
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} newObject - The instance of the model after the data portal action.
*/
raiseEvent(DataPortalEvent.postRemove);
cb(null, null);
}
// Helper callback for failure.
function failed (err, cb) {
// Launch finish event.
var dpError = wrapError(DataPortalAction.remove, err);
raiseEvent(DataPortalEvent.postRemove, null, dpError);
cb(err);
}
// Main activity.
function main (conn, cb) {
// Launch start event.
/**
* The event arises before the business object instance will be removed from the repository.
* @event EditableChildModel#preRemove
* @param {bo.shared.DataPortalEventArgs} eventArgs - Data portal event arguments.
* @param {EditableChildModel} oldObject - The instance of the model before the data portal action.
*/
raiseEvent(DataPortalEvent.preRemove);
// Remove children first.
removeChildren(conn, function (err) {
if (err)
failed(err, cb);
else {
// Execute removal.
if (extensions.dataRemove) {
// *** Custom removal.
extensions.dataRemove.call(self, getDataContext(conn), function (err) {
if (err)
failed(err, cb);
else
finish(cb);
});
} else {
// *** Standard removal.
var filter = properties.getKey(getPropertyValue);
dao.$runMethod('remove', conn, filter, function (err) {
if (err)
failed(err, cb);
else
finish(cb);
});
}
}
});
}
// Check permissions.
if (canDo(AuthorizationAction.removeObject))
main(connection, callback);
else
callback(null);
}
//endregion
//endregion
//region Actions
/**
* Initializes a newly created business object.
* <br/>_This method is called by the parent object._
*
* @function EditableChildModel#create
* @protected
* @param {external.cbDataPortal} callback - Returns a new editable business object.
*/
this.create = function(callback) {
data_create(callback);
};
/**
* Initializes a business object with data retrieved from the repository.
* <br/>_This method is called by the parent object._
*
* @function EditableChildModel#fetch
* @protected
* @param {object} [data] - The data to load into the business object.
* @param {string} [method] - An alternative fetch method to check for permission.
* @param {external.cbDataPortal} callback - Returns the required editable business object.
*/
this.fetch = function(data, method, callback) {
data_fetch(data, method || M_FETCH, callback);
};
/**
* Saves the changes of the business object to the repository.
* <br/>_This method is called by the parent object._
*
* @function EditableChildModel#save
* @protected
* @param {object} connection - The connection data.
* @param {external.cbDataPortal} callback - The business object with the new state after the save.
*/
this.save = function(connection, callback) {
if (this.isValid()) {
switch (state) {
case MODEL_STATE.created:
data_insert(connection, callback);
break;
case MODEL_STATE.changed:
data_update(connection, callback);
break;
case MODEL_STATE.markedForRemoval:
data_remove(connection, callback);
break;
default:
callback(null, this);
}
}
};
/**
* Marks the business object to be deleted from the repository on next save.
*
* @function EditableChildModel#remove
*/
this.remove = function() {
markForRemoval();
};
//endregion
//region Validation
/**
* Indicates whether all the validation rules of the business object, including
* the ones of its child objects, succeeds. A valid business object may have
* broken rules with severity of success, information and warning.
*
* _This method is called by the parent object._
*
* @function EditableChildModel#isValid
* @protected
* @returns {boolean} True when the business object is valid, otherwise false.
*/
this.isValid = function() {
if (!isValidated)
this.checkRules();
return brokenRules.isValid() && childrenAreValid();
};
/**
* Executes all the validation rules of the business object, including the ones
* of its child objects.
*
* _This method is called by the parent object._
*
* @function EditableChildModel#checkRules
* @protected
*/
this.checkRules = function() {
brokenRules.clear();
var context = new ValidationContext(store, brokenRules);
properties.forEach(function(property) {
rules.validate(property, context);
});
checkChildRules();
isValidated = true;
};
/**
* Gets the broken rules of the business object.
*
* _This method is called by the parent object._
*
* @function EditableChildModel#getBrokenRules
* @protected
* @param {string} [namespace] - The namespace of the message keys when messages are localizable.
* @returns {bo.rules.BrokenRulesOutput} The broken rules of the business object.
*/
this.getBrokenRules = function(namespace) {
var bro = brokenRules.output(namespace);
bro = getChildBrokenRules(namespace, bro);
return bro.$length ? bro : null;
};
//endregion
//region Properties
function getPropertyValue(property) {
return store.getValue(property);
}
function setPropertyValue(property, value) {
if (store.setValue(property, value))
markAsChanged(true);
}
function readPropertyValue(property) {
if (canBeRead(property)) {
if (property.getter)
return property.getter(getPropertyContext(property));
else
return store.getValue(property);
} else
return null;
}
function writePropertyValue(property, value) {
if (canBeWritten(property)) {
var changed = property.setter ?
property.setter(getPropertyContext(property), value) :
store.setValue(property, value);
if (changed === true)
markAsChanged(true);
}
}
function getPropertyContext(primaryProperty) {
if (!propertyContext)
propertyContext = new PropertyContext(properties.toArray(), readPropertyValue, writePropertyValue);
return propertyContext.with(primaryProperty);
}
properties.map(function(property) {
if (property.type instanceof DataType) {
// Normal property
store.initValue(property);
Object.defineProperty(self, property.name, {
get: function () {
return readPropertyValue(property);
},
set: function (value) {
if (property.isReadOnly)
throw new ModelError('readOnly', properties.name, property.name);
writePropertyValue(property, value);
},
enumerable: true
});
rules.add(new DataTypeRule(property));
} else {
// Child item/collection
if (property.type.create) // Item
property.type.create(self, eventHandlers, function (err, item) {
store.initValue(property, item);
});
else // Collection
store.initValue(property, new property.type(self, eventHandlers));
Object.defineProperty(self, property.name, {
get: function () {
return readPropertyValue(property);
},
set: function (value) {
throw new ModelError('readOnly', properties.name, property.name);
},
enumerable: false
});
}
});
//endregion
// Immutable object.
Object.freeze(this);
};
util.inherits(EditableChildModel, ModelBase);
/**
* The name of the model type.
*
* @property {string} EditableChildModel.constructor.modelType
* @default EditableChildModel
* @readonly
*/
Object.defineProperty(EditableChildModel, 'modelType', {
get: function () { return CLASS_NAME; }
});
/**
* The name of the model. However, it can be hidden by a model property with the same name.
*
* @name EditableChildModel#$modelName
* @type {string}
* @readonly
*/
EditableChildModel.prototype.$modelName = properties.name;
//region Factory methods
/**
* Creates a new editable business object instance.
* <br/>_This method is called by the parent object._
*
* @function EditableChildModel.create
* @protected
* @param {object} parent - The parent business object.
* @param {bo.shared.EventHandlerList} [eventHandlers] - The event handlers of the instance.
* @param {external.cbDataPortal} callback - Returns a new editable business object.
*
* @throws {@link bo.rules.AuthorizationError Authorization error}:
* The user has no permission to execute the action.
* @throws {@link bo.shared.DataPortalError Data portal error}:
* Creating the business object has failed.
*/
EditableChildModel.create = function(parent, eventHandlers, callback) {
var instance = new EditableChildModel(parent, eventHandlers);
instance.create(function (err) {
if (err)
callback(err);
else
callback(null, instance);
});
};
/**
* Initializes an editable business object width data retrieved from the repository.
* <br/>_This method is called by the parent object._
*
* @function EditableChildModel.load
* @protected
* @param {object} parent - The parent business object.
* @param {object} data - The data to load into the business object.
* @param {bo.shared.EventHandlerList} [eventHandlers] - The event handlers of the instance.
* @param {external.cbDataPortal} callback - Returns the required editable business object.
*
* @throws {@link bo.rules.AuthorizationError Authorization error}:
* The user has no permission to execute the action.
*/
EditableChildModel.load = function(parent, data, eventHandlers, callback) {
var instance = new EditableChildModel(parent, eventHandlers);
instance.fetch(data, undefined, function (err) {
if (err)
callback(err);
else
callback(null, instance);
});
};
//endregion
return EditableChildModel;
};
module.exports = EditableChildModelFactory;