#!/usr/bin/env node
-process.mixin(require("/utils.js"));
+process.mixin(require('sys'));
puts("Welcome to the Node.js REPL.");
puts("Enter ECMAScript at the prompt.");
puts("Tip 1: Use 'rlwrap node-repl' for a better interface");
puts("Tip 2: Type Control-D to exit.");
-require("/repl.js").start();
+require('repl').start();
// vim:ft=javascript
World":
----------------------------------------
-var sys = require("/sys.js"),
- http = require("/http.js");
+var sys = require("sys"),
+ http = require("http");
http.createServer(function (request, response) {
response.sendHeader(200, {"Content-Type": "text/plain"});
response.sendBody("Hello World\n");
A listener on this event should not try to perform
I/O since the process will forcibly exit in less
than microsecond. However, it is a good hook to
- perform constant time checks of the module's
+ perform constant time checks of the module"s
state (like for unit tests).
+
The parameter +code+ is the integer exit code
share structure with the original object(s).
+
Undefined properties are not copied. However, properties inherited from the
-object's prototype will be copied over.
+object"s prototype will be copied over.
=== System module
-These function are in +"/sys.js"+. Use +require("/sys.js")+ to access them.
+These function are in the module +"sys"+. Use +require("sys")+ to access
+them.
+puts(string)+::
Outputs the +string+ and a trailing new-line to +stdout+.
in a promise callback.
+
----------------------------------------
-var sys = require("/sys.js");
+var sys = require("sys");
sys.exec("ls /").addCallback(function (stdout, stderr) {
puts(stdout);
});
If you created the promise (by doing +new process.Promise()+) then call
+emitSuccess+ to emit the +"success"+ event with the given arguments.
+
-(+promise.emit("success", arg1, arg2, ...)+ should also work, but doesn't at
+(+promise.emit("success", arg1, arg2, ...)+ should also work, but doesn"t at
the moment due to a bug; use +emitSuccess+ instead.)
+promise.emitError(arg1, arg2, ...)+ ::
+
----------------------------------------
promise.addErrback(function(e) {
- if (e instanceof Error && e.message === 'timeout') {
+ if (e instanceof Error && e.message === "timeout") {
// handle timeout
} else {
// handle regular error
+
*IMPORTANT* +promise.wait()+ is not a true fiber/coroutine. If any other
promises are created and made to wait while the first promise waits, the
-first promise's wait will not return until all others return. The benefit of
+first promise"s wait will not return until all others return. The benefit of
this is a simple implementation and the event loop does not get blocked.
Disadvantage is the possibility of situations where the promise stack grows
infinitely large because promises keep getting created and keep being told
=== Modules
+Node uses the CommonJS module system
+
Node has a simple module loading system. In Node, files and modules are in
one-to-one correspondence. As an example, +foo.js+ loads the module
-+circle.js+.
++circle.js+ in the same directory.
The contents of +foo.js+:
----------------------------------------
-var circle = require("circle.js"),
- sys = require("/sys.js");
+var circle = require("./circle"),
+var sys = require("sys");
sys.puts("The area of a circle of radius 4 is " + circle.area(4));
----------------------------------------
+circumference()+. To export an object, add to the special +exports+
object. (Alternatively, one can use +this+ instead of +exports+.) Variables
local to the module will be private. In this example the variable +PI+ is
-private to +circle.js+. The function +puts()+ comes from the module
-+"/sys.js"+.
+private to +circle.js+. The function +puts()+ comes from the module +"sys"+,
+which is a built-in module. Modules which are not prefixed by +"./"+ are
+built-in module--more about this later.
-The module path is relative to the file calling +require()+. That is,
-+circle.js+ must be in the same directory as +foo.js+ for +require()+ to
-find it.
+A module prefixed with +"./"+ is relative to the file calling +require()+.
+That is, +circle.js+ must be in the same directory as +foo.js+ for
++require("./circle")+ to find it.
-Use +process.mixin()+ to include modules into the global namespace.
-
-----------------------------------------
-process.mixin(process, require("circle.js"), require("/sys.js"));
-puts("The area of a cirlce of radius 4 is " + area(4));
-----------------------------------------
-
-When an absolute path is given to +require()+, like
-+require("/mjsunit.js")+ the module is searched for in the
-+require.paths+ array. +require.paths+ on my system looks like this:
+Without the leading +"./"+, like +require("mjsunit")+ the module is searched
+for in the +require.paths+ array. +require.paths+ on my system looks like
+this:
----------------------------------------
[ "/home/ryan/.node_libraries"
-, "/home/ryan/local/node/lib/node_libraries"
-, "/"
+, "/usr/local/lib/node/libraries"
]
----------------------------------------
-That is, first Node looks for +"/home/ryan/.node_libraries/mjsunit.js"+ and
-then for +"/home/ryan/local/node/lib/node_libraries/mjsunit.js"+. If not
-found, it finally looks for +"/mjsunit.js"+ (in the root directory).
+That is, when +require("mjsunit")+ is called Node looks for
+
+ 1. +"/home/ryan/.node_libraries/mjsunit.js"+
+
+ 2. +"/home/ryan/.node_libraries/mjsunit.node"+
+
+ 3. +"/home/ryan/.node_libraries/mjsunit/index.js"+
+
+ 4. +"/home/ryan/.node_libraries/mjsunit/index.node"+
+
+ 5. +"/usr/local/lib/node/libraries/mjsunit.js"+
+
+ 6. +"/usr/local/lib/node/libraries/mjsunit.node"+
+
+ 7. +"/usr/local/lib/node/libraries/mjsunit/index.js"+
+
+ 8. +"/usr/local/lib/node/libraries/mjsunit/index.node"+
+
+interrupting once a file is found. Files ending in +".node"+ are binary Addon
+Modules; see the section below about addons. +"index.js"+ allows one to
+package a module as a directory.
+require.paths+ can be modified at runtime by simply unshifting new
-paths on to it and at startup with the +NODE_LIBRARY_PATHS+ environmental
+paths on to it and at startup with the +NODE_PATH+ environmental
variable (which should be a list of paths, colon separated).
-Node comes with several libraries which are installed when +"make install"+
-is run. These are currently undocumented, but do look them up in your
-system.
+Use +process.mixin()+ to include modules into the global namespace.
+
+----------------------------------------
+process.mixin(GLOBAL, require("./circle"), require("sys"));
+puts("The area of a cirlce of radius 4 is " + area(4));
+----------------------------------------
=== Child Processes
Node provides a tridirectional +popen(3)+ facility through the class
-+process.ChildProcess+. It is possible to stream data through the child's +stdin+,
++process.ChildProcess+. It is possible to stream data through the child"s +stdin+,
+stdout+, and +stderr+ in a fully non-blocking way.
==== +process.ChildProcess+
+child.write(data, encoding="ascii")+ ::
-Write data to the child process's +stdin+. The second argument is optional and
+Write data to the child process"s +stdin+. The second argument is optional and
specifies the encoding: possible values are +"utf8"+, +"ascii"+, and
+"binary"+.
+child.close()+ ::
-Closes the process's +stdin+ stream.
+Closes the process"s +stdin+ stream.
+child.kill(signal="SIGTERM")+ ::
=== POSIX module
File I/O is provided by simple wrappers around standard POSIX functions. To
-use this module do +require("/posix.js")+.
+use this module do +require("posix")+.
All POSIX wrappers have a similar form. They return a promise
(+process.Promise+). Example of deleting a file:
------------------------------------------------------------------------------
-var posix = require("/posix.js"),
- sys = require("/sys.js");
+var posix = require("posix"),
+ sys = require("sys");
var promise = posix.unlink("/tmp/hello");
=== HTTP
-To use the HTTP server and client one must +require("/http.js")+.
+To use the HTTP server and client one must +require("http")+.
The HTTP interfaces in Node are designed to support many features
of the protocol which have been traditionally difficult to use.
}
----------------------------------------
-In order to support the full spectrum of possible HTTP applications, Node's
+In order to support the full spectrum of possible HTTP applications, Node"s
HTTP API is very low-level. It deals with connection handling and message
parsing only. It parses a message into headers and body but it does not
parse the actual headers or the body.
+
The first time +sendBody+ is called, it will send the buffered header
information and the first body to the client. The second time
-+sendBody+ is called, Node assumes you're going to be streaming data, and
++sendBody+ is called, Node assumes you"re going to be streaming data, and
sends that seperately. That is, the response is buffered up to the
first chunk of body.
=== Multipart Parsing
A library to parse HTTP requests with +multipart/form-data+ is included with
-Node. To use it, +require("/multipart.js")+.
+Node. To use it, +require("multipart")+.
+multipart.parse(options)+ ::
- on success: Returns an object where each key holds the value of one part of
the stream. +options+ can either be an instance of
- +http.ServerRequest+ or an object containing a 'boundary' and a
- 'data' key.
+ +http.ServerRequest+ or an object containing a "boundary" and a
+ "data" key.
- on error: no parameters.
==== +multipart.Stream+
Here is an example for parsing a +multipart/form-data+ request:
----------------------------------------
-var multipart = require('/multipart.js');
+var multipart = require("multipart");
var stream = new multipart.Stream(options);
var parts = {};
-stream.addListener('part', function (part) {
- var name = part.headers['Content-Disposition'].name;
- var buffer = '';
+stream.addListener("part", function (part) {
+ var name = part.headers["Content-Disposition"].name;
+ var buffer = "";
- part.addListener('body', function(chunk) {
+ part.addListener("body", function(chunk) {
buffer = buffer + chunk;
});
- part.addListener('complete', function() {
+ part.addListener("complete", function() {
parts[name] = buffer;
});
});
-stream.addListener('complete', function() {
+stream.addListener("complete", function() {
// The parts object now contains all parts and data
});
----------------------------------------
=== TCP
-To use the TCP server and client one must +require("/tcp.js")+.
+To use the TCP server and client one must +require("tcp")+.
==== +tcp.Server+
on port 7000
----------------------------------------
-var tcp = require("/tcp.js");
+var tcp = require("tcp");
var server = tcp.createServer(function (socket) {
socket.setEncoding("utf8");
socket.addListener("connect", function () {
=== DNS module
-Use +require("/dns.js")+ to access this module
+Use +require("dns")+ to access this module
Here is an example of which resolves +"www.google.com"+ then reverse
resolves the IP addresses which are returned.
-------------------------------------------------------------------------
-var dns = require("/dns.js");
+var dns = require("dns");
var resolution = dns.resolve4("www.google.com");
includable in other programs.
The standalone REPL is called +node-repl+ and is installed at
-+$PREFIX/bin/node-repl+. It's recommended to use it with the program
++$PREFIX/bin/node-repl+. It"s recommended to use it with the program
+rlwrap+ for a better user interface. I set
------------------------------------
alias node-repl="rlwrap node-repl"
The library is called +/repl.js+ and it can be used like this:
------------------------------------
-var sys = require("/sys.js"),
- tcp = require("/tcp.js"),
- repl = require("/repl.js");
+var sys = require("sys"),
+ tcp = require("tcp"),
+ repl = require("repl");
nconnections = 0;
tcp.createServer(function (c) {
sys.error("Connection!");
- Others. Look in +deps/+ for what else is available.
Node statically compiles all its dependencies into the executable. When
-compiling your module, you don't need to worry about linking to any of these
+compiling your module, you don"t need to worry about linking to any of these
libraries.
-To get started let's make a small Addon which does the following except in
+To get started let"s make a small Addon which does the following except in
C++:
-----------------------------------------------------
exports.hello = "world";
do this we create a file called +wscript+ which is python code and looks
like this:
-----------------------------------------------------
-srcdir = '.'
-blddir = 'build'
-VERSION = '0.0.1'
+srcdir = "."
+blddir = "build"
+VERSION = "0.0.1"
def set_options(opt):
- opt.tool_options('compiler_cxx')
+ opt.tool_options("compiler_cxx")
def configure(conf):
- conf.check_tool('compiler_cxx')
- conf.check_tool('node_addon')
+ conf.check_tool("compiler_cxx")
+ conf.check_tool("node_addon")
def build(bld):
- obj = bld.new_task_gen('cxx', 'shlib', 'node_addon')
- obj.target = 'hello'
+ obj = bld.new_task_gen("cxx", "shlib", "node_addon")
+ obj.target = "hello"
obj.source = "hello.cc"
-----------------------------------------------------
Running +node-waf configure build+ will create a file
</p>
<pre>
-var sys = require("/sys.js"),
- http = require("/http.js");
+var sys = require('sys'),
+ http = require('http');
http.createServer(function (req, res) {
setTimeout(function () {
- res.sendHeader(200, {"Content-Type": "text/plain"});
- res.sendBody("Hello World");
+ res.sendHeader(200, {'Content-Type': 'text/plain'});
+ res.sendBody('Hello World');
res.finish();
}, 2000);
}).listen(8000);
-sys.puts("Server running at http://127.0.0.1:8000/");</pre>
+sys.puts('Server running at http://127.0.0.1:8000/');</pre>
</pre>
<p>
-var posix = require("/posix.js");
+var posix = require("./posix");
/*jslint onevar: true, undef: true, eqeqeq: true, plusplus: true, regexp: true, newcap: true, immed: true */
/*globals exports, node, __filename */
-var sys = require("/sys.js");
+var sys = require('sys');
var CRLF = "\r\n";
var STATUS_CODES = {
// A repl library that you can include in your own code to get a runtime
// interface to your program. Just require("/repl.js").
-var sys = require("/sys.js");
+var sys = require('sys');
sys.puts("Type '.help' for options.");
-process.fs.exists = function (path, callback) {
- var p = process.fs.stat(path);
- p.addCallback(function () { callback(true); });
- p.addErrback(function () { callback(false); });
-};
process.fs.cat = function (path, encoding) {
var promise = new process.Promise();
+(function () { // annonymous namespace
+
+// deprecation errors
+
+GLOBAL.include = function () {
+ throw new Error("include() has been removed. Use process.mixin(process, require(file)) to get the same effect.");
+};
+
+GLOBAL.puts = function () {
+ throw new Error("puts() has moved. Use require('/sys.js') to bring it back.");
+}
+
+GLOBAL.print = function () {
+ throw new Error("print() has moved. Use require('/sys.js') to bring it back.");
+}
+
+GLOBAL.p = function () {
+ throw new Error("p() has moved. Use require('/sys.js') to bring it back.");
+}
+
+process.debug = function () {
+ throw new Error("process.debug() has moved. Use require('/sys.js') to bring it back.");
+}
+
+process.error = function () {
+ throw new Error("process.error() has moved. Use require('/sys.js') to bring it back.");
+}
+
process.tcp.createServer = function () {
throw new Error("process.tcp.createServer() has moved. Use require('/tcp.js') to access it.");
};
process.createProcess = function () {
- throw "process.createProcess() has been changed to process.createChildProcess() update your code";
-};
-
-process.createChildProcess = function (file, args, env) {
- var child = new process.ChildProcess();
- args = args || [];
- env = env || process.ENV;
- var envPairs = [];
- for (var key in env) {
- if (env.hasOwnProperty(key)) {
- envPairs.push(key + "=" + env[key]);
- }
- }
- // TODO Note envPairs is not currently used in child_process.cc. The PATH
- // needs to be searched for the 'file' command if 'file' does not contain
- // a '/' character.
- child.spawn(file, args, envPairs);
- return child;
+ throw new Error("process.createProcess() has been changed to process.createChildProcess() update your code");
};
process.exec = function () {
throw new Error("process.tcp.createConnection() has moved. Use require('/tcp.js') to access it.");
};
-include = function () {
- throw new Error("include() has been removed. Use process.mixin(process, require(file)) to get the same effect.");
-}
-/* From jQuery.extend in the jQuery JavaScript Library v1.3.2
- * Copyright (c) 2009 John Resig
- * Dual licensed under the MIT and GPL licenses.
- * http://docs.jquery.com/License
- */
+
+
+process.createChildProcess = function (file, args, env) {
+ var child = new process.ChildProcess();
+ args = args || [];
+ env = env || process.ENV;
+ var envPairs = [];
+ for (var key in env) {
+ if (env.hasOwnProperty(key)) {
+ envPairs.push(key + "=" + env[key]);
+ }
+ }
+ // TODO Note envPairs is not currently used in child_process.cc. The PATH
+ // needs to be searched for the 'file' command if 'file' does not contain
+ // a '/' character.
+ child.spawn(file, args, envPairs);
+ return child;
+};
+
+// From jQuery.extend in the jQuery JavaScript Library v1.3.2
+// Copyright (c) 2009 John Resig
+// Dual licensed under the MIT and GPL licenses.
+// http://docs.jquery.com/License
process.mixin = function() {
// copy reference to target object
var target = arguments[0] || {}, i = 1, length = arguments.length, deep = false, options;
return target;
};
+
+
// Signal Handlers
-(function () { // anonymous namespace
+function isSignal (event) {
+ return event.slice(0, 3) === 'SIG' && process.hasOwnProperty(event);
+};
- function isSignal (event) {
- return event.slice(0, 3) === 'SIG' && process.hasOwnProperty(event);
- };
+process.addListener("newListener", function (event) {
+ if (isSignal(event) && process.listeners(event).length === 0) {
+ var handler = new process.SignalHandler(process[event]);
+ handler.addListener("signal", function () {
+ process.emit(event);
+ });
+ }
+});
- process.addListener("newListener", function (event) {
- if (isSignal(event) && process.listeners(event).length === 0) {
- var handler = new process.SignalHandler(process[event]);
- handler.addListener("signal", function () {
- process.emit(event);
- });
- }
- });
-})(); // anonymous namespace
// Timers
-function setTimeout (callback, after) {
+GLOBAL.setTimeout = function (callback, after) {
var timer = new process.Timer();
timer.addListener("timeout", callback);
timer.start(after, 0);
return timer;
}
-function setInterval (callback, repeat) {
+GLOBAL.setInterval = function (callback, repeat) {
var timer = new process.Timer();
timer.addListener("timeout", callback);
timer.start(repeat, repeat);
return timer;
}
-function clearTimeout (timer) {
+GLOBAL.clearTimeout = function (timer) {
timer.stop();
}
-clearInterval = clearTimeout;
+GLOBAL.clearInterval = GLOBAL.clearTimeout;
+
+
+
-// Module
+// Modules
-process.libraryPaths = [ process.path.join(process.ENV["HOME"], ".node_libraries")
- , process.path.join(process.installPrefix, "lib/node/libraries")
- , "/"
- ];
+var debugLevel = 0;
+if ("NODE_DEBUG" in process.ENV) debugLevel = 1;
-if (process.ENV["NODE_LIBRARY_PATHS"]) {
- process.libraryPaths =
- process.ENV["NODE_LIBRARY_PATHS"].split(":").concat(process.libraryPaths);
+function debug (x) {
+ if (debugLevel > 0) {
+ process.stdio.writeError(x + "\n");
+ }
}
-process.Module = function (filename, parent) {
- process.assert(filename.charAt(0) == "/");
- this.filename = filename;
+
+// private constructor
+function Module (name, parent) {
+ this.name = name;
this.exports = {};
this.parent = parent;
+ this.filename = null;
this.loaded = false;
this.loadPromise = null;
this.exited = false;
this.children = [];
};
-process.Module.cache = {};
+var moduleCache = {};
-(function () {
- function retrieveFromCache (loadPromise, fullPath, parent) {
- var module;
- if (fullPath in process.Module.cache) {
- module = process.Module.cache[fullPath];
- setTimeout(function () {
- loadPromise.emitSuccess(module.exports);
- }, 0);
- } else {
- module = new process.Module(fullPath, parent);
- process.Module.cache[fullPath] = module;
- module.load(loadPromise);
- }
+function createModule (name, parent) {
+ if (name in moduleCache) {
+ debug("found " + JSON.stringify(name) + " in cache");
+ return moduleCache[name];
}
+ debug("didn't found " + JSON.stringify(name) + " in cache. creating new module");
+ var m = new Module(name, parent);
+ moduleCache[name] = m;
+ return m;
+};
- function findPath (path, dirs, callback) {
- process.assert(path.charAt(0) == "/");
- process.assert(dirs.constructor == Array);
+function createInternalModule (name, constructor) {
+ var m = createModule(name);
+ constructor(m.exports);
+ m.loaded = true;
+ return m;
+};
- if (dirs.length == 0) {
- callback();
- } else {
- var dir = dirs[0];
- var rest = dirs.slice(1, dirs.length);
-
- var fullPath = process.path.join(dir, path);
- process.fs.exists(fullPath, function (doesExist) {
- if (doesExist) {
- callback(fullPath);
- } else {
- findPath(path, rest, callback);
- }
- });
- }
- }
+var pathModule = createInternalModule("path", function (exports) {
+ exports.join = function () {
+ var joined = "";
+ for (var i = 0; i < arguments.length; i++) {
+ var part = arguments[i].toString();
- process.loadModule = function (requestedPath, exports, parent) {
- var loadPromise = new process.Promise();
+ /* Some logic to shorten paths */
+ if (part === ".") continue;
+ while (/^\.\//.exec(part)) part = part.replace(/^\.\//, "");
- // On success copy the loaded properties into the exports
- loadPromise.addCallback(function (t) {
- for (var prop in t) {
- if (t.hasOwnProperty(prop)) exports[prop] = t[prop];
+ if (i === 0) {
+ part = part.replace(/\/*$/, "/");
+ } else if (i === arguments.length - 1) {
+ part = part.replace(/^\/*/, "");
+ } else {
+ part = part.replace(/^\/*/, "").replace(/\/*$/, "/");
}
- });
+ joined += part;
+ }
+ return joined;
+ };
- loadPromise.addErrback(function (e) {
- process.stdio.writeError(e.message + "\n");
- process.exit(1);
- });
+ exports.dirname = function (path) {
+ if (path.charAt(0) !== "/") path = "./" + path;
+ var parts = path.split("/");
+ return parts.slice(0, parts.length-1).join("/");
+ };
- if (!parent) {
- // root module
- process.assert(requestedPath.charAt(0) == "/");
- retrieveFromCache(loadPromise, requestedPath);
+ exports.filename = function (path) {
+ if (path.charAt(0) !== "/") path = "./" + path;
+ var parts = path.split("/");
+ return parts[parts.length-1];
+ };
- } else {
- if (requestedPath.charAt(0) == "/") {
- // Need to find the module in process.libraryPaths
- findPath(requestedPath, process.libraryPaths, function (fullPath) {
- if (fullPath) {
- retrieveFromCache(loadPromise, fullPath, parent);
- } else {
- loadPromise.emitError(new Error("Cannot find module '" + requestedPath + "'"));
+ exports.exists = function (path, callback) {
+ var p = process.fs.stat(path);
+ p.addCallback(function () { callback(true); });
+ p.addErrback(function () { callback(false); });
+ };
+});
+
+var path = pathModule.exports;
+
+
+
+var modulePaths = [ path.join(process.installPrefix, "lib/node/libraries")
+ ];
+
+if (process.ENV["HOME"]) {
+ modulePaths.unshift(path.join(process.ENV["HOME"], ".node_libraries"));
+}
+
+if (process.ENV["NODE_PATH"]) {
+ modulePaths = process.ENV["NODE_PATH"].split(":").concat(modulePaths);
+}
+
+
+function findModulePath (name, dirs, callback) {
+ process.assert(dirs.constructor == Array);
+
+ if (/.(js|node)$/.exec(name)) {
+ throw new Error("No longer accepting filename extension in module names");
+ }
+
+ if (dirs.length == 0) {
+ callback();
+ return;
+ }
+
+ var dir = dirs[0];
+ var rest = dirs.slice(1, dirs.length);
+
+ var js = path.join(dir, name + ".js");
+ var addon = path.join(dir, name + ".node");
+ var indexJs = path.join(dir, name, "index.js");
+ var indexAddon = path.join(dir, name, "index.addon");
+
+ // TODO clean up the following atrocity!
+
+ path.exists(js, function (found) {
+ if (found) {
+ callback(js);
+ return;
+ }
+ path.exists(addon, function (found) {
+ if (found) {
+ callback(addon);
+ return;
+ }
+ path.exists(indexJs, function (found) {
+ if (found) {
+ callback(indexJs);
+ return;
+ }
+ path.exists(indexAddon, function (found) {
+ if (found) {
+ callback(indexAddon);
+ return;
}
+ findModulePath(name, rest, callback);
});
+ });
+ });
+ });
+}
+
+function loadModule (request, parent) {
+ // This is the promise which is actually returned from require.async()
+ var loadPromise = new process.Promise();
+ loadPromise.addErrback(function (e) {
+ process.stdio.writeError(e.message + "\n");
+ process.exit(1);
+ });
+
+ debug("loadModule REQUEST " + JSON.stringify(request) + " parent: " + JSON.stringify(parent));
+
+ var name, paths;
+ if (request.charAt(0) == "." && request.charAt(1) == "/") {
+ // Relative request
+ name = path.join(path.dirname(parent.name), request);
+ paths = [path.dirname(parent.filename)];
+ } else {
+ name = request;
+ paths = modulePaths;
+ }
+
+ if (name in moduleCache) {
+ debug("found " + JSON.stringify(name) + " in cache");
+ // In cache
+ var module = moduleCache[name];
+ setTimeout(function () {
+ loadPromise.emitSuccess(module.exports);
+ }, 0);
+ } else {
+ debug("looking for " + JSON.stringify(name) + " in " + JSON.stringify(paths));
+ // Not in cache
+ findModulePath(request, paths, function (filename) {
+ if (!filename) {
+ loadPromise.emitError(new Error("Cannot find module '" + request + "'"));
} else {
- // Relative file load
- var fullPath = process.path.join(process.path.dirname(parent.filename),
- requestedPath);
- retrieveFromCache(loadPromise, fullPath, parent);
+ var module = createModule(name, parent);
+ module.load(filename, loadPromise);
}
- }
+ });
+ }
- return loadPromise;
- };
-}());
+ return loadPromise;
+};
+
+Module.prototype.load = function (filename, loadPromise) {
+ debug("load " + JSON.stringify(filename) + " for module " + JSON.stringify(this.name));
+
+ process.assert(!this.loaded);
+ process.assert(!this.loadPromise);
-process.Module.prototype.load = function (loadPromise) {
- if (this.loaded) {
- loadPromise.emitError(new Error("Module '" + self.filename + "' is already loaded."));
- return;
- }
- process.assert(!process.loadPromise);
this.loadPromise = loadPromise;
+ this.filename = filename;
- if (this.filename.match(/\.node$/)) {
- this.loadObject(loadPromise);
+ if (filename.match(/\.node$/)) {
+ this.loadObject(filename, loadPromise);
} else {
- this.loadScript(loadPromise);
+ this.loadScript(filename, loadPromise);
}
};
-process.Module.prototype.loadObject = function (loadPromise) {
+Module.prototype.loadObject = function (filename, loadPromise) {
var self = this;
// XXX Not yet supporting loading from HTTP. would need to download the
// file, store it to tmp then run dlopen on it.
- process.fs.exists(self.filename, function (does_exist) {
- if (does_exist) {
- self.loaded = true;
- process.dlopen(self.filename, self.exports); // FIXME synchronus
- loadPromise.emitSuccess(self.exports);
- } else {
- loadPromise.emitError(new Error("Error reading " + self.filename));
- }
- });
+ setTimeout(function () {
+ self.loaded = true;
+ process.dlopen(filename, self.exports); // FIXME synchronus
+ loadPromise.emitSuccess(self.exports);
+ }, 0);
};
-process.Module.prototype.loadScript = function (loadPromise) {
+Module.prototype.loadScript = function (filename, loadPromise) {
var self = this;
- var catPromise = process.cat(self.filename);
+ var catPromise = process.cat(filename);
catPromise.addErrback(function () {
- loadPromise.emitError(new Error("Error reading " + self.filename));
+ loadPromise.emitError(new Error("Error reading " + filename));
});
catPromise.addCallback(function (content) {
content = content.replace(/^\#\!.*/, '');
function requireAsync (url) {
- return self.newChild(url);
+ return loadModule(url, self); // new child
}
function require (url) {
return requireAsync(url).wait();
}
- require.paths = process.libraryPaths;
+ require.paths = modulePaths;
require.async = requireAsync;
// create wrapper function
- var wrapper = "var __wrap__ = function (__module, __filename, exports, require) { "
+ var wrapper = "var __wrap__ = function (exports, require, module, __filename) { "
+ content
+ "\n}; __wrap__;";
- var compiled_wrapper = process.compile(wrapper, self.filename);
+ var compiledWrapper = process.compile(wrapper, filename);
- compiled_wrapper.apply(self.exports, [self, self.filename, self.exports, require]);
+ compiledWrapper.apply(self.exports, [self.exports, require, self, filename]);
self.waitChildrenLoad(function () {
self.loaded = true;
});
};
-process.Module.prototype.newChild = function (path) {
- return process.loadModule(path, {}, this);
-};
-
-process.Module.prototype.waitChildrenLoad = function (callback) {
+Module.prototype.waitChildrenLoad = function (callback) {
var nloaded = 0;
var children = this.children;
for (var i = 0; i < children.length; i++) {
process.reallyExit(code);
};
-(function () {
- var cwd = process.cwd();
+var cwd = process.cwd();
- // Make process.ARGV[0] and process.ARGV[1] into full paths.
- if (process.ARGV[0].charAt(0) != "/") {
- process.ARGV[0] = process.path.join(cwd, process.ARGV[0]);
- }
+// Make process.ARGV[0] and process.ARGV[1] into full paths.
+if (process.ARGV[0].charAt(0) != "/") {
+ process.ARGV[0] = path.join(cwd, process.ARGV[0]);
+}
- if (process.ARGV[1].charAt(0) != "/") {
- process.ARGV[1] = process.path.join(cwd, process.ARGV[1]);
- }
+if (process.ARGV[1].charAt(0) != "/") {
+ process.ARGV[1] = path.join(cwd, process.ARGV[1]);
+}
+
+// Load the root module--the command line argument.
+var m = createModule(".");
+var loadPromise = new process.Promise();
+m.load(process.ARGV[1], loadPromise);
+loadPromise.wait();
- // Load the root module--the command line argument.
- process.loadModule(process.ARGV[1], process);
-}());
+}()); // end annonymous namespace
return process.fs.cat(location, encoding);
};
-process.path = new function () {
- this.join = function () {
- var joined = "";
- for (var i = 0; i < arguments.length; i++) {
- var part = arguments[i].toString();
- /* Some logic to shorten paths */
- if (part === ".") continue;
- while (/^\.\//.exec(part)) part = part.replace(/^\.\//, "");
- if (i === 0) {
- part = part.replace(/\/*$/, "/");
- } else if (i === arguments.length - 1) {
- part = part.replace(/^\/*/, "");
- } else {
- part = part.replace(/^\/*/, "").replace(/\/*$/, "/");
- }
- joined += part;
- }
- return joined;
- };
-
- this.dirname = function (path) {
- if (path.charAt(0) !== "/") path = "./" + path;
- var parts = path.split("/");
- return parts.slice(0, parts.length-1).join("/");
- };
-
- this.filename = function (path) {
- if (path.charAt(0) !== "/") path = "./" + path;
- var parts = path.split("/");
- return parts[parts.length-1];
- };
-};
-
-
-puts = function () {
- throw new Error("puts() has moved. Use require('/sys.js') to bring it back.");
-}
-
-print = function () {
- throw new Error("print() has moved. Use require('/sys.js') to bring it back.");
-}
-
-p = function () {
- throw new Error("p() has moved. Use require('/sys.js') to bring it back.");
-}
-
-process.debug = function () {
- throw new Error("process.debug() has moved. Use require('/sys.js') to bring it back.");
-}
-
-process.error = function () {
- throw new Error("process.error() has moved. Use require('/sys.js') to bring it back.");
-}
-exports.testDir = process.path.dirname(__filename);
-exports.fixturesDir = process.path.join(exports.testDir, "fixtures");
-exports.libDir = process.path.join(exports.testDir, "../../lib");
+var path = require("path");
+
+exports.testDir = path.dirname(__filename);
+exports.fixturesDir = path.join(exports.testDir, "fixtures");
+exports.libDir = path.join(exports.testDir, "../../lib");
require.paths.unshift(exports.libDir);
-var mjsunit = require("/mjsunit.js");
-var utils = require("/utils.js");
-process.mixin(exports, mjsunit, utils);
-exports.posix = require("/posix.js");
+var mjsunit = require("mjsunit");
+var sys = require("sys");
+
+process.mixin(exports, mjsunit, sys);
+exports.posix = require("posix");
+exports.path = path;
-var c = require("b/c.js");
+var c = require("./b/c");
debug("load fixtures/a.js");
-var d = require("d.js");
+var d = require("./d");
+
+var mjsunit = require("mjsunit");
+
+var package = require("./package");
+
+mjsunit.assertEquals("world", package.hello);
debug("load fixtures/b/c.js");
--- /dev/null
+exports.hello = "world";
+debug("load package/index.js");
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
-var testTxt = process.path.join(fixturesDir, "test.txt");
+var testTxt = path.join(fixturesDir, "test.txt");
-var libDir = process.path.join(testDir, "../../lib");
+var libDir = path.join(testDir, "../../lib");
require.paths.unshift(libDir);
-process.mixin(require("/file.js"));
+process.mixin(require("file"));
var fileUnlinked = false;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
setTimeout(function () {
- a = require("fixtures/a.js");
+ a = require("./fixtures/a");
}, 50);
process.addListener("exit", function () {
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var e = new process.EventEmitter();
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
success_count = 0;
error_count = 0;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var got_error = false;
-var filename = process.path.join(fixturesDir, "does_not_exist.txt");
+var filename = path.join(fixturesDir, "does_not_exist.txt");
var promise = posix.cat(filename, "raw");
promise.addCallback(function (content) {
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
-tcp = require("/tcp.js");
-sys = require("/sys.js");
+tcp = require("tcp");
+sys = require("sys");
PORT = 23123;
-var x = process.path.join(fixturesDir, "x.txt");
+var x = path.join(fixturesDir, "x.txt");
var expected = "xyz";
var server = tcp.createServer(function (socket) {
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var got_error = false;
var success_count = 0;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
-var path = process.path.join(fixturesDir, "write.txt");
+var fn = path.join(fixturesDir, "write.txt");
var expected = "hello";
var found;
-posix.open(path, process.O_WRONLY | process.O_TRUNC | process.O_CREAT, 0644).addCallback(function (file) {
+posix.open(fn, process.O_WRONLY | process.O_TRUNC | process.O_CREAT, 0644).addCallback(function (file) {
posix.write(file, expected, 0, "utf8").addCallback(function() {
posix.close(file).addCallback(function() {
- posix.cat(path, process.UTF8).addCallback(function(contents) {
+ posix.cat(fn, process.UTF8).addCallback(function(contents) {
found = contents;
- posix.unlink(path).wait();
+ posix.unlink(fn).wait();
});
});
});
-process.mixin(require("common.js"));
-http = require("/http.js");
+process.mixin(require("./common"));
+http = require("http");
PORT = 8888;
var body = "exports.A = function() { return 'A';}";
-process.mixin(require("common.js"));
-http = require("/http.js");
+process.mixin(require("./common"));
+http = require("http");
PORT = 8888;
var body1_s = "1111111111111111";
-process.mixin(require("common.js"));
-http = require("/http.js");
+process.mixin(require("./common"));
+http = require("http");
var PORT = 18032;
var sent_body = "";
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
-http = require("/http.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
+http = require("http");
// Make sure no exceptions are thrown when receiving malformed HTTP
// requests.
-process.mixin(require("common.js"));
-http = require("/http.js");
+process.mixin(require("./common"));
+http = require("http");
var PROXY_PORT = 8869;
var BACKEND_PORT = 8870;
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
-http = require("/http.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
+http = require("http");
var port = 8222;
-process.mixin(require("common.js"));
-http = require("/http.js");
+process.mixin(require("./common"));
+http = require("http");
PORT = 8888;
var responses_sent = 0;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
-var dirname = process.path.dirname(__filename);
-var fixtures = process.path.join(dirname, "fixtures");
-var d = process.path.join(fixtures, "dir");
+var dirname = path.dirname(__filename);
+var fixtures = path.join(dirname, "fixtures");
+var d = path.join(fixtures, "dir");
var mkdir_error = false;
var rmdir_error = false;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
debug("load test-module-loading.js");
-var a = require("fixtures/a.js");
-var d = require("fixtures/b/d.js");
-var d2 = require("fixtures/b/d.js");
+var a = require("./fixtures/a");
+var d = require("./fixtures/b/d");
+var d2 = require("./fixtures/b/d");
assertFalse(false, "testing the test program.");
-process.mixin(require("common.js"));
-http = require("/http.js");
+process.mixin(require("./common"));
+http = require("http");
-var multipart = require('/multipart.js');
-var fixture = require('fixtures/multipart.js');
+var multipart = require('multipart');
+var fixture = require('./fixtures/multipart');
var port = 8222;
var parts_reveived = 0;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var pwd_called = false;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var exit_status = -1;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var cat = process.createChildProcess("cat");
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var N = 40;
var finished = false;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var timeouts = 0;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var p1_done = false;
var p1 = new process.Promise();
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var got_error = false;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
puts("process.pid: " + process.pid);
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
PORT = 23123;
binaryString = "";
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
// settings
var port = 20743;
var bytes = 1024*40;
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
var tests_run = 0;
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
var tests_run = 0;
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
var N = 50;
var port = 8921;
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
PORT = 20444;
N = 30*1024; // 500kb
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
PORT = 20443;
N = 200;
-process.mixin(require("common.js"));
-tcp = require("/tcp.js");
+process.mixin(require("./common"));
+tcp = require("tcp");
port = 9992;
exchanges = 0;
starttime = null;
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
var WINDOW = 200; // why is does this need to be so big?
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
// üäö
-process.mixin(require("common.js"));
+process.mixin(require("./common"));
function timer (t) {
var promise = new process.Promise();
projects / platform / upstream / nodejs.git / commitdiff