Skip to content
This repository was archived by the owner on May 20, 2025. It is now read-only.

Commit 0ee423c

Browse files
geof90geof90
committed
retry report status
1 parent 3ba181a commit 0ee423c

File tree

7 files changed

+215
-65
lines changed

7 files changed

+215
-65
lines changed

‎CodePush.js

Lines changed: 31 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { AcquisitionManager as Sdk } from "code-push/script/acquisition-sdk";
22
import { Alert } from "./AlertAdapter";
33
import requestFetchAdapter from "./request-fetch-adapter";
4-
import { Platform } from "react-native";
4+
import { AppState, Platform } from "react-native";
55

66
let NativeCodePush = require("react-native").NativeModules.CodePush;
77
const PackageMixins = require("./package-mixins")(NativeCodePush);
@@ -174,19 +174,42 @@ const notifyApplicationReady = (() => {
174174

175175
async function notifyApplicationReadyInternal() {
176176
await NativeCodePush.notifyApplicationReady();
177+
tryReportStatus();
178+
}
179+
180+
async function tryReportStatus(resumeListener) {
177181
const statusReport = await NativeCodePush.getNewStatusReport();
178182
if (statusReport) {
179183
const config = await getConfiguration();
180184
const previousLabelOrAppVersion = statusReport.previousLabelOrAppVersion;
181185
const previousDeploymentKey = statusReport.previousDeploymentKey || config.deploymentKey;
182-
if (statusReport.appVersion) {
183-
const sdk = getPromisifiedSdk(requestFetchAdapter, config);
184-
sdk.reportStatusDeploy(/* deployedPackage */ null, /* status */ null, previousLabelOrAppVersion, previousDeploymentKey);
185-
} else {
186-
config.deploymentKey = statusReport.package.deploymentKey;
187-
const sdk = getPromisifiedSdk(requestFetchAdapter, config);
188-
sdk.reportStatusDeploy(statusReport.package, statusReport.status, previousLabelOrAppVersion, previousDeploymentKey);
186+
try {
187+
if (statusReport.appVersion) {
188+
const sdk = getPromisifiedSdk(requestFetchAdapter, config);
189+
await sdk.reportStatusDeploy(/* deployedPackage */ null, /* status */ null, previousLabelOrAppVersion, previousDeploymentKey);
190+
} else {
191+
config.deploymentKey = statusReport.package.deploymentKey;
192+
const sdk = getPromisifiedSdk(requestFetchAdapter, config);
193+
await sdk.reportStatusDeploy(statusReport.package, statusReport.status, previousLabelOrAppVersion, previousDeploymentKey);
194+
}
195+
196+
log(`Reported status: ${JSON.stringify(statusReport)}`);
197+
NativeCodePush.recordStatusReported(statusReport);
198+
resumeListener && AppState.removeEventListener("change", resumeListener);
199+
} catch (e) {
200+
log(`Report status failed: ${JSON.stringify(statusReport)}`);
201+
NativeCodePush.saveStatusReportForRetry(statusReport);
202+
// Try again when the app resumes
203+
if (!resumeListener) {
204+
resumeListener = (newState) => {
205+
newState === "active" && tryReportStatus(resumeListener);
206+
};
207+
208+
AppState.addEventListener("change", resumeListener);
209+
}
189210
}
211+
} else {
212+
resumeListener && AppState.removeEventListener("change", resumeListener);
190213
}
191214
}
192215

‎android/app/src/main/java/com/microsoft/codepush/react/CodePush.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -626,6 +626,12 @@ protected Void doInBackground(Void... params) {
626626
promise.resolve(newAppVersionStatusReport);
627627
return null;
628628
}
629+
} else {
630+
WritableMap retryStatusReport = codePushTelemetryManager.getRetryStatusReport();
631+
if (retryStatusReport != null) {
632+
promise.resolve(retryStatusReport);
633+
return null;
634+
}
629635
}
630636

631637
promise.resolve("");
@@ -720,6 +726,11 @@ public void notifyApplicationReady(Promise promise) {
720726
promise.resolve("");
721727
}
722728

729+
@ReactMethod
730+
public void recordStatusReported(ReadableMap statusReport) {
731+
codePushTelemetryManager.recordStatusReported(statusReport);
732+
}
733+
723734
@ReactMethod
724735
public void restartApp(boolean onlyIfUpdateIsPending) {
725736
// If this is an unconditional restart request, or there
@@ -729,6 +740,11 @@ public void restartApp(boolean onlyIfUpdateIsPending) {
729740
}
730741
}
731742

743+
@ReactMethod
744+
public void saveStatusReportForRetry(ReadableMap statusReport) {
745+
codePushTelemetryManager.saveStatusReportForRetry(statusReport);
746+
}
747+
732748
@ReactMethod
733749
// Replaces the current bundle with the one downloaded from removeBundleUrl.
734750
// It is only to be used during tests. No-ops if the test configuration flag is not set.

‎android/app/src/main/java/com/microsoft/codepush/react/CodePushTelemetryManager.java

Lines changed: 70 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -3,18 +3,28 @@
33
import android.content.Context;
44
import android.content.SharedPreferences;
55

6+
import com.facebook.react.bridge.ReadableMap;
67
import com.facebook.react.bridge.WritableMap;
78
import com.facebook.react.bridge.WritableNativeMap;
89

10+
import org.json.JSONException;
11+
import org.json.JSONObject;
12+
913
public class CodePushTelemetryManager {
1014

1115
private Context applicationContext;
16+
private final String APP_VERSION_KEY = "appVersion";
1217
private final String CODE_PUSH_PREFERENCES;
1318
private final String DEPLOYMENT_FAILED_STATUS = "DeploymentFailed";
1419
private final String DEPLOYMENT_KEY_KEY = "deploymentKey";
1520
private final String DEPLOYMENT_SUCCEEDED_STATUS = "DeploymentSucceeded";
1621
private final String LABEL_KEY = "label";
1722
private final String LAST_DEPLOYMENT_REPORT_KEY = "CODE_PUSH_LAST_DEPLOYMENT_REPORT";
23+
private final String PACKAGE_KEY = "package";
24+
private final String PREVIOUS_DEPLOYMENT_KEY_KEY = "previousDeploymentKey";
25+
private final String PREVIOUS_LABEL_OR_APP_VERSION_KEY = "previousLabelOrAppVersion";
26+
private final String RETRY_DEPLOYMENT_REPORT_KEY = "CODE_PUSH_RETRY_DEPLOYMENT_REPORT";
27+
private final String STATUS_KEY = "status";
1828

1929
public CodePushTelemetryManager(Context applicationContext, String codePushPreferencesKey) {
2030
this.applicationContext = applicationContext;
@@ -24,34 +34,51 @@ public CodePushTelemetryManager(Context applicationContext, String codePushPrefe
2434
public WritableMap getBinaryUpdateReport(String appVersion) {
2535
String previousStatusReportIdentifier = this.getPreviousStatusReportIdentifier();
2636
if (previousStatusReportIdentifier == null) {
27-
this.recordDeploymentStatusReported(appVersion);
37+
this.clearRetryStatusReport();
2838
WritableNativeMap reportMap = new WritableNativeMap();
29-
reportMap.putString("appVersion", appVersion);
39+
reportMap.putString(APP_VERSION_KEY, appVersion);
3040
return reportMap;
3141
} else if (!previousStatusReportIdentifier.equals(appVersion)) {
32-
this.recordDeploymentStatusReported(appVersion);
42+
this.clearRetryStatusReport();
3343
WritableNativeMap reportMap = new WritableNativeMap();
3444
if (this.isStatusReportIdentifierCodePushLabel(previousStatusReportIdentifier)) {
3545
String previousDeploymentKey = this.getDeploymentKeyFromStatusReportIdentifier(previousStatusReportIdentifier);
3646
String previousLabel = this.getVersionLabelFromStatusReportIdentifier(previousStatusReportIdentifier);
37-
reportMap.putString("appVersion", appVersion);
38-
reportMap.putString("previousDeploymentKey", previousDeploymentKey);
39-
reportMap.putString("previousLabelOrAppVersion", previousLabel);
47+
reportMap.putString(APP_VERSION_KEY, appVersion);
48+
reportMap.putString(PREVIOUS_DEPLOYMENT_KEY_KEY, previousDeploymentKey);
49+
reportMap.putString(PREVIOUS_LABEL_OR_APP_VERSION_KEY, previousLabel);
4050
} else {
4151
// Previous status report was with a binary app version.
42-
reportMap.putString("appVersion", appVersion);
43-
reportMap.putString("previousLabelOrAppVersion", previousStatusReportIdentifier);
52+
reportMap.putString(APP_VERSION_KEY, appVersion);
53+
reportMap.putString(PREVIOUS_LABEL_OR_APP_VERSION_KEY, previousStatusReportIdentifier);
4454
}
4555
return reportMap;
4656
}
4757

4858
return null;
4959
}
5060

61+
public WritableMap getRetryStatusReport() {
62+
SharedPreferences settings = applicationContext.getSharedPreferences(CODE_PUSH_PREFERENCES, 0);
63+
String retryStatusReportString = settings.getString(RETRY_DEPLOYMENT_REPORT_KEY, null);
64+
if (retryStatusReportString != null) {
65+
clearRetryStatusReport();
66+
try {
67+
JSONObject retryStatusReport = new JSONObject(retryStatusReportString);
68+
return CodePushUtils.convertJsonObjectToWritable(retryStatusReport);
69+
} catch (JSONException e) {
70+
e.printStackTrace();
71+
return null;
72+
}
73+
}
74+
75+
return null;
76+
}
77+
5178
public WritableMap getRollbackReport(WritableMap lastFailedPackage) {
5279
WritableNativeMap reportMap = new WritableNativeMap();
53-
reportMap.putMap("package", lastFailedPackage);
54-
reportMap.putString("status", DEPLOYMENT_FAILED_STATUS);
80+
reportMap.putMap(PACKAGE_KEY, lastFailedPackage);
81+
reportMap.putString(STATUS_KEY, DEPLOYMENT_FAILED_STATUS);
5582
return reportMap;
5683
}
5784

@@ -60,28 +87,28 @@ public WritableMap getUpdateReport(WritableMap currentPackage) {
6087
String previousStatusReportIdentifier = this.getPreviousStatusReportIdentifier();
6188
if (currentPackageIdentifier != null) {
6289
if (previousStatusReportIdentifier == null) {
63-
this.recordDeploymentStatusReported(currentPackageIdentifier);
90+
this.clearRetryStatusReport();
6491
WritableNativeMap reportMap = new WritableNativeMap();
65-
reportMap.putMap("package", currentPackage);
66-
reportMap.putString("status", DEPLOYMENT_SUCCEEDED_STATUS);
92+
reportMap.putMap(PACKAGE_KEY, currentPackage);
93+
reportMap.putString(STATUS_KEY, DEPLOYMENT_SUCCEEDED_STATUS);
6794
return reportMap;
6895
} else if (!previousStatusReportIdentifier.equals(currentPackageIdentifier)) {
69-
this.recordDeploymentStatusReported(currentPackageIdentifier);
96+
this.clearRetryStatusReport();
7097
if (this.isStatusReportIdentifierCodePushLabel(previousStatusReportIdentifier)) {
7198
String previousDeploymentKey = this.getDeploymentKeyFromStatusReportIdentifier(previousStatusReportIdentifier);
7299
String previousLabel = this.getVersionLabelFromStatusReportIdentifier(previousStatusReportIdentifier);
73100
WritableNativeMap reportMap = new WritableNativeMap();
74-
reportMap.putMap("package", currentPackage);
75-
reportMap.putString("status", DEPLOYMENT_SUCCEEDED_STATUS);
76-
reportMap.putString("previousDeploymentKey", previousDeploymentKey);
77-
reportMap.putString("previousLabelOrAppVersion", previousLabel);
101+
reportMap.putMap(PACKAGE_KEY, currentPackage);
102+
reportMap.putString(STATUS_KEY, DEPLOYMENT_SUCCEEDED_STATUS);
103+
reportMap.putString(PREVIOUS_DEPLOYMENT_KEY_KEY, previousDeploymentKey);
104+
reportMap.putString(PREVIOUS_LABEL_OR_APP_VERSION_KEY, previousLabel);
78105
return reportMap;
79106
} else {
80107
// Previous status report was with a binary app version.
81108
WritableNativeMap reportMap = new WritableNativeMap();
82-
reportMap.putMap("package", currentPackage);
83-
reportMap.putString("status", DEPLOYMENT_SUCCEEDED_STATUS);
84-
reportMap.putString("previousLabelOrAppVersion", previousStatusReportIdentifier);
109+
reportMap.putMap(PACKAGE_KEY, currentPackage);
110+
reportMap.putString(STATUS_KEY, DEPLOYMENT_SUCCEEDED_STATUS);
111+
reportMap.putString(PREVIOUS_LABEL_OR_APP_VERSION_KEY, previousStatusReportIdentifier);
85112
return reportMap;
86113
}
87114
}
@@ -90,6 +117,26 @@ public WritableMap getUpdateReport(WritableMap currentPackage) {
90117
return null;
91118
}
92119

120+
public void recordStatusReported(ReadableMap statusReport) {
121+
if (statusReport.hasKey(APP_VERSION_KEY)) {
122+
saveStatusReportedForIdentifier(statusReport.getString(APP_VERSION_KEY));
123+
} else if (statusReport.hasKey(PACKAGE_KEY)) {
124+
String packageIdentifier = getPackageStatusReportIdentifier(statusReport.getMap(PACKAGE_KEY));
125+
saveStatusReportedForIdentifier(packageIdentifier);
126+
}
127+
}
128+
129+
public void saveStatusReportForRetry(ReadableMap statusReport) {
130+
SharedPreferences settings = applicationContext.getSharedPreferences(CODE_PUSH_PREFERENCES, 0);
131+
JSONObject statusReportJSON = CodePushUtils.convertReadableToJsonObject(statusReport);
132+
settings.edit().putString(RETRY_DEPLOYMENT_REPORT_KEY, statusReportJSON.toString()).commit();
133+
}
134+
135+
private void clearRetryStatusReport() {
136+
SharedPreferences settings = applicationContext.getSharedPreferences(CODE_PUSH_PREFERENCES, 0);
137+
settings.edit().remove(RETRY_DEPLOYMENT_REPORT_KEY).commit();
138+
}
139+
93140
private String getDeploymentKeyFromStatusReportIdentifier(String statusReportIdentifier) {
94141
String[] parsedIdentifier = statusReportIdentifier.split(":");
95142
if (parsedIdentifier.length > 0) {
@@ -99,7 +146,7 @@ private String getDeploymentKeyFromStatusReportIdentifier(String statusReportIde
99146
}
100147
}
101148

102-
private String getPackageStatusReportIdentifier(WritableMap updatePackage) {
149+
private String getPackageStatusReportIdentifier(ReadableMap updatePackage) {
103150
// Because deploymentKeys can be dynamically switched, we use a
104151
// combination of the deploymentKey and label as the packageIdentifier.
105152
String deploymentKey = CodePushUtils.tryGetString(updatePackage, DEPLOYMENT_KEY_KEY);
@@ -129,7 +176,7 @@ private boolean isStatusReportIdentifierCodePushLabel(String statusReportIdentif
129176
return statusReportIdentifier != null && statusReportIdentifier.contains(":");
130177
}
131178

132-
private void recordDeploymentStatusReported(String appVersionOrPackageIdentifier) {
179+
private void saveStatusReportedForIdentifier(String appVersionOrPackageIdentifier) {
133180
SharedPreferences settings = applicationContext.getSharedPreferences(CODE_PUSH_PREFERENCES, 0);
134181
settings.edit().putString(LAST_DEPLOYMENT_REPORT_KEY, appVersionOrPackageIdentifier).commit();
135182
}

‎ios/CodePush/CodePush.h

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -112,8 +112,11 @@ failCallback:(void (^)(NSError *err))failCallback;
112112
@interface CodePushTelemetryManager : NSObject
113113

114114
+ (NSDictionary *)getBinaryUpdateReport:(NSString *)appVersion;
115+
+ (NSDictionary *)getRetryStatusReport;
115116
+ (NSDictionary *)getRollbackReport:(NSDictionary *)lastFailedPackage;
116117
+ (NSDictionary *)getUpdateReport:(NSDictionary *)currentPackage;
118+
+ (void)recordStatusReported:(NSDictionary *)statusReport;
119+
+ (void)saveStatusReportForRetry:(NSDictionary *)statusReport;
117120

118121
@end
119122

‎ios/CodePush/CodePush.m

Lines changed: 22 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ @implementation CodePush {
1515
BOOL _isFirstRunAfterUpdate;
1616
int _minimumBackgroundDuration;
1717
NSDate *_lastResignedDate;
18-
18+
1919
// Used to coordinate the dispatching of download progress events to JS.
2020
long long _latestExpectedContentLength;
2121
long long _latestReceivedConentLength;
@@ -507,14 +507,14 @@ - (void)applicationWillResignActive
507507
[mutableUpdatePackage setValue:[CodePushUpdateUtils modifiedDateStringOfFileAtURL:binaryBundleURL]
508508
forKey:BinaryBundleDateKey];
509509
}
510-
510+
511511
if (notifyProgress) {
512512
// Set up and unpause the frame observer so that it can emit
513513
// progress events every frame if the progress is updated.
514514
_didUpdateProgress = NO;
515515
_paused = NO;
516516
}
517-
517+
518518
[CodePushPackage
519519
downloadPackage:mutableUpdatePackage
520520
expectedBundleFileName:[bundleResourceName stringByAppendingPathExtension:bundleResourceExtension]
@@ -525,7 +525,7 @@ - (void)applicationWillResignActive
525525
_latestExpectedContentLength = expectedContentLength;
526526
_latestReceivedConentLength = receivedContentLength;
527527
_didUpdateProgress = YES;
528-
528+
529529
// If the download is completed, stop observing frame
530530
// updates and synchronously send the last event.
531531
if (expectedContentLength == receivedContentLength) {
@@ -549,7 +549,7 @@ - (void)applicationWillResignActive
549549
if ([CodePushErrorUtils isCodePushError:err]) {
550550
[self saveFailedUpdate:mutableUpdatePackage];
551551
}
552-
552+
553553
// Stop observing frame updates if the download fails.
554554
_didUpdateProgress = NO;
555555
_paused = YES;
@@ -783,19 +783,35 @@ - (void)applicationWillResignActive
783783
NSString *appVersion = [[CodePushConfig current] appVersion];
784784
resolve([CodePushTelemetryManager getBinaryUpdateReport:appVersion]);
785785
return;
786+
} else {
787+
NSDictionary *retryStatusReport = [CodePushTelemetryManager getRetryStatusReport];
788+
if (retryStatusReport) {
789+
resolve(retryStatusReport);
790+
return;
791+
}
786792
}
787793

788794
resolve(nil);
789795
}
790796

797+
RCT_EXPORT_METHOD(recordStatusReported:(NSDictionary *)statusReport)
798+
{
799+
[CodePushTelemetryManager recordStatusReported:statusReport];
800+
}
801+
802+
RCT_EXPORT_METHOD(saveStatusReportForRetry:(NSDictionary *)statusReport)
803+
{
804+
[CodePushTelemetryManager saveStatusReportForRetry:statusReport];
805+
}
806+
791807
#pragma mark - RCTFrameUpdateObserver Methods
792808

793809
- (void)didUpdateFrame:(RCTFrameUpdate *)update
794810
{
795811
if (!_didUpdateProgress) {
796812
return;
797813
}
798-
814+
799815
[self dispatchDownloadProgressEvent];
800816
_didUpdateProgress = NO;
801817
}

‎ios/CodePush/CodePushDownloadHandler.m

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ - (id)init:(NSString *)downloadFilePath
2020
return self;
2121
}
2222

23-
-(void)download:(NSString*)url {
23+
- (void)download:(NSString*)url {
2424
NSURLRequest *request = [NSURLRequest requestWithURL:[NSURL URLWithString:url]
2525
cachePolicy:NSURLRequestUseProtocolCachePolicy
2626
timeoutInterval:60.0];
@@ -47,12 +47,12 @@ - (NSCachedURLResponse *)connection:(NSURLConnection *)connection
4747
return nil;
4848
}
4949

50-
-(void)connection:(NSURLConnection *)connection didReceiveResponse:(NSURLResponse *)response {
50+
- (void)connection:(NSURLConnection *)connection didReceiveResponse:(NSURLResponse *)response {
5151
self.expectedContentLength = response.expectedContentLength;
5252
[self.outputFileStream open];
5353
}
5454

55-
-(void)connection:(NSURLConnection *)connection didReceiveData:(NSData *)data {
55+
- (void)connection:(NSURLConnection *)connection didReceiveData:(NSData *)data {
5656
if (self.receivedContentLength < 4) {
5757
for (int i = 0; i < [data length]; i++) {
5858
int headerOffset = (int)self.receivedContentLength + i;
@@ -97,7 +97,7 @@ - (void)connection:(NSURLConnection*)connection didFailWithError:(NSError*)error
9797
self.failCallback(error);
9898
}
9999

100-
-(void)connectionDidFinishLoading:(NSURLConnection *)connection {
100+
- (void)connectionDidFinishLoading:(NSURLConnection *)connection {
101101
// expectedContentLength might be -1 when NSURLConnection don't know the length(e.g. response encode with gzip)
102102
if (self.expectedContentLength > 0) {
103103
// We should have received all of the bytes if this is called.

0 commit comments

Comments
 (0)