EventRelayerGroup.php

Go to the documentation of this file.

<?php
namespace Wikimedia\EventRelayer;
 
use UnexpectedValueException;
 
class EventRelayerGroup {
    protected $configByChannel = [];
 
    protected $relayers = [];
 
    public function __construct( array $config ) {
        $this->configByChannel = $config;
    }
 
    public function getRelayer( $channel ) {
        $channelKey = isset( $this->configByChannel[$channel] )
            ? $channel
            : 'default';
 
        if ( !isset( $this->relayers[$channelKey] ) ) {
            if ( !isset( $this->configByChannel[$channelKey] ) ) {
                throw new UnexpectedValueException( "No config for '$channelKey'" );
            }
 
            $config = $this->configByChannel[$channelKey];
            $class = $config['class'];
 
            $this->relayers[$channelKey] = new $class( $config );
        }
 
        return $this->relayers[$channelKey];
    }
}
 
class_alias( EventRelayerGroup::class, 'EventRelayerGroup' );