Annotation of versionedFile/versionedFile.py, revision 1.37

1.1       dwinter     1: from OFS.Folder import Folder
                      2: from OFS.Image import File
                      3: from OFS.Image import cookId
1.5       dwinter     4: from Globals import DTMLFile, InitializeClass,package_home
1.1       dwinter     5: from Products.PageTemplates.PageTemplateFile import PageTemplateFile
                      6: from AccessControl import getSecurityManager
                      7: from Products.PageTemplates.PageTemplate import PageTemplate
1.5       dwinter     8: from Products.PageTemplates.ZopePageTemplate import ZopePageTemplate
1.1       dwinter     9: from AccessControl import ClassSecurityInfo
1.35      dwinter    10: 
                     11: from threading import Thread
                     12: import shutil
                     13: import tempfile
1.5       dwinter    14: import os.path
1.19      dwinter    15: 
1.15      dwinter    16: import time
1.19      dwinter    17: try:
                     18:     from Products.ECHO_content.ECHO_collection import ECHO_basis
                     19: except:
                     20:     print "ECHO Elements not imported"
1.20      dwinter    21:     class ECHO_basis:
1.31      dwinter    22:         """leer"""
                     23:             manage_options=()
1.1       dwinter    24: 
1.19      dwinter    25:    
1.1       dwinter    26: def sortv(x,y):
                     27:     return cmp(x[0],y[0])
1.37    ! dwinter    28: tdir = "/tmp/downloadVersionedFiles"
1.35      dwinter    29: 
                     30: class generateDownloadZip:
                     31:     """generateDownloadSet"""
                     32: 
                     33:     def __init__(self,folderObject,url):
                     34:         """init downloadzip"""
                     35:         self.folder=folderObject
                     36:         self.done=None
                     37:         self.response=""
                     38:         self.url=url
                     39:         
                     40:     def __call__(self):
                     41:         """call generate download zip"""
                     42:         storeTempDir=tempfile.tempdir
                     43:    tempfile.tempdir=tdir
                     44: 
                     45:         tmpPath=tempfile.mktemp()
                     46:         tmpZip=tempfile.mktemp()+".gtz"
                     47:         tmpFn=os.path.split(tmpZip)[1]
                     48:         
                     49:         if not os.path.exists(tempfile.tempdir):
                     50:             os.mkdir(tempfile.tempdir) 
                     51: 
                     52:         if not os.path.exists(tmpPath):
                     53:            os.mkdir(tmpPath) 
                     54:        
1.37    ! dwinter    55:    self.response="<h3>1. step: getting the files</h3>"
1.35      dwinter    56: 
                     57:         for files in self.folder.ZopeFind(self.folder,obj_metatypes=['versionedFile']):
                     58:             lastV=files[1].getLastVersion()
                     59:             self.response+=str("<p>Get File: %s<br>\n"%lastV.title)
                     60: 
                     61:             savePath=os.path.join(tmpPath,lastV.title)
                     62:             fh=file(savePath,"w")
                     63:             fh.write(lastV.data)
                     64:             fh.close()
                     65: 
                     66:         self.response+="<h3>2. step: creating the downloadable file</h3>"
                     67:    self.response+="<p>Create gtar<br>"
                     68:         self.response+="<p>This can take a while....<br>\n"
                     69: 
                     70:         fh=os.popen2("tar zcvf %s %s/*"%(tmpZip,tmpPath),1)[1]
                     71:         self.response+="<br>"
                     72:         for c in fh.read():
                     73:             self.response+=c
                     74:             if c==")":
                     75:                 self.response+="<br>\n"
                     76:            
                     77:                
                     78: 
                     79:         
                     80:         shutil.rmtree(tmpPath)
                     81: 
                     82:         self.response+="<p>finished<br>\n"
                     83: 
                     84:         len=os.stat(tmpZip)[6]
                     85:         downloadUrl=self.url+"/downloadSet"
                     86:         self.response+="""<h1><a href="downloadSet?fn=%s">Click here for download ( %i Byte)</a></h1>\n"""%(tmpFn,len)
1.36      dwinter    87:         self.response+="""<p>The file you receive is a tar (gnutar) compressed file, after unpacking you will find a new folder <emph>tmp</emph> where the files are stored in.</p>"""
1.35      dwinter    88:         self.response+="""<p>The file will be stored for a while, you can download it later, the URL is:</p>
                     89:            <p><a href="downloadSet?fn=%s">%s?fn=%s</a></h1>\n"""%(tmpFn,downloadUrl,tmpFn)
                     90: 
                     91:         self.done=True
                     92: 
1.1       dwinter    93:  
1.35      dwinter    94:     def getResult(self):
                     95:         """get result"""
                     96:         return self.response
                     97: 
                     98:     def isDone(self):
                     99:         if self.done:
                    100:             return True
                    101:         else:
                    102:             return False
                    103:         
                    104: 
