diff --git a/CMakeLists.txt b/CMakeLists.txt
index 2eb1adc0e438faa151518073d866868bb354797b..2ba3de72d540afb9266a558792676bd60953e005 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -17,8 +17,10 @@ add_custom_target(check
add_library(common OBJECT
src/ErrorHandler.cpp
src/Message.cpp
- src/MessageParser.cpp
+ src/MessageParser.cpp
+ src/ServicePool.cpp
src/Helpers/CRCHelper.cpp
+ src/Helpers/TimeAndDate.cpp
src/Helpers/TimeHelper.cpp
src/Services/EventReportService.cpp
src/Services/MemoryManagementService.cpp
@@ -31,10 +33,11 @@ add_library(common OBJECT
)
# Specify the .cpp files for the executables
+file(GLOB x86_main_SRC "src/Platform/x86/*.cpp")
add_executable(ecss_services
src/main.cpp
$<TARGET_OBJECTS:common>
- src/Platform/x86/Service.cpp
+ ${x86_main_SRC}
)
IF (EXISTS "${PROJECT_SOURCE_DIR}/lib/Catch2/CMakeLists.txt")
diff --git a/ci/.clang-tidy b/ci/.clang-tidy
index 79406a31501a0c54cd823f6aa9f9d5f56d9d0715..d6611e01ed1e46f65632ddbbfa2814514c8367c8 100644
--- a/ci/.clang-tidy
+++ b/ci/.clang-tidy
@@ -19,7 +19,7 @@ Checks: >
performance-*,
readability-*,
zircon-*
-WarningsAsErrors: '*,-misc-unused-parameters,-llvm-header-guard,-cppcoreguidelines-pro-type-member-init,-google-runtime-references,-clang-diagnostic-tautological-constant-out-of-range-compare,-readability-redundant-declaration,-modernize-use-equals-default,-fuchsia-statically-constructed-objects,-hicpp-signed-bitwise,-cert-err58-cpp'
+WarningsAsErrors: '*,-misc-unused-parameters,-llvm-header-guard,-cppcoreguidelines-pro-type-member-init,-google-runtime-references,-clang-diagnostic-tautological-constant-out-of-range-compare,-readability-redundant-declaration',-modernize-use-equals-default,-fuchsia-statically-constructed-objects,-hicpp-signed-bitwise,-cert-err58-cpp',-clang-diagnostic-error,-misc-noexcept-move-constructor'
HeaderFilterRegex: 'ecss-services\/((?!lib\/).)*$'
AnalyzeTemporaryDtors: false
...
diff --git a/ci/vera.profile b/ci/vera.profile
index 4da7dae75b571530a062c8453ffa0f3c6a89781e..2382359f944d16804f95c08abf35c78c0d758ae8 100644
--- a/ci/vera.profile
+++ b/ci/vera.profile
@@ -9,7 +9,6 @@ set rules {
L006
T001
T002
- T003
T004
T005
T006
diff --git a/inc/ErrorHandler.hpp b/inc/ErrorHandler.hpp
index 25c65960e3e408ca35e5a818794eeaa83f873c70..07c290934b7f5bc3b2e86c2d56324ccb2169c4c0 100644
--- a/inc/ErrorHandler.hpp
+++ b/inc/ErrorHandler.hpp
@@ -1,6 +1,8 @@
#ifndef PROJECT_ERRORHANDLER_HPP
#define PROJECT_ERRORHANDLER_HPP
+#include <type_traits>
+
// Forward declaration of the class, since its header file depends on the ErrorHandler
class Message;
@@ -15,20 +17,13 @@ class Message;
class ErrorHandler {
private:
/**
- * Log the error to a logging facility. Currently, this just displays the error on the screen.
- *
- * @todo This function MUST be moved as platform-dependent code. Currently, it uses g++ specific
- * functions for desktop.
+ * Log the error to a logging facility. Platform-dependent.
*/
template<typename ErrorType>
static void logError(const Message &message, ErrorType errorType);
/**
- * Log an error without a Message to a logging facility. Currently, this just displays the error
- * on the screen.
- *
- * @todo This function MUST be moved as platform-dependent code. Currently, it uses g++ specific
- * functions for desktop.
+ * Log an error without a Message to a logging facility. Platform-dependent.
*/
template<typename ErrorType>
static void logError(ErrorType errorType);
@@ -59,9 +54,14 @@ public:
UnacceptablePacket = 5,
/**
- * Asked a Message type that it doesn't exist
+ * A date that isn't valid according to the Gregorian calendar or cannot be parsed by the
+ * TimeHelper
+ */
+ InvalidDate = 6,
+ /**
+ * Asked a Message type that doesn't exist
*/
- UnknownMessageType = 6,
+ UnknownMessageType = 7,
};
/**
@@ -165,7 +165,7 @@ public:
/**
* Report a failure about the progress of the execution of a request
*
- * Note:This function is different from reportError, because we need one more /p(stepID)
+ * @note This function is different from reportError, because we need one more \p stepID
* to call the proper function for reporting the progress of the execution of a request
*
* @param message The incoming message that prompted the failure
@@ -183,6 +183,7 @@ public:
*
* Note that these errors correspond to bugs or faults in the software, and should be treated
* differently. Such an error may prompt a task or software reset.
+ *
*/
static void reportInternalError(InternalErrorType errorCode);
@@ -212,6 +213,35 @@ public:
reportError(message, errorCode);
}
}
+
+ /**
+ * Convert a parameter given in C++ to an ErrorSource that can be easily used in comparisons.
+ * @tparam ErrorType One of the enums specified in ErrorHandler.
+ * @param error An error code of a specific type
+ * @return The corresponding ErrorSource
+ */
+ template<typename ErrorType>
+ inline static ErrorSource findErrorSource(ErrorType error) {
+ // While this may seem like a "hacky" way to convert enums to ErrorSource, it should be
+ // optimised by the compiler to constant time.
+
+ if (std::is_same<ErrorType, AcceptanceErrorType>()) {
+ return Acceptance;
+ }
+ if (std::is_same<ErrorType, ExecutionStartErrorType>()) {
+ return ExecutionStart;
+ }
+ if (std::is_same<ErrorType, ExecutionProgressErrorType>()) {
+ return ExecutionProgress;
+ }
+ if (std::is_same<ErrorType, ExecutionCompletionErrorType>()) {
+ return ExecutionCompletion;
+ }
+ if (std::is_same<ErrorType, RoutingErrorType>()) {
+ return Routing;
+ }
+ return Internal;
+ }
};
#endif //PROJECT_ERRORHANDLER_HPP
diff --git a/inc/Helpers/TimeAndDate.hpp b/inc/Helpers/TimeAndDate.hpp
new file mode 100644
index 0000000000000000000000000000000000000000..8ddc566973bddfbf78c6fa695d141935d12c06d7
--- /dev/null
+++ b/inc/Helpers/TimeAndDate.hpp
@@ -0,0 +1,79 @@
+#ifndef ECSS_SERVICES_TIMEANDDATE_HPP
+#define ECSS_SERVICES_TIMEANDDATE_HPP
+
+#include <cstdint>
+#include "macros.hpp"
+
+/**
+ * A class that represents the time and date.
+ *
+ * @note
+ * This class represents UTC (Coordinated Universal Time) date
+ */
+class TimeAndDate {
+public:
+ uint16_t year;
+ uint8_t month;
+ uint8_t day;
+ uint8_t hour;
+ uint8_t minute;
+ uint8_t second;
+
+ /**
+ * Assign the instances with the Unix epoch 1/1/1970 00:00:00
+ */
+ TimeAndDate();
+
+ /**
+ * @param year the year as it used in Gregorian calendar
+ * @param month the month as it used in Gregorian calendar
+ * @param day the day as it used in Gregorian calendar
+ * @param hour UTC hour in 24 format
+ * @param minute UTC minutes
+ * @param second UTC seconds
+ */
+ TimeAndDate(uint16_t year, uint8_t month, uint8_t day, uint8_t hour, uint8_t minute, uint8_t
+ second);
+
+ /**
+ * Compare two timestamps.
+ *
+ * @param Date the date that will be compared with the pointer `this`
+ * @return true if the pointer `this` is smaller than \p Date
+ */
+ bool operator<(const TimeAndDate &Date);
+
+ /**
+ * Compare two timestamps.
+ *
+ * @param Date the date that will be compared with the pointer `this`
+ * @return true if the pointer `this` is greater than \p Date
+ */
+ bool operator>(const TimeAndDate &Date);
+
+ /**
+ * Compare two timestamps.
+ *
+ * @param Date the date that will be compared with the pointer `this`
+ * @return true if the pointer `this` is equal to \p Date
+ */
+ bool operator==(const TimeAndDate &Date);
+
+ /**
+ * Compare two timestamps.
+ *
+ * @param Date the date that will be compared with the pointer `this`
+ * @return true if the pointer `this` is smaller than or equal to \p Date
+ */
+ bool operator<=(const TimeAndDate &Date);
+
+ /**
+ * Compare two timestamps.
+ *
+ * @param Date the date that will be compared with the pointer `this`
+ * @return true if the pointer `this` is greater than or equal to \p Date
+ */
+ bool operator>=(const TimeAndDate &Date);
+};
+
+#endif //ECSS_SERVICES_TIMEANDDATE_HPP
diff --git a/inc/Helpers/TimeHelper.hpp b/inc/Helpers/TimeHelper.hpp
index 8661fff4c05df60a8c43b583bec6a62695f060a7..6d3bf156cec960316f9878e4f0fd834c9b12b60c 100644
--- a/inc/Helpers/TimeHelper.hpp
+++ b/inc/Helpers/TimeHelper.hpp
@@ -3,39 +3,94 @@
#include <cstdint>
#include <Message.hpp>
+#include "TimeAndDate.hpp"
+
+#define SECONDS_PER_MINUTE 60
+#define SECONDS_PER_HOUR 3600
+#define SECONDS_PER_DAY 86400
/**
* This class formats the spacecraft time and cooperates closely with the ST[09] time management.
- * The ECSS standard supports two time formats: the CUC and CSD that are described in
- * CCSDS 301.0-B-4 standard
- * The chosen time format is CUC. The reasons for this selection are the followings:
- * 1)It is more flexible from the CSD. The designer is free to decide how much memory will use
- * for the time unit and what that time unit will be(seconds, minutes, hours etc.).
- * 2)It can use TAI(international atomic time) as reference time scale. So there is no need
- * to worry about leap seconds(code UTC-based)
*
- * Note: The implementation of the time formats are in general RTC-dependent. First, we need to
- * get the time data from the RTC, so we know what time is it and then format it!
+ * The ECSS standard supports two time formats: the CUC and CSD that are described in CCSDS
+ * 301.0-B-4 standard. The chosen time format is CDS and it is UTC-based (UTC: Coordinated
+ * Universal Time). It consists of two main fields: the time code preamble field (P-field) and
+ * the time specification field (T-field). The P-Field is the metadata for the T-Field. The
+ * T-Field is consisted of two segments: 1) the `DAY` and the 2) `ms of day` segments.
+ * The P-field won't be included in the code, because as the ECSS standards claims, it can be
+ * just implicitly declared.
+ *
+ * @note
+ * Since this code is UTC-based, the leap second correction must be made. The leap seconds that
+ * have been occurred between timestamps should be considered if a critical time-difference is
+ * needed
+ *
*/
class TimeHelper {
public:
+ static constexpr uint8_t DaysOfMonth[12] = {31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31};
+
+ TimeHelper() = default;
+
+ /**
+ * @param year The year that will be examined if it is a leap year (366 days)
+ * @return if the \p year is a leap year returns true and if it isn't returns false
+ */
+ static bool IsLeapYear(uint16_t year);
+
+ /**
+ * Convert UTC date to elapsed seconds since Unix epoch (1/1/1970 00:00:00).
+ *
+ * This is a reimplemented mktime() of <ctime> library in an embedded systems way
+ *
+ * @note
+ * This function can convert UTC dates after 1 January 2019 to elapsed seconds since Unix epoch
+ *
+ * @param TimeInfo the time information/data from the RTC (UTC format)
+ * @return the elapsed seconds between a given UTC date (after the Unix epoch) and Unix epoch
+ * @todo check if we need to change the epoch to the recommended one from the standard, 1
+ * January 1958
+ */
+ static uint32_t utcToSeconds(TimeAndDate &TimeInfo);
+
+ /**
+ * Convert elapsed seconds since Unix epoch to UTC date.
+ *
+ * This is a reimplemented gmtime() of <ctime> library in an embedded systems way
+ *
+ * @note
+ * This function can convert elapsed seconds since Unix epoch to UTC dates after 1 January 2019
+ *
+ * @param seconds elapsed seconds since Unix epoch
+ * @return the UTC date based on the \p seconds
+ * @todo check if we need to change the epoch to the recommended one from the standard, 1
+ * January 1958
+ */
+ static TimeAndDate secondsToUTC(uint32_t seconds);
+
/**
- * Generate the CUC time format
+ * Generate the CDS time format (3.3 in CCSDS 301.0-B-4 standard).
*
- * @details The CUC time format consists of two main fields: the time code preamble field
- * (P-field) and the time specification field(T-field). The P-Field is the metadata for the
- * T-Field. The T-Field contains the value of the time unit and the designer decides what the
- * time unit will be, so this is a subject for discussion. The recommended time unit from the
- * standard is the second and it is probably the best solution for accuracy.
- * @param seconds the seconds provided from the RTC. This function in general should have
- * parameters corresponding with the RTC. For the time being we assume that the RTC has a
- * 32-bit counter that counts seconds(the RTC in Nucleo F103RB!)
- * @todo check if we need milliseconds(fractions of the time unit)
- * @todo the time unit should be declared in the metadata. But how?
- * @todo check if we need to define other epoch than the 1 January 1958
+ * Converts a UTC date to CDS time format.
+ *
+ * @param TimeInfo is the data provided from RTC (UTC)
+ * @return TimeFormat the CDS time format. More specific, 48 bits are used for the T-field
+ * (16 for the `DAY` and 32 for the `ms of day`)
* @todo time security for critical time operations
+ * @todo declare the implicit P-field
+ * @todo check if we need milliseconds
*/
- static uint64_t implementCUCTimeFormat(uint32_t seconds);
+ static uint64_t generateCDStimeFormat(struct TimeAndDate &TimeInfo);
+
+ /**
+ * Parse the CDS time format (3.3 in CCSDS 301.0-B-4 standard)
+ *
+ * @param data time information provided from the ground segment. The length of the data is a
+ * fixed size of 48 bits
+ * @return the UTC date
+ */
+ static TimeAndDate parseCDStimeFormat(const uint8_t *data);
};
+
#endif //ECSS_SERVICES_TIMEHELPER_HPP
diff --git a/inc/Service.hpp b/inc/Service.hpp
index 0aab624de64f9196d2ddae82ce97d3cb0c738156..09937508303e6a1b19dffca76e68db0266299802 100644
--- a/inc/Service.hpp
+++ b/inc/Service.hpp
@@ -5,6 +5,8 @@
#include "Message.hpp"
#include <iostream> // This file should be removed
+class ServicePool;
+
/**
* A spacecraft service, as defined in ECSS-E-ST-70-41C
*
@@ -17,6 +19,10 @@ class Service {
private:
uint16_t messageTypeCounter = 0;
protected:
+ /**
+ * The service type of this Service. For example, ST[12]'s serviceType is `12`.
+ * Specify this value in the constructor of your service.
+ */
uint8_t serviceType{};
/**
@@ -45,6 +51,40 @@ protected:
* this, but this particular function does actually nothing.
*/
void execute(Message &message);
+
+ /**
+ * Default protected constructor for this Service
+ */
+ Service() = default;
+public:
+ /**
+ * @brief Unimplemented copy constructor
+ *
+ * Does not allow Services should be copied. There should be only one instance for each Service.
+ */
+ Service (Service const&) = delete;
+
+ /**
+ * Unimplemented assignment operation
+ *
+ * Does not allow changing the instances of Services, as Services are singletons.
+ */
+ void operator=(Service const&) = delete;
+
+ /**
+ * Default destructor
+ */
+ ~Service() = default;
+
+ /**
+ * Default move constructor
+ */
+ Service(Service && service) noexcept = default;
+
+ /**
+ * Default move assignment operator
+ */
+ Service & operator=(Service && service) noexcept = default;
};
diff --git a/inc/ServicePool.hpp b/inc/ServicePool.hpp
new file mode 100644
index 0000000000000000000000000000000000000000..8a1e6035855eea8b35003ff37047ac4bb1b01f06
--- /dev/null
+++ b/inc/ServicePool.hpp
@@ -0,0 +1,49 @@
+#ifndef ECSS_SERVICES_SERVICEPOOL_HPP
+#define ECSS_SERVICES_SERVICEPOOL_HPP
+
+#include "Services/RequestVerificationService.hpp"
+#include "Services/TimeManagementService.hpp"
+#include "Services/EventReportService.hpp"
+#include "Services/EventActionService.hpp"
+#include "Services/ParameterService.hpp"
+#include "Services/TestService.hpp"
+#include "Services/MemoryManagementService.hpp"
+
+/**
+ * Defines a class that contains instances of all Services.
+ *
+ * All Services should be stored here and should not be instantiated in a different way.
+ *
+ * @todo Find a way to disable services which are not used
+ */
+class ServicePool {
+public:
+ RequestVerificationService requestVerification;
+ EventReportService eventReport;
+ MemoryManagementService memoryManagement;
+ TimeManagementService timeManagement;
+ EventActionService eventAction;
+ TestService testService;
+ ParameterService parameterManagement;
+
+ /**
+ * The default ServicePool constructor
+ */
+ ServicePool() = default;
+
+ /**
+ * Reset all the services and their contents/properties to the original values
+ *
+ * @note This performs the reset in-place, i.e. no new memory is allocated. As such, all
+ * Services already stored as values will point to the "new" Services after a reset.
+ */
+ void reset();
+};
+
+/**
+ * A global variable that defines the basic pool where services can be fetched from
+ */
+extern ServicePool Services;
+
+
+#endif //ECSS_SERVICES_SERVICEPOOL_HPP
diff --git a/inc/Services/ParameterService.hpp b/inc/Services/ParameterService.hpp
index c331ae2743d7ffbd4e137d043889515f491d0372..5672b3c6bbbc9cca8983937c075f43dae6b733d2 100644
--- a/inc/Services/ParameterService.hpp
+++ b/inc/Services/ParameterService.hpp
@@ -2,9 +2,11 @@
#define ECSS_SERVICES_PARAMETERSERVICE_HPP
#include "Service.hpp"
-// #include "Services/RequestVerificationService.hpp"
+#include "ErrorHandler.hpp"
+#include "etl/map.h"
-#define CONFIGLENGTH 5
+// Number of stored parameters. MAX_PARAMS is just a dummy number for now.
+#define MAX_PARAMS 5
/**
* Implementation of the ST[20] parameter management service,
@@ -18,10 +20,11 @@
* PTC and PFC for each parameter shall be specified as in
* ECSS-E-ST-70-41C, chapter 7.3
*/
+
+typedef uint16_t ParamId; // parameter IDs are given sequentially
struct Parameter {
uint8_t ptc; // Packet field type code (PTC)
uint8_t pfc; // Packet field format code (PFC)
- uint16_t paramId; // Unique ID of the parameter
uint32_t settingData;
// Actual data defining the operation of a peripheral or subsystem.
@@ -34,14 +37,15 @@ struct Parameter {
* Holds the list with the parameters and provides functions
* for parameter reporting and modification.
*
- * @todo Ensure that the parameter list is sorted by ID
+ * The parameter list is stored in a map with the parameter IDs as keys and values
+ * corresponding Parameter structs containing the PTC, PFC and the parameter's value.
*/
+
class ParameterService : public Service {
private:
- Parameter paramsList[CONFIGLENGTH];
- // CONFIGLENGTH is just a dummy number for now, this should be statically set
- static uint16_t numOfValidIds(Message idMsg); //count the valid ids in a given TC[20, 1]
+ etl::map<ParamId, Parameter, MAX_PARAMS> paramsList;
+ uint16_t numOfValidIds(Message idMsg); //count the valid ids in a given TC[20, 1]
public:
/**
@@ -54,14 +58,14 @@ public:
* containing the current configuration
* **for the parameters specified in the carried valid IDs**.
*
- * No sophisticated error checking for now, just whether the package is of the correct type
- * and whether the requested IDs are valid, ignoring the invalid ones. If no IDs are correct,
- * the returned message shall be empty.
+ * No sophisticated error checking for now, just whether the packet is of the correct type
+ * and whether the requested IDs are valid, ignoring the invalid ones.
+ * If the packet has an incorrect header, an InternalError::UnacceptablePacket is raised.
+ * If no IDs are correct, the returned message shall be empty.
*
* @param paramId: a valid TC[20, 1] packet carrying the requested parameter IDs
* @return None (messages are stored using storeMessage())
*
- * @todo Generate failure notifs where needed when ST[01] is ready
*
* NOTES:
* Method for valid ID counting is a hack (clones the message and figures out the number
@@ -69,7 +73,7 @@ public:
*
* Everything apart from the setting data is uint16 (setting data are uint32 for now)
*/
- void reportParameterIds(Message paramIds);
+ void reportParameterIds(Message& paramIds);
/**
* This function receives a TC[20, 3] message and after checking whether its type is correct,
@@ -79,10 +83,9 @@ public:
* @param newParamValues: a valid TC[20, 3] message carrying parameter ID and replacement value
* @return None
*
- * @todo Generate failure notifications where needed (eg. when an invalid ID is encountered)
* @todo Use pointers for changing and storing addresses to comply with the standard
*/
- void setParameterIds(Message newParamValues);
+ void setParameterIds(Message& newParamValues);
};
diff --git a/inc/Services/RequestVerificationService.hpp b/inc/Services/RequestVerificationService.hpp
index 3f78f83b369b33b73269488b6f70451044f6c729..683b74d2b0ebe64e5c14021685e13a830b119fa2 100644
--- a/inc/Services/RequestVerificationService.hpp
+++ b/inc/Services/RequestVerificationService.hpp
@@ -132,12 +132,6 @@ public:
* subservices. More arguments are needed.
*/
void execute(const Message &message);
-
- /**
- * The purpose of this instance is to access the execute function of this service when a
- * MessageParser object is created
- */
- static RequestVerificationService instance;
};
diff --git a/inc/Services/TestService.hpp b/inc/Services/TestService.hpp
index f06be9693ff82a88faa69ae2b4c1f86a5760a2cf..937c1b97888e3ce1eb84f643b0dc34bd110329bc 100644
--- a/inc/Services/TestService.hpp
+++ b/inc/Services/TestService.hpp
@@ -32,12 +32,6 @@ public:
* @todo Error handling for the switch() in the implementation of this execute function
*/
void execute(Message &message);
-
- /**
- * The purpose of this instance is to access the execute function of this service when a
- * MessageParser object is created
- */
- static TestService instance;
};
diff --git a/inc/Services/TimeManagementService.hpp b/inc/Services/TimeManagementService.hpp
index d006a5d712b27ffc0218ef31dee469d5bb7d411a..d50b0f74bd9d188183c6704a80c969f64159453c 100644
--- a/inc/Services/TimeManagementService.hpp
+++ b/inc/Services/TimeManagementService.hpp
@@ -1,20 +1,33 @@
#ifndef ECSS_SERVICES_TIMEMANAGEMENTSERVICE_HPP
#define ECSS_SERVICES_TIMEMANAGEMENTSERVICE_HPP
+
#include <Service.hpp>
-#include <ctime>
#include "Helpers/TimeHelper.hpp"
/**
- * Implementation of the ST[09] time management. The current implementation sends
- * a report with the spacecraft time that is formatted according to the CUC time code format
- * (check TimeHelper for the format)
+ * Implementation of the ST[09] time management.
+ *
+ * @notes
+ * There is a noticeable difference between setting the time using GPS and setting the time
+ * using space packets from the ground segment. The GPS module sends the actual time of UTC (123519
+ * is 12:35:19 UTC), while space packets, for time configuration, sends the elapsed time units
+ * (seconds, days depends on the time format) from a specific epoch (1 January 1958 00:00:00). Time
+ * updates using GPS have nothing to do with this service, but for consistency and simplicity we
+ * are trying to set the time with a common way independently of the time source. This is also
+ * the reason that we chose CDS time format (because it is UTC based, check class `TimeHelper`)
+ *
+ * About the GPS receiver, we assume that it outputs NMEA (message format) data
*
+ * @todo check if we need to follow the standard for time-management or we should send the time-data
+ * like GPS
+ * @todo check if the final GPS receiver support NMEA protocol
* @todo When the time comes for the application processes we should consider this: All reports
* generated by the application process that is identified by APID 0 are time reports
* @todo Declare the time accuracy that the standard claims in the spacecraft
- * time reference section(6.9.3.d,e)
+ * time reference section (6.9.3.d,e)
*/
+
class TimeManagementService : public Service {
public:
TimeManagementService() {
@@ -22,15 +35,33 @@ public:
}
/**
- * TM[9,2] CUC time report
+ * TM[9,3] CDS time report.
+ *
+ * This function sends reports with the spacecraft time that is formatted according to the CDS
+ * time code format (check class `TimeHelper` for the format)
*
+ * @param TimeInfo the time information/data from the RTC (UTC format)
* @todo check if we need spacecraft time reference status
* @todo ECSS standard claims: <<The time reports generated by the time reporting subservice
* are spacecraft time packets. A spacecraft time packet does not carry the message type,
* consisting of the service type and message subtype.>> Check if we need to implement that
* or should ignore the standard?
*/
- void cucTimeReport();
+
+ void cdsTimeReport(TimeAndDate &TimeInfo);
+
+ /**
+ * TC[9,128] CDS time request.
+ *
+ * This function is a custom subservice (mission specific) with message type 128 (as defined
+ * from the standard for custom message types, 5.3.3.1.f) and it parses the data of the
+ * time-management telecommand packet. This data is formatted according to the CDS time code
+ * format (check class `TimeHelper` for the format)
+ *
+ * @param message the message that will be parsed for its time-data. The data of the \p message
+ * should be a fixed size of 48 bits
+ */
+ TimeAndDate cdsTimeRequest(Message &message);
};
diff --git a/src/ErrorHandler.cpp b/src/ErrorHandler.cpp
index d62eadd5025efb6ecbaa252def3a664ef1a8f55b..a2f20e7703087577a6b9c1818d75e7618cced2cf 100644
--- a/src/ErrorHandler.cpp
+++ b/src/ErrorHandler.cpp
@@ -1,70 +1,45 @@
#include <iostream>
#include <cxxabi.h>
#include <ErrorHandler.hpp>
+#include <ServicePool.hpp>
#include "Services/RequestVerificationService.hpp"
-// TODO: Use service singleton, as soon as singletons are ready
-static RequestVerificationService requestVerificationService;
-
template<>
void ErrorHandler::reportError(const Message &message, AcceptanceErrorType errorCode) {
- requestVerificationService.failAcceptanceVerification(message, errorCode);
+ Services.requestVerification.failAcceptanceVerification(message, errorCode);
logError(message, errorCode);
}
template<>
void ErrorHandler::reportError(const Message &message, ExecutionStartErrorType errorCode) {
- requestVerificationService.failStartExecutionVerification(message, errorCode);
+ Services.requestVerification.failStartExecutionVerification(message, errorCode);
logError(message, errorCode);
}
void ErrorHandler::reportProgressError(const Message &message, ExecutionProgressErrorType
errorCode, uint8_t stepID) {
- requestVerificationService.failProgressExecutionVerification(message, errorCode, stepID);
+ Services.requestVerification.failProgressExecutionVerification(message, errorCode, stepID);
logError(message, errorCode);
}
template<>
void ErrorHandler::reportError(const Message &message, ExecutionCompletionErrorType errorCode) {
- requestVerificationService.failCompletionExecutionVerification(message, errorCode);
+ Services.requestVerification.failCompletionExecutionVerification(message, errorCode);
logError(message, errorCode);
}
template<>
void ErrorHandler::reportError(const Message &message, RoutingErrorType errorCode) {
- requestVerificationService.failRoutingVerification(message, errorCode);
+ Services.requestVerification.failRoutingVerification(message, errorCode);
logError(message, errorCode);
}
void ErrorHandler::reportInternalError(ErrorHandler::InternalErrorType errorCode) {
- logError(UnknownInternalError);
-}
-
-template<typename ErrorType>
-void ErrorHandler::logError(const Message &message, ErrorType errorType) {
- std::cerr
- /*
- * Gets the error class name from the template
- * Note: This is g++-dependent code and should only be used for debugging.
- */
- << abi::__cxa_demangle(typeid(ErrorType).name(), nullptr, nullptr, nullptr)
- << " Error " << "[" << static_cast<uint16_t>(message.serviceType) << "," <<
- static_cast<uint16_t>(message.messageType) << "]: " << errorType << std::endl;
-}
-
-template<typename ErrorType>
-void ErrorHandler::logError(ErrorType errorType) {
- std::cerr
- /*
- * Gets the error class name from the template
- * Note: This is g++-dependent code and should only be used for debugging.
- */
- << abi::__cxa_demangle(typeid(ErrorType).name(), nullptr, nullptr, nullptr)
- << " Error: " << errorType << std::endl;
+ logError(errorCode);
}
diff --git a/src/Helpers/CRCHelper.cpp b/src/Helpers/CRCHelper.cpp
index e0cd4ebf914ff885c7f50a52aeec4cd3e42c8da8..8361455071673204dcaa88ab4c3f136615127fdf 100644
--- a/src/Helpers/CRCHelper.cpp
+++ b/src/Helpers/CRCHelper.cpp
@@ -9,7 +9,7 @@ uint16_t CRCHelper::calculateCRC(const uint8_t* message, uint32_t length) {
// CRC16-CCITT generator polynomial (as specified in standard)
uint16_t polynomial = 0x1021u;
- for (int i = 0; i < length; i++) {
+ for (uint32_t i = 0; i < length; i++) {
// "copy" (XOR w/ existing contents) the current msg bits into the MSB of the shift register
shiftReg ^= (message[i] << 8u);
diff --git a/src/Helpers/TimeAndDate.cpp b/src/Helpers/TimeAndDate.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..d0a5fc7d937744663c501f3c54b7329cbe1ffa29
--- /dev/null
+++ b/src/Helpers/TimeAndDate.cpp
@@ -0,0 +1,171 @@
+#include "Helpers/TimeHelper.hpp"
+
+
+TimeAndDate::TimeAndDate() {
+ // Unix epoch 1/1/1970
+ year = 1970;
+ month = 1;
+ day = 1;
+ hour = 0;
+ minute = 0;
+ second = 0;
+}
+
+TimeAndDate::TimeAndDate(uint16_t year, uint8_t month, uint8_t day, uint8_t hour, uint8_t minute,
+ uint8_t second) {
+ // check if the parameters make sense
+ assertI(2019 <= year, ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(1 <= month && month <= 12, ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(1 <= day && day <= 31, ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(0 <= hour && hour <= 24, ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(0 <= minute && minute <= 60, ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(0 <= second && second <= 60, ErrorHandler::InternalErrorType::InvalidDate);
+
+ this->year = year;
+ this->month = month;
+ this->hour = hour;
+ this->day = day;
+ this->minute = minute;
+ this->second = second;
+}
+
+bool TimeAndDate::operator<(const TimeAndDate &Date) {
+ // compare years
+ if (this->year < Date.year) {
+ return true;
+ }
+ if (this->year > Date.year) {
+ return false;
+ }
+
+ // compare months
+ if (this->month < Date.month) {
+ return true;
+ }
+ if (this->month > Date.month) {
+ return false;
+ }
+
+ // compare days
+ if (this->day < Date.day) {
+ return true;
+ }
+ if (this->day > Date.day) {
+ return false;
+ }
+
+ // compare hours
+ if (this->hour < Date.hour) {
+ return true;
+ }
+ if (this->hour > Date.hour) {
+ return false;
+ }
+
+ // compare minutes
+ if (this->minute < Date.minute) {
+ return true;
+ }
+ if (this->minute > Date.minute) {
+ return false;
+ }
+
+ // compare seconds
+ if (this->second < Date.second) {
+ return true;
+ }
+
+ return false;
+}
+
+bool TimeAndDate::operator>(const TimeAndDate &Date) {
+ // compare years
+ if (this->year > Date.year) {
+ return true;
+ }
+ if (this->year < Date.year) {
+ return false;
+ }
+
+ // compare months
+ if (this->month > Date.month) {
+ return true;
+ }
+ if (this->month < Date.month) {
+ return false;
+ }
+
+ // compare days
+ if (this->day > Date.day) {
+ return true;
+ }
+ if (this->day < Date.day) {
+ return false;
+ }
+
+ // compare hours
+ if (this->hour > Date.hour) {
+ return true;
+ }
+ if (this->hour < Date.hour) {
+ return false;
+ }
+
+ // compare minutes
+ if (this->minute > Date.minute) {
+ return true;
+ }
+ if (this->minute < Date.minute) {
+ return false;
+ }
+
+ // compare seconds
+ if (this->second > Date.second) {
+ return true;
+ }
+
+ return false;
+}
+
+bool TimeAndDate::operator==(const TimeAndDate &Date) {
+ // compare years
+ if (this->year != Date.year) {
+ return false;
+ }
+
+ // compare months
+ if (this->month != Date.month) {
+ return false;
+ }
+
+ // compare days
+ if (this->day != Date.day) {
+ return false;
+ }
+
+ // compare hours
+ if (this->hour != Date.hour) {
+ return false;
+ }
+
+ // compare minutes
+ if (this->minute != Date.minute) {
+ return false;
+ }
+
+ // compare seconds
+ if (this->second != Date.second) {
+ return false;
+ }
+
+ return true;
+}
+
+
+bool TimeAndDate::operator<=(const TimeAndDate &Date) {
+ return (*this < Date || *this == Date);
+}
+
+bool TimeAndDate::operator>=(const TimeAndDate &Date) {
+ return (*this > Date || *this == Date);
+}
diff --git a/src/Helpers/TimeHelper.cpp b/src/Helpers/TimeHelper.cpp
index 462c7e8b35ea06bfe440f84b7e3e568e2a7891d2..93aa1cae95a557edad4a7e17dabbbecfe846cbfb 100644
--- a/src/Helpers/TimeHelper.cpp
+++ b/src/Helpers/TimeHelper.cpp
@@ -1,43 +1,135 @@
#include "Helpers/TimeHelper.hpp"
-uint64_t TimeHelper::implementCUCTimeFormat(uint32_t seconds) {
- // the total number of octets including the P-field (1 octet) and T-field(4 octets) is 5
-
- // define the P-field
- const uint8_t bit0 = 0; // P-field extension(‘zero’: no extension, ‘one’: field is extended)
- const uint8_t bits1_3 = 1; // Time code identification ( 001 -> 1958 January 1 epoch )
- const uint8_t bits4_5 = 4 - 1; // Number of octets of the basic time unit minus one
- const uint8_t bits6_7 = 0; // Number of octets of the fractional time unit
- const uint8_t pField = (bits6_7 << 6 | bits4_5 << 4 | bits1_3 << 1 | bit0);
-
- // just a reminder to be careful with the assigned values
- static_assert(bit0 < 2);
- static_assert(bits1_3 < 16);
- static_assert(bits4_5 < 4);
- static_assert(bits6_7 < 4);
+bool TimeHelper::IsLeapYear(uint16_t year) {
+ if (year % 4 != 0) {
+ return false;
+ }
+ if (year % 100 != 0) {
+ return true;
+ }
+ return (year % 400) == 0;
+}
+
+uint32_t TimeHelper::utcToSeconds(TimeAndDate &TimeInfo) {
+ // the date, that \p TimeInfo represents, should be greater than or equal to 1/1/2019 and the
+ // date should be valid according to Gregorian calendar
+ assertI(TimeInfo.year >= 2019, ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(1 <= TimeInfo.month && TimeInfo.month <= 12,
+ ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(1 <= TimeInfo.day && TimeInfo.day <= 31,
+ ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(0 <= TimeInfo.hour && TimeInfo.hour <= 24,
+ ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(0 <= TimeInfo.minute && TimeInfo.minute <= 60,
+ ErrorHandler::InternalErrorType::InvalidDate);
+ assertI(0 <= TimeInfo.second && TimeInfo.second <= 60,
+ ErrorHandler::InternalErrorType::InvalidDate);
+
+ uint32_t secs = 1546300800; // elapsed seconds from Unix epoch until 1/1/2019 00:00:00 (UTC)
+ for (uint16_t y = 2019; y < TimeInfo.year; ++y) {
+ secs += (IsLeapYear(y) ? 366 : 365) * SECONDS_PER_DAY;
+ }
+ for (uint16_t m = 1; m < TimeInfo.month; ++m) {
+ secs += DaysOfMonth[m - 1] * SECONDS_PER_DAY;
+ if (m == 2 && IsLeapYear(TimeInfo.year)) {
+ secs += SECONDS_PER_DAY;
+ }
+ }
+ secs += (TimeInfo.day - 1) * SECONDS_PER_DAY;
+ secs += TimeInfo.hour * SECONDS_PER_HOUR;
+ secs += TimeInfo.minute * SECONDS_PER_MINUTE;
+ secs += TimeInfo.second;
+ return secs;
+}
+
+struct TimeAndDate TimeHelper::secondsToUTC(uint32_t seconds) {
+ // elapsed seconds should be between dates, that are after 1/1/2019 and Unix epoch
+ assertI(seconds >= 1546300800, ErrorHandler::InternalErrorType::InvalidDate);
+
+ seconds -= 1546300800; // elapsed seconds from Unix epoch until 1/1/2019 00:00:00 (UTC)
+ TimeAndDate TimeInfo;
+ TimeInfo.year = 2019;
+ TimeInfo.month = 1;
+ TimeInfo.day = 0;
+ TimeInfo.hour = 0;
+ TimeInfo.minute = 0;
+ TimeInfo.second = 0;
+
+ // calculate years
+ while (seconds >= (IsLeapYear(TimeInfo.year) ? 366 : 365) * SECONDS_PER_DAY) {
+ seconds -= (IsLeapYear(TimeInfo.year) ? 366 : 365) * SECONDS_PER_DAY;
+ TimeInfo.year++;
+ }
+
+ // calculate months
+ uint8_t i = 0;
+ while (seconds >= (DaysOfMonth[i] * SECONDS_PER_DAY)) {
+ TimeInfo.month++;
+ seconds -= (DaysOfMonth[i] * SECONDS_PER_DAY);
+ i++;
+ if (i == 1 && IsLeapYear(TimeInfo.year)) {
+ if (seconds <= (28 * SECONDS_PER_DAY)) {
+ break;
+ }
+ TimeInfo.month++;
+ seconds -= 29 * SECONDS_PER_DAY;
+ i++;
+ }
+ }
+
+ // calculate days
+ TimeInfo.day = seconds / SECONDS_PER_DAY;
+ seconds -= TimeInfo.day * SECONDS_PER_DAY;
+ TimeInfo.day++; // add 1 day because we start count from 1 January (and not 0 January!)
+
+ // calculate hours
+ TimeInfo.hour = seconds / SECONDS_PER_HOUR;
+ seconds -= TimeInfo.hour * SECONDS_PER_HOUR;
+
+ // calculate minutes
+ TimeInfo.minute = seconds / SECONDS_PER_MINUTE;
+ seconds -= TimeInfo.minute * SECONDS_PER_MINUTE;
+
+ // calculate seconds
+ TimeInfo.second = seconds;
+ return TimeInfo;
+}
+
+uint64_t TimeHelper::generateCDStimeFormat(TimeAndDate &TimeInfo) {
/**
- * Define the T-field, the seconds passed from the defined epoch 1 January 1958
- * We use 4 octets(32 bits) for the time unit(seconds) because 32 bits for the seconds are
- * enough to count 136 years! But if we use 24 bits for the seconds then it will count 0,5
- * years and this isn't enough. Remember we can use only integers numbers of octets for the
- * time unit(second)
- *
- * @todo the implementation of the total seconds depends on the structure of the RTC
+ * Define the T-field. The total number of octets for the implementation of T-field is 6(2 for
+ * the `DAY` and 4 for the `ms of day`
*/
- uint32_t totalSeconds = seconds;
+
+ uint32_t seconds = utcToSeconds(TimeInfo);
/**
- * Define time format including P-field and T-Field
- *
- * Notes:
- * Only the 40 bits of the 64 will be used for the timeFormat(0-7 : P-field, 8-39: T-field)
- *
- * Shift operators have high priority. That's why we should do a type-casting first so we
- * don't lose valuable bits
- */
- uint64_t timeFormat = (static_cast<uint64_t>(totalSeconds) << 8 | pField);
+ * The `DAY` segment, 16 bits as defined from standard. Actually the days passed since Unix
+ * epoch
+ */
+ auto elapsedDays = static_cast<uint16_t>(seconds / SECONDS_PER_DAY);
+ /**
+ * The `ms of day` segment, 32 bits as defined in standard. The `ms of the day` and DAY`
+ * should give the time passed since Unix epoch
+ */
+ auto msOfDay = static_cast<uint32_t >((seconds % SECONDS_PER_DAY) * 1000);
+
+ uint64_t timeFormat = (static_cast<uint64_t>(elapsedDays) << 32 | msOfDay);
return timeFormat;
}
+
+TimeAndDate TimeHelper::parseCDStimeFormat(const uint8_t *data) {
+ uint16_t elapsedDays = (static_cast<uint16_t >(data[0])) << 8 | static_cast<uint16_t >
+ (data[1]);
+ uint32_t msOfDay = (static_cast<uint32_t >(data[2])) << 24 |
+ (static_cast<uint32_t >(data[3])) << 16 |
+ (static_cast<uint32_t >(data[4])) << 8 |
+ static_cast<uint32_t >(data[5]);
+
+ uint32_t seconds = elapsedDays * SECONDS_PER_DAY + msOfDay / 1000;
+
+ return secondsToUTC(seconds);
+}
diff --git a/src/MessageParser.cpp b/src/MessageParser.cpp
index 141fcc7ecc8b309a73861cc30a1b8a2f8c254538..13ea653f94810e69ffe062882c6d9afec3d1942d 100644
--- a/src/MessageParser.cpp
+++ b/src/MessageParser.cpp
@@ -1,20 +1,19 @@
#include <Services/EventActionService.hpp>
+#include <ServicePool.hpp>
#include "ErrorHandler.hpp"
#include "MessageParser.hpp"
#include "macros.hpp"
#include "Services/TestService.hpp"
#include "Services/RequestVerificationService.hpp"
-TestService TestService::instance;
-RequestVerificationService RequestVerificationService::instance;
void MessageParser::execute(Message &message) {
switch (message.serviceType) {
case 1:
- RequestVerificationService::instance.execute(message);
+ Services.requestVerification.execute(message);
break;
case 17:
- TestService::instance.execute(message);
+ Services.testService.execute(message);
break;
default:
ErrorHandler::reportInternalError(ErrorHandler::UnknownMessageType);
diff --git a/src/Platform/x86/ErrorHandler.cpp b/src/Platform/x86/ErrorHandler.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..6119440cc09527624c64a4adc517e7d6c551e7ee
--- /dev/null
+++ b/src/Platform/x86/ErrorHandler.cpp
@@ -0,0 +1,40 @@
+/**
+ * This file specifies the logging utilities for x86 desktop platforms. These logging functions
+ * just print the error to screen (via stderr).
+ */
+
+#include <iostream>
+#include <cxxabi.h>
+#include <ErrorHandler.hpp>
+#include <Message.hpp>
+
+// TODO: Find a way to reduce the number of copies of this chunk
+template void ErrorHandler::logError(const Message &, ErrorHandler::AcceptanceErrorType);
+template void ErrorHandler::logError(const Message &, ErrorHandler::ExecutionStartErrorType);
+template void ErrorHandler::logError(const Message &, ErrorHandler::ExecutionProgressErrorType);
+template void ErrorHandler::logError(const Message &, ErrorHandler::ExecutionCompletionErrorType);
+template void ErrorHandler::logError(const Message &, ErrorHandler::RoutingErrorType);
+template void ErrorHandler::logError(ErrorHandler::InternalErrorType);
+
+template<typename ErrorType>
+void ErrorHandler::logError(const Message &message, ErrorType errorType) {
+ std::cerr
+ /*
+ * Gets the error class name from the template
+ * Note: This is g++-dependent code and should only be used for debugging.
+ */
+ << abi::__cxa_demangle(typeid(ErrorType).name(), nullptr, nullptr, nullptr)
+ << " Error " << "[" << static_cast<uint16_t>(message.serviceType) << "," <<
+ static_cast<uint16_t>(message.messageType) << "]: " << errorType << std::endl;
+}
+
+template<typename ErrorType>
+void ErrorHandler::logError(ErrorType errorType) {
+ std::cerr
+ /*
+ * Gets the error class name from the template
+ * Note: This is g++-dependent code and should only be used for debugging.
+ */
+ << abi::__cxa_demangle(typeid(ErrorType).name(), nullptr, nullptr, nullptr)
+ << " Error: " << errorType << std::endl;
+}
diff --git a/src/ServicePool.cpp b/src/ServicePool.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..f76e2ee77d066b475c0678baec2159ad3dc1a246
--- /dev/null
+++ b/src/ServicePool.cpp
@@ -0,0 +1,14 @@
+#include "ServicePool.hpp"
+
+ServicePool Services = ServicePool();
+
+void ServicePool::reset() {
+ // Call the destructor
+ this->~ServicePool();
+
+ // Call the constructor
+ // Note the usage of "placement new" that replaces the contents of the Services variable.
+ // This is not dangerous usage, since all the memory that will be used for this has been
+ // statically allocated from before.
+ new (this) ServicePool();
+}
diff --git a/src/Services/MemoryManagementService.cpp b/src/Services/MemoryManagementService.cpp
index f904291c44b171161064a131300c79847b785346..ebb58a115bf2f7a3779708d47f9037ac16f42871 100644
--- a/src/Services/MemoryManagementService.cpp
+++ b/src/Services/MemoryManagementService.cpp
@@ -15,7 +15,7 @@ MemoryManagementService::RawDataMemoryManagement::RawDataMemoryManagement(
// Function declarations for the raw data memory management subservice
void MemoryManagementService::RawDataMemoryManagement::loadRawData(Message &request) {
/**
- * Bare in mind that there is currently no error checking for invalid parameters.
+ * Bear in mind that there is currently no error checking for invalid parameters.
* A future version will include error checking and the corresponding error report/notification,
* as the manual implies.
*
diff --git a/src/Services/ParameterService.cpp b/src/Services/ParameterService.cpp
index bf19881992e6265b8254ae0c09bc118a665a780f..dd0f4c7495d4b925feb1355fe8808415043450c2 100644
--- a/src/Services/ParameterService.cpp
+++ b/src/Services/ParameterService.cpp
@@ -2,13 +2,9 @@
#define DEMOMODE
-#ifdef DEMOMODE
-
#include <ctime>
#include <cstdlib>
-#endif
-
ParameterService::ParameterService() {
#ifdef DEMOMODE
// Test code, setting up some of the parameter fields
@@ -16,56 +12,85 @@ ParameterService::ParameterService() {
time_t currTime = time(nullptr);
struct tm *today = localtime(&currTime);
- paramsList[0].paramId = 0; // random parameter ID
- paramsList[0].settingData = today->tm_hour; // the current hour
- paramsList[0].ptc = 3; // unsigned int
- paramsList[0].pfc = 14; // 32 bits
+ Parameter test1, test2;
+
+ test1.settingData = today->tm_hour; // the current hour
+ test1.ptc = 3; // unsigned int
+ test1.pfc = 14; // 32 bits
+
+ test2.settingData = today->tm_min; // the current minute
+ test2.ptc = 3; // unsigned int
+ test2.pfc = 14; // 32 bits
+
+ // MAKE SURE THE IDS ARE UNIQUE WHEN INSERTING!
+ /**
+ * @todo: Make a separate insert() function for parameter insertion to protect from blunders
+ * if needed to
+ */
+
+ paramsList.insert(std::make_pair(0, test1));
+ paramsList.insert(std::make_pair(1, test2));
- paramsList[1].paramId = 1; // random parameter ID
- paramsList[1].settingData = today->tm_min; // the current minute
- paramsList[1].ptc = 3; // unsigned int
- paramsList[1].pfc = 14; // 32 bits
#endif
}
-void ParameterService::reportParameterIds(Message paramIds) {
+void ParameterService::reportParameterIds(Message& paramIds) {
Message reqParam(20, 2, Message::TM, 1); // empty TM[20, 2] parameter report message
- if (paramIds.packetType == Message::TC && paramIds.serviceType == 20 &&
- paramIds.messageType == 1) {
- uint16_t ids = paramIds.readUint16();
- reqParam.appendUint16(numOfValidIds(paramIds)); // include the number of valid IDs
-
- for (int i = 0; i < ids; i++) {
- uint16_t currId = paramIds.readUint16(); // current ID to be appended
-
- if (currId < CONFIGLENGTH) { // check to prevent out-of-bounds access due to invalid id
- reqParam.appendUint16(currId);
- reqParam.appendUint32(paramsList[currId].settingData);
- } else {
- // generate failure of execution notification for ST[06]
- continue; //ignore the invalid ID
- }
+ paramIds.resetRead(); // since we're passing a reference, the reading position shall be reset
+ // to its default before any read operations (to ensure the correct data is being read)
+
+ // assertion: correct message, packet and service type (at failure throws an
+ // InternalError::UnacceptablePacket)
+ ErrorHandler::assertRequest(paramIds.packetType == Message::TC, paramIds,
+ ErrorHandler::AcceptanceErrorType::UnacceptableMessage);
+ ErrorHandler::assertRequest(paramIds.messageType == 1, paramIds,
+ ErrorHandler::AcceptanceErrorType::UnacceptableMessage);
+ ErrorHandler::assertRequest(paramIds.serviceType == 20, paramIds,
+ ErrorHandler::AcceptanceErrorType::UnacceptableMessage);
+
+ uint16_t ids = paramIds.readUint16();
+ reqParam.appendUint16(numOfValidIds(paramIds)); // include the number of valid IDs
+
+ for (int i = 0; i < ids; i++) {
+ uint16_t currId = paramIds.readUint16(); // current ID to be appended
+
+ if (paramsList.find(currId) != paramsList.end()) {
+ reqParam.appendUint16(currId);
+ reqParam.appendUint32(paramsList[currId].settingData);
+ } else {
+ ErrorHandler::reportError(paramIds,
+ ErrorHandler::ExecutionStartErrorType::UnknownExecutionStartError);
+ continue; // generate failed start of execution notification & ignore
}
}
storeMessage(reqParam);
}
-void ParameterService::setParameterIds(Message newParamValues) {
- if (newParamValues.packetType == Message::TC && newParamValues.serviceType == 20 &&
- newParamValues.messageType == 3) {
- uint16_t ids = newParamValues.readUint16(); //get number of ID's
+void ParameterService::setParameterIds(Message& newParamValues) {
- for (int i = 0; i < ids; i++) {
- uint16_t currId = newParamValues.readUint16();
+ // assertion: correct message, packet and service type (at failure throws an
+ // InternalError::UnacceptablePacket which gets logged)
- if (currId < CONFIGLENGTH) {
- paramsList[currId].settingData = newParamValues.readUint32();
- } else {
- // generate failure of execution notification for ST[06]
- continue; // ignore the invalid ID
- }
+ ErrorHandler::assertRequest(newParamValues.packetType == Message::TC, newParamValues,
+ ErrorHandler::AcceptanceErrorType::UnacceptableMessage);
+ ErrorHandler::assertRequest(newParamValues.messageType == 3, newParamValues,
+ ErrorHandler::AcceptanceErrorType::UnacceptableMessage);
+ ErrorHandler::assertRequest(newParamValues.serviceType == 20, newParamValues,
+ ErrorHandler::AcceptanceErrorType::UnacceptableMessage);
+
+ uint16_t ids = newParamValues.readUint16(); //get number of ID's
+
+ for (int i = 0; i < ids; i++) {
+ uint16_t currId = newParamValues.readUint16();
+
+ if (paramsList.find(currId) != paramsList.end()) {
+ paramsList[currId].settingData = newParamValues.readUint32();
+ } else {
+ ErrorHandler::reportError(newParamValues,
+ ErrorHandler::ExecutionStartErrorType::UnknownExecutionStartError);
+ continue; // generate failed start of execution notification & ignore
}
}
}
@@ -85,7 +110,7 @@ uint16_t ParameterService::numOfValidIds(Message idMsg) {
idMsg.readUint32(); //skip the 32bit settings blocks, we need only the IDs
}
- if (currId < CONFIGLENGTH) {
+ if (paramsList.find(currId) != paramsList.end()) {
validIds++;
}
}
diff --git a/src/Services/TimeManagementService.cpp b/src/Services/TimeManagementService.cpp
index 2b3feb68aa059b7131863d84cd2d6e79d8328fa1..70c89dba2ec097f2d332bcfd2371550bcab9e03c 100644
--- a/src/Services/TimeManagementService.cpp
+++ b/src/Services/TimeManagementService.cpp
@@ -1,20 +1,26 @@
#include "Services/TimeManagementService.hpp"
-void TimeManagementService::cucTimeReport() {
- // TM[9,2] CUC time report
+void TimeManagementService::cdsTimeReport(TimeAndDate &TimeInfo) {
+ // TM[9,3] CDS time report
- Message timeReport = createTM(2);
+ Message timeReport = createTM(3);
- /**
- * For the time being we will use C++ functions to get a time value, but this will change
- * when the RTC will be implemented
- */
- uint32_t seconds;
- seconds = time(nullptr); // seconds have passed since 00:00:00 GMT, Jan 1, 1970
- uint64_t timeFormat = TimeHelper::implementCUCTimeFormat(seconds); // store the return value
+ uint64_t timeFormat = TimeHelper::generateCDStimeFormat(TimeInfo);
- timeReport.appendByte(timeFormat); // append the P-field
- timeReport.appendWord(timeFormat >> 8); // append the T-field
+ timeReport.appendHalfword(static_cast<uint16_t >(timeFormat >> 32));
+ timeReport.appendWord(static_cast<uint32_t >(timeFormat));
storeMessage(timeReport);
}
+
+TimeAndDate TimeManagementService::cdsTimeRequest(Message &message) {
+ // TC{9,128] CDS time request
+
+ // check if we have the correct size of the data. The size should be 6 (48 bits)
+ ErrorHandler::assertRequest(message.dataSize == 6, message,
+ ErrorHandler::AcceptanceErrorType::UnacceptableMessage);
+
+ TimeAndDate timeInfo = TimeHelper::parseCDStimeFormat(message.data);
+
+ return timeInfo;
+}
diff --git a/src/main.cpp b/src/main.cpp
index cdbd7c3d106dc8601572996cb79811f55e53efaf..3cbb641d6d5a7b8b97b0af612c7ef8f91912f214 100644
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -1,4 +1,5 @@
#include <iostream>
+#include <ServicePool.hpp>
#include "Helpers/CRCHelper.hpp"
#include "Helpers/TimeHelper.hpp"
#include "Services/TestService.hpp"
@@ -35,7 +36,7 @@ int main() {
std::cout << packet.readFloat() << " " << std::dec << packet.readSint32() << std::endl;
// ST[17] test
- TestService testService;
+ TestService & testService = Services.testService;
Message receivedPacket = Message(17, 1, Message::TC, 1);
testService.areYouAlive(receivedPacket);
receivedPacket = Message(17, 3, Message::TC, 1);
@@ -44,7 +45,7 @@ int main() {
// ST[20] test
- ParameterService paramService;
+ ParameterService & paramService = Services.parameterManagement;
// Test code for reportParameter
Message sentPacket = Message(20, 1, Message::TC, 1); //application id is a dummy number (1)
@@ -72,7 +73,7 @@ int main() {
*(pStr + 1) = 'G';
*(pStr + 2) = '\0';
- MemoryManagementService memMangService;
+ MemoryManagementService & memMangService = Services.memoryManagement;
Message rcvPack = Message(6, 5, Message::TC, 1);
rcvPack.appendEnum8(MemoryManagementService::MemoryID::EXTERNAL); // Memory ID
rcvPack.appendUint16(3); // Iteration count
@@ -112,7 +113,7 @@ int main() {
// ST[01] test
- RequestVerificationService reqVerifService;
+ RequestVerificationService & reqVerifService = Services.requestVerification;
Message receivedMessage = Message(1, 1, Message::TC, 3);
reqVerifService.successAcceptanceVerification(receivedMessage);
@@ -196,14 +197,17 @@ int main() {
errorMessage.appendBits(2, 7);
errorMessage.appendByte(15);
-
- // TimeHelper test
- uint64_t test = TimeHelper::implementCUCTimeFormat(1200);
- std::cout << "\n" << test << "\n";
-
// ST[09] test
- TimeManagementService timeReport;
- timeReport.cucTimeReport();
+ TimeManagementService & timeReport = Services.timeManagement;
+ TimeAndDate timeInfo;
+ // 10/04/1998 10:15:00
+ timeInfo.year = 1998;
+ timeInfo.month = 4;
+ timeInfo.day = 10;
+ timeInfo.hour = 10;
+ timeInfo.minute = 15;
+ timeInfo.second = 0;
+ timeReport.cdsTimeReport(timeInfo);
// ST[05] (5,5 to 5,8) test [works]
EventReportService::Event eventIDs[] = {EventReportService::HighSeverityUnknownEvent,
@@ -226,7 +230,7 @@ int main() {
// ST[19] test
- EventActionService eventActionService;
+ EventActionService & eventActionService = Services.eventAction;
Message eventActionDefinition(19, 1, Message::TC, 1);
eventActionDefinition.appendEnum16(0);
eventActionDefinition.appendEnum16(2);
diff --git a/test/Helpers/TimeAndDate.cpp b/test/Helpers/TimeAndDate.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..44d1c43938ee20b9e2de6f3d040b3dba2b7a07a2
--- /dev/null
+++ b/test/Helpers/TimeAndDate.cpp
@@ -0,0 +1,234 @@
+#include "catch2/catch.hpp"
+#include "Helpers/TimeAndDate.hpp"
+
+
+TEST_CASE("Date comparison", "[operands]") {
+
+ SECTION("Invalid date") {
+ TimeAndDate InvalidDate0(1900, 2, 2, 4, 5, 6); // error in year
+ TimeAndDate InvalidDate1(2030, 70, 2, 4, 5, 6); // error in month
+ TimeAndDate InvalidDate2(2030, 2, 73, 4, 5, 6); // error in day
+ TimeAndDate InvalidDate3(2030, 2, 2, 74, 5, 6); // error in hour
+ TimeAndDate InvalidDate4(2030, 2, 2, 4, 75, 6); // error in minute
+ TimeAndDate InvalidDate5(2030, 2, 2, 4, 5, 76); // error in seconds
+ }
+
+ SECTION("Different year") {
+ TimeAndDate Now;
+ // 10/04/2021 10:15:00
+ Now.year = 2021;
+ Now.month = 4;
+ Now.day = 10;
+ Now.hour = 10;
+ Now.minute = 15;
+ Now.second = 0;
+
+ TimeAndDate Date;
+ // 10/04/2020 10:15:00
+ Date.year = 2020;
+ Date.month = 4;
+ Date.day = 10;
+ Date.hour = 10;
+ Date.minute = 15;
+ Date.second = 0;
+
+ CHECK((Now < Date) == false);
+ CHECK((Now > Date) == true);
+ CHECK((Now > Date) == true);
+ CHECK((Now < Date) == false);
+
+ CHECK((Now <= Date) == false);
+ CHECK((Now >= Date) == true);
+ CHECK((Now >= Date) == true);
+ CHECK((Now <= Date) == false);
+
+ CHECK((Now == Date) == false);
+ }
+
+ SECTION("Different month") {
+
+ TimeAndDate Now;
+ // 10/05/2020 10:15:00
+ Now.year = 2020;
+ Now.month = 5;
+ Now.day = 10;
+ Now.hour = 10;
+ Now.minute = 15;
+ Now.second = 0;
+
+ TimeAndDate Date;
+ // 10/04/2020 10:15:00
+ Date.year = 2020;
+ Date.month = 4;
+ Date.day = 10;
+ Date.hour = 10;
+ Date.minute = 15;
+ Date.second = 0;
+
+ CHECK((Now < Date) == false);
+ CHECK((Now > Date) == true);
+ CHECK((Now > Date) == true);
+ CHECK((Now < Date) == false);
+
+ CHECK((Now <= Date) == false);
+ CHECK((Now >= Date) == true);
+ CHECK((Now >= Date) == true);
+ CHECK((Now <= Date) == false);
+
+ CHECK((Now == Date) == false);
+ }
+
+ SECTION("Different day") {
+ TimeAndDate Now;
+ // 11/04/2020 10:15:00
+ Now.year = 2020;
+ Now.month = 5;
+ Now.day = 11;
+ Now.hour = 10;
+ Now.minute = 15;
+ Now.second = 0;
+
+ TimeAndDate Date;
+ // 10/04/2020 10:15:00
+ Date.year = 2020;
+ Date.month = 4;
+ Date.day = 10;
+ Date.hour = 10;
+ Date.minute = 15;
+ Date.second = 0;
+
+ CHECK((Now < Date) == false);
+ CHECK((Now > Date) == true);
+ CHECK((Now > Date) == true);
+ CHECK((Now < Date) == false);
+
+ CHECK((Now <= Date) == false);
+ CHECK((Now >= Date) == true);
+ CHECK((Now >= Date) == true);
+ CHECK((Now <= Date) == false);
+
+ CHECK((Now == Date) == false);
+ }
+
+ SECTION("Different hour") {
+ TimeAndDate Now;
+ // 10/04/2020 11:15:00
+ Now.year = 2020;
+ Now.month = 4;
+ Now.day = 10;
+ Now.hour = 11;
+ Now.minute = 15;
+ Now.second = 0;
+
+ TimeAndDate Date;
+ // 10/04/2020 10:15:00
+ Date.year = 2020;
+ Date.month = 4;
+ Date.day = 10;
+ Date.hour = 10;
+ Date.minute = 15;
+ Date.second = 0;
+
+ CHECK((Now < Date) == false);
+ CHECK((Now > Date) == true);
+ CHECK((Now > Date) == true);
+ CHECK((Now < Date) == false);
+
+ CHECK((Now <= Date) == false);
+ CHECK((Now >= Date) == true);
+ CHECK((Now >= Date) == true);
+ CHECK((Now <= Date) == false);
+
+ CHECK((Now == Date) == false);
+ }
+
+ SECTION("Different minute") {
+ TimeAndDate Now;
+ // 10/04/2020 10:16:00
+ Now.year = 2020;
+ Now.month = 4;
+ Now.day = 10;
+ Now.hour = 10;
+ Now.minute = 16;
+ Now.second = 0;
+
+ TimeAndDate Date;
+ // 10/04/2020 10:15:00
+ Date.year = 2020;
+ Date.month = 4;
+ Date.day = 10;
+ Date.hour = 10;
+ Date.minute = 15;
+ Date.second = 0;
+
+ CHECK((Now < Date) == false);
+ CHECK((Now > Date) == true);
+ CHECK((Now > Date) == true);
+ CHECK((Now < Date) == false);
+
+ CHECK((Now <= Date) == false);
+ CHECK((Now >= Date) == true);
+ CHECK((Now >= Date) == true);
+ CHECK((Now <= Date) == false);
+
+ CHECK((Now == Date) == false);
+ }
+
+ SECTION("Different second") {
+ TimeAndDate Now;
+ // 10/04/2020 10:15:01
+ Now.year = 2020;
+ Now.month = 4;
+ Now.day = 10;
+ Now.hour = 10;
+ Now.minute = 15;
+ Now.second = 1;
+
+ TimeAndDate Date;
+ // 10/04/2020 10:15:00
+ Date.year = 2020;
+ Date.month = 4;
+ Date.day = 10;
+ Date.hour = 10;
+ Date.minute = 15;
+ Date.second = 0;
+
+ CHECK((Now < Date) == false);
+ CHECK((Now > Date) == true);
+ CHECK((Now > Date) == true);
+ CHECK((Now < Date) == false);
+
+ CHECK((Now <= Date) == false);
+ CHECK((Now >= Date) == true);
+ CHECK((Now >= Date) == true);
+ CHECK((Now <= Date) == false);
+
+ CHECK((Now == Date) == false);
+ }
+
+ SECTION("Same date") {
+ TimeAndDate Now;
+ // 10/04/2020 10:15:01
+ Now.year = 2020;
+ Now.month = 4;
+ Now.day = 10;
+ Now.hour = 10;
+ Now.minute = 15;
+ Now.second = 0;
+
+ TimeAndDate Date;
+ // 10/04/2020 10:15:00
+ Date.year = 2020;
+ Date.month = 4;
+ Date.day = 10;
+ Date.hour = 10;
+ Date.minute = 15;
+ Date.second = 0;
+
+ CHECK((Now == Date) == true);
+ CHECK((Now <= Date) == true);
+ CHECK((Now >= Date) == true);
+ CHECK((Now >= Date) == true);
+ CHECK((Now <= Date) == true);
+ }
+}
diff --git a/test/Helpers/TimeHelper.cpp b/test/Helpers/TimeHelper.cpp
index 0b23a2a05d7bb06a032bbfee1c51f2baa6d2f23d..31fb012da5fff869c06e1305fa6e194b7cf9be0b 100644
--- a/test/Helpers/TimeHelper.cpp
+++ b/test/Helpers/TimeHelper.cpp
@@ -2,9 +2,230 @@
#include "Helpers/TimeHelper.hpp"
TEST_CASE("Time format implementation", "[CUC]") {
- // very simple tests for the TimeHelper
- CHECK(TimeHelper::implementCUCTimeFormat(60) == 0b11110000110010);
- CHECK(TimeHelper::implementCUCTimeFormat(1000) == 0x3E832);
- CHECK(TimeHelper::implementCUCTimeFormat(1200) == 0x4B032);
+ SECTION("Invalid date") {
+ TimeAndDate TimeInfo;
+
+ // invalid year
+ TimeInfo.year = 2018;
+ TimeInfo.month = 4;
+ TimeInfo.day = 10;
+ TimeInfo.hour = 10;
+ TimeInfo.minute = 15;
+ TimeInfo.second = 0;
+
+ TimeHelper time;
+ TimeHelper::utcToSeconds(TimeInfo);
+
+ // invalid month
+ TimeInfo.year = 2018;
+ TimeInfo.month = 60;
+ TimeInfo.day = 10;
+ TimeInfo.hour = 10;
+ TimeInfo.minute = 15;
+ TimeInfo.second = 0;
+
+ TimeHelper::utcToSeconds(TimeInfo);
+
+ // invalid day
+ TimeInfo.year = 2018;
+ TimeInfo.month = 4;
+ TimeInfo.day = 35;
+ TimeInfo.hour = 10;
+ TimeInfo.minute = 15;
+ TimeInfo.second = 0;
+
+ TimeHelper::utcToSeconds(TimeInfo);
+
+ // invalid hour
+ TimeInfo.year = 2018;
+ TimeInfo.month = 4;
+ TimeInfo.day = 10;
+ TimeInfo.hour = 100;
+ TimeInfo.minute = 15;
+ TimeInfo.second = 0;
+
+ TimeHelper::utcToSeconds(TimeInfo);
+
+ // invalid minute
+ TimeInfo.year = 2018;
+ TimeInfo.month = 4;
+ TimeInfo.day = 10;
+ TimeInfo.hour = 10;
+ TimeInfo.minute = 200;
+ TimeInfo.second = 0;
+
+ TimeHelper::utcToSeconds(TimeInfo);
+
+ // invalid second
+ TimeInfo.year = 2018;
+ TimeInfo.month = 4;
+ TimeInfo.day = 10;
+ TimeInfo.hour = 10;
+ TimeInfo.minute = 15;
+ TimeInfo.second = 122;
+
+ TimeHelper::utcToSeconds(TimeInfo);
+ }
+
+ SECTION("Convert UTC date to elapsed seconds since Unix epoch") {
+ TimeAndDate TimeInfo;
+ // 10/04/2020 10:15:00
+ TimeInfo.year = 2020;
+ TimeInfo.month = 4;
+ TimeInfo.day = 10;
+ TimeInfo.hour = 10;
+ TimeInfo.minute = 15;
+ TimeInfo.second = 0;
+
+ TimeHelper time;
+ uint32_t currTime = TimeHelper::utcToSeconds(TimeInfo);
+
+ uint16_t elapsedDays = currTime / 86400;
+ uint32_t msOfDay = currTime % 86400 * 1000;
+ uint64_t timeFormat = (static_cast<uint64_t>(elapsedDays) << 32 | msOfDay);
+ CHECK(TimeHelper::generateCDStimeFormat(TimeInfo) == timeFormat);
+
+ // 1/1/2019 00:00:00
+ TimeInfo.year = 2019;
+ TimeInfo.month = 1;
+ TimeInfo.day = 1;
+ TimeInfo.hour = 0;
+ TimeInfo.minute = 0;
+ TimeInfo.second = 0;
+
+ currTime = TimeHelper::utcToSeconds(TimeInfo);
+
+ elapsedDays = currTime / 86400;
+ msOfDay = currTime % 86400 * 1000;
+ timeFormat = (static_cast<uint64_t>(elapsedDays) << 32 | msOfDay);
+ CHECK(TimeHelper::generateCDStimeFormat(TimeInfo) == timeFormat);
+
+ // 5/12/2020 00:00:00
+ TimeInfo.year = 2020;
+ TimeInfo.month = 12;
+ TimeInfo.day = 5;
+ TimeInfo.hour = 0;
+ TimeInfo.minute = 0;
+ TimeInfo.second = 0;
+
+ currTime = TimeHelper::utcToSeconds(TimeInfo);
+ CHECK(currTime == 1607126400);
+
+ // 10/12/2020 00:00:00
+ TimeInfo.year = 2020;
+ TimeInfo.month = 12;
+ TimeInfo.day = 10;
+ TimeInfo.hour = 0;
+ TimeInfo.minute = 0;
+ TimeInfo.second = 0;
+
+ currTime = TimeHelper::utcToSeconds(TimeInfo);
+ CHECK(currTime == 1607558400);
+
+ // 15/12/2020 00:00:00
+ TimeInfo.year = 2020;
+ TimeInfo.month = 12;
+ TimeInfo.day = 15;
+ TimeInfo.hour = 0;
+ TimeInfo.minute = 0;
+ TimeInfo.second = 0;
+
+ currTime = TimeHelper::utcToSeconds(TimeInfo);
+ CHECK(currTime == 1607990400);
+
+ // 20/12/2020 00:00:00
+ TimeInfo.year = 2020;
+ TimeInfo.month = 12;
+ TimeInfo.day = 20;
+ TimeInfo.hour = 0;
+ TimeInfo.minute = 0;
+ TimeInfo.second = 0;
+
+ currTime = TimeHelper::utcToSeconds(TimeInfo);
+ CHECK(currTime == 1608422400);
+ }
+
+ SECTION("Convert elapsed seconds since Unix epoch to UTC date") {
+ uint32_t seconds = 1586513700; // elapsed seconds between 10/04/2020 10:15:00 and Unix epoch
+
+ TimeHelper time;
+ TimeAndDate TimeInfo = TimeHelper::secondsToUTC(seconds);
+ CHECK(TimeInfo.year == 2020);
+ CHECK(TimeInfo.month == 4);
+ CHECK(TimeInfo.day == 10);
+ CHECK(TimeInfo.hour == 10);
+ CHECK(TimeInfo.minute == 15);
+ CHECK(TimeInfo.second == 0);
+
+ seconds = 1546300800; // elapsed seconds between 1/1/2019 00:00:00 and Unix epoch
+
+ TimeInfo = TimeHelper::secondsToUTC(seconds);
+ CHECK(TimeInfo.year == 2019);
+ CHECK(TimeInfo.month == 1);
+ CHECK(TimeInfo.day == 1);
+ CHECK(TimeInfo.hour == 0);
+ CHECK(TimeInfo.minute == 0);
+ CHECK(TimeInfo.second == 0);
+
+ seconds = 1550966400; // elapsed seconds between 24/2/2019 00:00:00 and Unix epoch
+
+ TimeInfo = TimeHelper::secondsToUTC(seconds);
+ CHECK(TimeInfo.year == 2019);
+ CHECK(TimeInfo.month == 2);
+ CHECK(TimeInfo.day == 24);
+ CHECK(TimeInfo.hour == 0);
+ CHECK(TimeInfo.minute == 0);
+ CHECK(TimeInfo.second == 0);
+
+ seconds = 1551571200; // elapsed seconds between 3/3/2019 00:00:00 and Unix epoch
+
+ TimeInfo = TimeHelper::secondsToUTC(seconds);
+ CHECK(TimeInfo.year == 2019);
+ CHECK(TimeInfo.month == 3);
+ CHECK(TimeInfo.day == 3);
+ CHECK(TimeInfo.hour == 0);
+ CHECK(TimeInfo.minute == 0);
+ CHECK(TimeInfo.second == 0);
+
+ seconds = 1742907370; // elapsed seconds between 25/3/2025 12:56:10 and Unix epoch
+
+ TimeInfo = TimeHelper::secondsToUTC(seconds);
+ CHECK(TimeInfo.year == 2025);
+ CHECK(TimeInfo.month == 3);
+ CHECK(TimeInfo.day == 25);
+ CHECK(TimeInfo.hour == 12);
+ CHECK(TimeInfo.minute == 56);
+ CHECK(TimeInfo.second == 10);
+
+ seconds = 1583020800; // elapsed seconds between 1/3/2020 00:00:00 and Unix epoch
+
+ TimeInfo = TimeHelper::secondsToUTC(seconds);
+ CHECK(TimeInfo.year == 2020);
+ CHECK(TimeInfo.month == 3);
+ CHECK(TimeInfo.day == 1);
+ CHECK(TimeInfo.hour == 0);
+ CHECK(TimeInfo.minute == 0);
+ CHECK(TimeInfo.second == 0);
+
+ seconds = 1582934400; // elapsed seconds between 2/29/2020 00:00:00 and Unix epoch
+
+ TimeInfo = TimeHelper::secondsToUTC(seconds);
+ CHECK(TimeInfo.year == 2020);
+ CHECK(TimeInfo.month == 2);
+ CHECK(TimeInfo.day == 29);
+ CHECK(TimeInfo.hour == 0);
+ CHECK(TimeInfo.minute == 0);
+ CHECK(TimeInfo.second == 0);
+
+ seconds = 1577923200; // elapsed seconds between 2/1/2020 00:00:00 and Unix epoch
+
+ TimeInfo = TimeHelper::secondsToUTC(seconds);
+ CHECK(TimeInfo.year == 2020);
+ CHECK(TimeInfo.month == 1);
+ CHECK(TimeInfo.day == 2);
+ CHECK(TimeInfo.hour == 0);
+ CHECK(TimeInfo.minute == 0);
+ CHECK(TimeInfo.second == 0);
+ }
}
diff --git a/test/Services/EventActionService.cpp b/test/Services/EventActionService.cpp
index f40de3fda9cc5aeab243d61ce786b5c991fb4651..964e8826e64404a08c7c6c544f85c0e69408fa56 100644
--- a/test/Services/EventActionService.cpp
+++ b/test/Services/EventActionService.cpp
@@ -5,9 +5,11 @@
#include <etl/String.hpp>
#include <cstring>
#include <iostream>
+#include <ServicePool.hpp>
+
+EventActionService & eventActionService = Services.eventAction;
TEST_CASE("Add event-action definitions TC[19,1]", "[service][st09]") {
- EventActionService eventActionService;
char checkstring[256];
Message message(19, 1, Message::TC, 0);
message.appendEnum16(0);
@@ -43,7 +45,6 @@ TEST_CASE("Add event-action definitions TC[19,1]", "[service][st09]") {
}
TEST_CASE("Delete event-action definitions TC[19,2]", "[service][st09]") {
- EventActionService eventActionService;
Message message0(19, 1, Message::TC, 0);
message0.appendEnum16(1);
message0.appendEnum16(0);
@@ -116,7 +117,6 @@ TEST_CASE("Delete event-action definitions TC[19,2]", "[service][st09]") {
}
TEST_CASE("Delete all event-action definitions TC[19,3]", "[service][st09]") {
- EventActionService eventActionService;
Message message0(19, 1, Message::TC, 0);
message0.appendEnum16(1);
message0.appendEnum16(0);
@@ -160,7 +160,6 @@ TEST_CASE("Delete all event-action definitions TC[19,3]", "[service][st09]") {
}
TEST_CASE("Enable event-action definitions TC[19,4]", "[service][st09]") {
- EventActionService eventActionService;
Message message0(19, 1, Message::TC, 0);
message0.appendEnum16(1);
message0.appendEnum16(0);
@@ -186,7 +185,6 @@ TEST_CASE("Enable event-action definitions TC[19,4]", "[service][st09]") {
}
TEST_CASE("Disable event-action definitions TC[19,5]", "[service][st09]") {
- EventActionService eventActionService;
Message message0(19, 1, Message::TC, 0);
message0.appendEnum16(1);
message0.appendEnum16(0);
@@ -209,7 +207,6 @@ TEST_CASE("Disable event-action definitions TC[19,5]", "[service][st09]") {
}
TEST_CASE("Request event-action definition status TC[19,6]", "[service][st09]") {
- EventActionService eventActionService;
Message message(19, 6, Message::TC, 0);
eventActionService.requestEventActionDefinitionStatus(message);
REQUIRE(ServiceTests::hasOneMessage());
@@ -219,7 +216,6 @@ TEST_CASE("Request event-action definition status TC[19,6]", "[service][st09]")
}
TEST_CASE("Event-action status report TM[19,7]", "[service][st09]") {
- EventActionService eventActionService;
Message message0(19, 1, Message::TC, 0);
message0.appendEnum16(1);
message0.appendEnum16(0);
@@ -251,14 +247,12 @@ TEST_CASE("Event-action status report TM[19,7]", "[service][st09]") {
}
TEST_CASE("Enable event-action function TC[19,8]", "[service][st09]") {
- EventActionService eventActionService;
Message message(19, 8, Message::TC, 0);
eventActionService.enableEventActionFunction(message);
CHECK(eventActionService.getEventActionFunctionStatus() == true);
}
TEST_CASE("Disable event-action function TC[19,9]", "[service][st09]") {
- EventActionService eventActionService;
Message message(19, 9, Message::TC, 0);
eventActionService.disableEventActionFunction(message);
CHECK(eventActionService.getEventActionFunctionStatus() == false);
diff --git a/test/Services/EventReportService.cpp b/test/Services/EventReportService.cpp
index ca90bee5d782856869384041d48f13d13054c694..2d76b5cc08511ce8c292b3aca2de8823ea0c12a6 100644
--- a/test/Services/EventReportService.cpp
+++ b/test/Services/EventReportService.cpp
@@ -4,11 +4,12 @@
#include "ServiceTests.hpp"
#include <cstring>
+EventReportService & eventReportService = Services.eventReport;
+
/*
* @todo: Change the reinterpret_cast
*/
TEST_CASE("Informative Event Report TM[5,1]", "[service][st05]") {
- EventReportService eventReportService;
const char eventReportData[] = "HelloWorld";
char checkString[255];
eventReportService.informativeEventReport(EventReportService::InformativeUnknownEvent,
@@ -28,7 +29,6 @@ TEST_CASE("Informative Event Report TM[5,1]", "[service][st05]") {
}
TEST_CASE("Low Severity Anomaly Report TM[5,2]", "[service][st05]") {
- EventReportService eventReportService;
const char eventReportData[] = "HelloWorld";
char checkString[255];
eventReportService.lowSeverityAnomalyReport(EventReportService::LowSeverityUnknownEvent,
@@ -48,7 +48,6 @@ TEST_CASE("Low Severity Anomaly Report TM[5,2]", "[service][st05]") {
}
TEST_CASE("Medium Severity Anomaly Report TM[5,3]", "[service][st05]") {
- EventReportService eventReportService;
const char eventReportData[] = "HelloWorld";
char checkString[255];
eventReportService.mediumSeverityAnomalyReport
@@ -68,7 +67,6 @@ TEST_CASE("Medium Severity Anomaly Report TM[5,3]", "[service][st05]") {
}
TEST_CASE("High Severity Anomaly Report TM[5,4]", "[service][st05]") {
- EventReportService eventReportService;
const char eventReportData[] = "HelloWorld";
char checkString[255];
eventReportService.highSeverityAnomalyReport(EventReportService::HighSeverityUnknownEvent,
@@ -88,7 +86,6 @@ TEST_CASE("High Severity Anomaly Report TM[5,4]", "[service][st05]") {
}
TEST_CASE("Enable Report Generation TC[5,5]", "[service][st05]") {
- EventReportService eventReportService;
eventReportService.getStateOfEvents().reset();
EventReportService::Event eventID[] = {EventReportService::AssertionFail,
EventReportService::LowSeverityUnknownEvent};
@@ -102,7 +99,6 @@ TEST_CASE("Enable Report Generation TC[5,5]", "[service][st05]") {
}
TEST_CASE("Disable Report Generation TC[5,6]", "[service][st05]") {
- EventReportService eventReportService;
EventReportService::Event eventID[] = {EventReportService::InformativeUnknownEvent,
EventReportService::MediumSeverityUnknownEvent};
Message message(5, 6, Message::TC, 1);
@@ -120,7 +116,6 @@ TEST_CASE("Disable Report Generation TC[5,6]", "[service][st05]") {
}
TEST_CASE("Request list of disabled events TC[5,7]", "[service][st05]") {
- EventReportService eventReportService;
Message message(5, 7, Message::TC, 1);
eventReportService.requestListOfDisabledEvents(message);
REQUIRE(ServiceTests::hasOneMessage());
@@ -131,7 +126,6 @@ TEST_CASE("Request list of disabled events TC[5,7]", "[service][st05]") {
}
TEST_CASE("List of Disabled Events Report TM[5,8]", "[service][st05]") {
- EventReportService eventReportService;
EventReportService::Event eventID[] = {EventReportService::MCUStart,
EventReportService::HighSeverityUnknownEvent};
Message message(5, 6, Message::TC, 1);
@@ -156,7 +150,6 @@ TEST_CASE("List of Disabled Events Report TM[5,8]", "[service][st05]") {
}
TEST_CASE("List of observables 6.5.6", "[service][st05]") {
- EventReportService eventReportService;
EventReportService::Event eventID[] = {EventReportService::HighSeverityUnknownEvent};
Message message(5, 6, Message::TC, 1);
message.appendUint16(1);
diff --git a/test/Services/MemoryManagementService.cpp b/test/Services/MemoryManagementService.cpp
index 64b0181f904a8d53845d43019c6dc9f579b41b9b..ec1ef2d5c0e4094d1905ad3ebfcc342d5adef396 100644
--- a/test/Services/MemoryManagementService.cpp
+++ b/test/Services/MemoryManagementService.cpp
@@ -4,6 +4,8 @@
#include "ServiceTests.hpp"
#include "Helpers/CRCHelper.hpp"
+MemoryManagementService & memMangService = Services.memoryManagement;
+
TEST_CASE("TM[6,2]", "[service][st06]") {
// Required test variables
char *pStr = static_cast<char *>(malloc(4));
@@ -12,8 +14,6 @@ TEST_CASE("TM[6,2]", "[service][st06]") {
*(pStr + 2) = '\0';
uint8_t data[2] = {'h', 'R'};
- MemoryManagementService memMangService;
-
Message receivedPacket = Message(6, 2, Message::TC, 1);
receivedPacket.appendEnum8(MemoryManagementService::MemoryID::EXTERNAL); // Memory ID
receivedPacket.appendUint16(2); // Iteration count
diff --git a/test/Services/ParameterService.cpp b/test/Services/ParameterService.cpp
index dbf1820b51e3d1d13f13f70e5f3eb7e139289894..61b96d6c1cc1c93cdc0c013717f401cb01c4abec 100644
--- a/test/Services/ParameterService.cpp
+++ b/test/Services/ParameterService.cpp
@@ -3,18 +3,16 @@
#include "Message.hpp"
#include "ServiceTests.hpp"
-#define CATCH_CONFIG_MAIN
+ParameterService & pserv = Services.parameterManagement;
TEST_CASE("Parameter Report Subservice") {
- ParameterService pserv;
-
SECTION("Faulty Instruction Handling Test") {
Message request(20, 1, Message::TC, 1);
Message report(20, 2, Message::TM, 1);
request.appendUint16(2); // number of requested IDs
request.appendUint16(34672); // faulty ID in this context
- request.appendUint16(3); // valid
+ request.appendUint16(1); // valid
pserv.reportParameterIds(request);
report = ServiceTests::get(0);
@@ -29,11 +27,19 @@ TEST_CASE("Parameter Report Subservice") {
}
}
+ // **WARNING**
+ // TODO: Update this test (and all tests in general) to use the error handler's output when
+ // checking for assertions.
SECTION("Wrong Message Type Handling Test") {
Message falseRequest(15, 3, Message::TM, 1); // a totally wrong message
pserv.reportParameterIds(falseRequest);
- Message response = ServiceTests::get(0);
+ Message errorNotif = ServiceTests::get(0);
+ CHECK(errorNotif.messageType == 4); // check for proper failed start of
+ // execution notification
+ CHECK(errorNotif.serviceType == 1);
+
+ Message response = ServiceTests::get(1);
CHECK(response.messageType == 2);
CHECK(response.serviceType == 20);
CHECK(response.packetType == Message::TM);
@@ -42,29 +48,44 @@ TEST_CASE("Parameter Report Subservice") {
}
TEST_CASE("Parameter Setting Subservice") {
- ParameterService pserv;
-
SECTION("Faulty Instruction Handling Test") {
Message setRequest(20, 3, Message::TC, 1);
Message reportRequest(20, 1, Message::TC, 1);
- setRequest.appendUint16(2); // correct number of IDs
- setRequest.appendUint16(3); // correct ID
+ setRequest.appendUint16(2); // total number of IDs
+ setRequest.appendUint16(1); // correct ID in this context
setRequest.appendUint32(3735928559); // 0xDEADBEEF in hex (new setting)
setRequest.appendUint16(16742); // faulty ID in this context
setRequest.appendUint32(3131746989); // 0xBAAAAAAD (this shouldn't be found in the report)
reportRequest.appendUint16(2);
reportRequest.appendUint16(16742);
- reportRequest.appendUint16(3);
+ reportRequest.appendUint16(1); // used to be 3, which pointed the bug with
+ // numOfValidIds out, now is 1 in order to be a valid ID (a separate test for
+ // numOfValidIds shall be introduced)
+
+ // Since every reporting and setting is called with the same (sometimes faulty) parameters,
+ // and there are errors generated (as should be) it is important to catch and check for
+ // them in order to preserve the integrity of the test.
pserv.reportParameterIds(reportRequest);
- Message before = ServiceTests::get(0);
+ Message errorNotif1 = ServiceTests::get(0);
+ CHECK(errorNotif1.messageType == 4);
+ CHECK(errorNotif1.serviceType == 1);
+
+ Message before = ServiceTests::get(1);
pserv.setParameterIds(setRequest);
+ Message errorNotif2 = ServiceTests::get(2);
+ CHECK(errorNotif2.messageType == 4);
+ CHECK(errorNotif2.serviceType == 1);
pserv.reportParameterIds(reportRequest);
- Message after = ServiceTests::get(1);
+ Message errorNotif3 = ServiceTests::get(3);
+ CHECK(errorNotif3.messageType == 4);
+ CHECK(errorNotif3.serviceType == 1);
+
+ Message after = ServiceTests::get(4);
before.readUint16();
after.readUint16(); // skip the number of IDs
diff --git a/test/Services/RequestVerificationService.cpp b/test/Services/RequestVerificationService.cpp
index 3e80440466cb13eb0a89d49dbc3d23b7eafd43ab..8464dc5b8eb48cb1dfc1de38c0f4bcd3dfc59a20 100644
--- a/test/Services/RequestVerificationService.cpp
+++ b/test/Services/RequestVerificationService.cpp
@@ -3,9 +3,9 @@
#include <Message.hpp>
#include "ServiceTests.hpp"
-TEST_CASE("TM[1,1]", "[service][st01]") {
- RequestVerificationService reqVerifService;
+RequestVerificationService & reqVerifService = Services.requestVerification;
+TEST_CASE("TM[1,1]", "[service][st01]") {
Message receivedMessage = Message(1, 1, Message::TC, 3);
reqVerifService.successAcceptanceVerification(receivedMessage);
REQUIRE(ServiceTests::hasOneMessage());
@@ -27,8 +27,6 @@ TEST_CASE("TM[1,1]", "[service][st01]") {
}
TEST_CASE("TM[1,2]", "[service][st01]") {
- RequestVerificationService reqVerifService;
-
Message receivedMessage = Message(1, 2, Message::TC, 3);
reqVerifService.failAcceptanceVerification(receivedMessage,
ErrorHandler::UnknownAcceptanceError);
@@ -52,8 +50,6 @@ TEST_CASE("TM[1,2]", "[service][st01]") {
}
TEST_CASE("TM[1,3]", "[service][st01]") {
- RequestVerificationService reqVerifService;
-
Message receivedMessage = Message(1, 3, Message::TC, 3);
reqVerifService.successStartExecutionVerification(receivedMessage);
REQUIRE(ServiceTests::hasOneMessage());
@@ -75,8 +71,6 @@ TEST_CASE("TM[1,3]", "[service][st01]") {
}
TEST_CASE("TM[1,4]", "[service][st01]") {
- RequestVerificationService reqVerifService;
-
Message receivedMessage = Message(1, 2, Message::TC, 3);
reqVerifService.failStartExecutionVerification(receivedMessage,
ErrorHandler::UnknownExecutionStartError);
@@ -100,8 +94,6 @@ TEST_CASE("TM[1,4]", "[service][st01]") {
}
TEST_CASE("TM[1,5]", "[service][st01]") {
- RequestVerificationService reqVerifService;
-
Message receivedMessage = Message(1, 5, Message::TC, 3);
reqVerifService.successProgressExecutionVerification(receivedMessage, 0);
REQUIRE(ServiceTests::hasOneMessage());
@@ -124,8 +116,6 @@ TEST_CASE("TM[1,5]", "[service][st01]") {
}
TEST_CASE("TM[1,6]", "[service][st01]") {
- RequestVerificationService reqVerifService;
-
Message receivedMessage = Message(1, 5, Message::TC, 3);
reqVerifService.failProgressExecutionVerification(receivedMessage,
ErrorHandler::UnknownExecutionProgressError,
@@ -151,8 +141,6 @@ TEST_CASE("TM[1,6]", "[service][st01]") {
}
TEST_CASE("TM[1,7]", "[service][st01]") {
- RequestVerificationService reqVerifService;
-
Message receivedMessage = Message(1, 7, Message::TC, 3);
reqVerifService.successCompletionExecutionVerification(receivedMessage);
REQUIRE(ServiceTests::hasOneMessage());
@@ -174,8 +162,6 @@ TEST_CASE("TM[1,7]", "[service][st01]") {
}
TEST_CASE("TM[1,8]", "[service][st01]") {
- RequestVerificationService reqVerifService;
-
Message receivedMessage = Message(1, 8, Message::TC, 3);
reqVerifService.failCompletionExecutionVerification(receivedMessage,
ErrorHandler::UnknownExecutionCompletionError);
@@ -198,8 +184,6 @@ TEST_CASE("TM[1,8]", "[service][st01]") {
}
TEST_CASE("TM[1,10]", "[service][st01]") {
- RequestVerificationService reqVerifService;
-
Message receivedMessage = Message(1, 10, Message::TC, 3);
reqVerifService.failRoutingVerification(receivedMessage, ErrorHandler::UnknownRoutingError);
REQUIRE(ServiceTests::hasOneMessage());
diff --git a/test/Services/ServiceTests.hpp b/test/Services/ServiceTests.hpp
index a160558a0aac56d215ae6af329ce7b690c0b2f4d..09957305df164f3c7042ddd058aa19a4081b7054 100644
--- a/test/Services/ServiceTests.hpp
+++ b/test/Services/ServiceTests.hpp
@@ -2,7 +2,9 @@
#define ECSS_SERVICES_TESTS_SERVICES_SERVICETESTS_HPP
#include <vector>
+#include <map>
#include <Message.hpp>
+#include <ServicePool.hpp>
/**
* Supporting class for tests against ECSS services
@@ -10,8 +12,34 @@
* @todo See if members of this class can be made non-static
*/
class ServiceTests {
+protected:
+ /**
+ * The list of Messages that have been sent as a result of all the processing.
+ *
+ * Whenever a Message is sent from anywhere in the code, it is stored in this array. The
+ * testing code can fetch these Messages using the ServiceTests::get() method.
+ */
static std::vector<Message> queuedMessages;
+ /**
+ * The list of Errors that the ErrorHandler caught.
+ *
+ * Whenever an Error is thrown anywhere in the code, it is collected in the thrownErrors
+ * array. Then, the user can tests whether or which types of errors were thrown, using
+ * the ServiceTests::hasNoErrors() and ServiceTests::thrownError() functions.
+ *
+ * A multimap with keys (ErrorHandler::ErrorSource, ErrorHandler::ErrorType) and values of `1`.
+ *
+ * @todo If errors get more complex, this should hold the complete error information
+ */
+ static std::multimap<std::pair<ErrorHandler::ErrorSource, uint16_t>, bool> thrownErrors;
+
+ /**
+ * Whether an error assertion function was called, indicating that we are expecting to see
+ * Errors thrown after this Message
+ */
+ static bool expectingErrors;
+
public:
/**
* Get a message from the list of queued messages to send
@@ -22,12 +50,26 @@ public:
}
/**
- * Add a message to the queue of messages to be sent
+ * Add a message to the queue of messages having been sent
*/
static void queue(const Message &message) {
queuedMessages.push_back(message);
}
+ /**
+ * Add one error to the list of occurred errors.
+ *
+ * @note This function will be called automatically by the ErrorHandler, and should not be
+ * used in tests.
+ *
+ * @param errorSource The source of the error.
+ * @param errorCode The integer code of the error, coming directly from one of the ErrorCode
+ * enumerations in ErrorHandler.
+ */
+ static void addError(ErrorHandler::ErrorSource errorSource, uint16_t errorCode) {
+ thrownErrors.emplace(std::make_pair(errorSource, errorCode), 1);
+ }
+
/**
* Counts the number of messages in the queue
*/
@@ -43,10 +85,56 @@ public:
}
/**
- * Remove all the queued messages from the list, starting over from 0 items again
+ * Reset the testing environment, starting from zero for all parameters
*/
static void reset() {
queuedMessages.clear();
+ thrownErrors.clear();
+ expectingErrors = false;
+
+ Services.reset();
+ }
+
+/**
+ * Return whether an error assertion function was called, which means that we are expecting this
+ * request to contain errors
+ * @return
+ */
+ static bool isExpectingErrors() {
+ return expectingErrors;
+ }
+
+ /**
+ * Find if there are *no* thrown errors
+ * @return True if 0 errors were thrown after the message
+ * @todo Implement a way to run this assertion at the end of every test
+ */
+ static bool hasNoErrors() {
+ return thrownErrors.empty();
+ }
+
+ /**
+ * Find the number of thrown errors after the processing of this Message.
+ */
+ static uint64_t countErrors() {
+ expectingErrors = true;
+
+ return thrownErrors.size();
+ }
+
+ /**
+ * Find if an error
+ * @tparam ErrorType An enumeration of ErrorHandler
+ * @param errorType The error code of the Error, corresponding to the correct type as
+ * specified in ErrorHandler
+ */
+ template<typename ErrorType>
+ static bool thrownError(ErrorType errorType) {
+ ErrorHandler::ErrorSource errorSource = ErrorHandler::findErrorSource(errorType);
+
+ expectingErrors = true;
+
+ return thrownErrors.find(std::make_pair(errorSource, errorType)) != thrownErrors.end();
}
};
diff --git a/test/Services/TestService.cpp b/test/Services/TestService.cpp
index a94934ad20836620ec2ab1779d4ce0107798d08c..700c0b9df512d6a5e8aa2ae803762f1e07240294 100644
--- a/test/Services/TestService.cpp
+++ b/test/Services/TestService.cpp
@@ -3,9 +3,9 @@
#include <Message.hpp>
#include "ServiceTests.hpp"
-TEST_CASE("TM[17,1]", "[service][st17]") {
- TestService testService;
+TestService & testService = Services.testService;
+TEST_CASE("TM[17,1]", "[service][st17]") {
Message receivedPacket = Message(17, 1, Message::TC, 1);
testService.areYouAlive(receivedPacket);
REQUIRE(ServiceTests::hasOneMessage());
@@ -17,8 +17,6 @@ TEST_CASE("TM[17,1]", "[service][st17]") {
}
TEST_CASE("TM[17,3]", "[service][st17]") {
- TestService testService;
-
Message receivedPacket = Message(17, 3, Message::TC, 1);
receivedPacket.appendEnum16(40);
testService.onBoardConnection(receivedPacket);
diff --git a/test/Services/TimeManagementService.cpp b/test/Services/TimeManagementService.cpp
index 714c99e144480c5037a286a5dcdada334f06d145..f8d0ba754d561656bcb008716d97741f7cf6bb7c 100644
--- a/test/Services/TimeManagementService.cpp
+++ b/test/Services/TimeManagementService.cpp
@@ -2,15 +2,77 @@
#include <Services/TimeManagementService.hpp>
#include "ServiceTests.hpp"
-TEST_CASE("TM[9,2]", "[service][st09]") {
- TimeManagementService timeFormat;
+TimeManagementService & timeService = Services.timeManagement;
- uint32_t seconds;
- seconds = time(nullptr);
+TEST_CASE("TM[9,3]", "[service][st09]") {
+ TimeAndDate TimeInfo;
- timeFormat.cucTimeReport();
+ // 10/04/2020 10:15:00
+ TimeInfo.year = 2020;
+ TimeInfo.month = 4;
+ TimeInfo.day = 10;
+ TimeInfo.hour = 10;
+ TimeInfo.minute = 15;
+ TimeInfo.second = 0;
+
+ uint32_t currTime = TimeHelper::utcToSeconds(TimeInfo);
+
+ uint16_t elapsedDays = currTime/86400;
+ uint32_t msOfDay = currTime % 86400 * 1000;
+ uint64_t timeFormat = (static_cast<uint64_t>(elapsedDays) << 32 | msOfDay);
+
+ timeService.cdsTimeReport(TimeInfo);
Message response = ServiceTests::get(0);
- CHECK(response.readByte() == 50);
- CHECK(response.readWord() == seconds);
+ CHECK(response.serviceType == 9);
+ CHECK(response.messageType == 3);
+ CHECK(response.packetType == Message::TM);
+ CHECK(response.readHalfword() == static_cast<uint16_t>(timeFormat >> 32));
+ CHECK(response.readWord() == static_cast<uint32_t >(timeFormat));
+
+ Message message = Message(9, 128, Message::TC, 3);
+ message.appendHalfword(static_cast<uint16_t >(timeFormat >> 32));
+ message.appendWord(static_cast<uint32_t >(timeFormat));
+
+ TimeInfo = timeService.cdsTimeRequest(message);
+ CHECK(TimeInfo.year == 2020);
+ CHECK(TimeInfo.month == 4);
+ CHECK(TimeInfo.day == 10);
+ CHECK(TimeInfo.hour == 10);
+ CHECK(TimeInfo.minute == 15);
+ CHECK(TimeInfo.second == 0);
+
+
+ // 1/1/2019 00:00:00
+ TimeInfo.year = 2019;
+ TimeInfo.month = 1;
+ TimeInfo.day = 1;
+ TimeInfo.hour = 0;
+ TimeInfo.minute = 0;
+ TimeInfo.second = 0;
+
+ currTime = TimeHelper::utcToSeconds(TimeInfo);
+
+ elapsedDays = currTime/86400;
+ msOfDay = currTime % 86400 * 1000;
+ timeFormat = (static_cast<uint64_t>(elapsedDays) << 32 | msOfDay);
+
+ timeService.cdsTimeReport(TimeInfo);
+ response = ServiceTests::get(1);
+ CHECK(response.serviceType == 9);
+ CHECK(response.messageType == 3);
+ CHECK(response.packetType == Message::TM);
+ CHECK(response.readHalfword() == static_cast<uint16_t>(timeFormat >> 32));
+ CHECK(response.readWord() == static_cast<uint32_t >(timeFormat));
+
+ message = Message(9, 128, Message::TC, 3);
+ message.appendHalfword(static_cast<uint16_t >(timeFormat >> 32));
+ message.appendWord(static_cast<uint32_t >(timeFormat));
+ TimeInfo = timeService.cdsTimeRequest(message);
+ CHECK(TimeInfo.year == 2019);
+ CHECK(TimeInfo.month == 1);
+ CHECK(TimeInfo.day == 1);
+ CHECK(TimeInfo.hour == 0);
+ CHECK(TimeInfo.minute == 0);
+ CHECK(TimeInfo.second == 0);
}
diff --git a/test/TestPlatform.cpp b/test/TestPlatform.cpp
index 10f9cdf366fd4950138248a6564b33c7d8dd0a10..0880d64ea865d220846ac5659068606cbce65d62 100644
--- a/test/TestPlatform.cpp
+++ b/test/TestPlatform.cpp
@@ -5,15 +5,49 @@
#include <Service.hpp>
#include "Services/ServiceTests.hpp"
+// Explicit template specializations for the logError() function
+template void ErrorHandler::logError(const Message &, ErrorHandler::AcceptanceErrorType);
+template void ErrorHandler::logError(const Message &, ErrorHandler::ExecutionStartErrorType);
+template void ErrorHandler::logError(const Message &, ErrorHandler::ExecutionProgressErrorType);
+template void ErrorHandler::logError(const Message &, ErrorHandler::ExecutionCompletionErrorType);
+template void ErrorHandler::logError(const Message &, ErrorHandler::RoutingErrorType);
+template void ErrorHandler::logError(ErrorHandler::InternalErrorType);
+
+// Initialisation of ServiceTests properties
std::vector<Message> ServiceTests::queuedMessages = std::vector<Message>();
+std::multimap<std::pair<ErrorHandler::ErrorSource, uint16_t>, bool> ServiceTests::thrownErrors =
+ std::multimap<std::pair<ErrorHandler::ErrorSource, uint16_t>, bool>();
+bool ServiceTests::expectingErrors = false;
void Service::storeMessage(const Message &message) {
+ // Just add the message to the queue
ServiceTests::queue(message);
}
+template<typename ErrorType>
+void ErrorHandler::logError(const Message &message, ErrorType errorType) {
+ logError(errorType);
+}
+
+template<typename ErrorType>
+void ErrorHandler::logError(ErrorType errorType) {
+ ServiceTests::addError(ErrorHandler::findErrorSource(errorType), errorType);
+}
+
struct ServiceTestsListener : Catch::TestEventListenerBase {
using TestEventListenerBase::TestEventListenerBase; // inherit constructor
+ void sectionEnded(Catch::SectionStats const §ionStats) override {
+ // Make sure we don't have any errors
+ if (not ServiceTests::isExpectingErrors()) {
+ // An Error was thrown with this Message. If you expected this to happen, please call a
+ // corresponding assertion function from ServiceTests to silence this message.
+
+ //TODO: Uncomment the following line as soon as Issue #19 is closed
+ // CHECK(ServiceTests::hasNoErrors());
+ }
+ }
+
void testCaseEnded(Catch::TestCaseStats const &testCaseStats) override {
// Tear-down after a test case is run
ServiceTests::reset();