Chromium Code Reviews| Index: ios/shared/chrome/browser/ui/browser_list/browser_list_session_service_impl.mm |
| diff --git a/ios/shared/chrome/browser/ui/browser_list/browser_list_session_service_impl.mm b/ios/shared/chrome/browser/ui/browser_list/browser_list_session_service_impl.mm |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..ec600701f77e87a7c6e897dadec4602df7b587f2 |
| --- /dev/null |
| +++ b/ios/shared/chrome/browser/ui/browser_list/browser_list_session_service_impl.mm |
| @@ -0,0 +1,278 @@ |
| +// Copyright 2017 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. |
| + |
| +#import "ios/shared/chrome/browser/ui/browser_list/browser_list_session_service_impl.h" |
| + |
| +#include <map> |
| + |
| +#include "base/bind.h" |
| +#include "base/callback.h" |
| +#include "base/logging.h" |
| +#include "base/memory/ptr_util.h" |
| +#include "ios/chrome/browser/chrome_url_constants.h" |
| +#import "ios/chrome/browser/sessions/session_ios.h" |
| +#import "ios/chrome/browser/sessions/session_service_ios.h" |
| +#import "ios/chrome/browser/sessions/session_window_ios.h" |
| +#import "ios/chrome/browser/web_state_list/web_state_list.h" |
| +#import "ios/chrome/browser/web_state_list/web_state_list_observer.h" |
| +#import "ios/chrome/browser/web_state_list/web_state_list_serialization.h" |
| +#import "ios/shared/chrome/browser/ui/browser_list/browser.h" |
| +#import "ios/shared/chrome/browser/ui/browser_list/browser_list.h" |
| +#import "ios/shared/chrome/browser/ui/browser_list/browser_list_observer.h" |
| +#import "ios/web/public/navigation_item.h" |
| +#import "ios/web/public/navigation_manager.h" |
| +#import "ios/web/public/web_state/web_state.h" |
| +#import "ios/web/public/web_state/web_state_observer.h" |
| + |
| +#if !defined(__has_feature) || !__has_feature(objc_arc) |
| +#error "This file requires ARC support." |
| +#endif |
| + |
| +namespace { |
| + |
| +// BrowserListSessionServiceWebStateObserver observes a WebState and invokes |
| +// |closure| when a new navigation item is committed. |
| +class BrowserListSessionServiceWebStateObserver : public web::WebStateObserver { |
| + public: |
| + explicit BrowserListSessionServiceWebStateObserver( |
| + const base::RepeatingClosure& closure); |
| + ~BrowserListSessionServiceWebStateObserver() override; |
| + |
| + // Changes the observed WebState to |web_state|. |
| + void ObserveWebState(web::WebState* web_state); |
| + |
| + // web::WebStateObserver implementation. |
| + void NavigationItemCommitted( |
| + const web::LoadCommittedDetails& load_details) override; |
| + |
| + private: |
| + base::RepeatingClosure closure_; |
| + |
| + DISALLOW_COPY_AND_ASSIGN(BrowserListSessionServiceWebStateObserver); |
| +}; |
| + |
| +BrowserListSessionServiceWebStateObserver:: |
| + BrowserListSessionServiceWebStateObserver( |
| + const base::RepeatingClosure& closure) |
| + : WebStateObserver(), closure_(closure) { |
| + DCHECK(!closure_.is_null()); |
| +} |
| + |
| +BrowserListSessionServiceWebStateObserver:: |
| + ~BrowserListSessionServiceWebStateObserver() = default; |
| + |
| +void BrowserListSessionServiceWebStateObserver::ObserveWebState( |
| + web::WebState* web_state) { |
| + WebStateObserver::Observe(web_state); |
| +} |
| + |
| +void BrowserListSessionServiceWebStateObserver::NavigationItemCommitted( |
| + const web::LoadCommittedDetails& load_details) { |
| + closure_.Run(); |
| +} |
| + |
| +// BrowserListSessionServiceWebStateListObserver observes a WebStateList and |
| +// invokes |closure| when the active WebState changes or a navigation item is |
| +// committed in the active WebState. |
| +class BrowserListSessionServiceWebStateListObserver |
| + : public WebStateListObserver { |
| + public: |
| + BrowserListSessionServiceWebStateListObserver( |
| + WebStateList* web_state_list, |
| + const base::RepeatingClosure& closure); |
| + ~BrowserListSessionServiceWebStateListObserver() override; |
| + |
| + // WebStateListObserver implementation. |
| + void WebStateActivatedAt(WebStateList* web_state_list, |
| + web::WebState* old_web_state, |
| + web::WebState* new_web_state, |
| + int active_index, |
| + bool user_action) override; |
| + |
| + private: |
| + WebStateList* web_state_list_; |
| + base::RepeatingClosure closure_; |
| + BrowserListSessionServiceWebStateObserver observer_; |
| + |
| + DISALLOW_COPY_AND_ASSIGN(BrowserListSessionServiceWebStateListObserver); |
| +}; |
| + |
| +BrowserListSessionServiceWebStateListObserver:: |
| + BrowserListSessionServiceWebStateListObserver( |
| + WebStateList* web_state_list, |
| + const base::RepeatingClosure& closure) |
| + : web_state_list_(web_state_list), closure_(closure), observer_(closure) { |
| + DCHECK(!closure_.is_null()); |
| + web_state_list_->AddObserver(this); |
| +} |
| + |
| +BrowserListSessionServiceWebStateListObserver:: |
| + ~BrowserListSessionServiceWebStateListObserver() { |
| + web_state_list_->RemoveObserver(this); |
| +} |
| + |
| +void BrowserListSessionServiceWebStateListObserver::WebStateActivatedAt( |
| + WebStateList* web_state_list, |
| + web::WebState* old_web_state, |
| + web::WebState* new_web_state, |
| + int active_index, |
| + bool user_action) { |
| + if (old_web_state) |
| + closure_.Run(); |
| + observer_.ObserveWebState(new_web_state); |
| +} |
| + |
| +// BrowserListSessionServiceBrowserListObserver observes a BrowserList and |
| +// invokes |closure| then the active WebState changes in any of the Browsers' |
| +// WebStates or a navigation item is committed in one of the active WebStates. |
| +class BrowserListSessionServiceBrowserListObserver |
| + : public BrowserListObserver { |
| + public: |
| + BrowserListSessionServiceBrowserListObserver( |
| + BrowserList* browser_list, |
| + const base::RepeatingClosure& closure); |
| + ~BrowserListSessionServiceBrowserListObserver() override; |
| + |
| + // BrowserListObserver implementation. |
| + void OnBrowserCreated(BrowserList* browser_list, Browser* browser) override; |
| + void OnBrowserRemoved(BrowserList* browser_list, Browser* browser) override; |
| + |
| + private: |
| + BrowserList* browser_list_; |
| + base::RepeatingClosure closure_; |
| + std::map<Browser*, std::unique_ptr<WebStateListObserver>> observers_; |
| + |
| + DISALLOW_COPY_AND_ASSIGN(BrowserListSessionServiceBrowserListObserver); |
| +}; |
| + |
| +BrowserListSessionServiceBrowserListObserver:: |
| + BrowserListSessionServiceBrowserListObserver( |
| + BrowserList* browser_list, |
| + const base::RepeatingClosure& closure) |
| + : browser_list_(browser_list), closure_(closure) { |
| + DCHECK(!closure_.is_null()); |
| + for (int index = 0; index < browser_list_->count(); ++index) |
| + OnBrowserCreated(browser_list_, browser_list_->GetBrowserAtIndex(index)); |
| + browser_list_->AddObserver(this); |
| +} |
| + |
| +BrowserListSessionServiceBrowserListObserver:: |
| + ~BrowserListSessionServiceBrowserListObserver() { |
| + browser_list_->RemoveObserver(this); |
| +} |
| + |
| +void BrowserListSessionServiceBrowserListObserver::OnBrowserCreated( |
| + BrowserList* browser_list, |
| + Browser* browser) { |
| + DCHECK(browser); |
| + DCHECK_EQ(browser_list, browser_list_); |
| + DCHECK(observers_.find(browser) == observers_.end()); |
| + observers_.insert(std::make_pair( |
| + browser, base::MakeUnique<BrowserListSessionServiceWebStateListObserver>( |
| + &browser->web_state_list(), closure_))); |
| +} |
| + |
| +void BrowserListSessionServiceBrowserListObserver::OnBrowserRemoved( |
| + BrowserList* browser_list, |
| + Browser* browser) { |
| + DCHECK(browser); |
| + DCHECK_EQ(browser_list, browser_list_); |
| + DCHECK(observers_.find(browser) != observers_.end()); |
| + observers_.erase(browser); |
| +} |
| + |
| +} // namespace |
| + |
| +BrowserListSessionServiceImpl::BrowserListSessionServiceImpl( |
| + BrowserList* browser_list, |
| + NSString* session_directory, |
| + SessionServiceIOS* session_service, |
| + const CreateWebStateCallback& create_web_state) |
| + : browser_list_(browser_list), |
| + session_directory_([session_directory copy]), |
| + session_service_(session_service), |
| + create_web_state_(create_web_state) { |
| + DCHECK(browser_list_); |
| + DCHECK(session_directory_); |
| + DCHECK(session_service_); |
| + DCHECK(create_web_state_); |
| + // It is safe to use base::Unretained as the closure is indirectly owned by |
| + // the BrowserListSessionServiceImpl instance and will be deleted before it. |
| + observer_ = base::MakeUnique<BrowserListSessionServiceBrowserListObserver>( |
| + browser_list, |
| + base::BindRepeating(&BrowserListSessionServiceImpl::ScheduleSaveSession, |
| + base::Unretained(this), false)); |
| +} |
| + |
| +BrowserListSessionServiceImpl::~BrowserListSessionServiceImpl() = default; |
| + |
| +bool BrowserListSessionServiceImpl::RestoreSession() { |
| + DCHECK(browser_list_) << "RestoreSession called after Shutdown."; |
| + SessionIOS* session = |
| + [session_service_ loadSessionFromDirectory:session_directory_]; |
| + if (!session) |
| + return false; |
| + |
| + DCHECK_LE(session.sessionWindows.count, static_cast<NSUInteger>(INT_MAX)); |
| + for (NSUInteger index = 0; index < session.sessionWindows.count; ++index) { |
| + Browser* browser = |
| + static_cast<int>(index) < browser_list_->count() |
| + ? browser_list_->GetBrowserAtIndex(static_cast<int>(index)) |
| + : browser_list_->CreateNewBrowser(); |
| + |
| + SessionWindowIOS* session_window = session.sessionWindows[index]; |
| + if (!session_window.sessions.count) |
| + continue; |
| + |
| + WebStateList& web_state_list = browser->web_state_list(); |
| + const int old_count = web_state_list.count(); |
| + DeserializeWebStateList(&web_state_list, session_window, create_web_state_); |
| + DCHECK_GT(web_state_list.count(), old_count); |
| + |
| + if (old_count != 1) |
|
marq (ping after 24h)
2017/05/09 10:18:59
Can you add comments to spell out the case that's
sdefresne
2017/05/11 15:57:59
Done.
|
| + continue; |
| + |
| + web::WebState* web_state = web_state_list.GetWebStateAt(0); |
| + web::NavigationItem* navigation_item = |
| + web_state->GetNavigationManager()->GetLastCommittedItem(); |
| + if (!navigation_item) |
| + continue; |
| + |
| + if (navigation_item->GetURL() != kChromeUINewTabURL) |
|
marq (ping after 24h)
2017/05/09 10:18:59
Note that it's possible to have an NTP in the midd
sdefresne
2017/05/11 15:57:59
Currently code in TabModel does not check for any
marq (ping after 24h)
2017/05/12 07:48:35
Look good, thanks.
|
| + continue; |
| + |
| + web_state_list.CloseWebStateAt(0); |
| + } |
| + |
| + return true; |
| +} |
| + |
| +void BrowserListSessionServiceImpl::ScheduleLastSessionDeletion() { |
| + DCHECK(browser_list_) << "ScheduleLastSessionDeletion called after Shutdown."; |
| + [session_service_ deleteLastSessionFileInDirectory:session_directory_]; |
| +} |
| + |
| +void BrowserListSessionServiceImpl::ScheduleSaveSession(bool immediately) { |
| + DCHECK(browser_list_) << "ScheduleSaveSession called after Shutdown."; |
| + DCHECK_GE(browser_list_->count(), 0); |
| + const int count = browser_list_->count(); |
| + NSMutableArray<SessionWindowIOS*>* windows = |
| + [NSMutableArray arrayWithCapacity:static_cast<NSUInteger>(count)]; |
| + for (int index = 0; index < count; ++index) { |
| + Browser* browser = browser_list_->GetBrowserAtIndex(index); |
| + [windows addObject:SerializeWebStateList(&browser->web_state_list())]; |
| + } |
| + |
| + [session_service_ saveSession:[[SessionIOS alloc] initWithWindows:windows] |
| + directory:session_directory_ |
| + immediately:!!immediately]; |
|
marq (ping after 24h)
2017/05/09 10:18:59
Is the !! to avoid bool-to-BOOL weirdness in 32-bi
sdefresne
2017/05/11 15:57:59
This is because bool != BOOL (even in 64-bit) but
|
| +} |
| + |
| +void BrowserListSessionServiceImpl::Shutdown() { |
| + // Stop observing the BrowserList before it is destroyed (BrowserList is a |
| + // base::SupportsUserData::Data attached to ChromeBrowserState so it will |
| + // be destroyed after the KeyedService two-stage shutdown). |
| + browser_list_ = nullptr; |
| + observer_.reset(); |
| +} |