!7

cmodule VectorImageStream > DynImageSurfaceAndEnabled {
  transient S fpsText;
  transient new PerSecondCounter fpsCounter;
  transient JButton btnStartStream;
  
  start {
    set zoomToWindowOnSetImage;
    dm_vmBus_onMessage_q vectorSDK_gotLine((mod, s) -> handleLine((S) s));
    dm_doEvery(1.0, r {
      double fps = fpsCounter.getLast();
      setField(fpsText := formatDoubleX(fps, 1) + " fps");
      enableButton(btnStartStream, fps == 0);
    });
    dm_registerAs_direct vectorCamStream();
    dm_vmBus_onMessageAndNow vectorSDK_connected(rThread startStream);
  }
  
  void handleLine(S s) {
    S prefix = "img: ";
    if (!enabled || !startsWith(s, prefix)) ret;
    fpsCounter.inc();
    BufferedImage img = imageFromBytes(base64decode(substring(s, prefix)));
    vmBus_send haveVectorImage(module(), img);
    setImage(img);
  }
  
  void startStream enter {
    dm_call vectorSDK('startCamStream);
  }
  
  JPanel makeControlArea() {
    JPanel buttons = super.makeControlArea();
    enableDoubleBuffering(); // flickers when partially obscured otherwise
    addComponents_inFront(buttons,
      btnStartStream = jbutton("Start", rThread startStream));
    ret westCenterAndEastWithMargin(
      jbutton("Snapshot", rThread snapshot),
      dm_rightAlignedLabel fpsText(), buttons);
  }
  
  void snapshot enter {
    File f = vectorCamDir("vector-" + ymd_minus_hms_minus_millis() + ".jpg");
    saveJPEG(f, getImage());
    copyFileToClipboard(f);
    printFileInfo(f);
  }
  
  // API
  
  BufferedImage getLatestVectorImage() {
    ret getImage();
  }
}