Fire the `backgroundfetchabort` event for aborted fetches

content/browser/background_fetch/background_fetch_service_unittest.cc

 // Copyright 2017 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.
 
 #include <map>
 #include <memory>
 #include <utility>
 
 #include "base/macros.h"
 #include "base/memory/ptr_util.h"
@@ skipping 459 matching lines @@
   ASSERT_TRUE(CreateRegistrationId(kExampleTag, &registration_id));
 
   // Deliberate do *not* create a fetch for the |registration_id|.
 
   blink::mojom::BackgroundFetchError error;
 
   ASSERT_NO_FATAL_FAILURE(Abort(registration_id, &error));
   ASSERT_EQ(error, blink::mojom::BackgroundFetchError::INVALID_TAG);
 }
 
+TEST_F(BackgroundFetchServiceTest, AbortEventDispatch) {
+  // Tests that the `backgroundfetchabort` event will be fired when a Background
+  // Fetch registration has been aborted by either the user or developer.
+
+  BackgroundFetchRegistrationId registration_id;
+  ASSERT_TRUE(CreateRegistrationId(kExampleTag, &registration_id));
+
+  // base::RunLoop that we'll run until the event has been dispatched. If this
+  // test times out, it means that the event could not be dispatched.
+  base::RunLoop event_dispatched_loop;
+  embedded_worker_test_helper()->set_abort_event_closure(
+      event_dispatched_loop.QuitClosure());
+
+  constexpr int kResponseCode = 200;
+
+  std::vector<ServiceWorkerFetchRequest> requests;
+  requests.push_back(CreateRequestWithProvidedResponse(
+      "GET", "https://example.com/funny_cat.txt",
+      TestResponseBuilder(kResponseCode)
+          .SetResponseData("Random data about a funny cat.")
+          .Build()));
+
+  // Create the registration with the given |requests|.
+  {
+    BackgroundFetchOptions options;
+
+    blink::mojom::BackgroundFetchError error;
+    BackgroundFetchRegistration registration;
+
+    // Create the first registration. This must succeed.
+    ASSERT_NO_FATAL_FAILURE(
+        Fetch(registration_id, requests, options, &error, &registration));
+    ASSERT_EQ(error, blink::mojom::BackgroundFetchError::NONE);
+  }
+
+  // Immediately abort the request created for the |registration_id|. Then wait
+  // for the `backgroundfetchabort` event to have been invoked.
+  {
+    blink::mojom::BackgroundFetchError error;
+
+    ASSERT_NO_FATAL_FAILURE(Abort(registration_id, &error));
+    ASSERT_EQ(error, blink::mojom::BackgroundFetchError::NONE);
+  }
+
+  event_dispatched_loop.Run();
+
+  ASSERT_TRUE(embedded_worker_test_helper()->last_tag().has_value());
+  EXPECT_EQ(kExampleTag, embedded_worker_test_helper()->last_tag().value());
+}
+
 TEST_F(BackgroundFetchServiceTest, GetTags) {
   // This test verifies that the list of active tags can be retrieved from the
   // service for a given Service Worker, as extracted from a registration.
 
   BackgroundFetchRegistrationId registration_id;
   ASSERT_TRUE(CreateRegistrationId(kExampleTag, &registration_id));
 
   BackgroundFetchRegistrationId second_registration_id;
   ASSERT_TRUE(CreateRegistrationId(kAlternativeTag, &second_registration_id));
 
@@ skipping 61 matching lines @@
     const bool has_alternative_tag =
         tags[0] == kAlternativeTag || tags[1] == kAlternativeTag;
 
     EXPECT_TRUE(has_example_tag);
     EXPECT_TRUE(has_alternative_tag);
   }
 }
 
 }  // namespace
 }  // namespace content