notificationservice/app/Http/Controllers/OneSignalController.php

<?php

namespace App\Http\Controllers;

use App\Models\Notification;
use App\Models\OnesignalAgent;
use App\Models\OnesignalUser;
use App\Traits\ApiResponser;
use Illuminate\Http\Response;
use Illuminate\Http\Request;
use Berkayk\OneSignal\OneSignalFacade;
use Mockery\Matcher\Not;

class OneSignalController extends Controller
{
    use ApiResponser;
    /**
     * Create a new controller instance.
     *
     * @return void
     */
    public function __construct()
    {
        //
    }

    public function addUserPlayerID(Request $request){
        $this->validate($request , [
            'user_code'=> 'required',
            'player_id'=> 'required',
            'set_default' => 'required|boolean'
        ]);
        $records = OnesignalUser::where('user_code',$request->user_code)->get();
        if($request->set_default){
            foreach ($records as $r){
                $r->delete();
            }
            $user = new OnesignalUser();
            $user->fill($request->all());
            $user->save();
        }else{

            $saveUser = OnesignalUser::where('user_code',$request->user_code)->where('player_id',$request->player_id)->first();
            if(!$saveUser){
                if(sizeof($records)>0)
                    return $this->errorResponse(trans('errors.phone_already_associated'), Response::HTTP_CREATED);

                $request->set_default = true;
                return $this->addUserPlayerID($request);
            }else{
                if(sizeof($records)>1)
                    return $this->errorResponse(trans('errors.phone_already_associated'), Response::HTTP_CREATED);
            }
        }

        return $this->successResponse(trans('messages.player_id_saved'));
    }

    public function addAgentPlayerID(Request $request){
        $this->validate($request , [
            'code_membre'=> 'required',
            'player_id'=> 'required',
            'set_default' => 'required|boolean'
        ]);

        $records = OnesignalAgent::where('code_membre',$request->code_membre)->get();

        if($request->set_default){
            foreach ($records as $r){
                $r->delete();
            }
            $user = new OnesignalAgent();
            $user->fill($request->all());
            $user->save();
        }else{

            $saveUser = OnesignalAgent::where('code_membre',$request->code_membre)->where('player_id',$request->player_id)->first();

            if(!$saveUser){
                if(sizeof($records)>0)
                    return $this->errorResponse(trans('errors.phone_already_associated'), Response::HTTP_CREATED);

                $request->set_default = true;
                return $this->addAgentPlayerID($request);
            }else{
                if(sizeof($records)>1)
                    return $this->errorResponse(trans('errors.phone_already_associated'), Response::HTTP_CREATED);
            }
        }

        return $this->successResponse(trans('messages.player_id_saved'));
    }

    public function pushMessageToOneUser(Request $request){
        $this->validate($request , [
            'user_code'=> 'required',
            'message'=> 'required',
            'data'=>'required'
        ]);

        $userIds = OnesignalUser::where('user_code',$request->user_code)->get();
        $notif =  new Notification();
        $notif->user_code = $request->user_code;
        $notif->message = $request->message;
        $notif->data = json_encode($request->data);
        $notif->read = false;
        $notif->save();
        if($userIds){
            foreach ($userIds as $userId){
                OneSignalFacade::async()->sendNotificationToUser($request->message, $userId->player_id, $url = null, $request->data);
//                OneSignal::sendNotificationToUser($request->message, $userId->player_id, $url = null, $request->data);
            }
        }

        return $this->successResponse('Notification delivered');
    }

    public function pushMessageToOneAgent(Request $request){
        $this->validate($request , [
            'agent_code'=> 'required',
            'message'=> 'required',
            'data'=>'required'
        ]);

        $userIds = OnesignalAgent::where('code_membre',$request->agent_code)->get();
        $notif =  new Notification();
        $notif->agent_code = $request->agent_code;
        $notif->message = $request->message;
        $notif->data = json_encode($request->data);
        $notif->read = false;
        $notif->save();
        if($userIds){
            foreach ($userIds as $userId){
                OneSignalFacade::async()->sendNotificationToUser($request->message, $userId->player_id, $url = null, $request->data);
            }
        }

        return $this->successResponse('Notification delivered');
    }
}