yunkong2/yunkong2.simple-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Initial commit

Browse Source
This commit is contained in:
zhongjin
2018-07-21 15:01:25 +08:00
commit f645903d19
22 changed files with 4728 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

728
test/lib/setup.js Normal file
View File

@@ -0,0 +1,728 @@
/* jshint -W097 */// jshint strict:false
/*jslint node: true */
// check if tmp directory exists
var fs = require('fs');
var path = require('path');
var child_process = require('child_process');
var rootDir = path.normalize(__dirname + '/../../');
var pkg = require(rootDir + 'package.json');
var debug = typeof v8debug === 'object';
pkg.main = pkg.main || 'main.js';
var adapterName = path.normalize(rootDir).replace(/\\/g, '/').split('/');
adapterName = adapterName[adapterName.length - 2];
var adapterStarted = false;
function getAppName() {
var parts = __dirname.replace(/\\/g, '/').split('/');
return parts[parts.length - 3].split('.')[0];
}
var appName = getAppName().toLowerCase();
var objects;
var states;
var pid = null;
function copyFileSync(source, target) {
var targetFile = target;
//if target is a directory a new file with the same name will be created
if (fs.existsSync(target)) {
if ( fs.lstatSync( target ).isDirectory() ) {
targetFile = path.join(target, path.basename(source));
}
}
try {
fs.writeFileSync(targetFile, fs.readFileSync(source));
}
catch (err) {
console.log("file copy error: " +source +" -> " + targetFile + " (error ignored)");
}
}
function copyFolderRecursiveSync(source, target, ignore) {
var files = [];
var base = path.basename(source);
if (base === adapterName) {
base = pkg.name;
}
//check if folder needs to be created or integrated
var targetFolder = path.join(target, base);
if (!fs.existsSync(targetFolder)) {
fs.mkdirSync(targetFolder);
}
//copy
if (fs.lstatSync(source).isDirectory()) {
files = fs.readdirSync(source);
files.forEach(function (file) {
if (ignore && ignore.indexOf(file) !== -1) {
return;
}
var curSource = path.join(source, file);
var curTarget = path.join(targetFolder, file);
if (fs.lstatSync(curSource).isDirectory()) {
// ignore grunt files
if (file.indexOf('grunt') !== -1) return;
if (file === 'chai') return;
if (file === 'mocha') return;
copyFolderRecursiveSync(curSource, targetFolder, ignore);
} else {
copyFileSync(curSource, curTarget);
}
});
}
}
if (!fs.existsSync(rootDir + 'tmp')) {
fs.mkdirSync(rootDir + 'tmp');
}
function storeOriginalFiles() {
console.log('Store original files...');
var dataDir = rootDir + 'tmp/' + appName + '-data/';
var f = fs.readFileSync(dataDir + 'objects.json');
var objects = JSON.parse(f.toString());
if (objects['system.adapter.admin.0'] && objects['system.adapter.admin.0'].common) {
objects['system.adapter.admin.0'].common.enabled = false;
}
if (objects['system.adapter.admin.1'] && objects['system.adapter.admin.1'].common) {
objects['system.adapter.admin.1'].common.enabled = false;
}
fs.writeFileSync(dataDir + 'objects.json.original', JSON.stringify(objects));
try {
f = fs.readFileSync(dataDir + 'states.json');
fs.writeFileSync(dataDir + 'states.json.original', f);
}
catch (err) {
console.log('no states.json found - ignore');
}
}
function restoreOriginalFiles() {
console.log('restoreOriginalFiles...');
var dataDir = rootDir + 'tmp/' + appName + '-data/';
var f = fs.readFileSync(dataDir + 'objects.json.original');
fs.writeFileSync(dataDir + 'objects.json', f);
try {
f = fs.readFileSync(dataDir + 'states.json.original');
fs.writeFileSync(dataDir + 'states.json', f);
}
catch (err) {
console.log('no states.json.original found - ignore');
}
}
function checkIsAdapterInstalled(cb, counter, customName) {
customName = customName || pkg.name.split('.').pop();
counter = counter || 0;
var dataDir = rootDir + 'tmp/' + appName + '-data/';
console.log('checkIsAdapterInstalled...');
try {
var f = fs.readFileSync(dataDir + 'objects.json');
var objects = JSON.parse(f.toString());
if (objects['system.adapter.' + customName + '.0']) {
console.log('checkIsAdapterInstalled: ready!');
setTimeout(function () {
if (cb) cb();
}, 100);
return;
} else {
console.warn('checkIsAdapterInstalled: still not ready');
}
} catch (err) {
}
if (counter > 20) {
console.error('checkIsAdapterInstalled: Cannot install!');
if (cb) cb('Cannot install');
} else {
console.log('checkIsAdapterInstalled: wait...');
setTimeout(function() {
checkIsAdapterInstalled(cb, counter + 1);
}, 1000);
}
}
function checkIsControllerInstalled(cb, counter) {
counter = counter || 0;
var dataDir = rootDir + 'tmp/' + appName + '-data/';
console.log('checkIsControllerInstalled...');
try {
var f = fs.readFileSync(dataDir + 'objects.json');
var objects = JSON.parse(f.toString());
if (objects['system.adapter.admin.0']) {
console.log('checkIsControllerInstalled: installed!');
setTimeout(function () {
if (cb) cb();
}, 100);
return;
}
} catch (err) {
}
if (counter > 20) {
console.log('checkIsControllerInstalled: Cannot install!');
if (cb) cb('Cannot install');
} else {
console.log('checkIsControllerInstalled: wait...');
setTimeout(function() {
checkIsControllerInstalled(cb, counter + 1);
}, 1000);
}
}
function installAdapter(customName, cb) {
if (typeof customName === 'function') {
cb = customName;
customName = null;
}
customName = customName || pkg.name.split('.').pop();
console.log('Install adapter...');
var startFile = 'node_modules/' + appName + '.js-controller/' + appName + '.js';
// make first install
if (debug) {
child_process.execSync('node ' + startFile + ' add ' + customName + ' --enabled false', {
cwd: rootDir + 'tmp',
stdio: [0, 1, 2]
});
checkIsAdapterInstalled(function (error) {
if (error) console.error(error);
console.log('Adapter installed.');
if (cb) cb();
});
} else {
// add controller
var _pid = child_process.fork(startFile, ['add', customName, '--enabled', 'false'], {
cwd: rootDir + 'tmp',
stdio: [0, 1, 2, 'ipc']
});
waitForEnd(_pid, function () {
checkIsAdapterInstalled(function (error) {
if (error) console.error(error);
console.log('Adapter installed.');
if (cb) cb();
});
});
}
}
function waitForEnd(_pid, cb) {
if (!_pid) {
cb(-1, -1);
return;
}
_pid.on('exit', function (code, signal) {
if (_pid) {
_pid = null;
cb(code, signal);
}
});
_pid.on('close', function (code, signal) {
if (_pid) {
_pid = null;
cb(code, signal);
}
});
}
function installJsController(cb) {
console.log('installJsController...');
if (!fs.existsSync(rootDir + 'tmp/node_modules/' + appName + '.js-controller') ||
!fs.existsSync(rootDir + 'tmp/' + appName + '-data')) {
// try to detect appName.js-controller in node_modules/appName.js-controller
// travis CI installs js-controller into node_modules
if (fs.existsSync(rootDir + 'node_modules/' + appName + '.js-controller')) {
console.log('installJsController: no js-controller => copy it from "' + rootDir + 'node_modules/' + appName + '.js-controller"');
// copy all
// stop controller
console.log('Stop controller if running...');
var _pid;
if (debug) {
// start controller
_pid = child_process.exec('node ' + appName + '.js stop', {
cwd: rootDir + 'node_modules/' + appName + '.js-controller',
stdio: [0, 1, 2]
});
} else {
_pid = child_process.fork(appName + '.js', ['stop'], {
cwd: rootDir + 'node_modules/' + appName + '.js-controller',
stdio: [0, 1, 2, 'ipc']
});
}
waitForEnd(_pid, function () {
// copy all files into
if (!fs.existsSync(rootDir + 'tmp')) fs.mkdirSync(rootDir + 'tmp');
if (!fs.existsSync(rootDir + 'tmp/node_modules')) fs.mkdirSync(rootDir + 'tmp/node_modules');
if (!fs.existsSync(rootDir + 'tmp/node_modules/' + appName + '.js-controller')){
console.log('Copy js-controller...');
copyFolderRecursiveSync(rootDir + 'node_modules/' + appName + '.js-controller', rootDir + 'tmp/node_modules/');
}
console.log('Setup js-controller...');
var __pid;
if (debug) {
// start controller
_pid = child_process.exec('node ' + appName + '.js setup first --console', {
cwd: rootDir + 'tmp/node_modules/' + appName + '.js-controller',
stdio: [0, 1, 2]
});
} else {
__pid = child_process.fork(appName + '.js', ['setup', 'first', '--console'], {
cwd: rootDir + 'tmp/node_modules/' + appName + '.js-controller',
stdio: [0, 1, 2, 'ipc']
});
}
waitForEnd(__pid, function () {
checkIsControllerInstalled(function () {
// change ports for object and state DBs
var config = require(rootDir + 'tmp/' + appName + '-data/' + appName + '.json');
config.objects.port = 19001;
config.states.port = 19000;
fs.writeFileSync(rootDir + 'tmp/' + appName + '-data/' + appName + '.json', JSON.stringify(config, null, 2));
console.log('Setup finished.');
copyAdapterToController();
installAdapter(function () {
storeOriginalFiles();
if (cb) cb(true);
});
});
});
});
} else {
// check if port 9000 is free, else admin adapter will be added to running instance
var client = new require('net').Socket();
client.connect(9000, '127.0.0.1', function() {
console.error('Cannot initiate fisrt run of test, because one instance of application is running on this PC. Stop it and repeat.');
process.exit(0);
});
setTimeout(function () {
client.destroy();
if (!fs.existsSync(rootDir + 'tmp/node_modules/' + appName + '.js-controller')) {
console.log('installJsController: no js-controller => install from git');
child_process.execSync('npm install https://git.spacen.net/' + appName + '/' + appName + '.js-controller/tarball/master --prefix ./ --production', {
cwd: rootDir + 'tmp/',
stdio: [0, 1, 2]
});
} else {
console.log('Setup js-controller...');
var __pid;
if (debug) {
// start controller
child_process.exec('node ' + appName + '.js setup first', {
cwd: rootDir + 'tmp/node_modules/' + appName + '.js-controller',
stdio: [0, 1, 2]
});
} else {
child_process.fork(appName + '.js', ['setup', 'first'], {
cwd: rootDir + 'tmp/node_modules/' + appName + '.js-controller',
stdio: [0, 1, 2, 'ipc']
});
}
}
// let npm install admin and run setup
checkIsControllerInstalled(function () {
var _pid;
if (fs.existsSync(rootDir + 'node_modules/' + appName + '.js-controller/' + appName + '.js')) {
_pid = child_process.fork(appName + '.js', ['stop'], {
cwd: rootDir + 'node_modules/' + appName + '.js-controller',
stdio: [0, 1, 2, 'ipc']
});
}
waitForEnd(_pid, function () {
// change ports for object and state DBs
var config = require(rootDir + 'tmp/' + appName + '-data/' + appName + '.json');
config.objects.port = 19001;
config.states.port = 19000;
fs.writeFileSync(rootDir + 'tmp/' + appName + '-data/' + appName + '.json', JSON.stringify(config, null, 2));
copyAdapterToController();
installAdapter(function () {
storeOriginalFiles();
if (cb) cb(true);
});
});
});
}, 1000);
}
} else {
setTimeout(function () {
console.log('installJsController: js-controller installed');
if (cb) cb(false);
}, 0);
}
}
function copyAdapterToController() {
console.log('Copy adapter...');
// Copy adapter to tmp/node_modules/appName.adapter
copyFolderRecursiveSync(rootDir, rootDir + 'tmp/node_modules/', ['.idea', 'test', 'tmp', '.git', appName + '.js-controller']);
console.log('Adapter copied.');
}
function clearControllerLog() {
var dirPath = rootDir + 'tmp/log';
var files;
try {
if (fs.existsSync(dirPath)) {
console.log('Clear controller log...');
files = fs.readdirSync(dirPath);
} else {
console.log('Create controller log directory...');
files = [];
fs.mkdirSync(dirPath);
}
} catch(e) {
console.error('Cannot read "' + dirPath + '"');
return;
}
if (files.length > 0) {
try {
for (var i = 0; i < files.length; i++) {
var filePath = dirPath + '/' + files[i];
fs.unlinkSync(filePath);
}
console.log('Controller log cleared');
} catch (err) {
console.error('cannot clear log: ' + err);
}
}
}
function clearDB() {
var dirPath = rootDir + 'tmp/yunkong2-data/sqlite';
var files;
try {
if (fs.existsSync(dirPath)) {
console.log('Clear sqlite DB...');
files = fs.readdirSync(dirPath);
} else {
console.log('Create controller log directory...');
files = [];
fs.mkdirSync(dirPath);
}
} catch(e) {
console.error('Cannot read "' + dirPath + '"');
return;
}
if (files.length > 0) {
try {
for (var i = 0; i < files.length; i++) {
var filePath = dirPath + '/' + files[i];
fs.unlinkSync(filePath);
}
console.log('Clear sqlite DB');
} catch (err) {
console.error('cannot clear DB: ' + err);
}
}
}
function setupController(cb) {
installJsController(function (isInited) {
clearControllerLog();
clearDB();
if (!isInited) {
restoreOriginalFiles();
copyAdapterToController();
}
// read system.config object
var dataDir = rootDir + 'tmp/' + appName + '-data/';
var objs;
try {
objs = fs.readFileSync(dataDir + 'objects.json');
objs = JSON.parse(objs);
}
catch (e) {
console.log('ERROR reading/parsing system configuration. Ignore');
objs = {'system.config': {}};
}
if (!objs || !objs['system.config']) {
objs = {'system.config': {}};
}
if (cb) cb(objs['system.config']);
});
}
function startAdapter(objects, states, callback) {
if (adapterStarted) {
console.log('Adapter already started ...');
if (callback) callback(objects, states);
return;
}
adapterStarted = true;
console.log('startAdapter...');
if (fs.existsSync(rootDir + 'tmp/node_modules/' + pkg.name + '/' + pkg.main)) {
try {
if (debug) {
// start controller
pid = child_process.exec('node node_modules/' + pkg.name + '/' + pkg.main + ' --console silly', {
cwd: rootDir + 'tmp',
stdio: [0, 1, 2]
});
} else {
// start controller
pid = child_process.fork('node_modules/' + pkg.name + '/' + pkg.main, ['--console', 'silly'], {
cwd: rootDir + 'tmp',
stdio: [0, 1, 2, 'ipc']
});
}
} catch (error) {
console.error(JSON.stringify(error));
}
} else {
console.error('Cannot find: ' + rootDir + 'tmp/node_modules/' + pkg.name + '/' + pkg.main);
}
if (callback) callback(objects, states);
}
function startController(isStartAdapter, onObjectChange, onStateChange, callback) {
if (typeof isStartAdapter === 'function') {
callback = onStateChange;
onStateChange = onObjectChange;
onObjectChange = isStartAdapter;
isStartAdapter = true;
}
if (onStateChange === undefined) {
callback = onObjectChange;
onObjectChange = undefined;
}
if (pid) {
console.error('Controller is already started!');
} else {
console.log('startController...');
adapterStarted = false;
var isObjectConnected;
var isStatesConnected;
var Objects = require(rootDir + 'tmp/node_modules/' + appName + '.js-controller/lib/objects/objectsInMemServer');
objects = new Objects({
connection: {
"type" : "file",
"host" : "127.0.0.1",
"port" : 19001,
"user" : "",
"pass" : "",
"noFileCache": false,
"connectTimeout": 2000
},
logger: {
silly: function (msg) {
console.log(msg);
},
debug: function (msg) {
console.log(msg);
},
info: function (msg) {
console.log(msg);
},
warn: function (msg) {
console.warn(msg);
},
error: function (msg) {
console.error(msg);
}
},
connected: function () {
isObjectConnected = true;
if (isStatesConnected) {
console.log('startController: started!');
if (isStartAdapter) {
startAdapter(objects, states, callback);
} else {
if (callback) {
callback(objects, states);
callback = null;
}
}
}
},
change: onObjectChange
});
// Just open in memory DB itself
var States = require(rootDir + 'tmp/node_modules/' + appName + '.js-controller/lib/states/statesInMemServer');
states = new States({
connection: {
type: 'file',
host: '127.0.0.1',
port: 19000,
options: {
auth_pass: null,
retry_max_delay: 15000
}
},
logger: {
silly: function (msg) {
console.log(msg);
},
debug: function (msg) {
console.log(msg);
},
info: function (msg) {
console.log(msg);
},
warn: function (msg) {
console.log(msg);
},
error: function (msg) {
console.log(msg);
}
},
connected: function () {
isStatesConnected = true;
if (isObjectConnected) {
console.log('startController: started!!');
if (isStartAdapter) {
startAdapter(objects, states, callback);
} else {
if (callback) {
callback(objects, states);
callback = null;
}
}
}
},
change: onStateChange
});
}
}
function stopAdapter(cb) {
if (!pid) {
console.error('Controller is not running!');
if (cb) {
setTimeout(function () {
cb(false);
}, 0);
}
} else {
adapterStarted = false;
pid.on('exit', function (code, signal) {
if (pid) {
console.log('child process terminated due to receipt of signal ' + signal);
if (cb) cb();
pid = null;
}
});
pid.on('close', function (code, signal) {
if (pid) {
if (cb) cb();
pid = null;
}
});
pid.kill('SIGTERM');
}
}
function _stopController() {
if (objects) {
objects.destroy();
objects = null;
}
if (states) {
states.destroy();
states = null;
}
}
function stopController(cb) {
var timeout;
if (objects) {
console.log('Set system.adapter.' + pkg.name + '.0');
objects.setObject('system.adapter.' + pkg.name + '.0', {
common:{
enabled: false
}
});
}
stopAdapter(function () {
if (timeout) {
clearTimeout(timeout);
timeout = null;
}
_stopController();
if (cb) {
cb(true);
cb = null;
}
});
timeout = setTimeout(function () {
timeout = null;
console.log('child process NOT terminated');
_stopController();
if (cb) {
cb(false);
cb = null;
}
pid = null;
}, 5000);
}
// Setup the adapter
function setAdapterConfig(common, native, instance) {
var objects = JSON.parse(fs.readFileSync(rootDir + 'tmp/' + appName + '-data/objects.json').toString());
var id = 'system.adapter.' + adapterName.split('.').pop() + '.' + (instance || 0);
if (common) objects[id].common = common;
if (native) objects[id].native = native;
fs.writeFileSync(rootDir + 'tmp/' + appName + '-data/objects.json', JSON.stringify(objects));
}
// Read config of the adapter
function getAdapterConfig(instance) {
var objects = JSON.parse(fs.readFileSync(rootDir + 'tmp/' + appName + '-data/objects.json').toString());
var id = 'system.adapter.' + adapterName.split('.').pop() + '.' + (instance || 0);
return objects[id];
}
if (typeof module !== undefined && module.parent) {
module.exports.getAdapterConfig = getAdapterConfig;
module.exports.setAdapterConfig = setAdapterConfig;
module.exports.startController = startController;
module.exports.stopController = stopController;
module.exports.setupController = setupController;
module.exports.stopAdapter = stopAdapter;
module.exports.startAdapter = startAdapter;
module.exports.installAdapter = installAdapter;
module.exports.appName = appName;
module.exports.adapterName = adapterName;
module.exports.adapterStarted = adapterStarted;
}

