From 8c5237ff7f6b2412107641188bf45febf7cec6dc Mon Sep 17 00:00:00 2001
From: Netkas <netkas@nosial.net>
Date: Wed, 21 Jun 2023 14:51:21 -0400
Subject: [PATCH] Implemented Telegram Chat Peers

---
 .idea/inspectionProfiles/Project_Default.xml  |  72 +++++
 src/FederationLib/Classes/Configuration.php   |   5 +
 .../Interfaces/PeerMetadataInterface.php      |   9 +-
 .../PeerMetadataManagerInterface.php          |  12 +-
 .../MetadataManagers/TelegramChatManager.php  | 282 +++++++++++++++++
 .../MetadataManagers/TelegramUserManager.php  |  37 +--
 src/FederationLib/Managers/PeerManager.php    |   2 -
 src/FederationLib/Objects/Standard/Client.php |   2 +-
 .../PeerMetadata/TelegramChatMetadata.php     | 293 ++++++++++++++++++
 .../PeerMetadata/TelegramUserMetadata.php     |  68 ++--
 10 files changed, 703 insertions(+), 79 deletions(-)
 create mode 100644 src/FederationLib/Managers/MetadataManagers/TelegramChatManager.php
 create mode 100644 src/FederationLib/Objects/Standard/PeerMetadata/TelegramChatMetadata.php

diff --git a/.idea/inspectionProfiles/Project_Default.xml b/.idea/inspectionProfiles/Project_Default.xml
index a854623..dc24bc1 100755
--- a/.idea/inspectionProfiles/Project_Default.xml
+++ b/.idea/inspectionProfiles/Project_Default.xml
@@ -1,6 +1,78 @@
 <component name="InspectionProjectProfileManager">
   <profile version="1.0">
     <option name="myName" value="Project Default" />
+    <inspection_tool class="DuplicatedCode" enabled="true" level="WEAK WARNING" enabled_by_default="true">
+      <Languages>
+        <language minSize="111" name="PHP" />
+      </Languages>
+    </inspection_tool>
+    <inspection_tool class="ForgottenDebugOutputInspection" enabled="true" level="ERROR" enabled_by_default="true">
+      <option name="configuration">
+        <list>
+          <option value="\Codeception\Util\Debug::debug" />
+          <option value="\Codeception\Util\Debug::pause" />
+          <option value="\Doctrine\Common\Util\Debug::dump" />
+          <option value="\Doctrine\Common\Util\Debug::export" />
+          <option value="\Illuminate\Support\Debug\Dumper::dump" />
+          <option value="\Symfony\Component\Debug\Debug::enable" />
+          <option value="\Symfony\Component\Debug\DebugClassLoader::enable" />
+          <option value="\Symfony\Component\Debug\ErrorHandler::register" />
+          <option value="\Symfony\Component\Debug\ExceptionHandler::register" />
+          <option value="\TYPO3\CMS\Core\Utility\DebugUtility::debug" />
+          <option value="\Zend\Debug\Debug::dump" />
+          <option value="\Zend\Di\Display\Console::export" />
+          <option value="dd" />
+          <option value="debug_print_backtrace" />
+          <option value="debug_zval_dump" />
+          <option value="dpm" />
+          <option value="dpq" />
+          <option value="dsm" />
+          <option value="dump" />
+          <option value="dvm" />
+          <option value="error_log" />
+          <option value="kpr" />
+          <option value="phpinfo" />
+          <option value="print_r" />
+          <option value="var_dump" />
+          <option value="var_export" />
+          <option value="wp_die" />
+          <option value="xdebug_break" />
+          <option value="xdebug_call_class" />
+          <option value="xdebug_call_file" />
+          <option value="xdebug_call_function" />
+          <option value="xdebug_call_line" />
+          <option value="xdebug_code_coverage_started" />
+          <option value="xdebug_debug_zval" />
+          <option value="xdebug_debug_zval_stdout" />
+          <option value="xdebug_dump_superglobals" />
+          <option value="xdebug_enable" />
+          <option value="xdebug_get_code_coverage" />
+          <option value="xdebug_get_collected_errors" />
+          <option value="xdebug_get_declared_vars" />
+          <option value="xdebug_get_function_stack" />
+          <option value="xdebug_get_headers" />
+          <option value="xdebug_get_monitored_functions" />
+          <option value="xdebug_get_profiler_filename" />
+          <option value="xdebug_get_stack_depth" />
+          <option value="xdebug_get_tracefile_name" />
+          <option value="xdebug_is_enabled" />
+          <option value="xdebug_memory_usage" />
+          <option value="xdebug_peak_memory_usage" />
+          <option value="xdebug_print_function_stack" />
+          <option value="xdebug_start_code_coverage" />
+          <option value="xdebug_start_error_collection" />
+          <option value="xdebug_start_function_monitor" />
+          <option value="xdebug_start_trace" />
+          <option value="xdebug_stop_code_coverage" />
+          <option value="xdebug_stop_error_collection" />
+          <option value="xdebug_stop_function_monitor" />
+          <option value="xdebug_stop_trace" />
+          <option value="xdebug_time_index" />
+          <option value="xdebug_var_dump" />
+        </list>
+      </option>
+      <option name="migratedIntoUserSpace" value="true" />
+    </inspection_tool>
     <inspection_tool class="IncorrectHttpHeaderInspection" enabled="true" level="WARNING" enabled_by_default="true">
       <option name="customHeaders">
         <set>
