# coding: utf-8

"""

TODO:
    - load drops from pop3 or imap
    - webpack / bundle js to a single file
    - improve attribute handling
    - filtering views to different blocks

"""

from __future__ import print_function, absolute_import

import sys
import os.path
import argparse
import re
import bottle

try:
    import ujson as json
except ImportError:
    import json

from json import JSONDecoder

from datetime import datetime, date, timedelta

from tinydb import TinyDB, Query
from tinydb_serialization import Serializer, SerializationMiddleware

from drop_parser import DropParserManager


class DatetimeSerializer(Serializer):
    OBJ_CLASS = datetime

    def encode(self, obj):
        return obj.strftime("%Y-%m-%dT%H:%M:%S")

    def decode(self, s):
        return datetime.strptime(s, "%Y-%m-%dT%H:%M:%S")

def json_datetime_serial(obj):
    if isinstance(obj, datetime):
        return obj.isoformat()
    raise TypeError("not serializable")

def _storage():
    _serializer = SerializationMiddleware()
    _serializer.register_serializer(DatetimeSerializer(), "DatetimeSerializer")
    return _serializer


def drop_collection():
    db = TinyDB("braindrops.json", storage=_storage())
    table = db.table("drops")
    return table


COLOR_TAG = "cyan"
COLOR_ATTR = "yellow"
COLOR_DATETIME = "white"


try:
    from termcolor import colored
except ImportError:
    print ("INFO: improve display by installing termcolor with 'pip install termcolor'");
    def colored(message, *args, **kwargs):
        return message


def parser_drop(message):
    p = DropParserManager([
        'drop_parser.TagParser',
        'drop_parser.BirthdayAttrParser',
    ])
    return p.parse(message)


def _prettify_tags(message):

    def fnc(match):
        return colored(match.groups()[0], COLOR_TAG)

    return re.sub("(#\w+)", fnc, message)


def _prettify_attrs(message):

    def fnc(match):
        return colored("%s:%s" % match.groups(0), COLOR_ATTR)

    return re.sub("(@\w+):([\w+\_\-\.]+)", fnc, message)


def _prettify(drop, full=False):
    resp = []
    resp.append(" ".join([colored("{%s}" %drop.eid, "red"), colored(drop['datetime'], COLOR_DATETIME)]))
    resp.append(_prettify_attrs(_prettify_tags(drop['message'])))
    if full:
        resp.append("tags: {}".format(colored(", ".join(drop['tags']), "green")))
        resp.append("attrs: {}".format(drop['attrs']))
    return "\n".join(resp)


def _add(message):
    drop = parser_drop(message)
    drops = drop_collection()
    eid = drops.insert(drop)
    return _get(eid)


def cmd_add(args):
    drop = _add(" ".join(args.message))
    print(_prettify(drop, full=True))


def _list(tags=None, limit=10, today=False, days=None):
    drops = drop_collection()

    if not tags:
        tags = list()

    query = None

    if today:
        Drop = Query()
        today = date.today()

        def match_date(value, date_value):
            return value.date() == date_value

        query = drops.search(Drop.datetime.test(match_date, date.today()))

    if days is not None:
        Drop = Query()

        def match_dayrange(value, day_range):
            return value > datetime.now() - timedelta(days=day_range)

        query = drops.search(Drop.datetime.test(match_dayrange, days))

    if tags:
        Drop = Query()
        from operator import __or__
        search_query = reduce(__or__, [
            Drop.tags.test(lambda l: tag in l) for tag in tags
        ])
        query = drops.search(search_query)
    else:
        if query is None:
            query = drops.all()
    query = sorted(query, key=lambda o: o['datetime'], reverse=True)
    query = query[:limit]
    for drop in query:
        yield drop

def cmd_list(args):
    for drop in _list(tags=args.tags, limit=args.limit, today=args.today, days=args.days):
        if not args.quiet:
            print(_prettify(drop, full=args.full))
            print()
        else:
            print(drop.eid)

def _tags():
    from collections import defaultdict
    tags = defaultdict(int)
    drops = drop_collection()
    for drop in drops.all():
        for tag in drop['tags']:
            tags[tag] += 1
    for tag, count in sorted(tags.items(), key=lambda o: o[1], reverse=True):
        yield tag, count

def cmd_tags(args):
    for tag, count in _tags():
        print("%s: %s" % (tag, count))

