Skip to content

Commit

Permalink
WUI/API: fix log file path #330 #332
Browse files Browse the repository at this point in the history
  • Loading branch information
kanreisa committed Aug 20, 2017
1 parent 09edc70 commit fd4711d
Show file tree
Hide file tree
Showing 2 changed files with 78 additions and 56 deletions.
73 changes: 42 additions & 31 deletions api/script-log-stream.vm.js
@@ -1,32 +1,43 @@
(function() {

if (['wui', 'operator', 'scheduler'].indexOf(request.param.name) === -1) {
return response.error(404);
}

var filename = './log/' + request.param.name;

if (!fs.existsSync(filename)) {
response.head(204);
response.end('');
return;
}

response.head(200);

response.write(new Array(1024).join(' '));

var tailf = child_process.spawn('tail', ['-f', '-n', '100', filename]);
children.push(tailf.pid);

tailf.stdout.pipe(response);

tailf.on('exit', function(code) {
response.end();
});

request.on('close', function() {
tailf.kill('SIGKILL');
});

(function() {

if (['wui', 'operator', 'scheduler'].indexOf(request.param.name) === -1) {
return response.error(404);
}

let filename = "";
switch (request.param.name) {
case "wui":
filename = define.WUI_LOG_FILE;
break;
case "scheduler":
filename = define.SCHEDULER_LOG_FILE;
break;
case "operator":
filename = define.OPERATOR_LOG_FILE;
break;
}

if (!fs.existsSync(filename)) {
response.head(204);
response.end('');
return;
}

response.head(200);

response.write(new Array(1024).join(' '));

var tailf = child_process.spawn('tail', ['-f', '-n', '100', filename]);
children.push(tailf.pid);

tailf.stdout.pipe(response);

tailf.on('exit', function(code) {
response.end();
});

request.on('close', function() {
tailf.kill('SIGKILL');
});

})();
61 changes: 36 additions & 25 deletions api/script-log.vm.js
@@ -1,26 +1,37 @@
(function() {

if (['wui', 'operator', 'scheduler'].indexOf(request.param.name) === -1) {
return response.error(404);
}

var filename = './log/' + request.param.name;

if (!fs.existsSync(filename)) {
response.head(204);
response.end('');
return;
}

response.head(200);

fs.readFile(filename, function(err, data) {
if (err) {
util.log(err);
return response.error(500);
}

response.end(data);
});

(function() {

if (['wui', 'operator', 'scheduler'].indexOf(request.param.name) === -1) {
return response.error(404);
}

let filename = "";
switch (request.param.name) {
case "wui":
filename = define.WUI_LOG_FILE;
break;
case "scheduler":
filename = define.SCHEDULER_LOG_FILE;
break;
case "operator":
filename = define.OPERATOR_LOG_FILE;
break;
}

if (!fs.existsSync(filename)) {
response.head(204);
response.end('');
return;
}

response.head(200);

fs.readFile(filename, function(err, data) {
if (err) {
util.log(err);
return response.error(500);
}

response.end(data);
});

})();

0 comments on commit fd4711d

Please sign in to comment.