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\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'
        ]);

        $saveUser = OnesignalUser::where('user_code',$request->user_code)->where('player_id',$request->player_id)->first();
        if(!$saveUser){
            $user = new OnesignalUser();
            $user->fill($request->all());
            $user->save();
        }
        return $this->successResponse('Player ID saved');
    }

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

        $saveUser = OnesignalAgent::where('code_membre',$request->code_membre)->where('player_id',$request->player_id)->first();
        if(!$saveUser){
            $user = new OnesignalAgent();
            $user->fill($request->all());
            $user->save();
        }
        return $this->successResponse('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');
    }
}