OLD | NEW |
1 // Copyright 2012 The Chromium Authors. All rights reserved. | 1 // Copyright 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "ios/chrome/browser/omaha/omaha_service.h" | 5 #include "ios/chrome/browser/omaha/omaha_service.h" |
6 | 6 |
7 #import <Foundation/Foundation.h> | 7 #import <Foundation/Foundation.h> |
8 | 8 |
9 #include <memory> | 9 #include <memory> |
10 #include <utility> | 10 #include <utility> |
11 | 11 |
12 #include "base/bind.h" | 12 #include "base/bind.h" |
13 #include "base/i18n/time_formatting.h" | 13 #include "base/i18n/time_formatting.h" |
14 #include "base/ios/device_util.h" | 14 #include "base/ios/device_util.h" |
15 #include "base/logging.h" | 15 #include "base/logging.h" |
16 #include "base/mac/scoped_nsobject.h" | |
17 #include "base/memory/ptr_util.h" | 16 #include "base/memory/ptr_util.h" |
18 #include "base/metrics/field_trial.h" | 17 #include "base/metrics/field_trial.h" |
19 #include "base/rand_util.h" | 18 #include "base/rand_util.h" |
20 #include "base/strings/stringprintf.h" | 19 #include "base/strings/stringprintf.h" |
21 #include "base/strings/sys_string_conversions.h" | 20 #include "base/strings/sys_string_conversions.h" |
22 #include "base/strings/utf_string_conversions.h" | 21 #include "base/strings/utf_string_conversions.h" |
23 #include "base/sys_info.h" | 22 #include "base/sys_info.h" |
24 #include "base/time/time.h" | 23 #include "base/time/time.h" |
25 #include "base/values.h" | 24 #include "base/values.h" |
26 #include "components/metrics/metrics_pref_names.h" | 25 #include "components/metrics/metrics_pref_names.h" |
(...skipping 10 matching lines...) Expand all Loading... |
37 #include "ios/public/provider/chrome/browser/chrome_browser_provider.h" | 36 #include "ios/public/provider/chrome/browser/chrome_browser_provider.h" |
38 #include "ios/public/provider/chrome/browser/omaha/omaha_service_provider.h" | 37 #include "ios/public/provider/chrome/browser/omaha/omaha_service_provider.h" |
39 #include "ios/public/provider/chrome/browser/omaha/omaha_xml_writer.h" | 38 #include "ios/public/provider/chrome/browser/omaha/omaha_xml_writer.h" |
40 #include "ios/web/public/web_thread.h" | 39 #include "ios/web/public/web_thread.h" |
41 #include "libxml/xmlwriter.h" | 40 #include "libxml/xmlwriter.h" |
42 #include "net/base/backoff_entry.h" | 41 #include "net/base/backoff_entry.h" |
43 #include "net/base/load_flags.h" | 42 #include "net/base/load_flags.h" |
44 #include "net/url_request/url_fetcher.h" | 43 #include "net/url_request/url_fetcher.h" |
45 #include "url/gurl.h" | 44 #include "url/gurl.h" |
46 | 45 |
| 46 #if !defined(__has_feature) || !__has_feature(objc_arc) |
| 47 #error "This file requires ARC support." |
| 48 #endif |
| 49 |
47 namespace { | 50 namespace { |
48 // Number of hours to wait between successful requests. | 51 // Number of hours to wait between successful requests. |
49 const int kHoursBetweenRequests = 5; | 52 const int kHoursBetweenRequests = 5; |
50 // Minimal time to wait between retry requests. | 53 // Minimal time to wait between retry requests. |
51 const CFTimeInterval kPostRetryBaseSeconds = 3600; | 54 const CFTimeInterval kPostRetryBaseSeconds = 3600; |
52 // Maximal time to wait between retry requests. | 55 // Maximal time to wait between retry requests. |
53 const CFTimeInterval kPostRetryMaxSeconds = 6 * kPostRetryBaseSeconds; | 56 const CFTimeInterval kPostRetryMaxSeconds = 6 * kPostRetryBaseSeconds; |
54 | 57 |
55 // Default last sent application version when none has been sent yet. | 58 // Default last sent application version when none has been sent yet. |
56 const char kDefaultLastSentVersion[] = "0.0.0.0"; | 59 const char kDefaultLastSentVersion[] = "0.0.0.0"; |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
120 // XML parser for the server response. | 123 // XML parser for the server response. |
121 @interface ResponseParser : NSObject<NSXMLParserDelegate> { | 124 @interface ResponseParser : NSObject<NSXMLParserDelegate> { |
122 BOOL hasError_; | 125 BOOL hasError_; |
123 BOOL responseIsParsed_; | 126 BOOL responseIsParsed_; |
124 BOOL appIsParsed_; | 127 BOOL appIsParsed_; |
125 BOOL updateCheckIsParsed_; | 128 BOOL updateCheckIsParsed_; |
126 BOOL urlIsParsed_; | 129 BOOL urlIsParsed_; |
127 BOOL manifestIsParsed_; | 130 BOOL manifestIsParsed_; |
128 BOOL pingIsParsed_; | 131 BOOL pingIsParsed_; |
129 BOOL eventIsParsed_; | 132 BOOL eventIsParsed_; |
130 base::scoped_nsobject<NSString> appId_; | 133 NSString* appId_; |
131 std::unique_ptr<UpgradeRecommendedDetails> updateInformation_; | 134 std::unique_ptr<UpgradeRecommendedDetails> updateInformation_; |
132 } | 135 } |
133 | 136 |
134 // Initialization method. |appId| is the application id one expects to find in | 137 // Initialization method. |appId| is the application id one expects to find in |
135 // the response message. | 138 // the response message. |
136 - (instancetype)initWithAppId:(NSString*)appId; | 139 - (instancetype)initWithAppId:(NSString*)appId; |
137 | 140 |
138 // Returns YES if the message has been correctly parsed. | 141 // Returns YES if the message has been correctly parsed. |
139 - (BOOL)isCorrect; | 142 - (BOOL)isCorrect; |
140 | 143 |
141 // If an upgrade is possible, returns the details of the notification to send. | 144 // If an upgrade is possible, returns the details of the notification to send. |
142 // Otherwise, return NULL. | 145 // Otherwise, return NULL. |
143 - (UpgradeRecommendedDetails*)upgradeRecommendedDetails; | 146 - (UpgradeRecommendedDetails*)upgradeRecommendedDetails; |
144 | 147 |
145 @end | 148 @end |
146 | 149 |
147 @implementation ResponseParser | 150 @implementation ResponseParser |
148 | 151 |
149 - (instancetype)initWithAppId:(NSString*)appId { | 152 - (instancetype)initWithAppId:(NSString*)appId { |
150 if (self = [super init]) { | 153 if (self = [super init]) { |
151 appId_.reset([appId retain]); | 154 appId_ = appId; |
152 } | 155 } |
153 return self; | 156 return self; |
154 } | 157 } |
155 | 158 |
156 - (BOOL)isCorrect { | 159 - (BOOL)isCorrect { |
157 // A response should have either a ping ACK or an event ACK, depending on the | 160 // A response should have either a ping ACK or an event ACK, depending on the |
158 // contents of the request. | 161 // contents of the request. |
159 return !hasError_ && (pingIsParsed_ || eventIsParsed_); | 162 return !hasError_ && (pingIsParsed_ || eventIsParsed_); |
160 } | 163 } |
161 | 164 |
(...skipping 427 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
589 if (fetcher->GetResponseCode() != 200) { | 592 if (fetcher->GetResponseCode() != 200) { |
590 DLOG(WARNING) << "Error contacting the Omaha server"; | 593 DLOG(WARNING) << "Error contacting the Omaha server"; |
591 SendOrScheduleNextPing(); | 594 SendOrScheduleNextPing(); |
592 return; | 595 return; |
593 } | 596 } |
594 | 597 |
595 std::string response; | 598 std::string response; |
596 bool result = fetcher->GetResponseAsString(&response); | 599 bool result = fetcher->GetResponseAsString(&response); |
597 DCHECK(result); | 600 DCHECK(result); |
598 NSData* xml = [NSData dataWithBytes:response.data() length:response.length()]; | 601 NSData* xml = [NSData dataWithBytes:response.data() length:response.length()]; |
599 base::scoped_nsobject<NSXMLParser> parser( | 602 NSXMLParser* parser = [[NSXMLParser alloc] initWithData:xml]; |
600 [[NSXMLParser alloc] initWithData:xml]); | |
601 const std::string application_id = ios::GetChromeBrowserProvider() | 603 const std::string application_id = ios::GetChromeBrowserProvider() |
602 ->GetOmahaServiceProvider() | 604 ->GetOmahaServiceProvider() |
603 ->GetApplicationID(); | 605 ->GetApplicationID(); |
604 base::scoped_nsobject<ResponseParser> delegate([[ResponseParser alloc] | 606 ResponseParser* delegate = [[ResponseParser alloc] |
605 initWithAppId:base::SysUTF8ToNSString(application_id)]); | 607 initWithAppId:base::SysUTF8ToNSString(application_id)]; |
606 parser.get().delegate = delegate.get(); | 608 parser.delegate = delegate; |
607 | 609 |
608 if (![parser parse] || ![delegate isCorrect]) { | 610 if (![parser parse] || ![delegate isCorrect]) { |
609 DLOG(ERROR) << "Unable to parse XML response from Omaha server."; | 611 DLOG(ERROR) << "Unable to parse XML response from Omaha server."; |
610 SendOrScheduleNextPing(); | 612 SendOrScheduleNextPing(); |
611 return; | 613 return; |
612 } | 614 } |
613 // Handle success. | 615 // Handle success. |
614 number_of_tries_ = 0; | 616 number_of_tries_ = 0; |
615 // Schedule the next request. If requset that just finished was an install | 617 // Schedule the next request. If requset that just finished was an install |
616 // notification, send an active ping immediately. | 618 // notification, send an active ping immediately. |
617 next_tries_time_ = sending_install_event_ | 619 next_tries_time_ = sending_install_event_ |
618 ? base::Time::Now() | 620 ? base::Time::Now() |
619 : base::Time::Now() + base::TimeDelta::FromHours( | 621 : base::Time::Now() + base::TimeDelta::FromHours( |
620 kHoursBetweenRequests); | 622 kHoursBetweenRequests); |
621 current_ping_time_ = next_tries_time_; | 623 current_ping_time_ = next_tries_time_; |
622 last_sent_time_ = base::Time::Now(); | 624 last_sent_time_ = base::Time::Now(); |
623 last_sent_version_ = base::Version(version_info::GetVersionNumber()); | 625 last_sent_version_ = base::Version(version_info::GetVersionNumber()); |
624 sending_install_event_ = false; | 626 sending_install_event_ = false; |
625 ClearInstallRetryRequestId(); | 627 ClearInstallRetryRequestId(); |
626 PersistStates(); | 628 PersistStates(); |
627 SendOrScheduleNextPing(); | 629 SendOrScheduleNextPing(); |
628 | 630 |
629 // Send notification for updates if needed. | 631 // Send notification for updates if needed. |
630 UpgradeRecommendedDetails* details = | 632 UpgradeRecommendedDetails* details = [delegate upgradeRecommendedDetails]; |
631 [delegate.get() upgradeRecommendedDetails]; | |
632 if (details) { | 633 if (details) { |
633 web::WebThread::PostTask( | 634 web::WebThread::PostTask( |
634 web::WebThread::UI, FROM_HERE, | 635 web::WebThread::UI, FROM_HERE, |
635 base::Bind(upgrade_recommended_callback_, *details)); | 636 base::Bind(upgrade_recommended_callback_, *details)); |
636 } | 637 } |
637 } | 638 } |
638 | 639 |
639 void OmahaService::GetDebugInformationOnIOThread( | 640 void OmahaService::GetDebugInformationOnIOThread( |
640 const base::Callback<void(base::DictionaryValue*)> callback) { | 641 const base::Callback<void(base::DictionaryValue*)> callback) { |
641 auto result = base::MakeUnique<base::DictionaryValue>(); | 642 auto result = base::MakeUnique<base::DictionaryValue>(); |
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
701 | 702 |
702 void OmahaService::ClearPersistentStateForTests() { | 703 void OmahaService::ClearPersistentStateForTests() { |
703 NSUserDefaults* defaults = [NSUserDefaults standardUserDefaults]; | 704 NSUserDefaults* defaults = [NSUserDefaults standardUserDefaults]; |
704 [defaults removeObjectForKey:kNextTriesTimesKey]; | 705 [defaults removeObjectForKey:kNextTriesTimesKey]; |
705 [defaults removeObjectForKey:kCurrentPingKey]; | 706 [defaults removeObjectForKey:kCurrentPingKey]; |
706 [defaults removeObjectForKey:kNumberTriesKey]; | 707 [defaults removeObjectForKey:kNumberTriesKey]; |
707 [defaults removeObjectForKey:kLastSentVersionKey]; | 708 [defaults removeObjectForKey:kLastSentVersionKey]; |
708 [defaults removeObjectForKey:kLastSentTimeKey]; | 709 [defaults removeObjectForKey:kLastSentTimeKey]; |
709 [defaults removeObjectForKey:kRetryRequestIdKey]; | 710 [defaults removeObjectForKey:kRetryRequestIdKey]; |
710 } | 711 } |
OLD | NEW |