Report download status and duration

Author: ofalvai

package-mixins.js

@@ -1,5 +1,6 @@
 import { NativeEventEmitter } from "react-native";
 import log from "./logging";
+import { DownloadAcquisitionStatus } from "./lib/acquisition-sdk/acquisition-sdk";
 
 // Reporting this event is important, but avoid blocking install()/restartApp() indefinitely
 // on a stalled network request.
@@ -39,22 +40,33 @@ module.exports = (NativeCodePush) => {
           );
         }
 
+        const downloadStartTime = Date.now();
+        const reportDownloadStatus = async (status) => {
+          if (!reportStatusDownload) return;
+          const downloadDurationMs = Date.now() - downloadStartTime;
+          try {
+            await withTimeout(reportStatusDownload({ ...this, downloadDurationMs, status }), REPORT_STATUS_DOWNLOAD_TIMEOUT_MS);
+          } catch (err) {
+            log(`Report download status failed: ${err}`);
+          }
+        };
+
         // Use the downloaded package info. Native code will save the package info
         // so that the client knows what the current package version is.
         try {
           const updatePackageCopy = Object.assign({}, this);
           Object.keys(updatePackageCopy).forEach((key) => (typeof updatePackageCopy[key] === 'function') && delete updatePackageCopy[key]);
 
-          const downloadedPackage = await NativeCodePush.downloadUpdate(updatePackageCopy, !!downloadProgressCallback);
-
-          if (reportStatusDownload) {
-            try {
-              await withTimeout(reportStatusDownload(this), REPORT_STATUS_DOWNLOAD_TIMEOUT_MS);
-            } catch (err) {
-              log(`Report download status failed: ${err}`);
-            }
+          let downloadedPackage;
+          try {
+            downloadedPackage = await NativeCodePush.downloadUpdate(updatePackageCopy, !!downloadProgressCallback);
+          } catch (err) {
+            await reportDownloadStatus(DownloadAcquisitionStatus.Failed);
+            throw err;
           }
 
+          await reportDownloadStatus(DownloadAcquisitionStatus.Succeeded);
+
           return { ...downloadedPackage, ...local };
         } finally {
           downloadProgressSubscription && downloadProgressSubscription.remove();

src/acquisition-sdk/__tests__/acquisition-sdk.test.ts

@@ -222,7 +222,7 @@ describe("Acquisition SDK", () => {
     it("reportStatusDownload(...) signals completion", (done: Mocha.Done): void => {
         var acquisition = new acquisitionSdk.AcquisitionManager(new mockApi.HttpRequester(), configuration);
 
-        acquisition.reportStatusDownload(templateCurrentPackage, ((error: Error, parameter: void): void => {
+        acquisition.reportStatusDownload({ ...templateCurrentPackage, status: acquisitionSdk.DownloadAcquisitionStatus.Succeeded }, ((error: Error, parameter: void): void => {
             if (error) {
                 throw error;
             }
@@ -261,7 +261,7 @@ describe("Acquisition SDK", () => {
             (acquisitionSdk.AcquisitionManager as any)._apiCallsDisabled = false;
         }));
 
-        acquisition.reportStatusDownload(templateCurrentPackage, ((error: Error, parameter: void): void => {
+        acquisition.reportStatusDownload({ ...templateCurrentPackage, status: acquisitionSdk.DownloadAcquisitionStatus.Succeeded }, ((error: Error, parameter: void): void => {
             assert.strictEqual((acquisitionSdk.AcquisitionManager as any)._apiCallsDisabled, true);
             acquisition = acquisition = new acquisitionSdk.AcquisitionManager(new mockApi.CustomResponseHttpRequester(invalidJsonResponse), configuration);
             (acquisitionSdk.AcquisitionManager as any)._apiCallsDisabled = false;
@@ -287,7 +287,7 @@ describe("Acquisition SDK", () => {
             assert.strictEqual((acquisitionSdk.AcquisitionManager as any)._apiCallsDisabled, false);
         }));
 
-        acquisition.reportStatusDownload(templateCurrentPackage, ((error: Error, parameter: void): void => {
+        acquisition.reportStatusDownload({ ...templateCurrentPackage, status: acquisitionSdk.DownloadAcquisitionStatus.Succeeded }, ((error: Error, parameter: void): void => {
             assert.strictEqual((acquisitionSdk.AcquisitionManager as any)._apiCallsDisabled, false);
         }));
 

src/acquisition-sdk/acquisition-sdk.ts

@@ -1,6 +1,6 @@
 // Vendored from https://github.com/microsoft/code-push/blob/master/src/script/acquisition-sdk.ts (archived, MIT licensed)
 
-import { UpdateCheckResponse, UpdateCheckRequest, DeploymentStatusReport, DownloadReport } from "./types";
+import { UpdateCheckResponse, UpdateCheckRequest, DeploymentStatusReport, DownloadReport, DownloadStatus } from "./types";
 import { CodePushHttpError, CodePushDeployStatusError, CodePushPackageError } from "./code-push-error"
 
 export namespace Http {
@@ -35,6 +35,11 @@ export interface RemotePackage extends Package {
     downloadUrl: string;
 }
 
+export interface DownloadedPackage extends Package {
+    downloadDurationMs?: number;
+    status: DownloadStatus;
+}
+
 export interface NativeUpdateNotification {
     updateAppVersion: boolean;   // Always true
     appVersion: string;
@@ -59,6 +64,11 @@ export class AcquisitionStatus {
     public static DeploymentFailed = "DeploymentFailed";
 }
 
+export class DownloadAcquisitionStatus {
+    public static Succeeded: DownloadStatus = "DownloadSucceeded";
+    public static Failed: DownloadStatus = "DownloadFailed";
+}
+
 export class AcquisitionManager {
     private readonly BASE_URL_PART = "appcenter.ms";
     private _appVersion: string;
@@ -235,7 +245,7 @@ export class AcquisitionManager {
         });
     }
 
-    public reportStatusDownload(downloadedPackage: Package, callback?: Callback<void>): void {
+    public reportStatusDownload(downloadedPackage: DownloadedPackage, callback?: Callback<void>): void {
         if (AcquisitionManager._apiCallsDisabled) {
             console.log(`[CodePush] Api calls are disabled, skipping API call`);
             callback(/*error*/ null, /*not used*/ null);
@@ -246,7 +256,9 @@ export class AcquisitionManager {
         var body: DownloadReport = {
             client_unique_id: this._clientUniqueId,
             deployment_key: this._deploymentKey,
-            label: downloadedPackage.label
+            label: downloadedPackage.label,
+            download_duration_ms: downloadedPackage.downloadDurationMs,
+            status: downloadedPackage.status
         };
 
         this._httpRequester.request(Http.Verb.POST, url, JSON.stringify(body), (error: Error, response: Http.Response): void => {

src/acquisition-sdk/types.ts

@@ -13,11 +13,15 @@ export interface DeploymentStatusReport {
     status?: string;
 }
 
+export type DownloadStatus = "DownloadSucceeded" | "DownloadFailed";
+
 /*in*/
 export interface DownloadReport {
     client_unique_id: string;
     deployment_key: string;
     label: string;
+    download_duration_ms?: number;
+    status: DownloadStatus;
 }
 
 /*out*/