blob: 706fd58ff6d09beaa2a8bb9b22dfb45034185a84 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
// Copyright 2019 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 "cast/standalone_receiver/cast_socket_message_port.h"
#include <utility>
namespace openscreen {
namespace cast {
CastSocketMessagePort::CastSocketMessagePort() = default;
CastSocketMessagePort::~CastSocketMessagePort() = default;
// NOTE: we assume here that this message port is already the client for
// the passed in socket, so leave the socket's client unchanged. However,
// since sockets should map one to one with receiver sessions, we reset our
// client. The consumer of this message port should call SetClient with the new
// message port client after setting the socket.
void CastSocketMessagePort::SetSocket(std::unique_ptr<CastSocket> socket) {
client_ = nullptr;
socket_ = std::move(socket);
}
void CastSocketMessagePort::SetClient(MessagePort::Client* client) {
client_ = client;
}
void CastSocketMessagePort::OnError(CastSocket* socket, Error error) {
if (client_) {
client_->OnError(error);
}
}
void CastSocketMessagePort::OnMessage(CastSocket* socket,
::cast::channel::CastMessage message) {
if (client_) {
client_->OnMessage(message.source_id(), message.namespace_(),
message.payload_utf8());
}
}
void CastSocketMessagePort::PostMessage(absl::string_view sender_id,
absl::string_view message_namespace,
absl::string_view message) {
::cast::channel::CastMessage cast_message;
cast_message.set_source_id(sender_id.data(), sender_id.size());
cast_message.set_namespace_(message_namespace.data(),
message_namespace.size());
cast_message.set_payload_utf8(message.data(), message.size());
Error error = socket_->SendMessage(cast_message);
if (!error.ok()) {
client_->OnError(error);
}
}
} // namespace cast
} // namespace openscreen
|
