import json

import os

import os.path

import base64

import logging

import logging.handlers

from flask import Flask

from flask_bootstrap import Bootstrap

config_file = os.path.abspath('config.json')

bootstrap = Bootstrap()

logging_debug_string = ('%(levelname)s:%(name)s:%(asctime)s:%(filename)s'

                        ':%(lineno)d: %(message)s')

logging_string = '%(levelname)s - %(name)s - %(asctime)s - %(message)s'

logging_debug_formatter = logging.Formatter(logging_debug_string)

logging_formatter = logging.Formatter(logging_string)

def create_app():

    app = Flask(__name__)

    _default_secret_key = base64.b64encode(os.urandom(32)).decode('utf-8')

    app.config['SECRET_KEY'] = os.environ.get('SECRET_KEY',

                                              _default_secret_key)

    if not hasattr(app.config, 'from_json'):

        def from_json(file, silent=True):

            try:

                with open(file, encoding='utf-8') as json_file:

                    obj = json.load(json_file)

            except IOError:

                if silent:

                    return False

                raise

            for key in obj:

                if key.isupper():

                    app.config[key] = obj[key]

            return True

        app.config.from_json = from_json

    app.config.from_json(config_file, silent=True)

    app.config.setdefault('BOOTSTRAP_SERVE_LOCAL', True)

    bootstrap.init_app(app)

    app.logger.setLevel(logging.DEBUG)

    stream_handler = logging.StreamHandler()

    stream_handler.setLevel(logging.DEBUG)

    stream_handler.setFormatter(logging_debug_formatter)

    if not os.path.exists('spaceapi.log'):

        open('spaceapi.log', mode='a').close()

    rotating_file_handler = logging.handlers.RotatingFileHandler(

        'spaceapi.log',

        maxBytes=1300000,

        backupCount=10,

        encoding='utf-8')

    rotating_file_handler.setLevel(logging.INFO)

    rotating_file_handler.setFormatter(logging_formatter)

    if app.debug or ('ENABLE_DEBUG_LOG' in app.config and

                     app.config['ENABLE_DEBUG_LOG']):

        if not os.path.exists('spaceapi_debug.log'):

            open('spaceapi_debug.log', mode='a').close()

        second_rotating_file_handler = logging.handlers.RotatingFileHandler(

            'spaceapi_debug.log',

            maxBytes=1300000,

            backupCount=20,

            encoding='utf-8')

        second_rotating_file_handler.setLevel(logging.DEBUG)

        second_rotating_file_handler.setFormatter(logging_debug_formatter)

        app.logger.addHandler(second_rotating_file_handler)

    app.logger.addHandler(stream_handler)

    app.logger.addHandler(rotating_file_handler)

    @app.after_request

    def add_headers(response):

        response.headers.setdefault('Access-Control-Allow-Origin', '*')

        response.headers.setdefault('Cache-Control', 'no-cache')

        return response

    from .views import root_views

    app.register_blueprint(root_views)

    from .state import state_views

    app.register_blueprint(state_views, url_prefix='/state')

    from .sensors import sensors_views

    app.register_blueprint(sensors_views, url_prefix='/sensors')

    ActiveStatus().reload()

    return app

import json

import os.path

from time import time

import random

from functools import wraps

from flask import request, current_app

import tweepy

default_json_file = os.path.abspath('default.json')

last_state_file = os.path.abspath('laststate.json')

if not os.path.exists(default_json_file):

    raise RuntimeError('default.json does not exists!')

elif not os.path.isfile(default_json_file):

    raise RuntimeError('default.json is not a file!')

possible_open_tweets = (

    'The space is now open!',

    'The space is open! Come in and hack something!',

    'Yes, we\'re open! Come in and create something!',

    'Come by and hack something! We\'ve just opened!',

    'The ChaosStuff is now open for everyone!',

)

possible_closed_tweets = (

    'The space is now closed!',

    'We\'re closed now! See you soon.',

    'Sorry, we are closed now!',

    'The ChaosStuff is now closed! Come back another time!',

    'Poweroff process finished! We\'re closed!',

)

def post_tweet(tweet, spaceapi=None):

    if 'TWITTER_CONSUMER_KEY' in current_app.config:

        auth = tweepy.OAuthHandler(

            current_app.config['TWITTER_CONSUMER_KEY'],

            current_app.config['TWITTER_CONSUMER_SECRET']

        )

        auth.set_access_token(

            current_app.config['TWITTER_ACCESS_TOKEN_KEY'],

            current_app.config['TWITTER_ACCESS_TOKEN_SECRET']

        )

        api = tweepy.API(auth)

        if spaceapi is None:

            api.update_status(tweet)

        else:

            api.update_status(tweet, lat=spaceapi['location']['lat'], lon=spaceapi['location']['lon'])

class Singleton:

    def __new__(cls, *args, **kwargs):

        key = str(hash(cls))

        if not hasattr(cls, '_instance_dict'):

            cls._instance_dict = {}

        if key not in cls._instance_dict:

            cls._instance_dict[key] = super().__new__(cls, *args, **kwargs)

        return cls._instance_dict[key]