460
test/testApi.js Normal file
View File

@@ -0,0 +1,460 @@
/* jshint -W097 */// jshint strict:false
/*jslint node: true */
/*jshint expr: true*/
var expect = require('chai').expect;
var setup = require(__dirname + '/lib/setup');
var request = require('request');
var objects = null;
var states = null;
process.env.NO_PROXY = '127.0.0.1';
function checkConnectionOfAdapter(cb, counter) {
counter = counter || 0;
console.log('Try check #' + counter);
if (counter > 30) {
if (cb) cb('Cannot check connection');
return;
}
states.getState('system.adapter.simple-api.0.alive', function (err, state) {
if (err) console.error(err);
if (state && state.val) {
if (cb) cb();
} else {
setTimeout(function () {
checkConnectionOfAdapter(cb, counter + 1);
}, 1000);
}
});
}
describe('Test RESTful API', function() {
before('Test RESTful API: Start js-controller', function (_done) {
this.timeout(600000); // because of first install from npm
var brokerStarted = false;
setup.adapterStarted = false;
setup.setupController(function () {
var config = setup.getAdapterConfig();
// enable adapter
config.common.enabled = true;
config.common.loglevel = 'debug';
config.native.port = 18183;
setup.setAdapterConfig(config.common, config.native);
setup.startController(function (_objects, _states) {
objects = _objects;
states = _states;
// give some time to start server
setTimeout(function () {
_done();
}, 2000);
});
});
});
it('Test adapter: Check if adapter started and create upload datapoint', function (done) {
this.timeout(60000);
checkConnectionOfAdapter(function (res) {
if (res) console.log(res);
expect(res).not.to.be.equal('Cannot check connection');
objects.setObject('javascript.0.test-string', {
common: {
name: 'test',
type: 'string',
role: 'value',
def: ''
},
native: {
},
type: 'state'
}, function (err) {
expect(err).to.be.null;
states.setState('javascript.0.test-string','', function(err) {
expect(err).to.be.null;
done();
});
});
});
});
it('Test RESTful API: get - must return value', function (done) {
request('http://127.0.0.1:18183/get/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('get/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
//{
// "val" : true,
// "ack" : true,
// "ts" : 1455009717,
// "q" : 0,
// "from" : "system.adapter.simple-api.0",
// "lc" : 1455009717,
// "expire" : 30000,
// "_id" : "system.adapter.simple-api.0.alive",
// "type" : "state",
// "common" : {
// "name" : "simple-api.0.alive",
// "type" : "boolean",
// "role" : "indicator.state"
// },
// "native" : {}
//
//}
expect(obj).to.be.ok;
expect(obj.val).to.be.true;
expect(obj.ack).to.be.true;
expect(obj.ts).to.be.ok;
//expect(obj.from).to.equal("system.adapter.simple-api.0");
expect(obj.type).to.equal("state");
expect(obj._id).to.equal("system.adapter.simple-api.0.alive");
expect(obj.common).to.be.ok;
expect(obj.native).to.be.ok;
expect(obj.common.name).to.equal("simple-api.0.alive");
expect(obj.common.role).to.equal("indicator.state");
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API: getPlainValue - must return plain value', function (done) {
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('true');
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API: set - must set value', function (done) {
request('http://127.0.0.1:18183/set/system.adapter.simple-api.0.alive?val=false', function (error, response, body) {
console.log('set/system.adapter.simple-api.0.alive?val=false => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.false;
expect(obj.id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('false');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/get/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('get/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(JSON.parse(body).val).equal(false);
expect(response.statusCode).to.equal(200);
done();
});
});
});
});
it('Test RESTful API: set - must set easy string value', function (done) {
request('http://127.0.0.1:18183/set/javascript.0.test-string?val=bla', function (error, response, body) {
console.log('set/javascript.0.test-string?val=bla => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).equal('bla');
expect(obj.id).to.equal('javascript.0.test-string');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/javascript.0.test-string', function (error, response, body) {
console.log('getPlainValue/javascript.0.test-string => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('"bla"');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/get/javascript.0.test-string', function (error, response, body) {
console.log('get/javascript.0.test-string => ' + body);
expect(error).to.be.not.ok;
expect(JSON.parse(body).val).equal('bla');
expect(response.statusCode).to.equal(200);
done();
});
});
});
});
it('Test RESTful API: set - must set encoded string value', function (done) {
request('http://127.0.0.1:18183/set/javascript.0.test-string?val=bla%26fasel%2efoo%3Dhummer+hey', function (error, response, body) {
console.log('set/javascript.0.test-string?val=bla%20fasel%2efoo => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).equal('bla&fasel.foo=hummer hey');
expect(obj.id).to.equal('javascript.0.test-string');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/javascript.0.test-string', function (error, response, body) {
console.log('getPlainValue/javascript.0.test-string => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('"bla&fasel.foo=hummer hey"');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/get/javascript.0.test-string', function (error, response, body) {
console.log('get/javascript.0.test-string => ' + body);
expect(error).to.be.not.ok;
expect(JSON.parse(body).val).equal('bla&fasel.foo=hummer hey');
expect(response.statusCode).to.equal(200);
done();
});
});
});
});
it('Test RESTful API: set - must set val', function (done) {
request('http://127.0.0.1:18183/set/system.adapter.simple-api.0.alive?val=true', function (error, response, body) {
console.log('set/system.adapter.simple-api.0.alive?val=true => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.true;
expect(obj.id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('true');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API: toggle - must toggle boolean value to false', function (done) {
request('http://127.0.0.1:18183/toggle/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('toggle/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.false;
expect(obj.id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('false');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API: toggle - must toggle boolean value to true', function (done) {
request('http://127.0.0.1:18183/toggle/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('toggle/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.true;
expect(obj.id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('true');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API: toggle - must toggle number value to 100', function (done) {
request('http://127.0.0.1:18183/toggle/system.adapter.simple-api.upload', function (error, response, body) {
console.log('toggle/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.equal(100);
expect(obj.id).to.equal('system.adapter.simple-api.upload');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.upload', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('100');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/set/system.adapter.simple-api.upload?val=49', function (error, response, body) {
console.log('set/system.adapter.simple-api.upload?val=49 => ' + body);
request('http://127.0.0.1:18183/toggle/system.adapter.simple-api.upload', function (error, response, body) {
console.log('toggle/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.equal(51);
expect(obj.id).to.equal('system.adapter.simple-api.upload');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.upload', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('51');
expect(response.statusCode).to.equal(200);
done();
});
});
});
});
});
});
it('Test RESTful API: setBulk - must set values', function (done) {
request('http://127.0.0.1:18183/setBulk?system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false', function (error, response, body) {
console.log('setBulk/?system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(50);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(obj[1].val).to.be.equal(false);
expect(obj[1].id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(50);
expect(obj[1].val).equal(false);
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API: objects - must return objects', function (done) {
request('http://127.0.0.1:18183/objects?pattern=system.adapter.*', function (error, response, body) {
console.log('objects?pattern=system.adapter.* => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj['system.adapter.simple-api.0.alive']._id).to.be.ok;
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API: objects - must return objects', function (done) {
request('http://127.0.0.1:18183/objects?pattern=system.adapter.*&type=instance', function (error, response, body) {
console.log('objects?pattern=system.adapter.* => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj['system.adapter.simple-api.0']._id).to.be.ok;
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API: states - must return states', function (done) {
request('http://127.0.0.1:18183/states?pattern=system.adapter.*', function (error, response, body) {
console.log('states?pattern=system.adapter.* => ' + body);
expect(error).to.be.not.ok;
var states = JSON.parse(body);
expect(states['system.adapter.simple-api.0.uptime'].val).to.be.least(0);
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API: setBulk(POST) - must set values', function (done) {
request({
uri: 'http://127.0.0.1:18183/setBulk',
method: 'POST',
body: 'system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false&javascript.0.test-string=bla%26fasel%2efoo%3Dhummer+hey'
}, function(error, response, body) {
console.log('setBulk/?system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false&javascript.0.test-string=bla%26fasel%2efoo%3Dhummer+hey => ' + JSON.stringify(body));
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(50);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(obj[1].val).to.be.equal(false);
expect(obj[1].id).to.equal('system.adapter.simple-api.0.alive');
expect(obj[2].val).to.be.equal('bla&fasel.foo=hummer hey');
expect(obj[2].id).to.equal('javascript.0.test-string');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive,javascript.0.test-string', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive,javascript.0.test-string => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(50);
expect(obj[1].val).equal(false);
expect(obj[2].val).equal('bla&fasel.foo=hummer hey');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API: setBulk(POST-GET-Mix) - must set values', function (done) {
request({
uri: 'http://127.0.0.1:18183/setBulk?system.adapter.simple-api.upload=51&system.adapter.simple-api.0.alive=false',
method: 'POST',
body: ''
}, function(error, response, body) {
console.log('setBulk/?system.adapter.simple-api.upload=51&system.adapter.simple-api.0.alive=false => ' + JSON.stringify(body));
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(51);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(obj[1].val).to.be.equal(false);
expect(obj[1].id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(51);
expect(obj[1].val).equal(false);
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API: setValueFromBody(POST) - must set one value', function (done) {
request({
uri: 'http://127.0.0.1:18183/setValueFromBody/system.adapter.simple-api.upload',
method: 'POST',
body: '55'
}, function(error, response, body) {
console.log('setValueFromBody/?system.adapter.simple-api.upload => ' + JSON.stringify(body));
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(55);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(55);
expect(response.statusCode).to.equal(200);
done();
});
});
});
after('Test RESTful API: Stop js-controller', function (done) {
this.timeout(6000);
setup.stopController(function (normalTerminated) {
console.log('Adapter normal terminated: ' + normalTerminated);
done();
});
});
});

277
test/testApiAsLimitedUser.js Normal file
View File

@@ -0,0 +1,277 @@
/* jshint -W097 */// jshint strict:false
/*jslint node: true */
/*jshint expr: true*/
var expect = require('chai').expect;
var setup = require(__dirname + '/lib/setup');
var request = require('request');
var objects = null;
var states = null;
process.env.NO_PROXY = '127.0.0.1';
function checkConnectionOfAdapter(cb, counter) {
counter = counter || 0;
console.log('Try check #' + counter);
if (counter > 30) {
if (cb) cb('Cannot check connection');
return;
}
states.getState('system.adapter.simple-api.0.alive', function (err, state) {
if (err) console.error(err);
if (state && state.val) {
if (cb) cb();
} else {
setTimeout(function () {
checkConnectionOfAdapter(cb, counter + 1);
}, 1000);
}
});
}
describe('Test RESTful API as Owner-User', function() {
before('Test RESTful API as Owner-User: Start js-controller', function (_done) {
this.timeout(600000); // because of first install from npm
setup.adapterStarted = false;
var brokerStarted = false;
setup.setupController(function () {
var config = setup.getAdapterConfig();
// enable adapter
config.common.enabled = true;
config.common.loglevel = 'debug';
config.native.port = 18183;
config.native.defaultUser = 'myuser';
config.native.onlyAllowWhenUserIsOwner = true;
setup.setAdapterConfig(config.common, config.native);
setup.startController(function (_objects, _states) {
objects = _objects;
states = _states;
// give some time to start server
setTimeout(function () {
_done();
}, 2000);
});
});
});
it('Test adapter: Check if adapter started and create upload datapoint', function (done) {
this.timeout(60000);
checkConnectionOfAdapter(function (res) {
if (res) console.log(res);
expect(res).not.to.be.equal('Cannot check connection');
objects.setObject('system.group.writer', {
"common": {
"name": "Writer",
"desc": "",
"members": [
"system.user.myuser"
],
"acl": {
"object": {
"list": false,
"read": false,
"write": false,
"delete": false
},
"state": {
"list": false,
"read": true,
"write": true,
"create": false,
"delete": false
},
"users": {
"write": false,
"create": false,
"delete": false
},
"other": {
"execute": false,
"http": false,
"sendto": false
},
"file": {
"list": false,
"read": false,
"write": false,
"create": false,
"delete": false
}
}
},
"native": {},
"acl": {
"object": 1638,
"owner": "system.user.admin",
"ownerGroup": "system.group.administrator"
},
"_id": "system.group.writer",
"type": "group"
}, function (err) {
expect(err).to.be.null;
objects.setObject('system.user.myuser', {
"type": "user",
"common": {
"name": "myuser",
"enabled": true,
"groups": [],
"password": "pbkdf2$10000$ab4104d8bb68390ee7e6c9397588e768de6c025f0c732c18806f3d1270c83f83fa86a7bf62583770e5f8d0b405fbb3ad32214ef3584f5f9332478f2506414443a910bf15863b36ebfcaa7cbb19253ae32cd3ca390dab87b29cd31e11be7fa4ea3a01dad625d9de44e412680e1a694227698788d71f1e089e5831dc1bbacfa794b45e1c995214bf71ee4160d98b4305fa4c3e36ee5f8da19b3708f68e7d2e8197375c0f763d90e31143eb04760cc2148c8f54937b9385c95db1742595634ed004fa567655dfe1d9b9fa698074a9fb70c05a252b2d9cf7ca1c9b009f2cd70d6972ccf0ee281d777d66a0346c6c6525436dd7fe3578b28dca2c7adbfde0ecd45148$31c3248ba4dc9600a024b4e0e7c3e585"
},
"_id": "system.user.myuser",
"native": {},
"acl": {
"object": 1638
}
}, function (err) {
expect(err).to.be.null;
objects.setObject('javascript.0.test', {
common: {
name: 'test',
type: 'number',
role: 'level',
min: -100,
max: 100,
def: 1
},
native: {
},
type: 'state',
acl: {
object: 1638,
owner: "system.user.myuser",
ownerGroup:"system.group.administrator",
state: 1638
}
}, function (err) {
expect(err).to.be.null;
states.setState('javascript.0.test',1, function(err) {
console.log('END javascript.0.test ' + err);
expect(err).to.be.null;
done();
});
});
});
});
});
});
it('Test RESTful API as Owner-User: get - must return value', function (done) {
console.log('START get/system.adapter.simple-api.0.alive');
request('http://127.0.0.1:18183/get/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('get/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as Owner-User: getPlainValue - must return plain value', function (done) {
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as Owner-User: getPlainValue 4 Test-Endpoint - must return plain value', function (done) {
request('http://127.0.0.1:18183/getPlainValue/javascript.0.test', function (error, response, body) {
console.log('getPlainValue/javascript.0.test => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('1');
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API as Owner-User: set 4 Test-Endpoint - must set value', function (done) {
request('http://127.0.0.1:18183/set/javascript.0.test?val=2', function (error, response, body) {
console.log('set/javascript.0.test?val=false => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.equal(2);
expect(obj.id).to.equal('javascript.0.test');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/javascript.0.test', function (error, response, body) {
console.log('getPlainValue/javascript.0.test => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('2');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API as Owner-User: set - must set value', function (done) {
request('http://127.0.0.1:18183/set/system.adapter.simple-api.0.alive?val=false', function (error, response, body) {
console.log('set/system.adapter.simple-api.0.alive?val=false => ' + body);
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as Owner-User: set - must set val', function (done) {
request('http://127.0.0.1:18183/set/system.adapter.simple-api.0.alive?val=true', function (error, response, body) {
console.log('set/system.adapter.simple-api.0.alive?val=true => ' + body);
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as Owner-User: objects - must return objects', function (done) {
request('http://127.0.0.1:18183/objects?pattern=system.adapter.*', function (error, response, body) {
console.log('objects?pattern=system.adapter.* => ' + body);
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as Owner-User: objects - must return objects', function (done) {
request('http://127.0.0.1:18183/objects?pattern=system.adapter.*&type=instance', function (error, response, body) {
console.log('objects?pattern=system.adapter.* => ' + body);
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as Owner-User: states - must return states', function (done) {
request('http://127.0.0.1:18183/states?pattern=system.adapter.*', function (error, response, body) {
console.log('states?pattern=system.adapter.* => ' + body);
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as Owner-User: setValueFromBody(POST) - must set one value', function (done) {
request({
uri: 'http://127.0.0.1:18183/setValueFromBody/system.adapter.simple-api.upload',
method: 'POST',
body: '55'
}, function(error, response, body) {
console.log('setValueFromBody/?system.adapter.simple-api.upload => ' + JSON.stringify(body));
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
after('Test RESTful API as Owner-User: Stop js-controller', function (done) {
this.timeout(6000);
setup.stopController(function (normalTerminated) {
console.log('Adapter normal terminated: ' + normalTerminated);
done();
});
});
});

508
test/testApiAsUser.js Normal file
View File

@@ -0,0 +1,508 @@
/* jshint -W097 */// jshint strict:false
/*jslint node: true */
/*jshint expr: true*/
var expect = require('chai').expect;
var setup = require(__dirname + '/lib/setup');
var request = require('request');
var objects = null;
var states = null;
process.env.NO_PROXY = '127.0.0.1';
function checkConnectionOfAdapter(cb, counter) {
counter = counter || 0;
console.log('Try check #' + counter);
if (counter > 30) {
if (cb) cb('Cannot check connection');
return;
}
states.getState('system.adapter.simple-api.0.alive', function (err, state) {
if (err) console.error(err);
if (state && state.val) {
if (cb) cb();
} else {
setTimeout(function () {
checkConnectionOfAdapter(cb, counter + 1);
}, 1000);
}
});
}
describe('Test RESTful API as User', function() {
before('Test RESTful API as User: Start js-controller', function (_done) {
this.timeout(600000); // because of first install from npm
setup.adapterStarted = false;
var brokerStarted = false;
setup.setupController(function () {
var config = setup.getAdapterConfig();
// enable adapter
config.common.enabled = true;
config.common.loglevel = 'debug';
config.native.port = 18183;
config.native.defaultUser = 'myuser';
setup.setAdapterConfig(config.common, config.native);
setup.startController(function (_objects, _states) {
objects = _objects;
states = _states;
// give some time to start server
setTimeout(function () {
_done();
}, 2000);
});
});
});
it('Test adapter: Check if adapter started and create upload datapoint', function (done) {
this.timeout(60000);
checkConnectionOfAdapter(function (res) {
if (res) console.log(res);
expect(res).not.to.be.equal('Cannot check connection');
objects.setObject('system.group.writer', {
"common": {
"name": "Writer",
"desc": "",
"members": [
"system.user.myuser"
],
"acl": {
"object": {
"list": false,
"read": false,
"write": false,
"delete": false
},
"state": {
"list": false,
"read": true,
"write": true,
"create": false,
"delete": false
},
"users": {
"write": false,
"create": false,
"delete": false
},
"other": {
"execute": false,
"http": false,
"sendto": false
},
"file": {
"list": false,
"read": false,
"write": false,
"create": false,
"delete": false
}
}
},
"native": {},
"acl": {
"object": 1638,
"owner": "system.user.admin",
"ownerGroup": "system.group.administrator"
},
"_id": "system.group.writer",
"type": "group"
}, function (err) {
expect(err).to.be.null;
objects.setObject('system.user.myuser', {
"type": "user",
"common": {
"name": "myuser",
"enabled": true,
"groups": [],
"password": "pbkdf2$10000$ab4104d8bb68390ee7e6c9397588e768de6c025f0c732c18806f3d1270c83f83fa86a7bf62583770e5f8d0b405fbb3ad32214ef3584f5f9332478f2506414443a910bf15863b36ebfcaa7cbb19253ae32cd3ca390dab87b29cd31e11be7fa4ea3a01dad625d9de44e412680e1a694227698788d71f1e089e5831dc1bbacfa794b45e1c995214bf71ee4160d98b4305fa4c3e36ee5f8da19b3708f68e7d2e8197375c0f763d90e31143eb04760cc2148c8f54937b9385c95db1742595634ed004fa567655dfe1d9b9fa698074a9fb70c05a252b2d9cf7ca1c9b009f2cd70d6972ccf0ee281d777d66a0346c6c6525436dd7fe3578b28dca2c7adbfde0ecd45148$31c3248ba4dc9600a024b4e0e7c3e585"
},
"_id": "system.user.myuser",
"native": {},
"acl": {
"object": 1638
}
}, function (err) {
expect(err).to.be.null;
objects.setObject('javascript.0.test', {
common: {
name: 'test',
type: 'number',
role: 'level',
min: -100,
max: 100,
def: 1
},
native: {
},
type: 'state',
acl: {
object: 1638,
owner: "system.user.myuser",
ownerGroup:"system.group.administrator",
state: 1638
}
}, function (err) {
expect(err).to.be.null;
states.setState('javascript.0.test',1, function(err) {
expect(err).to.be.null;
done();
});
});
});
});
});
});
it('Test RESTful API as User: get - must return value', function (done) {
request('http://127.0.0.1:18183/get/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('get/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
//{
// "val" : true,
// "ack" : true,
// "ts" : 1455009717,
// "q" : 0,
// "from" : "system.adapter.simple-api.0",
// "lc" : 1455009717,
// "expire" : 30000,
// "_id" : "system.adapter.simple-api.0.alive",
// "type" : "state",
// "common" : {
// "name" : "simple-api.0.alive",
// "type" : "boolean",
// "role" : "indicator.state"
// },
// "native" : {}
//
//}
expect(obj).to.be.ok;
expect(obj.val).to.be.true;
expect(obj.ack).to.be.true;
expect(obj.ts).to.be.ok;
//expect(obj.from).to.equal("system.adapter.simple-api.0");
expect(obj.type).to.equal("state");
expect(obj._id).to.equal("system.adapter.simple-api.0.alive");
expect(obj.common).to.be.ok;
expect(obj.native).to.be.ok;
expect(obj.common.name).to.equal("simple-api.0.alive");
expect(obj.common.role).to.equal("indicator.state");
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API as User: getPlainValue - must return plain value', function (done) {
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('true');
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API as User: getPlainValue 4 Test-Endpoint - must return plain value', function (done) {
request('http://127.0.0.1:18183/getPlainValue/javascript.0.test', function (error, response, body) {
console.log('getPlainValue/javascript.0.test => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('1');
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API as User: set 4 Test-Endpoint - must set value', function (done) {
request('http://127.0.0.1:18183/set/javascript.0.test?val=2', function (error, response, body) {
console.log('set/javascript.0.test?val=false => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.equal(2);
expect(obj.id).to.equal('javascript.0.test');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/javascript.0.test', function (error, response, body) {
console.log('getPlainValue/javascript.0.test => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('2');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API as User: set - must set value', function (done) {
request('http://127.0.0.1:18183/set/system.adapter.simple-api.0.alive?val=false', function (error, response, body) {
console.log('set/system.adapter.simple-api.0.alive?val=false => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.false;
expect(obj.id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('false');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API as User: set - must set val', function (done) {
request('http://127.0.0.1:18183/set/system.adapter.simple-api.0.alive?val=true', function (error, response, body) {
console.log('set/system.adapter.simple-api.0.alive?val=true => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.true;
expect(obj.id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('true');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API as User: toggle - must toggle boolean value to false', function (done) {
request('http://127.0.0.1:18183/toggle/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('toggle/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.false;
expect(obj.id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('false');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API as User: toggle - must toggle boolean value to true', function (done) {
request('http://127.0.0.1:18183/toggle/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('toggle/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.true;
expect(obj.id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('true');
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API as User: toggle - must toggle number value to 100', function (done) {
request('http://127.0.0.1:18183/toggle/system.adapter.simple-api.upload', function (error, response, body) {
console.log('toggle/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.equal(100);
expect(obj.id).to.equal('system.adapter.simple-api.upload');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.upload', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('100');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/set/system.adapter.simple-api.upload?val=49', function (error, response, body) {
console.log('set/system.adapter.simple-api.upload?val=49 => ' + body);
request('http://127.0.0.1:18183/toggle/system.adapter.simple-api.upload', function (error, response, body) {
console.log('toggle/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj.val).to.be.equal(51);
expect(obj.id).to.equal('system.adapter.simple-api.upload');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getPlainValue/system.adapter.simple-api.upload', function (error, response, body) {
console.log('getPlainValue/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
expect(body).equal('51');
expect(response.statusCode).to.equal(200);
done();
});
});
});
});
});
});
it('Test RESTful API as User: setBulk - must set values', function (done) {
request('http://127.0.0.1:18183/setBulk/?system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false&javascript.0.test=3', function (error, response, body) {
console.log('setBulk/?system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false&javascript.0.test=3 => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(50);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(obj[1].val).to.be.equal(false);
expect(obj[1].id).to.equal('system.adapter.simple-api.0.alive');
expect(obj[2].val).to.be.equal(3);
expect(obj[2].id).to.equal('javascript.0.test');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive,javascript.0.test', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive&javascript.0.test => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(50);
expect(obj[1].val).equal(false);
expect(obj[2].val).equal(3);
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API as User: objects - must return objects', function (done) {
request('http://127.0.0.1:18183/objects?pattern=system.adapter.*', function (error, response, body) {
console.log('objects?pattern=system.adapter.* => ' + body);
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as User: objects - must return objects', function (done) {
request('http://127.0.0.1:18183/objects?pattern=system.adapter.*&type=instance', function (error, response, body) {
console.log('objects?pattern=system.adapter.* => ' + body);
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as User: states - must return states', function (done) {
request('http://127.0.0.1:18183/states?pattern=system.adapter.*', function (error, response, body) {
console.log('states?pattern=system.adapter.* => ' + body);
expect(body).to.be.equal('error: permissionError');
expect(response.statusCode).to.equal(401);
done();
});
});
it('Test RESTful API as User: setBulk(POST) - must set values', function (done) {
request({
uri: 'http://127.0.0.1:18183/setBulk',
method: 'POST',
body: 'system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false&javascript.0.test=4'
}, function(error, response, body) {
console.log('setBulk/?system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false&javascript.0.test=4 => ' + JSON.stringify(body));
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(50);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(obj[1].val).to.be.equal(false);
expect(obj[1].id).to.equal('system.adapter.simple-api.0.alive');
expect(obj[2].val).to.be.equal(4);
expect(obj[2].id).to.equal('javascript.0.test');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive,javascript.0.test', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive,javascript.0.test => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(50);
expect(obj[1].val).equal(false);
expect(obj[2].val).equal(4);
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API as User: setBulk(POST-GET-Mix) - must set values', function (done) {
request({
uri: 'http://127.0.0.1:18183/setBulk?system.adapter.simple-api.upload=51&system.adapter.simple-api.0.alive=false',
method: 'POST',
body: ''
}, function(error, response, body) {
console.log('setBulk/?system.adapter.simple-api.upload=51&system.adapter.simple-api.0.alive=false => ' + JSON.stringify(body));
expect(error).to.be.not.ok;
expect(response.statusCode).to.equal(200);
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(51);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(obj[1].val).to.be.equal(false);
expect(obj[1].id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(51);
expect(obj[1].val).equal(false);
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API as User: setValueFromBody(POST) - must set one value', function (done) {
request({
uri: 'http://127.0.0.1:18183/setValueFromBody/system.adapter.simple-api.upload',
method: 'POST',
body: '55'
}, function(error, response, body) {
console.log('setValueFromBody/?system.adapter.simple-api.upload => ' + JSON.stringify(body));
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(55);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(response.statusCode).to.equal(200);
request('http://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(55);
expect(response.statusCode).to.equal(200);
done();
});
});
});
after('Test RESTful API as User: Stop js-controller', function (done) {
this.timeout(6000);
setup.stopController(function (normalTerminated) {
console.log('Adapter normal terminated: ' + normalTerminated);
done();
});
});
});

91
test/testPackageFiles.js Normal file
View File

@@ -0,0 +1,91 @@
/* jshint -W097 */
/* jshint strict:false */
/* jslint node: true */
/* jshint expr: true */
var expect = require('chai').expect;
var fs = require('fs');
describe('Test package.json and io-package.json', function() {
it('Test package files', function (done) {
console.log();
var fileContentIOPackage = fs.readFileSync(__dirname + '/../io-package.json', 'utf8');
var ioPackage = JSON.parse(fileContentIOPackage);
var fileContentNPMPackage = fs.readFileSync(__dirname + '/../package.json', 'utf8');
var npmPackage = JSON.parse(fileContentNPMPackage);
expect(ioPackage).to.be.an('object');
expect(npmPackage).to.be.an('object');
expect(ioPackage.common.version, 'ERROR: Version number in io-package.json needs to exist').to.exist;
expect(npmPackage.version, 'ERROR: Version number in package.json needs to exist').to.exist;
expect(ioPackage.common.version, 'ERROR: Version numbers in package.json and io-package.json needs to match').to.be.equal(npmPackage.version);
if (!ioPackage.common.news || !ioPackage.common.news[ioPackage.common.version]) {
console.log('WARNING: No news entry for current version exists in io-package.json, no rollback in Admin possible!');
console.log();
}
expect(npmPackage.author, 'ERROR: Author in package.json needs to exist').to.exist;
expect(ioPackage.common.authors, 'ERROR: Authors in io-package.json needs to exist').to.exist;
if (ioPackage.common.name.indexOf('template') !== 0) {
if (Array.isArray(ioPackage.common.authors)) {
expect(ioPackage.common.authors.length, 'ERROR: Author in io-package.json needs to be set').to.not.be.equal(0);
if (ioPackage.common.authors.length === 1) {
expect(ioPackage.common.authors[0], 'ERROR: Author in io-package.json needs to be a real name').to.not.be.equal('my Name <my@email.com>');
}
}
else {
expect(ioPackage.common.authors, 'ERROR: Author in io-package.json needs to be a real name').to.not.be.equal('my Name <my@email.com>');
}
}
else {
console.log('WARNING: Testing for set authors field in io-package skipped because template adapter');
console.log();
}
expect(fs.existsSync(__dirname + '/../README.md'), 'ERROR: README.md needs to exist! Please create one with description, detail information and changelog. English is mandatory.').to.be.true;
if (!ioPackage.common.titleLang || typeof ioPackage.common.titleLang !== 'object') {
console.log('WARNING: titleLang is not existing in io-package.json. Please add');
console.log();
}
if (
ioPackage.common.title.indexOf('yunkong2') !== -1 ||
ioPackage.common.title.indexOf('yunkong2') !== -1 ||
ioPackage.common.title.indexOf('adapter') !== -1 ||
ioPackage.common.title.indexOf('Adapter') !== -1
) {
console.log('WARNING: title contains Adapter or yunkong2. It is clear anyway, that it is adapter for yunkong2.');
console.log();
}
if (ioPackage.common.name.indexOf('vis-') !== 0) {
if (!ioPackage.common.materialize || !fs.existsSync(__dirname + '/../admin/index_m.html') || !fs.existsSync(__dirname + '/../gulpfile.js')) {
console.log('WARNING: Admin3 support is missing! Please add it');
console.log();
}
if (ioPackage.common.materialize) {
expect(fs.existsSync(__dirname + '/../admin/index_m.html'), 'Admin3 support is enabled in io-package.json, but index_m.html is missing!').to.be.true;
}
}
var licenseFileExists = fs.existsSync(__dirname + '/../LICENSE');
var fileContentReadme = fs.readFileSync(__dirname + '/../README.md', 'utf8');
if (fileContentReadme.indexOf('## Changelog') === -1) {
console.log('Warning: The README.md should have a section ## Changelog');
console.log();
}
expect((licenseFileExists || fileContentReadme.indexOf('## License') !== -1), 'A LICENSE must exist as LICENSE file or as part of the README.md').to.be.true;
if (!licenseFileExists) {
console.log('Warning: The License should also exist as LICENSE file');
console.log();
}
if (fileContentReadme.indexOf('## License') === -1) {
console.log('Warning: The README.md should also have a section ## License to be shown in Admin3');
console.log();
}
done();
});
});

194
test/testSsl.js Normal file
View File

@@ -0,0 +1,194 @@
/* jshint -W097 */// jshint strict:false
/*jslint node: true */
/*jshint expr: true*/
var expect = require('chai').expect;
var setup = require(__dirname + '/lib/setup');
var request = require('request');
var objects = null;
var states = null;
process.env.NO_PROXY = '127.0.0.1';
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';
function checkConnectionOfAdapter(cb, counter) {
counter = counter || 0;
console.log('Try check #' + counter);
if (counter > 30) {
if (cb) cb('Cannot check connection');
return;
}
states.getState('system.adapter.simple-api.0.alive', function (err, state) {
if (err) console.error(err);
if (state && state.val) {
if (cb) cb();
} else {
setTimeout(function () {
checkConnectionOfAdapter(cb, counter + 1);
}, 1000);
}
});
}
describe('Test RESTful API SSL', function() {
before('Test RESTful API SSL: Start js-controller', function (_done) {
this.timeout(600000); // because of first install from npm
setup.adapterStarted = false;
var brokerStarted = false;
setup.setupController(function () {
var config = setup.getAdapterConfig();
// enable adapter
config.common.enabled = true;
config.common.loglevel = 'debug';
config.native.port = 18183;
config.native.auth = true;
config.native.secure = true;
config.native.certPublic = 'defaultPublic';
config.native.certPrivate = 'defaultPrivate';
setup.setAdapterConfig(config.common, config.native);
setup.startController(function (_objects, _states) {
objects = _objects;
states = _states;
// give some time to start server
setTimeout(function () {
_done();
}, 2000);
});
});
});
it('Test adapter: Check if adapter started and create upload datapoint', function (done) {
this.timeout(60000);
checkConnectionOfAdapter(function (res) {
if (res) console.log(res);
expect(res).not.to.be.equal('Cannot check connection');
done();
});
});
it('Test RESTful API SSL: get - must return value', function (done) {
request('https://127.0.0.1:18183/get/system.adapter.simple-api.0.alive?user=admin&pass=yunkong2', function (error, response, body) {
console.log('get/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
//{
// "val" : true,
// "ack" : true,
// "ts" : 1455009717,
// "q" : 0,
// "from" : "system.adapter.simple-api.0",
// "lc" : 1455009717,
// "expire" : 30000,
// "_id" : "system.adapter.simple-api.0.alive",
// "type" : "state",
// "common" : {
// "name" : "simple-api.0.alive",
// "type" : "boolean",
// "role" : "indicator.state"
// },
// "native" : {}
//
//}
expect(obj).to.be.ok;
expect(obj.val).to.be.true;
expect(obj.ack).to.be.true;
expect(obj.ts).to.be.ok;
//expect(obj.from).to.equal("system.adapter.simple-api.0");
expect(obj.type).to.equal("state");
expect(obj._id).to.equal("system.adapter.simple-api.0.alive");
expect(obj.common).to.be.ok;
expect(obj.native).to.be.ok;
expect(obj.common.name).to.equal("simple-api.0.alive");
expect(obj.common.role).to.equal("indicator.state");
expect(response.statusCode).to.equal(200);
done();
});
});
it('Test RESTful API SSL: get with no credentials', function (done) {
request('https://127.0.0.1:18183/get/system.adapter.simple-api.0.alive?user=admin&pass=io', function (error, response, body) {
console.log('get/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(response.statusCode).to.be.equal(401);
done();
});
});
it('Test RESTful API SSL: get with wrong credentials', function (done) {
request('https://127.0.0.1:18183/get/system.adapter.simple-api.0.alive', function (error, response, body) {
console.log('get/system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
expect(response.statusCode).to.be.equal(401);
done();
});
});
it('Test RESTful API SSL: setBulk(POST) - must set values', function (done) {
request({
uri: 'https://127.0.0.1:18183/setBulk?user=admin&pass=yunkong2',
method: 'POST',
body: 'system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false'
}, function(error, response, body) {
console.log('setBulk/?system.adapter.simple-api.upload=50&system.adapter.simple-api.0.alive=false => ' + JSON.stringify(body));
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(50);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(obj[1].val).to.be.equal(false);
expect(obj[1].id).to.equal('system.adapter.simple-api.0.alive');
expect(response.statusCode).to.equal(200);
request('https://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive?user=admin&pass=yunkong2', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload,system.adapter.simple-api.0.alive => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(50);
expect(obj[1].val).equal(false);
expect(response.statusCode).to.equal(200);
done();
});
});
});
it('Test RESTful API SSL: setValueFromBody(POST) - must set values', function (done) {
request({
uri: 'https://127.0.0.1:18183/setValueFromBody/system.adapter.simple-api.upload?user=admin&pass=yunkong2&',
method: 'POST',
body: '55'
}, function(error, response, body) {
console.log('setValueFromBody/?system.adapter.simple-api.upload => ' + JSON.stringify(body));
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj).to.be.ok;
expect(obj[0].val).to.be.equal(55);
expect(obj[0].id).to.equal('system.adapter.simple-api.upload');
expect(response.statusCode).to.equal(200);
body = "";
request('https://127.0.0.1:18183/getBulk/system.adapter.simple-api.upload?user=admin&pass=yunkong2', function (error, response, body) {
console.log('getBulk/system.adapter.simple-api.upload => ' + body);
expect(error).to.be.not.ok;
var obj = JSON.parse(body);
expect(obj[0].val).equal(55);
expect(response.statusCode).to.equal(200);
done();
});
});
});
after('Test RESTful API SSL: Stop js-controller', function (done) {
this.timeout(6000);
setup.stopController(function (normalTerminated) {
console.log('Adapter normal terminated: ' + normalTerminated);
done();
});
});
});