messages.py 6.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220
  1. import json
  2. import time
  3. import uuid
  4. from typing import Optional
  5. from open_webui.internal.db import Base, get_db
  6. from open_webui.models.tags import TagModel, Tag, Tags
  7. from pydantic import BaseModel, ConfigDict
  8. from sqlalchemy import BigInteger, Boolean, Column, String, Text, JSON
  9. from sqlalchemy import or_, func, select, and_, text
  10. from sqlalchemy.sql import exists
  11. ####################
  12. # Message DB Schema
  13. ####################
  14. class MessageReaction(Base):
  15. __tablename__ = "message_reaction"
  16. id = Column(Text, primary_key=True)
  17. user_id = Column(Text)
  18. message_id = Column(Text)
  19. name = Column(Text)
  20. created_at = Column(BigInteger)
  21. class MessageReactionModel(BaseModel):
  22. model_config = ConfigDict(from_attributes=True)
  23. id: str
  24. user_id: str
  25. message_id: str
  26. name: str
  27. created_at: int # timestamp in epoch
  28. class Message(Base):
  29. __tablename__ = "message"
  30. id = Column(Text, primary_key=True)
  31. user_id = Column(Text)
  32. channel_id = Column(Text, nullable=True)
  33. parent_id = Column(Text, nullable=True)
  34. content = Column(Text)
  35. data = Column(JSON, nullable=True)
  36. meta = Column(JSON, nullable=True)
  37. created_at = Column(BigInteger) # time_ns
  38. updated_at = Column(BigInteger) # time_ns
  39. class MessageModel(BaseModel):
  40. model_config = ConfigDict(from_attributes=True)
  41. id: str
  42. user_id: str
  43. channel_id: Optional[str] = None
  44. parent_id: Optional[str] = None
  45. content: str
  46. data: Optional[dict] = None
  47. meta: Optional[dict] = None
  48. created_at: int # timestamp in epoch
  49. updated_at: int # timestamp in epoch
  50. ####################
  51. # Forms
  52. ####################
  53. class MessageForm(BaseModel):
  54. content: str
  55. parent_id: Optional[str] = None
  56. data: Optional[dict] = None
  57. meta: Optional[dict] = None
  58. class Reactions(BaseModel):
  59. name: str
  60. user_ids: list[str]
  61. count: int
  62. class MessageResponse(MessageModel):
  63. reactions: list[Reactions]
  64. class MessageTable:
  65. def insert_new_message(
  66. self, form_data: MessageForm, channel_id: str, user_id: str
  67. ) -> Optional[MessageModel]:
  68. with get_db() as db:
  69. id = str(uuid.uuid4())
  70. ts = int(time.time_ns())
  71. message = MessageModel(
  72. **{
  73. "id": id,
  74. "user_id": user_id,
  75. "channel_id": channel_id,
  76. "parent_id": form_data.parent_id,
  77. "content": form_data.content,
  78. "data": form_data.data,
  79. "meta": form_data.meta,
  80. "created_at": ts,
  81. "updated_at": ts,
  82. }
  83. )
  84. result = Message(**message.model_dump())
  85. db.add(result)
  86. db.commit()
  87. db.refresh(result)
  88. return MessageModel.model_validate(result) if result else None
  89. def get_message_by_id(self, id: str) -> Optional[MessageResponse]:
  90. with get_db() as db:
  91. message = db.get(Message, id)
  92. if not message:
  93. return None
  94. reactions = self.get_reactions_by_message_id(id)
  95. return MessageResponse(
  96. **{
  97. **MessageModel.model_validate(message).model_dump(),
  98. "reactions": reactions,
  99. }
  100. )
  101. def get_messages_by_channel_id(
  102. self, channel_id: str, skip: int = 0, limit: int = 50
  103. ) -> list[MessageModel]:
  104. with get_db() as db:
  105. all_messages = (
  106. db.query(Message)
  107. .filter_by(channel_id=channel_id)
  108. .order_by(Message.created_at.desc())
  109. .offset(skip)
  110. .limit(limit)
  111. .all()
  112. )
  113. return [MessageModel.model_validate(message) for message in all_messages]
  114. def update_message_by_id(
  115. self, id: str, form_data: MessageForm
  116. ) -> Optional[MessageModel]:
  117. with get_db() as db:
  118. message = db.get(Message, id)
  119. message.content = form_data.content
  120. message.data = form_data.data
  121. message.meta = form_data.meta
  122. message.updated_at = int(time.time_ns())
  123. db.commit()
  124. db.refresh(message)
  125. return MessageModel.model_validate(message) if message else None
  126. def add_reaction_to_message(
  127. self, id: str, user_id: str, name: str
  128. ) -> Optional[MessageReactionModel]:
  129. with get_db() as db:
  130. reaction_id = str(uuid.uuid4())
  131. reaction = MessageReactionModel(
  132. id=reaction_id,
  133. user_id=user_id,
  134. message_id=id,
  135. name=name,
  136. created_at=int(time.time_ns()),
  137. )
  138. result = MessageReaction(**reaction.model_dump())
  139. db.add(result)
  140. db.commit()
  141. db.refresh(result)
  142. return MessageReactionModel.model_validate(result) if result else None
  143. def get_reactions_by_message_id(self, id: str) -> list[Reactions]:
  144. with get_db() as db:
  145. all_reactions = db.query(MessageReaction).filter_by(message_id=id).all()
  146. reactions = {}
  147. for reaction in all_reactions:
  148. if reaction.name not in reactions:
  149. reactions[reaction.name] = {
  150. "name": reaction.name,
  151. "user_ids": [],
  152. "count": 0,
  153. }
  154. reactions[reaction.name]["user_ids"].append(reaction.user_id)
  155. reactions[reaction.name]["count"] += 1
  156. return [Reactions(**reaction) for reaction in reactions.values()]
  157. def remove_reaction_by_id_and_user_id_and_name(
  158. self, id: str, user_id: str, name: str
  159. ) -> bool:
  160. with get_db() as db:
  161. db.query(MessageReaction).filter_by(
  162. message_id=id, user_id=user_id, name=name
  163. ).delete()
  164. db.commit()
  165. return True
  166. def delete_message_by_id(self, id: str) -> bool:
  167. with get_db() as db:
  168. db.query(Message).filter_by(id=id).delete()
  169. # Delete all reactions to this message
  170. db.query(MessageReaction).filter_by(message_id=id).delete()
  171. db.commit()
  172. return True
  173. Messages = MessageTable()