!+iE dZddlmZmZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ejeZgZe Zdedefd Zd efd Ze j.d d gdZe j.dd gdZy)zD Server-Sent Events (SSE) endpoint for real-time dashboard updates. )Responsestream_with_contextN)QueueEmpty)Lock)api_bp event_typedatacd||tjd}t5g}tD]} |j||D]}tj | dddt jd|dttdy#|j |Y{xYw#1swYKxYw)zq Broadcast an event to all connected SSE clients. Called by WebhookProcessor when orders are synced. )typer timestampNz[SSE] Broadcast: z to z clients) time _sse_lock _sse_queues put_nowaitappendremoveloggerinfolen)r r event_data dead_queuesqs C/var/www/hypershopcomercio.com.br/hyper-ai/app/api/endpoints/sse.pybroadcast_eventrs YY[J  "  &A & Z( & "A   q ! " " KK#J  |8JrGs0    8 $ F PP4P4151:nug./@meW-.r;