web-mooc/app/Http/Controllers/student/MessageController.php

<?php

namespace App\Http\Controllers\student;

use App\Http\Controllers\Controller;
use App\Models\Course;
use App\Models\Enrollment;
use App\Models\FileUploader;
use App\Models\MediaFile;
use App\Models\Message;
use App\Models\MessageThread;
use App\Models\User;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Session;
use Illuminate\Support\Str;

class MessageController extends Controller
{
    public function __construct()
    {
        date_default_timezone_set("Asia/Dhaka");
    }
    public function index()
    {
        $contacts = Message::where('sender_id', auth()->user()->id)
            ->orWhere('receiver_id', auth()->user()->id)
            ->latest('id')
            ->pluck('sender_id', 'receiver_id')
            ->toArray();

        // if url has any thread then get all conversations by that thread
        $conversations = [];
        if (request()->has('inbox') && !empty(request()->query('inbox'))) {
            $thread        = request()->query('inbox');
            $conversations = Message::join('message_threads', 'messages.thread_id', '=', 'message_threads.id')
                ->select('messages.*', 'message_threads.code')
                ->where('message_threads.code', $thread)
                ->get();
        } elseif (request()->has('instructor') && !empty(request()->query('instructor'))) {
            $new_thread = Str::random(25);
            $instructor_id = request()->query('instructor');

            $check_thread = MessageThread::where(function ($query) use ($instructor_id) {
                $query->where('contact_one', auth()->user()->id)->where('contact_two', $instructor_id);
            })
                ->orWhere(function ($query) use ($instructor_id) {
                    $query->where('contact_two', auth()->user()->id)->where('contact_one', $instructor_id);
                })->count();


            if ($check_thread == 0) {
                // create a new thread and redirect
                $data['code']        = $new_thread;
                $data['contact_one'] = auth()->user()->id;
                $data['contact_two'] = request()->query('instructor');
                MessageThread::insert($data);

                return redirect(route('message', ['inbox' => $new_thread, 'instructor' => $instructor_id]));
            }
        }



        $enrollments    = Enrollment::where('user_id', auth()->user()->id)->get();
        $my_instructors = array();
        foreach ($enrollments as $enrollment) :
            $course_details = Course::where('id', $enrollment->course_id)->firstOrNew();
            foreach (json_decode($course_details->instructor_ids, true) ?? array() as $instructor_id) {
                if (!in_array($instructor_id, $my_instructors)) {
                    $my_instructors[] = $instructor_id;
                }
            }
            if (!in_array($course_details->user_id, $my_instructors)) {
                $my_instructors[] = $course_details->user_id;
            }
        endforeach;
        $page_data['my_instructor_ids'] = $my_instructors;

        $page_data['contacts']      = array_keys($contacts);

        $page_data['message_threads']      = MessageThread::where('contact_one', auth()->user()->id)->where('contact_two', auth()->user()->id)->get();
        $page_data['conversations'] = $conversations;
        $view_path                  = 'frontend.' . get_frontend_settings('theme') . '.student.message.index';
        return view($view_path, $page_data);
    }

    public function store(Request $request)
    {
        if (empty($request->message) && !$request->media_files) {
            return redirect()->back();
        }

        $data['sender_id']   = auth()->user()->id;
        $data['receiver_id'] = $request->receiver_id;
        $data['thread_id']   = $request->thread;
        $data['message']     = $request->message;
        $data['read']     = 0;

        Message::insert($data);
        MessageThread::where('id', $request->thread)->update(['updated_at' => date('Y-m-d H:i:s')]);
        $conversation = Message::latest()->first();

        // upload media files
        if ($request->media_files) {
            $thread_code = MessageThread::where('id', $request->thread)->value('code');
            $files       = $request->media_files;

            foreach ($files as $file) {
                $mimeType  = $file->getClientMimeType();
                $mimeType  = explode('/', $mimeType);
                $file_type = $mimeType[0];

                if (in_array($file_type, ['image', 'video'])) {
                    $file_name = Str::random(20) . '.' . $file->extension();
                    FileUploader::upload($file, 'uploads/message/' . $thread_code . '/' . $file_name, null, null, 300);

                    $media['chat_id']   = $conversation->id;
                    $media['file_name'] = $file_name;
                    $media['file_type'] = $file_type;

                    MediaFile::insert($media);
                }
            }
        }
        Session::flash('success', get_phrase('Message sent successfully.'));
        return redirect()->back();
    }

    public function fetch_message(Request $request)
    {
        $conversations = Message::where('thread_id', $request->thread)->get();
        return view('frontend.default.student.message.body', compact('conversations'));
    }

    public function search_student(Request $request)
    {
        $page_data['user_details'] = User::where('email', $request->search_mail)->first();
        $view_path                 = 'frontend.' . get_frontend_settings('theme') . '.student.message.search_result';
        return view($view_path, $page_data);
    }

    public function inbox($user_id)
    {
        // check if any thread code exists or not
        $auth       = auth()->user()->id;
        $has_thread = MessageThread::where(function ($query) use ($auth, $user_id) {
            $query->where('contact_one', $auth)->where('contact_two', $user_id);
        })
            ->orWhere(function ($query) use ($auth, $user_id) {
                $query->where('contact_one', $user_id)->where('contact_two', $auth);
            })
            ->first();

        $thread = $has_thread ? $has_thread->code : Str::random(20);

        // create a new thread and redirect
        if (!$has_thread) {
            $data['code']        = $thread;
            $data['contact_one'] = $auth;
            $data['contact_two'] = $user_id;

            MessageThread::insert($data);

            return redirect(route('message', ['inbox' => $thread, 'instructor' => $user_id]));
        }
        return redirect()->route('message', ['inbox' => $thread]);
    }
}