1.19      dwinter   105: class versionedFileFolder(Folder,ECHO_basis):
1.1       dwinter   106:     """Folder with versioned files"""
                    107: 
1.14      dwinter   108:     
1.1       dwinter   109:     meta_type = "versionedFileFolder"
                    110: 
                    111:     security= ClassSecurityInfo()
                    112:     security.declareProtected('AUTHENTICATED_USER','addFileForm')
1.19      dwinter   113: 
                    114:     if ECHO_basis:
                    115:         optTMP= Folder.manage_options+ECHO_basis.manage_options
                    116:     else:
                    117:         optTMP= Folder.manage_options
                    118: 
                    119:     manage_options =optTMP+(
1.5       dwinter   120:        {'label':'Generate Index.html','action':'generateIndexHTML'},
1.6       dwinter   121:                 {'label':'Generate history_template.html','action':'generateHistoryHTML'},
1.35      dwinter   122:                 {'label':'Import Folder','action':'importFolderForm'},
1.36      dwinter   123:                 {'label':'Export Folder','action':'exportFolder'},
1.19      dwinter   124:                 )
1.5       dwinter   125: 
1.35      dwinter   126:     def importFolderForm(self):
                    127:         """form fuer folder import"""
                    128:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','importFolderForm.zpt')).__of__(self)
                    129:         return pt()
                    130:         
                    131:     def importFolder(self,path,comment="",author=None,lockedBy=None,RESPONSE=None):
                    132:         """importiere inhalt eines folders"""
                    133: 
                    134:         for fileName in os.listdir(path):
                    135:             if os.path.isfile(os.path.join(path,fileName)):
                    136:                 manage_addVersionedFile(self,fileName,'','')
                    137:                 id=fileName
                    138:                 ob=self._getOb(fileName)
                    139:                 ob.title=id
                    140:                 file2=file(os.path.join(path,fileName))
                    141:         
                    142:                 obj=ob.manage_addVersionedFileObject(id,comment,author,file2,content_type='')
                    143: 
                    144:         if RESPONSE:
                    145:             RESPONSE.redirect(self.REQUEST['URL1'])
                    146: 
                    147:     zipThreads={}
                    148:     zipThreads2={}
                    149: 
                    150:     def refreshTxt(self):
                    151:         """txt fuer refresh"""
                    152:         tn=self.REQUEST.SESSION['threadName']
                    153:         return """ 2;url=%s?repeat=%s """%(self.absolute_url()+"/exportFolder",tn)
                    154: 
                    155:     def exportFolder(self,repeat=None):
                    156:         """exportiert alle akutellen files des folders"""
                    157:         threadName=repeat
                    158:         
1.37    ! dwinter   159:         downloadZip=generateDownloadZip(self,self.absolute_url())
        !           160:         downloadZip()
        !           161:         return downloadZip.getResult()
        !           162:        ##  if not threadName or threadName=="":
        !           163: ##             threadStart=generateDownloadZip(self,self.absolute_url())
        !           164: ##             thread=Thread(target=threadStart)
1.35      dwinter   165:             
1.37    ! dwinter   166: ##             thread.start()
1.35      dwinter   167: 
                    168:                     
1.37    ! dwinter   169: ##             self.zipThreads[thread.getName()[0:]]=threadStart
        !           170: ##             self.zipThreads2[thread.getName()[0:]]=thread
        !           171: ##             self.REQUEST.SESSION['threadName']=thread.getName()[0:]
        !           172: ##             wait_template=self.aq_parent.ZopeFind(self.aq_parent,obj_ids=['zip_wait_template'])
        !           173: ##             if wait_template:
        !           174: ##                 return wait_template[0][1]()
        !           175: ##             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_wait.zpt')).__of__(self)
        !           176: ##             return pt()
1.35      dwinter   177:                 
1.37    ! dwinter   178: ##         else:
        !           179: ##             self.REQUEST.SESSION['threadName']=threadName
1.35      dwinter   180: 
1.37    ! dwinter   181: ##             if (self.zipThreads[threadName].getResult()==None):
1.35      dwinter   182: 
1.37    ! dwinter   183: ##                 wait_template=self.aq_parent.ZopeFind(self.aq_parent,obj_ids=['wait_template'])
        !           184: ##                 if wait_template:
        !           185: ##                     return wait_template[0][1]()
        !           186: 
        !           187: ##                 pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_wait.zpt')).__of__(self)
        !           188: ##                 return pt()
        !           189: ##             else:
        !           190: ##                 if self.zipThreads[threadName].isDone():
        !           191: ##                     self.REQUEST.SESSION['result']=self.zipThreads[threadName].getResult()
        !           192: ##                     self.zipThreads2[threadName].join()
        !           193: ##                     del(self.zipThreads2[threadName])
        !           194: ##                     del(self.zipThreads[threadName])
        !           195: ##                     pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_result.zpt')).__of__(self)
        !           196: ##                     return pt()
        !           197: 
        !           198: ##                 else:
        !           199: ##                     self.REQUEST.SESSION['result']=self.zipThreads[threadName].getResult()
        !           200: ##                     self.REQUEST.SESSION['threadName']=threadName
        !           201: ##                     pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','zip_wait_result.zpt')).__of__(self)
        !           202: ##                     return pt()
