[Findit] Refactor Findit pipeline.

appengine/findit/waterfall/test/start_try_job_on_demand_pipeline_test.py

 # Copyright 2016 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 testing_utils import testing
-
-from common.pipeline_wrapper import pipeline_handlers
-from model.wf_analysis import WfAnalysis
-from waterfall import try_job_util
+import mock
+
+from common.waterfall import failure_type
+from model.wf_try_job import WfTryJob
+from waterfall import start_try_job_on_demand_pipeline
 from waterfall.start_try_job_on_demand_pipeline import (
     StartTryJobOnDemandPipeline)
-
-
-class StartTryJobOnDemandPipelineTest(testing.AppengineTestCase):
-  app_module = pipeline_handlers._APP
-
-  def _MockTryJobScheduling(self, requests):
-    def Mocked_ScheduleTryJobIfNeeded(*args, **kwargs):
-      requests.append((args, kwargs))
-      return {'compile': 'try-job-key'}
-    self.mock(
-        try_job_util, 'ScheduleTryJobIfNeeded', Mocked_ScheduleTryJobIfNeeded)
+from waterfall.test import wf_testcase
+
+class StartTryJobOnDemandPipelineTest(wf_testcase.WaterfallTestCase):
+
+  def testGetLastPassCurrentBuildIsNotFirstFailure(self):
+    failure_info = {
+        'failed_steps': {
+          'a': {
+              'first_failure': 1,
+              'last_pass': 0
+          }
+        }
+    }
+    last_pass = start_try_job_on_demand_pipeline._GetLastPass(
+      2, failure_info, failure_type.COMPILE)
+    self.assertIsNone(last_pass)
+
+  def testGetLastPassUnknownType(self):
+    last_pass = start_try_job_on_demand_pipeline._GetLastPass(
+      1, {}, failure_type.UNKNOWN)
+    self.assertIsNone(last_pass)
+
+  def testGetLastPassTestNoLastPass(self):
+    try_job_type = failure_type.TEST
+    failure_info = {
+        'failure_type': try_job_type,
+        'builds': {
+            '0': {
+                'blame_list': ['r0', 'r1'],
+                'chromium_revision': 'r1'
+            },
+            '1': {
+                'blame_list': ['r2'],
+                'chromium_revision': 'r2'
+            }
+        },
+        'failed_steps': {
+            'a': {
+                'first_failure': 1,
+                'last_pass': 0,
+                'tests': {
+                    'test1': {
+                        'first_failure': 1
+                    }
+                }
+            }
+        }
+    }
+    last_pass = start_try_job_on_demand_pipeline._GetLastPass(
+      1, failure_info, try_job_type)
+    self.assertIsNone(last_pass)
+
+  def testGetSuspectsFromHeuristicResult(self):
+    heuristic_result = {
+        'failures': [
+            {
+                'step_name': 'compile',
+                'suspected_cls': [
+                    {
+                        'revision': 'r1',
+                    },
+                    {
+                        'revision': 'r2',
+                    },
+                ],
+            },
+        ]
+    }
+    expected_suspected_revisions = ['r1', 'r2']
+    self.assertEqual(
+        expected_suspected_revisions,
+        start_try_job_on_demand_pipeline._GetSuspectsFromHeuristicResult(
+            heuristic_result))
 
   def testNotScheduleTryJobIfBuildNotCompleted(self):
