Skip to content

Commit

Permalink
Fix for absence of logging routes with the same pattern as another theme
Browse files Browse the repository at this point in the history
  • Loading branch information
brianhyder committed Jun 2, 2015
1 parent eb6aa0b commit e714a28
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 22 deletions.
11 changes: 8 additions & 3 deletions include/http/request_handler.js
Expand Up @@ -291,15 +291,20 @@ module.exports = function RequestHandlerModule(pb) {
//set them in storage
if (isStatic) {
RequestHandler.staticRoutes[descriptor.path] = routeDescriptor;
pb.log.debug('RequestHander: Registered Static Route - Theme [%s] Path [%s][%s]', theme, descriptor.method, descriptor.path);
}
else {
RequestHandler.index[pattern] = RequestHandler.storage.length;
RequestHandler.storage.push(routeDescriptor);
pb.log.debug('RequestHandler: Registered Route - Theme [%s] Path [%s][%s] Pattern [%s]', theme, descriptor.method, descriptor.path, pattern);
}
}


//log the result
if (isStatic) {
pb.log.debug('RequestHander: Registered Static Route - Theme [%s] Path [%s][%s]', theme, descriptor.method, descriptor.path);
}
else {
pb.log.debug('RequestHandler: Registered Route - Theme [%s] Path [%s][%s] Pattern [%s]', theme, descriptor.method, descriptor.path, pattern);
}
return true;
};

Expand Down
28 changes: 10 additions & 18 deletions include/service/entities/plugin_service.js
Expand Up @@ -1292,7 +1292,7 @@ module.exports = function PluginServiceModule(pb) {
* @param {Object} plugin
* @param {Function} cb
*/
PluginService.prototype.installPluginDependencies = function(pluginDirName, dependencies, plugin, cb) {console.log('***installing dependencies');
PluginService.prototype.installPluginDependencies = function(pluginDirName, dependencies, plugin, cb) {

//verify parameters
if (!pb.validation.validateNonEmptyStr(pluginDirName, true) || !util.isObject(dependencies)) {
Expand All @@ -1312,12 +1312,12 @@ module.exports = function PluginServiceModule(pb) {
function(callback) {

//try and acquire the lock
lockService.acquire(key, function(err, reply) {console.log('LS_REPLY=%s', reply);
lockService.acquire(key, function(err, reply) {
if (util.isError(err)) {
return callback(err);
}
else if (reply) {
didLock = true;console.log('I Locked so calling back');
didLock = true;
return callback();
}

Expand All @@ -1332,32 +1332,30 @@ module.exports = function PluginServiceModule(pb) {
}, 1000);
});
},
function(err) {console.log('I made it here');
function(err) {

//a callback function that allows for deleting the lock key
var onDone = function(err, result) {
if (!didLock) { console.log('I never locked so exiting Im done');console.log(err);console.log(result);
if (!didLock) {
return cb(err, result);
}
lockService.release(key, function(error, didRelease) {console.log('Releasing lock: %s', didRelease);
lockService.release(key, function(error, didRelease) {
cb(err || error, didRelease);
});
};

//verify results
if (util.isError(err)) {console.log('I made it here2');
if (util.isError(err)) {
return onDone(err);
}
else if (retryCount >= MAX_DEPENDENCY_LOCK_RETRY_CNT) {

pb.log.warn('PluginService: Reached maximum retry count trying to verify dependencies');
return onDone(null, false);
}
console.log('I made it here3');console.log(plugin);

try{
//proceed to check to see if all dependencies are there
self.hasDependencies(plugin, function(err, hasDependencies) {console.log('checked dependencies');console.log(err);console.log(hasDependencies);
self.hasDependencies(plugin, function(err, hasDependencies) {
if (hasDependencies) {
pb.log.silly('PluginService: Assuming another process installed dependencies because they were discovered. Skipping install');
return onDone(err);
Expand All @@ -1369,10 +1367,6 @@ module.exports = function PluginServiceModule(pb) {
onDone(err, result);
});
});
}
catch(e) {
pb.log.error(e.stack);
}
}
);
};
Expand Down Expand Up @@ -2092,12 +2086,10 @@ pb.log.error(e.stack);
//get the routes
ControllerPrototype.getRoutes(function(err, routes) {
if (util.isError(err)) {
cb(err, null);
return;
return cb(err, null);
}
else if (!util.isArray(routes)) {
cb(new Error('Controller at ['+pathToController+'] did not return an array of routes'), null);
return;
return cb(new Error('Controller at ['+pathToController+'] did not return an array of routes'), null);
}

//attempt to register route
Expand Down
2 changes: 1 addition & 1 deletion include/system/command/mongo_command_broker.js
Expand Up @@ -309,7 +309,7 @@ module.exports = function MongoCommandBrokerModule(pb) {
instance.onCommandReceived(command.channel, command);
}
else {
console.log('Dummy record found');
/* no op */
}

//trigger wait for next object
Expand Down

0 comments on commit e714a28

Please sign in to comment.