Annotation of OSA_system2/OSAS_server.py, revision 1.20
1.1 dwinter 1: import os
2: import os.path
3: import stat
1.6 dwinter 4: import OSAS_helpers
1.8 dwinter 5: import xmlrpclib
1.7 dwinter 6: import bz2
1.9 dwinter 7: import base64
1.1 dwinter 8: from Products.PageTemplates.PageTemplateFile import PageTemplateFile
9: from Globals import InitializeClass,package_home
10: from OFS.SimpleItem import SimpleItem
1.14 dwinter 11: import zLOG
1.18 dwinter 12: import sys
1.3 dwinter 13:
1.10 dwinter 14: def encodeRPC(string):
15: return base64.encodestring(bz2.compress(string))
1.20 ! dwinter 16: def decodeRPC(string):
! 17: return bz2.decompress(base64.decodestring(string))
1.4 dwinter 18:
1.1 dwinter 19:
20: class OSAS_storeOnlineServer(SimpleItem):
21: """Server for store Online system"""
1.2 dwinter 22:
1.4 dwinter 23:
1.2 dwinter 24: meta_type="OSAS_server"
25:
1.15 dwinter 26: def __init__(self,id):
27: """initalize osas_server"""
28: self.id = id
29:
1.13 dwinter 30: def getImages(self,path):
1.12 dwinter 31: """hack"""
32: imageEnding=['.gif','.jpg','.jpeg','.png','.tiff','.tif']
1.13 dwinter 33:
1.12 dwinter 34: dirs=os.listdir(path)
35: ret=[]
1.13 dwinter 36:
1.12 dwinter 37: for dir in dirs:
1.13 dwinter 38:
39: if os.path.isdir(os.path.join(path,dir)):
40:
1.12 dwinter 41: for subdir in os.listdir(os.path.join(path,dir)):
42: if os.path.splitext(subdir)[1].lower() in imageEnding:
43: ret.append(os.path.join(dir,subdir))
44: else:
45: if os.path.splitext(dir)[1] in imageEnding:
46: ret.append(os.path.join(dir))
47: return ret
48:
49:
1.13 dwinter 50: def getMovies(self,path):
1.12 dwinter 51: """hack"""
52: movieEnding=['.dv','.mov','.mp4']
53: dirs=os.listdir(path)
54: ret=[]
55: for dir in dirs:
1.13 dwinter 56: if os.path.isdir(os.path.join(path,dir)):
1.12 dwinter 57: for subdir in os.listdir(os.path.join(path,dir)):
58: if os.path.splitext(subdir)[1].lower() in movieEnding:
59: ret.append(os.path.join(dir,subdir))
60: else:
1.13 dwinter 61: if os.path.splitext(dir)[1] in movieEnding:
1.12 dwinter 62: ret.append(os.path.join(dir))
63: return ret
64:
65:
1.1 dwinter 66: def findIndexMeta(self,realPath=""):
67: """finde Rueckwaerts im Baum von Pfad ausgehend, dass erste index.meta file
68: @keyword path: default ist "", Pfad auf das Object
69: @return: None falls kein index.meta existiert sonst Pfad auf das index.meta
70: """
71:
72: #suche index.meta
73: while (not os.path.exists(os.path.join(realPath,'index.meta'))) and (not ((realPath=="") or (realPath=="/"))):
74: realPath=os.path.split(realPath)[0]
75:
76: if realPath=='' or realPath=='/':
77: if os.path.exists(os.path.join(realPath,'index.meta')):
78: return (os.path.join(realPath,'index.meta'))
79: else:
80: return None
81: else:
82: return os.path.join(realPath,'index.meta')
83:
84: def findIndexMetaWithStats(self,path=""):
85: """finde Rueckwaerts im Baum von Pfad ausgehend, dass erste index.meta file
86: @keyword path: default ist "", Pfad auf das Object
87: @return: None falls kein index.meta existiert sonst Tupel (Pfad auf das index.meta,stats(indexMeta)
88: """
89:
90: indexMeta=self.findIndexMeta(path)
91: if indexMeta:
92: return (indexMeta,self.getStat(indexMeta))
93: else:
94: return (None,[])
95:
96:
97: def getStat(self,path=""):
98: """Gibt stat von path aus
99: @keyword path: default ist "", Pfad
100: @return: stat[path]"""
101:
102: if not os.path.exists(path):
103: #return None,"(ERROR) path %s does not exist."%path
104: return None
105: else:
106: return [x for x in os.stat(path)]
107:
108:
109:
110:
111: def listdir(self,path=""):
112: """list dir"""
113: return os.listdir(path)
114:
1.5 dwinter 115: def isdir(self,path=""):
116: """list dir"""
117: return os.path.isdir(path)
118:
119: def isfile(self,path=""):
120: """list dir"""
1.6 dwinter 121: return os.path.isfile(path)
1.5 dwinter 122:
123:
124:
1.3 dwinter 125: def getFile(self,path):
126: """getFile"""
1.4 dwinter 127:
128: if not os.path.exists(path):
129: return None
130:
1.3 dwinter 131: f=file(path,'r')
1.4 dwinter 132:
1.3 dwinter 133: ret=f.read()
1.4 dwinter 134:
1.3 dwinter 135: f.close()
1.4 dwinter 136:
1.3 dwinter 137: return ret
1.6 dwinter 138:
139: def getAllIndexMetasOfSubDirs(self,path):
140: """get all index Metas"""
141: ret={}
142: if os.path.exists(path+"/index.meta"):
1.10 dwinter 143: compressed=encodeRPC(file(path+"/index.meta","r").read())
1.8 dwinter 144: ret["."]=('OSAS_dir',compressed)
1.6 dwinter 145: for dir in os.listdir(path):
1.17 casties 146: zLOG.LOG("SERVER",zLOG.INFO,"get all index meta in %s"%dir)
1.6 dwinter 147: fileType=OSAS_helpers.checkOSASFileType(os.path.join(path,dir))
148: if os.path.exists(os.path.join(path,dir,"index.meta")):
1.10 dwinter 149: compressed=encodeRPC(file(os.path.join(path,dir,"index.meta"),"r").read())
1.8 dwinter 150: ret[dir]=('OSAS_dir',compressed)
1.6 dwinter 151: else:
152: ret[dir]=(fileType,None)
1.8 dwinter 153: return ret
1.6 dwinter 154:
1.20 ! dwinter 155: def writeMetaDataFile(self,path,metadata,compressed=None):
1.11 dwinter 156: """writefiletoserver"""
1.20 ! dwinter 157: if compressed:
! 158: metadata=decodeRPC(metadata)
! 159:
1.11 dwinter 160: try:
161: fh=file(path,"w")
162: fh.write(metadata)
163: fh.close
164: return True
165: except:
1.19 casties 166: zLOG.LOG("SERVER (writeMetadataFile)",zLOG.ERROR,"%s (%s)"%sys.exc_info()[0:2])
1.11 dwinter 167: return False
1.14 dwinter 168:
169: def generateMovieThumb(self,input,output):
1.16 dwinter 170: """generate Movie"""
171: zLOG.LOG("SERVER",zLOG.INFO,"/usr/local/bin/thumbbite.pl %s %s"%(input,output))
172: ret=os.popen("/usr/local/bin/thumbbite.pl %s %s"%(input,output))
173: zLOG.LOG("SERVER",zLOG.INFO,ret)
1.14 dwinter 174: return "ok"
175:
1.1 dwinter 176: def manage_addOSAS_storeOnlineServerForm(self):
177: """interface for adding the OSAS_storeOnline"""
178: pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','addStoreOnlineServer.zpt')).__of__(self)
179: return pt()
180:
181: def manage_addOSAS_storeOnlineServer(self,id,RESPONSE=None):
182: """add the OSAS_storeOnline
183: @param id: id
184: """
185: newObj=OSAS_storeOnlineServer(id)
186: self._setObject(id,newObj)
187: if RESPONSE is not None:
188: RESPONSE.redirect('manage_main')
189:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/cvs/cvsweb/icons/back.gif){kind=icon}
Return to OSAS_server.py CVS log ![[TXT]](/cvs/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvs/cvsweb/icons/dir.gif){kind=icon}
Up to [Repository] / OSA_system2