server.py

from datetime import date, datetime
from flask import Flask, jsonify, request, Response, send_file, send_from_directory
from flask_socketio import SocketIO
from firehose import Firehose
from scrapers.search_requests import Requests as Scraper
from time import sleep

import json
import os

'''
Configure Flask app.
'''
app = Flask(__name__, static_url_path='')
firehose = Firehose()
firehose.start()

server_queue = []
socketio = SocketIO(app)
print('CLASSIFIER TRAINING')

MAX_TWEETS_ON_SCREEN = 10

'''
Confirm socket connection to the client.
'''
@socketio.on('connect', namespace='/stream')
def client_connect():
    print('Connected to /stream')

'''
Listen to and process inputs.
'''
@socketio.on('inputs', namespace='/stream')
def handle_inputs(data):
    firehose.set_options(data)
    global server_queue
    del server_queue[:]
    socketio.emit('data', {'data': []}, namespace='/stream')

'''
Stream outputs to the client.
'''
@socketio.on('more', namespace='/stream')
def more_data():
    global server_queue
    tweets = firehose.get_tweets()

    server_queue = tweets + server_queue
    socketio.emit('data', {'data': server_queue}, namespace='/stream')
    if len(server_queue) > MAX_TWEETS_ON_SCREEN:
        del server_queue[-1:]

'''
Serve homepage and related assets.
'''
@app.route('/')
def root():
    print('FETCH ROOT')
    return send_file('index.html')

@app.route('/js/<path:path>')
def js(path):
    return send_from_directory('js', path)

@app.route('/css/<path:path>')
def css(path):
    return send_from_directory('css', path)

if __name__ == '__main__':
    print('APP STARTED')
    socketio.run(app)