update

diff --git a/rainbow.db b/rainbow.db
deleted file mode 100644 (file)
index f440b2b..0000000
Binary files a/rainbow.db and /dev/null differ

diff --git a/rainbowstream/db.py b/rainbowstream/db.py
index 0756b3a5edc9469983ab872e29bd3a2e815b9b1a..e0c7e84b2d2ffe7f160ef8f45c54795e1cace8d8 100644 (file)
--- a/rainbowstream/db.py
+++ b/rainbowstream/db.py
@@ -14,6 +14,9 @@ class RainbowDB():
         self.engine = create_engine('sqlite:///rainbow.db', echo=False)
 
     def store(self, tweet_id):
+        """
+        Store tweet id
+        """
         Session = sessionmaker(bind=self.engine)
         session = Session()
         m = Map(tweet_id)
@@ -21,13 +24,28 @@ class RainbowDB():
         session.commit()
 
     def rainbow_query(self, rid):
+        """
+        Query base of rainbow id
+        """
         Session = sessionmaker(bind=self.engine)
         session = Session()
         res = session.query(Map).filter("rainbow_id =:rid").params(rid=rid).all()
         return res
 
     def tweet_query(self, tid):
+        """
+        Query base of tweet id
+        """
         Session = sessionmaker(bind=self.engine)
         session = Session()
         res = session.query(Map).filter("tweet_id =:tid").params(tid=tid).all()
         return res
+
+    def truncate(self):
+        """
+        Truncate table
+        """
+        Session = sessionmaker(bind=self.engine)
+        session = Session()
+        session.query(Map).delete()
+        session.commit()

diff --git a/rainbowstream/rainbow.py b/rainbowstream/rainbow.py
index 8a03f6f38c5f8105dd160cd132b10e5c39c6c1ec..29cba75f9e5ae70ff551b0bad1822020a413c7d1 100644 (file)
--- a/rainbowstream/rainbow.py
+++ b/rainbowstream/rainbow.py
@@ -304,6 +304,7 @@ def quit():
     """
     Exit all
     """
+    db.truncate() 
     os.kill(g['stream_pid'], signal.SIGKILL)
     sys.exit()
 
@@ -351,6 +352,8 @@ def stream():
 
     # The Logo
     ascii_art()
+    g['stuff'] = '1'
+    home()
     # These arguments are optional:
     stream_args = dict(
         timeout=args.timeout,