clacksme/clacksme.py

@@ -4,7 +4,6 @@ import logging
 import signal
 import requests
 
-from requests.exceptions import ConnectionError
 from multiprocessing import Process, Event, Queue
 from logging.handlers import QueueHandler
 from imapclient import IMAPClient, exceptions
@@ -36,8 +35,7 @@ class MailboxNotifier(object):
                 with IMAPClient(self.mailbox.imap_host) as self.imap:
                     self.imap.login(self.mailbox.imap_user, 
                         self.mailbox.imap_pass)
-                    self.imap.select_folder("INBOX",
-                        readonly=self.mailbox.read_only)
+                    self.imap.select_folder("INBOX", readonly=True)
                     self.log.info("Connected to INBOX")
                     messages = self.imap.search("UNSEEN")
                     if len(messages) > 0:
@@ -115,9 +113,6 @@ class MailboxNotifier(object):
             if target.service == "mattermost" and target.enabled:
                 self.send_mattermost(target.target, text)
 
-            if target.service == "http_get" and target.enabled:
-                self.send_http_get(target.target)
-
     def send_pushover(self, po_user, text):
         notifier = Notifier.get(Notifier.service == "pushover")
         url = "https://api.pushover.net/1/messages.json"
@@ -138,15 +133,11 @@ class MailboxNotifier(object):
         self.log.debug(response.status_code)
         self.log.debug(response.text)
 
-    def send_http_get(self, url):
-        response = requests.get(url)
-        self.log.debug(response.status_code)
-        self.log.debug(response.text)
 
 def shutdown_handler(signal, frame):
     _shtudown.set()
 
-def logger_thread(log_queue, url):
+def logger_thread(log_queue):
     logging.debug("starting logger thread")
     while True:
         entry = log_queue.get()
@@ -155,12 +146,6 @@ def logger_thread(log_queue, url):
             break
         logger = logging.getLogger(entry.name)
         logger.handle(entry)
-        if url is not None:
-            try:
-                r = requests.get(url)
-
-            except ConnectionError:
-                pass
 
 def event_thread(event_queue):
     logging.debug("starting event thread")
@@ -192,8 +177,6 @@ def main():
     db.init(args.store, pragmas={'journal_mode': 'wal'})
     create_tables()
 
-    monitor_url = System.get_or_none(System.key == "monitor_url")
-
     log_queue = Queue()
     event_queue = Queue()
     processes = []
@@ -208,8 +191,7 @@ def main():
 
     logging.basicConfig(level=logging.DEBUG)
     logging.debug("starting up main")
-    log_thread = threading.Thread(target=logger_thread, 
-        args=(log_queue,monitor_url.value,))
+    log_thread = threading.Thread(target=logger_thread, args=(log_queue,))
     log_thread.start()
     e_thread = threading.Thread(target=event_thread, args=(event_queue,))
     e_thread.start()

clacksme/model.py

@@ -5,7 +5,7 @@ from playhouse.sqlite_ext import SqliteExtDatabase
 db = SqliteExtDatabase(None)
 migrator = SqliteMigrator(db)
 
-db_schema = "2"
+db_schema = "1"
 
 class BaseModel(Model):
     class Meta:
@@ -21,7 +21,6 @@ class Mailbox(BaseModel):
     imap_user = CharField()
     imap_pass = CharField()
     last_check = DateTimeField(null=True)
-    read_only = BooleanField(default=True)
 
 class Events(BaseModel):
     user = CharField()
@@ -45,30 +44,3 @@ def create_tables():
     with db:
         if not db.table_exists(System._meta.table_name):
             db.create_tables(tables)
-            System.replace(key="schema", value=db_schema).execute()
-
-        else:
-            schema_ver = System.get_or_none(key="schema")
-            migrate_tables(schema_ver)
-
-def migrate_tables(schema_ver):
-    if schema_ver is None or schema_ver.value == "1":
-        schema_ver = migrate_v2()
-
-    # if schema_ver == "2":
-    #     schema_ver = migrate_v3()
-
-    System.replace(key="schema", value=db_schema).execute()
-
-def migrate_v2():
-    # migration to schema version 2
-    read_only = BooleanField(default=True)
-    migrate(
-        migrator.add_column(
-            Mailbox._meta.table_name, 'read_only', read_only),
-    )
-    return "2"
-
-# def migrate_v3():
-#     # migration to schema version 3
-#     return "3"