def _get(eid):
    drops = drop_collection()
    return drops.get(eid=eid)


def cmd_get(args):
    print(_prettify(_get(args.id)))


def _remove(eid):
    drops = drop_collection()
    drops.remove(eids=[eid])


def cmd_remove(args):
    _remove(args.id)
    print("ok")


def _bottle_app():

    from bottle import response, request, Bottle, view, static_file
    app = Bottle(autojson=True)

    def to_json(value):
        return json.dumps(dict(value, id=value.eid), default=json_datetime_serial)

    def drop_prep(drop):
        return dict(drop, id=drop.eid)

    def json_response(value):
        response.content_type = "application/json"
        return json.dumps(value, default=json_datetime_serial)

    @app.route("/", method="GET")
    def index():
        return static_file("index.html", root=".")

    @app.route("/static/<path:path>")
    def static(path):
        return static_file(path, root="assets")

    @app.route("/api", method="GET")
    def api_index():
        json_response([
            app.get_url("api-drops-list"),
            app.get_url("api-drops-get", eid="<eid>"),
            app.get_url("api-drops-create"),
            app.get_url("api-drops-update", eid="<eid>"),
            app.get_url("api-drops-delete", eid="<eid>"),
        ])

    @app.route("/api/drops", method="GET", name="api-drops-list")
    def list():
        tag = request.query.get("tag", None)
        tag = None if tag is None else [tag]

        days = request.query.get("days", None)
        days = None if days is None else int(days)
        return json_response(map(drop_prep, _list(tags=tag, days=days)))

    @app.route("/api/drops", method="POST", name="api-drops-create")
    def create():
        payload = request.json
        return json_response(drop_prep((_add(payload['message']))))

    @app.route("/api/drops/<eid>", method="GET", name="api-drops-get")
    def get(eid):
        eid = int(eid)
        return json_response(drop_prep(_get(eid)))

    @app.route("/api/drops/<eid>", method="PUT", name="api-drops-update")
    def update(eid):
        raise NotImplementedError()

    @app.route("/api/drops/<eid>", method="DELETE", name="api-drops-delete")
    def delete(eid):
        eid = int(eid)
        _remove(eid)
        return json_response(["ok"])

    return app


def cmd_serve(args):
    app = _bottle_app()
    bottle.run(app=app, debug=args.debug, reloader=args.reloader, port=args.port, host=args.host)


parser = argparse.ArgumentParser(prog=__file__)
sub_parsers = parser.add_subparsers()

add_parser = sub_parsers.add_parser("add")
add_parser.add_argument("message", metavar="M", type=str, nargs="+")
add_parser.set_defaults(func=cmd_add)

list_parser = sub_parsers.add_parser("list")
list_parser.add_argument("--full", "-f", dest="full", action="store_true", default=False)
list_parser.add_argument("--tag", "-t", dest="tags", action="append", default=[])
list_parser.add_argument("--limit", "-l", dest="limit", type=int, default=5)
list_parser.add_argument("--quiet", "-q", dest="quiet", action="store_true", default=False)
list_parser.add_argument("--today", dest="today", action="store_true", default=False)
list_parser.add_argument("--days", dest="days", type=int, default=None)
list_parser.set_defaults(func=cmd_list)

rm_parser = sub_parsers.add_parser("rm")
rm_parser.add_argument("id", metavar="ID", type=int)
rm_parser.set_defaults(func=cmd_remove)

get_parser = sub_parsers.add_parser("get")
get_parser.set_defaults(func=cmd_get)
get_parser.add_argument("id", metavar="ID", type=int)

serve_parser = sub_parsers.add_parser("serve")
serve_parser.add_argument("--bind", "-b", dest="host", default="127.0.0.1", type=str)
serve_parser.add_argument("--port", "-p", dest="port", default=8080, type=int)
serve_parser.add_argument("--no-debug", "-d", dest="debug", action="store_false", default=True)
serve_parser.add_argument("--no-reloader", "-r", dest="reloader", action="store_false", default=True)
serve_parser.set_defaults(func=cmd_serve)

tags_parser = sub_parsers.add_parser("tags")
tags_parser.set_defaults(func=cmd_tags)


if __name__ == "__main__":
    args = parser.parse_args()
    args.func(args)

# coding: utf-8

