Merge pull request #9 from cakejelly/webhooks-support

Adds support for Webhooks

Author: cakejelly

README.md

@@ -28,7 +28,7 @@ Or install it yourself as:
 ## Usage
 
 ### Resources
-All client methods return  `Resource` objects or a collection of `Resource` objects. Every attribute from a resource can be accessed by calling attribute methods:
+All client methods return `Resource` objects or a collection of `Resource` objects. Every attribute from a resource can be accessed by calling attribute methods:
 
 ```ruby
 conversation = platform.conversations.find("fb2f3a48-523d-4449-a57f-c6651fc6612c")
@@ -46,8 +46,8 @@ conversation.attributes
 # => {"id" => "fb2f3a48-523d-4449-a57f-c6651fc6612c", "url" => "https://api.layer.com/apps/<APP_ID>/conversations/fb2f3a48-523d-4449-a57f-c6651fc6612c", ...}
 ```
 
-### [Platform API](https://developer.layer.com/docs/platform)
-See the official [Platform API docs](https://developer.layer.com/docs/platform) for additional info.
+### [Platform](https://developer.layer.com/docs/platform)
+See the [Platform API docs](https://developer.layer.com/docs/platform) for additional info.
 
 #### Authentication/setup
 
@@ -280,12 +280,76 @@ Make sure the following environment variables are set:
 ```ruby
 # Returns a valid signed identity token. #
 token = platform.generate_identity_token(user_id: "1234", nonce: "your_random_nonce")
-# => #<Layer::IdentityToken:0x007f89b4adb890
+# => #<Layer::IdentityToken:0x007f89b4adb890>
 
 token.to_s
 # => "eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiIsInR.cCI6IkpXVCIsImN0eSI6ImxheWVyLWVpdDt2PTEiLCJraWQiOiJhNz.5YTE0MC02YzY3LTExZTUtYjM0Mi1jZGJmNDAwZTE5NDgifQ"
 ```
 
+### [Webhooks](https://developer.layer.com/docs/webhooks)
+See the [Webhooks API docs](https://developer.layer.com/docs/webhooks) for additional info.
+
+#### Authentication/setup
+
+```ruby
+client = Layer::Webhooks::Client.new(api_token: "your_api_token", app_id: "your_app_id")
+# => #<Layer::Webhooks::Client @api_token="...", @app_id="...">
+```
+If you have `ENV['LAYER_API_TOKEN']` and `ENV['LAYER_APP_ID']` environment variables setup, they will be used by default and don't need to be included:
+```ruby
+client = Layer::Webhooks::Client.new
+# => #<Layer::Webhooks::Client @api_token="...", @app_id="...">
+```
+
+#### Registering Webhooks
+
+```ruby
+client.webhooks.create(
+  version: "1.0",
+  target_url: "https://mydomain.com/my-webhook-endpoint",
+  events: ["conversation.created", "message.sent"],
+  secret: "1697f925ec7b1697f925ec7b",
+  config: {:key1=>"value1", :key2=>"value2"}
+)
+# => #<Layer::Resources::Webhook @attributes={...}>
+```
+
+#### Listing Webhooks
+
+```ruby
+client.webhooks.list
+# => [#<Layer::Resources::Webhook>, #<Layer::Resources::Webhook>, ...]
+```
+
+#### Retrieving Webhooks
+
+```ruby
+client.webhooks.find("webhook_id")
+# => #<Layer::Resources::Webhook @attributes={...}>
+```
+
+#### Activating Webhooks
+
+```ruby
+webhook = client.webhooks.find("webhook_id")
+webhook.activate
+```
+
+#### Deactivating Webhooks
+
+```ruby
+webhook = client.webhooks.find("webhook_id")
+webhook.deactivate
+```
+
+#### Deleting Webhooks
+
+```ruby
+webhook = client.webhooks.find("webhook_id")
+webhook.destroy
+```
+
+
 ## Development ##
 
 After checking out the repo, run `bin/setup` to install dependencies. Then, run `rake rspec` to run the tests. You can also run `bin/console` for an interactive prompt that will allow you to experiment.

lib/layer/api.rb

@@ -8,15 +8,20 @@
 require "layer/resource"
 require "layer/resource_proxy"
 require "layer/identity_token"
+require "layer/base_client"
 
 # Platform
 require "layer/platform/client"
 
+# Webhooks
+require "layer/webhooks/client"
+
 # Resources
 require "layer/resources/conversation"
 require "layer/resources/message"
 require "layer/resources/announcement"
 require "layer/resources/user"
 require "layer/resources/block"
+require "layer/resources/webhook"
 
 require "layer/middleware/api_errors"

lib/layer/base_client.rb

@@ -0,0 +1,24 @@
+module Layer
+  class BaseClient
+    DEFAULT_HOST = "https://api.layer.com"
+
+    def client
+      @http_client ||= Layer::HttpClient.new(base_url, default_headers)
+    end
+
+    def strip_layer_prefix(string)
+      string.split("/").last if string
+    end
+
+    def default_headers
+      {
+        'Accept' => 'application/vnd.layer+json; version=1.0',
+        'Content-Type' => 'application/json'
+      }
+    end
+
+    def base_url
+      DEFAULT_HOST
+    end
+  end
+end

lib/layer/http_client.rb

@@ -2,18 +2,16 @@
 
 module Layer
   class HttpClient
-    DEFAULT_HOST = "https://api.layer.com"
+    attr_reader :base_url, :default_headers
 
-    attr_reader :app_id, :api_token
-
-    def initialize(app_id, api_token)
-      @app_id = app_id
-      @api_token = api_token
+    def initialize(base_url, default_headers)
+      @base_url = base_url
+      @default_headers = default_headers
     end
 
     def connection
       @connection ||= Faraday.new(url: base_url) do |faraday|
-        faraday.headers = default_layer_headers
+        faraday.headers = default_headers
         faraday.request  :url_encoded
         faraday.adapter  Faraday.default_adapter
         faraday.use Middleware::ApiErrors
@@ -53,20 +51,8 @@ def run_request(method, url, options = {})
       )
     end
 
-    def default_layer_headers
-      {
-        'Accept' => 'application/vnd.layer+json; version=1.0',
-        'Authorization' => "Bearer #{api_token}",
-        'Content-Type' => 'application/json'
-      }
-    end
-
     def layer_patch_header
       { 'Content-Type' => 'application/vnd.layer-patch+json' }
     end
-
-    def base_url
-      "#{DEFAULT_HOST}/apps/#{app_id}"
-    end
   end
 end

lib/layer/platform/client.rb

@@ -1,6 +1,6 @@
 module Layer
   module Platform
-    class Client
+    class Client < Layer::BaseClient
       attr_accessor :api_token, :app_id
 
       def initialize(options = {})
@@ -9,14 +9,6 @@ def initialize(options = {})
         @app_id = strip_layer_prefix(id)
       end
 
-      def client
-        @http_client ||= Layer::HttpClient.new(@app_id, @api_token)
-      end
-
-      def strip_layer_prefix(string)
-        string.split("/").last if string
-      end
-
       def announcements
         Layer::ResourceProxy.new(client, nil, Layer::Resources::Announcement)
       end
@@ -33,6 +25,14 @@ def generate_identity_token(options = {})
         Layer::IdentityToken.new(options)
       end
 
+      def default_headers
+        super.merge({"Authorization" => "Bearer #{api_token}"})
+      end
+
+      def base_url
+        "#{DEFAULT_HOST}/apps/#{app_id}"
+      end
+
       def inspect
         "#<#{self.class} api_token=\"#{@api_token}\" app_id=\"#{@app_id}\">"
       end

lib/layer/resources/webhook.rb

@@ -0,0 +1,13 @@
+module Layer
+  module Resources
+    class Webhook < Layer::Resource
+      def activate
+        client.post("#{url}/activate")
+      end
+
+      def deactivate
+        client.post("#{url}/deactivate")
+      end
+    end
+  end
+end

lib/layer/webhooks/client.rb

@@ -0,0 +1,36 @@
+module Layer
+  module Webhooks
+    class Client < Layer::BaseClient
+      attr_accessor :api_token, :app_id
+
+      def initialize(options = {})
+        id = options[:app_id] || ENV['LAYER_APP_ID']
+        @api_token = options[:api_token] || ENV['LAYER_API_TOKEN']
+        @app_id = strip_layer_prefix(id)
+      end
+
+      def webhooks
+        Layer::ResourceProxy.new(client, nil, Layer::Resources::Webhook)
+      end
+
+      def default_headers
+        super.merge(
+          {
+            "Authorization" => "Bearer #{api_token}",
+            "Accept" => "application/vnd.layer.webhooks+json; version=1.0"
+          }
+        )
+      end
+
+      def base_url
+        "#{DEFAULT_HOST}/apps/#{app_id}"
+      end
+
+      def inspect
+        "#<#{self.class} api_token=\"#{@api_token}\" app_id=\"#{@app_id}\">"
+      end
+
+      alias_method :to_s, :inspect
+    end
+  end
+end