Add CIPD pin reporting to swarming.

appengine/swarming/handlers_bot_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 logging
 import os
@@ skipping 379 matching lines @@
           'items_hot': '',
         },
       },
       'output': base64.b64encode('Ahahah'),
       'output_chunk_start': 0,
       'outputs_ref': {
         u'isolated': u'bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb',
         u'isolatedserver': u'http://localhost:1',
         u'namespace': u'default-gzip',
       },
+      'cipd_pins': [{
+        u'package_name': u'rm',
+        u'path': u'bin',
+        u'version': u'badc0fee'*5,
+      }],
       'task_id': task_id,
     }
     response = self.post_json('/swarming/api/v1/bot/task_update', params)
     self.assertEqual({u'must_stop': False, u'ok': True}, response)
 
     response = self.client_get_results(task_id)
     expected = {
       u'bot_dimensions': [
         {u'key': u'id', u'value': [u'bot1']},
         {u'key': u'os', u'value': [u'Amiga']},
         {u'key': u'pool', u'value': [u'default']},
       ],
       u'bot_id': u'bot1',
       u'bot_version': self.bot_version,
       u'completed_ts': str_now,
       u'costs_usd': [0.1],
       u'created_ts': str_now,
       u'duration': 3.,
       u'exit_code': u'0',
       u'failure': False,
       u'internal_failure': False,
       u'modified_ts': str_now,
       u'name': u'hi',
       u'outputs_ref': {
         u'isolated': u'bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb',
         u'isolatedserver': u'http://localhost:1',
         u'namespace': u'default-gzip',
       },
+      'cipd_pins': [{
+        u'package_name': u'rm',
+        u'path': u'bin',
+        u'version': u'badc0fee'*5,
+      }],
       u'server_versions': [u'v1a'],
       u'started_ts': str_now,
       u'state': u'COMPLETED',
       u'task_id': u'5cee488008811',
       u'try_number': u'1',
     }
     self.assertEqual(expected, response)
 
   def test_poll_not_enough_time(self):
     # Make sure there's a task that we don't get.
@@ skipping 493 matching lines @@
     self.app.get('/bot_code?tok=%s' % tok, status=200)
 
 
 if __name__ == '__main__':
   if '-v' in sys.argv:
     unittest.TestCase.maxDiff = None
   logging.basicConfig(
       level=logging.DEBUG if '-v' in sys.argv else logging.CRITICAL,
       format='%(levelname)-7s %(filename)s:%(lineno)3d %(message)s')
   unittest.main()