repdownload.py

Progra,, das sehr viele Medien formate spielt und sehr bekannt ist.

                   break
            except:
                pass
            if downresult:
                downloaded.append(files)    
                downresult = False
            
        return downloaded
    
    def donwload_files(self):
        self.initialtime = time.time()
        self.totalread = 0
        self.DownloadResult == gtk.RESPONSE_NONE
        for nfiles in self.PackFiles:
            if self.DownloadResult == gtk.RESPONSE_CANCEL:
                self.Packages.cancelDownload()
                break
            #self.labelsection.set_text(nfiles[download.SECTION])
            self.mgrade.append([nfiles[download.PACKAGE] , utils.fileSizeFormat(nfiles[download.SIZE]) , 0])
            self.treeline+= 1
            self.labelnumfiles.set_text('%s/%s' % (self.treeline + 1 ,self.filecount))
            self.scrollToPath(self.treeline)
            
            mainPath = os.path.join(self.conf[xmlfile.PATH],self.conf[xmlfile.DISTRIBUTION],  nfiles[download.REMOTEFILEPATH])
            
            utils.mkdir(mainPath)
            
            filePath = os.path.join(mainPath,nfiles[download.DEBFILENAME] )

            if not utils.fileExist(filePath):
                remotePath = self.conf[xmlfile.METHOD] + '://' + self.conf[xmlfile.HOST] + '/' + self.conf[xmlfile.DISTRIBUTION]  + '/' + nfiles[download.FILENAME]
                self.Packages = download.Download(remotePath, mainPath)
                self.Packages.connect('download_status',self.on_downloadStatus)
                self.Packages.download(True)
                self.downloadedFiles += 1
            else:
		fraction = float((100 * float(nfiles[download.SIZE])) / self.totalsize)
                self.on_downloadStatus(self.frmFetchRepo, nfiles[download.SIZE],float(nfiles[download.SIZE]), float(nfiles[download.SIZE]), float(fraction))
                self.mgrade[self.treeline][2] =100
       
        if self.DownloadResult == gtk.RESPONSE_CANCEL:
            dialog = gtk.MessageDialog(None, gtk.DIALOG_MODAL, gtk.MESSAGE_WARNING, gtk.BUTTONS_OK, msg.MESSAGE_0067)
            dialog.run()
            dialog.destroy()
            
    def SetOptions(self):
        self.totalsize = 0
        self.DownloadGUI = DownloadGUI.DownloadGUI(self.gladeFile)
        result = self.DownloadGUI.run()
        
        if result  != gtk.RESPONSE_OK:
            dialog = gtk.MessageDialog(None, gtk.DIALOG_MODAL, gtk.MESSAGE_WARNING, gtk.BUTTONS_OK, msg.MESSAGE_0067)
            dialog.run()
            dialog.destroy()
            return
        
        
        self.conf = self.load_conf(config.XML_FILE)
        ## just removing for teste purpouse

        self.wProgress = ProgressWindow.AptOnCDProgressDialog(self.DownloadGUI.getWindow())
        self.wProgress.Title(msg.MESSAGE_0059 )
        self.wProgress.Task(msg.MESSAGE_0057)
        self.wProgress.Description(msg.MESSAGE_0058) 
        self.wProgress.TaskTitle(msg.MESSAGE_0056 % self.conf[xmlfile.HOST] )
        self.wProgress.set_text('%d%%' % 0)
        
        utils.updateUI()
       
        #create the path fot destination of all Packages.tar.gz
        #folowing the rule down
        #DISTRIBUTION/dists/VERSION/SECTION/binary-ARCH/
        mainPath = os.path.join(self.conf[xmlfile.PATH],self.conf[xmlfile.DISTRIBUTION], 'dists', self.conf[xmlfile.VERSION])
        utils.mkdir(mainPath)
        tarfiles = []
        tarsize =0
        
        for sectionName in self.conf[xmlfile.SECTION].split(';'): 
           Pathx = os.path.join(mainPath, sectionName , 'binary-' + self.conf[xmlfile.ARCHITECTURE] )
           utils.mkdir(Pathx)

           downloadGz = ( \
                          self.conf[xmlfile.METHOD]  + '://' + self.conf[xmlfile.HOST] + '/' + self.conf[xmlfile.DISTRIBUTION]  + \
                          '/dists/' + self.conf[xmlfile.VERSION]  + '/' + sectionName  + '/binary-' + \
                          self.conf[xmlfile.ARCHITECTURE]  + '/Packages.gz')
           size = float(download.getRemoteFileSize(downloadGz))
           self.totalsize+=size
           
           tarfiles.append( ['Packages.gz',Pathx , downloadGz, size])
              
        validTars = self.Download_TarGZ(tarfiles)
        
        if len(validTars) == 0 or self.DownloadResult == gtk.RESPONSE_CANCEL:
            self.wProgress.destroy()
            dialog = gtk.MessageDialog(None, gtk.DIALOG_MODAL, gtk.MESSAGE_WARNING, gtk.BUTTONS_OK, msg.MESSAGE_0067)
            dialog.run()
            dialog.destroy()
            return
        
        self.PackFiles = []
        self.totalsize = 0
        self.totalread = 0
        for tar in validTars:
            s = parsegz.openGZ(tar[1] + '/Packages.gz'  )
            self.PackFiles.extend(parsegz.ParseFile(s).Parse())
         
        self.filecount = str(len(self.PackFiles))
        
        for nfiles in self.PackFiles:
            if nfiles[3] != '':
                self.totalsize+= float(nfiles[3])
        self.wProgress.destroy()

        if self.DownloadResult != gtk.RESPONSE_CANCEL:
            self.show_progress()
            self.donwload_files()
           
        self.frmFetchRepo.hide()

        if self.DownloadResult != gtk.RESPONSE_CANCEL:
            if self.conf[xmlfile.MEDIA] == 'DVD':
                cdSize =config.DVD
            else:
                cdSize = config.CD
            a = MediaSplitter.Splitter(self.conf[xmlfile.PATH], config.WORK_DIR, self.conf[xmlfile.DISTRIBUTION], self.conf[xmlfile.VERSION], self.conf[xmlfile.SECTION].split(';'), self.conf[xmlfile.ARCHITECTURE], cdSize)
            iSorted = a.SplitMedia()
            
            #we must show a progress window while copy is in progress
            #TODO - create strings in msg.py and input error handler
            taskLen = 0
            for s in iSorted:
                taskLen += len(s[1])
                
            self.wProgress.Title(msg.MESSAGE_0064 )
            self.wProgress.Task(msg.MESSAGE_0066)
            self.wProgress.TaskLenght( int(taskLen)) # Task's len
            self.wProgress.Description(msg.MESSAGE_0065) 
            self.wProgress.TaskTitle(msg.MESSAGE_0064 )
            self.wProgress.set_text('%d%%' % 0)

            i =1
            for s in iSorted:
                #print s[0]
                for n in s[1]:
                    #filesize = (float(n.Size)/1024.0**2 + 1)
                    utils.mkdir(n.TarGZ_Path % n.PackageSection)
                    utils.copyFile(n.SourceLocation, n.Destination)
                    self.wProgress.update(i)
                    i +=1
                    
            curdir = os.getcwd()
            cds ={}
            for s in iSorted:
                mediadir = s[0]+'/'
                os.chdir(mediadir)
                medianame = s[0].split('/')[-1].encode('utf8')
                cds[medianame] = []
                for sec in self.conf[xmlfile.SECTION].split(';'): 
                   pkgzdir = "dists/%s/%s/binary-%s/" % ( self.conf[xmlfile.VERSION],sec,self.conf[xmlfile.ARCHITECTURE])   
                   if utils.pathExists(os.path.join(mediadir,pkgzdir)):
                       os.system('apt-ftparchive packages  pool/ > ' + pkgzdir + 'Packages')
                       #make a .gz file
                       PackagesFile = os.path.join(mediadir,pkgzdir +'Packages')
                       fileObj = gzip.GzipFile(PackagesFile + '.gz', 'wb');
                       fileObj.write(file(PackagesFile, 'rb').read())
                       fileObj.close()
       		       utils.compress(PackagesFile, PackagesFile)
                       
		       os.system('apt-ftparchive release  dists/' + self.conf[xmlfile.VERSION] + ' > dists/' + self.conf[xmlfile.VERSION] + '/Release')
		       
                       cds[medianame].append(sec)

                os.system('ln -s . ' + self.conf[xmlfile.DISTRIBUTION])
                os.chdir(curdir)
            
            self.wProgress.Task(msg.MESSAGE_0020) 
            #print cds  
            for x in cds.keys():
                section = ''
                for n in cds[x]:
                    section+=n+'-'
                section = section[:-1]
                isoname = self.conf[xmlfile.DISTRIBUTION] + '-' + self.conf[xmlfile.VERSION] + '-' 
                isoname += section + '-' + self.conf[xmlfile.ARCHITECTURE] +'-' + x
                os.system('mkisofs -quiet -iso-level 4 -pad -l -r -J -joliet-long -v -V "aptoncd-'+ x  +'" -hide-rr-moved -o ' + os.path.join(config.WORK_DIR ,isoname +'.iso') + ' ' + mediadir + ' 2> /dev/null')
        
        self.wProgress.destroy()
        
        if self.DownloadResult != gtk.RESPONSE_CANCEL :
            checked = MessageBox().ShowFinished(self.gladeFile, config.WORK_DIR )  
        else:
            checked = False

        if checked and self.DownloadResult != gtk.RESPONSE_CANCEL :
            utils.removePath(os.path.join(config.WORK_DIR,'repository'))
	    utils.removePath(self.conf[xmlfile.PATH])
        
        #the comment below must be removed when code is ok
        #self.close_fetchwindow(self)