66
77namespace OCA \Richdocuments \Backgroundjobs ;
88
9- use OCA \Richdocuments \Db \WopiMapper ;
109use OCP \AppFramework \Utility \ITimeFactory ;
1110use OCP \BackgroundJob \TimedJob ;
1211use OCP \DB \QueryBuilder \IQueryBuilder ;
1312use OCP \IDBConnection ;
1413
1514class Cleanup extends TimedJob {
15+ private const EXPIRY_GRACE_PERIOD_SECONDS = 60 ;
16+
1617 public function __construct (
1718 ITimeFactory $ time ,
1819 private IDBConnection $ db ,
19- private WopiMapper $ wopiMapper ,
2020 ) {
2121 parent ::__construct ($ time );
2222
@@ -28,18 +28,17 @@ protected function run($argument) {
2828 // Expire template mappings for file creation
2929 $ query = $ this ->db ->getQueryBuilder ();
3030 $ query ->delete ('richdocuments_template ' )
31- ->where ($ query ->expr ()->lte ('timestamp ' , $ query ->createNamedParameter (time () - 60 , IQueryBuilder::PARAM_INT )));
31+ ->where ($ query ->expr ()->lte ('timestamp ' , $ query ->createNamedParameter (time () - self :: EXPIRY_GRACE_PERIOD_SECONDS , IQueryBuilder::PARAM_INT )));
3232 $ query ->executeStatement ();
3333
3434 // Expired WOPI access tokens
3535 $ this ->cleanUpWopiTokens ();
3636 }
3737
3838 private function cleanUpWopiTokens () {
39- $ tokenIds = $ this ->wopiMapper ->getExpiredTokenIds (1000 );
4039 $ query = $ this ->db ->getQueryBuilder ();
4140 $ query ->delete ('richdocuments_wopi ' )
42- ->where ($ query ->expr ()->in ( ' id ' , $ query ->createNamedParameter ($ tokenIds , IQueryBuilder::PARAM_INT_ARRAY )));
41+ ->where ($ query ->expr ()->lt ( ' expiry ' , $ query ->createNamedParameter (time () - self :: EXPIRY_GRACE_PERIOD_SECONDS , IQueryBuilder::PARAM_INT )));
4342 $ query ->executeStatement ();
4443 }
4544}
0 commit comments