from cubicweb.pyramid.test import PyramidCWTest


def set_language(request):
    lang = request.POST.get('lang', None)
    cnx = request.cw_cnx
    if lang is None:
        cnx.execute('DELETE CWProperty X WHERE X for_user U, U eid %(u)s',
                    {'u': cnx.user.eid})
    else:
        cnx.user.set_property(u'ui.language', lang)
    cnx.commit()

    request.response.text = cnx.user.properties.get('ui.language', '')
    return request.response


def add_remove_group(request):
    add_remove = request.POST['add_remove']
    cnx = request.cw_cnx
    if add_remove == 'add':
        cnx.execute('SET U in_group G WHERE G name "users", U eid %(u)s',
                    {'u': cnx.user.eid})
    else:
        cnx.execute('DELETE U in_group G WHERE G name "users", U eid %(u)s',
                    {'u': cnx.user.eid})
    cnx.commit()

    request.response.text = ','.join(sorted(cnx.user.groups))
    return request.response


class SessionSyncHoooksTC(PyramidCWTest):

    def includeme(self, config):
        for view in (set_language, add_remove_group):
            config.add_route(view.__name__, '/' + view.__name__)
            config.add_view(view, route_name=view.__name__)

    def setUp(self):
        super(SessionSyncHoooksTC, self).setUp()
        with self.admin_access.repo_cnx() as cnx:
            self.admin_eid = cnx.user.eid

    def test_sync_props(self):
        # initialize a pyramid session using admin credentials
        res = self.webapp.post('/login', {
            '__login': self.admlogin, '__password': self.admpassword})
        self.assertEqual(res.status_int, 303)
        # new property
        res = self.webapp.post('/set_language', {'lang': 'fr'})
        self.assertEqual(res.text, 'fr')
        # updated property
        res = self.webapp.post('/set_language', {'lang': 'en'})
        self.assertEqual(res.text, 'en')
        # removed property
        res = self.webapp.post('/set_language')
        self.assertEqual(res.text, '')

    def test_sync_groups(self):
        # initialize a pyramid session using admin credentials
        res = self.webapp.post('/login', {
            '__login': self.admlogin, '__password': self.admpassword})
        self.assertEqual(res.status_int, 303)
        # XXX how to get pyramid request using this session?
        res = self.webapp.post('/add_remove_group', {'add_remove': 'add'})
        self.assertEqual(res.text, 'managers,users')
        res = self.webapp.post('/add_remove_group', {'add_remove': 'remove'})
        self.assertEqual(res.text, 'managers')


if __name__ == '__main__':
    from unittest import main
    main()