Function upload_part

src/opencdeserver/api/app/api/documents.py:219–260

(part_id: str, request: Request, current_user: User = Depends(get_current_active_user))

@router.post("/documents/1.0/upload-part/{part_id}", tags=[""])
async def upload_part(part_id: str, request: Request, current_user: User = Depends(get_current_active_user)):

    # file_name = doc_db.safe_path(part_id)
    file_name = part_id

    # see if the user really has the part-node in the database, before receiving upload of this part
    # and get the document_id of the part
    document = doc_db.user_has_part(part_id, current_user)

    request_body = await request.body()

    if document:

        # try to receive the uploaded part
        try:
            print("File contents: ", request_body)

            # use document_id instead as dir_name
            # dir_name = doc_db.safe_path(document.document_id)
            dir_name = document.document_id

            path = "./data/document_parts/" + dir_name + "/"

            if not os.path.exists(path):
                os.makedirs(path)

            with open(path + file_name, "wb") as f:
                f.write(request_body)

        except Exception:
            print("Error uploading file")
            print(traceback.format_exc())
            print("Error uploading file")
            print(sys.exc_info()[2])

        finally:
            # We will write to the database, information about part successfully uploaded.
            doc_db.mark_part_as_uploaded(part_id, current_user)

        doc_db.debug(endpoint="upload-part", request={"part_id": part_id}, response={"uploaded": True})

        return {"message": f"Successfully uploaded part {file_name}"}


# ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ----