Fix most of the downloads api in incognito profiles

chrome/browser/download/download_extension_api.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/download/download_extension_api.h"
 
 #include <algorithm>
 #include <cctype>
 #include <iterator>
 #include <set>
@@ skipping 75 matching lines @@
 const char kEndTimeKey[] = "endTime";
 const char kErrorKey[] = "error";
 const char kFileSizeKey[] = "fileSize";
 const char kFilenameKey[] = "filename";
 const char kFilenameRegexKey[] = "filenameRegex";
 const char kHeaderNameKey[] = "name";
 const char kHeaderValueKey[] = "value";
 const char kHeaderBinaryValueKey[] = "binaryValue";
 const char kHeadersKey[] = "headers";
 const char kIdKey[] = "id";
+const char kIncognito[] = "incognito";
+const char kIncognitoNone[] = "none";
+const char kIncognitoOnly[] = "only";
 const char kLimitKey[] = "limit";
 const char kMethodKey[] = "method";
 const char kMimeKey[] = "mime";
 const char kOrderByKey[] = "orderBy";
 const char kPausedKey[] = "paused";
 const char kQueryKey[] = "query";
 const char kSaveAsKey[] = "saveAs";
 const char kSizeKey[] = "size";
 const char kStartTimeKey[] = "startTime";
 const char kStartedAfterKey[] = "startedAfter";
@@ skipping 83 matching lines @@
   if (item->GetDangerType() != content::DOWNLOAD_DANGER_TYPE_NOT_DANGEROUS)
     json->SetBoolean(kDangerAcceptedKey,
         item->GetSafetyState() == DownloadItem::DANGEROUS_BUT_VALIDATED);
   json->SetString(kStateKey, StateString(item->GetState()));
   json->SetBoolean(kPausedKey, item->IsPaused());
   json->SetString(kMimeKey, item->GetMimeType());
   json->SetInteger(kStartTimeKey,
       (item->GetStartTime() - base::Time::UnixEpoch()).InMilliseconds());
   json->SetInteger(kBytesReceivedKey, item->GetReceivedBytes());
   json->SetInteger(kTotalBytesKey, item->GetTotalBytes());
+  json->SetBoolean(kIncognito, item->IsOtr());
   if (item->GetState() == DownloadItem::INTERRUPTED) {
     json->SetInteger(kErrorKey, static_cast<int>(item->GetLastReason()));
   } else if (item->GetState() == DownloadItem::CANCELLED) {
     json->SetInteger(kErrorKey, static_cast<int>(
         content::DOWNLOAD_INTERRUPT_REASON_USER_CANCELED));
   }
   // TODO(benjhayden): Implement endTime and fileSize.
   // json->SetInteger(kEndTimeKey, -1);
   json->SetInteger(kFileSizeKey, item->GetTotalBytes());
   return scoped_ptr<base::DictionaryValue>(json);
@@ skipping 91 matching lines @@
   sorter_types[kStartTimeKey] = DownloadQuery::SORT_START_TIME;
   sorter_types[kStateKey] = DownloadQuery::SORT_STATE;
   sorter_types[kTotalBytesKey] = DownloadQuery::SORT_TOTAL_BYTES;
   sorter_types[kUrlKey] = DownloadQuery::SORT_URL;
 }
 
 bool IsNotTemporaryDownloadFilter(const DownloadItem& item) {
   return !item.IsTemporary();
 }
 
+DownloadItem* GetItem(Profile* profile, int id) {
+  DownloadManager* download_manager =
+      DownloadServiceFactory::GetForProfile(profile)->GetDownloadManager();
+  DownloadItem* download_item =
+      download_manager->GetActiveDownloadItem(id);
+  if (!download_item) {
+    if (profile->IsOffTheRecord()) {
+      // Try looking for the item in the original manager.
+      download_manager = DownloadServiceFactory::GetForProfile(
+          profile->GetOriginalProfile())->GetDownloadManager();
+      download_item = download_manager->GetActiveDownloadItem(id);
+    }
+  }
+  return download_item;
+}
+
 }  // namespace
 
 bool DownloadsFunctionInterface::RunImplImpl(
     DownloadsFunctionInterface* pimpl) {
   CHECK(pimpl);
   if (!pimpl->ParseArgs()) return false;
   UMA_HISTOGRAM_ENUMERATION(
       "Download.ApiFunctions", pimpl->function(), DOWNLOADS_FUNCTION_LAST);
   return pimpl->RunInternal();
 }
