mirror of
https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git
synced 2025-10-31 02:37:56 +00:00
316 lines
14 KiB
C++
316 lines
14 KiB
C++
//
|
|
// Created by stephane bourque on 2021-11-30.
|
|
//
|
|
|
|
#include "RESTAPI_subuser_handler.h"
|
|
#include "StorageService.h"
|
|
#include "framework/ow_constants.h"
|
|
#include "SMSSender.h"
|
|
#include "SMTPMailerService.h"
|
|
#include "ACLProcessor.h"
|
|
#include "AuthService.h"
|
|
#include "RESTAPI/RESTAPI_db_helpers.h"
|
|
#include "MFAServer.h"
|
|
#include "TotpCache.h"
|
|
|
|
namespace OpenWifi {
|
|
|
|
void RESTAPI_subuser_handler::DoGet() {
|
|
std::string Id = GetBinding("id", "");
|
|
if(Id.empty()) {
|
|
return BadRequest(RESTAPI::Errors::MissingUserID);
|
|
}
|
|
|
|
Poco::toLowerInPlace(Id);
|
|
std::string Arg;
|
|
SecurityObjects::UserInfo UInfo;
|
|
if(HasParameter("byEmail",Arg) && Arg=="true") {
|
|
if(!StorageService()->SubDB().GetUserByEmail(Id,UInfo)) {
|
|
return NotFound();
|
|
}
|
|
} else if(!StorageService()->SubDB().GetUserById(Id,UInfo)) {
|
|
return NotFound();
|
|
}
|
|
|
|
Poco::JSON::Object UserInfoObject;
|
|
Sanitize(UserInfo_, UInfo);
|
|
UInfo.to_json(UserInfoObject);
|
|
ReturnObject(UserInfoObject);
|
|
}
|
|
|
|
void RESTAPI_subuser_handler::DoDelete() {
|
|
std::string Id = GetBinding("id", "");
|
|
if(Id.empty()) {
|
|
return BadRequest(RESTAPI::Errors::MissingUserID);
|
|
}
|
|
|
|
SecurityObjects::UserInfo TargetUser;
|
|
if(!StorageService()->SubDB().GetUserById(Id,TargetUser)) {
|
|
return NotFound();
|
|
}
|
|
|
|
if(TargetUser.userRole != SecurityObjects::SUBSCRIBER) {
|
|
return BadRequest(RESTAPI::Errors::InvalidUserRole);
|
|
}
|
|
|
|
if(!Internal_ && !ACLProcessor::Can(UserInfo_.userinfo, TargetUser,ACLProcessor::DELETE)) {
|
|
return UnAuthorized(RESTAPI::Errors::ACCESS_DENIED);
|
|
}
|
|
|
|
if(!StorageService()->SubDB().DeleteUser(UserInfo_.userinfo.email,Id)) {
|
|
return NotFound();
|
|
}
|
|
|
|
AuthService()->DeleteSubUserFromCache(Id);
|
|
StorageService()->SubTokenDB().RevokeAllTokens(TargetUser.email);
|
|
StorageService()->SubPreferencesDB().DeleteRecord("id", Id);
|
|
StorageService()->SubAvatarDB().DeleteRecord("id", Id);
|
|
Logger_.information(fmt::format("User '{}' deleted by '{}'.",Id,UserInfo_.userinfo.email));
|
|
OK();
|
|
}
|
|
|
|
void RESTAPI_subuser_handler::DoPost() {
|
|
std::string Id = GetBinding("id", "");
|
|
if(Id!="0") {
|
|
return BadRequest(RESTAPI::Errors::IdMustBe0);
|
|
}
|
|
|
|
SecurityObjects::UserInfo NewUser;
|
|
const auto & RawObject = ParsedBody_;
|
|
if(!NewUser.from_json(RawObject)) {
|
|
return BadRequest(RESTAPI::Errors::InvalidJSONDocument);
|
|
}
|
|
|
|
if(NewUser.userRole == SecurityObjects::UNKNOWN || NewUser.userRole != SecurityObjects::SUBSCRIBER) {
|
|
return BadRequest(RESTAPI::Errors::InvalidUserRole);
|
|
}
|
|
|
|
Poco::toLowerInPlace(NewUser.email);
|
|
SecurityObjects::UserInfo Existing;
|
|
if(StorageService()->SubDB().GetUserByEmail(NewUser.email,Existing)) {
|
|
return BadRequest(RESTAPI::Errors::UserAlreadyExists);
|
|
}
|
|
|
|
if(!Internal_ && !ACLProcessor::Can(UserInfo_.userinfo,NewUser,ACLProcessor::CREATE)) {
|
|
return UnAuthorized(RESTAPI::Errors::ACCESS_DENIED);
|
|
}
|
|
|
|
Poco::toLowerInPlace(NewUser.email);
|
|
if(!Utils::ValidEMailAddress(NewUser.email)) {
|
|
return BadRequest(RESTAPI::Errors::InvalidEmailAddress);
|
|
}
|
|
|
|
if(!NewUser.currentPassword.empty()) {
|
|
if(!AuthService()->ValidateSubPassword(NewUser.currentPassword)) {
|
|
return BadRequest(RESTAPI::Errors::InvalidPassword);
|
|
}
|
|
}
|
|
|
|
if(NewUser.name.empty())
|
|
NewUser.name = NewUser.email;
|
|
|
|
// You cannot enable MFA during user creation
|
|
NewUser.userTypeProprietaryInfo.mfa.enabled = false;
|
|
NewUser.userTypeProprietaryInfo.mfa.method = "";
|
|
NewUser.userTypeProprietaryInfo.mobiles.clear();
|
|
NewUser.userTypeProprietaryInfo.authenticatorSecret.clear();
|
|
|
|
if(!StorageService()->SubDB().CreateUser(UserInfo_.userinfo.email, NewUser)) {
|
|
Logger_.information(fmt::format("Could not add user '{}'.",NewUser.email));
|
|
return BadRequest(RESTAPI::Errors::RecordNotCreated);
|
|
}
|
|
|
|
if(GetParameter("email_verification","false")=="true") {
|
|
if(AuthService::VerifySubEmail(NewUser))
|
|
Logger_.information(fmt::format("Verification e-mail requested for {}",NewUser.email));
|
|
StorageService()->SubDB().UpdateUserInfo(UserInfo_.userinfo.email,NewUser.id,NewUser);
|
|
}
|
|
|
|
if(!StorageService()->SubDB().GetUserByEmail(NewUser.email, NewUser)) {
|
|
Logger_.information(fmt::format("User '{}' but not retrieved.",NewUser.email));
|
|
return NotFound();
|
|
}
|
|
|
|
Poco::JSON::Object UserInfoObject;
|
|
Sanitize(UserInfo_, NewUser);
|
|
NewUser.to_json(UserInfoObject);
|
|
ReturnObject(UserInfoObject);
|
|
Logger_.information(fmt::format("User '{}' has been added by '{}')",NewUser.email, UserInfo_.userinfo.email));
|
|
}
|
|
|
|
void RESTAPI_subuser_handler::DoPut() {
|
|
std::string Id = GetBinding("id", "");
|
|
if(Id.empty()) {
|
|
return BadRequest(RESTAPI::Errors::MissingUserID);
|
|
}
|
|
|
|
SecurityObjects::UserInfo Existing;
|
|
if(!StorageService()->SubDB().GetUserById(Id,Existing)) {
|
|
return NotFound();
|
|
}
|
|
|
|
if(!Internal_ && !ACLProcessor::Can(UserInfo_.userinfo,Existing,ACLProcessor::MODIFY)) {
|
|
return UnAuthorized(RESTAPI::Errors::ACCESS_DENIED);
|
|
}
|
|
|
|
if(GetBoolParameter("resetMFA")) {
|
|
if( (UserInfo_.userinfo.userRole == SecurityObjects::ROOT) ||
|
|
(UserInfo_.userinfo.userRole == SecurityObjects::ADMIN && Existing.userRole!=SecurityObjects::ROOT) ||
|
|
(UserInfo_.userinfo.id == Id)) {
|
|
Existing.userTypeProprietaryInfo.mfa.enabled = false;
|
|
Existing.userTypeProprietaryInfo.mfa.method.clear();
|
|
Existing.userTypeProprietaryInfo.mobiles.clear();
|
|
Existing.modified = OpenWifi::Now();
|
|
Existing.notes.push_back( SecurityObjects::NoteInfo{
|
|
.created=OpenWifi::Now(),
|
|
.createdBy=UserInfo_.userinfo.email,
|
|
.note="MFA Reset by " + UserInfo_.userinfo.email});
|
|
StorageService()->SubDB().UpdateUserInfo(UserInfo_.userinfo.email,Id,Existing);
|
|
SecurityObjects::UserInfo NewUserInfo;
|
|
StorageService()->SubDB().GetUserByEmail(UserInfo_.userinfo.email,NewUserInfo);
|
|
Poco::JSON::Object ModifiedObject;
|
|
Sanitize(UserInfo_, NewUserInfo);
|
|
NewUserInfo.to_json(ModifiedObject);
|
|
return ReturnObject(ModifiedObject);
|
|
} else {
|
|
return UnAuthorized(RESTAPI::Errors::ACCESS_DENIED);
|
|
}
|
|
}
|
|
|
|
if(GetBoolParameter("forgotPassword")) {
|
|
Existing.changePassword = true;
|
|
Logger_.information(fmt::format("FORGOTTEN-PASSWORD({}): Request for {}", Request->clientAddress().toString(), Existing.email));
|
|
|
|
SecurityObjects::ActionLink NewLink;
|
|
NewLink.action = OpenWifi::SecurityObjects::LinkActions::SUB_FORGOT_PASSWORD;
|
|
NewLink.id = MicroService::CreateUUID();
|
|
NewLink.userId = Existing.id;
|
|
NewLink.created = OpenWifi::Now();
|
|
NewLink.expires = NewLink.created + (24*60*60);
|
|
NewLink.userAction = false;
|
|
StorageService()->ActionLinksDB().CreateAction(NewLink);
|
|
|
|
return OK();
|
|
}
|
|
|
|
SecurityObjects::UserInfo NewUser;
|
|
const auto & RawObject = ParsedBody_;
|
|
if(!NewUser.from_json(RawObject)) {
|
|
return BadRequest(RESTAPI::Errors::InvalidJSONDocument);
|
|
}
|
|
|
|
// some basic validations
|
|
if(RawObject->has("userRole") &&
|
|
(SecurityObjects::UserTypeFromString(RawObject->get("userRole").toString())==SecurityObjects::UNKNOWN ||
|
|
SecurityObjects::UserTypeFromString(RawObject->get("userRole").toString())==SecurityObjects::SUBSCRIBER)) {
|
|
return BadRequest(RESTAPI::Errors::InvalidUserRole);
|
|
}
|
|
|
|
// The only valid things to change are: changePassword, name,
|
|
AssignIfPresent(RawObject,"name", Existing.name);
|
|
AssignIfPresent(RawObject,"description", Existing.description);
|
|
AssignIfPresent(RawObject,"owner", Existing.owner);
|
|
AssignIfPresent(RawObject,"location", Existing.location);
|
|
AssignIfPresent(RawObject,"locale", Existing.locale);
|
|
AssignIfPresent(RawObject,"changePassword", Existing.changePassword);
|
|
AssignIfPresent(RawObject,"suspended", Existing.suspended);
|
|
AssignIfPresent(RawObject,"blackListed", Existing.blackListed);
|
|
|
|
if(RawObject->has("userRole")) {
|
|
auto NewRole = SecurityObjects::UserTypeFromString(RawObject->get("userRole").toString());
|
|
if(NewRole!=Existing.userRole) {
|
|
if(UserInfo_.userinfo.userRole!=SecurityObjects::ROOT && NewRole==SecurityObjects::ROOT) {
|
|
return UnAuthorized(RESTAPI::Errors::ACCESS_DENIED);
|
|
}
|
|
if(Id==UserInfo_.userinfo.id) {
|
|
return UnAuthorized(RESTAPI::Errors::ACCESS_DENIED);
|
|
}
|
|
Existing.userRole = NewRole;
|
|
}
|
|
}
|
|
|
|
if(RawObject->has("notes")) {
|
|
SecurityObjects::NoteInfoVec NIV;
|
|
NIV = RESTAPI_utils::to_object_array<SecurityObjects::NoteInfo>(RawObject->get("notes").toString());
|
|
for(auto const &i:NIV) {
|
|
SecurityObjects::NoteInfo ii{.created=(uint64_t)OpenWifi::Now(), .createdBy=UserInfo_.userinfo.email, .note=i.note};
|
|
Existing.notes.push_back(ii);
|
|
}
|
|
}
|
|
if(RawObject->has("currentPassword")) {
|
|
if(!AuthService()->ValidateSubPassword(RawObject->get("currentPassword").toString())) {
|
|
return BadRequest(RESTAPI::Errors::InvalidPassword);
|
|
}
|
|
if(!AuthService()->SetPassword(RawObject->get("currentPassword").toString(),Existing)) {
|
|
return BadRequest(RESTAPI::Errors::PasswordRejected);
|
|
}
|
|
}
|
|
|
|
if(GetParameter("email_verification","false")=="true") {
|
|
if(AuthService::VerifySubEmail(Existing))
|
|
Logger_.information(fmt::format("Verification e-mail requested for {}",Existing.email));
|
|
}
|
|
|
|
if(RawObject->has("userTypeProprietaryInfo")) {
|
|
if(NewUser.userTypeProprietaryInfo.mfa.enabled) {
|
|
if (!MFAMETHODS::Validate(NewUser.userTypeProprietaryInfo.mfa.method)) {
|
|
return BadRequest(RESTAPI::Errors::BadMFAMethod);
|
|
}
|
|
|
|
if( NewUser.userTypeProprietaryInfo.mfa.enabled &&
|
|
NewUser.userTypeProprietaryInfo.mfa.method == MFAMETHODS::SMS &&
|
|
!SMSSender()->Enabled()) {
|
|
return BadRequest(RESTAPI::Errors::SMSMFANotEnabled);
|
|
}
|
|
|
|
if( NewUser.userTypeProprietaryInfo.mfa.enabled &&
|
|
NewUser.userTypeProprietaryInfo.mfa.method == MFAMETHODS::EMAIL &&
|
|
!SMTPMailerService()->Enabled()) {
|
|
return BadRequest(RESTAPI::Errors::EMailMFANotEnabled);
|
|
}
|
|
|
|
Existing.userTypeProprietaryInfo.mfa.method = NewUser.userTypeProprietaryInfo.mfa.method;
|
|
Existing.userTypeProprietaryInfo.mfa.enabled = true;
|
|
|
|
if (NewUser.userTypeProprietaryInfo.mfa.method == MFAMETHODS::SMS) {
|
|
if(NewUser.userTypeProprietaryInfo.mobiles.empty()) {
|
|
return BadRequest(RESTAPI::Errors::NeedMobileNumber);
|
|
}
|
|
if (!SMSSender()->IsNumberValid(NewUser.userTypeProprietaryInfo.mobiles[0].number,UserInfo_.userinfo.email)) {
|
|
return BadRequest(RESTAPI::Errors::NeedMobileNumber);
|
|
}
|
|
Existing.userTypeProprietaryInfo.mobiles = NewUser.userTypeProprietaryInfo.mobiles;
|
|
Existing.userTypeProprietaryInfo.mobiles[0].verified = true;
|
|
Existing.userTypeProprietaryInfo.authenticatorSecret.clear();
|
|
} else if (NewUser.userTypeProprietaryInfo.mfa.method == MFAMETHODS::AUTHENTICATOR) {
|
|
std::string Secret;
|
|
Existing.userTypeProprietaryInfo.mobiles.clear();
|
|
if(Existing.userTypeProprietaryInfo.authenticatorSecret.empty() && TotpCache()->CompleteValidation(UserInfo_.userinfo,false,Secret)) {
|
|
Existing.userTypeProprietaryInfo.authenticatorSecret = Secret;
|
|
} else if (!Existing.userTypeProprietaryInfo.authenticatorSecret.empty()) {
|
|
// we allow someone to use their old secret
|
|
} else {
|
|
return BadRequest(RESTAPI::Errors::AuthenticatorVerificationIncomplete);
|
|
}
|
|
} else if (NewUser.userTypeProprietaryInfo.mfa.method == MFAMETHODS::EMAIL) {
|
|
Existing.userTypeProprietaryInfo.mobiles.clear();
|
|
Existing.userTypeProprietaryInfo.authenticatorSecret.clear();
|
|
}
|
|
} else {
|
|
Existing.userTypeProprietaryInfo.authenticatorSecret.clear();
|
|
Existing.userTypeProprietaryInfo.mobiles.clear();
|
|
Existing.userTypeProprietaryInfo.mfa.enabled = false;
|
|
}
|
|
}
|
|
|
|
if(StorageService()->SubDB().UpdateUserInfo(UserInfo_.userinfo.email,Id,Existing)) {
|
|
SecurityObjects::UserInfo NewUserInfo;
|
|
StorageService()->SubDB().GetUserById(Id,NewUserInfo);
|
|
Poco::JSON::Object ModifiedObject;
|
|
Sanitize(UserInfo_, NewUserInfo);
|
|
NewUserInfo.to_json(ModifiedObject);
|
|
return ReturnObject(ModifiedObject);
|
|
}
|
|
BadRequest(RESTAPI::Errors::RecordNotUpdated);
|
|
}
|
|
} |