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