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"
    )