class ActiveStatus(Singleton, dict):

    def reload(self):

            self.update(json.load(f))

                last_state_json = json.load(f)

            self['state'] = last_state_json['state']

            self['sensors'].update(last_state_json['sensors'])

    def save_last_state(self):

            last_state = {}

            last_state['state'] = self['state']

            last_state['sensors'] = self['sensors']

            json.dump(last_state, f, sort_keys=True)

    def add_user_present(self, username):

        if self['state']['open']:

            if 'people_now_present' not in self['sensors']:

                self['sensors']['people_now_present'] = [{'value': 0}]

            people_now_present = self['sensors']['people_now_present'][0]

            if 'names' in people_now_present and username not in people_now_present['names']:

                people_now_present['value'] += 1

                if username in current_app.config['PEOPLE_NOW_PRESENT_ALLOWED']:

                    people_now_present['names'].append(username)

            elif 'names' not in people_now_present:

                people_now_present['value'] += 1

                if username in current_app.config['PEOPLE_NOW_PRESENT_ALLOWED']:

                    people_now_present['names'] = [username]

            self['sensors']['people_now_present'][0] = people_now_present

        else:

            pass

    def remove_user_present(self, username):

        if self['state']['open'] and 'people_now_present' in self['sensors']:

            people_now_present = self['sensors']['people_now_present'][0]

            if people_now_present['value'] > 0:

                people_now_present['value'] -= 1

            if 'names' in people_now_present:

                if username in people_now_present['names']:

                    people_now_present['names'].remove(username)

                if not people_now_present['names'] or people_now_present['value'] == 0:

                    del people_now_present['names']

            self['sensors']['people_now_present'][0] = people_now_present

        else:

            pass

    def clear_user_present(self):

        self['sensors']['people_now_present'][0]['value'] = 0

        if 'names' in self['sensors']['people_now_present'][0]:

            del self['sensors']['people_now_present'][0]['names']

    def send_tweet(self, value):

        tweet = random.choice(possible_open_tweets) if value else random.choice(possible_closed_tweets)

        try:

            post_tweet(tweet, self)

        except Exception as e:

            current_app.logger.error('Sending tweet failed! %s' % e,

                                     exc_info=True)

    def set_new_state(self, value=None, trigger_person=None, message=None):

        if value is not None and value != self['state']['open']:

            self['state']['open'] = value

            self.send_tweet(value)

            if not value:

                if 'people_now_present' in self['sensors']:

                    self.clear_user_present()

                if 'message' in self['state']:

                    del self['state']['message']

            if trigger_person is None:

                del self['state']['trigger_person']

            else:

                self['state']['trigger_person'] = trigger_person

            self['state']['lastchange'] = int(time())

        if message is not None:

            self['state']['message'] = message

def request_wants_json():

    best = request.accept_mimetypes.best_match(

        ['application/json', 'text/html']

    )

    return best == 'application/json' and \

        request.accept_mimetypes[best] > \

        request.accept_mimetypes['text/html']

def fuzzy_list_find(lst, key, value):

    for i, dic in enumerate(lst):

        if dic[key] == value:

            return i

    raise ValueError

def first(iterable, keys):

    for key in keys:

        if key in iterable:

            return key

    raise ValueError

def pass_active_status(f):

    @wraps(f)

    def wrapper(*args, **kwargs):

        status = ActiveStatus()

        rv = f(status, *args, **kwargs)

        status.save_last_state()

        return rv

    return wrapper

from flask import Blueprint, jsonify, render_template, abort, request, redirect, url_for, current_app

from .auth import httpauth

root_views = Blueprint('root', __name__)

@root_views.route('/')

def index():

    if request_wants_json():

        return jsonify(ActiveStatus())

    return render_template('index.html', status=ActiveStatus())

@root_views.route('/status.json')

def status_json():

    return jsonify(ActiveStatus())

@root_views.route('/reload')

@httpauth.login_required

def reload():

    active = ActiveStatus()

    active.reload()

    return jsonify(active)

@root_views.route('/open', methods=('GET', 'POST'))

@httpauth.login_required

def open():

    if request.method == 'POST':

        active = ActiveStatus()

        try:

            if httpauth.username() in current_app.config['STATE_TRIGGER_PERSON_ALLOWED']:

                trigger_person = httpauth.username()

            else:

                trigger_person = None

        except KeyError:

            trigger_person = None

        if 'close' in request.form:

            new_state = False

        elif 'open' in request.form:

            new_state = True

        active.set_new_state(value=new_state, trigger_person=trigger_person)

        active.save_last_state()

        return redirect(url_for('root.index'))

    return render_template('open.html')

@root_views.route('/present', methods=('GET', 'POST'))

@httpauth.login_required

def present():

    if request.method == 'POST':

        active = ActiveStatus()

        if active['state']['open']:

            if 'present' in request.form:

            elif 'leave' in request.form:

            active.save_last_state()

        return redirect(url_for('root.index'))

    return render_template('present.html')