Commit d657a08

const server = require('./src/server');

const isDev = true;

server.setup({ projectDir, entryFile, webpackConfigFile, clientPort }, isDev);

"portscanner": "^2.2.0",

module.exports = {"name":"codecrumbs","version":"1.0.12-alpha","author":"Bohdan Liashenko","license":"BSD-3-Clause","repository":{"type":"git","url":"https://github.com/Bogdan-Lyashenko/codecrumbs.git"},"scripts":{"start":"yarn client-dev & yarn server-dev","start:demo":"node ./index.dev.js","client-dev":"cd src/public && webpack --config webpack.dev.js --progress --colors --watch --env dev","server-dev":"nodemon ./index.dev.js","server-debug":"nodemon --inspect ./index.dev.js","build":"cd src/public && webpack --config webpack.prod.js --progress --colors","start:standalone":"cd src/public/dist/standalone && http-server","pretty":"prettier --write \"./src/public/js/**/*.js\""},"bin":{"codecrumbs":"./cli/index.cli.js"},"dependencies":{"@babel/parser":"^7.1.2","@babel/polyfill":"^7.0.0","@babel/traverse":"^7.1.0","antd":"^3.9.2","chokidar":"^2.0.3","classnames":"^2.2.6","colors":"^1.3.2","commander":"^2.19.0","copy-text-to-clipboard":"^1.0.4","d3-flextree":"^2.1.1","directory-tree":"^2.1.0","file-saver":"^2.0.0","http-server":"^0.11.1","js2flowchart":"^1.1.7","lodash":"^4.17.10","lodash.debounce":"^4.0.8","madge":"^3.3.0","portscanner":"^2.2.0","react":"^16.7.0","react-dom":"^16.7.0","react-draggable":"^3.0.5","react-redux":"^5.0.7","react-syntax-highlighter":"8.0.1","redux":"^4.0.0","redux-persist":"^5.10.0","redux-saga":"^0.16.0","redux-thunk":"^2.2.0","reselect":"^4.0.0","websocket":"^1.0.26"},"devDependencies":{"@babel/core":"^7.1.2","@babel/plugin-syntax-dynamic-import":"^7.2.0","@babel/preset-env":"^7.1.0","@babel/preset-react":"^7.0.0","babel-loader":"^8.0.4","babel-plugin-import":"^1.9.1","css-loader":"^0.28.11","node-sass":"^4.9.3","nodemon":"^1.18.7","prettier":"^1.14.0","sass-loader":"^7.1.0","style-loader":"^0.21.0","webpack":"^4.20.2","webpack-bundle-analyzer":"^3.0.3","webpack-cli":"^3.1.2","webpack-merge":"^4.1.5"},"nodemonConfig":{"ignore":["src/public/**/*.*"],"delay":"2500"}};

ws.onopen = () => {

// connection is opened and ready to use

};

ws.onerror = error => {

// an error occurred when sending/receiving data

};

: '/bundle/';

const portscanner = require('portscanner');

const httpServer = require('http-server');

const { SERVER_PORT } = require('../shared/constants');

const mediator = require('./mediator');

const sourceServer = require('./instance');

const PORT_IN_USE = 'open';

const HOST = '127.0.0.1';

const setup = ({ projectDir, entryFile, webpackConfigFile, clientPort }, isDev) => {

Promise.all([

portscanner.checkPortStatus(clientPort, HOST).then(status => {

if (status !== PORT_IN_USE) {

/**

mediator.run({ port: SERVER_PORT });

}

}),

portscanner.checkPortStatus(clientPort, HOST).then(status => {

if (status !== PORT_IN_USE) {

/**

httpServer

.createServer({ root: './src/public/dist/local', cache: isDev ? -1 : 3600 })

.listen(clientPort, HOST, () => {

console.log(`"Codecrumbs" client is served on http://localhost:${clientPort}`);

});

}

})

]).then(() => {

//sourceServer instances are same socket "client" as browser client

//to communicate they need to send message to all, and filter by type

/**

sourceServer.run(`${HOST}:${SERVER_PORT}`, {

projectDir,

entryFile,

webpackConfigFile,

clientPort

setup

const WebSocketClient = require('websocket').client;

const api = require('./api/');

const projectSourceWatcher = require('./project-source/');

const { SOCKET_EVENT_TYPE } = require('../shared/constants');

const run = (mediatorEndPoint, { projectDir, entryFile, webpackConfigFile, clientPort }) => {

const webSocketClient = new WebSocketClient();

webSocketClient.on('connectFailed', error => {

console.log('Connect Error: ' + error);

});

webSocketClient.on('connect', connection => {

console.log(`Source server created for: ${projectDir}, entry point: ${entryFile}`);

connection.on('message', message => {

if (message.type === 'utf8') {

//console.log('mediator received msg', message.utf8Data)

}

});

projectSourceWatcher.subscribeOnChange(projectDir, entryFile, webpackConfigFile, {

onInit: data =>

connection.sendUTF(

JSON.stringify({

type: SOCKET_EVENT_TYPE.INIT_SOURCE_FILES_SYNC,

data

})

),

onChange: data =>

connection.sendUTF(

JSON.stringify({

type: SOCKET_EVENT_TYPE.UPDATE_SOURCE_FILE_SYNC,

data

})

)

});

});

webSocketClient.connect(`ws://${mediatorEndPoint}/`);

module.exports = {

run

const WebSocketServer = require('websocket').server;

const http = require('http');

const run = ({ port }) => {

const httpServer = http.createServer((request, response) => {

console.log('http call to mediator', request.url);

});

httpServer.listen(port, () => {

console.log(`Mediator server is listening: ${port}.`);

});

const webSocketServer = new WebSocketServer({ httpServer });

webSocketServer.on('request', request => {

const connection = request.accept(null, request.origin);

console.log('some client connects to mediator');

connection.on('message', message => {

if (message.type === 'utf8') {

//console.log('mediator received msg', message.utf8Data)

}

});

connection.on('close', connection => {

// close user connection

});

connection.sendUTF(

JSON.stringify({

type: 'connected!'

})

);

});

module.exports = {

run