Проект WebPack с функциональностью сервера

Question

http://wiki.bitplan.com/index.php/Dash описывает программное обеспечение для моделирования автомобиля https://github.com/mattbradley/dash, которое я собираюсь интегрировать с https://github.com/rc-dukes/dukes, как было запрошено в https://github.com/rc-dukes/dukes/issues/37.

Цель состоит в том, чтобы отправить изображение драйвера в программное обеспечение r c -dukes и позволить управлять движениями в симуляторе из r c -dukes через vert. х команд шины.

При разговоре с «настоящей» машиной - изображения передаются через http как mjpeg-stream на этом этапе.

Теперь Da sh - это проект, основанный на веб-пакетах, поэтому он предназначен для работы в качестве клиента в браузере даже из протокола file: //.

Теперь я хотел бы создать его версию, которая имеет функциональность веб-сервера и использует vert.x для связи с остальной частью проекта r c -dukes.

Сначала у меня было неправильное представление о простом добавлении WebServer и использовании require http и fs, что привело к довольно большому количеству SO вопросов о том, как интегрировать узел с WebServer - в конце концов, это не кажется хорошим маршрутом до go, поскольку это нарушит первоначальную идею базового проекта da sh.

Теперь я хотел бы «по желанию» иметь функциональность сервера в проекте.

Разделение проекта на версию сервера / клиента не кажется хорошей идеей.

Соответствующий текущий коммит вы найдете в https://github.com/rc-dukes/dash/commit/ea616a38 Соответствующие строки

  // import WebServer from "./remote/WebServer"

  //this.videoServer=new WebServer(8234);
  //this.videoServer.start()

в настоящее время закомментированы

Что будет лучший дизайн?

Я предполагаю, что лучшим вариантом будет отправка изображений через vert.x.

Answer 1

Вертикальный подход работает хорошо.

Обратные вызовы для сердцебиения и отправки изображений

/**
   * call back when a vert.x heartbeat is received
   * @param self - the true this pointer for class Simulator
   * @param heartBeatCount - the number of heart beats received so far
   */
  onHeartBeat(self,heartBeatCount) {
    var color=heartBeatCount/3%2==0?"white":"purple";
    self.setColorAndTitle("heartbeat-icon",color,heartBeatCount.toString());
    // reply with the current image
    self.onSendImage(self);
  }

  /**
   * call back to send current Three.js canvas over the vert.x wire
   * @param self - the true this pointer for class Simulator
   */
  onSendImage(self) {
    // https://stackoverflow.com/a/26197858/1497139
    var strMime = "image/jpeg";
    var imgData = this.renderer.domElement.toDataURL(strMime);
    self.remoteController.sendImage(imgData);
  }

Vert.x javascript Vertical для связи с Java Сервером сторона

// part of https://github.com/rc-dukes/dash fork of https://github.com/mattbradley/dash

const CALLSIGN_FLASH = "Velvet ears"; // Watchdog
const CALLSIGN_BO = "Lost sheep Bo";  // Car
const CALLSIGN_ROSCO = "Red Dog"; // Debug ImageView server
var simulatorVerticle = null;

/**
 * SimulatorVerticle to be used as remoteController
 */
export default class SimulatorVerticle {

  /**
   * construct me
   * @param busUrl
   * @param self
   * @param onHeartBeat
   */
  constructor(busUrl,self=null,onHeartBeat=null) {
    this.busUrl=busUrl;
    this.self=self;
    this.onHeartBeat=onHeartBeat;
    this.heartBeatCount=0;
    this.debugHeartBeat=true;
    this.remoteControl=new RemoteControl();
    simulatorVerticle=this;
    this.enabled=false;
  }

  /**
   * all publish messages should go thru this function
   *
   * @param address
   * @param message
   * @param headers
   */
  publish(address,message,headers) {
    if (this.eb.state===EventBus.OPEN)
      this.eb.publish(address, message, headers);
  };

  /**
   * send the given image to the debug image server
   * @param imgData
   */
  sendImage(imgData) {
    this.publish(CALLSIGN_ROSCO+":SIMULATOR_IMAGE",imgData);
  }

  /**
   * start the verticle and register the handlers
   */
  start() {
    if (!this.eb) {
      this.eb = new EventBus(this.busUrl);
      this.eb.onopen = function() {
        simulatorVerticle.eb.registerHandler(CALLSIGN_FLASH,simulatorVerticle.heartBeatHandler);
        simulatorVerticle.eb.registerHandler(CALLSIGN_BO,simulatorVerticle.carMessageHandler)
      };
    };
    this.enabled=true;
  }

  stop() {
    if (this.eb)
      this.eb.close();
    this.eb=null;
    this.enabled=false;
  }

  /**
   * handle a car message
   * @param err - potential errors
   * @param msg - the vert.x message
   */
  carMessageHandler(err,msg) {
    var carjo=msg.body;
    console.log(JSON.stringify(carjo));
    var sv=simulatorVerticle;
    switch (carjo.type) {
      case 'servodirect':
        if (carjo.position) {
          // the position can be between -100 and 100
          var pos=parseFloat(carjo.position);
          // we need a value between -1 and +1
          sv.remoteControl.steer=pos/100;
        }
      break;
      case 'servo':
         switch (carjo.position) {
           case 'left':
             sv.remoteControl.steer-=0.01;
           break;
           case 'right':
             sv.remoteControl.steer+=0.01;
           break;
           case 'center':
             sv.remoteControl.steer=0;
           break;
         }
      break;
      case 'motor':
         switch (carjo.speed) {
           case 'up':
             sv.remoteControl.gas+=0.01;
           break;
           case 'down':
             sv.remoteControl.gas-=0.01;
           break;
           case 'brake':
             sv.remoteControl.break+=0.01;
           break;
           case 'stop':
             sv.remoteControl.gas=0;
             sv.remoteControl.break=1;
           break;
         }
      break;
    }
  }

  /**
   * handle a heart beat message
   * @param err - potential errors
   * @param msg - the vert.x message
   */
  heartBeatHandler(err,msg) {
    var jo=msg.body;
    var sv=simulatorVerticle;
    if (sv.debugHeartBeat)
       console.log(JSON.stringify(jo));
    sv.heartBeatCount++;
    if (sv.onHeartBeat && sv.self) {
      sv.onHeartBeat(sv.self,sv.heartBeatCount);
    }
  }

  stateColor() {
    var stateColor = "white";
    if (this.eb) {
      switch (this.eb.state) {
      case EventBus.CONNECTING:
        stateColor = "orange";
        break;
      case EventBus.OPEN:
        stateColor = "green";
        break;
      case EventBus.CLOSING:
        stateColor = "orange";
        break;
      case EventBus.CLOSED:
        stateColor = "red";
        break;
      }
    } else {
      stateColor = "violet";
    }
    return stateColor;
  }
}

export class RemoteControl {
  /**
   * @param gas
   * @param brake
   * @param steer
   */
  constructor(gas=0,brake=0,steer=0) {
    this.gas=0;
    this.brake=0;
    this.steer=0;
  }
}