var events = require('events'),
- util = require('util');
+ util = require('util'),
+ _ = require('lodash'),
+ EventPublisher = require('./plugininterface.js');
+/**
+ * Publisher
+ * The main point in which events are fired and bound to
+ */
+
// Where events are bound to
var active_publisher;
// Create a publisher to allow event subscribing
function Publisher (obj) {
- var EventPublisher = function modulePublisher() {};
- util.inherits(EventPublisher, events.EventEmitter);
-
- return new EventPublisher();
-};
+ var EventPublisher = require('./plugininterface.js');
+ return new EventPublisher();
+}
// Register an already created Publisher() as the active instance
function registerPublisher (obj) {
- active_publisher = obj;
+ active_publisher = obj;
+}
+
+
+
+
+
+
+/**
+ * Keeping track of modules
+ */
+
+// Hold the loaded modules
+var registered_modules = [];
+
+function loadModule (module_file) {
+ var module,
+ full_module_filename = global.config.module_dir + module_file;
+
+ // Get an instance of the module and remove it from the cache
+ try {
+ module = require(full_module_filename);
+ delete require.cache[require.resolve(full_module_filename)];
+ } catch (err) {
+ // Module was not found
+ return false;
+ }
+
+ return module;
}
+// Find a registered collection, .dispose() of it and remove it
+function unloadModule (module) {
+ var found_module = false;
+
+ registered_modules = _.reject(registered_modules, function (registered_module) {
+ if (module.toLowerCase() === registered_module.module_name.toLowerCase()) {
+ found_module = true;
+ registered_module.dispose();
+ return true;
+ }
+ });
+
+ return found_module;
+}
+
+
+
+
+
+
+/**
+ * Module object
+ * To be created by modules to bind to server events
+ */
function Module (module_name) {
+ registered_modules.push(this);
+ this.module_name = module_name;
- // Holder for all the bound events by this module
- var bound_events = {};
+ // Holder for all the bound events by this module
+ this._events = {};
+}
- // Handy function to be a little more consistant with EventEmitter
- this._events = function () {
- return bound_events;
- };
- // Keep track of this modules events and bind
- this.subscribe = function (event_name, fn) {
- bound_events[event_name] = bound_events[event_name] || [];
- bound_events[event_name].push(fn);
+// Keep track of this modules events and bind
+Module.prototype.on = function (event_name, fn) {
+ var internal_events = ['dispose'];
- global.modules.on(event_name, fn);
- };
+ this._events[event_name] = this._events[event_name] || [];
+ this._events[event_name].push(fn);
+ // If this is an internal event, do not propogate the event
+ if (internal_events.indexOf(event_name) === -1) {
+ active_publisher.on(event_name, fn);
+ }
+};
- // Keep track of this modules events and bind once
- this.once = function (event_name, fn) {
- bound_events[event_name] = bound_events[event_name] || [];
- bound_events[event_name].push(fn);
- global.modules.once(event_name, fn);
- };
+// Keep track of this modules events and bind once
+Module.prototype.once = function (event_name, fn) {
+ this._events[event_name] = this._events[event_name] || [];
+ this._events[event_name].push(fn);
+ active_publisher.once(event_name, fn);
+};
- // Remove any events by this module only
- this.unsubscribe = function (event_name, fn) {
- var idx;
- if (typeof event_name === 'undefined') {
- // Remove all events
- bound_events = [];
+// Remove any events by this module only
+Module.prototype.off = function (event_name, fn) {
+ var idx;
- } else if (typeof fn === 'undefined') {
- // Remove all of 1 event type
- delete bound_events[event_name];
+ if (typeof event_name === 'undefined') {
+ // Remove all events
+ this._events = [];
- } else {
- // Remove a single event + callback
- for (idx in (bound_events[event_name] || [])) {
- if (bound_events[event_name][idx] === fn) {
- delete bound_events[event_name][idx];
- }
- }
- }
+ } else if (typeof fn === 'undefined') {
+ // Remove all of 1 event type
+ delete this._events[event_name];
- global.modules.removeListener(event_name, fn);
- };
+ } else {
+ // Remove a single event + callback
+ for (idx in (this._events[event_name] || [])) {
+ if (this._events[event_name][idx] === fn) {
+ delete this._events[event_name][idx];
+ }
+ }
+ }
+ active_publisher.off(event_name, fn);
+};
+
+
+
+// Clean up anything used by this module
+Module.prototype.dispose = function () {
+ // Call any dispose callbacks
+ (this._events['dispose'] || []).forEach(function (callback) {
+ callback();
+ });
- // Clean up anything used by this module
- this.dispose = function () {
- this.unsubscribe();
- };
+ // Remove all bound event listeners
+ this.off();
};
-module.exports = {
- // Objects
- Module: Module,
- Publisher: Publisher,
- // Methods
- registerPublisher: registerPublisher
+
+
+module.exports = {
+ // Objects
+ Module: Module,
+ Publisher: Publisher,
+
+ // Methods
+ registerPublisher: registerPublisher,
+ load: loadModule,
+ unload: unloadModule,
+ getRegisteredModules: function () { return registered_modules; }
};
\ No newline at end of file
projects / KiwiIRC.git / blobdiff