Skip to content
This repository has been archived by the owner on Apr 22, 2023. It is now read-only.

Commit

Permalink
Module system refactor
Browse files Browse the repository at this point in the history
There is one major API change in the refactor: filename extensions are now
required when requiring or including modules.

Added extra test to test-module-loading.js.
  • Loading branch information
ry committed Jun 8, 2009
1 parent 887f056 commit b6fe4ae
Show file tree
Hide file tree
Showing 13 changed files with 153 additions and 162 deletions.
236 changes: 101 additions & 135 deletions src/node.js
Original file line number Diff line number Diff line change
@@ -1,16 +1,38 @@
// module search paths
node.includes = ["."];
// Timers

function setTimeout (callback, delay) {
var timer = new node.Timer(callback, delay, 0);
timer.start();
return timer;
}

function setInterval (callback, delay) {
var timer = new node.Timer(callback, delay, delay);
timer.start();
return timer;
}

function clearTimeout (timer) {
timer.stop();
delete timer;
}

clearInterval = clearTimeout;

// This is useful for dealing with raw encodings.
Array.prototype.encodeUtf8 = function () {
return String.fromCharCode.apply(String, this);
}
};

node.path = new function () {
this.join = function () {
var joined = "";
for (var i = 0; i < arguments.length; i++) {
var part = arguments[i].toString();

if (part === ".") continue;
while (/^\.\//.exec(part)) part = part.replace(/^\.\//, "");

if (i === 0) {
part = part.replace(/\/*$/, "/");
} else if (i === arguments.length - 1) {
Expand All @@ -32,149 +54,93 @@ node.path = new function () {
};
};

// Timers

function setTimeout (callback, delay) {
var timer = new node.Timer(callback, delay, 0);
timer.start();
return timer;
};

function setInterval (callback, delay) {
var timer = new node.Timer(callback, delay, delay);
timer.start();
return timer;
};

function clearTimeout (timer) {
timer.stop();
delete timer;
};
clearInterval = clearTimeout;
// Module

// Modules
node.Module = function (o) {
this.parent = o.parent;
this.target = o.target || {};

(function () {
function findScript(base_directory, name, callback) {
// in the future this function will be more complicated
if (name.charAt(0) == "/")
throw "absolute module paths are not yet supported.";
if (!o.path) throw "path argument required";
if (o.path.charAt(0) == "/")
throw "Absolute module paths are not yet supported in Node";

var filename = node.path.join(base_directory, name) + ".js";
var dir = o.base_directory || ".";
this.filename = node.path.join(dir, o.path);

node.fs.exists(filename, function (status) {
callback(status ? filename : null);
});
}
this.loaded = false;
this.exited = false;
this.children = [];
};

// Constructor for submodule.
// "name" is like a path but without .js. e.g. "database/mysql"
// "target" is an object into which the submodule will be loaded.
function Sub (name, target) {
this.name = name;
this.target = target;

this.load = function (base_directory, callback) {
//node.debug("sub.load from <" + base_directory + "> " + this.toString());
findScript(base_directory, name, function (filename) {
if (filename === null) {
stderr.puts("Cannot find a script matching: " + name);
node.exit(1);
}
loadScript(filename, target, callback);
});
};

this.toString = function () {
return "[sub name=" + name + " target=" + target.toString() + "]";
}
}
node.Module.prototype.load = function (callback) {
var self = this;
if (self.loaded)
throw "Module '" + self.filename + "' is already loaded.";

function Scaffold (source, filename, module) {
// wrap the source in a strange function
var source = "function (__filename) {"
+ " var onLoad;"
+ " var exports = this;"
+ " var require = this.__require;"
+ " var include = this.__include;"
+ source
+ " this.__onLoad = onLoad;"
+ "};"
;
// returns the function
var compiled = node.compile(source, filename);

if (module.__onLoad) {
//node.debug("<"+ filename+"> has onload! this is bad");
node.fs.cat(self.filename, "utf8", function (status, content) {
if (status != 0) {
stderr.puts("Error reading " + self.filename);
node.exit(1);
}

module.__subs = [];
module.__require = function (name) {
var target = {};
module.__subs.push(new Sub(name, target));
return target;
}
module.__include = function (name) {
module.__subs.push(new Sub(name, module));
}
// execute the script of interest
compiled.apply(module, [filename]);

// The module still needs to have its submodules loaded.
this.filename = filename;
this.module = module;
this.subs = module.__subs;
this.onLoad = module.__onLoad;

// remove these references so they don't get exported.
delete module.__subs;
delete module.__onLoad;
delete module.__require;
delete module.__include;
}

function loadScript (filename, target, callback) {
node.fs.cat(filename, "utf8", function (status, content) {
if (status != 0) {
stderr.puts("Error reading " + filename);
node.exit(1);
}
self.target.__require = function (path) { return self.newChild(path, {}); };
self.target.__include = function (path) { self.newChild(path, self.target); };

// create wrapper function
var wrapper = "function (__filename) {\n"
+ " var onLoad;\n"
+ " var onExit;\n"
+ " var exports = this;\n"
+ " var require = this.__require;\n"
+ " var include = this.__include;\n"
+ content
+ "\n"
+ " this.__onLoad = onLoad;\n"
+ " this.__onExit = onExit;\n"
+ "};\n"
;
var compiled_wrapper = node.compile(wrapper, self.filename);

var scaffold = new Scaffold(content, filename, target);

//node.debug("after scaffold <" + filename + ">");

function finish() {
//node.debug("finish 1 load <" + filename + ">");
if (scaffold.onLoad instanceof Function) {
//node.debug("calling onLoad for <" + filename + ">");
scaffold.onLoad();
}
//node.debug("finish 2 load <" + filename + ">");
// execute the script of interest
compiled_wrapper.apply(self.target, [self.filename]);
self.onLoad = self.target.__onLoad;
self.onExit = self.target.__onExit;

self.loadChildren(function () {
if (self.onLoad) self.onLoad();
self.loaded = true;
if (callback) callback();
});
});
};

if (callback instanceof Function)
callback();
}
node.Module.prototype.newChild = function (path, target) {
var child = new node.Module({
target: target,
path: path,
base_directory: node.path.dirname(this.filename),
parent: this
});
this.children.push(child);
return target;
};

// Each time require() or include() was called inside the script
// a key/value was added to scaffold.__subs.
// Now we loop though each one and recursively load each.
if (scaffold.subs.length == 0) {
finish();
} else {
var ncomplete = 0;
for (var i = 0; i < scaffold.subs.length; i++) {
var sub = scaffold.subs[i];
sub.load(node.path.dirname(filename), function () {
ncomplete += 1;
//node.debug("<" + filename + "> ncomplete = " + ncomplete.toString() + " scaffold.subs.length = " + scaffold.subs.length.toString());
if (ncomplete === scaffold.subs.length)
finish();
});
}
}
node.Module.prototype.loadChildren = function (callback) {
var children = this.children;
if (children.length == 0 && callback) callback();
var nloaded = 0;
for (var i = 0; i < children.length; i++) {
var child = children[i];
child.load(function () {
nloaded += 1;
if (nloaded == children.length && callback) callback();
});
}
};

node.Module.prototype.exit = function (callback) {
throw "not implemented";
};

loadScript(ARGV[1], this);
})();
// Load the root module. I.E. the command line argument.
(new node.Module({ path: ARGV[1], target: this })).load();
11 changes: 8 additions & 3 deletions test/fixtures/a.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,10 @@
var c = require("b/c");
var c = require("b/c.js");
exports.A = function () {
return "A";
}
exports.C = function () { return c.C(); }
};
exports.C = function () {
return c.C();
};
exports.D = function () {
return c.D();
};
8 changes: 7 additions & 1 deletion test/fixtures/b/c.js
Original file line number Diff line number Diff line change
@@ -1,3 +1,9 @@
var d = require("d.js");

exports.C = function () {
return "C";
}
};

exports.D = function () {
return d.D();
};
4 changes: 4 additions & 0 deletions test/fixtures/b/d.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
exports.D = function () {
return "D";
};

2 changes: 1 addition & 1 deletion test/test-cat-noexist.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
include("mjsunit");
include("mjsunit.js");

function onLoad () {
var dirname = node.path.dirname(__filename);
Expand Down
2 changes: 1 addition & 1 deletion test/test-file-open.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
include("mjsunit");
include("mjsunit.js");
var assert_count = 0;

function onLoad () {
Expand Down
2 changes: 1 addition & 1 deletion test/test-http-server.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
include("mjsunit");
include("mjsunit.js");

var port = 8222;

Expand Down
23 changes: 23 additions & 0 deletions test/test-module-loading.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
include("mjsunit.js");
var a = require("fixtures/a.js");
var d = require("fixtures/b/d.js");
var d2 = require("fixtures/b/d.js");

function onLoad () {
assertFalse(false, "testing the test program.");

assertInstanceof(a.A, Function);
assertEquals("A", a.A());

assertInstanceof(a.C, Function);
assertEquals("C", a.C());

assertInstanceof(a.D, Function);
assertEquals("D", a.D());

assertInstanceof(d.D, Function);
assertEquals("D", d.D());

assertInstanceof(d2.D, Function);
assertEquals("D", d2.D());
}
2 changes: 1 addition & 1 deletion test/test-pingpong.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
include("mjsunit");
include("mjsunit.js");

var port = 12123;
var N = 1000;
Expand Down
2 changes: 1 addition & 1 deletion test/test-reconnecting-socket.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
include("mjsunit");
include("mjsunit.js");
var port = 8921;

function onLoad () {
Expand Down
2 changes: 1 addition & 1 deletion test/test-setTimeout.js
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
include("mjsunit");
include("mjsunit.js");

function onLoad () {
assertInstanceof(setTimeout, Function);
Expand Down
12 changes: 0 additions & 12 deletions test/test-test.js

This file was deleted.

Loading

0 comments on commit b6fe4ae

Please sign in to comment.