<?php

namespace App\Http\Controllers;

// ini_set('memory_limit', -1);
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use App\Models\Product;
use App\Models\Category;
use App\Models\S3bucket;
use App\Models\Material;
use App\Models\Pdf_test;
use App\Models\Student_test_upload;
use File;

use AWS\S3\S3Client;
use Aws\S3\S3Client as S3S3Client;
use Aws\CognitoIdentity\CognitoIdentityClient;
use Aws\Exception\AwsException;
use Aws\S3\Exception\S3Exception;
use Aws\S3\PostObjectV4;


class PublicContentController extends Controller
{
	/**
	 * Display a listing of the resource.
	 *
	 * @return \Illuminate\Http\Response
	 */
	public function index()
	{
		$data['mainMenu'] = 'publicContent';
		$data['subMenu'] = 'publicContentList';

		if (isset($_GET['query']) && strlen($_GET['query']) > 1) {
			$search_text = $_GET['query'];
			$data['products'] = DB::table('materials')->where('filename', 'LIKE', '%' . $search_text . '%')->paginate(10);
			$data['folder_name'] = 'navinclassess';
		} else {
			$data['products'] = DB::table('materials')->paginate(10);
			$data['folder_name'] = 'navinclassess';
		}
		return view('admin.publiccontent.public-content-list', $data);
	}

	/**
	 * Show the form for creating a new resource.
	 *
	 * @return \Illuminate\Http\Response
	 */
	public function create()
	{
		$data['mainMenu'] = 'publicContent';
		$data['subMenu'] = 'uploadPublicContent';
		$data['folderName'] = env('AWS_PUBLIC_FD');
		return view('admin.publiccontent.upload-public-content', $data);
	}



	public function aws_temp_url(Request $request)
	{
		if (empty($_POST['file']) && empty($_POST['type']) && empty($_POST['folder'])) {
			echo json_encode(['code' => 201, 'status' => false]);
			exit;
		}

		$accessKey = env('AWS_S3_ACCESS_KEY');
		$secretKey = env('AWS_S3_SECRET_KEY');
		$region = env('AWS_REGION');
		$host = env('AWS_HOST');
		$bucket = env('AWS_BUCKET');

		$s3 = new S3S3Client([
			'version' => 'latest',
			'region' => $region,
			'endpoint' => $host,
			'credentials' => [
				'key' => $accessKey,
				'secret' => $secretKey
			]
		]);

		$s3->putBucketCors([
			'Bucket' => $bucket, // REQUIRED
			'CORSConfiguration' => [ // REQUIRED
				'CORSRules' => [ // REQUIRED
					[
						'AllowedMethods' => ['POST', 'GET', 'HEAD', 'DELETE', 'PUT'], // REQUIRED
						'AllowedHeaders' => ['*'],
						'AllowedOrigins' => ['*'], // REQUIRED
						'ExposeHeaders' => ['ETag'],
						'MaxAgeSeconds' => 0
					],
				],
			]
		]);

		$folderName = env('AWS_PUBLIC_FD');
		$fileName = $_POST['file'];
		$formInputs = ['acl' => 'public-read'];
		$fileType = $_POST['type'];
		$fileKeyVal = $folderName . '/' . $fileName;

		$options = [
			['acl' => 'public-read'],
			['bucket' => $bucket],
			['starts-with', '$key', $fileKeyVal],
			['success_action_status' => '201'],
			['x-amz-expires' => '3600'],
			['Content-Type' => $fileType]
		];

		$expires = '+2 hours';
		$postObject = new PostObjectV4($s3, $bucket, $formInputs, $options, $expires);
		$formAttributes = $postObject->getFormAttributes();
		$formInputs = $postObject->getFormInputs();
		return json_encode(['code' => 200, 'status' => true, 'formAttributes' => $formAttributes, 'formInputs' => $formInputs]);
	}

