Revert of Cross-repo recipe package system.

scripts/slave/recipe_modules/generator_script/api.py

+# Copyright 2013 The Chromium Authors. All rights reserved.
+# Use of this source code is governed by a BSD-style license that can be
+# found in the LICENSE file.
+
+from recipe_engine import recipe_api
+
+class GeneratorScriptApi(recipe_api.RecipeApi):
+  def __call__(self, path_to_script, *args, **kwargs):
+    """Run a script and generate the steps emitted by that script.
+
+    If a step has a key 'outputs_presentation_json' whose value is
+    True, its command is extended with a --presentation-json argument
+    pointing to a file where it is expected to write presentation json
+    which is used to update that step's presentation on the waterfall.
+
+    Presentation keys are:
+      logs: A map of log names to log text.
+      links: A map of link text to URIs.
+      perf_logs: A map of log names to text.
+      step_summary_text: A string to set as the step summary.
+      step_text: A string to set as the step text.
+      properties: A map of build_property names to JSON-encoded values.
+
+    kwargs:
+      env - The environment for the generated steps.
+    """
+    f = '--output-json'
+    step_name = 'gen step(%s)' % self.m.path.basename(path_to_script)
+
+    step_test_data = kwargs.pop('step_test_data', None)
+    if str(path_to_script).endswith('.py'):
+      step_result = self.m.python(
+        step_name,
+        path_to_script, list(args) + [f, self.m.json.output()],
+        cwd=self.m.path['checkout'], step_test_data=step_test_data)
+    else:
+      step_result = self.m.step(
+        step_name,
+        [path_to_script,] + list(args) + [f, self.m.json.output()],
+        cwd=self.m.path['checkout'], step_test_data=step_test_data)
+    new_steps = step_result.json.output
+    assert isinstance(new_steps, list)
+    env = kwargs.get('env')
+
+    failed_steps = []
+    for step in new_steps:
+      if env:
+        new_env = dict(env)
+        new_env.update(step.get('env', {}))
+        step['env'] = new_env
+      outputs_json = step.pop('outputs_presentation_json', False)
+      if outputs_json:
+        # This step has requested a JSON file which the binary that
+        # it invokes can write to, so provide it with one.
+        step['cmd'].extend(['--presentation-json', self.m.json.output(False)])
+
+      #TODO(martiniss) change this to use a regular step call
+      step['ok_ret'] = set(step.pop('ok_ret', {0}))
+      step['infra_step'] = bool(step.pop('infra_step', False))
+      step['step_nest_level'] = int(step.pop('step_nest_level', 0))
+
+      if step.pop('always_run', False) or not failed_steps:
+        try:
+          self.m.step.run_from_dict(step)
+        except self.m.step.StepFailure:
+          failed_steps.append(step['name'])
+        finally:
+          step_result = self.m.step.active_result
+          if outputs_json:
+            p = step_result.presentation
+            j = step_result.json.output
+
+            if j:
+              p.logs.update(j.get('logs', {}))
+              p.links.update(j.get('links', {}))
+              p.perf_logs.update(j.get('perf_logs', {}))
+              p.step_summary_text = j.get('step_summary_text', '')
+              p.step_text = j.get('step_text', '')
+              p.properties.update(j.get('properties', {}))
+
+    if failed_steps:
+      raise self.m.step.StepFailure(
+        "the following steps in %s failed: %s" %
+        (step_name, failed_steps))