author | Aurelien Campeas <aurelien.campeas@logilab.fr> |
Thu, 09 Jul 2009 16:44:34 +0200 | |
branch | stable |
changeset 2360 | 1d43aa551ba9 |
parent 2200 | 25bb65dc4559 |
child 2588 | 3a590ff82e99 |
permissions | -rw-r--r-- |
0 | 1 |
# -*- coding: iso-8859-1 -*- |
1977
606923dff11b
big bunch of copyright / docstring update
Adrien Di Mascio <Adrien.DiMascio@logilab.fr>
parents:
1954
diff
changeset
|
2 |
"""unit tests for module cubicweb.server.repository |
606923dff11b
big bunch of copyright / docstring update
Adrien Di Mascio <Adrien.DiMascio@logilab.fr>
parents:
1954
diff
changeset
|
3 |
|
606923dff11b
big bunch of copyright / docstring update
Adrien Di Mascio <Adrien.DiMascio@logilab.fr>
parents:
1954
diff
changeset
|
4 |
:organization: Logilab |
606923dff11b
big bunch of copyright / docstring update
Adrien Di Mascio <Adrien.DiMascio@logilab.fr>
parents:
1954
diff
changeset
|
5 |
:copyright: 2001-2009 LOGILAB S.A. (Paris, FRANCE), license is LGPL v2. |
606923dff11b
big bunch of copyright / docstring update
Adrien Di Mascio <Adrien.DiMascio@logilab.fr>
parents:
1954
diff
changeset
|
6 |
:contact: http://www.logilab.fr/ -- mailto:contact@logilab.fr |
606923dff11b
big bunch of copyright / docstring update
Adrien Di Mascio <Adrien.DiMascio@logilab.fr>
parents:
1954
diff
changeset
|
7 |
:license: GNU Lesser General Public License, v2.1 - http://www.gnu.org/licenses |
606923dff11b
big bunch of copyright / docstring update
Adrien Di Mascio <Adrien.DiMascio@logilab.fr>
parents:
1954
diff
changeset
|
8 |
""" |
0 | 9 |
|
10 |
import os |
|
11 |
import sys |
|
12 |
import threading |
|
13 |
import time |
|
14 |
from copy import deepcopy |
|
1016
26387b836099
use datetime instead of mx.DateTime
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
15 |
from datetime import datetime |
1251
af40e615dc89
introduce a 'cw_' prefix on entity table and column names so we don't conflict with sql or DBMS specific keywords
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
16 |
|
0 | 17 |
from logilab.common.testlib import TestCase, unittest_main |
18 |
||
19 |
from yams.constraints import UniqueConstraint |
|
20 |
||
21 |
from cubicweb import BadConnectionId, RepositoryError, ValidationError, UnknownEid, AuthenticationError |
|
22 |
from cubicweb.schema import CubicWebSchema, RQLConstraint |
|
23 |
from cubicweb.dbapi import connect, repo_connect |
|
1251
af40e615dc89
introduce a 'cw_' prefix on entity table and column names so we don't conflict with sql or DBMS specific keywords
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
24 |
from cubicweb.devtools.apptest import RepositoryBasedTC |
af40e615dc89
introduce a 'cw_' prefix on entity table and column names so we don't conflict with sql or DBMS specific keywords
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
25 |
from cubicweb.devtools.repotest import tuplify |
1787 | 26 |
from cubicweb.server import repository |
1251
af40e615dc89
introduce a 'cw_' prefix on entity table and column names so we don't conflict with sql or DBMS specific keywords
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
27 |
from cubicweb.server.sqlutils import SQL_PREFIX |
0 | 28 |
|
29 |
||
30 |
# start name server anyway, process will fail if already running |
|
31 |
os.system('pyro-ns >/dev/null 2>/dev/null &') |
|
32 |
||
33 |
||
34 |
class RepositoryTC(RepositoryBasedTC): |
|
35 |
""" singleton providing access to a persistent storage for entities |
|
36 |
and relation |
|
37 |
""" |
|
1787 | 38 |
|
0 | 39 |
# def setUp(self): |
40 |
# pass |
|
1787 | 41 |
|
0 | 42 |
# def tearDown(self): |
43 |
# self.repo.config.db_perms = True |
|
44 |
# cnxid = self.repo.connect(*self.default_user_password()) |
|
45 |
# for etype in ('Affaire', 'Note', 'Societe', 'Personne'): |
|
46 |
# self.repo.execute(cnxid, 'DELETE %s X' % etype) |
|
47 |
# self.repo.commit(cnxid) |
|
48 |
# self.repo.close(cnxid) |
|
49 |
||
50 |
def test_fill_schema(self): |
|
51 |
self.repo.schema = CubicWebSchema(self.repo.config.appid) |
|
52 |
self.repo.config._cubes = None # avoid assertion error |
|
53 |
self.repo.fill_schema() |
|
54 |
pool = self.repo._get_pool() |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
55 |
table = SQL_PREFIX + 'CWEType' |
1251
af40e615dc89
introduce a 'cw_' prefix on entity table and column names so we don't conflict with sql or DBMS specific keywords
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
56 |
namecol = SQL_PREFIX + 'name' |
af40e615dc89
introduce a 'cw_' prefix on entity table and column names so we don't conflict with sql or DBMS specific keywords
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
57 |
finalcol = SQL_PREFIX + 'final' |
0 | 58 |
try: |
2200
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
59 |
cu = self.session.system_sql('SELECT %s FROM %s WHERE %s is NULL' % ( |
1251
af40e615dc89
introduce a 'cw_' prefix on entity table and column names so we don't conflict with sql or DBMS specific keywords
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
60 |
namecol, table, finalcol)) |
2200
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
61 |
self.assertEquals(cu.fetchall(), []) |
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
62 |
cu = self.session.system_sql('SELECT %s FROM %s WHERE %s=%%(final)s ORDER BY %s' |
1251
af40e615dc89
introduce a 'cw_' prefix on entity table and column names so we don't conflict with sql or DBMS specific keywords
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
63 |
% (namecol, table, finalcol, namecol), {'final': 'TRUE'}) |
2200
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
64 |
self.assertEquals(cu.fetchall(), [(u'Boolean',), (u'Bytes',), |
0 | 65 |
(u'Date',), (u'Datetime',), |
66 |
(u'Decimal',),(u'Float',), |
|
67 |
(u'Int',), |
|
68 |
(u'Interval',), (u'Password',), |
|
69 |
(u'String',), (u'Time',)]) |
|
70 |
finally: |
|
71 |
self.repo._free_pool(pool) |
|
1787 | 72 |
|
0 | 73 |
def test_schema_has_owner(self): |
74 |
repo = self.repo |
|
75 |
cnxid = repo.connect(*self.default_user_password()) |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
76 |
self.failIf(repo.execute(cnxid, 'CWEType X WHERE NOT X owned_by U')) |
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
77 |
self.failIf(repo.execute(cnxid, 'CWRType X WHERE NOT X owned_by U')) |
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
78 |
self.failIf(repo.execute(cnxid, 'CWAttribute X WHERE NOT X owned_by U')) |
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
79 |
self.failIf(repo.execute(cnxid, 'CWRelation X WHERE NOT X owned_by U')) |
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
80 |
self.failIf(repo.execute(cnxid, 'CWConstraint X WHERE NOT X owned_by U')) |
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
81 |
self.failIf(repo.execute(cnxid, 'CWConstraintType X WHERE NOT X owned_by U')) |
1787 | 82 |
|
0 | 83 |
def test_connect(self): |
84 |
login, passwd = self.default_user_password() |
|
85 |
self.assert_(self.repo.connect(login, passwd)) |
|
86 |
self.assertRaises(AuthenticationError, |
|
87 |
self.repo.connect, login, 'nimportnawak') |
|
88 |
self.assertRaises(AuthenticationError, |
|
89 |
self.repo.connect, login, None) |
|
90 |
self.assertRaises(AuthenticationError, |
|
91 |
self.repo.connect, None, None) |
|
1787 | 92 |
|
0 | 93 |
def test_execute(self): |
94 |
repo = self.repo |
|
95 |
cnxid = repo.connect(*self.default_user_password()) |
|
96 |
repo.execute(cnxid, 'Any X') |
|
97 |
repo.execute(cnxid, 'Any X where X is Personne') |
|
98 |
repo.execute(cnxid, 'Any X where X is Personne, X nom ~= "to"') |
|
99 |
repo.execute(cnxid, 'Any X WHERE X has_text %(text)s', {'text': u'\xe7a'}) |
|
100 |
repo.close(cnxid) |
|
1787 | 101 |
|
0 | 102 |
def test_login_upassword_accent(self): |
103 |
repo = self.repo |
|
104 |
cnxid = repo.connect(*self.default_user_password()) |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
105 |
repo.execute(cnxid, 'INSERT CWUser X: X login %(login)s, X upassword %(passwd)s, X in_state S, X in_group G WHERE S name "activated", G name "users"', |
0 | 106 |
{'login': u"barnab�", 'passwd': u"h�h�h�".encode('UTF8')}) |
107 |
repo.commit(cnxid) |
|
108 |
repo.close(cnxid) |
|
109 |
self.assert_(repo.connect(u"barnab�", u"h�h�h�".encode('UTF8'))) |
|
1787 | 110 |
|
0 | 111 |
def test_invalid_entity_rollback(self): |
112 |
repo = self.repo |
|
113 |
cnxid = repo.connect(*self.default_user_password()) |
|
1787 | 114 |
# no group |
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
115 |
repo.execute(cnxid, 'INSERT CWUser X: X login %(login)s, X upassword %(passwd)s, X in_state S WHERE S name "activated"', |
0 | 116 |
{'login': u"tutetute", 'passwd': 'tutetute'}) |
117 |
self.assertRaises(ValidationError, repo.commit, cnxid) |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
118 |
rset = repo.execute(cnxid, 'CWUser X WHERE X login "tutetute"') |
0 | 119 |
self.assertEquals(rset.rowcount, 0) |
1787 | 120 |
|
0 | 121 |
def test_close(self): |
122 |
repo = self.repo |
|
123 |
cnxid = repo.connect(*self.default_user_password()) |
|
124 |
self.assert_(cnxid) |
|
125 |
repo.close(cnxid) |
|
126 |
self.assertRaises(BadConnectionId, repo.execute, cnxid, 'Any X') |
|
1787 | 127 |
|
0 | 128 |
def test_invalid_cnxid(self): |
129 |
self.assertRaises(BadConnectionId, self.repo.execute, 0, 'Any X') |
|
130 |
self.assertRaises(BadConnectionId, self.repo.close, None) |
|
1787 | 131 |
|
0 | 132 |
def test_shared_data(self): |
133 |
repo = self.repo |
|
134 |
cnxid = repo.connect(*self.default_user_password()) |
|
135 |
repo.set_shared_data(cnxid, 'data', 4) |
|
136 |
cnxid2 = repo.connect(*self.default_user_password()) |
|
137 |
self.assertEquals(repo.get_shared_data(cnxid, 'data'), 4) |
|
138 |
self.assertEquals(repo.get_shared_data(cnxid2, 'data'), None) |
|
139 |
repo.set_shared_data(cnxid2, 'data', 5) |
|
140 |
self.assertEquals(repo.get_shared_data(cnxid, 'data'), 4) |
|
141 |
self.assertEquals(repo.get_shared_data(cnxid2, 'data'), 5) |
|
142 |
repo.get_shared_data(cnxid2, 'data', pop=True) |
|
143 |
self.assertEquals(repo.get_shared_data(cnxid, 'data'), 4) |
|
144 |
self.assertEquals(repo.get_shared_data(cnxid2, 'data'), None) |
|
145 |
repo.close(cnxid) |
|
146 |
repo.close(cnxid2) |
|
147 |
self.assertRaises(BadConnectionId, repo.get_shared_data, cnxid, 'data') |
|
148 |
self.assertRaises(BadConnectionId, repo.get_shared_data, cnxid2, 'data') |
|
149 |
self.assertRaises(BadConnectionId, repo.set_shared_data, cnxid, 'data', 1) |
|
150 |
self.assertRaises(BadConnectionId, repo.set_shared_data, cnxid2, 'data', 1) |
|
151 |
||
152 |
def test_check_session(self): |
|
153 |
repo = self.repo |
|
154 |
cnxid = repo.connect(*self.default_user_password()) |
|
155 |
self.assertEquals(repo.check_session(cnxid), None) |
|
156 |
repo.close(cnxid) |
|
157 |
self.assertRaises(BadConnectionId, repo.check_session, cnxid) |
|
158 |
||
159 |
def test_transaction_base(self): |
|
160 |
repo = self.repo |
|
161 |
cnxid = repo.connect(*self.default_user_password()) |
|
162 |
# check db state |
|
163 |
result = repo.execute(cnxid, 'Personne X') |
|
164 |
self.assertEquals(result.rowcount, 0) |
|
165 |
# rollback entity insertion |
|
166 |
repo.execute(cnxid, "INSERT Personne X: X nom 'bidule'") |
|
167 |
result = repo.execute(cnxid, 'Personne X') |
|
168 |
self.assertEquals(result.rowcount, 1) |
|
169 |
repo.rollback(cnxid) |
|
170 |
result = repo.execute(cnxid, 'Personne X') |
|
171 |
self.assertEquals(result.rowcount, 0, result.rows) |
|
172 |
# commit |
|
173 |
repo.execute(cnxid, "INSERT Personne X: X nom 'bidule'") |
|
174 |
repo.commit(cnxid) |
|
175 |
result = repo.execute(cnxid, 'Personne X') |
|
176 |
self.assertEquals(result.rowcount, 1) |
|
177 |
||
178 |
def test_transaction_base2(self): |
|
179 |
repo = self.repo |
|
180 |
cnxid = repo.connect(*self.default_user_password()) |
|
181 |
# rollback relation insertion |
|
182 |
repo.execute(cnxid, "SET U in_group G WHERE U login 'admin', G name 'guests'") |
|
183 |
result = repo.execute(cnxid, "Any U WHERE U in_group G, U login 'admin', G name 'guests'") |
|
184 |
self.assertEquals(result.rowcount, 1) |
|
185 |
repo.rollback(cnxid) |
|
186 |
result = repo.execute(cnxid, "Any U WHERE U in_group G, U login 'admin', G name 'guests'") |
|
187 |
self.assertEquals(result.rowcount, 0, result.rows) |
|
1787 | 188 |
|
0 | 189 |
def test_transaction_base3(self): |
190 |
repo = self.repo |
|
191 |
cnxid = repo.connect(*self.default_user_password()) |
|
192 |
# rollback state change which trigger TrInfo insertion |
|
193 |
ueid = repo._get_session(cnxid).user.eid |
|
194 |
rset = repo.execute(cnxid, 'TrInfo T WHERE T wf_info_for X, X eid %(x)s', {'x': ueid}) |
|
195 |
self.assertEquals(len(rset), 1) |
|
196 |
repo.execute(cnxid, 'SET X in_state S WHERE X eid %(x)s, S name "deactivated"', |
|
197 |
{'x': ueid}, 'x') |
|
198 |
rset = repo.execute(cnxid, 'TrInfo T WHERE T wf_info_for X, X eid %(x)s', {'x': ueid}) |
|
199 |
self.assertEquals(len(rset), 2) |
|
200 |
repo.rollback(cnxid) |
|
201 |
rset = repo.execute(cnxid, 'TrInfo T WHERE T wf_info_for X, X eid %(x)s', {'x': ueid}) |
|
202 |
self.assertEquals(len(rset), 1) |
|
1787 | 203 |
|
0 | 204 |
def test_transaction_interleaved(self): |
205 |
self.skip('implement me') |
|
206 |
||
1880
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
207 |
def test_close_wait_processing_request(self): |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
208 |
repo = self.repo |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
209 |
cnxid = repo.connect(*self.default_user_password()) |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
210 |
repo.execute(cnxid, 'INSERT CWUser X: X login "toto", X upassword "tutu", X in_group G WHERE G name "users"') |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
211 |
repo.commit(cnxid) |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
212 |
# close has to be in the thread due to sqlite limitations |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
213 |
def close_in_a_few_moment(): |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
214 |
time.sleep(0.1) |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
215 |
repo.close(cnxid) |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
216 |
t = threading.Thread(target=close_in_a_few_moment) |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
217 |
t.start() |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
218 |
try: |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
219 |
repo.execute(cnxid, 'DELETE CWUser X WHERE X login "toto"') |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
220 |
repo.commit(cnxid) |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
221 |
finally: |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
222 |
t.join() |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
223 |
|
0 | 224 |
def test_initial_schema(self): |
225 |
schema = self.repo.schema |
|
226 |
# check order of attributes is respected |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
227 |
self.assertListEquals([r.type for r in schema.eschema('CWAttribute').ordered_relations() |
1787 | 228 |
if not r.type in ('eid', 'is', 'is_instance_of', 'identity', |
0 | 229 |
'creation_date', 'modification_date', |
230 |
'owned_by', 'created_by')], |
|
231 |
['relation_type', 'from_entity', 'to_entity', 'constrained_by', |
|
1787 | 232 |
'cardinality', 'ordernum', |
0 | 233 |
'indexed', 'fulltextindexed', 'internationalizable', |
234 |
'defaultval', 'description_format', 'description']) |
|
235 |
||
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
236 |
self.assertEquals(schema.eschema('CWEType').main_attribute(), 'name') |
0 | 237 |
self.assertEquals(schema.eschema('State').main_attribute(), 'name') |
238 |
||
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
239 |
constraints = schema.rschema('name').rproperty('CWEType', 'String', 'constraints') |
0 | 240 |
self.assertEquals(len(constraints), 2) |
241 |
for cstr in constraints[:]: |
|
242 |
if isinstance(cstr, UniqueConstraint): |
|
243 |
constraints.remove(cstr) |
|
244 |
break |
|
245 |
else: |
|
246 |
self.fail('unique constraint not found') |
|
247 |
sizeconstraint = constraints[0] |
|
248 |
self.assertEquals(sizeconstraint.min, None) |
|
249 |
self.assertEquals(sizeconstraint.max, 64) |
|
250 |
||
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
251 |
constraints = schema.rschema('relation_type').rproperty('CWAttribute', 'CWRType', 'constraints') |
0 | 252 |
self.assertEquals(len(constraints), 1) |
253 |
cstr = constraints[0] |
|
254 |
self.assert_(isinstance(cstr, RQLConstraint)) |
|
255 |
self.assertEquals(cstr.restriction, 'O final TRUE') |
|
256 |
||
257 |
ownedby = schema.rschema('owned_by') |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
258 |
self.assertEquals(ownedby.objects('CWEType'), ('CWUser',)) |
0 | 259 |
|
260 |
def test_pyro(self): |
|
261 |
import Pyro |
|
262 |
Pyro.config.PYRO_MULTITHREADED = 0 |
|
1880
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
263 |
done = [] |
0 | 264 |
# the client part has to be in the thread due to sqlite limitations |
1880
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
265 |
t = threading.Thread(target=self._pyro_client, args=(done,)) |
0 | 266 |
try: |
267 |
daemon = self.repo.pyro_register() |
|
268 |
t.start() |
|
1880
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
269 |
while not done: |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
270 |
daemon.handleRequests(1.0) |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
271 |
t.join(1) |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
272 |
if t.isAlive(): |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
273 |
self.fail('something went wrong, thread still alive') |
0 | 274 |
finally: |
275 |
repository.pyro_unregister(self.repo.config) |
|
1787 | 276 |
|
1880
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
277 |
def _pyro_client(self, done): |
0 | 278 |
cnx = connect(self.repo.config.appid, u'admin', 'gingkow') |
279 |
# check we can get the schema |
|
280 |
schema = cnx.get_schema() |
|
281 |
self.assertEquals(schema.__hashmode__, None) |
|
1880
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
282 |
cu = cnx.cursor() |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
283 |
rset = cu.execute('Any U,G WHERE U in_group G') |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
284 |
cnx.close() |
293fe4b49e28
two in one: #343320: Logging out while deleting a CWUser blocks the cw server / #342692: ensure transaction state when Ctrl-C or other stop signal is received
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1787
diff
changeset
|
285 |
done.append(True) |
0 | 286 |
|
287 |
def test_internal_api(self): |
|
288 |
repo = self.repo |
|
289 |
cnxid = repo.connect(*self.default_user_password()) |
|
290 |
session = repo._get_session(cnxid, setpool=True) |
|
1954 | 291 |
self.assertEquals(repo.type_and_source_from_eid(1, session), |
292 |
('CWGroup', 'system', None)) |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
293 |
self.assertEquals(repo.type_from_eid(1, session), 'CWGroup') |
0 | 294 |
self.assertEquals(repo.source_from_eid(1, session).uri, 'system') |
295 |
self.assertEquals(repo.eid2extid(repo.system_source, 1, session), None) |
|
296 |
class dummysource: uri = 'toto' |
|
297 |
self.assertRaises(UnknownEid, repo.eid2extid, dummysource, 1, session) |
|
298 |
||
299 |
def test_public_api(self): |
|
300 |
self.assertEquals(self.repo.get_schema(), self.repo.schema) |
|
301 |
self.assertEquals(self.repo.source_defs(), {'system': {'adapter': 'native', 'uri': 'system'}}) |
|
302 |
# .properties() return a result set |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
303 |
self.assertEquals(self.repo.properties().rql, 'Any K,V WHERE P is CWProperty,P pkey K, P value V, NOT P for_user U') |
0 | 304 |
|
305 |
def test_session_api(self): |
|
306 |
repo = self.repo |
|
307 |
cnxid = repo.connect(*self.default_user_password()) |
|
308 |
self.assertEquals(repo.user_info(cnxid), (5, 'admin', set([u'managers']), {})) |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
309 |
self.assertEquals(repo.describe(cnxid, 1), (u'CWGroup', u'system', None)) |
0 | 310 |
repo.close(cnxid) |
311 |
self.assertRaises(BadConnectionId, repo.user_info, cnxid) |
|
312 |
self.assertRaises(BadConnectionId, repo.describe, cnxid, 1) |
|
313 |
||
314 |
def test_shared_data_api(self): |
|
315 |
repo = self.repo |
|
316 |
cnxid = repo.connect(*self.default_user_password()) |
|
317 |
self.assertEquals(repo.get_shared_data(cnxid, 'data'), None) |
|
318 |
repo.set_shared_data(cnxid, 'data', 4) |
|
319 |
self.assertEquals(repo.get_shared_data(cnxid, 'data'), 4) |
|
320 |
repo.get_shared_data(cnxid, 'data', pop=True) |
|
321 |
repo.get_shared_data(cnxid, 'whatever', pop=True) |
|
322 |
self.assertEquals(repo.get_shared_data(cnxid, 'data'), None) |
|
323 |
repo.close(cnxid) |
|
324 |
self.assertRaises(BadConnectionId, repo.set_shared_data, cnxid, 'data', 0) |
|
325 |
self.assertRaises(BadConnectionId, repo.get_shared_data, cnxid, 'data') |
|
1787 | 326 |
|
0 | 327 |
|
328 |
class DataHelpersTC(RepositoryBasedTC): |
|
1787 | 329 |
|
0 | 330 |
def setUp(self): |
331 |
""" called before each test from this class """ |
|
332 |
cnxid = self.repo.connect(*self.default_user_password()) |
|
333 |
self.session = self.repo._sessions[cnxid] |
|
334 |
self.session.set_pool() |
|
335 |
||
336 |
def tearDown(self): |
|
337 |
self.session.rollback() |
|
1787 | 338 |
|
0 | 339 |
def test_create_eid(self): |
340 |
self.assert_(self.repo.system_source.create_eid(self.session)) |
|
341 |
||
342 |
def test_source_from_eid(self): |
|
343 |
self.assertEquals(self.repo.source_from_eid(1, self.session), |
|
344 |
self.repo.sources_by_uri['system']) |
|
345 |
||
346 |
def test_source_from_eid_raise(self): |
|
347 |
self.assertRaises(UnknownEid, self.repo.source_from_eid, -2, self.session) |
|
348 |
||
349 |
def test_type_from_eid(self): |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
350 |
self.assertEquals(self.repo.type_from_eid(1, self.session), 'CWGroup') |
1787 | 351 |
|
0 | 352 |
def test_type_from_eid_raise(self): |
353 |
self.assertRaises(UnknownEid, self.repo.type_from_eid, -2, self.session) |
|
1787 | 354 |
|
0 | 355 |
def test_add_delete_info(self): |
356 |
entity = self.repo.vreg.etype_class('Personne')(self.session, None, None) |
|
357 |
entity.eid = -1 |
|
358 |
entity.complete = lambda x: None |
|
359 |
self.repo.add_info(self.session, entity, self.repo.sources_by_uri['system']) |
|
2200
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
360 |
cu = self.session.system_sql('SELECT * FROM entities WHERE eid = -1') |
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
361 |
data = cu.fetchall() |
1016
26387b836099
use datetime instead of mx.DateTime
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
362 |
self.assertIsInstance(data[0][3], datetime) |
0 | 363 |
data[0] = list(data[0]) |
364 |
data[0][3] = None |
|
365 |
self.assertEquals(tuplify(data), [(-1, 'Personne', 'system', None, None)]) |
|
366 |
self.repo.delete_info(self.session, -1) |
|
367 |
#self.repo.commit() |
|
2200
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
368 |
cu = self.session.system_sql('SELECT * FROM entities WHERE eid = -1') |
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
369 |
data = cu.fetchall() |
0 | 370 |
self.assertEquals(data, []) |
371 |
||
372 |
||
373 |
class FTITC(RepositoryBasedTC): |
|
1787 | 374 |
|
0 | 375 |
def test_reindex_and_modified_since(self): |
376 |
eidp = self.execute('INSERT Personne X: X nom "toto", X prenom "tutu"')[0][0] |
|
377 |
self.commit() |
|
1016
26387b836099
use datetime instead of mx.DateTime
sylvain.thenault@logilab.fr
parents:
17
diff
changeset
|
378 |
ts = datetime.now() |
0 | 379 |
self.assertEquals(len(self.execute('Personne X WHERE X has_text "tutu"')), 1) |
2200
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
380 |
cu = self.session.system_sql('SELECT mtime, eid FROM entities WHERE eid = %s' % eidp) |
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
381 |
omtime = cu.fetchone()[0] |
0 | 382 |
# our sqlite datetime adapter is ignore seconds fraction, so we have to |
383 |
# ensure update is done the next seconds |
|
384 |
time.sleep(1 - (ts.second - int(ts.second))) |
|
385 |
self.execute('SET X nom "tata" WHERE X eid %(x)s', {'x': eidp}, 'x') |
|
386 |
self.commit() |
|
387 |
self.assertEquals(len(self.execute('Personne X WHERE X has_text "tutu"')), 1) |
|
2200
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
388 |
cu = self.session.system_sql('SELECT mtime FROM entities WHERE eid = %s' % eidp) |
25bb65dc4559
test fixes, all server tests ok, except unittest_migractions (due to inter-tests-side-effects...)
Sylvain Thénault <sylvain.thenault@logilab.fr>
parents:
1977
diff
changeset
|
389 |
mtime = cu.fetchone()[0] |
0 | 390 |
self.failUnless(omtime < mtime) |
391 |
self.commit() |
|
392 |
date, modified, deleted = self.repo.entities_modified_since(('Personne',), omtime) |
|
393 |
self.assertEquals(modified, [('Personne', eidp)]) |
|
394 |
self.assertEquals(deleted, []) |
|
395 |
date, modified, deleted = self.repo.entities_modified_since(('Personne',), mtime) |
|
396 |
self.assertEquals(modified, []) |
|
397 |
self.assertEquals(deleted, []) |
|
398 |
self.execute('DELETE Personne X WHERE X eid %(x)s', {'x': eidp}) |
|
399 |
self.commit() |
|
400 |
date, modified, deleted = self.repo.entities_modified_since(('Personne',), omtime) |
|
401 |
self.assertEquals(modified, []) |
|
402 |
self.assertEquals(deleted, [('Personne', eidp)]) |
|
403 |
||
404 |
def test_composite_entity(self): |
|
405 |
assert self.schema.rschema('use_email').fulltext_container == 'subject' |
|
406 |
eid = self.add_entity('EmailAddress', address=u'toto@logilab.fr').eid |
|
407 |
self.commit() |
|
408 |
rset = self.execute('Any X WHERE X has_text %(t)s', {'t': 'toto'}) |
|
409 |
self.assertEquals(rset.rows, [[eid]]) |
|
410 |
self.execute('SET X use_email Y WHERE X login "admin", Y eid %(y)s', {'y': eid}) |
|
411 |
self.commit() |
|
412 |
rset = self.execute('Any X WHERE X has_text %(t)s', {'t': 'toto'}) |
|
413 |
self.assertEquals(rset.rows, [[self.session.user.eid]]) |
|
414 |
self.execute('DELETE X use_email Y WHERE X login "admin", Y eid %(y)s', {'y': eid}) |
|
415 |
self.commit() |
|
416 |
rset = self.execute('Any X WHERE X has_text %(t)s', {'t': 'toto'}) |
|
417 |
self.assertEquals(rset.rows, []) |
|
418 |
eid = self.add_entity('EmailAddress', address=u'tutu@logilab.fr').eid |
|
419 |
self.execute('SET X use_email Y WHERE X login "admin", Y eid %(y)s', {'y': eid}) |
|
420 |
self.commit() |
|
421 |
rset = self.execute('Any X WHERE X has_text %(t)s', {'t': 'tutu'}) |
|
422 |
self.assertEquals(rset.rows, [[self.session.user.eid]]) |
|
1787 | 423 |
|
424 |
||
0 | 425 |
class DBInitTC(RepositoryBasedTC): |
1787 | 426 |
|
0 | 427 |
def test_versions_inserted(self): |
428 |
inserted = [r[0] for r in self.execute('Any K ORDERBY K WHERE P pkey K, P pkey ~= "system.version.%"')] |
|
429 |
self.assertEquals(inserted, |
|
1787 | 430 |
[u'system.version.basket', u'system.version.card', u'system.version.comment', |
431 |
u'system.version.cubicweb', u'system.version.email', |
|
432 |
u'system.version.file', u'system.version.folder', |
|
17
62ce3e6126e0
work in progress: fix cubicweb/server tests
Adrien Di Mascio <Adrien.DiMascio@logilab.fr>
parents:
0
diff
changeset
|
433 |
u'system.version.tag']) |
1787 | 434 |
|
0 | 435 |
class InlineRelHooksTC(RepositoryBasedTC): |
436 |
"""test relation hooks are called for inlined relations |
|
437 |
""" |
|
438 |
def setUp(self): |
|
439 |
RepositoryBasedTC.setUp(self) |
|
440 |
self.hm = self.repo.hm |
|
441 |
self.called = [] |
|
1787 | 442 |
|
0 | 443 |
def _before_relation_hook(self, pool, fromeid, rtype, toeid): |
444 |
self.called.append((fromeid, rtype, toeid)) |
|
445 |
||
446 |
def _after_relation_hook(self, pool, fromeid, rtype, toeid): |
|
447 |
self.called.append((fromeid, rtype, toeid)) |
|
1787 | 448 |
|
0 | 449 |
def test_before_add_inline_relation(self): |
450 |
"""make sure before_<event>_relation hooks are called directly""" |
|
451 |
self.hm.register_hook(self._before_relation_hook, |
|
452 |
'before_add_relation', 'ecrit_par') |
|
453 |
eidp = self.execute('INSERT Personne X: X nom "toto"')[0][0] |
|
454 |
eidn = self.execute('INSERT Note X: X type "T"')[0][0] |
|
455 |
self.execute('SET N ecrit_par Y WHERE N type "T", Y nom "toto"') |
|
456 |
self.assertEquals(self.called, [(eidn, 'ecrit_par', eidp)]) |
|
1787 | 457 |
|
0 | 458 |
def test_after_add_inline_relation(self): |
459 |
"""make sure after_<event>_relation hooks are deferred""" |
|
460 |
self.hm.register_hook(self._after_relation_hook, |
|
461 |
'after_add_relation', 'ecrit_par') |
|
462 |
eidp = self.execute('INSERT Personne X: X nom "toto"')[0][0] |
|
463 |
eidn = self.execute('INSERT Note X: X type "T"')[0][0] |
|
464 |
self.assertEquals(self.called, []) |
|
465 |
self.execute('SET N ecrit_par Y WHERE N type "T", Y nom "toto"') |
|
466 |
self.assertEquals(self.called, [(eidn, 'ecrit_par', eidp,)]) |
|
1787 | 467 |
|
0 | 468 |
def test_after_add_inline(self): |
469 |
"""make sure after_<event>_relation hooks are deferred""" |
|
470 |
self.hm.register_hook(self._after_relation_hook, |
|
471 |
'after_add_relation', 'in_state') |
|
1398
5fe84a5f7035
rename internal entity types to have CW prefix instead of E
sylvain.thenault@logilab.fr
parents:
1263
diff
changeset
|
472 |
eidp = self.execute('INSERT CWUser X: X login "toto", X upassword "tutu", X in_state S WHERE S name "activated"')[0][0] |
0 | 473 |
eids = self.execute('State X WHERE X name "activated"')[0][0] |
474 |
self.assertEquals(self.called, [(eidp, 'in_state', eids,)]) |
|
1787 | 475 |
|
0 | 476 |
def test_before_delete_inline_relation(self): |
477 |
"""make sure before_<event>_relation hooks are called directly""" |
|
478 |
self.hm.register_hook(self._before_relation_hook, |
|
479 |
'before_delete_relation', 'ecrit_par') |
|
480 |
eidp = self.execute('INSERT Personne X: X nom "toto"')[0][0] |
|
481 |
eidn = self.execute('INSERT Note X: X type "T"')[0][0] |
|
482 |
self.execute('SET N ecrit_par Y WHERE N type "T", Y nom "toto"') |
|
483 |
self.execute('DELETE N ecrit_par Y WHERE N type "T", Y nom "toto"') |
|
484 |
self.assertEquals(self.called, [(eidn, 'ecrit_par', eidp)]) |
|
485 |
rset = self.execute('Any Y where N ecrit_par Y, N type "T", Y nom "toto"') |
|
486 |
# make sure the relation is really deleted |
|
487 |
self.failUnless(len(rset) == 0, "failed to delete inline relation") |
|
488 |
||
489 |
def test_after_delete_inline_relation(self): |
|
490 |
"""make sure after_<event>_relation hooks are deferred""" |
|
491 |
self.hm.register_hook(self._after_relation_hook, |
|
492 |
'after_delete_relation', 'ecrit_par') |
|
493 |
eidp = self.execute('INSERT Personne X: X nom "toto"')[0][0] |
|
494 |
eidn = self.execute('INSERT Note X: X type "T"')[0][0] |
|
495 |
self.execute('SET N ecrit_par Y WHERE N type "T", Y nom "toto"') |
|
496 |
self.assertEquals(self.called, []) |
|
497 |
self.execute('DELETE N ecrit_par Y WHERE N type "T", Y nom "toto"') |
|
498 |
self.assertEquals(self.called, [(eidn, 'ecrit_par', eidp,)]) |
|
499 |
||
1787 | 500 |
|
0 | 501 |
if __name__ == '__main__': |
502 |
unittest_main() |