"""Repository users' and internal' sessions.

:organization: Logilab

:copyright: 2001-2009 LOGILAB S.A. (Paris, FRANCE), license is LGPL v2.

:contact: http://www.logilab.fr/ -- mailto:contact@logilab.fr

:license: GNU Lesser General Public License, v2.1 - http://www.gnu.org/licenses

"""

__docformat__ = "restructuredtext en"

import sys

import threading

from time import time

from logilab.common.deprecation import deprecated

from rql.nodes import VariableRef, Function, ETYPE_PYOBJ_MAP, etype_from_pyobj

from yams import BASE_TYPES

from cubicweb import RequestSessionMixIn, Binary, UnknownEid

from cubicweb.dbapi import ConnectionProperties

from cubicweb.utils import make_uid

from cubicweb.server.rqlrewrite import RQLRewriter

ETYPE_PYOBJ_MAP[Binary] = 'Bytes'

def is_final(rqlst, variable, args):

    # try to find if this is a final var or not

    for select in rqlst.children:

        for sol in select.solutions:

            etype = variable.get_type(sol, args)

            if etype is None:

                continue

            if etype in BASE_TYPES:

                return True

            return False

def _make_description(selected, args, solution):

    """return a description for a result set"""

    description = []

    for term in selected:

        description.append(term.get_type(solution, args))

    return description

