espterm-front-end/jssrc/term_upload.js

/** File upload utility */
var TermUpl = (function () {
  var lines, // array of lines without newlines
    line_i, // current line index
    fuTout, // timeout handle for line sending
    send_delay_ms, // delay between lines (ms)
    nl_str, // newline string to use
    curLine, // current line (when using fuOil)
    inline_pos; // Offset in line (for long lines)

  // lines longer than this are split to chunks
  // sending a super-ling string through the socket is not a good idea
  var MAX_LINE_LEN = 128;

  function fuOpen() {
    fuStatus("Ready...");
    Modal.show('#fu_modal', onClose);
    $('#fu_form').toggleClass('busy', false);
    Input.blockKeys(true);
  }

  function onClose() {
    console.log("Upload modal closed.");
    clearTimeout(fuTout);
    line_i = 0;
    Input.blockKeys(false);
  }

  function fuStatus(msg) {
    qs('#fu_prog').textContent = msg;
  }

  function fuSend() {
    var v = qs('#fu_text').value;
    if (!v.length) {
      fuClose();
      return;
    }

    lines = v.split('\n');
    line_i = 0;
    inline_pos = 0; // offset in line
    send_delay_ms = qs('#fu_delay').value;

    // sanitize - 0 causes overflows
    if (send_delay_ms < 0) {
      send_delay_ms = 0;
      qs('#fu_delay').value = send_delay_ms;
    }

    nl_str = {
      'CR': '\r',
      'LF': '\n',
      'CRLF': '\r\n',
    }[qs('#fu_crlf').value];

    $('#fu_form').toggleClass('busy', true);
    fuStatus("Starting...");
    fuSendLine();
  }

  function fuSendLine() {
    if (!$('#fu_modal').hasClass('visible')) {
      // Modal is closed, cancel
      return;
    }

    if (!Conn.canSend()) {
      // postpone
      fuTout = setTimeout(fuSendLine, 1);
      return;
    }

    if (inline_pos == 0) {
      curLine = lines[line_i++] + nl_str;
    }

    var chunk;
    if ((curLine.length - inline_pos) <= MAX_LINE_LEN) {
      chunk = curLine.substr(inline_pos, MAX_LINE_LEN);
      inline_pos = 0;
    } else {
      chunk = curLine.substr(inline_pos, MAX_LINE_LEN);
      inline_pos += MAX_LINE_LEN;
    }

    if (!Input.sendString(chunk)) {
      fuStatus("FAILED!");
      return;
    }

    var all = lines.length;

    fuStatus(line_i + " / " + all + " (" + (Math.round((line_i / all) * 1000) / 10) + "%)");

    if (lines.length > line_i || inline_pos > 0) {
      fuTout = setTimeout(fuSendLine, send_delay_ms);
    } else {
      closeWhenReady();
    }
  }

  function closeWhenReady() {
    if (!Conn.canSend()) {
      // stuck in XOFF still, wait to process...
      fuStatus("Waiting for Tx buffer...");
      setTimeout(closeWhenReady, 100);
    } else {
      fuStatus("Done.");
      // delay to show it
      setTimeout(function () {
        fuClose();
      }, 100);
    }
  }

  function fuClose() {
    Modal.hide('#fu_modal');
  }

  return {
    init: function () {
      qs('#fu_file').addEventListener('change', function (evt) {
        var reader = new FileReader();
        var file = evt.target.files[0];
        console.log("Selected file type: " + file.type);
        if (!file.type.match(/text\/.*|application\/(json|csv|.*xml.*|.*script.*)/)) {
          // Deny load of blobs like img - can crash browser and will get corrupted anyway
          if (!confirm("This does not look like a text file: " + file.type + "\nReally load?")) {
            qs('#fu_file').value = '';
            return;
          }
        }
        reader.onload = function (e) {
          var txt = e.target.result.replace(/[\r\n]+/, '\n');
          qs('#fu_text').value = txt;
        };
        console.log("Loading file...");
        reader.readAsText(file);
      }, false);
    },
    close: fuClose,
    start: fuSend,
    open: fuOpen,
  }
})();