« back to all changes in this revision
Viewing changes to lib/canonical/arch/broker.py
- browse files at revision 63.1.148
- compare with another revision
- compare with revision 6744
- download diff
- download tarball
- view history from revision 63.1.148
- Committer: Robert Collins
- Date: 2005-10-31 18:29:12 UTC
- mfrom: (1102.1.126)
- mto: (1102.1.138) (63.1.155)
- mto: This revision was merged to the branch mainline in revision 2836.
- Revision ID: robertc@robertcollins.net-20051031182912-5b96cbfc568d7a46
Merge ddaa and my branch.
- files added:
- .bzrignore
- lib/bzrlib
- files removed:
- lib/canonical/arch
- lib/canonical/arch/tests
- files renamed:
- database/schema/pending/BranchDataStorage.sql => database/schema/patch-25-99-0.sql
- files modified:
- database/sampledata/current.sql
added
removed
lib/canonical/arch/broker.py
1
# arch-tag: 27f07153-69b6-4ddb-b704-eaabcca57e3e
2
# Author: Rob Weir <rob.weir@canonical.com>
3
# Copyright (C) 2004 Canonical Software
4
5
from pybaz import NameParser
6
7
from zope.interface import implements, classProvides
8
from canonical.launchpad.interfaces import INamespaceObject, ISourceTreeAPI, \
9
ISourceTreeFactory, IFileName, \
10
IArchiveItem, ICategoryItem, \
11
IRevisionFactory, IPatchlog, \
12
ICategoryFactory, ICategory, \
13
ILogMessage, IArchSourceTree, \
14
IDirName, IPathNameFactory, \
15
IArchiveLocation, IArchive, \
16
IBranchItem, IVersionItem, \
17
IBranch, IBranchFactory, \
18
ISetupable, IPackage, \
19
IArchiveCollection, \
20
IVersion,IRevision, \
21
IRevisionIterable, \
22
ICategoryIterable, \
23
IVersionIterable, \
24
IBranchIterable, \
25
ILogMessageFactory, \
26
IPathName, \
27
NamespaceError
28
from canonical.launchpad import database
29
from canonical.lp.dbschema import ArchArchiveType
30
31
import pybaz as arch
32
33
###############################################################################
34
### NamespaceObject
35
36
class NamespaceObject(object):
37
"""
38
Implement canonical.launchpad.interfaces.INamespaceObject against the
39
Soyuz database.
40
"""
41
42
implements(INamespaceObject)
43
44
def __init__(self, fullname):
45
"""Set our own name"""
46
self._fullname = fullname
47
48
def fullname(self):
49
return self._fullname
50
51
# Fullname is the *fully-qualified name of the object*
52
# eg rob@bah/baz--bor--0 is the fullname of a Version
53
fullname = property(fullname)
54
55
_eq_interface = None
56
57
def __eq__(self, x):
58
"""Are we not equal to x?"""
59
return x is not None \
60
and (id(x) == id(self)
61
or (self._eq_interface.providedBy(x)
62
and self.fullname == x.fullname))
63
64
def __ne__(self, x):
65
"""Are we not equal to x?"""
66
return not self.__eq__(x)
67
68
69
###############################################################################
70
### Iteration base classes
71
72
class RevisionIterable(object):
73
74
implements(IRevisionIterable)
75
76
def iter_revisions(self, reverse=False):
77
raise NotImplementedError, "Not implemented yet"
78
79
def iter_library_revisions(self, reverse=False):
80
raise NotImplementedError, "Not implemented yet"
81
82
83
class VersionIterable(RevisionIterable):
84
85
implements(IVersionIterable)
86
87
def iter_versions(self, reverse=False):
88
raise NotImplementedError, "Not implemented yet"
89
90
def iter_library_versions(self, reverse=False):
91
raise NotImplementedError, "Not implemented yet"
92
93
94
class BranchIterable(VersionIterable):
95
96
implements(IBranchIterable)
97
98
def iter_branches(self):
99
raise NotImplementedError, "Not implemented yet"
100
101
def iter_library_branches(self):
102
raise NotImplementedError, "Not implemented yet"
103
104
105
class CategoryIterable(BranchIterable):
106
107
implements(ICategoryIterable)
108
109
def iter_categories(self):
110
raise NotImplementedError, "Not implemented yet"
111
112
def iter_library_categories(self):
113
raise NotImplementedError, "Not implemented yet"
114
115
116
###############################################################################
117
### Containement base classes
118
119
class ArchiveItem(NamespaceObject):
120
121
implements(IArchiveItem)
122
123
def archive(self):
124
pass # Not implement yet
125
126
archive = property(archive)
127
128
def nonarch(self):
129
pass # Not implement yet
130
131
nonarch = property(nonarch)
132
133
134
class CategoryItem(ArchiveItem):
135
136
implements(ICategoryItem)
137
138
def __init__(self):
139
ArchiveItem.__init__(self)
140
self._category = "category"
141
142
def category(self):
143
return self._category
144
145
category = property(category)
146
147
148
class BranchItem(CategoryItem):
149
150
implements(IBranchItem)
151
152
def __init__(self):
153
CategoryItem.__init__(self)
154
self._branch = "branch"
155
156
def branch(self):
157
return self._branch
158
159
branch = property(branch)
160
161
162
class VersionItem(BranchItem):
163
164
implements(IVersionItem)
165
166
def __init__(self):
167
BranchItem.__init__(self)
168
self._version = "0"
169
170
def version(self):
171
return self._version
172
173
version = property(version)
174
175
176
###############################################################################
177
### Misc base classes
178
179
class Setupable(ArchiveItem):
180
181
implements(ISetupable)
182
183
def setup():
184
raise NotImplemented, "Not implemented yet"
185
186
187
class Package(Setupable, RevisionIterable):
188
189
implements(IPackage)
190
191
def as_revision():
192
raise NotImplemented, "Not implemented yet"
193
194
195
###############################################################################
196
### Concrete Namespace classes
197
198
import UserDict
199
class Archives(object, UserDict.DictMixin):
200
"""I am a collection of all the archives available to the system"""
201
implements(IArchiveCollection)
202
203
def __getitem__(self, key):
204
"""retrieve an archive"""
205
Archive._validate_name(key)
206
return self.getMapper().findByName(key)
207
208
def __setitem__(self, key, value):
209
"""Do not add an archive, just fail!"""
210
raise TypeError, ("Archives does not setitem. "
211
"Use the 'create' method instead")
212
213
def __delitem__(self, key):
214
"""Do not delete an archive, just fail!"""
215
raise TypeError, ("Archives does not delitem.")
216
217
def getMapper(self):
218
"""return the current mapper"""
219
return database.ArchiveMapper()
220
221
def keys(self):
222
return [archive.name for archive in
223
self.getMapper().findByMatchingName('%')]
224
225
def create(self, name, locations=[]):
226
"""create an archive"""
227
Archive._validate_name(name)
228
archive=Archive(name)
229
self.getMapper().insert(archive)
230
# TODO populate the archive locations too.
231
return archive
232
233
234
class ArchiveLocationRegistry(object):
235
"""I'm a list of the registered locations for an archive"""
236
237
def __init__(self, archive):
238
self._mapper = database.ArchiveLocationMapper()
239
self._archive = archive
240
241
def _createLocation(self, url, type):
242
"""Add a location to the database"""
243
location = ArchiveLocation(self._archive, url, type)
244
self._mapper.insertLocation(location)
245
return location
246
247
def createReadWriteTargetLocation(self, url):
248
"""Create a ArchiveLocation for a read/write mirror"""
249
return self._createLocation(url, ArchArchiveType.READWRITE)
250
251
def createReadOnlyTargetLocation(self, url):
252
"""Create a ArchiveLocation for a read-only archive"""
253
return self._createLocation(url, ArchArchiveType.READONLY)
254
255
def createMirrorTargetLocation(self, url):
256
"""Create a ArchiveLocation for a mirror target"""
257
return self._createLocation(url, ArchArchiveType.MIRRORTARGET)
258
259
def existsLocation(self, location):
260
"""Is location in the db?"""
261
return self._mapper.locationExists(location)
262
263
def _get(self, type):
264
"""Return all locations"""
265
return self._mapper.get(self._archive, type=type)
266
267
def _remove(self, type, name):
268
raise NotImplemented, "Not implemented yet"
269
270
def getMirrorTargetLocations(self):
271
return self._get(ArchArchiveType.MIRRORTARGET)
272
273
def getReadOnlyLocations(self):
274
return self._get(ArchArchiveType.READONLY)
275
276
def getReadWriteLocations(self):
277
return self._get(ArchArchiveType.READWRITE)
278
279
def removeMirrorTarget(self, location):
280
raise NotImplemented, "Not implemented yet"
281
282
def removeReadonlyTarget(self, location):
283
raise NotImplemented, "Not implemented yet"
284
285
def removeReadWriteTarget(self, location):
286
raise NotImplemented, "Not implemented yet"
287
288
289
class ArchiveLocation(object):
290
"""I'm a single location of an archive"""
291
292
implements(IArchiveLocation)
293
294
def __init__(self, archive, url, type):
295
"""Create us, given an Archive and a url string"""
296
self._mapper = database.ArchiveLocationMapper()
297
self._url = url
298
self._archive = archive
299
self._type = type
300
301
def url(self):
302
"""My registered location"""
303
return self._url
304
305
url = property(url)
306
307
def archive(self):
308
"""The archive I belong to"""
309
return self._archive
310
311
archive = property(archive)
312
313
def GPGSigned(self):
314
"""Am I GPG-signed?"""
315
return self._mapper.isItSigned(self)
316
317
GPGSigned = property(GPGSigned)
318
319
def unregister(self):
320
"""Delete me from the database"""
321
raise NotImplementedError, "Not implemented yet!"
322
323
324
class Archive(NamespaceObject, CategoryIterable):
325
"""A database & file store backed arch Archive"""
326
327
implements(IArchive)
328
_eq_interface = IArchive
329
330
def __init__(self, name):
331
"""Create a new Archive object from the named archive."""
332
NamespaceObject.__init__(self, name)
333
self._name = name
334
self._mapper = database.ArchiveMapper()
335
336
def _validate_name(archive_name):
337
"""Raise a NamespaceError if the given archive name is invalid."""
338
from pybaz import NameParser
339
if not NameParser.is_archive_name(archive_name):
340
raise NamespaceError("invalid archive name: %s" % archive_name)
341
_validate_name = staticmethod(_validate_name)
342
343
def exists(self):
344
# If it didn't exist, it would be a MissingArchive
345
return True
346
347
def name(self):
348
"""return the archive name"""
349
return self._name
350
351
name = property(name)
352
353
def location(self):
354
# ArchiveLocationRegistry objects know about different types of locations.
355
return ArchiveLocationRegistry(self)
356
357
location = property(location)
358
359
def __getitem__(self, category_name):
360
"""Instanciate a Category object belonging to that archive.
361
362
:param category_name: unqualified category name.
363
:type category_name: str
364
:rtype: `Category`
365
"""
366
if not NameParser.is_category_name(category_name):
367
raise NamespaceError('invalid category name: %s' % category_name)
368
category = Category(category_name, self)
369
mapper = database.CategoryMapper()
370
if not mapper.exists(category):
371
return MissingCategory(category_name, self)
372
else:
373
return category
374
375
def is_registered(self):
376
"""Is there an archive location associated with the archive?"""
377
# if we have at least one mention in the archivelocation table
378
location = self.location
379
if len(location.getMirrorTargetLocations()) + \
380
len(location.getReadOnlyLocations()) + \
381
len(location.getReadWriteLocations()) > 0:
382
return True
383
else:
384
return False
385
386
def unregister(self):
387
"""The location method should """
388
raise RuntimeError("This is old and broken, do not use it.")
389
390
def make_mirror(self, name, location, signed=False, listing=False):
391
raise NotImplementedError, "Not implemented yet!"
392
393
def create_category(self, name):
394
"""Creata a category object, inserting it if it doesn't exist."""
395
mapper = database.CategoryMapper()
396
category = Category(name, self)
397
mapper.insert(category)
398
return category
399
400
401
class MissingArchive(Archive):
402
"""I am a Special Case for missing archives"""
403
404
def __init__(self, name):
405
"""Create a new Archive object from the named archive."""
406
self._name = name
407
Archive.__init__(self, name)
408
409
def __getitem__(self, category_name):
410
"""Raise a TypeError."""
411
raise TypeError, "MissingCategory cannot getitem."""
412
413
def exists(self):
414
return False
415
416
417
class Category(Setupable, BranchIterable):
418
"""FS & DB backed Category object"""
419
classProvides(ICategoryFactory)
420
implements(ICategory)
421
_eq_interface = ICategory
422
423
def __init__(self, name, archive):
424
from pybaz import NameParser
425
self._archive = archive
426
self._name = name
427
428
self._fullname = self._archive.name + "/" + self._name
429
430
self._mapper = database.CategoryMapper()
431
self._nonarch = name
432
433
def __getitem__(self, name):
434
"""Return the asked-for branch object"""
435
branch = Branch(name, self)
436
mapper = database.BranchMapper()
437
if not mapper.exists(branch):
438
return MissingBranch(name, self)
439
else:
440
return branch
441
442
def archive(self):
443
return self._archive
444
445
archive = property(archive)
446
447
def nonarch(self):
448
"""The non-archive part of the name"""
449
return self._nonarch
450
451
nonarch = property(nonarch)
452
453
def name(self):
454
return self._name
455
456
name = property(name)
457
458
def exists(self):
459
return True
460
461
def setup(self):
462
self._mapper.insert(self)
463
464
def create_branch(self, name):
465
"""Creata a branch object, inserting it if it doesn't exist."""
466
mapper = database.BranchMapper()
467
branch = Branch(name, self)
468
mapper.insert(branch)
469
return branch
470
471
class MissingCategory(Category):
472
def __init__(self, name, archive):
473
Category.__init__(self, name, archive)
474
475
def exists(self):
476
return False
477
478
class Branch(CategoryItem, Package, VersionIterable):
479
"""DB-backed version of arch.Branch"""
480
481
implements(IBranch)
482
classProvides(IBranchFactory)
483
_eq_interface = IBranch
484
485
def __init__(self, name, category):
486
# NamespaceObject.__init__(self, category.fullname + "--" + name)
487
self._category = category
488
self._name = name
489
self._fullname = category.fullname + "--" + name
490
491
def exists(self):
492
return True
493
494
def __getitem__(self, name):
495
"""Return the asked-for version object"""
496
version = Version(name, self)
497
mapper = database.VersionMapper()
498
if not mapper.exists(version):
499
return MissingVersion(name, self)
500
else:
501
version._sqlobject_branch = mapper.findByName("%s--%s" % (self.fullname, name))
502
return version
503
504
def as_version():
505
"""Get the last version from this branch"""
506
raise NotImplementedError, "Not implemented yet!"
507
508
def category(self):
509
# Our parent object
510
return self._category
511
512
category = property(category)
513
514
def name(self):
515
# Our name. eg if self.fullname = "rob@bah/baz--bah", self.name = "bah".
516
return self._name
517
518
name = property(name)
519
520
def create_version(self, name):
521
"""Creata a version object, inserting it if it doesn't exist."""
522
mapper = database.VersionMapper()
523
version = Version(name, self)
524
version._sqlobject_branch = mapper.insert(version)
525
return version
526
527
class MissingBranch(Branch):
528
"""A branch that doesn't exist"""
529
def exists(self):
530
return False
531
532
533
class Version(BranchItem, Package, RevisionIterable):
534
"""Implementats canonical.launchpad.interfaces.IVersion, backed by the db"""
535
536
implements(IVersion)
537
_eq_interface = IVersion
538
539
def __init__(self, name, branch):
540
NamespaceObject.__init__(self, branch.fullname + "--" + name)
541
self._name = name
542
self._branch = branch
543
544
def exists(self):
545
return True
546
547
def __getitem__(self, key):
548
"""Return the asked-for revision object"""
549
revision = Revision(key, self)
550
mapper = database.RevisionMapper()
551
if not mapper.exists(revision):
552
return MissingRevision(key, self)
553
else:
554
revision.get_changeset()
555
return revision
556
557
def iter_cachedrevs(self):
558
raise NotImplementedError, "Not implemented yet!"
559
560
def iter_merges(self, other, reverse=False):
561
raise NotImplementedError, "Not implemented yet!"
562
563
def category(self):
564
return self._branch.category
565
566
category = property(category)
567
568
def branch(self):
569
return self._branch
570
571
branch = property(branch)
572
573
def name(self):
574
return self._name
575
576
name = property(name)
577
578
def create_revision(self, name):
579
"""Creata a Revision object, inserting it if it doesn't exist."""
580
mapper = database.RevisionMapper()
581
revision = Revision(name, self)
582
mapper.insert(revision)
583
return revision
584
585
class MissingVersion(Version):
586
"""A Version that doesn't exist."""
587
def exists(self):
588
return False
589
590
591
class Revision(VersionItem):
592
"""A Revision object backed by the database"""
593
594
implements(IRevision)
595
classProvides(IRevisionFactory)
596
_eq_interface = IRevision
597
598
def __init__(self, name, version):
599
NamespaceObject.__init__(self, version.fullname + "--" + name)
600
self._name = name
601
self._version = version
602
self._patchlog = None
603
self._cset = None
604
605
def exists(self):
606
return True
607
608
def set_patchlog(self, patchlog):
609
self._patchlog = patchlog
610
mapper = database.RevisionMapper()
611
mapper.update_log(self, patchlog.summary)
612
613
def patchlog(self):
614
return self._patchlog
615
616
patchlog = property(patchlog)
617
618
def get_changeset(self):
619
mapper = database.RevisionMapper()
620
self._cset = mapper.changeset(self)
621
622
def set_changeset(self, cset):
623
self._cset = cset
624
625
def changeset(self):
626
return self._cset
627
628
changeset = property(changeset)
629
630
def ancestor(self):
631
pass # Not implemented yet
632
633
ancestor = property(ancestor)
634
635
def previous(self):
636
pass # Not implemented yet
637
638
previous = property(previous)
639
640
def library_add(self):
641
raise NotImplementedError, "Not implemented yet!"
642
643
def library_remove(self):
644
raise NotImplementedError, "Not implemented yet!"
645
646
def library_find(self):
647
raise NotImplementedError, "Not implemented yet!"
648
649
def iter_ancestors(self, metoo=False):
650
raise NotImplementedError, "Not implemented yet!"
651
652
def cache(self, cache=None):
653
raise NotImplementedError, "Not implemented yet!"
654
655
def uncache(self):
656
raise NotImplementedError, "Not implemented yet!"
657
658
def category(self):
659
return self.version.branch.category
660
661
category = property(category)
662
663
def branch(self):
664
return self.version.branch
665
666
branch = property(branch)
667
668
def version(self):
669
return self._version
670
671
version = property(version)
672
673
def patchlevel(self):
674
return self._name
675
676
patchlevel = property(patchlevel)
677
678
def name(self):
679
return self._name
680
681
name = property(name)
682
683
684
class MissingRevision(Revision):
685
def __init__(self, name, version):
686
Revision.__init__(self, name, version)
687
688
def exists(self):
689
return False
690
691
class PatchlogFactory(object):
692
693
def __call__(revision, tree=None, fromlib=False):
694
raise NotImplementedError, "Not implemented yet!"
695
696
implements(IPatchlog)
697
698
def revision(self):
699
pass # Not implemented yet
700
701
revision = property(revision)
702
703
def summary(self):
704
pass # Not implemented yet
705
706
summary = property(summary)
707
708
def description(self):
709
pass # Not implemented yet
710
711
description = property(description)
712
713
def date(self):
714
pass # Not implemented yet
715
716
date = property(date)
717
718
def creator(self):
719
pass # Not implemented yet
720
721
creator = property(creator)
722
723
def continuation(self):
724
pass # Not implemented yet
725
726
continuation = property(continuation)
727
728
def new_patches(self):
729
pass # Not implemented yet
730
731
new_patches = property(new_patches)
732
733
def merged_patches(self):
734
pass # Not implemented yet
735
736
merged_patches = property(merged_patches)
737
738
def new_files(self):
739
pass # Not implemented yet
740
741
new_files = property(new_files)
742
743
def modified_files(self):
744
pass # Not implemented yet
745
746
modified_files = property(modified_files)
747
748
def removed_files(self):
749
pass # Not implemented yet
750
751
removed_files = property(removed_files)
752
753
def __getitem__(self, header):
754
raise NotImplementedError, "Not implemented yet!"
755
756
757
class LogMessageFactory(object):
758
759
implements(ILogMessageFactory)
760
761
def __call__(name):
762
raise NotImplementedError, "Not implemented yet!"
763
764
765
class LogMessage(object):
766
767
implements(ILogMessage)
768
769
def name(self):
770
pass # Not implemented yet
771
772
name = property(name)
773
774
def description(self):
775
pass # Not implemented yet
776
777
description = property(description)
778
779
def load(self):
780
raise NotImplementedError, "Not implemented yet!"
781
782
def save(self):
783
raise NotImplementedError, "Not implemented yet!"
784
785
def clear():
786
raise NotImplementedError, "Not implemented yet!"
787
788
def __getitem__(self, header):
789
raise NotImplementedError, "Not implemented yet!"
790
791
def __setitem__(self, header, text):
792
raise NotImplementedError, "Not implemented yet!"
793
794
795
class PathNameFactory(object):
796
797
implements(IPathNameFactory)
798
799
def __call__(path='.'):
800
raise NotImplementedError, "Not implemented yet!"
801
802
803
class PathName(object):
804
805
implements(IPathName)
806
807
def __div__(self, path):
808
raise NotImplementedError, "Not implemented yet!"
809
810
def abspath(self):
811
raise NotImplementedError, "Not implemented yet!"
812
813
def dirname(self):
814
raise NotImplementedError, "Not implemented yet!"
815
816
def basename(self):
817
raise NotImplementedError, "Not implemented yet!"
818
819
def realpath(self):
820
raise NotImplementedError, "Not implemented yet!"
821
822
def splitname(self):
823
raise NotImplementedError, "Not implemented yet!"
824
825
826
class DirName(PathName):
827
implements(IDirName)
828
pass
829
830
class FileName(PathName):
831
implements(IFileName)
832
pass
833
834
835
class SourceTreeAPI(object):
836
837
implements(ISourceTreeAPI)
838
839
def init_tree(self, directory, version=None, nested=False):
840
raise NotImplementedError, "Not implemented yet!"
841
842
def in_source_tree(self, directory=None):
843
raise NotImplementedError, "Not implemented yet!"
844
845
def tree_root(directory=None):
846
raise NotImplementedError, "Not implemented yet!"
847
848
849
class SourceTreeFactory(object):
850
851
implements(ISourceTreeFactory)
852
853
def __call_(root=None):
854
raise NotImplementedError, "Not implemented yet!"
855
856
857
class ArchSourceTree(DirName):
858
859
implements(IArchSourceTree)
860
861
def tree_version(self):
862
pass # Not implemented yet
863
864
tree_version = property(tree_version)
865
866
def tagging_method(self):
867
pass # Not implemented yet
868
869
tagging_method = property(tagging_method)
Loggerhead is a web-based interface for Breezy
Version: 2.0.1