Changeset 2262:458867491ec4 for gozerbot/net/cloud.py

Timestamp:

08/27/08 01:48:08 (4 months ago)

Author:

dunker@…

Branch:

default

Message:

add gozernet/infoitem/+searchdescr to the cloud

Files:

• gozerbot/net/cloud.py (modified) (3 diffs)

gozerbot/net/cloud.py

@@ -38 +38 @@
         return "name=%s url=<%s> seen=%s" % (self.name, self.url, self.regtime)
 
+    def doget(self, mount, cb, *args, **kwargs):
+        self.client = Client(self.url + mount, self.name).addcb(cb)
+        self.client.get()
+
+    def dopost(self, mount, cb, *args, **kwargs):
+        self.client = Client(self.url + mount, self.name).addcb(cb)
+        self.client.post(**kwargs)
+
     def query(self, what, cb):
         if what.startswith('/'):
@@ -56 +64 @@
 self.name).addcb(cb)
         self.client.get()
+
+    def infoitemsearchdescr(self, item, cb):
+        self.client = Client(self.url + 'gozernet/infoitem/+searchdescr/', \
+self.name).addcb(cb)
+        self.client.post(searchitem=item)
 
     def join(self, cb):
@@ -166 +179 @@
         start_new_thread(asyncore.loop, (), {'use_poll': True })
 
+    def doget(self, mount, *args, **kwargs):
+        for url, node in self.nodes.iteritems():
+            node.doget(mount, *args, **kwargs)
+        start_new_thread(asyncore.loop, (), {'use_poll': True })
+
+    def dopost(self, mount, *args, **kwargs):
+        for url, node in self.nodes.iteritems():
+            node.dopost(mount, *args, **kwargs)
+        start_new_thread(asyncore.loop, (), {'use_poll': True })
+
     def getnodes(self):
         result = []