Added more tests for change merged and comment added events

ferrit/rest.py

@@ -182,9 +182,9 @@ class App(bottle.Bottle):
                                            "target": "_blank"}]}}
 
     def _changes(self, project, branch, id, commit_id):
-        # We are looking for labels in the json
+        # We are looking for result of the job, not the notification about
-        labels = bottle.request.json.get('labels', {})
+        # starting the job.
-        if not labels:
+        if bottle.request.json.get('message', '').startswith('Build Started'):
             return
 
         LOG.info(json.dumps(bottle.request.json))

tests/base.py

@@ -4,6 +4,8 @@ import subprocess
 import time
 import unittest
 
+import requests
+
 
 class BaseTestCase(unittest.TestCase):
     def setUp(self):
@@ -25,3 +27,24 @@ class BaseTestCase(unittest.TestCase):
         os.killpg(self.process.pid, signal.SIGTERM)
         os.unlink('ferrit-http.log')
         os.unlink('ferrit-ssh.log')
+
+    def _send_and_get_response(self, event_type):
+        counter = 20
+        result = None
+        requests.post('http://localhost:8181/make/event',
+                      data='type=%s' % event_type)
+        while counter:
+            if not os.path.exists('ferrit-http.log'):
+                counter -= 1
+                time.sleep(1)
+                continue
+
+            with open('ferrit-http.log') as fobj:
+                result = fobj.read()
+                if not result:
+                    time.sleep(1)
+                    counter -= 1
+                else:
+                    break
+
+        return result

tests/test_change_merged.py

@@ -0,0 +1,13 @@
+import json
+
+from tests import base
+
+
+class TestChangeMerged(base.BaseTestCase):
+
+    def test_deploy(self):
+        result = self._send_and_get_response('change-merged')
+
+        self.assertTrue(result)
+        result = json.loads(result)
+        self.assertIn('--tag', result['message'])

tests/test_comment_added.py

@@ -0,0 +1,13 @@
+import json
+
+from tests import base
+
+
+class TestCommentAdded(base.BaseTestCase):
+
+    def test_recheck(self):
+        result = self._send_and_get_response('comment-added')
+
+        self.assertTrue(result)
+        result = json.loads(result)
+        self.assertEqual(result['labels']['Verified'], 1)