mirror of
				https://github.com/firefly-iii/firefly-iii.git
				synced 2025-10-31 02:36:28 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			94 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			94 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
| <?php
 | |
| declare(strict_types = 1);
 | |
| /**
 | |
|  * ExportJobRepository.php
 | |
|  * Copyright (C) 2016 Sander Dorigo
 | |
|  *
 | |
|  * This software may be modified and distributed under the terms
 | |
|  * of the MIT license.  See the LICENSE file for details.
 | |
|  */
 | |
| 
 | |
| namespace FireflyIII\Repositories\ExportJob;
 | |
| 
 | |
| use Carbon\Carbon;
 | |
| use FireflyIII\Models\ExportJob;
 | |
| use FireflyIII\User;
 | |
| use Illuminate\Support\Str;
 | |
| 
 | |
| /**
 | |
|  * Class ExportJobRepository
 | |
|  *
 | |
|  * @package FireflyIII\Repositories\ExportJob
 | |
|  */
 | |
| class ExportJobRepository implements ExportJobRepositoryInterface
 | |
| {
 | |
|     /** @var User */
 | |
|     private $user;
 | |
| 
 | |
|     /**
 | |
|      * BillRepository constructor.
 | |
|      *
 | |
|      * @param User $user
 | |
|      */
 | |
|     public function __construct(User $user)
 | |
|     {
 | |
|         $this->user = $user;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * @return bool
 | |
|      */
 | |
|     public function cleanup()
 | |
|     {
 | |
|         $dayAgo = Carbon::create()->subDay();
 | |
|         $set    = ExportJob::where('created_at', '<', $dayAgo->format('Y-m-d H:i:s'))
 | |
|                            ->whereIn('status', ['never_started', 'export_status_finished', 'export_downloaded'])
 | |
|                            ->get();
 | |
| 
 | |
|         // loop set:
 | |
|         /** @var ExportJob $entry */
 | |
|         foreach ($set as $entry) {
 | |
|             $key   = $entry->key;
 | |
|             $len   = strlen($key);
 | |
|             $files = scandir(storage_path('export'));
 | |
|             /** @var string $file */
 | |
|             foreach ($files as $file) {
 | |
|                 if (substr($file, 0, $len) === $key) {
 | |
|                     unlink(storage_path('export') . DIRECTORY_SEPARATOR . $file);
 | |
|                 }
 | |
|             }
 | |
|             $entry->delete();
 | |
|         }
 | |
| 
 | |
|         return true;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * @return ExportJob
 | |
|      */
 | |
|     public function create()
 | |
|     {
 | |
|         $exportJob = new ExportJob;
 | |
|         $exportJob->user()->associate($this->user);
 | |
|         /*
 | |
|          * In theory this random string could give db error.
 | |
|          */
 | |
|         $exportJob->key    = Str::random(12);
 | |
|         $exportJob->status = 'export_status_never_started';
 | |
|         $exportJob->save();
 | |
| 
 | |
|         return $exportJob;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * @param string $key
 | |
|      *
 | |
|      * @return ExportJob|null
 | |
|      */
 | |
|     public function findByKey(string $key)
 | |
|     {
 | |
|         return $this->user->exportJobs()->where('key', $key)->first();
 | |
|     }
 | |
| 
 | |
| }
 |