from flask import Flask, render_template, send_from_directory
from flask import jsonify
from flask_socketio import SocketIO, emit
import threading

app = Flask(__name__, static_url_path='')

global socketio, activations_per_state, properties
socketio = SocketIO(app)

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

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

@app.route('/')
def index():
    return render_template('index.html')


@app.route('/data')
def get_data():
    sets = parse_data()
    return jsonify(sets)

def format_whitespace(s, sub, nth):
    find = s.find(sub)
    # loop util we find no match
    i = 1
    while find != -1:
        # if i  is equal to nth we found nth matches so replace
        if i == nth:
            s = s[:find]+"\n"+s[find + len(sub):]
            i = 0
        # find + len(sub) + 1 means we start after the last match
        find = s.find(sub, find + len(sub) + 1)
        i += 1
    return s

def fillme(a, p):
    global socketio, activations_per_state, properties
    activations_per_state = a
    properties = p

def parse_data():
    global socketio, activations_per_state, properties
    sets = []

    for state in activations_per_state:
        for target in state.write_props:
            set = {}
            # set['source'] = format_whitespace(state.name, "_", 2).replace("_", " ")
            set['source'] = state.name
            set['target'] = target
            set['type'] = 'changes'
            sets.append(set)
        for signal in state.constraint.signals():
            # Add depended-on signals
            set = {}
            set['source'] = signal.id()
            # set['target'] = format_whitespace(state.name, "_", 2).replace("_", " ")
            set['target'] = state.name
            set['type'] = 'triggers'
            sets.append(set)
        if state.signal:
            set = {}
            # set['source'] = format_whitespace(state.name, "_", 2).replace("_", " ")
            set['source'] = state.name
            set['target'] = state.signal.id()
            set['type'] = 'emits'
            sets.append(set)

    for property_name, property in properties.items():
        for signal in property.signals():
            set = {}
            set['source'] = str(property.id())
            set['target'] = str(signal.id())
            set['type'] = 'sets'
            sets.append(set)

    return sets


@socketio.on('update')
def update():
    sets = parse_data()
    emit('newdata', jsonify(sets))


def activate(stateName):
    socketio.emit("activate", stateName)


def spike(signalName):
    socketio.emit("spike", signalName)


def advertise(*, ip="0.0.0.0", port=5001, debug=False):
    app.debug=debug
    appthread = threading.Thread(target=app.run, args=(ip, port))
    appthread.start()
    socketthread = threading.Thread(target=socketio.run, args=(app,))
    socketthread.start()
    activate(":pressure")

from flask import Flask, render_template, send_from_directory
from flask import jsonify
from flask_socketio import SocketIO, emit
import threading

app = Flask(__name__, static_url_path='')

global socketio, activations_per_state, properties
socketio = SocketIO(app)

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

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

@app.route('/')
def index():
    return render_template('index.html')


@app.route('/data')
def get_data():
    sets = parse_data()
    return jsonify(sets)

def format_whitespace(s, sub, nth):
    find = s.find(sub)
    # loop util we find no match
    i = 1
    while find != -1:
        # if i  is equal to nth we found nth matches so replace
        if i == nth:
            s = s[:find]+"\n"+s[find + len(sub):]
            i = 0
        # find + len(sub) + 1 means we start after the last match
        find = s.find(sub, find + len(sub) + 1)
        i += 1
    return s

def fillme(a, p):
    global socketio, activations_per_state, properties
    activations_per_state = a
    properties = p

def parse_data():
    global socketio, activations_per_state, properties
    sets = []

    for state in activations_per_state:
        for target in state.write_props:
            set = {}
            # set['source'] = format_whitespace(state.name, "_", 2).replace("_", " ")
            set['source'] = state.name
            set['target'] = target
            set['type'] = 'changes'
            sets.append(set)
        for signal in state.constraint.signals():
            # Add depended-on signals
            set = {}
            set['source'] = signal.id()
            # set['target'] = format_whitespace(state.name, "_", 2).replace("_", " ")
            set['target'] = state.name
            set['type'] = 'triggers'
            sets.append(set)
        if state.signal:
            set = {}
            # set['source'] = format_whitespace(state.name, "_", 2).replace("_", " ")
            set['source'] = state.name
            set['target'] = state.signal.id()
            set['type'] = 'emits'
            sets.append(set)

    for property_name, property in properties.items():
        for signal in property.signals():
            set = {}
            set['source'] = str(property.id())
            set['target'] = str(signal.id())
            set['type'] = 'sets'
            sets.append(set)

    return sets


@socketio.on('update')
def update():
    sets = parse_data()
    emit('newdata', jsonify(sets))


def activate(stateName):
    socketio.emit("activate", stateName)


def spike(signalName):
    socketio.emit("spike", signalName)


def advertise(*, ip="0.0.0.0", port=5001, debug=False):
    app.debug=debug
    appthread = threading.Thread(target=app.run, args=(ip, port))
    appthread.start()
    socketthread = threading.Thread(target=socketio.run, args=(app,))
    socketthread.start()
    activate(":pressure")

# loop util we find no match # if i  is equal to nth we found nth matches so replace # find + len(sub) + 1 means we start after the last match # set['source'] = format_whitespace(state.name, "_", 2).replace("_", " ") # Add depended-on signals # set['target'] = format_whitespace(state.name, "_", 2).replace("_", " ") # set['source'] = format_whitespace(state.name, "_", 2).replace("_", " ")