diff --git a/src/FederationLib/Classes/Configuration.php b/src/FederationLib/Classes/Configuration.php
index 2d77cd4..30f33ea 100644
--- a/src/FederationLib/Classes/Configuration.php
+++ b/src/FederationLib/Classes/Configuration.php
@@ -320,6 +320,11 @@
          */
         public static function getObjectCacheEnabled(string $name): bool
         {
+            if(self::isCacheSystemEnabled() === false)
+            {
+                return false;
+            }
+
             return (bool)self::getConfiguration()['cache_system']['cache'][sprintf('%s_enabled', $name)];
         }
 
diff --git a/src/FederationLib/Interfaces/PeerMetadataInterface.php b/src/FederationLib/Interfaces/PeerMetadataInterface.php
index cfe5742..5fbf623 100644
--- a/src/FederationLib/Interfaces/PeerMetadataInterface.php
+++ b/src/FederationLib/Interfaces/PeerMetadataInterface.php
@@ -3,6 +3,7 @@
     namespace FederationLib\Interfaces;
 
     use FederationLib\Exceptions\Standard\InvalidPeerMetadataException;
+    use FederationLib\Objects\ParsedFederatedAddress;
 
     interface PeerMetadataInterface extends SerializableObjectInterface
     {
@@ -34,9 +35,9 @@
         /**
          * Returns the calculated standard federated address of the peer
          *
-         * @return string
+         * @return ParsedFederatedAddress
          */
-        public function getFederatedAddress(): string;
+        public function getFederatedAddress(): ParsedFederatedAddress;
 
         /**
          * Sets the timestamp of when the peer record was last updated (this is usually used internally)
@@ -56,10 +57,10 @@
         /**
          * Sets the Client's UUID that last updated the peer record (this is usually used internally)
          *
-         * @param string|null $client
+         * @param string|null $client_uuid
          * @return void
          */
-        public function setUpdatedClient(?string $client): void;
+        public function setUpdatedClient(?string $client_uuid): void;
 
         /**
          * Returns the Client's UUID that last updated the peer record
diff --git a/src/FederationLib/Interfaces/PeerMetadataManagerInterface.php b/src/FederationLib/Interfaces/PeerMetadataManagerInterface.php
index 455caaf..f169289 100644
--- a/src/FederationLib/Interfaces/PeerMetadataManagerInterface.php
+++ b/src/FederationLib/Interfaces/PeerMetadataManagerInterface.php
@@ -13,26 +13,26 @@
          * data from the given $client_uuid
          *
          * @param ClientRecord|string $client_uuid
-         * @param TelegramUserMetadata $telegram_user_metadata
+         * @param PeerMetadataInterface $peer_metadata
          * @return string
          */
-        public function syncMetadata(ClientRecord|string $client_uuid, TelegramUserMetadata $telegram_user_metadata): string;
+        public function syncMetadata(ClientRecord|string $client_uuid, PeerMetadataInterface $peer_metadata): string;
 
         /**
          * Registers the metadata of the given federated address, this will ignore raw metadata & use data from the
          * given $client_uuid
          *
          * @param ClientRecord|string $client_uuid
-         * @param TelegramUserMetadata $telegram_user_metadata
+         * @param PeerMetadataInterface $peer_metadata
          * @return string
          */
-        public function registerMetadata(ClientRecord|string $client_uuid, TelegramUserMetadata $telegram_user_metadata): string;
+        public function registerMetadata(ClientRecord|string $client_uuid, PeerMetadataInterface $peer_metadata): string;
 
         /**
          * Returns the metadata of the given federated address, this returns the full raw metadata
          *
          * @param ParsedFederatedAddress|string $federated_address
-         * @return TelegramUserMetadata
+         * @return PeerMetadataInterface
          */
-        public function getMetadata(ParsedFederatedAddress|string $federated_address): TelegramUserMetadata;
+        public function getMetadata(ParsedFederatedAddress|string $federated_address): PeerMetadataInterface;
     }
