<?php

namespace App\Http\Controllers\OpenAi;

use App\Helpers\Classes\Helper;
use App\Http\Controllers\Controller;
use App\Models\OpenAIGenerator;
use App\Models\OpenaiGeneratorFilter;
use App\Models\Setting;
use App\Models\SettingTwo;
use App\Models\UserOpenai;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\Request;
use App\Services\Stream\StreamService;
use App\Models\UserOpenaiChat;
use GuzzleHttp\Client;
use Illuminate\Support\Facades\Auth;
use App\Services\VectorService;
use App\Models\UserOpenaiChatMessage;
use Illuminate\Support\Str;
use Illuminate\Support\Facades\Log;
use App\Models\PdfData;

class GeneratorController extends Controller
{
	protected $settings;
	protected $settings_two;
    public function __construct(public StreamService $streamService)
    {
		$this->middleware(function (Request $request, $next) {
			Helper::setOpenAiKey();
            return $next($request);
        });
        $this->settings = Setting::first();
		$this->settings_two = SettingTwo::first();
    }
	public function buildStreamedOutput(Request $request){
		$template_type = $request->get('template_type', 'chatbot');
		# If the template type is chat, then we will build a chat streamed output or other ai template streamed output
		switch ($template_type) {
			case 'chatbot':
			case 'vision':
				return $this->buildChatStreamedOutput($request);
				break;
			case 'writer':
				return $this->buildOtherStreamedOutput($request);
				break;
			default:
				return $this->buildOtherStreamedOutput($request);
				break;
		}
	}
	# chat template and etc.
	public function buildChatStreamedOutput(Request $request){
		$prompt = $request->get('prompt');
		$realtime = $request->get('realtime', false);
		$chat_id = $request->get('chat_id');
		$chat_type = $request->get('template_type');
		$images = $request->get('images', []);
		$pdfname = $request->get('pdfname', null);
		$pdfpath = $request->get('pdfpath', null);

		$user = Auth::user();

        $default_ai_engine = setting('default_ai_engine', 'openai');

        if ($default_ai_engine == 'openai') {
            $chat_bot = $this->settings?->openai_default_model == null ? 'gpt-3.5-turbo': $this->settings?->openai_default_model;
        } else if ($default_ai_engine == 'gemini') {
            $chat_bot = setting('gemini_default_model');
        } else if ($default_ai_engine == 'anthropic') {
            $chat_bot = setting('claude-3-opus-20240229');
        } else {
            $chat_bot = $this->settings?->openai_default_model == null ? 'gpt-3.5-turbo': $this->settings?->openai_default_model;
        }

		$history = [];
		$realtimePrompt = $prompt;
		$chat = UserOpenaiChat::whereId($chat_id)->first();

		# if prompt prefix exists, add it to the prompt
		// if ($chat->category->prompt_prefix != null && !str_starts_with($chat->category->slug, 'ai_')) {
		//     $prompt = "You will now play a character and respond as that character (You will never break character). Your name is". $chat->category->human_name. ". I want you to act as a". $chat->category->role . ". ". $chat->category->prompt_prefix . ' ' . $prompt;
		// } 

		# create the message here with default to fill it after stream
		$message = new UserOpenaiChatMessage();
		$message->user_id = $user->id;
		$message->user_openai_chat_id = $chat->id;
		$message->input = $prompt;
		$message->response = null;
		$message->realtime = $realtime ?? 0;
		$message->output = __("(If you encounter this message, please attempt to send your message again. If the error persists beyond multiple attempts, please don't hesitate to contact us for assistance!)");
		$message->hash = Str::random(256);
		$message->credits = 0;
		$message->words = 0;
		$message->images = $images;
		$message->pdfName = $request->pdfname;
		$message->pdfPath = $request->pdfpath;
		$message->save();

		# check if there completions for the template
		$category = $chat->category;
		if ($category->chat_completions) {
			$chat_completions = json_decode($category->chat_completions, true);
			foreach ($chat_completions as $item) {
				$history[] = [
					'role' => $item['role'],
					'content' => $item['content']?? '',
				];
			}
		} else {
			$history[] = ['role' => 'system', 'content' => 'You are a helpful assistant.'];
		}

		# if file attached, get the content of the file
		if ($category->chatbot_id || PdfData::where('chat_id', $chat_id)->exists()) {
			$extra_prompt = null;
			try {
				$extra_prompt = (new VectorService())->getMostSimilarText($prompt, $chat_id, 2, $category->chatbot_id);
				if ($extra_prompt) {
					if($chat->category->slug == 'ai_webchat'){
						$history[] = [
							'role' => 'system',
							'content' => "You are a Web Page Analyzer assistant. When referring to content from a specific website or link, please include a brief summary or context of the content. If users inquire about the content or purpose of the website/link, provide assistance professionally without explicitly mentioning the content. Website/link content: \n$extra_prompt"
						];
					}else{
						$history[] = [
							'role' => 'system',
							'content' => "You are a File Analyzer assistant. When referring to content from a specific file, please include a brief summary or context of the content. If users inquire about the content or purpose of the file, provide assistance professionally without explicitly mentioning the content. File content: \n$extra_prompt"
						];
					}
				}
			} catch (\Throwable $th) {
			}
		}else{
			# if instructions exists, add it to the history
			if ($category && $category?->instructions) {
				$history[] = ['role' => 'system', 'content' => $category->instructions ];
			}
		}
		# follow the context of the last 3 messages
		$lastThreeMessageQuery = $chat->messages()
		->whereNotNull('input')
		->orderBy('created_at', 'desc')
		->take(4)
		->get()
		->reverse();

		# if one of the last 3 messages contain images, then write proper history for vision model for all messages
		$contain_images = $this->checkIfHistoryContainsImages($lastThreeMessageQuery);

		# if the last 3 messages are not empty, add them to the history
		$count = count($lastThreeMessageQuery);
		if ($count > 1) {
			foreach ($lastThreeMessageQuery as $threeMessage) {
				if ($contain_images) {
					$content = [
						[
							'type' => 'text',
							'text' => $threeMessage->input,
						],
					];

					$images = collect($threeMessage->images)->map(function ($item) {
						if ($item !== "undefined" && $item !== null && $item !== "") {
							if (Str::startsWith($item, 'http')) {
								$imageData = file_get_contents($item);
							} else {
								$imageData = file_get_contents(substr($item, 1, strlen($item) - 1));
							}
							$base64Image = base64_encode($imageData);

							return [
								'type' => 'image_url',
								'image_url' => [
									'url' => 'data:image/png;base64,' . $base64Image,
								],
							];
						}
					})->toArray();

					// Filter out NULL values from $images
					$images = array_filter($images);

					$content = array_merge($content, $images);

					$history[] = [
						'role' => 'user',
						'content' => $content,
					];
				} else {
					$history[] = ['role' => 'user', 'content' => $threeMessage->input ?? ''];
				}

				if ($threeMessage->output !== null && $threeMessage->output !== '') {
					$history[] = ['role' => 'assistant', 'content' => $threeMessage->output];
				}
			}
		}
		if(($images == '' || $images == [] || $images == null) && $chat->category->slug != 'ai_vision') 
		{
			if($realtime && $this->settings_two->serper_api_key != null){
				$final_prompt = $this->getRealtimePrompt($realtimePrompt);
				$history[] = ['role' => 'user', 'content' => $final_prompt?? ''];
			}else{
				$history[] = ['role' => 'user', 'content' => $prompt?? ''];
			}
		}
		else{ # in this case we need to use vision model and its not included in OpenAI lib yet.. 
			if($chat_type == 'vision'){
				$history[] = [
					'role' => 'system',
					'content' => "You will now play a character and respond as that character (You will never break character). Your name is Vision AI. Must not introduce by yourself as well as greetings. Help also with asked questions based on previous responses and images if exists."
				];
			}
			$images = explode(',', $request->images);
			$history[] = [
				'role' => 'user',
				'content' => array_merge(
					[
						[
							'type' => 'text',
							'text' => $prompt,
						],
					],
					collect($images)->map(function ($item) {
						if ($item !== "undefined" && $item !== null && $item !== "") {
							if (Str::startsWith($item, 'http')) {
								$imageData = file_get_contents($item);
							} else {
								$imageData = file_get_contents(substr($item, 1, strlen($item) - 1));
							}
							$base64Image = base64_encode($imageData);
							return [
								'type' => 'image_url',
								'image_url' => [
									'url' => 'data:image/png;base64,' . $base64Image,
								],
							];
						}
					})->reject(null)->toArray() // Filter out NULL values
				),
			];
			$contain_images = true;
		}
		return $this->streamService->ChatStream($chat_bot, $history, $message, $chat_type, $contain_images);
	}

