twitchy.py

import re
import os
import json
import warnings
import HTMLParser
from random import shuffle
from StringIO import StringIO


import praw
import requests
from PIL import Image

from config import username, password, subreddit

def chunker(seq, size):
    return (seq[pos:pos + size] for pos in xrange(0, len(seq), size))

class configuration():
    def __init__(self):
        self.r, self.subreddit = self.reddit_setup()
        self.config = self.get_config()
        self.streams = self.wikipage_check(self.config["wikipages"]["stream_list"])
        self.banned = self.bans()
        self.messages = self.check_inbox()

    def get_config(self):
        try:
            wikipage = self.r.get_wiki_page(self.subreddit,"twitchbot_config")
            settings = wikipage.get_settings()
            if settings["permlevel"] == 0:
                subreddit_settings = self.r.get_settings(subreddit)
                if subreddit_settings["wikimode"] == "anyone":
                    warnings.warn("Your subreddit's wiki pages are set to allow anyone to edit them. Please consider changing this to mod-only on http://www.reddit.com/r/{subreddit}/wiki/settings/twitchbot_config".format(subreddit=subreddit), UserWarning)
            config = wikipage.content_md
            try:
                config = json.loads(config)
            except ValueError:
                print "No JSON object could be found, or the config page has broken JSON.\nUse www.jsonlint.com to validate your wiki config page."
                self.wikilog("No JSON object could be decoded from twitchbot config wiki page.")
                raise
            return HTMLParser.HTMLParser().unescape(config)
        except requests.exceptions.HTTPError:
            print "Couldn't access config wiki page, reddit may be down."
            self.config = {"wikipages":{"error_log":"twitchbot_error_log"}}
            self.wikilog("Couldn't access config wiki page, reddit may be down.")
            raise

    def wikilog(self, error):
        self.r.edit_wiki_page(self.subreddit, self.config["wikipages"]["error_log"], error, error)

    def reddit_setup(self):
        print "Logging in"
        r = praw.Reddit("Sidebar livestream updater for /r/{} by /u/andygmb ".format(subreddit))
        r.login(username=username, password=password, disable_warning=True)
        sub = r.get_subreddit(subreddit)
        return r, sub

    def wikipage_check(self, wikipage):
        try:
            wiki_list = self.r.get_wiki_page(self.subreddit, wikipage).content_md.splitlines()
            results = [item.lower() for item in wiki_list if len(item)]
        except requests.exceptions.HTTPError:
            print "No wikipage found at http://www.reddit.com/r/{}/wiki/{}".format(self.subreddit.display_name, wikipage)
            self.wikilog("Couldn't access wikipage at /wiki/{}/".format(wikipage))
            results = []
        return results

    def check_inbox(self):
        if self.config["accept_messages"].lower() not in ["false", "no", "n"]:
            streams = []
            inbox = self.r.get_inbox()
            print "Checking inbox for new messages"
            for message in inbox:
                if message.new \
                        and message.subject == "Twitch.tv request /r/{}".format(self.subreddit):
                    message_content = message.body.split()[0]
                    try:
                        re_pattern = 'twitch.tv/(\w+)'
                        # pattern matches twitch username in the first group
                        re_result = re.search(re_pattern, message_content)
                        if re_result:
                            stream_name = re_result.group(1).lower()
                        # extract the username stored in regex group 1
                        else:
                            print "Could not find stream name in message."
                            continue # skip to next message
                    except ValueError:
                        message.mark_as_read()
                        stream_name = "null"
                        print "Could not find stream name in message."

                    if "twitch.tv/" in message_content \
                            and len(stream_name) <=25 \
                            and stream_name not in self.banned \
                            and stream_name not in self.streams:
                        streams.append(stream_name)
                        message.reply(self.config["messages"]["success"].format(subreddit=self.subreddit))
                        message.mark_as_read()

                    elif stream_name in self.banned:
                        message.reply(self.config["messages"]["banned"].format(subreddit=self.subreddit))
                        message.mark_as_read()

                    elif stream_name in self.streams:
                        message.reply(self.config["messages"]["already_exists"].format(subreddit=self.subreddit))
                        message.mark_as_read()

            if streams:
                new_streams = list(set([stream for stream in streams if stream not in [self.streams, self.banned]]))
                self.streams.extend(new_streams)
                self.subreddit.edit_wiki_page(
                    self.config["wikipages"]["stream_list"],
                    "\n".join(self.streams),
                    reason="Adding stream(s): " + ", ".join(new_streams)
                )
        else:
            print "Skipping inbox check as accept_messages config is set to False."
            pass

    def update_stylesheet(self):
        print "Uploading thumbnail image(s)"
        try:
            self.subreddit.upload_image("img.png", self.config["image_upload_name"].encode("utf-8"), False)
        except praw.errors.APIException:
            print "Too many images uploaded."
            self.wikilog("Too many images uploaded to the stylesheet, max of 50 images allowed.")
            raise
        stylesheet = self.r.get_stylesheet(self.subreddit)
        stylesheet = HTMLParser.HTMLParser().unescape(stylesheet["stylesheet"])
        self.subreddit.set_stylesheet(stylesheet)

    def update_sidebar(self):
        content = self.r.get_wiki_page(self.subreddit, self.config["wikipages"]["stream_location"]).content_md.encode('utf-8')
        start_marker = self.config["stream_marker_start"].encode("utf-8")
        end_marker = self.config["stream_marker_end"].encode("utf-8")
        try:
            start = content.index(start_marker)
            end = content.index(end_marker) + len(end_marker)
        except ValueError:
            print "Couldn't find the stream markers in /wiki/{}".format(self.config["wikipages"]["stream_location"])
            self.wikilog("Couldn't find the stream markers in /wiki/{}".format(self.config["wikipages"]["stream_location"]))
            raise
        livestreams_string = "".join([stream["stream_output"] for stream in livestreams.streams])
        if content[start:end] != "{}\n\n{}\n\n{}".format(start_marker,livestreams_string,end_marker):
            print "Updating sidebar"
            content = content.replace(
                content[start:end],
                "{}\n\n{}\n\n{}".format(start_marker,livestreams_string,end_marker)
            )
            try:
                self.r.edit_wiki_page(self.subreddit, self.config["wikipages"]["stream_location"], content.decode("utf-8"), reason="Updating livestreams")
            except praw.errors.Forbidden:
                print "Maximum amount of characters (5120) reached. Please consider reducing your sidebars character limit or changing your max_streams_displayed in /wiki/twitchbot_config."
                self.wikilog("Maximum amount of characters (5120) reached. Please consider reducing your sidebars character limit or changing your max_streams_displayed in /wiki/twitchbot_config.")
                raise
            return True
        else:
            print "The stream content is exactly the same as what is already on https://www.reddit.com/r/{}/wiki/{}. Skipping update.".format(self.subreddit, self.config["wikipages"]["stream_location"])
            return False

    def sort_streams(self, streams):
        reverse = False
        if self.config["sort_type"].lower() == "descending":
            reverse = True
        if self.config["sort_type"].lower() == "random":
            shuffle(streams)
            return streams
        if self.config["sort_by"].lower() in ["viewercount", "views", "view", "viewers", "viewer"]:
            return sorted(streams, key=lambda stream:stream["json_data"]["viewers"], reverse=reverse)
        if self.config["sort_by"].lower() == "title":
            return sorted(streams, key=lambda stream:stream["json_data"]["channel"]["status"])
        return streams

    def bans(self):
        banned_streams = self.wikipage_check(self.config["wikipages"]["ban_list"])
        bans = []
        for stream in banned_streams:
            if stream in self.streams[:]:
                bans.append(stream)
                self.streams.remove(stream)
        if bans:
            print "Removing banned stream(s): " + ", ".join(bans)
            self.subreddit.edit_wiki_page(
                self.config["wikipages"]["stream_list"],
                "\n".join(self.streams),
                reason="Removing banned stream(s): " + ", ".join(bans)
            )
        return self.wikipage_check(self.config["wikipages"]["ban_list"])