1.35      dwinter   203: 
                    204:     def downloadSet(self,fn):
                    205:        """download prepared set"""
                    206:        filename=os.path.join(tdir,fn)
                    207: 
                    208:        
                    209:        self.REQUEST.RESPONSE.setHeader("Content-Disposition","""attachement; filename="%s" """%"donloadFileFolder.tgz")
                    210:        self.REQUEST.RESPONSE.setHeader("Content-Type","application/octet-stream")
                    211:        len=os.stat(filename)[6]
                    212:        self.REQUEST.RESPONSE.setHeader("Content-Length",len)
                    213:        images=file(filename).read()
                    214:        self.REQUEST.RESPONSE.write(images)
                    215:        self.REQUEST.RESPONSE.close()
                    216: 
                    217:    
                    218: 
1.14      dwinter   219:     def helpDownload(self):
                    220:         """download help"""
                    221:         
1.19      dwinter   222:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','helpDownload')).__of__(self)
1.14      dwinter   223:         return pt()
                    224:     
1.5       dwinter   225:     def generateIndexHTML(self,RESPONSE=None):
                    226:         """lege standard index.html an"""
                    227: 
                    228: 
1.22      dwinter   229:         if not self.ZopeFind(self,obj_ids=['index.html']):
1.5       dwinter   230:             zt=ZopePageTemplate('index.html')
                    231:             self._setObject('index.html',zt)
                    232:             default_content_fn = os.path.join(package_home(globals()),
                    233:                                                'zpt/versionFileFolderMain.zpt')
                    234:             text = open(default_content_fn).read()
                    235:             zt.pt_edit(text, 'text/html')
                    236: 
                    237:         else:
                    238:             return "already exists!"
                    239:         
                    240:         if RESPONSE is not None:
                    241:             RESPONSE.redirect('manage_main')
                    242: 
1.6       dwinter   243: 
                    244:     def generateHistoryHTML(self,RESPONSE=None):
                    245:         """lege standard index.html an"""
                    246: 
1.5       dwinter   247:         
1.6       dwinter   248: 
1.22      dwinter   249:         if not self.ZopeFind(self,obj_ids=['history_template.html']):
1.6       dwinter   250:             zt=ZopePageTemplate('history_template.html')
                    251:             self._setObject('history_template.html',zt)
                    252:             default_content_fn = os.path.join(package_home(globals()),
                    253:                                                'zpt/versionHistory.zpt')
                    254:             text = open(default_content_fn).read()
                    255:             zt.pt_edit(text, 'text/html')
                    256: 
                    257:         else:
                    258:             return "already exists!"
                    259:         
                    260:         if RESPONSE is not None:
                    261:             RESPONSE.redirect('manage_main')
                    262: 
1.32      dwinter   263:     
                    264:        
                    265: 
1.12      dwinter   266:     def getVersionedFiles(self,sortField='title'):
1.1       dwinter   267:         """get all versioned files"""
1.12      dwinter   268: 
                    269:         def sortName(x,y):
1.18      dwinter   270:             return cmp(x[1].title.lower(),y[1].title.lower())
1.12      dwinter   271: 
                    272:         def sortDate(x,y):
1.17      dwinter   273:             return cmp(y[1].getLastVersion().getTime(),x[1].getLastVersion().getTime())
1.12      dwinter   274: 
1.32      dwinter   275:         
1.30      dwinter   276:         def sortComment(x,y):
1.34      dwinter   277: 
                    278:         
                    279:             
1.31      dwinter   280:     try:
1.34      dwinter   281:        xc=getattr(x[1],'comment','ZZZZZZZZZZZZZ').lower()
1.31      dwinter   282:     except:
1.34      dwinter   283:        xc='ZZZZZZZZZZZZZ'.lower()
1.31      dwinter   284:     try:
1.34      dwinter   285:        yc=getattr(y[1],'comment','ZZZZZZZZZZZZZ').lower()
1.31      dwinter   286:          except:
1.34      dwinter   287:             yc='ZZZZZZZZZZZZZ'.lower()
                    288: 
                    289: 
                    290:          if (xc=='') or (xc=='ZZZZZZZZZZZZZ'.lower()):
                    291:              
                    292:              try:
                    293:                  xc=x[1].getLastVersion().getVComment().lower()
                    294:              except:
                    295:                  xc='ZZZZZZZZZZZZZ'.lower()
                    296:                  
                    297:          if (yc=='') or (yc=='ZZZZZZZZZZZZZ'.lower()):
                    298:              try:
                    299:                  yc=y[1].getLastVersion().getVComment().lower()
                    300:              except:
                    301:                  yc='ZZZZZZZZZZZZZ'.lower()
                    302: 
                    303:          
                    304:          return cmp(xc,yc)
