|
1 |
| -queue = require('queue') |
| 1 | +local queue = require('queue') |
| 2 | +rawset(_G, 'queue', queue) |
2 | 3 |
|
3 | 4 | -- Do not set listen for now so connector won't be
|
4 | 5 | -- able to send requests until everything is configured.
|
5 | 6 | box.cfg{
|
6 | 7 | work_dir = os.getenv("TEST_TNT_WORK_DIR"),
|
7 | 8 | }
|
8 | 9 |
|
9 |
| -box.once("init", function() |
10 |
| -box.schema.user.create('test', {password = 'test'}) |
11 |
| -box.schema.func.create('queue.tube.test_queue:ack') |
12 |
| -box.schema.func.create('queue.tube.test_queue:put') |
13 |
| -box.schema.func.create('queue.tube.test_queue:drop') |
14 |
| -box.schema.func.create('queue.tube.test_queue:peek') |
15 |
| -box.schema.func.create('queue.tube.test_queue:kick') |
16 |
| -box.schema.func.create('queue.tube.test_queue:take') |
17 |
| -box.schema.func.create('queue.tube.test_queue:delete') |
18 |
| -box.schema.func.create('queue.tube.test_queue:release') |
19 |
| -box.schema.func.create('queue.tube.test_queue:bury') |
20 |
| -box.schema.func.create('queue.statistics') |
21 |
| -box.schema.user.grant('test', 'create', 'space') |
22 |
| -box.schema.user.grant('test', 'write', 'space', '_schema') |
23 |
| -box.schema.user.grant('test', 'write', 'space', '_space') |
24 |
| -box.schema.user.grant('test', 'read,write', 'space', '_space_sequence') |
25 |
| -box.schema.user.grant('test', 'write', 'space', '_index') |
26 |
| -box.schema.user.grant('test', 'read, write', 'space', '_queue_session_ids') |
27 |
| -box.schema.user.grant('test', 'execute', 'universe') |
28 |
| -box.schema.user.grant('test', 'read,write', 'space', '_queue') |
29 |
| -box.schema.user.grant('test', 'read,write', 'space', '_schema') |
30 |
| -box.schema.user.grant('test', 'read,write', 'space', '_space') |
31 |
| -box.schema.user.grant('test', 'read,write', 'space', '_index') |
32 |
| -box.schema.user.grant('test', 'read,write', 'space', '_queue_consumers') |
33 |
| -box.schema.user.grant('test', 'read,write', 'space', '_priv') |
34 |
| -box.schema.user.grant('test', 'read,write', 'space', '_queue_taken_2') |
35 |
| -if box.space._trigger ~= nil then |
36 |
| - box.schema.user.grant('test', 'read', 'space', '_trigger') |
37 |
| -end |
38 |
| -if box.space._fk_constraint ~= nil then |
39 |
| - box.schema.user.grant('test', 'read', 'space', '_fk_constraint') |
40 |
| -end |
41 |
| -if box.space._ck_constraint ~= nil then |
42 |
| - box.schema.user.grant('test', 'read', 'space', '_ck_constraint') |
43 |
| -end |
44 |
| -if box.space._func_index ~= nil then |
45 |
| - box.schema.user.grant('test', 'read', 'space', '_func_index') |
46 |
| -end |
| 10 | + box.once("init", function() |
| 11 | + box.schema.user.create('test', {password = 'test'}) |
| 12 | + box.schema.func.create('queue.tube.test_queue:ack') |
| 13 | + box.schema.func.create('queue.tube.test_queue:put') |
| 14 | + box.schema.func.create('queue.tube.test_queue:drop') |
| 15 | + box.schema.func.create('queue.tube.test_queue:peek') |
| 16 | + box.schema.func.create('queue.tube.test_queue:kick') |
| 17 | + box.schema.func.create('queue.tube.test_queue:take') |
| 18 | + box.schema.func.create('queue.tube.test_queue:delete') |
| 19 | + box.schema.func.create('queue.tube.test_queue:release') |
| 20 | + box.schema.func.create('queue.tube.test_queue:bury') |
| 21 | + box.schema.func.create('queue.statistics') |
| 22 | + box.schema.user.grant('test', 'create', 'space') |
| 23 | + box.schema.user.grant('test', 'write', 'space', '_schema') |
| 24 | + box.schema.user.grant('test', 'write', 'space', '_space') |
| 25 | + box.schema.user.grant('test', 'read,write', 'space', '_space_sequence') |
| 26 | + box.schema.user.grant('test', 'write', 'space', '_index') |
| 27 | + box.schema.user.grant('test', 'read, write', 'space', '_queue_session_ids') |
| 28 | + box.schema.user.grant('test', 'execute', 'universe') |
| 29 | + box.schema.user.grant('test', 'read,write', 'space', '_queue') |
| 30 | + box.schema.user.grant('test', 'read,write', 'space', '_schema') |
| 31 | + box.schema.user.grant('test', 'read,write', 'space', '_space') |
| 32 | + box.schema.user.grant('test', 'read,write', 'space', '_index') |
| 33 | + box.schema.user.grant('test', 'read,write', 'space', '_queue_consumers') |
| 34 | + box.schema.user.grant('test', 'read,write', 'space', '_priv') |
| 35 | + box.schema.user.grant('test', 'read,write', 'space', '_queue_taken_2') |
| 36 | + if box.space._trigger ~= nil then |
| 37 | + box.schema.user.grant('test', 'read', 'space', '_trigger') |
| 38 | + end |
| 39 | + if box.space._fk_constraint ~= nil then |
| 40 | + box.schema.user.grant('test', 'read', 'space', '_fk_constraint') |
| 41 | + end |
| 42 | + if box.space._ck_constraint ~= nil then |
| 43 | + box.schema.user.grant('test', 'read', 'space', '_ck_constraint') |
| 44 | + end |
| 45 | + if box.space._func_index ~= nil then |
| 46 | + box.schema.user.grant('test', 'read', 'space', '_func_index') |
| 47 | + end |
47 | 48 | end)
|
48 | 49 |
|
49 | 50 | -- Set listen only when every other thing is configured.
|
|
0 commit comments