// 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 "services/ui/ime/ime_server_impl.h"

#include "services/catalog/public/interfaces/constants.mojom.h"
#include "services/service_manager/public/cpp/connector.h"
#include "services/ui/ime/ime_registrar_impl.h"

namespace ui {

IMEServerImpl::IMEServerImpl() : current_id_(0) {}

IMEServerImpl::~IMEServerImpl() {}

void IMEServerImpl::Init(service_manager::Connector* connector,
                         bool is_test_config) {
  connector_ = connector;
  connector_->ConnectToInterface(catalog::mojom::kServiceName, &catalog_);
  // TODO(moshayedi): crbug.com/664264. The catalog service should provide
  // different set of entries for test and non-test. Once that is implemented,
  // we won't need this check here.
  if (is_test_config) {
    connector_->Connect("test_ime_driver");
  } else {
    catalog_->GetEntriesProvidingCapability(
        "ime:ime_driver", base::Bind(&IMEServerImpl::OnGotCatalogEntries,
                                     base::Unretained(this)));
  }
}

void IMEServerImpl::AddBinding(mojom::IMEServerRequest request) {
  bindings_.AddBinding(this, std::move(request));
}

void IMEServerImpl::OnDriverChanged(mojom::IMEDriverPtr driver) {
  // TODO(moshayedi): crbug.com/664267. Make sure this is the driver we
  // requested at OnGotCatalogEntries().
  driver_ = std::move(driver);

  while (!pending_requests_.empty()) {
    driver_->StartSession(current_id_++,
                          std::move(pending_requests_.front().first),
                          std::move(pending_requests_.front().second));
    pending_requests_.pop();
  }
}

void IMEServerImpl::StartSession(
    mojom::TextInputClientPtr client,
    mojom::InputMethodRequest input_method_request) {
  if (driver_.get()) {
    // TODO(moshayedi): crbug.com/634431. This will forward all calls from
    // clients to the driver as they are. We may need to check |caret_bounds|
    // parameter of InputMethod::OnCaretBoundsChanged() here and limit them to
    // client's focused window.
    driver_->StartSession(current_id_++, std::move(client),
                          std::move(input_method_request));
  } else {
    pending_requests_.push(
        std::make_pair(std::move(client), std::move(input_method_request)));
  }
}

void IMEServerImpl::OnGotCatalogEntries(
    std::vector<catalog::mojom::EntryPtr> entries) {
  // TODO(moshayedi): crbug.com/662157. Decide what to do when number of
  // available IME drivers isn't exactly one.
  if (entries.size() == 0)
    return;
  connector_->Connect((*entries.begin())->name);
}

}  // namespace ui