SF.net SVN: fclient: [230] trunk/sandbox/fcp/fcp2_0_client.py
Status: Pre-Alpha
Brought to you by:
jurner
Menu
▾
▴
SF.net SVN: fclient: [230] trunk/sandbox/fcp/fcp2_0_client.py
|
From: <ju...@us...> - 2008-02-18 13:37:10
|
Revision: 230
http://fclient.svn.sourceforge.net/fclient/?rev=230&view=rev
Author: jurner
Date: 2008-02-18 05:37:05 -0800 (Mon, 18 Feb 2008)
Log Message:
-----------
fix: setDebugVerosity() for all loggers
Modified Paths:
--------------
trunk/sandbox/fcp/fcp2_0_client.py
Modified: trunk/sandbox/fcp/fcp2_0_client.py
===================================================================
--- trunk/sandbox/fcp/fcp2_0_client.py 2008-02-18 13:30:13 UTC (rev 229)
+++ trunk/sandbox/fcp/fcp2_0_client.py 2008-02-18 13:37:05 UTC (rev 230)
@@ -621,7 +621,9 @@
"""Sets the verbosity level of the client
@note: see L{consts.DebugVerbosity}
"""
+ self._logEvent.setLevel(debugVerbosity)
self._logMessage.setLevel(debugVerbosity)
+ self._logRuntime.setLevel(debugVerbosity)
def startFreenet(self, cmdline):
@@ -2315,398 +2317,3 @@
return msg['Identifier']
-#*****************************************************************************
-#
-#*****************************************************************************
-if __name__ == '__main__':
-
- Dir = os.path.dirname(os.path.abspath(__file__))
-
- c = FcpClient(
- connectionName='test',
- debugVerbosity=consts.DebugVerbosity.Debug
- )
-
- fpath = os.path.join(Dir, 'test.log')
- handler = logging.FileHandler(fpath, 'w')
- #formatter = logging.Formatter('%(name)s:%(levelname)s:%(funcName)s:%(message)s')
- #handler.setFormatter(formatter)
- logging.getLogger('Fcp.Client').addHandler(handler)
-
-
- nodeHello = c.connect()
- if nodeHello is not None:
-
-
-
- #for i in xrange(10):
- # c.next()
-
-
- def testGetData():
- def cb(event, request):
- pass
- #print request.data
- #c.modifyRequest(request['Identifier'], persistentUserData='foo')
-
- c.events.RequestCompleted += cb
- c.events.RequestFailed += cb
-
- identifier = c.getData(
- 'CHK@q4~2soHTd9SOINIoXmg~dn7LNUAOYzN1tHNHT3j4c9E,gcVRtoglEhgqN-DJolXPqJ4yX1f~1gBGh89HNWlFMWQ,AAIC--8/snow_002%20%2810%29.jpg',
- persistence=consts.Persistence.Connection,
- #binaryBlob=True,
- )
-
- c.run()
- #for i in xrange(50):
- # c.next()
-
- #c.removeRequest(identifier)
- #for i in xrange(5):
- # c.next()
-
- #testGetData()
-
- def testGetFile():
-
- def cb(event, request):
- c.sendMessage(
- #c.consts.Message.RemovePersistentRequest,
- c.consts.Message.ModifyPersistentRequest,
- Identifier=request['Identifier'],
- PriorityClass=0,
- Global=False,
- )
- pass
-
- filename = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'test.jpg')
- print filename
- identifier = c.getFile(
- 'CHK@q4~2soHTd9SOINIoXmg~dn7LNUAOYzN1tHNHT3j4c9E,gcVRtoglEhgqN-DJolXPqJ4yX1f~1gBGh89HNWlFMWQ,AAIC--8/snow_002%20%2810%29.jpg',
- filename,
- filenameCollision=consts.FilenameCollision.HandleRename,
- #persistence=consts.Persistence.Reboot,
- )
-
- c.events.RequestProgress += cb
-
- #c.run()
- for i in xrange(50):
- c.next()
-
- #c.removeRequest(identifier)
- #for i in xrange(5):
- # c.next()
-
- #testGetFile()
-
-
-
- def testGetKeyInfo():
-
-
-
- identifier = c.getKeyInfo(
- 'CHK@q4~2soHTd9SOINIoXmg~dn7LNUAOYzN1tHNHT3j4c9E,gcVRtoglEhgqN-DJolXPqJ4yX1f~1gBGh89HNWlFMWQ,AAIC--8/snow_002%20%2810%29.jpg',
- #persistence=c.consts.Persistence.Reboot,
- )
-
-
- def cb(event, msg):
- if event == c.events.RequestCompleted:
- pass
- #c.sendMessage(c.consts.Message.GetRequestStatus, Identifier=identifier)
- c.events.RequestCompleted += cb
-
- #for i in xrange(55):
- # c.next()
- #c.removeRequest(identifier)
- #for i in xrange(5):
- # c.next()
- c.run()
-
- #testGetKeyInfo()
-
-
- def testPutRedirect():
-
-
-
-
- def cb(event, msg):
- if event == c.events.RequestCompleted:
-
- identifier = c.putRedirect(
- 'HaHaHa',
- msg['URI']
- )
-
- pass
- #c.sendMessage(c.consts.Message.GetRequestStatus, Identifier=identifier)
- #print msg['FcErrorMessage']
-
-
- c.events.RequestCompleted += cb
- c.events.RequestFailed += cb
-
- #c.chkPutData('HaHaHaHa')
-
- #identifier = c.putRedirect(
- # 'foo',
- # 'USK@zQyF2O1o8B4y40w7Twz8y2I9haW3d2DTlxjTHPu7zc8,h2mhQNNE9aQvF~2yKAmKV1uorr7141-QOroBf5hrlbw,AQACAAE/AnotherIndex/0/',
- #'foo/bar'
- #persistence=c.consts.Persistence.Reboot,
- # )
-
- #c.sendMessage(
- # consts.Message.ClientPut,
- # Identifier='blah',
- # URI='KSK@foo',
- # TargetURI='USK@zQyF2O1o8B4y40w7Twz8y2I9haW3d2DTlxjTHPu7zc8,h2mhQNNE9aQvF~2yKAmKV1uorr7141-QOroBf5hrlbw,AQACAAE/AnotherIndex/0/',
- # UploadFrom='redirect',
- # )
-
- c.chkPutData('arggggggggg!')
-
- #for i in xrange(55):
- # c.next()
- #c.removeRequest(identifier)
- #for i in xrange(5):
- # c.next()
- c.run()
-
- #testPutRedirect()
-
-
-
-
-
- def testChkPutData():
- myIdentifier = c.chkPutData(
- 'test123hahaha',
- #persistence=c.Persistence.Reboot,
- )
-
- c.run()
- #for i in xrange(500):
- # c.next()
- #c.removeRequest(myIdentifier)
- #for i in xrange(5):
- # c.next()
-
- #testChkPutData()
-
-
-
- def testChkPutFile():
- fpath = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'test.jpg')
-
- identifier = c.chkPutFile(
- fpath,
- )
- c.run()
- #for i in xrange(500):
- # c.next()
- #c.removeRequest(identifier)
- #for i in xrange(5):
- # c.next()
-
- #testChkPutFile()
-
-
- def testUskPutData():
- def cb(event, request):
- insertURI = request['FcPrivateKey']
- myIdentifier = c.uskPutData(
- 'foo',
- insertURI + 'foo/0/',
- #persistence=consts.Persistence.Reboot,
- )
- #c.removeRequest(myIdentifier)
-
- c.events.KeypairGenerated += cb
- c.generateKeypair(keypairType=consts.KeyType.USK)
-
- #identifier = c.uskPutData(
- #'foo1',
- #'USK@dkbB9DSr6R2WWs0MFsB9BJvN2cRjNxSboanDQNMJVNc,uIi9-1JrCLZ~6MLa8UrxQCMLptu~PzL59hAtorUIStw,AQECAAE/foo/0/',
- #)
- c.run()
-
- #for i in xrange(700):
- # c.next()
-
- #testUskPutData()
-
-
- def testUskPutData():
- def cb(event, request):
- insertURI = request['FcPrivateKey']
- insertURI = 'USK@AKva7OolWsdAICB8ZE1hDgFqBJigJpYN2edJd6deiApU,dOitAHZSrt27Tl4wK7F-VHVShJVvzR7eNWKsXBolq8k,AQECAAE/'
-
-
- u = c.Upload(consts.KeyType.USK, privateKey=insertURI)
- u.addData('foo/0/', 'data here')
- c.putUpload(u)
-
-
- c.events.KeypairGenerated += cb
- c.generateKeypair(keypairType=consts.KeyType.USK)
-
- #identifier = c.uskPutData(
- #'foo1',
- #'USK@dkbB9DSr6R2WWs0MFsB9BJvN2cRjNxSboanDQNMJVNc,uIi9-1JrCLZ~6MLa8UrxQCMLptu~PzL59hAtorUIStw,AQECAAE/foo/0/',
- #)
- c.run()
-
- #testUskPutData()
-
-
-
- def testConfigData():
-
- from fcp2_0_config import Config
-
- def cb(event, msg):
-
- #print msg['current.fcp.persistentDownloadsInterval']
- #return
- root=Config(configDataMsg=msg)
-
- print
- print '***************************************'
- print '* walking config tree'
- print '***************************************'
- for node in root.walk():
- if node.name is None: # skip root
- continue
- print node.key()
- for valueClass, (value, valueType) in sorted(node.values.items()):
- print ' %s=%r (%s)' % (valueClass, value, valueType)
-
- print
- print '***************************************'
- print '* generating dict from config tree'
- print '***************************************'
- for key, value in root.toMessageParams().items():
- print '%s: %s (%s)' % (key, value, type(value))
-
- #c.setDebugVerbosity(c.DebugVerbosity.Warning)
-
- c.events.ConfigData += cb
- c.getConfig()
- for i in xrange(10):
- c.next()
-
- #testConfigData()
-
-
- #testConfigData()
-
-
- def testModifyConfig():
-
- from fcp2_0_config import Config
-
- def cb(event, msg):
- print msg['current.logger.interval']
- #print msg['current.fcp.persistentDownloadsInterval']
-
- c.setDebugVerbosity(c.consts.DebugVerbosity.Warning)
-
- c.events.ConfigData += cb
- #c.modifyConfig({'fcp.persistentDownloadsInterval': '3000000h'})
-
- c.modifyConfig({'logger.interval': '1'})
-
- for i in xrange(10):
- c.next()
-
- #testModifyConfig()
-
-
-
- def testNodeData():
-
- def cb(event, msg):
- pass
-
-
- c.events.NodeData += cb
- c.getNode()
- for i in xrange(10):
- c.next()
-
- #testNodeData()
-
-
- def testGenerateKeypair():
-
- def cb(event, msg):
- print '--------------------------------'
- print '>>>>privateKey:', msg['FcPrivateKey']
- print '>>>>publicKey:', msg['FcPublicKey']
- pass
-
- c.events.KeypairGenerated += cb
- c.generateKeypair('SSK@')
- c.generateKeypair('USK@')
-
-
- c.run()
- #for i in xrange(10):
- # c.next()
-
- #testGenerateKeypair()
-
-
- def testListPeers():
-
- def peerCb(event, msg):
- c.listPeerNotes(msg['identity'])
-
- c.events.Peer += peerCb
- c.listPeers()
-
-
-
- for i in xrange(50):
- c.next()
-
-
- #testListPeers()
-
- def testGetNode():
- c.getNode()
- for i in xrange(10):
- c.next()
-
- #testGetNode()
-
- def testGetPluginInfo():
- c.getPluginInfo('plugins.XMLLibrarian')
- for i in xrange(10):
- c.next()
-
- #testGetPluginInfo()
-
-
- def testListPeers():
- c.listPeers()
- for i in xrange(30):
- c.next()
-
- #testListPeers()
-
-
- def testSubscribeUSK():
- myIdentifier = c.subscribeUSK('USK@zQyF2O1o8B4y40w7Twz8y2I9haW3d2DTlxjTHPu7zc8,h2mhQNNE9aQvF~2yKAmKV1uorr7141-QOroBf5hrlbw,AQACAAE/AnotherIndex/0/')
- for i in xrange(10):
- c.next()
-
- for i in xrange(10):
- c.next()
-
-
- #testSubscribeUSK()
\ No newline at end of file
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
