Conditions | 1 |
Total Lines | 18 |
Code Lines | 17 |
Lines | 0 |
Ratio | 0 % |
Changes | 0 |
1 | import json |
||
21 | @pytest.mark.asyncio |
||
22 | async def test_alias_serialization(event_loop): |
||
23 | alias = { 'g': 'g' } |
||
24 | message = '1 + 1' |
||
25 | cluster = await driver.Cluster.open(event_loop, aliases=alias, hosts=['gremlin-server']) |
||
26 | client = await cluster.connect() |
||
27 | # This is the code client/conn uses on submit |
||
28 | message = request.RequestMessage( |
||
29 | processor='', op='eval', |
||
30 | args={'gremlin': message, |
||
31 | 'aliases': client._aliases}) |
||
32 | request_id = str(uuid.uuid4()) |
||
33 | message = serializer.GraphSONMessageSerializer().serialize_message( |
||
34 | request_id, message) |
||
35 | message = message.decode('utf-8')[34:] |
||
36 | aliases = json.loads(message)['args']['aliases'] |
||
37 | assert aliases == alias |
||
38 | await cluster.close() |
||
39 |