Coverage for microservice_websocket/app/blueprints/api/payload.py: 100%

1from fastapi import APIRouter, Header 

2 

3from ...utils.api_token import verify_api_token 

4from ...utils.payload import publish 

5from .models import PublishPayload 

6 

7payload_routr = APIRouter(prefix="/payload") 

8 

9 

10@payload_routr.post("/") 

11async def publish_route( 

12 payload: PublishPayload, authorization: str | None = Header(default=None) 

13): 

14 verify_api_token(authorization) 

15 

16 await publish(payload) 

17 

18 from ... import socketManager 

19 

20 await socketManager.emit("change") 

21 await socketManager.emit("change-reading") 

22 

23 return {"message": "Published"}