--- nfo/projects/netfraggle/bin/fraggleEngine.py 2004/08/25 22:47:28 1.2 +++ nfo/projects/netfraggle/bin/fraggleEngine.py 2004/08/31 16:48:19 1.8 @@ -1,31 +1,50 @@ -#!/usr/bin/env python +#----------------------------------------------------------------------------- +# Name: fraggleEngine.py +# Purpose: Does the main (non-gui) work +# +# Author: joko +# +# Created: 2004/30/08 +# RCS-ID: $Id: fraggleEngine.py,v 1.8 2004/08/31 16:48:19 joko Exp $ +# Copyright: (c) 2004 netfrag.org +# Licence: GPL +#----------------------------------------------------------------------------- + +#----------------------------------------------------------------------------- +# $Log: fraggleEngine.py,v $ +# 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 class FraggleEngine: """Back-end doing the work.""" def __init__(self): self.settings = {} - - 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 + self.topics = {} + 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.""" @@ -44,7 +63,114 @@ else: return None - + def fraggleSync(self): + + # v1 - demo + self.topics = [ + { + 'name': 'iNFO-Page:Test-ViaXMLRPC', + 'mode': 'pull', + 'result': 'item', + 'target': { + 'url': 'http://netfrag.org/nfo/netfraggle.php', + 'method': 'nfo.getContent', + 'arguments': 'Test', + 'type': 'XMLRPC', + } + }, + { + 'name': 'iNFO-Page:Home-ViaXMLRPC', + 'mode': 'pull', + 'result': 'item', + 'target': { + 'url': 'http://netfrag.org/nfo/netfraggle.php', + 'method': 'nfo.getContent', + 'arguments': 'Home', + 'type': 'XMLRPC', + } + }, + { + 'name': 'iNFO-PageIndex', + 'mode': 'pull', + 'result': 'list', + 'target': { + 'url': 'http://netfrag.org/nfo/netfraggle.php', + 'method': 'nfo.listTopics', + 'arguments': ['xmlpage'], + 'type': 'XMLRPC', + } + }, + { + 'name': 'TWiki-Test-ViaTWiki', + 'mode': 'push', + 'target': { + 'url': 'http://netfrag.org/twiki/bin/view/Main/NetFraggleTest', + 'type': 'TWiki', + } + }, + { + 'name': 'TWiki-Test-ViaXMLRPC', + 'mode': 'push', + 'target': { + 'method': 'appendToPage', + 'arguments': ['NetFraggleTest'], + 'type': 'XMLRPC', + } + }, + ] + return + + # v2 - live + + # 1. load payload from remote side + fragglexml = self.rpc.FraggleSync() + + # 2. (todo) unmarshal to self.topics (hash) + # self.topics = unmarshal(fragglexml) + + def getTopics(self): + return self.topics + + def getTopicById(self, id): + return self.topics[id] + + 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 + + class urlOpener(object): """Opens urls.""" def __init__(self):