-
Notifications
You must be signed in to change notification settings - Fork 6
/
bot.rb
178 lines (159 loc) · 4.54 KB
/
bot.rb
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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
require 'facebook/messenger'
require 'httparty'
require 'json'
include Facebook::Messenger
# NOTE: ENV variables should be set directly in terminal for localhost
# IMPORTANT! Subcribe your bot to your page
Facebook::Messenger::Subscriptions.subscribe(access_token: ENV['ACCESS_TOKEN'])
API_URL = 'https://maps.googleapis.com/maps/api/geocode/json?address='.freeze
IDIOMS = {
not_found: 'There were no resutls. Ask me again, please',
ask_location: 'Enter destination',
unknown_command: 'Sorry, I did not recognize your command',
menu_greeting: 'What do you want to look up?'
}.freeze
MENU_REPLIES = [
{
content_type: 'text',
title: 'Coordinates',
payload: 'COORDINATES'
},
{
content_type: 'text',
title: 'Full address',
payload: 'FULL_ADDRESS'
}
]
# Set call to action button when user is about to address bot
# for the first time.
Facebook::Messenger::Thread.set({
setting_type: 'call_to_actions',
thread_state: 'new_thread',
call_to_actions: [
{
payload: 'START'
}
]
}, access_token: ENV['ACCESS_TOKEN'])
# Create persistent menu
Facebook::Messenger::Thread.set({
setting_type: 'call_to_actions',
thread_state: 'existing_thread',
call_to_actions: [
{
type: 'postback',
title: 'Get coordinates',
payload: 'COORDINATES'
},
{
type: 'postback',
title: 'Get full address',
payload: 'FULL_ADDRESS'
}
]
}, access_token: ENV['ACCESS_TOKEN'])
# Set greeting (for first contact)
Facebook::Messenger::Thread.set({
setting_type: 'greeting',
greeting: {
text: 'Coordinator welcomes you!'
},
}, access_token: ENV['ACCESS_TOKEN'])
# Logic for postbacks
Bot.on :postback do |postback|
sender_id = postback.sender['id']
case postback.payload
when 'START' then show_replies_menu(postback.sender['id'], MENU_REPLIES)
when 'COORDINATES'
say(sender_id, IDIOMS[:ask_location])
show_coordinates(sender_id)
when 'FULL_ADDRESS'
say(sender_id, IDIOMS[:ask_location])
show_full_address(sender_id)
end
end
# Logic for quick replies and text commands
def wait_for_command
Bot.on :message do |message|
puts "Received '#{message.inspect}' from #{message.sender}" # debug only
sender_id = message.sender['id']
case message.text
when /coord/i, /gps/i
message.reply(text: IDIOMS[:ask_location])
show_coordinates(sender_id)
when /full ad/i # we got the user even the address is misspelled
message.reply(text: IDIOMS[:ask_location])
show_full_address(sender_id)
else
message.reply(text: IDIOMS[:unknown_command])
show_replies_menu(sender_id, MENU_REPLIES)
end
end
end
# Start conversation loop
def wait_for_any_input
Bot.on :message do |message|
show_replies_menu(message.sender['id'], MENU_REPLIES)
end
end
# helper function to send messages declaratively and directly
def say(recipient_id, text, quick_replies = nil)
message_options = {
recipient: { id: recipient_id },
message: { text: text }
}
if quick_replies
message_options[:message][:quick_replies] = quick_replies
end
Bot.deliver(message_options, access_token: ENV['ACCESS_TOKEN'])
end
# Display a set of quick replies that serves as a menu
def show_replies_menu(id, quick_replies)
say(id, IDIOMS[:menu_greeting], quick_replies)
wait_for_command
end
# Coordinates lookup
def show_coordinates(id)
handle_api_request do |api_response|
coord = extract_coordinates(api_response)
text = "Latitude: #{coord['lat']} / Longitude: #{coord['lng']}"
say(id, text)
end
end
# Full address lookup
def show_full_address(id)
handle_api_request do |api_response|
full_address = extract_full_address(api_response)
say(id, full_address)
end
end
# DRY out replicate code in both actions
def handle_api_request
Bot.on :message do |message|
parsed_response = get_parsed_response(API_URL, message.text)
message.type # let user know we're doing something
if parsed_response
yield(parsed_response, message)
wait_for_any_input
else
message.reply(text: IDIOMS[:not_found])
# meta-programming voodoo to call the callee
callee = Proc.new { caller_locations.first.label }
callee.call
end
end
end
# Talk to API
def get_parsed_response(url, query)
response = HTTParty.get(url + query)
parsed = JSON.parse(response.body)
parsed['status'] != 'ZERO_RESULTS' ? parsed : nil
end
def extract_coordinates(parsed)
parsed['results'].first['geometry']['location']
end
def extract_full_address(parsed)
parsed['results'].first['formatted_address']
end
# launch the loop
wait_for_any_input