# copyright 2003-2014 LOGILAB S.A. (Paris, FRANCE), all rights reserved.

        with self.admin_access.repo_cnx() as cnx:

            self.assertEqual(self.repo.schema['sender'].inlined, True)

            cnx.execute('INSERT EmailAddress X: X address "toto@logilab.fr", X alias "hop"')

            cnx.execute('INSERT EmailPart X: X content_format "text/plain", X ordernum 1, '

                        'X content "this is a test"')

            eeid = cnx.execute('INSERT Email X: X messageid "<1234>", X subject "test", '

                               'X sender Y, X recipients Y, X parts P '

                               'WHERE Y is EmailAddress, P is EmailPart')[0][0]

            cnx.execute('SET X sender Y WHERE X is Email, Y is EmailAddress')

            rset = cnx.execute('Any S WHERE X sender S, X eid %s' % eeid)

            self.assertEqual(len(rset), 1)

        with self.admin_access.repo_cnx() as cnx:

            u1 = self.create_user(cnx, u'1')

            u2 = self.create_user(cnx, u'2')

            u3 = self.create_user(cnx, u'3')

            ga = cnx.create_entity('CWGroup', name=u'A')

            gb = cnx.create_entity('CWGroup', name=u'B')

            u1.cw_set(friend=u2)

            u2.cw_set(friend=u3)

            ga.cw_set(friend=gb)

            ga.cw_set(friend=u1)

            cnx.commit()

            for l1, l2 in ((u'1', u'2'),

                           (u'2', u'3')):

                self.assertTrue(cnx.execute('Any U1,U2 WHERE U1 friend U2, U1 login %(l1)s, U2 login %(l2)s',

                                            {'l1': l1, 'l2': l2}))

                self.assertTrue(cnx.execute('Any U1,U2 WHERE U2 friend U1, U1 login %(l1)s, U2 login %(l2)s',

                                            {'l1': l1, 'l2': l2}))

            self.assertTrue(cnx.execute('Any GA,GB WHERE GA friend GB, GA name "A", GB name "B"'))

            self.assertTrue(cnx.execute('Any GA,GB WHERE GB friend GA, GA name "A", GB name "B"'))

            self.assertTrue(cnx.execute('Any GA,U1 WHERE GA friend U1, GA name "A", U1 login "1"'))

            self.assertTrue(cnx.execute('Any GA,U1 WHERE U1 friend GA, GA name "A", U1 login "1"'))

            self.assertFalse(cnx.execute('Any GA,U WHERE GA friend U, GA name "A", U login "2"'))

            for l1, l2 in ((u'1', u'3'),

                           (u'3', u'1')):

                self.assertFalse(cnx.execute('Any U1,U2 WHERE U1 friend U2, U1 login %(l1)s, U2 login %(l2)s',

                                             {'l1': l1, 'l2': l2}))

                self.assertFalse(cnx.execute('Any U1,U2 WHERE U2 friend U1, U1 login %(l1)s, U2 login %(l2)s',

                                             {'l1': l1, 'l2': l2}))

        with self.admin_access.web_request() as req:

            entity = req.create_entity('Workflow', name=u'wf1',

                                       description_format=u'text/html',

                                       description=u'yo')

            self.assertEqual(entity.description, u'yo')

            entity = req.create_entity('Workflow', name=u'wf2',

                                       description_format=u'text/html',

                                       description=u'<b>yo')

            self.assertEqual(entity.description, u'<b>yo</b>')

            entity = req.create_entity('Workflow', name=u'wf3',

                                       description_format=u'text/html',

                                       description=u'<b>yo</b>')

            self.assertEqual(entity.description, u'<b>yo</b>')

            entity = req.create_entity('Workflow', name=u'wf4',

                                       description_format=u'text/html',

                                       description=u'<b>R&D</b>')

            self.assertEqual(entity.description, u'<b>R&amp;D</b>')

            entity = req.create_entity('Workflow', name=u'wf5',

                                       description_format=u'text/html',

                                       description=u"<div>c&apos;est <b>l'ét&eacute;")

            self.assertEqual(entity.description, u"<div>c'est <b>l'été</b></div>")

        with self.admin_access.web_request() as req:

            entity = req.create_entity('Workflow', name=u'wf1',

                                       description_format=u'text/html',

                                       description=u'yo')

            entity.cw_set(name=u'wf2')

            self.assertEqual(entity.description, u'yo')

            entity.cw_set(description=u'R&D<p>yo')

            self.assertEqual(entity.description, u'R&amp;D<p>yo</p>')

        with self.admin_access.repo_cnx() as cnx:

            entity = cnx.create_entity('Workflow', name=u'wf1')

            self.assertEqual(entity.cwuri, self.repo.config['base-url'] + str(entity.eid))

        with self.admin_access.repo_cnx() as cnx:

            _now = datetime.now()

            entity = cnx.create_entity('Workflow', name=u'wf1')

            self.assertEqual((entity.creation_date - _now).seconds, 0)

            self.assertEqual((entity.modification_date - _now).seconds, 0)

        with self.admin_access.repo_cnx() as cnx:

            entity = cnx.create_entity('Bookmark', title=u'wf1', path=u'/view')

            cnx.commit() # fire operations

            self.assertEqual(len(entity.created_by), 1) # make sure we have only one creator

            self.assertEqual(entity.created_by[0].eid, self.session.user.eid)

        with self.admin_access.repo_cnx() as cnx:

            entity = cnx.create_entity('Bookmark', title=u'wf1', path=u'/view')

            cnx.commit() # fire operations

            self.assertEqual(len(entity.owned_by), 1) # make sure we have only one owner

            self.assertEqual(entity.owned_by[0].eid, self.session.user.eid)

        with self.admin_access.repo_cnx() as cnx:

            u = self.create_user(cnx, '  joe  ')

            tname = cnx.execute('Any L WHERE E login L, E eid %(e)s',

                                {'e': u.eid})[0][0]

            self.assertEqual(tname, 'joe')

            cnx.execute('SET X login " jijoe " WHERE X eid %(x)s', {'x': u.eid})

            tname = cnx.execute('Any L WHERE E login L, E eid %(e)s',

                                {'e': u.eid})[0][0]

            self.assertEqual(tname, 'jijoe')

        with self.admin_access.repo_cnx() as cnx:

            self.create_user(cnx, 'toto', password='hop', commit=False)

            self.assertRaises(AuthenticationError,

                              self.repo.connect, u'toto', password='hop')

            cnx.commit()

            cnxid = self.repo.connect(u'toto', password='hop')

            self.assertNotEqual(cnxid, self.session.id)

            cnx.execute('DELETE CWUser X WHERE X login "toto"')

            self.repo.execute(cnxid, 'State X')

            cnx.commit()

            self.assertRaises(BadConnectionId,

                              self.repo.execute, cnxid, 'State X')

        with self.admin_access.repo_cnx() as cnx:

            user = cnx.user

            self.assertEqual(user.groups, set(('managers',)))

            cnx.execute('SET X in_group G WHERE X eid %s, G name "guests"' % user.eid)

            self.assertEqual(user.groups, set(('managers',)))

            cnx.commit()

            self.assertEqual(user.groups, set(('managers', 'guests')))

            cnx.execute('DELETE X in_group G WHERE X eid %s, G name "guests"' % user.eid)

            self.assertEqual(user.groups, set(('managers', 'guests')))

            cnx.commit()

            self.assertEqual(user.groups, set(('managers',)))

        with self.admin_access.repo_cnx() as cnx:

            self.create_user(cnx, 'toto').eid

            # composite of euser should be owned by the euser regardless of who created it

            cnx.execute('INSERT EmailAddress X: X address "toto@logilab.fr", U use_email X '

                         'WHERE U login "toto"')

            cnx.commit()

            self.assertEqual(cnx.execute('Any A WHERE X owned_by U, U use_email X,'

                                           'U login "toto", X address A')[0][0],

                              'toto@logilab.fr')

        with self.admin_access.repo_cnx() as cnx:

            eid = cnx.execute('INSERT EmailAddress X: X address "toto@logilab.fr"')[0][0]

            cnx.execute('DELETE EmailAddress X WHERE X eid %s' % eid)

            cnx.commit()

            self.assertFalse(cnx.execute('Any X WHERE X created_by Y, X eid >= %(x)s', {'x': eid}))

        with self.admin_access.repo_cnx() as cnx:

            # check we can't add a CWEType or CWRType entity if it already exists one

            # with the same name

            self.assertRaises(ValidationError,

                              cnx.execute, 'INSERT CWEType X: X name "CWUser"')

            cnx.rollback()

            self.assertRaises(ValidationError,

                              cnx.execute, 'INSERT CWRType X: X name "in_group"')

        with self.admin_access.repo_cnx() as cnx:

            with self.assertRaises(ValidationError) as cm:

                cnx.execute('INSERT CWUser X: X login "admin"')

            ex = cm.exception

            ex.translate(unicode)

            self.assertIsInstance(ex.entity, int)

            self.assertEqual(ex.errors, {'login-subject': 'the value "admin" is already used, use another one'})