1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
|
# Copyright 2009-2011 Canonical Ltd. This software is licensed under the GNU
# Affero General Public License version 3 (see the file LICENSE).
"""Soyuz vocabularies."""
__metaclass__ = type
__all__ = [
'ComponentVocabulary',
'FilteredDistroArchSeriesVocabulary',
'PackageReleaseVocabulary',
'PPAVocabulary',
'ProcessorFamilyVocabulary',
'ProcessorVocabulary',
]
from sqlobject import AND
from storm.expr import SQL
from zope.component import getUtility
from zope.interface import implements
from zope.schema.vocabulary import SimpleTerm
from lp.registry.model.person import Person
from lp.services.database.sqlbase import (
quote,
sqlvalues,
)
from lp.services.webapp.interfaces import ILaunchBag
from lp.services.webapp.vocabulary import (
IHugeVocabulary,
NamedSQLObjectVocabulary,
SQLObjectVocabularyBase,
)
from lp.soyuz.enums import ArchivePurpose
from lp.soyuz.model.archive import Archive
from lp.soyuz.model.component import Component
from lp.soyuz.model.distroarchseries import DistroArchSeries
from lp.soyuz.model.processor import (
Processor,
ProcessorFamily,
)
from lp.soyuz.model.sourcepackagerelease import SourcePackageRelease
class ComponentVocabulary(SQLObjectVocabularyBase):
_table = Component
_orderBy = 'name'
def toTerm(self, obj):
return SimpleTerm(obj, obj.id, obj.name)
class FilteredDistroArchSeriesVocabulary(SQLObjectVocabularyBase):
"""All arch series of a particular distribution."""
_table = DistroArchSeries
_orderBy = ['DistroSeries.version', 'architecturetag', 'id']
_clauseTables = ['DistroSeries']
def toTerm(self, obj):
name = "%s %s (%s)" % (obj.distroseries.distribution.name,
obj.distroseries.name, obj.architecturetag)
return SimpleTerm(obj, obj.id, name)
def __iter__(self):
distribution = getUtility(ILaunchBag).distribution
if distribution:
query = """
DistroSeries.id = DistroArchSeries.distroseries AND
DistroSeries.distribution = %s
""" % sqlvalues(distribution.id)
results = self._table.select(
query, orderBy=self._orderBy, clauseTables=self._clauseTables)
for distroarchseries in results:
yield self.toTerm(distroarchseries)
class PackageReleaseVocabulary(SQLObjectVocabularyBase):
_table = SourcePackageRelease
_orderBy = 'id'
def toTerm(self, obj):
return SimpleTerm(
obj, obj.id, obj.name + " " + obj.version)
class PPAVocabulary(SQLObjectVocabularyBase):
implements(IHugeVocabulary)
_table = Archive
_orderBy = ['Person.name, Archive.name']
_clauseTables = ['Person']
_filter = AND(
Person.q.id == Archive.q.ownerID,
Archive.q.purpose == ArchivePurpose.PPA)
displayname = 'Select a PPA'
step_title = 'Search'
def toTerm(self, archive):
"""See `IVocabulary`."""
description = archive.description
if description is not None:
summary = description.splitlines()[0]
else:
summary = "No description available"
token = '%s/%s' % (archive.owner.name, archive.name)
return SimpleTerm(archive, token, summary)
def getTermByToken(self, token):
"""See `IVocabularyTokenized`."""
try:
owner_name, archive_name = token.split('/')
except ValueError:
raise LookupError(token)
clause = AND(
self._filter,
Person.name == owner_name,
Archive.name == archive_name)
obj = self._table.selectOne(
clause, clauseTables=self._clauseTables)
if obj is None:
raise LookupError(token)
else:
return self.toTerm(obj)
def search(self, query, vocab_filter=None):
"""Return a resultset of archives.
This is a helper required by `SQLObjectVocabularyBase.searchForTerms`.
"""
if not query:
return self.emptySelectResults()
query = query.lower()
try:
owner_name, archive_name = query.split('/')
except ValueError:
clause = AND(
self._filter,
SQL("(Archive.fti @@ ftq(%s) OR Person.fti @@ ftq(%s))"
% (quote(query), quote(query))))
else:
clause = AND(
self._filter,
Person.name == owner_name,
Archive.name == archive_name)
return self._table.select(
clause, orderBy=self._orderBy, clauseTables=self._clauseTables)
class ProcessorVocabulary(NamedSQLObjectVocabulary):
displayname = 'Select a processor'
_table = Processor
_orderBy = 'name'
class ProcessorFamilyVocabulary(NamedSQLObjectVocabulary):
displayname = 'Select a processor family'
_table = ProcessorFamily
_orderBy = 'name'
|