xyzshop/helper/room/room_processor.php

<?php
/**
 * Created by PhpStorm.
 * User: stanley-king
 * Date: 2017/12/14
 * Time: 下午12:07
 */

namespace room;

use event\IProcessor;
use process_looper;
use errcode;
use algorithm;

class room_processor implements IProcessor
{
    private $mAccConnes;
    private $mFactory;
    private $mRooms;
    private $mChatwo;

    public function __construct()
    {
        $this->mAccConnes = [];
        $this->mFactory = new factory();
        $this->mRooms = [];
        $this->mChatwo = new chatwo();
    }

    public function onStart()
    {

    }
    public function onConnected($bufid,$stream,$host,$port,$args)
    {

    }

    public function onRequest($bufid, $body)
    {
        $input = json_decode($body,true);
        if($input == false) {
            process_looper::instance()->close($bufid);
            return false;
        }

        $act = $input['act'];
        if(empty($act)) return false;

        if($act == proto_type::act_factory) {
            $ret = $this->onFactory($bufid,$input);
            process_looper::instance()->write($bufid,$ret);
            return true;
        }
        elseif($act == proto_type::act_access) {
            $ret = $this->onAccess($bufid,$input);
            process_looper::instance()->write($bufid,$ret);
            return true;
        }
        elseif($act == proto_type::act_room) {
            $ret = $this->onRoom($bufid,$input);
            process_looper::instance()->write($bufid,$ret);
            return true;
        }
        elseif($act == proto_type::act_chatwo) {
            $ret = $this->onChatwo($bufid,$input);
            return true;
        }
        else {
            return false;
        }
    }

    public function onClose($bufid)
    {
        $this->remove_acc($bufid);
    }

    private function broad_access($messages)
    {
        $body = json_encode($messages);
        foreach ($this->mAccConnes as $bufid) {
            process_looper::instance()->write($bufid,$body);
        }
    }

    static private function build_message($roomid,$room_type)
    {
        $msg['act']  = "room";
        $msg['op']   = "build";
        $msg['msgtype'] = "message";

        $msg['room'] = $roomid;
        $msg['receiver_type'] = $room_type;

        return $msg;
    }
    static private function invite_message($roomid,$room_type,$invitees)
    {
        $msg['act']  = "room";
        $msg['op']   = "invite";
        $msg['msgtype'] = "message";

        $msg['room'] = $roomid;
        $msg['receiver_type'] = $room_type;
        $msg['invitees'] = $invitees;

        return $msg;
    }
    static private function leave_message($roomid,$room_type,$user)
    {
        $msg['act']  = "room";
        $msg['op']   = "leave";
        $msg['msgtype'] = "message";

        $msg['room'] = $roomid;
        $msg['receiver_type'] = $room_type;
        $msg['user'] = $user;

        return $msg;
    }

    ////////////////////////////////////////Factory Message Handler/////////////////////////////////////////////////////
    private function onFactory($bufid,$input)
    {
        $op = $input['op'];
        if($op == 'build')
        {
            $roomid = intval($input['room']);

            if($roomid <= 0) {
                return $this->error(errcode::ErrRoomParam);
            }

            if(array_key_exists($roomid,$this->mRooms)) {
                return $this->success(['room' => $roomid]);
            }

            $room = $this->mFactory->build($roomid);
            if($room == false) {
                return $this->error(errcode::ErrRoomBuild);
            }
            else {
                $this->broad_access(self::build_message($roomid,$room->room_type()));
                $this->mRooms[$roomid] = $room;
                return $this->success(['room' => $room->room_id()]);
            }
        }
        elseif($op == 'list_room')
        {
            return $this->success(['rooms' => $this->mRooms]);
        }
        elseif($op == 'invite')
        {
            $roomid = intval($input['room']);
            if($roomid <= 0) {
                return $this->error(errcode::ErrRoomParam);
            }

            if(!array_key_exists($roomid,$this->mRooms))
            {
                $room = $this->mFactory->build($roomid);
                if($room != false) {
                    $this->mRooms[$roomid] = $room;
                    $this->broad_access(self::build_message($roomid,$room->room_type()));
                }
            }
            else {
                $room = $this->room($roomid);
            }

            if($room != false)
            {
                $inviter  = intval($input['inviter']);
                $invitees = $input['invitees'];

                if($inviter > 0 && !empty($invitees))
                {
                    $result = $room->invite($inviter,$invitees);
                    if($result != false)
                    {
                        $invitees = $result['invitees'];
                        if(!empty($invitees)) {
                            $this->broad_access(self::invite_message($roomid,$room->room_type(),$invitees));
                        }
                        return $this->success($result);
                    }
                }
            }

            return $this->error(errcode::ErrRoomInvite);
        }
        elseif($op == 'leave')
        {
            $roomid = intval($input['room']);
            if($roomid <= 0) {
                return $this->error(errcode::ErrRoomParam);
            }

            if(!array_key_exists($roomid,$this->mRooms))
            {
                $room = $this->mFactory->build($roomid);
                if($room != false) {
                    $this->mRooms[$roomid] = $room;
                }
                else {
                    $this->broad_access(self::build_message($roomid,$room->room_type()));
                }
            }
            else {
                $room = $this->room($roomid);
            }

            if($room != false)
            {
                $userid  = intval($input['user']);
                if($userid > 0)
                {
                    $result = $room->leave($userid);
                    if($result != false) {
                        $this->broad_access(self::leave_message($roomid,$room->room_type(),$userid));
                        return $this->success($result);
                    }
                }
            }

            return $this->error(errcode::ErrRoomLeave);
        }
        elseif($op == 'push') {
            $content  = $input['content'];
            $this->write_push($content);
            return $this->success(NULL);
        }
        else
        {
            return $this->error(errcode::ErrRoomFactoryOp);
        }
    }

