tempus db transaction consumer

transaction-ex.coffee

  deleteOne: (key, callback)->
    {time_entry} = TimeEntriesController
    deleteProjectTimeEntries = time_entry.delete().where(time_entry.projectId.equals(key))
    deleteProject = @project.delete().where(@project.id.equals(key))
    deleteUsersProjectsRows = @usersprojects.delete().where(@usersprojects.projectId.equals key)
    t = @transaction()
    start = ->
      async.eachSeries [deleteProjectTimeEntries, deleteUsersProjectsRows, deleteProject],
        (s, cb)->
          t.query s, (err)->
            cb(err)
        , ->
          t.commit()

    t.on 'begin', start
    t.on 'error', callback
    t.on 'commit', ->
      callback()
    t.on 'rollback', ->
      callback new Error "Could not delete project with id #{key}"