Agfdhyk

I currently have a reddit bot that receives keywords from a subreddit and then sends me a notification on Slack.

The current code for sending me the notification is

for kw in keywords:

                if kw.lower() in comment.body.lower():  # case insensitive check

                    already_alerted_submissions.append(comment.submission.id)

                    msg = '[Keyword *{0}* detected](http://www.reddit.com{1})'.format(

                        kw, comment.permalink)

                    slack_data = {'text': msg, 'mrkdwn': True}

So it is currently getting a list of keywords from

keywords = ['camera', 'nikon', 'canon', 'campus']  # case insensitive

I was wondering if it was possible to have two separate keyword lists in the file such as the following

keywords = ['camera', 'nikon', 'canon', 'campus']  # case insensitive

keywords_color = ['red', 'blue', 'green', 'black']  # case insensitive

And if the word "camera" was detected in a thread, it would post a message just like it does currently.

But if in the same comment, it detected a keyword from both
keywords AND and keywords_color

It could post the same message in slack but with another line saying something similar to "Color was detected"

So in the examples above the message in slack would look like the following.

1. [Keyword *camera* detected]

(http://www.reddit.com/r/camera/comments/9yg8mt/goodcameras

I just got a great CAMERA today, it is awesome

Or if it detected both "keywords" and "keywords_color" it would look like the following

2. 1. [Keyword *camera* detected]

(http://www.reddit.com/r/camera/comments/9yg8mt/goodcameras

I just got a great CAMERA today, it is a RED one and its awesome

**Colour was detected**

Would this be possible? any help would be appreciated!

The full scrip for the file is here:

def main():



    alerted_comments = get_list_from_pickle('alerted_comments.pickle')



    try:



        for comment in comment_stream:

            if comment.id in alerted_comments:

                continue



            if comment.author:  # if comment author hasn't deleted

                if comment.author.name in ignore_users:

                    continue



            for kw in keywords:

                if kw.lower() in comment.body.lower():  # case insensitive check

                    alerted_comments.append(comment.id)



                    while len(alerted_comments) > 100:

                        del alerted_comments[0]



                    with open('alerted_comments.pickle', 'wb') as fp:

                        pickle.dump(alerted_comments, fp)



            for kw in keywords:

                if kw.lower() in comment.body.lower():  # case insensitive check

                    alerted_comments.append(comment.submission.id)

                    msg = '[Keyword *{0}* detected](http://www.reddit.com{1})'.format(

                        kw, comment.permalink)

                    slack_data = {'text': msg, 'mrkdwn': True}



                    response = requests.post('https://hooks.slack.com/services/BE72P09A9/xxxxxxxxx78',

                                             data=json.dumps(slack_data), headers={'Content-Type': 'application/json'})

                    if response.status_code != 200:

                        raise ValueError('Request to slack returned an error %s, the response is:n%s' % (

                            response.status_code, response.text))



    except Exception as e:

        print('There was an error: ' + str(e))

        sleep(60)  # wait for 60 seconds before restarting

        main()



if __name__ == '__main__':

    main()

This is untested, but here you go:

import json

import time



import requests





class SlackError(Exception):

    # This isn't quite how I would handle this, so for now it's

    # just a hint of more to learn.

    pass





MSG_TEMPLATE = """[Keyword *{keyword}* detected]

(https://www.reddit.com{permalink})

{comment_body}"""



SLACK_WEBHOOK = 'https://hooks.slack.com/services/BE72P09A9/xxxxxxxxx78'





def main(*, save_path):

    keywords = ...

    color_keywords = ...

    ignore_users = ...



    comment_stream = ...



    with open(save_path, 'r') as fp:

        alerted_comments = json.load(fp)



    for comment in comment_stream:

        if comment.id in alerted_comments:

            continue



        if comment.author:  # if comment author hasn't deleted

            if comment.author.name in ignore_users:

                continue



        if any(kw.lower() in comment.body.lower() for kw in keywords):

            found_kws = [kw for kw in keywords if kw.lower() in comment.body.lower()]



            msg = MSG_TEMPLATE.format(

                keyword=found_kws[0],

                permalink=permalink,

                comment_body=comment.body

            )



            if any(kw.lower() in comment.body.lower() for kw in color_keywords):

                msg += "nColour was detected"



            slack_data = {'text': msg, 'mrkdwn': True}



            response = requests.post(

                SLACK_WEBHOOK,

                data=json.dumps(slack_data),

                headers={'Content-Type': 'application/json'}

            )



            if response.status_code == 200:

                # Moving this here so you don't miss a comment

                # because of an error. It does mean other errors

                # could potentially cause a repeat message. There

                # are ways to handle that.



                alerted_comments.append(comment.id)



                if len(alerted_comments) > 100:

                    alerted_comments = alerted_comments[-100:]



                with open(save_path, 'w') as fp:

                    json.dump(alerted_comments, fp)

            else:

                # You'll probably want to be more discerning than "not 200",

                # but that's fine for now.

                raise SlackError(

                    'Request to Slack returned an error %s, the response is:n%s' % (

                        response.status_code, response.text))



if __name__ == '__main__':

    while True:

        try:

            main(save_path='alerted_comments.json')

        except Exception as e:

            print('There was an error: {}'.format(str(e)))

            time.sleep(60)  # wait for 60 seconds before restarting

Let me know if you have any questions.