server.py

import os
import time

from apscheduler.schedulers.background import BackgroundScheduler
from flask import Flask, Response, redirect, render_template, request, url_for

import conversation_handler
import database_client
from messenger_client import MessengerClient

# from apscheduler.schedulers.blocking import BlockingScheduler

app = Flask(__name__)

VALIDATION_TOKEN = os.environ['validationToken']


REMINDER_TIME = 90   # should be 2 hours
INTERVAL_TIME = 100  # should be 1 hour

messenger_client = MessengerClient()
database_client = database_client.DatabaseClient()
conversation_handler = conversation_handler.ConversationHandler(database_client)


@app.route('/')
def home():
    return 'ok'


@app.route('/webhook', methods=['GET'])
def verify():
    """Facebook (FB) requests this to validate that we are in control of the app."""
    if request.args.get("hub.mode") == "subscribe" and request.args.get("hub.challenge"):
        if not request.args.get("hub.verify_token") == VALIDATION_TOKEN:
            return "Verification token mismatch", 403
        return request.args["hub.challenge"], 200

    return "Hello world", 200


@app.route('/webhook', methods=['POST'])
def posthook():
    """Hand a FB message.

    This is requested when we receive a message from FB. It includes the FB message data and metadata.
    This is the entry point to our other functions.
    """
    # handles the request and gets us into the current message
    data = request.get_json()

    print('posthook')
    message_text, sender_id = messenger_client.handle_received_data(data)
    name = messenger_client.get_users_name(sender_id)
    user = database_client.find_or_create_user(sender_id, name)

    updated_user, response, quickreply = conversation_handler.determine_response_for_user(message_text, user)
    database_client.update_user(updated_user)
    print('response: ', response)
    if response[:9] == 'SEND_LIST':
        tools_list = database_client.get_all_available_tools()
        messenger_client.send_list(updated_user['sender_id'], tools_list)
    else:
        messenger_client.send_message(updated_user['sender_id'], response, quickreply)

    return "ok", 200


# @sched.scheduled_job('interval', seconds=INTERVAL_TIME)
def check_if_due_and_remind():
    """Remind users of tools that will soon be due.

    Loop through the tools to determine whether they are due
    in the next two hours, and sends the reminder to the user.
    This uses the import time.
    """
    print('beginning check_if_due_and_remind')

    current_time = int(time.time())
    tools_list = database_client.get_all_tools()
    for tool in tools_list:
        print('next tool')
        if tool['current_due_date']:
            print('tool had due date')
            if int(tool['current_due_date']) - current_time <= REMINDER_TIME:
                # emoji in reminder_message is an alarm clock
                reminder_message = '⏰ Hi! The {} is due very soon, could you bring it back to the library please?'.format(tool['name'])
                user_to_remind = database_client.find_user('_id', tool['current_user'])
                messenger_client.send_message(user_to_remind['sender_id'], reminder_message, None)
                print('sent reminder message for {}'.format(tool['_id']))

# TODO: let them say they have returned it, so it stops reminding them


# def timed_job():
#     print('This job is run every three minutes.')

apsched = BackgroundScheduler()
apsched.start()
apsched.add_job(check_if_due_and_remind, 'interval', seconds=INTERVAL_TIME)

if __name__ == '__main__':
    app.run(debug=True, port=int(os.environ.get("PORT", 5000)), host=os.environ.get("HOST", '127.0.0.1'))