mirror of
https://github.com/onyx-dot-app/onyx.git
synced 2026-10-22 11:22:49 -05:00
Chris Weaver
132a9f750d
Also fixes import ordering (previously, local imports weren't grouped together as they should have been)
64 lines
2.1 KiB
Python
64 lines
2.1 KiB
Python
from typing import Any
|
|
|
|
from fastapi import APIRouter
|
|
from pydantic import BaseModel
|
|
from pydantic import Extra
|
|
|
|
from danswer.utils.logger import setup_logger
|
|
|
|
router = APIRouter()
|
|
|
|
logger = setup_logger()
|
|
|
|
|
|
class SlackEvent(BaseModel, extra=Extra.allow):
|
|
type: str
|
|
challenge: str | None
|
|
event: dict[str, Any] | None
|
|
|
|
|
|
class EventHandlingResponse(BaseModel):
|
|
challenge: str | None
|
|
|
|
|
|
# TODO: just store entry in DB and process in the background, until then this
|
|
# won't work cleanly since the slack bot token is not easily accessible
|
|
# @router.post("/process_slack_event", response_model=EventHandlingResponse)
|
|
# def process_slack_event(event: SlackEvent) -> EventHandlingResponse:
|
|
# logger.info("Recieved slack event: %s", event.dict())
|
|
|
|
# if event.type == "url_verification":
|
|
# return EventHandlingResponse(challenge=event.challenge)
|
|
|
|
# if event.type == "event_callback" and event.event:
|
|
# try:
|
|
# # TODO: process in the background as per slack guidelines
|
|
# message_type = event.event.get("subtype")
|
|
# if message_type == "message_changed":
|
|
# message = event.event["message"]
|
|
# else:
|
|
# message = event.event
|
|
|
|
# channel_id = event.event["channel"]
|
|
# thread_ts = message.get("thread_ts")
|
|
# slack_client = get_client()
|
|
# doc = thread_to_doc(
|
|
# channel=get_channel_info(client=slack_client, channel_id=channel_id),
|
|
# thread=get_thread(
|
|
# client=slack_client, channel_id=channel_id, thread_id=thread_ts
|
|
# )
|
|
# if thread_ts
|
|
# else [message],
|
|
# )
|
|
# if doc is None:
|
|
# logger.info("Message was determined to not be indexable")
|
|
# return EventHandlingResponse(challenge=None)
|
|
|
|
# build_indexing_pipeline()([doc])
|
|
# except Exception:
|
|
# logger.exception("Failed to process slack message")
|
|
# return EventHandlingResponse(challenge=None)
|
|
|
|
# logger.error("Unsupported event type: %s", event.type)
|
|
# return EventHandlingResponse(challenge=None)
|