91 lines
3 KiB
C++
91 lines
3 KiB
C++
// Copyright (c) 2014 GitHub, Inc.
|
|
// Use of this source code is governed by the MIT license that can be
|
|
// found in the LICENSE file.
|
|
|
|
#include "atom/browser/atom_access_token_store.h"
|
|
|
|
#include <string>
|
|
#include <utility>
|
|
|
|
#include "atom/browser/atom_browser_context.h"
|
|
#include "atom/common/google_api_key.h"
|
|
#include "base/environment.h"
|
|
#include "content/public/browser/browser_thread.h"
|
|
#include "content/public/browser/geolocation_provider.h"
|
|
|
|
using content::BrowserThread;
|
|
|
|
namespace atom {
|
|
|
|
namespace internal {
|
|
|
|
// Loads access tokens and other necessary data on the UI thread, and
|
|
// calls back to the originator on the originating thread.
|
|
class TokenLoadingJob : public base::RefCountedThreadSafe<TokenLoadingJob> {
|
|
public:
|
|
explicit TokenLoadingJob(
|
|
const content::AccessTokenStore::LoadAccessTokensCallback& callback)
|
|
: callback_(callback), request_context_getter_(nullptr) {}
|
|
|
|
void Run(AtomBrowserContext* browser_context) {
|
|
DCHECK_CURRENTLY_ON(BrowserThread::UI);
|
|
request_context_getter_ = browser_context->GetRequestContext();
|
|
std::unique_ptr<base::Environment> env(base::Environment::Create());
|
|
if (!env->GetVar("GOOGLE_API_KEY", &api_key_))
|
|
api_key_ = GOOGLEAPIS_API_KEY;
|
|
BrowserThread::PostTask(
|
|
BrowserThread::IO, FROM_HERE,
|
|
base::Bind(&TokenLoadingJob::RespondOnIOThread, this));
|
|
}
|
|
|
|
private:
|
|
friend class base::RefCountedThreadSafe<TokenLoadingJob>;
|
|
|
|
~TokenLoadingJob() {}
|
|
|
|
void RespondOnIOThread() {
|
|
// Equivalent to access_token_map[kGeolocationProviderURL].
|
|
// Somehow base::string16 is causing compilation errors when used in a pair
|
|
// of std::map on Linux, this can work around it.
|
|
content::AccessTokenStore::AccessTokenMap access_token_map;
|
|
std::pair<GURL, base::string16> token_pair;
|
|
token_pair.first = GURL(GOOGLEAPIS_ENDPOINT + api_key_);
|
|
access_token_map.insert(token_pair);
|
|
|
|
callback_.Run(access_token_map, request_context_getter_);
|
|
}
|
|
|
|
content::AccessTokenStore::LoadAccessTokensCallback callback_;
|
|
net::URLRequestContextGetter* request_context_getter_;
|
|
std::string api_key_;
|
|
};
|
|
|
|
} // namespace internal
|
|
|
|
AtomAccessTokenStore::AtomAccessTokenStore() {
|
|
browser_context_ = AtomBrowserContext::From("", false);
|
|
content::GeolocationProvider::GetInstance()->UserDidOptIntoLocationServices();
|
|
}
|
|
|
|
AtomAccessTokenStore::~AtomAccessTokenStore() {
|
|
}
|
|
|
|
void AtomAccessTokenStore::LoadAccessTokens(
|
|
const LoadAccessTokensCallback& callback) {
|
|
scoped_refptr<internal::TokenLoadingJob> job(
|
|
new internal::TokenLoadingJob(callback));
|
|
BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
|
|
base::Bind(&AtomAccessTokenStore::RunTokenLoadingJob,
|
|
this, base::RetainedRef(job)));
|
|
}
|
|
|
|
void AtomAccessTokenStore::RunTokenLoadingJob(
|
|
scoped_refptr<internal::TokenLoadingJob> job) {
|
|
job->Run(browser_context_.get());
|
|
}
|
|
|
|
void AtomAccessTokenStore::SaveAccessToken(const GURL& server_url,
|
|
const base::string16& access_token) {
|
|
}
|
|
|
|
} // namespace atom
|