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
171
172
173
174
175
176
177
178
179
180
181
|
#!/usr/bin/python
import getopt, sys, os
import settings
#__doc__="Usage: "+sys.argv[0]+" <local repository directory> <action> [<action arguments>...]"
def verbose_system(command):
print command
return os.system(command)
def list_configured_drivers():
#all .cfg files which end in .cfg as they should
return [x[:-len('.cfg')] for x in os.listdir(settings.GLOBAL_CONF_DIR) if x[-len('.cfg'):]=='.cfg']
#read key=value file to dict
def read_config(conf_file,defaults={}):
conffile=open(conf_file)
conf=defaults.copy()
for line in conffile:
if len(line):
value=line[line.find("=")+1:]
if value[-1]=='\n':
value=value[:-1]
conf[line[:line.find("=")]]=value
return conf
#returns dict of key=value config file
def read_driver_config(driver_name):
conffile=os.path.join(settings.GLOBAL_CONF_DIR,settings.DRIVER_DIR,driver_name+'.cfg')
return read_config(conffile,{
#'name':None,
#'executable':None,
})
return configs #dict
#read g-common config for a repo
def read_repo_config(repo_location):
hidden_conffile=os.path.join(repo_location,settings.MYDIR,'repo.cfg')
return read_config(hidden_conffile)
#sync a local repository's PACKAGES file
def action_sync(repo_location,driver,remote_uri):
if driver==None:
repo_conf=read_repo_config(repo_location)
driver=repo_conf['driver']
driver_conf=read_driver_config(driver)
if remote_uri is None:
remote_uri=repo_conf['uri']
if os.path.exists(repo_location):
try:
os.makedirs(os.path.join(repo_location,settings.MYDIR))
except:
pass
cfg_file=open(os.path.join(repo_location,settings.MYDIR,"repo.cfg"),"w")
cfg_file.write('driver='+driver+'\n')
cfg_file.write('uri='+remote_uri+'\n')
cfg_file.close()
return os.system(driver_conf['exec']+" "+repo_location+" sync "+remote_uri)
#list categories in this repositorie
def list_categories(repo_location):
repo_conf=read_repo_config(repo_location)
driver_conf=read_driver_config(repo_conf['driver'])
return os.system(driver_conf['exec']+" "+repo_location+" list-categories")
#idem ditto
def list_packages(repo_location):
repo_conf=read_repo_config(repo_location)
driver_conf=read_driver_config(repo_conf['driver'])
return os.system(driver_conf['exec']+" "+repo_location+" list-packages")
#generate a tree of ebuilds... note that we only link ebuild files, instead of generating them
#we will, however, generate metadata.xml and Manifest files
def generate_tree(repo_location,generate_manifest,generate_metadata):
import hashlib, subprocess
repo_conf=read_repo_config(repo_location)
driver_conf=read_driver_config(repo_conf['driver'])
if generate_metadata:
raise NotImplementedError
ebuild_file=settings.COMMON_EBUILD_FILE #get from settings
ebuild_digest=hashlib.sha1(open(ebuild_file).read()).hexdigest()
Manifest="EBUILD %s "+str(os.path.getsize(ebuild_file))+" SHA1 "+ebuild_digest
packages_list_pipe=subprocess.Popen(driver_conf['exec']+' '+repo_location+' list-packages',shell=True,stdout=subprocess.PIPE)
os.waitpid(packages_list_pipe.pid,0)
for line in packages_list_pipe.stdout:
category=line[:line.find("/")]
package=line[line.find("/")+1:line.find(" ")]
version=line[line.find(" ")+1:-1]
ebuild_dir=os.path.join(repo_location,category,package)
if not os.path.exists(ebuild_dir):
os.makedirs(ebuild_dir)
package_file=package+'-'+version+'.ebuild'
os.symlink(ebuild_file,os.path.join(ebuild_dir,package_file))
if generate_manifest:
manifest_file=open(os.path.join(ebuild_dir,'Manifest'),"w")
manifest_file.write(Manifest % package_file)
return 0
#list package details, in PMS's format
def action_package(repo_location,package_name):
repo_conf=read_repo_config(repo_location)
driver_conf=read_driver_config(repo_conf['driver'])
return os.system(driver_conf['exec']+" "+repo_location+" package "+package_name)
def exec_phase(repo_location,phase):
repo_conf=read_repo_config(repo_location)
driver_conf=read_driver_config(repo_conf['driver'])
env=os.environ
return os.system(driver_conf['exec']+" "+repo_location+" "+phase)
def usage():
print __doc__
return 0
def main():
arguments=sys.argv[1:]
#print options, arguments
if len(arguments)<2: #we need at least a local repository location and an action
usage()
sys.exit(0)
action=arguments[1]
repo_location=os.path.abspath(arguments[0])
if action=='sync':
if len(arguments)<2 or 'help' in arguments:
print "The 'sync' action takes the following parameters:"
print " * [driver]"
print " * [remote_repository_uri]"
sys.exit(1)
driver=None
remote_repo=None
if len(arguments)>2:
driver=arguments[2]
if len(arguments)>3:
remote_repo=arguments[3]
return action_sync(repo_location,driver,remote_repo)
elif action=='list-categories':
return list_categories(repo_location)
elif action=='list-packages':
return list_packages(repo_location)
elif action=='generate-tree':
if '--without-manifest' in arguments:
manifest=False
else:
manifest=True
if '--without-metadata' in arguments:
metadata=False
else:
metadata=True
return generate_tree(repo_location,manifest,metadata)
elif action=='package':
if len(arguments)<3 or 'help' in arguments:
print "The 'package' action takes the following parameters:"
print " * category/package_name"
print " * [version]"
sys.exit(1)
package_name=arguments[2]
return action_package(repo_location,package_name)
elif action=='usage' or action=='help':
return usage()
elif action in settings.PMS_PHASES:
return exec_phase(repo_location,action)
else:
return usage()
if __name__ == "__main__":
sys.exit(main())
|
GitWeb