mirror of
https://github.com/status-im/react-native.git
synced 2025-01-10 09:35:48 +00:00
54026024cc
Summary: Buck (our build system) currently starts multiple packager instances for each target and may build multiple targets in parallel. This means we're paying startup costs and are duplicating the work. This enables us to start one instance of the packager and connect to it via socket to do all the work that needs to be done. The way this is structured: 1. SocketServer: A server that listens on a socket path that is generated based on the server options 2. SocketClient: Interfaces with the server and exposes the operations that we support as methods 3. SocketInterface: Integration point and responsible for forking off the server
108 lines
2.7 KiB
JavaScript
108 lines
2.7 KiB
JavaScript
/**
|
|
* Copyright (c) 2015-present, Facebook, Inc.
|
|
* All rights reserved.
|
|
*
|
|
* This source code is licensed under the BSD-style license found in the
|
|
* LICENSE file in the root directory of this source tree. An additional grant
|
|
* of patent rights can be found in the PATENTS file in the same directory.
|
|
*/
|
|
'use strict';
|
|
|
|
require('babel-core/register')({
|
|
only: /react-packager\/src/
|
|
});
|
|
|
|
useGracefulFs();
|
|
|
|
var Activity = require('./src/Activity');
|
|
var Server = require('./src/Server');
|
|
var SocketInterface = require('./src/SocketInterface');
|
|
|
|
exports.middleware = function(options) {
|
|
var server = new Server(options);
|
|
return server.processRequest.bind(server);
|
|
};
|
|
|
|
exports.Activity = Activity;
|
|
|
|
// Renamed "package" to "bundle". But maintain backwards
|
|
// compat.
|
|
exports.buildPackage =
|
|
exports.buildBundle = function(options, bundleOptions) {
|
|
var server = createServer(options);
|
|
return server.buildBundle(bundleOptions)
|
|
.then(function(p) {
|
|
server.end();
|
|
return p;
|
|
});
|
|
};
|
|
|
|
exports.buildPackageFromUrl =
|
|
exports.buildBundleFromUrl = function(options, reqUrl) {
|
|
var server = createServer(options);
|
|
return server.buildBundleFromUrl(reqUrl)
|
|
.then(function(p) {
|
|
server.end();
|
|
return p;
|
|
});
|
|
};
|
|
|
|
exports.getDependencies = function(options, main) {
|
|
var server = createServer(options);
|
|
return server.getDependencies(main)
|
|
.then(function(r) {
|
|
server.end();
|
|
return r.dependencies;
|
|
});
|
|
};
|
|
|
|
exports.createClientFor = function(options) {
|
|
return SocketInterface.getOrCreateSocketFor(options);
|
|
};
|
|
|
|
process.on('message', function(m) {
|
|
if (m && m.type && m.type === 'createSocketServer') {
|
|
console.log('server got ipc message', m);
|
|
var options = m.data.options;
|
|
|
|
// regexp doesn't naturally serialize to json.
|
|
options.blacklistRE = new RegExp(options.blacklistRE.source);
|
|
|
|
SocketInterface.createSocketServer(
|
|
m.data.sockPath,
|
|
m.data.options
|
|
).then(
|
|
function() {
|
|
console.log('succesfully created server', m);
|
|
process.send({ type: 'createdServer' });
|
|
},
|
|
function(error) {
|
|
console.log('error creating server', error.code);
|
|
if (error.code === 'EADDRINUSE') {
|
|
// Server already listening, this may happen if multiple
|
|
// clients where started in quick succussion (buck).
|
|
process.send({ type: 'createdServer' });
|
|
} else {
|
|
throw error;
|
|
}
|
|
}
|
|
).done();
|
|
}
|
|
});
|
|
|
|
function useGracefulFs() {
|
|
var fs = require('fs');
|
|
var gracefulFs = require('graceful-fs');
|
|
gracefulFs.gracefulify(fs);
|
|
}
|
|
|
|
function createServer(options) {
|
|
Activity.disable();
|
|
// Don't start the filewatcher or the cache.
|
|
if (options.nonPersistent == null) {
|
|
options.nonPersistent = true;
|
|
}
|
|
|
|
return new Server(options);
|
|
}
|