diff options
Diffstat (limited to 'lib/MessageSystems')
| -rw-r--r-- | lib/MessageSystems/Transmission.php | 173 |
1 files changed, 164 insertions, 9 deletions
diff --git a/lib/MessageSystems/Transmission.php b/lib/MessageSystems/Transmission.php index 3039270..513efac 100644 --- a/lib/MessageSystems/Transmission.php +++ b/lib/MessageSystems/Transmission.php @@ -8,10 +8,8 @@ class Transmission { private $config; private $request; - /** - * - */ - public function __construct() { + + public function __construct($params = null) { $this->config = Configuration::getConfig(); $this->request = new Client(); $this->model = [ @@ -27,10 +25,31 @@ class Transmission { 'html'=>null, 'text'=>null, 'email_rfc822'=>null, - 'headers'=>null + 'headers'=>null, + 'use_draft_template'=>false, + ], + 'options'=>[ + 'open_tracking'=>true, + 'click_tracking'=>true ], 'recipients'=>null ]; + + if(!is_null($params)) { + foreach($params as $key=>$value) { + if(key_exists($key, $this->model)) { + $this->model[$key] = $value; + } else if (key_exists($key, $this->model['content'])) { + $this->model['content'][$key] = $value; + } else if (key_exists($key, $this->model['options'])) { + $this->model['options'][$key] = $value; + } + } + + if (isset($params['recipientList'])) { + $this->useRecipientList($params['recipientList']); + } + } } @@ -38,11 +57,29 @@ class Transmission { return $this->config['protocol'] . '://' . $this->config['host'] . ($this->config['port'] ? ':' . $this->config['port'] : '') . $this->config['baseUrl']; } + + public function send() { + try { + $response = $this->request->post($this->getBaseUrl(), [ + 'json'=>$this->model, + "headers"=>['authorization' => $this->config['key']], + "verify"=>$this->config['strictSSL'] + ]); + + $body = $response->json(); + + if ($response->getStatusCode() !== 200) { + return $body['errors']; + } + return $body; + + } catch (RequestException $exception) { + throw new \Exception('Unable to contact Transmissions API: '. $exception->getMessage()); + } + } + /** * - * @param unknown $config - * @param string $transmissionID - * @param string $callback * @return multitype:multitype:string */ private function fetch ($transmissionID = null) { @@ -55,7 +92,7 @@ class Transmission { //make request try { $response = $this->request->get($url, [ - "headers"=>['authorization' => $this->config['key']] + "headers"=>['authorization' => $this->config['key']], "verify"=>$this->config['strictSSL'] ]); @@ -80,6 +117,124 @@ class Transmission { public function find($transmissionID) { $this->fetch($transmissionID); } + + public function setMetadata ($meta) { + $this->model['metadata'] = $meta; + return $this; + } + + public function setSubstitutiondata ($subs) { + $this->model['substitution_data'] = $subs; + return $this; + } + + public function setCampaign ($campaignID) { + $this->model['campaign_id'] = $campaignID; + return $this; + } + + public function setDescription ($description) { + $this->model['description'] = $description; + return $this; + } + + public function setReturnPath ($returnPath) { + $this->model['return_path'] = $returnPath; + return $this; + } + + public function setReplyTo ($replyTo) { + $this->model['content']['reply_to'] = $replyTo; + return $this; + } + + public function setSubject ($subject) { + $this->model['content']['subject'] = $subject; + return $this; + } + + public function setFrom ($fromField) { + $this->model['content']['from'] = $fromField; + return $this; + } + + public function setHTMLContent ($html) { + $this->model['content']['html'] = $html; + return $this; + } + + public function setTextContent ($plaintext) { + $this->model['content']['text'] = $plaintext; + return $this; + } + + public function setRfc822Content ($rfc) { + $this->model['content']['rfc'] = $rfc; + return $this; + } + + public function setContentHeaders ($headers) { + $this->model['content']['headers'] = $headers; + return $this; + } + + public function addRecipient ($recipient) { + if(!is_array($this->model['recipients'])) { + $this->model['recipients'] = []; + } + $this->model['recipients'].push($recipient); + return $this; + } + + public function addRecipients ($recipients) { + if(!is_array($this->model['recipients'])) { + $this->model['recipients'] = []; + } + $this->model['recipients'] = array_merge($this->model['recipients'], $recipients); + return $this; + } + + public function useRecipientList ($recipientList) { + //reset the recipients field + $this->model['recipients'] = []; + $this->model['recipients']['list_name'] = $recipientList; + return $this; + } + + public function useStoredTemplate ($templateID) { + $this->model['content']['template_id'] = $templateID; + return $this; + } + + public function enableClickTracking () { + $this->model['opitons']['click_tracking'] = true; + return $this; + } + + public function disableClickTracking () { + $this->model['opitons']['click_tracking'] = false; + return $this; + } + + public function enableOpenTracking () { + $this->model['opitons']['open_tracking'] = true; + return $this; + } + + public function disableOpenTracking () { + $this->model['opitons']['open_tracking'] = false; + return $this; + } + + public function useDraftTemplate () { + $this->model['opitons']['use_draft_template'] = true; + return $this; + } + + public function usePublishedTemplate () { + $this->model['opitons']['use_draft_template'] = false; + return $this; + } } ?>
\ No newline at end of file |