diff --git a/logsystem/errors.log b/logsystem/errors.log new file mode 100644 index 0000000..af41eff --- /dev/null +++ b/logsystem/errors.log @@ -0,0 +1,22 @@ +{ + "resumo": { + "bloqueante": { + "1": 1, + "2": 0, + "3": 0, + "4": 0 + }, + "nao-bloqueante": { + "1": 0, + "2": 0, + "3": 0, + "4": 0 + } + }, + "detalhado": { + "1": "detalhe do erro", + "2": "detalhe", + "3": "detalhe", + "4": "detalhe" + } +} \ No newline at end of file diff --git a/logsystem/errors_template.json b/logsystem/errors_template.json new file mode 100644 index 0000000..d7225d4 --- /dev/null +++ b/logsystem/errors_template.json @@ -0,0 +1,23 @@ +{ + "resumo": { + "bloqueante": { + "1": 0, + "2": 0, + "3": 0, + "4": 0 + }, + "nao-bloqueante": { + "1": 0, + "2": 0, + "3": 0, + "4": 0 + } + }, + "detalhado": { + "1": "detalhe", + "2": "detalhe", + "3": "detalhe", + "4": "detalhe" + + } +} diff --git a/logsystem/main.coffee b/logsystem/main.coffee index be62540..be1c90b 100644 --- a/logsystem/main.coffee +++ b/logsystem/main.coffee @@ -1 +1,52 @@ -config = require('./config/main.js') +config = require('../config/main.js') +fs = require('fs') +kue = require('kue') +queue = kue.createQueue() +exports = module.exports = {} + +# 1 - Core retornou um erro. +# 2 - Vídeo inválido. +# 3 - Legenda inválida. +# 4 - Endpoint inválido. + +# params_box = JSON.parse(fs.readFileSync('./config/params_box.json', 'utf8')) +# errors = JSON.parse(fs.readFileSync('./logsystem/errors.log', 'utf8')) +# services = JSON.parse(fs.readFileSync('./logsystem/services.log', 'utf8')) + + +writeLog = (file, path) -> + fs.writeFileSync path, JSON.stringify(file, null, 4) + + +exports.incrementError = (id, detalhe="", inc=1) -> + errors_log_path = "./logsystem/errors.log" + errors = JSON.parse(fs.readFileSync(errors_log_path, 'utf8')) + + bloqueante = !config.isNaoBloqueante() # diferente de nao bloqueante aceita bloqueante ou ambos + + # id pode ser "1", "2", "3", "4" ou qualquer outro id criado para identificar erros + # 1 - Core retornou um erro. + # 2 - Vídeo inválido. + # 3 - Legenda inválida. + # 4 - Endpoint inválido. + + if bloqueante + errors["resumo"]["bloqueante"][id] += inc + else + errors["resumo"]["nao-bloqueante"][id] += inc + + errors["detalhado"][id] = detalhe + + writeLog(errors, errors_log_path) + +exports.incrementService = (serviceType, type, inc=1) -> + services_log_path = "./logsystem/services.log" + services = JSON.parse(fs.readFileSync(services_log_path, 'utf8')) + + if serviceType == "videos" + services["tipo"]["videos"][type] += inc + else if serviceType == "outros" + services["tipo"]["outros"][type] += inc + + + writeLog(services, services_log_path) diff --git a/logsystem/main.js b/logsystem/main.js index 43abdaf..ec53513 100644 --- a/logsystem/main.js +++ b/logsystem/main.js @@ -1,6 +1,53 @@ (function() { - var config; + var config, exports, fs, kue, queue, writeLog; - config = require('./config/main.js'); + config = require('../config/main.js'); + + fs = require('fs'); + + kue = require('kue'); + + queue = kue.createQueue(); + + exports = module.exports = {}; + + writeLog = function(file, path) { + return fs.writeFileSync(path, JSON.stringify(file, null, 4)); + }; + + exports.incrementError = function(id, detalhe, inc) { + var bloqueante, errors, errors_log_path; + if (detalhe == null) { + detalhe = ""; + } + if (inc == null) { + inc = 1; + } + errors_log_path = "./logsystem/errors.log"; + errors = JSON.parse(fs.readFileSync(errors_log_path, 'utf8')); + bloqueante = !config.isNaoBloqueante(); + if (bloqueante) { + errors["resumo"]["bloqueante"][id] += inc; + } else { + errors["resumo"]["nao-bloqueante"][id] += inc; + } + errors["detalhado"][id] = detalhe; + return writeLog(errors, errors_log_path); + }; + + exports.incrementService = function(serviceType, type, inc) { + var services, services_log_path; + if (inc == null) { + inc = 1; + } + services_log_path = "./logsystem/services.log"; + services = JSON.parse(fs.readFileSync(services_log_path, 'utf8')); + if (serviceType === "videos") { + services["tipo"]["videos"][type] += inc; + } else if (serviceType === "outros") { + services["tipo"]["outros"][type] += inc; + } + return writeLog(services, services_log_path); + }; }).call(this); diff --git a/logsystem/services.log b/logsystem/services.log new file mode 100644 index 0000000..32f227b --- /dev/null +++ b/logsystem/services.log @@ -0,0 +1,14 @@ +{ + "tipo": { + "videos": { + "requisicoes": 0, + "traducoes": 0, + "saude": 0 + }, + "outros": { + "requisicoes": 3, + "traducoes": 3, + "saude": 0 + } + } +} \ No newline at end of file diff --git a/logsystem/services_template.json b/logsystem/services_template.json new file mode 100644 index 0000000..3865530 --- /dev/null +++ b/logsystem/services_template.json @@ -0,0 +1,14 @@ +{ + "tipo": { + "videos": { + "requisicoes": 0, + "traducoes": 0, + "saude": 0 + }, + "outros": { + "requisicoes": 0, + "traducoes": 0, + "saude": 0 + } + } +} -- libgit2 0.21.2