Compare commits
4 Commits
929f609f24
...
623cff9cfd
| Author | SHA1 | Date | |
|---|---|---|---|
| 623cff9cfd | |||
| 3d884c8329 | |||
| 79d6b47aa8 | |||
| 89fc662181 |
+1
-1
@@ -140,7 +140,6 @@
|
||||
<ClCompile Include="models\User.cpp" />
|
||||
<ClCompile Include="services\AuthenticationManagementService.cpp" />
|
||||
<ClCompile Include="services\InventoryManagementService.cpp" />
|
||||
<ClCompile Include="services\NotificationManagementService.cpp" />
|
||||
<ClCompile Include="services\PaymentManagementService.cpp" />
|
||||
<ClCompile Include="services\ServiceManagementService.cpp" />
|
||||
<ClCompile Include="services\UserManagementService.cpp" />
|
||||
@@ -157,6 +156,7 @@
|
||||
<ClInclude Include="core\patterns\Observer.h" />
|
||||
<ClInclude Include="core\patterns\Subject.h" />
|
||||
<ClInclude Include="datastores\DataStore.h" />
|
||||
<ClInclude Include="datastores\DataStoreLockGuard.h" />
|
||||
<ClInclude Include="datastores\sharedmemory\FileHeader.h" />
|
||||
<ClInclude Include="datastores\sharedmemory\MappingInfo.h" />
|
||||
<ClInclude Include="datastores\sharedmemory\RecordState.h" />
|
||||
|
||||
+3
-3
@@ -114,9 +114,6 @@
|
||||
<ClCompile Include="datastores\DataStore.cpp">
|
||||
<Filter>Source Files\DataStores</Filter>
|
||||
</ClCompile>
|
||||
<ClCompile Include="services\NotificationManagementService.cpp">
|
||||
<Filter>Source Files\Services</Filter>
|
||||
</ClCompile>
|
||||
<ClCompile Include="core\patterns\Observer.cpp">
|
||||
<Filter>Source Files\Core\Patterns</Filter>
|
||||
</ClCompile>
|
||||
@@ -278,5 +275,8 @@
|
||||
<ClInclude Include="datastores\sharedmemory\SharedMemory.h">
|
||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="datastores\DataStoreLockGuard.h">
|
||||
<Filter>Header Files</Filter>
|
||||
</ClInclude>
|
||||
</ItemGroup>
|
||||
</Project>
|
||||
+23
-49
@@ -588,63 +588,37 @@ void Controller::configureNotifications(bool paymentNotifications, bool serviceN
|
||||
}
|
||||
|
||||
/*
|
||||
Function: loadSystemData
|
||||
Description: Loads all system data from persistent storage into memory.
|
||||
Invokes the respective management services to load users, inventory items, services,
|
||||
combo packages, service bookings, job cards, invoices, and observers.
|
||||
Function: initialize
|
||||
Description: Initializes the system and run system checks to ensure critical configurations, such as verifying admin existence.
|
||||
Parameters:
|
||||
- None
|
||||
Returns:
|
||||
- void
|
||||
- bool
|
||||
*/
|
||||
void Controller::loadSystemData()
|
||||
bool Controller::initialize()
|
||||
{
|
||||
m_userManagementService.loadUsers();
|
||||
m_inventoryManagementService.loadInventoryItems();
|
||||
m_serviceManagementService.loadServices();
|
||||
m_serviceManagementService.loadComboPackages();
|
||||
m_serviceManagementService.loadServiceBookings();
|
||||
m_serviceManagementService.loadJobCards();
|
||||
m_paymentManagementService.loadInvoices();
|
||||
m_serviceManagementService.loadObservers();
|
||||
m_paymentManagementService.loadObservers();
|
||||
m_inventoryManagementService.loadObservers();
|
||||
}
|
||||
auto& dataStore = DataStore::getInstance();
|
||||
|
||||
/*
|
||||
Function: saveSystemData
|
||||
Description: Saves all system data from memory back to persistent storage.
|
||||
Invokes the respective management services to save users, inventory items, services,
|
||||
combo packages, service bookings, job cards, invoices, and observers.
|
||||
Parameters:
|
||||
- None
|
||||
Returns:
|
||||
- void
|
||||
*/
|
||||
void Controller::saveSystemData()
|
||||
{
|
||||
m_userManagementService.saveUsers();
|
||||
m_inventoryManagementService.saveInventoryItems();
|
||||
m_serviceManagementService.saveServices();
|
||||
m_serviceManagementService.saveComboPackages();
|
||||
m_serviceManagementService.saveServiceBookings();
|
||||
m_serviceManagementService.saveJobCards();
|
||||
m_paymentManagementService.saveInvoices();
|
||||
m_serviceManagementService.saveObservers();
|
||||
m_paymentManagementService.saveObservers();
|
||||
m_inventoryManagementService.saveObservers();
|
||||
}
|
||||
|
||||
/*
|
||||
Function: runSystemChecks
|
||||
Description: Runs system checks to ensure critical configurations, such as verifying admin existence.
|
||||
Parameter: None
|
||||
Return type: void
|
||||
*/
|
||||
void Controller::runSystemChecks()
|
||||
{
|
||||
if (!dataStore.initialize())
|
||||
{
|
||||
return false;
|
||||
}
|
||||
m_userManagementService.ensureAdminExists();
|
||||
m_inventoryManagementService.sendLowStockAlerts();
|
||||
m_paymentManagementService.sendPaymentReminders();
|
||||
return true;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: shutdown
|
||||
Description: Shutdown the system, and do necessary cleanups
|
||||
Parameters:
|
||||
- None
|
||||
Returns:
|
||||
- void
|
||||
*/
|
||||
void Controller::shutdown()
|
||||
{
|
||||
auto& dataStore = DataStore::getInstance();
|
||||
dataStore.shutdown();
|
||||
}
|
||||
|
||||
@@ -70,7 +70,6 @@ public:
|
||||
util::Vector<const Notification*> getNotifications();
|
||||
void deleteNotification(const std::string& notificationID);
|
||||
void configureNotifications(bool paymentNotifications, bool serviceNotifications);
|
||||
void loadSystemData();
|
||||
void saveSystemData();
|
||||
void runSystemChecks();
|
||||
bool initialize();
|
||||
void shutdown();
|
||||
};
|
||||
@@ -13,5 +13,4 @@ class Observer
|
||||
{
|
||||
public:
|
||||
virtual ~Observer() = default;
|
||||
virtual void addNotification(Notification* notification) = 0;
|
||||
};
|
||||
@@ -228,6 +228,8 @@ Returns:
|
||||
*/
|
||||
util::Map<std::string, TrackedRecord<User>>& DataStore::getUsers()
|
||||
{
|
||||
auto users = loadRecords<User, SerializedUser>(m_users);
|
||||
refreshCache(m_userCache, users);
|
||||
return m_userCache;
|
||||
}
|
||||
|
||||
@@ -241,6 +243,8 @@ Returns:
|
||||
*/
|
||||
util::Map<std::string, TrackedRecord<Notification>>& DataStore::getNotifications()
|
||||
{
|
||||
auto notifications = loadRecords<Notification, SerializedNotification>(m_notifications);
|
||||
refreshCache(m_notificationCache, notifications);
|
||||
return m_notificationCache;
|
||||
}
|
||||
|
||||
@@ -322,6 +326,37 @@ util::Map<std::string, TrackedRecord<Invoice>>& DataStore::getInvoices()
|
||||
return m_invoiceCache;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getObservers
|
||||
Description: Retrieves observer records from the specified observer mapping
|
||||
and resolves them to User objects.
|
||||
Parameters:
|
||||
- mapping: Observer mapping to read from
|
||||
Returns:
|
||||
- util::Map<std::string, User*>: Collection of observer records
|
||||
Throws:
|
||||
- std::runtime_error if an observer references an invalid user ID
|
||||
*/
|
||||
util::Map<std::string, User*> DataStore::getObservers(MappingInfo& mapping)
|
||||
{
|
||||
auto& users = getUsers();
|
||||
util::Map<std::string, User*> observers;
|
||||
SharedMemory::ensureLatestMapping(mapping);
|
||||
size_t recordCount = SharedMemory::getRecordCount(mapping);
|
||||
for (size_t index = 0; index < recordCount; index++)
|
||||
{
|
||||
const SerializedObserver* observer = static_cast<SerializedObserver*>(SharedMemory::getRecordAddress(mapping, index));
|
||||
int userIndex = users.find(observer->id);
|
||||
if (userIndex == -1)
|
||||
{
|
||||
throw std::runtime_error("Invalid observer user ID");
|
||||
}
|
||||
User* user = users.getValueAt(userIndex).data;
|
||||
observers.insert(user->getId(), user);
|
||||
}
|
||||
return observers;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getServiceManagementObservers
|
||||
Description: Retrieves all service management observer records from the datastore.
|
||||
@@ -332,7 +367,7 @@ Returns:
|
||||
*/
|
||||
util::Map<std::string, User*> DataStore::getServiceManagementObservers()
|
||||
{
|
||||
return util::Map<std::string, User*>();
|
||||
return getObservers(m_serviceManagementObservers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -345,7 +380,7 @@ Returns:
|
||||
*/
|
||||
util::Map<std::string, User*> DataStore::getPaymentManagementObservers()
|
||||
{
|
||||
return util::Map<std::string, User*>();
|
||||
return getObservers(m_paymentManagementObservers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -358,7 +393,7 @@ Returns:
|
||||
*/
|
||||
util::Map<std::string, User*> DataStore::getInventoryManagementObservers()
|
||||
{
|
||||
return util::Map<std::string, User*>();
|
||||
return getObservers(m_inventoryManagementObservers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -371,6 +406,7 @@ Returns:
|
||||
*/
|
||||
void DataStore::saveUsers()
|
||||
{
|
||||
saveRecords<User, SerializedUser>(m_users, m_userCache);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -383,6 +419,7 @@ Returns:
|
||||
*/
|
||||
void DataStore::saveNotifications()
|
||||
{
|
||||
saveRecords<Notification, SerializedNotification>(m_notifications, m_notificationCache);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -457,16 +494,49 @@ void DataStore::saveInvoices()
|
||||
{
|
||||
}
|
||||
|
||||
/*
|
||||
Function: saveObservers
|
||||
Description: Persists observer records to the specified observer mapping.
|
||||
Parameters:
|
||||
- mapping: MappingInfo&, observer mapping to save to
|
||||
- observers: util::Map<std::string, User*>&, collection of observer records
|
||||
Returns:
|
||||
- None
|
||||
*/
|
||||
void DataStore::saveObservers(MappingInfo& mapping, util::Map<std::string, User*>& observers)
|
||||
{
|
||||
size_t observerCount = static_cast<size_t>(observers.getSize());
|
||||
size_t capacity = config::file::INITIAL_CAPACITY;
|
||||
while (capacity < observerCount)
|
||||
{
|
||||
capacity *= config::file::GROWTH_FACTOR;
|
||||
}
|
||||
if (!SharedMemory::resizeMapping(mapping, capacity))
|
||||
{
|
||||
throw std::runtime_error("Failed to resize observer mapping");
|
||||
}
|
||||
SharedMemory::setRecordCount(mapping, observerCount);
|
||||
for (size_t index = 0; index < observerCount; index++)
|
||||
{
|
||||
SerializedObserver serializedObserver;
|
||||
User* user = observers.getValueAt(static_cast<int>(index));
|
||||
strcpy_s(serializedObserver.id, user->getId().c_str());
|
||||
SerializedObserver* destination = static_cast<SerializedObserver*>(SharedMemory::getRecordAddress(mapping, index));
|
||||
*destination = serializedObserver;
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: saveServiceManagementObservers
|
||||
Description: Persists all service management observer records to the datastore.
|
||||
Parameters:
|
||||
- observers: util::Map<std::string, TrackedRecord<std::string>>&, collection of observer records
|
||||
- observers: util::Map<std::string, User*>&, collection of observer records
|
||||
Returns:
|
||||
- None
|
||||
*/
|
||||
void DataStore::saveServiceManagementObservers(util::Map<std::string, User*>& observers)
|
||||
{
|
||||
saveObservers(m_serviceManagementObservers, observers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -479,6 +549,7 @@ Returns:
|
||||
*/
|
||||
void DataStore::savePaymentManagementObservers(util::Map<std::string, User*>& observers)
|
||||
{
|
||||
saveObservers(m_paymentManagementObservers, observers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -491,6 +562,7 @@ Returns:
|
||||
*/
|
||||
void DataStore::saveInventoryManagementObservers(util::Map<std::string, User*>& observers)
|
||||
{
|
||||
saveObservers(m_inventoryManagementObservers, observers);
|
||||
}
|
||||
|
||||
/*
|
||||
|
||||
@@ -86,6 +86,8 @@ private:
|
||||
void saveRecords(MappingInfo& mapping, util::Map<std::string, TrackedRecord<TObject>>& records);
|
||||
template<typename TObject> void clearCache(util::Map<std::string, TrackedRecord<TObject>>&cache);
|
||||
template<typename TObject> void refreshCache(util::Map<std::string, TrackedRecord<TObject>>&cache, util::Map<std::string, TrackedRecord<TObject>>&refreshedCache);
|
||||
util::Map<std::string, User*> getObservers(MappingInfo& mapping);
|
||||
void saveObservers(MappingInfo& mapping, util::Map<std::string, User*>& observers);
|
||||
};
|
||||
|
||||
/*
|
||||
|
||||
+28
@@ -0,0 +1,28 @@
|
||||
/*
|
||||
File: DataStoreLockGuard.h
|
||||
Description: Defines the DataStoreLockGuard class used to manage DataStore
|
||||
locking and unlocking automatically within a scope.
|
||||
Author: Trenser
|
||||
Date: 12-June-2026
|
||||
*/
|
||||
|
||||
#pragma once
|
||||
#include "DataStore.h"
|
||||
|
||||
class DataStoreLockGuard
|
||||
{
|
||||
public:
|
||||
explicit DataStoreLockGuard(DataStore& dataStore)
|
||||
: m_dataStore(dataStore)
|
||||
{
|
||||
m_dataStore.lockDataStore();
|
||||
}
|
||||
~DataStoreLockGuard()
|
||||
{
|
||||
m_dataStore.unlockDataStore();
|
||||
}
|
||||
DataStoreLockGuard(const DataStoreLockGuard&) = delete;
|
||||
DataStoreLockGuard& operator=(const DataStoreLockGuard&) = delete;
|
||||
private:
|
||||
DataStore& m_dataStore;
|
||||
};
|
||||
+2
-1
@@ -10,6 +10,7 @@ Created: 11-June-2026
|
||||
*/
|
||||
|
||||
#include "SharedMemory.h"
|
||||
#include "Windows.h"
|
||||
#include "Config.h"
|
||||
|
||||
/*
|
||||
@@ -319,7 +320,7 @@ bool SharedMemory::ensureCapacityForInsert(MappingInfo& mapping)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
return resizeMapping(mapping, capacity * 2);
|
||||
return resizeMapping(mapping, capacity * config::file::GROWTH_FACTOR);
|
||||
}
|
||||
|
||||
/*
|
||||
|
||||
@@ -1,12 +1,13 @@
|
||||
/*
|
||||
File: Notification.cpp
|
||||
Description: Implements the Notification class which represents system notifications in the Vehicle Service Management System.
|
||||
Provides constructors, accessors, and mutators for notification details such as ID, recipient, title, message, and timestamp.
|
||||
Provides constructors, accessors, and mutators for notification details such as ID, recipientID, title, message, and timestamp.
|
||||
Author: Trenser
|
||||
Date: 19-May-2026
|
||||
*/
|
||||
|
||||
#include <sstream>
|
||||
#include "SerializedRecords.h"
|
||||
#include "Notification.h"
|
||||
#include "StringHelper.h"
|
||||
#include "Factory.h"
|
||||
@@ -22,8 +23,8 @@ Returns:
|
||||
- A new Notification object.
|
||||
*/
|
||||
Notification::Notification()
|
||||
: m_id("NOT" + std::to_string(++m_uid)),
|
||||
m_recipient(nullptr) {}
|
||||
: m_id("NOT" + std::to_string(++m_uid)),
|
||||
m_state(util::State::ACTIVE) {}
|
||||
|
||||
/*
|
||||
Function: Notification
|
||||
@@ -37,13 +38,14 @@ Parameters:
|
||||
Returns:
|
||||
- A new Notification object.
|
||||
*/
|
||||
Notification::Notification(const std::string& recipientUserId, User* recipient, const std::string& title, const std::string& message, const util::Timestamp& createdAt)
|
||||
Notification::Notification(const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt)
|
||||
: m_id("NOT" + std::to_string(++m_uid)),
|
||||
m_recipientUserId(recipientUserId),
|
||||
m_recipient(recipient),
|
||||
m_title(title),
|
||||
m_message(message),
|
||||
m_createdAt(createdAt) {}
|
||||
m_state(util::State::ACTIVE),
|
||||
m_createdAt(createdAt) {
|
||||
}
|
||||
|
||||
/*
|
||||
Function: Notification (parameterized constructor with ID)
|
||||
@@ -58,13 +60,13 @@ Parameters:
|
||||
Returns:
|
||||
- A new Notification object
|
||||
*/
|
||||
Notification::Notification(const std::string& id, const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt)
|
||||
Notification::Notification(const std::string& id, const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt, const util::State& state)
|
||||
: m_id(id),
|
||||
m_recipientUserId(recipientUserId),
|
||||
m_recipient(nullptr),
|
||||
m_title(title),
|
||||
m_message(message),
|
||||
m_createdAt(createdAt)
|
||||
m_createdAt(createdAt),
|
||||
m_state(state)
|
||||
{
|
||||
int idNumber = util::extractNumber(m_id);
|
||||
if (idNumber > m_uid)
|
||||
@@ -79,7 +81,7 @@ Description: Retrieves the unique ID of the notification.
|
||||
Returns:
|
||||
- const std::string& representing the notification ID.
|
||||
*/
|
||||
const std::string& Notification::getId() const
|
||||
const std::string& Notification::getId() const
|
||||
{
|
||||
return m_id;
|
||||
}
|
||||
@@ -95,17 +97,6 @@ const std::string& Notification::getRecipientUserId() const
|
||||
return m_recipientUserId;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getRecipient
|
||||
Description: Retrieves the pointer to the recipient user.
|
||||
Returns:
|
||||
- User* representing the recipient.
|
||||
*/
|
||||
User* Notification::getRecipient() const
|
||||
{
|
||||
return m_recipient;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getTitle
|
||||
Description: Retrieves the title of the notification.
|
||||
@@ -139,6 +130,17 @@ const util::Timestamp& Notification::getCreatedAt() const
|
||||
return m_createdAt;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getState
|
||||
Description: Retrieves the Notification state
|
||||
Returns:
|
||||
- const util::Timestamp& representing the creation timestamp.
|
||||
*/
|
||||
util::State Notification::getState() const
|
||||
{
|
||||
return m_state;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: setId
|
||||
Description: Sets the unique ID of the notification.
|
||||
@@ -165,19 +167,6 @@ void Notification::setRecipientUserId(const std::string& recipientUserId)
|
||||
m_recipientUserId = recipientUserId;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: setRecipient
|
||||
Description: Sets the recipient user pointer for the notification.
|
||||
Parameters:
|
||||
- recipient: Pointer to the User object.
|
||||
Returns:
|
||||
- void
|
||||
*/
|
||||
void Notification::setRecipient(User* recipient)
|
||||
{
|
||||
m_recipient = recipient;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: setTitle
|
||||
Description: Sets the title of the notification.
|
||||
@@ -217,71 +206,54 @@ void Notification::setCreatedAt(const util::Timestamp& createdAt)
|
||||
m_createdAt = createdAt;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: setState
|
||||
Description: Sets the Notification state.
|
||||
Parameters:
|
||||
- state: Notification state value.
|
||||
Returns:
|
||||
- void
|
||||
*/
|
||||
void Notification::setState(util::State state)
|
||||
{
|
||||
m_state = state;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: serialize
|
||||
Description: Serializes the notification into a CSV-formatted string.
|
||||
Description: Serializes the Notification object into a SerializedNotification record.
|
||||
Parameters:
|
||||
- None
|
||||
Returns:
|
||||
- std::string: Serialized notification record
|
||||
- SerializedNotification: Serialized representation of the notification
|
||||
*/
|
||||
std::string Notification::serialize() const
|
||||
SerializedNotification Notification::serialize() const
|
||||
{
|
||||
std::ostringstream serializedNotification;
|
||||
serializedNotification << m_id << ','
|
||||
<< m_recipientUserId << ','
|
||||
<< m_title << ','
|
||||
<< m_message << ','
|
||||
<< m_createdAt.toString();
|
||||
return serializedNotification.str();
|
||||
SerializedNotification serialized = {};
|
||||
strcpy_s(serialized.id, sizeof(serialized.id), m_id.c_str());
|
||||
strcpy_s(serialized.recipientUserId, sizeof(serialized.recipientUserId), m_recipientUserId.c_str());
|
||||
strcpy_s(serialized.title, sizeof(serialized.title), m_title.c_str());
|
||||
strcpy_s(serialized.message, sizeof(serialized.message), m_message.c_str());
|
||||
serialized.createdAt = m_createdAt;
|
||||
serialized.state = m_state;
|
||||
return serialized;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: deserialize
|
||||
Description: Deserializes a CSV-formatted string into a Notification object.
|
||||
Description: Deserializes a SerializedNotification record into a Notification object.
|
||||
Parameters:
|
||||
- record: const std::string&, serialized notification record
|
||||
- serializedNotification: const SerializedNotification&, serialized notification record
|
||||
Returns:
|
||||
- Notification*: Pointer to the deserialized Notification object
|
||||
Throws:
|
||||
- std::runtime_error if timestamp parsing fails
|
||||
*/
|
||||
Notification* Notification::deserialize(const std::string& record)
|
||||
Notification* Notification::deserialize(const SerializedNotification& serializedNotification)
|
||||
{
|
||||
std::string id, recipientUserId, title, message, createdAtTimestampString;
|
||||
std::istringstream serializedNotification(record);
|
||||
getline(serializedNotification, id, ',');
|
||||
getline(serializedNotification, recipientUserId, ',');
|
||||
getline(serializedNotification, title, ',');
|
||||
getline(serializedNotification, message, ',');
|
||||
getline(serializedNotification, createdAtTimestampString, ',');
|
||||
util::Timestamp createdAtTimestamp;
|
||||
try
|
||||
{
|
||||
createdAtTimestamp = util::Timestamp::fromString(createdAtTimestampString);
|
||||
}
|
||||
catch (...)
|
||||
{
|
||||
throw std::runtime_error("Invalid createdAt timestamp");
|
||||
}
|
||||
return Factory::getObject<Notification>(
|
||||
id,
|
||||
recipientUserId,
|
||||
title,
|
||||
message,
|
||||
createdAtTimestamp
|
||||
);
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getHeaders
|
||||
Description: Retrieves the CSV headers for notification serialization.
|
||||
Parameters:
|
||||
- None
|
||||
Returns:
|
||||
- std::string: Header string ("ID,RecipientID,Title,Message,Timestamp")
|
||||
*/
|
||||
std::string Notification::getHeaders()
|
||||
{
|
||||
return "ID,RecipientID,Title,Message,Timestamp";
|
||||
serializedNotification.id,
|
||||
serializedNotification.recipientUserId,
|
||||
serializedNotification.title,
|
||||
serializedNotification.message,
|
||||
serializedNotification.createdAt,
|
||||
serializedNotification.state);
|
||||
}
|
||||
@@ -9,8 +9,10 @@ Date: 19-May-2026
|
||||
#pragma once
|
||||
#include <string>
|
||||
#include "Timestamp.h"
|
||||
#include "Enums.h"
|
||||
|
||||
class User;
|
||||
struct SerializedNotification;
|
||||
|
||||
class Notification
|
||||
{
|
||||
@@ -18,27 +20,26 @@ private:
|
||||
static int m_uid;
|
||||
std::string m_id;
|
||||
std::string m_recipientUserId;
|
||||
User* m_recipient;
|
||||
std::string m_title;
|
||||
std::string m_message;
|
||||
util::Timestamp m_createdAt;
|
||||
util::State m_state;
|
||||
public:
|
||||
Notification();
|
||||
Notification(const std::string& recipientUserId, User* recipient, const std::string& title, const std::string& message, const util::Timestamp& createdAt);
|
||||
Notification(const std::string& id, const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt);
|
||||
Notification(const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt);
|
||||
Notification(const std::string& id, const std::string& recipientUserId, const std::string& title, const std::string& message, const util::Timestamp& createdAt, const util::State& state);
|
||||
const std::string& getId() const;
|
||||
const std::string& getRecipientUserId() const;
|
||||
User* getRecipient() const;
|
||||
const std::string& getTitle() const;
|
||||
const std::string& getMessage() const;
|
||||
const util::Timestamp& getCreatedAt() const;
|
||||
void setId(const std::string& id);
|
||||
void setRecipientUserId(const std::string& recipientUserId);
|
||||
void setRecipient(User* recipient);
|
||||
void setTitle(const std::string& title);
|
||||
void setMessage(const std::string& message);
|
||||
void setCreatedAt(const util::Timestamp& createdAt);
|
||||
std::string serialize() const;
|
||||
static Notification* deserialize(const std::string&);
|
||||
static std::string getHeaders();
|
||||
util::State getState() const;
|
||||
void setState(util::State state);
|
||||
SerializedNotification serialize() const;
|
||||
static Notification* deserialize(const SerializedNotification&);
|
||||
};
|
||||
|
||||
@@ -89,23 +89,6 @@ User::User(const std::string& userId, const std::string& userName, const std::st
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: ~User
|
||||
Description: Destructor that cleans up dynamically allocated notifications associated with the user.
|
||||
Parameters:
|
||||
- None
|
||||
Returns:
|
||||
- void
|
||||
*/
|
||||
User::~User()
|
||||
{
|
||||
auto values = m_notifications.getValues();
|
||||
for (int index = 0; index < values.getSize(); index++)
|
||||
{
|
||||
delete values[index];
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getId
|
||||
Description: Retrieves the unique ID of the user.
|
||||
@@ -172,17 +155,6 @@ const std::string& User::getEmail() const
|
||||
return m_email;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getNotifications
|
||||
Description: Retrieves the map of notifications associated with the user.
|
||||
Returns:
|
||||
- util::Map<std::string, Notification*>& representing the notifications.
|
||||
*/
|
||||
util::Map<std::string, Notification*>& User::getNotifications()
|
||||
{
|
||||
return m_notifications;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getUserType
|
||||
Description: Retrieves the role of the user.
|
||||
@@ -283,22 +255,6 @@ void User::setEmail(const std::string& email)
|
||||
m_email = email;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: addNotification
|
||||
Description: Adds a new notification to the user’s notification map.
|
||||
Parameters:
|
||||
- notification: Pointer to the Notification object.
|
||||
Returns:
|
||||
- void
|
||||
*/
|
||||
void User::addNotification(Notification* notification)
|
||||
{
|
||||
if (notification)
|
||||
{
|
||||
m_notifications.insert(notification->getId(), notification);
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: setRole
|
||||
Description: Sets the role of the user.
|
||||
|
||||
@@ -26,21 +26,19 @@ private:
|
||||
std::string m_name;
|
||||
std::string m_phone;
|
||||
std::string m_email;
|
||||
util::Map<std::string, Notification*> m_notifications;
|
||||
util::UserType m_type;
|
||||
util::State m_status;
|
||||
public:
|
||||
User();
|
||||
User(const std::string& userName, const std::string& password, const std::string& name, const std::string& phone, const std::string& email, util::UserType role);
|
||||
User(const std::string& userId, const std::string& userName, const std::string& password, const std::string& name, const std::string& phone, const std::string& email, util::UserType role, util::State status);
|
||||
~User();
|
||||
~User() = default;
|
||||
const std::string& getId() const;
|
||||
const std::string& getUserName() const;
|
||||
const std::string& getPassword() const;
|
||||
const std::string& getName() const;
|
||||
const std::string& getPhone() const;
|
||||
const std::string& getEmail() const;
|
||||
util::Map<std::string, Notification*>& getNotifications();
|
||||
util::UserType getUserType() const;
|
||||
util::State getState() const;
|
||||
void setId(const std::string& id);
|
||||
@@ -49,7 +47,6 @@ public:
|
||||
void setName(const std::string& name);
|
||||
void setPhone(const std::string& phone);
|
||||
void setEmail(const std::string& email);
|
||||
void addNotification(Notification* notification) override;
|
||||
void setRole(util::UserType role);
|
||||
void setState(util::State status);
|
||||
SerializedUser serialize() const;
|
||||
|
||||
+29
-21
@@ -19,7 +19,7 @@ Date: 22-May-2026
|
||||
#include "User.h"
|
||||
#include "Utility.h"
|
||||
#include "Vector.h"
|
||||
|
||||
#include "DataStoreLockGuard.h"
|
||||
|
||||
util::Map<std::string, User*> InventoryManagementService::m_observers{};
|
||||
|
||||
@@ -271,6 +271,9 @@ Returns:
|
||||
*/
|
||||
void InventoryManagementService::attach(User* user)
|
||||
{
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
m_observers.clear();
|
||||
m_observers = m_dataStore.getInventoryManagementObservers();
|
||||
if (user)
|
||||
{
|
||||
const std::string& userID = user->getId();
|
||||
@@ -279,6 +282,7 @@ void InventoryManagementService::attach(User* user)
|
||||
m_observers[userID] = user;
|
||||
}
|
||||
}
|
||||
m_dataStore.saveInventoryManagementObservers(m_observers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -291,6 +295,9 @@ Returns:
|
||||
*/
|
||||
void InventoryManagementService::detach(User* user)
|
||||
{
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
m_observers.clear();
|
||||
m_observers = m_dataStore.getInventoryManagementObservers();
|
||||
if (user)
|
||||
{
|
||||
const std::string& userID = user->getId();
|
||||
@@ -299,6 +306,7 @@ void InventoryManagementService::detach(User* user)
|
||||
m_observers.remove(userID);
|
||||
}
|
||||
}
|
||||
m_dataStore.saveInventoryManagementObservers(m_observers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -315,27 +323,27 @@ Throws:
|
||||
*/
|
||||
void InventoryManagementService::sendNotification(User* user, const std::string& title, const std::string& message)
|
||||
{
|
||||
if (user)
|
||||
if (!user)
|
||||
{
|
||||
if (m_observers.find(user->getId()) != -1)
|
||||
{
|
||||
Notification* notification =
|
||||
Factory::getObject<Notification>(
|
||||
user->getId(),
|
||||
user,
|
||||
title,
|
||||
message,
|
||||
util::Timestamp()
|
||||
);
|
||||
if (notification)
|
||||
{
|
||||
user->addNotification(notification);
|
||||
}
|
||||
else
|
||||
{
|
||||
throw std::runtime_error("Failed to create notification");
|
||||
}
|
||||
}
|
||||
return;
|
||||
}
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
m_observers = m_dataStore.getInventoryManagementObservers();
|
||||
if (m_observers.find(user->getId()) == -1)
|
||||
{
|
||||
return;
|
||||
}
|
||||
Notification* notification = Factory::getObject<Notification>(
|
||||
user->getId(),
|
||||
title,
|
||||
message,
|
||||
util::Timestamp());
|
||||
if (!notification)
|
||||
{
|
||||
throw std::runtime_error("Failed to create notification");
|
||||
}
|
||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
||||
m_dataStore.saveNotifications();
|
||||
}
|
||||
|
||||
|
||||
-1
@@ -1 +0,0 @@
|
||||
#include "NotificationManagementService.h"
|
||||
+29
-20
@@ -21,6 +21,7 @@ Date: 20-May-2026
|
||||
#include "Timestamp.h"
|
||||
#include "User.h"
|
||||
#include "Utility.h"
|
||||
#include "DataStoreLockGuard.h"
|
||||
|
||||
util::Map<std::string, User*> PaymentManagementService::m_observers{};
|
||||
|
||||
@@ -34,6 +35,9 @@ Returns:
|
||||
*/
|
||||
void PaymentManagementService::attach(User* user)
|
||||
{
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
m_observers.clear();
|
||||
m_observers = m_dataStore.getPaymentManagementObservers();
|
||||
if (user)
|
||||
{
|
||||
const std::string& userID = user->getId();
|
||||
@@ -42,6 +46,7 @@ void PaymentManagementService::attach(User* user)
|
||||
m_observers[userID] = user;
|
||||
}
|
||||
}
|
||||
m_dataStore.savePaymentManagementObservers(m_observers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -54,6 +59,9 @@ Returns:
|
||||
*/
|
||||
void PaymentManagementService::detach(User* user)
|
||||
{
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
m_observers.clear();
|
||||
m_observers = m_dataStore.getPaymentManagementObservers();
|
||||
if (user)
|
||||
{
|
||||
const std::string& userID = user->getId();
|
||||
@@ -62,6 +70,7 @@ void PaymentManagementService::detach(User* user)
|
||||
m_observers.remove(userID);
|
||||
}
|
||||
}
|
||||
m_dataStore.savePaymentManagementObservers(m_observers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -78,28 +87,28 @@ Throws:
|
||||
*/
|
||||
void PaymentManagementService::sendNotification(User* user, const std::string& title, const std::string& message)
|
||||
{
|
||||
if (user)
|
||||
if (!user)
|
||||
{
|
||||
if (m_observers.find(user->getId()) != -1)
|
||||
{
|
||||
Notification* notification =
|
||||
Factory::getObject<Notification>(
|
||||
user->getId(),
|
||||
user,
|
||||
title,
|
||||
message,
|
||||
util::Timestamp()
|
||||
);
|
||||
if (notification)
|
||||
{
|
||||
user->addNotification(notification);
|
||||
}
|
||||
else
|
||||
{
|
||||
throw std::runtime_error("Failed to create notification");
|
||||
}
|
||||
}
|
||||
return;
|
||||
}
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
m_observers = m_dataStore.getPaymentManagementObservers();
|
||||
if (m_observers.find(user->getId()) == -1)
|
||||
{
|
||||
return;
|
||||
}
|
||||
Notification* notification = Factory::getObject<Notification>(
|
||||
user->getId(),
|
||||
title,
|
||||
message,
|
||||
util::Timestamp());
|
||||
if (!notification)
|
||||
{
|
||||
throw std::runtime_error("Failed to create notification");
|
||||
}
|
||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
||||
m_dataStore.saveNotifications();
|
||||
}
|
||||
|
||||
/*
|
||||
|
||||
+31
-46
@@ -26,6 +26,7 @@ Date:19-May-2026
|
||||
#include "User.h"
|
||||
#include "UserManagementService.h"
|
||||
#include "Utility.h"
|
||||
#include "DataStoreLockGuard.h"
|
||||
|
||||
/*
|
||||
Function: purchaseService
|
||||
@@ -122,6 +123,9 @@ Returns:
|
||||
*/
|
||||
void ServiceManagementService::attach(User* user)
|
||||
{
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
m_observers.clear();
|
||||
m_observers = m_dataStore.getServiceManagementObservers();
|
||||
if (user)
|
||||
{
|
||||
const std::string& userID = user->getId();
|
||||
@@ -130,6 +134,7 @@ void ServiceManagementService::attach(User* user)
|
||||
m_observers[userID] = user;
|
||||
}
|
||||
}
|
||||
m_dataStore.saveServiceManagementObservers(m_observers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -142,6 +147,9 @@ Returns:
|
||||
*/
|
||||
void ServiceManagementService::detach(User* user)
|
||||
{
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
m_observers.clear();
|
||||
m_observers = m_dataStore.getServiceManagementObservers();
|
||||
if (user)
|
||||
{
|
||||
const std::string& userID = user->getId();
|
||||
@@ -150,6 +158,7 @@ void ServiceManagementService::detach(User* user)
|
||||
m_observers.remove(userID);
|
||||
}
|
||||
}
|
||||
m_dataStore.saveServiceManagementObservers(m_observers);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -166,52 +175,28 @@ Throws:
|
||||
*/
|
||||
void ServiceManagementService::sendNotification(User* user, const std::string& title, const std::string& message)
|
||||
{
|
||||
if (user)
|
||||
{
|
||||
if (m_observers.find(user->getId()) != -1)
|
||||
{
|
||||
Notification* notification =
|
||||
Factory::getObject<Notification>(
|
||||
user->getId(),
|
||||
user,
|
||||
title,
|
||||
message,
|
||||
util::Timestamp()
|
||||
);
|
||||
if (notification)
|
||||
{
|
||||
user->addNotification(notification);
|
||||
}
|
||||
else
|
||||
{
|
||||
throw std::runtime_error("Failed to create notification");
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: getObserverIDs
|
||||
Description: Retrieves the IDs of all observers currently attached to the
|
||||
ServiceManagementService.
|
||||
Parameters:
|
||||
- None
|
||||
Returns:
|
||||
- util::Vector<std::string>: Vector of observer user IDs
|
||||
*/
|
||||
util::Vector<std::string> ServiceManagementService::getObserverIDs()
|
||||
{
|
||||
util::Vector<std::string> observerIDs;
|
||||
int numberOfObservers = m_observers.getSize();
|
||||
for (int index = 0; index < numberOfObservers; index++)
|
||||
{
|
||||
User* observer = m_observers.getValueAt(index);
|
||||
if (observer)
|
||||
{
|
||||
observerIDs.push_back(observer->getId());
|
||||
}
|
||||
}
|
||||
return observerIDs;
|
||||
if (!user)
|
||||
{
|
||||
return;
|
||||
}
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
m_observers = m_dataStore.getServiceManagementObservers();
|
||||
if (m_observers.find(user->getId()) == -1)
|
||||
{
|
||||
return;
|
||||
}
|
||||
Notification* notification = Factory::getObject<Notification>(
|
||||
user->getId(),
|
||||
title,
|
||||
message,
|
||||
util::Timestamp());
|
||||
if (!notification)
|
||||
{
|
||||
throw std::runtime_error("Failed to create notification");
|
||||
}
|
||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
||||
m_dataStore.saveNotifications();
|
||||
}
|
||||
|
||||
/*
|
||||
|
||||
-2
@@ -53,6 +53,4 @@ public:
|
||||
void saveServiceBookings();
|
||||
void loadJobCards();
|
||||
void saveJobCards();
|
||||
void loadObservers();
|
||||
void saveObservers();
|
||||
};
|
||||
|
||||
+85
-101
@@ -20,6 +20,9 @@ Date:19-May-2026
|
||||
#include "UserManagementService.h"
|
||||
#include "Vector.h"
|
||||
#include "Validator.h"
|
||||
#include "Utility.h"
|
||||
#include "TrackedRecord.h"
|
||||
#include "DataStoreLockGuard.h"
|
||||
|
||||
/*
|
||||
Function: ensureAdminExists
|
||||
@@ -31,12 +34,13 @@ Return type: void
|
||||
*/
|
||||
void UserManagementService::ensureAdminExists()
|
||||
{
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& usersMap = m_dataStore.getUsers();
|
||||
int usersMapSize = usersMap.getSize();
|
||||
bool isAdminFound = false;
|
||||
for (int index = 0; index < usersMapSize; index++)
|
||||
{
|
||||
User* user = usersMap.getValueAt(index);
|
||||
User* user = usersMap.getValueAt(index).data;
|
||||
if (user && user->getUserType() == util::UserType::ADMIN)
|
||||
{
|
||||
isAdminFound = true;
|
||||
@@ -73,7 +77,9 @@ void UserManagementService::createUser(const std::string& username, const std::s
|
||||
InventoryManagementService inventoryManagementService;
|
||||
PaymentManagementService paymentManagementService;
|
||||
ServiceManagementService serviceManagementService;
|
||||
auto& usersMap = m_dataStore.getUsers();
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||
auto usersMap = util::getObjects(trackedUsersMap);
|
||||
if (util::isUsernameDuplicate(username, usersMap))
|
||||
{
|
||||
throw std::runtime_error("Username already exists");
|
||||
@@ -87,13 +93,14 @@ void UserManagementService::createUser(const std::string& username, const std::s
|
||||
throw std::runtime_error("Phone already exists");
|
||||
}
|
||||
User* newUser = Factory::getObject<User>(username, password, name, phone, email, type);
|
||||
usersMap.insert(newUser->getId(), newUser);
|
||||
trackedUsersMap.insert(newUser->getId(), util::createNewRecord(newUser));
|
||||
paymentManagementService.attach(newUser);
|
||||
serviceManagementService.attach(newUser);
|
||||
if (newUser->getUserType() == util::UserType::ADMIN)
|
||||
{
|
||||
inventoryManagementService.attach(newUser);
|
||||
}
|
||||
m_dataStore.saveUsers();
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -107,19 +114,24 @@ Return type: void
|
||||
*/
|
||||
void UserManagementService::updateUserDetails(const std::string& userID, const std::string& email, const std::string& phone)
|
||||
{
|
||||
auto& usersMap = m_dataStore.getUsers();
|
||||
int index = usersMap.find(userID);
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||
auto usersMap = util::getObjects(trackedUsersMap);
|
||||
int index = trackedUsersMap.find(userID);
|
||||
if (index == -1)
|
||||
{
|
||||
throw std::runtime_error("User does not exist!\n");
|
||||
}
|
||||
User* user = usersMap.getValueAt(index);
|
||||
User* user = trackedUsersMap.getValueAt(index).data;
|
||||
bool isModified = false;
|
||||
if (email != user->getEmail())
|
||||
{
|
||||
if (util::isEmailDuplicate(email, usersMap))
|
||||
{
|
||||
throw std::runtime_error("Email already exists!\n");
|
||||
}
|
||||
user->setEmail(email);
|
||||
isModified = true;
|
||||
}
|
||||
if (phone != user->getPhone())
|
||||
{
|
||||
@@ -127,9 +139,14 @@ void UserManagementService::updateUserDetails(const std::string& userID, const s
|
||||
{
|
||||
throw std::runtime_error("Phone number already exists!\n");
|
||||
}
|
||||
user->setPhone(phone);
|
||||
isModified = true;
|
||||
}
|
||||
if (isModified)
|
||||
{
|
||||
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
||||
m_dataStore.saveUsers();
|
||||
}
|
||||
user->setEmail(email);
|
||||
user->setPhone(phone);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -144,21 +161,27 @@ Throws:
|
||||
*/
|
||||
util::Vector<Notification*> UserManagementService::getUserNotifications(const std::string& userID)
|
||||
{
|
||||
auto& usersMap = m_dataStore.getUsers();
|
||||
if (usersMap.find(userID) == -1)
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||
if (trackedUsersMap.find(userID) == -1)
|
||||
{
|
||||
throw std::runtime_error("No user found with given UserID");
|
||||
}
|
||||
User* user = usersMap[userID];
|
||||
User* user = trackedUsersMap[userID].data;
|
||||
if (user)
|
||||
{
|
||||
auto& notifications = user->getNotifications();
|
||||
int numberOfNotifications = notifications.getSize();
|
||||
auto& trackedNotificationMap = m_dataStore.getNotifications();
|
||||
int numberOfNotifications = trackedNotificationMap.getSize();
|
||||
util::Vector<Notification*> notificationsVector;
|
||||
for (int index = 0; index < numberOfNotifications; index++)
|
||||
{
|
||||
notificationsVector.push_back(notifications.getValueAt(index));
|
||||
Notification* notification = trackedNotificationMap.getValueAt(index).data;
|
||||
if (notification->getRecipientUserId() == userID && notification->getState() == util::State::ACTIVE)
|
||||
{
|
||||
notificationsVector.push_back(notification);
|
||||
}
|
||||
}
|
||||
m_dataStore.unlockDataStore();
|
||||
return notificationsVector;
|
||||
}
|
||||
else
|
||||
@@ -169,97 +192,36 @@ util::Vector<Notification*> UserManagementService::getUserNotifications(const st
|
||||
|
||||
/*
|
||||
Function: deleteNotification
|
||||
Description: Deletes a specific notification associated with a given user ID.
|
||||
Description: Marks a specific notification associated with a given user
|
||||
as inactive.
|
||||
Parameters:
|
||||
- notificationID: The unique ID of the notification to be deleted.
|
||||
- userID: The unique ID of the user whose notification is to be deleted.
|
||||
Returns:
|
||||
- void
|
||||
Throws:
|
||||
- std::runtime_error if no user is found with the given UserID or if no notification is found with the given NotificationID.
|
||||
- std::runtime_error if no user is found with the given UserID or
|
||||
if no notification is found with the given NotificationID.
|
||||
*/
|
||||
void UserManagementService::deleteNotification(const std::string& notificationID, const std::string& userID)
|
||||
{
|
||||
auto& usersMap = m_dataStore.getUsers();
|
||||
if (usersMap.find(userID) == -1)
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||
int userIndex = trackedUsersMap.find(userID);
|
||||
if (userIndex == -1)
|
||||
{
|
||||
throw std::runtime_error("No user found with given UserID");
|
||||
}
|
||||
User* user = usersMap[userID];
|
||||
auto& notifications = user->getNotifications();
|
||||
if (notifications.find(notificationID) == -1)
|
||||
User* user = trackedUsersMap.getValueAt(userIndex).data;
|
||||
int notificationIndex = trackedNotificationsMap.find(notificationID);
|
||||
if (notificationIndex == -1)
|
||||
{
|
||||
throw std::runtime_error("No notification found with given NotificationID");
|
||||
}
|
||||
notifications.remove(notificationID);
|
||||
}
|
||||
|
||||
/*
|
||||
Function: loadUsers
|
||||
Description: Loads users and notifications from persistent storage into the datastore.
|
||||
Validates that each notification’s recipient exists and attaches the
|
||||
notification to the corresponding user.
|
||||
Parameters:
|
||||
- None
|
||||
Returns:
|
||||
- void
|
||||
Throws:
|
||||
- std::runtime_error if a notification recipient user ID is invalid
|
||||
*/
|
||||
void UserManagementService::loadUsers()
|
||||
{
|
||||
util::FileManager<User> userFileManager(config::file::USER_FILE);
|
||||
util::FileManager<Notification> notificationFileManager(config::file::NOTIFICATION_FILE);
|
||||
auto& users = m_dataStore.getUsers();
|
||||
auto usersMap = userFileManager.load();
|
||||
auto notificationsMap = notificationFileManager.load();
|
||||
int numberOfUsers = usersMap.getSize();
|
||||
int numberOfNotifications = notificationsMap.getSize();
|
||||
for (int index = 0; index < numberOfUsers; index++)
|
||||
{
|
||||
users[usersMap.getKeyAt(index)] = usersMap.getValueAt(index);
|
||||
}
|
||||
for (int index = 0; index < numberOfNotifications; index++)
|
||||
{
|
||||
Notification* notification = notificationsMap.getValueAt(index);
|
||||
const std::string& recipientUserId = notification->getRecipientUserId();
|
||||
int userIndex = users.find(recipientUserId);
|
||||
if (userIndex == -1)
|
||||
{
|
||||
throw std::runtime_error("Invalid recipient user ID");
|
||||
}
|
||||
User* user = users.getValueAt(userIndex);
|
||||
user->addNotification(notification);
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: saveUsers
|
||||
Description: Saves users and their notifications from the datastore to persistent storage.
|
||||
Collects notifications from all users into a single map before saving.
|
||||
Parameters:
|
||||
- None
|
||||
Returns:
|
||||
- void
|
||||
*/
|
||||
void UserManagementService::saveUsers()
|
||||
{
|
||||
util::FileManager<User> userFileManager(config::file::USER_FILE);
|
||||
util::FileManager<Notification> notificationFileManager(config::file::NOTIFICATION_FILE);
|
||||
auto& users = m_dataStore.getUsers();
|
||||
util::Map<std::string, Notification*> notifications;
|
||||
for (int userIndex = 0; userIndex < users.getSize(); userIndex++)
|
||||
{
|
||||
User* user = users.getValueAt(userIndex);
|
||||
auto& userNotifications = user->getNotifications();
|
||||
for (int notificationIndex = 0; notificationIndex < userNotifications.getSize(); notificationIndex++)
|
||||
{
|
||||
notifications[userNotifications.getKeyAt(notificationIndex)] =
|
||||
userNotifications.getValueAt(notificationIndex);
|
||||
}
|
||||
}
|
||||
userFileManager.save(users);
|
||||
notificationFileManager.save(notifications);
|
||||
trackedNotificationsMap.getValueAt(notificationIndex).data->setState(util::State::INACTIVE);
|
||||
trackedNotificationsMap.getValueAt(notificationIndex).state = RecordState::MODIFIED;
|
||||
m_dataStore.saveNotifications();
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -270,7 +232,9 @@ Return type: util::Map<std::string, User*>
|
||||
*/
|
||||
util::Map<std::string, User*> UserManagementService::getUsers()
|
||||
{
|
||||
return m_dataStore.getUsers();
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto users = util::getObjects(m_dataStore.getUsers());
|
||||
return users;
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -281,10 +245,12 @@ Return type: User*
|
||||
*/
|
||||
User* UserManagementService::getUser(const std::string& userID)
|
||||
{
|
||||
int index = m_dataStore.getUsers().find(userID);
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||
int index = trackedUsersMap.find(userID);
|
||||
if (index != -1)
|
||||
{
|
||||
return m_dataStore.getUsers().getValueAt(index);
|
||||
return trackedUsersMap.getValueAt(index).data;
|
||||
}
|
||||
return nullptr;
|
||||
}
|
||||
@@ -300,35 +266,53 @@ void UserManagementService::removeUser(const std::string& userID)
|
||||
InventoryManagementService inventoryManagementService;
|
||||
PaymentManagementService paymentManagementService;
|
||||
ServiceManagementService serviceManagementService;
|
||||
int index = m_dataStore.getUsers().find(userID);
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||
int index = trackedUsersMap.find(userID);
|
||||
if (index != -1)
|
||||
{
|
||||
User* user = m_dataStore.getUsers().getValueAt(index);
|
||||
User* user = trackedUsersMap.getValueAt(index).data;
|
||||
if (user != nullptr)
|
||||
{
|
||||
if (user->getUserType() == util::UserType::CUSTOMER)
|
||||
{
|
||||
serviceManagementService.cancelCustomerServiceBookings(userID);
|
||||
serviceManagementService.cancelCustomerServiceBookings(userID);
|
||||
}
|
||||
if (user->getUserType() == util::UserType::TECHNICIAN)
|
||||
{
|
||||
serviceManagementService.cancelTechnicianJobs(userID);
|
||||
}
|
||||
user->setState(util::State::INACTIVE);
|
||||
inventoryManagementService.detach(user);
|
||||
paymentManagementService.detach(user);
|
||||
serviceManagementService.detach(user);
|
||||
user->setState(util::State::INACTIVE);
|
||||
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
||||
m_dataStore.saveUsers();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
util::Map<std::string, User*> UserManagementService::getUsers(util::UserType type)
|
||||
/*
|
||||
Function: getUsers
|
||||
Description: Retrieves all active users of the specified type from
|
||||
the DataStore.
|
||||
Parameters:
|
||||
- type: The user type to filter by
|
||||
(ADMIN, CUSTOMER, or TECHNICIAN).
|
||||
Returns:
|
||||
- util::Map<std::string, User*>:
|
||||
Collection of active users matching the specified type,
|
||||
keyed by user ID.
|
||||
*/
|
||||
util::Map<std::string, User*> UserManagementService::getUsers(util::UserType type)
|
||||
{
|
||||
util::Map<std::string, User*>& currentUsers = m_dataStore.getUsers();
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||
util::Map<std::string, User*> currentUsers = util::getObjects(trackedUsersMap);
|
||||
util::Map<std::string, User*> filteredUsersMap;
|
||||
for (int iterator = 0; iterator < currentUsers.getSize(); iterator++)
|
||||
for (int index = 0; index < currentUsers.getSize(); index++)
|
||||
{
|
||||
User* currentUser = currentUsers.getValueAt(iterator);
|
||||
User* currentUser = currentUsers.getValueAt(index);
|
||||
if (currentUser && currentUser->getState() == util::State::ACTIVE && currentUser->getUserType() == type)
|
||||
{
|
||||
filteredUsersMap.insert(currentUser->getId(), currentUser);
|
||||
|
||||
-2
@@ -31,6 +31,4 @@ public:
|
||||
util::Vector<Notification*> getUserNotifications(const std::string& userID);
|
||||
void deleteNotification(const std::string& notificationID, const std::string& userID);
|
||||
void ensureAdminExists();
|
||||
void loadUsers();
|
||||
void saveUsers();
|
||||
};
|
||||
|
||||
@@ -29,6 +29,7 @@ namespace config
|
||||
namespace file
|
||||
{
|
||||
const size_t INITIAL_CAPACITY = 100;
|
||||
const size_t GROWTH_FACTOR = 2;
|
||||
constexpr const char* DIRECTORY = "files/";
|
||||
constexpr const char* INVENTORYITEM_FILE = "files/InventoryItem.dat";
|
||||
constexpr const char* USER_FILE = "files/User.dat";
|
||||
|
||||
@@ -27,8 +27,11 @@ void UserInterface::run()
|
||||
{
|
||||
try
|
||||
{
|
||||
m_controller.loadSystemData();
|
||||
m_controller.runSystemChecks();
|
||||
if (!m_controller.initialize())
|
||||
{
|
||||
std::cout << "Error: Failed to initialize the system!";
|
||||
return;
|
||||
}
|
||||
bool isMenuActive = true;
|
||||
while (isMenuActive)
|
||||
{
|
||||
@@ -49,7 +52,7 @@ void UserInterface::run()
|
||||
util::pressEnter();
|
||||
}
|
||||
}
|
||||
m_controller.saveSystemData();
|
||||
m_controller.shutdown();
|
||||
}
|
||||
catch (const std::invalid_argument& exception)
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user