1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914
|
// Copyright 2012 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef COMPONENTS_DOWNLOAD_PUBLIC_COMMON_DOWNLOAD_ITEM_IMPL_H_
#define COMPONENTS_DOWNLOAD_PUBLIC_COMMON_DOWNLOAD_ITEM_IMPL_H_
#include <stdint.h>
#include <memory>
#include <optional>
#include <string>
#include <vector>
#include "base/files/file_path.h"
#include "base/functional/callback_forward.h"
#include "base/memory/raw_ptr.h"
#include "base/memory/weak_ptr.h"
#include "base/observer_list.h"
#include "base/threading/thread_checker.h"
#include "base/threading/thread_checker_impl.h"
#include "base/time/time.h"
#include "components/download/database/in_progress/download_entry.h"
#include "components/download/public/common/download_create_info.h"
#include "components/download/public/common/download_destination_observer.h"
#include "components/download/public/common/download_interrupt_reasons.h"
#include "components/download/public/common/download_item.h"
#include "components/download/public/common/download_job.h"
#include "components/download/public/common/download_target_info.h"
#include "components/download/public/common/download_url_parameters.h"
#include "components/download/public/common/resume_mode.h"
#include "components/download/public/common/url_loader_factory_provider.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
#include "services/device/public/mojom/wake_lock_provider.mojom.h"
#include "services/network/public/mojom/fetch_api.mojom-shared.h"
#include "url/gurl.h"
#include "url/origin.h"
namespace download {
class DownloadFile;
class DownloadItemImplDelegate;
// See download_item.h for usage.
class COMPONENTS_DOWNLOAD_EXPORT DownloadItemImpl
: public DownloadItem,
public DownloadDestinationObserver {
public:
// Information about the initial request that triggers the download. Most of
// the fields are immutable after the DownloadItem is successfully
// created. However, it is possible that the url chain is changed when
// resuming an interrupted download. In that case, the download will restart
// from the beginning.
struct COMPONENTS_DOWNLOAD_EXPORT RequestInfo {
RequestInfo(const std::vector<GURL>& url_chain,
const GURL& referrer_url,
const std::string& serialized_embedder_download_data,
const GURL& tab_url,
const GURL& tab_referrer_url,
const std::optional<url::Origin>& request_initiator,
const std::string& suggested_filename,
const base::FilePath& forced_file_path,
ui::PageTransition transition_type,
bool has_user_gesture,
const std::string& remote_address,
base::Time start_time,
::network::mojom::CredentialsMode credentials_mode,
const std::optional<net::IsolationInfo>& isolation_info,
int64_t range_request_from,
int64_t range_request_to);
RequestInfo();
RequestInfo(const RequestInfo& other);
explicit RequestInfo(const GURL& url);
~RequestInfo();
// The chain of redirects that leading up to and including the final URL.
std::vector<GURL> url_chain;
// The URL of the page that initiated the download.
GURL referrer_url;
// The serialized embedder download data for the site instance that
// initiated this download. The embedder can use this field to add
// additional information about the download, such as the
// StoragePartitionConfig that pertains to it.
std::string serialized_embedder_download_data;
// The URL of the tab that initiated the download.
GURL tab_url;
// The URL of the referrer of the tab that initiated the download.
GURL tab_referrer_url;
// The origin of the requester that originally initiated the download.
std::optional<url::Origin> request_initiator;
// Filename suggestion from DownloadSaveInfo. It could, among others, be the
// suggested filename in 'download' attribute of an anchor. Details:
// http://www.whatwg.org/specs/web-apps/current-work/#downloading-hyperlinks
std::string suggested_filename;
// If non-empty, contains an externally supplied path that should be used as
// the target path.
base::FilePath forced_file_path;
// Page transition that triggered the download.
ui::PageTransition transition_type = ui::PAGE_TRANSITION_LINK;
// Whether the download was triggered with a user gesture.
bool has_user_gesture = false;
// The remote IP address where the download was fetched from.
std::string remote_address;
// Time the download was started.
base::Time start_time;
// The credentials mode of the request.
::network::mojom::CredentialsMode credentials_mode =
::network::mojom::CredentialsMode::kInclude;
// Isolation info for the request.
std::optional<net::IsolationInfo> isolation_info;
// Range request offsets. Used only for explicitly download part of the
// content.
int64_t range_request_from = kInvalidRange;
int64_t range_request_to = kInvalidRange;
};
// Information about the current state of the download destination.
struct COMPONENTS_DOWNLOAD_EXPORT DestinationInfo {
DestinationInfo(const base::FilePath& target_path,
const base::FilePath& current_path,
int64_t received_bytes,
bool all_data_saved,
const std::string& hash,
base::Time end_time);
DestinationInfo();
explicit DestinationInfo(TargetDisposition target_disposition);
DestinationInfo(const DestinationInfo& other);
~DestinationInfo();
// Whether the target should be overwritten, uniquified or prompted for.
TargetDisposition target_disposition = TARGET_DISPOSITION_OVERWRITE;
// Target path of an in-progress download. We may be downloading to a
// temporary or intermediate file (specified by |current_path|). Once the
// download completes, we will rename the file to |target_path|.
// |target_path| should be a valid file path on the system. On Android, this
// could be a content Uri.
base::FilePath target_path;
// Full path to the downloaded or downloading file. This is the path to the
// physical file, if one exists. The final target path is specified by
// |target_path|. |current_path| can be empty if the in-progress path
// hasn't been determined.
base::FilePath current_path;
// Current received bytes.
int64_t received_bytes = 0;
// Current uploaded bytes. Used only when the downloaded file is to be save
// in the cloud.
int64_t uploaded_bytes = 0;
// True if we've saved all the data for the download. If true, then the file
// at |current_path| contains |received_bytes|, which constitute the
// entirety of what we expect to save there. A digest of its contents can be
// found at |hash|.
bool all_data_saved = false;
// SHA256 hash of the possibly partial content. The hash is updated each
// time the download is interrupted, and when the all the data has been
// transferred. |hash| contains the raw binary hash and is not hex encoded.
//
// While the download is in progress, and while resuming, |hash| will be
// empty.
std::string hash;
// Time last update was written to target file.
base::Time end_time;
};
// The maximum number of attempts we will make to resume automatically.
static const int kMaxAutoResumeAttempts;
// Note that it is the responsibility of the caller to ensure that a
// DownloadItemImplDelegate passed to a DownloadItemImpl constructor
// outlives the DownloadItemImpl.
// Constructing from persistent store:
// |net_log| is constructed externally for our use.
DownloadItemImpl(
DownloadItemImplDelegate* delegate,
const std::string& guid,
uint32_t id,
const base::FilePath& current_path,
const base::FilePath& target_path,
const std::vector<GURL>& url_chain,
const GURL& referrer_url,
const std::string& serialized_embedder_download_data,
const GURL& tab_url,
const GURL& tab_referrer_url,
const std::optional<url::Origin>& request_initiator,
const std::string& mime_type,
const std::string& original_mime_type,
base::Time start_time,
base::Time end_time,
const std::string& etag,
const std::string& last_modified,
int64_t received_bytes,
int64_t total_bytes,
int32_t auto_resume_count,
const std::string& hash,
DownloadItem::DownloadState state,
DownloadDangerType danger_type,
DownloadInterruptReason interrupt_reason,
bool paused,
bool allow_metered,
bool opened,
base::Time last_access_time,
bool transient,
const std::vector<DownloadItem::ReceivedSlice>& received_slices,
int64_t range_request_from,
int64_t range_request_to,
std::unique_ptr<DownloadEntry> download_entry);
// Constructing for a regular download.
// |net_log| is constructed externally for our use.
DownloadItemImpl(DownloadItemImplDelegate* delegate,
uint32_t id,
const DownloadCreateInfo& info);
// Constructing for the "Save Page As..." feature:
// |net_log| is constructed externally for our use.
DownloadItemImpl(DownloadItemImplDelegate* delegate,
uint32_t id,
const base::FilePath& path,
const base::FilePath& display_name,
const GURL& url,
const std::string& mime_type,
DownloadJob::CancelRequestCallback cancel_request_callback);
DownloadItemImpl(const DownloadItemImpl&) = delete;
DownloadItemImpl& operator=(const DownloadItemImpl&) = delete;
~DownloadItemImpl() override;
// DownloadItem
void AddObserver(DownloadItem::Observer* observer) override;
void RemoveObserver(DownloadItem::Observer* observer) override;
void UpdateObservers() override;
void ValidateDangerousDownload() override;
void ValidateInsecureDownload() override;
void CopyDownload(AcquireFileCallback callback) override;
void Pause() override;
void Resume(bool user_resume) override;
void Cancel(bool user_cancel) override;
void Remove() override;
void OpenDownload() override;
void ShowDownloadInShell() override;
void Rename(const base::FilePath& name,
RenameDownloadCallback callback) override;
uint32_t GetId() const override;
const std::string& GetGuid() const override;
DownloadState GetState() const override;
void SetStateForTesting(DownloadState state) override;
void SetDownloadUrlForTesting(GURL url) override;
DownloadInterruptReason GetLastReason() const override;
bool IsPaused() const override;
bool AllowMetered() const override;
bool IsTemporary() const override;
bool CanResume() const override;
bool IsDone() const override;
int64_t GetBytesWasted() const override;
int32_t GetAutoResumeCount() const override;
const GURL& GetURL() const override;
const std::vector<GURL>& GetUrlChain() const override;
const GURL& GetOriginalUrl() const override;
const GURL& GetReferrerUrl() const override;
const std::string& GetSerializedEmbedderDownloadData() const override;
const GURL& GetTabUrl() const override;
const GURL& GetTabReferrerUrl() const override;
const std::optional<url::Origin>& GetRequestInitiator() const override;
std::string GetSuggestedFilename() const override;
const scoped_refptr<const net::HttpResponseHeaders>& GetResponseHeaders()
const override;
std::string GetContentDisposition() const override;
std::string GetMimeType() const override;
std::string GetOriginalMimeType() const override;
std::string GetRemoteAddress() const override;
bool HasUserGesture() const override;
ui::PageTransition GetTransitionType() const override;
const std::string& GetLastModifiedTime() const override;
const std::string& GetETag() const override;
bool IsSavePackageDownload() const override;
DownloadSource GetDownloadSource() const override;
const base::FilePath& GetFullPath() const override;
const base::FilePath& GetTargetFilePath() const override;
const base::FilePath& GetForcedFilePath() const override;
base::FilePath GetTemporaryFilePath() const override;
base::FilePath GetFileNameToReportUser() const override;
TargetDisposition GetTargetDisposition() const override;
const std::string& GetHash() const override;
bool GetFileExternallyRemoved() const override;
void DeleteFile(base::OnceCallback<void(bool)> callback) override;
DownloadFile* GetDownloadFile() override;
DownloadItemRenameHandler* GetRenameHandler() override;
#if BUILDFLAG(IS_ANDROID)
bool IsFromExternalApp() override;
bool IsMustDownload() override;
#endif // BUILDFLAG(IS_ANDROID)
bool IsDangerous() const override;
bool IsInsecure() const override;
DownloadDangerType GetDangerType() const override;
InsecureDownloadStatus GetInsecureDownloadStatus() const override;
bool TimeRemaining(base::TimeDelta* remaining) const override;
int64_t CurrentSpeed() const override;
int PercentComplete() const override;
bool AllDataSaved() const override;
int64_t GetTotalBytes() const override;
int64_t GetReceivedBytes() const override;
const std::vector<DownloadItem::ReceivedSlice>& GetReceivedSlices()
const override;
int64_t GetUploadedBytes() const override;
base::Time GetStartTime() const override;
base::Time GetEndTime() const override;
bool CanShowInFolder() override;
bool CanOpenDownload() override;
bool ShouldOpenFileBasedOnExtension() override;
bool ShouldOpenFileByPolicyBasedOnExtension() override;
bool GetOpenWhenComplete() const override;
bool GetAutoOpened() override;
bool GetOpened() const override;
base::Time GetLastAccessTime() const override;
bool IsTransient() const override;
bool RequireSafetyChecks() const override;
bool IsParallelDownload() const override;
DownloadCreationType GetDownloadCreationType() const override;
::network::mojom::CredentialsMode GetCredentialsMode() const override;
const std::optional<net::IsolationInfo>& GetIsolationInfo() const override;
void OnContentCheckCompleted(DownloadDangerType danger_type,
DownloadInterruptReason reason) override;
void OnAsyncScanningCompleted(DownloadDangerType danger_type) override;
void SetOpenWhenComplete(bool open) override;
void SetOpened(bool opened) override;
void SetLastAccessTime(base::Time last_access_time) override;
void SetDisplayName(const base::FilePath& name) override;
std::string DebugString(bool verbose) const override;
void SimulateErrorForTesting(DownloadInterruptReason reason) override;
// All remaining public interfaces virtual to allow for DownloadItemImpl
// mocks.
// State transition operations on regular downloads --------------------------
// Start the download.
// |download_file| is the associated file on the storage medium.
// |cancel_request_callback| is the callback to cancel the download.
// |new_create_info| is a DownloadCreateInfo containing the new response
// parameters. It may be different from the DownloadCreateInfo used to create
// the DownloadItem if Start() is being called in response for a
// download resumption request.
virtual void Start(std::unique_ptr<DownloadFile> download_file,
DownloadJob::CancelRequestCallback cancel_request_callback,
const DownloadCreateInfo& new_create_info,
URLLoaderFactoryProvider::URLLoaderFactoryProviderPtr
url_loader_factory_provider);
// Needed because of intertwining with DownloadManagerImpl -------------------
// TODO(rdsmith): Unwind DownloadManagerImpl and DownloadItemImpl,
// removing these from the public interface.
virtual void OnDownloadedFileRemoved();
// Provide a weak pointer reference to a DownloadDestinationObserver
// for use by download destinations.
virtual base::WeakPtr<DownloadDestinationObserver>
DestinationObserverAsWeakPtr();
// DownloadItemImpl routines only needed by SavePackage ----------------------
// Called by SavePackage to set the total number of bytes on the item.
virtual void SetTotalBytes(int64_t total_bytes);
virtual void OnAllDataSaved(int64_t total_bytes,
std::unique_ptr<crypto::SecureHash> hash_state);
// Called by SavePackage to display progress when the DownloadItem
// should be considered complete.
virtual void MarkAsComplete();
// DownloadDestinationObserver
void DestinationUpdate(
int64_t bytes_so_far,
int64_t bytes_per_sec,
const std::vector<DownloadItem::ReceivedSlice>& received_slices) override;
void DestinationError(
DownloadInterruptReason reason,
int64_t bytes_so_far,
std::unique_ptr<crypto::SecureHash> hash_state) override;
void DestinationCompleted(
int64_t total_bytes,
std::unique_ptr<crypto::SecureHash> hash_state) override;
void SetDelegate(DownloadItemImplDelegate* delegate);
void SetDownloadId(uint32_t download_id);
#if BUILDFLAG(IS_ANDROID)
void set_is_from_external_app(bool is_from_external_app) {
is_from_external_app_ = is_from_external_app;
}
#endif // BUILDFLAG(IS_ANDROID)
const DownloadUrlParameters::RequestHeadersType& request_headers() const {
return request_headers_;
}
bool fetch_error_body() const { return fetch_error_body_; }
uint64_t ukm_download_id() const { return ukm_download_id_; }
void SetAutoResumeCountForTesting(int32_t auto_resume_count);
std::pair<int64_t, int64_t> GetRangeRequestOffset() const;
private:
// Fine grained states of a download.
//
// New downloads can be created in the following states:
//
// INITIAL_INTERNAL: All active new downloads.
//
// COMPLETE_INTERNAL: Downloads restored from persisted state.
// CANCELLED_INTERNAL: - do -
// INTERRUPTED_INTERNAL: - do -
//
// IN_PROGRESS_INTERNAL: SavePackage downloads.
//
// On debug builds, state transitions can be verified via
// IsValidStateTransition() and IsValidSavePackageStateTransition(). Allowed
// state transitions are described below, both for normal downloads and
// SavePackage downloads.
enum DownloadInternalState {
// Initial state. Regular downloads are created in this state until the
// Start() call is received.
//
// Transitions to (regular):
// TARGET_PENDING_INTERNAL: After a successful Start() call.
// INTERRUPTED_TARGET_PENDING_INTERNAL: After a failed Start() call.
//
// Transitions to (SavePackage):
// <n/a> SavePackage downloads never reach this state.
INITIAL_INTERNAL,
// Embedder is in the process of determining the target of the download.
// Since the embedder is sensitive to state transitions during this time,
// any DestinationError/DestinationCompleted events are deferred until
// TARGET_RESOLVED_INTERNAL.
//
// Transitions to (regular):
// TARGET_RESOLVED_INTERNAL: Once the embedder invokes the callback.
// INTERRUPTED_TARGET_PENDING_INTERNAL: An error occurred prior to target
// determination.
// CANCELLED_INTERNAL: Cancelled.
//
// Transitions to (SavePackage):
// <n/a> SavePackage downloads never reach this state.
TARGET_PENDING_INTERNAL,
// Embedder is in the process of determining the target of the download, and
// the download is in an interrupted state. The interrupted state is not
// exposed to the embedder until target determination is complete.
//
// Transitions to (regular):
// INTERRUPTED_INTERNAL: Once the target is determined, the download
// is marked as interrupted.
// CANCELLED_INTERNAL: Cancelled.
//
// Transitions to (SavePackage):
// <n/a> SavePackage downloads never reach this state.
INTERRUPTED_TARGET_PENDING_INTERNAL,
// Embedder has completed target determination. It is now safe to resolve
// the download target as well as process deferred DestinationError events.
// This state is differs from TARGET_PENDING_INTERNAL due to it being
// allowed to transition to INTERRUPTED_INTERNAL, and it's different from
// IN_PROGRESS_INTERNAL in that entering this state doesn't require having
// a valid target. This state is transient (i.e. DownloadItemImpl will
// transition out of it before yielding execution). It's only purpose in
// life is to ensure the integrity of state transitions.
//
// Transitions to (regular):
// IN_PROGRESS_INTERNAL: Target successfully determined. The incoming
// data stream can now be written to the target.
// INTERRUPTED_INTERNAL: Either the target determination or one of the
// deferred signals indicated that the download
// should be interrupted.
// CANCELLED_INTERNAL: User cancelled the download or there was a
// deferred Cancel() call.
//
// Transitions to (SavePackage):
// <n/a> SavePackage downloads never reach this state.
TARGET_RESOLVED_INTERNAL,
// Download target is known and the data can be transferred from our source
// to our sink.
//
// Transitions to (regular):
// COMPLETING_INTERNAL: On final rename completion.
// CANCELLED_INTERNAL: On cancel.
// INTERRUPTED_INTERNAL: On interrupt.
//
// Transitions to (SavePackage):
// COMPLETE_INTERNAL: On completion.
// CANCELLED_INTERNAL: On cancel.
IN_PROGRESS_INTERNAL,
// Between commit point (dispatch of download file release) and completed.
// Embedder may be opening the file in this state.
//
// Transitions to (regular):
// COMPLETE_INTERNAL: On successful completion.
//
// Transitions to (SavePackage):
// <n/a> SavePackage downloads never reach this state.
COMPLETING_INTERNAL,
// After embedder has had a chance to auto-open. User may now open
// or auto-open based on extension.
//
// Transitions to (regular):
// <none> Terminal state.
//
// Transitions to (SavePackage):
// <none> Terminal state.
COMPLETE_INTERNAL,
// An error has interrupted the download.
//
// Transitions to (regular):
// RESUMING_INTERNAL: On resumption.
// CANCELLED_INTERNAL: On cancel.
//
// Transitions to (SavePackage):
// <n/a> SavePackage downloads never reach this state.
INTERRUPTED_INTERNAL,
// A request to resume this interrupted download is in progress.
//
// Transitions to (regular):
// TARGET_PENDING_INTERNAL: Once a server response is received from a
// resumption.
// INTERRUPTED_TARGET_PENDING_INTERNAL: A server response was received,
// but it indicated an error, and the download
// needs to go through target determination.
// TARGET_RESOLVED_INTERNAL: A resumption attempt received an error
// but it was not necessary to go through target
// determination.
// CANCELLED_INTERNAL: On cancel.
//
// Transitions to (SavePackage):
// <n/a> SavePackage downloads never reach this state.
RESUMING_INTERNAL,
// User has cancelled the download.
// TODO(asanka): Merge interrupted and cancelled states.
//
// Transitions to (regular):
// <none> Terminal state.
//
// Transitions to (SavePackage):
// <none> Terminal state.
CANCELLED_INTERNAL,
MAX_DOWNLOAD_INTERNAL_STATE,
};
// Normal progression of a download ------------------------------------------
// These are listed in approximately chronological order. There are also
// public methods involved in normal download progression; see
// the implementation ordering in download_item_impl.cc.
// Construction common to all constructors. |active| should be true for new
// downloads and false for downloads from the history.
// |download_type| indicates to the trace event what kind of download this is.
void Init(bool active, DownloadItem::DownloadCreationType download_type);
// Callback from file thread when we initialize the DownloadFile.
void OnDownloadFileInitialized(DownloadInterruptReason result,
int64_t bytes_wasted);
// Called to determine the target path. Will cause OnDownloadTargetDetermined
// to be called when the target information is available.
void DetermineDownloadTarget();
// Called when the target path has been determined.
virtual void OnDownloadTargetDetermined(DownloadTargetInfo target_info);
void OnDownloadRenamedToIntermediateName(DownloadInterruptReason reason,
const base::FilePath& full_path);
void OnTargetResolved();
// If all pre-requisites have been met, complete download processing, i.e. do
// internal cleanup, file rename, and potentially auto-open. (Dangerous
// downloads still may block on user acceptance after this point.)
void MaybeCompleteDownload();
// Called when the download is ready to complete.
// This may perform final rename if necessary and will eventually call
// DownloadItem::Completed().
void OnDownloadCompleting();
void OnRenameAndAnnotateDone(DownloadInterruptReason reason,
const base::FilePath& full_path);
void OnDownloadRenamedToFinalName(DownloadInterruptReason reason,
const base::FilePath& full_path);
// Called if the embedder took over opening a download, to indicate that
// the download has been opened.
void DelayedDownloadOpened(bool auto_opened);
// Called when the entire download operation (including renaming etc.)
// is completed.
void Completed();
// Helper routines -----------------------------------------------------------
// Indicate that an error has occurred on the download. Discards partial
// state. The interrupted download will not be considered continuable, but may
// be restarted.
void InterruptAndDiscardPartialState(DownloadInterruptReason reason);
// Indicates that an error has occurred on the download. The |bytes_so_far|
// and |hash_state| should correspond to the state of the DownloadFile. If the
// interrupt reason allows, this partial state may be allowed to continue the
// interrupted download upon resumption.
void InterruptWithPartialState(int64_t bytes_so_far,
std::unique_ptr<crypto::SecureHash> hash_state,
DownloadInterruptReason reason);
void UpdateProgress(int64_t bytes_so_far, int64_t bytes_per_sec);
void UpdateResumptionInfo(bool user_resume);
// Set |hash_| and |hash_state_| based on |hash_state|.
void SetHashState(std::unique_ptr<crypto::SecureHash> hash_state);
// Destroy the DownloadFile object. If |destroy_file| is true, the file is
// destroyed with it. Otherwise, DownloadFile::Detach() is called before
// object destruction to prevent file destruction. Destroying the file also
// resets |current_path_|.
void ReleaseDownloadFile(bool destroy_file);
// Deletes the download file at |current_path_|.
void DeleteDownloadFile();
// Check if a download is ready for completion. The callback provided
// may be called at some point in the future if an external entity
// state has change s.t. this routine should be checked again.
bool IsDownloadReadyForCompletion(base::OnceClosure state_change_notify);
// Call to transition state; all state transitions should go through this.
// |notify_action| specifies whether or not to call UpdateObservers() after
// the state transition.
void TransitionTo(DownloadInternalState new_state);
// Set the |danger_type_| and invoke observers if necessary.
void SetDangerType(DownloadDangerType danger_type);
void SetFullPath(const base::FilePath& new_path);
void AutoResumeIfValid();
enum class ResumptionRequestSource { AUTOMATIC, USER };
void ResumeInterruptedDownload(ResumptionRequestSource source);
// Update origin information based on the response to a download resumption
// request. Should only be called if the resumption request was successful.
virtual void UpdateValidatorsOnResumption(
const DownloadCreateInfo& new_create_info);
// Notify observers that this item is being removed by the user.
void NotifyRemoved();
// Determines the resume mode for an interrupted download. Requires
// last_reason_ to be set, but doesn't require the download to be in
// INTERRUPTED state.
ResumeMode GetResumeMode() const;
// Whether strong validators are present.
bool HasStrongValidators() const;
// Binds a device.mojom.WakeLockProvider receiver for any job that needs one.
void BindWakeLockProvider(
mojo::PendingReceiver<device::mojom::WakeLockProvider> receiver);
DownloadItem::DownloadRenameResult RenameDownloadedFile(
const std::string& name);
void RenameDownloadedFileDone(RenameDownloadCallback callback,
const base::FilePath& new_path,
DownloadRenameResult result);
static DownloadState InternalToExternalState(
DownloadInternalState internal_state);
static DownloadInternalState ExternalToInternalState(
DownloadState external_state);
// Debugging routines --------------------------------------------------------
static const char* DebugDownloadStateString(DownloadInternalState state);
static const char* DebugResumeModeString(ResumeMode mode);
static bool IsValidSavePackageStateTransition(DownloadInternalState from,
DownloadInternalState to);
static bool IsValidStateTransition(DownloadInternalState from,
DownloadInternalState to);
void UpdateRenameProgress(int64_t bytes_so_far, int64_t bytes_per_sec);
RequestInfo request_info_;
// GUID to identify the download, generated by
// |base::Uuid::GenerateRandomV4().AsLowercaseString| in download item, or
// provided by |DownloadUrlParameters|. The format should follow UUID version
// 4 in RFC 4122. The string representation is case sensitive. Legacy download
// GUID hex digits may be upper case ASCII characters, and new GUID will be in
// lower case.
std::string guid_;
uint32_t download_id_ = kInvalidId;
// Display name for the download. If this is empty, then the display name is
// considered to be |GetTargetFilePath().BaseName()|.
base::FilePath display_name_;
// Number of bytes wasted.
int64_t bytes_wasted_ = 0;
// Information from the response.
// The HTTP response headers. This contains a nullptr when the response has
// not yet been received. Only for consuming headers.
scoped_refptr<const net::HttpResponseHeaders> response_headers_;
// Content-disposition field from the header.
std::string content_disposition_;
// Mime-type from the header. Subject to change.
std::string mime_type_;
// The value of the content type header sent with the downloaded item. It
// may be different from |mime_type_|, which may be set based on heuristics
// which may look at the file extension and first few bytes of the file.
std::string original_mime_type_;
#if BUILDFLAG(IS_MAC)
// A list of tags specified by the user to be set on the file upon the
// completion of it being written to disk.
std::vector<std::string> file_tags_;
#endif
// Total bytes expected.
int64_t total_bytes_ = 0;
// Last reason.
DownloadInterruptReason last_reason_ = DOWNLOAD_INTERRUPT_REASON_NONE;
// Start time for recording statistics.
base::TimeTicks start_tick_;
// The current state of this download.
DownloadInternalState state_ = INITIAL_INTERNAL;
// Current danger type for the download.
DownloadDangerType danger_type_ = DOWNLOAD_DANGER_TYPE_NOT_DANGEROUS;
// The views of this item in the download shelf and download contents.
base::ObserverList<Observer> observers_;
// Our delegate.
raw_ptr<DownloadItemImplDelegate> delegate_ = nullptr;
// A flag for indicating if the download should be opened at completion.
bool open_when_complete_ = false;
// A flag for indicating if the downloaded file is externally removed.
bool file_externally_removed_ = false;
// True if the download was auto-opened. We set this rather than using
// an observer as it's frequently possible for the download to be auto opened
// before the observer is added.
bool auto_opened_ = false;
// True if the item was downloaded temporarily.
bool is_temporary_ = false;
// True if the item was explicitly paused by the user. This should be checked
// in conjunction with the download state to determine whether the download
// was truly paused.
bool paused_ = false;
// True if the download can proceed in a metered network.
bool allow_metered_ = false;
// Did the user open the item either directly or indirectly (such as by
// setting always open files of this type)? The shelf also sets this field
// when the user closes the shelf before the item has been opened but should
// be treated as though the user opened it.
bool opened_ = false;
// Time when the download was last accessed.
base::Time last_access_time_;
// Whether the download item should be transient and not shown in the UI.
bool transient_ = false;
// Whether the download requires safe browsing check.
bool require_safety_checks_ = true;
// Did the delegate delay calling Complete on this download?
bool delegate_delayed_complete_ = false;
// Error return from DestinationError or received at Start(). Stored
// separately from last_reason_ so that we can avoid handling destination
// errors until after file name determination has occurred.
DownloadInterruptReason deferred_interrupt_reason_ =
DOWNLOAD_INTERRUPT_REASON_NONE;
// The following fields describe the current state of the download file.
// DownloadFile associated with this download. Note that this
// pointer may only be used or destroyed on the download sequence.
// This pointer will be non-null only while the DownloadItem is in
// the IN_PROGRESS state.
std::unique_ptr<DownloadFile> download_file_;
// Information about |download_file_|.
DestinationInfo destination_info_;
// Current speed. Calculated by the DownloadFile.
int64_t bytes_per_sec_ = 0;
// The number of times this download has been resumed automatically. Will be
// reset to 0 if a resumption is performed in response to a Resume() call with
// user gesture.
int auto_resume_count_ = 0;
// In the event of an interruption, the DownloadDestinationObserver interface
// exposes the partial hash state. This state can be held by the download item
// in case it's needed for resumption.
std::unique_ptr<crypto::SecureHash> hash_state_;
// Contents of the Last-Modified header for the most recent server response.
std::string last_modified_time_;
// Server's ETAG for the file.
std::string etag_;
// The data slices that have been received so far.
std::vector<DownloadItem::ReceivedSlice> received_slices_;
std::unique_ptr<DownloadJob> job_;
// Value of |received_bytes_| at the time the download was interrupted with
// CONTENT_LENGTH_MISMATCH.
int64_t received_bytes_at_length_mismatch_ = -1;
// Check whether the download item is updating its observers.
bool is_updating_observers_;
// Whether the download should fetch the response body for non successful HTTP
// response.
bool fetch_error_body_ = false;
// Request header key/value pairs that will be added to the download HTTP
// request.
DownloadUrlParameters::RequestHeadersType request_headers_;
// Source of the download, used in metrics.
DownloadSource download_source_ = DownloadSource::UNKNOWN;
DownloadCreationType download_type_ =
DownloadCreationType::TYPE_ACTIVE_DOWNLOAD;
// UKM ID for reporting, default to 0 if uninitialized.
uint64_t ukm_download_id_ = 0;
// The InsecureDownloadStatus if determined.
InsecureDownloadStatus insecure_download_status_ =
InsecureDownloadStatus::UNKNOWN;
// A handler for renaming and helping with displaying the item.
std::unique_ptr<DownloadItemRenameHandler> rename_handler_;
// Whether renaming is in progress.
bool renaming_ = false;
#if BUILDFLAG(IS_ANDROID)
bool is_from_external_app_ = false;
bool is_must_download_ = false;
#endif // BUILDFLAG(IS_ANDROID)
THREAD_CHECKER(thread_checker_);
base::WeakPtrFactory<DownloadItemImpl> weak_ptr_factory_{this};
};
} // namespace download
#endif // COMPONENTS_DOWNLOAD_PUBLIC_COMMON_DOWNLOAD_ITEM_IMPL_H_
|