| @@ 117-124 (lines=8) @@ | ||
| 114 | * @param IUser $user |
|
| 115 | * @param int $id |
|
| 116 | */ |
|
| 117 | public function deleteById(IUser $user, $id) { |
|
| 118 | /* @var $qb IQueryBuilder */ |
|
| 119 | $qb = $this->db->getQueryBuilder(); |
|
| 120 | $qb->delete('authtoken') |
|
| 121 | ->where($qb->expr()->eq('id', $qb->createNamedParameter($id))) |
|
| 122 | ->andWhere($qb->expr()->eq('uid', $qb->createNamedParameter($user->getUID()))); |
|
| 123 | $qb->execute(); |
|
| 124 | } |
|
| 125 | } |
|
| 126 | ||
| @@ 243-251 (lines=9) @@ | ||
| 240 | * @param int $mountId |
|
| 241 | * @param string $newMountPoint |
|
| 242 | */ |
|
| 243 | public function setMountPoint($mountId, $newMountPoint) { |
|
| 244 | $builder = $this->connection->getQueryBuilder(); |
|
| 245 | ||
| 246 | $query = $builder->update('external_mounts') |
|
| 247 | ->set('mount_point', $builder->createNamedParameter($newMountPoint)) |
|
| 248 | ->where($builder->expr()->eq('mount_id', $builder->createNamedParameter($mountId, IQueryBuilder::PARAM_INT))); |
|
| 249 | ||
| 250 | $query->execute(); |
|
| 251 | } |
|
| 252 | ||
| 253 | /** |
|
| 254 | * @param int $mountId |
|
| @@ 257-265 (lines=9) @@ | ||
| 254 | * @param int $mountId |
|
| 255 | * @param string $newAuthBackend |
|
| 256 | */ |
|
| 257 | public function setAuthBackend($mountId, $newAuthBackend) { |
|
| 258 | $builder = $this->connection->getQueryBuilder(); |
|
| 259 | ||
| 260 | $query = $builder->update('external_mounts') |
|
| 261 | ->set('auth_backend', $builder->createNamedParameter($newAuthBackend)) |
|
| 262 | ->where($builder->expr()->eq('mount_id', $builder->createNamedParameter($mountId, IQueryBuilder::PARAM_INT))); |
|
| 263 | ||
| 264 | $query->execute(); |
|
| 265 | } |
|
| 266 | ||
| 267 | /** |
|
| 268 | * @param int $mountId |
|
| @@ 287-293 (lines=7) @@ | ||
| 284 | * |
|
| 285 | * @param IJob $job |
|
| 286 | */ |
|
| 287 | public function unlockJob($job) { |
|
| 288 | $query = $this->connection->getQueryBuilder(); |
|
| 289 | $query->update('jobs') |
|
| 290 | ->set('reserved_at', $query->expr()->literal(0, IQueryBuilder::PARAM_INT)) |
|
| 291 | ->where($query->expr()->eq('id', $query->createNamedParameter($job->getId(), IQueryBuilder::PARAM_INT))); |
|
| 292 | $query->execute(); |
|
| 293 | } |
|
| 294 | ||
| 295 | /** |
|
| 296 | * get the id of the last ran job |
|
| @@ 318-324 (lines=7) @@ | ||
| 315 | $query->execute(); |
|
| 316 | } |
|
| 317 | ||
| 318 | public function setExecutionTime($job, $timeTaken) { |
|
| 319 | $query = $this->connection->getQueryBuilder(); |
|
| 320 | $query->update('jobs') |
|
| 321 | ->set('execution_duration', $query->createNamedParameter($timeTaken, IQueryBuilder::PARAM_INT)) |
|
| 322 | ->where($query->expr()->eq('id', $query->createNamedParameter($job->getId(), IQueryBuilder::PARAM_INT))); |
|
| 323 | $query->execute(); |
|
| 324 | } |
|
| 325 | ||
| 326 | /** |
|
| 327 | * @inheritdoc |
|
| @@ 98-104 (lines=7) @@ | ||
| 95 | * |
|
| 96 | * @param int $id |
|
| 97 | */ |
|
| 98 | public function removeServer($id) { |
|
| 99 | $query = $this->connection->getQueryBuilder(); |
|
| 100 | $query->delete($this->dbTable) |
|
| 101 | ->where($query->expr()->eq('id', $query->createParameter('id'))) |
|
| 102 | ->setParameter('id', $id); |
|
| 103 | $query->execute(); |
|
| 104 | } |
|
| 105 | ||
| 106 | /** |
|
| 107 | * get trusted server with given ID |
|
| @@ 301-307 (lines=7) @@ | ||
| 298 | * |
|
| 299 | * @param IUser $user |
|
| 300 | */ |
|
| 301 | public function removeUserMounts(IUser $user) { |
|
| 302 | $builder = $this->connection->getQueryBuilder(); |
|
| 303 | ||
| 304 | $query = $builder->delete('mounts') |
|
| 305 | ->where($builder->expr()->eq('user_id', $builder->createNamedParameter($user->getUID()))); |
|
| 306 | $query->execute(); |
|
| 307 | } |
|
| 308 | ||
| 309 | public function removeUserStorageMount($storageId, $userId) { |
|
| 310 | $builder = $this->connection->getQueryBuilder(); |
|
| @@ 318-324 (lines=7) @@ | ||
| 315 | $query->execute(); |
|
| 316 | } |
|
| 317 | ||
| 318 | public function remoteStorageMounts($storageId) { |
|
| 319 | $builder = $this->connection->getQueryBuilder(); |
|
| 320 | ||
| 321 | $query = $builder->delete('mounts') |
|
| 322 | ->where($builder->expr()->eq('storage_id', $builder->createNamedParameter($storageId, IQueryBuilder::PARAM_INT))); |
|
| 323 | $query->execute(); |
|
| 324 | } |
|
| 325 | } |
|
| 326 | ||
| @@ 92-101 (lines=10) @@ | ||
| 89 | * @param string $token |
|
| 90 | * @return bool |
|
| 91 | */ |
|
| 92 | public function deleteByFileIdAndToken(int $fileId, string $token) : bool { |
|
| 93 | $query = $this->db->getQueryBuilder(); |
|
| 94 | ||
| 95 | $rowCount = $query->delete($this->getTableName()) |
|
| 96 | ->where($query->expr()->eq('file_id', $query->createNamedParameter($fileId))) |
|
| 97 | ->andWhere($query->expr()->eq('token_hash', $query->createNamedParameter(\md5($token)))) |
|
| 98 | ->execute(); |
|
| 99 | ||
| 100 | return $rowCount === 1; |
|
| 101 | } |
|
| 102 | ||
| 103 | /** |
|
| 104 | * @param string $token |
|
| @@ 396-402 (lines=7) @@ | ||
| 393 | * @param int $shareId |
|
| 394 | * @param string $token |
|
| 395 | */ |
|
| 396 | protected function updateSuccessfulReShare($shareId, $token) { |
|
| 397 | $query = $this->dbConnection->getQueryBuilder(); |
|
| 398 | $query->update($this->shareTable) |
|
| 399 | ->where($query->expr()->eq('id', $query->createNamedParameter($shareId))) |
|
| 400 | ->set('token', $query->createNamedParameter($token)) |
|
| 401 | ->execute(); |
|
| 402 | } |
|
| 403 | ||
| 404 | /** |
|
| 405 | * store remote ID in federated reShare table |
|
| @@ 549-558 (lines=10) @@ | ||
| 546 | * |
|
| 547 | * @param string $shareId |
|
| 548 | */ |
|
| 549 | private function removeShareFromTableById($shareId) { |
|
| 550 | $qb = $this->dbConnection->getQueryBuilder(); |
|
| 551 | $qb->delete($this->shareTable) |
|
| 552 | ->where($qb->expr()->eq('id', $qb->createNamedParameter($shareId))); |
|
| 553 | $qb->execute(); |
|
| 554 | ||
| 555 | $qb->delete('federated_reshares') |
|
| 556 | ->where($qb->expr()->eq('share_id', $qb->createNamedParameter($shareId))); |
|
| 557 | $qb->execute(); |
|
| 558 | } |
|
| 559 | ||
| 560 | /** |
|
| 561 | * @inheritdoc |
|
| @@ 910-919 (lines=10) @@ | ||
| 907 | * @param string $uid |
|
| 908 | * @param int $shareType |
|
| 909 | */ |
|
| 910 | public function userDeleted($uid, $shareType) { |
|
| 911 | //TODO: probabaly a good idea to send unshare info to remote servers |
|
| 912 | ||
| 913 | $qb = $this->dbConnection->getQueryBuilder(); |
|
| 914 | ||
| 915 | $qb->delete($this->shareTable) |
|
| 916 | ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_REMOTE))) |
|
| 917 | ->andWhere($qb->expr()->eq('uid_owner', $qb->createNamedParameter($uid))) |
|
| 918 | ->execute(); |
|
| 919 | } |
|
| 920 | ||
| 921 | /** |
|
| 922 | * This provider does not handle groups |
|