1.31      dwinter   305: 
1.12      dwinter   306:         def sortAuthor(x,y):
1.13      dwinter   307:             
1.30      dwinter   308:             return cmp(x[1].getLastVersion().lastEditor().lower(),y[1].getLastVersion().lastEditor().lower())
1.3       dwinter   309:         
1.2       dwinter   310:    versionedFiles=self.ZopeFind(self,obj_metatypes=['versionedFile'])
1.12      dwinter   311: 
                    312:         if sortField=='title':
                    313:             versionedFiles.sort(sortName)
                    314:         elif sortField=='date':
                    315:             versionedFiles.sort(sortDate)
                    316:         elif sortField=='author':
                    317:             versionedFiles.sort(sortAuthor)
1.30      dwinter   318:         elif sortField=='comment':
                    319:             versionedFiles.sort(sortComment)
1.12      dwinter   320: 
1.1       dwinter   321:         return versionedFiles
                    322: 
1.4       dwinter   323: 
                    324:     def header_html(self):
                    325:         """zusätzlicher header"""
                    326:         ext=self.ZopeFind(self,obj_ids=["header.html"])
                    327:         if ext:
                    328:             return ext[0][1]()
                    329:         else:
                    330:             return ""
                    331:         
1.1       dwinter   332:     def index_html(self):
                    333:         """main"""
1.4       dwinter   334:         ext=self.ZopeFind(self,obj_ids=["index.html"])
                    335:         if ext:
1.5       dwinter   336:             return ext[0][1]()
1.4       dwinter   337:         
1.19      dwinter   338:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','versionFileFolderMain')).__of__(self)
1.1       dwinter   339:         return pt()
                    340: 
                    341: 
                    342:     def addFileForm(self):
                    343:         """add a file"""
1.21      dwinter   344:         ext=self.ZopeFind(self,obj_ids=["addFileForm.dtml"])
                    345:         if ext:
                    346:             return ext[0][1]('',globals(),version='1',AUTHENTICATED_USER=self.REQUEST.AUTHENTICATED_USER)
                    347:         
1.1       dwinter   348:         out=DTMLFile('dtml/newFileAdd', globals(),Kind='VersionedFileObject',kind='versionedFileObject',version='1').__of__(self)
                    349:         return out()
                    350: 
                    351: 
1.11      dwinter   352:     def addFile(self,vC,file,author,newName='',content_type='',RESPONSE=None):
1.1       dwinter   353:         """ add a new file"""
1.11      dwinter   354:         if newName=='':
1.24      dwinter   355:             filename=file.filename
                    356:             id=filename[max(filename.rfind('/'),
                    357:                                     filename.rfind('\\'),
                    358:                                     filename.rfind(':'),
                    359:                                     )+1:]
1.25      dwinter   360: 
1.11      dwinter   361:         else:
                    362:             id=newName
1.1       dwinter   363:         
                    364:         vC=self.REQUEST.form['vC']
                    365:         manage_addVersionedFile(self,id,'','')
1.21      dwinter   366:         #if (getattr(self,'commentNonEmpty',0)==1) and vC.strip()=="":
                    367:             
                    368:             
1.1       dwinter   369:         ob=self._getOb(id)
                    370:         ob.title=id
1.3       dwinter   371:         file2=file
1.23      dwinter   372:         
                    373:         obj=ob.manage_addVersionedFileObject(id,vC,author,file2,content_type=content_type)
1.27      dwinter   374:         self.REQUEST.SESSION['objID']=ob.getId()
                    375:         self.REQUEST.SESSION['objID_parent']=None
1.1       dwinter   376: 
1.23      dwinter   377:         if obj.getSize()==0:
                    378:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','errorUploadFile')).__of__(self)
                    379:             return pt()
                    380:         
1.1       dwinter   381:         RESPONSE.redirect(self.REQUEST['URL1'])
                    382: 
