77 */
88namespace OCA \Files_Sharing \Command ;
99
10+ use OCA \Files_Sharing \External \ExternalShareMapper ;
1011use OCP \DB \QueryBuilder \IQueryBuilder ;
1112use OCP \Federation \ICloudIdManager ;
1213use OCP \IDBConnection ;
2223class CleanupRemoteStorages extends Command {
2324
2425 public function __construct (
25- protected IDBConnection $ connection ,
26- private ICloudIdManager $ cloudIdManager ,
26+ protected readonly IDBConnection $ connection ,
27+ private readonly ICloudIdManager $ cloudIdManager ,
2728 ) {
2829 parent ::__construct ();
2930 }
3031
31- protected function configure () {
32+ protected function configure (): void {
3233 $ this
3334 ->setName ('sharing:cleanup-remote-storages ' )
3435 ->setDescription ('Cleanup shared storage entries that have no matching entry in the shares_external table ' )
@@ -74,10 +75,11 @@ public function execute(InputInterface $input, OutputInterface $output): int {
7475 }
7576 }
7677 }
77- return 0 ;
78+
79+ return Command::SUCCESS ;
7880 }
7981
80- public function countFiles ($ numericId , OutputInterface $ output ) {
82+ public function countFiles ($ numericId , OutputInterface $ output ): void {
8183 $ queryBuilder = $ this ->connection ->getQueryBuilder ();
8284 $ queryBuilder ->select ($ queryBuilder ->func ()->count ('fileid ' ))
8385 ->from ('filecache ' )
@@ -92,7 +94,7 @@ public function countFiles($numericId, OutputInterface $output) {
9294 $ output ->writeln ("$ count files can be deleted for storage $ numericId " );
9395 }
9496
95- public function deleteStorage ($ id , $ numericId , OutputInterface $ output ) {
97+ public function deleteStorage ($ id , $ numericId , OutputInterface $ output ): void {
9698 $ queryBuilder = $ this ->connection ->getQueryBuilder ();
9799 $ queryBuilder ->delete ('storages ' )
98100 ->where ($ queryBuilder ->expr ()->eq (
@@ -106,7 +108,7 @@ public function deleteStorage($id, $numericId, OutputInterface $output) {
106108 $ this ->deleteFiles ($ numericId , $ output );
107109 }
108110
109- public function deleteFiles ($ numericId , OutputInterface $ output ) {
111+ public function deleteFiles ($ numericId , OutputInterface $ output ): void {
110112 $ queryBuilder = $ this ->connection ->getQueryBuilder ();
111113 $ queryBuilder ->delete ('filecache ' )
112114 ->where ($ queryBuilder ->expr ()->eq (
@@ -119,7 +121,11 @@ public function deleteFiles($numericId, OutputInterface $output) {
119121 $ output ->writeln ("deleted $ count files " );
120122 }
121123
122- public function getRemoteStorages () {
124+ /**
125+ * @return array<string, int>
126+ * @throws \OCP\DB\Exception
127+ */
128+ private function getRemoteStorages (): array {
123129 $ queryBuilder = $ this ->connection ->getQueryBuilder ();
124130 $ queryBuilder ->select (['id ' , 'numeric_id ' ])
125131 ->from ('storages ' )
@@ -148,7 +154,10 @@ public function getRemoteStorages() {
148154 return $ remoteStorages ;
149155 }
150156
151- public function getRemoteShareIds () {
157+ /**
158+ * @return array<string, string>
159+ */
160+ private function getRemoteShareIds (): array {
152161 $ queryBuilder = $ this ->connection ->getQueryBuilder ();
153162 $ queryBuilder ->select (['id ' , 'share_token ' , 'owner ' , 'remote ' ])
154163 ->from ('share_external ' );
@@ -159,7 +168,6 @@ public function getRemoteShareIds() {
159168 while ($ row = $ result ->fetchAssociative ()) {
160169 $ cloudId = $ this ->cloudIdManager ->getCloudId ($ row ['owner ' ], $ row ['remote ' ]);
161170 $ remote = $ cloudId ->getRemote ();
162-
163171 $ remoteShareIds [$ row ['id ' ]] = 'shared:: ' . md5 ($ row ['share_token ' ] . '@ ' . $ remote );
164172 }
165173 $ result ->closeCursor ();
0 commit comments