from AccessControl import ClassSecurityInfo
from archetypes.querywidget.interfaces import IQueryField
from copy import deepcopy
from Products.Archetypes.Field import ObjectField
from Products.Archetypes.Field import registerField
from Products.CMFPlone.utils import safe_unicode
from zope.component import getMultiAdapter
from zope.interface import implements
from zope.site.hooks import getSite


class QueryField(ObjectField):
    """QueryField for storing query"""

    implements(IQueryField)
    _properties = ObjectField._properties.copy()

    security = ClassSecurityInfo()

    def get(self, instance, **kwargs):
        """Get the query dict from the request or from the object"""
        raw = kwargs.get('raw', None)
        value = self.getRaw(instance)
        if raw is True:
            # We actually wanted the raw value, should have called getRaw
            return value
        querybuilder = getMultiAdapter((instance, getSite().REQUEST),
                                       name=u'querybuilderresults')

        sort_on = kwargs.get('sort_on', instance.getSort_on())
        sort_order = 'reverse' if instance.getSort_reversed() else 'ascending'
        limit = kwargs.get('limit', instance.getLimit())
        return querybuilder(query=value, batch=kwargs.get('batch', False),
                            b_start=kwargs.get('b_start', 0),
                            b_size=kwargs.get('b_size', 30),
                            sort_on=sort_on, sort_order=sort_order,
                            limit=limit, brains=kwargs.get('brains', False),
                            custom_query=kwargs.get('custom_query', {}))

    def getRaw(self, instance, **kwargs):
        value = deepcopy(ObjectField.get(self, instance, **kwargs) or [])
        safe_value = []
        for query in value:
            safe_query = {}
            for k, v in query.items():
                if type(v) is list:
                    safe_v = []
                    for i in v:
                        safe_v.append(safe_unicode(i))
                    safe_query[k] = safe_v
                elif type(v) is str:
                    safe_query[k] = safe_unicode(v)
                else:
                    safe_query[k] = v
            safe_value.append(safe_query)
        return safe_value


registerField(QueryField, title='QueryField',
              description=('query field for storing a query'))