wlan-cloud-ucentralsec/src/ActionLinkManager.cpp

//
// Created by stephane bourque on 2021-11-08.
//

#include "ActionLinkManager.h"
#include "StorageService.h"
#include "RESTObjects/RESTAPI_SecurityObjects.h"

namespace OpenWifi {

    int ActionLinkManager::Start() {
        if(!Running_)
            Thr_.start(*this);
        return 0;
    }

    void ActionLinkManager::Stop() {
        if(Running_) {
            Running_ = false;
            Thr_.wakeUp();
            Thr_.join();
        }
    }

    void ActionLinkManager::run() {
        Running_ = true ;

        while(Running_) {
            Poco::Thread::trySleep(2000);
            if(!Running_)
                break;
            std::vector<SecurityObjects::ActionLink>    Links;
            {
                std::lock_guard G(Mutex_);
                StorageService()->GetActions(Links);
            }

            if(Links.empty())
                continue;

            for(auto &i:Links) {
                if(!Running_)
                    break;

                SecurityObjects::UserInfo UInfo;
                if(!StorageService()->GetUserById(i.userId,UInfo)) {
                    StorageService()->CancelAction(i.id);
                    continue;
                }

                if(i.action==OpenWifi::SecurityObjects::LinkActions::FORGOT_PASSWORD) {
                    if(AuthService::SendEmailToUser(i.id, UInfo.email, AuthService::FORGOT_PASSWORD)) {
                        Logger_.information(Poco::format("Send password reset link to %s",UInfo.email));
                    }
                    StorageService()->SentAction(i.id);
                } else if (i.action==OpenWifi::SecurityObjects::LinkActions::VERIFY_EMAIL) {
                    if(AuthService::SendEmailToUser(i.id, UInfo.email, AuthService::EMAIL_VERIFICATION)) {
                        Logger_.information(Poco::format("Send email verification link to %s",UInfo.email));
                    }
                    StorageService()->SentAction(i.id);
                } else {
                    StorageService()->SentAction(i.id);
                }
            }
        }
    }

}