Skip to content

Add a simple server to test against #63

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Add a simple server to test against #63

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
123 changes: 64 additions & 59 deletions tests/FunctionalTest.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,9 @@
use React\EventLoop\Loop;
use React\Http\Browser;

class BankResponse
class AddResponse
{
public readonly int $additionResult;
}

/**
Expand All @@ -28,14 +29,37 @@ class FunctionalTest extends TestCase
*/
private $client;

// set up server once for all test cases
private static $serverProcess;

// download WSDL file only once for all test cases
private static $wsdl;

/**
* @beforeClass
*/
public static function setUpServerBeforeClass()
{
$listenAddress = '127.0.0.1:8000';
$serverRoot = __DIR__;
$serverStartCommand = sprintf('php -S %s -t %s >/dev/null 2>&1 &', $listenAddress, $serverRoot);
self::$serverProcess = \proc_open($serverStartCommand, [], $pipes);

// Briefly wait for the server to settle.
sleep(1);
}

public static function tearDownAfterClass(): void
{
proc_close(self::$serverProcess);
}

/**
* @beforeClass
*/
public static function setUpFileBeforeClass()
{
self::$wsdl = file_get_contents('http://www.thomas-bayer.com/axis2/services/BLZService?wsdl');
self::$wsdl = file_get_contents('http://localhost:8000/SimpleSoapServer.php?wsdl');
}

