Method get_file_response

core/storage.py:889–943

(self, file_code: FileCodes)

        return await get_file_url(file_code.code)

    async def get_file_response(self, file_code: FileCodes):
        try:
            filename = file_code.prefix + file_code.suffix
            content_length = None  # 初始化为 None，表示未知大小
            
            # 尝试获取文件大小
            try:
                stat_result = await self.operator.stat(await file_code.get_file_path())
                if hasattr(stat_result, 'content_length') and stat_result.content_length:
                    content_length = stat_result.content_length
                elif hasattr(stat_result, 'size') and stat_result.size:
                    content_length = stat_result.size
            except Exception:
                # 如果获取大小失败，则不提供 Content-Length
                pass
            
            # 尝试使用流式读取器
            try:
                # OpenDAL 可能提供 reader 方法返回一个异步读取器
                reader = await self.operator.reader(await file_code.get_file_path())
            except AttributeError:
                # 如果 reader 方法不存在，回退到全量读取（兼容旧版本）
                content = await self.operator.read(await file_code.get_file_path())
                encoded_filename = quote(filename, safe='')
                headers = {
                    "Content-Disposition": f"attachment; filename*=UTF-8''{encoded_filename}"
                }
                if content_length is not None:
                    headers["Content-Length"] = str(content_length)
                return Response(
                    content, headers=headers, media_type="application/octet-stream"
                )
            
            async def stream_generator():
                chunk_size = 65536
                while True:
                    chunk = await reader.read(chunk_size)
                    if not chunk:
                        break
                    yield chunk
            
            encoded_filename = quote(filename, safe='')
            headers = {
                "Content-Disposition": f"attachment; filename*=UTF-8''{encoded_filename}"
            }
            if content_length is not None:
                headers["Content-Length"] = str(content_length)
            return StreamingResponse(
                stream_generator(),
                media_type="application/octet-stream",
                headers=headers
            )
        except Exception as e:
            logger.info(e)
            raise HTTPException(status_code=404, detail="文件已过期删除")

    async def save_chunk(self, upload_id: str, chunk_index: int, chunk_data: bytes, chunk_hash: str, save_path: str):
        """保存分片到 OpenDAL 存储"""