class AmqpCaster

class AmqpCaster {
    private const FLAGS = [
        \AMQP_DURABLE => 'AMQP_DURABLE',
        \AMQP_PASSIVE => 'AMQP_PASSIVE',
        \AMQP_EXCLUSIVE => 'AMQP_EXCLUSIVE',
        \AMQP_AUTODELETE => 'AMQP_AUTODELETE',
        \AMQP_INTERNAL => 'AMQP_INTERNAL',
        \AMQP_NOLOCAL => 'AMQP_NOLOCAL',
        \AMQP_AUTOACK => 'AMQP_AUTOACK',
        \AMQP_IFEMPTY => 'AMQP_IFEMPTY',
        \AMQP_IFUNUSED => 'AMQP_IFUNUSED',
        \AMQP_MANDATORY => 'AMQP_MANDATORY',
        \AMQP_IMMEDIATE => 'AMQP_IMMEDIATE',
        \AMQP_MULTIPLE => 'AMQP_MULTIPLE',
        \AMQP_NOWAIT => 'AMQP_NOWAIT',
        \AMQP_REQUEUE => 'AMQP_REQUEUE',
    ];
    private const EXCHANGE_TYPES = [
        \AMQP_EX_TYPE_DIRECT => 'AMQP_EX_TYPE_DIRECT',
        \AMQP_EX_TYPE_FANOUT => 'AMQP_EX_TYPE_FANOUT',
        \AMQP_EX_TYPE_TOPIC => 'AMQP_EX_TYPE_TOPIC',
        \AMQP_EX_TYPE_HEADERS => 'AMQP_EX_TYPE_HEADERS',
    ];
    public static function castConnection(\AMQPConnection $c, array $a, Stub $stub, bool $isNested) : array {
        $prefix = Caster::PREFIX_VIRTUAL;
        $a += [
            $prefix . 'is_connected' => $c->isConnected(),
        ];
        // Recent version of the extension already expose private properties
        if (isset($a["\x00AMQPConnection\x00login"])) {
            return $a;
        }
        // BC layer in the amqp lib
        if (method_exists($c, 'getReadTimeout')) {
            $timeout = $c->getReadTimeout();
        }
        else {
            $timeout = $c->getTimeout();
        }
        $a += [
            $prefix . 'is_connected' => $c->isConnected(),
            $prefix . 'login' => $c->getLogin(),
            $prefix . 'password' => $c->getPassword(),
            $prefix . 'host' => $c->getHost(),
            $prefix . 'vhost' => $c->getVhost(),
            $prefix . 'port' => $c->getPort(),
            $prefix . 'read_timeout' => $timeout,
        ];
        return $a;
    }
    public static function castChannel(\AMQPChannel $c, array $a, Stub $stub, bool $isNested) : array {
        $prefix = Caster::PREFIX_VIRTUAL;
        $a += [
            $prefix . 'is_connected' => $c->isConnected(),
            $prefix . 'channel_id' => $c->getChannelId(),
        ];
        // Recent version of the extension already expose private properties
        if (isset($a["\x00AMQPChannel\x00connection"])) {
            return $a;
        }
        $a += [
            $prefix . 'connection' => $c->getConnection(),
            $prefix . 'prefetch_size' => $c->getPrefetchSize(),
            $prefix . 'prefetch_count' => $c->getPrefetchCount(),
        ];
        return $a;
    }
    public static function castQueue(\AMQPQueue $c, array $a, Stub $stub, bool $isNested) : array {
        $prefix = Caster::PREFIX_VIRTUAL;
        $a += [
            $prefix . 'flags' => self::extractFlags($c->getFlags()),
        ];
        // Recent version of the extension already expose private properties
        if (isset($a["\x00AMQPQueue\x00name"])) {
            return $a;
        }
        $a += [
            $prefix . 'connection' => $c->getConnection(),
            $prefix . 'channel' => $c->getChannel(),
            $prefix . 'name' => $c->getName(),
            $prefix . 'arguments' => $c->getArguments(),
        ];
        return $a;
    }
    public static function castExchange(\AMQPExchange $c, array $a, Stub $stub, bool $isNested) : array {
        $prefix = Caster::PREFIX_VIRTUAL;
        $a += [
            $prefix . 'flags' => self::extractFlags($c->getFlags()),
        ];
        $type = isset(self::EXCHANGE_TYPES[$c->getType()]) ? new ConstStub(self::EXCHANGE_TYPES[$c->getType()], $c->getType()) : $c->getType();
        // Recent version of the extension already expose private properties
        if (isset($a["\x00AMQPExchange\x00name"])) {
            $a["\x00AMQPExchange\x00type"] = $type;
            return $a;
        }
        $a += [
            $prefix . 'connection' => $c->getConnection(),
            $prefix . 'channel' => $c->getChannel(),
            $prefix . 'name' => $c->getName(),
            $prefix . 'type' => $type,
            $prefix . 'arguments' => $c->getArguments(),
        ];
        return $a;
    }
    public static function castEnvelope(\AMQPEnvelope $c, array $a, Stub $stub, bool $isNested, int $filter = 0) : array {
        $prefix = Caster::PREFIX_VIRTUAL;
        $deliveryMode = new ConstStub($c->getDeliveryMode() . (2 === $c->getDeliveryMode() ? ' (persistent)' : ' (non-persistent)'), $c->getDeliveryMode());
        // Recent version of the extension already expose private properties
        if (isset($a["\x00AMQPEnvelope\x00body"])) {
            $a["\x00AMQPEnvelope\x00delivery_mode"] = $deliveryMode;
            return $a;
        }
        if (!($filter & Caster::EXCLUDE_VERBOSE)) {
            $a += [
                $prefix . 'body' => $c->getBody(),
            ];
        }
        $a += [
            $prefix . 'delivery_tag' => $c->getDeliveryTag(),
            $prefix . 'is_redelivery' => $c->isRedelivery(),
            $prefix . 'exchange_name' => $c->getExchangeName(),
            $prefix . 'routing_key' => $c->getRoutingKey(),
            $prefix . 'content_type' => $c->getContentType(),
            $prefix . 'content_encoding' => $c->getContentEncoding(),
            $prefix . 'headers' => $c->getHeaders(),
            $prefix . 'delivery_mode' => $deliveryMode,
            $prefix . 'priority' => $c->getPriority(),
            $prefix . 'correlation_id' => $c->getCorrelationId(),
            $prefix . 'reply_to' => $c->getReplyTo(),
            $prefix . 'expiration' => $c->getExpiration(),
            $prefix . 'message_id' => $c->getMessageId(),
            $prefix . 'timestamp' => $c->getTimeStamp(),
            $prefix . 'type' => $c->getType(),
            $prefix . 'user_id' => $c->getUserId(),
            $prefix . 'app_id' => $c->getAppId(),
        ];
        return $a;
    }
    private static function extractFlags(int $flags) : ConstStub {
        $flagsArray = [];
        foreach (self::FLAGS as $value => $name) {
            if ($flags & $value) {
                $flagsArray[] = $name;
            }
        }
        if (!$flagsArray) {
            $flagsArray = [
                'AMQP_NOPARAM',
            ];
        }
        return new ConstStub(implode('|', $flagsArray), $flags);
    }

}