MySalesforceContactApi::get_my_singleton_connection() - Code Metrics - Inspection of "MAJOR: cleanup" - sunnysideup/silverstripe-salesforcepartner - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — master ( 14ed89...8aec5a )

by Nicolaas
created 2019-07-11 22:35 UTC
get_my_singleton_connection() A

↳ Parent: MySalesforceContactApi
Complexity

Conditions	2
Paths	2
Size

Total Lines	7
Code Lines	3
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
cc	2
eloc	3
nc	2
nop	0
dl	0
loc	7
rs	10
c	1
b	0
f	0
<?php

use SForce\SObject;
use SForce\Wsdl\SaveResult;

/**
 * This class adds / updates subscribers to Salesforce
 */

class MySalesforceContactApi extends Object
{

    /**
     * @param string $email
     * @param string $phoneNumber - OPTIONAL
     * @param string $firstName - OPTIONAL
     * @param string $lastName - OPTIONAL
     * @param array $extraFields - OPTIONAL
     * @param array $extraFilterArray - OPTIONAL
     *
     * @return bool
     */
    public static function add_email_subscriber(
        $email,
        $phoneNumber = null,
        $firstName = null,
        $lastName = null,
        $extraFields = [],
        $extraFilterArray = []
    ): bool
    {
        self::assert_email($email);

        $fields = $extraFields;
        $fields['Email'] = $email;
        $fields['FirstName'] = '-';
        $fields['LastName'] = '-';

        if ($firstName) {
            $fields['FirstName'] = $firstName;
        }
        if ($lastName) {
            $fields['LastName'] = $lastName;
        }
        if ($phoneNumber) {
            $fields['Phone'] = $phoneNumber;
        }

        //doing it!
        return self::create_contact($fields, $extraFilterArray);

    }

    /**
     * @param string $email
     * @param array $extraFields - OPTIONAL
     * @param array $extraFilterArray - OPTIONAL
     *
     * @return bool
     */
    public function update_email_subscriber(
        $email,
        $extraFields = [],
        $extraFilterArray = []
    ): bool
    {
        self::assert_email($email);
        $fields = $extraFields;
        $fields['Email'] = $email;

        //doing it
        return self::update_contact($fields, $extraFilterArray);


    }


    /**
     * @param $email
     *
     * @return bool
     */
    public static function is_email_registered($email) : bool
    {
        $subscriber = MySalesforcePartnerApi::retrieve_contact($email);
        $subscriber = MySalesforcePartnerApi::retrieve_contact($email);

        return $subscriber ? true : false;
    }


