mirror of
https://github.com/RetroShare/RetroShare.git
synced 2024-12-11 17:04:31 -05:00
2a5854188e
ported some of the tests across. git-svn-id: http://svn.code.sf.net/p/retroshare/code/trunk@7233 b45a01b8-16f6-495d-af2f-9b41ad6348cc
302 lines
6.6 KiB
C++
302 lines
6.6 KiB
C++
/*
|
|
* gxspublishgrouptest.cc
|
|
*
|
|
* Created on: 27 Apr 2013
|
|
* Author: crispy
|
|
*/
|
|
|
|
#include "gxspublishgrouptest.h"
|
|
#include "libretroshare/serialiser/support.h"
|
|
|
|
#define POLLING_TIME_OUT 5
|
|
|
|
GxsPublishGroupTest::GxsPublishGroupTest(GenExchangeTestService* const testService,
|
|
RsGeneralDataService* dataService)
|
|
: GenExchangeTest(testService, dataService, POLLING_TIME_OUT)
|
|
{
|
|
|
|
}
|
|
|
|
GxsPublishGroupTest::~GxsPublishGroupTest()
|
|
{
|
|
}
|
|
|
|
bool GxsPublishGroupTest::testGrpSubmissionRetrieval()
|
|
{
|
|
|
|
setUp();
|
|
|
|
GenExchangeTestService* testService = getTestService();
|
|
RsTokenService* tokenService = getTokenService();
|
|
|
|
// create some random grps to allow msg testing
|
|
|
|
RsDummyGrp* dgrp1 = new RsDummyGrp();
|
|
RsDummyGrp* dgrp2 = new RsDummyGrp();
|
|
RsDummyGrp* dgrp3 = new RsDummyGrp();
|
|
|
|
RsDummyGrp* dgrp1_copy = new RsDummyGrp();
|
|
RsDummyGrp* dgrp2_copy = new RsDummyGrp();
|
|
RsDummyGrp* dgrp3_copy = new RsDummyGrp();
|
|
|
|
init(*dgrp1);
|
|
init(*dgrp2);
|
|
init(*dgrp3);
|
|
|
|
RsTokReqOptions opts;
|
|
opts.mReqType = 45000;
|
|
uint32_t token;
|
|
RsGxsGroupId grpId;
|
|
|
|
std::vector<RsDummyGrp*> groupsPublished;
|
|
|
|
*dgrp1_copy = *dgrp1;
|
|
testService->publishDummyGrp(token, dgrp1);
|
|
pollForGrpAcknowledgement(token, grpId);
|
|
dgrp1_copy->meta.mGroupId = grpId;
|
|
groupsPublished.push_back(dgrp1_copy);
|
|
|
|
*dgrp2_copy = *dgrp2;
|
|
testService->publishDummyGrp(token, dgrp2);
|
|
pollForGrpAcknowledgement(token, grpId);
|
|
dgrp2_copy->meta.mGroupId = grpId;
|
|
groupsPublished.push_back(dgrp2_copy);
|
|
|
|
*dgrp3_copy = *dgrp3;
|
|
testService->publishDummyGrp(token, dgrp3);
|
|
pollForGrpAcknowledgement(token, grpId);
|
|
dgrp3_copy->meta.mGroupId = grpId;
|
|
groupsPublished.push_back(dgrp3_copy);
|
|
|
|
|
|
storeToGrpDataOutList(groupsPublished);
|
|
|
|
opts.mReqType = GXS_REQUEST_TYPE_GROUP_DATA;
|
|
std::list<RsGxsGroupId> grpIds;
|
|
tokenService->requestGroupInfo(token, 0, opts);
|
|
|
|
pollForToken(token, opts, true);
|
|
|
|
|
|
bool ok = compareGrpData();
|
|
|
|
breakDown();
|
|
|
|
return ok;
|
|
}
|
|
|
|
bool GxsPublishGroupTest::testSpecificGrpRetrieval()
|
|
{
|
|
setUp();
|
|
|
|
GenExchangeTestService* testService = getTestService();
|
|
RsTokenService* tokenService = getTokenService();
|
|
|
|
// create some random grps to allow msg testing
|
|
|
|
RsDummyGrp* dgrp1 = new RsDummyGrp();
|
|
RsDummyGrp* dgrp2 = new RsDummyGrp();
|
|
RsDummyGrp* dgrp3 = new RsDummyGrp();
|
|
|
|
RsDummyGrp* dgrp1_copy = new RsDummyGrp();
|
|
RsDummyGrp* dgrp2_copy = new RsDummyGrp();
|
|
|
|
init(*dgrp1);
|
|
init(*dgrp2);
|
|
init(*dgrp3);
|
|
|
|
RsTokReqOptions opts;
|
|
opts.mReqType = 45000;
|
|
uint32_t token;
|
|
RsGxsGroupId grpId;
|
|
|
|
std::vector<RsDummyGrp*> groupsPublished;
|
|
std::list<RsGxsGroupId> grpIds;
|
|
|
|
*dgrp1_copy = *dgrp1;
|
|
testService->publishDummyGrp(token, dgrp1);
|
|
pollForGrpAcknowledgement(token, grpId);
|
|
dgrp1_copy->meta.mGroupId = grpId;
|
|
groupsPublished.push_back(dgrp1_copy);
|
|
grpIds.push_back(grpId);
|
|
|
|
*dgrp2_copy = *dgrp2;
|
|
testService->publishDummyGrp(token, dgrp2);
|
|
pollForGrpAcknowledgement(token, grpId);
|
|
dgrp2_copy->meta.mGroupId = grpId;
|
|
groupsPublished.push_back(dgrp2_copy);
|
|
grpIds.push_back(grpId);
|
|
|
|
|
|
testService->publishDummyGrp(token, dgrp3);
|
|
pollForGrpAcknowledgement(token, grpId);
|
|
|
|
|
|
storeToGrpDataOutList(groupsPublished);
|
|
|
|
opts.mReqType = GXS_REQUEST_TYPE_GROUP_DATA;
|
|
|
|
tokenService->requestGroupInfo(token, 0, opts, grpIds);
|
|
|
|
pollForToken(token, opts, true);
|
|
|
|
|
|
bool ok = compareGrpData();
|
|
|
|
breakDown();
|
|
|
|
return ok;
|
|
}
|
|
|
|
bool GxsPublishGroupTest::testGrpIdRetrieval()
|
|
{
|
|
setUp();
|
|
|
|
std::list<RsGxsGroupId> grpIds;
|
|
createGrps(5, grpIds);
|
|
storeToGrpIdsOutList(grpIds);
|
|
RsTokReqOptions opts;
|
|
opts.mReqType = GXS_REQUEST_TYPE_GROUP_IDS;
|
|
uint32_t token;
|
|
|
|
getTokenService()->requestGroupInfo(token, 0, opts);
|
|
|
|
pollForToken(token, opts, true);
|
|
|
|
bool ok = compareGrpIds();
|
|
|
|
breakDown();
|
|
|
|
return ok;
|
|
}
|
|
|
|
bool GxsPublishGroupTest::testUpdateGroup()
|
|
{
|
|
setUp();
|
|
|
|
GenExchangeTestService* testService = getTestService();
|
|
RsTokenService* tokenService = getTokenService();
|
|
|
|
// create some random grps to allow msg testing
|
|
|
|
RsDummyGrp* dgrp1 = new RsDummyGrp();
|
|
RsDummyGrp* dgrp2 = new RsDummyGrp();
|
|
|
|
RsDummyGrp* dgrp2_copy = new RsDummyGrp();
|
|
|
|
init(*dgrp1);
|
|
init(*dgrp2);
|
|
|
|
RsTokReqOptions opts;
|
|
opts.mReqType = 45000;
|
|
uint32_t token;
|
|
RsGxsGroupId grpId;
|
|
|
|
std::vector<RsDummyGrp*> groupsPublished;
|
|
std::list<RsGxsGroupId> grpIds;
|
|
|
|
std::string name = dgrp1->meta.mGroupName;
|
|
*dgrp2 = *dgrp1;
|
|
testService->publishDummyGrp(token, dgrp1);
|
|
bool ok = pollForGrpAcknowledgement(token, grpId);
|
|
|
|
grpIds.push_back(grpId);
|
|
RsGxsGroupUpdateMeta updateMeta(grpId);
|
|
|
|
updateMeta.setMetaUpdate(RsGxsGroupUpdateMeta::NAME, name);
|
|
randString(SHORT_STR, dgrp2->grpData);
|
|
dgrp2->meta.mGroupId = grpId;
|
|
*dgrp2_copy = *dgrp2;
|
|
dgrp2->grpData ="ojfosfjsofjsof";
|
|
testService->updateDummyGrp(token, updateMeta, dgrp2);
|
|
ok &= pollForGrpAcknowledgement(token, grpId);
|
|
|
|
groupsPublished.push_back(dgrp2_copy);
|
|
|
|
opts.mReqType = GXS_REQUEST_TYPE_GROUP_DATA;
|
|
|
|
tokenService->requestGroupInfo(token, 0, opts, grpIds);
|
|
|
|
pollForToken(token, opts, true);
|
|
|
|
|
|
ok &= compareGrpData();
|
|
|
|
breakDown();
|
|
|
|
return ok;
|
|
|
|
}
|
|
|
|
bool GxsPublishGroupTest::testGrpMetaRetrieval()
|
|
{
|
|
|
|
setUp();
|
|
|
|
GenExchangeTestService* testService = getTestService();
|
|
|
|
// create some random grps to allow msg testing
|
|
|
|
RsDummyGrp* dgrp1 = new RsDummyGrp();
|
|
RsDummyGrp* dgrp2 = new RsDummyGrp();
|
|
RsDummyGrp* dgrp3 = new RsDummyGrp();
|
|
|
|
init(*dgrp1);
|
|
init(*dgrp2);
|
|
init(*dgrp3);
|
|
|
|
RsTokReqOptions opts;
|
|
opts.mReqType = 45000;
|
|
uint32_t token;
|
|
RsGxsGroupId grpId;
|
|
|
|
RsGroupMetaData meta1(dgrp1->meta);
|
|
RsGroupMetaData meta2(dgrp2->meta);
|
|
RsGroupMetaData meta3(dgrp3->meta);
|
|
|
|
std::list<RsGroupMetaData> groupsMetaPublished;
|
|
|
|
testService->publishDummyGrp(token, dgrp1);
|
|
pollForGrpAcknowledgement(token, grpId);
|
|
meta1.mGroupId = grpId;
|
|
groupsMetaPublished.push_back(meta1);
|
|
|
|
testService->publishDummyGrp(token, dgrp2);
|
|
pollForGrpAcknowledgement(token, grpId);
|
|
meta2.mGroupId = grpId;
|
|
groupsMetaPublished.push_back(meta2);
|
|
|
|
testService->publishDummyGrp(token, dgrp3);
|
|
pollForGrpAcknowledgement(token, grpId);
|
|
meta3.mGroupId = grpId;
|
|
groupsMetaPublished.push_back(meta3);
|
|
|
|
storeToGrpMetaOutList(groupsMetaPublished);
|
|
|
|
opts.mReqType = GXS_REQUEST_TYPE_GROUP_META;
|
|
std::list<RsGxsGroupId> grpIds;
|
|
|
|
getTokenService()->requestGroupInfo(token, 0, opts);
|
|
|
|
pollForToken(token, opts, true);
|
|
|
|
bool ok = compareGrpMeta();
|
|
|
|
breakDown();
|
|
|
|
return ok;
|
|
}
|
|
|
|
void GxsPublishGroupTest::runTests()
|
|
{
|
|
// CHECK(testGrpSubmissionRetrieval());
|
|
// CHECK(testGrpIdRetrieval());
|
|
// CHECK(testGrpMetaRetrieval());
|
|
// CHECK(testSpecificGrpRetrieval());
|
|
EXPECT_TRUE(testUpdateGroup());
|
|
}
|
|
|
|
|
|
|
|
|