iioservice/iioservice_simpleclient/sensor_client.h

// Copyright 2021 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.

#ifndef IIOSERVICE_IIOSERVICE_SIMPLECLIENT_SENSOR_CLIENT_H_
#define IIOSERVICE_IIOSERVICE_SIMPLECLIENT_SENSOR_CLIENT_H_

#include <memory>

#include <base/callback.h>
#include <base/memory/weak_ptr.h>
#include <base/sequenced_task_runner.h>
#include <mojo/public/cpp/bindings/receiver.h>
#include <mojo/public/cpp/bindings/remote.h>

#include "iioservice/mojo/cros_sensor_service.mojom.h"
#include "iioservice/mojo/sensor.mojom.h"

namespace iioservice {

class SensorClient : public cros::mojom::SensorHalClient {
 public:
  using QuitCallback = base::OnceCallback<void()>;

  static void SensorClientDeleter(SensorClient* observer);

  void BindClient(mojo::PendingReceiver<cros::mojom::SensorHalClient> client);

  // cros::mojom::SensorHalClient overrides:
  void SetUpChannel(
      mojo::PendingRemote<cros::mojom::SensorService> pending_remote) override;

 protected:
  SensorClient(scoped_refptr<base::SequencedTaskRunner> ipc_task_runner,
               QuitCallback quit_callback);

  void SetUpChannelTimeout();

  virtual void Start() = 0;
  virtual void Reset();

  void OnClientDisconnect();
  void OnServiceDisconnect();

  scoped_refptr<base::SequencedTaskRunner> ipc_task_runner_;
  QuitCallback quit_callback_;

  mojo::Receiver<cros::mojom::SensorHalClient> client_{this};
  mojo::Remote<cros::mojom::SensorService> sensor_service_remote_;

  base::WeakPtrFactory<SensorClient> weak_factory_{this};
};

}  // namespace iioservice

#endif  // IIOSERVICE_IIOSERVICE_SIMPLECLIENT_SENSOR_CLIENT_H_