@@ skipping 114 matching lines @@
         EXTENSION_FUNCTION_VALIDATE(header->GetString(
               kHeaderValueKey, &value));
       }
       if (!net::HttpUtil::IsSafeHeader(name)) {
         error_ = download_extension_errors::kGenericError;
         return false;
       }
     }
   }
   iodata_->rdh = content::ResourceDispatcherHost::Get();
+  // If the extension is running an OTR window, then
+  // GetCurrentBrowser()->profile() will be OTR, if there is a current browser
+  // at all. this->profile() will always be the original profile.
+  // Unfortunately, DownloadRequestHandle derives the DownloadManager* from
+  // render_process_host_id and render_view_host_routing_id, which don't seem to
+  // understand OTR, so this change will depend on DownloadManager::DownloadUrl.

[Randy Smith (Not in Mondays), 2012/05/02 18:57:01]

I'm confused; render_process_host_id and render_view_host_routing_id don't
understand OTR, or DownloadRequestHandle doesn't understand OTR?

Also: This comments shouldn't be committed as shown; it should either have a
TODO (and probably no code) or not be in at all.  My guess is that you're aiming
to commit DownloadUrl first, and then this--the ideal way to deal with that is
to work in a git branch that's branched off of DownloadUrl, and thus arrange for
this CL to show the diffs from that CL, and thus no-one but you has to worry
about commit order.  Let me know if you have any interest in pointers on setting
that up :-}.

[benjhayden, 2012/05/03 13:54:39]

Done.

+  // Profile* profile = profile();
+  // if ((GetCurrentBrowser() != NULL) &&
+  //     (GetCurrentBrowser()->profile() != NULL))
+  //   profile = GetCurrentBrowser()->profile();
   iodata_->resource_context = profile()->GetResourceContext();
   iodata_->render_process_host_id = render_view_host()->GetProcess()->GetID();
   iodata_->render_view_host_routing_id = render_view_host()->GetRoutingID();
   return true;
 }
 
 bool DownloadsDownloadFunction::RunInternal() {
   VLOG(1) << __FUNCTION__ << " " << iodata_->url.spec();
   if (!BrowserThread::PostTask(BrowserThread::IO, FROM_HERE, base::Bind(
           &DownloadsDownloadFunction::BeginDownloadOnIOThread, this))) {
@@ skipping 71 matching lines @@
     result_.reset(base::Value::CreateIntegerValue(dl_id.local()));
   } else {
     error_ = net::ErrorToString(error);
   }
   SendResponse(error_.empty());
 }
 
 DownloadsSearchFunction::DownloadsSearchFunction()
   : SyncDownloadsFunction(DOWNLOADS_FUNCTION_SEARCH),
     query_(new DownloadQuery()),
