Emiliano Balbuena · @edgebal · 1b9c9dd7 · Emiliano Balbuena · Emiliano Balbuena
--- a/Core/Channels/Delegates/Artifacts/SubscribersDelegate.php
+++ b/Core/Channels/Delegates/Artifacts/SubscribersDelegate.php
+ * @return bool 
+ */ 
+ public function delete($userGuid) 
+ { 
+ try { 
+ $cql = "SELECT * FROM friendsof WHERE key = ?"; 
+ $values = [ 
+ (string) $userGuid, 
+ ]; 
+ 
+ $prepared = new Custom(); 
+ $prepared->query($cql, $values); 
+ 
+ $rows = $this->db->request($prepared); 
+ 
+ foreach ($rows as $row) { 
--- a/Core/Channels/Snapshots/Repository.php
+++ b/Core/Channels/Snapshots/Repository.php
+ * @param CassandraClient $db 
+ */ 
+ public function __construct( 
+ $db = null 
+ ) 
+ { 
+ $this->db = $db ?: Di::_()->get('Database\Cassandra\Cql'); 
+ } 
+ 
+ /** 
+ * @param string|int $userGuid 
+ * @return \Generator 
+ * @yields Snapshot[] 
+ * @throws \Exception 
+ */ 
+ public function getAll($userGuid) 
--- a/Core/Comments/Comment.php
+++ b/Core/Comments/Comment.php
 ]; 
 } 
 
+ /** 
+ * @return string[] 
+ */ 
+ public function getSnapshotable() 
--- a/Core/Comments/Manager.php
+++ b/Core/Comments/Manager.php
 /** 
 * Adds a comment and triggers creation events 
 * @param Comment $comment 
+ * @param bool $triggerEvents 
 * @return bool 
 * @throws BlockedUserException 
- * @throws \Exception 
+ * @throws \Minds\Exceptions\StopEventException 
 */ 
- public function add(Comment $comment) 
+ public function add(Comment $comment, $triggerEvents = true) 
--- a/Core/Channels/Ban.php
+++ b/Core/Channels/Ban.php
+ foreach (static::BAN_DELEGATES as $delegateClassName) { 
+ try { 
+ $delegate = $this->artifactsDelegatesFactory->build($delegateClassName); 
+ $done = $delegate->snapshot($userGuid); 
+ 
+ if (!$done) { 
+ throw new \Exception("{$delegateClassName} ban cleanup snapshot failed for {$userGuid}"); 
+ } 
+ } catch (\Exception $e) { 
+ // TODO: Fail? 
+ error_log((string) $e); 
+ $snapshotCreated = false; 
+ } 
+ } 
+ 
+ // Delete (only if all snapshots were successful) 
--- a/Core/Channels/Delegates/Artifacts/ElasticsearchDocumentsDelegate.php
+++ b/Core/Channels/Delegates/Artifacts/ElasticsearchDocumentsDelegate.php
+ 
+ return true; 
+ } 
+ 
+ /** 
+ * @param $userGuid 
+ */ 
+ protected function snapshotUser($userGuid) 
+ { 
+ $params = [ 
+ 'index' => $this->config->get('elasticsearch')['index'], 
+ 'type' => 'user', 
+ 'id' => $userGuid 
+ ]; 
+ 
+ $document = $this->elasticsearch->getClient()->get($params); 
--- a/Core/Channels/Delegates/Artifacts/ElasticsearchDocumentsDelegate.php
+++ b/Core/Channels/Delegates/Artifacts/ElasticsearchDocumentsDelegate.php
+ if (count($bulk) > 2000) { 
+ $this->elasticsearch->bulk(['body' => $bulk]); 
+ $bulk = []; 
+ } 
+ } 
+ 
+ if ($bulk) { 
+ $this->elasticsearch->bulk(['body' => $bulk]); 
+ } 
+ } 
+ 
+ /** 
+ * @param $userGuid 
+ * @throws \Exception 
+ */ 
+ protected function restoreOwnedByUser($userGuid) 
--- a/Core/Channels/Delegates/Artifacts/PostsDelegate.php
+++ b/Core/Channels/Delegates/Artifacts/PostsDelegate.php
+ * @param CassandraClient $db 
+ */ 
+ public function __construct( 
+ $repository = null, 
+ $db = null 
+ ) 
+ { 
+ $this->repository = $repository ?: new Repository(); 
+ $this->db = $db ?: Di::_()->get('Database\Cassandra\Cql'); 
+ } 
+ 
+ /** 
+ * @param string|int $userGuid 
+ * @return bool 
+ */ 
+ public function snapshot($userGuid) 
--- a/Core/Channels/Delegates/Artifacts/UserIndexesDelegate.php
+++ b/Core/Channels/Delegates/Artifacts/UserIndexesDelegate.php
+ * @param CassandraClient $db 
+ */ 
+ public function __construct( 
+ $repository = null, 
+ $db = null 
+ ) 
+ { 
+ $this->repository = $repository ?: new Repository(); 
+ $this->db = $db ?: Di::_()->get('Database\Cassandra\Cql'); 
+ } 
+ 
+ /** 
+ * @param string|int $userGuid 
+ * @return bool 
+ */ 
+ public function snapshot($userGuid)