[Checkins] SVN: Sandbox/luciano/kirbi/kirbifetch/src/kirbifetch/ working on fetch

[Luciano Ramalho]

Log message for revision 78642:
  working on fetch
  

Changed:
  U   Sandbox/luciano/kirbi/kirbifetch/src/kirbifetch/fetch.py
  U   Sandbox/luciano/kirbi/kirbifetch/src/kirbifetch/tests/dummy_server.py

-=-
Modified: Sandbox/luciano/kirbi/kirbifetch/src/kirbifetch/fetch.py
===================================================================
--- Sandbox/luciano/kirbi/kirbifetch/src/kirbifetch/fetch.py	2007-08-06 20:53:41 UTC (rev 78641)
+++ Sandbox/luciano/kirbi/kirbifetch/src/kirbifetch/fetch.py	2007-08-06 21:06:33 UTC (rev 78642)
@@ -94,8 +94,8 @@
 
 
 if __name__ == '__main__':
-    xmlrpc_url = 'http://localhost:8080/RPC2'
-    poll_method = 'dump_pending_isbns'
+    xmlrpc_url = 'http://localhost:8080/pac'
+    poll_method = 'dump_incomplete_isbns'
     callback = 'add_books'
     fetcher = Fetch(xmlrpc_url, poll_method, callback, AmazonSource())
     reactor.callLater(0, fetcher.poll)

Modified: Sandbox/luciano/kirbi/kirbifetch/src/kirbifetch/tests/dummy_server.py
===================================================================
--- Sandbox/luciano/kirbi/kirbifetch/src/kirbifetch/tests/dummy_server.py	2007-08-06 20:53:41 UTC (rev 78641)
+++ Sandbox/luciano/kirbi/kirbifetch/src/kirbifetch/tests/dummy_server.py	2007-08-06 21:06:33 UTC (rev 78642)
@@ -7,46 +7,50 @@
 PORT = 8080
 
 class Server(object):
-    # pending will behave like an ordered set (no duplicates)
-    pending = []
+    # incomplete will behave like an ordered set (no duplicates)
+    incomplete = []
 
-    def __init__(self, pending = None):
-        if pending is not None:
-            self.pending = pending
+    def __init__(self, incomplete = None):
+        if incomplete is not None:
+            self.incomplete = incomplete
 
-    def add_pending_isbns(self, isbns):
+    def add_incomplete_isbns(self, isbns):
         print 'add%s' % isbns
         added = 0
         for isbn in isbns:
-            if isbn not in self.pending:
-                self.pending.append(isbn)
+            if isbn not in self.incomplete:
+                self.incomplete.append(isbn)
                 added += 1
         return added
     
-    def del_pending_isbns(self, isbns):
+    def del_incomplete_isbns(self, isbns):
         print 'del%s' % isbns
         deleted = 0
         for isbn in isbns:
-            if isbn in self.pending:
-                self.pending.remove(isbn)
+            if isbn in self.incomplete:
+                self.incomplete.remove(isbn)
                 deleted += 1
         return deleted
     
-    def dump_pending_isbns(self, max=0):
-        print 'dump%s' % self.pending
+    def show_incomplete_isbns(self):
+        print 'list%s' % self.incomplete
+        return self.incomplete
+
+    def dump_incomplete_isbns(self, max=0):
+        print 'dump%s' % self.incomplete
         if max == 0:
-            max = len(self.pending)
-        dump = self.pending[:max]
-        self.pending = self.pending[max:]
+            max = len(self.incomplete)
+        dump = self.incomplete[:max]
+        self.incomplete = self.incomplete[max:]
         return dump
-    
-    def show_pending_isbns(self):
-        print 'list%s' % self.pending
-        return self.pending
-    
+        
     def add_books(self, books):
+        print 'added:'
         pprint(books)
         return len(books)
+    
+    def add_error(self, isbn, msg):
+        print 'error(%s): %s' % (isbn, msg)
 
 
 if __name__=='__main__':
@@ -57,11 +61,11 @@
         print '  <n> (optional) max ISBN numbers loaded'
         sys.exit()
         
-    pending = file(sys.argv[1]).read().split()    
+    incomplete = file(sys.argv[1]).read().split()    
     if len(sys.argv) == 3:
-        pending = pending[:int(sys.argv[2])]
+        incomplete = incomplete[:int(sys.argv[2])]
 
-    srv = Server(pending)
+    srv = Server(incomplete)
 
     xmlrpc = SimpleXMLRPCServer(("localhost", PORT))