1.27      dwinter   383: 
                    384:     def deleteEmptyObject(self,submit,RESPONSE=None):
                    385:         """deleteemptyobject"""
                    386:         if submit=="delete it":
                    387:             if self.REQUEST.SESSION['objID_parent']:
                    388:                 obj=getattr(self,self.REQUEST.SESSION['objID_parent'])
                    389: 
                    390:             else:
                    391:                 obj=self
                    392:             obj.manage_delObjects([self.REQUEST.SESSION['objID']])
                    393: 
                    394:         RESPONSE.redirect(self.REQUEST['URL1'])
                    395:         
1.1       dwinter   396:         
                    397: manage_addVersionedFileFolderForm=DTMLFile('dtml/folderAdd', globals())
                    398: 
                    399: 
                    400: def manage_addVersionedFileFolder(self, id, title='',
                    401:                      createPublic=0,
                    402:                      createUserF=0,
                    403:                      REQUEST=None):
                    404:     """Add a new Folder object with id *id*.
                    405: 
                    406:     If the 'createPublic' and 'createUserF' parameters are set to any true
                    407:     value, an 'index_html' and a 'UserFolder' objects are created respectively
                    408:     in the new folder.
                    409:     """
                    410:     ob=versionedFileFolder()
                    411:     ob.id=str(id)
                    412:     ob.title=title
                    413:     self._setObject(id, ob)
                    414:     ob=self._getOb(id)
                    415: 
                    416:     checkPermission=getSecurityManager().checkPermission
                    417: 
                    418:     if createUserF:
                    419:         if not checkPermission('Add User Folders', ob):
                    420:             raise Unauthorized, (
                    421:                   'You are not authorized to add User Folders.'
                    422:                   )
                    423:         ob.manage_addUserFolder()
                    424: 
                    425:   
                    426:     if REQUEST is not None:
                    427:         return self.manage_main(self, REQUEST, update_menu=1)
                    428: 
                    429: 
                    430: 
                    431: class versionedFileObject(File):
                    432:     """File Object im Folder"""
                    433:     
                    434:     meta_type = "versionedFileObject"
                    435:     
                    436:     manage_editForm  =DTMLFile('dtml/fileEdit',globals(),
                    437:                                Kind='File',kind='file')
                    438:     manage_editForm._setName('manage_editForm')
1.14      dwinter   439: 
1.32      dwinter   440:     def getVComment(self):
                    441:         """get the comment of this file"""
                    442:         if not hasattr(self,'vComment') or (not self.vComment) or (self.vComment.lstrip()==""):
                    443:             return "Add comment"
                    444: 
                    445:         else:
                    446:             return self.vComment
                    447:             
                    448:     def manageVCommentForm(self):
                    449:         """add a comment"""
1.34      dwinter   450: 
                    451:         self.REQUEST.SESSION['refer']=self.REQUEST['HTTP_REFERER']
                    452: 
                    453: 
                    454:         
1.32      dwinter   455:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addVComment')).__of__(self)
                    456:         return pt()
                    457: 
                    458:     def manageVComment(self,text,comment_author,submit,REQUEST=None):
                    459:         """manage comments"""
                    460:         if submit =='change':
                    461:             if text=='':
                    462:                 self.vComment=None
                    463:             else:
                    464:                 self.vComment=text
                    465:                 self.vComment_author=comment_author
                    466: 
                    467:                 self.vComment_date=time.strftime("%Y-%m-%d %H:%M:%S",time.localtime())
                    468: 
1.34      dwinter   469:         if self.REQUEST.SESSION.has_key('refer'):
                    470: 
                    471:             return REQUEST.RESPONSE.redirect(self.REQUEST.SESSION['refer'])
1.32      dwinter   472:         return REQUEST.RESPONSE.redirect(self.aq_parent.absolute_url()+"/history")
                    473:     
                    474: 
1.15      dwinter   475:     def getTime(self):
                    476:         """getTime"""
                    477:         #return self.bobobase_modification_time().ISO()
                    478:         if hasattr(self,'time'):
                    479:             return time.strftime("%Y-%m-%d %H:%M:%S",self.time)
1.16      dwinter   480:    elif hasattr(self,'timefixed'):
                    481:        return self.timefixed
1.15      dwinter   482:         else:
1.16      dwinter   483:        setattr(self,'timefixed',self.bobobase_modification_time().ISO())
1.15      dwinter   484:             return self.bobobase_modification_time().ISO()
                    485: 
                    486: 
                    487: 
1.14      dwinter   488:     
1.1       dwinter   489: 
1.7       dwinter   490:     def download(self):
                    491:         """download and lock"""
                    492:         
1.33      dwinter   493:         self.REQUEST.RESPONSE.setHeader("Content-Disposition","""attachement; filename=%s"""%self.getId())
                    494:    self.REQUEST.RESPONSE.setHeader("Content-Type","application/octet-stream")
                    495:       
