Setup basic Runtime with properties and platform.

recipes.py

 #!/usr/bin/env python
 # 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.
 
 """Tool to interact with recipe repositories.
 
 This tool operates on the nearest ancestor directory containing an
 infra/config/recipes.cfg.
 """
@@ skipping 128 matching lines @@
     properties = get_properties_from_json(args.properties)
   elif args.properties_file:
     properties = get_properties_from_file(args.properties_file)
   elif op_properties is not None:
     properties = op_properties
   else:
     properties = arg_properties
 
   properties['recipe'] = args.recipe
 
+  # TODO(iannucci): A much better way to do this would be to dynamically
+  #   detect if the mirrors are actually available during the execution of the
+  #   recipe.
+  if ('use_mirror' not in properties and (
+    'TESTING_MASTERNAME' in os.environ or
+    'TESTING_SLAVENAME' in os.environ)):
+    properties['use_mirror'] = False
+
   os.environ['PYTHONUNBUFFERED'] = '1'
   os.environ['PYTHONIOENCODING'] = 'UTF-8'
 
   _, config_file = get_package_config(args)
   universe_view = loader.UniverseView(
       loader.RecipeUniverse(
           package_deps, config_file), package_deps.root_package)
 
   workdir = (args.workdir or
       os.path.join(os.path.dirname(os.path.realpath(__file__)), 'workdir'))
   logging.info('Using %s as work directory' % workdir)
   if not os.path.exists(workdir):
     os.makedirs(workdir)
 
   old_cwd = os.getcwd()
   os.chdir(workdir)
 
+  # Generate our Runtime instance.
+  rt = recipe_run.Runtime(properties)
+
   # Construct our stream engines. We may want to share stream events with more
   # than one StreamEngine implementation, so we will accumulate them in a
   # "stream_engines" list and compose them into a MultiStreamEngine.
   def build_annotation_stream_engine():
     return stream.AnnotatorStreamEngine(
         sys.stdout,
         emit_timestamps=(args.timestamps or
                          op_args.annotation_flags.emit_timestamp),
     )
 
@@ skipping 16 matching lines @@
   # Have a top-level set of invariants to enforce StreamEngine expectations.
   with stream.StreamEngineInvariants.wrap(multi_stream_engine) as stream_engine:
     # Emit initial properties if configured to do so.
     if op_args.annotation_flags.emit_initial_properties:
       with stream_engine.new_step_stream('Initial Properties') as s:
         for key in sorted(properties.iterkeys()):
           s.set_build_property(key, json.dumps(properties[key], sort_keys=True))
 
     try:
       ret = recipe_run.run_steps(
-          properties, stream_engine,
+          rt, stream_engine,
           step_runner.SubprocessStepRunner(stream_engine),
           universe_view=universe_view)
     finally:
       os.chdir(old_cwd)
 
     return handle_recipe_return(ret, args.output_result_json, stream_engine)
 
 
 def remote(args):
   from recipe_engine import remote
@@ skipping 394 matching lines @@
 
   if not isinstance(ret, int):
     if ret is None:
       ret = 0
     else:
       print >> sys.stderr, ret
       ret = 1
   sys.stdout.flush()
   sys.stderr.flush()
   os._exit(ret)