    /**
     * todo: all nullify thingy
     * assumes that all fields are correct (e.g. correct email format)
     * can use email or phone as identifier
     * @param  array $fieldsArray
     * @param  array $extraFilterArray -independent additional filters for retrieving contact
     *
     * @return bool
     */
    public static function create_contact($fieldsArray, $extraFilterArray = [])
    {
        $connection = self::get_my_singleton_connection();
        //get defaults
        $extraFilterArray = array_merge(
            SalesforceDefaultContactField::get_fields_for_filter(),
            $extraFilterArray
        );
        $fieldsArray = array_merge(
            SalesforceDefaultContactField::get_fields_to_send(),
            $fieldsArray,
            $extraFilterArray
        );
        $response = null;

        $existingContact = self::retrieve_contact($fieldsArray, $extraFilterArray);
        // Contact not found. Create a new Contact and set the details
        if ($existingContact) {
            return true;
        } else {
            $contact = new SObject();
            $contact->setType('Contact');
            foreach ($fieldsArray as $fieldName => $fieldValue) {
                $contact->$fieldName = $fieldValue;
            }
            $response = $connection->create([$contact]);
        }
        if(self::$debug) {
            $connection->debug($response);
        }
        $success = SalesforceContactLog::create_contact_log(
            'Created',
            $fieldsArray,
            $extraFilterArray,
            $response
        $success = SalesforceContactLog::create_contact_log(
        );

        return $success;

    }

    /**
     * todo: all nullify thingy
     * assumes that all fields are correct (e.g. correct email format)
     * can use email or phone as identifier
     * @param  array $fieldsArray
     * @param  array $extraFilterArray -independent additional filters for retrieving contact
     *
     * @return SForce\Wsdl\SaveResult|null
     */
    public static function update_contact($fieldsArray, $extraFilterArray = [])
    {
        $connection = self::get_my_singleton_connection();
        $response = null;


        //add defaults
        $extraFilterArray = array_merge(
            SalesforceDefaultContactField::get_fields_for_filter(),
            $extraFilterArray
        );
        $fieldsArray = array_merge(
            SalesforceDefaultContactField::get_fields_to_send(),
            $fieldsArray,
            $extraFilterArray
        );

        //find existing contact
        $existingContact = MySalesforcePartnerApi::array2sql($fieldsArray, $extraFilterArray);
        // Contact found. Update Contact with details
        if ($existingContact) {
            $contact = new SObject();
            $contact->setType('Contact');
            $contact->setId($existingContact->getId());
            foreach ($fieldsArray as $fieldName => $fieldValue) {
                if ($existingContact->$fieldName != $fieldValue) {
                    $contact->$fieldName = $fieldValue;
                }
            }
            $response = $connection->update([$contact]);
        } else {
            return null;
        }
        if(self::$debug) {
            $connection->debug($response);
        }
        $success = SalesforceContactLog::create_contact_log(
            'Updated',
            $fieldsArray,
            $extraFilterArray,
            $response
        $success = SalesforceContactLog::create_contact_log(
        );

        return $success;

    }

    /**
     * Retrive a contact by email address or by phone number
     * either the email (preferred) of phone needs to be set in the $fieldsArray
     *
     * @param array $fieldsArray
     * @param array $extraFilterArray additional filter key-value sets
     *
     * @return SForce\SObject|null
     */
    public static function retrieve_contact($fieldsArray, $extraFilterArray = [])
    {
        $connection = self::get_my_singleton_connection();
        // Check for existing Contact
        $existingContact = null;
        $filterArray = [];
        $finalFilterArray = [];
        $result = null;

        $email = isset($fieldsArray['Email']) ? trim($fieldsArray['Email']) : null;
        if ($email) {
            $filterArray['Email'] = $email;
        } else {
            $phone = isset($fieldsArray['Phone']) ? trim($fieldsArray['Phone']) : null;
            if ($phone) {
                $filterArray['Phone'] = $phone;
            }
        }
        if(count($filterArray)) {
            $finalFilterArray[] = MySalesforcePartnerApi::array2sql($filterArray);
            if(count($extraFilterArray)) {
                $finalFilterArray[] = MySalesforcePartnerApi::array2sql($extraFilterArray);
            }
            $where = ' ( '.implode(' ) AND ( ', $finalFilterArray).' ) ';
            $query = 'SELECT Id, FirstName, LastName, Phone, Email FROM Contact WHERE '.$where.' LIMIT 1';

            $result = $connection->query($query);
            if ($result) {
                $contacts = $result->getRecords();
                if ($contacts) {
                    $existingContact = $contacts[0];
                }
            }
        }
        if(self::$debug) {
            $connection->debug($result);
        }

        return $existingContact;
    }

    public static function retrieve_contact_record_types() : array
    {
        $connection = self::get_my_singleton_connection();
        $returnArray = [];
        $query = '
            SELECT Id, Name, Description, DeveloperName, IsActive, sObjectType
            FROM RecordType
            WHERE IsActive = true AND sObjectType = \'Contact\'';

        $result = $connection->query($query);
        if($result) {
            $records = $result->getRecords();
            if ($records) {
                foreach($records as $record) {
                    $object = $record->getFields();
                    $object->Id = $record->getId();
                    $returnArray[] = $object;
                }
            }
        }
        if(self::$debug) {
            $connection->debug($result);
        }
        return $returnArray;
    }


    /**
     * @param string $email
     */
    public static function assert_email($email)
    {
        if (!filter_var($email, FILTER_VALIDATE_EMAIL)) {
            throw new InvalidArgumentException('Wrong email address format');
        }
    }

    /**
     *
     * @var boolean
     */
    protected static $debug = true;

    /**
     * @param bool
     */
    public static function set_debug($b = true)
    {
        self::$debug = $b;
    }

    protected static $my_singleton_connection = null;

    protected static function get_my_singleton_connection()
    {
        if(self::$my_singleton_connection === null){
            self::$my_singleton_connection = MySalesforcePartnerApiConnectionOnly::singleton();
        }

        return self::$my_singleton_connection;
    }


}

sunnysideup / silverstripe-salesforcepartner

Push — master ( 14ed89...8aec5a )

get_my_singleton_connection() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
