(obj, info, client_id)
| 11 | @subscription.source("messages") |
| 12 | @convert_kwargs_to_snake_case |
| 13 | async def messages_source(obj, info, client_id): |
| 14 | while True: |
| 15 | message = await queue.get() |
| 16 | if message["client_id"] == client_id: |
| 17 | logging.info("Processing...") |
| 18 | content = message['content'] |
| 19 | decoded = content[content.find(",") + 1:] |
| 20 | bytes_data = BytesIO(base64.b64decode(decoded + "===")) |
| 21 | cartoon_image = photo_2_cartoon(bytes_data) |
| 22 | bytes_io = BytesIO() |
| 23 | cartoon_image.save(bytes_io, format="PNG") |
| 24 | message['content'] = base64_encode_img(cartoon_image) |
| 25 | queue.task_done() |
| 26 | logging.info("Done...") |
| 27 | yield message |
| 28 | else: |
| 29 | await queue.put(message) |
| 30 | |
| 31 | |
| 32 | @subscription.field("messages") |
nothing calls this directly
no test coverage detected