10 # earlier == more important
11 dirs = [ "/home/ftp/pub/Linux/PLD/dists/th/test/SRPMS/RPMS/",
12 "/home/ftp/pub/Linux/PLD/dists/th/ready/SRPMS/RPMS/",
13 "/home/ftp/pub/Linux/PLD/dists/th/PLD/SRPMS/RPMS/" ]
14 #dirs = [ "/home/pld/admins/th/1" ]
15 specsdir = "/home/pld/admins/th/SPECS"
17 if os.path.isdir(specsdir):
21 cmd = ['git', 'clone', '--depth=1', 'git://git.pld-linux.org/SPECS', specsdir]
23 p = subprocess.Popen(cmd, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
24 (out, err) = p.communicate(None)
34 self.re_n = re.compile('^(.*)-([^-]*)-([^-]*)\.src\.rpm$')
36 def __get_from_rpm(self, file_name):
37 m = self.re_n.match(file_name)
40 name = m.group(1).strip()
41 version = m.group(2).strip()
42 release = m.group(3).strip()
43 return (name, version, release)
45 def __get_from_cvs(self, name):
46 f = os.popen('rpm --specfile -q --queryformat "%{name}\n%{version}\n%{release}\n" ' + specsdir + '/' + name + '.spec 2> /dev/null', 'r')
47 name = f.readline().strip()
48 version = f.readline().strip()
49 release = f.readline().strip()
51 return (name, version, release)
53 def __update_cvs(self, name):
54 if not self.cvs.has_key(name):
55 self.cvs[name] = self.__get_from_cvs(name)
57 def __update_new(self, name):
58 cvs_nvr = self.cvs[name]
59 pkg_nvr = self.pkg[name]
61 cvs_rpm_vr = rpm.labelCompare((cvs_nvr[0], cvs_nvr[1], cvs_nvr[2]), (pkg_nvr[0], pkg_nvr[1], pkg_nvr[2]))
62 cvs_rpm_v = rpm.labelCompare((cvs_nvr[0], cvs_nvr[1], ""), (pkg_nvr[0], pkg_nvr[1], ""))
63 rpm_cvs_vr = rpm.labelCompare((pkg_nvr[0], pkg_nvr[1], pkg_nvr[2]), (cvs_nvr[0], cvs_nvr[1], cvs_nvr[2]))
64 rpm_cvs_v = rpm.labelCompare((pkg_nvr[0], pkg_nvr[1], ""), (cvs_nvr[0], cvs_nvr[1], ""))
66 if rpm_cvs_v < 0 and cvs_rpm_v > 0:
67 self.cvs_new_nv.append(name)
69 if rpm_cvs_vr < 0 and cvs_rpm_vr > 0 and cvs_nvr[1] == pkg_nvr[1]:
70 self.cvs_new_nvr.append(name)
73 self.cvs_new_nvr.sort()
74 self.cvs_new_nvr = list(set(self.cvs_new_nvr))
75 self.cvs_new_nv.sort()
76 self.cvs_new_nv = list(set(self.cvs_new_nv))
78 pkgs = list(self.pkg) + list(self.cvs)
80 for name in list(set(pkgs)):
81 self.__update_new(name)
83 def add_rpm(self, file_name):
84 nvr = self.__get_from_rpm(file_name)
88 if self.pkg.has_key(name):
89 if rpm.labelCompare(nvr, self.pkg[name]) > 0:
94 self.__update_cvs(name)
97 print "*** VERSION-RELEASE COMPARE FOR THE SAME VERSIONS ONLY ***"
98 for name in self.cvs_new_nvr:
99 self.cvs_new_nvr.sort()
100 cvs_nvr = self.cvs[name]
101 pkg_nvr = self.pkg[name]
102 print "GIT: [%s.spec] %s-%s-%s vs FTP: %s-%s-%s" % (name, cvs_nvr[0], cvs_nvr[1], cvs_nvr[2], pkg_nvr[0], pkg_nvr[1], pkg_nvr[2])
105 print "*** VERSION COMPARE ONLY ***"
106 self.cvs_new_nv.sort()
107 for name in self.cvs_new_nv:
108 cvs_nvr = self.cvs[name]
109 pkg_nvr = self.pkg[name]
110 print "GIT: [%s.spec] %s-%s-%s vs FTP: %s-%s-%s" % (name, cvs_nvr[0], cvs_nvr[1], cvs_nvr[2], pkg_nvr[0], pkg_nvr[1], pkg_nvr[2])
115 for rpm_file_name in os.listdir(d):
116 p.add_rpm(rpm_file_name)