neo4jrb/neo4j-core

require 'neo4j/transaction'

module Neo4j
  module Core
    class CypherSession
      module Transactions
        class Base < Neo4j::Transaction::Base
          def query(*args)
            options = if args[0].is_a?(::Neo4j::Core::Query)
                        args[1] ||= {}
                      else
                        args[1] ||= {}
                        args[2] ||= {}
                      end
            options[:transaction] ||= self

            adaptor.query(@session, *args)
          end

          def queries(options = {}, &block)
            adaptor.queries(@session, {transaction: self}.merge(options), &block)
          end

          def after_commit_registry
            @after_commit_registry ||= []
          end

          def after_commit(&block)
            after_commit_registry << block
          end

          def post_close!
            super
            after_commit_registry.each(&:call) unless failed?
          end

          private

          # Because we're inheriting from the old Transaction class
          # but the new adaptors work much like the old sessions
          def adaptor
            @session.adaptor
          end
        end
      end
    end
  end
end