diff options
Diffstat (limited to 'omaha_server/omaha/tests/test_statistics.py')
-rw-r--r-- | omaha_server/omaha/tests/test_statistics.py | 83 |
1 files changed, 22 insertions, 61 deletions
diff --git a/omaha_server/omaha/tests/test_statistics.py b/omaha_server/omaha/tests/test_statistics.py index bff2b98..ea1f5f5 100644 --- a/omaha_server/omaha/tests/test_statistics.py +++ b/omaha_server/omaha/tests/test_statistics.py @@ -35,7 +35,6 @@ from omaha.parser import parse_request from omaha.statistics import ( userid_counting, add_app_statistics, - add_app_live_statistics, is_user_active, get_kwargs_for_model, parse_os, @@ -44,7 +43,6 @@ from omaha.statistics import ( parse_apps, parse_events, collect_statistics, - update_live_statistics, get_users_statistics_months, get_channel_statistics, get_users_versions, @@ -124,11 +122,11 @@ class StatisticsTest(TestCase): userid = 1 channel = DEFAULT_CHANNEL platform = 'win' - app_kwargs = dict(appid='{F97917B1-20AB-48C1-9802-CEF305B10804}', version='30.0.123.1234') + app_kwargs = dict(appid='{2882CF9B-D9C2-4edb-9AAF-8ED5FCF366F7}', nextversion='0.0.0.1') success_app = create_app_xml(events=fixtures.event_install_success, **app_kwargs) error_app = create_app_xml(events=fixtures.event_install_error, **app_kwargs) appid = app_kwargs.get('appid') - version = app_kwargs.get('version') + version = app_kwargs.get('nextversion') events_request_appid = lambda date=now: DayEvents.from_date('request:%s' % appid, date) events_new_appid = lambda date=now: DayEvents.from_date('new_install:%s' % appid, date) @@ -138,7 +136,6 @@ class StatisticsTest(TestCase): events_request_appid_channel = lambda date=now: DayEvents.from_date('request:{}:{}'.format(appid, channel), date) events_request_appid_platform_version = lambda date=now: DayEvents.from_date('request:{}:{}:{}'.format(appid, platform, version), date) - self.assertEqual(len(events_new_appid()), 0) self.assertEqual(len(events_request_appid()), 0) self.assertEqual(len(events_request_appid_version()), 0) @@ -201,31 +198,6 @@ class StatisticsTest(TestCase): self.assertIn(userid, events_request_appid(next_month)) self.assertIn(userid, events_request_appid_platform(next_month)) - def test_add_app_live_statistics(self): - request = parse_request(fixtures.request_update_check) - app = request.findall('app')[0] - - now = datetime.utcnow() - userid = 1 - platform = 'win' - - appid = app.get('appid') - version = app.get('version') - - events_appid_version = HourEvents('online:{}:{}'.format(appid, version), now.year, now.month, now.day, now.hour) - events_appid_platform_version = HourEvents('online:{}:{}:{}'.format(appid, platform, version), now.year, now.month, now.day, now.hour) - - self.assertEqual(len(events_appid_version), 0) - self.assertEqual(len(events_appid_platform_version), 0) - - add_app_live_statistics(userid, platform, app) - - self.assertEqual(len(events_appid_version), 1) - self.assertEqual(len(events_appid_platform_version), 1) - - self.assertIn(userid, events_appid_version) - self.assertIn(userid, events_appid_platform_version) - def test_is_user_active(self): userid = '{F07B3878-CD6F-4B96-B52F-95C4D23077E0}' id = get_id(userid) @@ -393,7 +365,7 @@ class StatisticsTest(TestCase): for e in events: self.assertIn(e, app_req.events.all()) - def test_update_live_statistics_install(self): + def test_live_statistics_install(self): request = parse_request(fixtures.request_event_install_success) apps = request.findall('app') app = apps[0] @@ -406,46 +378,35 @@ class StatisticsTest(TestCase): version_1 = '0.0.0.1' version_2 = '0.0.0.2' - events_appid_version_1 = HourEvents('online:{}:{}'.format(appid, version_1), now.year, now.month, now.day, now.hour) - events_appid_platform_version_1 = HourEvents('online:{}:{}:{}'.format(appid, platform, version_1), now.year, now.month, now.day, now.hour) - - self.assertEqual(len(events_appid_version_1), 0) - self.assertEqual(len(events_appid_platform_version_1), 0) + events_appid_version = lambda version: HourEvents('request:{}:{}'.format(appid, version), now.year, now.month, now.day, now.hour) + events_appid_platform_version = lambda version: HourEvents('request:{}:{}'.format(appid, version), now.year, now.month, now.day, now.hour) - update_live_statistics(userid, apps, platform) + self.assertEqual(len(events_appid_version(version_1)), 0) + self.assertEqual(len(events_appid_platform_version(version_1)), 0) + userid_counting(userid, apps, platform) - self.assertEqual(len(events_appid_version_1), 1) - self.assertEqual(len(events_appid_platform_version_1), 1) + self.assertEqual(len(events_appid_version(version_1)), 1) + self.assertEqual(len(events_appid_platform_version(version_1)), 1) request = parse_request(fixtures.request_event_update_success) apps = request.findall('app') - update_live_statistics(userid, apps, platform) + userid_counting(userid, apps, platform) - events_appid_version_1 = HourEvents('online:{}:{}'.format(appid, version_1), now.year, now.month, now.day, now.hour) - events_appid_platform_version_1 = HourEvents('online:{}:{}:{}'.format(appid, platform, version_1), now.year, now.month, now.day, now.hour) - events_appid_version_2 = HourEvents('online:{}:{}'.format(appid, version_2), now.year, now.month, now.day, now.hour) - events_appid_platform_version_2 = HourEvents('online:{}:{}:{}'.format(appid, platform, version_2), now.year, now.month, now.day, now.hour) - - self.assertEqual(len(events_appid_version_1), 0) - self.assertEqual(len(events_appid_platform_version_1), 0) - self.assertEqual(len(events_appid_version_2), 1) - self.assertEqual(len(events_appid_platform_version_2), 1) + self.assertEqual(len(events_appid_version(version_1)), 0) + self.assertEqual(len(events_appid_platform_version(version_1)), 0) + self.assertEqual(len(events_appid_version(version_2)), 1) + self.assertEqual(len(events_appid_platform_version(version_2)), 1) request = parse_request(fixtures.request_event_uninstall_success) apps = request.findall('app') - update_live_statistics(userid, apps, platform) - - events_appid_version_2 = HourEvents('online:{}:{}'.format(appid, version_2), - now.year, now.month, now.day, now.hour) - events_appid_platform_version_2 = HourEvents('online:{}:{}:{}'.format(appid, platform, version_2), - now.year, now.month, now.day, now.hour) + userid_counting(userid, apps, platform) - self.assertEqual(len(events_appid_version_2), 1) - self.assertEqual(len(events_appid_platform_version_2), 1) + self.assertEqual(len(events_appid_version(version_2)), 1) + self.assertEqual(len(events_appid_platform_version(version_2)), 1) - def test_update_live_statistics_updatecheck(self): + def test_live_statistics_updatecheck(self): request = parse_request(fixtures.request_update_check) apps = request.findall('app') app = apps[0] @@ -457,13 +418,13 @@ class StatisticsTest(TestCase): appid = app.get('appid') version = app.get('version') - events_appid_version = HourEvents('online:{}:{}'.format(appid, version), now.year, now.month, now.day, now.hour) - events_appid_platform_version = HourEvents('online:{}:{}:{}'.format(appid, platform, version), now.year, now.month, now.day, now.hour) + events_appid_version = HourEvents('request:{}:{}'.format(appid, version), now.year, now.month, now.day, now.hour) + events_appid_platform_version = HourEvents('request:{}:{}:{}'.format(appid, platform, version), now.year, now.month, now.day, now.hour) self.assertEqual(len(events_appid_version), 0) self.assertEqual(len(events_appid_platform_version), 0) - update_live_statistics(userid, apps, platform) + userid_counting(userid, apps, platform) self.assertEqual(len(events_appid_version), 1) self.assertEqual(len(events_appid_platform_version), 1) |