"""

TODO:
    - load drops from pop3 or imap
    - webpack / bundle js to a single file
    - improve attribute handling
    - filtering views to different blocks

"""

from __future__ import print_function, absolute_import

import sys
import os.path
import argparse
import re
import bottle

try:
    import ujson as json
except ImportError:
    import json

from json import JSONDecoder

from datetime import datetime, date, timedelta

from tinydb import TinyDB, Query
from tinydb_serialization import Serializer, SerializationMiddleware

from drop_parser import DropParserManager


class DatetimeSerializer(Serializer):
    OBJ_CLASS = datetime

    def encode(self, obj):
        return obj.strftime("%Y-%m-%dT%H:%M:%S")

    def decode(self, s):
        return datetime.strptime(s, "%Y-%m-%dT%H:%M:%S")

def json_datetime_serial(obj):
    if isinstance(obj, datetime):
        return obj.isoformat()
    raise TypeError("not serializable")

def _storage():
    _serializer = SerializationMiddleware()
    _serializer.register_serializer(DatetimeSerializer(), "DatetimeSerializer")
    return _serializer


def drop_collection():
    db = TinyDB("braindrops.json", storage=_storage())
    table = db.table("drops")
    return table


COLOR_TAG = "cyan"
COLOR_ATTR = "yellow"
COLOR_DATETIME = "white"


try:
    from termcolor import colored
except ImportError:
    print ("INFO: improve display by installing termcolor with 'pip install termcolor'");
    def colored(message, *args, **kwargs):
        return message


def parser_drop(message):
    p = DropParserManager([
        'drop_parser.TagParser',
        'drop_parser.BirthdayAttrParser',
    ])
    return p.parse(message)


def _prettify_tags(message):

    def fnc(match):
        return colored(match.groups()[0], COLOR_TAG)

    return re.sub("(#\w+)", fnc, message)


def _prettify_attrs(message):

    def fnc(match):
        return colored("%s:%s" % match.groups(0), COLOR_ATTR)

    return re.sub("(@\w+):([\w+\_\-\.]+)", fnc, message)


def _prettify(drop, full=False):
    resp = []
    resp.append(" ".join([colored("{%s}" %drop.eid, "red"), colored(drop['datetime'], COLOR_DATETIME)]))
    resp.append(_prettify_attrs(_prettify_tags(drop['message'])))
    if full:
        resp.append("tags: {}".format(colored(", ".join(drop['tags']), "green")))
        resp.append("attrs: {}".format(drop['attrs']))
    return "\n".join(resp)


def _add(message):
    drop = parser_drop(message)
    drops = drop_collection()
    eid = drops.insert(drop)
    return _get(eid)


def cmd_add(args):
    drop = _add(" ".join(args.message))
    print(_prettify(drop, full=True))


def _list(tags=None, limit=10, today=False, days=None):
    drops = drop_collection()

    if not tags:
        tags = list()

    query = None

    if today:
        Drop = Query()
        today = date.today()

        def match_date(value, date_value):
            return value.date() == date_value

        query = drops.search(Drop.datetime.test(match_date, date.today()))

    if days is not None:
        Drop = Query()

        def match_dayrange(value, day_range):
            return value > datetime.now() - timedelta(days=day_range)

        query = drops.search(Drop.datetime.test(match_dayrange, days))

    if tags:
        Drop = Query()
        from operator import __or__
        search_query = reduce(__or__, [
            Drop.tags.test(lambda l: tag in l) for tag in tags
        ])
        query = drops.search(search_query)
    else:
        if query is None:
            query = drops.all()
    query = sorted(query, key=lambda o: o['datetime'], reverse=True)
    query = query[:limit]
    for drop in query:
        yield drop

def cmd_list(args):
    for drop in _list(tags=args.tags, limit=args.limit, today=args.today, days=args.days):
        if not args.quiet:
            print(_prettify(drop, full=args.full))
            print()
        else:
            print(drop.eid)

def _tags():
    from collections import defaultdict
    tags = defaultdict(int)
    drops = drop_collection()
    for drop in drops.all():
        for tag in drop['tags']:
            tags[tag] += 1
    for tag, count in sorted(tags.items(), key=lambda o: o[1], reverse=True):
        yield tag, count

def cmd_tags(args):
    for tag, count in _tags():
        print("%s: %s" % (tag, count))

def _get(eid):
    drops = drop_collection()
    return drops.get(eid=eid)


