Method get_file_response

core/storage.py:668–720

(self, file_code: FileCodes)

        return self._convert_link_to_download_link(permission.link.webUrl)

    async def get_file_response(self, file_code: FileCodes):
        try:
            filename = file_code.prefix + file_code.suffix
            link = await asyncio.to_thread(
                self._get_file_url, await file_code.get_file_path(), filename
            )
            
            content_length = None  # 初始化为 None，表示未知大小
            
            # 创建ClientSession并复用
            session = aiohttp.ClientSession()
            
            # 尝试发送HEAD请求获取Content-Length
            try:
                async with session.head(link) as resp:
                    if resp.status == 200 and 'Content-Length' in resp.headers:
                        content_length = int(resp.headers['Content-Length'])
            except Exception:
                # 如果HEAD请求失败，则不提供 Content-Length
                pass
            
            async def stream_generator():
                try:
                    async with session.get(link) as resp:
                        if resp.status != 200:
                            raise HTTPException(
                                status_code=resp.status,
                                detail=f"从OneDrive获取文件失败: {resp.status}"
                            )
                        chunk_size = 65536
                        while True:
                            chunk = await resp.content.read(chunk_size)
                            if not chunk:
                                break
                            yield chunk
                finally:
                    await session.close()
            
            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 HTTPException:
            raise
        except Exception:
            raise HTTPException(status_code=503, detail="服务代理下载异常，请稍后再试")

    async def get_file_url(self, file_code: FileCodes):
        if self.proxy: