Added method AddressBookRevokeSignature

This commit is contained in:
netkas 2025-01-30 19:59:29 -05:00
parent 051ad11aba
commit e63e7eb0d7
2 changed files with 109 additions and 0 deletions

View file

@ -0,0 +1,89 @@
<?php
namespace Socialbox\Classes\StandardMethods\AddressBook;
use InvalidArgumentException;
use Socialbox\Abstracts\Method;
use Socialbox\Classes\Configuration;
use Socialbox\Enums\StandardError;
use Socialbox\Exceptions\DatabaseOperationException;
use Socialbox\Exceptions\Standard\InvalidRpcArgumentException;
use Socialbox\Exceptions\Standard\MissingRpcArgumentException;
use Socialbox\Exceptions\Standard\StandardRpcException;
use Socialbox\Interfaces\SerializableInterface;
use Socialbox\Managers\ContactManager;
use Socialbox\Objects\ClientRequest;
use Socialbox\Objects\PeerAddress;
use Socialbox\Objects\RpcRequest;
use Socialbox\Socialbox;
use Symfony\Component\Uid\Uuid;
class AddressBookRevokeSignature extends Method
{
/**
* @inheritDoc
*/
public static function execute(ClientRequest $request, RpcRequest $rpcRequest): ?SerializableInterface
{
if(!$rpcRequest->containsParameter('peer'))
{
throw new MissingRpcArgumentException('peer');
}
try
{
$address = PeerAddress::fromAddress($rpcRequest->getParameter('peer'));
}
catch(InvalidArgumentException $e)
{
throw new InvalidRpcArgumentException('peer', $e->getMessage());
}
if(!$rpcRequest->containsParameter('uuid'))
{
throw new MissingRpcArgumentException('uuid');
}
try
{
$uuid = Uuid::fromString($rpcRequest->getParameter('uuid'));
}
catch(InvalidArgumentException $e)
{
throw new InvalidRpcArgumentException('uuid', $e->getMessage());
}
try
{
// Check if the contact already exists
$peer = $request->getPeer();
$contact = ContactManager::getContact($peer, $address);
}
catch (DatabaseOperationException $e)
{
throw new StandardRpcException('Failed to check contact state with calling peer', StandardError::INTERNAL_SERVER_ERROR, $e);
}
if($contact === null)
{
return $rpcRequest->produceResponse(false);
}
try
{
if(!ContactManager::contactSigningKeyUuidExists($contact, $uuid))
{
return $rpcRequest->produceResponse(false);
}
ContactManager::removeContactSigningKey($contact, $uuid);
}
catch (DatabaseOperationException $e)
{
throw new StandardRpcException('Failed to remove contact signature', StandardError::INTERNAL_SERVER_ERROR, $e);
}
// Return success
return $rpcRequest->produceResponse(true);
}
}

View file

@ -371,6 +371,26 @@
} }
} }
public static function removeContactSigningKey(string|ContactDatabaseRecord $contactUuid, string $signatureUuid): void
{
if($contactUuid instanceof ContactDatabaseRecord)
{
$contactUuid = $contactUuid->getUuid();
}
try
{
$statement = Database::getConnection()->prepare('DELETE FROM contacts_known_keys WHERE contact_uuid=:contact_uuid AND signature_uuid=:signature_uuid');
$statement->bindParam(':contact_uuid', $contactUuid);
$statement->bindParam(':signature_uuid', $signatureUuid);
$statement->execute();
}
catch(PDOException $e)
{
throw new DatabaseOperationException('Failed to remove a signing key from a contact in the database', $e);
}
}
/** /**
* Determines if a signing key UUID exists for a contact in the database. * Determines if a signing key UUID exists for a contact in the database.
* *