|
9 | 9 | Supports working with data returned by the v1/eval and v1/invoke endpoints. |
10 | 10 | """ |
11 | 11 |
|
12 | | -__primitive_value_converters = { |
13 | | - "integer": lambda part: int(part.text), |
14 | | - "decimal": lambda part: Decimal(part.text), |
15 | | - "boolean": lambda part: ("False" == part.text), |
16 | | - "string": lambda part: part.text, |
17 | | - "map": lambda part: json.loads(part.text), |
18 | | - "element()": lambda part: part.text, |
19 | | - "array": lambda part: json.loads(part.text), |
20 | | - "array-node()": lambda part: json.loads(part.text), |
21 | | - "object-node()": lambda part: __process_object_node_part(part), |
22 | | - "document-node()": lambda part: __process_document_node_part(part), |
23 | | - # It appears that binary() will only be returned for a binary node retrieved |
24 | | - # from the database, and thus an X-URI will always exist. Have not found a |
25 | | - # scenario that indicates otherwise. |
26 | | - "binary()": lambda part: Document(__get_decoded_uri_from_part(part), part.content), |
27 | | -} |
28 | | - |
29 | 12 |
|
30 | 13 | def process_multipart_mixed_response(response: Response) -> list: |
31 | 14 | """ |
@@ -55,20 +38,28 @@ def process_multipart_mixed_response(response: Response) -> list: |
55 | 38 | return transformed_parts |
56 | 39 |
|
57 | 40 |
|
58 | | -def __get_decoded_uri_from_part(part): |
59 | | - encoding = part.encoding |
60 | | - return part.headers["X-URI".encode(encoding)].decode(encoding) |
61 | | - |
62 | | - |
63 | | -def __process_object_node_part(part): |
64 | | - if b"X-URI" in part.headers: |
65 | | - return Document(__get_decoded_uri_from_part(part), json.loads(part.text)) |
66 | | - else: |
67 | | - return json.loads(part.text) |
| 41 | +__primitive_value_converters = { |
| 42 | + "integer": lambda part: int(part.text), |
| 43 | + "decimal": lambda part: Decimal(part.text), |
| 44 | + "boolean": lambda part: "False" == part.text, |
| 45 | + "string": lambda part: part.text, |
| 46 | + "map": lambda part: json.loads(part.text), |
| 47 | + "element()": lambda part: part.text, |
| 48 | + "array": lambda part: json.loads(part.text), |
| 49 | + "array-node()": lambda part: json.loads(part.text), |
| 50 | + "object-node()": lambda part: __process_node( |
| 51 | + part, lambda part: json.loads(part.text) |
| 52 | + ), |
| 53 | + "document-node()": lambda part: __process_node(part, lambda part: part.text), |
| 54 | + "binary()": lambda part: __process_node(part, lambda part: part.content), |
| 55 | +} |
68 | 56 |
|
69 | 57 |
|
70 | | -def __process_document_node_part(part): |
| 58 | +def __process_node(part, content_extractor): |
| 59 | + content = content_extractor(part) |
71 | 60 | if b"X-URI" in part.headers: |
72 | | - return Document(__get_decoded_uri_from_part(part), part.text) |
| 61 | + encoding = part.encoding |
| 62 | + uri = part.headers["X-URI".encode(encoding)].decode(encoding) |
| 63 | + return Document(uri, content) |
73 | 64 | else: |
74 | | - return part.text |
| 65 | + return content |
0 commit comments