/**
Expand All @@ -46,111 +70,91 @@ public function setUpClient()
$this->client = new Client(null, self::$wsdl);
}

public function testBlzService()
public function testSoapService()
{
$this->assertCount(2, $this->client->getFunctions());
$this->assertCount(3, $this->client->getTypes());
$this->assertCount(1, $this->client->getFunctions());
$this->assertCount(2, $this->client->getTypes());

$api = new Proxy($this->client);

$promise = $api->getBank(array('blz' => '12070000'));
$promise = $api->add(['x' => 21, 'y' => 21]);

$result = Block\await($promise, Loop::get());

$this->assertIsObject($result);
$this->assertTrue(isset($result->details));
$this->assertTrue(isset($result->details->bic));
$this->assertEquals(42, $result->additionResult);
}

public function testBlzServiceWithClassmapReturnsExpectedType()
public function testSoapServiceWithClassmapReturnsExpectedType()
{
$this->client = new Client(null, self::$wsdl, array(
'classmap' => array(
'getBankResponseType' => 'Clue\Tests\React\Soap\BankResponse'
'AddResponse' => AddResponse::class
)
));

$this->assertCount(2, $this->client->getFunctions());
$this->assertCount(3, $this->client->getTypes());
$this->assertCount(1, $this->client->getFunctions());
$this->assertCount(2, $this->client->getTypes());

$api = new Proxy($this->client);

$promise = $api->getBank(array('blz' => '12070000'));
$promise = $api->add(['x' => 21, 'y' => 21]);

$result = Block\await($promise, Loop::get());

$this->assertInstanceOf('Clue\Tests\React\Soap\BankResponse', $result);
$this->assertTrue(isset($result->details));
$this->assertTrue(isset($result->details->bic));
$this->assertInstanceOf(AddResponse::class, $result);
$this->assertEquals(42, $result->additionResult);
}

public function testBlzServiceWithSoapV12()
public function testSoapServiceWithSoapV12()
{
$this->client = new Client(null, self::$wsdl, array(
'soap_version' => SOAP_1_2
));

$this->assertCount(2, $this->client->getFunctions());
$this->assertCount(3, $this->client->getTypes());
$this->assertCount(1, $this->client->getFunctions());
$this->assertCount(2, $this->client->getTypes());

$api = new Proxy($this->client);

$promise = $api->getBank(array('blz' => '12070000'));
$promise = $api->add(['x' => 21, 'y' => 21]);

$result = Block\await($promise, Loop::get());

$this->assertIsObject($result);
$this->assertTrue(isset($result->details));
$this->assertTrue(isset($result->details->bic));
$this->assertEquals(42, $result->additionResult);
}

public function testBlzServiceNonWsdlModeReturnedWithoutOuterResultStructure()
public function testSoapServiceNonWsdlMode()
{
$this->client = new Client(null, null, array(
'location' => 'http://www.thomas-bayer.com/axis2/services/BLZService',
'uri' => 'http://thomas-bayer.com/blz/',
'location' => 'http://localhost:8000/SimpleSoapServer.php',
'uri' => 'http://localhost:8000/SimpleSoapServer.php'
));

$api = new Proxy($this->client);

// try encoding the "blz" parameter with the correct namespace (see uri)
// $promise = $api->getBank(new SoapParam('12070000', 'ns1:blz'));
$promise = $api->getBank(new \SoapVar('12070000', XSD_STRING, null, null, 'blz', 'http://thomas-bayer.com/blz/'));

$promise = $api->add((object)['x' => 21, 'y' => 21]);

$result = Block\await($promise, Loop::get());

$this->assertIsObject($result);
$this->assertFalse(isset($result->details));
$this->assertTrue(isset($result->bic));
$this->assertEquals(42, $result->additionResult);
}

public function testBlzServiceWithRedirectLocationRejectsWithRuntimeException()
public function testSoapServiceWithRedirectLocationRejectsWithRuntimeException()
{
$this->client = new Client(null, null, array(
'location' => 'http://httpbingo.org/redirect-to?url=' . rawurlencode('http://www.thomas-bayer.com/axis2/services/BLZService'),
'uri' => 'http://thomas-bayer.com/blz/',
'location' => 'http://httpbin.org/redirect-to?url=' . rawurlencode('http://localhost:8000/SimpleSoapServer.php/'),
'uri' => 'http://localhost:8000/SimpleSoapServer.php/',
));

$api = new Proxy($this->client);
$promise = $api->getBank('a');
$promise = $api->add(['x' => 21, 'y' => 21]);

$this->expectException(\RuntimeException::class);
$this->expectExceptionMessage('redirects');
Block\await($promise, Loop::get());
}

public function testBlzServiceWithInvalidBlzRejectsWithSoapFault()
{
$api = new Proxy($this->client);

$promise = $api->getBank(array('blz' => 'invalid'));

$this->expectException(\SoapFault::class);
$this->expectExceptionMessage('Keine Bank zur BLZ invalid gefunden!');
Block\await($promise, Loop::get());
Async\await($promise);
}

public function testBlzServiceWithInvalidMethodRejectsWithSoapFault()
public function testSoapServiceWithInvalidMethodRejectsWithSoapFault()
{
$api = new Proxy($this->client);

Expand All @@ -165,7 +169,7 @@ public function testCancelMethodRejectsWithRuntimeException()
{
$api = new Proxy($this->client);

$promise = $api->getBank(array('blz' => '12070000'));
$promise = $api->add(['x' => 21, 'y' => 21]);
$promise->cancel();

$this->expectException(\RuntimeException::class);
Expand All @@ -181,7 +185,7 @@ public function testTimeoutRejectsWithRuntimeException()
$this->client = new Client($browser, self::$wsdl);
$api = new Proxy($this->client);

$promise = $api->getBank(array('blz' => '12070000'));
$promise = $api->add(['x' => 21, 'y' => 21]);

$this->expectException(\RuntimeException::class);
$this->expectExceptionMessage('timed out');
Expand All @@ -190,13 +194,13 @@ public function testTimeoutRejectsWithRuntimeException()

public function testGetLocationForFunctionName()
{
$this->assertEquals('http://www.thomas-bayer.com/axis2/services/BLZService', $this->client->getLocation('getBank'));
$this->assertEquals('http://www.thomas-bayer.com/axis2/services/BLZService', $this->client->getLocation('getBank'));
$this->assertEquals('http://localhost:8000/SimpleSoapServer.php', $this->client->getLocation('add'));
$this->assertEquals('http://localhost:8000/SimpleSoapServer.php', $this->client->getLocation('add'));
}

public function testGetLocationForFunctionNumber()
{
$this->assertEquals('http://www.thomas-bayer.com/axis2/services/BLZService', $this->client->getLocation(0));
$this->assertEquals('http://localhost:8000/SimpleSoapServer.php', $this->client->getLocation(0));
}

public function testGetLocationOfUnknownFunctionNameFails()
Expand All @@ -208,7 +212,7 @@ public function testGetLocationOfUnknownFunctionNameFails()
public function testGetLocationForUnknownFunctionNumberFails()
{
$this->expectException(\SoapFault::class);
$this->assertEquals('http://www.thomas-bayer.com/axis2/services/BLZService', $this->client->getLocation(100));
$this->assertEquals('http://localhost:8000/SimpleSoapServer.php', $this->client->getLocation(100));
}

public function testGetLocationWithExplicitLocationOptionReturnsAsIs()
Expand All @@ -233,7 +237,7 @@ public function testWithLocationInvalidRejectsWithRuntimeException()
{
$api = new Proxy($this->client->withLocation('http://nonsense.invalid'));

$promise = $api->getBank(array('blz' => '12070000'));
$promise = $api->add(['x' => 21, 'y' => 21]);

$this->expectException(\RuntimeException::class);
Block\await($promise, Loop::get());
Expand All @@ -246,9 +250,10 @@ public function testWithLocationRestoredToOriginalResolves()
$client = $client->withLocation($original);
$api = new Proxy($client);

$promise = $api->getBank(array('blz' => '12070000'));
$promise = $api->add(['x' => 21, 'y' => 21]);

$result = Block\await($promise, Loop::get());
$this->assertIsObject($result);
$this->assertEquals(42, $result->additionResult);
}
}
25 changes: 25 additions & 0 deletions tests/SimpleSoapServer.php
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
<?php
declare(strict_types=1);
ini_set("soap.wsdl_cache_enabled","0");

class AdditionResult {
public function __construct(public readonly int $additionResult) {}
}

class SoapService {
public function add(object $intsToSum) {
return new AdditionResult($intsToSum->x + $intsToSum->y);
}
}

// Create SOAP server with WSDL
$server = new SoapServer(__DIR__ . '/SimpleSoapServer.wsdl', array(
'soap_version' => SOAP_1_2,
'trace' => true
));

// Set the class that handles the SOAP requests
$server->setClass('SoapService');

// Handle the request
$server->handle();
64 changes: 64 additions & 0 deletions tests/SimpleSoapServer.wsdl
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,64 @@
<?xml version="1.0" encoding="UTF-8"?>
<definitions name="SimpleSoapServer"
targetNamespace="SimpleSoapServer"
xmlns="http://schemas.xmlsoap.org/wsdl/"
xmlns:soap12="http://schemas.xmlsoap.org/wsdl/soap12/"
xmlns:tns="SimpleSoapServer"
xmlns:xsd="http://www.w3.org/2001/XMLSchema">

<types>
<schema targetNamespace="SimpleSoapServer"
xmlns="http://www.w3.org/2001/XMLSchema">
<element name="Add">
<complexType>
<sequence>
<element name="x" type="xsd:int"/>
<element name="y" type="xsd:int"/>
</sequence>
</complexType>
</element>
<element name="AddResponse">
<complexType>
<sequence>
<element name="additionResult" type="xsd:int"/>
</sequence>
</complexType>
</element>
</schema>
</types>

<message name="AddRequest">
<part name="parameters" element="tns:Add"/>
</message>

<message name="AddResponse">
<part name="parameters" element="tns:AddResponse"/>
</message>

<portType name="SimpleSoapServerPortType">
<operation name="add">
<input message="tns:AddRequest"/>
<output message="tns:AddResponse"/>
</operation>
</portType>

<binding name="SimpleSoapServerBinding" type="tns:SimpleSoapServerPortType">
<soap12:binding style="rpc" transport="http://schemas.xmlsoap.org/soap/http"/>
<operation name="add">
<soap12:operation soapAction="http://localhost:8000/SimpleSoapServer.php#add"/>
<input>
<soap12:body use="literal" namespace="SimpleSoapServer"/>
</input>
<output>
<soap12:body use="literal" namespace="SimpleSoapServer"/>
</output>
</operation>
</binding>

<service name="SimpleSoapServer">
<port name="SimpleSoapServerPort" binding="tns:SimpleSoapServerBinding">
<soap12:address location="http://localhost:8000/SimpleSoapServer.php"/>
</port>
</service>

</definitions>
Loading