swooletw / laravel-swoole

src/Websocket/Authenticatable.php

<?php

namespace SwooleTW\Http\Websocket;

use Illuminate\Contracts\Auth\Authenticatable as AuthenticatableContract;
use InvalidArgumentException;

/**
 * Trait Authenticatable
 *
 * @property-read \SwooleTW\Http\Websocket\Rooms\RoomContract $room
 */
trait Authenticatable
{
    protected $userId;

    /**
     * Login using current user.
     *
     * @param \Illuminate\Contracts\Auth\Authenticatable $user
     *
     * @return mixed
     */
    public function loginUsing(AuthenticatableContract $user)
    {
        return $this->loginUsingId($user->getAuthIdentifier());
    }

    /**
     * Login using current userId.
     *
     * @param $userId
     *
     * @return mixed
     */
    public function loginUsingId($userId)
    {
        return $this->join(static::USER_PREFIX . $userId);

It seems like join() must be provided by classes using this trait. How about adding it as abstract method to this trait?

The constant SwooleTW\Http\Websocket\Authenticatable::USER_PREFIX was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    /**
     * Logout with current sender's fd.
     *
     * @return mixed
     */
    public function logout()
    {
        if (is_null($userId = $this->getUserId())) {
            return null;
        }

        return $this->leave(static::USER_PREFIX . $userId);

The constant SwooleTW\Http\Websocket\Authenticatable::USER_PREFIX was not found. Maybe you did not declare it correctly or list all dependencies?

It seems like leave() must be provided by classes using this trait. How about adding it as abstract method to this trait?

    }

    /**
     * Set multiple recepients' fds by users.
     *
     * @param $users
     *
     * @return \SwooleTW\Http\Websocket\Authenticatable
     */
    public function toUser($users)
    {
        $users = is_object($users) ? func_get_args() : $users;

        $userIds = array_map(function (AuthenticatableContract $user) {
            $this->checkUser($user);

            return $user->getAuthIdentifier();
        }, $users);

        return $this->toUserId($userIds);
    }

    /**
     * Set multiple recepients' fds by userIds.
     *
     * @param $userIds
     *
     * @return \SwooleTW\Http\Websocket\Authenticatable
     */
    public function toUserId($userIds)
    {
        $userIds = is_string($userIds) || is_integer($userIds) ? func_get_args() : $userIds;

        foreach ($userIds as $userId) {
            $fds = $this->room->getClients(static::USER_PREFIX . $userId);

The constant SwooleTW\Http\Websocket\Authenticatable::USER_PREFIX was not found. Maybe you did not declare it correctly or list all dependencies?

            $this->to($fds);

It seems like to() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        }

        return $this;
    }

    /**
     * Get current auth user id by sender's fd.
     */
    public function getUserId()
    {
        if (! is_null($this->userId)) {
            return $this->userId;
        }

        $rooms = $this->room->getRooms($this->getSender());

It seems like getSender() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        foreach ($rooms as $room) {
            if (count($explode = explode(static::USER_PREFIX, $room)) === 2) {

The constant SwooleTW\Http\Websocket\Authenticatable::USER_PREFIX was not found. Maybe you did not declare it correctly or list all dependencies?

                $this->userId = $explode[1];
            }
        }

        return $this->userId;
    }

    /**
     * Check if a user is online by given userId.
     *
     * @param $userId
     *
     * @return bool
     */
    public function isUserIdOnline($userId)
    {
        return ! empty($this->room->getClients(static::USER_PREFIX . $userId));

The constant SwooleTW\Http\Websocket\Authenticatable::USER_PREFIX was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    /**
     * Check if user object implements AuthenticatableContract.
     *
     * @param $user
     */
    protected function checkUser($user)
    {
        if (! $user instanceOf AuthenticatableContract) {
            throw new InvalidArgumentException('user object must implement ' . AuthenticatableContract::class);
        }
    }
}