added initial support for incoming mtom/xop message handling
This commit is contained in:
parent
8d3743d928
commit
4ed8d6813a
|
@ -0,0 +1,32 @@
|
||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Bundle\WebServiceBundle\Soap;
|
||||||
|
|
||||||
|
class SoapAttachment
|
||||||
|
{
|
||||||
|
private $id;
|
||||||
|
private $type;
|
||||||
|
private $content;
|
||||||
|
|
||||||
|
public function __construct($id, $type, $content)
|
||||||
|
{
|
||||||
|
$this->id = $id;
|
||||||
|
$this->type = $type;
|
||||||
|
$this->content = $content;
|
||||||
|
}
|
||||||
|
|
||||||
|
public function getId()
|
||||||
|
{
|
||||||
|
return $this->id;
|
||||||
|
}
|
||||||
|
|
||||||
|
public function getType()
|
||||||
|
{
|
||||||
|
return $this->type;
|
||||||
|
}
|
||||||
|
|
||||||
|
public function getContent()
|
||||||
|
{
|
||||||
|
return $this->content;
|
||||||
|
}
|
||||||
|
}
|
|
@ -14,6 +14,9 @@ use Bundle\WebServiceBundle\Util\Collection;
|
||||||
|
|
||||||
use Symfony\Component\HttpFoundation\Request;
|
use Symfony\Component\HttpFoundation\Request;
|
||||||
|
|
||||||
|
use Zend\Mime\Mime;
|
||||||
|
use Zend\Mime\Message;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* SoapRequest.
|
* SoapRequest.
|
||||||
*
|
*
|
||||||
|
@ -26,6 +29,11 @@ class SoapRequest extends Request
|
||||||
*/
|
*/
|
||||||
protected $rawContent;
|
protected $rawContent;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $soapMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var string
|
* @var string
|
||||||
*/
|
*/
|
||||||
|
@ -37,20 +45,22 @@ class SoapRequest extends Request
|
||||||
protected $soapHeaders;
|
protected $soapHeaders;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var unknown
|
* @var \Bundle\WebServiceBundle\Util\Collection
|
||||||
*/
|
*/
|
||||||
protected $soapArguments;
|
protected $soapAttachments;
|
||||||
|
|
||||||
public function __construct($rawContent = null, array $query = null, array $attributes = null, array $cookies = null, array $server = null)
|
public function __construct($rawContent = null, array $query = null, array $attributes = null, array $cookies = null, array $server = null)
|
||||||
{
|
{
|
||||||
parent::__construct($query, null, $attributes, $cookies, null, $server);
|
parent::__construct($query, null, $attributes, $cookies, null, $server);
|
||||||
|
|
||||||
$this->rawContent = $rawContent != null ? $rawContent : $this->loadRawContent();
|
$this->rawContent = $rawContent != null ? $rawContent : $this->loadRawContent();
|
||||||
|
$this->soapMessage = null;
|
||||||
$this->soapHeaders = new Collection('getName');
|
$this->soapHeaders = new Collection('getName');
|
||||||
|
$this->soapAttachments = new Collection('getId');
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Gets the SOAP XML content.
|
* Gets raw data send to the server.
|
||||||
*
|
*
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
|
@ -59,11 +69,31 @@ class SoapRequest extends Request
|
||||||
return $this->rawContent;
|
return $this->rawContent;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Gets the XML string of the SOAP message.
|
||||||
|
*
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
public function getSoapMessage()
|
||||||
|
{
|
||||||
|
if($this->soapMessage === null)
|
||||||
|
{
|
||||||
|
$this->soapMessage = $this->initializeSoapMessage();
|
||||||
|
}
|
||||||
|
|
||||||
|
return $this->soapMessage;
|
||||||
|
}
|
||||||
|
|
||||||
public function getSoapHeaders()
|
public function getSoapHeaders()
|
||||||
{
|
{
|
||||||
return $this->soapHeaders;
|
return $this->soapHeaders;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public function getSoapAttachments()
|
||||||
|
{
|
||||||
|
return $this->soapAttachments;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Loads the plain HTTP POST data.
|
* Loads the plain HTTP POST data.
|
||||||
*
|
*
|
||||||
|
@ -73,4 +103,89 @@ class SoapRequest extends Request
|
||||||
{
|
{
|
||||||
return isset($GLOBALS['HTTP_RAW_POST_DATA']) ? $GLOBALS['HTTP_RAW_POST_DATA'] : file_get_contents('php://input');
|
return isset($GLOBALS['HTTP_RAW_POST_DATA']) ? $GLOBALS['HTTP_RAW_POST_DATA'] : file_get_contents('php://input');
|
||||||
}
|
}
|
||||||
|
|
||||||
|
protected function initializeSoapMessage()
|
||||||
|
{
|
||||||
|
if($this->server->has('CONTENT_TYPE'))
|
||||||
|
{
|
||||||
|
$type = $this->splitContentTypeHeader($this->server->get('CONTENT_TYPE'));
|
||||||
|
|
||||||
|
switch($type['_type'])
|
||||||
|
{
|
||||||
|
case 'multipart/related':
|
||||||
|
if($type['type'] == 'application/xop+xml')
|
||||||
|
{
|
||||||
|
return $this->initializeMtomSoapMessage($type, $this->rawContent);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
//log error
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'application/soap+xml':
|
||||||
|
// goto fallback
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
// log error
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// fallback
|
||||||
|
return $this->rawContent;
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function initializeMtomSoapMessage(array $contentTypeHeader, $content)
|
||||||
|
{
|
||||||
|
if(!isset($contentTypeHeader['start']) || !isset($contentTypeHeader['boundary']))
|
||||||
|
{
|
||||||
|
throw new \InvalidArgumentException();
|
||||||
|
}
|
||||||
|
|
||||||
|
$mimeMessage = Message::createFromMessage($content, $contentTypeHeader['boundary']);
|
||||||
|
$mimeParts = $mimeMessage->getParts();
|
||||||
|
|
||||||
|
$soapMimePartId = $contentTypeHeader['start'];
|
||||||
|
$soapMimePartType = $this->splitContentTypeHeader($contentTypeHeader['start-info']);
|
||||||
|
|
||||||
|
$rootPart = array_shift($mimeParts);
|
||||||
|
$rootPartType = $this->splitContentTypeHeader($rootPart->type);
|
||||||
|
|
||||||
|
// TODO: add more checks to achieve full compatibility to MTOM spec
|
||||||
|
// http://www.w3.org/TR/soap12-mtom/
|
||||||
|
if($rootPart->id != $soapMimePartId || $rootPartType['_type'] != 'application/xop+xml' || $rootPartType['type'] != $soapMimePartType['type'])
|
||||||
|
{
|
||||||
|
throw new \InvalidArgumentException();
|
||||||
|
}
|
||||||
|
|
||||||
|
foreach($mimeParts as $mimePart)
|
||||||
|
{
|
||||||
|
$this->soapAttachments->add(new SoapAttachment(
|
||||||
|
trim($mimePart->id, '<>'),
|
||||||
|
$mimePart->type,
|
||||||
|
// handle content decoding / prevent encoding
|
||||||
|
$mimePart->getContent()
|
||||||
|
));
|
||||||
|
}
|
||||||
|
|
||||||
|
// handle content decoding / prevent encoding
|
||||||
|
return $rootPart->getContent();
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function splitContentTypeHeader($header)
|
||||||
|
{
|
||||||
|
$result = array();
|
||||||
|
$parts = explode(';', strtolower($header));
|
||||||
|
|
||||||
|
$result['_type'] = array_shift($parts);
|
||||||
|
|
||||||
|
foreach($parts as $part)
|
||||||
|
{
|
||||||
|
list($key, $value) = explode('=', trim($part), 2);
|
||||||
|
|
||||||
|
$result[$key] = trim($value, '"');
|
||||||
|
}
|
||||||
|
|
||||||
|
return $result;
|
||||||
|
}
|
||||||
}
|
}
|
|
@ -78,7 +78,7 @@ class SoapKernel implements HttpKernelInterface
|
||||||
$this->soapRequest = $this->checkRequest($request);
|
$this->soapRequest = $this->checkRequest($request);
|
||||||
|
|
||||||
ob_start();
|
ob_start();
|
||||||
$this->soapServer->handle($this->soapRequest->getRawContent());
|
$this->soapServer->handle($this->soapRequest->getSoapMessage());
|
||||||
|
|
||||||
$soapResponseContent = ob_get_clean();
|
$soapResponseContent = ob_get_clean();
|
||||||
$this->soapResponse->setContent($soapResponseContent);
|
$this->soapResponse->setContent($soapResponseContent);
|
||||||
|
|
Loading…
Reference in New Issue