mirrors/calibre-web
1
0
Fork 0
mirror of https://github.com/janeczku/calibre-web synced 2024-12-01 05:49:58 +00:00
Code Issues Releases Wiki Activity

Finished code to chunk successfully.

Browse Source
This commit is contained in:
Jack Darlington 2017-03-06 22:50:24 +00:00
parent 10b129cb07
commit e3e26d418d
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
cps/web.py
View File

@ -7,7 +7,8 @@ import logging
from logging.handlers import RotatingFileHandler from logging.handlers import RotatingFileHandler
import textwrap import textwrap
from flask import Flask, render_template, session, request, Response, redirect, url_for, send_from_directory, \ from flask import Flask, render_template, session, request, Response, redirect, url_for, send_from_directory, \
make_response, g, flash, abort, send_file, Markup make_response, g, flash, abort, send_file, Markup, \
stream_with_context
from flask import __version__ as flaskVersion from flask import __version__ as flaskVersion
import ub import ub
from ub import config from ub import config
@ -767,7 +768,7 @@ def do_gdrive_download(df, headers):
app.logger.info(total_size) app.logger.info(total_size)
download_url = df.metadata.get('downloadUrl') download_url = df.metadata.get('downloadUrl')
app.logger.info (time.time()-startTime) app.logger.info (time.time()-startTime)
s = partial(total_size, 1024 * 100) # I'm downloading BIG files, so 100M chunk size is fine for me s = partial(total_size, 1024 * 1024) # I'm downloading BIG files, so 100M chunk size is fine for me
def stream(): def stream():
for bytes in s: for bytes in s:
headers = {"Range" : 'bytes=%s-%s' % (bytes[0], bytes[1])} headers = {"Range" : 'bytes=%s-%s' % (bytes[0], bytes[1])}
@ -777,11 +778,7 @@ def do_gdrive_download(df, headers):
else: else:
app.logger.info('An error occurred: %s' % resp) app.logger.info('An error occurred: %s' % resp)
return return
app.logger.info(str(bytes[1])+"...") return Response(stream_with_context(stream()), headers=headers)
app.logger.info (time.time()-startTime)
return Response(stream(), headers=headers)
@app.route("/opds/download/<book_id>/<format>/") @app.route("/opds/download/<book_id>/<format>/")
@requires_basic_auth_if_no_ano @requires_basic_auth_if_no_ano