zenapply / php-peoplematter

src/PeopleMatter.php

<?php

namespace Zenapply\PeopleMatter;

use DateTime;
use Exception;
use GuzzleHttp\Client;
use Zenapply\PeopleMatter\Exceptions\PeopleMatterException;
use Zenapply\PeopleMatter\Models\BusinessUnit;
use Zenapply\PeopleMatter\Models\Job;
use Zenapply\PeopleMatter\Models\Person;
use Zenapply\PeopleMatter\Models\Employee;

class PeopleMatter
{
    protected $alias;
    protected $authenticated = false;
    protected $client;
    protected $host;
    protected $password;
    protected $username;

    /**
     * Creates a PeopleMatter instance that can register and unregister webhooks with the API
     * @param string      $username The Username
     * @param string      $password The Password
     * @param string      $alias    The business alias
     * @param string      $host     The host to connect to
     * @param Client|null $client   The Guzzle client (used for testing)
     */
    public function __construct($username, $password, $alias, $host = "api.peoplematter.com", Client $client = null)
    {
        $this->alias = $alias;
        $this->client = $client;
        $this->host = $host;
        $this->password = $password;
        $this->username = $username;
    }

    public function hire(Person $person, Job $job, BusinessUnit $businessUnit, $timeStatus, DateTime $hired_at = null)
    {
        $this->login();

        if ($hired_at === null) {
            $hired_at = new DateTime("now");
        }

        if (!in_array($timeStatus, ["FullTime", "PartTime"])) {
            throw new Exception("{$timeStatus} is invalid! Please use FullTime or PartTime");
        }

        $url = "https://{$this->host}/api/services/platform/hireemployee";

        return $this->request("POST", $url, [
            "json" => [
                "HireDate" => $hired_at->format("m/d/Y"),
                "Business" => [
                    "Alias" => $this->alias,
                ],
                "BusinessUnit" => [
                    "UnitNumber" => $businessUnit->UnitNumber
                ],
                "Person" => $person->toArray(),
                "JobPositions" => [
                    [
                        "Business" => [
                            "Alias" => $this->alias,
                        ],
                        "BusinessUnit" => [
                            "UnitNumber" => $businessUnit->UnitNumber
                        ],
                        "Job" => [
                            "Code" => $job->Code,
                        ],
                        "TimeStatus" => $timeStatus,
                        "Person" => $person->toArray(),
                    ]
                ]
            ]
        ]);
    }

    /**
     * @return string
     */
    protected function buildUrl($resource)
    {
        return "https://{$this->host}/api/{$resource}";
    }

    public function getBusinessUnits()

This method seems to be duplicated in your project.

    {
        $this->login();
        $response = $this->request("GET", $this->buildUrl("businessunit"), [
            "query" => [
                "businessalias" => $this->alias,
            ]
        ]);

        $units = [];
        foreach ($response["Records"] as $unit) {
            $units[] = new BusinessUnit($unit);
        }

        return $units;
    }

    public function getJobs()

This method seems to be duplicated in your project.

    {
        $this->login();
        $response = $this->request("GET", $this->buildUrl("job"), [
            "query" => [
                "businessalias" => $this->alias,
            ]
        ]);

        $jobs = [];
        foreach ($response["Jobs"] as $unit) {
            $jobs[] = new Job($unit);
        }

        return $jobs;
    }

    public function getEmployee($email)
    {
        if (empty($email)) {
            throw new Exception("Email is invalid!");
        }
        $this->login();
        $employees = [];
        $response = $this->request("GET", $this->buildUrl("businessunitemployee"), [
            "query" => [
                "businessalias" => $this->alias,
                "PersonEmailAddress" => $email,
            ]
        ]);

        foreach ($response["Records"] as $unit) {
            $employees[] = new Employee($unit);
        }

        return count($employees) > 0 ? $employees[0] : null;
    }


    protected function login()
    {
        if ($this->authenticated !== true) {
            $url = "https://{$this->host}/api/account/login";
            $this->request("POST", $url, [
                "form_params" => [
                    "email" => $this->username,
                    "password" => $this->password,
                ]
            ]);
            $this->authenticated = true;
        }

        return $this->authenticated;
    }

    /**
     * Returns the Client instance
     * @return Client
     */
    public function getClient()
    {
        if (!$this->client instanceof Client) {
            $this->client = new Client([
                "cookies" => true
            ]);
        }
        return $this->client;
    }
    
    /**
     * Executes a request to the PeopleMatter API
     * @param  string $method  The request type
     * @param  string $url     The url to request
     * @param  array  $options An array of options for the request
     * @return array           The response as an array
     */
    protected function request($method, $url, $options = [])
    {
        $client = $this->getClient();
        try {
            $response = $client->request($method, $url, $options);
        } catch (\GuzzleHttp\Exception\ClientException $e) {
            $response = $e->getResponse();
            throw new PeopleMatterException($response->getStatusCode().": ".$response->getReasonPhrase(), 1);
        }

        $body = $response->getBody();
        if (!is_array($body)) {
            $json = json_decode($body, true);
        } else {
            $json = $body;
        }

        if (!empty($json["ErrorMessage"])) {
            throw new PeopleMatterException($json["ErrorMessage"], $json["ErrorCode"]);
        }

        return $json;
    }
}