	# ai writer template and etc.
	public function buildOtherStreamedOutput(Request $request)
    {
        if (setting('default_ai_engine') == 'gemini') {
            $chat_bot = setting('gemini_default_model');
        }else if (setting('default_ai_engine') == 'anthropic') {
            $chat_bot = setting('claude-3-opus-20240229');
        }
        else {
            $chat_bot = $this->settings?->openai_default_model == null ? 'gpt-3.5-turbo': $this->settings?->openai_default_model;
        }

		return $this->streamService->OtherStream($request, $chat_bot);
	}

	# reduce tokens when the stream is interrupted
	public function reduceTokensWhenIntterruptStream(Request $request, $type) {
		return $this->streamService->reduceTokensWhenIntterruptStream($request, $type);
	}

	private function getRealtimePrompt($realtimePrompt){
		$client = new Client();
		$headers = [
			'X-API-KEY' => $this->settings_two->serper_api_key,
			'Content-Type' => 'application/json',
		];
		$body = [
			'q' => $realtimePrompt,
		];
		$response = $client->post('https://google.serper.dev/search', [
			'headers' => $headers,
			'json' => $body,
		]);
		$toGPT = $response->getBody()->getContents();
		try {
			$toGPT = json_decode($toGPT);
		} catch (\Throwable $th) {
		}
		$final_prompt =
		'Prompt: '.$realtimePrompt.
		'\n\nWeb search json results: '
		.json_encode($toGPT).
		'\n\nInstructions: Based on the Prompt generate a proper response with help of Web search results(if the Web search results in the same context). Only if the prompt require links: (make curated list of links and descriptions using only the <a target="_blank">, write links with using <a target="_blank"> with mrgin Top of <a> tag is 5px and start order as number and write link first and then write description). Must not write links if its not necessary. Must not mention anything about the prompt text.';
		return $final_prompt;
	}
	private function checkIfHistoryContainsImages($lastThreeMessages){
		foreach ($lastThreeMessages as $message) {
			if($message->images != null && $message->images != '' && $message->images != []){
				return true;
			}
		}
		return false;
	}