	// Sync List
	public function listObjects(Request $request)
	{
		$admin_id = $request->session()->get('loggedIn')['id'];

		$accessKey = env('AWS_S3_ACCESS_KEY');
		$secretKey = env('AWS_S3_SECRET_KEY');
		$region = env('AWS_REGION');
		$host = env('AWS_HOST');
		$bucket = env('AWS_BUCKET');

		$fileName = env('AWS_PUBLIC_FD');


		$s3 = new S3S3Client([
			'version' => 'latest',
			'region' => $region,
			'endpoint' => $host,
			'credentials' => [
				'key' => $accessKey,
				'secret' => $secretKey
			]
		]);

		$s3->putBucketCors([
			'Bucket' => $bucket, // REQUIRED
			'CORSConfiguration' => [ // REQUIRED
				'CORSRules' => [ // REQUIRED
					[
						'AllowedMethods' => ['POST', 'GET', 'HEAD', 'DELETE', 'PUT'], // REQUIRED
						'AllowedHeaders' => ['*'],
						'AllowedOrigins' => ['*'], // REQUIRED
						'ExposeHeaders' => ['ETag'],
						'MaxAgeSeconds' => 0
					],
				],
			]
		]);

		$batchInsert = array();
		try {

			$videos = $s3->getPaginator('ListObjects', [
				'Bucket' => $bucket,
				'Prefix' => env('AWS_PUBLIC_FD')
			]);


			foreach ($videos as $video) {
				foreach ($video['Contents'] as $object) {
					// dd($video['Contents']);
					// echo $object['Key'] . PHP_EOL;
					$folderName = explode('/', $object['Key']);

					if ($folderName[0] == env('AWS_PUBLIC_FD') && ($object['Size'] > 16)) {
						$aInsert = array(
							'filename'  => basename($object['Key']),
							'path'      => $object['Key'],
							'size'      => $object['Size'],
							'etag'      => trim($object['ETag'], '"'),
							'type'      => 'pdf',
							'admin_id'  => $admin_id,
							'date'      => $object['LastModified']->format(\DateTime::ISO8601),
						);
						array_push($batchInsert, $aInsert);
					}
				}
			}

			if (!empty($batchInsert)) {
				Material::where(['admin_id' => $admin_id])->delete();
			}

			Material::insert($batchInsert);
		} catch (S3Exception $e) {
			echo $e->getMessage() . PHP_EOL;
		}
	}


	public function studentUploadFileList(Request $request)
	{
		$data['mainMenu'] = 'pdfManagement';
		$data['subMenu'] = 'studentFileList';
		$admin_id = $request->session()->get('loggedIn')['id'];

		if (isset($_GET['query']) && strlen($_GET['query']) > 1) {

			$search_text = $_GET['query'];


			$data['products'] = Student_test_upload::where('users.name', 'LIKE', '%' . $search_text . '%')
				->orwhere('users.email', 'LIKE', '%' . $search_text . '%')
				->orwhere('users.phone', 'LIKE', '%' . $search_text . '%')
				->where(['users.admin_id' => $admin_id])
				->join('users', 'student_test_uploads.student_id', '=', 'users.user_unique_id')
				->orderBy('id', 'DESC')
				->paginate(10, ['student_test_uploads.*', 'users.name', 'users.email', 'users.phone']);
		} else {

			$data['products'] = Student_test_upload::where(['users.admin_id' => $admin_id])
				->join('users', 'student_test_uploads.student_id', '=', 'users.user_unique_id')
				->orderBy('id', 'DESC')
				->paginate(10, ['student_test_uploads.*', 'users.name', 'users.email', 'users.phone']);
		}
		return view('admin.pdf-test.student-file-list', $data);
	}

	public function deleteObject($etag)
	{
		if (!empty($etag)) {

			$videos = Material::where(['etag' => $etag])->first();
			$path = $videos->path;
			$accessKey = env('AWS_S3_ACCESS_KEY');
			$secretKey = env('AWS_S3_SECRET_KEY');
			$region = env('AWS_REGION');
			$host = env('AWS_HOST');
			$bucket = env('AWS_BUCKET');


			$s3 = new S3S3Client([
				'version' => 'latest',
				'region' => $region,
				'endpoint' => $host,
				'credentials' => [
					'key' => $accessKey,
					'secret' => $secretKey
				]
			]);

			$s3->putBucketCors([
				'Bucket' => $bucket, // REQUIRED
				'CORSConfiguration' => [ // REQUIRED
					'CORSRules' => [ // REQUIRED
						[
							'AllowedMethods' => ['POST', 'GET', 'HEAD', 'DELETE', 'PUT'], // REQUIRED
							'AllowedHeaders' => ['*'],
							'AllowedOrigins' => ['*'], // REQUIRED
							'ExposeHeaders' => ['ETag'],
							'MaxAgeSeconds' => 0
						],
					],
				]
			]);

			try {
				$result = $s3->deleteObject([
					'Bucket' => $bucket,
					'Key' => $path
				]);
				// echo json_encode([['code' => 200], ['status' => true]]);

				Material::where(['etag' => $etag])->delete();
				return back()->with('error', 'You Select Category Type!');
			} catch (S3Exception $e) {
				echo $e->getMessage() . PHP_EOL;
			}
		}
	}
}