shipping-portal/app/Classes/Modules/PerfexCRM/Services/CreatesPerfexCRMLead.php

<?php

namespace App\Classes\Modules\PerfexCRM\Services;

use Illuminate\Support\Facades\Http;
use App\Classes\Exceptions\MalformedRequestException;
use App\Classes\Exceptions\ConnectionErrorException;
use Illuminate\Support\Facades\Log;
use App\Classes\Modules\PerfexCRM\DataTransferObjects\CreateLeadPerfexCRMObject;

class CreatesPerfexCRMLead
{
    /**
     * @param CreateLeadPerfexCRMObject $createLeadPerfexCRMObject
     * @return null|object
     * @throws MalformedRequestException
     */
    public function execute(CreateLeadPerfexCRMObject $createLeadPerfexCRMObject) {
        try{
            $custom_fields = [
                "leads" => [
                    4 => $createLeadPerfexCRMObject->getCompanyReference()
                ]
            ];

            $data = [
                'name' => $createLeadPerfexCRMObject->getName(),
                'email' => $createLeadPerfexCRMObject->getEmail(),
                'phonenumber' => $createLeadPerfexCRMObject->getPhone(),
                'company' => $createLeadPerfexCRMObject->getCompanyName(),
                'source' => 2, //1: Exchange, 2: Shipping Portal
                'status' => 2, //2: Lead, 1: Customer
                'custom_fields' => $custom_fields
            ];

            $response = Http::asForm()->withHeaders([
                'authtoken' => config('perfexcrm.api_key')])
            ->post(config('perfexcrm.base_url').'/api/leads/byemail',$data);

            if($response->successful()){
                $data = $response->json();
                return (object) $data;
            }else{
                Log::channel('perfex_crm')->info('CreatesPerfexCRMLead: '.$response);
                return null;
            }
        }
        catch(\Illuminate\Http\Client\ConnectionException $exception){
            $error = 'Failed to connect to CRM';
            throw new ConnectionErrorException($error, $exception->getMessage(), "", $exception->getTraceAsString());
        }
        catch(\Exception $exception){
            throw new MalformedRequestException('Unable to get correct response from Perfex CRM server: ' . $exception->getMessage());
        }
    }
}