SalesforceBulkApi\api\JobApiSF

Complexity

Total Complexity

3

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	15	1
A	detail()	0	14	1
A	close()	0	15	1

<?php

namespace SalesforceBulkApi\api;

use SalesforceBulkApi\dto\CreateJobDto;
use SalesforceBulkApi\dto\JobInfoDto;
use SalesforceBulkApi\helpers\ApiHelper;
use SalesforceBulkApi\services\ApiSalesforce;
use GuzzleHttp\Psr7\Request;

class JobApiSF
{
    /**
     * @var string
     */
    public static $endpoint = 'https://%s.salesforce.com/services/async/%s/job';

    /**
     * @param ApiSalesforce $api
     * @param CreateJobDto  $dto
     *
     * @return JobInfoDto
     * @throws \Exception
     */
    public static function create(ApiSalesforce $api, CreateJobDto $dto)
    {
        $version  = $api->getLoginParams()->getApiVersion();
        $request  = new Request(
            'POST',
            sprintf(self::$endpoint, $api->getSession()->getInstance(), $version),
            [
                'Content-Type'   => 'application/json; charset=UTF8',
                'X-SFDC-Session' => $api->getSession()->getSessionId()
            ],
            $dto->toJson()
        );
        $response = ApiHelper::getResponse($request, $api);

        return new JobInfoDto($response->getBody()->getContents());
    }

    /**
     * @param ApiSalesforce $api
     * @param JobInfoDto    $job
     *
     * @return JobInfoDto
     * @throws \Exception
     */
    public static function detail(ApiSalesforce $api, JobInfoDto $job)
    {
        $version  = $api->getLoginParams()->getApiVersion();
        $request  = new Request(
            'GET',
            sprintf(self::$endpoint, $api->getSession()->getInstance(), $version) . '/' . $job->getId(),
            [
                'Content-Type'   => 'application/json; charset=UTF8',
                'X-SFDC-Session' => $api->getSession()->getSessionId()
            ]
        );
        $response = ApiHelper::getResponse($request, $api);

        return new JobInfoDto($response->getBody()->getContents());
    }

    /**
     * @param ApiSalesforce $api
     * @param JobInfoDto    $job
     *
     * @return JobInfoDto
     * @throws \Exception
     */
    public static function close(ApiSalesforce $api, JobInfoDto $job)
    {
        $version  = $api->getLoginParams()->getApiVersion();
        $request  = new Request(
            'POST',
            sprintf(self::$endpoint, $api->getSession()->getInstance(), $version) . '/' . $job->getId(),
            [
                'Content-Type'   => 'application/json; charset=UTF8',
                'X-SFDC-Session' => $api->getSession()->getSessionId()
            ],
            '{ "state" : "Closed" }'
        );
        $response = ApiHelper::getResponse($request, $api);

        return new JobInfoDto($response->getBody()->getContents());
    }
}