aboutsummaryrefslogtreecommitdiff
blob: 4617057f6202269c51918077b776d59fa53a8505 (plain)
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
from roverlay import config

from roverlay.remote.repoloader import read_repofile

class RepoList ( object ):

	def __init__ ( self ):
		self.repos = list()
		self.sync_enabled = True
		self.use_broken_repos = False

	def sort ( self ):
		raise Exception ( "method stub." )

	def load_file ( self, _file ):
		new_repos = read_repofile ( _file )
		if new_repos:
			self.repos.extend ( new_repos )
	# --- end of load_file (...) ---

	def load ( self ):
		files = config.get_or_fail ( 'REPO.config_files' )
		for f in files:
			self.load_file ( f )
	# --- end of load (...) ---

	def sync_all ( self, package_queue=None ):
		q = None
		if package_queue is None:
			q = list()
			add = q.append
		else:
			# TODO: _nowait? raises Exception when queue is full which is
			#                good in non-threaded execution
			# -> timeout,..
			add = q.put


		# !! TODO resume here.

		for repo in self.repos:
			if repo.sync() if self.sync_enabled else repo.nosync():
				# scan repo and create package infos
				for p in repo.scan_distdir(): add ( p )
			elif self.use_broken_repos:
				# warn and scan repo
				## ..
				for p in repo.scan_distdir(): add ( p )

	# --- end of sync_all (...) ---

	def __str__ ( self ):
		return '\n'.join ( ( str ( x ) for x in self.repos ) )