✨ AI answers user questions in support center (🗃️⚠️🚨) (#8525)

Author: matusdrobuliak66

packages/models-library/src/models_library/conversations.py

@@ -38,7 +38,10 @@ class ConversationMessageType(StrAutoEnum):
 #
 
 
-IsSupportUser: TypeAlias = bool
+class ConversationUserType(StrAutoEnum):
+    SUPPORT_USER = auto()
+    CHATBOT_USER = auto()
+    REGULAR_USER = auto()
 
 
 class ConversationGetDB(BaseModel):
@@ -58,7 +61,29 @@ class ConversationGetDB(BaseModel):
     modified: datetime
     last_message_created_at: datetime
 
-    model_config = ConfigDict(from_attributes=True)
+    model_config = ConfigDict(
+        from_attributes=True,
+        json_schema_extra={
+            "examples": [
+                # Support message
+                {
+                    "conversation_id": "42838344-03de-4ce2-8d93-589a5dcdfd05",
+                    "product_name": "osparc",
+                    "name": "test_conversation",
+                    "project_uuid": "42838344-03de-4ce2-8d93-589a5dcdfd05",
+                    "user_group_id": "789",
+                    "type": ConversationType.SUPPORT,
+                    "extra_context": {},
+                    "fogbugz_case_id": None,
+                    "is_read_by_user": False,
+                    "is_read_by_support": False,
+                    "created": "2024-01-01T12:00:00",
+                    "modified": "2024-01-01T12:00:00",
+                    "last_message_created_at": "2024-01-01T12:00:00",
+                }
+            ]
+        },
+    )
 
 
 class ConversationMessageGetDB(BaseModel):

packages/models-library/src/models_library/rabbitmq_messages.py

@@ -9,6 +9,7 @@
 from common_library.basic_types import DEFAULT_FACTORY
 from pydantic import BaseModel, Field
 
+from .conversations import ConversationGetDB, ConversationMessageID
 from .products import ProductName
 from .progress_bar import ProgressReport
 from .projects import ProjectID
@@ -93,6 +94,17 @@ def routing_key(self) -> str | None:
         return None
 
 
+class WebserverChatbotRabbitMessage(RabbitMessageBase):
+    channel_name: Literal["simcore.services.webserver-chatbot"] = (
+        "simcore.services.webserver-chatbot"
+    )
+    conversation: ConversationGetDB
+    last_message_id: ConversationMessageID
+
+    def routing_key(self) -> str | None:
+        return None
+
+
 class ProgressType(StrAutoEnum):
     COMPUTATION_RUNNING = auto()  # NOTE: this is the original only progress report
 

packages/postgres-database/src/simcore_postgres_database/migration/versions/e1c7e416461c_add_chatbot_user_id_to_products_table.py

@@ -0,0 +1,42 @@
+"""add chatbot user id to products table
+
+Revision ID: e1c7e416461c
+Revises: f641b3eacafd
+Create Date: 2025-10-16 07:51:44.033767+00:00
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "e1c7e416461c"
+down_revision = "f641b3eacafd"
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column(
+        "products", sa.Column("support_chatbot_user_id", sa.BigInteger(), nullable=True)
+    )
+    op.create_foreign_key(
+        "fk_products_support_chatbot_user_id",
+        "products",
+        "users",
+        ["support_chatbot_user_id"],
+        ["id"],
+        onupdate="CASCADE",
+        ondelete="SET NULL",
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_constraint(
+        "fk_products_support_chatbot_user_id", "products", type_="foreignkey"
+    )
+    op.drop_column("products", "support_chatbot_user_id")
+    # ### end Alembic commands ###

packages/postgres-database/src/simcore_postgres_database/migration/versions/ff13501db935_add_base_url_to_product_table.py

@@ -0,0 +1,32 @@
+"""Add base_url to product table
+
+Revision ID: ff13501db935
+Revises: e1c7e416461c
+Create Date: 2025-10-17 14:48:02.509847+00:00
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "ff13501db935"
+down_revision = "e1c7e416461c"
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column("products", sa.Column("base_url", sa.String(), nullable=True))
+    # ### end Alembic commands ###
+
+    op.execute("UPDATE products SET base_url = 'http://CHANGE_ME.localhost'")
+
+    op.alter_column("products", "base_url", existing_type=sa.String(), nullable=True)
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column("products", "base_url")
+    # ### end Alembic commands ###

packages/postgres-database/src/simcore_postgres_database/models/products.py

@@ -19,6 +19,7 @@
 from .base import metadata
 from .groups import groups
 from .jinja2_templates import jinja2_templates
+from .users import users
 
 # NOTE: a default entry is created in the table Product
 # see packages/postgres-database/src/simcore_postgres_database/migration/versions/350103a7efbd_modified_products_table.py
@@ -153,6 +154,12 @@ class ProductLoginSettingsDict(TypedDict, total=False):
         nullable=False,
         doc="Regular expression that matches product hostname from an url string",
     ),
