blob: 367b4a0bf7e97c7227b5ae35c792cbb8660849be (
plain)
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
|
// 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.
#ifndef CHROME_BROWSER_CHROMEOS_CONTACTS_GDATA_CONTACTS_SERVICE_H_
#define CHROME_BROWSER_CHROMEOS_CONTACTS_GDATA_CONTACTS_SERVICE_H_
#include <set>
#include <string>
#include "base/basictypes.h"
#include "base/callback.h"
#include "base/compiler_specific.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/scoped_vector.h"
#include "base/time.h"
#include "googleurl/src/gurl.h"
class Profile;
namespace base {
class Value;
} // namespace base
namespace google_apis {
class AuthService;
class OperationRunner;
} // namespace google_apis
namespace net {
class URLRequestContextGetter;
} // namespace net
namespace contacts {
class Contact;
// Interface for fetching a user's Google contacts via the Contacts API
// (described at https://developers.google.com/google-apps/contacts/v3/).
class GDataContactsServiceInterface {
public:
typedef base::Callback<void(scoped_ptr<ScopedVector<contacts::Contact> >)>
SuccessCallback;
typedef base::Closure FailureCallback;
virtual ~GDataContactsServiceInterface() {}
virtual void Initialize() = 0;
// Downloads all contacts changed at or after |min_update_time| and invokes
// the appropriate callback asynchronously on the UI thread when complete. If
// min_update_time.is_null() is true, all contacts will be returned.
virtual void DownloadContacts(SuccessCallback success_callback,
FailureCallback failure_callback,
const base::Time& min_update_time) = 0;
protected:
GDataContactsServiceInterface() {}
private:
DISALLOW_COPY_AND_ASSIGN(GDataContactsServiceInterface);
};
class GDataContactsService : public GDataContactsServiceInterface {
public:
typedef base::Callback<std::string(const std::string&)>
RewritePhotoUrlCallback;
GDataContactsService(
net::URLRequestContextGetter* url_request_context_getter,
Profile* profile);
virtual ~GDataContactsService();
google_apis::AuthService* auth_service_for_testing();
const std::string& cached_my_contacts_group_id_for_testing() const {
return cached_my_contacts_group_id_;
}
void clear_cached_my_contacts_group_id_for_testing() {
cached_my_contacts_group_id_.clear();
}
void set_max_photo_downloads_per_second_for_testing(int max_downloads) {
max_photo_downloads_per_second_ = max_downloads;
}
void set_photo_download_timer_interval_for_testing(base::TimeDelta interval) {
photo_download_timer_interval_ = interval;
}
void set_groups_feed_url_for_testing(const GURL& url) {
groups_feed_url_for_testing_ = url;
}
void set_contacts_feed_url_for_testing(const GURL& url) {
contacts_feed_url_for_testing_ = url;
}
void set_rewrite_photo_url_callback_for_testing(RewritePhotoUrlCallback cb) {
rewrite_photo_url_callback_for_testing_ = cb;
}
// Overridden from GDataContactsServiceInterface:
virtual void Initialize() OVERRIDE;
virtual void DownloadContacts(SuccessCallback success_callback,
FailureCallback failure_callback,
const base::Time& min_update_time) OVERRIDE;
private:
class DownloadContactsRequest;
// Invoked by a download request once it's finished (either successfully or
// unsuccessfully).
void OnRequestComplete(DownloadContactsRequest* request);
net::URLRequestContextGetter* url_request_context_getter_; // not owned
scoped_ptr<google_apis::OperationRunner> runner_;
// Group ID for the "My Contacts" system contacts group.
// Cached after a DownloadContactsRequest has completed.
std::string cached_my_contacts_group_id_;
// In-progress download requests. Pointers are owned by this class.
std::set<DownloadContactsRequest*> requests_;
// Maximum number of photos we'll try to download per second (per
// DownloadContacts() request).
int max_photo_downloads_per_second_;
// Amount of time that we'll wait between waves of photo download requests.
// This is usually one second (see |max_photo_downloads_per_second_|) but can
// be set to a lower value for tests to make them complete more quickly.
base::TimeDelta photo_download_timer_interval_;
// If non-empty, URLs that will be used to fetch feeds.
GURL groups_feed_url_for_testing_;
GURL contacts_feed_url_for_testing_;
// Callback that's invoked to rewrite photo URLs for tests.
// This is needed for tests that serve static feed data from a host/port
// that's only known at runtime.
RewritePhotoUrlCallback rewrite_photo_url_callback_for_testing_;
DISALLOW_COPY_AND_ASSIGN(GDataContactsService);
};
} // namespace contacts
#endif // CHROME_BROWSER_CHROMEOS_CONTACTS_GDATA_CONTACTS_SERVICE_H_
|
