Mercurial > libervia-backend
view libervia/backend/models/core.py @ 4151:18026ce0819c
core (xmpp): message reception workflow refactoring:
- Call methods from a root async one instead of using Deferred callbacks chain.
- Use a queue to be sure to process messages in order.
author | Goffi <goffi@goffi.org> |
---|---|
date | Wed, 22 Nov 2023 14:50:35 +0100 |
parents | c36295487082 |
children | 98687eaa6a09 |
line wrap: on
line source
#!/usr/bin/env python3 # Libervia common models # Copyright (C) 2009-2023 Jérôme Poisson (goffi@goffi.org) # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU Affero General Public License as published by # the Free Software Foundation, either version 3 of the License, or # (at your option) any later version. # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU Affero General Public License for more details. # You should have received a copy of the GNU Affero General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. from typing import Annotated, Literal from pydantic import BaseModel, Field, validator class MessageData(dict): pass class MessageUpdateData(BaseModel): type: str def __init__(self, **kwargs): if "type" not in kwargs: kwargs["type"] = "reactions" super().__init__(**kwargs) class MessageEditData(MessageUpdateData): message: dict[str, str] | None = Field( None, description=( "Updated message content, can be in several languages (key is language code " 'or "" for default)' ), ) subject: dict[str, str] | None = Field( None, description=( "Updated subject of the message, can be in several languages (key is " 'language code or "" for default)' ), ) mess_type: str | None = Field( None, description=( "Updated type of the message (cf RFC 6121 §5.2.2) + C.MESS_TYPE_INFO (system " "info)" ), ) class MessageReactionData(MessageUpdateData): reactions: dict[str, list[str]] = Field( description="Reaction to reacting entities mapping" )