Annotation of versionedFile/versionedFile.py, revision 1.41

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

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