import datetime

import json

import logging

import pytz

import functools

from .tasks import send_tracking_data

logger = logging.getLogger(__name__)

def get_base_message(verb, renkan_id, current_user, registration = None):

    #create

    #open-read

    #open-edit

    #close

    #delete

    #update

    timestamp = datetime.datetime.utcnow().replace(tzinfo=pytz.utc)

    verbNode = {

        "create" : {

            "id": 'http://activitystrea.ms/schema/1.0/create',

            "display": { 'fr-FR': 'a créé' }

        },

        "update": {

            "id": 'http://activitystrea.ms/schema/1.0/update',

            "display": { 'fr-FR': 'a modifié' }

        },

        "delete": {

            "id": 'http://activitystrea.ms/schema/1.0/delete',

            "display": { 'fr-FR': 'a supprimé' }

        },

        "close": {

            "id": 'http://activitystrea.ms/schema/1.0/close',

            "display": { 'fr-FR': 'a fermé'}

        },

        "open_read": {

            "id": 'http://id.tincanapi.com/verb/viewed',

            "display": { 'fr-FR': 'a vu'}

        },

        "open_edit": {

            "id" : 'http://activitystrea.ms/schema/1.0/access',

            "display": { 'fr-FR': "a édité" }

        }

    }[verb];

    msg = {

        'actor': {

            'objectType': 'Agent',

            'name': current_user,

            'account': {

                'homePage': 'https://www.metaeducation.fr/Utilisateurs/',

                'name': current_user

            }

        },

        'verb': verbNode,

        'object': {

            'objectType': 'Activity',

            'id': get_renkan_urn(renkan_id)

        },

        'context': {

            'extensions': {

                'http://liris.renkantracking.org/application': 'Outil carte mentale'

            }

        },

        'timestamp': timestamp.isoformat()

    };

    if registration:

        msg['context']['registration'] = registration

    return msg

def get_renkan_urn(renkan_id):

    return 'urn:mtdc:renkan:renkan:%s' % renkan_id;

def send_close_renkan(renkan, current_user, registration):

    msg = get_base_message('close', renkan.renkan_guid, current_user, registration)

    msg['object'] = {

        **(msg['object']),

        **{

            "definition": {

                "name": {

                    'fr-FR': renkan.title

                },

                "type": "http://www.w3.org/ns/activitystreams#Renkan",

                "extensions": {

                    'http://www.w3.org/ns/activitystreams#Data': json.loads(renkan.content),

                }

            }

        }

    }

def send_open_read_renkan(renkan, current_user, registration):

    msg = get_base_message('open_read', renkan.renkan_guid, current_user, registration)

    msg['object'] = {

        **(msg['object']),

        **{

            "definition": {

                "name": {

                    'fr-FR': renkan.title

                },

                "type": "http://www.w3.org/ns/activitystreams#Renkan",

                "extensions": {

                    'http://www.w3.org/ns/activitystreams#Data': json.loads(renkan.content),

                }

            }

        }

    }

def send_open_edit_renkan(renkan, current_user, registration):

    msg = get_base_message('open_edit', renkan.renkan_guid, current_user, registration)

    msg['object'] = {

        **(msg.get('object', {})),

        **{

            "definition": {

                "name": {

                    'fr-FR': renkan.title

                },

                "type": "http://www.w3.org/ns/activitystreams#Renkan",

                "extensions": {

                    'http://www.w3.org/ns/activitystreams#Data': json.loads(renkan.content),

                }

            }

        }

    }

def _send_operation_renkan(action, renkan, current_user, content=None):

    if not content:

        content = json.loads(renkan.content)

        title = renkan.title

        renkan_guid = renkan.renkan_guid

    else:

        content = json.loads(content)

        title = content.get('title', '')

        renkan_guid = content.get('id', content.get('_id', ''))

    msg = get_base_message(action, renkan_guid, current_user)

    msg['object'] = {

        **(msg.get('object',{})),

        **{

            "definition": {

                "name": {

                    'fr-FR': title

                },

                "type": "http://www.w3.org/ns/activitystreams#Renkan",

                "extensions": {

                    'http://www.w3.org/ns/activitystreams#Data': content,

                }

            }

        }

    }

send_delete_renkan = functools.partial(_send_operation_renkan, 'delete')

send_update_renkan = functools.partial(_send_operation_renkan, 'update')

def send_create_renkan(renkan, current_user):

    msg = get_base_message('create', renkan.renkan_guid, current_user)

    msg['object'] = {

        **(msg.get('object', {})),

        **{

            "definition": {

                "name": {

                    'fr-FR': renkan.title

                },

                "type": "http://www.w3.org/ns/activitystreams#Renkan",

                "extensions": {

                    'http://www.w3.org/ns/activitystreams#Data': json.loads(renkan.content),

                }

            }

        }

    }

    if renkan.source_revision:

        msg['context']['extensions'] = {

            **msg.get('context', {}).get('extensions', {}),

            **{

                'http://liris.renkantracking.org/fromCreate': {'renkan': renkan.source_revision.parent_renkan.renkan_guid, 'revision': renkan.source_revision.revision_guid}

            }

        }