\ No newline at end of file
diff --git a/src/FederationLib/Managers/MetadataManagers/TelegramChatManager.php b/src/FederationLib/Managers/MetadataManagers/TelegramChatManager.php
new file mode 100644
index 0000000..5da2e68
--- /dev/null
+++ b/src/FederationLib/Managers/MetadataManagers/TelegramChatManager.php
@@ -0,0 +1,282 @@
+<?php
+
+    namespace FederationLib\Managers\MetadataManagers;
+
+    use Doctrine\DBAL\ParameterType;
+    use Exception;
+    use FederationLib\Classes\Configuration;
+    use FederationLib\Classes\Database;
+    use FederationLib\Classes\Utilities;
+    use FederationLib\Enums\DatabaseTables;
+    use FederationLib\Enums\Misc;
+    use FederationLib\Exceptions\DatabaseException;
+    use FederationLib\Exceptions\Standard\InvalidPeerMetadataException;
+    use FederationLib\Exceptions\Standard\PeerMetadataNotFoundException;
+    use FederationLib\Interfaces\PeerMetadataInterface;
+    use FederationLib\Interfaces\PeerMetadataManagerInterface;
+    use FederationLib\Managers\RedisConnectionManager;
+    use FederationLib\Objects\ClientRecord;
+    use FederationLib\Objects\ParsedFederatedAddress;
+    use FederationLib\Objects\Standard\PeerMetadata\TelegramChatMetadata;
+    use LogLib\Log;
+
+    class TelegramChatManager implements PeerMetadataManagerInterface
+    {
+        /**
+         * Syncs the metadata into the database
+         *
+         * @param ClientRecord|string $client_uuid
+         * @param PeerMetadataInterface $peer_metadata
+         * @return string
+         * @throws DatabaseException
+         * @throws InvalidPeerMetadataException
+         */
+        public function syncMetadata(ClientRecord|string $client_uuid, PeerMetadataInterface $peer_metadata): string
+        {
+            if($client_uuid instanceof ClientRecord)
+            {
+                $client_uuid = $client_uuid->getUuid();
+            }
+
+            $peer_metadata->validate();
+            $cache_key = sprintf('telegram_chat_metadata:%s', $peer_metadata->getFederatedAddress());
+            $redis_client = null;
+
+            if(Configuration::getObjectCacheEnabled('peer_objects'))
+            {
+                try
+                {
+                    $redis_client = RedisConnectionManager::getConnectionFromConfig('peer_objects');
+
+                    if($redis_client->exists($cache_key))
+                    {
+                        $redis_client->del($cache_key);
+                    }
+                }
+                catch(Exception $e)
+                {
+                    Log::warning(Misc::FEDERATIONLIB, sprintf('There was an error with the cache system while tyring to sync peer metadata with the Redis server: %s', $e->getMessage()), $e);
+                }
+            }
+
+            try
+            {
+                $old_metadata = $this->getMetadata($peer_metadata->getFederatedAddress());
+            }
+            catch(PeerMetadataNotFoundException $e)
+            {
+                unset($e);
+
+                // If it doesn't exist, we create it instead of updating it
+                return $this->registerMetadata($client_uuid, $peer_metadata);
+            }
+
+            // Take the old metadata and get the differences
+            $differences = Utilities::metadataDifferences($old_metadata, $peer_metadata);
+
+            try
+            {
+                // If there are no differences, then we don't need to update the database
+                if(count($differences) === 0)
+                {
+                    if($redis_client !== null && Configuration::getObjectCacheTtl('peer_objects') > 0)
+                    {
+                        // Reset the TTL since we just accessed it
+                        $redis_client->expire($cache_key, Configuration::getObjectCacheTtl('peer_objects'));
+                    }
+
+                    return $peer_metadata->getFederatedAddress();
+                }
+
+                $qb = Database::getConnection()->createQueryBuilder();
+                $qb->update(DatabaseTables::PEERS_TELEGRAM_CHAT);
+                $qb->where('federated_address = :federated_address');
+                $qb->setParameter('federated_address', $peer_metadata->getFederatedAddress());
+                $qb->set('updated_timestamp', $qb->createNamedParameter(time(), ParameterType::INTEGER));
+                $qb->set('updated_client', $qb->createNamedParameter($client_uuid));
+                $qb->setMaxResults(1);
+
+                foreach($differences as $key => $value)
+                {
+                    $qb->set($key, $qb->createNamedParameter($value));
+                }
+
+                $qb->executeQuery();
+            }
+            catch(Exception $e)
+            {
+                throw new DatabaseException(sprintf('There was a database error while trying to sync peer metadata: %s', $e->getMessage()), $e);
+            }
+
+            if($redis_client !== null && count($differences) > 0)
+            {
+                try
+                {
+                    foreach($differences as $key => $value)
+                    {
+                        $redis_client->hSet($cache_key, $key, $value);
+                    }
+                }
+                catch(Exception $e)
+                {
+                    Log::warning(Misc::FEDERATIONLIB, sprintf('There was an error with the cache system while tyring to sync peer metadata with the Redis server: %s', $e->getMessage()), $e);
+                }
+            }
+
+            return $peer_metadata->getFederatedAddress();
+        }
+
+        /**
+         * Registers the metadata into the database
+         *
+         * @param ClientRecord|string $client_uuid
+         * @param PeerMetadataInterface $peer_metadata
+         * @return string
+         * @throws DatabaseException
+         */
+        public function registerMetadata(ClientRecord|string $client_uuid, PeerMetadataInterface $peer_metadata): string
+        {
+            if($client_uuid instanceof ClientRecord)
+            {
+                $client_uuid = $client_uuid->getUuid();
+            }
+
+            try
+            {
+                $peer_metadata->validate();
+                $qb = Database::getConnection()->createQueryBuilder();
+                $qb->insert(DatabaseTables::PEERS_TELEGRAM_CHAT);
+
+                $qb->setValue('federated_address', $qb->createNamedParameter($peer_metadata->getFederatedAddress()));
+                $qb->setValue('updated_timestamp', $qb->createNamedParameter(time(), ParameterType::INTEGER));
+                $qb->setValue('updated_client', $qb->createNamedParameter($client_uuid));
+
+                foreach($peer_metadata->toArray() as $key => $value)
+                {
+                    switch(gettype($value))
+                    {
+                        case 'array':
+                            $qb->setValue($key, $qb->createNamedParameter(implode(',', $value)));
+                            break;
+                        case 'NULL':
+                            $qb->setValue($key, $qb->createNamedParameter(null, ParameterType::NULL));
+                            break;
+                        case 'boolean':
+                            $qb->setValue($key, $qb->createNamedParameter((int)$value, ParameterType::INTEGER));
+                            break;
+                        case 'integer':
+                            $qb->setValue($key, $qb->createNamedParameter($value, ParameterType::INTEGER));
+                            break;
+
+                        default:
+                            $qb->setValue($key, $qb->createNamedParameter($value));
+                            break;
+                    }
+                }
+
+                $qb->executeQuery();
+            }
+            catch(Exception $e)
+            {
+                throw new DatabaseException(sprintf('There was a database error while trying to register peer metadata: %s', $e->getMessage()), $e);
+            }
+
+            return $peer_metadata->getFederatedAddress();
+        }
+
+        /**
+         * @param string|ParsedFederatedAddress $federated_address
+         * @return PeerMetadataInterface
+         * @throws DatabaseException
+         * @throws PeerMetadataNotFoundException
+         */
+        public function getMetadata(string|ParsedFederatedAddress $federated_address): PeerMetadataInterface
+        {
+            if(Configuration::getObjectCacheEnabled('peer_objects'))
+            {
+                try
+                {
+                    $redis = RedisConnectionManager::getConnectionFromConfig('peer_objects');
+                    $key = sprintf('telegram_chat_metadata:%s', $federated_address->getAddress());
+
+                    if($redis->exists($key))
+                    {
+                        $telegram_chat_metadata = TelegramChatMetadata::fromArray($redis->hGetAll($key), true);
+
+                        if(Configuration::getObjectCacheTTL('peer_objects') > 0)
+                        {
+                            $redis->expire($key, Configuration::getObjectCacheTTL('peer_objects'));
+                        }
+
+                        Log::debug(Misc::FEDERATIONLIB, sprintf('Loaded peer metadata object %s from cache', $federated_address->getAddress()));
+                        return $telegram_chat_metadata;
+                    }
+                }
+                catch(Exception $e)
+                {
+                    Log::warning(Misc::FEDERATIONLIB, sprintf('Failed to load peer metadata object %s from cache: %s', $federated_address->getAddress(), $e->getMessage()));
+                }
+            }
+
+            $qb = Database::getConnection()->createQueryBuilder();
+            $qb->select(
+                'id',
+                'type',
+                'title',
+                'username',
+                'first_name',
+                'last_name',
+                'is_forum',
+                'updated_timestamp',
+                'updated_client'
+            );
+            $qb->from(DatabaseTables::PEERS_TELEGRAM_CHAT);
+            $qb->where('federated_address = :federated_address');
+            $qb->setParameter('federated_address', $federated_address->getAddress());
+            $qb->setMaxResults(1);
+
+            try
+            {
+                $result = $qb->executeQuery();
+
+                if($result->rowCount() === 0)
+                {
+                    throw new PeerMetadataNotFoundException(sprintf('PeerRecord metadata not found for federated address %s', $federated_address->getAddress()));
+                }
+
+                $telegram_chat_metadata = TelegramChatMetadata::fromArray($result->fetchAssociative(), true);
+            }
+            catch(PeerMetadataNotFoundException $e)
+            {
+                throw $e;
+            }
+            catch(Exception $e)
+            {
+                throw new DatabaseException(sprintf('Failed to get peer metadata for federated address %s', $federated_address->getAddress()), $e);
+            }
+
+            if(Configuration::isCacheSystemEnabled() && Configuration::getObjectCacheEnabled('peer_objects'))
+            {
+                try
+                {
+                    $redis = RedisConnectionManager::getConnectionFromConfig('peer_objects');
+
+                    $key = sprintf('telegram_chat_metadata:%s', $federated_address);
+                    $redis->hMSet($key, $telegram_chat_metadata->toArray());
+
+                    if(Configuration::getObjectCacheTTL('peer_objects') > 0)
+                    {
+                        $redis->expire($key, Configuration::getObjectCacheTTL('peer_objects'));
+                    }
+
+                    Log::debug(Misc::FEDERATIONLIB, sprintf('Cached peer metadata object %s', $federated_address->getAddress()));
+                }
+                catch(Exception $e)
+                {
+                    Log::warning(Misc::FEDERATIONLIB, sprintf('Failed to cache peer metadata object %s: %s', $federated_address->getAddress(), $e->getMessage()));
+                }
+            }
+
+            return $telegram_chat_metadata;
+        }
+    }
\ No newline at end of file
diff --git a/src/FederationLib/Managers/MetadataManagers/TelegramUserManager.php b/src/FederationLib/Managers/MetadataManagers/TelegramUserManager.php
index d530d6d..7f317c4 100644
--- a/src/FederationLib/Managers/MetadataManagers/TelegramUserManager.php
+++ b/src/FederationLib/Managers/MetadataManagers/TelegramUserManager.php
@@ -12,6 +12,7 @@
     use FederationLib\Exceptions\DatabaseException;
     use FederationLib\Exceptions\Standard\InvalidPeerMetadataException;
     use FederationLib\Exceptions\Standard\PeerMetadataNotFoundException;
+    use FederationLib\Interfaces\PeerMetadataInterface;
     use FederationLib\Interfaces\PeerMetadataManagerInterface;
     use FederationLib\Managers\RedisConnectionManager;
     use FederationLib\Objects\ClientRecord;
@@ -23,23 +24,23 @@
     {
         /**
          * @param ClientRecord|string $client_uuid
-         * @param TelegramUserMetadata $telegram_user_metadata
+         * @param TelegramUserMetadata $peer_metadata
          * @return string
          * @throws DatabaseException
          * @throws InvalidPeerMetadataException
          */
-        public function syncMetadata(ClientRecord|string $client_uuid, TelegramUserMetadata $telegram_user_metadata): string
+        public function syncMetadata(ClientRecord|string $client_uuid, PeerMetadataInterface $peer_metadata): string
         {
             if($client_uuid instanceof ClientRecord)
             {
                 $client_uuid = $client_uuid->getUuid();
             }
 
-            $telegram_user_metadata->validate();
-            $cache_key = sprintf('telegram_user_metadata:%s', $telegram_user_metadata->getFederatedAddress());
+            $peer_metadata->validate();
+            $cache_key = sprintf('telegram_user_metadata:%s', $peer_metadata->getFederatedAddress());
             $redis_client = null;
 
-            if(Configuration::isCacheSystemEnabled() && Configuration::getObjectCacheEnabled('peer_objects'))
+            if(Configuration::getObjectCacheEnabled('peer_objects'))
             {
                 try
                 {
@@ -58,18 +59,18 @@
 
             try
             {
-                $old_metadata = $this->getMetadata($telegram_user_metadata->getFederatedAddress());
+                $old_metadata = $this->getMetadata($peer_metadata->getFederatedAddress());
             }
             catch(PeerMetadataNotFoundException $e)
             {
                 unset($e);
 
                 // If it doesn't exist, we create it instead of updating it
-                return $this->registerMetadata($client_uuid, $telegram_user_metadata);
+                return $this->registerMetadata($client_uuid, $peer_metadata);
             }
 
             // Take the old metadata and get the differences
-            $differences = Utilities::metadataDifferences($old_metadata, $telegram_user_metadata);
+            $differences = Utilities::metadataDifferences($old_metadata, $peer_metadata);
 
             try
             {
@@ -82,13 +83,13 @@
                         $redis_client->expire($cache_key, Configuration::getObjectCacheTtl('peer_objects'));
                     }
 
-                    return $telegram_user_metadata->getFederatedAddress();
+                    return $peer_metadata->getFederatedAddress();
                 }
 
                 $qb = Database::getConnection()->createQueryBuilder();
                 $qb->update(DatabaseTables::PEERS_TELEGRAM_USER);
                 $qb->where('federated_address = :federated_address');
-                $qb->setParameter('federated_address', $telegram_user_metadata->getFederatedAddress());
+                $qb->setParameter('federated_address', $peer_metadata->getFederatedAddress());
                 $qb->set('updated_timestamp', $qb->createNamedParameter(time(), ParameterType::INTEGER));
                 $qb->set('updated_client', $qb->createNamedParameter($client_uuid));
                 $qb->setMaxResults(1);
@@ -120,18 +121,18 @@
                 }
             }
 
-            return $telegram_user_metadata->getFederatedAddress();
+            return $peer_metadata->getFederatedAddress();
         }
 
         /**
          * Registers the client's metadata with the database
          *
          * @param ClientRecord|string $client_uuid
-         * @param TelegramUserMetadata $telegram_user_metadata
+         * @param TelegramUserMetadata $peer_metadata
          * @return string
          * @throws DatabaseException
          */
