Annotation of versionedFile/versionedFile.py, revision 1.42

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

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