Function get_save_handler

apps/knowledge/task/handler.py:17–41

(knowledge_id, user_id, selector)

def get_save_handler(knowledge_id, user_id, selector):
    from knowledge.serializers.document import DocumentSerializers

    def handler(child_link: ChildLink, response: Fork.Response):
        if response.status == 200:
            try:
                document_name = (
                    child_link.tag.text
                    if child_link.tag is not None and len(child_link.tag.text.strip()) > 0
                    else child_link.url
                )
                paragraphs = get_split_model("web.md").parse(response.content)
                DocumentSerializers.Create(data={"knowledge_id": knowledge_id, "user_id": user_id}).save(
                    {
                        "name": document_name,
                        "paragraphs": paragraphs,
                        "meta": {"source_url": child_link.url, "selector": selector},
                        "type": KnowledgeType.WEB,
                    },
                    with_valid=True,
                )
            except Exception as e:
                maxkb_logger.error(f"{str(e)}:{traceback.format_exc()}")

    return handler


def get_sync_handler(knowledge_id, user_id):