vendor/bjsmasth/php-salesforce-rest-api/src/CRUD.php line 22

Open in your IDE?
  1. <?php
  3. namespace bjsmasth\Salesforce;
  5. use GuzzleHttp\Client;
  7. class CRUD
  8. {
  9.     protected $instance_url;
  10.     protected $access_token;
  12.     public function __construct()
  13.     {
  14.         if (!isset($_SESSION) and !isset($_SESSION['salesforce'])) {
  15.             throw new \Exception('Access Denied', 403);
  16.         }
  18.         $this->instance_url = $_SESSION['salesforce']['instance_url'];
  19.         $this->access_token = $_SESSION['salesforce']['access_token'];
  20.     }
  22.     public function query($query)
  23.     {
  24.         $url = "$this->instance_url/services/data/v39.0/query";
  26.         $client = new Client();
  27.         $request = $client->request('GET', $url, [
  28.             'headers' => [
  29.                 'Authorization' => "OAuth $this->access_token"
  30.             ],
  31.             'query' => [
  32.                 'q' => $query
  33.             ]
  34.         ]);
  36.         return json_decode($request->getBody(), true);
  37.     }
  39.     public function create($object, array $data)
  40.     {
  41.         $url = "$this->instance_url/services/data/v39.0/sobjects/$object/";
  43.         $client = new Client();
  45.         $request = $client->request('POST', $url, [
  46.             'headers' => [
  47.                 'Authorization' => "OAuth $this->access_token",
  48.                 'Content-type' => 'application/json'
  49.             ],
  50.             'json' => $data
  51.         ]);
  53.         $status = $request->getStatusCode();
  55.         if ($status != 201) {
  56.             die("Error: call to URL $url failed with status $status, response: " . $request->getReasonPhrase());
  57.         }
  59.         $response = json_decode($request->getBody(), true);
  60.         $id = $response["id"];
  62.         return $id;
  64.     }
  66.     public function update($object, $id, array $data)
  67.     {
  68.         $url = "$this->instance_url/services/data/v39.0/sobjects/$object/$id";
  70.         $client = new Client();
  72.         $request = $client->request('PATCH', $url, [
  73.             'headers' => [
  74.                 'Authorization' => "OAuth $this->access_token",
  75.                 'Content-type' => 'application/json'
  76.             ],
  77.             'json' => $data
  78.         ]);
  80.         $status = $request->getStatusCode();
  82.         if ($status != 204) {
  83.             die("Error: call to URL $url failed with status $status, response: " . $request->getReasonPhrase());
  84.         }
  86.         return $status;
  87.     }
  89.     public function delete($object, $id)
  90.     {
  91.         $url = "$this->instance_url/services/data/v39.0/sobjects/$object/$id";
  93.         $client = new Client();
  94.         $request = $client->request('DELETE', $url, [
  95.             'headers' => [
  96.                 'Authorization' => "OAuth $this->access_token",
  97.             ]
  98.         ]);
  100.         $status = $request->getStatusCode();
  102.         if ($status != 204) {
  103.             die("Error: call to URL $url failed with status $status, response: " . $request->getReasonPhrase());
  104.         }
  106.         return true;
  107.     }
  108. }