Changeset 2262:458867491ec4

Timestamp:

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

Author:

dunker@…

Branch:

default

Message:

add gozernet/infoitem/+searchdescr to the cloud

Files:

• gozerbot/net/cloud.py (modified) (3 diffs)
• gozerplugs/plugs/cloud.py (modified) (2 diffs)
• gozerplugs/plugs/infoitem.py (modified) (1 diff)

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 = []

gozerplugs/plugs/cloud.py

@@ -76 +76 @@
         return dumps(info.get(input))
 
+def infoitemsearchdescr_POST(server, request):
+    try:
+        input = getpostdata(request)
+        what = input['searchitem']
+    except KeyError:
+        rlog(10, request.host, 'no searchitem provided')
+        return dumps('no searchitem provided')
+    return dumps(info.searchdescr(what))
+
 def init():
     """ init the cloud plugin """
@@ -90 +99 @@
                 server.addhandler('/gozernet/nodes/', 'GET', nodes_GET)
                 server.addhandler('/gozernet/infoitem/', 'GET', infoitem_GET)
+                server.addhandler('/gozernet/infoitem/+searchdescr', 'POST', \
+infoitemsearchdescr_POST)
                 server.addhandler('/gozernet/+auth/', 'POST', auth_POST)
                 server.addhandler('/gozernet/+ping/', 'GET', ping_GET)

gozerplugs/plugs/infoitem.py

@@ -279 +279 @@
         what = ievent.rest
     what = what.strip().lower()
+    if cloud.enabled:
+        def cb(client, request):
+            if request.error:
+                ievent.reply("%s: %s" % (client.host, request.error))
+            if request.data:
+                res = []
+                for result in request.data:
+                    res.append("[%s] %s" % (result[0], result[1]))
+                ievent.reply("%s: " % client.host, res, dot=True)
+        cloud.dopost('gozernet/infoitem/+searchdescr', cb, searchitem=what)
+        return
     result = info.searchdescr(what)
     if result: