Cursor.coffee

EventEmitter = (require 'events').EventEmitter
ListNode = (require '../list/ListNode.coffee').ListNode
ExodusError = (require '../errors/ExodusError.coffee').ExodusError

class Cursor extends EventEmitter

  store: undefined

  txn: undefined

  node: undefined

  begin: undefined

  end: undefined

  isClosed: undefined

  @create$Store$TransactionDescriptor: (store, txn, o) ->
    if !o? then o = new Cursor()
    o.store = store
    o.txn = txn
    o.node = ListNode.create$Log store.getList().log
    o.node.next = store.getList().rootNode.next
    o.node.nextAddr = store.getList().rootNode.nextAddr
    o.begin = true
    o.end = false
    o.isClosed = false
    return o

  getNext$emit: () ->
    oldnode = @node
    @node = @node.next
    if @node?
      @node.once 'getNode', (ok, newnode) =>
        if ok? && !newnode.isEmpty()
          @begin = false
          @node = newnode
          @node.prev = oldnode
          @emit 'getNext', true
        else
          @end = true
          @node = oldnode
          @emit 'getNext', false
      @node.getNode()
    else
      @end = true
      @emit 'getNext', @node?

  getLast$emit: () ->
    @begin = false
    @end = true
    if @node.next?
      @once 'getNext', (success) =>
        if success
          @getLast$emit()
        else
          @emit 'getLast', true
      @getNext$emit()
    else
      @emit 'getLast', true

  getPrev: () ->
    if @node.prev? && !@node.prev.keyAddr.equals$Addr64 @node.nullAddr
      @node = @node.prev
      @end = false
      return true
    else
      @begin = true
      return false

  getKey: () ->
    return @node.key

  getValue: () ->
    return @node.value

  count: () ->
    return @store.count()

  close: () ->
    if @isClosed
      throw new ExodusError "Cursor is already closed"
    @isClosed = true

  deleteCurrent: () ->
    if @begin
      return false
    else
      @node = @store.getList().deleteNode$ListNode @node
      return true

exports.Cursor = Cursor