+    sa.Column(
+        "base_url",
+        sa.String,
+        nullable=False,
+        doc="Product base URL (scheme + host), ex. https://osparc.io",
+    ),
     # EMAILS --------------------
     sa.Column(
         "support_email",
@@ -281,6 +288,19 @@ class ProductLoginSettingsDict(TypedDict, total=False):
         nullable=True,
         doc="Group associated to this product support",
     ),
+    sa.Column(
+        "support_chatbot_user_id",
+        sa.BigInteger,
+        sa.ForeignKey(
+            users.c.id,
+            name="fk_products_support_chatbot_user_id",
+            ondelete=RefActions.SET_NULL,
+            onupdate=RefActions.CASCADE,
+        ),
+        unique=False,
+        nullable=True,
+        doc="User associated to this product chatbot user",
+    ),
     sa.Column(
         "support_assigned_fogbugz_person_id",
         sa.BigInteger,

packages/postgres-database/tests/conftest.py

@@ -354,7 +354,9 @@ async def _creator(product_name: str) -> Row:
         async with asyncpg_engine.begin() as connection:
             result = await connection.execute(
                 sa.insert(products)
-                .values(name=product_name, host_regex=".*")
+                .values(
+                    name=product_name, host_regex=".*", base_url="https://example.com"
+                )
                 .returning(sa.literal_column("*"))
             )
             assert result

packages/postgres-database/tests/products/test_models_products.py

@@ -67,18 +67,21 @@ async def test_jinja2_templates_table(
             {
                 "name": "osparc",
                 "host_regex": r"^osparc.",
+                "base_url": "https://osparc.io",
                 "registration_email_template": registration_email_template,
             },
             {
                 "name": "s4l",
                 "host_regex": r"(^s4l[\.-])|(^sim4life\.)",
+                "base_url": "https://sim4life.info",
                 "short_name": "s4l web",
                 "registration_email_template": registration_email_template,
             },
             {
                 "name": "tis",
                 "short_name": "TIP",
                 "host_regex": r"(^ti.[\.-])|(^ti-solution\.)",
+                "base_url": "https://tis.com",
             },
         ]:
             #  aiopg doesn't support executemany!!
@@ -133,6 +136,7 @@ async def test_insert_select_product(
         "display_name": "o²S²PARC",
         "short_name": "osparc",
         "host_regex": r"([\.-]{0,1}osparc[\.-])",
+        "base_url": "https://osparc.io",
         "support_email": "foo@osparc.io",
         "twilio_messaging_sid": None,
         "vendor": Vendor(

packages/postgres-database/tests/test_utils_services.py

@@ -151,6 +151,7 @@ def services_fixture(faker: Faker, pg_sa_engine: sa.engine.Engine) -> ServicesFi
             "display_name": "Product Osparc",
             "short_name": "osparc",
             "host_regex": r"^osparc.",
+            "base_url": "https://osparc.io",
             "priority": 0,
         }
         product_name = conn.execute(

packages/postgres-database/tests/test_utils_services_environments.py

@@ -34,7 +34,9 @@ class ExpectedSecrets(NamedTuple):
 async def product_name(connection: SAConnection) -> str:
     a_product_name = "a_prod"
     await connection.execute(
-        products.insert().values(name=a_product_name, host_regex="")
+        products.insert().values(
+            name=a_product_name, host_regex="", base_url="http://example.com"
+        )
     )
     yield a_product_name
     await connection.execute(products.delete())

packages/pytest-simcore/src/pytest_simcore/helpers/faker_factories.py

@@ -306,6 +306,7 @@ def random_product(
         "display_name": suffix.capitalize().replace("_", " "),
         "short_name": suffix[:4],
         "host_regex": r"[a-zA-Z0-9]+\.com",
+        "base_url": f"https://{suffix}.com",
         "support_email": f"support@{suffix}.io",
         "product_owners_email": fake.random_element(
             elements=[f"product-owners@{suffix}.io", None]