mirror of
https://github.com/the-djmaze/snappymail.git
synced 2024-09-19 23:25:54 +08:00
Fixing indentation
This commit is contained in:
parent
1c63287243
commit
6919a6a34f
2
.editorconfig
Normal file
2
.editorconfig
Normal file
|
@ -0,0 +1,2 @@
|
|||
[*.php]
|
||||
indent_style = tab
|
File diff suppressed because it is too large
Load diff
|
@ -2,11 +2,11 @@
|
|||
|
||||
namespace RainLoop\Actions;
|
||||
|
||||
use \RainLoop\Enumerations\Capa;
|
||||
use \RainLoop\Exceptions\ClientException;
|
||||
use \RainLoop\Model\Account;
|
||||
use \RainLoop\Model\Identity;
|
||||
use \RainLoop\Notifications;
|
||||
use RainLoop\Enumerations\Capa;
|
||||
use RainLoop\Exceptions\ClientException;
|
||||
use RainLoop\Model\Account;
|
||||
use RainLoop\Model\Identity;
|
||||
use RainLoop\Notifications;
|
||||
use RainLoop\Providers\Storage\Enumerations\StorageType;
|
||||
use function trim;
|
||||
|
||||
|
@ -16,12 +16,11 @@ trait Accounts
|
|||
/**
|
||||
* @throws \MailSo\Base\Exceptions\Exception
|
||||
*/
|
||||
public function DoAccountSetup() : array
|
||||
public function DoAccountSetup(): array
|
||||
{
|
||||
$oAccount = $this->getAccountFromToken();
|
||||
|
||||
if (!$this->GetCapa(false, false, Capa::ADDITIONAL_ACCOUNTS, $oAccount))
|
||||
{
|
||||
if (!$this->GetCapa(false, false, Capa::ADDITIONAL_ACCOUNTS, $oAccount)) {
|
||||
return $this->FalseResponse(__FUNCTION__);
|
||||
}
|
||||
|
||||
|
@ -31,15 +30,12 @@ trait Accounts
|
|||
|
||||
$sEmail = trim($this->GetActionParam('Email', ''));
|
||||
$sPassword = $this->GetActionParam('Password', '');
|
||||
$bNew = '1' === (string) $this->GetActionParam('New', '1');
|
||||
$bNew = '1' === (string)$this->GetActionParam('New', '1');
|
||||
|
||||
$sEmail = \MailSo\Base\Utils::IdnToAscii($sEmail, true);
|
||||
if ($bNew && ($oAccount->Email() === $sEmail || $sParentEmail === $sEmail || isset($aAccounts[$sEmail])))
|
||||
{
|
||||
if ($bNew && ($oAccount->Email() === $sEmail || $sParentEmail === $sEmail || isset($aAccounts[$sEmail]))) {
|
||||
throw new ClientException(Notifications::AccountAlreadyExists);
|
||||
}
|
||||
else if (!$bNew && !isset($aAccounts[$sEmail]))
|
||||
{
|
||||
} else if (!$bNew && !isset($aAccounts[$sEmail])) {
|
||||
throw new ClientException(Notifications::AccountDoesNotExist);
|
||||
}
|
||||
|
||||
|
@ -47,8 +43,7 @@ trait Accounts
|
|||
$oNewAccount->SetParentEmail($sParentEmail);
|
||||
|
||||
$aAccounts[$oNewAccount->Email()] = $oNewAccount->GetAuthToken();
|
||||
if (!$oAccount->IsAdditionalAccount())
|
||||
{
|
||||
if (!$oAccount->IsAdditionalAccount()) {
|
||||
$aAccounts[$oAccount->Email()] = $oAccount->GetAuthToken();
|
||||
}
|
||||
|
||||
|
@ -59,12 +54,11 @@ trait Accounts
|
|||
/**
|
||||
* @throws \MailSo\Base\Exceptions\Exception
|
||||
*/
|
||||
public function DoAccountDelete() : array
|
||||
public function DoAccountDelete(): array
|
||||
{
|
||||
$oAccount = $this->getAccountFromToken();
|
||||
|
||||
if (!$this->GetCapa(false, false, Capa::ADDITIONAL_ACCOUNTS, $oAccount))
|
||||
{
|
||||
if (!$this->GetCapa(false, false, Capa::ADDITIONAL_ACCOUNTS, $oAccount)) {
|
||||
return $this->FalseResponse(__FUNCTION__);
|
||||
}
|
||||
|
||||
|
@ -74,16 +68,13 @@ trait Accounts
|
|||
|
||||
$aAccounts = $this->GetAccounts($oAccount);
|
||||
|
||||
if (0 < \strlen($sEmailToDelete) && $sEmailToDelete !== $sParentEmail && isset($aAccounts[$sEmailToDelete]))
|
||||
{
|
||||
if (0 < \strlen($sEmailToDelete) && $sEmailToDelete !== $sParentEmail && isset($aAccounts[$sEmailToDelete])) {
|
||||
unset($aAccounts[$sEmailToDelete]);
|
||||
|
||||
$oAccountToChange = null;
|
||||
if ($oAccount->Email() === $sEmailToDelete && !empty($aAccounts[$sParentEmail]))
|
||||
{
|
||||
if ($oAccount->Email() === $sEmailToDelete && !empty($aAccounts[$sParentEmail])) {
|
||||
$oAccountToChange = $this->GetAccountFromCustomToken($aAccounts[$sParentEmail], false, false);
|
||||
if ($oAccountToChange)
|
||||
{
|
||||
if ($oAccountToChange) {
|
||||
$this->AuthToken($oAccountToChange);
|
||||
}
|
||||
}
|
||||
|
@ -98,13 +89,12 @@ trait Accounts
|
|||
/**
|
||||
* @throws \MailSo\Base\Exceptions\Exception
|
||||
*/
|
||||
public function DoIdentityUpdate() : array
|
||||
public function DoIdentityUpdate(): array
|
||||
{
|
||||
$oAccount = $this->getAccountFromToken();
|
||||
|
||||
$oIdentity = new \RainLoop\Model\Identity();
|
||||
if (!$oIdentity->FromJSON($this->GetActionParams(), true))
|
||||
{
|
||||
if (!$oIdentity->FromJSON($this->GetActionParams(), true)) {
|
||||
throw new ClientException(Notifications::InvalidInputArgument);
|
||||
}
|
||||
|
||||
|
@ -115,18 +105,16 @@ trait Accounts
|
|||
/**
|
||||
* @throws \MailSo\Base\Exceptions\Exception
|
||||
*/
|
||||
public function DoIdentityDelete() : array
|
||||
public function DoIdentityDelete(): array
|
||||
{
|
||||
$oAccount = $this->getAccountFromToken();
|
||||
|
||||
if (!$this->GetCapa(false, false, Capa::IDENTITIES, $oAccount))
|
||||
{
|
||||
if (!$this->GetCapa(false, false, Capa::IDENTITIES, $oAccount)) {
|
||||
return $this->FalseResponse(__FUNCTION__);
|
||||
}
|
||||
|
||||
$sId = trim($this->GetActionParam('IdToDelete', ''));
|
||||
if (empty($sId))
|
||||
{
|
||||
if (empty($sId)) {
|
||||
throw new ClientException(Notifications::UnknownError);
|
||||
}
|
||||
|
||||
|
@ -137,15 +125,14 @@ trait Accounts
|
|||
/**
|
||||
* @throws \MailSo\Base\Exceptions\Exception
|
||||
*/
|
||||
public function DoAccountsAndIdentitiesSortOrder() : array
|
||||
public function DoAccountsAndIdentitiesSortOrder(): array
|
||||
{
|
||||
$oAccount = $this->getAccountFromToken();
|
||||
|
||||
$aAccounts = $this->GetActionParam('Accounts', null);
|
||||
$aIdentities = $this->GetActionParam('Identities', null);
|
||||
|
||||
if (!\is_array($aAccounts) && !\is_array($aIdentities))
|
||||
{
|
||||
if (!\is_array($aAccounts) && !\is_array($aIdentities)) {
|
||||
return $this->FalseResponse(__FUNCTION__);
|
||||
}
|
||||
|
||||
|
@ -161,19 +148,17 @@ trait Accounts
|
|||
/**
|
||||
* @throws \MailSo\Base\Exceptions\Exception
|
||||
*/
|
||||
public function DoAccountsAndIdentities() : array
|
||||
public function DoAccountsAndIdentities(): array
|
||||
{
|
||||
$oAccount = $this->getAccountFromToken();
|
||||
|
||||
$mAccounts = false;
|
||||
|
||||
if ($this->GetCapa(false, false, Capa::ADDITIONAL_ACCOUNTS, $oAccount))
|
||||
{
|
||||
if ($this->GetCapa(false, false, Capa::ADDITIONAL_ACCOUNTS, $oAccount)) {
|
||||
$mAccounts = $this->GetAccounts($oAccount);
|
||||
$mAccounts = \array_keys($mAccounts);
|
||||
|
||||
foreach ($mAccounts as $iIndex => $sName)
|
||||
{
|
||||
foreach ($mAccounts as $iIndex => $sName) {
|
||||
$mAccounts[$iIndex] = \MailSo\Base\Utils::IdnToUtf8($sName);
|
||||
}
|
||||
}
|
||||
|
@ -184,35 +169,35 @@ trait Accounts
|
|||
));
|
||||
}
|
||||
|
||||
/**
|
||||
* @param Account $account
|
||||
* @return Identity[]
|
||||
*/
|
||||
public function GetIdentities(Account $account) : array
|
||||
{
|
||||
if(!$account) return [];
|
||||
/**
|
||||
* @param Account $account
|
||||
* @return Identity[]
|
||||
*/
|
||||
public function GetIdentities(Account $account): array
|
||||
{
|
||||
if (!$account) return [];
|
||||
|
||||
// A custom name for a single identity is also stored in this system
|
||||
$allowMultipleIdentities = $this->GetCapa(false, false, Capa::IDENTITIES, $account);
|
||||
// A custom name for a single identity is also stored in this system
|
||||
$allowMultipleIdentities = $this->GetCapa(false, false, Capa::IDENTITIES, $account);
|
||||
|
||||
// Get all identities
|
||||
$identities = $this->IdentitiesProvider()->GetIdentities($account, $allowMultipleIdentities);
|
||||
// Get all identities
|
||||
$identities = $this->IdentitiesProvider()->GetIdentities($account, $allowMultipleIdentities);
|
||||
|
||||
// Sort identities
|
||||
$orderString = $this->StorageProvider()->Get($account, StorageType::CONFIG, 'accounts_identities_order');
|
||||
$order = json_decode($orderString, true) ?? [];
|
||||
if(isset($order['Identities']) && is_array($order['Identities']) && count($order['Identities']) > 1) {
|
||||
$list = array_map(function($item) {
|
||||
if('' === $item) $item = '---';
|
||||
return $item;
|
||||
}, $order['Identities']);
|
||||
// Sort identities
|
||||
$orderString = $this->StorageProvider()->Get($account, StorageType::CONFIG, 'accounts_identities_order');
|
||||
$order = json_decode($orderString, true) ?? [];
|
||||
if (isset($order['Identities']) && is_array($order['Identities']) && count($order['Identities']) > 1) {
|
||||
$list = array_map(function ($item) {
|
||||
if ('' === $item) $item = '---';
|
||||
return $item;
|
||||
}, $order['Identities']);
|
||||
|
||||
usort($identities, function($a, $b) use ($list) {
|
||||
return array_search($a->Id(true), $list) < array_search($b->Id(true), $list) ? -1 : 1;
|
||||
});
|
||||
}
|
||||
usort($identities, function ($a, $b) use ($list) {
|
||||
return array_search($a->Id(true), $list) < array_search($b->Id(true), $list) ? -1 : 1;
|
||||
});
|
||||
}
|
||||
|
||||
return $identities;
|
||||
}
|
||||
return $identities;
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
@ -7,40 +7,40 @@ use MailSo\Base\Utils;
|
|||
|
||||
class Identity implements JsonSerializable
|
||||
{
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sId;
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sId;
|
||||
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sEmail;
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sEmail;
|
||||
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sName;
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sName;
|
||||
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sReplyTo;
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sReplyTo;
|
||||
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sBcc;
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sBcc;
|
||||
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sSignature;
|
||||
/**
|
||||
* @var string
|
||||
*/
|
||||
private $sSignature;
|
||||
|
||||
/**
|
||||
* @var bool
|
||||
*/
|
||||
private $bSignatureInsertBefore;
|
||||
/**
|
||||
* @var bool
|
||||
*/
|
||||
private $bSignatureInsertBefore;
|
||||
|
||||
function __construct(string $sId = '', string $sEmail = '')
|
||||
{
|
||||
|
@ -53,88 +53,87 @@ class Identity implements JsonSerializable
|
|||
$this->bSignatureInsertBefore = false;
|
||||
}
|
||||
|
||||
public function Id(bool $bFillOnEmpty = false) : string
|
||||
public function Id(bool $bFillOnEmpty = false): string
|
||||
{
|
||||
return $bFillOnEmpty ? ('' === $this->sId ? '---' : $this->sId) : $this->sId;
|
||||
}
|
||||
|
||||
public function Email() : string
|
||||
public function Email(): string
|
||||
{
|
||||
return $this->sEmail;
|
||||
}
|
||||
|
||||
public function SetEmail(string $sEmail) : self
|
||||
public function SetEmail(string $sEmail): self
|
||||
{
|
||||
$this->sEmail = $sEmail;
|
||||
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function Name() : string
|
||||
public function Name(): string
|
||||
{
|
||||
return $this->sName;
|
||||
}
|
||||
|
||||
public function ReplyTo() : string
|
||||
public function ReplyTo(): string
|
||||
{
|
||||
return $this->sReplyTo;
|
||||
}
|
||||
|
||||
public function Bcc() : string
|
||||
public function Bcc(): string
|
||||
{
|
||||
return $this->sBcc;
|
||||
}
|
||||
|
||||
public function Signature() : string
|
||||
public function Signature(): string
|
||||
{
|
||||
return $this->sSignature;
|
||||
}
|
||||
|
||||
public function SignatureInsertBefore() : bool
|
||||
public function SignatureInsertBefore(): bool
|
||||
{
|
||||
return $this->bSignatureInsertBefore;
|
||||
}
|
||||
|
||||
public function SetId(string $sId): Identity
|
||||
{
|
||||
$this->sId = $sId;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetName(string $sName): Identity
|
||||
{
|
||||
$this->sName = $sName;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetReplyTo(string $sReplyTo): Identity
|
||||
{
|
||||
$this->sReplyTo = $sReplyTo;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetBcc(string $sBcc): Identity
|
||||
{
|
||||
$this->sBcc = $sBcc;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetSignature(string $sSignature): Identity
|
||||
{
|
||||
$this->sSignature = $sSignature;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetSignatureInsertBefore(bool $bSignatureInsertBefore): Identity
|
||||
{
|
||||
$this->bSignatureInsertBefore = $bSignatureInsertBefore;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function FromJSON(array $aData, bool $bAjax = false) : bool
|
||||
public function SetId(string $sId): Identity
|
||||
{
|
||||
if (!empty($aData['Email']))
|
||||
{
|
||||
$this->sId = $sId;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetName(string $sName): Identity
|
||||
{
|
||||
$this->sName = $sName;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetReplyTo(string $sReplyTo): Identity
|
||||
{
|
||||
$this->sReplyTo = $sReplyTo;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetBcc(string $sBcc): Identity
|
||||
{
|
||||
$this->sBcc = $sBcc;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetSignature(string $sSignature): Identity
|
||||
{
|
||||
$this->sSignature = $sSignature;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function SetSignatureInsertBefore(bool $bSignatureInsertBefore): Identity
|
||||
{
|
||||
$this->bSignatureInsertBefore = $bSignatureInsertBefore;
|
||||
return $this;
|
||||
}
|
||||
|
||||
public function FromJSON(array $aData, bool $bAjax = false): bool
|
||||
{
|
||||
if (!empty($aData['Email'])) {
|
||||
$this->sId = !empty($aData['Id']) ? $aData['Id'] : '';
|
||||
$this->sEmail = $bAjax ? Utils::IdnToAscii($aData['Email'], true) : $aData['Email'];
|
||||
$this->sName = isset($aData['Name']) ? $aData['Name'] : '';
|
||||
|
@ -150,7 +149,7 @@ class Identity implements JsonSerializable
|
|||
return false;
|
||||
}
|
||||
|
||||
public function ToSimpleJSON() : array
|
||||
public function ToSimpleJSON(): array
|
||||
{
|
||||
return array(
|
||||
'Id' => $this->Id(),
|
||||
|
@ -176,12 +175,12 @@ class Identity implements JsonSerializable
|
|||
);
|
||||
}
|
||||
|
||||
public function Validate() : bool
|
||||
public function Validate(): bool
|
||||
{
|
||||
return !empty($this->sEmail);
|
||||
}
|
||||
|
||||
public function IsAccountIdentities() : bool
|
||||
public function IsAccountIdentities(): bool
|
||||
{
|
||||
return '' === $this->Id();
|
||||
}
|
||||
|
|
|
@ -8,127 +8,132 @@ use RainLoop\Providers\Identities\IIdentities;
|
|||
|
||||
class Identities extends AbstractProvider
|
||||
{
|
||||
/** @var IIdentities[] */
|
||||
private $drivers;
|
||||
/** @var IIdentities[] */
|
||||
private $drivers;
|
||||
|
||||
/** @var Identity[][][] */
|
||||
private $identitiesPerDriverPerAccount;
|
||||
/** @var Identity[][][] */
|
||||
private $identitiesPerDriverPerAccount;
|
||||
|
||||
/**
|
||||
* Identities constructor.
|
||||
* @param IIdentities[] $drivers
|
||||
*/
|
||||
public function __construct(?array $drivers = null)
|
||||
{
|
||||
if($drivers === null) $drivers = [];
|
||||
/**
|
||||
* Identities constructor.
|
||||
* @param IIdentities[] $drivers
|
||||
*/
|
||||
public function __construct(?array $drivers = null)
|
||||
{
|
||||
if ($drivers === null) $drivers = [];
|
||||
|
||||
$this->drivers = array_filter($drivers, function($driver) {
|
||||
return $driver instanceof IIdentities;
|
||||
});
|
||||
}
|
||||
$this->drivers = array_filter($drivers, function ($driver) {
|
||||
return $driver instanceof IIdentities;
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* @param Account $account
|
||||
* @param bool $allowMultipleIdentities
|
||||
* @return Identity[]
|
||||
*/
|
||||
public function GetIdentities(Account $account, bool $allowMultipleIdentities) : array {
|
||||
// Find all identities stored in the system
|
||||
$identities = $this->MergeIdentitiesPerDriver($this->GetIdentiesPerDriver($account));
|
||||
/**
|
||||
* @param Account $account
|
||||
* @param bool $allowMultipleIdentities
|
||||
* @return Identity[]
|
||||
*/
|
||||
public function GetIdentities(Account $account, bool $allowMultipleIdentities): array
|
||||
{
|
||||
// Find all identities stored in the system
|
||||
$identities = $this->MergeIdentitiesPerDriver($this->GetIdentiesPerDriver($account));
|
||||
|
||||
// Find the primary identity
|
||||
$primaryIdentity = current(array_filter($identities, function($identity) {
|
||||
return $identity->IsAccountIdentities();
|
||||
}));
|
||||
// Find the primary identity
|
||||
$primaryIdentity = current(array_filter($identities, function ($identity) {
|
||||
return $identity->IsAccountIdentities();
|
||||
}));
|
||||
|
||||
// If no primary identity is found, generate default one from account info
|
||||
if($primaryIdentity === null || $primaryIdentity === false)
|
||||
$identities[] = $primaryIdentity = new Identity('', $account->Email());
|
||||
// If no primary identity is found, generate default one from account info
|
||||
if ($primaryIdentity === null || $primaryIdentity === false)
|
||||
$identities[] = $primaryIdentity = new Identity('', $account->Email());
|
||||
|
||||
// Return only primary identity or all identities
|
||||
return $allowMultipleIdentities ? $identities : [$primaryIdentity];
|
||||
}
|
||||
// Return only primary identity or all identities
|
||||
return $allowMultipleIdentities ? $identities : [$primaryIdentity];
|
||||
}
|
||||
|
||||
public function UpdateIdentity(Account $account, Identity $identity) {
|
||||
// Find all identities in the system
|
||||
$identities = &$this->GetIdentiesPerDriver($account);
|
||||
public function UpdateIdentity(Account $account, Identity $identity)
|
||||
{
|
||||
// Find all identities in the system
|
||||
$identities = &$this->GetIdentiesPerDriver($account);
|
||||
|
||||
$isNew = true;
|
||||
foreach($this->drivers as $driver) {
|
||||
if(!$driver->SupportsStore()) continue;
|
||||
$isNew = true;
|
||||
foreach ($this->drivers as $driver) {
|
||||
if (!$driver->SupportsStore()) continue;
|
||||
|
||||
$driverIdentities = &$identities[$driver->Name()];
|
||||
if(!isset($driverIdentities[$identity->Id(true)]))
|
||||
continue;
|
||||
$driverIdentities = &$identities[$driver->Name()];
|
||||
if (!isset($driverIdentities[$identity->Id(true)]))
|
||||
continue;
|
||||
|
||||
// We update the identity in all writeable stores
|
||||
$driverIdentities[$identity->Id(true)] = $identity;
|
||||
$isNew = false;
|
||||
// We update the identity in all writeable stores
|
||||
$driverIdentities[$identity->Id(true)] = $identity;
|
||||
$isNew = false;
|
||||
|
||||
$driver->SetIdentities($account, $driverIdentities);
|
||||
}
|
||||
$driver->SetIdentities($account, $driverIdentities);
|
||||
}
|
||||
|
||||
// If it is a new identity we add it to any storage driver
|
||||
if($isNew) {
|
||||
// Pick any storage driver to store the result, typically only file storage
|
||||
$storageDriver = current(array_filter($this->drivers, function($driver) {
|
||||
return $driver->SupportsStore();
|
||||
}));
|
||||
// If it is a new identity we add it to any storage driver
|
||||
if ($isNew) {
|
||||
// Pick any storage driver to store the result, typically only file storage
|
||||
$storageDriver = current(array_filter($this->drivers, function ($driver) {
|
||||
return $driver->SupportsStore();
|
||||
}));
|
||||
|
||||
$identities[$storageDriver->Name()][$identity->Id(true)] = $identity;
|
||||
$storageDriver->SetIdentities($account, $identities[$storageDriver->Name()]);
|
||||
}
|
||||
}
|
||||
$identities[$storageDriver->Name()][$identity->Id(true)] = $identity;
|
||||
$storageDriver->SetIdentities($account, $identities[$storageDriver->Name()]);
|
||||
}
|
||||
}
|
||||
|
||||
public function DeleteIdentity(Account $account, string $identityId) {
|
||||
// On deletion, we remove the identity from all drivers if they are writeable.
|
||||
$identities = &$this->GetIdentiesPerDriver($account);
|
||||
public function DeleteIdentity(Account $account, string $identityId)
|
||||
{
|
||||
// On deletion, we remove the identity from all drivers if they are writeable.
|
||||
$identities = &$this->GetIdentiesPerDriver($account);
|
||||
|
||||
foreach($this->drivers as $driver) {
|
||||
if(!$driver->SupportsStore()) continue;
|
||||
foreach ($this->drivers as $driver) {
|
||||
if (!$driver->SupportsStore()) continue;
|
||||
|
||||
$driverIdentities = &$identities[$driver->Name()];
|
||||
if(!isset($driverIdentities[$identityId]))
|
||||
continue;
|
||||
$driverIdentities = &$identities[$driver->Name()];
|
||||
if (!isset($driverIdentities[$identityId]))
|
||||
continue;
|
||||
|
||||
// We found it, so remove and update storage if relevant
|
||||
$identity = $driverIdentities[$identityId];
|
||||
if($identity->IsAccountIdentities()) continue; // never remove the primary identity
|
||||
// We found it, so remove and update storage if relevant
|
||||
$identity = $driverIdentities[$identityId];
|
||||
if ($identity->IsAccountIdentities()) continue; // never remove the primary identity
|
||||
|
||||
unset($driverIdentities[$identityId]);
|
||||
$driver->SetIdentities($account, $driverIdentities);
|
||||
}
|
||||
}
|
||||
unset($driverIdentities[$identityId]);
|
||||
$driver->SetIdentities($account, $driverIdentities);
|
||||
}
|
||||
}
|
||||
|
||||
private function &GetIdentiesPerDriver(Account $account) : array {
|
||||
if(isset($this->identitiesPerDriverPerAccount[$account->Email()]))
|
||||
return $this->identitiesPerDriverPerAccount[$account->Email()];
|
||||
private function &GetIdentiesPerDriver(Account $account): array
|
||||
{
|
||||
if (isset($this->identitiesPerDriverPerAccount[$account->Email()]))
|
||||
return $this->identitiesPerDriverPerAccount[$account->Email()];
|
||||
|
||||
$identitiesPerDriver = [];
|
||||
foreach($this->drivers as $driver) {
|
||||
$driverIdentities = $driver->GetIdentities($account);
|
||||
$identitiesPerDriver = [];
|
||||
foreach ($this->drivers as $driver) {
|
||||
$driverIdentities = $driver->GetIdentities($account);
|
||||
|
||||
foreach($driverIdentities as $identity)
|
||||
$identitiesPerDriver[$driver->Name()][$identity->Id(true)] = $identity;
|
||||
}
|
||||
foreach ($driverIdentities as $identity)
|
||||
$identitiesPerDriver[$driver->Name()][$identity->Id(true)] = $identity;
|
||||
}
|
||||
|
||||
$this->identitiesPerDriverPerAccount[$account->Email()] = $identitiesPerDriver;
|
||||
return $this->identitiesPerDriverPerAccount[$account->Email()];
|
||||
}
|
||||
$this->identitiesPerDriverPerAccount[$account->Email()] = $identitiesPerDriver;
|
||||
return $this->identitiesPerDriverPerAccount[$account->Email()];
|
||||
}
|
||||
|
||||
/**
|
||||
* @param Identity[][] $identitiesPerDriver
|
||||
* @return Identity[]
|
||||
*/
|
||||
private function MergeIdentitiesPerDriver(array $identitiesPerDriver) : array {
|
||||
// Merge logic for the identities
|
||||
$identities = [];
|
||||
foreach($this->drivers as $driver) {
|
||||
// Merge and replace by key
|
||||
foreach($identitiesPerDriver[$driver->Name()] as $identity)
|
||||
$identities[$identity->Id(true)] = $identity;
|
||||
}
|
||||
/**
|
||||
* @param Identity[][] $identitiesPerDriver
|
||||
* @return Identity[]
|
||||
*/
|
||||
private function MergeIdentitiesPerDriver(array $identitiesPerDriver): array
|
||||
{
|
||||
// Merge logic for the identities
|
||||
$identities = [];
|
||||
foreach ($this->drivers as $driver) {
|
||||
// Merge and replace by key
|
||||
foreach ($identitiesPerDriver[$driver->Name()] as $identity)
|
||||
$identities[$identity->Id(true)] = $identity;
|
||||
}
|
||||
|
||||
return array_values($identities);
|
||||
}
|
||||
return array_values($identities);
|
||||
}
|
||||
}
|
|
@ -8,62 +8,64 @@ use RainLoop\Providers\Storage;
|
|||
|
||||
class FileIdentities implements IIdentities
|
||||
{
|
||||
/**
|
||||
* @var Storage
|
||||
*/
|
||||
private $localStorageProvider;
|
||||
/**
|
||||
* @var Storage
|
||||
*/
|
||||
private $localStorageProvider;
|
||||
|
||||
/**
|
||||
* FileIdentities constructor.
|
||||
* @param Storage $localStorageProvider
|
||||
*/
|
||||
public function __construct(Storage $localStorageProvider)
|
||||
{
|
||||
$this->localStorageProvider = $localStorageProvider;
|
||||
}
|
||||
/**
|
||||
* FileIdentities constructor.
|
||||
* @param Storage $localStorageProvider
|
||||
*/
|
||||
public function __construct(Storage $localStorageProvider)
|
||||
{
|
||||
$this->localStorageProvider = $localStorageProvider;
|
||||
}
|
||||
|
||||
/**
|
||||
* @inheritDoc
|
||||
*/
|
||||
public function GetIdentities(Account $account): array
|
||||
{
|
||||
if(!$account) return [];
|
||||
/**
|
||||
* @inheritDoc
|
||||
*/
|
||||
public function GetIdentities(Account $account): array
|
||||
{
|
||||
if (!$account) return [];
|
||||
|
||||
$data = $this->localStorageProvider->Get($account, Storage\Enumerations\StorageType::CONFIG, 'identities');
|
||||
$subIdentities = json_decode($data, true) ?? [];
|
||||
$result = [];
|
||||
$data = $this->localStorageProvider->Get($account, Storage\Enumerations\StorageType::CONFIG, 'identities');
|
||||
$subIdentities = json_decode($data, true) ?? [];
|
||||
$result = [];
|
||||
|
||||
foreach($subIdentities as $subIdentity) {
|
||||
$identity = new Identity();
|
||||
$identity->FromJSON($subIdentity);
|
||||
foreach ($subIdentities as $subIdentity) {
|
||||
$identity = new Identity();
|
||||
$identity->FromJSON($subIdentity);
|
||||
|
||||
if(!$identity->Validate()) continue;
|
||||
if($identity->IsAccountIdentities()) $identity->SetEmail($account->Email());
|
||||
$result[] = $identity;
|
||||
}
|
||||
if (!$identity->Validate()) continue;
|
||||
if ($identity->IsAccountIdentities()) $identity->SetEmail($account->Email());
|
||||
$result[] = $identity;
|
||||
}
|
||||
|
||||
return $result;
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
|
||||
/**
|
||||
* @inheritDoc
|
||||
*/
|
||||
public function SetIdentities(Account $account, array $identities)
|
||||
{
|
||||
$jsons = array_map(function($identity) { return $identity->ToSimpleJSON(); }, $identities);
|
||||
$this->localStorageProvider->Put($account, Storage\Enumerations\StorageType::CONFIG, 'identities', json_encode($jsons));
|
||||
}
|
||||
/**
|
||||
* @inheritDoc
|
||||
*/
|
||||
public function SetIdentities(Account $account, array $identities)
|
||||
{
|
||||
$jsons = array_map(function ($identity) {
|
||||
return $identity->ToSimpleJSON();
|
||||
}, $identities);
|
||||
$this->localStorageProvider->Put($account, Storage\Enumerations\StorageType::CONFIG, 'identities', json_encode($jsons));
|
||||
}
|
||||
|
||||
/**
|
||||
* @inheritDoc
|
||||
*/
|
||||
public function SupportsStore() : bool
|
||||
{
|
||||
return true;
|
||||
}
|
||||
/**
|
||||
* @inheritDoc
|
||||
*/
|
||||
public function SupportsStore(): bool
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
public function Name(): string
|
||||
{
|
||||
return "File";
|
||||
}
|
||||
public function Name(): string
|
||||
{
|
||||
return "File";
|
||||
}
|
||||
}
|
|
@ -7,28 +7,28 @@ use RainLoop\Model\Identity;
|
|||
|
||||
interface IIdentities
|
||||
{
|
||||
/**
|
||||
* @param Account $account
|
||||
*
|
||||
* @return Identity[]
|
||||
*/
|
||||
public function GetIdentities(Account $account) : array;
|
||||
/**
|
||||
* @param Account $account
|
||||
*
|
||||
* @return Identity[]
|
||||
*/
|
||||
public function GetIdentities(Account $account): array;
|
||||
|
||||
/**
|
||||
* @param Account $account
|
||||
* @param Identity[] $identities
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function SetIdentities(Account $account, array $identities);
|
||||
/**
|
||||
* @param Account $account
|
||||
* @param Identity[] $identities
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function SetIdentities(Account $account, array $identities);
|
||||
|
||||
/**
|
||||
* @return bool
|
||||
*/
|
||||
public function SupportsStore() : bool;
|
||||
/**
|
||||
* @return bool
|
||||
*/
|
||||
public function SupportsStore(): bool;
|
||||
|
||||
/**
|
||||
* @return string
|
||||
*/
|
||||
public function Name() : string;
|
||||
/**
|
||||
* @return string
|
||||
*/
|
||||
public function Name(): string;
|
||||
}
|
|
@ -8,37 +8,40 @@ use RainLoop\Model\Identity;
|
|||
|
||||
class TestIdentities implements IIdentities
|
||||
{
|
||||
/**
|
||||
* @param Account $account
|
||||
* @return Identity[]
|
||||
*/
|
||||
public function GetIdentities(Account $account): array
|
||||
{
|
||||
$oIdentity = new Identity('', $account->Email());
|
||||
$oIdentity->SetName("Test Name");
|
||||
/**
|
||||
* @param Account $account
|
||||
* @return Identity[]
|
||||
*/
|
||||
public function GetIdentities(Account $account): array
|
||||
{
|
||||
$oIdentity = new Identity('', $account->Email());
|
||||
$oIdentity->SetName("Test Name");
|
||||
|
||||
return [$oIdentity];
|
||||
}
|
||||
return [$oIdentity];
|
||||
}
|
||||
|
||||
/**
|
||||
* @param Account $account
|
||||
* @param Identity[] $identities
|
||||
*
|
||||
* @return void
|
||||
* @throws Exception
|
||||
*/
|
||||
public function SetIdentities(Account $account, array $identities)
|
||||
{
|
||||
throw new Exception("Not implemented");
|
||||
}
|
||||
/**
|
||||
* @param Account $account
|
||||
* @param Identity[] $identities
|
||||
*
|
||||
* @return void
|
||||
* @throws Exception
|
||||
*/
|
||||
public function SetIdentities(Account $account, array $identities)
|
||||
{
|
||||
throw new Exception("Not implemented");
|
||||
}
|
||||
|
||||
/**
|
||||
* @return bool
|
||||
*/
|
||||
public function SupportsStore() : bool
|
||||
{
|
||||
return false;
|
||||
}
|
||||
/**
|
||||
* @return bool
|
||||
*/
|
||||
public function SupportsStore(): bool
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
public function Name() : string { return "Test"; }
|
||||
public function Name(): string
|
||||
{
|
||||
return "Test";
|
||||
}
|
||||
}
|
Loading…
Reference in a new issue