Add http_get notification type and toggle for read_only mailbox
Some checks failed
ci/woodpecker/push/woodpecker Pipeline was successful
ci/woodpecker/manual/woodpecker Pipeline failed

This closes #2
This commit is contained in:
Morgan McMillian 2023-04-01 10:44:37 -07:00
parent 6cf37aebb2
commit ab5c6e7712
2 changed files with 38 additions and 2 deletions

View file

@ -36,7 +36,8 @@ class MailboxNotifier(object):
with IMAPClient(self.mailbox.imap_host) as self.imap: with IMAPClient(self.mailbox.imap_host) as self.imap:
self.imap.login(self.mailbox.imap_user, self.imap.login(self.mailbox.imap_user,
self.mailbox.imap_pass) self.mailbox.imap_pass)
self.imap.select_folder("INBOX", readonly=True) self.imap.select_folder("INBOX",
readonly=self.mailbox.read_only)
self.log.info("Connected to INBOX") self.log.info("Connected to INBOX")
messages = self.imap.search("UNSEEN") messages = self.imap.search("UNSEEN")
if len(messages) > 0: if len(messages) > 0:
@ -114,6 +115,9 @@ class MailboxNotifier(object):
if target.service == "mattermost" and target.enabled: if target.service == "mattermost" and target.enabled:
self.send_mattermost(target.target, text) 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): def send_pushover(self, po_user, text):
notifier = Notifier.get(Notifier.service == "pushover") notifier = Notifier.get(Notifier.service == "pushover")
url = "https://api.pushover.net/1/messages.json" url = "https://api.pushover.net/1/messages.json"
@ -134,6 +138,10 @@ class MailboxNotifier(object):
self.log.debug(response.status_code) self.log.debug(response.status_code)
self.log.debug(response.text) 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): def shutdown_handler(signal, frame):
_shtudown.set() _shtudown.set()

View file

@ -5,7 +5,7 @@ from playhouse.sqlite_ext import SqliteExtDatabase
db = SqliteExtDatabase(None) db = SqliteExtDatabase(None)
migrator = SqliteMigrator(db) migrator = SqliteMigrator(db)
db_schema = "1" db_schema = "2"
class BaseModel(Model): class BaseModel(Model):
class Meta: class Meta:
@ -21,6 +21,7 @@ class Mailbox(BaseModel):
imap_user = CharField() imap_user = CharField()
imap_pass = CharField() imap_pass = CharField()
last_check = DateTimeField(null=True) last_check = DateTimeField(null=True)
read_only = BooleanField(default=True)
class Events(BaseModel): class Events(BaseModel):
user = CharField() user = CharField()
@ -44,3 +45,30 @@ def create_tables():
with db: with db:
if not db.table_exists(System._meta.table_name): if not db.table_exists(System._meta.table_name):
db.create_tables(tables) 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"