Import clue/reactphp-buzz v2.9.0

Change namespace from `Clue\React\Buzz` to `React\Http` and update all
tests with merged namespaces.

See https://github.com/clue/reactphp-buzz for original repo.

Author: clue

LICENSE

@@ -1,3 +1,6 @@
+The MIT License (MIT)
+
+Copyright (c) 2013 Christian Lück
 Copyright (c) 2012 Igor Wiedler, Chris Boden
 
 Permission is hereby granted, free of charge, to any person obtaining a copy

README.md

@@ -5,15 +5,21 @@
     "license": "MIT",
     "require": {
         "php": ">=5.3.0",
-        "ringcentral/psr7": "^1.2",
-        "react/socket": "^1.0 || ^0.8.3",
-        "react/stream": "^1.0 || ^0.7.1",
-        "react/promise": "^2.3 || ^1.2.1",
         "evenement/evenement": "^3.0 || ^2.0 || ^1.0",
-        "react/promise-stream": "^1.1"
+        "psr/http-message": "^1.0",
+        "react/event-loop": "^1.0 || ^0.5",
+        "react/http-client": "^0.5.10",
+        "react/promise": "^2.3 || ^1.2.1",
+        "react/promise-stream": "^1.1",
+        "react/socket": "^1.1",
+        "react/stream": "^1.0 || ^0.7.5",
+        "ringcentral/psr7": "^1.2"
     },
     "require-dev": {
         "clue/block-react": "^1.1",
+        "clue/http-proxy-react": "^1.3",
+        "clue/reactphp-ssh-proxy": "^1.0",
+        "clue/socks-react": "^1.0",
         "phpunit/phpunit": "^9.0 || ^5.7 || ^4.8.35"
     },
     "autoload": {

composer.json

@@ -0,0 +1,15 @@
+<?php
+
+use React\Http\Browser;
+use Psr\Http\Message\ResponseInterface;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$loop = React\EventLoop\Factory::create();
+$client = new Browser($loop);
+
+$client->get('http://google.com/')->then(function (ResponseInterface $response) {
+    var_dump($response->getHeaders(), (string)$response->getBody());
+});
+
+$loop->run();

examples/01-google.php

@@ -0,0 +1,23 @@
+<?php
+
+use React\Http\Browser;
+use Psr\Http\Message\ResponseInterface;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$loop = React\EventLoop\Factory::create();
+$client = new Browser($loop);
+
+$client->head('http://www.github.com/clue/http-react')->then(function (ResponseInterface $response) {
+    var_dump($response->getHeaders(), (string)$response->getBody());
+});
+
+$client->get('http://google.com/')->then(function (ResponseInterface $response) {
+    var_dump($response->getHeaders(), (string)$response->getBody());
+});
+
+$client->get('http://www.lueck.tv/psocksd')->then(function (ResponseInterface $response) {
+    var_dump($response->getHeaders(), (string)$response->getBody());
+});
+
+$loop->run();

examples/02-concurrent.php

@@ -0,0 +1,32 @@
+<?php
+
+// concurrently request a number of URLs.
+// return immediately once the first is completed, cancel all others.
+
+use React\Http\Browser;
+use Psr\Http\Message\ResponseInterface;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$loop = React\EventLoop\Factory::create();
+$client = new Browser($loop);
+
+$promises = array(
+    $client->head('http://www.github.com/clue/http-react'),
+    $client->get('https://httpbin.org/'),
+    $client->get('https://google.com'),
+    $client->get('http://www.lueck.tv/psocksd'),
+    $client->get('http://www.httpbin.org/absolute-redirect/5')
+);
+
+React\Promise\any($promises)->then(function (ResponseInterface $response) use ($promises) {
+    // first response arrived => cancel all other pending requests
+    foreach ($promises as $promise) {
+        $promise->cancel();
+    }
+
+    var_dump($response->getHeaders());
+    echo PHP_EOL . $response->getBody();
+});
+
+$loop->run();

examples/03-any.php

@@ -0,0 +1,29 @@
+<?php
+
+use React\Http\Browser;
+use Psr\Http\Message\ResponseInterface;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$loop = React\EventLoop\Factory::create();
+$client = new Browser($loop);
+
+$data = array(
+    'name' => array(
+        'first' => 'Alice',
+        'name' => 'Smith'
+    ),
+    'email' => 'alice@example.com'
+);
+
+$client->post(
+    'https://httpbin.org/post',
+    array(
+        'Content-Type' => 'application/json'
+    ),
+    json_encode($data)
+)->then(function (ResponseInterface $response) {
+    echo (string)$response->getBody();
+}, 'printf');
+
+$loop->run();

examples/04-post-json.php

@@ -0,0 +1,26 @@
+<?php
+
+use React\Http\Browser;
+use Psr\Http\Message\ResponseInterface;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$loop = React\EventLoop\Factory::create();
+$client = new Browser($loop);
+
+$xml = new SimpleXMLElement('<users></users>');
+$child = $xml->addChild('user');
+$child->alias = 'clue';
+$child->name = 'Christian Lück';
+
+$client->put(
+    'https://httpbin.org/put',
+    array(
+        'Content-Type' => 'text/xml'
+    ),
+    $xml->asXML()
+)->then(function (ResponseInterface $response) {
+    echo (string)$response->getBody();
+}, 'printf');
+
+$loop->run();

examples/05-put-xml.php

@@ -0,0 +1,29 @@
+<?php
+
+use React\Http\Browser;
+use Clue\React\HttpProxy\ProxyConnector as HttpConnectClient;
+use Psr\Http\Message\ResponseInterface;
+use React\EventLoop\Factory as LoopFactory;
+use React\Socket\Connector;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$loop = LoopFactory::create();
+
+// create a new HTTP CONNECT proxy client which connects to a HTTP CONNECT proxy server listening on localhost:8080
+// not already running a HTTP CONNECT proxy server? Try LeProxy.org!
+$proxy = new HttpConnectClient('127.0.0.1:8080', new Connector($loop));
+
+// create a Browser object that uses the HTTP CONNECT proxy client for connections
+$connector = new Connector($loop, array(
+    'tcp' => $proxy,
+    'dns' => false
+));
+$browser = new Browser($loop, $connector);
+
+// demo fetching HTTP headers (or bail out otherwise)
+$browser->get('https://www.google.com/')->then(function (ResponseInterface $response) {
+    echo RingCentral\Psr7\str($response);
+}, 'printf');
+
+$loop->run();

examples/11-http-proxy.php

@@ -0,0 +1,29 @@
+<?php
+
+use React\Http\Browser;
+use Clue\React\Socks\Client as SocksClient;
+use Psr\Http\Message\ResponseInterface;
+use React\EventLoop\Factory as LoopFactory;
+use React\Socket\Connector;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$loop = LoopFactory::create();
+
+// create a new SOCKS proxy client which connects to a SOCKS proxy server listening on localhost:1080
+// not already running a SOCKS proxy server? Try LeProxy.org or this: `ssh -D 1080 localhost`
+$proxy = new SocksClient('127.0.0.1:1080', new Connector($loop));
+
+// create a Browser object that uses the SOCKS proxy client for connections
+$connector = new Connector($loop, array(
+    'tcp' => $proxy,
+    'dns' => false
+));
+$browser = new Browser($loop, $connector);
+
+// demo fetching HTTP headers (or bail out otherwise)
+$browser->get('https://www.google.com/')->then(function (ResponseInterface $response) {
+    echo RingCentral\Psr7\str($response);
+}, 'printf');
+
+$loop->run();