From d74634b5cf37965c8d4963fa63abce5ea1be97ff Mon Sep 17 00:00:00 2001
From: Cassio Cabral <cassioscabral@gmail.com>
Date: Wed, 9 Sep 2015 12:46:16 -0300
Subject: [PATCH] adiciona cron e unirest pra poder lidar com o update da saude em services.log

---
 logsystem/main.coffee  | 12 ++++++++++++
 logsystem/main.js      | 18 ++++++++++++++++++
 logsystem/services.log |  6 +++---
 package.json           |  4 +++-
 server.js              | 19 +++++++++++++++++++
 5 files changed, 55 insertions(+), 4 deletions(-)

diff --git a/logsystem/main.coffee b/logsystem/main.coffee
index be1c90b..db69dd0 100644
--- a/logsystem/main.coffee
+++ b/logsystem/main.coffee
@@ -50,3 +50,15 @@ exports.incrementService = (serviceType, type, inc=1) ->
 
 
   writeLog(services, services_log_path)
+
+exports.updateHealth = (serviceType="outros", value=0) ->
+  services_log_path = "./logsystem/services.log"
+  services = JSON.parse(fs.readFileSync(services_log_path, 'utf8'))
+
+  # if e else if pra excluir valores diferente desses dois
+  if serviceType == "videos"
+    services["tipo"]["videos"]["saude"] = value
+  else if serviceType == "outros"
+    services["tipo"]["outros"]["saude"] = value
+
+  writeLog(services, services_log_path)
diff --git a/logsystem/main.js b/logsystem/main.js
index ec53513..dd3d331 100644
--- a/logsystem/main.js
+++ b/logsystem/main.js
@@ -50,4 +50,22 @@
     return writeLog(services, services_log_path);
   };
 
+  exports.updateHealth = function(serviceType, value) {
+    var services, services_log_path;
+    if (serviceType == null) {
+      serviceType = "outros";
+    }
+    if (value == null) {
+      value = 0;
+    }
+    services_log_path = "./logsystem/services.log";
+    services = JSON.parse(fs.readFileSync(services_log_path, 'utf8'));
+    if (serviceType === "videos") {
+      services["tipo"]["videos"]["saude"] = value;
+    } else if (serviceType === "outros") {
+      services["tipo"]["outros"]["saude"] = value;
+    }
+    return writeLog(services, services_log_path);
+  };
+
 }).call(this);
diff --git a/logsystem/services.log b/logsystem/services.log
index 8216532..866574d 100644
--- a/logsystem/services.log
+++ b/logsystem/services.log
@@ -6,9 +6,9 @@
             "saude": 0
         },
         "outros": {
-            "requisicoes": 4,
-            "traducoes": 4,
-            "saude": 0
+            "requisicoes": 88,
+            "traducoes": 88,
+            "saude": 1
         }
     }
 }
\ No newline at end of file
diff --git a/package.json b/package.json
index 4acbf0b..42946b4 100644
--- a/package.json
+++ b/package.json
@@ -17,6 +17,8 @@
     "ip": "latest",
     "mongoose": "^3.8.16",
     "python-shell": "0.0.3",
-    "kue": "latest"
+    "kue": "latest",
+    "unirest": "latest",
+    "cron": "latest"
   }
 }
diff --git a/server.js b/server.js
index 9ec29c4..003ae5b 100755
--- a/server.js
+++ b/server.js
@@ -19,6 +19,7 @@ var config = require('./config/main.js');
 var logger = require('./logsystem/main.js');
 var kue = require('kue');
 var queue = kue.createQueue();
+var unirest = require('unirest');
 
 app.use(express.static(path.join(__dirname, '/videos')));
 app.use(express.bodyParser({ keepExtensions: true, uploadDir: path.join(__dirname, '/uploads') }));
@@ -170,3 +171,21 @@ app.get('/*', function(req, res){
 app.listen(properties.port, properties.host, function(){
 	console.log('Server running on ' + properties.host + ':' + properties.port);
 });
+
+
+
+var CronJob = require('cron').CronJob;
+// '* * * * * *' == a cada 1 segundo
+new CronJob('* * * * * *', function() {
+	unirest.post('http://localhost:5000/api')
+	.header('Accept', 'application/json')
+	.send({ "servico": "texto", "transparencia": "opaco", "texto": "texto teste" })
+	.end(function (response) {
+	  console.log(response.status);
+		if(response.status === 200){
+			logger.updateHealth("outros", 1);
+		} else {
+			logger.updateHealth();
+		}
+	});
+}, null, true); // no lugar do null pode ser uma funcao pra executar quando parar
--
libgit2 0.21.2