--- versionedFile/versionedFile.py 2005/03/31 16:44:23 1.34 +++ versionedFile/versionedFile.py 2005/06/20 21:34:17 1.35 @@ -7,6 +7,10 @@ from AccessControl import getSecurityMan from Products.PageTemplates.PageTemplate import PageTemplate from Products.PageTemplates.ZopePageTemplate import ZopePageTemplate from AccessControl import ClassSecurityInfo + +from threading import Thread +import shutil +import tempfile import os.path import time @@ -21,7 +25,82 @@ except: def sortv(x,y): return cmp(x[0],y[0]) +tdir = "/tmp/testia" + +class generateDownloadZip: + """generateDownloadSet""" + + def __init__(self,folderObject,url): + """init downloadzip""" + self.folder=folderObject + self.done=None + self.response="" + self.url=url + + def __call__(self): + """call generate download zip""" + storeTempDir=tempfile.tempdir + tempfile.tempdir=tdir + + tmpPath=tempfile.mktemp() + tmpZip=tempfile.mktemp()+".gtz" + tmpFn=os.path.split(tmpZip)[1] + + if not os.path.exists(tempfile.tempdir): + os.mkdir(tempfile.tempdir) + + if not os.path.exists(tmpPath): + os.mkdir(tmpPath) + + self.response="

1. step: gettung the files

" + + for files in self.folder.ZopeFind(self.folder,obj_metatypes=['versionedFile']): + lastV=files[1].getLastVersion() + self.response+=str("

Get File: %s
\n"%lastV.title) + + savePath=os.path.join(tmpPath,lastV.title) + fh=file(savePath,"w") + fh.write(lastV.data) + fh.close() + + self.response+="

2. step: creating the downloadable file

" + self.response+="

Create gtar
" + self.response+="

This can take a while....
\n" + + fh=os.popen2("tar zcvf %s %s/*"%(tmpZip,tmpPath),1)[1] + self.response+="
" + for c in fh.read(): + self.response+=c + if c==")": + self.response+="
\n" + + + + + shutil.rmtree(tmpPath) + + self.response+="

finished
\n" + + len=os.stat(tmpZip)[6] + downloadUrl=self.url+"/downloadSet" + self.response+="""

Click here for download ( %i Byte)

\n"""%(tmpFn,len) + self.response+="""

The file will be stored for a while, you can download it later, the URL is:

+

%s?fn=%s\n"""%(tmpFn,downloadUrl,tmpFn) + + self.done=True + + def getResult(self): + """get result""" + return self.response + + def isDone(self): + if self.done: + return True + else: + return False + + class versionedFileFolder(Folder,ECHO_basis): """Folder with versioned files""" @@ -39,10 +118,100 @@ class versionedFileFolder(Folder,ECHO_ba manage_options =optTMP+( {'label':'Generate Index.html','action':'generateIndexHTML'}, {'label':'Generate history_template.html','action':'generateHistoryHTML'}, + {'label':'Import Folder','action':'importFolderForm'}, ) - - + def importFolderForm(self): + """form fuer folder import""" + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','importFolderForm.zpt')).__of__(self) + return pt() + + def importFolder(self,path,comment="",author=None,lockedBy=None,RESPONSE=None): + """importiere inhalt eines folders""" + + for fileName in os.listdir(path): + if os.path.isfile(os.path.join(path,fileName)): + manage_addVersionedFile(self,fileName,'','') + id=fileName + ob=self._getOb(fileName) + ob.title=id + file2=file(os.path.join(path,fileName)) + + obj=ob.manage_addVersionedFileObject(id,comment,author,file2,content_type='') + + if RESPONSE: + RESPONSE.redirect(self.REQUEST['URL1']) + + zipThreads={} + zipThreads2={} + + def refreshTxt(self): + """txt fuer refresh""" + tn=self.REQUEST.SESSION['threadName'] + return """ 2;url=%s?repeat=%s """%(self.absolute_url()+"/exportFolder",tn) + + def exportFolder(self,repeat=None): + """exportiert alle akutellen files des folders""" + threadName=repeat + + + if not threadName or threadName=="": + threadStart=generateDownloadZip(self,self.absolute_url()) + thread=Thread(target=threadStart) + + thread.start() + + + self.zipThreads[thread.getName()[0:]]=threadStart + self.zipThreads2[thread.getName()[0:]]=thread + self.REQUEST.SESSION['threadName']=thread.getName()[0:] + wait_template=self.aq_parent.ZopeFind(self.aq_parent,obj_ids=['zip_wait_template']) + if wait_template: + return wait_template[0][1]() + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_wait.zpt')).__of__(self) + return pt() + + else: + self.REQUEST.SESSION['threadName']=threadName + + if (self.zipThreads[threadName].getResult()==None): + + wait_template=self.aq_parent.ZopeFind(self.aq_parent,obj_ids=['wait_template']) + if wait_template: + return wait_template[0][1]() + + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_wait.zpt')).__of__(self) + return pt() + else: + if self.zipThreads[threadName].isDone(): + self.REQUEST.SESSION['result']=self.zipThreads[threadName].getResult() + self.zipThreads2[threadName].join() + del(self.zipThreads2[threadName]) + del(self.zipThreads[threadName]) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_result.zpt')).__of__(self) + return pt() + + else: + self.REQUEST.SESSION['result']=self.zipThreads[threadName].getResult() + self.REQUEST.SESSION['threadName']=threadName + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_wait_result.zpt')).__of__(self) + return pt() + + def downloadSet(self,fn): + """download prepared set""" + filename=os.path.join(tdir,fn) + + + self.REQUEST.RESPONSE.setHeader("Content-Disposition","""attachement; filename="%s" """%"donloadFileFolder.tgz") + self.REQUEST.RESPONSE.setHeader("Content-Type","application/octet-stream") + len=os.stat(filename)[6] + self.REQUEST.RESPONSE.setHeader("Content-Length",len) + images=file(filename).read() + self.REQUEST.RESPONSE.write(images) + self.REQUEST.RESPONSE.close() + + + def helpDownload(self): """download help""" @@ -526,8 +695,11 @@ class versionedFile(Folder): def manage_addVersionedFileObject(self,id,vC,author,file='',title='',precondition='', content_type='',changeName='no',newName='', RESPONSE=None): """add""" + try: #der ganze vC unsinn muss ueberarbeitet werden + vC=self.REQUEST['vC'] + except: + pass - vC=self.REQUEST['vC'] author=self.REQUEST['author'] if changeName=="yes": @@ -540,7 +712,8 @@ class versionedFile(Folder): if not newName=='': self.title=newName[0:] - + print self.title + id="V%i"%self.getVersion()+"_"+self.title manage_addVersionedFileObject(self,id,vC,author,file,"V%i"%self.getVersion()+"_"+self.title,precondition, content_type)