|
11 | 11 | from models_library.projects import ProjectID |
12 | 12 | from models_library.socketio import SocketMessageDict |
13 | 13 | from models_library.users import UserID |
14 | | -from pydantic import BaseModel |
| 14 | +from pydantic import AliasGenerator, BaseModel, ConfigDict |
| 15 | +from pydantic.alias_generators import to_camel |
15 | 16 |
|
16 | 17 | from ..socketio.messages import send_message_to_standard_group |
17 | 18 |
|
18 | | -SOCKET_IO_CONVERSATION_MESSAGE_CREATED_EVENT: Final[str] = "conversationMessageCreated" |
19 | | - |
20 | | -SOCKET_IO_CONVERSATION_MESSAGE_DELETED_EVENT: Final[str] = "conversationMessageDeleted" |
21 | | - |
22 | | -SOCKET_IO_CONVERSATION_MESSAGE_UPDATED_EVENT: Final[str] = "conversationMessageUpdated" |
| 19 | +SOCKET_IO_CONVERSATION_MESSAGE_CREATED_EVENT: Final[str] = ( |
| 20 | + "conversation:message:created" |
| 21 | +) |
| 22 | +SOCKET_IO_CONVERSATION_MESSAGE_DELETED_EVENT: Final[str] = ( |
| 23 | + "conversation:message:deleted" |
| 24 | +) |
| 25 | +SOCKET_IO_CONVERSATION_MESSAGE_UPDATED_EVENT: Final[str] = ( |
| 26 | + "conversation:message:updated" |
| 27 | +) |
23 | 28 |
|
24 | 29 |
|
25 | | -class ConversationMessage(BaseModel): |
| 30 | +class BaseConversationMessage(BaseModel): |
26 | 31 | conversation_id: ConversationID |
27 | 32 | message_id: ConversationMessageID |
28 | 33 |
|
| 34 | + model_config = ConfigDict( |
| 35 | + populate_by_name=True, |
| 36 | + from_attributes=True, |
| 37 | + alias_generator=AliasGenerator( |
| 38 | + serialization_alias=to_camel, |
| 39 | + ), |
| 40 | + ) |
| 41 | + |
29 | 42 |
|
30 | | -class ConversationMessageCreated(ConversationMessage): |
| 43 | +class ConversationMessageCreated(BaseConversationMessage): |
31 | 44 | content: str |
32 | 45 | created: datetime.datetime |
33 | 46 |
|
34 | 47 |
|
35 | | -class ConversationMessageUpdated(ConversationMessage): |
| 48 | +class ConversationMessageUpdated(BaseConversationMessage): |
36 | 49 | content: str |
37 | 50 | modified: datetime.datetime |
38 | 51 |
|
39 | 52 |
|
40 | | -class ConversationMessageDeleted(ConversationMessage): ... |
| 53 | +class ConversationMessageDeleted(BaseConversationMessage): ... |
41 | 54 |
|
42 | 55 |
|
43 | 56 | async def _send_message_to_recipients(app, recipients, notification_message): |
|
0 commit comments