Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import os
- import psycopg2
- import time
- import praw
- while True:
- reddit = praw.Reddit(username = os.environ['username'],
- password = os.environ['password'],
- client_id = os.environ['client_id'],
- client_secret = os.environ['client_secret'],
- user_agent = os.environ['user_agent'])
- subreddit = reddit.subreddit("Flume")
- submission = reddit.submission(url = os.environ['url'])
- submission.comments.replace_more(limit=None)
- conn = psycopg2.connect(os.environ['DATABASE_URL'], sslmode='require')
- cur = conn.cursor()
- for comment in submission.comments:
- cur.execute("SELECT commentID FROM Comment WHERE commentID = %s;", (str(comment.id),))
- result = cur.fetchall()
- if (len(result) == 0) :
- user = comment.author
- print("New comment, sending link to: " + user.name)
- cur.execute("INSERT INTO Comment VALUES (%s)", (str(comment.id),))
- reddit.redditor(user.name).message("Flume Stream Link", os.environ['dl_link']
- + "\n\nLet me know if this link dies as well. Enjoy!"
- + "\n\n To prevent this link from being taken down easily, please DON'T post it on other subreddits like r/xTrill, I greatly appreciate your help!")
- comment.reply("sent")
- conn.commit()
- cur.close()
- conn.close()
- time.sleep(10)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement