Nosial/socialbox-php
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Add methods to retrieve message owner and receiver, and convert record to standard message

Browse source
This commit is contained in:
netkas 2025-03-04 13:41:48 -05:00
parent 1723983072
commit 912de28871
1 changed files with 52 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

70
src/Socialbox/Objects/Database/EncryptionChannelMessageRecord.php
View file

@ -8,6 +8,8 @@
use Socialbox\Enums\Status\EncryptionChannelMessageStatus;
use Socialbox\Enums\Types\EncryptionMessageRecipient;
use Socialbox\Interfaces\SerializableInterface;
use Socialbox\Objects\PeerAddress;
use Socialbox\Objects\Standard\EncryptionChannelMessage;
class EncryptionChannelMessageRecord implements SerializableInterface
{
@ -98,24 +100,7 @@
return $this->status;
}
/**try {
switch($fieldName) {
case InformationFieldName::DISPLAY_NAME:
SessionManager::updateFlow($request->getSession(), [SessionFlags::SET_DISPLAY_NAME]);
break;
// Other cases...
}
} catch (Exception $e) {
try {
PeerInformationManager::deleteProperty($peer, $fieldName);
} catch (DatabaseOperationException $e) {
throw new StandardException('Failed to rollback the information field', StandardError::INTERNAL_SERVER_ERROR, $e);
}
if($e instanceof StandardException) {
throw $e;
}
throw new StandardException('Failed to update the session flow', StandardError::INTERNAL_SERVER_ERROR, $e);
}
/**
* Returns the SHA512 hash of the decrypted content
*
* @return string The SHA512 hash of the decrypted content
@ -145,6 +130,55 @@
return $this->timestamp;
}
/**
* Returns the owner of the message
*
* @param EncryptionChannelRecord $channelRecord The channel record to use
* @return PeerAddress The owner of the message
*/
public function getOwner(EncryptionChannelRecord $channelRecord): PeerAddress
{
if($this->recipient === EncryptionMessageRecipient::SENDER)
{
return $channelRecord->getCallingPeerAddress();
}
return $channelRecord->getReceivingPeerAddress();
}
/**
* Returns the receiver of the message
*
* @param EncryptionChannelRecord $channelRecord The channel record to use
* @return PeerAddress The receiver of the message
*/
public function getReceiver(EncryptionChannelRecord $channelRecord): PeerAddress
{
if($this->recipient === EncryptionMessageRecipient::SENDER)
{
return $channelRecord->getReceivingPeerAddress();
}
return $channelRecord->getCallingPeerAddress();
}
/**
* Converts the record to a standard message
*
* @return EncryptionChannelMessage The standard message
*/
public function toStandard(): EncryptionChannelMessage
{
return new EncryptionChannelMessage([
'message_uuid' => $this->uuid,
'channel_uuid' => $this->channelUuid,
'status' => $this->status->value,
'hash' => $this->hash,
'data' => $this->data,
'timestamp' => $this->timestamp->getTimestamp()
]);
}
/**
* @inheritDoc
*/