VILLASweb/src/signal/signals-data-manager.js

/**
 * This file is part of VILLASweb.
 *
 * VILLASweb is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * VILLASweb is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with VILLASweb. If not, see <http://www.gnu.org/licenses/>.
 ******************************************************************************/

import RestDataManager from '../common/data-managers/rest-data-manager';
import RestAPI from "../common/api/rest-api";
import AppDispatcher from "../common/app-dispatcher";
import NotificationsDataManager from "../common/data-managers/notifications-data-manager";
import NotificationsFactory from "../common/data-managers/notifications-factory";

class SignalsDataManager extends RestDataManager{

  constructor() {
    super('signal', '/signals');
  }

  reloadConfig(token, data){
    // request in signals
    RestAPI.get(this.makeURL('/configs/' + data.configID), token).then(response => {
      AppDispatcher.dispatch({
        type: 'configs/edited',
        data: response.config
      });
    });

  }

  startAutoConfig(url, socketname, token, configID){
    // This function queries the VILLASnode API to obtain the configuration of the VILLASnode located at url
    // Endpoint: http[s]://server:port/api/v1 (to be generated based on IC API URL, port 4000)
    // data contains the request data: { action, id, (request)}
    // See documentation of VILLASnode API: https://villas.fein-aachen.org/doc/node-dev-api-node.html

    RestAPI.get(url, null).then(response => {
      AppDispatcher.dispatch({
        type: 'signals/autoconfig-loaded',
        data: response,
        token: token,
        socketname: socketname,
        configID: configID
      });
    }).catch(error => {
      AppDispatcher.dispatch({
        type: 'signals/autoconfig-error',
        error: error
      })
    })
  }

  saveSignals(nodes, token, configID, socketname){

    if(nodes.length === 0){
      NotificationsDataManager.addNotification(
        NotificationsFactory.AUTOCONF_ERROR('Failed to load nodes, VILLASnode returned empty response'));
      return;
    }

    let configured = false;
    let error = false;
    for(let nodeConfig of nodes){
      console.log("parsing node config: ", nodeConfig)
      if(!nodeConfig.hasOwnProperty("name")){
        console.warn("Could not parse the following node config because it lacks a name parameter:", nodeConfig);
      } else if(nodeConfig.name === socketname){
        if(configured){
          NotificationsDataManager.addNotification(
            NotificationsFactory.AUTOCONF_WARN('VILLASnode returned multiple node configurations for the websocket ' +
              socketname + '. This is a problem of the VILLASnode.'));
          continue;
        }
        // signals are not yet configured:
        let index_in = 1
        let index_out = 1

        if(!nodeConfig.in.hasOwnProperty("signals")){
          NotificationsDataManager.addNotification(
            NotificationsFactory.AUTOCONF_ERROR('Failed to load in signal config, no field for in signals contained in response.'));
          error = true;
        } else{

          // add all in signals
          for(let inSig of nodeConfig.in.signals) {

            if (inSig.enabled) {
              console.log("adding input signal:", inSig);

              let newSignal = {
                configID: configID,
                direction: 'in',
                name: inSig.hasOwnProperty("name") ? inSig.name : "in_" + String(index_in),
                unit: inSig.hasOwnProperty("unit") ? inSig.unit : '-',
                index: index_in,
                scalingFactor: 1.0
              };

              AppDispatcher.dispatch({
                type: 'signals/start-add',
                data: newSignal,
                token: token
              });

              index_in++;
            }
          }
        }

        if(!nodeConfig.out.hasOwnProperty("signals")){
          NotificationsDataManager.addNotification(
            NotificationsFactory.AUTOCONF_ERROR('Failed to load out signal config, no field for out signals contained in response.'));
          error=true;
        }else {

          // add all out signals

          for (let outSig of nodeConfig.out.signals) {

            if (outSig.enabled) {
              console.log("adding output signal:", outSig);
              let newSignal = {
                configID: configID,
                direction: 'out',
                name: outSig.hasOwnProperty("name") ? outSig.name : "out_" + String(index_out),
                unit: outSig.hasOwnProperty("unit") ? outSig.unit : '-',
                index: index_out,
                scalingFactor: 1.0
              };

              AppDispatcher.dispatch({
                type: 'signals/start-add',
                data: newSignal,
                token: token
              });

              index_out++;
            }
          }
        }

        console.log("Configured", index_in-1, "input signals and", index_out-1, "output signals");
        configured=true;
      } else {
        console.log("ignoring node with name ",nodeConfig.name, " expecting ", socketname )
      }


    }

    if(!error) {
      NotificationsDataManager.addNotification(NotificationsFactory.AUTOCONF_INFO());
    }

  }

}

export default new SignalsDataManager()