#
# See LICENCE for detail
# Copyright (c) 2014 IRI
#

import datetime
import json
import uuid

def get_table_create_stmt():
    return (
        "CREATE TABLE IF NOT EXISTS annotations ( "
        "id serial PRIMARY KEY, "
        "uuid uuid UNIQUE, "
        "created timestamp default (now() at time zone 'utc') NOT NULL, "
        "ts timestamptz NOT NULL, "
        "event varchar(255) NOT NULL, "
        "channel varchar(255) NOT NULL, "
        "content json);"
    )

def insert_annot_async(params, conn):

    content = params.get('content', {})
    if not isinstance(content, basestring):
        params['content'] = json.dumps(content)
    if 'uuid' not in params:
        params['uuid'] = uuid.uuid4()

    if 'ts' not in params:
        params['ts'] = datetime.utcnow()

    defer = conn.runOperation("INSERT INTO annotations (uuid, ts, event, channel, content) VALUES (%(uuid)s, %(ts)s, %(event)s, %(channel)s, %(content)s)", params)
    defer.addCallback(lambda _: params)

    return defer