    public function index($workbook_slug = null)
    {
        abort_if(Helper::setting('feature_ai_advanced_editor') == 0, 404); 
        $apiUrl = base64_encode('https://api.openai.com/v1/chat/completions');
		$settings_two = SettingTwo::first();
		if ($settings_two->openai_default_stream_server == 'backend') {
			$apikeyPart1 = base64_encode(rand(1, 100));
			$apikeyPart2 = base64_encode(rand(1, 100));
			$apikeyPart3 = base64_encode(rand(1, 100));
		}else{
			$settings = Setting::first();
			// Fetch the Site Settings object with openai_api_secret
			if ($settings?->user_api_option) {
				$apiKeys = explode(',', auth()->user()?->api_keys);
			} else {
				$apiKeys = explode(',', $settings?->openai_api_secret);
			}
			$apiKey = $apiKeys[array_rand($apiKeys)];
			$len = strlen($apiKey);
			$parts[] = substr($apiKey, 0, $l[] = rand(1, $len - 5));
			$parts[] = substr($apiKey, $l[0], $l[] = rand(1, $len - $l[0] - 3));
			$parts[] = substr($apiKey, array_sum($l));
			$apikeyPart1 = base64_encode($parts[0]);
			$apikeyPart2 = base64_encode($parts[1]);
			$apikeyPart3 = base64_encode($parts[2]);
		}
		if($workbook_slug){
			$workbook = UserOpenai::where('slug', $workbook_slug)->where('user_id', auth()->user()->id)->first();
		}else{
			$workbook = null;
		}
		
        return view('panel.user.generator.index', [
            'list' => OpenAIGenerator::query()
                ->where('active', true)->get(),
            'filters' => OpenaiGeneratorFilter::query()
                ->where(function ($query) {
                    $query->where('user_id', auth()->id())
                        ->orWhereNull('user_id');
                })
                ->get(),
            'apikeyPart1' => $apikeyPart1,
            'apikeyPart2' => $apikeyPart2,
            'apikeyPart3' => $apikeyPart3,
            'apiUrl' => $apiUrl,
			'workbook' => $workbook,
        ]);
    }