def cmd_get(args):
    print(_prettify(_get(args.id)))


def _remove(eid):
    drops = drop_collection()
    drops.remove(eids=[eid])


def cmd_remove(args):
    _remove(args.id)
    print("ok")


def _bottle_app():

    from bottle import response, request, Bottle, view, static_file
    app = Bottle(autojson=True)

    def to_json(value):
        return json.dumps(dict(value, id=value.eid), default=json_datetime_serial)

    def drop_prep(drop):
        return dict(drop, id=drop.eid)

    def json_response(value):
        response.content_type = "application/json"
        return json.dumps(value, default=json_datetime_serial)

    @app.route("/", method="GET")
    def index():
        return static_file("index.html", root=".")

    @app.route("/static/<path:path>")
    def static(path):
        return static_file(path, root="assets")

    @app.route("/api", method="GET")
    def api_index():
        json_response([
            app.get_url("api-drops-list"),
            app.get_url("api-drops-get", eid="<eid>"),
            app.get_url("api-drops-create"),
            app.get_url("api-drops-update", eid="<eid>"),
            app.get_url("api-drops-delete", eid="<eid>"),
        ])

    @app.route("/api/drops", method="GET", name="api-drops-list")
    def list():
        tag = request.query.get("tag", None)
        tag = None if tag is None else [tag]

        days = request.query.get("days", None)
        days = None if days is None else int(days)
        return json_response(map(drop_prep, _list(tags=tag, days=days)))

    @app.route("/api/drops", method="POST", name="api-drops-create")
    def create():
        payload = request.json
        return json_response(drop_prep((_add(payload['message']))))

    @app.route("/api/drops/<eid>", method="GET", name="api-drops-get")
    def get(eid):
        eid = int(eid)
        return json_response(drop_prep(_get(eid)))

    @app.route("/api/drops/<eid>", method="PUT", name="api-drops-update")
    def update(eid):
        raise NotImplementedError()

    @app.route("/api/drops/<eid>", method="DELETE", name="api-drops-delete")
    def delete(eid):
        eid = int(eid)
        _remove(eid)
        return json_response(["ok"])

    return app


def cmd_serve(args):
    app = _bottle_app()
    bottle.run(app=app, debug=args.debug, reloader=args.reloader, port=args.port, host=args.host)


parser = argparse.ArgumentParser(prog=__file__)
sub_parsers = parser.add_subparsers()

add_parser = sub_parsers.add_parser("add")
add_parser.add_argument("message", metavar="M", type=str, nargs="+")
add_parser.set_defaults(func=cmd_add)

list_parser = sub_parsers.add_parser("list")
list_parser.add_argument("--full", "-f", dest="full", action="store_true", default=False)
list_parser.add_argument("--tag", "-t", dest="tags", action="append", default=[])
list_parser.add_argument("--limit", "-l", dest="limit", type=int, default=5)
list_parser.add_argument("--quiet", "-q", dest="quiet", action="store_true", default=False)
list_parser.add_argument("--today", dest="today", action="store_true", default=False)
list_parser.add_argument("--days", dest="days", type=int, default=None)
list_parser.set_defaults(func=cmd_list)

rm_parser = sub_parsers.add_parser("rm")
rm_parser.add_argument("id", metavar="ID", type=int)
rm_parser.set_defaults(func=cmd_remove)

get_parser = sub_parsers.add_parser("get")
get_parser.set_defaults(func=cmd_get)
get_parser.add_argument("id", metavar="ID", type=int)

serve_parser = sub_parsers.add_parser("serve")
serve_parser.add_argument("--bind", "-b", dest="host", default="127.0.0.1", type=str)
serve_parser.add_argument("--port", "-p", dest="port", default=8080, type=int)
serve_parser.add_argument("--no-debug", "-d", dest="debug", action="store_false", default=True)
serve_parser.add_argument("--no-reloader", "-r", dest="reloader", action="store_false", default=True)
serve_parser.set_defaults(func=cmd_serve)

tags_parser = sub_parsers.add_parser("tags")
tags_parser.set_defaults(func=cmd_tags)


if __name__ == "__main__":
    args = parser.parse_args()
    args.func(args)

# coding: utf-8 TODO:
     - load drops from pop3 or imap
     - webpack / bundle js to a single file
     - improve attribute handling
     - filtering views to different blocks #\w+)", fnc, message)