subscription_spec.rb in pushpad-1.3.0

- old
+ new

@@ -1,9 +1,19 @@
 require "spec_helper"
 
 module Pushpad
   describe Subscription do
+    def stub_subscription_get(options)
+      stub_request(:get, "https://pushpad.xyz/api/v1/projects/#{options[:project_id]}/subscriptions/#{options[:id]}").
+        to_return(status: 200, body: options[:attributes].to_json)
+    end
+
+    def stub_failing_subscription_get(options)
+      stub_request(:get, "https://pushpad.xyz/api/v1/projects/#{options[:project_id]}/subscriptions/#{options[:id]}").
+        to_return(status: 404)
+    end
+    
     def stub_subscriptions_head(options)
       stub_request(:head, "https://pushpad.xyz/api/v1/projects/#{options[:project_id]}/subscriptions").
         with(query: hash_including(options.fetch(:query, {}))).
         to_return(status: 200,
                   headers: { "X-Total-Count" => options.fetch(:total_count, 10) })
@@ -22,11 +32,68 @@
     
     def stub_failing_subscriptions_get(options)
       stub_request(:get, "https://pushpad.xyz/api/v1/projects/#{options[:project_id]}/subscriptions").
         to_return(status: 403)
     end
+    
+    def stub_subscriptions_post(project_id, attributes = {})
+      stub_request(:post, "https://pushpad.xyz/api/v1/projects/#{project_id}/subscriptions").
+        with(body: hash_including(attributes)).
+        to_return(status: 201, body: attributes.to_json)
+    end
 
+    def stub_failing_subscriptions_post(project_id)
+      stub_request(:post, "https://pushpad.xyz/api/v1/projects/#{project_id}/subscriptions").
+        to_return(status: 403)
+    end
+    
+    def stub_subscription_patch(project_id, id, attributes = {})
+      stub_request(:patch, "https://pushpad.xyz/api/v1/projects/#{project_id}/subscriptions/#{id}").
+        with(body: hash_including(attributes)).
+        to_return(status: 200, body: attributes.to_json)
+    end
+
+    def stub_failing_subscription_patch(project_id, id)
+      stub_request(:patch, "https://pushpad.xyz/api/v1/projects/#{project_id}/subscriptions/#{id}").
+        to_return(status: 422)
+    end
+    
+    def stub_subscription_delete(project_id, id)
+      stub_request(:delete, "https://pushpad.xyz/api/v1/projects/#{project_id}/subscriptions/#{id}").
+        to_return(status: 204)
+    end
+    
+    def stub_failing_subscription_delete(project_id, id)
+      stub_request(:delete, "https://pushpad.xyz/api/v1/projects/#{project_id}/subscriptions/#{id}").
+        to_return(status: 403)
+    end
+    
+    describe ".create" do
+      it "creates a new subscription with the given attributes and returns it" do
+        attributes = {
+          endpoint: "https://example.com/push/f7Q1Eyf7EyfAb1", 
+          p256dh: "BCQVDTlYWdl05lal3lG5SKr3VxTrEWpZErbkxWrzknHrIKFwihDoZpc_2sH6Sh08h-CacUYI-H8gW4jH-uMYZQ4=",
+          auth: "cdKMlhgVeSPzCXZ3V7FtgQ==",
+          uid: "exampleUid", 
+          tags: ["exampleTag1", "exampleTag2"]
+        }
+        stub_subscriptions_post(5, attributes)
+
+        subscription = Subscription.create(attributes, project_id: 5)
+        expect(subscription).to have_attributes(attributes)
+      end
+      
+      it "fails with CreateError if response status code is not 201" do
+        attributes = { endpoint: "https://example.com/push/123" }
+        stub_failing_subscriptions_post(5)
+
+        expect {
+          Subscription.create(attributes, project_id: 5)
+        }.to raise_error(Subscription::CreateError)
+      end
+    end
+
     describe ".count" do
       it "returns value from X-Total-Count header" do
         stub_subscriptions_head(project_id: 5, total_count: 100)
 
         result = Subscription.count(project_id: 5)
@@ -91,10 +158,50 @@
           Subscription.count(project_id: 5)
         }.to raise_error(Subscription::CountError)
       end
     end
     
