blob: d33c59bcff95ae33a4d09e77252b70b952bad70c [file] [log] [blame]
// Copyright 2018 The Fuchsia 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 <string>
#include <flatbuffers/flatbuffers.h>
#include <lib/fit/function.h>
#include <lib/fxl/strings/string_view.h>
#include <lib/netconnector/cpp/message_relay.h>
#include <lib/zx/channel.h>
namespace p2p_provider {
// RemoteConnection holds a connection with a single remote device.
class RemoteConnection {
explicit RemoteConnection(std::string local_name);
// Starts listening on the provided channel for new messages.
// |channel| is presumed to be sending/receiving messages from/to another
// device.
void Start(zx::channel channel);
// Sends |data| to another device through the channel set in |Start|.
void SendMessage(fxl::StringView data);
// Disconnects.
void Disconnect();
// |on_empty| will be called when this connection is no longer valid, either
// because we disconnected or because the other side disconnected.
void set_on_empty(fit::closure on_empty);
// |on_close| will be called when the other side closes the connection.
void set_on_close(fit::closure on_close);
// |on_message| will be called for every new message received.
void set_on_message(fit::function<void(std::vector<uint8_t>)> on_message);
void OnChannelClosed();
void OnNewMessage(std::vector<uint8_t> data);
bool started_ = false;
const std::string local_name_;
netconnector::MessageRelay message_relay_;
fit::closure on_empty_;
fit::closure on_close_;
fit::function<void(std::vector<uint8_t>)> on_message_;
} // namespace p2p_provider