diagnostics/diagnosticsd/diagnosticsd_mojo_service.cc

// Copyright 2018 The Chromium OS 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 "diagnostics/diagnosticsd/diagnosticsd_mojo_service.h"

#include <string>
#include <utility>

#include <base/json/json_reader.h>
#include <base/logging.h>
#include <base/values.h>
#include <mojo/public/c/system/types.h>

namespace diagnostics {

DiagnosticsdMojoService::DiagnosticsdMojoService(
    Delegate* delegate,
    MojomDiagnosticsdServiceRequest self_interface_request,
    MojomDiagnosticsdClientPtr client_ptr)
    : delegate_(delegate),
      self_binding_(this /* impl */, std::move(self_interface_request)),
      client_ptr_(std::move(client_ptr)) {
  DCHECK(delegate_);
  DCHECK(self_binding_.is_bound());
  DCHECK(client_ptr_);
}

DiagnosticsdMojoService::~DiagnosticsdMojoService() = default;

void DiagnosticsdMojoService::SendUiMessageToDiagnosticsProcessor(
    mojo::ScopedSharedBufferHandle json_message,
    const SendUiMessageToDiagnosticsProcessorCallback& callback) {
  NOTIMPLEMENTED();
}

void DiagnosticsdMojoService::SendUiMessageToDiagnosticsProcessorWithSize(
    mojo::ScopedSharedBufferHandle json_message,
    int64_t json_message_size,
    const SendUiMessageToDiagnosticsProcessorWithSizeCallback& callback) {
  mojo::ScopedSharedBufferMapping json_message_data =
      json_message->Map(json_message_size);
  if (!json_message_data) {
    LOG(ERROR) << "Mojo Map failed.";
    callback.Run();
    return;
  }

  int json_error_code = base::JSONReader::JSON_NO_ERROR;
  int json_error_line, json_error_column;
  std::string json_error_message;
  base::JSONReader::ReadAndReturnError(
      base::StringPiece(static_cast<const char*>(json_message_data.get()),
                        json_message_size),
      base::JSONParserOptions::JSON_ALLOW_TRAILING_COMMAS, &json_error_code,
      &json_error_message, &json_error_line, &json_error_column);
  if (json_error_code == base::JSONReader::JSON_NO_ERROR) {
    base::StringPiece json_message(
        static_cast<const char*>(json_message_data.get()), json_message_size);
    delegate_->SendGrpcUiMessageToDiagnosticsProcessor(json_message);
  } else {
    LOG(ERROR) << "Invalid JSON at line " << json_error_line << " and column "
               << json_error_column
               << ". JSON parsing message: " << json_error_message
               << ". Error code: " << json_error_code;
  }

  callback.Run();
}

}  // namespace diagnostics