Annotation of versionedFile/versionedFile.py, revision 1.48

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

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