mirror of
https://git.jami.net/savoirfairelinux/jami-daemon.git
synced 2025-08-12 22:09:25 +08:00
swarmchat: initialize empty git repository with initial commit
This patch offers an API to create conversation. A conversation is represented by a git repository. The repository will contains the account certificate in /admins, its CRLs in /CRLs and the device key in /devices. Moreover, the first signed commit's hash will be the conversation's id Change-Id: Iac7ff7f6002185a5bb0f51d4c10df1afe9e059b4
This commit is contained in:
Sébastien Blin
181
test/unitTest/conversationRepository/conversationRepository.cpp
Normal file
181
test/unitTest/conversationRepository/conversationRepository.cpp
Normal file
@ -0,0 +1,181 @@
|
||||
/*
|
||||
* Copyright (C) 2017-2019 Savoir-faire Linux Inc.
|
||||
* Author: Sébastien Blin <sebastien.blin@savoirfairelinux.com>
|
||||
*
|
||||
* 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/>.
|
||||
*/
|
||||
|
||||
#include <cppunit/TestAssert.h>
|
||||
#include <cppunit/TestFixture.h>
|
||||
#include <cppunit/extensions/HelperMacros.h>
|
||||
|
||||
#include <condition_variable>
|
||||
#include <string>
|
||||
#include <fstream>
|
||||
#include <streambuf>
|
||||
|
||||
#include "manager.h"
|
||||
#include "jamidht/conversationrepository.h"
|
||||
#include "jamidht/jamiaccount.h"
|
||||
#include "../../test_runner.h"
|
||||
#include "dring.h"
|
||||
#include "base64.h"
|
||||
#include "fileutils.h"
|
||||
#include "account_const.h"
|
||||
|
||||
#include "git2.h"
|
||||
|
||||
using namespace DRing::Account;
|
||||
|
||||
namespace jami { namespace test {
|
||||
|
||||
class ConversationRepositoryTest : public CppUnit::TestFixture {
|
||||
public:
|
||||
~ConversationRepositoryTest() {
|
||||
DRing::fini();
|
||||
}
|
||||
static std::string name() { return "ConversationRepository"; }
|
||||
void setUp();
|
||||
void tearDown();
|
||||
|
||||
std::string aliceId;
|
||||
std::string bobId;
|
||||
|
||||
private:
|
||||
void testCreateRepository();
|
||||
|
||||
CPPUNIT_TEST_SUITE(ConversationRepositoryTest);
|
||||
CPPUNIT_TEST(testCreateRepository);
|
||||
CPPUNIT_TEST_SUITE_END();
|
||||
};
|
||||
|
||||
CPPUNIT_TEST_SUITE_NAMED_REGISTRATION(ConversationRepositoryTest, ConversationRepositoryTest::name());
|
||||
|
||||
void
|
||||
ConversationRepositoryTest::setUp()
|
||||
{
|
||||
// Init daemon
|
||||
DRing::init(DRing::InitFlag(DRing::DRING_FLAG_DEBUG | DRing::DRING_FLAG_CONSOLE_LOG));
|
||||
CPPUNIT_ASSERT(DRing::start("dring-sample.yml"));
|
||||
|
||||
std::map<std::string, std::string> details = DRing::getAccountTemplate("RING");
|
||||
details[ConfProperties::TYPE] = "RING";
|
||||
details[ConfProperties::DISPLAYNAME] = "ALICE";
|
||||
details[ConfProperties::ALIAS] = "ALICE";
|
||||
details[ConfProperties::UPNP_ENABLED] = "true";
|
||||
details[ConfProperties::ARCHIVE_PASSWORD] = "";
|
||||
details[ConfProperties::ARCHIVE_PIN] = "";
|
||||
details[ConfProperties::ARCHIVE_PATH] = "";
|
||||
aliceId = Manager::instance().addAccount(details);
|
||||
|
||||
details = DRing::getAccountTemplate("RING");
|
||||
details[ConfProperties::TYPE] = "RING";
|
||||
details[ConfProperties::DISPLAYNAME] = "BOB";
|
||||
details[ConfProperties::ALIAS] = "BOB";
|
||||
details[ConfProperties::UPNP_ENABLED] = "true";
|
||||
details[ConfProperties::ARCHIVE_PASSWORD] = "";
|
||||
details[ConfProperties::ARCHIVE_PIN] = "";
|
||||
details[ConfProperties::ARCHIVE_PATH] = "";
|
||||
bobId = Manager::instance().addAccount(details);
|
||||
|
||||
auto aliceAccount = Manager::instance().getAccount<JamiAccount>(aliceId);
|
||||
auto bobAccount = Manager::instance().getAccount<JamiAccount>(bobId);
|
||||
|
||||
bool ready = false;
|
||||
bool idx = 0;
|
||||
while(!ready && idx < 100) {
|
||||
auto details = aliceAccount->getVolatileAccountDetails();
|
||||
auto daemonStatus = details[DRing::Account::ConfProperties::Registration::STATUS];
|
||||
ready = (daemonStatus == "REGISTERED");
|
||||
details = bobAccount->getVolatileAccountDetails();
|
||||
daemonStatus = details[DRing::Account::ConfProperties::Registration::STATUS];
|
||||
ready &= (daemonStatus == "REGISTERED");
|
||||
if (!ready) {
|
||||
idx += 1;
|
||||
std::this_thread::sleep_for(std::chrono::milliseconds(100));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
void
|
||||
ConversationRepositoryTest::tearDown()
|
||||
{
|
||||
auto currentAccSize = Manager::instance().getAccountList().size();
|
||||
Manager::instance().removeAccount(aliceId, true);
|
||||
Manager::instance().removeAccount(bobId, true);
|
||||
// Because cppunit is not linked with dbus, just poll if removed
|
||||
for (int i = 0; i < 40; ++i) {
|
||||
if (Manager::instance().getAccountList().size() <= currentAccSize - 2) break;
|
||||
std::this_thread::sleep_for(std::chrono::milliseconds(100));
|
||||
}
|
||||
}
|
||||
|
||||
void
|
||||
ConversationRepositoryTest::testCreateRepository()
|
||||
{
|
||||
auto aliceAccount = Manager::instance().getAccount<JamiAccount>(aliceId);
|
||||
auto aliceDeviceId = aliceAccount->currentDeviceId();
|
||||
auto uri = aliceAccount->getUsername();
|
||||
|
||||
auto repository = ConversationRepository::createConversation(aliceAccount->weak());
|
||||
|
||||
// Assert that repository exists
|
||||
CPPUNIT_ASSERT(repository != nullptr);
|
||||
auto repoPath = fileutils::get_data_dir()+DIR_SEPARATOR_STR+aliceAccount->getAccountID()+DIR_SEPARATOR_STR+"conversations"+DIR_SEPARATOR_STR+repository->id();
|
||||
CPPUNIT_ASSERT(fileutils::isDirectory(repoPath));
|
||||
|
||||
// Assert that first commit is signed by alice
|
||||
git_repository* repo;
|
||||
CPPUNIT_ASSERT(git_repository_open(&repo, repoPath.c_str()) == 0);
|
||||
|
||||
// 1. Verify that last commit is correctly signed by alice
|
||||
git_oid commit_id;
|
||||
CPPUNIT_ASSERT(git_reference_name_to_id(&commit_id, repo, "HEAD") == 0);
|
||||
|
||||
git_buf signature = {}, signed_data = {};
|
||||
git_commit_extract_signature(&signature, &signed_data, repo, &commit_id, "signature");
|
||||
auto pk = base64::decode(std::string(signature.ptr, signature.ptr + signature.size));
|
||||
auto data = std::vector<uint8_t>(signed_data.ptr, signed_data.ptr + signed_data.size);
|
||||
git_repository_free(repo);
|
||||
|
||||
CPPUNIT_ASSERT(aliceAccount->identity().second->getPublicKey().checkSignature(data, pk));
|
||||
|
||||
// 2. Check created files
|
||||
auto CRLsPath = repoPath + DIR_SEPARATOR_STR + "CRLs" + DIR_SEPARATOR_STR + aliceDeviceId;
|
||||
CPPUNIT_ASSERT(fileutils::isDirectory(repoPath));
|
||||
|
||||
auto adminCrt = repoPath + DIR_SEPARATOR_STR + "admins" + DIR_SEPARATOR_STR + uri + ".crt";
|
||||
CPPUNIT_ASSERT(fileutils::isFile(adminCrt));
|
||||
|
||||
auto crt = std::ifstream(adminCrt);
|
||||
std::string adminCrtStr((std::istreambuf_iterator<char>(crt)), std::istreambuf_iterator<char>());
|
||||
|
||||
auto cert = aliceAccount->identity().second;
|
||||
auto deviceCert = cert->toString(false);
|
||||
auto parentCert = cert->issuer->toString(true);
|
||||
|
||||
CPPUNIT_ASSERT(adminCrtStr == parentCert);
|
||||
|
||||
auto deviceCrt = repoPath + DIR_SEPARATOR_STR + "devices" + DIR_SEPARATOR_STR + aliceDeviceId + ".crt";
|
||||
CPPUNIT_ASSERT(fileutils::isFile(deviceCrt));
|
||||
|
||||
crt = std::ifstream(deviceCrt);
|
||||
std::string deviceCrtStr((std::istreambuf_iterator<char>(crt)), std::istreambuf_iterator<char>());
|
||||
|
||||
CPPUNIT_ASSERT(deviceCrtStr == deviceCert);
|
||||
}
|
||||
|
||||
}} // namespace test
|
||||
|
||||
RING_TEST_RUNNER(jami::test::ConversationRepositoryTest::name())
|
||||
Reference in New Issue
Block a user