87 lines
3.6 KiB
C++
87 lines
3.6 KiB
C++
#include <catch2/catch_test_macros.hpp>
|
|
#include <filesystem>
|
|
|
|
#include "fsfw/cfdp.h"
|
|
#include "fsfw/cfdp/CfdpMessage.h"
|
|
#include "fsfw/cfdp/handler/PutRequest.h"
|
|
#include "fsfw/cfdp/handler/SourceHandler.h"
|
|
#include "fsfw/cfdp/pdu/EofPduCreator.h"
|
|
#include "fsfw/cfdp/pdu/FileDataCreator.h"
|
|
#include "fsfw/cfdp/pdu/MetadataPduCreator.h"
|
|
#include "fsfw/cfdp/pdu/MetadataPduReader.h"
|
|
#include "fsfw/globalfunctions/arrayprinter.h"
|
|
#include "fsfw/storagemanager/StorageManagerIF.h"
|
|
#include "fsfw/tmtcservices/TmTcMessage.h"
|
|
#include "fsfw/util/SeqCountProvider.h"
|
|
#include "mocks/AcceptsTmMock.h"
|
|
#include "mocks/EventReportingProxyMock.h"
|
|
#include "mocks/FilesystemMock.h"
|
|
#include "mocks/MessageQueueMock.h"
|
|
#include "mocks/StorageManagerMock.h"
|
|
#include "mocks/cfdp/FaultHandlerMock.h"
|
|
#include "mocks/cfdp/RemoteConfigTableMock.h"
|
|
#include "mocks/cfdp/UserMock.h"
|
|
|
|
TEST_CASE("CFDP Source Handler", "[cfdp]") {
|
|
using namespace cfdp;
|
|
using namespace returnvalue;
|
|
using namespace std::filesystem;
|
|
MessageQueueId_t destQueueId = 2;
|
|
AcceptsTmMock tmReceiver(destQueueId);
|
|
MessageQueueMock mqMock(destQueueId);
|
|
EntityId localId = EntityId(UnsignedByteField<uint16_t>(2));
|
|
EntityId remoteId = EntityId(UnsignedByteField<uint16_t>(3));
|
|
FaultHandlerMock fhMock;
|
|
LocalEntityCfg localEntityCfg(localId, IndicationCfg(), fhMock);
|
|
FilesystemMock fsMock;
|
|
UserMock userMock(fsMock);
|
|
SeqCountProviderU16 seqCountProvider;
|
|
SourceHandlerParams dp(localEntityCfg, userMock, seqCountProvider);
|
|
|
|
EventReportingProxyMock eventReporterMock;
|
|
LocalPool::LocalPoolConfig storeCfg = {{10, 32}, {10, 64}, {10, 128}, {10, 1024}};
|
|
StorageManagerMock tcStore(2, storeCfg);
|
|
StorageManagerMock tmStore(3, storeCfg);
|
|
FsfwParams fp(tmReceiver, &mqMock, &eventReporterMock);
|
|
fp.tcStore = &tcStore;
|
|
fp.tmStore = &tmStore;
|
|
auto sourceHandler = SourceHandler(dp, fp);
|
|
CHECK(sourceHandler.initialize() == OK);
|
|
|
|
SECTION("Test Basic") {
|
|
CHECK(sourceHandler.getState() == CfdpState::IDLE);
|
|
CHECK(sourceHandler.getStep() == SourceHandler::TransactionStep::IDLE);
|
|
}
|
|
|
|
SECTION("Transfer empty file") {
|
|
// using StorageManagerIF::getData;
|
|
RemoteEntityCfg cfg;
|
|
EntityId id(cfdp::WidthInBytes::ONE_BYTE, 5);
|
|
cfg.remoteId = id;
|
|
FilesystemParams srcFileName("/tmp/cfdp-test.txt");
|
|
fsMock.createFile(srcFileName);
|
|
cfdp::StringLv srcNameLv(srcFileName.path, std::strlen(srcFileName.path));
|
|
FilesystemParams destFileName("/tmp/cfdp-test2.txt");
|
|
cfdp::StringLv destNameLv(destFileName.path, std::strlen(destFileName.path));
|
|
PutRequest putRequest(id, srcNameLv, destNameLv);
|
|
CHECK(sourceHandler.transactionStart(putRequest, cfg) == OK);
|
|
SourceHandler::FsmResult& fsmResult = sourceHandler.stateMachine();
|
|
CHECK(fsmResult.packetsSent == 1);
|
|
CHECK(mqMock.numberOfSentMessages() == 1);
|
|
TmTcMessage tmtcMessage;
|
|
REQUIRE(mqMock.getNextSentMessage(destQueueId, tmtcMessage) == OK);
|
|
auto accessor = tmStore.getData(tmtcMessage.getStorageId());
|
|
REQUIRE(accessor.first == OK);
|
|
const uint8_t* pduPtr = accessor.second.data();
|
|
CHECK(accessor.second.size() == 55);
|
|
MetadataGenericInfo metadataInfo;
|
|
MetadataPduReader metadataReader(pduPtr, accessor.second.size(), metadataInfo, nullptr, 0);
|
|
size_t srcFileSize = 0;
|
|
arrayprinter::print(pduPtr, accessor.second.size());
|
|
REQUIRE(metadataReader.parseData() == OK);
|
|
const char* srcNameRead = metadataReader.getSourceFileName().getString(srcFileSize);
|
|
REQUIRE(srcNameRead != nullptr);
|
|
std::string srcNameReadStr(srcNameRead, srcFileSize);
|
|
CHECK(std::string(srcFileName.path) == srcNameReadStr);
|
|
}
|
|
} |