var DATA_CONTROL_MANAGER_LISTENER_ID = 'DataControlManagerChangeCallback';
var DataType = {
- 'MAP': 'MAP',
- 'SQL': 'SQL'
+ MAP: 'MAP',
+ SQL: 'SQL'
};
var DataControlListenersManager = (function() {
+ function changeEvent(event) {
+ var successCallback;
- function changeEvent(event) {
- var successCallback;
-
- if (DataType.SQL === event.type.substr(0,3)) {
- if (type_.isEmptyObject(this._SQLDataControlCbMap)) {
- return;
- }
- for (var listenerId in this._SQLDataControlCbMap) {
- if (this._SQLDataControlCbMap.hasOwnProperty(listenerId)) {
- if (this._SQLDataControlCbMap[listenerId].providerId === event.providerId &&
- this._SQLDataControlCbMap[listenerId].dataId === event.dataId) {
- successCallback = this._SQLDataControlCbMap[listenerId].changeCallback;
- if (type_.isFunction(successCallback)) {
- successCallback(event.type, {columns: event.columns, values: event.values});
+ if (DataType.SQL === event.type.substr(0, 3)) {
+ if (type_.isEmptyObject(this._SQLDataControlCbMap)) {
+ return;
}
- }
- }
- }
- } else {
- if (type_.isEmptyObject(this._MAPDataControlCbMap)) {
- return;
- }
- for (var listenerId in this._MAPDataControlCbMap) {
- if (this._MAPDataControlCbMap.hasOwnProperty(listenerId)) {
- if (this._MAPDataControlCbMap[listenerId].providerId === event.providerId &&
- this._MAPDataControlCbMap[listenerId].dataId === event.dataId) {
- successCallback = this._MAPDataControlCbMap[listenerId].changeCallback;
- if (type_.isFunction(successCallback)) {
- successCallback(event.type, {columns: event.columns, values: event.values});
+ for (var listenerId in this._SQLDataControlCbMap) {
+ if (this._SQLDataControlCbMap.hasOwnProperty(listenerId)) {
+ if (
+ this._SQLDataControlCbMap[listenerId].providerId ===
+ event.providerId &&
+ this._SQLDataControlCbMap[listenerId].dataId === event.dataId
+ ) {
+ successCallback = this._SQLDataControlCbMap[listenerId]
+ .changeCallback;
+ if (type_.isFunction(successCallback)) {
+ successCallback(event.type, {
+ columns: event.columns,
+ values: event.values
+ });
+ }
+ }
+ }
+ }
+ } else {
+ if (type_.isEmptyObject(this._MAPDataControlCbMap)) {
+ return;
+ }
+ for (var listenerId in this._MAPDataControlCbMap) {
+ if (this._MAPDataControlCbMap.hasOwnProperty(listenerId)) {
+ if (
+ this._MAPDataControlCbMap[listenerId].providerId ===
+ event.providerId &&
+ this._MAPDataControlCbMap[listenerId].dataId === event.dataId
+ ) {
+ successCallback = this._MAPDataControlCbMap[listenerId]
+ .changeCallback;
+ if (type_.isFunction(successCallback)) {
+ successCallback(event.type, {
+ columns: event.columns,
+ values: event.values
+ });
+ }
+ }
+ }
}
- }
}
- }
}
- }
- function _DataControlListenerManager() {
- this._SQLDataControlCbMap = {};
- this._MAPDataControlCbMap = {};
- this.lastListenerId = 0;
- this.changeEvent = changeEvent.bind(this);
- }
-
- _DataControlListenerManager.prototype.addChangeListener = function(type, providerId, dataId, changeCallback, errorCallback) {
- var _realWatchId = 0;
- if (DataType.SQL === type) {
- for (var i in this._SQLDataControlCbMap) {
- if (this._SQLDataControlCbMap.hasOwnProperty(i) &&
- this._SQLDataControlCbMap[i].providerId === providerId &&
- this._SQLDataControlCbMap[i].dataId === dataId) {
- _realWatchId = this._SQLDataControlCbMap[i].realWatchId;
- }
- }
- } else {
- for (var i in this._MAPDataControlCbMap) {
- if (this._MAPDataControlCbMap.hasOwnProperty(i) &&
- this._MAPDataControlCbMap[i].providerId === providerId &&
- this._MAPDataControlCbMap[i].dataId === dataId) {
- _realWatchId = this._MAPDataControlCbMap[i].realWatchId;
- }
- }
+ function _DataControlListenerManager() {
+ this._SQLDataControlCbMap = {};
+ this._MAPDataControlCbMap = {};
+ this.lastListenerId = 0;
+ this.changeEvent = changeEvent.bind(this);
}
- if (!_realWatchId) {
- var callback = function(result) {
- if (native_.isFailure(result)) {
- native_.callIfPossible(errorCallback, native_.getErrorObject(result));
- return;
+ _DataControlListenerManager.prototype.addChangeListener = function(
+ type,
+ providerId,
+ dataId,
+ changeCallback,
+ errorCallback
+ ) {
+ var _realWatchId = 0;
+ if (DataType.SQL === type) {
+ for (var i in this._SQLDataControlCbMap) {
+ if (
+ this._SQLDataControlCbMap.hasOwnProperty(i) &&
+ this._SQLDataControlCbMap[i].providerId === providerId &&
+ this._SQLDataControlCbMap[i].dataId === dataId
+ ) {
+ _realWatchId = this._SQLDataControlCbMap[i].realWatchId;
+ }
+ }
+ } else {
+ for (var i in this._MAPDataControlCbMap) {
+ if (
+ this._MAPDataControlCbMap.hasOwnProperty(i) &&
+ this._MAPDataControlCbMap[i].providerId === providerId &&
+ this._MAPDataControlCbMap[i].dataId === dataId
+ ) {
+ _realWatchId = this._MAPDataControlCbMap[i].realWatchId;
+ }
+ }
}
- };
- var result =
- native_.call('DataControlConsumerObject_addChangeListener', {
- providerId: providerId,
- dataId: dataId,
- type: type
- }, callback);
-
- if (native_.isFailure(result)) {
- throw native_.getErrorObject(result);
- } else {
- result = native_.getResultObject(result);
- _realWatchId = converter_.toLong(result.watchId, true);
- }
- if (type_.isEmptyObject(this._SQLDataControlCbMap) &&
- type_.isEmptyObject(this._MAPDataControlCbMap)) {
- native_.addListener(DATA_CONTROL_MANAGER_LISTENER_ID, this.changeEvent);
- }
- }
- if (DataType.SQL === type) {
- this._SQLDataControlCbMap[++this.lastListenerId] = {'providerId': providerId,
- 'dataId': dataId,
- 'changeCallback': changeCallback,
- 'realWatchId': _realWatchId};
- } else {
- this._MAPDataControlCbMap[++this.lastListenerId] = {'providerId': providerId,
- 'dataId': dataId,
- 'changeCallback': changeCallback,
- 'realWatchId': _realWatchId};
- }
-
- return this.lastListenerId;
- };
-
- _DataControlListenerManager.prototype.removeChangeListener = function(type, providerId, dataId, listenerId) {
- var _realWatchId = 0;
- if (DataType.SQL === type &&
- !type_.isUndefined(this._SQLDataControlCbMap[listenerId])) {
- _realWatchId = this._SQLDataControlCbMap[listenerId].realWatchId;
- delete this._SQLDataControlCbMap[listenerId];
- for (var i in this._SQLDataControlCbMap) {
- if (this._SQLDataControlCbMap.hasOwnProperty(i) &&
- this._SQLDataControlCbMap[i].realWatchId === _realWatchId) {
- return;
+ if (!_realWatchId) {
+ var callback = function(result) {
+ if (native_.isFailure(result)) {
+ native_.callIfPossible(errorCallback, native_.getErrorObject(result));
+ return;
+ }
+ };
+ var result = native_.call(
+ 'DataControlConsumerObject_addChangeListener',
+ {
+ providerId: providerId,
+ dataId: dataId,
+ type: type
+ },
+ callback
+ );
+
+ if (native_.isFailure(result)) {
+ throw native_.getErrorObject(result);
+ } else {
+ result = native_.getResultObject(result);
+ _realWatchId = converter_.toLong(result.watchId, true);
+ }
+ if (
+ type_.isEmptyObject(this._SQLDataControlCbMap) &&
+ type_.isEmptyObject(this._MAPDataControlCbMap)
+ ) {
+ native_.addListener(DATA_CONTROL_MANAGER_LISTENER_ID, this.changeEvent);
+ }
}
- }
- } else if (DataType.MAP === type &&
- !type_.isUndefined(this._MAPDataControlCbMap[listenerId])) {
- _realWatchId = this._MAPDataControlCbMap[listenerId].realWatchId;
- delete this._MAPDataControlCbMap[listenerId];
- for (var i in this._MAPDataControlCbMap) {
- if (this._MAPDataControlCbMap.hasOwnProperty(i) &&
- this._MAPDataControlCbMap[i].realWatchId === _realWatchId) {
- return;
+
+ if (DataType.SQL === type) {
+ this._SQLDataControlCbMap[++this.lastListenerId] = {
+ providerId: providerId,
+ dataId: dataId,
+ changeCallback: changeCallback,
+ realWatchId: _realWatchId
+ };
+ } else {
+ this._MAPDataControlCbMap[++this.lastListenerId] = {
+ providerId: providerId,
+ dataId: dataId,
+ changeCallback: changeCallback,
+ realWatchId: _realWatchId
+ };
}
- }
- } else {
- console.log('Type invalid or listener was not added');
- return;
- }
- if (0 != _realWatchId) {
- native_.call('DataControlConsumerObject_removeChangeListener',{
- watchId: _realWatchId,
- });
+ return this.lastListenerId;
+ };
+
+ _DataControlListenerManager.prototype.removeChangeListener = function(
+ type,
+ providerId,
+ dataId,
+ listenerId
+ ) {
+ var _realWatchId = 0;
+ if (
+ DataType.SQL === type &&
+ !type_.isUndefined(this._SQLDataControlCbMap[listenerId])
+ ) {
+ _realWatchId = this._SQLDataControlCbMap[listenerId].realWatchId;
+ delete this._SQLDataControlCbMap[listenerId];
+ for (var i in this._SQLDataControlCbMap) {
+ if (
+ this._SQLDataControlCbMap.hasOwnProperty(i) &&
+ this._SQLDataControlCbMap[i].realWatchId === _realWatchId
+ ) {
+ return;
+ }
+ }
+ } else if (
+ DataType.MAP === type &&
+ !type_.isUndefined(this._MAPDataControlCbMap[listenerId])
+ ) {
+ _realWatchId = this._MAPDataControlCbMap[listenerId].realWatchId;
+ delete this._MAPDataControlCbMap[listenerId];
+ for (var i in this._MAPDataControlCbMap) {
+ if (
+ this._MAPDataControlCbMap.hasOwnProperty(i) &&
+ this._MAPDataControlCbMap[i].realWatchId === _realWatchId
+ ) {
+ return;
+ }
+ }
+ } else {
+ console.log('Type invalid or listener was not added');
+ return;
+ }
- if (type_.isEmptyObject(this._SQLDataControlCbMap) &&
- type_.isEmptyObject(this._MAPDataControlCbMap)) {
- native_.removeListener(DATA_CONTROL_MANAGER_LISTENER_ID);
- }
- }
- };
+ if (0 != _realWatchId) {
+ native_.call('DataControlConsumerObject_removeChangeListener', {
+ watchId: _realWatchId
+ });
- return _DataControlListenerManager;
+ if (
+ type_.isEmptyObject(this._SQLDataControlCbMap) &&
+ type_.isEmptyObject(this._MAPDataControlCbMap)
+ ) {
+ native_.removeListener(DATA_CONTROL_MANAGER_LISTENER_ID);
+ }
+ }
+ };
+ return _DataControlListenerManager;
})();
var listenersManager = new DataControlListenersManager();
function SetReadOnlyProperty(obj, n, v) {
- Object.defineProperty(obj, n, {value: v, writable: false});
+ Object.defineProperty(obj, n, { value: v, writable: false });
}
function DataControlManager() {
- // constructor of DataControlManager
+ // constructor of DataControlManager
}
var privUtils_ = xwalk.utils;
var getDataControlConsumer = function(providerId, dataId, type) {
- privUtils_.checkPrivilegeAccess(privUtils_.privilege.DATACONTROL_CONSUMER);
- var args = validator_.validateArgs(arguments, [
- {'name': 'providerId', 'type': types_.STRING},
- {'name': 'dataId', 'type': types_.STRING},
- {'name': 'type', 'type': types_.ENUM, 'values': [DataType.SQL, DataType.MAP]}
- ]);
-
- var returnObject = null;
- if (DataType.SQL === type) {
- returnObject = new SQLDataControlConsumer();
- } else if (DataType.MAP == type) {
- returnObject = new MappedDataControlConsumer();
- }
-
- SetReadOnlyProperty(returnObject, 'type', args.type); // read only property
- SetReadOnlyProperty(returnObject, 'providerId', args.providerId); // read only property
- SetReadOnlyProperty(returnObject, 'dataId', args.dataId); // read only property
-
- return returnObject;
-};
+ privUtils_.checkPrivilegeAccess(privUtils_.privilege.DATACONTROL_CONSUMER);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'providerId', type: types_.STRING },
+ { name: 'dataId', type: types_.STRING },
+ { name: 'type', type: types_.ENUM, values: [DataType.SQL, DataType.MAP] }
+ ]);
+
+ var returnObject = null;
+ if (DataType.SQL === type) {
+ returnObject = new SQLDataControlConsumer();
+ } else if (DataType.MAP == type) {
+ returnObject = new MappedDataControlConsumer();
+ }
+
+ SetReadOnlyProperty(returnObject, 'type', args.type); // read only property
+ SetReadOnlyProperty(returnObject, 'providerId', args.providerId); // read only
+ // property
+ SetReadOnlyProperty(returnObject, 'dataId', args.dataId); // read only property
+ return returnObject;
+};
DataControlManager.prototype.getDataControlConsumer = function(providerId, dataId, type) {
- return getDataControlConsumer.apply(null, arguments);
+ return getDataControlConsumer.apply(null, arguments);
};
function DataControlConsumerObject() {
- // constructor of DataControlConsumerObject
+ // constructor of DataControlConsumerObject
}
DataControlConsumerObject.prototype.addChangeListener = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'dataChangeCallback', 'type': types_.FUNCTION, optional: false,
- nullable: false},
- {'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true}
- ]);
-
- var type = DataType.SQL;
- if (this instanceof MappedDataControlConsumer) {
- type = DataType.MAP;
- }
-
- return listenersManager.addChangeListener(type, this.providerId, this.dataId,
- args.dataChangeCallback, args.errorCallback);
+ var args = validator_.validateArgs(arguments, [
+ {
+ name: 'dataChangeCallback',
+ type: types_.FUNCTION,
+ optional: false,
+ nullable: false
+ },
+ { name: 'errorCallback', type: types_.FUNCTION, optional: true, nullable: true }
+ ]);
+
+ var type = DataType.SQL;
+ if (this instanceof MappedDataControlConsumer) {
+ type = DataType.MAP;
+ }
+
+ return listenersManager.addChangeListener(
+ type,
+ this.providerId,
+ this.dataId,
+ args.dataChangeCallback,
+ args.errorCallback
+ );
};
DataControlConsumerObject.prototype.removeChangeListener = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'watchId', 'type': types_.LONG}
- ]);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'watchId', type: types_.LONG }
+ ]);
- var type = DataType.SQL;
- if (this instanceof MappedDataControlConsumer) {
- type = DataType.MAP;
- }
+ var type = DataType.SQL;
+ if (this instanceof MappedDataControlConsumer) {
+ type = DataType.MAP;
+ }
- listenersManager.removeChangeListener(type, this.providerId, this.dataId, args.watchId);
+ listenersManager.removeChangeListener(
+ type,
+ this.providerId,
+ this.dataId,
+ args.watchId
+ );
};
function SQLDataControlConsumer() {
- // constructor of SQLDataControlConsumer
+ // constructor of SQLDataControlConsumer
}
SQLDataControlConsumer.prototype = new DataControlConsumerObject();
SQLDataControlConsumer.prototype.constructor = SQLDataControlConsumer;
SQLDataControlConsumer.prototype.insert = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'reqId', 'type': types_.LONG},
- {'name': 'insertionData', 'type': types_.DICTIONARY},
- {'name': 'successCallback', 'type': types_.FUNCTION, optional: true, nullable: true},
- {'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true}
- ]);
-
- // doing conversion of all elements to string
- var ins = validator_.validateArgs([args.insertionData.columns, args.insertionData.values], [
- {name : 'columns', type : types_.ARRAY, values : types_.STRING},
- {name : 'values', type : types_.ARRAY, values : types_.STRING}
- ]);
-
- var nativeParam = {
- 'providerId': this.providerId,
- 'dataId': this.dataId,
- 'reqId': args.reqId,
- 'insertionData': args.insertionData
- };
-
- var syncResult =
- native_.call('SQLDataControlConsumer_insert', nativeParam, function(result) {
- if (result.status == 'success') {
- if (args.successCallback) {
- args.successCallback(result['requestId'], result['result']);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'reqId', type: types_.LONG },
+ { name: 'insertionData', type: types_.DICTIONARY },
+ {
+ name: 'successCallback',
+ type: types_.FUNCTION,
+ optional: true,
+ nullable: true
+ },
+ { name: 'errorCallback', type: types_.FUNCTION, optional: true, nullable: true }
+ ]);
+
+ // doing conversion of all elements to string
+ var ins = validator_.validateArgs(
+ [args.insertionData.columns, args.insertionData.values],
+ [
+ { name: 'columns', type: types_.ARRAY, values: types_.STRING },
+ { name: 'values', type: types_.ARRAY, values: types_.STRING }
+ ]
+ );
+
+ var nativeParam = {
+ providerId: this.providerId,
+ dataId: this.dataId,
+ reqId: args.reqId,
+ insertionData: args.insertionData
+ };
+
+ var syncResult = native_.call('SQLDataControlConsumer_insert', nativeParam, function(
+ result
+ ) {
+ if (result.status == 'success') {
+ if (args.successCallback) {
+ args.successCallback(result['requestId'], result['result']);
+ }
}
- }
- if (result.status == 'error') {
- if (args.errorCallback) {
- var err = result['result'];
- var e = new WebAPIException(err.name, err.message);
- args.errorCallback(result['requestId'], e);
+ if (result.status == 'error') {
+ if (args.errorCallback) {
+ var err = result['result'];
+ var e = new WebAPIException(err.name, err.message);
+ args.errorCallback(result['requestId'], e);
+ }
}
- }
});
- if (native_.isFailure(syncResult)) {
- throw native_.getErrorObject(syncResult);
- }
+ if (native_.isFailure(syncResult)) {
+ throw native_.getErrorObject(syncResult);
+ }
};
SQLDataControlConsumer.prototype.update = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'reqId', 'type': types_.LONG},
- {'name': 'updateData', 'type': types_.DICTIONARY},
- {'name': 'where', 'type': types_.STRING},
- {'name': 'successCallback', 'type': types_.FUNCTION, optional: true, nullable: true},
- {'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true}
- ]);
-
- var nativeParam = {
- 'providerId': this.providerId,
- 'dataId': this.dataId,
- 'reqId': args.reqId,
- 'where': args.where,
- 'updateData': args.updateData
- };
-
- var syncResult =
- native_.call('SQLDataControlConsumer_update', nativeParam, function(result) {
- if (result.status == 'success') {
- if (args.successCallback) {
- args.successCallback(result['requestId']);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'reqId', type: types_.LONG },
+ { name: 'updateData', type: types_.DICTIONARY },
+ { name: 'where', type: types_.STRING },
+ {
+ name: 'successCallback',
+ type: types_.FUNCTION,
+ optional: true,
+ nullable: true
+ },
+ { name: 'errorCallback', type: types_.FUNCTION, optional: true, nullable: true }
+ ]);
+
+ var nativeParam = {
+ providerId: this.providerId,
+ dataId: this.dataId,
+ reqId: args.reqId,
+ where: args.where,
+ updateData: args.updateData
+ };
+
+ var syncResult = native_.call('SQLDataControlConsumer_update', nativeParam, function(
+ result
+ ) {
+ if (result.status == 'success') {
+ if (args.successCallback) {
+ args.successCallback(result['requestId']);
+ }
}
- }
- if (result.status == 'error') {
- if (args.errorCallback) {
- var err = result['result'];
- var e = new WebAPIException(err.name, err.message);
- args.errorCallback(result['requestId'], e);
+ if (result.status == 'error') {
+ if (args.errorCallback) {
+ var err = result['result'];
+ var e = new WebAPIException(err.name, err.message);
+ args.errorCallback(result['requestId'], e);
+ }
}
- }
});
- if (native_.isFailure(syncResult)) {
- throw native_.getErrorObject(syncResult);
- }
+ if (native_.isFailure(syncResult)) {
+ throw native_.getErrorObject(syncResult);
+ }
};
SQLDataControlConsumer.prototype.remove = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'reqId', 'type': types_.LONG},
- {'name': 'where', 'type': types_.STRING},
- {'name': 'successCallback', 'type': types_.FUNCTION, optional: true, nullable: true},
- {'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true}
- ]);
-
- var nativeParam = {
- 'providerId': this.providerId,
- 'dataId': this.dataId,
- 'reqId': args.reqId,
- 'where': args.where
- };
-
- var syncResult =
- native_.call('SQLDataControlConsumer_remove', nativeParam, function(result) {
- if (result.status == 'success') {
- if (args.successCallback) {
- args.successCallback(result['requestId']);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'reqId', type: types_.LONG },
+ { name: 'where', type: types_.STRING },
+ {
+ name: 'successCallback',
+ type: types_.FUNCTION,
+ optional: true,
+ nullable: true
+ },
+ { name: 'errorCallback', type: types_.FUNCTION, optional: true, nullable: true }
+ ]);
+
+ var nativeParam = {
+ providerId: this.providerId,
+ dataId: this.dataId,
+ reqId: args.reqId,
+ where: args.where
+ };
+
+ var syncResult = native_.call('SQLDataControlConsumer_remove', nativeParam, function(
+ result
+ ) {
+ if (result.status == 'success') {
+ if (args.successCallback) {
+ args.successCallback(result['requestId']);
+ }
}
- }
- if (result.status == 'error') {
- if (args.errorCallback) {
- var err = result['result'];
- var e = new WebAPIException(err.name, err.message);
- args.errorCallback(result['requestId'], e);
+ if (result.status == 'error') {
+ if (args.errorCallback) {
+ var err = result['result'];
+ var e = new WebAPIException(err.name, err.message);
+ args.errorCallback(result['requestId'], e);
+ }
}
- }
});
- if (native_.isFailure(syncResult)) {
- throw native_.getErrorObject(syncResult);
- }
-
+ if (native_.isFailure(syncResult)) {
+ throw native_.getErrorObject(syncResult);
+ }
};
SQLDataControlConsumer.prototype.select = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'reqId', 'type': types_.LONG},
- {'name': 'columns', 'type': types_.ARRAY},
- {'name': 'where', 'type': types_.STRING},
- {'name': 'successCallback', 'type': types_.FUNCTION},
- {'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true},
- {'name': 'page', 'type': types_.LONG, optional: true, nullable: true},
- {'name': 'maxNumberPerPage', 'type': types_.LONG, optional: true, nullable: true},
- {'name': 'order', 'type': types_.STRING, optional: true, nullable: true}
- ]);
-
- var nativeParam = {
- 'providerId': this.providerId,
- 'dataId': this.dataId,
- 'reqId': args.reqId,
- 'columns': args.columns,
- 'where': args.where
- };
- if (args['page']) {
- nativeParam['page'] = args.page;
- }
- if (args['maxNumberPerPage']) {
- nativeParam['maxNumberPerPage'] = args.maxNumberPerPage;
- }
- if (args['order']) {
- nativeParam['order'] = args.order;
- }
-
- var syncResult =
- native_.call('SQLDataControlConsumer_select', nativeParam, function(result) {
- if (result.status == 'success') {
- args.successCallback(result['result'], result['requestId']);
- }
- if (result.status == 'error') {
- if (args.errorCallback) {
- var err = result['result'];
- var e = new WebAPIException(err.name, err.message);
- args.errorCallback(result['requestId'], e);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'reqId', type: types_.LONG },
+ { name: 'columns', type: types_.ARRAY },
+ { name: 'where', type: types_.STRING },
+ { name: 'successCallback', type: types_.FUNCTION },
+ { name: 'errorCallback', type: types_.FUNCTION, optional: true, nullable: true },
+ { name: 'page', type: types_.LONG, optional: true, nullable: true },
+ { name: 'maxNumberPerPage', type: types_.LONG, optional: true, nullable: true },
+ { name: 'order', type: types_.STRING, optional: true, nullable: true }
+ ]);
+
+ var nativeParam = {
+ providerId: this.providerId,
+ dataId: this.dataId,
+ reqId: args.reqId,
+ columns: args.columns,
+ where: args.where
+ };
+ if (args['page']) {
+ nativeParam['page'] = args.page;
+ }
+ if (args['maxNumberPerPage']) {
+ nativeParam['maxNumberPerPage'] = args.maxNumberPerPage;
+ }
+ if (args['order']) {
+ nativeParam['order'] = args.order;
+ }
+
+ var syncResult = native_.call('SQLDataControlConsumer_select', nativeParam, function(
+ result
+ ) {
+ if (result.status == 'success') {
+ args.successCallback(result['result'], result['requestId']);
+ }
+ if (result.status == 'error') {
+ if (args.errorCallback) {
+ var err = result['result'];
+ var e = new WebAPIException(err.name, err.message);
+ args.errorCallback(result['requestId'], e);
+ }
}
- }
});
- if (native_.isFailure(syncResult)) {
- throw native_.getErrorObject(syncResult);
- }
+ if (native_.isFailure(syncResult)) {
+ throw native_.getErrorObject(syncResult);
+ }
};
-
function MappedDataControlConsumer() {
- // constructor of MappedDataControlConsumer
+ // constructor of MappedDataControlConsumer
}
MappedDataControlConsumer.prototype = new DataControlConsumerObject();
MappedDataControlConsumer.prototype.constructor = MappedDataControlConsumer;
MappedDataControlConsumer.prototype.addValue = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'reqId', 'type': types_.LONG},
- {'name': 'key', 'type': types_.STRING},
- {'name': 'value', 'type': types_.STRING},
- {'name': 'successCallback', 'type': types_.FUNCTION, optional: true, nullable: true},
- {'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true}
- ]);
-
- var nativeParam = {
- 'providerId': this.providerId,
- 'dataId': this.dataId,
- 'reqId': args.reqId,
- 'key': args.key,
- 'value': args.value
- };
-
- var syncResult =
- native_.call('MappedDataControlConsumer_addValue', nativeParam, function(result) {
- if (result.status == 'success') {
- if (args.successCallback) {
- args.successCallback(result['requestId']);
- }
- }
- if (result.status == 'error') {
- if (args.errorCallback) {
- var err = result['result'];
- var e = new WebAPIException(err.name, err.message);
- args.errorCallback(result['requestId'], e);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'reqId', type: types_.LONG },
+ { name: 'key', type: types_.STRING },
+ { name: 'value', type: types_.STRING },
+ {
+ name: 'successCallback',
+ type: types_.FUNCTION,
+ optional: true,
+ nullable: true
+ },
+ { name: 'errorCallback', type: types_.FUNCTION, optional: true, nullable: true }
+ ]);
+
+ var nativeParam = {
+ providerId: this.providerId,
+ dataId: this.dataId,
+ reqId: args.reqId,
+ key: args.key,
+ value: args.value
+ };
+
+ var syncResult = native_.call(
+ 'MappedDataControlConsumer_addValue',
+ nativeParam,
+ function(result) {
+ if (result.status == 'success') {
+ if (args.successCallback) {
+ args.successCallback(result['requestId']);
+ }
+ }
+ if (result.status == 'error') {
+ if (args.errorCallback) {
+ var err = result['result'];
+ var e = new WebAPIException(err.name, err.message);
+ args.errorCallback(result['requestId'], e);
+ }
+ }
}
- }
- });
-
- if (native_.isFailure(syncResult)) {
- throw native_.getErrorObject(syncResult);
- }
+ );
+ if (native_.isFailure(syncResult)) {
+ throw native_.getErrorObject(syncResult);
+ }
};
MappedDataControlConsumer.prototype.removeValue = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'reqId', 'type': types_.LONG},
- {'name': 'key', 'type': types_.STRING},
- {'name': 'value', 'type': types_.STRING},
- {'name': 'successCallback', 'type': types_.FUNCTION},
- {'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true}
- ]);
-
- var nativeParam = {
- 'providerId': this.providerId,
- 'dataId': this.dataId,
- 'reqId': args.reqId,
- 'key': args.key,
- 'value': args.value
- };
-
- var syncResult =
- native_.call('MappedDataControlConsumer_removeValue', nativeParam, function(result) {
- if (result.status == 'success') {
- args.successCallback(result['requestId']);
- }
- if (result.status == 'error') {
- if (args.errorCallback) {
- var err = result['result'];
- var e = new WebAPIException(err.name, err.message);
- args.errorCallback(result['requestId'], e);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'reqId', type: types_.LONG },
+ { name: 'key', type: types_.STRING },
+ { name: 'value', type: types_.STRING },
+ { name: 'successCallback', type: types_.FUNCTION },
+ { name: 'errorCallback', type: types_.FUNCTION, optional: true, nullable: true }
+ ]);
+
+ var nativeParam = {
+ providerId: this.providerId,
+ dataId: this.dataId,
+ reqId: args.reqId,
+ key: args.key,
+ value: args.value
+ };
+
+ var syncResult = native_.call(
+ 'MappedDataControlConsumer_removeValue',
+ nativeParam,
+ function(result) {
+ if (result.status == 'success') {
+ args.successCallback(result['requestId']);
+ }
+ if (result.status == 'error') {
+ if (args.errorCallback) {
+ var err = result['result'];
+ var e = new WebAPIException(err.name, err.message);
+ args.errorCallback(result['requestId'], e);
+ }
+ }
}
- }
- });
-
- if (native_.isFailure(syncResult)) {
- throw native_.getErrorObject(syncResult);
- }
+ );
+ if (native_.isFailure(syncResult)) {
+ throw native_.getErrorObject(syncResult);
+ }
};
MappedDataControlConsumer.prototype.getValue = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'reqId', 'type': types_.LONG},
- {'name': 'key', 'type': types_.STRING},
- {'name': 'successCallback', 'type': types_.FUNCTION},
- {'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true}
- ]);
-
- var nativeParam = {
- 'providerId': this.providerId,
- 'dataId': this.dataId,
- 'reqId': args.reqId,
- 'key': args.key
- };
-
- var syncResult =
- native_.call('MappedDataControlConsumer_getValue', nativeParam, function(result) {
- if (result.status == 'success') {
- args.successCallback(result['result'], result['requestId']);
- }
- if (result.status == 'error') {
- if (args.errorCallback) {
- var err = result['result'];
- var e = new WebAPIException(err.name, err.message);
- args.errorCallback(result['requestId'], e);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'reqId', type: types_.LONG },
+ { name: 'key', type: types_.STRING },
+ { name: 'successCallback', type: types_.FUNCTION },
+ { name: 'errorCallback', type: types_.FUNCTION, optional: true, nullable: true }
+ ]);
+
+ var nativeParam = {
+ providerId: this.providerId,
+ dataId: this.dataId,
+ reqId: args.reqId,
+ key: args.key
+ };
+
+ var syncResult = native_.call(
+ 'MappedDataControlConsumer_getValue',
+ nativeParam,
+ function(result) {
+ if (result.status == 'success') {
+ args.successCallback(result['result'], result['requestId']);
+ }
+ if (result.status == 'error') {
+ if (args.errorCallback) {
+ var err = result['result'];
+ var e = new WebAPIException(err.name, err.message);
+ args.errorCallback(result['requestId'], e);
+ }
+ }
}
- }
- });
-
- if (native_.isFailure(syncResult)) {
- throw native_.getErrorObject(syncResult);
- }
+ );
+ if (native_.isFailure(syncResult)) {
+ throw native_.getErrorObject(syncResult);
+ }
};
MappedDataControlConsumer.prototype.updateValue = function() {
- var args = validator_.validateArgs(arguments, [
- {'name': 'reqId', 'type': types_.LONG},
- {'name': 'key', 'type': types_.STRING},
- {'name': 'oldValue', 'type': types_.STRING},
- {'name': 'newValue', 'type': types_.STRING},
- {'name': 'successCallback', 'type': types_.FUNCTION},
- {'name': 'errorCallback', 'type': types_.FUNCTION, optional: true, nullable: true}
- ]);
-
- var nativeParam = {
- 'providerId': this.providerId,
- 'dataId': this.dataId,
- 'reqId': args.reqId,
- 'key': args.key,
- 'oldValue': args.oldValue,
- 'newValue': args.newValue
- };
-
- var syncResult =
- native_.call('MappedDataControlConsumer_updateValue', nativeParam, function(result) {
- if (result.status == 'success') {
- args.successCallback(result['requestId']);
- }
- if (result.status == 'error') {
- if (args.errorCallback) {
- var err = result['result'];
- var e = new WebAPIException(err.name, err.message);
- args.errorCallback(result['requestId'], e);
+ var args = validator_.validateArgs(arguments, [
+ { name: 'reqId', type: types_.LONG },
+ { name: 'key', type: types_.STRING },
+ { name: 'oldValue', type: types_.STRING },
+ { name: 'newValue', type: types_.STRING },
+ { name: 'successCallback', type: types_.FUNCTION },
+ { name: 'errorCallback', type: types_.FUNCTION, optional: true, nullable: true }
+ ]);
+
+ var nativeParam = {
+ providerId: this.providerId,
+ dataId: this.dataId,
+ reqId: args.reqId,
+ key: args.key,
+ oldValue: args.oldValue,
+ newValue: args.newValue
+ };
+
+ var syncResult = native_.call(
+ 'MappedDataControlConsumer_updateValue',
+ nativeParam,
+ function(result) {
+ if (result.status == 'success') {
+ args.successCallback(result['requestId']);
+ }
+ if (result.status == 'error') {
+ if (args.errorCallback) {
+ var err = result['result'];
+ var e = new WebAPIException(err.name, err.message);
+ args.errorCallback(result['requestId'], e);
+ }
+ }
}
- }
- });
-
- if (native_.isFailure(syncResult)) {
- throw native_.getErrorObject(syncResult);
- }
+ );
+ if (native_.isFailure(syncResult)) {
+ throw native_.getErrorObject(syncResult);
+ }
};
exports = new DataControlManager();
-
projects / platform / core / api / webapi-plugins.git / blobdiff