heristop/webservice-bundle

This bundle allows to synchronize a table with a soap webservice.

WebServiceBundle

This bundle allows to synchronize a table with a soap webservice., _(*1)

Installation

Download sources from github:, _(*2)

    [HeriJobQueueBundle]
        git=https://github.com/heristop/HeriWebServiceBundle.git
        target=/bundles/Heri/WebServiceBundle/

Or use composer adding the requirement below:, _(*3)

``` js { "require": { "heristop/webservice-bundle": "*" } }, <sub>(*4)</sub>

Register namespace in autoload:

```php

    $loader->registerNamespaces(array(
        ...
        'Heri' => __DIR__.'/../vendor/bundles',
    ));

Load in AppKernel:, <sub>(*5)</sub>

    $bundles[] = new Heri\WebServiceBundle\HeriWebServiceBundle();

Usage

First, add the column toUpdate in your entity definition. This field will be set to false after the synchronization:, <sub>(*6)</sub>

    /**
     * @ORM\Column(name="to_update", type="boolean")
     */
    protected $toUpdate;

Generate getters and setters:, <sub>(*7)</sub>

    app/console doctrine:generate:entities %YourBundle%

Create a class in %YourBundle%/Service directory to apply the mapping with the WSDL. The bundle contains an example:, <sub>(*8)</sub>

    namespace Heri\Bundle\WebServiceBundle\Service;

    use Heri\Bundle\WebServiceBundle\ClientSoap\ClientObject;

    class Sample extends ClientObject
    {
        public function configure()
        {
            $this->name  = 'sample';
            $this->table = 'HeriWebServiceBundle:Sample';
            $this->func  = 'addSample';
        }

        public function hydrate($record)
        {  
            $this->params = array(
                'id'    => $record->getId(),
                'label' => $record->getLabel(),
            );
        }

    }

Configure the webservices connection in config.yml:, <sub>(*9)</sub>

    heri_web_service:  
        namespaces:             [ %YourBundleNamespace%\Service ]
        authentication:                      # optional
            login:              %login%
            password:           %password%
        webservices:
            brand:
                name:           brand
                url:            %soap_url%
                authentication: true         # optional

Then, use this command to call a webservice and retrieve all the records with toUpdate to true:, <sub>(*10)</sub>

    app:console webservice:load %Service%

To see the list of available functions add list option., <sub>(*11)</sub>

Configuration

Edit config.yml to add SyncListener:, <sub>(*12)</sub>

    services:
       sync.listener:
            class: Heri\Bundle\WebServiceBundle\Listener\SyncListener
            tags:
                - { name: doctrine.event_listener, event: prePersist, connection: default }
                - { name: doctrine.event_listener, event: postPersist, connection: default }

JobQueue

This bundle can be used with HeriJobQueueBundle to manage multiple webservice connections., <sub>(*13)</sub>

Override configuration and add the depedency to jobqueue service in config.yml:, <sub>(*14)</sub>

    services:
        sync.listener:
            class: Heri\Bundle\WebServiceBundle\Listener\SyncListener
            arguments: [@jobqueue]
            tags:
                - { name: doctrine.event_listener, event: prePersist, connection: default }
                - { name: doctrine.event_listener, event: postPersist, connection: default }
        jobqueue:
            class: Heri\Bundle\JobQueueBundle\Service\QueueService
            arguments: [@logger]
            tags:
                - { name: monolog.logger, channel: jobqueue }

Add a method called synchronize() in the object which return the name of queue:, <sub>(*15)</sub>

    /**
     * Adds synchronization in specified queue
     * 
     * @return string
     */
    public function synchronize()
    {
        return '%queue_name%';
    }

When the record will be saved in database, the synchronization to the webservice will be pushed in queue., <sub>(*16)</sub>

Note

You can override the ClientObject class in order to apply a specific configuration., <sub>(*17)</sub>

The example below shows the method to connect your application to a Magento plateform:, <sub>(*18)</sub>

heri_web_service:
    namespaces:             [ %YourBundleNamespace%\Service ]
    authentication:
        login:              sampleuser
        password:           123456
    webservices:
        magento:
            name:           api
            url:            http://myshop-local.com/index.php/api/

abstract class ClientMagento extends ClientObject
{
    protected $name = 'api';

    protected function callFunction($func, array $params = array())
    {
        $connection = $this->getContainer()->getConnection();
        $sessionId = $this->client->login($connection->getLogin(), $connection->getPassword());

        return $this->client->call(
            $sessionId,
            $func,
            $params
        );
    }
}