-
Notifications
You must be signed in to change notification settings - Fork 1
/
meetupslackers.py
130 lines (115 loc) · 7.81 KB
/
meetupslackers.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
import requests, json, time, csv, logging, os, re
#this isn't very pythonic yet, so chillax: I'm working on getting there :-D
class meetupslackers(object):
def __init__(self):
logging.basicConfig(filename="meetupslackers.log",level=logging.DEBUG)
logging.info("meetupslackers initiated")
self.http_webhook = os.environ['slack_webhook_dev']
self.meetupJson = self.loadMeetup()
self.json_keys = ['name','how_to_find_us','maybe_rsvp_count','headcount','waitlist_count','time','yes_rsvp_count','id','visibility','updated','rsvp_limit','created','description','event_url','utc_offset','status','group','venue']
self.json_group = ['who', 'name', 'group_lat', 'created','join_mode','group_lon', 'urlname', 'id']
self.json_venue = ['city','name','zip','country','lon','state','address_1','repinned','lat','id']
#simple slack message: botname, emoji and message
def create_message(self, botname, emoji, message):
logging.info("create_message")
payload={"username": botname, "icon_emoji": emoji, "text": message}
return payload
#pushes a complicated slack message which includes attachments, could more than likely call the simple message and extend it with finer details to save some code
def create_message_test(self, botname, emoji, message, title, title_link, img_url, color):
logging.info("create_message_test")
payload={"username": botname, "icon_emoji": emoji, "attachments": [ {"fallback": message, "title": title, "title_link": title_link, "image_url": img_url, "text": message, "color": color}]}
return payload
#this is the meetup slack message, formated to look all nice and shit: huge candidate for cleanup
def formatSlackMessage(self, event, botname, emoji, message_add):
logging.info("formatSlackMessage")
spacer = "\t\t"
eventNameLink = "<" + event['event_url'] + "|" + event['name'] + ">"
map = ":pushpin:" + spacer + "<" + "https://www.google.com/maps/dir//" + (event['venue_address_1']).replace(" ", "+") + "+" + (event['venue_city']).replace(" ", "+") + "+" + (event['venue_state']).replace(" ", "+") + "+" + (event['venue_zip']).replace(" ", "+") + "|" + event['venue_name'] + ">"
description = (re.sub('<[^<]+?>', '', (event['description'])))[:144] + "..."
eventTime = time.strftime('%a, %b %d %I:%M %p', time.localtime((event['time']/1000)-25200))
message = description + "\n" + ":loudspeaker:" + spacer + eventTime + "\n:users:" + spacer + ":bust_in_silhouette:" + str(event['yes_rsvp_count']) + " / " + ":busts_in_silhouette: " + str(event['rsvp_limit']) + "\n " + map
color = "#010000"
payload={"username": botname, "icon_emoji": emoji, "attachments": [ {"fallback": message, "title": eventNameLink, "image_url": "", "text": message, "color": color}]}
line_1 = ""
line_2 = ""
line_3 = ""
return payload
#Snags the meetup api info as JSON
def loadMeetup(self):
logging.info("loadMeetup called, opening config.conf")
r = requests.get(os.environ['meetup_api'])
return r.json()
# really really really ugly json parsing, this was a first draft and a candidate for reworking asap
# the basic gist is that it flattens out the json events with the relevant keys we need for the slack announcement
# and then puts the induvidual Json's into a list
# I think a better way to do this is to pull the list of existing keys off of the json and if it doesn't contain the
# list of required keys, then go ahead and add them with defualt null values (add for next version)
def parseJson(self, meetupAPIKeys, group, venue):
logging.info("try_parse_json")
jsonList = []
returnDict = {}
meetupJson = self.meetupJson
for eventCount in range(meetupJson['meta']['count']): #go through all of the events in the meetup
returnDict = {} #clear the event dictionary
for count in range(len(meetupAPIKeys)): #go through all of the important key's we're looking for: if any are missing, populate them with data
try:
if meetupAPIKeys[count] == 'venue': #venue is indented with some special keys, so go through these as well
for venueCount in range(len(venue)):
try:
returnDict['venue_' + venue[venueCount]] = meetupJson['results'][eventCount][meetupAPIKeys[count]][venue[venueCount]]
except:
logging.warning("venue failed for some reason")
returnDict['venue_' + venue[venueCount]] = "empty"
except:
logging.warning(meetupAPIKeys[count] + " failed :-(")
returnDict[meetupAPIKeys[count]] = "VALUE NOT ENTERED"
######This block of code is checking for the specific fields we're looking to format into Slack
######If something is missing then we populate it with some known values so that the slack message
######handler can populate it with something friendly instead of garbage
######Is there a better way to do this???
returnDict['event_url'] = meetupJson['results'][eventCount]['event_url']
returnDict['name'] = meetupJson['results'][eventCount]['name']
returnDict['yes_rsvp_count'] = meetupJson['results'][eventCount]['yes_rsvp_count']
try: #gotta mark events that don't have a time with a special value so they don't get announced
returnDict['description'] = meetupJson['results'][eventCount]['description']
except:
logging.warning("description wasn't found")
returnDict['description'] = "Learn to Code LA presents another learning event!"
try: #gotta mark events that don't have a time with a special value so they don't get announced
returnDict['waitlist_count'] = meetupJson['results'][eventCount]['waitlist_count']
except:
logging.warning("waitlist_count wasn't found")
returnDict['waitlist_count'] = -1
try: #gotta mark events that don't have a time with a special value so they don't get announced
returnDict['duaration'] = meetupJson['results'][eventCount]['duration']
except:
logging.warning("duration wasn't found")
returnDict['duration'] = -1
try: #gotta mark events that don't have a time with a special value so they don't get announced
returnDict['time'] = meetupJson['results'][eventCount]['time']
except:
logging.warning("time wasn't found")
returnDict['time'] = -1
try:
returnDict['rsvp_limit'] = meetupJson['results'][eventCount]['rsvp_limit']
except:
logging.warning("rsvp_limit wasn't found")
returnDict['rsvp_limit'] = ":infinity:" #gotta mark events that don't have a time with a special value so they don't get announced
#try: #gotta mark events that don't have a time with a special value so they don't get announced
# returnDict['json_key'] = meetupJson['results'][eventCount]['json_key']
#except:
# logging.warning("json_key wasn't found")
# returnDict['json_key'] = -1
jsonList.append(returnDict)
return jsonList
##events is a list, message is a test message
def announce(self, events):
#logging.info("announcing events")
botname ="meetup"
emoji = ":meetup:"
message_add = "test"
for count in range(len(events)):
r = requests.post(self.http_webhook, data=json.dumps(self.formatSlackMessage(events[count], botname, emoji, message_add)))
if __name__ == '__main__':
meetupIntegration = meetupslackers()
meetupIntegration.announce(meetupIntegration.parseJson(meetupIntegration.json_keys, meetupIntegration.json_group, meetupIntegration.json_venue))