Whoops, don't run the program to delete things by default. Also use t…

…able listen, not listens.

config.py.sample

@@ -14,7 +14,7 @@ TEST_SQLALCHEMY_DATABASE_URI = "postgresql://lb_test@/lb_test"
 
 # Other postgres configuration options
 # Oldest listens which can be stored in the database, in days.
-MAX_POSTGRES_LISTEN_HISTORY = "90"
+MAX_POSTGRES_LISTEN_HISTORY = "-1"
 # Log Postgres queries if they execeed this time, in milliseconds.
 PG_QUERY_TIMEOUT = "3000"
 # Disable synchronous_commit to OFF for Postgres. Default: False

webserver/scheduler.py

@@ -32,6 +32,11 @@ def _clean_postgres(self, max_days=90):
         """ Clean all the listens that are older than a set no of days
             Default: 90 days
         """
+
+        # If max days is set to a negative number, don't throw anything out
+        if max_days < 0:
+            return
+
         seconds = max_days*24*3600
         engine = create_engine(self.conf['SQLALCHEMY_DATABASE_URI'], poolclass=NullPool)
         connection = engine.connect()
@@ -49,9 +54,9 @@ def _clean_postgres(self, max_days=90):
         #         """
 
         query = """
-                DELETE FROM listens
+                DELETE FROM listen
                 WHERE id in (
-                    SELECT id FROM listens
+                    SELECT id FROM listen
                     JOIN (
                         SELECT user_id, extract(epoch from max(ts)) as max
                         FROM listens