Updated cron scripts

1 files changed, 43 insertions, 0 deletions

diff --git a/cron/hourly.py b/cron/hourly.py
new file mode 100644
index 0000000..daf46ec
--- /dev/null
+++ b/cron/hourly.py
@@ -0,0 +1,43 @@
+import os
+import sys
+
+sys.path.insert(1, os.path.join(os.path.dirname(__file__), ".."))
+
+from discord_webhook import DiscordWebhook
+from operator import itemgetter
+import subprocess
+import subreddit
+import database
+import datetime
+
+def dump():
+    subprocess.run(["rm", "-fv", "/tmp/*.sql*"])
+    proc1 = subprocess.Popen(
+        [
+            "mysqldump", subreddit.CONFIG["mysql"]["database"], 
+            "--ignore-table", "SmallYTChannel.log", "--verbose", 
+            "-u", subreddit.CONFIG["mysql"]["user"], 
+            "-h", subreddit.CONFIG["mysql"]["host"], 
+            "-p%s" % subreddit.CONFIG["mysql"]["passwd"]
+        ],
+        stdout = subprocess.PIPE
+    )
+    proc2 = subprocess.Popen("gzip > /tmp/sytc_nolog.sql.gz", shell = True, stdin = proc1.stdout, stdout = subprocess.PIPE)
+    output = proc2.communicate()
+
+def push(fp = "/tmp/sytc_nolog.sql.gz"):
+    webhook = DiscordWebhook(
+        url = subreddit.CONFIG["discord_webhook"],
+        content = "Hourly /u/SmallYTChannelBot database dump from %s" % datetime.datetime.now().astimezone().isoformat()
+    )
+
+    with open(fp, "rb") as f:
+        webhook.add_file(file = f.read(), filename = os.path.split(fp)[-1])
+
+    response = webhook.execute()
+    subreddit.display(str(response))
+
+if __name__ == "__main__":
+    dump()
+    push()
+