from typing import List

from flask import request, jsonify, Response
from peewee import fn, Alias, SQL, DoesNotExist, Expression, ModelSelect
from playhouse.postgres_ext import TS_MATCH
from playhouse.shortcuts import model_to_dict
from psycopg2._psycopg import cursor

from app import app
from models import *


# logger = logging.getLogger('peewee')
# logger.addHandler(logging.StreamHandler())
# logger.setLevel(logging.DEBUG)


def add_cors(response: Response) -> Response:
    header = response.headers
    header['Access-Control-Allow-Origin'] = '*'
    return response


def suggest(query: str, until: int, series: str, limit: int = 10) -> ModelSelect:
    return Phrase.select(Phrase.text, Alias(fn.SUM(Phrase.count), "total_count")).join(Episode).join(Series).where(
        (Episode.series.slug == series) &
        (Episode.episode_number <= until) &
        (Phrase.text.contains(query))
    ).group_by(Phrase.text).order_by(SQL("total_count DESC")).limit(limit)


def search(query: str, until: int, series: str, limit: int = 50) -> ModelSelect:
    a = Alias(fn.ts_rank_cd(Line.search_text, fn.websearch_to_tsquery('english', query), 1 + 4), "rank")

    return Line.select(Line, Person, Episode, Series, a).where(
        Expression(Line.search_text, TS_MATCH, fn.websearch_to_tsquery('english', query))
        &
        (Episode.episode_number <= until)
        &
        (Episode.series.slug == series)
    ).order_by(SQL("rank DESC")) \
        .join(Person).switch(Line) \
        .join(Episode).join(Series) \
        .limit(limit)


global_excludes = [Line.search_text, Episode.phrases_imported, Episode.text_imported, Person.series, Episode.title]


@app.route("/api/suggest")
def api_question():
    query: str = request.args.get('query')
    until = request.args.get('until')
    series = request.args.get('series')
    if not query or not until or not series:
        return "no suggest query", 400
    if len(query) > 50:
        return "too long query", 400
    phrases = suggest(query, until, series)
    return jsonify([p.text for p in phrases])


@app.route("/api/search")
def api_search():
    query = request.args.get('query')
    until = request.args.get('until')
    series = request.args.get('series')
    if not query or not until or not series:
        return "no suggest query", 400
    if len(query) > 50:
        return "too long query", 400

    results = search(query, until, series)

    if len(results) == 0:
        result: cursor = db.execute_sql("select websearch_to_tsquery('english',%s)", [query])
        parsed = result.fetchone()[0]
        if not parsed:
            return jsonify({
                "status": "warning",
                "message": "Only stop words were used. Please try to add a less common word to the search."
            })
        else:
            resp: Response = jsonify({"status": "warning", "message": f"No results were found for \"{parsed}\""})
            resp.status_code = 404
            return resp

    data = []
    d: Line
    ri = 0
    for d in results:
        entry = model_to_dict(d, extra_attrs=["rank"], exclude=global_excludes + [Episode.subtitle_hash])
        entry["rank"] = float(entry["rank"])
        data.append({"centerID": d.id, "resultID": ri, "offset": 1, "lines": [entry]})
        ri += 1

    return jsonify(data)


@app.route("/api/expand")
def api_expand():
    center_id = request.args.get('centerID')
    offset = int(request.args.get('offset', 1))
    if not center_id:
        return "no central line ID", 400

    try:
        center: Line = Line.select().where(Line.id == center_id).get()

    except DoesNotExist:
        return "not found", 404

    lines = Line.select().where(
        (Line.episode == center.episode) & (Line.order << [center.order - offset, center.order + offset])
    )
    l: Line
    data = []
    for l in lines:
        entry = model_to_dict(l, exclude=global_excludes)
        data.append(entry)

    return jsonify(data)


@app.route("/api/series")
def series():
    series_list = []

    for series in Series.select():
        last_episode: Episode = Episode.select().where(Episode.series == series).order_by(
            Episode.upload_date.desc()).limit(
            1).get()
        series_data = model_to_dict(series)
        series_data["last_upload"] = last_episode.upload_date.strftime("%Y-%m-%d")
        series_data["length"] = Episode.select().where(Episode.series == series).count()
        series_list.append(series_data)
    return jsonify({
        "series": series_list
    })


@app.route("/api/episodes")
def api_episodes():
    all_series: List[Series] = Series.select().order_by(Series.id)
    data = []
    for series in all_series:

        episodes: List[Episode] = Episode.select().where(Episode.series == series).order_by(Episode.video_number)

        series_data = []
        for episode in episodes:
            entry = model_to_dict(episode, exclude=[Episode.series, Episode.title])
            if entry["upload_date"]:
                entry["upload_date"] = entry["upload_date"].strftime("%Y-%m-%d")
            series_data.append(entry)
        data.append({
            "meta": model_to_dict(series),
            "episodes": series_data
        })

    return jsonify(data)


if __name__ == "__main__":
    app.debug = True
    app.after_request(add_cors)
    app.run()