    ////////////////////////////////////////Access Message Handler//////////////////////////////////////////////////////
    private function onAccess($bufid,$input)
    {
        $op = $input['op'];
        if($op == 'list') {
            $this->add_acc($bufid);
            $reply = ['act' => 'access','op' => $op,'rooms' => $this->rooms()];
            return $this->success($reply);
        }
        else {
            return $this->error(errcode::ErrRoomAccessOp);
        }
    }

    private function rooms()
    {
        $result = [];
        foreach ($this->mRooms as $roomid => $room) {
            $result[] = $roomid;
        }
        return $result;
    }
    ////////////////////////////////////////Room Message Handler////////////////////////////////////////////////////////
    private function onRoom($bufid,$input)
    {
        $roomid = intval($input['room']);
        $room = $this->room($roomid);

        if($room != false)
        {
            $function = $input['op'] . 'Op';
            if (method_exists($room,$function))
            {
                $ret = $room->$function($input);
                if($ret != false) {
                    $this->write_roomsg($bufid,$room);
                }

                return $this->success($ret);
            }
        }

        return $this->error(errcode::ErrRoom);
    }
    ////////////////////////////////////////Peer Message Handler////////////////////////////////////////////////////////
    private function onChatwo($bufid, $input)
    {
        $function = $input['op'] . 'Op';
        if (method_exists($this->mChatwo,$function))
        {
            $msg = $this->mChatwo->$function($input);
            if($msg != false)
            {
                $body = $this->success($msg);
                foreach ($this->mAccConnes as $conn) {
                    process_looper::instance()->write($conn,$body);
                }
            }

            return true;
        }
    }
    ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
    private function write_push($content)
    {
        $msg = [];

        $msg['act']  = "room";
        $msg['op']   = "relay";
        $msg['relay_type'] = "alluser";
        $msg['receivers'] = [];
        $msg['room'] = 0;
        $msg['receiver_type'] = proto_type::sroom_push;

        $msg['body']['act']  = proto_type::act_push;
        $msg['body']['op']   = 'message';
        $msg['body']['content'] = $content;

        $body = $this->success($msg);
        foreach ($this->mAccConnes as $conn) {
            process_looper::instance()->write($conn,$body);
        }
    }
    ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
    protected function write_accmsg($bufid,$op,$content)
    {
        $msg['act']  = "access";
        $msg['op']   = $op;

        $msg['body']['act']  = 'access';
        $msg['body']['op']   = $op;
        $msg['body']['content'] = $content;
        $body = $this->success($msg);

        process_looper::instance()->write($bufid,$body);
    }

    private function write_roomsg($bufid,$room)
    {
        $retmsgs = $room->relay_users_msgs();
        foreach ($retmsgs as $msg) {
            $body = json_encode($msg);
            process_looper::instance()->write($bufid,$body);
        }

        $broad_msgs = $room->relay_broadcast_msgs();
        foreach ($broad_msgs as $msg)
        {
            $body = json_encode($msg);
            foreach ($this->mAccConnes as $conn) {
                process_looper::instance()->write($conn,$body);
            }
        }
    }
    ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
    private function room($roomid)
    {
        if($roomid <= 0) return false;
        if(array_key_exists($roomid,$this->mRooms)) {
            return $this->mRooms[$roomid];
        } else {
            return false;
        }
    }

    private function add_acc($bufid) {
        $connid = intval($bufid);
        if($connid <= 0) return false;

        if(!algorithm::binary_search($this->mAccConnes,$connid)) {
            $pos = algorithm::lower_bonud($this->mAccConnes,$connid);
            algorithm::array_insert($this->mAccConnes,$pos,$connid);
        }
        return true;
    }
    private function remove_acc($bufid)
    {
        $connid = intval($bufid);
        if($connid <= 0) return false;

        if(algorithm::binary_search($this->mAccConnes,$connid)) {
            $pos = algorithm::lower_bonud($this->mAccConnes,$connid);
            algorithm::array_erase($this->mAccConnes,$pos);
        }
        return true;
    }

    ////////////////////////////////返回包///////////////////////////////////////////////////////////////////////////////
    private function success($val)
    {
        $code = errcode::Success;
        $data['code'] = $code;
        $data['message'] = errcode::msg($code);
        $data['data'] = $val;
        $data['msgtype'] = "reply";

        return json_encode($data);
    }

    private function error($code,$message = '')
    {
        if (empty($message)) {
            $message = errcode::msg($code);
        }

        $data['code'] = $code;
        $data['message'] = $message;
        $data['data'] = null;
        $data['msgtype'] = "reply";

        return json_encode($data);
    }
}