--- OSAS/OSA_system/OSAS_archiver.py 2003/12/23 13:43:10 1.3 +++ OSAS/OSA_system/OSAS_archiver.py 2005/05/04 14:06:31 1.12 @@ -1,4 +1,8 @@ -# Methoden und Klassen fuer den MPIWG Archiver +""" Methoden und Klassen fuer den MPIWG Archiver +20040303 Zur Zeit nur angepasst and das System des MPIWG +nächste schritte: Konfigurierbarkeit der Metadaten / Konfigurierbarkeit der Server + +""" from OFS.Image import Image from OFS.Folder import Folder @@ -6,11 +10,11 @@ from OFS.SimpleItem import SimpleItem from Products.PageTemplates.PageTemplateFile import PageTemplateFile from Products.PageTemplates.PageTemplate import PageTemplate from AccessControl import ClassSecurityInfo -from Globals import InitializeClass -from Globals import Persistent +from Globals import InitializeClass,Persistent,package_home from Acquisition import Implicit from OSAS_show import * from OSAS_helpers import * +from types import * import os.path import os @@ -30,18 +34,23 @@ class OSAS_archiveInbox(SimpleItem,Persi self.title=title self.pathes=[] - def addPath(self,path): + def addPath(self,path,RESPONSE=None): + """add a path""" today=time.localtime() - self.pathes.append([path,today]) + temp=self.pathes[0:] + temp.append([path,today]) + self.pathes=temp[0:] + if RESPONSE: + RESPONSE.redirect("index_html") def index_html(self): """main""" - pt=PageTemplateFile('Products/OSA_system/OSAS_archiveInboxIndex.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','OSAS_archiveInboxIndex.zpt')).__of__(self) return pt() def manage_AddOSAS_archiveInboxForm(self): """interface for adding the OSAS_root""" - pt=PageTemplateFile('Products/OSA_system/AddOSAS_archiveInbox.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','AddOSAS_archiveInbox.zpt')).__of__(self) return pt() @@ -80,12 +89,48 @@ class OSAS_metadataOrganizer(SimpleItem, self.title=title #self.acquisitionData=['provider_name','provider_address','provider_contact','provider_url','date','description'] + + def getName(self): + """gives name from request session path""" + path=self.REQUEST.SESSION['path'] + splitted=path.split("/") + return splitted[len(splitted)-1] + + def addRessourceMeta(self,path=None,RESPONSE=None): + """Metadaten fuer Ressource""" + if not path: + path=self.REQUEST.SESSION['path'] + + else: + self.REQUEST.SESSION['path']=path + + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','inputRessourceData.zpt')).__of__(self) + return pt() + + + def writeRessourceMetadata(self,name,date,description,creator,RESPONSE=None): + """schreibe Resourcedata in index.meta""" + + path=self.REQUEST.SESSION['path'] + + subnodes={} + subnodes['name']=name + subnodes['archive-creation-date']=date + subnodes['creator']=creator + subnodes['description']=description + + changeNodesInIndexMeta(path,"",subnodes) + self.inbox.addPath(self.REQUEST.SESSION['path']) + RESPONSE.redirect(self.REQUEST['URL2']) + + def addAcquisition(self,path): """Hinzufügen von Acquisition Daten""" self.REQUEST.SESSION['path']=path - pt=PageTemplateFile('Products/OSA_system/inputAcquisitionData.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','inputAcquisitionData.zpt')).__of__(self) return pt() + def writeAcquisitionMetadata(self,date,path,media_type,producer="mpiwg",description=""): """Schreibe Acquisiondata in index.meta""" @@ -114,7 +159,7 @@ class OSAS_metadataOrganizer(SimpleItem, self.metaDataSet=self.metaDataSets[self.mediaToAcquisition[media_type]] self.media_type=self.mediaToAcquisition[media_type] - pt=PageTemplateFile('Products/OSA_system/inputDocumentMetadata.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','inputDocumentMetadata.zpt')).__of__(self) return pt() @@ -139,7 +184,7 @@ class OSAS_metadataOrganizer(SimpleItem, changeNodesInIndexMeta(self.REQUEST.SESSION['path'],"img",subnodes) - pt=PageTemplateFile('Products/OSA_system/inputBiblioMetadata.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','inputBiblioMetadata.zpt')).__of__(self) return pt() def writeBiblioMetadata(self,bibdata_type,RESPONSE=None): @@ -151,19 +196,16 @@ class OSAS_metadataOrganizer(SimpleItem, #for key in form.keys(): # subnodes[key]=form['device'] subnodes=form + del subnodes['bibdata_type'] #in form but not metadata changeNodesInIndexMeta(self.REQUEST.SESSION['path'],"bib",subnodes,nodeAttributes={'type':bibdata_type},parent="meta") - self.inbox.addPath(self.REQUEST.SESSION['path']) - RESPONSE.redirect(self.REQUEST['URL2']) - - - - + #return self.REQUEST + return self.addRessourceMeta() def manage_AddOSAS_metadataOrganizerForm(self): """interface for adding the OSAS_root""" - pt=PageTemplateFile('Products/OSA_system/AddOSAS_metadataOrganizer.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','AddOSAS_metadataOrganizer.zpt')).__of__(self) return pt() @@ -190,7 +232,7 @@ class OSAS_processViewer(SimpleItem,Pers def index_html(self): """main page""" - pt=PageTemplateFile('Products/OSA_system/processViewerIndex.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','processViewerIndex.zpt')).__of__(self) return pt() def storeFile(self,something): @@ -198,9 +240,10 @@ class OSAS_processViewer(SimpleItem,Pers self.REQUEST.SESSION['something']=something return 1 - def getFile(self): + def getFile(self,number): """get info from session""" - return self.REQUEST.SESSION['something'] + check=self.getoverview('/var/tmp/archiver').messages()[number] + return check def getoverview(self,path): """get overview""" @@ -214,14 +257,42 @@ class OSAS_processViewer(SimpleItem,Pers return 'error?number=%i'%i - def view(self): + def geterror(self,str,context): + session=context.REQUEST.SESSION + return session[str] + + + def readfile(self,path): + + ret="" + f=open(path,'r') + for g in f.readlines(): + ret=ret+g + return ret + + def writefile(self,path,txt,REQUEST): + """writefile""" + f=open(path,'w') + f.write(txt) + f.close() + rval=self.aq_acquire('archive2') + return rval() + + + def view(self,number): """view page""" - pt=PageTemplateFile('Products/OSA_system/processViewerView.zpt').__of__(self) + self.errnum=number + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','processViewerView.zpt')).__of__(self) + return pt() + + def error(self): + """view errors""" + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','processViewerError.zpt')).__of__(self) return pt() def manage_AddOSAS_processViewerForm(self): """interface for adding the OSAS_processViewer""" - pt=PageTemplateFile('Products/OSA_system/AddOSAS_processViewer.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','AddOSAS_processViewer.zpt')).__of__(self) return pt() @@ -242,23 +313,49 @@ class OSAS_archiver(Folder, Persistent,I meta_type="OSAS_archiver" - # to be deleted later - #startPath="/mpiwg" + manage_options = Folder.manage_options+( + {'label':'Main Config','action':'changeOSAS_archiverForm'}, + ) + + def unarchive(self,path): + """unarchive the path""" + f = os.popen("/usr/local/mpiwg/archive/unarchiver "+path,"r") + return f.readlines() + + def checkIfUnarchive(self,path): + if not os.path.exists(path+"/index.meta"): + return 0 + f=file(path+"/index.meta","r").read() + dom=xml.dom.minidom.parseString(f) + archiveStorageDates=dom.getElementsByTagName("archive-storage-date") + if archiveStorageDates: + return 1 + else: + return 0 + ## methoden aus dem alten archive.py - + def isArray(self,path): + """check for array""" + if type(path) == StringType: + return 0 + else: + return 1 + def archiver(self,path): """archive the documents in path""" tmp=archive.archive(path,self.REQUEST.SESSION) - pt=PageTemplateFile('Products/OSA_system/archiveStatus.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','archiveStatus.zpt')).__of__(self) return pt() - + def archive2(self): + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','archive2.zpt')).__of__(self) + return pt() def metachecker(self,path): - """check the metadata the documents in path""" + """check the metadata of the documents in path""" self.REQUEST.SESSION['path']=self.REQUEST['path'] return archive.metacheck(path) @@ -295,7 +392,6 @@ class OSAS_archiver(Folder, Persistent,I def getfilesystem2(self,start,reload=0): """load filesystem""" - k=filesystem2(start,1) return k @@ -315,12 +411,12 @@ class OSAS_archiver(Folder, Persistent,I def archiver_html(self): """archiver""" - pt=PageTemplateFile('Products/OSA_system/OSAS_Archiver.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','OSAS_Archiver.zpt')).__of__(self) return pt() def index_html(self): """main page""" - pt=PageTemplateFile('Products/OSA_system/archiverIndex.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','archiverIndex.zpt')).__of__(self) return pt() def getDate(self): @@ -329,7 +425,7 @@ class OSAS_archiver(Folder, Persistent,I def newFolders_html(self): """main page""" - pt=PageTemplateFile('Products/OSA_system/newFolders.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','newFolders.zpt')).__of__(self) return pt() def getProducers(self): @@ -346,7 +442,7 @@ class OSAS_archiver(Folder, Persistent,I def getProducer(self,id): """Gebe ProducerObjekt zurück""" - obj=getattr(self.aq_parent.producerFolder,id) + obj=getattr(self.producerFolder,id) return obj @@ -355,20 +451,63 @@ class OSAS_archiver(Folder, Persistent,I """Erzeuge Folder im producer Verzeichnis mit ids""" self.REQUEST.SESSION['producer']=producer self.REQUEST.SESSION['ids']=self.idGenerator.giveIdsOut(number) - pt=PageTemplateFile('Products/OSA_system/createFoldersForm.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','createFoldersForm.zpt')).__of__(self) return pt() def createFolders(self,folderList,producer): """Erzeug die entsprechenden Folder""" - for folder in folderList: - os.mkdir(self.startPath+"/"+producer+"/"+folder) - self.REQUEST.SESSION['folderList']=folderList - pt=PageTemplateFile('Products/OSA_system/createFolders.zpt').__of__(self) + #hack + #producer="library" + if type(folderList)==StringType: + folders=[folderList] + else: + folders=folderList + #return producer + producerFolderName=self.getProducer(producer).producerFolderName + + for folder in folders: + os.mkdir(self.startPath+"/"+producerFolderName+"/"+folder) + os.chmod(self.startPath+"/"+producerFolderName+"/"+folder,0775) + self.REQUEST.SESSION['folderList']=folders + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','createFolders.zpt')).__of__(self) return pt() + def storeerror(self,ret,path,context,i): + """store an error""" + session=context.REQUEST.SESSION + session['error%i'%i]=ret + session['path%i'%i]=path + + return 'error?number=%i'%i + + def geterror(self,str,context): + session=context.REQUEST.SESSION + return session[str] + + def readfile(self,path): + + ret="" + f=open(path,'r') + for g in f.readlines(): + ret=ret+g + return ret + + def writefile(self,path,txt,REQUEST): + """writefile""" + f=open(path,'w') + f.write(txt) + f.close() + return self.archive2() + + def error(self): + """view errors""" + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','processViewerError.zpt')).__of__(self) + return pt() + + def archiveSelected(self): """Archiviere ausgewaehlte files""" - pt=PageTemplateFile('Products/OSA_system/archiveSelected.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','archiveSelected.zpt')).__of__(self) return pt() def enterAcquisitionMetadata(self): @@ -381,12 +520,23 @@ class OSAS_archiver(Folder, Persistent,I """Anzeige der noch zu archivieren Files""" + def changeOSAS_archiverForm(self): + """change""" + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','ChangeOSAS_archiver.zpt')).__of__(self) + return pt() + def changeOSAS_archiver(self,startPath,title="",RESPONSE=None): + """change""" + self.startPath=startPath + self.title=title + + if RESPONSE is not None: + RESPONSE.redirect('manage_main') def manage_AddOSAS_archiverForm(self): """interface for adding the OSAS_root""" - pt=PageTemplateFile('Products/OSA_system/AddOSAS_archiver.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','AddOSAS_archiver.zpt')).__of__(self) return pt() @@ -407,42 +557,47 @@ class OSAS_producer(SimpleItem,Persisten meta_type="OSAS_producer" - def __init__(self,shortName,fullName,address="",url="",contact=""): + def __init__(self,shortName,fullName,producerFolderName,address="",url="",contact=""): self.id=shortName self.title=fullName self.address=address self.url=url self.contact=contact - + self.producerFolderName=producerFolderName + manage_options = SimpleItem.manage_options+( {'label':'Main Config','action':'changeOSAS_producerForm'}, ) def changeOSAS_producerForm(self): """change""" - pt=PageTemplateFile('Products/OSA_system/ChangeOSAS_producer.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','ChangeOSAS_producer.zpt')).__of__(self) return pt() - def changeOSAS_producer(self,title,address,contact="",url=""): + def changeOSAS_producer(self,title,address,producerFolderName,contact="",url="",RESPONSE=None): """change""" - self.title=fullName + self.title=title self.address=address self.url=url self.contact=contact + self.producerFolderName=producerFolderName + if RESPONSE: + RESPONSE.redirect("manage_main") + def manage_AddOSAS_producerForm(self): """interface for adding the OSAS_root""" - pt=PageTemplateFile('Products/OSA_system/AddOSAS_producer.zpt').__of__(self) + pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','AddOSAS_producer.zpt')).__of__(self) return pt() -def manage_AddOSAS_producer(self,id,title="",contact="",address="",url="",RESPONSE=None): +def manage_AddOSAS_producer(self,id,producerFolderName,title="",contact="",address="",url="",RESPONSE=None): """add the OSAS_root""" if title=="": title=id - newObj=OSAS_producer(id, title,address,contact,url) + newObj=OSAS_producer(id, title,producerFolderName,address,contact,url) self._setObject(id,newObj) if RESPONSE is not None: RESPONSE.redirect('manage_main')