Add calls to the offliner and unit tests.

components/offline_pages/background/request_coordinator_unittest.cc

 // Copyright 2016 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 "components/offline_pages/background/request_coordinator.h"
 
 #include <memory>
 #include <utility>
 
 #include "base/bind.h"
+#include "base/location.h"
 #include "base/test/test_simple_task_runner.h"
 #include "base/threading/thread_task_runner_handle.h"
+#include "components/offline_pages/background/offliner.h"
 #include "components/offline_pages/background/offliner_factory.h"
 #include "components/offline_pages/background/offliner_policy.h"
 #include "components/offline_pages/background/request_queue.h"
 #include "components/offline_pages/background/request_queue_in_memory_store.h"
 #include "components/offline_pages/background/save_page_request.h"
 #include "components/offline_pages/background/scheduler.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace offline_pages {
 
@@ skipping 18 matching lines @@
 
   bool schedule_called() const { return schedule_called_; }
 
   bool unschedule_called() const { return unschedule_called_; }
 
  private:
   bool schedule_called_;
   bool unschedule_called_;
 };
 
+class OfflinerStub : public Offliner {
+  bool LoadAndSave(const SavePageRequest& request,
+                   const CompletionCallback& callback) override {
+    // Post the callback on the run loop.
+    base::ThreadTaskRunnerHandle::Get()->PostTask(
+        FROM_HERE, base::Bind(callback, request, Offliner::SAVED));
+    return true;
+  }
+
+  // Clears the currently processing request, if any.
+  void Cancel() override {}
+};
+
+class OfflinerFactoryStub : public OfflinerFactory {
+ public:
+  Offliner* GetOffliner(const OfflinerPolicy* policy) override {
+    offliner_.reset(new OfflinerStub());
+    return offliner_.get();
+  }
+
+ private:
+  std::unique_ptr<Offliner> offliner_;
+};
+
 class RequestCoordinatorTest
     : public testing::Test {
  public:
   RequestCoordinatorTest();
   ~RequestCoordinatorTest() override;
 
   void SetUp() override;
 
   void PumpLoop();
 
@@ skipping 27 matching lines @@
 
 RequestCoordinatorTest::RequestCoordinatorTest()
     : last_get_requests_result_(RequestQueue::GetRequestsResult::kStoreFailure),
       task_runner_(new base::TestSimpleTaskRunner),
       task_runner_handle_(task_runner_) {}
 
 RequestCoordinatorTest::~RequestCoordinatorTest() {}
 
 void RequestCoordinatorTest::SetUp() {
   std::unique_ptr<OfflinerPolicy> policy(new OfflinerPolicy());
-  std::unique_ptr<OfflinerFactory> factory;
+  std::unique_ptr<OfflinerFactory> factory(new OfflinerFactoryStub());
   std::unique_ptr<RequestQueueInMemoryStore>
       store(new RequestQueueInMemoryStore());
   std::unique_ptr<RequestQueue> queue(new RequestQueue(std::move(store)));
   std::unique_ptr<Scheduler> scheduler_stub(new SchedulerStub());
   coordinator_.reset(new RequestCoordinator(
       std::move(policy), std::move(factory), std::move(queue),
       std::move(scheduler_stub)));
 }
 
 void RequestCoordinatorTest::PumpLoop() {
@@ skipping 16 matching lines @@
 }
 
 TEST_F(RequestCoordinatorTest, SavePageLater) {
   EXPECT_TRUE(coordinator()->SavePageLater(kUrl, kClientId));
 
   // Expect that a request got placed on the queue.
   coordinator()->GetQueue()->GetRequests(
       base::Bind(&RequestCoordinatorTest::GetRequestsDone,
                  base::Unretained(this)));
 
-  // Wait for callback to finish.
+  // Wait for callbacks to finish, both request queue and offliner.
   PumpLoop();
 
-  // Check the results are as expected.
+  // Check the request queue is as expected.
   EXPECT_EQ(1UL, last_requests().size());
   EXPECT_EQ(kUrl, last_requests()[0].url());
   EXPECT_EQ(kClientId, last_requests()[0].client_id());
 
   // Expect that the scheduler got notified.
   SchedulerStub* scheduler_stub = reinterpret_cast<SchedulerStub*>(
       coordinator()->GetSchedulerForTesting());
   EXPECT_TRUE(scheduler_stub->schedule_called());
+
+  // Check that the offliner callback got a response.
+  EXPECT_EQ(Offliner::SAVED, coordinator()->last_offlining_status());
+
+  // TODO(petewil): Expect that the scheduler got notified.
 }
 
 }  // namespace offline_pages