first commit

Author: edzzn

.idea/inspectionProfiles/profiles_settings.xml

@@ -0,0 +1 @@
+# turisbot

.idea/misc.xml

@@ -1,11 +1,68 @@
-import sys
+# Implemented with Bottle
+
+import os
 from wit import Wit
-from fb import getFirstPage
+import requests
+from bottle import Bottle, request, debug, response
+from fb import getDataPage, searchPage
+from random import randrange
+from sys import argv
+
+# Declare some constants
+FB_VERIFY_TOKEN = os.environ['FB_VERIFY_TOKEN']
+# FB_PAGE_ID = os.environ['FB_PAGE_ID']
+FB_ACCESS_TOKEN = os.environ['FB_ACCESS_TOKEN']
+WIT_TOKEN = os.environ['WIT_TOKEN']
+
+# Setup Bottle Server
+debug(True)
+app = Bottle()
+
+
+# Facebook Messenger GET Webhook
+@app.get('/webhook')
+def messenger_webhook():
+    verify_token = request.query.get('hub.verify_token')
+    if verify_token == FB_VERIFY_TOKEN:
+        challenge = response.status = 200
+        challenge = request.query.get('hub.challenge')
+        return challenge
+    else:
+        return 'Invalid Request or Verification Token'
 
-if len(sys.argv) != 2:
-    print('usage: python ' + sys.argv[0] + ' <wit-token>')
-    exit(1)
-access_token = sys.argv[1]
+
+# Facebook Messenger POST Webhook
+@app.post('/webhook')
+def messenger_post():
+    data = request.json
+    print('Data Received')
+    print(data)
+    if data['object'] == 'page':
+        for entry in data['entry']:
+            messages = entry['messaging']
+            if messages[0]:
+                # Get the first message
+                message = messages[0]
+                fb_id = message['sender']['id']
+                text = message['message']['text']
+                client.run_actions(session_id=fb_id, message=text)
+    else:
+        # Returned another event
+        return 'Received Different Event'
+    return None
+
+
+def fb_message(sender_id, text):
+    data = {
+        'recipient': {'id': sender_id},
+        'message': {'text': text}
+    }
+    # prepare query
+    qs = 'access_token=' + FB_ACCESS_TOKEN
+    # send post request to messenger
+    resp = requests.post('https://graph.facebook.com/me/messages?' + qs,
+                         json=data)
+    return resp.content
 
 
 def first_entity_value(entities, entity):
@@ -18,33 +75,63 @@ def first_entity_value(entities, entity):
 
 
 def send(request, response):
-    print(response['text'])
+    # sender function
+    fb_id = request['session_id']
+    text = response['text']
+    print('Fb_di:')
+    print(fb_id)
+    print('text: ')
+    print(response)
+    fb_message(fb_id, text)
 
 
 def merge(request):
+    # get the context, type
     context = request['context']
     entities = request['entities']
+    print('In merge(), context: ' + str(context) +
+          ' entities:' + str(entities))
 
     if 'place' in context:
         del context['place']
     category = first_entity_value(entities, 'category')
     if category:
         context['cat'] = category
+    if 'ack' in context:
+        print(context['ack'])
+        del context['ack']
     return context
 
 
 def select_place(request):
     context = request['context']
-    context['place'] = getFirstPage(context['cat'])
-    return context
+    data = getDataPage(context['cat'])
+    if data is not None:
+        i = randrange(0, len(data) - 1, 1)
+        dataPage = searchPage(data[i]['id'])
+        msj = data[i]['name']
+        if 'street' in dataPage['location']:
+            msj = msj + ", esta en las calles: " + str(dataPage['location']['street'])
+        if 'overall_star_rating' in dataPage:
+            msj = msj + " y tiene un promedio de " + \
+                str(dataPage['overall_star_rating']) + ' estrellas'
+        context['place'] = msj
+        return context
+    else:
+        context['place'] = 'No place found'
+        return context
 
 
+# Setup Actions
 actions = {
     'send': send,
     'merge': merge,
     'select-place': select_place,
 }
 
+# Setup Wit Client
+client = Wit(access_token=WIT_TOKEN, actions=actions)
 
-client = Wit(access_token=access_token, actions=actions)
-client.interactive()
+if __name__ == '__main__':
+    # Run Server
+    app.run(host='0.0.0.0', port=argv[1])

.idea/modules.xml

@@ -1,4 +1,3 @@
-Flask==0.11.1
 Jinja2==2.8
 MarkupSafe==0.23
 Werkzeug==0.11.10