+    describe ".find" do
+      it "returns subscription with attributes from json response" do
+        attributes = {
+          id: 5,
+          endpoint: "https://example.com/push/f7Q1Eyf7EyfAb1", 
+          p256dh: "BCQVDTlYWdl05lal3lG5SKr3VxTrEWpZErbkxWrzknHrIKFwihDoZpc_2sH6Sh08h-CacUYI-H8gW4jH-uMYZQ4=",
+          auth: "cdKMlhgVeSPzCXZ3V7FtgQ==",
+          uid: "exampleUid", 
+          tags: ["exampleTag1", "exampleTag2"],
+          last_click_at: "2023-11-03T10:30:00.000Z",
+          created_at: "2016-09-06T10:47:05.494Z"
+        }
+        stub_subscription_get(id: 5, project_id: 10, attributes: attributes)
+
+        subscription = Subscription.find(5, project_id: 10)
+
+        attributes.delete(:last_click_at)
+        attributes.delete(:created_at)
+        expect(subscription).to have_attributes(attributes)
+        expect(subscription.last_click_at.utc.to_s).to eq(Time.utc(2023, 11, 3, 10, 30, 0.0).to_s)
+        expect(subscription.created_at.utc.to_s).to eq(Time.utc(2016, 9, 6, 10, 47, 5.494).to_s)
+      end
+
+      it "fails with FindError if response status code is not 200" do
+        stub_failing_subscription_get(id: 5, project_id: 10)
+
+        expect {
+          Subscription.find(5, project_id: 10)
+        }.to raise_error(Subscription::FindError)
+      end
+      
+      it "fails with helpful error message when project_id is missing" do
+        Pushpad.project_id = nil
+
+        expect {
+          Subscription.find 5
+        }.to raise_error(/must set project_id/)
+      end
+    end
+    
     describe ".find_all" do
       it "returns subscriptions of project with attributes from json response" do
         attributes = {
           id: 1169,
           endpoint: "https://example.com/push/f7Q1Eyf7EyfAb1", 
@@ -192,9 +299,73 @@
         stub_subscriptions_get(project_id: 5, list: [])
 
         subscriptions = Subscription.find_all(project_id: 5)
 
         expect(subscriptions).to eq([])
+      end
+    end
+    
+    describe "#update" do
+      it "updates a subscription with the given attributes and returns it" do
+        attributes = {
+          uid: "exampleUid", 
+          tags: ["exampleTag1", "exampleTag2"]
+        }
+        stub_subscription_patch(5, 123, attributes)
+
+        subscription = Subscription.new(id: 123)
+        subscription.update attributes, project_id: 5
+        expect(subscription).to have_attributes(attributes)
+      end
+      
+      it "fails with UpdateError if response status code is not 200" do
+        attributes = { uid: "exampleUid" }
+        stub_failing_subscription_patch(5, 123)
+
+        subscription = Subscription.new(id: 123)
+        
+        expect {
+          subscription.update attributes, project_id: 5
+        }.to raise_error(Subscription::UpdateError)
+      end
+      
+      it "fails with helpful error message when project_id is missing" do
+        Pushpad.project_id = nil
+
+        expect {
+          Subscription.new(id: 123).update({})
+        }.to raise_error(/must set project_id/)
+      end
+      
+      it "fails with helpful error message when id is missing" do
+        Pushpad.project_id = 5
+        
+        expect {
+          Subscription.new(id: nil).update({})
+        }.to raise_error(/must set id/)
+      end
+    end
+    
+    describe "#delete" do
+      it "deletes a subscription" do
+        Pushpad.project_id = 5
+        stub_subscription_delete(5, 123)
+        
+        subscription = Subscription.new(id: 123)
+        
+        res = subscription.delete
+        expect(res).to be_nil
+      end
+      
+      it "fails with DeleteError if response status code is not 204" do
+        Pushpad.project_id = 5
+        stub_failing_subscription_delete(5, 123)
+        
+        subscription = Subscription.new(id: 123)
+        
+        expect {
+          subscription.delete
+        }.to raise_error(Subscription::DeleteError)
       end
     end
     
   end
 end