1.10      dwinter   496:         self.content_type="application/octet-stream"
1.33      dwinter   497:         #self.REQUEST.RESPONSE.redirect(self.absolute_url())
                    498:         self.REQUEST.RESPONSE.write(self.index_html())
                    499:         #self.REQUEST.RESPONSE.write("bl")
                    500:         self.REQUEST.close()
1.7       dwinter   501:     
                    502:     def downloadLocked(self):
                    503:         """download and lock"""
                    504:         
                    505:         
                    506:         if self.REQUEST['AUTHENTICATED_USER']=='Anonymous User':
                    507:             return "please login first"
                    508:         if not self.aq_parent.lockedBy=="":
                    509:             return "cannot be locked because is already locked by %s"%self.lockedBy
                    510:         self.aq_parent.lockedBy=self.REQUEST['AUTHENTICATED_USER']
1.1       dwinter   511: 
1.10      dwinter   512:         self.content_type="application/octet-stream"
1.7       dwinter   513:         self.REQUEST.RESPONSE.redirect(self.absolute_url())
                    514:     
1.1       dwinter   515:     def setVersionNumber(self,versionNumber):
                    516:         """set version"""
                    517:         self.versionNumber=versionNumber
                    518: 
                    519:     def getVersionNumber(self):
                    520:         """get version"""
                    521:         return self.versionNumber
                    522: 
1.32      dwinter   523:    
                    524:             
1.1       dwinter   525:     def lastEditor(self):
                    526:         """last Editor"""
1.5       dwinter   527:         if hasattr(self,'author'):
1.32      dwinter   528:             ret=self.author.replace("-","\n")
                    529:             ret=ret.replace("\r","\n")
                    530:             return ret
                    531: 
1.5       dwinter   532:         else:
                    533:             jar=self._p_jar
                    534:             oid=self._p_oid
                    535: 
                    536:             if jar is None or oid is None: return None
                    537: 
                    538:             return jar.db().history(oid)[0]['user_name']
1.1       dwinter   539: 
                    540:     
                    541:     
                    542:         
                    543: manage_addVersionedFileObjectForm=DTMLFile('dtml/fileAdd', globals(),Kind='VersionedFileObject',kind='versionedFileObject', version='1')
                    544: 
1.5       dwinter   545: def manage_addVersionedFileObject(self,id,vC='',author='', file='',title='',precondition='', content_type='',
1.1       dwinter   546:                    REQUEST=None):
                    547:     """Add a new File object.
                    548: 
                    549:     Creates a new File object 'id' with the contents of 'file'"""
1.5       dwinter   550: 
1.1       dwinter   551:     id=str(id)
                    552:     title=str(title)
                    553:     content_type=str(content_type)
                    554:     precondition=str(precondition)
1.3       dwinter   555:     
1.1       dwinter   556:     id, title = cookId(id, title, file)
                    557: 
                    558:     self=self.this()
                    559: 
                    560:     # First, we create the file without data:
                    561:     self._setObject(id, versionedFileObject(id,title,'',content_type, precondition))
                    562:     self._getOb(id).versionComment=str(vC)
1.15      dwinter   563:     self._getOb(id).time=time.localtime()
                    564:     
1.5       dwinter   565:     setattr(self._getOb(id),'author',author)
1.1       dwinter   566:     
                    567:     # Now we "upload" the data.  By doing this in two steps, we
                    568:     # can use a database trick to make the upload more efficient.
                    569:     if file:
                    570:         self._getOb(id).manage_upload(file)
                    571:     if content_type:
                    572:         self._getOb(id).content_type=content_type
                    573: 
                    574:     if REQUEST is not None:
                    575:         REQUEST['RESPONSE'].redirect(self.absolute_url()+'/manage_main')
                    576: 
                    577: 
                    578: 
                    579: 
                    580: class versionedFile(Folder):
                    581:     """Versioniertes File"""
                    582: 
1.5       dwinter   583:     def __init__(self, id, title, lockedBy,author):
1.1       dwinter   584:         """init"""
                    585:         self.id=id
                    586:         self.title=title
                    587:         self.lockedBy=lockedBy
1.5       dwinter   588:         self.author=author
1.32      dwinter   589: 
                    590:     def getComment(self):
                    591:         """get the comment of this file"""
                    592:         if not hasattr(self,'comment') or (not self.comment) or (self.comment.lstrip()==""):
                    593:             return "Add comment"
                    594: 
                    595:         else:
                    596:             return self.comment
                    597:             
1.1       dwinter   598:         
                    599:     meta_type="versionedFile"
                    600: 
