Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(20)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: infra_libs/event_mon/test/monitoring_test.py

Issue 2213143002: Add infra_libs as a bootstrap dependency. (Closed) Base URL: https://chromium.googlesource.com/infra/infra.git@master
Patch Set: Removed the ugly import hack Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« bootstrap/deps.pyl ('K') | « infra_libs/event_mon/test/data/valid_creds.json ('k') | infra_libs/event_mon/test/router_test.py » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: infra_libs/event_mon/test/monitoring_test.py
diff --git a/infra_libs/event_mon/test/monitoring_test.py b/infra_libs/event_mon/test/monitoring_test.py
deleted file mode 100644
index 51316be2fa9c9f5180fb9b4cd1bec924bbd3ad22..0000000000000000000000000000000000000000
--- a/infra_libs/event_mon/test/monitoring_test.py
+++ /dev/null
@@ -1,1267 +0,0 @@
-# -*- encoding:utf-8 -*-
-# Copyright 2015 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 unittest
-
-from infra_libs import event_mon
-from infra_libs.event_mon import config, router
-from infra_libs.event_mon import monitoring
-from infra_libs.event_mon.protos.chrome_infra_log_pb2 import (
- ChromeInfraEvent, ServiceEvent, BuildEvent)
-from infra_libs.event_mon.protos.log_request_lite_pb2 import LogRequestLite
-from infra_libs.event_mon.protos.goma_stats_pb2 import GomaStats
-
-
-class ConstantTest(unittest.TestCase):
- def test_constants(self):
- # Make sure constants have not been renamed since they're part of the API.
- self.assertTrue(event_mon.EVENT_TYPES)
- self.assertTrue(event_mon.TIMESTAMP_KINDS)
- self.assertTrue(event_mon.BUILD_EVENT_TYPES)
- self.assertTrue(event_mon.BUILD_RESULTS)
-
-
-class GetServiceEventTest(unittest.TestCase):
-
- # We have to setup and tear down event_mon for each test to avoid
- # interactions between tests because event_mon stores a global state.
- def setUp(self):
- event_mon.setup_monitoring(run_type='dry')
-
- def tearDown(self):
- event_mon.close()
-
- def test_get_service_event_default(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- log_event = monitoring._get_service_event('START').log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the correct thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('service_event'))
- self.assertTrue(event.service_event.HasField('type'))
- self.assertEquals(event.service_event.type, ServiceEvent.START)
- self.assertEquals(event.timestamp_kind, ChromeInfraEvent.BEGIN)
-
- def test_get_service_event_correct_versions(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- code_version = [
- {'source_url': 'https://fake.url/thing',
- 'revision': '708329c2aeece8aac33af6a5a772ffb14b55903f'},
- {'source_url': 'svn://fake_svn.url/other_thing',
- 'revision': '123456'},
- {'source_url': 'https://other_fake.url/yet_another_thing',
- 'version': 'v2.0'},
- {'source_url': 'https://other_fake2.url/yet_another_thing2',
- 'dirty': True},
- ]
-
- log_event = monitoring._get_service_event(
- 'START', code_version=code_version).log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- code_version_p = event.service_event.code_version
- self.assertEquals(len(code_version_p), len(code_version))
-
- self.assertEqual(code_version_p[0].source_url,
- code_version[0]['source_url'])
- self.assertEqual(code_version_p[0].git_hash, code_version[0]['revision'])
- self.assertFalse(code_version_p[0].HasField('svn_revision'))
-
- self.assertEqual(code_version_p[1].source_url,
- code_version[1]['source_url'])
- self.assertEqual(code_version_p[1].svn_revision,
- int(code_version[1]['revision']))
- self.assertFalse(code_version_p[1].HasField('git_hash'))
-
- self.assertEqual(code_version_p[2].source_url,
- code_version[2]['source_url'])
- self.assertFalse(code_version_p[2].HasField('svn_revision'))
- self.assertEqual(code_version_p[2].version,
- code_version[2]['version'])
-
- self.assertEqual(code_version_p[3].source_url,
- code_version[3]['source_url'])
- self.assertEqual(code_version_p[3].dirty, True)
-
- def test_get_service_event_stop(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- log_event = monitoring._get_service_event('STOP').log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertEqual(event.service_event.type, ServiceEvent.STOP)
- self.assertEquals(event.timestamp_kind, ChromeInfraEvent.END)
-
- def test_get_service_event_update(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- log_event = monitoring._get_service_event('UPDATE').log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertEqual(event.service_event.type, ServiceEvent.UPDATE)
- self.assertEquals(event.timestamp_kind, ChromeInfraEvent.POINT)
-
- def test_get_service_event_crash_simple(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- log_event = monitoring._get_service_event('CRASH').log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertEqual(event.service_event.type, ServiceEvent.CRASH)
- self.assertEquals(event.timestamp_kind, ChromeInfraEvent.END)
-
- def test_get_service_event_crash_with_ascii_trace(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- stack_trace = 'A nice ascii string'
- log_event = monitoring._get_service_event(
- 'CRASH', stack_trace=stack_trace).log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertEqual(event.service_event.type, ServiceEvent.CRASH)
- self.assertEqual(event.service_event.stack_trace, stack_trace)
- self.assertEquals(event.timestamp_kind, ChromeInfraEvent.END)
-
- def test_get_service_event_crash_with_unicode_trace(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- stack_trace = u"Soyez prêt à un étrange goût de Noël."
- log_event = monitoring._get_service_event(
- 'CRASH', stack_trace=stack_trace).log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertEqual(event.service_event.type, ServiceEvent.CRASH)
- self.assertEqual(event.service_event.stack_trace, stack_trace)
- self.assertEquals(event.timestamp_kind, ChromeInfraEvent.END)
-
- def test_get_service_event_crash_with_big_trace(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- stack_trace = "this is way too long" * 55
- self.assertTrue(len(stack_trace) > monitoring.STACK_TRACE_MAX_SIZE)
- log_event = monitoring._get_service_event(
- 'CRASH', stack_trace=stack_trace).log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertEqual(event.service_event.type, ServiceEvent.CRASH)
- self.assertEqual(len(event.service_event.stack_trace),
- monitoring.STACK_TRACE_MAX_SIZE)
- self.assertEquals(event.timestamp_kind, ChromeInfraEvent.END)
-
- def test_get_service_event_crash_invalid_trace(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- # This is not a stacktrace
- stack_trace = 123456
- # Should not crash
- log_event = monitoring._get_service_event(
- 'CRASH', stack_trace=stack_trace).log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
-
- # Send only valid data this time
- self.assertEqual(event.service_event.type, ServiceEvent.CRASH)
- self.assertFalse(event.service_event.HasField('stack_trace'))
-
- def test_get_service_event_trace_without_crash(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- stack_trace = 'A nice ascii string'
- log_event = monitoring._get_service_event(
- 'START', stack_trace=stack_trace).log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
-
- # Make sure we send even invalid data.
- self.assertEqual(event.service_event.type, ServiceEvent.START)
- self.assertEqual(event.service_event.stack_trace, stack_trace)
- self.assertEquals(event.timestamp_kind, ChromeInfraEvent.BEGIN)
-
- def test_get_service_event_with_non_default_service_name(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- log_event = monitoring._get_service_event(
- 'START', service_name='my.nice.service.name').log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('service_event'))
- self.assertTrue(event.service_event.HasField('type'))
- self.assertEquals(event.service_event.type, ServiceEvent.START)
- self.assertEquals(event.event_source.service_name, 'my.nice.service.name')
-
- def test_get_service_event_with_unicode_service_name(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
- service_name = u'à_la_française_hé_oui'
- log_event = monitoring._get_service_event(
- 'START', service_name=service_name).log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('service_event'))
- self.assertTrue(event.service_event.HasField('type'))
- self.assertEquals(event.service_event.type, ServiceEvent.START)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertEquals(event.timestamp_kind, ChromeInfraEvent.BEGIN)
-
-class SendServiceEventTest(unittest.TestCase):
- def setUp(self):
- event_mon.setup_monitoring(run_type='dry')
-
- def tearDown(self):
- event_mon.close()
-
- def test_send_service_event_bad_versions(self):
- # Check that an invalid version does not cause any exception.
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- code_version = [{}, {'revision': 'https://fake.url'}]
- log_event = monitoring._get_service_event(
- 'START', code_version=code_version).log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('service_event'))
- self.assertTrue(event.service_event.HasField('type'))
- self.assertEqual(len(event.service_event.code_version), 0)
-
- def test_send_service_event_bad_type(self):
- # Check that an invalid type for code_version does not raise
- # any exception.
-
- code_versions = [None, 123, 'string',
- [None], [123], ['string'], [['list']]]
- for code_version in code_versions:
- log_event = monitoring._get_service_event(
- 'START', code_version=code_version).log_event()
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('service_event'))
- self.assertTrue(event.service_event.HasField('type'))
- self.assertEqual(len(event.service_event.code_version), 0)
-
- def test_send_service_event_smoke(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- self.assertTrue(event_mon.send_service_event('START'))
- self.assertTrue(event_mon.send_service_event('START',
- timestamp_kind=None))
- self.assertTrue(event_mon.send_service_event('START',
- timestamp_kind='BEGIN'))
- self.assertTrue(event_mon.send_service_event('STOP',
- timestamp_kind='END',
- event_timestamp=1234))
-
- def test_send_service_errors(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- self.assertFalse(event_mon.send_service_event('invalid'))
- self.assertFalse(event_mon.send_service_event('START',
- timestamp_kind='invalid'))
- self.assertFalse(event_mon.send_service_event(
- 'START', event_timestamp='2015-01-25'))
-
-
-class GetBuildEventTest(unittest.TestCase):
- def setUp(self):
- event_mon.setup_monitoring(run_type='dry')
-
- def tearDown(self):
- event_mon.close()
-
- def test_get_build_event_default(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
-
- def test_get_build_event_with_patch_url(self):
- patch_url = 'http://foo.bar/123#456'
- log_event = monitoring.get_build_event(
- 'BUILD', 'bot.host.name', 'build_name', patch_url=patch_url).log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.patch_url, patch_url)
-
- def test_get_build_event_with_bbucket_id(self):
- log_event = monitoring.get_build_event(
- 'BUILD', 'bot.host.name', 'build_name', bbucket_id=123).log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.bbucket_id, 123)
-
- # Try invalid value. This should not throw any exceptions.
- log_event = monitoring.get_build_event(
- 'BUILD', 'bot.host.name', 'build_name', bbucket_id='foo').log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- def test_get_build_event_with_category(self):
- log_event = monitoring.get_build_event(
- 'BUILD', 'bot.host.name', 'build_name',
- category='git_cl_try').log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(
- event.build_event.category, BuildEvent.CATEGORY_GIT_CL_TRY)
-
- # Try unknown value. Should produce CATEGORY_UNKNOWN.
- log_event = monitoring.get_build_event(
- 'BUILD', 'bot.host.name', 'build_name', category='foobar').log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(
- event.build_event.category, BuildEvent.CATEGORY_UNKNOWN)
-
- # Try empty value. Should not set category.
- log_event = monitoring.get_build_event(
- 'BUILD', 'bot.host.name', 'build_name', category='').log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertFalse(event.build_event.HasField('category'))
-
- def test_get_build_event_invalid_type(self):
- # An invalid type is a critical error.
- log_event = monitoring.get_build_event('INVALID_TYPE',
- 'bot.host.name',
- 'build_name').log_event()
- self.assertIsNone(log_event)
-
- def test_get_build_event_invalid_build_name(self):
- # an invalid builder name is not a critical error.
- hostname = 'bot.host.name'
- log_event = monitoring.get_build_event('BUILD', hostname, '').log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
-
- self.assertFalse(event.build_event.HasField('build_name'))
-
- def test_get_build_event_invalid_hostname(self):
- # an invalid hostname is not a critical error.
- builder_name = 'builder_name'
- log_event = monitoring.get_build_event(
- 'BUILD', None, builder_name).log_event()
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.build_name, builder_name)
-
- self.assertFalse(event.build_event.HasField('host_name'))
-
- def test_get_build_event_with_build_zero(self):
- # testing 0 is important because bool(0) == False
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 0
- build_scheduling_time = 123456789
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
-
- def test_get_build_event_with_build_non_zero(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265 # int32
- build_scheduling_time = 123456789
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
-
- def test_get_build_event_invalid_scheduler(self):
- # Providing a build number on a scheduler event is invalid.
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265 # int32
- log_event = monitoring.get_build_event(
- 'SCHEDULER',
- hostname,
- build_name,
- build_number=build_number).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.SCHEDULER)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
-
- self.assertFalse(event.build_event.HasField('build_scheduling_time_ms'))
-
- def test_get_build_event_invalid_buildname(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265 # int32
- build_scheduling_time = 123456789
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
-
- def test_get_build_event_missing_build_number(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_scheduling_time = 123456789
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_scheduling_time=build_scheduling_time).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
-
- self.assertFalse(event.build_event.HasField('build_number'))
-
- def test_get_build_event_with_default_build_number(self):
- event_mon.setup_monitoring()
- orig_event = event_mon.get_default_event()
- build_number = 123
- orig_event.build_event.build_number = build_number
- event_mon.set_default_event(orig_event)
-
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_scheduling_time = 123456789
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_scheduling_time=build_scheduling_time).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
-
- self.assertEquals(event.build_event.build_number, build_number)
-
- def test_get_build_event_build_number_overwrites_default(self):
- event_mon.setup_monitoring()
- orig_event = event_mon.get_default_event()
- orig_event.build_event.build_number = 123
- event_mon.set_default_event(orig_event)
-
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 0 # zero should override the default value
- build_scheduling_time = 123456789
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
-
- def test_get_build_event_with_step_info_wrong_type(self):
- # BUILD event with step info is invalid.
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
- step_name = 'step_name'
- step_text = 'step_text'
- step_number = 0 # valid step number
-
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- step_name=step_name,
- step_text=step_text,
- step_number=step_number).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
- self.assertEquals(event.build_event.step_name, step_name)
- self.assertEquals(event.build_event.step_text, step_text)
- self.assertEquals(event.build_event.step_number, step_number)
-
- def test_get_build_event_with_step_info(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
- step_name = 'step_name'
- step_number = 0 # valid step number
-
- log_event = monitoring.get_build_event(
- 'STEP',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- step_name=step_name,
- step_number=step_number).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.STEP)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
- self.assertEquals(event.build_event.step_name, step_name)
- self.assertEquals(event.build_event.step_number, step_number)
-
- def test_get_build_event_step_name_in_default(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
- step_number = 0 # valid step number
- step_name = 'step_name'
-
- event_mon.setup_monitoring()
- orig_event = event_mon.get_default_event()
- orig_event.build_event.step_name = step_name
- event_mon.set_default_event(orig_event)
-
- log_event = monitoring.get_build_event(
- 'STEP',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- step_number=step_number).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.STEP)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
- self.assertEquals(event.build_event.step_number, step_number)
-
- self.assertEquals(event.build_event.step_name, step_name)
-
- def test_get_build_event_missing_step_name(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
- step_number = 0 # valid step number
-
- log_event = monitoring.get_build_event(
- 'STEP',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- step_number=step_number).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.STEP)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
- self.assertEquals(event.build_event.step_number, step_number)
-
- self.assertFalse(event.build_event.HasField('step_name'))
-
- def test_get_build_event_missing_step_text(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
- step_number = 0 # valid step number
-
- log_event = monitoring.get_build_event(
- 'STEP',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- step_number=step_number).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertFalse(event.build_event.HasField('step_text'))
-
- def test_get_build_event_missing_step_number(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
- step_name = 'step_name'
-
- log_event = monitoring.get_build_event(
- 'STEP',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- step_name=step_name).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.STEP)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
- self.assertEquals(event.build_event.step_name, step_name)
-
- self.assertFalse(event.build_event.HasField('step_number'))
-
- def test_get_build_event_step_info_missing_build_info(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- step_name = 'step_name'
- step_number = 0 # valid step number
-
- log_event = monitoring.get_build_event(
- 'STEP',
- hostname,
- build_name,
- step_name=step_name,
- step_number=step_number).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.STEP)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.step_name, step_name)
- self.assertEquals(event.build_event.step_number, step_number)
-
- self.assertFalse(event.build_event.HasField('build_number'))
- self.assertFalse(event.build_event.HasField('build_scheduling_time_ms'))
-
- def test_get_build_event_with_invalid_result(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
- result = '---INVALID---'
-
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- result=result).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
-
- self.assertFalse(event.build_event.HasField('result'))
-
- def test_get_build_event_with_valid_result(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
- result = 'SUCCESS'
-
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- result=result).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
- self.assertEquals(event.build_event.result, BuildEvent.SUCCESS)
-
- def test_get_build_event_test_result_mapping(self):
- # Tests the hacky mapping between buildbot results and the proto values.
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
-
- # WARNINGS -> WARNING
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- result='WARNINGS').log_event() # with an S
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
- self.assertEquals(event.build_event.result, BuildEvent.WARNING) # no S
-
- # EXCEPTION -> INFRA_FAILURE
- log_event = monitoring.get_build_event(
- 'BUILD',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- result='EXCEPTION').log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
- self.assertEquals(event.build_event.result, BuildEvent.INFRA_FAILURE)
-
- def test_get_build_event_valid_result_wrong_type(self):
- # SCHEDULER can't have a result
- hostname = 'bot.host.name'
- build_name = 'build_name'
- build_number = 314159265
- build_scheduling_time = 123456789
- result = 'SUCCESS'
-
- log_event = monitoring.get_build_event(
- 'SCHEDULER',
- hostname,
- build_name,
- build_number=build_number,
- build_scheduling_time=build_scheduling_time,
- result=result).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.SCHEDULER)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.build_event.build_number, build_number)
- self.assertEquals(event.build_event.build_scheduling_time_ms,
- build_scheduling_time)
- self.assertEquals(event.build_event.result, BuildEvent.SUCCESS)
-
- def test_get_build_event_with_non_default_service_name(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my.other.nice.service'
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
-
- def test_get_build_event_with_unicode_service_name(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = u'à_la_française'
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
-
- def test_get_build_event_with_invalid_service_name(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 1234 # invalid
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name).log_event()
-
- self.assertIsNone(log_event)
-
- def test_get_build_event_with_extra_result_code_string(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- extra_result_code='result').log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertEquals(event.build_event.extra_result_code, ['result'])
-
- def test_get_build_event_with_extra_result_code_list(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
- extra_results = ['result1', 'result2']
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- extra_result_code=extra_results).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertEquals(event.build_event.extra_result_code, extra_results)
-
- def test_get_build_event_with_extra_result_code_invalid_scalar(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
- extra_results = 1234
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- extra_result_code=extra_results).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertEquals(len(event.build_event.extra_result_code), 0)
-
- def test_get_build_event_with_extra_result_code_invalid_list(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
- extra_results = [1234, 'result']
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- extra_result_code=extra_results).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertEquals(event.build_event.extra_result_code, ['result'])
-
- def test_get_build_event_with_goma_stats(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
- goma_stats = GomaStats()
- goma_stats.request_stats.total = 42
-
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- goma_stats=goma_stats).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertEquals(event.build_event.goma_stats, goma_stats)
-
- def test_get_build_event_invalid_goma_stats(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
-
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- goma_stats='what-is-a-string-doing-here?').log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertFalse(event.build_event.HasField('goma_stats'))
-
- def test_get_build_event_with_goma_error_unknown(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
- goma_error = 'GOMA_ERROR_UNKNOWN'
-
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- goma_error=goma_error).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertEquals(event.build_event.goma_error,
- BuildEvent.GOMA_ERROR_UNKNOWN)
-
- def test_get_build_event_with_goma_error_crash(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
- goma_error = 'GOMA_ERROR_CRASHED'
- goma_crash_report_id = '0123456789abcdef'
-
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- goma_error=goma_error, goma_crash_report_id=goma_crash_report_id
- ).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertEquals(event.build_event.goma_error,
- BuildEvent.GOMA_ERROR_CRASHED)
- self.assertEquals(event.build_event.goma_crash_report_id,
- goma_crash_report_id)
-
- def test_get_build_event_with_goma_error_non_crash_with_crash_id(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
- goma_error = 'GOMA_ERROR_UNKNOWN'
- goma_crash_report_id = '0123456789abcdef'
-
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- goma_error=goma_error, goma_crash_report_id=goma_crash_report_id
- ).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- self.assertEquals(event.build_event.goma_error,
- BuildEvent.GOMA_ERROR_UNKNOWN)
- self.assertEquals(event.build_event.goma_crash_report_id,
- goma_crash_report_id)
-
- def test_get_build_event_with_both_goma_error_and_stats(self):
- hostname = 'bot.host.name'
- build_name = 'build_name'
- service_name = 'my nice service'
- goma_error = 'GOMA_ERROR_UNKNOWN'
- goma_stats = GomaStats()
- goma_stats.request_stats.total = 42
-
- log_event = monitoring.get_build_event(
- 'BUILD', hostname, build_name, service_name=service_name,
- goma_stats=goma_stats, goma_error=goma_error,
- ).log_event()
-
- self.assertIsInstance(log_event, LogRequestLite.LogEventLite)
- self.assertTrue(log_event.HasField('event_time_ms'))
- self.assertTrue(log_event.HasField('source_extension'))
-
- # Check that source_extension deserializes to the right thing.
- event = ChromeInfraEvent.FromString(log_event.source_extension)
- self.assertTrue(event.HasField('build_event'))
- self.assertEquals(event.build_event.type, BuildEvent.BUILD)
- self.assertEquals(event.build_event.host_name, hostname)
- self.assertEquals(event.build_event.build_name, build_name)
- self.assertEquals(event.event_source.service_name, service_name)
- # warns but allow to have both.
- self.assertEquals(event.build_event.goma_error,
- BuildEvent.GOMA_ERROR_UNKNOWN)
- self.assertEquals(event.build_event.goma_stats, goma_stats)
-
-
-class SendBuildEventTest(unittest.TestCase):
- def setUp(self):
- event_mon.setup_monitoring(run_type='dry')
-
- def tearDown(self):
- event_mon.close()
-
- def test_send_build_event_smoke(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- self.assertTrue(event_mon.send_build_event('BUILD',
- 'bot.host.name',
- 'build.name'))
- self.assertTrue(event_mon.send_build_event(
- 'BUILD',
- 'bot.host.name',
- 'build_name',
- build_number=1,
- build_scheduling_time=123456789,
- result='FAILURE',
- timestamp_kind='POINT',
- event_timestamp=None))
-
-
-class SendEventsTest(unittest.TestCase):
- def setUp(self):
- event_mon.setup_monitoring(run_type='dry')
-
- def tearDown(self):
- event_mon.close()
-
- def test_send_events_smoke(self):
- self.assertIsInstance(config._router, router._Router)
- self.assertIsInstance(config._cache.get('default_event'), ChromeInfraEvent)
-
- events = [
- event_mon.get_build_event(
- 'BUILD',
- 'bot.host.name',
- 'build_name',
- build_number=1,
- build_scheduling_time=123456789,
- result='FAILURE',
- timestamp_kind='POINT',
- event_timestamp=None),
- event_mon.get_build_event(
- 'BUILD',
- 'bot2.host.name',
- 'build_name2',
- build_number=1,
- build_scheduling_time=123456789,
- result='FAILURE',
- timestamp_kind='POINT',
- event_timestamp=None),
- ]
- self.assertTrue(monitoring.send_events(events))
« bootstrap/deps.pyl ('K') | « infra_libs/event_mon/test/data/valid_creds.json ('k') | infra_libs/event_mon/test/router_test.py » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698