Create Tasks.Tags endpoint and Cron job

appengine/swarming/handlers_endpoints_test.py

 #!/usr/bin/env python
 # coding=utf-8
 # Copyright 2015 The LUCI Authors. All rights reserved.
 # Use of this source code is governed under the Apache License, Version 2.0
 # that can be found in the LICENSE file.
 
 import base64
 import datetime
 import json
 import logging
@@ skipping 840 matching lines @@
                 except:  # pylint: disable=bare-except
                   self.fail(
                       'Is unsupported: (%s, %s, %s)' %
                       (using_filter, state, sort))
                 # Don't check for correctness here, just assert that it doesn't
                 # throw due to missing index or invalid query.
                 result.pop(u'items', None)
                 expected = {u'now': str_now_120}
                 self.assertEqual(expected, result)
 
+  def test_tags_ok(self):
+    """Asserts that TasksTags is returned with the right data."""
+    self.set_as_privileged_user()
+    now = datetime.datetime(2009, 1, 2, 3, 4, 5, 6)
+    self.mock_now(now)
+    task_result.TagAggregation(
+        key=task_result.TagAggregation.KEY,
+        tags=[
+            task_result.TagValues(
+                tag='foo', values=['alpha', 'beta']),
+            task_result.TagValues(
+                tag='bar', values=['gamma', 'delta', 'epsilon']),
+        ],
+        ts=now).put()
+    expected = {
+      u'tasks_tags': [
+        {
+          u'key': 'foo',
+          u'value': [u'alpha', u'beta'],
+        },
+        {
+          u'key': 'bar',
+          u'value': [u'gamma', u'delta', u'epsilon'],
+        },
+      ],
+      u'ts': unicode(now.strftime(self.DATETIME_FORMAT)),
+    }
+    self.assertEqual(expected, self.call_api('tags', body={}).json)
+
   def _gen_two_tasks(self):
     # first request
     now = datetime.datetime(2010, 1, 2, 3, 4, 5)
     str_now = unicode(now.strftime(self.DATETIME_NO_MICRO))
     self.mock_now(now)
     self.mock(random, 'getrandbits', lambda _: 0x66)
     _, first_id = self.client_create_task_raw(
         name='first', tags=['project:yay', 'commit:post', 'os:Win'],
         properties=dict(idempotent=True))
     self.set_as_bot()
@@ skipping 1017 matching lines @@
     self.assertEqual(expected, response.json)
 
 
 if __name__ == '__main__':
   if '-v' in sys.argv:
     unittest.TestCase.maxDiff = None
     logging.basicConfig(level=logging.DEBUG)
   else:
     logging.basicConfig(level=logging.CRITICAL)
   unittest.main()