FM / net

/usr/local/lib/node_modules/pm2/node_modules/js-git/net/

/usr/local/lib/node_modules/pm2/node_modules/js-git/net

Name	Size	Mode	Actions
git-fetch-pack.js	5100	0644	edit dl rm
request-xhr.js	959	0644	edit dl rm
tcp-chrome-sockets.js	2573	0644	edit dl rm
tcp-node.js	1741	0644	edit dl rm
tcp-ws-proxy.js	1731	0644	edit dl rm
transport-http.js	3286	0644	edit dl rm
transport-tcp.js	1227	0644	edit dl rm

Edit: /usr/local/lib/node_modules/pm2/node_modules/js-git/net/tcp-chrome-sockets.js (2573B)

"use strict";

var makeChannel = require('culvert');
var wrapHandler = require('../lib/wrap-handler');
var tcp = window.chrome.sockets.tcp;
var runtime = window.chrome.runtime;

module.exports = connect;

function connect(host, port, onError) {
  port = port|0;
  host = String(host);
  if (!port || !host) throw new TypeError("host and port are required");

onCreate = wrap(onCreate, onError);
  onConnect = wrap(onConnect, onError);
  onInfo = wrap(onInfo, onError);
  onReceive = wrap(onReceive, onError);
  onReceiveError = wrap(onReceiveError, onError);
  onData = wrapHandler(onData, onError);
  onWrite = wrap(onWrite, onError);

var paused = false;
  var open = false;
  var socketId;

var serverChannel = makeChannel();
  var clientChannel = makeChannel();
  var socket = {
    put: serverChannel.put,
    drain: serverChannel.drain,
    take: clientChannel.take
  };

tcp.onReceive.addListener(onReceive);
  tcp.onReceiveError.addListener(onReceiveError);
  tcp.create(onCreate);

return {
    put: clientChannel.put,
    drain: clientChannel.drain,
    take: serverChannel.take
  };

function onCreate(createInfo) {
    socketId = createInfo.socketId;
    tcp.connect(socketId, host, port, onConnect);
  }

function onConnect(result) {
    if (result < 0) throw new Error(runtime.lastError.message + " Connection error");
    tcp.getInfo(socketId, onInfo);
  }

function onInfo(socketInfo) {
    if (!socketInfo.connected) {
      throw new Error("Connection failed");
    }
    open = true;
    socket.take(onData);
  }

function onReceive(info) {
    if (info.socketId !== socketId) return;
    if (socket.put(new Uint8Array(info.data)) || paused) return;
    paused = true;
    tcp.setPaused(socketId, true);
    socket.drain(onDrain);
  }

function onDrain() {
    if (!paused) return;
    paused = false;
    if (open) tcp.setPaused(socketId, false);
  }

function onReceiveError(info) {
    if (info.socketId !== socketId) return;
    open = false;
    tcp.close(socketId);
    socket.put();
    // TODO: find a way to tell close and error apart.
    // throw new Error("Code " + info.resultCode + " error while receiving.");
  }

function onData(data) {
    tcp.send(socketId, data.buffer, onWrite);
  }

function onWrite(info) {
    if (info.resultCode < 0) {
      throw new Error(runtime.lastError.message + " Error writing.");
    }
    socket.take(onData);
  }
}

function wrap(fn, onError) {
  return function () {
    try {
      return fn.apply(this, arguments);
    }
    catch (err) {
      onError(err);
    }
  };
}

cmd: