Disable api calls

src/script/acquisition-sdk.ts

@@ -58,6 +58,7 @@ export class AcquisitionStatus {
 }
 
 export class AcquisitionManager {
+    private readonly BASER_URL_PART = "appcenter.ms";
     private _appVersion: string;
     private _clientUniqueId: string;
     private _deploymentKey: string;
@@ -66,6 +67,7 @@ export class AcquisitionManager {
     private _serverUrl: string;
     private _publicPrefixUrl: string = "v0.1/public/codepush/";
 
+    private static _apiCallsDisabled: boolean = false;
     constructor(httpRequester: Http.Requester, configuration: Configuration) {
         this._httpRequester = httpRequester;
 
@@ -80,7 +82,24 @@ export class AcquisitionManager {
         this._ignoreAppVersion = configuration.ignoreAppVersion;
     }
 
+    // Used for Tests
+    public static get apiCallsDisabled(): boolean {
+        return this._apiCallsDisabled;
+    }
+
+    private handleRequestFailure(statusCode: number) {
+        if (this._serverUrl.includes(this.BASER_URL_PART) && !(statusCode >= 500 || statusCode == 408 || statusCode == 429)) {
+            AcquisitionManager._apiCallsDisabled = true;
+        }
+    }
+
     public queryUpdateWithCurrentPackage(currentPackage: Package, callback?: Callback<RemotePackage | NativeUpdateNotification>): void {
+        if (AcquisitionManager._apiCallsDisabled) {
+            console.log(`[CodePush] Api calls are disabled, skipping API call`);
+            callback(/*error=*/ null, /*remotePackage=*/ null);
+            return;
+        }
+
         if (!currentPackage || !currentPackage.appVersion) {
             throw new CodePushPackageError("Calling common acquisition SDK with incorrect package");  // Unexpected; indicates error in our implementation
         }
@@ -104,6 +123,7 @@ export class AcquisitionManager {
 
             if (response.statusCode !== 200) {
                 let errorMessage: any;
+                this.handleRequestFailure(response.statusCode)
                 if (response.statusCode === 0) {
                     errorMessage = `Couldn't send request to ${requestUrl}, xhr.statusCode = 0 was returned. One of the possible reasons for that might be connection problems. Please, check your internet connection.`;
                 } else {
@@ -147,6 +167,12 @@ export class AcquisitionManager {
     }
 
     public reportStatusDeploy(deployedPackage?: Package, status?: string, previousLabelOrAppVersion?: string, previousDeploymentKey?: string, callback?: Callback<void>): void {
+        if (AcquisitionManager._apiCallsDisabled) {
+            console.log(`[CodePush] Api calls are disabled, skipping API call`);
+            callback(null, null)
+            return;
+        }
+
         var url: string = this._serverUrl + this._publicPrefixUrl + "report_status/deploy";
         var body: DeploymentStatusReport = {
             app_version: this._appVersion,
@@ -197,6 +223,7 @@ export class AcquisitionManager {
                 }
 
                 if (response.statusCode !== 200) {
+                    this.handleRequestFailure(response.statusCode)
                     callback(new CodePushHttpError(response.statusCode + ": " + response.body), /*not used*/ null);
                     return;
                 }
@@ -207,6 +234,12 @@ export class AcquisitionManager {
     }
 
     public reportStatusDownload(downloadedPackage: Package, callback?: Callback<void>): void {
+        if (AcquisitionManager._apiCallsDisabled) {
+            console.log(`[CodePush] Api calls are disabled, skipping API call`);
+            callback(null, null)
+            return;
+        }
+
         var url: string = this._serverUrl + this._publicPrefixUrl + "report_status/download";
         var body: DownloadReport = {
             client_unique_id: this._clientUniqueId,
@@ -222,6 +255,7 @@ export class AcquisitionManager {
                 }
 
                 if (response.statusCode !== 200) {
+                    this.handleRequestFailure(response.statusCode)
                     callback(new CodePushHttpError(response.statusCode + ": " + response.body), /*not used*/ null);
                     return;
                 }

src/test/acquisition-sdk.ts

@@ -226,6 +226,53 @@ describe("Acquisition SDK", () => {
             done();
         }));
     });
+
+    it("doesnt disable api calls on successful response", (done: Mocha.Done): void => {
+        var acquisition = new acquisitionSdk.AcquisitionManager(new mockApi.HttpRequester(), configuration);
+
+        acquisition.queryUpdateWithCurrentPackage(templateCurrentPackage, (error: Error, returnPackage: acquisitionSdk.RemotePackage | acquisitionSdk.NativeUpdateNotification) => {
+            assert.strictEqual(acquisitionSdk.AcquisitionManager.apiCallsDisabled, false);
+        });
+
+        acquisition.queryUpdateWithCurrentPackage(templateCurrentPackage, (error: Error, returnPackage: acquisitionSdk.RemotePackage | acquisitionSdk.NativeUpdateNotification) => {
+            assert.notStrictEqual(returnPackage, null)
+        });
+
+        acquisition.reportStatusDeploy(templateCurrentPackage, acquisitionSdk.AcquisitionStatus.DeploymentSucceeded, "1.5.0", mockApi.validDeploymentKey, ((error: Error, parameter: void): void => {
+            assert.strictEqual(acquisitionSdk.AcquisitionManager.apiCallsDisabled, false);
+        }))
+
+        acquisition.reportStatusDownload(templateCurrentPackage, ((error: Error, parameter: void): void => {
+            assert.strictEqual(acquisitionSdk.AcquisitionManager.apiCallsDisabled, false);
+        }));
+        done();
+    })
+
+    it("disables api calls on unsuccessful response", (done: Mocha.Done): void => {
+        var invalidJsonResponse: acquisitionSdk.Http.Response = {
+            statusCode: 404,
+            body: "Not found"
+        };
+        configuration = { ...configuration, serverUrl: "https://codepush.appcenter.ms" }
+        var acquisition = new acquisitionSdk.AcquisitionManager(new mockApi.CustomResponseHttpRequester(invalidJsonResponse), configuration);
+
+        acquisition.queryUpdateWithCurrentPackage(templateCurrentPackage, (error: Error, returnPackage: acquisitionSdk.RemotePackage | acquisitionSdk.NativeUpdateNotification) => {
+            assert.strictEqual(acquisitionSdk.AcquisitionManager.apiCallsDisabled, true);
+        });
+
+        acquisition.reportStatusDeploy(templateCurrentPackage, acquisitionSdk.AcquisitionStatus.DeploymentSucceeded, "1.5.0", mockApi.validDeploymentKey, ((error: Error, parameter: void): void => {
+            assert.strictEqual(acquisitionSdk.AcquisitionManager.apiCallsDisabled, true);
+        }))
+        acquisition.reportStatusDownload(templateCurrentPackage, ((error: Error, parameter: void): void => {
+            assert.strictEqual(acquisitionSdk.AcquisitionManager.apiCallsDisabled, true);
+        }));
+
+        acquisition.queryUpdateWithCurrentPackage(templateCurrentPackage, (error: Error, returnPackage: acquisitionSdk.RemotePackage | acquisitionSdk.NativeUpdateNotification) => {
+            assert.strictEqual(returnPackage, null);
+        })
+        done();
+    })
+
 });
 
 function clone<T>(initialObject: T): T {