diff --git a/distributor.js b/distributor.js index 95cf1ef..33561bc 100644 --- a/distributor.js +++ b/distributor.js @@ -31,14 +31,14 @@ exports.init = function(app, callback) { }; // create resource for build data - var createBuildDataResource = function(build) { - if (build.id in buildDataResourcesHash) { + var createBuildDataResource = function(buildId) { + if (buildId in buildDataResourcesHash) { return; } - var buildDataResource = app.dataio.resource('build' + build.id); + var buildDataResource = app.dataio.resource('build' + buildId); buildDataResource.on('connection', function(client) { var callback = this.async(), - buildLogPath = getBuildLogPath(build.id); + buildLogPath = getBuildLogPath(buildId); var stream = fs.createReadStream(buildLogPath, { encoding: 'utf8' @@ -60,7 +60,7 @@ exports.init = function(app, callback) { ); }); }); - buildDataResourcesHash[build.id] = buildDataResource; + buildDataResourcesHash[buildId] = buildDataResource; }; exports.createBuildDataResource = createBuildDataResource; @@ -73,7 +73,7 @@ exports.init = function(app, callback) { if (build.status === 'queued') { // remove prev log if it exists - for development fs.unlink(getBuildLogPath(build.id)); - createBuildDataResource(build); + createBuildDataResource(build.id); } buildsResource.clientEmitSync('change', { diff --git a/resources/projects.js b/resources/projects.js index d004f13..7e20151 100644 --- a/resources/projects.js +++ b/resources/projects.js @@ -11,7 +11,7 @@ module.exports = function(app) { distributor = app.distributor; resource.use('createBuildDataResource', function(req, res) { - createBuildDataResource({id: req.data.id}); + createBuildDataResource(req.data.buildId); res.send(); }); diff --git a/static/js/app/stores/terminal.js b/static/js/app/stores/terminal.js index 211c242..4e24143 100644 --- a/static/js/app/stores/terminal.js +++ b/static/js/app/stores/terminal.js @@ -40,11 +40,14 @@ define([ // create data resource for completed build if (build.completed) { - connect.resource('projects') - .sync('createBuildDataResource', function(err) { + connect.resource('projects').sync( + 'createBuildDataResource', + {buildId: build.id}, + function(err) { if (err) throw err; connectToBuildDataResource(); - }); + } + ); } else { connectToBuildDataResource(); }