mirror of
https://github.com/node-red/node-red.git
synced 2025-03-01 10:36:34 +00:00
Add UI testing code for mqtt node
This commit is contained in:
Yuma Matsuura
228
test/editor/specs/scenario/cookbook_mqtt_uispec.js
Normal file
228
test/editor/specs/scenario/cookbook_mqtt_uispec.js
Normal file
@@ -0,0 +1,228 @@
|
||||
/**
|
||||
* Copyright JS Foundation and other contributors, http://js.foundation
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
**/
|
||||
|
||||
var when = require('when');
|
||||
var should = require("should");
|
||||
var fs = require('fs-extra');
|
||||
|
||||
var helper = require("../../editor_helper");
|
||||
var debugTab = require('../../pageobjects/editor/debugTab_page');
|
||||
var workspace = require('../../pageobjects/editor/workspace_page');
|
||||
var specUtil = require('../../pageobjects/util/spec_util_page');
|
||||
var mqttConfig = require('../../pageobjects/nodes/core/io/10-mqttconfig_page.js');
|
||||
|
||||
var nodeWidth = 200;
|
||||
var nodeHeight = 100;
|
||||
var httpNodeRoot = "/api";
|
||||
|
||||
var mqttServer;
|
||||
var mosca = require('mosca');
|
||||
var moscaSettings = {
|
||||
port: 1883,
|
||||
persistence: {
|
||||
// Needs for retaining messages.
|
||||
factory: mosca.persistence.Memory
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
// https://cookbook.nodered.org/
|
||||
describe('cookbook', function() {
|
||||
beforeEach(function() {
|
||||
workspace.deleteAllNodes();
|
||||
});
|
||||
|
||||
before(function() {
|
||||
browser.call(function() {
|
||||
return new Promise(function(resolve, reject) {
|
||||
mqttServer = new mosca.Server(moscaSettings, function() {
|
||||
resolve();
|
||||
});
|
||||
});
|
||||
});
|
||||
helper.startServer();
|
||||
});
|
||||
|
||||
after(function() {
|
||||
browser.call(function() {
|
||||
return new Promise(function(resolve, reject) {
|
||||
mqttServer.close(function() {
|
||||
resolve();
|
||||
});
|
||||
});
|
||||
});
|
||||
helper.stopServer();
|
||||
});
|
||||
|
||||
describe('MQTT', function() {
|
||||
it('Add an MQTT broker to prepare for UI test', function() {
|
||||
var mqttOutNode = workspace.addNode("mqttOut", nodeWidth);
|
||||
|
||||
mqttOutNode.edit();
|
||||
mqttConfig.edit();
|
||||
mqttConfig.setServer("localhost");
|
||||
mqttConfig.clickOk();
|
||||
mqttOutNode.clickOk();
|
||||
|
||||
workspace.deploy();
|
||||
});
|
||||
|
||||
it('Connect to an MQTT broker', function() {
|
||||
var injectNode = workspace.addNode("inject");
|
||||
var mqttOutNode = workspace.addNode("mqttOut", nodeWidth);
|
||||
|
||||
var mqttInNode = workspace.addNode("mqttIn", 0, nodeHeight);
|
||||
var debugNode = workspace.addNode("debug", nodeWidth * 2, nodeHeight);
|
||||
|
||||
injectNode.edit();
|
||||
injectNode.setPayload("num", 22);
|
||||
injectNode.clickOk();
|
||||
|
||||
mqttOutNode.edit();
|
||||
mqttOutNode.setTopic("sensors/livingroom/temp");
|
||||
mqttOutNode.clickOk();
|
||||
|
||||
injectNode.connect(mqttOutNode);
|
||||
|
||||
mqttInNode.edit();
|
||||
mqttInNode.setTopic("sensors/livingroom/temp");
|
||||
mqttInNode.setQoS("2");
|
||||
mqttInNode.clickOk();
|
||||
|
||||
mqttInNode.connect(debugNode);
|
||||
|
||||
workspace.deploy();
|
||||
|
||||
debugTab.open();
|
||||
debugTab.clearMessage();
|
||||
injectNode.clickLeftButton();
|
||||
debugTab.getMessage().should.eql('"22"');
|
||||
});
|
||||
|
||||
// skip this case since it is same as other cases.
|
||||
it.skip('Publish messages to a topic');
|
||||
|
||||
it('Set the topic of a published message', function() {
|
||||
var injectNode = workspace.addNode("inject");
|
||||
var mqttOutNode = workspace.addNode("mqttOut", nodeWidth * 2);
|
||||
|
||||
injectNode.edit();
|
||||
injectNode.setPayload("num", 22);
|
||||
injectNode.setTopic("sensors/kitchen/temperature");
|
||||
injectNode.clickOk();
|
||||
|
||||
mqttOutNode.edit();
|
||||
mqttOutNode.clickOk();
|
||||
|
||||
injectNode.connect(mqttOutNode);
|
||||
|
||||
// The code for confirmation starts from here.
|
||||
var mqttInNode = workspace.addNode("mqttIn", 0, nodeHeight);
|
||||
var debugNode = workspace.addNode("debug", nodeWidth * 2, nodeHeight);
|
||||
|
||||
mqttInNode.edit();
|
||||
mqttInNode.setTopic("sensors/kitchen/temperature");
|
||||
mqttInNode.clickOk();
|
||||
|
||||
mqttInNode.connect(debugNode);
|
||||
// The code for confirmation ends here.
|
||||
|
||||
workspace.deploy();
|
||||
|
||||
debugTab.open();
|
||||
debugTab.clearMessage();
|
||||
injectNode.clickLeftButton();
|
||||
debugTab.getMessage().should.eql('"22"');
|
||||
});
|
||||
|
||||
it('Publish a retained message to a topic', function() {
|
||||
var injectNode = workspace.addNode("inject");
|
||||
var mqttOutNode = workspace.addNode("mqttOut", nodeWidth);
|
||||
|
||||
injectNode.edit();
|
||||
injectNode.setPayload("num", 22);
|
||||
injectNode.clickOk();
|
||||
|
||||
mqttOutNode.edit();
|
||||
mqttOutNode.setTopic("sensors/livingroom/temp");
|
||||
mqttOutNode.setRetain("true");
|
||||
mqttOutNode.clickOk();
|
||||
|
||||
injectNode.connect(mqttOutNode);
|
||||
|
||||
workspace.deploy();
|
||||
debugTab.open();
|
||||
injectNode.clickLeftButton();
|
||||
debugTab.clearMessage();
|
||||
|
||||
// The code for confirmation starts from here.
|
||||
var mqttInNode = workspace.addNode("mqttIn", 0, nodeHeight);
|
||||
var debugNode = workspace.addNode("debug", nodeWidth * 2, nodeHeight);
|
||||
|
||||
mqttInNode.edit();
|
||||
mqttInNode.setTopic("sensors/livingroom/temp");
|
||||
mqttInNode.clickOk();
|
||||
|
||||
mqttInNode.connect(debugNode);
|
||||
// The code for confirmation ends here.
|
||||
|
||||
workspace.deploy();
|
||||
debugTab.open();
|
||||
debugTab.getMessage().should.eql('"22"');
|
||||
});
|
||||
|
||||
// skip this case since it is same as other cases.
|
||||
it.skip('Subscribe to a topic');
|
||||
|
||||
it('Receive a parsed JSON message', function() {
|
||||
var injectNode = workspace.addNode("inject");
|
||||
var mqttOutNode = workspace.addNode("mqttOut", nodeWidth);
|
||||
|
||||
var mqttInNode = workspace.addNode("mqttIn", 0, nodeHeight);
|
||||
var jsonNode = workspace.addNode("json", nodeWidth, nodeHeight);
|
||||
var debugNode = workspace.addNode("debug", nodeWidth * 2, nodeHeight);
|
||||
|
||||
injectNode.edit();
|
||||
injectNode.setPayload("json", '{"sensor_id": 1234, "temperature": 13 }');
|
||||
injectNode.clickOk();
|
||||
|
||||
mqttOutNode.edit();
|
||||
mqttOutNode.setTopic("sensors/livingroom/temp");
|
||||
mqttOutNode.clickOk();
|
||||
|
||||
injectNode.connect(mqttOutNode);
|
||||
|
||||
mqttInNode.edit();
|
||||
mqttInNode.setTopic("sensors/#");
|
||||
mqttInNode.setQoS("2");
|
||||
mqttInNode.clickOk();
|
||||
|
||||
jsonNode.edit();
|
||||
jsonNode.setProperty("payload");
|
||||
jsonNode.clickOk();
|
||||
|
||||
mqttInNode.connect(jsonNode);
|
||||
jsonNode.connect(debugNode);
|
||||
|
||||
workspace.deploy();
|
||||
|
||||
debugTab.open();
|
||||
debugTab.clearMessage();
|
||||
injectNode.clickLeftButton();
|
||||
debugTab.getMessage().should.eql(['1234', '13']);
|
||||
});
|
||||
});
|
||||
});
|
||||
Reference in New Issue
Block a user