README

Shared data model, serialization, middleware pipeline, and contract system for RPC over WebSocket.

This is the foundation library — both rpc-client and rpc-server depend on it.

Install

composer require php-websocket-rpc/rpc

Requires PHP 8.5+ and the msgpack extension.

Features

• Payload model — base class and kind interfaces (request, response, notification, stream open/close/data)
• Contract system — ContractInvocation, ContractResponse, ContractStreamInvocation, ContractStreamValue, ContractStreamClose, ContractPublish
• PHP Attributes — #[RpcSubscribe], #[RpcStream], #[RpcPublish], #[NeedAuthorization] for declaring RPC patterns on interfaces
• Serialization — ContractSerializer encodes/decodes values for wire transmission using [FQCN, props] format
• Middleware pipeline — MiddlewarePipeline for chaining request/response processors
• Stream interfaces — StreamChannelAware, StreamSubscribable for streaming and pub/sub
• Authentication — AuthService contract, WebsocketUserInterface, User value object, typed auth exceptions

Contract Attributes

Authentication

AuthService Contract

A built-in contract that all clients can use to authenticate:

use PhpWebsocketRpc\Rpc\Contract\AuthService;

$auth = $client->createProxy(AuthService::class);
$user = $auth->authenticate('jwt-token-here');
// $user instanceof PhpWebsocketRpc\Rpc\Auth\User
// $user->id, $user->roles

WebsocketUserInterface

interface WebsocketUserInterface
{
    public function getUniqueIdentifier(): string;
    public function getRoles(): array;
}

User (built-in value object)

$user = new User('user-42', ['admin', 'customer']);
echo $user->id;          // 'user-42'
echo $user->roles;       // ['admin', 'customer']

Error Codes

Both extend RpcDispatchException and carry the error code in getRpcCode().

Key Classes