|
15 | 15 |
|
16 | 16 | from codespeed.models import (Environment, Report, Project, Revision, Result, |
17 | 17 | Executable, Benchmark, Branch) |
18 | | - |
| 18 | +from codespeed.domain import (get_default_environment, getbaselineexecutables, |
| 19 | + getdefaultexecutable) |
19 | 20 |
|
20 | 21 | logger = logging.getLogger(__name__) |
21 | 22 |
|
@@ -51,104 +52,6 @@ def no_data_found(request): |
51 | 52 | }, context_instance=RequestContext(request)) |
52 | 53 |
|
53 | 54 |
|
54 | | -def getbaselineexecutables(): |
55 | | - baseline = [{ |
56 | | - 'key': "none", |
57 | | - 'name': "None", |
58 | | - 'executable': "none", |
59 | | - 'revision': "none", |
60 | | - }] |
61 | | - executables = Executable.objects.select_related('project') |
62 | | - revs = Revision.objects.exclude(tag="").select_related('branch__project') |
63 | | - maxlen = 22 |
64 | | - for rev in revs: |
65 | | - # Add executables that correspond to each tagged revision. |
66 | | - for exe in [e for e in executables if e.project == rev.branch.project]: |
67 | | - exestring = str(exe) |
68 | | - if len(exestring) > maxlen: |
69 | | - exestring = str(exe)[0:maxlen] + "..." |
70 | | - name = exestring + " " + rev.tag |
71 | | - key = str(exe.id) + "+" + str(rev.id) |
72 | | - baseline.append({ |
73 | | - 'key': key, |
74 | | - 'executable': exe, |
75 | | - 'revision': rev, |
76 | | - 'name': name, |
77 | | - }) |
78 | | - # move default to first place |
79 | | - if hasattr(settings, 'DEF_BASELINE') and settings.DEF_BASELINE is not None: |
80 | | - try: |
81 | | - exename = settings.DEF_BASELINE['executable'] |
82 | | - commitid = settings.DEF_BASELINE['revision'] |
83 | | - for base in baseline: |
84 | | - if base['key'] == "none": |
85 | | - continue |
86 | | - if (base['executable'].name == exename and |
87 | | - base['revision'].commitid == commitid): |
88 | | - baseline.remove(base) |
89 | | - baseline.insert(1, base) |
90 | | - break |
91 | | - except KeyError: |
92 | | - # TODO: write to server logs |
93 | | - #error in settings.DEF_BASELINE |
94 | | - pass |
95 | | - return baseline |
96 | | - |
97 | | - |
98 | | -def get_default_environment(enviros, data, multi=False): |
99 | | - """Returns the default environment. Preference level is: |
100 | | - * Present in URL parameters (permalinks) |
101 | | - * Value in settings.py |
102 | | - * First Environment ID |
103 | | -
|
104 | | - """ |
105 | | - defaultenviros = [] |
106 | | - # Use permalink values |
107 | | - if 'env' in data: |
108 | | - for env_value in data['env'].split(","): |
109 | | - for env in enviros: |
110 | | - try: |
111 | | - env_id = int(env_value) |
112 | | - except ValueError: |
113 | | - # Not an int |
114 | | - continue |
115 | | - for env in enviros: |
116 | | - if env_id == env.id: |
117 | | - defaultenviros.append(env) |
118 | | - if not multi: |
119 | | - break |
120 | | - # Use settings.py value |
121 | | - if not defaultenviros and not multi: |
122 | | - if (hasattr(settings, 'DEF_ENVIRONMENT') and |
123 | | - settings.DEF_ENVIRONMENT is not None): |
124 | | - for env in enviros: |
125 | | - if settings.DEF_ENVIRONMENT == env.name: |
126 | | - defaultenviros.append(env) |
127 | | - break |
128 | | - # Last fallback |
129 | | - if not defaultenviros: |
130 | | - defaultenviros = enviros |
131 | | - if multi: |
132 | | - return defaultenviros |
133 | | - else: |
134 | | - return defaultenviros[0] |
135 | | - |
136 | | - |
137 | | -def getdefaultexecutable(): |
138 | | - default = None |
139 | | - if hasattr(settings, 'DEF_EXECUTABLE') and settings.DEF_EXECUTABLE is not None: |
140 | | - try: |
141 | | - default = Executable.objects.get(name=settings.DEF_EXECUTABLE) |
142 | | - except Executable.DoesNotExist: |
143 | | - pass |
144 | | - if default is None: |
145 | | - execquery = Executable.objects.filter(project__track=True) |
146 | | - if len(execquery): |
147 | | - default = execquery[0] |
148 | | - |
149 | | - return default |
150 | | - |
151 | | - |
152 | 55 | def getcomparisonexes(): |
153 | 56 | all_executables = {} |
154 | 57 | exekeys = [] |
@@ -689,7 +592,7 @@ def changes(request): |
689 | 592 | selectedrevision = Revision.objects.get( |
690 | 593 | commitid__startswith=commitid, branch=branch |
691 | 594 | ) |
692 | | - if not selectedrevision in revisionlists[selectedrevision.project.name]: |
| 595 | + if selectedrevision not in revisionlists[selectedrevision.project.name]: |
693 | 596 | revisionlists[selectedrevision.project.name].append(selectedrevision) |
694 | 597 | except Revision.DoesNotExist: |
695 | 598 | selectedrevision = lastrevisions[0] |
@@ -735,11 +638,11 @@ def reports(request): |
735 | 638 | context['significant_reports'] = \ |
736 | 639 | Report.objects.filter( |
737 | 640 | revision__branch__name=settings.DEF_BRANCH, |
738 | | - colorcode__in = ('red','green') |
| 641 | + colorcode__in=('red', 'green') |
739 | 642 | ).order_by('-revision__date')[:10] |
740 | 643 |
|
741 | | - return render_to_response('codespeed/reports.html', |
742 | | - context, context_instance=RequestContext(request)) |
| 644 | + return render_to_response('codespeed/reports.html', context, |
| 645 | + context_instance=RequestContext(request)) |
743 | 646 |
|
744 | 647 |
|
745 | 648 | @require_GET |
@@ -780,7 +683,7 @@ def displaylogs(request): |
780 | 683 | rev, e, exc_info=True) |
781 | 684 | error = repr(e) |
782 | 685 |
|
783 | | - # add commit browsing url to logs |
| 686 | + # Add commit browsing url to logs |
784 | 687 | project = rev.branch.project |
785 | 688 | for log in logs: |
786 | 689 | log['commit_browse_url'] = project.commit_browsing_url.format(**log) |
@@ -851,7 +754,7 @@ def validate_result(item): |
851 | 754 |
|
852 | 755 | error = True |
853 | 756 | for key in mandatory_data: |
854 | | - if not key in item: |
| 757 | + if key not in item: |
855 | 758 | return 'Key "' + key + '" missing from request', error |
856 | 759 | elif key in item and item[key] == "": |
857 | 760 | return 'Value for key "' + key + '" empty in request', error |
@@ -995,7 +898,7 @@ def add_json_results(request): |
995 | 898 | if error: |
996 | 899 | logger.debug( |
997 | 900 | "add_json_results: could not save item %d because %s" % ( |
998 | | - i, response)) |
| 901 | + i, response)) |
999 | 902 | return HttpResponseBadRequest(response) |
1000 | 903 | else: |
1001 | 904 | unique_reports.add(response) |
|
0 commit comments