Inbox mail table (#202)

* Inbox mail table

* Create and get requests for inbox mail

* new model

* mail collection by threads

* enums inboxmail reference

* restructure return inbox mails

* is admin notificaiton

* create admin notification

* kratos

* inbox mail threads

* fix warning subquery

* is in progress inbox mail thread

* update progress

* unread mail count

* unread mails

* remove kratos

* remove org filter

* inbox mail support progress state

* clear prints

* extend

* remove org filter fix, get engineers

* add org name to inbox threads

* fix import

* update kratos import

* pr comments

* clean up comments

* PR comments

---------

Co-authored-by: LennartSchmidtKern <lennart.schmidt@kern.ai>

Author: lumburovskalina

business_objects/user.py

@@ -26,6 +26,41 @@ def get_user_cached_if_not_admin(user_id: str) -> Optional[User]:
     return user
 
 
+def get_admin_users() -> List[User]:
+    kernai_admins = (
+        session.query(User)
+        .filter(User.email.ilike("%@kern.ai"), User.verified == True)
+        .all()
+    )
+
+    query = """
+    SELECT email FROM global.full_admin_access
+    """
+
+    result = general.execute_all(query)
+    full_admin_emails = [row[0].lower() for row in result] if result else []
+
+    if full_admin_emails:
+        full_admins = (
+            session.query(User).filter(User.email.in_(full_admin_emails)).all()
+        )
+    else:
+        full_admins = []
+
+    admin_users = {user.id: user for user in kernai_admins + full_admins}
+    return list(admin_users.values())
+
+
+def get_engineer_users(org_id: str) -> List[User]:
+    engineers = (
+        session.query(User)
+        .filter(User.role == enums.UserRoles.ENGINEER.value)
+        .filter(User.organization_id == org_id)
+        .all()
+    )
+    return engineers
+
+
 @TTLCacheDecorator(CacheEnum.USER, 5, "user_id")
 def get_user_cached(user_id: str) -> User:
     user = get(user_id)
@@ -52,6 +87,23 @@ def get_all(
     return query.all()
 
 
+def get_all_users_by_users_team(user_id: str) -> List[User]:
+    if not user_id:
+        return []
+    teams_subquery = (
+        session.query(TeamMember.team_id)
+        .filter(TeamMember.user_id == user_id)
+        .subquery()
+    )
+    query = (
+        session.query(User)
+        .join(TeamMember, TeamMember.user_id == User.id)
+        .filter(TeamMember.team_id.in_(sql.select(teams_subquery)))
+        .distinct(User.id)
+    )
+    return query.all()
+
+
 def get_all_team_members_by_project(project_id: str) -> List[User]:
     query = (
         session.query(TeamMember)

enums.py

@@ -180,6 +180,9 @@ class Tablenames(Enum):
     TIMED_EXECUTIONS = "timed_executions"
     CONVERSATION_SHARE = "conversation_share"
     CONVERSATION_GLOBAL_SHARE = "conversation_global_share"
+    INBOX_MAIL = "inbox_mail"
+    INBOX_MAIL_THREAD = "inbox_mail_thread"
+    INBOX_MAIL_THREAD_ASSOCIATION = "inbox_mail_thread_association"
 
     def snake_case_to_pascal_case(self):
         # the type name (written in PascalCase) of a table is needed to create backrefs
@@ -1026,3 +1029,10 @@ class MessageType(Enum):
 
 class TimedExecutionKey(Enum):
     LAST_RESET_USER_MESSAGE_COUNT = "LAST_RESET_USER_MESSAGE_COUNT"
+
+
+class InboxMailThreadSupportProgressState(Enum):
+    PENDING = "PENDING"
+    IN_PROGRESS = "IN_PROGRESS"
+    RESOLVED = "RESOLVED"
+    FAILED = "FAILED"