WIP - start adding refund, commit and void to transactions

Author: devton

lib/blnk/resourceable.rb

@@ -18,13 +18,7 @@ class << self
 
       attr_accessor :resource_name, :id_field, :create_contract, :search_contract
 
-      def find(id)
-        check_vars
-        res = get_request(path: "/#{resource_name}/#{id}")
-        return Success(new(res.parse)) if res.status.success?
-
-        Failure(res.parse)
-      end
+      def find(id) = with_req resp: get_request(path: "/#{resource_name}/#{id}")
 
       def all
         check_vars
@@ -76,9 +70,30 @@ def create_contract_new
       end
 
       def search_contract_new = (search_contract || DefaultSearchContract).new
+
+      def handler(parsed, status) = (status.success? ? Success(new(parsed)) : Failure(parsed))
+      def with_req(resp:, self_caller: nil) = using_resp(resp:, self_caller:, &method(:handler))
+
+      def using_resp(resp:, self_caller: nil, &block)
+        check_vars
+        parsed = resp.parse.transform_keys(&:to_sym)
+        self_caller&.reload
+
+        block.call(parsed, resp.status)
+      end
+    end
+
+    def reload
+      self.class.find(_id) do |res|
+        next unless res.status.success?
+
+        res.parse.each_pair do |k, v|
+          self[k] = v
+        end
+        self
+      end
     end
 
-    def reload = self.class.find(_id)
     # table[self.class.id_field]
     def persisted? = !_id.nil?
     def _id = public_send(self.class.id_field)

lib/blnk/transaction.rb

@@ -15,11 +15,23 @@ class CreateContract < Dry::Validation::Contract
         required(:allow_overdraft).value(:bool)
         optional(:inflight).value(:bool)
         optional(:rate).value(:integer)
+        optional(:scheduled_for).value(:string)
       end
     end
 
     self.resource_name = :transactions
     self.id_field = :transaction_id
     self.create_contract = CreateContract
+
+    def refund = self.class.with_req(req: request_refund, self_caller: self)
+    def void = raise NotImplementedError
+    def commit = raise NotImplementedError
+
+    private
+
+    def inflight_path = "/transactions/inflight/#{_id}"
+    def refund_path = "/refund-transactions/#{_id}"
+    def request_update_inflight(body:, path: inflight_path) = self.class.put_request(path:, body:)
+    def request_refund(path: refund_path) = self.class.post_request(path:, body: nil)
   end
 end