+    include_on_the_record_(true),
+    include_incognito_(true),
     get_id_(0),
     has_get_id_(false) {
 }
 
 DownloadsSearchFunction::~DownloadsSearchFunction() {}
 
 bool DownloadsSearchFunction::ParseArgs() {
   static base::LazyInstance<FilterTypeMap> filter_types =
     LAZY_INSTANCE_INITIALIZER;
   if (filter_types.Get().size() == 0)
     InitFilterTypeMap(filter_types.Get());
 
   base::DictionaryValue* query_json = NULL;
   EXTENSION_FUNCTION_VALIDATE(args_->GetDictionary(0, &query_json));
   for (base::DictionaryValue::Iterator query_json_field(*query_json);
        query_json_field.HasNext(); query_json_field.Advance()) {
     FilterTypeMap::const_iterator filter_type =
         filter_types.Get().find(query_json_field.key());
 
     if (filter_type != filter_types.Get().end()) {
       if (!query_->AddFilter(filter_type->second, query_json_field.value())) {
         error_ = download_extension_errors::kInvalidFilterError;
         return false;
       }
     } else if (query_json_field.key() == kIdKey) {
       EXTENSION_FUNCTION_VALIDATE(query_json_field.value().GetAsInteger(
           &get_id_));
       has_get_id_ = true;
+    } else if (query_json_field.key() == kIncognito) {
+      std::string incognito;
+      EXTENSION_FUNCTION_VALIDATE(query_json_field.value().GetAsString(
+          &incognito));
+      if (incognito == kIncognitoNone) {
+        include_incognito_ = false;
+      } else if (incognito == kIncognitoOnly) {
+        include_on_the_record_ = false;
+      } else {
+        EXTENSION_FUNCTION_VALIDATE(false);
+      }
     } else if (query_json_field.key() == kOrderByKey) {
       if (!ParseOrderBy(query_json_field.value()))
         return false;
     } else if (query_json_field.key() == kDangerKey) {
       std::string danger_str;
       EXTENSION_FUNCTION_VALIDATE(query_json_field.value().GetAsString(
           &danger_str));
       content::DownloadDangerType danger_type =
           DangerEnumFromString(danger_str);
       if (danger_type == content::DOWNLOAD_DANGER_TYPE_MAX) {
@@ skipping 53 matching lines @@
       error_ = download_extension_errors::kInvalidOrderByError;
       return false;
     }
     query_->AddSorter(sorter_type->second, direction);
   }
   return true;
 }
 
 bool DownloadsSearchFunction::RunInternal() {
   DownloadQuery::DownloadVector all_items, cpp_results;
-  DownloadManager* manager = DownloadServiceFactory::GetForProfile(profile())
-    ->GetDownloadManager();
+  Profile* original_profile = NULL;
+  Profile* otr_profile = NULL;
+  if (profile()->IsOffTheRecord()) {
+    otr_profile = profile();
+    original_profile = profile()->GetOriginalProfile();
+  } else {
+    original_profile = profile();
+    if (profile()->HasOffTheRecordProfile())
+      otr_profile = profile()->GetOffTheRecordProfile();

[Randy Smith (Not in Mondays), 2012/05/02 18:57:01]

I don't think it's cool to allow access to OTR downloads from an extension
running in a regular window.  That seems like it punches a hole in the privacy
protection.  Am I confused about what you're doing here?

[benjhayden, 2012/05/03 13:54:39]

Done.

+  }
+  DownloadManager* original_manager = DownloadServiceFactory::GetForProfile(
+      original_profile)->GetDownloadManager();
+  DownloadManager* otr_manager = NULL;
+  if (otr_profile != NULL) {
+    otr_manager = DownloadServiceFactory::GetForProfile(otr_profile)
+      ->GetDownloadManager();
+  }
   if (has_get_id_) {
-    DownloadItem* item = manager->GetDownloadItem(get_id_);
+    DownloadItem* item = original_manager->GetDownloadItem(get_id_);
+    if ((item == NULL) && (otr_manager != NULL))
+      item = otr_manager->GetDownloadItem(get_id_);
     if (item != NULL)
       all_items.push_back(item);
   } else {
-    manager->GetAllDownloads(FilePath(FILE_PATH_LITERAL("")), &all_items);
+    if (include_on_the_record_)
+      original_manager->GetAllDownloads(
+          FilePath(FILE_PATH_LITERAL("")), &all_items);
+    if (include_incognito_ && (otr_manager != NULL))
+      otr_manager->GetAllDownloads(
+          FilePath(FILE_PATH_LITERAL("")), &all_items);
   }
   query_->Search(all_items.begin(), all_items.end(), &cpp_results);
   base::ListValue* json_results = new base::ListValue();
   for (DownloadManager::DownloadVector::const_iterator it = cpp_results.begin();
        it != cpp_results.end(); ++it) {
     scoped_ptr<base::DictionaryValue> item(DownloadItemToJSON(*it));
     json_results->Append(item.release());
   }
   result_.reset(json_results);
   return true;
 }
 
 DownloadsPauseFunction::DownloadsPauseFunction()
   : SyncDownloadsFunction(DOWNLOADS_FUNCTION_PAUSE),
     download_id_(DownloadId::Invalid().local()) {
 }
 
 DownloadsPauseFunction::~DownloadsPauseFunction() {}
 
 bool DownloadsPauseFunction::ParseArgs() {
   EXTENSION_FUNCTION_VALIDATE(args_->GetInteger(0, &download_id_));
   return true;
 }
 
 bool DownloadsPauseFunction::RunInternal() {
-  DownloadManager* download_manager =
-      DownloadServiceFactory::GetForProfile(profile())->GetDownloadManager();
-  DownloadItem* download_item =
-      download_manager->GetActiveDownloadItem(download_id_);
-  DCHECK(!download_item || download_item->IsInProgress());
-
-  if (!download_item) {
+  DownloadItem* download_item = GetItem(
+      GetCurrentBrowser()->profile(), download_id_);
+  if ((download_item == NULL) || !download_item->IsInProgress()) {
     // This could be due to an invalid download ID, or it could be due to the
     // download not being currently active.
     error_ = download_extension_errors::kInvalidOperationError;
   } else if (!download_item->IsPaused()) {
     // If download_item->IsPaused() already then we treat it as a success.
     download_item->TogglePause();
   }
   return error_.empty();
 }
 
 DownloadsResumeFunction::DownloadsResumeFunction()
   : SyncDownloadsFunction(DOWNLOADS_FUNCTION_RESUME),
     download_id_(DownloadId::Invalid().local()) {
 }
 
 DownloadsResumeFunction::~DownloadsResumeFunction() {}
 
 bool DownloadsResumeFunction::ParseArgs() {
   EXTENSION_FUNCTION_VALIDATE(args_->GetInteger(0, &download_id_));
   return true;
 }
 
 bool DownloadsResumeFunction::RunInternal() {
-  DownloadManager* download_manager =
-      DownloadServiceFactory::GetForProfile(profile())->GetDownloadManager();
-  DownloadItem* download_item =
-      download_manager->GetActiveDownloadItem(download_id_);
-  DCHECK(!download_item || download_item->IsInProgress());
-
-  if (!download_item) {
+  DownloadItem* download_item = GetItem(
+      GetCurrentBrowser()->profile(), download_id_);
+  if (download_item == NULL) {
     // This could be due to an invalid download ID, or it could be due to the
     // download not being currently active.
     error_ = download_extension_errors::kInvalidOperationError;
   } else if (download_item->IsPaused()) {
     // If !download_item->IsPaused() already, then we treat it as a success.
     download_item->TogglePause();
   }
   return error_.empty();
 }
 
 DownloadsCancelFunction::DownloadsCancelFunction()
   : SyncDownloadsFunction(DOWNLOADS_FUNCTION_CANCEL),
     download_id_(DownloadId::Invalid().local()) {
 }
 
 DownloadsCancelFunction::~DownloadsCancelFunction() {}
 
 bool DownloadsCancelFunction::ParseArgs() {
   EXTENSION_FUNCTION_VALIDATE(args_->GetInteger(0, &download_id_));
   return true;
 }
 
 bool DownloadsCancelFunction::RunInternal() {
-  DownloadManager* download_manager =
-      DownloadServiceFactory::GetForProfile(profile())->GetDownloadManager();
-  DownloadItem* download_item =
-      download_manager->GetActiveDownloadItem(download_id_);
-
-  if (download_item)
+  DownloadItem* download_item = GetItem(
+      GetCurrentBrowser()->profile(), download_id_);
+  if (download_item != NULL)
     download_item->Cancel(true);
   // |download_item| can be NULL if the download ID was invalid or if the
   // download is not currently active.  Either way, we don't consider it a
   // failure.
   return error_.empty();
 }
 
 DownloadsEraseFunction::DownloadsEraseFunction()
   : AsyncDownloadsFunction(DOWNLOADS_FUNCTION_ERASE) {
 }
@@ skipping 329 matching lines @@
   ListValue args;
   args.Append(arg);
   std::string json_args;
   base::JSONWriter::Write(&args, &json_args);
   profile_->GetExtensionEventRouter()->DispatchEventToRenderers(
       event_name,
       json_args,
       profile_,
       GURL());
 }