OLD | NEW |
1 # Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 # Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
4 | 4 |
5 import json | 5 import json |
6 import logging | 6 import logging |
7 import operator | 7 import operator |
8 | 8 |
9 from appengine_wrappers import GetAppVersion | 9 from appengine_wrappers import GetAppVersion |
10 from object_store_creator import ObjectStoreCreator | |
11 | 10 |
12 class BranchUtility(object): | 11 class BranchUtility(object): |
13 def __init__(self, fetch_url, fetcher, object_store=None): | 12 def __init__(self, fetch_url, fetcher, object_store_creator_factory): |
14 self._fetch_url = fetch_url | 13 self._fetch_url = fetch_url |
15 self._fetcher = fetcher | 14 self._fetcher = fetcher |
16 if object_store is None: | 15 self._object_store = (object_store_creator_factory.Create(BranchUtility) |
17 object_store = (ObjectStoreCreator.SharedFactory(GetAppVersion()) | 16 .Create()) |
18 .Create(BranchUtility).Create()) | |
19 self._object_store = object_store | |
20 | 17 |
21 @staticmethod | 18 @staticmethod |
22 def GetAllBranchNames(): | 19 def GetAllBranchNames(): |
23 return ['stable', 'beta', 'dev', 'trunk'] | 20 return ['stable', 'beta', 'dev', 'trunk'] |
24 | 21 |
25 def GetAllBranchNumbers(self): | 22 def GetAllBranchNumbers(self): |
26 return [(branch, self.GetBranchNumberForChannelName(branch)) | 23 return [(branch, self.GetBranchNumberForChannelName(branch)) |
27 for branch in BranchUtility.GetAllBranchNames()] | 24 for branch in BranchUtility.GetAllBranchNames()] |
28 | 25 |
29 @staticmethod | 26 @staticmethod |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
72 else: | 69 else: |
73 branch_numbers[branch] += 1 | 70 branch_numbers[branch] += 1 |
74 | 71 |
75 sorted_branches = sorted(branch_numbers.iteritems(), | 72 sorted_branches = sorted(branch_numbers.iteritems(), |
76 None, | 73 None, |
77 operator.itemgetter(1), | 74 operator.itemgetter(1), |
78 True) | 75 True) |
79 self._object_store.Set(channel_name, sorted_branches[0][0]) | 76 self._object_store.Set(channel_name, sorted_branches[0][0]) |
80 | 77 |
81 return sorted_branches[0][0] | 78 return sorted_branches[0][0] |
OLD | NEW |