Make JSONParser a pure interface.

components/safe_json/safe_json_parser.cc

 // Copyright 2013 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/safe_json/safe_json_parser.h"
 
 #include <string>
 
-#include "base/single_thread_task_runner.h"
+#include "base/sequenced_task_runner.h"
 #include "base/strings/utf_string_conversions.h"
 #include "base/thread_task_runner_handle.h"
 #include "base/tuple.h"
 #include "base/values.h"
 #include "components/safe_json/safe_json_parser_messages.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/utility_process_host.h"
+#include "content/public/browser/utility_process_host_client.h"
 #include "grit/components_strings.h"
 #include "ipc/ipc_message_macros.h"
 #include "ui/base/l10n/l10n_util.h"
 
 using content::BrowserThread;
 using content::UtilityProcessHost;
 
 namespace safe_json {
 
-SafeJsonParser::SafeJsonParser(const std::string& unsafe_json,
-                               const SuccessCallback& success_callback,
-                               const ErrorCallback& error_callback)
+namespace {
+
+SafeJsonParser::Factory g_factory = nullptr;
+
+class SafeJsonParserImpl : public content::UtilityProcessHostClient,
+                           public SafeJsonParser {
+ public:
+  SafeJsonParserImpl(const std::string& unsafe_json,
+                     const SuccessCallback& success_callback,
+                     const ErrorCallback& error_callback);
+
+  void Start() override;
+
+ private:
+  ~SafeJsonParserImpl() override;
+
+  void StartWorkOnIOThread();
+
+  void OnJSONParseSucceeded(const base::ListValue& wrapper);
+  void OnJSONParseFailed(const std::string& error_message);
+
+  void ReportResults();
+  void ReportResultsOnOriginThread();
+
+  // Implementing pieces of the UtilityProcessHostClient interface.
+  bool OnMessageReceived(const IPC::Message& message) override;
+
+  const std::string unsafe_json_;
+  SuccessCallback success_callback_;
+  ErrorCallback error_callback_;
+  scoped_refptr<base::SequencedTaskRunner> caller_task_runner_;
+
+  scoped_ptr<base::Value> parsed_json_;
+  std::string error_;
+
+  DISALLOW_COPY_AND_ASSIGN(SafeJsonParserImpl);
+};
+
+SafeJsonParserImpl::SafeJsonParserImpl(const std::string& unsafe_json,
+                                       const SuccessCallback& success_callback,
+                                       const ErrorCallback& error_callback)
     : unsafe_json_(unsafe_json),
       success_callback_(success_callback),
-      error_callback_(error_callback) {
-}
+      error_callback_(error_callback) {}
 
-void SafeJsonParser::Start() {
+void SafeJsonParserImpl::Start() {
+  // Current callers of this class are known to either come from
+  // the UI or IO threads. This DCHECK can be removed/further enhanced
+  // in case this class is useable outside of these contexts.
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI) ||
+         BrowserThread::CurrentlyOn(BrowserThread::IO));
+
   caller_task_runner_ = base::ThreadTaskRunnerHandle::Get();
 
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
-      base::Bind(&SafeJsonParser::StartWorkOnIOThread, this));
+      base::Bind(&SafeJsonParserImpl::StartWorkOnIOThread, this));
 }
 
-SafeJsonParser::~SafeJsonParser() {
+SafeJsonParserImpl::~SafeJsonParserImpl() {
 }
 
-void SafeJsonParser::StartWorkOnIOThread() {
+void SafeJsonParserImpl::StartWorkOnIOThread() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   UtilityProcessHost* host = UtilityProcessHost::Create(
       this, base::ThreadTaskRunnerHandle::Get().get());
   host->SetName(
       l10n_util::GetStringUTF16(IDS_UTILITY_PROCESS_JSON_PARSER_NAME));
   host->Send(new SafeJsonParserMsg_ParseJSON(unsafe_json_));
 }
 
-void SafeJsonParser::OnJSONParseSucceeded(const base::ListValue& wrapper) {
+void SafeJsonParserImpl::OnJSONParseSucceeded(const base::ListValue& wrapper) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   const base::Value* value = NULL;
   CHECK(wrapper.Get(0, &value));
 
   parsed_json_.reset(value->DeepCopy());
   ReportResults();
 }
 
-void SafeJsonParser::OnJSONParseFailed(const std::string& error_message) {
+void SafeJsonParserImpl::OnJSONParseFailed(const std::string& error_message) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   error_ = error_message;
   ReportResults();
 }
 
-void SafeJsonParser::ReportResults() {
+void SafeJsonParserImpl::ReportResults() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 
   caller_task_runner_->PostTask(
       FROM_HERE,
-      base::Bind(&SafeJsonParser::ReportResultsOnOriginThread, this));
+      base::Bind(&SafeJsonParserImpl::ReportResultsOnOriginThread, this));
 }
 
-void SafeJsonParser::ReportResultsOnOriginThread() {
-  // Current callers of this class are known to either come from
-  // the UI or IO threads. This DCHECK can be removed/further enhanced
-  // in case this class is useable outside of these contexts.
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI) ||
-         BrowserThread::CurrentlyOn(BrowserThread::IO));
+void SafeJsonParserImpl::ReportResultsOnOriginThread() {
+  DCHECK(caller_task_runner_->RunsTasksOnCurrentThread());
   if (error_.empty() && parsed_json_) {
     if (!success_callback_.is_null())
       success_callback_.Run(parsed_json_.Pass());
   } else {
     if (!error_callback_.is_null())
       error_callback_.Run(error_);
   }
 }
 
-bool SafeJsonParser::OnMessageReceived(const IPC::Message& message) {
+bool SafeJsonParserImpl::OnMessageReceived(const IPC::Message& message) {
   bool handled = true;
-  IPC_BEGIN_MESSAGE_MAP(SafeJsonParser, message)
+  IPC_BEGIN_MESSAGE_MAP(SafeJsonParserImpl, message)
     IPC_MESSAGE_HANDLER(SafeJsonParserHostMsg_ParseJSON_Succeeded,
                         OnJSONParseSucceeded)
     IPC_MESSAGE_HANDLER(SafeJsonParserHostMsg_ParseJSON_Failed,
                         OnJSONParseFailed)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
+}  // namespace
+
+// static
+void SafeJsonParser::SetFactoryForTesting(Factory factory) {
+  g_factory = factory;
+}
+
+// static
+SafeJsonParser* SafeJsonParser::Create(
+    const std::string& unsafe_json,
+    const SuccessCallback& success_callback,
+    const ErrorCallback& error_callback) {
+  if (g_factory)
+    return g_factory(unsafe_json, success_callback, error_callback);
+
+  return new SafeJsonParserImpl(unsafe_json, success_callback, error_callback);
+}
+
 }  // namespace safe_json