Events

OPC UA Client ──dispatch──▸ PSR-14 EventDispatcher ──▸ Laravel Event System ──▸ Your Listeners

// AppServiceProvider or any service provider boot() method

use Illuminate\Support\Facades\Event;
use PhpOpcua\Client\Event\ClientConnected;
use PhpOpcua\Client\Event\NodeValueRead;
use PhpOpcua\Client\Event\DataChangeReceived;

Event::listen(ClientConnected::class, function (ClientConnected $e) {
    logger()->info("Connected to {$e->endpointUrl}");
});

Event::listen(NodeValueRead::class, function (NodeValueRead $e) {
    logger()->debug("Read {$e->nodeId}: {$e->dataValue->getValue()}");
});

Event::listen(DataChangeReceived::class, function (DataChangeReceived $e) {
    DB::table('sensor_readings')->insert([
        'value' => $e->dataValue->getValue(),
        'client_handle' => $e->clientHandle,
        'timestamp' => now(),
    ]);
});

// app/Listeners/LogOpcUaConnection.php
namespace App\Listeners;

use PhpOpcua\Client\Event\ClientConnected;

class LogOpcUaConnection
{
    public function handle(ClientConnected $event): void
    {
        logger()->info("OPC UA connected to {$event->endpointUrl}");
    }
}

// AppServiceProvider::boot()
Event::listen(ClientConnected::class, LogOpcUaConnection::class);

namespace App\Listeners;

use Illuminate\Contracts\Queue\ShouldQueue;
use PhpOpcua\Client\Event\DataChangeReceived;

class StoreDataChange implements ShouldQueue
{
    public $queue = 'opcua';

    public function handle(DataChangeReceived $event): void
    {
        DB::table('sensor_readings')->insert([
            'value' => $event->dataValue->getValue(),
            'client_handle' => $event->clientHandle,
            'subscription_id' => $event->subscriptionId,
        ]);
    }
}

use PhpOpcua\Client\Event\ClientConnected;
use PhpOpcua\Client\Event\ClientDisconnected;
use PhpOpcua\Client\Event\ConnectionFailed;

Event::listen(ClientConnected::class, function ($e) {
    logger()->info("OPC UA connected: {$e->endpointUrl}");
});

Event::listen(ClientDisconnected::class, function ($e) {
    logger()->info('OPC UA disconnected');
});

Event::listen(ConnectionFailed::class, function ($e) {
    logger()->error("OPC UA connection failed: {$e->endpointUrl}", [
        'error' => $e->exception->getMessage(),
    ]);
});

use PhpOpcua\Client\Event\CacheHit;
use PhpOpcua\Client\Event\CacheMiss;

$hits = 0;
$misses = 0;

Event::listen(CacheHit::class, function () use (&$hits) { $hits++; });
Event::listen(CacheMiss::class, function () use (&$misses) { $misses++; });

use PhpOpcua\Client\Event\AlarmActivated;
use App\Notifications\AlarmTriggered;

Event::listen(AlarmActivated::class, function (AlarmActivated $e) {
    $operators = User::role('operator')->get();

    Notification::send($operators, new AlarmTriggered(
        source: $e->sourceName,
        severity: $e->severity,
        message: $e->message,
    ));
});

use PhpOpcua\Client\Event\NodeValueWriteFailed;

Event::listen(NodeValueWriteFailed::class, function (NodeValueWriteFailed $e) {
    logger()->warning("Write failed on {$e->nodeId}", [
        'value' => $e->value,
        'status' => sprintf('0x%08X', $e->statusCode),
    ]);
});

use PhpOpcua\Client\Event\RetryAttempt;
use PhpOpcua\Client\Event\RetryExhausted;

Event::listen(RetryAttempt::class, function (RetryAttempt $e) {
    logger()->warning("Retry {$e->attempt}/{$e->maxRetries}: {$e->exception->getMessage()}");
});

Event::listen(RetryExhausted::class, function (RetryExhausted $e) {
    logger()->error("All {$e->maxRetries} retries exhausted", [
        'error' => $e->exception->getMessage(),
    ]);
});

use PhpOpcua\Client\Event\DataChangeReceived;
use Illuminate\Support\Facades\Broadcast;

Event::listen(DataChangeReceived::class, function (DataChangeReceived $e) {
    broadcast(new \App\Events\SensorUpdated(
        clientHandle: $e->clientHandle,
        value: $e->dataValue->getValue(),
    ));
});

$client = Opcua::connectTo('opc.tcp://...', [
    'event_dispatcher' => null,
]);

use PhpOpcua\Client\Event\NullEventDispatcher;

$client = Opcua::connect();
$client->setEventDispatcher(new NullEventDispatcher());