feat: Add BillableObjects resource (#22)

Author: jaredhoyt

lib/kickplan/adapters/http.rb

@@ -43,6 +43,10 @@ def update_account(key, params)
         put("accounts/#{key}", params.to_h).body
       end
 
+      def upsert_billable_object(params)
+        post("billable_objects", params.to_h).body
+      end
+
       # @api private
       def connection
         memoize do

lib/kickplan/adapters/memory.rb

@@ -71,6 +71,10 @@ def update_account(key, params)
         end
       end
 
+      def upsert_billable_object(params)
+        true
+      end
+
       # @api private
       def accounts
         memoize { Concurrent::Map.new }

lib/kickplan/request.rb

@@ -12,6 +12,7 @@ class Request < Dry::Struct
 
   require_relative "requests/accounts/create"
   require_relative "requests/accounts/update"
+  require_relative "requests/billable_objects/upsert"
   require_relative "requests/features/resolve"
   require_relative "requests/metrics/set"
 

lib/kickplan/requests/billable_objects/upsert.rb

@@ -0,0 +1,14 @@
+# frozen_string_literal: true
+
+module Kickplan
+  module Requests
+    module BillableObjects
+      class Upsert < Request
+        attribute :external_id, Types::String
+        attribute :external_type, Types::String
+        attribute :account_key, Types::String
+        attribute? :properties, Types::Hash
+      end
+    end
+  end
+end

lib/kickplan/resource.rb

@@ -23,6 +23,7 @@ def inspect
   end
 
   require_relative "resources/accounts"
+  require_relative "resources/billable_objects"
   require_relative "resources/features"
   require_relative "resources/metrics"
 end

lib/kickplan/resources/billable_objects.rb

@@ -0,0 +1,14 @@
+# frozen_string_literal: true
+
+module Kickplan
+  module Resources
+    class BillableObjects < Resource
+      def upsert(options = {})
+        params = Requests::BillableObjects::Upsert.new(options)
+        response = adapter.upsert_billable_object(params)
+
+        Schemas::BillableObject.wrap(response)
+      end
+    end
+  end
+end

lib/kickplan/schema.rb

@@ -21,5 +21,6 @@ def self.wrap(attributes = {})
   end
 
   require_relative "schemas/account"
+  require_relative "schemas/billable_object"
   require_relative "schemas/resolution"
 end

lib/kickplan/schemas/billable_object.rb

@@ -0,0 +1,12 @@
+# frozen_string_literal: true
+
+module Kickplan
+  module Schemas
+    class BillableObject < Schema
+      attribute :external_id, Types::String
+      attribute :external_type, Types::String
+      attribute :account_key, Types::String
+      attribute :properties, Types::Hash
+    end
+  end
+end

spec/cassettes/billable_objects/upsert.yml

@@ -11,6 +11,7 @@
 
   # Test the adapter through the resource interface
   let(:accounts) { client::Accounts }
+  let(:billable_objects) { client::BillableObjects }
   let(:metrics) { client::Metrics }
   let(:features) { client::Features }
 
@@ -207,4 +208,34 @@
       expect(response.name).to eq "Acme Inc."
     end
   end
+
+  describe "#upsert_billable_object",
+    vcr: { cassette_name: "billable_objects/upsert" } do
+    let(:params) {{
+      external_id: "1234",
+      external_type: "license",
+      account_key: "acme",
+      properties: {
+        active: true
+      }
+    }}
+
+    it "creates a POST request for 'billable_objects'" do
+      expect(adapter.connection).to receive(:post).
+        with("billable_objects", hash_including(params)).
+        and_call_original
+
+      billable_objects.upsert(params)
+    end
+
+    it "returns Kickplan::Schemas::BillableObject", :aggregate_failures do
+      response = billable_objects.upsert(params)
+
+      expect(response).to be_a Kickplan::Schemas::BillableObject
+      expect(response.external_id).to eq "1234"
+      expect(response.external_type).to eq "license"
+      expect(response.account_key).to eq "acme"
+      expect(response.properties).to eq params[:properties].transform_keys(&:to_s)
+    end
+  end
 end