aboutsummaryrefslogtreecommitdiff
path: root/main.py
diff options
context:
space:
mode:
authorCody Hiar <cody@hiar.ca>2021-02-04 11:26:21 -0700
committerCody Hiar <cody@hiar.ca>2021-02-04 11:26:21 -0700
commitcd518ff1d07800d46812c016f1b73f9a5f2f4313 (patch)
tree749b9592f5d000cececed401f8fcc168db0c7fc5 /main.py
parent5a15eab4a0f930525cb0f7e97daefdd23113c929 (diff)
Add printer script for cleaner formatting
Diffstat (limited to 'main.py')
-rw-r--r--main.py27
1 files changed, 20 insertions, 7 deletions
diff --git a/main.py b/main.py
index f5fd103..6e29c47 100644
--- a/main.py
+++ b/main.py
@@ -14,14 +14,20 @@ def get_slack_client():
return WebClient(token=token)
-def fetch_results():
- """Query slack for the latest results."""
+def get_messages():
+ """Get messages."""
c = get_slack_client()
r = c.search_messages(query="@cody", sort="timestamp")
-
- # Write the results if
if r.data["ok"]:
- messages = r.data["messages"]["matches"]
+ return r.data["messages"]["matches"]
+ else:
+ return []
+
+
+def fetch_results():
+ """Query slack for the latest results."""
+ messages = get_messages()
+ if messages:
write_to_database(messages)
print("Archival Complete.")
else:
@@ -34,7 +40,13 @@ def write_to_database(messages):
for msg in messages:
username = msg["username"]
timestamp = datetime.fromtimestamp(int(msg["ts"].split(".")[0]))
- if session.query(Message).filter(Message.username == username).filter(Message.timestamp == timestamp).count() != 0:
+ if (
+ session.query(Message)
+ .filter(Message.username == username)
+ .filter(Message.timestamp == timestamp)
+ .count()
+ != 0
+ ):
continue
print("New notification")
session.add(
@@ -49,4 +61,5 @@ def write_to_database(messages):
session.commit()
-fetch_results()
+if __name__ == "__main__":
+ fetch_results()