Line data Source code
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 : */ 17 : #pragma once 18 : 19 : #include "jamidht/channel_handler.h" 20 : #include "jamidht/jamiaccount.h" 21 : #include <dhtnet/connectionmanager.h> 22 : 23 : namespace jami { 24 : 25 : /** 26 : * Manages channels for exchanging messages between peers 27 : */ 28 : class MessageChannelHandler : public ChannelHandlerInterface 29 : { 30 : public: 31 : using OnMessage = std::function<void(const std::shared_ptr<dht::crypto::Certificate>&, std::string&, const std::string&)>; 32 : using OnPeerStateChanged = std::function<void(const std::string&, bool)>; 33 : MessageChannelHandler(dhtnet::ConnectionManager& cm, OnMessage onMessage, OnPeerStateChanged onPeer); 34 : ~MessageChannelHandler(); 35 : 36 : /** 37 : * Ask for a new message channel 38 : * @param deviceId The device to connect 39 : * @param name (Unused, generated from deviceId) 40 : * @param cb The callback to call when connected (can be immediate if already connected) 41 : * @param connectionType for iOS notifications 42 : * @param forceNewConnection If we want a new SIP connection 43 : */ 44 : void connect(const DeviceId& deviceId, 45 : const std::string&, 46 : ConnectCb&& cb, 47 : const std::string& connectionType, 48 : bool forceNewConnection = false) override; 49 : 50 : std::shared_ptr<dhtnet::ChannelSocket> getChannel(const std::string& peer, 51 : const DeviceId& deviceId) const; 52 : std::vector<std::shared_ptr<dhtnet::ChannelSocket>> getChannels(const std::string& peer) const; 53 : 54 : /** 55 : * Determine if we accept or not the message request 56 : * @param deviceId Device who asked 57 : * @param name Name asked 58 : * @return if the channel is for a valid conversation and device not banned 59 : */ 60 : bool onRequest(const std::shared_ptr<dht::crypto::Certificate>& peer, 61 : const std::string& name) override; 62 : 63 : /** 64 : * Launch message process 65 : * @param deviceId Device who asked 66 : * @param name Name asked 67 : * @param channel Channel used to message 68 : */ 69 : void onReady(const std::shared_ptr<dht::crypto::Certificate>& peer, 70 : const std::string& name, 71 : std::shared_ptr<dhtnet::ChannelSocket> channel) override; 72 : 73 : void closeChannel(const std::string& peer, const DeviceId& device, const std::shared_ptr<dhtnet::ChannelSocket>& conn); 74 : 75 : struct Message 76 : { 77 : uint64_t id {0}; /* Message ID */ 78 : std::string t; /* Message type */ 79 : std::string c; /* Message content */ 80 : std::unique_ptr<ConversationRequest> req; /* Conversation request */ 81 26499 : MSGPACK_DEFINE_MAP(id, t, c, req) 82 : }; 83 : 84 : static bool sendMessage(const std::shared_ptr<dhtnet::ChannelSocket>&, const Message& message); 85 : 86 : private: 87 : struct Impl; 88 : std::shared_ptr<Impl> pimpl_; 89 : }; 90 : 91 : } // namespace jami