class livestreams():
    def __init__(self, config):
        self.config = config # This is kind of retarded, should probably subclass or just have the entire bot in one class.
        self.streams = []

    def check_stream_length(self):
        max_streams = int(self.config.config["max_streams_displayed"])
        if len(self.streams) > max_streams:
            self.streams = self.streams[:max_streams]
            print "There are more than {max_stream_count} streams currently \
			- the amount displayed has been reduced to {max_stream_count}. \
			You can increase this in your /wiki/twitchbot_config.".format(max_stream_count=max_streams)
        if len(self.streams):
            self.streams = self.config.sort_streams(self.streams)
            for index, stream in enumerate(self.streams):
                stream["stream_output"] = stream["stream_output"].format(index=index)
            return True
        else:
            self.streams = [{"stream_output":self.config.config["no_streams_string"]}]
            return False

    def get_livestreams(self):
        print "Requesting stream info"
        for chunk in chunker(self.config.streams, 100):
            api_link = "https://api.twitch.tv/kraken/streams?channel="
            for stream in chunk:
                api_link += stream + ","
            try:
                data = requests.get(api_link).json()
                if data["_total"] > 0:
                    self.parse_stream_info(data)
                else:
                    pass
            except:
                pass


    def parse_stream_info(self, data):
        print "Parsing stream info"
        allowed_games = [str(game.lower()) for game in self.config.config["allowed_games"]]
        for streamer in data["streams"]:
            if not len(allowed_games) or streamer["game"].lower() in allowed_games:
                try:
                    title = re.sub(r'[*)(>/#\[\]\\]*', '', streamer["channel"]["status"]).replace("\n", "").encode("utf-8")
                    # Removing characters that can break reddit formatting
                    game = re.sub(r'[*)(>/#\[\]\\]*', '', streamer["game"]).replace("\n", "").encode("utf-8")
                    #Add elipises if title is too long
                    if len(title) >= int(self.config.config["max_title_length"]):
                        title = title[0:int(self.config.config["max_title_length"]) - 3] + "..."
                    name = re.sub(r'[*)(>/#\[\]\\]*', '', streamer["channel"]["name"]).replace("\n", "").encode("utf-8")
                    display_name = re.sub(r'[*)(>/#\[\]\\]*', '', streamer["channel"]["display_name"]).replace("\n", "").encode("utf-8")
                    viewercount = "{:,}".format(streamer["viewers"])
                    self.streams.append({
                        "stream_output":HTMLParser.HTMLParser().unescape(self.config.config["string_format"].encode("utf-8").format(name=name, title=title, viewercount=viewercount, display_name=display_name, game=game, index="{index}")),
                        "json_data":streamer
                    })
                except KeyError:
                    pass

    def create_spritesheet(self):
        print "Creating image spritesheet"
        width, height = (
        int(self.config.config["thumbnail_size"]["width"]),
        int(self.config.config["thumbnail_size"]["height"])
        )
        preview_images = []
        for stream in self.streams:
            url = stream["json_data"]["preview"]["template"]
            preview_data = requests.get(url.format(width=str(width), height=str(height) )).content
            # Download image
            preview_img = Image.open(StringIO(preview_data))
            # Convert to PIL Image
            preview_images.append(preview_img)
        w, h = width, height * (len(preview_images) or 1)
        spritesheet = Image.new("RGB", (w, h))
        xpos = 0
        ypos = 0
        for img in preview_images:
            bbox = (xpos, ypos)
            spritesheet.paste(img,bbox)
            ypos = ypos + height
        path_to_file = os.path.join(os.path.dirname(os.path.realpath(__file__)), "img.png")
        spritesheet.save(path_to_file)


if __name__ == "__main__":
    config = configuration()
    livestreams = livestreams(config)
    livestreams.get_livestreams()
    if livestreams.check_stream_length():
        if livestreams.config.update_sidebar():
            livestreams.create_spritesheet()
            livestreams.config.update_stylesheet()
    else:
        livestreams.config.update_sidebar()