<?php

namespace App\Jobs\AvatarPipeline;

use Cache;
use App\Avatar;
use App\Profile;
use Carbon\Carbon;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Str;
use Image as Intervention;
use Storage;

class AvatarOptimize implements ShouldQueue
{
	use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

	protected $profile;
	protected $current;

	/**
	 * Delete the job if its models no longer exist.
	 *
	 * @var bool
	 */
	public $deleteWhenMissingModels = true;

	/**
	 * Create a new job instance.
	 *
	 * @return void
	 */
	public function __construct(Profile $profile, $current)
	{
		$this->profile = $profile;
		$this->current = $current;
	}

	/**
	 * Execute the job.
	 *
	 * @return void
	 */
	public function handle()
	{
		$avatar = $this->profile->avatar;
		$file = storage_path("app/$avatar->media_path");

		try {
			$img = Intervention::make($file)->orientate();
			$img->fit(200, 200, function ($constraint) {
				$constraint->upsize();
			});
			$quality = config_cache('pixelfed.image_quality');
			$img->save($file, $quality);

			$avatar = Avatar::whereProfileId($this->profile->id)->firstOrFail();
			$avatar->change_count = ++$avatar->change_count;
			$avatar->last_processed_at = Carbon::now();
			$avatar->save();
			Cache::forget('avatar:' . $avatar->profile_id);
			$this->deleteOldAvatar($avatar->media_path, $this->current);

			if(config_cache('pixelfed.cloud_storage') && config_cache('instance.avatar.local_to_cloud')) {
				$this->uploadToCloud($avatar);
			} else {
				$avatar->cdn_url = null;
				$avatar->save();
			}
		} catch (Exception $e) {
		}
	}

	protected function deleteOldAvatar($new, $current)
	{
		if ( storage_path('app/'.$new) == $current ||
			 Str::endsWith($current, 'avatars/default.png') ||
			 Str::endsWith($current, 'avatars/default.jpg'))
		{
			return;
		}
		if (is_file($current)) {
			@unlink($current);
		}
	}

	protected function uploadToCloud($avatar)
	{
		$base = 'cache/avatars/' . $avatar->profile_id;
		$disk = Storage::disk(config('filesystems.cloud'));
		$disk->deleteDirectory($base);
		$path = $base . '/' . 'a' . strtolower(Str::random(random_int(3,6))) . $avatar->change_count . '.' . pathinfo($avatar->media_path, PATHINFO_EXTENSION);
		$url = $disk->put($path, Storage::get($avatar->media_path));
		$avatar->cdn_url = $disk->url($path);
		$avatar->save();
		Storage::delete($avatar->media_path);
		Cache::forget('avatar:' . $avatar->profile_id);
	}
}