Removes small bug finding duplicates where there is none.

Also removes print statement from data.py

log/bug_tweepy

@@ -0,0 +1,36 @@
+ found, creating
+ElementException :  Cannot create Member, Tweet is not valid !
+No member found, creating
+No member found, creating
+Error: Duplicate members found.
+Error: Duplicate members found.
+No member found, creating
+Error: Duplicate members found.
+Exception in thread Thread-1:
+Traceback (most recent call last):
+  File "/usr/lib/python2.7/threading.py", line 552, in __bootstrap_inner
+    self.run()
+  File "/usr/lib/python2.7/threading.py", line 505, in run
+    self.__target(*self.__args, **self.__kwargs)
+  File "/home/jll/.virtualenvs/twiderboard/local/lib/python2.7/site-packages/tweepy/streaming.py", line 117, in _run
+    self._read_loop(resp)
+  File "/home/jll/.virtualenvs/twiderboard/local/lib/python2.7/site-packages/tweepy/streaming.py", line 150, in _read_loop
+    c = resp.read(1)
+  File "/usr/lib/python2.7/httplib.py", line 541, in read
+    return self._read_chunked(amt)
+  File "/usr/lib/python2.7/httplib.py", line 574, in _read_chunked
+    line = self.fp.readline(_MAXLINE + 1)
+  File "/usr/lib/python2.7/socket.py", line 476, in readline
+    data = self._sock.recv(self._rbufsize)
+  File "/usr/lib/python2.7/ssl.py", line 241, in recv
+    return self.read(buflen)
+  File "/usr/lib/python2.7/ssl.py", line 160, in read
+    return self._sslobj.read(len)
+SSLError: The read operation timed out
+
+^C
+Stopping Streamer
+
+
+--------------------------------
+

twiderboard/data.py

@@ -35,7 +35,6 @@ if oa != 'True':
     oauth = False
 else:
     oauth = True
-print oauth == True
 keys_root = parser.get('keys', 'root')
 oauth_name = parser.get('keys', 'oauth')
 basic_name = parser.get('keys', 'basic')

twiderboard/streamer.py

@@ -54,7 +54,7 @@ class StreamSaverListener(StreamListener):
         # here i should update members now.
         self.update_members(tweet)
 
-        self.cpt += 1
+        #self.cpt += 1
 
         if self.cpt >= 1:
             self.session.commit()  # force saving changes
@@ -87,7 +87,7 @@ class StreamSaverListener(StreamListener):
         m_query = self.session.query(Member).filter(Member.author == auth).filter(Member.hashtag == hasht)
 
         reslen = len(m_query.all())
-        if reslen >= 1:
+        if reslen > 1:
             print "Error: Duplicate members found."
         elif reslen == 0:
             print "No member found, creating"
@@ -106,9 +106,12 @@ class StreamSaverListener(StreamListener):
             member = Member(tweet.author, tweet.hashtag, 1)
             self.session.add(member)
 
+            self.cpt += 1
         else:
-            self.logger.error("ElementException :  Cannot create Member, Tweet is not valid !")
+            #self.logger.error("ElementException :  Cannot create Member, Tweet is not valid !")
-            raise ElementException  # FIXME : Take care
+            print "ElementException :  Cannot create Member, Tweet is not valid !"
+            #raise ElementException  # FIXME : Take care
+            pass
 
     def update_member(self, member):
         """
@@ -119,8 +122,10 @@ class StreamSaverListener(StreamListener):
             member.update()
             self.session.add(member)
 
+            self.cpt += 1
         else:
-            self.logger.error("ElementException :  Cannot update Member, Member is not valid !")
+            #self.logger.error("ElementException :  Cannot update Member, Member is not valid !")
+            print "ElementException :  Cannot update Member, Member is not valid !"
             raise ElementException  # FIXME : Take care