Xsolve\SalesforceClient\Repository\SObjectRepository

Complexity

Total Complexity

8

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	delete()	0	3	1
A	update()	0	6	1
A	create()	0	12	2
A	getFieldValues()	0	7	2
A	find()	0	5	1

<?php

namespace Xsolve\SalesforceClient\Repository;

use JMS\Serializer\ArrayTransformerInterface;
use JMS\Serializer\SerializationContext;
use Xsolve\SalesforceClient\Client\SalesforceClient;
use Xsolve\SalesforceClient\Model\AbstractSObject;
use Xsolve\SalesforceClient\Request\Create;
use Xsolve\SalesforceClient\Request\Delete;
use Xsolve\SalesforceClient\Request\Get;
use Xsolve\SalesforceClient\Request\Update;

class SObjectRepository implements SObjectRepositoryInterface
{
    const GROUP_UPDATE = 'update';
    const GROUP_CREATE = 'create';

    /**
     * @var SalesforceClient
     */
    protected $client;

    /**
     * @var ArrayTransformerInterface
     */
    protected $serializer;

    public function __construct(SalesforceClient $client, ArrayTransformerInterface $serializer)
    {
        $this->client = $client;
        $this->serializer = $serializer;
    }

    /**
     * {@inheritdoc}
     */
    public function create(AbstractSObject $object)
    {
        $response = $this->client->doRequest(new Create(
            $object::getSObjectName(),
            $this->serializer->toArray($object, SerializationContext::create()->setGroups([self::GROUP_CREATE]))
        ));

        if (!$response['success']) {
            return;
        }

        $object->setId($response['id']);
    }

    /**
     * {@inheritdoc}
     */
    public function delete(AbstractSObject $object)
    {
        $this->client->doRequest(new Delete($object::getSObjectName(), $object->getId()));
    }

    /**
     * {@inheritdoc}
     */
    public function update(AbstractSObject $object)
    {
        $this->client->doRequest(new Update(
            $object::getSObjectName(),
            $object->getId(),
            $this->serializer->toArray($object, SerializationContext::create()->setGroups([self::GROUP_UPDATE])->setSerializeNull(true))
        ));
    }

    /**
     * {@inheritdoc}
     */
    public function find(string $class, string $id): AbstractSObject
    {
        return $this->serializer->fromArray(
            $this->getFieldValues($class, $id),
            $class
        );
    }

    /**
     * {@inheritdoc}
     */
    public function getFieldValues(string $class, string $id, array $fields = []): array
    {
        if (!is_a($class, AbstractSObject::class, true)) {
            throw new \RuntimeException(sprintf('%s should extend %s', $class, AbstractSObject::class));
        }

        return $this->client->doRequest(new Get($class::getSObjectName(), $id, $fields));
    }
}