-    requests = []
-    self._MockTryJobScheduling(requests)
+    pipeline = start_try_job_on_demand_pipeline.StartTryJobOnDemandPipeline()
+    result = pipeline.run(
+        'm', 'b', 1, {}, {}, {}, False, False)
+    self.assertEqual(list(result), [])
+
+  @mock.patch.object(start_try_job_on_demand_pipeline, 'try_job_util')
+  def testNotScheduleTryJobIfDontNeedTryJob(self, mock_other):
+    mock_other.NeedANewTryJob.return_value = False
+    pipeline = start_try_job_on_demand_pipeline.StartTryJobOnDemandPipeline()
+    result = pipeline.run(
+        'm', 'b', 1, {}, {}, {}, True, False)
+    self.assertEqual(list(result), [])
+
+  @mock.patch.object(start_try_job_on_demand_pipeline, 'try_job_util')
+  def testNotScheduleTryJobIfUnsupportedFailureType(self, mock_other):
+    mock_other.NeedANewTryJob.return_value = True
+    try_job_type = failure_type.UNKNOWN
+    failure_info = {
+        'failure_type': try_job_type,
+        'builds': {
+            '0': {
+                'blame_list': ['r0', 'r1'],
+                'chromium_revision': 'r1'
+            },
+            '1': {
+                'blame_list': ['r2'],
+                'chromium_revision': 'r2'
+            }
+        },
+        'failed_steps': {
+            'a': {
+                'first_failure': 1,
+                'last_pass': 0
+            }
+        }
+    }
+    pipeline = start_try_job_on_demand_pipeline.StartTryJobOnDemandPipeline()
+    result = pipeline.run(
+        'm', 'b', 1, failure_info, {}, {}, True, False)
+    self.assertEqual(list(result), [])
+
+  @mock.patch.object(start_try_job_on_demand_pipeline, 'try_job_util')
+  def testCompileTryJob(self, mock_other):
+
+    master_name = 'm'
+    builder_name = 'b'
+    build_number = 1
+    try_job_type = failure_type.COMPILE
+    failure_info = {
+        'failure_type': try_job_type,
+        'builds': {
+            '0': {
+                'blame_list': ['r0', 'r1'],
+                'chromium_revision': 'r1'
+            },
+            '1': {
+                'blame_list': ['r2'],
+                'chromium_revision': 'r2'
+            }
+        },
+        'failed_steps': {
+          'compile': {
+              'first_failure': 1,
+              'last_pass': 0
+          }
+        }
+    }
+    good_revision = 'r1'
+    bad_revision = 'r2'
+    WfTryJob.Create('m', 'b', 1).put()
+
+    mock_other.NeedANewTryJob.return_value = True
+    mock_other.GetFailedTargetsFromSignals.return_value = {}
+
+    self.MockPipeline(
+        start_try_job_on_demand_pipeline.ScheduleCompileTryJobPipeline,
+        'try_job_id',
+        expected_args=[
+            master_name, builder_name, build_number, good_revision,
+           bad_revision, try_job_type, {}, []],
+        expected_kwargs={})
+    self.MockPipeline(
+        start_try_job_on_demand_pipeline.MonitorTryJobPipeline,
+        'try_job_result',
+        expected_args=[
+            master_name, builder_name, build_number, try_job_type, 'try_job_id'
+        ],
+        expected_kwargs={})
+    self.MockPipeline(
+        start_try_job_on_demand_pipeline.IdentifyTryJobCulpritPipeline,
+        'final_result',
+        expected_args=[
+            master_name, builder_name, build_number, ['r2'], try_job_type,
+            'try_job_id', 'try_job_result'],
+        expected_kwargs={})
+
     pipeline = StartTryJobOnDemandPipeline()
-    self.assertFalse(pipeline.run(None, None, False, False, None))
-    self.assertEqual(0, len(requests))
-
-  def testTryJobScheduled(self):
-    master_name, builder_name, build_number = 'm', 'b', 123
-    WfAnalysis.Create(master_name, builder_name, build_number).put()
-    failure_info = {
-        'master_name': master_name,
-        'builder_name': builder_name,
-        'build_number': build_number,
-    }
-
-    requests = []
-    self._MockTryJobScheduling(requests)
+    result = pipeline.run(
+        'm', 'b', 1, failure_info, {}, {}, True, False)
+    self.assertNotEqual(list(result), [])
+
+  @mock.patch.object(start_try_job_on_demand_pipeline, 'try_job_util')
+  def testTestTryJob(self, mock_other):
+
+    master_name = 'm'
+    builder_name = 'b'
+    build_number = 1
+    try_job_type = failure_type.TEST
+    failure_info = {
+        'failure_type': try_job_type,
+        'builds': {
+            '0': {
+                'blame_list': ['r0', 'r1'],
+                'chromium_revision': 'r1'
+            },
+            '1': {
+                'blame_list': ['r2'],
+                'chromium_revision': 'r2'
+            }
+        },
+        'failed_steps': {
+            'a': {
+                'first_failure': 1,
+                'last_pass': 0,
+                'tests': {
+                    'test1': {
+                        'first_failure': 1,
+                        'last_pass': 0
+                    }
+                }
+            },
+            'b': {
+                'first_failure': 0,
+                'tests': {
+                    'b_test1': {
+                        'first_failure': 0
+                    }
+                }
+            }
+        }
+    }
+    good_revision = 'r1'
+    bad_revision = 'r2'
+
+    mock_other.NeedANewTryJob.return_value = True
+    mock_other.GetFailedTargetsFromSignals.return_value = {}
+
+    self.MockPipeline(
+        start_try_job_on_demand_pipeline.ScheduleTestTryJobPipeline,
+        'try_job_id',
+        expected_args=[
+            master_name, builder_name, build_number, good_revision,
+           bad_revision, try_job_type, 'targeted_tests', []],
+        expected_kwargs={})
+    self.MockPipeline(
+        start_try_job_on_demand_pipeline.MonitorTryJobPipeline,
+        'try_job_result',
+        expected_args=[
+            master_name, builder_name, build_number, try_job_type, 'try_job_id'
+        ],
+        expected_kwargs={})
+    self.MockPipeline(
+        start_try_job_on_demand_pipeline.IdentifyTryJobCulpritPipeline,
+        'final_result',
+        expected_args=[
+            master_name, builder_name, build_number, ['r2'], try_job_type,
+            'try_job_id', 'try_job_result'],
+        expected_kwargs={})
 
     pipeline = StartTryJobOnDemandPipeline()
-    self.assertTrue(pipeline.run(failure_info, None, True, False, None))
-    self.assertEqual(1, len(requests))
-    self.assertEqual(
-        {'compile': 'try-job-key'},
-        WfAnalysis.Get(
-            master_name, builder_name, build_number).failure_result_map)
+    result = pipeline.run(
+        'm', 'b', 1, failure_info, {}, {}, True, False)
+    WfTryJob.Create('m', 'b', 1).put()
+    self.assertNotEqual(list(result), [])