-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #5 from andersonluisribeiro/master
Fix import/export
- Loading branch information
Showing
4 changed files
with
30 additions
and
293 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,181 +1,45 @@ | ||
| import { logger } from '@dojot/dojot-module-logger'; | ||
| import requestsDevice from './requestsDevice'; | ||
| import requestsTemplate from './requestsTemplate'; | ||
| import requestFlow from './requestsFlow'; | ||
| import Requests from '../utils/requests'; | ||
| import config from '../config'; | ||
|
|
||
| async function deleteAllData(token) { | ||
| logger.debug('Deleting all devices.'); | ||
| await Requests._delete(token, `${config.device_manager_url}/device`); | ||
| logger.debug('Deleting all templates.'); | ||
| await Requests._delete(token, `${config.device_manager_url}/template`); | ||
| async function deleteAllFlows(token) { | ||
| logger.debug('Deleting all flows.'); | ||
| await Requests._delete(token, `${config.flow_broker_url}/v1/flow`); | ||
| } | ||
|
|
||
| function improveDeviceToBeCreated(newsIdTemplate, devices) { | ||
| const deviceList = devices; | ||
| deviceList.forEach((device, indexDevice) => { | ||
| device.templates.forEach((templateId, index) => { | ||
| newsIdTemplate.forEach((item) => { | ||
| if (parseInt(item.oldId, 0) === parseInt(templateId, 0)) { | ||
| deviceList[indexDevice].templates[index] = item.newId; | ||
| } | ||
| }); | ||
| }); | ||
|
|
||
| device.attrs.forEach((attr) => { | ||
| const changeattr = attr; | ||
| newsIdTemplate.forEach((item) => { | ||
| if (parseInt(attr.template_id, 0) === parseInt(item.oldId, 0)) { | ||
| changeattr.template_id = item.newId.toString(); | ||
| } | ||
|
|
||
| item.newObject.attrs.forEach((attrTemplate) => { | ||
| if (attrTemplate.label === changeattr.label) { | ||
| delete changeattr.created; | ||
| changeattr.id = attrTemplate.id; | ||
| } | ||
| }); | ||
|
|
||
| if (attr.metadata !== undefined) { | ||
| attr.metadata.forEach((meta) => { | ||
| const data = meta; | ||
| if (data.id !== undefined) { | ||
| delete data.id; | ||
| } | ||
| }); | ||
| } | ||
| }); | ||
| }); | ||
| }); | ||
| return deviceList; | ||
| } | ||
|
|
||
| function changeIdDeviceFlow(newDevices, flows) { | ||
| const flowsList = flows; | ||
| flowsList.forEach((flow) => { | ||
| flow.flow.forEach((nodeIn) => { | ||
| const node = nodeIn; | ||
| if ((node.type === 'device in') || (node.type === 'actuate')) { | ||
| newDevices.forEach((device) => { | ||
| if (device.oldId === node._device_id) { | ||
| node._device_id = device.newId; | ||
| node.device_source_id = `Device (${device.newId})`; | ||
| } | ||
| }); | ||
| } else if (node.type === 'device out') { | ||
| newDevices.forEach((device) => { | ||
| let newDevicesIds = []; | ||
| node.devices_source_configured.forEach( (deviceId) => { | ||
| if (device.oldId === deviceId) { | ||
| newDevicesIds.push(device.newId); | ||
| } | ||
| }); | ||
| node.devices_source_configured = newDevicesIds; | ||
| }); | ||
| } | ||
| }); | ||
| }); | ||
| return flowsList; | ||
| } | ||
|
|
||
| function removeMetadataIDTemplate(templates) { | ||
| const temp = templates; | ||
| temp.forEach((template) => { | ||
| template.attrs.forEach((attr) => { | ||
| const oneAttr = attr; | ||
| delete oneAttr.id; | ||
| if (oneAttr.metadata !== undefined) { | ||
| oneAttr.metadata.forEach((meta) => { | ||
| const data = meta; | ||
| if (data.id !== undefined) { | ||
| delete data.id; | ||
| } | ||
| }); | ||
| } | ||
| }); | ||
| }); | ||
| return templates; | ||
| } | ||
|
|
||
| function changeIdTemplateFlow(newflows, flows) { | ||
| const flowsList = flows; | ||
| flowsList.forEach((flow) => { | ||
| flow.flow.forEach((objIn) => { | ||
| const obj = objIn; | ||
| if (obj.type === 'device template in') { | ||
| newflows.forEach((item) => { | ||
| if (item.oldId === obj.device_template_id) { | ||
| obj.device_template_id = item.newId; | ||
| obj.device_template.id = item.newId; | ||
| } | ||
| }); | ||
| } | ||
| }); | ||
| }); | ||
| return flowsList; | ||
| } | ||
|
|
||
| /** | ||
| * @param {array} data data array to be imported on dojot, like the exported object. | ||
| * @returns {array} return the imported objects on dojot. | ||
| */ | ||
| const post = (token, data) => new Promise(async (resolve, reject) => { | ||
| logger.debug('Will import data.'); | ||
| try { | ||
| await deleteAllData(token); | ||
| await deleteAllFlows(token); | ||
| } catch (error) { | ||
| reject(error.toString()); | ||
| return; | ||
| } | ||
| const body = data; | ||
| body.templates = removeMetadataIDTemplate(body.templates); | ||
| requestsTemplate.post(token, body.templates) | ||
| .then((templates) => { | ||
| logger.debug('Templates imported.'); | ||
| body.templates = templates; | ||
| body.devices = improveDeviceToBeCreated(templates, body.devices); | ||
| requestsDevice.post(token, body.devices) | ||
| .then((devices) => { | ||
| logger.debug('Devices imported.'); | ||
| body.devices = devices; | ||
| body.flows = changeIdDeviceFlow(devices, body.flows); | ||
| body.flows = changeIdTemplateFlow(templates, body.flows); | ||
| requestFlow.post(token, body.flows) | ||
| .then((newflows) => { | ||
| logger.debug('Flows imported.'); | ||
| const bodyTemplates = body.templates; | ||
| body.templates = []; | ||
| bodyTemplates.forEach((item) => { | ||
| body.templates.push(item.newObject); | ||
| }); | ||
|
|
||
| const bodyDevices = body.devices; | ||
| body.devices = []; | ||
| bodyDevices.forEach((item) => { | ||
| body.devices.push(item.newObject[0]); | ||
| }); | ||
|
|
||
| body.flows = newflows; | ||
| logger.debug('Resolving importation.'); | ||
| resolve(body); | ||
| }) | ||
| .catch((err) => { | ||
| logger.debug(`Received error on import flows, ${err}. Rejecting the request`); | ||
| reject(err); | ||
| }); | ||
| }) | ||
| .catch((err) => { | ||
| logger.debug(`Received error on import Devices, ${err}. Rejecting the request`); | ||
| reject(err); | ||
| }); | ||
| }) | ||
| .catch((err) => { | ||
| logger.debug(`Received error on import Templates, ${err}. Rejecting the request`); | ||
| reject(err); | ||
| }); | ||
| const body = data; | ||
|
|
||
| requestFlow.post(token, body.flows).then((newflows) => { | ||
| logger.debug('Flows imported.'); | ||
|
|
||
| Requests.post(token, `${config.device_manager_url}/import`, {templates: body.templates, devices: body.devices}).then(res => { | ||
| logger.debug('Devices and templates imported.'); | ||
| resolve({'message': 'data imported!'}); | ||
| }) | ||
| .catch((err) => { | ||
| logger.debug(`Received error on import templates and devices, ${err}. Rejecting the request`); | ||
| reject(err); | ||
| }); | ||
| }) | ||
| .catch((err) => { | ||
| logger.debug(`Received error on import flows, ${err}. Rejecting the request`); | ||
| reject(err); | ||
| }); | ||
|
|
||
| }); | ||
|
|
||
| export default { post }; |
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