1.26      dwinter   601:     def manageCommentForm(self):
                    602:         """add a comment"""
                    603:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addComment')).__of__(self)
                    604:         return pt()
                    605: 
                    606:     def manageComment(self,text,comment_author,submit,REQUEST=None):
                    607:         """manage comments"""
                    608:         if submit =='change':
                    609:             if text=='':
                    610:                 self.comment=None
                    611:             else:
                    612:                 self.comment=text
                    613:                 self.comment_author=comment_author
                    614: 
                    615:                 self.comment_date=time.strftime("%Y-%m-%d %H:%M:%S",time.localtime())
                    616: 
                    617:         return REQUEST.RESPONSE.redirect(self.aq_parent.absolute_url())
                    618:     
1.1       dwinter   619:     def getLastVersion(self):
                    620:         """Last Version"""
                    621:         tmp=0
                    622:         lastVersion=None
1.2       dwinter   623:         
1.1       dwinter   624:         for version in self.ZopeFind(self):
1.2       dwinter   625:             
1.1       dwinter   626:             if hasattr(version[1],'versionNumber'):
1.2       dwinter   627:                 
1.1       dwinter   628:                 if int(version[1].versionNumber) > tmp:
                    629:                     tmp=int(version[1].versionNumber,)
                    630:                     lastVersion=version[1]
                    631:         return lastVersion
                    632:     
                    633:     def index_html(self):
                    634:         """main view"""
                    635:         lastVersion=self.getLastVersion()
                    636:         #return "File:"+self.title+"  Version:%i"%lastVersion.versionNumber," modified:",lastVersion.bobobase_modification_time()," size:",lastVersion.getSize(),"modified by:",lastVersion.lastEditor()
1.15      dwinter   637:         return "File: %s Version:%i modified:%s size:%s modified by:%s"%(self.title,lastVersion.versionNumber,lastVersion.getTime(),lastVersion.getSize(),lastVersion.lastEditor())
1.1       dwinter   638:                                                                          
                    639:     def getVersion(self):
                    640:         tmp=0
                    641:         for version in self.ZopeFind(self):
1.2       dwinter   642:             
1.1       dwinter   643:             if hasattr(version[1],'versionNumber'):
1.2       dwinter   644:                 
1.1       dwinter   645:                 if int(version[1].versionNumber) > tmp:
                    646:                     tmp=int(version[1].versionNumber,)
                    647:         return tmp+1
                    648: 
                    649:     security= ClassSecurityInfo()
                    650:     security.declareProtected('AUTHENTICATED_USER','unlock')
                    651: 
                    652:     def history(self):
1.6       dwinter   653:         """history"""  
                    654: 
                    655:         ext=self.ZopeFind(self.aq_parent,obj_ids=["history_template.html"])
                    656:         if ext:
                    657:             return getattr(self,ext[0][1].getId())()
                    658:         
1.19      dwinter   659:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','versionHistory')).__of__(self)
1.1       dwinter   660:         return pt()
                    661: 
                    662:     def getVersions(self):
                    663:         """get all versions"""
                    664:         ret=[]
                    665:         for version in self.ZopeFind(self):
                    666:             if hasattr(version[1],'versionNumber'):
                    667:                 ret.append((version[1].versionNumber,version[1]))
                    668:         ret.sort(sortv)
                    669:         return ret
                    670: 
1.28      dwinter   671:     security.declareProtected('AUTHENTICATED_USER','forceunlock')   
                    672:     def forceunlock(self,RESPONSE):
1.1       dwinter   673:         """unlock"""
1.28      dwinter   674:         self.lockedBy=''
1.29      dwinter   675: 
                    676:     security.declareProtected('AUTHENTICATED_USER','unlock')   
                    677:     def unlock(self,RESPONSE):
                    678:         """unlock"""
                    679:         if str(self.lockedBy) in [str(self.REQUEST['AUTHENTICATED_USER'])]:
                    680:             self.lockedBy=''
                    681:             RESPONSE.redirect(self.REQUEST['URL2'])
                    682:         else:
                    683:             return "Sorry, not locked by you! (%s,%s)"%(self.lockedBy,self.REQUEST['AUTHENTICATED_USER'])
                    684:         
                    685: 
1.8       dwinter   686:     
1.1       dwinter   687:     security.declareProtected('AUTHENTICATED_USER','addVersionedFileObjectForm')
                    688: 
                    689:     def addVersionedFileObjectForm(self):
                    690:         """add a new version"""
1.2       dwinter   691:         
                    692:         if str(self.REQUEST['AUTHENTICATED_USER']) in ["Anonymous User"]:
1.1       dwinter   693:             return "please login first"
                    694:         if (self.lockedBy==self.REQUEST['AUTHENTICATED_USER']) or (self.lockedBy==''):
                    695:             out=DTMLFile('dtml/fileAdd', globals(),Kind='VersionedFileObject',kind='versionedFileObject',version=self.getVersion()).__of__(self)
                    696:             return out()
                    697:         else:
                    698:             return "Sorry file is locked by somebody else"
                    699:         
