Hi John, welcome!

";print_r($apiStatusData);die;

                //dispatch(new SendLeadByLenderApi($clientId, $apiStatusData, 'lender_api'))->onConnection("database");
                dispatch(new SendLeadByLenderApi($clientId, $apiStatusData, 'lender_api'))->onConnection("lender_api_schedule_job");


                /*   return response()->json([
        "success" => true,
        "message" => "Application sent.Please check submission log",
    ]);*/
            }



            // Remove duplicate emails
            //$emails = array_unique($emailSet);
            //$ccEmails=array_unique($ccEmails);
            $file_name = $request->fileName;
            $sendAttachment = true;
            $messageData = [
                "subject" => $request->subject,
                "message" => $request->editor1,
                'file_path' => $file_name,
                'file_paths' => $file_paths,
                'emails' => $emailSet,
                // 'ccEmails'=>$ccEmails,
                'mailable' => "emails.send_email_generic_crm",
                'user_id' => $request->auth->id
            ];

            /*return response()->json([
            "success" => false,
            "message" => $messageData,
        ]);*/
            Log::info("Before notification: ", ['messageData' => $messageData]);
            $notificationData = [
                "action" => "lenders_submission",
                "user" => $messageData
            ];
            Log::info('Notification data prepared', ['notificationData' => $notificationData]);
            ///dispatch(new SendCrmNotificationEmail($clientId, $notificationData, 'submission'))->onConnection("database");

            $notificationController = new NotificationController();
            $notificationController->sendCrmNotification($clientId, $notificationData, 'submission');

            $leadId = $request->lead_id;
            $submittedDate = Carbon::now();
            foreach ($toEmailId as $lenderId) {
                CrmSendLeadToLender::on("mysql_$clientId")->create([
                    'lender_id' => $lenderId,
                    'lead_id' => $leadId,
                    'submitted_date' => $submittedDate,
                    'created_at' => Carbon::now(),
                    'updated_at' => Carbon::now(),
                ]);
            }
        } catch (\Throwable $exception) {
            Log::error("MailController.sendMail.error", [
                "message" => $exception->getMessage(),
                "file" => $exception->getFile(),
                "line" => $exception->getLine()
            ]);

            return response()->json([
                "success" => false,
                "message" => $exception->getMessage(),
            ]);
        }

        return response()->json([
            "success" => true,
            "message" => "Emails sent successfully",
        ]);
    }

    public function ai_sendEmail(Request $request)
    {
        $validator = Validator::make($request->all(), [
            'client_id'     => 'required|numeric',
            'prompt_id'     => 'required|numeric',
            'to_email'      => 'required|email',
            'function_name' => 'required|string',
            'list_id'       => 'required|numeric',
            'lead_id'       => 'required|numeric',
        ]);

        if ($validator->fails()) {
            return response()->json([
                'success' => false,
                'errors'  => $validator->errors(),
            ], 422);
        }

        $client_id     = $request->input('client_id');
        $prompt_id     = $request->input('prompt_id');
        $to_email      = $request->input('to_email');
        $function_name = $request->input('function_name');
        $list_id       = $request->input('list_id');
        $lead_id       = $request->input('lead_id');

        Log::debug('Step 1: Request received', compact('client_id','prompt_id','to_email','function_name','list_id','lead_id'));

        try {
            /** -------------------------------
             * Step 4: Fetch email functions + templates
             * ------------------------------- */
            Log::debug('Step 4: Processing email template replacements');

            $parent_id = $client_id;

            $functions = PromptFunction::on("mysql_" . $client_id)
                ->where('prompt_id', $prompt_id)
                ->where('type', 'email')
                ->get()
                ->map(fn($fn) => [
                    'type'    => $fn->type,
                    'name'    => $fn->name,
                    'message' => $fn->message,
                ])->toArray();

            foreach ($functions as &$fn) {
                if (!empty($fn['message'])) {
                    $emailTplId = $fn['message'];
                    try {
                        $tpl_record = EmailTemplete::on("mysql_" . $parent_id)
                            ->select('subject', 'template_html')
                            ->find($emailTplId);

                        if ($tpl_record && (!empty($tpl_record->template_html) || !empty($tpl_record->subject))) {
                            $fn['message'] = [
                                'subject' => $tpl_record->subject ?? '',
                                'body'    => $tpl_record->template_html ?? '',
                            ];
                        }
                    } catch (Exception $e) {
                        Log::error('Email template fetch failed', [
                            'template_id' => $emailTplId,
                            'error'       => $e->getMessage(),
                        ]);
                    }
                }
            }
            unset($fn);

            /** -------------------------------
             * Step 5: Dynamic replacements
             * ------------------------------- */
            Log::debug('Step 5: Performing dynamic replacements');
            $lead_record = ListData::on("mysql_" . $client_id)->find($lead_id);
            if (!$lead_record) {
                Log::error('Lead not found', compact('lead_id'));
                return response()->json(['success' => false, 'error' => 'Lead not found'], 404);
            }

            $list_headers = ListHeader::on("mysql_" . $client_id)->where('list_id', $list_id)->get();
            $lead_data = [];
            foreach ($list_headers as $val) {
                $label = Label::on("mysql_" . $client_id)->find($val->label_id);
                $label_title = $label->title ?? null;
                if ($label_title) $lead_data[$label_title] = $lead_record->{$val->column_name} ?? '';
            }

            foreach ($functions as &$fn) {
                if (is_array($fn['message'])) {
                    foreach (['subject', 'body'] as $field) {
                        foreach ($lead_data as $key => $value) {
                            $fn['message'][$field] = str_replace('[[' . $key . ']]', $value, $fn['message'][$field]);
                        }
                    }
                }
            }
            unset($fn);

            /** -------------------------------
             * Step 6: Send email for matching function_name
             * ------------------------------- */
            $targetFunction = collect($functions)->firstWhere('name', $function_name);
            if (!$targetFunction || !is_array($targetFunction['message'])) {
                return response()->json([
                    'success' => false,
                    'error'   => 'No valid message template found for given function.',
                ], 404);
            }

            $subject = $targetFunction['message']['subject'] ?? 'No Subject';
            $body    = $targetFunction['message']['body'] ?? 'No Body Content';

            $client = new Client();
            $response = $client->post('https://api.sendgrid.com/v3/mail/send', [
                'headers' => [
                    'Authorization' => 'Bearer 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',
                    'Content-Type'  => 'application/json',
                ],
                'json' => [
                    'personalizations' => [[ 'to' => [['email' => $to_email]] ]],
                    'from'    => ['email' => 'noreply@voiptella.com'],
                    'subject' => $subject,
                    'content' => [[ 'type' => 'text/html', 'value' => $body ]]
                ]
            ]);

            return response()->json([
                'success' => true,
                'status'  => $response->getStatusCode(),
                'sent_to' => $to_email,
                'subject' => $subject,
            ]);
        } catch (Exception $e) {
            Log::error('Mail send failed', ['error' => $e->getMessage()]);
            return response()->json(['success' => false, 'error' => $e->getMessage()], 500);
        }
    }
}