netfraggle/bin/fraggleEngine.py

#-----------------------------------------------------------------------------
# Name:        fraggleEngine.py
# Purpose:     Does the main (non-gui) work
#
# Author:      joko
#
# Created:     2004/30/08
# RCS-ID:      $Id: fraggleEngine.py,v 1.10 2004/09/13 21:07:38 xabbu Exp $
# Copyright:   (c) 2004 netfrag.org
# Licence:     GPL
#-----------------------------------------------------------------------------

#-----------------------------------------------------------------------------
# $Log: fraggleEngine.py,v $
# Revision 1.10  2004/09/13 21:07:38  xabbu
# + function query added for testing of the nql / rpc interface
#
# Revision 1.9  2004/09/01 21:43:30  xabbu
# +Moved funtion getDefaultDir from FraggleCtlPreferences to FraggleEngine for more convenience
# +FraggleCtlModules class creation for handling content modules
#
# Revision 1.8  2004/08/31 16:48:19  joko
# + def authenticate
#
# Revision 1.7  2004/08/31 09:34:10  joko
# + def query_remote: don't do "getTopicById" here anymore
#
# Revision 1.6  2004/08/31 02:23:07  joko
# U changes to (dummy) topics metadata (FraggleXml)
# + def query_remote: wrapper for making remote xmlrpc call
#
# Revision 1.5  2004/08/30 13:03:13  joko
# - def getDefaultDir now in fraggleCtlPreferences
# + def getTopicById
#
# Revision 1.4  2004/08/27 03:18:30  joko
# new methods: fraggleSync, getTopics
#
# Revision 1.3  2004/08/26 15:25:04  joko
# added cvs headers
#-----------------------------------------------------------------------------

import os
from fraggleConstants import *
import FraggleXMLRPC
import fraggleCtlPreferences
import FraggleCtlModules
import fraggleParserXML

class FraggleEngine:
    """Back-end doing the work."""
    def __init__(self):
        self.settings = {}
        self.topics = {}
        self.modules = FraggleCtlModules.create(self)
        self.preferences = fraggleCtlPreferences.create(self)
        self.rpc = FraggleXMLRPC.create(self, self.preferences.getConfig())

    def setSetting(self, settingname, value):
        """Sets settingname to value in self.settings."""
        self.settings[settingname] = value

    def getSetting(self, settingname, default=None):
        """Returns settingname from self.settings. If not found
           and default!=None, the default value is return *and*
           saved to the settings."""
        if self.settings.has_key(settingname):
            return self.settings[settingname]
        else:
            if default!=None:
                self.setSetting(settingname, default)
                return default
            else:
                return None

    def syncTopics(self):
        query = "GET * FROM contenttypes"
        topicData = self.queryCms(query)
        topictypes = topicData['1']
      
        for i in topictypes:
         self.topics[i] = topictypes[i]['1']
         
        #print self.topics
        
    def getTopics(self):
        return self.topics
    
    def getTopicById(self, id):
        return self.topics[id]
    
    def listItems(self,topicId):
        result = self.queryCms("GET creator_id, language_id, description FROM contents")
        #print result
        
    def queryCms(self,nqlquery):
        
        from xmlrpclib import Server,Error
        rpc = Server('http://netfrag.org/nfo/netfraggle.php')
        result = rpc.query(nqlquery)
        if result['0']['error'] == '0':
           #print result
           return result
           
        #else:
        #print result['0']['error']
        #return result
       
    def query_remote(self, topicmeta):

        if topicmeta['target']['type'] == 'XMLRPC':
            # TODO: make FraggleXMLRPC do all stuff
            # (call methods dynamically)
            from xmlrpclib import Server, Error
            rpc = Server(topicmeta['target']['url'])
            #try:
            if topicmeta['result'] == 'item':
                topicdata = {}
                try:
                    #topicdata = rpc.getContent('Home')
                    #topicdata = rpc.getContent(tuple(topicmeta['target']['arguments']))
                    topicdata = rpc.getContent(topicmeta['target']['arguments'])
                    #print topicdata
                except Error, v:
                    print "ERROR", v
            elif topicmeta['result'] == 'list':
                topicdata = []
                try:
                    arg = {'type': 'xmlpage'}
                    topicdata = rpc.listTopics(arg)
                    #print topicdata
                    #self.styledTextContent.SetText(repr(topicdata))
                except Error, v:
                    print "ERROR", v
        return topicdata

    def authenticate(self, server, username, password):
        from xmlrpclib import Server, Error
        rpc = Server(server)
        try:
            return rpc.authenticate({'user': username, 'pass': password})
        except Error, v:
            print "ERROR", v
        
    def getDefaultDir(self):
        """Gets location of default dir and creates it
           if necessary. ($HOME/.pears/)"""
        try:
            import pearsdebug
            savedir = pearsdebug.savedir
        except:
            dir = '.netfraggle'
            savedir = os.path.expanduser(os.path.join('~', dir))
            if len(savedir)<=len("c:\\/" + dir):
                # problem that might occur on Win2k (no $HOME environment variable)
                temp = os.path.join(os.path.expandvars('$USERPROFILE'), dir)
                if temp > len("c:\\/" + dir):
                    savedir = temp
            # create dir if it doesn't exist
            if not os.path.exists(savedir):
                os.makedirs(savedir)
        return savedir
                   