1.11      dwinter   700:     def manage_addVersionedFileObject(self,id,vC,author,file='',title='',precondition='', content_type='',changeName='no',newName='', RESPONSE=None):
1.1       dwinter   701:         """add"""
1.35      dwinter   702:         try: #der ganze vC unsinn muss ueberarbeitet werden
                    703:             vC=self.REQUEST['vC']
                    704:         except:
                    705:             pass
1.1       dwinter   706:         
1.5       dwinter   707:         author=self.REQUEST['author']
1.6       dwinter   708:         
                    709:         if changeName=="yes":
1.24      dwinter   710:             filename=file.filename
                    711:             self.title=filename[max(filename.rfind('/'),
                    712:                         filename.rfind('\\'),
                    713:                         filename.rfind(':'),
                    714:                         )+1:]
                    715: 
1.6       dwinter   716: 
1.11      dwinter   717:         if not newName=='':
                    718:             self.title=newName[0:]
1.35      dwinter   719:         print self.title
                    720:         
1.1       dwinter   721:         id="V%i"%self.getVersion()+"_"+self.title
1.23      dwinter   722:         
1.5       dwinter   723:         manage_addVersionedFileObject(self,id,vC,author,file,"V%i"%self.getVersion()+"_"+self.title,precondition, content_type)
1.1       dwinter   724:         objs=self.ZopeFind(self,obj_ids=[id])[0][1].setVersionNumber(int(self.getVersion()))
1.27      dwinter   725:         self.REQUEST.SESSION['objID_parent']=self.getId()
1.23      dwinter   726: 
1.1       dwinter   727:         if RESPONSE:
1.27      dwinter   728:             obj=self.ZopeFind(self,obj_ids=[id])[0][1]
                    729:             if obj.getSize()==0:
                    730:                 self.REQUEST.SESSION['objID']=obj.getId()
1.23      dwinter   731:                 pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','errorUploadFile')).__of__(self)
                    732:                 return pt()
                    733: 
                    734:             else:
                    735:                 RESPONSE.redirect(self.REQUEST['URL2'])
1.1       dwinter   736: 
1.23      dwinter   737:         else:
                    738:             return self.ZopeFind(self,obj_ids=[id])[0][1]
                    739:         
1.1       dwinter   740:     security.declareProtected('AUTHENTICATED_USER','downloadLocked')
                    741: 
1.7       dwinter   742:     def download(self):
                    743:         """download and lock"""
1.33      dwinter   744: 
                    745:         self.REQUEST.RESPONSE.setHeader("Content-Disposition","""attachement; filename=%s"""%self.getLastVersion().getId())
                    746:    self.REQUEST.RESPONSE.setHeader("Content-Type","application/octet-stream")
                    747:       
                    748:         self.content_type="application/octet-stream"
                    749:         #self.REQUEST.RESPONSE.write("bl")
                    750:         self.REQUEST.RESPONSE.write(self.getLastVersion().index_html())
                    751:         self.REQUEST.close()
                    752: 
                    753:         #self.getLastVersion().content_type="application/octet-stream"
                    754:         #self.REQUEST.RESPONSE.redirect(self.REQUEST['URL1']+'/'+self.getId()+'/'+self.getLastVersion().getId())
1.7       dwinter   755:     
1.1       dwinter   756:     def downloadLocked(self):
                    757:         """download and lock"""
                    758:         if self.REQUEST['AUTHENTICATED_USER']=='Anonymous User':
                    759:             return "please login first"
                    760:         if not self.lockedBy=="":
                    761:             return "cannot be locked because is already locked by %s"%self.lockedBy
                    762:         self.lockedBy=self.REQUEST['AUTHENTICATED_USER']
1.9       dwinter   763:         self.getLastVersion().content_type="application/octet-stream"
1.1       dwinter   764:         self.REQUEST.RESPONSE.redirect(self.REQUEST['URL1']+'/'+self.getId()+'/'+self.getLastVersion().getId())
                    765:     
                    766: def manage_addVersionedFileForm(self):
                    767:     """interface for adding the OSAS_root"""
1.19      dwinter   768:     pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addVersionedFile.zpt')).__of__(self)
1.1       dwinter   769:     return pt()
                    770: 
1.5       dwinter   771: def manage_addVersionedFile(self,id,title,lockedBy, author=None, RESPONSE=None):
1.1       dwinter   772:     """add the OSAS_root"""
1.5       dwinter   773:     newObj=versionedFile(id,title,lockedBy,author)
1.1       dwinter   774:     self._setObject(id,newObj)
1.5       dwinter   775:    
1.1       dwinter   776:     if RESPONSE is not None:
                    777:         RESPONSE.redirect('manage_main')
                    778: 
                    779: 
                    780: InitializeClass(versionedFile)
                    781: InitializeClass(versionedFileFolder)

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>