FIX Issue #1

daamien · Mar 28, 2015 · 0e0eea9 · 0e0eea9
1 parent a16c089
commit 0e0eea9
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/mailchimpfdw/__init__.py b/mailchimpfdw/__init__.py
@@ -3,6 +3,7 @@
 """
 
 from multicorn import ForeignDataWrapper
+from multicorn.utils import log_to_postgres
 import mailchimp
 
 
@@ -24,6 +25,9 @@ def __init__(self,options,columns):
         self.list_id = the_list['data'][0]['id']
 
         self.columns=columns
+
+        # DEBUG
+        #log_to_postgres("Mailchimp FDW loaded : %s" % __file__) 
 
 
     def execute(self, quals, columns):
@@ -34,7 +38,9 @@ def execute(self, quals, columns):
         # Fetch the members, page by page
         while start_page * self.page_size <= total :
             filters = {'start' : start_page, 'limit': self.page_size} 
-            page=self.chimp.lists.members(self.list_id,'',filters)['data']
+            page =self.chimp.lists.members(self.list_id,'subscribed',filters)['data']
+            page+=self.chimp.lists.members(self.list_id,'cleaned',filters)['data']
+            page+=self.chimp.lists.members(self.list_id,'unsubscribed',filters)['data']
             for member in page:
                 line = {}
                 for column_name in self.columns:

diff --git a/setup.py b/setup.py
@@ -2,7 +2,7 @@
 
 setup(
   name='mailchimpfdw',
-  version='0.1.0',
+  version='0.2.0',
   author='Damien Clochard',
   license='Postgresql',
   packages=['mailchimpfdw']