Ring Daemon 16.0.0
Loading...
Searching...
No Matches
auth_channel_handler.cpp
Go to the documentation of this file.
1/*
2 * Copyright (C) 2004-2025 Savoir-faire Linux Inc.
3 *
4 * This program is free software: you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation, either version 3 of the License, or
7 * (at your option) any later version.
8 *
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
13 *
14 * You should have received a copy of the GNU General Public License
15 * along with this program. If not, see <https://www.gnu.org/licenses/>.
16 */
19
20#include <opendht/thread_pool.h>
21
22namespace jami {
23
24AuthChannelHandler::AuthChannelHandler(const std::shared_ptr<JamiAccount>& acc,
25 dhtnet::ConnectionManager& cm)
27 , account_(acc)
28 , connectionManager_(cm)
29{}
30
32
33// deprecated
34void
36 const std::string& name,
37 ConnectCb&& cb,
38 const std::string& connectionType,
40{
41 JAMI_DEBUG("[AuthChannel {}] connecting to name = {}", deviceId.toString(), name);
42 connectionManager_.connectDevice(deviceId, name, std::move(cb));
43}
44
45void
47 const std::string& channelPath,
49{
50 JAMI_DEBUG("[AuthChannel {}] connecting to channelPath = {}", infoHash.toString(), channelPath);
51 connectionManager_.connectDevice(infoHash, channelPath, std::move(cb));
52}
53
54bool
55AuthChannelHandler::onRequest(const std::shared_ptr<dht::crypto::Certificate>& cert,
56 const std::string& name)
57{
58 JAMI_DEBUG("[AuthChannel] New auth channel requested for `{}`.", cert->getId().toString());
59 auto acc = account_.lock();
60 if (!cert || !cert->issuer || !acc)
61 return false;
62
63 JAMI_DEBUG("[AuthChannel] New auth channel requested with name = `{}`.", name);
64
65 if (auto acc = account_.lock())
66 return true;
67
68 return false;
69}
70
71void
72AuthChannelHandler::onReady(const std::shared_ptr<dht::crypto::Certificate>& cert,
73 const std::string& deviceId,
74 std::shared_ptr<dhtnet::ChannelSocket> channel)
75{
76 JAMI_DEBUG("[AuthChannel] Auth channel with {}/{} ready.", cert->getId().toString(), deviceId);
77}
78
79} // namespace jami
AuthChannelHandler(const std::shared_ptr< JamiAccount > &acc, dhtnet::ConnectionManager &cm)
void connect(const DeviceId &deviceId, const std::string &name, ConnectCb &&cb, const std::string &connectionType="", bool forceNewConnection=false) override
Ask for a new sync channel.
bool onRequest(const std::shared_ptr< dht::crypto::Certificate > &peer, const std::string &name) override
Determine if we accept or not the sync request.
void onReady(const std::shared_ptr< dht::crypto::Certificate > &peer, const std::string &name, std::shared_ptr< dhtnet::ChannelSocket > channel) override
Launch sync process.
A Channel handler is used to make the link between JamiAccount and ConnectionManager Its role is to m...
#define JAMI_DEBUG(formatstr,...)
Definition logger.h:226
std::function< void(std::shared_ptr< dhtnet::ChannelSocket >, const DeviceId &)> ConnectCb
dht::PkId DeviceId
void emitSignal(Args... args)
Definition ring_signal.h:64
std::function< void(std::shared_ptr< dhtnet::ChannelSocket >, const dht::InfoHash &)> ConnectCallbackLegacy