class Session(RequestSessionMixIn):

    """tie session id, user, connections pool and other session data all

    together

    """

    def __init__(self, user, repo, cnxprops=None, _id=None):

        super(Session, self).__init__(repo.vreg)

        cnxprops = cnxprops or ConnectionProperties('inmemory')

        self.user = user

        self.repo = repo

        self.cnxtype = cnxprops.cnxtype

        self.creation = time()

        self.timestamp = self.creation

        self.is_internal_session = False

        self.is_super_session = False

        self.default_mode = 'read'

        # short cut to querier .execute method

        self._execute = repo.querier.execute

        # shared data, used to communicate extra information between the client

        # and the rql server

        self.data = {}

        # i18n initialization

        self.set_language(cnxprops.lang)

        # internals

        self._threaddata = threading.local()

        self._threads_in_transaction = set()

        self._closed = False

    def __str__(self):

        return '<%ssession %s (%s 0x%x)>' % (self.cnxtype, self.user.login,

                                             self.id, id(self))

    @property

    def schema(self):

        return self.repo.schema

    def add_relation(self, fromeid, rtype, toeid):

        if self.is_super_session:

            self.repo.glob_add_relation(self, fromeid, rtype, toeid)

            return

        self.is_super_session = True

        try:

            self.repo.glob_add_relation(self, fromeid, rtype, toeid)

        finally:

            self.is_super_session = False

    def update_rel_cache_add(self, subject, rtype, object, symetric=False):

        self._update_entity_rel_cache_add(subject, rtype, 'subject', object)

        if symetric:

            self._update_entity_rel_cache_add(object, rtype, 'subject', subject)

        else:

            self._update_entity_rel_cache_add(object, rtype, 'object', subject)

    def update_rel_cache_del(self, subject, rtype, object, symetric=False):

        self._update_entity_rel_cache_del(subject, rtype, 'subject', object)

        if symetric:

            self._update_entity_rel_cache_del(object, rtype, 'object', object)

        else:

            self._update_entity_rel_cache_del(object, rtype, 'object', subject)

    def _rel_cache(self, eid, rtype, role):

        try:

            entity = self.entity_cache(eid)

        except KeyError:

            return

        return entity.relation_cached(rtype, role)

    def _update_entity_rel_cache_add(self, eid, rtype, role, targeteid):

        rcache = self._rel_cache(eid, rtype, role)

        if rcache is not None:

            rset, entities = rcache

            rset.rows.append([targeteid])

            if isinstance(rset.description, list): # else description not set

                rset.description.append([self.describe(targeteid)[0]])

            rset.rowcount += 1

            targetentity = self.entity_from_eid(targeteid)

            entities.append(targetentity)

    def _update_entity_rel_cache_del(self, eid, rtype, role, targeteid):

        rcache = self._rel_cache(eid, rtype, role)

        if rcache is not None:

            rset, entities = rcache

            for idx, row in enumerate(rset.rows):

                if row[0] == targeteid:

                    break

            else:

                raise Exception('cache inconsistency for %s %s %s %s' %

                                (eid, rtype, role, targeteid))

            del rset.rows[idx]

            if isinstance(rset.description, list): # else description not set

                del rset.description[idx]

            del entities[idx]

            rset.rowcount -= 1

    # resource accessors ######################################################

    def actual_session(self):

        """return the original parent session if any, else self"""

        return self

    def system_sql(self, sql, args=None, rollback_on_failure=True):

        """return a sql cursor on the system database"""

        if not sql.split(None, 1)[0].upper() == 'SELECT':

            self.mode = 'write'

        return self.pool.source('system').doexec(self, sql, args,

                                                 rollback=rollback_on_failure)

    def set_language(self, language):

        """i18n configuration for translation"""

        vreg = self.vreg

        language = language or self.user.property_value('ui.language')

        try:

            self._ = self.__ = vreg.config.translations[language]

        except KeyError:

            language = vreg.property_value('ui.language')

            try:

                self._ = self.__ = vreg.config.translations[language]

            except KeyError:

                self._ = self.__ = unicode

        self.lang = language

    def change_property(self, prop, value):

        assert prop == 'lang' # this is the only one changeable property for now

        self.set_language(value)

    # connection management ###################################################

    def keep_pool_mode(self, mode):

        """set pool_mode, e.g. how the session will keep its pool:

        * if mode == 'write', the pool is freed after each ready query, but kept

          until the transaction's end (eg commit or rollback) when a write query

          is detected (eg INSERT/SET/DELETE queries)

        * if mode == 'transaction', the pool is only freed after the

          transaction's end

        notice that a repository has a limited set of pools, and a session has to

        wait for a free pool to run any rql query (unless it already has a pool

        set).

        """

        assert mode in ('transaction', 'write')

        if mode == 'transaction':

            self.default_mode = 'transaction'

        else: # mode == 'write'

            self.default_mode = 'read'

    def get_mode(self):

        return getattr(self._threaddata, 'mode', self.default_mode)

    def set_mode(self, value):

        self._threaddata.mode = value

    mode = property(get_mode, set_mode,

                    doc='transaction mode (read/write/transaction), resetted to'

                    ' default_mode on commit / rollback')

    def get_commit_state(self):

        return getattr(self._threaddata, 'commit_state', None)

    def set_commit_state(self, value):

        self._threaddata.commit_state = value

    commit_state = property(get_commit_state, set_commit_state)

    @property

    def pool(self):

        """connections pool, set according to transaction mode for each query"""

        return getattr(self._threaddata, 'pool', None)

    def set_pool(self, checkclosed=True):

        """the session need a pool to execute some queries"""

        if checkclosed and self._closed:

            raise Exception('try to set pool on a closed session')

        if self.pool is None:

            # get pool first to avoid race-condition

            self._threaddata.pool = pool = self.repo._get_pool()

            try:

                pool.pool_set()

            except:

                self._threaddata.pool = None

                self.repo._free_pool(pool)

                raise

            self._threads_in_transaction.add(threading.currentThread())

        return self._threaddata.pool

    def reset_pool(self, ignoremode=False):

        """the session is no longer using its pool, at least for some time"""

        # pool may be none if no operation has been done since last commit

        # or rollback

        if self.pool is not None and (ignoremode or self.mode == 'read'):

            # even in read mode, we must release the current transaction

            pool = self.pool

            try:

                self._threads_in_transaction.remove(threading.currentThread())

            except KeyError:

                pass

            pool.pool_reset()

            self._threaddata.pool = None

            # free pool once everything is done to avoid race-condition

            self.repo._free_pool(pool)

    def _touch(self):

        """update latest session usage timestamp and reset mode to read"""

        self.timestamp = time()

        self.local_perm_cache.clear()

        self._threaddata.mode = self.default_mode

    # shared data handling ###################################################

    def get_shared_data(self, key, default=None, pop=False):

        """return value associated to `key` in session data"""

        if pop:

            return self.data.pop(key, default)

        else:

            return self.data.get(key, default)

    def set_shared_data(self, key, value, querydata=False):

        """set value associated to `key` in session data"""

        if querydata:

            self.transaction_data[key] = value

        else:

            self.data[key] = value

    # request interface #######################################################

    def set_entity_cache(self, entity):

        # XXX session level caching may be a pb with multiple repository

        #     instances, but 1. this is probably not the only one :$ and 2. it

        #     may be an acceptable risk. Anyway we could activate it or not

        #     according to a configuration option

        try:

            self.transaction_data['ecache'].setdefault(entity.eid, entity)

        except KeyError:

            self.transaction_data['ecache'] = ecache = {}

            ecache[entity.eid] = entity

    def entity_cache(self, eid):

        try:

            return self.transaction_data['ecache'][eid]

        except:

            raise

    def cached_entities(self):

        return self.transaction_data.get('ecache', {}).values()

    def drop_entity_cache(self, eid=None):

        if eid is None:

            self.transaction_data.pop('ecache', None)

        else:

            del self.transaction_data['ecache'][eid]

    def base_url(self):

        url = self.repo.config['base-url']

        if not url:

            try:

                url = self.repo.config.default_base_url()

            except AttributeError: # default_base_url() might not be available

                self.warning('missing base-url definition in server config')

                url = u''

        return url

    def from_controller(self):

        """return the id (string) of the controller issuing the request (no

        sense here, always return 'view')

        """

        return 'view'

    def source_defs(self):

        return self.repo.source_defs()

    def describe(self, eid):

        """return a tuple (type, sourceuri, extid) for the entity with id <eid>"""

        return self.repo.type_and_source_from_eid(eid, self)

    # db-api like interface ###################################################

    def source_from_eid(self, eid):

        """return the source where the entity with id <eid> is located"""

        return self.repo.source_from_eid(eid, self)

    def decorate_rset(self, rset, propagate=False):

        rset.vreg = self.vreg

        rset.req = propagate and self or self.actual_session()

        return rset

    @property

    def super_session(self):

        try:

            csession = self._threaddata.childsession

        except AttributeError:

            if self.is_super_session:

                csession = self

            else:

                csession = ChildSession(self)

            self._threaddata.childsession = csession

        # need shared pool set

        self.set_pool(checkclosed=False)

        return csession

    def unsafe_execute(self, rql, kwargs=None, eid_key=None, build_descr=True,

                       propagate=False):

        """like .execute but with security checking disabled (this method is

        internal to the server, it's not part of the db-api)

        if `propagate` is true, the super_session will be attached to the result

        set instead of the parent session, hence further query done through

        entities fetched from this result set will bypass security as well

        """

        return self.super_session.execute(rql, kwargs, eid_key, build_descr,

                                          propagate)

    @property

    def cursor(self):

        """return a rql cursor"""

        return self

    def execute(self, rql, kwargs=None, eid_key=None, build_descr=True,

                propagate=False):

        """db-api like method directly linked to the querier execute method

        Becare that unlike actual cursor.execute, `build_descr` default to

        false

        """

        rset = self._execute(self, rql, kwargs, eid_key, build_descr)

        return self.decorate_rset(rset, propagate)

    def commit(self, reset_pool=True):

        """commit the current session's transaction"""

        if self.pool is None:

            assert not self.pending_operations

            self.transaction_data.clear()

            self._touch()

            self.debug('commit session %s done (no db activity)', self.id)

            return

        if self.commit_state:

            return

        # on rollback, an operation should have the following state

        # information:

        # - processed by the precommit/commit event or not

        # - if processed, is it the failed operation

        try:

            for trstate in ('precommit', 'commit'):

                processed = []