connector.py

FCKeditor,此HTML文本编辑器可以让web程序拥有如MS Word这样强大的编辑功能.支持当前流行的浏览器如IE 5.5+, Firefox 1.0+, Mozilla 1.3+与Netsc

	"""
	createXmlFooter

	Purpose: returns the xml footer
	"""
	def createXmlFooter(self):
		s = """</Connector>"""
		return s

	"""
	sendError

	Purpose: in the event of an error, return an xml based error
	"""
	def sendError(self, number, text):
		self.setXmlHeaders()
		s = ""
		# Create the XML document header
		s += """<?xml version="1.0" encoding="utf-8" ?>"""
		s += """<Connector>"""
		s += """<Error number="%s" text="%s" />""" % (number, text)
		s += """</Connector>"""
		return s

	"""
	getFolders

	Purpose: command to recieve a list of folders
	"""
	def getFolders(self, resourceType, currentFolder):
		if (self.isZope()):
			return self.getZopeFolders(resourceType, currentFolder)
		else:
			return self.getNonZopeFolders(resourceType, currentFolder)

	def getZopeFolders(self, resourceType, currentFolder):
		# Open the folders node
		s = ""
		s += """<Folders>"""
		zopeFolder = self.findZopeFolder(resourceType, currentFolder)
		for (name, o) in zopeFolder.objectItems(["Folder"]):
			s += """<Folder name="%s" />""" % (
					self.convertToXmlAttribute(name)
					)
		# Close the folders node
		s += """</Folders>"""
		return s

	def getNonZopeFolders(self, resourceType, currentFolder):
		# Map the virtual path to our local server
		serverPath = self.serverMapFolder(resourceType, currentFolder)
		# Open the folders node
		s = ""
		s += """<Folders>"""
		for someObject in os.listdir(serverPath):
			someObjectPath = os.path.join(serverPath, someObject)
			if os.path.isdir(someObjectPath):
				s += """<Folder name="%s" />""" % (
						self.convertToXmlAttribute(someObject)
						)
		# Close the folders node
		s += """</Folders>"""
		return s
		
	"""
	getFoldersAndFiles

	Purpose: command to recieve a list of folders and files
	"""
	def getFoldersAndFiles(self, resourceType, currentFolder):
		if (self.isZope()):
			return self.getZopeFoldersAndFiles(resourceType, currentFolder)
		else:
			return self.getNonZopeFoldersAndFiles(resourceType, currentFolder)

	def getNonZopeFoldersAndFiles(self, resourceType, currentFolder):
		# Map the virtual path to our local server
		serverPath = self.serverMapFolder(resourceType, currentFolder)
		# Open the folders / files node
		folders = """<Folders>"""
		files = """<Files>"""
		for someObject in os.listdir(serverPath):
			someObjectPath = os.path.join(serverPath, someObject)
			if os.path.isdir(someObjectPath):
				folders += """<Folder name="%s" />""" % (
						self.convertToXmlAttribute(someObject)
						)
			elif os.path.isfile(someObjectPath):
				size = os.path.getsize(someObjectPath)
				files += """<File name="%s" size="%s" />""" % (
						self.convertToXmlAttribute(someObject),
						os.path.getsize(someObjectPath)
						)
		# Close the folders / files node
		folders += """</Folders>"""
		files += """</Files>"""
		# Return it
		s = folders + files
		return s

	def getZopeFoldersAndFiles(self, resourceType, currentFolder):
		folders = self.getZopeFolders(resourceType, currentFolder)
		files = self.getZopeFiles(resourceType, currentFolder)
		s = folders + files
		return s

	def getZopeFiles(self, resourceType, currentFolder):
		# Open the files node
		s = ""
		s += """<Files>"""
		zopeFolder = self.findZopeFolder(resourceType, currentFolder)
		for (name, o) in zopeFolder.objectItems(["File","Image"]):
			s += """<File name="%s" size="%s" />""" % (
					self.convertToXmlAttribute(name),
					((o.get_size() / 1024) + 1)
					)
		# Close the files node
		s += """</Files>"""
		return s
		
	def findZopeFolder(self, resourceType, folderName):
		# returns the context of the resource / folder
		zopeFolder = self.getZopeUploadContext()
		folderName = self.removeFromStart(folderName, "/")
		folderName = self.removeFromEnd(folderName, "/")
		if (resourceType <> ""):
			try:
				zopeFolder = zopeFolder[resourceType]
			except:
				zopeFolder.manage_addProduct["OFSP"].manage_addFolder(id=resourceType, title=resourceType)
				zopeFolder = zopeFolder[resourceType]
		if (folderName <> ""):
			folderNames = folderName.split("/")
			for folderName in folderNames:
				zopeFolder = zopeFolder[folderName]
		return zopeFolder

	"""
	createFolder

	Purpose: command to create a new folder
	"""
	def createFolder(self, resourceType, currentFolder):
		if (self.isZope()):
			return self.createZopeFolder(resourceType, currentFolder)
		else:
			return self.createNonZopeFolder(resourceType, currentFolder)

	def createZopeFolder(self, resourceType, currentFolder):
		# Find out where we are
		zopeFolder = self.findZopeFolder(resourceType, currentFolder)
		errorNo = 0
		errorMsg = ""
		if self.request.has_key("NewFolderName"):
			newFolder = self.request.get("NewFolderName", None)
			zopeFolder.manage_addProduct["OFSP"].manage_addFolder(id=newFolder, title=newFolder)
		else:
			errorNo = 102
		error = """<Error number="%s" originalDescription="%s" />""" % (
				errorNo,
				self.convertToXmlAttribute(errorMsg)
				)
		return error

	def createNonZopeFolder(self, resourceType, currentFolder):
		errorNo = 0
		errorMsg = ""
		if self.request.has_key("NewFolderName"):
			newFolder = self.request.get("NewFolderName", None)
			currentFolderPath = self.serverMapFolder(
					resourceType, 
					currentFolder
					)
			try:
				newFolderPath = currentFolderPath + newFolder
				errorMsg = self.createServerFolder(newFolderPath)
				if (errorMsg is not None):
					errorNo = 110
			except:
				errorNo = 103
		else:
			errorNo = 102
		error = """<Error number="%s" originalDescription="%s" />""" % (
				errorNo,
				self.convertToXmlAttribute(errorMsg)
				)
		return error

	"""
	getFileName

	Purpose: helper function to extrapolate the filename
	"""
	def getFileName(self, filename):
		for splitChar in ["/", "\\"]:
			array = filename.split(splitChar)
			if (len(array) > 1):
				filename = array[-1]
		return filename

	"""
	fileUpload

	Purpose: command to upload files to server
	"""
	def fileUpload(self, resourceType, currentFolder):
		if (self.isZope()):
			return self.zopeFileUpload(resourceType, currentFolder)
		else:
			return self.nonZopeFileUpload(resourceType, currentFolder)

	def zopeFileUpload(self, resourceType, currentFolder, count=None):
		zopeFolder = self.findZopeFolder(resourceType, currentFolder)
		file = self.request.get("NewFile", None)
		fileName = self.getFileName(file.filename)
		fileNameOnly = self.removeExtension(fileName)
		fileExtension = self.getExtension(fileName).lower()
		if (count):
			nid = "%s.%s.%s" % (fileNameOnly, count, fileExtension)
		else:
			nid = fileName
		title = nid
		try:
			zopeFolder.manage_addProduct['OFSP'].manage_addFile(
					id=nid,
					title=title,
					file=file.read()
					)
		except:
			if (count):
				count += 1
			else:
				count = 1
			self.zopeFileUpload(resourceType, currentFolder, count)
		return
		
	def nonZopeFileUpload(self, resourceType, currentFolder):
		errorNo = 0
		errorMsg = ""
		if self.request.has_key("NewFile"):
			# newFile has all the contents we need
			newFile = self.request.get("NewFile", "")
			# Get the file name
			newFileName = newFile.filename
			newFileNameOnly = self.removeExtension(newFileName)
			newFileExtension = self.getExtension(newFileName).lower()
			allowedExtensions = self.getAllowedExtensions(resourceType)
			deniedExtensions = self.getDeniedExtensions(resourceType)
			if (allowedExtensions is not None):
				# Check for allowed
				isAllowed = False
				if (newFileExtension in allowedExtensions):
					isAllowed = True
			elif (deniedExtensions is not None):
				# Check for denied
				isAllowed = True
				if (newFileExtension in deniedExtensions):
					isAllowed = False
			else:
				# No extension limitations
				isAllowed = True

			if (isAllowed):
				if (self.isZope()):
					# Upload into zope
					self.zopeFileUpload(resourceType, currentFolder)
				else:
					# Upload to operating system
					# Map the virtual path to the local server path
					currentFolderPath = self.serverMapFolder(
							resourceType, 
							currentFolder
							)
					i = 0
					while (True):
						newFilePath = "%s%s" % (
								currentFolderPath,
								newFileName
								)
						if os.path.exists(newFilePath):
							i += 1
							newFilePath = "%s%s(%s).%s" % (
									currentFolderPath,
									newFileNameOnly,
									i,
									newFileExtension
									)
							errorNo = 201
							break
						else:
							fileHandle = open(newFilePath,'w')
							linecount = 0
							while (1):
								#line = newFile.file.readline()
								line = newFile.readline()
								if not line: break
								fileHandle.write("%s" % line)
								linecount += 1
							os.chmod(newFilePath, 0777)
							break
			else:
				newFileName = "Extension not allowed"
				errorNo = 203
		else:
			newFileName = "No File"
			errorNo = 202
	
		string = """
<script type="text/javascript">
window.parent.frames["frmUpload"].OnUploadCompleted(%s,"%s");
</script>
				""" % (
						errorNo,
						newFileName.replace('"',"'")
						)
		return string

	def run(self):
		s = ""
		try:
			# Check if this is disabled
			if not(self.enabled):
				return self.sendError(1, "This connector is disabled.  Please check the connector configurations and try again")
			# Make sure we have valid inputs
			if not(
					(self.request.has_key("Command")) and 
					(self.request.has_key("Type")) and 
					(self.request.has_key("CurrentFolder"))
					):
				return 
			# Get command
			command = self.request.get("Command", None)
			# Get resource type
			resourceType = self.request.get("Type", None)
			# folder syntax must start and end with "/"
			currentFolder = self.request.get("CurrentFolder", None)
			if (currentFolder[-1] <> "/"):
				currentFolder += "/"
			if (currentFolder[0] <> "/"):
				currentFolder = "/" + currentFolder
			# Check for invalid paths
			if (".." in currentFolder):
				return self.sendError(102, "")
			# File upload doesn't have to return XML, so intercept
			# her:e
			if (command == "FileUpload"):
				return self.fileUpload(resourceType, currentFolder)
			# Begin XML
			s += self.createXmlHeader(command, resourceType, currentFolder)
			# Execute the command
			if (command == "GetFolders"):
				f = self.getFolders
			elif (command == "GetFoldersAndFiles"):
				f = self.getFoldersAndFiles
			elif (command == "CreateFolder"):
				f = self.createFolder
			else:
				f = None
			if (f is not None):
				s += f(resourceType, currentFolder)
			s += self.createXmlFooter()
		except Exception, e:
			s = "ERROR: %s" % e
		return s
			
# Running from command line
if __name__ == '__main__':
	# To test the output, uncomment the standard headers
	#print "Content-Type: text/html"
	#print ""
	print getFCKeditorConnector()

"""
Running from zope, you will need to modify this connector. 
If you have uploaded the FCKeditor into Zope (like me), you need to 
move this connector out of Zope, and replace the "connector" with an
alias as below.  The key to it is to pass the Zope context in, as
we then have a like to the Zope context.

## Script (Python) "connector.py"
##bind container=container
##bind context=context
##bind namespace=
##bind script=script
##bind subpath=traverse_subpath
##parameters=*args, **kws
##title=ALIAS
##
import Products.connector as connector
return connector.getFCKeditorConnector(context=context).run()
"""