class urlOpener(object):
    """Opens urls."""
    def __init__(self):
        pass
    def open(self, url="", command=None):
        """Opens the url with the method defined in the settings.
           If command==None, it is retreived from the settings.
        """       
        if command==None:
            command = FraggleEngine().getSetting(BROWSERCOMMAND, BROWSERDEFAULT)
        if command==BROWSERDEFAULT.strip():
            # use default opening method
            import os
            if os.environ.has_key("BROWSER") and \
               os.environ["BROWSER"]=='kfmclient openProfile webbrowsing':
                print "Invalid browser detected : %s\nResetting to konqueror." % os.environ["BROWSER"]
                os.environ["BROWSER"] = 'konqueror' # set it to konqueror
            import webbrowser # MUST be imported only AFTER os.environ has been modified
            webbrowser.open(url, 1)
            #webbrowser.open_new(url)
        else: #otherwise use user-defined command line
            # replase %URL with actual url
            command = command.replace("%URL", url)
            import os
            os.system(command)

1	joko	1.5	#-----------------------------------------------------------------------------
2			# Name: fraggleEngine.py
3			# Purpose: Does the main (non-gui) work
4			#
5			# Author: joko
6			#
7			# Created: 2004/30/08
8	xabbu	1.11	# RCS-ID: $Id: fraggleEngine.py,v 1.10 2004/09/13 21:07:38 xabbu Exp $
9	joko	1.5	# Copyright: (c) 2004 netfrag.org
10			# Licence: GPL
11			#-----------------------------------------------------------------------------
12	joko	1.2
13	joko	1.5	#-----------------------------------------------------------------------------
14	joko	1.4	# $Log: fraggleEngine.py,v $
15	xabbu	1.11	# Revision 1.10 2004/09/13 21:07:38 xabbu
16			# + function query added for testing of the nql / rpc interface
17			#
18	xabbu	1.10	# Revision 1.9 2004/09/01 21:43:30 xabbu
19			# +Moved funtion getDefaultDir from FraggleCtlPreferences to FraggleEngine for more convenience
20			# +FraggleCtlModules class creation for handling content modules
21			#
22	xabbu	1.9	# Revision 1.8 2004/08/31 16:48:19 joko
23			# + def authenticate
24			#
25	joko	1.8	# Revision 1.7 2004/08/31 09:34:10 joko
26			# + def query_remote: don't do "getTopicById" here anymore
27			#
28	joko	1.7	# Revision 1.6 2004/08/31 02:23:07 joko
29			# U changes to (dummy) topics metadata (FraggleXml)
30			# + def query_remote: wrapper for making remote xmlrpc call
31			#
32	joko	1.6	# Revision 1.5 2004/08/30 13:03:13 joko
33			# - def getDefaultDir now in fraggleCtlPreferences
34			# + def getTopicById
35			#
36	joko	1.5	# Revision 1.4 2004/08/27 03:18:30 joko
37			# new methods: fraggleSync, getTopics
38			#
39	joko	1.4	# Revision 1.3 2004/08/26 15:25:04 joko
40			# added cvs headers
41	joko	1.5	#-----------------------------------------------------------------------------
42	joko	1.3
43	joko	1.1	import os
44	joko	1.2	from fraggleConstants import *
45	joko	1.4	import FraggleXMLRPC
46	joko	1.5	import fraggleCtlPreferences
47	xabbu	1.9	import FraggleCtlModules
48	xabbu	1.10	import fraggleParserXML
49	joko	1.1
50			class FraggleEngine:
51	joko	1.2	"""Back-end doing the work."""
52			def __init__(self):
53			self.settings = {}
54	joko	1.4	self.topics = {}
55	xabbu	1.9	self.modules = FraggleCtlModules.create(self)
56	joko	1.5	self.preferences = fraggleCtlPreferences.create(self)
57			self.rpc = FraggleXMLRPC.create(self, self.preferences.getConfig())
58	joko	1.2
59			def setSetting(self, settingname, value):
60			"""Sets settingname to value in self.settings."""
61			self.settings[settingname] = value
62
63			def getSetting(self, settingname, default=None):
64			"""Returns settingname from self.settings. If not found
65			and default!=None, the default value is return and
66			saved to the settings."""
67			if self.settings.has_key(settingname):
68			return self.settings[settingname]
69			else:
70			if default!=None:
71			self.setSetting(settingname, default)
72			return default
73			else:
74			return None
75	joko	1.4
76	xabbu	1.11	def syncTopics(self):
77			query = "GET * FROM contenttypes"
78			topicData = self.queryCms(query)
79			topictypes = topicData['1']
80
81			for i in topictypes:
82			self.topics[i] = topictypes[i]['1']
83
84			#print self.topics
85	joko	1.4
86			def getTopics(self):
87			return self.topics
88	joko	1.5
89			def getTopicById(self, id):
90			return self.topics[id]
91	xabbu	1.10
92			def listItems(self,topicId):
93			result = self.queryCms("GET creator_id, language_id, description FROM contents")
94	xabbu	1.11	#print result
95	xabbu	1.10
96			def queryCms(self,nqlquery):
97
98			from xmlrpclib import Server,Error
99			rpc = Server('http://netfrag.org/nfo/netfraggle.php')
100	xabbu	1.11	result = rpc.query(nqlquery)
101			if result['0']['error'] == '0':
102			#print result
103			return result
104
105			#else:
106			#print result['0']['error']
107			#return result
108
109	joko	1.7	def query_remote(self, topicmeta):
110	joko	1.2
111	joko	1.6	if topicmeta['target']['type'] == 'XMLRPC':
112			# TODO: make FraggleXMLRPC do all stuff
113			# (call methods dynamically)
114			from xmlrpclib import Server, Error
115			rpc = Server(topicmeta['target']['url'])
116			#try:
117			if topicmeta['result'] == 'item':
118			topicdata = {}
119			try:
120			#topicdata = rpc.getContent('Home')
121			#topicdata = rpc.getContent(tuple(topicmeta['target']['arguments']))
122			topicdata = rpc.getContent(topicmeta['target']['arguments'])
123			#print topicdata
124			except Error, v:
125			print "ERROR", v
126			elif topicmeta['result'] == 'list':
127			topicdata = []
128			try:
129			arg = {'type': 'xmlpage'}
130			topicdata = rpc.listTopics(arg)
131			#print topicdata
132			#self.styledTextContent.SetText(repr(topicdata))
133			except Error, v:
134			print "ERROR", v
135			return topicdata
136	joko	1.8
137			def authenticate(self, server, username, password):
138			from xmlrpclib import Server, Error
139			rpc = Server(server)
140			try:
141			return rpc.authenticate({'user': username, 'pass': password})
142			except Error, v:
143			print "ERROR", v
144
145	xabbu	1.9	def getDefaultDir(self):
146			"""Gets location of default dir and creates it
147			if necessary. ($HOME/.pears/)"""
148			try:
149			import pearsdebug
150			savedir = pearsdebug.savedir
151			except:
152			dir = '.netfraggle'
153			savedir = os.path.expanduser(os.path.join('~', dir))
154			if len(savedir)<=len("c:\\/" + dir):
155			# problem that might occur on Win2k (no $HOME environment variable)
156			temp = os.path.join(os.path.expandvars('$USERPROFILE'), dir)
157			if temp > len("c:\\/" + dir):
158			savedir = temp
159			# create dir if it doesn't exist
160			if not os.path.exists(savedir):
161			os.makedirs(savedir)
162			return savedir
163
164	joko	1.2	class urlOpener(object):
165			"""Opens urls."""
166			def __init__(self):
167			pass
168			def open(self, url="", command=None):
169			"""Opens the url with the method defined in the settings.
170			If command==None, it is retreived from the settings.
171			"""
172			if command==None:
173			command = FraggleEngine().getSetting(BROWSERCOMMAND, BROWSERDEFAULT)
174			if command==BROWSERDEFAULT.strip():
175			# use default opening method
176			import os
177			if os.environ.has_key("BROWSER") and \
178			os.environ["BROWSER"]=='kfmclient openProfile webbrowsing':
179			print "Invalid browser detected : %s\nResetting to konqueror." % os.environ["BROWSER"]
180			os.environ["BROWSER"] = 'konqueror' # set it to konqueror
181			import webbrowser # MUST be imported only AFTER os.environ has been modified
182			webbrowser.open(url, 1)
183			#webbrowser.open_new(url)
184			else: #otherwise use user-defined command line
185			# replase %URL with actual url
186			command = command.replace("%URL", url)
187			import os
188			os.system(command)
189
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26