-
Notifications
You must be signed in to change notification settings - Fork 21
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Fixing config services and configuration type handling
Co-authored-by: Walter Domenico Vergara <walterwootz@users.noreply.github.com>
- Loading branch information
1 parent
da85d37
commit 648bcdf
Showing
13 changed files
with
1,367 additions
and
39 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,98 @@ | ||
| const { expect, assert } = require('chai'); | ||
| const util = require('util'); | ||
| const exec = util.promisify(require('child_process').exec); | ||
| const child = require('child_process'); | ||
| const path = require('path'); | ||
| const axios = require('axios'); | ||
|
|
||
| /** | ||
| * Contains the current child process of the agent | ||
| * @type {null} | ||
| */ | ||
| let agentProcess = null; | ||
|
|
||
| /** | ||
| * If true, start and stop an agent instance for each test block | ||
| * @type {boolean} | ||
| */ | ||
| const MOCK_AGENT_PROCESS = true; | ||
|
|
||
| /** | ||
| * If true, start and stop an environment (opcua car server, orion, mongodb) for each test block using docker | ||
| * @type {boolean} | ||
| */ | ||
| const MOCK_ENVIRONMENT = true; | ||
|
|
||
| /** | ||
| * Start the agent in a child process using configuration file passed as argument | ||
| * @param testConfigFile | ||
| * @returns {ChildProcessWithoutNullStreams} | ||
| */ | ||
| function startAgent(testConfigFile) { | ||
| console.log('>>>>> STARTING AGENT <<<<<'); | ||
| agentProcess = child.spawn('node', ['./bin/iotagent-opcua', `./test/functional/mock/${testConfigFile}`]); | ||
| agentProcess.stdout.setEncoding('utf8'); | ||
| agentProcess.stdout.on('data', function (data) { | ||
| console.log('AGENT_LOG: ' + data); | ||
| }); | ||
| agentProcess.stderr.setEncoding('utf8'); | ||
| agentProcess.stderr.on('data', function (data) { | ||
| console.error('AGENT_ERR: ' + data); | ||
| }); | ||
| return agentProcess; | ||
| } | ||
|
|
||
| /** | ||
| * Stop the child process of the agent | ||
| * @param process | ||
| */ | ||
| function stopAgent(process) { | ||
| console.log('>>>>> STOPPING AGENT <<<<<'); | ||
| process.kill('SIGINT'); | ||
| } | ||
|
|
||
| async function wait(seconds) { | ||
| await new Promise((resolve) => setTimeout(resolve, seconds * 1000)); | ||
| } | ||
|
|
||
| describe('IoT Agent OPCUA Auto Configuration', () => { | ||
| describe('When configurationType is equal to "auto"', () => { | ||
| before(async () => { | ||
| if (MOCK_ENVIRONMENT) { | ||
| await exec(path.resolve(__dirname, '../start-env.sh')); | ||
| } | ||
| if (MOCK_AGENT_PROCESS) { | ||
| startAgent('config-v2-auto-configuration.test.js'); | ||
| } | ||
| }); | ||
| after(async () => { | ||
| if (MOCK_ENVIRONMENT) { | ||
| await exec(path.resolve(__dirname, '../stop-env.sh')); | ||
| } | ||
| if (MOCK_AGENT_PROCESS) { | ||
| stopAgent(agentProcess); | ||
| } | ||
| }); | ||
| it('Should run the mapping tool and perform provisioning of device', async () => { | ||
| await wait(5); | ||
|
|
||
| const mockConfig = require('./mock/config-v2-auto-configuration.test'); | ||
| const url = `http://localhost:${mockConfig.iota.server.port}/iot/devices`; | ||
| try { | ||
| const res = await axios.get(url, { | ||
| headers: { | ||
| 'fiware-service': mockConfig.iota.service, | ||
| 'fiware-servicepath': mockConfig.iota.subservice | ||
| } | ||
| }); | ||
| expect(res.status).to.greaterThanOrEqual(200).and.lessThanOrEqual(300); | ||
| expect(res.data.count).is.greaterThanOrEqual(1); | ||
| expect(res.data.devices.length).is.greaterThanOrEqual(1); | ||
| expect(res.data.devices[0].entity_name).to.equal(mockConfig.mappingTool.entityId); | ||
| expect(res.data.devices[0].entity_type).to.equal(mockConfig.mappingTool.entityType); | ||
| } catch (err) { | ||
| assert.fail('Request failed', 'Request success', `GET /iot/devices failed ${err}`); | ||
| } | ||
| }); | ||
| }); | ||
| }); |
Oops, something went wrong.