-        public function registerMetadata(ClientRecord|string $client_uuid, TelegramUserMetadata $telegram_user_metadata): string
+        public function registerMetadata(ClientRecord|string $client_uuid, PeerMetadataInterface $peer_metadata): string
         {
             if($client_uuid instanceof ClientRecord)
             {
@@ -140,15 +141,15 @@
 
             try
             {
-                $telegram_user_metadata->validate();
+                $peer_metadata->validate();
                 $qb = Database::getConnection()->createQueryBuilder();
                 $qb->insert(DatabaseTables::PEERS_TELEGRAM_USER);
 
-                $qb->setValue('federated_address', $qb->createNamedParameter($telegram_user_metadata->getFederatedAddress()));
+                $qb->setValue('federated_address', $qb->createNamedParameter($peer_metadata->getFederatedAddress()));
                 $qb->setValue('updated_timestamp', $qb->createNamedParameter(time(), ParameterType::INTEGER));
                 $qb->setValue('updated_client', $qb->createNamedParameter($client_uuid));
 
-                foreach($telegram_user_metadata->toArray() as $key => $value)
+                foreach($peer_metadata->toArray() as $key => $value)
                 {
                     switch(gettype($value))
                     {
@@ -178,7 +179,7 @@
                 throw new DatabaseException(sprintf('There was a database error while trying to register peer metadata: %s', $e->getMessage()), $e);
             }
 
-            return $telegram_user_metadata->getFederatedAddress();
+            return $peer_metadata->getFederatedAddress();
         }
 
         /**
@@ -189,7 +190,7 @@
          */
         public function getMetadata(ParsedFederatedAddress|string $federated_address): TelegramUserMetadata
         {
-            if(Configuration::isCacheSystemEnabled() && Configuration::getObjectCacheEnabled('peer_objects'))
+            if(Configuration::getObjectCacheEnabled('peer_objects'))
             {
                 try
                 {
diff --git a/src/FederationLib/Managers/PeerManager.php b/src/FederationLib/Managers/PeerManager.php
index ec69227..cc8e018 100644
--- a/src/FederationLib/Managers/PeerManager.php
+++ b/src/FederationLib/Managers/PeerManager.php
@@ -70,11 +70,9 @@
          * @param ParsedFederatedAddress|string $federated_address
          * @param array $peer_metadata
          * @return void
-         * @throws CacheConnectionException
          * @throws DatabaseException
          * @throws InvalidFederatedAddressException
          * @throws InvalidPeerMetadataException
-         * @throws RedisException
          * @throws UnsupportedPeerType
          */
         public function syncPeer(ClientRecord|string $client_uuid, ParsedFederatedAddress|string $federated_address, array $peer_metadata): void
diff --git a/src/FederationLib/Objects/Standard/Client.php b/src/FederationLib/Objects/Standard/Client.php
index 602e552..6a5360e 100644
--- a/src/FederationLib/Objects/Standard/Client.php
+++ b/src/FederationLib/Objects/Standard/Client.php
@@ -60,7 +60,7 @@
             {
                 return;
             }
-
+            
             $this->uuid = $client->getUuid();
             $this->enabled = $client->isEnabled();
             $this->name = $client->getName();
diff --git a/src/FederationLib/Objects/Standard/PeerMetadata/TelegramChatMetadata.php b/src/FederationLib/Objects/Standard/PeerMetadata/TelegramChatMetadata.php
new file mode 100644
index 0000000..ddb0687
--- /dev/null
+++ b/src/FederationLib/Objects/Standard/PeerMetadata/TelegramChatMetadata.php
@@ -0,0 +1,293 @@
+<?php
+
+    /** @noinspection PhpMissingFieldTypeInspection */
+
+    namespace FederationLib\Objects\Standard\PeerMetadata;
+
+    use FederationLib\Classes\Validate;
+    use FederationLib\Enums\Standard\InternetPeerType;
+    use FederationLib\Exceptions\Standard\InvalidPeerMetadataException;
+    use FederationLib\Interfaces\PeerMetadataInterface;
+    use FederationLib\Objects\ParsedFederatedAddress;
+
+    class TelegramChatMetadata implements PeerMetadataInterface
+    {
+        /**
+         * @var int
+         */
+        private $id;
+
+        /**
+         * @var string
+         */
+        private $type;
+
+        /**
+         * @var string|null
+         */
+        private $title;
+
+        /**
+         * @var string|null
+         */
+        private $username;
+
+        /**
+         * @var string|null
+         */
+        private $first_name;
+
+        /**
+         * @var string|null
+         */
+        private $last_name;
+
+        /**
+         * @var bool
+         */
+        private $is_forum;
+
+        /**
+         * @var int|null
+         */
+        private $updated_timestamp;
+
+        /**
+         * @var string|null
+         */
+        private $updated_client;
+
+        /**
+         * Validates the metadata, throws an exception if the metadata is invalid.
+         *
+         * @return void
+         * @throws InvalidPeerMetadataException
+         */
+        public function validate(): void
+        {
+            $required_properties = [
+                'id' => 'integer',
+                'type' => 'string'
+            ];
+
+            $optional_properties = [
+                'title' => 'string',
+                'username' => 'string',
+                'first_name' => 'string',
+                'last_name' => 'string',
+                'is_forum' => 'boolean'
+            ];
+
+            Validate::validateMetadata($this->toArray(), $required_properties, $optional_properties);
+
+            if(!in_array(strtolower($this->type), ['private', 'group', 'supergroup', 'channel']))
+            {
+                throw new InvalidPeerMetadataException(sprintf('The metadata contains an invalid value for the property "type": got %s"', $this->type));
+            }
+        }
+
+        /**
+         * Indicates whether this peer is automated
+         * (in this case it's never because it's an internet peer)
+         *
+         * @return bool
+         */
+        public function isAutomated(): bool
+        {
+            return false;
+        }
+
+        /**
+         * Returns the platform-specific ID for this peer
+         *
+         * @return string
+         */
+        public function getPlatformId(): string
+        {
+            return $this->id;
+        }
+
+        /**
+         * Returns the full federated address for this peer
+         *
+         * @return ParsedFederatedAddress
+         */
+        public function getFederatedAddress(): ParsedFederatedAddress
+        {
+            return new ParsedFederatedAddress(sprintf('%s:%s', InternetPeerType::TELEGRAM_CHAT, $this->id));
+        }
+
+        /**
+         * Returns the Client UUID that last updated this metadata
+         *
+         * @return string|null
+         */
+        public function getUpdatedClient(): ?string
+        {
+            return $this->updated_client;
+        }
+
+        /**
+         * Sets the client UUID that last updated this metadata
+         *
+         * @param string|null $client_uuid
+         * @return void
+         */
+        public function setUpdatedClient(?string $client_uuid): void
+        {
+            $this->updated_client = $client_uuid;
+        }
+
+        /**
+         * Returns the Unix Timestamp for when this metadata was last updated
+         *
+         * @return int|null
+         */
+        public function getLastUpdatedTimestamp(): ?int
+        {
+            return $this->updated_timestamp;
+        }
+
+        /**
+         * Sets the last updated timestamp
+         *
+         * @param int|null $timestamp
+         * @return void
+         */
+        public function setLastUpdatedTimestamp(?int $timestamp): void
+        {
+            $this->updated_timestamp = $timestamp;
+        }
+
+        /**
+         * Unique identifier for this chat. This number may have more than 32 significant bits and some programming
+         * languages may have difficulty/silent defects in interpreting it. But it has at most 52 significant bits, so
+         * a signed 64-bit integer or double-precision float type are safe for storing this identifier.
+         *
+         * @return int
+         */
+        public function getId(): int
+        {
+            return $this->id;
+        }
+
+        /**
+         * Type of chat, can be either “private”, “group”, “supergroup” or “channel”
+         *
+         * @return string
+         */
+        public function getType(): string
+        {
+            return $this->type;
+        }
+
+        /**
+         * Optional. Title, for supergroups, channels and group chats
+         *
+         * @return string|null
+         */
+        public function getTitle(): ?string
+        {
+            return $this->title;
+        }
+
+        /**
+         * Optional. Username, for private chats, supergroups and channels if available
+         *
+         * @return string|null
+         */
+        public function getUsername(): ?string
+        {
+            return $this->username;
+        }
+
+        /**
+         *  Optional. First name of the other party in a private chat
+         *
+         * @return string|null
+         */
+        public function getFirstName(): ?string
+        {
+            return $this->first_name;
+        }
+
+        /**
+         * Optional. Last name of the other party in a private chat
+         *
+         * @return string|null
+         */
+        public function getLastName(): ?string
+        {
+            return $this->last_name;
+        }
+
+        /**
+         * Optional. True, if the supergroup chat is a forum (has topics enabled)
+         *
+         * @link https://telegram.org/blog/topics-in-groups-collectible-usernames#topics-in-groups
+         * @return bool
+         */
+        public function isForum(): bool
+        {
+            return $this->is_forum;
+        }
+
+        /**
+         * Returns an array representation of this object
+         *
+         * @param bool $raw
+         * @return array
+         */
+        public function toArray(bool $raw=false): array
+        {
+            $return = [
+                'id' => $this->id,
+                'type' => $this->type,
+                'title' => $this->title,
+                'username' => $this->username,
+                'first_name' => $this->first_name,
+                'last_name' => $this->last_name,
+                'is_forum' => $this->is_forum
+            ];
+
+            if (!$raw)
+            {
+                return $return;
+            }
+
+            return array_merge($return, [
+                'updated_timestamp' => $this->updated_timestamp,
+                'updated_client' => $this->updated_client
+            ]);
+        }
+
+        /**
+         * Constructs object from an array representation
+         *
+         * @param array $array
+         * @param bool $raw
+         * @return TelegramChatMetadata
+         */
+        public static function fromArray(array $array, bool $raw=false): TelegramChatMetadata
+        {
+            $object = new self();
+
+            $object->id = $array['id'];
+            $object->type = $array['type'];
+            $object->title = $array['title'];
+            $object->username = $array['username'];
+            $object->first_name = $array['first_name'];
+            $object->last_name = $array['last_name'];
+            $object->is_forum = $array['is_forum'];
+
+            if(!$raw)
+            {
+                return $object;
+            }
+
+            $object->updated_timestamp = $array['updated_timestamp'];
+            $object->updated_client = $array['updated_client'];
+
+            return $object;
+        }
+    }
\ No newline at end of file
diff --git a/src/FederationLib/Objects/Standard/PeerMetadata/TelegramUserMetadata.php b/src/FederationLib/Objects/Standard/PeerMetadata/TelegramUserMetadata.php
index 55dcf89..72f20ea 100644
--- a/src/FederationLib/Objects/Standard/PeerMetadata/TelegramUserMetadata.php
+++ b/src/FederationLib/Objects/Standard/PeerMetadata/TelegramUserMetadata.php
@@ -5,9 +5,11 @@
 
     namespace FederationLib\Objects\Standard\PeerMetadata;
 
+    use FederationLib\Classes\Validate;
     use FederationLib\Enums\Standard\UserPeerType;
     use FederationLib\Exceptions\Standard\InvalidPeerMetadataException;
     use FederationLib\Interfaces\PeerMetadataInterface;
+    use FederationLib\Objects\ParsedFederatedAddress;
 
     class TelegramUserMetadata implements PeerMetadataInterface
     {
@@ -63,50 +65,20 @@
          */
         public function validate(): void
         {
-            if($this->id === null)
-            {
-                throw new InvalidPeerMetadataException(sprintf('The property "id" is required in the metadata for peer type %s', UserPeerType::TELEGRAM_USER));
-            }
+            $required_properties = [
+                'id' => 'integer',
+                'is_bot' => 'boolean',
+                'first_name' => 'string',
+                'is_premium' => 'boolean',
+            ];
 
-            if(!is_int($this->id))
-            {
-                throw new InvalidPeerMetadataException(sprintf('The property "id" must be an integer in metadata for peer type %s, got %s', UserPeerType::TELEGRAM_USER, gettype($this->id)));
-            }
+            $optional_properties = [
+                'last_name' => 'string',
+                'username' => 'string',
+                'language_code' => 'string',
+            ];
 
-            if(!is_bool($this->is_bot))
-            {
-                throw new InvalidPeerMetadataException(sprintf('The property "is_bot" must be a boolean in metadata for peer type %s, got %s', UserPeerType::TELEGRAM_USER, gettype($this->is_bot)));
-            }
-
-            if($this->first_name === null)
-            {
-                throw new InvalidPeerMetadataException(sprintf('The property "first_name" is required in the metadata for peer type %s', UserPeerType::TELEGRAM_USER));
-            }
-
-            if(!is_string($this->first_name))
-            {
-                throw new InvalidPeerMetadataException(sprintf('The property "first_name" must be a string in metadata for peer type %s, got %s', UserPeerType::TELEGRAM_USER, gettype($this->first_name)));
-            }
-
-            if($this->last_name !== null && !is_string($this->last_name))
-            {
-                throw new InvalidPeerMetadataException(sprintf('The property "last_name" must be a string in metadata for peer type %s, got %s', UserPeerType::TELEGRAM_USER, gettype($this->last_name)));
-            }
-
-            if($this->username !== null && !is_string($this->username))
-            {
-                throw new InvalidPeerMetadataException(sprintf('The property "username" must be a string in metadata for peer type %s, got %s', UserPeerType::TELEGRAM_USER, gettype($this->username)));
-            }
-
-            if($this->language_code !== null && !is_string($this->language_code))
-            {
-                throw new InvalidPeerMetadataException(sprintf('The property "language_code" must be a string in metadata for peer type %s, got %s', UserPeerType::TELEGRAM_USER, gettype($this->language_code)));
-            }
-
-            if(!is_bool($this->is_premium))
-            {
-                throw new InvalidPeerMetadataException(sprintf('The property "is_premium" must be a boolean in metadata for peer type %s, got %s', UserPeerType::TELEGRAM_USER, gettype($this->is_premium)));
-            }
+            Validate::validateMetadata($this->toArray(), $required_properties, $optional_properties);
         }
 
         /**
@@ -133,11 +105,11 @@
          * Returns the standard federated address of the peer
          * Format: telegram.user:<id>
          *
-         * @return string
+         * @return ParsedFederatedAddress
          */
-        public function getFederatedAddress(): string
+        public function getFederatedAddress(): ParsedFederatedAddress
         {
-            return sprintf('%s:%s', UserPeerType::TELEGRAM_USER, $this->id);
+            return new ParsedFederatedAddress(sprintf('%s:%s', UserPeerType::TELEGRAM_USER, $this->id));
         }
 
         /**
@@ -153,12 +125,12 @@
         /**
          * Sets the client UUID that last updated the record
          *
-         * @param string|null $client
+         * @param string|null $client_uuid
          * @return void
          */
-        public function setUpdatedClient(?string $client): void
+        public function setUpdatedClient(?string $client_uuid): void
         {
-            $this->updated_client = $client;
+            $this->updated_client = $client_uuid;
         }
 
         /**