octamp/client

WAMP client for PHP Swoole

v1.3.0 2023-09-23 03:14 UTC

Requires

• php: >=8.1
• voryx/thruway-common: ^1.0

Requires (Dev)

• mockery/mockery: ^1.5
• openswoole/ide-helper: ^4.11
• phpunit/phpunit: ^10.0

MIT

• Cydrick Nonog

README

Octamp Client is an open source client for WAMP (Web Application Messaging Protocol), for PHP.

Octamp Client uses Open Swoole, is a high-performance network framework based on an event-driven, asynchronous, non-blocking I/O coroutine programming model for PHP.

We also design the Octamp Client functions to be identical to AutobahnJS

The name Octamp is from Octopus + WAMP

Supported WAMP Features

• Publish
• Subscribe
• Call
• Call Progressive
• Register

Requierements

• PHP >= 8.1
• Swoole / OpenSwoole Extension

Installation

composer require octamp/client

Example

<?php

use Octamp\Client\Auth\WampcraAuthenticator;
use Octamp\Client\Peer;
use Octamp\Client\Session;

require_once __DIR__ . '/../../vendor/autoload.php';

\Co\run(function () {
    $client = new Peer('crossbar', 9000);
    
    $client->onOpen(function (Session $session) {
        // subscribe
        $session->subscribe('hello', function (array $args) {
            echo 'Event ' . $args[0] . PHP_EOL;
        });
    
        // publish
        $session->publish('hello', ['hello octamp'], [], ['exclude_me' => false]);
    
        // publish with acknowledgement
        $session
            ->publish('hello', ['hello octamp with acknowledgement'], [], ['acknowledge' => true, 'exclude_me' => false])
            ->then(
                function () {
                    echo 'Publish Acknowledged!' . PHP_EOL;
                },
                function ($error) {
                    echo 'Publish Error ' . $error . PHP_EOL;
                },
            );
    
        // register
        $session->register('add', function (array $args) {
            return $args[0] + $args[1];
        });
    
        // call
        $session->call('add', [1, 3])->then(function ($result) {
            echo 'Result ' . $result . PHP_EOL;
        });
    });
    
    $client->open();
});

TODOs

• Call Cancel
• Call Timeout
• Unsubscribe
• RPC Progress Call
• Auto Reconnect
• Subprotocol Handling
• Heartbeat
• Custom Error Handling
• TLS connection
• Session Logging
• Session Prefix
• Pattern Base Subscription / Registration