Merge pull request #109 from nurazem/add_subscriptions

Add support for Subscriptions

Author: josler

lib/intercom.rb

@@ -10,6 +10,7 @@
 require "intercom/admin"
 require "intercom/count"
 require "intercom/request"
+require "intercom/subscription"
 require "intercom/notification"
 require "intercom/utils"
 require "intercom/errors"

lib/intercom/collection_proxy.rb

@@ -47,7 +47,11 @@ def resource_class; @resource_class; end
 
     def deserialize_response_hash(response_hash, block)
       top_level_type = response_hash.delete('type')
-      top_level_entity_key = Utils.entity_key_from_type(top_level_type)
+      if resource_name == 'subscriptions'
+        top_level_entity_key = 'items'
+      else
+        top_level_entity_key = Utils.entity_key_from_type(top_level_type)
+      end
       response_hash[top_level_entity_key].each do |object_json|
         block.call Lib::TypedJsonDeserializer.new(object_json).deserialize
       end

lib/intercom/subscription.rb

@@ -0,0 +1,15 @@
+require 'intercom/api_operations/list'
+require 'intercom/api_operations/find_all'
+require 'intercom/api_operations/save'
+require 'intercom/api_operations/delete'
+require 'intercom/traits/api_resource'
+
+module Intercom
+  class Subscription
+    include ApiOperations::List
+    include ApiOperations::Find
+    include ApiOperations::Save
+    include ApiOperations::Delete
+    include Traits::ApiResource
+  end
+end

spec/spec_helper.rb

@@ -262,6 +262,33 @@ def test_conversation_notification
   }
 end
 
+def test_subscription
+  {"request"=>
+       {"type"=>"notification_subscription",
+        "id"=>"nsub_123456789",
+        "created_at"=>1410368642,
+        "updated_at"=>1410368642,
+        "service_type"=>"web",
+        "app_id"=>"3qmk5gyg",
+        "url"=>
+            "http://example.com",
+        "self"=>
+            "https://api.intercom.io/subscriptions/nsub_123456789",
+        "topics"=>["user.created", "conversation.user.replied", "conversation.admin.replied"],
+        "active"=>true,
+        "metadata"=>{},
+        "hub_secret"=>nil,
+        "mode"=>"point",
+        "links"=>
+            {"sent"=>
+                 "https://api.intercom.io/subscriptions/nsub_123456789/sent",
+             "retry"=>
+                 "https://api.intercom.io/subscriptions/nsub_123456789/retry",
+             "errors"=>
+                 "https://api.intercom.io/subscriptions/nsub_123456789/errors"},
+        "notes"=>[]}}
+end
+
 def error_on_modify_frozen
   RUBY_VERSION =~ /1.8/ ? TypeError : RuntimeError
 end

spec/unit/intercom/subscription_spec.rb

@@ -0,0 +1,18 @@
+require 'spec_helper'
+
+describe "Intercom::Subscription" do
+  it "gets a subscription" do
+    Intercom.expects(:get).with("/subscriptions/nsub_123456789", {}).returns(test_subscription)
+    subscription = Intercom::Subscription.find(:id => "nsub_123456789")
+    subscription.request.topics[0].must_equal "user.created"
+    subscription.request.topics[1].must_equal "conversation.user.replied"
+  end
+
+  it "creates a subscription" do
+    Intercom.expects(:post).with("/subscriptions", {'url' => "http://example.com", 'topics' => ["user.created"]}).returns(test_subscription)
+    subscription = Intercom::Subscription.create(:url => "http://example.com", :topics => ["user.created"])
+    subscription.request.topics[0].must_equal "user.created"
+    subscription.request.url.must_equal "http://example.com"
+  end
+
+end