1 |
|
2 | var log_fs;
|
3 |
|
4 | module.exports = {
|
5 | ssh: null,
|
6 | handler: function(options) {
|
7 | var stdouting;
|
8 | stdouting = 0;
|
9 | return this.call(options, log_fs, {
|
10 | serializer: {
|
11 | 'diff': function(log) {
|
12 | return log.type + "," + log.level + "," + (JSON.stringify(log.message)) + ",\n";
|
13 | },
|
14 | 'end': function() {
|
15 | return "lifecycle,INFO,Finished with success,\n";
|
16 | },
|
17 | 'error': function(err) {
|
18 | var content, error, i, len, print, ref;
|
19 | content = [];
|
20 | content.push("lifecycle,ERROR,Finished with error,\n");
|
21 | print = function(err) {
|
22 | return content.push("lifecycle,ERROR," + (err.stack || err.message) + ",\n");
|
23 | };
|
24 | if (!err.errors) {
|
25 | print(err);
|
26 | } else if (err.errors) {
|
27 | ref = err.errors;
|
28 | for (i = 0, len = ref.length; i < len; i++) {
|
29 | error = ref[i];
|
30 | print(error);
|
31 | }
|
32 | }
|
33 | return content.join();
|
34 | },
|
35 | 'header': function(log) {
|
36 | return log.type + ",,," + log.header + "\n";
|
37 | },
|
38 | 'stdin': function(log) {
|
39 | return log.type + "," + log.level + "," + (JSON.stringify(log.message)) + ",\n";
|
40 | },
|
41 | 'stderr': function(log) {
|
42 | return log.type + "," + log.level + "," + (JSON.stringify(log.message)) + ",\n";
|
43 | },
|
44 | 'stdout': function(log) {
|
45 | return log.type + "," + log.level + "," + (JSON.stringify(log.message)) + ",\n";
|
46 | },
|
47 | 'text': function(log) {
|
48 | return log.type + "," + log.level + "," + (JSON.stringify(log.message)) + ",\n";
|
49 | }
|
50 | }
|
51 | });
|
52 | }
|
53 | };
|
54 |
|
55 | log_fs = require('./fs');
|