Merge pull request #7 from knocklabs/jazambuja-kno-3536-php-sdk-add-schedules-support

feat(kno-3536): add support for schedules API

Author: juanazam

src/Api/Objects.php

@@ -38,6 +38,21 @@ public function getMessages(string $collection, string $objectId, array $params
         return $this->getRequest($url, $params, $headers);
     }
 
+    /**
+     * @param string $collection
+     * @param string $objectId
+     * @param array $params
+     * @param array $headers
+     * @return array
+     * @throws Exception
+     */
+    public function getSchedules(string $collection, string $objectId, array $params = [], array $headers = []): array
+    {
+        $url = $this->url('/objects/%s/%s/schedules', $collection, $objectId);
+
+        return $this->getRequest($url, $params, $headers);
+    }
+
     /**
      * @param string $collection
      * @param string $objectId

src/Api/Users.php

@@ -51,6 +51,20 @@ public function getMessages(string $userId, array $params = [], array $headers =
         return $this->getRequest($url, $params, $headers);
     }
 
+    /**
+     * @param string $userId
+     * @param array $params
+     * @param array $headers
+     * @return array
+     * @throws Exception
+     */
+    public function getSchedules(string $userId, array $params = [], array $headers = []): array
+    {
+        $url = $this->url('/users/%s/schedules', $userId);
+
+        return $this->getRequest($url, $params, $headers);
+    }
+
     /**
      * @param string $userId
      * @param array $body

src/Api/Workflows.php

@@ -33,4 +33,63 @@ public function cancel(string $key, array $body, array $headers = [])
 
         return $this->postRequest($url, $body, $headers);
     }
+
+    /**
+     * @param string $key
+     * @param array $schedule_attrs
+     * @param array $headers
+     * @return array
+     * @throws Exception
+     */
+    public function createSchedules(string $key, array $schedule_attrs, array $headers = []): array
+    {
+        $url = $this->url('/schedules');
+        $schedule_attrs['workflow'] = $key;
+
+        return $this->postRequest($url, $schedule_attrs, $headers);
+    }
+
+    /**
+     * @param array $schedule_ids
+     * @param array $schedule_attrs
+     * @param array $headers
+     * @return array
+     * @throws Exception
+     */
+    public function updateSchedules(array $schedule_ids, array $schedule_attrs, array $headers = []): array
+    {
+        $url = $this->url('/schedules');
+        $schedule_attrs['schedule_ids'] = $schedule_ids;
+
+        return $this->putRequest($url, $schedule_attrs, $headers);
+    }
+
+    /**
+     * @param array $schedule_ids
+     * @param array $headers
+     * @return array
+     * @throws Exception
+     */
+    public function deleteSchedules(array $schedule_ids, array $headers = []): array
+    {
+        $url = $this->url('/schedules');
+        $body = ['schedule_ids' => $schedule_ids];
+
+        return $this->deleteRequest($url, $body, $headers);
+    }
+
+    /**
+     * @param string $key
+     * @param array $params
+     * @param array $headers
+     * @return array
+     * @throws Exception
+     */
+    public function listSchedules(string $key, array $params = [], array $headers = []): array
+    {
+        $params['workflow'] = $key;
+        $url = $this->url('/schedules');
+
+        return $this->getRequest($url, $params, $headers);
+    }
 }