gittransport.h

Go to the documentation of this file.

/*
 *  Copyright (C) 2004-2025 Savoir-faire Linux Inc.
 *
 *  This program is free software: you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation, either version 3 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program. If not, see <https://www.gnu.org/licenses/>.
 */
#pragma once
 
#include <memory>
#include <string>
#include <string_view>
#include <algorithm>
#include <git2/remote.h>
#include <git2/sys/transport.h>
#include <git2/errors.h>
#include <git2.h>
 
namespace jami {
class Manager;
} // namespace jami
 
namespace dhtnet {
class ChannelSocket;
} // namespace dhtnet
 
// NOTE: THIS MUST BE IN THE ROOT NAMESPACE FOR LIBGIT2
 
struct P2PStream
{
    git_smart_subtransport_stream base;
    std::weak_ptr<dhtnet::ChannelSocket> socket;
 
    std::string cmd {};
    std::string url {};
    unsigned sent_command : 1;
};
 
struct P2PSubTransport
{
    git_smart_subtransport base;
    std::unique_ptr<P2PStream> stream;
    git_remote* remote;
};
 
using namespace std::string_view_literals;
constexpr auto UPLOAD_PACK_CMD = "git-upload-pack"sv;
constexpr auto HOST_TAG = "host="sv;
 
/*
 * Create a git protocol request.
 *
 * For example: 0029git-upload-pack conversation\0host=device\0
 * @param buf       The buffer to fill
 * @param cmd       The wanted command
 * @param url       The repository's URL
 * @return 0 on success, - 1 on error
 */
int generateRequest(git_buf* request, const std::string& cmd, const std::string_view& url);
 
int sendCmd(P2PStream* s);
 
int P2PStreamRead(git_smart_subtransport_stream* stream, char* buffer, size_t buflen, size_t* read);
 
int P2PStreamWrite(git_smart_subtransport_stream* stream, const char* buffer, size_t len);
 
void P2PStreamFree(git_smart_subtransport_stream* stream);
 
int P2PSubTransportAction(git_smart_subtransport_stream** out,
                          git_smart_subtransport* transport,
                          const char* url,
                          git_smart_service_t action);
 
int P2PSubTransportClose(git_smart_subtransport*);
 
void P2PSubTransportFree(git_smart_subtransport* transport);
 
int P2PSubTransportNew(P2PSubTransport** out, git_transport* owner, void* payload);
 
int p2p_subtransport_cb(git_smart_subtransport** out, git_transport* owner, void* payload);
 
int p2p_transport_cb(git_transport** out, git_remote* owner, void* param);