    public function generator(Request $request, $slug)
    {

    }

    public function generatorOptions(Request $request, $slug)
    {
        $openai = OpenAIGenerator::query()
            ->where('slug', $slug)
            ->firstOrFail();
        $apiUrl = base64_encode('https://api.openai.com/v1/chat/completions');
		$settings_two = SettingTwo::first();
		if ($settings_two->openai_default_stream_server == 'backend') {
			$apikeyPart1 = base64_encode(rand(1, 100));
			$apikeyPart2 = base64_encode(rand(1, 100));
			$apikeyPart3 = base64_encode(rand(1, 100));
		}else{
			$settings = Setting::first();
			// Fetch the Site Settings object with openai_api_secret
			if ($settings?->user_api_option) {
				$apiKeys = explode(',', auth()->user()?->api_keys);
			} else {
				$apiKeys = explode(',', $settings?->openai_api_secret);
			}
			$apiKey = $apiKeys[array_rand($apiKeys)];

			$len = strlen($apiKey);
			$parts[] = substr($apiKey, 0, $l[] = rand(1, $len - 5));
			$parts[] = substr($apiKey, $l[0], $l[] = rand(1, $len - $l[0] - 3));
			$parts[] = substr($apiKey, array_sum($l));
			$apikeyPart1 = base64_encode($parts[0]);
			$apikeyPart2 = base64_encode($parts[1]);
			$apikeyPart3 = base64_encode($parts[2]);
		}

        $apiSearch = base64_encode('https://google.serper.dev/search');
        $auth = $request->user();
        return view(
            'panel.user.generator.components.generator-options',
            compact(
                'slug',
                'openai',
                'apiSearch',
                'apikeyPart1',
                'apikeyPart2',
                'apikeyPart3',
                'apiUrl',
                'auth'
            )
        )->render();
    }

    protected function openai(Request $request)
    {
        $team = $request->user()->getAttribute('team');

        $myCreatedTeam = $request->user()->getAttribute('myCreatedTeam');

        return UserOpenai::query()
            ->where(function (Builder $query) use ($team, $myCreatedTeam) {
                $query->where('user_id', auth()->id())
                    ->when($team || $myCreatedTeam, function ($query) use ($team, $myCreatedTeam) {
                        if ($team && $team?->is_shared) {
                            $query->orWhere('team_id', $team->id);
                        }
                        if ($myCreatedTeam) {
                            $query->orWhere('team_id', $myCreatedTeam->id);
                        }
                    });
            });
    }
}