Implement interprocess event handling for notifications and account disable
Changes: - Implements #2061 - Introduce EventManager for user-specific Windows event publishing/listening - Add real-time notification and account-disabled event propagation - Register authentication events through Controller and AuthenticationManagementService - Trigger notification events from Inventory, Payment, and Service Management modules - Trigger account-disabled events when users are deactivated - Extract common menu event listener logic into Menu base class - Add notification popup handling for Admin, Customer, and Technician menus - Refactor shared memory components into core/sharedmemory - Update project structure and include paths for events and shared memory modules
This commit is contained in:
+13
-9
@@ -102,7 +102,7 @@
|
||||
<SDLCheck>true</SDLCheck>
|
||||
<PreprocessorDefinitions>_DEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>
|
||||
<ConformanceMode>true</ConformanceMode>
|
||||
<AdditionalIncludeDirectories>$(ProjectDir)models;$(ProjectDir)controllers;$(ProjectDir)factories;$(ProjectDir)views;$(ProjectDir)services;$(ProjectDir)utilities;$(ProjectDir)core\patterns;$(ProjectDir)datastores;$(ProjectDir)datastores\sharedmemory;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
|
||||
<AdditionalIncludeDirectories>$(ProjectDir)models;$(ProjectDir)controllers;$(ProjectDir)factories;$(ProjectDir)views;$(ProjectDir)services;$(ProjectDir)utilities;$(ProjectDir)core\patterns;$(ProjectDir)datastores;$(ProjectDir)core\sharedmemory;$(ProjectDir)core\events;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
|
||||
</ClCompile>
|
||||
<Link>
|
||||
<SubSystem>Console</SubSystem>
|
||||
@@ -117,7 +117,7 @@
|
||||
<SDLCheck>true</SDLCheck>
|
||||
<PreprocessorDefinitions>NDEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>
|
||||
<ConformanceMode>true</ConformanceMode>
|
||||
<AdditionalIncludeDirectories>$(ProjectDir)models;$(ProjectDir)controllers;$(ProjectDir)factories;$(ProjectDir)views;$(ProjectDir)services;$(ProjectDir)utilities;$(ProjectDir)core\patterns;$(ProjectDir)datastores;$(ProjectDir)datastores\sharedmemory;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
|
||||
<AdditionalIncludeDirectories>$(ProjectDir)models;$(ProjectDir)controllers;$(ProjectDir)factories;$(ProjectDir)views;$(ProjectDir)services;$(ProjectDir)utilities;$(ProjectDir)core\patterns;$(ProjectDir)datastores;$(ProjectDir)core\sharedmemory;$(ProjectDir)core\events;%(AdditionalIncludeDirectories)</AdditionalIncludeDirectories>
|
||||
</ClCompile>
|
||||
<Link>
|
||||
<SubSystem>Console</SubSystem>
|
||||
@@ -126,10 +126,11 @@
|
||||
</ItemDefinitionGroup>
|
||||
<ItemGroup>
|
||||
<ClCompile Include="controllers\Controller.cpp" />
|
||||
<ClCompile Include="core\events\EventManager.cpp" />
|
||||
<ClCompile Include="core\patterns\Observer.cpp" />
|
||||
<ClCompile Include="core\patterns\Subject.cpp" />
|
||||
<ClCompile Include="core\sharedmemory\SharedMemory.cpp" />
|
||||
<ClCompile Include="datastores\DataStore.cpp" />
|
||||
<ClCompile Include="datastores\sharedmemory\SharedMemory.cpp" />
|
||||
<ClCompile Include="models\ComboPackage.cpp" />
|
||||
<ClCompile Include="models\InventoryItem.cpp" />
|
||||
<ClCompile Include="models\Invoice.cpp" />
|
||||
@@ -148,21 +149,23 @@
|
||||
<ClCompile Include="utilities\Validator.cpp" />
|
||||
<ClCompile Include="views\AdminMenu.cpp" />
|
||||
<ClCompile Include="views\CustomerMenu.cpp" />
|
||||
<ClCompile Include="views\Menu.cpp" />
|
||||
<ClCompile Include="views\TechnicianMenu.cpp" />
|
||||
<ClCompile Include="views\UserInterface.cpp" />
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<ClInclude Include="controllers\Controller.h" />
|
||||
<ClInclude Include="core\events\EventManager.h" />
|
||||
<ClInclude Include="core\patterns\Observer.h" />
|
||||
<ClInclude Include="core\patterns\Subject.h" />
|
||||
<ClInclude Include="core\sharedmemory\FileHeader.h" />
|
||||
<ClInclude Include="core\sharedmemory\MappingInfo.h" />
|
||||
<ClInclude Include="core\sharedmemory\RecordState.h" />
|
||||
<ClInclude Include="core\sharedmemory\SerializedRecords.h" />
|
||||
<ClInclude Include="core\sharedmemory\SharedMemory.h" />
|
||||
<ClInclude Include="core\sharedmemory\TrackedRecord.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" />
|
||||
<ClInclude Include="datastores\sharedmemory\SerializedRecords.h" />
|
||||
<ClInclude Include="datastores\sharedmemory\SharedMemory.h" />
|
||||
<ClInclude Include="datastores\sharedmemory\TrackedRecord.h" />
|
||||
<ClInclude Include="factories\Factory.h" />
|
||||
<ClInclude Include="models\ComboPackage.h" />
|
||||
<ClInclude Include="models\InventoryItem.h" />
|
||||
@@ -191,6 +194,7 @@
|
||||
<ClInclude Include="utilities\Vector.h" />
|
||||
<ClInclude Include="views\AdminMenu.h" />
|
||||
<ClInclude Include="views\CustomerMenu.h" />
|
||||
<ClInclude Include="views\Menu.h" />
|
||||
<ClInclude Include="views\MenuHelper.h" />
|
||||
<ClInclude Include="views\TechnicianMenu.h" />
|
||||
<ClInclude Include="views\UserInterface.h" />
|
||||
|
||||
+42
-24
@@ -64,11 +64,17 @@
|
||||
<Filter Include="Source Files\Core\Patterns">
|
||||
<UniqueIdentifier>{8057b93d-51a9-42df-b06e-01ce395f6308}</UniqueIdentifier>
|
||||
</Filter>
|
||||
<Filter Include="Header Files\DataStores\SharedMemory">
|
||||
<UniqueIdentifier>{ec639004-44c6-4bd6-9963-077adde82b5f}</UniqueIdentifier>
|
||||
<Filter Include="Header Files\Core\SharedMemory">
|
||||
<UniqueIdentifier>{d9da9793-fe6f-4914-bee3-99d5934da228}</UniqueIdentifier>
|
||||
</Filter>
|
||||
<Filter Include="Source Files\DataStores\SharedMemory">
|
||||
<UniqueIdentifier>{7aa8722e-adfa-466e-8211-de63f3b7892b}</UniqueIdentifier>
|
||||
<Filter Include="Source Files\Core\SharedMemory">
|
||||
<UniqueIdentifier>{0769afb6-f57d-4ae3-a1cf-ceca6e606af0}</UniqueIdentifier>
|
||||
</Filter>
|
||||
<Filter Include="Header Files\Core\Events">
|
||||
<UniqueIdentifier>{85029bdb-6941-41dc-a3a7-9e5841671d8c}</UniqueIdentifier>
|
||||
</Filter>
|
||||
<Filter Include="Source Files\Core\Events">
|
||||
<UniqueIdentifier>{1050aca7-6f2c-4ccb-a446-db9c898c3599}</UniqueIdentifier>
|
||||
</Filter>
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
@@ -144,8 +150,14 @@
|
||||
<ClCompile Include="models\ComboPackage.cpp">
|
||||
<Filter>Source Files\Models</Filter>
|
||||
</ClCompile>
|
||||
<ClCompile Include="datastores\sharedmemory\SharedMemory.cpp">
|
||||
<Filter>Source Files\DataStores\SharedMemory</Filter>
|
||||
<ClCompile Include="core\sharedmemory\SharedMemory.cpp">
|
||||
<Filter>Source Files\Core\SharedMemory</Filter>
|
||||
</ClCompile>
|
||||
<ClCompile Include="core\events\EventManager.cpp">
|
||||
<Filter>Source Files\Core\Events</Filter>
|
||||
</ClCompile>
|
||||
<ClCompile Include="views\Menu.cpp">
|
||||
<Filter>Source Files\Views</Filter>
|
||||
</ClCompile>
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
@@ -254,26 +266,32 @@
|
||||
<ClInclude Include="views\MenuHelper.h">
|
||||
<Filter>Header Files\Views</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="datastores\sharedmemory\FileHeader.h">
|
||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="datastores\sharedmemory\MappingInfo.h">
|
||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="datastores\sharedmemory\RecordState.h">
|
||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="datastores\sharedmemory\TrackedRecord.h">
|
||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="datastores\sharedmemory\SerializedRecords.h">
|
||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="datastores\sharedmemory\SharedMemory.h">
|
||||
<Filter>Header Files\DataStores\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="datastores\DataStoreLockGuard.h">
|
||||
<Filter>Header Files\DataStores</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="core\sharedmemory\FileHeader.h">
|
||||
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="core\sharedmemory\MappingInfo.h">
|
||||
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="core\sharedmemory\RecordState.h">
|
||||
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="core\sharedmemory\SerializedRecords.h">
|
||||
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="core\sharedmemory\SharedMemory.h">
|
||||
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="core\sharedmemory\TrackedRecord.h">
|
||||
<Filter>Header Files\Core\SharedMemory</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="core\events\EventManager.h">
|
||||
<Filter>Header Files\Core\Events</Filter>
|
||||
</ClInclude>
|
||||
<ClInclude Include="views\Menu.h">
|
||||
<Filter>Header Files\Views</Filter>
|
||||
</ClInclude>
|
||||
</ItemGroup>
|
||||
</Project>
|
||||
@@ -622,3 +622,16 @@ void Controller::shutdown()
|
||||
auto& dataStore = DataStore::getInstance();
|
||||
dataStore.shutdown();
|
||||
}
|
||||
|
||||
/*
|
||||
Function: registerEvents
|
||||
Description: Registers menu event handles with the authentication
|
||||
service.
|
||||
Parameter: HANDLE accountDisabledEvent - account disabled event handle
|
||||
HANDLE notificationAvailableEvent - notification event handle
|
||||
Return type: void
|
||||
*/
|
||||
void Controller::registerEvents(HANDLE accountDisabledEvent, HANDLE notificationAvailableEvent)
|
||||
{
|
||||
m_authenticationManagementService.registerEvents(accountDisabledEvent, notificationAvailableEvent);
|
||||
}
|
||||
|
||||
@@ -8,6 +8,7 @@ Date:19-May-2026
|
||||
*/
|
||||
|
||||
#pragma once
|
||||
#include <windows.h>
|
||||
#include <string>
|
||||
#include "AuthenticationManagementService.h"
|
||||
#include "Enums.h"
|
||||
@@ -72,4 +73,5 @@ public:
|
||||
void configureNotifications(bool paymentNotifications, bool serviceNotifications);
|
||||
bool initialize();
|
||||
void shutdown();
|
||||
void registerEvents(HANDLE accountDisabledEvent, HANDLE notificationAvailableEvent);
|
||||
};
|
||||
+225
@@ -0,0 +1,225 @@
|
||||
/*
|
||||
File: EventManager.cpp
|
||||
Description: Implementation file containing the method definitions of the
|
||||
EventManager class, including listener management and
|
||||
interprocess event publishing.
|
||||
Author: Trenser
|
||||
Date:15-Jun-2026
|
||||
*/
|
||||
|
||||
#include <iostream>
|
||||
#include <stdexcept>
|
||||
#include "EventManager.h"
|
||||
|
||||
namespace
|
||||
{
|
||||
const std::string USER_DISABLED_EVENT = "userDisabled_";
|
||||
|
||||
const std::string NOTIFICATION_AVAILABLE_EVENT = "notificationAvailable_";
|
||||
}
|
||||
|
||||
/*
|
||||
Function: EventManager
|
||||
Description: Constructs an EventManager instance with default values.
|
||||
Parameter: None
|
||||
Return type: None
|
||||
*/
|
||||
EventManager::EventManager()
|
||||
:
|
||||
m_userDisabledEvent(NULL),
|
||||
m_notificationAvailableEvent(NULL),
|
||||
m_shutdownEvent(NULL),
|
||||
m_running(false) {}
|
||||
|
||||
/*
|
||||
Function: ~EventManager
|
||||
Description: Destroys the EventManager and performs final cleanup.
|
||||
Parameter: None
|
||||
Return type: None
|
||||
*/
|
||||
EventManager::~EventManager()
|
||||
{
|
||||
shutdown();
|
||||
if (m_listenerThread.joinable())
|
||||
{
|
||||
m_listenerThread.join();
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: initialize
|
||||
Description: Creates the user-specific events and starts the listener
|
||||
thread.
|
||||
Parameter: const std::string& userId - unique identifier of the user
|
||||
std::function<void()> userDisabledCallback - callback for
|
||||
user disable events
|
||||
std::function<void()> notificationCallback - callback for
|
||||
notification events
|
||||
Return type: bool - true if initialization succeeds, false otherwise
|
||||
*/
|
||||
bool EventManager::initialize(const std::string& userId, std::function<void()> userDisabledCallback, std::function<void()> notificationCallback)
|
||||
{
|
||||
if (m_running.load())
|
||||
{
|
||||
return false;
|
||||
}
|
||||
m_userDisabledCallback = userDisabledCallback;
|
||||
m_notificationCallback = notificationCallback;
|
||||
m_userDisabledEvent = CreateEventA(NULL, FALSE, FALSE, (USER_DISABLED_EVENT + userId).c_str());
|
||||
if (!m_userDisabledEvent)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
if (GetLastError() == ERROR_ALREADY_EXISTS)
|
||||
{
|
||||
CloseHandle(m_userDisabledEvent);
|
||||
m_userDisabledEvent = NULL;
|
||||
throw std::runtime_error("Only one session allowed per user.");
|
||||
}
|
||||
m_notificationAvailableEvent = CreateEventA(NULL, FALSE, FALSE, (NOTIFICATION_AVAILABLE_EVENT + userId).c_str());
|
||||
if (!m_notificationAvailableEvent)
|
||||
{
|
||||
CloseHandle(m_userDisabledEvent);
|
||||
m_userDisabledEvent = NULL;
|
||||
return false;
|
||||
}
|
||||
m_shutdownEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
|
||||
if (!m_shutdownEvent)
|
||||
{
|
||||
CloseHandle(m_userDisabledEvent);
|
||||
CloseHandle(m_notificationAvailableEvent);
|
||||
m_userDisabledEvent = NULL;
|
||||
m_notificationAvailableEvent = NULL;
|
||||
return false;
|
||||
}
|
||||
m_running.store(true);
|
||||
m_listenerThread = std::thread(&EventManager::run, this);
|
||||
return true;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: shutdown
|
||||
Description: Stops the listener thread and releases event resources.
|
||||
Parameter: None
|
||||
Return type: None
|
||||
*/
|
||||
void EventManager::shutdown()
|
||||
{
|
||||
if (!m_running.load())
|
||||
{
|
||||
return;
|
||||
}
|
||||
m_running.store(false);
|
||||
if (m_shutdownEvent)
|
||||
{
|
||||
SetEvent(m_shutdownEvent);
|
||||
}
|
||||
if (m_listenerThread.joinable())
|
||||
{
|
||||
if (std::this_thread::get_id() != m_listenerThread.get_id())
|
||||
{
|
||||
m_listenerThread.join();
|
||||
}
|
||||
}
|
||||
if (m_userDisabledEvent)
|
||||
{
|
||||
CloseHandle(m_userDisabledEvent);
|
||||
m_userDisabledEvent = NULL;
|
||||
}
|
||||
if (m_notificationAvailableEvent)
|
||||
{
|
||||
CloseHandle(m_notificationAvailableEvent);
|
||||
m_notificationAvailableEvent = NULL;
|
||||
}
|
||||
if (m_shutdownEvent)
|
||||
{
|
||||
CloseHandle(m_shutdownEvent);
|
||||
m_shutdownEvent = NULL;
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: run
|
||||
Description: Waits for and dispatches user-related events.
|
||||
Parameter: None
|
||||
Return type: void
|
||||
*/
|
||||
void EventManager::run()
|
||||
{
|
||||
HANDLE handles[3];
|
||||
handles[0] = m_userDisabledEvent;
|
||||
handles[1] = m_notificationAvailableEvent;
|
||||
handles[2] = m_shutdownEvent;
|
||||
while (m_running.load())
|
||||
{
|
||||
DWORD result = WaitForMultipleObjects(3, handles, FALSE, INFINITE);
|
||||
switch (result)
|
||||
{
|
||||
case WAIT_OBJECT_0:
|
||||
try
|
||||
{
|
||||
if (m_userDisabledCallback)
|
||||
{
|
||||
m_userDisabledCallback();
|
||||
}
|
||||
}
|
||||
catch (const std::exception& exception)
|
||||
{
|
||||
std::cout << exception.what() << std::endl;
|
||||
}
|
||||
break;
|
||||
case WAIT_OBJECT_0 + 1:
|
||||
try
|
||||
{
|
||||
if (m_notificationCallback)
|
||||
{
|
||||
m_notificationCallback();
|
||||
}
|
||||
}
|
||||
catch (const std::exception& exception)
|
||||
{
|
||||
std::cout << exception.what() << std::endl;
|
||||
}
|
||||
break;
|
||||
case WAIT_OBJECT_0 + 2:
|
||||
return;
|
||||
default:
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: sendUserDisabledEvent
|
||||
Description: Publishes a user disabled event for a specific user.
|
||||
Parameter: const std::string& userId - target user identifier
|
||||
Return type: void
|
||||
*/
|
||||
void EventManager::sendUserDisabledEvent(const std::string& userId)
|
||||
{
|
||||
HANDLE eventHandle = CreateEventA(NULL, FALSE, FALSE, (USER_DISABLED_EVENT + userId).c_str());
|
||||
if (!eventHandle)
|
||||
{
|
||||
return;
|
||||
}
|
||||
SetEvent(eventHandle);
|
||||
CloseHandle(eventHandle);
|
||||
}
|
||||
|
||||
/*
|
||||
Function: sendNotificationAvailableEvent
|
||||
Description: Publishes a notification available event for a specific
|
||||
user.
|
||||
Parameter: const std::string& userId - target user identifier
|
||||
Return type: void
|
||||
*/
|
||||
void EventManager::sendNotificationAvailableEvent(const std::string& userId)
|
||||
{
|
||||
HANDLE eventHandle = CreateEventA(NULL, FALSE, FALSE, (NOTIFICATION_AVAILABLE_EVENT + userId).c_str());
|
||||
if (!eventHandle)
|
||||
{
|
||||
return;
|
||||
}
|
||||
SetEvent(eventHandle);
|
||||
CloseHandle(eventHandle);
|
||||
}
|
||||
@@ -0,0 +1,37 @@
|
||||
/*
|
||||
File: EventManager.h
|
||||
Description: Header file declaring the EventManager class, which manages
|
||||
user-specific interprocess events for user disable and
|
||||
notification availability updates.
|
||||
Author: Trenser
|
||||
Date:15-Jun-2026
|
||||
*/
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <windows.h>
|
||||
#include <atomic>
|
||||
#include <functional>
|
||||
#include <string>
|
||||
#include <thread>
|
||||
|
||||
class EventManager
|
||||
{
|
||||
private:
|
||||
HANDLE m_userDisabledEvent;
|
||||
HANDLE m_notificationAvailableEvent;
|
||||
HANDLE m_shutdownEvent;
|
||||
std::atomic<bool> m_running;
|
||||
std::thread m_listenerThread;
|
||||
std::function<void()> m_userDisabledCallback;
|
||||
std::function<void()> m_notificationCallback;
|
||||
void run();
|
||||
|
||||
public:
|
||||
EventManager();
|
||||
~EventManager();
|
||||
bool initialize(const std::string& userId, std::function<void()> userDisabledCallback, std::function<void()> notificationCallback);
|
||||
void shutdown();
|
||||
static void sendUserDisabledEvent(const std::string& userId);
|
||||
static void sendNotificationAvailableEvent(const std::string& userId);
|
||||
};
|
||||
+36
@@ -14,6 +14,9 @@ Date:19-May-2026
|
||||
#include "DataStoreLockGuard.h"
|
||||
|
||||
User* AuthenticationManagementService::m_authenticatedUser = nullptr;
|
||||
EventManager AuthenticationManagementService::m_eventManager;
|
||||
HANDLE AuthenticationManagementService::m_accountDisabledEvent = NULL;
|
||||
HANDLE AuthenticationManagementService::m_notificationsAvailableEvent = NULL;
|
||||
|
||||
/*
|
||||
Function: login
|
||||
@@ -37,6 +40,22 @@ bool AuthenticationManagementService::login(const std::string& username, const s
|
||||
if (password == user->getPassword())
|
||||
{
|
||||
m_authenticatedUser = user;
|
||||
m_eventManager.initialize(
|
||||
user->getId(),
|
||||
[]()
|
||||
{
|
||||
if (m_accountDisabledEvent)
|
||||
{
|
||||
SetEvent(m_accountDisabledEvent);
|
||||
}
|
||||
},
|
||||
[]()
|
||||
{
|
||||
if (m_notificationsAvailableEvent)
|
||||
{
|
||||
SetEvent(m_notificationsAvailableEvent);
|
||||
}
|
||||
});
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
@@ -65,7 +84,10 @@ Return type: void
|
||||
*/
|
||||
void AuthenticationManagementService::logout()
|
||||
{
|
||||
m_eventManager.shutdown();
|
||||
m_authenticatedUser = nullptr;
|
||||
m_accountDisabledEvent = NULL;
|
||||
m_notificationsAvailableEvent = NULL;
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -92,3 +114,17 @@ void AuthenticationManagementService::changePassword(const std::string& newPassw
|
||||
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
||||
m_dataStore.saveUsers();
|
||||
}
|
||||
|
||||
/*
|
||||
Function: registerEvents
|
||||
Description: Registers menu event handles used to notify the active
|
||||
menu of account disable and notification events.
|
||||
Parameter: HANDLE accountDisabledEvent - account disabled event handle
|
||||
HANDLE notificationAvailableEvent - notification event handle
|
||||
Return type: void
|
||||
*/
|
||||
void AuthenticationManagementService::registerEvents(HANDLE accountDisabledEvent, HANDLE notifictionAvailableEvent)
|
||||
{
|
||||
m_accountDisabledEvent = accountDisabledEvent;
|
||||
m_notificationsAvailableEvent = notifictionAvailableEvent;
|
||||
}
|
||||
|
||||
+6
@@ -9,6 +9,8 @@ Date:19-May-2026
|
||||
|
||||
#pragma once
|
||||
#include <string>
|
||||
#include <windows.h>
|
||||
#include "EventManager.h"
|
||||
#include "DataStore.h"
|
||||
|
||||
class User;
|
||||
@@ -17,6 +19,9 @@ class AuthenticationManagementService
|
||||
{
|
||||
private:
|
||||
static User* m_authenticatedUser;
|
||||
static EventManager m_eventManager;
|
||||
static HANDLE m_accountDisabledEvent;
|
||||
static HANDLE m_notificationsAvailableEvent;
|
||||
DataStore& m_dataStore;
|
||||
public:
|
||||
AuthenticationManagementService() : m_dataStore(DataStore::getInstance()) {}
|
||||
@@ -24,4 +29,5 @@ public:
|
||||
void logout();
|
||||
void changePassword(const std::string& newPassword);
|
||||
User* getAuthenticatedUser();
|
||||
void registerEvents(HANDLE accountDisabledEvent, HANDLE notificationAvailableEvent);
|
||||
};
|
||||
|
||||
+2
@@ -19,6 +19,7 @@ Date: 22-May-2026
|
||||
#include "Utility.h"
|
||||
#include "Vector.h"
|
||||
#include "DataStoreLockGuard.h"
|
||||
#include "EventManager.h"
|
||||
|
||||
util::Map<std::string, User*> InventoryManagementService::m_observers{};
|
||||
|
||||
@@ -281,5 +282,6 @@ void InventoryManagementService::sendNotification(User* user, const std::string&
|
||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
||||
m_dataStore.saveNotifications();
|
||||
EventManager::sendNotificationAvailableEvent(user->getId());
|
||||
}
|
||||
|
||||
|
||||
+2
@@ -22,6 +22,7 @@ Date: 20-May-2026
|
||||
#include "User.h"
|
||||
#include "Utility.h"
|
||||
#include "DataStoreLockGuard.h"
|
||||
#include "EventManager.h"
|
||||
|
||||
util::Map<std::string, User*> PaymentManagementService::m_observers{};
|
||||
|
||||
@@ -109,6 +110,7 @@ void PaymentManagementService::sendNotification(User* user, const std::string& t
|
||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
||||
m_dataStore.saveNotifications();
|
||||
EventManager::sendNotificationAvailableEvent(user->getId());
|
||||
}
|
||||
|
||||
/*
|
||||
|
||||
+2
@@ -27,6 +27,7 @@ Date:19-May-2026
|
||||
#include "DataStoreLockGuard.h"
|
||||
#include "Utility.h"
|
||||
#include "DataStoreLockGuard.h"
|
||||
#include "EventManager.h"
|
||||
|
||||
/*
|
||||
Function: purchaseService
|
||||
@@ -199,6 +200,7 @@ void ServiceManagementService::sendNotification(User* user, const std::string& t
|
||||
auto& trackedNotificationsMap = m_dataStore.getNotifications();
|
||||
trackedNotificationsMap.insert(notification->getId(), util::createNewRecord(notification));
|
||||
m_dataStore.saveNotifications();
|
||||
EventManager::sendNotificationAvailableEvent(user->getId());
|
||||
}
|
||||
|
||||
/*
|
||||
|
||||
+27
-18
@@ -22,6 +22,7 @@ Date:19-May-2026
|
||||
#include "Utility.h"
|
||||
#include "TrackedRecord.h"
|
||||
#include "DataStoreLockGuard.h"
|
||||
#include "EventManager.h"
|
||||
|
||||
/*
|
||||
Function: ensureAdminExists
|
||||
@@ -267,30 +268,38 @@ void UserManagementService::removeUser(const std::string& userID)
|
||||
InventoryManagementService inventoryManagementService;
|
||||
PaymentManagementService paymentManagementService;
|
||||
ServiceManagementService serviceManagementService;
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||
int index = trackedUsersMap.find(userID);
|
||||
if (index != -1)
|
||||
std::string removedUserID;
|
||||
{
|
||||
User* user = trackedUsersMap.getValueAt(index).data;
|
||||
if (user != nullptr)
|
||||
DataStoreLockGuard lock(m_dataStore);
|
||||
auto& trackedUsersMap = m_dataStore.getUsers();
|
||||
int index = trackedUsersMap.find(userID);
|
||||
if (index != -1)
|
||||
{
|
||||
if (user->getUserType() == util::UserType::CUSTOMER)
|
||||
User* user = trackedUsersMap.getValueAt(index).data;
|
||||
if (user != nullptr)
|
||||
{
|
||||
serviceManagementService.cancelCustomerServiceBookings(userID);
|
||||
if (user->getUserType() == util::UserType::CUSTOMER)
|
||||
{
|
||||
serviceManagementService.cancelCustomerServiceBookings(userID);
|
||||
}
|
||||
if (user->getUserType() == util::UserType::TECHNICIAN)
|
||||
{
|
||||
serviceManagementService.cancelTechnicianJobs(userID);
|
||||
}
|
||||
inventoryManagementService.detach(user);
|
||||
paymentManagementService.detach(user);
|
||||
serviceManagementService.detach(user);
|
||||
user->setState(util::State::INACTIVE);
|
||||
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
||||
removedUserID = user->getId();
|
||||
m_dataStore.saveUsers();
|
||||
}
|
||||
if (user->getUserType() == util::UserType::TECHNICIAN)
|
||||
{
|
||||
serviceManagementService.cancelTechnicianJobs(userID);
|
||||
}
|
||||
inventoryManagementService.detach(user);
|
||||
paymentManagementService.detach(user);
|
||||
serviceManagementService.detach(user);
|
||||
user->setState(util::State::INACTIVE);
|
||||
trackedUsersMap.getValueAt(index).state = RecordState::MODIFIED;
|
||||
m_dataStore.saveUsers();
|
||||
}
|
||||
}
|
||||
if (!removedUserID.empty())
|
||||
{
|
||||
EventManager::sendUserDisabledEvent(removedUserID);
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
|
||||
@@ -30,10 +30,16 @@ Return type: void
|
||||
*/
|
||||
void AdminMenu::showMenu()
|
||||
{
|
||||
startEventListener();
|
||||
while (true)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (!m_isMenuActive)
|
||||
{
|
||||
logout();
|
||||
break;
|
||||
}
|
||||
int choice;
|
||||
util::clear();
|
||||
std::cout << "Admin Menu"
|
||||
@@ -68,6 +74,7 @@ void AdminMenu::showMenu()
|
||||
util::pressEnter();
|
||||
}
|
||||
}
|
||||
stopEventListener();
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -78,6 +85,11 @@ Return type: bool - true if menu continues, false if logout
|
||||
*/
|
||||
bool AdminMenu::handleOperation(int choice)
|
||||
{
|
||||
if (!m_isMenuActive)
|
||||
{
|
||||
logout();
|
||||
return false;
|
||||
}
|
||||
switch (choice)
|
||||
{
|
||||
case 1:
|
||||
@@ -141,6 +153,19 @@ bool AdminMenu::handleOperation(int choice)
|
||||
return true;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: handleNotificationEvent
|
||||
Description: Retrieves and displays the latest notification for the
|
||||
currently logged in admin.
|
||||
Parameter: None
|
||||
Return type: void
|
||||
*/
|
||||
void AdminMenu::handleNotificationEvent()
|
||||
{
|
||||
auto notifications = m_controller.getNotifications();
|
||||
displayNewNotification(notifications);
|
||||
}
|
||||
|
||||
/*
|
||||
Function: logout
|
||||
Description: Logs out the currently authenticated admin user.
|
||||
|
||||
@@ -9,12 +9,13 @@ Date:19-May-2026
|
||||
|
||||
#pragma once
|
||||
#include "Controller.h"
|
||||
#include "Menu.h"
|
||||
|
||||
class AdminMenu
|
||||
class AdminMenu : public Menu
|
||||
{
|
||||
private:
|
||||
Controller m_controller;
|
||||
bool handleOperation(int choice);
|
||||
void handleNotificationEvent() override;
|
||||
public:
|
||||
void showMenu();
|
||||
void logout();
|
||||
|
||||
@@ -32,10 +32,17 @@ Return type: void
|
||||
*/
|
||||
void CustomerMenu::showMenu()
|
||||
{
|
||||
|
||||
startEventListener();
|
||||
while (true)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (!m_isMenuActive)
|
||||
{
|
||||
logout();
|
||||
break;
|
||||
}
|
||||
int choice;
|
||||
util::clear();
|
||||
std::cout << "Customer Menu"
|
||||
@@ -62,6 +69,7 @@ void CustomerMenu::showMenu()
|
||||
util::pressEnter();
|
||||
}
|
||||
}
|
||||
stopEventListener();
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -72,6 +80,11 @@ Return type: bool - true if menu continues, false if logout
|
||||
*/
|
||||
bool CustomerMenu::handleOperation(int choice)
|
||||
{
|
||||
if (!m_isMenuActive)
|
||||
{
|
||||
logout();
|
||||
return false;
|
||||
}
|
||||
switch (choice)
|
||||
{
|
||||
case 1:
|
||||
@@ -111,6 +124,19 @@ bool CustomerMenu::handleOperation(int choice)
|
||||
return true;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: handleNotificationEvent
|
||||
Description: Retrieves and displays the latest notification for the
|
||||
currently logged in admin.
|
||||
Parameter: None
|
||||
Return type: void
|
||||
*/
|
||||
void CustomerMenu::handleNotificationEvent()
|
||||
{
|
||||
auto notifications = m_controller.getNotifications();
|
||||
displayNewNotification(notifications);
|
||||
}
|
||||
|
||||
/*
|
||||
Function: logout
|
||||
Description: Logs out the currently authenticated customer user.
|
||||
|
||||
@@ -9,13 +9,14 @@ Date:19-May-2026
|
||||
*/
|
||||
|
||||
#pragma once
|
||||
#include "Menu.h"
|
||||
#include "Controller.h"
|
||||
|
||||
class CustomerMenu
|
||||
class CustomerMenu : public Menu
|
||||
{
|
||||
private:
|
||||
Controller m_controller;
|
||||
bool handleOperation(int choice);
|
||||
void handleNotificationEvent();
|
||||
public:
|
||||
void showMenu();
|
||||
void logout();
|
||||
|
||||
@@ -0,0 +1,144 @@
|
||||
/*
|
||||
File: Menu.cpp
|
||||
Description: Implementation file containing common menu event listener
|
||||
functionality, account disable handling, and notification
|
||||
event dispatching for all menu types.
|
||||
Author: Trenser
|
||||
Date:16-Jun-2026
|
||||
*/
|
||||
|
||||
#include "Menu.h"
|
||||
|
||||
/*
|
||||
Function: Menu
|
||||
Description: Constructs a Menu object and initializes event handles
|
||||
and menu state.
|
||||
Parameter: None
|
||||
Return type: None
|
||||
*/
|
||||
Menu::Menu()
|
||||
:
|
||||
m_isMenuActive(false),
|
||||
m_accountDisabledEvent(NULL),
|
||||
m_notificationAvailableEvent(NULL),
|
||||
m_shutdownEvent(NULL) {}
|
||||
|
||||
/*
|
||||
Function: ~Menu
|
||||
Description: Destroys the Menu object and performs event listener
|
||||
cleanup.
|
||||
Parameter: None
|
||||
Return type: None
|
||||
*/
|
||||
Menu::~Menu()
|
||||
{
|
||||
stopEventListener();
|
||||
}
|
||||
|
||||
/*
|
||||
Function: startEventListener
|
||||
Description: Creates menu event handles, registers them with the
|
||||
authentication service, and starts the event listener
|
||||
thread.
|
||||
Parameter: None
|
||||
Return type: void
|
||||
*/
|
||||
void Menu::startEventListener()
|
||||
{
|
||||
if (m_isMenuActive.load())
|
||||
{
|
||||
return;
|
||||
}
|
||||
m_isMenuActive.store(true);
|
||||
m_accountDisabledEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
|
||||
m_notificationAvailableEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
|
||||
m_shutdownEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
|
||||
m_controller.registerEvents(m_accountDisabledEvent, m_notificationAvailableEvent);
|
||||
m_eventListenerThread = std::thread(&Menu::eventListenerLoop, this);
|
||||
}
|
||||
|
||||
/*
|
||||
Function: eventListenerLoop
|
||||
Description: Waits for account disabled, notification available,
|
||||
and shutdown events and dispatches them to the
|
||||
appropriate handlers.
|
||||
Parameter: None
|
||||
Return type: void
|
||||
*/
|
||||
void Menu::eventListenerLoop()
|
||||
{
|
||||
HANDLE handles[3];
|
||||
handles[0] = m_accountDisabledEvent;
|
||||
handles[1] = m_notificationAvailableEvent;
|
||||
handles[2] = m_shutdownEvent;
|
||||
while (m_isMenuActive.load())
|
||||
{
|
||||
DWORD result = WaitForMultipleObjects(3, handles, FALSE, INFINITE);
|
||||
switch (result)
|
||||
{
|
||||
case WAIT_OBJECT_0:
|
||||
handleAccountDisabledEvent();
|
||||
break;
|
||||
case WAIT_OBJECT_0 + 1:
|
||||
handleNotificationEvent();
|
||||
break;
|
||||
case WAIT_OBJECT_0 + 2:
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: stopEventListener
|
||||
Description: Stops the event listener thread and releases all
|
||||
associated event handles.
|
||||
Parameter: None
|
||||
Return type: void
|
||||
*/
|
||||
void Menu::stopEventListener()
|
||||
{
|
||||
m_isMenuActive.store(false);
|
||||
if (m_shutdownEvent)
|
||||
{
|
||||
SetEvent(m_shutdownEvent);
|
||||
}
|
||||
if (m_eventListenerThread.joinable())
|
||||
{
|
||||
m_eventListenerThread.join();
|
||||
}
|
||||
if (m_accountDisabledEvent)
|
||||
{
|
||||
CloseHandle(m_accountDisabledEvent);
|
||||
}
|
||||
if (m_notificationAvailableEvent)
|
||||
{
|
||||
CloseHandle(m_notificationAvailableEvent);
|
||||
}
|
||||
if (m_shutdownEvent)
|
||||
{
|
||||
CloseHandle(m_shutdownEvent);
|
||||
}
|
||||
m_accountDisabledEvent = NULL;
|
||||
m_notificationAvailableEvent = NULL;
|
||||
m_shutdownEvent = NULL;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: handleAccountDisabledEvent
|
||||
Description: Handles an account disabled event by marking the menu
|
||||
inactive and notifying the user.
|
||||
Parameter: None
|
||||
Return type: void
|
||||
*/
|
||||
void Menu::handleAccountDisabledEvent()
|
||||
{
|
||||
m_isMenuActive.store(false);
|
||||
MessageBoxA(
|
||||
GetConsoleWindow(),
|
||||
"Your account has been disabled.",
|
||||
"Account Disabled",
|
||||
MB_OK |
|
||||
MB_ICONWARNING |
|
||||
MB_SETFOREGROUND |
|
||||
MB_TOPMOST);
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
/*
|
||||
File: Menu.h
|
||||
Description: Base class providing common event listener functionality
|
||||
for all menu implementations.
|
||||
Author: Trenser
|
||||
Date:16-Jun-2026
|
||||
*/
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <windows.h>
|
||||
#include <atomic>
|
||||
#include <thread>
|
||||
#include "Controller.h"
|
||||
|
||||
class Menu
|
||||
{
|
||||
protected:
|
||||
Controller m_controller;
|
||||
std::atomic<bool> m_isMenuActive;
|
||||
HANDLE m_accountDisabledEvent;
|
||||
HANDLE m_notificationAvailableEvent;
|
||||
HANDLE m_shutdownEvent;
|
||||
std::thread m_eventListenerThread;
|
||||
void startEventListener();
|
||||
void stopEventListener();
|
||||
void eventListenerLoop();
|
||||
void handleAccountDisabledEvent();
|
||||
virtual void handleNotificationEvent() = 0;
|
||||
public:
|
||||
Menu();
|
||||
virtual ~Menu();
|
||||
};
|
||||
@@ -1407,4 +1407,38 @@ inline std::string selectComboPackage(util::Map<std::string, const ComboPackage*
|
||||
std::cout << "Enter a valid choice.\n";
|
||||
return "";
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Function: displayNewNotification
|
||||
Description: Displays the most recent notification from the supplied
|
||||
notification collection.
|
||||
Parameter: util::Vector<const Notification*> notifications -
|
||||
collection of notifications
|
||||
Return type: void
|
||||
*/
|
||||
inline void displayNewNotification(util::Vector<const Notification*> notifications)
|
||||
{
|
||||
const Notification* notification = nullptr;
|
||||
size_t numberOfNotifications = notifications.getSize();
|
||||
for (int index = 0; index < numberOfNotifications; index++)
|
||||
{
|
||||
if (!notification)
|
||||
{
|
||||
notification = notifications[index];
|
||||
}
|
||||
else
|
||||
{
|
||||
if (notification->getId() < notifications[index]->getId())
|
||||
{
|
||||
notification = notifications[index];
|
||||
}
|
||||
}
|
||||
}
|
||||
MessageBoxA(
|
||||
GetConsoleWindow(),
|
||||
notification->getMessage().c_str(),
|
||||
notification->getTitle().c_str(),
|
||||
MB_OK |
|
||||
MB_ICONINFORMATION);
|
||||
}
|
||||
@@ -27,10 +27,16 @@ Returns:
|
||||
*/
|
||||
void TechnicianMenu::showMenu()
|
||||
{
|
||||
startEventListener();
|
||||
while (true)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (!m_isMenuActive)
|
||||
{
|
||||
logout();
|
||||
break;
|
||||
}
|
||||
int choice;
|
||||
util::clear();
|
||||
std::cout << "Technician Menu"
|
||||
@@ -52,6 +58,7 @@ void TechnicianMenu::showMenu()
|
||||
util::pressEnter();
|
||||
}
|
||||
}
|
||||
stopEventListener();
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -62,6 +69,11 @@ Return type: bool - true if menu continues, false if logout
|
||||
*/
|
||||
bool TechnicianMenu::handleOperation(int choice)
|
||||
{
|
||||
if (!m_isMenuActive)
|
||||
{
|
||||
logout();
|
||||
return false;
|
||||
}
|
||||
switch (choice)
|
||||
{
|
||||
case 1:
|
||||
@@ -86,6 +98,19 @@ bool TechnicianMenu::handleOperation(int choice)
|
||||
return true;
|
||||
}
|
||||
|
||||
/*
|
||||
Function: handleNotificationEvent
|
||||
Description: Retrieves and displays the latest notification for the
|
||||
currently logged in admin.
|
||||
Parameter: None
|
||||
Return type: void
|
||||
*/
|
||||
void TechnicianMenu::handleNotificationEvent()
|
||||
{
|
||||
auto notifications = m_controller.getNotifications();
|
||||
displayNewNotification(notifications);
|
||||
}
|
||||
|
||||
/*
|
||||
Function: displayJobs
|
||||
Description: Displays all Jobs assigned to a Technician
|
||||
|
||||
@@ -9,12 +9,13 @@ Date:19-May-2026
|
||||
|
||||
#pragma once
|
||||
#include "Controller.h"
|
||||
#include "Menu.h"
|
||||
|
||||
class TechnicianMenu
|
||||
class TechnicianMenu : public Menu
|
||||
{
|
||||
private:
|
||||
Controller m_controller;
|
||||
bool handleOperation(int choice);
|
||||
void handleNotificationEvent();
|
||||
public:
|
||||
void showMenu();
|
||||
void displayJobs();
|
||||
|
||||
Reference in New Issue
Block a user