Download the PHP package clue/connection-manager-extra without Composer

clue/reactphp-connection-manager-extra

This project provides extra (in terms of "additional", "extraordinary", "special" and "unusual") decorators, built on top of ReactPHP's Socket.

Table of contents

• Support us
• Introduction
• Usage
  • Repeat
  • Timeout
  • Delay
  • Reject
  • Swappable
  • Consecutive
  • Random
  • Concurrent
  • Selective
• Install
• Tests
• License

Support us

I maintain an ecosystem of open-source projects that have been downloaded hundreds of millions of times and are actively maintained and continuously improved. If you find any of these projects useful, please consider becoming a sponsor on GitHub. Your support helps ensure long-term maintenance and continued development. Thank you! 🚀

Introduction

If you're not already familar with react/socket, think of it as an async (non-blocking) version of fsockopen() or stream_socket_client(). I.e. before you can send and receive data to/from a remote server, you first have to establish a connection - which takes its time because it involves several steps. In order to be able to establish several connections at the same time, react/socket provides a simple API to establish simple connections in an async (non-blocking) way.

This project includes several classes that extend this base functionality by implementing the same simple ConnectorInterface. This interface provides a single promise-based method connect($uri) which can be used to easily notify when the connection is successfully established or the Connector gives up and the connection fails.

Because everything uses the same simple API, the resulting Connector classes can be easily interchanged and be used in places that expect the normal ConnectorInterface. This can be used to stack them into each other, like using delaying SSL/TLS connections, randomly picking a Connector or any combination thereof.

Usage

This section lists all features of this library along with some examples. The examples assume you've installed this library and already set up a Socket/Connector instance $connector.

All classes are located in the ConnectionManager\Extra namespace.

Repeat

The ConnectionManagerRepeat($connector, $tries) tries connecting to the given location up to a maximum of $tries times when the connection fails.

If you pass a value of 3 to it, it will first issue a normal connection attempt and then retry up to 2 times if the connection attempt fails:

Timeout

The ConnectionManagerTimeout($connector, $timeout, $loop = null) sets a maximum $timeout in seconds on when to give up waiting for the connection to complete.

Delay

The ConnectionManagerDelay($connector, $delay, $loop = null) sets a fixed initial $delay in seconds before actually trying to connect. (Not to be confused with ConnectionManagerTimeout which sets a maximum timeout.)

Reject

The ConnectionManagerReject(null|string|callable $reason) simply rejects every single connection attempt. This is particularly useful for the below ConnectionManagerSelective to reject connection attempts to only certain destinations (for example blocking advertisements or harmful sites).

The constructor accepts an optional rejection reason which will be used for rejecting the resulting promise.

You can explicitly pass a string value which will be used as the message for the Exception instance:

You can explicitly pass a callable value which will be used to either throw or return a custom Exception instance:

Swappable

The ConnectionManagerSwappable($connector) is a simple decorator for other ConnectionManagers to simplify exchanging the actual ConnectionManager during runtime (->setConnectionManager($connector)).

Consecutive

The ConnectionManagerConsecutive($connectors) establishes connections by trying to connect through any of the given ConnectionManagers in consecutive order until the first one succeeds.

Random

The ConnectionManagerRandom($connectors) works much like ConnectionManagerConsecutive but instead of using a fixed order, it always uses a randomly shuffled order.

Concurrent

The ConnectionManagerConcurrent($connectors) establishes connections by trying to connect through ALL of the given ConnectionManagers at once, until the first one succeeds.

Selective

The ConnectionManagerSelective($connectors) manages a list of Connectors and forwards each connection through the first matching one. This can be used to implement networking access control lists (ACLs) or firewall rules like a blacklist or whitelist.

This allows fine-grained control on how to handle outgoing connections, like rejecting advertisements, delaying unencrypted HTTP requests or forwarding HTTPS connection through a foreign country.

If none of the entries in the list matches, the connection will be rejected. This can be used to implement a very simple whitelist like this:

If you want to implement a blacklist (i.e. reject only certain targets), make sure to add a default target to the end of the list like this:

Similarly, you can also combine any of the other connectors to implement more advanced connection setups, such as delaying unencrypted connections only and retrying unreliable hosts:

Each entry in the list MUST be in the form host or host:port, where host may contain the * wildcard character and port may be given as either an exact port number or as a range in the form of min-max. Passing anything else will result in an InvalidArgumentException.

Note that the host will be matched exactly as-is otherwise. This means that if you only block youtube.com, this has no effect on www.youtube.com. You may want to add a second rule for *.youtube.com in this case.

Install

The recommended way to install this library is through Composer. New to Composer?

This project follows SemVer. This will install the latest supported version:

See also the CHANGELOG for details about version upgrades.

This project aims to run on any platform and thus does not require any PHP extensions and supports running on legacy PHP 5.3 through current PHP 8+ and HHVM. It's highly recommended to use the latest supported PHP version for this project.

Tests

To run the test suite, you first need to clone this repo and then install all dependencies through Composer:

To run the test suite, go to the project root and run:

The test suite is set up to always ensure 100% code coverage across all supported environments. If you have the Xdebug extension installed, you can also generate a code coverage report locally like this:

License

This project is released under the permissive MIT license.

Do you use this project in a commercial setting? Sponsoring with invoicing is available, contact me (@clue) for details.