Fixing spelling error among all services
This commit is contained in:
1 parent
e7a6e95311
commit
79ba5e1887
2 files changed
+3
-3
No files matched your search
@@ -55,7 +55,7 @@ Receives notification data from internal services and queues it to RabbitMQ for
|
|||||||
**Request Body:**
|
**Request Body:**
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"receipent_user_id": 12345,
|
"user_id": 12345,
|
||||||
"message": {
|
"message": {
|
||||||
"title": "New Message",
|
"title": "New Message",
|
||||||
"body": "You have a new notification",
|
"body": "You have a new notification",
|
||||||
|
|||||||
+2
-2
@@ -24,7 +24,7 @@ api_key_header_internal = APIKeyHeader(name="X-API-Key-Internal")
|
|||||||
MAX_PAGES = 5
|
MAX_PAGES = 5
|
||||||
|
|
||||||
class Notification(BaseModel):
|
class Notification(BaseModel):
|
||||||
receipent_user_id : int = Field(gt=0) #ToDo fix among all services
|
user_id : int = Field(gt=0) #ToDo fix among all services
|
||||||
message : Dict
|
message : Dict
|
||||||
|
|
||||||
class PullResponse(BaseModel):
|
class PullResponse(BaseModel):
|
||||||
@@ -139,7 +139,7 @@ async def receive_notifications(
|
|||||||
logger.info(f"Received notifcation data from {program_name} for RMQ")
|
logger.info(f"Received notifcation data from {program_name} for RMQ")
|
||||||
logger.debug(f"Notification data: {notification_data}")
|
logger.debug(f"Notification data: {notification_data}")
|
||||||
await request.app.state.rmq_producer.publish(
|
await request.app.state.rmq_producer.publish(
|
||||||
notification_data.receipent_user_id,
|
notification_data.user_id,
|
||||||
notification_data.message
|
notification_data.message
|
||||||
)
|
)
|
||||||
logger.info("Successfully queued for delivery to RMQ")
|
logger.info("Successfully queued for delivery to RMQ")
|
||||||
|
|||||||
Reference in new issue
Block a user