X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=daklib%2Fbinary.py;h=06f773c91e70e2fa9856393125294dbe4091867d;hb=7b0927e3f971d65db69e97d035e73e9afada3d6e;hp=8dd9b30113cdf7800aa2420d0e0726a3a5374d2b;hpb=5c4242ac752fcc98787ecf0d84927f907808e36e;p=dak.git diff --git a/daklib/binary.py b/daklib/binary.py index 8dd9b301..06f773c9 100755 --- a/daklib/binary.py +++ b/daklib/binary.py @@ -99,8 +99,9 @@ class Binary(object): (result, output) = commands.getstatusoutput(cmd) if result != 0: rejected = True + print("%s: 'ar t' invocation failed." % (self.filename)) self.reject("%s: 'ar t' invocation failed." % (self.filename)) - self.reject(utils.prefix_multi_line_string(output, " [ar output:] "), "") + self.reject(utils.prefix_multi_line_string(output, " [ar output:] ")) self.chunks = output.split('\n') @@ -110,13 +111,14 @@ class Binary(object): # a temporary directory if not self.tmpdir: - tmpdir = tempfile.mkdtemp() + tmpdir = utils.temp_dirname() cwd = os.getcwd() try: os.chdir( tmpdir ) cmd = "ar x %s %s %s" % (os.path.join(cwd,self.filename), self.chunks[1], self.chunks[2]) (result, output) = commands.getstatusoutput(cmd) if result != 0: + print("%s: '%s' invocation failed." % (self.filename, cmd)) self.reject("%s: '%s' invocation failed." % (self.filename, cmd)) self.reject(utils.prefix_multi_line_string(output, " [ar output:] ")) else: @@ -142,10 +144,10 @@ class Binary(object): if self.chunks[0] != "debian-binary": rejected = True self.reject("%s: first chunk is '%s', expected 'debian-binary'." % (self.filename, self.chunks[0])) - if self.chunks[1] != "control.tar.gz": + if not rejected and self.chunks[1] != "control.tar.gz": rejected = True self.reject("%s: second chunk is '%s', expected 'control.tar.gz'." % (self.filename, self.chunks[1])) - if self.chunks[2] not in [ "data.tar.bz2", "data.tar.gz" ]: + if not rejected and self.chunks[2] not in [ "data.tar.bz2", "data.tar.gz" ]: rejected = True self.reject("%s: third chunk is '%s', expected 'data.tar.gz' or 'data.tar.bz2'." % (self.filename, self.chunks[2])) @@ -166,34 +168,35 @@ class Binary(object): @return True if the deb is valid and contents were imported """ - rejected = not self.valid_deb() - self.__unpack() - result = False + rejected = not self.valid_deb() + if not rejected: + self.__unpack() - cwd = os.getcwd() - if not rejected and self.tmpdir: - try: - os.chdir(self.tmpdir) - if self.chunks[1] == "control.tar.gz": - control = tarfile.open(os.path.join(self.tmpdir, "control.tar.gz" ), "r:gz") - control.extract('./control', self.tmpdir ) - if self.chunks[2] == "data.tar.gz": - data = tarfile.open(os.path.join(self.tmpdir, "data.tar.gz"), "r:gz") - elif self.chunks[2] == "data.tar.bz2": - data = tarfile.open(os.path.join(self.tmpdir, "data.tar.bz2" ), "r:bz2") - - if bootstrap_id: - result = DBConn().insert_content_paths(bootstrap_id, [tarinfo.name for tarinfo in data if not tarinfo.isdir()]) - else: - pkg = deb822.Packages.iter_paragraphs(file(os.path.join(self.tmpdir,'control'))).next() - result = DBConn().insert_pending_content_paths(pkg, [tarinfo.name for tarinfo in data if not tarinfo.isdir()]) - except: - traceback.print_exc() - result = False + cwd = os.getcwd() + if not rejected and self.tmpdir: + try: + os.chdir(self.tmpdir) + if self.chunks[1] == "control.tar.gz": + control = tarfile.open(os.path.join(self.tmpdir, "control.tar.gz" ), "r:gz") + control.extract('./control', self.tmpdir ) + if self.chunks[2] == "data.tar.gz": + data = tarfile.open(os.path.join(self.tmpdir, "data.tar.gz"), "r:gz") + elif self.chunks[2] == "data.tar.bz2": + data = tarfile.open(os.path.join(self.tmpdir, "data.tar.bz2" ), "r:bz2") + + if bootstrap_id: + result = DBConn().insert_content_paths(bootstrap_id, [tarinfo.name for tarinfo in data if not tarinfo.isdir()]) + else: + pkgs = deb822.Packages.iter_paragraphs(file(os.path.join(self.tmpdir,'control'))) + pkg = pkgs.next() + result = DBConn().insert_pending_content_paths(pkg, [tarinfo.name for tarinfo in data if not tarinfo.isdir()]) + + except: + traceback.print_exc() - os.chdir(cwd) + os.chdir(cwd) return result def check_utf8_package(self, package):