appengine/findit/backend_main.py

# Copyright 2018 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.

import webapp2

import gae_ts_mon

from gae_libs import appengine_util
from gae_libs.pipelines import pipeline_handlers
from handlers import build_ahead
from handlers import calculate_confidence_scores
from handlers import check_reverted_cls
from handlers import collect_tree_closures
from handlers import obscure_emails
from handlers import process_failure_analysis_requests
from handlers import process_flake_analysis_request
from handlers.disabled_tests.detection import detect_test_disablement
from handlers.disabled_tests.export import export_test_disablement
from handlers.flake import update_open_flake_issues
from handlers.flake.detection import detect_flakes
from handlers.flake.detection import process_flakes
from handlers.flake.detection import update_flake_counts
from handlers.flake.reporting import generate_report

# For appengine pipeline running on backend module.
pipeline_backend_application = pipeline_handlers._APP
if appengine_util.IsInProductionApp():
  gae_ts_mon.initialize(pipeline_backend_application)

# "waterfall-backend" module.
waterfall_backend_web_pages_handler_mappings = [
    ('/waterfall/cron/calculate-confidence-scores',
     calculate_confidence_scores.CalculateConfidenceScores),
    ('/waterfall/cron/check-reverted-cls', check_reverted_cls.CheckRevertedCLs),
    ('/waterfall/cron/collect-tree-closures',
     collect_tree_closures.CollectTreeClosures),
    ('/waterfall/cron/obscure-emails', obscure_emails.ObscureEmails),
    ('/waterfall/cron/periodic-build-ahead', build_ahead.BuildAhead),
    ('/waterfall/task/process-failure-analysis-requests',
     process_failure_analysis_requests.ProcessFailureAnalysisRequests),
    ('/waterfall/task/process-flake-analysis-request',
     process_flake_analysis_request.ProcessFlakeAnalysisRequest),
]
waterfall_backend_web_application = webapp2.WSGIApplication(
    waterfall_backend_web_pages_handler_mappings, debug=False)
if appengine_util.IsInProductionApp():
  gae_ts_mon.initialize(waterfall_backend_web_application)

# "disabled-test-backend" module.
disabled_test_backend_web_pages_handler_mappings = [
    ('/disabled-tests/detection/cron/detect-test-disablement',
     detect_test_disablement.DetectTestDisablementCronJob),
    ('/disabled-tests/detection/task/detect-test-disablement',
     detect_test_disablement.DisabledTestDetection),
    ('/disabled-tests/export/cron/export-test-disablement',
     export_test_disablement.ExportTestDisablementCronJob),
    ('/disabled-tests/export/task/export-test-disablement',
     export_test_disablement.DisabledTestExport),
]
disabled_test_backend_web_application = webapp2.WSGIApplication(
    disabled_test_backend_web_pages_handler_mappings, debug=False)
if appengine_util.IsInProductionApp():
  gae_ts_mon.initialize(disabled_test_backend_web_application)

# "flake-detection-backend" module.
flake_detection_backend_web_pages_handler_mappings = [
    ('/flake/detection/cron/detect-hidden-flakes',
     detect_flakes.DetectHiddenFlakesCronJob),
    ('/flake/detection/cron/detect-non-hidden-flakes',
     detect_flakes.DetectNonHiddenFlakesCronJob),
    ('/flake/detection/cron/generate-flakiness-report',
     generate_report.PrepareFlakinessReport),
    ('/flake/detection/cron/process-flakes',
     process_flakes.ProcessFlakesCronJob),
    ('/flake/detection/cron/update-flake-counts',
     update_flake_counts.UpdateFlakeCountsCron),
    ('/flake/detection/task/detect-flakes', detect_flakes.FlakeDetection),
    ('/flake/detection/task/detect-flakes-from-build',
     detect_flakes.DetectFlakesFromFlakyCQBuild),
    ('/flake/detection/task/process-flakes', process_flakes.FlakeAutoAction),
    ('/flake/detection/task/update-flake-counts',
     update_flake_counts.UpdateFlakeCountsTask),
]
flake_detection_backend_web_application = webapp2.WSGIApplication(
    flake_detection_backend_web_pages_handler_mappings, debug=False)
if appengine_util.IsInProductionApp():
  gae_ts_mon.initialize(flake_detection_backend_web_application)

# "auto-action-backend" module.
auto_action_backend_web_pages_handler_mappings = [
    ('/auto-action/cron/update-open-flake-issues',
     update_open_flake_issues.UpdateOpenFlakeIssuesCron),
    ('/auto-action/task/update-open-flake-issues',
     update_open_flake_issues.UpdateOpenFlakeIssuesTask),
]
auto_action_backend_web_application = webapp2.WSGIApplication(
    auto_action_backend_web_pages_handler_mappings, debug=False)
if appengine_util.IsInProductionApp():
  gae_ts_mon.initialize(auto_action_backend_web_application)